/**
      @file     tipc_bcast.c
      @date     2015-08-31

      @author   장길석 jks@falinux.com
      @brief    TIPC-DGRAM 소켓을 사용하여 멀티캐스트가 가능한 통신을 담당한다.

  
      @modify
      @todo
      @bug
      @remark
  
      @warning
  */
  //

  //  저작권    에프에이리눅스(주)
  //            외부공개 금지

  //
  //----------------------------------------------------------------------------
  
  #include <stdio.h>
  #include <stdlib.h>
  #include <string.h>
  #include <unistd.h>
  #include <fcntl.h>
  #include <errno.h>
  #include <sys/types.h>
  #include <sys/un.h>
  #include <sys/socket.h>
  #include <netinet/in.h>
  #include <arpa/inet.h>
  #include <linux/tipc.h>
  #include <pollmng.h>
  #include "../../include/fanet/tipc_bcast.h"
  
  char desc_tipc_bcast[] = "falinux tipc broadcast ver 0.0.1";

  /// tipc_bcast 개별 구조체

  typedef struct {
      int   type;                                                     // server type
      int   lower;                                                    // port lower
      int   upper;                                                    // port upper
  } tipc_bcast_priv_t;
  
  //------------------------------------------------------------------------------

  /** @brief    tipc_bcast 소켓을 서버형태로 open 한다.
      @param    port  포트번호
      @return   poll_obj_t 형태의 포인터

  *///----------------------------------------------------------------------------
  
  poll_obj_t  *tipc_bcast_open( int type, int lower, int upper )
  {
      struct sockaddr_tipc server_addr;
  
      server_addr.family             = AF_TIPC;
      server_addr.addrtype           = TIPC_ADDR_NAMESEQ;
      server_addr.scope              = TIPC_CLUSTER_SCOPE;
      server_addr.addr.nameseq.type  = type;
      server_addr.addr.nameseq.lower = lower;
      server_addr.addr.nameseq.upper = upper;
  
      int sockfd = socket (AF_TIPC, SOCK_RDM, 0);
  
      if ( bind( sockfd, (struct sockaddr *)&server_addr, sizeof(server_addr))) {
          printf("Server: port {%u,%u,%u} could not be created
  ",
                  type, lower, upper);
          close( sockfd );
          return NULL;
      }
  
      tipc_bcast_priv_t *tipc_bcast;
      poll_obj_t *obj;

      // tipc_bcast 만의 정보를 설정한다.

      tipc_bcast = (tipc_bcast_priv_t *)malloc( sizeof(tipc_bcast_priv_t) );
      tipc_bcast->type        = type;
      tipc_bcast->lower       = lower;
      tipc_bcast->upper       = upper;
  
      obj             = poll_add( sockfd );
      obj->type       = STYP_TIPC_DGRAM;
      obj->priv       = (void *)tipc_bcast;
  
      return obj;
  }
  
  //------------------------------------------------------------------------------

  /** @brief    tipc_bcast 소켓을 close 한다.
      @param    obj  폴객체 포인터

  *///----------------------------------------------------------------------------
  void tipc_bcast_close( poll_obj_t *obj )
  {
      close( obj->fd );
  
      if ( obj->priv ){
          free( obj->priv );
      }
  
      poll_delete( obj );
  }
  //------------------------------------------------------------------------------

  /** @brief    tipc_bcast 소켓을 통해 데이타를 전송한다.
      @param    obj     폴객체 포인터
      @param    host    상대방 IP 나 호스트이름 문자열포인터
      @param    port    상대방 포트번호
      @param    buf     전송버퍼
      @param    len     버퍼의 길이
      @return   전송한 데이타 개수

  *///----------------------------------------------------------------------------
  int  tipc_bcast_write( poll_obj_t *obj, int type, int lower, int upper, char *buf, int len )
  {
      struct sockaddr_tipc server_addr;
  
      server_addr.family              = AF_TIPC;
      server_addr.addrtype            = TIPC_ADDR_MCAST;
      server_addr.addr.nameseq.type   = type;
      server_addr.addr.nameseq.lower  = lower;
      server_addr.addr.nameseq.upper  = upper;
  
      int wrcnt = sendto( obj->fd, buf, len, 0,
                     (struct sockaddr *)&server_addr, sizeof( server_addr));
  
      return wrcnt;
  }
  //------------------------------------------------------------------------------

  /** @brief    tipc_bcast 소켓을 통해 데이타를 읽는다.
      @param    obj     폴객체 포인터
      @param    len     버퍼의 길이
      @return   전송된 데이타 개수

  *///----------------------------------------------------------------------------
  int  tipc_bcast_read( poll_obj_t *obj, char *buf, int len )
  {
      struct sockaddr_tipc client_addr;
      socklen_t            alen = sizeof(struct sockaddr_tipc);
  
      int rdcnt = recvfrom( obj->fd, buf, len, 0,
                       (struct sockaddr *)&client_addr, &alen);
  
      if ( 0 > rdcnt ){
          perror( "tipc_bcast recv error:" );
      }
  
      return rdcnt;
  }