Searched refs:msg (Results 51 - 75 of 164) sorted by relevance

1234567

/fuchsia/zircon/system/utest/syslog/
H A Dsyslog_socket_tests.cpp59 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 Dsyslog_tests.c193 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 Dchannel.c318 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 Dvirtual-layer.cpp278 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 Dmain.cpp62 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 Duserboot.cpp147 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 Dprocessargs.c74 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 Dunittest.h80 // 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 Dfx_logger.cpp55 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 Dfx_logger.h59 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 Dchannel.cpp92 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 Dchannel_dispatcher.cpp159 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 Dldsvc_tests.c84 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 Dserver_tests.c41 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 Ddevmgr-devfs.cpp132 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 Ddmctl.cpp21 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 Dfidl.c28 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 Dspawn.c115 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 Dprocessargs.h39 zx_status_t zxr_processargs_strings(void* msg, uint32_t bytes,
/fuchsia/zircon/third_party/ulib/musl/include/sys/
H A Dmsg.h20 #include <bits/msg.h>
/fuchsia/zircon/system/host/bootserver/
H A Dbootserver.c223 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 Dunittest.cpp84 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 Dchannel_dispatcher.h37 // 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 Dmessage_packet.h36 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 Dlocale_map.c6 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;

Completed in 208 milliseconds

1234567