14#include "ruby/internal/config.h"
26# if defined(HAVE_FDOPENDIR) && defined(HAVE_DIRFD) && \
27 defined(HAVE_OPENAT) && defined(HAVE_FSTATAT)
28# define USE_OPENDIR_AT 1
30# define USE_OPENDIR_AT 0
42#undef HAVE_DIRENT_NAMLEN
43#if defined HAVE_DIRENT_H && !defined _WIN32
45# define NAMLEN(dirent) strlen((dirent)->d_name)
46#elif defined HAVE_DIRECT_H && !defined _WIN32
48# define NAMLEN(dirent) strlen((dirent)->d_name)
51# define NAMLEN(dirent) (dirent)->d_namlen
52# define HAVE_DIRENT_NAMLEN 1
53# ifdef HAVE_SYS_NDIR_H
63# include "win32/dir.h"
72char *strchr(
char*,
char);
79#define USE_NAME_ON_FS_REAL_BASENAME 1
82#ifdef HAVE_GETATTRLIST
83# define USE_NAME_ON_FS USE_NAME_ON_FS_REAL_BASENAME
84# define RUP32(size) ((size)+3/4)
85# define SIZEUP32(type) RUP32(sizeof(type))
87# define USE_NAME_ON_FS USE_NAME_ON_FS_REAL_BASENAME
89# define USE_NAME_ON_FS 0
93# define NORMALIZE_UTF8PATH 1
94# include <sys/param.h>
95# include <sys/mount.h>
96# include <sys/vnode.h>
98# define NORMALIZE_UTF8PATH 0
104#include "internal/array.h"
105#include "internal/dir.h"
106#include "internal/encoding.h"
107#include "internal/error.h"
108#include "internal/file.h"
109#include "internal/gc.h"
110#include "internal/io.h"
111#include "internal/object.h"
112#include "internal/imemo.h"
113#include "internal/vm.h"
127#define vm_initialized rb_cThread
132# define chdir(p) rb_w32_uchdir(p)
133# define ruby_getcwd() rb_w32_ugetcwd(NULL, 0)
139#ifdef HAVE_GETATTRLIST
140struct getattrlist_args {
143 struct attrlist *list;
146 unsigned int options;
149# define GETATTRLIST_ARGS(list_, buf_, options_) (struct getattrlist_args) \
150 {.list = list_, .buf = buf_, .size = sizeof(buf_), .options = options_}
153nogvl_getattrlist(
void *args)
155 struct getattrlist_args *arg = args;
156 return (
void *)(
VALUE)getattrlist(arg->path, arg->list, arg->buf, arg->size, arg->options);
160gvl_getattrlist(
struct getattrlist_args *args,
const char *path)
163 return IO_WITHOUT_GVL_INT(nogvl_getattrlist, args);
166# ifdef HAVE_FGETATTRLIST
168nogvl_fgetattrlist(
void *args)
170 struct getattrlist_args *arg = args;
171 return (
void *)(
VALUE)fgetattrlist(arg->fd, arg->list, arg->buf, arg->size, arg->options);
175gvl_fgetattrlist(
struct getattrlist_args *args,
int fd)
178 return IO_WITHOUT_GVL_INT(nogvl_fgetattrlist, args);
183#if NORMALIZE_UTF8PATH
184# if defined HAVE_FGETATTRLIST || !defined HAVE_GETATTRLIST
185# define need_normalization(dirp, path) need_normalization(dirp)
187# define need_normalization(dirp, path) need_normalization(path)
190need_normalization(
DIR *dirp,
const char *path)
192# if defined HAVE_FGETATTRLIST || defined HAVE_GETATTRLIST
193 u_int32_t attrbuf[SIZEUP32(fsobj_tag_t)];
194 struct attrlist al = {ATTR_BIT_MAP_COUNT, 0, ATTR_CMN_OBJTAG,};
195 struct getattrlist_args args = GETATTRLIST_ARGS(&al, attrbuf, 0);
196# if defined HAVE_FGETATTRLIST
197 int ret = gvl_fgetattrlist(&args, dirfd(dirp));
199 int ret = gvl_getattrlist(&args, path);
202 const fsobj_tag_t *tag = (
void *)(attrbuf+1);
214has_nonascii(
const char *ptr,
size_t len)
224# define IF_NORMALIZE_UTF8PATH(something) something
226# define IF_NORMALIZE_UTF8PATH(something)
229#if defined(IFTODT) && defined(DT_UNKNOWN)
230# define EMULATE_IFTODT 0
232# define EMULATE_IFTODT 1
236# define IFTODT(m) (((m) & S_IFMT) / ((~S_IFMT & (S_IFMT-1)) + 1))
241 path_exist = DT_UNKNOWN,
242 path_directory = DT_DIR,
243 path_regular = DT_REG,
244 path_symlink = DT_LNK,
247 path_directory = IFTODT(S_IFDIR),
248 path_regular = IFTODT(S_IFREG),
249 path_symlink = IFTODT(S_IFLNK),
255#define FNM_NOESCAPE 0x01
256#define FNM_PATHNAME 0x02
257#define FNM_DOTMATCH 0x04
258#define FNM_CASEFOLD 0x08
259#define FNM_EXTGLOB 0x10
260#if CASEFOLD_FILESYSTEM
261#define FNM_SYSCASE FNM_CASEFOLD
266#define FNM_SHORTNAME 0x20
268#define FNM_SHORTNAME 0
270#define FNM_GLOB_NOSORT 0x40
271#define FNM_GLOB_SKIPDOT 0x80
276# define Next(p, e, enc) ((p)+ rb_enc_mbclen((p), (e), (enc)))
277# define Inc(p, e, enc) ((p) = Next((p), (e), (enc)))
288 const int nocase = flags & FNM_CASEFOLD;
289 const int escape = !(flags & FNM_NOESCAPE);
294 if (p >= pend)
return NULL;
295 if (*p ==
'!' || *p ==
'^') {
302 if (escape && *t1 ==
'\\')
306 p = t1 + (r = rb_enc_mbclen(t1, pend, enc));
307 if (p >= pend)
return NULL;
308 if (p[0] ==
'-' && p[1] !=
']') {
309 const char *t2 = p + 1;
311 if (escape && *t2 ==
'\\')
315 p = t2 + (r2 = rb_enc_mbclen(t2, pend, enc));
317 if ((r <= (send-s) && memcmp(t1, s, r) == 0) ||
318 (r2 <= (send-s) && memcmp(t2, s, r2) == 0)) {
323 if (nocase) c1 = rb_enc_toupper(c1, enc);
325 if (nocase) c2 = rb_enc_toupper(c2, enc);
326 if (c1 < c2)
continue;
328 if (nocase) c2 = rb_enc_toupper(c2, enc);
329 if (c1 > c2)
continue;
333 if (r <= (send-s) && memcmp(t1, s, r) == 0) {
337 if (!nocase)
continue;
340 if (c1 != c2)
continue;
345 return ok == not ? NULL : (
char *)p + 1;
353#define UNESCAPE(p) (escape && *(p) == '\\' ? (p) + 1 : (p))
354#define ISEND(p) (!*(p) || (pathname && *(p) == '/'))
355#define RETURN(val) return *pcur = p, *scur = s, (val);
364 const int period = !(flags & FNM_DOTMATCH);
365 const int pathname = flags & FNM_PATHNAME;
366 const int escape = !(flags & FNM_NOESCAPE);
367 const int nocase = flags & FNM_CASEFOLD;
369 const char *ptmp = 0;
370 const char *stmp = 0;
372 const char *p = *pcur;
373 const char *pend = p + strlen(p);
374 const char *s = *scur;
375 const char *send = s + strlen(s);
379 if (period && *s ==
'.' && *UNESCAPE(p) !=
'.')
385 do { p++; }
while (*p ==
'*');
386 if (ISEND(UNESCAPE(p))) {
407 if ((t = bracket(p + 1, pend, s, send, flags, enc)) != 0) {
419 RETURN(ISEND(p) ? 0 : FNM_NOMATCH);
422 r = rb_enc_precise_mbclen(p, pend, enc);
425 if (r <= (send-s) && memcmp(p, s, r) == 0) {
430 if (!nocase)
goto failed;
441 Inc(stmp, send, enc);
456 const char *p = pattern;
457 const char *s = string;
458 const char *send = s + strlen(
string);
459 const int period = !(flags & FNM_DOTMATCH);
460 const int pathname = flags & FNM_PATHNAME;
462 const char *ptmp = 0;
463 const char *stmp = 0;
467 if (p[0] ==
'*' && p[1] ==
'*' && p[2] ==
'/') {
468 do { p += 3; }
while (p[0] ==
'*' && p[1] ==
'*' && p[2] ==
'/');
472 if (fnmatch_helper(&p, &s, flags, enc) == 0) {
473 while (*s && *s !=
'/') Inc(s, send, enc);
483 if (ptmp && stmp && !(period && *stmp ==
'.')) {
484 while (*stmp && *stmp !=
'/') Inc(stmp, send, enc);
496 return fnmatch_helper(&p, &s, flags, enc);
500static VALUE sym_directory, sym_link, sym_file, sym_unknown;
502#if defined(DT_BLK) || defined(S_IFBLK)
503static VALUE sym_block_device;
505#if defined(DT_CHR) || defined(S_IFCHR)
506static VALUE sym_character_device;
508#if defined(DT_FIFO) || defined(S_IFIFO)
509static VALUE sym_fifo;
511#if defined(DT_SOCK) || defined(S_IFSOCK)
512static VALUE sym_socket;
526 if (dir->dir) closedir(dir->dir);
529RUBY_REFERENCES(dir_refs) = {
530 RUBY_REF_EDGE(
struct dir_data, path),
537 RUBY_REFS_LIST_PTR(dir_refs),
541 0, NULL, RUBY_TYPED_WB_PROTECTED | RUBY_TYPED_THREAD_SAFE_FREE | RUBY_TYPED_DECL_MARKING | RUBY_TYPED_EMBEDDABLE
547dir_s_alloc(
VALUE klass)
560nogvl_opendir(
void *ptr)
562 const char *path = ptr;
564 return opendir(path);
568opendir_without_gvl(
const char *path)
570 if (vm_initialized) {
571 union {
const void *in;
void *out; } u;
575 return IO_WITHOUT_GVL(nogvl_opendir, u.out);
578 return opendir(path);
585 if (closedir(dp->dir) < 0) {
587 rb_sys_fail(
"closedir");
594check_closedir(
DIR *dirp)
596 if (closedir(dirp) < 0)
597 rb_sys_fail(
"closedir");
606 rb_encoding *fsenc =
NIL_P(enc) ? rb_filesystem_encoding() : rb_to_encoding(enc);
610 dirname = rb_str_encode_ospath(dirname);
617 path = RSTRING_PTR(dirname);
618 dp->dir = opendir_without_gvl(path);
619 if (dp->dir == NULL) {
621 if (rb_gc_for_fd(e)) {
622 dp->dir = opendir_without_gvl(path);
624#ifdef HAVE_GETATTRLIST
626 u_int32_t attrbuf[1];
627 struct attrlist al = {ATTR_BIT_MAP_COUNT, 0};
628 struct getattrlist_args args = GETATTRLIST_ARGS(&al, attrbuf, FSOPT_NOFOLLOW);
629 if (gvl_getattrlist(&args, path) == 0) {
630 dp->dir = opendir_without_gvl(path);
634 if (dp->dir == NULL) {
636 rb_syserr_fail_path(e, orig);
650 dir_initialize(ec, dir, dirname, enc);
658 return dir_close(dir);
661# if defined(HAVE_FDOPENDIR) && defined(HAVE_DIRFD)
663nogvl_fdopendir(
void *fd)
665 return fdopendir((
int)(
VALUE)fd);
694 if (!(dp->dir = IO_WITHOUT_GVL(nogvl_fdopendir, (
void *)(
VALUE)
NUM2INT(fd)))) {
695 rb_sys_fail(
"fdopendir");
703#define dir_s_for_fd rb_f_notimplement
706NORETURN(
static void dir_closed(
void));
717 rb_check_frozen(dir);
724 struct dir_data *dirp = dir_get(dir);
725 if (!dirp->dir) dir_closed();
729#define GetDIR(obj, dirp) ((dirp) = dir_check(obj))
742dir_inspect(
VALUE dir)
747 if (!
NIL_P(dirp->path)) {
761#if defined(__sun) && !defined(HAVE_DIRFD)
762# if defined(HAVE_DIR_D_FD)
763# define dirfd(x) ((x)->d_fd)
765# elif defined(HAVE_DIR_DD_FD)
766# define dirfd(x) ((x)->dd_fd)
793 fd = dirfd(dirp->dir);
795 rb_sys_fail(
"dirfd");
799#define dir_fileno rb_f_notimplement
848 switch (rb_enc_to_index(enc)) {
849 case ENCINDEX_ASCII_8BIT:
850 case ENCINDEX_US_ASCII:
857# define READDIR(dir, enc) rb_w32_readdir((dir), (enc))
858# define READDIR_NOGVL READDIR
860NORETURN(
static void *sys_failure(
void *function));
862sys_failure(
void *function)
864 rb_sys_fail(function);
868nogvl_readdir(
void *dir)
871 if ((dir = readdir(dir)) == NULL) {
878# define READDIR(dir, enc) IO_WITHOUT_GVL(nogvl_readdir, (void *)(dir))
879# define READDIR_NOGVL(dir, enc) nogvl_readdir((dir))
884to_be_skipped(
const struct dirent *dp)
886 const char *name = dp->d_name;
887 if (name[0] !=
'.')
return FALSE;
888#ifdef HAVE_DIRENT_NAMLEN
889 switch (NAMLEN(dp)) {
891 if (name[1] !=
'.')
return FALSE;
898 if (!name[1])
return TRUE;
899 if (name[1] !=
'.')
return FALSE;
900 if (!name[2])
return TRUE;
927 if ((dp = READDIR(dirp->dir, dirp->enc)) != NULL) {
950static int do_lstat(
int fd,
const char *path,
struct stat *pst,
int flags,
rb_encoding *enc);
956 switch (dir_entry->dp->d_type) {
959 type = sym_block_device;
964 type = sym_character_device;
968 type = sym_directory;
994 if (do_lstat(dirfd(dir_entry->dirp->dir), dir_entry->dp->d_name, &st, 0, rb_filesystem_encoding()) == 0) {
995 switch (st.st_mode & S_IFMT) {
997 type = sym_directory;
1017 type = sym_block_device;
1022 type = sym_character_device;
1063 return dir_each_entry(dir, dir_yield,
Qnil, FALSE);
1071 IF_NORMALIZE_UTF8PATH(
int norm_p);
1074 rewinddir(dirp->dir);
1075 IF_NORMALIZE_UTF8PATH(norm_p = need_normalization(dirp->dir, RSTRING_PTR(dirp->path)));
1076 while ((dp = READDIR(dirp->dir, dirp->enc)) != NULL) {
1077 const char *name = dp->d_name;
1078 size_t namlen = NAMLEN(dp);
1081 if (children_only && name[0] ==
'.') {
1082 if (namlen == 1)
continue;
1083 if (namlen == 2 && name[1] ==
'.')
continue;
1085#if NORMALIZE_UTF8PATH
1086 if (norm_p && has_nonascii(name, namlen) &&
1087 !
NIL_P(path = rb_str_normalize_ospath(name, namlen))) {
1088 path = rb_external_str_with_enc(path, dirp->enc);
1097 (*each)(arg, path, &each_args);
1099 if (!dirp->dir) dir_closed();
1125 if((pos = telldir(dirp->dir)) < 0)
1126 rb_sys_fail(
"telldir");
1127 return rb_int2inum(pos);
1130#define dir_tell rb_f_notimplement
1161 seekdir(dirp->dir, p);
1165#define dir_seek rb_f_notimplement
1196#define dir_set_pos rb_f_notimplement
1215dir_rewind(
VALUE dir)
1220 rewinddir(dirp->dir);
1243 dirp = dir_get(dir);
1244 if (!dirp->dir)
return Qnil;
1245 close_dir_data(dirp);
1251nogvl_chdir(
void *ptr)
1253 const char *path = ptr;
1255 return (
void *)(
VALUE)chdir(path);
1259dir_chdir0(
VALUE path)
1261 if (IO_WITHOUT_GVL_INT(nogvl_chdir, (
void*)RSTRING_PTR(path)) < 0)
1262 rb_sys_fail_path(path);
1271 .blocking = 0, .thread = NULL,
1272 .path =
Qnil, .line = 0,
1278 if (chdir_lock.blocking == 0) {
1279 VALUE path = rb_source_location(&chdir_lock.line);
1286 chdir_lock.blocking++;
1287 if (chdir_lock.thread == NULL) {
1295 chdir_lock.blocking--;
1296 if (chdir_lock.blocking == 0) {
1297 chdir_lock.thread = NULL;
1298 chdir_lock.path =
Qnil;
1299 chdir_lock.line = 0;
1304chdir_alone_block_p(
void)
1307 if (chdir_lock.blocking > 0) {
1309 rb_raise(
rb_eRuntimeError,
"conflicting chdir during another chdir block");
1311 if (!
NIL_P(chdir_lock.path)) {
1312 rb_warn(
"conflicting chdir during another chdir block\n"
1313 "%" PRIsVALUE
":%d: note: previous chdir was here",
1314 chdir_lock.path, chdir_lock.line);
1317 rb_warn(
"conflicting chdir during another chdir block");
1325 VALUE old_path, new_path;
1334 dir_chdir0(args->new_path);
1341chdir_restore(
VALUE v)
1346 dir_chdir0(args->old_path);
1352chdir_path(
VALUE path,
bool yield_path)
1354 if (chdir_alone_block_p()) {
1357 args.old_path = rb_str_encode_ospath(rb_dir_getwd());
1358 args.new_path = path;
1360 args.yield_path = yield_path;
1364 char *p = RSTRING_PTR(path);
1365 int r = IO_WITHOUT_GVL_INT(nogvl_chdir, p);
1367 rb_sys_fail_path(path);
1442 path = rb_str_encode_ospath(rb_get_path(argv[0]));
1445 const char *dist = getenv(
"HOME");
1447 dist = getenv(
"LOGDIR");
1448 if (!dist) rb_raise(rb_eArgError,
"HOME/LOGDIR not set");
1453 return chdir_path(path,
true);
1456#if defined(HAVE_FCHDIR) && defined(HAVE_DIRFD) && HAVE_FCHDIR && HAVE_DIRFD
1458nogvl_fchdir(
void *ptr)
1460 const int *fd = ptr;
1462 return (
void *)(
VALUE)fchdir(*fd);
1468 if (IO_WITHOUT_GVL_INT(nogvl_fchdir, (
void *)&fd) < 0)
1469 rb_sys_fail(
"fchdir");
1479fchdir_yield(
VALUE v)
1481 struct fchdir_data *args = (
void *)v;
1482 dir_fchdir(args->fd);
1489fchdir_restore(
VALUE v)
1491 struct fchdir_data *args = (
void *)v;
1494 dir_fchdir(
RB_NUM2INT(dir_fileno(args->old_dir)));
1496 dir_close(args->old_dir);
1557 if (chdir_alone_block_p()) {
1558 struct fchdir_data args;
1559 args.old_dir = dir_s_alloc(klass);
1560 dir_initialize(NULL, args.old_dir, rb_fstring_cstr(
"."),
Qnil);
1566 int r = IO_WITHOUT_GVL_INT(nogvl_fchdir, &fd);
1568 rb_sys_fail(
"fchdir");
1574#define dir_s_fchdir rb_f_notimplement
1603#if defined(HAVE_FCHDIR) && defined(HAVE_DIRFD) && HAVE_FCHDIR && HAVE_DIRFD
1604 return dir_s_fchdir(
rb_cDir, dir_fileno(dir));
1606 return chdir_path(dir_get(dir)->path,
false);
1610static VALUE last_cwd;
1614getcwd_to_str(
VALUE arg)
1616 const char *path = (
const char *)arg;
1618 return rb_str_normalize_ospath(path, strlen(path));
1625getcwd_xfree(
VALUE arg)
1632rb_dir_getwd_ospath_slowpath(
void)
1639rb_dir_getwd_ospath(
void)
1641 char buf[PATH_MAX < LONG_MAX ? PATH_MAX : -1];
1642 char *path = getcwd(buf, PATH_MAX);
1644 return rb_dir_getwd_ospath_slowpath();
1646 size_t len = strlen(path);
1649 VALUE cached_cwd = RUBY_ATOMIC_VALUE_LOAD(last_cwd);
1651 if (!cached_cwd || (
size_t)RSTRING_LEN(cached_cwd) !=
len ||
1652 memcmp(RSTRING_PTR(cached_cwd), path,
len) != 0) {
1654 cached_cwd = rb_str_normalize_ospath(path, (
long)
len);
1670 int fsenc = rb_enc_to_index(fs);
1674 case ENCINDEX_US_ASCII:
1675 fsenc = ENCINDEX_ASCII_8BIT;
1676 case ENCINDEX_ASCII_8BIT:
1678#if defined _WIN32 || defined __APPLE__
1683 return rb_enc_associate_index(cwd, fsenc);
1697dir_s_getwd(
VALUE dir)
1699 return rb_dir_getwd();
1703check_dirname(
VALUE dir)
1711 enc = rb_enc_get(d);
1714 pend = rb_enc_path_end(rb_enc_path_skip_prefix(path, pend, enc), pend, enc);
1715 if (pend - path <
len) {
1719 return rb_str_encode_ospath(d);
1722#if defined(HAVE_CHROOT)
1724nogvl_chroot(
void *dirname)
1726 return (
void *)(
VALUE)chroot((
const char *)dirname);
1744 path = check_dirname(path);
1745 if (IO_WITHOUT_GVL_INT(nogvl_chroot, (
void *)RSTRING_PTR(path)) == -1)
1746 rb_sys_fail_path(path);
1751#define dir_s_chroot rb_f_notimplement
1760nogvl_mkdir(
void *ptr)
1764 return (
void *)(
VALUE)mkdir(m->path, m->mode);
1791 if (
rb_scan_args(argc, argv,
"11", &path, &vmode) == 2) {
1798 path = check_dirname(path);
1799 m.path = RSTRING_PTR(path);
1800 r = IO_WITHOUT_GVL_INT(nogvl_mkdir, &m);
1802 rb_sys_fail_path(path);
1808nogvl_rmdir(
void *ptr)
1810 const char *path = ptr;
1812 return (
void *)(
VALUE)rmdir(path);
1840 dir = check_dirname(dir);
1841 p = RSTRING_PTR(dir);
1842 r = IO_WITHOUT_GVL_INT(nogvl_rmdir, (
void *)p);
1844 rb_sys_fail_path(dir);
1850#ifdef RUBY_FUNCTION_NAME_STRING
1857#ifndef RUBY_FUNCTION_NAME_STRING
1858#define sys_enc_warning_in(func, mesg, enc) sys_enc_warning(mesg, enc)
1862sys_warning_1(
VALUE mesg)
1865#ifdef RUBY_FUNCTION_NAME_STRING
1866 rb_sys_enc_warning(arg->enc,
"%s: %s", arg->func, arg->mesg);
1868 rb_sys_enc_warning(arg->enc,
"%s", arg->mesg);
1874sys_enc_warning_in(
const char *func,
const char *mesg,
rb_encoding *enc)
1877#ifdef RUBY_FUNCTION_NAME_STRING
1882 rb_protect(sys_warning_1, (
VALUE)&arg, 0);
1885#define GLOB_VERBOSE (1U << (sizeof(int) * CHAR_BIT - 1))
1886#define sys_warning(val, enc) \
1887 ((flags & GLOB_VERBOSE) ? sys_enc_warning_in(RUBY_FUNCTION_NAME_STRING, (val), (enc)) :(void)0)
1890glob_alloc_size(
size_t x,
size_t y)
1902glob_alloc_n(
size_t x,
size_t y)
1904 return malloc(glob_alloc_size(x, y));
1908glob_realloc_n(
void *p,
size_t x,
size_t y)
1910 return realloc(p, glob_alloc_size(x, y));
1913#define GLOB_ALLOC(type) ((type *)malloc(sizeof(type)))
1914#define GLOB_ALLOC_N(type, n) ((type *)glob_alloc_n(sizeof(type), n))
1915#define GLOB_REALLOC(ptr, size) realloc((ptr), (size))
1916#define GLOB_REALLOC_N(ptr, n) glob_realloc_n(ptr, sizeof(*(ptr)), n)
1917#define GLOB_FREE(ptr) free(ptr)
1918#define GLOB_JUMP_TAG(status) (((status) == -1) ? rb_memerror() : rb_jump_tag(status))
1924ALWAYS_INLINE(
static int to_be_ignored(
int e));
1928 return e == ENOENT || e == ENOTDIR;
1932#define STAT(args) (int)(VALUE)nogvl_stat(&(args))
1933#define LSTAT(args) (int)(VALUE)nogvl_lstat(&(args))
1935#define STAT(args) IO_WITHOUT_GVL_INT(nogvl_stat, (void *)&(args))
1936#define LSTAT(args) IO_WITHOUT_GVL_INT(nogvl_lstat, (void *)&(args))
1939typedef int ruby_glob_errfunc(
const char*,
VALUE,
const void*,
int);
1942 ruby_glob_errfunc *error;
1946at_subpath(
int fd,
size_t baselen,
const char *path)
1949 if (fd != (
int)AT_FDCWD && baselen > 0) {
1951 if (*path ==
'/') ++path;
1954 return *path ? path :
".";
1958struct fstatat_args {
1966nogvl_fstatat(
void *args)
1968 struct fstatat_args *arg = (
struct fstatat_args *)args;
1969 return (
void *)(
VALUE)fstatat(arg->fd, arg->path, arg->pst, arg->flag);
1978nogvl_stat(
void *args)
1981 return (
void *)(
VALUE)stat(arg->path, arg->pst);
1987do_stat(
int fd,
const char *path,
struct stat *pst,
int flags,
rb_encoding *enc)
1990 struct fstatat_args args;
1995 int ret = IO_WITHOUT_GVL_INT(nogvl_fstatat, (
void *)&args);
2000 int ret = STAT(args);
2002 if (ret < 0 && !to_be_ignored(
errno))
2003 sys_warning(path, enc);
2008#if defined HAVE_LSTAT || defined lstat || USE_OPENDIR_AT
2011nogvl_lstat(
void *args)
2014 return (
void *)(
VALUE)lstat(arg->path, arg->pst);
2019do_lstat(
int fd,
const char *path,
struct stat *pst,
int flags,
rb_encoding *enc)
2022 struct fstatat_args args;
2026 args.flag = AT_SYMLINK_NOFOLLOW;
2027 int ret = IO_WITHOUT_GVL_INT(nogvl_fstatat, (
void *)&args);
2032 int ret = LSTAT(args);
2034 if (ret < 0 && !to_be_ignored(
errno))
2035 sys_warning(path, enc);
2040#define do_lstat do_stat
2049with_gvl_gc_for_fd(
void *ptr)
2053 return (
void *)RBOOL(rb_gc_for_fd(*e));
2057gc_for_fd_with_gvl(
int e)
2062 return RBOOL(rb_gc_for_fd(e));
2066nogvl_opendir_at(
void *ptr)
2072 const int opendir_flags = (O_RDONLY|O_CLOEXEC|
2077 int fd = openat(oaa->basefd, oaa->path, opendir_flags);
2079 dirp = fd >= 0 ? fdopendir(fd) : 0;
2083 switch (gc_for_fd_with_gvl(e)) {
2085 if (fd < 0) fd = openat(oaa->basefd, oaa->path, opendir_flags);
2086 if (fd >= 0) dirp = fdopendir(fd);
2087 if (dirp)
return dirp;
2092 if (fd >= 0) close(fd);
2097 dirp = opendir(oaa->path);
2098 if (!dirp && gc_for_fd_with_gvl(
errno))
2099 dirp = opendir(oaa->path);
2106opendir_at(
int basefd,
const char *path)
2110 oaa.basefd = basefd;
2114 return IO_WITHOUT_GVL(nogvl_opendir_at, &oaa);
2116 return nogvl_opendir_at(&oaa);
2120do_opendir(
const int basefd,
size_t baselen,
const char *path,
int flags,
rb_encoding *enc,
2121 ruby_glob_errfunc *errfunc,
VALUE arg,
int *status)
2126 if (!fundamental_encoding_p(enc)) {
2127 tmp = rb_enc_str_new(path, strlen(path), enc);
2128 tmp = rb_str_encode_ospath(tmp);
2129 path = RSTRING_PTR(tmp);
2132 dirp = opendir_at(basefd, at_subpath(basefd, baselen, path));
2137 if (!to_be_ignored(e)) {
2139 *status = (*errfunc)(path, arg, enc, e);
2142 sys_warning(path, enc);
2147 if (tmp) rb_str_resize(tmp, 0);
2154enum glob_pattern_type { PLAIN, ALPHA, BRACE, MAGICAL, RECURSIVE, MATCH_ALL, MATCH_DIR };
2157static enum glob_pattern_type
2158has_magic(
const char *p,
const char *pend,
int flags,
rb_encoding *enc)
2160 const int escape = !(flags & FNM_NOESCAPE);
2166 while (p < pend && (c = *p++) != 0) {
2178 if (escape && p++ >= pend)
2193 p = Next(p-1, pend, enc);
2196 return hasmagical ? MAGICAL : hasalpha ? ALPHA : PLAIN;
2201find_dirsep(
const char *p,
const char *pend,
int flags,
rb_encoding *enc)
2203 const int escape = !(flags & FNM_NOESCAPE);
2208 while ((c = *p++) != 0) {
2230 if (escape && !(c = *p++))
2235 p = Next(p-1, pend, enc);
2243remove_backslashes(
char *p,
register const char *pend,
rb_encoding *enc)
2251 memmove(t, s, p - s);
2262 memmove(t, s, p - s);
2269 enum glob_pattern_type
type;
2270 bool follow_symlinks;
2274static void glob_free_pattern(
struct glob_pattern *list);
2278glob_recursive_length(
const char *p,
const char *e)
2280 if (e - p < 3 || p[0] !=
'*' || p[1] !=
'*')
return 0;
2281 if (p[2] ==
'/')
return 3;
2282 if (e - p >= 4 && p[2] ==
'*' && p[3] ==
'/')
return 4;
2287glob_make_pattern(
const char *p,
const char *e,
int flags,
rb_encoding *enc)
2293 while (p < e && *p) {
2294 const char *start = p;
2295 bool follow_symlinks =
false;
2298 while ((
len = glob_recursive_length(p, e)) != 0) {
2299 follow_symlinks |=
len == 4;
2301 while (p < e && *p ==
'/') p++;
2304 if (!tmp)
goto error;
2305 tmp->follow_symlinks = follow_symlinks;
2307 tmp->type = RECURSIVE;
2313 const char *m = find_dirsep(p, e, flags, enc);
2314 const enum glob_pattern_type magic = has_magic(p, m, flags, enc);
2315 const enum glob_pattern_type non_magic = (USE_NAME_ON_FS || FNM_SYSCASE) ? PLAIN : ALPHA;
2318 if (!(FNM_SYSCASE || magic > non_magic) && !recursive && *m) {
2320 while (has_magic(m+1, m2 = find_dirsep(m+1, e, flags, enc), flags, enc) <= non_magic &&
2325 buf = GLOB_ALLOC_N(
char, m-p+1);
2330 memcpy(buf, p, m-p);
2332 tmp->type = magic > MAGICAL ? MAGICAL : magic > non_magic ? magic : PLAIN;
2351 tmp->follow_symlinks =
false;
2352 tmp->type = dirsep ? MATCH_DIR : MATCH_ALL;
2361 glob_free_pattern(list);
2372 GLOB_FREE(tmp->str);
2378join_path(
const char *path,
size_t len,
int dirsep,
const char *name,
size_t namlen)
2380 char *buf = GLOB_ALLOC_N(
char,
len+namlen+(dirsep?1:0)+1);
2383 memcpy(buf, path,
len);
2387 memcpy(buf+
len, name, namlen);
2388 buf[
len+namlen] =
'\0';
2392#ifdef HAVE_GETATTRLIST
2393# if defined HAVE_FGETATTRLIST
2394# define is_case_sensitive(dirp, path) is_case_sensitive(dirp)
2396# define is_case_sensitive(dirp, path) is_case_sensitive(path)
2399is_case_sensitive(
DIR *dirp,
const char *path)
2403 vol_capabilities_attr_t cap[1];
2405 struct attrlist al = {ATTR_BIT_MAP_COUNT, 0, 0, ATTR_VOL_INFO|ATTR_VOL_CAPABILITIES};
2406 const vol_capabilities_attr_t *
const cap = attrbuf[0].cap;
2407 const int idx = VOL_CAPABILITIES_FORMAT;
2408 const uint32_t mask = VOL_CAP_FMT_CASE_SENSITIVE;
2409 struct getattrlist_args args = GETATTRLIST_ARGS(&al, attrbuf, FSOPT_NOFOLLOW);
2410# if defined HAVE_FGETATTRLIST
2411 int ret = gvl_fgetattrlist(&args, dirfd(dirp));
2413 int ret = gvl_getattrlist(&args, path);
2418 if (!(cap->valid[idx] & mask))
2420 return (cap->capabilities[idx] & mask) != 0;
2424replace_real_basename(
char *path,
long base,
rb_encoding *enc,
int norm_p,
int flags, rb_pathtype_t *
type)
2428 attrreference_t ref[1];
2429 fsobj_type_t objtype;
2430 char path[MAXPATHLEN * 3];
2432 struct attrlist al = {ATTR_BIT_MAP_COUNT, 0, ATTR_CMN_NAME|ATTR_CMN_OBJTYPE};
2433 const attrreference_t *
const ar = attrbuf[0].ref;
2437 IF_NORMALIZE_UTF8PATH(
VALUE utf8str =
Qnil);
2440 struct getattrlist_args args = GETATTRLIST_ARGS(&al, attrbuf, FSOPT_NOFOLLOW);
2441 if (gvl_getattrlist(&args, path)) {
2442 if (!to_be_ignored(
errno))
2443 sys_warning(path, enc);
2447 switch (attrbuf[0].objtype) {
2448 case VREG: *
type = path_regular;
break;
2449 case VDIR: *
type = path_directory;
break;
2450 case VLNK: *
type = path_symlink;
break;
2451 default: *
type = path_exist;
break;
2453 name = (
char *)ar + ar->attr_dataoffset;
2454 len = (long)ar->attr_length - 1;
2455 if (name +
len > (
char *)attrbuf +
sizeof(attrbuf))
2458# if NORMALIZE_UTF8PATH
2459 if (norm_p && has_nonascii(name,
len)) {
2460 if (!
NIL_P(utf8str = rb_str_normalize_ospath(name,
len))) {
2466 tmp = GLOB_REALLOC(path, base +
len + 1);
2469 memcpy(path + base, name,
len);
2470 path[base +
len] =
'\0';
2472 IF_NORMALIZE_UTF8PATH(
if (!
NIL_P(utf8str)) rb_str_resize(utf8str, 0));
2477int rb_w32_reparse_symlink_p(
const WCHAR *path);
2480replace_real_basename(
char *path,
long base,
rb_encoding *enc,
int norm_p,
int flags, rb_pathtype_t *
type)
2482 char *plainname = path;
2483 volatile VALUE tmp = 0;
2484 WIN32_FIND_DATAW fd;
2485 WIN32_FILE_ATTRIBUTE_DATA fa;
2487 HANDLE h = INVALID_HANDLE_VALUE;
2490 if (!fundamental_encoding_p(enc)) {
2492 tmp = rb_str_encode_ospath(tmp);
2493 plainname = RSTRING_PTR(tmp);
2495 wplain = rb_w32_mbstr_to_wstr(CP_UTF8, plainname, -1, &wlen);
2496 if (tmp) rb_str_resize(tmp, 0);
2497 if (!wplain)
return path;
2498 if (GetFileAttributesExW(wplain, GetFileExInfoStandard, &fa)) {
2499 h = FindFirstFileW(wplain, &fd);
2500 e = rb_w32_map_errno(GetLastError());
2502 if (fa.dwFileAttributes & FILE_ATTRIBUTE_REPARSE_POINT) {
2503 if (!rb_w32_reparse_symlink_p(wplain))
2504 fa.dwFileAttributes &= ~FILE_ATTRIBUTE_REPARSE_POINT;
2507 if (h == INVALID_HANDLE_VALUE) {
2509 if (e && !to_be_ignored(e)) {
2511 sys_warning(path, enc);
2517 (fa.dwFileAttributes & FILE_ATTRIBUTE_REPARSE_POINT) ? path_symlink :
2518 (fa.dwFileAttributes & FILE_ATTRIBUTE_DIRECTORY) ? path_directory :
2522 tmp = rb_w32_conv_from_wchar(fd.cFileName, enc);
2523 wlen = RSTRING_LEN(tmp);
2524 buf = GLOB_REALLOC(path, base + wlen + 1);
2527 memcpy(path + base, RSTRING_PTR(tmp), wlen);
2528 path[base + wlen] = 0;
2530 rb_str_resize(tmp, 0);
2534 wlen = WideCharToMultiByte(CP_UTF8, 0, fd.cFileName, -1, NULL, 0, NULL, NULL);
2535 utf8filename = GLOB_REALLOC(0, wlen);
2538 WideCharToMultiByte(CP_UTF8, 0, fd.cFileName, -1, utf8filename, wlen, NULL, NULL);
2539 buf = GLOB_REALLOC(path, base + wlen + 1);
2542 memcpy(path + base, utf8filename, wlen);
2543 path[base + wlen] = 0;
2545 GLOB_FREE(utf8filename);
2550#elif USE_NAME_ON_FS == USE_NAME_ON_FS_REAL_BASENAME
2551# error not implemented
2555# define S_ISDIR(m) (((m) & S_IFMT) == S_IFDIR)
2560# define S_ISLNK(m) (0)
2562# define S_ISLNK(m) (((m) & S_IFMT) == S_IFLNK)
2567 void (*func)(
const char *,
VALUE,
void *);
2575#define glob_call_func(func, path, arg, enc) (*(func))((path), (arg), (void *)(enc))
2578glob_func_caller(
VALUE val)
2582 glob_call_func(args->func, args->path, args->value, args->enc);
2593glob_func_warning(
VALUE val)
2596 rb_syserr_enc_warning(arg->error, arg->enc,
"%s", arg->path);
2602rb_glob_warning(
const char *path,
VALUE a,
const void *enc,
int error)
2610 rb_protect(glob_func_warning, (
VALUE)&args, &status);
2615NORETURN(
static VALUE glob_func_error(
VALUE val));
2618glob_func_error(
VALUE val)
2627rb_glob_error(
const char *path,
VALUE a,
const void *enc,
int error)
2638 errfunc = glob_func_warning;
2643 rb_protect(errfunc, (
VALUE)&args, &status);
2651 const char *d_altname;
2659 if (fnmatch(pat, enc, name, flags) == 0)
return 1;
2661 if (dp->d_altname && (flags & FNM_SHORTNAME)) {
2662 if (fnmatch(pat, enc, dp->d_altname, flags) == 0)
return 1;
2675glob_directory_seen(
const struct glob_directory *directory,
const struct stat *st)
2677 for (; directory; directory = directory->parent) {
2678 if (directory->st.st_dev == st->st_dev && directory->st.st_ino == st->st_ino
2679#ifdef HAVE_STRUCT_STAT_ST_INOHIGH
2680 && directory->st.st_inohigh == st->st_inohigh
2693 rb_pathtype_t pathtype;
2707dirent_match_brace(
const char *pattern,
VALUE val,
void *enc)
2711 return dirent_match(pattern, enc, arg->name, arg->dp, arg->flags);
2720 size_t path_len = 0;
2722 for (p = *beg; p; p = p->next) {
2726 str = p->follow_symlinks ?
"***" :
"**";
2737 size_t len = strlen(str);
2738 char *tmp = join_path(path ? path :
"", path_len, path != NULL, str,
len);
2743 if (!tmp)
return NULL;
2751static int push_caller(
const char *path,
VALUE val,
void *enc);
2756static const size_t rb_dirent_name_offset =
2760dirent_copy(
const struct dirent *dp,
rb_dirent_t *rdp)
2762 if (!dp)
return NULL;
2763 size_t namlen = NAMLEN(dp);
2764 const size_t altlen =
2766 dp->d_altlen ? dp->d_altlen + 1 :
2770 if (!rdp && !(newrdp = malloc(rb_dirent_name_offset + namlen + 1 + altlen)))
2772 newrdp->d_namlen = namlen;
2774 char *name = (
char *)newrdp + rb_dirent_name_offset;
2775 memcpy(name, dp->d_name, namlen);
2776 name[namlen] =
'\0';
2778 newrdp->d_altname = NULL;
2780 char *
const altname = name + namlen + 1;
2781 memcpy(altname, dp->d_altname, altlen - 1);
2782 altname[altlen - 1] =
'\0';
2783 newrdp->d_altname = altname;
2786 newrdp->d_name = name;
2789 newrdp->d_name = dp->d_name;
2791 newrdp->d_altname = dp->d_altname;
2795 newrdp->d_type = dp->d_type;
2814glob_sort_cmp(
const void *a,
const void *b,
void *e)
2818 return strcmp(ent1->d_name, ent2->d_name);
2824 if (flags & FNM_GLOB_NOSORT) {
2825 check_closedir(ent->nosort.dirp);
2826 ent->nosort.dirp = NULL;
2828 else if (ent->sort.entries) {
2829 for (
size_t i = 0, count = ent->sort.count; i < count;) {
2830 GLOB_FREE(ent->sort.entries[i++]);
2832 GLOB_FREE(ent->sort.entries);
2833 ent->sort.entries = NULL;
2834 ent->sort.count = ent->sort.idx = 0;
2842 if (flags & FNM_GLOB_NOSORT) {
2843 ent->nosort.dirp = dirp;
2849 size_t count = 0, capacity = 0;
2850 ent->sort.count = 0;
2852 ent->sort.entries = 0;
2854 if ((capacity = dirp->nfiles) > 0) {
2855 if (!(newp = GLOB_ALLOC_N(
rb_dirent_t, capacity))) {
2856 check_closedir(dirp);
2859 ent->sort.entries = newp;
2862 while ((dp = READDIR(dirp, enc)) != NULL) {
2867 if (count >= capacity) {
2869 if (!(newp = GLOB_REALLOC_N(ent->sort.entries, capacity))) {
2873 ent->sort.entries = newp;
2875 ent->sort.entries[count++] = rdp;
2876 ent->sort.count = count;
2878 check_closedir(dirp);
2879 if (count < capacity) {
2880 if (!(newp = GLOB_REALLOC_N(ent->sort.entries, count))) {
2881 glob_dir_finish(ent, 0);
2884 ent->sort.entries = newp;
2886 ruby_qsort(ent->sort.entries, ent->sort.count,
sizeof(ent->sort.entries[0]),
2887 glob_sort_cmp, NULL);
2892 glob_dir_finish(ent, 0);
2893 check_closedir(dirp);
2900 if (flags & FNM_GLOB_NOSORT) {
2901 return dirent_copy(READDIR(ent->nosort.dirp, enc), &ent->nosort.ent);
2903 else if (ent->sort.idx < ent->sort.count) {
2904 return ent->sort.entries[ent->sort.idx++];
2918 rb_pathtype_t pathtype,
2931 int plain = 0, brace = 0, magical = 0, recursive = 0, match_all = 0, match_dir = 0;
2932 int follow_symlink = 0;
2933 int escape = !(flags & FNM_NOESCAPE);
2934 size_t pathlen = baselen + namelen;
2936 rb_check_stack_overflow();
2938 for (cur = beg; cur < end; ++cur) {
2940 if (p->type == RECURSIVE) {
2942 if (p->follow_symlinks) follow_symlink = 1;
2950#if USE_NAME_ON_FS == USE_NAME_ON_FS_REAL_BASENAME
2957 if (!recursive || strchr(p->str,
'/')) {
2971 rb_bug(
"continuous RECURSIVEs");
2977 char* brace_path = join_path_from_pattern(beg);
2978 if (!brace_path)
return -1;
2981 args.baselen = baselen;
2982 args.namelen = namelen;
2983 args.dirsep = dirsep;
2984 args.pathtype = pathtype;
2985 args.ancestors = ancestors;
2989 status = ruby_brace_expand(brace_path, flags, push_caller, (
VALUE)&args, enc,
Qfalse);
2990 GLOB_FREE(brace_path);
2995 if (match_all && pathtype == path_unknown) {
2996 if (do_lstat(fd, path, &st, flags, enc) == 0) {
2997 pathtype = IFTODT(st.st_mode);
3000 pathtype = path_noent;
3003 if (match_dir && (pathtype == path_unknown || pathtype == path_symlink)) {
3004 if (do_stat(fd, path, &st, flags, enc) == 0) {
3005 pathtype = IFTODT(st.st_mode);
3008 pathtype = path_noent;
3011 if (match_all && pathtype > path_noent) {
3012 const char *subpath = path + baselen + (baselen && path[baselen] ==
'/');
3013 status = glob_call_func(funcs->match, subpath, arg, enc);
3014 if (status)
return status;
3016 if (match_dir && pathtype == path_directory) {
3017 int seplen = (baselen && path[baselen] ==
'/');
3018 const char *subpath = path + baselen + seplen;
3019 char *tmp = join_path(subpath, namelen - seplen, dirsep,
"", 0);
3020 if (!tmp)
return -1;
3021 status = glob_call_func(funcs->match, tmp, arg, enc);
3023 if (status)
return status;
3027 if (pathtype == path_noent)
return 0;
3029 if ((follow_symlink || ancestors) && (magical || recursive || plain)) {
3030 if (do_stat(fd, at_subpath(fd, baselen, path), &directory.st, flags, enc) < 0 ||
3031 !S_ISDIR(directory.st.st_mode))
return 0;
3032 directory.parent = ancestors;
3033 ancestors = &directory;
3036 if (magical || recursive) {
3039 IF_NORMALIZE_UTF8PATH(
int norm_p);
3040 dirp = do_opendir(fd, baselen, path, flags, enc, funcs->error, arg, &status);
3042# if FNM_SYSCASE || NORMALIZE_UTF8PATH
3043 if ((magical < 2) && !recursive && (
errno == EACCES)) {
3050 IF_NORMALIZE_UTF8PATH(norm_p = need_normalization(dirp, *path ? path :
"."));
3052# if NORMALIZE_UTF8PATH
3053 if (!(norm_p || magical || recursive)) {
3054 check_closedir(dirp);
3058# ifdef HAVE_GETATTRLIST
3059 if (is_case_sensitive(dirp, path) == 0)
3060 flags |= FNM_CASEFOLD;
3063 if (!glob_opendir(&globent, dirp, flags, enc)) {
3066 status = (*funcs->error)(path, arg, enc, ENOMEM);
3069 sys_warning(path, enc);
3074 int skipdot = (flags & FNM_GLOB_SKIPDOT);
3075 flags |= FNM_GLOB_SKIPDOT;
3077 while ((dp = glob_getent(&globent, flags, enc)) != NULL) {
3079 rb_pathtype_t new_pathtype = path_unknown;
3083 int symlink_directory = 0;
3084 bool symlink_cycle =
false;
3085 IF_NORMALIZE_UTF8PATH(
VALUE utf8str =
Qnil);
3088 namlen = dp->d_namlen;
3089 if (name[0] ==
'.') {
3093 if (recursive && !(flags & FNM_DOTMATCH))
continue;
3094 if (skipdot)
continue;
3096 new_pathtype = path_directory;
3098 else if (namlen == 2 && name[1] ==
'.') {
3104# if NORMALIZE_UTF8PATH
3105 if (norm_p && has_nonascii(name, namlen)) {
3106 if (!
NIL_P(utf8str = rb_str_normalize_ospath(name, namlen))) {
3111 buf = join_path(path, pathlen, dirsep, name, namlen);
3112 IF_NORMALIZE_UTF8PATH(
if (!
NIL_P(utf8str)) rb_str_resize(utf8str, 0));
3117 name = buf + pathlen + (dirsep != 0);
3119 if (dp->d_type != DT_UNKNOWN) {
3121 new_pathtype = dp->d_type;
3124 if (recursive && dotfile < ((flags & FNM_DOTMATCH) ? 2 : 1) &&
3125 new_pathtype == path_unknown) {
3127 if (do_lstat(fd, buf, &st, flags, enc) == 0)
3128 new_pathtype = IFTODT(st.st_mode);
3130 new_pathtype = path_noent;
3133 if (follow_symlink && new_pathtype == path_symlink &&
3134 dotfile < ((flags & FNM_DOTMATCH) ? 2 : 1)) {
3135 symlink_directory = do_stat(fd, at_subpath(fd, baselen, buf), &st, flags, enc) == 0 &&
3136 S_ISDIR(st.st_mode);
3137 if (symlink_directory) symlink_cycle = glob_directory_seen(ancestors, &st);
3140 new_beg = new_end = GLOB_ALLOC_N(
struct glob_pattern *, (end - beg) * 2);
3147 for (cur = beg; cur < end; ++cur) {
3150 if (p->type == RECURSIVE) {
3151 if (new_pathtype == path_directory ||
3152 new_pathtype == path_exist) {
3153 if (dotfile < ((flags & FNM_DOTMATCH) ? 2 : 1))
3156 else if (p->follow_symlinks && symlink_directory) {
3157 if (!symlink_cycle) {
3160 else if (p->next->type == MATCH_DIR) {
3162 *new_end++ = p->next;
3172 if (ruby_brace_expand(p->str, flags, dirent_match_brace,
3174 *new_end++ = p->next;
3179 if (dirent_match(p->str, enc, name, dp, flags))
3180 *new_end++ = p->next;
3186 status = glob_helper(fd, buf, baselen, name - buf - baselen + namlen, 1,
3187 new_pathtype, new_beg, new_end,
3188 ancestors, flags, funcs, arg, enc);
3194 glob_dir_finish(&globent, flags);
3199# if FNM_SYSCASE || NORMALIZE_UTF8PATH
3202 copy_beg = copy_end = GLOB_ALLOC_N(
struct glob_pattern *, end - beg);
3203 if (!copy_beg)
return -1;
3204 for (cur = beg; cur < end; ++cur)
3205 *copy_end++ = (*cur)->type <= ALPHA ? *cur : 0;
3207 for (cur = copy_beg; cur < copy_end; ++cur) {
3209 rb_pathtype_t new_pathtype = path_unknown;
3212 size_t len = strlen((*cur)->str) + 1;
3213 name = GLOB_ALLOC_N(
char,
len);
3218 memcpy(name, (*cur)->str,
len);
3220 len = remove_backslashes(name, name+
len-1, enc) - name;
3222 new_beg = new_end = GLOB_ALLOC_N(
struct glob_pattern *, end - beg);
3228 *new_end++ = (*cur)->next;
3229 for (cur2 = cur + 1; cur2 < copy_end; ++cur2) {
3230 if (*cur2 && fnmatch((*cur2)->str, enc, name, flags) == 0) {
3231 *new_end++ = (*cur2)->next;
3236 buf = join_path(path, pathlen, dirsep, name,
len);
3243#if USE_NAME_ON_FS == USE_NAME_ON_FS_REAL_BASENAME
3244 if ((*cur)->type == ALPHA) {
3245 buf = replace_real_basename(buf, pathlen + (dirsep != 0), enc,
3246 IF_NORMALIZE_UTF8PATH(1)+0,
3247 flags, &new_pathtype);
3251 status = glob_helper(fd, buf, baselen,
3252 namelen + strlen(buf + pathlen), 1,
3253 new_pathtype, new_beg, new_end,
3254 ancestors, flags, funcs, arg, enc);
3261 GLOB_FREE(copy_beg);
3268push_caller(
const char *path,
VALUE val,
void *enc)
3274 list = glob_make_pattern(path, path + strlen(path), arg->flags, enc);
3278 status = glob_helper(arg->fd, arg->path, arg->baselen, arg->namelen, arg->dirsep,
3279 arg->pathtype, &list, &list + 1, arg->ancestors, arg->flags, arg->funcs,
3281 glob_free_pattern(list);
3285static int ruby_glob0(
const char *path,
int fd,
const char *base,
int flags,
3297push_glob0_caller(
const char *path,
VALUE val,
void *enc)
3300 return ruby_glob0(path, arg->fd, arg->base, arg->flags, arg->funcs, arg->arg, enc);
3304ruby_glob0(
const char *path,
int fd,
const char *base,
int flags,
3309 const char *root, *start;
3311 size_t n, baselen = 0;
3312 int status, dirsep = FALSE;
3314 start = root = path;
3323 return ruby_brace_expand(path, flags, push_glob0_caller, (
VALUE)&args, enc,
Qfalse);
3326 flags |= FNM_SYSCASE;
3328 root = rb_enc_path_skip_prefix(root, root + strlen(root), enc);
3331 if (*root ==
'/') root++;
3340 buf = GLOB_ALLOC_N(
char, n + 1);
3341 if (!buf)
return -1;
3342 MEMCPY(buf, start,
char, n);
3345 list = glob_make_pattern(root, root + strlen(root), flags, enc);
3350 status = glob_helper(fd, buf, baselen, n-baselen, dirsep,
3351 path_unknown, &list, &list + 1,
3352 NULL, flags, funcs, arg, enc);
3353 glob_free_pattern(list);
3365 return ruby_glob0(path, AT_FDCWD, 0, flags & ~GLOB_VERBOSE,
3366 &funcs, arg, rb_ascii8bit_encoding());
3370rb_glob_caller(
const char *path,
VALUE a,
void *enc)
3376 rb_protect(glob_func_caller, a, &status);
3381 rb_glob_caller, rb_glob_error,
3385rb_glob(
const char *path,
void (*func)(
const char *,
VALUE,
void *),
VALUE arg)
3392 args.enc = rb_ascii8bit_encoding();
3394 status = ruby_glob0(path, AT_FDCWD, 0, GLOB_VERBOSE, &rb_glob_funcs,
3395 (
VALUE)&args, args.enc);
3396 if (status) GLOB_JUMP_TAG(status);
3400push_pattern(
const char *path,
VALUE ary,
void *enc)
3402#if defined _WIN32 || defined __APPLE__
3404 rb_encoding *eenc = rb_default_internal_encoding();
3416 const int escape = !(flags & FNM_NOESCAPE);
3417 const char *p = str;
3418 const char *pend = p + strlen(p);
3420 const char *lbrace = 0, *rbrace = 0;
3421 int nest = 0, status = 0;
3424 if (*p ==
'{' && nest++ == 0) {
3427 if (*p ==
'}' && lbrace && --nest == 0) {
3431 if (*p ==
'\\' && escape) {
3437 if (lbrace && rbrace) {
3438 size_t len = strlen(s) + 1;
3439 char *buf = GLOB_ALLOC_N(
char,
len);
3442 if (!buf)
return -1;
3443 memcpy(buf, s, lbrace-s);
3446 while (p < rbrace) {
3447 const char *t = ++p;
3449 while (p < rbrace && !(*p ==
',' && nest == 0)) {
3450 if (*p ==
'{') nest++;
3451 if (*p ==
'}') nest--;
3452 if (*p ==
'\\' && escape) {
3453 if (++p == rbrace)
break;
3457 memcpy(buf+shift, t, p-t);
3458 strlcpy(buf+shift+(p-t), rbrace+1,
len-(shift+(p-t)));
3459 status = ruby_brace_expand(buf, flags, func, arg, enc, var);
3464 else if (!lbrace && !rbrace) {
3465 status = glob_call_func(func, s, arg, enc);
3479glob_brace(
const char *path,
VALUE val,
void *enc)
3483 return ruby_glob0(path, AT_FDCWD, 0, arg->flags, &arg->funcs, arg->value, enc);
3491 flags &= ~GLOB_VERBOSE;
3492 args.funcs.match = func;
3493 args.funcs.error = 0;
3496 return ruby_brace_expand(str, flags, glob_brace, (
VALUE)&args, enc,
Qfalse);
3502 return ruby_brace_glob_with_enc(str, flags, func, arg, rb_ascii8bit_encoding());
3512#if defined _WIN32 || defined __APPLE__
3513 str = rb_str_encode_ospath(str);
3515 if (rb_enc_to_index(enc) == ENCINDEX_US_ASCII)
3516 enc = rb_filesystem_encoding();
3517 if (rb_enc_to_index(enc) == ENCINDEX_US_ASCII)
3518 enc = rb_ascii8bit_encoding();
3519 flags |= GLOB_VERBOSE;
3520 args.func = push_pattern;
3527 struct dir_data *dirp = RTYPEDDATA_GET_DATA(base);
3528 if (!dirp->dir) dir_closed();
3530 if ((fd = dirfd(dirp->dir)) == -1)
3531 rb_sys_fail_path(dir_inspect(base));
3535 args.base = RSTRING_PTR(base);
3537#if defined _WIN32 || defined __APPLE__
3538 enc = rb_utf8_encoding();
3541 return ruby_glob0(RSTRING_PTR(str), fd, args.base, flags, &rb_glob_funcs,
3546rb_push_glob(
VALUE str,
VALUE base,
int flags)
3555 else if (!rb_str_to_cstr(str)) {
3556 rb_raise(rb_eArgError,
"nul-separated glob pattern is deprecated");
3559 rb_enc_check(str, rb_enc_from_encoding(rb_usascii_encoding()));
3563 status = push_glob(ary, str, base, flags);
3564 if (status) GLOB_JUMP_TAG(status);
3579 status = push_glob(ary, str, base, flags);
3580 if (status) GLOB_JUMP_TAG(status);
3588dir_glob_option_base(
VALUE base)
3590 if (NIL_OR_UNDEF_P(base)) {
3594 if (rb_typeddata_is_kind_of(base, &dir_data_type)) {
3599 if (!RSTRING_LEN(base))
return Qnil;
3604dir_glob_option_sort(
VALUE sort)
3606 return (rb_bool_expected(sort,
"sort", TRUE) ? 0 : FNM_GLOB_NOSORT);
3612 const int flags = dir_glob_option_sort(sort);
3613 base = dir_glob_option_base(base);
3615 return rb_push_glob(
RARRAY_AREF(args, 0), base, flags);
3617 return dir_globs(args, base, flags);
3624 const int flags = (
NUM2INT(rflags) | dir_glob_option_sort(sort)) & ~FNM_CASEFOLD;
3625 base = dir_glob_option_base(base);
3627 ary = rb_push_glob(str, base, flags);
3630 ary = dir_globs(ary, base, flags);
3641dir_open_dir(
int argc,
VALUE *argv)
3687 dir = dir_open_dir(argc, argv);
3688 rb_ensure(dir_each, dir, dir_close, dir);
3699dir_collect(
VALUE dir)
3702 dir_each_entry(dir, dir_entry_ary_push, ary, FALSE);
3728 dir = dir_open_dir(argc, argv);
3729 return rb_ensure(dir_collect, dir, dir_close, dir);
3733dir_each_child(
VALUE dir)
3735 return dir_each_entry(dir, dir_yield,
Qnil, TRUE);
3747dir_s_each_child(
int argc,
VALUE *argv,
VALUE io)
3752 dir = dir_open_dir(argc, argv);
3753 rb_ensure(dir_each_child, dir, dir_close, dir);
3776dir_each_child_m(
VALUE dir)
3779 return dir_each_entry(dir, dir_yield,
Qnil, TRUE);
3794dir_collect_children(
VALUE dir)
3797 dir_each_entry(dir, dir_entry_ary_push, ary, TRUE);
3825dir_scan_children(
VALUE dir)
3828 dir_each_entry(dir, dir_yield_with_type,
Qnil, TRUE);
3833 dir_each_entry(dir, dir_yield_with_type, ary, TRUE);
3858dir_s_children(
int argc,
VALUE *argv,
VALUE io)
3862 dir = dir_open_dir(argc, argv);
3863 return rb_ensure(dir_collect_children, dir, dir_close, dir);
3905dir_s_scan(
int argc,
VALUE *argv,
VALUE klass)
3907 VALUE dir = dir_open_dir(argc, argv);
3908 return rb_ensure(dir_scan_children, dir, dir_close, dir);
3912fnmatch_brace(
const char *pattern,
VALUE val,
void *enc)
3915 VALUE path = arg->value;
3919 if (enc_pattern != enc_path) {
3920 if (!rb_enc_asciicompat(enc_pattern))
3922 if (!rb_enc_asciicompat(enc_path))
3926 long len = strlen(pattern);
3928 enc_pattern, &cr) !=
len)
3934 return (fnmatch(pattern, enc, RSTRING_PTR(path), arg->flags) == 0);
3939file_s_fnmatch(
int argc,
VALUE *argv,
VALUE obj)
3941 VALUE pattern, path;
3945 if (
rb_scan_args(argc, argv,
"21", &pattern, &path, &rflags) == 3)
3953 if (flags & FNM_EXTGLOB) {
3958 if (ruby_brace_expand(RSTRING_PTR(pattern), flags, fnmatch_brace,
3959 (
VALUE)&args, rb_enc_get(pattern), pattern) > 0)
3963 rb_encoding *enc = rb_enc_compatible(pattern, path);
3965 if (fnmatch(RSTRING_PTR(pattern), enc, RSTRING_PTR(path), flags) == 0)
3992 user = (argc > 0) ? argv[0] :
Qnil;
3998 return rb_home_dir_of(user,
rb_str_new(0, 0));
4001 return rb_default_home_dir(
rb_str_new(0, 0));
4020rb_file_directory_p(
void)
4026nogvl_dir_empty_p(
void *ptr)
4028 const char *path = ptr;
4029 DIR *dir = opendir(path);
4035 switch (gc_for_fd_with_gvl(e)) {
4037 dir = opendir(path);
4042 if (e == ENOTDIR)
return (
void *)
Qfalse;
4046 while ((dp = READDIR_NOGVL(dir, NULL)) != NULL) {
4047 if (!to_be_skipped(dp)) {
4052 check_closedir(dir);
4053 return (
void *)result;
4076 enum {false_on_notdir = 1};
4080 dirname = rb_str_encode_ospath(dirname);
4082 path = RSTRING_PTR(dirname);
4084#if defined HAVE_GETATTRLIST && defined ATTR_DIR_ENTRYCOUNT
4086 u_int32_t attrbuf[SIZEUP32(fsobj_tag_t)];
4087 struct attrlist al = {ATTR_BIT_MAP_COUNT, 0, ATTR_CMN_OBJTAG,};
4088 struct getattrlist_args args = GETATTRLIST_ARGS(&al, attrbuf, 0);
4089 if (gvl_getattrlist(&args, path) != 0)
4090 rb_sys_fail_path(orig);
4091 if (*(
const fsobj_tag_t *)(attrbuf+1) == VT_HFS) {
4093 al.dirattr = ATTR_DIR_ENTRYCOUNT;
4094 if (gvl_getattrlist(&args, path) == 0) {
4095 if (attrbuf[0] >= 2 *
sizeof(u_int32_t))
4096 return RBOOL(attrbuf[1] == 0);
4097 if (false_on_notdir)
return Qfalse;
4099 rb_sys_fail_path(orig);
4104 result = (
VALUE)IO_WITHOUT_GVL(nogvl_dir_empty_p, (
void *)path);
4106 rb_syserr_fail_path((
int)
FIX2LONG(result), orig);
4114 sym_directory =
ID2SYM(rb_intern(
"directory"));
4115 sym_link =
ID2SYM(rb_intern(
"link"));
4116 sym_file =
ID2SYM(rb_intern(
"file"));
4117 sym_unknown =
ID2SYM(rb_intern(
"unknown"));
4119#if defined(DT_BLK) || defined(S_IFBLK)
4120 sym_block_device =
ID2SYM(rb_intern(
"blockSpecial"));
4122#if defined(DT_CHR) || defined(S_IFCHR)
4123 sym_character_device =
ID2SYM(rb_intern(
"characterSpecial"));
4125#if defined(DT_FIFO) || defined(S_IFIFO)
4126 sym_fifo =
ID2SYM(rb_intern(
"fifo"));
4128#if defined(DT_SOCK) || defined(S_IFSOCK)
4129 sym_socket =
ID2SYM(rb_intern(
"socket"));
4132 rb_gc_register_address(&chdir_lock.path);
4133 rb_gc_register_address(&last_cwd);
4182 rb_file_const(
"FNM_NOESCAPE",
INT2FIX(FNM_NOESCAPE));
4184 rb_file_const(
"FNM_PATHNAME",
INT2FIX(FNM_PATHNAME));
4186 rb_file_const(
"FNM_DOTMATCH",
INT2FIX(FNM_DOTMATCH));
4188 rb_file_const(
"FNM_CASEFOLD",
INT2FIX(FNM_CASEFOLD));
4190 rb_file_const(
"FNM_EXTGLOB",
INT2FIX(FNM_EXTGLOB));
4192 rb_file_const(
"FNM_SYSCASE",
INT2FIX(FNM_SYSCASE));
4194 rb_file_const(
"FNM_SHORTNAME",
INT2FIX(FNM_SHORTNAME));
#define RBIMPL_ASSERT_OR_ASSUME(...)
This is either RUBY_ASSERT or RBIMPL_ASSUME, depending on RUBY_DEBUG.
#define RUBY_DEBUG
Define this macro when you want assertions.
#define RUBY_ATOMIC_VALUE_SET(var, val)
Identical to RUBY_ATOMIC_SET, except it expects its arguments are VALUE.
#define rb_define_method(klass, mid, func, arity)
Defines klass#mid.
#define rb_define_singleton_method(klass, mid, func, arity)
Defines klass.mid.
int ruby_glob_func(const char *path, VALUE arg, void *enc)
Type of a glob callback function.
void rb_include_module(VALUE klass, VALUE module)
Includes a module to a class.
int rb_scan_args(int argc, const VALUE *argv, const char *fmt,...)
Retrieves argument from argc and argv to given VALUE references according to the format string.
int rb_block_given_p(void)
Determines if the current method is given a block.
#define rb_str_new2
Old name of rb_str_new_cstr.
#define ENC_CODERANGE_7BIT
Old name of RUBY_ENC_CODERANGE_7BIT.
#define T_STRING
Old name of RUBY_T_STRING.
#define xfree
Old name of ruby_xfree.
#define INT2FIX
Old name of RB_INT2FIX.
#define rb_str_cat2
Old name of rb_str_cat_cstr.
#define ID2SYM
Old name of RB_ID2SYM.
#define UNREACHABLE_RETURN
Old name of RBIMPL_UNREACHABLE_RETURN.
#define CLASS_OF
Old name of rb_class_of.
#define ISALPHA
Old name of rb_isalpha.
#define ISASCII
Old name of rb_isascii.
#define Qtrue
Old name of RUBY_Qtrue.
#define NUM2INT
Old name of RB_NUM2INT.
#define INT2NUM
Old name of RB_INT2NUM.
#define Qnil
Old name of RUBY_Qnil.
#define Qfalse
Old name of RUBY_Qfalse.
#define FIX2LONG
Old name of RB_FIX2LONG.
#define NIL_P
Old name of RB_NIL_P.
#define MBCLEN_CHARFOUND_P(ret)
Old name of ONIGENC_MBCLEN_CHARFOUND_P.
#define NUM2LONG
Old name of RB_NUM2LONG.
#define FIXNUM_P
Old name of RB_FIXNUM_P.
void rb_syserr_fail(int e, const char *mesg)
Raises appropriate exception that represents a C errno.
VALUE rb_eIOError
IOError exception.
void rb_syserr_fail_str(int e, VALUE mesg)
Identical to rb_syserr_fail(), except it takes the message in Ruby's String instead of C's.
VALUE rb_eRuntimeError
RuntimeError exception.
void * rb_check_typeddata(VALUE obj, const rb_data_type_t *data_type)
Identical to rb_typeddata_is_kind_of(), except it raises exceptions instead of returning false.
void rb_warn(const char *fmt,...)
Identical to rb_warning(), except it reports unless $VERBOSE is nil.
VALUE rb_cObject
Object class.
VALUE rb_mEnumerable
Enumerable module.
VALUE rb_cFile
File class.
#define RB_OBJ_WRITE(old, slot, young)
Declaration of a "back" pointer.
static unsigned int rb_enc_codepoint(const char *p, const char *e, rb_encoding *enc)
Queries the code point of character pointed by the passed pointer.
VALUE rb_str_conv_enc(VALUE str, rb_encoding *from, rb_encoding *to)
Encoding conversion main routine.
VALUE rb_enc_str_new_cstr(const char *ptr, rb_encoding *enc)
Identical to rb_enc_str_new(), except it assumes the passed pointer is a pointer to a C string.
VALUE rb_external_str_new_with_enc(const char *ptr, long len, rb_encoding *enc)
Identical to rb_external_str_new(), except it additionally takes an encoding.
int rb_enc_str_asciionly_p(VALUE str)
Queries if the passed string is "ASCII only".
long rb_str_coderange_scan_restartable(const char *str, const char *end, rb_encoding *enc, int *cr)
Scans the passed string until it finds something odd.
VALUE rb_funcallv_kw(VALUE recv, ID mid, int argc, const VALUE *argv, int kw_splat)
Identical to rb_funcallv(), except you can specify how to handle the last element of the given array.
VALUE rb_funcallv(VALUE recv, ID mid, int argc, const VALUE *argv)
Identical to rb_funcall(), except it takes the method arguments as a C array.
Defines RBIMPL_HAS_BUILTIN.
VALUE rb_ary_each(VALUE ary)
Iteratively yields each element of the passed array to the implicitly passed block if any.
VALUE rb_check_array_type(VALUE obj)
Try converting an object to its array representation using its to_ary method, if any.
VALUE rb_ary_new(void)
Allocates a new, empty array.
VALUE rb_ary_push(VALUE ary, VALUE elem)
Special case of rb_ary_cat() that it adds only one element.
VALUE rb_assoc_new(VALUE car, VALUE cdr)
Identical to rb_ary_new_from_values(), except it expects exactly two parameters.
#define RETURN_ENUMERATOR(obj, argc, argv)
Identical to RETURN_SIZED_ENUMERATOR(), except its size is unknown.
static int rb_check_arity(int argc, int min, int max)
Ensures that the passed integer is in the passed range.
VALUE rb_str_new_shared(VALUE str)
Identical to rb_str_new_cstr(), except it takes a Ruby's string instead of C's.
#define rb_utf8_str_new_cstr(str)
Identical to rb_str_new_cstr, except it generates a string of "UTF-8" encoding.
VALUE rb_str_append(VALUE dst, VALUE src)
Identical to rb_str_buf_append(), except it converts the right hand side before concatenating.
VALUE rb_str_subseq(VALUE str, long beg, long len)
Identical to rb_str_substr(), except the numbers are interpreted as byte offsets instead of character...
#define rb_str_new(str, len)
Allocates an instance of rb_cString.
VALUE rb_str_dup(VALUE str)
Duplicates a string.
void rb_must_asciicompat(VALUE obj)
Asserts that the given string's encoding is (Ruby's definition of) ASCII compatible.
VALUE rb_str_freeze(VALUE str)
This is the implementation of String#freeze.
#define rb_str_dup_frozen
Just another name of rb_str_new_frozen.
#define rb_str_new_cstr(str)
Identical to rb_str_new, except it assumes the passed pointer is a pointer to a C string.
VALUE rb_thread_current(void)
Obtains the "current" thread.
VALUE rb_class_name(VALUE obj)
Queries the name of the given object's class.
void rb_define_alloc_func(VALUE klass, rb_alloc_func_t func)
Sets the allocator function of a class.
int len
Length of the buffer.
#define RB_OBJ_SET_SHAREABLE(obj)
Wrapper of rb_obj_set_shareable().
static VALUE RB_OBJ_SET_FROZEN_SHAREABLE(VALUE obj)
Freezes and marks the object as shareable.
void * rb_thread_call_with_gvl(void *(*func)(void *), void *data1)
(Re-)acquires the GVL.
void ruby_qsort(void *, const size_t, const size_t, int(*)(const void *, const void *, void *), void *)
Reentrant implementation of quick sort.
char * ruby_getcwd(void)
This is our own version of getcwd(3) that uses ruby_xmalloc() instead of system malloc (benefits our ...
#define RB_NUM2INT
Just another name of rb_num2int_inline.
VALUE rb_yield_values(int n,...)
Identical to rb_yield(), except it takes variadic number of parameters and pass them to the block.
VALUE rb_yield_values2(int n, const VALUE *argv)
Identical to rb_yield_values(), except it takes the parameters as a C array instead of variadic argum...
VALUE rb_yield(VALUE val)
Yields the block.
#define MEMCPY(p1, p2, type, n)
Handy macro to call memcpy.
#define MEMZERO(p, type, n)
Handy macro to erase a region of memory.
static int rb_mul_size_overflow(size_t a, size_t b, size_t max, size_t *c)
#define RB_GC_GUARD(v)
Prevents premature destruction of local objects.
#define NUM2MODET
Converts a C's mode_t into an instance of rb_cInteger.
VALUE type(ANYARGS)
ANYARGS-ed function type.
VALUE rb_ensure(type *q, VALUE w, type *e, VALUE r)
An equivalent of ensure clause.
#define RARRAY_LEN
Just another name of rb_array_len.
#define RARRAY_AREF(a, i)
#define StringValue(v)
Ensures that the parameter object is a String.
#define RSTRING_GETMEM(str, ptrvar, lenvar)
Convenient macro to obtain the contents and length at once.
#define StringValueCStr(v)
Identical to StringValuePtr, except it additionally checks for the contents for viability as a C stri...
#define TypedData_Get_Struct(obj, type, data_type, sval)
Obtains a C struct from inside of a wrapper Ruby object.
#define TypedData_Make_Struct(klass, type, data_type, sval)
Identical to TypedData_Wrap_Struct, except it allocates a new data region internally instead of takin...
#define FilePathValue(v)
Ensures that the parameter object is a path.
#define errno
Ractor-aware version of errno.
#define FilePathStringValue(v)
This macro actually does the same thing as FilePathValue now.
#define RB_PASS_CALLED_KEYWORDS
Pass keywords if current method is called with keywords, useful for argument delegation.
This is the struct that holds necessary info for a struct.
uintptr_t VALUE
Type that represents a Ruby object.
static bool RB_TYPE_P(VALUE obj, enum ruby_value_type t)
Queries if the given object is of given type.