protected ConcurrentLinkedQueue<SocketWrapper<Long>> waitingRequests =
new ConcurrentLinkedQueue<SocketWrapper<Long>>();
-
+
// ------------------------------------------------------------- Properties
// Ignore
}
if (c++ > 60) {
+ log.warn(sm.getString("endpoint.warn.unlockAcceptFailed",
+ acceptors[i].getName()));
// If the Acceptor is still running force
// the hard socket close.
if (serverSock != 0) {
processSocketAsync(socket,SocketStatus.TIMEOUT);
}
}
-
+
// Loop if endpoint is paused
while (paused && running) {
try {
// Ignore
}
}
-
+
}
}
}
-
-
+
+
// ----------------------------------------------------- Poller Inner Class
/**
* Poller class.
endpoint.sendfile.addfail=Sendfile failure: [{0}] {1}
endpoint.sendfile.nosupport=Disabling sendfile, since either the APR version or the system doesn't support it
endpoint.warn.noInsecureReneg=Secure renegotation is not supported by the SSL library {0}
+endpoint.warn.unlockAcceptFailed=unlockAccept call failed for Acceptor thread [{0}]