forked from Telodendria/Telodendria
Break out main() into Main.c, fix some compile warnings on Cygwin.
This commit is contained in:
parent
9a1300ff2e
commit
ca053a12b1
7 changed files with 522 additions and 479 deletions
1
TODO.txt
1
TODO.txt
|
|
@ -23,6 +23,7 @@ Milestone: v0.3.0
|
||||||
[~] Option to pretty-print Json
|
[~] Option to pretty-print Json
|
||||||
[ ] Document JsonEncode() and JsonEncodeValue()
|
[ ] Document JsonEncode() and JsonEncodeValue()
|
||||||
[ ] Update man page for td
|
[ ] Update man page for td
|
||||||
|
[ ] Document Telodendria and Main
|
||||||
|
|
||||||
[~] Simple command line tool to make matrix requests
|
[~] Simple command line tool to make matrix requests
|
||||||
[x] Built on HTTP client API
|
[x] Built on HTTP client API
|
||||||
|
|
|
||||||
|
|
@ -198,7 +198,7 @@ HttpRequestSend(HttpClientContext * context)
|
||||||
|
|
||||||
tmp = line + 9;
|
tmp = line + 9;
|
||||||
|
|
||||||
while (isspace(*tmp) && *tmp != '\0')
|
while (isspace((unsigned char) *tmp) && *tmp != '\0')
|
||||||
{
|
{
|
||||||
tmp++;
|
tmp++;
|
||||||
}
|
}
|
||||||
|
|
|
||||||
500
src/Main.c
Normal file
500
src/Main.c
Normal file
|
|
@ -0,0 +1,500 @@
|
||||||
|
/*
|
||||||
|
* Copyright (C) 2022-2023 Jordan Bancino <@jordan:bancino.net>
|
||||||
|
*
|
||||||
|
* Permission is hereby granted, free of charge, to any person
|
||||||
|
* obtaining a copy of this software and associated documentation files
|
||||||
|
* (the "Software"), to deal in the Software without restriction,
|
||||||
|
* including without limitation the rights to use, copy, modify, merge,
|
||||||
|
* publish, distribute, sublicense, and/or sell copies of the Software,
|
||||||
|
* and to permit persons to whom the Software is furnished to do so,
|
||||||
|
* subject to the following conditions:
|
||||||
|
*
|
||||||
|
* The above copyright notice and this permission notice shall be
|
||||||
|
* included in all copies or portions of the Software.
|
||||||
|
*
|
||||||
|
* THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND,
|
||||||
|
* EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF
|
||||||
|
* MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND
|
||||||
|
* NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS
|
||||||
|
* BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN
|
||||||
|
* ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN
|
||||||
|
* CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
|
||||||
|
* SOFTWARE.
|
||||||
|
*/
|
||||||
|
#include <stdio.h>
|
||||||
|
#include <stdlib.h>
|
||||||
|
#include <string.h>
|
||||||
|
#include <ctype.h>
|
||||||
|
#include <unistd.h>
|
||||||
|
#include <errno.h>
|
||||||
|
#include <signal.h>
|
||||||
|
|
||||||
|
#include <grp.h>
|
||||||
|
#include <pwd.h>
|
||||||
|
|
||||||
|
#include <Telodendria.h>
|
||||||
|
#include <Memory.h>
|
||||||
|
#include <TelodendriaConfig.h>
|
||||||
|
#include <Log.h>
|
||||||
|
#include <HashMap.h>
|
||||||
|
#include <Json.h>
|
||||||
|
#include <HttpServer.h>
|
||||||
|
#include <Matrix.h>
|
||||||
|
#include <Db.h>
|
||||||
|
#include <Cron.h>
|
||||||
|
#include <Uia.h>
|
||||||
|
|
||||||
|
static HttpServer *httpServer = NULL;
|
||||||
|
|
||||||
|
static void
|
||||||
|
TelodendriaSignalHandler(int signalNo)
|
||||||
|
{
|
||||||
|
(void) signalNo;
|
||||||
|
HttpServerStop(httpServer);
|
||||||
|
}
|
||||||
|
|
||||||
|
typedef enum ArgFlag
|
||||||
|
{
|
||||||
|
ARG_VERSION = (1 << 0),
|
||||||
|
ARG_CONFIGTEST = (1 << 1),
|
||||||
|
ARG_VERBOSE = (1 << 2)
|
||||||
|
} ArgFlag;
|
||||||
|
|
||||||
|
int
|
||||||
|
main(int argc, char **argv)
|
||||||
|
{
|
||||||
|
LogConfig *lc;
|
||||||
|
int exit = EXIT_SUCCESS;
|
||||||
|
|
||||||
|
/* Arg parsing */
|
||||||
|
int opt;
|
||||||
|
int flags = 0;
|
||||||
|
char *configArg = NULL;
|
||||||
|
|
||||||
|
/* Config file */
|
||||||
|
FILE *configFile = NULL;
|
||||||
|
HashMap *config = NULL;
|
||||||
|
|
||||||
|
/* Program configuration */
|
||||||
|
TelodendriaConfig *tConfig = NULL;
|
||||||
|
|
||||||
|
/* User validation */
|
||||||
|
struct passwd *userInfo = NULL;
|
||||||
|
struct group *groupInfo = NULL;
|
||||||
|
|
||||||
|
/* Signal handling */
|
||||||
|
struct sigaction sigAction;
|
||||||
|
|
||||||
|
MatrixHttpHandlerArgs matrixArgs;
|
||||||
|
Cron *cron = NULL;
|
||||||
|
|
||||||
|
memset(&matrixArgs, 0, sizeof(matrixArgs));
|
||||||
|
|
||||||
|
lc = LogConfigCreate();
|
||||||
|
|
||||||
|
if (!lc)
|
||||||
|
{
|
||||||
|
printf("Fatal error: unable to allocate memory for logger.\n");
|
||||||
|
return EXIT_FAILURE;
|
||||||
|
}
|
||||||
|
|
||||||
|
MemoryHook(TelodendriaMemoryHook, lc);
|
||||||
|
|
||||||
|
TelodendriaPrintHeader(lc);
|
||||||
|
|
||||||
|
#ifdef __OpenBSD__
|
||||||
|
Log(lc, LOG_DEBUG, "Attempting pledge...");
|
||||||
|
|
||||||
|
if (pledge("stdio rpath wpath cpath flock inet dns getpw id unveil", NULL) != 0)
|
||||||
|
{
|
||||||
|
Log(lc, LOG_ERR, "Pledge failed: %s", strerror(errno));
|
||||||
|
exit = EXIT_FAILURE;
|
||||||
|
goto finish;
|
||||||
|
}
|
||||||
|
#endif
|
||||||
|
|
||||||
|
while ((opt = getopt(argc, argv, "f:Vvn")) != -1)
|
||||||
|
{
|
||||||
|
switch (opt)
|
||||||
|
{
|
||||||
|
case 'f':
|
||||||
|
configArg = optarg;
|
||||||
|
break;
|
||||||
|
case 'V':
|
||||||
|
flags |= ARG_VERSION;
|
||||||
|
break;
|
||||||
|
case 'v':
|
||||||
|
flags |= ARG_VERBOSE;
|
||||||
|
break;
|
||||||
|
case 'n':
|
||||||
|
flags |= ARG_CONFIGTEST;
|
||||||
|
break;
|
||||||
|
case '?':
|
||||||
|
exit = EXIT_FAILURE;
|
||||||
|
goto finish;
|
||||||
|
default:
|
||||||
|
break;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
if (flags & ARG_VERBOSE)
|
||||||
|
{
|
||||||
|
LogConfigLevelSet(lc, LOG_DEBUG);
|
||||||
|
}
|
||||||
|
|
||||||
|
if (flags & ARG_VERSION)
|
||||||
|
{
|
||||||
|
goto finish;
|
||||||
|
}
|
||||||
|
|
||||||
|
if (!configArg)
|
||||||
|
{
|
||||||
|
Log(lc, LOG_ERR, "No configuration file specified.");
|
||||||
|
exit = EXIT_FAILURE;
|
||||||
|
goto finish;
|
||||||
|
}
|
||||||
|
else if (strcmp(configArg, "-") == 0)
|
||||||
|
{
|
||||||
|
configFile = stdin;
|
||||||
|
}
|
||||||
|
else
|
||||||
|
{
|
||||||
|
fclose(stdin);
|
||||||
|
#ifdef __OpenBSD__
|
||||||
|
if (unveil(configArg, "r") != 0)
|
||||||
|
{
|
||||||
|
Log(lc, LOG_ERR, "Unable to unveil() configuration file '%s' for reading.", configArg);
|
||||||
|
exit = EXIT_FAILURE;
|
||||||
|
goto finish;
|
||||||
|
}
|
||||||
|
#endif
|
||||||
|
configFile = fopen(configArg, "r");
|
||||||
|
if (!configFile)
|
||||||
|
{
|
||||||
|
Log(lc, LOG_ERR, "Unable to open configuration file '%s' for reading.", configArg);
|
||||||
|
exit = EXIT_FAILURE;
|
||||||
|
goto finish;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
Log(lc, LOG_NOTICE, "Processing configuration file '%s'.", configArg);
|
||||||
|
|
||||||
|
config = JsonDecode(configFile);
|
||||||
|
fclose(configFile);
|
||||||
|
|
||||||
|
if (!config)
|
||||||
|
{
|
||||||
|
Log(lc, LOG_ERR, "Syntax error in configuration file.");
|
||||||
|
exit = EXIT_FAILURE;
|
||||||
|
goto finish;
|
||||||
|
}
|
||||||
|
|
||||||
|
tConfig = TelodendriaConfigParse(config, lc);
|
||||||
|
JsonFree(config);
|
||||||
|
|
||||||
|
if (!tConfig)
|
||||||
|
{
|
||||||
|
exit = EXIT_FAILURE;
|
||||||
|
goto finish;
|
||||||
|
}
|
||||||
|
|
||||||
|
if (flags & ARG_CONFIGTEST)
|
||||||
|
{
|
||||||
|
Log(lc, LOG_INFO, "Configuration is OK.");
|
||||||
|
goto finish;
|
||||||
|
}
|
||||||
|
|
||||||
|
#ifdef __OpenBSD__
|
||||||
|
if (unveil(tConfig->dataDir, "rwc") != 0)
|
||||||
|
{
|
||||||
|
Log(lc, LOG_ERR, "Unveil of data directory failed: %s", strerror(errno));
|
||||||
|
exit = EXIT_FAILURE;
|
||||||
|
goto finish;
|
||||||
|
}
|
||||||
|
|
||||||
|
unveil(NULL, NULL); /* Done with unveil(), so disable it */
|
||||||
|
#endif
|
||||||
|
|
||||||
|
if (!tConfig->logTimestamp || strcmp(tConfig->logTimestamp, "default") != 0)
|
||||||
|
{
|
||||||
|
LogConfigTimeStampFormatSet(lc, tConfig->logTimestamp);
|
||||||
|
}
|
||||||
|
else
|
||||||
|
{
|
||||||
|
Free(tConfig->logTimestamp);
|
||||||
|
tConfig->logTimestamp = NULL;
|
||||||
|
}
|
||||||
|
|
||||||
|
if (tConfig->flags & TELODENDRIA_LOG_COLOR)
|
||||||
|
{
|
||||||
|
LogConfigFlagSet(lc, LOG_FLAG_COLOR);
|
||||||
|
}
|
||||||
|
else
|
||||||
|
{
|
||||||
|
LogConfigFlagClear(lc, LOG_FLAG_COLOR);
|
||||||
|
}
|
||||||
|
|
||||||
|
LogConfigLevelSet(lc, flags & ARG_VERBOSE ? LOG_DEBUG : tConfig->logLevel);
|
||||||
|
|
||||||
|
if (chdir(tConfig->dataDir) != 0)
|
||||||
|
{
|
||||||
|
Log(lc, LOG_ERR, "Unable to change into data directory: %s.", strerror(errno));
|
||||||
|
exit = EXIT_FAILURE;
|
||||||
|
goto finish;
|
||||||
|
}
|
||||||
|
else
|
||||||
|
{
|
||||||
|
Log(lc, LOG_DEBUG, "Changed working directory to: %s", tConfig->dataDir);
|
||||||
|
}
|
||||||
|
|
||||||
|
|
||||||
|
if (tConfig->flags & TELODENDRIA_LOG_FILE)
|
||||||
|
{
|
||||||
|
FILE *logFile = fopen("telodendria.log", "a");
|
||||||
|
|
||||||
|
if (!logFile)
|
||||||
|
{
|
||||||
|
Log(lc, LOG_ERR, "Unable to open log file for appending.");
|
||||||
|
exit = EXIT_FAILURE;
|
||||||
|
goto finish;
|
||||||
|
}
|
||||||
|
|
||||||
|
Log(lc, LOG_INFO, "Logging to the log file. Check there for all future messages.");
|
||||||
|
LogConfigOutputSet(lc, logFile);
|
||||||
|
}
|
||||||
|
else if (tConfig->flags & TELODENDRIA_LOG_STDOUT)
|
||||||
|
{
|
||||||
|
Log(lc, LOG_DEBUG, "Already logging to standard output.");
|
||||||
|
}
|
||||||
|
else if (tConfig->flags & TELODENDRIA_LOG_SYSLOG)
|
||||||
|
{
|
||||||
|
Log(lc, LOG_INFO, "Logging to the syslog. Check there for all future messages.");
|
||||||
|
LogConfigFlagSet(lc, LOG_FLAG_SYSLOG);
|
||||||
|
|
||||||
|
openlog("telodendria", LOG_PID | LOG_NDELAY, LOG_DAEMON);
|
||||||
|
/* Always log everything, because the Log API will control what
|
||||||
|
* messages get passed to the syslog */
|
||||||
|
setlogmask(LOG_UPTO(LOG_DEBUG));
|
||||||
|
}
|
||||||
|
else
|
||||||
|
{
|
||||||
|
Log(lc, LOG_ERR, "Unknown logging method in flags: '%d'", tConfig->flags);
|
||||||
|
Log(lc, LOG_ERR, "This is a programmer error; please report it.");
|
||||||
|
exit = EXIT_FAILURE;
|
||||||
|
goto finish;
|
||||||
|
}
|
||||||
|
|
||||||
|
Log(lc, LOG_DEBUG, "Configuration:");
|
||||||
|
LogConfigIndent(lc);
|
||||||
|
Log(lc, LOG_DEBUG, "Listen On: %d", tConfig->listenPort);
|
||||||
|
Log(lc, LOG_DEBUG, "Server Name: %s", tConfig->serverName);
|
||||||
|
Log(lc, LOG_DEBUG, "Base URL: %s", tConfig->baseUrl);
|
||||||
|
Log(lc, LOG_DEBUG, "Identity Server: %s", tConfig->identityServer);
|
||||||
|
Log(lc, LOG_DEBUG, "Run As: %s:%s", tConfig->uid, tConfig->gid);
|
||||||
|
Log(lc, LOG_DEBUG, "Data Directory: %s", tConfig->dataDir);
|
||||||
|
Log(lc, LOG_DEBUG, "Threads: %d", tConfig->threads);
|
||||||
|
Log(lc, LOG_DEBUG, "Max Connections: %d", tConfig->maxConnections);
|
||||||
|
Log(lc, LOG_DEBUG, "Max Cache: %ld", tConfig->maxCache);
|
||||||
|
Log(lc, LOG_DEBUG, "Flags: %x", tConfig->flags);
|
||||||
|
LogConfigUnindent(lc);
|
||||||
|
|
||||||
|
/* Arguments to pass into the HTTP handler */
|
||||||
|
matrixArgs.lc = lc;
|
||||||
|
matrixArgs.config = tConfig;
|
||||||
|
|
||||||
|
/* Bind the socket before possibly dropping permissions */
|
||||||
|
httpServer = HttpServerCreate(tConfig->listenPort, tConfig->threads, tConfig->maxConnections,
|
||||||
|
MatrixHttpHandler, &matrixArgs);
|
||||||
|
if (!httpServer)
|
||||||
|
{
|
||||||
|
Log(lc, LOG_ERR, "Unable to create HTTP server on port %d: %s",
|
||||||
|
tConfig->listenPort, strerror(errno));
|
||||||
|
exit = EXIT_FAILURE;
|
||||||
|
goto finish;
|
||||||
|
}
|
||||||
|
|
||||||
|
Log(lc, LOG_DEBUG, "Running as uid:gid: %d:%d.", getuid(), getgid());
|
||||||
|
|
||||||
|
if (tConfig->uid && tConfig->gid)
|
||||||
|
{
|
||||||
|
userInfo = getpwnam(tConfig->uid);
|
||||||
|
groupInfo = getgrnam(tConfig->gid);
|
||||||
|
|
||||||
|
if (!userInfo || !groupInfo)
|
||||||
|
{
|
||||||
|
Log(lc, LOG_ERR, "Unable to locate the user/group specified in the configuration.");
|
||||||
|
exit = EXIT_FAILURE;
|
||||||
|
goto finish;
|
||||||
|
}
|
||||||
|
else
|
||||||
|
{
|
||||||
|
Log(lc, LOG_DEBUG, "Found user/group information using getpwnam() and getgrnam().");
|
||||||
|
}
|
||||||
|
}
|
||||||
|
else
|
||||||
|
{
|
||||||
|
Log(lc, LOG_DEBUG, "No user/group info specified in the config.");
|
||||||
|
}
|
||||||
|
|
||||||
|
if (getuid() == 0)
|
||||||
|
{
|
||||||
|
#ifndef __OpenBSD__ /* chroot() is only useful without
|
||||||
|
* unveil() */
|
||||||
|
if (chroot(".") == 0)
|
||||||
|
{
|
||||||
|
Log(lc, LOG_DEBUG, "Changed the root directory to: %s.", tConfig->dataDir);
|
||||||
|
}
|
||||||
|
else
|
||||||
|
{
|
||||||
|
Log(lc, LOG_WARNING, "Unable to chroot into directory: %s.", tConfig->dataDir);
|
||||||
|
}
|
||||||
|
#endif
|
||||||
|
|
||||||
|
if (userInfo && groupInfo)
|
||||||
|
{
|
||||||
|
if (setgid(groupInfo->gr_gid) != 0 || setuid(userInfo->pw_uid) != 0)
|
||||||
|
{
|
||||||
|
Log(lc, LOG_ERR, "Unable to set process uid/gid.");
|
||||||
|
exit = EXIT_FAILURE;
|
||||||
|
goto finish;
|
||||||
|
}
|
||||||
|
else
|
||||||
|
{
|
||||||
|
Log(lc, LOG_DEBUG, "Set uid/gid to %s:%s.", tConfig->uid, tConfig->gid);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
else
|
||||||
|
{
|
||||||
|
Log(lc, LOG_WARNING, "We are running as root, and we are not dropping to another user");
|
||||||
|
Log(lc, LOG_WARNING, "because none was specified in the configuration file.");
|
||||||
|
Log(lc, LOG_WARNING, "This is probably a security issue.");
|
||||||
|
}
|
||||||
|
}
|
||||||
|
else
|
||||||
|
{
|
||||||
|
Log(lc, LOG_WARNING, "Not setting root directory, because we are not root.");
|
||||||
|
|
||||||
|
if (tConfig->uid && tConfig->gid)
|
||||||
|
{
|
||||||
|
if (getuid() != userInfo->pw_uid || getgid() != groupInfo->gr_gid)
|
||||||
|
{
|
||||||
|
Log(lc, LOG_WARNING, "Not running as the uid/gid specified in the configuration.");
|
||||||
|
}
|
||||||
|
else
|
||||||
|
{
|
||||||
|
Log(lc, LOG_DEBUG, "Running as the uid/gid specified in the configuration.");
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
/* These config values are no longer needed; don't hold them in
|
||||||
|
* memory anymore */
|
||||||
|
Free(tConfig->dataDir);
|
||||||
|
Free(tConfig->uid);
|
||||||
|
Free(tConfig->gid);
|
||||||
|
|
||||||
|
tConfig->dataDir = NULL;
|
||||||
|
tConfig->uid = NULL;
|
||||||
|
tConfig->gid = NULL;
|
||||||
|
|
||||||
|
|
||||||
|
if (!tConfig->maxCache)
|
||||||
|
{
|
||||||
|
Log(lc, LOG_WARNING, "Database caching is disabled.");
|
||||||
|
Log(lc, LOG_WARNING,
|
||||||
|
"If this is not what you intended, check the config file");
|
||||||
|
Log(lc, LOG_WARNING,
|
||||||
|
"and ensure that maxCache is a valid number of bytes.");
|
||||||
|
}
|
||||||
|
|
||||||
|
matrixArgs.db = DbOpen(".", tConfig->maxCache);
|
||||||
|
|
||||||
|
if (!matrixArgs.db)
|
||||||
|
{
|
||||||
|
Log(lc, LOG_ERR, "Unable to open data directory as a database.");
|
||||||
|
exit = EXIT_FAILURE;
|
||||||
|
goto finish;
|
||||||
|
}
|
||||||
|
|
||||||
|
cron = CronCreate(60 * 1000); /* 1-minute tick */
|
||||||
|
if (!cron)
|
||||||
|
{
|
||||||
|
Log(lc, LOG_ERR, "Unable to set up job scheduler.");
|
||||||
|
exit = EXIT_FAILURE;
|
||||||
|
goto finish;
|
||||||
|
}
|
||||||
|
|
||||||
|
Log(lc, LOG_DEBUG, "Registering jobs...");
|
||||||
|
|
||||||
|
CronEvery(cron, 30 * 60 * 1000, (JobFunc *) UiaCleanup, &matrixArgs);
|
||||||
|
|
||||||
|
Log(lc, LOG_NOTICE, "Starting job scheduler...");
|
||||||
|
CronStart(cron);
|
||||||
|
|
||||||
|
Log(lc, LOG_NOTICE, "Starting server...");
|
||||||
|
|
||||||
|
if (!HttpServerStart(httpServer))
|
||||||
|
{
|
||||||
|
Log(lc, LOG_ERR, "Unable to start HTTP server.");
|
||||||
|
exit = EXIT_FAILURE;
|
||||||
|
goto finish;
|
||||||
|
}
|
||||||
|
|
||||||
|
Log(lc, LOG_INFO, "Listening on port: %d", tConfig->listenPort);
|
||||||
|
|
||||||
|
sigAction.sa_handler = TelodendriaSignalHandler;
|
||||||
|
sigfillset(&sigAction.sa_mask);
|
||||||
|
sigAction.sa_flags = SA_RESTART;
|
||||||
|
|
||||||
|
if (sigaction(SIGINT, &sigAction, NULL) < 0)
|
||||||
|
{
|
||||||
|
Log(lc, LOG_ERR, "Unable to install signal handler.");
|
||||||
|
exit = EXIT_FAILURE;
|
||||||
|
goto finish;
|
||||||
|
}
|
||||||
|
|
||||||
|
/* Block this thread until the server is terminated by a signal
|
||||||
|
* handler */
|
||||||
|
HttpServerJoin(httpServer);
|
||||||
|
|
||||||
|
finish:
|
||||||
|
Log(lc, LOG_NOTICE, "Shutting down...");
|
||||||
|
if (httpServer)
|
||||||
|
{
|
||||||
|
HttpServerFree(httpServer);
|
||||||
|
Log(lc, LOG_DEBUG, "Freed HTTP Server.");
|
||||||
|
}
|
||||||
|
|
||||||
|
if (cron)
|
||||||
|
{
|
||||||
|
CronStop(cron);
|
||||||
|
CronFree(cron);
|
||||||
|
Log(lc, LOG_DEBUG, "Stopped and freed job scheduler.");
|
||||||
|
}
|
||||||
|
|
||||||
|
/*
|
||||||
|
* If we're not logging to standard output, then we can close it. Otherwise,
|
||||||
|
* if we are logging to stdout, LogConfigFree() will close it for us.
|
||||||
|
*/
|
||||||
|
if (!tConfig || !(tConfig->flags & TELODENDRIA_LOG_STDOUT))
|
||||||
|
{
|
||||||
|
fclose(stdout);
|
||||||
|
}
|
||||||
|
|
||||||
|
DbClose(matrixArgs.db);
|
||||||
|
|
||||||
|
LogConfigTimeStampFormatSet(lc, NULL);
|
||||||
|
TelodendriaConfigFree(tConfig);
|
||||||
|
|
||||||
|
Log(lc, LOG_DEBUG, "");
|
||||||
|
MemoryIterate(TelodendriaMemoryIterator, lc);
|
||||||
|
Log(lc, LOG_DEBUG, "");
|
||||||
|
|
||||||
|
Log(lc, LOG_DEBUG, "Exiting with code '%d'.", exit);
|
||||||
|
LogConfigFree(lc);
|
||||||
|
|
||||||
|
MemoryFreeAll();
|
||||||
|
|
||||||
|
fclose(stderr);
|
||||||
|
return exit;
|
||||||
|
}
|
||||||
|
|
@ -21,28 +21,10 @@
|
||||||
* CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
|
* CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
|
||||||
* SOFTWARE.
|
* SOFTWARE.
|
||||||
*/
|
*/
|
||||||
#include <stdio.h>
|
|
||||||
#include <stdlib.h>
|
|
||||||
#include <string.h>
|
|
||||||
#include <ctype.h>
|
|
||||||
#include <unistd.h>
|
|
||||||
#include <errno.h>
|
|
||||||
#include <signal.h>
|
|
||||||
|
|
||||||
#include <grp.h>
|
|
||||||
#include <pwd.h>
|
|
||||||
|
|
||||||
#include <Telodendria.h>
|
#include <Telodendria.h>
|
||||||
#include <Memory.h>
|
#include <Memory.h>
|
||||||
#include <TelodendriaConfig.h>
|
|
||||||
#include <Log.h>
|
#include <Log.h>
|
||||||
#include <HashMap.h>
|
|
||||||
#include <Json.h>
|
|
||||||
#include <HttpServer.h>
|
|
||||||
#include <Matrix.h>
|
|
||||||
#include <Db.h>
|
|
||||||
#include <Cron.h>
|
|
||||||
#include <Uia.h>
|
|
||||||
|
|
||||||
const char
|
const char
|
||||||
TelodendriaLogo[TELODENDRIA_LOGO_HEIGHT][TELODENDRIA_LOGO_WIDTH] = {
|
TelodendriaLogo[TELODENDRIA_LOGO_HEIGHT][TELODENDRIA_LOGO_WIDTH] = {
|
||||||
|
|
@ -80,7 +62,7 @@ const char
|
||||||
"======================================================="
|
"======================================================="
|
||||||
};
|
};
|
||||||
|
|
||||||
static void
|
void
|
||||||
TelodendriaHexDump(size_t off, char *hexBuf, char *asciiBuf, void *args)
|
TelodendriaHexDump(size_t off, char *hexBuf, char *asciiBuf, void *args)
|
||||||
{
|
{
|
||||||
LogConfig *lc = args;
|
LogConfig *lc = args;
|
||||||
|
|
@ -95,7 +77,7 @@ TelodendriaHexDump(size_t off, char *hexBuf, char *asciiBuf, void *args)
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
static void
|
void
|
||||||
TelodendriaMemoryHook(MemoryAction a, MemoryInfo * i, void *args)
|
TelodendriaMemoryHook(MemoryAction a, MemoryInfo * i, void *args)
|
||||||
{
|
{
|
||||||
LogConfig *lc = (LogConfig *) args;
|
LogConfig *lc = (LogConfig *) args;
|
||||||
|
|
@ -127,7 +109,7 @@ TelodendriaMemoryHook(MemoryAction a, MemoryInfo * i, void *args)
|
||||||
MemoryInfoGetPointer(i));
|
MemoryInfoGetPointer(i));
|
||||||
}
|
}
|
||||||
|
|
||||||
static void
|
void
|
||||||
TelodendriaMemoryIterator(MemoryInfo * i, void *args)
|
TelodendriaMemoryIterator(MemoryInfo * i, void *args)
|
||||||
{
|
{
|
||||||
LogConfig *lc = (LogConfig *) args;
|
LogConfig *lc = (LogConfig *) args;
|
||||||
|
|
@ -143,23 +125,7 @@ TelodendriaMemoryIterator(MemoryInfo * i, void *args)
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
static HttpServer *httpServer = NULL;
|
void
|
||||||
|
|
||||||
static void
|
|
||||||
TelodendriaSignalHandler(int signalNo)
|
|
||||||
{
|
|
||||||
(void) signalNo;
|
|
||||||
HttpServerStop(httpServer);
|
|
||||||
}
|
|
||||||
|
|
||||||
typedef enum ArgFlag
|
|
||||||
{
|
|
||||||
ARG_VERSION = (1 << 0),
|
|
||||||
ARG_CONFIGTEST = (1 << 1),
|
|
||||||
ARG_VERBOSE = (1 << 2)
|
|
||||||
} ArgFlag;
|
|
||||||
|
|
||||||
static void
|
|
||||||
TelodendriaPrintHeader(LogConfig * lc)
|
TelodendriaPrintHeader(LogConfig * lc)
|
||||||
{
|
{
|
||||||
size_t i;
|
size_t i;
|
||||||
|
|
@ -183,441 +149,3 @@ TelodendriaPrintHeader(LogConfig * lc)
|
||||||
Log(lc, LOG_INFO, "");
|
Log(lc, LOG_INFO, "");
|
||||||
}
|
}
|
||||||
|
|
||||||
int
|
|
||||||
main(int argc, char **argv)
|
|
||||||
{
|
|
||||||
LogConfig *lc;
|
|
||||||
int exit = EXIT_SUCCESS;
|
|
||||||
|
|
||||||
/* Arg parsing */
|
|
||||||
int opt;
|
|
||||||
int flags = 0;
|
|
||||||
char *configArg = NULL;
|
|
||||||
|
|
||||||
/* Config file */
|
|
||||||
FILE *configFile = NULL;
|
|
||||||
HashMap *config = NULL;
|
|
||||||
|
|
||||||
/* Program configuration */
|
|
||||||
TelodendriaConfig *tConfig = NULL;
|
|
||||||
|
|
||||||
/* User validation */
|
|
||||||
struct passwd *userInfo = NULL;
|
|
||||||
struct group *groupInfo = NULL;
|
|
||||||
|
|
||||||
/* Signal handling */
|
|
||||||
struct sigaction sigAction;
|
|
||||||
|
|
||||||
MatrixHttpHandlerArgs matrixArgs;
|
|
||||||
Cron *cron = NULL;
|
|
||||||
|
|
||||||
memset(&matrixArgs, 0, sizeof(matrixArgs));
|
|
||||||
|
|
||||||
lc = LogConfigCreate();
|
|
||||||
|
|
||||||
if (!lc)
|
|
||||||
{
|
|
||||||
printf("Fatal error: unable to allocate memory for logger.\n");
|
|
||||||
return EXIT_FAILURE;
|
|
||||||
}
|
|
||||||
|
|
||||||
MemoryHook(TelodendriaMemoryHook, lc);
|
|
||||||
|
|
||||||
TelodendriaPrintHeader(lc);
|
|
||||||
|
|
||||||
#ifdef __OpenBSD__
|
|
||||||
Log(lc, LOG_DEBUG, "Attempting pledge...");
|
|
||||||
|
|
||||||
if (pledge("stdio rpath wpath cpath flock inet dns getpw id unveil", NULL) != 0)
|
|
||||||
{
|
|
||||||
Log(lc, LOG_ERR, "Pledge failed: %s", strerror(errno));
|
|
||||||
exit = EXIT_FAILURE;
|
|
||||||
goto finish;
|
|
||||||
}
|
|
||||||
#endif
|
|
||||||
|
|
||||||
while ((opt = getopt(argc, argv, "f:Vvn")) != -1)
|
|
||||||
{
|
|
||||||
switch (opt)
|
|
||||||
{
|
|
||||||
case 'f':
|
|
||||||
configArg = optarg;
|
|
||||||
break;
|
|
||||||
case 'V':
|
|
||||||
flags |= ARG_VERSION;
|
|
||||||
break;
|
|
||||||
case 'v':
|
|
||||||
flags |= ARG_VERBOSE;
|
|
||||||
break;
|
|
||||||
case 'n':
|
|
||||||
flags |= ARG_CONFIGTEST;
|
|
||||||
break;
|
|
||||||
case '?':
|
|
||||||
exit = EXIT_FAILURE;
|
|
||||||
goto finish;
|
|
||||||
default:
|
|
||||||
break;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
if (flags & ARG_VERBOSE)
|
|
||||||
{
|
|
||||||
LogConfigLevelSet(lc, LOG_DEBUG);
|
|
||||||
}
|
|
||||||
|
|
||||||
if (flags & ARG_VERSION)
|
|
||||||
{
|
|
||||||
goto finish;
|
|
||||||
}
|
|
||||||
|
|
||||||
if (!configArg)
|
|
||||||
{
|
|
||||||
Log(lc, LOG_ERR, "No configuration file specified.");
|
|
||||||
exit = EXIT_FAILURE;
|
|
||||||
goto finish;
|
|
||||||
}
|
|
||||||
else if (strcmp(configArg, "-") == 0)
|
|
||||||
{
|
|
||||||
configFile = stdin;
|
|
||||||
}
|
|
||||||
else
|
|
||||||
{
|
|
||||||
fclose(stdin);
|
|
||||||
#ifdef __OpenBSD__
|
|
||||||
if (unveil(configArg, "r") != 0)
|
|
||||||
{
|
|
||||||
Log(lc, LOG_ERR, "Unable to unveil() configuration file '%s' for reading.", configArg);
|
|
||||||
exit = EXIT_FAILURE;
|
|
||||||
goto finish;
|
|
||||||
}
|
|
||||||
#endif
|
|
||||||
configFile = fopen(configArg, "r");
|
|
||||||
if (!configFile)
|
|
||||||
{
|
|
||||||
Log(lc, LOG_ERR, "Unable to open configuration file '%s' for reading.", configArg);
|
|
||||||
exit = EXIT_FAILURE;
|
|
||||||
goto finish;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
Log(lc, LOG_NOTICE, "Processing configuration file '%s'.", configArg);
|
|
||||||
|
|
||||||
config = JsonDecode(configFile);
|
|
||||||
fclose(configFile);
|
|
||||||
|
|
||||||
if (!config)
|
|
||||||
{
|
|
||||||
Log(lc, LOG_ERR, "Syntax error in configuration file.");
|
|
||||||
exit = EXIT_FAILURE;
|
|
||||||
goto finish;
|
|
||||||
}
|
|
||||||
|
|
||||||
tConfig = TelodendriaConfigParse(config, lc);
|
|
||||||
JsonFree(config);
|
|
||||||
|
|
||||||
if (!tConfig)
|
|
||||||
{
|
|
||||||
exit = EXIT_FAILURE;
|
|
||||||
goto finish;
|
|
||||||
}
|
|
||||||
|
|
||||||
if (flags & ARG_CONFIGTEST)
|
|
||||||
{
|
|
||||||
Log(lc, LOG_INFO, "Configuration is OK.");
|
|
||||||
goto finish;
|
|
||||||
}
|
|
||||||
|
|
||||||
#ifdef __OpenBSD__
|
|
||||||
if (unveil(tConfig->dataDir, "rwc") != 0)
|
|
||||||
{
|
|
||||||
Log(lc, LOG_ERR, "Unveil of data directory failed: %s", strerror(errno));
|
|
||||||
exit = EXIT_FAILURE;
|
|
||||||
goto finish;
|
|
||||||
}
|
|
||||||
|
|
||||||
unveil(NULL, NULL); /* Done with unveil(), so disable it */
|
|
||||||
#endif
|
|
||||||
|
|
||||||
if (!tConfig->logTimestamp || strcmp(tConfig->logTimestamp, "default") != 0)
|
|
||||||
{
|
|
||||||
LogConfigTimeStampFormatSet(lc, tConfig->logTimestamp);
|
|
||||||
}
|
|
||||||
else
|
|
||||||
{
|
|
||||||
Free(tConfig->logTimestamp);
|
|
||||||
tConfig->logTimestamp = NULL;
|
|
||||||
}
|
|
||||||
|
|
||||||
if (tConfig->flags & TELODENDRIA_LOG_COLOR)
|
|
||||||
{
|
|
||||||
LogConfigFlagSet(lc, LOG_FLAG_COLOR);
|
|
||||||
}
|
|
||||||
else
|
|
||||||
{
|
|
||||||
LogConfigFlagClear(lc, LOG_FLAG_COLOR);
|
|
||||||
}
|
|
||||||
|
|
||||||
LogConfigLevelSet(lc, flags & ARG_VERBOSE ? LOG_DEBUG : tConfig->logLevel);
|
|
||||||
|
|
||||||
if (chdir(tConfig->dataDir) != 0)
|
|
||||||
{
|
|
||||||
Log(lc, LOG_ERR, "Unable to change into data directory: %s.", strerror(errno));
|
|
||||||
exit = EXIT_FAILURE;
|
|
||||||
goto finish;
|
|
||||||
}
|
|
||||||
else
|
|
||||||
{
|
|
||||||
Log(lc, LOG_DEBUG, "Changed working directory to: %s", tConfig->dataDir);
|
|
||||||
}
|
|
||||||
|
|
||||||
|
|
||||||
if (tConfig->flags & TELODENDRIA_LOG_FILE)
|
|
||||||
{
|
|
||||||
FILE *logFile = fopen("telodendria.log", "a");
|
|
||||||
|
|
||||||
if (!logFile)
|
|
||||||
{
|
|
||||||
Log(lc, LOG_ERR, "Unable to open log file for appending.");
|
|
||||||
exit = EXIT_FAILURE;
|
|
||||||
goto finish;
|
|
||||||
}
|
|
||||||
|
|
||||||
Log(lc, LOG_INFO, "Logging to the log file. Check there for all future messages.");
|
|
||||||
LogConfigOutputSet(lc, logFile);
|
|
||||||
}
|
|
||||||
else if (tConfig->flags & TELODENDRIA_LOG_STDOUT)
|
|
||||||
{
|
|
||||||
Log(lc, LOG_DEBUG, "Already logging to standard output.");
|
|
||||||
}
|
|
||||||
else if (tConfig->flags & TELODENDRIA_LOG_SYSLOG)
|
|
||||||
{
|
|
||||||
Log(lc, LOG_INFO, "Logging to the syslog. Check there for all future messages.");
|
|
||||||
LogConfigFlagSet(lc, LOG_FLAG_SYSLOG);
|
|
||||||
|
|
||||||
openlog("telodendria", LOG_PID | LOG_NDELAY, LOG_DAEMON);
|
|
||||||
/* Always log everything, because the Log API will control what
|
|
||||||
* messages get passed to the syslog */
|
|
||||||
setlogmask(LOG_UPTO(LOG_DEBUG));
|
|
||||||
}
|
|
||||||
else
|
|
||||||
{
|
|
||||||
Log(lc, LOG_ERR, "Unknown logging method in flags: '%d'", tConfig->flags);
|
|
||||||
Log(lc, LOG_ERR, "This is a programmer error; please report it.");
|
|
||||||
exit = EXIT_FAILURE;
|
|
||||||
goto finish;
|
|
||||||
}
|
|
||||||
|
|
||||||
Log(lc, LOG_DEBUG, "Configuration:");
|
|
||||||
LogConfigIndent(lc);
|
|
||||||
Log(lc, LOG_DEBUG, "Listen On: %d", tConfig->listenPort);
|
|
||||||
Log(lc, LOG_DEBUG, "Server Name: %s", tConfig->serverName);
|
|
||||||
Log(lc, LOG_DEBUG, "Base URL: %s", tConfig->baseUrl);
|
|
||||||
Log(lc, LOG_DEBUG, "Identity Server: %s", tConfig->identityServer);
|
|
||||||
Log(lc, LOG_DEBUG, "Run As: %s:%s", tConfig->uid, tConfig->gid);
|
|
||||||
Log(lc, LOG_DEBUG, "Data Directory: %s", tConfig->dataDir);
|
|
||||||
Log(lc, LOG_DEBUG, "Threads: %d", tConfig->threads);
|
|
||||||
Log(lc, LOG_DEBUG, "Max Connections: %d", tConfig->maxConnections);
|
|
||||||
Log(lc, LOG_DEBUG, "Max Cache: %ld", tConfig->maxCache);
|
|
||||||
Log(lc, LOG_DEBUG, "Flags: %x", tConfig->flags);
|
|
||||||
LogConfigUnindent(lc);
|
|
||||||
|
|
||||||
/* Arguments to pass into the HTTP handler */
|
|
||||||
matrixArgs.lc = lc;
|
|
||||||
matrixArgs.config = tConfig;
|
|
||||||
|
|
||||||
/* Bind the socket before possibly dropping permissions */
|
|
||||||
httpServer = HttpServerCreate(tConfig->listenPort, tConfig->threads, tConfig->maxConnections,
|
|
||||||
MatrixHttpHandler, &matrixArgs);
|
|
||||||
if (!httpServer)
|
|
||||||
{
|
|
||||||
Log(lc, LOG_ERR, "Unable to create HTTP server on port %d: %s",
|
|
||||||
tConfig->listenPort, strerror(errno));
|
|
||||||
exit = EXIT_FAILURE;
|
|
||||||
goto finish;
|
|
||||||
}
|
|
||||||
|
|
||||||
Log(lc, LOG_DEBUG, "Running as uid:gid: %d:%d.", getuid(), getgid());
|
|
||||||
|
|
||||||
if (tConfig->uid && tConfig->gid)
|
|
||||||
{
|
|
||||||
userInfo = getpwnam(tConfig->uid);
|
|
||||||
groupInfo = getgrnam(tConfig->gid);
|
|
||||||
|
|
||||||
if (!userInfo || !groupInfo)
|
|
||||||
{
|
|
||||||
Log(lc, LOG_ERR, "Unable to locate the user/group specified in the configuration.");
|
|
||||||
exit = EXIT_FAILURE;
|
|
||||||
goto finish;
|
|
||||||
}
|
|
||||||
else
|
|
||||||
{
|
|
||||||
Log(lc, LOG_DEBUG, "Found user/group information using getpwnam() and getgrnam().");
|
|
||||||
}
|
|
||||||
}
|
|
||||||
else
|
|
||||||
{
|
|
||||||
Log(lc, LOG_DEBUG, "No user/group info specified in the config.");
|
|
||||||
}
|
|
||||||
|
|
||||||
if (getuid() == 0)
|
|
||||||
{
|
|
||||||
#ifndef __OpenBSD__ /* chroot() is only useful without
|
|
||||||
* unveil() */
|
|
||||||
if (chroot(".") == 0)
|
|
||||||
{
|
|
||||||
Log(lc, LOG_DEBUG, "Changed the root directory to: %s.", tConfig->dataDir);
|
|
||||||
}
|
|
||||||
else
|
|
||||||
{
|
|
||||||
Log(lc, LOG_WARNING, "Unable to chroot into directory: %s.", tConfig->dataDir);
|
|
||||||
}
|
|
||||||
#endif
|
|
||||||
|
|
||||||
if (userInfo && groupInfo)
|
|
||||||
{
|
|
||||||
if (setgid(groupInfo->gr_gid) != 0 || setuid(userInfo->pw_uid) != 0)
|
|
||||||
{
|
|
||||||
Log(lc, LOG_ERR, "Unable to set process uid/gid.");
|
|
||||||
exit = EXIT_FAILURE;
|
|
||||||
goto finish;
|
|
||||||
}
|
|
||||||
else
|
|
||||||
{
|
|
||||||
Log(lc, LOG_DEBUG, "Set uid/gid to %s:%s.", tConfig->uid, tConfig->gid);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
else
|
|
||||||
{
|
|
||||||
Log(lc, LOG_WARNING, "We are running as root, and we are not dropping to another user");
|
|
||||||
Log(lc, LOG_WARNING, "because none was specified in the configuration file.");
|
|
||||||
Log(lc, LOG_WARNING, "This is probably a security issue.");
|
|
||||||
}
|
|
||||||
}
|
|
||||||
else
|
|
||||||
{
|
|
||||||
Log(lc, LOG_WARNING, "Not setting root directory, because we are not root.");
|
|
||||||
|
|
||||||
if (tConfig->uid && tConfig->gid)
|
|
||||||
{
|
|
||||||
if (getuid() != userInfo->pw_uid || getgid() != groupInfo->gr_gid)
|
|
||||||
{
|
|
||||||
Log(lc, LOG_WARNING, "Not running as the uid/gid specified in the configuration.");
|
|
||||||
}
|
|
||||||
else
|
|
||||||
{
|
|
||||||
Log(lc, LOG_DEBUG, "Running as the uid/gid specified in the configuration.");
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
/* These config values are no longer needed; don't hold them in
|
|
||||||
* memory anymore */
|
|
||||||
Free(tConfig->dataDir);
|
|
||||||
Free(tConfig->uid);
|
|
||||||
Free(tConfig->gid);
|
|
||||||
|
|
||||||
tConfig->dataDir = NULL;
|
|
||||||
tConfig->uid = NULL;
|
|
||||||
tConfig->gid = NULL;
|
|
||||||
|
|
||||||
|
|
||||||
if (!tConfig->maxCache)
|
|
||||||
{
|
|
||||||
Log(lc, LOG_WARNING, "Database caching is disabled.");
|
|
||||||
Log(lc, LOG_WARNING,
|
|
||||||
"If this is not what you intended, check the config file");
|
|
||||||
Log(lc, LOG_WARNING,
|
|
||||||
"and ensure that maxCache is a valid number of bytes.");
|
|
||||||
}
|
|
||||||
|
|
||||||
matrixArgs.db = DbOpen(".", tConfig->maxCache);
|
|
||||||
|
|
||||||
if (!matrixArgs.db)
|
|
||||||
{
|
|
||||||
Log(lc, LOG_ERR, "Unable to open data directory as a database.");
|
|
||||||
exit = EXIT_FAILURE;
|
|
||||||
goto finish;
|
|
||||||
}
|
|
||||||
|
|
||||||
cron = CronCreate(60 * 1000); /* 1-minute tick */
|
|
||||||
if (!cron)
|
|
||||||
{
|
|
||||||
Log(lc, LOG_ERR, "Unable to set up job scheduler.");
|
|
||||||
exit = EXIT_FAILURE;
|
|
||||||
goto finish;
|
|
||||||
}
|
|
||||||
|
|
||||||
Log(lc, LOG_DEBUG, "Registering jobs...");
|
|
||||||
|
|
||||||
CronEvery(cron, 30 * 60 * 1000, (JobFunc *) UiaCleanup, &matrixArgs);
|
|
||||||
|
|
||||||
Log(lc, LOG_NOTICE, "Starting job scheduler...");
|
|
||||||
CronStart(cron);
|
|
||||||
|
|
||||||
Log(lc, LOG_NOTICE, "Starting server...");
|
|
||||||
|
|
||||||
if (!HttpServerStart(httpServer))
|
|
||||||
{
|
|
||||||
Log(lc, LOG_ERR, "Unable to start HTTP server.");
|
|
||||||
exit = EXIT_FAILURE;
|
|
||||||
goto finish;
|
|
||||||
}
|
|
||||||
|
|
||||||
Log(lc, LOG_INFO, "Listening on port: %d", tConfig->listenPort);
|
|
||||||
|
|
||||||
sigAction.sa_handler = TelodendriaSignalHandler;
|
|
||||||
sigfillset(&sigAction.sa_mask);
|
|
||||||
sigAction.sa_flags = SA_RESTART;
|
|
||||||
|
|
||||||
if (sigaction(SIGINT, &sigAction, NULL) < 0)
|
|
||||||
{
|
|
||||||
Log(lc, LOG_ERR, "Unable to install signal handler.");
|
|
||||||
exit = EXIT_FAILURE;
|
|
||||||
goto finish;
|
|
||||||
}
|
|
||||||
|
|
||||||
/* Block this thread until the server is terminated by a signal
|
|
||||||
* handler */
|
|
||||||
HttpServerJoin(httpServer);
|
|
||||||
|
|
||||||
finish:
|
|
||||||
Log(lc, LOG_NOTICE, "Shutting down...");
|
|
||||||
if (httpServer)
|
|
||||||
{
|
|
||||||
HttpServerFree(httpServer);
|
|
||||||
Log(lc, LOG_DEBUG, "Freed HTTP Server.");
|
|
||||||
}
|
|
||||||
|
|
||||||
if (cron)
|
|
||||||
{
|
|
||||||
CronStop(cron);
|
|
||||||
CronFree(cron);
|
|
||||||
Log(lc, LOG_DEBUG, "Stopped and freed job scheduler.");
|
|
||||||
}
|
|
||||||
|
|
||||||
/*
|
|
||||||
* If we're not logging to standard output, then we can close it. Otherwise,
|
|
||||||
* if we are logging to stdout, LogConfigFree() will close it for us.
|
|
||||||
*/
|
|
||||||
if (!tConfig || !(tConfig->flags & TELODENDRIA_LOG_STDOUT))
|
|
||||||
{
|
|
||||||
fclose(stdout);
|
|
||||||
}
|
|
||||||
|
|
||||||
DbClose(matrixArgs.db);
|
|
||||||
|
|
||||||
LogConfigTimeStampFormatSet(lc, NULL);
|
|
||||||
TelodendriaConfigFree(tConfig);
|
|
||||||
|
|
||||||
Log(lc, LOG_DEBUG, "");
|
|
||||||
MemoryIterate(TelodendriaMemoryIterator, lc);
|
|
||||||
Log(lc, LOG_DEBUG, "");
|
|
||||||
|
|
||||||
Log(lc, LOG_DEBUG, "Exiting with code '%d'.", exit);
|
|
||||||
LogConfigFree(lc);
|
|
||||||
|
|
||||||
MemoryFreeAll();
|
|
||||||
|
|
||||||
fclose(stderr);
|
|
||||||
return exit;
|
|
||||||
}
|
|
||||||
|
|
|
||||||
|
|
@ -24,6 +24,9 @@
|
||||||
#ifndef TELODENDRIA_H
|
#ifndef TELODENDRIA_H
|
||||||
#define TELODENDRIA_H
|
#define TELODENDRIA_H
|
||||||
|
|
||||||
|
#include <Memory.h>
|
||||||
|
#include <Log.h>
|
||||||
|
|
||||||
#define TELODENDRIA_LOGO_WIDTH 56
|
#define TELODENDRIA_LOGO_WIDTH 56
|
||||||
#define TELODENDRIA_LOGO_HEIGHT 22
|
#define TELODENDRIA_LOGO_HEIGHT 22
|
||||||
|
|
||||||
|
|
@ -36,4 +39,15 @@ extern const char
|
||||||
extern const char
|
extern const char
|
||||||
TelodendriaHeader[TELODENDRIA_HEADER_HEIGHT][TELODENDRIA_HEADER_WIDTH];
|
TelodendriaHeader[TELODENDRIA_HEADER_HEIGHT][TELODENDRIA_HEADER_WIDTH];
|
||||||
|
|
||||||
|
extern void
|
||||||
|
TelodendriaHexDump(size_t, char *, char *, void *);
|
||||||
|
|
||||||
|
extern void
|
||||||
|
TelodendriaMemoryHook(MemoryAction, MemoryInfo *, void *);
|
||||||
|
|
||||||
|
extern void
|
||||||
|
TelodendriaMemoryIterator(MemoryInfo *, void *);
|
||||||
|
|
||||||
|
extern void
|
||||||
|
TelodendriaPrintHeader(LogConfig *lc);
|
||||||
#endif
|
#endif
|
||||||
|
|
|
||||||
|
|
@ -35,7 +35,7 @@
|
||||||
CFLAGS="${CFLAGS} ${DEFINES} ${INCLUDES}"
|
CFLAGS="${CFLAGS} ${DEFINES} ${INCLUDES}"
|
||||||
LDFLAGS="${LDFLAGS} ${STATIC}"
|
LDFLAGS="${LDFLAGS} ${STATIC}"
|
||||||
|
|
||||||
MAIN="Telodendria"
|
MAIN="Main"
|
||||||
|
|
||||||
if [ "$DEBUG" = "1" ]; then
|
if [ "$DEBUG" = "1" ]; then
|
||||||
CFLAGS="$CFLAGS -O0 -g -pg"
|
CFLAGS="$CFLAGS -O0 -g -pg"
|
||||||
|
|
|
||||||
|
|
@ -98,7 +98,7 @@ main(int argc, char **argv)
|
||||||
*val = '\0';
|
*val = '\0';
|
||||||
val++;
|
val++;
|
||||||
|
|
||||||
while (*val && isspace(*val))
|
while (*val && isspace((unsigned char) *val))
|
||||||
{
|
{
|
||||||
val++;
|
val++;
|
||||||
}
|
}
|
||||||
|
|
|
||||||
Loading…
Reference in a new issue