프로토타입

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

반환값

에러 코드(errno)를 반환한다. 에러 코드에 대한 자세한 내용는 “Appendix A. 에러별 대응 방안”나 "Tmax Application Development Guide"를 참고한다.

예제

#include <stdio.h>
#include <usrinc/atmi.h>
void main(int argc, char* argv[])
{
   int ret, usrerrno=0;
   char *sndbuf, *rcvbuf;
   ret=tpstart((TPSTART_T*)NULL);
   if (ret==-1){ 
      usrerrno=gettperrno();
      printf(“error no : %d\n”, usrerrno);
   }
   data process…
   tpend();
} 

관련 함수

gettpurcode()

프로토타입

#include <usrinc/tmaxapi.h>
int tmax_chk_conn (int sec)

파라미터

반환값

오류

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

예제

#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <usrinc/atmi.h>
#include <usrinc/fbuf.h>        
#include <usrinc/tmaxapi.h>
#include “../fdl/demo_fdl.h”

main(int argc, char *argv[])
{
        FBUF    *sndbuf, *rcvbuf;
        int     fc, fg, ret,  i, chkno;
        char    sndata[30],    rcvdata[30];
        char     input[10], outdata[10];
        long    sndlen, rcvlen;
        int Count = 1;

        if (argc != 2) 
            error processing…

        if ( (ret = tmaxreadenv( “tmax.env”,”TMAX” )) == -1 )
            error processing…

        /* tpstart 수행 여부 체크 */
        /***
        chkno = tmax_chk_conn(-1);
        printf(“chkno = %d\n”, chkno);
        if(chkno < 0)
        {
              printf(“tpstart is not started\n”);
              printf(“errno = %d\tstrerror=%s\n”, tperrno, tpstrerror(tperrno) );
        }
        else if(chkno == 0)
        {
              printf(“tpstart is started\n”);
        }    
        ***/

        if (tpstart((TPSTART_T *)NULL) == -1)
              error processing…
        if ((sndbuf = (FBUF *)tpalloc(“FIELD”, NULL, 0)) == NULL) 
              error processing…
        if ((rcvbuf = (FBUF *)tpalloc(“FIELD”, NULL, 0)) == NULL) 
              error processing…
        /* 소켓의 상태 점검 */
        /***********
        chkno = tmax_chk_conn(0);
        printf(“chkno = %d\n”, chkno);
        if(chkno < 0)
        {
              printf(“The situation of socket is bad\n”);
              printf(“errno = %d\tstrerror=%s\n”, tperrno, tpstrerror(tperrno) );
        }
        else if(chkno == 0)
        {
              printf(“The situation of socket is good\n”);
        }
        **********/
        printf(“My Count = %d\n”, Count++);
        strcpy(input, “INPUT”);
        strcpy(sndata, argv[1]);
        fc = fbput(sndbuf, fbget_fldkey(input), sndata, 0);
        if (tpcall(“FDLTOUPPER”, (char *)sndbuf, 0, (char **)&rcvbuf,
                    (long *)&rcvlen, TPNOFLAGS) == -1) 
              error processing… 
        /* 메시지 전달로써 연결 상태 점검 */
        chkno = tmax_chk_conn(1);
        printf(“chkno = %d\n”, chkno);
        if(chkno < 0)
        {
              printf(“The situation of connection(Message Transfer) is bad\n”);
              printf(“errno = %d\tstrerror=%s\n”, tperrno, tpstrerror(tperrno) );
        }
        else if(chkno == 0)
        {
              printf(“The situation of connection(Message Transfer) is good\n”);
        }

        strcpy(outdata, “OUTPUT”);
        fg = fbget(rcvbuf, fbget_fldkey(outdata), rcvdata, 0);
        fbprint(rcvbuf);
        tpfree((char *)sndbuf);
        tpfree((char *)rcvbuf);
        tpend();
}

관련 함수

tpalivechk()

프로토타입

#include <tmaxapi.h>
int tmax_gq_count (void)

반환값

오류

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

프로토타입

#include <tmaxapi.h>
int tmax_gq_get(char *key, long keylenl, char **data, long *lenl, long flagsl)

파라미터

반환값

오류

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

프로토타입

#include <tmaxapi.h>
SQ_KEYLIST_T tmax_gq_getkeylist(char *key, long keylenl)

파라미터

반환값

오류

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

프로토타입

#include <tmaxapi.h>
int tmax_gq_keygen(char *key, long keylenl)

파라미터

반환값

오류

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

프로토타입

#include <tmaxapi.h>
int tmax_gq_purge(char *key, long keylenl)

파라미터

반환값

오류

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

프로토타입

#include <tmaxapi.h>
int tmax_gq_put(char *key, long keylenl, char *data, long lenl, long flagsl)

파라미터

다음은 flagsl에 설정 가능한 값의 설명이다.

반환값

오류

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

프로토타입

#include <tmaxapi.h>
int tmax_get_sessionid(void)

반환값

오류

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

프로토타입

#include <tmaxapi.h>
int tmax_keylist_count(SQ_KEYLIST_T keylist)

파라미터

반환값

오류

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

프로토타입

#include <tmaxapi.h>
int tmax_keylist_free(SQ_KEYLIST_T keylist)

파라미터

반환값

오류

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

프로토타입

#include <tmaxapi.h>
int tmax_keylist_getakey(SQ_KEYLIST_T keylist, int nth, SQ_KEYINFO_T *keyinfo)

파라미터

다음은 keyinfo에 대한 설명이다.

Structure keyinfo {
     long keylen
     long datalen
     time_t starttime
     char *key
};

반환값

오류

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

프로토타입

#include <tmaxapi.h>
int tmax_sq_count(void)

반환값

오류

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

프로토타입

#include <tmaxapi.h>
int tmax_sq_get(char *key, long keylenl, char **data, long *lenl, long flagsl)

파라미터

반환값

오류

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

프로토타입

#include <tmaxapi.h>
SQ_KEYLIST_T tmax_sq_getkeylist(char *key, long keylenl)

파라미터

반환값

오류

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

프로토타입

#include <tmaxapi.h>
int tmax_sq_keygen(char *key, long keylenl)

파라미터

반환값

오류

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

프로토타입

#include <tmaxapi.h>
int tmax_sq_purge(char *key, long keylenl)

파라미터

반환값

오류

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

프로토타입

#include <tmaxapi.h>
int tmax_sq_put(char *key, long keylenl, char *data, long lenl, long flagsl)

파라미터

다음은 flagsl에 설정되는 값에 대한 설명이다.

반환값

오류

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

프로토타입

#include <tmaxapi.h>
char *tmaxlastsvc(char *idata, char *odata, long flags)

파라미터

반환값

오류

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

예제

#include <usrinc/atmi.h>
main(int argc, char *argv[])
{
   ...
   if(tpcall(“TOUPPER”, sndbuf, 0, &rcvbuf, &rcvlen, TPNOFLAGS)==-1){
      memset(svc, NULL, 16);
      strcpy((char *)svc, tmaxlastsvc(sndbuf, rcvbuf, TPNOFLAGS));
      printf(“servicename = %s\n”, svc);
      error processing
   }
   ...
}

프로토타입

#include <tmaxapi.h>
int tmaxreadenv (char *file, char *label)

파라미터

반환값

예제

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

void main(int argc, char* argv[])
{
    tmaxreadenv(“tmax.env”, “tmax”);  /*”tmax.env”의 “tmax”절에서 환경변수를 얻음*/
    tpstart((TPSTART_T *)NULL);
    data process…
    tpend();
}

관련 함수

tpstart()

프로토타입

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

파라미터

반환값

오류

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

관련 함수

tpacall(), tpbroadcast(), tpgetrply(), tp_usleep(), tpsleep()

프로토타입

#include <tmaxapi.h>
int tp_usleep (int usec)

파라미터

반환값

오류

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

예제

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

void main(int argc, char *argv[])
{
    int ret, cd;
    char *buf;
    long 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<0) { error processing }
    while(1)
    {
        ret=tp_usleep(2000000);
        if (ret<0) {error processing }
        if (ret==0) printf("waited 2sec..\n");
        else {
            printf("data received!\n");
            break;
        }
    }
    ret=tprecv(cd, &buf, &len, TPNOFLAGS, &revent);
    if (ret<0) { error processing }
    data process....
    tpend();
} 

관련 함수

tmax_get_db_usrname(), tmax_get_db_tnsname()

프로토타입

#include <tuxfml.h>
int tpabort (long flags)

파라미터

반환값

“3.1.88. tx_rollback”을 참고한다.

오류

“3.1.88. tx_rollback”을 참고한다.

예제

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

void main(int argc, char *argv[])
{
    char *buf;
    int ret; 
    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…
    ret = tpbegin(5, TPNOFLAGS);
    if (ret < 0){ error processing }

    ret=tpcall(“SERVICE",(char *)buf,strlen(buf),(char **)&buf,&len,TPNOFLAGS);
    if (ret == -1)
    {
        ret = tpabort(TPNOFLAGS);
        if (ret < 0){ error processing }
        tpfree(buf);
        tpend();
        exit(1);
    }

    ret = tpcommit(TPNOFLAGS);
    if (ret < 0){ error processing }
    tpfree(buf);
    tpend();
}

관련 함수

tx_rollback()

프로토타입

# 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 <usrinc/tmaxapi.h>
int tpacallsvg (int svgno, char *svc, char *data, long lenl, long flagsl)

파라미터

svgno를 제외한 다른 파라미터는 “3.1.24. tpacall”을 참고한다.

반환값

오류

에러에 관한 자세한 내용은 “3.1.24. tpacall”을 참고한다.

예제

<클라이언트 프로그램>

#include <usrinc/tmaxapi.h>
#include “../fdl/demo_fdl.h”

int main(int argc, char *argv[])
{
    FBUF    *sndbuf, *rcvbuf;
    int     ret, I, cd;
    char    sndata[30],     rcvdata[30];
    long    sndlen, rcvlen;
    struct svglist *svg_list;
    char svc[32];
        
    ret = tmaxreadenv( “tmax.env”,”TMAX” );
    ret = tpstart((TPSTART_T *)NULL);
    sndbuf = (FBUF *)tpalloc(“FIELD”, NULL, 0)};
    rcvbuf = (FBUF *)tpalloc(“FIELD”, NULL, 0));
    strcpy(sndata, argv[1]);

    ret = fbput(sndbuf, INPUT, sndata, 0);
    strcpy(svc, “FDLTOUPPER”);
    svg_list = (struct svglist *)tpgetsvglist(svc, 0);

    for(i=0; i< svg_list->ns_entry; i++)
    {
        printf(“\n”);
        printf(“ >>> tpcallsvg ( %d th svg )\n”, i+1);
        strcpy(sndata, argv[1]);
        ret = fbput(sndbuf, INPUT, sndata, 0);
        cd = tpacallsvg(svg_list->s_list[i], svc, (char *)sndbuf, 0, 0);
        if(cd < 0)
        {
            printf(“tpacall failed! errno = %d[%s]\n”, tperrno, 
                     tpstrerror(tperrno));
            tpfree((char *)sndbuf);
            tpfree((char *)rcvbuf);
            tpend();
            exit(1);
        }
        ret = tpgetrply(&cd, (char **)&rcvbuf, (long *)&rcvlen, 0);
        ret = fbget(rcvbuf, OUTPUT, rcvdata, 0);
        fbprint(rcvbuf);
    }
    tpfree((char *)sndbuf);
    tpfree((char *)rcvbuf);
    tpend();
    return 0;
}

관련 함수

tpacall( ), tpcallsvg( ), tpgetsvglist( ), tpgetmysvgno( )

프로토타입

#include <usrinc/tmaxapi.h>
int tpalivechk(void)

반환값

오류

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

예제

#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <usrinc/atmi.h>
#include <usrinc/fbuf.h>
#include <usrinc/tmaxapi.h>
#include “../fdl/demo_fdl.h”

main(int argc, char *argv[])
{
    FBUF    *sndbuf, *rcvbuf;
    int     chkno;
    char    sndata[30], rcvdata[30];
    char    input[10], outdata[10];
    long    sndlen, rcvlen;

    if ( (ret = tmaxreadenv( “tmax.env”,”TMAX” )) == -1 ){
        printf( “tmax read env failed\n” );
        exit(1);
    }
    if (tpstart((TPSTART_T *)NULL) == -1)
        error processing…
    if ((sndbuf = (FBUF *)tpalloc(“FIELD”, NULL, 0)) == NULL) 
        error processing…
    if ((rcvbuf = (FBUF *)tpalloc(“FIELD”, NULL, 0)) == NULL) 
        error processing…
    /* socket의 상태 점검 */
    chkno = tpalivechk();
    printf(“chkno = %d\n”, chkno);
    if(chkno < 0)
    {
        printf(“The situation of socket is bad\n”);
        printf(“errno = %d\tstrerror=%s\n”, tperrno, tpstrerror(tperrno) );
    }
    else if(chkno == 0)
    {
        printf(“The situation of socket is good\n”);
    }
    tpcall…
    data process…
    tpend();
}

관련 함수

tmax_chk_conn()

프로토타입

# 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()

프로토타입

int tpbegin(unsigned long timeout, long flags);

파라미터

반환값

“3.1.91. tx_set_transaction_timeout”와 “3.1.85. tx_begin”를 참고한다.

예제

#include <stdio.h>
#include <usrinc/atmi.h>
#include <tuxinc/tuxfml.h>
void main(int argc, char *argv[])
{
    char *buf;
    int ret;
    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…
    ret = tpbegin(5, TPNOFLAGS);
    if (ret < 0){ error processing }

    ret = tpcall(“SERVICE”, (char *)buf, strlen(buf), 
                 (char **)&buf, &len, TPNOFLAGS);
    if (ret == -1)
    {
        ret = tpabort(TPNOFLAGS);
        if (ret < 0){ error processing }
        tpfree(buf);
        tpend();
        exit(1);
    }
    ret = tpcommit(TPNOFLAGS);
    if (ret < 0){ error processing }
    tpfree(buf);
    tpend();
}

관련 함수

tx_set_transaction_timeout(), tx_begin()

프로토타입

# 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 <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 <usrinc/tmaxapi.h>
int tpcallsvg (int svgno, char *svc, char *idata, long ilenl, char **odata, 
               long *olen, long flagsl)

파라미터

svgno 이외의 파라미터는 “3.1.30. tpcall”을 참고한다.

반환값

오류

에러에 관한 자세한 내용은 “3.1.30. tpcall”을 참고한다.

예제

<클라이언트 프로그램>

#include <usrinc/tmaxapi.h>
#include “../fdl/demo_fdl.h”

int main(int argc, char *argv[])
{
    FBUF    *sndbuf, *rcvbuf;
    int     ret, i;
    char    sndata[30],     rcvdata[30];
    long    sndlen, rcvlen;
    struct svglist *svg_list;
    char svc[32];
        
    ret = tmaxreadenv( “tmax.env”,”TMAX” );
    ret = tpstart((TPSTART_T *)NULL);
    sndbuf = (FBUF *)tpalloc(“FIELD”, NULL, 0)};
    rcvbuf = (FBUF *)tpalloc(“FIELD”, NULL, 0));
    strcpy(sndata, argv[1]);
    ret = fbput(sndbuf, INPUT, sndata, 0);
    strcpy(svc, “FDLTOUPPER”);
    svg_list = (struct svglist *)tpgetsvglist(svc, 0);

    for(i=0; i< svg_list->ns_entry; i++)
    {
        printf(“\n”);
        printf(“ >>> tpcallsvg ( %d th svg )\n”, i+1);
        strcpy(sndata, argv[1]);
        ret = fbput(sndbuf, INPUT, sndata, 0);
        if (tpcallsvg(svg_list->s_list[i], svc, (char *)sndbuf, 0, 
            (char **)&rcvbuf, &rcvlen, 0) == -1)
        {
            printf("tpcall failed! errno = %d[%s]\n",tperrno,tpstrerror(tperrno));
            tpfree((char *)sndbuf);
            tpfree((char *)rcvbuf);
            tpend();
            exit(1);
        }
        ret = fbget(rcvbuf, OUTPUT, rcvdata, 0);
        fbprint(rcvbuf);
    }
    tpfree((char *)sndbuf);
    tpfree((char *)rcvbuf);
    tpend();
    return 0;
}

관련 함수

tpcall( ), tpacallsvg( ), tpgetsvglist( ), tpgetmysvgno( )

프로토타입

# 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 <tuxfml.h>
int  tpcommit (long flags)

파라미터

반환값

“3.1.86. tx_commit”을 참고한다.

예제

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

void main(int argc, char *argv[])
{
    char *buf;
    int ret;
    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…
    ret = tpbegin(5, TPNOFLAGS);
    if (ret < 0){ error processing }
 
    ret=tpcall("SERVICE",(char *)buf,strlen(buf),(char **)&buf,&len,TPNOFLAGS);
    if (ret == -1)
    {
        ret = tpabort(TPNOFLAGS);
        if (ret < 0){ error processing }
        tpfree(buf);
        tpend();
        exit(1);
    }
    ret = tpcommit(TPNOFLAGS);
    if (ret < 0){ error processing }

    tpfree(buf);
    tpend();
}

관련 함수

tx_commit()

프로토타입

# 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  <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 <usrinc/tmaxapi.h>
int tpdeq_ctl(char *qname, char *svc, TMQCTL *ctl, char **data, 
              long *len, long flags);

파라미터

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

반환값

오류

tpdeq_ctl()가 정상 처리되지 않을 경우 tperrno에 아래 값 중 하나가 설정된다.

예제

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

main(int argc, char *argv[])
{
    char    *sndbuf, *rcvbuf;
    long    rcvlen, sndlen, revent;
    int ret, i, cd;
    TMQCTL   *ctl;

    ctl = (TMQCTL*)malloc(sizeof(TMQCTL));
    memset(ctl, 0, sizeof(TMQCTL));
    if (argc != 2) {
        printf(“Usage: toupper_rq string\n”);
        exit(1);
    }

    if ( (ret = tmaxreadenv( “tmax.env”,”TMAX” )) == -1 ){
        printf( “tmax read env failed\n” );
        exit(1);
    }

    if (tpstart((TPSTART_T *)NULL) == -1){
        printf(“tpstart failed\n”);
        exit(1);
    }

    if ((sndbuf = (char *)tpalloc(“STRING”, NULL, 0)) == NULL) {
        printf(“sendbuf alloc failed !\n”);
        tpend();
        exit(1);
    }

    if ((rcvbuf = (char *)tpalloc(“STRING”, NULL, 0)) == NULL) {
        printf(“recvbuf alloc failed !\n”);
        tpfree((char *)sndbuf);
        tpend();
        exit(1);
    }

    ret = tx_begin();
    if(ret < 0)
    {
        fprintf(stderr, “tx_begin() fail\n”);
        tpfree((char *)sndbuf);
        tpfree((char *)rcvbuf);
        exit(1);
    }

    strcpy(sndbuf, argv[1]);
    cd = tpdeq_ctl(“txrq1”, “TOUPPER”, ctl, &rcvbuf, &rcvlen, TPRQS );
    if (cd < 0)
    {
        printf(“tpdeq failed [%s]\n”, tpstrerror(tperrno) );
        tpfree((char *)sndbuf);
        tpfree((char *)rcvbuf);
        tpend();
        exit(1);
    }

    cd = tpdeq_ctl(“txrq1”, “TOUPPER”, ctl, &rcvbuf, &rcvlen, TPRQS );
    if (cd < 0)
    {
        printf(“tpdeq failed [%s]\n”, tpstrerror(tperrno) );
        tpfree((char *)sndbuf);
        tpfree((char *)rcvbuf);
        tpend();
        exit(1);
    }

    data process....
    ret = tx_commit();
    if(ret < 0)
    {
        fprintf(stderr, “tx_commit() fail\n”);
        tpfree((char *)sndbuf);
        tpfree((char *)rcvbuf);
        tx_rollback();
        exit(1);
    }
    tpfree((char *)sndbuf);
    tpfree((char *)rcvbuf);
    tpend();
}

관련 함수

tpenq_ctl(), tpqstat()

프로토타입

# 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  <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 <usrinc/tmaxapi.h>
int tpenq_ctl(char *qname, char *svc, TMQCTL *ctl, char *data, long len, 
              long flags);

파라미터

다음은 flags에 설정 가능한 값에 대한 설명이다.

반환값

오류

tpenq_ctl()가 정상 처리되지 않을 경우 tperrno에 아래 값 중 하나가 설정된다.

예제

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

main(int argc, char *argv[])
{
    char    *sndbuf, *rcvbuf;
    long    rcvlen, sndlen, revent;
    int ret, i, cd;
    TMQCTL   *ctl;
    long t;

    ctl = (TMQCTL*)malloc(sizeof(TMQCTL));
    memset(ctl, 0, sizeof(TMQCTL));
    time(&t);
    ctl->deq_time = (int)t + 3;

    if (argc != 2) {
        printf(“Usage: toupper string\n”);
        exit(1);
    }
    if ( (ret = tmaxreadenv( “tmax.env”,”TMAX” )) == -1 ){
        printf( “tmax read env failed\n” );
        exit(1);
    }
    if (tpstart((TPSTART_T *)NULL) == -1){
        printf(“tpstart failed\n”);
        exit(1);
    }
    if ((sndbuf = (char *)tpalloc(“STRING”, NULL, 0)) == NULL) {
        printf(“sendbuf alloc failed !\n”);
        tpend();
        exit(1);
    }
    if ((rcvbuf = (char *)tpalloc(“STRING”, NULL, 0)) == NULL) {
        printf(“recvbuf alloc failed !\n”);
        tpfree((char *)sndbuf);
        tpend();
        exit(1);
    }
    ret = tx_begin();
    if(ret < 0)
    {
        fprintf(stderr, “tx_begin() fail\n”);
        tpfree((char *)sndbuf);
        tpfree((char *)rcvbuf);
        exit(1);
    }

    strcpy(sndbuf, argv[1]);
    cd = tpenq_ctl(“txrq1”, “TOUPPER”, ctl, (char *)sndbuf, 0, TPRQS );
    if (cd < 0) {
        printf(“tpenq failed [%s]\n”, tpstrerror(tperrno));
        tpfree((char *)sndbuf);
        tpfree((char *)rcvbuf);
        tpend();
        exit(1);
    }
    cd = tpenq_ctl(“txrq1”, “TOUPPER”, ctl, (char *)sndbuf, 0, TPRQS );
    if (cd < 0) {
        printf(“tpenq failed [%s]\n”, tpstrerror(tperrno));
        tpfree((char *)sndbuf);
        tpfree((char *)rcvbuf);
        tpend();
        exit(1);
    }
    data process....
    ret = tx_commit();
    if(ret < 0)
    {
        fprintf(stderr, “tx_commit() fail\n”);
        tpfree((char *)sndbuf);
        tpfree((char *)rcvbuf);
        tx_rollback();
        exit(1);
    }

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

    tpend();
}

관련 함수

tpdeq_ctl(), tpqstat()

프로토타입

# include  <atmi.h>
int  tperrordetail(int errno)

파라미터

반환값

예제

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

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

    data process…

    ret = tpcall(“SERVICE”, sndbuf, 20, &rcvbuf, &rcvlen, TPNOCHANGE);
    if (ret == -1){
        fprintf(stderr, “tpcall fail,,,[%d][%s]\n”, 
                tperrordetail(tperrno), tpstrerror(tperrno));
        error processing
    }

    tpfree(buf);
    tpend();
}

프로토타입

# include <tmaxapi.h>
int  tpextsvcinfo (char *data, char *svc, , int *type, int *errcode )

파라미터

다음은 type에 설정 가능한 값에 대한 설명이다.

반환값

오류

tpextsvcname()이 정상 처리되지 않을 경우 tperrno에 아래 값 중 하나가 설정된다.

관련 함수

tpenq(), tpdeq(), tpextsvcname()

프로토타입

# 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 <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 <tmaxapi.h>
int  tpget_timeout(void)

반환값

tpget_timeout()는 현재 설정된 블록 타임아웃을 초 단위로 반환하며, 에러를 반환하지는 않는다.

예제

#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=tpget_timeout();
    printf(“block time = %d\n”, sec);

    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 tpgetactivesvr(char *nodename, char **outbufp);

파라미터

반환값

오류

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

예제

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

main(int argc, char *argv[])
{
    char    *sndbuf, *rcvbuf, *data;
    long    rcvlen, sndlen;
    int     ret, n, i;
    char nodename[35];

    if (argc != 2) {
        printf(“Usage: toupper string\n”);
        exit(1);
    }
    if ( (ret = tmaxreadenv( “tmax.env”,”TMAX” )) == -1 ){
        printf( “tmax read env failed\n” );
        exit(1);
    }

    if (tpstart((TPSTART_T *)NULL) == -1){
        printf(“tpstart failed\n”);
       exit(1);
    }

    if ((rcvbuf = (char *)tpalloc(“STRING”, NULL, 0)) == NULL) {
        printf(“recvbuf alloc failed !\n”);
        tpfree((char *)sndbuf);
        tpend();
        exit(1);
    }

    strcpy(nodename, “starbj”);
    if((n = tpgetactivesvr(nodename, &rcvbuf)) < 0) {
        printf(“getactivesvr failed\n”);
        tpfree((char *)rcvbuf);
        tpend();
        exit(1);
    }
    printf(“Total %d servers\n”, n);
    data = rcvbuf;
    for (i = 0; i < n; i++) {
        printf(“ACTIVE[%s]\n”, data);
        data += strlen(data) + 1;
    }
    tpfree((char *)sndbuf);
    tpfree((char *)rcvbuf);
    tpend();
}

프로토타입

#include <tmaxapi.h>
int tpgetcliaddr(int clid, int *ip, int *port, long flags);

파라미터

반환값

오류

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

예제

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

TOUPPER(TPSVCINFO *msg)
{
        int             ret;
        int             clid;
        int             port;
        int*            ip;
        ...
        clid = tpgetclid();
        printf(“clid = %d\n”, clid);
  
        ret = tpgetcliaddr(clid, ip, &port, 0);
        if(ret < 0)
          error routine..

        printf(“ip = %s, port = %d\n”, inet_ntoa(ip), port);
        tpreturn(TPSUCCESS,0,(char *)msg->data, 0,0);
}

관련 함수

tpgetclid()

프로토타입

#include <tmaxapi.h>
#include <arpa/inet.h>
int tpgetcliaddr_ipv6(int clid, struct sockaddr_storage *saddr, long flags);

파라미터

반환값

오류

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

예제

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

TOUPPER(TPSVCINFO *msg)
{
        int             ret;
        int             clid;
        int             portno;
        struct sockaddr_storage saddr;
        struct sockaddr_in *cli_sin4;
        struct sockaddr_in6 *cli_sin6;
        char ipaddrbuf[INET6_ADDRSTRLEN];
        const char *ipaddr = NULL;
        ...
        clid = tpgetclid();
        printf(“clid = %d\n”, clid);
  
        ret = tpgetcliaddr_ipv6(clid, &ipaddr, 0);
        if(ret < 0)
          error routine..

        if (saddr.ss_family == AF_INET) {
            cli_sin4 = (struct sockaddr_in *)&saddr;
            ipaddr = inet_ntop(AF_INET, &(cli_sin4->sin_addr), ipaddrbuf, sizeof(ipaddrbuf));
            portno = ntohs(cli_sin4->sin_port);
        } else if (saddr.ss_family == AF_INET6) {
            cli_sin6 = (struct sockaddr_in *)&saddr;
            ipaddr = inet_ntop(AF_INET6, &(cli_sin6->sin6_addr), ipaddrbuf, sizeof(ipaddrbuf));
            portno = ntohs(cli_sin6->sin6_port);
        }
        if (ipaddr == NULL)
            ipaddr = "unknown";

        printf(“ip = %s, port = %d\n”, ipaddr, portno);
        tpreturn(TPSUCCESS,0,(char *)msg->data, 0,0);
}

관련 함수

tpgetclid()

프로토타입

#include <tmaxapi.h>
int  tpgetclid(void)

반환값

오류

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

예제

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

SERVICE(TPSVCINFO *msg)
{
    int ret, clid;
    char *buf;

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

    clid = tpgetclid();
    if (clid==-1) { error process }

    ret=tpsendtocli(clid, buf, strlen(buf), 0);
    if (ret==-1) { error processing }
    data process….

    tpreturn(TPSUCCESS,0,buf, strlen(buf), 0);
}

관련 함수

tpsendtocli()

프로토타입

#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()

프로토타입

#include <tmaxapi.h>
char *tpgetenv(char *name)

파라미터

반환값

예제

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

main(int argc, char *argv[])
{
    char *TMAXD, *SDLFI;
    TMAXD=tpgetenv(“TMAXDIR”);
    SDLFI=tpgetenv(“SDLFILE”);
    printf (“tmaxdir : %s\nsdlfile : %s\n”,TMAXD,SDLFI);
}

관련 함수

tpputenv()

프로토타입

#include <tuxatmi.h>
int  tpgetlev(void)

반환값

예제

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

EXEC SQL include sqlca.h;
EXEC SQL begin declare section;
struct emp *buf;
EXEC SQL end declare section;

DELETE(TPSVCINFO *msg)
{
    struct emp *buf;
    buf = (struct emp *)msg->data;
    data process...
    if (tpgetlev()) printf(“transaction mode\n”);
    else printf(« nontransaction mode\n »);
    EXEC SQL DELETE FROM emp
    WHERE empno = :buf->empno;
    data process...
    tpreturn(TPSUCCESS,0,buf, strlen(buf), 0);
}

프로토타입

#include <tmaxapi.h>
int  tpgetpeername(struct sockaddr *name, int *namelen)

파라미터

반환값

오류

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

예제

#include <stdio.h>
#include <netinet/in.h>
#include <arpa/inet.h>
#include <usrinc/atmi.h>
#inlcude <usrinc/tmaxapi.h>
...
DELETE(TPSVCINFO *msg)
{
    struct sockaddr_in cli;
    char ipAddr[16];
    int cli_len, ret;

    data process...
    memset((char *)&cli, 0, sizeof(cli));
    ret = tpgetpeername((struct sockaddr *)&cli, &cli_len);
    if (ret == -1){ error processing }
    else{
        memcpy(ipAddr, inet_ntoa(cli.sin_addr), 16);
    }
    printf(“ip = %s , port = %d\n”, ipAddr, cli.sin_port);
    data process...

    tpreturn(TPSUCCESS, 0, 0, 0, 0);
}

예제 - IPv6 프로토콜 환경

#include <stdio.h>
#include <netinet/in.h>
#include <arpa/inet.h>
#include <usrinc/atmi.h>
#inlcude <usrinc/tmaxapi.h>
...
DELETE(TPSVCINFO *msg)
{
    struct sockaddr_storage cli_saddr;
    struct sockaddr_in *cli_sin4;
    struct sockaddr_in6 *cli_sin6;
    char ipaddrbuf[INET6_ADDRSTRLEN];
    const char *ipaddr = NULL;
    int cli_len, ret;
    int portno;

    data process...
    memset((char *)&cli_saddr, 0, sizeof(cli_saddr));
    cli_len = sizeof(cli_saddr);
    ret = tpgetpeername((struct sockaddr *)&cli_saddr, &cli_len);
    if (ret == -1) {
        error processing
    }
    else {
        if (cli_saddr.ss_family == AF_INET) {
            cli_sin4 = (struct sockaddr_in *)&cli_saddr;
            ipaddr = inet_ntop(AF_INET, &(cli_sin4->sin_addr), ipaddrbuf, sizeof(ipaddrbuf));
            portno = ntohs(cli_sin4->sin_port);
        } else if (cli_saddr.ss_family == AF_INET6) {
            cli_sin6 = (struct sockaddr_in *)&cli_saddr;
            ipaddr = inet_ntop(AF_INET6, &(cli_sin6->sin6_addr), ipaddrbuf, sizeof(ipaddrbuf));
            portno = ntohs(cli_sin6->sin6_port);
        }
        if (ipaddr == NULL)
            ipaddr = "unknown";
    }
    printf(“ip = %s , port = %d\n”, ipaddr, portno);
    data process...

    tpreturn(TPSUCCESS, 0, 0, 0, 0);
}

관련함수

tpgetpeer_ipaddr(), tpgetsockname(), tpstart()

프로토타입

# 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 <tmaxapi.h>
int  tpgetsockname (struct sockaddr  *name,  int  *namelen)

파라미터

반환값

오류

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

예제

#include <stdio.h>
#include <netinet/in.h>
#include <arpa/inet.h>
#include <usrinc/atmi.h>
#inlcude <usrinc/tmaxapi.h>
...
DELETE(TPSVCINFO *msg)
{
    ...
    struct sockaddr_in cli;
    char ipAddr[16];
    int cli_len, ret, i;
    ...
    memset((char *)&cli, 0, sizeof(cli));

    ret = tpgetsockname((struct sockaddr *)&cli_saddr, &cli_len);
    if (ret == -1){ 
        error processing 
    }
    else{
        memcpy(ipAddr, inet_ntoa(cli.sin_addr), 16);
    }    
    printf(“ip = %s , port = %d\n”, ipAddr, cli.sin_port);
    ...
}

예제 - IPv6 프로토콜 환경

#include <stdio.h>
#include <netinet/in.h>
#include <arpa/inet.h>
#include <usrinc/atmi.h>
#inlcude <usrinc/tmaxapi.h>
...
DELETE(TPSVCINFO *msg)
{
    struct sockaddr_storage cli_saddr;
    struct sockaddr_in *cli_sin4;
    struct sockaddr_in6 *cli_sin6;
    char ipaddrbuf[INET6_ADDRSTRLEN];
    const char *ipaddr = NULL;
    int cli_len, ret;
    int portno;

    data process...
    memset((char *)&cli_saddr, 0, sizeof(cli_saddr));
    cli_len = sizeof(cli_saddr);
    

    ret = tpgetsockname((struct sockaddr *)&cli_saddr, &cli_len);
    if (ret == -1) {
        error processing
    }
    else {
        if (cli_saddr.ss_family == AF_INET) {
            cli_sin4 = (struct sockaddr_in *)&cli_saddr;
            ipaddr = inet_ntop(AF_INET, &(cli_sin4->sin_addr), ipaddrbuf, sizeof(ipaddrbuf));
            portno = ntohs(cli_sin4->sin_port);
        } else if (cli_saddr.ss_family == AF_INET6) {
            cli_sin6 = (struct sockaddr_in *)&cli_saddr;
            ipaddr = inet_ntop(AF_INET6, &(cli_sin6->sin6_addr), ipaddrbuf, sizeof(ipaddrbuf));
            portno = ntohs(cli_sin6->sin6_port);
        }
        if (ipaddr == NULL)
            ipaddr = "unknown";
    }
    printf(“ip = %s , port = %d\n”, ipaddr, portno);
    ...
}

관련함수

tpgetpeer_ipaddr(), tpgetpeername(), tpstart()

프로토타입

#include <usrinc/tmaxapi.h>
int tpgetsprlist(char *svc, int svgno, int *starti, int *endi, long flagsl);

파라미터

반환값

오류

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

예제

main(int argc, char *argv[])
{
    int     ret;
    int     starti = 0, endi = 0;
        
    if (argc != 2) {
       printf(“Usage: argv[1] string\n”);
       exit(1);
       if((ret = tmaxreadenv( “tmax.env”,”TMAX” )) == -1 ){
          printf(“<%-15s> tmaxreadenv fail [%s]”, __FILE__, tpstrerror(tperrno));
          exit(1);
       }

    if (tpstart((TPSTART_T *)NULL) == -1){
        printf(“<%-15s> tpstart fail [%s]”, __FILE__, tpstrerror(tperrno));
        exit(1);
    }

    /* tpgetsprlist in client */
    ret = tpgetsprlist(argv[1], 2, &starti, &endi, 0);
    if (ret < 0) {
        printf(“<%-15s> tpgetsprlist fail [%s]”, __FILE__, tpstrerror(tperrno));
        exit(1);
    } 
    else {
       printf(“Received Message : starti[%d], endi[%d]\n”, starti, endi);
    }
    tpend();
}

프로토타입

#include <tmaxapi.h>
struct svglist* tpgetsvglist(char *svc, long flags)

파라미터

반환값

에러가 발생하면 NULL을 반환하고 tperrno에 상황에 해당하는 값이 설정된다. 그렇지 않으면 서비스 호출에 실패한 서버 그룹 리스트를 struct svglist 에 설정하여 반환한다.

반환한 struct svglist의 내용은 다음과 같다.

struct svglist {
    int ns_entry;
    int nf_entry; 
    int *s_list;
    int *f_list;
};

오류

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

프로토타입

#include <tuxfatmi.h>
int tpgprio (void)

반환값

오류

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

예제

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

SERVICE(TPSVCINFO *msg)
{
    int ret, prio;
    prio = tpgprio();
    if (prio==-1) { error processing }
    if (prio > 50) tpforward(“SERVICE1”, msg->data, msg->len, 0);
    else  tpforward(“SERVICE2”, msg->data, msg->len, 0);
}

관련함수

tpacall(), tpcall(), tpsprio()

프로토타입

#include <tmaxapi.h>
struct svglist *tpmcall(char *qname, char *svc, char *data, long len, long flags)

파라미터

반환값

에러가 발생하면 NULL을 반환하고 tperrno에 상황에 해당하는 값이 설정된다. 그렇지 않으면 서비스 호출에 실패한 서버 그룹 리스트를 struct svglist 에 설정하여 반환한다.

반환한 struct svglist의 내용은 다음과 같다.

struct svglist {
    int ns_entry;
    int nf_entry;
    int *s_list;
    int *f_list;
};

오류

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

예제

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

main(int argc, char *argv[])
{
    char    *sndbuf;
    int     ret;
    …

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

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

    ret = tpmcall(NULL, “TPMCALL”, sndbuf, 0, TPNOFLAGS);
    if (ret == NULL){  error processing  }
    …
}

관련함수

tpcall(), tpgetsvglist(), tpmcallx()

프로토타입

#include <usrinc/tmaxapi.h>
struct svglistx* tpmcallx(char *svc, char *data, long len, long flags)

파라미터

flags로 사용 가능한 값은 아래와 같다.

반환값

에러가 발생하면 NULL을 반환하고 tperrno에 상황에 해당하는 값이 설정된다. 그렇지 않으면 서비스 호출에 실패한 서버 그룹 리스트를 struct svglistx에 설정하여 반환한다.

반환한 struct svglistx의 내용은 다음과 같다.

struct svglistx {
     int ns_entry; /* number of entries of s_list */
     int nf_entry; /* number of entries of f_list */
     int nr_entry; /* number of entries of r_list */
     int *s_list; /* list of server group numbers */
     int *f_list; /* list of tperrno of each server group */
     int *r_list; /* list of tpurcode of each server group */
};

오류

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

예제

#include <stdio.h>
#include <unistd.h>
#include <stdlib.h>
#include <string.h>
#include <usrinc/atmi.h>
#include <usrinc/tmaxapi.h>
main(int argc, char *argv[])
{
     char *sndbuf, *rcvbuf;
     long rcvlen, sndlen;
     struct svglistx svglist;
     struct svglistx *psvglist;
     int ret, i;

     psvglist = &svglist;
     if (argc != 2) {
          printf("Usage: toupper string\n");
          exit(1);
     }

     if ( (ret = tmaxreadenv( "tmax.env","TMAX" )) == -1 ){
          printf( "tmax read env failed\n" );
          exit(1);
     }

     if (tpstart((TPSTART_T *)NULL) == -1){
          printf("tpstart failed[%s]\n",tpstrerror(tperrno));
          exit(1);
     }

     if ((sndbuf = (char *)tpalloc("STRING", NULL, 0)) == NULL)
     {
          printf("sendbuf alloc failed !\n");
          tpend();
          exit(1);
     }

     if ((rcvbuf = (char *)tpalloc("STRING", NULL, 0)) == NULL)
     {
          printf("recvbuf alloc failed !\n");
          tpfree((char *)sndbuf);
          tpend();
          exit(1);
     }

     strcpy(sndbuf, argv[1]);
     psvglist = tpmcallx("TOUPPER", sndbuf, 0, TPBLOCK);
     if(psvglist == NULL)
     {
          printf("tpmcall is failed[%s]\n",
          tpstrerror(tperrno));
          tpfree((char *)sndbuf);
          tpfree((char *)rcvbuf);
          tpend();
          exit(1);
     }

     printf("send data: %s\n", sndbuf);
     printf("ns_entry = %d\n", psvglist->ns_entry);
     printf("nf_entry = %d\n", psvglist->nf_entry);
     printf("nr_entry = %d\n", psvglist->nr_entry);

     for(i=0; i<psvglist->ns_entry; i++)
          printf("psvglist->s_list[%d] = %d\n", i, psvglist->s_list[i]);
     for(i=0; i<psvglist->nf_entry; i++)
          printf("psvglist->f_list[%d] = %d\n", i, psvglist->f_list[i]);
     for(i=0; i<psvglist->nr_entry; i++)
          printf("psvglist->r_list[%d] = %d\n", i, psvglist->r_list[i]);

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

관련함수

tpcall(), tpgetsvglist(), tpmcall()

프로토타입

#include <atmi.h>
int tpnotify(CLIENTID *id, char *data, long len, long flags);

파라미터

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

반환값

오류

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

예제

#include <stdio.h>
#include <usrinc/atmi.h>
#include <usrinc/fbuf.h>
#include “../fdl/demo_fdl.h”

TOUPPER(TPSVCINFO* msg) {
    int i, n;
    char    rdata[100];
    FBUF    *stdata;

    stdata=(FBUF *)msg->data;
    memset(rdata, 0x00, sizeof(rdata));
    if (fbget(stdata, INPUT, rdata, 0) == -1){
    printf(“fbget failed errno = %d\n”, fberror);
    }

    for (i = 0; i < msg->len; i++) {
        rdata[i] = toupper(rdata[i]);
    }
    if (fbput(stdata, OUTPUT, rdata, 0) == -1)
        printf(“fbput failed\n”);

    i = tpnotify(&(msg->cltid), (char*)stdata, 0, TPACK);
    printf(“i= %d\n”, i);
    tpreturn(TPSUCCESS, 0, (char *)stdata, 0, 0);
}

프로토타입

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

파라미터

반환값

오류

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

관련함수

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

프로토타입

#include <tmaxapi.h>
int tpputenv(char *string)

파라미터

반환값

예제

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

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

    SDLFI=tpgetenv(“SDLFILE”);
    if (SDLFI=NULL) ret=tpputenv(“SDLFILE=/tmax/sample/sdl/test.sdl”);
    if (ret<0) { error processing }

    SDLFI=tpgetenv(“SDLFILE”);
    printf (“tmax sdlfile : %s\n”,SDLFI);
}

관련 함수

tpgetenv()

프로토타입

# 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  tpqsvcstat (char *qname, char * svc, long  flags )

파라미터

다음은 flags에 설정 가능한 값에 대한 설명이다.

반환값

오류

tpqscvstat()가 정상 처리되지 않을 경우 tperrno에 아래 값 중 하나가 설정된다.

관련 함수

tpenq(), tpdeq(), tpqstat()

프로토타입

# 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>
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 <tmaxapi.h>
int  tpreissue(char *qname, char *filter, long flags)

파라미터

반환값

오류

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

관련 함수

tpenq(), tpdeq()

프로토타입

# include <tuxatmi.h>
int  tpscmt(long  flags)

파라미터

반환값

예제

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

int main(int argc, char *argv[])
{
    ...
    ret = tpstart((TPSTART_T *)NULL);
    if (ret == -1) {
        error processing
    }
    ...
    ret = tpscmt(TP_CMT_COMPLETED);
    if (ret < 0){
        error processing
    }

    ret = tpbegin();
    if (ret < 0){
        error processing
    }
    ...
    ret= tpcall(“SERVICE1”,(char*)buf, strlen(buf),(char **)&get,&rlen,TPNOFLAGS);
    if (ret == -1)
    {
        error processing
    }
    ...
    ret= tpcall(“SERVICE2",(char*)buf,strlen(buf),(char **)&get,&rlen,TPNOFLAGS);
    if (ret == -1)
    {
        error processing
    }

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

프로토타입

# 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 <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 <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 <ucs.h>
int  tpsetfd (int  fd)

파라미터

반환값

오류

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

예제

#include <stdio.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <errno.h>
#include <usrinc/ucs.h>
... 
#define SERV_ADDR “168.126.185.129”
#define SERV_PORT 1500
 
int fd_read(int, char *, int);
extern int errno;
 
int usermain(int argc, char *argv[])
{
    ...
    int listen_fd, n, newfd;
    struct sockaddr_in my_addr, child_addr;
    socklen_t child_len;
    buf = tpalloc(“STRING”, NULL, 0);
    if (buf == NULL){
        error processing
    }
 
    memset((void *)&my_addr, NULL, sizeof(my_addr));
    memset((void *)&child_addr, NULL, sizeof(child_addr));
    listen_fd = socket(AF_INET, SOCK_STREAM, 0);
    if (listen_fd == -1){
        error processing
    }
 
    my_addr.sin_family = AF_INET;
    inaddr = inet_addr(SERV_ADDR);
    my_addr.sin_port = htons((unsigned short)SERV_PORT);
 
    if (inaddr != -1){
        memcpy((char *)&my_addr.sin_addr, (char *)&inaddr, sizeof(inaddr));
    } 
    ret = bind(listen_fd, (struct sockaddr *)&my_addr, sizeof(my_addr));
    if (ret == -1){
        error processing
    }
    ret = listen(listen_fd, 5);
    if (ret == -1){
        error processing
    }
 
    ret = tpsetfd(listen_fd);
    if (ret == -1){
        error processing
    }
    ...

    while(1) {
        n = tpschedule(10);
        ...
        if (n == UCS_USER_MSG){
            if (tpissetfd(listen_fd)) {
                child_len = sizeof(child_addr);
                newfd = accept(listen_fd, &child_addr, &child_len);
                if (newfd == -1){
                    error processing
                }
 
            ret = tpsetfd(newfd);
            if (ret == -1){
                error processing
            }
        }
 
        if (tpissetfd(newfd)){
            /* 소켓으로 부터 버퍼를 읽는다 */
            fd_read(newfd, buf, 1024);
            ret = tpcall(“SERVICE”, (char *)buf, sizeof(buf), (char **)&buf, 
                           (long *)&rlen, TPNOFLAGS);
            if (ret == -1){
                error processing
            }
            ...
            tpclrfd(newfd);
            close(newfd);
        }
        ...   
    }
    return 1;
} 

관련 함수

tpclrfd(), tpissetfd()

프로토타입

#include <tmaxapi.h>
int  tpsleep (struct  timeval  *timeout)

파라미터

timeout은 timeval이라는 구조체에 대한 포인터로서 다음과 같이 구성되어 있다(UNIX 시스템의 <sys/time.h>을 참고한다).

struct timeval{
      long    tv_sec    /* seconds unit */
      long    tv_usec  /* 0.000001 (micro seconds) unit */
};

반환값

오류

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

예제

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

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

    struct timeval sl_time, *sleep;
    sl_time.tv_sec =3;
    sl_time.tv_usec=500000;
    sleep=&sl_time;

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

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

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

    ret=tpsleep(sleep); /* 3.5초간 대기 */ 
    if (ret==-1) 
       { error processing }
    if (ret==0) 
       printf(“waited 3.5sec\n”);

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

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

관련 함수

tp_sleep(), tp_usleep(), tpacall(), tpbroadcast(), tpgetrply()

프로토타입

#include <usrinc/tmaxapi.h>
int tpspracall(char *svcname, int spri, char *data, long lenl, long flagsl);

파라미터

반환값

오류

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

예제

....
main(int argc, char *argv[])
{
    char    *sndbuf, *rcvbuf;
    long    sndlen, rcvlen;
    int     ret, cd;
    int     starti = 0, endi = 0, spri = 0;
    if (argc != 2) {
        printf(“Usage: argv[1] string\n”);
        exit(1);
    }

    if ( (ret = tmaxreadenv( “tmax.env”,”TMAX” )) == -1 ){
        printf(“<%-15s> tmaxreadenv fail [%s]”, __FILE__, tpstrerror(tperrno));
        exit(1);
    }

    if (tpstart((TPSTART_T *)NULL) == -1){
        printf(“<%-15s> tpstart fail [%s]”, __FILE__, tpstrerror(tperrno));
        exit(1);
    }

    if ((sndbuf = (char*)tpalloc(“CARRAY”, 0, 0)) == NULL) {
        printf(“<%-15s> sndbuf tpalloc fail [%s]”, __FILE__, tpstrerror(tperrno));
        exit(1);
    }

    if ((rcvbuf = (char*)tpalloc(“CARRAY”, 0, 0)) == NULL) {
        printf(“<%-15s> sndbuf tpalloc fail [%s]”, __FILE__, tpstrerror(tperrno));
        tpfree((char*)sndbuf);
        exit(1);
    }

    /* tpgetsprlist in client */
    ret = tpgetsprlist(argv[1], 2, &starti, &endi, 0);
    if (ret < 0) {
        printf(“<%-15s> tpgetsprlist fail [%s]”, __FILE__, tpstrerror(tperrno)
    );
    exit(1);
    } else {
        /*printf(“Received Message from Server : 
         starti[%d], endi[%d]\n”, starti, endi);*/
    }
    strcpy((char*)sndbuf, “tpspracall test”);

    /* tpspracall in client */
    for(spri = starti; spri <= endi; spri++) {
        cd = tpspracall(argv[1], spri, sndbuf, strlen(sndbuf), 0);
        if(cd < 0) {
            printf(“<%-15s> tpsprcall fail [%s]”, __FILE__, tpstrerror(tperrno));
            exit(1);
        } else {
            ret = tpgetrply(&cd, &rcvbuf, &rcvlen, 0);
            if(ret < 0) {
                printf(“Received Message from %d spri: tpgetrply fail[%s]\n”, 
                         spri, tpstrerror(tperrno));
            } else {
                printf(“Received Message from %d spri: msg[%s], len[%d]\n”, 
                         spri, rcvbuf, rcvlen);
            }
        }
    }
    tpend();
}

프로토타입

#include <tuxatmi.h>
int tpsprio (int prio, long flags)

파라미터

반환값

오류

tpsprio()가 정상적으로 수행되지 않을 경우 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 };
    ret=tpsprio(30,0);
    if (ret==-1) { error processing }

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

    data process....

    ret=tpsprio(-20,0);
    if (ret==-1) { error processing }

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

    tpfree(buf);
    tpend();
}

관련 함수

tpacall(), tpcall(), tpgprio()

클라이언트 프로그램

함수를 사용하여 하나의 클라이언트가 기존에 생성된 다른 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()

프로토타입

# include <atmi.h>
char *tpstrerror (int 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->dompwd, “tuxedo”);

    if (tpstart(tpinfo) == -1){
        printf(“tpstart fail , err = %s\n”, tpstrerror(tperrno)); 
        exit(1);
    }

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

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

프로토타입

# include <tmaxapi.h>
char *tpsubqname(int type)

파라미터

tpqstat(), tpqsvcstat() 등에 사용된 것과 동일한 의미로 서브 큐 번호에 해당하는 이름은 다음과 같다.

반환값

프로토타입

# 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 <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 <tmaxapi.h>
int tpunsubscribe(long sd, long flags)

파라미터

반환값

오류

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

관련함수

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

프로토타입

#include <tuxfml.h>
char *tuxgetenv(char *name)

파라미터

반환값

예제

...
#include <tuxinc/tuxatmi.h>
int main(int argc, char *argv[])
{
    ...
    char hostAddr[20];    
    ...
    memset(hostAddr, NULL, sizeof(hostAddr));
    memcpy(hostAddr, tuxgetenv(“TMAX_HOST_ADDR”), sizeof(hostAddr));
    printf(“host address = %s\n”, hostAddr);
    ...
}

관련 함수

tuxputenv()

프로토타입

#include <tuxfml.h>
int tuxputenv(char *string)

파라미터

반환값

예제

 ...
#include <tuxinc/tuxatmi.h>
int main(int argc, char *argv[])
{
    ...
    char hostAddr[20];
    char envVal[20];
    ...
    ret = tuxputenv(“A=10”);
    if (ret < 0){
        printf(“tuxputenv fail...[%d]\n”, tperrno);
    }
    memset(envVal, NULL, sizeof(envVal));
    memcpy(envVal, tuxgetenv(“A”), sizeof(envVal));
    printf(“envVal = %s\n”, envVal);
    ...
}

관련 함수

tuxgetenv()

프로토타입

#include <tuxfml.h>
int tuxreadenv (char *file, char *label)

파라미터

반환값

오류

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

예제

...
#include <tuxinc/tuxatmi.h>
int main(int argc, char *argv[])
{
    ...
    ret = tuxreadenv( “tmax.env”,”TMAX” );
    if (ret == -1){
        error processing
    }
    ret = tpinit((TPINIT *)NULL);
    if (ret == -1){
        error processing
    }
    ...
    ret = tpcall(“SERVICE”, buf, 0, &buf, &rcvlen, TPNOFLAGS);
    if (ret == -1){
        error processing
    }
    ...
    tpterm();
}

관련 함수

tpstart()

프로토타입

#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()이 정상적으로 수행되지 않을 경우 다음의 에러 코드를 반환한다.