diff options
author | bala <bala@ae88bc3d-4319-0410-8dbf-d08b4c9d3795> | 2003-05-23 10:56:16 +0000 |
---|---|---|
committer | bala <bala@ae88bc3d-4319-0410-8dbf-d08b4c9d3795> | 2003-05-23 10:56:16 +0000 |
commit | 54b5d7013eb54a35f363546f39d0c754e1d6da5e (patch) | |
tree | 62de5ed04a03da9964d849ac3a10ad05c0cf10d9 /TAO/tao/Acceptor_Impl.cpp | |
parent | 1ec171123fa7d5548542694a53ef251aa89108a0 (diff) | |
download | ATCD-54b5d7013eb54a35f363546f39d0c754e1d6da5e.tar.gz |
ChangeLogTag:
Diffstat (limited to 'TAO/tao/Acceptor_Impl.cpp')
-rw-r--r-- | TAO/tao/Acceptor_Impl.cpp | 28 |
1 files changed, 19 insertions, 9 deletions
diff --git a/TAO/tao/Acceptor_Impl.cpp b/TAO/tao/Acceptor_Impl.cpp index 2307b027175..d290d2f4157 100644 --- a/TAO/tao/Acceptor_Impl.cpp +++ b/TAO/tao/Acceptor_Impl.cpp @@ -25,13 +25,14 @@ # pragma once #endif /* ACE_LACKS_PRAGMA_ONCE */ -#include "tao/ORB_Core.h" -#include "tao/ORB_Table.h" -#include "tao/Server_Strategy_Factory.h" -#include "tao/Connector_Registry.h" -#include "tao/Transport_Cache_Manager.h" -#include "tao/Thread_Lane_Resources.h" -#include "tao/Transport.h" +#include "ORB_Core.h" +// #include "ORB_Table.h" +#include "Server_Strategy_Factory.h" +// #include "Connector_Registry.h" +#include "Transport_Cache_Manager.h" +#include "Thread_Lane_Resources.h" +#include "Transport.h" +#include "Thread_Per_Connection_Handler.h" #include "ace/Object_Manager.h" @@ -103,8 +104,17 @@ TAO_Concurrency_Strategy<SVC_HANDLER>::activate_svc_handler (SVC_HANDLER *sh, // thread-per-connection concurrency model if (f->activate_server_connections ()) - return sh->activate (f->server_connection_thread_flags (), - f->server_connection_thread_count ()); + { + TAO_Thread_Per_Connection_Handler *tpch = 0; + + ACE_NEW_RETURN (tpch, + TAO_Thread_Per_Connection_Handler (sh), + -1); + + return tpch->activate (f->server_connection_thread_flags (), + f->server_connection_thread_count ()); + } + // reactive concurrency model. We may want to register ourselves // with the reactor. Call the register handler on the transport. |