Changeset 988 for vendor/current/source4/wrepl_server
- Timestamp:
- Nov 24, 2016, 1:14:11 PM (9 years ago)
- Location:
- vendor/current/source4/wrepl_server
- Files:
-
- 7 edited
Legend:
- Unmodified
- Added
- Removed
-
vendor/current/source4/wrepl_server/wrepl_apply_records.c
r740 r988 904 904 905 905 /* don't care about the result */ 906 (void)status; 906 907 talloc_free(state); 907 908 } … … 1101 1102 1102 1103 /* don't care about the result */ 1104 (void)status; 1103 1105 talloc_free(state); 1104 1106 } -
vendor/current/source4/wrepl_server/wrepl_in_call.c
r740 r988 362 362 wrepl_in->conn->event.ctx); 363 363 364 NT_STATUS_HAVE_NO_MEMORY_AND_FREE(wrepl_out->sock, update_state); 364 if (wrepl_out->sock == NULL) { 365 TALLOC_FREE(update_state); 366 return NT_STATUS_NO_MEMORY; 367 } 365 368 366 369 TALLOC_FREE(wrepl_in->send_queue); 367 370 368 371 status = wrepl_socket_donate_stream(wrepl_out->sock, &wrepl_in->tstream); 369 NT_STATUS_NOT_OK_RETURN_AND_FREE(status, update_state); 372 if (!NT_STATUS_IS_OK(status)) { 373 TALLOC_FREE(update_state); 374 return status; 375 } 370 376 371 377 update_state->wrepl_in = wrepl_in; -
vendor/current/source4/wrepl_server/wrepl_in_connection.c
r740 r988 66 66 67 67 status = wreplsrv_in_call(call); 68 NT_STATUS_IS_ERR_RETURN(status); 68 if (NT_STATUS_IS_ERR(status)) { 69 return status; 70 } 69 71 if (!NT_STATUS_IS_OK(status)) { 70 72 /* w2k just ignores invalid packets, so we do */ … … 442 444 struct interface *ifaces; 443 445 444 load_interface s(task, lpcfg_interfaces(lp_ctx), &ifaces);445 446 num_interfaces = iface_ count(ifaces);446 load_interface_list(task, lp_ctx, &ifaces); 447 448 num_interfaces = iface_list_count(ifaces); 447 449 448 450 /* We have been given an interfaces line, and been … … 451 453 */ 452 454 for(i = 0; i < num_interfaces; i++) { 453 address = iface_n_ip(ifaces, i); 455 if (!iface_list_n_is_v4(ifaces, i)) { 456 continue; 457 } 458 address = iface_list_n_ip(ifaces, i); 454 459 status = stream_setup_socket(task, task->event_ctx, 455 460 task->lp_ctx, model_ops, … … 465 470 } 466 471 } else { 467 address = lpcfg_socket_address(lp_ctx);472 address = "0.0.0.0"; 468 473 status = stream_setup_socket(task, task->event_ctx, task->lp_ctx, 469 474 model_ops, &wreplsrv_stream_ops, -
vendor/current/source4/wrepl_server/wrepl_out_helpers.c
r740 r988 224 224 if (!*wreplconn) status = NT_STATUS_NO_MEMORY; 225 225 } else { 226 status = NT_STATUS_ INVALID_CONNECTION;226 status = NT_STATUS_CONNECTION_DISCONNECTED; 227 227 } 228 228 } … … 358 358 359 359 if (io->in.num_owners) { 360 struct wrepl_wins_owner *partners; 361 uint32_t i; 362 363 partners = talloc_array(state, 364 struct wrepl_wins_owner, 365 io->in.num_owners); 366 if (composite_nomem(partners, c)) goto failed; 367 368 for (i=0; i < io->in.num_owners; i++) { 369 partners[i] = io->in.owners[i]; 370 partners[i].address = talloc_strdup(partners, 371 io->in.owners[i].address); 372 if (composite_nomem(partners[i].address, c)) goto failed; 373 } 374 360 375 state->table_io.out.num_partners = io->in.num_owners; 361 state->table_io.out.partners = io->in.owners;376 state->table_io.out.partners = partners; 362 377 state->stage = WREPLSRV_PULL_TABLE_STAGE_DONE; 363 378 composite_done(c); … … 389 404 struct wreplsrv_pull_table_state); 390 405 io->out.num_owners = state->table_io.out.num_partners; 391 io->out.owners = talloc_ reference(mem_ctx,state->table_io.out.partners);406 io->out.owners = talloc_move(mem_ctx, &state->table_io.out.partners); 392 407 } 393 408 … … 549 564 struct wreplsrv_pull_names_state); 550 565 io->out.num_names = state->pull_io.out.num_names; 551 io->out.names = talloc_ reference(mem_ctx,state->pull_io.out.names);566 io->out.names = talloc_move(mem_ctx, &state->pull_io.out.names); 552 567 } 553 568 -
vendor/current/source4/wrepl_server/wrepl_periodic.c
r414 r988 90 90 service->periodic.next_event = next_time; 91 91 92 new_te = event_add_timed(service->task->event_ctx, service,92 new_te = tevent_add_timer(service->task->event_ctx, service, 93 93 service->periodic.next_event, 94 94 wreplsrv_periodic_handler_te, service); -
vendor/current/source4/wrepl_server/wrepl_scavenging.c
r740 r988 307 307 308 308 struct verify_state { 309 struct messaging_context *msg_ctx;309 struct imessaging_context *msg_ctx; 310 310 struct wreplsrv_service *service; 311 311 struct winsdb_record *rec; -
vendor/current/source4/wrepl_server/wrepl_server.c
r740 r988 39 39 struct loadparm_context *lp_ctx) 40 40 { 41 return ldb_wrap_connect(mem_ctx, ev_ctx, lp_ctx, private_path(mem_ctx,42 lp_ctx, lpcfg_wins_config_url(lp_ctx)),41 return ldb_wrap_connect(mem_ctx, ev_ctx, lp_ctx, lpcfg_private_path(mem_ctx, 42 lp_ctx, "wins_config.ldb"), 43 43 system_session(lp_ctx), NULL, 0); 44 44 } … … 79 79 if (owner == NULL) { 80 80 struct interface *ifaces; 81 load_interface s(service, lpcfg_interfaces(lp_ctx), &ifaces);82 owner = iface_ n_ip(ifaces, 0);81 load_interface_list(service, lp_ctx, &ifaces); 82 owner = iface_list_first_v4(ifaces); 83 83 } 84 84 … … 193 193 talloc_steal(partner, partner->address); 194 194 195 DLIST_ADD_END(service->partners, partner , struct wreplsrv_partner *);195 DLIST_ADD_END(service->partners, partner); 196 196 } 197 197 … … 329 329 cur->partner = wreplsrv_find_partner(service, wins_owner); 330 330 331 DLIST_ADD_END(table, cur , struct wreplsrv_owner *);331 DLIST_ADD_END(table, cur); 332 332 *_table = table; 333 333 } … … 452 452 struct wreplsrv_service *service; 453 453 454 if (!lpcfg_w ins_support(task->lp_ctx)) {454 if (!lpcfg_we_are_a_wins_server(task->lp_ctx)) { 455 455 return; 456 456 }
Note:
See TracChangeset
for help on using the changeset viewer.