From b103e07a14524d66f1a67d6f3041e85a57948cde Mon Sep 17 00:00:00 2001 From: fhanik Date: Fri, 15 Jun 2007 21:35:57 +0000 Subject: [PATCH] fix formatting for latest added example git-svn-id: https://svn.apache.org/repos/asf/tomcat/trunk@547794 13f79535-47bb-0310-9956-ffa450edef68 --- webapps/docs/aio.xml | 15 ++++++++++----- 1 file changed, 10 insertions(+), 5 deletions(-) diff --git a/webapps/docs/aio.xml b/webapps/docs/aio.xml index ac695320a..65f9bd5b9 100644 --- a/webapps/docs/aio.xml +++ b/webapps/docs/aio.xml @@ -309,7 +309,8 @@ public class ExampleDelayedAjaxResponse implements CometProcessor { if (event.isWriteable()) { //did we write it all? event.close(); //close the event, in anticipation of the next request event.register(OP_CALLBACK); //triggers an END event - } else { //we didn't write it all, trigger a WRITE event when we are done with the write event.register(OP_WRITE); + } else { //we didn't write it all, trigger a WRITE event when we are done with the write + event.register(OP_WRITE); } } else { //we are not able to write, let us know when we can @@ -329,7 +330,8 @@ public class ExampleDelayedAjaxResponse implements CometProcessor { if ( event.getEventType() == CometEvent.EventType.BEGIN ) { //configure non blocking event.configureBlocking(false); - //deregister for READ since we want to enable pipe lining on the connection //for the next HTTP request + //deregister for READ since we want to enable pipe lining on the connection + //for the next HTTP request event.unregister(OP_READ); //add the client to the list clients.add(event); @@ -349,7 +351,8 @@ public class ExampleDelayedAjaxResponse implements CometProcessor { event.close(); } } if ( event.getEventType() == CometEvent.EventType.END ) { - clients.remove(event); } else if (...) { + clients.remove(event); + } else if (...) { ... } ... @@ -383,7 +386,8 @@ public class ExampleDelayedAjaxResponse implements CometProcessor { if ( event.getEventType() == CometEvent.EventType.BEGIN ) { //configure blocking event.configureBlocking(true); - //deregister for READ since we want to enable pipe lining on the connection //for the next HTTP request + //deregister for READ since we want to enable pipe lining on the connection + //for the next HTTP request event.unregister(OP_READ); //add the client to the list clients.add(event); @@ -395,7 +399,8 @@ public class ExampleDelayedAjaxResponse implements CometProcessor { //unregister from the write event event.unregister(OP_WRITE); //we can now write - byte[] data = getDelayedResponse(event); //note we don't have to check for null data here + byte[] data = getDelayedResponse(event); + //note we don't have to check for null data here event.getHttpServletResponse().getOutputStream().write(data); event.close(); } if ( event.getEventType() == CometEvent.EventType.END ) { -- 2.11.0