Lines Matching refs:_ntfy_obj
44 _ntfy_obj = NULL; in IMtConnection()
49 if (_ntfy_obj) { in ~IMtConnection()
50 NtfyObjMgr::Instance()->FreeNtfyObj(_ntfy_obj); in ~IMtConnection()
51 _ntfy_obj = NULL; in ~IMtConnection()
62 if (_ntfy_obj) { in Reset()
63 NtfyObjMgr::Instance()->FreeNtfyObj(_ntfy_obj); in Reset()
64 _ntfy_obj = NULL; in Reset()
73 _ntfy_obj = NULL; in Reset()
95 if (_ntfy_obj) { in CreateSocket()
96 _ntfy_obj->SetOsfd(_osfd); in CreateSocket()
247 if (_ntfy_obj) { in CreateSocket()
248 _ntfy_obj->SetOsfd(_osfd); in CreateSocket()
274 if (_ntfy_obj) { in CreateSocket()
275 _ntfy_obj->SetOsfd(_osfd); in CreateSocket()
602 if (!_action || !_ntfy_obj) { in CreateSocket()
603 MTLOG_ERROR("conn not set action %p, or _ntfy_obj %p, error", _action, _ntfy_obj); in CreateSocket()
606 SessionProxy* proxy = dynamic_cast<SessionProxy*>(_ntfy_obj); in CreateSocket()
608 MTLOG_ERROR("ntfy obj not match, _ntfy_obj %p, error", _ntfy_obj); in CreateSocket()
613 MTLOG_ERROR("real ntfy obj not match, _ntfy_obj %p, error", _ntfy_obj); in CreateSocket()
626 _ntfy_obj->SetOsfd(osfd); in CreateSocket()
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()
654 MTLOG_ERROR("socket send failed, fd %d, errno %d(%s)", _ntfy_obj->GetOsfd(), 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()
673 if (_ntfy_obj->GetRcvEvents() <= 0) { in RecvData()
674 MTLOG_DEBUG("conn _ntfy_obj %p, no recv event, retry it", _ntfy_obj); in RecvData()