| /external/virglrenderer/server/ |
| D | render_server.c | 25 render_server_init_poll_fds(struct render_server *srv, in render_server_init_poll_fds() argument
28 const int socket_fd = srv->client->socket.fd; in render_server_init_poll_fds()
29 const int sigchld_fd = render_worker_jail_get_sigchld_fd(srv->worker_jail); in render_server_init_poll_fds()
44 render_server_poll(UNUSED struct render_server *srv, in render_server_poll() argument
62 render_server_run(struct render_server *srv) in render_server_run() argument
64 struct render_client *client = srv->client; in render_server_run()
67 const int poll_fd_count = render_server_init_poll_fds(srv, poll_fds); in render_server_run()
69 while (srv->state == RENDER_SERVER_STATE_RUN) { in render_server_run()
70 if (!render_server_poll(srv, poll_fds, poll_fd_count)) in render_server_run()
79 if (!render_worker_jail_reap_workers(srv->worker_jail)) in render_server_run()
[all …]
|
| D | render_client.c | 45 struct render_server *srv = client->server; in render_client_detach_all_records() local
48 render_worker_jail_detach_workers(srv->worker_jail); in render_client_detach_all_records()
60 struct render_server *srv = client->server; in render_client_remove_record() local
62 render_worker_destroy(srv->worker_jail, rec->worker); in render_client_remove_record()
109 struct render_server *srv = client->server; in render_client_create_context() local
127 rec->worker = render_worker_create(srv->worker_jail, render_client_worker_thread, in render_client_create_context()
132 rec->worker = render_worker_create(srv->worker_jail, NULL, NULL, 0); in render_client_create_context()
147 srv->state = RENDER_SERVER_STATE_SUBPROCESS; in render_client_create_context()
148 *srv->context_args = ctx_args; in render_client_create_context()
153 assert(srv->context_args->ctx_fd == ctx_fd); in render_client_create_context()
[all …]
|
| /external/rust/crates/grpcio-sys/grpc/third_party/cares/cares/test/ |
| D | ares-test-parse-srv.cc | 18 struct ares_srv_reply* srv = nullptr; in TEST_F() local
19 EXPECT_EQ(ARES_SUCCESS, ares_parse_srv_reply(data.data(), data.size(), &srv)); in TEST_F()
20 ASSERT_NE(nullptr, srv); in TEST_F()
22 EXPECT_EQ("srv.example.com", std::string(srv->host)); in TEST_F()
23 EXPECT_EQ(10, srv->priority); in TEST_F()
24 EXPECT_EQ(20, srv->weight); in TEST_F()
25 EXPECT_EQ(30, srv->port); in TEST_F()
27 struct ares_srv_reply* srv2 = srv->next; in TEST_F()
35 ares_free_data(srv); in TEST_F()
52 struct ares_srv_reply* srv = nullptr; in TEST_F() local
[all …]
|
| D | ares-test-fuzz.c | 30 struct ares_srv_reply* srv = NULL; in LLVMFuzzerTestOneInput() local
31 ares_parse_srv_reply(data, size, &srv); in LLVMFuzzerTestOneInput()
32 if (srv) ares_free_data(srv); in LLVMFuzzerTestOneInput()
|
| /external/wpa_supplicant_8/src/wps/ |
| D | http_server.c | 23 struct http_server *srv; member
45 struct http_server *srv = req->srv; in http_request_cb() local
51 srv->cb(srv->cb_ctx, req); in http_request_cb()
61 static struct http_request * http_request_init(struct http_server *srv, int fd, in http_request_init() argument
66 if (srv->request_count >= HTTP_SERVER_MAX_CONNECTIONS) { in http_request_init()
75 req->srv = srv; in http_request_init()
94 struct http_server *srv; in http_request_deinit() local
99 srv = req->srv; in http_request_deinit()
101 r = srv->requests; in http_request_deinit()
107 srv->requests = r->next; in http_request_deinit()
[all …]
|
| /external/virglrenderer/src/proxy/ |
| D | proxy_server.c | 15 proxy_server_connect(struct proxy_server *srv) in proxy_server_connect() argument
17 int client_fd = srv->client_fd; in proxy_server_connect()
19 srv->client_fd = -1; in proxy_server_connect()
24 proxy_server_destroy(struct proxy_server *srv) in proxy_server_destroy() argument
26 if (srv->pid >= 0) { in proxy_server_destroy()
27 kill(srv->pid, SIGKILL); in proxy_server_destroy()
30 waitid(P_PID, srv->pid, &siginfo, WEXITED); in proxy_server_destroy()
33 if (srv->client_fd >= 0) in proxy_server_destroy()
34 close(srv->client_fd); in proxy_server_destroy()
36 free(srv); in proxy_server_destroy()
[all …]
|
| /external/rust/crates/tokio/tests/ |
| D | tcp_socket.rs | 12 let srv = assert_ok!(TcpSocket::new_v4()); in basic_usage_v4() localVariable
13 assert_ok!(srv.bind(addr)); in basic_usage_v4()
15 let srv = assert_ok!(srv.listen(128)); in basic_usage_v4() localVariable
18 let addr = srv.local_addr().unwrap(); in basic_usage_v4()
23 let _ = assert_ok!(srv.accept().await); in basic_usage_v4()
31 let srv = assert_ok!(TcpSocket::new_v6()); in basic_usage_v6() localVariable
32 assert_ok!(srv.bind(addr)); in basic_usage_v6()
34 let srv = assert_ok!(srv.listen(128)); in basic_usage_v6() localVariable
37 let addr = srv.local_addr().unwrap(); in basic_usage_v6()
42 let _ = assert_ok!(srv.accept().await); in basic_usage_v6()
[all …]
|
| D | tcp_connect.rs | 12 let srv = assert_ok!(TcpListener::bind("127.0.0.1:0").await); in connect_v4() localVariable
13 let addr = assert_ok!(srv.local_addr()); in connect_v4()
19 let (socket, addr) = assert_ok!(srv.accept().await); in connect_v4()
40 let srv = assert_ok!(TcpListener::bind("[::1]:0").await); in connect_v6() localVariable
41 let addr = assert_ok!(srv.local_addr()); in connect_v6()
47 let (socket, addr) = assert_ok!(srv.accept().await); in connect_v6()
67 let srv = assert_ok!(TcpListener::bind("127.0.0.1:0").await); in connect_addr_ip_string() localVariable
68 let addr = assert_ok!(srv.local_addr()); in connect_addr_ip_string()
72 assert_ok!(srv.accept().await); in connect_addr_ip_string()
84 let srv = assert_ok!(TcpListener::bind("127.0.0.1:0").await); in connect_addr_ip_str_slice() localVariable
[all …]
|
| D | buffered.rs | 15 let srv = assert_ok!(TcpListener::bind("127.0.0.1:0").await); in echo_server() localVariable
16 let addr = assert_ok!(srv.local_addr()); in echo_server()
40 let (mut a, _) = assert_ok!(srv.accept().await); in echo_server()
41 let (mut b, _) = assert_ok!(srv.accept().await); in echo_server()
|
| /external/libwebsockets/minimal-examples/secure-streams/minimal-secure-streams-perf/ |
| D | README.md | 46 [2021/03/31 15:29:49:0716] N: lws_ss_deserialize_parse: RX METADATA srv
47 [2021/03/31 15:29:49:0882] U: myss_rx: len 1380, flags: 1, srv: lwsws, test: hello
48 [2021/03/31 15:29:49:0907] U: myss_rx: len 140, flags: 0, srv: lwsws, test: hello
50 [2021/03/31 15:29:49:0937] U: myss_rx: len 1380, flags: 0, srv: lwsws, test: hello
51 [2021/03/31 15:29:49:0938] U: myss_rx: len 140, flags: 0, srv: lwsws, test: hello
52 [2021/03/31 15:29:49:0940] U: myss_rx: len 829, flags: 0, srv: lwsws, test: hello
53 [2021/03/31 15:29:49:0942] U: myss_rx: len 691, flags: 0, srv: lwsws, test: hello
54 [2021/03/31 15:29:49:0943] U: myss_rx: len 1380, flags: 0, srv: lwsws, test: hello
55 [2021/03/31 15:29:49:0944] U: myss_rx: len 140, flags: 0, srv: lwsws, test: hello
56 [2021/03/31 15:29:49:0945] U: myss_rx: len 1380, flags: 0, srv: lwsws, test: hello
[all …]
|
| /external/python/cpython3/Lib/test/test_asyncio/ |
| D | test_server.py | 26 if srv.is_serving():
44 async def main(srv): argument
45 async with srv:
46 await srv.serve_forever()
48 srv = self.loop.run_until_complete(asyncio.start_server(
51 self.assertFalse(srv.is_serving())
53 main_task = self.loop.create_task(main(srv))
55 addr = srv.sockets[0].getsockname()
60 self.assertEqual(srv.sockets, ())
62 self.assertIsNone(srv._sockets)
[all …]
|
| /external/grpc-grpc/src/ruby/end2end/ |
| D | sig_handling_client.rb | 21 def initialize(srv, stub) argument
22 @srv = srv
69 srv = new_rpc_server_for_testing(poll_period: 3)
70 srv.add_http2_port("0.0.0.0:#{client_control_port}",
74 control_service = SigHandlingClientController.new(srv, stub)
75 srv.handle(control_service)
77 srv.run
79 srv.wait_till_running
|
| D | channel_closing_client.rb | 47 srv = new_rpc_server_for_testing
49 srv.add_http2_port("0.0.0.0:#{client_control_port}", :this_port_is_insecure)
50 srv.handle(ChannelClosingClientController.new(ch))
51 srv.run
65 srv.stop
|
| /external/openscreen/discovery/dnssd/impl/ |
| D | dns_data_graph_unittest.cc | 137 auto srv = GetFakeSrvRecord(primary_domain_, secondary_domain_); in TEST_F() local
141 TriggerRecordCreationWithCallback(srv, secondary_domain_); in TEST_F()
155 auto srv = GetFakeSrvRecord(primary_domain_); in TEST_F() local
159 TriggerRecordCreation(srv); in TEST_F()
172 auto srv = GetFakeSrvRecord(primary_domain_, secondary_domain_); in TEST_F() local
176 TriggerRecordCreationWithCallback(srv, secondary_domain_); in TEST_F()
190 auto srv = GetFakeSrvRecord(primary_domain_, secondary_domain_); in TEST_F() local
194 TriggerRecordCreationWithCallback(srv, secondary_domain_); in TEST_F()
198 auto result = ApplyDataRecordChange(srv, RecordChangedEvent::kExpired); in TEST_F()
207 auto srv = GetFakeSrvRecord(primary_domain_); in TEST_F() local
[all …]
|
| /external/wpa_supplicant_8/src/ap/ |
| D | authsrv.c | 107 struct radius_server_conf srv; in hostapd_setup_radius_srv() local
109 os_memset(&srv, 0, sizeof(srv)); in hostapd_setup_radius_srv()
110 srv.client_file = conf->radius_server_clients; in hostapd_setup_radius_srv()
111 srv.auth_port = conf->radius_server_auth_port; in hostapd_setup_radius_srv()
112 srv.acct_port = conf->radius_server_acct_port; in hostapd_setup_radius_srv()
113 srv.conf_ctx = hapd; in hostapd_setup_radius_srv()
114 srv.ipv6 = conf->radius_server_ipv6; in hostapd_setup_radius_srv()
115 srv.get_eap_user = hostapd_radius_get_eap_user; in hostapd_setup_radius_srv()
116 srv.eap_req_id_text = conf->eap_req_id_text; in hostapd_setup_radius_srv()
117 srv.eap_req_id_text_len = conf->eap_req_id_text_len; in hostapd_setup_radius_srv()
[all …]
|
| /external/swiftshader/tests/regres/cmd/export_to_sheets/ |
| D | main.go | 70 srv, err := createSheetsService(*authdir)
76 if err := createTestListSheets(srv, lists); err != nil {
80 spreadsheet, err := srv.Spreadsheets.Get(*spreadsheetID).Do()
103 columnHeaders, err := fetchRow(srv, spreadsheet, sheet, 0)
115 hashValues, err := fetchColumn(srv, spreadsheet, sheet, hashColumnIndex)
176 if _, err := srv.Spreadsheets.Values.BatchUpdate(*spreadsheetID, &req).Do(); err != nil {
249 func fetchRow(srv *sheets.Service, spreadsheet *sheets.Spreadsheet, sheet *sheets.Sheet, row int) (…
251 data, err := srv.Spreadsheets.Values.Get(spreadsheet.SpreadsheetId, rng).Do()
259 func fetchColumn(srv *sheets.Service, spreadsheet *sheets.Spreadsheet, sheet *sheets.Sheet, row int…
261 data, err := srv.Spreadsheets.Values.Get(spreadsheet.SpreadsheetId, rng).Do()
[all …]
|
| /external/perfetto/src/base/ |
| D | unix_socket_unittest.cc | 104 auto srv = in TEST_F() local
107 ASSERT_TRUE(srv->is_listening()); in TEST_F()
112 EXPECT_CALL(event_listener_, OnNewIncomingConnection(srv.get(), _)) in TEST_F()
142 auto srv = in TEST_F() local
145 ASSERT_TRUE(srv->is_listening()); in TEST_F()
155 EXPECT_CALL(event_listener_, OnNewIncomingConnection(srv.get(), _)) in TEST_F()
199 srv->Shutdown(true); in TEST_F()
209 auto srv = UnixSocket::Listen(std::move(fd), &event_listener_, &task_runner_, in TEST_F() local
211 ASSERT_TRUE(srv->is_listening()); in TEST_F()
221 EXPECT_CALL(event_listener_, OnNewIncomingConnection(srv.get(), _)) in TEST_F()
[all …]
|
| /external/flatbuffers/tests/MyGame/Example/ |
| D | MonsterStorage_grpc.go | 179 func RegisterMonsterStorageServer(s grpc.ServiceRegistrar, srv MonsterStorageServer) {
180 s.RegisterService(&_MonsterStorage_serviceDesc, srv)
183 func _MonsterStorage_Store_Handler(srv interface{}, ctx context.Context,
190 return srv.(MonsterStorageServer).Store(ctx, in)
193 Server: srv,
198 return srv.(MonsterStorageServer).Store(ctx, req.(*Monster))
202 func _MonsterStorage_Retrieve_Handler(srv interface{}, stream grpc.ServerStream) error {
207 return srv.(MonsterStorageServer).Retrieve(m, &monsterStorageRetrieveServer{stream})
223 func _MonsterStorage_GetMaxHitPoint_Handler(srv interface{}, stream grpc.ServerStream) error {
224 return srv.(MonsterStorageServer).GetMaxHitPoint(&monsterStorageGetMaxHitPointServer{stream})
[all …]
|
| /external/flatbuffers/grpc/examples/go/greeter/models/ |
| D | Greeter_grpc.go | 98 func RegisterGreeterServer(s grpc.ServiceRegistrar, srv GreeterServer) {
99 s.RegisterService(&_Greeter_serviceDesc, srv)
102 func _Greeter_SayHello_Handler(srv interface{}, ctx context.Context,
109 return srv.(GreeterServer).SayHello(ctx, in)
112 Server: srv,
117 return srv.(GreeterServer).SayHello(ctx, req.(*HelloRequest))
121 func _Greeter_SayManyHellos_Handler(srv interface{}, stream grpc.ServerStream) error {
126 return srv.(GreeterServer).SayManyHellos(m, &greeterSayManyHellosServer{stream})
|
| /external/openthread/third_party/mbedtls/repo/tests/suites/ |
| D | test_suite_ecdh.function | 312 mbedtls_ecdh_context srv, cli;
320 mbedtls_ecdh_init( &srv );
324 TEST_ASSERT( mbedtls_ecdh_setup( &srv, id ) == 0 );
327 TEST_ASSERT( mbedtls_ecdh_make_params( &srv, &len, buf, 1000,
336 TEST_ASSERT( mbedtls_ecdh_read_public( &srv, buf, len ) == 0 );
338 TEST_ASSERT( mbedtls_ecdh_calc_secret( &srv, &len, buf, 1000,
347 mbedtls_ecdh_free( &srv );
357 mbedtls_ecdh_context srv, cli;
366 mbedtls_ecdh_init( &srv );
387 TEST_ASSERT( mbedtls_ecdh_setup( &srv, id ) == 0 );
[all …]
|
| /external/libcups/scheduler/ |
| D | dirsvc.c | 59 static void dnssdDeregisterInstance(cupsd_srv_t *srv, int from_callback);
77 static int dnssdRegisterInstance(cupsd_srv_t *srv, cupsd_printer_t *p, char *name, const char *typ…
687 cupsd_srv_t *srv, /* I - Service */ in dnssdDeregisterInstance() argument
690 if (!srv || !*srv) in dnssdDeregisterInstance()
696 DNSServiceRefDeallocate(*srv); in dnssdDeregisterInstance()
698 *srv = NULL; in dnssdDeregisterInstance()
704 if (*srv) in dnssdDeregisterInstance()
706 avahi_entry_group_free(*srv); in dnssdDeregisterInstance()
707 *srv = NULL; in dnssdDeregisterInstance()
960 AvahiEntryGroup *srv, /* I - Service */ in dnssdRegisterCallback() argument
[all …]
|
| /external/wpa_supplicant_8/wpa_supplicant/examples/ |
| D | wps-nfc.py | 26 srv = None variable
399 global srv
401 while not wait_connection and srv.sent_carrier is None:
402 if srv.ho_server_processing:
409 global srv
410 srv = HandoverServer(llc)
413 srv.uuid = None
416 srv.uuid = arg_uuid
425 global srv
426 srv.start()
[all …]
|
| /external/linux-kselftest/tools/testing/selftests/bpf/prog_tests/ |
| D | sockmap_ktls.c | 43 int err, cli, srv, zero = 0; in test_sockmap_ktls_disconnect_after_delete() local
45 srv = tcp_server(family); in test_sockmap_ktls_disconnect_after_delete()
46 if (srv == -1) in test_sockmap_ktls_disconnect_after_delete()
49 err = getsockname(srv, (struct sockaddr *)&addr, &len); in test_sockmap_ktls_disconnect_after_delete()
92 close(srv); in test_sockmap_ktls_disconnect_after_delete()
|
| /external/mbedtls/tests/suites/ |
| D | test_suite_ecdh.function | 198 mbedtls_ecdh_context srv, cli;
206 mbedtls_ecdh_init( &srv );
210 TEST_ASSERT( mbedtls_ecdh_setup( &srv, id ) == 0 );
213 TEST_ASSERT( mbedtls_ecdh_make_params( &srv, &len, buf, 1000,
222 TEST_ASSERT( mbedtls_ecdh_read_public( &srv, buf, len ) == 0 );
224 TEST_ASSERT( mbedtls_ecdh_calc_secret( &srv, &len, buf, 1000,
234 mbedtls_ecdh_free( &srv );
244 mbedtls_ecdh_context srv, cli;
254 mbedtls_ecdh_init( &srv );
276 TEST_ASSERT( mbedtls_ecdh_setup( &srv, id ) == 0 );
[all …]
|
| /external/linux-kselftest/tools/testing/selftests/netfilter/ |
| D | nft_nat_zones.sh | 38 srv="ns-srv-$sfx"
50 ip netns del $srv
95 ip netns add "$srv"
97 echo "SKIP: Could not create server netns $srv"
101 ip link add veth0 netns "$gw" type veth peer name eth0 netns "$srv"
103 ip -net "$srv" link set lo up
104 ip -net "$srv" link set eth0 up
158 ip -net "$srv" addr add 10.3.0.99/24 dev eth0
159 ip -net "$srv" addr add dead:3::99/64 dev eth0
268 ip netns exec $srv iperf3 -s > /dev/null 2>&1 &
|