Форум программистов [Powered by Invision Power Board]

Версия для печати темы
Нажмите сюда для просмотра этой темы в оригинальном формате

Форум программистов > C/C++: Общие вопросы > Алгоритм удаления клиента IOCP

Автор: REZiaMIX 17.11.2009, 12:39

Столкнулся со следюущей проблемой:
Пул потоков: допустим два потока(> 1)
Идет прием пакетов , без особой обработки.
Если в пришедшем буффере первый символ '*'

Код


if(Buffer[0] == '*')

Тогда начинаем массовую рассылку всем клиентам сервера буффера "Broadcast!"(не суть)
В процедуре массовой рассылки:

Код


nSent = WSASend(Client->GetSocket(), Client->GetWBufPtr(), 1, 
                    &dwBytes, dwFlags, ClientList->GetOvpPtr(), NULL);

                if (( nSent == SOCKET_ERROR) && (WSAGetLastError() != WSA_IO_PENDING))
                    RemoveClient(Client);

Где RemoveClient - процедура удаления из списка клиентов(вектор) с необходимой защитой критическими секциями.

Объект Client создается при подключении:

Код


CClientContext   * ClientContext  = new CClientContext;

Процедура RemoveClient:

Код


ClientList.erasebyptr(_Client);
delete _Client;

И вот , при массовой рассылке происходит ошибка отправки(клиент резко отключился!) , Client удаляется из вектора , и удаляется delet'ом.
Но в это время(поток2) уже начал принимать новый буффер от отключаемого клиента и обращается к методам по уже несуществующему объекту(указатель то уже невалиден)

Каким образом синхронизировать всю эту чепуху?
Пока в голову приходит только блокировать массив(или его части, несколькими крит.секциями) клиентов при начале любой обработки в потоке?

Автор: xvr 17.11.2009, 14:53

В каждом клиенте сделать счетчик InUse, который должен считать количество потоков, в которых для данного клиента что то сейчас делается. Так же вводится флаг DeletePending, который говорит, что при общении с клиентом произошла ошибка.
Добавляется 2 процедуры и изменяется RemoveClient:

Код


void CClientContext::Start()
{
 LockCriticalSection();
 ++InUse;
 UnlockCriticalSection();
}

void CClientContext::End()
{
 LockCriticalSection();
 --InUse;
 if (!InUse && DeletePending)
  {
   ClientList.erasebyptr(this);
   delete this;
  }
 UnlockCriticalSection();
}

void CClientContext::RemoveClient()
{
 LockCriticalSection();
 if (InUse) DeletePending=true; else
  {
   ClientList.erasebyptr(this);
   delete this;
  }
 UnlockCriticalSection();
}

Процедуры Start & End вызываются перед и после любой работы с клиентом (можно их обвернуть в smart pointer на клиента)

Автор: REZiaMIX 17.11.2009, 15:04

Спасибо , очень понравилось такое решение smile