luo980/uvw
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

clean up

Browse Source
This commit is contained in:
Michele Caini 2016-07-26 09:06:00 +02:00
parent be34dfdf69
commit 4e87371513
3 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
src/uvw/pipe.hpp
View File

@ -42,7 +42,7 @@ public:
}
void connect(std::string name) {
auto listener = [ptr = this->shared_from_this()](const auto &event, details::Connect &) {
auto listener = [ptr = shared_from_this()](const auto &event, details::Connect &) {
ptr->publish(event);
};

2
src/uvw/tcp.hpp
View File

@ -84,7 +84,7 @@ public:
typename details::IpTraits<I>::Type addr;
details::IpTraits<I>::AddrFunc(ip.data(), port, &addr);
auto listener = [ptr = this->shared_from_this()](const auto &event, details::Connect &) {
auto listener = [ptr = shared_from_this()](const auto &event, details::Connect &) {
ptr->publish(event);
};

6
src/uvw/udp.hpp
View File

@ -137,11 +137,11 @@ public:
uv_buf_t bufs[] = { uv_buf_init(data, len) };
auto listener = [ptr = this->shared_from_this()](const auto &event, details::Send &) {
auto listener = [ptr = shared_from_this()](const auto &event, details::Send &) {
ptr->publish(event);
};
auto send = this->loop().resource<details::Send>();
auto send = loop().resource<details::Send>();
send->once<ErrorEvent>(listener);
send->once<SendEvent>(listener);
send->send(get<uv_udp_t>(), bufs, 1, reinterpret_cast<const sockaddr *>(&addr));
@ -161,7 +161,7 @@ public:
auto bw = uv_udp_try_send(get<uv_udp_t>(), bufs, 1, reinterpret_cast<const sockaddr *>(&addr));
if(bw < 0) {
this->publish(ErrorEvent{bw});
publish(ErrorEvent{bw});
bw = 0;
}