Home
last modified time | relevance | path

Searched refs:flags (Results 1 – 25 of 47) sorted by relevance

12

/unit/src/
H A Dnxt_fs_mount.c20 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 Dnxt_linux_sendfile.c40 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 Dnxt_mem_map.c11 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 Dnxt_test_build.c34 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 Dnxt_clone.h28 nxt_int_t flags; member
38 #define nxt_is_clone_flag_set(flags, test) \ argument
39 ((flags & CLONE_##test) == CLONE_##test)
H A Dnxt_mem_map.h49 #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 Dnxt_lib.c36 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 Dnxt_file.c59 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 Dnxt_tstr.c28 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 Dnxt_external.c33 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 Dnxt_conn_read.c198 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 Dnxt_test_build.h86 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 Dnxt_kqueue_engine.c85 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 Dnxt_buf.c31 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 Dnxt_http_js.c37 .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 Dnxt_buf.h216 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 Dnxt_conf_validation.c58 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 Dnxt_fs_mount.h37 nxt_fs_flags_t flags; member
H A Dnxt_hpux_sendfile.c16 const struct iovec *hdtrl, int flags) in nxt_sys_sendfile() argument
26 const struct iovec *hdtrl, int flags);
H A Dnxt_socket.c16 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 Dnxt_listen_socket.h23 uint8_t flags; member
H A Dnxt_buf_pool.c38 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 Dnxt_buf_pool.h30 uint8_t flags; /* 2 bits */ member
/unit/src/perl/
H A Dnxt_perl_psgi_layer.c41 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 Dlog.py56 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)

12