/dports/net/mosquitto/mosquitto-2.0.13/src/ |
H A D | control.c | 82 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 D | persist_write_v5.c | 142 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 D | persist_read_v5.c | 166 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 D | retain.c | 44 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 D | persist_write_v5.c | 132 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 D | persist_read_v5.c | 144 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 D | subs.c | 64 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 D | apropos_menu.c | 42 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 D | mqtt_prot.c | 129 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 D | slstd.c | 366 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 D | packet-kafka.c | 2305 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 D | packet-lbmsrs.c | 1171 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 D | packet-kafka.c | 2305 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 D | packet-lbmsrs.c | 1171 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 D | packet-kafka.c | 2305 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 D | packet-lbmsrs.c | 1171 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 D | packet-kafka.c | 2305 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 D | packet-lbmsrs.c | 1171 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 D | kfk.c | 966 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 D | topic_partition.c | 204 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 D | mqtt.c | 719 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 D | mqttd.c | 484 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 D | mqttd.c | 484 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 D | mqttd.c | 484 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 D | metadata.ex | 273 <<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,
|