Модераторы: Daevaorn
  

Поиск:

Ответ в темуСоздание новой темы Создание опроса
> Алгоритм удаления клиента IOCP 
V
    Опции темы
REZiaMIX
Дата 17.11.2009, 12:39 (ссылка) | (нет голосов) Загрузка ... Загрузка ... Быстрая цитата Цитата


Опытный
**


Профиль
Группа: Участник
Сообщений: 346
Регистрация: 3.11.2007

Репутация: нет
Всего: 4



Столкнулся со следюущей проблемой:
Пул потоков: допустим два потока(> 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) уже начал принимать новый буффер от отключаемого клиента и обращается к методам по уже несуществующему объекту(указатель то уже невалиден)

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


Это сообщение отредактировал(а) REZiaMIX - 17.11.2009, 12:45


--------------------
user posted image
PM MAIL   Вверх
xvr
Дата 17.11.2009, 14:53 (ссылка) | (нет голосов) Загрузка ... Загрузка ... Быстрая цитата Цитата


Эксперт
****


Профиль
Группа: Комодератор
Сообщений: 7046
Регистрация: 28.8.2007
Где: Дублин, Ирландия

Репутация: 60
Всего: 223



В каждом клиенте сделать счетчик 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 на клиента)

PM MAIL   Вверх
REZiaMIX
Дата 17.11.2009, 15:04 (ссылка) | (нет голосов) Загрузка ... Загрузка ... Быстрая цитата Цитата


Опытный
**


Профиль
Группа: Участник
Сообщений: 346
Регистрация: 3.11.2007

Репутация: нет
Всего: 4



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


--------------------
user posted image
PM MAIL   Вверх
  
Ответ в темуСоздание новой темы Создание опроса
Правила форума "С++:Общие вопросы"
Earnest Daevaorn

Добро пожаловать!

  • Черновик стандарта C++ (за октябрь 2005) можно скачать с этого сайта. Прямая ссылка на файл черновика(4.4мб).
  • Черновик стандарта C (за сентябрь 2005) можно скачать с этого сайта. Прямая ссылка на файл черновика (3.4мб).
  • Прежде чем задать вопрос, прочтите это и/или это!
  • Здесь хранится весь мировой запас ссылок на документы, связанные с C++ :)
  • Не брезгуйте пользоваться тегами [code=cpp][/code].
  • Пожалуйста, не просите написать за вас программы в этом разделе - для этого существует "Центр Помощи".
  • C++ FAQ

Если Вам понравилась атмосфера форума, заходите к нам чаще! С уважением, Earnest Daevaorn

 
0 Пользователей читают эту тему (0 Гостей и 0 Скрытых Пользователей)
0 Пользователей:
« Предыдущая тема | C/C++: Общие вопросы | Следующая тема »


 




[ Время генерации скрипта: 0.0509 ]   [ Использовано запросов: 22 ]   [ GZIP включён ]


Реклама на сайте     Информационное спонсорство

 
По вопросам размещения рекламы пишите на vladimir(sobaka)vingrad.ru
Отказ от ответственности     Powered by Invision Power Board(R) 1.3 © 2003  IPS, Inc.