Changeset 28

Show
Ignore:
Timestamp:
03/17/06 22:38:48 (3 years ago)
Author:
atack2
Message:

Specialized this to become strictly a server. Using this and pseudoClient, we should be able to try out the scalability of this solution. Note, as in the previous changeset [27], output is a little troubling.

Files:

Legend:

Unmodified
Added
Removed
Modified
Copied
Moved

  • test_projects/pseudoServer/content/overlay.js

    r26 r28  
    1818var serverSocket = Components.classes["@mozilla.org/network/server-socket;1"] 
    1919                                                        .createInstance(Components.interfaces.nsIServerSocket); 
    20  
    21  
    22 //* 
    23 //* This is the listener for accepted connections, and it will handle 
    24 //* the passage of data 
    25 //*  
    26  
    27 var dataListener = { 
    28         contentRead : "", 
    29          
    30         onStartRequest: function(request, context)      { 
    31                 myDump("Starting receive step!"); 
    32         }, 
    33  
    34         onStopRequest: function(request, context, status)       { 
    35                 myDump("Receiving complete!"); 
    36         }, 
    37      
    38         onDataAvailable: function(request, context, inputStream, offset, count) { 
    39                 var sinput = Components.classes["@mozilla.org/scriptableinputstream;1"] 
    40                                 .createInstance(Components.interfaces.nsIScriptableInputStream); 
    41                 sinput.init(inputStream); 
    42                 var newinput = sinput.read(count); 
    43                 myDump("Data is available: " + newinput); 
    44                  
    45                 //window._content.document.open(); 
    46                 window._content.document.write(newinput + "<br /><br /><br /><br />"); 
    47                 //window._content.document.close(); 
    48         }, 
    49 }; 
    50  
    5120 
    5221//*                                                      
    …… 
    9564serverSocket.asyncListen(serverListener); 
    9665myDump("Listening!"); 
    97  
    98 var myObserver = { 
    99         observe: function(subject,topic,data){ 
    100                 subject = subject.QueryInterface(Components.interfaces.nsIHttpChannel); 
    101                 subject.setRequestHeader("Supports", "Overhaul 50 5000", false); 
    102         } 
    103 } 
    104  
    105 setTimeout('sendSomething();',1000); 
    106  
    107 function sendSomething()        { 
    108         var observerService = Components.classes["@mozilla.org/observer-service;1"] 
    109         .getService(Components.interfaces.nsIObserverService); 
    110          
    111         observerService.addObserver(myObserver,"http-on-modify-request",false); 
    112         var host="128.174.253.222"; 
    113         var port="7055"; 
    114          
    115         var transportService =Components.classes["@mozilla.org/network/socket-transport-service;1"] 
    116                                         .getService(Components.interfaces.nsISocketTransportService); 
    117         var cliantSocket = transportService.createTransport(null,0,host,port,null); 
    118         var outstream = cliantSocket.openOutputStream(0,0,0); 
    119          
    120         var sendingMessage="Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!Overhaul!TAKA IS AWESOME!<br /> <br />"; 
    121         outstream.write(sendingMessage,sendingMessage.length); 
    122          
    123          
    124         var sendingMessage="GET /file.html CHUNK <#> HTTP\1.0\n\n"; 
    125         outstream.write(sendingMessage,sendingMessage.length); 
    126          
    127         var sendingSecondMessage="HOST localhost\n\n"; 
    128         outstream.write(sendingSecondMessage,sendingSecondMessage.length); 
    129          
    130         var sendingPortMessage="Overhaul-port: <7055>\n\n"; 
    131         outstream.write(sendingPortMessage,sendingPortMessage.length); 
    132          
    133         var sendingHostsPortMessage="Overhaul-hosts: <localhost:7055>\n\n"; 
    134         outstream.write(sendingHostsPortMessage,sendingHostsPortMessage.length); 
    135          
    136         var sendingChunkMessage="Overhaul-hosts: <CHUNKDATA>\n\n"; 
    137         outstream.write(sendingChunkMessage,sendingChunkMessage.length); 
    138          
    139         var listener = { 
    140                 finished : function(data){ 
    141                 dump(data); 
    142                 } 
    143         }    
    144         var stream = cliantSocket.openInputStream(0,0,0); 
    145         var instream = Components.classes["@mozilla.org/scriptableinputstream;1"] 
    146           .createInstance(Components.interfaces.nsIScriptableInputStream); 
    147         instream.init(stream); 
    148         var dataListener2 = { 
    149                 data : "",   
    150                 onStartRequest: function(request, context){}, 
    151                 onStopRequest: function(request, context, status){ 
    152                 instream.close(); 
    153                 listener.finished(this.data); 
    154                 myDump(this.data); 
    155                 outstream.write(this.data,this.data.length); 
    156                 outstream.close(); 
    157           }, 
    158                 onDataAvailable: function(request, context, inputStream, offset, count){ 
    159                 this.data += instream.read(count); 
    160           } 
    161         }; 
    162          
    163          
    164         var pump = Components.classes["@mozilla.org/network/input-stream-pump;1"]. 
    165                 createInstance(Components.interfaces.nsIInputStreamPump); 
    166         pump.init(stream, -1, -1, 0, 0, true); 
    167         pump.asyncRead(dataListener2,null); 
    168          
    169         // window._content.document.open(); 
    170                 window._content.document.write("HI!\n"); 
    171         //      window._content.document.close(); 
    172          
    173         setTimeout('sendSomething();',5000); 
    174 }