source3/lib/tevent_wait.c

   1 /*
   2    Unix SMB/CIFS implementation.
   3    Implement a send/recv interface to wait for an external trigger
   4    Copyright (C) Volker Lendecke 2012
   5
   6    This program is free software; you can redistribute it and/or modify
   7    it under the terms of the GNU General Public License as published by
   8    the Free Software Foundation; either version 3 of the License, or
   9    (at your option) any later version.
  10
  11    This program is distributed in the hope that it will be useful,
  12    but WITHOUT ANY WARRANTY; without even the implied warranty of
  13    MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  14    GNU General Public License for more details.
  15
  16    You should have received a copy of the GNU General Public License
  17    along with this program.  If not, see <http://www.gnu.org/licenses/>.
  18 */
  19
  20 #include "lib/replace/replace.h"
  21 #include "talloc.h"
  22 #include "tevent.h"
  23 #include "tevent_wait.h"
  24 #include "lib/util/tevent_unix.h"
  25
  26 struct tevent_wait_state {
  27         struct tevent_immediate *im;
  28         struct tevent_context *ev;
  29 };
  30
  31 struct tevent_req *tevent_wait_send(TALLOC_CTX *mem_ctx,
  32                                     struct tevent_context *ev)
  33 {
  34         struct tevent_req *req;
  35         struct tevent_wait_state *state;
  36
  37         req = tevent_req_create(mem_ctx, &state, struct tevent_wait_state);
  38         if (req == NULL) {
  39                 return NULL;
  40         }
  41         state->ev = ev;
  42         state->im = tevent_create_immediate(state);
  43         if (tevent_req_nomem(state->im, req)) {
  44                 return tevent_req_post(req, ev);
  45         }
  46         return req;
  47 }
  48
  49 static void tevent_wait_trigger(struct tevent_context *ctx,
  50                                 struct tevent_immediate *im,
  51                                 void *private_data);
  52
  53 void tevent_wait_done(struct tevent_req *req)
  54 {
  55         struct tevent_wait_state *state;
  56
  57         if (req == NULL) {
  58                 return;
  59         }
  60         state = tevent_req_data(req, struct tevent_wait_state);
  61
  62         tevent_schedule_immediate(state->im, state->ev,
  63                                   tevent_wait_trigger, req);
  64 }
  65
  66 static void tevent_wait_trigger(struct tevent_context *ctx,
  67                                 struct tevent_immediate *im,
  68                                 void *private_data)
  69 {
  70         struct tevent_req *req = talloc_get_type_abort(
  71                 private_data, struct tevent_req);
  72         tevent_req_done(req);
  73 }
  74
  75 int tevent_wait_recv(struct tevent_req *req)
  76 {
  77         int err;
  78
  79         if (tevent_req_is_unix_error(req, &err)) {
  80                 return err;
  81         }
  82         return 0;
  83 }