diff options
| author | venkita <venkita@ae88bc3d-4319-0410-8dbf-d08b4c9d3795> | 2003-10-02 12:43:10 +0000 |
|---|---|---|
| committer | venkita <venkita@ae88bc3d-4319-0410-8dbf-d08b4c9d3795> | 2003-10-02 12:43:10 +0000 |
| commit | a8e1f2fbb48834dfe55c24bb54bc4acc92e9edc6 (patch) | |
| tree | 35ce4c242ef9cb6214b91d196c383206bd7572f9 /Kokyu/Dispatcher_Task.cpp | |
| parent | 22a4746dc5e97c300223d2ea1f48a325e83edccb (diff) | |
| download | ATCD-a8e1f2fbb48834dfe55c24bb54bc4acc92e9edc6.tar.gz | |
ChangeLogTag: Thu Oct 2 07:33:07 2003 Venkita Subramonian <venkita@cs.wustl.edu>
Diffstat (limited to 'Kokyu/Dispatcher_Task.cpp')
| -rw-r--r-- | Kokyu/Dispatcher_Task.cpp | 9 |
1 files changed, 6 insertions, 3 deletions
diff --git a/Kokyu/Dispatcher_Task.cpp b/Kokyu/Dispatcher_Task.cpp index 19ae12a3fa8..28ac43452ca 100644 --- a/Kokyu/Dispatcher_Task.cpp +++ b/Kokyu/Dispatcher_Task.cpp @@ -73,7 +73,7 @@ Dispatcher_Task::svc (void) -1); } - ACE_DEBUG ((LM_DEBUG, "(%t) Dispatcher Thread started prio=%d\n", prio)); + //ACE_DEBUG ((LM_DEBUG, "(%t) Dispatcher Thread started prio=%d\n", prio)); while (!done) { @@ -85,6 +85,8 @@ Dispatcher_Task::svc (void) ACE_ERROR ((LM_ERROR, "EC (%P|%t) getq error in Dispatching Queue\n")); + //ACE_DEBUG ((LM_DEBUG, "(%t) : next command got from queue\n")); + Dispatch_Queue_Item *qitem = ACE_dynamic_cast(Dispatch_Queue_Item*, mb); @@ -125,11 +127,12 @@ Dispatcher_Task::enqueue (const Dispatch_Command* cmd, ACE_Message_Block *mb = new (buf) Dispatch_Queue_Item (cmd, qos_info, - this->data_block_.duplicate (), + &(this->data_block_), + ACE_Message_Block::DONT_DELETE, this->allocator_); this->putq (mb); - + return 0; } |