src/breedline/breedline-murphy.c

   1 /*
   2  * Copyright (c) 2012, Intel Corporation
   3  *
   4  * Redistribution and use in source and binary forms, with or without
   5  * modification, are permitted provided that the following conditions are
   6  * met:
   7  *
   8  *   * Redistributions of source code must retain the above copyright notice,
   9  *     this list of conditions and the following disclaimer.
  10  *   * Redistributions in binary form must reproduce the above copyright
  11  *     notice, this list of conditions and the following disclaimer in the
  12  *     documentation and/or other materials provided with the distribution.
  13  *   * Neither the name of Intel Corporation nor the names of its contributors
  14  *     may be used to endorse or promote products derived from this software
  15  *     without specific prior written permission.
  16  *
  17  * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS
  18  * "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT
  19  * LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR
  20  * A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT
  21  * OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,
  22  * SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT
  23  * LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
  24  * DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
  25  * THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
  26  * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE
  27  * OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
  28  */
  29
  30 #include <murphy/common.h>
  31 #include <breedline/breedline.h>
  32
  33 typedef struct {
  34     mrp_io_watch_t  *w;
  35     void           (*cb)(int fd, int events, void *user_data);
  36     void            *user_data;
  37 } watch_t;
  38
  39
  40 static void io_cb(mrp_io_watch_t *watch, int fd, mrp_io_event_t events,
  41                   void *user_data)
  42 {
  43     watch_t *w = (watch_t *)user_data;
  44     int      e = 0;
  45
  46     MRP_UNUSED(watch);
  47
  48     if (events & MRP_IO_EVENT_IN)
  49         e |= POLLIN;
  50     if (events & MRP_IO_EVENT_HUP)
  51         e |= POLLHUP;
  52
  53     w->cb(fd, e, w->user_data);
  54 }
  55
  56
  57 static void *add_watch(void *mlp, int fd,
  58                        void (*cb)(int fd, int events, void *user_data),
  59                        void *user_data)
  60 {
  61     mrp_mainloop_t *ml     = (mrp_mainloop_t *)mlp;
  62     mrp_io_event_t  events = MRP_IO_EVENT_IN | MRP_IO_EVENT_HUP;
  63     watch_t        *w;
  64
  65     w = mrp_allocz(sizeof(*w));
  66
  67     if (w != NULL) {
  68         w->cb        = cb;
  69         w->user_data = user_data;
  70         w->w         = mrp_add_io_watch(ml, fd, events, io_cb, w);
  71
  72         if (w->w != NULL)
  73             return w;
  74         else
  75             mrp_free(w);
  76     }
  77
  78     return NULL;
  79 }
  80
  81
  82 static void del_watch(void *wp)
  83 {
  84     watch_t *w = (watch_t *)wp;
  85
  86     if (w != NULL) {
  87         mrp_del_io_watch(w->w);
  88         mrp_free(w);
  89     }
  90 }
  91
  92
  93 static brl_allocator_t allocator = {
  94     .allocfn   = mrp_mm_alloc,
  95     .reallocfn = mrp_mm_realloc,
  96     .strdupfn  = mrp_mm_strdup,
  97     .freefn    = mrp_mm_free
  98 };
  99
 100
 101 static brl_mainloop_ops_t ml_ops = {
 102     .add_watch = add_watch,
 103     .del_watch = del_watch
 104 };
 105
 106
 107 brl_t *brl_create_with_murphy(int fd, const char *prompt, mrp_mainloop_t *ml,
 108                               brl_line_cb_t cb, void *user_data)
 109 {
 110     brl_t *brl;
 111
 112     brl_set_allocator(&allocator);
 113
 114     brl = brl_create(fd, prompt);
 115
 116     if (brl != NULL) {
 117         if (brl_use_mainloop(brl, ml, &ml_ops, cb, user_data) == 0)
 118             return brl;
 119         else
 120             brl_destroy(brl);
 121     }
 122
 123     return NULL;
 124 }