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

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

中间件编程

开发平台：

Java

server.cpp：源码内容
  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.  */
  18. #include <jni.h>
  19. #include <sys/types.h>
  20. #include <sys/stat.h>
  21. #include <fcntl.h>
  23. #include <stdlib.h>
  24. #include "string.h"
  26. #include "AtmiBrokerServerControl.h"
  27. #include "ace/OS_NS_unistd.h"
  28. #include "xatmi.h"
  29. #include "userlogc.h"
  30. #include "XATMITestSuite.h"
  32. int interationCount = 100;
  34. #include "ace/OS_NS_unistd.h"
  36. #include "xatmi.h"
  37. #include "userlogc.h"
  39. extern void test_tpcall_TPETIME_service(TPSVCINFO *svcinfo);
  40. extern void test_tpcall_TPEOTYPE_service(TPSVCINFO *svcinfo);
  41. extern void test_tpcall_TPESVCFAIL_service(TPSVCINFO *svcinfo);
  42. extern void test_tprecv_TPEV_DISCONIMM_service(TPSVCINFO *svcinfo);
  43. extern void test_tprecv_TPEV_SVCFAIL_service(TPSVCINFO *svcinfo);
  44. extern void test_no_tpreturn_service(TPSVCINFO *svcinfo);
  46. extern void test_tx_tpcall_x_octet_service_without_tx(TPSVCINFO *svcinfo);
  47. extern void test_tx_tpcall_x_octet_service_with_tx(TPSVCINFO *svcinfo);
  49. extern "C" void BAR(TPSVCINFO * svcinfo) {
  50. int sendlen = 14;
  51. char* buffer = tpalloc((char*) "X_OCTET", NULL, sendlen);
  52. strncpy(buffer, "BAR SAYS HELLO", 14);
  54. tpreturn(TPSUCCESS, 1, buffer, sendlen, 0);
  55. }
  57. void tpcall_x_octet(TPSVCINFO * svcinfo) {
  58. int sendlen = 14;
  59. char* buffer = tpalloc((char*) "X_OCTET", 0, sendlen);
  60. strncpy(buffer, "BAR SAYS HELLO", 14);
  61. tpreturn(TPSUCCESS, 1, buffer, sendlen, 0);
  62. }
  64. void loopy(TPSVCINFO* tpsvcinfo) {
  65. userlogc((char*) "loopy");
  66. }
  68. /* this routine is used for DEBIT and CREDIT */
  69. void debit_credit_svc(TPSVCINFO *svcinfo) {
  70. userlogc((char*) "debit_credit_svc: %d", svcinfo->len);
  71. DATA_BUFFER *dc_ptr;
  72. int rval;
  73. /* extract request typed buffer */
  74. dc_ptr = (DATA_BUFFER *) svcinfo->data;
  75. /*
  76.  * Depending on service name used to invoke this
  77.  * routine, perform either debit or credit work.
  78.  */
  79. if (!strcmp(svcinfo->name, "DEBIT")) {
  80. /*
  81.  * Parse input data and perform debit
  82.  * as part of global transaction.
  83.  */
  84. } else {
  85. /*
  86.  * Parse input data and perform credit
  87.  * as part of global transaction.
  88.  */
  89. }
  90. // TODO MAKE TWO TESTS
  91. if (dc_ptr->failTest == 0) {
  92. rval = TPSUCCESS;
  93. dc_ptr->output = OK;
  94. } else {
  95. rval = TPFAIL; /* global transaction will not commit */
  96. dc_ptr->output = NOT_OK;
  97. }
  98. /* send reply and return from service routine */
  99. tpreturn(rval, 0, (char *) dc_ptr, 0, 0);
  100. userlogc((char*) "tpreturn 0 hmm: %d", svcinfo->len);
  101. }
  103. /* this routine is used for INQUIRY */
  104. void inquiry_svc(TPSVCINFO *svcinfo) {
  105. userlogc((char*) "inquiry_svc");
  106. DATA_BUFFER *ptr;
  107. long event;
  108. int rval;
  109. /* extract initial typed buffer sent as part of tpconnect() */
  110. ptr = (DATA_BUFFER *) svcinfo->data;
  111. /*
  112.  * Parse input string, ptr->input, and retrieve records.
  113.  * Return 10 records at a time to client. Records are
  114.  * placed in ptr->output, an array of account records.
  115.  */
  116. for (int i = 0; i < 5; i++) {
  117. /* gather from DBMS next 10 records into ptr->output array */
  118. tpsend(svcinfo->cd, (char *) ptr, 0, TPSIGRSTRT, &event);
  119. }
  120. // TODO DO OK AND FAIL
  121. if (ptr->failTest == 0) {
  122. rval = TPSUCCESS;
  123. } else {
  124. rval = TPFAIL; /* global transaction will not commit */
  125. }
  126. /* terminate service routine, send no data, and */
  127. /* terminate connection */
  128. tpreturn(rval, 0, NULL, 0, 0);
  129. }
  131. void testtpacall_service(TPSVCINFO *svcinfo) {
  132. userlogc((char*) "testtpacall_service");
  133. int len = 20;
  134. char *toReturn = (char*) malloc(len);
  135. strcpy(toReturn, "testtpacall_service");
  136. tpreturn(TPSUCCESS, 0, toReturn, len, 0);
  137. free(toReturn);
  138. }
  139. void test_tpcall_x_octet_service(TPSVCINFO *svcinfo) {
  140. userlogc((char*) "test_tpcall_x_octet_service");
  141. bool ok = false;
  142. if (svcinfo->data) {
  143. if (strncmp(svcinfo->data, "test_tpcall_x_octet", svcinfo->len) == 0) {
  144. ok = true;
  145. }
  146. }
  148. int len = 60;
  149. char *toReturn = ::tpalloc((char*) "X_OCTET", NULL, len);
  150. if (ok) {
  151. strcpy(toReturn, "tpcall_x_octet");
  152. } else {
  153. strcpy(toReturn, "fail");
  154. if (svcinfo->data) {
  155. strcpy(toReturn, svcinfo->data);
  156. } else {
  157. strcpy(toReturn, "dud");
  158. }
  159. }
  160. tpreturn(TPSUCCESS, 20, toReturn, len, 0);
  161. }
  163. void test_tpcall_x_octet_service_zero(TPSVCINFO *svcinfo) {
  164. userlogc((char*) "test_tpcall_x_octet_service_zero");
  165. int len = 0;
  166. char *toReturn = ::tpalloc((char*) "X_OCTET", NULL, len);
  167. tpreturn(TPSUCCESS, 21, toReturn, len, 0);
  168. }
  170. void test_tpcall_x_common_service(TPSVCINFO *svcinfo) {
  171. userlogc((char*) "test_tpcall_x_common_service");
  172. bool ok = false;
  173. DEPOSIT *dptr = (DEPOSIT*) svcinfo->data;
  174. if (dptr->acct_no == 12345678 && dptr->amount == 50) {
  175. ok = true;
  176. } else {
  177. char* foo = svcinfo->data;
  178. for (int i = 0; i < svcinfo->len; i++) {
  179. userlogc((char*) "Position: %d was: %o", i, foo[i]);
  180. }
  181. userlogc((char*) "Data was: %d/%d", dptr->acct_no, dptr->amount);
  182. }
  184. int len = 60;
  185. char *toReturn = ::tpalloc((char*) "X_OCTET", NULL, len);
  186. if (ok) {
  187. strcpy(toReturn, "tpcall_x_common");
  188. } else {
  189. strcpy(toReturn, "fail");
  190. }
  191. tpreturn(TPSUCCESS, 22, toReturn, len, 0);
  192. }
  194. void test_tpcall_x_c_type_service(TPSVCINFO *svcinfo) {
  195. userlogc((char*) "test_tpcall_x_c_type_service");
  196. bool ok = false;
  197. ACCT_INFO *aptr = (ACCT_INFO*) svcinfo->data;
  198. bool acctEq = aptr->acct_no == 12345678;
  199. bool nameEq = strcmp(aptr->name, "TOM") == 0;
  200. bool fooEq = aptr->foo[0] == 1.1F && aptr->foo[1] == 2.2F;
  201. bool balsEq = aptr->balances[0] == 1.1 && aptr->balances[1] == 2.2;
  202. if (acctEq && nameEq && fooEq && balsEq) {
  203. ok = true;
  204. }
  205. int len = 60;
  206. char *toReturn = ::tpalloc((char*) "X_OCTET", NULL, len);
  207. if (ok) {
  208. strcpy(toReturn, "tpcall_x_c_type");
  209. } else {
  210. strcpy(toReturn, "fail");
  211. }
  212. tpreturn(TPSUCCESS, 23, toReturn, len, 0);
  213. }
  214. void testtpcancel_service(TPSVCINFO *svcinfo) {
  215. userlogc((char*) "testtpcancel_service");
  216. if (!(svcinfo->flags && TPNOREPLY)) {
  217. int len = 21;
  218. char *toReturn = ::tpalloc((char*) "X_OCTET", NULL, len);
  219. strcpy(toReturn, "testtpcancel_service");
  220. tpreturn(TPSUCCESS, 0, toReturn, len, 0);
  221. }
  222. }
  223. void testtpconnect_service(TPSVCINFO *svcinfo) {
  224. userlogc((char*) "testtpconnect_service");
  225. tpreturn(TPSUCCESS, 0, NULL, 0, 0);
  226. }
  227. void testTPConversation_service(TPSVCINFO *svcinfo) {
  229. userlogc((char*) "testTPConversation_service ");
  230. bool fail = false;
  231. char *sendbuf = ::tpalloc((char*) "X_OCTET", NULL, svcinfo->len);
  232. char *rcvbuf = ::tpalloc((char*) "X_OCTET", NULL, svcinfo->len);
  234. char* expectedResult = (char*) malloc(11);
  235. strcpy(expectedResult, "conversate");
  236. userlogc((char*) "testTPConversation_service expected: %s", expectedResult);
  238. /* int errorMessageLen = 10 + 1 + svcinfo->len + 1;
  239.  userlogc((char*) "testTPConversation_service errorMessageLen: %d", errorMessageLen);
  241.  char* errorMessage = (char*) malloc(errorMessageLen);
  242.  sprintf(errorMessage, "%s/%s", expectedResult, svcinfo->data);
  243.  userlogc((char*) "testTPConversation_service errorMessage will be: %s", errorMessage);
  244.  */
  245. if (strncmp(expectedResult, svcinfo->data, 10) != 0) {
  246. userlogc((char*) "Fail");
  247. if (svcinfo->data != NULL) {
  248. userlogc((char*) "Got invalid data");
  249. } else {
  250. userlogc((char*) "GOT A NULL");
  251. }
  252. fail = true;
  253. } else {
  254. userlogc((char*) "Chatting");
  255. long revent = 0;
  256. for (int i = 0; i < interationCount; i++) {
  257. sprintf(sendbuf, "hi%d", i);
  258. //userlogc((char*) "testTPConversation_service:%s:", sendbuf);
  259. int result = ::tpsend(svcinfo->cd, sendbuf, svcinfo->len,
  260. TPRECVONLY, &revent);
  261. if (result != -1) {
  262. result = ::tprecv(svcinfo->cd, &rcvbuf, &svcinfo->len, 0,
  263. &revent);
  264. if (result == -1 && revent == TPEV_SENDONLY) {
  265. char* expectedResult = (char*) malloc(svcinfo->len);
  266. sprintf(expectedResult, "yo%d", i);
  267. // char* errorMessage = (char*) malloc(svcinfo->len * 2 + 1);
  268. // sprintf(errorMessage, "%s/%s", expectedResult, rcvbuf);
  269. if (strcmp(expectedResult, rcvbuf) != 0) {
  270. free(expectedResult);
  271. // free(errorMessage);
  272. fail = true;
  273. break;
  274. }
  275. free(expectedResult);
  276. // free(errorMessage);
  277. } else {
  278. fail = true;
  279. break;
  280. }
  281. } else {
  282. fail = true;
  283. break;
  284. }
  285. }
  286. userlogc((char*) "Chatted");
  287. }
  289. if (fail) {
  290. tpreturn(TPESVCFAIL, 0, sendbuf, 0, 0);
  291. } else {
  292. sprintf(sendbuf, "hi%d", interationCount);
  293. tpreturn(TPSUCCESS, 0, sendbuf, svcinfo->len, 0);
  294. }
  296. ::tpfree(rcvbuf);
  297. free(expectedResult);
  298. // free(errorMessage);
  299. }
  301. void testTPConversation_short_service(TPSVCINFO *svcinfo) {
  302. userlogc((char*) "testTPConversation_short_service");
  303. long sendlen = 4;
  304. long revent = 0;
  305. char *sendbuf = ::tpalloc((char*) "X_OCTET", NULL, sendlen);
  306. strcpy(sendbuf, "hi0");
  307. ::tpsend(svcinfo->cd, sendbuf, sendlen, 0, &revent);
  308. strcpy(sendbuf, "hi1");
  309. tpreturn(TPSUCCESS, 0, sendbuf, sendlen, 0);
  310. }
  311. void testtpdiscon_service(TPSVCINFO *svcinfo) {
  312. userlogc((char*) "testtpdiscon_service");
  313. long timeout = 2;
  314. ACE_OS::sleep(timeout);
  315. }
  317. void testtpfreeservice_service(TPSVCINFO *svcinfo) {
  318. userlogc((char*) "testtpfreeservice_service");
  319. // Allocate a buffer to return
  320. char *toReturn = tpalloc((char*) "X_OCTET", (char*) "acct_info", 1);
  322. // Free should be idempotent on the inbound buffer
  323. ::tpfree(svcinfo->data);
  325. // Get the data from tptypes still
  326. int toTest = ::tptypes(svcinfo->data, NULL, NULL);
  328. // Check the values of tptypes (should still have been valid
  329. if (toTest == -1 || tperrno == TPEINVAL) {
  330. // False
  331. toReturn[0] = '0';
  332. } else {
  333. // True
  334. toReturn[0] = '1';
  335. }
  337. // Return the data
  338. tpreturn(TPSUCCESS, 0, toReturn, 1, 0);
  339. }
  340. void testtpgetrply_service(TPSVCINFO *svcinfo) {
  341. userlogc((char*) "testtpgetrply_service");
  342. char * toReturn = ::tpalloc((char*) "X_OCTET", NULL, 22);
  343. strcpy(toReturn, "testtpgetrply_service");
  344. tpreturn(TPSUCCESS, 0, toReturn, 22, 0);
  345. }
  346. void testtprecv_service(TPSVCINFO *svcinfo) {
  347. userlogc((char*) "testtprecv_service");
  348. }
  350. void testtpreturn_service(TPSVCINFO *svcinfo) {
  351. userlogc((char*) "testtpreturn_service");
  352. char *toReturn = (char*) malloc(21);
  353. strcpy(toReturn, "testtpreturn_service");
  354. tpreturn(TPSUCCESS, 0, toReturn, 21, 0);
  355. free(toReturn);
  356. }
  358. void testtpreturn_service_tpurcode(TPSVCINFO *svcinfo) {
  359. userlogc((char*) "testtpreturn_service_tpurcode");
  360. int len = 0;
  361. char *toReturn = ::tpalloc((char*) "X_OCTET", NULL, len);
  362. if (strncmp(svcinfo->data, "24", 2) == 0) {
  363. tpreturn(TPSUCCESS, 24, toReturn, len, 0);
  364. } else {
  365. tpreturn(TPSUCCESS, 77, toReturn, len, 0);
  366. }
  367. }
  369. void testtpsend_service(TPSVCINFO *svcinfo) {
  370. userlogc((char*) "testtpsend_service");
  371. }
  373. void testtpsend_tpsendonly_service(TPSVCINFO *svcinfo) {
  374. userlogc((char*) "testtpsend_tpsendonly_service");
  376. long event = 0;
  377. int result = ::tpsend(svcinfo->cd, svcinfo->data, svcinfo->len, TPRECVONLY,
  378. &event);
  380. long revent = 0;
  381. long rcvlen;
  382. char* rcvbuf = (char *) tpalloc((char*) "X_OCTET", NULL, svcinfo->len);
  383. result = ::tprecv(svcinfo->cd, &rcvbuf, &rcvlen, 0, &revent);
  384. }
  386. void testtpservice_service(TPSVCINFO *svcinfo) {
  387. userlogc((char*) "testtpservice_service");
  388. }
  389. void testtpunadvertise_service(TPSVCINFO *svcinfo) {
  390. userlogc((char*) "testtpunadvertise_service");
  391. char * toReturn = new char[26];
  392. strcpy(toReturn, "testtpunadvertise_service");
  393. // Changed length from 0L to svcinfo->len
  394. tpreturn(TPSUCCESS, 0, toReturn, 25, 0);
  395. delete toReturn;
  396. }
  398. void test_TTL_service(TPSVCINFO *svcinfo) {
  399. long timeout = 45;
  401. ACE_OS::sleep(timeout);
  402. userlogc((char*) "TTL sleep timeout %d seconds", timeout);
  404. int len = 60;
  405. char *toReturn = ::tpalloc((char*) "X_OCTET", NULL, len);
  406. strcpy(toReturn, "test_tpcall_TTL_service");
  407. tpreturn(TPSUCCESS, 0, toReturn, len, 0);
  408. }
  410. extern "C"
  411. JNIEXPORT void JNICALL Java_org_jboss_blacktie_jatmibroker_RunServer_serverinit(JNIEnv *, jobject) {
  412. int exit_status = -1;
  413. userlogc((char*) "serverinit called");
  414. #ifdef WIN32
  415. char* argv[] = {(char*)"server", (char*)"-c", (char*)"win32", (char*)"default", (char*)"-i", (char*)"1"};
  416. #else
  417. char* argv[] = {(char*)"server", (char*)"-c", (char*)"linux", (char*)"default", (char*)"-i", (char*)"1"};
  418. #endif
  419. int argc = sizeof(argv)/sizeof(char*);
  421. exit_status = serverinit(argc, argv);
  422. exit_status = tpadvertise((char*) "BAR", BAR);
  423. userlogc((char*) "serverinit returning");
  424. return;
  425. }
  427. extern "C"
  428. JNIEXPORT void JNICALL Java_org_jboss_blacktie_jatmibroker_RunServer_serverdone(JNIEnv *, jobject) {
  429. int exit_status = -1;
  430. userlogc((char*) "serverdone called");
  431. exit_status = serverdone();
  432. userlogc((char*) "serverdone returning");
  433. return;
  434. }
  436. extern "C"
  437. JNIEXPORT void JNICALL Java_org_jboss_blacktie_jatmibroker_RunServer_tpadvertiseBAR(JNIEnv *, jobject) {
  438. // Do local work
  439. tpadvertise((char*) "BAR", BAR);
  440. }
  442. extern "C"
  443. JNIEXPORT void JNICALL Java_org_jboss_blacktie_jatmibroker_RunServer_tpadvertiseLOOPY(JNIEnv *, jobject) {
  444. tpadvertise((char*) "LOOPY", loopy);
  445. }
  447. extern "C"
  448. JNIEXPORT void JNICALL Java_org_jboss_blacktie_jatmibroker_RunServer_tpadvertiseDEBIT(JNIEnv *, jobject) {
  449. tpadvertise((char*) "DEBIT", debit_credit_svc);
  450. }
  452. extern "C"
  453. JNIEXPORT void JNICALL Java_org_jboss_blacktie_jatmibroker_RunServer_tpadvertiseCREDIT(JNIEnv *, jobject) {
  454. tpadvertise((char*) "CREDIT", debit_credit_svc);
  455. }
  457. extern "C"
  458. JNIEXPORT void JNICALL Java_org_jboss_blacktie_jatmibroker_RunServer_tpadvertiseINQUIRY(JNIEnv *, jobject) {
  459. tpadvertise((char*) "INQUIRY", inquiry_svc);
  460. }
  462. extern "C"
  463. JNIEXPORT void JNICALL Java_org_jboss_blacktie_jatmibroker_RunServer_tpadvertiseTestTPACall(JNIEnv *, jobject) {
  464. tpadvertise((char*) "TestTPACall", testtpacall_service);
  465. // TODO tpadvertise exit_status =
  466. }
  468. extern "C"
  469. JNIEXPORT void JNICALL Java_org_jboss_blacktie_jatmibroker_RunServer_tpadvertisetpcallXOctet(JNIEnv *, jobject) {
  470. tpadvertise((char*) "tpcall_x_octet", test_tpcall_x_octet_service);
  471. }
  473. extern "C"
  474. JNIEXPORT void JNICALL Java_org_jboss_blacktie_jatmibroker_RunServer_tpadvertisetpcallXOctetZero(JNIEnv *, jobject) {
  475. tpadvertise((char*) "tpcall_x_octet", test_tpcall_x_octet_service_zero);
  476. }
  478. extern "C"
  479. JNIEXPORT void JNICALL Java_org_jboss_blacktie_jatmibroker_RunServer_tpadvertisetpcallXCommon(JNIEnv *, jobject) {
  480. tpadvertise((char*) "tpcall_x_common", test_tpcall_x_common_service);
  481. }
  483. extern "C"
  484. JNIEXPORT void JNICALL Java_org_jboss_blacktie_jatmibroker_RunServer_tpadvertisetpcallXCType(JNIEnv *, jobject) {
  485. tpadvertise((char*) "tpcall_x_c_type", test_tpcall_x_c_type_service);
  486. }
  488. extern "C"
  489. JNIEXPORT void JNICALL Java_org_jboss_blacktie_jatmibroker_RunServer_tpadvertiseTestTPCancel(JNIEnv *, jobject) {
  490. tpadvertise((char*) "TestTPCancel", testtpcancel_service);
  491. }
  493. extern "C"
  494. JNIEXPORT void JNICALL Java_org_jboss_blacktie_jatmibroker_RunServer_tpadvertiseTestTPConnect(JNIEnv *, jobject) {
  495. tpadvertise((char*) "TestTPConnect", testtpconnect_service);
  496. }
  498. extern "C"
  499. JNIEXPORT void JNICALL Java_org_jboss_blacktie_jatmibroker_RunServer_tpadvertiseTestTPConversation(JNIEnv *, jobject) {
  500. tpadvertise((char*) "TestTPConversation",
  501. testTPConversation_service);
  502. }
  504. extern "C"
  505. JNIEXPORT void JNICALL Java_org_jboss_blacktie_jatmibroker_RunServer_tpadvertiseTestTPConversa2(JNIEnv *, jobject) {
  506. tpadvertise((char*) "TestTPConversation",
  507. testTPConversation_short_service);
  508. }
  510. extern "C"
  511. JNIEXPORT void JNICALL Java_org_jboss_blacktie_jatmibroker_RunServer_tpadvertiseTestTPDiscon(JNIEnv *, jobject) {
  512. tpadvertise((char*) "TestTPDiscon", testtpdiscon_service);
  513. }
  515. extern "C"
  516. JNIEXPORT void JNICALL Java_org_jboss_blacktie_jatmibroker_RunServer_tpadvertiseTestTPFree(JNIEnv *, jobject) {
  517. tpadvertise((char*) "TestTPFree", testtpfreeservice_service);
  518. }
  520. extern "C"
  521. JNIEXPORT void JNICALL Java_org_jboss_blacktie_jatmibroker_RunServer_tpadvertiseTestTPGetrply(JNIEnv *, jobject) {
  522. tpadvertise((char*) "TestTPGetrply", testtpgetrply_service);
  523. }
  525. extern "C"
  526. JNIEXPORT void JNICALL Java_org_jboss_blacktie_jatmibroker_RunServer_tpadvertiseTestTPRecv(JNIEnv *, jobject) {
  527. tpadvertise((char*) "TestTPRecv", testtprecv_service);
  528. }
  530. extern "C"
  531. JNIEXPORT void JNICALL Java_org_jboss_blacktie_jatmibroker_RunServer_tpadvertiseTestTPReturn(JNIEnv *, jobject) {
  532. tpadvertise((char*) "TestTPReturn", testtpreturn_service);
  533. }
  535. extern "C"
  536. JNIEXPORT void JNICALL Java_org_jboss_blacktie_jatmibroker_RunServer_tpadvertiseTestTPReturn2(JNIEnv *, jobject) {
  537. tpadvertise((char*) "TestTPReturn",
  538. testtpreturn_service_tpurcode);
  539. }
  541. extern "C"
  542. JNIEXPORT void JNICALL Java_org_jboss_blacktie_jatmibroker_RunServer_tpadvertiseTestTPSendTPSendOnly(JNIEnv *, jobject) {
  543. tpadvertise((char*) "TestTPSend", testtpsend_tpsendonly_service);
  544. }
  546. extern "C"
  547. JNIEXPORT void JNICALL Java_org_jboss_blacktie_jatmibroker_RunServer_tpadvertiseTestTPSend(JNIEnv *, jobject) {
  548. tpadvertise((char*) "TestTPSend", testtpsend_service);
  549. }
  551. extern "C"
  552. JNIEXPORT void JNICALL Java_org_jboss_blacktie_jatmibroker_RunServer_tpadvertiseTestTPService(JNIEnv *, jobject) {
  553. tpadvertise((char*) "TestTPService", testtpservice_service);
  554. }
  556. extern "C"
  557. JNIEXPORT void JNICALL Java_org_jboss_blacktie_jatmibroker_RunServer_tpadvertiseTestTPUnadvertise(JNIEnv *, jobject) {
  558. tpadvertise((char*) "TestTPUnadvertise",
  559. testtpunadvertise_service);
  560. }
  562. extern "C"
  563. JNIEXPORT void JNICALL Java_org_jboss_blacktie_jatmibroker_RunServer_tpadvertiseTX1(JNIEnv *, jobject) {
  564. tpadvertise((char*) "tpcall_x_octet", test_tx_tpcall_x_octet_service_without_tx);
  565. }
  567. extern "C"
  568. JNIEXPORT void JNICALL Java_org_jboss_blacktie_jatmibroker_RunServer_tpadvertiseTX2(JNIEnv *, jobject) {
  569. tpadvertise((char*) "tpcall_x_octet", test_tx_tpcall_x_octet_service_with_tx);
  570. }
  572. extern "C"
  573. JNIEXPORT void JNICALL Java_org_jboss_blacktie_jatmibroker_RunServer_tpadvertiseTestRollbackOnlyTpcallTPETIMEService(JNIEnv *, jobject) {
  574. tpadvertise((char*) "TestRbkOnly", test_tpcall_TPETIME_service);
  575. }
  577. extern "C"
  578. JNIEXPORT void JNICALL Java_org_jboss_blacktie_jatmibroker_RunServer_tpadvertiseTestRollbackOnlyTpcallTPEOTYPEService(JNIEnv *, jobject) {
  579. tpadvertise((char*) "TestRbkOnly", test_tpcall_TPEOTYPE_service);
  580. }
  582. extern "C"
  583. JNIEXPORT void JNICALL Java_org_jboss_blacktie_jatmibroker_RunServer_tpadvertiseTestRollbackOnlyTpcallTPESVCFAILService(JNIEnv *, jobject) {
  584. tpadvertise((char*) "TestRbkOnly", test_tpcall_TPESVCFAIL_service);
  585. }
  587. extern "C"
  588. JNIEXPORT void JNICALL Java_org_jboss_blacktie_jatmibroker_RunServer_tpadvertiseTestRollbackOnlyTprecvTPEVDISCONIMMService(JNIEnv *, jobject) {
  589. tpadvertise((char*) "TestRbkOnly", test_tprecv_TPEV_DISCONIMM_service);
  590. }
  592. extern "C"
  593. JNIEXPORT void JNICALL Java_org_jboss_blacktie_jatmibroker_RunServer_tpadvertiseTestRollbackOnlyTprecvTPEVSVCFAILService(JNIEnv *, jobject) {
  594. tpadvertise((char*) "TestRbkOnly", test_tprecv_TPEV_SVCFAIL_service);
  595. }
  597. extern "C"
  598. JNIEXPORT void JNICALL Java_org_jboss_blacktie_jatmibroker_RunServer_tpadvertiseTestRollbackOnlyNoTpreturnService(JNIEnv *, jobject) {
  599. tpadvertise((char*) "TestRbkOnly", test_no_tpreturn_service);
  600. }
  602. extern "C"
  603. JNIEXPORT void JNICALL Java_org_jboss_blacktie_jatmibroker_RunServer_tpadvertiseTTL(JNIEnv *, jobject) {
  604. tpadvertise((char*) "TTL", test_TTL_service);
  605. }