diff options
| author | parsons <parsons@ae88bc3d-4319-0410-8dbf-d08b4c9d3795> | 2008-08-05 18:52:53 +0000 |
|---|---|---|
| committer | parsons <parsons@ae88bc3d-4319-0410-8dbf-d08b4c9d3795> | 2008-08-05 18:52:53 +0000 |
| commit | 19bf3f820e78f0b5faf978bdc4c09b46ce2e6f8b (patch) | |
| tree | 10f16522edb5de271a413ed9d2c673d20c91c99b /ACE/Kokyu | |
| parent | dd04d852afa0f63b82968fa555b92f6abf1a2e16 (diff) | |
| download | ATCD-19bf3f820e78f0b5faf978bdc4c09b46ce2e6f8b.tar.gz | |
ChangeLogTag: Tue Aug 5 18:51:02 UTC 2008 Jeff Parsons <j.parsons@vanderbilt.edu>
Diffstat (limited to 'ACE/Kokyu')
| -rw-r--r-- | ACE/Kokyu/Dispatcher_Task.cpp | 17 |
1 files changed, 12 insertions, 5 deletions
diff --git a/ACE/Kokyu/Dispatcher_Task.cpp b/ACE/Kokyu/Dispatcher_Task.cpp index 8cbb9cd97ac..c6e1ef9e3ba 100644 --- a/ACE/Kokyu/Dispatcher_Task.cpp +++ b/ACE/Kokyu/Dispatcher_Task.cpp @@ -98,12 +98,19 @@ Dispatcher_Task::svc (void) while (!done) { ACE_Message_Block *mb; + if (this->getq (mb) == -1) - if (ACE_OS::last_error () == ESHUTDOWN) - return 0; - else - ACE_ERROR ((LM_ERROR, - "EC (%P|%t) getq error in Dispatching Queue\n")); + { + if (ACE_OS::last_error () == ESHUTDOWN) + { + return 0; + } + else + { + ACE_ERROR ((LM_ERROR, + "EC (%P|%t) getq error in Dispatching Queue\n")); + } + } //ACE_DEBUG ((LM_DEBUG, "(%t) : next command got from queue\n")); |