Lines Matching refs:msg_buff
107 MtMsgBuf* msg_buff = msgmgr->GetMsgBuf(max_len); in InitConnEnv() local
108 if (!msg_buff) { in InitConnEnv()
112 msg_buff->SetBuffType(BUFF_SEND); in InitConnEnv()
113 _conn->SetMtMsgBuff(msg_buff); in InitConnEnv()
138 MtMsgBuf* msg_buff = NULL; in DoEncode() local
140 msg_buff = _conn->GetMtMsgBuff(); in DoEncode()
142 if (!_conn || !msg_buff) { in DoEncode()
143 MTLOG_ERROR("conn(%p) or msgbuff(%p) null", _conn, msg_buff); in DoEncode()
147 int msg_len = msg_buff->GetMaxLen(); in DoEncode()
148 int ret = this->HandleEncode(msg_buff->GetMsgBuff(), msg_len, _msg); in DoEncode()
154 msg_buff->SetMsgLen(msg_len); in DoEncode()
161 MtMsgBuf* msg_buff = NULL; in DoInput() local
163 msg_buff = _conn->GetMtMsgBuff(); in DoInput()
165 if (!_conn || !msg_buff) { in DoInput()
166 MTLOG_ERROR("conn(%p) or msgbuff(%p) null", _conn, msg_buff); in DoInput()
170 int msg_len = msg_buff->GetHaveRcvLen(); in DoInput()
171 int ret = this->HandleInput(msg_buff->GetMsgBuff(), msg_len, _msg); in DoInput()
183 MtMsgBuf* msg_buff = NULL; in DoProcess() local
185 msg_buff = _conn->GetMtMsgBuff(); in DoProcess()
187 if (!_conn || !msg_buff) { in DoProcess()
188 MTLOG_ERROR("conn(%p) or msgbuff(%p) null", _conn, msg_buff); in DoProcess()
192 int ret = this->HandleProcess(msg_buff->GetMsgBuff(), msg_buff->GetMsgLen(), _msg); in DoProcess()