/unit/src/ |
H A D | nxt_parse.c | 19 nxt_uint_t val; in nxt_int_parse() local 26 val = 0; in nxt_int_parse() 43 val = val * 10 + c; in nxt_int_parse() 65 size_t val; in nxt_size_t_parse() local 72 val = 0; in nxt_size_t_parse() 89 val = val * 10 + c; in nxt_size_t_parse() 177 val = 0; in nxt_off_t_parse() 194 val = val * 10 + c; in nxt_off_t_parse() 229 val = 0; in nxt_str_int_parse() 246 val = val * 10 + c; in nxt_str_int_parse() [all …]
|
H A D | nxt_atomic.h | 49 #define nxt_atomic_or_fetch(ptr, val) \ argument 50 __sync_or_and_fetch(ptr, val) 53 #define nxt_atomic_and_fetch(ptr, val) \ argument 54 __sync_and_and_fetch(ptr, val) 91 #define nxt_atomic_or_fetch(ptr, val) \ argument 92 atomic_or_ulong_nv(ptr, val) 95 #define nxt_atomic_and_fetch(ptr, val) \ argument 96 atomic_and_ulong_nv(ptr, val)
|
H A D | nxt_capability.c | 68 struct __user_cap_data_struct *val, data[2]; in nxt_capability_specific_set() local 80 val = &data[0]; in nxt_capability_specific_set() 90 if (nxt_slow_path(nxt_capget(&hdr, val) == -1)) { in nxt_capability_specific_set() 95 if ((val->effective & (1 << CAP_SYS_CHROOT)) != 0) { in nxt_capability_specific_set() 99 if ((val->effective & (1 << CAP_SETUID)) == 0) { in nxt_capability_specific_set() 103 if ((val->effective & (1 << CAP_SETGID)) == 0) { in nxt_capability_specific_set()
|
H A D | nxt_random.c | 120 uint8_t val; in nxt_random_add() local 124 val = r->s[r->i]; in nxt_random_add() 125 r->j += val + key[n % len]; in nxt_random_add() 128 r->s[r->j] = val; in nxt_random_add() 143 uint32_t val; in nxt_random() local 151 val = nxt_random_byte(r) << 24; in nxt_random() 152 val |= nxt_random_byte(r) << 16; in nxt_random() 153 val |= nxt_random_byte(r) << 8; in nxt_random() 154 val |= nxt_random_byte(r); in nxt_random() 156 return val; in nxt_random()
|
H A D | nxt_clang.h | 219 #define nxt_abs(val) \ argument 220 abs(val) 231 #define nxt_bswap32(val) \ argument 232 ( ((val) >> 24) \ 233 | (((val) & 0x00FF0000) >> 8) \ 234 | (((val) & 0x0000FF00) << 8) \ 235 | ((val) << 24))
|
H A D | nxt_socket.c | 78 int val; in nxt_socket_getsockopt() local 81 len = sizeof(val); in nxt_socket_getsockopt() 83 if (nxt_fast_path(getsockopt(s, level, sockopt, &val, &len) == 0)) { in nxt_socket_getsockopt() 85 s, level, nxt_socket_sockopt_name(level, sockopt), val); in nxt_socket_getsockopt() 86 return val; in nxt_socket_getsockopt() 99 nxt_uint_t sockopt, int val) in nxt_socket_setsockopt() argument 103 len = sizeof(val); in nxt_socket_setsockopt() 105 if (nxt_fast_path(setsockopt(s, level, sockopt, &val, len) == 0)) { in nxt_socket_setsockopt() 107 s, level, nxt_socket_sockopt_name(level, sockopt), val); in nxt_socket_setsockopt() 112 s, level, nxt_socket_sockopt_name(level, sockopt), val, in nxt_socket_setsockopt()
|
H A D | nxt_time_parse.c | 314 nxt_uint_t val, term, scale, max; in nxt_term_parse() local 337 val = 0; in nxt_term_parse() 363 val = val * 10 + c; in nxt_term_parse() 469 if (val > max) { in nxt_term_parse() 473 term += val * scale; in nxt_term_parse() 479 val = 0; in nxt_term_parse() 485 val *= 1000; in nxt_term_parse() 488 return term + val; in nxt_term_parse()
|
H A D | nxt_djb_hash.h | 21 #define nxt_djb_hash_add(hash, val) \ argument 22 ((uint32_t) ((((hash) << 5) + (hash)) ^ (uint32_t) (val)))
|
H A D | nxt_tstr.c | 251 nxt_str_t *val) in nxt_tstr_query() argument 256 nxt_tstr_str(tstr, val); in nxt_tstr_query() 266 tstr->u.var, val, query->ctx, in nxt_tstr_query() 277 tstr->u.js, val, query->ctx); in nxt_tstr_query() 287 val->length--; in nxt_tstr_query() 295 nxt_debug(task, "tstr query: \"%V\", result: \"%V\"", &str, val); in nxt_tstr_query()
|
H A D | nxt_nvbcq.h | 83 nxt_nvbcq_enqueue(nxt_nvbcq_t volatile *q, nxt_nvbcq_atomic_t val) in nxt_nvbcq_enqueue() argument 94 && nxt_atomic_cmp_set(&q->entries[i], NXT_NVBCQ_SIZE, val)) in nxt_nvbcq_enqueue()
|
H A D | nxt_app_nncq.h | 101 nxt_app_nncq_enqueue(nxt_app_nncq_t volatile *q, nxt_app_nncq_atomic_t val) in nxt_app_nncq_enqueue() argument 123 n = nxt_app_nncq_new_entry(q, t_cycle, val); in nxt_app_nncq_enqueue()
|
H A D | nxt_nncq.h | 98 nxt_nncq_enqueue(nxt_nncq_t volatile *q, nxt_nncq_atomic_t val) in nxt_nncq_enqueue() argument 120 n = nxt_nncq_new_entry(q, t_cycle, val); in nxt_nncq_enqueue()
|
H A D | nxt_tstr.h | 54 nxt_str_t *val);
|
H A D | nxt_socket.h | 101 nxt_uint_t level, nxt_uint_t sockopt, int val);
|
/unit/src/nodejs/unit-http/ |
H A D | nxt_napi.h | 45 coerce_to_string(napi_value val) in coerce_to_string() 177 get_array_length(napi_value val) in get_array_length() 314 get_property_names(napi_value val) in get_property_names() 411 is_array(napi_value val) in is_array() 426 is_buffer(napi_value val) in is_buffer() 604 create(int32_t val) in create() 619 create(uint32_t val) in create() 634 create(int64_t val) in create() 659 remove_wrap(napi_value val) in remove_wrap() 688 type_of(napi_value val) in type_of() [all …]
|
H A D | websocket_request.js | 232 var val = pair.substr(++eq_idx, pair.length).trim(); 235 if ('"' === val[0]) { 236 val = val.slice(1, -1); 241 value: decodeURIComponent(val)
|
H A D | http_server.js | 77 value.forEach(function(val) { argument 78 value_len += Buffer.byteLength(val + "", 'latin1'); 156 value.forEach(function(val) { argument 157 this.headers_len -= Buffer.byteLength(val + "", 'latin1');
|
/unit/src/test/ |
H A D | nxt_term_parse_test.c | 39 nxt_int_t val; in nxt_term_parse_test() local 48 val = nxt_term_parse(s->start, s->length, terms[i].is_sec); in nxt_term_parse_test() 50 if (val != terms[i].value) { in nxt_term_parse_test() 53 s, terms[i].value, val); in nxt_term_parse_test()
|
/unit/src/ruby/ |
H A D | nxt_ruby_stream_io.c | 19 nxt_inline long nxt_ruby_stream_io_s_write(nxt_ruby_ctx_t *rctx, VALUE val); 238 nxt_ruby_stream_io_s_write(nxt_ruby_ctx_t *rctx, VALUE val) in nxt_ruby_stream_io_s_write() argument 240 if (nxt_slow_path(val == Qnil)) { in nxt_ruby_stream_io_s_write() 244 if (TYPE(val) != T_STRING) { in nxt_ruby_stream_io_s_write() 245 val = rb_funcall(val, rb_intern("to_s"), 0); in nxt_ruby_stream_io_s_write() 247 if (TYPE(val) != T_STRING) { in nxt_ruby_stream_io_s_write() 252 nxt_unit_req_error(rctx->req, "Ruby: %s", RSTRING_PTR(val)); in nxt_ruby_stream_io_s_write() 254 return RSTRING_LEN(val); in nxt_ruby_stream_io_s_write()
|
/unit/test/go/ns_inspect/ |
H A D | app.go | 49 val, err := strconv.ParseUint(str, 10, 64) 51 return val
|
/unit/src/python/ |
H A D | nxt_python_asgi.c | 1224 PyObject *iter, *header, *h_iter, *name, *val, *res; in nxt_py_asgi_enum_headers() local 1257 val = PyIter_Next(h_iter); in nxt_py_asgi_enum_headers() 1258 if (nxt_slow_path(val == NULL || !PyBytes_Check(val))) { in nxt_py_asgi_enum_headers() 1259 Py_XDECREF(val); in nxt_py_asgi_enum_headers() 1268 res = cb(data, i, name, val); in nxt_py_asgi_enum_headers() 1271 Py_DECREF(val); in nxt_py_asgi_enum_headers() 1291 nxt_py_asgi_calc_size(void *data, int i, PyObject *name, PyObject *val) in nxt_py_asgi_calc_size() argument 1298 ctx->fields_size += PyBytes_GET_SIZE(name) + PyBytes_GET_SIZE(val); in nxt_py_asgi_calc_size() 1305 nxt_py_asgi_add_field(void *data, int i, PyObject *name, PyObject *val) in nxt_py_asgi_add_field() argument 1317 val_str = PyBytes_AS_STRING(val); in nxt_py_asgi_add_field() [all …]
|
H A D | nxt_python_asgi.h | 11 PyObject *name, PyObject *val);
|
/unit/src/wasm/ |
H A D | nxt_wasm.c | 60 const char *val; in nxt_wasm_do_send_headers() local 63 val = (const char *)rh + rh->fields[i].value_off; in nxt_wasm_do_send_headers() 66 val, rh->fields[i].value_len); in nxt_wasm_do_send_headers()
|
/unit/test/ |
H A D | test_php_application.py | 86 def set_opcache(app, val): argument 88 {"admin": {"opcache.enable": val, "opcache.enable_cli": val}}, 93 assert r['headers']['X-OPcache'] == val, 'opcache value'
|
/unit/src/wasm-wasi-component/src/ |
H A D | lib.rs | 541 fn add_field(&mut self, key: &[u8], val: &[u8]) { in add_field() 547 val.as_ptr().cast(), in add_field() 548 val.len().try_into().unwrap(), in add_field()
|