summaryrefslogtreecommitdiff
path: root/source3
diff options
context:
space:
mode:
authorVolker Lendecke <vl@samba.org>2009-01-22 18:50:37 +0100
committerVolker Lendecke <vl@samba.org>2009-01-22 22:59:53 +0100
commit42fa1441bf17ae486ebca5553e503242a653c92c (patch)
tree7ed18d9ab1c0d8acaff36170a0c615b67aa44110 /source3
parent1fcd85e8b9235301c7bc6c4c0878e73ddcbd4b16 (diff)
downloadsamba-42fa1441bf17ae486ebca5553e503242a653c92c.tar.gz
samba-42fa1441bf17ae486ebca5553e503242a653c92c.tar.bz2
samba-42fa1441bf17ae486ebca5553e503242a653c92c.zip
Add struct rpc_cli_transport
Diffstat (limited to 'source3')
-rw-r--r--source3/include/client.h50
1 files changed, 50 insertions, 0 deletions
diff --git a/source3/include/client.h b/source3/include/client.h
index 09fdb81462..c47f058318 100644
--- a/source3/include/client.h
+++ b/source3/include/client.h
@@ -61,6 +61,56 @@ struct cli_pipe_auth_data {
} a_u;
};
+/**
+ * rpc_cli_transport defines a transport mechanism to ship rpc requests
+ * asynchronously to a server and receive replies
+ */
+
+struct rpc_cli_transport {
+
+ /**
+ * Trigger an async read from the server. May return a short read.
+ */
+ struct async_req *(*read_send)(TALLOC_CTX *mem_ctx,
+ struct event_context *ev,
+ uint8_t *data, size_t size,
+ void *priv);
+ /**
+ * Get the result from the read_send operation.
+ */
+ NTSTATUS (*read_recv)(struct async_req *req, ssize_t *preceived);
+
+ /**
+ * Trigger an async write to the server. May return a short write.
+ */
+ struct async_req *(*write_send)(TALLOC_CTX *mem_ctx,
+ struct event_context *ev,
+ const uint8_t *data, size_t size,
+ void *priv);
+ /**
+ * Get the result from the read_send operation.
+ */
+ NTSTATUS (*write_recv)(struct async_req *req, ssize_t *psent);
+
+ /**
+ * This is an optimization for the SMB transport. It models the
+ * TransactNamedPipe API call: Send and receive data in one round
+ * trip. The transport implementation is free to set this to NULL,
+ * cli_pipe.c will fall back to the explicit write/read routines.
+ */
+ struct async_req *(*trans_send)(TALLOC_CTX *mem_ctx,
+ struct event_context *ev,
+ uint8_t *data, size_t data_len,
+ uint32_t max_rdata_len,
+ void *priv);
+ /**
+ * Get the result from the read_send operation.
+ */
+ NTSTATUS (*trans_recv)(struct async_req *req, TALLOC_CTX *mem_ctx,
+ uint8_t **prdata, uint32_t *prdata_len);
+ void *priv;
+};
+
struct rpc_pipe_client {
struct rpc_pipe_client *prev, *next;