Changeset 31


Ignore:
Timestamp:
Aug 24, 2012 2:38:52 PM (5 years ago)
Author:
psaiteja
Message:

corrected an error in adding entries to client database.

File:
1 edited

Legend:

Unmodified
Added
Removed
  • VSNServer/src/ServerProxy.java

    r30 r31  
    248248                         
    249249                        try{ 
    250                                 System.out.println("Starting UDP server on port"+UDPport); 
    251250                                udpthread = new UDPServerThread(UDPport,conn,m_threshold); 
    252251                                udpthread.start(); 
     
    259258                                return; 
    260259                        } 
     260                         
     261                        System.out.println("Started UDP server on port "+UDPport); 
    261262                         
    262263                        while (true) 
     
    264265                                Socket client = server.accept(); 
    265266                                String clientip = client.getInetAddress().getHostAddress(); 
    266                                 int clientport = client.getPort(); 
    267267                                try {            
    268268                                        Statement stmt2 = conn.createStatement(); 
    269                                         ResultSet rs = stmt2.executeQuery("select * from ClientDatabase where IP='"+clientip+"' AND Port="+clientport); 
    270                                         if (rs.next()) { 
    271                                                 System.out.println("Client entry exists - IP: " + rs.getString(1)+" Port:"+rs.getInt(2)); 
    272                                         } else { 
     269                                        ResultSet rs = stmt2.executeQuery("select * from ClientDatabase where IP='"+clientip+"'"); 
     270                                        if (!rs.next()) { 
     271                                                //System.out.println("Client entry exists - IP: " + rs.getString(1)+" Port:"+rs.getInt(2)); 
     272                                        //} else { 
    273273                                                PreparedStatement psInsert = conn.prepareStatement("insert into ClientDatabase values (?,?,?)"); 
    274274 
     
    279279 
    280280                                                psInsert.executeUpdate(); 
     281                                                System.out.println("Added client database entry with ip:"+clientip+" port:"+(DEFAULT_UDP_PORT-1)); 
    281282                                                 
    282283                                                udpthread.sendoldhashes(clientip, DEFAULT_UDP_PORT-1); 
Note: See TracChangeset for help on using the changeset viewer.