Prototype

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

Return Value

Returns an errno. For more information about errno, refer to "Appendix A. Error Codes and Actions to Be Taken" or "Tmax Application Development Guide".

Example

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

Related Function

gettpurcode()

Prototype

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

Parameter

Return Value

Error

When a tmax_chk_conn() fails to execute, a tperrno will be set to one of the following values:

Example

#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 check */
        /***
        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…
        /* socket status check */
        /***********
        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… 
        /* Check for the connection status by transmitting message */
        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();
}

Related Function

tpalivechk()

Prototype

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

Return Value

Error

When tmax_gq_count() fails to execute, tperrno will be set to the following value:

Prototype

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

Parameter

Return Value

Error

When tmax_gq_get() fails to execute, tperrno will be set to the following value:

Prototype

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

Parameter

Return Value

Error

When tmax_gq_getkeylist() fails to execute, tperrno will be set to the following value:

Prototype

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

Parameter

Return Value

Error

When tmax_gq_keygen() fails to execute, tperrno will be set to the following value:

Prototype

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

Parameter

Return Value

Error

When a tmax_gq_purge() fails to execute, a tperrno will be set to one of the following values:

Prototype

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

Parameter

The following are possible flag values:

Return Value

Error

When a tmax_gq_put() fails to execute, a tperrno will be set to one of the following values:

Prototype

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

Return Value

Error

When tmax_get_sessionid() fails to execute, tperrno will be set to the following value:

Prototype

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

Parameter

Return Value

Error

When tmax_keylist_count() fails to execute, tperrno will be set to the following value:

Prototype

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

Parameter

Return Value

Error

When a tmax_keylist_free() fails to execute, a tperrno will be set to the following value:

Prototype

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

Parameter

The following is an example of keyinfo:

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

Return Value

Error

When a tmax_keylist_getakey() fails to execute, a tperrno will be set to one of the following values:

Prototype

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

Return Value

Error

When a tmax_sq_count() fails to execute, a tperrno will be set to the following value:

Prototype

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

Parameter

Return Value

Error

When a tmax_sq_get() fails to execute, a tperrno will be set to one of the following values:

Prototype

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

Parameter

Return Value

Error

When a tmax_sq_getkeylist() fails to execute, a tperrno is set to one of the following values:

Prototype

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

Parameter

Return Value

Error

When a tmax_sq_keygen() fails to execute, a tperrno will be set to the following value:

Prototype

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

Parameter

Return Value

Error

When a tmax_sq_purge() fails to execute, a tperrno will be set to the following value:

Prototype

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

Parameter

The following are possible flag values:

Return Value

Error

When a tmax_sq_put() fails to execute, a tperrno will be set to one of the following values:

Prototype

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

Parameter

Return Value

Error

When a tmaxlastsvc() fails to execute, a tperrno will be set to the following value:

Example

#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
   }
   ...
}

Prototype

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

Parameter

Return Value

Example

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

void main(int argc, char* argv[])
{
    tmaxreadenv(“tmax.env”, “tmax”);  /*”obtains environment variable from "tmax"section of tmax.env"*/
    tpstart((TPSTART_T *)NULL);
    data process…
    tpend();
}

Related Function

tpstart()

Prototype

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

Parameter

Return Value

Error

When a tp_sleep() fails to execute, a tperrno will be set to one of the following values:

Related Functions

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

Prototype

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

Parameter

Return Value

Error

When a tp_usleep() fails to execute, a tperrno will be set to one of the following values:

Example

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

Related Functions

tmax_get_db_usrname(), tmax_get_db_tnsname()

Prototype

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

Parameter

Return Value

Refer to "3.1.88. tx_rollback".

Error

Refer to "3.1.88. tx_rollback".

Example

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

Related Function

tx_rollback()

Prototype

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

Parameter

The following are the available flags:

Return Value

Error

If a tpacall() fails, a tperrno will be set to one of the following values:

Example

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

Related Functions

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

Prototype

#include <usrinc/tmaxapi.h>
int tpacallsvg (int svgno, char *svc, char *data, long lenl, long flagsl)

Parameter

Refer to "3.1.24. tpacall" for the parameters other than svgno.

Return Value

Error

Refer to the error section of the "3.1.24. tpacall" function.

Example

<Client Program>

#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;
}

Related Functions

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

Prototype

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

Return Value

Error

When a tpalivechk() fails to execute, a tperrno will be set to one of the following values:

Example

#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 status check */
    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();
}

Related Function

tmax_chk_conn()

Prototype

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

Parameter

Return Value

Error

When a tpalloc() fails to execute, a tperrno will be set to one of the following values:

Example

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

Related Functions

tpfree(), tprealloc(), tptypes()

Prototype

int tpbegin(unsigned long timeout, long flags);

Parameter

Return Value

Refer to "3.1.91. tx_set_transaction_timeout" and "3.1.85. tx_begin".

Example

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

Related Functions

tx_set_transaction_timeout(), tx_begin()

Prototype

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

Parameter

The following are possible flag values:

Return Value

Error

When a tpbroadcast() fails to execute and no messages can be transmitted to a client, a tperrno will be set to one of the following values:

Example

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

Related Functions

tpalloc(), tpend(), tpstart()

Prototype

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

Parameter

The following are available flags:

Return Value

Error

If a tpcall() fails, a tperrno will be set to one of the following values:

Example

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

Related Functions

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

Prototype

#include <usrinc/tmaxapi.h>
int tpcallsvg (int svgno, char *svc, char *idata, long ilenl, char **odata, 
               long *olen, long flagsl)

Parameter

Refer to "3.1.30. tpcall" for parameters other than svgno.

Return Value

Error

Refer to the error section of the "3.1.30. tpcall" section.

Example

<Client Program>

#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;
}

Related Functions

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

Prototype

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

Parameter

Return Value

Error

When a tpcancel() fails to execute, a tperrno will be set to one of the following values:

Example

#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]);         /* Cancels the second response. */
    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();
}

Related Function

tpacall()

Prototype

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

Parameter

Return Value

Refer to "3.1.86. tx_commit".

Example

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

Related Function

tx_commit()

Prototype

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

Parameter

The following are possible flag values:

Return Value

Error

If a function call fails, a caller's transaction will not be affected unless there is a specific direction. When a tpconnect() fails to execute, a tperrno will be set to one of the following values:

Example

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

Related Functions

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

Prototype

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

Parameter

The following are possible flag values:

Return Value

Error

When a tpdeq() fails to execute, a tperrno will be set to one of the following values:

Example

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

Related Functions

tpenq(), tpqstat()

Prototype

#include <usrinc/tmaxapi.h>
int tpdeq_ctl(char *qname, char *svc, TMQCTL *ctl, char **data, 
              long *len, long flags);

Parameter

The following are possible flag values:

Return Value

Error

When a tpdeq_ctl() fails to execute, a tperrno will be set to one of the following values:

Example

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

Related Functions

tpenq_ctl(), tpqstat()

Prototype

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

Parameter

Return Value

Error

When a tpdiscon() fails to execute, a tperrno will be set to one of the following values:

Example

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

Related Functions

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

Prototype

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

Parameter

The following are possible flag values:

Return Value

Error

When a tpenq() fails to execute, a tperrno will be set to one of the following values:

Example

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

Related Functions

tpdeq(), tpqstat()

Prototype

#include <usrinc/tmaxapi.h>
int tpenq_ctl(char *qname, char *svc, TMQCTL *ctl, char *data, long len, 
              long flags);

Parameter

The following are possible flag values:

Return Value

Error

When a tpenq_ctl() fails to execute, a tperrno will be set to one of the following values:

Example

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

Related Functions

tpdeq_ctl(), tpqstat()

Prototype

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

Parameter

Return Value

Example

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

Prototype

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

Parameter

The following are the possible type values:

Return Value

Error

When a tpextsvcname() fails to execute, a tperrno will be set to one of the following values:

Related Functions

tpenq(), tpdeq(), tpextsvcname()

Prototype

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

Parameter

Return Value

Error

When a tpextsvcname() fails to execute, a tperrno will be set to one of the following values:

Example

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

Related Functions

tpenq(), tpdeq()

Prototype

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

Parameter

Return Value

A tpfree() function does not return any value to a function caller.

Example

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

Related Functions

tpalloc(), tprealloc()

Prototype

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

Return Value

A tpget_timeout() returns a configured blocking time (in seconds) and does not return an error.

Example

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

Prototype

#include <tmaxapi.h>
int tpgetactivesvr(char *nodename, char **outbufp);

Parameter

Return Value

Error

When a tpgetclid() fails to execute, a tperrno will be set to one of the following values:

Example

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

Prototype

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

Parameter

Return Value

Error

When a tpgetcliaddr() fails to execute, a tperrno will be set to one of the following values:

Example

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

Related Function

tpgetclid()

Prototype

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

Parameter

Return Value

Error

When a tpgetcliaddr_ipv6() fails to execute, a tperrno will be set to one of the following values:

Example

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

Related Function

tpgetclid()

Prototype

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

Return Value

Error

When a tpgetclid() fails to execute, a tperrno will be set to one of the following values:

Example

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

Related Function

tpsendtocli()

Prototype

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

Parameter

Return Values

Error

When a tpgetctxt() fails to execute, a tperrno will be set to one of the following values:

Example - Client Program

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

Example - Server Program

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

Related Function

tpsetctxt()

Prototype

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

Parameter

Return Value

Example

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

Related Function

tpputenv()

Prototype

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

Return Value

Example

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

Prototype

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

Parameter

Return Value

Error

When a tpgetpeername() fails to execute, a tperrno will be set to one of the following values:

Example

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

Example - IPv6 protocol environment

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

Related Functions

tpgetpeer_ipaddr(), tpgetsockname(), tpstart()

Prototype

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

Parameter

The following are the available flags:

Return Value

Error

If a tpgetrply() fails, a tperrno will be set to one of the following values:

Example

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

Related Functions

tpacall(), tpalloc(), tpreturn()

Prototype

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

Parameter

Return Value

Error

When a tpgetsockname() fails to execute, a tperrno will be set to one of the following values:

Example

#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);
    ...
}

Example - IPv6 protocol environment

#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);
    ...
}

Related Functions

tpgetpeer_ipaddr(), tpgetpeername(), tpstart()

Prototype

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

Parameter

Return Value

Error

When a tpgetsprlist() fails to execute, a tperrno will be set to one of the following values:

Example

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

Prototype

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

Parameter

Return Value

When an error occurs, a tpgetsvglist() will return a NULL and a tperrno will be set to an error code. Otherwise, a tpgetsvglist() will store a list of server groups that failed to be called into a svglist struct and will return a struct.

The following is the structure of a svglist struct:

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

Error

When a tpgetsvglist() fails to execute, a tperrno will be set to one of the following values:

Prototype

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

Return Value

Error

When a tpgprio() fails to execute, a tperrno will be set to one of the following values:

Example

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

Related Functions

tpacall(), tpcall(), tpsprio()

Prototype

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

Parameter

Return Value

When an error occurs, a tpmcall() will return a NULL and a tperrno will be set to an error code. Otherwise, a list of server groups that failed to be called will be returned in a svglist struct.

The following will be returned:

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

Error

When a tpmcall() fails to execute, a tperrno will be set to one of the following values:

Example

#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  }
    …
}

Related Functions

tpcall(), tpgetsvglist(), tpmcallx()

Prototype

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

Parameter

The following are possible flag values:

Return Value

When an error occurs, a tpmcallx() will return a NULL and a tperrno will be set to an error code. Otherwise, a list of server groups that failed to be called will be returned in a svglist struct.

The following will be returned:

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 */
};

Error

When a tpmcallx() fails to execute, a tperrno will be set to one of the following values:

Example

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

Related Functions

tpcall(), tpgetsvglist(), tpmcall()

Prototype

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

Parameter

The following are possible flag values:

Return Value

Error

When a tpnotify() fails to execute, a tperrno will be set to one of the following values:

Example

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

Prototype

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

Parameter

Return Values

Error

When a tppost() fails to execute, a tperrno will be set to one of the following values:

Related Functions

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

Prototype

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

Parameter

Return Value

Example

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

Related Function

tpgetenv()

Prototype

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

Parameter

The following are possible flag values:

Return Values

Error

When a tpqstat() fails to execute, a tperrno will be set to one of the following values:

Example

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

Related Functions

tpenq(), tpdeq()

Prototype

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

Parameter

The following are possible flag values:

Return Value

Error

When a tpqscvstat() fails to execute, a tperrno will be set to one of the following values:

Related Functions

tpenq(), tpdeq(), tpqstat()

Prototype

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

Parameter

Return Values

Error

When a tprealloc() fails to execute, a tperrno will be set to one of the following values:

Example

#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 }
}

Related Functions

tpalloc(), tpfree(), tptypes()

Prototype

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

Parameter

The following are possible flag values:

The following describes event types that are returned to a revent:

Return Value

If the value of a revent is TREV_SVCSUCC or TREV_SVCFAIL, a tpurcode global variable that is delivered by a tpreturn() will be defined by an application. Otherwise, a -1 will be returned and a tperrno will be set to the value corresponding to a state. If an event has no error, a tprecv() will return a -1 and a tperrno will be set to [TPEEVENT].

Error

When a tprecv() fails to execute, a tperrno will be set to one of the following values:

Example

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

Related Functions

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

Prototype

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

Parameter

Return Value

Error

When a tpreissue() fails to execute, a tperrno will be set to one of the following values:

Related Functions

tpenq(), tpdeq()

Prototype

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

Parameter

Return Value

Example

#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
    }
    ...
}

Prototype

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

Parameter

The following are possible flag values:

The events that can be delivered to revent are as follows:

Return Value

If a revent is a TREV_SVCFAIL, a tpurcode global variable is set to a rcode value, which is delivered when calling a tpreturn().

Error

When a tpsend() fails to execute, a tperrno will be set to one of the following values:

Example

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

Related Functions

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

Prototype

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

Parameter

Return Value

Error

When a tpsetsvctimeout() fails to execute, a tperrno will be set to one of the following values:

Example

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

Prototype

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

Parameter

Return Value

Error

When a tpset_timeout() fails to execute, a tperrno will be set to one of the following values:

Example

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

Prototype

#include <ucs.h>
int  tpsetfd (int  fd)

Parameter

Return Value

Error

When a tpsetfd() fails to execute, a tperrno will be set to one of the following values:

Example

#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)){
            /* Reads a buffer from a socket */
            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;
} 

Related Functions

tpclrfd(), tpissetfd()

Prototype

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

Parameter

A timeout is a pointer for a struct named timeval, which is composed as follows (See the <sys/time.h> file of a UNIX system).

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

Return Value

Error

When a tpsleep() fails to execute, a tperrno will be set to one of the following values:

Example

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

Related Functions

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

Prototype

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

Parameter

Return Value

Error

When a tpspracall() fails to execute, a tperrno will be set to one of the following values:

Example

....
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();
}

Prototype

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

Parameter

Return Value

Error

When a tpsprio() fails to execute, a tperrno will be set to one of the following values:

Example

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

Related Functions

tpacall(), tpcall(), tpgprio()

Client Program

A client can assign a different previously created context to a current client using a function. Most ATMI functions are based on per-context. To know the current context of a client, the return value of a tpgetctxt() can be checked.

A client can use multiple contexts, but only one context is used at a time. For example, if a tpacall() is called in context1, tpgetrply() must be called in context1 even though another context has been used.

Server Program

A service thread processes a service by getting a context, but a user created thread does not have its own context. Most ATMI functions can work after getting a context. Therefore a user created thread must share a context with a service thread if required. A user created thread can share a context with other service threads by using a tpsetctxt().

A user created thread that calls a tpsetctxt() shares context information with a service thread. For example, if a service thread calls a tpacall(), after that it is possible for a user created thread to receive a response for a request through a tpgetrply().

A tpsetctxt() cannot be used in a service thread. A service thread has its own context by default, and cannot replace the context with other one. Therefore, if a service thread calls a tpsetctxt(), an error will be returned with a TPEPROTO error code.

If a user created thread shares a context with a service thread through this function, the user created thread must call a tpsetctxt (TPNULLCONTEXT) before the service thread calls a tpreturn(). In other words, at the time that the service thread calls tpreturn(), the context of the service thread must be changed not to be shared by other user created threads. If this is not kept, tpreturn() will fail and aTPESVCERR error code will be returned to the client. Therefore, the process flow between threads must be controlled through synchronization. The ctxtid parameter of a tpsetctxt() uses the Context-ID which that is retrieved by calling a tpgetctxt() from a service thread.

Prototype

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

Parameter

Return Value

Error

When a tpsetctxt() fails to execute, a tperrno will be set to one of the following values:

Example - Client Program

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

Example - Server Program

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

Related Function

tpgetctxt()

Prototype

# include <atmi.h>
char *tpstrerror (int tperrno)

Parameter

Return Value

Example

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

Prototype

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

Parameter

The followings are names corresponding to a sub queue number. They are the same as those used in a tpqstat() and a tpqsvcstat().

Return Value

Prototype

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

Parameter

If a tpsubscribe() is executed by a server, a ctl must not be NULL and it should be configured as shown below:

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

Return Value

Error

When a tpsubscribe() fails to execute, a tperrno will be set to one of the following values:

Related Functions

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

Prototype

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

Parameter

Return Value

Error

When a tptypes() fails to execute, a tperrno will be set to one of the following values:

Example

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

Related Functions

tpalloc(), tpfree(), tprealloc()

Prototype

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

Parameter

Return Value

Error

When a tpunsubscribe() fails to execute, a tperrno will be set to one of the following values:

Related Functions

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

Prototype

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

Parameter

Return Value

Example

...
#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);
    ...
}

Related Function

tuxputenv()

Prototype

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

Parameter

Return Value

Example

 ...
#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);
    ...
}

Related Function

tuxgetenv()

Prototype

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

Parameter

Return Value

Error