인프런 커뮤니티 질문&답변

안녕하세요.

거의 하루종일 보고 있는 문젠데요.

클라이언트에서 에코해줄 때 강사님은 OnRecvCompleted() 함수 안에서 인자로 받은 length가 아니라 sizeof send_buffer를 사용하고 계셔서 오류가 발생 안 했어요.

인자로 받는 length를 해주면 프로그램 구동하고 나서 얼마 안돼서 주고받는 데이터가 영원히 증가합니다. 물론 ASSERT_CRASH가 있기 때문에 메모리 할당해주는 부분에서 결국 멈추긴 합니다.

정확한 이유를 못 찾겠네요. 이리저리 중단점 찍어보는데, 한 가지 확실한 건 서버에서 WSASend() 해주고 클라에서 받을 때 갑자기 데이터 사이즈가 튑니다. 더미 클라에서 세션을 하나만 넣어줘도 재현돼요.

이럴 때 비동기 + 멀티스레드는 정말 헬이네요. ProcessSend()로 들어오는 sendBytes가 갑자기 26, 52..이렇게 되어버립니다. GSendBufferManager에서 반환하는 메모리 위치는 문제가 없어요. 어느 순간 데이터를 미친 듯이 이어 붙입니다.

위 이미지처럼 하나씩만 오고 가야 하는데(Hell, World!)
어느 순간 아래 이미지처럼 확 늘어납니다.

계속 누적돼요. 강사님 코드 거의 그대로입니다.

WSASend() 동작이 중첩됐나까지 의심하게 되네요. 그러나 송신 큐 부분에 락 걸고 이후 코드는 스택 변수라 강사님과 동일하게 진행됩니다.

void Session::RegisterSend()
{
  _send_event.Init();
  _send_event.owner = shared_from_this();

  // 보낼 데이터를 send_event에 등록
  // 레퍼런스 카운트 유지를 위해 SendEvent의 멤버변수를 이용한다
  {
    WRITE_LOCK;
    while (false == _send_queue.empty())
    {
	SharedSendBuffer send_buffer = 
        _send_queue.front();
	_send_queue.pop();
       _send_event.send_buffers.push_back(send_buffer);
     }
   }

  xvector<WSABUF> wsabufs;
  wsabufs.reserve(_send_event.send_buffers.size());
  for (SharedSendBuffer send_buffer : _send_event.send_buffers)
  {
    WSABUF wsabuf;
    wsabuf.buf = reinterpret_cast<char*>(send_buffer->Buffer());
    wsabuf.len = static_cast<LONG>(send_buffer->WriteSize());
  printf("wsabuf len: %d\n", wsabuf.len);
	wsabufs.push_back(wsabuf);
   }

  DWORD send_bytes = 0;

  int32 result = 
WSASend(_socket, wsabufs.data(), static_cast<DWORD>(wsabufs.size()), &send_bytes, 0, &_send_event, nullptr);
  int32 error = WSAGetLastError();
  if (SOCKET_ERROR == result && error != WSA_IO_PENDING)
	{
		HandleError(error);
		// release ref
		_send_event.owner = nullptr;
		_send_event.send_buffers.clear();
		_send_registered.store(false);
		return;
	}
}

 정상적인 에코 서버라면 주고 받는 데이터의 크기가 계속 일정해야 한다고 생각해서 테스트한 건데 고통의 시간을 겪고 있습니다..

참고로 GameSession에서 OnRecv 재정의할 때 1회만 브로드캐스트 해주고 있습니다.

int32 GameSession::OnRecvCompleted(BYTE* buffer, int32 length)
{
	// temp echo
printf("GameSession OnRecvCompleted len: %d\n", length);

SharedSendBuffer send_buffer = g_send_buffer_manager->Open(4096);
memcpy(send_buffer->Buffer(), buffer, length);
send_buffer->Close(length);

	
g_session_manager.Broadcast(send_buffer);	

return length;
}