사용법

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

파라미터

사용법

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

파라미터

사용법

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

파라미터

예제

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

사용법

int remote_closed(int index, int type)

파라미터

사용법

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

파라미터

반환값

예제

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

사용법

#include <arpa/inet.h>

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

파라미터

반환값

예제

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

사용법

int get_msg_length(msg_header_t *hp)

파라미터

반환값

리모트 노드로부터 실 데이터의 길이를 반환한다. 함수의 반환값으로 TCPGW는 실 데이터를 리모트 노드에서 읽게 된다.

헤더를 확인하고 문제가 있을 경우에 -2를 리턴하면 해당 채널이 종료된다.

사용법

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

파라미터

반환값

Tmax 서비스로 보낼 타입을 정의한다. TCPGW는 값을 바탕으로 Tmax로 어떤 처리를 할 것인지를 판단한다. 예를 들어 REMOTE_REQUEST는 리모트 노드로부터 Request가 발생한 것으로 판단하며, REMOTE_REPLY는 Tmax 서비스로부터 Request가 발생하여 리모트 노드로부터 Response가 오는 경우 반환하는 값이다. REMOTE_REPLY_CONT는 Response 메시지가 이어서 올 경우 반환하는 값이며, REMOTE_SENDTOCLI는 비요청 메시지일 경우 반환하는 값이다.

-1을 리턴 하고 환경설정파일의 CLOPT 절에 -e 옵션을 설정하면 해당 채널이 종료된다.

리모트 노드로부터 응답을 수신한 경우에는 반드시 UID 값을 info 구조체의 uid 항목에 지정해 주어야 한다. 기타 다른 값들은 상황에 맞게 주어야 한다.

사용법

int get_channel_num(char *data)

파라미터

반환값

채널 번호를 반환한다.

사용법

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

파라미터

반환값

사용자는 실제적으로 리모트 노드에 전송할 데이터의 전체 길이를 반환해야 한다. 메시지 헤더와 실 데이터를 더한 길이를 반환한다.

사용법

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

파라미터

사용법

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

파라미터

사용법

int prepare_shutdown(int code)

파라미터

사용법

int set_service_time_out(int uid, char *header)

파라미터

사용법

int chk_end_msg(int len, char *data)

파라미터

사용법

int inmsg_recovery(char *data, msg_info_t *info)

파라미터

반환값

사용자는 새로운 데이터의 길이를 반환해야 한다.

사용법

int inmsg_recovery(char *data, msg_info_t *info)

파라미터

반환값

사용법

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

파라미터

반환값

Tmax 서비스로 보낼 타입을 정의한다. TCPGW는 값을 바탕으로 Tmax로 어떤 처리를 할 것인지를 판단한다. 예를 들어, REMOTE_REQUEST는 리모트 노드로부터 Request가 발생한 것으로 판단하며, REMOTE_REPLY는 Tmax 서비스로부터 Request가 발생하여 리모트 노드로부터 Response가 오는 경우 반환하는 값이다. REMOTE_REPLY_CONT는 Response 메시지가 이어서 올 경우 반환하는 값이며, REMOTE_SENDTOCLI는 비요청 메시지일 경우 반환하는 값이다. 리모트 노드로부터 응답을 수신한 경우에는 반드시 UID 값을 info 구조체의 uid 항목에 지정해 주어야 한다. 그리고 기타 다른 값들 상황에 맞게 주어야 한다.

사용법

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

파라미터

반환값

사용자는 함수에서 실제적으로 리모트 노드에 전송할 데이터의 전체 길이를 반환해야 한다. 메시지 헤더와 실 데이터를 더한 길이를 반환한다.

사용법

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

파라미터

반환값

에러가 발생할 때 음수값을 반환해야 하며, 이 경우 장애 감시 기능은 비활성화된다.

사용법

int chk_pong_msg(msg_header_t *hp)

파라미터

반환값

사용법

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

파라미터

반환값

예제

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

사용법

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

파라미터

반환값

예제

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

사용법

int reset_ping_msg(msg_header_t *hp)

파라미터

반환값

예제

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

사용법

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

파라미터

반환값

예제

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

사용법

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

파라미터

반환값

오류

예제

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");
     /* 에러 메시지에는 데이터가 포함되지 않으므로
       데이터 부분까지 전달되기 위해서는 -I 옵션을 사용해야 한다.
       사용하지 않을 시 사용자 헤더까지만 CLH로 전달된다.   */
     /* 사용자헤더가 없는 경우에  hp와 data의 값이 같을 수 있다. */
     strcpy(hp->retsvcname, "RECVSVC_CHANGE");
     return len;
}

사용법

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

파라미터

반환값

예제

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

사용법

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

파라미터

반환값

예제

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