storm-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From bo...@apache.org
Subject [2/4] git commit: fix added code not in when-let block
Date Fri, 06 Jun 2014 16:26:13 GMT
fix added code not in when-let block


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

Branch: refs/heads/master
Commit: 50408bfc1c193356a66f50f9ce9aeb7786031f4b
Parents: 0108765
Author: Kang Xiao <kxiao.tiger@gmail.com>
Authored: Sat Mar 8 01:12:22 2014 +0800
Committer: Kang Xiao <kxiao.tiger@gmail.com>
Committed: Sat Mar 8 01:12:22 2014 +0800

----------------------------------------------------------------------
 storm-core/src/clj/backtype/storm/daemon/drpc.clj | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-storm/blob/50408bfc/storm-core/src/clj/backtype/storm/daemon/drpc.clj
----------------------------------------------------------------------
diff --git a/storm-core/src/clj/backtype/storm/daemon/drpc.clj b/storm-core/src/clj/backtype/storm/daemon/drpc.clj
index 54e71e0..57c26df 100644
--- a/storm-core/src/clj/backtype/storm/daemon/drpc.clj
+++ b/storm-core/src/clj/backtype/storm/daemon/drpc.clj
@@ -62,9 +62,9 @@
                           (when (> (time-delta start) (conf DRPC-REQUEST-TIMEOUT-SECS))
                             (when-let [sem (@id->sem id)]
                               (swap! id->result assoc id (DRPCExecutionException. "Request
timed out"))
-                              (.release sem))
                               (.remove (acquire-queue request-queues (@id->function id))
(@id->request id))
                               (log-warn "Timeout DRPC request id: " id " start at " start)
+                              (.release sem))
                             (cleanup id)
                             ))
                         TIMEOUT-CHECK-SECS


Mime
View raw message