| 39 | } |
| 40 | |
| 41 | void CSocketImpl::SyncRead() { |
| 42 | if (!_read_event->_client_socket) { |
| 43 | _read_event->_client_socket = memshared_from_this(); |
| 44 | } |
| 45 | |
| 46 | if (_event_actions) { |
| 47 | _read_event->_event_flag_set = 0; |
| 48 | _read_event->_event_flag_set |= EVENT_READ; |
| 49 | if (_event_actions->AddRecvEvent(_read_event)) { |
| 50 | _post_event_num++; |
| 51 | |
| 52 | // something wrong |
| 53 | }else { |
| 54 | auto cppnet_ins = GetCppnetInstance(); |
| 55 | if (cppnet_ins) { |
| 56 | cppnet_ins->_ReadFunction(_read_event, ERR_CONNECT_CLOSE | EVENT_DISCONNECT); |
| 57 | } |
| 58 | } |
| 59 | } |
| 60 | } |
| 61 | |
| 62 | void CSocketImpl::SyncWrite(const char* src, uint32_t len) { |
| 63 | _write_event->_buffer->Write(src, len); |
no test coverage detected