/unit/src/ |
H A D | nxt_murmur_hash.c | 30 h *= m; in nxt_murmur_hash2() 31 h ^= k; in nxt_murmur_hash2() 49 h ^= h >> 13; in nxt_murmur_hash2() 50 h *= m; in nxt_murmur_hash2() 51 h ^= h >> 15; in nxt_murmur_hash2() 53 return h; in nxt_murmur_hash2() 78 h *= m; in nxt_murmur_hash2_uint32() 79 h ^= k; in nxt_murmur_hash2_uint32() 81 h ^= h >> 13; in nxt_murmur_hash2_uint32() 82 h *= m; in nxt_murmur_hash2_uint32() [all …]
|
H A D | nxt_hash.h | 19 nxt_hash_find(nxt_hash_t *h, nxt_lvlhsh_query_t *lhq) in nxt_hash_find() argument 21 lhq->proto = h->proto; in nxt_hash_find() 23 return nxt_lvlhsh_find(&h->lvlhsh, lhq); in nxt_hash_find() 28 nxt_hash_insert(nxt_hash_t *h, nxt_lvlhsh_query_t *lhq) in nxt_hash_insert() argument 30 lhq->proto = h->proto; in nxt_hash_insert() 31 lhq->pool = h->pool; in nxt_hash_insert() 33 return nxt_lvlhsh_insert(&h->lvlhsh, lhq); in nxt_hash_insert() 38 nxt_hash_delete(nxt_hash_t *h, nxt_lvlhsh_query_t *lhq) in nxt_hash_delete() argument 40 lhq->proto = h->proto; in nxt_hash_delete() 41 lhq->pool = h->pool; in nxt_hash_delete() [all …]
|
H A D | nxt_websocket.c | 59 const nxt_websocket_header_t *h; in nxt_websocket_frame_header_size() local 61 h = data; in nxt_websocket_frame_header_size() 62 p = h->payload_len; in nxt_websocket_frame_header_size() 72 if (h->mask) { in nxt_websocket_frame_header_size() 84 const nxt_websocket_header_t *h; in nxt_websocket_frame_payload_len() local 86 h = data; in nxt_websocket_frame_payload_len() 87 p = h->payload_len; in nxt_websocket_frame_payload_len() 103 nxt_websocket_header_t *h; in nxt_websocket_frame_init() local 105 h = data; in nxt_websocket_frame_init() 114 h->payload_len = 126; in nxt_websocket_frame_init() [all …]
|
H A D | nxt_nvbcq.h | 85 nxt_nvbcq_atomic_t t, h, i; in nxt_nvbcq_enqueue() local 88 h = t - NXT_NVBCQ_SIZE; in nxt_nvbcq_enqueue() 100 if ((t - h) == NXT_NVBCQ_SIZE) { in nxt_nvbcq_enqueue() 101 h = nxt_nvbcq_head(q); in nxt_nvbcq_enqueue() 116 nxt_nvbcq_atomic_t h, t, i, e; in nxt_nvbcq_dequeue() local 118 h = nxt_nvbcq_head(q); in nxt_nvbcq_dequeue() 119 t = h + NXT_NVBCQ_SIZE; in nxt_nvbcq_dequeue() 122 i = nxt_nvbcq_map(q, h); in nxt_nvbcq_dequeue() 128 nxt_atomic_cmp_set(&q->head, h, h + 1); in nxt_nvbcq_dequeue() 133 if ((t - h) == NXT_NVBCQ_SIZE) { in nxt_nvbcq_dequeue() [all …]
|
H A D | nxt_app_nncq.h | 138 nxt_app_nncq_atomic_t h, j, e; in nxt_app_nncq_dequeue() local 141 h = nxt_app_nncq_head(q); in nxt_app_nncq_dequeue() 142 j = nxt_app_nncq_map(q, h); in nxt_app_nncq_dequeue() 146 h_cycle = nxt_app_nncq_cycle(q, h); in nxt_app_nncq_dequeue() 156 if (nxt_atomic_cmp_set(&q->head, h, h + 1)) { in nxt_app_nncq_dequeue()
|
H A D | nxt_nncq.h | 135 nxt_nncq_atomic_t h, j, e; in nxt_nncq_dequeue() local 138 h = nxt_nncq_head(q); in nxt_nncq_dequeue() 139 j = nxt_nncq_map(q, h); in nxt_nncq_dequeue() 143 h_cycle = nxt_nncq_cycle(q, h); in nxt_nncq_dequeue() 153 if (nxt_atomic_cmp_set(&q->head, h, h + 1)) { in nxt_nncq_dequeue()
|
H A D | nxt_http_parse.h | 112 #define nxt_http_field_hash_char(h, c) (((h) << 4) + (h) + (c)) argument 113 #define nxt_http_field_hash_end(h) (((h) >> 16) ^ (h)) argument
|
/unit/auto/ |
H A D | sockets | 13 nxt_feature_test="#include <stdio.h> 36 nxt_feature_test="#include <stdio.h> 54 nxt_feature_test="#include <stdio.h> 69 nxt_feature_test="#include <stdio.h> 85 nxt_feature_test="#include <stdio.h> 101 nxt_feature_test="#include <stdio.h> 103 #include <sys/un.h> 117 nxt_feature_test="#include <stdio.h> 132 nxt_feature_test="#include <stdio.h> 150 nxt_feature_test="#include <stdio.h> [all …]
|
H A D | events | 13 nxt_feature_test="#include <sys/epoll.h> 14 #include <unistd.h> 33 nxt_feature_test="#include <signal.h> 35 #include <unistd.h> 80 #include <unistd.h> 124 nxt_feature_test="#include <port.h> 125 #include <unistd.h> 150 nxt_feature_test="#include <fcntl.h> 153 #include <unistd.h> 178 nxt_feature_test="#include <fcntl.h> [all …]
|
H A D | unix | 13 nxt_feature_test="#include <unistd.h> 14 #include <sys/random.h> 34 nxt_feature_test="#include <unistd.h> 53 # OpenBSD 5.6 lacks <sys/random.h>. 99 nxt_feature_test="#include <stdlib.h> 155 nxt_feature_test="#include <stdlib.h> 156 #include <dlfcn.h> 160 dlsym(h, \"\"); 161 dlclose(h); 188 nxt_feature_test="#include <stdlib.h> [all …]
|
H A D | shmem | 15 nxt_feature_test="#include <sys/mman.h> 16 #include <fcntl.h> 17 #include <unistd.h> 18 #include <sys/stat.h> 19 #include <sys/types.h> 60 nxt_feature_test="#include <sys/mman.h> 61 #include <fcntl.h> 93 nxt_feature_test="#include <sys/mman.h> 94 #include <fcntl.h> 95 #include <sys/stat.h> [all …]
|
H A D | sendfile | 18 nxt_feature_test="#include <sys/sendfile.h> 41 nxt_feature_test="#include <sys/types.h> 42 #include <sys/socket.h> 43 #include <sys/uio.h> 44 #include <stdlib.h> 67 nxt_feature_test="#include <sys/types.h> 68 #include <sys/socket.h> 69 #include <sys/uio.h> 70 #include <stdlib.h> 125 nxt_feature_test="#include <sys/socket.h> [all …]
|
H A D | files | 13 nxt_feature_test="#include <fcntl.h> 29 nxt_feature_test="#include <fcntl.h> 45 nxt_feature_test="#include <fcntl.h> 59 nxt_feature_test="#include <fcntl.h> 60 #include <unistd.h> 61 #include <sys/syscall.h> 62 #include <linux/openat2.h> 63 #include <string.h>
|
H A D | mmap | 13 nxt_feature_test="#include <stdlib.h> 14 #include <sys/mman.h> 35 nxt_feature_test="#include <stdlib.h> 36 #include <sys/mman.h> 56 nxt_feature_test="#include <stdlib.h> 57 #include <sys/mman.h> 76 nxt_feature_test="#include <stdlib.h> 77 #include <sys/mman.h>
|
H A D | isolation | 21 #include <sched.h> 39 #include <sys/wait.h> 41 #include <sched.h> 68 nxt_feature_test="#include <sys/syscall.h> 79 nxt_feature="<mntent.h>" 84 nxt_feature_test="#include <mntent.h> 97 nxt_feature_test="#include <sys/prctl.h> 110 nxt_feature_test="#include <sys/prctl.h> 123 nxt_feature_test="#include <sys/mount.h> 142 nxt_feature_test="#include <sys/mount.h> [all …]
|
H A D | malloc | 14 nxt_feature_test="#include <stdlib.h> 37 nxt_feature_test="#include <stdlib.h> 60 nxt_feature_test="#include <malloc.h> 82 nxt_feature_test="#include <stdlib.h> 83 #include <malloc_np.h> 106 nxt_feature_test="#include <malloc/malloc.h> 126 nxt_feature_test="#include <stdlib.h> 143 nxt_feature="alloca() in alloca.h" 148 nxt_feature_test="#include <alloca.h> 169 nxt_feature_test="#include <malloc.h>
|
H A D | types | 19 nxt_feature_test="#include <stdio.h> 33 nxt_feature_test="#include <stdio.h> 47 nxt_feature_test="#include <stdio.h> 61 nxt_feature_test="#include <stdio.h> 81 nxt_feature_test="#include <stdio.h> 96 #include <unistd.h> 97 #include <stdio.h> 111 nxt_feature_test="#include <time.h> 112 #include <stdio.h>
|
H A D | time | 14 nxt_feature_test="#include <time.h> 37 nxt_feature_test="#include <time.h> 54 nxt_feature_test="#include <time.h> 88 nxt_feature_test="#include <time.h> 111 nxt_feature_test="#include <time.h> 128 nxt_feature_test="#include <time.h> 163 nxt_feature_test="#include <stdlib.h> 164 #include <sys/mercury.h> 182 nxt_feature_test="#include <time.h> 200 nxt_feature_test="#include <time.h> [all …]
|
H A D | capability | 9 nxt_feature_test="#include <linux/capability.h> 10 #include <unistd.h> 11 #include <sys/syscall.h>
|
H A D | threads | 48 #include <pthread.h> 66 nxt_feature_test="#include <pthread.h> 83 nxt_feature_test="#include <pthread.h> 111 nxt_feature_test="#include <pthread.h> 131 nxt_feature_test="#include <semaphore.h> 190 nxt_feature_test="#include <pthread.h> 191 #include <stdlib.h> 228 nxt_feature_test="#include <pthread.h> 249 nxt_feature_test="#include <limits.h> 250 #include <pthread.h> [all …]
|
H A D | ssltls | 24 nxt_feature_test="#include <openssl/ssl.h> 40 nxt_feature_test="#include <openssl/ssl.h> 62 nxt_feature_test="#include <openssl/ssl.h> 76 nxt_feature_test="#include <openssl/ssl.h> 101 nxt_feature_test="#include <gnutls/gnutls.h> 122 nxt_feature_test="#include <gnutls/gnutls.h> 136 nxt_feature_test="#include <gnutls/gnutls.h> 161 nxt_feature_test="#include <cyassl/ssl.h> 192 nxt_feature_test="#include <polarssl/ssl.h>
|
/unit/go/ |
H A D | unit.go | 115 h := handler_registry_.next 117 handler_registry_.m[h] = handler 121 return h 124 func get_handler(h uintptr) http.Handler { 128 return *handler_registry_.m[h] 131 func reset_handler(h uintptr) { 135 delete(handler_registry_.m, h) 146 h := set_handler(&handler) 148 rc := C.nxt_cgo_run(C.uintptr_t(h)) 150 reset_handler(h)
|
/unit/test/python/threads/ |
H A D | asgi.py | 11 for h in headers: 12 if h[0] == n: 13 return h[1]
|
/unit/test/python/variables/ |
H A D | asgi.py | 15 for h in headers: 16 if h[0] == n: 17 res.append(h[1])
|
/unit/test/python/header_fields/ |
H A D | wsgi.py | 3 h = (k for k, v in environ.items() if k.startswith('HTTP_')) 6 '200', [('Content-Length', '0'), ('All-Headers', ','.join(h))]
|