|
|
| version 1.1.2.1, 2011/11/23 08:50:38 | version 1.4, 2012/07/03 12:46:00 |
|---|---|
| Line 1 | Line 1 |
| /************************************************************************* | |
| * (C) 2011 AITNET ltd - Sofia/Bulgaria - <misho@aitbg.com> | |
| * by Michael Pounov <misho@openbsd-bg.org> | |
| * | |
| * $Author$ | |
| * $Id$ | |
| * | |
| ************************************************************************** | |
| The ELWIX and AITNET software is distributed under the following | |
| terms: | |
| All of the documentation and software included in the ELWIX and AITNET | |
| Releases is copyrighted by ELWIX - Sofia/Bulgaria <info@elwix.org> | |
| Copyright 2004, 2005, 2006, 2007, 2008, 2009, 2010, 2011, 2012 | |
| by Michael Pounov <misho@elwix.org>. All rights reserved. | |
| Redistribution and use in source and binary forms, with or without | |
| modification, are permitted provided that the following conditions | |
| are met: | |
| 1. Redistributions of source code must retain the above copyright | |
| notice, this list of conditions and the following disclaimer. | |
| 2. Redistributions in binary form must reproduce the above copyright | |
| notice, this list of conditions and the following disclaimer in the | |
| documentation and/or other materials provided with the distribution. | |
| 3. All advertising materials mentioning features or use of this software | |
| must display the following acknowledgement: | |
| This product includes software developed by Michael Pounov <misho@elwix.org> | |
| ELWIX - Embedded LightWeight unIX and its contributors. | |
| 4. Neither the name of AITNET nor the names of its contributors | |
| may be used to endorse or promote products derived from this software | |
| without specific prior written permission. | |
| THIS SOFTWARE IS PROVIDED BY AITNET AND CONTRIBUTORS ``AS IS'' AND | |
| ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE | |
| IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE | |
| ARE DISCLAIMED. IN NO EVENT SHALL THE REGENTS OR CONTRIBUTORS BE LIABLE | |
| FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL | |
| DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS | |
| OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) | |
| HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT | |
| LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY | |
| OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF | |
| SUCH DAMAGE. | |
| */ | |
| #include "global.h" | #include "global.h" |
| extern char *__progname; | |
| /* | |
| * mqtt_rtlm_log() Log message | |
| * | |
| * @fmt = format string | |
| * @... = argument list | |
| * return: none | |
| */ | |
| static void | |
| mqtt_rtlm_log(const char *fmt, ...) | |
| { | |
| va_list lst; | |
| va_start(lst, fmt); | |
| vsyslog(LOG_ERR, fmt, lst); | |
| va_end(lst); | |
| } | |
| #define MQTT_RTLM_LOG() (mqtt_rtlm_log("Error:: System #%d - %s", errno, strerror(errno))) | |
| /* | |
| * mqtt_rtlm_open() Open log file | |
| * | |
| * @cfg = loaded config | |
| * return: NULL error or SQL handle | |
| */ | |
| FILE * | |
| mqtt_rtlm_open(cfg_root_t *cfg) | |
| { | |
| FILE *f = NULL; | |
| const char *str = NULL; | |
| if (!cfg) | |
| return NULL; | |
| str = cfg_getAttribute(cfg, "mqtt_log", "name"); | |
| if (!str) { | |
| mqtt_rtlm_log("Error:: Unknown file name ...\n"); | |
| return NULL; | |
| } | |
| if (!(f = fopen(str, "a"))) { | |
| MQTT_RTLM_LOG(); | |
| return NULL; | |
| } | |
| return f; | |
| } | |
| /* | |
| * mqtt_rtlm_close() Close log file | |
| * | |
| * @f = File handle | |
| * return: none | |
| */ | |
| void | |
| mqtt_rtlm_close(FILE *f) | |
| { | |
| if (f) | |
| fclose(f); | |
| } | |
| /* | |
| * mqtt_rtlm_logger() Logger to file | |
| * | |
| * @f = File handle | |
| * @fmt = Message format | |
| * @... = argument list | |
| * return: -1 error or >-1 logged successful | |
| */ | |
| int | |
| mqtt_rtlm_logger(FILE *f, const char *fmt, ...) | |
| { | |
| va_list lst; | |
| int ret = 0; | |
| char szStr[STRSIZ] = { 0 }, szFmt[BUFSIZ] = { 0 }; | |
| struct tm *tm; | |
| time_t tim; | |
| if (!f || !fmt) | |
| return -1; | |
| tim = time(NULL); | |
| tm = localtime(&tim); | |
| strftime(szFmt, sizeof szFmt, "[%Y-%m-%d %H:%M:%S] ", tm); | |
| snprintf(szStr, sizeof szStr, "%s (%d):: ", __progname, getpid()); | |
| strlcat(szFmt, szStr, sizeof szFmt); | |
| strlcat(szFmt, fmt, sizeof szFmt); | |
| va_start(lst, fmt); | |
| ret = vfprintf(f, szFmt, lst); | |
| va_end(lst); | |
| fflush(f); | |
| return ret; | |
| } |