X-Git-Url: https://git.verplant.org/?a=blobdiff_plain;f=src%2Frrd_open.c;h=a01b07543a88878556e21097b4c1c6985e0f6c69;hb=271be77064640b1daa3408885d60b8bead1126ad;hp=e83918454cad9e3bee9ac37b819ca6e5ce401cdc;hpb=b9c1a336b13d8093b9841848cbed687a6e01a5c3;p=rrdtool.git diff --git a/src/rrd_open.c b/src/rrd_open.c index e839184..a01b075 100644 --- a/src/rrd_open.c +++ b/src/rrd_open.c @@ -4,62 +4,6 @@ * rrd_open.c Open an RRD File ***************************************************************************** * $Id$ - * $Log$ - * Revision 1.10 2004/05/26 22:11:12 oetiker - * reduce compiler warnings. Many small fixes. -- Mike Slifcak - * - * Revision 1.9 2003/04/29 21:56:49 oetiker - * readline in rrd_open.c reads the file in 8 KB blocks, and calls realloc for - * each block. realloc is very slow in Mac OS X for huge blocks, e.g. when - * restoring databases from huge xml files. This patch finds the size of the - * file, and starts out with malloc'ing the full size. - * -- Peter Speck - * - * Revision 1.8 2003/04/11 19:43:44 oetiker - * New special value COUNT which allows calculations based on the position of a - * value within a data set. Bug fix in rrd_rpncalc.c. PREV returned erroneus - * value for the second value. Bug fix in rrd_restore.c. Bug causing seek error - * when accesing an RRD restored from an xml that holds an RRD version <3. - * -- Ruben Justo - * - * Revision 1.7 2003/03/31 21:22:12 oetiker - * enables RRDtool updates with microsecond or in case of windows millisecond - * precision. This is needed to reduce time measurement error when archive step - * is small. (<30s) -- Sasha Mikheev - * - * Revision 1.6 2003/02/13 07:05:27 oetiker - * Find attached the patch I promised to send to you. Please note that there - * are three new source files (src/rrd_is_thread_safe.h, src/rrd_thread_safe.c - * and src/rrd_not_thread_safe.c) and the introduction of librrd_th. This - * library is identical to librrd, but it contains support code for per-thread - * global variables currently used for error information only. This is similar - * to how errno per-thread variables are implemented. librrd_th must be linked - * alongside of libpthred - * - * There is also a new file "THREADS", holding some documentation. - * - * -- Peter Stamfest - * - * Revision 1.5 2002/06/20 00:21:03 jake - * More Win32 build changes; thanks to Kerry Calvert. - * - * Revision 1.4 2002/02/01 20:34:49 oetiker - * fixed version number and date/time - * - * Revision 1.3 2001/03/04 13:01:55 oetiker - * Aberrant Behavior Detection support. A brief overview added to rrdtool.pod. - * Major updates to rrd_update.c, rrd_create.c. Minor update to other core files. - * This is backwards compatible! But new files using the Aberrant stuff are not readable - * by old rrdtool versions. See http://cricket.sourceforge.net/aberrant/rrd_hw.htm - * -- Jake Brutlag - * - * Revision 1.2 2001/03/04 10:29:20 oetiker - * fixed filedescriptor leak - * -- Mike Franusich - * - * Revision 1.1.1.1 2001/02/25 22:25:05 oetiker - * checkin - * *****************************************************************************/ #include "rrd_tool.h" @@ -145,8 +89,12 @@ rrd_file_t *rrd_open( rrd_file_t *rrd_file = NULL; off_t newfile_size = 0; - if (rdwr & RRD_CREAT) - newfile_size = (off_t) rrd->stat_head; + if (rdwr & RRD_CREAT) { + /* yes bad inline signaling alert, we are using the + floatcookie to pass the size in ... only used in resize */ + newfile_size = (off_t) rrd->stat_head->float_cookie; + free(rrd->stat_head); + } rrd_init(rrd); rrd_file = malloc(sizeof(rrd_file_t)); if (rrd_file == NULL) { @@ -189,7 +137,6 @@ rrd_file_t *rrd_open( mm_flags |= MAP_POPULATE; /* populate ptes and data */ #endif #if defined MAP_NONBLOCK -// if (!(rdwr & RRD_COPY)) mm_flags |= MAP_NONBLOCK; /* just populate ptes */ #endif #ifdef USE_DIRECT_IO @@ -217,7 +164,7 @@ rrd_file_t *rrd_open( } else { rrd_file->file_len = newfile_size; lseek(rrd_file->fd, newfile_size - 1, SEEK_SET); - write(rrd_file->fd, "\0", 1); /* poke */ + write(rrd_file->fd, "\0", 1); /* poke */ lseek(rrd_file->fd, 0, SEEK_SET); } #ifdef HAVE_POSIX_FADVISE @@ -257,6 +204,8 @@ rrd_file_t *rrd_open( goto out_done; } #endif + if (rdwr & RRD_CREAT) + goto out_done; #ifdef USE_MADVISE if (rdwr & RRD_COPY) { /* We will read everything in a moment (copying) */ @@ -356,9 +305,7 @@ rrd_file_t *rrd_open( rrd_file->header_len = offset; rrd_file->pos = offset; -#ifdef USE_MADVISE out_done: -#endif return (rrd_file); out_nullify_head: rrd->stat_head = NULL; @@ -487,23 +434,24 @@ inline ssize_t rrd_read( size_t count) { #ifdef HAVE_MMAP - size_t _cnt = count; - ssize_t _surplus = rrd_file->pos + _cnt - rrd_file->file_len; + size_t _cnt = count; + ssize_t _surplus = rrd_file->pos + _cnt - rrd_file->file_len; + if (_surplus > 0) { /* short read */ _cnt -= _surplus; } if (_cnt == 0) - return 0; /* EOF */ + return 0; /* EOF */ buf = memcpy(buf, rrd_file->file_start + rrd_file->pos, _cnt); - rrd_file->pos += _cnt; /* mimmic read() semantics */ + rrd_file->pos += _cnt; /* mimmic read() semantics */ return _cnt; #else ssize_t ret; ret = read(rrd_file->fd, buf, count); if (ret > 0) - rrd_file->pos += ret; /* mimmic read() semantics */ + rrd_file->pos += ret; /* mimmic read() semantics */ return ret; #endif } @@ -571,8 +519,7 @@ inline void rrd_free( void rrd_free( rrd_t *rrd) { - if (atoi(rrd->stat_head->version) < 3) - free(rrd->live_head); + free(rrd->live_head); free(rrd->stat_head); free(rrd->ds_def); free(rrd->rra_def);