Home
last modified time | relevance | path

Searched refs:rpc_client (Results 1 – 25 of 139) sorted by relevance

123456

/dports/devel/pycharm-pro/pycharm-2020.2.3/plugins/python/helpers/pydev/pydev_tests/
H A Dtest_pydevconsole.py32 rpc_client = self.start_client_thread() #@UnusedVariable
37 … interpreter = pydevconsole.InterpreterInterface(threading.currentThread(), rpc_client=rpc_client)
57 … interpreter = pydevconsole.InterpreterInterface(threading.currentThread(), rpc_client=rpc_client)
144 self.rpc_client = None
176 return rpc_client
243 rpc_client.execLine('class Foo:')
244 rpc_client.execLine(' pass')
245 rpc_client.execLine('')
246 rpc_client.execLine('foo = Foo()')
247 rpc_client.execLine('a = %s()' % (raw_input_name,))
[all …]
H A Dtest_pydev_ipython_011.py219 self.rpc_client = None
239 rpc_client, _ = make_rpc_client(PythonConsoleFrontendService, host, port)
244 self.front_end = get_pydev_frontend(rpc_client)
247 sys.stdin = StdIn(self, rpc_client)
/dports/devel/libsearpc/libsearpc-d1fd751/demo/
H A Dsearpc-demo-client.c108 rpc_string_test(int sockfd, struct sockaddr_in *servaddr, SearpcClient *rpc_client, GError *error) in rpc_string_test() argument
113 ret = searpc_client_call__int(rpc_client, "searpc_strlen", &error, in rpc_string_test()
128 rpc_glist_test(int sockfd, struct sockaddr_in *servaddr, SearpcClient *rpc_client, GError *error) in rpc_glist_test() argument
132 GList *ans=searpc_client_call__objlist(rpc_client, "searpc_objlisttest", in rpc_glist_test()
180 SearpcClient *rpc_client; in main() local
200 rpc_client = searpc_client_new(); in main()
201 rpc_client->send = transport_callback; in main()
202 rpc_client->arg = (void *)(long)sockfd; in main()
204 rpc_string_test(sockfd, &servaddr, rpc_client, error); in main()
207 rpc_client->arg = (void *)(long)sockfd; in main()
[all …]
H A Ddemo-async-client.c94 SearpcClient *rpc_client; in main() local
133 rpc_client = searpc_client_new(); in main()
134 rpc_client->async_send = transport_send; in main()
135 rpc_client->async_arg = (void *)(long)transport; in main()
138 searpc_client_async_call__int(rpc_client, "searpc_strlen", in main()
/dports/net/ryu/ryu-4.26/ryu/app/
H A Dws_topology.py93 for rpc_client in self.rpc_clients:
96 rpc_server = rpc_client.get_proxy()
100 self.logger.debug('WebSocket disconnected: %s', rpc_client.ws)
101 disconnected_clients.append(rpc_client)
118 rpc_client = WebSocketRPCClient(ws)
119 self.app.rpc_clients.append(rpc_client)
120 rpc_client.serve_forever()
/dports/comms/uhd/uhd-90ce6062b6b5df2eddeee723777be85108e4e7c7/host/lib/include/uhdlib/usrp/common/
H A Dmpmd_mb_controller.hpp26 mpmd_mb_controller(uhd::rpc_client::sptr rpcc, uhd::device_addr_t device_info);
29 uhd::rpc_client::sptr get_rpc_client() in get_rpc_client()
45 mpmd_timekeeper(const size_t tk_idx, uhd::rpc_client::sptr rpc_client) in mpmd_timekeeper() argument
46 : _tk_idx(tk_idx), _rpc(rpc_client) in mpmd_timekeeper()
65 uhd::rpc_client::sptr _rpc;
97 mutable uhd::rpc_client::sptr _rpc;
/dports/comms/uhd/uhd-90ce6062b6b5df2eddeee723777be85108e4e7c7/host/lib/transport/nirio/rpc/
H A Drpc_client.cpp26 rpc_client::rpc_client(const std::string& server, in rpc_client() function in uhd::usrprio_rpc::rpc_client
101 rpc_client::~rpc_client() in ~rpc_client()
106 const boost::system::error_code& rpc_client::call(func_id_t func_id, in call()
167 void rpc_client::_handle_response_hdr( in _handle_response_hdr()
182 boost::bind(&rpc_client::_handle_response_data, in _handle_response_hdr()
204 void rpc_client::_handle_response_data( in _handle_response_data()
219 void rpc_client::_wait_for_next_response_header() in _wait_for_next_response_header()
224 boost::bind(&rpc_client::_handle_response_hdr, in _wait_for_next_response_header()
/dports/net/ulxmlrpcpp/ulxmlrpcpp-1.7.5/msvc/ulxmlrpcpp/
H A Drpc_client.dsp1 # Microsoft Developer Studio Project File - Name="rpc_client" - Package Owner=<4>
7 CFG=rpc_client - Win32 Debug
11 !MESSAGE NMAKE /f "rpc_client.mak".
16 !MESSAGE NMAKE /f "rpc_client.mak" CFG="rpc_client - Win32 Debug"
20 !MESSAGE "rpc_client - Win32 Release" (basierend auf "Win32 (x86) Console Application")
21 !MESSAGE "rpc_client - Win32 Debug" (basierend auf "Win32 (x86) Console Application")
31 !IF "$(CFG)" == "rpc_client - Win32 Release"
54 !ELSEIF "$(CFG)" == "rpc_client - Win32 Debug"
82 # Name "rpc_client - Win32 Release"
83 # Name "rpc_client - Win32 Debug"
[all …]
/dports/lang/rust/rustc-1.58.1-src/vendor/jsonrpc-derive/tests/
H A Dclient.rs35 let (client, rpc_client) = local::connect::<gen_client::Client, _, _>(handler); in client_server_roundtrip()
45 futures::join!(fut, rpc_client).1.unwrap(); in client_server_roundtrip()
79 let (client, rpc_client) = local::connect::<gen_client::Client, _, _>(handler); in client_generates_correct_named_params_payload()
88 exec.spawn_ok(async move { futures::join!(fut, rpc_client).1.unwrap() }); in client_generates_correct_named_params_payload()
117 let (client, rpc_client) = local::connect::<gen_client::Client, _, _>(handler); in client_generates_correct_raw_params_payload()
126 exec.spawn_ok(async move { futures::join!(fut, rpc_client).1.unwrap() }); in client_generates_correct_raw_params_payload()
/dports/misc/liblxi/liblxi-1.13/src/
H A Dvxi11.c75 vxi11_data->rpc_client = clnt_create(address, DEVICE_CORE, DEVICE_CORE_VERSION, "tcp"); in vxi11_connect()
76 if (vxi11_data->rpc_client == NULL) in vxi11_connect()
80 link_params.clientId = (unsigned long) vxi11_data->rpc_client; in vxi11_connect()
89 if (create_link_1(&link_params, &vxi11_data->link_resp, vxi11_data->rpc_client) != RPC_SUCCESS) in vxi11_connect()
95 clnt_destroy(vxi11_data->rpc_client); in vxi11_connect()
106 destroy_link_1(&vxi11_data->link_resp.lid, &device_error, vxi11_data->rpc_client); in vxi11_disconnect()
107 clnt_destroy(vxi11_data->rpc_client); in vxi11_disconnect()
128 if (device_write_1(&write_params, &write_resp, vxi11_data->rpc_client) != RPC_SUCCESS) in vxi11_send()
160 if (device_read_1(&read_params, &read_resp, vxi11_data->rpc_client) != RPC_SUCCESS) in vxi11_receive()
/dports/www/pear-Services_Blogging/Services_Blogging-0.2.4/Services/Blogging/Driver/
H A DMetaWeblog.php75 $this->rpc_client = new XML_RPC_Client(
107 $request, $this->rpc_client
121 Services_Blogging_XmlRpc::sendRequest($request, $this->rpc_client);
152 $request, $this->rpc_client
187 Services_Blogging_XmlRpc::sendRequest($request, $this->rpc_client);
213 $request, $this->rpc_client
H A DLiveJournal.php264 $request, $this->rpc_client
336 $request, $this->rpc_client
384 $request, $this->rpc_client
439 $request, $this->rpc_client
/dports/devel/pycharm-pro/pycharm-2020.2.3/plugins/python/helpers/pydev/_pydev_bundle/
H A Dpydev_stdin.py54 def __init__(self, interpreter, rpc_client, original_stdin=sys.stdin): argument
57 self.rpc_client = rpc_client
64 requested_input = self.rpc_client.requestInput()
H A Dpydev_ipython_console.py17 def __init__(self, main_thread, show_banner=True, connect_status_queue=None, rpc_client=None): argument
18 BaseInterpreterInterface.__init__(self, main_thread, connect_status_queue, rpc_client)
19 self.interpreter = get_pydev_frontend(rpc_client)
H A Dpydev_ipython_console_011.py54 def create_editor_hook(rpc_client): argument
69 rpc_client.IPythonEditor(filename, str(line))
502 def get_pydev_frontend(rpc_client): argument
506 if _PyDevFrontEndContainer._last_rpc_client != rpc_client:
507 _PyDevFrontEndContainer._last_rpc_client = rpc_client
512 _PyDevFrontEndContainer._instance.ipython.hooks['editor'] = create_editor_hook(rpc_client)
/dports/devel/gnome-builder/gnome-builder-41.3/src/libide/lsp/
H A Dide-lsp-client.c57 JsonrpcClient *rpc_client;
172 g_assert (JSONRPC_IS_CLIENT (rpc_client));
181 jsonrpc_client_call_async (rpc_client,
915 g_assert (JSONRPC_IS_CLIENT (rpc_client));
1149 g_clear_object (&priv->rpc_client);
1416 g_return_if_fail (!priv->rpc_client || JSONRPC_IS_CLIENT (priv->rpc_client));
1774 if (priv->rpc_client != NULL)
1782 g_clear_object (&priv->rpc_client);
1879 g_return_if_fail (!priv->rpc_client || JSONRPC_IS_CLIENT (priv->rpc_client));
1884 if (priv->rpc_client == NULL)
[all …]
/dports/comms/uhd/uhd-90ce6062b6b5df2eddeee723777be85108e4e7c7/host/include/uhd/transport/nirio/rpc/
H A Drpc_client.hpp20 class rpc_client : private uhd::noncopyable class
26 rpc_client(const std::string& server,
30 ~rpc_client();
/dports/devel/pycharm-pro/pycharm-2020.2.3/plugins/python/helpers/pydev/
H A Dpydevconsole.py67 def __init__(self, mainThread, connect_status_queue=None, rpc_client=None): argument
68 BaseInterpreterInterface.__init__(self, mainThread, connect_status_queue, rpc_client)
341 def server_handler_factory(rpc_client): argument
342 interpreter.rpc_client = rpc_client
397 interpreter = InterpreterInterface(threading.currentThread(), rpc_client=client)
/dports/multimedia/dvdrip/dvdrip-0.98.11/lib/Video/DVDRip/GUI/Cluster/
H A DControl.pm26 sub rpc_client { shift->{rpc_client} } subroutine
46 sub set_rpc_client { shift->{rpc_client} = $_[1] }
699 my $rpc_client = Event::RPC::Client->new(
711 eval { $rpc_client->connect };
713 if ( not $rpc_client->get_connected ) {
730 eval { $rpc_client->connect };
733 if ( not $rpc_client->get_connected ) {
749 $self->set_rpc_client($rpc_client);
822 my $rpc_client = $self->rpc_client;
823 $rpc_client->disconnect if $rpc_client;
/dports/comms/uhd/uhd-90ce6062b6b5df2eddeee723777be85108e4e7c7/host/lib/usrp/mpmd/
H A Dmpmd_mboard_impl.cpp67 void init_device(uhd::rpc_client::sptr rpc, const uhd::device_addr_t mb_args) in init_device()
91 uhd::rpc_client::sptr rpc, const size_t duration_ms = MPMD_MEAS_LATENCY_DURATION) in measure_rpc_latency()
158 uhd::rpc_client::sptr make_mpm_rpc_client(const std::string& rpc_server_addr, in make_mpm_rpc_client()
162 return uhd::rpc_client::make(rpc_server_addr, in make_mpm_rpc_client()
189 auto rpcc = uhd::rpc_client::make(rpc_addr, rpc_port); in is_device_reachable()
230 auto chdr_rpcc = uhd::rpc_client::make(chdr_addr, rpc_port); in is_device_reachable()
/dports/comms/uhd/uhd-90ce6062b6b5df2eddeee723777be85108e4e7c7/host/lib/usrp/dboard/e3xx/
H A De3xx_ad9361_iface.cpp17 e3xx_ad9361_iface(rpc_client::sptr rpcc) in e3xx_ad9361_iface()
133 rpc_client::sptr _rpcc;
143 ad9361_ctrl::sptr make_rpc(rpc_client::sptr rpcc) in make_rpc()
/dports/net/ulxmlrpcpp/ulxmlrpcpp-1.7.5/bcb6/
H A DMakefile.am29 rpc_client.bpf \
30 rpc_client.bpr \
/dports/devel/gnome-builder/gnome-builder-41.3/src/plugins/clang/
H A Dide-clang-client.c41 JsonrpcClient *rpc_client; member
163 g_clear_object (&self->rpc_client); in ide_clang_client_subprocess_exited()
188 g_assert (self->rpc_client == NULL); in ide_clang_client_subprocess_spawned()
206 self->rpc_client = jsonrpc_client_new (stream); in ide_clang_client_subprocess_spawned()
233 jsonrpc_client_call_async (self->rpc_client, in ide_clang_client_subprocess_spawned()
317 if (self->rpc_client == NULL) in ide_clang_client_buffer_saved()
404 g_clear_object (&self->rpc_client); in ide_clang_client_destroy()
433 g_clear_object (&self->rpc_client); in ide_clang_client_finalize()
466 JsonrpcClient *rpc_client = (JsonrpcClient *)object; in ide_clang_client_call_cb() local
471 g_assert (JSONRPC_IS_CLIENT (rpc_client)); in ide_clang_client_call_cb()
[all …]
/dports/net/ulxmlrpcpp/ulxmlrpcpp-1.7.5/bcb5/
H A DMakefile.am29 rpc_client.bpf \
30 rpc_client.bpr \
/dports/devel/libsearpc/libsearpc-d1fd751/
H A DREADME.markdown41 * Create a rpc_client and supply the transport function.
45 ### Create rpc_client ###
51 /* create an rpc_client and supply the transport function. */
52 SearpcClient *rpc_client;
53 rpc_client = searpc_client_new();
54 rpc_client->transport = transport_callback;
55 rpc_client->arg = &sockfd;
96 * arg: rpc_client->arg. Normally a socket number.

123456