Lines Matching refs:flags
75 uint32_t flags; member
132 assert(!(handle->flags & UV_HANDLE_PIPESERVER)); in uv__pipe_connection_init()
390 uv_pipe_t* parent_pipe, HANDLE* child_pipe_ptr, unsigned int flags) { in uv__create_stdio_pipe_pair() argument
407 if (flags & UV_READABLE_PIPE) { in uv__create_stdio_pipe_pair()
414 if (flags & UV_WRITABLE_PIPE) { in uv__create_stdio_pipe_pair()
419 if (flags & UV_NONBLOCK_PIPE || parent_pipe->ipc) { in uv__create_stdio_pipe_pair()
440 if (flags & UV_READABLE_PIPE) in uv__create_stdio_pipe_pair()
441 parent_pipe->flags |= UV_HANDLE_WRITABLE; in uv__create_stdio_pipe_pair()
442 if (flags & UV_WRITABLE_PIPE) in uv__create_stdio_pipe_pair()
443 parent_pipe->flags |= UV_HANDLE_READABLE; in uv__create_stdio_pipe_pair()
470 assert(handle->flags & UV_HANDLE_CONNECTION); in uv__set_pipe_handle()
471 assert(!(handle->flags & UV_HANDLE_PIPESERVER)); in uv__set_pipe_handle()
472 if (handle->flags & UV_HANDLE_CLOSING) in uv__set_pipe_handle()
515 handle->flags |= UV_HANDLE_NON_OVERLAPPED_PIPE; in uv__set_pipe_handle()
524 handle->flags |= UV_HANDLE_EMULATE_IOCP; in uv__set_pipe_handle()
530 handle->flags |= duplex_flags; in uv__set_pipe_handle()
595 assert(handle->flags & UV_HANDLE_CONNECTION); in uv__pipe_shutdown()
600 if (handle->flags & UV_HANDLE_CLOSING) { in uv__pipe_shutdown()
614 handle->flags |= UV_HANDLE_WRITABLE; /* Questionable. */ in uv__pipe_shutdown()
632 handle->flags |= UV_HANDLE_WRITABLE; /* Questionable. */ in uv__pipe_shutdown()
643 assert(handle->flags & UV_HANDLE_CLOSING); in uv__pipe_endgame()
644 assert(!(handle->flags & UV_HANDLE_CLOSED)); in uv__pipe_endgame()
646 if (handle->flags & UV_HANDLE_CONNECTION) { in uv__pipe_endgame()
670 if (handle->flags & UV_HANDLE_EMULATE_IOCP) { in uv__pipe_endgame()
681 if (handle->flags & UV_HANDLE_NON_OVERLAPPED_PIPE) in uv__pipe_endgame()
685 if (handle->flags & UV_HANDLE_PIPESERVER) { in uv__pipe_endgame()
696 if (handle->flags & UV_HANDLE_BOUND) in uv_pipe_pending_instances()
699 handle->flags |= UV_HANDLE_PIPESERVER; in uv_pipe_pending_instances()
712 unsigned int flags) { in uv_pipe_bind2() argument
718 if (flags & ~UV_PIPE_NO_TRUNCATE) { in uv_pipe_bind2()
734 if (handle->flags & UV_HANDLE_BOUND) { in uv_pipe_bind2()
750 if (!(handle->flags & UV_HANDLE_PIPESERVER)) { in uv_pipe_bind2()
798 handle->flags |= UV_HANDLE_PIPESERVER; in uv_pipe_bind2()
799 handle->flags |= UV_HANDLE_BOUND; in uv_pipe_bind2()
880 unsigned int flags, in uv_pipe_connect2() argument
897 if (flags & ~UV_PIPE_NO_TRUNCATE) { in uv_pipe_connect2()
921 if (handle->flags & UV_HANDLE_PIPESERVER) { in uv_pipe_connect2()
925 if (handle->flags & UV_HANDLE_CONNECTION) { in uv_pipe_connect2()
1003 if (!(handle->flags & UV_HANDLE_READ_PENDING)) in uv__pipe_interrupt_read()
1005 if (handle->flags & UV_HANDLE_CANCELLATION_PENDING) in uv__pipe_interrupt_read()
1010 if (!(handle->flags & UV_HANDLE_NON_OVERLAPPED_PIPE)) { in uv__pipe_interrupt_read()
1043 handle->flags |= UV_HANDLE_CANCELLATION_PENDING; in uv__pipe_interrupt_read()
1048 handle->flags &= ~UV_HANDLE_READING; in uv__pipe_read_stop()
1060 if (handle->flags & UV_HANDLE_READING) { in uv__pipe_close()
1061 handle->flags &= ~UV_HANDLE_READING; in uv__pipe_close()
1065 if (handle->flags & UV_HANDLE_LISTENING) { in uv__pipe_close()
1066 handle->flags &= ~UV_HANDLE_LISTENING; in uv__pipe_close()
1070 handle->flags &= ~(UV_HANDLE_READABLE | UV_HANDLE_WRITABLE); in uv__pipe_close()
1081 if (handle->flags & UV_HANDLE_PIPESERVER) { in uv__pipe_close()
1092 if (handle->flags & UV_HANDLE_CONNECTION) { in uv__pipe_close()
1096 if ((handle->flags & UV_HANDLE_CONNECTION) in uv__pipe_close()
1109 assert(handle->flags & UV_HANDLE_LISTENING); in uv__pipe_queue_accept()
1185 pipe_client->flags |= UV_HANDLE_READABLE | UV_HANDLE_WRITABLE; in uv__pipe_accept()
1193 if (!(server->flags & UV_HANDLE_CLOSING)) { in uv__pipe_accept()
1207 if (handle->flags & UV_HANDLE_LISTENING) { in uv__pipe_listen()
1211 if (!(handle->flags & UV_HANDLE_BOUND)) { in uv__pipe_listen()
1215 if (handle->flags & UV_HANDLE_READING) { in uv__pipe_listen()
1219 if (!(handle->flags & UV_HANDLE_PIPESERVER)) { in uv__pipe_listen()
1227 handle->flags |= UV_HANDLE_LISTENING; in uv__pipe_listen()
1383 assert(handle->flags & UV_HANDLE_READING); in uv__pipe_queue_read()
1384 assert(!(handle->flags & UV_HANDLE_READ_PENDING)); in uv__pipe_queue_read()
1390 if (handle->flags & UV_HANDLE_NON_OVERLAPPED_PIPE) { in uv__pipe_queue_read()
1401 if (handle->flags & UV_HANDLE_EMULATE_IOCP) { in uv__pipe_queue_read()
1419 if (handle->flags & UV_HANDLE_EMULATE_IOCP) { in uv__pipe_queue_read()
1433 handle->flags |= UV_HANDLE_READ_PENDING; in uv__pipe_queue_read()
1439 handle->flags |= UV_HANDLE_READ_PENDING; in uv__pipe_queue_read()
1449 handle->flags |= UV_HANDLE_READING; in uv__pipe_read_start()
1456 if (!(handle->flags & UV_HANDLE_READ_PENDING)) { in uv__pipe_read_start()
1457 if (handle->flags & UV_HANDLE_EMULATE_IOCP && in uv__pipe_read_start()
1603 if (handle->flags & (UV_HANDLE_EMULATE_IOCP | UV_HANDLE_BLOCKING_WRITES)) { in uv__pipe_write_data()
1626 if ((handle->flags & in uv__pipe_write_data()
1646 } else if (handle->flags & UV_HANDLE_NON_OVERLAPPED_PIPE) { in uv__pipe_write_data()
1656 } else if (handle->flags & UV_HANDLE_BLOCKING_WRITES) { in uv__pipe_write_data()
1713 if (handle->flags & UV_HANDLE_EMULATE_IOCP) { in uv__pipe_write_data()
1814 frame_header.flags |= UV__IPC_FRAME_HAS_SOCKET_XFER | in uv__pipe_write_ipc()
1818 frame_header.flags |= UV__IPC_FRAME_HAS_SOCKET_XFER; in uv__pipe_write_ipc()
1829 frame_header.flags |= UV__IPC_FRAME_HAS_DATA; in uv__pipe_write_ipc()
2003 if ((frame_header.flags & ~UV__IPC_FRAME_VALID_FLAGS) != 0) in uv__pipe_read_ipc()
2010 xfer_flags = frame_header.flags & UV__IPC_FRAME_XFER_FLAGS; in uv__pipe_read_ipc()
2025 if (frame_header.flags & UV__IPC_FRAME_HAS_DATA) { in uv__pipe_read_ipc()
2064 handle->flags &= ~(UV_HANDLE_READ_PENDING | UV_HANDLE_CANCELLATION_PENDING); in uv__process_pipe_read_req()
2071 if (!(handle->flags & UV_HANDLE_READING)) in uv__process_pipe_read_req()
2096 while (avail > 0 && handle->flags & UV_HANDLE_READING) { in uv__process_pipe_read_req()
2119 if ((handle->flags & UV_HANDLE_READING) && in uv__process_pipe_read_req()
2120 !(handle->flags & UV_HANDLE_READ_PENDING)) { in uv__process_pipe_read_req()
2137 if (handle->flags & UV_HANDLE_EMULATE_IOCP) { in uv__process_pipe_write_req()
2165 if (handle->flags & UV_HANDLE_NON_OVERLAPPED_PIPE && in uv__process_pipe_write_req()
2185 if (handle->flags & UV_HANDLE_CLOSING) { in uv__process_pipe_accept_req()
2205 if (!(handle->flags & UV_HANDLE_CLOSING)) { in uv__process_pipe_accept_req()
2228 if (handle->flags & UV_HANDLE_CLOSING) in uv__process_pipe_connect_req()
2256 if (handle->flags & UV_HANDLE_CLOSING) { in uv__process_pipe_shutdown_req()
2263 if (handle->flags & UV_HANDLE_READABLE) { in uv__process_pipe_shutdown_req()
2270 if (handle->flags & UV_HANDLE_READ_PENDING) { in uv__process_pipe_shutdown_req()
2293 assert(pipe->flags & UV_HANDLE_CONNECTION); in eof_timer_init()
2306 assert(pipe->flags & UV_HANDLE_CONNECTION); in eof_timer_start()
2315 assert(pipe->flags & UV_HANDLE_CONNECTION); in eof_timer_stop()
2333 assert(pipe->flags & UV_HANDLE_READ_PENDING); in eof_timer_cb()
2339 if ((pipe->flags & UV_HANDLE_READ_PENDING) && in eof_timer_cb()
2358 assert(pipe->flags & UV_HANDLE_CONNECTION); in eof_timer_destroy()
2383 if (pipe->flags & UV_HANDLE_PIPESERVER) in uv_pipe_open()
2385 if (pipe->flags & UV_HANDLE_CONNECTION) in uv_pipe_open()
2445 assert(!(pipe->flags & UV_HANDLE_NON_OVERLAPPED_PIPE)); in uv_pipe_open()
2485 if (handle->flags & UV_HANDLE_CONNECTION && in uv__pipe_getname()
2486 handle->flags & UV_HANDLE_NON_OVERLAPPED_PIPE) { in uv__pipe_getname()
2558 if (handle->flags & UV_HANDLE_BOUND) in uv_pipe_getsockname()
2561 if (handle->flags & UV_HANDLE_CONNECTION || in uv_pipe_getsockname()
2573 if (handle->flags & UV_HANDLE_BOUND) in uv_pipe_getpeername()
2579 if (handle->flags & UV_HANDLE_CONNECTION) { in uv_pipe_getpeername()
