this.eventSubType = eventSubType;
}
+ @Override
public void close() throws IOException {
if (request == null) {
throw new IllegalStateException(sm.getString("cometEvent.nullRequest"));
if (iscomet) request.cometClose();
}
+ @Override
public EventSubType getEventSubType() {
return eventSubType;
}
+ @Override
public EventType getEventType() {
return eventType;
}
+ @Override
public HttpServletRequest getHttpServletRequest() {
return request.getRequest();
}
+ @Override
public HttpServletResponse getHttpServletResponse() {
return response.getResponse();
}
+ @Override
public void setTimeout(int timeout) throws IOException, ServletException,
UnsupportedOperationException {
if (request.getAttribute("org.apache.tomcat.comet.timeout.support") == Boolean.TRUE) {
// -------------------- JMX registration --------------------
- private ObjectName onameProtocolHandler;
-
@Override
protected String getDomainInternal() {
return MBeanUtils.getDomain(getService());
public static final String Package = "org.apache.catalina.connector";
- public static final int DEFAULT_CONNECTION_LINGER = -1;
- public static final int DEFAULT_CONNECTION_TIMEOUT = 60000;
- public static final int DEFAULT_CONNECTION_UPLOAD_TIMEOUT = 300000;
- public static final int DEFAULT_SERVER_SOCKET_TIMEOUT = 0;
-
- public static final int PROCESSOR_IDLE = 0;
- public static final int PROCESSOR_ACTIVE = 1;
}
AccessController.doPrivileged(
new PrivilegedExceptionAction<Integer>(){
+ @Override
public Integer run() throws IOException{
Integer integer = Integer.valueOf(ib.readByte());
return integer;
AccessController.doPrivileged(
new PrivilegedExceptionAction<Integer>(){
+ @Override
public Integer run() throws IOException{
Integer integer = Integer.valueOf(ib.available());
return integer;
AccessController.doPrivileged(
new PrivilegedExceptionAction<Integer>(){
+ @Override
public Integer run() throws IOException{
Integer integer =
Integer.valueOf(ib.read(b, 0, b.length));
AccessController.doPrivileged(
new PrivilegedExceptionAction<Integer>(){
+ @Override
public Integer run() throws IOException{
Integer integer =
Integer.valueOf(ib.read(b, off, len));
AccessController.doPrivileged(
new PrivilegedExceptionAction<Void>(){
+ @Override
public Void run() throws IOException{
ib.close();
return null;
*/
protected String name = null;
+ @Override
public String getName() {
return (this.name);
}
*
* @throws IOException An underlying IOException occurred
*/
+ @Override
public int realReadBytes(byte cbuf[], int off, int len)
throws IOException {
* been read before, they are ignored. If a mark was set, then the
* mark is lost.
*/
+ @Override
public void realWriteChars(char c[], int off, int len)
throws IOException {
markPos = -1;
}
+ @Override
public int realReadChars(char cbuf[], int off, int len)
throws IOException {
conv = AccessController.doPrivileged(
new PrivilegedExceptionAction<B2CConverter>(){
+ @Override
public B2CConverter run() throws IOException {
return new B2CConverter(enc);
}
// -------------------- BufferedOutputStream compatibility
- /**
- * Real write - this buffer will be sent to the client
- */
- public void flushBytes()
- throws IOException {
-
- bb.flushBuffer();
-
- }
-
public long getContentWritten() {
return bytesWritten + charsWritten;
}