| 211 | #endif |
| 212 | |
| 213 | void addWaitingNativeSocket(const std::shared_ptr<KNativeSocketObject>& s) { |
| 214 | BOXEDWINE_CRITICAL_SECTION_WITH_MUTEX(waitingNodeMutex); |
| 215 | for (auto& waitingSocket : waitingNativeSockets) { |
| 216 | if (waitingSocket->nativeSocket == s->nativeSocket) { |
| 217 | return; |
| 218 | } |
| 219 | } |
| 220 | |
| 221 | waitingNativeSockets.push_back(s); |
| 222 | #ifdef BOXEDWINE_MULTI_THREADED |
| 223 | startNativeSocketsThread(); |
| 224 | char buf = 2; |
| 225 | ::send(nativeSocketPipe[1], &buf, 1, 0); |
| 226 | #endif |
| 227 | } |
| 228 | |
| 229 | void removeWaitingSocket(S32 nativeSocket) { |
| 230 | { |
no test coverage detected