refinements
This commit is contained in:
parent
c58c9b8d15
commit
0c60ea1cff
@ -30,6 +30,8 @@ public:
|
||||
|
||||
void start(int signum) { invoke(uv_signal_start, get<uv_signal_t>(), &startCallback, signum); }
|
||||
void stop() { invoke(&uv_signal_stop, get<uv_signal_t>()); }
|
||||
|
||||
int signal() const noexcept { return get<uv_signal_t>()->signum; }
|
||||
};
|
||||
|
||||
|
||||
|
||||
@ -35,15 +35,11 @@ class Tcp final: public Stream<Tcp> {
|
||||
|
||||
int err = std::forward<F>(f)(get<uv_tcp_t>(), reinterpret_cast<sockaddr *>(&ssto), &len);
|
||||
|
||||
if(err) {
|
||||
publish(ErrorEvent{err});
|
||||
} else {
|
||||
if(!err) {
|
||||
typename Traits::Type *aptr = reinterpret_cast<typename Traits::Type *>(&ssto);
|
||||
err = Traits::NameFunc(aptr, name, len);
|
||||
|
||||
if(err) {
|
||||
publish(ErrorEvent{err});
|
||||
} else {
|
||||
if(!err) {
|
||||
addr = { std::string{name}, ntohs(aptr->sin_port) };
|
||||
}
|
||||
}
|
||||
|
||||
Loading…
Reference in New Issue
Block a user