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
121
122
123
124
125
126
127
|
/*****************************************************************************\
*
* $Id: dsh.h,v 1.23 2002/08/11 02:47:42 garlick Exp $
* $Source: /chaos/cvs/pdsh/dsh.h,v $
*
* Copyright (C) 1998-2002 The Regents of the University of California.
* Produced at Lawrence Livermore National Laboratory (cf, DISCLAIMER).
* Written by Jim Garlick (garlick@llnl.gov>
* UCRL-CODE-980038
*
* This file is part of PDSH, a parallel remote shell program.
* For details, see <http://www.llnl.gov/linux/pdsh/>.
*
* PDSH is free software; you can redistribute it and/or modify it under
* the terms of the GNU General Public License as published by the Free
* Software Foundation; either version 2 of the License, or (at your option)
* any later version.
*
* PDSH 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 General Public License
* for more details.
*
* You should have received a copy of the GNU General Public License along
* with PDSH; if not, write to the Free Software Foundation, Inc.,
* 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA.
\*****************************************************************************/
#ifndef _DSH_INCLUDED
#define _DSH_INCLUDED
#if HAVE_CONFIG_H
#include "config.h"
#endif
#if HAVE_PTHREAD_H
#include <pthread.h>
#endif
#include "list.h"
#include "opt.h"
#define LINEBUFSIZE 2048
#define INTR_TIME 1 /* secs */
#define WDOG_POLL 2 /* secs */
/* some handy SP constants */
/* NOTE: degenerate case of one node per frame, nodes would be 1, 17, 33,... */
#define MAX_SP_NODES 512
#define MAX_SP_NODES_PER_FRAME 16
#define MAX_SP_NODE_NUMBER (MAX_SP_NODES * MAX_SP_NODES_PER_FRAME - 1)
#ifndef MAXHOSTNAMELEN
#define MAXHOSTNAMELEN 64
#endif
#ifndef MAX
#define MAX(a,b) ((a) > (b) ? (a) : (b))
#endif
#ifndef MIN
#define MIN(a,b) ((a) < (b) ? (a) : (b))
#endif
#define IP_ADDR_LEN 4 /* XXX */
#if !HAVE_PTHREAD_SIGMASK && HAVE_SIGTHREADMASK
#define pthread_sigmask(x, y, z) sigthreadmask(x, y, z)
#endif
#ifndef _BOOL_DEFINED
#define _BOOL_DEFINED
typedef enum {false, true} bool;
#endif
typedef enum {DSH_NEW, DSH_RCMD, DSH_READING, DSH_DONE, DSH_FAILED} state_t;
typedef struct thd {
pthread_t thread;
pthread_attr_t attr;
state_t state; /* thread state */
char *host; /* host name */
char *luser; /* local username */
char *ruser; /* remote username */
rcmd_t rcmd_type; /* K4, BSD ? */
time_t start; /* time stamp for start */
time_t connect; /* time stamp for connect */
time_t finish; /* time stamp for finish */
char *dsh_cmd; /* command */
bool dsh_sopt; /* true if -s (sep stderr/out)*/
list_t pcp_infiles; /* name of input files/dirs */
char *pcp_outfile; /* name of output file/dir */
bool pcp_popt; /* preserve mtime/mode */
bool pcp_ropt; /* recursive */
int rc; /* remote return code (-S) */
int nodeid; /* node index */
int nnodes; /* number of nodes in job */
int fd; /* stdin/stdout */
int efd; /* signal/stderr */
bool labels; /* display host: labels */
char addr[IP_ADDR_LEN]; /* IP address */
} thd_t;
int dsh(opt_t *);
void set_rcmd_timeout(int);
void testcase(int);
int xrcmd(char *, char *, char *, char *, char *, int, int *);
void xrcmd_signal(int, int);
void xrcmd_init(opt_t *);
int k4cmd (char *, char *, char *, char *, char *, int, int *);
void k4cmd_signal(int, int);
void k4cmd_init(opt_t *);
int sshcmd (char *, char *, char *, char *, char *, int, int *);
int sshcmdrw (char *, char *, char *, char *, char *, int, int *);
void sshcmd_signal(int, int);
void sshcmd_init(opt_t *);
int qcmd(char *, char *, char *, char *, char *, int, int *);
void qcmd_init(opt_t *);
void qcmd_signal(int, int);
#endif /* _DSH_INCLUDED */
|
