Searched refs:orig_offsets (Results 1 – 5 of 5) sorted by relevance
| /dports/net/librdkafka/librdkafka-1.8.2/tests/ |
| H A D | 0081-admin.c | 1642 rd_kafka_topic_partition_list_t *orig_offsets, *offsets, in do_test_DeleteConsumerGroupOffsets() local
1724 orig_offsets, topics[i/2], in do_test_DeleteConsumerGroupOffsets()
1734 if (test_partition_list_cmp(committed, orig_offsets)) { in do_test_DeleteConsumerGroupOffsets()
1736 test_print_partition_list(orig_offsets); in do_test_DeleteConsumerGroupOffsets()
1747 for (i = 0 ; i < orig_offsets->cnt ; i++) { in do_test_DeleteConsumerGroupOffsets()
1748 if (i < orig_offsets->cnt / 2) in do_test_DeleteConsumerGroupOffsets()
1751 orig_offsets->elems[i].topic, in do_test_DeleteConsumerGroupOffsets()
1756 orig_offsets->elems[i].topic, in do_test_DeleteConsumerGroupOffsets()
1760 orig_offsets->elems[i].topic, in do_test_DeleteConsumerGroupOffsets()
1857 test_print_partition_list(orig_offsets); in do_test_DeleteConsumerGroupOffsets()
[all …]
|
| /dports/sysutils/fluent-bit/fluent-bit-1.8.11/plugins/out_kafka/librdkafka-1.7.0/tests/ |
| H A D | 0081-admin.c | 1642 rd_kafka_topic_partition_list_t *orig_offsets, *offsets, in do_test_DeleteConsumerGroupOffsets() local
1724 orig_offsets, topics[i/2], in do_test_DeleteConsumerGroupOffsets()
1734 if (test_partition_list_cmp(committed, orig_offsets)) { in do_test_DeleteConsumerGroupOffsets()
1736 test_print_partition_list(orig_offsets); in do_test_DeleteConsumerGroupOffsets()
1747 for (i = 0 ; i < orig_offsets->cnt ; i++) { in do_test_DeleteConsumerGroupOffsets()
1748 if (i < orig_offsets->cnt / 2) in do_test_DeleteConsumerGroupOffsets()
1751 orig_offsets->elems[i].topic, in do_test_DeleteConsumerGroupOffsets()
1756 orig_offsets->elems[i].topic, in do_test_DeleteConsumerGroupOffsets()
1760 orig_offsets->elems[i].topic, in do_test_DeleteConsumerGroupOffsets()
1857 test_print_partition_list(orig_offsets); in do_test_DeleteConsumerGroupOffsets()
[all …]
|
| /dports/net/chrony/chrony-4.2/ |
| H A D | sourcestats.c | 164 double orig_offsets[MAX_SAMPLES]; member
316 inst->orig_offsets[m] = -sample->offset; in SST_AccumulateSample()
888 inst->offsets[i], inst->orig_offsets[j], in SST_SaveToFile()
920 &sample_time, &inst->offsets[i], &inst->orig_offsets[i], in SST_LoadFromFile()
961 report->orig_latest_meas = inst->orig_offsets[j]; in SST_DoSourceReport()
|
| /dports/net/chrony-lite/chrony-4.2/ |
| H A D | sourcestats.c | 164 double orig_offsets[MAX_SAMPLES]; member
316 inst->orig_offsets[m] = -sample->offset; in SST_AccumulateSample()
888 inst->offsets[i], inst->orig_offsets[j], in SST_SaveToFile()
920 &sample_time, &inst->offsets[i], &inst->orig_offsets[i], in SST_LoadFromFile()
961 report->orig_latest_meas = inst->orig_offsets[j]; in SST_DoSourceReport()
|
| /dports/net-p2p/vuze/vuze-5.7.4.0_2/com/aelitis/azureus/core/networkmanager/impl/http/ |
| H A D | HTTPNetworkConnection.java | 1017 private final long[] orig_offsets; field in HTTPNetworkConnection.httpRequest
1038 orig_offsets = _offsets; in httpRequest()
1052 mod_offsets = orig_offsets.clone(); in httpRequest()
1088 return( orig_offsets ); in getOriginalOffsets()
|