citadel/context.h

   1
   2 #ifndef CONTEXT_H
   3 #define CONTEXT_H
   4
   5 #include <stdarg.h>
   6 #include "sysdep.h"
   7 #include "server.h"
   8 #include "sysdep_decls.h"
   9 #include "threads.h"
  10
  11
  12 /*
  13  * Here's the big one... the Citadel context structure.
  14  *
  15  * This structure keeps track of all information relating to a running
  16  * session on the server.  We keep one of these for each session thread.
  17  *
  18  */
  19 struct CitContext {
  20         struct CitContext *prev;        /* Link to previous session in list */
  21         struct CitContext *next;        /* Link to next session in the list */
  22
  23         int cs_pid;             /* session ID */
  24         int dont_term;          /* for special activities like artv so we don't get killed */
  25         time_t lastcmd;         /* time of last command executed */
  26         time_t lastidle;        /* For computing idle time */
  27         int state;              /* thread state (see CON_ values below) */
  28         int kill_me;            /* Set to nonzero to flag for termination */
  29
  30         const char *Pos;        /* Our read position inside of the ReadBuf */
  31         StrBuf *ReadBuf;        /* Our block buffered read buffer */
  32         StrBuf *MigrateBuf;        /* Our block buffered read buffer */
  33
  34         const char *sPos;        /* Our read position inside of the ReadBuf */
  35         StrBuf *sReadBuf;        /* Our block buffered read buffer */
  36         StrBuf *sMigrateBuf;        /* Our block buffered read buffer */
  37         int client_socket;
  38         int is_local_socket;    /* set to 1 if client is on unix domain sock */
  39         /* Redirect this session's output to a memory buffer? */
  40         StrBuf *redirect_buffer;                /* the buffer */
  41 #ifdef HAVE_OPENSSL
  42         SSL *ssl;
  43         int redirect_ssl;
  44 #endif
  45
  46         char curr_user[USERNAME_SIZE];  /* name of current user */
  47         int logged_in;          /* logged in */
  48         int internal_pgm;       /* authenticated as internal program */
  49         int nologin;            /* not allowed to log in */
  50         int curr_view;          /* The view type for the current user/room */
  51         int is_master;          /* Is this session logged in using the master user? */
  52
  53         char net_node[32]       ;/* Is the client another Citadel server? */
  54         time_t previous_login;  /* Date/time of previous login */
  55         char lastcmdname[5];    /* name of last command executed */
  56         unsigned cs_flags;      /* miscellaneous flags */
  57         int is_async;           /* Nonzero if client accepts async msgs */
  58         int async_waiting;      /* Nonzero if there are async msgs waiting */
  59         int input_waiting;      /* Nonzero if there is client input waiting */
  60         int can_receive_im;     /* Session is capable of receiving instant messages */
  61
  62         /* Client information */
  63         int cs_clientdev;       /* client developer ID */
  64         int cs_clienttyp;       /* client type code */
  65         int cs_clientver;       /* client version number */
  66         uid_t cs_UDSclientUID;  /* the uid of the client when talking via UDS */
  67         char cs_clientname[32]; /* name of client software */
  68         char cs_host[64];       /* host logged in from */
  69         char cs_addr[64];       /* address logged in from */
  70
  71         /* The Internet type of thing */
  72         char cs_inet_email[128];                /* Return address of outbound Internet mail */
  73         char cs_inet_other_emails[1024];        /* User's other valid Internet email addresses */
  74         char cs_inet_fn[128];                   /* Friendly-name of outbound Internet mail */
  75
  76         FILE *download_fp;      /* Fields relating to file transfer */
  77         size_t download_fp_total;
  78         char download_desired_section[128];
  79         FILE *upload_fp;
  80         char upl_file[256];
  81         char upl_path[PATH_MAX];
  82         char upl_comment[256];
  83         char upl_filedir[PATH_MAX];
  84         char upl_mimetype[64];
  85         char dl_is_net;
  86         char upload_type;
  87
  88         struct ctdluser user;   /* Database record buffers */
  89         struct ctdlroom room;
  90
  91         /* Beginning of cryptography - session nonce */
  92         char cs_nonce[NONCE_SIZE];      /* The nonce for this session's next auth transaction */
  93
  94
  95         /* A linked list of all instant messages sent to us. */
  96         struct ExpressMessage *FirstExpressMessage;
  97         int disable_exp;        /* Set to 1 to disable incoming pages */
  98         int newmail;            /* Other sessions increment this */
  99
 100         /* Masqueraded values in the 'who is online' list */
 101         char fake_username[USERNAME_SIZE];
 102         char fake_hostname[64];
 103         char fake_roomname[ROOMNAMELEN];
 104
 105         /* Preferred MIME formats */
 106         char preferred_formats[256];
 107         int msg4_dont_decode;
 108
 109         /* Dynamically allocated session data */
 110         char *session_specific_data;            /* Used by individual protocol modules */
 111         struct cit_ical *CIT_ICAL;              /* calendaring data */
 112         struct ma_info *ma;                     /* multipart/alternative data */
 113         const char *ServiceName;                /* readable purpose of this session */
 114         void *openid_data;                      /* Data stored by the OpenID module */
 115         char *ldap_dn;                          /* DN of user when using AUTHMODE_LDAP */
 116
 117
 118         void (*h_command_function) (void) ;     /* service command function */
 119         void (*h_async_function) (void) ;       /* do async msgs function */
 120         void (*h_greeting_function) (void) ;    /* greeting function for session startup */
 121 };
 122
 123 typedef struct CitContext CitContext;
 124
 125 /*
 126  * Values for CitContext.state
 127  *
 128  * A session that is doing nothing is in CON_IDLE state.  When activity
 129  * is detected on the socket, it goes to CON_READY, indicating that it
 130  * needs to have a worker thread bound to it.  When a thread binds to
 131  * the session, it goes to CON_EXECUTING and does its thing.  When the
 132  * transaction is finished, the thread sets it back to CON_IDLE and lets
 133  * it go.
 134  */
 135 enum {
 136         CON_IDLE,               /* This context is doing nothing */
 137         CON_GREETING,           /* This context needs to output its greeting */
 138         CON_STARTING,           /* This context is outputting its greeting */
 139         CON_READY,              /* This context needs attention */
 140         CON_EXECUTING           /* This context is bound to a thread */
 141 };
 142
 143 #define CC MyContext()
 144
 145
 146 extern citthread_key_t MyConKey;                        /* TSD key for MyContext() */
 147 extern int num_sessions;
 148 extern CitContext masterCC;
 149 extern CitContext *ContextList;
 150
 151 CitContext *MyContext (void);
 152 void RemoveContext (struct CitContext *);
 153 CitContext *CreateNewContext (void);
 154 void context_cleanup(void);
 155 void kill_session (int session_to_kill);
 156 void InitializeMasterCC(void);
 157 void dead_session_purge(int force);
 158 void set_async_waiting(struct CitContext *ccptr);
 159
 160 /* Deprecated, user CtdlBumpNewMailCounter() instead */
 161 void BumpNewMailCounter(long) __attribute__ ((deprecated));
 162
 163 void terminate_idle_sessions(void);
 164 int CtdlTerminateOtherSession (int session_num);
 165 /* bits returned by CtdlTerminateOtherSession */
 166 #define TERM_FOUND      0x01
 167 #define TERM_ALLOWED    0x02
 168 #define TERM_KILLED     0x03
 169 #define TERM_NOTALLOWED -1
 170
 171 /*
 172  * Bind a thread to a context.  (It's inline merely to speed things up.)
 173  */
 174 static INLINE void become_session(CitContext *which_con) {
 175 /*
 176         pid_t tid = syscall(SYS_gettid);
 177 */
 178         citthread_setspecific(MyConKey, (void *)which_con );
 179 /*
 180         CtdlLogPrintf(CTDL_DEBUG, "[%d]: Now doing %s\n",
 181                       (int) tid,
 182                       ((which_con != NULL) && (which_con->ServiceName != NULL)) ?
 183                       which_con->ServiceName:"");
 184 */
 185 }
 186
 187
 188 #endif /* CONTEXT_H */