/common/home/bel/bella/lnx/exports/build/current/all/op-services/consmngr/srvr/consmngr.h

Go to the documentation of this file.

#ifndef CONSMNGR_H
#define CONSMNGR_H

#include <stdio.h>
#include <stdlib.h>
#include <unistd.h>
#include <string.h>
#include <time.h>
#include <libgen.h>
#include <sys/socket.h>
#include <sys/types.h>
#include <sys/stat.h>
#include <sys/inotify.h>
#include <fcntl.h>
#include <netinet/in.h>
#include <arpa/inet.h>
#include <errno.h>
#include <signal.h>
#include <wait.h>
#include "ix_tools.h"
#include "isintf.h"
#include "rsintf.h"
#include "consintf.h"
#include "xcons.h"
#include "uv.h"
#include "xvalue.h"
#include "xfreader.h"
#include "ixf.h"
#include "vmssys.h"
#include "version.h"

#define IX_V_INIT 0x02
#define IX_V_CMD 0x04
#define IX_V_WATCH 0x08
#define IX_V_NOTIFY 0x20
#define IX_V_XFER 0x40
#define IX_V_TIMER 0x80
#define IX_V_MSG 0x100
#define IX_V_RUNLEVEL 0x200
#define IX_V_DEBUG 0x400

#define MAX_SERVICES 8
#define CMD_MAX 256
#define PROC_MAX 256
#define LISTENER_MAX 32
#define CMD_LEN_MAX 4096

#define CONS_GUI "consgui"
#define CONS_PROG "KONS.sh"
#define BEAMLINEID "beamlineid"
#define BEAMLINEKEY "BEAMLINE_KEY"
#define CONS_USER "opcons"

#define CONS_WAIT_PROC "zdisup"

// default path for consoles logfile
#define CONS_PATH "/common/usr/develop/operating/log"

// configuration environment
#define CONFIG_ENV "BELA_CONFIGDIR"

typedef enum
{
  EXEC_START,
  EXEC_REMOVE
} cons_type_e;

/*
 * info and state of a process
 */
typedef struct
{
  char proc  [CMD_LEN_MAX];  // process name
  char cmdstr[CMD_LEN_MAX];  // command str from client
  int opt;                   // how the process is spawned
  int id;                    // id of command
  xf_t *pxf;                 // the associated client stream connection
  int result;                // result of command execution (exit code)
  pid_t pid;                 // process id of command, > 0: running
  pid_t pgid;                // process group id of command, 
                             // > 0: it is a group leader
  time_t term_time;           // the time process was terminated
  cons_type_e type;          // 
  int status;                // status of execution
  int runlevel;              // runlevel for group start command
  int fd[3];                 // stdin, stdout, stderr for process

} cmd_t;

// common message 
typedef struct
{
  xf_instance_t *pinst;
  xf_t *pxf;
} msg_t;

// listener for process list changes
typedef struct
{
  int lifetime;
  int minrunlevel;
  int maxrunlevel;
  xf_t *pxf;
} listener_t;

typedef struct
{
  int min;
  int max;
  int active;
  int level;
  int start;
} runlevel_t;

typedef struct
{
  char console[256];
  char options[256];
} console_t;

typedef struct
{
  char *myproc;
  char *consname;
  char *logpath;
  char logfn[PATH_MAX];
  int logfd;
  int log;
  int myudpport;
  int mytcpport;
  int mqevid;
  int daemon;
  int gui;
  char *guiprog;
  int zd;
  char *zdfn;
  int master;
  int test;
  int set;
  int undecor;

  int wait;
  int wait_time;
  char *wait_proc;

  ix_list_t *pcmd_list;
  ix_list_t *pproc_list;
  ix_list_t *plistener_list;
  ix_cs_t *pcs;
  int verbose;
  ix_msg_queue_t *pmq;
  ix_msg_queue_t *pdelayedmq;
  xf_refl_t *service_l[MAX_SERVICES];
  xf_refl_t *pcons_refl;

  ix_event_t *ptev;
  ix_event_t *prltev;
  ix_event_t *pmsgev;
  ix_event_t *pdelayedmsgev;
  ix_event_t *pdelayevent;
  ix_event_t *pkillevent;
  ix_event_t *psigev;
  ix_event_t *prunningev;

  ix_timer_t *pt;
  ix_timer_t *pdelaytimer;
  ix_timer_t *pkilltimer;
  ix_timer_t *prlt;
  rs_reg_t rs;

  int trun_f;
  int delay_f;
  int kill_f;

  char *user;
  char userhost[PATH_MAX];

  ix_thread_t *pstart;
  runlevel_t runlevel;
  int rl_timeout;
  int delay_timer;
  int kill_timer;
  int beamlineid;
  char beamkey[256];
  char hostname[512];
  char **environ;
} gl_data;


/***************************
 * main.c
 **************************/
cmd_t *cmd_new_proc( char *proc, char *cmdstr, int opt, int type, 
    int runlevel, int fd[3] );
cmd_t *cmd_new_xms( xcons_cmd_t *pc,  xf_t *pxf, int type );
void cmd_free( cmd_t * p);
int kick_update_listener(void);
int cancel_runlevel_timer(void);
int kick_handle_runlevel(void);
int kick_kill_timer(void);
int init_set( xcons_init_t *pinit );
int set_proc_env( char *proc );
int restart_proc( cmd_t *pcmd );
int add_uv_proc( cmd_t *proc );
int rm_uv_proc( cmd_t *proc );
int set_uv_proc( cmd_t *proc );



/***************************
 * proc.c 
 **************************/
/*
 * 0 ok
 * !0 error
 */
int add_proc( cmd_t *proc, int update_flag );
int exec_proc( cmd_t *proc );
int start_proc( char *proc );
int kill_proc( char *proc );
int rm_proc( char *proc );
int runlevel_proc( int min, int max );
int running_proc( char *proc );
void handle_runlevel(int timeout_f );
int quit_proc( int mode );
int is_inlist_proc( char *proc );
int _kill_proc( cmd_t *proc, int signal );

/*
 * <0: not known
 * 0: known, not running
 * >0: known running
 */
int check_proc( char *proc );
int check_proc_list(void);
int check_kill_list(void);

/***************************
 * db.c 
 ***************************/
int init_proc_list( xcons_init_t *pdef );

/****************************
 * xmsg.c 
 ****************************/
int update_listener(void);
int rm_listener( xf_t *pxf);
int add_listener( xcons_subscribe_t *psub, xf_t *pxf);
int proc_request( xcons_request_t *preq, xf_t *pxf );


#endif

---