사용자 프로그램과 함수

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)

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

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)

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