| /system/netd/server/ |
| D | WakeupControllerTest.cpp | 111 } msg = {}; in TEST_F() local
113 msg.uidAttr.nla_type = NFULA_UID; in TEST_F()
114 msg.uidAttr.nla_len = sizeof(msg.uidAttr) + sizeof(msg.uid); in TEST_F()
115 msg.uid = htonl(kUid); in TEST_F()
117 msg.gidAttr.nla_type = NFULA_GID; in TEST_F()
118 msg.gidAttr.nla_len = sizeof(msg.gidAttr) + sizeof(msg.gid); in TEST_F()
119 msg.gid = htonl(kGid); in TEST_F()
121 msg.tsAttr.nla_type = NFULA_TIMESTAMP; in TEST_F()
122 msg.tsAttr.nla_len = sizeof(msg.tsAttr) + sizeof(msg.ts); in TEST_F()
123 msg.ts.tv_sec = htonl(kTsNs / kNsPerS); in TEST_F()
[all …]
|
| D | NFLogListener.cpp | 52 const nfgenmsg& nfmsg, const Slice msg) { in __anon837550c70202() argument
54 ss << nlmsg << " " << nfmsg << " " << msg << " " << netdutils::toHex(msg, 32); in __anon837550c70202()
58 using SendFn = std::function<Status(const Slice msg)>;
67 } __attribute__((packed)) msg = {}; in cfgCmdPfUnbind() local
69 msg.nlhdr.nlmsg_len = sizeof(msg); in cfgCmdPfUnbind()
70 msg.nlhdr.nlmsg_type = kNFLogConfigMsgType; in cfgCmdPfUnbind()
71 msg.nlhdr.nlmsg_flags = NLM_F_REQUEST; in cfgCmdPfUnbind()
72 msg.nfhdr.nfgen_family = AF_UNSPEC; in cfgCmdPfUnbind()
73 msg.attr.nfa_len = sizeof(msg.attr) + sizeof(msg.cmd); in cfgCmdPfUnbind()
74 msg.attr.nfa_type = NFULA_CFG_CMD; in cfgCmdPfUnbind()
[all …]
|
| D | SockDiagTest.cpp | 38 static bool isLoopbackSocket(const inet_diag_msg *msg) { in isLoopbackSocket() argument
39 return SockDiag::isLoopbackSocket(msg); in isLoopbackSocket()
110 auto checkIPv4Dump = [&] (uint8_t /* proto */, const inet_diag_msg *msg) { in TEST_F() argument
111 EXPECT_EQ(htonl(INADDR_LOOPBACK), msg->id.idiag_src[0]); in TEST_F()
113 seenclient46 |= (msg->id.idiag_sport == client46.sin6_port); in TEST_F()
114 inet_ntop(AF_INET, msg->id.idiag_src, src, sizeof(src)); in TEST_F()
115 inet_ntop(AF_INET, msg->id.idiag_src, dst, sizeof(dst)); in TEST_F()
117 src, htons(msg->id.idiag_sport), in TEST_F()
118 dst, htons(msg->id.idiag_dport), in TEST_F()
119 tcpStateName(msg->idiag_state)); in TEST_F()
[all …]
|
| /system/core/trusty/storage/lib/ |
| D | storage.c | 57 static ssize_t check_response(struct storage_msg *msg, ssize_t res) in check_response() argument
62 if ((size_t)res < sizeof(*msg)) { in check_response()
63 ALOGE("invalid msg length (%zd < %zd)\n", res, sizeof(*msg)); in check_response()
67 ALOGV("cmd 0x%x: server returned %u\n", msg->cmd, msg->result); in check_response()
69 switch(msg->result) { in check_response()
71 return res - sizeof(*msg); in check_response()
83 ALOGE("cmd 0x%x: is unhandles command\n", msg->cmd); in check_response()
93 ALOGE("cmd 0x%x: internal server error\n", msg->cmd); in check_response()
98 msg->cmd, msg->result); in check_response()
146 struct storage_msg msg = { .cmd = STORAGE_FILE_OPEN, .flags = _to_msg_flags(opflags)}; in storage_open_file() local
[all …]
|
| /system/core/init/ |
| D | uevent_listener.cpp | 32 static void ParseEvent(const char* msg, Uevent* uevent) { in ParseEvent() argument
44 while (*msg) { in ParseEvent()
45 if (!strncmp(msg, "ACTION=", 7)) { in ParseEvent()
46 msg += 7; in ParseEvent()
47 uevent->action = msg; in ParseEvent()
48 } else if (!strncmp(msg, "DEVPATH=", 8)) { in ParseEvent()
49 msg += 8; in ParseEvent()
50 uevent->path = msg; in ParseEvent()
51 } else if (!strncmp(msg, "SUBSYSTEM=", 10)) { in ParseEvent()
52 msg += 10; in ParseEvent()
[all …]
|
| /system/bt/stack/test/ |
| D | stack_avrcp_test.cc | 32 tAVRC_MSG msg{}; in TEST_F() local
36 msg.hdr.opcode = AVRC_OP_BROWSE; in TEST_F()
37 msg.browse.p_browse_data = browse_cmd_buf; in TEST_F()
38 msg.browse.browse_len = 2; in TEST_F()
39 EXPECT_EQ(AVRC_ParsCommand(&msg, &result, scratch_buf, sizeof(scratch_buf)), in TEST_F()
44 msg.browse.browse_len = 3; in TEST_F()
45 EXPECT_EQ(AVRC_ParsCommand(&msg, &result, scratch_buf, sizeof(scratch_buf)), in TEST_F()
48 msg.browse.browse_len = 5; in TEST_F()
49 EXPECT_EQ(AVRC_ParsCommand(&msg, &result, scratch_buf, sizeof(scratch_buf)), in TEST_F()
54 msg.browse.browse_len = 3; in TEST_F()
[all …]
|
| /system/media/camera/src/ |
| D | camera_metadata_tag_info.c | 933 const char *msg = "error: not an enum"; in camera_metadata_enum_snprint() local
940 msg = "TRANSFORM_MATRIX"; in camera_metadata_enum_snprint()
944 msg = "FAST"; in camera_metadata_enum_snprint()
948 msg = "HIGH_QUALITY"; in camera_metadata_enum_snprint()
952 msg = "error: enum value out of range"; in camera_metadata_enum_snprint()
965 msg = "OFF"; in camera_metadata_enum_snprint()
969 msg = "FAST"; in camera_metadata_enum_snprint()
973 msg = "HIGH_QUALITY"; in camera_metadata_enum_snprint()
977 msg = "error: enum value out of range"; in camera_metadata_enum_snprint()
988 msg = "OFF"; in camera_metadata_enum_snprint()
[all …]
|
| /system/keymaster/tests/ |
| D | android_keymaster_messages_test.cpp | 51 EmptyKeymasterResponse msg(ver); in TEST() local
52 msg.error = KM_ERROR_OK; in TEST()
54 UniquePtr<EmptyKeymasterResponse> deserialized(round_trip(ver, msg, 4)); in TEST()
60 EmptyKeymasterResponse msg(ver); in TEST() local
61 msg.error = KM_ERROR_MEMORY_ALLOCATION_FAILED; in TEST()
63 UniquePtr<EmptyKeymasterResponse> deserialized(round_trip(ver, msg, 4)); in TEST()
267 GetKeyCharacteristicsResponse msg(ver); in TEST() local
268 msg.error = KM_ERROR_OK; in TEST()
269 msg.enforced.Reinitialize(params, array_length(params)); in TEST()
270 msg.unenforced.Reinitialize(params, array_length(params)); in TEST()
[all …]
|
| /system/core/libnetutils/ |
| D | dhcpmsg.c | 24 static void *init_dhcp_msg(dhcp_msg *msg, int type, void *hwaddr, uint32_t xid) in init_dhcp_msg() argument
28 memset(msg, 0, sizeof(dhcp_msg)); in init_dhcp_msg()
30 msg->op = OP_BOOTREQUEST; in init_dhcp_msg()
31 msg->htype = HTYPE_ETHER; in init_dhcp_msg()
32 msg->hlen = 6; in init_dhcp_msg()
33 msg->hops = 0; in init_dhcp_msg()
35 msg->flags = htons(FLAGS_BROADCAST); in init_dhcp_msg()
37 msg->xid = xid; in init_dhcp_msg()
39 memcpy(msg->chaddr, hwaddr, 6); in init_dhcp_msg()
41 x = msg->options; in init_dhcp_msg()
[all …]
|
| D | dhcpclient.c | 164 int decode_dhcp_msg(dhcp_msg *msg, int len, dhcp_info *info) in decode_dhcp_msg() argument
175 if (msg->options[0] != OPT_COOKIE1) return -1; in decode_dhcp_msg()
176 if (msg->options[1] != OPT_COOKIE2) return -1; in decode_dhcp_msg()
177 if (msg->options[2] != OPT_COOKIE3) return -1; in decode_dhcp_msg()
178 if (msg->options[3] != OPT_COOKIE4) return -1; in decode_dhcp_msg()
180 x = msg->options + 4; in decode_dhcp_msg()
230 info->ipaddr = msg->yiaddr; in decode_dhcp_msg()
247 void dump_dhcp_msg(dhcp_msg *msg, int len) in dump_dhcp_msg() argument
263 if (msg->op == OP_BOOTREQUEST) in dump_dhcp_msg()
265 else if (msg->op == OP_BOOTREPLY) in dump_dhcp_msg()
[all …]
|
| /system/core/trusty/storage/proxy/ |
| D | proxy.c | 112 static int handle_req(struct storage_msg* msg, const void* req, size_t req_len) { in handle_req() argument
115 if ((msg->flags & STORAGE_MSG_FLAG_POST_COMMIT) && (msg->cmd != STORAGE_RPMB_SEND)) { in handle_req()
120 ALOGE("cmd 0x%x: post commit option is not implemented\n", msg->cmd); in handle_req()
121 msg->result = STORAGE_ERR_UNIMPLEMENTED; in handle_req()
122 return ipc_respond(msg, NULL, 0); in handle_req()
125 if (msg->flags & STORAGE_MSG_FLAG_PRE_COMMIT) { in handle_req()
128 msg->result = STORAGE_ERR_GENERIC; in handle_req()
129 return ipc_respond(msg, NULL, 0); in handle_req()
133 switch (msg->cmd) { in handle_req()
135 rc = storage_file_delete(msg, req, req_len); in handle_req()
[all …]
|
| D | ipc.c | 67 ssize_t ipc_get_msg(struct storage_msg *msg, void *req_buf, size_t req_buf_len) in ipc_get_msg() argument
70 struct iovec iovs[2] = {{msg, sizeof(*msg)}, {req_buf, req_buf_len}}; in ipc_get_msg()
81 if ((size_t)rc < sizeof(*msg)) { in ipc_get_msg()
87 if (msg->size != (uint32_t)rc) { in ipc_get_msg()
89 msg->cmd, msg->size, (uint32_t)rc); in ipc_get_msg()
93 return rc - sizeof(*msg); in ipc_get_msg()
96 int ipc_respond(struct storage_msg *msg, void *out, size_t out_size) in ipc_respond() argument
99 struct iovec iovs[2] = {{msg, sizeof(*msg)}, {out, out_size}}; in ipc_respond()
103 msg->cmd |= STORAGE_RESP_BIT; in ipc_respond()
108 msg->cmd, strerror(errno)); in ipc_respond()
|
| D | storage.c | 162 int storage_file_delete(struct storage_msg *msg, in storage_file_delete() argument
171 msg->result = STORAGE_ERR_NOT_VALID; in storage_file_delete()
179 msg->result = STORAGE_ERR_NOT_VALID; in storage_file_delete()
186 msg->result = STORAGE_ERR_GENERIC; in storage_file_delete()
201 msg->result = translate_errno(rc); in storage_file_delete()
206 msg->result = STORAGE_NO_ERROR; in storage_file_delete()
211 return ipc_respond(msg, NULL, 0); in storage_file_delete()
215 int storage_file_open(struct storage_msg *msg, in storage_file_open() argument
225 msg->result = STORAGE_ERR_NOT_VALID; in storage_file_open()
233 msg->result = STORAGE_ERR_NOT_VALID; in storage_file_open()
[all …]
|
| D | storage.h | 21 int storage_file_delete(struct storage_msg *msg,
24 int storage_file_open(struct storage_msg *msg,
27 int storage_file_close(struct storage_msg *msg,
30 int storage_file_write(struct storage_msg *msg,
33 int storage_file_read(struct storage_msg *msg,
36 int storage_file_get_size(struct storage_msg *msg,
39 int storage_file_set_size(struct storage_msg *msg,
|
| /system/chre/apps/power_test/common/ |
| D | request_manager.cc | 307 const TimerMessage *msg; in handleMessageFromHost() local
308 if (verifyMessage<TimerMessage>(hostMessage, &msg)) { in handleMessageFromHost()
309 success = requestTimer(msg->enable(), TimerType::WAKEUP, in handleMessageFromHost()
310 Nanoseconds(msg->wakeup_interval_ns())); in handleMessageFromHost()
315 const WifiScanMessage *msg; in handleMessageFromHost() local
316 if (verifyMessage<WifiScanMessage>(hostMessage, &msg)) { in handleMessageFromHost()
317 mWifiScanType = static_cast<uint8_t>(msg->scan_type()); in handleMessageFromHost()
318 mWifiRadioChain = static_cast<uint8_t>(msg->radio_chain()); in handleMessageFromHost()
319 mWifiChannelSet = static_cast<uint8_t>(msg->channel_set()); in handleMessageFromHost()
320 success = requestTimer(msg->enable(), TimerType::WIFI, in handleMessageFromHost()
[all …]
|
| /system/core/fs_mgr/libsnapshot/ |
| D | snapuserd_client.cpp | 114 bool SnapuserdClient::Sendmsg(const std::string& msg) { in Sendmsg() argument
115 LOG(DEBUG) << "Sendmsg: msg " << msg << " sockfd: " << sockfd_; in Sendmsg()
116 ssize_t numBytesSent = TEMP_FAILURE_RETRY(send(sockfd_, msg.data(), msg.size(), MSG_NOSIGNAL)); in Sendmsg()
122 if ((size_t)numBytesSent < msg.size()) { in Sendmsg()
123 LOG(ERROR) << "Partial data sent, expected " << msg.size() << " bytes, sent " in Sendmsg()
131 std::string msg = "delete," + control_device; in WaitForDeviceDelete() local
132 if (!Sendmsg(msg)) { in WaitForDeviceDelete()
133 LOG(ERROR) << "Failed to send message " << msg << " to snapuserd"; in WaitForDeviceDelete()
145 char msg[PACKET_SIZE]; in Receivemsg() local
146 ssize_t ret = TEMP_FAILURE_RETRY(recv(sockfd_, msg, sizeof(msg), 0)); in Receivemsg()
[all …]
|
| /system/bt/stack/avdt/ |
| D | avdt_ccb_act.cc | 150 p_data->msg.discover_rsp.p_sep_info = sep_info; in avdt_ccb_hdl_discover_cmd()
151 p_data->msg.discover_rsp.num_seps = 0; in avdt_ccb_hdl_discover_cmd()
157 sep_info[p_data->msg.discover_rsp.num_seps].in_use = p_scb->in_use; in avdt_ccb_hdl_discover_cmd()
158 sep_info[p_data->msg.discover_rsp.num_seps].seid = p_scb->ScbHandle(); in avdt_ccb_hdl_discover_cmd()
159 sep_info[p_data->msg.discover_rsp.num_seps].media_type = in avdt_ccb_hdl_discover_cmd()
161 sep_info[p_data->msg.discover_rsp.num_seps].tsep = in avdt_ccb_hdl_discover_cmd()
164 p_data->msg.discover_rsp.num_seps++; in avdt_ccb_hdl_discover_cmd()
190 (tAVDT_CTRL*)(&p_data->msg.discover_rsp), in avdt_ccb_hdl_discover_rsp()
209 AvdtpScb* p_scb = avdt_scb_by_hdl(p_data->msg.single.seid); in avdt_ccb_hdl_getcap_cmd()
213 p_data->msg.hdr.err_code = AVDT_ERR_BAD_STATE; in avdt_ccb_hdl_getcap_cmd()
[all …]
|
| /system/gatekeeper/tests/ |
| D | gatekeeper_messages_test.cpp | 52 EnrollRequest msg(USER_ID, {}, make_buffer(password_size), {}); in TEST() local
54 std::vector<uint8_t> serialized_msg(msg.GetSerializedSize()); in TEST()
55 … ASSERT_EQ(serialized_msg.size(), msg.Serialize(&*serialized_msg.begin(), &*serialized_msg.end())); in TEST()
67 …ASSERT_EQ(0, memcmp(msg.provided_password.Data<uint8_t>(), deserialized_password->Data<uint8_t>(),… in TEST()
76 EnrollRequest msg(USER_ID, {}, make_buffer(password_size), {}); in TEST() local
77 std::vector<uint8_t> serialized_msg(msg.GetSerializedSize()); in TEST()
78 … ASSERT_EQ(serialized_msg.size(), msg.Serialize(&*serialized_msg.begin(), &*serialized_msg.end())); in TEST()
90 …ASSERT_EQ(0, memcmp(msg.provided_password.Data<uint8_t>(), deserialized_password->Data<uint8_t>(),… in TEST()
104 …EnrollRequest msg(USER_ID, move(password_handle), move(provided_password), move(enrolled_password)… in TEST() local
105 std::vector<uint8_t> serialized_msg(msg.GetSerializedSize()); in TEST()
[all …]
|
| /system/core/fs_mgr/tools/ |
| D | dmuserd.cpp | 150 struct dm_user_message msg; in simple_daemon() local
156 if (read_all(control_fd, &msg, sizeof(msg)) < 0) { in simple_daemon()
165 switch (msg.type) { in simple_daemon()
180 type = std::string("(unknown, id=") + std::to_string(msg.type) + ")"; in simple_daemon()
185 if (msg.flags & DM_USER_REQ_MAP_FLAG_SYNC) { in simple_daemon()
189 if (msg.flags & DM_USER_REQ_MAP_FLAG_META) { in simple_daemon()
193 if (msg.flags & DM_USER_REQ_MAP_FLAG_FUA) { in simple_daemon()
197 if (msg.flags & DM_USER_REQ_MAP_FLAG_PREFLUSH) { in simple_daemon()
203 << std::to_string(msg.sector) << " with length " << std::to_string(msg.len) in simple_daemon()
207 type = msg.type; in simple_daemon()
[all …]
|
| /system/timezone/input_tools/android/common/src/main/java/com/android/libcore/timezone/util/ |
| D | Errors.java | 54 public HaltExecutionException addFatalAndHalt(String msg) throws HaltExecutionException { in addFatalAndHalt() argument
55 addInternal(msg, null, LEVEL_FATAL); in addFatalAndHalt()
60 public HaltExecutionException addFatalAndHalt(String msg, Throwable t) in addFatalAndHalt() argument
62 addInternal(msg, t, LEVEL_FATAL); in addFatalAndHalt()
66 public void addError(String msg) { in addError() argument
67 addInternal(msg, null, LEVEL_ERROR); in addError()
70 public void addError(String msg, Throwable t) { in addError() argument
71 addInternal(msg, t, LEVEL_ERROR); in addError()
74 public void addWarning(String msg) { in addWarning() argument
75 addInternal(msg, null, LEVEL_WARNING); in addWarning()
[all …]
|
| /system/extras/tests/uevents/ |
| D | uevents.c | 25 char msg[UEVENT_MSG_LEN+2]; in main() local
33 while ((n = uevent_kernel_multicast_recv(device_fd, msg, UEVENT_MSG_LEN)) > 0) { in main()
34 msg[n] = '\0'; in main()
35 msg[n+1] = '\0'; in main()
38 if (msg[i] == '\0') in main()
39 msg[i] = ' '; in main()
41 printf("%s\n", msg); in main()
|
| /system/chre/apps/test/chqts/src/echo_message/ |
| D | echo_message.cc | 44 auto *msg = static_cast<const chreMessageFromHostData *>(eventData); in nanoappHandleEvent() local
51 static_cast<uint8_t *>(chreHeapAlloc(msg->messageSize)); in nanoappHandleEvent()
52 if (msg->messageSize != 0 && messageBuffer == nullptr) { in nanoappHandleEvent()
57 const_cast<void *>(msg->message), msg->messageSize); in nanoappHandleEvent()
60 static_cast<void *>(messageBuffer), msg->messageSize, in nanoappHandleEvent()
61 msg->messageType, msg->hostEndpoint, messageFreeCallback)) { in nanoappHandleEvent()
|
| /system/libbase/ |
| D | logging_splitters.h | 32 static void SplitByLines(const char* msg, const F& log_function, Args&&... args) { in SplitByLines() argument
33 const char* newline = strchr(msg, '\n'); in SplitByLines()
35 log_function(msg, newline - msg, args...); in SplitByLines()
36 msg = newline + 1; in SplitByLines()
37 newline = strchr(msg, '\n'); in SplitByLines()
40 log_function(msg, -1, args...); in SplitByLines()
49 unsigned int line, const char* msg, const F& log_function) { in SplitByLogdChunks() argument
97 const char* newline = strchr(msg, '\n'); in SplitByLogdChunks()
100 if (chunk_position != 0 && chunk_position + (newline - msg) + 1 + file_header_size > max_size) { in SplitByLogdChunks()
106 write_to_logd_chunk(msg, newline - msg); in SplitByLogdChunks()
[all …]
|
| /system/bt/stack/btm/ |
| D | btm_main.cc | 65 const std::string& msg, const std::string& extra) { in btm_log_history() argument
68 msg.substr(0, kMaxLogHistoryMsgLength).c_str(), addr, extra.c_str()); in btm_log_history()
72 const std::string& msg, const std::string& extra) { in BTM_LogHistory() argument
73 btm_log_history(tag, PRIVATE_ADDRESS(bd_addr), msg, extra); in BTM_LogHistory()
77 const std::string& msg) { in BTM_LogHistory() argument
78 BTM_LogHistory(tag, bd_addr, msg, std::string()); in BTM_LogHistory()
82 const std::string& msg, const std::string& extra) { in BTM_LogHistory() argument
83 btm_log_history(tag, PRIVATE_ADDRESS(ble_bd_addr), msg, extra); in BTM_LogHistory()
87 const std::string& msg) { in BTM_LogHistory() argument
88 BTM_LogHistory(tag, ble_bd_addr, msg, std::string()); in BTM_LogHistory()
|
| /system/logging/logd/ |
| D | RecordingLogBuffer.cpp | 21 static void WriteLogMessage(int fd, const RecordedLogMessage& meta, const std::string& msg) { in WriteLogMessage() argument
23 android::base::WriteFully(fd, msg.c_str(), meta.msg_len); in WriteLogMessage()
27 pid_t tid, const char* msg, uint16_t len) { in RecordLogMessage() argument
46 since_boot_messages_.emplace_back(recorded_log_message, std::string(msg, len)); in RecordLogMessage()
49 for (const auto& [meta, msg] : since_boot_messages_) { in RecordLogMessage()
50 WriteLogMessage(fd_.get(), meta, msg); in RecordLogMessage()
55 WriteLogMessage(fd_.get(), recorded_log_message, std::string(msg, len)); in RecordLogMessage()
59 const char* msg, uint16_t len) { in Log() argument
60 RecordLogMessage(log_id, realtime, uid, pid, tid, msg, len); in Log()
61 return SimpleLogBuffer::Log(log_id, realtime, uid, pid, tid, msg, len); in Log()
|