Start line:  
End line:  

Snippet Preview

Snippet HTML Code

Stack Overflow Questions
  /*
   * Licensed to the Apache Software Foundation (ASF) under one or more
   * contributor license agreements.  See the NOTICE file distributed with
   * this work for additional information regarding copyright ownership.
   * The ASF licenses this file to You under the Apache License, Version 2.0
   * (the "License"); you may not use this file except in compliance with
   * the License.  You may obtain a copy of the License at
   *
   *     http://www.apache.org/licenses/LICENSE-2.0
  *
  * Unless required by applicable law or agreed to in writing, software
  * distributed under the License is distributed on an "AS IS" BASIS,
  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
 package org.apache.jackrabbit.mk.test;
 
 import org.junit.Test;
Test the data store using the MicroKernel API.
 
 public class DataStoreIT extends AbstractMicroKernelIT {
 
     public DataStoreIT(MicroKernelFixture fixture) {
         super(fixture, 1);
     }
 
     @Test
     public void small() throws IOException {
         doTest(10, 10);
     }
 
     @Test
     public void medium() throws IOException {
         doTest(1000, 10);
     }
 
     @Test
     public void large() throws IOException {
         doTest(1000000, 1);
     }
 
     private void doTest(int maxLengthint countthrows IOException {
         String[] s = new String[count * 2];
         Random r = new Random(0);
         for (int i = 0; i < s.length;) {
             int len = count == 1 ? maxLength : r.nextInt(maxLength);
             byte[] data = new byte[len];
             r.nextBytes(data);
             s[i++] = .write(new ByteArrayInputStream(data));
             s[i++] = .write(new ByteArrayInputStream(data));
         }
         r.setSeed(0);
         for (int i = 0; i < s.length;) {
             int len = count == 1 ? maxLength : r.nextInt(maxLength);
             byte[] expectedData = new byte[len];
             r.nextBytes(expectedData);
             Assert.assertEquals(len.getLength(s[i++]));
 
             String id = s[i++];
             doTestReadFully(expectedDatalenid);
             doTestRead(expectedDatalenid);
         }
     }
 
     private void doTestReadFully(byte[] expectedDataint expectedLenString idthrows IOException {
         byte[] got = MicroKernelInputStream.readFully(id);
         assertByteArrayEquals(expectedDataexpectedLengot);
     }
 
     private void assertByteArrayEquals(byte[] expectedint expectedLenbyte[] got) {
         Assert.assertEquals(expectedLengot.length);
         for (int j = 0; j < expectedLenj++) {
             if (expected[j] != got[j]) {
                 Assert.assertEquals("j:" + jexpected[j], got[j]);
             }
         }
     }
 
     private void doTestRead(byte[] expectedDataint expectedLenString idthrows IOException {
         InputStream in = new MicroKernelInputStream(id);
         Random r = new Random(1);
         ByteArrayOutputStream buff = new ByteArrayOutputStream();
         int minLen = 0;
         if (expectedLen > 1000000) {
             minLen = 4000;
         }
        while (true) {
            int op = r.nextInt(3);
            if (op == 0) {
                int x = in.read();
                if (x < 0) {
                    break;
                }
                buff.write(x);
            } else if (op == 1) {
                byte[] x = new byte[minLen + r.nextInt(5000)];
                int l = in.read(x);
                if (l < 0) {
                    break;
                }
                buff.write(x, 0, l);
            } else {
                int offset = r.nextInt(10);
                int len = minLen + r.nextInt(1000);
                byte[] x = new byte[offset + len];
                int l = in.read(xoffsetlen);
                if (l < 0) {
                    break;
                }
                buff.write(xoffsetl);
            }
        }
        byte[] got = buff.toByteArray();
        assertByteArrayEquals(expectedDataexpectedLengot);
    }
New to GrepCode? Check out our FAQ X