| /dports/net/proby/proby-1.0.2/cargo-crates/actix-http-1.0.1/src/h1/ |
| H A D | payload.rs | 130 pub fn need_read(&self, cx: &mut Context<'_>) -> PayloadStatus { in need_read() method
134 if shared.borrow().need_read { in need_read()
151 need_read: bool, field
164 need_read: true, in new()
184 self.need_read = self.len < MAX_BUFFER_SIZE; in feed_data()
201 self.need_read = self.len < MAX_BUFFER_SIZE; in readany()
203 if self.need_read && !self.eof { in readany()
213 self.need_read = true; in readany()
|
| /dports/www/miniserve/miniserve-0.18.0/cargo-crates/actix-http-3.0.0-beta.9/src/h1/ |
| H A D | payload.rs | 129 pub fn need_read(&self, cx: &mut Context<'_>) -> PayloadStatus { in need_read() method
133 if shared.borrow().need_read { in need_read()
150 need_read: bool, field
163 need_read: true, in new()
221 self.need_read = self.len < MAX_BUFFER_SIZE; in feed_data()
236 self.need_read = self.len < MAX_BUFFER_SIZE; in readany()
238 if self.need_read && !self.eof { in readany()
248 self.need_read = true; in readany()
|
| /dports/lang/v/v-0.1.29/vlib/encoding/csv/ |
| H A D | reader.v | 101 mut need_read := true
108 if need_read {
122 need_read = false
138 need_read = true
|
| /dports/multimedia/librespot/librespot-0.1.3/cargo-crates/tokio-core-0.1.17/src/reactor/ |
| H A D | poll_evented.rs | 261 self.need_read(); in poll_ready()
293 pub fn need_read(&self) { in need_read() method
359 self.need_read(); in read()
427 self.need_read(); in read()
|
| /dports/security/sequoia/sequoia-383133f6be990237044900a4df676488bf8dd71e/cargo-crates/tokio-core-0.1.17/src/reactor/ |
| H A D | poll_evented.rs | 261 self.need_read(); in poll_ready()
293 pub fn need_read(&self) { in need_read() method
359 self.need_read(); in read()
427 self.need_read(); in read()
|
| /dports/audio/spotifyd/spotifyd-0.3.0/cargo-crates/tokio-core-0.1.17/src/reactor/ |
| H A D | poll_evented.rs | 261 self.need_read(); in poll_ready()
293 pub fn need_read(&self) { in need_read() method
359 self.need_read(); in read()
427 self.need_read(); in read()
|
| /dports/lang/spidermonkey60/firefox-60.9.0/third_party/rust/tokio-uds/src/ |
| H A D | lib.rs | 143 self.io.need_read(); in accept()
273 pub fn need_read(&self) { in need_read() method
274 self.io.need_read() in need_read()
450 self.io.need_read(); in read_buf()
593 pub fn need_read(&self) { in need_read() method
594 self.io.need_read() in need_read()
640 self.io.need_read(); in recv_from()
654 self.io.need_read(); in recv()
|
| /dports/devel/libiqxmlrpc/libiqxmlrpc-0.13.5/libiqxmlrpc/ |
| H A D | ssl_lib.h | 118 class LIBIQXMLRPC_API need_read: public ssl::io_error {
120 need_read(): in need_read() function
|
| /dports/lang/spidermonkey60/firefox-60.9.0/third_party/rust/tokio-core/src/reactor/ |
| H A D | poll_evented.rs | 149 pub fn need_read(&self) { in need_read() method
200 self.need_read(); in read()
259 self.need_read(); in read()
|
| /dports/multimedia/librespot/librespot-0.1.3/cargo-crates/tokio-0.1.22/src/reactor/ |
| H A D | poll_evented.rs | 212 let _ = self.need_read(); in poll_ready()
252 pub fn need_read(&mut self) -> io::Result<()> { in need_read() method
354 self.need_read()?; in read()
|
| /dports/devel/sccache/sccache-0.2.15/cargo-crates/tokio-0.1.22/src/reactor/ |
| H A D | poll_evented.rs | 212 let _ = self.need_read(); in poll_ready()
252 pub fn need_read(&mut self) -> io::Result<()> { in need_read() method
354 self.need_read()?; in read()
|
| /dports/net-mgmt/nfs-exporter/freebsd-nfs-exporter-0.3.0/cargo-crates/tokio-0.1.22/src/reactor/ |
| H A D | poll_evented.rs | 212 let _ = self.need_read(); in poll_ready()
252 pub fn need_read(&mut self) -> io::Result<()> { in need_read() method
354 self.need_read()?; in read()
|
| /dports/sysutils/vector/vector-0.10.0/cargo-crates/tokio-0.1.22/src/reactor/ |
| H A D | poll_evented.rs | 212 let _ = self.need_read(); in poll_ready()
252 pub fn need_read(&mut self) -> io::Result<()> { in need_read() method
354 self.need_read()?; in read()
|
| /dports/www/geckodriver/mozilla-central-e9783a644016aa9b317887076618425586730d73/testing/geckodriver/cargo-crates/tokio-0.1.11/src/reactor/ |
| H A D | poll_evented.rs | 211 let _ = self.need_read(); in poll_ready()
251 pub fn need_read(&mut self) -> io::Result<()> { in need_read() method
353 self.need_read()?; in read()
|
| /dports/editors/xi-term/xi-term-d264767/cargo-crates/tokio-0.1.21/src/reactor/ |
| H A D | poll_evented.rs | 212 let _ = self.need_read(); in poll_ready()
252 pub fn need_read(&mut self) -> io::Result<()> { in need_read() method
354 self.need_read()?; in read()
|
| /dports/www/firefox/firefox-99.0/third_party/rust/tokio-0.1.14/src/reactor/ |
| H A D | poll_evented.rs | 211 let _ = self.need_read(); in poll_ready()
251 pub fn need_read(&mut self) -> io::Result<()> { in need_read() method
353 self.need_read()?; in read()
|
| /dports/mail/thunderbird/thunderbird-91.8.0/third_party/rust/tokio-0.1.11/src/reactor/ |
| H A D | poll_evented.rs | 211 let _ = self.need_read(); in poll_ready()
251 pub fn need_read(&mut self) -> io::Result<()> { in need_read() method
353 self.need_read()?; in read()
|
| /dports/security/sequoia/sequoia-383133f6be990237044900a4df676488bf8dd71e/cargo-crates/tokio-0.1.22/src/reactor/ |
| H A D | poll_evented.rs | 212 let _ = self.need_read(); in poll_ready()
252 pub fn need_read(&mut self) -> io::Result<()> { in need_read() method
354 self.need_read()?; in read()
|
| /dports/www/websocat/websocat-1.9.0/cargo-crates/tokio-0.1.22/src/reactor/ |
| H A D | poll_evented.rs | 212 let _ = self.need_read(); in poll_ready()
252 pub fn need_read(&mut self) -> io::Result<()> { in need_read() method
354 self.need_read()?; in read()
|
| /dports/sysutils/rsfetch/rsfetch-2.0.0/cargo-crates/tokio-0.1.22/src/reactor/ |
| H A D | poll_evented.rs | 212 let _ = self.need_read(); in poll_ready()
252 pub fn need_read(&mut self) -> io::Result<()> { in need_read() method
354 self.need_read()?; in read()
|
| /dports/www/firefox-esr/firefox-91.8.0/third_party/rust/tokio-0.1.11/src/reactor/ |
| H A D | poll_evented.rs | 211 let _ = self.need_read(); in poll_ready()
251 pub fn need_read(&mut self) -> io::Result<()> { in need_read() method
353 self.need_read()?; in read()
|
| /dports/lang/spidermonkey78/firefox-78.9.0/third_party/rust/tokio-0.1.11/src/reactor/ |
| H A D | poll_evented.rs | 211 let _ = self.need_read(); in poll_ready()
251 pub fn need_read(&mut self) -> io::Result<()> { in need_read() method
353 self.need_read()?; in read()
|
| /dports/audio/spotifyd/spotifyd-0.3.0/cargo-crates/tokio-0.1.22/src/reactor/ |
| H A D | poll_evented.rs | 212 let _ = self.need_read();
252 pub fn need_read(&mut self) -> io::Result<()> {
354 self.need_read()?;
|
| /dports/games/libretro-yabause/yabause-ea5b118/yabause/src/ |
| H A D | scsp_dsp_jit.cpp | 53 u32 need_read; member
432 jit.PushRel(offsetof(DspContext, need_read)); in op4()
454 jit.PushRel(offsetof(DspContext, need_read)); in op4()
473 jit.PullRel(offsetof(DspContext, need_read)); in op4()
564 jit.PullRel(offsetof(DspContext, need_read)); in op5()
|
| H A D | scspdsp.c | 52 int need_read; member
210 if (dsp->need_read) in ScspDspExec()
217 dsp->need_read = 0; in ScspDspExec()
231 dsp->need_read = 1; in ScspDspExec()
|