Home
last modified time | relevance | path

Searched refs:client (Results 1 – 25 of 6409) sorted by relevance

12345678910>>...257

/external/rust/crates/grpcio-sys/grpc/src/core/tsi/alts/handshaker/
Dalts_handshaker_client.cc112 alts_grpc_handshaker_client* client) { in handshaker_client_send_buffer_destroy() argument
113 GPR_ASSERT(client != nullptr); in handshaker_client_send_buffer_destroy()
114 grpc_byte_buffer_destroy(client->send_buffer); in handshaker_client_send_buffer_destroy()
115 client->send_buffer = nullptr; in handshaker_client_send_buffer_destroy()
127 alts_grpc_handshaker_client* client) { in alts_grpc_handshaker_client_unref() argument
128 if (gpr_unref(&client->refs)) { in alts_grpc_handshaker_client_unref()
129 if (client->base.vtable != nullptr && in alts_grpc_handshaker_client_unref()
130 client->base.vtable->destruct != nullptr) { in alts_grpc_handshaker_client_unref()
131 client->base.vtable->destruct(&client->base); in alts_grpc_handshaker_client_unref()
133 grpc_byte_buffer_destroy(client->send_buffer); in alts_grpc_handshaker_client_unref()
[all …]
/external/adhd/cras/src/libcras/
Dcras_client.c164 struct cras_client *client; member
257 struct cras_client client; member
263 offsetof(struct client_int, client)))
369 static int client_thread_rm_stream(struct cras_client *client,
371 static int handle_message_from_server(struct cras_client *client);
372 static int reregister_notifications(struct cras_client *client);
386 static void server_state_unlock(const struct cras_client *client, int lock_rc) in server_state_unlock() argument
390 if (!client) in server_state_unlock()
392 client_int = to_client_int(client); in server_state_unlock()
408 static int server_state_rdlock(const struct cras_client *client) in server_state_rdlock() argument
[all …]
Dcras_client.h78 typedef int (*cras_playback_cb_t)(struct cras_client *client,
99 typedef int (*cras_unified_cb_t)(struct cras_client *client,
114 typedef int (*cras_error_cb_t)(struct cras_client *client,
149 typedef void (*cras_connection_status_cb_t)(struct cras_client *client,
154 typedef void (*cras_thread_priority_cb_t)(struct cras_client *client);
157 typedef void (*get_hotword_models_cb_t)(struct cras_client *client,
161 typedef void (*cras_hotword_trigger_cb_t)(struct cras_client *client,
166 typedef int (*cras_hotword_error_cb_t)(struct cras_client *client,
181 int cras_client_create(struct cras_client **client);
192 int cras_client_create_with_type(struct cras_client **client,
[all …]
/external/adhd/cras/src/server/
Dcras_observer.c111 struct cras_observer_client *client; in output_volume_alert() local
115 DL_FOREACH (g_observer->clients, client) { in output_volume_alert()
116 if (client->ops.output_volume_changed) in output_volume_alert()
117 client->ops.output_volume_changed(client->context, in output_volume_alert()
124 struct cras_observer_client *client; in output_mute_alert() local
128 DL_FOREACH (g_observer->clients, client) { in output_mute_alert()
129 if (client->ops.output_mute_changed) in output_mute_alert()
130 client->ops.output_mute_changed(client->context, in output_mute_alert()
139 struct cras_observer_client *client; in capture_gain_alert() local
143 DL_FOREACH (g_observer->clients, client) { in capture_gain_alert()
[all …]
Dcras_rclient_util.c21 int rclient_send_message_to_client(const struct cras_rclient *client, in rclient_send_message_to_client() argument
25 return cras_send_with_fds(client->fd, (const void *)msg, msg->length, in rclient_send_message_to_client()
29 void rclient_destroy(struct cras_rclient *client) in rclient_destroy() argument
31 cras_observer_remove(client->observer); in rclient_destroy()
33 client); in rclient_destroy()
34 free(client); in rclient_destroy()
64 rclient_validate_stream_connect_message(const struct cras_rclient *client, in rclient_validate_stream_connect_message() argument
67 if (!cras_valid_stream_id(msg->stream_id, client->id)) { in rclient_validate_stream_connect_message()
71 msg->stream_id, client->id); in rclient_validate_stream_connect_message()
76 if (direction < 0 || !(client->supported_directions & direction)) { in rclient_validate_stream_connect_message()
[all …]
Dcras_control_rclient.c31 static void dump_audio_thread_info(struct cras_rclient *client) in dump_audio_thread_info() argument
40 client->ops->send_message_to_client(client, &msg.header, NULL, 0); in dump_audio_thread_info()
44 static void get_atlog_fd(struct cras_rclient *client) in get_atlog_fd() argument
51 client->ops->send_message_to_client(client, &msg.header, &atlog_fd, 1); in get_atlog_fd()
55 static void dump_audio_thread_snapshots(struct cras_rclient *client) in dump_audio_thread_snapshots() argument
61 client->ops->send_message_to_client(client, &msg.header, NULL, 0); in dump_audio_thread_snapshots()
64 static void handle_get_hotword_models(struct cras_rclient *client, in handle_get_hotword_models() argument
84 client->ops->send_message_to_client(client, &msg->header, NULL, 0); in handle_get_hotword_models()
90 client->ops->send_message_to_client(client, &msg->header, NULL, 0); in handle_get_hotword_models()
98 struct cras_rclient *client = (struct cras_rclient *)context; in send_output_volume_changed() local
[all …]
Dcras_rclient.c33 void cras_rclient_destroy(struct cras_rclient *client) in cras_rclient_destroy() argument
35 client->ops->destroy(client); in cras_rclient_destroy()
40 int cras_rclient_buffer_from_client(struct cras_rclient *client, in cras_rclient_buffer_from_client() argument
50 return client->ops->handle_message_from_client(client, msg, fds, in cras_rclient_buffer_from_client()
55 int cras_rclient_send_message(const struct cras_rclient *client, in cras_rclient_send_message() argument
59 return client->ops->send_message_to_client(client, msg, fds, num_fds); in cras_rclient_send_message()
62 static void cras_rclient_set_client_type(struct cras_rclient *client, in cras_rclient_set_client_type() argument
65 client->client_type = client_type; in cras_rclient_set_client_type()
71 struct cras_rclient *client; in cras_rclient_create() local
87 client = cras_playback_rclient_create(fd, id); in cras_rclient_create()
[all …]
/external/python/google-api-python-client/docs/dyn/
Dindex.md2 * [v1](http://googleapis.github.io/google-api-python-client/docs/dyn/abusiveexperiencereport_v1.htm…
6 * [v1](http://googleapis.github.io/google-api-python-client/docs/dyn/acceleratedmobilepageurl_v1.ht…
10 * [v1beta1](http://googleapis.github.io/google-api-python-client/docs/dyn/accessapproval_v1beta1.ht…
14 * [v1](http://googleapis.github.io/google-api-python-client/docs/dyn/accesscontextmanager_v1.html)
15 * [v1beta](http://googleapis.github.io/google-api-python-client/docs/dyn/accesscontextmanager_v1bet…
19 * [v1.2](http://googleapis.github.io/google-api-python-client/docs/dyn/adexchangebuyer_v1.2.html)
20 * [v1.3](http://googleapis.github.io/google-api-python-client/docs/dyn/adexchangebuyer_v1.3.html)
21 * [v1.4](http://googleapis.github.io/google-api-python-client/docs/dyn/adexchangebuyer_v1.4.html)
25 * [v2beta1](http://googleapis.github.io/google-api-python-client/docs/dyn/adexchangebuyer2_v2beta1.…
29 * [v1](http://googleapis.github.io/google-api-python-client/docs/dyn/adexperiencereport_v1.html)
[all …]
/external/autotest/metadata/tests/
Dpolicy.star15 … main_package = 'autotest_lib.client.site_tests.policy_AccessibilityTest.policy_AccessibilityTest',
20 …main_package = 'autotest_lib.client.site_tests.policy_AlternateErrorPages.policy_AlternateErrorPag…
25 …main_package = 'autotest_lib.client.site_tests.policy_ArcAudioCaptureAllowed.policy_ArcAudioCaptur…
30 …main_package = 'autotest_lib.client.site_tests.policy_ArcBackupRestoreServiceEnabled.policy_ArcBac…
35 …main_package = 'autotest_lib.client.site_tests.policy_ArcDisableScreenshots.policy_ArcDisableScree…
40 …main_package = 'autotest_lib.client.site_tests.policy_ArcExternalStorageDisabled.policy_ArcExterna…
45 …main_package = 'autotest_lib.client.site_tests.policy_ArcVideoCaptureAllowed.policy_ArcVideoCaptur…
50 …main_package = 'autotest_lib.client.site_tests.policy_AudioOutputAllowed.policy_AudioOutputAllowed…
55 … main_package = 'autotest_lib.client.site_tests.policy_AutotestSanity.policy_AutotestSanity',
60 …main_package = 'autotest_lib.client.site_tests.policy_BookmarkBarEnabled.policy_BookmarkBarEnabled…
[all …]
Dplatform.star15 … main_package = 'autotest_lib.client.site_tests.platform_AccurateTime.platform_AccurateTime',
25 … main_package = 'autotest_lib.client.site_tests.platform_AesThroughput.platform_AesThroughput',
30 … main_package = 'autotest_lib.client.site_tests.platform_AnomalyDetector.platform_AnomalyDetector',
35 … main_package = 'autotest_lib.client.site_tests.platform_BootLockbox.platform_BootLockbox',
45 main_package = 'autotest_lib.client.site_tests.platform_BootPerf.platform_BootPerf',
50 …main_package = 'autotest_lib.client.site_tests.platform_CheckErrorsInLog.platform_CheckErrorsInLog…
55 … main_package = 'autotest_lib.client.site_tests.platform_ChromeCgroups.platform_ChromeCgroups',
60 … main_package = 'autotest_lib.client.site_tests.platform_CleanShutdown.platform_CleanShutdown',
85 …main_package = 'autotest_lib.client.site_tests.platform_CrosDisksArchive.platform_CrosDisksArchive…
105 … main_package = 'autotest_lib.client.site_tests.platform_CrosDisksSshfs.platform_CrosDisksSshfs',
[all …]
Dhardware.star15 main_package = 'autotest_lib.client.site_tests.hardware_Backlight.hardware_Backlight',
20 main_package = 'autotest_lib.client.site_tests.hardware_Badblocks.hardware_Badblocks',
25 …main_package = 'autotest_lib.client.site_tests.hardware_DiskFirmwareUpgrade.hardware_DiskFirmwareU…
35 main_package = 'autotest_lib.client.site_tests.hardware_DiskSize.hardware_DiskSize',
40 main_package = 'autotest_lib.client.site_tests.hardware_EC.hardware_EC',
45 … main_package = 'autotest_lib.client.site_tests.hardware_GPIOSwitches.hardware_GPIOSwitches',
50 main_package = 'autotest_lib.client.site_tests.hardware_GPS.hardware_GPS',
55 main_package = 'autotest_lib.client.site_tests.hardware_GobiGPS.hardware_GobiGPS',
60 main_package = 'autotest_lib.client.site_tests.hardware_Keyboard.hardware_Keyboard',
65 … main_package = 'autotest_lib.client.site_tests.hardware_LightSensor.hardware_LightSensor',
[all …]
/external/grpc-grpc/src/core/tsi/alts/handshaker/
Dalts_handshaker_client.cc47 static tsi_result make_grpc_call(alts_handshaker_client* client, in make_grpc_call() argument
49 GPR_ASSERT(client != nullptr && event != nullptr); in make_grpc_call()
51 reinterpret_cast<alts_grpc_handshaker_client*>(client); in make_grpc_call()
119 static tsi_result handshaker_client_start_client(alts_handshaker_client* client, in handshaker_client_start_client() argument
121 if (client == nullptr || event == nullptr) { in handshaker_client_start_client()
131 tsi_result result = make_grpc_call(client, event, true /* is_start */); in handshaker_client_start_client()
166 static tsi_result handshaker_client_start_server(alts_handshaker_client* client, in handshaker_client_start_server() argument
169 if (client == nullptr || event == nullptr || bytes_received == nullptr) { in handshaker_client_start_server()
179 tsi_result result = make_grpc_call(client, event, true /* is_start */); in handshaker_client_start_server()
204 static tsi_result handshaker_client_next(alts_handshaker_client* client, in handshaker_client_next() argument
[all …]
/external/libiio/src/
Diiod-client.c35 static ssize_t iiod_client_read_integer(struct iiod_client *client, in iiod_client_read_integer() argument
44 ret = client->ops->read_line(client->pdata, in iiod_client_read_integer()
69 static int iiod_client_exec_command(struct iiod_client *client, in iiod_client_exec_command() argument
75 ret = client->ops->write(client->pdata, desc, cmd, strlen(cmd)); in iiod_client_exec_command()
79 ret = iiod_client_read_integer(client, desc, &resp); in iiod_client_exec_command()
83 static ssize_t iiod_client_write_all(struct iiod_client *client, in iiod_client_write_all() argument
86 struct iio_context_pdata *pdata = client->pdata; in iiod_client_write_all()
87 const struct iiod_client_ops *ops = client->ops; in iiod_client_write_all()
110 static ssize_t iiod_client_read_all(struct iiod_client *client, in iiod_client_read_all() argument
113 struct iio_context_pdata *pdata = client->pdata; in iiod_client_read_all()
[all …]
/external/igt-gpu-tools/lib/
Digt_chamelium_stream.c126 static bool chamelium_stream_read_config(struct chamelium_stream *client) in chamelium_stream_read_config() argument
144 client->host = parse_url_host(chamelium_url); in chamelium_stream_read_config()
145 if (!client->host) { in chamelium_stream_read_config()
150 client->port = STREAM_PORT; in chamelium_stream_read_config()
155 static bool chamelium_stream_connect(struct chamelium_stream *client) in chamelium_stream_connect() argument
164 client->host, client->port); in chamelium_stream_connect()
166 snprintf(port_str, sizeof(port_str), "%u", client->port); in chamelium_stream_connect()
170 ret = getaddrinfo(client->host, port_str, &hints, &results); in chamelium_stream_connect()
176 client->fd = -1; in chamelium_stream_connect()
178 client->fd = socket(ai->ai_family, ai->ai_socktype, in chamelium_stream_connect()
[all …]
/external/autotest/client/common_lib/cros/
Dtpm_utils.py8 from autotest_lib.client.common_lib import error
9 from autotest_lib.client.cros import constants
26 def TPMStatus(client): argument
31 out = client.run('tpm_manager_client status --nonsensitive').stdout.strip()
47 def IsTPMAvailable(client): argument
52 status = TPMStatus(client)
56 def ClearTPMServer(client, out_dir): argument
62 if IsTPMAvailable(client):
66 client.run('stop ui')
67 client.run('crossystem clear_tpm_owner_request=1')
[all …]
Dpinweaver_client.py20 def __check_pinweaver_client_present(client, message): argument
22 run = client.run('which pinweaver_client', ignore_status=True)
26 def __execute_for_dict(client, *args, **kwargs): argument
30 __check_pinweaver_client_present(client, args[0])
36 run = client.run(*args, **kwargs)
45 def ResetTree(client, bits_per_level, height): argument
50 return __execute_for_dict(client, 'pinweaver_client resettree %d %d' %
54 def InsertLeaf(client, label, auxilary_hashes, low_entropy_secret, argument
62 client, 'pinweaver_client insert %d %s %s %s %s %s' %
67 def RemoveLeaf(client, label, auxilary_hashes, mac): argument
[all …]
/external/wayland/src/
Dwayland-server.c129 struct wl_client *client; member
149 struct wl_display *display = resource->client->display; in log_closure()
189 if (res && res->client != resource->client) { in verify_objects()
210 if (resource->client->error) in handle_array()
214 resource->client->error = 1; in handle_array()
222 resource->client->error = 1; in handle_array()
228 if (send_func(closure, resource->client->connection)) in handle_array()
229 resource->client->error = 1; in handle_array()
283 struct wl_client *client = resource->client; in wl_resource_post_error_vargs() local
295 if (client->error || !client->display_resource) in wl_resource_post_error_vargs()
[all …]
/external/grpc-grpc-java/interop-testing/src/test/java/io/grpc/testing/integration/
DStressTestClientTest.java51 StressTestClient client = new StressTestClient(); in ipv6AddressesShouldBeSupported() local
52 client.parseArgs(new String[] {"--server_addresses=[0:0:0:0:0:0:0:1]:8080," in ipv6AddressesShouldBeSupported()
55 assertEquals(2, client.addresses().size()); in ipv6AddressesShouldBeSupported()
56 assertEquals(new InetSocketAddress("0:0:0:0:0:0:0:1", 8080), client.addresses().get(0)); in ipv6AddressesShouldBeSupported()
57 assertEquals(new InetSocketAddress("1:2:3:4:f:e:a:b", 8083), client.addresses().get(1)); in ipv6AddressesShouldBeSupported()
62 StressTestClient client = new StressTestClient(); in defaults() local
63 assertEquals(singletonList(new InetSocketAddress("localhost", 8080)), client.addresses()); in defaults()
64 assertTrue(client.testCaseWeightPairs().isEmpty()); in defaults()
65 assertEquals(-1, client.durationSecs()); in defaults()
66 assertEquals(1, client.channelsPerServer()); in defaults()
[all …]
/external/virglrenderer/vtest/
Dvtest_server.c117 static int vtest_client_dispatch_commands(struct vtest_client *client);
289 struct vtest_client *client; in vtest_server_add_client() local
291 client = calloc(1, sizeof(*client)); in vtest_server_add_client()
292 if (!client) in vtest_server_add_client()
295 client->in_fd = in_fd; in vtest_server_add_client()
296 client->out_fd = out_fd; in vtest_server_add_client()
298 client->input.data.fd = in_fd; in vtest_server_add_client()
299 client->input.read = vtest_block_read; in vtest_server_add_client()
301 list_addtail(&client->head, &server.new_clients); in vtest_server_add_client()
362 struct vtest_client *client; in vtest_server_wait_clients() local
[all …]
/external/linux-kselftest/tools/testing/selftests/tpm2/
Dtpm2_tests.py15 self.client = tpm2.Client()
16 self.root_key = self.client.create_root_key()
19 self.client.flush_context(self.root_key)
20 self.client.close()
26 blob = self.client.seal(self.root_key, data, auth, None)
27 result = self.client.unseal(self.root_key, blob, auth, None)
31 handle = self.client.start_auth_session(tpm2.TPM2_SE_TRIAL)
38 self.client.policy_pcr(handle, pcrs)
39 self.client.policy_password(handle)
41 policy_dig = self.client.get_policy_digest(handle)
[all …]
/external/python/cpython3/Lib/test/
Dtest_ftplib.py476 self.client = ftplib.FTP(timeout=TIMEOUT, encoding=encoding)
477 self.client.connect(self.server.host, self.server.port)
480 self.client.close()
491 self.assertEqual(self.client.getwelcome(), '220 welcome')
494 self.assertEqual(self.client.sanitize('foo'), repr('foo'))
495 self.assertEqual(self.client.sanitize('pass 12345'), repr('pass *****'))
496 self.assertEqual(self.client.sanitize('PASS 12345'), repr('PASS *****'))
499 self.assertRaises(ValueError, self.client.sendcmd, 'echo 40\r\n0')
500 self.assertRaises(ValueError, self.client.sendcmd, 'echo 40\n0')
501 self.assertRaises(ValueError, self.client.sendcmd, 'echo 40\r0')
[all …]
/external/libcups/tools/
Dippeveprinter.c256 static http_status_t authenticate_request(ippeve_client_t *client);
260 static void copy_job_attributes(ippeve_client_t *client, ippeve_job_t *job, cups_array_t *ra);
262 static ippeve_job_t *create_job(ippeve_client_t *client);
269 static void delete_client(ippeve_client_t *client);
280 static ippeve_job_t *find_job(ippeve_client_t *client);
281 static void finish_document_data(ippeve_client_t *client, ippeve_job_t *job);
282 static void finish_document_uri(ippeve_client_t *client, ippeve_job_t *job);
283 static void html_escape(ippeve_client_t *client, const char *s, size_t slen);
284 static void html_footer(ippeve_client_t *client);
285 static void html_header(ippeve_client_t *client, const char *title, int refresh);
[all …]
/external/webrtc/rtc_base/
Dsocket_unittest.cc236 std::unique_ptr<AsyncSocket> client( in ConnectInternal() local
238 sink.Monitor(client.get()); in ConnectInternal()
239 EXPECT_EQ(AsyncSocket::CS_CLOSED, client->GetState()); in ConnectInternal()
240 EXPECT_TRUE(IsUnspecOrEmptyIP(client->GetLocalAddress().ipaddr())); in ConnectInternal()
256 EXPECT_EQ(0, client->Connect(server->GetLocalAddress())); in ConnectInternal()
257 EXPECT_FALSE(client->GetLocalAddress().IsNil()); in ConnectInternal()
258 EXPECT_NE(server->GetLocalAddress(), client->GetLocalAddress()); in ConnectInternal()
261 EXPECT_EQ(AsyncSocket::CS_CONNECTING, client->GetState()); in ConnectInternal()
262 EXPECT_FALSE(sink.Check(client.get(), SSE_OPEN)); in ConnectInternal()
263 EXPECT_FALSE(sink.Check(client.get(), SSE_CLOSE)); in ConnectInternal()
[all …]
/external/okhttp/okhttp-tests/src/test/java/com/squareup/okhttp/
DOkHttpClientTest.java61 OkHttpClient client = new OkHttpClient(); in timeoutDefaults() local
62 assertEquals(10_000, client.getConnectTimeout()); in timeoutDefaults()
63 assertEquals(10_000, client.getReadTimeout()); in timeoutDefaults()
64 assertEquals(10_000, client.getWriteTimeout()); in timeoutDefaults()
68 OkHttpClient client = new OkHttpClient(); in timeoutValidRange() local
70 client.setConnectTimeout(1, TimeUnit.NANOSECONDS); in timeoutValidRange()
74 client.setWriteTimeout(1, TimeUnit.NANOSECONDS); in timeoutValidRange()
78 client.setReadTimeout(1, TimeUnit.NANOSECONDS); in timeoutValidRange()
82 client.setConnectTimeout(365, TimeUnit.DAYS); in timeoutValidRange()
86 client.setWriteTimeout(365, TimeUnit.DAYS); in timeoutValidRange()
[all …]
/external/grpc-grpc/test/cpp/interop/
Dclient.cc105 grpc::testing::InteropClient client(channel_creation_func, true, in main() local
110 std::bind(&grpc::testing::InteropClient::DoEmpty, &client); in main()
112 std::bind(&grpc::testing::InteropClient::DoLargeUnary, &client); in main()
114 &grpc::testing::InteropClient::DoServerCompressedUnary, &client); in main()
116 &grpc::testing::InteropClient::DoClientCompressedUnary, &client); in main()
118 std::bind(&grpc::testing::InteropClient::DoRequestStreaming, &client); in main()
120 std::bind(&grpc::testing::InteropClient::DoResponseStreaming, &client); in main()
122 &grpc::testing::InteropClient::DoServerCompressedStreaming, &client); in main()
124 &grpc::testing::InteropClient::DoClientCompressedStreaming, &client); in main()
127 &client); in main()
[all …]

12345678910>>...257