]> git.saurik.com Git - apt.git/blame - apt-pkg/contrib/mmap.cc
Ensure the memory buffer is 0'd
[apt.git] / apt-pkg / contrib / mmap.cc
CommitLineData
578bfd0a
AL
1// -*- mode: cpp; mode: fold -*-
2// Description /*{{{*/
0db4a45b 3// $Id: mmap.cc,v 1.22 2001/05/27 05:19:30 jgg Exp $
578bfd0a
AL
4/* ######################################################################
5
6 MMap Class - Provides 'real' mmap or a faked mmap using read().
7
8 MMap cover class.
9
10 Some broken versions of glibc2 (libc6) have a broken definition
11 of mmap that accepts a char * -- all other systems (and libc5) use
12 void *. We can't safely do anything here that would be portable, so
13 libc6 generates warnings -- which should be errors, g++ isn't properly
14 strict.
15
16 The configure test notes that some OS's have broken private mmap's
17 so on those OS's we can't use mmap. This means we have to use
18 configure to test mmap and can't rely on the POSIX
19 _POSIX_MAPPED_FILES test.
20
21 ##################################################################### */
22 /*}}}*/
23// Include Files /*{{{*/
6c139d6e 24#ifdef __GNUG__
094a497d 25#pragma implementation "apt-pkg/mmap.h"
6c139d6e
AL
26#endif
27
578bfd0a 28#define _BSD_SOURCE
094a497d
AL
29#include <apt-pkg/mmap.h>
30#include <apt-pkg/error.h>
578bfd0a 31
b2e465d6
AL
32#include <apti18n.h>
33
578bfd0a
AL
34#include <sys/mman.h>
35#include <sys/stat.h>
578bfd0a
AL
36#include <unistd.h>
37#include <fcntl.h>
38 /*}}}*/
39
40// MMap::MMap - Constructor /*{{{*/
41// ---------------------------------------------------------------------
42/* */
2d11135a 43MMap::MMap(FileFd &F,unsigned long Flags) : Flags(Flags), iSize(0),
578bfd0a
AL
44 Base(0)
45{
46 if ((Flags & NoImmMap) != NoImmMap)
2d11135a
AL
47 Map(F);
48}
49 /*}}}*/
50// MMap::MMap - Constructor /*{{{*/
51// ---------------------------------------------------------------------
52/* */
53MMap::MMap(unsigned long Flags) : Flags(Flags), iSize(0),
54 Base(0)
55{
578bfd0a
AL
56}
57 /*}}}*/
58// MMap::~MMap - Destructor /*{{{*/
59// ---------------------------------------------------------------------
60/* */
61MMap::~MMap()
62{
2d11135a 63 Close();
578bfd0a
AL
64}
65 /*}}}*/
66// MMap::Map - Perform the mapping /*{{{*/
67// ---------------------------------------------------------------------
68/* */
2d11135a 69bool MMap::Map(FileFd &Fd)
578bfd0a
AL
70{
71 iSize = Fd.Size();
72
73 // Set the permissions.
74 int Prot = PROT_READ;
75 int Map = MAP_SHARED;
76 if ((Flags & ReadOnly) != ReadOnly)
77 Prot |= PROT_WRITE;
78 if ((Flags & Public) != Public)
79 Map = MAP_PRIVATE;
80
b35d2f5f 81 if (iSize == 0)
b2e465d6 82 return _error->Error(_("Can't mmap an empty file"));
b35d2f5f 83
578bfd0a
AL
84 // Map it.
85 Base = mmap(0,iSize,Prot,Map,Fd.Fd(),0);
86 if (Base == (void *)-1)
b2e465d6 87 return _error->Errno("mmap",_("Couldn't make mmap of %lu bytes"),iSize);
578bfd0a
AL
88
89 return true;
90}
91 /*}}}*/
92// MMap::Close - Close the map /*{{{*/
93// ---------------------------------------------------------------------
94/* */
2d11135a 95bool MMap::Close(bool DoSync)
578bfd0a 96{
2d11135a 97 if ((Flags & UnMapped) == UnMapped || Base == 0 || iSize == 0)
578bfd0a 98 return true;
2d11135a 99
1164783d
AL
100 if (DoSync == true)
101 Sync();
578bfd0a
AL
102
103 if (munmap((char *)Base,iSize) != 0)
104 _error->Warning("Unable to munmap");
105
106 iSize = 0;
b2e465d6 107 Base = 0;
578bfd0a
AL
108 return true;
109}
110 /*}}}*/
111// MMap::Sync - Syncronize the map with the disk /*{{{*/
112// ---------------------------------------------------------------------
0149949b
AL
113/* This is done in syncronous mode - the docs indicate that this will
114 not return till all IO is complete */
578bfd0a
AL
115bool MMap::Sync()
116{
2d11135a
AL
117 if ((Flags & UnMapped) == UnMapped)
118 return true;
119
de3c15ea 120#ifdef _POSIX_SYNCHRONIZED_IO
1164783d 121 if ((Flags & ReadOnly) != ReadOnly)
578bfd0a 122 if (msync((char *)Base,iSize,MS_SYNC) != 0)
4b1b89c5 123 return _error->Errno("msync","Unable to write mmap");
de3c15ea 124#endif
578bfd0a
AL
125 return true;
126}
127 /*}}}*/
128// MMap::Sync - Syncronize a section of the file to disk /*{{{*/
129// ---------------------------------------------------------------------
130/* */
131bool MMap::Sync(unsigned long Start,unsigned long Stop)
132{
2d11135a
AL
133 if ((Flags & UnMapped) == UnMapped)
134 return true;
135
35c22def
AL
136#ifdef _POSIX_SYNCHRONIZED_IO
137 unsigned long PSize = sysconf(_SC_PAGESIZE);
1164783d 138 if ((Flags & ReadOnly) != ReadOnly)
35c22def 139 if (msync((char *)Base+(int)(Start/PSize)*PSize,Stop - Start,MS_SYNC) != 0)
4b1b89c5 140 return _error->Errno("msync","Unable to write mmap");
de3c15ea 141#endif
578bfd0a
AL
142 return true;
143}
144 /*}}}*/
145
146// DynamicMMap::DynamicMMap - Constructor /*{{{*/
147// ---------------------------------------------------------------------
148/* */
8e06abb2 149DynamicMMap::DynamicMMap(FileFd &F,unsigned long Flags,unsigned long WorkSpace) :
2d11135a 150 MMap(F,Flags | NoImmMap), Fd(&F), WorkSpace(WorkSpace)
578bfd0a 151{
d38b7b3d
AL
152 if (_error->PendingError() == true)
153 return;
154
2d11135a 155 unsigned long EndOfFile = Fd->Size();
b2e465d6
AL
156 if (EndOfFile > WorkSpace)
157 WorkSpace = EndOfFile;
158 else
159 {
160 Fd->Seek(WorkSpace);
161 char C = 0;
162 Fd->Write(&C,sizeof(C));
163 }
164
2d11135a 165 Map(F);
578bfd0a
AL
166 iSize = EndOfFile;
167}
168 /*}}}*/
2d11135a
AL
169// DynamicMMap::DynamicMMap - Constructor for a non-file backed map /*{{{*/
170// ---------------------------------------------------------------------
171/* This is just a fancy malloc really.. */
172DynamicMMap::DynamicMMap(unsigned long Flags,unsigned long WorkSpace) :
173 MMap(Flags | NoImmMap | UnMapped), Fd(0), WorkSpace(WorkSpace)
174{
175 if (_error->PendingError() == true)
176 return;
177
178 Base = new unsigned char[WorkSpace];
0db4a45b 179 memset(Base,0,WorkSpace);
2d11135a
AL
180 iSize = 0;
181}
182 /*}}}*/
578bfd0a
AL
183// DynamicMMap::~DynamicMMap - Destructor /*{{{*/
184// ---------------------------------------------------------------------
185/* We truncate the file to the size of the memory data set */
186DynamicMMap::~DynamicMMap()
187{
2d11135a
AL
188 if (Fd == 0)
189 {
190 delete [] (unsigned char *)Base;
191 return;
192 }
193
578bfd0a 194 unsigned long EndOfFile = iSize;
1164783d 195 iSize = WorkSpace;
2d11135a
AL
196 Close(false);
197 ftruncate(Fd->Fd(),EndOfFile);
578bfd0a
AL
198}
199 /*}}}*/
200// DynamicMMap::RawAllocate - Allocate a raw chunk of unaligned space /*{{{*/
201// ---------------------------------------------------------------------
f55a958f
AL
202/* This allocates a block of memory aligned to the given size */
203unsigned long DynamicMMap::RawAllocate(unsigned long Size,unsigned long Aln)
578bfd0a
AL
204{
205 unsigned long Result = iSize;
f55a958f
AL
206 if (Aln != 0)
207 Result += Aln - (iSize%Aln);
208
209 iSize = Result + Size;
578bfd0a
AL
210
211 // Just in case error check
e5eebd12 212 if (Result + Size > WorkSpace)
578bfd0a
AL
213 {
214 _error->Error("Dynamic MMap ran out of room");
215 return 0;
216 }
470773ca 217
578bfd0a
AL
218 return Result;
219}
220 /*}}}*/
221// DynamicMMap::Allocate - Pooled aligned allocation /*{{{*/
222// ---------------------------------------------------------------------
223/* This allocates an Item of size ItemSize so that it is aligned to its
224 size in the file. */
225unsigned long DynamicMMap::Allocate(unsigned long ItemSize)
226{
227 // Look for a matching pool entry
228 Pool *I;
229 Pool *Empty = 0;
230 for (I = Pools; I != Pools + PoolCount; I++)
231 {
232 if (I->ItemSize == 0)
233 Empty = I;
234 if (I->ItemSize == ItemSize)
235 break;
236 }
237
238 // No pool is allocated, use an unallocated one
239 if (I == Pools + PoolCount)
240 {
241 // Woops, we ran out, the calling code should allocate more.
242 if (Empty == 0)
243 {
244 _error->Error("Ran out of allocation pools");
245 return 0;
246 }
247
248 I = Empty;
249 I->ItemSize = ItemSize;
250 I->Count = 0;
251 }
252
253 // Out of space, allocate some more
254 if (I->Count == 0)
255 {
256 I->Count = 20*1024/ItemSize;
f55a958f 257 I->Start = RawAllocate(I->Count*ItemSize,ItemSize);
578bfd0a 258 }
f55a958f 259
578bfd0a
AL
260 I->Count--;
261 unsigned long Result = I->Start;
470773ca 262 I->Start += ItemSize;
578bfd0a
AL
263 return Result/ItemSize;
264}
265 /*}}}*/
266// DynamicMMap::WriteString - Write a string to the file /*{{{*/
267// ---------------------------------------------------------------------
268/* Strings are not aligned to anything */
269unsigned long DynamicMMap::WriteString(const char *String,
270 unsigned long Len)
271{
272 unsigned long Result = iSize;
273 // Just in case error check
470773ca 274 if (Result + Len > WorkSpace)
578bfd0a
AL
275 {
276 _error->Error("Dynamic MMap ran out of room");
277 return 0;
278 }
279
6e52073f 280 if (Len == (unsigned long)-1)
578bfd0a
AL
281 Len = strlen(String);
282 iSize += Len + 1;
283 memcpy((char *)Base + Result,String,Len);
284 ((char *)Base)[Result + Len] = 0;
285 return Result;
286}
287 /*}}}*/