에프에이리눅스 / 1611_0007_prime_oven

Blame view

app/app-prime-modbus/lib/fanet/tipc_bcast.c 4.39 KB
edit raw normal view history
8c2952457   김태훈   응용 프로그램 추가 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
 
  /**
      @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;
  }