| 360 | } |
| 361 | |
| 362 | void TCPSocket::read_callback(CFReadStreamRef stream, CFStreamEventType event, void *my_ptr) { |
| 363 | TCPSocket *s = reinterpret_cast<TCPSocket *>(my_ptr); |
| 364 | switch (event) { |
| 365 | case kCFStreamEventHasBytesAvailable: |
| 366 | s->rw_handler(true, true); |
| 367 | break; |
| 368 | case kCFStreamEventErrorOccurred: { |
| 369 | CFStreamError error = CFReadStreamGetError(stream); |
| 370 | if (error.domain == kCFStreamErrorDomainPOSIX) { |
| 371 | } else if (error.domain == kCFStreamErrorDomainMacOSStatus) { |
| 372 | } |
| 373 | s->close_and_call(); |
| 374 | break; |
| 375 | } |
| 376 | case kCFStreamEventEndEncountered: |
| 377 | s->close_and_call(); |
| 378 | break; |
| 379 | } |
| 380 | } |
| 381 | |
| 382 | void TCPSocket::write_callback(CFWriteStreamRef stream, CFStreamEventType event, void *my_ptr) { |
| 383 | TCPSocket *s = reinterpret_cast<TCPSocket *>(my_ptr); |
nothing calls this directly
no test coverage detected