Lines Matching refs:_msg_buff

45     _msg_buff   = NULL;  in IMtConnection()
54 if (_msg_buff) { in ~IMtConnection()
55 MsgBuffPool::Instance()->FreeMsgBuf(_msg_buff); in ~IMtConnection()
56 _msg_buff = NULL; in ~IMtConnection()
67 if (_msg_buff) { in Reset()
68 MsgBuffPool::Instance()->FreeMsgBuf(_msg_buff); in Reset()
69 _msg_buff = NULL; in Reset()
74 _msg_buff = NULL; in Reset()
117 if (!_action || !_msg_buff) { in SendData()
118 MTLOG_ERROR("conn not set action %p, or msg %p, error", _action, _msg_buff); in SendData()
123 int ret = ff_hook_sendto(_osfd, _msg_buff->GetMsgBuff(), _msg_buff->GetMsgLen(), 0, in SendData()
140 _msg_buff->SetHaveSndLen(ret); in SendData()
147 if (!_action || !_msg_buff) { in RecvData()
148 MTLOG_ERROR("conn not set action %p, or msg %p, error", _action, _msg_buff); in RecvData()
155 int ret = ff_hook_recvfrom(_osfd, _msg_buff->GetMsgBuff(), _msg_buff->GetMaxLen(), in RecvData()
176 _msg_buff->SetHaveRcvLen(ret); in RecvData()
182 _msg_buff->SetMsgLen(ret); in RecvData()
191 _msg_buff->SetHaveRcvLen(0); in RecvData()
208 if (!_action || !_msg_buff) { in OpenCnnect()
209 MTLOG_ERROR("conn not set action %p, or msg %p, error", _action, _msg_buff); in OpenCnnect()
283 if (!_action || !_msg_buff) { in SendData()
284 MTLOG_ERROR("conn not set action %p, or msg %p, error", _action, _msg_buff); in SendData()
288 char* msg_ptr = (char*)_msg_buff->GetMsgBuff(); in SendData()
289 int msg_len = _msg_buff->GetMsgLen(); in SendData()
290 int have_send_len = _msg_buff->GetHaveSndLen(); in SendData()
308 _msg_buff->SetHaveSndLen(have_send_len); in SendData()
323 if (!_action || !_msg_buff) { in RecvData()
324 MTLOG_ERROR("conn not set action %p, or msg %p, error", _action, _msg_buff); in RecvData()
328 char* msg_ptr = (char*)_msg_buff->GetMsgBuff(); in RecvData()
329 int max_len = _msg_buff->GetMaxLen(); in RecvData()
330 int have_rcv_len = _msg_buff->GetHaveRcvLen(); in RecvData()
354 _msg_buff->SetHaveRcvLen(have_rcv_len); in RecvData()
360 _msg_buff->SetMsgLen(have_rcv_len); in RecvData()
638 if (!_action || !_msg_buff || !_ntfy_obj) { in SendData()
639 … MTLOG_ERROR("conn not set action %p, or msg %p, ntfy %p error", _action, _msg_buff, _ntfy_obj); in SendData()
644 …int ret = ff_hook_sendto(_ntfy_obj->GetOsfd(), _msg_buff->GetMsgBuff(), _msg_buff->GetMsgLen(), 0, in SendData()
661 _msg_buff->SetHaveSndLen(ret); in SendData()
668 if (!_ntfy_obj || !_msg_buff) { in RecvData()
669 MTLOG_ERROR("conn not set _ntfy_obj %p, or msg %p, error", _ntfy_obj, _msg_buff); in RecvData()
678 int msg_len = _msg_buff->GetMsgLen(); in RecvData()
679 if (BUFF_RECV == _msg_buff->GetBuffType()) in RecvData()
685 MTLOG_DEBUG("conn msg buff %p, no recv comm", _msg_buff); in RecvData()