blob: 7dd6b5e27b1808b951d050eb9864a21c8bce2bcd (
plain)
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
|
/*
* mc_socket.h: socket based multicast for vlib mc
*
* Copyright (c) 2010 Cisco and/or its affiliates.
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at:
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
#ifndef __included_mc_socket_h__
#define __included_mc_socket_h__
#include <vlib/unix/unix.h>
#include <netinet/in.h>
typedef struct {
int socket;
struct sockaddr_in tx_addr;
} mc_multicast_socket_t;
/* TCP catchup socket */
typedef struct {
int socket;
u32 unix_file_index;
u8 * input_vector;
u8 * output_vector;
u32 output_vector_n_written;
u32 connect_in_progress;
} mc_socket_catchup_t;
typedef struct mc_socket_main_t {
mc_main_t mc_main;
/* Multicast mastership/to-relay/from-relay sockets. */
mc_multicast_socket_t multicast_sockets[MC_N_TRANSPORT_TYPE];
/* Unicast UDP ack sockets */
int ack_socket;
/* TCP catchup server socket */
int catchup_server_socket;
/* Pool of stream-private catchup sockets */
mc_socket_catchup_t *catchups;
uword * catchup_index_by_file_descriptor;
u32 rx_mtu_n_bytes;
/* Receive MTU in bytes and VLIB buffers. */
u32 rx_mtu_n_buffers;
/* Vector of RX VLIB buffers. */
u32 * rx_buffers;
/* Vector of scatter/gather descriptors for sending/receiving VLIB buffers
via kernel. */
struct iovec * iovecs;
/* IP address of interface to use for multicast. */
u32 if_ip4_address_net_byte_order;
u32 ack_udp_port;
u32 catchup_tcp_port;
/* Interface on which to listen for multicasts. */
char * multicast_interface_name;
/* Multicast address to use (e.g. 0xefff0000).
Host byte order. */
u32 multicast_tx_ip4_address_host_byte_order;
/* TTL to use for multicasts. */
u32 multicast_ttl;
/* Multicast ports for mastership, joins, etc. will be chosen
starting at the given port in host byte order.
A total of MC_N_TRANSPORT_TYPE ports will be used. */
u32 base_multicast_udp_port_host_byte_order;
} mc_socket_main_t;
always_inline u32
mc_socket_peer_id_get_address (mc_peer_id_t i)
{
u32 a = ((i.as_u8[0] << 24)
| (i.as_u8[1] << 16)
| (i.as_u8[2] << 8)
| (i.as_u8[3] << 0));
return clib_host_to_net_u32 (a);
}
always_inline u32
mc_socket_peer_id_get_port (mc_peer_id_t i)
{ return clib_host_to_net_u16 ((i.as_u8[4] << 8) | i.as_u8[5]); }
static_always_inline mc_peer_id_t
mc_socket_set_peer_id (u32 address_net_byte_order, u32 port_host_byte_order)
{
mc_peer_id_t i;
u32 a = ntohl (address_net_byte_order);
u32 p = port_host_byte_order;
i.as_u8[0] = (a >> 24) & 0xff;
i.as_u8[1] = (a >> 16) & 0xff;
i.as_u8[2] = (a >> 8) & 0xff;
i.as_u8[3] = (a >> 0) & 0xff;
i.as_u8[4] = (p >> 8) & 0xff;
i.as_u8[5] = (p >> 0) & 0xff;
i.as_u8[6] = 0;
i.as_u8[7] = 0;
return i;
}
clib_error_t *
mc_socket_main_init (mc_socket_main_t * msm, char **intfc_probe_list,
int n_intfcs_to_probe);
#endif /* __included_mc_socket_h__ */
|
