Prototype

int init_remote_info(char *myname, int mynumber, int num_channel, int key)

Parameter

Prototype

int remote_connected(int index, int addr, int portno, int type, int fd)

Parameter

Prototype

#include <arpa/inet.h>
int remote_connected_ipv6(int index, struct sockaddr *saddr, int portno, int type, int fd) 

Parameter

Example

int
remote_connected_ipv6(int index, struct sockaddr *saddr, int portno, int type, int fd)
{
    char buf[INET6_ADDRSTRLEN];
    char *ipaddr = NULL;
    int cli_portno;

    if (index < 0)
        return -1;

    if (saddr->sa_family == AF_INET6) {
        ipaddr = (char *)inet_ntop(AF_INET6, &(((struct sockaddr_in6 *)saddr)->sin6_addr), buf, sizeof(buf));
        cli_portno = ntohs(((struct sockaddr_in6 *)saddr)->sin6_port);
    } else if (saddr->sa_family == AF_INET) {
        ipaddr = (char *)inet_ntop(AF_INET, &(((struct sockaddr_in *)saddr)->sin_addr), buf, sizeof(buf));
        cli_portno = ntohs(((struct sockaddr_in *)saddr)->sin_port);
    }
    if (ipaddr == NULL)
        ipaddr = "unknown";

    printf("remote_connected_ipv6, REMOTE[%d] IPADDR[%s] CLIPORT[%d] SVRPORT[%d] TYPE[%d] fd[%d] connected\n",
            index, ipaddr, cli_portno, portno, type, fd);

    return 1;
}

Prototype

int remote_closed(int index, int type)

Parameter

Prototype

int allow_connection(int addr, int portno, int type, int fd)

Parameter

can be called

Example

int allow_connection(int addr, int portno, int type, int fd)
{
    int i, n, len;
    struct in_addr in;
    char *ipaddr, *endptr;
    char *deny[] = {"10.10.30.1",
                    "121.100.100.*",
                    NULL};

    if (addr == -1)
        return -1;
    in.s_addr = addr;
    ipaddr = inet_ntoa(in);

    for (i = 0; deny[i] != NULL; i++) {
        if ((endptr = strpbrk(deny[i], "*")) != NULL) {
            if (strncmp(deny[i], ipaddr, (endptr - deny[i])) == 0)
                return -1;
        } else {
            if (strcmp(deny[i], ipaddr) == 0)
                return -1;
        }
    }
    return 1;
}

Prototype

#include <arpa/inet.h>

int allow_connection(struct sockaddr *saddr, int portno, int type, int fd)

Parameter

can be called

Example

int
allow_connection_ipv6(struct sockaddr *saddr, int svr_portno, int type, int fd)
{
    char buf[INET6_ADDRSTRLEN];
    char *ipaddr;
    int cli_portno;

    int i, n, len;
    char *endptr;
    char *allow[] = {"10.10.30.1",
                    "121.100.100.*",
                    NULL};

    if (saddr->sa_family == AF_INET6) {
        ipaddr = (char *)inet_ntop(AF_INET6, &(((struct sockaddr_in6 *)saddr)->sin6_addr), buf, sizeof(buf));
        cli_portno = ntohs(((struct sockaddr_in6 *)saddr)->sin6_port);
    } else if (saddr->sa_family == AF_INET) {
        ipaddr = (char *)inet_ntop(AF_INET, &(((struct sockaddr_in *)saddr)->sin_addr), buf, sizeof(buf));
        cli_portno = ntohs(((struct sockaddr_in *)saddr)->sin_port);
    }
    if (ipaddr == NULL)
        ipaddr = "unknown";

    for (i = 0; allow[i] != NULL; i++) {
        if ((endptr = strpbrk(allow[i], "*")) != NULL) {
            if (strncmp(allow[i], ipaddr, (endptr - deny[i])) == 0)
                return 1;
        } else {
            if (strcmp(allow[i], ipaddr) == 0)
                return 1;
        }
    }
    return -1;
}

Prototype

int get_msg_length(msg_header_t *hp)

Parameter

can be called

Length of the actual data from the remote node. TCPGW reads the actual data from the remote node using the can be called of the function. The header can be checked for errors. If there is an error, return -2 to terminate the channel.

Prototype

int get_msg_info(msg_header_t *hp, char *data,msg_info_t *info)

Parameter

Return Value

Message type to send to Tmax service. TCPGW uses this value to determine what needs to be processed. For example, REMOTE_REQUEST indicates that there is a request from the remote node, and REMOTE_REPLY is a value that is returned when the remote node sends a response for the request from the Tmax service.

REMOTE_REPLY_CONT is a value returned when response messages are received in succession, REMOTE_SENDTOCLI is the value returned for an unrequested message.

If -1 is returned and the -e option is configured in the CLOPT section of the environment file, then the channel is terminated.

When a response is received from the remote node, the UID value must be set to the uid in the info struct. Other values must also be set appropriately.

Prototype

int get_channel_num(char *data)

Parameter

Return Value

Channel number.

Prototype

int put_msg_info(msg_header_t *hp, char *data, msg_info_t *info)

Parameter

Return Value

Total length of the data to send to the remote node, which includes the lengths of the message header and the actual data.

Prototype

int put_msg_complete(msg_header_t *hp, char *data, msg_info_t *info)

Parameter

Prototype

int get_service_name(char *header, int err, char *svc)

Parameter

Prototype

int prepare_shutdown(int code)

Parameter

Prototype

int set_service_time_out(int uid, char *header)

Parameter

Prototype

int chk_end_msg(int len, char *data)

Parameter

Prototype

int inmsg_recovery(char *data, msg_info_t *info)

Parameter

Return Value

Length of the newly created data.

Prototype

int inmsg_recovery(char *data, msg_info_t *info)

Parameter

Return Value

Prototype

int get_extmsg_info(msg_header_t *hp, char **data, int asize, msg_info_t *info)

Parameter

Return Value

Message type to send to Tmax service. TCPGW uses this value to determines what needs to be processed. For example, REMOTE_REQUEST indicates that there is a request from the remote node, and REMOTE_REPLY is a value that is returned when the remote node sends a response for the request from the Tmax service.

REMOTE_REPLY_CONT is a value returned when response messages are received in succession, REMOTE_SENDTOCLI is the value returned for an unrequested message.

When a response is received from the remote node, the UID value must be set to the uid in the info struct. Other values must also be set appropriately.

Prototype

int put_extmsg_info(msg_header_t *hp, char **data, int asize, msg_info_t *info)

Parameter

Return Value

Total length of the data to send to the remote node, which includes the lengths of the message header and the actual data.

Prototype

int set_ping_msg(msg_header_t *hp, int *interval, int *binterval, int *timeout, 
                 int *mode)

Parameter

Return Value

When there is an error, a negative value must be returned which disables the monitoring function.

Prototype

int chk_pong_msg(msg_header_t *hp)

Parameter

Return Value

Prototype

int set_extping_msg(msg_header_t *hp, char *data, int len, int *interval,
                    int *binterval, int *timeout, int *mode)

Parameter

Return Value

Example

int set_extping_msg(msg_header_t *hp, char *data, int len, int *interval, 
                    int *binterval, int *timeout, int *mode)
{
        msg_body_t *body;

        body = (msg_body_t *)data;
        memset(body->data, 0x00, 52);

        memcpy(body->data, "tmax50", 7);
        body->data[51] = 0;
        printf("set_extping_msg : data = %s\n", body->data);

        hp->len = 7;
        *interval = 10;
        *binterval = 20;
        *timeout = 100;
        *mode = 0; /* OUTBOUND CHANNEL */

        return 1;
}

Prototype

int chk_extpong_msg(msg_header_t *hp, char *data, int len)

Parameter

Return Value

Example

int chk_extpong_msg(msg_header_t *hp, char *data, int len)
{
        msg_body_t *body;
        char data2[15];

        body = (msg_body_t *)data;
        printf("chk_extpong_msg : data = %s\n", body->data);

        if (strcmp(body->data, "ping_reply")
                return 1;
        return 0;
}

Prototype

int reset_ping_msg(msg_header_t *hp)

Parameter

Return Value

Example

int reset_ping_msg(msg_header_t *hp)
{
        hp->len = 0;
        hp->msgtype = HEALTH_CHECK;
        return 1;
}

Prototype

int reset_extping_msg(msg_header_t *hp, char *data, int len)

Parameter

Return Value

Example

int reset_extping_msg(msg_header_t *hp, char *data, int len)
{
        int body_len;
        char *message = "reset_msg";

        body_len = min(len, strlen(message));
        strncpy(data, message, (body_len - 1));
        data[(body_len - 1)] = '\0';
        hp->len = body_len;
        printf("reset_extping_msg : data = %s\n", data);

        return body_len;
}

Prototype

int set_error_msg(msg_header_t *hp, int err, char *data, int len)

Parameter

Return Value

Error

Example

int set_error_msg(msg_header_t *hp, int err, char *data, int len)
{
     msg_body_t * body;
     body = (msg_body_t *)data;
     strcpy(body->data, "changed hello data");
     /* Since data is not included in the error message,
       -1 option must be used to also send the data part.
       Otherwise, only user header part is sent to CLH.   */
     /* The hp and data values can be same without the user header. */
     strcpy(hp->retsvcname, "RECVSVC_CHANGE");
     return len;
}

Prototype

int get_msg_security(char **data, int asize, int len)

Parameter

Return Value

Example

int get_msg_security(char **data, int asize, int len)
{
     ...
     new_size = len * 2;
     if (new_size > asize) {
         tmpbuf = (char *)realloc(*data, new_size);
         if (tmpbuf == NULL) {
             /* error processing */
         }
         *data = tmpbuf;
     }
     ...
     return new_size;
}

Prototype

int put_msg_security(char **data, int asize, int len)

Parameter

Return Value

Example

int put_msg_security(char **data, int asize, int len)
{
     ...
     new_size = len * 2;
     if (new_size > asize) {
         tmpbuf = (char *)realloc(*data, new_size);
         if (tmpbuf == NULL) {
             /* error processing */
         }
         *data = tmpbuf;
     }
     ...
     return new_size;
}