Home
last modified time | relevance | path

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

12345678910>>...257

/external/adhd/cras/src/libcras/
Dcras_client.c159 struct cras_client *client; member
254 struct cras_client client; member
259 ((struct client_int *)((char *)cptr - offsetof(struct client_int, client)))
279 static int client_thread_rm_stream(struct cras_client *client,
281 static int handle_message_from_server(struct cras_client *client);
282 static int reregister_notifications(struct cras_client *client);
292 static void server_state_unlock(const struct cras_client *client, in server_state_unlock() argument
297 if (!client) in server_state_unlock()
299 client_int = to_client_int(client); in server_state_unlock()
315 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,
100 typedef int (*cras_unified_cb_t)(struct cras_client *client,
116 typedef int (*cras_error_cb_t)(struct cras_client *client,
136 typedef void (*cras_server_error_cb_t)(struct cras_client *client,
170 typedef void (*cras_connection_status_cb_t)(struct cras_client *client,
175 typedef void (*cras_thread_priority_cb_t)(struct cras_client *client);
178 typedef void (*get_hotword_models_cb_t)(struct cras_client *client,
182 typedef void (*cras_hotword_trigger_cb_t)(struct cras_client *client,
187 typedef int (*cras_hotword_error_cb_t)(struct cras_client *client,
203 int cras_client_create(struct cras_client **client);
[all …]
/external/tensorflow/tensorflow/contrib/ignite/kernels/igfs/
Digfs_messages.cc20 Status IGFSPath::Read(ExtendedTCPClient *client) { in Read() argument
21 return client->ReadNullableString(&path); in Read()
24 Status IGFSFile::Read(ExtendedTCPClient *client) { in Read() argument
31 TF_RETURN_IF_ERROR(client->ReadBool(&has_path)); in Read()
34 TF_RETURN_IF_ERROR(path.Read(client)); in Read()
37 TF_RETURN_IF_ERROR(client->ReadInt(&block_size)); in Read()
38 TF_RETURN_IF_ERROR(client->ReadLong(&group_block_size)); in Read()
39 TF_RETURN_IF_ERROR(client->ReadLong(&length)); in Read()
40 TF_RETURN_IF_ERROR(client->ReadStringMap(&properties)); in Read()
41 TF_RETURN_IF_ERROR(client->ReadLong(&access_time)); in Read()
[all …]
/external/syzkaller/dashboard/app/
Dfix_test.go22 c.client.UploadBuild(build1)
25 c.client.ReportCrash(crash1)
27 builderPollResp, _ := c.client.BuilderPoll(build1.Manager)
30 needRepro, _ := c.client.NeedRepro(testCrashID(crash1))
33 rep := c.client.pollBug()
36 reply, _ := c.client.ReportingUpdate(&dashapi.BugUpdate{
44 needRepro, _ = c.client.NeedRepro(testCrashID(crash1))
48 builderPollResp, _ = c.client.BuilderPoll(build1.Manager)
53 c.client.updateBug(rep.ID, dashapi.BugStatusOpen, "")
58 reply, _ = c.client.ReportingUpdate(&dashapi.BugUpdate{
[all …]
Dreporting_test.go20 c.client.UploadBuild(build)
29 c.client.ReportCrash(crash1)
32 resp, _ := c.client.ReportingPollBugs("unknown")
36 resp, _ = c.client.ReportingPollBugs("test")
70 c.expectEQ(c.client.pollBug(), want)
77 c.client.ReportCrash(crash1)
78 rep1 := c.client.pollBug()
90 reply, _ := c.client.ReportingUpdate(&dashapi.BugUpdate{
98 c.client.pollBugs(0)
101 c.client.updateBug(rep.ID, dashapi.BugStatusUpstream, "")
[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( in output_volume_alert()
106 client->context, in output_volume_alert()
113 struct cras_observer_client *client; in output_mute_alert() local
117 DL_FOREACH(g_observer->clients, client) { in output_mute_alert()
118 if (client->ops.output_mute_changed) in output_mute_alert()
119 client->ops.output_mute_changed( in output_mute_alert()
120 client->context, in output_mute_alert()
[all …]
Dcras_rclient.c38 static int handle_client_stream_connect(struct cras_rclient *client, in handle_client_stream_connect() argument
73 stream_config.client = client; in handle_client_stream_connect()
103 rc = cras_rclient_send_message(client, reply, stream_fds, 2); in handle_client_stream_connect()
129 cras_rclient_send_message(client, reply, NULL, 0); in handle_client_stream_connect()
140 struct cras_rclient *client, in handle_client_stream_disconnect() argument
148 static void dump_audio_thread_info(struct cras_rclient *client) in dump_audio_thread_info() argument
157 cras_rclient_send_message(client, &msg.header, NULL, 0); in dump_audio_thread_info()
161 static void dump_audio_thread_snapshots(struct cras_rclient *client) in dump_audio_thread_snapshots() argument
167 cras_rclient_send_message(client, &msg.header, NULL, 0); in dump_audio_thread_snapshots()
170 static void handle_get_hotword_models(struct cras_rclient *client, in handle_get_hotword_models() argument
[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/wayland/src/
Dwayland-server.c121 struct wl_client *client; member
140 struct wl_display *display = resource->client->display; in log_closure()
174 resource->client->error = 1; in wl_resource_post_event_array()
178 if (wl_closure_send(closure, resource->client->connection)) in wl_resource_post_event_array()
179 resource->client->error = 1; in wl_resource_post_event_array()
213 resource->client->error = 1; in wl_resource_queue_event_array()
217 if (wl_closure_queue(closure, resource->client->connection)) in wl_resource_queue_event_array()
218 resource->client->error = 1; in wl_resource_queue_event_array()
244 struct wl_client *client = resource->client; in wl_resource_post_error() local
252 client->error = 1; in wl_resource_post_error()
[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/autotest/client/common_lib/cros/
Dcr50_utils.py9 from autotest_lib.client.common_lib import error
187 def GetSavedVersion(client): argument
197 if not client.path_exists(CR50_VERSION):
200 result = client.run(GET_CR50_VERSION).stdout.strip()
204 def GetRLZ(client): argument
213 result = client.run('vpd -g rlz_brand_code', ignore_status=True)
220 def SetRLZ(client, rlz): argument
234 if rlz == GetRLZ(client):
237 client.run('vpd -s rlz_brand_code=%s' % rlz)
239 client.run('vpd -d rlz_brand_code')
[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 …]
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 …]
/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/adhd/cras/src/tests/
Dcras_test_client.c125 static int got_samples(struct cras_client *client, in got_samples() argument
162 static int put_samples(struct cras_client *client, in put_samples() argument
212 static int put_stdin_samples(struct cras_client *client, in put_stdin_samples() argument
233 static int stream_error(struct cras_client *client, in stream_error() argument
298 static void print_device_lists(struct cras_client *client) in print_device_lists() argument
307 rc = cras_client_get_output_devices(client, devs, nodes, &num_devs, in print_device_lists()
318 rc = cras_client_get_input_devices(client, devs, nodes, &num_devs, in print_device_lists()
326 static void print_attached_client_list(struct cras_client *client) in print_attached_client_list() argument
332 num_clients = cras_client_get_attached_clients(client, in print_attached_client_list()
347 static void print_active_stream_info(struct cras_client *client) in print_active_stream_info() argument
[all …]
/external/python/cpython3/Lib/test/
Dtest_ftplib.py471 self.client = ftplib.FTP(timeout=TIMEOUT)
472 self.client.connect(self.server.host, self.server.port)
475 self.client.close()
486 self.assertEqual(self.client.getwelcome(), '220 welcome')
489 self.assertEqual(self.client.sanitize('foo'), repr('foo'))
490 self.assertEqual(self.client.sanitize('pass 12345'), repr('pass *****'))
491 self.assertEqual(self.client.sanitize('PASS 12345'), repr('PASS *****'))
494 self.assertRaises(ValueError, self.client.sendcmd, 'echo 40\r\n0')
495 self.assertRaises(ValueError, self.client.sendcmd, 'echo 40\n0')
496 self.assertRaises(ValueError, self.client.sendcmd, 'echo 40\r0')
[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/nos/host/android/hals/authsecret/test/
Dtest.cpp71 MockNuggetClient client; in TEST() local
72 AuthSecret hal{client}; in TEST()
74 EXPECT_CALL(client, CallApp(APP_ID_NUGGET, NUGGET_PARAM_CHANGE_UPDATE_PASSWORD, in TEST()
77 EXPECT_CALL(client, CallApp(APP_ID_NUGGET, NUGGET_PARAM_ENABLE_UPDATE, _, _)) in TEST()
79 EXPECT_CALL(client, CallApp(APP_ID_NUGGET, NUGGET_PARAM_REBOOT, _, _)) in TEST()
88 MockNuggetClient client; in TEST() local
89 AuthSecret hal{client}; in TEST()
91 EXPECT_CALL(client, CallApp(APP_ID_NUGGET, NUGGET_PARAM_CHANGE_UPDATE_PASSWORD, in TEST()
94 EXPECT_CALL(client, CallApp(APP_ID_NUGGET, NUGGET_PARAM_ENABLE_UPDATE, _, _)) in TEST()
96 EXPECT_CALL(client, CallApp(APP_ID_NUGGET, NUGGET_PARAM_REBOOT, _, _)) in TEST()
[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/nos/host/android/citadel/validation/
Dcitadel_validation_tool.cpp61 bool ReadRegister(NuggetClientInterface& client, uint32_t address, uint32_t* value) { in ReadRegister() argument
67 const uint32_t status = client.CallApp(APP_ID_NUGGET, NUGGET_PARAM_READ32, buffer, &buffer); in ReadRegister()
84 bool WriteRegister(NuggetClientInterface& client, uint32_t address, uint32_t value) { in WriteRegister() argument
92 const uint32_t status = client.CallApp(APP_ID_NUGGET, NUGGET_PARAM_WRITE32, buffer, nullptr); in WriteRegister()
106 bool CheckRegisterInRange(NuggetClientInterface& client, uint32_t address, in CheckRegisterInRange() argument
109 if (!ReadRegister(client, address, &value)) { in CheckRegisterInRange()
124 bool CheckRegisterNotInRange(NuggetClientInterface& client, uint32_t address, in CheckRegisterNotInRange() argument
127 if (!ReadRegister(client, address, &value)) { in CheckRegisterNotInRange()
139 bool CyclesSinceBoot(NuggetClientInterface & client, uint32_t* cycles) { in CyclesSinceBoot() argument
142 if (client.CallApp(APP_ID_NUGGET, NUGGET_PARAM_CYCLES_SINCE_BOOT, in CyclesSinceBoot()
[all …]
/external/nos/test/system-test-harness/src/
Davb_tests.cc30 static unique_ptr<nos::NuggetClientInterface> client; member in __anon6499bfc00111::AvbTest
98 unique_ptr<nos::NuggetClientInterface> AvbTest::client; member in __anon6499bfc00111::AvbTest
104 client = nugget_tools::MakeNuggetClient(); in SetUpTestCase()
105 client->Open(); in SetUpTestCase()
106 EXPECT_TRUE(client->IsOpen()) << "Unable to connect"; in SetUpTestCase()
110 client->Close(); in TearDownTestCase()
111 client = unique_ptr<nos::NuggetClientInterface>(); in TearDownTestCase()
123 avb_tools::BootloaderDone(client.get()); // We don't need BL for setup. in SetUp()
129 ResetProduction(client.get()); in SetUp()
131 code = Reset(client.get(), ResetRequest::LOCKS, NULL, 0); in SetUp()
[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/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/python/oauth2client/tests/
Dtest_client.py39 from oauth2client import client
83 credentials = client.Credentials()
85 client.Credentials.new_from_json(json)
88 credentials = client.Credentials()
94 credentials = client.Credentials()
100 credentials = client.Credentials()
106 credentials = client.Credentials()
112 credentials = client.Credentials()
118 '_class': client.Credentials.__name__,
119 '_module': client.Credentials.__module__,
[all …]

12345678910>>...257