##// END OF EJS Templates
osutil: add version to help detect breaking binary changes...
Jun Wu -
r32359:dc51700b default
parent child Browse files
Show More
@@ -1,1328 +1,1335 b''
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 <stdlib.h>
15 15 #include <string.h>
16 16 #include <errno.h>
17 17
18 18 #ifdef _WIN32
19 19 #include <windows.h>
20 20 #include <io.h>
21 21 #else
22 22 #include <dirent.h>
23 23 #include <sys/socket.h>
24 24 #include <sys/stat.h>
25 25 #include <sys/types.h>
26 26 #include <unistd.h>
27 27 #ifdef HAVE_LINUX_STATFS
28 28 #include <linux/magic.h>
29 29 #include <sys/vfs.h>
30 30 #endif
31 31 #ifdef HAVE_BSD_STATFS
32 32 #include <sys/mount.h>
33 33 #include <sys/param.h>
34 34 #endif
35 35 #endif
36 36
37 37 #ifdef __APPLE__
38 38 #include <sys/attr.h>
39 39 #include <sys/vnode.h>
40 40 #endif
41 41
42 42 #include "util.h"
43 43
44 44 /* some platforms lack the PATH_MAX definition (eg. GNU/Hurd) */
45 45 #ifndef PATH_MAX
46 46 #define PATH_MAX 4096
47 47 #endif
48 48
49 49 #ifdef _WIN32
50 50 /*
51 51 stat struct compatible with hg expectations
52 52 Mercurial only uses st_mode, st_size and st_mtime
53 53 the rest is kept to minimize changes between implementations
54 54 */
55 55 struct hg_stat {
56 56 int st_dev;
57 57 int st_mode;
58 58 int st_nlink;
59 59 __int64 st_size;
60 60 int st_mtime;
61 61 int st_ctime;
62 62 };
63 63 struct listdir_stat {
64 64 PyObject_HEAD
65 65 struct hg_stat st;
66 66 };
67 67 #else
68 68 struct listdir_stat {
69 69 PyObject_HEAD
70 70 struct stat st;
71 71 };
72 72 #endif
73 73
74 74 #ifdef IS_PY3K
75 75 #define listdir_slot(name) \
76 76 static PyObject *listdir_stat_##name(PyObject *self, void *x) \
77 77 { \
78 78 return PyLong_FromLong(((struct listdir_stat *)self)->st.name); \
79 79 }
80 80 #else
81 81 #define listdir_slot(name) \
82 82 static PyObject *listdir_stat_##name(PyObject *self, void *x) \
83 83 { \
84 84 return PyInt_FromLong(((struct listdir_stat *)self)->st.name); \
85 85 }
86 86 #endif
87 87
88 88 listdir_slot(st_dev)
89 89 listdir_slot(st_mode)
90 90 listdir_slot(st_nlink)
91 91 #ifdef _WIN32
92 92 static PyObject *listdir_stat_st_size(PyObject *self, void *x)
93 93 {
94 94 return PyLong_FromLongLong(
95 95 (PY_LONG_LONG)((struct listdir_stat *)self)->st.st_size);
96 96 }
97 97 #else
98 98 listdir_slot(st_size)
99 99 #endif
100 100 listdir_slot(st_mtime)
101 101 listdir_slot(st_ctime)
102 102
103 103 static struct PyGetSetDef listdir_stat_getsets[] = {
104 104 {"st_dev", listdir_stat_st_dev, 0, 0, 0},
105 105 {"st_mode", listdir_stat_st_mode, 0, 0, 0},
106 106 {"st_nlink", listdir_stat_st_nlink, 0, 0, 0},
107 107 {"st_size", listdir_stat_st_size, 0, 0, 0},
108 108 {"st_mtime", listdir_stat_st_mtime, 0, 0, 0},
109 109 {"st_ctime", listdir_stat_st_ctime, 0, 0, 0},
110 110 {0, 0, 0, 0, 0}
111 111 };
112 112
113 113 static PyObject *listdir_stat_new(PyTypeObject *t, PyObject *a, PyObject *k)
114 114 {
115 115 return t->tp_alloc(t, 0);
116 116 }
117 117
118 118 static void listdir_stat_dealloc(PyObject *o)
119 119 {
120 120 o->ob_type->tp_free(o);
121 121 }
122 122
123 123 static PyTypeObject listdir_stat_type = {
124 124 PyVarObject_HEAD_INIT(NULL, 0)
125 125 "osutil.stat", /*tp_name*/
126 126 sizeof(struct listdir_stat), /*tp_basicsize*/
127 127 0, /*tp_itemsize*/
128 128 (destructor)listdir_stat_dealloc, /*tp_dealloc*/
129 129 0, /*tp_print*/
130 130 0, /*tp_getattr*/
131 131 0, /*tp_setattr*/
132 132 0, /*tp_compare*/
133 133 0, /*tp_repr*/
134 134 0, /*tp_as_number*/
135 135 0, /*tp_as_sequence*/
136 136 0, /*tp_as_mapping*/
137 137 0, /*tp_hash */
138 138 0, /*tp_call*/
139 139 0, /*tp_str*/
140 140 0, /*tp_getattro*/
141 141 0, /*tp_setattro*/
142 142 0, /*tp_as_buffer*/
143 143 Py_TPFLAGS_DEFAULT | Py_TPFLAGS_BASETYPE, /*tp_flags*/
144 144 "stat objects", /* tp_doc */
145 145 0, /* tp_traverse */
146 146 0, /* tp_clear */
147 147 0, /* tp_richcompare */
148 148 0, /* tp_weaklistoffset */
149 149 0, /* tp_iter */
150 150 0, /* tp_iternext */
151 151 0, /* tp_methods */
152 152 0, /* tp_members */
153 153 listdir_stat_getsets, /* tp_getset */
154 154 0, /* tp_base */
155 155 0, /* tp_dict */
156 156 0, /* tp_descr_get */
157 157 0, /* tp_descr_set */
158 158 0, /* tp_dictoffset */
159 159 0, /* tp_init */
160 160 0, /* tp_alloc */
161 161 listdir_stat_new, /* tp_new */
162 162 };
163 163
164 164 #ifdef _WIN32
165 165
166 166 static int to_python_time(const FILETIME *tm)
167 167 {
168 168 /* number of seconds between epoch and January 1 1601 */
169 169 const __int64 a0 = (__int64)134774L * (__int64)24L * (__int64)3600L;
170 170 /* conversion factor from 100ns to 1s */
171 171 const __int64 a1 = 10000000;
172 172 /* explicit (int) cast to suspend compiler warnings */
173 173 return (int)((((__int64)tm->dwHighDateTime << 32)
174 174 + tm->dwLowDateTime) / a1 - a0);
175 175 }
176 176
177 177 static PyObject *make_item(const WIN32_FIND_DATAA *fd, int wantstat)
178 178 {
179 179 PyObject *py_st;
180 180 struct hg_stat *stp;
181 181
182 182 int kind = (fd->dwFileAttributes & FILE_ATTRIBUTE_DIRECTORY)
183 183 ? _S_IFDIR : _S_IFREG;
184 184
185 185 if (!wantstat)
186 186 return Py_BuildValue("si", fd->cFileName, kind);
187 187
188 188 py_st = PyObject_CallObject((PyObject *)&listdir_stat_type, NULL);
189 189 if (!py_st)
190 190 return NULL;
191 191
192 192 stp = &((struct listdir_stat *)py_st)->st;
193 193 /*
194 194 use kind as st_mode
195 195 rwx bits on Win32 are meaningless
196 196 and Hg does not use them anyway
197 197 */
198 198 stp->st_mode = kind;
199 199 stp->st_mtime = to_python_time(&fd->ftLastWriteTime);
200 200 stp->st_ctime = to_python_time(&fd->ftCreationTime);
201 201 if (kind == _S_IFREG)
202 202 stp->st_size = ((__int64)fd->nFileSizeHigh << 32)
203 203 + fd->nFileSizeLow;
204 204 return Py_BuildValue("siN", fd->cFileName,
205 205 kind, py_st);
206 206 }
207 207
208 208 static PyObject *_listdir(char *path, int plen, int wantstat, char *skip)
209 209 {
210 210 PyObject *rval = NULL; /* initialize - return value */
211 211 PyObject *list;
212 212 HANDLE fh;
213 213 WIN32_FIND_DATAA fd;
214 214 char *pattern;
215 215
216 216 /* build the path + \* pattern string */
217 217 pattern = PyMem_Malloc(plen + 3); /* path + \* + \0 */
218 218 if (!pattern) {
219 219 PyErr_NoMemory();
220 220 goto error_nomem;
221 221 }
222 222 memcpy(pattern, path, plen);
223 223
224 224 if (plen > 0) {
225 225 char c = path[plen-1];
226 226 if (c != ':' && c != '/' && c != '\\')
227 227 pattern[plen++] = '\\';
228 228 }
229 229 pattern[plen++] = '*';
230 230 pattern[plen] = '\0';
231 231
232 232 fh = FindFirstFileA(pattern, &fd);
233 233 if (fh == INVALID_HANDLE_VALUE) {
234 234 PyErr_SetFromWindowsErrWithFilename(GetLastError(), path);
235 235 goto error_file;
236 236 }
237 237
238 238 list = PyList_New(0);
239 239 if (!list)
240 240 goto error_list;
241 241
242 242 do {
243 243 PyObject *item;
244 244
245 245 if (fd.dwFileAttributes & FILE_ATTRIBUTE_DIRECTORY) {
246 246 if (!strcmp(fd.cFileName, ".")
247 247 || !strcmp(fd.cFileName, ".."))
248 248 continue;
249 249
250 250 if (skip && !strcmp(fd.cFileName, skip)) {
251 251 rval = PyList_New(0);
252 252 goto error;
253 253 }
254 254 }
255 255
256 256 item = make_item(&fd, wantstat);
257 257 if (!item)
258 258 goto error;
259 259
260 260 if (PyList_Append(list, item)) {
261 261 Py_XDECREF(item);
262 262 goto error;
263 263 }
264 264
265 265 Py_XDECREF(item);
266 266 } while (FindNextFileA(fh, &fd));
267 267
268 268 if (GetLastError() != ERROR_NO_MORE_FILES) {
269 269 PyErr_SetFromWindowsErrWithFilename(GetLastError(), path);
270 270 goto error;
271 271 }
272 272
273 273 rval = list;
274 274 Py_XINCREF(rval);
275 275 error:
276 276 Py_XDECREF(list);
277 277 error_list:
278 278 FindClose(fh);
279 279 error_file:
280 280 PyMem_Free(pattern);
281 281 error_nomem:
282 282 return rval;
283 283 }
284 284
285 285 #else
286 286
287 287 int entkind(struct dirent *ent)
288 288 {
289 289 #ifdef DT_REG
290 290 switch (ent->d_type) {
291 291 case DT_REG: return S_IFREG;
292 292 case DT_DIR: return S_IFDIR;
293 293 case DT_LNK: return S_IFLNK;
294 294 case DT_BLK: return S_IFBLK;
295 295 case DT_CHR: return S_IFCHR;
296 296 case DT_FIFO: return S_IFIFO;
297 297 case DT_SOCK: return S_IFSOCK;
298 298 }
299 299 #endif
300 300 return -1;
301 301 }
302 302
303 303 static PyObject *makestat(const struct stat *st)
304 304 {
305 305 PyObject *stat;
306 306
307 307 stat = PyObject_CallObject((PyObject *)&listdir_stat_type, NULL);
308 308 if (stat)
309 309 memcpy(&((struct listdir_stat *)stat)->st, st, sizeof(*st));
310 310 return stat;
311 311 }
312 312
313 313 static PyObject *_listdir_stat(char *path, int pathlen, int keepstat,
314 314 char *skip)
315 315 {
316 316 PyObject *list, *elem, *stat = NULL, *ret = NULL;
317 317 char fullpath[PATH_MAX + 10];
318 318 int kind, err;
319 319 struct stat st;
320 320 struct dirent *ent;
321 321 DIR *dir;
322 322 #ifdef AT_SYMLINK_NOFOLLOW
323 323 int dfd = -1;
324 324 #endif
325 325
326 326 if (pathlen >= PATH_MAX) {
327 327 errno = ENAMETOOLONG;
328 328 PyErr_SetFromErrnoWithFilename(PyExc_OSError, path);
329 329 goto error_value;
330 330 }
331 331 strncpy(fullpath, path, PATH_MAX);
332 332 fullpath[pathlen] = '/';
333 333
334 334 #ifdef AT_SYMLINK_NOFOLLOW
335 335 dfd = open(path, O_RDONLY);
336 336 if (dfd == -1) {
337 337 PyErr_SetFromErrnoWithFilename(PyExc_OSError, path);
338 338 goto error_value;
339 339 }
340 340 dir = fdopendir(dfd);
341 341 #else
342 342 dir = opendir(path);
343 343 #endif
344 344 if (!dir) {
345 345 PyErr_SetFromErrnoWithFilename(PyExc_OSError, path);
346 346 goto error_dir;
347 347 }
348 348
349 349 list = PyList_New(0);
350 350 if (!list)
351 351 goto error_list;
352 352
353 353 while ((ent = readdir(dir))) {
354 354 if (!strcmp(ent->d_name, ".") || !strcmp(ent->d_name, ".."))
355 355 continue;
356 356
357 357 kind = entkind(ent);
358 358 if (kind == -1 || keepstat) {
359 359 #ifdef AT_SYMLINK_NOFOLLOW
360 360 err = fstatat(dfd, ent->d_name, &st,
361 361 AT_SYMLINK_NOFOLLOW);
362 362 #else
363 363 strncpy(fullpath + pathlen + 1, ent->d_name,
364 364 PATH_MAX - pathlen);
365 365 fullpath[PATH_MAX] = '\0';
366 366 err = lstat(fullpath, &st);
367 367 #endif
368 368 if (err == -1) {
369 369 /* race with file deletion? */
370 370 if (errno == ENOENT)
371 371 continue;
372 372 strncpy(fullpath + pathlen + 1, ent->d_name,
373 373 PATH_MAX - pathlen);
374 374 fullpath[PATH_MAX] = 0;
375 375 PyErr_SetFromErrnoWithFilename(PyExc_OSError,
376 376 fullpath);
377 377 goto error;
378 378 }
379 379 kind = st.st_mode & S_IFMT;
380 380 }
381 381
382 382 /* quit early? */
383 383 if (skip && kind == S_IFDIR && !strcmp(ent->d_name, skip)) {
384 384 ret = PyList_New(0);
385 385 goto error;
386 386 }
387 387
388 388 if (keepstat) {
389 389 stat = makestat(&st);
390 390 if (!stat)
391 391 goto error;
392 392 elem = Py_BuildValue("siN", ent->d_name, kind, stat);
393 393 } else
394 394 elem = Py_BuildValue("si", ent->d_name, kind);
395 395 if (!elem)
396 396 goto error;
397 397 stat = NULL;
398 398
399 399 PyList_Append(list, elem);
400 400 Py_DECREF(elem);
401 401 }
402 402
403 403 ret = list;
404 404 Py_INCREF(ret);
405 405
406 406 error:
407 407 Py_DECREF(list);
408 408 Py_XDECREF(stat);
409 409 error_list:
410 410 closedir(dir);
411 411 /* closedir also closes its dirfd */
412 412 goto error_value;
413 413 error_dir:
414 414 #ifdef AT_SYMLINK_NOFOLLOW
415 415 close(dfd);
416 416 #endif
417 417 error_value:
418 418 return ret;
419 419 }
420 420
421 421 #ifdef __APPLE__
422 422
423 423 typedef struct {
424 424 u_int32_t length;
425 425 attrreference_t name;
426 426 fsobj_type_t obj_type;
427 427 struct timespec mtime;
428 428 #if __LITTLE_ENDIAN__
429 429 mode_t access_mask;
430 430 uint16_t padding;
431 431 #else
432 432 uint16_t padding;
433 433 mode_t access_mask;
434 434 #endif
435 435 off_t size;
436 436 } __attribute__((packed)) attrbuf_entry;
437 437
438 438 int attrkind(attrbuf_entry *entry)
439 439 {
440 440 switch (entry->obj_type) {
441 441 case VREG: return S_IFREG;
442 442 case VDIR: return S_IFDIR;
443 443 case VLNK: return S_IFLNK;
444 444 case VBLK: return S_IFBLK;
445 445 case VCHR: return S_IFCHR;
446 446 case VFIFO: return S_IFIFO;
447 447 case VSOCK: return S_IFSOCK;
448 448 }
449 449 return -1;
450 450 }
451 451
452 452 /* get these many entries at a time */
453 453 #define LISTDIR_BATCH_SIZE 50
454 454
455 455 static PyObject *_listdir_batch(char *path, int pathlen, int keepstat,
456 456 char *skip, bool *fallback)
457 457 {
458 458 PyObject *list, *elem, *stat = NULL, *ret = NULL;
459 459 int kind, err;
460 460 unsigned long index;
461 461 unsigned int count, old_state, new_state;
462 462 bool state_seen = false;
463 463 attrbuf_entry *entry;
464 464 /* from the getattrlist(2) man page: a path can be no longer than
465 465 (NAME_MAX * 3 + 1) bytes. Also, "The getattrlist() function will
466 466 silently truncate attribute data if attrBufSize is too small." So
467 467 pass in a buffer big enough for the worst case. */
468 468 char attrbuf[LISTDIR_BATCH_SIZE * (sizeof(attrbuf_entry) + NAME_MAX * 3 + 1)];
469 469 unsigned int basep_unused;
470 470
471 471 struct stat st;
472 472 int dfd = -1;
473 473
474 474 /* these must match the attrbuf_entry struct, otherwise you'll end up
475 475 with garbage */
476 476 struct attrlist requested_attr = {0};
477 477 requested_attr.bitmapcount = ATTR_BIT_MAP_COUNT;
478 478 requested_attr.commonattr = (ATTR_CMN_NAME | ATTR_CMN_OBJTYPE |
479 479 ATTR_CMN_MODTIME | ATTR_CMN_ACCESSMASK);
480 480 requested_attr.fileattr = ATTR_FILE_DATALENGTH;
481 481
482 482 *fallback = false;
483 483
484 484 if (pathlen >= PATH_MAX) {
485 485 errno = ENAMETOOLONG;
486 486 PyErr_SetFromErrnoWithFilename(PyExc_OSError, path);
487 487 goto error_value;
488 488 }
489 489
490 490 dfd = open(path, O_RDONLY);
491 491 if (dfd == -1) {
492 492 PyErr_SetFromErrnoWithFilename(PyExc_OSError, path);
493 493 goto error_value;
494 494 }
495 495
496 496 list = PyList_New(0);
497 497 if (!list)
498 498 goto error_dir;
499 499
500 500 do {
501 501 count = LISTDIR_BATCH_SIZE;
502 502 err = getdirentriesattr(dfd, &requested_attr, &attrbuf,
503 503 sizeof(attrbuf), &count, &basep_unused,
504 504 &new_state, 0);
505 505 if (err < 0) {
506 506 if (errno == ENOTSUP) {
507 507 /* We're on a filesystem that doesn't support
508 508 getdirentriesattr. Fall back to the
509 509 stat-based implementation. */
510 510 *fallback = true;
511 511 } else
512 512 PyErr_SetFromErrnoWithFilename(PyExc_OSError, path);
513 513 goto error;
514 514 }
515 515
516 516 if (!state_seen) {
517 517 old_state = new_state;
518 518 state_seen = true;
519 519 } else if (old_state != new_state) {
520 520 /* There's an edge case with getdirentriesattr. Consider
521 521 the following initial list of files:
522 522
523 523 a
524 524 b
525 525 <--
526 526 c
527 527 d
528 528
529 529 If the iteration is paused at the arrow, and b is
530 530 deleted before it is resumed, getdirentriesattr will
531 531 not return d at all! Ordinarily we're expected to
532 532 restart the iteration from the beginning. To avoid
533 533 getting stuck in a retry loop here, fall back to
534 534 stat. */
535 535 *fallback = true;
536 536 goto error;
537 537 }
538 538
539 539 entry = (attrbuf_entry *)attrbuf;
540 540
541 541 for (index = 0; index < count; index++) {
542 542 char *filename = ((char *)&entry->name) +
543 543 entry->name.attr_dataoffset;
544 544
545 545 if (!strcmp(filename, ".") || !strcmp(filename, ".."))
546 546 continue;
547 547
548 548 kind = attrkind(entry);
549 549 if (kind == -1) {
550 550 PyErr_Format(PyExc_OSError,
551 551 "unknown object type %u for file "
552 552 "%s%s!",
553 553 entry->obj_type, path, filename);
554 554 goto error;
555 555 }
556 556
557 557 /* quit early? */
558 558 if (skip && kind == S_IFDIR && !strcmp(filename, skip)) {
559 559 ret = PyList_New(0);
560 560 goto error;
561 561 }
562 562
563 563 if (keepstat) {
564 564 /* from the getattrlist(2) man page: "Only the
565 565 permission bits ... are valid". */
566 566 st.st_mode = (entry->access_mask & ~S_IFMT) | kind;
567 567 st.st_mtime = entry->mtime.tv_sec;
568 568 st.st_size = entry->size;
569 569 stat = makestat(&st);
570 570 if (!stat)
571 571 goto error;
572 572 elem = Py_BuildValue("siN", filename, kind, stat);
573 573 } else
574 574 elem = Py_BuildValue("si", filename, kind);
575 575 if (!elem)
576 576 goto error;
577 577 stat = NULL;
578 578
579 579 PyList_Append(list, elem);
580 580 Py_DECREF(elem);
581 581
582 582 entry = (attrbuf_entry *)((char *)entry + entry->length);
583 583 }
584 584 } while (err == 0);
585 585
586 586 ret = list;
587 587 Py_INCREF(ret);
588 588
589 589 error:
590 590 Py_DECREF(list);
591 591 Py_XDECREF(stat);
592 592 error_dir:
593 593 close(dfd);
594 594 error_value:
595 595 return ret;
596 596 }
597 597
598 598 #endif /* __APPLE__ */
599 599
600 600 static PyObject *_listdir(char *path, int pathlen, int keepstat, char *skip)
601 601 {
602 602 #ifdef __APPLE__
603 603 PyObject *ret;
604 604 bool fallback = false;
605 605
606 606 ret = _listdir_batch(path, pathlen, keepstat, skip, &fallback);
607 607 if (ret != NULL || !fallback)
608 608 return ret;
609 609 #endif
610 610 return _listdir_stat(path, pathlen, keepstat, skip);
611 611 }
612 612
613 613 static PyObject *statfiles(PyObject *self, PyObject *args)
614 614 {
615 615 PyObject *names, *stats;
616 616 Py_ssize_t i, count;
617 617
618 618 if (!PyArg_ParseTuple(args, "O:statfiles", &names))
619 619 return NULL;
620 620
621 621 count = PySequence_Length(names);
622 622 if (count == -1) {
623 623 PyErr_SetString(PyExc_TypeError, "not a sequence");
624 624 return NULL;
625 625 }
626 626
627 627 stats = PyList_New(count);
628 628 if (stats == NULL)
629 629 return NULL;
630 630
631 631 for (i = 0; i < count; i++) {
632 632 PyObject *stat, *pypath;
633 633 struct stat st;
634 634 int ret, kind;
635 635 char *path;
636 636
637 637 /* With a large file count or on a slow filesystem,
638 638 don't block signals for long (issue4878). */
639 639 if ((i % 1000) == 999 && PyErr_CheckSignals() == -1)
640 640 goto bail;
641 641
642 642 pypath = PySequence_GetItem(names, i);
643 643 if (!pypath)
644 644 goto bail;
645 645 path = PyBytes_AsString(pypath);
646 646 if (path == NULL) {
647 647 Py_DECREF(pypath);
648 648 PyErr_SetString(PyExc_TypeError, "not a string");
649 649 goto bail;
650 650 }
651 651 ret = lstat(path, &st);
652 652 Py_DECREF(pypath);
653 653 kind = st.st_mode & S_IFMT;
654 654 if (ret != -1 && (kind == S_IFREG || kind == S_IFLNK)) {
655 655 stat = makestat(&st);
656 656 if (stat == NULL)
657 657 goto bail;
658 658 PyList_SET_ITEM(stats, i, stat);
659 659 } else {
660 660 Py_INCREF(Py_None);
661 661 PyList_SET_ITEM(stats, i, Py_None);
662 662 }
663 663 }
664 664
665 665 return stats;
666 666
667 667 bail:
668 668 Py_DECREF(stats);
669 669 return NULL;
670 670 }
671 671
672 672 /*
673 673 * recvfds() simply does not release GIL during blocking io operation because
674 674 * command server is known to be single-threaded.
675 675 *
676 676 * Old systems such as Solaris don't provide CMSG_LEN, msg_control, etc.
677 677 * Currently, recvfds() is not supported on these platforms.
678 678 */
679 679 #ifdef CMSG_LEN
680 680
681 681 static ssize_t recvfdstobuf(int sockfd, int **rfds, void *cbuf, size_t cbufsize)
682 682 {
683 683 char dummy[1];
684 684 struct iovec iov = {dummy, sizeof(dummy)};
685 685 struct msghdr msgh = {0};
686 686 struct cmsghdr *cmsg;
687 687
688 688 msgh.msg_iov = &iov;
689 689 msgh.msg_iovlen = 1;
690 690 msgh.msg_control = cbuf;
691 691 msgh.msg_controllen = (socklen_t)cbufsize;
692 692 if (recvmsg(sockfd, &msgh, 0) < 0)
693 693 return -1;
694 694
695 695 for (cmsg = CMSG_FIRSTHDR(&msgh); cmsg;
696 696 cmsg = CMSG_NXTHDR(&msgh, cmsg)) {
697 697 if (cmsg->cmsg_level != SOL_SOCKET ||
698 698 cmsg->cmsg_type != SCM_RIGHTS)
699 699 continue;
700 700 *rfds = (int *)CMSG_DATA(cmsg);
701 701 return (cmsg->cmsg_len - CMSG_LEN(0)) / sizeof(int);
702 702 }
703 703
704 704 *rfds = cbuf;
705 705 return 0;
706 706 }
707 707
708 708 static PyObject *recvfds(PyObject *self, PyObject *args)
709 709 {
710 710 int sockfd;
711 711 int *rfds = NULL;
712 712 ssize_t rfdscount, i;
713 713 char cbuf[256];
714 714 PyObject *rfdslist = NULL;
715 715
716 716 if (!PyArg_ParseTuple(args, "i", &sockfd))
717 717 return NULL;
718 718
719 719 rfdscount = recvfdstobuf(sockfd, &rfds, cbuf, sizeof(cbuf));
720 720 if (rfdscount < 0)
721 721 return PyErr_SetFromErrno(PyExc_OSError);
722 722
723 723 rfdslist = PyList_New(rfdscount);
724 724 if (!rfdslist)
725 725 goto bail;
726 726 for (i = 0; i < rfdscount; i++) {
727 727 PyObject *obj = PyLong_FromLong(rfds[i]);
728 728 if (!obj)
729 729 goto bail;
730 730 PyList_SET_ITEM(rfdslist, i, obj);
731 731 }
732 732 return rfdslist;
733 733
734 734 bail:
735 735 Py_XDECREF(rfdslist);
736 736 return NULL;
737 737 }
738 738
739 739 #endif /* CMSG_LEN */
740 740
741 741 #if defined(HAVE_SETPROCTITLE)
742 742 /* setproctitle is the first choice - available in FreeBSD */
743 743 #define SETPROCNAME_USE_SETPROCTITLE
744 744 #elif (defined(__linux__) || defined(__APPLE__)) && PY_MAJOR_VERSION == 2
745 745 /* rewrite the argv buffer in place - works in Linux and OS X. Py_GetArgcArgv
746 746 * in Python 3 returns the copied wchar_t **argv, thus unsupported. */
747 747 #define SETPROCNAME_USE_ARGVREWRITE
748 748 #else
749 749 #define SETPROCNAME_USE_NONE
750 750 #endif
751 751
752 752 #ifndef SETPROCNAME_USE_NONE
753 753 static PyObject *setprocname(PyObject *self, PyObject *args)
754 754 {
755 755 const char *name = NULL;
756 756 if (!PyArg_ParseTuple(args, "s", &name))
757 757 return NULL;
758 758
759 759 #if defined(SETPROCNAME_USE_SETPROCTITLE)
760 760 setproctitle("%s", name);
761 761 #elif defined(SETPROCNAME_USE_ARGVREWRITE)
762 762 {
763 763 static char *argvstart = NULL;
764 764 static size_t argvsize = 0;
765 765 if (argvstart == NULL) {
766 766 int argc = 0, i;
767 767 char **argv = NULL;
768 768 char *argvend;
769 769 extern void Py_GetArgcArgv(int *argc, char ***argv);
770 770 Py_GetArgcArgv(&argc, &argv);
771 771
772 772 /* Check the memory we can use. Typically, argv[i] and
773 773 * argv[i + 1] are continuous. */
774 774 argvend = argvstart = argv[0];
775 775 for (i = 0; i < argc; ++i) {
776 776 if (argv[i] > argvend || argv[i] < argvstart)
777 777 break; /* not continuous */
778 778 size_t len = strlen(argv[i]);
779 779 argvend = argv[i] + len + 1 /* '\0' */;
780 780 }
781 781 if (argvend > argvstart) /* sanity check */
782 782 argvsize = argvend - argvstart;
783 783 }
784 784
785 785 if (argvstart && argvsize > 1) {
786 786 int n = snprintf(argvstart, argvsize, "%s", name);
787 787 if (n >= 0 && (size_t)n < argvsize)
788 788 memset(argvstart + n, 0, argvsize - n);
789 789 }
790 790 }
791 791 #endif
792 792
793 793 Py_RETURN_NONE;
794 794 }
795 795 #endif /* ndef SETPROCNAME_USE_NONE */
796 796
797 797 #if defined(HAVE_BSD_STATFS)
798 798 static const char *describefstype(const struct statfs *pbuf)
799 799 {
800 800 /* BSD or OSX provides a f_fstypename field */
801 801 return pbuf->f_fstypename;
802 802 }
803 803 #elif defined(HAVE_LINUX_STATFS)
804 804 static const char *describefstype(const struct statfs *pbuf)
805 805 {
806 806 /* Begin of Linux filesystems */
807 807 #ifdef ADFS_SUPER_MAGIC
808 808 if (pbuf->f_type == ADFS_SUPER_MAGIC)
809 809 return "adfs";
810 810 #endif
811 811 #ifdef AFFS_SUPER_MAGIC
812 812 if (pbuf->f_type == AFFS_SUPER_MAGIC)
813 813 return "affs";
814 814 #endif
815 815 #ifdef AUTOFS_SUPER_MAGIC
816 816 if (pbuf->f_type == AUTOFS_SUPER_MAGIC)
817 817 return "autofs";
818 818 #endif
819 819 #ifdef BDEVFS_MAGIC
820 820 if (pbuf->f_type == BDEVFS_MAGIC)
821 821 return "bdevfs";
822 822 #endif
823 823 #ifdef BEFS_SUPER_MAGIC
824 824 if (pbuf->f_type == BEFS_SUPER_MAGIC)
825 825 return "befs";
826 826 #endif
827 827 #ifdef BFS_MAGIC
828 828 if (pbuf->f_type == BFS_MAGIC)
829 829 return "bfs";
830 830 #endif
831 831 #ifdef BINFMTFS_MAGIC
832 832 if (pbuf->f_type == BINFMTFS_MAGIC)
833 833 return "binfmtfs";
834 834 #endif
835 835 #ifdef BTRFS_SUPER_MAGIC
836 836 if (pbuf->f_type == BTRFS_SUPER_MAGIC)
837 837 return "btrfs";
838 838 #endif
839 839 #ifdef CGROUP_SUPER_MAGIC
840 840 if (pbuf->f_type == CGROUP_SUPER_MAGIC)
841 841 return "cgroup";
842 842 #endif
843 843 #ifdef CIFS_MAGIC_NUMBER
844 844 if (pbuf->f_type == CIFS_MAGIC_NUMBER)
845 845 return "cifs";
846 846 #endif
847 847 #ifdef CODA_SUPER_MAGIC
848 848 if (pbuf->f_type == CODA_SUPER_MAGIC)
849 849 return "coda";
850 850 #endif
851 851 #ifdef COH_SUPER_MAGIC
852 852 if (pbuf->f_type == COH_SUPER_MAGIC)
853 853 return "coh";
854 854 #endif
855 855 #ifdef CRAMFS_MAGIC
856 856 if (pbuf->f_type == CRAMFS_MAGIC)
857 857 return "cramfs";
858 858 #endif
859 859 #ifdef DEBUGFS_MAGIC
860 860 if (pbuf->f_type == DEBUGFS_MAGIC)
861 861 return "debugfs";
862 862 #endif
863 863 #ifdef DEVFS_SUPER_MAGIC
864 864 if (pbuf->f_type == DEVFS_SUPER_MAGIC)
865 865 return "devfs";
866 866 #endif
867 867 #ifdef DEVPTS_SUPER_MAGIC
868 868 if (pbuf->f_type == DEVPTS_SUPER_MAGIC)
869 869 return "devpts";
870 870 #endif
871 871 #ifdef EFIVARFS_MAGIC
872 872 if (pbuf->f_type == EFIVARFS_MAGIC)
873 873 return "efivarfs";
874 874 #endif
875 875 #ifdef EFS_SUPER_MAGIC
876 876 if (pbuf->f_type == EFS_SUPER_MAGIC)
877 877 return "efs";
878 878 #endif
879 879 #ifdef EXT_SUPER_MAGIC
880 880 if (pbuf->f_type == EXT_SUPER_MAGIC)
881 881 return "ext";
882 882 #endif
883 883 #ifdef EXT2_OLD_SUPER_MAGIC
884 884 if (pbuf->f_type == EXT2_OLD_SUPER_MAGIC)
885 885 return "ext2";
886 886 #endif
887 887 #ifdef EXT2_SUPER_MAGIC
888 888 if (pbuf->f_type == EXT2_SUPER_MAGIC)
889 889 return "ext2";
890 890 #endif
891 891 #ifdef EXT3_SUPER_MAGIC
892 892 if (pbuf->f_type == EXT3_SUPER_MAGIC)
893 893 return "ext3";
894 894 #endif
895 895 #ifdef EXT4_SUPER_MAGIC
896 896 if (pbuf->f_type == EXT4_SUPER_MAGIC)
897 897 return "ext4";
898 898 #endif
899 899 #ifdef F2FS_SUPER_MAGIC
900 900 if (pbuf->f_type == F2FS_SUPER_MAGIC)
901 901 return "f2fs";
902 902 #endif
903 903 #ifdef FUSE_SUPER_MAGIC
904 904 if (pbuf->f_type == FUSE_SUPER_MAGIC)
905 905 return "fuse";
906 906 #endif
907 907 #ifdef FUTEXFS_SUPER_MAGIC
908 908 if (pbuf->f_type == FUTEXFS_SUPER_MAGIC)
909 909 return "futexfs";
910 910 #endif
911 911 #ifdef HFS_SUPER_MAGIC
912 912 if (pbuf->f_type == HFS_SUPER_MAGIC)
913 913 return "hfs";
914 914 #endif
915 915 #ifdef HOSTFS_SUPER_MAGIC
916 916 if (pbuf->f_type == HOSTFS_SUPER_MAGIC)
917 917 return "hostfs";
918 918 #endif
919 919 #ifdef HPFS_SUPER_MAGIC
920 920 if (pbuf->f_type == HPFS_SUPER_MAGIC)
921 921 return "hpfs";
922 922 #endif
923 923 #ifdef HUGETLBFS_MAGIC
924 924 if (pbuf->f_type == HUGETLBFS_MAGIC)
925 925 return "hugetlbfs";
926 926 #endif
927 927 #ifdef ISOFS_SUPER_MAGIC
928 928 if (pbuf->f_type == ISOFS_SUPER_MAGIC)
929 929 return "isofs";
930 930 #endif
931 931 #ifdef JFFS2_SUPER_MAGIC
932 932 if (pbuf->f_type == JFFS2_SUPER_MAGIC)
933 933 return "jffs2";
934 934 #endif
935 935 #ifdef JFS_SUPER_MAGIC
936 936 if (pbuf->f_type == JFS_SUPER_MAGIC)
937 937 return "jfs";
938 938 #endif
939 939 #ifdef MINIX_SUPER_MAGIC
940 940 if (pbuf->f_type == MINIX_SUPER_MAGIC)
941 941 return "minix";
942 942 #endif
943 943 #ifdef MINIX2_SUPER_MAGIC
944 944 if (pbuf->f_type == MINIX2_SUPER_MAGIC)
945 945 return "minix2";
946 946 #endif
947 947 #ifdef MINIX3_SUPER_MAGIC
948 948 if (pbuf->f_type == MINIX3_SUPER_MAGIC)
949 949 return "minix3";
950 950 #endif
951 951 #ifdef MQUEUE_MAGIC
952 952 if (pbuf->f_type == MQUEUE_MAGIC)
953 953 return "mqueue";
954 954 #endif
955 955 #ifdef MSDOS_SUPER_MAGIC
956 956 if (pbuf->f_type == MSDOS_SUPER_MAGIC)
957 957 return "msdos";
958 958 #endif
959 959 #ifdef NCP_SUPER_MAGIC
960 960 if (pbuf->f_type == NCP_SUPER_MAGIC)
961 961 return "ncp";
962 962 #endif
963 963 #ifdef NFS_SUPER_MAGIC
964 964 if (pbuf->f_type == NFS_SUPER_MAGIC)
965 965 return "nfs";
966 966 #endif
967 967 #ifdef NILFS_SUPER_MAGIC
968 968 if (pbuf->f_type == NILFS_SUPER_MAGIC)
969 969 return "nilfs";
970 970 #endif
971 971 #ifdef NTFS_SB_MAGIC
972 972 if (pbuf->f_type == NTFS_SB_MAGIC)
973 973 return "ntfs-sb";
974 974 #endif
975 975 #ifdef OCFS2_SUPER_MAGIC
976 976 if (pbuf->f_type == OCFS2_SUPER_MAGIC)
977 977 return "ocfs2";
978 978 #endif
979 979 #ifdef OPENPROM_SUPER_MAGIC
980 980 if (pbuf->f_type == OPENPROM_SUPER_MAGIC)
981 981 return "openprom";
982 982 #endif
983 983 #ifdef OVERLAYFS_SUPER_MAGIC
984 984 if (pbuf->f_type == OVERLAYFS_SUPER_MAGIC)
985 985 return "overlay";
986 986 #endif
987 987 #ifdef PIPEFS_MAGIC
988 988 if (pbuf->f_type == PIPEFS_MAGIC)
989 989 return "pipefs";
990 990 #endif
991 991 #ifdef PROC_SUPER_MAGIC
992 992 if (pbuf->f_type == PROC_SUPER_MAGIC)
993 993 return "proc";
994 994 #endif
995 995 #ifdef PSTOREFS_MAGIC
996 996 if (pbuf->f_type == PSTOREFS_MAGIC)
997 997 return "pstorefs";
998 998 #endif
999 999 #ifdef QNX4_SUPER_MAGIC
1000 1000 if (pbuf->f_type == QNX4_SUPER_MAGIC)
1001 1001 return "qnx4";
1002 1002 #endif
1003 1003 #ifdef QNX6_SUPER_MAGIC
1004 1004 if (pbuf->f_type == QNX6_SUPER_MAGIC)
1005 1005 return "qnx6";
1006 1006 #endif
1007 1007 #ifdef RAMFS_MAGIC
1008 1008 if (pbuf->f_type == RAMFS_MAGIC)
1009 1009 return "ramfs";
1010 1010 #endif
1011 1011 #ifdef REISERFS_SUPER_MAGIC
1012 1012 if (pbuf->f_type == REISERFS_SUPER_MAGIC)
1013 1013 return "reiserfs";
1014 1014 #endif
1015 1015 #ifdef ROMFS_MAGIC
1016 1016 if (pbuf->f_type == ROMFS_MAGIC)
1017 1017 return "romfs";
1018 1018 #endif
1019 1019 #ifdef SECURITYFS_MAGIC
1020 1020 if (pbuf->f_type == SECURITYFS_MAGIC)
1021 1021 return "securityfs";
1022 1022 #endif
1023 1023 #ifdef SELINUX_MAGIC
1024 1024 if (pbuf->f_type == SELINUX_MAGIC)
1025 1025 return "selinux";
1026 1026 #endif
1027 1027 #ifdef SMACK_MAGIC
1028 1028 if (pbuf->f_type == SMACK_MAGIC)
1029 1029 return "smack";
1030 1030 #endif
1031 1031 #ifdef SMB_SUPER_MAGIC
1032 1032 if (pbuf->f_type == SMB_SUPER_MAGIC)
1033 1033 return "smb";
1034 1034 #endif
1035 1035 #ifdef SOCKFS_MAGIC
1036 1036 if (pbuf->f_type == SOCKFS_MAGIC)
1037 1037 return "sockfs";
1038 1038 #endif
1039 1039 #ifdef SQUASHFS_MAGIC
1040 1040 if (pbuf->f_type == SQUASHFS_MAGIC)
1041 1041 return "squashfs";
1042 1042 #endif
1043 1043 #ifdef SYSFS_MAGIC
1044 1044 if (pbuf->f_type == SYSFS_MAGIC)
1045 1045 return "sysfs";
1046 1046 #endif
1047 1047 #ifdef SYSV2_SUPER_MAGIC
1048 1048 if (pbuf->f_type == SYSV2_SUPER_MAGIC)
1049 1049 return "sysv2";
1050 1050 #endif
1051 1051 #ifdef SYSV4_SUPER_MAGIC
1052 1052 if (pbuf->f_type == SYSV4_SUPER_MAGIC)
1053 1053 return "sysv4";
1054 1054 #endif
1055 1055 #ifdef TMPFS_MAGIC
1056 1056 if (pbuf->f_type == TMPFS_MAGIC)
1057 1057 return "tmpfs";
1058 1058 #endif
1059 1059 #ifdef UDF_SUPER_MAGIC
1060 1060 if (pbuf->f_type == UDF_SUPER_MAGIC)
1061 1061 return "udf";
1062 1062 #endif
1063 1063 #ifdef UFS_MAGIC
1064 1064 if (pbuf->f_type == UFS_MAGIC)
1065 1065 return "ufs";
1066 1066 #endif
1067 1067 #ifdef USBDEVICE_SUPER_MAGIC
1068 1068 if (pbuf->f_type == USBDEVICE_SUPER_MAGIC)
1069 1069 return "usbdevice";
1070 1070 #endif
1071 1071 #ifdef V9FS_MAGIC
1072 1072 if (pbuf->f_type == V9FS_MAGIC)
1073 1073 return "v9fs";
1074 1074 #endif
1075 1075 #ifdef VXFS_SUPER_MAGIC
1076 1076 if (pbuf->f_type == VXFS_SUPER_MAGIC)
1077 1077 return "vxfs";
1078 1078 #endif
1079 1079 #ifdef XENFS_SUPER_MAGIC
1080 1080 if (pbuf->f_type == XENFS_SUPER_MAGIC)
1081 1081 return "xenfs";
1082 1082 #endif
1083 1083 #ifdef XENIX_SUPER_MAGIC
1084 1084 if (pbuf->f_type == XENIX_SUPER_MAGIC)
1085 1085 return "xenix";
1086 1086 #endif
1087 1087 #ifdef XFS_SUPER_MAGIC
1088 1088 if (pbuf->f_type == XFS_SUPER_MAGIC)
1089 1089 return "xfs";
1090 1090 #endif
1091 1091 /* End of Linux filesystems */
1092 1092 return NULL;
1093 1093 }
1094 1094 #endif /* def HAVE_LINUX_STATFS */
1095 1095
1096 1096 #if defined(HAVE_BSD_STATFS) || defined(HAVE_LINUX_STATFS)
1097 1097 /* given a directory path, return filesystem type name (best-effort) */
1098 1098 static PyObject *getfstype(PyObject *self, PyObject *args)
1099 1099 {
1100 1100 const char *path = NULL;
1101 1101 struct statfs buf;
1102 1102 int r;
1103 1103 if (!PyArg_ParseTuple(args, "s", &path))
1104 1104 return NULL;
1105 1105
1106 1106 memset(&buf, 0, sizeof(buf));
1107 1107 r = statfs(path, &buf);
1108 1108 if (r != 0)
1109 1109 return PyErr_SetFromErrno(PyExc_OSError);
1110 1110 return Py_BuildValue("s", describefstype(&buf));
1111 1111 }
1112 1112 #endif /* defined(HAVE_LINUX_STATFS) || defined(HAVE_BSD_STATFS) */
1113 1113
1114 1114 #endif /* ndef _WIN32 */
1115 1115
1116 1116 static PyObject *listdir(PyObject *self, PyObject *args, PyObject *kwargs)
1117 1117 {
1118 1118 PyObject *statobj = NULL; /* initialize - optional arg */
1119 1119 PyObject *skipobj = NULL; /* initialize - optional arg */
1120 1120 char *path, *skip = NULL;
1121 1121 int wantstat, plen;
1122 1122
1123 1123 static char *kwlist[] = {"path", "stat", "skip", NULL};
1124 1124
1125 1125 if (!PyArg_ParseTupleAndKeywords(args, kwargs, "s#|OO:listdir",
1126 1126 kwlist, &path, &plen, &statobj, &skipobj))
1127 1127 return NULL;
1128 1128
1129 1129 wantstat = statobj && PyObject_IsTrue(statobj);
1130 1130
1131 1131 if (skipobj && skipobj != Py_None) {
1132 1132 skip = PyBytes_AsString(skipobj);
1133 1133 if (!skip)
1134 1134 return NULL;
1135 1135 }
1136 1136
1137 1137 return _listdir(path, plen, wantstat, skip);
1138 1138 }
1139 1139
1140 1140 #ifdef _WIN32
1141 1141 static PyObject *posixfile(PyObject *self, PyObject *args, PyObject *kwds)
1142 1142 {
1143 1143 static char *kwlist[] = {"name", "mode", "buffering", NULL};
1144 1144 PyObject *file_obj = NULL;
1145 1145 char *name = NULL;
1146 1146 char *mode = "rb";
1147 1147 DWORD access = 0;
1148 1148 DWORD creation;
1149 1149 HANDLE handle;
1150 1150 int fd, flags = 0;
1151 1151 int bufsize = -1;
1152 1152 char m0, m1, m2;
1153 1153 char fpmode[4];
1154 1154 int fppos = 0;
1155 1155 int plus;
1156 1156 FILE *fp;
1157 1157
1158 1158 if (!PyArg_ParseTupleAndKeywords(args, kwds, "et|si:posixfile", kwlist,
1159 1159 Py_FileSystemDefaultEncoding,
1160 1160 &name, &mode, &bufsize))
1161 1161 return NULL;
1162 1162
1163 1163 m0 = mode[0];
1164 1164 m1 = m0 ? mode[1] : '\0';
1165 1165 m2 = m1 ? mode[2] : '\0';
1166 1166 plus = m1 == '+' || m2 == '+';
1167 1167
1168 1168 fpmode[fppos++] = m0;
1169 1169 if (m1 == 'b' || m2 == 'b') {
1170 1170 flags = _O_BINARY;
1171 1171 fpmode[fppos++] = 'b';
1172 1172 }
1173 1173 else
1174 1174 flags = _O_TEXT;
1175 1175 if (m0 == 'r' && !plus) {
1176 1176 flags |= _O_RDONLY;
1177 1177 access = GENERIC_READ;
1178 1178 } else {
1179 1179 /*
1180 1180 work around http://support.microsoft.com/kb/899149 and
1181 1181 set _O_RDWR for 'w' and 'a', even if mode has no '+'
1182 1182 */
1183 1183 flags |= _O_RDWR;
1184 1184 access = GENERIC_READ | GENERIC_WRITE;
1185 1185 fpmode[fppos++] = '+';
1186 1186 }
1187 1187 fpmode[fppos++] = '\0';
1188 1188
1189 1189 switch (m0) {
1190 1190 case 'r':
1191 1191 creation = OPEN_EXISTING;
1192 1192 break;
1193 1193 case 'w':
1194 1194 creation = CREATE_ALWAYS;
1195 1195 break;
1196 1196 case 'a':
1197 1197 creation = OPEN_ALWAYS;
1198 1198 flags |= _O_APPEND;
1199 1199 break;
1200 1200 default:
1201 1201 PyErr_Format(PyExc_ValueError,
1202 1202 "mode string must begin with one of 'r', 'w', "
1203 1203 "or 'a', not '%c'", m0);
1204 1204 goto bail;
1205 1205 }
1206 1206
1207 1207 handle = CreateFile(name, access,
1208 1208 FILE_SHARE_READ | FILE_SHARE_WRITE |
1209 1209 FILE_SHARE_DELETE,
1210 1210 NULL,
1211 1211 creation,
1212 1212 FILE_ATTRIBUTE_NORMAL,
1213 1213 0);
1214 1214
1215 1215 if (handle == INVALID_HANDLE_VALUE) {
1216 1216 PyErr_SetFromWindowsErrWithFilename(GetLastError(), name);
1217 1217 goto bail;
1218 1218 }
1219 1219
1220 1220 fd = _open_osfhandle((intptr_t)handle, flags);
1221 1221
1222 1222 if (fd == -1) {
1223 1223 CloseHandle(handle);
1224 1224 PyErr_SetFromErrnoWithFilename(PyExc_IOError, name);
1225 1225 goto bail;
1226 1226 }
1227 1227 #ifndef IS_PY3K
1228 1228 fp = _fdopen(fd, fpmode);
1229 1229 if (fp == NULL) {
1230 1230 _close(fd);
1231 1231 PyErr_SetFromErrnoWithFilename(PyExc_IOError, name);
1232 1232 goto bail;
1233 1233 }
1234 1234
1235 1235 file_obj = PyFile_FromFile(fp, name, mode, fclose);
1236 1236 if (file_obj == NULL) {
1237 1237 fclose(fp);
1238 1238 goto bail;
1239 1239 }
1240 1240
1241 1241 PyFile_SetBufSize(file_obj, bufsize);
1242 1242 #else
1243 1243 file_obj = PyFile_FromFd(fd, name, mode, bufsize, NULL, NULL, NULL, 1);
1244 1244 if (file_obj == NULL)
1245 1245 goto bail;
1246 1246 #endif
1247 1247 bail:
1248 1248 PyMem_Free(name);
1249 1249 return file_obj;
1250 1250 }
1251 1251 #endif
1252 1252
1253 1253 #ifdef __APPLE__
1254 1254 #include <ApplicationServices/ApplicationServices.h>
1255 1255
1256 1256 static PyObject *isgui(PyObject *self)
1257 1257 {
1258 1258 CFDictionaryRef dict = CGSessionCopyCurrentDictionary();
1259 1259
1260 1260 if (dict != NULL) {
1261 1261 CFRelease(dict);
1262 1262 Py_RETURN_TRUE;
1263 1263 } else {
1264 1264 Py_RETURN_FALSE;
1265 1265 }
1266 1266 }
1267 1267 #endif
1268 1268
1269 1269 static char osutil_doc[] = "Native operating system services.";
1270 1270
1271 1271 static PyMethodDef methods[] = {
1272 1272 {"listdir", (PyCFunction)listdir, METH_VARARGS | METH_KEYWORDS,
1273 1273 "list a directory\n"},
1274 1274 #ifdef _WIN32
1275 1275 {"posixfile", (PyCFunction)posixfile, METH_VARARGS | METH_KEYWORDS,
1276 1276 "Open a file with POSIX-like semantics.\n"
1277 1277 "On error, this function may raise either a WindowsError or an IOError."},
1278 1278 #else
1279 1279 {"statfiles", (PyCFunction)statfiles, METH_VARARGS | METH_KEYWORDS,
1280 1280 "stat a series of files or symlinks\n"
1281 1281 "Returns None for non-existent entries and entries of other types.\n"},
1282 1282 #ifdef CMSG_LEN
1283 1283 {"recvfds", (PyCFunction)recvfds, METH_VARARGS,
1284 1284 "receive list of file descriptors via socket\n"},
1285 1285 #endif
1286 1286 #ifndef SETPROCNAME_USE_NONE
1287 1287 {"setprocname", (PyCFunction)setprocname, METH_VARARGS,
1288 1288 "set process title (best-effort)\n"},
1289 1289 #endif
1290 1290 #if defined(HAVE_BSD_STATFS) || defined(HAVE_LINUX_STATFS)
1291 1291 {"getfstype", (PyCFunction)getfstype, METH_VARARGS,
1292 1292 "get filesystem type (best-effort)\n"},
1293 1293 #endif
1294 1294 #endif /* ndef _WIN32 */
1295 1295 #ifdef __APPLE__
1296 1296 {
1297 1297 "isgui", (PyCFunction)isgui, METH_NOARGS,
1298 1298 "Is a CoreGraphics session available?"
1299 1299 },
1300 1300 #endif
1301 1301 {NULL, NULL}
1302 1302 };
1303 1303
1304 static const int version = 1;
1305
1304 1306 #ifdef IS_PY3K
1305 1307 static struct PyModuleDef osutil_module = {
1306 1308 PyModuleDef_HEAD_INIT,
1307 1309 "osutil",
1308 1310 osutil_doc,
1309 1311 -1,
1310 1312 methods
1311 1313 };
1312 1314
1313 1315 PyMODINIT_FUNC PyInit_osutil(void)
1314 1316 {
1317 PyObject *m;
1315 1318 if (PyType_Ready(&listdir_stat_type) < 0)
1316 1319 return NULL;
1317 1320
1318 return PyModule_Create(&osutil_module);
1321 m = PyModule_Create(&osutil_module);
1322 PyModule_AddIntConstant(m, "version", version);
1323 return m;
1319 1324 }
1320 1325 #else
1321 1326 PyMODINIT_FUNC initosutil(void)
1322 1327 {
1328 PyObject *m;
1323 1329 if (PyType_Ready(&listdir_stat_type) == -1)
1324 1330 return;
1325 1331
1326 Py_InitModule3("osutil", methods, osutil_doc);
1332 m = Py_InitModule3("osutil", methods, osutil_doc);
1333 PyModule_AddIntConstant(m, "version", version);
1327 1334 }
1328 1335 #endif
General Comments 0
You need to be logged in to leave comments. Login now