Home
last modified time | relevance | path

Searched refs:topic_len (Results 1 – 25 of 66) sorted by relevance

123

/dports/net/mosquitto/mosquitto-2.0.13/src/
H A Dcontrol.c82 size_t topic_len; in control__register_callback() local
85 topic_len = strlen(topic); in control__register_callback()
86 if(topic_len == 0 || topic_len > 65535) return MOSQ_ERR_INVAL; in control__register_callback()
91 HASH_FIND(hh, opts->plugin_callbacks.control, topic, topic_len, cb_found); in control__register_callback()
119 size_t topic_len; in control__unregister_callback() local
122 topic_len = strlen(topic); in control__unregister_callback()
123 if(topic_len == 0 || topic_len > 65535) return MOSQ_ERR_INVAL; in control__unregister_callback()
126 HASH_FIND(hh, opts->plugin_callbacks.control, topic, topic_len, cb_found); in control__unregister_callback()
H A Dpersist_write_v5.c142 uint16_t topic_len = chunk->F.topic_len; in persist__chunk_message_store_write_v6() local
156 chunk->F.topic_len = htons(chunk->F.topic_len); in persist__chunk_message_store_write_v6()
161 topic_len + payloadlen + in persist__chunk_message_store_write_v6()
172 write_e(db_fptr, chunk->topic, topic_len); in persist__chunk_message_store_write_v6()
224 uint16_t topic_len = chunk->F.topic_len; in persist__chunk_sub_write_v6() local
228 chunk->F.topic_len = htons(chunk->F.topic_len); in persist__chunk_sub_write_v6()
232 id_len + topic_len); in persist__chunk_sub_write_v6()
237 write_e(db_fptr, chunk->topic, topic_len); in persist__chunk_sub_write_v6()
H A Dpersist_read_v5.c166 chunk->F.topic_len = ntohs(chunk->F.topic_len); in persist__chunk_msg_store_read_v56()
169 … chunk->F.payloadlen + chunk->F.source_id_len + chunk->F.source_username_len + chunk->F.topic_len); in persist__chunk_msg_store_read_v56()
185 rc = persist__read_string_len(db_fptr, &chunk->topic, chunk->F.topic_len); in persist__chunk_msg_store_read_v56()
260 chunk->F.topic_len = ntohs(chunk->F.topic_len); in persist__chunk_sub_read_v56()
266 rc = persist__read_string_len(db_fptr, &chunk->topic, chunk->F.topic_len); in persist__chunk_sub_read_v56()
H A Dretain.c44 child->topic_len = len; in retain__add_hier_entry()
47 child->topic_len = 0; in retain__add_hier_entry()
52 strncpy(child->topic, topic, (size_t)child->topic_len+1); in retain__add_hier_entry()
55 HASH_ADD_KEYPTR(hh, *sibling, child->topic, child->topic_len, child); in retain__add_hier_entry()
/dports/www/domoticz/domoticz-2020.2/extern/mosquitto/src/
H A Dpersist_write_v5.c132 uint16_t topic_len = chunk->F.topic_len; in persist__chunk_message_store_write_v5() local
147 chunk->F.topic_len = htons(chunk->F.topic_len); in persist__chunk_message_store_write_v5()
152 topic_len + payloadlen + in persist__chunk_message_store_write_v5()
163 write_e(db_fptr, chunk->topic, topic_len); in persist__chunk_message_store_write_v5()
212 uint16_t topic_len = chunk->F.topic_len; in persist__chunk_sub_write_v5() local
216 chunk->F.topic_len = htons(chunk->F.topic_len); in persist__chunk_sub_write_v5()
220 id_len + topic_len); in persist__chunk_sub_write_v5()
225 write_e(db_fptr, chunk->topic, topic_len); in persist__chunk_sub_write_v5()
H A Dpersist_read_v5.c144 chunk->F.topic_len = ntohs(chunk->F.topic_len); in persist__chunk_msg_store_read_v5()
147 … chunk->F.payloadlen + chunk->F.source_id_len + chunk->F.source_username_len + chunk->F.topic_len); in persist__chunk_msg_store_read_v5()
163 rc = persist__read_string_len(db_fptr, &chunk->topic, chunk->F.topic_len); in persist__chunk_msg_store_read_v5()
235 chunk->F.topic_len = ntohs(chunk->F.topic_len); in persist__chunk_sub_read_v5()
241 rc = persist__read_string_len(db_fptr, &chunk->topic, chunk->F.topic_len); in persist__chunk_sub_read_v5()
H A Dsubs.c64 uint16_t topic_len; member
198 new_topic->topic_len = strlen(topic); in sub__topic_append()
199 new_topic->topic = mosquitto__malloc(new_topic->topic_len+1); in sub__topic_append()
204 strncpy(new_topic->topic, topic, new_topic->topic_len+1); in sub__topic_append()
692 child->topic_len = len; in sub__add_hier_entry()
695 child->topic_len = 0; in sub__add_hier_entry()
700 strncpy(child->topic, topic, child->topic_len+1); in sub__add_hier_entry()
740 tokens->topic_len = 0; in sub__add()
743 HASH_FIND(hh, *root, tokens->topic, tokens->topic_len, subhier); in sub__add()
790 tokens->topic_len = 0; in sub__remove()
[all …]
/dports/misc/vifm/vifm-0.11/src/menus/
H A Dapropos_menu.c42 size_t section_len, char topic[], size_t topic_len);
102 char topic[], size_t topic_len) in parse_apropos_line() argument
126 topic_len == 0 || topic_len - 1 < (size_t)(sep - line)) in parse_apropos_line()
/dports/sysutils/fluent-bit/fluent-bit-1.8.11/plugins/in_mqtt/
H A Dmqtt_prot.c129 static int mqtt_data_append(char *topic, size_t topic_len,
178 msgpack_pack_str(&mp_pck, topic_len);
179 msgpack_pack_str_body(&mp_pck, topic, topic_len);
228 int topic_len;
257 topic_len = hlen;
281 mqtt_data_append((char *) (conn->buf + topic), topic_len,
/dports/japanese/libslang/slang-1.4.5jp2/src/
H A Dslstd.c366 unsigned int topic_len, str_len; in get_doc_string() local
381 topic_len = strlen (topic); in get_doc_string()
400 && (0 == strncmp (p, topic, topic_len)) in get_doc_string()
401 && ((p[topic_len] == '\n') || (p [topic_len] == 0) in get_doc_string()
402 || (p[topic_len] == ' ') || (p[topic_len] == '\t'))) in get_doc_string()
/dports/net/wireshark-lite/wireshark-3.6.1/epan/dissectors/
H A Dpacket-kafka.c2305 int topic_start, topic_len; in dissect_kafka_offset_fetch_request_topic() local
2450 int topic_start, topic_len; in dissect_kafka_offset_fetch_response_topic() local
2770 int topic_start, topic_len; in dissect_kafka_leader_and_isr_request_partition_state() local
2868 int topic_start, topic_len; in dissect_kafka_leader_and_isr_request_topic_state() local
2982 int topic_start, topic_len; in dissect_kafka_leader_and_isr_response_partition() local
3041 int topic_start, topic_len; in dissect_kafka_stop_replica_request_topic() local
3075 int topic_start, topic_len; in dissect_kafka_stop_replica_request_ungrouped_partition() local
3160 int topic_start, topic_len; in dissect_kafka_stop_replica_response_partition() local
3506 int topic_off, topic_len; in dissect_kafka_produce_request_topic() local
3894 int topic_start, topic_len; in dissect_kafka_update_metadata_request_partition() local
[all …]
H A Dpacket-lbmsrs.c1171 if ((total_payload_len - offset) < topic_len) in dissect_lbmsrs_sir_ser()
1180 offset += topic_len; in dissect_lbmsrs_sir_ser()
1414 if ((total_payload_len - offset) < topic_len) in dissect_lbmsrs_sdr()
1423 offset += topic_len; in dissect_lbmsrs_sdr()
1466 if ((total_payload_len - offset) < topic_len) in dissect_lbmsrs_rir()
1475 offset += topic_len; in dissect_lbmsrs_rir()
1572 if ((total_payload_len - offset) < topic_len) in dissect_lbmsrs_rer()
1581 offset += topic_len; in dissect_lbmsrs_rer()
1679 if ((total_payload_len - offset) < topic_len) in dissect_lbmsrs_rdr()
1688 offset += topic_len; in dissect_lbmsrs_rdr()
[all …]
/dports/net/wireshark/wireshark-3.6.1/epan/dissectors/
H A Dpacket-kafka.c2305 int topic_start, topic_len; in dissect_kafka_offset_fetch_request_topic() local
2450 int topic_start, topic_len; in dissect_kafka_offset_fetch_response_topic() local
2770 int topic_start, topic_len; in dissect_kafka_leader_and_isr_request_partition_state() local
2868 int topic_start, topic_len; in dissect_kafka_leader_and_isr_request_topic_state() local
2982 int topic_start, topic_len; in dissect_kafka_leader_and_isr_response_partition() local
3041 int topic_start, topic_len; in dissect_kafka_stop_replica_request_topic() local
3075 int topic_start, topic_len; in dissect_kafka_stop_replica_request_ungrouped_partition() local
3160 int topic_start, topic_len; in dissect_kafka_stop_replica_response_partition() local
3506 int topic_off, topic_len; in dissect_kafka_produce_request_topic() local
3894 int topic_start, topic_len; in dissect_kafka_update_metadata_request_partition() local
[all …]
H A Dpacket-lbmsrs.c1171 if ((total_payload_len - offset) < topic_len) in dissect_lbmsrs_sir_ser()
1180 offset += topic_len; in dissect_lbmsrs_sir_ser()
1414 if ((total_payload_len - offset) < topic_len) in dissect_lbmsrs_sdr()
1423 offset += topic_len; in dissect_lbmsrs_sdr()
1466 if ((total_payload_len - offset) < topic_len) in dissect_lbmsrs_rir()
1475 offset += topic_len; in dissect_lbmsrs_rir()
1572 if ((total_payload_len - offset) < topic_len) in dissect_lbmsrs_rer()
1581 offset += topic_len; in dissect_lbmsrs_rer()
1679 if ((total_payload_len - offset) < topic_len) in dissect_lbmsrs_rdr()
1688 offset += topic_len; in dissect_lbmsrs_rdr()
[all …]
/dports/net/tshark-lite/wireshark-3.6.1/epan/dissectors/
H A Dpacket-kafka.c2305 int topic_start, topic_len;
2450 int topic_start, topic_len;
2770 int topic_start, topic_len;
2868 int topic_start, topic_len;
2982 int topic_start, topic_len;
3041 int topic_start, topic_len;
3075 int topic_start, topic_len;
3160 int topic_start, topic_len;
3506 int topic_off, topic_len;
3894 int topic_start, topic_len;
[all …]
H A Dpacket-lbmsrs.c1171 if ((total_payload_len - offset) < topic_len)
1180 offset += topic_len;
1414 if ((total_payload_len - offset) < topic_len)
1423 offset += topic_len;
1466 if ((total_payload_len - offset) < topic_len)
1475 offset += topic_len;
1572 if ((total_payload_len - offset) < topic_len)
1581 offset += topic_len;
1679 if ((total_payload_len - offset) < topic_len)
1688 offset += topic_len;
[all …]
/dports/net/tshark/wireshark-3.6.1/epan/dissectors/
H A Dpacket-kafka.c2305 int topic_start, topic_len; in dissect_kafka_offset_fetch_request_topic() local
2450 int topic_start, topic_len; in dissect_kafka_offset_fetch_response_topic() local
2770 int topic_start, topic_len; in dissect_kafka_leader_and_isr_request_partition_state() local
2868 int topic_start, topic_len; in dissect_kafka_leader_and_isr_request_topic_state() local
2982 int topic_start, topic_len; in dissect_kafka_leader_and_isr_response_partition() local
3041 int topic_start, topic_len; in dissect_kafka_stop_replica_request_topic() local
3075 int topic_start, topic_len; in dissect_kafka_stop_replica_request_ungrouped_partition() local
3160 int topic_start, topic_len; in dissect_kafka_stop_replica_response_partition() local
3506 int topic_off, topic_len; in dissect_kafka_produce_request_topic() local
3894 int topic_start, topic_len; in dissect_kafka_update_metadata_request_partition() local
[all …]
H A Dpacket-lbmsrs.c1171 if ((total_payload_len - offset) < topic_len)
1180 offset += topic_len;
1414 if ((total_payload_len - offset) < topic_len)
1423 offset += topic_len;
1466 if ((total_payload_len - offset) < topic_len)
1475 offset += topic_len;
1572 if ((total_payload_len - offset) < topic_len)
1581 offset += topic_len;
1679 if ((total_payload_len - offset) < topic_len)
1688 offset += topic_len;
[all …]
/dports/net/kamailio/kamailio-5.4.5/src/modules/kafka/
H A Dkfk.c966 int topic_len = strlen(topic); in kfk_stats_topic_new() local
967 if (topic_len == 0) { in kfk_stats_topic_new()
986 st->topic_name->s = shm_malloc(topic_len + 1); in kfk_stats_topic_new()
991 memcpy(st->topic_name->s, topic, topic_len); in kfk_stats_topic_new()
992 st->topic_name->s[topic_len] = '\0'; in kfk_stats_topic_new()
993 st->topic_name->len = topic_len; in kfk_stats_topic_new()
1025 int topic_len = strlen(topic); in kfk_stats_add() local
1042 if ((*stats_pre)->topic_name->len == topic_len && in kfk_stats_add()
/dports/net/pecl-rdkafka/rdkafka-4.0.4/
H A Dtopic_partition.c204 arglen_t topic_len; in ZEND_END_ARG_INFO() local
211 …if (zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "sl|l", &topic, &topic_len, &partition, &offs… in ZEND_END_ARG_INFO()
259 arglen_t topic_len; in ZEND_END_ARG_INFO() local
262 if (zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "s", &topic, &topic_len) == FAILURE) { in ZEND_END_ARG_INFO()
/dports/net/libwebsockets/libwebsockets-v4.2.2/lib/roles/mqtt/
H A Dmqtt.c719 pub->topic_len = (uint16_t)par->n; in _lws_mqtt_rx_parser()
722 pub->topic = (char *)lws_zalloc((size_t)pub->topic_len + 1, in _lws_mqtt_rx_parser()
727 (size_t)pub->topic_len + 1); in _lws_mqtt_rx_parser()
728 buf += pub->topic_len; in _lws_mqtt_rx_parser()
729 len -= pub->topic_len; in _lws_mqtt_rx_parser()
738 (unsigned int)(2 + pub->topic_len + ((pub->qos) ? 2 : 0)); in _lws_mqtt_rx_parser()
778 (unsigned int)(2 + pub->topic_len + ((pub->qos) ? 2 : 0)); in _lws_mqtt_rx_parser()
1782 vh_len = (unsigned int)(2 + pub->topic_len + ((pub->qos) ? 2 : 0)); in lws_mqtt_client_send_publish()
1796 lws_ser_wu16be(p, pub->topic_len); in lws_mqtt_client_send_publish()
1809 lws_strncpy((char *)p, pub->topic, (size_t)pub->topic_len+1); in lws_mqtt_client_send_publish()
[all …]
/dports/net/proby/proby-1.0.2/cargo-crates/curl-sys-0.4.34+curl-7.71.1/curl/tests/server/
H A Dmqttd.c484 unsigned int topic_len; in mqttit() local
570 topic_len = (buffer[2] << 8) | buffer[3]; in mqttit()
571 if(topic_len != (remaining_length - 5)) { in mqttit()
573 topic_len, remaining_length - 5); in mqttit()
576 memcpy(topic, &buffer[4], topic_len); in mqttit()
577 topic[topic_len] = 0; in mqttit()
/dports/devel/cargo-generate/cargo-generate-0.9.0/cargo-crates/curl-sys-0.4.41+curl-7.75.0/curl/tests/server/
H A Dmqttd.c484 unsigned int topic_len; in mqttit() local
570 topic_len = (buffer[2] << 8) | buffer[3]; in mqttit()
571 if(topic_len != (remaining_length - 5)) { in mqttit()
573 topic_len, remaining_length - 5); in mqttit()
576 memcpy(topic, &buffer[4], topic_len); in mqttit()
577 topic[topic_len] = 0; in mqttit()
/dports/www/newsboat/newsboat-2.22.1/cargo-crates/curl-sys-0.4.39+curl-7.74.0/curl/tests/server/
H A Dmqttd.c484 unsigned int topic_len; in mqttit() local
570 topic_len = (buffer[2] << 8) | buffer[3]; in mqttit()
571 if(topic_len != (remaining_length - 5)) { in mqttit()
573 topic_len, remaining_length - 5); in mqttit()
576 memcpy(topic, &buffer[4], topic_len); in mqttit()
577 topic[topic_len] = 0; in mqttit()
/dports/net/elixir-kafka_ex/kafka_ex-0.10.0/lib/kafka_ex/protocol/
H A Dmetadata.ex273 <<error_code::16-signed, topic_len::16-signed,
274 topic::size(topic_len)-binary, partition_metadatas_size::32-signed,
296 topic_len::16-signed,
297 topic::size(topic_len)-binary,

123