root/opal/mca/event/libevent2022/libevent2022.h

INCLUDED FROM

   1 /*
   2  * Copyright (c) 2010-2015 Cisco Systems, Inc.  All rights reserved.
   3  * Copyright (c) 2010      Oracle and/or its affiliates.  All rights reserved.
   4  * Copyright (c) 2012-2013 Los Alamos National Security, LLC.
   5  *                         All rights reserved.
   6  * Copyright (c) 2015      Intel, Inc. All rights reserved.
   7  * Copyright (c) 2017      Research Organization for Information Science
   8  *                         and Technology (RIST). All rights reserved.
   9  * $COPYRIGHT$
  10  *
  11  * Additional copyrights may follow
  12  *
  13  * $HEADER$
  14  *
  15  * When this component is used, this file is included in the rest of
  16  * the OPAL/ORTE/OMPI code base via opal/mca/event/event.h.  As such,
  17  * this header represents the public interface to this static component.
  18  */
  19 
  20 #ifndef MCA_OPAL_EVENT_LIBEVENT2022_H
  21 #define MCA_OPAL_EVENT_LIBEVENT2022_H
  22 
  23 #include "opal_config.h"
  24 
  25 #ifdef HAVE_SYS_TYPES_H
  26 #include <sys/types.h>
  27 #endif
  28 
  29 #ifdef WIN32
  30 #define WIN32_LEAN_AND_MEAN
  31 #include <windows.h>
  32 #undef WIN32_LEAN_AND_MEAN
  33 #endif
  34 #ifdef HAVE_SYS_TIME_H
  35 #include <sys/time.h>
  36 #endif
  37 #include <stdio.h>
  38 #include <stdlib.h>
  39 #ifndef WIN32
  40 #ifdef HAVE_UNISTD_H
  41 #include <unistd.h>
  42 #endif
  43 #endif
  44 #include <errno.h>
  45 #include <signal.h>
  46 #include <string.h>
  47 #include <assert.h>
  48 #include <time.h>
  49 
  50 #include "opal/class/opal_object.h"
  51 #include "opal/threads/mutex.h"
  52 #include "opal/threads/threads.h"
  53 #include "opal/util/output.h"
  54 #include "opal/constants.h"
  55 #include "opal/util/argv.h"
  56 #include "opal/mca/event/base/base.h"
  57 
  58 #include "libevent/event.h"
  59 #include "libevent/include/event2/thread.h"
  60 
  61 #include "opal/mca/event/event.h"
  62 
  63 typedef event_callback_fn opal_event_cbfunc_t;
  64 
  65 
  66 BEGIN_C_DECLS
  67 
  68 typedef struct event_base opal_event_base_t;
  69 typedef struct event opal_event_t;
  70 
  71 OPAL_DECLSPEC extern opal_event_base_t *opal_sync_event_base;
  72 
  73 #define OPAL_EV_TIMEOUT EV_TIMEOUT
  74 #define OPAL_EV_READ    EV_READ
  75 #define OPAL_EV_WRITE   EV_WRITE
  76 #define OPAL_EV_SIGNAL  EV_SIGNAL
  77 /* Persistent event: won't get removed automatically when activated. */
  78 #define OPAL_EV_PERSIST EV_PERSIST
  79 
  80 #define OPAL_EVLOOP_ONCE     EVLOOP_ONCE        /**< Block at most once. */
  81 #define OPAL_EVLOOP_NONBLOCK EVLOOP_NONBLOCK    /**< Do not block. */
  82 
  83 /* Global function to create and release an event base */
  84 OPAL_DECLSPEC opal_event_base_t* opal_event_base_create(void);
  85 
  86 #define opal_event_base_free(x) event_base_free(x)
  87 
  88 OPAL_DECLSPEC int opal_event_init(void);
  89 
  90 OPAL_DECLSPEC int opal_event_finalize(void);
  91 
  92 #define opal_event_reinit(b) event_reinit((b))
  93 
  94 #define opal_event_base_init_common_timeout (b, t) event_base_init_common_timeout((b), (t))
  95 
  96 #define opal_event_base_loopbreak(b) event_base_loopbreak(b)
  97 
  98 #define opal_event_base_loopexit(b) event_base_loopexit(b, NULL)
  99 
 100 /* Event priority APIs */
 101 #define opal_event_base_priority_init(b, n) event_base_priority_init((b), (n))
 102 
 103 #define opal_event_set_priority(x, n) event_priority_set((x), (n))
 104 
 105 /* thread support APIs */
 106 #define opal_event_use_threads() evthread_use_pthreads()
 107 
 108 /* Basic event APIs */
 109 #define opal_event_enable_debug_mode() event_enable_debug_mode()
 110 
 111 #define opal_event_set(b, x, fd, fg, cb, arg) event_assign((x), (b), (fd), (fg), (event_callback_fn) (cb), (arg))
 112 
 113 #define opal_event_assign(x, b, fd, fg, cb, arg) event_assign((x), (b), (fd), (fg), (event_callback_fn) (cb), (arg))
 114 
 115 #define opal_event_add(ev, tv) event_add((ev), (tv))
 116 
 117 #define opal_event_del(ev) event_del((ev))
 118 
 119 #define opal_event_active(x, y, z) event_active((x), (y), (z))
 120 
 121 #define opal_event_new(b, fd, fg, cb, arg) event_new((b), (fd), (fg), (event_callback_fn) (cb), (arg))
 122 
 123 OPAL_DECLSPEC opal_event_t* opal_event_alloc(void);
 124 
 125 #define opal_event_free(x) event_free((x))
 126 
 127 /* Timer APIs */
 128 #define opal_event_evtimer_new(b, cb, arg) opal_event_new((b), -1, 0, (cb), (arg))
 129 
 130 #define opal_event_evtimer_add(x, tv) opal_event_add((x), (tv))
 131 
 132 #define opal_event_evtimer_set(b, x, cb, arg) event_assign((x), (b), -1, 0, (event_callback_fn) (cb), (arg))
 133 
 134 #define opal_event_evtimer_del(x) opal_event_del((x))
 135 
 136 #define opal_event_evtimer_pending(x, tv) event_pending((x), EV_TIMEOUT, (tv))
 137 
 138 #define opal_event_evtimer_initialized(x) event_initialized((x))
 139 
 140 /* Signal APIs */
 141 #define opal_event_signal_add(x, tv) event_add((x), (tv))
 142 
 143 #define opal_event_signal_set(b, x, fd, cb, arg) event_assign((x), (b), (fd), EV_SIGNAL|EV_PERSIST, (event_callback_fn) (cb), (arg))
 144 
 145 #define opal_event_signal_del(x) event_del((x))
 146 
 147 #define opal_event_signal_pending(x, tv) event_pending((x), EV_SIGNAL, (tv))
 148 
 149 #define opal_event_signal_initalized(x) event_initialized((x))
 150 
 151 #define opal_event_get_signal(x) event_get_signal((x))
 152 
 153 #define opal_event_loop(b, fg) event_base_loop((b), (fg))
 154 
 155 END_C_DECLS
 156 
 157 #endif /* MCA_OPAL_EVENT_LIBEVENT2022_H */