@@ -245,9 +245,9 @@ public void start() {
245245
246246 _connection .start ();
247247 while (!_connection .isStartup ()) {
248- _shell .getBackoffAlgorithm ().waitBeforeRetry ();
249- _connection = new NioClient ("Agent" , _shell .getHost (), _shell .getPort (), _shell .getWorkers (), this );
250- _connection .start ();
248+ _shell .getBackoffAlgorithm ().waitBeforeRetry ();
249+ _connection = new NioClient ("Agent" , _shell .getHost (), _shell .getPort (), _shell .getWorkers (), this );
250+ _connection .start ();
251251 }
252252 }
253253
@@ -495,7 +495,7 @@ protected void processRequest(final Request request, final Link link) {
495495 _reconnectAllowed = false ;
496496 answer = new Answer (cmd , true , null );
497497 } else if (cmd instanceof MaintainCommand ) {
498- s_logger .debug ("Received maintainCommand" );
498+ s_logger .debug ("Received maintainCommand" );
499499 cancelTasks ();
500500 _reconnectAllowed = false ;
501501 answer = new MaintainAnswer ((MaintainCommand )cmd );
@@ -820,17 +820,17 @@ public synchronized void run() {
820820 }
821821
822822 public class AgentRequestHandler extends Task {
823- public AgentRequestHandler (Task .Type type , Link link , Request req ) {
823+ public AgentRequestHandler (Task .Type type , Link link , Request req ) {
824824 super (type , link , req );
825825 }
826826
827- @ Override
828- protected void doTask (Task task ) throws Exception {
829- Request req = (Request )this .get ();
830- if (!(req instanceof Response )) {
831- processRequest (req , task .getLink ());
832- }
833- }
827+ @ Override
828+ protected void doTask (Task task ) throws Exception {
829+ Request req = (Request )this .get ();
830+ if (!(req instanceof Response )) {
831+ processRequest (req , task .getLink ());
832+ }
833+ }
834834 }
835835
836836 public class ServerHandler extends Task {
@@ -853,12 +853,12 @@ public void doTask(final Task task) {
853853 try {
854854 request = Request .parse (task .getData ());
855855 if (request instanceof Response ) {
856- //It's for pinganswer etc, should be processed immediately.
856+ //It's for pinganswer etc, should be processed immediately.
857857 processResponse ((Response ) request , task .getLink ());
858858 } else {
859- //put the requests from mgt server into another thread pool, as the request may take a longer time to finish. Don't block the NIO main thread pool
859+ //put the requests from mgt server into another thread pool, as the request may take a longer time to finish. Don't block the NIO main thread pool
860860 //processRequest(request, task.getLink());
861- _executor .execute (new AgentRequestHandler (this .getType (), this .getLink (), request ));
861+ _executor .execute (new AgentRequestHandler (this .getType (), this .getLink (), request ));
862862 }
863863 } catch (final ClassNotFoundException e ) {
864864 s_logger .error ("Unable to find this request " );
0 commit comments