diff options
| author | Volker Lendecke <vl@samba.org> | 2013-12-30 21:35:03 +0100 |
|---|---|---|
| committer | Volker Lendecke <vl@samba.org> | 2014-01-21 08:11:01 +0100 |
| commit | 017609767fff34118cb1f77c40af2037fba6fab2 (patch) | |
| tree | 77fc42d3cb10b1c30789db84831331a52689f6de /source3/lib/dbwrap | |
| parent | 5f3ccfc16b7c64d2de109ba26d92d22ae1010882 (diff) | |
| download | samba-017609767fff34118cb1f77c40af2037fba6fab2.tar.gz samba-017609767fff34118cb1f77c40af2037fba6fab2.tar.xz samba-017609767fff34118cb1f77c40af2037fba6fab2.zip | |
dbwrap_watch: Use messaging_read_send/recv
Signed-off-by: Volker Lendecke <vl@samba.org>
Reviewed-by: Jeremy Allison <jra@samba.org>
Diffstat (limited to 'source3/lib/dbwrap')
| -rw-r--r-- | source3/lib/dbwrap/dbwrap_watch.c | 20 |
1 files changed, 7 insertions, 13 deletions
diff --git a/source3/lib/dbwrap/dbwrap_watch.c b/source3/lib/dbwrap/dbwrap_watch.c index e65dbf41bde..b586b661a34 100644 --- a/source3/lib/dbwrap/dbwrap_watch.c +++ b/source3/lib/dbwrap/dbwrap_watch.c @@ -230,7 +230,6 @@ struct dbwrap_record_watch_state { struct db_context *db; struct tevent_req *req; struct messaging_context *msg; - struct msg_channel *channel; TDB_DATA key; TDB_DATA w_key; }; @@ -248,7 +247,6 @@ struct tevent_req *dbwrap_record_watch_send(TALLOC_CTX *mem_ctx, struct dbwrap_record_watch_state *state; struct db_context *watchers_db; NTSTATUS status; - int ret; req = tevent_req_create(mem_ctx, &state, struct dbwrap_record_watch_state); @@ -272,12 +270,12 @@ struct tevent_req *dbwrap_record_watch_send(TALLOC_CTX *mem_ctx, return tevent_req_post(req, ev); } - ret = msg_channel_init(state, state->msg, MSG_DBWRAP_MODIFIED, - &state->channel); - if (ret != 0) { - tevent_req_nterror(req, map_nt_error_from_unix(ret)); + subreq = messaging_read_send(state, ev, state->msg, + MSG_DBWRAP_MODIFIED); + if (tevent_req_nomem(subreq, req)) { return tevent_req_post(req, ev); } + tevent_req_set_callback(subreq, dbwrap_record_watch_done, req); status = dbwrap_record_add_watcher( state->w_key, messaging_server_id(state->msg)); @@ -286,11 +284,6 @@ struct tevent_req *dbwrap_record_watch_send(TALLOC_CTX *mem_ctx, } talloc_set_destructor(state, dbwrap_record_watch_state_destructor); - subreq = msg_read_send(state, state->ev, state->channel); - if (tevent_req_nomem(subreq, req)) { - return tevent_req_post(req, ev); - } - tevent_req_set_callback(subreq, dbwrap_record_watch_done, req); return req; } @@ -365,7 +358,7 @@ static void dbwrap_record_watch_done(struct tevent_req *subreq) struct messaging_rec *rec; int ret; - ret = msg_read_recv(subreq, talloc_tos(), &rec); + ret = messaging_read_recv(subreq, talloc_tos(), &rec); TALLOC_FREE(subreq); if (ret != 0) { tevent_req_nterror(req, map_nt_error_from_unix(ret)); @@ -381,7 +374,8 @@ static void dbwrap_record_watch_done(struct tevent_req *subreq) /* * Not our record, wait for the next one */ - subreq = msg_read_send(state, state->ev, state->channel); + subreq = messaging_read_send(state, state->ev, state->msg, + MSG_DBWRAP_MODIFIED); if (tevent_req_nomem(subreq, req)) { return; } |