开通博客赚积分
发布资源赚积分
分类

源码开发语言/平台
当前位置：首页 > 源码/资料 > 中间件编程 > 查看源码
ConnectionManager.cxx
资源名称：blacktie-2.0.0.M3-src.zip　[点击查看]
上传用户：xfwatch
上传日期：2020-12-14
资源大小：872k
文件大小：4k
源码类别：

中间件编程

开发平台：

Java

ConnectionManager.cxx：源码内容
  1. /*
  2.  * JBoss, Home of Professional Open Source
  3.  * Copyright 2008, Red Hat, Inc., and others contributors as indicated
  4.  * by the @authors tag. All rights reserved.
  5.  * See the copyright.txt in the distribution for a
  6.  * full listing of individual contributors.
  7.  * This copyrighted material is made available to anyone wishing to use,
  8.  * modify, copy, or redistribute it subject to the terms and conditions
  9.  * of the GNU Lesser General Public License, v. 2.1.
  10.  * This program is distributed in the hope that it will be useful, but WITHOUT A
  11.  * WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS FOR A
  12.  * PARTICULAR PURPOSE.  See the GNU Lesser General Public License for more details.
  13.  * You should have received a copy of the GNU Lesser General Public License,
  14.  * v.2.1 along with this distribution; if not, write to the Free Software
  15.  * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston,
  16.  * MA  02110-1301, USA.
  17.  */
  19. #include "log4cxx/basicconfigurator.h"
  20. #include "log4cxx/propertyconfigurator.h"
  21. #include "log4cxx/logger.h"
  22. #include "log4cxx/logmanager.h"
  24. #include "AtmiBrokerServer.h"
  25. #include "ConnectionManager.h"
  26. #include "AtmiBrokerEnv.h"
  27. #include "SymbolLoader.h"
  28. #include "xatmi.h"
  30. log4cxx::LoggerPtr loggerConnectionManager(log4cxx::Logger::getLogger(
  31. "ConnectionManager"));
  32. extern char server[30];
  33. extern int serverid;
  35. #ifdef IDE_DEBUG
  36. #include "HybridConnectionImpl.h"
  37. #endif
  38. ConnectionManager::ConnectionManager() {
  39. LOG4CXX_TRACE(loggerConnectionManager, (char*) "constructor");
  40. lock = new SynchronizableObject();
  41. }
  43. ConnectionManager::~ConnectionManager() {
  44. LOG4CXX_TRACE(loggerConnectionManager, (char*) "destructor");
  46. this->closeConnections();
  47. delete lock;
  48. }
  50. void ConnectionManager::closeConnections() {
  51. LOG4CXX_TRACE(loggerConnectionManager, (char*) "closeConnections");
  53. lock->lock();
  54. ConnectionMap::iterator it;
  55. for (it = manager.begin(); it != manager.end(); it++) {
  56. delete (*it).second;
  57. }
  58. manager.clear();
  59. lock->unlock();
  60. }
  62. Connection*
  63. ConnectionManager::getConnection(char* side) {
  64. char* transportLibrary;
  65. char adm[XATMI_SERVICE_NAME_LENGTH + 1];
  66. ACE_OS::snprintf(adm, XATMI_SERVICE_NAME_LENGTH + 1, "%s_ADMIN_%d", server,
  67. serverid);
  69. #ifdef WIN32
  70. transportLibrary = (char*) "atmibroker-hybrid.dll";
  71. #else
  72. transportLibrary = (char*) "libatmibroker-hybrid.so";
  73. #endif
  74. LOG4CXX_DEBUG(loggerConnectionManager, (char*) "transport is " << transportLibrary);
  75. std::string key = side;
  76. key.append("/");
  77. key.append(transportLibrary);
  79. lock->lock();
  80. ConnectionMap::iterator it;
  81. it = manager.find(key);
  83. if (it != manager.end()) {
  84. LOG4CXX_DEBUG(loggerConnectionManager, (char*) "Found Connection in map " << (*it).second);
  85. lock->unlock();
  86. return (*it).second;
  87. } else {
  88. #ifdef IDE_DEBUG
  89. Connection* connection = new HybridConnectionImpl(side);
  90. manager.insert(ConnectionMap::value_type(key, connection));
  91. LOG4CXX_DEBUG(loggerConnectionManager, (char*) "insert service " << key << " connection " << connection);
  92. lock->unlock();
  93. return connection;
  94. #else
  95. connection_factory_t* connectionFactory =
  96. (connection_factory_t*) ::lookup_symbol(transportLibrary,
  97. "connectionFactory");
  98. if (connectionFactory != NULL) {
  99. Connection* connection = connectionFactory->create_connection(side);
  100. manager.insert(ConnectionMap::value_type(key, connection));
  101. LOG4CXX_DEBUG(loggerConnectionManager, (char*) "insert service "
  102. << key << " connection " << connection);
  103. lock->unlock();
  104. return connection;
  105. }
  106. #endif
  107. }
  109. LOG4CXX_WARN(loggerConnectionManager,
  110. (char*) "can not create connection for service " << side);
  111. lock->unlock();
  112. return NULL;
  113. }
  115. Connection*
  116. ConnectionManager::getClientConnection() {
  117. return getConnection((char*) "client");
  118. }
  120. Connection*
  121. ConnectionManager::getServerConnection() {
  122. return getConnection((char*) "server");
  123. }