@@ -28,17 +28,17 @@ class Poller {
28
28
auto * loop = UvLoop (env);
29
29
30
30
poll->data = this ;
31
- if (auto err = uv_poll_init_socket (loop, poll, fd); err != 0 ) {
31
+ if (auto err = uv_poll_init_socket (loop, poll. get () , fd); err != 0 ) {
32
32
return err;
33
33
}
34
34
35
35
readable_timer->data = this ;
36
- if (auto err = uv_timer_init (loop, readable_timer); err != 0 ) {
36
+ if (auto err = uv_timer_init (loop, readable_timer. get () ); err != 0 ) {
37
37
return err;
38
38
}
39
39
40
40
writable_timer->data = this ;
41
- if (auto err = uv_timer_init (loop, writable_timer); err != 0 ) {
41
+ if (auto err = uv_timer_init (loop, writable_timer. get () ); err != 0 ) {
42
42
return err;
43
43
}
44
44
@@ -72,7 +72,7 @@ class Poller {
72
72
73
73
if (timeout > 0 ) {
74
74
[[maybe_unused]] auto err = uv_timer_start (
75
- readable_timer,
75
+ readable_timer. get () ,
76
76
[](uv_timer_t * timer) {
77
77
auto & poller = *reinterpret_cast <Poller*>(timer->data );
78
78
poller.Trigger (UV_READABLE);
@@ -84,7 +84,7 @@ class Poller {
84
84
85
85
if (events == 0 ) {
86
86
/* Only start polling if we were not polling already. */
87
- [[maybe_unused]] auto err = uv_poll_start (poll, UV_READABLE, Callback);
87
+ [[maybe_unused]] auto err = uv_poll_start (poll. get () , UV_READABLE, Callback);
88
88
assert (err == 0 );
89
89
}
90
90
@@ -96,7 +96,7 @@ class Poller {
96
96
97
97
if (timeout > 0 ) {
98
98
[[maybe_unused]] auto err = uv_timer_start (
99
- writable_timer,
99
+ writable_timer. get () ,
100
100
[](uv_timer_t * timer) {
101
101
auto & poller = *reinterpret_cast <Poller*>(timer->data );
102
102
poller.Trigger (UV_WRITABLE);
@@ -110,7 +110,7 @@ class Poller {
110
110
events on the socket in an edge-triggered fashion by making the
111
111
file descriptor become ready for READING." */
112
112
if (events == 0 ) {
113
- [[maybe_unused]] auto err = uv_poll_start (poll, UV_READABLE, Callback);
113
+ [[maybe_unused]] auto err = uv_poll_start (poll. get () , UV_READABLE, Callback);
114
114
assert (err == 0 );
115
115
}
116
116
@@ -142,18 +142,18 @@ class Poller {
142
142
void Trigger (uint32_t triggered) {
143
143
events &= ~triggered;
144
144
if (events == 0 ) {
145
- [[maybe_unused]] auto err = uv_poll_stop (poll);
145
+ [[maybe_unused]] auto err = uv_poll_stop (poll. get () );
146
146
assert (err == 0 );
147
147
}
148
148
149
149
if ((triggered & UV_READABLE) != 0 ) {
150
- [[maybe_unused]] auto err = uv_timer_stop (readable_timer);
150
+ [[maybe_unused]] auto err = uv_timer_stop (readable_timer. get () );
151
151
assert (err == 0 );
152
152
static_cast <T*>(this )->ReadableCallback ();
153
153
}
154
154
155
155
if ((triggered & UV_WRITABLE) != 0 ) {
156
- [[maybe_unused]] auto err = uv_timer_stop (writable_timer);
156
+ [[maybe_unused]] auto err = uv_timer_stop (writable_timer. get () );
157
157
assert (err == 0 );
158
158
static_cast <T*>(this )->WritableCallback ();
159
159
}
0 commit comments