Home
last modified time | relevance | path

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

12345678910>>...14

/system/bt/stack/l2cap/
Dl2cap_client.cc59 static void fragment_packet(l2cap_client_t* client, buffer_t* packet);
60 static void dispatch_fragments(l2cap_client_t* client);
119 void l2cap_client_free(l2cap_client_t* client) { in l2cap_client_free() argument
120 if (!client) return; in l2cap_client_free()
122 list_remove(l2cap_clients, client); in l2cap_client_free()
123 l2cap_client_disconnect(client); in l2cap_client_free()
124 list_free(client->outbound_fragments); in l2cap_client_free()
125 osi_free(client); in l2cap_client_free()
128 bool l2cap_client_connect(l2cap_client_t* client, in l2cap_client_connect() argument
130 CHECK(client != NULL); in l2cap_client_connect()
[all …]
/system/bt/hci/src/
Dhci_inject.cc134 client_t* client = (client_t*)osi_calloc(sizeof(client_t)); in accept_ready() local
136 client->socket = socket; in accept_ready()
138 if (!list_append(clients, client)) { in accept_ready()
140 client_free(client); in accept_ready()
144 socket_register(socket, thread_get_reactor(thread), client, read_ready, NULL); in accept_ready()
151 client_t* client = (client_t*)context; in read_ready() local
154 socket_read(client->socket, client->buffer + client->buffer_size, in read_ready()
155 sizeof(client->buffer) - client->buffer_size); in read_ready()
157 list_remove(clients, client); in read_ready()
160 client->buffer_size += ret; in read_ready()
[all …]
/system/bt/stack/include/
Dl2cap_client.h29 void (*connected)(l2cap_client_t* client, void* context);
30 void (*disconnected)(l2cap_client_t* client, void* context);
31 void (*read_ready)(l2cap_client_t* client, buffer_t* packet, void* context);
32 void (*write_ready)(l2cap_client_t* client, void* context);
51 void l2cap_client_free(l2cap_client_t* client);
62 bool l2cap_client_connect(l2cap_client_t* client,
68 void l2cap_client_disconnect(l2cap_client_t* client);
72 bool l2cap_client_is_connected(const l2cap_client_t* client);
79 bool l2cap_client_write(l2cap_client_t* client, buffer_t* packet);
/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/tools/aidl/tests/
Dtest_data_example_interface.cpp1380 …droid.os.Trace.traceBegin(android.os.Trace.TRACE_TAG_AIDL, "IExampleInterface::isEnabled::client");
1402 …ndroid.os.Trace.traceBegin(android.os.Trace.TRACE_TAG_AIDL, "IExampleInterface::getState::client");
1424 …roid.os.Trace.traceBegin(android.os.Trace.TRACE_TAG_AIDL, "IExampleInterface::getAddress::client");
1447 ….os.Trace.traceBegin(android.os.Trace.TRACE_TAG_AIDL, "IExampleInterface::getParcelables::client");
1471 …oid.os.Trace.traceBegin(android.os.Trace.TRACE_TAG_AIDL, "IExampleInterface::setScanMode::client");
1496 ….os.Trace.traceBegin(android.os.Trace.TRACE_TAG_AIDL, "IExampleInterface::registerBinder::client");
1518 …Trace.traceBegin(android.os.Trace.TRACE_TAG_AIDL, "IExampleInterface::getRecursiveBinder::client");
1540 …s.Trace.traceBegin(android.os.Trace.TRACE_TAG_AIDL, "IExampleInterface::takesAnInterface::client");
1563 …s.Trace.traceBegin(android.os.Trace.TRACE_TAG_AIDL, "IExampleInterface::takesAParcelable::client");
/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()
119 cutils_socket_t client = socket_network_client( in TEST() local
122 TestConnectedSockets(server, client, SOCK_DGRAM); in TEST()
130 cutils_socket_t client = socket_network_client( in TEST() local
135 TestConnectedSockets(handler, client, SOCK_STREAM); in TEST()
[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/netd/server/
DFwmarkServer.cpp42 bool isSystemServer(SocketClient* client) { in isSystemServer() argument
43 if (client->getUid() != AID_SYSTEM) { in isSystemServer()
48 if (getpeercon(client->getSocket(), &context)) { in isSystemServer()
67 bool FwmarkServer::onDataAvailable(SocketClient* client) { in onDataAvailable() argument
69 int error = processClient(client, &socketFd); in onDataAvailable()
76 client->sendData(&error, sizeof(error)); in onDataAvailable()
84 int FwmarkServer::processClient(SocketClient* client, int* socketFd) { in processClient() argument
106 … int messageLength = TEMP_FAILURE_RETRY(recvmsg(client->getSocket(), &message, MSG_CMSG_CLOEXEC)); in processClient()
117 Permission permission = mNetworkController->getPermissionForUser(client->getUid()); in processClient()
127 return mTrafficCtrl->setCounterSet(command.trafficCtrlInfo, command.uid, client->getUid()); in processClient()
[all …]
/system/chre/host/common/test/
Dchre_test_client.cc134 void requestHubInfo(SocketClient& client) { in requestHubInfo() argument
139 if (!client.sendMessage(builder.GetBufferPointer(), builder.GetSize())) { in requestHubInfo()
144 void requestNanoappList(SocketClient& client) { in requestNanoappList() argument
149 if (!client.sendMessage(builder.GetBufferPointer(), builder.GetSize())) { in requestNanoappList()
154 void sendMessageToNanoapp(SocketClient& client) { in sendMessageToNanoapp() argument
163 if (!client.sendMessage(builder.GetBufferPointer(), builder.GetSize())) { in sendMessageToNanoapp()
168 void sendLoadNanoappRequest(SocketClient& client, const char *filename, in sendLoadNanoappRequest() argument
195 if (!client.sendMessage(builder.GetBufferPointer(), builder.GetSize())) { in sendLoadNanoappRequest()
200 void sendUnloadNanoappRequest(SocketClient& client, uint64_t appId) { in sendUnloadNanoappRequest() argument
208 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.bp157 "client/auth.cpp",
158 "client/usb_libusb.cpp",
159 "client/usb_dispatch.cpp",
160 "client/transport_mdns.cpp",
167 srcs: ["client/usb_linux.cpp"],
170 srcs: ["client/usb_osx.cpp"],
179 "client/usb_windows.cpp",
259 "client/adb_client.cpp",
260 "client/bugreport.cpp",
261 "client/commandline.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/audio_stress_test/
Daudio_stress_test.cc79 void sendLoadNanoappRequest(SocketClient& client, const char *filename, in sendLoadNanoappRequest() argument
106 if (!client.sendMessage(builder.GetBufferPointer(), builder.GetSize())) { in sendLoadNanoappRequest()
114 SocketClient client; in main() local
117 if (!client.connect("chre", callbacks)) { in main()
120 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/extras/simpleperf/
DUnixSocket_test.cpp80 std::unique_ptr<UnixSocketConnection> client = in ClientToTestUndelayedMessage() local
82 ASSERT_TRUE(client != nullptr); in ClientToTestUndelayedMessage()
93 return client->SendMessage(reply_msg, true); in ClientToTestUndelayedMessage()
96 ASSERT_TRUE(client->PrepareForIO(loop, receive_message_callback, in ClientToTestUndelayedMessage()
143 std::unique_ptr<UnixSocketConnection> client = in ClientToTestBufferedMessage() local
145 ASSERT_TRUE(client != nullptr); in ClientToTestBufferedMessage()
152 return client->NoMoreMessage(); in ClientToTestBufferedMessage()
155 ASSERT_TRUE(client->PrepareForIO(loop, receive_message_callback, in ClientToTestBufferedMessage()
163 if (!client->SendMessage(msg, false)) { in ClientToTestBufferedMessage()
/system/sepolicy/prebuilts/api/29.0/public/
Dhal_neuralnetworks.te1 # HwBinder IPC from client to server, and callbacks
9 # Allow NN HAL service to use a client-provided fd residing in /data/data/.
13 # Allow NN HAL service to use a client-provided fd residing in /data/local/tmp/.
16 # Allow NN HAL client to check the ro.nnapi.extensions.deny_on_product
/system/sepolicy/public/
Dhal_neuralnetworks.te1 # HwBinder IPC from client to server, and callbacks
9 # Allow NN HAL service to use a client-provided fd residing in /data/data/.
13 # Allow NN HAL service to use a client-provided fd residing in /data/local/tmp/.
16 # Allow NN HAL client to check the ro.nnapi.extensions.deny_on_product
/system/update_engine/
Dlibupdate_engine-client.pc.in3 Name: libupdate_engine-client
5 Description: update_engine client interface library
Dlibupdate_engine-client-test.pc.in3 Name: libupdate_engine-client-test
5 Description: update_engine client interface mock library
/system/chre/platform/slpi/include/chre/platform/slpi/see/
Dsee_helper.h132 sns_client *client; member
417 bool sendSeeReqSync(sns_client *client, sns_client_request_msg *req,
446 sns_client *client, const sns_std_suid& suid,
475 sns_client *client, const void *payload, size_t payloadLen);
488 static void seeIndCb(sns_client *client, void *msg, uint32_t msgLen,
496 static void seeRespCb(sns_client *client, sns_std_error error, void *cbData);
503 bool waitForService(sns_client **client,

12345678910>>...14