storm-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From bo...@apache.org
Subject [10/12] storm git commit: switch the order of doing the init and put initHttp() first in launchServer,
Date Wed, 09 Mar 2016 15:54:03 GMT
switch the order of doing the init and put initHttp() first in launchServer,


Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/e2306533
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/e2306533
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/e2306533

Branch: refs/heads/master
Commit: e23065333f1fc0db98e1e97af451b3f1ee4d443f
Parents: bc25c51
Author: xiaojian.fxj <xiaojian.fxj@alibaba-inc.com>
Authored: Wed Mar 9 19:03:49 2016 +0800
Committer: xiaojian.fxj <xiaojian.fxj@alibaba-inc.com>
Committed: Wed Mar 9 19:03:49 2016 +0800

----------------------------------------------------------------------
 storm-core/src/jvm/org/apache/storm/daemon/DrpcServer.java | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/storm/blob/e2306533/storm-core/src/jvm/org/apache/storm/daemon/DrpcServer.java
----------------------------------------------------------------------
diff --git a/storm-core/src/jvm/org/apache/storm/daemon/DrpcServer.java b/storm-core/src/jvm/org/apache/storm/daemon/DrpcServer.java
index c4792d0..f223f89 100644
--- a/storm-core/src/jvm/org/apache/storm/daemon/DrpcServer.java
+++ b/storm-core/src/jvm/org/apache/storm/daemon/DrpcServer.java
@@ -63,6 +63,7 @@ public class DrpcServer implements DistributedRPC.Iface, DistributedRPCInvocatio
     private AtomicInteger ctr = new AtomicInteger(0);
     private ConcurrentHashMap<String, ConcurrentLinkedQueue<DRPCRequest>> requestQueues
= new ConcurrentHashMap<String, ConcurrentLinkedQueue<DRPCRequest>>();
 
+
     private static class InternalRequest {
         public final Semaphore sem;
         public final int startTimeSecs;
@@ -200,8 +201,8 @@ public class DrpcServer implements DistributedRPC.Iface, DistributedRPCInvocatio
 
     public void launchServer() throws Exception {
         LOG.info("Starting drpc server for storm version {}", VersionInfo.getVersion());
-        initThrift();
         initHttp();
+        initThrift();
     }
 
     @Override


Mime
View raw message