Changeset 22

Show
Ignore:
Timestamp:
02/25/06 13:50:20 (3 years ago)
Author:
atack2
Message:

Set the outgoing message to loop infinitely @ 1s. This should be good for our test farm.

Files:

Legend:

Unmodified
Added
Removed
Modified
Copied
Moved

  • test_projects/pseudoServer/content/overlay.js

    r21 r22  
    9898} 
    9999 
    100 var observerService = Components.classes["@mozilla.org/observer-service;1"] 
    101 .getService(Components.interfaces.nsIObserverService); 
     100setTimeout('sendSomething();',1000); 
    102101 
    103 observerService.addObserver(myObserver,"http-on-modify-request",false); 
    104 var host="128.174.253.222"; 
    105 var port="7055"; 
    106  
    107 var transportService =Components.classes["@mozilla.org/network/socket-transport-service;1"] 
    108                                 .getService(Components.interfaces.nsISocketTransportService); 
    109 var cliantSocket = transportService.createTransport(null,0,host,port,null); 
    110 var outstream = cliantSocket.openOutputStream(0,0,0); 
    111 var sendingMessage="GET /file.html CHUNK <#> HTTP\1.0\n\n"; 
    112 outstream.write(sendingMessage,sendingMessage.length); 
    113  
    114 var sendingSecondMessage="HOST localhost\n\n"; 
    115 outstream.write(sendingSecondMessage,sendingSecondMessage.length); 
    116  
    117 var sendingPortMessage="Overhaul-port: <7055>\n\n"; 
    118 outstream.write(sendingPortMessage,sendingPortMessage.length); 
    119  
    120 var sendingHostsPortMessage="Overhaul-hosts: <localhost:7055>\n\n"; 
    121 outstream.write(sendingHostsPortMessage,sendingHostsPortMessage.length); 
    122  
    123 var sendingChunkMessage="Overhaul-hosts: <CHUNKDATA>\n\n"; 
    124 outstream.write(sendingChunkMessage,sendingChunkMessage.length); 
    125  
    126 var listener = { 
    127         finished : function(data){ 
    128         dump(data); 
    129         } 
    130 }    
    131 var stream = cliantSocket.openInputStream(0,0,0); 
    132 var instream = Components.classes["@mozilla.org/scriptableinputstream;1"] 
    133   .createInstance(Components.interfaces.nsIScriptableInputStream); 
    134 instream.init(stream); 
    135 var dataListener2 = { 
    136         data : "",   
    137         onStartRequest: function(request, context){}, 
    138         onStopRequest: function(request, context, status){ 
    139         instream.close(); 
    140         listener.finished(this.data); 
    141         alert(this.data); 
    142         outstream.write(this.data,this.data.length); 
    143         outstream.close(); 
    144   }, 
    145         onDataAvailable: function(request, context, inputStream, offset, count){ 
    146         this.data += instream.read(count); 
    147   } 
    148 }; 
    149  
    150  
    151 var pump = Components.classes["@mozilla.org/network/input-stream-pump;1"]. 
    152         createInstance(Components.interfaces.nsIInputStreamPump); 
    153 pump.init(stream, -1, -1, 0, 0, true); 
    154 pump.asyncRead(dataListener2,null); 
     102function sendSomething()        { 
     103        var observerService = Components.classes["@mozilla.org/observer-service;1"] 
     104        .getService(Components.interfaces.nsIObserverService); 
     105         
     106        observerService.addObserver(myObserver,"http-on-modify-request",false); 
     107        var host="128.174.253.25"; 
     108        var port="7055"; 
     109         
     110        var transportService =Components.classes["@mozilla.org/network/socket-transport-service;1"] 
     111                                        .getService(Components.interfaces.nsISocketTransportService); 
     112        var cliantSocket = transportService.createTransport(null,0,host,port,null); 
     113        var outstream = cliantSocket.openOutputStream(0,0,0); 
     114        var sendingMessage="GET /file.html CHUNK <#> HTTP\1.0\n\n"; 
     115        outstream.write(sendingMessage,sendingMessage.length); 
     116         
     117        var sendingSecondMessage="HOST localhost\n\n"; 
     118        outstream.write(sendingSecondMessage,sendingSecondMessage.length); 
     119         
     120        var sendingPortMessage="Overhaul-port: <7055>\n\n"; 
     121        outstream.write(sendingPortMessage,sendingPortMessage.length); 
     122         
     123        var sendingHostsPortMessage="Overhaul-hosts: <localhost:7055>\n\n"; 
     124        outstream.write(sendingHostsPortMessage,sendingHostsPortMessage.length); 
     125         
     126        var sendingChunkMessage="Overhaul-hosts: <CHUNKDATA>\n\n"; 
     127        outstream.write(sendingChunkMessage,sendingChunkMessage.length); 
     128         
     129        var listener = { 
     130                finished : function(data){ 
     131                dump(data); 
     132                } 
     133        }    
     134        var stream = cliantSocket.openInputStream(0,0,0); 
     135        var instream = Components.classes["@mozilla.org/scriptableinputstream;1"] 
     136          .createInstance(Components.interfaces.nsIScriptableInputStream); 
     137        instream.init(stream); 
     138        var dataListener2 = { 
     139                data : "",   
     140                onStartRequest: function(request, context){}, 
     141                onStopRequest: function(request, context, status){ 
     142                instream.close(); 
     143                listener.finished(this.data); 
     144                alert(this.data); 
     145                outstream.write(this.data,this.data.length); 
     146                outstream.close(); 
     147          }, 
     148                onDataAvailable: function(request, context, inputStream, offset, count){ 
     149                this.data += instream.read(count); 
     150          } 
     151        }; 
     152         
     153         
     154        var pump = Components.classes["@mozilla.org/network/input-stream-pump;1"]. 
     155                createInstance(Components.interfaces.nsIInputStreamPump); 
     156        pump.init(stream, -1, -1, 0, 0, true); 
     157        pump.asyncRead(dataListener2,null); 
     158         
     159        setTimeout('sendSomething();',5000); 
     160}