fo_server.h

Go to the documentation of this file.

/* {{{ Initial headers */
/*
 * $LastChangedDate: 2003-11-27 01:55:17 +0100 (Thu, 27 Nov 2003) $
 * $LastChangedRevision: 5 $
 * $LastChangedBy: ckruse $
 *
 */
/* }}} */

#ifndef __FO_SERVER_H
#define __FO_SERVER_H

#define SCHEDULING SCHED_OTHER

typedef struct s_posting {
  u_int64_t mid; 
  u_char *unid; 
  u_int32_t unid_len; 
  u_char *subject; 
  u_int32_t subject_len; 
  u_char *category; 
  u_int32_t category_len; 
  u_char *content; 
  u_int32_t content_len; 
  time_t date; 
  u_int16_t level; 
  u_int16_t invisible; 
  struct {
    u_char *name; 
    u_char *email; 
    u_char *hp; 
    u_char *img; 
    u_char *ip; 
    u_int32_t name_len; 
    u_int32_t email_len; 
    u_int32_t hp_len; 
    u_int32_t img_len; 
    u_int32_t ip_len; 
  } user;

  struct s_posting *next; 
  struct s_posting *prev; 
} t_posting;


typedef struct s_thread {
  u_int64_t tid; 
  t_cf_rwlock lock;

  t_posting *postings; 
  t_posting *newest; 
  t_posting *oldest; 
  t_posting *last; 
  int32_t posts; 
  struct s_thread *next; 
  struct s_thread *prev; 
} t_thread;

typedef void (*t_worker)(int); 
typedef struct s_client {
  int sock; 
  t_worker worker; 
  struct s_client *next; 
} t_client;

#define INITIAL_WORKERS_NUM 40 
#define MAX_WORKERS_NUM     45 
#define CLIENT_PRIORITY_NUM 43 
#define MAX_CLIENT_NUM      45 
typedef struct s_client_queque {
  t_cf_mutex lock; 
  t_cf_mutex cond_lock; 
  pthread_cond_t  cond; 
  u_int32_t workers; 
  u_int32_t clientnum; 
  int down; 
  t_client *clients; 
  t_client *last; 
} t_client_queque;

typedef struct s_server {
  int sock; 
  u_int32_t size; 
  t_worker worker; 
  struct sockaddr *addr; 
  struct s_server *next; 
} t_server;

typedef struct s_head {
  t_cf_rwlock lock;

  pthread_t workers[MAX_WORKERS_NUM];

  int fresh;

  t_string cache_visible;

  t_string cache_invisible;

  time_t date_visible;

  time_t date_invisible;

  t_thread *thread,*last;

  u_int64_t tid;

  u_int64_t mid;

  int locked;

  pthread_mutex_t log_lock;

  FILE *std;

  FILE *err;

   t_client_queque clients;

  t_cf_mutex server_lock;

  t_server *servers;

  #ifdef CF_SHARED_MEM

  #define CF_SHARED_MODE (SHM_R|SHM_W|(SHM_R>>3)|(SHM_R>>6))

  int shm_ids[2]; 
  int shm_sem; 
  void *shm_ptrs[2]; 
  t_cf_mutex shm_lock; 
  #endif

  t_cf_hash *protocol_handlers;

  t_cf_hash *threads;

  t_cf_rwlock threads_lock;
} t_head;

extern int    RUN; 
extern t_head head; 
void terminate(int n);

typedef int (*t_server_protocol_handler)(int,const u_char **,int,rline_t *); 
typedef int (*t_server_init_filter)(int); 
#endif

/* eof */

---