/system/connectivity/shill/net/ |
H A D | rtnl_listener.cc | 42 void RTNLListener::NotifyEvent(int type, const RTNLMessage& msg) { argument 44 callback_.Run(msg);
|
H A D | rtnl_handler.cc | 160 RTNLMessage msg( 169 msg.set_link_status(RTNLMessage::LinkStatus(ARPHRD_VOID, flags, change)); 176 SendMessageWithErrorMask(&msg, error_mask); 180 RTNLMessage msg( 189 msg.SetAttribute( 193 CHECK(SendMessage(&msg)); 215 void RTNLHandler::DispatchEvent(int type, const RTNLMessage& msg) { argument 217 listener->NotifyEvent(type, msg); 257 RTNLMessage msg( 265 CHECK(SendMessage(&msg)); 283 RTNLMessage msg; local [all...] |
H A D | rtnl_message_unittest.cc | 397 RTNLMessage msg; local 398 EXPECT_TRUE(msg.Decode(packet)); 400 EXPECT_EQ(RTNLMessage::kTypeLink, msg.type()); 401 EXPECT_EQ(mode, msg.mode()); 402 EXPECT_EQ(interface_index, msg.interface_index()); 404 RTNLMessage::LinkStatus status = msg.link_status(); 408 EXPECT_TRUE(msg.HasAttribute(IFLA_ADDRESS)); 409 EXPECT_EQ(address.GetLength(), msg.GetAttribute(IFLA_ADDRESS).GetLength()); 410 EXPECT_TRUE(msg.GetAttribute(IFLA_ADDRESS).Equals(address)); 412 EXPECT_TRUE(msg 434 RTNLMessage msg; local 465 RTNLMessage msg; local 522 RTNLMessage msg; local 555 RTNLMessage msg; local 683 RTNLMessage msg; local 761 RTNLMessage msg; local [all...] |
/system/core/libcutils/ |
H A D | debugger.c | 46 debugger_msg_t msg; local 47 memset(&msg, 0, sizeof(msg)); 48 msg.tid = tid; 49 msg.action = action; 70 if (send_request(sock_fd, &msg, sizeof(msg)) < 0) {
|
/system/bt/bta/av/ |
H A D | bta_av_api.c | 427 p_buf->msg.op_id = rc_id; 428 p_buf->msg.state = key_state; 429 p_buf->msg.p_pass_data = NULL; 430 p_buf->msg.pass_len = 0; 458 p_buf->msg.op_id = AVRC_ID_VENDOR; 459 p_buf->msg.state = key_state; 460 p_buf->msg.pass_len = buf_len; 462 p_buf->msg.p_pass_data = NULL; 464 p_buf->msg.p_pass_data = (UINT8 *)(p_buf + 1); 465 memcpy(p_buf->msg [all...] |
/system/core/adb/ |
H A D | adb.cpp | 128 switch(p->msg.command){ 140 label, tag, p->msg.arg0, p->msg.arg1, p->msg.data_length); 141 count = p->msg.data_length; 165 p->msg.command = A_OKAY; 166 p->msg.arg0 = local; 167 p->msg.arg1 = remote; 175 p->msg.command = A_CLSE; 176 p->msg [all...] |
H A D | file_sync_client.cpp | 258 syncmsg msg; local 259 msg.data.id = ID_DONE; 260 msg.data.size = mtime; 262 return WriteOrDie(lpath, rpath, &msg.data, sizeof(msg.data)); 266 syncmsg msg; local 267 if (!ReadFdExactly(fd, &msg.status, sizeof(msg.status))) { 271 if (msg.status.id == ID_OKAY) { 280 if (msg 287 ReportCopyFailure(const char* from, const char* to, const syncmsg& msg) argument 410 syncmsg msg; local 440 syncmsg msg; local 459 syncmsg msg; local 537 syncmsg msg; local [all...] |
H A D | adb_auth_client.cpp | 195 char msg[MAX_PAYLOAD_V1]; local 214 ret = snprintf(msg, sizeof(msg), "PK%s", key); 215 if (ret >= (signed)sizeof(msg)) { 219 D("Sending '%s'", msg); 221 ret = unix_write(framework_fd, msg, ret);
|
/system/core/logd/tests/ |
H A D | logd_test.cpp | 206 log_msg *msg, unsigned int version, int lid) { 211 switch(msg->entry.hdr_size) { 216 case sizeof(msg->entry_v2): 223 fprintf(stderr, "%s: v%u[%u] ", prefix, version, msg->len()); 225 fprintf(stderr, "hdr_size=%u ", msg->entry.hdr_size); 228 msg->entry.pid, msg->entry.tid, msg->entry.sec, msg->entry.nsec); 233 fprintf(stderr, "euid=%u ", msg 205 dump_log_msg(const char *prefix, log_msg *msg, unsigned int version, int lid) argument 302 log_msg msg; local 742 log_msg msg; local [all...] |
/system/netd/server/ |
H A D | SockDiagTest.cpp | 98 auto checkIPv4Dump = [&] (uint8_t /* proto */, const inet_diag_msg *msg) { 99 if (msg == nullptr) { 104 EXPECT_EQ(htonl(INADDR_LOOPBACK), msg->id.idiag_src[0]); 106 seenclient46 |= (msg->id.idiag_sport == client46.sin6_port); 107 inet_ntop(AF_INET, msg->id.idiag_src, src, sizeof(src)); 108 inet_ntop(AF_INET, msg->id.idiag_src, dst, sizeof(dst)); 110 src, htons(msg->id.idiag_sport), 111 dst, htons(msg->id.idiag_dport), 112 tcpStateName(msg->idiag_state)); 119 auto checkIPv6Dump = [&] (uint8_t /* proto */, const inet_diag_msg *msg) { 268 checkSocketState(int i, int sock, const char *msg) argument [all...] |
H A D | MDnsSdListener.cpp | 103 char *msg; local 107 asprintf(&msg, "%d %d", refNumber, errorCode); 108 context->mListener->sendBroadcast(ResponseCode::ServiceDiscoveryFailed, msg, false); 126 asprintf(&msg, "%d %s %s %s", refNumber, quotedServiceName, regType, replyDomain); 128 context->mListener->sendBroadcast(respCode, msg, false); 130 free(msg); 135 char *msg; local 136 asprintf(&msg, "Invalid number of arguments to %s", str); 137 cli->sendMsg(ResponseCode::CommandParameterError, msg, false); 138 free(msg); 151 char *msg; local 196 char *msg; local 251 char *msg; local 319 char *msg; local 326 char *msg; local 373 char *msg; local 409 char* msg = NULL; local [all...] |
H A D | SockDiag.cpp | 228 inet_diag_msg *msg = reinterpret_cast<inet_diag_msg *>(NLMSG_DATA(nlh)); local 229 if (callback(proto, msg)) { 230 sockDestroy(proto, msg); 239 int SockDiag::sockDestroy(uint8_t proto, const inet_diag_msg *msg) { argument 240 if (msg == nullptr) { 250 .sdiag_family = msg->idiag_family, 252 .idiag_states = (uint32_t) (1 << msg->idiag_state), 253 .id = msg->id, 326 auto shouldDestroy = [uid] (uint8_t, const inet_diag_msg *msg) { 327 return (msg ! [all...] |
/system/connectivity/apmanager/ |
H A D | device_info.h | 67 void OnWiFiPhyInfoReceived(const shill::Nl80211Message& msg); 70 void LinkMsgHandler(const shill::RTNLMessage& msg); 88 void OnWiFiInterfaceInfoReceived(const shill::Nl80211Message& msg); 93 uint32_t iface_index, const shill::Nl80211Message& msg);
|
/system/core/init/ |
H A D | init.h | 34 void handle_control_message(const std::string& msg, const std::string& arg);
|
H A D | property_service.cpp | 234 prop_msg msg; local 271 r = TEMP_FAILURE_RETRY(recv(s, &msg, sizeof(msg), MSG_DONTWAIT)); 273 ERROR("sys_prop: mis-match msg size received: %d expected: %zu: %s\n", 279 switch(msg.cmd) { 281 msg.name[PROP_NAME_MAX-1] = 0; 282 msg.value[PROP_VALUE_MAX-1] = 0; 284 if (!is_legal_property_name(msg.name, strlen(msg.name))) { 285 ERROR("sys_prop: illegal property name. Got: \"%s\"\n", msg [all...] |
/system/connectivity/dhcp_client/ |
H A D | dhcpv4.h | 61 void HandleOffer(const DHCPMessage& msg); 62 void HandleAck(const DHCPMessage& msg); 63 void HandleNak(const DHCPMessage& msg);
|
/system/connectivity/shill/cellular/ |
H A D | cellular_error.cc | 51 const string msg = dbus_error->GetMessage(); local 65 if (!msg.empty()) 66 return error->Populate(type, msg);
|
H A D | cellular_error_mm1.cc | 64 const string msg = dbus_error->GetMessage(); local 82 if (!msg.empty()) 83 return error->Populate(type, msg);
|
/system/core/include/sysutils/ |
H A D | SocketClient.h | 48 int sendMsg(int code, const char *msg, bool addErrno); 49 int sendMsg(int code, const char *msg, bool addErrno, bool useCmdNum); 50 int sendMsg(const char *msg);
|
/system/core/fastboot/ |
H A D | engine.cpp | 66 const char *msg; member in struct:Action 137 a->msg = mkmsg("Setting current slot to '%s'", slot); 144 a->msg = mkmsg("erasing '%s'", ptn); 154 a->msg = mkmsg("sending '%s' (%d KB)", ptn, sz / 1024); 157 a->msg = mkmsg("writing '%s'", ptn); 167 a->msg = mkmsg("sending sparse '%s' %zu/%zu (%d KB)", ptn, current, total, sz / 1024); 170 a->msg = mkmsg("writing '%s' %zu/%zu", ptn, current, total); 255 a->msg = mkmsg("checking %s", var); 305 a->msg = "rebooting"; 308 void fb_queue_command(const char *cmd, const char *msg) argument [all...] |
/system/bt/btif/src/ |
H A D | btif_sock_util.c | 97 struct msghdr msg; local 99 memset(&msg, 0, sizeof(msg)); 108 msg.msg_control = msgbuf; 109 msg.msg_controllen = sizeof msgbuf; 110 cmsg = CMSG_FIRSTHDR(&msg); 125 msg.msg_iov = &iv; 126 msg.msg_iovlen = 1; 129 OSI_NO_INTR(ret = sendmsg(sock_fd, &msg, MSG_NOSIGNAL)); 141 memset(&msg, [all...] |
/system/core/libsysutils/src/ |
H A D | SocketClient.cpp | 54 int SocketClient::sendMsg(int code, const char *msg, bool addErrno) { argument 55 return sendMsg(code, msg, addErrno, mUseCmdNum); 58 int SocketClient::sendMsg(int code, const char *msg, bool addErrno, bool useCmdNum) { argument 64 ret = asprintf(&buf, "%d %d %s (%s)", code, getCmdNum(), msg, strerror(errno)); 66 ret = asprintf(&buf, "%d %s (%s)", code, msg, strerror(errno)); 70 ret = asprintf(&buf, "%d %d %s", code, getCmdNum(), msg); 72 ret = asprintf(&buf, "%d %s", code, msg); 144 int SocketClient::sendMsg(const char *msg) { argument 146 if (sendData(msg, strlen(msg) [all...] |
/system/extras/tests/net_test/ |
H A D | netlink.py | 90 def _Decode(self, command, msg, nla_type, nla_data): 94 def _ParseAttributes(self, command, family, msg, data): 103 msg: A Struct, the type of the data after the netlink header. 123 nla_name, nla_data = self._Decode(command, msg, nla.nla_type, nla_data) 142 def _Send(self, msg): 143 # self._Debug(msg.encode("hex")) 145 self.sock.send(msg) 213 msg, data = self._ParseNLMsg(data, msgtype) 214 if msg is None: 216 out.append(msg) [all...] |
H A D | tcp_test.py | 60 def _ReceiveAndExpectResponse(self, netid, packet, reply, msg): 62 reply, msg) 89 msg = "Received %s, expected to see reply %s" % (desc, synack_desc) 90 reply = self._ReceiveAndExpectResponse(netid, syn, synack, msg) 109 self.ExpectPacketOn(netid, msg + ": expecting %s" % desc, data) 114 msg = "Received %s, expected to see reply %s" % (desc, ack_desc) 117 # self._ReceiveAndExpectResponse(netid, fin, ack, msg) 120 self.ExpectPacketOn(netid, msg + ": expecting %s" % ack_desc, ack)
|
/system/connectivity/shill/ |
H A D | device_info.cc | 581 bool DeviceInfo::GetLinkNameFromMessage(const RTNLMessage& msg, argument 583 if (!msg.HasAttribute(IFLA_IFNAME)) 586 ByteString link_name_bytes(msg.GetAttribute(IFLA_IFNAME)); 593 bool DeviceInfo::IsRenamedBlacklistedDevice(const RTNLMessage& msg) { argument 594 int interface_index = msg.interface_index(); 603 if (!GetLinkNameFromMessage(msg, &interface_name)) 615 void DeviceInfo::AddLinkMsgHandler(const RTNLMessage& msg) { argument 616 DCHECK(msg.type() == RTNLMessage::kTypeLink && 617 msg.mode() == RTNLMessage::kModeAdd); 618 int dev_index = msg 687 DelLinkMsgHandler(const RTNLMessage& msg) argument 1043 LinkMsgHandler(const RTNLMessage& msg) argument 1054 AddressMsgHandler(const RTNLMessage& msg) argument 1100 RdnssMsgHandler(const RTNLMessage& msg) argument 1186 RetrieveLinkStatistics(int interface_index, const RTNLMessage& msg) argument 1216 GetInterfaceMessage msg; local 1231 OnWiFiInterfaceInfoReceived(const Nl80211Message& msg) argument [all...] |