グローバル・トランザクションのコーディング

フィールド	説明
timeout	トランザクションがタイムアウトになるまでの時間 (秒単位)。この引数に 0 を指定すると、システムで可能な最長時間 (秒単位) に設定されます。つまり、timeout には、システムで定義された符号なし long 型の最大値が設定されます。 timeout に 0 または非現実的な大きな値を指定すると、システムによるエラー検出と報告が遅れる原因となります。timeout パラメータを使用すると、サービス要求に対する応答が妥当な時間内に確実に返されるようになります。また、ネットワーク障害などの問題が発生した場合に、コミットされる前にトランザクションを終了できます。応答を人が待っている場合、このパラメータには小さな値 (可能な場合は 30 秒未満) を設定します。生産システムの場合、timeout に大きな値を設定して、システムの負荷やデータベースの競合に起因する遅延に対応できるようにします。予測される平均応答時間を 2、3 倍した時間が最適です。注記 timeout 引数に設定する値は、BEA Tuxedo のアプリケーション管理者がコンフィギュレーション・ファイルに設定した SCANUNIT パラメータの値と一致していなければなりません。SCANUNIT パラメータには、タイムアウトになったトランザクションとサービス要求でブロックされた呼び出しがないかどうかを確認、つまりスキャンする頻度を指定します。このパラメータの値は、定期的なスキャンの間隔 (走査を行う間隔) を表します。 timeout パラメータには、走査を行う間隔より大きな値を設定します。timeout パラメータに設定された値が走査を行う間隔より小さいと、トランザクションがタイムアウトになる時間と、そのタイムアウトが検出される時間にずれが生じます。SCANUNIT のデフォルト値は 10 秒です。timeout パラメータの設定値についてはアプリケーション管理者と検討し、timeout に設定した値がシステム・パラメータの値と矛盾しないようにします。
flags	現在は定義されていません。0 を設定します。

フィールド

説明

timeout

トランザクションがタイムアウトになるまでの時間 (秒単位)。この引数に 0 を指定すると、システムで可能な最長時間 (秒単位) に設定されます。つまり、timeout には、システムで定義された符号なし long 型の最大値が設定されます。

timeout に 0 または非現実的な大きな値を指定すると、システムによるエラー検出と報告が遅れる原因となります。timeout パラメータを使用すると、サービス要求に対する応答が妥当な時間内に確実に返されるようになります。また、ネットワーク障害などの問題が発生した場合に、コミットされる前にトランザクションを終了できます。

応答を人が待っている場合、このパラメータには小さな値 (可能な場合は 30 秒未満) を設定します。

生産システムの場合、timeout に大きな値を設定して、システムの負荷やデータベースの競合に起因する遅延に対応できるようにします。予測される平均応答時間を 2、3 倍した時間が最適です。

注記 timeout 引数に設定する値は、BEA Tuxedo のアプリケーション管理者がコンフィギュレーション・ファイルに設定した SCANUNIT パラメータの値と一致していなければなりません。SCANUNIT パラメータには、タイムアウトになったトランザクションとサービス要求でブロックされた呼び出しがないかどうかを確認、つまりスキャンする頻度を指定します。このパラメータの値は、定期的なスキャンの間隔 (走査を行う間隔) を表します。

timeout パラメータには、走査を行う間隔より大きな値を設定します。timeout パラメータに設定された値が走査を行う間隔より小さいと、トランザクションがタイムアウトになる時間と、そのタイムアウトが検出される時間にずれが生じます。SCANUNIT のデフォルト値は 10 秒です。timeout パラメータの設定値についてはアプリケーション管理者と検討し、timeout に設定した値がシステム・パラメータの値と矛盾しないようにします。

flags

現在は定義されていません。0 を設定します。

#include <stdio.h> /* UNIX */
#include <string.h> /* UNIX */
#include <atmi.h> /* BEA Tuxedo システム */
#include <Uunix.h> /* BEA Tuxedo システム */
#include <userlog.h> /* BEA Tuxedo システム */
#include "bank.h" /* 銀行業務アプリケーションのマクロ定義 */
#include "aud.h" /* 銀行業務アプリケーションの VIEW 定義 */

#define INVI 0 /* 残高照会 */
#define ACCT 1 /* 残高照会 */
#define TELL 2 /* 窓口の残高照会 */

static int sum_bal _((char *, char *));
static long sitelist[NSITE] = SITEREP; /* 監査用マシンのリスト */
static char pgmname[STATLEN]; /* プログラム名 = argv[0] */
static char result_str[STATLEN]; /* 照会の結果を入れる配列 */

main(argc, argv)
int argc;
char *argv[];
{
int aud_type=INVI; /* 監査の種類－指定されていない場合は無効 */
int clarg; /* optind からのコマンド行引数のインデックス */
int c; /* オプション文字 */
int cflgs=0; /* コミットのフラグ。現在使用されていません。 */
int aflgs=0; /* アボートのフラグ。現在使用されていません。 */
int nbl=0; /* 支店リストのエントリ数 */
char svc_name[NAMELEN]; /* サービス名 */
char hdr_type[NAMELEN]; /* 出力の表題 */
int retc; /* sum_bal() の戻り値 */
struct aud *audv; /* audit バッファ構造体へのポインタ */
int audrl=0; /* audit の戻り値の長さ */
long q_branchid; /* 照会する支店番号 */

.. . /* コマンド行オプションの取得と変数の設定 */

/* アプリケーションへの参加 */

if (tpinit((TPINIT *) NULL) == -1) {
(void)userlog("%s:failed to join application¥n", pgmname);
exit(1);
}

/* グローバル・トランザクションの開始 */

if (tpbegin(30, 0) == -1) {
(void)userlog("%s:failed to begin transaction¥n", pgmname);
(void)tpterm();
exit(1);
}

if (nbl == 0) { /* 支店番号が指定されていないので、総勘定を計算 */
retc = sum_bal(svc_name, hdr_type); /* sum_bal ルーチンは省略 */

} else {

/* バッファの作成、およびデータ・ポインタの設定 */

if ((audv = (struct aud *)tpalloc("VIEW", "aud", sizeof(struct aud)))
== (struct aud *)NULL) {
(void)userlog("audit:unable to allocate space for VIEW¥n");
exit(1);
}

/* aud 構造体を用意します。 */

audv->b_id = q_branchid;
audv->balance = 0.0;
audv->ermsg[0] = '¥0';

/* tpcall の実行 */

if (tpcall(svc_name,(char *)audv,sizeof(struct aud),
(char **)audv,(long *)audrl,0) == -1){
(void)fprintf (stderr,"%s service failed¥n%s:%s¥n",
svc_name, svc_name, audv->ermsg);
retc = -1;

}else {

(void)sprintf(result_str,"Branch %ld %s balance is $%.2f¥n",
audv->b_id, hdr_type, audv->balance);
}
tpfree((char *)audv);
}

/* グローバル・トランザクションのコミット */

if (retc < 0) /* sum_bal の実行が失敗したので処理をアボート */
(void) tpabort(aflgs);
else {
if (tpcommit(cflgs) == -1) {
(void)userlog("%s:failed to commit transaction¥n", pgmname);
(void)tpterm();
exit(1);
}
/* トランザクションのコミットが成功した場合のみ、結果を出力 */
(void)printf("%s",result_str);
}

/* アプリケーションからの分離 */

if (tpterm() == -1) {
(void)userlog("%s:failed to leave application¥n", pgmname);
exit(1);
}

if (tpbegin(30, 0) == -1) {
(void)userlog("%s: failed to begin transaction¥n", argv[0]);
tpterm();
exit(1);
}
. . .
communication calls
. . .
if (tperrno == TPETIME){
if (tpabort(0) == -1) {
check for errors;
}
else if (tpcommit(0) == -1){
check for errors;
}
. . .

フィールド	説明
*t_id	トランザクション識別子を指すポインタ。
flags	現在使用されていません。将来使用するために予約されたフィールド。

フィールド

説明

*t_id

トランザクション識別子を指すポインタ。

flags

現在使用されていません。将来使用するために予約されたフィールド。

フィールド	説明
*t_id	トランザクション識別子を指すポインタ。
flags	現在使用されていません。将来使用するために予約されたフィールド。

フィールド

説明

*t_id

トランザクション識別子を指すポインタ。

flags

現在使用されていません。将来使用するために予約されたフィールド。

DEBIT(SVCINFO *s)
{
TPTRANID t;
tpsuspend(&t,TPNOFLAGS); /* 実行中のトランザクションを中断 */

tpbegin(30,TPNOFLAGS); /* 別のトランザクションを開始 */
別のトランザクションで処理を実行
tpcommit(TPNOFLAGS); /* トランザクションをコミット */

tpresume(&t,TPNOFLAGS); /* 最初のトランザクションを再開 */

.
.
.
tpreturn(. . . );
}

001 #include <stdio.h>
002 #include "atmi.h"
003
004 main()
005 {
006 char *sbuf, *rbuf;
007 long slen, rlen;
008 if (tpinit((TPINIT *) NULL) == -1)
009 error message, exit program;
010 if (tpbegin(30, 0) == -1)
011 error message, tpterm, exit program;
012 if ((sbuf=tpalloc("STRING", NULL, 100)) == NULL)
013 error message, tpabort, tpterm, exit program;
014 if ((rbuf=tpalloc("STRING", NULL, 2000)) == NULL)
015 error message, tpfree sbuf, tpabort, tpterm, exit program;
016 (void)strcpy(sbuf, "REPORT=accrcv DBNAME=accounts");
017 slen=strlen(sbuf);
018 if (tpcall("REPORT", sbuf, slen, &rbuf, &rlen, 0) == -1) {
019 switch(tperrno) {
020 case TPESVCERR:
021 fprintf(stderr,
022 "REPORT service's tpreturn encountered problems¥n");
023 break;
024 case TPESVCFAIL:
025 fprintf(stderr,
026 "REPORT service TPFAILED with return code of %d¥n", tpurcode);
027 break;
028 case TPEOTYPE:
029 fprintf(stderr,
030 "REPORT service's reply is not of any known data type¥n");
031 break;
032 default:
033 fprintf(stderr,
034 "REPORT service failed with error %d¥n", tperrno);
035 break;
036 }
037 if (tpabort(0) == -1){
038 check for errors;
039 }
040 }
041 else
042 if (tpcommit(0) == -1)
043 fprintf(stderr, "Transaction failed at commit time¥n");
044 tpfree(rbuf);
045 tpfree(sbuf);
046 tpterm();
047 exit(0);
048 }

001 #define BEGFAIL 3 /* tpbegin が失敗した場合に返す tpurcode の値を設定 */

002 void
003 OPEN_ACCT(transb)

004 TPSVCINFO *transb;

005 {
... other declarations ...
006 FBFR *transf; /* 復号化されたメッセージのフィールド化バッファ */
007 int dotran; /* tpbegin、tpcommit、tpabort のどれであるかを確認 */

008 /* tpsvcinfo データ・バッファへのポインタを設定 */

009 transf = (FBFR *)transb->data;

010 /* トランザクションがあるかどうかを確認し、ない場合は開始、ある場合は確認 */

011 dotran = 0;
012 if (tpgetlev() == 0) {
013 dotran = 1;
014 if (tpbegin(30, 0) == -1) {
015 Fchg(transf, STATLIN, 0,
016 "Attempt to tpbegin within service routine failed¥n");
017 tpreturn(TPFAIL, BEGFAIL, transb->data, 0, 0);
018 }
019 }
. . .