/dports/net/py-h11/h11-0.12.0/docs/source/_examples/ |
H A D | myclient.py | 23 def next_event(self, max_bytes_per_recv=200): member in MyHttpClient 28 event = self.conn.next_event()
|
/dports/net/ntp/ntp-4.2.8p15/lib/isc/win32/ |
H A D | app.c | 137 isc_event_t *event, *next_event; in isc__app_run() local 151 event = next_event) { in isc__app_run() 152 next_event = ISC_LIST_NEXT(event, ev_link); in isc__app_run()
|
/dports/net-mgmt/wmi-client/wmi-1.3.16/Samba/source/lib/events/ |
H A D | events_internal.h | 41 struct timeval next_event, 66 struct timeval next_event; member
|
/dports/mail/roundcube-calendar-kolab/roundcubemail-plugins-kolab-3.5.5/plugins/calendar/drivers/kolab/ |
H A D | kolab_calendar.php | 695 while ($next_event = $recurrence->next_instance()) { 696 $datestr = $next_event['start']->format('Ymd'); 697 $instance_id = $next_event['start']->format($recurrence_id_format); 705 $event_start = $next_event['start']; 706 $event_end = $next_event['end']; 710 $event_copy = $next_event; 718 $rec_event = $this->_to_driver_event($next_event, false, false, $event); 740 else if ($next_event['start'] > $end) // stop loop if out of range
|
/dports/games/fishsupper/fishsupper-0.1.6/src/ |
H A D | Pause_menu.cpp | 69 while ( input_ptr->next_event(ke) ) in update() 122 while ( input_ptr->next_event(ke) ) in has_pressed_jump()
|
/dports/databases/percona-toolkit/percona-toolkit-3.3.0/lib/ |
H A D | RawLogParser.pm | 48 my ($next_event, $tell) = @args{@required_args}; 53 while ( defined($line = $next_event->()) ) {
|
/dports/audio/dssi/dssi-1.1.1/examples/ |
H A D | less_trivial_synth.c | 90 int next_event; member 261 data[voice].next_event = vals.attack; in runLTS() 268 data[voice].next_event = vals.release; in runLTS() 278 data[voice].next_event = vals.release; in runLTS() 321 if (d->counter >= d->next_event) { in run_voice() 330 d->next_event = vals->decay; in run_voice() 337 d->next_event = INT_MAX; in run_voice()
|
/dports/www/firefox/firefox-99.0/third_party/rust/neqo-http3/tests/webtransport/ |
H A D | mod.rs | 122 while let Some(event) = self.server.next_event() { in negotiate_wt_session() 209 while let Some(event) = self.client.next_event() { in check_session_closed_event_client() 244 let event = self.server.next_event().unwrap(); in check_session_closed_event_server() 279 while let Some(event) = self.client.next_event() { in receive_data_client() 361 while let Some(event) = self.client.next_event() { in check_events_after_closing_session_client() 420 while let Some(event) = self.server.next_event() { in receive_data_server() 502 while let Some(event) = self.server.next_event() { in check_events_after_closing_session_server()
|
/dports/multimedia/v4l_compat/linux-5.13-rc2/kernel/time/ |
H A D | tick-sched.c | 851 basemono, ts->next_tick, dev->next_event, in tick_nohz_stop_tick() 1120 return __this_cpu_read(tick_cpu_device.evtdev)->next_event; in tick_nohz_get_next_hrtimer() 1143 ktime_t next_event; in tick_nohz_get_sleep_length() local 1147 *delta_next = ktime_sub(dev->next_event, now); in tick_nohz_get_sleep_length() 1152 next_event = tick_nohz_next_event(ts, cpu); in tick_nohz_get_sleep_length() 1153 if (!next_event) in tick_nohz_get_sleep_length() 1160 next_event = min_t(u64, next_event, in tick_nohz_get_sleep_length() 1163 return ktime_sub(next_event, now); in tick_nohz_get_sleep_length() 1269 dev->next_event = KTIME_MAX; in tick_nohz_handler()
|
/dports/multimedia/libv4l/linux-5.13-rc2/kernel/time/ |
H A D | tick-sched.c | 851 basemono, ts->next_tick, dev->next_event, in tick_nohz_stop_tick() 1120 return __this_cpu_read(tick_cpu_device.evtdev)->next_event; in tick_nohz_get_next_hrtimer() 1143 ktime_t next_event; in tick_nohz_get_sleep_length() local 1147 *delta_next = ktime_sub(dev->next_event, now); in tick_nohz_get_sleep_length() 1152 next_event = tick_nohz_next_event(ts, cpu); in tick_nohz_get_sleep_length() 1153 if (!next_event) in tick_nohz_get_sleep_length() 1160 next_event = min_t(u64, next_event, in tick_nohz_get_sleep_length() 1163 return ktime_sub(next_event, now); in tick_nohz_get_sleep_length() 1269 dev->next_event = KTIME_MAX; in tick_nohz_handler()
|
/dports/lang/spidermonkey78/firefox-78.9.0/third_party/rust/neqo-http3/src/ |
H A D | server.rs | 105 while let Some(e) = handler.borrow_mut().next_event() { in process_http3() 155 pub fn next_event(&mut self) -> Option<Http3ServerEvent> { in next_event() method 156 self.events.next_event() in next_event() 238 while let Some(e) = neqo_trans_conn.next_event() { in connect_and_receive_settings() 434 while let Some(e) = peer_conn.conn.next_event() { in test_server_received_unknown_stream() 607 while let Some(event) = hconn.next_event() { in test_server_request_with_body() 667 while let Some(event) = hconn.next_event() { in test_server_request_with_body_send_stop_sending() 716 while let Some(event) = hconn.next_event() { in test_server_request_with_body_send_stop_sending() 747 while let Some(event) = hconn.next_event() { in test_server_request_with_body_server_reset() 783 while let Some(event) = peer_conn.conn.next_event() { in test_server_request_with_body_server_reset()
|
/dports/multimedia/v4l-utils/linux-5.13-rc2/kernel/time/ |
H A D | tick-sched.c | 851 basemono, ts->next_tick, dev->next_event, in tick_nohz_stop_tick() 1120 return __this_cpu_read(tick_cpu_device.evtdev)->next_event; in tick_nohz_get_next_hrtimer() 1143 ktime_t next_event; in tick_nohz_get_sleep_length() local 1147 *delta_next = ktime_sub(dev->next_event, now); in tick_nohz_get_sleep_length() 1152 next_event = tick_nohz_next_event(ts, cpu); in tick_nohz_get_sleep_length() 1153 if (!next_event) in tick_nohz_get_sleep_length() 1160 next_event = min_t(u64, next_event, in tick_nohz_get_sleep_length() 1163 return ktime_sub(next_event, now); in tick_nohz_get_sleep_length() 1269 dev->next_event = KTIME_MAX; in tick_nohz_handler()
|
/dports/emulators/mednafen/mednafen/src/psx/ |
H A D | timer.cpp | 107 uint32 next_event = 1024; // in CalcNextEvent() local 116 next_event = 1; in CalcNextEvent() 143 if(next_event > tmp_clocks) in CalcNextEvent() 144 next_event = tmp_clocks; in CalcNextEvent() 147 return(next_event); in CalcNextEvent()
|
/dports/emulators/dolphin-emu/dolphin-3152428/Source/Core/Core/HW/ |
H A D | SystemTimers.cpp | 180 u32 next_event = GetTicksPerSecond() / 1000; in ThrottleCallback() local 192 next_event = u32(next_event * config.m_EmulationSpeed); in ThrottleCallback() 206 CoreTiming::ScheduleEvent(next_event - cyclesLate, et_Throttle, last_time + 1000); in ThrottleCallback()
|
/dports/audio/jack/jack2-eaedec353489f26617221d66f80fd2503953c663/linux/alsa/ |
H A D | alsa_rawmidi.c | 122 event_head_t next_event; member 1109 out->next_event.time = 0; in output_port_init() 1110 out->next_event.size = 0; in output_port_init() 1159 while (port->next_event.time <= proc->cur_time) { in do_midi_output() 1160 port->todo += port->next_event.size; in do_midi_output() 1161 …er_read(port->base.event_ring, (char*)&port->next_event, sizeof(port->next_event))!=sizeof(port->n… in do_midi_output() 1162 port->next_event.time = 0; in do_midi_output() 1163 port->next_event.size = 0; in do_midi_output() 1166 … got %d bytes for %ld", (long)proc->cur_time, (int)port->next_event.size, (long)port->next_event.t… in do_midi_output() 1175 if (!port->todo && port->next_event.time && port->next_event.time < proc->next_time) { in do_midi_output() [all …]
|
/dports/devel/arm-none-eabi-newlib/newlib-2.4.0/newlib/libc/machine/spu/ |
H A D | spu_timer_flih.S | 101 next_event: label 113 brnz $3, next_event
|
/dports/devel/tinygo/tinygo-0.14.1/lib/picolibc/newlib/libc/machine/spu/ |
H A D | spu_timer_flih.S | 101 next_event: label 113 brnz $3, next_event
|
/dports/graphics/gthumb/gthumb-3.10.1/extensions/slideshow/ |
H A D | gth-slideshow.c | 70 guint next_event; member 180 if (self->priv->next_event != 0) { in _gth_slideshow_load_current_image() 181 g_source_remove (self->priv->next_event); in _gth_slideshow_load_current_image() 182 self->priv->next_event = 0; in _gth_slideshow_load_current_image() 221 if (self->priv->next_event != 0) { in next_image_cb() 222 g_source_remove (self->priv->next_event); in next_image_cb() 223 self->priv->next_event = 0; in next_image_cb() 242 if (self->priv->next_event != 0) in view_next_image_automatically() 254 if (self->priv->next_event != 0) in gth_slideshow_finalize() 255 g_source_remove (self->priv->next_event); in gth_slideshow_finalize() [all …]
|
/dports/cad/ghdl/ghdl-1.0.0/testsuite/synth/issue1314/ |
H A D | issue.vhdl | 158 NEXT_EVENT_0_a : assert always ((req and din = x"4") -> next_event(ack)(dout = x"4")); 159 NEXT_EVENT_1_a : assert always ((req and din = x"7") -> next_event(ack)(dout = x"7")); 168 assert always ((req and din = i_slv) -> next_event(ack)(dout = i_slv)); 171 NEXT_EVENT_a : assert always ((req and din = i_slv) -> next_event(ack)(dout = i_slv));
|
/dports/emulators/citra/citra-ac98458e0/src/core/ |
H A D | core_timing.cpp | 178 const auto& next_event = event_queue.begin(); in GetMaxSliceLength() local 179 if (next_event != event_queue.end()) { in GetMaxSliceLength() 180 ASSERT(next_event->time - executed_ticks > 0); in GetMaxSliceLength() 181 return next_event->time - executed_ticks; in GetMaxSliceLength()
|
/dports/emulators/citra-qt5/citra-ac98458e0/src/core/ |
H A D | core_timing.cpp | 178 const auto& next_event = event_queue.begin(); in GetMaxSliceLength() local 179 if (next_event != event_queue.end()) { in GetMaxSliceLength() 180 ASSERT(next_event->time - executed_ticks > 0); in GetMaxSliceLength() 181 return next_event->time - executed_ticks; in GetMaxSliceLength()
|
/dports/lang/erlang-runtime24/otp-OTP-24.1.7/lib/ssl/src/ |
H A D | tls_dtls_connection.erl | 243 Connection:next_event(?FUNCTION_NAME, no_record, 277 Connection:next_event(certify, no_record, 290 Connection:next_event(certify, no_record, 439 Connection:next_event(?FUNCTION_NAME, no_record, 580 Connection:next_event(?FUNCTION_NAME, no_record, 621 Connection:next_event(?FUNCTION_NAME, no_record, 680 [{next_event, internal, Handshake}]}; 880 Connection:next_event(certify, no_record, State, Actions). 934 Connection:next_event(cipher, no_record, State, Actions) 1367 Connection:next_event(Next, no_record, State); [all …]
|
/dports/lang/erlang-wx/otp-OTP-24.1.7/lib/ssl/src/ |
H A D | tls_dtls_connection.erl | 243 Connection:next_event(?FUNCTION_NAME, no_record, 277 Connection:next_event(certify, no_record, 290 Connection:next_event(certify, no_record, 439 Connection:next_event(?FUNCTION_NAME, no_record, 580 Connection:next_event(?FUNCTION_NAME, no_record, 621 Connection:next_event(?FUNCTION_NAME, no_record, 680 [{next_event, internal, Handshake}]}; 880 Connection:next_event(certify, no_record, State, Actions). 934 Connection:next_event(cipher, no_record, State, Actions) 1367 Connection:next_event(Next, no_record, State); [all …]
|
/dports/lang/erlang/otp-OTP-24.1.7/lib/ssl/src/ |
H A D | tls_dtls_connection.erl | 243 Connection:next_event(?FUNCTION_NAME, no_record, 277 Connection:next_event(certify, no_record, 290 Connection:next_event(certify, no_record, 439 Connection:next_event(?FUNCTION_NAME, no_record, 580 Connection:next_event(?FUNCTION_NAME, no_record, 621 Connection:next_event(?FUNCTION_NAME, no_record, 680 [{next_event, internal, Handshake}]}; 880 Connection:next_event(certify, no_record, State, Actions). 934 Connection:next_event(cipher, no_record, State, Actions) 1367 Connection:next_event(Next, no_record, State); [all …]
|
/dports/lang/erlang-java/otp-OTP-24.1.7/lib/ssl/src/ |
H A D | tls_dtls_connection.erl | 243 Connection:next_event(?FUNCTION_NAME, no_record, 277 Connection:next_event(certify, no_record, 290 Connection:next_event(certify, no_record, 439 Connection:next_event(?FUNCTION_NAME, no_record, 580 Connection:next_event(?FUNCTION_NAME, no_record, 621 Connection:next_event(?FUNCTION_NAME, no_record, 680 [{next_event, internal, Handshake}]}; 880 Connection:next_event(certify, no_record, State, Actions). 934 Connection:next_event(cipher, no_record, State, Actions) 1367 Connection:next_event(Next, no_record, State); [all …]
|