addons/Socket/source/IoEvent.c

   1 //metadoc Event copyright Steve Dekorte, 2004
   2 //metadoc Event license BSD revised
   3 //metadoc Event description Networking Event.
   4 //metadoc category Networking
   5
   6 #include "IoEvent.h"
   7 #include "IoState.h"
   8 #include "IoNumber.h"
   9 #include "IoSeq.h"
  10
  11 #define EVENT(self) ((struct event *)IoObject_dataPointer(self))
  12
  13 IoEvent *IoMessage_locals_eventArgAt_(IoMessage *self, IoObject *locals, int n)
  14 {
  15         IoObject *v = IoMessage_locals_valueArgAt_(self, locals, n);
  16
  17         if (!ISEVENT(v))
  18         {
  19                 IoMessage_locals_numberArgAt_errorForType_(self, locals, n, "Event");
  20         }
  21
  22         return v;
  23 }
  24
  25 IoTag *IoEvent_newTag(void *state)
  26 {
  27         IoTag *tag = IoTag_newWithName_("Event");
  28         IoTag_state_(tag, state);
  29         IoTag_cloneFunc_(tag, (IoTagCloneFunc *)IoEvent_rawClone);
  30         IoTag_freeFunc_(tag, (IoTagFreeFunc *)IoEvent_free);
  31         return tag;
  32 }
  33
  34 IoEvent *IoEvent_proto(void *state)
  35 {
  36         IoObject *self = IoObject_new(state);
  37
  38         IoObject_tag_(self, IoEvent_newTag(state));
  39         IoObject_setDataPointer_(self, (struct event *)calloc(1, sizeof(struct event)));
  40
  41         IoState_registerProtoWithFunc_((IoState *)state, self, IoEvent_proto);
  42
  43         {
  44                 IoMethodTable methodTable[] = {
  45                 {"isPending", IoEvent_isPending},
  46                 {"isValid", IoEvent_isValid},
  47                 {NULL, NULL},
  48                 };
  49
  50                 IoObject_addMethodTable_(self, methodTable);
  51         }
  52
  53         IoObject_setSlot_to_(self, IOSYMBOL("EV_READ"), IONUMBER(EV_READ));
  54         IoObject_setSlot_to_(self, IOSYMBOL("EV_WRITE"), IONUMBER(EV_WRITE));
  55         IoObject_setSlot_to_(self, IOSYMBOL("EV_SIGNAL"), IONUMBER(EV_SIGNAL));
  56         //IoObject_setSlot_to_(self, IOSYMBOL("EV_TIMEOUT"), IONUMBER(EV_TIMEOUT));
  57         //IoObject_setSlot_to_(self, IOSYMBOL("EV_PERSIST"), IONUMBER(EV_PERSIST));
  58
  59         return self;
  60 }
  61
  62 IoEvent *IoEvent_rawClone(IoEvent *proto)
  63 {
  64         IoObject *self = IoObject_rawClonePrimitive(proto);
  65         IoObject_setDataPointer_(self, (struct event *)calloc(1, sizeof(struct event)));
  66         return self;
  67 }
  68
  69 IoEvent *IoEvent_new(void *state)
  70 {
  71         IoObject *proto = IoState_protoWithInitFunction_((IoState *)state, IoEvent_proto);
  72         return IOCLONE(proto);
  73 }
  74
  75 void IoEvent_free(IoEvent *self)
  76 {
  77         // this check ensures that libevent is never holding a referenced
  78         // to an IoEvent that has been collected
  79
  80         if (event_initialized(EVENT(self)) && event_pending(EVENT(self), 0, NULL))
  81         {
  82                 event_del(EVENT(self));
  83         }
  84
  85         free(EVENT(self));
  86 }
  87
  88 struct event *IoEvent_rawEvent(IoEvent *self)
  89 {
  90         return EVENT(self);
  91 }
  92
  93 IoObject *IoEvent_isPending(IoEvent *self, IoObject *locals, IoMessage *m)
  94 {
  95         int result = event_pending(EVENT(self), 0, NULL);
  96         return IOBOOL(self, result);
  97 }
  98
  99 IoObject *IoEvent_isValid(IoEvent *self, IoObject *locals, IoMessage *m)
 100 {
 101         return RawDescriptor_isValid(EVENT(self)->ev_fd) ? IOTRUE(self) : IOFALSE(self);
 102 }