/dports/devel/pycharm-pro/pycharm-2020.2.3/plugins/python/helpers/pydev/pydev_tests/ |
H A D | test_pydevconsole.py | 32 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 D | test_pydev_ipython_011.py | 219 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 D | searpc-demo-client.c | 108 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 D | demo-async-client.c | 94 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 D | ws_topology.py | 93 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 D | mpmd_mb_controller.hpp | 26 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 D | rpc_client.cpp | 26 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 D | rpc_client.dsp | 1 # 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 D | client.rs | 35 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 D | vxi11.c | 75 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 D | MetaWeblog.php | 75 $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 D | LiveJournal.php | 264 $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 D | pydev_stdin.py | 54 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 D | pydev_ipython_console.py | 17 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 D | pydev_ipython_console_011.py | 54 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 D | ide-lsp-client.c | 57 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 D | rpc_client.hpp | 20 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 D | pydevconsole.py | 67 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 D | Control.pm | 26 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 D | mpmd_mboard_impl.cpp | 67 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 D | e3xx_ad9361_iface.cpp | 17 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 D | Makefile.am | 29 rpc_client.bpf \ 30 rpc_client.bpr \
|
/dports/devel/gnome-builder/gnome-builder-41.3/src/plugins/clang/ |
H A D | ide-clang-client.c | 41 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 D | Makefile.am | 29 rpc_client.bpf \ 30 rpc_client.bpr \
|
/dports/devel/libsearpc/libsearpc-d1fd751/ |
H A D | README.markdown | 41 * 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.
|