eventd.c-Dateireferenz

#include <wizlevels.h>
#include <defines.h>
#include <events.h>

Include-Abhängigkeitsdiagramm für eventd.c:

gehe zum Quellcode dieser Datei

Makrodefinitionen
#define	STATISTICS
#define	HOME(x)   (__PATH__(0)+x)
#define	STORE   HOME("save/eventd")
#define	LOG(x)
#define	LOGEVENT(x, y, z)
#define	LOGREGISTER(w, x, y, z)
#define	LOGUNREGISTER(x, y, z)
#define	LOGEVENTFINISH(x, y)
#define	DEBUG(x)
#define	TICK_RESERVE   300000
#define	TICKSPERCALLBACK   30000
#define	CB_FUN   0
#define	CB_CLOSURE   1
#define	CB_OBJECT   2
#define	P_EID   0
#define	P_TRIGOB   1
#define	P_TRIGOBNAME   2
#define	P_ARGS   3
#define	P_TIME   4
#define	A_EID   0
#define	A_TRIGOB   1
#define	A_TRIGOBNAME   2
#define	A_ARGS   3
#define	A_LISTENERS   4
#define	A_TIME   5
Funktionen
protected void	save_me ()
varargs int	remove (int silent)
int	CheckEventID (string eid)
protected int	allowed (string eid, object ob, object po)
protected int	allowedtrigger (string eid, object trigger)
int	RegisterEvent (string eid, string fun, object ob)
int	UnregisterEvent (string eid, object ob)
varargs int	TriggerEvent (string eid, mixed args)
protected void	heart_beat ()
protected void	create ()
public void	reset ()
mapping	QueryEvents ()
mixed	QueryPending ()
mixed	QueryActive ()
mapping	QueryStats ()
int	UpdateMe (int flag)
Variablen
mapping	events = ([])
nosave mixed	pending = ({})
nosave mixed	active = ({})
int	lastboot
nosave int	updateme
nosave mapping	stats = ([])

---

Makro-Dokumentation

#define A_ARGS   3

Definiert in Zeile 62 der Datei eventd.c.

Wird benutzt von heart_beat().

#define A_EID   0

Definiert in Zeile 59 der Datei eventd.c.

Wird benutzt von heart_beat().

#define A_LISTENERS   4

Definiert in Zeile 63 der Datei eventd.c.

Wird benutzt von heart_beat() und UnregisterEvent().

#define A_TIME   5

Definiert in Zeile 64 der Datei eventd.c.

#define A_TRIGOB   1

Definiert in Zeile 60 der Datei eventd.c.

Wird benutzt von heart_beat().

#define A_TRIGOBNAME   2

Definiert in Zeile 61 der Datei eventd.c.

Wird benutzt von heart_beat().

#define CB_CLOSURE   1

Definiert in Zeile 49 der Datei eventd.c.

Wird benutzt von heart_beat().

#define CB_FUN   0

Definiert in Zeile 48 der Datei eventd.c.

#define CB_OBJECT   2

Definiert in Zeile 50 der Datei eventd.c.

Wird benutzt von heart_beat().

#define DEBUG

(

x

)

Wert:

if (find_player("zesstra"))\
          tell_object(find_player("zesstra"),\
                      "EDBG: "+x+"\n")

Definiert in Zeile 39 der Datei eventd.c.

#define HOME

(

x

)

(__PATH__(0)+x)

Definiert in Zeile 19 der Datei eventd.c.

#define LOG

(

x

)

Wert:

log_file("EVENTS", sprintf(\
      "[%s] %s\n",dtime(time()),x))

Definiert in Zeile 23 der Datei eventd.c.

Wird benutzt von cleanup_data(), create() und reset().

#define LOGEVENT	(	x,
		y,
		z		)

Definiert in Zeile 27 der Datei eventd.c.

Wird benutzt von TriggerEvent().

#define LOGEVENTFINISH	(	x,
		y		)

Definiert in Zeile 36 der Datei eventd.c.

#define LOGREGISTER	(	w,
		x,
		y,
		z		)

Definiert in Zeile 30 der Datei eventd.c.

Wird benutzt von RegisterEvent().

#define LOGUNREGISTER	(	x,
		y,
		z		)

Definiert in Zeile 33 der Datei eventd.c.

Wird benutzt von UnregisterEvent().

#define P_ARGS   3

Definiert in Zeile 55 der Datei eventd.c.

Wird benutzt von heart_beat().

#define P_EID   0

Definiert in Zeile 52 der Datei eventd.c.

Wird benutzt von heart_beat().

#define P_TIME   4

Definiert in Zeile 56 der Datei eventd.c.

Wird benutzt von heart_beat().

#define P_TRIGOB   1

Definiert in Zeile 53 der Datei eventd.c.

Wird benutzt von heart_beat().

#define P_TRIGOBNAME   2

Definiert in Zeile 54 der Datei eventd.c.

Wird benutzt von heart_beat().

#define STATISTICS

Definiert in Zeile 17 der Datei eventd.c.

#define STORE   HOME("save/eventd")

Definiert in Zeile 20 der Datei eventd.c.

#define TICK_RESERVE   300000

Definiert in Zeile 44 der Datei eventd.c.

Wird benutzt von heart_beat().

#define TICKSPERCALLBACK   30000

Definiert in Zeile 45 der Datei eventd.c.

---

Dokumentation der Funktionen

protected int allowed	(	string	eid,
		object	ob,
		object	po
	)

Definiert in Zeile 110 der Datei eventd.c.

                                                        {
    return(1);
}

protected int allowedtrigger	(	string	eid,
		object	trigger
	)

Definiert in Zeile 119 der Datei eventd.c.

Wird benutzt von TriggerEvent().

                                                         {
    return(1);
}

Hier ist ein Graph der zeigt, wo diese Funktion aufgerufen wird:

int CheckEventID

(

string

eid

)

Definiert in Zeile 99 der Datei eventd.c.

Benutzt events.

                             {
    if (!stringp(eid) || !member(events,eid))
        return 0;
    return(sizeof(events[eid]));
}

protected void create

(

)

Definiert in Zeile 269 der Datei eventd.c.

                        {
    seteuid(getuid(ME));
    restore_object(STORE);
    if (lastboot != __BOOT_TIME__) {
      // Oh. Reboot war... Alle Events wegschmeissen (es koennten zwar die
      // Eventanmeldungen von BPs ueberleben, aber auch die sollen sich lieber
      // im create() anmelden.)
      events=([]);
      lastboot=__BOOT_TIME__;;
    }
    set_heart_beat(0);
    LOG("Event-Dispatcher loaded");
}

protected void heart_beat

(

)

Definiert in Zeile 188 der Datei eventd.c.

Benutzt A_ARGS, A_EID, A_LISTENERS, A_TRIGOB, A_TRIGOBNAME, active, CB_CLOSURE, CB_OBJECT, cl, events, m_delete(), P_ARGS, P_EID, P_TIME, P_TRIGOB, P_TRIGOBNAME, pending, query_closure_object() und TICK_RESERVE.

                            {
  // solange ueber active und pending laufen, bis keine Ticks mehr da sind,
  // bzw. in der Schleife abgebrochen wird, weil keine Events mehr da sind.
  while(get_eval_cost() > TICK_RESERVE) {
    // HB abschalten, wenn nix zu tun ist.
    if (!sizeof(active)) {
      if (!sizeof(pending)) {
        set_heart_beat(0);
        return;
      }
      // scheint noch min. ein Eintrag in pending zu sein, nach active kopieren,
      // plus die Callback-Infos aus events
      active=({pending[0][P_EID],
               pending[0][P_TRIGOB],pending[0][P_TRIGOBNAME],
               pending[0][P_ARGS],                         
               deep_copy(events[pending[0][P_EID]]),
               pending[0][P_TIME] });

      if (sizeof(pending)>1)
        pending=pending[1..]; // und aus pending erstmal loeschen. ;-)
      else
        pending=({});
      //DEBUG(sprintf("Pending: %O",pending));
      //DEBUG(sprintf("Active: %O",active));
    }
    // jetzte den aktiven Event abarbeiten.
    // Infos aus active holen...
    string eid=active[A_EID];
    object trigob=active[A_TRIGOB];
    string trigobname=active[A_TRIGOBNAME];
    mixed args=active[A_ARGS];
    mapping listeners=active[A_LISTENERS];
    // und ueber alle Listener iterieren
    foreach(string obname, string fun, closure cl, object listener: 
                 listeners) {
      // erst pruefen, ob noch genug Ticks da sind. wenn nicht, gehts im
      // naechsten HB weiter.
      if (get_eval_cost() < TICK_RESERVE) {
        return;
      }
      // wenn Closure und/oder zugehoeriges Objekt nicht existieren, versuchen
      // wir erstmal, es wiederzufinden. ;-)
      if (!objectp(query_closure_object(cl))) {
        if (objectp(listener=find_object(obname)) &&
            closurep(cl=symbol_function(fun,listener))) {
            //geklappt, auch in events wieder ergaenzen
            events[eid][obname,CB_CLOSURE]=cl;
            events[eid][obname,CB_OBJECT]=listener;
        }
        else {
          // Objekt nicht gefunden oder Closure nicht erzeugbar, austragen
          efun::m_delete(listeners,obname);
          // und aus events austragen.
          efun::m_delete(events[eid],obname);
          // und naechster Durchgang
          continue;
        }
      }
      // Objekt noch da, Closure wird als ausfuehrbar betrachtet. 
      catch(limited(#'funcall,({TICKSPERCALLBACK}),cl,eid,trigob,args);publish);
      // fertig mit diesem Objekt.
      efun::m_delete(listeners,obname);
    }
    // Statistik? Differenzen zwische Erledigungszeit und Eintragszeit bilden
    // die Keys, die Values werden einfach hochgezaehlt.
#ifdef STATISTICS
    stats[time()-active[A_TIME]]++;
#endif // STATISTICS
    // ok, fertig mit active.
    active=({});
    //DEBUG(sprintf("Fertig: %O %O",eid, trigobname));
    LOGEVENTFINISH(eid,trigobname);
  }  // while(get_eval_cost() > TICK_RESERVE)
  // Soll dies Ding neugeladen werden? Wenn ja, Selbstzerstoerung, wenn keine
  // Events mehr da sind.
  if (updateme && !sizeof(active) && !sizeof(pending)) {
    DEBUG(sprintf("Update requested\n"));
    remove(1);
  }
}

Hier ist ein Graph der zeigt, was diese Funktion aufruft:

mixed QueryActive

(

)

Definiert in Zeile 314 der Datei eventd.c.

                    {
    return(deep_copy(active));
}

mapping QueryEvents

(

)

Definiert in Zeile 306 der Datei eventd.c.

                      {
    return(deep_copy(events));
}

mixed QueryPending

(

)

Definiert in Zeile 310 der Datei eventd.c.

                     {
    return(deep_copy(pending));
}

mapping QueryStats

(

)

Definiert in Zeile 318 der Datei eventd.c.

                     {
    return(copy(stats));
}

int RegisterEvent	(	string	eid,
		string	fun,
		object	ob
	)

Definiert in Zeile 127 der Datei eventd.c.

Benutzt allowed, cl, events, LOGREGISTER und save_me().

                                                     {
    object po;
    if (!stringp(eid) || !stringp(fun) || 
        !objectp(ob) || !objectp(po=previous_object()))
        return -1;
    if (!allowed(eid, ob, po)) return -2;
    closure cl=symbol_function(fun,ob);
    if (!closurep(cl))
        return -3;
    if (!mappingp(events[eid]))
        events[eid]=m_allocate(1,3); // 3 Werte pro Key
    events[eid]+=([object_name(ob):fun;cl;ob]);
    if (find_call_out(#'save_me)==-1)
        call_out(#'save_me,15);
    LOGREGISTER(ob,fun,eid,po);
    return 1;
}

Hier ist ein Graph der zeigt, was diese Funktion aufruft:

varargs int remove

(

int

silent

)

Definiert in Zeile 288 der Datei eventd.c.

                               {
    save_me();
    DEBUG(sprintf("remove() called by %O - destructing\n", previous_object())); 
    LOG(sprintf("remove called by %O - destructing",previous_object()));
    destruct(ME);
    return 1;
}

public void reset

(

void

)

Definiert in Zeile 296 der Datei eventd.c.

                    {
  if (updateme && !sizeof(active) && !sizeof(pending)) {
    DEBUG(sprintf("Update requested\n"));
    remove(1);
  }
}

protected void save_me

(

)

Definiert in Zeile 284 der Datei eventd.c.

                         {
  save_object(STORE);
}

varargs int TriggerEvent	(	string	eid,
		mixed	args
	)

Definiert in Zeile 174 der Datei eventd.c.

Benutzt allowedtrigger(), events, LOGEVENT und pending.

                                                 {
    object trigger;
    if (!stringp(eid) || 
        !objectp(trigger=previous_object())) 
        return -1;
    if (!allowedtrigger(eid, trigger)) return -2;
    if (!member(events,eid)) return -3;
    pending+=({ ({eid,trigger,object_name(trigger), args, time()}) });
    set_heart_beat(1);
    LOGEVENT(eid,trigger,args);
    //DEBUG(sprintf("%O",pending));
    return 1;
}

Hier ist ein Graph der zeigt, was diese Funktion aufruft:

int UnregisterEvent	(	string	eid,
		object	ob
	)

Definiert in Zeile 150 der Datei eventd.c.

Benutzt A_LISTENERS, active, events, LOGUNREGISTER, m_delete() und save_me().

                                           {
    object po;
    if (!stringp(eid) || !objectp(ob) || 
        !objectp(po=previous_object()) || !mappingp(events[eid]))
        return -1;
    string oname=object_name(ob);
    if (!member(events[eid],oname)) 
        return -2;
    efun::m_delete(events[eid],oname);
    if (!sizeof(events[eid]))
        efun::m_delete(events,eid);
    // aus aktivem Event austragen, falls es drin sein sollte.
    if (sizeof(active) && member(active,eid) 
        && member(active[eid,A_LISTENERS], oname)) {
        efun::m_delete(active[eid,A_LISTENERS],oname);
    }
    if (find_call_out(#'save_me)==-1)
      call_out(#'save_me,15);
    LOGUNREGISTER(ob, eid, po);
    return 1;
}

Hier ist ein Graph der zeigt, was diese Funktion aufruft:

int UpdateMe

(

int

flag

)

Definiert in Zeile 322 der Datei eventd.c.

                       {
    return (updateme=flag);
}

---

Variablen-Dokumentation

nosave mixed active = ({})

Definiert in Zeile 80 der Datei eventd.c.

Wird benutzt von activate(), add(), heart_beat(), Query_Keys(), ReadNewQuest(), renew_player_object(), setlist(), swho() und UnregisterEvent().

mapping events = ([])

Definiert in Zeile 71 der Datei eventd.c.

Wird benutzt von CheckEventID(), heart_beat(), RegisterEvent(), TriggerEvent() und UnregisterEvent().

int lastboot

Definiert in Zeile 82 der Datei eventd.c.

nosave mixed pending = ({})

Definiert in Zeile 75 der Datei eventd.c.

Wird benutzt von heart_beat(), Send(), TriggerEvent() und udp_www().

nosave mapping stats = ([])

Definiert in Zeile 90 der Datei eventd.c.

Wird benutzt von is_bank(), scan_obj() und stat().

nosave int updateme

Definiert in Zeile 85 der Datei eventd.c.