| Methods Summary |
|---|
| public PoolTcpEndpoint | getEndpoint()
return endpoint;
|
| public java.net.Socket | getSocket()
return socket;
|
| public static int | readLine(java.io.InputStream in, byte[] b, int off, int len)
if (len <= 0) {
return 0;
}
int count = 0, c;
while ((c = in.read()) != -1) {
b[off++] = (byte)c;
count++;
if (c == '\n" || count == len) {
break;
}
}
return count > 0 ? count : -1;
|
| public void | recycle()
endpoint = null;
socket = null;
|
| public void | setEndpoint(PoolTcpEndpoint endpoint)
this.endpoint = endpoint;
|
| public static void | setMaxShutdownTries(int mst)
MAX_SHUTDOWN_TRIES = mst;
|
| public void | setSocket(java.net.Socket socket)
this.socket=socket;
|
| public static void | shutdownInput(java.net.Socket socket)
try {
InputStream is = socket.getInputStream();
int available = is.available ();
int count=0;
// XXX on JDK 1.3 just socket.shutdownInput () which
// was added just to deal with such issues.
// skip any unread (bogus) bytes
while (available > 0 && count++ < MAX_SHUTDOWN_TRIES) {
is.skip (available);
available = is.available();
}
}catch(NullPointerException npe) {
// do nothing - we are just cleaning up, this is
// a workaround for Netscape \n\r in POST - it is supposed
// to be ignored
}
|
