Home
last modified time | relevance | path

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

12345678910>>...17

/system/chre/platform/slpi/see/
Dsns_qmi_client.c39 struct sns_client *client; member
66 sns_client *client = ind_cb_data; in client_ind_cb() local
82 client->ind_cb(client, ind->payload, ind->payload_len, client->ind_cb_data); in client_ind_cb()
97 static sns_request *create_request(sns_client *client, sns_client_resp resp_cb, in create_request() argument
106 request->client = client; in create_request()
133 request->resp_cb(request->client, err, request->resp_cb_data); in client_resp_cb()
147 sns_client *client = err_cb_data; in client_error_cb() local
152 client->error_cb(client, SNS_STD_ERROR_INVALID_STATE, client->error_cb_data); in client_error_cb()
168 sns_client *client; in sns_client_init() local
170 client = sns_malloc(sizeof(*client)); in sns_client_init()
[all …]
/system/bt/hci/src/
Dhci_inject.cc137 client_t* client = (client_t*)osi_calloc(sizeof(client_t)); in accept_ready() local
139 client->socket = socket; in accept_ready()
141 if (!list_append(clients, client)) { in accept_ready()
143 client_free(client); in accept_ready()
147 socket_register(socket, thread_get_reactor(thread), client, read_ready, NULL); in accept_ready()
154 client_t* client = (client_t*)context; in read_ready() local
157 socket_read(client->socket, client->buffer + client->buffer_size, in read_ready()
158 sizeof(client->buffer) - client->buffer_size); in read_ready()
160 list_remove(clients, client); in read_ready()
163 client->buffer_size += ret; in read_ready()
[all …]
/system/core/logd/
DFlushCommand.cpp38 void FlushCommand::runSocketCommand(SocketClient* client) { in runSocketCommand() argument
46 if (entry->mClient == client) { in runSocketCommand()
75 bool FlushCommand::hasReadLogs(SocketClient* client) { in hasReadLogs() argument
76 return clientHasLogCredentials(client); in hasReadLogs()
79 static bool clientHasSecurityCredentials(SocketClient* client) { in clientHasSecurityCredentials() argument
80 return (client->getUid() == AID_SYSTEM) || (client->getGid() == AID_SYSTEM); in clientHasSecurityCredentials()
83 bool FlushCommand::hasSecurityLogs(SocketClient* client) { in hasSecurityLogs() argument
84 return clientHasSecurityCredentials(client); in hasSecurityLogs()
DFlushCommand.h37 virtual void runSocketCommand(SocketClient* client);
39 static bool hasReadLogs(SocketClient* client);
40 static bool hasSecurityLogs(SocketClient* client);
DLogTimes.cpp30 LogTimeEntry::LogTimeEntry(LogReader& reader, SocketClient* client, in LogTimeEntry() argument
40 mClient(client), in LogTimeEntry()
73 SocketClient* client = me->mClient; in threadStart() local
77 bool privileged = FlushCommand::hasReadLogs(client); in threadStart()
78 bool security = FlushCommand::hasSecurityLogs(client); in threadStart()
101 logbuf.flushTo(client, start, nullptr, privileged, security, in threadStart()
105 start = logbuf.flushTo(client, start, me->mLastTid, privileged, in threadStart()
128 reader.release(client); in threadStart()
130 client->decRef(); in threadStart()
/system/core/libcutils/
Dsockets_test.cpp34 static void TestConnectedSockets(cutils_socket_t server, cutils_socket_t client, in TestConnectedSockets() argument
37 ASSERT_NE(INVALID_SOCKET, client); in TestConnectedSockets()
44 ASSERT_EQ(3, send(client, "foo", 3, 0)); in TestConnectedSockets()
60 EXPECT_EQ(3, recv(client, buffer, sizeof(buffer), 0)); in TestConnectedSockets()
68 EXPECT_EQ(11, socket_send_buffers(client, socket_buffers, 3)); in TestConnectedSockets()
73 EXPECT_EQ(0, socket_close(client)); in TestConnectedSockets()
100 cutils_socket_t client = socket_network_client( in TEST() local
103 TestConnectedSockets(server, client, SOCK_DGRAM); in TEST()
111 cutils_socket_t client = socket_network_client( in TEST() local
116 TestConnectedSockets(handler, client, SOCK_STREAM); in TEST()
[all …]
/system/chre/platform/slpi/see/include/
Dsns_client.h41 typedef void (*sns_client_ind)(struct sns_client *client, void *msg,
49 typedef void (*sns_client_resp)(struct sns_client *client, sns_std_error error,
57 typedef void (*sns_client_error)(struct sns_client *client, sns_std_error error,
72 int sns_client_init(struct sns_client **client, uint32_t timeout,
82 int sns_client_deinit(struct sns_client *client);
92 int sns_client_send(struct sns_client *client, sns_client_request_msg *msg,
/system/core/adb/pairing_auth/tests/
Dpairing_auth_test.cpp52 PairingAuthUniquePtr client(nullptr, PairingAuthDeleter); in TEST_F() local
55 client = PairingAuthUniquePtr(pairing_auth_client_new(nullptr, 0), in TEST_F()
61 client = PairingAuthUniquePtr(pairing_auth_client_new(nullptr, 2), in TEST_F()
68 client = PairingAuthUniquePtr(pairing_auth_client_new(&p, 0), PairingAuthDeleter); in TEST_F()
76 auto client = makeClient(pswd); in TEST_F() local
79 ASSERT_NE(nullptr, client); in TEST_F()
84 size_t msg_size = pairing_auth_msg_size(client.get()); in TEST_F()
87 pairing_auth_get_spake2_msg(client.get(), buf.data()); in TEST_F()
143 auto client = makeClient({0x01, 0x02, 0x03}); in TEST_F() local
144 std::vector<uint8_t> client_msg(pairing_auth_msg_size(client.get())); in TEST_F()
[all …]
/system/core/fastboot/
Dsocket_test.cpp36 std::unique_ptr<Socket>* client, in MakeConnectedSockets() argument
44 *client = Socket::NewClient(protocol, hostname, (*server)->GetLocalPort(), nullptr); in MakeConnectedSockets()
45 if (*client == nullptr) { in MakeConnectedSockets()
78 std::unique_ptr<Socket> server, client; in TEST() local
81 ASSERT_TRUE(MakeConnectedSockets(protocol, &server, &client)); in TEST()
83 EXPECT_TRUE(SendString(client.get(), "foo")); in TEST()
87 EXPECT_TRUE(ReceiveString(client.get(), "bar baz")); in TEST()
92 std::unique_ptr<Socket> server, client; in TEST() local
96 ASSERT_TRUE(MakeConnectedSockets(protocol, &server, &client)); in TEST()
101 EXPECT_EQ(-1, client->Receive(buffer, sizeof(buffer), kShortTimeoutMs)); in TEST()
[all …]
/system/bt/service/ipc/binder/
Dbluetooth_low_energy_binder_server.cc73 auto client = GetLEClient(client_id); in Connect() local
74 if (!client) { in Connect()
81 client->Connect(std::string(String8(address).string()), is_direct); in Connect()
91 auto client = GetLEClient(client_id); in Disconnect() local
92 if (!client) { in Disconnect()
98 *_aidl_return = client->Disconnect(std::string(String8(address).string())); in Disconnect()
109 auto client = GetLEClient(client_id); in SetMtu() local
110 if (!client) { in SetMtu()
116 *_aidl_return = client->SetMtu(std::string(String8(address).string()), mtu); in SetMtu()
121 bluetooth::LowEnergyClient* client, int status, const char* address, in OnConnectionState() argument
[all …]
/system/tools/aidl/tests/
Dtest_data_example_interface.cpp1392 …droid.os.Trace.traceBegin(android.os.Trace.TRACE_TAG_AIDL, "IExampleInterface::isEnabled::client");
1414 …ndroid.os.Trace.traceBegin(android.os.Trace.TRACE_TAG_AIDL, "IExampleInterface::getState::client");
1436 …roid.os.Trace.traceBegin(android.os.Trace.TRACE_TAG_AIDL, "IExampleInterface::getAddress::client");
1459 ….os.Trace.traceBegin(android.os.Trace.TRACE_TAG_AIDL, "IExampleInterface::getParcelables::client");
1483 …oid.os.Trace.traceBegin(android.os.Trace.TRACE_TAG_AIDL, "IExampleInterface::setScanMode::client");
1508 ….os.Trace.traceBegin(android.os.Trace.TRACE_TAG_AIDL, "IExampleInterface::registerBinder::client");
1530 …Trace.traceBegin(android.os.Trace.TRACE_TAG_AIDL, "IExampleInterface::getRecursiveBinder::client");
1552 …s.Trace.traceBegin(android.os.Trace.TRACE_TAG_AIDL, "IExampleInterface::takesAnInterface::client");
1575 …s.Trace.traceBegin(android.os.Trace.TRACE_TAG_AIDL, "IExampleInterface::takesAParcelable::client");
/system/netd/server/
DFwmarkServer.cpp47 bool isSystemServer(SocketClient* client) { in isSystemServer() argument
48 if (client->getUid() != AID_SYSTEM) { in isSystemServer()
53 if (getpeercon(client->getSocket(), &context)) { in isSystemServer()
74 bool FwmarkServer::onDataAvailable(SocketClient* client) { in onDataAvailable() argument
76 int error = processClient(client, &socketFd); in onDataAvailable()
83 client->sendData(&error, sizeof(error)); in onDataAvailable()
101 int FwmarkServer::processClient(SocketClient* client, int* socketFd) { in processClient() argument
108 ReceiveFileDescriptorVector(client->getSocket(), buf, sizeof(buf), 1, &received_fds); in processClient()
128 Permission permission = mNetworkController->getPermissionForUser(client->getUid()); in processClient()
138 return mTrafficCtrl->setCounterSet(command.trafficCtrlInfo, command.uid, client->getUid()); in processClient()
[all …]
/system/chre/host/common/test/
Dchre_test_client.cc135 void requestHubInfo(SocketClient &client) { in requestHubInfo() argument
140 if (!client.sendMessage(builder.GetBufferPointer(), builder.GetSize())) { in requestHubInfo()
145 void requestNanoappList(SocketClient &client) { in requestNanoappList() argument
150 if (!client.sendMessage(builder.GetBufferPointer(), builder.GetSize())) { in requestNanoappList()
155 void sendMessageToNanoapp(SocketClient &client) { in sendMessageToNanoapp() argument
164 if (!client.sendMessage(builder.GetBufferPointer(), builder.GetSize())) { in sendMessageToNanoapp()
169 void sendLoadNanoappRequest(SocketClient &client, const char *filename, in sendLoadNanoappRequest() argument
198 if (!client.sendMessage(builder.GetBufferPointer(), builder.GetSize())) { in sendLoadNanoappRequest()
203 void sendUnloadNanoappRequest(SocketClient &client, uint64_t appId) { in sendUnloadNanoappRequest() argument
211 if (!client.sendMessage(builder.GetBufferPointer(), builder.GetSize())) { in sendUnloadNanoappRequest()
[all …]
/system/tools/hidl/test/java_test/
Dhidl_test_java9 echo "Testing $SIZE bit native client/server"
11 # Test native server with Java client
16 && echo "Java client => native server PASSED" \
17 || (echo "Java client => native server FAILED" && false) || e=1
21 # Test Java server with native client
25 && echo "native client => Java server PASSED" \
26 || (echo "native client => Java server FAILED" && false) || e=1
/system/core/adb/
Dtransport_benchmark.cpp61 auto client = MakeConnection<ConnectionType>(unique_fd(fds[0])); in BM_Connection_Unidirectional() local
66 client->SetReadCallback([](Connection*, std::unique_ptr<apacket>) -> bool { return true; }); in BM_Connection_Unidirectional()
72 client->SetErrorCallback( in BM_Connection_Unidirectional()
77 client->Start(); in BM_Connection_Unidirectional()
91 client->Write(std::move(packet)); in BM_Connection_Unidirectional()
98 client->Stop(); in BM_Connection_Unidirectional()
116 auto client = MakeConnection<ConnectionType>(unique_fd(fds[0])); in BM_Connection_Echo() local
124 … client->SetReadCallback([&received_bytes](Connection*, std::unique_ptr<apacket> packet) -> bool { in BM_Connection_Echo()
146 client->SetErrorCallback( in BM_Connection_Echo()
151 client->Start(); in BM_Connection_Echo()
[all …]
DAndroid.bp193 "client/auth.cpp",
194 "client/adb_wifi.cpp",
195 "client/usb_libusb.cpp",
196 "client/usb_dispatch.cpp",
197 "client/transport_mdns.cpp",
198 "client/transport_usb.cpp",
199 "client/pairing/pairing_client.cpp",
206 srcs: ["client/usb_linux.cpp"] + libadb_linux_srcs,
209 srcs: ["client/usb_osx.cpp"],
217 "client/usb_windows.cpp",
[all …]
/system/bt/service/test/
Dlow_energy_client_unittest.cc60 void OnConnectionState(LowEnergyClient* client, int status, in OnConnectionState() argument
62 ASSERT_TRUE(client); in OnConnectionState()
66 void OnMtuChanged(LowEnergyClient* client, int status, const char* address, in OnMtuChanged() argument
68 ASSERT_TRUE(client); in OnMtuChanged()
120 auto callback = [&](std::unique_ptr<LowEnergyClient> client) { in SetUp() argument
121 le_client_ = std::move(client); in SetUp()
135 const std::function<void(std::unique_ptr<LowEnergyClient> client)> in RegisterTestClient()
178 std::unique_ptr<LowEnergyClient> client; in TEST_F() local
185 client = std::unique_ptr<LowEnergyClient>( in TEST_F()
224 ASSERT_TRUE(client.get() != nullptr); // Assert to terminate in case of error in TEST_F()
[all …]
Dgatt_client_unittest.cc89 std::unique_ptr<GattClient> client; in TEST_F() local
96 client = std::unique_ptr<GattClient>( in TEST_F()
135 ASSERT_TRUE(client.get() != nullptr); // Assert to terminate in case of error in TEST_F()
137 EXPECT_EQ(client_id0, client->GetInstanceId()); in TEST_F()
138 EXPECT_EQ(uuid0, client->GetAppIdentifier()); in TEST_F()
145 client.reset(); in TEST_F()
154 ASSERT_TRUE(client.get() == nullptr); // Assert to terminate in case of error in TEST_F()
/system/chre/host/common/test/power_test/
Dchre_power_test_client.cc263 bool requestNanoappList(SocketClient &client) { in requestNanoappList() argument
268 if (!client.sendMessage(builder.GetBufferPointer(), builder.GetSize())) { in requestNanoappList()
275 bool sendLoadNanoappRequest(SocketClient &client, const char *filename, in sendLoadNanoappRequest() argument
304 client.sendMessage(builder.GetBufferPointer(), builder.GetSize()); in sendLoadNanoappRequest()
312 bool loadNanoapp(SocketClient &client, sp<SocketCallbacks> callbacks, in loadNanoapp() argument
315 if (!sendLoadNanoappRequest(client, filename, appId, appVersion, in loadNanoapp()
327 bool sendUnloadNanoappRequest(SocketClient &client, uint64_t appId) { in sendUnloadNanoappRequest() argument
335 if (!client.sendMessage(builder.GetBufferPointer(), builder.GetSize())) { in sendUnloadNanoappRequest()
342 bool unloadNanoapp(SocketClient &client, sp<SocketCallbacks> callbacks, in unloadNanoapp() argument
344 if (!sendUnloadNanoappRequest(client, appId)) { in unloadNanoapp()
[all …]
/system/core/adb/client/pairing/tests/
Dpairing_connection_test.cpp163 auto client = PairingClient::create({}, client_info_, {}, {}, ""); in TEST_F() local
164 EXPECT_EQ(nullptr, client); in TEST_F()
166 client = PairingClient::create({}, client_info_, {0x01}, {0x01}, "127.0.0.1"); in TEST_F()
167 EXPECT_EQ(nullptr, client); in TEST_F()
169 client = PairingClient::create({0x01}, {}, {0x01}, {0x01}, "127.0.0.1"); in TEST_F()
170 EXPECT_EQ(nullptr, client); in TEST_F()
172 client = PairingClient::create({0x01}, client_info_, {}, {0x01}, "127.0.0.1"); in TEST_F()
173 EXPECT_EQ(nullptr, client); in TEST_F()
175 client = PairingClient::create({0x01}, client_info_, {0x01}, {}, "127.0.0.1"); in TEST_F()
176 EXPECT_EQ(nullptr, client); in TEST_F()
[all …]
/system/sepolicy/public/
Dhal_neuralnetworks.te1 # HwBinder IPC from client to server, and callbacks
11 # Allow NN HAL service to use a client-provided fd residing in /data/data/.
15 # Allow NN HAL service to use a client-provided fd residing in /data/local/tmp/.
18 # Allow NN HAL service to read a client-provided ION memory fd.
21 # Allow NN HAL service to use a client-provided fd residing in /storage
24 # Allow NN HAL client to check the ro.nnapi.extensions.deny_on_product
/system/sepolicy/prebuilts/api/30.0/public/
Dhal_neuralnetworks.te1 # HwBinder IPC from client to server, and callbacks
11 # Allow NN HAL service to use a client-provided fd residing in /data/data/.
15 # Allow NN HAL service to use a client-provided fd residing in /data/local/tmp/.
18 # Allow NN HAL service to read a client-provided ION memory fd.
21 # Allow NN HAL service to use a client-provided fd residing in /storage
24 # Allow NN HAL client to check the ro.nnapi.extensions.deny_on_product
/system/chre/host/common/audio_stress_test/
Daudio_stress_test.cc79 void sendLoadNanoappRequest(SocketClient &client, const char *filename, in sendLoadNanoappRequest() argument
107 if (!client.sendMessage(builder.GetBufferPointer(), builder.GetSize())) { in sendLoadNanoappRequest()
115 SocketClient client; in main() local
118 if (!client.connect("chre", callbacks)) { in main()
121 sendLoadNanoappRequest(client, "/data/audio_stress_test.so", in main()
/system/bt/service/common/
DREADME2 and our client library. All source files here are under the "bluetooth"
3 subdirectory, which is the exported root path for the client static library.
10 This is so that client applications that link against the client library have
/system/core/adb/libs/adbconnection/
Dadbconnection_server.cpp82 unique_fd client( in adbconnection_listen() local
85 if (client == -1) { in adbconnection_listen()
92 register_event.data.fd = client.get(); in adbconnection_listen()
94 if (epoll_ctl(epfd.get(), EPOLL_CTL_ADD, client.get(), &register_event) != 0) { in adbconnection_listen()
98 pending_connections.emplace_back(std::move(client)); in adbconnection_listen()

12345678910>>...17