diff options
| author | Joseph Henry <josephjah@gmail.com> | 2016-01-14 13:23:01 -0800 |
|---|---|---|
| committer | Joseph Henry <josephjah@gmail.com> | 2016-01-14 13:23:01 -0800 |
| commit | f52a82d9f2a9399fa957aee13f495b5565148084 (patch) | |
| tree | cf91a23813551cd151ede5e5d49d50815d6281ad /osdep | |
| parent | 5e30eabd30df01d5a186accef05c09fadbd4f21c (diff) | |
| download | infinitytier-f52a82d9f2a9399fa957aee13f495b5565148084.tar.gz infinitytier-f52a82d9f2a9399fa957aee13f495b5565148084.zip | |
Updated RX buffer code
Diffstat (limited to 'osdep')
| -rw-r--r-- | osdep/Phy.hpp | 10 |
1 files changed, 5 insertions, 5 deletions
diff --git a/osdep/Phy.hpp b/osdep/Phy.hpp index 8b6db36b..7dc0b5dd 100644 --- a/osdep/Phy.hpp +++ b/osdep/Phy.hpp @@ -974,6 +974,11 @@ public: case ZT_PHY_SOCKET_UNIX_IN: { #ifdef __UNIX_LIKE__ ZT_PHY_SOCKFD_TYPE sock = s->sock; // if closed, s->sock becomes invalid as s is no longer dereferencable + if ((FD_ISSET(sock,&wfds))&&(FD_ISSET(sock,&_writefds))) { + try { + _handler->phyOnUnixWritable((PhySocket *)&(*s),&(s->uptr)); + } catch ( ... ) {} + } if (FD_ISSET(sock,&rfds)) { long n = (long)::read(sock,buf,sizeof(buf)); if (n <= 0) { @@ -984,11 +989,6 @@ public: } catch ( ... ) {} } } - if ((FD_ISSET(sock,&wfds))&&(FD_ISSET(sock,&_writefds))) { - try { - //_handler->phyOnUnixWritable((PhySocket *)&(*s),&(s->uptr)); - } catch ( ... ) {} - } #endif // __UNIX_LIKE__ } break; |