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
|
/*
* stonith_expect_helpers.h: Some common expect defines.
*
* Copyright (C) 2004 Lars Marowsky-Bree <lmb@suse.de>
*
* This library is free software; you can redistribute it and/or
* modify it under the terms of the GNU Lesser General Public
* License as published by the Free Software Foundation; either
* version 2.1 of the License, or (at your option) any later version.
*
* This library is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
* Lesser General Public License for more details.
*
* You should have received a copy of the GNU Lesser General Public
* License along with this library; if not, write to the Free Software
* Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA
*
*/
/* This is still somewhat ugly. It needs to be included after the PILS
* definitions so that it can access them, but the code reduction seemed
* to justify this. Hopefully it can be made somewhat more elegant
* eventually. */
/*
* Many expect/telnet plugins use these defines and functions.
*/
#define SEND(fd,s) { \
size_t slen = strlen(s); \
if (Debug) { \
LOG(PIL_DEBUG \
, "Sending [%s] (len %d)" \
, (s) \
, (int)slen); \
} \
if (write((fd), (s), slen) != slen) { \
LOG(PIL_CRIT \
, "%s: write failed" \
, __FUNCTION__); \
} \
}
#define EXPECT(fd,p,t) { \
if (StonithLookFor(fd, p, t) < 0) \
return(errno == ETIMEDOUT \
? S_TIMEOUT : S_OOPS); \
}
#define NULLEXPECT(fd,p,t) { \
if (StonithLookFor(fd, p, t) < 0) \
return(NULL); \
}
#define SNARF(fd,s, to) { \
if (StonithScanLine(fd,to,(s),sizeof(s))\
!= S_OK){ \
return(S_OOPS); \
} \
}
#define NULLSNARF(fd,s, to){ \
if (StonithScanLine(fd,to,(s),sizeof(s))\
!= S_OK) { \
return(NULL); \
} \
}
/* Look for any of the given patterns. We don't care which */
static int
StonithLookFor(int fd, struct Etoken * tlist, int timeout)
{
int rc;
char savebuf[512];
if ((rc = EXPECT_TOK(fd, tlist, timeout, savebuf, sizeof(savebuf)
, Debug)) < 0) {
LOG(PIL_CRIT, "Did not find string %s from " DEVICE "."
, tlist[0].string);
LOG(PIL_CRIT, "Received [%s]", savebuf);
}
return(rc);
}
#ifndef DOESNT_USE_STONITHSCANLINE
/* Accept either a CR/NL or an NL/CR */
static struct Etoken CRNL[] = { {"\n\r",0,0},{"\r\n",0,0},{NULL,0,0}};
static int
StonithScanLine(int fd, int timeout, char * buf, int max)
{
if (EXPECT_TOK(fd, CRNL, timeout, buf, max, Debug) < 0) {
LOG(PIL_CRIT, "Could not read line from" DEVICE ".");
return(S_OOPS);
}
return(S_OK);
}
#endif
#ifndef DOESNT_USE_STONITHKILLCOMM
static void
Stonithkillcomm(int *rdfd, int *wrfd, int *pid)
{
if ((rdfd != NULL) && (*rdfd >= 0)) {
close(*rdfd);
*rdfd = -1;
}
if ((wrfd != NULL) && (*wrfd >= 0)) {
close(*wrfd);
*wrfd = -1;
}
if ((pid != NULL) && (*pid > 0)) {
STONITH_KILL(*pid, SIGKILL);
(void)waitpid(*pid, NULL, 0);
*pid = -1;
}
}
#endif
|
