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

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

中间件编程

开发平台：

Java

TestTPCall.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.  */
  18. #include "TestAssert.h"
  20. #include "BaseServerTest.h"
  21. #include "XATMITestSuite.h"
  23. #include "xatmi.h"
  25. #include "TestTPCall.h"
  26. #include "Sleeper.h"
  28. extern void test_tpcall_x_octet_service(TPSVCINFO *svcinfo);
  29. extern void test_tpcall_x_octet_service_zero(TPSVCINFO *svcinfo);
  30. extern void test_tpcall_x_common_service(TPSVCINFO *svcinfo);
  31. extern void test_tpcall_x_c_type_service(TPSVCINFO *svcinfo);
  33. extern void test_tpcall_TPNOBLOCK(TPSVCINFO *svcinfo);
  34. extern void test_tpcall_TPNOTIME(TPSVCINFO *svcinfo);
  36. void TestTPCall::setUp() {
  37. userlogc((char*) "TestTPCall::setUp");
  38. sendbuf = NULL;
  39. rcvbuf = NULL;
  40. BaseServerTest::setUp();
  41. // Do local work
  42. }
  44. void TestTPCall::tearDown() {
  45. userlogc((char*) "TestTPCall::tearDown");
  46. // Do local work
  47. ::tpfree( sendbuf);
  48. ::tpfree( rcvbuf);
  50. // Clean up server
  51. BaseServerTest::tearDown();
  52. }
  54. void TestTPCall::test_tpcall_systemerr() {
  55. userlogc((char*) "test_tpcall_systemerr");
  56. sendlen = strlen("test_tpcall_systemerr") + 1;
  57. rcvlen = sendlen;
  58. BT_ASSERT((sendbuf
  59. = (char *) tpalloc((char*) "X_OCTET", NULL, sendlen)) != NULL);
  60. BT_ASSERT((rcvbuf = (char *) tpalloc((char*) "X_OCTET", NULL, rcvlen))
  61. != NULL);
  62. (void) strcpy(sendbuf, "test_tpcall_systemerr");
  63. BT_ASSERT(tperrno == 0);
  65. // TODO stopNamingService();
  67. int id = ::tpcall((char*) "TestTPCall", (char *) sendbuf, sendlen,
  68. (char **) &rcvbuf, &rcvlen, (long) 0);
  69. BT_ASSERT(tperrno == TPESYSTEM);
  70. BT_ASSERT(id == -1);
  71. BT_ASSERT(strcmp(rcvbuf, "testtpcall") == -1);
  72. }
  74. void TestTPCall::test_tpcall_unknown_service() {
  75. userlogc((char*) "test_tpcall_unknown_service");
  76. sendlen = strlen("test_tpcall_unknown_service") + 1;
  77. rcvlen = sendlen;
  78. sendbuf = (char *) tpalloc((char*) "X_OCTET", NULL, sendlen);
  79. rcvbuf = (char *) tpalloc((char*) "X_OCTET", NULL, rcvlen);
  80. strcpy(sendbuf, "test_tpcall_unknown_service");
  82. int id = ::tpcall((char*) "UNKNOWN_SERVICE", (char *) sendbuf, sendlen,
  83. (char **) &rcvbuf, &rcvlen, (long) 0);
  84. BT_ASSERT(tperrno == TPENOENT);
  85. BT_ASSERT(id == -1);
  86. BT_ASSERT(tperrno != 0);
  87. }
  89. void TestTPCall::test_tpcall_x_octet_lessdata() {
  90. userlogc((char*) "test_tpcall_x_octet_lessdata");
  91. BT_FAIL("UNIMPLEMENTED");
  92. }
  94. void TestTPCall::test_tpcall_null_service() {
  95. userlogc((char*) "test_tpcall_x_octet");
  96. tpadvertise((char*) "tpcall_x_octet", test_tpcall_x_octet_service);
  98. sendlen = strlen("test_tpcall_x_octet") + 1;
  99. rcvlen = sendlen;
  100. BT_ASSERT((sendbuf
  101. = (char *) tpalloc((char*) "X_OCTET", NULL, sendlen)) != NULL);
  102. BT_ASSERT((rcvbuf = (char *) tpalloc((char*) "X_OCTET", NULL, rcvlen))
  103. != NULL);
  104. (void) strcpy(sendbuf, "test_tpcall_x_octet");
  105. BT_ASSERT(tperrno == 0);
  107. int id = ::tpcall(NULL, (char *) sendbuf, sendlen, (char **) &rcvbuf,
  108. &rcvlen, (long) 0);
  109. BT_ASSERT(tperrno == TPEINVAL);
  110. BT_ASSERT(id == -1);
  111. BT_ASSERT_MESSAGE(rcvbuf, strcmp(rcvbuf, "tpcall_x_octet") != 0);
  112. }
  114. void TestTPCall::test_tpcall_x_octet() {
  115. userlogc((char*) "test_tpcall_x_octet");
  116. tpadvertise((char*) "tpcall_x_octet", test_tpcall_x_octet_service);
  118. sendlen = strlen("test_tpcall_x_octet") + 1;
  119. rcvlen = sendlen;
  120. BT_ASSERT((sendbuf
  121. = (char *) tpalloc((char*) "X_OCTET", NULL, sendlen)) != NULL);
  122. BT_ASSERT((rcvbuf = (char *) tpalloc((char*) "X_OCTET", NULL, rcvlen))
  123. != NULL);
  124. (void) strcpy(sendbuf, "test_tpcall_x_octet");
  125. BT_ASSERT(tperrno == 0);
  127. int id = ::tpcall((char*) "tpcall_x_octet", (char *) sendbuf, sendlen,
  128. (char **) &rcvbuf, &rcvlen, (long) 0);
  129. BT_ASSERT(tperrno != TPEINVAL);
  130. BT_ASSERT(tperrno != TPENOENT);
  131. BT_ASSERT(tperrno != TPEITYPE);
  132. BT_ASSERT(tperrno != TPEOTYPE);
  133. BT_ASSERT(tperrno != TPETRAN);
  134. BT_ASSERT(tperrno != TPETIME);
  135. BT_ASSERT(tperrno != TPESVCFAIL);
  136. BT_ASSERT(tperrno != TPESVCERR);
  137. BT_ASSERT(tperrno != TPEBLOCK);
  138. BT_ASSERT(tperrno != TPGOTSIG);
  139. BT_ASSERT(tperrno != TPEPROTO);
  140. BT_ASSERT(tperrno != TPESYSTEM);
  141. BT_ASSERT(tperrno != TPEOS);
  142. BT_ASSERT(tperrno == 0);
  143. BT_ASSERT(tpurcode == 20);
  144. BT_ASSERT(id != -1);
  145. BT_ASSERT_MESSAGE(rcvbuf, strcmp(rcvbuf, "tpcall_x_octet") == 0);
  146. }
  148. void TestTPCall::test_tpcall_x_octet_zero() {
  149. userlogc((char*) "test_tpcall_x_octet_zero");
  150. tpadvertise((char*) "tpcall_x_octet", test_tpcall_x_octet_service_zero);
  152. BT_ASSERT((sendbuf = (char *) tpalloc((char*) "X_OCTET", NULL, 0))
  153. != NULL);
  154. BT_ASSERT((rcvbuf = (char *) tpalloc((char*) "X_OCTET", NULL, 0))
  155. != NULL);
  156. BT_ASSERT(tperrno == 0);
  158. sendlen = 0;
  159. rcvlen = sendlen;
  161. int id = ::tpcall((char*) "tpcall_x_octet", (char *) sendbuf, 0,
  162. (char **) &rcvbuf, &rcvlen, (long) 0);
  163. BT_ASSERT(tperrno != TPEINVAL);
  164. BT_ASSERT(tperrno != TPENOENT);
  165. BT_ASSERT(tperrno != TPEITYPE);
  166. BT_ASSERT(tperrno != TPEOTYPE);
  167. BT_ASSERT(tperrno != TPETRAN);
  168. BT_ASSERT(tperrno != TPETIME);
  169. BT_ASSERT(tperrno != TPESVCFAIL);
  170. BT_ASSERT(tperrno != TPESVCERR);
  171. BT_ASSERT(tperrno != TPEBLOCK);
  172. BT_ASSERT(tperrno != TPGOTSIG);
  173. BT_ASSERT(tperrno != TPEPROTO);
  174. BT_ASSERT(tperrno != TPESYSTEM);
  175. BT_ASSERT(tperrno != TPEOS);
  176. BT_ASSERT(tperrno == 0);
  177. BT_ASSERT(tpurcode == 21);
  178. BT_ASSERT(id != -1);
  179. BT_ASSERT(rcvlen == 0);
  180. }
  182. #include "malloc.h"
  183. // 9.1.2
  184. void TestTPCall::test_tpcall_x_common() {
  185. userlogc((char*) "test_tpcall_x_common");
  186. tpadvertise((char*) "tpcall_x_common", test_tpcall_x_common_service);
  188. DEPOSIT *dptr;
  189. dptr = (DEPOSIT*) tpalloc((char*) "X_COMMON", (char*) "deposit", 0);
  190. rcvlen = 60;
  192. BT_ASSERT((rcvbuf = (char *) tpalloc((char*) "X_OCTET", NULL, rcvlen))
  193. != NULL);
  194. sendbuf = (char*) dptr;
  195. dptr->acct_no = 12345678;
  196. dptr->amount = 50;
  198. // userlogc("%d %d %d", sizeof(long), sizeof(int), sizeof(short));
  199. // char foo[sizeof(short)]; // 8
  200. // memcpy(foo, &sendbuf[8], sizeof(short));
  201. // short* bar = (short*) foo;
  202. // short barbar = *bar;
  204. int id = ::tpcall((char*) "tpcall_x_common", (char*) dptr, 0,
  205. (char**) &rcvbuf, &rcvlen, 0);
  206. BT_ASSERT(tperrno == 0);
  207. BT_ASSERT(tpurcode == 22);
  208. BT_ASSERT(id != -1);
  209. BT_ASSERT_MESSAGE(rcvbuf, strcmp(rcvbuf, "tpcall_x_common") == 0);
  210. }
  211. // 9.1.3
  212. void TestTPCall::test_tpcall_x_c_type() {
  213. userlogc((char*) "test_tpcall_x_c_type");
  214. tpadvertise((char*) "tpcall_x_c_type", test_tpcall_x_c_type_service);
  216. ACCT_INFO *aptr;
  217. aptr = (ACCT_INFO*) tpalloc((char*) "X_C_TYPE", (char*) "acct_info", 0);
  218. rcvlen = 60;
  220. BT_ASSERT((rcvbuf = (char *) tpalloc((char*) "X_OCTET", NULL, rcvlen))
  221. != NULL);
  222. sendbuf = (char*) aptr;
  223. aptr->acct_no = 12345678;
  224. strcpy(aptr->name, "TOM");
  225. aptr->foo[0] = 1.1F;
  226. aptr->foo[1] = 2.2F;
  228. aptr->balances[0] = 1.1;
  229. aptr->balances[1] = 2.2;
  231. int id = ::tpcall((char*) "tpcall_x_c_type", (char*) aptr, 0,
  232. (char**) &rcvbuf, &rcvlen, TPNOCHANGE);
  233. BT_ASSERT(tperrno == 0);
  234. BT_ASSERT(tpurcode == 23);
  235. BT_ASSERT(id != -1);
  236. BT_ASSERT_MESSAGE(rcvbuf, strcmp(rcvbuf, "tpcall_x_c_type") == 0);
  237. }
  239. void TestTPCall::test_tpcall_with_TPNOCHANGE() {
  240. userlogc((char*) "test_tpcall_with_TPNOCHANGE");
  241. tpadvertise((char*) "tpcall_x_c_type", test_tpcall_x_c_type_service);
  243. ACCT_INFO *aptr;
  244. aptr = (ACCT_INFO*) tpalloc((char*) "X_C_TYPE", (char*) "acct_info", 0);
  245. rcvlen = 60;
  247. rcvbuf = (char *) tpalloc((char*) "X_C_TYPE", (char*) "acct_info", 0);
  248. BT_ASSERT(rcvbuf != NULL);
  249. sendbuf = (char*) aptr;
  250. aptr->acct_no = 12345678;
  251. strcpy(aptr->name, "TOM");
  252. aptr->foo[0] = 1.1F;
  253. aptr->foo[1] = 2.2F;
  255. aptr->balances[0] = 1.1;
  256. aptr->balances[1] = 2.2;
  258. int id = ::tpcall((char*) "tpcall_x_c_type", (char*) aptr, 0,
  259. (char**) &rcvbuf, &rcvlen, TPNOCHANGE);
  260. BT_ASSERT(tperrno == TPEOTYPE);
  261. BT_ASSERT(id == -1);
  263. char* type = (char*) malloc(8);
  264. char* subtype = (char*) malloc(16);
  265. long toTest = ::tptypes(rcvbuf, type, subtype);
  266. BT_ASSERT(strncmp(type, "X_C_TYPE", 8) == 0);
  267. BT_ASSERT(strncmp(subtype, "acct_info", 16) == 0);
  268. BT_ASSERT(toTest == sizeof(ACCT_INFO));
  269. free(type);
  270. free(subtype);
  272. }
  274. void TestTPCall::test_tpcall_without_TPNOCHANGE() {
  275. userlogc((char*) "test_tpcall_without_TPNOCHANGE");
  276. tpadvertise((char*) "tpcall_x_c_type", test_tpcall_x_c_type_service);
  278. ACCT_INFO *aptr;
  279. aptr = (ACCT_INFO*) tpalloc((char*) "X_C_TYPE", (char*) "acct_info", 0);
  280. rcvlen = 60;
  282. rcvbuf = (char *) tpalloc((char*) "X_C_TYPE", (char*) "acct_info", 0);
  283. BT_ASSERT(rcvbuf != NULL);
  284. sendbuf = (char*) aptr;
  285. aptr->acct_no = 12345678;
  286. strcpy(aptr->name, "TOM");
  287. aptr->foo[0] = 1.1F;
  288. aptr->foo[1] = 2.2F;
  290. aptr->balances[0] = 1.1;
  291. aptr->balances[1] = 2.2;
  293. int id = ::tpcall((char*) "tpcall_x_c_type", (char*) aptr, 0,
  294. (char**) &rcvbuf, &rcvlen, 0);
  295. BT_ASSERT(tperrno == 0);
  296. BT_ASSERT(tpurcode == 23);
  297. BT_ASSERT(id != -1);
  298. BT_ASSERT_MESSAGE(rcvbuf, strcmp(rcvbuf, "tpcall_x_c_type") == 0);
  299. BT_ASSERT(rcvlen == 60);
  300. char* type = (char*) malloc(8);
  301. char* subtype = (char*) malloc(16);
  302. long toTest = ::tptypes(rcvbuf, type, subtype);
  303. BT_ASSERT(strcmp(type, "X_OCTET") == 0);
  304. BT_ASSERT(strcmp(subtype, "") == 0);
  305. BT_ASSERT(toTest == 60);
  306. free(type);
  307. free(subtype);
  308. }
  310. void test_tpcall_x_octet_service(TPSVCINFO *svcinfo) {
  311. userlogc((char*) "test_tpcall_x_octet_service");
  312. bool ok = false;
  313. if (svcinfo->data) {
  314. if (strncmp(svcinfo->data, "test_tpcall_x_octet", svcinfo->len) == 0) {
  315. ok = true;
  316. }
  317. }
  319. int len = 60;
  320. char *toReturn = ::tpalloc((char*) "X_OCTET", NULL, len);
  321. if (ok) {
  322. strcpy(toReturn, "tpcall_x_octet");
  323. } else {
  324. strcpy(toReturn, "fail");
  325. if (svcinfo->data) {
  326. strcpy(toReturn, svcinfo->data);
  327. } else {
  328. strcpy(toReturn, "dud");
  329. }
  330. }
  331. tpreturn(TPSUCCESS, 20, toReturn, len, 0);
  332. }
  334. void test_tpcall_x_octet_service_zero(TPSVCINFO *svcinfo) {
  335. userlogc((char*) "test_tpcall_x_octet_service_zero");
  336. int len = 0;
  337. char *toReturn = ::tpalloc((char*) "X_OCTET", NULL, len);
  338. tpreturn(TPSUCCESS, 21, toReturn, len, 0);
  339. }
  341. void test_tpcall_x_common_service(TPSVCINFO *svcinfo) {
  342. userlogc((char*) "test_tpcall_x_common_service");
  343. bool ok = false;
  344. DEPOSIT *dptr = (DEPOSIT*) svcinfo->data;
  345. if (dptr->acct_no == 12345678 && dptr->amount == 50) {
  346. ok = true;
  347. }
  349. int len = 60;
  350. char *toReturn = ::tpalloc((char*) "X_OCTET", NULL, len);
  351. if (ok) {
  352. strcpy(toReturn, "tpcall_x_common");
  353. } else {
  354. strcpy(toReturn, "fail");
  355. }
  356. tpreturn(TPSUCCESS, 22, toReturn, len, 0);
  357. }
  359. void test_tpcall_x_c_type_service(TPSVCINFO *svcinfo) {
  360. userlogc((char*) "test_tpcall_x_c_type_service");
  361. bool ok = false;
  362. ACCT_INFO *aptr = (ACCT_INFO*) svcinfo->data;
  363. bool acctEq = aptr->acct_no == 12345678;
  364. bool nameEq = strcmp(aptr->name, "TOM") == 0;
  365. bool fooEq = aptr->foo[0] == 1.1F && aptr->foo[1] == 2.2F;
  366. bool balsEq = aptr->balances[0] == 1.1 && aptr->balances[1] == 2.2;
  367. if (acctEq && nameEq && fooEq && balsEq) {
  368. ok = true;
  369. }
  370. int len = 60;
  371. char *toReturn = ::tpalloc((char*) "X_OCTET", NULL, len);
  372. if (ok) {
  373. strcpy(toReturn, "tpcall_x_c_type");
  374. } else {
  375. strcpy(toReturn, "fail");
  376. }
  377. tpreturn(TPSUCCESS, 23, toReturn, len, 0);
  378. }
  380. void TestTPCall::test_tpcall_with_TPNOBLOCK() {
  381. char* toTest = (char*) "test_tpcall_TPNOBLOCK";
  382. userlogc(toTest);
  383. tpadvertise((char*) "tpcall_x_octet", test_tpcall_TPNOBLOCK);
  385. sendlen = strlen(toTest) + 1;
  386. rcvlen = sendlen;
  387. BT_ASSERT((sendbuf
  388. = (char *) tpalloc((char*) "X_OCTET", NULL, sendlen)) != NULL);
  389. BT_ASSERT((rcvbuf = (char *) tpalloc((char*) "X_OCTET", NULL, rcvlen))
  390. != NULL);
  391. (void) strcpy(sendbuf, toTest);
  392. BT_ASSERT(tperrno == 0);
  394. int id = ::tpcall((char*) "tpcall_x_octet", (char *) sendbuf, sendlen,
  395. (char **) &rcvbuf, &rcvlen, TPNOBLOCK);
  396. BT_ASSERT(tperrno == 0);
  397. BT_ASSERT(id != -1);
  398. BT_ASSERT(strcmp(rcvbuf, toTest) == 0);
  399. }
  401. void TestTPCall::test_tpcall_without_TPNOBLOCK() {
  402. char* toTest = (char*) "test_tpcall_no_TPNOBLOCK";
  403. userlogc(toTest);
  404. tpadvertise((char*) "tpcall_x_octet", test_tpcall_TPNOBLOCK);
  406. sendlen = strlen(toTest) + 1;
  407. rcvlen = sendlen;
  408. BT_ASSERT((sendbuf
  409. = (char *) tpalloc((char*) "X_OCTET", NULL, sendlen)) != NULL);
  410. BT_ASSERT((rcvbuf = (char *) tpalloc((char*) "X_OCTET", NULL, rcvlen))
  411. != NULL);
  412. (void) strcpy(sendbuf, toTest);
  413. BT_ASSERT(tperrno == 0);
  415. int id = ::tpcall((char*) "tpcall_x_octet", (char *) sendbuf, sendlen,
  416. (char **) &rcvbuf, &rcvlen, (long) 0);
  417. BT_ASSERT(tperrno == 0);
  418. BT_ASSERT(id != -1);
  419. BT_ASSERT_MESSAGE(rcvbuf, strcmp(rcvbuf, toTest) == 0);
  420. }
  422. void TestTPCall::test_tpcall_without_TPNOTIME() {
  423. char* toTest = (char*) "test_tpcall_no_TPNOTIME";
  424. userlogc(toTest);
  425. tpadvertise((char*) "tpcall_x_octet", test_tpcall_TPNOTIME);
  427. sendlen = strlen(toTest) + 1;
  428. rcvlen = sendlen;
  429. BT_ASSERT((sendbuf
  430. = (char *) tpalloc((char*) "X_OCTET", NULL, sendlen)) != NULL);
  431. BT_ASSERT((rcvbuf = (char *) tpalloc((char*) "X_OCTET", NULL, rcvlen))
  432. != NULL);
  433. (void) strcpy(sendbuf, toTest);
  434. BT_ASSERT(tperrno == 0);
  436. int id = ::tpcall((char*) "tpcall_x_octet", (char *) sendbuf, sendlen,
  437. (char **) &rcvbuf, &rcvlen, 0);
  438. BT_ASSERT(tperrno == TPETIME);
  439. BT_ASSERT(id == -1);
  440. BT_ASSERT(strcmp(rcvbuf, toTest) == -1);
  441. }
  443. void TestTPCall::test_tpcall_with_TPNOTIME() {
  444. char* toTest = (char*) "test_tpcall_TPNOTIME";
  445. userlogc(toTest);
  446. tpadvertise((char*) "tpcall_x_octet", test_tpcall_TPNOTIME);
  448. sendlen = strlen(toTest) + 1;
  449. rcvlen = sendlen;
  450. BT_ASSERT((sendbuf
  451. = (char *) tpalloc((char*) "X_OCTET", NULL, sendlen)) != NULL);
  452. BT_ASSERT((rcvbuf = (char *) tpalloc((char*) "X_OCTET", NULL, rcvlen))
  453. != NULL);
  454. (void) strcpy(sendbuf, toTest);
  455. BT_ASSERT(tperrno == 0);
  457. int id = ::tpcall((char*) "tpcall_x_octet", (char *) sendbuf, sendlen,
  458. (char **) &rcvbuf, &rcvlen, TPNOTIME);
  459. BT_ASSERT(tperrno == 0);
  460. BT_ASSERT(id != -1);
  461. BT_ASSERT_MESSAGE(rcvbuf, strcmp(rcvbuf, toTest) == 0);
  462. }
  464. void test_tpcall_TPNOBLOCK(TPSVCINFO *svcinfo) {
  465. userlogc((char*) "test_tpcall_TPNOBLOCK");
  466. ::sleeper(5);
  467. tpreturn(TPSUCCESS, 0, svcinfo->data, svcinfo->len, 0);
  468. }
  470. void test_tpcall_TPNOTIME(TPSVCINFO *svcinfo) {
  471. userlogc((char*) "test_tpcall_TPNOTIME");
  472. ::sleeper(31);
  473. tpreturn(TPSUCCESS, 0, svcinfo->data, svcinfo->len, 0);
  474. }