##// END OF EJS Templates
merge with stable
Matt Mackall -
r15098:edf7ae54 merge default
parent child Browse files
Show More
@@ -1,578 +1,578
1 1 /*
2 2 osutil.c - native operating system services
3 3
4 4 Copyright 2007 Matt Mackall and others
5 5
6 6 This software may be used and distributed according to the terms of
7 7 the GNU General Public License, incorporated herein by reference.
8 8 */
9 9
10 10 #define _ATFILE_SOURCE
11 11 #include <Python.h>
12 12 #include <fcntl.h>
13 13 #include <stdio.h>
14 14 #include <string.h>
15 15 #include <errno.h>
16 16
17 17 #ifdef _WIN32
18 18 #include <windows.h>
19 19 #include <io.h>
20 20 #else
21 21 #include <dirent.h>
22 22 #include <sys/stat.h>
23 23 #include <sys/types.h>
24 24 #include <unistd.h>
25 25 #endif
26 26
27 27 #include "util.h"
28 28
29 29 /* some platforms lack the PATH_MAX definition (eg. GNU/Hurd) */
30 30 #ifndef PATH_MAX
31 31 #define PATH_MAX 4096
32 32 #endif
33 33
34 34 #ifdef _WIN32
35 35 /*
36 36 stat struct compatible with hg expectations
37 37 Mercurial only uses st_mode, st_size and st_mtime
38 38 the rest is kept to minimize changes between implementations
39 39 */
40 40 struct hg_stat {
41 41 int st_dev;
42 42 int st_mode;
43 43 int st_nlink;
44 44 __int64 st_size;
45 45 int st_mtime;
46 46 int st_ctime;
47 47 };
48 48 struct listdir_stat {
49 49 PyObject_HEAD
50 50 struct hg_stat st;
51 51 };
52 52 #else
53 53 struct listdir_stat {
54 54 PyObject_HEAD
55 55 struct stat st;
56 56 };
57 57 #endif
58 58
59 59 #define listdir_slot(name) \
60 60 static PyObject *listdir_stat_##name(PyObject *self, void *x) \
61 61 { \
62 62 return PyInt_FromLong(((struct listdir_stat *)self)->st.name); \
63 63 }
64 64
65 65 listdir_slot(st_dev)
66 66 listdir_slot(st_mode)
67 67 listdir_slot(st_nlink)
68 68 #ifdef _WIN32
69 69 static PyObject *listdir_stat_st_size(PyObject *self, void *x)
70 70 {
71 71 return PyLong_FromLongLong(
72 72 (PY_LONG_LONG)((struct listdir_stat *)self)->st.st_size);
73 73 }
74 74 #else
75 75 listdir_slot(st_size)
76 76 #endif
77 77 listdir_slot(st_mtime)
78 78 listdir_slot(st_ctime)
79 79
80 80 static struct PyGetSetDef listdir_stat_getsets[] = {
81 81 {"st_dev", listdir_stat_st_dev, 0, 0, 0},
82 82 {"st_mode", listdir_stat_st_mode, 0, 0, 0},
83 83 {"st_nlink", listdir_stat_st_nlink, 0, 0, 0},
84 84 {"st_size", listdir_stat_st_size, 0, 0, 0},
85 85 {"st_mtime", listdir_stat_st_mtime, 0, 0, 0},
86 86 {"st_ctime", listdir_stat_st_ctime, 0, 0, 0},
87 87 {0, 0, 0, 0, 0}
88 88 };
89 89
90 90 static PyObject *listdir_stat_new(PyTypeObject *t, PyObject *a, PyObject *k)
91 91 {
92 92 return t->tp_alloc(t, 0);
93 93 }
94 94
95 95 static void listdir_stat_dealloc(PyObject *o)
96 96 {
97 97 o->ob_type->tp_free(o);
98 98 }
99 99
100 100 static PyTypeObject listdir_stat_type = {
101 101 PyVarObject_HEAD_INIT(NULL, 0)
102 102 "osutil.stat", /*tp_name*/
103 103 sizeof(struct listdir_stat), /*tp_basicsize*/
104 104 0, /*tp_itemsize*/
105 105 (destructor)listdir_stat_dealloc, /*tp_dealloc*/
106 106 0, /*tp_print*/
107 107 0, /*tp_getattr*/
108 108 0, /*tp_setattr*/
109 109 0, /*tp_compare*/
110 110 0, /*tp_repr*/
111 111 0, /*tp_as_number*/
112 112 0, /*tp_as_sequence*/
113 113 0, /*tp_as_mapping*/
114 114 0, /*tp_hash */
115 115 0, /*tp_call*/
116 116 0, /*tp_str*/
117 117 0, /*tp_getattro*/
118 118 0, /*tp_setattro*/
119 119 0, /*tp_as_buffer*/
120 120 Py_TPFLAGS_DEFAULT | Py_TPFLAGS_BASETYPE, /*tp_flags*/
121 121 "stat objects", /* tp_doc */
122 122 0, /* tp_traverse */
123 123 0, /* tp_clear */
124 124 0, /* tp_richcompare */
125 125 0, /* tp_weaklistoffset */
126 126 0, /* tp_iter */
127 127 0, /* tp_iternext */
128 128 0, /* tp_methods */
129 129 0, /* tp_members */
130 130 listdir_stat_getsets, /* tp_getset */
131 131 0, /* tp_base */
132 132 0, /* tp_dict */
133 133 0, /* tp_descr_get */
134 134 0, /* tp_descr_set */
135 135 0, /* tp_dictoffset */
136 136 0, /* tp_init */
137 137 0, /* tp_alloc */
138 138 listdir_stat_new, /* tp_new */
139 139 };
140 140
141 141 #ifdef _WIN32
142 142
143 143 static int to_python_time(const FILETIME *tm)
144 144 {
145 145 /* number of seconds between epoch and January 1 1601 */
146 146 const __int64 a0 = (__int64)134774L * (__int64)24L * (__int64)3600L;
147 147 /* conversion factor from 100ns to 1s */
148 148 const __int64 a1 = 10000000;
149 149 /* explicit (int) cast to suspend compiler warnings */
150 150 return (int)((((__int64)tm->dwHighDateTime << 32)
151 151 + tm->dwLowDateTime) / a1 - a0);
152 152 }
153 153
154 154 static PyObject *make_item(const WIN32_FIND_DATAA *fd, int wantstat)
155 155 {
156 156 PyObject *py_st;
157 157 struct hg_stat *stp;
158 158
159 159 int kind = (fd->dwFileAttributes & FILE_ATTRIBUTE_DIRECTORY)
160 160 ? _S_IFDIR : _S_IFREG;
161 161
162 162 if (!wantstat)
163 163 return Py_BuildValue("si", fd->cFileName, kind);
164 164
165 165 py_st = PyObject_CallObject((PyObject *)&listdir_stat_type, NULL);
166 166 if (!py_st)
167 167 return NULL;
168 168
169 169 stp = &((struct listdir_stat *)py_st)->st;
170 170 /*
171 171 use kind as st_mode
172 172 rwx bits on Win32 are meaningless
173 173 and Hg does not use them anyway
174 174 */
175 175 stp->st_mode = kind;
176 176 stp->st_mtime = to_python_time(&fd->ftLastWriteTime);
177 177 stp->st_ctime = to_python_time(&fd->ftCreationTime);
178 178 if (kind == _S_IFREG)
179 179 stp->st_size = ((__int64)fd->nFileSizeHigh << 32)
180 180 + fd->nFileSizeLow;
181 181 return Py_BuildValue("siN", fd->cFileName,
182 182 kind, py_st);
183 183 }
184 184
185 185 static PyObject *_listdir(char *path, int plen, int wantstat, char *skip)
186 186 {
187 187 PyObject *rval = NULL; /* initialize - return value */
188 188 PyObject *list;
189 189 HANDLE fh;
190 190 WIN32_FIND_DATAA fd;
191 191 char *pattern;
192 192
193 193 /* build the path + \* pattern string */
194 194 pattern = malloc(plen + 3); /* path + \* + \0 */
195 195 if (!pattern) {
196 196 PyErr_NoMemory();
197 197 goto error_nomem;
198 198 }
199 199 strcpy(pattern, path);
200 200
201 201 if (plen > 0) {
202 202 char c = path[plen-1];
203 203 if (c != ':' && c != '/' && c != '\\')
204 204 pattern[plen++] = '\\';
205 205 }
206 206 strcpy(pattern + plen, "*");
207 207
208 208 fh = FindFirstFileA(pattern, &fd);
209 209 if (fh == INVALID_HANDLE_VALUE) {
210 210 PyErr_SetFromWindowsErrWithFilename(GetLastError(), path);
211 211 goto error_file;
212 212 }
213 213
214 214 list = PyList_New(0);
215 215 if (!list)
216 216 goto error_list;
217 217
218 218 do {
219 219 PyObject *item;
220 220
221 221 if (fd.dwFileAttributes & FILE_ATTRIBUTE_DIRECTORY) {
222 222 if (!strcmp(fd.cFileName, ".")
223 223 || !strcmp(fd.cFileName, ".."))
224 224 continue;
225 225
226 226 if (skip && !strcmp(fd.cFileName, skip)) {
227 227 rval = PyList_New(0);
228 228 goto error;
229 229 }
230 230 }
231 231
232 232 item = make_item(&fd, wantstat);
233 233 if (!item)
234 234 goto error;
235 235
236 236 if (PyList_Append(list, item)) {
237 237 Py_XDECREF(item);
238 238 goto error;
239 239 }
240 240
241 241 Py_XDECREF(item);
242 242 } while (FindNextFileA(fh, &fd));
243 243
244 244 if (GetLastError() != ERROR_NO_MORE_FILES) {
245 245 PyErr_SetFromWindowsErrWithFilename(GetLastError(), path);
246 246 goto error;
247 247 }
248 248
249 249 rval = list;
250 250 Py_XINCREF(rval);
251 251 error:
252 252 Py_XDECREF(list);
253 253 error_list:
254 254 FindClose(fh);
255 255 error_file:
256 256 free(pattern);
257 257 error_nomem:
258 258 return rval;
259 259 }
260 260
261 261 #else
262 262
263 263 int entkind(struct dirent *ent)
264 264 {
265 265 #ifdef DT_REG
266 266 switch (ent->d_type) {
267 267 case DT_REG: return S_IFREG;
268 268 case DT_DIR: return S_IFDIR;
269 269 case DT_LNK: return S_IFLNK;
270 270 case DT_BLK: return S_IFBLK;
271 271 case DT_CHR: return S_IFCHR;
272 272 case DT_FIFO: return S_IFIFO;
273 273 case DT_SOCK: return S_IFSOCK;
274 274 }
275 275 #endif
276 276 return -1;
277 277 }
278 278
279 279 static PyObject *_listdir(char *path, int pathlen, int keepstat, char *skip)
280 280 {
281 281 PyObject *list, *elem, *stat, *ret = NULL;
282 282 char fullpath[PATH_MAX + 10];
283 283 int kind, err;
284 284 struct stat st;
285 285 struct dirent *ent;
286 286 DIR *dir;
287 287 #ifdef AT_SYMLINK_NOFOLLOW
288 288 int dfd = -1;
289 289 #endif
290 290
291 291 if (pathlen >= PATH_MAX) {
292 292 errno = ENAMETOOLONG;
293 293 PyErr_SetFromErrnoWithFilename(PyExc_OSError, path);
294 294 goto error_value;
295 295 }
296 296 strncpy(fullpath, path, PATH_MAX);
297 297 fullpath[pathlen] = '/';
298 298
299 299 #ifdef AT_SYMLINK_NOFOLLOW
300 300 dfd = open(path, O_RDONLY);
301 301 if (dfd == -1) {
302 302 PyErr_SetFromErrnoWithFilename(PyExc_OSError, path);
303 303 goto error_value;
304 304 }
305 305 dir = fdopendir(dfd);
306 306 #else
307 307 dir = opendir(path);
308 308 #endif
309 309 if (!dir) {
310 310 PyErr_SetFromErrnoWithFilename(PyExc_OSError, path);
311 311 goto error_dir;
312 312 }
313 313
314 314 list = PyList_New(0);
315 315 if (!list)
316 316 goto error_list;
317 317
318 318 while ((ent = readdir(dir))) {
319 319 if (!strcmp(ent->d_name, ".") || !strcmp(ent->d_name, ".."))
320 320 continue;
321 321
322 322 kind = entkind(ent);
323 323 if (kind == -1 || keepstat) {
324 324 #ifdef AT_SYMLINK_NOFOLLOW
325 325 err = fstatat(dfd, ent->d_name, &st,
326 326 AT_SYMLINK_NOFOLLOW);
327 327 #else
328 328 strncpy(fullpath + pathlen + 1, ent->d_name,
329 329 PATH_MAX - pathlen);
330 330 fullpath[PATH_MAX] = 0;
331 331 err = lstat(fullpath, &st);
332 332 #endif
333 333 if (err == -1) {
334 334 strncpy(fullpath + pathlen + 1, ent->d_name,
335 335 PATH_MAX - pathlen);
336 336 fullpath[PATH_MAX] = 0;
337 337 PyErr_SetFromErrnoWithFilename(PyExc_OSError,
338 338 fullpath);
339 339 goto error;
340 340 }
341 341 kind = st.st_mode & S_IFMT;
342 342 }
343 343
344 344 /* quit early? */
345 345 if (skip && kind == S_IFDIR && !strcmp(ent->d_name, skip)) {
346 346 ret = PyList_New(0);
347 347 goto error;
348 348 }
349 349
350 350 if (keepstat) {
351 351 stat = PyObject_CallObject((PyObject *)&listdir_stat_type, NULL);
352 352 if (!stat)
353 353 goto error;
354 354 memcpy(&((struct listdir_stat *)stat)->st, &st, sizeof(st));
355 355 elem = Py_BuildValue("siN", ent->d_name, kind, stat);
356 356 } else
357 357 elem = Py_BuildValue("si", ent->d_name, kind);
358 358 if (!elem)
359 359 goto error;
360 360
361 361 PyList_Append(list, elem);
362 362 Py_DECREF(elem);
363 363 }
364 364
365 365 ret = list;
366 366 Py_INCREF(ret);
367 367
368 368 error:
369 369 Py_DECREF(list);
370 370 error_list:
371 371 closedir(dir);
372 372 error_dir:
373 373 #ifdef AT_SYMLINK_NOFOLLOW
374 374 close(dfd);
375 375 #endif
376 376 error_value:
377 377 return ret;
378 378 }
379 379
380 380 #endif /* ndef _WIN32 */
381 381
382 382 static PyObject *listdir(PyObject *self, PyObject *args, PyObject *kwargs)
383 383 {
384 384 PyObject *statobj = NULL; /* initialize - optional arg */
385 385 PyObject *skipobj = NULL; /* initialize - optional arg */
386 386 char *path, *skip = NULL;
387 387 int wantstat, plen;
388 388
389 389 static char *kwlist[] = {"path", "stat", "skip", NULL};
390 390
391 391 if (!PyArg_ParseTupleAndKeywords(args, kwargs, "s#|OO:listdir",
392 392 kwlist, &path, &plen, &statobj, &skipobj))
393 393 return NULL;
394 394
395 395 wantstat = statobj && PyObject_IsTrue(statobj);
396 396
397 397 if (skipobj && skipobj != Py_None) {
398 398 skip = PyBytes_AsString(skipobj);
399 399 if (!skip)
400 400 return NULL;
401 401 }
402 402
403 403 return _listdir(path, plen, wantstat, skip);
404 404 }
405 405
406 406 #ifdef _WIN32
407 407 static PyObject *posixfile(PyObject *self, PyObject *args, PyObject *kwds)
408 408 {
409 409 static char *kwlist[] = {"name", "mode", "buffering", NULL};
410 410 PyObject *file_obj = NULL;
411 411 char *name = NULL;
412 412 char *mode = "rb";
413 413 DWORD access = 0;
414 414 DWORD creation;
415 415 HANDLE handle;
416 416 int fd, flags = 0;
417 417 int bufsize = -1;
418 418 char m0, m1, m2;
419 419 char fpmode[4];
420 420 int fppos = 0;
421 421 int plus;
422 422 FILE *fp;
423 423
424 424 if (!PyArg_ParseTupleAndKeywords(args, kwds, "et|si:posixfile", kwlist,
425 425 Py_FileSystemDefaultEncoding,
426 426 &name, &mode, &bufsize))
427 427 return NULL;
428 428
429 429 m0 = mode[0];
430 430 m1 = m0 ? mode[1] : '\0';
431 431 m2 = m1 ? mode[2] : '\0';
432 432 plus = m1 == '+' || m2 == '+';
433 433
434 434 fpmode[fppos++] = m0;
435 435 if (m1 == 'b' || m2 == 'b') {
436 436 flags = _O_BINARY;
437 437 fpmode[fppos++] = 'b';
438 438 }
439 439 else
440 440 flags = _O_TEXT;
441 441 if (m0 == 'r' && !plus) {
442 442 flags |= _O_RDONLY;
443 443 access = GENERIC_READ;
444 444 } else {
445 445 /*
446 446 work around http://support.microsoft.com/kb/899149 and
447 447 set _O_RDWR for 'w' and 'a', even if mode has no '+'
448 448 */
449 449 flags |= _O_RDWR;
450 450 access = GENERIC_READ | GENERIC_WRITE;
451 451 fpmode[fppos++] = '+';
452 452 }
453 453 fpmode[fppos++] = '\0';
454 454
455 455 switch (m0) {
456 456 case 'r':
457 457 creation = OPEN_EXISTING;
458 458 break;
459 459 case 'w':
460 460 creation = CREATE_ALWAYS;
461 461 break;
462 462 case 'a':
463 463 creation = OPEN_ALWAYS;
464 464 flags |= _O_APPEND;
465 465 break;
466 466 default:
467 467 PyErr_Format(PyExc_ValueError,
468 468 "mode string must begin with one of 'r', 'w', "
469 469 "or 'a', not '%c'", m0);
470 470 goto bail;
471 471 }
472 472
473 473 handle = CreateFile(name, access,
474 474 FILE_SHARE_READ | FILE_SHARE_WRITE |
475 475 FILE_SHARE_DELETE,
476 476 NULL,
477 477 creation,
478 478 FILE_ATTRIBUTE_NORMAL,
479 479 0);
480 480
481 481 if (handle == INVALID_HANDLE_VALUE) {
482 482 PyErr_SetFromWindowsErrWithFilename(GetLastError(), name);
483 483 goto bail;
484 484 }
485 485
486 486 fd = _open_osfhandle((intptr_t)handle, flags);
487 487
488 488 if (fd == -1) {
489 489 CloseHandle(handle);
490 490 PyErr_SetFromErrnoWithFilename(PyExc_IOError, name);
491 491 goto bail;
492 492 }
493 493 #ifndef IS_PY3K
494 494 fp = _fdopen(fd, fpmode);
495 495 if (fp == NULL) {
496 496 _close(fd);
497 497 PyErr_SetFromErrnoWithFilename(PyExc_IOError, name);
498 498 goto bail;
499 499 }
500 500
501 501 file_obj = PyFile_FromFile(fp, name, mode, fclose);
502 502 if (file_obj == NULL) {
503 503 fclose(fp);
504 504 goto bail;
505 505 }
506 506
507 507 PyFile_SetBufSize(file_obj, bufsize);
508 508 #else
509 509 file_obj = PyFile_FromFd(fd, name, mode, bufsize, NULL, NULL, NULL, 1);
510 510 if (file_obj == NULL)
511 511 goto bail;
512 512 #endif
513 513 bail:
514 514 PyMem_Free(name);
515 515 return file_obj;
516 516 }
517 517 #endif
518 518
519 519 #ifdef __APPLE__
520 520 #include <ApplicationServices/ApplicationServices.h>
521 521
522 522 static PyObject *isgui(PyObject *self)
523 523 {
524 524 CFDictionaryRef dict = CGSessionCopyCurrentDictionary();
525 525
526 526 if (dict != NULL) {
527 527 CFRelease(dict);
528 return Py_True;
528 Py_RETURN_TRUE;
529 529 } else {
530 return Py_False;
530 Py_RETURN_FALSE;
531 531 }
532 532 }
533 533 #endif
534 534
535 535 static char osutil_doc[] = "Native operating system services.";
536 536
537 537 static PyMethodDef methods[] = {
538 538 {"listdir", (PyCFunction)listdir, METH_VARARGS | METH_KEYWORDS,
539 539 "list a directory\n"},
540 540 #ifdef _WIN32
541 541 {"posixfile", (PyCFunction)posixfile, METH_VARARGS | METH_KEYWORDS,
542 542 "Open a file with POSIX-like semantics.\n"
543 543 "On error, this function may raise either a WindowsError or an IOError."},
544 544 #endif
545 545 #ifdef __APPLE__
546 546 {
547 547 "isgui", (PyCFunction)isgui, METH_NOARGS,
548 548 "Is a CoreGraphics session available?"
549 549 },
550 550 #endif
551 551 {NULL, NULL}
552 552 };
553 553
554 554 #ifdef IS_PY3K
555 555 static struct PyModuleDef osutil_module = {
556 556 PyModuleDef_HEAD_INIT,
557 557 "osutil",
558 558 osutil_doc,
559 559 -1,
560 560 methods
561 561 };
562 562
563 563 PyMODINIT_FUNC PyInit_osutil(void)
564 564 {
565 565 if (PyType_Ready(&listdir_stat_type) < 0)
566 566 return NULL;
567 567
568 568 return PyModule_Create(&osutil_module);
569 569 }
570 570 #else
571 571 PyMODINIT_FUNC initosutil(void)
572 572 {
573 573 if (PyType_Ready(&listdir_stat_type) == -1)
574 574 return;
575 575
576 576 Py_InitModule3("osutil", methods, osutil_doc);
577 577 }
578 578 #endif
@@ -1,449 +1,452
1 1 # win32.py - utility functions that use win32 API
2 2 #
3 3 # Copyright 2005-2009 Matt Mackall <mpm@selenic.com> and others
4 4 #
5 5 # This software may be used and distributed according to the terms of the
6 6 # GNU General Public License version 2 or any later version.
7 7
8 8 import encoding
9 9 import ctypes, errno, os, struct, subprocess, random
10 10
11 11 _kernel32 = ctypes.windll.kernel32
12 12 _advapi32 = ctypes.windll.advapi32
13 13 _user32 = ctypes.windll.user32
14 14
15 15 _BOOL = ctypes.c_long
16 16 _WORD = ctypes.c_ushort
17 17 _DWORD = ctypes.c_ulong
18 18 _UINT = ctypes.c_uint
19 19 _LONG = ctypes.c_long
20 20 _LPCSTR = _LPSTR = ctypes.c_char_p
21 21 _HANDLE = ctypes.c_void_p
22 22 _HWND = _HANDLE
23 23
24 24 _INVALID_HANDLE_VALUE = _HANDLE(-1).value
25 25
26 26 # GetLastError
27 27 _ERROR_SUCCESS = 0
28 28 _ERROR_INVALID_PARAMETER = 87
29 29 _ERROR_INSUFFICIENT_BUFFER = 122
30 30
31 31 # WPARAM is defined as UINT_PTR (unsigned type)
32 32 # LPARAM is defined as LONG_PTR (signed type)
33 33 if ctypes.sizeof(ctypes.c_long) == ctypes.sizeof(ctypes.c_void_p):
34 34 _WPARAM = ctypes.c_ulong
35 35 _LPARAM = ctypes.c_long
36 36 elif ctypes.sizeof(ctypes.c_longlong) == ctypes.sizeof(ctypes.c_void_p):
37 37 _WPARAM = ctypes.c_ulonglong
38 38 _LPARAM = ctypes.c_longlong
39 39
40 40 class _FILETIME(ctypes.Structure):
41 41 _fields_ = [('dwLowDateTime', _DWORD),
42 42 ('dwHighDateTime', _DWORD)]
43 43
44 44 class _BY_HANDLE_FILE_INFORMATION(ctypes.Structure):
45 45 _fields_ = [('dwFileAttributes', _DWORD),
46 46 ('ftCreationTime', _FILETIME),
47 47 ('ftLastAccessTime', _FILETIME),
48 48 ('ftLastWriteTime', _FILETIME),
49 49 ('dwVolumeSerialNumber', _DWORD),
50 50 ('nFileSizeHigh', _DWORD),
51 51 ('nFileSizeLow', _DWORD),
52 52 ('nNumberOfLinks', _DWORD),
53 53 ('nFileIndexHigh', _DWORD),
54 54 ('nFileIndexLow', _DWORD)]
55 55
56 56 # CreateFile
57 57 _FILE_SHARE_READ = 0x00000001
58 58 _FILE_SHARE_WRITE = 0x00000002
59 59 _FILE_SHARE_DELETE = 0x00000004
60 60
61 61 _OPEN_EXISTING = 3
62 62
63 63 # SetFileAttributes
64 64 _FILE_ATTRIBUTE_NORMAL = 0x80
65 65 _FILE_ATTRIBUTE_NOT_CONTENT_INDEXED = 0x2000
66 66
67 67 # Process Security and Access Rights
68 68 _PROCESS_QUERY_INFORMATION = 0x0400
69 69
70 70 # GetExitCodeProcess
71 71 _STILL_ACTIVE = 259
72 72
73 73 # registry
74 74 _HKEY_CURRENT_USER = 0x80000001L
75 75 _HKEY_LOCAL_MACHINE = 0x80000002L
76 76 _KEY_READ = 0x20019
77 77 _REG_SZ = 1
78 78 _REG_DWORD = 4
79 79
80 80 class _STARTUPINFO(ctypes.Structure):
81 81 _fields_ = [('cb', _DWORD),
82 82 ('lpReserved', _LPSTR),
83 83 ('lpDesktop', _LPSTR),
84 84 ('lpTitle', _LPSTR),
85 85 ('dwX', _DWORD),
86 86 ('dwY', _DWORD),
87 87 ('dwXSize', _DWORD),
88 88 ('dwYSize', _DWORD),
89 89 ('dwXCountChars', _DWORD),
90 90 ('dwYCountChars', _DWORD),
91 91 ('dwFillAttribute', _DWORD),
92 92 ('dwFlags', _DWORD),
93 93 ('wShowWindow', _WORD),
94 94 ('cbReserved2', _WORD),
95 95 ('lpReserved2', ctypes.c_char_p),
96 96 ('hStdInput', _HANDLE),
97 97 ('hStdOutput', _HANDLE),
98 98 ('hStdError', _HANDLE)]
99 99
100 100 class _PROCESS_INFORMATION(ctypes.Structure):
101 101 _fields_ = [('hProcess', _HANDLE),
102 102 ('hThread', _HANDLE),
103 103 ('dwProcessId', _DWORD),
104 104 ('dwThreadId', _DWORD)]
105 105
106 106 _DETACHED_PROCESS = 0x00000008
107 107 _STARTF_USESHOWWINDOW = 0x00000001
108 108 _SW_HIDE = 0
109 109
110 110 class _COORD(ctypes.Structure):
111 111 _fields_ = [('X', ctypes.c_short),
112 112 ('Y', ctypes.c_short)]
113 113
114 114 class _SMALL_RECT(ctypes.Structure):
115 115 _fields_ = [('Left', ctypes.c_short),
116 116 ('Top', ctypes.c_short),
117 117 ('Right', ctypes.c_short),
118 118 ('Bottom', ctypes.c_short)]
119 119
120 120 class _CONSOLE_SCREEN_BUFFER_INFO(ctypes.Structure):
121 121 _fields_ = [('dwSize', _COORD),
122 122 ('dwCursorPosition', _COORD),
123 123 ('wAttributes', _WORD),
124 124 ('srWindow', _SMALL_RECT),
125 125 ('dwMaximumWindowSize', _COORD)]
126 126
127 127 _STD_ERROR_HANDLE = _DWORD(-12).value
128 128
129 129 # types of parameters of C functions used (required by pypy)
130 130
131 131 _kernel32.CreateFileA.argtypes = [_LPCSTR, _DWORD, _DWORD, ctypes.c_void_p,
132 132 _DWORD, _DWORD, _HANDLE]
133 133 _kernel32.CreateFileA.restype = _HANDLE
134 134
135 135 _kernel32.GetFileInformationByHandle.argtypes = [_HANDLE, ctypes.c_void_p]
136 136 _kernel32.GetFileInformationByHandle.restype = _BOOL
137 137
138 138 _kernel32.CloseHandle.argtypes = [_HANDLE]
139 139 _kernel32.CloseHandle.restype = _BOOL
140 140
141 _kernel32.CreateHardLinkA.argtypes = [_LPCSTR, _LPCSTR, ctypes.c_void_p]
142 _kernel32.CreateHardLinkA.restype = _BOOL
141 try:
142 _kernel32.CreateHardLinkA.argtypes = [_LPCSTR, _LPCSTR, ctypes.c_void_p]
143 _kernel32.CreateHardLinkA.restype = _BOOL
144 except AttributeError:
145 pass
143 146
144 147 _kernel32.SetFileAttributesA.argtypes = [_LPCSTR, _DWORD]
145 148 _kernel32.SetFileAttributesA.restype = _BOOL
146 149
147 150 _kernel32.OpenProcess.argtypes = [_DWORD, _BOOL, _DWORD]
148 151 _kernel32.OpenProcess.restype = _HANDLE
149 152
150 153 _kernel32.GetExitCodeProcess.argtypes = [_HANDLE, ctypes.c_void_p]
151 154 _kernel32.GetExitCodeProcess.restype = _BOOL
152 155
153 156 _kernel32.GetLastError.argtypes = []
154 157 _kernel32.GetLastError.restype = _DWORD
155 158
156 159 _kernel32.GetModuleFileNameA.argtypes = [_HANDLE, ctypes.c_void_p, _DWORD]
157 160 _kernel32.GetModuleFileNameA.restype = _DWORD
158 161
159 162 _kernel32.CreateProcessA.argtypes = [_LPCSTR, _LPCSTR, ctypes.c_void_p,
160 163 ctypes.c_void_p, _BOOL, _DWORD, ctypes.c_void_p, _LPCSTR, ctypes.c_void_p,
161 164 ctypes.c_void_p]
162 165 _kernel32.CreateProcessA.restype = _BOOL
163 166
164 167 _kernel32.ExitProcess.argtypes = [_UINT]
165 168 _kernel32.ExitProcess.restype = None
166 169
167 170 _kernel32.GetCurrentProcessId.argtypes = []
168 171 _kernel32.GetCurrentProcessId.restype = _DWORD
169 172
170 173 _SIGNAL_HANDLER = ctypes.WINFUNCTYPE(_BOOL, _DWORD)
171 174 _kernel32.SetConsoleCtrlHandler.argtypes = [_SIGNAL_HANDLER, _BOOL]
172 175 _kernel32.SetConsoleCtrlHandler.restype = _BOOL
173 176
174 177 _kernel32.GetStdHandle.argtypes = [_DWORD]
175 178 _kernel32.GetStdHandle.restype = _HANDLE
176 179
177 180 _kernel32.GetConsoleScreenBufferInfo.argtypes = [_HANDLE, ctypes.c_void_p]
178 181 _kernel32.GetConsoleScreenBufferInfo.restype = _BOOL
179 182
180 183 _advapi32.RegOpenKeyExA.argtypes = [_HANDLE, _LPCSTR, _DWORD, _DWORD,
181 184 ctypes.c_void_p]
182 185 _advapi32.RegOpenKeyExA.restype = _LONG
183 186
184 187 _advapi32.RegQueryValueExA.argtypes = [_HANDLE, _LPCSTR, ctypes.c_void_p,
185 188 ctypes.c_void_p, ctypes.c_void_p, ctypes.c_void_p]
186 189 _advapi32.RegQueryValueExA.restype = _LONG
187 190
188 191 _advapi32.RegCloseKey.argtypes = [_HANDLE]
189 192 _advapi32.RegCloseKey.restype = _LONG
190 193
191 194 _advapi32.GetUserNameA.argtypes = [ctypes.c_void_p, ctypes.c_void_p]
192 195 _advapi32.GetUserNameA.restype = _BOOL
193 196
194 197 _user32.GetWindowThreadProcessId.argtypes = [_HANDLE, ctypes.c_void_p]
195 198 _user32.GetWindowThreadProcessId.restype = _DWORD
196 199
197 200 _user32.ShowWindow.argtypes = [_HANDLE, ctypes.c_int]
198 201 _user32.ShowWindow.restype = _BOOL
199 202
200 203 _WNDENUMPROC = ctypes.WINFUNCTYPE(_BOOL, _HWND, _LPARAM)
201 204 _user32.EnumWindows.argtypes = [_WNDENUMPROC, _LPARAM]
202 205 _user32.EnumWindows.restype = _BOOL
203 206
204 207 def _raiseoserror(name):
205 208 err = ctypes.WinError()
206 209 raise OSError(err.errno, '%s: %s' % (name, err.strerror))
207 210
208 211 def _getfileinfo(name):
209 212 fh = _kernel32.CreateFileA(name, 0,
210 213 _FILE_SHARE_READ | _FILE_SHARE_WRITE | _FILE_SHARE_DELETE,
211 214 None, _OPEN_EXISTING, 0, None)
212 215 if fh == _INVALID_HANDLE_VALUE:
213 216 _raiseoserror(name)
214 217 try:
215 218 fi = _BY_HANDLE_FILE_INFORMATION()
216 219 if not _kernel32.GetFileInformationByHandle(fh, ctypes.byref(fi)):
217 220 _raiseoserror(name)
218 221 return fi
219 222 finally:
220 223 _kernel32.CloseHandle(fh)
221 224
222 225 def oslink(src, dst):
223 226 try:
224 227 if not _kernel32.CreateHardLinkA(dst, src, None):
225 228 _raiseoserror(src)
226 229 except AttributeError: # Wine doesn't support this function
227 230 _raiseoserror(src)
228 231
229 232 def nlinks(name):
230 233 '''return number of hardlinks for the given file'''
231 234 return _getfileinfo(name).nNumberOfLinks
232 235
233 236 def samefile(fpath1, fpath2):
234 237 '''Returns whether fpath1 and fpath2 refer to the same file. This is only
235 238 guaranteed to work for files, not directories.'''
236 239 res1 = _getfileinfo(fpath1)
237 240 res2 = _getfileinfo(fpath2)
238 241 return (res1.dwVolumeSerialNumber == res2.dwVolumeSerialNumber
239 242 and res1.nFileIndexHigh == res2.nFileIndexHigh
240 243 and res1.nFileIndexLow == res2.nFileIndexLow)
241 244
242 245 def samedevice(fpath1, fpath2):
243 246 '''Returns whether fpath1 and fpath2 are on the same device. This is only
244 247 guaranteed to work for files, not directories.'''
245 248 res1 = _getfileinfo(fpath1)
246 249 res2 = _getfileinfo(fpath2)
247 250 return res1.dwVolumeSerialNumber == res2.dwVolumeSerialNumber
248 251
249 252 def testpid(pid):
250 253 '''return True if pid is still running or unable to
251 254 determine, False otherwise'''
252 255 h = _kernel32.OpenProcess(_PROCESS_QUERY_INFORMATION, False, pid)
253 256 if h:
254 257 try:
255 258 status = _DWORD()
256 259 if _kernel32.GetExitCodeProcess(h, ctypes.byref(status)):
257 260 return status.value == _STILL_ACTIVE
258 261 finally:
259 262 _kernel32.CloseHandle(h)
260 263 return _kernel32.GetLastError() != _ERROR_INVALID_PARAMETER
261 264
262 265 def lookupreg(key, valname=None, scope=None):
263 266 ''' Look up a key/value name in the Windows registry.
264 267
265 268 valname: value name. If unspecified, the default value for the key
266 269 is used.
267 270 scope: optionally specify scope for registry lookup, this can be
268 271 a sequence of scopes to look up in order. Default (CURRENT_USER,
269 272 LOCAL_MACHINE).
270 273 '''
271 274 byref = ctypes.byref
272 275 if scope is None:
273 276 scope = (_HKEY_CURRENT_USER, _HKEY_LOCAL_MACHINE)
274 277 elif not isinstance(scope, (list, tuple)):
275 278 scope = (scope,)
276 279 for s in scope:
277 280 kh = _HANDLE()
278 281 res = _advapi32.RegOpenKeyExA(s, key, 0, _KEY_READ, ctypes.byref(kh))
279 282 if res != _ERROR_SUCCESS:
280 283 continue
281 284 try:
282 285 size = _DWORD(600)
283 286 type = _DWORD()
284 287 buf = ctypes.create_string_buffer(size.value + 1)
285 288 res = _advapi32.RegQueryValueExA(kh.value, valname, None,
286 289 byref(type), buf, byref(size))
287 290 if res != _ERROR_SUCCESS:
288 291 continue
289 292 if type.value == _REG_SZ:
290 293 # never let a Unicode string escape into the wild
291 294 return encoding.tolocal(buf.value.encode('UTF-8'))
292 295 elif type.value == _REG_DWORD:
293 296 fmt = '<L'
294 297 s = ctypes.string_at(byref(buf), struct.calcsize(fmt))
295 298 return struct.unpack(fmt, s)[0]
296 299 finally:
297 300 _advapi32.RegCloseKey(kh.value)
298 301
299 302 def executablepath():
300 303 '''return full path of hg.exe'''
301 304 size = 600
302 305 buf = ctypes.create_string_buffer(size + 1)
303 306 len = _kernel32.GetModuleFileNameA(None, ctypes.byref(buf), size)
304 307 if len == 0:
305 308 raise ctypes.WinError()
306 309 elif len == size:
307 310 raise ctypes.WinError(_ERROR_INSUFFICIENT_BUFFER)
308 311 return buf.value
309 312
310 313 def getuser():
311 314 '''return name of current user'''
312 315 size = _DWORD(300)
313 316 buf = ctypes.create_string_buffer(size.value + 1)
314 317 if not _advapi32.GetUserNameA(ctypes.byref(buf), ctypes.byref(size)):
315 318 raise ctypes.WinError()
316 319 return buf.value
317 320
318 321 _signalhandler = []
319 322
320 323 def setsignalhandler():
321 324 '''Register a termination handler for console events including
322 325 CTRL+C. python signal handlers do not work well with socket
323 326 operations.
324 327 '''
325 328 def handler(event):
326 329 _kernel32.ExitProcess(1)
327 330
328 331 if _signalhandler:
329 332 return # already registered
330 333 h = _SIGNAL_HANDLER(handler)
331 334 _signalhandler.append(h) # needed to prevent garbage collection
332 335 if not _kernel32.SetConsoleCtrlHandler(h, True):
333 336 raise ctypes.WinError()
334 337
335 338 def hidewindow():
336 339
337 340 def callback(hwnd, pid):
338 341 wpid = _DWORD()
339 342 _user32.GetWindowThreadProcessId(hwnd, ctypes.byref(wpid))
340 343 if pid == wpid.value:
341 344 _user32.ShowWindow(hwnd, _SW_HIDE)
342 345 return False # stop enumerating windows
343 346 return True
344 347
345 348 pid = _kernel32.GetCurrentProcessId()
346 349 _user32.EnumWindows(_WNDENUMPROC(callback), pid)
347 350
348 351 def termwidth():
349 352 # cmd.exe does not handle CR like a unix console, the CR is
350 353 # counted in the line length. On 80 columns consoles, if 80
351 354 # characters are written, the following CR won't apply on the
352 355 # current line but on the new one. Keep room for it.
353 356 width = 79
354 357 # Query stderr to avoid problems with redirections
355 358 screenbuf = _kernel32.GetStdHandle(
356 359 _STD_ERROR_HANDLE) # don't close the handle returned
357 360 if screenbuf is None or screenbuf == _INVALID_HANDLE_VALUE:
358 361 return width
359 362 csbi = _CONSOLE_SCREEN_BUFFER_INFO()
360 363 if not _kernel32.GetConsoleScreenBufferInfo(
361 364 screenbuf, ctypes.byref(csbi)):
362 365 return width
363 366 width = csbi.srWindow.Right - csbi.srWindow.Left
364 367 return width
365 368
366 369 def spawndetached(args):
367 370 # No standard library function really spawns a fully detached
368 371 # process under win32 because they allocate pipes or other objects
369 372 # to handle standard streams communications. Passing these objects
370 373 # to the child process requires handle inheritance to be enabled
371 374 # which makes really detached processes impossible.
372 375 si = _STARTUPINFO()
373 376 si.cb = ctypes.sizeof(_STARTUPINFO)
374 377 si.dwFlags = _STARTF_USESHOWWINDOW
375 378 si.wShowWindow = _SW_HIDE
376 379
377 380 pi = _PROCESS_INFORMATION()
378 381
379 382 env = ''
380 383 for k in os.environ:
381 384 env += "%s=%s\0" % (k, os.environ[k])
382 385 if not env:
383 386 env = '\0'
384 387 env += '\0'
385 388
386 389 args = subprocess.list2cmdline(args)
387 390 # Not running the command in shell mode makes python26 hang when
388 391 # writing to hgweb output socket.
389 392 comspec = os.environ.get("COMSPEC", "cmd.exe")
390 393 args = comspec + " /c " + args
391 394
392 395 res = _kernel32.CreateProcessA(
393 396 None, args, None, None, False, _DETACHED_PROCESS,
394 397 env, os.getcwd(), ctypes.byref(si), ctypes.byref(pi))
395 398 if not res:
396 399 raise ctypes.WinError()
397 400
398 401 return pi.dwProcessId
399 402
400 403 def unlink(f):
401 404 '''try to implement POSIX' unlink semantics on Windows'''
402 405
403 406 # POSIX allows to unlink and rename open files. Windows has serious
404 407 # problems with doing that:
405 408 # - Calling os.unlink (or os.rename) on a file f fails if f or any
406 409 # hardlinked copy of f has been opened with Python's open(). There is no
407 410 # way such a file can be deleted or renamed on Windows (other than
408 411 # scheduling the delete or rename for the next reboot).
409 412 # - Calling os.unlink on a file that has been opened with Mercurial's
410 413 # posixfile (or comparable methods) will delay the actual deletion of
411 414 # the file for as long as the file is held open. The filename is blocked
412 415 # during that time and cannot be used for recreating a new file under
413 416 # that same name ("zombie file"). Directories containing such zombie files
414 417 # cannot be removed or moved.
415 418 # A file that has been opened with posixfile can be renamed, so we rename
416 419 # f to a random temporary name before calling os.unlink on it. This allows
417 420 # callers to recreate f immediately while having other readers do their
418 421 # implicit zombie filename blocking on a temporary name.
419 422
420 423 for tries in xrange(10):
421 424 temp = '%s-%08x' % (f, random.randint(0, 0xffffffff))
422 425 try:
423 426 os.rename(f, temp) # raises OSError EEXIST if temp exists
424 427 break
425 428 except OSError, e:
426 429 if e.errno != errno.EEXIST:
427 430 raise
428 431 else:
429 432 raise IOError, (errno.EEXIST, "No usable temporary filename found")
430 433
431 434 try:
432 435 os.unlink(temp)
433 436 except OSError:
434 437 # The unlink might have failed because the READONLY attribute may heave
435 438 # been set on the original file. Rename works fine with READONLY set,
436 439 # but not os.unlink. Reset all attributes and try again.
437 440 _kernel32.SetFileAttributesA(temp, _FILE_ATTRIBUTE_NORMAL)
438 441 try:
439 442 os.unlink(temp)
440 443 except OSError:
441 444 # The unlink might have failed due to some very rude AV-Scanners.
442 445 # Leaking a tempfile is the lesser evil than aborting here and
443 446 # leaving some potentially serious inconsistencies.
444 447 pass
445 448
446 449 def makedir(path, notindexed):
447 450 os.mkdir(path)
448 451 if notindexed:
449 452 _kernel32.SetFileAttributesA(path, _FILE_ATTRIBUTE_NOT_CONTENT_INDEXED)
General Comments 0
You need to be logged in to leave comments. Login now