/fuchsia/zircon/system/utest/syslog/ |
H A D | syslog_socket_tests.cpp | 59 const char* msg, const char** tags, int num_tags) { 74 EXPECT_STR_EQ(msg, packet.data + pos, ""); 84 const char* msg = "test message"; local 85 FX_LOG(INFO, nullptr, msg); 86 output_compare_helper(fbl::move(local), FX_LOG_INFO, msg, nullptr, 0); local 205 char msg[2048] = {0}; local 206 memset(msg, 'a', sizeof(msg) - 1); 207 FX_LOGF(INFO, "tag", "%s", msg); 226 char msg[204 local 58 output_compare_helper(zx::socket local, fx_log_severity_t severity, const char* msg, const char** tags, int num_tags) argument 262 char msg[] = "some text"; local 271 output_compare_helper(fbl::move(local), FX_LOG_INFO, msg, tags, local 282 const char* msg = "test message"; local 285 output_compare_helper(fbl::move(local), -1, msg, nullptr, 0); local [all...] |
H A D | syslog_tests.c | 193 char msg[2048] = {0}; local 195 memset(msg, 'a', sizeof(msg) - 1); 196 FX_LOGF(INFO, NULL, "%s", msg); 199 msg[n] = 0; 202 msg[0] = '%'; 203 msg[1] = 's'; 204 FX_LOG(INFO, NULL, msg); 207 msg[n] = 0;
|
/fuchsia/zircon/system/utest/core/channel/ |
H A D | channel.c | 318 uint32_t msg = MSG_UNSET; local 319 uint32_t msg_size = sizeof(msg); 320 zx_status_t status = zx_channel_read(_channel[0], 0u, &msg, NULL, 326 if (msg_size != sizeof(msg)) { 330 if (msg >= multithread_read_num_messages) { 335 ((uint32_t*)arg)[i] = msg; 376 uint32_t msg = received0[i]; local 377 ASSERT_NE(msg, MSG_READ_FAILED, "read failed"); 378 ASSERT_NE(msg, MSG_WRONG_SIZE, "got wrong message size"); 379 ASSERT_NE(msg, MSG_BAD_DAT 384 uint32_t msg = received1[i]; local 515 msg_t msg; local 582 msg_t msg; local 737 uint8_t msg[64]; local 796 char msg[8] = { 0, }; local 851 char msg[8] = { 0, }; local [all...] |
/fuchsia/zircon/system/uapp/display-test/ |
H A D | virtual-layer.cpp | 278 fuchsia_display_ControllerSetLayerPrimaryPositionRequest msg; 279 msg.hdr.ordinal = fuchsia_display_ControllerSetLayerPrimaryPositionOrdinal; 282 msg.layer_id = layer.id; 283 msg.transform = rotation_; 285 msg.src_frame.width = layer.src.width; 286 msg.src_frame.height = layer.src.height; 287 msg.src_frame.x_pos = layer.src.x_pos; 288 msg.src_frame.y_pos = layer.src.y_pos; 290 msg.dest_frame.width = layer.dest.width; 291 msg 390 fuchsia_display_ControllerSetLayerCursorPositionRequest msg; local [all...] |
H A D | main.cpp | 62 fidl::Message msg(fidl::BytePart(byte_buffer, ZX_CHANNEL_MAX_MSG_BYTES), fidl::HandlePart()); 70 if (msg.Read(dc_handle, 0) != ZX_OK) { 75 if (msg.ordinal() == fuchsia_display_ControllerDisplaysChangedOrdinal) { 77 if (msg.Decode(&fuchsia_display_ControllerDisplaysChangedEventTable, 79 printf("Fidl decode error %d %s\n", msg.ordinal(), err_msg); 84 msg.bytes().data()); 90 } else if (msg.ordinal() == fuchsia_display_ControllerClientOwnershipChangeOrdinal) { 92 msg.bytes().data())->has_ownership; 94 printf("Got unexpected message %d\n", msg.ordinal()); 189 fidl::Message msg(fid [all...] |
/fuchsia/zircon/kernel/lib/userboot/ |
H A D | userboot.cpp | 147 fbl::unique_ptr<MessagePacket> msg, 163 zx_status_t status = kernel_channel->Write(fbl::move(msg)); 201 bootstrap_message* msg = local 203 if (msg == nullptr) { 207 memset(&msg->header, 0, sizeof(msg->header)); 208 msg->header.protocol = ZX_PROCARGS_PROTOCOL; 209 msg->header.version = ZX_PROCARGS_VERSION; 210 msg->header.environ_off = offsetof(struct bootstrap_message, cmdline); 211 msg 145 make_bootstrap_channel( fbl::RefPtr<ProcessDispatcher> process, fbl::unique_ptr<MessagePacket> msg, zx_handle_t* out) argument [all...] |
/fuchsia/zircon/system/ulib/runtime/ |
H A D | processargs.c | 74 zx_status_t zxr_processargs_strings(void* msg, uint32_t bytes, argument 76 zx_proc_args_t* const pa = msg; 79 status = unpack_strings(msg, bytes, argv, pa->args_off, pa->args_num); 82 status = unpack_strings(msg, bytes, envp, 86 status = unpack_strings(msg, bytes, names, pa->names_off, pa->names_num);
|
/fuchsia/zircon/system/ulib/unittest/include/unittest/ |
H A D | unittest.h | 80 // The following helper function makes the "msg" argument optional in 485 #define UT_BYTES_EQ(expected, actual, length, msg, ret) \ 490 if (!unittest_expect_bytes_eq((expected), (actual), (length), msg)) { \ 496 #define UT_BYTES_NE(bytes1, bytes2, length, msg, ret) \ 506 msg, #bytes1, #bytes2); \ 582 #define EXPECT_BYTES_EQ(expected, actual, length, msg) UT_BYTES_EQ(expected, actual, length, msg, DONOT_RET) 583 #define EXPECT_BYTES_NE(bytes1, bytes2, length, msg) UT_BYTES_NE(bytes1, bytes2, length, msg, DONOT_RET) 614 #define ASSERT_BYTES_EQ(expected, actual, length, msg) UT_BYTES_E [all...] |
/fuchsia/zircon/system/ulib/syslog/ |
H A D | fx_logger.cpp | 55 const char* tag, const char* msg, 89 // Write msg 95 fbl::min(strlen(msg), static_cast<size_t>(n - 1)); 96 memcpy(packet.data + pos, msg, write_len); 101 count = vsnprintf(packet.data + pos, n, msg, args); 129 const char* tag, const char* msg, 176 buf.Append(msg); 178 buf.AppendVPrintf(msg, args); 193 const char* msg, va_list args, bool perform_format) { 194 if (msg 54 VLogWriteToSocket(fx_log_severity_t severity, const char* tag, const char* msg, va_list args, bool perform_format) argument 81 ZX_DEBUG_ASSERT(write_len < 128); packet.data[pos++] = static_cast<char>(write_len); memcpy(packet.data + pos, tag, write_len); pos += write_len; } } packet.data[pos++] = 0; ZX_DEBUG_ASSERT(pos < kDataSize); int n = static_cast<int>(kDataSize - pos); int count = 0; size_t msg_pos = pos; if (!perform_format) { size_t write_len = fbl::min(strlen(msg), static_cast<size_t>(n - 1)); memcpy(packet.data + pos, msg, write_len); pos += write_len; packet.data[pos] = 0; count = static_cast<int>(write_len + 1); } else { count = vsnprintf(packet.data + pos, n, msg, args); if (count < 0) { return ZX_ERR_INVALID_ARGS; } } if (count >= n) { constexpr char kEllipsis[] = �; constexpr size_t kEllipsisSize = sizeof(kEllipsis) - 1; memcpy(packet.data + kDataSize - 1 - kEllipsisSize, kEllipsis, kEllipsisSize); count = n - 1; } auto size = sizeof(packet.metadata) + msg_pos + count + 1; ZX_DEBUG_ASSERT(size <= sizeof(packet)); auto status = socket_.write(0, &packet, size, nullptr); if (status == ZX_ERR_BAD_STATE || status == ZX_ERR_PEER_CLOSED) { ActivateFallback(-1); return VLogWriteToFd(logger_fd_.load(fbl::memory_order_relaxed), severity, tag, packet.data + msg_pos, args, false); } if (status != ZX_OK) { dropped_logs_.fetch_add(1); } return status; } zx_status_t fx_logger::VLogWriteToFd(int fd, fx_log_severity_t severity, const char* tag, const char* msg, va_list args, bool perform_format) { zx_time_t time = zx_clock_get_monotonic(); constexpr char kEllipsis[] = �; constexpr size_t kEllipsisSize = sizeof(kEllipsis) - 1; constexpr size_t kMaxMessageSize = 2043; fbl::StringBuffer<kMaxMessageSize + kEllipsisSize + 1 > buf; buf.AppendPrintf(�, time / 1000000000UL, (time / 1000UL) % 1000000UL); buf.AppendPrintf(�, pid_); buf.AppendPrintf(�, GetCurrentThreadKoid()); buf.Append(�); if (!tagstr_.empty()) { buf.Append(tagstr_); } if (tag != NULL) { size_t len = strlen(tag); if (len > 0) { if (!tagstr_.empty()) { buf.Append(�); } buf.Append(tag, fbl::min(len, static_cast<size_t>(FX_LOG_MAX_TAG_LEN - 1))); } } buf.Append(�); switch (severity) { case FX_LOG_INFO: buf.Append(�); break; case FX_LOG_WARNING: buf.Append(�); break; case FX_LOG_ERROR: buf.Append(�); break; case FX_LOG_FATAL: buf.Append(�); break; default: buf.AppendPrintf(�, -severity); } buf.Append(�); if (!perform_format) { buf.Append(msg); } else { buf.AppendVPrintf(msg, args); } if (buf.size() > kMaxMessageSize) { buf.Resize(kMaxMessageSize); buf.Append(kEllipsis); } buf.Append(�); ssize_t status = write(fd, buf.data(), buf.size()); if (status < 0) { return ZX_ERR_IO; } return ZX_OK; } zx_status_t fx_logger::VLogWrite(fx_log_severity_t severity, const char* tag, const char* msg, va_list args, bool perform_format) { if (msg == NULL || severity > FX_LOG_FATAL) { return ZX_ERR_INVALID_ARGS; } if (GetSeverity() > severity) argument [all...] |
H A D | fx_logger.h | 59 const char* msg) { 61 return VLogWrite(severity, tag, msg, empty_args, false); 79 const char* msg, va_list args, bool perform_format); 82 const char* msg, va_list args, bool perform_format); 58 LogWrite(fx_log_severity_t severity, const char* tag, const char* msg) argument
|
/fuchsia/zircon/kernel/syscalls/ |
H A D | channel.cpp | 92 static void msg_get_handles(ProcessDispatcher* up, MessagePacket* msg, argument 94 Handle* const* handle_list = msg->handles(); 95 msg->set_owns_handles(false); 133 fbl::unique_ptr<MessagePacket> msg; 134 result = channel->Read(&num_bytes, &num_handles, &msg, 156 if (msg->CopyDataTo(bytes) != ZX_OK) 163 msg_get_handles(up, msg.get(), handles, num_handles); 235 static zx_status_t msg_put_handles(ProcessDispatcher* up, MessagePacket* msg, argument 266 msg->mutable_handles()[ix] = handle; 270 msg 294 fbl::unique_ptr<MessagePacket> msg; local 348 fbl::unique_ptr<MessagePacket> msg; local [all...] |
/fuchsia/zircon/kernel/object/ |
H A D | channel_dispatcher.cpp | 159 fbl::unique_ptr<MessagePacket>* msg, 180 *msg = messages_.pop_front(); 189 zx_status_t ChannelDispatcher::Write(fbl::unique_ptr<MessagePacket> msg) { argument 198 peer_->WriteSelf(fbl::move(msg)); 203 zx_status_t ChannelDispatcher::Call(fbl::unique_ptr<MessagePacket> msg, argument 243 msg->set_txid(txid); 250 peer_->WriteSelf(fbl::move(msg)); 301 void ChannelDispatcher::WriteSelf(fbl::unique_ptr<MessagePacket> msg) { argument 308 zx_txid_t txid = msg->get_txid(); 314 waiter.Deliver(fbl::move(msg)); 157 Read(uint32_t* msg_size, uint32_t* msg_handle_count, fbl::unique_ptr<MessagePacket>* msg, bool may_discard) argument 353 Deliver(fbl::unique_ptr<MessagePacket> msg) argument [all...] |
/fuchsia/zircon/system/utest/fidl-simple/ |
H A D | ldsvc_tests.c | 84 static zx_status_t ldsvc_server_reply(fidl_txn_t* txn, const fidl_msg_t* msg) { argument 86 if (msg->num_bytes < sizeof(fidl_message_header_t)) 88 fidl_message_header_t* hdr = (fidl_message_header_t*)msg->bytes; 92 return zx_channel_write(conn->channel, 0, msg->bytes, msg->num_bytes, 93 msg->handles, msg->num_handles); 114 fidl_msg_t msg = { local 123 &msg.num_bytes, &msg [all...] |
H A D | server_tests.c | 41 fidl_msg_t msg = { local 56 status = fuchsia_crash_Analyzer_dispatch(&kContext, &txn, &msg, &ops); 72 status = fuchsia_crash_Analyzer_dispatch(&kContext, &txn, &msg, &ops); 94 status = fuchsia_crash_Analyzer_try_dispatch(&kContext, &txn, &msg, &ops); 114 static zx_status_t reply_handler(fidl_txn_t* txn, const fidl_msg_t* msg) { argument 116 EXPECT_EQ(sizeof(fidl_message_header_t), msg->num_bytes, ""); 117 EXPECT_EQ(0u, msg->num_handles, ""); 157 fidl_msg_t msg = { local 169 status = fuchsia_crash_Analyzer_try_dispatch(NULL, &txn, &msg, &ops);
|
/fuchsia/zircon/system/core/devmgr/ |
H A D | devmgr-devfs.cpp | 132 zxrio_describe_t msg; local 133 memset(&msg, 0, sizeof(msg)); 134 msg.hdr.ordinal = fuchsia_io_NodeOnOpenOrdinal; 135 msg.status = status; 136 zx_channel_write(h, 0, &msg, sizeof(zxrio_describe_t), nullptr, 0); 207 uint8_t msg[fuchsia_io_MAX_FILENAME + 2]; local 208 msg[0] = static_cast<uint8_t>(op); 209 msg[1] = static_cast<uint8_t>(len); 210 memcpy(msg 552 zxrio_describe_t msg; local 645 devfs_fidl_handler(fidl_msg_t* msg, fidl_txn_t* txn, void* cookie) argument [all...] |
H A D | dmctl.cpp | 21 dc_msg_t msg; local 23 if (dc_msg_pack(&msg, &msglen, cmd, cmdlen, nullptr, nullptr) < 0) { 26 msg.op = op; 28 return dc_msg_rpc(dmctl_dev->rpc, &msg, msglen, h, hcount, &rsp, sizeof(rsp), nullptr, nullptr);
|
/fuchsia/zircon/system/ulib/fdio/ |
H A D | fidl.c | 28 static zx_status_t txn_reply(fidl_txn_t* txn, const fidl_msg_t* msg) { argument 30 fidl_message_header_t* hdr = msg->bytes; 32 return zx_channel_write(cnxn->channel, 0, msg->bytes, msg->num_bytes, 33 msg->handles, msg->num_handles); 38 static zx_status_t txn_null_reply(fidl_txn_t* reply, const fidl_msg_t* msg) { argument 46 fidl_msg_t msg = { local 62 cb(&msg, &cnxn.txn, cookie); 69 fidl_msg_t msg local [all...] |
H A D | spawn.c | 115 uint8_t msg[msg_len]; local 116 memset(msg, 0, msg_len); 118 fidl_message_header_t* hdr = (fidl_message_header_t*)msg; 136 return zx_channel_write(launcher, 0, msg, msg_len, NULL, 0); 146 uint8_t msg[msg_capacity]; local 147 memset(msg, 0, msg_capacity); 149 fuchsia_process_LauncherAddHandlesRequest* req = (fuchsia_process_LauncherAddHandlesRequest*)msg; 247 status = zx_channel_write(launcher, 0, msg, msg_len, handles, h); 279 uint8_t msg[msg_len]; local 280 memset(msg, 539 } msg; local [all...] |
/fuchsia/zircon/system/ulib/runtime/include/runtime/ |
H A D | processargs.h | 39 zx_status_t zxr_processargs_strings(void* msg, uint32_t bytes,
|
/fuchsia/zircon/third_party/ulib/musl/include/sys/ |
H A D | msg.h | 20 #include <bits/msg.h>
|
/fuchsia/zircon/system/host/bootserver/ |
H A D | bootserver.c | 223 nbmsg msg; local 225 msg.magic = NB_MAGIC; 226 msg.cookie = cookie++; 227 msg.cmd = NB_BOOT; 228 msg.arg = 0; 239 ssize_t send_result = sendto(s, &msg, sizeof(msg), 0, (struct sockaddr*)&target_addr, 241 if (send_result == sizeof(msg)) { 253 nbmsg msg; local 255 msg 506 nbmsg* msg = (void*)buf; local [all...] |
/fuchsia/zircon/system/ulib/unittest/ |
H A D | unittest.cpp | 84 const char* msg) { 86 printf("%s. expected\n", msg); 97 const char* msg, 110 msg, str1_expr, str2_expr, str1_value, str2_value); 118 const char* msg, 131 msg, str1_expr, str2_expr, str1_value); 139 const char* msg, 152 msg, str1_expr, str2_expr, str1_value); 83 unittest_expect_bytes_eq(const uint8_t* expected, const uint8_t* actual, size_t len, const char* msg) argument 95 unittest_expect_str_eq(const char* str1_value, const char* str2_value, const char* str1_expr, const char* str2_expr, const char* msg, const char* source_filename, int source_line_num, const char* source_function) argument 116 unittest_expect_str_ne(const char* str1_value, const char* str2_value, const char* str1_expr, const char* str2_expr, const char* msg, const char* source_filename, int source_line_num, const char* source_function) argument 137 unittest_expect_str_str(const char* str1_value, const char* str2_value, const char* str1_expr, const char* str2_expr, const char* msg, const char* source_filename, int source_line_num, const char* source_function) argument
|
/fuchsia/zircon/kernel/object/include/object/ |
H A D | channel_dispatcher.h | 37 // actual size and handle count of the next message. The next message is returned in |*msg| on 41 fbl::unique_ptr<MessagePacket>* msg, 45 zx_status_t Write(fbl::unique_ptr<MessagePacket> msg) TA_NO_THREAD_SAFETY_ANALYSIS; 46 zx_status_t Call(fbl::unique_ptr<MessagePacket> msg, zx_time_t deadline, 77 void Deliver(fbl::unique_ptr<MessagePacket> msg); 108 void WriteSelf(fbl::unique_ptr<MessagePacket> msg) TA_REQ(get_lock());
|
H A D | message_packet.h | 36 fbl::unique_ptr<MessagePacket>* msg); 39 fbl::unique_ptr<MessagePacket>* msg); 94 fbl::unique_ptr<MessagePacket>* msg);
|
/fuchsia/zircon/third_party/ulib/musl/src/locale/ |
H A D | locale_map.c | 6 const char* __lctrans(const char* msg, const struct __locale_map* lm) { argument 9 trans = __mo_lookup(lm->map, lm->map_size, msg); 10 return trans ? trans : msg;
|