sin/samba-mirror
1
0
Fork 0
mirror of https://github.com/samba-team/samba.git synced 2024-12-25 23:21:54 +03:00
Code
420fae5dcb
samba-mirror/source4/wrepl_server/wrepl_periodic.c

Ignoring revisions in .git-blame-ignore-revs. Click here to bypass and see the normal blame view.

119 lines
3.3 KiB
C
Raw Normal View History

r12230: prepare for a generic periodic processing scheduling of pull,push,scavenging and reread-config events metze (This used to be commit 977117278c4b9fc1b7845b6aa6d5862e5a776651)
2005-12-14 13:56:43 +03:00
/*
Unix SMB/CIFS implementation.
WINS Replication server
Copyright (C) Stefan Metzmacher 2005
This program is free software; you can redistribute it and/or modify
it under the terms of the GNU General Public License as published by
r23792: convert Samba4 to GPLv3 There are still a few tidyups of old FSF addresses to come (in both s3 and s4). More commits soon. (This used to be commit fcf38a38ac691abd0fa51b89dc951a08e89fdafa)
2007-07-10 06:07:03 +04:00
the Free Software Foundation; either version 3 of the License, or
r12230: prepare for a generic periodic processing scheduling of pull,push,scavenging and reread-config events metze (This used to be commit 977117278c4b9fc1b7845b6aa6d5862e5a776651)
2005-12-14 13:56:43 +03:00
(at your option) any later version.
This program is distributed in the hope that it will be useful,
but WITHOUT ANY WARRANTY; without even the implied warranty of
MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
GNU General Public License for more details.
You should have received a copy of the GNU General Public License
r23792: convert Samba4 to GPLv3 There are still a few tidyups of old FSF addresses to come (in both s3 and s4). More commits soon. (This used to be commit fcf38a38ac691abd0fa51b89dc951a08e89fdafa)
2007-07-10 06:07:03 +04:00
along with this program. If not, see <http://www.gnu.org/licenses/>.
r12230: prepare for a generic periodic processing scheduling of pull,push,scavenging and reread-config events metze (This used to be commit 977117278c4b9fc1b7845b6aa6d5862e5a776651)
2005-12-14 13:56:43 +03:00
*/
#include "includes.h"
#include "lib/events/events.h"
s4: rename source4/smbd/ to source4/samba/ Signed-off-by: Ralph Boehme <slow@samba.org> Reviewed-by: Andrew Bartlett <abartlet@samba.org> Autobuild-User(master): Ralph Böhme <slow@samba.org> Autobuild-Date(master): Fri Nov 27 10:07:18 UTC 2020 on sn-devel-184
2020-11-20 17:27:17 +03:00
#include "samba/service_task.h"
#include "samba/service.h"
r14464: Don't include ndr_BASENAME.h files unless strictly required, instead try to include just the BASENAME.h files (containing only structs) (This used to be commit 3dd477ca5147f28a962b8437e2611a8222d706bd)
2006-03-16 03:23:11 +03:00
#include "librpc/gen_ndr/winsrepl.h"
r12230: prepare for a generic periodic processing scheduling of pull,push,scavenging and reread-config events metze (This used to be commit 977117278c4b9fc1b7845b6aa6d5862e5a776651)
2005-12-14 13:56:43 +03:00
#include "wrepl_server/wrepl_server.h"
r12372: - make the periodic scheduling a bit easier, instead of passing an uint32_t next_interval everywhere, we now call wreplsrv_periodic_schedule() if we want to schedule an event - also prevent us from looping with a 0 interval, by using 1s as minimum interval metze (This used to be commit b6943b11fc6e501d5081d591336185518943ee5a)
2005-12-20 00:52:37 +03:00
static NTSTATUS wreplsrv_periodic_run(struct wreplsrv_service *service)
r12230: prepare for a generic periodic processing scheduling of pull,push,scavenging and reread-config events metze (This used to be commit 977117278c4b9fc1b7845b6aa6d5862e5a776651)
2005-12-14 13:56:43 +03:00
{
r12372: - make the periodic scheduling a bit easier, instead of passing an uint32_t next_interval everywhere, we now call wreplsrv_periodic_schedule() if we want to schedule an event - also prevent us from looping with a 0 interval, by using 1s as minimum interval metze (This used to be commit b6943b11fc6e501d5081d591336185518943ee5a)
2005-12-20 00:52:37 +03:00
NTSTATUS status;
r12702: - reload the partner configuration, when the sequenceNumber of the wins_config.ldb changes - use a periodic run interval of 15 secs per default, as we no longer send push notifies with each run metze (This used to be commit 0382b3135c770847be33fbf8ee500f2c0bf265e2)
2006-01-03 23:19:39 +03:00
status = wreplsrv_load_partners(service);
NT_STATUS_NOT_OK_RETURN(status);
r12434: implement database scavenging, the only missing part is the verifying of active replicas with the owning wins server, after the verify interval passes. metze (This used to be commit 7d1f7ae9c65c09f8bf72e159b771f231f96e8591)
2005-12-22 14:40:14 +03:00
status = wreplsrv_scavenging_run(service);
NT_STATUS_NOT_OK_RETURN(status);
r12391: use the new periodic schedule system for the pull replication too metze (This used to be commit 3383568c31545a6716eb7045b56d516d507c0b4d)
2005-12-20 03:55:28 +03:00
status = wreplsrv_out_pull_run(service);
NT_STATUS_NOT_OK_RETURN(status);
r12372: - make the periodic scheduling a bit easier, instead of passing an uint32_t next_interval everywhere, we now call wreplsrv_periodic_schedule() if we want to schedule an event - also prevent us from looping with a 0 interval, by using 1s as minimum interval metze (This used to be commit b6943b11fc6e501d5081d591336185518943ee5a)
2005-12-20 00:52:37 +03:00
status = wreplsrv_out_push_run(service);
NT_STATUS_NOT_OK_RETURN(status);
r12242: - make the push notifications triggered by the change count - for now we fake the change count to '1', so we'll still have periodicly triggered push notifies, the interval is the 'wreplsrv:periodic_interval=60' - add the 'pushUseInform' attribute to the wreplPartner objectClass to configure if we'll use WREPL_REPL_INFORM notifies metze (This used to be commit fa1a5660bb2ef7fabd72ad9b993dd91d59ac409e)
2005-12-14 22:19:43 +03:00
r12372: - make the periodic scheduling a bit easier, instead of passing an uint32_t next_interval everywhere, we now call wreplsrv_periodic_schedule() if we want to schedule an event - also prevent us from looping with a 0 interval, by using 1s as minimum interval metze (This used to be commit b6943b11fc6e501d5081d591336185518943ee5a)
2005-12-20 00:52:37 +03:00
return NT_STATUS_OK;
r12230: prepare for a generic periodic processing scheduling of pull,push,scavenging and reread-config events metze (This used to be commit 977117278c4b9fc1b7845b6aa6d5862e5a776651)
2005-12-14 13:56:43 +03:00
}
s4:lib/tevent: rename structs list="" list="$list event_context:tevent_context" list="$list fd_event:tevent_fd" list="$list timed_event:tevent_timer" for s in $list; do o=`echo $s | cut -d ':' -f1` n=`echo $s | cut -d ':' -f2` r=`git grep "struct $o" |cut -d ':' -f1 |sort -u` files=`echo "$r" | grep -v source3 | grep -v nsswitch | grep -v packaging4` for f in $files; do cat $f | sed -e "s/struct $o/struct $n/g" > $f.tmp mv $f.tmp $f done done metze
2008-12-29 22:24:57 +03:00
static void wreplsrv_periodic_handler_te(struct tevent_context *ev, struct tevent_timer *te,
r12230: prepare for a generic periodic processing scheduling of pull,push,scavenging and reread-config events metze (This used to be commit 977117278c4b9fc1b7845b6aa6d5862e5a776651)
2005-12-14 13:56:43 +03:00
struct timeval t, void *ptr)
{
struct wreplsrv_service *service = talloc_get_type(ptr, struct wreplsrv_service);
r12372: - make the periodic scheduling a bit easier, instead of passing an uint32_t next_interval everywhere, we now call wreplsrv_periodic_schedule() if we want to schedule an event - also prevent us from looping with a 0 interval, by using 1s as minimum interval metze (This used to be commit b6943b11fc6e501d5081d591336185518943ee5a)
2005-12-20 00:52:37 +03:00
NTSTATUS status;
r12230: prepare for a generic periodic processing scheduling of pull,push,scavenging and reread-config events metze (This used to be commit 977117278c4b9fc1b7845b6aa6d5862e5a776651)
2005-12-14 13:56:43 +03:00
service->periodic.te = NULL;
r12372: - make the periodic scheduling a bit easier, instead of passing an uint32_t next_interval everywhere, we now call wreplsrv_periodic_schedule() if we want to schedule an event - also prevent us from looping with a 0 interval, by using 1s as minimum interval metze (This used to be commit b6943b11fc6e501d5081d591336185518943ee5a)
2005-12-20 00:52:37 +03:00
status = wreplsrv_periodic_schedule(service, service->config.periodic_interval);
if (!NT_STATUS_IS_OK(status)) {
s4-server: kill main daemon if a task fails to initialise When one of our core tasks fails to initialise it can now ask for the server as a whole to die, rather than limping along in a degraded state.
2009-09-19 05:05:55 +04:00
task_server_terminate(service->task, nt_errstr(status), false);
r12230: prepare for a generic periodic processing scheduling of pull,push,scavenging and reread-config events metze (This used to be commit 977117278c4b9fc1b7845b6aa6d5862e5a776651)
2005-12-14 13:56:43 +03:00
return;
}
r12372: - make the periodic scheduling a bit easier, instead of passing an uint32_t next_interval everywhere, we now call wreplsrv_periodic_schedule() if we want to schedule an event - also prevent us from looping with a 0 interval, by using 1s as minimum interval metze (This used to be commit b6943b11fc6e501d5081d591336185518943ee5a)
2005-12-20 00:52:37 +03:00
status = wreplsrv_periodic_run(service);
if (!NT_STATUS_IS_OK(status)) {
DEBUG(0,("wresrv_periodic_run() failed: %s\n", nt_errstr(status)));
}
}
NTSTATUS wreplsrv_periodic_schedule(struct wreplsrv_service *service, uint32_t next_interval)
{
TALLOC_CTX *tmp_mem;
s4:lib/tevent: rename structs list="" list="$list event_context:tevent_context" list="$list fd_event:tevent_fd" list="$list timed_event:tevent_timer" for s in $list; do o=`echo $s | cut -d ':' -f1` n=`echo $s | cut -d ':' -f2` r=`git grep "struct $o" |cut -d ':' -f1 |sort -u` files=`echo "$r" | grep -v source3 | grep -v nsswitch | grep -v packaging4` for f in $files; do cat $f | sed -e "s/struct $o/struct $n/g" > $f.tmp mv $f.tmp $f done done metze
2008-12-29 22:24:57 +03:00
struct tevent_timer *new_te;
r12372: - make the periodic scheduling a bit easier, instead of passing an uint32_t next_interval everywhere, we now call wreplsrv_periodic_schedule() if we want to schedule an event - also prevent us from looping with a 0 interval, by using 1s as minimum interval metze (This used to be commit b6943b11fc6e501d5081d591336185518943ee5a)
2005-12-20 00:52:37 +03:00
struct timeval next_time;
/* prevent looping */
if (next_interval == 0) next_interval = 1;
r12391: use the new periodic schedule system for the pull replication too metze (This used to be commit 3383568c31545a6716eb7045b56d516d507c0b4d)
2005-12-20 03:55:28 +03:00
next_time = timeval_current_ofs(next_interval, 5000);
r12372: - make the periodic scheduling a bit easier, instead of passing an uint32_t next_interval everywhere, we now call wreplsrv_periodic_schedule() if we want to schedule an event - also prevent us from looping with a 0 interval, by using 1s as minimum interval metze (This used to be commit b6943b11fc6e501d5081d591336185518943ee5a)
2005-12-20 00:52:37 +03:00
if (service->periodic.te) {
/*
* if the timestamp of the new event is higher,
* as current next we don't need to reschedule
*/
if (timeval_compare(&next_time, &service->periodic.next_event) > 0) {
return NT_STATUS_OK;
}
}
/* reset the next scheduled timestamp */
service->periodic.next_event = next_time;
s4:misc: remove last usage of legacy event_ fn names Autobuild-User: Simo Sorce <idra@samba.org> Autobuild-Date: Sun Aug 14 00:38:13 CEST 2011 on sn-devel-104
2010-05-25 23:29:14 +04:00
new_te = tevent_add_timer(service->task->event_ctx, service,
r12372: - make the periodic scheduling a bit easier, instead of passing an uint32_t next_interval everywhere, we now call wreplsrv_periodic_schedule() if we want to schedule an event - also prevent us from looping with a 0 interval, by using 1s as minimum interval metze (This used to be commit b6943b11fc6e501d5081d591336185518943ee5a)
2005-12-20 00:52:37 +03:00
service->periodic.next_event,
wreplsrv_periodic_handler_te, service);
NT_STATUS_HAVE_NO_MEMORY(new_te);
tmp_mem = talloc_new(service);
r12702: - reload the partner configuration, when the sequenceNumber of the wins_config.ldb changes - use a periodic run interval of 15 secs per default, as we no longer send push notifies with each run metze (This used to be commit 0382b3135c770847be33fbf8ee500f2c0bf265e2)
2006-01-03 23:19:39 +03:00
DEBUG(6,("wreplsrv_periodic_schedule(%u) %sscheduled for: %s\n",
r12372: - make the periodic scheduling a bit easier, instead of passing an uint32_t next_interval everywhere, we now call wreplsrv_periodic_schedule() if we want to schedule an event - also prevent us from looping with a 0 interval, by using 1s as minimum interval metze (This used to be commit b6943b11fc6e501d5081d591336185518943ee5a)
2005-12-20 00:52:37 +03:00
next_interval,
(service->periodic.te?"re":""),
nt_time_string(tmp_mem, timeval_to_nttime(&next_time))));
talloc_free(tmp_mem);
talloc_free(service->periodic.te);
service->periodic.te = new_te;
return NT_STATUS_OK;
r12230: prepare for a generic periodic processing scheduling of pull,push,scavenging and reread-config events metze (This used to be commit 977117278c4b9fc1b7845b6aa6d5862e5a776651)
2005-12-14 13:56:43 +03:00
}
NTSTATUS wreplsrv_setup_periodic(struct wreplsrv_service *service)
{
NTSTATUS status;
r12372: - make the periodic scheduling a bit easier, instead of passing an uint32_t next_interval everywhere, we now call wreplsrv_periodic_schedule() if we want to schedule an event - also prevent us from looping with a 0 interval, by using 1s as minimum interval metze (This used to be commit b6943b11fc6e501d5081d591336185518943ee5a)
2005-12-20 00:52:37 +03:00
status = wreplsrv_periodic_schedule(service, 0);
NT_STATUS_NOT_OK_RETURN(status);
r12230: prepare for a generic periodic processing scheduling of pull,push,scavenging and reread-config events metze (This used to be commit 977117278c4b9fc1b7845b6aa6d5862e5a776651)
2005-12-14 13:56:43 +03:00
return NT_STATUS_OK;
}
Copy Permalink