Searched refs:m_curMsgPos (Results 1 – 2 of 2) sorted by relevance
266 , m_curMsgPos (0) in TcpIpRecvThread()280 m_curMsgPos = 0; in start()292 bool hasHeader = m_curMsgPos >= xs::MESSAGE_HEADER_SIZE; in run()300 hasPayload = m_curMsgPos >= messageSize; in run()306 …handleMessage(messageType, m_curMsgPos > xs::MESSAGE_HEADER_SIZE ? &m_curMsgBuf[xs::MESSAGE_HEADER… in run()307 m_curMsgPos = 0; in run()313 size_t bytesToRecv = curSize-m_curMsgPos; in run()320 result = m_socket.receive(&m_curMsgBuf[m_curMsgPos], bytesToRecv, &numRecv); in run()338 m_curMsgPos += numRecv; in run()
113 size_t m_curMsgPos; member in xe::TcpIpRecvThread