r2185: add a callback function to the dcerpc async API

also add a demonstration of its use in the netlogon async example
(This used to be commit f2a0438c66b999189c1a2ad726e91efd0748eb90)

1 files changed, 20 insertions, 0 deletions

diff --git a/source4/librpc/rpc/dcerpc.c b/source4/librpc/rpc/dcerpc.c
index ec22696419..55acf4625c 100644
--- a/source4/librpc/rpc/dcerpc.c
+++ b/source4/librpc/rpc/dcerpc.c
@@ -631,6 +631,9 @@ static void dcerpc_request_recv_data(struct dcerpc_pipe *p,
 			req->state = RPC_REQUEST_DONE;
 			req->status = status;
 			DLIST_REMOVE(p->pending, req);
+			if (req->async.callback) {
+				req->async.callback(req);
+			}
 		}
 		return;
 	}
@@ -655,6 +658,9 @@ static void dcerpc_request_recv_data(struct dcerpc_pipe *p,
 		req->status = status;
 		req->state = RPC_REQUEST_DONE;
 		DLIST_REMOVE(p->pending, req);
+		if (req->async.callback) {
+			req->async.callback(req);
+		}
 		return;
 	}
 
@@ -664,6 +670,9 @@ static void dcerpc_request_recv_data(struct dcerpc_pipe *p,
 		req->status = NT_STATUS_NET_WRITE_FAULT;
 		req->state = RPC_REQUEST_DONE;
 		DLIST_REMOVE(p->pending, req);
+		if (req->async.callback) {
+			req->async.callback(req);
+		}
 		return;
 	}
 
@@ -674,6 +683,9 @@ static void dcerpc_request_recv_data(struct dcerpc_pipe *p,
 		req->status = NT_STATUS_NET_WRITE_FAULT;
 		req->state = RPC_REQUEST_DONE;
 		DLIST_REMOVE(p->pending, req);
+		if (req->async.callback) {
+			req->async.callback(req);
+		}
 		return;
 	}
 
@@ -686,6 +698,9 @@ static void dcerpc_request_recv_data(struct dcerpc_pipe *p,
 			req->status = NT_STATUS_NO_MEMORY;
 			req->state = RPC_REQUEST_DONE;
 			DLIST_REMOVE(p->pending, req);
+			if (req->async.callback) {
+				req->async.callback(req);
+			}
 			return;
 		}
 		memcpy(req->payload.data+req->payload.length, 
@@ -707,6 +722,10 @@ static void dcerpc_request_recv_data(struct dcerpc_pipe *p,
 	} else {
 		req->flags &= ~DCERPC_PULL_BIGENDIAN;
 	}
+
+	if (req->async.callback) {
+		req->async.callback(req);
+	}
 }
 
 
@@ -737,6 +756,7 @@ struct rpc_request *dcerpc_request_send(struct dcerpc_pipe *p,
 	req->payload = data_blob(NULL, 0);
 	req->flags = 0;
 	req->fault_code = 0;
+	req->async.callback = NULL;
 
 	init_dcerpc_hdr(p, &pkt);