@@ -47,12 +47,12 @@ public Result invoke(Invoker<?> invoker, Invocation invocation) throws RpcExcept
4747 String methodName = invocation .getMethodName ();
4848 int max = invoker .getUrl ().getMethodParameter (methodName , Constants .ACTIVES_KEY , 0 );
4949 RpcStatus count = RpcStatus .getStatus (invoker .getUrl (), invocation .getMethodName ());
50- if (!RpcStatus .beginCount (url , methodName , max )) {
50+ if (!count .beginCount (url , methodName , max )) {
5151 long timeout = invoker .getUrl ().getMethodParameter (invocation .getMethodName (), Constants .TIMEOUT_KEY , 0 );
5252 long start = System .currentTimeMillis ();
5353 long remain = timeout ;
5454 synchronized (count ) {
55- while (!RpcStatus .beginCount (url , methodName , max )) {
55+ while (!count .beginCount (url , methodName , max )) {
5656 try {
5757 count .wait (remain );
5858 } catch (InterruptedException e ) {
@@ -79,7 +79,7 @@ public Result invoke(Invoker<?> invoker, Invocation invocation) throws RpcExcept
7979 isSuccess = false ;
8080 throw t ;
8181 } finally {
82- RpcStatus .endCount (url , methodName , System .currentTimeMillis () - begin , isSuccess );
82+ count .endCount (url , methodName , System .currentTimeMillis () - begin , isSuccess );
8383 if (max > 0 ) {
8484 synchronized (count ) {
8585 count .notifyAll ();
0 commit comments