Home
last modified time | relevance | path

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

12345678910>>...249

/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)))
283 static int client_thread_rm_stream(struct cras_client *client,
285 static int handle_message_from_server(struct cras_client *client);
286 static int reregister_notifications(struct cras_client *client);
296 static void server_state_unlock(const struct cras_client *client, int lock_rc) in server_state_unlock() argument
300 if (!client) in server_state_unlock()
302 client_int = to_client_int(client); in server_state_unlock()
318 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.c99 struct cras_observer_client *client; in output_volume_alert() local
103 DL_FOREACH (g_observer->clients, client) { in output_volume_alert()
104 if (client->ops.output_volume_changed) in output_volume_alert()
105 client->ops.output_volume_changed(client->context, in output_volume_alert()
112 struct cras_observer_client *client; in output_mute_alert() local
116 DL_FOREACH (g_observer->clients, client) { in output_mute_alert()
117 if (client->ops.output_mute_changed) in output_mute_alert()
118 client->ops.output_mute_changed(client->context, in output_mute_alert()
127 struct cras_observer_client *client; in capture_gain_alert() local
131 DL_FOREACH (g_observer->clients, client) { in capture_gain_alert()
[all …]
Dcras_control_rclient.c30 static void dump_audio_thread_info(struct cras_rclient *client) in dump_audio_thread_info() argument
39 client->ops->send_message_to_client(client, &msg.header, NULL, 0); in dump_audio_thread_info()
43 static void get_atlog_fd(struct cras_rclient *client) in get_atlog_fd() argument
50 client->ops->send_message_to_client(client, &msg.header, &atlog_fd, 1); in get_atlog_fd()
54 static void dump_audio_thread_snapshots(struct cras_rclient *client) in dump_audio_thread_snapshots() argument
60 client->ops->send_message_to_client(client, &msg.header, NULL, 0); in dump_audio_thread_snapshots()
63 static void handle_get_hotword_models(struct cras_rclient *client, in handle_get_hotword_models() argument
83 client->ops->send_message_to_client(client, &msg->header, NULL, 0); in handle_get_hotword_models()
89 client->ops->send_message_to_client(client, &msg->header, NULL, 0); in handle_get_hotword_models()
97 struct cras_rclient *client = (struct cras_rclient *)context; in send_output_volume_changed() local
[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/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/wayland/src/
Dwayland-server.c126 struct wl_client *client; member
146 struct wl_display *display = resource->client->display; in log_closure()
186 if (res && res->client != resource->client) { in verify_objects()
207 if (resource->client->error) in handle_array()
211 resource->client->error = 1; in handle_array()
219 resource->client->error = 1; in handle_array()
225 if (send_func(closure, resource->client->connection)) in handle_array()
226 resource->client->error = 1; in handle_array()
280 struct wl_client *client = resource->client; in wl_resource_post_error_vargs() local
292 if (client->error || !client->display_resource) in wl_resource_post_error_vargs()
[all …]
/external/webrtc/webrtc/base/
Dsocket_unittest.cc197 scoped_ptr<AsyncSocket> client(ss_->CreateAsyncSocket(loopback.family(), in ConnectInternal() local
199 sink.Monitor(client.get()); in ConnectInternal()
200 EXPECT_EQ(AsyncSocket::CS_CLOSED, client->GetState()); in ConnectInternal()
201 EXPECT_PRED1(IsUnspecOrEmptyIP, client->GetLocalAddress().ipaddr()); in ConnectInternal()
217 EXPECT_EQ(0, client->Connect(server->GetLocalAddress())); in ConnectInternal()
218 EXPECT_FALSE(client->GetLocalAddress().IsNil()); in ConnectInternal()
219 EXPECT_NE(server->GetLocalAddress(), client->GetLocalAddress()); in ConnectInternal()
222 EXPECT_EQ(AsyncSocket::CS_CONNECTING, client->GetState()); in ConnectInternal()
223 EXPECT_FALSE(sink.Check(client.get(), testing::SSE_OPEN)); in ConnectInternal()
224 EXPECT_FALSE(sink.Check(client.get(), testing::SSE_CLOSE)); in ConnectInternal()
[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/autotest/client/common_lib/cros/
Dtpm_utils.py8 from autotest_lib.client.common_lib import error
26 def TPMStatus(client): argument
31 out = client.run('cryptohome --action=tpm_status').stdout.strip()
48 def IsTPMAvailable(client): argument
53 status = TPMStatus(client)
57 def ClearTPMServer(client, out_dir): argument
63 if IsTPMAvailable(client):
67 client.run('stop ui')
69 password = TPMStatus(client)['Password']
72 client.get_file(_PASSWD_FILE, out_dir)
[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 …]
Dcr50_utils.py9 from autotest_lib.client.common_lib import error
189 def GetSavedVersion(client): argument
199 if not client.path_exists(CR50_VERSION):
202 result = client.run(GET_CR50_VERSION).stdout.strip()
206 def StopTrunksd(client): argument
208 if 'running' in client.run('status trunksd').stdout:
209 client.run('stop trunksd')
212 def GSCTool(client, args, ignore_status=False): argument
225 StopTrunksd(client)
234 result = client.run('gsctool %s' % ' '.join(args),
[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/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 …]
DURLConnectionTest.java109 private OkUrlFactory client; field in URLConnectionTest
115 client = new OkUrlFactory(new OkHttpClient()); in setUp()
135 connection = client.open(server.getUrl("/")); in requestHeaders()
194 connection = client.open(server.getUrl("/")); in getRequestPropertyReturnsLastValue()
207 connection = client.open(server.getUrl("/")); in responseHeaders()
237 connection = client.open(server.getUrl("/")); in serverSendsInvalidResponseHeaders()
248 connection = client.open(server.getUrl("/")); in serverSendsInvalidCodeTooLarge()
259 connection = client.open(server.getUrl("/")); in serverSendsInvalidCodeNotANumber()
270 connection = client.open(server.getUrl("/")); in serverSendsUnnecessaryWhitespace()
282 connection = client.open(url); in connectRetriesUntilConnectedOrFailed()
[all …]
/external/adhd/cras/src/tools/cras_test_client/
Dcras_test_client.c223 static int got_samples(struct cras_client *client, cras_stream_id_t stream_id, in got_samples() argument
257 static int put_samples(struct cras_client *client, cras_stream_id_t stream_id, in put_samples() argument
305 put_stdin_samples(struct cras_client *client, cras_stream_id_t stream_id, in put_stdin_samples() argument
322 static int stream_error(struct cras_client *client, cras_stream_id_t stream_id, in stream_error() argument
383 static void print_device_lists(struct cras_client *client) in print_device_lists() argument
392 rc = cras_client_get_output_devices(client, devs, nodes, &num_devs, in print_device_lists()
403 rc = cras_client_get_input_devices(client, devs, nodes, &num_devs, in print_device_lists()
411 static void print_attached_client_list(struct cras_client *client) in print_attached_client_list() argument
417 num_clients = cras_client_get_attached_clients(client, clients, in print_attached_client_list()
429 static void print_active_stream_info(struct cras_client *client) in print_active_stream_info() argument
[all …]
/external/python/cpython3/Lib/test/
Dtest_ftplib.py468 self.client = ftplib.FTP(timeout=TIMEOUT)
469 self.client.connect(self.server.host, self.server.port)
472 self.client.close()
483 self.assertEqual(self.client.getwelcome(), '220 welcome')
486 self.assertEqual(self.client.sanitize('foo'), repr('foo'))
487 self.assertEqual(self.client.sanitize('pass 12345'), repr('pass *****'))
488 self.assertEqual(self.client.sanitize('PASS 12345'), repr('PASS *****'))
491 self.assertRaises(ValueError, self.client.sendcmd, 'echo 40\r\n0')
492 self.assertRaises(ValueError, self.client.sendcmd, 'echo 40\n0')
493 self.assertRaises(ValueError, self.client.sendcmd, 'echo 40\r0')
[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 …]
/external/python/cpython2/Lib/test/
Dtest_ftplib.py426 self.client = ftplib.FTP(timeout=10)
427 self.client.connect(self.server.host, self.server.port)
430 self.client.close()
434 self.assertEqual(self.client.getwelcome(), '220 welcome')
437 self.assertEqual(self.client.sanitize('foo'), repr('foo'))
438 self.assertEqual(self.client.sanitize('pass 12345'), repr('pass *****'))
439 self.assertEqual(self.client.sanitize('PASS 12345'), repr('PASS *****'))
442 self.assertRaises(ValueError, self.client.sendcmd, 'echo 40\r\n0')
443 self.assertRaises(ValueError, self.client.sendcmd, 'echo 40\n0')
444 self.assertRaises(ValueError, self.client.sendcmd, 'echo 40\r0')
[all …]
/external/okhttp/okhttp-ws-tests/src/test/java/com/squareup/okhttp/internal/ws/
DRealWebSocketTest.java52 private RealWebSocket client; field in RealWebSocketTest
68 client = new RealWebSocket(true, server2client.source(), client2Server.sink(), random, in setUp()
99 client.sendMessage(null); in nullMessageThrows()
107 client.sendMessage(RequestBody.create(TEXT, "Hello!")); in textMessage()
113 client.sendMessage(RequestBody.create(BINARY, "Hello!")); in binaryMessage()
120 client.sendMessage(RequestBody.create(null, "Hey!")); in missingContentTypeThrows()
130 client.sendMessage(RequestBody.create(MediaType.parse("text/plain"), "Hey!")); in unknownContentTypeThrows()
151 client.sendMessage(message); in streamingMessage()
164 client.sendPing(new Buffer().writeUtf8("Pong?")); in streamingMessageCanInterleavePing()
170 client.sendMessage(message); in streamingMessageCanInterleavePing()
[all …]
/external/adhd/cras/src/tools/cras_monitor/
Dcras_monitor.c81 const char *node_name_for_node_id(struct cras_client *client, in node_name_for_node_id() argument
103 rc = cras_client_get_output_devices(client, devs, nodes, in node_name_for_node_id()
106 rc = cras_client_get_input_devices(client, devs, nodes, in node_name_for_node_id()
133 struct cras_client *client = (struct cras_client *)context; in active_node_changed() local
134 const char *node_name = node_name_for_node_id(client, dir, node_id); in active_node_changed()
142 struct cras_client *client = (struct cras_client *)context; in output_node_volume_changed() local
144 node_name_for_node_id(client, CRAS_STREAM_OUTPUT, node_id); in output_node_volume_changed()
152 struct cras_client *client = (struct cras_client *)context; in node_left_right_swapped_changed() local
154 node_name_for_node_id(client, CRAS_STREAM_OUTPUT, node_id); in node_left_right_swapped_changed()
162 struct cras_client *client = (struct cras_client *)context; in input_node_gain_changed() local
[all …]
/external/tensorflow/tensorflow/compiler/xla/python/
Dshared_device_buffer_test.cc28 LocalClient* client = ClientLibrary::LocalClientOrDie(); in TEST() local
33 shape, client->backend().transfer_manager(), in TEST()
34 client->backend().memory_allocator(), 0, nullptr)); in TEST()
37 EXPECT_EQ(buffer->allocator(), client->backend().memory_allocator()); in TEST()
43 LocalClient* client = ClientLibrary::LocalClientOrDie(); in TEST() local
50 a_shape, client->backend().transfer_manager(), in TEST()
51 client->backend().memory_allocator(), 0, nullptr)); in TEST()
54 b_shape, client->backend().transfer_manager(), in TEST()
55 client->backend().memory_allocator(), 0, nullptr)); in TEST()
59 client->backend().transfer_manager(), in TEST()
[all …]
/external/adhd/cras/src/alsa_plugin/
Dctl_cras.c45 struct cras_client *client; member
54 cras_client_stop(cras->client); in ctl_cras_close()
55 cras_client_destroy(cras->client); in ctl_cras_close()
122 static long capture_index_to_gain(struct cras_client *client, long index) in capture_index_to_gain() argument
128 min = cras_client_get_system_min_capture_gain(client); in capture_index_to_gain()
129 max = cras_client_get_system_max_capture_gain(client); in capture_index_to_gain()
142 static long capture_gain_to_index(struct cras_client *client, long gain) in capture_gain_to_index() argument
148 min = cras_client_get_system_min_capture_gain(client); in capture_gain_to_index()
149 max = cras_client_get_system_max_capture_gain(client); in capture_gain_to_index()
162 static int get_nodes(struct cras_client *client, enum CRAS_STREAM_DIRECTION dir, in get_nodes() argument
[all …]

12345678910>>...249