Home
last modified time | relevance | path

Searched refs:message (Results 1 – 25 of 153) sorted by relevance

1234567

/device/board/isoftstone/yangfan/common/mqtt/mqttclient/samples/linux/
Dhello.cpp15 MQTT::Message &message = md.message; in messageArrived() local
18 ++arrivedcount, message.qos, message.retained, message.dup, message.id); in messageArrived()
19 printf("Payload %.*s\n", (int)message.payloadlen, (char*)message.payload); in messageArrived()
53 MQTT::Message message; in main() local
58 message.qos = MQTT::QOS0; in main()
59 message.retained = false; in main()
60 message.dup = false; in main()
61 message.payload = (void*)buf; in main()
62 message.payloadlen = strlen(buf)+1; in main()
63 rc = client.publish(topic, message); in main()
[all …]
Dmain.cpp207 MQTT::Message &message = md.message; in messageArrived() local
210 ++arrivedcount, message.qos, message.retained, message.dup, message.id); in messageArrived()
211 printf("Payload %.*s\n", message.payloadlen, (char*)message.payload); in messageArrived()
245 MQTT::Message message; in main() local
250 message.qos = MQTT::QOS0; in main()
251 message.retained = false; in main()
252 message.dup = false; in main()
253 message.payload = (void*)buf; in main()
254 message.payloadlen = strlen(buf)+1; in main()
255 rc = client.publish(topic, &message); in main()
[all …]
Dstdoutsub.cpp198 MQTT::Message &message = md.message; in messageArrived() local
203 printf("%.*s", (int)message.payloadlen, (char*)message.payload); in messageArrived()
205 printf("%.*s%s", (int)message.payloadlen, (char*)message.payload, opts.delimiter); in messageArrived()
/device/board/isoftstone/yangfan/common/mqtt/mqttclient/samples/ardunio/hello/
DHello.ino32 MQTT::Message &message = md.message;
35 ++arrivedcount, message.qos, message.retained, message.dup, message.id);
37 sprintf(printbuf, "Payload %s\n", (char*)message.payload);
95 MQTT::Message message;
99 // Send and receive QoS 0 message
101 sprintf(buf, "Hello World! QoS 0 message");
103 message.qos = MQTT::QOS0;
104 message.retained = false;
105 message.dup = false;
106 message.payload = (void*)buf;
[all …]
/device/soc/hisilicon/hi3861v100/sdk_liteos/third_party/lwip_sack/include/lwip/
Ddebug.h129 #define LWIP_ASSERT(message, assertion) do { if (!(assertion)) { \ argument
130 LWIP_PLATFORM_ASSERT(message); } } while (0)
135 #define LWIP_ASSERT(message, assertion)
140 #define LWIP_PLATFORM_ERROR(message) LWIP_PLATFORM_ASSERT(message) argument
142 #define LWIP_PLATFORM_ERROR(message) LWIP_PLATFORM_DIAG((message))
144 #define LWIP_PLATFORM_ERROR(message)
148 #define LWIP_ERROR_LOG0(message) diag_layer_msg_e0(0, message) argument
150 #define LWIP_ERROR_LOG0(message)
154 #define LWIP_ERROR(message, expression, handler) do { \ argument
156 LWIP_ERROR_LOG0(message); \
[all …]
/device/soc/hpmicro/sdk/hpm_sdk/drivers/src/
Dhpm_can_drv.c132 static void can_fill_tx_buffer(CAN_Type *base, const can_transmit_buf_t *message);
355 static void can_fill_tx_buffer(CAN_Type *base, const can_transmit_buf_t *message) in can_fill_tx_buffer() argument
357 base->TBUF[0] = message->buffer[0]; in can_fill_tx_buffer()
358 base->TBUF[1] = message->buffer[1]; in can_fill_tx_buffer()
360 uint32_t copy_words = can_get_data_words_from_dlc(message->dlc); in can_fill_tx_buffer()
362 base->TBUF[2U + i] = message->buffer[2U + i]; in can_fill_tx_buffer()
366 hpm_stat_t can_send_message_blocking(CAN_Type *base, const can_transmit_buf_t *message) in can_send_message_blocking() argument
372 if ((base == NULL) || (message == NULL)) { in can_send_message_blocking()
379 can_fill_tx_buffer(base, message); in can_send_message_blocking()
409 …m_stat_t can_send_high_priority_message_blocking(CAN_Type *base, const can_transmit_buf_t *message) in can_send_high_priority_message_blocking() argument
[all …]
/device/board/isoftstone/yangfan/common/mqtt/mqttclient_c/samples/freertos/
DMQTTEcho.c22 data->message->payloadlen, data->message->payload); in messageArrived()
61 MQTTMessage message; in prvMQTTEchoTask() local
64 message.qos = 1; in prvMQTTEchoTask()
65 message.retained = 0; in prvMQTTEchoTask()
66 message.payload = payload; in prvMQTTEchoTask()
68 message.payloadlen = strlen(payload); in prvMQTTEchoTask()
70 if ((rc = MQTTPublish(&client, "FreeRTOS/sample/a", &message)) != 0) in prvMQTTEchoTask()
/device/soc/esp/esp32/components/hal/include/hal/
Dtwai_hal.h237 static inline void twai_hal_format_frame(const twai_message_t *message, twai_hal_frame_t *frame) in twai_hal_format_frame() argument
240 twai_ll_format_frame_buffer(message->identifier, message->data_length_code, message->data, in twai_hal_format_frame()
241 message->flags, frame); in twai_hal_format_frame()
253 static inline void twai_hal_parse_frame(twai_hal_frame_t *frame, twai_message_t *message) in twai_hal_parse_frame() argument
256 twai_ll_prase_frame_buffer(frame, &message->identifier, &message->data_length_code, in twai_hal_parse_frame()
257 message->data, &message->flags); in twai_hal_parse_frame()
/device/board/bearpi/bearpi_hm_nano/app/D5_iot_mqtt/
Diot_mqtt.c46 data->topicName->lenstring.data, data->message->payloadlen, data->message->payload); in messageArrived()
89 MQTTMessage message; in MQTTDemoTask() local
92 message.qos = MQTT_QOS; in MQTTDemoTask()
93 message.retained = 0; in MQTTDemoTask()
94 message.payload = payload; in MQTTDemoTask()
96 message.payloadlen = strlen(payload); in MQTTDemoTask()
98 if ((rc = MQTTPublish(&client, "pubtopic", &message)) != 0) { in MQTTDemoTask()
/device/soc/esp/esp32/components/esp_lwip/port/include/arch/
Dcc.h86 #define LWIP_PLATFORM_ASSERT(message) abort() argument
89 #define LWIP_PLATFORM_ASSERT(message) __assert_func(__FILE__, __LINE__, __ASSERT_FUNC, message) argument
96 #define LWIP_ERROR(message, expression, handler) do { if (!(expression)) { \ argument
97 puts(message); handler;}} while(0)
100 #define LWIP_ERROR(message, expression, handler) do { if (!(expression)) { \ argument
/device/soc/rockchip/common/kernel/drivers/gpu/arm/midgard/tests/include/kutf/
Dkutf_suite.h372 const char *message,
427 void kutf_test_skip_msg(struct kutf_context *context, const char *message);
439 void kutf_test_pass(struct kutf_context *context, char const *message);
451 void kutf_test_debug(struct kutf_context *context, char const *message);
463 void kutf_test_info(struct kutf_context *context, char const *message);
475 void kutf_test_warn(struct kutf_context *context, char const *message);
487 void kutf_test_fail(struct kutf_context *context, char const *message);
499 void kutf_test_fatal(struct kutf_context *context, char const *message);
/device/soc/telink/b91/b91_ble_sdk/common/
Dassert.h54 #define TODO(x) COMPILE_MESSAGE(message("--TODO-- " #x))
56 #define TODO(x) __pragma(message("--TODO-- "_STRINGIFY(x) " ::function: " __FUNCTION__ "@" STRINGIF…
64 #define WARN(x) COMPILE_MESSAGE(message("--WARN-- " #x))
66 #define WARN(x) __pragma(message("--WARN-- "_STRINGIFY(x) " ::function: " __FUNCTION__ "@" STRINGIF…
74 #define NOTE(x) COMPILE_MESSAGE(message("--NOTE-- " #x))
76 #define NOTE(x) __pragma(message("--NOTE-- "_STRINGIFY(x) " ::function: " __FUNCTION__ "@" STRINGIF…
/device/soc/rockchip/common/kernel/drivers/gpu/arm/bifrost/tests/include/kutf/
Dkutf_suite.h434 const char *message,
489 void kutf_test_skip_msg(struct kutf_context *context, const char *message);
501 void kutf_test_pass(struct kutf_context *context, char const *message);
513 void kutf_test_debug(struct kutf_context *context, char const *message);
525 void kutf_test_info(struct kutf_context *context, char const *message);
537 void kutf_test_warn(struct kutf_context *context, char const *message);
549 void kutf_test_fail(struct kutf_context *context, char const *message);
561 void kutf_test_fatal(struct kutf_context *context, char const *message);
/device/soc/rockchip/common/kernel/drivers/gpu/arm/midgard/tests/kutf/
Dkutf_suite.c359 if (res->message) in kutf_debugfs_run_read()
360 message_len = strlen(res->message); in kutf_debugfs_run_read()
384 if (res->message) { in kutf_debugfs_run_read()
386 res->message, message_len); in kutf_debugfs_run_read()
866 const char *message, in kutf_test_log_result() argument
874 new_status, message); in kutf_test_log_result()
879 const char *message, in kutf_test_log_result_external() argument
882 kutf_test_log_result(context, message, new_status); in kutf_test_log_result_external()
925 void kutf_test_skip_msg(struct kutf_context *context, const char *message) in kutf_test_skip_msg() argument
931 "Test skipped: %s", message), KUTF_RESULT_SKIP); in kutf_test_skip_msg()
[all …]
Dkutf_resultset.c55 const char *message) in kutf_add_result() argument
70 new_result->message = message; in kutf_add_result()
/device/soc/rockchip/common/kernel/drivers/gpu/arm/bifrost/tests/kutf/
Dkutf_suite.c424 message_len = strlen(res->message); in kutf_debugfs_run_read()
429 bytes_not_copied = copy_to_user(buf, res->message, in kutf_debugfs_run_read()
453 if (res->message) in kutf_debugfs_run_read()
454 message_len = strlen(res->message); in kutf_debugfs_run_read()
478 if (res->message) { in kutf_debugfs_run_read()
480 res->message, message_len); in kutf_debugfs_run_read()
1045 const char *message, in kutf_test_log_result() argument
1052 kutf_add_result(context, new_status, message); in kutf_test_log_result()
1057 const char *message, in kutf_test_log_result_external() argument
1060 kutf_test_log_result(context, message, new_status); in kutf_test_log_result_external()
[all …]
/device/board/isoftstone/yangfan/common/mqtt/mqttclient_c/src/
DMQTTClient.c26 md->message = aMessage; in NewMessageData()
214 int deliverMessage(MQTTClient* c, MQTTString* topicName, MQTTMessage* message) in deliverMessage() argument
227 NewMessageData(&md, topicName, message); in deliverMessage()
237 NewMessageData(&md, topicName, message); in deliverMessage()
735 int MQTTAsyncPublish(MQTTClient* c, const char* topicName, MQTTMessage* message) in MQTTAsyncPublish() argument
752 if (message->qos == QOS1 || message->qos == QOS2) in MQTTAsyncPublish()
753 message->id = getNextPacketId(c); in MQTTAsyncPublish()
755 … len = MQTTSerialize_publish(c->buf, c->buf_size, 0, message->qos, message->retained, message->id, in MQTTAsyncPublish()
756 topic, (unsigned char*)message->payload, message->payloadlen); in MQTTAsyncPublish()
775 int MQTTPublish(MQTTClient* c, const char* topicName, MQTTMessage* message) in MQTTPublish() argument
[all …]
/device/soc/winnermicro/wm800/board/platform/drivers/spi/
Dwm_hostspi.c60 int tls_spi_async(struct tls_spi_message *message);
61 int tls_spi_sync(struct tls_spi_message *message);
748 struct tls_spi_message message; in tls_spi_read_with_cmd() local
779 spi_message_init(&message); in tls_spi_read_with_cmd()
785 dl_list_add_tail(&message.transfers, &x[0].transfer_list); in tls_spi_read_with_cmd()
790 dl_list_add_tail(&message.transfers, &x[1].transfer_list); in tls_spi_read_with_cmd()
794 status = tls_spi_sync(&message); in tls_spi_read_with_cmd()
983 struct tls_spi_message message; in tls_spi_write_with_cmd() local
1012 spi_message_init(&message); in tls_spi_write_with_cmd()
1018 dl_list_add_tail(&message.transfers, &x[0].transfer_list); in tls_spi_write_with_cmd()
[all …]
/device/board/isoftstone/yangfan/common/mqtt/mqttclient_c/samples/linux/
Dstdoutsub.c183 MQTTMessage* message = md->message; in messageArrived() local
188 printf("%.*s", (int)message->payloadlen, (char*)message->payload); in messageArrived()
190 printf("%.*s%s", (int)message->payloadlen, (char*)message->payload, opts.delimiter); in messageArrived()
/device/soc/esp/esp32/components/driver/include/driver/
Dcan.h63 #define can_transmit(message, ticks_to_wait) twai_transmit(message, ticks_to_wai… argument
64 #define can_receive(message, ticks_to_wait) twai_receive(message, ticks_to_wait) argument
/device/soc/rockchip/common/vendor/drivers/gpu/arm/bifrost/
Dmali_linux_trace.h273 TRACE_EVENT(sysgraph, TP_PROTO(enum sysgraph_msg message, unsigned int proc_id, unsigned int atom_i…
274 TP_ARGS(message, proc_id, atom_id),
275 TP_STRUCT__entry(__field(unsigned int, proc_id) __field(enum sysgraph_msg, message)
277 …TP_fast_assign(__entry->proc_id = proc_id; __entry->message = message; __entry->atom_id = atom_id;…
278 …TP_printk("msg=%u proc_id=%u, param1=%d\n", __entry->message, __entry->proc_id, __entry->atom_id));
287 … TP_PROTO(enum sysgraph_msg message, unsigned int proc_id, unsigned int atom_id, unsigned int js),
288 TP_ARGS(message, proc_id, atom_id, js),
289 TP_STRUCT__entry(__field(unsigned int, proc_id) __field(enum sysgraph_msg, message)
291 … TP_fast_assign(__entry->proc_id = proc_id; __entry->message = message; __entry->atom_id = atom_id;
293 …TP_printk("msg=%u proc_id=%u, param1=%d, param2=%d\n", __entry->message, __entry->proc_id, __entry…
/device/soc/rockchip/common/kernel/drivers/gpu/arm/bifrost/
Dmali_linux_trace.h406 TP_PROTO(enum sysgraph_msg message, unsigned int proc_id,
408 TP_ARGS(message, proc_id, atom_id),
411 __field(enum sysgraph_msg, message)
416 __entry->message = message;
419 TP_printk("msg=%u proc_id=%u, param1=%d", __entry->message,
430 TP_PROTO(enum sysgraph_msg message, unsigned int proc_id,
432 TP_ARGS(message, proc_id, atom_id, js),
435 __field(enum sysgraph_msg, message)
441 __entry->message = message;
446 __entry->message, __entry->proc_id,
/device/soc/esp/esp32/components/hal/esp32/include/hal/
Dcan_hal.h117 static inline void can_hal_format_frame(const can_message_t *message, can_hal_frame_t *frame) in can_hal_format_frame() argument
119 twai_hal_format_frame(message, frame); in can_hal_format_frame()
122 static inline void can_hal_parse_frame(can_hal_frame_t *frame, can_message_t *message) in can_hal_parse_frame() argument
124 twai_hal_parse_frame(frame, message); in can_hal_parse_frame()
/device/board/bearpi/bearpi_hm_nano/app/D6_iot_cloud_oc/src/
Doc_mqtt.c84 …oc_mqtt.cmd_rsp_cb((uint8_t *)msg_data->message->payload, msg_data->message->payloadlen, &response… in mqtt_callback()
196 MQTTMessage message; in oc_mqtt_publish() local
201 message.qos = qos; in oc_mqtt_publish()
202 message.retained = 0; in oc_mqtt_publish()
203 message.payload = (void *)msg; in oc_mqtt_publish()
204 message.payloadlen = msg_len; in oc_mqtt_publish()
206 if (MQTTPublish(&mq_client, topic, &message) < 0) { in oc_mqtt_publish()
/device/soc/hisilicon/hi3861v100/sdk_liteos/third_party/paho.mqtt.c/include/mqtt/
DMQTTAsync.h348 …MQTTAsync_messageArrived(void* context, char* topicName, int topicLen, MQTTAsync_message* message);
437 const char *message; member
457 const char *message; member
479 MQTTAsync_message message; member
514 MQTTAsync_message message; /**< the message being sent to the server */ member
870 const char* message; member
1511 typedef void MQTTAsync_traceCallback(enum MQTTASYNC_TRACE_LEVELS level, char* message);

1234567