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

Parameter

Return Value

Error

When a tpclrfd() 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 }

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

        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 }
                ...
            ret = tpclrfd(newfd);
            if (ret == -1){ error processing }
            close(newfd);
        }
        ...
   }
   return 1;
}

Related Function

tpissetfd()

Prototype

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

Parameter

Return Values

Error

When a tpissetfd() 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 }

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

tpissetfd(), tpsetfd()

Prototype

# include <ucs.h>
int  tpregcb (UcsCallback)

Parameter

Value

Error

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

Example

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

void reply_receive(UCSMSGINFO *reply);
DUMMY(TPSVCINFO *msg)
{
    data process ….
}

int usermain(int argc, char *argv[])
{
    int ret;
    char *buf

    ret = tpregcb(reply_receive);
    if (ret == -1){ error processing }
    buf=tpalloc(“STRING”, NULL, 0);
    if (buf==NULL) { error processing }
    data process…
    while(1)
    {
        ...
        tpschedule(3);
        cd = tpacall(“SERVICE”, buf, strlen(buf), TPNOFLAGS);
        if (cd < 0) { error processing }
        ...
    }
}

void reply_receive(UCSMSGINFO *reply)
{
    printf(“data....%s\n”, reply->data);
}

Related Function

tpunregcb()

Prototype

#include <ucs.h>
int  tprelay(char *svc, char *data, long len, long flags, CTX_T *ctxp);

Parameter

Return Value

Error

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

Example

...
#include <stdio.h>
#include <usrinc/ucs.h>
CTX_T *ctx = NULL;

DUMMY(TPSVCINFO *msg)
{
    data process ….
}

usermain(int argc, char *argv[])
{
    int ret, i;
    char *rcvbuf, *sndbuf;
    long sndlen;

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

    while(1) {
        tpschedule(1);
        if (ctx != NULL) 
        {
            i++;
            if ((sndbuf = (char *)tpalloc(“CARRAY”,NULL, 1024)) == NULL)
            { error processing }
            else 
            {
                 ...
                 ret = tprelay(“TPRETURN”, sndbuf, sndlen, 0, ctx);
                 if (ret==-1) { error processing }
                 data process...
                 ctx = NULL;
                 tpfree(sndbuf);
             }
        }
    }
}

int RELAY(TPSVCINFO *rqst)
{
   ...
   ctx = tpsavectx();
   tpreturn(TPSUCCESS, 0, rqst->data, rqst->len, 0);
}

Related Functions

tpreturn(), tpforward()

Prototype

#include <ucs.h>
CTX_T * tpsavectx(void)

Return Value

Error

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

Example

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

CTX_T *ctx = NULL;

usermain(int argc, char *argv[])
{
    int ret, i;
    char *rcvbuf, *sndbuf;
    long sndlen;

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

    i = 0;
    while(1) {
        tpschedule(1);
        if (ctx != NULL) 
        {
            i++;
            if ((sndbuf = (char *)tpalloc(“CARRAY”,NULL, 1024)) == NULL)
            { error processing }
            else 
            {
                ...
                ret = tprelay(“TPRETURN”, sndbuf, sndlen, 0, ctx);
                if (ret==-1) { error processing }
                data process...
                ctx = NULL;
                tpfree(sndbuf);
            }
        }
    }
}

int RELAY(TPSVCINFO *rqst)
{
    ...
    ctx = tpsavectx();
    tpreturn(TPSUCCESS, 0, rqst->data, rqst->len, 0);
}

Related Functions

tpreturn(), tpforward(), tprelay()

Prototype

#include <ucs.h>
int  tpschedule(int timeout)

Parameter

Return Value

Error

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

Example

#include <stdio.h>
#include <usrinc/atmi.h>
#include <usrinc/ucs.h>
int usermain(int argc, char *argv[])
{
    ...
    while(1)
    {
        ...
        tpschedule(3);
        ret = tpcall(“SERVICE”, (char *)buf, strlen(buf), (char **)&buf, 
                      (long *)&rlen, TPNOFLAGS);
        if (ret == -1) { error processing}         
        ...
    }
}

Related Functions

tpsleep(), tp_sleep(), tp_usleep()

Prototype

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

Parameter

The following are possible flag values:

Return Value

Error

When a tpsendcli() 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 processing }

    ret=tpsendtocli(clid, (char *)buf, 0, 0);
    if (ret==-1) { error processing }
    tpreturn(TPSUCCESS, 0, 0, 0);
}

Related Function

tpbroadcast()

Prototype

# include <tmaxapi.h>
void  tpsvctimeout(TPSVCINFO *msg)

Parameter

Return Value

A tpsvctimeout() is designed to perform the actions required in a service timeout. There is no return value and no errors can occur.

Example

#include <stdio.h>
#include <usrinc/atmi.h>
SERVICE(TPSVCINFO *msg)
{
    ...
    tpreturn(TPSUCCESS,0,(char *)msg->data, 0,TPNOFLAGS);
}

void tpsvctimeout(TPSVCINFO *msg)
{
    ...
    tpreturn(TPFAIL, TPETIME, (char *)buf, sizeof(buf), TPNOFLAGS);
}

Prototype

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

Return Value

A tpsvrdone() is a function used to perform necessary jobs before a developer ends a server process. Due to this, it does not have a return value and an error cannot be generated.

Example

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

EXEC SQL INCLUDE sqlca.h;

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

    EXEC SQL begin declare section;
    ….
    EXEC SQL end declare section;
    EXEC SQL CONNECT : scott IDENTIFIED BY : tiger; 
    buf=tpalloc(“STRING”, NULL, 0);
    if (buf==NULL) { error processing }
    data process….

    cd=tpgetclid();
    if (cd==-1) { error processing }
    ret=tpsendtocli(cd, buf, 0, TPNOFLAGS);
    if (ret==-1) { error processing }
    data process....

    tpsvrdone();
}

void tpsvrdone()
{
    printf(“ Sevice end\n”);
    EXEC SQL COMMIT WORK RELEASE;
}

Related Functions

tx_close(), tpsvrinit()

Prototype

#include <ucs.h>
int  tpsvrdown(void)

Return Value

A tpsvrdown() is used to perform necessary jobs before a developer ends a server process, so it does not have a return value.

Example

...
#include <usrinc/atmi.h>
#include <usrinc/ucs.h>
int usermain(int argc, char *argv[])
{
    count=0;
    ...
    while(1)
    {
        ...
        tpschedule(3);
        cd = tpacall(“SERVICE”, buf, strlen(buf), TPNOREPLY);
        if (cd < 0) { error processing }
        ...
        if (count == 10) tpsvrdown();
    }
}

void reply_receive(UCSMSGINFO *reply)
{
    printf(“data....%s\n”, reply->data);
}

Related Functions

tpsvrinit(), tpsvrdone()

Prototype

#include <ucs.h>
int  tpunregcb (void)

Value

Error

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

Example

...
#include <usrinc/atmi.h>
#include <usrinc/ucs.h>
void reply_receive(UCSMSGINFO *reply);

int usermain(int argc, char *argv[])
{
    ...
    ret = tpregcb(reply_receive);
    if (ret == -1){ error processing  }

    ret = tpunregcb();
    if (ret == -1){  error processing  }
    while(1)
    {
        ...
        tpschedule(3);
        cd = tpacall(“SERVICE”, buf, strlen(buf), TPNOFLAGS);
        if (cd < 0) { error processing  }
        ...
    }
}

void reply_receive(UCSMSGINFO *reply)
{
    printf(“first reply receive\n”);
    printf(“data....%s\n”, reply->data); 
}

See also

tpregcb()

Prototype

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

Parameter

The following are possible flag values:

Return Value

Error

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

Example

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

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

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

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

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

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

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

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

Related Functions

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

Prototype

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

Parameter

Return Value

Error

When a tpsetunsol() 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 get_unsol(char *data, long len, long flags)
{
    printf(“get unsolicited data = %s\n”, data);
    data process....
}

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

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

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

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

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

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

Related Functions

tpstart(), tpend(), tpgetunsol()

Prototype

# include <atmi.h>
int  tpsetunsol_flag  (int  flag)

Parameter

Return Value

Example

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

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

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

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

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

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

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

Related Funciton

tpstart()