Модераторы: Partizan, gambit
  

Поиск:

Ответ в темуСоздание новой темы Создание опроса
> проблемы с таймерами, останавливаются, хотя были взведены 
:(
    Опции темы
Zhenyok
Дата 18.12.2007, 08:51 (ссылка) | (нет голосов) Загрузка ... Загрузка ... Быстрая цитата Цитата


Новичок



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

Репутация: нет
Всего: нет
Доброго времени суток. Пишу сервер на c#(многопоточный, общается через TCP с драйверами), столкнулся с такой проблемой: остановливаются таймеры(System.Timers), то один ,то другой, то через пару часов, то через месяц.   smile. Думал что проблемы в исчерпании пула системных потоков-нет, все нормально, потоков хватает, а таймер останавливается
Вот код таймеров посылки тестовых команд драйверам(у них AutoReset = true)
Код

private void TestCommandTimerCallback(object source, ElapsedEventArgs e)
{
SendTestCommand();
}

в SendTestCommand() выполняется socket.BeginSend

код таймера для работы с ключем AutoReset = false
Код

private void haspTimer_Elapsed(object sender, System.Timers.ElapsedEventArgs e)
{
    haspTimer.Stop();
    CheckHaspStatus();
    haspTimer.Start();
}

где CheckHaspStatus() проверяет состояние ключа. 
Все вроде безобидно, но в чем дело - никак не пойму smile 

Думал что еще виноват GC, он приостанивливает на время чистки, так нет, делал тесты заполнял все кучи, GC с
ума сходил, но все работало, да и по логам ситуация другая(сообщения сбиваются, таймеры время пропускают, очередь смешивается)
В моей же ситуации все четко, просто таймер останавливается.

Еще подозрения падали на загруженность процессора - тоже не то(делал тесты)
Общих ресурсов нет, deadlock-а тоже.

Главное не на всех машинах падает, а только на сервере фирмы smile !!!!
Может из-за конфигурации системы, или hyper threading-а
Приложение компилировалось на MSVS2003, на сервере стоит framework 1
Может кто знает в чем причина подскажите хоть в какую сторону рыть, а то уже голова скоро лопнет smile 
PM MAIL   Вверх
tol05
Дата 18.12.2007, 12:05 (ссылка) | (нет голосов) Загрузка ... Загрузка ... Быстрая цитата Цитата


Эксперт
***


Профиль
Группа: Участник Клуба
Сообщений: 1632
Регистрация: 21.12.2006
Где: Харьков

Репутация: 63
Всего: 170
Socket.EndSend() когда вызывается?

И код давай сюда. Иначе никто не ответит.


--------------------
На хорошей работе и сны хорошие снятся.
PM MAIL   Вверх
Zhenyok
Дата 18.12.2007, 14:07 (ссылка) | (нет голосов) Загрузка ... Загрузка ... Быстрая цитата Цитата


Новичок



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

Репутация: нет
Всего: нет
вот метод
Код

private void SendTestCommand()
        {
            if(!isSocketClosed)
            {
            
                byte[]        command     = new byte[6];
                DateTime    time     = DateTime.Now;
                command[0] = (byte)time.Minute;
                command[1] = (byte)time.Second;
                command[2] = BitConverter.GetBytes(528)[0];
                command[3] = BitConverter.GetBytes(528)[1];
                try
                {
                    socket.BeginSend(command,0,command.Length,SocketFlags.None,new AsyncCallback(SendCallBack),socket);            Log.AddInfo(this.ToString()+": Begin send test command");
                
                }
                catch(Exception ex)
                {
                    Log.Add(this.ToString()+ex.ToString());
                    CloseSocket();
                }
            }
        }

а вот метод SendCallBack
Код



private void SendCallBack(IAsyncResult ar)
        {
            try
            {
                Socket soc = (Socket)ar.AsyncState;
                if (soc.Connected)
                {
                    int byteSend = soc.EndSend(ar);
                    Log.AddInfo(this.ToString() + ": End send test command");
                }
                else
                {

                    Log.Add("SendCallback SOCKET " + this.ToString() + " not connected");
                    CloseSocket();
                }

            }
            catch (SocketException ex)
            {
                Log.Add("SendCallback " +this.ToString()+ ex.ToString());
                CloseSocket();
            }
            catch (System.Exception ex)
            {
                Log.Add(ex.StackTrace);
                Log.Add("SendCallback " +this.ToString()+ ex.ToString());

            }

        }


Вот функции приема данных
Код

    private void BeginRecieve() 
        {
            try 
            {
                StateObject state = new StateObject();
                socket.BeginReceive(state.buffer,0,StateObject.BUFFER_SIZE,SocketFlags.None,new AsyncCallback(ReceiveCallback),state);
            
            }
            catch(Exception ex) 
            {
                Log.Add(this.ToString()+ex.ToString());
                CloseSocket();
            }
            
        }
        

        private void ReceiveCallback(IAsyncResult ar) 
        {
            if( isDisposed || isSocketClosed || !socket.Connected )
            {
                return; 
            }
            
            try 
            {
                controlTimer.Stop();
                StateObject state = (StateObject)ar.AsyncState;
                int byteRead = socket.EndReceive(ar);
                if(byteRead > 0) 
                {
                    byte[] response = new byte[byteRead];
                    Array.Copy(state.buffer, response, byteRead);
                    RaiseMessageEvent(response);                
                }
                else
                {
                    SendTestCommand();
                } 
                if(!isSocketClosed)
                {
                        socket.BeginReceive(state.buffer,0,StateObject.BUFFER_SIZE,SocketFlags.None,new AsyncCallback(ReceiveCallback),state);
                       
                }
                
            } 
            catch(Exception ex)
            {
                Log.Add(this.ToString()+ex.ToString());
                CloseSocket();
            }
        }


вот методы чтения и записи в сокет

Добавлено через 35 секунд
все что есть
PM MAIL   Вверх
ivashkanet
Дата 18.12.2007, 14:11 (ссылка) | (нет голосов) Загрузка ... Загрузка ... Быстрая цитата Цитата


Кодю потиху
****


Профиль
Группа: Участник Клуба
Сообщений: 3684
Регистрация: 23.2.2006
Где: Гомель, Беларусь

Репутация: 47
Всего: 149
Цитата(Zhenyok @  18.12.2007,  08:51 Найти цитируемый пост)
    haspTimer.Stop();
   CheckHaspStatus();
    haspTimer.Start();

А эксепшин не может здесь выскочить?


--------------------
design, simplicity, and experience with a technology focus
PM MAIL WWW ICQ   Вверх
Zhenyok
Дата 18.12.2007, 14:58 (ссылка) | (нет голосов) Загрузка ... Загрузка ... Быстрая цитата Цитата


Новичок



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

Репутация: нет
Всего: нет
была такая теория, тестировал порождением нового exception, бесполезно, проглатывает его, т.к. метод выполняется в системном потоке.
Но теория не подтвердилась
PM MAIL   Вверх
tol05
Дата 18.12.2007, 15:44 (ссылка) | (нет голосов) Загрузка ... Загрузка ... Быстрая цитата Цитата


Эксперт
***


Профиль
Группа: Участник Клуба
Сообщений: 1632
Регистрация: 21.12.2006
Где: Харьков

Репутация: 63
Всего: 170
ИМХО если просто останавливаются таймеры, то это значит, что их в очередной раз просто не запустили. Поэтому я согласен с ivashkanet
 (ivashkanet, блин, твой новый аватар просто крышу рвет)

smile 

Нужно искать в CheckHaspStatus()

Значит все-таки в ней валится...

Цитата(Zhenyok @  18.12.2007,  07:51 Найти цитируемый пост)
то через пару часов, то через месяц



Это сообщение отредактировал(а) tol05 - 18.12.2007, 15:45


--------------------
На хорошей работе и сны хорошие снятся.
PM MAIL   Вверх
Zhenyok
Дата 18.12.2007, 16:32 (ссылка) | (нет голосов) Загрузка ... Загрузка ... Быстрая цитата Цитата


Новичок



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

Репутация: нет
Всего: нет
вот лог, где ясно видно, что haspTimer был взведен, но не выполнтлся, а функция отработала корректно
8:17:21.62 TestCommandTimerCallback work 24 all 1000
8:17:21.62 SOCKET 0: TestCommand timer elapsed
8:17:21.62 SOCKET 0: Begin send test command
8:17:21.62 SOCKET 0: SendTestCommand called
8:17:21.62 SOCKET 0: End send test command
8:17:21.62 TestCommandTimerCallback work 24 all 1000
8:17:21.62 SOCKET 1: TestCommand timer elapsed
8:17:21.62 SOCKET 1: Begin send test command
8:17:21.62 SOCKET 1: SendTestCommand called
8:17:21.62 SOCKET 1: End send test command
8:17:21.62 TestCommandTimerCallback work 24 all 1000
8:17:21.62 SOCKET 2: TestCommand timer elapsed
8:17:21.62 SOCKET 2: Begin send test command
8:17:21.62 SOCKET 2: SendTestCommand called
8:17:21.62 SOCKET 2: End send test command
8:17:21.62 ReceiveCallback work 25 all 999
8:17:21.62 ReceiveCallback work 25 all 999
8:17:21.78 haspTimer_Elapsed start    haspTimerStoped = False
8:17:21.78 HaspTimer.Stop()  haspTimerStoped = False
8:17:21.78 work 24 all 1000
8:17:21.78 Hasp status: 1 StatusOk
8:17:21.109 ReceiveCallback work 24 all 999
8:17:21.125 Hasp status: 2 StatusOk
8:17:21.125 Hasp status: 3 StatusOk
8:17:21.140 Hasp status: 4 StatusOk
8:17:21.140 Hasp status 5 : StatusOk
8:17:21.140 Hasp status: 6 StatusOk
8:17:21.140 Hasp status: 7 StatusOk
8:17:21.140  hasp return True
8:17:21.140 CheckHaspStatus()1 = true  buffermanStopedByHasp =  False
8:17:21.140 End HaspTimer_Elapsed    haspTimer.Enabled = True
14.12.2007 
8:17:22.125 ReceiveCallback work 25 all 999
8:17:22.125 ReceiveCallback work 25 all 999
8:17:22.125 TestCommandTimerCallback work 24 all 1000
8:17:22.125 SOCKET 0: TestCommand timer elapsed
8:17:22.125 SOCKET 0: Begin send test command
8:17:22.125 SOCKET 0: SendTestCommand called
8:17:22.125 SOCKET 0: End send test command
8:17:22.125 TestCommandTimerCallback work 24 all 1000
8:17:22.125 SOCKET 1: TestCommand timer elapsed
8:17:22.125 SOCKET 1: Begin send test command
8:17:22.125 SOCKET 1: SendTestCommand called
8:17:22.125 SOCKET 1: End send test command
8:17:22.125 TestCommandTimerCallback work 24 all 1000
8:17:22.125 SOCKET 2: TestCommand timer elapsed
8:17:22.140 SOCKET 2: Begin send test command
8:17:22.140 SOCKET 2: SendTestCommand called
8:17:22.140 SOCKET 2: End send test command
8:17:22.140 haspTimer_Elapsed start    haspTimerStoped = False
8:17:22.140 HaspTimer.Stop()  haspTimerStoped = False
8:17:22.140 work 24 all 1000
8:17:22.140 Hasp status: 1 StatusOk
8:17:22.140 ReceiveCallback work 24 all 999
8:17:22.187 Hasp status: 2 StatusOk
8:17:22.187 Hasp status: 3 StatusOk
8:17:22.203 Hasp status: 4 StatusOk
8:17:22.203 Hasp status 5 : StatusOk
8:17:22.203 Hasp status: 6 StatusOk
8:17:22.203 Hasp status: 7 StatusOk
8:17:22.203  hasp return True
8:17:22.203 CheckHaspStatus()1 = true  buffermanStopedByHasp =  False
8:17:22.203 End HaspTimer_Elapsed    haspTimer.Enabled = True
14.12.2007 
8:17:23.140 ReceiveCallback work 25 all 999
8:17:23.140 ReceiveCallback work 25 all 999
8:17:23.140 TestCommandTimerCallback work 24 all 1000
8:17:23.140 SOCKET 0: TestCommand timer elapsed
8:17:23.140 SOCKET 0: Begin send test command
8:17:23.140 SOCKET 0: SendTestCommand called
8:17:23.140 SOCKET 0: End send test command
8:17:23.140 TestCommandTimerCallback work 24 all 1000
8:17:23.140 SOCKET 1: TestCommand timer elapsed
8:17:23.140 SOCKET 1: Begin send test command
8:17:23.140 SOCKET 1: SendTestCommand called
8:17:23.140 SOCKET 1: End send test command
8:17:23.140 TestCommandTimerCallback work 24 all 1000
8:17:23.140 SOCKET 2: TestCommand timer elapsed
8:17:23.140 SOCKET 2: Begin send test command
8:17:23.140 SOCKET 2: SendTestCommand called
8:17:23.203 SOCKET 2: End send test command
8:17:23.218 ReceiveCallback work 25 all 999

14.12.2007 
8:17:24.156 TestCommandTimerCallback work 24 all 1000
8:17:24.156 SOCKET 0: TestCommand timer elapsed
8:17:24.156 SOCKET 0: Begin send test command
8:17:24.156 SOCKET 0: SendTestCommand called
8:17:24.156 SOCKET 0: End send test command
8:17:24.156 TestCommandTimerCallback work 24 all 1000
8:17:24.156 SOCKET 1: TestCommand timer elapsed
8:17:24.156 SOCKET 1: Begin send test command
8:17:24.156 SOCKET 1: SendTestCommand called
8:17:24.156 SOCKET 1: End send test command
8:17:24.156 TestCommandTimerCallback work 24 all 1000
8:17:24.156 SOCKET 2: TestCommand timer elapsed
8:17:24.156 SOCKET 2: Begin send test command
8:17:24.156 SOCKET 2: SendTestCommand called
8:17:24.156 SOCKET 2: End send test command
8:17:24.156 ReceiveCallback work 25 all 999
8:17:24.156 ReceiveCallback work 25 all 999
8:17:24.281 ReceiveCallback work 25 all 999 



я бы понял если там исключение, так нет же, не вылетает !!!
PM MAIL   Вверх
mr.DUDA
Дата 19.12.2007, 15:45 (ссылка) | (нет голосов) Загрузка ... Загрузка ... Быстрая цитата Цитата


3D-маньяк
****


Профиль
Группа: Экс. модератор
Сообщений: 8244
Регистрация: 27.7.2003
Где: город-герой Минск

Репутация: 110
Всего: 232
В крайнем случае можно вместо Start/Stop попробовать юзать булевский флаг:
Код
bool _ignoreTimerElapsed = false;

private void haspTimer_Elapsed(object sender, System.Timers.ElapsedEventArgs e)
{
    if(_ignoreTimerElapsed) return;

    _ignoreTimerElapsed = true;
    try
    {
        CheckHaspStatus();
    }
    finally { _ignoreTimerElapsed = false; }
}


Вообще не очень понятно, почему используется Start/Stop и почему AutoReset=true...


--------------------
user posted image
PM MAIL WWW   Вверх
Zhenyok
Дата 20.12.2007, 08:42 (ссылка) | (нет голосов) Загрузка ... Загрузка ... Быстрая цитата Цитата


Новичок



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

Репутация: нет
Всего: нет
флаг можно использовать-не вопрос, я пытаюсь понять почему таймер в следующую секунду не запустился, хотя при выходе из haspTimer_Elapsed hasrTimer.Enabled = true, т.е. оп определению он должен сработать!!! А он не сработал. Есть ли какие-нить предпосылки для этого? Дело в системе или коде? Почему тогда на некоторых компах работает всегда, а на некоторых падает
PM MAIL   Вверх
mr.DUDA
Дата 20.12.2007, 10:29 (ссылка) | (нет голосов) Загрузка ... Загрузка ... Быстрая цитата Цитата


3D-маньяк
****


Профиль
Группа: Экс. модератор
Сообщений: 8244
Регистрация: 27.7.2003
Где: город-герой Минск

Репутация: 110
Всего: 232
Код странный. Во-первых, несколько обработчиков Elapsed могут выполниться одновременно т.к. таймер использует пул потоков для генерации события Elapsed. Во-вторых, AutoReset говорит о том что Elapsed будет выкинут 1 раз после Start. В-третьих, Start/Stop в каждом обработчике Elapsed... Наконец, не мешало бы поставить try..catch на метод CheckHaspStatus.


--------------------
user posted image
PM MAIL WWW   Вверх
  
 Ответ в темуСоздание новой темы Создание опроса
Прежде чем создать тему, посмотрите сюда:
mr.DUDA
THandle
Используйте теги [code=csharp][/code] для подсветки кода. Используйтe чекбокс "транслит" если у Вас нет русских шрифтов.
Что делать если Вам помогли, но отблагодарить помощника плюсом в репутацию Вы не можете(не хватает сообщений)? Пишите сюда, или отправляйте репорт. Поставим :)
Так же не забывайте отмечать свой вопрос решенным, если он таковым является :)

Если Вам понравилась атмосфера форума, заходите к нам чаще! С уважением, mr.DUDA, THandle.
 
0 Пользователей читают эту тему (0 Гостей и 0 Скрытых Пользователей)
0 Пользователей:
« Предыдущая тема | Общие вопросы по .NET и C# | Следующая тема »

Подписаться на тему | Подписка на этот форум | Скачать/Распечатать тему


 




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


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

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