X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/7da2926d0733ff0683f31aeea176ce71e127264f..51c23076e2b42ff07dc167dea1cb0e3a4ab3cf68:/src/xbt/xbt_log_appender_file.c diff --git a/src/xbt/xbt_log_appender_file.c b/src/xbt/xbt_log_appender_file.c index 53427762ef..97f6586dbf 100644 --- a/src/xbt/xbt_log_appender_file.c +++ b/src/xbt/xbt_log_appender_file.c @@ -1,52 +1,39 @@ /* file_appender - a dumb log appender which simply prints to a file */ -/* Copyright (c) 2007-2014. The SimGrid Team. +/* Copyright (c) 2007-2018. The SimGrid Team. * All rights reserved. */ /* This program is free software; you can redistribute it and/or modify it * under the terms of the license (GNU LGPL) which comes with this package. */ +#include "src/internal_config.h" +#include "src/xbt/log_private.h" #include "xbt/sysdep.h" -#include "xbt/log_private.h" -#ifdef HAVE_SMPI -#include "smpi/private.h" // to access bench_begin/end. Not ultraclean, I confess -#endif +#include #include +#include static void append_file(xbt_log_appender_t this_, char *str) { fputs(str, (FILE *) this_->data); } -static void smpi_append_file(xbt_log_appender_t this_, char *str) { - fputs(str, (FILE *) this_->data); -} - static void free_(xbt_log_appender_t this_) { if (this_->data != stderr) fclose(this_->data); } -#ifdef HAVE_SMPI -void __smpi_bench_dont (void); // Stupid prototype -void __smpi_bench_dont (void) { /* I'm only a place-holder in case we link without SMPI */; } -void smpi_bench_begin(void) __attribute__ ((weak, alias ("__smpi_bench_dont"))); -void smpi_bench_end(void) __attribute__ ((weak, alias ("__smpi_bench_dont"))); -#endif - -XBT_LOG_EXTERNAL_CATEGORY(smpi); // To detect if SMPI is inited - xbt_log_appender_t xbt_log_appender_file_new(char *arg) { xbt_log_appender_t res = xbt_new0(s_xbt_log_appender_t, 1); - if (_XBT_LOGV(smpi).initialized) // HACK to detect if we run in SMPI mode. Relies on MAIN__ source disposition - res->do_append = smpi_append_file; - else - res->do_append = append_file; - res->free_ = free_; - if (arg) + res->do_append = &append_file; + res->free_ = &free_; + if (arg) { res->data = (void *) fopen(arg, "w"); - else + if (res->data == NULL) + xbt_die("Cannot open file: %s: %s", arg, strerror(errno)); + } else { res->data = (void *) stderr; + } return res; } @@ -62,18 +49,17 @@ typedef struct xbt_log_append2_file_s* xbt_log_append2_file_t; #define APPEND2_END_TOKEN_CLEAR "\n " static void open_append2_file(xbt_log_append2_file_t data){ - if(data->count<0) - { + if(data->count<0) { //Roll - if(!data->file) + if (!data->file) { data->file= fopen(data->filename, "w"); - else{ + if (data->file == NULL) + xbt_die("Cannot open file: %s: %s", data->filename, strerror(errno)); + } else { fputs(APPEND2_END_TOKEN_CLEAR,data->file); fseek(data->file,0,SEEK_SET); } - } - else{ - //printf("Splitting\n"); + } else{ //Split if(data->file) fclose(data->file); @@ -87,36 +73,32 @@ static void open_append2_file(xbt_log_append2_file_t data){ snprintf(newname,511,"%s%i%s",pre,data->count,post); data->count++; data->file= fopen(newname, "w"); - xbt_assert(data->file); - + if (data->file == NULL) + xbt_die("Cannot open file: %s: %s", newname, strerror(errno)); + xbt_free(pre); } } - - - static void append2_file(xbt_log_appender_t this_, char *str) { xbt_log_append2_file_t d=(xbt_log_append2_file_t) this_->data; xbt_assert(d->file); - if(ftell(d->file)>=d->limit) - { + if(ftell(d->file)>=d->limit) { open_append2_file(d); } fputs(str, d->file); if(d->count<0){ - fputs(APPEND2_END_TOKEN,d->file); - fseek(d->file,-((signed long)strlen(APPEND2_END_TOKEN)),SEEK_CUR); + fputs(APPEND2_END_TOKEN,d->file); + fseek(d->file,-((signed long)strlen(APPEND2_END_TOKEN)),SEEK_CUR); } } -static void smpi_append2_file(xbt_log_appender_t this_, char *str) { - append2_file(this_,str); -} - -static void free_append2_(xbt_log_appender_t this_) { - FILE* f=((xbt_log_append2_file_t)(this_->data))->file; - if (f) - fclose(f); +static void free_append2_(xbt_log_appender_t this_) +{ + xbt_log_append2_file_t data = this_->data; + if (data->file) + fclose(data->file); + xbt_free(data->filename); + xbt_free(data); } @@ -125,12 +107,9 @@ static void free_append2_(xbt_log_appender_t this_) { //For split, replace % in the file by the current count xbt_log_appender_t xbt_log_appender2_file_new(char *arg,int roll) { - xbt_log_appender_t res = xbt_new0(s_xbt_log_appender_t, 1); - if (_XBT_LOGV(smpi).initialized) // HACK to detect if we run in SMPI mode. Relies on MAIN__ source disposition - res->do_append = smpi_append2_file; - else - res->do_append = append2_file; - res->free_ = free_append2_; + xbt_log_appender_t res = xbt_new0(s_xbt_log_appender_t, 1); + res->do_append = &append2_file; + res->free_ = &free_append2_; xbt_log_append2_file_t data = xbt_new0(struct xbt_log_append2_file_s, 1); xbt_assert(arg); char* buf=xbt_strdup(arg); @@ -138,13 +117,15 @@ xbt_log_appender_t xbt_log_appender2_file_new(char *arg,int roll) { xbt_assert(sep>0); data->filename=xbt_strdup(sep+1); *sep='\0'; - data->limit=atol(buf); + char *endptr; + data->limit=strtol(buf,&endptr,10); + xbt_assert(endptr[0]=='\0', "Invalid buffer size: %s", buf); + xbt_free(buf); if(roll) data->count=-1; else data->count=0; - open_append2_file(data); + open_append2_file(data); res->data = data; return res; } -