Annotation of embedaddon/freevrrpd/vrrp_thread.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_thread.c,v 1.4 2004/03/05 22:06:45 spe Exp $
33: */
34:
35: #include <stdlib.h>
36: #include <errno.h>
37: #include <string.h>
38: #include "vrrp_thread.h"
39: #include "vrrp_moncircuit.h"
40:
41: pthread_mutex_t pth_mutex, pth_mutex_monitor;
42:
43: void
44: vrrp_thread_mutex_lock(void)
45: {
46: pthread_mutex_lock(&pth_mutex);
47:
48: return;
49: }
50:
51: void
52: vrrp_thread_mutex_unlock(void)
53: {
54: pthread_mutex_unlock(&pth_mutex);
55:
56: return;
57: }
58:
59: void vrrp_thread_mutex_lock_monitor(void)
60: {
61: pthread_mutex_lock(&pth_mutex_monitor);
62:
63: return;
64: }
65:
66: void vrrp_thread_mutex_unlock_monitor(void)
67: {
68: pthread_mutex_unlock(&pth_mutex_monitor);
69:
70: return;
71: }
72:
73: void *
74: vrrp_thread_launch_vrrprouter(void *args)
75: {
76: int **args2 = (int **)args;
77: struct vrrp_vr *vr = (struct vrrp_vr *)args2[0];
78: sem_t *sem = (sem_t *)args2[1];
79: int returnCode = 0;
80:
81: vr_ptr[vr_ptr_pos] = vr;
82: vr_ptr_pos++;
83: if (vr_ptr_pos == 255) {
84: syslog(LOG_ERR, "cannot configure more than 255 VRID... exiting\n");
85: exit(-1);
86: }
87: sem_post(sem);
88: for (;;) {
89: switch (vr->state) {
90: case VRRP_STATE_INITIALIZE:
91: returnCode = vrrp_state_initialize(vr);
92: break;
93: case VRRP_STATE_MASTER:
94: returnCode = vrrp_state_master(vr);
95: break;
96: case VRRP_STATE_BACKUP:
97: returnCode = vrrp_state_backup(vr);
98: break;
99: }
100: if (returnCode < 0) {
101: syslog(LOG_ERR, "vrid [%d] Cannot reach the correct state, disabled: %s\n", vr->vr_id, strerror(errno));
102: pthread_exit(NULL);
103: }
104: }
105:
106: /* Normally never executed */
107: return NULL;
108: }
109:
110: char
111: vrrp_thread_initialize(void)
112: {
113: if (pthread_mutex_init(&pth_mutex, NULL) != 0) {
114: syslog(LOG_ERR, "can't initialize thread for socket reading [ PTH_MUTEX, NULL ]");
115: return -1;
116: }
117: if (pthread_mutex_init(&pth_mutex_monitor, NULL) != 0) {
118: syslog(LOG_ERR, "can't initialize thread for socket reading [ PTH_MUTEX, NULL ]");
119: return -1;
120: }
121: return 0;
122: }
123:
124: char
125: vrrp_thread_create_vrid(struct vrrp_vr * vr)
126: {
127: pthread_t pth;
128: pthread_attr_t pth_attr;
129: sem_t sem;
130: void *args[2];
131:
132: if (sem_init(&sem, 0, 0) == -1) {
133: syslog(LOG_ERR, "can't initialize an unnamed semaphore [ SEM, 0, 0 ]");
134: return -1;
135: }
136: if (pthread_attr_init(&pth_attr) != 0) {
137: syslog(LOG_ERR, "can't initialize thread attributes [ PTH_ATTR ]");
138: return -1;
139: }
140: if (pthread_attr_setdetachstate(&pth_attr, PTHREAD_CREATE_DETACHED) != 0) {
141: syslog(LOG_ERR, "can't set thread attributes [ PTH_ATTR, PTHREAD_CREATE_DETACHED ]");
142: return -1;
143: }
144: args[0] = vr;
145: args[1] = &sem;
146: if (pthread_create(&pth, &pth_attr, vrrp_thread_launch_vrrprouter, args) != 0) {
147: syslog(LOG_ERR, "can't create new thread [ PTH, PTH_ATTR, VRRP_THREAD_READ_SOCKET ]");
148: return -1;
149: }
150: sem_wait(&sem);
151: sem_destroy(&sem);
152:
153: return 0;
154: }
155:
156: int vrrp_thread_create_moncircuit(void)
157: {
158: pthread_t pth;
159: pthread_attr_t pth_attr;
160: sem_t sem;
161: int delay = VRRP_MONCIRCUIT_MONDELAY;
162: void *args[2];
163:
164: if (sem_init(&sem, 0, 0) == -1) {
165: syslog(LOG_ERR, "can't initialize an unnamed semaphore [ SEM, 0, 0 ]");
166: return -1;
167: }
168: if (pthread_attr_init(&pth_attr) != 0) {
169: syslog(LOG_ERR, "can't initialize thread attributes [ PTH_ATTR ]");
170: return -1;
171: }
172: if (pthread_attr_setdetachstate(&pth_attr, PTHREAD_CREATE_DETACHED) != 0) {
173: syslog(LOG_ERR, "can't set thread attributes [ PTH_ATTR, PTHREAD_CREATE_DETACHED ]");
174: return -1;
175: }
176: args[0] = &delay;
177: args[1] = &sem;
178: if (pthread_create(&pth, &pth_attr, vrrp_moncircuit_monitor_thread, args) != 0) {
179: syslog(LOG_ERR, "can't create new thread [ PTH, PTH_ATTR, VRRP_THREAD_READ_SOCKET ]");
180: return -1;
181: }
182: sem_wait(&sem);
183: sem_destroy(&sem);
184:
185: return 0;
186: }
FreeBSD-CVSweb <freebsd-cvsweb@FreeBSD.org>
![[BACK]](/icons/cvsweb/back.gif){kind=icon}
Return to vrrp_thread.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