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()
{
 
    /* データベースのオープン */
 
    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);     /* サーバの終了 */
  }
  return(0);
}

void
tpsvrdone()  /* サーバ終了ルーチン */

void
tpsvrdone()
{
 
     /* データベースのクローズ */ 
     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 システム */
#include <sqlcode.h>    /* BEA Tuxedo システム */
#include "bank.flds.h"  /* bankdb フィールド */
#include "aud.h"        /* 銀行業務アプリケーションの VIEW 定義 */
 
EXEC SQL begin declare section;
static long branch_id;  /* 支店番号 */
static float bal;       /* 残高 */
EXEC SQL end declare section;
 
/*
 * あるサイトの口座残高の合計を算出するサービス
 */
 
void
#ifdef __STDC__
ABAL(TPSVCINFO *transb)
 
#else
 
ABAL(transb)
TPSVCINFO *transb;
#endif
 
{
     struct aud *transv;         /* デコードされたメッセージの VIEW */
 
     /* tpsvcinfo データ バッファへのポインタの設定 */
 
     transv = (struct aud *)transb->data;
 
     set the consistency level of the transaction
 
     /* メッセージから支店番号を受け取り、照会を行う */
 
     EXEC SQL declare acur cursor for
      select SUM(BALANCE) from ACCOUNT;
     EXEC SQL open acur;         /* オープン */
     EXEC SQL fetch acur into :bal;   /* フェッチ */
     if (SQLCODE != SQL_OK) {      /* 何もなし */
      (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 /* tptypes が失敗したことを示す戻りコード */
#define INVALMTY 2 /* 無効なメッセージ タイプであることを示す戻りコード */
 
void
ABAL(transb)
 
TPSVCINFO *transb;
 
{
   struct aud *transv; /* VIEW メッセージ */
   FBFR *transf;  /* フィールド化バッファ メッセージ */
   int repc;  /* tpgetrply の戻りコード */
   char typ[TMTYPELEN+1], subtyp[TMSTYPELEN+1]; /* メッセージのタイプとサブタイプ */
   char *retstr;  /* tptypes が失敗した場合に返される文字列 */
 
/* 送信されたバッファ タイプを確認する。 */ 
   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);
   }
/* タイプに基づいてサービス要求を処理する方法を決定する。 */
   if (strcmp(typ, "FML") == 0) {
      transf = (FBFR *)transb->data;
... フィールド化バッファのための abal サービスを実行するコード...
 tpreturn が成功し、応答として FML バッファを送信する
   }
   else if (strcmp(typ, "VIEW") == 0 && strcmp(subtyp, "aud") == 0) {
      transv = (struct aud *)transb->data;
... aud 構造体のための abal サービスを実行するコード ...
 tpreturn の実行が成功し、応答として aud VIEW バッファを送信
   }
   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;     /* 印刷バッファ */
 
{
char prname[20], ocmd[30];     /* プリンタ名、出力コマンド */
long rlen;                     /* 応答バッファの長さ */
int prio;                      /* 要求の優先順位 */
FILE *lp_pipe;                 /* パイプ ファイルへのポインタ */
 
prio=tpgprio();
if (prio <= 20)
  (void)strcpy(prname,"bigjobs"); /* 優先順位の低い (冗長的) ジョブを
                                     大型コンピュータの中央
                                     レーザ プリンタに送信する。そこで
                                     出力をソートし、
                                     bin に保存する。 */
else if (prio <= 60)
  (void)strcpy(prname,roundrobin()); /* ローカルの小型レーザ プリンタの 1 つに
                                        プリンタを順に割り当てる。
                                        そのプリンタで直ちに出力される。
                                        プリンタの
                                        リストに従って、roundrobin() が
                                        実行される。 */
else
   (void)strcpy(prname,"hispeed");
                                   /* ジョブを高速レーザ 
                                      プリンタに割り当てる。
                                      冗長出力を毎日行う人のために
                                      予約されている。 */
 
(void)sprintf(ocmd, "lp -d%s", prname);   /* lp(1) 出力コマンド */
lp_pipe = popen(ocmd, "w");               /* コマンドへのパイプの作成 */
(void)fprintf(lp_pipe, "%s", pbuf->data); /* 出力の印刷 */
(void)pclose(lp_pipe);                    /* パイプのクローズ */
 
if ((pbuf->flags & TPNOREPLY))
   tpreturn(TPSUCCESS, 0, NULL, 0, 0);
rlen = strlen(prname) + 1;
pbuf->data = tprealloc(pbuf->data, rlen); /* 名前のために十分な領域を確保する。 */
(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 システム */
#include "atmi.h"       /* BEA Tuxedo システム */
#include "Usysflds.h"   /* BEA Tuxedo システム */
#include "userlog.h"    /* BEA Tuxedo システム */
#include "bank.h"       /* BANKING #defines */
#include "bank.flds.h"  /* bankdb フィールド */
 
 
/*
 * 振替元口座から振替先口座に 
 * 振り替えるサービス
 */
 
void
#ifdef __STDC__
TRANSFER(TPSVCINFO *transb)
 
#else
 
TRANSFER(transb)
TPSVCINFO *transb;
#endif
 
{
   FBFR *transf;          /* デコードされたメッセージのフィールド化バッファ */
   long db_id, cr_id;     /* 振替元口座と振替先口座の番号              */
   float db_bal, cr_bal;  /* 振替元口座と振替先口座の残高          */
   float tamt;            /* 振替額            */
   FBFR *reqfb;           /* 要求メッセージ用のフィールド化バッファ */
   int reqlen;            /* フィールド化バッファの長さ          */
   char t_amts[BALSTR];   /* 振替額を表す文字列        */
   char db_amts[BALSTR];  /* 振替元の口座残高を表す文字列  */
   char cr_amts[BALSTR];  /* 振替先の口座残高を示す文字列 */
 
/* tpsvcinfo データ バッファを指すポインタを設定 */
transf = (FBFR *)transb->data;
 
/* 振替元 (db_id) と振替先 (cr_id) の口座番号を取得 */
 
/* 振替元の口座番号が有効かどうかを確認 */
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);
}
/* 振替先の口座番号が有効かどうかを確認 */
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);
}
 
/* 振替金額 (払い戻し金額) を取得 */
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);
 
/* 振替金額が妥当かどうかを確認 */
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);
}
 
/* 引出要求バッファを作成 */
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);
 
/* 要求バッファに番号を格納 */
(void)Fchg(reqfb,ACCOUNT_ID,0,(char *)&db_id, (FLDLEN)0);
 
/* 要求バッファに金額を格納 */
(void)Fchg(reqfb,SAMOUNT,0,t_amts, (FLDLEN)0);
 
/* この引き出しの優先順位を上げる */
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);
}
 
/* 応答バッファから振替元口座の残高を取得 */
 
(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);
}
 
/* 要求バッファに振替先の口座番号を格納 */
(void)Fchg(reqfb,ACCOUNT_ID,0,(char *)&cr_id, (FLDLEN)0);
 
/* 要求バッファに振替金額を格納 */
(void)Fchg(reqfb,SAMOUNT,0,t_amts, (FLDLEN)0);
 
/* 振替 (預入) の関数の呼び出しの優先順位を上げる */
if (tpsprio(PRIORITY, 0L) == -1)
     (void)userlog("Unable to increase priority of deposit\n");
 
/* tpcall を実行して、振替先口座に振替金額を移動 */
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);
}
 
/* 応答バッファから振替先口座の残高を取得 */
 
(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);
}
 
/* 振替の成功を示す値を格納する応答バッファを設定 */
(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)

 ...
/* tpsvcinfo データ バッファへのポインタを設定 */ 
transf = (FBFR *)transb->data;
...
/* account に新規口座レコードを挿入 */ 
account_id = ++last_acct;    /* 新規口座番号を取得 */
tlr_bal = 0.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) {    /* レコードの挿入が失敗 */
      (void)Fchg(transf, STATLIN, 0,
          "Cannot update ACCOUNT", (FLDLEN)0);
       tpreturn(TPFAIL, 0, transb->data, 0L, 0);
}
 
/* 新規 last_acct で支店レコードを更新 */
 
EXEC SQL update BRANCH set LAST_ACCT = :last_acct where BRANCH_ID = :branch_id;
if (SQLCODE != SQL_OK) {      /* レコードの更新が失敗 */
       (void)Fchg(transf, STATLIN, 0,
           "Cannot update BRANCH", (FLDLEN)0);
        tpreturn(TPFAIL, 0, transb->data, 0L, 0);
}
/* 振替 (預金) の関数の呼び出しの優先順位を上げる */
if (tpsprio(PRIORITY, 0L) == -1)
     (void)userlog("Unable to increase priority of deposit\n");
 
/* tpforward を使用して同じバッファを預金サービスに転送し、最初の残高を設定 */
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)