maintagent.c

Go to the documentation of this file.

/*
 SPDX-FileCopyrightText: © 2013 Hewlett-Packard Development Company, L.P.
 SPDX-FileCopyrightText: © 2014, 2019 Siemens AG
 
 SPDX-License-Identifier: GPL-2.0-only
*/
#include "maintagent.h"
 
#ifdef COMMIT_HASH_S
char BuildVersion[]="maintagent build version: " VERSION_S " r(" COMMIT_HASH_S ").\n";
#else
char BuildVersion[]="maintagent build version: NULL.\n";
#endif
 
int main(int argc, char **argv)
{
  int cmdopt;
  char *COMMIT_HASH;
  char *VERSION;
  char agentRev[myBUFSIZ];
  char *agentDesc = "Maintenance Agent";
 
  /* connect to the scheduler */
  fo_scheduler_connect(&argc, argv, &pgConn);
  dbManager = fo_dbManager_new(pgConn);
 
  /* get agent pk
   * Note, if GetAgentKey fails, this process will exit.
   */
  COMMIT_HASH = fo_sysconfig("maintagent", "COMMIT_HASH");
  VERSION = fo_sysconfig("maintagent", "VERSION");
  snprintf(agentRev, sizeof(agentRev), "%s.%s", VERSION, COMMIT_HASH);
  /* insert/update agent data if necessary */
  fo_GetAgentKey(pgConn, basename(argv[0]), 0, agentRev, agentDesc);
 
  int validateFoldersExe = 0;
  int verifyFilePermsExe = 0;
  int removeUploadsExe = 0;
  int normalizeUploadPrioritiesExe = 0;
  int removeTempsExe = 0;
  int vacAnalyzeExe = 0;
  int processExpiredExe = 0;
  int removeOrphanedFilesExe = 0;
  int reIndexAllTablesExe = 0;
  int removeOrphanedRowsExe = 0;
  int removeOrphanedLogs = 0;
  int removeExpiredTokensExe = 0;
  int tokenRetentionPeriod = 30;
  int removeOldGoldExe = 0;
  int removeOldLogsExe = 0;
  char goldOlder[11];
  char oldLogsDate[11] = {};
 
  /* command line options */
  while ((cmdopt = getopt(argc, argv, "aAc:DEFghiIl:LNo:pPRt:TUvVZ")) != -1)
  {
    switch (cmdopt)
    {
      case 'a': /* All non slow operations */
        if (validateFoldersExe == 0)
        {
          validateFolders();
          validateFoldersExe = 1;
        }
        if (verifyFilePermsExe == 0)
        {
          verifyFilePerms(1);
          verifyFilePermsExe = 1;
        }
        if (removeUploadsExe == 0)
        {
          removeUploads();
          removeUploadsExe = 1;
        }
        if (normalizeUploadPrioritiesExe == 0)
        {
          normalizeUploadPriorities();
          normalizeUploadPrioritiesExe = 1;
        }
        if (removeTempsExe == 0)
        {
          removeTemps();
          removeTempsExe = 1;
        }
        if (vacAnalyzeExe == 0)
        {
          vacAnalyze();
          vacAnalyzeExe = 1;
        }
        if (removeOrphanedLogs == 0)
        {
          removeOrphanedLogFiles();
          removeOrphanedLogs = 1;
        }
        break;
      case 'A': /* All operations */
        if (validateFoldersExe == 0)
        {
          validateFolders();
          validateFoldersExe = 1;
        }
        if (verifyFilePermsExe == 0)
        {
          verifyFilePerms(1);
          verifyFilePermsExe = 1;
        }
        if (removeUploadsExe == 0)
        {
          removeUploads();
          removeUploadsExe = 1;
        }
        if (normalizeUploadPrioritiesExe == 0)
        {
          normalizeUploadPriorities();
          normalizeUploadPrioritiesExe = 1;
        }
        if (removeTempsExe == 0)
        {
          removeTemps();
          removeTempsExe = 1;
        }
        if (vacAnalyzeExe == 0)
        {
          vacAnalyze();
          vacAnalyzeExe = 1;
        }
        if (processExpiredExe == 0)
        {
          processExpired();
          processExpiredExe = 1;
        }
        if (removeOrphanedFilesExe == 0)
        {
          removeOrphanedFiles();
          removeOrphanedFilesExe = 1;
        }
        if (reIndexAllTablesExe == 0)
        {
          reIndexAllTables();
          reIndexAllTablesExe = 1;
        }
        if (removeOrphanedRowsExe == 0)
        {
          removeOrphanedRows();
          removeOrphanedRowsExe = 1;
        }
        if (removeOrphanedLogs == 0)
        {
          removeOrphanedLogFiles();
          removeOrphanedLogs = 1;
        }
        break;
      case 'D': /* Vac/Analyze (slow) */
        if (vacAnalyzeExe == 0)
        {
          vacAnalyze();
          vacAnalyzeExe = 1;
        }
        break;
      case 'F': /* Validate folder contents */
        if (validateFoldersExe == 0)
        {
          validateFolders();
          validateFoldersExe = 1;
        }
        break;
      case 'g': /* Delete orphan gold files */
        deleteOrphanGold();
        break;
      case 'h':
        usage(argv[0]);
        exitNow(0);
      case 'N': /* Remove uploads with no pfiles */
        if (normalizeUploadPrioritiesExe == 0)
        {
          normalizeUploadPriorities();
          normalizeUploadPrioritiesExe = 1;
        }
        break;
      case 'o': /* Gold files older than given date */
        if (removeOldGoldExe == 0)
        {
          strncpy(goldOlder, optarg, 10);
          deleteOldGold(goldOlder);
          removeOldGoldExe = 1;
        }
        break;
      case 'p': /* Verify file permissions */
        verifyFilePerms(0);
        break;
      case 'P': /* Verify and fix file permissions */
        if (verifyFilePermsExe == 0)
        {
          verifyFilePerms(1);
          verifyFilePermsExe = 1;
        }
        break;
      case 'R': /* Remove uploads with no pfiles */
        if (removeUploadsExe == 0)
        {
          removeUploads();
          removeUploadsExe = 1;
        }
        break;
      case 't': /* Remove expired personal access token */
        if (removeExpiredTokensExe == 0)
        {
          tokenRetentionPeriod = atol(optarg);
          removeExpiredTokens(tokenRetentionPeriod);
          removeExpiredTokensExe = 1;
        }
        break;
      case 'T': /* Remove orphaned temp tables */
        if (removeTempsExe == 0)
        {
          removeTemps();
          removeTempsExe = 1;
        }
        break;
      case 'U': /* Process expired uploads (slow) */
        if (processExpiredExe == 0)
        {
          processExpired();
          processExpiredExe = 1;
        }
        break;
      case 'Z': /* Remove orphaned files from the repository (slow) */
        if (removeOrphanedFilesExe == 0)
        {
          removeOrphanedFiles();
          removeOrphanedFilesExe = 1;
        }
        break;
      case 'I': /* Reindexing of database */
        if (reIndexAllTablesExe == 0)
        {
          reIndexAllTables();
          reIndexAllTablesExe = 1;
        }
        break;
      case 'E': /* Remove orphaned files from the database */
        if (removeOrphanedRowsExe == 0)
        {
          removeOrphanedRows();
          removeOrphanedRowsExe = 1;
        }
        break;
      case 'l': /* Remove old log files */
        if (removeOldLogsExe == 0)
        {
          strncpy(oldLogsDate, optarg, 10);
          removeOldLogFiles(oldLogsDate);
          removeOldLogsExe = 1;
        }
        break;
      case 'L': /* Remove orphaned log files from file system */
        if (removeOrphanedLogs == 0)
        {
          removeOrphanedLogFiles();
          removeOrphanedLogs = 1;
        }
        break;
      case 'i': /* "Initialize" */
        exitNow(0);
      case 'v': /* verbose output for debugging  */
        agent_verbose++;  
        break;
      case 'V': /* print version info */
        printf("%s", BuildVersion);
        exitNow(0);
      case 'c':
        break; /* handled by fo_scheduler_connect() */
      default:
        usage(argv[0]);
        exitNow(-1);
    }
  }
 
  exitNow(0); /* success */
  return (0); /* Never executed but prevents compiler warning */
} /* main() */