diff options
Diffstat (limited to 'TAO/CIAO/tools/Config_Handlers/RT-CCM/OR_Handler.cpp')
| -rw-r--r-- | TAO/CIAO/tools/Config_Handlers/RT-CCM/OR_Handler.cpp | 148 |
1 files changed, 74 insertions, 74 deletions
diff --git a/TAO/CIAO/tools/Config_Handlers/RT-CCM/OR_Handler.cpp b/TAO/CIAO/tools/Config_Handlers/RT-CCM/OR_Handler.cpp index d7c750d07cd..5fd8a1b32ff 100644 --- a/TAO/CIAO/tools/Config_Handlers/RT-CCM/OR_Handler.cpp +++ b/TAO/CIAO/tools/Config_Handlers/RT-CCM/OR_Handler.cpp @@ -9,84 +9,84 @@ namespace CIAO { - namespace Config_Handlers + namespace Config_Handlers + { + bool OR_Handler::orb_resources (const ORBResources &src, + ::CIAO::DAnCE::ORBResources &dest) { - bool OR_Handler::orb_resources (const ORBResources &src, - ::CIAO::DAnCE::ORBResources &dest) - { - // We know that there should be only one. - dest.length (1); - - // Set the length of the threadpools - CORBA::ULong pos (dest[0].threadpool_list.length ()); - dest[0].threadpool_list.length (pos + src.count_threadpool ()); - - for (ORBResources::threadpool_const_iterator i = src.begin_threadpool (); - i != src.end_threadpool (); - ++i) - { - TP_Handler::thread_pool (*i, - dest[0].threadpool_list[pos++]); - } - - pos = dest[0].threadpool_with_lanes_list.length (); - dest[0].threadpool_with_lanes_list.length (pos + src.count_threadpoolWithLanes ()); + // We know that there should be only one. + dest.length (1); - for (ORBResources::threadpoolWithLanes_const_iterator j = src.begin_threadpoolWithLanes(); - j != src.end_threadpoolWithLanes(); - j++) - { - TPL_Handler::threadpool_with_lanes (*j, - dest[0].threadpool_with_lanes_list [pos++]); - } + // Set the length of the threadpools + CORBA::ULong pos (dest[0].threadpool_list.length ()); + dest[0].threadpool_list.length (pos + src.count_threadpool ()); - pos = dest[0].connection_bands_list.length (); - dest[0].connection_bands_list.length (pos + src.count_connectionBands ()); + for (ORBResources::threadpool_const_iterator i = src.begin_threadpool (); + i != src.end_threadpool (); + ++i) + { + TP_Handler::thread_pool (*i, + dest[0].threadpool_list[pos++]); + } - for (ORBResources::connectionBands_const_iterator k = src.begin_connectionBands(); - k != src.end_connectionBands(); - k++) - { - CB_Handler::connection_band (*k, - dest[0].connection_bands_list[pos++]); - } - return true; - } + pos = dest[0].threadpool_with_lanes_list.length (); + dest[0].threadpool_with_lanes_list.length (pos + src.count_threadpoolWithLanes ()); - ORBResources OR_Handler::orb_resources (const ::CIAO::DAnCE::ORBResources &src) - throw (OR_Handler::No_Resource) - { - if (src.length () == 0 || - src[0].threadpool_list.length () == 0 || - src[0].threadpool_with_lanes_list.length () == 0 || - src[0].connection_bands_list.length () == 0) - { - throw No_Resource (); - } - - size_t len; //For checking the length of sequences - - ORBResources ores; - - len = src[0].threadpool_list.length(); - for(size_t i = 0; i < len; ++i) - { - ores.add_threadpool (TP_Handler::thread_pool (src[0].threadpool_list[i])); - } - - len = src[0].threadpool_with_lanes_list.length(); - for(size_t j = 0; j < len; ++j) - { - ores.add_threadpoolWithLanes(TPL_Handler::threadpool_with_lanes (src[0].threadpool_with_lanes_list[j])); - } - - len = src[0].connection_bands_list.length(); - for(size_t k = 0; k < len; k++) - { - ores.add_connectionBands (CB_Handler::connection_band (src[0].connection_bands_list[k])); - } - - return ores; - } + for (ORBResources::threadpoolWithLanes_const_iterator j = src.begin_threadpoolWithLanes(); + j != src.end_threadpoolWithLanes(); + j++) + { + TPL_Handler::threadpool_with_lanes (*j, + dest[0].threadpool_with_lanes_list [pos++]); + } + + pos = dest[0].connection_bands_list.length (); + dest[0].connection_bands_list.length (pos + src.count_connectionBands ()); + + for (ORBResources::connectionBands_const_iterator k = src.begin_connectionBands(); + k != src.end_connectionBands(); + k++) + { + CB_Handler::connection_band (*k, + dest[0].connection_bands_list[pos++]); + } + return true; + } + + ORBResources OR_Handler::orb_resources (const ::CIAO::DAnCE::ORBResources &src) + throw (OR_Handler::No_Resource) + { + if (src.length () == 0 || + src[0].threadpool_list.length () == 0 || + src[0].threadpool_with_lanes_list.length () == 0 || + src[0].connection_bands_list.length () == 0) + { + throw No_Resource (); + } + + size_t len; //For checking the length of sequences + + ORBResources ores; + + len = src[0].threadpool_list.length(); + for(size_t i = 0; i < len; ++i) + { + ores.add_threadpool (TP_Handler::thread_pool (src[0].threadpool_list[i])); + } + + len = src[0].threadpool_with_lanes_list.length(); + for(size_t j = 0; j < len; ++j) + { + ores.add_threadpoolWithLanes(TPL_Handler::threadpool_with_lanes (src[0].threadpool_with_lanes_list[j])); + } + + len = src[0].connection_bands_list.length(); + for(size_t k = 0; k < len; k++) + { + ores.add_connectionBands (CB_Handler::connection_band (src[0].connection_bands_list[k])); + } + + return ores; } + } } |