Home
last modified time | relevance | path

Searched refs:RpcThread (Results 1 – 8 of 8) sorted by relevance

/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-common-project/hadoop-common/src/test/java/org/apache/hadoop/ipc/
H A DTestRPCWaitForProxy.java51 RpcThread worker = new RpcThread(0); in testWaitForProxy()
69 RpcThread worker = new RpcThread(100); in testInterruptedWaitForProxy()
97 private class RpcThread extends Thread { class in TestRPCWaitForProxy
102 private RpcThread(int connectRetries) { in RpcThread() method in TestRPCWaitForProxy.RpcThread
/dports/net-p2p/transmission-remote-gui/transgui-5.18.0/
H A Drpc.pas108 RpcThread: TRpcThread;
221 FRpc.RpcThread:=nil;
224 FRpc.RpcThread:=nil;
879 Result:=Assigned(RpcThread) and FConnected;
884 Result:=not FConnected and Assigned(RpcThread);
958 RpcThread:=TRpcThread.Create;
959 with RpcThread do begin
968 if Assigned(RpcThread) then begin
969 RpcThread.Terminate;
970 while Assigned(RpcThread) do begin
/dports/security/softether-devel/v4.36-9754/src/Cedar/
H A DClient.h480 THREAD *RpcThread; // RPC thread member
H A DClient.c5659 c->RpcThread = NewThread(CiRpcServerThread, (void *)c); in CiStartRpcServer()
5660 WaitThreadInit(c->RpcThread); in CiStartRpcServer()
5675 WaitThread(c->RpcThread, INFINITE); in CiStopRpcServer()
5676 ReleaseThread(c->RpcThread); in CiStopRpcServer()
/dports/security/softether/v4.38-9760/src/Cedar/
H A DClient.h480 THREAD *RpcThread; // RPC thread member
H A DClient.c5659 c->RpcThread = NewThread(CiRpcServerThread, (void *)c); in CiStartRpcServer()
5660 WaitThreadInit(c->RpcThread); in CiStartRpcServer()
5675 WaitThread(c->RpcThread, INFINITE); in CiStopRpcServer()
5676 ReleaseThread(c->RpcThread); in CiStopRpcServer()
/dports/security/softether5/SoftEtherVPN-5.02.5180/src/Cedar/
H A DClient.h383 THREAD *RpcThread; // RPC thread member
H A DClient.c5367 c->RpcThread = NewThread(CiRpcServerThread, (void *)c); in CiStartRpcServer()
5368 WaitThreadInit(c->RpcThread); in CiStartRpcServer()
5383 WaitThread(c->RpcThread, INFINITE); in CiStopRpcServer()
5384 ReleaseThread(c->RpcThread); in CiStopRpcServer()