Changeset 16


Ignore:
Timestamp:
Aug 13, 2012 2:32:42 PM (5 years ago)
Author:
psaiteja
Message:

removed unnecessary commented code, and made minor changes to the code to prevent handling null objects.

File:
1 edited

Legend:

Unmodified
Added
Removed
  • VSNClient/appClientModule/jProxy.java

    r15 r16  
    394394                                                Statement stmt2 = conn.createStatement(); 
    395395                                                ResultSet rs = stmt2.executeQuery("select * from ClientHashlist where UrlHash='"+urldigest+"'"); 
    396                                                 int num = 0; 
    397396                                                if (rs.next()) { 
    398397                                                        server = new Socket(hostName, hostPort); 
    399398                                                        contacted_origin = true; 
    400399                                                        toVSN = false; 
    401                                                         System.out.println("to origin server:"); 
     400                                                        System.out.println("to origin server:"+host+url); 
    402401                                                } else { 
    403402                                                        if ((fwdServer.length() > 0) && (fwdPort > 0)) 
    404403                                                        { 
    405                                                                 System.out.println("to VSN:"); 
     404                                                                System.out.println("to VSN:"+host+url); 
    406405                                                                toVSN = true; 
    407406                                                                server = new Socket(fwdServer, fwdPort); 
    408407                                                        }  else  { 
    409                                                                 System.out.println("to origin server (2):"); 
     408                                                                System.out.println("to origin server (2):"+host+url); 
    410409                                                                server = new Socket(hostName, hostPort); 
    411410                                                                contacted_origin = true; 
     
    476475                                         
    477476                                        if(responseLength==-2){ 
    478                                                 System.out.println("Got redirected by VSN server"); 
     477                                                System.out.println("Got redirected by VSN server:"+host+url); 
    479478                                                PreparedStatement psInsert = conn.prepareStatement("insert into ClientHashlist values (?,?,?)"); 
    480479                                                psInsert.setString(1, VSNurldigest.toString()); 
     
    501500                                                         
    502501                                                        responseLength = streamHTTPData2(redirect_serverIn, clientOut,host,url, true,toVSN,VSNurldigest,VSNobjectdigest); 
     502                                                         
     503                                                        redirect_serverIn.close(); 
     504                                                        redirect_serverOut.close(); 
     505                                                        redirect_socket.close(); 
    503506                                                } 
    504                                                 redirect_socket.close(); 
    505507                                        } 
    506508                                        if(responseLength==-3){ 
    507                                                 System.out.println("Hash did not match"); 
     509                                                System.out.println("Hash did not match:"+host+url); 
    508510                                                Socket third_socket = null; 
    509511                                                try {            
     
    537539                                                         
    538540                                                        responseLength = streamHTTPData2(third_serverIn, clientOut,host,url, true,toVSN,VSNurldigest,VSNobjectdigest); 
     541                                                         
     542                                                        third_serverIn.close(); 
     543                                                        third_serverOut.close(); 
     544                                                        third_socket.close(); 
    539545                                                } 
    540                                                 third_socket.close(); 
    541546                                        } 
    542547                                } 
     
    553558                                serverOut.close(); 
    554559                        } 
    555                          
    556                         // send the response back to the client, if we haven't already 
    557                         //if (debugLevel > 1){ 
    558                         //      clientOut.write(response, 0, responseLength); 
    559                         //      clientOut.flush(); 
    560                         //} 
    561                          
    562560                         
    563561                        // if the user wants debug info, send them debug info; however, 
     
    576574                                debugOut.flush(); 
    577575                        } 
    578 //                      if (debugLevel > 1) 
    579 //                      { 
    580 //                              debugOut.println("REQUEST:\n" + (new String(request))); 
    581 //                              debugOut.println("RESPONSE:\n" + (new String(response))); 
    582 //                              debugOut.flush(); 
    583 //                      } 
    584576                         
    585577                        // close all the client streams so we can listen again 
     
    762754                int byteCount = 0; 
    763755                ByteArrayOutputStream bs = new ByteArrayOutputStream(); 
    764                 String received_urldigest = ""; 
    765                 String received_objectdigest = ""; 
    766756                 
    767757                try 
     
    771761                        if (data != null) 
    772762                        { 
    773                                 header.append(data + "\r\n"); 
    774763                                pos = data.indexOf(" "); 
    775764                                if ((data.toLowerCase().startsWith("http")) && (pos >= 0) && (data.indexOf(" ", pos+1) >= 0)) 
     
    794783                                        return -2; 
    795784                                } 
     785                                header.append(data + "\r\n"); 
    796786                        } 
    797787                         
     
    804794                                header.append(data + "\r\n"); 
    805795                                 
    806                                 // check for the Host header 
    807                                 pos = data.toLowerCase().indexOf("host:"); 
    808                                 if (pos >= 0) 
    809                                 { 
    810                                         host.setLength(0); 
    811                                         host.append(data.substring(pos + 5).trim()); 
    812                                 } 
     796//                              // check for the Host header 
     797//                              pos = data.toLowerCase().indexOf("host:"); 
     798//                              if (pos >= 0) 
     799//                              { 
     800//                                      host.setLength(0); 
     801//                                      host.append(data.substring(pos + 5).trim()); 
     802//                              } 
    813803                                 
    814804                                // check for the Content-Length header 
     
    821811                                if (pos >= 0) 
    822812                                        contentType = data.substring(pos + 13).trim(); 
    823                                  
    824                                 if(data.toLowerCase().indexOf("VSNurldigest:")>=0) 
    825                                         received_urldigest = data.substring(13).trim(); 
    826                                 if(data.toLowerCase().indexOf("VSNobjectdigest:")>=0) 
    827                                         received_objectdigest = data.substring(16).trim(); 
    828813                        } 
    829814                         
     
    890875                                                                        System.out.println("computing and checking response hash"); 
    891876                                                                        byte [] response = bs.toByteArray(); 
    892                                                                          
    893                                                                         MessageDigest sha1 = MessageDigest.getInstance("SHA-1"); 
    894                                                                                                                                                  
    895                                                                         //sha1.update(response, 0, response.length); 
     877                                                                        MessageDigest sha1 = MessageDigest.getInstance("SHA-1");                                                         
    896878                                                                        byte [] obdigest = sha1.digest(response); 
    897879                                                                        sha1.reset(); 
    898                                                                         //sha1.update(url_string.getBytes(), 0, 
    899                                                                         //              url_string.length()); 
     880                                                                         
    900881                                                                        byte [] udigest = sha1.digest((host.toString()+url.toString()).getBytes()); 
    901882                                                                         
     
    910891                                                                        urldigest.append(Integer.toHexString(0xFF & udigest[i])); 
    911892                                                                } 
    912                                                                  
    913                                                                 //System.out.println(url.toString()); 
    914                                                                         //System.out.println("Digests: " + urldigest + " : " 
    915                                                                         //              + objectdigest); 
    916893                                                                         
    917894                                                                        try {            
     
    932909                                                                                        } 
    933910                                                                                        else if(rs.getString(2).equalsIgnoreCase(objectdigest.toString())){ 
     911                                                                                                System.out.println("Hash match:"+host+url); 
    934912                                                                                                if(!wroteheader){ 
    935913                                                                                                        // convert the header to a byte array, and write it to our stream 
     
    958936                                                                        } catch (Exception e) { 
    959937                                                                                e.printStackTrace(); 
    960                                                                         } 
    961  
    962 //                                                              if(!toVSN){ 
    963 //                                                                      out.write(bs.toByteArray(), 0, bs.size()); 
    964 //                                                                              out.flush(); 
    965 //                                                              }                                
     938                                                                        }                        
    966939                                                                } 
    967940                                                        } 
Note: See TracChangeset for help on using the changeset viewer.