/dports/sysutils/flowgger/flowgger-0.2.10/cargo-crates/kafka-0.8.0/src/consumer/ |
H A D | mod.rs | 251 let mut fetch_state = self.state.fetch_offsets.get_mut(&tp).expect( in process_fetch_responses() localVariable 256 fetch_state.offset = last_msg.offset + 1; in process_fetch_responses() 263 let prev_max_bytes = fetch_state.max_bytes; in process_fetch_responses() 270 fetch_state.max_bytes in process_fetch_responses() 279 fetch_state.max_bytes, in process_fetch_responses() 280 fetch_state.offset, in process_fetch_responses() 289 if fetch_state.offset < data.highwatermark_offset() { in process_fetch_responses() 290 if fetch_state.max_bytes < self.config.retry_max_bytes_limit { in process_fetch_responses() 292 let prev_max_bytes = fetch_state.max_bytes; in process_fetch_responses() 297 fetch_state.max_bytes = incr_max_bytes; in process_fetch_responses() [all …]
|
/dports/emulators/vice/vice-3.5/src/vic20/ |
H A D | vic-cycle.c | 58 if (vic.fetch_state != VIC_FETCH_IDLE) { in vic_cycle_close_v() 92 vic.fetch_state = VIC_FETCH_START; in vic_cycle_open_h() 114 vic.fetch_state = VIC_FETCH_DONE; in vic_cycle_close_h() 139 vic.fetch_state = VIC_FETCH_MATRIX; in vic_cycle_start_fetch() 157 vic.fetch_state = VIC_FETCH_IDLE; in vic_cycle_end_of_line() 278 switch (vic.fetch_state) { in vic_cycle_fetch() 302 vic.fetch_state = VIC_FETCH_CHARGEN; in vic_cycle_fetch() 322 vic.fetch_state = VIC_FETCH_MATRIX; in vic_cycle_fetch() 350 if ((vic.fetch_state == VIC_FETCH_IDLE) && (vic.regs[0] & 0x7fu) == vic.raster_cycle) { in vic_cycle()
|
H A D | vic.c | 285 vic.fetch_state = VIC_FETCH_IDLE; in vic_reset() 491 mon_out("Fetch: %s, from ", fetch_state_name[vic.fetch_state]); in vic_dump() 493 switch (vic.fetch_state) { in vic_dump() 524 if (vic.fetch_state != VIC_FETCH_IDLE) { in vic_dump() 536 if (vic.fetch_state != VIC_FETCH_IDLE) { in vic_dump()
|
H A D | vic-snapshot.c | 66 || (SMW_W(m, (uint16_t)vic.fetch_state) < 0) in vic_snapshot_write_module() 157 vic.fetch_state = (vic_fetch_state_t)w; in vic_snapshot_read_module()
|
H A D | victypes.h | 189 vic_fetch_state_t fetch_state; member
|
/dports/emulators/libretro-vice/vice-libretro-5725415/vice/src/vic20/ |
H A D | vic-cycle.c | 58 if (vic.fetch_state != VIC_FETCH_IDLE) { in vic_cycle_close_v() 92 vic.fetch_state = VIC_FETCH_START; in vic_cycle_open_h() 114 vic.fetch_state = VIC_FETCH_DONE; in vic_cycle_close_h() 139 vic.fetch_state = VIC_FETCH_MATRIX; in vic_cycle_start_fetch() 157 vic.fetch_state = VIC_FETCH_IDLE; in vic_cycle_end_of_line() 278 switch (vic.fetch_state) { in vic_cycle_fetch() 302 vic.fetch_state = VIC_FETCH_CHARGEN; in vic_cycle_fetch() 322 vic.fetch_state = VIC_FETCH_MATRIX; in vic_cycle_fetch() 350 if ((vic.fetch_state == VIC_FETCH_IDLE) && (vic.regs[0] & 0x7fu) == vic.raster_cycle) { in vic_cycle()
|
H A D | vic.c | 281 vic.fetch_state = VIC_FETCH_IDLE; in vic_reset() 487 mon_out("Fetch: %s, from ", fetch_state_name[vic.fetch_state]); in vic_dump() 489 switch (vic.fetch_state) { in vic_dump() 519 if (vic.fetch_state != VIC_FETCH_IDLE) { in vic_dump() 531 if (vic.fetch_state != VIC_FETCH_IDLE) { in vic_dump()
|
H A D | vic-snapshot.c | 66 || (SMW_W(m, (uint16_t)vic.fetch_state) < 0) in vic_snapshot_write_module() 157 vic.fetch_state = (vic_fetch_state_t)w; in vic_snapshot_read_module()
|
H A D | victypes.h | 189 vic_fetch_state_t fetch_state; member
|
/dports/lang/erlang-doc/otp_doc_html_24.1/lib/xmerl-1.3.28/doc/html/ |
H A D | xmerl.eix | 12 {"fetch_state", "fetch_state(S::global_state())", "fetch_state-1"}, 13 {"fetch_state", "fetch_state(X::FetchState, S::global_state())", "fetch_state-2"},
|
/dports/sysutils/ansible2/ansible-2.9.27/lib/ansible/modules/cloud/scaleway/ |
H A D | scaleway_compute.py | 191 def fetch_state(compute_api, server): function 220 if fetch_state(compute_api, server) not in SCALEWAY_TRANSITIONS_STATES: 222 compute_api.module.debug("Server in state: %s" % fetch_state(compute_api, server)) 365 while fetch_state(compute_api=compute_api, server=target_server) != "stopped": 408 current_state = fetch_state(compute_api=compute_api, server=target_server) 454 current_state = fetch_state(compute_api=compute_api, server=target_server) 505 if fetch_state(compute_api=compute_api, server=target_server) in ("running",): 513 if fetch_state(compute_api=compute_api, server=target_server) in ("stopped",):
|
H A D | scaleway_lb.py | 172 def fetch_state(api, lb): function 201 state = fetch_state(api, lb) 204 api.module.debug("load-balancer in state: %s" % fetch_state(api, lb))
|
/dports/sysutils/ansible/ansible-4.7.0/ansible_collections/community/general/plugins/modules/cloud/scaleway/ |
H A D | scaleway_compute.py | 198 def fetch_state(compute_api, server): function 229 if fetch_state(compute_api, server) not in SCALEWAY_TRANSITIONS_STATES: 231 compute_api.module.debug("Server in state: %s" % fetch_state(compute_api, server)) 374 while fetch_state(compute_api=compute_api, server=target_server) != "stopped": 417 current_state = fetch_state(compute_api=compute_api, server=target_server) 463 current_state = fetch_state(compute_api=compute_api, server=target_server) 514 if fetch_state(compute_api=compute_api, server=target_server) in ("running",): 522 if fetch_state(compute_api=compute_api, server=target_server) in ("stopped",):
|
H A D | scaleway_lb.py | 178 def fetch_state(api, lb): function 207 state = fetch_state(api, lb) 210 api.module.debug("load-balancer in state: %s" % fetch_state(api, lb))
|
/dports/sysutils/ansible/ansible-4.7.0/ansible_collections/community/general/plugins/modules/ |
H A D | scaleway_compute.py | 198 def fetch_state(compute_api, server): function 229 if fetch_state(compute_api, server) not in SCALEWAY_TRANSITIONS_STATES: 231 compute_api.module.debug("Server in state: %s" % fetch_state(compute_api, server)) 374 while fetch_state(compute_api=compute_api, server=target_server) != "stopped": 417 current_state = fetch_state(compute_api=compute_api, server=target_server) 463 current_state = fetch_state(compute_api=compute_api, server=target_server) 514 if fetch_state(compute_api=compute_api, server=target_server) in ("running",): 522 if fetch_state(compute_api=compute_api, server=target_server) in ("stopped",):
|
H A D | scaleway_lb.py | 178 def fetch_state(api, lb): function 207 state = fetch_state(api, lb) 210 api.module.debug("load-balancer in state: %s" % fetch_state(api, lb))
|
/dports/sysutils/openipmi/OpenIPMI-2.0.29/lib/ |
H A D | sdr.c | 142 enum fetch_state_e fetch_state; member 412 sdrs->fetch_state = IDLE; in ipmi_sdr_info_alloc() 658 sdrs->fetch_state = HANDLERS; in fetch_complete() 671 if (sdrs->fetch_state == HANDLERS) in fetch_complete() 673 sdrs->fetch_state = IDLE; in fetch_complete() 1709 if (sdrs->fetch_state == IDLE) in start_fetch() 1712 sdrs->fetch_state = FETCHING; in start_fetch() 2310 sdrs->fetch_state = HANDLERS; in save_complete() 2326 if (sdrs->fetch_state == HANDLERS) in save_complete() 2328 sdrs->fetch_state = IDLE; in save_complete() [all …]
|
/dports/sysutils/vector/vector-0.10.0/cargo-crates/rdkafka-sys-2.0.0+1.4.2/librdkafka/src/ |
H A D | rdkafka_partition.h | 242 #define RD_KAFKA_TOPPAR_FETCH_IS_STARTED(fetch_state) \ argument 243 ((fetch_state) >= RD_KAFKA_TOPPAR_FETCH_OFFSET_QUERY) 438 int fetch_state);
|
/dports/sysutils/syslog-ng/syslog-ng-3.35.1/lib/logproto/ |
H A D | logproto-buffered-server.c | 277 self->fetch_state = LPBSF_FETCHING_FROM_BUFFER; in log_proto_buffered_server_apply_state() 854 if (self->fetch_state == LPBSF_FETCHING_FROM_BUFFER) in log_proto_buffered_server_fetch() 866 self->fetch_state = LPBSF_FETCHING_FROM_INPUT; in log_proto_buffered_server_fetch() 869 else if (self->fetch_state == LPBSF_FETCHING_FROM_INPUT) in log_proto_buffered_server_fetch() 895 self->fetch_state = LPBSF_FETCHING_FROM_BUFFER; in log_proto_buffered_server_fetch()
|
H A D | logproto-buffered-server.h | 87 gint fetch_state; member
|
/dports/net/librdkafka/librdkafka-1.8.2/src/ |
H A D | rdkafka_partition.h | 240 #define RD_KAFKA_TOPPAR_FETCH_IS_STARTED(fetch_state) \ argument 241 ((fetch_state) >= RD_KAFKA_TOPPAR_FETCH_OFFSET_QUERY) 444 int fetch_state);
|
/dports/sysutils/fluent-bit/fluent-bit-1.8.11/plugins/out_kafka/librdkafka-1.7.0/src/ |
H A D | rdkafka_partition.h | 240 #define RD_KAFKA_TOPPAR_FETCH_IS_STARTED(fetch_state) \ argument 241 ((fetch_state) >= RD_KAFKA_TOPPAR_FETCH_OFFSET_QUERY) 444 int fetch_state);
|
/dports/net/ifstated/ifstated-5.1/ |
H A D | ifstated.c | 69 void fetch_state(void); 221 fetch_state(); in load_config() 649 fetch_state(void) in fetch_state() function
|
/dports/emulators/uae/uae-0.8.29/src/ |
H A D | custom.c | 262 } fetch_state; variable 730 fetch_state = fetch_was_plane0; in fetch() 1142 fetch_state = fetch_was_plane0; in do_long_fetch() 1271 if (fetch_state == fetch_was_plane0) in update_fetch() 1274 fetch_state = fetch_started; in update_fetch() 1324 if (fetch_state == fetch_was_plane0) in update_fetch() 1326 fetch_state = fetch_started; in update_fetch() 1357 fetch_state = fetch_started; in start_bpl_dma() 1388 if (fetch_state != fetch_not_started) in maybe_start_bpl_dma() 1827 if (fetch_state != fetch_not_started) in finish_decisions() [all …]
|
/dports/sysutils/vector/vector-0.10.0/cargo-crates/rdkafka-sys-2.0.0+1.4.2/librdkafka/ |
H A D | STATISTICS.md | 173 fetch_state | string | `"active"` | Consumer fetch state for this partition (none, stopping, stoppe… 526 "fetch_state": "none", 556 "fetch_state": "none", 586 "fetch_state": "none",
|