Home
last modified time | relevance | path

Searched refs:write_bufs (Results 1 – 25 of 124) sorted by relevance

12345

/dports/security/sudo/sudo-1.9.8p2/logsrvd/
H A Dlogsrvd_relay.c98 while ((buf = TAILQ_FIRST(&relay_closure->write_bufs)) != NULL) { in relay_closure_free()
99 TAILQ_REMOVE(&relay_closure->write_bufs, buf, entries); in relay_closure_free()
129 TAILQ_INIT(&relay_closure->write_bufs); in relay_closure_alloc()
177 TAILQ_INSERT_TAIL(&relay_closure->write_bufs, buf, entries); in relay_enqueue_write()
225 TAILQ_INSERT_TAIL(&relay_closure->write_bufs, buf, entries); in fmt_client_message()
909 if ((buf = TAILQ_FIRST(&relay_closure->write_bufs)) == NULL) { in relay_client_msg_cb()
986 TAILQ_REMOVE(&relay_closure->write_bufs, buf, entries); in relay_client_msg_cb()
988 if (TAILQ_EMPTY(&relay_closure->write_bufs)) in relay_client_msg_cb()
1232 TAILQ_EMPTY(&relay_closure->write_bufs)) { in relay_shutdown()
H A Dlogsrvd.h70 struct connection_buffer_list write_bufs; member
91 struct connection_buffer_list write_bufs; member
H A Dlogsrvd.c143 while ((buf = TAILQ_FIRST(&closure->write_bufs)) != NULL) { in connection_closure_free()
146 TAILQ_REMOVE(&closure->write_bufs, buf, entries); in connection_closure_free()
183 TAILQ_INIT(&closure->write_bufs); in connection_closure_alloc()
350 TAILQ_INSERT_TAIL(&closure->write_bufs, buf, entries); in fmt_server_message()
893 if ((buf = TAILQ_FIRST(&closure->write_bufs)) == NULL) { in server_msg_cb()
948 TAILQ_REMOVE(&closure->write_bufs, buf, entries); in server_msg_cb()
950 if (TAILQ_EMPTY(&closure->write_bufs)) { in server_msg_cb()
/dports/multimedia/v4l_compat/linux-5.13-rc2/drivers/spi/
H A Dspi-sprd.c170 int (*write_bufs)(struct sprd_spi *ss, u32 len); member
413 write_size += ss->write_bufs(ss, len); in sprd_spi_txrx_bufs()
433 write_size += ss->write_bufs(ss, len); in sprd_spi_txrx_bufs()
608 write_size = ss->write_bufs(ss, trans_len); in sprd_spi_dma_txrx_bufs()
745 ss->write_bufs = sprd_spi_write_bufs_u8; in sprd_spi_setup_transfer()
752 ss->write_bufs = sprd_spi_write_bufs_u16; in sprd_spi_setup_transfer()
759 ss->write_bufs = sprd_spi_write_bufs_u32; in sprd_spi_setup_transfer()
784 ss->write_bufs = sprd_spi_write_only_receive; in sprd_spi_setup_transfer()
/dports/multimedia/libv4l/linux-5.13-rc2/drivers/spi/
H A Dspi-sprd.c170 int (*write_bufs)(struct sprd_spi *ss, u32 len); member
413 write_size += ss->write_bufs(ss, len); in sprd_spi_txrx_bufs()
433 write_size += ss->write_bufs(ss, len); in sprd_spi_txrx_bufs()
608 write_size = ss->write_bufs(ss, trans_len); in sprd_spi_dma_txrx_bufs()
745 ss->write_bufs = sprd_spi_write_bufs_u8; in sprd_spi_setup_transfer()
752 ss->write_bufs = sprd_spi_write_bufs_u16; in sprd_spi_setup_transfer()
759 ss->write_bufs = sprd_spi_write_bufs_u32; in sprd_spi_setup_transfer()
784 ss->write_bufs = sprd_spi_write_only_receive; in sprd_spi_setup_transfer()
/dports/multimedia/v4l-utils/linux-5.13-rc2/drivers/spi/
H A Dspi-sprd.c170 int (*write_bufs)(struct sprd_spi *ss, u32 len); member
413 write_size += ss->write_bufs(ss, len); in sprd_spi_txrx_bufs()
433 write_size += ss->write_bufs(ss, len); in sprd_spi_txrx_bufs()
608 write_size = ss->write_bufs(ss, trans_len); in sprd_spi_dma_txrx_bufs()
745 ss->write_bufs = sprd_spi_write_bufs_u8; in sprd_spi_setup_transfer()
752 ss->write_bufs = sprd_spi_write_bufs_u16; in sprd_spi_setup_transfer()
759 ss->write_bufs = sprd_spi_write_bufs_u32; in sprd_spi_setup_transfer()
784 ss->write_bufs = sprd_spi_write_only_receive; in sprd_spi_setup_transfer()
/dports/multimedia/scte35dump/scte35dump-0.1.6/cargo-crates/mio-0.6.19/test/
H A Dtest_udp_socket.rs192 let write_bufs: Vec<_> = vec![b"hello, " as &[u8], b"world"] in test_udp_socket_send_recv_bufs() localVariable
240 let cnt = match tx.send_bufs(write_bufs.as_slice()) { in test_udp_socket_send_recv_bufs()
/dports/sysutils/vector/vector-0.10.0/cargo-crates/mio-0.6.21/test/
H A Dtest_udp_socket.rs192 let write_bufs: Vec<_> = vec![b"hello, " as &[u8], b"world"] in test_udp_socket_send_recv_bufs() localVariable
240 let cnt = match tx.send_bufs(write_bufs.as_slice()) { in test_udp_socket_send_recv_bufs()
/dports/www/geckodriver/mozilla-central-e9783a644016aa9b317887076618425586730d73/testing/geckodriver/cargo-crates/mio-0.6.19/test/
H A Dtest_udp_socket.rs192 let write_bufs: Vec<_> = vec![b"hello, " as &[u8], b"world"] in test_udp_socket_send_recv_bufs() localVariable
240 let cnt = match tx.send_bufs(write_bufs.as_slice()) { in test_udp_socket_send_recv_bufs()
/dports/editors/xi-term/xi-term-d264767/cargo-crates/mio-0.6.19/test/
H A Dtest_udp_socket.rs192 let write_bufs: Vec<_> = vec![b"hello, " as &[u8], b"world"] in test_udp_socket_send_recv_bufs() localVariable
240 let cnt = match tx.send_bufs(write_bufs.as_slice()) { in test_udp_socket_send_recv_bufs()
/dports/games/abstreet/abstreet-0.2.9-49-g74aca40c0/cargo-crates/mio-0.6.21/test/
H A Dtest_udp_socket.rs192 let write_bufs: Vec<_> = vec![b"hello, " as &[u8], b"world"] in test_udp_socket_send_recv_bufs() localVariable
240 let cnt = match tx.send_bufs(write_bufs.as_slice()) { in test_udp_socket_send_recv_bufs()
/dports/editors/xi-core/xi-editor-0.3.0/rust/cargo-crates/mio-0.6.19/test/
H A Dtest_udp_socket.rs192 let write_bufs: Vec<_> = vec![b"hello, " as &[u8], b"world"] in test_udp_socket_send_recv_bufs() localVariable
240 let cnt = match tx.send_bufs(write_bufs.as_slice()) { in test_udp_socket_send_recv_bufs()
/dports/sysutils/rsfetch/rsfetch-2.0.0/cargo-crates/mio-0.6.21/test/
H A Dtest_udp_socket.rs192 let write_bufs: Vec<_> = vec![b"hello, " as &[u8], b"world"] in test_udp_socket_send_recv_bufs() localVariable
240 let cnt = match tx.send_bufs(write_bufs.as_slice()) { in test_udp_socket_send_recv_bufs()
/dports/lang/spidermonkey78/firefox-78.9.0/third_party/rust/mio/test/
H A Dtest_udp_socket.rs192 let write_bufs: Vec<_> = vec![b"hello, " as &[u8], b"world"] in test_udp_socket_send_recv_bufs() localVariable
240 let cnt = match tx.send_bufs(write_bufs.as_slice()) { in test_udp_socket_send_recv_bufs()
/dports/sysutils/flowgger/flowgger-0.2.10/cargo-crates/mio-0.6.19/test/
H A Dtest_udp_socket.rs192 let write_bufs: Vec<_> = vec![b"hello, " as &[u8], b"world"]
240 let cnt = match tx.send_bufs(write_bufs.as_slice()) {
/dports/audio/spotifyd/spotifyd-0.3.0/cargo-crates/mio-0.6.21/test/
H A Dtest_udp_socket.rs192 let write_bufs: Vec<_> = vec![b"hello, " as &[u8], b"world"] in test_udp_socket_send_recv_bufs() localVariable
240 let cnt = match tx.send_bufs(write_bufs.as_slice()) { in test_udp_socket_send_recv_bufs()
/dports/security/sudo/sudo-1.9.8p2/plugins/sudoers/
H A Dlog_client.h100 struct connection_buffer_list write_bufs; member
H A Dlog_client.c647 while ((buf = TAILQ_FIRST(&closure->write_bufs)) != NULL) { in client_closure_free()
648 TAILQ_REMOVE(&closure->write_bufs, buf, entries); in client_closure_free()
729 TAILQ_INSERT_TAIL(&closure->write_bufs, buf, entries); in fmt_client_message()
1856 if ((buf = TAILQ_FIRST(&closure->write_bufs)) == NULL) { in client_msg_cb()
1917 TAILQ_REMOVE(&closure->write_bufs, buf, entries); in client_msg_cb()
1919 if (TAILQ_EMPTY(&closure->write_bufs)) { in client_msg_cb()
1969 TAILQ_INIT(&closure->write_bufs); in client_closure_alloc()
/dports/sysutils/vector/vector-0.10.0/cargo-crates/mio-uds-0.6.7/tests/
H A Dsmoke.rs88 assert_eq!(t!(a.write_bufs(&vecs)), send.len()); in stream_iovec()
/dports/editors/xi-term/xi-term-d264767/cargo-crates/mio-uds-0.6.7/tests/
H A Dsmoke.rs88 assert_eq!(t!(a.write_bufs(&vecs)), send.len()); in stream_iovec()
/dports/games/abstreet/abstreet-0.2.9-49-g74aca40c0/cargo-crates/mio-uds-0.6.7/tests/
H A Dsmoke.rs88 assert_eq!(t!(a.write_bufs(&vecs)), send.len()); in stream_iovec()
/dports/www/geckodriver/mozilla-central-e9783a644016aa9b317887076618425586730d73/testing/geckodriver/cargo-crates/mio-uds-0.6.7/tests/
H A Dsmoke.rs88 assert_eq!(t!(a.write_bufs(&vecs)), send.len()); in stream_iovec()
/dports/lang/spidermonkey78/firefox-78.9.0/third_party/rust/mio-uds/tests/
H A Dsmoke.rs88 assert_eq!(t!(a.write_bufs(&vecs)), send.len()); in stream_iovec()
/dports/audio/spotifyd/spotifyd-0.3.0/cargo-crates/mio-uds-0.6.7/tests/
H A Dsmoke.rs88 assert_eq!(t!(a.write_bufs(&vecs)), send.len()); in stream_iovec()
/dports/lang/spidermonkey60/firefox-60.9.0/third_party/rust/tokio-core/src/net/
H A Dtcp.rs476 let r = self.io.get_ref().write_bufs(bufs); in write_vec()
548 self.io.get_ref().write_bufs(&bufs[..n]) in write_buf()

12345