int
tpsvrinit(int argc, char **argv)

tpsvrinit(argc, argv)
int argc;
char **argv;
{
        int c;
        extern char *optarg;
        extern int optind;
        .
        .
        .
        while((c = getopt(argc, argv, "f:x:")) != EOF)
            switch(c){
            .
            .
            .
            } 
        .
        .
        .
}

tpsvrinit()
{
 
    /* Open database */
 
    if (tpopen() == -1) {
          (void)userlog("tpsvrinit: failed to open database: ");
          switch (tperrno) {
             case TPESYSTEM:
                 (void)userlog("System 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(-1);     /* causes the server to exit */
   }
  return(0);
}

void
tpsvrdone()  /* Server termination routine */

void
tpsvrdone()
{
 
     /* 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;
}

char      name[32];
long      flags;
char      *data; 
long      len;
int       cd;
int       appkey;
CLIENTID  cltid;

#include <stdio.h>      /* UNIX */
#include <atmi.h>       /* BEA Tuxedo System */
#include <sqlcode.h>    /* BEA Tuxedo System */
#include "bank.flds.h"  /* bankdb fields */
#include "aud.h"        /* BANKING view defines */
 
EXEC SQL begin declare section;
static long branch_id;  /* branch id */
static float bal;       /* balance */
EXEC SQL end declare section;
 
/*
 * Service to find sum of the account balances at a SITE
 */
 
void
#ifdef __STDC__
ABAL(TPSVCINFO *transb)
 
#else
 
ABAL(transb)
TPSVCINFO *transb;
#endif
 
{
     struct aud *transv;         /* view of decoded message */
 
     /* Set pointer to TPSVCINFO data buffer */
 
     transv = (struct aud *)transb->data;
 
     set the consistency level of the transaction
 
     /* Get branch id from message, do query */
 
     EXEC SQL declare acur cursor for
      select SUM(BALANCE) from ACCOUNT;
     EXEC SQL open acur;         /* open */
     EXEC SQL fetch acur into :bal;   /* fetch */
     if (SQLCODE != SQL_OK) {      /* nothing found */
      (void)strcpy (transv->ermsg,"abal failed in sql aggregation"); 
      EXEC SQL close acur;
      tpreturn(TPFAIL, 0, transb->data, sizeof(struct aud), 0);
     }
     EXEC SQL close acur;
     transv->balance = bal;
     tpreturn (TPSUCCESS, 0, transb->data, sizeof(struct aud), 0);
}

#define TMTYPERR 1 /* return code indicating tptypes failed */
#define INVALMTY 2 /* return code indicating invalid message type */
 
void
ABAL(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);
   }
}

#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++]);
}

void
tpreturn(int rval, int rcode, char *data, long len, long flags)

#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);
}

void
tpcancel(int cd)

int cd1;
 .
 .
 .
      if ((cd1=tpacall(sname, (char *)audv, sizeof(struct aud),
         TPNOTRAN)) == -1) {
      .
      .
      .
      }
      if (tpgetrply(cd1, (char **)&audv,&audrl, 0) == -1) {
      if (tperrno == TPETIME) {
          tpcancel(cd1);
          .
          .
          .
         }
      }
      tpreturn(TPSUCCESS, 0,NULL, 0L, 0);

void
tpforward(char *svc, char *data, long len, long flags)

 ...
/* 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); 

int
tpadvertise(char *svcname, void *func)

tpunadvertise(char *svcname)
char *svcname;

extern void tlr_funcs()
 .
 .
 .
 if (tpadvertise("DEPOSIT", (tlr_funcs)(TPSVCINFO *)) == -1)
       check for errors;
 if (tpadvertise("WITHDRAW", (tlr_funcs)(TPSVCINFO *)) == -1)
       check for errors;
 if (tpunadvertise("TLR_INIT") == -1)
       check for errors;
 tpreturn(TPSUCCESS, 0, transb->data,0L, 0);

buildserver  -o filename -f filenames -l filenames -s -v

buildserver – o ACCT – f acct.o – s NEW_ACCT:OPEN_ACCT – s CLOSE_ACCT

#ifdef __cplusplus
extern "C"
#endif
MYSERVICE(TPSVCINFO *tpsvcinfo)