22
22
23
23
#include < mutex>
24
24
25
- using namespace swoole ;
26
-
25
+ using swoole::Callback;
26
+ using swoole::Reactor;
27
+ using swoole::ReactorHandler;
27
28
using swoole::network::Socket;
28
29
29
30
static std::mutex init_lock;
@@ -49,9 +50,9 @@ int swoole_event_init(int flags) {
49
50
reactor->wait_exit = 1 ;
50
51
}
51
52
52
- coroutine::Socket::init_reactor (reactor);
53
- coroutine::System::init_reactor (reactor);
54
- network::Client::init_reactor (reactor);
53
+ swoole:: coroutine::Socket::init_reactor (reactor);
54
+ swoole:: coroutine::System::init_reactor (reactor);
55
+ swoole:: network::Client::init_reactor (reactor);
55
56
56
57
SwooleTG.reactor = reactor;
57
58
@@ -62,7 +63,7 @@ int swoole_event_add(Socket *socket, int events) {
62
63
return SwooleTG.reactor ->add (socket, events);
63
64
}
64
65
65
- int swoole_event_add_or_update (swoole::network:: Socket *_socket, int event) {
66
+ int swoole_event_add_or_update (Socket *_socket, int event) {
66
67
if (event == SW_EVENT_READ) {
67
68
return SwooleTG.reactor ->add_read_event (_socket);
68
69
} else if (event == SW_EVENT_WRITE) {
@@ -108,7 +109,7 @@ ssize_t swoole_event_write(Socket *socket, const void *data, size_t len) {
108
109
return SwooleTG.reactor ->write (SwooleTG.reactor , socket, data, len);
109
110
}
110
111
111
- ssize_t swoole_event_writev (swoole::network:: Socket *socket, const iovec *iov, size_t iovcnt) {
112
+ ssize_t swoole_event_writev (Socket *socket, const iovec *iov, size_t iovcnt) {
112
113
return SwooleTG.reactor ->writev (SwooleTG.reactor , socket, iov, iovcnt);
113
114
}
114
115
0 commit comments