非同期メッセージの送信

この節では、次の操作を行う方法について説明します。

ここで説明する非同期の処理は、ファンアウト並列処理と呼ばれます。クライアントの要求が複数のサービスに同時に分散 (つまり「ファンアウト」) されて処理が行われるからです。

非同期要求の送信

int
tpacall(char *svc, char *data, long len, long flags)

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

tpacall( ) 関数の引数

引数	説明
svc	アプリケーションで提供されるサービス名を指すポインタ。
data	要求のデータ部分のアドレスを含むポインタ。このポインタは、tpalloc() の以前の呼び出しで割り当てられた型付きバッファを参照しなければなりません。idata の type (および指定されている場合は subtype) は、サービス・ルーチンで使用できる type (および指定されている場合は subtype) と合致する必要があります。タイプが合致しない場合、tperrno に TPEITYPE が設定され、関数の呼び出しが失敗します。 データが要求されていない場合、data に NULL ポインタを設定します。NULL ポインタが設定されていると、パラメータは無視されます。要求でデータが信されていない場合は、data のバッファを割り当てる必要はありません。
len	data で参照されるバッファ内の要求データの長さ。バッファが自己記述型の場合、つまり FML、FML32、VIEW、VIEW32、X_COMMON、X_C_TYPE、または STRING 型バッファの場合、この引数にゼロを設定すると引数が無視されます。
flags	フラグのオプション。論理演算子 OR を使用すると、複数のフラグをリストできます。この値にゼロを設定すると、デフォルトの方法で通信が行われます。有効なフラグとデフォルト値については、『BEA Tuxedo C リファレンス』の tpacall(3c) を参照してください。

例: TPNOTRAN と TPNOREPLY フラグを設定した非同期メッセージの送信

TPNOTRAN と TPNOREPLY フラグを設定した非同期メッセージの送信

#include <stdio.h>
#include "atmi.h"
 
main()
 
{
char *rbuf;         /* レポート用バッファ */
long rlen, rrlen;   /* レポート用の送信バッファと受信バッファの長さ */
 
  join application
 
if (rbuf = tpalloc("STRING", NULL, 0) == NULL) /* レポート用の領域の割り当て */
 error
(void)strcpy(rbuf, "REPORT=accrcv DBNAME=accounts");/* レポートのパラメータの送信 */
rlen = strlen(rbuf)+1;  /* 要求の長さ */
 
start transaction
 
if (tpcall("REPORT", rbuf, rlen, &rbuf, &rrlen, 0)
   == -1) /* レポート印刷ストリームの取得 */
   error
if (tpacall("PRINTER", rbuf, rrlen, TPNOTRAN|TPNOREPLY)
   == -1) /* プリンタへのレポートの送信 */
   error

. . .
commit transaction
free buffer
アプリケーションを終了
}

例: 非同期要求の送信

以下のコード例は、銀行の総残高照会を行う非同期呼び出しを示しています。銀行業務アプリケーションのデータは、複数のデータベース・サイトに分散されているので、各サイトに対して SQL クエリを実行する必要があります。その場合、データベース・サイトごとに支店番号が 1 つ選択され、そのサイトに対して ABAL または TBAL サービスが呼び出されます。支店番号は実際の SQL クエリでは使用されませんが、この番号によって BEA Tuxedo システムが適切なサイトに要求を送ることができるようになります。次のコードでは、サイトごとに for ループが tpacall() を一度呼び出しています。

非同期要求の送信

audv->balance = 0.0;
(void)strcpy(audv->ermsg, "");
 
for (i=0; i<NSITE; i++) {
 
  /* aud 構造体を用意します。 */
 
  audv->b_id = sitelist[i];/* このフィールドでルーティングを行います。 */
 
  /* tpacall の実行 */
 
  if ((cd[i]=tpacall(sname, (char *)audv, sizeof(struct aud), 0))
     == -1) {
     (void)fprintf (stderr,
        "%s:%s service request failed for site rep %ld\n",
        pgmname, sname, sitelist[i]);
        tpfree((char *)audv);
        return(-1);
  }
}

非同期応答の受信

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

int
tpgetrply(int *cd, char **data, long *len, long flags)

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

tpgetrply( ) 関数の引数

引数	説明
cd	tpacall() が返す呼び出し記述子を指すポインタ。
*data	応答を受信する出力バッファを指すポインタのアドレス。tpalloc() 関数を使用して、出力バッファを割り当てておく必要があります。tpcall() から正常に制御が戻ったときに、応答メッセージにデータが含まれていないと、*data にゼロが設定されます。ポインタと出力バッファの内容は変更されません。 要求メッセージと応答メッセージの両方に同じバッファを使用できます。その場合、odata には、入力バッファを割り当てたときに返されたポインタのアドレスを設定します。このパラメータが NULL を指している場合は、エラーになります。
len	応答データの長さを指すポインタ。このパラメータが NULL を指している場合は、エラーになります。
flags	フラグのオプション。論理演算子 OR を使用すると、複数のフラグをリストできます。この値にゼロを設定すると、デフォルトの方法で通信が行われます。有効なフラグとデフォルト値については、『BEA Tuxedo C リファレンス』の tpcall(3c) を参照してください。