Annotation of embedaddon/freevrrpd/vrrp_state.c, revision 1.1.1.1
1.1 misho 1: /*
2: * Copyright (c) 2001,2002 Sebastien Petit <spe@bsdfr.org>
3: *
4: * Redistribution and use in source forms, with and without modification,
5: * are permitted provided that the following conditions are met:
6: * 1. Redistributions of source code must retain the above copyright notice,
7: * this list of conditions and the following disclaimer.
8: * 2. Redistributions in binary form must reproduce the above copyright notice,
9: * this list of conditions and the following disclaimer in the documentation
10: * and/or other materials provided with the distribution. Obviously, it
11: * would be nice if you gave credit where credit is due but requiring it
12: * would be too onerous.
13: * 3. All advertising materials mentioning features or use of this software
14: * must display the following acknowledgement:
15: * This product includes software developed by Sebastien Petit.
16: * 4. Neither the name of its contributors may be used to endorse or promote
17: * products derived from this software without specific prior written
18: * permission.
19: *
20: * THIS SOFTWARE IS PROVIDED BY THE REGENTS AND CONTRIBUTORS ``AS IS'' AND
21: * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
22: * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
23: * ARE DISCLAIMED. IN NO EVENT SHALL THE REGENTS OR CONTRIBUTORS BE LIABLE
24: * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
25: * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
26: * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
27: * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
28: * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
29: * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
30: * SUCH DAMAGE.
31: *
32: * $Id: vrrp_state.c,v 1.18 2004/04/02 11:04:46 spe Exp $
33: */
34:
35: #include <stdlib.h>
36: #include <errno.h>
37: #include "vrrp_state.h"
38: #ifdef ENABLE_VRRP_AH
39: #include "vrrp_ah.h"
40: #endif
41:
42: char
43: vrrp_state_initialize(struct vrrp_vr * vr)
44: {
45: if ((vr->priority == 255) && (! vr->fault)) {
46: if (vrrp_state_set_master(vr) == -1)
47: return -1;
48: } else if (vrrp_state_set_backup(vr) == -1)
49: return -1;
50:
51: return 0;
52: }
53:
54: char
55: vrrp_state_set_master(struct vrrp_vr * vr)
56: {
57: int returnCode = 0;
58: int counter = 0;
59:
60: vrrp_network_send_advertisement(vr);
61: vrrp_thread_mutex_lock();
62: vrrp_thread_mutex_lock_monitor();
63: if (vrrp_interface_vripaddr_set(vr) == -1) {
64: vrrp_thread_mutex_unlock_monitor();
65: vrrp_thread_mutex_unlock();
66: return -1;
67: }
68: if (vrrp_interface_up(vr->viface_name) < 0) {
69: vrrp_thread_mutex_unlock_monitor();
70: vrrp_thread_mutex_unlock();
71: return -1;
72: }
73:
74: /* Some NICs will reset (eg: bge/em) and wait some seconds before becoming carrier again */
75: /* So we must wait for carrier */
76: if (vr->useMonitoredCircuits) {
77: for (counter = 0; (counter < vr->vr_if->carrier_timeout) && (returnCode != 1); counter++) {
78: returnCode = vrrp_moncircuit_interface_status(vr->sd, vr->vr_if->if_name);
79: sleep(1);
80: }
81: }
82:
83: vrrp_thread_mutex_unlock_monitor();
84: vrrp_thread_mutex_unlock();
85: if (vr->spanningTreeLatency) {
86: syslog(LOG_NOTICE, "waiting %d seconds for the spanning tree latency", vr->spanningTreeLatency);
87: sleep(vr->spanningTreeLatency);
88: }
89: if (vrrp_misc_calcul_tminterval(&vr->tm.adv_tm, vr->adv_int) == -1)
90: return -1;
91: vr->state = VRRP_STATE_MASTER;
92: syslog(LOG_NOTICE, "server state vrid %d: master", vr->vr_id);
93: printf("server state vrid %d: master\n", vr->vr_id);
94: if (vr->master_script) {
95: syslog(LOG_INFO, "[master] executing script %s\n", vr->master_script);
96: if (system(vr->master_script) == -1)
97: syslog(LOG_ERR, "[master] cannot execute script %s\n", vr->master_script);
98: else
99: syslog(LOG_INFO, "[master] script %s has been executed\n", vr->master_script);
100: }
101:
102: return 0;
103: }
104:
105: char
106: vrrp_state_set_backup(struct vrrp_vr * vr)
107: {
108: int returnCode = 0;
109: int counter = 0;
110:
111: vrrp_thread_mutex_lock();
112: vrrp_interface_vripaddr_delete(vr);
113: vrrp_thread_mutex_lock_monitor();
114: if (vrrp_interface_down(vr->viface_name) < 0) {
115: vrrp_thread_mutex_unlock_monitor();
116: vrrp_thread_mutex_unlock();
117: return -1;
118: }
119:
120: /* Some NICs will reset (eg: bge/em) and wait some seconds before becoming carrier again */
121: /* So we must wait for carrier */
122: if (vr->useMonitoredCircuits) {
123: for (counter = 0; (counter < vr->vr_if->carrier_timeout) && (returnCode != 1); counter++) {
124: returnCode = vrrp_moncircuit_interface_status(vr->sd, vr->vr_if->if_name);
125: sleep(1);
126: }
127: }
128: vrrp_thread_mutex_unlock_monitor();
129: vrrp_thread_mutex_unlock();
130: if (vr->spanningTreeLatency) {
131: syslog(LOG_NOTICE, "waiting %d seconds for the spanning tree latency", vr->spanningTreeLatency);
132: sleep(vr->spanningTreeLatency);
133: }
134: vr->skew_time = (256 - vr->priority) / 256;
135: vr->master_down_int = (3 * vr->adv_int) + vr->skew_time;
136: if (vrrp_misc_calcul_tminterval(&vr->tm.master_down_tm, vr->master_down_int) == -1)
137: return -1;
138: vr->state = VRRP_STATE_BACKUP;
139: syslog(LOG_NOTICE, "server state vrid %d: backup", vr->vr_id);
140: printf("server state vrid %d: backup\n", vr->vr_id);
141: if (vr->backup_script) {
142: syslog(LOG_INFO, "[backup] executing script %s\n", vr->backup_script);
143: if (system(vr->backup_script) == -1)
144: syslog(LOG_ERR, "[backup] cannot execute script %s\n", vr->backup_script);
145: else
146: syslog(LOG_INFO, "[backup] script %s has been executed\n", vr->backup_script);
147: }
148:
149: return 0;
150: }
151:
152: char
153: vrrp_state_select(struct vrrp_vr * vr, struct timeval * interval)
154: {
155: int coderet;
156: fd_set readfds;
157:
158: FD_ZERO(&readfds);
159: FD_SET(vr->sd, &readfds);
160: coderet = select(FD_SETSIZE, &readfds, NULL, NULL, interval);
161:
162: return coderet;
163: }
164:
165: /* Operation a effectuer durant l'etat master */
166: char
167: vrrp_state_master(struct vrrp_vr * vr)
168: {
169: int coderet;
170: u_char packet[4096];
171: ssize_t packetSize;
172: struct ip *ipp = (struct ip *) packet;
173: #ifdef ENABLE_VRRP_AH
174: struct vrrp_hdr *vrrph = (struct vrrp_hdr *) & packet[sizeof(struct ip)+vrrp_ah_ahhdr_len(vr)];
175: #else
176: struct vrrp_hdr *vrrph = (struct vrrp_hdr *) & packet[sizeof(struct ip)];
177: #endif
178: struct timeval interval;
179: struct sockaddr_in saddr;
180: socklen_t len;
181:
182: for (;;) {
183: if (vrrp_misc_calcul_tmrelease(&vr->tm.adv_tm, &interval) == -1)
184: return -1;
185: coderet = vrrp_state_select(vr, &interval);
186: if (coderet > 0) {
187: len = sizeof(struct sockaddr_in);
188: packetSize = recvfrom(vr->sd, packet, sizeof(packet), 0, (struct sockaddr *)&saddr, &len);
189: if (packetSize == -1) {
190: syslog(LOG_ERR, "can't read on vr->sd socket descriptor: %s", strerror(errno));
191: return -1;
192: }
193: if (vrrp_misc_check_vrrp_packet(vr, packet, packetSize) == -1)
194: continue;
195: if (vrrph->priority == 0) {
196: if (vr->sd == -1)
197: return -1;
198: vrrp_network_send_advertisement(vr);
199: if (vrrp_misc_calcul_tminterval(&vr->tm.adv_tm, vr->adv_int) == -1)
200: return -1;
201: continue;
202: }
203: if (vrrp_state_check_priority(vrrph, vr, ipp->ip_src) || (vr->fault) || (vr->vr_if->alive != 1)) {
204: if (vrrp_state_set_backup(vr) == -1)
205: return -1;
206: }
207: return 0;
208: }
209: if (coderet == 0) {
210: if ((vr->vr_if->alive != 1) || (vr->fault)) {
211: if (vrrp_state_set_backup(vr) == -1)
212: return -1;
213: return 0;
214: }
215: vrrp_network_send_advertisement(vr);
216: if (vrrp_misc_calcul_tminterval(&vr->tm.adv_tm, vr->adv_int) == -1)
217: return -1;
218: continue;
219: }
220: if (coderet == -1) {
221: syslog(LOG_ERR, "select on readfds fd_set failed: %s", strerror(errno));
222: return -1;
223: }
224: }
225:
226: /* Normally never executed */
227: return 0;
228: }
229:
230: char
231: vrrp_state_backup(struct vrrp_vr * vr)
232: {
233: int coderet;
234: u_char packet[4096];
235: ssize_t packetSize;
236: #ifdef ENABLE_VRRP_AH
237: struct vrrp_hdr *vrrph = (struct vrrp_hdr *) & packet[sizeof(struct ip)+vrrp_ah_ahhdr_len(vr)];
238: #else
239: struct vrrp_hdr *vrrph = (struct vrrp_hdr *) & packet[sizeof(struct ip)];
240: #endif
241: struct timeval interval;
242: struct sockaddr_in saddr;
243: socklen_t len;
244:
245: for (;;) {
246: if (vrrp_misc_calcul_tmrelease(&vr->tm.master_down_tm, &interval) == -1)
247: return -1;
248: coderet = vrrp_state_select(vr, &interval);
249: if (coderet > 0) {
250: len = sizeof(struct sockaddr_in);
251: packetSize = recvfrom(vr->sd, packet, sizeof(packet), 0, (struct sockaddr *)&saddr, &len);
252: if (packetSize == -1) {
253: syslog(LOG_ERR, "can't read on vr->sd socket descriptor: %s", strerror(errno));
254: return -1;
255: }
256: if (vrrp_misc_check_vrrp_packet(vr, packet, packetSize) == -1)
257: continue;
258: if (vrrph->priority == 0) {
259: if (vrrp_misc_calcul_tminterval(&vr->tm.master_down_tm, vr->skew_time) == -1)
260: return -1;
261: continue;
262: }
263: if (vr->preempt_mode == 0 || vrrph->priority >= vr->priority)
264: if (vrrp_misc_calcul_tminterval(&vr->tm.master_down_tm, vr->master_down_int) == -1)
265: return -1;
266: continue;
267: }
268: if (coderet == -1) {
269: syslog(LOG_ERR, "select on readfds fd_set failed: %s", strerror(errno));
270: return -1;
271: }
272: if ((! coderet) && (vr->vr_if->alive == 1) && (! vr->fault)) {
273: if (! vrrp_state_set_master(vr))
274: return 0;
275: }
276: else
277: if (vrrp_misc_calcul_tminterval(&vr->tm.master_down_tm, vr->master_down_int) == -1)
278: return -1;
279: }
280:
281: /* Normally never executed */
282: return 0;
283: }
284:
285: char
286: vrrp_state_check_priority(struct vrrp_hdr * vrrph, struct vrrp_vr * vr, struct in_addr addr)
287: {
288: if (vrrph->priority > vr->priority)
289: return 1;
290: if ((vrrph->priority == vr->priority) && (addr.s_addr > vr->vr_if->ip_addrs[0].s_addr))
291: return 1;
292:
293: return 0;
294: }
FreeBSD-CVSweb <freebsd-cvsweb@FreeBSD.org>
![[BACK]](/icons/cvsweb/back.gif){kind=icon}
Return to vrrp_state.c CVS log ![[TXT]](/icons/cvsweb/text.gif){kind=icon}
![[DIR]](/icons/cvsweb/dir.gif){kind=icon}
Up to [ELWIX - Embedded LightWeight unIX -] / embedaddon / freevrrpd