VPF::Реализация Timeout'a во время получения данных

vaddsm

Дата 30.6.2007, 14:09 (ссылка)

(нет голосов)

Загрузка ...

Шустрый

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

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

Собственно идея такова: я пораждаю поток перед началом цикла приема данных, который следит за тем чтобы переменная таймаута не превышала определенного времени, на каждом шаге цикла приема данных я присваиваю этой переменной настоящее время. Таким образом если будет существенная задержка ожидающий поток попытается закрыть это соединение. Но только попытается в этом то вся и проблема.

Код


use threads;
use threads::shared;

...

Код


my ($s_timeout, $s_opened, $socketno): shared;

...

Код


sub CheckSock($)
{
 my ($stream) = @_;
 my ($sock); 
 while($s_opened == 1)
 { 
  print "while $s_opened\n";    
  if($s_timeout + 20 < time())
  {
   print "closing...\n";
 # ДО ЭТОЙ ТОЧКИ ПРОБЛЕМ НЕ ВОЗНИКАЕТ ЧЕГО ДЕЛАТЬ ЗДЕСТЬ?
 #  if(open($sock, "+<&=$socketno"))
 # {
 #  print $sock "\n\n";    
 #   close($sock);
 #  }    
   $s_opened = -1;
   last;    
  }      
  Time::HiRes::sleep(2);    
 }
 $s_opened = -1;
}

sub setCheckPoint($)
{
 my ($sock) = @_;
 $socketno = fileno($sock);    
 $s_timeout = time();    
 $s_opened = 1;
 threads->new(\&CheckSock, "");    
}

sub closeCheckPoint()
{
 print "closeCheckPoint1\n";    
 if($s_opened != -1)
 {    
  $s_opened = 0;  
  print "set $s_opened\n";
  while($s_opened != -1) {sleep(1);}
 }
 print "closeCheckPoint2\n";
}

...

Код


 setCheckPoint($socket);
 
 while($r = <$socket>)
 { 
  $s_timeout = time();
   #...
 }

  close($socket);
  closeCheckPoint();

Короче, расшарить хандл для потока нельзя, можно только скаляр. поэтому я передаю потоку fileno($sock);
Вопрос, как зная fileno($sock); закрыть соединения?

Каие варианты предложите еще?

Всем спасибо.

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