/system/bt/stack/l2cap/ |
H A D | l2cap_client.c | 55 static void fragment_packet(l2cap_client_t *client, buffer_t *packet); 56 static void dispatch_fragments(l2cap_client_t *client); 95 LOG_ERROR(LOG_TAG, "%s unable to allocate space for L2CAP client list.", __func__); 121 void l2cap_client_free(l2cap_client_t *client) { argument 122 if (!client) 125 list_remove(l2cap_clients, client); 126 l2cap_client_disconnect(client); 127 list_free(client->outbound_fragments); 128 osi_free(client); 131 bool l2cap_client_connect(l2cap_client_t *client, cons argument 151 l2cap_client_disconnect(l2cap_client_t *client) argument 169 l2cap_client_is_connected(const l2cap_client_t *client) argument 175 l2cap_client_write(l2cap_client_t *client, buffer_t *packet) argument 191 l2cap_client_t *client = find(local_channel_id); local 214 l2cap_client_t *client = find(local_channel_id); local 258 l2cap_client_t *client = find(local_channel_id); local 292 l2cap_client_t *client = find(local_channel_id); local 311 l2cap_client_t *client = find(local_channel_id); local 326 l2cap_client_t *client = find(local_channel_id); local 347 l2cap_client_t *client = find(local_channel_id); local 368 fragment_packet(l2cap_client_t *client, buffer_t *packet) argument 399 dispatch_fragments(l2cap_client_t *client) argument 427 l2cap_client_t *client = (l2cap_client_t *)list_node(node); local [all...] |
/system/bt/stack/include/ |
H A D | l2cap_client.h | 29 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); 41 // Creates and returns a new L2CAP client object. |callbacks| must not be NULL and 48 // Frees the L2CAP client object allocated with |l2cap_client_new|. |client| may be NULL. 49 void l2cap_client_free(l2cap_client_t *client); 51 // Attempts to connect the |client| to a peer device specified by |remote_bdaddr| 57 // while |l2cap_client_is_connected|. |client| an [all...] |
/system/core/logd/ |
H A D | FlushCommand.cpp | 45 // runSocketCommand is called once for every open client on the 47 // client tracking and log region locks LastLogTimes list of 48 // LogTimeEntrys, and spawn a transitory per-client thread to 54 void FlushCommand::runSocketCommand(SocketClient *client) { argument 62 if (entry->mClient == client) { 84 entry = new LogTimeEntry(mReader, client, mNonBlock, mTail, mLogMask, 89 client->incRef(); 91 // release client and entry reference counts once done 96 bool FlushCommand::hasReadLogs(SocketClient *client) { argument 97 return clientHasLogCredentials(client); 100 clientHasSecurityCredentials(SocketClient *client) argument 104 hasSecurityLogs(SocketClient *client) argument [all...] |
H A D | FlushCommand.h | 45 virtual void runSocketCommand(SocketClient *client); 47 static bool hasReadLogs(SocketClient *client); 48 static bool hasSecurityLogs(SocketClient *client);
|
H A D | LogTimes.cpp | 27 LogTimeEntry::LogTimeEntry(LogReader &reader, SocketClient *client, argument 42 mClient(client), 83 SocketClient *client = me->mClient; local 100 reader.release(client); 103 if (client) { 104 client->decRef(); 120 SocketClient *client = me->mClient; local 121 if (!client) { 128 bool privileged = FlushCommand::hasReadLogs(client); 129 bool security = FlushCommand::hasSecurityLogs(client); [all...] |
/system/core/include/sysutils/ |
H A D | SocketClientCommand.h | 24 virtual void runSocketCommand(SocketClient *client) = 0;
|
/system/bt/hci/src/ |
H A D | hci_inject.c | 135 client_t *client = (client_t *)osi_calloc(sizeof(client_t)); 137 client->socket = socket; 139 if (!list_append(clients, client)) { 140 LOG_ERROR(LOG_TAG, "%s unable to add client to list.", __func__); 141 client_free(client); 145 socket_register(socket, thread_get_reactor(thread), client, read_ready, NULL); 152 client_t *client = (client_t *)context; local 154 ssize_t ret = socket_read(client->socket, client->buffer + client [all...] |
/system/netd/server/ |
H A D | FwmarkServer.h | 30 bool onDataAvailable(SocketClient* client); 33 int processClient(SocketClient* client, int* socketFd);
|
H A D | FwmarkServer.cpp | 31 bool FwmarkServer::onDataAvailable(SocketClient* client) { argument 33 int error = processClient(client, &socketFd); 39 // inadvertently cause the client to hang (which always waits for a response). 40 client->sendData(&error, sizeof(error)); 42 // Always close the client connection (by returning false). This prevents a DoS attack where 43 // the client issues multiple commands on the same connection, never reading the responses, 44 // causing its receive buffer to fill up, and thus causing our client->sendData() to block. 48 int FwmarkServer::processClient(SocketClient* client, int* socketFd) { argument 69 int messageLength = TEMP_FAILURE_RETRY(recvmsg(client->getSocket(), &message, 0)); 78 Permission permission = mNetworkController->getPermissionForUser(client [all...] |
/system/tpm/trunks/aidl/android/trunks/ |
H A D | ITrunks.aidl | 22 oneway void SendCommand(in byte[] command, in ITrunksClient client);
|
/system/bt/service/ipc/binder/ |
H A D | bluetooth_low_energy_binder_server.cpp | 65 auto client = GetLEClient(client_id); local 66 if (!client) { 71 return client->Connect(std::string(address), is_direct); 80 auto client = GetLEClient(client_id); local 81 if (!client) { 86 return client->Disconnect(std::string(address)); 97 auto client = GetLEClient(client_id); local 98 if (!client) { 103 return client->SetMtu(address, mtu); 113 auto client local 126 auto client = GetLEClient(client_id); local 143 auto client = GetLEClient(client_id); local 184 auto client = GetLEClient(client_id); local 220 OnConnectionState( bluetooth::LowEnergyClient* client, int status, const char* address, bool connected) argument 235 OnMtuChanged( bluetooth::LowEnergyClient* client, int status, const char* address, int mtu) argument 251 OnScanResult( bluetooth::LowEnergyClient* client, const bluetooth::ScanResult& result) argument [all...] |
/system/core/libcutils/tests/ |
H A D | sockets_test.cpp | 32 static void TestConnectedSockets(cutils_socket_t server, cutils_socket_t client, argument 35 ASSERT_NE(INVALID_SOCKET, client); 41 // Send client -> server first to get the UDP client's address. 42 ASSERT_EQ(3, send(client, "foo", 3, 0)); 51 // Now send server -> client. 58 EXPECT_EQ(3, recv(client, buffer, sizeof(buffer), 0)); 66 EXPECT_EQ(11, socket_send_buffers(client, socket_buffers, 3)); 71 EXPECT_EQ(0, socket_close(client)); 117 cutils_socket_t client local 128 cutils_socket_t client = socket_network_client( local 139 cutils_socket_t client = socket_network_client( local 150 cutils_socket_t client = socket_network_client( local 173 cutils_socket_t client = socket_network_client( local [all...] |
/system/tools/aidl/tests/ |
H A D | aidl_test_client_nullables.h | 28 namespace client { namespace in namespace:android::aidl::tests 32 } // namespace client
|
H A D | aidl_test_client_service_exceptions.h | 27 namespace client { namespace in namespace:android::aidl::tests 32 } // namespace client
|
H A D | aidl_test_client_file_descriptors.h | 28 namespace client { namespace in namespace:android::aidl::tests 33 } // namespace client
|
H A D | aidl_test_client_parcelables.h | 28 namespace client { namespace in namespace:android::aidl::tests 33 } // namespace client
|
H A D | aidl_test_client_primitives.h | 28 namespace client { namespace in namespace:android::aidl::tests 35 } // namespace client
|
H A D | aidl_test_client_service_exceptions.cpp | 30 namespace client { namespace in namespace:android::aidl::tests 46 } // namespace client
|
H A D | aidl_test_client_utf8_strings.h | 28 namespace client { namespace in namespace:android::aidl::tests 37 } // namespace client
|
/system/nativepower/example/ |
H A D | power_example.cc | 43 brillo::FlagHelper::Init(argc, argv, "Example power-management client."); 49 android::PowerManagerClient client; local 50 CHECK(client.Init()); 54 CHECK(client.Reboot(android::RebootReason::DEFAULT)); 57 CHECK(client.ShutDown(android::ShutdownReason::DEFAULT)); 60 CHECK(client.Suspend(base::SysInfo::Uptime(), 65 client.CreateWakeLock("power_example", "power"));
|
/system/core/fastboot/ |
H A D | socket_test.cpp | 34 // Creates connected sockets |server| and |client|. Returns true on success. 36 std::unique_ptr<Socket>* client, 44 *client = Socket::NewClient(protocol, hostname, (*server)->GetLocalPort(), nullptr); 45 if (*client == nullptr) { 46 ADD_FAILURE() << "Failed to create client."; 50 // TCP passes the client off to a new socket. 54 ADD_FAILURE() << "Failed to accept client connection."; 76 // Tests sending packets client -> server, then server -> client. 78 std::unique_ptr<Socket> server, client; local 35 MakeConnectedSockets(Socket::Protocol protocol, std::unique_ptr<Socket>* server, std::unique_ptr<Socket>* client, const std::string hostname = �) argument 92 std::unique_ptr<Socket> server, client; local 113 std::unique_ptr<Socket> server, client; local 138 std::unique_ptr<Socket> server, client; local 158 std::unique_ptr<Socket> server, client; local [all...] |
/system/connectivity/shill/ |
H A D | arp_client_test_helper.cc | 27 ArpClientTestHelper::ArpClientTestHelper(MockArpClient* client) argument 28 : client_(client) {}
|
H A D | arp_client_test_helper.h | 29 // Class for simulate ARP client receiving ARP packets for unit test purpose. 32 explicit ArpClientTestHelper(MockArpClient* client);
|
/system/weaved/buffet/ |
H A D | avahi_mdns_client.h | 23 #include <avahi-client/client.h> 24 #include <avahi-client/publish.h>
|
/system/bt/service/test/ |
H A D | gatt_client_unittest.cpp | 103 std::unique_ptr<GattClient> client; local 110 client = std::unique_ptr<GattClient>( 151 ASSERT_TRUE(client.get() != nullptr); // Assert to terminate in case of error 153 EXPECT_EQ(client_id0, client->GetInstanceId()); 154 EXPECT_EQ(uuid0, client->GetAppIdentifier()); 157 // The client should unregister itself when deleted. 161 client.reset(); 171 ASSERT_TRUE(client.get() == nullptr); // Assert to terminate in case of error
|