| | |
| | | ctx.close(); |
| | | } catch (Exception e) { |
| | | |
| | | println ("INFO", "Failed: expected error code 3 "); |
| | | println("INFO", "ERROR : exception raised during first bind"); |
| | | e.printStackTrace(); |
| | | System.exit(1); |
| | | } |
| | |
| | | for (int i=0; i < nb_threads; i++ ) { |
| | | Worker w = new Worker(this, server); |
| | | } |
| | | |
| | | println ("INFO", nb_threads + " threads connected to server " + server ); |
| | | |
| | | // Wait until all the threads have initialized their context |
| | |
| | | } |
| | | } |
| | | catch ( Exception e1 ) { |
| | | System.out.println ("E1"); |
| | | println("INFO", "ERROR : exception raised when starting threads"); |
| | | e1.printStackTrace(); |
| | | } |
| | | |
| | |
| | | total_nb_srchs=0; |
| | | } |
| | | } catch ( Exception e2 ) { |
| | | System.out.println("E2"); |
| | | println("INFO", "ERROR : exception raised by the client"); |
| | | e2.printStackTrace(); |
| | | } |
| | | } |