Lines Matching refs:_recv_cache
756 rw_cache_destroy(&_recv_cache); in Reset()
779 rw_cache_init(&_recv_cache, NULL); in CSockLink()
802 _recv_cache.pool = CNetMgr::Instance()->GetSkBuffMng(type); in SetProtoType()
1141 _rsp_buff->data_len += read_cache_begin(&_recv_cache, _rsp_buff->data_len, in ExtendRecvRsp()
1195 while (_recv_cache.len > 0) in DispathTcp()
1237 if (_rsp_buff->data_len >= _recv_cache.len) in DispathTcp()
1239 MTLOG_DEBUG("maybe need wait more data, now %u", _recv_cache.len); in DispathTcp()
1246 if (ret > (int32_t)_recv_cache.len) in DispathTcp()
1256 cache_skip_data(&_recv_cache, ret); in DispathTcp()
1263 cache_skip_data(&_recv_cache, ret); in DispathTcp()
1297 while ((block = TAILQ_FIRST(&_recv_cache.list)) != NULL) in DispathUdp()
1302 cache_skip_data(&_recv_cache, block->data_len); in DispathUdp()
1311 cache_skip_data(&_recv_cache, block->data_len); in DispathUdp()
1319 cache_skip_data(&_recv_cache, block->data_len); in DispathUdp()
1326 cache_skip_first_buffer(&_recv_cache); in DispathUdp()
1360 ret = cache_udp_recv(&_recv_cache, _fd, NULL); in InputNotify()
1364 ret = cache_tcp_recv(&_recv_cache, _fd); in InputNotify()