src/PlatformSpecific.cpp

   1 //
   2 // This file is part of the aMule Project.
   3 //
   4 // Copyright (c) 2008 aMule Team ( admin@amule.org / http://www.amule.org )
   5 //
   6 // Any parts of this program derived from the xMule, lMule or eMule project,
   7 // or contributed by third-party developers are copyrighted by their
   8 // respective authors.
   9 //
  10 // This program is free software; you can redistribute it and/or modify
  11 // it under the terms of the GNU General Public License as published by
  12 // the Free Software Foundation; either version 2 of the License, or
  13 // (at your option) any later version.
  14 //
  15 // This program is distributed in the hope that it will be useful,
  16 // but WITHOUT ANY WARRANTY; without even the implied warranty of
  17 // MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  18 // GNU General Public License for more details.
  19 //
  20 // You should have received a copy of the GNU General Public License
  21 // along with this program; if not, write to the Free Software
  22 // Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA  02110-1301, USA
  23 //
  24
  25 #include "PlatformSpecific.h"
  26
  27 #ifdef HAVE_CONFIG_H
  28 #       include "config.h"
  29 #endif
  30
  31 // NTFS Sparse Files (only for MSW)
  32 #ifdef __WXMSW__
  33 #include "common/Format.h"
  34 #include "Logger.h"
  35 #include <winbase.h>
  36 #include <winioctl.h>
  37 #ifndef FSCTL_SET_SPARSE
  38 #       define FSCTL_SET_SPARSE         CTL_CODE(FILE_DEVICE_FILE_SYSTEM, 49, METHOD_BUFFERED, FILE_SPECIAL_ACCESS)
  39 #endif
  40 #ifndef FSCTL_SET_ZERO_DATA
  41 #       define FSCTL_SET_ZERO_DATA      CTL_CODE(FILE_DEVICE_FILE_SYSTEM, 50, METHOD_BUFFERED, FILE_WRITE_DATA)
  42 #endif
  43
  44 // Create a message from a Windows error code
  45 static wxString SystemError()
  46 {
  47         WCHAR * lpMsgBuf = NULL;
  48
  49         FormatMessageW(
  50                 FORMAT_MESSAGE_ALLOCATE_BUFFER | FORMAT_MESSAGE_FROM_SYSTEM,
  51                 NULL,
  52                 GetLastError(),
  53                 0, // Default language
  54                 (LPWSTR) &lpMsgBuf,
  55                 0,
  56                 NULL
  57         );
  58
  59         wxString ret(lpMsgBuf);
  60         LocalFree(lpMsgBuf);
  61         return ret;
  62 }
  63
  64 // Create a file in sparse mode
  65 bool PlatformSpecific::CreateSparseFile(const CPath& name, uint64_t size)
  66 {
  67         DWORD dwReturnedBytes=0;
  68
  69         HANDLE hd = CreateFileW(name.GetRaw().c_str(),
  70                 GENERIC_READ | GENERIC_WRITE,
  71                 0,       // share - not shareable
  72                 NULL,    // security - not inheritable
  73                 CREATE_ALWAYS,
  74                 FILE_ATTRIBUTE_ARCHIVE,
  75                 NULL);
  76         if (hd == INVALID_HANDLE_VALUE) {
  77                 AddDebugLogLineM(true, logPartFile, CFormat(wxT("converting %s to sparse failed (OPEN): %s ")) % name % SystemError());
  78                 return false;
  79         }
  80
  81         if (!DeviceIoControl(hd, FSCTL_SET_SPARSE, NULL, 0, NULL, 0, &dwReturnedBytes, NULL)) {
  82                 AddDebugLogLineM(true, logPartFile, CFormat(wxT("converting %s to sparse failed (SET_SPARSE): %s ")) % name % SystemError());
  83         } else {
  84                 // FILE_ZERO_DATA_INFORMATION is not defined here
  85                 struct {
  86                         uint64 FileOffset;
  87                         uint64 BeyondFinalZero;
  88                 } fzdi;
  89                 fzdi.FileOffset = 0;
  90                 fzdi.BeyondFinalZero = size;
  91                 LARGE_INTEGER largo;
  92                 largo.QuadPart = size;
  93
  94                 // zero the data
  95                 if (!DeviceIoControl(hd, FSCTL_SET_ZERO_DATA, (LPVOID) &fzdi, sizeof(fzdi), NULL, 0, &dwReturnedBytes, NULL)) {
  96                         AddDebugLogLineM(true, logPartFile, CFormat(wxT("converting %s to sparse failed (ZERO): %s")) % name % SystemError());
  97                 } else if (!SetFilePointerEx(hd, largo, NULL, FILE_BEGIN) || !SetEndOfFile(hd)) {
  98                         AddDebugLogLineM(true, logPartFile, CFormat(wxT("converting %s to sparse failed (SEEK): %s")) % name % SystemError());
  99                 }
 100         }
 101         CloseHandle(hd);
 102         return true;
 103 }
 104
 105 #else  // non Windows systems don't need all this
 106 #include "CFile.h"
 107
 108 bool PlatformSpecific::CreateSparseFile(const CPath& name, uint64_t WXUNUSED(size))
 109 {
 110         CFile f;
 111         return f.Create(name.GetRaw(), true) && f.Close();
 112 }
 113
 114 #endif
 115
 116 #ifdef __WXMSW__
 117 #include <wx/msw/registry.h>
 118 #include <wx/utils.h>
 119
 120 // Get the max number of connections that the OS supports, or -1 for default
 121 int PlatformSpecific::GetMaxConnections()
 122 {
 123         int maxconn = -1;
 124         // Try to get the max connection value in the registry
 125         wxRegKey key( wxT("HKEY_LOCAL_MACHINE\\System\\CurrentControlSet\\Services\\VxD\\MSTCP\\MaxConnections") );
 126         wxString value;
 127         if ( key.Exists() ) {
 128                 value = key.QueryDefaultValue();
 129         }
 130         if ( !value.IsEmpty() && value.IsNumber() ) {
 131                 long mc;
 132                 value.ToLong(&mc);
 133                 maxconn = (int)mc;
 134         } else {
 135                 switch (wxGetOsVersion()) {
 136                 case wxOS_WINDOWS_9X:
 137                         // This includes all Win9x versions
 138                         maxconn = 50;
 139                         break;
 140                 case wxOS_WINDOWS_NT:
 141                         // This includes NT based windows
 142                         maxconn = 500;
 143                         break;
 144                 default:
 145                         // Anything else. Let aMule decide...
 146                         break;
 147                 }
 148         }
 149
 150         return maxconn;
 151 }
 152 #endif
 153
 154
 155 #ifdef __WXMSW__
 156 #include <winbase.h>
 157 #include <shlwapi.h>
 158
 159 static PlatformSpecific::EFSType doGetFilesystemType(const CPath& path)
 160 {
 161         wxWritableWCharBuffer pathRaw(path.GetRaw());
 162         LPWSTR volume = pathRaw;
 163         if (!PathStripToRootW(volume)) {
 164                 return PlatformSpecific::fsOther;
 165         }
 166         PathAddBackslashW(volume);
 167
 168         DWORD maximumComponentLength = 0;
 169         DWORD filesystemFlags = 0;
 170         WCHAR filesystemNameBuffer[128];
 171         if (!GetVolumeInformationW(volume, NULL, 0, NULL, &maximumComponentLength, &filesystemFlags, filesystemNameBuffer, 128)) {
 172                 return PlatformSpecific::fsOther;
 173         }
 174         if (wxStrnicmp(filesystemNameBuffer, wxT("FAT"), 3) == 0) {
 175                 return PlatformSpecific::fsFAT;
 176         } else if (wxStrcmp(filesystemNameBuffer, wxT("NTFS")) == 0) {
 177                 return PlatformSpecific::fsNTFS;
 178         }
 179         return PlatformSpecific::fsOther;
 180 };
 181
 182 #elif defined(HAVE_GETMNTENT) && defined(HAVE_MNTENT_H)
 183 #include <stdio.h>
 184 #include <string.h>
 185 #include <mntent.h>
 186 #ifndef _PATH_MOUNTED
 187 #       define _PATH_MOUNTED    "/etc/mtab"
 188 #endif
 189 #include <common/StringFunctions.h>
 190
 191 static PlatformSpecific::EFSType doGetFilesystemType(const CPath& path)
 192 {
 193         struct mntent *entry = NULL;
 194         PlatformSpecific::EFSType retval = PlatformSpecific::fsOther;
 195         FILE *mnttab = fopen(_PATH_MOUNTED, "r");
 196         unsigned bestPrefixLen = 0;
 197
 198         if (mnttab == NULL) {
 199                 return PlatformSpecific::fsOther;
 200         }
 201
 202         while ((entry = getmntent(mnttab)) != NULL) {
 203                 if (entry->mnt_dir) {
 204                         wxString dir = char2unicode(entry->mnt_dir);
 205                         if (dir == path.GetRaw().Mid(0, dir.Length())) {
 206                                 if (dir.Length() >= bestPrefixLen) {
 207                                         if (entry->mnt_type == NULL) {
 208                                                 break;
 209                                         } else if (!strcmp(entry->mnt_type, "ntfs")) {
 210                                                 retval = PlatformSpecific::fsNTFS;
 211                                         } else if (!strcmp(entry->mnt_type, "msdos") ||
 212                                                    !strcmp(entry->mnt_type, "umsdos") ||
 213                                                    !strcmp(entry->mnt_type, "vfat") ||
 214                                                    !strncmp(entry->mnt_type, "fat", 3)) {
 215                                                 retval = PlatformSpecific::fsFAT;
 216                                         } else if (!strcmp(entry->mnt_type, "hfs")) {
 217                                                 retval = PlatformSpecific::fsHFS;
 218                                         } else if (!strcmp(entry->mnt_type, "hpfs")) {
 219                                                 retval = PlatformSpecific::fsHPFS;
 220                                         } else if (!strcmp(entry->mnt_type, "minix")) {
 221                                                 retval = PlatformSpecific::fsMINIX;
 222                                         } /* Add more filesystem types here */
 223                                         else if (dir.Length() > bestPrefixLen) {
 224                                                 retval = PlatformSpecific::fsOther;
 225                                         }
 226                                         bestPrefixLen = dir.Length();
 227                                 }
 228                         }
 229                 }
 230         }
 231         fclose(mnttab);
 232         return retval;
 233 }
 234
 235 #elif defined(HAVE_GETMNTENT) && defined(HAVE_SYS_MNTENT_H) && defined(HAVE_SYS_MNTTAB_H)
 236 #include <stdio.h>
 237 #include <string.h>
 238 #include <sys/mntent.h>
 239 #include <sys/mnttab.h>
 240 #ifndef MNTTAB
 241 #       define MNTTAB   "/etc/mnttab"
 242 #endif
 243 #include <common/StringFunctions.h>
 244
 245 static PlatformSpecific::EFSType doGetFilesystemType(const CPath& path)
 246 {
 247         struct mnttab *entry = NULL;
 248         PlatformSpecific::EFSType retval = PlatformSpecific::fsOther;
 249         FILE *mnttab = fopen(MNTTAB, "r");
 250         unsigned bestPrefixLen = 0;
 251
 252         if (mnttab == NULL) {
 253                 return PlatformSpecific::fsOther;
 254         }
 255
 256         while (getmntent(mnttab, entry) == 0) {
 257                 if (entry->mnt_mountp) {
 258                         wxString dir = char2unicode(entry->mnt_mountp);
 259                         if (dir == path.GetRaw().Mid(0, dir.Length())) {
 260                                 if (dir.Length() >= bestPrefixLen) {
 261                                         if (entry->mnt_fstype == NULL) {
 262                                                 break;
 263                                         } else if (!strcmp(entry->mnt_fstype, MNTTYPE_PCFS)) {
 264                                                 retval = PlatformSpecific::fsFAT;
 265                                         } else if (hasmntopt(entry, MNTOPT_NOLARGEFILES)) {
 266                                                 // MINIX is a file system that can handle special chars but has no large files.
 267                                                 retval = PlatformSpecific::fsMINIX;
 268                                         } else if (dir.Length() > bestPrefixLen) {
 269                                                 retval = PlatformSpecific::fsOther;
 270                                         }
 271                                         bestPrefixLen = dir.Length();
 272                                 }
 273                         }
 274                 }
 275         }
 276         fclose(mnttab);
 277         return retval;
 278 }
 279
 280 #else
 281
 282 // No way to determine filesystem type, no restrictions apply.
 283 static inline PlatformSpecific::EFSType doGetFilesystemType(const CPath& WXUNUSED(path))
 284 {
 285         return PlatformSpecific::fsOther;
 286 }
 287
 288 #endif
 289
 290 #include <map>
 291 #include <wx/thread.h>
 292
 293 PlatformSpecific::EFSType PlatformSpecific::GetFilesystemType(const CPath& path)
 294 {
 295         typedef std::map<wxString, EFSType>     FSMap;
 296         // Caching previous results, to speed up further checks.
 297         static FSMap    s_fscache;
 298         // Lock used to ensure the integrity of the cache.
 299         static wxMutex  s_lock;
 300
 301         wxCHECK_MSG(path.IsOk(), fsOther, wxT("Invalid path in GetFilesystemType()"));
 302
 303         wxMutexLocker locker(s_lock);
 304
 305         FSMap::iterator it = s_fscache.find(path.GetRaw());
 306         if (it != s_fscache.end()) {
 307                 return it->second;
 308         }
 309
 310         return s_fscache[path.GetRaw()] = doGetFilesystemType(path);
 311 }