| 164 | } |
| 165 | |
| 166 | void LocalSocket::OnDisconnect(){ |
| 167 | connected = false; |
| 168 | |
| 169 | acquireLock(&watcherLock); |
| 170 | while(watching.get_length()){ |
| 171 | watching.remove_at(0)->Signal(); // Signal all watching on disconnect |
| 172 | } |
| 173 | releaseLock(&watcherLock); |
| 174 | |
| 175 | peer = nullptr; |
| 176 | } |
| 177 | |
| 178 | Socket* LocalSocket::Accept(sockaddr* addr, socklen_t* addrlen, int mode){ |
| 179 | if((mode & O_NONBLOCK) && pending.get_length() <= 0){ |
no test coverage detected