private void stopIn ( ) throws IOException { if ( inClosed ) { return ; } inClosed = true ; LOG . log ( Level . FINE , "Shutting down socket for input" ) ; // unblock all waiting readers setEof ( ) ; // signal orchestrator thread it is ok to quit now as there will be no more input synchronized ( orchestratorEvent ) { shutdown = true ; orchestratorEvent . notifyAll ( ) ; } // close socket for input - that will cause readExecutor to throw EOFException // and exit orchestrator thread main loop; client can still write to the socket socket . shutdownInput ( ) ; }
Stop the thread reading stdin from the NailGun client