X-Git-Url: http://mj.ucw.cz/gitweb/?a=blobdiff_plain;ds=inline;f=lib%2Fpartmap.c;h=2b70f1d916f6e16e0235687f0f51007aac44f849;hb=580fd9c443c2a4faba5a703d49f366de5d3968c9;hp=7a31de28c33ebf94f964fdb1dee814178f62bb6d;hpb=e1642f1c4125567b5b3054701a085b0a2ec94f9b;p=libucw.git diff --git a/lib/partmap.c b/lib/partmap.c index 7a31de28..2b70f1d9 100644 --- a/lib/partmap.c +++ b/lib/partmap.c @@ -1,8 +1,8 @@ /* * UCW Library -- Mapping of File Parts * - * (c) 2003 Martin Mares - * (c) 2003 Robert Spalek + * (c) 2003--2006 Martin Mares + * (c) 2003--2005 Robert Spalek * * This software may be freely distributed and used according to the terms * of the GNU Lesser General Public License. @@ -10,6 +10,7 @@ #include "lib/lib.h" #include "lib/lfs.h" +#include "lib/partmap.h" #include #include @@ -17,24 +18,19 @@ #include #include #include -#include - -struct partmap { - int fd; - sh_off_t file_size; - sh_off_t start_off, end_off; - byte *start_map; - int writeable; -}; +#ifdef CONFIG_PARTMAP_IS_MMAP +#define PARTMAP_WINDOW ~(size_t)0 +#else #ifdef TEST #define PARTMAP_WINDOW 4096 #else #define PARTMAP_WINDOW 16777216 #endif +#endif struct partmap * -partmap_open(byte *name, int writeable) +partmap_open(char *name, int writeable) { struct partmap *p = xmalloc_zero(sizeof(struct partmap)); @@ -44,6 +40,9 @@ partmap_open(byte *name, int writeable) if ((p->file_size = sh_seek(p->fd, 0, SEEK_END)) < 0) die("lseek(%s): %m", name); p->writeable = writeable; +#ifdef CONFIG_PARTMAP_IS_MMAP + partmap_load(p, 0, p->file_size); +#endif return p; } @@ -62,27 +61,24 @@ partmap_close(struct partmap *p) xfree(p); } -void * -partmap_map(struct partmap *p, sh_off_t start, uns size) +void +partmap_load(struct partmap *p, sh_off_t start, uns size) { - if (!p->start_map || start < p->start_off || (sh_off_t) (start+size) > p->end_off) - { - if (p->start_map) - munmap(p->start_map, p->end_off - p->start_off); - sh_off_t end = start + size; - sh_off_t win_start = start/PAGE_SIZE * PAGE_SIZE; - uns win_len = PARTMAP_WINDOW; - if ((sh_off_t) (win_start+win_len) > p->file_size) - win_len = ALIGN(p->file_size - win_start, PAGE_SIZE); - if ((sh_off_t) (win_start+win_len) < end) - die("partmap_map: Window is too small for mapping %d bytes", size); - p->start_map = sh_mmap(NULL, win_len, p->writeable ? (PROT_READ | PROT_WRITE) : PROT_READ, MAP_SHARED, p->fd, win_start); - if (p->start_map == MAP_FAILED) - die("mmap failed at position %Ld: %m", (long long)win_start); - p->start_off = win_start; - p->end_off = win_start+win_len; - } - return p->start_map + (start - p->start_off); + if (p->start_map) + munmap(p->start_map, p->end_off - p->start_off); + sh_off_t end = start + size; + sh_off_t win_start = start/CPU_PAGE_SIZE * CPU_PAGE_SIZE; + size_t win_len = PARTMAP_WINDOW; + if ((sh_off_t) (win_start+win_len) > p->file_size) + win_len = ALIGN_TO(p->file_size - win_start, CPU_PAGE_SIZE); + if ((sh_off_t) (win_start+win_len) < end) + die("partmap_map: Window is too small for mapping %d bytes", size); + p->start_map = sh_mmap(NULL, win_len, p->writeable ? (PROT_READ | PROT_WRITE) : PROT_READ, MAP_SHARED, p->fd, win_start); + if (p->start_map == MAP_FAILED) + die("mmap failed at position %lld: %m", (long long)win_start); + p->start_off = win_start; + p->end_off = win_start+win_len; + madvise(p->start_map, win_len, MADV_SEQUENTIAL); } #ifdef TEST