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
|
/*-
* Copyright (c) 1992, 1993, 1995 Eugene W. Stark
* All rights reserved.
*
* Redistribution and use in source and binary forms, with or without
* modification, are permitted provided that the following conditions
* are met:
* 1. Redistributions of source code must retain the above copyright
* notice, this list of conditions and the following disclaimer.
* 2. Redistributions in binary form must reproduce the above copyright
* notice, this list of conditions and the following disclaimer in the
* documentation and/or other materials provided with the distribution.
* 3. All advertising materials mentioning features or use of this software
* must display the following acknowledgement:
* This product includes software developed by Eugene W. Stark.
* 4. The name of the author may not be used to endorse or promote products
* derived from this software without specific prior written permission.
*
* THIS SOFTWARE IS PROVIDED BY EUGENE W. STARK (THE AUTHOR) ``AS IS'' AND
* ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
* IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
* ARE DISCLAIMED. IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR ANY DIRECT,
* INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES
* (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR
* SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
* HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
* LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
* OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
* SUCH DAMAGE.
*/
#ifndef lint
static const char rcsid[] =
"$Id$";
#endif /* not lint */
#include <stdio.h>
#include <unistd.h>
#include <sys/param.h>
#include <sys/stat.h>
#include "xtend.h"
#include "xten.h"
#include "paths.h"
void printstatus __P((FILE *, STATUS *));
/*
* Initialize the status table from the status files
*/
void
initstatus()
{
if(lseek(status, 0, SEEK_SET) != 0) {
fprintf(Log, "%s: Seek error on status file\n", thedate());
return;
}
if(read(status, Status, 16*16*sizeof(STATUS)) != 16*16*sizeof(STATUS)) {
fprintf(Log, "%s: Read error on status file\n", thedate());
return;
}
}
/*
* Checkpoint status of any devices whose status has changed
* and notify anyone monitoring those devices.
*/
void
checkpoint_status()
{
int h, i, k, offset;
offset = 0;
for(h = 0; h < 16; h++) {
for(i = 0; i < 16; i++) {
if(Status[h][i].changed) {
if(lseek(status, offset, SEEK_SET) != offset) {
fprintf(Log, "%s: Seek error on status file\n", thedate());
} else {
if(write(status, &Status[h][i], sizeof(STATUS)) != sizeof(STATUS)) {
fprintf(Log, "%s: Write error on status file\n", thedate());
}
}
Status[h][i].changed = 0;
for(k = 0; k < MAXMON; k++) {
if(Monitor[k].inuse
&& Monitor[k].house == h && Monitor[k].unit == i) {
/*
* Arrange to catch SIGPIPE in case client has gone away.
*/
extern int client;
extern void clientgone();
void (*prev)();
client = k;
prev = signal(SIGPIPE, clientgone);
printstatus(Monitor[k].user, &Status[h][i]);
fflush(Monitor[k].user);
signal(SIGPIPE, prev);
}
}
}
offset += sizeof(STATUS);
}
}
}
int client;
void clientgone()
{
fprintf(Log, "%s: Deleting monitor table entry %d, client gone\n", thedate(), client);
fclose(Monitor[client].user);
Monitor[client].inuse = 0;
}
|
