1 /*
2 * binkleyforce -- unix FTN mailer project
3 *
4 * Copyright (c) 1998-2000 Alexander Belkin, 2:5020/1398.11
5 *
6 * This program is free software; you can redistribute it and/or modify
7 * it under the terms of the GNU General Public License as published by
8 * the Free Software Foundation; either version 2 of the License, or
9 * (at your option) any later version.
10 *
11 * $Id: daemon_branch.c,v 1.1.1.1 2004/09/09 09:52:37 kstepanenkov Exp $
12 */
13
14 #include "includes.h"
15 #include "confread.h"
16 #include "logger.h"
17 #include "util.h"
18 #include "daemon.h"
19
20 static s_daemon_branch *daemon_branch_tab = NULL;
21 static signed int daemon_branch_num = 0;
22
23
24 #define ASSERT_POS(pos) ASSERT((pos) >= 0 && ((pos) + 1) <= daemon_branch_num \
25 && daemon_branch_tab)
26
daemon_branch_exist(s_faddr addr)27 bool daemon_branch_exist(s_faddr addr)
28 {
29 int i;
30
31 for( i = 0; i < daemon_branch_num; i++ )
32 if( !ftn_addrcomp(daemon_branch_tab[i].addr, addr) )
33 return TRUE;
34
35 return FALSE;
36 }
37
daemon_branch_check_stop_timers(void)38 void daemon_branch_check_stop_timers(void)
39 {
40 int i;
41 time_t now = time(0);
42
43 for( i = 0; i < daemon_branch_num; i++ )
44 if( daemon_branch_tab[i].stop && !daemon_branch_tab[i].wait
45 && now >= daemon_branch_tab[i].stop )
46 {
47 if( kill(daemon_branch_tab[i].pid, SIGKILL) == -1 )
48 logerr("cannot kill branch with PID %d",
49 (int)daemon_branch_tab[i].pid);
50 }
51 }
52
daemon_branch_exit(pid_t pid,int rc)53 int daemon_branch_exit(pid_t pid, int rc)
54 {
55 int i;
56
57 for( i = 0; i < daemon_branch_num; i++ )
58 if( daemon_branch_tab[i].pid == pid )
59 {
60 daemon_branch_tab[i].rc = rc;
61 daemon_branch_tab[i].wait = TRUE;
62 return 0;
63 }
64
65 return -1;
66
67 }
68
daemon_branch_get_first_waiting(void)69 int daemon_branch_get_first_waiting(void)
70 {
71 int i;
72
73 for( i = 0; i < daemon_branch_num; i++ )
74 if( daemon_branch_tab[i].wait )
75 return i;
76
77 return -1;
78 }
79
daemon_branch_get_pointer(int pos)80 s_daemon_branch *daemon_branch_get_pointer(int pos)
81 {
82 ASSERT_POS(pos);
83
84 if( pos + 1 > daemon_branch_num )
85 {
86 bf_log("internal error: branch position is out of range");
87 return NULL;
88 }
89
90 return &daemon_branch_tab[pos];
91 }
92
daemon_branch_add(s_faddr addr,pid_t pid,bool tcpip,const char * pname)93 void daemon_branch_add(s_faddr addr, pid_t pid, bool tcpip, const char *pname)
94 {
95 if( daemon_branch_tab )
96 {
97 daemon_branch_tab =
98 (s_daemon_branch *)xrealloc(daemon_branch_tab,
99 sizeof(s_daemon_branch)*(daemon_branch_num + 1));
100 memset(&daemon_branch_tab[daemon_branch_num], '\0',
101 sizeof(s_daemon_branch));
102 }
103 else
104 {
105 daemon_branch_tab =
106 (s_daemon_branch *)xmalloc(sizeof(s_daemon_branch));
107 memset(daemon_branch_tab, '\0', sizeof(s_daemon_branch));
108 daemon_branch_num = 0;
109 }
110
111 daemon_branch_tab[daemon_branch_num].addr = addr;
112 daemon_branch_tab[daemon_branch_num].wait = FALSE;
113 daemon_branch_tab[daemon_branch_num].tcpip = tcpip;
114 daemon_branch_tab[daemon_branch_num].pid = pid;
115 daemon_branch_tab[daemon_branch_num].start = time(NULL);
116
117 if( pname )
118 daemon_branch_tab[daemon_branch_num].portname = xstrcpy(pname);
119
120 daemon_branch_num++;
121 }
122
daemon_branch_remove(int pos)123 void daemon_branch_remove(int pos)
124 {
125 ASSERT_POS(pos);
126
127 if( daemon_branch_tab[pos].portname )
128 free(daemon_branch_tab[pos].portname);
129
130 if( daemon_branch_num > 1 )
131 {
132 memmove(&daemon_branch_tab[pos],
133 &daemon_branch_tab[pos+1],
134 sizeof(s_daemon_branch)*(daemon_branch_num - pos - 1));
135 daemon_branch_tab =
136 (s_daemon_branch *)xrealloc(daemon_branch_tab,
137 sizeof(s_daemon_branch)*(daemon_branch_num - 1));
138 daemon_branch_num--;
139 }
140 else
141 {
142 free(daemon_branch_tab);
143 daemon_branch_tab = NULL;
144 daemon_branch_num = 0;
145 }
146 }
147
daemon_branch_number(void)148 int daemon_branch_number(void)
149 {
150 return daemon_branch_num;
151 }
152
daemon_branch_deinit(void)153 void daemon_branch_deinit(void)
154 {
155 if( daemon_branch_tab )
156 free(daemon_branch_tab);
157
158 daemon_branch_tab = NULL;
159 daemon_branch_num = 0;
160 }
161
162