| /dports/devel/cxxtools/cxxtools-2.2.1/src/json/ |
| H A D | rpcserver.cpp | 36 RpcServer::RpcServer(EventLoopBase& eventLoop) in RpcServer() function in cxxtools::json::RpcServer
40 RpcServer::RpcServer(EventLoopBase& eventLoop, const std::string& ip, unsigned short int port, int … in RpcServer() function in cxxtools::json::RpcServer
46 RpcServer::RpcServer(EventLoopBase& eventLoop, unsigned short int port, int backlog) in RpcServer() function in cxxtools::json::RpcServer
52 RpcServer::~RpcServer() in ~RpcServer()
57 void RpcServer::addService(const std::string& praefix, const ServiceRegistry& service) in addService()
67 void RpcServer::listen(const std::string& ip, unsigned short int port, int backlog) in listen()
72 void RpcServer::listen(unsigned short int port, int backlog) in listen()
77 unsigned RpcServer::minThreads() const in minThreads()
82 void RpcServer::minThreads(unsigned m) in minThreads()
87 unsigned RpcServer::maxThreads() const in maxThreads()
[all …]
|
| H A D | rpcserverimpl.cpp | 97 RpcServerImpl::RpcServerImpl(EventLoopBase& eventLoop, Signal<RpcServer::Runmode>& runmodeChanged, … in RpcServerImpl()
98 : _runmode(RpcServer::Stopped), in RpcServerImpl()
118 if (runmode() == RpcServer::Running) in ~RpcServerImpl()
152 runmode(RpcServer::Starting); in start()
162 runmode(RpcServer::Running); in start()
170 runmode(RpcServer::Terminating); in terminate()
204 runmode(RpcServer::Stopped); in terminate()
208 runmode(RpcServer::Failed); in terminate()
214 if (runmode() == RpcServer::Running) in noWaitingThreads()
224 if (runmode() == RpcServer::Running) in threadTerminated()
[all …]
|
| H A D | rpcserverimpl.h | 68 …RpcServerImpl(EventLoopBase& eventLoop, Signal<RpcServer::Runmode>& runmodeChanged, ServiceRegistr…
88 RpcServer::Runmode runmode() const in runmode()
92 void runmode(RpcServer::Runmode runmode) in runmode()
98 RpcServer::Runmode _runmode;
99 Signal<RpcServer::Runmode>& _runmodeChanged;
138 { return runmode() == RpcServer::Terminating; } in isTerminating()
|
| /dports/devel/cxxtools/cxxtools-2.2.1/src/bin/ |
| H A D | rpcserver.cpp | 36 RpcServer::RpcServer(EventLoopBase& eventLoop) in RpcServer() function in cxxtools::bin::RpcServer
40 RpcServer::RpcServer(EventLoopBase& eventLoop, const std::string& ip, unsigned short int port, int … in RpcServer() function in cxxtools::bin::RpcServer
46 RpcServer::RpcServer(EventLoopBase& eventLoop, unsigned short int port, int backlog) in RpcServer() function in cxxtools::bin::RpcServer
52 RpcServer::~RpcServer() in ~RpcServer()
57 void RpcServer::addService(const ServiceRegistry& service) in addService()
77 void RpcServer::listen(const std::string& ip, unsigned short int port, int backlog) in listen()
82 void RpcServer::listen(unsigned short int port, int backlog) in listen()
87 unsigned RpcServer::minThreads() const in minThreads()
92 void RpcServer::minThreads(unsigned m) in minThreads()
97 unsigned RpcServer::maxThreads() const in maxThreads()
[all …]
|
| H A D | rpcserverimpl.cpp | 97 RpcServerImpl::RpcServerImpl(EventLoopBase& eventLoop, Signal<RpcServer::Runmode>& runmodeChanged, … in RpcServerImpl()
98 : _runmode(RpcServer::Stopped), in RpcServerImpl()
118 if (runmode() == RpcServer::Running) in ~RpcServerImpl()
152 runmode(RpcServer::Starting); in start()
162 runmode(RpcServer::Running); in start()
170 runmode(RpcServer::Terminating); in terminate()
204 runmode(RpcServer::Stopped); in terminate()
208 runmode(RpcServer::Failed); in terminate()
214 if (runmode() == RpcServer::Running) in noWaitingThreads()
224 if (runmode() == RpcServer::Running) in threadTerminated()
[all …]
|
| H A D | rpcserverimpl.h | 68 …RpcServerImpl(EventLoopBase& eventLoop, Signal<RpcServer::Runmode>& runmodeChanged, ServiceRegistr…
88 RpcServer::Runmode runmode() const in runmode()
92 void runmode(RpcServer::Runmode runmode) in runmode()
98 RpcServer::Runmode _runmode;
99 Signal<RpcServer::Runmode>& _runmodeChanged;
138 { return runmode() == RpcServer::Terminating; } in isTerminating()
|
| /dports/databases/hbase/hbase-1.2.1/hbase-server/src/main/java/org/apache/hadoop/hbase/ipc/ |
| H A D | CallRunner.java | 28 import org.apache.hadoop.hbase.ipc.RpcServer.Call;
85 if (RpcServer.LOG.isDebugEnabled()) { in run()
86 RpcServer.LOG.debug(Thread.currentThread().getName() + ": skipped " + call); in run()
92 if (RpcServer.LOG.isTraceEnabled()) { in run()
94 RpcServer.LOG.trace(call.toShortString() + " executing as " + in run()
100 RpcServer.CurCall.set(call); in run()
115 RpcServer.LOG.debug(Thread.currentThread().getName() + ": " + call.toShortString(), e); in run()
125 RpcServer.CurCall.set(null); in run()
141 RpcServer.LOG.info(Thread.currentThread().getName() + ": exiting on OutOfMemoryError"); in run()
150 RpcServer.LOG.warn(Thread.currentThread().getName() + ": caught a ClosedChannelException, " + in run()
[all …]
|
| H A D | RpcSchedulerContext.java | 26 private final RpcServer rpcServer;
31 RpcSchedulerContext(final RpcServer rpcServer) { in RpcSchedulerContext()
|
| H A D | SimpleRpcScheduler.java | 78 RpcServer.Call callA = a.getCall(); in compare()
79 RpcServer.Call callB = b.getCall(); in compare()
116 handlerCount * RpcServer.DEFAULT_MAX_CALLQUEUE_LENGTH_PER_HANDLER); in SimpleRpcScheduler()
194 RpcServer.Call call = callTask.getCall(); in dispatch()
|
| H A D | MetricsHBaseServerWrapperImpl.java | 24 private RpcServer server;
26 MetricsHBaseServerWrapperImpl(RpcServer server) { in MetricsHBaseServerWrapperImpl()
|
| H A D | FifoRpcScheduler.java | 44 handlerCount * RpcServer.DEFAULT_MAX_CALLQUEUE_LENGTH_PER_HANDLER); in FifoRpcScheduler()
80 task.setStatus(RpcServer.getStatus()); in dispatch()
|
| /dports/devel/cxxtools/cxxtools-2.2.1/include/cxxtools/json/ |
| H A D | rpcserver.h | 46 class RpcServer : public ServiceRegistry
51 RpcServer(EventLoopBase& eventLoop);
52 …RpcServer(EventLoopBase& eventLoop, const std::string& ip, unsigned short int port, int backlog = …
53 RpcServer(EventLoopBase& eventLoop, unsigned short int port, int backlog = 64);
54 ~RpcServer();
|
| /dports/devel/cxxtools/cxxtools-2.2.1/include/cxxtools/bin/ |
| H A D | rpcserver.h | 46 class RpcServer : public ServiceRegistry
51 RpcServer(EventLoopBase& eventLoop);
52 …RpcServer(EventLoopBase& eventLoop, const std::string& ip, unsigned short int port, int backlog = …
53 RpcServer(EventLoopBase& eventLoop, unsigned short int port, int backlog = 64);
54 ~RpcServer();
|
| /dports/databases/hbase/hbase-1.2.1/hbase-server/src/test/java/org/apache/hadoop/hbase/ipc/ |
| H A D | TestSimpleRpcScheduler.java | 34 import org.apache.hadoop.hbase.ipc.RpcServer.Call;
177 RpcServer.Call smallCall = mock(RpcServer.Call.class); in testRpcScheduler()
183 RpcServer.Call largeCall = mock(RpcServer.Call.class); in testRpcScheduler()
189 RpcServer.Call hugeCall = mock(RpcServer.Call.class); in testRpcScheduler()
255 RpcServer.Call putCall = mock(RpcServer.Call.class); in testScanQueues()
263 RpcServer.Call getCall = mock(RpcServer.Call.class); in testScanQueues()
269 RpcServer.Call scanCall = mock(RpcServer.Call.class); in testScanQueues()
|
| H A D | TestCallRunner.java | 35 RpcServer.Call mockCall = Mockito.mock(RpcServer.Call.class); in testSimpleCall()
36 mockCall.connection = Mockito.mock(RpcServer.Connection.class); in testSimpleCall()
|
| /dports/databases/hbase/hbase-1.2.1/hbase-server/src/main/java/org/apache/hadoop/hbase/security/token/ |
| H A D | TokenProvider.java | 33 import org.apache.hadoop.hbase.ipc.RpcServer;
65 SecretManager<?> mgr = ((RpcServer)server).getSecretManager(); in start()
113 User currentUser = RpcServer.getRequestUser(); in getAuthenticationToken()
139 User requestUser = RpcServer.getRequestUser(); in whoAmI()
|
| /dports/cad/yosys/yosys-yosys-0.12/frontends/rpc/ |
| H A D | rpc_frontend.cc | 73 struct RpcServer { struct
76 RpcServer(const std::string &name) : name(name) { } in RpcServer() argument
77 virtual ~RpcServer() { } in ~RpcServer() argument
158 std::shared_ptr<RpcServer> server;
247 struct HandleRpcServer : RpcServer {
251 : RpcServer(name), hsend(hsend), hrecv(hrecv) { } in HandleRpcServer()
290 struct FdRpcServer : RpcServer {
295 : RpcServer(name), fdsend(fdsend), fdrecv(fdrecv), pid(pid) { } in FdRpcServer()
418 std::shared_ptr<RpcServer> server; in execute()
|
| /dports/devel/grpc134/grpc-1.34.1/src/ruby/spec/support/ |
| H A D | helpers.rb | 27 RpcServer = GRPC::RpcServer constant
81 RpcServer.new(**server_opts)
|
| /dports/devel/grpc/grpc-1.42.0/src/ruby/spec/support/ |
| H A D | helpers.rb | 27 RpcServer = GRPC::RpcServer constant
81 RpcServer.new(**server_opts)
|
| /dports/devel/grpc130/grpc-1.30.2/src/ruby/spec/support/ |
| H A D | helpers.rb | 27 RpcServer = GRPC::RpcServer constant
81 RpcServer.new(**server_opts)
|
| /dports/www/chromium-legacy/chromium-88.0.4324.182/third_party/grpc/src/src/ruby/spec/support/ |
| H A D | helpers.rb | 27 RpcServer = GRPC::RpcServer constant
81 RpcServer.new(**server_opts)
|
| /dports/databases/hbase/hbase-1.2.1/hbase-server/src/main/java/org/apache/hadoop/hbase/client/ |
| H A D | VersionInfoUtil.java | 23 import org.apache.hadoop.hbase.ipc.RpcServer;
38 RpcCallContext call = RpcServer.getCurrentCall(); in currentClientHasMinimumVersion()
|
| /dports/lang/rust/rustc-1.58.1-src/vendor/jsonrpc-derive/tests/ |
| H A D | client.rs | 19 struct RpcServer; struct
21 impl Rpc for RpcServer { implementation
34 handler.extend_with(RpcServer.to_delegate()); in client_server_roundtrip()
|
| /dports/devel/cxxtools/cxxtools-2.2.1/demo/ |
| H A D | rpcserver.cpp | 139 cxxtools::bin::RpcServer binServer(loop, ip, bport); in main()
149 cxxtools::json::RpcServer jsonServer(loop, ip, jport); in main()
|
| /dports/databases/hbase/hbase-1.2.1/hbase-server/src/main/java/org/apache/hadoop/hbase/security/ |
| H A D | HBaseSaslRpcServer.java | 37 import org.apache.hadoop.hbase.ipc.RpcServer;
74 private RpcServer.Connection connection;
78 RpcServer.Connection connection) { in SaslDigestCallbackHandler()
|