[ViewVC] Diff of: cvs/deliantra/server/server/cfperl.xs

Comparing deliantra/server/server/cfperl.xs (file contents):
Revision 1.85 by root, Sat Dec 16 03:08:26 2006 UTC vs.
Revision 1.108 by elmex, Mon Dec 25 11:16:48 2006 UTC

  *  GNU General Public License for more details.
  *
  *  You should have received a copy of the GNU General Public License
  *  along with this program; if not, write to the Free Software
  *  Foundation, Inc. 51 Franklin Street, Fifth Floor, Boston, MA  02110-1301 USA
-*/
+ */
 #define PLUGIN_NAME    "perl"
 #define PLUGIN_VERSION "cfperl 0.5"
 #include <plugin_common.h>
 #include <EXTERN.h>
 #include <perl.h>
 #include <XSUB.h>
+#include "CoroAPI.h"
 #include "perlxsi.c"
 extern sint64 *levels; // the experience table
 typedef object  object_ornull;
 static f_plug_api object_set_property = cfapi_object_set_property;
 static f_plug_api object_insert       = cfapi_object_insert;
 static PerlInterpreter *perl;
-static AV *cb_global, *cb_object, *cb_player, *cb_type, *cb_map;
+static AV *cb_global, *cb_object, *cb_player, *cb_client, *cb_type, *cb_map;
 //////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////
 static SV *
 newSVptr (void *ptr, const char *klass, HV *hv = newHV ())
 inline void sv_to (SV *sv, refptr<T>      &v) { T *tmp; sv_to (sv, tmp); v = tmp; }
 template<int N>
 inline void sv_to (SV *sv, char      (&v)[N]) { assign (v, SvPV_nolen (sv)); }
+inline void sv_to (SV *sv, rangetype      &v) { v = (rangetype)   SvIV (sv); }
+inline void sv_to (SV *sv, bowtype_t      &v) { v = (bowtype_t)   SvIV (sv); }
+inline void sv_to (SV *sv, petmode_t      &v) { v = (petmode_t)   SvIV (sv); }
+inline void sv_to (SV *sv, usekeytype     &v) { v = (usekeytype)  SvIV (sv); }
+inline void sv_to (SV *sv, unapplymode    &v) { v = (unapplymode) SvIV (sv); }
 inline void sv_to (SV *sv, UUID           &v)
 {
   unsigned int version;
   if (2 != sscanf (SvPV_nolen (sv), "<%d.%" SCNx64 ">", &version, &v.seq) || 1 != version)
     croak ("unparsable uuid: %s", SvPV_nolen (sv));
 }
+inline void sv_to (SV *sv, object::flags_t::reference v) { v = boolSV (sv); }
 static SV *
 newSVdt_va (va_list &ap, data_type type)
 {
   SV *sv;
       case DT_MAP:
         // va_arg (object *) when void * is passed is an XSI extension
         sv = to_sv (va_arg (ap, maptile *));
         break;
-      case DT_SOCKET:
+      case DT_CLIENT:
         sv = to_sv (va_arg (ap, client *));
         break;
       case DT_PLAYER:
         sv = to_sv (va_arg (ap, player *));
   HV *hv = (HV *)SvRV ((SV *)self);
   if (SvREFCNT ((SV *)self) == 1
       && SvREFCNT ((SV *)hv) == 1
-      && !HvKEYS (hv))
+      && !HvTOTALKEYS (hv))
     {
       SvREFCNT_dec ((SV *)self);
       self = 0;
     }
 }
   switch (type)
     {
       case DT_OBJECT: INVOKE_OBJECT (REATTACH, obj); break;
       case DT_PLAYER: INVOKE_PLAYER (REATTACH, obj); break;
+      case DT_CLIENT: INVOKE_CLIENT (REATTACH, obj); break;
       case DT_MAP:    INVOKE_MAP    (REATTACH, obj); break;
     }
 }
 template<class subclass>
   PL_exit_flags |= PERL_EXIT_DESTRUCT_END;
   char *argv[] = {
     "",
     "-e"
-    "use Event;"      // required for bootstrap
+    "use Event; use Coro;" // required for bootstrap
-    "cf->bootstrap;"  // required for datadir :*>
+    "cf->bootstrap;"       // required for datadir :*>
     "unshift @INC, cf::datadir ();"
     "require cf;"
   };
   if (perl_parse (perl, xs_init, 2, argv, (char **)NULL) || perl_run (perl))
   AV *callbacks = 0;
   object *op;
   player *pl;
   maptile *map;
+  client *ns;
   // callback call ordering is:
   // 1. per-object callback
   // 2. per-class object
   // 3. per-type callback
           gather_callbacks (callbacks, map->cb, event);
         gather_callbacks (callbacks, cb_map, event);
         break;
+      case KLASS_CLIENT:
+        dt = (data_type) va_arg (ap, int);
+        assert (("first argument must be of type client", dt == DT_CLIENT));
+        ns = va_arg (ap, client *);
+        if (ns->cb)
+          gather_callbacks (callbacks, ns->cb, event);
+        gather_callbacks (callbacks, cb_client, event);
+        break;
       default:
         assert (("unsupported event klass in cfperl_invoke", 0));
     }
   // short-circuit processing if no callbacks found/defined
   switch (KLASS_OF (event))
     {
       case KLASS_OBJECT: PUSHs (sv_2mortal (newSVdt (DT_OBJECT, op)));  break;
       case KLASS_PLAYER: PUSHs (sv_2mortal (newSVdt (DT_PLAYER, pl)));  break;
+      case KLASS_CLIENT: PUSHs (sv_2mortal (newSVdt (DT_CLIENT, ns)));  break;
       case KLASS_MAP:    PUSHs (sv_2mortal (newSVdt (DT_MAP,    map))); break;
     }
   for (;;)
     {
 {
   HV *stash = gv_stashpv ("cf", 1);
   I_EVENT_API (PACKAGE);
   watcher_base::GEventAPI = GEventAPI;
+  I_CORO_API (PACKAGE);
   newCONSTSUB (stash, "VERSION", newSVpv (VERSION, sizeof (VERSION) - 1));
   static const struct {
     const char *name;
     const_iv (POTION)
     const_iv (FOOD)
     const_iv (POISON)
     const_iv (BOOK)
     const_iv (CLOCK)
-    const_iv (LIGHTNING)
     const_iv (ARROW)
     const_iv (BOW)
     const_iv (WEAPON)
     const_iv (ARMOUR)
     const_iv (PEDESTAL)
     const_iv (AMULET)
     const_iv (PLAYERMOVER)
     const_iv (TELEPORTER)
     const_iv (CREATOR)
     const_iv (SKILL)
-    const_iv (EXPERIENCE)
     const_iv (EARTHWALL)
     const_iv (GOLEM)
     const_iv (THROWN_OBJ)
     const_iv (BLINDNESS)
     const_iv (GOD)
     const_iv (FLOOR)
     const_iv (FLESH)
     const_iv (INORGANIC)
     const_iv (SKILL_TOOL)
     const_iv (LIGHTER)
-    const_iv (TRAP_PART)
-    const_iv (WALL)
+    const_iv (BUILDABLE_WALL)
-    const_iv (LIGHT_SOURCE)
     const_iv (MISC_OBJECT)
-    const_iv (MONSTER)
-    const_iv (SPAWN_GENERATOR)
     const_iv (LAMP)
     const_iv (DUPLICATOR)
-    const_iv (TOOL)
     const_iv (SPELLBOOK)
-    const_iv (BUILDFAC)
     const_iv (CLOAK)
     const_iv (SPINNER)
     const_iv (GATE)
     const_iv (BUTTON)
     const_iv (CF_HANDLE)
     const_iv (SPELL_EFFECT)
     const_iv (CONVERTER)
     const_iv (BRACERS)
     const_iv (POISONING)
     const_iv (SAVEBED)
-    const_iv (POISONCLOUD)
-    const_iv (FIREHOLES)
     const_iv (WAND)
     const_iv (SCROLL)
     const_iv (DIRECTOR)
     const_iv (GIRDLE)
     const_iv (FORCE)
     const_iv (DISEASE)
     const_iv (SYMPTOM)
     const_iv (BUILDER)
     const_iv (MATERIAL)
     const_iv (ITEM_TRANSFORMER)
-    const_iv (QUEST)
     const_iv (NUM_SUBTYPES)
     const_iv (ST_BD_BUILD)
     const_iv (ST_BD_REMOVE)
     const_iv (FLAG_MONSTER)
     const_iv (FLAG_FRIENDLY)
     const_iv (FLAG_GENERATOR)
     const_iv (FLAG_IS_THROWN)
     const_iv (FLAG_AUTO_APPLY)
-    const_iv (FLAG_TREASURE)
     const_iv (FLAG_PLAYER_SOLD)
     const_iv (FLAG_SEE_INVISIBLE)
     const_iv (FLAG_CAN_ROLL)
     const_iv (FLAG_OVERLAY_FLOOR)
     const_iv (FLAG_IS_TURNABLE)
     const_iv (FLAG_ACTIVATE_ON_RELEASE)
     const_iv (FLAG_IS_WATER)
     const_iv (FLAG_CONTENT_ON_GEN)
     const_iv (FLAG_IS_A_TEMPLATE)
     const_iv (FLAG_IS_BUILDABLE)
-    const_iv (FLAG_AFK)
     const_iv (NDI_BLACK)
     const_iv (NDI_WHITE)
     const_iv (NDI_NAVY)
     const_iv (NDI_RED)
     const_iv (F_BUY)
     const_iv (F_SHOP)
     const_iv (F_SELL)
     const_iv (P_BLOCKSVIEW)
+    const_iv (P_PLAYER)
     const_iv (P_NO_MAGIC)
     const_iv (P_IS_ALIVE)
     const_iv (P_NO_CLERIC)
     const_iv (P_NEED_UPDATE)
-    const_iv (P_NO_ERROR)
     const_iv (P_OUT_OF_MAP)
     const_iv (P_NEW_MAP)
     const_iv (UP_OBJ_INSERT)
     const_iv (UP_OBJ_REMOVE)
     const_iv (MAP_LOADING)
     const_iv (MAP_SAVING)
     const_iv (KLASS_GLOBAL)
     const_iv (KLASS_OBJECT)
+    const_iv (KLASS_CLIENT)
     const_iv (KLASS_PLAYER)
     const_iv (KLASS_MAP)
+    const_iv (CS_QUERY_YESNO)
+    const_iv (CS_QUERY_SINGLECHAR)
+    const_iv (CS_QUERY_HIDEINPUT)
+    const_iv (ST_DEAD)
+    const_iv (ST_SETUP)
+    const_iv (ST_PLAYING)
+    const_iv (ST_CUSTOM)
+    const_iv (ST_CHANGE_CLASS)
+    const_iv (ST_CONFIRM_QUIT)
+    const_iv (ST_GET_PARTY_PASSWORD)
   };
   for (civ = const_iv + sizeof (const_iv) / sizeof (const_iv [0]); civ-- > const_iv; )
     newCONSTSUB (stash, (char *)civ->name, newSViv (civ->iv));
 void _init_vars ()
 	CODE:
         cb_global  = get_av ("cf::CB_GLOBAL", 1);
         cb_object  = get_av ("cf::CB_OBJECT", 1);
         cb_player  = get_av ("cf::CB_PLAYER", 1);
+        cb_client  = get_av ("cf::CB_CLIENT", 1);
         cb_type    = get_av ("cf::CB_TYPE"  , 1);
         cb_map     = get_av ("cf::CB_MAP"   , 1);
 void _global_reattach ()
 	CODE:
 {
         // reattach to all attachable objects in the game.
+        for (sockvec::iterator i = clients.begin (); i != clients.end (); ++i)
+          reattach (*i);
         for (player *pl = first_player; pl; pl = pl->next)
           reattach (pl);
         for (maptile *map = first_map; map; map = map->next)
           reattach (map);
         for (object *op = object::first; op; op = op->next)
           reattach (op);
 }
-bool
-add_client (int fd, const char *peername)
 NV floor (NV x)
 NV ceil (NV x)
 int random_roll (int min, int max, object *op, int goodbad);
 const char *cost_string_from_value(uint64 cost, int approx = 0)
-int invoke (int event, ...)
-	CODE:
-        if (KLASS_OF (event) != KLASS_GLOBAL) croak ("event class must be GLOBAL");
-	AV *av = (AV *)sv_2mortal ((SV *)newAV ());
-        for (int i = 1; i < items; i++) av_push (av, SvREFCNT_inc (ST (i)));
-        RETVAL = INVOKE_((event_type)event, ARG_AV (av));
-	OUTPUT: RETVAL
 int
 exp_to_level (val64 exp)
         CODE:
 {
         int i = 0;
           RETVAL = newSVpv (resist_plus[atnr], 0);
         else
           XSRETURN_UNDEF;
         OUTPUT: RETVAL
+MODULE = cf        PACKAGE = cf::attachable
 int
-_valid (SV *obj)
+valid (SV *obj)
 	CODE:
         RETVAL = SvROK (obj) && mg_find (SvRV (obj), PERL_MAGIC_ext);
 	OUTPUT:
 	RETVAL
+MODULE = cf        PACKAGE = cf::global
+int invoke (SV *klass, int event, ...)
+	CODE:
+        if (KLASS_OF (event) != KLASS_GLOBAL) croak ("event class must be GLOBAL");
+	AV *av = (AV *)sv_2mortal ((SV *)newAV ());
+        for (int i = 1; i < items; i++) av_push (av, SvREFCNT_inc (ST (i)));
+        RETVAL = INVOKE_((event_type)event, ARG_AV (av));
+	OUTPUT: RETVAL
 MODULE = cf        PACKAGE = cf::object         PREFIX = cf_object_
 INCLUDE: $PERL genacc object ../include/object.h |
         RETVAL = object::first;
 	OUTPUT: RETVAL
 # missing properties
-int flag (object *op, int flag, int value = 1)
-	PROTOTYPE: $$;$
-	CODE:
-        RETVAL = QUERY_FLAG (op, flag);
-        if (items >= 3)
-          if (value)
-            SET_FLAG (op, flag);
-          else
-            CLEAR_FLAG (op, flag);
-        OUTPUT: RETVAL
 object *head (object *op)
 	PROTOTYPE: $
 	CODE:
         RETVAL = op->head ? op->head : op;
         OUTPUT: RETVAL
 	PROTOTYPE: $
         PPCODE:
 {
 	object *o;
 	for (o = obj->inv; o; o = o->below)
-          XPUSHs (sv_2mortal (newSVcfapi (CFAPI_POBJECT, o)));
+          XPUSHs (sv_2mortal (to_sv (o)));
 }
+void
+set_animation (object *op, int idx)
+	CODE:
+        SET_ANIMATION (op, idx);
+void
+object::drain_stat ()
+void
+object::drain_specific_stat (int stat)
+void
+object::change_luck (int change)
+void
+object::add_statbonus ()
+void
+object::remove_statbonus ()
 object *find_best_object_match (object *op, const char *match)
 object *find_marked_object (object *op)
-int resistance (object *op, int rtype, int newval = 0)
-        CODE:
-        if (rtype < 0 || rtype >= NROFATTACKS)
-          croak ("resistance out of bounds");
-        RETVAL = op->resist [rtype];
-        if (items >= 3)
-          op->resist [rtype] = newval;
-        OUTPUT: RETVAL
-void set_resistance (object *op, int rtype, int val)
-        CODE:
-        if (rtype < 0 || rtype >= NROFATTACKS)
-        op->resist[rtype] = val;
 int need_identify (const object *obj);
 int apply_shop_mat (object *shop_mat, object *op);
 void remove (object *op)
 	CODE:
         op->remove ();
-void destroy (object *op, int recursive = 0)
+void
-	CODE:
+object::destroy (int recursive = 0)
-        op->destroy (recursive);
 object *cf_object_present_archname_inside (object *op, char *whatstr)
 int cf_object_transfer (object *op, int x, int y, int r = 0, object_ornull *orig = 0)
 	OUTPUT: RETVAL
 int query_money (object *op)
 	ALIAS: money = 0
-int query_cost (object *op, object *who, int flags)
+val64 query_cost (object *op, object *who, int flags)
 	ALIAS: cost = 0
 void spring_trap (object *op, object *victim)
 int check_trigger (object *op, object *cause)
 object *cf_object_insert_in_ob (object *ob, object *where)
 int cf_object_teleport (object *op, maptile *map, int x, int y)
-void update (object *op, int action)
+void update_object (object *op, int action)
-	CODE:
-        update_object (op, action);
 object *cf_create_object_by_name (const char *name)
 void change_exp (object *op, uint64 exp, const char *skill_name = 0, int flag = 0)
 void remove_button_link (object *op);
 MODULE = cf        PACKAGE = cf::object         PREFIX = cf_
-void cf_fix_object (object *pl)
-	ALIAS: fix = 0
 object *cf_insert_ob_in_ob (object *ob, object *where)
 # no clean way to get an object from an archetype - stupid idiotic
 # dumb kludgy misdesigned plug-in api slowly gets on my nerves.
 player *contr (object *op)
 	CODE:
         RETVAL = op->contr;
         OUTPUT: RETVAL
+void
+object::roll_stats ()
+void
+object::update_stats ()
+void
+object::swap_stats (int a, int b)
 const char *get_ob_key_value (object *op, const char *key)
 bool set_ob_key_value (object *op, const char *key, const char *value = 0, int add_key = 1)
 base_name (object *op, int plural = op->nrof > 1)
         CODE:
         RETVAL = query_base_name (op, plural);
         OUTPUT: RETVAL
+object *decrease_ob_nr (object *op, unsigned long i)
 MODULE = cf        PACKAGE = cf::object::player PREFIX = cf_player_
 player *player (object *op)
 	CODE:
         RETVAL = op->contr;
 	OUTPUT: RETVAL
+void check_score (object *op)
 void cf_player_message (object *obj, char *txt, int flags = NDI_ORANGE | NDI_UNIQUE)
 object *cf_player_send_inventory (object *op)
         RETVAL = INVOKE_((event_type)event, ARG_PLAYER (pl), ARG_AV (av));
 	OUTPUT: RETVAL
 SV *registry (player *pl)
+player *
+create ()
+	CODE:
+        RETVAL = player::create ();
+	OUTPUT:
+        RETVAL
+player *
+load (const char *path)
+	CODE:
+        RETVAL = player::load (path);
+	OUTPUT:
+        RETVAL
+void
+player::save (bool final = false)
+void
+player::connect (client *ns)
+void
+save_stats (player *pl)
+	CODE:
+        pl->ob->stats.hp    = pl->ob->stats.maxhp;
+        pl->ob->stats.sp    = pl->ob->stats.maxsp;
+        pl->ob->stats.grace = pl->ob->stats.maxgrace;
+        pl->orig_stats      = pl->ob->stats;
 player *cf_player_find (char *name)
 	PROTOTYPE: $
 void cf_player_move (player *pl, int dir)
 player *first ()
 	CODE:
         RETVAL = first_player;
         OUTPUT: RETVAL
-player *next (player *pl)
-	CODE:
-        RETVAL = pl->next;
-        OUTPUT: RETVAL
 bool
 cell_visible (player *pl, int dx, int dy)
 	CODE:
-        RETVAL = FABS (dx) <= pl->socket->mapx / 2 && FABS (dy) <= pl->socket->mapy / 2
+        RETVAL = FABS (dx) <= pl->ns->mapx / 2 && FABS (dy) <= pl->ns->mapy / 2
-                 && !pl->blocked_los [dx + pl->socket->mapx / 2][dy + pl->socket->mapy / 2];
+                 && !pl->blocked_los [dx + pl->ns->mapx / 2][dy + pl->ns->mapy / 2];
         OUTPUT:
         RETVAL
 void
 send (player *pl, SV *packet)
 	CODE:
 {
 	STRLEN len;
 	char *buf = SvPVbyte (packet, len);
+        if (pl->ns)
-        pl->socket->send_packet (buf, len);
+          pl->ns->send_packet (buf, len);
 }
 int
 listening (player *pl, int new_value = -1)
 	CODE:
         if (y)        sv_to (y,        pl->bed_y);
 void
 list ()
 	PPCODE:
-{
-	player *pl;
-        for (pl = first_player; pl; pl = pl->next)
+        for (player *pl = first_player; pl; pl = pl->next)
-          XPUSHs (newSVcfapi (CFAPI_PPLAYER, pl));
+          XPUSHs (sv_2mortal (to_sv (pl)));
-}
 bool
 peaceful (player *pl, bool new_setting = 0)
 	PROTOTYPE: $;$
         CODE:
 INCLUDE: $PERL genacc client ../include/client.h |
 int invoke (client *ns, int event, ...)
 	CODE:
-        if (KLASS_OF (event) != KLASS_SOCKET) croak ("event class must be SOCKET");
+        if (KLASS_OF (event) != KLASS_CLIENT) croak ("event class must be CLIENT");
 	AV *av = (AV *)sv_2mortal ((SV *)newAV ());
         for (int i = 2; i < items; i++) av_push (av, SvREFCNT_inc (ST (i)));
-        RETVAL = INVOKE_((event_type)event, ARG_SOCKET (ns), ARG_AV (av));
+        RETVAL = INVOKE_((event_type)event, ARG_CLIENT (ns), ARG_AV (av));
 	OUTPUT: RETVAL
 SV *registry (client *ns)
+void
+list ()
+	PPCODE:
+        EXTEND (SP, clients.size ());
+        for (sockvec::iterator i = clients.begin (); i != clients.end (); ++i)
+          PUSHs (sv_2mortal (to_sv (*i)));
+client *
+create (int fd, const char *peername)
+	CODE:
+        RETVAL = client::create (fd, peername);
+	OUTPUT:
+        RETVAL
+void
+client::send_packet (SV *packet)
+	CODE:
+{
+	STRLEN len;
+	char *buf = SvPVbyte (packet, len);
+        THIS->send_packet (buf, len);
+}
+void
+client::destroy ()

Diff Legend

-–
+Removed lines
-+
+Added lines
-<
+Changed lines
->
+Changed lines

Comparing deliantra/server/server/cfperl.xs (file contents): Revision 1.85 by root, Sat Dec 16 03:08:26 2006 UTC vs. Revision 1.108 by elmex, Mon Dec 25 11:16:48 2006 UTC

Diff Legend

Comparing deliantra/server/server/cfperl.xs (file contents):
Revision 1.85 by root, Sat Dec 16 03:08:26 2006 UTC vs.
Revision 1.108 by elmex, Mon Dec 25 11:16:48 2006 UTC