| /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 | 54 const nfgenmsg& nfmsg, const Slice msg) { in __anon262d658c0202() argument
56 ss << nlmsg << " " << nfmsg << " " << msg << " " << netdutils::toHex(msg, 32); in __anon262d658c0202()
60 using SendFn = std::function<Status(const Slice msg)>;
69 } __attribute__((packed)) msg = {}; in cfgCmdPfUnbind() local
71 msg.nlhdr.nlmsg_len = sizeof(msg); in cfgCmdPfUnbind()
72 msg.nlhdr.nlmsg_type = kNFLogConfigMsgType; in cfgCmdPfUnbind()
73 msg.nlhdr.nlmsg_flags = NLM_F_REQUEST; in cfgCmdPfUnbind()
74 msg.nfhdr.nfgen_family = AF_UNSPEC; in cfgCmdPfUnbind()
75 msg.attr.nfa_len = sizeof(msg.attr) + sizeof(msg.cmd); in cfgCmdPfUnbind()
76 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 …]
|
| D | SockDiag.cpp | 62 bool isAdbSocket(const inet_diag_msg *msg, int adbPort) { in isAdbSocket() argument
63 return adbPort > 0 && msg->id.idiag_sport == htons(adbPort) && in isAdbSocket()
64 (msg->idiag_uid == AID_ROOT || msg->idiag_uid == AID_SHELL); in isAdbSocket()
224 const inet_diag_msg *msg = reinterpret_cast<inet_diag_msg *>(NLMSG_DATA(nlh)); in readDiagMsg() local
225 if (shouldDestroy(proto, msg)) { in readDiagMsg()
226 sockDestroy(proto, msg); in readDiagMsg()
242 inet_diag_msg *msg = reinterpret_cast<inet_diag_msg *>(NLMSG_DATA(nlh)); in readDiagMsgWithTcpInfo() local
243 uint32_t attr_len = nlh->nlmsg_len - NLMSG_LENGTH(sizeof(*msg)); in readDiagMsgWithTcpInfo()
244 struct rtattr *attr = reinterpret_cast<struct rtattr*>(msg+1); in readDiagMsgWithTcpInfo()
256 tcpInfoReader(mark, msg, tcpinfo, tcpinfoLength); in readDiagMsgWithTcpInfo()
[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/media/camera/src/ |
| D | camera_metadata_tag_info.c | 969 const char *msg = "error: not an enum"; in camera_metadata_enum_snprint() local
976 msg = "TRANSFORM_MATRIX"; in camera_metadata_enum_snprint()
980 msg = "FAST"; in camera_metadata_enum_snprint()
984 msg = "HIGH_QUALITY"; in camera_metadata_enum_snprint()
988 msg = "error: enum value out of range"; in camera_metadata_enum_snprint()
1001 msg = "OFF"; in camera_metadata_enum_snprint()
1005 msg = "FAST"; in camera_metadata_enum_snprint()
1009 msg = "HIGH_QUALITY"; in camera_metadata_enum_snprint()
1013 msg = "error: enum value out of range"; in camera_metadata_enum_snprint()
1024 msg = "OFF"; in camera_metadata_enum_snprint()
[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/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/fs_mgr/libsnapshot/snapuserd/ |
| D | snapuserd_client.cpp | 116 bool SnapuserdClient::Sendmsg(const std::string& msg) { in Sendmsg() argument
117 LOG(DEBUG) << "Sendmsg: msg " << msg << " sockfd: " << sockfd_; in Sendmsg()
118 ssize_t numBytesSent = TEMP_FAILURE_RETRY(send(sockfd_, msg.data(), msg.size(), MSG_NOSIGNAL)); in Sendmsg()
124 if ((size_t)numBytesSent < msg.size()) { in Sendmsg()
125 LOG(ERROR) << "Partial data sent, expected " << msg.size() << " bytes, sent " in Sendmsg()
133 std::string msg = "delete," + control_device; in WaitForDeviceDelete() local
134 if (!Sendmsg(msg)) { in WaitForDeviceDelete()
135 LOG(ERROR) << "Failed to send message " << msg << " to snapuserd"; in WaitForDeviceDelete()
147 std::string msg = "supports,second_stage_socket_handoff"; in SupportsSecondStageSocketHandoff() local
148 if (!Sendmsg(msg)) { in SupportsSecondStageSocketHandoff()
[all …]
|
| /system/core/trusty/storage/proxy/ |
| D | proxy.c | 116 static int handle_req(struct storage_msg* msg, const void* req, size_t req_len) { in handle_req() argument
119 if ((msg->flags & STORAGE_MSG_FLAG_POST_COMMIT) && msg->cmd != STORAGE_RPMB_SEND && in handle_req()
120 msg->cmd != STORAGE_FILE_WRITE) { in handle_req()
125 ALOGE("cmd 0x%x: post commit option is not implemented\n", msg->cmd); in handle_req()
126 msg->result = STORAGE_ERR_UNIMPLEMENTED; in handle_req()
127 return ipc_respond(msg, NULL, 0); in handle_req()
130 if (msg->flags & STORAGE_MSG_FLAG_PRE_COMMIT) { in handle_req()
133 msg->result = STORAGE_ERR_SYNC_FAILURE; in handle_req()
134 return ipc_respond(msg, NULL, 0); in handle_req()
138 if (msg->flags & STORAGE_MSG_FLAG_PRE_COMMIT_CHECKPOINT) { 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 | 179 int storage_file_delete(struct storage_msg *msg, in storage_file_delete() argument
188 msg->result = STORAGE_ERR_NOT_VALID; in storage_file_delete()
196 msg->result = STORAGE_ERR_NOT_VALID; in storage_file_delete()
203 msg->result = STORAGE_ERR_GENERIC; in storage_file_delete()
217 msg->result = translate_errno(rc); in storage_file_delete()
222 msg->result = STORAGE_NO_ERROR; in storage_file_delete()
227 return ipc_respond(msg, NULL, 0); in storage_file_delete()
243 int storage_file_open(struct storage_msg* msg, const void* r, size_t req_len) { in storage_file_open() argument
251 msg->result = STORAGE_ERR_NOT_VALID; in storage_file_open()
259 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/core/libnetutils/ |
| 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 …]
|
| 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 …]
|
| /system/chre/apps/power_test/common/ |
| D | request_manager.cc | 361 bool RequestManager::requestWifiNanSub(const WifiNanSubMessage *msg) { in requestWifiNanSub() argument
363 config.subscribeType = msg->sub_type(); in requestWifiNanSub()
364 config.service = reinterpret_cast<const char *>(msg->service_name()->data()); in requestWifiNanSub()
365 if (msg->service_specific_info()) { in requestWifiNanSub()
366 config.serviceSpecificInfo = msg->service_specific_info()->Data(); in requestWifiNanSub()
367 config.serviceSpecificInfoSize = msg->service_specific_info()->size(); in requestWifiNanSub()
369 if (msg->match_filter()) { in requestWifiNanSub()
370 config.matchFilter = msg->match_filter()->Data(); in requestWifiNanSub()
371 config.matchFilterLength = msg->match_filter()->size(); in requestWifiNanSub()
395 const TimerMessage *msg; in handleMessageFromHost() local
[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/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/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 | 48 auto *msg = static_cast<const chreMessageFromHostData *>(eventData); in nanoappHandleEvent() local
55 static_cast<uint8_t *>(chreHeapAlloc(msg->messageSize)); in nanoappHandleEvent()
56 if (msg->messageSize != 0 && messageBuffer == nullptr) { in nanoappHandleEvent()
61 const_cast<void *>(msg->message), msg->messageSize); in nanoappHandleEvent()
64 static_cast<void *>(messageBuffer), msg->messageSize, in nanoappHandleEvent()
65 msg->messageType, msg->hostEndpoint, messageFreeCallback)) { in nanoappHandleEvent()
|
| /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()
|
| /system/core/trusty/gatekeeper/ |
| D | trusty_gatekeeper_ipc.c | 53 struct gatekeeper_message *msg = malloc(msg_size); in trusty_gatekeeper_call() local
54 msg->cmd = cmd; in trusty_gatekeeper_call()
55 memcpy(msg->payload, in, in_size); in trusty_gatekeeper_call()
57 ssize_t rc = write(handle_, msg, msg_size); in trusty_gatekeeper_call()
58 free(msg); in trusty_gatekeeper_call()
78 msg = (struct gatekeeper_message *) out; in trusty_gatekeeper_call()
80 if ((cmd | GK_RESP_BIT) != msg->cmd) { in trusty_gatekeeper_call()
81 ALOGE("invalid command (%d)\n", msg->cmd); in trusty_gatekeeper_call()
|
| /system/unwinding/libunwindstack/ |
| D | ArmExidx.cpp | 210 std::string msg = "pop {"; in DecodePrefix_10_00() local
214 msg += ", "; in DecodePrefix_10_00()
216 msg += android::base::StringPrintf("r%zu", reg); in DecodePrefix_10_00()
220 Log::Info(log_indent_, "%s}", msg.c_str()); in DecodePrefix_10_00()
299 std::string msg = "pop {r4"; in DecodePrefix_10_10() local
301 msg += android::base::StringPrintf("-r%d", 4 + end_reg); in DecodePrefix_10_10()
304 Log::Info(log_indent_, "%s, r14}", msg.c_str()); in DecodePrefix_10_10()
306 Log::Info(log_indent_, "%s}", msg.c_str()); in DecodePrefix_10_10()
393 std::string msg = "pop {"; in DecodePrefix_10_11_0001() local
397 msg += ", "; in DecodePrefix_10_11_0001()
[all …]
|