Changeset 50

Timestamp:

04/22/06 14:48:01 (2 years ago)

Author:

tueda2

Message:

Basic function : overhaul handler

Files:

• trunk/overhaul_handler.js (modified) (1 diff)

trunk/overhaul_handler.js

@@ -7 +7 @@
-//*     process and displaying the web page to the user.
-//*
-
+
+
-        var self = this;
+        
+        // counter for the raw datas
+        var i;
+        
+        //raw data(unmodified)
+        var receivedDataArray=new Array();
+        
+        //modified data
+        //please WAIT!!
+        
+        var availableList=new Array();
+        
+        //get double array which client have which chunks
+        var info= new overhaul_info(clientHostArray,clientPortArray, url, this);
+        info.sendInfoRequests();
+        
+        //loop until all of the data get
+        for(i=0;i<numChunk;i++){
+                if(chunks_held[i]!=null){
+                        receivedDataArray[i]=chunks_held[i];
+                        break;
+                }
+                else{
+                        
+                        var host=null;
+                        var port=null;
+                        var k=0
+                        
+                        while((host==null)||k<2){       //while loop begins
+                                //get available host from the bottom
+                                var j=availableList.size()-1;
+                                for(;j>=0;j--){
+                                        if(availableList[j][i]==1){
+                                                host=clientHostArray[j];
+                                                port=clientPortArray[j];
+                                                break;
+                                        }
+                                }
+                                if(host==null){
+                                        availableList=overhaul_info(clientHostArray,clientPortArray);
+                                }
+                                k++;
+                        }//while loop ends
+
+                        if((host!=null)||(port!=null)){
+                        
+                                //Opensockets
+                                var transportService =Components.classes["@mozilla.org/network/socket-transport-service;1"]
+                                                        .getService(Components.interfaces.nsISocketTransportService);
+                                var cliantSocket = transportService.createTransport(null,0,host,port,null);
+                                //Open output stream
+                                var outstream = cliantSocket.openOutputStream(0,0,0);
+                                
+                                //filename: the file want to get
+                                //numChunk: the number of the chunk data which is wanted
+                                var sendingMessage="GET "+filename+" CHUNK "+numChunk+" HTTP\1.0\n\n";
+                                                outstream.write(sendingMessage,sendingMessage.length);
+        
+                                //myHost: my IP address
+                                var sendingSecondMessage="HOST "+myHost+"\n\n";
+                                                outstream.write(sendingSecondMessage,sendingSecondMessage.length);
+        
+                                //myPort: my port address
+                                var sendingPortMessage="Overhaul-port: "+myPort+"\n\n";
+                                                outstream.write(sendingPortMessage,sendingPortMessage.length);
+        
+                                //theHostList: the host and port list which this client has
+                                var sendingHostsPortMessage="Overhaul-hosts: "+theHostList+"\n\n";
+                                                outstream.write(sendingHostsPortMessage,sendingHostsPortMessage.length);
+        
+                                //thisChunkData: the chunk data which want to send
+                                var sendingChunkMessage="Overhaul-hosts: "+thisChunkData+"\n\n";
+                                                outstream.write(sendingChunkMessage,sendingChunkMessage.length);
+        
+                                //Open inputStream
+                                var stream = cliantSocket.openInputStream(0,0,0);
+                                var instream = Components.classes["@mozilla.org/scriptableinputstream;1"]
+                                                .createInstance(Components.interfaces.nsIScriptableInputStream);
+                                instream.init(stream);
+
+                                var pump = Components.classes["@mozilla.org/network/input-stream-pump;1"].
+                                                createInstance(Components.interfaces.nsIInputStreamPump);
+                                pump.init(stream, -1, -1, 0, 0, true);
+                                pump.asyncRead(dataListener,null);
+                        
+                        else{
+                                throw "Error";
+                        }
+                }
+        }
+        //loop ends (here this function already holds entire data in the Array "")
+
+        var final="";
+        for(int i=0;receivedDataArray.size();i++){
+                final+=receivedDataArray[i];
+        }
+        window._content.document.write(final);
+
+
+        //*
+        //* This is the listener for accepted connections, and it will handle
+        //* the passage of data
+        //* 
+
+        var dataListener = {    
+                onStartRequest: function(request, context)      {
+                                },
+                onStopRequest: function(request, context, status)       {
+                                },
+                onDataAvailable: function(request, context, inputStream, offset, count) {
+                        var sinput = Components.classes["@mozilla.org/scriptableinputstream;1"]
+                                        .createInstance(Components.interfaces.nsIScriptableInputStream);
+                sinput.init(inputStream);
+                receivedDataArray[i]+= sinput.read(count);
+                },
+        };
+
-}
+
+overhaul_handler.prototype={
+                updateRows : function(row, number){
+                        this.availableList[number]=row;
+                }
+}
+