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

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

中间件编程

开发平台：

Java

AtmiBrokerEnv.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 <stdio.h>
  20. #include <stdlib.h>
  21. #include <string.h>
  22. #include <stdarg.h>
  23. #include <iostream>
  25. #include "userlogc.h"
  26. #include "AtmiBrokerEnv.h"
  27. #include "AtmiBrokerEnvXml.h"
  28. #include "SynchronizableObject.h"
  29. #include "log4cxx/logger.h"
  30. #include "ace/ACE.h"
  31. #include "ace/OS_NS_stdlib.h"
  32. #include "ace/OS_NS_stdio.h"
  33. #include "ace/OS_NS_string.h"
  34. #include "ace/Default_Constants.h"
  36. log4cxx::LoggerPtr loggerAtmiBrokerEnv(log4cxx::Logger::getLogger(
  37. "AtmiBrokerEnv"));
  39. int AtmiBrokerEnv::ENV_VARIABLE_SIZE = 30;
  41. char *AtmiBrokerEnv::ENVIRONMENT_DIR = NULL;
  42. AtmiBrokerEnv *AtmiBrokerEnv::ptrAtmiBrokerEnv = NULL;
  44. char* configuration = NULL;
  45. SynchronizableObject instance_lock;
  46. int referencesAtmiBrokerEnv = 0;
  48. AtmiBrokerEnv * AtmiBrokerEnv::get_instance() {
  49. initializeLogger();
  50. instance_lock.lock();
  51. if (referencesAtmiBrokerEnv == 0) {
  52. if (ptrAtmiBrokerEnv == NULL) {
  53. try {
  54. LOG4CXX_DEBUG(loggerAtmiBrokerEnv,
  55. (char*) "Creating AtmiBrokerEnv");
  56. ptrAtmiBrokerEnv = new AtmiBrokerEnv();
  57. } catch (...) {
  58. instance_lock.unlock();
  59. throw ;
  60. }
  61. } else {
  62. LOG4CXX_WARN(loggerAtmiBrokerEnv,
  63. (char*) "Did not create AtmiBrokerEnv");
  64. }
  65. }
  66. referencesAtmiBrokerEnv++;
  67. LOG4CXX_TRACE(loggerAtmiBrokerEnv,
  68. (char*) "Reference count: " << referencesAtmiBrokerEnv);
  69. instance_lock.unlock();
  70. return ptrAtmiBrokerEnv;
  71. }
  73. void AtmiBrokerEnv::discard_instance() {
  74. instance_lock.lock();
  75. referencesAtmiBrokerEnv--;
  76. LOG4CXX_TRACE(loggerAtmiBrokerEnv, (char*) "Reference count: "
  77. << referencesAtmiBrokerEnv);
  78. if (referencesAtmiBrokerEnv == 0) {
  79. if (ptrAtmiBrokerEnv != NULL) {
  80. try {
  81. LOG4CXX_DEBUG(loggerAtmiBrokerEnv,
  82. (char*) "Deleting AtmiBrokerEnv");
  83. delete ptrAtmiBrokerEnv;
  84. } catch (...) {
  85. instance_lock.unlock();
  86. ptrAtmiBrokerEnv = NULL;
  87. throw ;
  88. }
  89. ptrAtmiBrokerEnv = NULL;
  90. } else {
  91. LOG4CXX_WARN(loggerAtmiBrokerEnv,
  92. (char*) "Did not delete AtmiBrokerEnv");
  93. }
  94. }
  95. instance_lock.unlock();
  96. }
  98. void AtmiBrokerEnv::set_environment_dir(const char* dir) {
  99. if (ENVIRONMENT_DIR != NULL) {
  100. free( ENVIRONMENT_DIR);
  101. ENVIRONMENT_DIR = NULL;
  102. }
  103. if (dir != NULL) {
  104. LOG4CXX_DEBUG(loggerAtmiBrokerEnv,
  105. (char*) "setting configuration dir: " << dir);
  106. ENVIRONMENT_DIR = strdup(dir);
  107. } else {
  108. LOG4CXX_DEBUG(loggerAtmiBrokerEnv,
  109. (char*) "setting configuration to null");
  110. }
  111. }
  113. void AtmiBrokerEnv::set_configuration(const char* dir) {
  114. if (configuration == NULL) {
  115. initializeLogger();
  116. if (dir != NULL) {
  117. LOG4CXX_DEBUG(loggerAtmiBrokerEnv,
  118. (char*) "setting configuration type: " << dir);
  120. configuration = strdup(dir);
  121. } else {
  122. configuration = strdup("");
  123. LOG4CXX_DEBUG(loggerAtmiBrokerEnv,
  124. (char*) "setting configuration to null");
  125. }
  126. }
  127. }
  129. AtmiBrokerEnv::AtmiBrokerEnv() {
  130. LOG4CXX_DEBUG(loggerAtmiBrokerEnv, (char*) "constructor");
  131. readEnvironment = false;
  133. set_environment_dir(ACE_OS::getenv("BLACKTIE_CONFIGURATION_DIR"));
  134. set_configuration(ACE_OS::getenv("BLACKTIE_CONFIGURATION"));
  136. try {
  137. readenv();
  138. } catch (...) {
  139. destroy();
  140. throw ;
  141. }
  142. }
  144. AtmiBrokerEnv::~AtmiBrokerEnv() {
  145. LOG4CXX_DEBUG(loggerAtmiBrokerEnv, (char*) "destructor");
  146. destroy();
  147. }
  149. void AtmiBrokerEnv::destroy() {
  150. LOG4CXX_DEBUG(loggerAtmiBrokerEnv, (char*) "destroy");
  151. for (std::vector<envVar_t>::iterator i = envVariableInfoSeq.begin(); i
  152. != envVariableInfoSeq.end(); i++) {
  153. free((*i).name);
  154. free((*i).value);
  155. }
  157. set_environment_dir( NULL);
  158. if (configuration != NULL) {
  159. free( configuration);
  160. configuration = NULL;
  161. }
  162. envVariableInfoSeq.clear();
  164. //free(namingServiceId);
  165. //free(transFactoryId);
  167. if (xarmp) {
  168. xarmp = xarmp->head;
  170. while (xarmp) {
  171. xarm_config_t * next = xarmp->next;
  173. free(xarmp->resourceName);
  174. free(xarmp->openString);
  175. free(xarmp->closeString);
  176. free(xarmp->xasw);
  177. free(xarmp->xalib);
  179. free( xarmp);
  181. xarmp = next;
  182. }
  183. xarmp = 0;
  184. }
  186. if (servers.size() != 0) {
  187. for (ServersInfo::iterator server = servers.begin(); server
  188. != servers.end(); server++) {
  189. free((*server)->serverName);
  191. std::vector<ServiceInfo>* services = &(*server)->serviceVector;
  192. for (std::vector<ServiceInfo>::iterator i = services->begin(); i
  193. != services->end(); i++) {
  194. free((*i).serviceName);
  195. free((*i).transportLib);
  196. free((*i).function_name);
  197. free((*i).library_name);
  198. }
  199. services->clear();
  201. delete (*server);
  202. }
  203. servers.clear();
  204. }
  206. LOG4CXX_DEBUG(loggerAtmiBrokerEnv, (char*) "free orbConfig");
  207. free(orbConfig.opt);
  208. free(orbConfig.transactionFactoryName);
  209. orbConfig.opt = NULL;
  210. orbConfig.transactionFactoryName = NULL;
  212. LOG4CXX_DEBUG(loggerAtmiBrokerEnv, (char*) "free mqConfig");
  213. free(mqConfig.host);
  214. free(mqConfig.user);
  215. free(mqConfig.pwd);
  216. mqConfig.host = NULL;
  217. mqConfig.user = NULL;
  218. mqConfig.pwd = NULL;
  220. Buffers::iterator it;
  221. for (it = buffers.begin(); it != buffers.end(); ++it) {
  222. Buffer* buffer = it->second;
  223. if (buffer != NULL) {
  224. free(buffer->name);
  225. buffer->name = NULL;
  226. buffer->memSize = -1;
  227. buffer->wireSize = -1;
  229. //std::vector<ServiceInfo>* services = &(*server)->serviceVector;
  230. Attributes::iterator i;
  231. for (i = buffer->attributes.begin(); i != buffer->attributes.end(); ++i) {
  232. Attribute* attribute = i->second;
  233. free(attribute->id);
  234. attribute->id = NULL;
  235. free(attribute->type);
  236. delete attribute;
  237. }
  238. buffer->attributes.clear();
  240. delete buffer;
  241. }
  242. }
  243. buffers.clear();
  245. readEnvironment = false;
  246. }
  248. char*
  249. AtmiBrokerEnv::getTransportLibrary(char* serviceName) {
  250. if (servers.size() != 0) {
  251. for (ServersInfo::iterator server = servers.begin(); server
  252. != servers.end(); server++) {
  253. std::vector<ServiceInfo>* services = &(*server)->serviceVector;
  254. for (std::vector<ServiceInfo>::iterator i = services->begin(); i
  255. != services->end(); i++) {
  256. if (ACE_OS::strncmp((*i).serviceName, serviceName, 15) == 0) {
  257. return (*i).transportLib;
  258. }
  259. }
  260. }
  261. }
  263. return NULL;
  264. }
  266. const char* AtmiBrokerEnv::getenv(const char* anEnvName, const char* defValue) {
  267. LOG4CXX_DEBUG(loggerAtmiBrokerEnv, (char*) "getenv %s" << anEnvName);
  269. char *envValue = ::getenv(anEnvName);
  270. if (envValue != NULL) {
  271. LOG4CXX_DEBUG(loggerAtmiBrokerEnv, (char*) "getenv env is %s"
  272. << envValue);
  273. return envValue;
  274. }
  276. for (std::vector<envVar_t>::iterator i = envVariableInfoSeq.begin(); i
  277. != envVariableInfoSeq.end(); i++) {
  278. if (strcmp(anEnvName, (*i).name) == 0) {
  279. LOG4CXX_DEBUG(loggerAtmiBrokerEnv,
  280. (char*) "getenv found env name '%s'" << (*i).value);
  281. return (*i).value;
  282. }
  283. }
  285. return defValue;
  286. }
  288. char*
  289. AtmiBrokerEnv::getenv(char* anEnvName) {
  290. const char* val = getenv(anEnvName, NULL);
  292. if (val != NULL)
  293. return (char *) val;
  295. LOG4CXX_ERROR(loggerAtmiBrokerEnv, (char*) "Could not locate: "
  296. << anEnvName);
  297. throw new std::exception();
  298. }
  300. int AtmiBrokerEnv::putenv(char* anEnvNameValue) {
  301. LOG4CXX_DEBUG(loggerAtmiBrokerEnv, (char*) "putenv %s" << anEnvNameValue);
  303. char *p = strchr(anEnvNameValue, '=');
  304. envVar_t envVar;
  306. envVar.name = ACE::strndup(anEnvNameValue, (size_t)(p - anEnvNameValue));
  307. envVar.value = ACE::strndup(p + 1, (int) (strlen(anEnvNameValue)
  308. - strlen(p)));
  309. envVariableInfoSeq.push_back(envVar);
  311. LOG4CXX_DEBUG(loggerAtmiBrokerEnv, (char*) "putenv name '" << envVar.name
  312. << "' value '" << envVar.value);
  314. return 1;
  315. }
  317. int AtmiBrokerEnv::readenv() {
  318. if (!readEnvironment) {
  319. LOG4CXX_DEBUG(loggerAtmiBrokerEnv, (char*) "readenv");
  320. if (ENVIRONMENT_DIR != NULL) {
  321. LOG4CXX_DEBUG(loggerAtmiBrokerEnv,
  322. (char*) "readenv configuration dir: " << ENVIRONMENT_DIR);
  323. } else {
  324. LOG4CXX_DEBUG(loggerAtmiBrokerEnv,
  325. (char*) "readenv default configuration");
  326. }
  328. AtmiBrokerEnvXml aAtmiBrokerEnvXml;
  329. if (aAtmiBrokerEnvXml.parseXmlDescriptor(&envVariableInfoSeq,
  330. ENVIRONMENT_DIR, configuration)) {
  331. readEnvironment = true;
  332. } else {
  333. if (ENVIRONMENT_DIR != NULL) {
  334. LOG4CXX_ERROR(loggerAtmiBrokerEnv, (char*) "can not parse "
  335. << ENVIRONMENT_DIR << "/btconfig.xml");
  336. } else {
  337. LOG4CXX_ERROR(loggerAtmiBrokerEnv,
  338. (char*) "can not parse btconfig.xml");
  339. }
  340. throw std::exception();
  341. }
  342. }
  343. return 1;
  344. }
  346. std::vector<envVar_t>& AtmiBrokerEnv::getEnvVariableInfoSeq() {
  347. return envVariableInfoSeq;
  348. }