中间件编程

开发平台：
Java

DbService.c：源码内容
							/*
 * JBoss, Home of Professional Open Source
 * Copyright 2009, Red Hat, Inc., and others contributors as indicated
 * by the @authors tag. All rights reserved.
 * See the copyright.txt in the distribution for a
 * full listing of individual contributors.
 * This copyrighted material is made available to anyone wishing to use,
 * modify, copy, or redistribute it subject to the terms and conditions
 * of the GNU Lesser General Public License, v. 2.1.
 * This program is distributed in the hope that it will be useful, but WITHOUT A
 * WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS FOR A
 * PARTICULAR PURPOSE.  See the GNU Lesser General Public License for more details.
 * You should have received a copy of the GNU Lesser General Public License,
 * v.2.1 along with this distribution; if not, write to the Free Software
 * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston,
 * MA  02110-1301, USA.
 */
#include "tx/request.h"
#ifdef TX_RC
#include "testrm.h"
#ifndef TX_RC_RMID
#define TX_RC_RMID 202
#endif
/**
 * See if the request corresponds to a request to inject faults during
 * 2PC processing
 */
static void inject_fault(int xa_method, int type)
{
	userlogc( "TxLog inject_fault check type=0x%x", type);
	if (type & TX_TYPE_HALT) {
		fault_t fault = {0, TX_RC_RMID, O_XA_NONE, XA_OK, F_HALT, (void*) 0};
		if (type & TX_TYPE_PREPARE) {
			fault.op = O_XA_PREPARE;
			userlogc( "TxLog inject_fault adding halt on prepare");
		} else if (type & TX_TYPE_COMMIT) {
			fault.op = O_XA_COMMIT;
			userlogc( "TxLog inject_fault adding halt on commit");
		} else {
			userlogc( "TxLog inject_fault not adding fault ");
		}
		(void) dummy_rm_add_fault(&fault);
	}
}
#else
#define inject_fault(xa_method, type)
#endif
#ifdef UNITTEST
void tx_db_service(TPSVCINFO *svcinfo)
#else
void BAR(TPSVCINFO * svcinfo)
#endif
{
	test_req_t *req = (test_req_t *) svcinfo->data;
	test_req_t *resp = (test_req_t *) tpalloc((char*) "X_C_TYPE", (char*) "test_req", 0);
	product_t *p = products;
	userlogc_debug( "TxLog %s service %s running", __FUNCTION__, TXTEST_SVC_NAME);
	resp->status = -1;
	// see if the client wishes to inject a fault during 2PC protocol processing
	inject_fault(O_XA_COMMIT, req->txtype);
	for (p = products; p->id != -1; p++) {
		if (req->prod == p->id) {
			int rv;
			strncpy(req->db, p->dbname, sizeof(req->db));
			userlogc_debug("TxLog Service %s %4d: prod=%8s (id=%d) op=%c tx=0x%x data=%s", TXTEST_SVC_NAME,
					req->id, p->pname, p->id, req->op, req->txtype, req->data);
			rv = p->access(req, resp);
			userlogc_debug("TxLog Service %s %4d: resp->status=%d rv=%d", TXTEST_SVC_NAME, req->id, resp->status, rv);
			break;
		}
	}
	tpreturn(TPSUCCESS, resp->status, (char *) resp, sizeof (test_req_t), 0);
}

						