Package dijjer.io.xfer

Examples of dijjer.io.xfer.InputStreamBlockReceiver

30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
public class InputStreamBlockReceiverTest extends TestCase {
  public void testISBR() throws Exception {
    byte[] ba1 = new byte[1000];
    ByteArrayInputStream bais = new ByteArrayInputStream(ba1);
    PartiallyReceivedBlock prb1 = new PartiallyReceivedBlock(100, 10);
    InputStreamBlockReceiver isbr1 = new InputStreamBlockReceiver(prb1, bais);
    isbr1.start();
    assertTrue(prb1.allReceived());
    byte[] ba2 = prb1.getBlock();
    for(int x=0; x<ba2.length; x++) {
      assertEquals(ba1[x], ba2[x]);
    }
   
    bais.reset();
    PartiallyReceivedBlock prb2 = new PartiallyReceivedBlock(100, 11);
    InputStreamBlockReceiver isbr2 = new InputStreamBlockReceiver(prb2, bais);
    isbr2.start();
   
    byte[] ba3 = prb2.getBlock();
    for (int x=0; x<ba1.length; x++) {
      assertEquals(ba1[x], ba3[x]);
    }
View Full Code Here
80
81
82
83
84
85
86
87
88
89
          continue;
        }
     
      //Stuff below here is only executed once
      InputStream is = uc.getInputStream();
      InputStreamBlockReceiver isrb = new InputStreamBlockReceiver(_prb, is);
      isrb.start();
      break;
    }
  }
View Full Code Here
216
217
218
219
220
221
222
223
224
225
226
    boolean cached = false;
    Logger.info("Dispatcher: Retrieving " + bi + " at ttl " + ttl);
    // See if we have it in our local store
    byte[] data = _ds.getDataForBlock(bi.getHashKey());
    if (data != null) {
      (new InputStreamBlockReceiver(prb, new ByteArrayInputStream(data))).start();
      if (requestor != null) {
        forwardData(requestor, prb, uid, forwarders, true);
      }
      return true;
    }
View Full Code Here
TOP

Related Classes of dijjer.io.xfer.InputStreamBlockReceiver

  • dijjer.io.comm.Dispatcher
  • dijjer.io.xfer.http.HttpBlockReceiver
  • dijjer.util.Buffer
  • InputStreamBlockReceiverTest
    • Copyright © 2018 www.massapicom. All rights reserved.
    All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.