Home
last modified time | relevance | path

Searched refs:complete_io (Results 1 – 25 of 80) sorted by relevance

1234

/dports/net/routinator/routinator-0.10.2/cargo-crates/rustls-0.19.1/src/
H A Dstream.rs31 self.sess.complete_io(self.sock)?; in complete_prior_io()
35 self.sess.complete_io(self.sock)?; in complete_prior_io()
56 while self.sess.wants_read() && self.sess.complete_io(self.sock)?.0 != 0 {} in read()
75 let _ = self.sess.complete_io(self.sock); in write()
88 let _ = self.sess.complete_io(self.sock); in write_vectored()
98 self.sess.complete_io(self.sock)?; in flush()
/dports/www/ffsend/ffsend-ccd489ce2e75b91c0f17fbf13dbd91fe84f5ad98/cargo-crates/rustls-0.19.1/src/
H A Dstream.rs31 self.sess.complete_io(self.sock)?; in complete_prior_io()
35 self.sess.complete_io(self.sock)?; in complete_prior_io()
56 while self.sess.wants_read() && self.sess.complete_io(self.sock)?.0 != 0 {} in read()
75 let _ = self.sess.complete_io(self.sock); in write()
88 let _ = self.sess.complete_io(self.sock); in write_vectored()
98 self.sess.complete_io(self.sock)?; in flush()
/dports/net/krill/krill-0.9.4/cargo-crates/rustls-0.19.1/src/
H A Dstream.rs31 self.sess.complete_io(self.sock)?; in complete_prior_io()
35 self.sess.complete_io(self.sock)?; in complete_prior_io()
56 while self.sess.wants_read() && self.sess.complete_io(self.sock)?.0 != 0 {} in read()
75 let _ = self.sess.complete_io(self.sock); in write()
88 let _ = self.sess.complete_io(self.sock); in write_vectored()
98 self.sess.complete_io(self.sock)?; in flush()
/dports/dns/doh-proxy/doh-proxy-0.9.2/cargo-crates/rustls-0.19.1/src/
H A Dstream.rs31 self.sess.complete_io(self.sock)?; in complete_prior_io()
35 self.sess.complete_io(self.sock)?; in complete_prior_io()
56 while self.sess.wants_read() && self.sess.complete_io(self.sock)?.0 != 0 {} in read()
75 let _ = self.sess.complete_io(self.sock); in write()
88 let _ = self.sess.complete_io(self.sock); in write_vectored()
98 self.sess.complete_io(self.sock)?; in flush()
/dports/www/xh/xh-0.14.1/cargo-crates/rustls-0.19.1/src/
H A Dstream.rs31 self.sess.complete_io(self.sock)?; in complete_prior_io()
35 self.sess.complete_io(self.sock)?; in complete_prior_io()
56 while self.sess.wants_read() && self.sess.complete_io(self.sock)?.0 != 0 {} in read()
75 let _ = self.sess.complete_io(self.sock); in write()
88 let _ = self.sess.complete_io(self.sock); in write_vectored()
98 self.sess.complete_io(self.sock)?; in flush()
/dports/textproc/angle-grinder/angle-grinder-0.18.0/cargo-crates/rustls-0.18.1/src/
H A Dstream.rs27 self.sess.complete_io(self.sock)?; in complete_prior_io()
31 self.sess.complete_io(self.sock)?; in complete_prior_io()
50 self.sess.complete_io(self.sock)?.0 != 0 in read()
66 let _ = self.sess.complete_io(self.sock); in write()
79 let _ = self.sess.complete_io(self.sock); in write_vectored()
89 self.sess.complete_io(self.sock)?; in flush()
/dports/www/miniserve/miniserve-0.18.0/cargo-crates/rustls-0.19.1/src/
H A Dstream.rs31 self.sess.complete_io(self.sock)?; in complete_prior_io()
35 self.sess.complete_io(self.sock)?; in complete_prior_io()
56 while self.sess.wants_read() && self.sess.complete_io(self.sock)?.0 != 0 {} in read()
75 let _ = self.sess.complete_io(self.sock); in write()
88 let _ = self.sess.complete_io(self.sock); in write_vectored()
98 self.sess.complete_io(self.sock)?; in flush()
/dports/devel/py-maturin/maturin-0.11.3/cargo-crates/rustls-0.19.1/src/
H A Dstream.rs31 self.sess.complete_io(self.sock)?; in complete_prior_io()
35 self.sess.complete_io(self.sock)?; in complete_prior_io()
56 while self.sess.wants_read() && self.sess.complete_io(self.sock)?.0 != 0 {} in read()
75 let _ = self.sess.complete_io(self.sock); in write()
88 let _ = self.sess.complete_io(self.sock); in write_vectored()
98 self.sess.complete_io(self.sock)?; in flush()
/dports/www/zola/zola-0.15.2/cargo-crates/rustls-0.20.2/src/
H A Dstream.rs35 self.conn.complete_io(self.sock)?; in complete_prior_io()
39 self.conn.complete_io(self.sock)?; in complete_prior_io()
62 let at_eof = self.conn.complete_io(self.sock)?.0 == 0; in read()
91 let _ = self.conn.complete_io(self.sock); in write()
107 let _ = self.conn.complete_io(self.sock); in write_vectored()
117 self.conn.complete_io(self.sock)?; in flush()
H A Dconn.rs93 pub fn complete_io<T>(&mut self, io: &mut T) -> Result<(usize, usize), io::Error> in complete_io() method
99 Connection::Client(conn) => conn.complete_io(io), in complete_io()
100 Connection::Server(conn) => conn.complete_io(io), in complete_io()
427 pub fn complete_io<T>(&mut self, io: &mut T) -> Result<(usize, usize), io::Error> in complete_io() method
/dports/audio/ncspot/ncspot-0.9.3/cargo-crates/rustls-0.20.2/src/
H A Dstream.rs35 self.conn.complete_io(self.sock)?; in complete_prior_io()
39 self.conn.complete_io(self.sock)?; in complete_prior_io()
62 let at_eof = self.conn.complete_io(self.sock)?.0 == 0; in read()
91 let _ = self.conn.complete_io(self.sock); in write()
107 let _ = self.conn.complete_io(self.sock); in write_vectored()
117 self.conn.complete_io(self.sock)?; in flush()
H A Dconn.rs93 pub fn complete_io<T>(&mut self, io: &mut T) -> Result<(usize, usize), io::Error> in complete_io() method
99 Connection::Client(conn) => conn.complete_io(io), in complete_io()
100 Connection::Server(conn) => conn.complete_io(io), in complete_io()
427 pub fn complete_io<T>(&mut self, io: &mut T) -> Result<(usize, usize), io::Error> in complete_io() method
/dports/security/vaultwarden/vaultwarden-1.23.1/cargo-crates/rustls-0.17.0/src/
H A Dstream.rs27 self.sess.complete_io(self.sock)?; in complete_prior_io()
31 self.sess.complete_io(self.sock)?; in complete_prior_io()
50 self.sess.complete_io(self.sock)?.0 != 0 in read()
66 let _ = self.sess.complete_io(self.sock); in write()
76 self.sess.complete_io(self.sock)?; in flush()
/dports/security/rustscan/RustScan-2.0.1/cargo-crates/rustls-0.17.0/src/
H A Dstream.rs27 self.sess.complete_io(self.sock)?; in complete_prior_io()
31 self.sess.complete_io(self.sock)?; in complete_prior_io()
50 self.sess.complete_io(self.sock)?.0 != 0 in read()
66 let _ = self.sess.complete_io(self.sock); in write()
76 self.sess.complete_io(self.sock)?; in flush()
/dports/games/abstreet/abstreet-0.2.9-49-g74aca40c0/cargo-crates/rustls-0.17.0/src/
H A Dstream.rs27 self.sess.complete_io(self.sock)?; in complete_prior_io()
31 self.sess.complete_io(self.sock)?; in complete_prior_io()
50 self.sess.complete_io(self.sock)?.0 != 0 in read()
66 let _ = self.sess.complete_io(self.sock); in write()
76 self.sess.complete_io(self.sock)?; in flush()
/dports/databases/mariadb105-client/mariadb-10.5.15/libmariadb/plugins/pvio/
H A Dpvio_npipe.c118 static BOOL complete_io(HANDLE file, OVERLAPPED *ov, BOOL ret, DWORD timeout, DWORD *size) in complete_io() function
166 ret= complete_io(cpipe->pipe, &cpipe->overlapped, ret, pvio->timeout[PVIO_READ_TIMEOUT], &size); in pvio_npipe_read()
185 ret= complete_io(cpipe->pipe, &cpipe->overlapped, ret, pvio->timeout[PVIO_WRITE_TIMEOUT], &size); in pvio_npipe_write()
/dports/databases/mariadb104-server/mariadb-10.4.24/libmariadb/plugins/pvio/
H A Dpvio_npipe.c118 static BOOL complete_io(HANDLE file, OVERLAPPED *ov, BOOL ret, DWORD timeout, DWORD *size) in complete_io() function
166 ret= complete_io(cpipe->pipe, &cpipe->overlapped, ret, pvio->timeout[PVIO_READ_TIMEOUT], &size); in pvio_npipe_read()
185 ret= complete_io(cpipe->pipe, &cpipe->overlapped, ret, pvio->timeout[PVIO_WRITE_TIMEOUT], &size); in pvio_npipe_write()
/dports/databases/mariadb104-client/mariadb-10.4.24/libmariadb/plugins/pvio/
H A Dpvio_npipe.c118 static BOOL complete_io(HANDLE file, OVERLAPPED *ov, BOOL ret, DWORD timeout, DWORD *size) in complete_io() function
166 ret= complete_io(cpipe->pipe, &cpipe->overlapped, ret, pvio->timeout[PVIO_READ_TIMEOUT], &size); in pvio_npipe_read()
185 ret= complete_io(cpipe->pipe, &cpipe->overlapped, ret, pvio->timeout[PVIO_WRITE_TIMEOUT], &size); in pvio_npipe_write()
/dports/databases/mariadb103-server/mariadb-10.3.34/libmariadb/plugins/pvio/
H A Dpvio_npipe.c118 static BOOL complete_io(HANDLE file, OVERLAPPED *ov, BOOL ret, DWORD timeout, DWORD *size) in complete_io() function
166 ret= complete_io(cpipe->pipe, &cpipe->overlapped, ret, pvio->timeout[PVIO_READ_TIMEOUT], &size); in pvio_npipe_read()
185 ret= complete_io(cpipe->pipe, &cpipe->overlapped, ret, pvio->timeout[PVIO_WRITE_TIMEOUT], &size); in pvio_npipe_write()
/dports/databases/mariadb103-client/mariadb-10.3.34/libmariadb/plugins/pvio/
H A Dpvio_npipe.c118 static BOOL complete_io(HANDLE file, OVERLAPPED *ov, BOOL ret, DWORD timeout, DWORD *size) in complete_io() function
166 ret= complete_io(cpipe->pipe, &cpipe->overlapped, ret, pvio->timeout[PVIO_READ_TIMEOUT], &size); in pvio_npipe_read()
185 ret= complete_io(cpipe->pipe, &cpipe->overlapped, ret, pvio->timeout[PVIO_WRITE_TIMEOUT], &size); in pvio_npipe_write()
/dports/databases/mariadb-connector-c/mariadb-connector-c-3.2.4-src/plugins/pvio/
H A Dpvio_npipe.c118 static BOOL complete_io(HANDLE file, OVERLAPPED *ov, BOOL ret, DWORD timeout, DWORD *size) in complete_io() function
166 ret= complete_io(cpipe->pipe, &cpipe->overlapped, ret, pvio->timeout[PVIO_READ_TIMEOUT], &size); in pvio_npipe_read()
185 ret= complete_io(cpipe->pipe, &cpipe->overlapped, ret, pvio->timeout[PVIO_WRITE_TIMEOUT], &size); in pvio_npipe_write()
/dports/databases/mariadb105-server/mariadb-10.5.15/libmariadb/plugins/pvio/
H A Dpvio_npipe.c118 static BOOL complete_io(HANDLE file, OVERLAPPED *ov, BOOL ret, DWORD timeout, DWORD *size) in complete_io() function
166 ret= complete_io(cpipe->pipe, &cpipe->overlapped, ret, pvio->timeout[PVIO_READ_TIMEOUT], &size); in pvio_npipe_read()
185 ret= complete_io(cpipe->pipe, &cpipe->overlapped, ret, pvio->timeout[PVIO_WRITE_TIMEOUT], &size); in pvio_npipe_write()
/dports/security/acmed/acmed-0.18.0/cargo-crates/attohttpc-0.17.0/src/tls/
H A Drustls_impl.rs67 while let Err(err) = session.complete_io(&mut stream) { in handshake()
94 self.inner.sess.complete_io(&mut self.inner.sock)?; in handle_close_notify()
/dports/security/vaultwarden/vaultwarden-1.23.1/cargo-crates/rustls-0.17.0/tests/
H A Dapi.rs956 let (rdlen, wrlen) = client.complete_io(&mut OtherSession::new(&mut server)).unwrap(); in client_complete_io_for_handshake()
967 let err = client.complete_io(&mut input).unwrap_err(); in client_complete_io_for_handshake_eof()
982 let (rdlen, wrlen) = client.complete_io(&mut pipe).unwrap(); in client_complete_io_for_write()
1000 let (rdlen, wrlen) = client.complete_io(&mut pipe).unwrap(); in client_complete_io_for_read()
1014 let (rdlen, wrlen) = server.complete_io(&mut OtherSession::new(&mut client)).unwrap(); in server_complete_io_for_handshake()
1026 let err = server.complete_io(&mut input).unwrap_err(); in server_complete_io_for_handshake_eof()
1041 let (rdlen, wrlen) = server.complete_io(&mut pipe).unwrap(); in server_complete_io_for_write()
1059 let (rdlen, wrlen) = server.complete_io(&mut pipe).unwrap(); in server_complete_io_for_read()
1354 let rc = server.complete_io(&mut pipe); in server_complete_io_for_handshake_ending_with_alert()
/dports/security/rustscan/RustScan-2.0.1/cargo-crates/rustls-0.17.0/tests/
H A Dapi.rs956 let (rdlen, wrlen) = client.complete_io(&mut OtherSession::new(&mut server)).unwrap(); in client_complete_io_for_handshake()
967 let err = client.complete_io(&mut input).unwrap_err(); in client_complete_io_for_handshake_eof()
982 let (rdlen, wrlen) = client.complete_io(&mut pipe).unwrap(); in client_complete_io_for_write()
1000 let (rdlen, wrlen) = client.complete_io(&mut pipe).unwrap(); in client_complete_io_for_read()
1014 let (rdlen, wrlen) = server.complete_io(&mut OtherSession::new(&mut client)).unwrap(); in server_complete_io_for_handshake()
1026 let err = server.complete_io(&mut input).unwrap_err(); in server_complete_io_for_handshake_eof()
1041 let (rdlen, wrlen) = server.complete_io(&mut pipe).unwrap(); in server_complete_io_for_write()
1059 let (rdlen, wrlen) = server.complete_io(&mut pipe).unwrap(); in server_complete_io_for_read()
1354 let rc = server.complete_io(&mut pipe); in server_complete_io_for_handshake_ending_with_alert()

1234