2 Unix SMB/CIFS mplementation.
3 DSDB replication service outgoing Pull-Replication
5 Copyright (C) Stefan Metzmacher 2007
7 This program is free software; you can redistribute it and/or modify
8 it under the terms of the GNU General Public License as published by
9 the Free Software Foundation; either version 3 of the License, or
10 (at your option) any later version.
12 This program is distributed in the hope that it will be useful,
13 but WITHOUT ANY WARRANTY; without even the implied warranty of
14 MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
15 GNU General Public License for more details.
17 You should have received a copy of the GNU General Public License
18 along with this program. If not, see <http://www.gnu.org/licenses/>.
23 #include "dsdb/samdb/samdb.h"
24 #include "auth/auth.h"
25 #include "smbd/service.h"
26 #include "lib/events/events.h"
27 #include "lib/messaging/irpc.h"
28 #include "dsdb/repl/drepl_service.h"
29 #include "lib/ldb/include/ldb_errors.h"
30 #include "../lib/util/dlinklist.h"
31 #include "librpc/gen_ndr/ndr_misc.h"
32 #include "librpc/gen_ndr/ndr_drsuapi.h"
33 #include "librpc/gen_ndr/ndr_drsblobs.h"
34 #include "libcli/composite/composite.h"
36 static WERROR
dreplsrv_schedule_partition_pull_source(struct dreplsrv_service
*s
,
37 struct dreplsrv_partition
*p
,
38 struct dreplsrv_partition_source_dsa
*source
,
41 struct dreplsrv_out_operation
*op
;
43 op
= talloc_zero(mem_ctx
, struct dreplsrv_out_operation
);
44 W_ERROR_HAVE_NO_MEMORY(op
);
47 op
->source_dsa
= source
;
49 DLIST_ADD_END(s
->ops
.pending
, op
, struct dreplsrv_out_operation
*);
54 static WERROR
dreplsrv_schedule_partition_pull(struct dreplsrv_service
*s
,
55 struct dreplsrv_partition
*p
,
59 struct dreplsrv_partition_source_dsa
*cur
;
61 for (cur
= p
->sources
; cur
; cur
= cur
->next
) {
62 status
= dreplsrv_schedule_partition_pull_source(s
, p
, cur
, mem_ctx
);
63 W_ERROR_NOT_OK_RETURN(status
);
69 WERROR
dreplsrv_schedule_pull_replication(struct dreplsrv_service
*s
, TALLOC_CTX
*mem_ctx
)
72 struct dreplsrv_partition
*p
;
74 for (p
= s
->partitions
; p
; p
= p
->next
) {
75 status
= dreplsrv_schedule_partition_pull(s
, p
, mem_ctx
);
76 W_ERROR_NOT_OK_RETURN(status
);
83 /* force an immediate of the specified partition by GUID */
84 WERROR
dreplsrv_schedule_partition_pull_by_guid(struct dreplsrv_service
*s
, TALLOC_CTX
*mem_ctx
,
87 struct dreplsrv_partition
*p
;
89 for (p
= s
->partitions
; p
; p
= p
->next
) {
90 if (GUID_compare(&p
->nc
.guid
, guid
) == 0) {
91 return dreplsrv_schedule_partition_pull(s
, p
, mem_ctx
);
95 return WERR_NOT_FOUND
;
98 static void dreplsrv_pending_op_callback(struct dreplsrv_out_operation
*op
)
100 struct repsFromTo1
*rf
= op
->source_dsa
->repsFrom1
;
101 struct dreplsrv_service
*s
= op
->service
;
106 unix_to_nt_time(&now
, t
);
108 rf
->result_last_attempt
= dreplsrv_op_pull_source_recv(op
->creq
);
109 if (W_ERROR_IS_OK(rf
->result_last_attempt
)) {
110 rf
->consecutive_sync_failures
= 0;
111 rf
->last_success
= now
;
112 DEBUG(2,("dreplsrv_op_pull_source(%s)\n",
113 win_errstr(rf
->result_last_attempt
)));
117 rf
->consecutive_sync_failures
++;
119 DEBUG(1,("dreplsrv_op_pull_source(%s/%s) failures[%u]\n",
120 win_errstr(rf
->result_last_attempt
),
121 nt_errstr(werror_to_ntstatus(rf
->result_last_attempt
)),
122 rf
->consecutive_sync_failures
));
126 s
->ops
.current
= NULL
;
127 dreplsrv_run_pending_ops(s
);
130 static void dreplsrv_pending_op_callback_creq(struct composite_context
*creq
)
132 struct dreplsrv_out_operation
*op
= talloc_get_type(creq
->async
.private_data
,
133 struct dreplsrv_out_operation
);
134 dreplsrv_pending_op_callback(op
);
137 void dreplsrv_run_pending_ops(struct dreplsrv_service
*s
)
139 struct dreplsrv_out_operation
*op
;
143 if (s
->ops
.current
) {
144 /* if there's still one running, we're done */
148 if (!s
->ops
.pending
) {
149 /* if there're no pending operations, we're done */
154 unix_to_nt_time(&now
, t
);
158 DLIST_REMOVE(s
->ops
.pending
, op
);
160 op
->source_dsa
->repsFrom1
->last_attempt
= now
;
162 op
->creq
= dreplsrv_op_pull_source_send(op
);
164 dreplsrv_pending_op_callback(op
);
168 op
->creq
->async
.fn
= dreplsrv_pending_op_callback_creq
;
169 op
->creq
->async
.private_data
= op
;