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 | b6440dd88e8f74694fd79924593edaf90f40a51a (patch) | |
tree | 35ce4c242ef9cb6214b91d196c383206bd7572f9 /Kokyu/Dispatcher_Task.cpp | |
parent | 08ec73bb222689386ac234e7dd53631515691394 (diff) | |
download | ATCD-b6440dd88e8f74694fd79924593edaf90f40a51a.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; } |