Skip to content
This repository has been archived by the owner. It is now read-only.
Permalink
Browse files

build: install ev-emul.h

  • Loading branch information...
bnoordhuis committed Jun 18, 2012
1 parent 1df222f commit f405517de1273bdf8493bc8a1e1294ded026c93a
Showing with 257 additions and 1 deletion.
  1. +251 −0 src/ev-emul.h
  2. +5 −0 src/node.h
  3. +1 −1 tools/installer.js
@@ -0,0 +1,251 @@
/* Copyright Joyent, Inc. and other Node contributors.
*
* Permission is hereby granted, free of charge, to any person obtaining a
* copy of this software and associated documentation files (the
* "Software"), to deal in the Software without restriction, including
* without limitation the rights to use, copy, modify, merge, publish,
* distribute, sublicense, and/or sell copies of the Software, and to permit
* persons to whom the Software is furnished to do so, subject to the
* following conditions:
*
* The above copyright notice and this permission notice shall be included
* in all copies or substantial portions of the Software.
*
* THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS
* OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF
* MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN
* NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM,
* DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR
* OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE
* USE OR OTHER DEALINGS IN THE SOFTWARE.
*/

#ifndef NODE_EV_EMUL_H_
#define NODE_EV_EMUL_H_

#include "uv.h"

#include <stdio.h>
#include <stddef.h>
#include <stdint.h>
#include <string.h>

#undef ev_init
#undef ev_set_cb
#undef ev_set_priority
#undef ev_is_active
#undef ev_timer_init
#undef ev_timer_set
#undef ev_io_init
#undef ev_io_set

#undef EV_P
#undef EV_P_
#undef EV_A
#undef EV_A_
#undef EV_DEFAULT
#undef EV_DEFAULT_
#undef EV_DEFAULT_UC
#undef EV_DEFAULT_UC_

#define EV_P void
#define EV_P_
#define EV_A
#define EV_A_
#define EV_DEFAULT
#define EV_DEFAULT_
#define EV_DEFAULT_UC
#define EV_DEFAULT_UC_

#define ev_init(w, cb_) \
do { \
void* data = (w)->data; \
memset((w), 0, sizeof(*(w))); \
(w)->data = data; \
(w)->cb = (cb_); \
} \
while (0)

#define ev_set_cb(w, cb_) \
do \
(w)->cb = (cb_); \
while (0)

#define ev_set_priority(...)

#define ev_is_active(w) \
(uv_is_active((uv_handle_t*) &(w)->handle))

#define ev_now(...) \
(uv_hrtime() / 1e9)

#define __uv_container_of(ptr, type, field) \
((type*) ((char*) (ptr) - offsetof(type, field)))

#define __uv_warn_of(old_, new_) \
do { \
if (__uv_warn_##old_) break; \
__uv_warn_##old_ = 1; \
fputs("WARNING: " #old_ " is deprecated, use " #new_ "\n", stderr); \
} \
while (0)

static int __uv_warn_ev_io __attribute__((unused));
static int __uv_warn_ev_timer __attribute__((unused));
static int __uv_warn_ev_ref __attribute__((unused));
static int __uv_warn_ev_unref __attribute__((unused));

struct __ev_io;
typedef struct __ev_io __ev_io;
typedef void (*__ev_io_cb)(__ev_io*, int);

struct __ev_timer;
typedef struct __ev_timer __ev_timer;
typedef void (*__ev_timer_cb)(__ev_timer*, int);

/* Field order matters. Don't touch. */
struct __ev_io {
__ev_io_cb cb;
void* data;
int flags; /* bit 1 == initialized, yes or no? */
uv_poll_t handle;
int fd;
int events;
};

/* Field order matters. Don't touch. */
struct __ev_timer {
__ev_timer_cb cb;
void* data;
int flags;
uv_timer_t handle;
double delay;
double repeat;
};


inline static void __uv_poll_cb(uv_poll_t* handle, int status, int events) {
__ev_io* w = __uv_container_of(handle, __ev_io, handle);
w->cb(w, events);
(void) status;
}


inline static void __uv_timer_cb(uv_timer_t* handle, int status) {
__ev_timer* w = __uv_container_of(handle, __ev_timer, handle);
w->cb(w, 0);
(void) status;
}


inline static void __ev_io_init(__ev_io* w, __ev_io_cb cb, int fd, int events) {
__uv_warn_of(ev_io, uv_poll_t);
ev_init(w, cb);
w->fd = fd;
w->events = events;
}


inline static void __ev_io_set(__ev_io* w, int fd, int events) {
__uv_warn_of(ev_io, uv_poll_t);
w->fd = fd;
w->events = events;
}


inline static void __ev_io_start(__ev_io* w) {
__uv_warn_of(ev_io, uv_poll_t);
if (!(w->flags & 1)) {
uv_poll_init(uv_default_loop(), &w->handle, w->fd);
w->flags |= 1;
}
uv_poll_start(&w->handle, w->events, __uv_poll_cb);
}


inline static void __ev_io_stop(__ev_io* w) {
__uv_warn_of(ev_io, uv_poll_t);
uv_poll_stop(&w->handle);
}


inline static void __ev_timer_init(__ev_timer* w,
__ev_timer_cb cb,
double delay,
double repeat) {
__uv_warn_of(ev_timer, uv_timer_t);
ev_init(w, cb);
w->delay = delay;
w->repeat = repeat;
}


inline static void __ev_timer_set(__ev_timer* w,
double delay,
double repeat) {
__uv_warn_of(ev_timer, uv_timer_t);
w->delay = delay;
w->repeat = repeat;
}


inline static void __ev_timer_start(__ev_timer* w) {
uint64_t ms = 1000;
__uv_warn_of(ev_timer, uv_timer_t);
if (!(w->flags & 1)) {
uv_timer_init(uv_default_loop(), &w->handle);
w->flags |= 1;
}
uv_timer_start(&w->handle, __uv_timer_cb, w->delay * ms, w->repeat * ms);
}


inline static void __ev_timer_stop(__ev_timer* w) {
__uv_warn_of(ev_timer, uv_timer_t);
uv_timer_stop(&w->handle);
}


inline static void __ev_timer_again(__ev_timer* w) {
__uv_warn_of(ev_timer, uv_timer_t);
if (w->flags & 1)
uv_timer_again(&w->handle);
else
__ev_timer_start(w); /* work around node-zookeeper bug */
}


/* Evil. Using this will void your warranty. */
inline static void __ev_ref(void) {
__uv_warn_of(ev_ref, uv_ref);
uv_default_loop()->active_handles++;
}


/* Evil. Using this will void your warranty. */
inline static void __ev_unref(void) {
__uv_warn_of(ev_unref, uv_unref);
uv_default_loop()->active_handles--;
}


#define ev_io __ev_io
#define ev_io_init __ev_io_init
#define ev_io_set __ev_io_set
#define ev_io_start __ev_io_start
#define ev_io_stop __ev_io_stop

#define ev_timer __ev_timer
#define ev_timer_init __ev_timer_init
#define ev_timer_set __ev_timer_set
#define ev_timer_start __ev_timer_start
#define ev_timer_stop __ev_timer_stop
#define ev_timer_again __ev_timer_again

#define ev_ref __ev_ref
#define ev_unref __ev_unref

#undef __uv_container_of
#undef __uv_warn_of

#endif /* NODE_EV_EMUL_H_ */
@@ -273,5 +273,10 @@ MakeCallback(const v8::Handle<v8::Object> object,
const v8::Handle<v8::Function> callback,
int argc,
v8::Handle<v8::Value> argv[]);

#if !defined(NODE_WANT_INTERNALS)
# include "ev-emul.h"
#endif

} // namespace node
#endif // SRC_NODE_H_
@@ -92,7 +92,7 @@ if (cmd === 'install') {
copy([
// Node
'src/node.h', 'src/node_buffer.h', 'src/node_object_wrap.h',
'src/node_version.h',
'src/node_version.h', 'src/ev-emul.h',
// v8
'deps/v8/include/v8-debug.h', 'deps/v8/include/v8-preparser.h',
'deps/v8/include/v8-profiler.h', 'deps/v8/include/v8-testing.h',

0 comments on commit f405517

Please sign in to comment.
You can’t perform that action at this time.