Urlader/urlib.c

#include "urlib.h"

#include <fcntl.h>

#ifdef _WIN32

  #include <windows.h>
  //#include <winbase.h>
  #include <shlobj.h>
  #include <shlwapi.h>
  #include <wininet.h>

  static DWORD dword;

  #define u_handle HANDLE
  #define u_invalid_handle 0
  #define u_valid(handle) (!!handle)

  #define u_setenv(name,value) SetEnvironmentVariable (name, value)
  #define u_mkdir(path) !CreateDirectory (path, NULL)
  #define u_chdir(path) !SetCurrentDirectory (path)
  #define u_rename(fr,to) !MoveFile (fr, to)
  #define u_open(path) CreateFile (path, GENERIC_READ, FILE_SHARE_READ, NULL, OPEN_EXISTING, FILE_ATTRIBUTE_NORMAL | FILE_FLAG_SEQUENTIAL_SCAN, NULL)
  #define u_creat(path,exec) CreateFile (path, GENERIC_WRITE, FILE_SHARE_WRITE, NULL, CREATE_ALWAYS, FILE_ATTRIBUTE_NORMAL | FILE_FLAG_SEQUENTIAL_SCAN, NULL)
  #define u_creat(path,exec) CreateFile (path, GENERIC_WRITE, FILE_SHARE_WRITE, NULL, CREATE_ALWAYS, FILE_ATTRIBUTE_NORMAL | FILE_FLAG_SEQUENTIAL_SCAN, NULL)
  #define u_close(handle) CloseHandle (handle)
  #define u_append(path,add) PathAppend (path, add)
  #define u_write(handle,data,len) (WriteFile (handle, data, len, &dword, 0) ? dword : -1)

  #define u_fsync(handle) FlushFileBuffers (handle)
  #define u_sync()

  #define u_lockfile(path) CreateFile (path, GENERIC_READ | GENERIC_WRITE, FILE_SHARE_READ | FILE_SHARE_WRITE, NULL, OPEN_ALWAYS, FILE_ATTRIBUTE_NORMAL, NULL)
  #define u_cloexec(handle)

#else

  #define _GNU_SOURCE 1
  #define _BSD_SOURCE 1
  // the above increases our chances of getting MAP_ANONYMOUS

  #include <sys/mman.h>
  #include <sys/types.h>
  #include <sys/stat.h>
  #include <unistd.h>
  #include <pwd.h>

  #if defined (MAP_ANON) && !defined (MAP_ANONYMOUS)
    #define MAP_ANONYMOUS MAP_ANON
  #endif

  #ifdef PATH_MAX
    #define MAX_PATH (PATH_MAX < 4096 ? 4096 : PATH_MAX)
  #else
    #define MAX_PATH 4096
  #endif

  #define u_handle int
  #define u_invalid_handle -1
  #define u_valid(fd) ((fd) >= 0)

  #define u_setenv(name,value) setenv (name, value, 1)
  #define u_mkdir(path) mkdir (path, 0777)
  #define u_chdir(path) chdir (path)
  #define u_rename(fr,to) rename (fr, to)
  #define u_open(path) open (path, O_RDONLY)
  #define u_creat(path,exec) open (path, O_WRONLY | O_CREAT | O_TRUNC, (exec) ? 0777 : 0666)
  #define u_close(handle) close (handle)
  #define u_append(path,add) strcat (strcat (path, "/"), add)
  #define u_write(handle,data,len) write (handle, data, len)

  // on a mostly idle system, a sync at the end is certainly faster, hope for the best
  #define u_fsync(handle)
  #define u_sync() sync ()

  #define u_lockfile(path) open (path, O_RDWR | O_CREAT, 0666)
  #define u_cloexec(handle) fcntl (handle, F_SETFD, FD_CLOEXEC)

#endif

#define u_16(ptr) (((ptr)[0] << 8) | (ptr)[1])
#define u_32(ptr) (((ptr)[0] << 24) | ((ptr)[1] << 16) | ((ptr)[2] << 8) | (ptr)[3])

static void *
u_malloc (unsigned int size)
{
  void *addr;

#ifdef _WIN32
  HANDLE handle = CreateFileMapping (0, 0, PAGE_READWRITE, 0, size, NULL);

  if (!handle)
    return 0;

  addr = MapViewOfFile (handle, FILE_MAP_WRITE, 0, 0, size);

  CloseHandle (handle);
#elif defined (MAP_ANONYMOUS)
  addr = mmap (0, size, PROT_READ | PROT_WRITE, MAP_PRIVATE | MAP_ANON, -1, 0);

  if (addr == (void *)-1)
    addr = 0;
#else
  addr = malloc (size);
#endif

  return addr;
}

static void
u_free (void *addr, unsigned int size)
{
#ifdef _WIN32
  UnmapViewOfFile (addr);
#elif defined (MAP_ANONYMOUS)
  munmap (addr, size);
#else
  free (addr);
#endif
}

static void *
u_mmap (u_handle h, unsigned int size)
{
  void *addr;

#ifdef _WIN32
  HANDLE handle = CreateFileMapping (h, 0, PAGE_READONLY, 0, size, NULL);

  if (!handle)
    return 0;

  addr = MapViewOfFile (handle, FILE_MAP_READ, 0, 0, size);

  CloseHandle (handle);
#else
  addr = mmap (0, size, PROT_READ, MAP_SHARED, h, 0);

  if (addr == (void *)-1)
    addr = 0;
#endif

  return addr;
}

static void
u_munmap (void *addr, unsigned int len)
{
#ifdef _WIN32
  UnmapViewOfFile (addr);
#else
  munmap (addr, len);
#endif
}
static u_handle
u_lock (const char *path, int excl, int dowait)
{
  u_handle h;

  h = u_lockfile (path);
  if (!u_valid (h))
    return h;

  u_cloexec (h);

  for (;;)
    {
      int success;

      // acquire the lock
#ifdef _WIN32
      OVERLAPPED ov = { 0 };

      success = LockFileEx (h,
                            (excl ? LOCKFILE_EXCLUSIVE_LOCK : 0)
                            | (dowait ? 0 : LOCKFILE_FAIL_IMMEDIATELY),
                            0,
                            1, 0,
                            &ov);
#else
      struct flock lck = { 0 };

      lck.l_type   = excl ? F_WRLCK : F_RDLCK;
      lck.l_whence = SEEK_SET;
      lck.l_len    = 1;

      success = !fcntl (h, dowait ? F_SETLKW : F_SETLK, &lck);
#endif

      if (!success)
        break;

      // we have the lock, now verify that the lockfile still exists

#ifdef _WIN32
      // apparently, we have to open the file to get its info :(
      BY_HANDLE_FILE_INFORMATION s1, s2;
      u_handle h2 = u_lockfile (path);
      if (!u_valid (h))
        break;

      success = GetFileInformationByHandle (h, &s1)
                && GetFileInformationByHandle (h2, &s2);

      u_close (h2);

      if (!success)
        break;

      success = s1.dwVolumeSerialNumber == s2.dwVolumeSerialNumber
             && s1.nFileIndexHigh       == s2.nFileIndexHigh
             && s1.nFileIndexLow        == s2.nFileIndexLow;
#else
      struct stat s1, s2;

      if (fstat (h, &s1) || stat (path, &s2))
        break;

      success = s1.st_dev == s2.st_dev
             && s1.st_ino == s2.st_ino;
#endif

      if (success)
        return h; // lock successfully acquired

      // files differ, close and retry - should be very rare
      u_close (h);
    }

  // failure
  u_close (h);
  return u_invalid_handle;
}

Revision:	1.1
Committed:	Fri Dec 30 23:34:08 2011 UTC (12 years, 4 months ago) by root
Content type:	text/plain
Branch:	MAIN
Log Message:	* empty log message *
#	Content
1	#include "urlib.h"
2
3	#include <fcntl.h>
4
5	#ifdef _WIN32
6
7	#include <windows.h>
8	//#include <winbase.h>
9	#include <shlobj.h>
10	#include <shlwapi.h>
11	#include <wininet.h>
12
13	static DWORD dword;
14
15	#define u_handle HANDLE
16	#define u_invalid_handle 0
17	#define u_valid(handle) (!!handle)
18
19	#define u_setenv(name,value) SetEnvironmentVariable (name, value)
20	#define u_mkdir(path) !CreateDirectory (path, NULL)
21	#define u_chdir(path) !SetCurrentDirectory (path)
22	#define u_rename(fr,to) !MoveFile (fr, to)
23	#define u_open(path) CreateFile (path, GENERIC_READ, FILE_SHARE_READ, NULL, OPEN_EXISTING, FILE_ATTRIBUTE_NORMAL \| FILE_FLAG_SEQUENTIAL_SCAN, NULL)
24	#define u_creat(path,exec) CreateFile (path, GENERIC_WRITE, FILE_SHARE_WRITE, NULL, CREATE_ALWAYS, FILE_ATTRIBUTE_NORMAL \| FILE_FLAG_SEQUENTIAL_SCAN, NULL)
25	#define u_creat(path,exec) CreateFile (path, GENERIC_WRITE, FILE_SHARE_WRITE, NULL, CREATE_ALWAYS, FILE_ATTRIBUTE_NORMAL \| FILE_FLAG_SEQUENTIAL_SCAN, NULL)
26	#define u_close(handle) CloseHandle (handle)
27	#define u_append(path,add) PathAppend (path, add)
28	#define u_write(handle,data,len) (WriteFile (handle, data, len, &dword, 0) ? dword : -1)
29
30	#define u_fsync(handle) FlushFileBuffers (handle)
31	#define u_sync()
32
33	#define u_lockfile(path) CreateFile (path, GENERIC_READ \| GENERIC_WRITE, FILE_SHARE_READ \| FILE_SHARE_WRITE, NULL, OPEN_ALWAYS, FILE_ATTRIBUTE_NORMAL, NULL)
34	#define u_cloexec(handle)
35
36	#else
37
38	#define _GNU_SOURCE 1
39	#define _BSD_SOURCE 1
40	// the above increases our chances of getting MAP_ANONYMOUS
41
42	#include <sys/mman.h>
43	#include <sys/types.h>
44	#include <sys/stat.h>
45	#include <unistd.h>
46	#include <pwd.h>
47
48	#if defined (MAP_ANON) && !defined (MAP_ANONYMOUS)
49	#define MAP_ANONYMOUS MAP_ANON
50	#endif
51
52	#ifdef PATH_MAX
53	#define MAX_PATH (PATH_MAX < 4096 ? 4096 : PATH_MAX)
54	#else
55	#define MAX_PATH 4096
56	#endif
57
58	#define u_handle int
59	#define u_invalid_handle -1
60	#define u_valid(fd) ((fd) >= 0)
61
62	#define u_setenv(name,value) setenv (name, value, 1)
63	#define u_mkdir(path) mkdir (path, 0777)
64	#define u_chdir(path) chdir (path)
65	#define u_rename(fr,to) rename (fr, to)
66	#define u_open(path) open (path, O_RDONLY)
67	#define u_creat(path,exec) open (path, O_WRONLY \| O_CREAT \| O_TRUNC, (exec) ? 0777 : 0666)
68	#define u_close(handle) close (handle)
69	#define u_append(path,add) strcat (strcat (path, "/"), add)
70	#define u_write(handle,data,len) write (handle, data, len)
71
72	// on a mostly idle system, a sync at the end is certainly faster, hope for the best
73	#define u_fsync(handle)
74	#define u_sync() sync ()
75
76	#define u_lockfile(path) open (path, O_RDWR \| O_CREAT, 0666)
77	#define u_cloexec(handle) fcntl (handle, F_SETFD, FD_CLOEXEC)
78
79	#endif
80
81	#define u_16(ptr) (((ptr)[0] << 8) \| (ptr)[1])
82	#define u_32(ptr) (((ptr)[0] << 24) \| ((ptr)[1] << 16) \| ((ptr)[2] << 8) \| (ptr)[3])
83
84	static void *
85	u_malloc (unsigned int size)
86	{
87	void *addr;
88
89	#ifdef _WIN32
90	HANDLE handle = CreateFileMapping (0, 0, PAGE_READWRITE, 0, size, NULL);
91
92	if (!handle)
93	return 0;
94
95	addr = MapViewOfFile (handle, FILE_MAP_WRITE, 0, 0, size);
96
97	CloseHandle (handle);
98	#elif defined (MAP_ANONYMOUS)
99	addr = mmap (0, size, PROT_READ \| PROT_WRITE, MAP_PRIVATE \| MAP_ANON, -1, 0);
100
101	if (addr == (void *)-1)
102	addr = 0;
103	#else
104	addr = malloc (size);
105	#endif
106
107	return addr;
108	}
109
110	static void
111	u_free (void *addr, unsigned int size)
112	{
113	#ifdef _WIN32
114	UnmapViewOfFile (addr);
115	#elif defined (MAP_ANONYMOUS)
116	munmap (addr, size);
117	#else
118	free (addr);
119	#endif
120	}
121
122	static void *
123	u_mmap (u_handle h, unsigned int size)
124	{
125	void *addr;
126
127	#ifdef _WIN32
128	HANDLE handle = CreateFileMapping (h, 0, PAGE_READONLY, 0, size, NULL);
129
130	if (!handle)
131	return 0;
132
133	addr = MapViewOfFile (handle, FILE_MAP_READ, 0, 0, size);
134
135	CloseHandle (handle);
136	#else
137	addr = mmap (0, size, PROT_READ, MAP_SHARED, h, 0);
138
139	if (addr == (void *)-1)
140	addr = 0;
141	#endif
142
143	return addr;
144	}
145
146	static void
147	u_munmap (void *addr, unsigned int len)
148	{
149	#ifdef _WIN32
150	UnmapViewOfFile (addr);
151	#else
152	munmap (addr, len);
153	#endif
154	}
155	static u_handle
156	u_lock (const char *path, int excl, int dowait)
157	{
158	u_handle h;
159
160	h = u_lockfile (path);
161	if (!u_valid (h))
162	return h;
163
164	u_cloexec (h);
165
166	for (;;)
167	{
168	int success;
169
170	// acquire the lock
171	#ifdef _WIN32
172	OVERLAPPED ov = { 0 };
173
174	success = LockFileEx (h,
175	(excl ? LOCKFILE_EXCLUSIVE_LOCK : 0)
176	\| (dowait ? 0 : LOCKFILE_FAIL_IMMEDIATELY),
177	0,
178	1, 0,
179	&ov);
180	#else
181	struct flock lck = { 0 };
182
183	lck.l_type = excl ? F_WRLCK : F_RDLCK;
184	lck.l_whence = SEEK_SET;
185	lck.l_len = 1;
186
187	success = !fcntl (h, dowait ? F_SETLKW : F_SETLK, &lck);
188	#endif
189
190	if (!success)
191	break;
192
193	// we have the lock, now verify that the lockfile still exists
194
195	#ifdef _WIN32
196	// apparently, we have to open the file to get its info :(
197	BY_HANDLE_FILE_INFORMATION s1, s2;
198	u_handle h2 = u_lockfile (path);
199	if (!u_valid (h))
200	break;
201
202	success = GetFileInformationByHandle (h, &s1)
203	&& GetFileInformationByHandle (h2, &s2);
204
205	u_close (h2);
206
207	if (!success)
208	break;
209
210	success = s1.dwVolumeSerialNumber == s2.dwVolumeSerialNumber
211	&& s1.nFileIndexHigh == s2.nFileIndexHigh
212	&& s1.nFileIndexLow == s2.nFileIndexLow;
213	#else
214	struct stat s1, s2;
215
216	if (fstat (h, &s1) \|\| stat (path, &s2))
217	break;
218
219	success = s1.st_dev == s2.st_dev
220	&& s1.st_ino == s2.st_ino;
221	#endif
222
223	if (success)
224	return h; // lock successfully acquired
225
226	// files differ, close and retry - should be very rare
227	u_close (h);
228	}
229
230	// failure
231	u_close (h);
232	return u_invalid_handle;
233	}
234