The Tor Browser: netwerk/test/unit/test_bug470716.js@6474c204b198 (annotated)

netwerk/test/unit/test_bug470716.js@6474c204b198 (annotated)

netwerk/test/unit/test_bug470716.js

Wed, 31 Dec 2014 06:09:35 +0100

author: Michael Schloh von Bennewitz <michael@schloh.com>
date: Wed, 31 Dec 2014 06:09:35 +0100
changeset 0: 6474c204b198
permissions: -rw-r--r--

Cloned upstream origin tor-browser at tor-browser-31.3.0esr-4.5-1-build1
revision ID fc1c9ff7c1b2defdbc039f12214767608f46423f for hacking purpose.

 const CC = Components.Constructor;
 const StreamCopier = CC("@mozilla.org/network/async-stream-copier;1",
                         "nsIAsyncStreamCopier",
                         "init");
 const ScriptableInputStream = CC("@mozilla.org/scriptableinputstream;1",
                                  "nsIScriptableInputStream",
                                  "init");
 const Pipe = CC("@mozilla.org/pipe;1",
                 "nsIPipe",
                 "init");
 var pipe1;
 var pipe2;
 var copier;
 var test_result;
 var test_content;
 var test_source_closed;
 var test_sink_closed;
 var test_nr;
 var copyObserver =
 {
   onStartRequest: function(request, context) { },
   onStopRequest: function(request, cx, statusCode)
   {
     // check status code
     do_check_eq(statusCode, test_result);
     // check number of copied bytes
     do_check_eq(pipe2.inputStream.available(), test_content.length);
     // check content
     var scinp = new ScriptableInputStream(pipe2.inputStream);
     var content = scinp.read(scinp.available());
     do_check_eq(content, test_content);
     // check closed sink
     try {
       pipe2.outputStream.write("closedSinkTest", 14);
       do_check_false(test_sink_closed);
     }
     catch (ex) {
       do_check_true(test_sink_closed);
     }
     // check closed source
     try {
       pipe1.outputStream.write("closedSourceTest", 16);
       do_check_false(test_source_closed);
     }
     catch (ex) {
       do_check_true(test_source_closed);
     }
     do_timeout(0, do_test);
   },
   QueryInterface: function(aIID)
   {
     if (aIID.equals(Ci.nsIRequestObserver) ||
         aIID.equals(Ci.nsISupports))
       return this;
     throw Cr.NS_ERROR_NO_INTERFACE;
   }
 };
 function startCopier(closeSource, closeSink) {
   pipe1 = new Pipe(true       /* nonBlockingInput */,
                    true       /* nonBlockingOutput */,
 /* segmentSize */,
 xffffffff /* segmentCount */,
                    null       /* segmentAllocator */);
   pipe2 = new Pipe(true       /* nonBlockingInput */,
                    true       /* nonBlockingOutput */,
 /* segmentSize */,
 xffffffff /* segmentCount */,
                    null       /* segmentAllocator */);
   copier = new StreamCopier(pipe1.inputStream  /* aSource */,
                             pipe2.outputStream /* aSink */,
                             null               /* aTarget */,
                             true               /* aSourceBuffered */,
                             true               /* aSinkBuffered */,
 /* aChunkSize */,
                             closeSource        /* aCloseSource */,
                             closeSink          /* aCloseSink */);
   copier.asyncCopy(copyObserver, null);
 }
 function do_test() {
   test_nr++;
   test_content = "test" + test_nr;
   switch (test_nr) {
   case 1:
   case 2: // close sink
   case 3: // close source
   case 4: // close both
     // test canceling transfer
     // use some undefined error code to check if it is successfully passed
     // to the request observer
     test_result = 0x87654321;
     test_source_closed = ((test_nr-1)>>1 != 0);
     test_sink_closed = ((test_nr-1)%2 != 0);
     startCopier(test_source_closed, test_sink_closed);
     pipe1.outputStream.write(test_content, test_content.length);
     pipe1.outputStream.flush();
     do_timeout(20,
 		function(){
                copier.cancel(test_result);
                pipe1.outputStream.write("a", 1);});
     break;
   case 5:
   case 6: // close sink
   case 7: // close source
   case 8: // close both
     // test copying with EOF on source
     test_result = 0;
     test_source_closed = ((test_nr-5)>>1 != 0);
     test_sink_closed = ((test_nr-5)%2 != 0);
     startCopier(test_source_closed, test_sink_closed);
     pipe1.outputStream.write(test_content, test_content.length);
     // we will close the source
     test_source_closed = true;
     pipe1.outputStream.close();
     break;
   case 9:
   case 10: // close sink
   case 11: // close source
   case 12: // close both
     // test copying with error on sink
     // use some undefined error code to check if it is successfully passed
     // to the request observer
     test_result = 0x87654321;
     test_source_closed = ((test_nr-9)>>1 != 0);
     test_sink_closed = ((test_nr-9)%2 != 0);
     startCopier(test_source_closed, test_sink_closed);
     pipe1.outputStream.write(test_content, test_content.length);
     pipe1.outputStream.flush();
     // we will close the sink
     test_sink_closed = true;
     do_timeout(20,
 		function()
 		{
                pipe2.outputStream
                     .QueryInterface(Ci.nsIAsyncOutputStream)
                     .closeWithStatus(test_result);
                pipe1.outputStream.write("a", 1);});
     break;
   case 13:
     do_test_finished();
     break;
   }
 }
 function run_test() {
   test_nr = 0;
   do_timeout(0, do_test);
   do_test_pending();
 }