/unit/go/ |
H A D | observable.go | 16 func (o *observable) attach(c chan int) { 20 o.observers = append(o.observers, c)
|
H A D | response.go | 98 func wait_shm_ack(c chan int) { 99 observer_registry_.attach(c) 101 _ = <-c
|
/unit/auto/modules/ |
H A D | wasm | 107 wasm_config_t *c; 109 c = wasm_config_new(); 110 wasm_config_delete(c); 141 src/wasm/nxt_wasm.c \ 145 NXT_WASM_MODULE_SRCS="$NXT_WASM_MODULE_SRCS src/wasm/nxt_rt_wasmtime.c" 155 nxt_obj=${nxt_src%.c}-$NXT_WASM_MODULE.o 156 nxt_dep=${nxt_src%.c}-$NXT_WASM_MODULE.dep 165 \$(CC) -c \$(CFLAGS) $NXT_WASM_ADDITIONAL_FLAGS \$(NXT_INCS) \\
|
H A D | perl | 57 if /bin/sh -c "$NXT_PERL -MConfig -e 'print \"Perl version: \", 149 src/perl/nxt_perl_psgi.c \ 150 src/perl/nxt_perl_psgi_layer.c 159 nxt_obj=${nxt_src%.c}-$NXT_PERL_MODULE.o 160 nxt_dep=${nxt_src%.c}-$NXT_PERL_MODULE.dep 169 \$(CC) -c \$(CFLAGS) $NXT_PERL_CFLAGS \$(NXT_INCS) $NXT_PERL_INCLUDE \\
|
H A D | ruby | 57 if /bin/sh -c "$NXT_RUBY -v" >> $NXT_AUTOCONF_ERR 2>&1; then 214 src/ruby/nxt_ruby.c \ 215 src/ruby/nxt_ruby_stream_io.c 224 nxt_obj=${nxt_src%.c}-$NXT_RUBY_MODULE.o 225 nxt_dep=${nxt_src%.c}-$NXT_RUBY_MODULE.dep 234 \$(CC) -c \$(CFLAGS) $NXT_RUBY_CFLAGS -DNXT_RUBY_MOUNTS_H=\"$NXT_RUBY_MOUNTS_HEADER\" \\
|
H A D | php | 72 if /bin/sh -c "${NXT_PHP_CONFIG} --version" >> $NXT_AUTOCONF_ERR 2>&1; then 229 src/nxt_php_sapi.c \ 238 nxt_obj=${nxt_src%.c}-$NXT_PHP_MODULE.o 239 nxt_dep=${nxt_src%.c}-$NXT_PHP_MODULE.dep 247 \$(CC) -c \$(CFLAGS) $NXT_PHP_ADDITIONAL_FLAGS \$(NXT_INCS) \\
|
H A D | java | 346 src/nxt_java.c \ 347 src/java/nxt_jni.c \ 348 src/java/nxt_jni_Context.c \ 350 src/java/nxt_jni_HeadersEnumeration.c \ 351 src/java/nxt_jni_InputStream.c \ 352 src/java/nxt_jni_OutputStream.c \ 353 src/java/nxt_jni_Request.c \ 354 src/java/nxt_jni_Response.c \ 355 src/java/nxt_jni_Thread.c \ 356 src/java/nxt_jni_URLClassLoader.c \ [all …]
|
/unit/auto/ |
H A D | make | 50 nxt_obj=${nxt_src%.c}.o 64 nxt_obj=${nxt_src%.c}.o 112 nxt_obj=${nxt_src%.c}.o 113 nxt_dep=${nxt_src%.c}.dep 131 nxt_src=src/test/nxt_cq_test.c 149 nxt_src=src/test/nxt_cq_test.c 178 nxt_obj=${nxt_src%.c}.o 286 nxt_obj=${nxt_src%.c}.o 324 nxt_obj=${nxt_src%.c}.o 325 nxt_dep=${nxt_src%.c}.dep [all …]
|
H A D | pcre | 10 if /bin/sh -c "(pcre2-config --version)" >> $NXT_AUTOCONF_ERR 2>&1; then 41 if /bin/sh -c "(pcre-config --version)" >> $NXT_AUTOCONF_ERR 2>&1; then
|
/unit/src/ |
H A D | nxt_log.h | 118 #define nxt_assert(c) \ argument 120 if (nxt_slow_path(!(c))) { \ 122 __FILE__, __LINE__, #c); \ 133 #define nxt_assert(c) argument
|
H A D | nxt_http_parse.c | 522 u_char *p, c; in nxt_http_parse_field_name() local 548 c = normal[ch]; \ in nxt_http_parse_field_name() 560 hash = nxt_http_field_hash_char(hash, c); in nxt_http_parse_field_name() 831 (nxt_fast_path((nxt_http_normal[c / 8] & (1 << (c & 7))) != 0)) 858 u_char *p, *u, c, ch, high, *args; in nxt_http_parse_complex_target() local 1052 c = (u_char) (ch | 0x20); in nxt_http_parse_complex_target() 1053 if (c >= 'a' && c <= 'f') { in nxt_http_parse_complex_target() 1054 high = (u_char) (c - 'a' + 10); in nxt_http_parse_complex_target() 1091 c = (u_char) (ch | 0x20); in nxt_http_parse_complex_target() 1092 if (c >= 'a' && c <= 'f') { in nxt_http_parse_complex_target() [all …]
|
H A D | nxt_http_route_addr.c | 12 static nxt_bool_t nxt_valid_ipv6_blocks(u_char *c, size_t len); 319 nxt_valid_ipv6_blocks(u_char *c, size_t len) in nxt_valid_ipv6_blocks() argument 324 end = c + len; in nxt_valid_ipv6_blocks() 327 while (c != end) { in nxt_valid_ipv6_blocks() 328 if (*c == ':') { in nxt_valid_ipv6_blocks() 330 c++; in nxt_valid_ipv6_blocks() 336 c++; in nxt_valid_ipv6_blocks()
|
H A D | nxt_sendbuf.c | 211 nxt_sendbuf_copy_coalesce(nxt_conn_t *c, nxt_buf_mem_t *bm, nxt_buf_t *b, in nxt_sendbuf_copy_coalesce() argument 246 nxt_log_debug(c->socket.log, "sendbuf copy:%uz fl:%b", copied, flush); in nxt_sendbuf_copy_coalesce() 258 n = c->io->send(c, bm->pos, nxt_min(size, limit)); in nxt_sendbuf_copy_coalesce() 260 nxt_log_debug(c->socket.log, "sendbuf sent:%z", n); in nxt_sendbuf_copy_coalesce() 284 return c->io->send(c, b->mem.pos, nxt_min(size, limit)); in nxt_sendbuf_copy_coalesce() 288 nxt_log_debug(c->socket.log, "sendbuf done"); in nxt_sendbuf_copy_coalesce()
|
H A D | nxt_sockaddr.c | 57 sa = c->remote; in nxt_sockaddr_cache_free() 776 u_char c, *end; in nxt_inet_addr() local 792 c = *buf++; in nxt_inet_addr() 794 digit = c - '0'; in nxt_inet_addr() 802 if (c == '.' && octet < 256) { in nxt_inet_addr() 847 c = *buf++; in nxt_inet6_addr() 849 if (c == ':') { in nxt_inet6_addr() 874 if (c == '.' && nibbles != 0) { in nxt_inet6_addr() 903 digit = c - '0'; in nxt_inet6_addr() 911 c |= 0x20; in nxt_inet6_addr() [all …]
|
H A D | nxt_clang.h | 31 #define nxt_expect(c, x) \ argument 32 __builtin_expect((long) (x), (c)) 43 #define nxt_expect(c, x) \ argument
|
H A D | nxt_php_sapi.c | 378 nxt_php_app_conf_t *c; in nxt_php_setup() local 384 c = &conf->u.php; in nxt_php_setup() 409 if (c->options != NULL) { in nxt_php_setup() 429 if (c->options != NULL) { in nxt_php_setup() 468 c = &conf->u.php; in nxt_php_start() 470 n = (c->targets != NULL) ? nxt_conf_object_members_count(c->targets) : 1; in nxt_php_start() 824 char c, *p, *start; in nxt_php_disable() local 843 c = *p; in nxt_php_disable() 845 if (c == ' ' || c == ',' || c == '\0') { in nxt_php_disable() 868 } while (c != '\0'); in nxt_php_disable() [all …]
|
H A D | nxt_polarssl.c | 23 nxt_event_conn_t *c); 95 nxt_event_conn_t *c) in nxt_polarssl_conn_init() argument
|
H A D | nxt_sha1.h | 14 uint32_t a, b, c, d, e; member
|
/unit/src/ruby/ |
H A D | nxt_ruby.c | 54 nxt_ruby_app_conf_t *c); 267 nxt_ruby_app_conf_t *c; in nxt_ruby_start() local 276 c = &conf->u.ruby; in nxt_ruby_start() 278 nxt_ruby_threads = c->threads; in nxt_ruby_start() 295 rack_init.script = &c->script; in nxt_ruby_start() 311 if (c->hooks.start != NULL) { in nxt_ruby_start() 366 ruby_unit_init.data = c; in nxt_ruby_start() 1337 nxt_ruby_app_conf_t *c; in nxt_ruby_ready_handler() local 1339 c = ctx->unit->data; in nxt_ruby_ready_handler() 1341 if (c->threads <= 1) { in nxt_ruby_ready_handler() [all …]
|
/unit/src/perl/ |
H A D | nxt_perl_psgi.c | 98 nxt_perl_app_conf_t *c); 1137 nxt_perl_app_conf_t *c; in nxt_perl_psgi_start() local 1141 c = &common_conf->u.perl; in nxt_perl_psgi_start() 1156 rc = nxt_perl_psgi_init_threads(c); in nxt_perl_psgi_start() 1168 perl_init.data = c; in nxt_perl_psgi_start() 1192 nxt_perl_psgi_join_threads(NULL, c); in nxt_perl_psgi_start() 1268 nxt_perl_app_conf_t *c; in nxt_perl_psgi_ready_handler() local 1271 c = ctx->unit->data; in nxt_perl_psgi_ready_handler() 1273 if (c->threads <= 1) { in nxt_perl_psgi_ready_handler() 1336 if (c->threads <= 1) { in nxt_perl_psgi_init_threads() [all …]
|
/unit/pkg/contrib/src/wasmtime/ |
H A D | Makefile | 29 cp $</crates/c-api/wasm-c-api/include/wasm.h $</crates/c-api/include/
|
/unit/src/test/ |
H A D | nxt_cq_test.c | 137 uint32_t c; in cas_worker() local 145 c = q->counter; in cas_worker() 147 if (nxt_atomic_cmp_set(&q->counter, c, c + 1)) { in cas_worker() 344 double *stats, m, c; in main() local 540 c = cov(stats + k - STAT_ITER, m, STAT_ITER); in main() 546 (int) k + 1, times[k], mopsec[k], m, c); in main() 551 (int) k + 1, times[k], mopsec[k], m, c); in main() 555 if (c < MIN_COV) { in main()
|
/unit/ |
H A D | .gitattributes | 1 *.c diff=cpp
|
/unit/test/unit/applications/ |
H A D | tls.py | 46 with open(key_path, 'rb') as k, open(crt_path, 'rb') as c: 47 return self.conf(k.read() + c.read(), f'/certificates/{crt}')
|
/unit/pkg/rpm/ |
H A D | Makefile.wasm | 9 MODULE_CONFARGS_wasm= wasm --include-path=\`pwd\`/pkg/contrib/wasmtime/crates/c-api/include --lib-p…
|