* database.c: print log messages for file defragmentations
authorArt Cancro <ajc@citadel.org>
Fri, 21 May 1999 00:04:44 +0000 (00:04 +0000)
committerArt Cancro <ajc@citadel.org>
Fri, 21 May 1999 00:04:44 +0000 (00:04 +0000)
        * citserver.c: implemented CtdlAllocUserData() and CtdlGetUserData()
          for arbitrary per-session data storage (by modules etc.) without
          having to add fields to struct CitContext
        * msgbase.c: removed "desired_section" from struct CitContext and
          implemented it using CtdlGetUserData() as a test.

citadel/ChangeLog
citadel/citserver.c
citadel/citserver.h
citadel/messages/hello
citadel/msgbase.c
citadel/server.h

index d34ed338293f688e7291cfaa4c7abbcfe41a0d42..a235422fc5f2341ad9791f249cd3c3f061eab063 100644 (file)
@@ -1,6 +1,13 @@
+Thu May 20 20:01:30 EDT 1999 Art Cancro <ajc@uncnsrd.mt-kisco.ny.us>
+       * database.c: print log messages for file defragmentations
+       * citserver.c: implemented CtdlAllocUserData() and CtdlGetUserData()
+         for arbitrary per-session data storage (by modules etc.) without
+         having to add fields to struct CitContext
+       * msgbase.c: removed "desired_section" from struct CitContext and
+         implemented it using CtdlGetUserData() as a test.
+
 Wed May 19 19:30:28 EDT 1999 Art Cancro <ajc@uncnsrd.mt-kisco.ny.us>
        * commands.c, commands.h, routines.c: began color scheme changes
-       * database.c: print log messages for file defragmentations
 
 1999-05-15 Nathan Bryant <bryant@cs.usm.maine.edu>
        * configure.in: Added untested support for BSDI 4.x.
index 5e685dbd97543d984f416e4728d59806f34bebbb..45e36721a170baa86aba19403a5cf164289f70fc 100644 (file)
@@ -88,6 +88,29 @@ void master_cleanup(void) {
        }
 
 
+/*
+ * Free any per-session data allocated by modules or whatever
+ */
+void deallocate_user_data(struct CitContext *con)
+{
+       struct CtdlSessData *ptr;
+
+       begin_critical_section(S_SESSION_TABLE);
+       while (con->FirstSessData != NULL) {
+               lprintf(9, "Deallocating user data symbol %ld\n",
+                       con->FirstSessData->sym_id);
+               if (con->FirstSessData->sym_data != NULL)
+                       phree(con->FirstSessData->sym_data);
+               ptr = con->FirstSessData->next;
+               phree(con->FirstSessData);
+               con->FirstSessData = ptr;
+       }
+       end_critical_section(S_SESSION_TABLE);
+}
+
+
+
+
 /*
  * Gracefully terminate the session and thread.
  * (This is called as a cleanup handler by the thread library.)
@@ -115,6 +138,9 @@ void cleanup_stuff(void *arg)
        /* Deallocate any message list we might have in memory */
        if (CC->msglist != NULL) phree(CC->msglist);
 
+       /* Deallocate any user-data attached to this session */
+       deallocate_user_data(CC);
+
        /* Now get rid of the session and context */
        lprintf(7, "cleanup_stuff() calling RemoveContext(%d)\n", CC->cs_pid);
        RemoveContext(CC);
@@ -126,6 +152,62 @@ void cleanup_stuff(void *arg)
        }
 
 
+
+/*
+ * Return a pointer to some generic per-session user data.
+ * (This function returns NULL if the requested symbol is not allocated.)
+ *
+ * NOTE: we use critical sections for allocating and de-allocating these,
+ *       but not for locating one.
+ */
+void *CtdlGetUserData(unsigned long requested_sym) 
+{
+       struct CtdlSessData *ptr;
+
+       for (ptr = CC->FirstSessData; ptr != NULL; ptr = ptr->next)
+               if (ptr->sym_id == requested_sym)
+                       return(ptr->sym_data);
+
+       lprintf(2, "ERROR! CtdlGetUserData(%ld) symbol not allocated\n",
+               requested_sym);
+       return NULL;
+}
+
+
+/*
+ * Allocate some generic per-session user data.
+ */
+void CtdlAllocUserData(unsigned long requested_sym, size_t num_bytes)
+{
+       struct CtdlSessData *ptr;
+
+       lprintf(9, "CtdlAllocUserData(%ld) called\n", requested_sym);
+
+       for (ptr = CC->FirstSessData; ptr != NULL; ptr = ptr->next)  {
+               if (ptr->sym_id == requested_sym) {
+                       lprintf(2, "ERROR: CtdlAllocUserData() requested for"
+                               " symbol id %ld already registered\n", 
+                               requested_sym);
+                       return;
+               }
+       }
+
+       ptr = mallok(sizeof(struct CtdlSessData));
+       ptr->sym_id = requested_sym;
+       ptr->sym_data = mallok(num_bytes);
+
+       begin_critical_section(S_SESSION_TABLE);
+       ptr->next = CC->FirstSessData;
+       CC->FirstSessData = ptr;
+       end_critical_section(S_SESSION_TABLE);
+
+       lprintf(9, "CtdlAllocUserData(%ld) finished\n", requested_sym);
+}
+
+
+
+
+
 /*
  * set_wtmpsupp()  -  alter the session listing
  */
@@ -741,6 +823,7 @@ void *context_loop(struct CitContext *con)
        CC->cs_flags = 0;
        CC->upload_type = UPL_FILE;
        CC->dl_is_net = 0;
+       CC->FirstSessData = NULL;
 
        num_sessions = session_count();
        CC->nologin = 0;
index a07682c34aa446d2dfeb183dc64570791e873c63..2f4534f1962c7efda3b74924fc5285f19df607d8 100644 (file)
@@ -23,3 +23,6 @@ void cmd_down (void);
 void cmd_scdn (char *argbuf);
 void cmd_extn (char *argbuf);
 void *context_loop (struct CitContext *con);
+void deallocate_user_data(struct CitContext *con);
+void *CtdlGetUserData(unsigned long requested_sym);
+void CtdlAllocUserData(unsigned long requested_sym, size_t num_bytes);
index f2ccad31860659fd629575270b7bce727b217cb6..beea9ef89585d72483f462e67ef45a4b6dacbc0a 100644 (file)
@@ -1,5 +1,4 @@
- < this logon banner resides in ./messages/hello >
-  Welcome to ^humannode !
+
+   *** YOU ARE LOGGED ON TO A TEST BBS ***
+
+
index 4b2c9ed850cba46ba7e790739fec025329bd3c70..7d325aeba17425fd405e900a980a58dfab59612c 100644 (file)
@@ -20,6 +20,7 @@
 #include "msgbase.h"
 #include "support.h"
 #include "sysdep_decls.h"
+#include "citserver.h"
 #include "room_ops.h"
 #include "user_ops.h"
 #include "file_ops.h"
@@ -35,6 +36,8 @@
 #define MSGS_LAST      4
 #define MSGS_GT                5
 
+#define desired_section ((char *)CtdlGetUserData(SYM_DESIRED_SECTION))
+
 extern struct config config;
 
 
@@ -368,7 +371,7 @@ void mime_download(char *name, char *filename, char *partnum, char *disp,
        if (CC->download_fp != NULL) return;
 
        /* ...or if this is not the desired section */
-       if (strcasecmp(CC->desired_section, partnum)) return;
+       if (strcasecmp(desired_section, partnum)) return;
 
        snprintf(tmpname, sizeof tmpname,
                "/tmp/CitServer.download.%4x.%4x", getpid(), ++seq);
@@ -506,7 +509,7 @@ time_t output_message(char *msgid, int mode, int headers_only) {
                        if (CC->download_fp == NULL) {
                                cprintf("%d Section %s not found.\n",
                                        ERROR+FILE_NOT_FOUND,
-                                       CC->desired_section);
+                                       desired_section);
                                }
                        }
                cdb_free(dmsgtext);
@@ -771,8 +774,10 @@ void cmd_opna(char *cmdbuf)
 {
        char msgid[256];
 
+       CtdlAllocUserData(SYM_DESIRED_SECTION, 64);
+
        extract(msgid, cmdbuf, 0);
-       extract(CC->desired_section, cmdbuf, 1);
+       extract(desired_section, cmdbuf, 1);
 
        output_message(msgid, MT_DOWNLOAD, 0);
        }
index b6cd9afa74ad9ac67bfc99d093becc942bf69e1e..d7c2361dcce4ae96783876a023e005f30980fb4b 100644 (file)
@@ -7,6 +7,21 @@ typedef pthread_t THREAD;
 /* #define DEBUG_MEMORY_LEAKS */
 
 
+/*
+ * Generic per-session variable or data structure storage
+ */
+struct CtdlSessData {
+       struct CtdlSessData *next;
+       unsigned long sym_id;
+       void *sym_data;
+};
+
+/*
+ * For the time being, all known userdata symbols are defined here.
+ */
+#define SYM_DESIRED_SECTION            0x00000001
+
+
 /*
  * Here's the big one... the Citadel context structure.
  *
@@ -19,63 +34,63 @@ typedef pthread_t THREAD;
 struct CitContext {
        struct CitContext *next;        /* Link to next session in the list */
 
-        struct usersupp usersupp;      /* Database record buffers */
-        struct quickroom quickroom;
-       
+       struct usersupp usersupp;       /* Database record buffers */
+       struct quickroom quickroom;
+
        long *msglist;
        int num_msgs;
 
-        char curr_user[32];            /* name of current user */
-        int logged_in;                 /* logged in */
-        int internal_pgm;              /* authenticated as internal program */
-        char temp[32];                 /* temp file name */
-        int nologin;                   /* not allowed to log in */
+       char curr_user[32];     /* name of current user */
+       int logged_in;          /* logged in */
+       int internal_pgm;       /* authenticated as internal program */
+       char temp[32];          /* temp file name */
+       int nologin;            /* not allowed to log in */
 
-        char net_node[32];
+       char net_node[32];
        THREAD mythread;
-       int n_crit;                     /* number of critical sections open */
+       int n_crit;             /* number of critical sections open */
        int client_socket;
-       int cs_pid;                     /* session ID */
+       int cs_pid;             /* session ID */
        char cs_room[ROOMNAMELEN];      /* current room */
-       time_t cs_lastupdt;             /* time of last update */
-       time_t lastcmd;                 /* time of last command executed */
-       time_t lastidle;                /* For computing idle time */
-       char lastcmdname[5];            /* name of last command executed */
-       unsigned cs_flags;              /* miscellaneous flags */
-
-                                       /* feeping creaturisms... */
-       int cs_clientdev;               /* client developer ID */
-       int cs_clienttyp;               /* client type code */
-       int cs_clientver;               /* client version number */
-       char cs_clientname[32];         /* name of client software */
-       char cs_host[25];               /* host logged in from */
-
-        FILE *download_fp;             /* Fields relating to file transfer */
-        FILE *upload_fp;
+       time_t cs_lastupdt;     /* time of last update */
+       time_t lastcmd;         /* time of last command executed */
+       time_t lastidle;        /* For computing idle time */
+       char lastcmdname[5];    /* name of last command executed */
+       unsigned cs_flags;      /* miscellaneous flags */
+
+                               /* feeping creaturisms... */
+       int cs_clientdev;       /* client developer ID */
+       int cs_clienttyp;       /* client type code */
+       int cs_clientver;       /* client version number */
+       char cs_clientname[32]; /* name of client software */
+       char cs_host[25];       /* host logged in from */
+
+       FILE *download_fp;      /* Fields relating to file transfer */
+       FILE *upload_fp;
        char upl_file[256];
        char upl_path[256];
        char upl_comment[256];
        char upl_filedir[256];
-       char chat_room[20];             /* The chat room */
+       char chat_room[20];     /* The chat room */
        char dl_is_net;
        char upload_type;
 
        struct ExpressMessage *FirstExpressMessage;
 
-       char fake_username[32];         /* Fake username <bc>                */
-       char fake_postname[32];         /* Fake postname <bc>                */
-       char fake_hostname[25];         /* Name of the fake hostname <bc>    */
-       char fake_roomname[ROOMNAMELEN];/* Name of the fake room <bc>        */
+       char fake_username[32]; /* Fake username <bc>                */
+       char fake_postname[32]; /* Fake postname <bc>                */
+       char fake_hostname[25]; /* Name of the fake hostname <bc>    */
+       char fake_roomname[ROOMNAMELEN]; /* Name of the fake room <bc> */
 
-       int FloorBeingSearched;         /* This is used by cmd_lrms() etc.   */
-       char desired_section[64];       /* This is used for MIME downloads   */
-       };
+       int FloorBeingSearched;    /* This is used by cmd_lrms() etc.   */
+       struct CtdlSessData *FirstSessData;
+};
 
 typedef struct CitContext t_context;
 
-#define CS_STEALTH     1               /* stealth mode */
-#define CS_CHAT                2               /* chat mode */
-#define CS_POSTING     4               /* Posting */
+#define CS_STEALTH     1       /* stealth mode */
+#define CS_CHAT                2       /* chat mode */
+#define CS_POSTING     4       /* Posting */
 
 struct CitContext *MyContext(void);
 #define CC ((struct CitContext *)MyContext())
@@ -87,15 +102,15 @@ extern struct CitControl CitControl;
 
 struct ExpressMessage {
        struct ExpressMessage *next;
-       time_t timestamp;               /* When this message was sent */
-       unsigned flags;                 /* Special instructions */
-       char sender[64];                /* Name of sending user */
-       char *text;                     /* Message text (if applicable) */
-       };
+       time_t timestamp;       /* When this message was sent */
+       unsigned flags;         /* Special instructions */
+       char sender[64];        /* Name of sending user */
+       char *text;             /* Message text (if applicable) */
+};
 
-#define EM_BROADCAST   1               /* Broadcast message */
-#define EM_GO_AWAY     2               /* Server requests client log off */
-#define EM_CHAT                4               /* Server requests client enter chat */
+#define EM_BROADCAST   1       /* Broadcast message */
+#define EM_GO_AWAY     2       /* Server requests client log off */
+#define EM_CHAT                4       /* Server requests client enter chat */
 
 struct ChatLine {
        struct ChatLine *next;
@@ -104,7 +119,7 @@ struct ChatLine {
        char chat_text[256];
        char chat_room[20];
        char chat_username[32];
-       };
+};
 
 /*
  * Various things we need to lock and unlock
@@ -135,12 +150,12 @@ struct ChatLine {
 /*
  * message transfer formats
  */
-#define MT_CITADEL     0               /* Citadel proprietary */
-#define MT_DATE                1               /* We're only looking for the date */
-#define MT_RFC822      2               /* RFC822 */
-#define MT_RAW         3               /* IGnet raw format */
-#define MT_MIME                4               /* MIME-formatted message */
-#define MT_DOWNLOAD    5               /* Download a component */
+#define MT_CITADEL     0       /* Citadel proprietary */
+#define MT_DATE                1       /* We're only looking for the date */
+#define MT_RFC822      2       /* RFC822 */
+#define MT_RAW         3       /* IGnet raw format */
+#define MT_MIME                4       /* MIME-formatted message */
+#define MT_DOWNLOAD    5       /* Download a component */
 
 
 /*
@@ -157,7 +172,7 @@ struct ChatLine {
 struct cdbdata {
        size_t len;
        char *ptr;
-       };
+};
 
 
 /* Structures and declarations for function hooks of various types */
@@ -166,13 +181,13 @@ struct LogFunctionHook {
        struct LogFunctionHook *next;
        int loglevel;
        void (*h_function_pointer) (char *);
-       };
+};
 extern struct LogFunctionHook *LogHookTable;
 
 struct CleanupFunctionHook {
        struct CleanupFunctionHook *next;
        void (*h_function_pointer) (void);
-       };
+};
 extern struct CleanupFunctionHook *CleanupHookTable;
 
 
@@ -186,7 +201,7 @@ struct SessionFunctionHook {
        struct SessionFunctionHook *next;
        void (*h_function_pointer) (void);
        int eventtype;
-       };
+};
 extern struct SessionFunctionHook *SessionHookTable;
 
 #define EVT_STOP       0       /* Session is terminating */
@@ -206,7 +221,7 @@ struct UserFunctionHook {
        struct UserFunctionHook *next;
        void (*h_function_pointer) (char *username, long usernum);
        int eventtype;
-       };
+};
 extern struct UserFunctionHook *UserHookTable;
 
 #define EVT_PURGEUSER  100     /* Deleting a user */
@@ -220,11 +235,11 @@ struct visit {
        long v_usernum;
        long v_lastseen;
        unsigned int v_flags;
-       };
+};
 
-#define V_FORGET       1               /* User has zapped this room        */
-#define V_LOCKOUT      2               /* User is locked out of this room  */
-#define V_ACCESS       4               /* Access is granted to this room   */
+#define V_FORGET       1       /* User has zapped this room        */
+#define V_LOCKOUT      2       /* User is locked out of this room  */
+#define V_ACCESS       4       /* Access is granted to this room   */
 
 #define UA_KNOWN                2
 #define UA_GOTOALLOWED          4
@@ -246,11 +261,11 @@ void *tracked_realloc(void *, size_t);
 void dump_tracked(void);
 
 struct TheHeap {
-        struct TheHeap *next;
-        char h_file[32];
-        int h_line;
-        void *h_ptr;
-        };
+       struct TheHeap *next;
+       char h_file[32];
+       int h_line;
+       void *h_ptr;
+};
 
 extern struct TheHeap *heap;