Home
last modified time | relevance | path

Searched refs:fetch_state (Results 1 – 25 of 88) sorted by relevance

1234

/dports/sysutils/flowgger/flowgger-0.2.10/cargo-crates/kafka-0.8.0/src/consumer/
H A Dmod.rs251 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 Dvic-cycle.c58 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 Dvic.c285 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 Dvic-snapshot.c66 || (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 Dvictypes.h189 vic_fetch_state_t fetch_state; member
/dports/emulators/libretro-vice/vice-libretro-5725415/vice/src/vic20/
H A Dvic-cycle.c58 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 Dvic.c281 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 Dvic-snapshot.c66 || (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 Dvictypes.h189 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 Dxmerl.eix12 {"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 Dscaleway_compute.py191 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 Dscaleway_lb.py172 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 Dscaleway_compute.py198 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 Dscaleway_lb.py178 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 Dscaleway_compute.py198 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 Dscaleway_lb.py178 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 Dsdr.c142 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 Drdkafka_partition.h242 #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 Dlogproto-buffered-server.c277 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 Dlogproto-buffered-server.h87 gint fetch_state; member
/dports/net/librdkafka/librdkafka-1.8.2/src/
H A Drdkafka_partition.h240 #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 Drdkafka_partition.h240 #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 Difstated.c69 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 Dcustom.c262 } 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 DSTATISTICS.md173 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",

1234