1 // Windows/FileIO.cpp
2
3 #include "StdAfx.h"
4
5 #ifdef SUPPORT_DEVICE_FILE
6 #include "../../C/Alloc.h"
7 #endif
8
9 #include "FileIO.h"
10 #include "FileName.h"
11
12 #ifndef _UNICODE
13 extern bool g_IsNT;
14 #endif
15
16 using namespace NWindows;
17 using namespace NFile;
18 using namespace NName;
19
20 namespace NWindows {
21 namespace NFile {
22
23 #ifdef SUPPORT_DEVICE_FILE
24
25 namespace NSystem
26 {
27 bool MyGetDiskFreeSpace(CFSTR rootPath, UInt64 &clusterSize, UInt64 &totalSize, UInt64 &freeSize);
28 }
29 #endif
30
31 namespace NIO {
32
33 /*
34 WinXP-64 CreateFile():
35 "" - ERROR_PATH_NOT_FOUND
36 :stream - OK
37 .:stream - ERROR_PATH_NOT_FOUND
38 .\:stream - OK
39
40 folder\:stream - ERROR_INVALID_NAME
41 folder:stream - OK
42
43 c:\:stream - OK
44
45 c::stream - ERROR_INVALID_NAME, if current dir is NOT ROOT ( c:\dir1 )
46 c::stream - OK, if current dir is ROOT ( c:\ )
47 */
48
Create(CFSTR path,DWORD desiredAccess,DWORD shareMode,DWORD creationDisposition,DWORD flagsAndAttributes)49 bool CFileBase::Create(CFSTR path, DWORD desiredAccess,
50 DWORD shareMode, DWORD creationDisposition, DWORD flagsAndAttributes)
51 {
52 if (!Close())
53 return false;
54
55 #ifdef SUPPORT_DEVICE_FILE
56 IsDeviceFile = false;
57 #endif
58
59 #ifndef _UNICODE
60 if (!g_IsNT)
61 {
62 _handle = ::CreateFile(fs2fas(path), desiredAccess, shareMode,
63 (LPSECURITY_ATTRIBUTES)NULL, creationDisposition, flagsAndAttributes, (HANDLE)NULL);
64 }
65 else
66 #endif
67 {
68 IF_USE_MAIN_PATH
69 _handle = ::CreateFileW(fs2us(path), desiredAccess, shareMode,
70 (LPSECURITY_ATTRIBUTES)NULL, creationDisposition, flagsAndAttributes, (HANDLE)NULL);
71 #ifdef WIN_LONG_PATH
72 if (_handle == INVALID_HANDLE_VALUE && USE_SUPER_PATH)
73 {
74 UString superPath;
75 if (GetSuperPath(path, superPath, USE_MAIN_PATH))
76 _handle = ::CreateFileW(superPath, desiredAccess, shareMode,
77 (LPSECURITY_ATTRIBUTES)NULL, creationDisposition, flagsAndAttributes, (HANDLE)NULL);
78 }
79 #endif
80 }
81 return (_handle != INVALID_HANDLE_VALUE);
82 }
83
Close()84 bool CFileBase::Close() throw()
85 {
86 if (_handle == INVALID_HANDLE_VALUE)
87 return true;
88 if (!::CloseHandle(_handle))
89 return false;
90 _handle = INVALID_HANDLE_VALUE;
91 return true;
92 }
93
GetPosition(UInt64 & position) const94 bool CFileBase::GetPosition(UInt64 &position) const throw()
95 {
96 return Seek(0, FILE_CURRENT, position);
97 }
98
GetLength(UInt64 & length) const99 bool CFileBase::GetLength(UInt64 &length) const throw()
100 {
101 #ifdef SUPPORT_DEVICE_FILE
102 if (IsDeviceFile && SizeDefined)
103 {
104 length = Size;
105 return true;
106 }
107 #endif
108
109 DWORD sizeHigh;
110 DWORD sizeLow = ::GetFileSize(_handle, &sizeHigh);
111 if (sizeLow == 0xFFFFFFFF)
112 if (::GetLastError() != NO_ERROR)
113 return false;
114 length = (((UInt64)sizeHigh) << 32) + sizeLow;
115 return true;
116 }
117
Seek(Int64 distanceToMove,DWORD moveMethod,UInt64 & newPosition) const118 bool CFileBase::Seek(Int64 distanceToMove, DWORD moveMethod, UInt64 &newPosition) const throw()
119 {
120 #ifdef SUPPORT_DEVICE_FILE
121 if (IsDeviceFile && SizeDefined && moveMethod == FILE_END)
122 {
123 distanceToMove += Size;
124 moveMethod = FILE_BEGIN;
125 }
126 #endif
127
128 LONG high = (LONG)(distanceToMove >> 32);
129 DWORD low = ::SetFilePointer(_handle, (LONG)(distanceToMove & 0xFFFFFFFF), &high, moveMethod);
130 if (low == 0xFFFFFFFF)
131 if (::GetLastError() != NO_ERROR)
132 return false;
133 newPosition = (((UInt64)(UInt32)high) << 32) + low;
134 return true;
135 }
136
Seek(UInt64 position,UInt64 & newPosition) const137 bool CFileBase::Seek(UInt64 position, UInt64 &newPosition) const throw()
138 {
139 return Seek(position, FILE_BEGIN, newPosition);
140 }
141
SeekToBegin() const142 bool CFileBase::SeekToBegin() const throw()
143 {
144 UInt64 newPosition;
145 return Seek(0, newPosition);
146 }
147
SeekToEnd(UInt64 & newPosition) const148 bool CFileBase::SeekToEnd(UInt64 &newPosition) const throw()
149 {
150 return Seek(0, FILE_END, newPosition);
151 }
152
153 // ---------- CInFile ---------
154
155 #ifdef SUPPORT_DEVICE_FILE
156
CorrectDeviceSize()157 void CInFile::CorrectDeviceSize()
158 {
159 // maybe we must decrease kClusterSize to 1 << 12, if we want correct size at tail
160 static const UInt32 kClusterSize = 1 << 14;
161 UInt64 pos = Size & ~(UInt64)(kClusterSize - 1);
162 UInt64 realNewPosition;
163 if (!Seek(pos, realNewPosition))
164 return;
165 Byte *buf = (Byte *)MidAlloc(kClusterSize);
166
167 bool needbackward = true;
168
169 for (;;)
170 {
171 UInt32 processed = 0;
172 // up test is slow for "PhysicalDrive".
173 // processed size for latest block for "PhysicalDrive0" is 0.
174 if (!Read1(buf, kClusterSize, processed))
175 break;
176 if (processed == 0)
177 break;
178 needbackward = false;
179 Size = pos + processed;
180 if (processed != kClusterSize)
181 break;
182 pos += kClusterSize;
183 }
184
185 if (needbackward && pos != 0)
186 {
187 pos -= kClusterSize;
188 for (;;)
189 {
190 // break;
191 if (!Seek(pos, realNewPosition))
192 break;
193 if (!buf)
194 {
195 buf = (Byte *)MidAlloc(kClusterSize);
196 if (!buf)
197 break;
198 }
199 UInt32 processed = 0;
200 // that code doesn't work for "PhysicalDrive0"
201 if (!Read1(buf, kClusterSize, processed))
202 break;
203 if (processed != 0)
204 {
205 Size = pos + processed;
206 break;
207 }
208 if (pos == 0)
209 break;
210 pos -= kClusterSize;
211 }
212 }
213 MidFree(buf);
214 }
215
216
CalcDeviceSize(CFSTR s)217 void CInFile::CalcDeviceSize(CFSTR s)
218 {
219 SizeDefined = false;
220 Size = 0;
221 if (_handle == INVALID_HANDLE_VALUE || !IsDeviceFile)
222 return;
223 #ifdef UNDER_CE
224
225 SizeDefined = true;
226 Size = 128 << 20;
227
228 #else
229
230 PARTITION_INFORMATION partInfo;
231 bool needCorrectSize = true;
232
233 /*
234 WinXP 64-bit:
235
236 HDD \\.\PhysicalDrive0 (MBR):
237 GetPartitionInfo == GeometryEx : corrrect size? (includes tail)
238 Geometry : smaller than GeometryEx (no tail, maybe correct too?)
239 MyGetDiskFreeSpace : FAIL
240 Size correction is slow and block size (kClusterSize) must be small?
241
242 HDD partition \\.\N: (NTFS):
243 MyGetDiskFreeSpace : Size of NTFS clusters. Same size can be calculated after correction
244 GetPartitionInfo : size of partition data: NTFS clusters + TAIL; TAIL contains extra empty sectors and copy of first sector of NTFS
245 Geometry / CdRomGeometry / GeometryEx : size of HDD (not that partition)
246
247 CD-ROM drive (ISO):
248 MyGetDiskFreeSpace : correct size. Same size can be calculated after correction
249 Geometry == CdRomGeometry : smaller than corrrect size
250 GetPartitionInfo == GeometryEx : larger than corrrect size
251
252 Floppy \\.\a: (FAT):
253 Geometry : correct size.
254 CdRomGeometry / GeometryEx / GetPartitionInfo / MyGetDiskFreeSpace - FAIL
255 correction works OK for FAT.
256 correction works OK for non-FAT, if kClusterSize = 512.
257 */
258
259 if (GetPartitionInfo(&partInfo))
260 {
261 Size = partInfo.PartitionLength.QuadPart;
262 SizeDefined = true;
263 needCorrectSize = false;
264 if ((s)[0] == '\\' && (s)[1] == '\\' && (s)[2] == '.' && (s)[3] == '\\' && (s)[5] == ':' && (s)[6] == 0)
265 {
266 FChar path[4] = { s[4], ':', '\\', 0 };
267 UInt64 clusterSize, totalSize, freeSize;
268 if (NSystem::MyGetDiskFreeSpace(path, clusterSize, totalSize, freeSize))
269 Size = totalSize;
270 else
271 needCorrectSize = true;
272 }
273 }
274
275 if (!SizeDefined)
276 {
277 my_DISK_GEOMETRY_EX geomEx;
278 SizeDefined = GetGeometryEx(&geomEx);
279 if (SizeDefined)
280 Size = geomEx.DiskSize.QuadPart;
281 else
282 {
283 DISK_GEOMETRY geom;
284 SizeDefined = GetGeometry(&geom);
285 if (!SizeDefined)
286 SizeDefined = GetCdRomGeometry(&geom);
287 if (SizeDefined)
288 Size = geom.Cylinders.QuadPart * geom.TracksPerCylinder * geom.SectorsPerTrack * geom.BytesPerSector;
289 }
290 }
291
292 if (needCorrectSize && SizeDefined && Size != 0)
293 {
294 CorrectDeviceSize();
295 SeekToBegin();
296 }
297
298 // SeekToBegin();
299 #endif
300 }
301
302 // ((desiredAccess & (FILE_WRITE_DATA | FILE_APPEND_DATA | GENERIC_WRITE)) == 0 &&
303
304 #define MY_DEVICE_EXTRA_CODE \
305 IsDeviceFile = IsDevicePath(fileName); \
306 CalcDeviceSize(fileName);
307 #else
308 #define MY_DEVICE_EXTRA_CODE
309 #endif
310
Open(CFSTR fileName,DWORD shareMode,DWORD creationDisposition,DWORD flagsAndAttributes)311 bool CInFile::Open(CFSTR fileName, DWORD shareMode, DWORD creationDisposition, DWORD flagsAndAttributes)
312 {
313 bool res = Create(fileName, GENERIC_READ, shareMode, creationDisposition, flagsAndAttributes);
314 MY_DEVICE_EXTRA_CODE
315 return res;
316 }
317
OpenShared(CFSTR fileName,bool shareForWrite)318 bool CInFile::OpenShared(CFSTR fileName, bool shareForWrite)
319 { return Open(fileName, FILE_SHARE_READ | (shareForWrite ? FILE_SHARE_WRITE : 0), OPEN_EXISTING, FILE_ATTRIBUTE_NORMAL); }
320
Open(CFSTR fileName)321 bool CInFile::Open(CFSTR fileName)
322 { return OpenShared(fileName, false); }
323
324 // ReadFile and WriteFile functions in Windows have BUG:
325 // If you Read or Write 64MB or more (probably min_failure_size = 64MB - 32KB + 1)
326 // from/to Network file, it returns ERROR_NO_SYSTEM_RESOURCES
327 // (Insufficient system resources exist to complete the requested service).
328
329 // Probably in some version of Windows there are problems with other sizes:
330 // for 32 MB (maybe also for 16 MB).
331 // And message can be "Network connection was lost"
332
333 static UInt32 kChunkSizeMax = (1 << 22);
334
Read1(void * data,UInt32 size,UInt32 & processedSize)335 bool CInFile::Read1(void *data, UInt32 size, UInt32 &processedSize) throw()
336 {
337 DWORD processedLoc = 0;
338 bool res = BOOLToBool(::ReadFile(_handle, data, size, &processedLoc, NULL));
339 processedSize = (UInt32)processedLoc;
340 return res;
341 }
342
ReadPart(void * data,UInt32 size,UInt32 & processedSize)343 bool CInFile::ReadPart(void *data, UInt32 size, UInt32 &processedSize) throw()
344 {
345 if (size > kChunkSizeMax)
346 size = kChunkSizeMax;
347 return Read1(data, size, processedSize);
348 }
349
Read(void * data,UInt32 size,UInt32 & processedSize)350 bool CInFile::Read(void *data, UInt32 size, UInt32 &processedSize) throw()
351 {
352 processedSize = 0;
353 do
354 {
355 UInt32 processedLoc = 0;
356 bool res = ReadPart(data, size, processedLoc);
357 processedSize += processedLoc;
358 if (!res)
359 return false;
360 if (processedLoc == 0)
361 return true;
362 data = (void *)((unsigned char *)data + processedLoc);
363 size -= processedLoc;
364 }
365 while (size > 0);
366 return true;
367 }
368
369 // ---------- COutFile ---------
370
GetCreationDisposition(bool createAlways)371 static inline DWORD GetCreationDisposition(bool createAlways)
372 { return createAlways? CREATE_ALWAYS: CREATE_NEW; }
373
Open(CFSTR fileName,DWORD shareMode,DWORD creationDisposition,DWORD flagsAndAttributes)374 bool COutFile::Open(CFSTR fileName, DWORD shareMode, DWORD creationDisposition, DWORD flagsAndAttributes)
375 { return CFileBase::Create(fileName, GENERIC_WRITE, shareMode, creationDisposition, flagsAndAttributes); }
376
Open(CFSTR fileName,DWORD creationDisposition)377 bool COutFile::Open(CFSTR fileName, DWORD creationDisposition)
378 { return Open(fileName, FILE_SHARE_READ, creationDisposition, FILE_ATTRIBUTE_NORMAL); }
379
Create(CFSTR fileName,bool createAlways)380 bool COutFile::Create(CFSTR fileName, bool createAlways)
381 { return Open(fileName, GetCreationDisposition(createAlways)); }
382
CreateAlways(CFSTR fileName,DWORD flagsAndAttributes)383 bool COutFile::CreateAlways(CFSTR fileName, DWORD flagsAndAttributes)
384 { return Open(fileName, FILE_SHARE_READ, GetCreationDisposition(true), flagsAndAttributes); }
385
SetTime(const FILETIME * cTime,const FILETIME * aTime,const FILETIME * mTime)386 bool COutFile::SetTime(const FILETIME *cTime, const FILETIME *aTime, const FILETIME *mTime) throw()
387 { return BOOLToBool(::SetFileTime(_handle, cTime, aTime, mTime)); }
388
SetMTime(const FILETIME * mTime)389 bool COutFile::SetMTime(const FILETIME *mTime) throw() { return SetTime(NULL, NULL, mTime); }
390
WritePart(const void * data,UInt32 size,UInt32 & processedSize)391 bool COutFile::WritePart(const void *data, UInt32 size, UInt32 &processedSize) throw()
392 {
393 if (size > kChunkSizeMax)
394 size = kChunkSizeMax;
395 DWORD processedLoc = 0;
396 bool res = BOOLToBool(::WriteFile(_handle, data, size, &processedLoc, NULL));
397 processedSize = (UInt32)processedLoc;
398 return res;
399 }
400
Write(const void * data,UInt32 size,UInt32 & processedSize)401 bool COutFile::Write(const void *data, UInt32 size, UInt32 &processedSize) throw()
402 {
403 processedSize = 0;
404 do
405 {
406 UInt32 processedLoc = 0;
407 bool res = WritePart(data, size, processedLoc);
408 processedSize += processedLoc;
409 if (!res)
410 return false;
411 if (processedLoc == 0)
412 return true;
413 data = (const void *)((const unsigned char *)data + processedLoc);
414 size -= processedLoc;
415 }
416 while (size > 0);
417 return true;
418 }
419
SetEndOfFile()420 bool COutFile::SetEndOfFile() throw() { return BOOLToBool(::SetEndOfFile(_handle)); }
421
SetLength(UInt64 length)422 bool COutFile::SetLength(UInt64 length) throw()
423 {
424 UInt64 newPosition;
425 if (!Seek(length, newPosition))
426 return false;
427 if (newPosition != length)
428 return false;
429 return SetEndOfFile();
430 }
431
432 }}}
433