| /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/rust/crates/tokio/tests/ |
| D | tcp_socket.rs | 11 let srv = assert_ok!(TcpSocket::new_v4()); in basic_usage_v4() localVariable
12 assert_ok!(srv.bind(addr)); in basic_usage_v4()
14 let srv = assert_ok!(srv.listen(128)); in basic_usage_v4() localVariable
17 let addr = srv.local_addr().unwrap(); in basic_usage_v4()
22 let _ = assert_ok!(srv.accept().await); in basic_usage_v4()
29 let srv = assert_ok!(TcpSocket::new_v6()); in basic_usage_v6() localVariable
30 assert_ok!(srv.bind(addr)); in basic_usage_v6()
32 let srv = assert_ok!(srv.listen(128)); in basic_usage_v6() localVariable
35 let addr = srv.local_addr().unwrap(); in basic_usage_v6()
40 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()
39 let srv = assert_ok!(TcpListener::bind("[::1]:0").await); in connect_v6() localVariable
40 let addr = assert_ok!(srv.local_addr()); in connect_v6()
46 let (socket, addr) = assert_ok!(srv.accept().await); in connect_v6()
66 let srv = assert_ok!(TcpListener::bind("127.0.0.1:0").await); in connect_addr_ip_string() localVariable
67 let addr = assert_ok!(srv.local_addr()); in connect_addr_ip_string()
71 assert_ok!(srv.accept().await); in connect_addr_ip_string()
83 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()
|
| D | tcp_shutdown.rs | 10 let srv = assert_ok!(TcpListener::bind("127.0.0.1:0").await); in shutdown() localVariable
11 let addr = assert_ok!(srv.local_addr()); in shutdown()
23 let (mut stream, _) = assert_ok!(srv.accept().await); in shutdown()
|
| D | tcp_echo.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()
35 let (mut stream, _) = assert_ok!(srv.accept().await); in echo_server()
|
| /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()
49 srv = self.loop.run_until_complete(asyncio.start_server(
52 self.assertFalse(srv.is_serving())
54 main_task = self.loop.create_task(main(srv))
56 addr = srv.sockets[0].getsockname()
61 self.assertEqual(srv.sockets, ())
63 self.assertIsNone(srv._sockets)
[all …]
|
| D | test_buffered_proto.py | 61 srv = self.loop.run_until_complete(
65 addr = srv.sockets[0].getsockname()
69 srv.close()
70 self.loop.run_until_complete(srv.wait_closed())
|
| /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 | 106 struct radius_server_conf srv; in hostapd_setup_radius_srv() local
108 os_memset(&srv, 0, sizeof(srv)); in hostapd_setup_radius_srv()
109 srv.client_file = conf->radius_server_clients; in hostapd_setup_radius_srv()
110 srv.auth_port = conf->radius_server_auth_port; in hostapd_setup_radius_srv()
111 srv.acct_port = conf->radius_server_acct_port; in hostapd_setup_radius_srv()
112 srv.conf_ctx = hapd; in hostapd_setup_radius_srv()
113 srv.ipv6 = conf->radius_server_ipv6; in hostapd_setup_radius_srv()
114 srv.get_eap_user = hostapd_radius_get_eap_user; in hostapd_setup_radius_srv()
115 srv.eap_req_id_text = conf->eap_req_id_text; in hostapd_setup_radius_srv()
116 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 | 71 srv, err := createSheetsService(*authdir)
77 if err := createTestListSheets(srv, lists); err != nil {
81 spreadsheet, err := srv.Spreadsheets.Get(*spreadsheetID).Do()
104 columnHeaders, err := fetchRow(srv, spreadsheet, sheet, 0)
116 hashValues, err := fetchColumn(srv, spreadsheet, sheet, hashColumnIndex)
177 if _, err := srv.Spreadsheets.Values.BatchUpdate(*spreadsheetID, &req).Do(); err != nil {
250 func fetchRow(srv *sheets.Service, spreadsheet *sheets.Spreadsheet, sheet *sheets.Sheet, row int) (…
252 data, err := srv.Spreadsheets.Values.Get(spreadsheet.SpreadsheetId, rng).Do()
260 func fetchColumn(srv *sheets.Service, spreadsheet *sheets.Spreadsheet, sheet *sheets.Sheet, row int…
262 data, err := srv.Spreadsheets.Values.Get(spreadsheet.SpreadsheetId, rng).Do()
[all …]
|
| /external/perfetto/src/base/ |
| D | unix_socket_unittest.cc | 102 auto srv = in TEST_F() local
105 ASSERT_TRUE(srv->is_listening()); in TEST_F()
110 EXPECT_CALL(event_listener_, OnNewIncomingConnection(srv.get(), _)) in TEST_F()
140 auto srv = in TEST_F() local
143 ASSERT_TRUE(srv->is_listening()); in TEST_F()
153 EXPECT_CALL(event_listener_, OnNewIncomingConnection(srv.get(), _)) in TEST_F()
197 srv->Shutdown(true); in TEST_F()
207 auto srv = UnixSocket::Listen(std::move(fd), &event_listener_, &task_runner_, in TEST_F() local
209 ASSERT_TRUE(srv->is_listening()); in TEST_F()
219 EXPECT_CALL(event_listener_, OnNewIncomingConnection(srv.get(), _)) in TEST_F()
[all …]
|
| /external/flatbuffers/tests/MyGame/Example/ |
| D | MonsterStorage_grpc.go | 132 func RegisterMonsterStorageServer(s *grpc.Server, srv MonsterStorageServer) {
133 s.RegisterService(&_MonsterStorage_serviceDesc, srv)
136 func _MonsterStorage_Store_Handler(srv interface{}, ctx context.Context,
140 if interceptor == nil { return srv.(MonsterStorageServer).Store(ctx, in) }
142 Server: srv,
147 return srv.(MonsterStorageServer).Store(ctx, req.(* Monster))
153 func _MonsterStorage_Retrieve_Handler(srv interface{}, stream grpc.ServerStream) error {
156 return srv.(MonsterStorageServer).Retrieve(m, &monsterStorageRetrieveServer{stream})
173 func _MonsterStorage_GetMaxHitPoint_Handler(srv interface{}, stream grpc.ServerStream) error {
174 return srv.(MonsterStorageServer).GetMaxHitPoint(&monsterStorageGetMaxHitPointServer{stream})
[all …]
|
| /external/golang-protobuf/protoc-gen-go/testdata/grpc/ |
| D | grpc.pb.go | 335 func (*UnimplementedTestServer) Downstream(req *SimpleRequest, srv Test_DownstreamServer) error {
338 func (*UnimplementedTestServer) Upstream(srv Test_UpstreamServer) error {
341 func (*UnimplementedTestServer) Bidi(srv Test_BidiServer) error {
345 func RegisterTestServer(s *grpc.Server, srv TestServer) {
346 s.RegisterService(&_Test_serviceDesc, srv)
349 func _Test_UnaryCall_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, int…
355 return srv.(TestServer).UnaryCall(ctx, in)
358 Server: srv,
362 return srv.(TestServer).UnaryCall(ctx, req.(*SimpleRequest))
367 func _Test_Downstream_Handler(srv interface{}, stream grpc.ServerStream) error {
[all …]
|
| /external/openscreen/osp/impl/discovery/mdns/ |
| D | mdns_responder_adapter_impl_unittest.cc | 72 auto srv = mdns_adapter->TakeSrvResponses(); in TEST() local
73 ASSERT_EQ(1u, srv.size()); in TEST()
74 ASSERT_THAT(srv[0].domain_name.GetLabels(), in TEST()
76 EXPECT_EQ(12345, srv[0].port); in TEST()
83 mdns_adapter->StartAQuery(0, srv[0].domain_name); in TEST()
|
| /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 …]
|
| D | p2p-nfc.py | 33 srv = None variable
487 global srv
489 while not wait_connection and srv.sent_carrier is None:
490 if srv.ho_server_processing:
518 global srv
519 srv = HandoverServer(llc)
528 global srv
529 srv.start()
642 global srv
643 if only_one and srv and srv.success:
|
| /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/golang-protobuf/protoc-gen-go/testdata/deprecated/ |
| D | deprecated.pb.go | 256 func RegisterDeprecatedServiceServer(s *grpc.Server, srv DeprecatedServiceServer) {
257 s.RegisterService(&_DeprecatedService_serviceDesc, srv)
260 func _DeprecatedService_DeprecatedCall_Handler(srv interface{}, ctx context.Context, dec func(inter…
266 return srv.(DeprecatedServiceServer).DeprecatedCall(ctx, in)
269 Server: srv,
273 return srv.(DeprecatedServiceServer).DeprecatedCall(ctx, req.(*DeprecatedRequest))
|
| /external/wpa_supplicant_8/hostapd/ |
| D | wps-ap-nfc.py | 254 global srv
255 srv = HandoverServer(llc)
262 global srv
263 srv.start()
330 global srv
331 if only_one and srv and srv.success:
|
| /external/selinux/python/sepolicy/sepolicy/help/ |
| D | file_equiv.txt | 7 …t content in a location other then /var/www like /srv/www. He could define an equivalence between …
9 …ow the substitution. Using the example above when matchpathcon is handed /srv/www/cgi-bin/myscrip…
13 # semanage fcontext -a -e /var/www /srv/www
|