| /dports/net/py-kafka-python/kafka-python-1.4.5/kafka/ |
| H A D | context.py | 55 self.high_water_mark = None
70 max_offset = max(offset + 1, self.high_water_mark.get(partition, 0))
75 self.high_water_mark[partition] = max_offset
81 return bool(self.high_water_mark)
91 self.high_water_mark = dict()
122 if self.high_water_mark:
123 self.logger.info("Committing offsets: %s", self.high_water_mark)
124 self.commit_partition_offsets(self.high_water_mark)
125 self.update_consumer_offsets(self.high_water_mark)
|
| /dports/net-mgmt/nagios-plugins/nagios-plugins-2.3.3/plugins-scripts/ |
| H A D | check_file_age.pl | 39 … $output, @filelist, $filename, $safe_filename, $counter, $summary, $high_water_mark, $this_level,…
88 $high_water_mark = 0;
110 if ($high_water_mark < $this_level) {
111 $high_water_mark = $this_level;
115 elsif($high_water_mark = $this_level) {
145 if ($high_water_mark < $this_level) {
146 $high_water_mark = $this_level;
150 elsif ($high_water_mark == $this_level) {
|
| /dports/www/qt5-webengine/qtwebengine-everywhere-src-5.15.2/src/3rdparty/chromium/third_party/blink/renderer/core/streams/ |
| H A D | queuing_strategy_common.cc | 14 v8::Local<v8::Value> high_water_mark; in HighWaterMarkOrUndefined() local
16 high_water_mark = init->highWaterMark().V8Value(); in HighWaterMarkOrUndefined()
18 high_water_mark = v8::Undefined(script_state->GetIsolate()); in HighWaterMarkOrUndefined()
20 return high_water_mark; in HighWaterMarkOrUndefined()
|
| /dports/astro/astrometry/astrometry.net-0.85/util/ |
| H A D | dselip.c | 34 static int high_water_mark = 0; variable
38 if (n > high_water_mark) { in dselip()
41 high_water_mark = n; in dselip()
52 high_water_mark = 0; in dselip_cleanup()
|
| /dports/security/s2n/s2n-tls-1.1.2/tests/cbmc/proofs/s2n_stuffer_skip_write/ |
| H A D | s2n_stuffer_skip_write_harness.c | 42 …assert(stuffer->high_water_mark == MAX(old_stuffer.write_cursor + data_len, old_stuffer.high_water… in s2n_stuffer_skip_write_harness()
47 assert(stuffer->high_water_mark == old_stuffer.high_water_mark); in s2n_stuffer_skip_write_harness()
|
| /dports/security/s2n/s2n-tls-1.1.2/tests/cbmc/proofs/s2n_stuffer_raw_write/ |
| H A D | s2n_stuffer_raw_write_harness.c | 46 …assert(stuffer->high_water_mark == MAX(old_stuffer.write_cursor + data_len, old_stuffer.high_water… in s2n_stuffer_raw_write_harness()
52 assert(stuffer->high_water_mark == old_stuffer.high_water_mark); in s2n_stuffer_raw_write_harness()
|
| /dports/security/s2n/s2n-tls-1.1.2/tests/cbmc/proofs/s2n_stuffer_write_bytes/ |
| H A D | s2n_stuffer_write_bytes_harness.c | 51 …assert(stuffer->high_water_mark == MAX(old_stuffer.write_cursor + size, old_stuffer.high_water_mar… in s2n_stuffer_write_bytes_harness()
55 assert(stuffer->high_water_mark == old_stuffer.high_water_mark); in s2n_stuffer_write_bytes_harness()
|
| /dports/security/s2n/s2n-tls-1.1.2/tests/cbmc/proofs/s2n_stuffer_write/ |
| H A D | s2n_stuffer_write_harness.c | 56 …assert(stuffer->high_water_mark == MAX(old_stuffer.write_cursor + blob->size, old_stuffer.high_wat… in s2n_stuffer_write_harness()
60 assert(stuffer->high_water_mark == old_stuffer.high_water_mark); in s2n_stuffer_write_harness()
|
| /dports/databases/percona56-client/percona-server-5.6.51-91.0/sql/ |
| H A D | merge_sort.h | 71 for (Element_type **high_water_mark= first+1; in insert_sort() local
72 high_water_mark < last; in insert_sort()
73 high_water_mark++) in insert_sort()
75 for (Element_type **cur= high_water_mark; cur > first ; cur--) in insert_sort()
|
| /dports/databases/percona-pam-for-mysql/percona-server-5.6.51-91.0/sql/ |
| H A D | merge_sort.h | 71 for (Element_type **high_water_mark= first+1; in insert_sort() local
72 high_water_mark < last; in insert_sort()
73 high_water_mark++) in insert_sort()
75 for (Element_type **cur= high_water_mark; cur > first ; cur--) in insert_sort()
|
| /dports/databases/mysqlwsrep56-server/mysql-wsrep-wsrep_5.6.51-25.33/sql/ |
| H A D | merge_sort.h | 71 for (Element_type **high_water_mark= first+1; in insert_sort() local
72 high_water_mark < last; in insert_sort()
73 high_water_mark++) in insert_sort()
75 for (Element_type **cur= high_water_mark; cur > first ; cur--) in insert_sort()
|
| /dports/databases/percona56-server/percona-server-5.6.51-91.0/sql/ |
| H A D | merge_sort.h | 71 for (Element_type **high_water_mark= first+1; in insert_sort() local
72 high_water_mark < last; in insert_sort()
73 high_water_mark++) in insert_sort()
75 for (Element_type **cur= high_water_mark; cur > first ; cur--) in insert_sort()
|
| /dports/databases/mysql56-client/mysql-5.6.51/sql/ |
| H A D | merge_sort.h | 71 for (Element_type **high_water_mark= first+1; in insert_sort() local
72 high_water_mark < last; in insert_sort()
73 high_water_mark++) in insert_sort()
75 for (Element_type **cur= high_water_mark; cur > first ; cur--) in insert_sort()
|
| /dports/databases/xtrabackup8/percona-xtrabackup-8.0.14/sql/ |
| H A D | merge_sort.h | 71 for (Element_type **high_water_mark = first + 1; high_water_mark < last; in insert_sort() local
72 high_water_mark++) { in insert_sort()
73 for (Element_type **cur = high_water_mark; cur > first; cur--) { in insert_sort()
|
| /dports/databases/percona57-server/percona-server-5.7.36-39/sql/ |
| H A D | merge_sort.h | 71 for (Element_type **high_water_mark= first+1; in insert_sort() local
72 high_water_mark < last; in insert_sort()
73 high_water_mark++) in insert_sort()
75 for (Element_type **cur= high_water_mark; cur > first ; cur--) in insert_sort()
|
| /dports/databases/mysqlwsrep57-server/mysql-wsrep-wsrep_5.7.35-25.27/sql/ |
| H A D | merge_sort.h | 71 for (Element_type **high_water_mark= first+1; in insert_sort() local
72 high_water_mark < last; in insert_sort()
73 high_water_mark++) in insert_sort()
75 for (Element_type **cur= high_water_mark; cur > first ; cur--) in insert_sort()
|
| /dports/databases/percona57-client/percona-server-5.7.36-39/sql/ |
| H A D | merge_sort.h | 71 for (Element_type **high_water_mark= first+1; in insert_sort() local
72 high_water_mark < last; in insert_sort()
73 high_water_mark++) in insert_sort()
75 for (Element_type **cur= high_water_mark; cur > first ; cur--) in insert_sort()
|
| /dports/databases/mysql57-client/mysql-5.7.36/sql/ |
| H A D | merge_sort.h | 71 for (Element_type **high_water_mark= first+1; in insert_sort() local
72 high_water_mark < last; in insert_sort()
73 high_water_mark++) in insert_sort()
75 for (Element_type **cur= high_water_mark; cur > first ; cur--) in insert_sort()
|
| /dports/databases/percona57-pam-for-mysql/percona-server-5.7.36-39/sql/ |
| H A D | merge_sort.h | 71 for (Element_type **high_water_mark= first+1; in insert_sort() local
72 high_water_mark < last; in insert_sort()
73 high_water_mark++) in insert_sort()
75 for (Element_type **cur= high_water_mark; cur > first ; cur--) in insert_sort()
|
| /dports/databases/xtrabackup/percona-xtrabackup-2.4.21/sql/ |
| H A D | merge_sort.h | 71 for (Element_type **high_water_mark= first+1; in insert_sort() local
72 high_water_mark < last; in insert_sort()
73 high_water_mark++) in insert_sort()
75 for (Element_type **cur= high_water_mark; cur > first ; cur--) in insert_sort()
|
| /dports/devel/tla/tla-1.3.5/src/hackerlab/mem/ |
| H A D | alloc-limits.c | 66 size_t high_water_mark; member
179 answer->high_water_mark = 0; in make_alloc_limits()
311 return limits->high_water_mark; in lim_high_water_mark()
440 if (limits->in_use > limits->high_water_mark) in lim_soft_malloc()
441 limits->high_water_mark = limits->in_use; in lim_soft_malloc()
572 if (limits->in_use > limits->high_water_mark) in lim_soft_realloc()
573 limits->high_water_mark = limits->in_use; in lim_soft_realloc()
|
| /dports/devel/tla/tla-1.3.5/src/hackerlab/tests/rx-tests/ |
| H A D | unit-dfa-utf16.c | 206 size_t high_water_mark; in main() local
212 …rx_dfa_cache_statistics (&threshold, &failure_pt, &in_use, &high_water_mark, &dfa_hits, &dfa_misse… in main()
217 (unsigned long)high_water_mark, in main()
225 size_t high_water_mark; in main() local
230 …rx_nfa_cache_statistics (&threshold, &failure_pt, &in_use, &high_water_mark, &nfa_hits, &nfa_misse… in main()
235 (unsigned long)high_water_mark, in main()
|
| /dports/devel/tla/tla-1.3.5/src/hackerlab/tests/rx-xml-tests/ |
| H A D | test-time-re.c | 254 size_t high_water_mark; in main() local
260 …rx_dfa_cache_statistics (&threshold, &failure_pt, &in_use, &high_water_mark, &dfa_hits, &dfa_misse… in main()
265 (unsigned long)high_water_mark, in main()
273 size_t high_water_mark; in main() local
278 …rx_nfa_cache_statistics (&threshold, &failure_pt, &in_use, &high_water_mark, &nfa_hits, &nfa_misse… in main()
283 (unsigned long)high_water_mark, in main()
|
| /dports/comms/xcwcp/unixcw-3.5.1/src/libcw/ |
| H A D | libcw_tq.c | 130 … cw_tq_set_capacity_internal(cw_tone_queue_t *tq, uint32_t capacity, uint32_t high_water_mark);
251 int cw_tq_set_capacity_internal(cw_tone_queue_t *tq, uint32_t capacity, uint32_t high_water_mark) in cw_tq_set_capacity_internal() argument
258 if (!high_water_mark || high_water_mark > CW_TONE_QUEUE_HIGH_WATER_MARK_MAX) { in cw_tq_set_capacity_internal()
273 if (high_water_mark > capacity) { in cw_tq_set_capacity_internal()
279 tq->high_water_mark = high_water_mark; in cw_tq_set_capacity_internal()
318 return tq->high_water_mark; in cw_tq_get_high_water_mark_internal()
978 static cw_tone_queue_t *test_cw_tq_capacity_test_init(uint32_t capacity, uint32_t high_water_mark, …
1629 cw_tone_queue_t *test_cw_tq_capacity_test_init(uint32_t capacity, uint32_t high_water_mark, int hea… in test_cw_tq_capacity_test_init() argument
1635 int rv = cw_tq_set_capacity_internal(tq, capacity, high_water_mark); in test_cw_tq_capacity_test_init()
1638 …w_assert (tq->high_water_mark == high_water_mark, "incorrect high water mark: %"PRIu32" != %"PRIu3… in test_cw_tq_capacity_test_init()
|
| /dports/comms/unixcw/unixcw-3.5.1/src/libcw/ |
| H A D | libcw_tq.c | 130 … cw_tq_set_capacity_internal(cw_tone_queue_t *tq, uint32_t capacity, uint32_t high_water_mark);
251 int cw_tq_set_capacity_internal(cw_tone_queue_t *tq, uint32_t capacity, uint32_t high_water_mark) in cw_tq_set_capacity_internal() argument
258 if (!high_water_mark || high_water_mark > CW_TONE_QUEUE_HIGH_WATER_MARK_MAX) { in cw_tq_set_capacity_internal()
273 if (high_water_mark > capacity) { in cw_tq_set_capacity_internal()
279 tq->high_water_mark = high_water_mark; in cw_tq_set_capacity_internal()
318 return tq->high_water_mark; in cw_tq_get_high_water_mark_internal()
978 static cw_tone_queue_t *test_cw_tq_capacity_test_init(uint32_t capacity, uint32_t high_water_mark, …
1629 cw_tone_queue_t *test_cw_tq_capacity_test_init(uint32_t capacity, uint32_t high_water_mark, int hea… in test_cw_tq_capacity_test_init() argument
1635 int rv = cw_tq_set_capacity_internal(tq, capacity, high_water_mark); in test_cw_tq_capacity_test_init()
1638 …w_assert (tq->high_water_mark == high_water_mark, "incorrect high water mark: %"PRIu32" != %"PRIu3… in test_cw_tq_capacity_test_init()
|