summaryrefslogtreecommitdiff
path: root/source4/rpc_server/drsuapi
diff options
context:
space:
mode:
authorAndrew Tridgell <tridge@samba.org>2009-09-09 18:04:07 +1000
committerAndrew Tridgell <tridge@samba.org>2009-09-09 18:04:07 +1000
commit8640293fabb0fd0fe92b814411577dcdb449100d (patch)
treee9c67e1a8c115525e8dd351d3ee61386d42c3111 /source4/rpc_server/drsuapi
parent939b936d1af9a5221922864ad579bf50157b957b (diff)
downloadsamba-8640293fabb0fd0fe92b814411577dcdb449100d.tar.gz
samba-8640293fabb0fd0fe92b814411577dcdb449100d.tar.bz2
samba-8640293fabb0fd0fe92b814411577dcdb449100d.zip
s4/repl: implement DsReplicaSync
This patch implements DsReplicaSync by passing the call via irpc to the repl server task. The repl server then triggers an immediate replication of the specified partition. This means we no longer need to set a small value for dreplsrv:periodic_interval to force frequent DRS replication. We can now wait for the DC to send us a ReplicaSync msg for any partition that changes, and we immediately sync that partition.
Diffstat (limited to 'source4/rpc_server/drsuapi')
-rw-r--r--source4/rpc_server/drsuapi/dcesrv_drsuapi.c31
1 files changed, 26 insertions, 5 deletions
diff --git a/source4/rpc_server/drsuapi/dcesrv_drsuapi.c b/source4/rpc_server/drsuapi/dcesrv_drsuapi.c
index a9c7eb794a..73cc8cb1ef 100644
--- a/source4/rpc_server/drsuapi/dcesrv_drsuapi.c
+++ b/source4/rpc_server/drsuapi/dcesrv_drsuapi.c
@@ -29,6 +29,7 @@
#include "lib/ldb/include/ldb_errors.h"
#include "param/param.h"
#include "librpc/gen_ndr/ndr_drsblobs.h"
+#include "messaging/irpc.h"
/*
drsuapi_DsBind
@@ -228,12 +229,32 @@ static WERROR dcesrv_drsuapi_DsUnbind(struct dcesrv_call_state *dce_call, TALLOC
drsuapi_DsReplicaSync
*/
static WERROR dcesrv_drsuapi_DsReplicaSync(struct dcesrv_call_state *dce_call, TALLOC_CTX *mem_ctx,
- struct drsuapi_DsReplicaSync *r)
+ struct drsuapi_DsReplicaSync *r)
{
- /* TODO: implement this call correct!
- * for now we just say yes,
- * because we have no output parameter
- */
+ struct server_id *repld;
+ struct irpc_request *ireq;
+
+ if (DEBUGLVL(4)) {
+ NDR_PRINT_IN_DEBUG(drsuapi_DsReplicaSync, r);
+ }
+
+ repld = irpc_servers_byname(dce_call->msg_ctx, mem_ctx, "dreplsrv");
+ if (repld == NULL || repld[0].id == 0) {
+ DEBUG(0,("DsReplicaSync: Unable to find dreplsrv task\n"));
+ return WERR_DS_DRA_INTERNAL_ERROR;
+ }
+
+ ireq = IRPC_CALL_SEND(dce_call->msg_ctx, repld[0],
+ drsuapi, DRSUAPI_DSREPLICASYNC,
+ r, mem_ctx);
+ if (ireq == NULL) {
+ DEBUG(0,("DsReplicaSync: Failed to forward request to dreplsrv task\n"));
+ return WERR_DS_DRA_INTERNAL_ERROR;
+ }
+
+ /* we are not interested in a reply */
+ talloc_free(ireq);
+
return WERR_OK;
}