| /system/netd/resolv/ |
| D | DnsProxyListener.h | 43 int runCommand(SocketClient* c, int argc, char** argv) override;
50 GetAddrInfoHandler(SocketClient* c, char* host, char* service, addrinfo* hints,
59 SocketClient* mClient; // ref counted
71 int runCommand(SocketClient* c, int argc, char** argv) override;
76 GetHostByNameHandler(SocketClient* c, char* name, int af,
85 SocketClient* mClient; // ref counted
96 int runCommand(SocketClient* c, int argc, char** argv) override;
101 GetHostByAddrHandler(SocketClient* c, void* address, int addressLen, int addressFamily,
110 SocketClient* mClient; // ref counted
122 int runCommand(SocketClient* c, int argc, char** argv) override;
[all …]
|
| D | DnsProxyListener.cpp | 90 void tryThreadOrError(SocketClient* cli, T* handler) { in tryThreadOrError()
507 DnsProxyListener::GetAddrInfoHandler::GetAddrInfoHandler(SocketClient* c, char* host, char* service, in GetAddrInfoHandler()
518 static bool sendBE32(SocketClient* c, uint32_t data) { in sendBE32()
525 static bool sendLenAndData(SocketClient* c, const int len, const void* data) { in sendLenAndData()
530 static bool sendhostent(SocketClient* c, hostent* hp) { in sendhostent()
557 static bool sendaddrinfo(SocketClient* c, addrinfo* ai) { in sendaddrinfo()
708 int DnsProxyListener::GetAddrInfoCmd::runCommand(SocketClient *cli, in runCommand()
771 int DnsProxyListener::ResNSendCommand::runCommand(SocketClient* cli, int argc, char** argv) { in runCommand()
813 DnsProxyListener::ResNSendHandler::ResNSendHandler(SocketClient* c, std::string msg, uint32_t flags, in ResNSendHandler()
905 bool sendCodeAndBe32(SocketClient* c, int code, int data) { in sendCodeAndBe32()
[all …]
|
| /system/core/libsysutils/src/ |
| D | SocketClient.cpp | 35 SocketClient::SocketClient(int socket, bool owned) { in SocketClient() function in SocketClient
39 SocketClient::SocketClient(int socket, bool owned, bool useCmdNum) { in SocketClient() function in SocketClient
43 void SocketClient::init(int socket, bool owned, bool useCmdNum) { in init()
67 SocketClient::~SocketClient() { in ~SocketClient()
73 int SocketClient::sendMsg(int code, const char *msg, bool addErrno) { in sendMsg()
77 int SocketClient::sendMsg(int code, const char *msg, bool addErrno, bool useCmdNum) { in sendMsg()
103 int SocketClient::sendBinaryMsg(int code, const void *data, int len) { in sendBinaryMsg()
127 int SocketClient::sendCode(int code) { in sendCode()
133 char *SocketClient::quoteArg(const char *arg) { in quoteArg()
164 int SocketClient::sendMsg(const char *msg) { in sendMsg()
[all …]
|
| D | SocketListener.cpp | 96 mClients[mSock] = new SocketClient(mSock, false, mUseCmdNum); in startListener()
191 mClients[c] = new SocketClient(c, true, mUseCmdNum); in runListener()
197 std::vector<SocketClient*> pending; in runListener()
208 SocketClient* c = it->second; in runListener()
215 for (SocketClient* c : pending) { in runListener()
226 bool SocketListener::release(SocketClient* c, bool wakeup) { in release()
246 std::vector<SocketClient*> SocketListener::snapshotClients() { in snapshotClients()
247 std::vector<SocketClient*> clients; in snapshotClients()
251 SocketClient* c = pair.second; in snapshotClients()
261 for (SocketClient* c : snapshotClients()) { in sendBroadcast()
[all …]
|
| D | FrameworkCommand.cpp | 30 int FrameworkCommand::runCommand(SocketClient *c UNUSED, int argc UNUSED, in runCommand()
|
| /system/chre/host/common/ |
| D | socket_client.cc | 36 SocketClient::SocketClient() { in SocketClient() function in android::chre::SocketClient
40 SocketClient::~SocketClient() { in ~SocketClient()
44 bool SocketClient::connect(const char *socketName, in connect()
49 bool SocketClient::connectInBackground(const char *socketName, in connectInBackground()
54 void SocketClient::disconnect() { in disconnect()
79 bool SocketClient::isConnected() const { in isConnected()
83 bool SocketClient::sendMessage(const void *data, size_t length) { in sendMessage()
105 bool SocketClient::doConnect(const char *socketName, in doConnect()
137 bool SocketClient::inReceiveThread() const { in inReceiveThread()
141 void SocketClient::receiveThread() { in receiveThread()
[all …]
|
| /system/core/libsysutils/include/sysutils/ |
| D | SocketListener.h | 30 std::unordered_map<int, SocketClient*> mClients;
50 bool release(SocketClient *c) { return release(c, true); } in release()
53 virtual bool onDataAvailable(SocketClient *c) = 0;
60 std::vector<SocketClient*> snapshotClients();
62 bool release(SocketClient *c, bool wakeup);
|
| D | SocketClient.h | 9 class SocketClient {
32 SocketClient(int sock, bool owned);
33 SocketClient(int sock, bool owned, bool useCmdNum);
34 virtual ~SocketClient();
|
| D | FrameworkListener.h | 24 class SocketClient; variable
47 bool onDataAvailable(SocketClient* c) override;
50 void dispatchCommand(SocketClient *c, char *data);
|
| D | FrameworkCommand.h | 19 class SocketClient; variable
30 virtual int runCommand(SocketClient *c, int argc, char **argv) = 0;
|
| D | SocketClientCommand.h | 24 virtual void runSocketCommand(SocketClient *client) = 0;
|
| D | NetlinkListener.h | 45 virtual bool onDataAvailable(SocketClient *cli);
|
| /system/core/logd/ |
| D | CommandListener.h | 46 int runCommand(SocketClient* c, int argc, char** argv);
57 int runCommand(SocketClient* c, int argc, char** argv); \
75 int runCommand(SocketClient* c, int argc, char** argv); \
89 int runCommand(SocketClient* c, int argc, char** argv); \
90 void release(SocketClient* c) { \
|
| D | FlushCommand.cpp | 38 void FlushCommand::runSocketCommand(SocketClient* client) { in runSocketCommand()
75 bool FlushCommand::hasReadLogs(SocketClient* client) { in hasReadLogs()
79 static bool clientHasSecurityCredentials(SocketClient* client) { in clientHasSecurityCredentials()
83 bool FlushCommand::hasSecurityLogs(SocketClient* client) { in hasSecurityLogs()
|
| D | FlushCommand.h | 37 virtual void runSocketCommand(SocketClient* client);
39 static bool hasReadLogs(SocketClient* client);
40 static bool hasSecurityLogs(SocketClient* client);
|
| D | CommandListener.cpp | 60 int CommandListener::ShutdownCmd::runCommand(SocketClient* /*cli*/, in runCommand() argument
79 int CommandListener::ClearCmd::runCommand(SocketClient* cli, int argc, in runCommand()
106 int CommandListener::GetBufSizeCmd::runCommand(SocketClient* cli, int argc, in runCommand()
131 int CommandListener::SetBufSizeCmd::runCommand(SocketClient* cli, int argc, in runCommand()
164 int CommandListener::GetBufSizeUsedCmd::runCommand(SocketClient* cli, int argc, in runCommand()
199 int CommandListener::GetStatisticsCmd::runCommand(SocketClient* cli, int argc, in runCommand()
240 int CommandListener::GetPruneListCmd::runCommand(SocketClient* cli, in runCommand()
251 int CommandListener::SetPruneListCmd::runCommand(SocketClient* cli, int argc, in runCommand()
283 int CommandListener::GetEventTagCmd::runCommand(SocketClient* cli, int argc, in runCommand()
332 int CommandListener::ReinitCmd::runCommand(SocketClient* cli, int /*argc*/, in runCommand()
[all …]
|
| D | LogReader.h | 40 virtual bool onDataAvailable(SocketClient* cli);
45 void doSocketDelete(SocketClient* cli);
|
| D | LogTimes.h | 53 LogTimeEntry(LogReader& reader, SocketClient* client, bool nonBlock,
57 SocketClient* mClient;
|
| D | LogListener.h | 41 virtual bool onDataAvailable(SocketClient* cli);
|
| /system/netd/server/ |
| D | MDnsSdListener.h | 109 int runCommand(SocketClient *c, int argc, char** argv);
113 void stop(SocketClient *cli, int argc, char **argv, const char *str);
115 void discover(SocketClient *cli, const char *iface, const char *regType,
119 void serviceRegister(SocketClient *cli, int requestId, const char *interfaceName,
123 void resolveService(SocketClient *cli, int requestId,
127 void setHostname(SocketClient *cli, int requestId, const char *hostname);
129 void getAddrInfo(SocketClient *cli, int requestId, const char *interfaceName,
|
| D | FwmarkServer.h | 38 bool onDataAvailable(SocketClient* client);
41 int processClient(SocketClient* client, int* socketFd);
|
| D | MDnsSdListener.cpp | 66 void MDnsSdListener::Handler::discover(SocketClient *cli, in discover()
116 char *quotedServiceName = SocketClient::quoteArg(serviceName); in MDnsSdListenerDiscoverCallback()
137 void MDnsSdListener::Handler::stop(SocketClient *cli, int argc, char **argv, const char *str) { in stop()
161 void MDnsSdListener::Handler::serviceRegister(SocketClient *cli, int requestId, in serviceRegister()
207 char *quotedServiceName = SocketClient::quoteArg(serviceName); in MDnsSdListenerRegisterCallback()
217 void MDnsSdListener::Handler::resolveService(SocketClient *cli, int requestId, in resolveService()
263 char *quotedFullName = SocketClient::quoteArg(fullname); in MDnsSdListenerResolveCallback()
264 char *quotedHostTarget = SocketClient::quoteArg(hosttarget); in MDnsSdListenerResolveCallback()
287 void MDnsSdListener::Handler::getAddrInfo(SocketClient *cli, int requestId, in getAddrInfo()
331 char *quotedHostname = SocketClient::quoteArg(hostname); in MDnsSdListenerGetAddrInfoCallback()
[all …]
|
| /system/chre/host/common/audio_stress_test/ |
| D | audio_stress_test.cc | 42 using android::chre::SocketClient;
51 class SocketCallbacks : public SocketClient::ICallbacks,
79 void sendLoadNanoappRequest(SocketClient& client, const char *filename, in sendLoadNanoappRequest()
114 SocketClient client; in main()
|
| /system/chre/host/common/include/chre_host/ |
| D | socket_client.h | 32 class SocketClient {
34 SocketClient();
35 ~SocketClient();
|
| /system/chre/host/common/test/ |
| D | chre_test_client.cc | 49 using android::chre::SocketClient;
67 class SocketCallbacks : public SocketClient::ICallbacks,
134 void requestHubInfo(SocketClient& client) { in requestHubInfo()
144 void requestNanoappList(SocketClient& client) { in requestNanoappList()
154 void sendMessageToNanoapp(SocketClient& client) { in sendMessageToNanoapp()
168 void sendLoadNanoappRequest(SocketClient& client, const char *filename, in sendLoadNanoappRequest()
200 void sendUnloadNanoappRequest(SocketClient& client, uint64_t appId) { in sendUnloadNanoappRequest()
235 SocketClient client; in main()
|