lazylogger.cxx File Reference

#include "midas.h"
#include "msystem.h"
#include "mstrlcpy.h"
#include <libgen.h>
#include <mutex>
#include <iostream>
#include "mdsupport.h"
#include <assert.h>
#include <vector>
#include <string>
#include <algorithm>

Include dependency graph for lazylogger.cxx:

Go to the source code of this file.

Classes
struct	DIRLOG
struct	LAZY_SETTING
struct	LAZY_STATISTICS
struct	LAZY_INFO

Macros
#define	URL_SIZE   256
#define	NOTHING_TODO   0
#define	FORCE_EXIT   1
#define	EXIT_REQUEST   2
#define	TRY_LATER   3
#define	NEW_FILE   1
#define	REMOVE_FILE   2
#define	REMOVE_ENTRY   3
#define	MAX_LAZY_CHANNEL   100
#define	TRACE
#define	LOG_TYPE_SCRIPT   (-1)
#define	DONTOPENZIP   0
#define	MAX_FILE_PATH   128
#define	LAZY_SETTINGS_STRING   "\Period = INT : 10\n\Maintain free space (%) = INT : 0\n\Stay behind = INT : 0\n\Alarm Class = STRING : [32]\n\Running condition = STRING : [128] ALWAYS\n\Data dir = STRING : [256] \n\Data format = STRING : [8] MIDAS\n\Filename format = STRING : [128] run%05d.mid\n\Backup type = STRING : [8] Tape\n\Execute after rewind = STRING : [64]\n\Path = STRING : [128] \n\Capacity (Bytes) = FLOAT : 5e9\n\List label= STRING : [128] \n\Execute before writing file = STRING : [64]\n\Execute after writing file = STRING : [64]\n\Modulo.Position = STRING : [8]\n\Copy Delay = INT : 0\n\Tape Data Append = BOOL : y\n\"
#define	LAZY_STATISTICS_STRING   "\Backup file = STRING : [128] none \n\File size (Bytes) = DOUBLE : 0.0\n\KBytes copied = DOUBLE : 0.0\n\Total Bytes copied = DOUBLE : 0.0\n\Copy progress (%) = DOUBLE : 0\n\Copy Rate (Bytes per s) = DOUBLE : 0\n\Backup status (%) = DOUBLE : 0\n\Number of Files = INT : 0\n\Current Lazy run = INT : 0\n\"
#define	WATCHDOG_TIMEOUT   60000 /* 60 sec for tape access */

Typedefs
typedef std::vector< DIRLOG >	DIRLOGLIST

Functions
bool	cmp_dirlog1 (const DIRLOG &a, const DIRLOG &b)
bool	cmp_dirlog (const DIRLOG &a, const DIRLOG &b)
INT	moduloCheck (INT lModulo, INT lPosition, INT lrun)
BOOL	lazy_file_exists (char *dir, char *file)
INT	lazy_main (INT, LAZY_INFO *, int max_event_size)
INT	lazy_copy (char *dev, char *file, int max_event_size)
INT	lazy_load_params (HNDLE hDB, HNDLE hKey)
INT	build_log_list (const char *fmt, const char *dir, DIRLOGLIST *plog)
INT	build_done_list_odb (HNDLE, INT **)
void	lazy_settings_hotlink (HNDLE hDB, HNDLE hKey, void *info)
void	lazy_maintain_check (HNDLE hKey, LAZY_INFO *pLall)
void	print_dirlog (const DIRLOGLIST *dirlog)
INT	lazy_trstop (INT rn, char *error)
INT	lazy_run_extract (const char *name)
INT	lazy_file_remove (const char *pufile)
INT	lazy_log_update (INT action, INT run, const char *label, const char *file, DWORD perf_time)
std::string	list_filename (const char *lazyname, const char *listname)
void	load_done_list (const char *lazyname, const DIRLOGLIST *dirlist, DIRLOGLIST *dlist)
int	save_list (const char *lazyname, const char *listname, const DIRLOGLIST *dlist)
void	convert_done_list (HNDLE hLch)
INT	build_done_list (HNDLE hLch, const DIRLOGLIST *pdirlist, DIRLOGLIST *pdone)
INT	save_done_list (HNDLE hLch, DIRLOGLIST *pdone)
int	find_next_file (const DIRLOGLIST *plog, const DIRLOGLIST *pdone)
INT	lazy_select_purge (HNDLE hKey, INT channel, LAZY_INFO *pLall, const char *fmt, const char *dir, DIRLOG *f)
void	lazy_statistics_update (INT cploop_time)
BOOL	condition_test (char *string)
BOOL	lazy_condition_check (void)
int	lazy_disk_copy_loop (const char *outfile, const char *infile, FILE *fpout, FILE *fpin)
INT	lazy_disk_copy (const char *outfile, const char *infile)
INT	lazy_maintain_free_space (LAZY_INFO *pLch, LAZY_INFO *pLall)
static void	watch_settings (HNDLE hDB, HNDLE hKey, HNDLE index, void *info)
int	main (int argc, char **argv)

Variables
BOOL	debug = FALSE
	debug printouts
BOOL	nodelete = FALSE
LAZY_SETTING	lazy
LAZY_STATISTICS	lazyst
LAZY_INFO	lazyinfo [MAX_LAZY_CHANNEL] = {{0, FALSE, "Tape"}}
INT	channel = -1
INT	lazy_semaphore
HNDLE	hDB
	main ODB handle
HNDLE	hKey
HNDLE	pcurrent_hKey
double	lastsz
HNDLE	hKeyst
INT	run_state
INT	hDev
BOOL	msg_flag
BOOL	convert_flag = FALSE
BOOL	copy_continue = TRUE
INT	data_fmt
INT	dev_type
char	lazylog [MAX_STRING_LENGTH]
BOOL	full_bck_flag = FALSE
BOOL	maintain_touched = FALSE
INT	blockn = 0
BOOL	stop_transition = FALSE
BOOL	delay_start = FALSE
DWORD	lazy_time = 0

Macro Definition Documentation

DONTOPENZIP

#define DONTOPENZIP   0

Definition at line 51 of file lazylogger.cxx.

EXIT_REQUEST

#define EXIT_REQUEST   2

Definition at line 42 of file lazylogger.cxx.

FORCE_EXIT

#define FORCE_EXIT   1

Definition at line 41 of file lazylogger.cxx.

LAZY_SETTINGS_STRING

#define LAZY_SETTINGS_STRING   "\Period = INT : 10\n\Maintain free space (%) = INT : 0\n\Stay behind = INT : 0\n\Alarm Class = STRING : [32]\n\Running condition = STRING : [128] ALWAYS\n\Data dir = STRING : [256] \n\Data format = STRING : [8] MIDAS\n\Filename format = STRING : [128] run%05d.mid\n\Backup type = STRING : [8] Tape\n\Execute after rewind = STRING : [64]\n\Path = STRING : [128] \n\Capacity (Bytes) = FLOAT : 5e9\n\List label= STRING : [128] \n\Execute before writing file = STRING : [64]\n\Execute after writing file = STRING : [64]\n\Modulo.Position = STRING : [8]\n\Copy Delay = INT : 0\n\Tape Data Append = BOOL : y\n\"

Definition at line 122 of file lazylogger.cxx.

LAZY_STATISTICS_STRING

#define LAZY_STATISTICS_STRING   "\Backup file = STRING : [128] none \n\File size (Bytes) = DOUBLE : 0.0\n\KBytes copied = DOUBLE : 0.0\n\Total Bytes copied = DOUBLE : 0.0\n\Copy progress (%) = DOUBLE : 0\n\Copy Rate (Bytes per s) = DOUBLE : 0\n\Backup status (%) = DOUBLE : 0\n\Number of Files = INT : 0\n\Current Lazy run = INT : 0\n\"

Definition at line 142 of file lazylogger.cxx.

LOG_TYPE_SCRIPT

#define LOG_TYPE_SCRIPT   (-1)

Definition at line 50 of file lazylogger.cxx.

MAX_FILE_PATH

#define MAX_FILE_PATH   128

Definition at line 119 of file lazylogger.cxx.

MAX_LAZY_CHANNEL

#define MAX_LAZY_CHANNEL   100

Definition at line 48 of file lazylogger.cxx.

NEW_FILE

#define NEW_FILE   1

Definition at line 45 of file lazylogger.cxx.

NOTHING_TODO

#define NOTHING_TODO   0

Definition at line 40 of file lazylogger.cxx.

REMOVE_ENTRY

#define REMOVE_ENTRY   3

Definition at line 47 of file lazylogger.cxx.

REMOVE_FILE

#define REMOVE_FILE   2

Definition at line 46 of file lazylogger.cxx.

TRACE

#define TRACE

Definition at line 49 of file lazylogger.cxx.

TRY_LATER

#define TRY_LATER   3

Definition at line 43 of file lazylogger.cxx.

URL_SIZE

#define URL_SIZE   256

Definition at line 31 of file lazylogger.cxx.

WATCHDOG_TIMEOUT

#define WATCHDOG_TIMEOUT   60000 /* 60 sec for tape access */

Definition at line 217 of file lazylogger.cxx.

Typedef Documentation

DIRLOGLIST

typedef std::vector<DIRLOG> DIRLOGLIST

Definition at line 62 of file lazylogger.cxx.

Function Documentation

build_done_list()

INT build_done_list	(	HNDLE	hLch,
		const DIRLOGLIST *	pdirlist,
		DIRLOGLIST *	pdone
	)

Definition at line 719 of file lazylogger.cxx.

{
   HNDLE hKey;
   KEY key;
   int status = db_get_key(hDB, hLch, &key);
   assert(status == DB_SUCCESS);
 
   if (db_find_key(hDB, hLch, "List", &hKey) == DB_SUCCESS) {
      cm_msg(MERROR, "build_done_list",
             "lazylogger cannot continue: found old-style done list in ODB \'/Lazy/%s/List\'. Please convert to new done list format using \'lazylogger -C\'",
             key.name);
      cm_disconnect_experiment();
      exit(1);
   }
 
   load_done_list(key.name, pdirlist, pdone);
 
   return pdone->size();
}

Here is the call graph for this function:

Here is the caller graph for this function:

build_done_list_odb()

INT build_done_list_odb	(	HNDLE	hLch,
		INT **	pdo
	)

Definition at line 488 of file lazylogger.cxx.

{
   HNDLE hKey, hSubkey;
   KEY key;
   INT i, j, size, tot_nelement, nelement, temp;
 
   if (db_find_key(hDB, hLch, "List", &hKey) != DB_SUCCESS) {
      return 0;
   }
 
   tot_nelement = 0;
   for (i = 0;; i++) {
      db_enum_key(hDB, hKey, i, &hSubkey);
      if (!hSubkey)
         break;
      db_get_key(hDB, hSubkey, &key);
      nelement = key.num_values;
      *pdo = (INT *) realloc(*pdo, sizeof(INT) * (tot_nelement + nelement));
      size = nelement * sizeof(INT);
      db_get_data(hDB, hSubkey, (char *) (*pdo + tot_nelement), &size, TID_INT);
      tot_nelement += nelement;
   }
 
   if (0) {
      printf("read pdo: %d\n", tot_nelement);
      for (i = 0; i < tot_nelement; i++)
         printf("%d: %d\n", i, (*pdo)[i]);
   }
 
   /* expand compressed run numbers */
   for (i = 0; i < tot_nelement; i++)
      if ((*pdo)[i] < 0) {
         int first = (*pdo)[i - 1];
         int last = -(*pdo)[i];
         int nruns = last - first + 1;
         assert(nruns > 1);
 
         *pdo = (INT *) realloc(*pdo, sizeof(INT) * (tot_nelement + nruns - 2));
         assert(*pdo != NULL);
 
         memmove((*pdo) + i + nruns - 1, (*pdo) + i + 1, sizeof(INT) * (tot_nelement - i - 1));
 
         for (j = 1; j < nruns; j++)
            (*pdo)[i + j - 1] = first + j;
 
         tot_nelement += nruns - 2;
      }
 
   if (0) {
      printf("uncompressed pdo: %d\n", tot_nelement);
      for (i = 0; i < tot_nelement; i++)
         printf("%d: %d\n", i, (*pdo)[i]);
   }
 
   /* sort array of integers */
   for (j = 0; j < tot_nelement - 1; j++) {
      for (i = j + 1; i < tot_nelement; i++) {
         if (*(*pdo + j) > *(*pdo + i)) {
            memcpy(&temp, (*pdo + i), sizeof(INT));
            memcpy((*pdo + i), (*pdo + j), sizeof(INT));
            memcpy((*pdo + j), &temp, sizeof(INT));
         }
      }
   }
 
   if (0) {
      printf("sorted pdo: %d\n", tot_nelement);
      for (i = 0; i < tot_nelement; i++)
         printf(" %d\n", (*pdo)[i]);
   }
 
   return tot_nelement;
}

Here is the call graph for this function:

Here is the caller graph for this function:

build_log_list()

INT build_log_list	(	const char *	fmt,
		const char *	dir,
		DIRLOGLIST *	plog
	)

Definition at line 392 of file lazylogger.cxx.

{
   char str[MAX_FILE_PATH];
   char dir[MAX_FILE_PATH];
   char *dot;
   int lModulo = 0, lPosition = 0;
 
   mstrlcpy(dir, xdir, sizeof(dir));
 
   while (fmt) {
      /* substitue %xx by * */
      mstrlcpy(str, fmt, sizeof(str));
 
      fmt = strchr(fmt, ',');
      if (fmt)
         fmt++;
 
      char *s = strchr(str, ',');
      if (s)
         *s = 0;
 
      if (strchr(str, '%')) {
         *strchr(str, '%') = '*';
         if (strchr(str, '.'))
            strcpy((strchr(str, '*') + 1), strchr(str, '.'));
      }
 
      char *list = NULL;
 
      /* create dir listing with given criteria */
      int nfile = ss_file_find(dir, str, &list);
 
      /* check */
      /*
       for (j=0;j<nfile;j++)
       printf ("list[%i]:%s\n",j, list+j*MAX_STRING_LENGTH);
     */
 
      std::vector<std::string> flist;
      for (int j = 0; j < nfile; j++)
         flist.push_back(list + j * MAX_STRING_LENGTH);
 
      free(list);
 
      /* Check Modulo option */
      if (lazy.modulo[0]) {
         /* Modulo enabled, extract modulo and position */
         dot = strchr(lazy.modulo, '.');
         if (dot) {
            *dot = '\0';
            lModulo = atoi(lazy.modulo);
            lPosition = atoi(dot + 1);
            *dot = '.';
         }
      }
 
      /* fill structure */
      for (unsigned j = 0 ; j < flist.size(); j++) {
         INT lrun;
         /* extract run number */
         lrun = lazy_run_extract((char *) flist[j].c_str());
         /* apply the modulo if enabled */
         lrun = moduloCheck(lModulo, lPosition, lrun);
         /* if modulo enable skip */
         if (lrun == 0)
            continue;
 
         std::string s = dir;
         s += flist[j];
 
         DIRLOG d;
         d.filename = flist[j];
         d.runno = lrun;
         d.size = ss_file_size((char *) s.c_str());
 
         dlist->push_back(d);
      }
   }
 
   sort(dlist->begin(), dlist->end(), cmp_dirlog);
 
   return dlist->size();
}

Here is the call graph for this function:

Here is the caller graph for this function:

cmp_dirlog()

bool cmp_dirlog	(	const DIRLOG &	a,
		const DIRLOG &	b
	)

Definition at line 112 of file lazylogger.cxx.

                                                  {
   bool r = cmp_dirlog1(a, b);
   //printf("compare %s %s yields %d\n", a.filename.c_str(), b.filename.c_str(), r);
   return r;
}

Here is the call graph for this function:

Here is the caller graph for this function:

cmp_dirlog1()

bool cmp_dirlog1	(	const DIRLOG &	a,
		const DIRLOG &	b
	)

Definition at line 64 of file lazylogger.cxx.

                                                   {
   if (a.runno < b.runno)
      return true;
 
   if (a.runno > b.runno)
      return false;
 
   const char *sa = a.filename.c_str();
   const char *sb = b.filename.c_str();
 
   while (1) {
      if (*sa == 0) // sa is shorter
         return true;
 
      if (*sb == 0) // sb is shorter
         return false;
 
      //printf("cmp char %c %c\n", *sa, *sb);
 
      if (*sa < *sb)
         return true;
 
      if (*sa > *sb)
         return false;
 
      // at this point, *sa == *sb
 
      if (isdigit(*sa)) {
         int ia = strtoul(sa, (char **) &sa, 10);
         int ib = strtoul(sb, (char **) &sb, 10);
 
         //printf("cmp int %d %d\n", ia, ib);
 
         if (ia < ib)
            return true;
 
         if (ia > ib)
            return false;
 
         // at this point, ia == ib
         continue;
      }
 
      sa++;
      sb++;
   }
}

Here is the caller graph for this function:

condition_test()

BOOL condition_test

(

char *

string

)

Definition at line 1051 of file lazylogger.cxx.

{
   KEY key;
   double value;
   double lcond_value;
   INT size, index, status;
   char left[64], right[64];
   char *p = NULL, *pp, *ppl, *pc, *lp;
 
   index = 0;
   p = string;
   if (p) {
      while (isspace(*p))
         p++;
 
      pc = strpbrk(p, "<=>");
      if (pc) {
         strncpy(left, p, pc - p);
         lp = left + (pc - p - 1);
         while (isspace(*lp))
            lp--;
         *(lp + 1) = '\0';
         strncpy(right, pc + 1, (strlen(p) - strlen(left)));
         right[strlen(p) - strlen(left) - 1] = '\0';
      }
 
      if ((pp = strpbrk(left, "[(")) != NULL) {
         if ((ppl = strpbrk(left, "])")) != NULL) {
            *pp = '\0';
            *ppl = '\0';
            index = atoi(pp + 1);
         }
         *pp = '\0';
      }
 
      /* convert value */
      value = (double) (atoi(right));
 
      status = db_find_key(hDB, 0, left, &hKey);
      if (status != DB_SUCCESS) {
         cm_msg(MINFO, "condition_check", "Key %s not found", left);
         return FALSE;
      }
      status = db_get_key(hDB, hKey, &key);
      if ((status == DB_SUCCESS) && (key.type <= TID_DOUBLE)) {
         /* get value of the condition */
         size = sizeof(lcond_value);
         db_get_data_index(hDB, hKey, &lcond_value, &size, index, key.type);
         std::string s = db_sprintf(&lcond_value, key.item_size, 0, key.type);
         lcond_value = std::stof(s);
      }
 
      /*  printf("string:%s\n condition: %s %f %c %f \n"
       , string, left, lcond_value, *pc, value);
     */
      /*
       if (pv == NULL)
       return TRUE;
     */
      /* perform condition check */
      if (((*pc == '>') && ((double) lcond_value > value)) || ((*pc == '=') && ((double) lcond_value == value)) ||
          ((*pc == '<') && ((double) lcond_value < value)))
         return TRUE;
      else
         return FALSE;
   }
   /* catch wrong argument in the condition as TRUE */
   return TRUE;
}

Here is the call graph for this function:

Here is the caller graph for this function:

convert_done_list()

void convert_done_list

(

HNDLE

hLch

)

Definition at line 664 of file lazylogger.cxx.

{
   DIRLOGLIST dlist;
 
   build_log_list(lazy.backfmt, lazy.dir, &dlist);
 
   KEY key;
   int status = db_get_key(hDB, hLch, &key);
   assert(status == DB_SUCCESS);
 
   HNDLE hKey;
   status = db_find_key(hDB, hLch, "List", &hKey);
 
   if (status != DB_SUCCESS) {
      cm_msg(MERROR, "convert_done_list", "Cannot find \'/Lazy/%s/List\' db_find_key() status %d", key.name, status);
      cm_disconnect_experiment();
      exit(1);
   }
 
   INT *pdo = NULL;
   int n = build_done_list_odb(hLch, &pdo);
 
   DIRLOGLIST done;
 
   for (int i = 0; i < n; i++)
      for (unsigned j = 0; j < dlist.size(); j++)
         if (dlist[j].runno == pdo[i])
            done.push_back(dlist[j]);
 
   free(pdo);
 
   save_list(key.name, "donelist", &done);
 
   status = db_rename_key(hDB, hKey, "List.converted");
   assert(status == DB_SUCCESS);
 
   cm_msg(MINFO, "convert_done_list",
          "Done list converted from old ODB \'/Lazy/%s/List\' format to new file-based format. ODB \'List\' renamed to \'List.converted\'",
          key.name);
 
   cm_disconnect_experiment();
   exit(1);
}

Here is the call graph for this function:

Here is the caller graph for this function:

find_next_file()

int find_next_file	(	const DIRLOGLIST *	plog,
		const DIRLOGLIST *	pdone
	)

Definition at line 771 of file lazylogger.cxx.

{
   for (unsigned j = 0; j < plog->size(); j++) {
      bool found = false;
      for (unsigned i = 0; i < pdone->size(); i++) {
         if ((*plog)[j].filename == (*pdone)[i].filename)
            found = true;
      }
 
      if (!found)
         if ((*plog)[j].size > 0)
            return j;
   }
 
   return -1;
}

Here is the caller graph for this function:

lazy_condition_check()

BOOL lazy_condition_check

(

void

)

Definition at line 1136 of file lazylogger.cxx.

{
   /* Get condition */
   if (equal_ustring(lazy.condition, "ALWAYS"))
      return TRUE;
   else if (equal_ustring(lazy.condition, "NEVER"))
      return FALSE;
   else if (equal_ustring(lazy.condition, "WHILE_ACQ_NOT_RUNNING")) {
      if (run_state == STATE_RUNNING)
         return FALSE;
      else
         return TRUE;
   } else
      return (condition_test(lazy.condition));
}

Here is the call graph for this function:

Here is the caller graph for this function:

lazy_copy()

INT lazy_copy	(	char *	dev,
		char *	file,
		int	max_event_size
	)

Definition at line 1163 of file lazylogger.cxx.

{
   void *plazy = NULL;
   DWORD szlazy;
   INT status, no_cpy_last_time = 0;
   INT cpy_loop_time;
   DWORD watchdog_timeout;
   static INT last_error = 0;
   //char *pext;
   BOOL watchdog_flag, exit_request = FALSE;
   char filename[256];
 
   if (debug)
      printf("lazy_copy %s to %s\n", infile, outfile);
 
   /* init copy variables */
   lazyst.cur_size = 0.0f;
 
   /* open any logging file (output) */
   mstrlcpy(filename, outfile, sizeof(filename)); // ftp modifies filename
   if ((status = md_file_wopen(dev_type, data_fmt, filename, &hDev)) != 1) {
      if ((ss_time() - last_error) > 60) {
         last_error = ss_time();
         cm_msg(MTALK, "Lazy_copy", "cannot open %s, error %d", outfile, status);
      }
      return (FORCE_EXIT);
   }
 
   /* New lazy copy if TAPE & append required force a mv to EOD */
   if ((dev_type == LOG_TYPE_TAPE) && lazy.tapeAppend) {
      /* Position Tape to end of Data */
      cm_msg(MINFO, "Lazy", "Positioning Tape to EOD");
 
      cm_get_watchdog_params(&watchdog_flag, &watchdog_timeout);
      cm_set_watchdog_params(watchdog_flag, 300000); /* 5 min for tape rewind */
      status = ss_tape_spool(hDev);
      cm_set_watchdog_params(watchdog_flag, watchdog_timeout);
      if (status != SS_SUCCESS) {
         cm_msg(MINFO, "Lazy", "Error while Positioning Tape to EOD (%d)", status);
         ss_tape_close(hDev);
         return (FORCE_EXIT);
      }
   }
 
   /* reset error message */
   last_error = 0;
 
   /* open input data file */
   if (md_file_ropen(infile, data_fmt, DONTOPENZIP, max_event_size) != MD_SUCCESS)
      return (FORCE_EXIT);
 
   /* run shell command if available */
   if (equal_ustring(lazy.type, "Tape")) {
      /* get the block number. If -1 it probably means that the tape
       is not ready. Wait for a while  */
      blockn = -1;
      while (blockn < 0) {
         blockn = ss_tape_get_blockn(hDev);
         if (blockn >= 0)
            break;
         cm_msg(MINFO, "Lazy", "Tape is not ready");
         cm_yield(3000);
      }
      if (lazy.commandBefore[0]) {
         char cmd[256];
         sprintf(cmd, "%s %s %s %d %s %i", lazy.commandBefore, infile, outfile, blockn, lazy.backlabel, lazyst.nfiles);
         cm_msg(MINFO, "Lazy", "Exec pre file write script:%s", cmd);
         ss_system(cmd);
      }
   }
 
   /* force a statistics update on the first loop */
   cpy_loop_time = -2000;
   if (dev_type == LOG_TYPE_TAPE) {
      char str[256];
      sprintf(str, "Starting lazy job on %s at block %d", lazyst.backfile, blockn);
      if (msg_flag)
         cm_msg(MTALK, "Lazy", "%s", str);
      cm_msg1(MINFO, "lazy_copy", "lazy", "%s", str);
   }
 
   /* infinite loop while copying */
   while (1) {
      if (copy_continue) {
         if (md_physrec_get(data_fmt, &plazy, &szlazy) == MD_SUCCESS) {
            status = md_log_write(hDev, data_fmt, dev_type, plazy, szlazy);
            if (status != SS_SUCCESS) {
               /* close source file */
               md_file_rclose(dev_type);
               /* close output data file */
               md_file_wclose(hDev, dev_type, data_fmt, outfile);
               /* szlazy is the requested block size. Why is it copied to cm_msg?
             cm_msg(MERROR,"lazy_copy","Write error %i",szlazy); */
               cm_msg(MERROR, "lazy_copy", "Write error ");
               if (status == SS_NO_SPACE)
                  return status;
               return (FORCE_EXIT);
            }
            lazyst.cur_size += (double) szlazy;
            lazyst.cur_dev_size += (double) szlazy;
            if ((ss_millitime() - cpy_loop_time) > 2000) {
               /* update statistics */
               lazy_statistics_update(cpy_loop_time);
 
               /* check conditions */
               copy_continue = lazy_condition_check();
 
               /* update check loop */
               cpy_loop_time = ss_millitime();
 
               /* yield quickly */
               status = cm_yield(1);
               if (status == RPC_SHUTDOWN || status == SS_ABORT || exit_request) {
                  cm_msg(MINFO, "Lazy", "Abort postponed until end of copy of %s %1.0lf[%%]",
                         infile, (double) lazyst.progress);
                  exit_request = TRUE;
               }
            }
         } /* get physrec */
         else
            break;
      } /* copy_continue */
      else { /* !copy_continue */
         status = cm_yield(1000);
         if (status == RPC_SHUTDOWN || status == SS_ABORT)
            return (FORCE_EXIT);
         if ((ss_millitime() - no_cpy_last_time) > 5000) {
            copy_continue = lazy_condition_check();
            no_cpy_last_time = ss_millitime();
         }
      } /* !copy_continue */
   } /* while forever */
 
   /* update for last the statistics */
   lazy_statistics_update(0);
 
   /* close input log device */
   md_file_rclose(dev_type);
 
   /* close output data file */
   if (equal_ustring(lazy.type, "Tape")) {
      blockn = ss_tape_get_blockn(hDev);
   }
   status = md_file_wclose(hDev, dev_type, data_fmt, outfile);
   if (status != SS_SUCCESS) {
      if (status == SS_NO_SPACE)
         return status;
      return (FORCE_EXIT);
   }
 
   /* request exit */
   if (exit_request)
      return (EXIT_REQUEST);
   return 0;
}

Here is the call graph for this function:

Here is the caller graph for this function:

lazy_disk_copy()

INT lazy_disk_copy	(	const char *	outfile,
		const char *	infile
	)

Definition at line 1615 of file lazylogger.cxx.

{
   int status;
   DWORD watchdog_timeout;
   BOOL watchdog_flag;
 
   if (debug)
      printf("lazy_disk_copy %s to %s\n", infile, outfile);
 
   double MiB = 1024 * 1024;
   double disk_size = ss_disk_size((char *) outfile);
   double disk_free = ss_disk_free((char *) outfile);
 
   if (debug)
      printf("output disk size %.1f MiB, free %.1f MiB\n", disk_size / MiB, disk_free / MiB);
 
   /* init copy variables */
   lazyst.cur_size = 0.0f;
 
   /* run shell command if available */
   if (lazy.commandBefore[0]) {
      char cmd[256];
      sprintf(cmd, "%s %s %i", lazy.commandBefore, infile, lazyst.nfiles);
      cm_msg(MINFO, "Lazy", "Exec pre file write script:%s", cmd);
      ss_system(cmd);
   }
 
   FILE *fpin = fopen(infile, "rb");
   if (!fpin) {
      cm_msg(MERROR, "Lazy_disk_copy", "Cannot read from \'%s\', errno %d (%s)", infile, errno, strerror(errno));
      return FORCE_EXIT;
   }
 
   FILE *fptest = fopen(outfile, "rb");
   if (fptest) {
      fclose(fptest);
      fptest = NULL;
      cm_msg(MINFO, "Lazy_disk_copy", "Output file \'%s\' already exists, removing", outfile);
      unlink(outfile);
      //return FORCE_EXIT;
   }
 
   FILE *fpout = fopen(outfile, "wb");
   if (!fpout) {
      cm_msg(MERROR, "Lazy_disk_copy", "Cannot write to \'%s\', errno %d (%s)", outfile, errno, strerror(errno));
      fclose(fpin);
      return TRY_LATER;
   }
 
   setbuf(fpin, NULL);
   setbuf(fpout, NULL);
 
   {
      char str[MAX_FILE_PATH];
      sprintf(str, "Starting lazy_disk_copy \'%s\' to \'%s\'", infile, outfile);
      if (msg_flag)
         cm_msg(MTALK, "Lazy", "%s", str);
      cm_msg1(MINFO, "lazy_disk_copy", "lazy", "%s", str);
   }
 
   double cpy_start_time = ss_millitime();
 
   cm_get_watchdog_params(&watchdog_flag, &watchdog_timeout);
   cm_set_watchdog_params(watchdog_flag, 10 * 60 * 1000); /* increase timeout in case of delays writing output file */
 
   int copy_status = lazy_disk_copy_loop(outfile, infile, fpout, fpin);
 
   cm_set_watchdog_params(watchdog_flag, watchdog_timeout);
 
   /* update for last the statistics */
   lazy_statistics_update(0);
 
   /* close input log device */
   fclose(fpin);
   fpin = NULL;
 
   status = fclose(fpout);
   if (status != 0) {
      cm_msg(MERROR, "Lazy_disk_copy", "Cannot close \'%s\', errno %d (%s)", outfile, errno, strerror(errno));
      //if (status == SS_NO_SPACE)
      //   return status;
      return TRY_LATER;
   }
 
   if (copy_status) {
      return copy_status;
   }
 
   chmod(outfile, 0444);
 
   double t = (ss_millitime() - cpy_start_time) / 1000.0;
   //double MiB = 1024*1024;
   cm_msg(MINFO, "lazy_disk_copy", "Copy finished in %.1f sec, %.1f MiBytes at %.1f MiBytes/sec", t,
          lazyst.cur_size / MiB, lazyst.cur_size / t / MiB);
 
   return 0;
}

Here is the call graph for this function:

Here is the caller graph for this function:

lazy_disk_copy_loop()

int lazy_disk_copy_loop	(	const char *	outfile,
		const char *	infile,
		FILE *	fpout,
		FILE *	fpin
	)

Definition at line 1333 of file lazylogger.cxx.

                                                                                          {
   int status;
   int no_cpy_last_time = 0;
 
   /* force a statistics update on the first loop */
   int cpy_loop_time = -2000;
 
   /* infinite loop while copying */
   while (1) {
      if (copy_continue) {
         const int kBufSize = 1 * 1024 * 1024;
         char buf[kBufSize];
         int rd = fread(buf, 1, kBufSize, fpin);
         if (rd > 0) {
            int wr = fwrite(buf, 1, rd, fpout);
            if (wr != rd) {
               cm_msg(MERROR, "Lazy_disk_copy", "Cannot write to \'%s\', errno %d (%s)", outfile, errno,
                      strerror(errno));
               //if (status == SS_NO_SPACE)
               //   return status;
               return TRY_LATER;
            }
 
            lazyst.cur_size += (double) wr;
            lazyst.cur_dev_size += (double) wr;
            if ((ss_millitime() - cpy_loop_time) > 2000) {
               /* update statistics */
               lazy_statistics_update(cpy_loop_time);
 
               /* check conditions */
               copy_continue = lazy_condition_check();
 
               /* update check loop */
               cpy_loop_time = ss_millitime();
 
               /* yield quickly */
               status = cm_yield(1);
               if (status == RPC_SHUTDOWN || status == SS_ABORT) {
                  cm_msg(MINFO, "Lazy", "Copy aborted by cm_yield() status %d", status);
                  return FORCE_EXIT;
               }
            }
         } else if (rd == 0) {
            // end of input file
            break;
         } else {
            // read error
            cm_msg(MERROR, "Lazy_disk_copy", "Cannot read from \'%s\', errno %d (%s)", infile, errno, strerror(errno));
            return FORCE_EXIT;
         }
      } /* copy_continue */
      else { /* !copy_continue */
         status = cm_yield(1000);
         if (status == RPC_SHUTDOWN || status == SS_ABORT) {
            return FORCE_EXIT;
         }
         if ((ss_millitime() - no_cpy_last_time) > 5000) {
            copy_continue = lazy_condition_check();
            no_cpy_last_time = ss_millitime();
         }
      } /* !copy_continue */
   } /* while forever */
 
   return 0;
}

Here is the call graph for this function:

Here is the caller graph for this function:

lazy_file_exists()

BOOL lazy_file_exists	(	char *	dir,
		char *	file
	)

Definition at line 1850 of file lazylogger.cxx.

{
   char *list;
   char fullfile[MAX_FILE_PATH] = {'\0'};
 
   if (ss_file_find(dir, file, &list) == 1) {
      strcat(fullfile, dir);
      strcat(fullfile, DIR_SEPARATOR_STR);
      strcat(fullfile, file);
      if ((lazyst.file_size = (double) (ss_file_size(fullfile))) > 0) {
         free(list);
         return TRUE;
      }
   }
   free(list);
   return FALSE;
}

Here is the call graph for this function:

Here is the caller graph for this function:

lazy_file_remove()

INT lazy_file_remove

(

const char *

pufile

)

Definition at line 294 of file lazylogger.cxx.

                                         {
   INT fHandle, status;
 
   if (nodelete) {
      printf("lazy_file_remove: running in nodelete mode (-n switch), will not remove \'%s\'\n", pufile);
      return !SS_SUCCESS;
   }
 
   /* open device */
   fHandle = open(pufile, O_RDONLY, 0644);
   if (fHandle == -1)
      return SS_INVALID_NAME;
 
   close(fHandle);
 
   status = ss_file_remove((char *) pufile);
   if (status != 0)
      return SS_FILE_ERROR;
   return SS_SUCCESS;
}

Here is the call graph for this function:

Here is the caller graph for this function:

lazy_load_params()

INT lazy_load_params	(	HNDLE	hDB,
		HNDLE	hKey
	)

lazy_log_update()

INT lazy_log_update	(	INT	action,
		INT	run,
		const char *	label,
		const char *	file,
		DWORD	perf_time
	)

Definition at line 316 of file lazylogger.cxx.

                                                                                               {
   char str[1024];
 
   strcpy(str, "no action");
 
   /* log Lazy logger to midas.log only */
   if (action == NEW_FILE) {
      /* keep track of number of file on that channel */
      lazyst.nfiles++;
 
      if (equal_ustring(lazy.type, "FTP"))
         sprintf(str, "%s[%i]: (cp:%.1fs) %s %1.3lfMB file COPIED",
                 label, lazyst.nfiles, (double) perf_time / 1000., lazyst.backfile, lazyst.file_size / 1024.0 / 1024.0);
      else if (equal_ustring(lazy.type, "SFTP"))
         sprintf(str, "%s[%i]: (cp:%.1fs) %s %1.3lfMB file COPIED",
                 label, lazyst.nfiles, (double) perf_time / 1000., lazyst.backfile, lazyst.file_size / 1024.0 / 1024.0);
      else if (equal_ustring(lazy.type, "Script")) {
         sprintf(str, "%s[%i]: (cp:%.1fs) %s %1.3lfMB  file NEW",
                 label, lazyst.nfiles, (double) perf_time / 1000., lazyst.backfile, lazyst.file_size / 1024.0 / 1024.0);
      } else if (equal_ustring(lazy.type, "Disk")) {
         if (lazy.path[0] != 0)
            if (lazy.path[strlen(lazy.path) - 1] != DIR_SEPARATOR)
               strcat(lazy.path, DIR_SEPARATOR_STR);
         sprintf(str, "%s[%i]: (cp:%.1fs) %s%s %1.3lfMB  file NEW",
                 label, lazyst.nfiles, (double) perf_time / 1000.,
                 lazy.path, lazyst.backfile, lazyst.file_size / 1024.0 / 1024.0);
      } else if (equal_ustring(lazy.type, "Tape")) {
         /* June 2002, use variable blockn from the real tape position */
         sprintf(str, "%s[%i]: (cp:%.1fs) %s/%s %1.3lfMB  file NEW (position at block %d)",
                 label, lazyst.nfiles, (double) perf_time / 1000.,
                 lazy.path, lazyst.backfile, lazyst.file_size / 1024.0 / 1024.0, blockn);
         if (lazy.commandAfter[0]) {
            char cmd[1024];
            sprintf(cmd, "%s %s %i %s/%s %1.3lf %d", lazy.commandAfter,
                    lazy.backlabel, lazyst.nfiles, lazy.path, lazyst.backfile,
                    lazyst.file_size / 1024.0 / 1024.0, blockn);
            cm_msg(MINFO, "Lazy", "Exec post file write script:%s", cmd);
            ss_system(cmd);
         }
      }
   } else if (action == REMOVE_FILE)
      sprintf(str, "%i (rm:%dms) %s file REMOVED", run, perf_time, file);
 
   else if (action == REMOVE_ENTRY)
      sprintf(str, "%s run#%i entry REMOVED", label, run);
 
   /* Now add this info to a special log file */
   cm_msg1(MINFO, "lazy", "lazy_log_update", "%s", str);
 
   return 0;
}

Here is the call graph for this function:

Here is the caller graph for this function:

lazy_main()

INT lazy_main	(	INT	channel,
		LAZY_INFO *	pLall,
		int	max_event_size
	)

Definition at line 1975 of file lazylogger.cxx.

{
   DWORD cp_time;
   INT size, status;
   char str[MAX_FILE_PATH], inffile[MAX_FILE_PATH], outffile[MAX_FILE_PATH];
   BOOL watchdog_flag, exit_request = FALSE;
   DWORD watchdog_timeout;
   LAZY_INFO *pLch;
   static BOOL eot_reached = FALSE;
   BOOL haveTape;
 
   /* current channel */
   pLch = &pLall[channel];
 
   if (convert_flag) {
      convert_done_list(pLch->hKey);
      assert(!"NOT REACHED");
   }
 
   /* extract Data format from the struct */
   if (equal_ustring(lazy.format, "MIDAS"))
      data_fmt = FORMAT_MIDAS;
   else {
      cm_msg(MERROR, "Lazy", "Unknown data format %s (MIDAS)", lazy.format);
      return DB_NO_ACCESS;
   }
 
   /* extract Device type from the struct */
   if (equal_ustring(lazy.type, "DISK"))
      dev_type = LOG_TYPE_DISK;
   else if (equal_ustring(lazy.type, "TAPE"))
      dev_type = LOG_TYPE_TAPE;
   else if (equal_ustring(lazy.type, "FTP"))
      dev_type = LOG_TYPE_FTP;
   else if (equal_ustring(lazy.type, "SFTP"))
      dev_type = LOG_TYPE_SFTP;
   else if (equal_ustring(lazy.type, "SCRIPT"))
      dev_type = LOG_TYPE_SCRIPT;
   else {
      cm_msg(MERROR, "Lazy", "Unknown device type %s (Disk, Tape, SFTP, FTP or SCRIPT)", lazy.type);
      return DB_NO_ACCESS;
   }
 
   if ((dev_type == LOG_TYPE_SCRIPT) || (dev_type == LOG_TYPE_DISK))
      if (lazy.backlabel[0] == 0 || strcmp(lazy.backlabel, lazyinfo[channel].name) != 0) {
         mstrlcpy(lazy.backlabel, lazyinfo[channel].name, sizeof(lazy.backlabel));
         size = sizeof(lazy.backlabel);
         db_set_value(hDB, pLch->hKey, "Settings/List label", lazy.backlabel, size, 1, TID_STRING);
      }
   /* make sure that we don't operate on the current DAQ file if so set to oldest */
   //if (lazy.staybehind == 0) {
   //   cm_msg(MERROR, "Lazy", "Stay behind cannot be 0");
   //   return NOTHING_TODO;
   //}
 
   /* Check if Tape is OK */
   /* ... */
 
   haveTape = (lazy.backlabel[0] != '\0');
 
   /* check if space on device (not empty tape label) */
   if (lazy.backlabel[0] == '\0') {
      full_bck_flag = TRUE;
   } else {
      if (full_bck_flag) {
         full_bck_flag = FALSE;
         size = sizeof(lazyst);
         memset(&lazyst, 0, size);
         if (db_find_key(hDB, pLch->hKey, "Statistics", &hKeyst) == DB_SUCCESS) {
            status = db_set_record(hDB, hKeyst, &lazyst, size, 0);
            /* New session of lazy, apply append in case of Tape */
            /* DISK for debugging */
            if ((dev_type == LOG_TYPE_DISK) && lazy.tapeAppend) {
               /* Position Tape to end of Data */
               cm_msg(MINFO, "Lazy", "Positioning Tape to EOD");
            }
         } else
            cm_msg(MERROR, "lazy_main", "did not find /Lazy/Lazy_%s/Statistics for zapping", pLch->name);
         // INT al_reset_alarm(char *alarm_name)
         if (dev_type == LOG_TYPE_TAPE)
            al_reset_alarm("Tape");
      }
   }
   /* check if data dir is none empty */
   if (lazy.dir[0] == '\0') {
      cm_msg(MINFO, "Lazy", "Please setup Data dir for input source path!");
      return NOTHING_TODO;
   }
 
   if (lazy.dir[0] != 0)
      if (lazy.dir[strlen(lazy.dir) - 1] != DIR_SEPARATOR)
         strcat(lazy.dir, DIR_SEPARATOR_STR);
 
   /* check if device path is set */
   if (lazy.path[0] == '\0') {
      cm_msg(MINFO, "Lazy", "Please setup backup device path too!");
      return NOTHING_TODO;
   }
 
   DIRLOGLIST dirlist;
   build_log_list(lazy.backfmt, lazy.dir, &dirlist);
 
   save_list(pLch->name, "dirlist", &dirlist);
 
   DIRLOGLIST donelist;
   build_done_list(pLch->hKey, &dirlist, &donelist);
 
   lazy_maintain_free_space(pLch, pLall);
 
   /* compare list : run NOT in donelist AND run in dirlog */
   int tobe_backup = find_next_file(&dirlist, &donelist);
 
   //const DIRLOG* tobe_backup = cmp_log2donelist(&dirlist, &donelist);
 
   //if (debug)
   //print_dirlog(&dirlist);
 
   //print_dirlog(&donelist);
   //printf("tobe_backup: %p\n", tobe_backup);
 
   if (tobe_backup < 0)
      return NOTHING_TODO;
 
   if (debug)
      printf("selected for backup: %s, run %d\n", dirlist[tobe_backup].filename.c_str(), dirlist[tobe_backup].runno);
 
   /* Get current run number */
   int cur_acq_run;
   size = sizeof(cur_acq_run);
   status = db_get_value(hDB, 0, "Runinfo/Run number", &cur_acq_run, &size, TID_INT, FALSE);
   assert(status == SUCCESS);
 
   lazyst.cur_run = dirlist[tobe_backup].runno;
 
   int behind_files = dirlist.size() - tobe_backup;
   int behind_runs = cur_acq_run - dirlist[tobe_backup].runno;
 
   bool nothing_todo_files = (behind_files <= lazy.staybehind);
   bool nothing_todo_runs = (behind_runs < abs(lazy.staybehind));
 
   bool nothing_todo = false;
 
   /* "stay behind by so many runs" mode */
   if (lazy.staybehind < 0)
      nothing_todo = nothing_todo_runs;
 
   /* "stay behind by so many files" mode */
   if (lazy.staybehind > 0)
      nothing_todo = nothing_todo_files;
 
   /* "no stay behind" mode */
   if (lazy.staybehind == 0) {
      if (dirlist[tobe_backup].runno != cur_acq_run)
         nothing_todo = false;
      else if (behind_files > 1)
         nothing_todo = false;
      else {
         nothing_todo = false;
 
         /* In case it is the current run make sure
          1) no transition is in progress
          2) the run start has not been aborted
          3) the run has been ended
         */
 
         int flag;
         size = sizeof(flag);
         status = db_get_value(hDB, 0, "Runinfo/Transition in progress", &flag, &size, TID_INT, FALSE);
         assert(status == SUCCESS);
         if (flag) {
            if (debug)
               printf("transition in progress, cannot backup last file\n");
            nothing_todo = true;
         }
 
         size = sizeof(flag);
         status = db_get_value(hDB, 0, "Runinfo/Start abort", &flag, &size, TID_INT, FALSE);
         assert(status == SUCCESS);
         if (flag) {
            if (debug)
               printf("run start aborted, cannot backup last file\n");
            nothing_todo = true;
         }
 
         int cur_state_run;
         status = db_get_value(hDB, 0, "Runinfo/State", &cur_state_run, &size, TID_INT, FALSE);
         assert(status == SUCCESS);
         if ((cur_state_run != STATE_STOPPED)) {
            if (debug)
               printf("run still running, cannot backup last file\n");
            nothing_todo = true;
         }
      }
   }
 
   if (debug)
      printf("behind: %d files, %d runs, staybehind: %d, nothing_todo: files: %d, runs: %d, lazylogger: %d\n",
             behind_files, behind_runs, lazy.staybehind, nothing_todo_files, nothing_todo_runs, nothing_todo);
 
   if (nothing_todo) {
      return NOTHING_TODO;
   }
 
   if ((dev_type != LOG_TYPE_SCRIPT) && (dev_type != LOG_TYPE_DISK))
      if (!haveTape) {
         if (debug)
            printf("haveTape: %d, nothing to do.\n", haveTape);
         return NOTHING_TODO;
      }
 
   mstrlcpy(lazyst.backfile, dirlist[tobe_backup].filename.c_str(), sizeof(lazyst.backfile));
 
   std::string xfile = lazy.dir;
   xfile += dirlist[tobe_backup].filename;
   mstrlcpy(inffile, xfile.c_str(), sizeof(inffile));
 
   /* Check again if the backup file is present in the logger dir */
   if (lazy_file_exists(lazy.dir, lazyst.backfile)) {
      /* compose the destination file name */
      if ((dev_type == LOG_TYPE_DISK) || (dev_type == LOG_TYPE_SFTP)) {
         if (lazy.path[0] != 0)
            if (lazy.path[strlen(lazy.path) - 1] != DIR_SEPARATOR)
               strcat(lazy.path, DIR_SEPARATOR_STR);
         strcpy(outffile, lazy.path);
         strcat(outffile, lazyst.backfile);
      } else if (dev_type == LOG_TYPE_TAPE)
         strcpy(outffile, lazy.path);
      else if (dev_type == LOG_TYPE_FTP) {
         /* Format for FTP
          lazy.path=host,port,user,password,directory,filename[,umask]
          expect filename in format such as "bck%08d.mid" */
 
         /*
          if (lazy.path[0] != 0)
          if (lazy.path[strlen(lazy.path)-1] != DIR_SEPARATOR)
          strcat(lazy.path, DIR_SEPARATOR_STR);
        */
 
         strcpy(str, lazy.path);
         /* substitute "%d" for current run number */
         if (strchr(str, '%'))
            sprintf(outffile, str, lazyst.cur_run);
         else
            strcpy(outffile, str);
 
         /* substitute "#d" for current run number millenium */
         mstrlcpy(str, outffile, sizeof(str));
         if (strchr(str, '#')) {
            *strchr(str, '#') = '%';
            sprintf(outffile, str, lazyst.cur_run / 1000);
         }
      }
 
      /* check if space on backup device ONLY in the TAPE case */
      if (((dev_type == LOG_TYPE_TAPE) && (lazy.capacity < (lazyst.cur_dev_size + lazyst.file_size))) || eot_reached) {
         char pre_label[32];
         /* save the last label for shell script */
         strcpy(pre_label, lazy.backlabel);
 
         /* Reset EOT reached */
         eot_reached = FALSE;
 
         /* not enough space => reset list label */
         lazy.backlabel[0] = '\0';
         size = sizeof(lazy.backlabel);
         db_set_value(hDB, pLch->hKey, "Settings/List label", lazy.backlabel, size, 1, TID_STRING);
         full_bck_flag = TRUE;
         cm_msg(MINFO, "Lazy", "Not enough space for next copy on backup device!");
 
         /* rewind device if TAPE type */
         if (dev_type == LOG_TYPE_TAPE) {
            INT status, channel;
            char str[256];
            sprintf(str, "Tape %s is full with %d files", pre_label, lazyst.nfiles);
            cm_msg(MINFO, "Lazy", "%s", str);
 
            /* Setup alarm */
            lazy.alarm[0] = 0;
            size = sizeof(lazy.alarm);
            db_get_value(hDB, pLch->hKey, "Settings/Alarm Class", lazy.alarm, &size, TID_STRING, TRUE);
 
            /* trigger alarm if defined */
            if (lazy.alarm[0])
               al_trigger_alarm("Tape",
                                "Tape full, Please remove current tape and load new one!",
                                lazy.alarm, "Tape full", AT_INTERNAL);
 
            /* run shell command if available */
            if (lazy.command[0]) {
               std::string cmd;
               cmd += lazy.command;
               cmd += " ";
               cmd += lazy.path;
               cmd += " ";
               cmd += pLch->name;
               cmd += " ";
               cmd += pre_label;
               cm_msg(MINFO, "Lazy", "Exec post-rewind script:%s", cmd.c_str());
               ss_system(cmd.c_str());
            }
 
            cm_msg(MINFO, "Lazy", "backup device rewinding...");
            cm_get_watchdog_params(&watchdog_flag, &watchdog_timeout);
            cm_set_watchdog_params(watchdog_flag, 300000); /* 5 min for tape rewind */
            status = ss_tape_open(outffile, O_RDONLY, &channel);
            if (channel < 0) {
               cm_msg(MERROR, "Lazy", "Cannot rewind tape %s - %d - %d", outffile, channel, status);
               return NOTHING_TODO;
            }
            //else
            //    cm_msg(MINFO,"Lazy", "After call ss_tape_open used to rewind tape %s - %d - %d", outffile, channel, status);
            cm_msg(MINFO, "Lazy", "Calling ss_tape_unmount");
            ss_tape_unmount(channel);
            ss_tape_close(channel);
            cm_set_watchdog_params(watchdog_flag, watchdog_timeout);
            return NOTHING_TODO;
         } // 1
      } // LOG_TYPE_TAPE
 
      // Postpone copy by "copy_delay" if the copy check happens right after the
      // stop transition. This permit EOR external scripts to complete there operations
      // prior to the lazycopy.
      // Delay the copy in case:
      // 0) all previous condition for copy is satisfied
      // 1) Stopped transition has been detected,
 
      if (stop_transition) {
         printf("in loop stop detected\n");
         stop_transition = FALSE; // reset transition (trfunction())
         delay_start = TRUE; // take notice of transition
         lazy_time = ss_time(); // mark time for delay
      }
      // check if its time after a stop transition
      if (delay_start && (ss_time() - lazy_time) < (DWORD) lazy.copy_delay) {
         printf("During delay %d... (%d)\n", ss_time() - lazy_time, lazy.copy_delay);
         return NOTHING_TODO;
      } else {
         delay_start = FALSE;
      }
 
      /* Finally do the copy */
      cp_time = ss_millitime();
      status = 0;
      if (dev_type == LOG_TYPE_SCRIPT) {
#ifdef OS_LINUX
         //sprintf(lazy.backlabel, "%06d", 100 * (lazyst.cur_run / 100));
         status = lazy_script_copy(inffile);
#else
         assert(!"lazy_script_copy not supported under Windows");
#endif
      } else if (dev_type == LOG_TYPE_SFTP) {
#ifdef HAVE_CURL
         // copy CURL SFTP
         status = lazy_sftp_copy(outffile, inffile);
#else
         assert(!"SFTP copying requires CURL to be installed! Install CURL, re-run cmake, and re-compile!");
#endif
      } else if (dev_type == LOG_TYPE_DISK) {
         // copy block mode
         status = lazy_disk_copy(outffile, inffile);
      } else {
         // copy event mode (old method)
         status = lazy_copy(outffile, inffile, max_event_size);
      }
 
      if ((status != 0) && (status != EXIT_REQUEST)) {
         if (status == SS_NO_SPACE) {
            /* Consider this case as EOT reached */
            eot_reached = TRUE;
            return status;
         } else if (status == FORCE_EXIT)
            return status;
         cm_msg(MERROR, "Lazy", "copy failed -%s-%s-%i", lazy.path, lazyst.backfile, status);
         if (status == TRY_LATER)
            return status;
         return FORCE_EXIT;
      }
      cp_time = ss_millitime() - cp_time;
 
      // copy done, update listings, logs, ODB
      donelist.push_back(dirlist[tobe_backup]);
      save_done_list(pLch->hKey, &donelist);
      lazy_log_update(NEW_FILE, lazyst.cur_run, lazy.backlabel, lazyst.backfile, cp_time);
      db_send_changed_records();
   } /* file exists */
   else {
      // If file not present it may be due to a run abort.
      // As the file is based on the "tobe_backup" run number
      // which is evaluated every lazy check, if a run is missing
      // it will be skiped properly.
      // No message is needed in this case.
      //    cm_msg(MERROR, "Lazy", "lazy_file_exists file %s doesn't exists", lazyst.backfile);
      return NOTHING_TODO;
   }
 
   if (status == EXIT_REQUEST)
      exit_request = TRUE;
 
   //-PAA code moved at the end of "file exists condition" (above)
   // cp_time = ss_millitime() - cp_time;
   // donelist.push_back(dirlist[tobe_backup]);
   // save_done_list(pLch->hKey, &donelist);
   // lazy_log_update(NEW_FILE, lazyst.cur_run, lazy.backlabel, lazyst.backfile, cp_time);
 
   if (msg_flag)
      cm_msg(MTALK, "Lazy", "         lazy job %s done!", lazyst.backfile);
 
   /* generate/update a <channel>_recover.odb file when everything is Ok
      after each file copy */
   {
      std::string str;
      /* leave "list label" as it is, as long as the _recover.odb is loaded before
        the lazylogger is started with NO -z things should be fine */
      /* save the recover with "List Label" empty */
      if (lazy.dir[strlen(lazy.dir) - 1] != DIR_SEPARATOR) {
         str += lazy.dir;
         str += DIR_SEPARATOR;
         str += pLch->name;
         str += "_recover.odb";
      } else {
         str += lazy.dir;
         str += pLch->name;
         str += "_recover.odb";
      }
 
      db_save(hDB, pLch->hKey, str.c_str(), TRUE);
   }
 
   if (exit_request)
      return (FORCE_EXIT);
   return NOTHING_TODO;
}

Here is the call graph for this function:

Here is the caller graph for this function:

lazy_maintain_check()

void lazy_maintain_check	(	HNDLE	hKey,
		LAZY_INFO *	pLall
	)

Definition at line 940 of file lazylogger.cxx.

{
   INT size;
   INT i, maintain;
   char dir[256], ff[128];
   char cdir[256], cff[128];
   char cmodulostr[8], modulostr[8];
 
   /* do test only if maintain has been touched */
   if (!maintain_touched)
      return;
   maintain_touched = FALSE;
 
   /* check is Maintain free is enabled */
   size = sizeof(maintain);
   db_get_value(hDB, hKey, "Settings/Maintain free space (%)", &maintain, &size, TID_INT, TRUE);
   if (maintain != 0) {
      /* scan other channels */
 
      /* get current specification */
      size = sizeof(cdir);
      db_get_value(hDB, hKey, "Settings/Data dir", cdir, &size, TID_STRING, TRUE);
      size = sizeof(cff);
      db_get_value(hDB, hKey, "Settings/filename format", cff, &size, TID_STRING, TRUE);
      size = sizeof(modulostr);
      db_get_value(hDB, hKey, "Settings/Modulo.Position", cmodulostr, &size, TID_STRING, TRUE);
 
      /* build matching dir and ff */
      for (i = 0; i < MAX_LAZY_CHANNEL; i++) {
         if (((pLall + i)->hKey) && (hKey != (pLall + i)->hKey)) { /* valid channel */
            size = sizeof(dir);
            db_get_value(hDB, (pLall + i)->hKey, "Settings/Data dir", dir, &size, TID_STRING, TRUE);
            size = sizeof(ff);
            db_get_value(hDB, (pLall + i)->hKey, "Settings/filename format", ff, &size, TID_STRING, TRUE);
            size = sizeof(modulostr);
            db_get_value(hDB, (pLall + i)->hKey, "Settings/Modulo.Position", modulostr, &size, TID_STRING, TRUE);
 
            if ((strcmp(dir, cdir) == 0) && (strcmp(ff, cff) == 0) && !cmodulostr[0] && !modulostr[0]) {
               /* check "maintain free space" */
               size = sizeof(maintain);
               db_get_value(hDB, (pLall + i)->hKey, "Settings/Maintain free space (%)",
                            &maintain, &size, TID_INT, TRUE);
               if (maintain) {
                  /* disable and inform */
                  size = sizeof(maintain);
                  maintain = 0;
                  db_set_value(hDB, (pLall + i)->hKey, "Settings/Maintain free space (%)", &maintain, size, 1, TID_INT);
                  cm_msg(MINFO, "lazy_maintain_check",
                         "Maintain free space on channel %s has been disable", (pLall + i)->name);
               }
            }
         }
      }
   }
}

Here is the call graph for this function:

Here is the caller graph for this function:

lazy_maintain_free_space()

INT lazy_maintain_free_space	(	LAZY_INFO *	pLch,
		LAZY_INFO *	pLall
	)

Definition at line 1881 of file lazylogger.cxx.

                                                                {
   int status;
 
   /* update "maintain free space" */
   lazy_maintain_check(pLch->hKey, pLall);
 
   /* check SPACE and purge if necessary = % (1:99) */
   if (lazy.pupercent > 0) {
 
      // Compute initial disk space
      double freepercent = 100. * ss_disk_free(lazy.dir) / ss_disk_size(lazy.dir);
 
      // Check for Disk full first
      if (freepercent < 5.0) {
         std::string str;
         str += "Disk ";
         str += lazy.dir;
         str += "is almost full, free space: ";
         char buf[256];
         sprintf(buf, "%.1f%%", freepercent);
         str += buf;
         al_trigger_alarm("Disk Full", str.c_str(), lazy.alarm, "Disk buffer full", AT_INTERNAL);
      } else {
         HNDLE hKey;
         if (db_find_key(hDB, 0, "/Alarms/Alarms/Disk Full", &hKey) == DB_SUCCESS)
            al_reset_alarm("Disk Full");
      }
 
      if (debug)
         printf("free space on %s: %.1f%%, lazy limit %d%%\n", lazy.dir, freepercent, lazy.pupercent);
 
      /* Lock other clients out of this following code as
       it may access the other client info tree */
 
      status = ss_semaphore_wait_for(lazy_semaphore, 5000);
      if (status != SS_SUCCESS) {
         /* exit for now and come back later */
         return NOTHING_TODO;
      }
 
      /* check purging action */
      while (freepercent <= (double) lazy.pupercent) {
         // flag for single purge
         BOOL donepurge = FALSE;
         /* search file to purge : run in donelist AND run in dirlog */
         /* synchronize donelist to dir log in case user has purged
         some file by hand. Basically remove the run in the list if the
         file is not anymore in the source dir. */
         DIRLOG f;
         if (lazy_select_purge(pLch->hKey, channel, pLall, lazy.backfmt, lazy.dir, &f) == SUCCESS) {
            /* check if beyond keep file + 1 */
            if (1 /*purun < (cur_acq_run - abs(lazy.staybehind) - 1)*/) {
               DWORD rm_time;
               /* remove file */
               rm_time = ss_millitime();
               std::string path = lazy.dir;
               path += f.filename;
               if (debug)
                  printf("file selected for removal %s [%s]\n", f.filename.c_str(), path.c_str());
               status = lazy_file_remove(path.c_str());
               rm_time = ss_millitime() - rm_time;
               if (status != SS_SUCCESS) {
                  cm_msg(MERROR, "Lazy", "lazy_file_remove failed on file %s", path.c_str());
                  // break out if can't delete files
                  break;
               } else {
                  status = lazy_log_update(REMOVE_FILE, f.runno, NULL, path.c_str(), rm_time);
                  donepurge = TRUE;
               }
            } // purun found
 
            // Re-compute free space
            freepercent = 100. * ss_disk_free(lazy.dir) / ss_disk_size(lazy.dir);
 
            if (debug)
               printf("free space on %s: %.1f%%, lazy limit %d%%\n", lazy.dir, freepercent, lazy.pupercent);
 
         } // select_purge
 
         // donepurge = FALSE => nothing else to do
         // donepurge = TRUE  => one purge done loop back once more
         if (!donepurge)
            break;
      } // while
 
      /* Release the semaphore  */
      status = ss_semaphore_release(lazy_semaphore);
 
   } /* end of if pupercent > 0 */
 
   return SUCCESS;
}

Here is the call graph for this function:

Here is the caller graph for this function:

lazy_run_extract()

INT lazy_run_extract

(

const char *

name

)

Definition at line 255 of file lazylogger.cxx.

{
#if 0
   char run_str[256];
   int j;
 
   mstrlcpy(run_str, name, sizeof(run_str));
   if (strlen(run_str) < 2)
      return 0;
 
   for (j = strlen(run_str) - 1; j >= 0 && !isdigit(run_str[j]); j--)
      run_str[j] = 0;
 
   for (j = strlen(run_str) - 1; j >= 0 && isdigit(run_str[j]); j--);
 
   return atoi(run_str + j + 1);
#endif
 
   while (*name && !isdigit(*name))
      name++;
 
   if (*name == 0)
      return 0;
 
   return atoi(name);
}

Here is the caller graph for this function:

lazy_select_purge()

INT lazy_select_purge	(	HNDLE	hKey,
		INT	channel,
		LAZY_INFO *	pLall,
		const char *	fmt,
		const char *	dir,
		DIRLOG *	f
	)

Definition at line 801 of file lazylogger.cxx.

{
   int size;
   char ddir[256], ff[128], strmodulo[8];
 
   /* Scan donelist from first element (oldest)
      check if run exists in dirlog
      if yes return file and run number */
 
   while (1) {
      /* try to find the oldest matching run present in the list AND on disk */
      /* build current done list */
 
      DIRLOGLIST dirlists[MAX_LAZY_CHANNEL];
      DIRLOGLIST donelists[MAX_LAZY_CHANNEL];
 
      /* build matching dir and file format (ff) */
      for (int i = 0; i < MAX_LAZY_CHANNEL; i++) {
         /* Check if key present && key different than currrent
          and if modulo is off */
         if (((pLall + i)->hKey)) {
            /* extract dir and ff */
            size = sizeof(strmodulo);
            db_get_value(hDB, (pLall + i)->hKey, "Settings/Modulo.Position", strmodulo, &size, TID_STRING, TRUE);
            if (strmodulo[0]) {
               /* Modulo enabled, skip this channel */
               if (debug)
                  printf("purge: skipping channel \'%s\' which uses modulo \'%s\'\n", lazyinfo[i].name, strmodulo);
               continue;
            }
 
            size = sizeof(ddir);
            db_get_value(hDB, (pLall + i)->hKey, "Settings/Data dir", ddir, &size, TID_STRING, TRUE);
            size = sizeof(ff);
            db_get_value(hDB, (pLall + i)->hKey, "Settings/filename format", ff, &size, TID_STRING, TRUE);
 
            // monkey about with trailing '/' characters
 
            int len = strlen(ddir);
            if (ddir[len - 1] != '/') {
               ddir[len] = '/';
               ddir[len + 1] = 0;
            }
 
            /* if same dir && same ff => mark lazy channel */
            if (strcmp(ddir, dir) != 0) {
               if (debug)
                  printf("purge: skipping channel \'%s\' which uses different data dir \'%s\', we use \'%s\'\n",
                         lazyinfo[i].name, ddir, dir);
               continue;
            }
 
            if (debug)
               printf("Loading file lists for channel \'%s\', data dir \'%s\', format \'%s\'\n", lazyinfo[i].name, ddir,
                      ff);
 
            /* load file list and done list for matching channels */
            build_log_list(ff, ddir, &dirlists[i]);
            build_done_list(pLall[i].hKey, &dirlists[i], &donelists[i]);
         }
      } /* end of loop over channels */
 
      /* search for files to delete */
      for (unsigned k = 0; k < dirlists[channel].size(); k++) {
         bool can_delete = true;
 
         if (debug)
            printf("purge: consider file \'%s\'\n", dirlists[channel][k].filename.c_str());
 
         for (int i = 0; i < MAX_LAZY_CHANNEL; i++)
            if (((pLall + i)->hKey)) {
               bool in_dir_list = false;
               bool in_done_list = false;
 
               for (unsigned j = 0; j < dirlists[i].size(); j++)
                  if (dirlists[i][j].filename == dirlists[channel][k].filename) {
                     in_dir_list = true;
                     break;
                  }
 
               if (!in_dir_list) {
                  if (debug)
                     printf("channel \'%s\': file is not in dir list, ok to delete\n", lazyinfo[i].name);
                  continue;
               }
 
               for (unsigned j = 0; j < donelists[i].size(); j++)
                  if (donelists[i][j].filename == dirlists[channel][k].filename) {
                     in_done_list = true;
                     break;
                  }
 
               if (!in_done_list) {
                  if (debug)
                     printf("channel \'%s\': file is in dirlist but not in done list, cannot delete\n",
                            lazyinfo[i].name);
                  can_delete = false;
                  break;
               }
 
               if (debug)
                  printf("channel \'%s\': file is in dirlist and in done list, ok to delete\n", lazyinfo[i].name);
            }
 
         if (can_delete) {
            if (debug)
               printf("purge: file \'%s\' is done by all channels\n", dirlists[channel][k].filename.c_str());
            *f = dirlists[channel][k];
            return SUCCESS;
         }
      }
 
      /* nothing to remove */
      return !SUCCESS;
   }
}

Here is the call graph for this function:

Here is the caller graph for this function:

lazy_settings_hotlink()

void lazy_settings_hotlink	(	HNDLE	hDB,
		HNDLE	hKey,
		void *	info
	)

lazy_statistics_update()

void lazy_statistics_update

(

INT

cploop_time

)

Definition at line 1007 of file lazylogger.cxx.

{
 
   if (debug) {
      printf("file.size:%f - ", lazyst.file_size);
      printf("file.curr:%f - ", lazyst.cur_size);
      printf("lastsz:%f - ", lastsz);
      printf("nfiles:%i\n", lazyst.nfiles);
   }
   /* update rate [kb/s] statistics */
   if (cploop_time == 0) // special function: set copy_rate to zero at end of copy
      lazyst.copy_rate = 0.0;
   if ((ss_millitime() - cploop_time) > 100)
      lazyst.copy_rate = 1000.f * (lazyst.cur_size - lastsz) / (ss_millitime() - cploop_time);
   if (lazyst.copy_rate < 0.0)
      lazyst.copy_rate = 0.0;
 
   /* update % statistics */
   if (lazyst.file_size != 0.0f)
      lazyst.progress = (100.0f * (lazyst.cur_size / lazyst.file_size));
   else
      lazyst.progress = 0.0f;
 
   /* update backup % statistics */
   if (lazy.capacity > 0.0f)
      lazyst.bckfill = 100.0f * (lazyst.cur_dev_size / lazy.capacity);
   else
      lazyst.bckfill = 0.0f;
 
   lastsz = lazyst.cur_size;
   /* udate ODB statistics */
   db_send_changed_records();
}

Here is the call graph for this function:

Here is the caller graph for this function:

lazy_trstop()

INT lazy_trstop	(	INT	rn,
		char *	error
	)

Definition at line 248 of file lazylogger.cxx.

                                     {
   printf("lazy has detected a STOP transition\n");
   stop_transition = TRUE;
   return CM_SUCCESS;
}

Here is the caller graph for this function:

list_filename()

std::string list_filename	(	const char *	lazyname,
		const char *	listname
	)

Definition at line 572 of file lazylogger.cxx.

                                                                    {
   std::string s(cm_get_path());
   s += ".Lazy_";
   s += lazyname;
   s += ".";
   s += listname;
   return s;
}

Here is the call graph for this function:

Here is the caller graph for this function:

load_done_list()

void load_done_list	(	const char *	lazyname,
		const DIRLOGLIST *	dirlist,
		DIRLOGLIST *	dlist
	)

Definition at line 581 of file lazylogger.cxx.

                                                                                        {
   FILE *fp = fopen(list_filename(lazyname, "donelist").c_str(), "r");
   if (!fp)
      return;
 
   while (1) {
      char str[256];
      char *s = fgets(str, sizeof(str), fp);
      if (!s)
         break;
 
      DIRLOG d;
 
      char *p = strchr(s, ' ');
 
      if (p) {
         *p = 0;
         p++;
      }
 
      d.filename = s;
      d.runno = strtoul(p, &p, 0);
      d.size = strtod(p, &p);
 
      bool found = false;
      if (dirlist) {
         for (unsigned i = 0; i < dirlist->size(); i++)
            if ((*dirlist)[i].filename == d.filename) {
               found = true;
               break;
            }
      } else
         found = true;
 
      if (found)
         dlist->push_back(d);
   }
 
   fclose(fp);
 
   sort(dlist->begin(), dlist->end(), cmp_dirlog);
}

Here is the call graph for this function:

Here is the caller graph for this function:

main()

int main	(	int	argc,
		char **	argv
	)

Definition at line 2441 of file lazylogger.cxx.

                                {
   char channel_name[32];
   char host_name[HOST_NAME_LENGTH];
   char expt_name[HOST_NAME_LENGTH];
   BOOL daemon;
   INT i, msg, size, status, mainlast_time;
   DWORD last_time_kb = 0;
   setbuf(stdout, NULL);
   setbuf(stderr, NULL);
 
   /* set default */
   host_name[0] = 0;
   expt_name[0] = 0;
   channel_name[0] = 0;
   BOOL zap_flag = FALSE;
   msg_flag = FALSE;
   debug = daemon = FALSE;
 
   /* set default */
   cm_get_environment(host_name, sizeof(host_name), expt_name, sizeof(expt_name));
 
   /* get parameters */
   for (i = 1; i < argc; i++) {
      if (argv[i][0] == '-' && argv[i][1] == 'd')
         debug = TRUE;
      else if (argv[i][0] == '-' && argv[i][1] == 'n')
         nodelete = TRUE;
      else if (argv[i][0] == '-' && argv[i][1] == 'D')
         daemon = TRUE;
      else if (strncmp(argv[i], "-C", 2) == 0)
         convert_flag = TRUE;
      else if (strncmp(argv[i], "-z", 2) == 0)
         zap_flag = TRUE;
      else if (strncmp(argv[i], "-t", 2) == 0)
         msg_flag = TRUE;
      else if (argv[i][0] == '-') {
         if (i + 1 >= argc || argv[i + 1][0] == '-')
            goto usage;
         if (strncmp(argv[i], "-e", 2) == 0)
            strcpy(expt_name, argv[++i]);
         else if (strncmp(argv[i], "-h", 2) == 0)
            strcpy(host_name, argv[++i]);
         else if (strncmp(argv[i], "-c", 2) == 0)
            strcpy(channel_name, argv[++i]);
      } else {
         usage:
         printf("Lazylogger: Multi channel background data copier\n");
         printf("\n");
         printf("Usage: lazylogger [-d] [-n] [-D] [-h <Hostname>] [-e <Experiment>] [-z] [-t] [-C] -c <channel name>\n");
         printf("\n");
         printf("Options:\n");
         printf(" -c <channel name> - specify lazylogger channel name\n");
         printf(" -C - convert old-format done list to new file-based format\n");
         printf(" -d - enable debug printout\n");
         printf(" -n - do not delete any files (for testing \"Maintain free space\")\n");
         printf(" -D - start as a daemon\n");
         printf(" -h - connect to experiment on another machine\n");
         printf(" -e - connect to non-default experiment\n");
         printf(" -z - clear /Lazy/channel/Statistics\n");
         printf(" -t - permit lazy logger to TALK (see mlxspeaker)\n");
         printf("\n");
         printf("Quick man :\n");
         printf("The Lazy/Settings tree is composed of the following parameters:\n");
         printf("Maintain free space (%%)(0): purge source device to maintain free space on the source directory\n");
         printf("                      (0) : no purge      \n");
         printf("Stay behind  (0)         : If negative number : lazylog runs starting from the OLDEST\n");
         printf("                             run file sitting in the 'Dir data' to the current acquisition\n");
         printf("                             run minus the 'Stay behind number'\n");
         printf("                            If positive number : lazylog starts from the current\n");
         printf("                             acquisition run minus 'Stay behind number' \n");
         printf("                            Zero : no stay-behind - files are saved as soon as they are closed\n");
         printf("Alarm Class               : Specify the Class to be used in case of Tape Full condition\n");
         printf("Running condition         : active/deactive lazylogger under given condition i.e:\n");
         printf("                           'ALWAYS' (default)     : Independent of the ACQ state ...\n");
         printf("                           'NEVER'                : ...\n");
         printf("                           'WHILE_ACQ_NOT_RUNNING': ...\n");
         printf("                           '/alias/max_rate < 200'    (max_rate is a link)\n");
         printf("                           '/equipment/scaler/variables/scal[4] < 23.45'\n");
         printf("                           '/equipment/trigger/statistics/events per sec. < 400'\n");
         printf("Data dir                  : MIDAS Data Directory (same as \"/Logger/Data Dir\")\n");
         printf("Data format               : Data format (MIDAS)\n");
         printf("Filename format           : Run format i.e. \"run%%05d.mid\", or \"*.mid.gz\" or \"*.mid.gz,*.xml\" \n");
         printf("List label                : Label of destination save_set.\n");
         printf("                            Prevent lazylogger to run if not given.\n");
         printf("                            Will be reset if maximum capacity reached.\n");
         printf("Execute after rewind      : Execute the command <cmd> after rewind complete\n");
         printf("                          : args passed are: 'device path' 'channel name' 'list label'\n");
         printf("                          : The actual command will look like: <cmd> /dev/nst0 Tape Data_2000\n");
         printf("Backup type               : Destination device type (Disk, Tape, Script, SFTP, FTP)\n");
         printf("Path                      : Destination path (file.ext, /dev/nst0, ftp...)\n");
         printf("                            in case of SFTP type, the 'Path' entry should be:\n");
         printf("                            sftp://username@host/path\n");
         printf("                            in case of FTP type, the 'Path' entry should be:\n");
         printf("                            host, port, user, password, directory, run%%05d.mid\n");
         printf("Capacity (Bytes)          : Maximum capacity of the destination device.\n");
         printf("modulo                    : Enable multiple lazy on same source. Ex: 3ch : 3.0, 3.1, 3.2\n");
         printf("tapeAppend                : Enable positioning of the TAPE to EOD before each lazy copy\n");
         return 1;
      }
   }
 
   /* Handle SIGPIPE signals generated from errors on the pipe */
#ifdef SIGPIPE
   signal(SIGPIPE, SIG_IGN);
#endif
   if (daemon) {
      printf("Becoming a daemon...\n");
      ss_daemon_init(FALSE);
   }
 
   /* connect to experiment */
   status = cm_connect_experiment1(host_name, expt_name, "Lazy", 0, DEFAULT_ODB_SIZE, WATCHDOG_TIMEOUT);
   if (status != CM_SUCCESS)
      return 1;
 
   /* create a common semaphore for the independent lazylogger */
   status = ss_semaphore_create("LAZY", &lazy_semaphore);
 
   /* check lazy status for multiple channels */
   cm_get_experiment_database(&hDB, &hKey);
   if (db_find_key(hDB, 0, "/Lazy", &hKey) == DB_SUCCESS) {
      HNDLE hSubkey;
      KEY key;
      INT j = 0;
      for (i = 0;; i++) {
         db_enum_key(hDB, hKey, i, &hSubkey);
         if (!hSubkey)
            break;
         db_get_key(hDB, hSubkey, &key);
         if (key.type == TID_KEY) {
            /* compose client name */
            std::string strclient;
            strclient += "Lazy_";
            strclient += key.name;
            if (cm_exist(strclient.c_str(), TRUE) == CM_SUCCESS)
               lazyinfo[j].active = TRUE;
            else
               lazyinfo[j].active = FALSE;
            strcpy(lazyinfo[j].name, key.name);
 
            lazyinfo[j].hKey = hSubkey;
            j++;
         }
      }
   } else {
      /* create settings tree */
      channel = 0;
      if (channel_name[0] != 0)
         mstrlcpy(lazyinfo[channel].name, channel_name, sizeof(lazyinfo[channel].name));
      std::string str;
      str += "/Lazy/";
      str += lazyinfo[channel].name;
      str += "/Settings";
      db_create_record(hDB, 0, str.c_str(), LAZY_SETTINGS_STRING);
   }
 
   { /* Selection of client */
      INT i, j;
      char str[32];
 
      if (lazyinfo[0].hKey) {
         if (channel_name[0] == 0) {
            /* command prompt */
            printf(" Available Lazy channels to connect to:\n");
            i = 0;
            j = 1;
            while (lazyinfo[i].hKey) {
               if (!lazyinfo[i].active)
                  printf("%d) Lazy %s \n", j, lazyinfo[i].name);
               else
                  printf(".) Lazy %s already active\n", lazyinfo[i].name);
               j++;
               i++;
            }
            printf("Enter client number or new lazy client name: ");
            i = atoi(ss_gets(str, 32));
            if ((i == 0) && ((strlen(str) == 0) || (strncmp(str, " ", 1) == 0))) {
               cm_msg(MERROR, "Lazy", "Please specify a valid channel name (%s)", str);
               cm_disconnect_experiment();
               return 1;
            }
         } else {
            /* Skip the command prompt for serving the -c option */
            /*
           scan if channel_name already exists
           Yes : check if client is running
           Yes : get out (goto error)
           No  : connect (extract index)
           No  : new channel (i=0)
         */
            i = 0;
            j = -1;
            while (lazyinfo[i].hKey) {
               if (equal_ustring(channel_name, lazyinfo[i].name)) {
                  /* correct name => check active  */
                  if (lazyinfo[i].active) {
                     cm_msg(MERROR, "Lazy", "Lazy channel "
                                            "%s"
                                            " already running!",
                            lazyinfo[i].name);
                     cm_disconnect_experiment();
                     return 1;
                  }
                  j = i;
               }
               i++;
            }
            if (j == -1) {
               /* new entry */
               i = 0;
               mstrlcpy(str, channel_name, sizeof(str));
            } else {
               /* connect to */
               i = j + 1;
            }
         }
 
         if (i == 0) { /* new entry */
            for (j = 0; j < MAX_LAZY_CHANNEL; j++) {
               if (lazyinfo[j].hKey == 0) {
                  /* compose client name */
                  std::string strclient;
                  strclient += "Lazy_";
                  strclient += str;
                  if (cm_exist(strclient.c_str(), TRUE) == CM_SUCCESS)
                     lazyinfo[j].active = TRUE;
                  else
                     lazyinfo[j].active = FALSE;
                  strcpy(lazyinfo[j].name, str);
                  lazyinfo[j].hKey = 0;
                  channel = j;
                  break;
               }
            }
         } else if (!lazyinfo[i - 1].active)
            channel = i - 1;
         else
            channel = -1;
      }
 
      if (channel < 0) {
         cm_disconnect_experiment();
         return 1;
      }
 
      { /* creation of the lazy channel */
         char str[128];
 
         if (lazyinfo[channel].hKey == 0)
            printf(" Creating Lazy channel %s\n", lazyinfo[channel].name);
 
         /* create/update settings */
         sprintf(str, "/Lazy/%s/Settings", lazyinfo[channel].name);
         db_create_record(hDB, 0, str, LAZY_SETTINGS_STRING);
         /* create/update statistics */
         sprintf(str, "/Lazy/%s/Statistics", lazyinfo[channel].name);
         db_create_record(hDB, 0, str, LAZY_STATISTICS_STRING);
         sprintf(str, "/Lazy/%s", lazyinfo[channel].name);
         db_find_key(hDB, 0, str, &lazyinfo[channel].hKey);
      }
   }
   /* disconnect from experiment */
   cm_disconnect_experiment();
 
   { /* reconnect to experiment with proper name */
      std::string str;
      str += "Lazy_";
      str += lazyinfo[channel].name;
      status = cm_connect_experiment1(host_name, expt_name, str.c_str(), 0, DEFAULT_ODB_SIZE, WATCHDOG_TIMEOUT);
   }
   if (status != CM_SUCCESS) {
      cm_disconnect_experiment();
      return 1;
   }
 
   cm_get_experiment_database(&hDB, &hKey);
 
   int max_event_size = DEFAULT_MAX_EVENT_SIZE;
 
   size = sizeof(max_event_size);
   status = db_get_value(hDB, 0, "/Experiment/MAX_EVENT_SIZE", &max_event_size, &size, TID_DWORD, TRUE);
 
   /* Remove temporary Lazy entry */
 
   status = db_delete(hDB, 0, "Programs/Lazy");
   if (status != DB_SUCCESS) {
      cm_msg(MERROR, "Lazy", "Cannot delete /Programs/Lazy");
   }
 
   /* turn on keepalive messages with increased timeout */
   if (debug)
      cm_set_watchdog_params(TRUE, 0);
 
#ifdef HAVE_FTPLIB
   if (debug)
      ftp_debug((int (*)(const char *)) puts, (int (*)(const char *)) puts);
#endif
 
   printf("Lazy_%s starting... "
          "!"
          " to exit \n",
          lazyinfo[channel].name);
 
   if (zap_flag) {
      /* reset the statistics */
      cm_msg(MINFO, "Lazy", "zapping %s/statistics content", lazyinfo[channel].name);
      size = sizeof(lazyst);
      memset(&lazyst, 0, size);
      if (db_find_key(hDB, lazyinfo[channel].hKey, "Statistics", &hKeyst) == DB_SUCCESS)
         status = db_set_record(hDB, hKeyst, &lazyst, size, 0);
      else
         cm_msg(MERROR, "Lazy", "did not find %s/Statistics for zapping", lazyinfo[channel].name);
   }
 
   /* get value once & hot links the run state */
   db_find_key(hDB, 0, "/runinfo/state", &hKey);
   size = sizeof(run_state);
   db_get_data(hDB, hKey, &run_state, &size, TID_INT);
   status = db_open_record(hDB, hKey, &run_state, sizeof(run_state), MODE_READ, NULL, NULL); // watch a TID_INT
   if (status != DB_SUCCESS) {
      cm_msg(MERROR, "Lazy", "cannot open /runinfo/state record");
   }
   /* hot link for statistics in write mode */
   size = sizeof(lazyst);
   if (db_find_key(hDB, lazyinfo[channel].hKey, "Statistics", &hKey) == DB_SUCCESS) {
      db_get_record1(hDB, hKey, &lazyst, &size, 0, LAZY_STATISTICS_STRING);
   }
   status = db_open_record1(hDB, hKey, &lazyst, sizeof(lazyst), MODE_WRITE, NULL, NULL, LAZY_STATISTICS_STRING);
   if (status == DB_NO_ACCESS) {
      /* record is probably still in exclusive access by dead FE, so reset it */
      status = db_set_mode(hDB, hKey, MODE_READ | MODE_WRITE | MODE_DELETE, TRUE);
      if (status != DB_SUCCESS)
         cm_msg(MERROR, "Lazy", "Cannot change access mode for %s/Statistics record, error %d", lazyinfo[channel].name,
                status);
      else
         cm_msg(MINFO, "Lazy", "Recovered access mode for %s/Statistics record", lazyinfo[channel].name);
      status = db_open_record1(hDB, hKey, &lazyst, sizeof(lazyst), MODE_WRITE, NULL, NULL, LAZY_STATISTICS_STRING);
   }
   if (status != DB_SUCCESS) {
      cm_msg(MERROR, "Lazy", "cannot open %s/Statistics record", lazyinfo[channel].name);
   }
   /* get /settings once & hot link settings in read mode */
   db_find_key(hDB, lazyinfo[channel].hKey, "Settings", &hKey);
 
   size = sizeof(lazy);
   status = db_get_record1(hDB, hKey, &lazy, &size, 0, LAZY_SETTINGS_STRING);
   if (status != DB_SUCCESS) {
      cm_msg(MERROR, "Lazy", "cannot get %s/Settings record, db_get_record() status %d", lazyinfo[channel].name,
             status);
   }
 
   status = db_watch(hDB, hKey, watch_settings, &hKey);
   if (status != DB_SUCCESS) {
      cm_msg(MERROR, "Lazy", "cannot open %s/Settings record", lazyinfo[channel].name);
   }
 
   /* set global key for that channel */
   pcurrent_hKey = lazyinfo[channel].hKey;
 
   /* set Data dir from /logger if local is empty & /logger exists */
   if ((lazy.dir[0] == '\0') && (db_find_key(hDB, 0, "/Logger/Data dir", &hKey) == DB_SUCCESS)) {
      size = sizeof(lazy.dir);
      db_get_data(hDB, hKey, lazy.dir, &size, TID_STRING);
      db_set_value(hDB, lazyinfo[channel].hKey, "Settings/Data dir", lazy.dir, size, 1, TID_STRING);
   }
 
   // Register for STOP transition
   if (cm_register_transition(TR_STOP, lazy_trstop, 810) != CM_SUCCESS) {
      printf("Failed to start local RPC server");
      cm_disconnect_experiment();
 
      /* let user read message before window might close */
      ss_sleep(5000);
      return 1;
   }
 
   mainlast_time = 0;
 
   /* initialize ss_getchar() */
   ss_getchar(0);
 
   DWORD period = lazy.period * 1000;
 
   int ch = 0;
 
   do {
      msg = cm_yield(2000);
      if (period < 1)
         period = 1;
      if ((ss_millitime() - mainlast_time) > period) {
         status = lazy_main(channel, &lazyinfo[0], max_event_size);
         if (status == FORCE_EXIT) {
            cm_msg(MERROR, "lazy", "Exit requested by program");
            break;
         }
         mainlast_time = ss_millitime();
         if (status == TRY_LATER) {
            period *= 2;
            DWORD max_period = 30 * 60 * 1000;
            if (period > max_period)
               period = max_period;
            cm_msg(MINFO, "lazy", "Will try again after %d seconds", period);
         } else {
            period = lazy.period * 1000;
         }
      }
 
      /* check keyboard once every 100 ms */
      if (ss_millitime() - last_time_kb > 100) {
         last_time_kb = ss_millitime();
 
         ch = 0;
         while (ss_kbhit()) {
            ch = ss_getchar(0);
            if (ch == -1)
               ch = getchar();
            if ((char) ch == '!')
               break;
         }
      }
   } while (msg != RPC_SHUTDOWN && msg != SS_ABORT && ch != '!');
 
   cm_disconnect_experiment();
   return 1;
}

Here is the call graph for this function:

moduloCheck()

INT moduloCheck	(	INT	lModulo,
		INT	lPosition,
		INT	lrun
	)

Definition at line 369 of file lazylogger.cxx.

{
   if (lModulo) {
      if ((lrun % lModulo) == lPosition)
         return lrun;
      else
         return 0;
   } else
      return lrun;
}

Here is the caller graph for this function:

print_dirlog()

void print_dirlog

(

const DIRLOGLIST *

dirlog

)

Definition at line 238 of file lazylogger.cxx.

                                            {
   for (unsigned i = 0; i < dirlog->size(); i++)
      printf("%d: %s, run %d, size %12.0f\n",
             i,
             (*dirlog)[i].filename.c_str(),
             (*dirlog)[i].runno,
             (*dirlog)[i].size);
};

save_done_list()

INT save_done_list	(	HNDLE	hLch,
		DIRLOGLIST *	pdone
	)

Definition at line 750 of file lazylogger.cxx.

{
   KEY key;
   int status = db_get_key(hDB, hLch, &key);
   assert(status == DB_SUCCESS);
   sort(pdone->begin(), pdone->end(), cmp_dirlog);
   save_list(key.name, "donelist", pdone);
   return SUCCESS;
}

Here is the call graph for this function:

Here is the caller graph for this function:

save_list()

int save_list	(	const char *	lazyname,
		const char *	listname,
		const DIRLOGLIST *	dlist
	)

Definition at line 624 of file lazylogger.cxx.

                                                                                   {
   std::string fname = list_filename(lazyname, listname);
   std::string tmpname = fname + ".tmp";
 
   FILE *fp = fopen(tmpname.c_str(), "w");
   if (!fp) {
      cm_msg(MERROR, "save_list", "Cannot write to \'%s\', errno %d (%s)",
             tmpname.c_str(),
             errno,
             strerror(errno));
      return !SUCCESS;
   }
 
   for (unsigned i = 0; i < dlist->size(); i++) {
      const char *s = (*dlist)[i].filename.c_str();
      const char *p;
      while ((p = strchr(s, DIR_SEPARATOR)))
         s = p + 1;
      fprintf(fp, "%s %d %12.0f\n",
              s,
              (*dlist)[i].runno,
              (*dlist)[i].size);
   }
 
   fclose(fp);
 
   int status = rename(tmpname.c_str(), fname.c_str());
   if (status) {
      cm_msg(MERROR, "save_list", "Cannot rename \'%s\' to \'%s\', errno %d (%s)",
             tmpname.c_str(),
             fname.c_str(),
             errno,
             strerror(errno));
      return !SUCCESS;
   }
 
   return SUCCESS;
}

Here is the call graph for this function:

Here is the caller graph for this function:

watch_settings()

static void watch_settings ( HNDLE  hDB, HNDLE  hKey, HNDLE  index, void *  info  )

static

Definition at line 2419 of file lazylogger.cxx.

                                                                           {
   int status;
   assert(info != NULL);
   HNDLE hSet = *(HNDLE *) info;
   int size = sizeof(lazy);
   status = db_get_record1(hDB, hSet, &lazy, &size, 0, LAZY_SETTINGS_STRING);
   if (status != DB_SUCCESS) {
      cm_msg(MINFO, "watch_settings", "db_get_record(settings) status %d", status);
      return;
   }
 
   // printf("Settings updated\n");
 
   if (lazy.pupercent != 0)
      maintain_touched = TRUE;
   else
      maintain_touched = FALSE;
 
   //printf("pup %d, touched %d\n", lazy.pupercent, maintain_touched);
}

Here is the call graph for this function:

Here is the caller graph for this function:

Variable Documentation

blockn

INT blockn = 0

Definition at line 212 of file lazylogger.cxx.

channel

INT channel = -1

Definition at line 198 of file lazylogger.cxx.

convert_flag

BOOL convert_flag = FALSE

Definition at line 207 of file lazylogger.cxx.

copy_continue

BOOL copy_continue = TRUE

Definition at line 208 of file lazylogger.cxx.

data_fmt

INT data_fmt

Definition at line 209 of file lazylogger.cxx.

debug

BOOL debug = FALSE

debug printouts

Definition at line 53 of file lazylogger.cxx.

delay_start

BOOL delay_start = FALSE

Definition at line 214 of file lazylogger.cxx.

dev_type

INT dev_type

Definition at line 209 of file lazylogger.cxx.

full_bck_flag

BOOL full_bck_flag = FALSE

Definition at line 211 of file lazylogger.cxx.

hDB

HNDLE hDB

main ODB handle

Definition at line 202 of file lazylogger.cxx.

hDev

INT hDev

Definition at line 205 of file lazylogger.cxx.

hKey

HNDLE hKey

Definition at line 202 of file lazylogger.cxx.

hKeyst

HNDLE hKeyst

Definition at line 204 of file lazylogger.cxx.

lastsz

double lastsz

Definition at line 203 of file lazylogger.cxx.

lazy

LAZY_SETTING lazy

Definition at line 175 of file lazylogger.cxx.

lazy_semaphore

INT lazy_semaphore

Definition at line 201 of file lazylogger.cxx.

lazy_time

DWORD lazy_time = 0

Definition at line 215 of file lazylogger.cxx.

lazyinfo

LAZY_INFO lazyinfo[MAX_LAZY_CHANNEL] = {{0, FALSE, "Tape"}}

Definition at line 196 of file lazylogger.cxx.

{{0, FALSE, "Tape"}};

lazylog

char lazylog[MAX_STRING_LENGTH]

Definition at line 210 of file lazylogger.cxx.

lazyst

LAZY_STATISTICS lazyst

Definition at line 188 of file lazylogger.cxx.

maintain_touched

BOOL maintain_touched = FALSE

Definition at line 211 of file lazylogger.cxx.

msg_flag

BOOL msg_flag

Definition at line 206 of file lazylogger.cxx.

nodelete

BOOL nodelete = FALSE

Definition at line 54 of file lazylogger.cxx.

pcurrent_hKey

HNDLE pcurrent_hKey

Definition at line 202 of file lazylogger.cxx.

run_state

INT run_state

Definition at line 205 of file lazylogger.cxx.

stop_transition

BOOL stop_transition = FALSE

Definition at line 213 of file lazylogger.cxx.