Searched refs:rd_headers (Results 1 – 2 of 2) sorted by relevance
1023 static int py_header_to_c (rd_kafka_headers_t *rd_headers, in py_header_to_c() argument1097 rd_kafka_headers_t *rd_headers = NULL; in py_headers_list_to_c() local1100 rd_headers = rd_kafka_headers_new(len); in py_headers_list_to_c()1106 rd_kafka_headers_destroy(rd_headers); in py_headers_list_to_c()1113 if (!py_header_to_c(rd_headers, in py_headers_list_to_c()1116 rd_kafka_headers_destroy(rd_headers); in py_headers_list_to_c()1120 return rd_headers; in py_headers_list_to_c()1130 rd_kafka_headers_t *rd_headers = NULL; in py_headers_dict_to_c() local1134 rd_headers = rd_kafka_headers_new(len); in py_headers_dict_to_c()1138 if (!py_header_to_c(rd_headers, ko, vo)) { in py_headers_dict_to_c()[all …]
238 rd_kafka_headers_t *rd_headers = NULL; in Producer_produce() local284 if(!(rd_headers = py_headers_to_c(headers))) in Producer_produce()307 ,rd_headers in Producer_produce()