[Swift-commit] Cog update

swift at ci.uchicago.edu swift at ci.uchicago.edu
Tue Apr 10 19:00:08 CDT 2012


------------------------------------------------------------------------
r3371 | hategan | 2012-04-10 18:57:05 -0500 (Tue, 10 Apr 2012) | 1 line

fixed npe for standalone coaster service
------------------------------------------------------------------------
Index: modules/provider-coaster/src/org/globus/cog/abstraction/coaster/service/CoasterService.java
===================================================================
--- modules/provider-coaster/src/org/globus/cog/abstraction/coaster/service/CoasterService.java	(revision 3370)
+++ modules/provider-coaster/src/org/globus/cog/abstraction/coaster/service/CoasterService.java	(working copy)
@@ -99,10 +99,12 @@
 
     protected void initializeLocalService() throws IOException {
         localService = new LocalTCPService(newLocalRequestManager());
+        localService.start();
     }
 
     protected void initializeLocalService(int port) throws IOException {
         localService = new LocalTCPService(newLocalRequestManager(), port);
+        localService.start();
     }
 
 
@@ -140,7 +142,6 @@
             if (localService == null) {
                 throw new IllegalStateException("Local service not initialized");
             }
-            localService.start();
             jobQueue = new JobQueue(localService);
             jobQueue.start();
             localService.setRegistrationManager(jobQueue);
Index: modules/provider-coaster/src/org/globus/cog/abstraction/coaster/service/LocalTCPService.java
===================================================================
--- modules/provider-coaster/src/org/globus/cog/abstraction/coaster/service/LocalTCPService.java	(revision 3370)
+++ modules/provider-coaster/src/org/globus/cog/abstraction/coaster/service/LocalTCPService.java	(working copy)
@@ -14,7 +14,6 @@
 import java.net.Socket;
 import java.net.SocketException;
 import java.net.URI;
-import java.net.URISyntaxException;
 import java.nio.channels.ServerSocketChannel;
 import java.nio.channels.SocketChannel;
 import java.util.Map;
@@ -44,8 +43,6 @@
     private RequestManager requestManager;
     private ServiceContext context = new ServiceContext(this);
     
-    private final URI contact;
-    
     private Thread serverThread;
 
     public LocalTCPService(RequestManager rm) throws IOException {
@@ -56,14 +53,6 @@
         setRequestManager(rm);
         buffMan = new TCPBufferManager();
         this.port = port;
-        URI lh = null;
-        try {
-            lh = new URI("localhost:" + port);
-        }
-        catch (URISyntaxException e) {
-            logger.error("Internal error", e);
-        }
-        this.contact = lh;
     }
 
     public String registrationReceived(String blockid, String url, 



More information about the Swift-commit mailing list