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
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
|
/***********************************************************************
* *
* This software is part of the ast package *
* Copyright (c) 1990-2011 AT&T Intellectual Property *
* and is licensed under the *
* Eclipse Public License, Version 1.0 *
* by AT&T Intellectual Property *
* *
* A copy of the License is available at *
* http://www.eclipse.org/org/documents/epl-v10.html *
* (with md5 checksum b35adb5213ca9657e911e9befb180842) *
* *
* Information and Software Systems Research *
* AT&T Research *
* Florham Park NJ *
* *
* Glenn Fowler <gsf@research.att.com> *
* *
***********************************************************************/
#pragma prototyped
/*
* Glenn Fowler
* AT&T Research
*
* coshell library interface
*/
#ifndef _COSHELL_H
#define _COSHELL_H
#include <ast.h>
#if !_BLD_coshell
#undef procrun
#define procrun(a,b,c) coprocrun(a,b,c)
#undef system
#define system(a) cosystem(a)
#endif
struct Coshell_s; typedef struct Coshell_s Coshell_t;
struct Cojob_s; typedef struct Cojob_s Cojob_t;
/*
* DEPRECATED names for compatibility
*/
#define COSHELL Coshell_t
#define COJOB Cojob_t
#define CO_ID "coshell" /* library/command id */
#define CO_ENV_ATTRIBUTES "COATTRIBUTES"/* coshell attributes env var */
#define CO_ENV_EXPORT "COEXPORT" /* coshell env var export list */
#define CO_ENV_HOST "HOSTNAME" /* coshell host name env var */
#define CO_ENV_MSGFD "_COSHELL_msgfd"/* msg fd */
#define CO_ENV_OPTIONS "COSHELL_OPTIONS"/* options environment var */
#define CO_ENV_PROC "NPROC" /* concurrency environment var */
#define CO_ENV_SHELL "COSHELL" /* coshell path environment var */
#define CO_ENV_TEMP "COTEMP" /* 10 char temp file base */
#define CO_ENV_TYPE "HOSTTYPE" /* coshell host type env var */
#define CO_OPT_ACK "ack" /* wait for server coexec() ack */
#define CO_OPT_INDIRECT "indirect" /* indirect server connection */
#define CO_OPT_SERVER "server" /* server connection */
#define CO_QUANT 100 /* time quanta per sec */
#define CO_ANY 0x000001 /* return any open coshell */
#define CO_DEBUG 0x000002 /* library debug trace */
#define CO_EXPORT 0x000004 /* export everything */
#define CO_IGNORE 0x000008 /* ignore command errors */
#define CO_LOCAL 0x000010 /* local affinity */
#define CO_NONBLOCK 0x000020 /* don't block coexec if Q full */
#define CO_SHELL 0x000040 /* shell using coshell! */
#define CO_SILENT 0x000080 /* don't trace commands */
#define CO_KSH 0x000100 /* coshell is ksh (readonly) */
#define CO_SERVER 0x000200 /* coshell is server (readonly) */
#define CO_OSH 0x000400 /* coshell is OLD (readonly) */
#define CO_CROSS 0x000800 /* don't prepend local dirs */
#define CO_DEVFD 0x001000 /* coshell handles /dev/fd/# */
#define CO_SERIALIZE 0x002000 /* serialize stdout and stderr */
#define CO_SERVICE 0x004000 /* service callouts */
#define CO_APPEND 0x008000 /* append coexec() out/err */
#define CO_SEPARATE 0x010000 /* 1 shell+wait per coexec() */
#define CO_ORPHAN 0x020000 /* PROC_ORPHAN */
#define CO_USER 0x100000 /* first user flag */
struct Cojob_s /* coshell job info */
{
Coshell_t* coshell; /* running in this coshell */
int id; /* job id */
int status; /* exit status */
int flags; /* CO_* flags */
void* local; /* local info */
unsigned long user; /* user time in 1/CO_QUANT secs */
unsigned long sys; /* sys time in 1/CO_QUANT secs */
#ifdef _CO_JOB_PRIVATE_
_CO_JOB_PRIVATE_ /* library private additions */
#endif
};
struct Coshell_s /* coshell connection info */
{
void* data; /* user data, initially 0 */
int flags; /* flags */
int outstanding; /* number of outstanding jobs */
int running; /* number of running jobs */
int total; /* number of coexec() jobs */
unsigned long user; /* user time in 1/CO_QUANT secs */
unsigned long sys; /* sys time in 1/CO_QUANT secs */
Sfio_t* msgfp; /* message stream for sfpoll() */
#ifdef _CO_SHELL_PRIVATE_
_CO_SHELL_PRIVATE_ /* library private additions */
#endif
};
extern int coclose(Coshell_t*);
extern Cojob_t* coexec(Coshell_t*, const char*, int, const char*, const char*, const char*);
extern char* coinit(int);
extern int coexport(Coshell_t*, const char*, const char*);
extern int cokill(Coshell_t*, Cojob_t*, int);
extern Coshell_t* coopen(const char*, int, const char*);
extern void coquote(Sfio_t*, const char*, int);
extern int cosync(Coshell_t*, const char*, int, int);
extern Cojob_t* cowait(Coshell_t*, Cojob_t*, int);
extern int cojobs(Coshell_t*);
extern int copending(Coshell_t*);
extern int cozombie(Coshell_t*);
extern int coattr(Coshell_t*, const char*);
extern int coprocrun(const char*, char**, int);
extern int cosystem(const char*);
#endif
|
