Home
last modified time | relevance | path

Searched refs:mask (Results 1 – 20 of 20) sorted by relevance

/unit/src/
H A Dnxt_lvlhsh.c67 ((uintptr_t) lvl & (mask << 1))
205 uintptr_t mask; in nxt_lvlhsh_level_find() local
212 slot = lvl[key & mask]; in nxt_lvlhsh_level_find()
316 uintptr_t mask; in nxt_lvlhsh_level_insert() local
323 slot = &lvl[key & mask]; in nxt_lvlhsh_level_insert()
517 uintptr_t mask; in nxt_lvlhsh_level_convertion_insert() local
524 slot = &lvl[key & mask]; in nxt_lvlhsh_level_convertion_insert()
648 uintptr_t mask; in nxt_lvlhsh_level_delete() local
656 slot = &lvl[key & mask]; in nxt_lvlhsh_level_delete()
785 uintptr_t mask; in nxt_lvlhsh_level_each() local
[all …]
H A Dnxt_websocket_header.h20 uint8_t mask:1; member
32 uint8_t mask:1; member
H A Dnxt_port_memory_int.h132 nxt_free_map_t bits, mask; in nxt_port_mmap_get_free_chunk() local
135 mask = default_mask << ((*c) % FREE_BITS); in nxt_port_mmap_get_free_chunk()
138 bits = m[i] & mask; in nxt_port_mmap_get_free_chunk()
139 mask = default_mask; in nxt_port_mmap_get_free_chunk()
H A Dnxt_unit_websocket.h20 uint8_t *mask; member
H A Dnxt_h1proto_websocket.c265 if (nxt_slow_path(wsh->mask == 0)) { in nxt_h1p_conn_ws_frame_header_read()
403 uint8_t *p, *mask; in nxt_h1p_conn_ws_frame_process() local
419 mask = nxt_pointer_to(wsh, hsize - 4); in nxt_h1p_conn_ws_frame_process()
422 code = ((p[0] ^ mask[0]) << 8) + (p[1] ^ mask[1]); in nxt_h1p_conn_ws_frame_process()
652 uint8_t mask[4]; in nxt_h1p_conn_ws_pong() local
664 nxt_memcpy(mask, b->mem.pos, 4); in nxt_h1p_conn_ws_pong()
694 *out->mem.free++ = *b->mem.pos++ ^ mask[i % 4]; in nxt_h1p_conn_ws_pong()
H A Dnxt_test_build.c41 signalfd(int fd, const sigset_t *mask, int flags) in signalfd() argument
H A Dnxt_mem_zone.c582 uint8_t mask; in nxt_mem_zone_alloc_chunk() local
597 mask = 0x80; in nxt_mem_zone_alloc_chunk()
600 if ((map[n] & mask) == 0) { in nxt_mem_zone_alloc_chunk()
602 map[n] |= mask; in nxt_mem_zone_alloc_chunk()
607 mask >>= 1; in nxt_mem_zone_alloc_chunk()
609 } while (mask != 0); in nxt_mem_zone_alloc_chunk()
H A Dnxt_websocket.c72 if (h->mask) { in nxt_websocket_frame_header_size()
H A Dnxt_process.c335 sigset_t mask; in nxt_process_pipe_timer() local
354 pthread_sigmask(SIG_SETMASK, NULL, &mask); in nxt_process_pipe_timer()
355 sigdelset(&mask, SIGINT); in nxt_process_pipe_timer()
356 sigdelset(&mask, SIGTERM); in nxt_process_pipe_timer()
361 ret = ppoll(&pfd, 1, &ts, &mask); in nxt_process_pipe_timer()
H A Dnxt_test_build.h87 int signalfd(int fd, const sigset_t *mask, int flags);
H A Dnxt_http_parse.c1222 uint32_t key, mask; in nxt_http_fields_hash_collisions() local
1234 mask = level ? (1 << NXT_HTTP_FIELD_LVLHSH_SHIFT) - 1 : 0xFFFF; in nxt_http_fields_hash_collisions()
1247 lhq.key_hash = nxt_http_field_hash_end(key) & mask; in nxt_http_fields_hash_collisions()
H A Dnxt_unit.c1691 if (ws_impl->ws.header->mask) { in nxt_unit_process_websocket()
1692 ws_impl->ws.mask = (uint8_t *) b->buf.start + hsize - 4; in nxt_unit_process_websocket()
1695 ws_impl->ws.mask = NULL; in nxt_unit_process_websocket()
3426 if (ws->mask == NULL) { in nxt_unit_websocket_read()
3434 b[i] ^= ws->mask[ (i + d) % 4 ]; in nxt_unit_websocket_read()
3473 if (ws_impl->ws.header->mask) { in nxt_unit_websocket_retain()
3474 ws_impl->ws.mask = (uint8_t *) b + hsize - 4; in nxt_unit_websocket_retain()
3477 ws_impl->ws.mask = NULL; in nxt_unit_websocket_retain()
/unit/test/unit/applications/
H A Dwebsockets.py65 def apply_mask(self, data, mask): argument
66 return bytes(b ^ m for b, m in zip(data, itertools.cycle(mask)))
151 mask=True, argument
166 head2 = 0b10000000 if mask else 0
176 if mask:
180 if mask:
/unit/src/java/nginx/unit/websocket/
H A DWsRemoteEndpointImplBase.java441 byte[] mask; in writeMessagePart()
444 mask = Util.generateMask(); in writeMessagePart()
446 mask = null; in writeMessagePart()
692 byte[] mask, boolean first) { in writeHeader() argument
737 headerBuffer.put(mask[0]); in writeHeader()
738 headerBuffer.put(mask[1]); in writeHeader()
739 headerBuffer.put(mask[2]); in writeHeader()
740 headerBuffer.put(mask[3]); in writeHeader()
806 private final byte[] mask; field in WsRemoteEndpointImplBase.OutputBufferSendHandler
821 this.mask = mask; in OutputBufferSendHandler()
[all …]
H A DWsFrameBase.java79 private final byte[] mask = new byte[4]; field in WsFrameBase
278 inputBuffer.get(mask, 0, 4); in processRemainingHeader()
986 byte b = (byte) ((inputBuffer.get() ^ mask[maskIndex]) & 0xFF); in getMoreData()
/unit/auto/
H A Devents39 sigset_t mask;
41 sigemptyset(&mask);
42 n = signalfd(-1, &mask, 0);
/unit/src/nodejs/unit-http/
H A Dwebsocket_connection.js670 frame.mask = this.maskOutgoingPackets;
/unit/test/
H A Dtest_java_websockets.py93 ws.frame_write(sock, ws.OP_TEXT, message, mask=False)
H A Dtest_node_websockets.py93 ws.frame_write(sock, ws.OP_TEXT, message, mask=False)
H A Dtest_asgi_websockets.py134 ws.frame_write(sock, ws.OP_TEXT, message, mask=False)