s3-rpc_server: Add npa_state_init() function.

Signed-off-by: Andreas Schneider <asn@samba.org>
Reviewed-by: Stefan Metzmacher <metze@samba.org>

diff --git a/source3/rpc_server/rpc_ncacn_np.c b/source3/rpc_server/rpc_ncacn_np.c
index c58f97dec9879fe5131c6d792df993c0a82f5b10..f2c45d9b11d3729ba0944e33152da063791cbd96 100644 (file)
--- a/source3/rpc_server/rpc_ncacn_np.c
+++ b/source3/rpc_server/rpc_ncacn_np.c
@@ -41,6 +41,33 @@
 #undef DBGC_CLASS
 #define DBGC_CLASS DBGC_RPC_SRV
 
+static struct npa_state *npa_state_init(TALLOC_CTX *mem_ctx)
+{
+       struct npa_state *npa;
+
+       npa = talloc_zero(mem_ctx, struct npa_state);
+       if (npa == NULL) {
+               return NULL;
+       }
+
+       npa->read_queue = tevent_queue_create(npa, "npa_cli_read");
+       if (npa->read_queue == NULL) {
+               DEBUG(0, ("tevent_queue_create failed\n"));
+               goto fail;
+       }
+
+       npa->write_queue = tevent_queue_create(npa, "npa_cli_write");
+       if (npa->write_queue == NULL) {
+               DEBUG(0, ("tevent_queue_create failed\n"));
+               goto fail;
+       }
+
+       return npa;
+fail:
+       talloc_free(npa);
+       return NULL;
+}
+
 /****************************************************************************
  Make an internal namedpipes structure
 ****************************************************************************/

diff --git a/source3/rpc_server/rpc_ncacn_np.h b/source3/rpc_server/rpc_ncacn_np.h
index 67cd8a1285400bba3b4e94ad24c561fd9ce29b81..2665b7f590259368ae30a80841389230cb1eba6a 100644 (file)
--- a/source3/rpc_server/rpc_ncacn_np.h
+++ b/source3/rpc_server/rpc_ncacn_np.h
@@ -24,6 +24,19 @@ struct dcerpc_binding_handle;
 struct ndr_interface_table;
 struct tsocket_address;
 
+struct npa_state {
+       struct tstream_context *stream;
+
+       struct tevent_queue *read_queue;
+       struct tevent_queue *write_queue;
+
+       uint64_t allocation_size;
+       uint16_t device_state;
+       uint16_t file_type;
+
+       void *private_data;
+};
+
 struct np_proxy_state {
        uint16_t file_type;
        uint16_t device_state;