サービス・ルーチンの終了

応答の送信

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

次の表は、tpreturn() 関数の引数を示しています。

tpreturn( ) 関数の引数

引数	説明
rval	サービスが正常に終了したかどうかをアプリケーション・レベルで示す値。この値は、シンボリック名で表される整数値です。有効な設定は、次のとおりです。 TPSUCCESS―関数呼び出しが成功したことを示します。関数は、応答メッセージを呼び出し元のバッファに格納します。つまり、応答メッセージがある場合は、呼び出し元のバッファ内にあります。 TPFAIL (デフォルト)―サービスが失敗したことを示します。関数は、応答を待つクライアント・プロセスにエラー・メッセージを通知します。その場合、クライアントが呼び出した tpcall() または tpgetrply() 関数が失敗し、変数 tperrno(5) にアプリケーション定義の失敗を示す TPESVCFAIL が設定されます。応答メッセージが要求されている場合、呼び出し元のバッファから取得できます。 TPEXIT―サービスが失敗したことを示します。関数は、応答を待つクライアント・プロセスにエラー・メッセージを通知して終了します。 この引数の値がグローバル・トランザクションに与える影響については、「グローバル・トランザクションのコーディング」を参照してください。
rcode	アプリケーション定義の戻りコードを呼び出し元に返します。クライアントは、グローバル変数 tpurcode(5) を照会して、rcode に返された値にアクセスできます。成功または失敗に関係なく、このコードは関数から返されます。
data	クライアント・プロセスに返される応答メッセージを指すポインタ。メッセージ・バッファは、tpalloc() を使用して既に割り当てられていることが必要です。 SVCINFO 構造体のサービスに渡されたバッファと同じものを使用する場合は、バッファの割り当ておよび解放について意識する必要はありません。この 2 つの処理は、システムで提供される main() 関数で行われます。このバッファは、tpfree() コマンドを使用しても解放できません。このコマンドを使ってバッファの解放を試みると失敗します。tprealloc() 関数を使用すると、バッファのサイズを変更できます。 サービス・ルーチンに渡されたバッファとは別のバッファを使ってメッセージを返す場合、自分でそのバッファを割り当てる必要があります。アプリケーション側で tpreturn() 関数が呼び出されると、バッファは自動的に解放されます。 応答メッセージを返す必要がない場合は、この引数に NULL ポインタを設定します。 注記 クライアントに応答を返す必要がない場合、つまり TPNOREPLY が設定されている場合、tpreturn() 関数は data と len 引数を無視して main() に制御を戻します。
len	応答バッファの長さ。アプリケーションはこの引数の値に、tpcall() 関数の olen パラメータ、または tpgetrply() 関数の len パラメータを使用してアクセスできます。 クライアントとして動作するプロセスは、この戻り値を使用して、応答バッファのサイズが大きくなったかどうか調べることができます。 クライアントが応答を要求していて応答バッファにデータが存在していない場合、つまり data 引数に NULL ポインタが設定されている場合、クライアントのバッファを変更せずに長さがゼロの応答が返されます。 data 引数が指定されていない場合、この引数の値は無視されます。
flag	現在使用されていません。

注記 次のコード例では、フィールド化バッファ transf 内の ACCOUNT_ID フィールドのゼロ番目のオカレンスに、アプリケーションが cr_id 変数から取得した「振替先口座」の識別子を移動しています。このような移動が必要なのは、FML バッファ内のフィールドのこのオカレンスが、データ依存型ルーティングに使用されるからです。詳細については、『BEA Tuxedo アプリケーションの設定』を参照してください。

withdrawal サービス呼び出しのシナリオは、DEPOSIT サービスへの呼び出しにも適用できます。呼び出しが成功すると、このサービスによってサービス・ルーチンに割り当てられていた応答バッファが解放され、rval 引数に TPSUCCESS が設定されて、適切な残高情報がステータス行に返されます。

tpreturn( ) 関数

#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"       /* 銀行業務アプリケーションのマクロ定義 */
#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;
 
/* 振替元と振替先の口座番号を取得します。 */
 
/* 振替元の口座番号が有効かどうかを確認します。 */
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);
 
/* WITHDRAWAL サービス呼び出しの優先順位を上げます。 */
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);
}

記述子の無効化

tpcancel() 関数の呼び出しには、次の文法を使用します。

void
tpcancel(int cd)

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

要求の転送

tpforward() 関数の呼び出しには、次の文法を使用します。

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

次の表は、tpreturn() 関数の引数を示しています。

tpreturn() 関数の引数

引数	説明
svc	要求が転送されるサービス名を指す文字型のポインタ。
data	クライアント・プロセスに返される応答メッセージを指すポインタ。メッセージ・バッファは、tpalloc() を使用して既に割り当てられていることが必要です。 SVCINFO 構造体のサービスに渡されたバッファと同じものを使用する場合は、バッファの割り当ておよび解放について意識する必要はありません。この 2 つの処理は、システムで提供される main() 関数で行われます。このバッファは、tpfree() コマンドを使用しても解放できません。このコマンドを使ってバッファの解放を試みると失敗します。tprealloc() 関数を使用すると、バッファのサイズを変更できます。 サービス・ルーチンに渡されたバッファとは別のバッファを使ってメッセージを返す場合、自分でそのバッファを割り当てる必要があります。アプリケーション側で tpreturn() 関数が呼び出されると、バッファは自動的に解放されます。 応答メッセージを返す必要がない場合は、この引数に NULL ポインタを設定します。 注記 クライアントに応答を返す必要がない場合、つまり TPNOREPLY が設定されている場合、tpreturn() 関数は data と len 引数を無視して main() に制御を戻します。
len	応答バッファの長さ。アプリケーションはこの引数の値に、tpcall() 関数の olen パラメータ、または tpgetrply() 関数の len パラメータを使用してアクセスできます。 クライアントとして動作するプロセスは、この戻り値を使用して、応答バッファのサイズが大きくなったかどうか調べることができます。 クライアントが応答を要求していて応答バッファにデータが存在していない場合、つまり data 引数に NULL ポインタが設定されている場合、クライアントのバッファを変更せずに長さがゼロの応答が返されます。 data 引数が指定されていない場合、この引数の値は無視されます。
flag	現在使用されていません。

要求の転送

注記 クライアントとして動作するサーバ・プロセスが応答を要求する場合、このサーバが自分自身からサービスを要求することはできません。つまり、必要なサービスの唯一のインスタンスが要求を行っているサーバ・プロセスからのみ提供される場合、その呼び出しは失敗して再帰呼び出しができないことが示されます。ただし、TPNOREPLY 通信フラグが設定された状態でサービス・ルーチンが自分宛てに要求を送信または転送した場合、サービスは自分からの応答を待機しないので、呼び出しは失敗しません。

tpforward( ) 関数

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