sin/samba-mirror
1
0
Fork 0
mirror of https://github.com/samba-team/samba.git synced 2024-12-23 17:34:34 +03:00
Code

r12309: fix a crash bug, which appens in an error case

Browse Source 
metze
(This used to be commit 292bb4b6cb)
This commit is contained in:
Stefan Metzmacher 2005-12-17 19:24:13 +00:00 committed by Gerald (Jerry) Carter
parent 736543016e
commit 810833ad93
1 changed files with 9 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
source4/wrepl_server/wrepl_out_push.c
View File

@ -40,19 +40,20 @@ static void wreplsrv_out_partner_push(struct wreplsrv_partner *partner, BOOL pro
static void wreplsrv_push_handler_creq(struct composite_context *creq)
{
struct wreplsrv_partner *partner = talloc_get_type(creq->async.private_data, struct wreplsrv_partner);
struct wreplsrv_push_notify_io *old_notify_io;
partner->push.last_status = wreplsrv_push_notify_recv(partner->push.creq);
partner->push.creq = NULL;
talloc_free(partner->push.notify_io);
partner->push.notify_io = NULL;
partner->push.last_run = timeval_current();
old_notify_io = partner->push.notify_io;
partner->push.notify_io = NULL;
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)));
return;
goto done;
}
partner->push.error_count++;
@ -61,13 +62,15 @@ static void wreplsrv_push_handler_creq(struct composite_context *creq)
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));
return;
goto done;
}
DEBUG(1,("wreplsrv_push_notify(%s): %s: error_count: %u: retry\n",
partner->address, nt_errstr(partner->push.last_status),
partner->push.error_count));
wreplsrv_out_partner_push(partner, partner->push.notify_io->in.propagate);
wreplsrv_out_partner_push(partner, old_notify_io->in.propagate);
done:
talloc_free(old_notify_io);
}
static void wreplsrv_out_partner_push(struct wreplsrv_partner *partner, BOOL propagate)