blob: 3686c824a2d73bc056a28ddd8cccd3ec98f08051 (
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
127
128
129
130
131
132
133
134
135
136
137
|
/*
* 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 clib_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__ */
/*
* fd.io coding-style-patch-verification: ON
*
* Local Variables:
* eval: (c-set-style "gnu")
* End:
*/
|
