| /system/chre/platform/slpi/see/ |
| D | sns_qmi_client.c | 39 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/ |
| D | hci_inject.cc | 137 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/libcutils/ |
| D | sockets_test.cpp | 34 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/chpp/clients/ |
| D | wwan.c | 66 struct ChppClientState client; // WWAN client state member
164 &wwanClientContext->client, in chppDispatchWwanResponse()
171 chppClientProcessOpenResponse(&wwanClientContext->client, buf, len); in chppDispatchWwanResponse()
217 chppClientInit(&wwanClientContext->client, handle); in chppWwanClientInit()
230 chppClientDeinit(&wwanClientContext->client); in chppWwanClientDeinit()
242 chppClientCloseOpenRequests(&wwanClientContext->client, &kWwanClientConfig, in chppWwanClientNotifyReset()
245 if (wwanClientContext->client.openState != CHPP_OPEN_STATE_OPENED && in chppWwanClientNotifyReset()
246 !wwanClientContext->client.pseudoOpen) { in chppWwanClientNotifyReset()
250 wwanClientContext->client.openState); in chppWwanClientNotifyReset()
251 chppClientSendOpenRequest(&wwanClientContext->client, in chppWwanClientNotifyReset()
[all …]
|
| D | gnss.c | 65 struct ChppClientState client; // GNSS client state member
183 &gnssClientContext->client, in chppDispatchGnssResponse()
190 chppClientProcessOpenResponse(&gnssClientContext->client, buf, len); in chppDispatchGnssResponse()
297 chppClientInit(&gnssClientContext->client, handle); in chppGnssClientInit()
310 chppClientDeinit(&gnssClientContext->client); in chppGnssClientDeinit()
322 chppClientCloseOpenRequests(&gnssClientContext->client, &kGnssClientConfig, in chppGnssClientNotifyReset()
325 if (gnssClientContext->client.openState != CHPP_OPEN_STATE_OPENED && in chppGnssClientNotifyReset()
326 !gnssClientContext->client.pseudoOpen) { in chppGnssClientNotifyReset()
330 gnssClientContext->client.openState); in chppGnssClientNotifyReset()
332 chppClientSendOpenRequest(&gGnssClientContext.client, in chppGnssClientNotifyReset()
[all …]
|
| D | wifi.c | 73 struct ChppClientState client; // WiFi client state member
189 &wifiClientContext->client, in chppDispatchWifiResponse()
196 chppClientProcessOpenResponse(&wifiClientContext->client, buf, len); in chppDispatchWifiResponse()
294 chppClientInit(&wifiClientContext->client, handle); in chppWifiClientInit()
307 chppClientDeinit(&wifiClientContext->client); in chppWifiClientDeinit()
319 chppClientCloseOpenRequests(&wifiClientContext->client, &kWifiClientConfig, in chppWifiClientNotifyReset()
323 if (wifiClientContext->client.openState != CHPP_OPEN_STATE_OPENED && in chppWifiClientNotifyReset()
324 !wifiClientContext->client.pseudoOpen) { in chppWifiClientNotifyReset()
328 wifiClientContext->client.openState); in chppWifiClientNotifyReset()
329 chppClientSendOpenRequest(&wifiClientContext->client, in chppWifiClientNotifyReset()
[all …]
|
| D | loopback.c | 45 struct ChppClientState client; // Loopback client state member
65 context->loopbackClientContext->client.appContext = context; in chppLoopbackClientInit()
66 chppClientInit(&context->loopbackClientContext->client, CHPP_HANDLE_LOOPBACK); in chppLoopbackClientInit()
68 context->loopbackClientContext->client.openState = CHPP_OPEN_STATE_OPENED; in chppLoopbackClientInit()
77 chppClientDeinit(&context->loopbackClientContext->client); in chppLoopbackClientDeinit()
91 &context->loopbackClientContext->client, in chppDispatchLoopbackServiceResponse()
137 chppMutexLock(&context->loopbackClientContext->client.responseMutex); in chppDispatchLoopbackServiceResponse()
138 context->loopbackClientContext->client.responseReady = true; in chppDispatchLoopbackServiceResponse()
140 &context->loopbackClientContext->client.responseCondVar); in chppDispatchLoopbackServiceResponse()
141 chppMutexUnlock(&context->loopbackClientContext->client.responseMutex); in chppDispatchLoopbackServiceResponse()
[all …]
|
| D | timesync.c | 43 struct ChppClientState client; // Timesync client state member
62 context->timesyncClientContext->client.appContext = context; in chppTimesyncClientInit()
65 chppClientInit(&context->timesyncClientContext->client, CHPP_HANDLE_TIMESYNC); in chppTimesyncClientInit()
68 context->timesyncClientContext->client.openState = CHPP_OPEN_STATE_OPENED; in chppTimesyncClientInit()
75 chppClientDeinit(&context->timesyncClientContext->client); in chppTimesyncClientDeinit()
107 &context->timesyncClientContext->client, in chppDispatchTimesyncServiceResponse()
166 &context->timesyncClientContext->client, CHPP_TIMESYNC_COMMAND_GETTIME); in chppTimesyncMeasureOffset()
174 &context->timesyncClientContext->client, in chppTimesyncMeasureOffset()
|
| /system/chre/platform/slpi/see/include/ |
| D | sns_client.h | 41 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/fastboot/ |
| D | socket_test.cpp | 36 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/ |
| D | bluetooth_low_energy_binder_server.cc | 73 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/chre/host/common/test/ |
| D | chre_test_client.cc | 151 void requestHubInfo(SocketClient &client) { in requestHubInfo() argument
156 if (!client.sendMessage(builder.GetBufferPointer(), builder.GetSize())) { in requestHubInfo()
161 void requestNanoappList(SocketClient &client) { in requestNanoappList() argument
166 if (!client.sendMessage(builder.GetBufferPointer(), builder.GetSize())) { in requestNanoappList()
171 void sendMessageToNanoapp(SocketClient &client) { in sendMessageToNanoapp() argument
180 if (!client.sendMessage(builder.GetBufferPointer(), builder.GetSize())) { in sendMessageToNanoapp()
206 void sendNanoappLoad(SocketClient &client, uint64_t appId, uint32_t appVersion, in sendNanoappLoad() argument
221 if (!client.sendMessage(builder.GetBufferPointer(), builder.GetSize())) { in sendNanoappLoad()
226 void sendLoadNanoappRequest(SocketClient &client, const char *headerPath, in sendLoadNanoappRequest() argument
243 sendNanoappLoad(client, appHeader->appId, appHeader->appVersion, in sendLoadNanoappRequest()
[all …]
|
| /system/netd/server/ |
| D | FwmarkServer.cpp | 47 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/libfmq/tests/ |
| D | fmq_test.py | 32 def make_test(client, server): argument
35 run_cmd("adb shell killall %s >/dev/null 2>&1" % client, ignore_error=True)
38 run_cmd("adb shell %s" % client)
40 run_cmd("adb shell killall %s >/dev/null 2>&1" % client, ignore_error=True)
67 for client in clients:
69 test_name = 'test_%s_to_%s' % (short_name(client), short_name(server))
70 test = make_test(client, server)
|
| /system/tools/hidl/test/hidl_test/ |
| D | hidl_test.py | 32 def make_test(client, server): argument
35 run_cmd("adb shell killall %s >/dev/null 2>&1" % client, ignore_error=True)
38 run_cmd("adb shell %s" % client)
40 run_cmd("adb shell killall %s >/dev/null 2>&1" % client, ignore_error=True)
67 for client in clients:
69 test_name = 'test_%s_to_%s' % (short_name(client), short_name(server))
70 test = make_test(client, server)
|
| /system/tools/hidl/test/java_test/ |
| D | hidl_test_java.py | 38 def make_test(client, server): argument
43 cleanup(client)
47 run_cmd("adb shell %s %s -c" % (env, client))
49 cleanup(client)
74 for client in cmds:
76 test_name = 'test_%s_to_%s' % (short_name(client), short_name(server))
77 test = make_test(client, server)
|
| /system/bt/service/test/ |
| D | low_energy_client_unittest.cc | 62 void OnConnectionState(LowEnergyClient* client, int status, in OnConnectionState() argument
64 ASSERT_TRUE(client); in OnConnectionState()
68 void OnMtuChanged(LowEnergyClient* client, int status, const char* address, in OnMtuChanged() argument
70 ASSERT_TRUE(client); in OnMtuChanged()
122 auto callback = [&](std::unique_ptr<LowEnergyClient> client) { in SetUp() argument
123 le_client_ = std::move(client); in SetUp()
137 const std::function<void(std::unique_ptr<LowEnergyClient> client)> in RegisterTestClient()
180 std::unique_ptr<LowEnergyClient> client; in TEST_F() local
187 client = std::unique_ptr<LowEnergyClient>( in TEST_F()
226 ASSERT_TRUE(client.get() != nullptr); // Assert to terminate in case of error in TEST_F()
[all …]
|
| D | gatt_client_unittest.cc | 90 std::unique_ptr<GattClient> client; in TEST_F() local
97 client = std::unique_ptr<GattClient>( in TEST_F()
136 ASSERT_TRUE(client.get() != nullptr); // Assert to terminate in case of error in TEST_F()
138 EXPECT_EQ(client_id0, client->GetInstanceId()); in TEST_F()
139 EXPECT_EQ(uuid0, client->GetAppIdentifier()); in TEST_F()
146 client.reset(); in TEST_F()
155 ASSERT_TRUE(client.get() == nullptr); // Assert to terminate in case of error in TEST_F()
|
| /system/sepolicy/public/ |
| D | hal_neuralnetworks.te | 1 # 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 service to read a client-provided fd residing in /data/app/.
27 # Allow NN HAL client to check the ro.nnapi.extensions.deny_on_product
|
| /system/sepolicy/prebuilts/api/31.0/public/ |
| D | hal_neuralnetworks.te | 1 # 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 service to read a client-provided fd residing in /data/app/.
27 # Allow NN HAL client to check the ro.nnapi.extensions.deny_on_product
|
| /system/sepolicy/prebuilts/api/30.0/public/ |
| D | hal_neuralnetworks.te | 1 # 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/ |
| D | audio_stress_test.cc | 80 void sendLoadNanoappRequest(SocketClient &client, const char *filename, in sendLoadNanoappRequest() argument
111 if (!client.sendMessage(builder.GetBufferPointer(), builder.GetSize())) { in sendLoadNanoappRequest()
119 SocketClient client; in main() local
122 if (!client.connect("chre", callbacks)) { in main()
125 sendLoadNanoappRequest(client, "/data/audio_stress_test.so", in main()
|
| /system/bt/service/common/ |
| D | README | 2 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/chre/host/common/test/power_test/ |
| D | chre_power_test_client.cc | 334 bool requestNanoappList(SocketClient &client) { in requestNanoappList() argument
339 if (!client.sendMessage(builder.GetBufferPointer(), builder.GetSize())) { in requestNanoappList()
346 bool sendLoadNanoappRequest(SocketClient &client, const char *filename, in sendLoadNanoappRequest() argument
381 client.sendMessage(builder.GetBufferPointer(), builder.GetSize()); in sendLoadNanoappRequest()
389 bool loadNanoapp(SocketClient &client, sp<SocketCallbacks> callbacks, in loadNanoapp() argument
392 if (!sendLoadNanoappRequest(client, filename, appId, appVersion, apiVersion, in loadNanoapp()
404 bool sendUnloadNanoappRequest(SocketClient &client, uint64_t appId) { in sendUnloadNanoappRequest() argument
412 if (!client.sendMessage(builder.GetBufferPointer(), builder.GetSize())) { in sendUnloadNanoappRequest()
419 bool unloadNanoapp(SocketClient &client, sp<SocketCallbacks> callbacks, in unloadNanoapp() argument
421 if (!sendUnloadNanoappRequest(client, appId)) { in unloadNanoapp()
[all …]
|
| /system/logging/logd/ |
| D | LogReader.cpp | 40 static bool CanReadSecurityLogs(SocketClient* client) { in CanReadSecurityLogs() argument
41 return client->getUid() == AID_SYSTEM || client->getGid() == AID_SYSTEM; in CanReadSecurityLogs()
44 static std::string SocketClientToName(SocketClient* client) { in SocketClientToName() argument
45 return android::base::StringPrintf("pid %d, fd %d", client->getPid(), client->getSocket()); in SocketClientToName()
50 SocketLogWriter(LogReader* reader, SocketClient* client, bool privileged) in SocketLogWriter() argument
51 : LogWriter(client->getUid(), privileged), reader_(reader), client_(client) {} in SocketLogWriter()
|