Home
last modified time | relevance | path

Searched refs:SW_EVENT_WRITE (Results 1 – 25 of 29) sorted by relevance

12

/dports/devel/pecl-swoole/swoole-4.8.5/core-tests/src/reactor/
H A Dbase.cpp42 …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 Dswoole_reactor.h229 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 Dswoole_coroutine_socket.h155 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 Dswoole.h418 SW_EVENT_WRITE = 1u << 10, enumerator
419 SW_EVENT_RDWR = SW_EVENT_READ | SW_EVENT_WRITE,
H A Dswoole_socket.h428 return events & SW_EVENT_WRITE; in isset_writable_event()
/dports/devel/pecl-swoole/swoole-4.8.5/src/coroutine/
H A Dsystem.cc366 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 Dsocket.cc73 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 Dclient.cc67 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 Dsocket.cc108 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 Ddns.cc419 … 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 Dswoole_event.cc188 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 Dswoole_curl.cc68 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 Dphp_swoole_curl.h135 return action == CURL_POLL_IN ? SW_EVENT_READ : SW_EVENT_WRITE; in get_event()
H A Dswoole_runtime.cc1815 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 Dkqueue.cc219 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 Dbase.cc279 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 Dselect.cc195 handler = reactor_->get_handler(SW_EVENT_WRITE, event.type); in wait()
H A Depoll.cc206 handler = reactor_->get_handler(SW_EVENT_WRITE, event.type);
H A Dpoll.cc202 handler = reactor_->get_handler(SW_EVENT_WRITE, event.type); in wait()
/dports/devel/pecl-swoole/swoole-4.8.5/src/wrapper/
H A Devent.cc68 } else if (event == SW_EVENT_WRITE) { in swoole_event_add_or_update()
/dports/devel/pecl-swoole/swoole-4.8.5/src/server/
H A Dmaster.cc1323 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 Dtask_worker.cc371 if (_sock->wait_event(-1, SW_EVENT_WRITE) == 0) { in add_static_handler_location()
H A Dreactor_thread.cc490 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 Dhook.cpp140 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 Dasync_thread.cc265 event->pipe_socket->wait_event(1000, SW_EVENT_WRITE); in Stream_onConnect()

12