Lines Matching defs:partner
84 state->wreplconn->partner->push.wreplconn = state->wreplconn;
85 talloc_steal(state->wreplconn->partner, state->wreplconn);
90 state->wreplconn->partner->pull.wreplconn = state->wreplconn;
91 talloc_steal(state->wreplconn->partner, state->wreplconn);
140 static struct composite_context *wreplsrv_out_connect_send(struct wreplsrv_partner *partner,
145 struct wreplsrv_service *service = partner->service;
150 c = talloc_zero(partner, struct composite_context);
164 wreplconn = partner->push.wreplconn;
165 wreplconnp = &partner->push.wreplconn;
168 wreplconn = partner->pull.wreplconn;
169 wreplconnp = &partner->pull.wreplconn;
194 wreplconn->partner = partner;
201 partner->our_address?partner->our_address:wrepl_best_ip(service->task->lp_ctx, partner->address),
202 partner->address);
239 struct wreplsrv_partner *partner;
342 struct wreplsrv_service *service = io->in.partner->service;
366 state->creq = wreplsrv_out_connect_send(io->in.partner, WINSREPL_PARTNER_PULL, NULL);
398 struct wreplsrv_partner *partner;
434 state->pull_io.in.partner = state->io->in.owner;
502 struct wreplsrv_service *service = io->in.partner->service;
521 state->creq = wreplsrv_out_connect_send(io->in.partner, partner_type, io->in.wreplconn);
583 current_owner = wreplsrv_find_owner(state->io->in.partner->service,
584 state->io->in.partner->pull.table,
587 local_owner = wreplsrv_find_owner(state->io->in.partner->service,
588 state->io->in.partner->service->table,
607 * this means the remote partner has some new records of this owner
619 state->names_io.in.partner = state->io->in.partner;
670 /* update partner table */
672 status = wreplsrv_add_table(state->io->in.partner->service,
673 state->io->in.partner,
674 &state->io->in.partner->pull.table,
690 status = wreplsrv_apply_records(state->io->in.partner,
785 struct wreplsrv_service *service = io->in.partner->service;
801 state->table_io.in.partner = io->in.partner;
851 struct wreplsrv_service *service = state->io->in.partner->service;
917 status = wreplsrv_in_connection_merge(state->io->in.partner,
937 struct wreplsrv_service *service = state->io->in.partner->service;
1068 struct wreplsrv_service *service = io->in.partner->service;
1081 /* we can cache the connection in partner->push->wreplconn */
1103 state->creq = wreplsrv_out_connect_send(io->in.partner, partner_type, NULL);