sin/samba-mirror
1
0
Fork 0
mirror of https://github.com/samba-team/samba.git synced 2024-12-28 07:21:54 +03:00
Code
2b771cc5a6
samba-mirror/source4/wrepl_server/wrepl_out_push.c

145 lines
4.4 KiB
C
Raw Normal View History

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
/*
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
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
(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/>.
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
*/
#include "includes.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"
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
#include "wrepl_server/wrepl_server.h"
#include "libcli/composite/composite.h"
r12674: make use of the winsdb functions metze (This used to be commit 9a7da608e2099ea1d037b6985358649a6e35a714)
2006-01-02 19:14:08 +03:00
#include "nbt_server/wins/winsdb.h"
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
static void wreplsrv_out_partner_push(struct wreplsrv_partner *partner, BOOL propagate);
static void wreplsrv_push_handler_creq(struct composite_context *creq)
{
struct wreplsrv_partner *partner = talloc_get_type(creq->async.private_data, struct wreplsrv_partner);
r12309: fix a crash bug, which appens in an error case metze (This used to be commit 292bb4b6cb600ce286ded90d32d72123fdaae1d7)
2005-12-17 22:24:13 +03:00
struct wreplsrv_push_notify_io *old_notify_io;
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
partner->push.last_status = wreplsrv_push_notify_recv(partner->push.creq);
partner->push.creq = NULL;
r12309: fix a crash bug, which appens in an error case metze (This used to be commit 292bb4b6cb600ce286ded90d32d72123fdaae1d7)
2005-12-17 22:24:13 +03:00
old_notify_io = partner->push.notify_io;
partner->push.notify_io = NULL;
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
if (NT_STATUS_IS_OK(partner->push.last_status)) {
partner->push.error_count = 0;
DEBUG(2,("wreplsrv_push_notify(%s): %s\n",
partner->address, nt_errstr(partner->push.last_status)));
r12309: fix a crash bug, which appens in an error case metze (This used to be commit 292bb4b6cb600ce286ded90d32d72123fdaae1d7)
2005-12-17 22:24:13 +03:00
goto done;
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
}
partner->push.error_count++;
if (partner->push.error_count > 1) {
DEBUG(1,("wreplsrv_push_notify(%s): %s: error_count: %u: giving up\n",
partner->address, nt_errstr(partner->push.last_status),
partner->push.error_count));
r12309: fix a crash bug, which appens in an error case metze (This used to be commit 292bb4b6cb600ce286ded90d32d72123fdaae1d7)
2005-12-17 22:24:13 +03:00
goto done;
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
}
DEBUG(1,("wreplsrv_push_notify(%s): %s: error_count: %u: retry\n",
partner->address, nt_errstr(partner->push.last_status),
partner->push.error_count));
r12309: fix a crash bug, which appens in an error case metze (This used to be commit 292bb4b6cb600ce286ded90d32d72123fdaae1d7)
2005-12-17 22:24:13 +03:00
wreplsrv_out_partner_push(partner, old_notify_io->in.propagate);
done:
talloc_free(old_notify_io);
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
}
static void wreplsrv_out_partner_push(struct wreplsrv_partner *partner, BOOL propagate)
{
/* a push for this partner is currently in progress, so we're done */
if (partner->push.creq) return;
/* now prepare the push notify */
partner->push.notify_io = talloc(partner, struct wreplsrv_push_notify_io);
if (!partner->push.notify_io) {
goto nomem;
}
partner->push.notify_io->in.partner = partner;
partner->push.notify_io->in.inform = partner->push.use_inform;
partner->push.notify_io->in.propagate = propagate;
partner->push.creq = wreplsrv_push_notify_send(partner->push.notify_io, partner->push.notify_io);
if (!partner->push.creq) {
r12388: fix debug messages metze (This used to be commit 8b99b2d6c47ef5596269b57a71b275236b43a2a1)
2005-12-20 03:33:41 +03:00
DEBUG(1,("wreplsrv_push_notify_send(%s) failed nomem?\n",
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
partner->address));
goto nomem;
}
partner->push.creq->async.fn = wreplsrv_push_handler_creq;
partner->push.creq->async.private_data = partner;
return;
nomem:
talloc_free(partner->push.notify_io);
partner->push.notify_io = NULL;
r12388: fix debug messages metze (This used to be commit 8b99b2d6c47ef5596269b57a71b275236b43a2a1)
2005-12-20 03:33:41 +03:00
DEBUG(1,("wreplsrv_out_partner_push(%s,%u) failed nomem? (ignoring)\n",
partner->address, propagate));
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
return;
}
r13111: w2k3 uses the naxVersion id for calculating the notification, so we do now metze (This used to be commit e48a47aa650781ebe79425f41eee925f358ceb96)
2006-01-24 20:36:13 +03:00
static uint32_t wreplsrv_calc_change_count(struct wreplsrv_partner *partner, uint64_t maxVersionID)
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
{
r12642: only do push notifications when something changed metze (This used to be commit 61f1c8c347d26f34e3e924ceae55e99e6c1461f7)
2005-12-31 12:44:04 +03:00
uint64_t tmp_diff = UINT32_MAX;
/* catch an overflow */
r13111: w2k3 uses the naxVersion id for calculating the notification, so we do now metze (This used to be commit e48a47aa650781ebe79425f41eee925f358ceb96)
2006-01-24 20:36:13 +03:00
if (partner->push.maxVersionID > maxVersionID) {
r12642: only do push notifications when something changed metze (This used to be commit 61f1c8c347d26f34e3e924ceae55e99e6c1461f7)
2005-12-31 12:44:04 +03:00
goto done;
}
r13111: w2k3 uses the naxVersion id for calculating the notification, so we do now metze (This used to be commit e48a47aa650781ebe79425f41eee925f358ceb96)
2006-01-24 20:36:13 +03:00
tmp_diff = maxVersionID - partner->push.maxVersionID;
r12642: only do push notifications when something changed metze (This used to be commit 61f1c8c347d26f34e3e924ceae55e99e6c1461f7)
2005-12-31 12:44:04 +03:00
if (tmp_diff > UINT32_MAX) {
tmp_diff = UINT32_MAX;
goto done;
}
done:
r13111: w2k3 uses the naxVersion id for calculating the notification, so we do now metze (This used to be commit e48a47aa650781ebe79425f41eee925f358ceb96)
2006-01-24 20:36:13 +03:00
partner->push.maxVersionID = maxVersionID;
r12642: only do push notifications when something changed metze (This used to be commit 61f1c8c347d26f34e3e924ceae55e99e6c1461f7)
2005-12-31 12:44:04 +03:00
return (uint32_t)(tmp_diff & UINT32_MAX);
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
NTSTATUS wreplsrv_out_push_run(struct wreplsrv_service *service)
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
{
struct wreplsrv_partner *partner;
r12642: only do push notifications when something changed metze (This used to be commit 61f1c8c347d26f34e3e924ceae55e99e6c1461f7)
2005-12-31 12:44:04 +03:00
uint64_t seqnumber;
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
uint32_t change_count;
r13111: w2k3 uses the naxVersion id for calculating the notification, so we do now metze (This used to be commit e48a47aa650781ebe79425f41eee925f358ceb96)
2006-01-24 20:36:13 +03:00
seqnumber = winsdb_get_maxVersion(service->wins_db);
r12642: only do push notifications when something changed metze (This used to be commit 61f1c8c347d26f34e3e924ceae55e99e6c1461f7)
2005-12-31 12:44:04 +03:00
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
for (partner = service->partners; partner; partner = partner->next) {
/* if it's not a push partner, go to the next partner */
if (!(partner->type & WINSREPL_PARTNER_PUSH)) continue;
/* if push notifies are disabled for this partner, go to the next partner */
if (partner->push.change_count == 0) continue;
/* get the actual change count for the partner */
r12642: only do push notifications when something changed metze (This used to be commit 61f1c8c347d26f34e3e924ceae55e99e6c1461f7)
2005-12-31 12:44:04 +03:00
change_count = wreplsrv_calc_change_count(partner, seqnumber);
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
/* if the configured change count isn't reached, go to the next partner */
if (change_count < partner->push.change_count) continue;
wreplsrv_out_partner_push(partner, False);
}
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;
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
}
Copy Permalink