Home
last modified time | relevance | path

Searched refs:topic (Results 1 - 25 of 1343) sorted by relevance

12345678910>>...54

/kernel/linux/linux-6.6/tools/perf/pmu-events/
H A Dempty-pmu-events.c19 .topic = "cache",
26 .topic = "other",
32 .topic = "other",
38 .topic = "other",
44 .topic = "uncore",
52 .topic = "uncore",
60 .topic = "uncore",
68 .topic = "uncore",
76 .topic = "uncore",
84 .topic
[all...]
/vendor/hisilicon/hispark_pegasus/demo/iottencent_demo/
H A Diot_main.c63 const char *topic; member
78 /* Tencent iot cloud topic */
85 static int MsgRcvCallBack(char *context, char *topic, int topicLen, MQTTClient_message *message) in MsgRcvCallBack() argument
93 topiLen = strlen(topic); in MsgRcvCallBack()
103 (void)memcpy_s(buf, bufSize, topic, topiLen); in MsgRcvCallBack()
105 msg->topic = buf; in MsgRcvCallBack()
111 IOT_LOG_DEBUG("RCVMSG:QOS:%d TOPIC:%s PAYLOAD:%s\r\n", msg->qos, msg->topic, msg->payload); in MsgRcvCallBack()
119 MQTTClient_free(topic); in MsgRcvCallBack()
140 ret = MQTTClient_publishMessage(client, msg->topic, &pubMsg, &gIoTAppCb.tocken); in MqttProcessQueueMsg()
149 gIoTAppCb.msgCallBack(msg->qos, msg->topic, ms in MqttProcessQueueMsg()
282 IotSendMsg(int qos, const char *topic, const char *payload) IotSendMsg() argument
[all...]
H A Diot_main.h19 typedef void (*fnMsgCallBack)(int qos, const char *topic, const char *payload);
34 * @param topic: the iot mqtt topic
42 int IotSendMsg(int qos, const char *topic, const char *payload);
H A Diot_profile.c161 // < use this function to make a topic to publish
317 char *topic; in IoTProfilePropertyReport() local
323 topic = MakeTopic(CN_PROFILE_TOPICFMT_TOPIC, deviceID, NULL); in IoTProfilePropertyReport()
324 if (topic == NULL) { in IoTProfilePropertyReport()
328 if ((topic != NULL) && (msg != NULL)) { in IoTProfilePropertyReport()
329 ret = IotSendMsg(0, topic, msg); in IoTProfilePropertyReport()
332 hi_free(0, topic); in IoTProfilePropertyReport()
/vendor/hisilicon/hispark_pegasus/demo/mqtt_demo/
H A Diot_main.c63 const char *topic; member
78 /* Tencent iot cloud topic */
85 static int MsgRcvCallBack(char *context, char *topic, int topicLen, MQTTClient_message *message) in MsgRcvCallBack() argument
93 topiLen = strlen(topic); in MsgRcvCallBack()
103 (void)memcpy_s(buf, bufSize, topic, topiLen); in MsgRcvCallBack()
105 msg->topic = buf; in MsgRcvCallBack()
111 IOT_LOG_DEBUG("RCVMSG:QOS:%d TOPIC:%s PAYLOAD:%s\r\n", msg->qos, msg->topic, msg->payload); in MsgRcvCallBack()
119 MQTTClient_free(topic); in MsgRcvCallBack()
140 ret = MQTTClient_publishMessage(client, msg->topic, &pubMsg, &gIoTAppCb.tocken); in MqttProcessQueueMsg()
149 gIoTAppCb.msgCallBack(msg->qos, msg->topic, ms in MqttProcessQueueMsg()
282 IotSendMsg(int qos, const char *topic, const char *payload) IotSendMsg() argument
[all...]
H A Diot_main.h19 typedef void (*fnMsgCallBack)(int qos, const char *topic, const char *payload);
34 * @param topic: the iot mqtt topic
42 int IotSendMsg(int qos, const char *topic, const char *payload);
/vendor/hisilicon/hispark_pegasus/demo/coap_demo/
H A Diot_main.c59 const char *topic; member
84 static int MsgRcvCallBack(unsigned char *context, char *topic, int topicLen, MQTTClient_message *message) in MsgRcvCallBack() argument
93 topicLength = strlen(topic); in MsgRcvCallBack()
103 ret = memcpy_s(buf, bufSize, topic, topicLength); in MsgRcvCallBack()
108 msg->topic = buf; in MsgRcvCallBack()
117 IOT_LOG_DEBUG("RCVMSG:QOS:%d TOPIC:%s PAYLOAD:%s\r\n", msg->qos, msg->topic, msg->payload); in MsgRcvCallBack()
125 MQTTClient_free(topic); in MsgRcvCallBack()
145 ret = MQTTClient_publishMessage(client, msg->topic, &pubmsg, &g_ioTAppCb.tocken); in IoTMsgProcess()
154 g_ioTAppCb.msgCallBack(msg->qos, msg->topic, msg->payload); in IoTMsgProcess()
220 IOT_LOG_ERROR("Subscribe the default topic faile in MqttProcess()
314 IotSendMsg(int qos, const char *topic, const char *payload) IotSendMsg() argument
[all...]
H A Diot_profile.c160 // use this function to make a topic to publish
240 const char *topic; in IoTProfileCmdResp() local
247 topic = MakeTopic(CN_PROFILE_TOPICFMT_CMDRESP, deviceID, payload->requestID); in IoTProfileCmdResp()
248 if (topic == NULL) { in IoTProfileCmdResp()
252 if ((topic != NULL) && (msg != NULL)) { in IoTProfileCmdResp()
253 ret = IotSendMsg(0, topic, msg); in IoTProfileCmdResp()
256 hi_free(0, topic); in IoTProfileCmdResp()
292 char *topic; in IoTProfilePropertyReport() local
298 topic = MakeTopic(CN_PROFILE_TOPICFMT_PROPERTYREPORT, deviceID, NULL); in IoTProfilePropertyReport()
299 if (topic in IoTProfilePropertyReport()
[all...]
H A Dapp_demo_iot.c34 static void DemoMsgRcvCallBack(int qos, const char *topic, const char *payload) in DemoMsgRcvCallBack() argument
39 IOT_LOG_DEBUG("RCVMSG:QOS:%d TOPIC:%s PAYLOAD:%s\r\n", qos, topic, payload); in DemoMsgRcvCallBack()
41 tmp = strstr(topic, CN_COMMAND_INDEX); in DemoMsgRcvCallBack()
H A Diot_main.h19 typedef void (*FnMsgCallBack)(int qos, const char *topic, const char *payload);
37 * @param topic: the iot mqtt topic
43 int IotSendMsg(int qos, const char *topic, const char *payload);
/vendor/hisilicon/hispark_pegasus/demo/oc_demo/
H A Diot_main.c60 const char *topic; member
85 static int MsgRcvCallBack(unsigned char *context, char *topic, int topicLen, MQTTClient_message *message) in MsgRcvCallBack() argument
93 topicLength = strlen(topic); in MsgRcvCallBack()
103 (void)memcpy_s(buf, bufSize, topic, topicLength); in MsgRcvCallBack()
105 msg->topic = buf; in MsgRcvCallBack()
111 IOT_LOG_DEBUG("RCVMSG:QOS:%d TOPIC:%s PAYLOAD:%s\r\n", msg->qos, msg->topic, msg->payload); in MsgRcvCallBack()
119 MQTTClient_free(topic); in MsgRcvCallBack()
139 ret = MQTTClient_publishMessage(client, msg->topic, &pubmsg, &g_ioTAppCb.tocken); in IoTMsgProcess()
148 g_ioTAppCb.msgCallBack(msg->qos, msg->topic, msg->payload); in IoTMsgProcess()
213 IOT_LOG_ERROR("Subscribe the default topic faile in MqttProcess()
303 IotSendMsg(int qos, const char *topic, const char *payload) IotSendMsg() argument
[all...]
H A Diot_profile.c154 // use this function to make a topic to publish
240 const char *topic; in IoTProfileCmdResp() local
247 topic = MakeTopic(CN_PROFILE_TOPICFMT_CMDRESP, deviceID, payload->requestID); in IoTProfileCmdResp()
248 if (topic == NULL) { in IoTProfileCmdResp()
252 if ((topic != NULL) && (msg != NULL)) { in IoTProfileCmdResp()
253 ret = IotSendMsg(0, topic, msg); in IoTProfileCmdResp()
256 hi_free(0, topic); in IoTProfileCmdResp()
292 char *topic; in IoTProfilePropertyReport() local
298 topic = MakeTopic(CN_PROFILE_TOPICFMT_PROPERTYREPORT, deviceID, NULL); in IoTProfilePropertyReport()
299 if (topic in IoTProfilePropertyReport()
[all...]
H A Diot_main.h19 typedef void (*FnMsgCallBack)(int qos, const char *topic, const char *payload);
37 * @param topic: the iot mqtt topic
43 int IotSendMsg(int qos, const char *topic, const char *payload);
/third_party/libwebsockets/lib/secure-streams/protocols/
H A Dss-mqtt.c37 if (h->u.mqtt.sub_info.topic) { in secstream_mqtt_cleanup()
39 if (h->u.mqtt.sub_info.topic[i].name) { in secstream_mqtt_cleanup()
40 lws_free((void*)h->u.mqtt.sub_info.topic[i].name); in secstream_mqtt_cleanup()
41 h->u.mqtt.sub_info.topic[i].name = NULL; in secstream_mqtt_cleanup()
44 lws_free(h->u.mqtt.sub_info.topic); in secstream_mqtt_cleanup()
45 h->u.mqtt.sub_info.topic = NULL; in secstream_mqtt_cleanup()
81 " topic with no output\n", in secstream_mqtt_subscribe()
90 "topic", in secstream_mqtt_subscribe()
101 lwsl_err("%s, failed to expand MQTT subscribe topic\n", in secstream_mqtt_subscribe()
121 h->u.mqtt.sub_info.topic in secstream_mqtt_subscribe()
145 secstream_mqtt_publish(struct lws *wsi, uint8_t *buf, size_t buf_len, uint32_t payload_len, const char* topic, lws_mqtt_qos_levels_t qos, uint8_t retain, uint8_t dup, int f) secstream_mqtt_publish() argument
350 secstream_mqtt_is_shadow_matched(struct lws *wsi, const char *topic) secstream_mqtt_is_shadow_matched() argument
[all...]
/third_party/lwip/src/include/lwip/apps/
H A Dmqtt.h77 /** will topic, set to NULL if will is not to be used,
140 * arrives to a subscribed topic @see mqtt_subscribe
155 * arrives to a subscribed topic @see mqtt_subscribe
158 * @param topic Zero terminated Topic text string, topic may not be referenced after callback return
161 typedef void (*mqtt_incoming_publish_cb_t)(void *arg, const char *topic, u32_t tot_len);
189 err_t mqtt_sub_unsub(mqtt_client_t *client, const char *topic, u8_t qos, mqtt_request_cb_t cb, void *arg, u8_t sub);
192 *Subscribe to topic */
193 #define mqtt_subscribe(client, topic, qos, cb, arg) mqtt_sub_unsub(client, topic, qo
[all...]
/kernel/linux/linux-6.6/tools/perf/tests/
H A Dpmu-events.c51 .topic = "branch",
63 .topic = "branch",
75 .topic = "other",
87 .topic = "other",
99 .topic = "other",
112 .topic = "cache",
133 .topic = "uncore",
147 .topic = "uncore",
161 .topic = "uncore",
175 .topic
[all...]
/kernel/linux/linux-6.6/drivers/accel/habanalabs/common/
H A Dmemory_mgr.c165 behavior->topic, rc); in hl_mmap_mem_buf_alloc()
177 behavior->topic, rc); in hl_mmap_mem_buf_alloc()
257 buf->behavior->topic, user_mem_size, buf->mappable_size);
270 buf->behavior->topic, vma->vm_start);
279 buf->behavior->topic);
332 const char *topic; local
338 topic = buf->behavior->topic;
342 topic, id);
/kernel/linux/linux-5.10/tools/perf/tests/
H A Dpmu-events.c36 .topic = "branch",
46 .topic = "branch",
56 .topic = "other",
66 .topic = "other",
76 .topic = "other",
94 .topic = "uncore",
106 .topic = "uncore",
188 if (!is_same(table->topic, te->topic)) { in test_pmu_event_table()
189 pr_debug2("testing event table %s: mismatched topic, in test_pmu_event_table()
[all...]
/third_party/libwebsockets/lib/roles/mqtt/client/
H A Dclient-mqtt-handshake.c63 if (c->conn_flags & LMQCFT_WILL_FLAG && c->will.topic) { in lws_mqtt_client_send_connect()
64 len = len + (unsigned int)c->will.topic->len + 2; in lws_mqtt_client_send_connect()
85 * 4. Payload - Client ID, Will topic & message, in lws_mqtt_client_send_connect()
108 if (lws_mqtt_str_is_not_empty(c->will.topic)) { in lws_mqtt_client_send_connect()
109 lws_ser_wu16be(p, c->will.topic->len); in lws_mqtt_client_send_connect()
111 memcpy(p, c->will.topic->buf, c->will.topic->len); in lws_mqtt_client_send_connect()
112 p += c->will.topic->len; in lws_mqtt_client_send_connect()
H A Dclient-mqtt.c136 if (cp->will_param.topic && in lws_create_client_mqtt_object()
137 *cp->will_param.topic) { in lws_create_client_mqtt_object()
138 c->will.topic = lws_mqtt_str_create_cstr_dup( in lws_create_client_mqtt_object()
139 cp->will_param.topic, 0); in lws_create_client_mqtt_object()
140 if (!c->will.topic) in lws_create_client_mqtt_object()
178 lws_mqtt_str_free(&c->will.topic); in lws_create_client_mqtt_object()
/third_party/libwebsockets/lib/roles/mqtt/
H A Dmqtt.c274 lws_mqtt_validate_topic(const char *topic, size_t topiclen, uint8_t awsiot) in lws_mqtt_validate_topic() argument
277 const char *sub = topic; in lws_mqtt_validate_topic()
284 if (topic[0] == '$') { in lws_mqtt_validate_topic()
291 if (topic[0] == '$') in lws_mqtt_validate_topic()
297 /* topic == "+foo" || "a/+foo" ? */ in lws_mqtt_validate_topic()
301 /* topic == "foo+" or "foo+/a" ? */ in lws_mqtt_validate_topic()
307 /* topic == "foo#" ? */ in lws_mqtt_validate_topic()
311 /* topic == "#foo" ? */ in lws_mqtt_validate_topic()
330 lws_mqtt_create_sub(struct _lws_mqtt_related *mqtt, const char *topic) in lws_mqtt_create_sub() argument
333 size_t topiclen = strlen(topic); in lws_mqtt_create_sub()
[all...]
/kernel/linux/linux-5.10/tools/perf/util/
H A Dpmu.c264 perf_pmu_assign_str(old->name, "topic", &old->topic, &newalias->topic); in perf_pmu_update_alias()
282 zfree(&newalias->topic); in perf_pmu_free_alias()
310 char *long_desc, char *topic, in __perf_pmu__new_alias()
377 alias->topic = topic ? strdup(topic) : NULL; in __perf_pmu__new_alias()
780 (char *)pe->long_desc, (char *)pe->topic, in pmu_add_cpu_aliases_map()
1428 char *topic; member
308 __perf_pmu__new_alias(struct list_head *list, char *dir, char *name, char *desc, char *val, char *long_desc, char *topic, char *unit, char *perpkg, char *metric_expr, char *metric_name, char *deprecated) __perf_pmu__new_alias() argument
1495 char *topic = NULL; print_pmu_events() local
[all...]
/kernel/linux/linux-6.6/tools/perf/
H A Dbuiltin-list.c57 /** @last_topic: The last printed event topic. */
98 static void default_print_event(void *ps, const char *pmu_name, const char *topic, in default_print_event() argument
117 (!topic || !strglobmatch_nocase(topic, print_state->event_glob))) in default_print_event()
128 if (strcmp(print_state->last_topic, topic ?: "")) { in default_print_event()
129 if (topic) in default_print_event()
130 printf("\n%s:\n", topic); in default_print_event()
132 print_state->last_topic = strdup(topic ?: ""); in default_print_event()
140 if (!topic && event_type_desc) { in default_print_event()
324 static void json_print_event(void *ps, const char *pmu_name, const char *topic, in json_print_event() argument
[all...]
/kernel/linux/linux-6.6/tools/perf/util/
H A Dpfm.c179 char topic[80], name[80]; in print_libpfm_event() local
184 snprintf(topic, sizeof(topic), "pfm %s", pinfo->name); in print_libpfm_event()
223 print_cb->print_event(print_state, pinfo->name, topic, in print_libpfm_event()
258 topic, in print_libpfm_event()
/third_party/libwebsockets/minimal-examples/mqtt-client/minimal-mqtt-client/
H A Dminimal-mqtt-client.c24 STATE_SUBSCRIBE, /* subscribe to the topic */
48 .topic = "good/bye",
65 .topic = &topics[0],
216 pub_param.topic = "test/topic"; in callback_mqtt()
217 pub_param.topic_len = (uint16_t)strlen(pub_param.topic); in callback_mqtt()
287 lwsl_hexdump_notice(pub->topic, pub->topic_len); in callback_mqtt()

Completed in 13 milliseconds

12345678910>>...54