프로토타입

#include <atmi.h>
int tpstart (TPSTART_T *tpinfo )

파라미터

tpinfo는 TPSTART_T 라는 구조체에 대한 포인터(pointer)로 TPSTART라는 버퍼 타입을 사용하며, tpstart()를 호출하기 전에 반드시 tpalloc()에 의해 할당되어야 한다. 할당된 버퍼는 tpstart() 호출 후에 tpfree()를 통해 제거되어야 한다. 클라이언트는 시스템 연결할 때에 구조체 형식인 tpinfo 파라미터를 통해 필요한 정보를 넘긴다. tpinfo 파라미터는 클라이언트 정보, 비요청 메시지 처리 여부, 보안 정보 등을 포함한다.

tpinfo는 NULL 값을 사용할 수 있다. NULL인 경우 cltid, dompwd, usrname, usrpwd는 길이가 0인 string이 주어지고 Tmax 보안 특징을 사용하지 않으며 flags는 선택되지 않는다.

다음은 TPSTART_T 구조체의 구성이다.

struct TPSTART_T{
      char cltid[MAXTIDENT+2];  /*클라이언트명 (tpbroadcast())*/
      char dompwd[MAX_PASSWD_LENGTH+2];  /*시스템 접속 보안에 대한 암호*/
      char usrname[MAXTIDENT+2];   /*사용자 인증 보안에 대한 계정*/
      char usrpwd[MAX_PASSWD_LENGTH+2]; /*사용자 인증 보안에 대한 암호*/
      int flags; /*비요청 메시지 유형과 시스템 접근 방법결정*/
} ;

flags에 설정할 수 있는 값은 다음과 같다.

반환값

오류

tpstart()가 정상적으로 수행되지 않을 경우 tperrno에 다음 값 중 하나가 설정된다.

예제

#include <stdio.h>
#include <usrinc/atmi.h>
void main(int argc, char *argv[])
{
    int ret;
    char *buf;
    long len;
    TPSTART_T  *tpinfo;

    tpinfo = (TPSTART_T *)tpalloc(“TPSTART”, NULL, sizeof(TPSTART_T));
    if (tpinfo==NULL) { error processing }

    strcpy(tpinfo->cltname, “cli1”);
    strcpy(tpinfo->usrname, “navis”);
    strcpy(tpinfo->dompwd, “tmax”);
    tpinfo->flags = TPUNSOL_HND;
    ret=tpstart(tpinfo);
    if (ret==-1) { error processing }

    buf = (char *)tpalloc(“CARRAY”, NULL, 20);
    if (buf==NULL) {error processing };

    ret=tpcall(“SERVICE”, buf, 20, &buf, &len, TPNOFLAGS);
    if (ret==-1) { error processing }

    data process....
    tpfree((char *) buf);
    tpend();
}

관련 함수

tpend()

프로토타입

# include  <atmi.h>
int  tpend (void)

반환값

오류

tpend()가 정상적으로 수행되지 않을 경우 tperrno에 다음 값 중 하나가 설정된다.

예제

#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <usrinc/atmi.h>

void main(int argc, char *argv[])
{
    char    *sndbuf, *rcvbuf;
    long    rcvlen, sndlen;
    int     ret;

    ret=tpstart((TPSTART_T *)NULL)
    if (ret==-1) {error processing }

    buf = (char *)tpalloc(“STRING”, NULL, 0)
    if (buf=NULL) { error processing }

    data process …

    ret=tpcall(“SERVICE”, buf, 0, &buf, &len, TPNOFLAGS);
    if (ret==-1) { error processing }

    data process …
    printf(“ data: %s\n”, buf);
    tpfree((char *)buf);
    tpend();
}

관련 함수

tpstart()

프로토타입

# include <atmi.h>
int tpcall (char *svc, char *idata, long ilen, char **odata, long *olen, 
            long flags)

파라미터

flags로 사용 가능한 값은 다음과 같다.

반환값

오류

tpcall()가 정상적으로 수행되지 않을 경우 tperrno에 다음 값 중 하나가 설정된다.

예제

#include <stdio.h>
#include <usrinc/atmi.h>

void main(int argc, char *argv[])
{
    int ret;
    char *sndbuf, *rcvbuf;
    long sndlen,  rcvlen;
        
    ret=tpstart((TPSTART_T *)NULL);
    if (ret==-1) { error processing }
        
    sndbuf = (char *)tpalloc(“CARRAY”, NULL, 20);
    if (sndbuf==NULL) {error processing };

    rcvbuf = (char *)tpalloc(“CARRAY”, NULL, 20);
    if (rcvbuf==NULL) {error processing };

    data process....

    sndbuf=strlen(sndbuf);
    ret=tpcall(”SERVICE”, sndbuf, sndlen, &rcvbuf, &rcvlen, TPNOCHANGE);
    if (ret==-1) { error processing }

    data process....

    tpfree((char *)sndbuf);
    tpfree((char *)rcvbuf);
    tpend();
}

관련 함수

tpalloc(), tpacall(), tpgetrply(), tpreturn()

프로토타입

# include <atmi.h>
int tpacall (char *svc, char *data, long len, long flags)

파라미터

flags로 사용 가능한 값은 다음과 같다.

반환값

오류

tpacall()이 정상적으로 수행되지 않을 경우 tperrno에 다음 값 중 하나가 설정된다.

예제

#include <stdio.h>
#include <usrinc/atmi.h>
void main(int argc, char *argv[])
{
    char *buf;
    int ret,cd;
    long len;

    ret=tpstart((TPSTART_T *)NULL);
    if (ret<0) { error processing }

    buf = (char *)tpalloc(“CARRAY”, NULL, 20);
    if (buf==NULL) {error processing }
    data process....

    cd = tpacall(“SERVICE”, sndbuf, 20, TPNOTIME);
    if (cd<0) {error processing }
    data process…

    ret=tpgetrply(&cd, (char **)&buf, &len, TPNOTIME);
    if (ret<0) { error processing }
    data process....

    tpfree((char *)buf);
    tpend();
}

관련함수

tpalloc(), tpcall(), tpcancel(), tpgetrply()

프로토타입

# include <atmi.h>
int  tpgetrply(int *cd, char **data, long *len, long flags)

파라미터

flags로 사용 가능한 값은 다음과 같다.

반환값

오류

tpgetrply()가 정상적으로 수행되지 않을 경우 tperrno에 다음 값 중 하나가 설정된다.

예제

#include <stdio.h>
#include <usrinc/atmi.h>
void main(int argc, char *argv[])
{
    int ret;
    long len;
    char *buf;

    ret=tpstart((TPSTART_T *)NULL);
    if (ret==-1) { error processing }

    buf = (char *)tpalloc(“STRING”, NULL, 0);
    if (buf==NULL) { error processing }
    data process …

    cd = tpacall(“SERVICE”, buf, 0, TPNOFLAGS);
    if (cd==-1) { error procesing }
    data process....

    ret=tpgetrply(&cd, &buf, &len, TPNOTIME);
    if (ret==-1) { error processing }
    data process....

    tpfree(buf);
    tpend();
}

관련함수

tpacall(), tpalloc(), tpreturn()

프로토타입

# include <atmi.h>
int tpcancel (int cd)

파라미터

반환값

오류

tpcancel()이 정상적으로 수행되지 않을 경우 tperrno에 다음 값 중 하나가 설정된다.

예제

#include <stdio.h>
#include <usrinc/atmi.h>
void main(int argc, char *argv[]) 
{
    char *test[2];
    int ret, i, cd[2];
    long len;

    if (argc != 4) { error processing }
    ret=tpstart((TPSTART_T *)NULL;
    if (ret==-1) { error processing }

    for (i=0; i<3; i++)
    {
        test[i] = tpalloc(“STRING”,NULL,0);
        if (test[I])==NULL} { error processing }
        strcpy(test[i],argv[i+1]);
        cd[i]=tpacall(“SERVICE”, test[i], 0, TPNOTIME);
    )

    ret=tpcancel(cd[1]);         /* 2번째 응답을 취소한다. */
    if (ret==-1) { error processing }
    for (i=0; i<3; i++)
    {
        ret=tpgetrply(&cd[i], (char **)&test[i], &len, TPNOTIME)
        if (ret==-1) printf(“Can’t rcv data from service of %d\n”,cd[i]);
        else prtinf(“%dth rcv data : %s\n”, I+1, test[I]);
        tpfree(test[I]);
    }
    tpend();
}

관련함수

tpacall()

프로토타입

# include  <atmi.h>
int  tpconnect (char  *svc,  char  *data,  long  len,  long  flags)

파라미터

flags로 사용 가능한 값은 다음과 같다.

반환값

오류

tpconnect()가 정상적으로 수행되지 않을 경우 tperrno에 다음 값 중 하나가 설정된다. 특별한 언급이 없다면 함수 호출을 실패할 경우 호출자의 트랜잭션에 영향을 미치지 않는다.

예제

#include <stdio.h>
#include <usrinc/atmi.h>

void main(int argc, char *argv[])
{
    char *buf;
    int ret, cd;
    long len, revent;

    ret=tpstart((TPSTART_T *)NULL);
    if (ret==-1) { error processing }

    buf=tpalloc(“STRING”,NULL,0);
    if (buf=NULL) { error procesing }

    data process ....

    cd = tpconnect(“SERVICE”,sndbuf,0,TPRECVONLY);
    if (cd==-1) { error processing }
    data process.... 

    ret=tprecv(cd, &buf, &len, TPNOFLAGS, revent);
    if (ret==-1) { error processing }
    tpfree(buf);
    tpend();
}

관련함수

tpalloc(), tpdiscon(), tprecv(), tpsend()

프로토타입

# include <atmi.h>
int  tpsend (int  cd,  char  *data,  long  len,  long  flags,  long  *revent)

파라미터

flags로 사용 가능한 값은 다음과 같다.

revent에 전달되는 이벤트들은 다음과 같다.

반환값

반환할 경우 revent가 TREV_SVCFAIL이면, tpurcode 전역변수는 tpreturn()를 호출할 때에 전달된 rcode 값이 된다 .

오류

tpsend()가 정상적으로 수행되지 않을 경우 tperrno에 다음 값 중 하나가 설정된다.

예제

#include <stdio.h>
#include <usrinc/atmi.h>
#include “../sdl/demo.s”

main(int argc,char* argv[])
{
    int ret, cd;
    struct dat *buf;
    long revent, len;

    if (argc!=3) {error processing }
    ret=tpstart((TPSTART_T *)NULL);
    if (ret==-1) { error processing }

    buf=(struct dat *)tpalloc(“STRUCT”, “dat”, 0);
    if (buf==NULL) { error processing }
    strcpy(buf->sdata, argv[1]);
    data process….

    cd=tpconnect(“SERVICE”, buf, 0, TPSENDONLY);
    if (cd==-1) { error processing }
    strcpy(buf->sdata, argv[2]);
    data process….

    ret=tpsend(cd, buf, 0,TPRECVONLY,&revent);
    if (ret==-1) { error processing }

    ret=tprecv(&cd,(char**)&buf,&len,TPNOTIME,&revent);
    if (ret==-1) { error processing }
    data process....

    tpfree(buf);
    tpend();
}

관련함수

tpalloc(), tpconnect(), tpdiscon(), tprecv(), tpreturn()

프로토타입

# include <atmi.h>
int  tprecv (int cd, char **data, long *len, long flags, long *revent)

파라미터

flags로 사용 가능한 값은 다음과 같다.

다음은 revent에 반환되는 이벤트 유형에 대한 설명이다.

반환값

revent 값이 TREV_SVCSUCC이거나 TREV_SVCFAIL인 경우, tpreturn()으로 전달되는 tpurcode 전역 변수는 애플리케이션에서 정의한 값을 갖게 된다. 그렇지 않으면 -1을 반환하고, tperrno에 에러 상황에 해당하는 값이 설정된다. 에러 없이 이벤트가 존재한다면 tprecv()는 -1을 반환하고 tperrno는 [TPEEVENT]가 된다.

오류

tprecv()가 정상적으로 수행되지 않을 경우 tperrno에 다음 값 중 하나가 설정된다.

예제

#include <stdio.h>
#include <usrinc/atmi.h>
#include “../sdl/demo.s”

main(int argc,char* argv[])
{
    int ret, cd;
    struct dat *buf;
    long revent, len;

    if (argc!=3) {error processing }
    ret=tpstart((TPSTART_T *)NULL);
    if (ret==-1) { error processing }

    buf=(struct dat *)tpalloc(“STRUCT”, “dat”, 0);
    if (buf==NULL) { error processing }
    strcpy(buf->sdata, argv[1]);
    data process….

    cd=tpconnect(“SERVICE”, buf, 0, TPSENDONLY);
    if (cd==-1) { error processing }
    strcpy(buf->sdata, argv[2]);
    data process….

    ret=tpsend(cd, buf, 0,TPRECVONLY,&revent);
    if (ret==-1) { error processing }

    ret=tprecv(cd,(char**)&buf,&len,TPNOTIME,&revent);
    if (ret==-1) { error processing }
    data process....

    tpfree(buf);
    tpend();
}

관련함수

tpalloc(), tpconnect(), tpdiscon(), tpsend()

프로토타입

# include  <atmi.h>
int  tpdiscon (int cd)

파라미터

반환값

오류

tpdiscon()이 정상적으로 수행되지 않을 경우 tperrno에 다음 값 중 하나가 설정된다.

예제

#include <stdio.h>
#include <stdlib.h>
#include <usrinc/atmi.h>

void main(int argc, char *argv[])
{
    int ret, cd;
    char *buf
    long len, revent;

    ret=tpstart((TPSTART_T *)NULL);
    if (ret==-1) { error processing }

    buf=tpalloc(“STRING”, NULL, 0);
    if (buf==NULL) { error processing }

    data process....
    cd=tpconnect(“SERVICE”,buf,0,TPRECVONLY);

    if (cd==-1) { error processing }
    data process....
    ret=tprecv(cd, (char **)&buf, &len, TPNOFLAGS, &revent);
    if (ret==-1 && revent != TPEV_SENDONLY && revent != TPEV_SVCSUCC)
    { error processing }
    printf(“received data = %s\n”, buf);
    if (atoi(buf)>90) {
        ret=tpdiscon(cd);
        if (ret==-1) {error processing }
        tpfree(buf);
        tpend();
        exit(1);
    }

    data process....
    tpfree(buf);
    tpend();
}

관련함수

tpconnect(), tprecv(), tpreturn(), tpsend()

프로토타입

# include  <atmi.h>
Unsolfunc *tpsetunsol (void ( *disp ) ( char  *data,  long  len,  long  flags ) )

파라미터

반환값

오류

tpsetunsol()이 정상적으로 수행되지 않을 경우 tperrno에 다음 값 중 하나가 설정된다.

예제

#include <stdio.h>
#include <usrinc/atmi.h>
#include “../sdl/demo.s”

void get_unsol(char *data, long len, long flags)
{
    printf(“get unsolicited data = %s\n”, data);
    data process....
}

void main(int argc, char *argv[])
{
    int ret;
    char *buf;
    long len;

    ret=tpstart((TPSTART_T *)NULL);
    if (ret==-1) { error processing }
    ret=tpsetupsol_flag(TPUNSOL_HND);
    if (ret==-1) { error processing }

    ret=tpsetunsol(get_unsol);
    if (ret==TPUNSOLERR) { error processing }

    buf = (char *)tpalloc(“CARRAY”, NULL, 20);
    if (buf==NULL) {error processing };
    data process... 

    ret=tpcall(“SERVICE”, buf, 20, (char **)&buf, &len, TPNOFLAGS);
    if (ret==-1) { error processing }
    data process... 

    tpfree((char *)buf);
    tpend();
}

관련함수

tpstart(), tpend(), tpgetunsol()

프로토타입

#include <tmaxapi.h>
int  tpgetunsol (int type, char **data, long *len, long flags)

파라미터

flags로 사용 가능한 값은 다음과 같다.

반환값

오류

tpgetunsol()이 정상적으로 수행되지 않을 경우 tperrno에 다음 값 중 하나가 설정된다.

예제

#include <stdio.h>
#include <string.h>
#include <usrinc/tmaxapi.h>

void main(int argc, char *argv[])
{
    int ret;
    char *buf;
    long len;

    ret=tpstart((TPSTART_T *)NULL);
    if (ret==-1) { error processing }

    buf=tpalloc(“STRING”, NULL, 0);
    if (buf==NULL) { error processing }
    data process....

    while(1)
    {
        ret=tp_sleep(2);
        if (ret==-1) { error processing }

        if (ret==0) 
            printf(“nothing happened\n”);
        else {
            ret=tpgetunsol(UNSOL_TPSENDTOCLI, (char **)&buf, &len, TPNOCHANGE);
            if (ret==-1) { error processing }
            printf(“received data : %s\n”, buf);
        }

        data process....
        if (strncmp(buf, “end”, 3)==0) break;
    }

    data process....
    tpfree(buf);
    tpend();
}

관련함수

tpbroadcast(), tpsetunsol(), tpstart(), tpend()

프로토타입

#include <tmaxapi.h>
int  tpset_timeout (int sec)

파라미터

반환값

오류

tpset_timeout()이 정상적으로 수행되지 않을 경우 tperrno에 다음 값 중 하나가 설정된다.

예제

#include <stdio.h>
#include <usrinc/atmi.h>
#include <usrinc/tmaxapi.h>

void main(int argc, char *argv[])
{
    int ret;
    char *sndbuf, *rcvbuf;
    long sndlen,  rcvlen;
        
    ret=tpstart((TPSTART_T *)NULL);
    if (ret==-1) { error processing }
        
    sndbuf = (char *)tpalloc(“CARRAY”, NULL, 20);
    if (sndbuf==NULL) {error processing };
    rcvbuf = (char *)tpalloc(“CARRAY”, NULL, 20);
    if (rcvbuf==NULL) {error processing };
    data process....

    sndbuf=strlen(sndbuf);
    ret=tpset_timeout(4);
    if (ret==-1) { error processing }

    ret=tpcall(“SERVICE”, sndbuf, sndlen, &rcvbuf, &rcvlen, TPNOCHANGE);
    if (ret==-1) { error processing }
    data process....

    tpfree((char *)sndbuf);
    tpfree((char *)rcvbuf);
    tpend();
}

프로토타입

#include <tmaxapi.h>
int  tpsetsvctimeout (int sec, long flags)

파라미터

반환값

오류

tpsetsvctimeout()이 정상적으로 수행되지 않을 경우 tperrno에 다음 값 중 하나가 설정된다.

예제

#include <stdio.h>
#include <usrinc/atmi.h>
#include <stdlib.h>
#include <usrinc/tmaxapi.h>
#include <usrinc/tdlcall.h>

TOUPPER(TPSVCINFO *msg)
{
        int             i;  

        if ( tpsetsvctimeout(10, 0) < 0 )
              ;
            //error handle code 
        printf("TOUPPER service is started!\n");
        sleep(15);
        printf("INPUT : data=%s\n", msg->data);

        for (i = 0; i < msg->len; i++) 
                msg->data[i] = toupper(msg->data[i]);
        printf("OUTPUT: data=%s\n", msg->data);
        tpreturn(TPSUCCESS,0,(char *)msg->data, 0,0);
} 

프로토타입

# include <atmi.h>
char * tpalloc (char *type, char *subtype, long size)

파라미터

반환값

오류

tpalloc()가 정상적으로 수행되지 않을 경우 tperrno에 다음 값 중 하나가 설정된다.

예제

#include <stdio.h>
#include <usrinc/atmi.h>
#include “../sdl/demo.s”

void main(int argc, char *argv[])
{
    int ret;
    struct data *buf;
    long len;

    ret=tpstart((TPSTART_T *)NULL);
    if (ret<0) { error processing }
    buf=(struct data *)tpalloc(“STRUCT”, “data”,0);
    data process....

    ret=tpcall(“SERVICE”, (char *)sndbuf, 0, (char **)&rcvbuf, &len, TPNOFLAGS);
    if (ret<0) {error processing }
    data process....
    tpfree((char *)buf);
    tpend();
}

관련함수

tpfree(), tprealloc(), tptypes()

프로토타입

# include <atmi.h>
char  * tprealloc (char *ptr, long size)

파라미터

반환값

오류

tprealloc()가 정상적으로 수행되지 않을 경우 tperrno에 다음 값 중 하나가 설정된다.

예제

#include <stdio.h>
#include <usrinc/atmi.h>
void main(int argc, char *argv[])
{
    char *buf;
    buf=tpalloc(“STRING”,NULL,10);
    if (buf==NULL) { error processing }
    buf=tprealloc(buf,20);  /* ok */
    if (buf==NULL) { error processing }

    buf=”test”;
    buf=tprealloc(buf,30);  /*error : TPEINVAL */
    if (buf==NULL) { error processing }
}

관련함수

tpalloc(), tpfree(), tptypes()

프로토타입

# include <atmi.h>
void  tpfree(char *ptr)

파라미터

반환값

tpfree()는 함수 호출자에게 아무런 값도 반환하지 않는다.

예제

#include <usrinc/atmi.h>
#include <stdio.h>
#include “../sdl/demo.s”

void main(int argc, char *argv[])
{
    int ret;
    struct data *buf;
    char *message, *message2;

    ret=tpstart((TPSTART_T *)NULL);
    if (ret==-1) { error processing }

    buf=(struct data *)tpalloc(“STRUCT”, “data”,0);
    if (buf==NULL) { error processing }
    message=tpalloc(“STRING”, NULL, 0);
    if (message==NULL) { error processing }

    message2=tpalloc(“CARRAY”, NULL, 20);
    if (message==NULL) { error processing }

    data process....
    tpfree((char *)buf);
    tpfree(message);
    tpfree((char *)message2);
    tpend();
}

관련함수

tpalloc(), tprealloc()

프로토타입

#include <atmi.h>
long  tptypes (char  *ptr, char  *type, char  *subtype )

파라미터

반환값

오류

tptypes()가 정상적으로 수행되지 않을 경우 tperrno에 다음 값 중 하나가 설정된다.

예제

#include <stdio.h>
#include <usrinc/atmi.h>
#include “../sdl/demo.s”
main(int argc, char *argv[])
{
    int ret;
    struct sel_o *rcvbuf;
    char type[9], subtype[17];
    long size;

    ret=tpstart((TPSTART_T *)NULL);
    if (ret==-1) { error processing }
    buf=(struct sel_o*)tpalloc(“STRUCT”,”sel_o”,0);
    if (buf==NULL) {error processing };

    size =tptypes((char*)buf, type,subtype);
    if (size==-1) {error processing };
    printf (“buf : size %d, type %s, subtype %s\n\n”, size, type, subtype); 

    /*rcvbuf : size 1024, type STRUCT, subtype sel_o */
    data process...
    tpfree((char *)buf);
    tpend();
}

관련함수

tpalloc(), tpfree(), tprealloc()

프로토타입

#include <tx.h>
int  tx_begin (void)

반환값

오류

tx_begin()이 정상적으로 수행되지 않을 경우 다음의 에러 코드를 반환한다.

예제

#include <stdio.h>
#include <usrinc/atmi.h>
#include <usrinc/tx.h>

void main(int argc, char *argv[])
{
    char *buf;
    int ret,cd;
    long len, revent;

    ret=tpstart((TPSTART_T *)NULL);
    if (ret==-1) { error processing }

    buf = (char *)tpalloc(“CARRAY”, NULL, 20);
    if (buf==NULL) {error processing };

    data process.…

    ret=tx_set_transaction_timeout( 5 );
    if (ret<0) { error processing }

    ret=tx_begin();
    if (ret<0) { error processing }

    cd = tpconnect(“SERVICE”, buf, 20, TPRECVONLY);
    if (cd==-1) { error processing }

    ret = tprecv(cd, (char **)&buf, &len,TPNOFLAGS, &revent)};
    if (ret < 0 && revent != TPEV_SVCSUCC)  
        tx_rollback();
    else    
        tx_commit(); 

    data process....

    tpfree((char *)buf);
    tpend();
}

관련함수

tx_commit(), tx_open(), tx_rollback(), tx_set_transaction_timeout()

프로토타입

# include  <tx.h>
int  tx_commit(void)

반환값

오류

tx_commit()이 정상적으로 수행되지 않을 경우 다음의 에러 코드를 반환한다.

예제

#include <stdio.h>
#include <usrinc/atmi.h>
#include <usrinc/tx.h>

void main(int argc, char *argv[])
{
    char *buf;
    int ret,cd;
    long len, revent;

    ret=tpstart((TPSTART_T *)NULL);
    if (ret==-1) { error processing }

    buf = (char *)tpalloc(“CARRAY”, NULL, 20);
    if (buf==NULL) {error processing };

    data process.…

    ret=tx_set_transaction_timeout( 5 );
    if (ret<0) { error processing }

    ret=tx_begin();
    if (ret<0) { error processing }

    cd = tpconnect(“SERVICE”, buf, 20, TPRECVONLY);
    if (cd==-1) { error processing }

    ret = tprecv(cd, (char **)&buf, &len,TPNOFLAGS, &revent)};
    if (ret < 0 && revent != TPEV_SVCSUCC)  
       tx_rollback();
    else
       tx_commit();

    data process....
    tpfree((char *)buf);
    tpend();
}

관련함수

tx_begin(), tx_set_commit_return(), tx_set_transaction_control(), tx_set_transaction_timeout()

프로토타입

#include  <tx.h>
int tx_info (TXINFO  *info)

파라미터

info가 NULL이 아니라면 info가 가리키는 TXINFO 구조체는 전역 트랜잭션에 관한 정보가 된다.

TXINFO 구조체는 아래와 같이 구성되어 있다.

struct TXINFO {
       XID                      xid;
       COMMIT_RETURN            when_return;
       TRANSACTION_CONTROL      transaction_control;
       TRANSACTION_TIMEOUT      transaction_timeout;
       TRANSACTION_STATE        transaction_state;
};

tx_info()가 트랜잭션 모드에서 호출된다면 xid는 현재 트랜잭션 branch id가 되고 transaction_state는 현재 트랜잭션의 상태가 된다. 호출자가 트랜잭션 모드에 있지 않다면, xid는 NULL XID가 된다. 자세한 내용은 <tx.h>를 참고한다.

호출자가 트랜잭션 모드에 있는 것과 관계없이 when_return, transaction_control, 그리고 transaction_timeout은 commit_return의 현재 설정과 transaction_control 특성, 그리고 초 단위의 트랜잭션 타임아웃 값을 포함한다.

반환된 트랜잭션 타임아웃 값은 다음 트랜잭션이 시작될 때부터 사용된다. 현재 트랜잭션이 시작된 후에 tx_set_transaction_timeout() 호출을 통해 트랜잭션 타임아웃값을 변경했을 수도 있기 때문에 호출자의 현재 전역 트랜잭션에 대한 타임아웃 값이 아닐 수도 있다. info가 NULL이라면, TXINFO 구조체는 반환되지 않는다.

같은 전역 트랜잭션 내에서 계속적인 tx_info() 호출은 동일한 gtrid(전역 트랜잭션 구분자)의 XID 제공을 보장한다. 하지만 반드시 동일한 bqual(로컬 트랜잭션 구분자)을 보장하지는 않는다. XID는 동일하지 않을 수 있다.

반환값

오류

tx_info()가 정상적으로 수행되지 않을 경우 다음의 에러 코드를 반환한다.

예제

#include <stdio.h>
#include <string.h>
#include <usrinc/atmi.h>
#include <usrinc/tx.h>
void main(int argc, char *argv[])
{
    int ret;
    long len;
    char *buf;
    TXINFO info;

    ret=tpstart((TPSTART_T *)NULL);
    if (ret==-1) { error processing }

    buf = (char *)tpalloc(“CARRAY”, NULL, 20);
    if (buf==NULL) {error processing };
    data process....
    ret=tx_begin();
    if (ret<0) { error processing }
 
    ret=tpcall(“SERVICE”, buf, 20, (char **)&buf, &len, TPNOFLAGS);
    if (ret==-1) { error processing }

    if (tx_info(&info)==1) printf(“In transaction \n”);
    else printf(“Not in transaction \n”);

    if (strncmp(buf, “err”, 3)==0) tx_rollback();
    else  tx_commit();

    data process....
    tpfree((char *)buf);
    tpend();
}

관련함수

tx_open(), tx_set_commit_return(), tx_set_transaction_control(), tx_set_transaction_timeout()

프로토타입

#include  <tx.h>
int  tx_rollback(void)

반환값

오류

tx_rollback()이 정상적으로 수행되지 않을 경우 다음의 에러 코드를 반환한다.

예제

#include <stdio.h>
#include <usrinc/atmi.h>
#include <usrinc/tx.h>

void main(int argc, char *argv[])
{
    char *buf;
    int ret,cd;
    long len, revent;

    ret=tpstart((TPSTART_T *)NULL);
    if (ret==-1) { error processing }
 
    buf = (char *)tpalloc(“CARRAY”, NULL, 20);
    if (buf==NULL) {error processing };
    data process.…
    ret=tx_set_transaction_timeout( 5 );
    if (ret<0) { error processing }

    ret=tx_begin();
    if (ret<0) { error processing }

    cd = tpconnect(“SERVICE”, buf, 20, TPRECVONLY);
    if (cd==-1) { error processing }
    ret = tprecv(cd, (char **)&buf, &len,TPNOFLAGS, &revent)};
    if (ret < 0 && revent != TPEV_SVCSUCC)  tx_rollback();
    else    tx_commit();
    data process....

    tpfree((char *)buf);
    tpend();
}

관련함수

tx_begin(), tx_set_transaction_control(), tx_set_transaction_timeout()

프로토타입

# include  <tx.h>
int  tx_set_transaction_timeout (TRANSACTION_TIMEOUT  timeout)

파라미터

반환값

오류

tx_set_transaction_timeout()은 기존의 transaction_timeout 값의 변경 없이 다음의 에러 코드를 반환한다.

예제

#include <usrinc/atmi.h>
#include <usrinc/tx.h>

void main(int argc, char *argv[]) 
{
    int ret;
    long len;
    char *buf;

    ret=tpstart((TPSTART_T *)NULL);
    if (ret==-1) { error processing }

    buf = (char *)tpalloc(“STRING”, NULL, 0);
    if (buf==NULL) {error processing };

    ret=tx_set_transaction_timeout( 5 );
    if (ret<0) { error processing }

    ret=tx_begin();
    if (ret<0) { error processing }
    ret = tpcall(“SERVICE”, (char *)buf, strlen(buf), (char **)&buf, &len, 
                   TPNOFLAGS);
    if (ret == -1) {
        tx_rollback();
        error processing
    }
    data process ….
    ret = tx_commit();
    if (ret < 0) { error processing }

    data process...
    tpfree((char *)buf);
    tpend();
}

관련함수

tx_begin(), tx_commit(), tx_open(), tx_rollback(), tx_info()

프로토타입

# include  <tx.h>
int  tx_set_transaction_control(TRANSACTION_CONTROL  control)

파라미터

control로 사용 가능한 값은 다음과 같다.

반환값

오류

tx_set_transaction_control()은 기존의 transaction_control 특성 변경없이 다음의 에러 코드를 반환한다.

예제

#include <usrinc/atmi.h>
#include <usrinc/tx.h>

int main(int argc, char *argv[])
{
    int ret;
    long len;
    char *buf;

    ret = tpstart((TPSTART_T *)NULL);
    if (ret == -1) { error processing }

    buf = (char *)tpalloc(“CARRAY”, NULL, 20);
    if (buf==NULL) {error processing };
    ret = tx_set_transaction_timeout(5);
    if (ret < 0){ error processing }
 
    ret = tx_set_transaciont_control(TX_UNCHAINED);
    if (ret < 0){ error processing }
    ret = tx_begin();
    if (ret < 0) { error processing }
    data process....

    ret = tpcall(“SERVICE1”, (char *)buf, strlen(buf), (char **)&buf, &len, 
                  TPNOFLAGS);
    if (ret == -1)
    {
        tx_rollback();
        error processing
    }

    data process...
    ret = tpcall(“SERVICE2”, (char *)buf, strlen(buf), (char **)&buf, &len, 
                   TPNOFLAGS);
    if (ret == -1)
    {
        tx_rollback();
        error processing
    }
    data process ….

    ret = tx_commit();
    if (ret < 0) { error processing }
    data process...

    tpfree((char *)buf);
    tpend();
}

관련함수

tx_begin(), tx_commit(), tx_open(), tx_rollback(), tx_info()

프로토타입

#include  <tx.h>
int  tx_set_commit_return (COMMIT_RETURN  when_return)

파라미터

when_return으로 사용 가능한 값은 다음과 같다.

반환값

성공적으로 작업이 완료된 경우 tx_set_commit_return()은 음이 아닌 값의 [TX_OK]를 반환한다.

when_return이 TX_COMMIT_COMPLETED 또는 TX_COMMIT_DECISION_LOGGED으로 설정되지 않았다면, 함수는 음이 아닌 값으로 [TX_NOT_SUPPORTED]를 반환하고, commit_return 특성은 현재 적용되고 있는 값이 여전히 유효하다. 트랜잭션 관리자는 when_return을 최소한 TX_COMMIT_COMPLETED나 TX_COMMIT_DECISION_LOGGED 중의 하나로는 설정해야 한다.

함수 호출에 실패한 경우 에러 코드를 반환한다.

오류

tx_set_commit_return()는 commit_return 특성 설정 변경없이 음수값 중 하나를 반환한다.

예제

#include <usrinc/tx.h>

int main(int argc, char *argv[])
{
    int ret;
    long len;
    char *buf;

    ret = tpstart((TPSTART_T *)NULL);
    if (ret == -1) { error processing }

    buf = (char *)tpalloc(“CARRAY”, NULL, 20);
    if (buf==NULL) {error processing };
    ret = tx_set_transaction_timeout(5);
    if (ret < 0){ error processing }

    ret = tx_set_commit_return(TX_COMMIT_COMPLETED);
    if (ret < 0){ error processing }

    ret = tx_begin();
    if (ret < 0){ error processing }

    data process....
    ret = tpcall(“SERVICE1”, (char *)buf, strlen(buf), (char **)&buf, &len, 
                   TPNOFLAGS);
    if (ret == -1)
    {
        tx_rollback();
        error processing
    }

    data process...
    ret = tpcall(“SERVICE2”, (char *)buf, strlen(buf), (char **)&buf, &len, 
                   TPNOFLAGS);
    if (ret == -1)
    {
        tx_rollback();
        error processing
    }

    data process ….

    ret = tx_commit();
    if (ret < 0) { error processing }

    data process...

    tpfree((char *)buf);
    tpend();
}

관련함수

tx_commit(), tx_open(), tx_info()

프로토타입

# include  <tmaxapi.h>
int  tpenq (char *qname, char *svc, char *data, long len, long flags)

파라미터

flags에 사용 가능한 값은 다음과 같다.

반환값

오류

tpenq()가 정상적으로 수행되지 않을 경우 tperrno에 다음 값 중 하나가 설정된다.

예제

#include <stdio.h>
#include <usrinc/atmi.h>
#include <usrinc/tmaxapi.h>

void main(int argc, char *argv[])
{
    int ret;
    char *buf;
    long len;

    ret=tpstart((TPSTART_T *)NULL);
    if (ret==-1) { error processing }

    buf = (char *)tpalloc(“STRING”, NULL, 0);
    if (buf==NULL) { error processing }
    data process....

    ret=tpenq(“RQ”, “SERVICE”, (char *)buf, strlen(buf), TPRQS);
    if (ret==-1) { error processing }
    data process....

    ret=tpdeq(“RQ”, “SERVICE”, (char **)&buf, (long *)&len, TPRQS);
    if (ret==-1) { error processing }
    data process....

    tpfree(buf);
    tpend();
}

관련함수

tpdeq(), tpqstat()

프로토타입

# include  <tmaxapi.h>
int  tpdeq (char *qname, char *svc, char **data, long *len, long flags)

파라미터

flags에 사용 가능한 값은 다음과 같다.

반환값

오류

tpdeq()가 정상적으로 수행되지 않을 경우 tperrno에 다음 값 중 하나가 설정된다.

예제

#include <stdio.h>
#include <usrinc/atmi.h>
#include <usrinc/tmaxapi.h>

void main(int argc, char *argv[])
{
    int ret;
    char *buf;
    long len;
    ret=tpstart((TPSTART_T *)NULL);
    if (ret==-1) { error processing }

    buf = (char *)tpalloc(“STRING”, NULL, 0);
    if (buf==NULL) { error processing }
    data process....

    ret=tpenq(“RQ”, “SERVICE”, (char *)buf, strlen(buf), TPRQS);
    if (ret==-1) { error processing }
    data process....

    ret=tpdeq(“RQ”, “SERVICE”, (char **)&buf, (long *)&len, TPRQS);
    if (ret==-1) { error processing }
    data process....

    tpfree(buf);
    tpend();
}

관련함수

tpenq(), tpqstat()

프로토타입

# include  <tmaxapi.h>
int  tpqstat (char *qname, long  flags)

파라미터

flags로 사용 가능한 값은 다음과 같다.

반환값

오류

tpqstat()가 정상적으로 수행되지 않을 경우 tperrno에 다음 값 중 하나가 설정된다.

예제

#include <stdio.h>
#include <usrinc/atmi.h>
#include <usrinc/tmaxapi.h>

void main(int argc, char *argv[])
{
    int ret, i;
    char *buf;

    if (argc!=2) { error processing }
    ret=tpstart((TPSTART_T *)NULL);
    if (ret==-1) {error processing }

    buf = (char *)tpalloc(“STRING”, NULL, 0);
    if (buf==NULL) { error processing }
    strcpy(buf, argv[1]);

    data process…

    ret=tpenq(“RQ”, NULL, (char *)buf, strlen(buf), TPRQS);
    if (ret==-1) {error processing }
    printf(“qstat :”);
    for (i=0;i<4;i++) {
        ret=tpqstat(“rq”, i);
        if (ret==-1) {error processing }
        printf(“  %d”,ret);        /* qstat :  1  0  0  1 */
    }
    printf(“\n”);
    data process…

    ret=tpenq(“RQ”, “SERVICE”, (char *)buf, strlen(buf), TPRQS);
    if (ret==-1) {error processing }
    printf(”qstat :”);

    for (i=0;i<4;i++) {
        ret=tpqstat(“rq”, i);
        if (ret==-1) {error processing } 
        printf(”  %d”,ret);        /* qstat :  2  0  0  2 */

    }
    printf(“\n”);
    tpfree((char *)buf);
    tpend();
}

관련함수

tpenq(), tpdeq()

프로토타입

# include <tmaxapi.h>
int  tpextsvcname (char *data, char *svc)

파라미터

반환값

오류

tpextsvcname()이 정상적으로 수행되지 않을 경우 tperrno에 다음 값 중 하나가 설정된다.

예제

#include <stdio.h>
#include <usrinc/atmi.h>
#include <usrinc/tmaxapi.h>
void main(int argc, char *argv[])
{
    int ret;
    char *buf, *svc_name;
    long len;

    ret=tpstart((TPSTART_T *)NULL);
    if (ret==-1) { error processing }

    buf = (char *)tpalloc(“STRING”, NULL, 0);
    if (buf==NULL) { error processing }
    data process....

    ret=tpenq(“RQ”, “SERVICE”, (char *)buf, strlen(buf), TPRQS);
    if (ret==-1) { error processing }
    data process....

    ret=tpdeq(“RQ”, “SERVICE”, (char **)&buf, (long *)&len, TPRQS);
    if (ret==-1) { error processing }

    ret=tpextsvcname(buf, svc_name);
    if (ret==-1) { error processing }
    printf(“svc name : %s    ,”,svc_name);
    data process....

    tpfree(buf);
    tpend();
}

관련함수

tpenq(), tpdeq()

프로토타입

# include <tmaxapi.h>
long tpsubscribe(char *eventname, char *filter, TPEVCTL *ctl, long flags)

파라미터

서버에서 tpsubscribe()를 행하는 경우에는 ctl이 NULL이면 안되며 아래와 같은 내용을 가져야 한다.

struct tpevctl {
    long ctl_flags;
    long post_flags;
    char svc[XATMI_SERVICE_NAME_LENGTH];
    char qname[RQ_NAME_LENGTH];
};
typedef struct tpevctl TPEVCTL;

반환값

오류

tpsubscribe()가 정상적으로 수행되지 않을 경우 tperrno에 다음 값 중 하나가 설정된다.

관련함수

tpsetunsol(), tpsetunsol_flag(), tpgetunsol(), tpacall(), tpenq()

프로토타입

# include <tmaxapi.h>
int tpunsubscribe(long sd, long flags)

파라미터

반환값

오류

tpunsubscribe()가 정상적으로 수행되지 않을 경우 tperrno에 다음 값 중 하나가 설정된다.

관련함수

tpsetunsol(), tpsetunsol_flag(), tpgetunsol(), tpacall(), tpenq()

프로토타입

# include <tmaxapi.h>
int tppost(char *eventname, char *data, long len, long flags)

파라미터

반환값

오류

tppost()이 정상적으로 수행되지 않을 경우 tperrno에 다음 값 중 하나가 설정된다.

관련함수

tpsetunsol(), tpsetunsol_flag(), tpgetunsol(), tpacall(), tpenq()

프로토타입

# include <atmi.h>
int tpbroadcast (char *nodename, char *usrname, char *cltname, 
                 char *data, long len, long flags)

파라미터

flags로 사용 가능한 값에 대한 설명이다.

반환값

오류

tpbroadcast()가 정상적으로 수행되지 않은 경우 어떤 메시지도 클라이언트들에게 송신되지 않으며 tperrno에 다음 값 중 하나가 설정된다.

예제

#include <stdio.h>
#include <usrinc/atmi.h>
void main(int argc, char *argv[])
{
    int ret;
    char *buf;
    TPSTART_T *tpinfo;

    tpinfo = (TPSTART_T *)tpalloc(“TPSTART”, NULL, sizeof(TPSTART_T));
    if (tpinfo==NULL) { error processing }
    strcpy(tpinfo->cltname, “cli1”);
    strcpy(tpinfo->usrname, “navis”);
    ret=tpstart(tpinfo);
    if (ret==-1) { error processing }

    buf=tpalloc(“STRING”, NULL, 0);
    if (buf==NULL) { error processing }
    data process…

    tpbroadcast(“tmax”, NULL, NULL, buf, 0, TPNOFLAGS);
    data process....

    tpfree(buf);
    tpend();
}

관련함수

tpalloc(), tpend(), tpstart()

프로토타입

# include <tmaxapi.h>
int WinTmaxAcall(TPSTART_T *sinfo, HANDLE wHandle, unsigned int msgtype, 
                 char *svc, char *sndbuf, int len, int flags)

파라미터

flags로 사용 가능한 값은 다음과 같다.

반환값

오류

WinTmaxAcall()이 정상적으로 수행되지 않을 경우 tperrno에 다음 값 중 하나가 설정된다.

예제

...
#include <usrinc/tmaxapi.h>
#define WM_WINTMAX_RECV WM_USER + 1
...

BEGIN_MESSAGE_MAP(CWinTmaxAcall2TestDlg, CDialog)
...
ON_MESSAGE(WM_WINTMAX_RECV, OnWinTmaxAcall)
...
END_MESSAGE_MAP()

BOOL CWinTmaxAcall2TestDlg::OnInitDialog()
{
    CDialog::OnInitDialog();
    ...
    ret = tmaxreadenv(“tmax.env”, “TMAX”);
    if (ret == -1){
        AfxMessageBox(“tmaxreadenv fail...”);
        return FALSE;
    }
    return TRUE;  // return TRUE  unless you set the focus to a control
}

void CWinTmaxAcall2TestDlg::OnOK() 
{
    ...
    GetDlgItemText(IDC_EDIT1, m_Input);
    lstrcpy((LPTSTR)buf, (LPCTSTR)m_Input.operator const char *());
    ...

    buf = tpalloc(“STRING”, NULL, 0);
    if (buf == NULL){
        AfxMessageBox(“buf alloc fail...”);
        return FALSE;
    }

    ret = WinTmaxAcall((TPSTART_T *)NULL, m_hWnd, WM_WINTMAX_RECV, 
           “TOUPPER”, buf, 0, TPNOFLAGS);
    if (ret == -1){
        error processing
    }
}

LRESULT CWinTmaxAcall2TestDlg::OnWinTmaxAcall(WPARAM wp, LPARAM lp)
{
    char msg[100];
    memset(msg, 0x00, 100);
    TPSVCINFO *get = (TPSVCINFO *)wp;
    if (lp < 0){
        error processing
    }
    ...
    SetDlgItemText(IDC_EDIT2, get->data);
    return 0;
}

관련함수

tpacall(), WinTmaxAcall2()

프로토타입

# include <tmaxapi.h>
int WinTmaxAcall2(TPSTART_T *sinfo, WinTmaxCallback fn, char *svc, 
                  char *sndbuf, int len, int flags)

파라미터

flags로 사용 가능한 값은 다음과 같다.

반환값

오류

WinTmaxAcall2()가 정상적으로 수행되지 않을 경우 tperrno에 다음 값 중 하나가 설정된다.

예제

#include <usrinc/tmaxapi.h>
#define WM_WINTMAX_RECV WM_USER + 1
int mycallfn(unsigned int, long);
...

BEGIN_MESSAGE_MAP(CWinTmaxAcall2TestDlg, CDialog)
...
END_MESSAGE_MAP()

BOOL CWinTmaxAcall2TestDlg::OnInitDialog()
{
    CDialog::OnInitDialog();
    ...
    ret = tmaxreadenv(“tmax.env”, “TMAX”);
    if (ret == -1){
        AfxMessageBox(“tmaxreadenv fail...”);
        return FALSE;
    }
    return TRUE;  // return TRUE  unless you set the focus to a control
}

void CWinTmaxAcall2TestDlg::OnOK() 
{
    ...
    GetDlgItemText(IDC_EDIT1, m_Input);
    lstrcpy((LPTSTR)buf, (LPCTSTR)m_Input.operator const char *());
    ...
    buf = tpalloc(“STRING”, NULL, 0);
    if (buf == NULL){
        AfxMessageBox(“buf alloc fail...”);
        return FALSE;
    }
    ret = WinTmaxAcall2((TPSTART_T *)NULL, (WinTmaxCallback)mycallfn, 
                       “TOUPPER”, (char *)buf, 0, TPNOFLAGS);
    if (ret == -1){
        error processing
    }
}

int mycallfn(unsigned int msg, long retval)
{
    TPSVCINFO *svcinfo;
    char infomsg[30];
    memset(infomsg, 0x00, sizeof(infomsg));
    svcinfo = (TPSVCINFO *)msg;
    strncpy(infomsg, svcinfo->data, svcinfo->len);
    if (retval != 0){
        strcpy(infomsg,tpstrerror(retval));
        AfxMessageBox(infomsg);
        return -1;
    } else {
        strncpy(infomsg, svcinfo->data, sizeof(infomsg) - 1);
        AfxMessageBox(infomsg);
        return 1; 
    }
}

관련함수

tpacall(),WinTmaxAcall()

프로토타입

# include <WinTmax.h>
int WinTmaxStart(TPSTART_T *tpinfo)

파라미터

TPSTART_T에 대해서는 “9.2.1. tpstart”를 참고한다.

반환값

오류

WinTmaxStart()가 정상적으로 수행되지 않을 경우 tperrno에 다음 값 중 하나가 설정된다.

관련함수

tpstart(), WinTmaxEnd(), WinTmaxSend(), WinTmaxSetContext()

프로토타입

# include <WinTmax.h>
int WinTmaxEnd(void)

반환값

오류

WinTmaxEnd()가 정상적으로 수행되지 않을 경우 tperrno에 다음 값 중 하나가 설정된다.

관련함수

tpend(), WinTmaxStart()

프로토타입

# include <WinTmax.h>
int WinTmaxSetContext(void *winhandle, unsigned int msgType, int slot)

파라미터

다음은 slot에 설정할 수 있는 값이다.

반환값

오류WinTmaxSetContext()가 정상적으로 수행되지 않을 경우 tperrno에 다음 값 중 하나가 설정된다.

예제

...
int CTMaxGwView::Connect()
{
    CString szTemp, Fname;
    WinTmaxEnd();
    int Ret = tmaxreadenv(TMAXINI, “TMAX117”);
    if(Ret<0)
    {
        szTemp.Format(“tmaxreadenv error”);
        LogDisplay2(2, (char *)(const char *)szTemp, szTemp.GetLength());
        return FALSE;
    }
    if (WinTmaxStart((TPSTART_T *)NULL) == -1) {
        szTemp.Format(“WinTmaxStart 에러 = [%s]”, tpstrerror(tperrno));
        LogDisplay2(2, (char *)(const char *)szTemp, szTemp.GetLength());
        return FALSE;
    }

    WinTmaxSetContext(m_hWnd, WM_TMAX_RECV_RDP, 0);
    WinTmaxSetContext(m_hWnd, WM_TMAX_RECV_ERR, 1);
    WinTmaxSetContext(m_hWnd, WM_TMAX_RECV, 2);

    return TRUE;
}

관련함수

WinTmaxStart(),WinTmaxEnd(), WinTmaxSend()

프로토타입

# include <WinTmax.h>
int WinTmaxSend(int recvContext, char *svc, char *data, long len, long flags)

파라미터

WinTmaxSend()는 tpacall() 함수와 비슷하게 동작하며, 서비스를 요청하고 응답이 도착할 때까지 기다리지 않고 즉시 반환한다. 이후 응답은 WinTmaxStart()를 호출할 때 생성되었던 스레드에서 처리하여 WinTmaxSetContext()에서 설정된 윈도우로 응답 결과를 알려준다. 따라서 응답을 받기 위한 별도의 API는 제공되지 않는다.

다음은 비어있는 slot 하나를 찾아서 (hwd, 0x300)을 저장하고 index를 반환하는 예이다. WinTmaxSetContext()의 반환값 rc를 WinTmaxSend()의 recvContext 파라미터로 사용하며, WinTmaxSend(rc, svc, data, len, 0) 호출 이후에 응답이 오면 hwd windows에 0 x 300번 메시지 및 응답 결과를 전송한다.

rc = WinTmaxSetContext(hwd, 0x300, -1);
int nSendResult = WindTmaxSend(rc, (LPSTR)(LPCSTR)strService, (Char*)tpbuf, nLen, TPNOFLAGS);
/*
  이후 내부 스레드에서 응답 메시지를 처리하여 해당 윈도우로 다음과 같이 메시지를 전달한다.
  SendMessage(hwd, 0x300, (UINT) &msg, callRet);
*/

메시지를 받은 윈도우에서는 WPARAM에 응답 데이터(msg), LPARAM에 응답 결과(callRet)를 전달받는다. callRet가 0일 경우 정상적인 응답이고, -1일 경우 오류가 발생했음을 알려준다. 이때 tperrno 값을 통해 오류의 원인을 파악할 수 있다.

WinTmaxSend()는 구조상 트랜잭션을 지원하지 않으며, Tmax 시스템의 환경설정 BLOCKTIME 항목 또는 tpsettimeout()의 영향을 받지 않는다. 다만 WinTmaxSend() 호출할 때 TPBLOCK flag를 주었을 경우에만 해당 flag의 동작 방식에 대해서 BLOCKTIME이 적용된다.

WinTmaxSend()에서 사용할 수 있는 flags 값은 다음과 같다.

반환값

오류

WinTmaxSend()가 정상적으로 수행되지 않을 경우 tperrno에 다음 값 중 하나가 설정된다.

Windows로 전달된 메시지의 LPARAM이 -1인 경우 tperrno에 다음 값 중 하나가 설정된다.

예제

...
int CTMaxGwView::SendData2(char *data, long nLen)
{
    CString szTemp;
    m_send_length.Format(“%d”,nLen);
    UpdateData(FALSE);

    char *tpbuf = tpalloc(“STRING”, NULL, nLen);
    if (tpbuf == NULL) {
        szTemp.Format(“tpalloc Error [%s]”, tpstrerror(tperrno));
        LogDisplay2(2, (char *)(const char *)szTemp, szTemp.GetLength());
        return -1;
    }

   memcpy(tpbuf, data, nLen);

   CString strService;
   strService.Format(“TOUPPER_STRING”); 

   int nSendResult=WinTmaxSend(2,(LPSTR)(LPCSTR)strService, (char*)tpbuf, nLen, 0);
   tpfree(tpbuf);
    …
}

관련 함수

WinTmaxStart(),WinTmaxEnd()

프로토타입

#include <usrinc/atmi.h>
int tpgetctxt(int *ctxtid, long flags)

파라미터

반환값

오류

tpgetctxt()가 정상적으로 수행되지 않을 경우 tperrno에 다음 값 중 하나가 설정된다.

예제 - 클라이언트 프로그램

int newContext()
{
    int i;
    int id;
    i = tpstart(tpinfo);
    if (i < 0)
    {
        printf(“\t[newContext]tpstart fail[%d][%s]\n",tperrno,
                tpstrerror(tperrno));
        tpfree((char *)tpinfo);
        return -1;
    }
    i = tpgetctxt(&id,TPNOFLAGS);
    if (i < 0) 
    {
        printf(“\t[newContext]tpgetctxt fail[%d][%s]\n",tperrno,
                 tpstrerror(tperrno));
        return -1;
    }
    return id;
}

예제 - 서버 프로그램

typedef param {
    int ctxtid;
    TPSVCINFO *svcinfo;
} param_t;

MSERVICE(TPSVCINFO *svcinfo)
{
    pthread_t tid;
    param_t param;

    printf("MSERVICE service is started!");
    tpgetctxt(&param.ctxtid, TPNOFLAGS);
    param.svcinfo = svcinfo;

    pthread_create(&tid, NULL, THREAD_ROUTINE, &param);
    pthread_join(tid, NULL);

    printf("MSERVICE service is finished!");
    tpreturn(TPSUCCESS, 0, svcinfo->data, 0L, TPNOFLAGS);
}

void *THREAD_ROUTINE(void *arg)
{
    param_t *param;
    TPSVCINFO *svcinfo;
   
    param = (param_t *)arg;
    svcinfo = param->svcinfo;

    if (tpsetctxt(param->ctxtid, TPNOFLAGS) == -1) {
        printf("tpsetctxt(%d) failed, [tperrno:%d]", param->ctxtid, tperrno);
        return NULL;
    }

    tpcall("MTOUPPER", sndbuf, 0, &rcvbuf, &rcvlen, TPNOFLAGS);

    if (tpsetctxt(TPNULLCONTEXT, TPNOFLAGS) == -1) {
        printf("tpsetctxt(TPNULLCONTEXT) failed, [tperrno:%d]", tperrno);
        return NULL;
    }

    return NULL;
}

관련함수

tpsetctxt()

클라이언트 프로그램

함수를 사용하여 하나의 클라이언트가 기존에 생성된 다른 context를 현재 클라이언트에 할당할 수 있고 대부분의 ATMI 함수들은 per-context 기반으로 되어 있다. 클라이언트의 현재 context를 알기 위해서는 tpgetctxt()라는 함수를 사용하여 반환되는 값으로 확인할 수 있다.

클라이언트는 여러 개의 context를 사용할 수 있지만 해당하는 순간에는 단 하나의 context만을 갖게 된다. 예를 들면 context1에서 tpacall()을 한 경우 다른 context를 사용했다 하더라도 tpgetrply()를 정상적으로 하기 위해서는 tpgetrply()를 하는 시점에서는 context1을 현재 context로 설정해 주어야 한다.

서버 프로그램

서비스 스레드는 서비스를 처리할 때 context를 할당받아서 사용하게 되지만, 사용자 생성 스레드는 자신만의 context가 존재하지 않는다. 대부분의 ATMI 함수들은 context가 할당되어야만 동작할 수 있다. 따라서 사용자 생성 스레드는 필요한 경우에는 서비스 스레드의 context를 공유해서 사용해야 한다. 사용자 생성 스레드는 tpsetctxt 함수를 사용하여 다른 서비스 스레드의 context를 공유할 수 있다.

tpsetctxt를 호출한 사용자 생성 스레드는 서비스 스레드와 context 정보를 공유한다. 예를 들어 서비스 스레드에서 tpacall()을 호출하면 그 이후 사용자 생성 스레드에서 tpgetrply()를 통해 요청에 대한 응답을 받는 것이 가능하다.

tpsetctxt() 함수는 서비스 스레드에서는 사용할 수 없다. 서비스 스레드는 기본적으로 자신의 context를 가지고 있으며, 다른 context로 교체하여 사용할 수 없다. 따라서 서비스 스레드에서 tpsetctxt() 함수를 호출하면 TPEPROTO 오류코드와 함께 에러를 반환하게 된다.

사용자 생성 스레드에서 이 함수를 통해 서비스 스레드의 context를 공유한 경우에는 반드시 서비스 스레드가 tpreturn()을 호출하기 전에 먼저 사용자 생성 스레드에서 tpsetctxt(TPNULLCONTEXT)를 호출해야 한다. 즉, 서비스 스레드가 tpreturn()을 호출하는 시점에 다른 사용자 생성 스레드가 서비스 스레드의 context를 공유하지 않도록 변경해야 한다. 이를 지키지 않으면 tpreturn()은 실패하게 되고 클라이언트로 TPESVCERR 에러 코드를 반환하게 된다. 따라서 반드시 동기화 등을 통해 이들 스레드 사이에서의 프로세스 흐름을 제어해야 한다. tpsetctxt() 함수의 ctxtid 파라미터는 서비스 스레드에서 tpgetctxt() 함수를 호출해서 얻은 Context-ID를 사용한다.

프로토타입

#include <usrinc/atmi.h>
int tpsetctxt(int ctxtid, long flags)

파라미터

반환값

오류

tpsetctxt()가 정상적으로 수행되지 않을 경우 tperrno에 다음 값 중 하나가 설정된다.

예제 - 클라이언트 프로그램

int altContext(int id)
{
    int i;
    int ret;
    ret = tpsetctxt(id, TPNOFLAGS);
    if (ret < 0)
    {
       printf(“\t[altContext]tpsetctxt fail[%d][%s]\n"tperrno,
                tpstrerror(tperrno));
       tpfree((char *)tpinfo);
       return -1;
    }
    return 1;
}

예제 - 서버 프로그램

typedef param {
    int ctxtid;
    TPSVCINFO *svcinfo;
} param_t;

MSERVICE(TPSVCINFO *svcinfo)
{
    pthread_t tid;
    param_t param;

    printf("MSERVICE service is started!");
    tpgetctxt(&param.ctxtid, TPNOFLAGS);
    param.svcinfo = svcinfo;

    pthread_create(&tid, NULL, THREAD_ROUTINE, &param);
    pthread_join(tid, NULL);

    printf("MSERVICE service is finished!");
    tpreturn(TPSUCCESS, 0, svcinfo->data, 0L, TPNOFLAGS);
}

void *THREAD_ROUTINE(void *arg)
{
    param_t *param;
    TPSVCINFO *svcinfo;
   
    param = (param_t *)arg;
    svcinfo = param->svcinfo;

    if (tpsetctxt(param->ctxtid, TPNOFLAGS) == -1) {
        printf("tpsetctxt(%d) failed, [tperrno:%d]", param->ctxtid, tperrno);
        return NULL;
    }

    tpcall("MTOUPPER", sndbuf, 0, &rcvbuf, &rcvlen, TPNOFLAGS);

    if (tpsetctxt(TPNULLCONTEXT, TPNOFLAGS) == -1) {
        printf("tpsetctxt(TPNULLCONTEXT) failed, [tperrno:%d]", tperrno);
        return NULL;
    }

    return NULL;
}

관련함수

tpgetctxt()