Changeset 30


Ignore:
Timestamp:
Aug 22, 2012 2:04:58 PM (5 years ago)
Author:
psaiteja
Message:

Added debug statements and corrected an error in getting client IP address from the HTTP web request socket.

File:
1 edited

Legend:

Unmodified
Added
Removed
  • VSNServer/src/ServerProxy.java

    r28 r30  
    226226                                        System.out.println("Client database Table does not exist"); 
    227227                                        Statement stmt = conn.createStatement(); 
    228                                         stmt.executeUpdate("CREATE TABLE ClientDatabase (IP VARCHAR(15) NOT NULL PRIMARY KEY, Port INT DEFAULT "+(DEFAULT_UDP_PORT-1)+", Added TIMESTAMP NOT NULL)"); 
     228                                        stmt.executeUpdate("CREATE TABLE ClientDatabase (IP VARCHAR(15) NOT NULL, Port INT DEFAULT "+(DEFAULT_UDP_PORT-1)+", Added TIMESTAMP NOT NULL, PRIMARY KEY (IP, Port))"); 
    229229                                        Statement stmt2 = conn.createStatement(); 
    230                                         stmt2.executeUpdate("CREATE INDEX IPIndex on ClientDatabase(IP ASC)"); 
     230                                        stmt2.executeUpdate("CREATE INDEX IPIndex on ClientDatabase(IP ASC, Port ASC)"); 
    231231                                } 
    232232                        } catch (SQLException e) { 
     
    235235                                        conn = DriverManager.getConnection("jdbc:derby:serverdatabase;create=true"); 
    236236                                        Statement stmt = conn.createStatement(); 
    237                                         stmt.executeUpdate("CREATE TABLE ClientDatabase (IP VARCHAR(15) NOT NULL PRIMARY KEY, Port INT DEFAULT "+(DEFAULT_UDP_PORT-1)+", Added TIMESTAMP NOT NULL)"); 
     237                                        stmt.executeUpdate("CREATE TABLE ClientDatabase (IP VARCHAR(15) NOT NULL, Port INT DEFAULT "+(DEFAULT_UDP_PORT-1)+", Added TIMESTAMP NOT NULL, PRIMARY KEY (IP, Port))"); 
    238238                                        Statement stmt2 = conn.createStatement(); 
    239                                         stmt2.executeUpdate("CREATE INDEX IPIndex on ClientDatabase(IP ASC)"); 
     239                                        stmt2.executeUpdate("CREATE INDEX IPIndex on ClientDatabase(IP ASC, Port ASC)"); 
    240240                                } else 
    241241                                        e.printStackTrace(); 
     
    248248                         
    249249                        try{ 
    250                                 System.out.println("Starting UDP server"); 
     250                                System.out.println("Starting UDP server on port"+UDPport); 
    251251                                udpthread = new UDPServerThread(UDPport,conn,m_threshold); 
    252252                                udpthread.start(); 
     
    263263                        { 
    264264                                Socket client = server.accept(); 
    265                                 String clientip = client.getInetAddress().toString(); 
     265                                String clientip = client.getInetAddress().getHostAddress(); 
     266                                int clientport = client.getPort(); 
    266267                                try {            
    267268                                        Statement stmt2 = conn.createStatement(); 
    268                                         ResultSet rs = stmt2.executeQuery("select * from ClientDatabase where IP='"+clientip+"'"); 
     269                                        ResultSet rs = stmt2.executeQuery("select * from ClientDatabase where IP='"+clientip+"' AND Port="+clientport); 
    269270                                        if (rs.next()) { 
    270                                                 System.out.println("Client entry exists -  IP: " + rs.getString(1)); 
     271                                                System.out.println("Client entry exists - IP: " + rs.getString(1)+" Port:"+rs.getInt(2)); 
    271272                                        } else { 
    272273                                                PreparedStatement psInsert = conn.prepareStatement("insert into ClientDatabase values (?,?,?)"); 
     
    342343                                String IPAddress = receivePacket.getAddress().getHostAddress();  
    343344                                int port = receivePacket.getPort();  
    344                                  
     345                                System.out.println("Received UDP 'Hello' request from IP:"+IPAddress+" Port:"+port); 
    345346                                try {            
    346347                                        Statement stmt = database_conn.createStatement(); 
    347                                         ResultSet rs = stmt.executeQuery("select * from ClientDatabase where IP='"+IPAddress+"'"); 
     348                                        ResultSet rs = stmt.executeQuery("select * from ClientDatabase where IP='"+IPAddress+"' AND Port="+port); 
    348349                                        if (! rs.next()) { 
    349350                                                PreparedStatement psInsert = database_conn.prepareStatement("insert into ClientDatabase values (?,?,?)"); 
     
    355356 
    356357                                                psInsert.executeUpdate(); 
    357                                                  
     358                                                System.out.println("Inserted into ClientDatabase IP:"+IPAddress+" Port:"+port); 
    358359                                                sendoldhashes(IPAddress, port); 
    359360                                        } 
    360361                                        rs.close(); 
     362                                         
    361363                                } catch (SQLException e) { 
    362364                                        System.out.println("Unable to add client details for the UDP packet with IP:"+IPAddress+" port:"+port); 
Note: See TracChangeset for help on using the changeset viewer.