/dports/devel/pecl-swoole/swoole-4.8.5/core-tests/src/reactor/ |
H A D | base.cpp | 42 …ASSERT_NE(reactor->write_handler[Reactor::get_fd_type(SW_FD_CO_SOCKET | SW_EVENT_WRITE)], nullptr); in TEST() 49 … ASSERT_NE(reactor->write_handler[Reactor::get_fd_type(SW_FD_CO_POLL | SW_EVENT_WRITE)], nullptr); in TEST() 53 … ASSERT_NE(reactor->write_handler[Reactor::get_fd_type(SW_FD_CO_EVENT | SW_EVENT_WRITE)], nullptr); in TEST() 67 reactor.set_handler(SW_EVENT_WRITE, (ReactorHandler) 0x2); in TEST() 68 ASSERT_EQ(reactor.write_handler[Reactor::get_fd_type(SW_EVENT_WRITE)], (ReactorHandler) 0x2); in TEST() 216 reactor->set_handler(SW_FD_PIPE | SW_EVENT_WRITE, [](Reactor *reactor, Event *event) -> int { in reactor_test_func() 224 reactor->add(p.get_socket(true), SW_EVENT_WRITE); in reactor_test_func() 253 ret = swoole_event_add_or_update(p.get_socket(false), SW_EVENT_WRITE); in TEST() 256 ASSERT_TRUE(p.get_socket(false)->events & SW_EVENT_WRITE); in TEST()
|
/dports/devel/pecl-swoole/swoole-4.8.5/include/ |
H A D | swoole_reactor.h | 229 if (_socket->events & SW_EVENT_WRITE) { in remove_read_event() 239 _socket->events &= (~SW_EVENT_WRITE); in remove_write_event() 247 if (_socket->events & SW_EVENT_WRITE) { in add_read_event() 257 _socket->events |= SW_EVENT_WRITE; in add_write_event() 260 return add(_socket, SW_EVENT_WRITE); in add_write_event() 294 case SW_EVENT_WRITE: in get_handler() 311 handler = get_handler(SW_EVENT_WRITE, fd_type); in get_error_handler() 361 …return (FdType)(flags & (~SW_EVENT_READ) & (~SW_EVENT_WRITE) & (~SW_EVENT_ERROR) & (~SW_EVENT_ONCE… in get_fd_type() 369 return events & SW_EVENT_WRITE; in isset_write_event()
|
H A D | swoole_coroutine_socket.h | 155 reactor->set_handler(SW_FD_CO_SOCKET | SW_EVENT_WRITE, writable_event_callback); in init_reactor() 212 if (event & SW_EVENT_WRITE) { in get_bound_co() 228 } else if (event == SW_EVENT_WRITE) { in get_event_str()
|
H A D | swoole.h | 418 SW_EVENT_WRITE = 1u << 10, enumerator 419 SW_EVENT_RDWR = SW_EVENT_READ | SW_EVENT_WRITE,
|
H A D | swoole_socket.h | 428 return events & SW_EVENT_WRITE; in isset_writable_event()
|
/dports/devel/pecl-swoole/swoole-4.8.5/src/coroutine/ |
H A D | system.cc | 366 if (i->second.events & SW_EVENT_WRITE) { in socket_poll_trigger_event() 367 i->second.revents |= SW_EVENT_WRITE; in socket_poll_trigger_event() 389 …ket_poll_trigger_event(reactor, (CoroPollTask *) event->socket->object, event->fd, SW_EVENT_WRITE); in socket_poll_write_callback() 404 if (events & SW_EVENT_WRITE) { in translate_events_to_poll() 418 sw_events |= SW_EVENT_WRITE; in translate_events_from_poll() 548 event_waiter_callback(reactor, (EventWaiter *) event->socket->object, SW_EVENT_WRITE); in event_waiter_write_callback() 561 events &= SW_EVENT_READ | SW_EVENT_WRITE; in wait_event() 595 if (events & SW_EVENT_WRITE) { in wait_event() 596 revents |= SW_EVENT_WRITE; in wait_event() 605 reactor->set_handler(SW_FD_CO_POLL | SW_EVENT_WRITE, socket_poll_write_callback); in init_reactor() [all …]
|
H A D | socket.cc | 73 if (socket->want_event == SW_EVENT_WRITE) { in writable_event_callback() 135 want_event = SW_EVENT_WRITE; in wait_event() 165 } else if (event == SW_EVENT_WRITE) { in wait_event() 794 if (sw_unlikely(!is_available(SW_EVENT_WRITE))) { in send() 883 if (sw_unlikely(!is_available(SW_EVENT_WRITE))) { in write() 959 if (sw_unlikely(!is_available(SW_EVENT_WRITE))) { in writev() 973 if (sw_unlikely(!is_available(SW_EVENT_WRITE))) { in writev_all() 1056 if (sw_unlikely(!is_available(SW_EVENT_WRITE))) { in send_all() 1107 if (sw_unlikely(!is_available(SW_EVENT_WRITE))) { in sendmsg() 1310 if (sw_unlikely(!is_available(SW_EVENT_WRITE))) { in sendfile() [all …]
|
/dports/devel/pecl-swoole/swoole-4.8.5/src/network/ |
H A D | client.cc | 67 reactor->set_handler(SW_FD_STREAM_CLIENT | SW_EVENT_WRITE, Client_onWrite); 112 if (socket->events & SW_EVENT_WRITE) { 113 ret = swoole_event_set(socket, SW_EVENT_WRITE); 125 if (socket->events & SW_EVENT_WRITE) { 126 ret = swoole_event_set(socket, SW_EVENT_READ | SW_EVENT_WRITE); 520 … if (cli->socket->wait_event(timeout > 0 ? (int) (timeout * 1000) : timeout, SW_EVENT_WRITE) < 0) { 660 if (swoole_event_add(cli->socket, SW_EVENT_WRITE) < 0) { 710 cli->socket->wait_event(1000, SW_EVENT_WRITE); 737 if (swoole_event_add_or_update(cli->socket, SW_EVENT_WRITE) == SW_ERR) { 978 swoole_event_set(event->socket, SW_EVENT_WRITE); [all …]
|
H A D | socket.cc | 108 if (wait_event(timeout_ms, SW_EVENT_WRITE) < 0) { 131 wait_event((int) (send_timeout_ * 1000), SW_EVENT_WRITE) == SW_OK) { 168 if (events & SW_EVENT_WRITE) { 203 wait_event((int) (send_timeout_ * 1000), SW_EVENT_WRITE) == SW_OK) { 279 …tch_error(errno) == SW_WAIT && wait_event((int) (send_timeout_ * 1000), SW_EVENT_WRITE) == SW_OK) {
|
H A D | dns.cc | 419 … swoole_event_set_handler(SW_FD_CARES | SW_EVENT_WRITE, [](Reactor *reactor, Event *event) -> int { in init_reactor() 446 events |= SW_EVENT_WRITE; in init_reactor()
|
/dports/devel/pecl-swoole/swoole-4.8.5/ext-src/ |
H A D | swoole_event.cc | 188 return reactor->get_handler(SW_EVENT_WRITE, event->socket->fd_type)(reactor, event); in event_error_callback() 422 swoole_event_set_handler(SW_FD_USER | SW_EVENT_WRITE, event_writable_callback); in event_check_reactor() 461 if (socket_fd == 0 && (events & SW_EVENT_WRITE)) { in PHP_FUNCTION() 469 if (!(events & (SW_EVENT_WRITE | SW_EVENT_READ))) { in PHP_FUNCTION() 598 if ((events & SW_EVENT_WRITE) && reactor_fd->fci_cache_write.function_handler == nullptr) { in PHP_FUNCTION() 762 zend_long events = SW_EVENT_READ | SW_EVENT_WRITE; in PHP_FUNCTION()
|
H A D | swoole_curl.cc | 68 swoole_event_set_handler(PHP_SWOOLE_FD_CO_CURL | SW_EVENT_WRITE, cb_writable); in create_socket() 107 events |= SW_EVENT_WRITE; in set_event()
|
H A D | php_swoole_curl.h | 135 return action == CURL_POLL_IN ? SW_EVENT_READ : SW_EVENT_WRITE; in get_event()
|
H A D | swoole_runtime.cc | 1815 stream_array_to_fd_set(w_array, fds, SW_EVENT_WRITE); in PHP_FUNCTION() 1875 SW_ASSERT((revents & (~(SW_EVENT_READ | SW_EVENT_WRITE | SW_EVENT_ERROR))) == 0); in PHP_FUNCTION() 1880 if ((revents & SW_EVENT_WRITE) && w_array) { in PHP_FUNCTION()
|
/dports/devel/pecl-swoole/swoole-4.8.5/src/reactor/ |
H A D | kqueue.cc | 219 if (socket->events & SW_EVENT_WRITE) { in del() 295 … handler = reactor_->get_handler(kevent->filter == EVFILT_READ ? SW_EVENT_READ : SW_EVENT_WRITE, in wait()
|
H A D | base.cc | 279 socket->wait_event(SW_SOCKET_OVERFLOW_WAIT, SW_EVENT_WRITE); in write_func() 368 if (socket->wait_event(network::Socket::default_write_timeout, SW_EVENT_WRITE) == SW_ERR) { in drain_write_buffer()
|
H A D | select.cc | 195 handler = reactor_->get_handler(SW_EVENT_WRITE, event.type); in wait()
|
H A D | epoll.cc | 206 handler = reactor_->get_handler(SW_EVENT_WRITE, event.type);
|
H A D | poll.cc | 202 handler = reactor_->get_handler(SW_EVENT_WRITE, event.type); in wait()
|
/dports/devel/pecl-swoole/swoole-4.8.5/src/wrapper/ |
H A D | event.cc | 68 } else if (event == SW_EVENT_WRITE) { in swoole_event_add_or_update()
|
/dports/devel/pecl-swoole/swoole-4.8.5/src/server/ |
H A D | master.cc | 1323 if (_socket->events & SW_EVENT_WRITE) { 1324 return reactor->set(conn->socket, SW_EVENT_WRITE); 1336 if (_socket->events & SW_EVENT_WRITE) { 1337 return reactor->set(_socket, SW_EVENT_READ | SW_EVENT_WRITE);
|
H A D | task_worker.cc | 371 if (_sock->wait_event(-1, SW_EVENT_WRITE) == 0) { in add_static_handler_location()
|
H A D | reactor_thread.cc | 490 reactor->set_handler(SW_FD_SESSION | SW_EVENT_WRITE, ReactorThread_onWrite); 754 reactor->set_handler(SW_FD_PIPE | SW_EVENT_WRITE, ReactorThread_onPipeWrite);
|
/dports/devel/pecl-swoole/swoole-4.8.5/core-tests/src/coroutine/ |
H A D | hook.cpp | 140 ASSERT_EQ(swoole_coroutine_socket_wait_event(sock, SW_EVENT_WRITE, 5), SW_OK); in TEST()
|
/dports/devel/pecl-swoole/swoole-4.8.5/src/os/ |
H A D | async_thread.cc | 265 event->pipe_socket->wait_event(1000, SW_EVENT_WRITE); in Stream_onConnect()
|