Searched refs:sessionBuff (Results 1 – 4 of 4) sorted by relevance
295 std::shared_ptr<BufferObject> sessionBuff = sessionObject->GetSessionBuff(); in MoveTransData2Buffer() local296 if (sessionBuff == nullptr) { in MoveTransData2Buffer()305 char *sendBuffer = sessionBuff->GetSendBufferAndLock(sendSize); in MoveTransData2Buffer()312 sessionBuff->UpdateSendBuffer(sendSize); in MoveTransData2Buffer()313 ssize_t writeCursor = sessionBuff->GetSendBufferWriteCursor(); in MoveTransData2Buffer()314 ssize_t readCursor = sessionBuff->GetSendBufferReadCursor(); in MoveTransData2Buffer()317 sessionBuff->ReleaseSendBufferLock(); in MoveTransData2Buffer()324 sessionBuff->ReleaseSendBufferLock(); in MoveTransData2Buffer()330 sessionBuff->SetSendBufferWriteCursor(writeCursor); in MoveTransData2Buffer()331 sessionBuff->SetSendBufferReadCursor(readCursor); in MoveTransData2Buffer()[all …]
75 int SendData(std::shared_ptr<BufferObject> sessionBuff, int32_t socketId);
344 std::shared_ptr<BufferObject> sessionBuff = sessionOfPeer->GetSessionBuff(); in OnSendMessage() local345 if (sessionBuff == nullptr) { in OnSendMessage()350 return SendData(sessionBuff, socketId); in OnSendMessage()362 ssize_t writeCursor = sessionBuff->GetSendBufferWriteCursor(); in SendData()363 ssize_t readCursor = sessionBuff->GetSendBufferReadCursor(); in SendData()367 sessionBuff->ReleaseSendBufferLock(); in SendData()373 sessionBuff->ReleaseSendBufferLock(); in SendData()384 sessionBuff->ReleaseSendBufferLock(); in SendData()389 sessionBuff->SetSendBufferReadCursor(readCursor); in SendData()390 sessionBuff->SetSendBufferWriteCursor(writeCursor); in SendData()[all …]
787 std::shared_ptr<BufferObject> sessionBuff = std::make_shared<BufferObject>(); variable788 sessionBuff->sendBufferCursorW_ = 8;789 sessionBuff->sendBufferCursorR_ = 7;790 sessionBuff->sendBuffSize_ = SOCKET_BUFF_RESERVED_SIZE;792 sessionBuff->sendBuffer_ = buff;794 sessionOfPeer->buff_ = sessionBuff;