Notes: If you want to write your own versions of tpsvrinit() and tpsvrdone(), remember that the default versions of these two routines call tx_open() and tx_close(), respectively. If you write a new version of tpsvrinit() that calls tpopen() rather than tx_open(), you should also write a new version of tpsvrdone() that calls tpclose(). In other words, both functions in an open/close pair must belong to the same set.

Receiving Command-line Options

Opening a Resource Manager

Listing 5‑3 Closing a Resource Manager with tpsvrdone( )

voidtpsvrdone(){ /* Close the database */ if(tpclose() == -1) (void)userlog("tpsvrdone: failed to close database: "); switch (tperrno) { case TPESYSTEM: (void)userlog("BEA TUXEDO error\n"); break; case TPEOS: (void)userlog("Unix error %d\n",Uunixerr); break; case TPEPROTO: (void)userlog("Called in improper context\n"); break; case TPERMERR: (void)userlog("RM failure\n"); break; } return; } return;}

Listing 5‑4 Typical Service Definition

Listing 5‑5 Checking for Buffer Type

#define TMTYPERR 1 /* return code indicating tptypes failed */#define INVALMTY 2 /* return code indicating invalid message type */ voidABAL(transb) TPSVCINFO *transb; { struct aud *transv; /* view message */ FBFR *transf; /* fielded buffer message */ int repc; /* tpgetrply return code */ char typ[TMTYPELEN+1], subtyp[TMSTYPELEN+1]; /* type, subtype of message */ char *retstr; /* return string if tptypes fails */ /* find out what type of buffer sent */ if (tptypes((char *)transb->data, typ, subtyp) == -1) { retstr=tpalloc("STRING", NULL, 100); (void)sprintf(retstr, "Message garbled; tptypes cannot tell what type message\n"); tpreturn(TPFAIL, TMTYPERR, retstr, 100, 0); }/* Determine method of processing service request based on type */ if (strcmp(typ, "FML") == 0) { transf = (FBFR *)transb->data;... code to do abal service for fielded buffer ... tpreturn succeeds and sends FML buffer in reply } else if (strcmp(typ, "VIEW") == 0 && strcmp(subtyp, "aud") == 0) { transv = (struct aud *)transb->data;... code to do abal service for aud struct ... tpreturn succeeds and sends aud view buffer in reply } else { retstr=tpalloc("STRING", NULL, 100); (void)sprintf(retstr, "Message garbled; is neither FML buffer nor aud view\n"); tpreturn(TPFAIL, INVALMTY, retstr, 100, 0); }}

Listing 5‑6 Checking the Priority of a Received Request

#include <stdio.h>#include "atmi.h" char *roundrobin(); PRINTER(pbuf) TPSVCINFO *pbuf; /* print buffer */ {char prname[20], ocmd[30]; /* printer name, output command */long rlen; /* return buffer length */int prio; /* priority of request */FILE *lp_pipe; /* pipe file pointer */ prio=tpgprio();if (prio <= 20) (void)strcpy(prname,"bigjobs"); /* send low priority (verbose) jobs to big comp. center laser printer where operator sorts output and puts it in a bin */else if (prio <= 60) (void)strcpy(prname,roundrobin()); /* assign printer on a rotating basis to one of many local small laser printers where output can be picked up immediately; roundrobin() cycles through list of printers */else (void)strcpy(prname,"hispeed"); /* assign job to high-speed laser printer; reserved for those who need verbose output on a daily, frequent basis */ (void)sprintf(ocmd, "lp -d%s", prname); /* output lp(1) command */lp_pipe = popen(ocmd, "w"); /* create pipe to command */(void)fprintf(lp_pipe, "%s", pbuf->data); /* print output there */(void)pclose(lp_pipe); /* close pipe */ if ((pbuf->flags & TPNOREPLY)) tpreturn(TPSUCCESS, 0, NULL, 0, 0);rlen = strlen(prname) + 1;pbuf->data = tprealloc(pbuf->data, rlen); /* ensure enough space for name */(void)strcpy(pbuf->data, prname);tpreturn(TPSUCCESS, 0, pbuf->data, rlen, 0); char *roundrobin() {static char *printers[] = {"printer1", "printer2", "printer3", "printer4"};static int p = 0; if (p > 3) p=0;return(printers[p++]);}

Listing 5‑7 tpreturn( ) Function

#include <stdio.h> /* UNIX */#include <string.h> /* UNIX */#include "fml.h" /* BEA Tuxedo System */#include "atmi.h" /* BEA Tuxedo System */#include "Usysflds.h" /* BEA Tuxedo System */#include "userlog.h" /* BEA Tuxedo System */#include "bank.h" /* BANKING #defines */#include "bank.flds.h" /* bankdb fields */ /* * Service to transfer an amount from a debit account to a credit * account */ void#ifdef __STDC__TRANSFER(TPSVCINFO *transb) #else TRANSFER(transb)TPSVCINFO *transb;#endif { FBFR *transf; /* fielded buffer of decoded message */ long db_id, cr_id; /* from/to account id’s */ float db_bal, cr_bal; /* from/to account balances */ float tamt; /* amount of the transfer */ FBFR *reqfb; /* fielded buffer for request message*/ int reqlen; /* length of fielded buffer */ char t_amts[BALSTR]; /* string for transfer amount */ char db_amts[BALSTR]; /* string for debit account balance */ char cr_amts[BALSTR]; /* string for credit account balance */ /* Set pointr to TPSVCINFO data buffer */transf = (FBFR *)transb->data; /* Get debit (db_id) and credit (cr_id) account IDs */ /* must have valid debit account number */if (((db_id = Fvall(transf, ACCOUNT_ID, 0)) < MINACCT) || (db_id > MAXACCT)) { (void)Fchg(transf, STATLIN, 0,"Invalid debit account number",(FLDLEN)0); tpreturn(TPFAIL, 0, transb->data, 0L, 0);}/* must have valid credit account number */if ((cr_id = Fvall(transf, ACCOUNT_ID, 1)) < MINACCT || cr_id > MAXACCT) { (void)Fchg(transf,STATLIN, 0,"Invalid credit account number",(FLDLEN)0); tpreturn(TPFAIL, 0, transb->data, 0L, 0);} /* get amount to be withdrawn */if (Fget(transf, SAMOUNT, 0, t_amts, < 0) 0 || strcmp(t_amts,"") == 0) { (void)Fchg(transf, STATLIN, 0, "Invalid amount",(FLDLEN)0); tpreturn(TPFAIL, 0, transb->data, 0L, 0);}(void)sscanf(t_amts,"%f",tamt); /* must have valid amount to transfer */if (tamt = 0.0) { (void)Fchg(transf, STATLIN, 0, "Transfer amount must be greater than $0.00",(FLDLEN)0); tpreturn(TPFAIL, 0, transb->data, 0L, 0);} /* make withdraw request buffer */if ((reqfb = (FBFR *)tpalloc("FML",NULL,transb->len)) == (FBFR *)NULL) { (void)userlog("tpalloc failed in transfer\n"); (void)Fchg(transf, STATLIN, 0, "unable to allocate request buffer", (FLDLEN)0); tpreturn(TPFAIL, 0, transb->data, 0L, 0);}reqlen = Fsizeof(reqfb); /* put ID in request buffer */(void)Fchg(reqfb,ACCOUNT_ID,0,(char *)&db_id, (FLDLEN)0); /* put amount in request buffer */(void)Fchg(reqfb,SAMOUNT,0,t_amts, (FLDLEN)0); /* increase the priority of withdraw call */if (tpsprio(PRIORITY, 0L) == -1) (void)userlog("Unable to increase priority of withdraw\n"); if (tpcall("WITHDRAWAL", (char *)reqfb,0, (char **)&reqfb, (long *)&reqlen,TPSIGRSTRT) == -1) { (void)Fchg(transf, STATLIN, 0, "Cannot withdraw from debit account", (FLDLEN)0); tpfree((char *)reqfb); tpreturn(TPFAIL, 0,transb->data, 0L, 0);} /* get "debit" balance from return buffer */ (void)strcpy(db_amts, Fvals((FBFR *)reqfb,SBALANCE,0));void)sscanf(db_amts,"%f",db_bal);if ((db_amts == NULL) || (db_bal < 0.0)) { (void)Fchg(transf, STATLIN, 0, "illegal debit account balance", (FLDLEN)0); tpfree((char *)reqfb); tpreturn(TPFAIL, 0, transb->data, 0L, 0);} /* put deposit account ID in request buffer */(void)Fchg(reqfb,ACCOUNT_ID,0,(char *)&cr_id, (FLDLEN)0); /* put transfer amount in request buffer */(void)Fchg(reqfb,SAMOUNT,0,t_amts, (FLDLEN)0); /* Up the priority of deposit call */if (tpsprio(PRIORITY, 0L) == -1) (void)userlog("Unable to increase priority of deposit\n"); /* Do a tpcall to deposit to second account */if (tpcall("DEPOSIT", (char *)reqfb, 0, (char **)&reqfb, (long *)&reqlen, TPSIGRSTRT) == -1) { (void)Fchg(transf, STATLIN, 0, "Cannot deposit into credit account", (FLDLEN)0); tpfree((char *)reqfb); tpreturn(TPFAIL, 0,transb->data, 0L, 0);} /* get "credit" balance from return buffer */ (void)strcpy(cr_amts, Fvals((FBFR *)reqfb,SBALANCE,0));(void)sscanf(cr_amts,"%f",&cr_bal);if ((cr_amts == NULL) || (cr_bal 0.0)) { (void)Fchg(transf, STATLIN, 0, "Illegal credit account balance", (FLDLEN)0); tpreturn(TPFAIL, 0, transb->data, 0L, 0);} /* set buffer for successful return */(void)Fchg(transf, FORMNAM, 0, "CTRANSFER", (FLDLEN)0);(void)Fchg(transf, SAMOUNT, 0, Fvals(reqfb,SAMOUNT,0), (FLDLEN)0);(void)Fchg(transf, STATLIN, 0, "", (FLDLEN)0);(void)Fchg(transf, SBALANCE, 0, db_amts, (FLDLEN)0);(void)Fchg(transf, SBALANCE, 1, cr_amts, (FLDLEN)0);tpfree((char *)reqfb);tpreturn(TPSUCCESS, 0,transb->data, 0L, 0);}

Listing 5‑8 Invalidating a Reply After Timing Out

Figure 5‑1 Forwarding a Request

.../* set pointer to TPSVCINFO data buffer */ transf = (FBFR *)transb->data;.../* Insert new account record into ACCOUNT*/ account_id = ++last_acct; /* get new account number */tlr_bal = 0.0; /* temporary balance of 0 */ EXEC SQL insert into ACCOUNT (ACCOUNT_ID, BRANCH_ID, BALANCE,ACCT_TYPE, LAST_NAME, FIRST_NAME, MID_INIT, ADDRESS, PHONE) values(:account_id, :branch_id, :tlr_bal, :acct_type, :last_name, :first_name, :mid_init, :address, :phone);if (SQLCODE != SQL_OK) { /* Failure to insert */ (void)Fchg(transf, STATLIN, 0, "Cannot update ACCOUNT", (FLDLEN)0); tpreturn(TPFAIL, 0, transb->data, 0L, 0);} /* Update branch record with new LAST_ACCT */ EXEC SQL update BRANCH set LAST_ACCT = :last_acct where BRANCH_ID = :branch_id;if (SQLCODE != SQL_OK) { /* Failure to update */ (void)Fchg(transf, STATLIN, 0, "Cannot update BRANCH", (FLDLEN)0); tpreturn(TPFAIL, 0, transb->data, 0L, 0);}/* up the priority of the deposit call */if (tpsprio(PRIORITY, 0L) == -1) (void)userlog("Unable to increase priority of deposit\n"); /* tpforward same buffer to deposit service to add initial balance */tpforward("DEPOSIT", transb->data, 0L, 0);

Listing 5‑10 Dynamic Advertising and Unadvertising

Notes: The Oracle Tuxedo libraries are linked in automatically. You do not need to specify the Oracle Tuxedo library names on the command line.

Table of Contents