diff options
| author | Stefan Metzmacher <metze@samba.org> | 2019-08-29 10:28:14 +0000 |
|---|---|---|
| committer | Stefan Metzmacher <metze@samba.org> | 2020-12-17 13:59:38 +0000 |
| commit | 560e4b1b32f56ed4cfffc60efd9199ed435409ba (patch) | |
| tree | e4891b9a2ba67112ddd79e31766c665ce9381fb0 /libcli | |
| parent | 76121ae7cf4967329b9745137999fde00309c987 (diff) | |
| download | samba-560e4b1b32f56ed4cfffc60efd9199ed435409ba.tar.gz | |
libcli/smb: add smbXcli_conn_send_queue()
This is useful in order to test async requests
tevent_queue_wait_send/recv() can be used to block
the queue between requests or wait for the queue to be flushed.
Signed-off-by: Stefan Metzmacher <metze@samba.org>
Reviewed-by: Jeremy Allison <jra@samba.org>
Diffstat (limited to 'libcli')
| -rw-r--r-- | libcli/smb/smbXcli_base.c | 5 | ||||
| -rw-r--r-- | libcli/smb/smbXcli_base.h | 1 |
2 files changed, 6 insertions, 0 deletions
diff --git a/libcli/smb/smbXcli_base.c b/libcli/smb/smbXcli_base.c index df80be6bf16..0fc4aa4451a 100644 --- a/libcli/smb/smbXcli_base.c +++ b/libcli/smb/smbXcli_base.c @@ -2743,6 +2743,11 @@ NTSTATUS smb1cli_req_chain_submit(struct tevent_req **reqs, int num_reqs) return NT_STATUS_OK; } +struct tevent_queue *smbXcli_conn_send_queue(struct smbXcli_conn *conn) +{ + return conn->outgoing; +} + bool smbXcli_conn_has_async_calls(struct smbXcli_conn *conn) { return ((tevent_queue_length(conn->outgoing) != 0) diff --git a/libcli/smb/smbXcli_base.h b/libcli/smb/smbXcli_base.h index db5f5d58799..d9c3175bdf5 100644 --- a/libcli/smb/smbXcli_base.h +++ b/libcli/smb/smbXcli_base.h @@ -43,6 +43,7 @@ struct smbXcli_conn *smbXcli_conn_create(TALLOC_CTX *mem_ctx, bool smbXcli_conn_is_connected(struct smbXcli_conn *conn); void smbXcli_conn_disconnect(struct smbXcli_conn *conn, NTSTATUS status); +struct tevent_queue *smbXcli_conn_send_queue(struct smbXcli_conn *conn); bool smbXcli_conn_has_async_calls(struct smbXcli_conn *conn); bool smbXcli_conn_dfs_supported(struct smbXcli_conn *conn); |