/unit/src/ |
H A D | nxt_fs_mount.c | 20 unsigned long flags; in nxt_fs_mount() local 22 flags = 0; in nxt_fs_mount() 32 flags = MS_BIND | MS_REC; in nxt_fs_mount() 49 flags |= MS_NODEV; in nxt_fs_mount() 53 flags |= MS_NOEXEC; in nxt_fs_mount() 57 flags |= MS_NOSUID; in nxt_fs_mount() 61 flags |= MS_RELATIME; in nxt_fs_mount() 83 int flags; in nxt_fs_mount() local 97 flags = 0; in nxt_fs_mount() 118 flags |= MNT_NOEXEC; in nxt_fs_mount() [all …]
|
H A D | nxt_linux_sendfile.c | 40 nxt_uint_t flags); 54 nxt_uint_t niov, flags; in nxt_linux_event_conn_io_sendfile() local 75 flags = MSG_NOSIGNAL; in nxt_linux_event_conn_io_sendfile() 82 flags |= MSG_MORE; in nxt_linux_event_conn_io_sendfile() 93 return nxt_linux_sendmsg(c, &sb, niov, flags); in nxt_linux_event_conn_io_sendfile() 148 n = send(c->socket.fd, buf, size, flags); in nxt_linux_send() 153 c->socket.fd, buf, size, flags, n); in nxt_linux_send() 189 nxt_uint_t niov, nxt_uint_t flags) in nxt_linux_sendmsg() argument 203 n = sendmsg(c->socket.fd, &msg, flags); in nxt_linux_sendmsg() 208 c->socket.fd, niov, flags, n); in nxt_linux_sendmsg() [all …]
|
H A D | nxt_mem_map.c | 11 nxt_mem_mmap(void *addr, size_t len, nxt_uint_t protection, nxt_uint_t flags, in nxt_mem_mmap() argument 16 p = mmap(addr, len, protection, flags, fd, offset); in nxt_mem_mmap() 20 addr, len, protection, flags, fd, offset, p); in nxt_mem_mmap() 24 addr, len, protection, flags, fd, offset, nxt_errno); in nxt_mem_mmap()
|
H A D | nxt_test_build.c | 34 eventfd(u_int initval, int flags) in eventfd() argument 41 signalfd(int fd, const sigset_t *mask, int flags) in signalfd() argument 48 accept4(int sockfd, struct sockaddr *addr, socklen_t *addrlen, int flags) in accept4() argument 148 ssize_t send_file(int *s, struct sf_parms *sf_iobuf, uint_t flags) in send_file() argument
|
H A D | nxt_clone.h | 28 nxt_int_t flags; member 38 #define nxt_is_clone_flag_set(flags, test) \ argument 39 ((flags & CLONE_##test) == CLONE_##test)
|
H A D | nxt_mem_map.h | 49 #define nxt_mem_map(addr, ctx, len, protection, flags, fd, offset) \ argument 50 nxt_mem_mmap(addr, len, protection, flags, fd, offset) 58 nxt_uint_t flags, nxt_fd_t fd, nxt_off_t offset);
|
H A D | nxt_lib.c | 36 nxt_int_t flags; in nxt_lib_start() local 40 flags = nxt_stderr_start(); in nxt_lib_start() 83 if (flags != -1) { in nxt_lib_start() 84 nxt_debug(&nxt_main_task, "stderr flags: 0x%04Xd", flags); in nxt_lib_start()
|
H A D | nxt_file.c | 59 how.flags = mode; in nxt_file_openat2() 482 int flags; in nxt_fd_nonblocking() local 484 flags = fcntl(fd, F_GETFL); in nxt_fd_nonblocking() 486 if (nxt_slow_path(flags == -1)) { in nxt_fd_nonblocking() 491 flags |= O_NONBLOCK; in nxt_fd_nonblocking() 506 int flags; in nxt_fd_blocking() local 508 flags = fcntl(fd, F_GETFL); in nxt_fd_blocking() 515 flags &= O_NONBLOCK; in nxt_fd_blocking() 689 int flags, fd; in nxt_stderr_start() local 693 if (flags != -1) { in nxt_stderr_start() [all …]
|
H A D | nxt_tstr.c | 28 nxt_tstr_flags_t flags; member 85 nxt_tstr_flags_t flags) in nxt_tstr_compile() argument 91 strz = (flags & NXT_TSTR_STRZ) != 0; in nxt_tstr_compile() 111 tstr->flags = flags; in nxt_tstr_compile() 217 if (tstr->flags & NXT_TSTR_STRZ) { in nxt_tstr_str() 267 tstr->flags & NXT_TSTR_LOGGING); in nxt_tstr_query() 286 if (tstr->flags & NXT_TSTR_STRZ) { in nxt_tstr_query()
|
H A D | nxt_external.c | 33 int res, flags; in nxt_external_fd_no_cloexec() local 39 flags = fcntl(fd, F_GETFD); in nxt_external_fd_no_cloexec() 41 if (nxt_slow_path(flags == -1)) { in nxt_external_fd_no_cloexec() 46 flags &= ~FD_CLOEXEC; in nxt_external_fd_no_cloexec() 48 res = fcntl(fd, F_SETFD, flags); in nxt_external_fd_no_cloexec()
|
H A D | nxt_conn_read.c | 198 nxt_conn_io_recv(nxt_conn_t *c, void *buf, size_t size, nxt_uint_t flags) in nxt_conn_io_recv() argument 204 n = recv(c->socket.fd, buf, size, flags); in nxt_conn_io_recv() 209 c->socket.fd, buf, size, flags, n); in nxt_conn_io_recv() 212 if ((size_t) n < size && (flags & MSG_PEEK) == 0) { in nxt_conn_io_recv() 222 if ((flags & MSG_PEEK) == 0) { in nxt_conn_io_recv() 247 c->socket.fd, buf, size, flags, err); in nxt_conn_io_recv()
|
H A D | nxt_test_build.h | 86 int eventfd(u_int initval, int flags); 87 int signalfd(int fd, const sigset_t *mask, int flags); 91 int accept4(int sockfd, struct sockaddr *addr, socklen_t *addrlen, int flags); 269 ssize_t send_file(int *s, struct sf_parms *sf_iobuf, uint_t flags);
|
H A D | nxt_kqueue_engine.c | 85 nxt_int_t filter, nxt_uint_t flags); 429 kev->flags = flags; in nxt_kqueue_enable_file() 445 nxt_int_t filter, nxt_uint_t flags) in nxt_kqueue_fd_set() argument 456 kev->flags = flags; in nxt_kqueue_fd_set() 592 kev.flags = EV_ADD; in nxt_kqueue_add_signal() 618 kev.flags = EV_ADD | EV_CLEAR; in nxt_kqueue_enable_post() 648 kev.flags = 0; in nxt_kqueue_signal() 730 if (nxt_slow_path(kev->flags & EV_ERROR)) { in nxt_kqueue_poll() 749 eof = (kev->flags & EV_EOF) != 0; in nxt_kqueue_poll() 758 if ((kev->flags & NXT_KEVENT_ONESHOT) != 0) { in nxt_kqueue_poll() [all …]
|
H A D | nxt_buf.c | 31 nxt_buf_mem_alloc(nxt_mp_t *mp, size_t size, nxt_uint_t flags) in nxt_buf_mem_alloc() argument 96 nxt_buf_file_alloc(nxt_mp_t *mp, size_t size, nxt_uint_t flags) in nxt_buf_file_alloc() argument 143 nxt_buf_sync_alloc(nxt_mp_t *mp, nxt_uint_t flags) in nxt_buf_sync_alloc() argument 154 b->is_nobuf = ((flags & NXT_BUF_SYNC_NOBUF) != 0); in nxt_buf_sync_alloc() 155 b->is_flush = ((flags & NXT_BUF_SYNC_FLUSH) != 0); in nxt_buf_sync_alloc() 156 b->is_last = ((flags & NXT_BUF_SYNC_LAST) != 0); in nxt_buf_sync_alloc()
|
H A D | nxt_http_js.c | 37 .flags = NJS_EXTERN_PROPERTY, 46 .flags = NJS_EXTERN_PROPERTY, 55 .flags = NJS_EXTERN_PROPERTY, 64 .flags = NJS_EXTERN_PROPERTY, 73 .flags = NJS_EXTERN_OBJECT, 84 .flags = NJS_EXTERN_OBJECT, 95 .flags = NJS_EXTERN_OBJECT,
|
H A D | nxt_buf.h | 216 nxt_uint_t flags); 220 nxt_uint_t flags); 222 NXT_EXPORT nxt_buf_t *nxt_buf_sync_alloc(nxt_mp_t *mp, nxt_uint_t flags);
|
H A D | nxt_conf_validation.c | 58 nxt_conf_vldt_flags_t flags:32; member 410 .flags = NXT_CONF_VLDT_TSTR, 450 .flags = NXT_CONF_VLDT_REQUIRED 465 .flags = NXT_CONF_VLDT_REQUIRED 469 .flags = NXT_CONF_VLDT_REQUIRED 485 .flags = NXT_CONF_VLDT_REQUIRED, 694 .flags = NXT_CONF_VLDT_TSTR, 712 .flags = NXT_CONF_VLDT_TSTR, 727 .flags = NXT_CONF_VLDT_TSTR, 757 .flags = NXT_CONF_VLDT_TSTR, [all …]
|
H A D | nxt_fs_mount.h | 37 nxt_fs_flags_t flags; member
|
H A D | nxt_hpux_sendfile.c | 16 const struct iovec *hdtrl, int flags) in nxt_sys_sendfile() argument 26 const struct iovec *hdtrl, int flags);
|
H A D | nxt_socket.c | 16 nxt_uint_t protocol, nxt_uint_t flags) in nxt_socket_create() argument 22 if (flags & NXT_NONBLOCK) { in nxt_socket_create() 40 if (flags & NXT_NONBLOCK) { in nxt_socket_create()
|
H A D | nxt_listen_socket.h | 23 uint8_t flags; member
|
H A D | nxt_buf_pool.c | 38 b = nxt_buf_mem_alloc(bp->mem_pool, size, bp->flags); in nxt_buf_pool_mem_alloc() 78 b = nxt_buf_file_alloc(bp->mem_pool, size, bp->flags); in nxt_buf_pool_file_alloc()
|
H A D | nxt_buf_pool.h | 30 uint8_t flags; /* 2 bits */ member
|
/unit/src/perl/ |
H A D | nxt_perl_psgi_layer.c | 41 CLONE_PARAMS *param, int flags); 44 CLONE_PARAMS *param, int flags); 148 PerlIOBase(f)->flags |= PERLIO_F_OPEN; in nxt_perl_psgi_layer_stream_open() 188 if ((PerlIOBase(f)->flags & PERLIO_F_CANREAD) == 0) { in nxt_perl_psgi_layer_stream_read() 189 PerlIOBase(f)->flags |= PERLIO_F_ERROR; in nxt_perl_psgi_layer_stream_read() 210 if (PerlIOBase(f)->flags & PERLIO_F_CANWRITE) { in nxt_perl_psgi_layer_stream_write() 254 CLONE_PARAMS *param, int flags) in nxt_perl_psgi_layer_stream_arg() argument 262 if (flags & PERLIO_DUP_CLONE) { in nxt_perl_psgi_layer_stream_arg() 265 } else if (flags & PERLIO_DUP_FD) { in nxt_perl_psgi_layer_stream_arg() 278 CLONE_PARAMS *param, int flags) in nxt_perl_psgi_layer_stream_dup() argument [all …]
|
/unit/test/unit/ |
H A D | log.py | 56 def findall(pattern, name=UNIT_LOG, flags=re.M): argument 57 return re.findall(pattern, Log.read(name), flags) 103 def wait_for_record(pattern, name=UNIT_LOG, wait=150, flags=re.M): argument 106 found = re.search(pattern, file.read(), flags)
|