| 36 |
|
error(CONSISTENCY, "bad RDSextend in RdataShareMap()"); |
| 37 |
|
return; |
| 38 |
|
} |
| 39 |
< |
int mmprot = PROT_NONE; |
| 40 |
< |
int oflags = 0; |
| 39 |
> |
int oflags, mmprot; |
| 40 |
|
switch (flags & (RDSread|RDSwrite)) { |
| 41 |
|
case RDSread|RDSwrite: |
| 42 |
< |
mmprot |= PROT_READ|PROT_WRITE; |
| 43 |
< |
oflags |= O_RDWR; |
| 42 |
> |
mmprot = PROT_READ|PROT_WRITE; |
| 43 |
> |
oflags = O_RDWR|O_CREAT; |
| 44 |
|
break; |
| 46 |
– |
case RDSread: |
| 47 |
– |
mmprot |= PROT_READ; |
| 48 |
– |
oflags |= O_RDONLY; |
| 49 |
– |
break; |
| 45 |
|
case RDSwrite: |
| 46 |
< |
mmprot |= PROT_WRITE; |
| 47 |
< |
oflags |= O_WRONLY; |
| 46 |
> |
mmprot = PROT_WRITE; |
| 47 |
> |
oflags = O_RDWR|O_CREAT; // XXX system limitation |
| 48 |
|
break; |
| 49 |
+ |
case RDSread: |
| 50 |
+ |
mmprot = PROT_READ; |
| 51 |
+ |
oflags = O_RDONLY; |
| 52 |
+ |
break; |
| 53 |
|
} |
| 54 |
|
int fd = -1; |
| 55 |
|
if (name) { // opening a shared file |
| 56 |
< |
if (flags & RDSexcl) oflags |= O_CREAT|O_EXCL; |
| 56 |
> |
if (flags & RDSexcl) oflags |= O_EXCL; |
| 57 |
|
else if (flags & RDSextend && !siz) oflags |= O_TRUNC; |
| 58 |
|
fd = open(name, oflags, 0666); |
| 59 |
|
if (fd < 0) { |
| 80 |
|
return; |
| 81 |
|
} |
| 82 |
|
} |
| 83 |
< |
mmorg = (void *)mmap(NULL, siz, mmprot, |
| 83 |
> |
if (siz) mmorg = (void *)mmap(NULL, siz, mmprot, |
| 84 |
|
MAP_SHARED|(name ? MAP_FILE : MAP_ANON), fd, 0); |
| 85 |
|
close(fd); |
| 86 |
|
if (mmorg == MAP_FAILED) { |
| 107 |
|
size_t |
| 108 |
|
RdataShareMap::Resize(size_t new_siz) |
| 109 |
|
{ |
| 111 |
– |
if (!mmorg) |
| 112 |
– |
return 0; |
| 110 |
|
if (new_siz > 0) { |
| 111 |
|
if (new_siz == osiz) |
| 112 |
|
return osiz; |
| 153 |
|
close(fd); |
| 154 |
|
return 0; |
| 155 |
|
} |
| 156 |
< |
munmap(mmorg, osiz); |
| 156 |
> |
if (mmorg) munmap(mmorg, osiz); |
| 157 |
|
mmorg = mmap(NULL, new_siz, |
| 158 |
|
mode&RDSread ? PROT_READ|PROT_WRITE : PROT_WRITE, |
| 159 |
|
MAP_SHARED|MAP_FILE, fd, 0); |