summaryrefslogtreecommitdiff
path: root/src/tet3/tcm/tcm.c
blob: 257dd7ac3efcd64fe96cb6bc12fc5f17aef10f57 (plain)
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
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
237
238
239
240
241
242
243
244
245
246
247
248
249
250
251
252
253
254
255
256
257
258
259
260
261
262
263
264
265
266
267
268
269
270
271
272
273
274
275
276
277
278
279
280
281
282
283
284
285
286
287
288
289
290
291
292
293
294
295
296
297
298
299
300
301
302
303
304
305
306
307
308
309
310
311
312
313
314
315
316
317
318
319
320
321
322
323
324
325
326
327
328
329
330
331
332
333
334
335
336
337
338
339
340
341
342
343
344
345
346
347
348
349
350
351
352
353
354
355
356
357
358
359
/*
 *      SCCS:  @(#)tcm.c	1.17 (98/09/01) 
 *
 *	UniSoft Ltd., London, England
 *
 * (C) Copyright 1992 X/Open Company Limited
 *
 * All rights reserved.  No part of this source code may be reproduced,
 * stored in a retrieval system, or transmitted, in any form or by any
 * means, electronic, mechanical, photocopying, recording or otherwise,
 * except as stated in the end-user licence agreement, without the prior
 * permission of the copyright owners.
 *
 * X/Open and the 'X' symbol are trademarks of X/Open Company Limited in
 * the UK and other countries.
 */

#ifdef HAVE_CONFIG_H
#include <config.h>
#endif

/************************************************************************

SCCS:   	@(#)tcm.c	1.17 98/09/01 TETware release 3.3
NAME:		tcm.c
PRODUCT:	TETware
AUTHOR:		Andrew Dingwall, UniSoft Ltd.
DATE CREATED:	April 1992

DESCRIPTION:
	tcm main() and client-related functions

MODIFICATIONS:
	Denis McConalogue, UniSoft Limited, June 1993
	API enhancements - combined [ms]tcmfuncs.c into this file.

	Denis McConalogue, UniSoft Limited, September 1993
	changed tet_tcmptype() to set process type PT_MTCM for
	all non-distributed test cases (executing on master or
	slave systems).

	Andrew Dingwall, UniSoft Ltd., August 1996
	changes for TETware

	Geoff Clare, UniSoft Ltd., Sept 1996
	changes for TETware-Lite

	Geoff Clare, UniSoft Ltd., Oct 1996
	restructured tcm source to avoid "ld -r"
	(this file was mtcmfuncs.c - moved main() and other things here)

	Andrew Dingwall, UniSoft Ltd., April 1997
	initialise tet_pname in case it gets used (in tet_dtcmerror())
	before it can be set up in tet_tcm*_main()

	Andrew Dingwall, UniSoft Ltd., June 1997
	initialised tet_tcmlast to the hightest possible value

	Andrew Dingwall, UniSoft Ltd., July 1998
	Added support for shared API libraries.
 
	Andrew Josey, The Open Group, February 2000
	Add a cast to the call on tet_init_globals to placate the
	latest g++ compiler.
************************************************************************/

#ifdef __cplusplus
extern "C" {
#endif

#include <stdio.h>
#  include <signal.h>
#  include <unistd.h>
#include "dtmac.h"
#include "dtmsg.h"
#include "dtthr.h"
#include "globals.h"
#include "tcmfuncs.h"
#ifndef TET_LITE /* -START-LITE-CUT- */
#  include "error.h"
#  include "ptab.h"
#  include "synreq.h"
#  include "server.h"
#  include "tslib.h"
#endif		/* -END-LITE-CUT- */
#include "dtetlib.h"
#include "sigsafe.h"

extern int	tet_tcm_main PROTOLIST((int, char **));
extern void	tet_dtcmerror PROTOLIST((int, const char *, int, const char *, const char *));

TET_EXPORT char *tet_pname = "<unknown>";
TET_EXPORT int tet_thistest = 0;
TET_EXPORT int tet_nosigreset = 0;	/* has no effect in WIN32 */

#ifndef TET_LITE /* -START-LITE-CUT- */
TET_EXPORT long tet_snid = -1L;		/* sync id */
TET_EXPORT long tet_xrid = -1L;		/* xres id */
TET_EXPORT int *tet_snames;		/* system name list */
TET_EXPORT int tet_Nsname;		/* number of system names */
TET_EXPORT struct ptab *tet_sdptab, *tet_xdptab;
					/* ptab elements for syncd and xresd */
int tet_psysid = -1;			/* parent's system id */
#endif		/* -END-LITE-CUT- */

TET_EXPORT sigset_t tet_blockable_sigs;

#ifdef TET_THREADS
TET_EXPORT tet_thread_t tet_start_tid;
#endif /* TET_THREADS */

#ifdef __cplusplus
}
#endif

/*
**	main() is the main program for the Test Case Manager (TCM).
**	It is simply a wrapper for tet_tcm_main().
*/

#ifdef PROTOTYPES
int main(int argc, char **argv)
#else
int main(argc, argv)
int	argc;
char	**argv;
#endif
{

#ifdef TET_LITE					/* -LITE-CUT-LINE- */
#  define MYPTYPE	PT_MTCM
#  define MYSYSID	0
#else						/* -START-LITE-CUT- */
#  define MYPTYPE	-1
#  define MYSYSID	-1
#endif						/* -END-LITE-CUT- */

	/* must be first */
	tet_init_globals(argc > 0 ? tet_basename(*argv) : (char *) "TCM",
		MYPTYPE, MYSYSID, tet_dtcmerror, tet_genfatal);

	/*
	** make sure that we are linked with the right version of
	** the API library
	*/
	tet_check_apilib_version();


	return tet_tcm_main(argc, argv);
}

#ifndef TET_LITE /* -START-LITE-CUT- */

#ifdef __cplusplus
extern "C" {
#endif

/*
**	tet_tcm_async() - do an automatic sync from the MTCM
*/

#ifdef PROTOTYPES
TET_EXPORT int tet_tcm_async(long spno, int vote, int timeout,
	    struct synreq *synreq, int *nsys)
#else
TET_EXPORT int tet_tcm_async(spno, vote, timeout, synreq, nsys)
long spno;
int vote, timeout, *nsys;
struct synreq *synreq;
#endif
{
	return(tet_sdasync(tet_snid, tet_xrid, spno, vote, timeout, synreq, nsys));
}

/*
**	tet_tcmptype() - return process type for a TCM
**
**	In TETware there is almost no difference between "master" and
**	"slave" TCMs and this function is only used to decide which
**	TCMs in a distributed test case should inform XRESD of IC and
**	TP start and end.
**	Someone has to do it so it might as well be the first (or only)
**	system in the system list.
*/

int tet_tcmptype PROTOLIST((void))
{
	int sys1;

	sys1 = tet_snames ? *tet_snames : -1;

	return (tet_mysysid == sys1 ? PT_MTCM : PT_STCM);
}

/*
**	tet_ss_dead() - server-specific dead process handler
**
**	should only be called from tet_si_service() when a server dies
**	unexpectedly
**
**	server logoff routines do not come here
*/

#ifdef PROTOTYPES
TET_EXPORT void tet_ss_dead(struct ptab *pp)
#else
TET_EXPORT void tet_ss_dead(pp)
struct ptab *pp;
#endif
{
	/* emit a diagnostic if this is unexpected */
	if ((pp->pt_flags & PF_LOGGEDOFF) == 0)
		error(0, "server connection closed", tet_r2a(&pp->pt_rid));

	pp->pt_flags = (pp->pt_flags & ~PF_LOGGEDON) | PF_LOGGEDOFF;
}

/*
**	tet_ss_connect() - connect to remote process
*/

#ifdef PROTOTYPES
TET_EXPORT void tet_ss_connect(struct ptab *pp)
#else
TET_EXPORT void tet_ss_connect(pp)
struct ptab *pp;
#endif
{
	tet_ts_connect(pp);
}

/*
**	tet_ss_ptalloc(), tet_ss_ptfree()  - allocate and free server-specific
**		ptab data area
**
**	tcm does not make use of server-specific data
*/

#ifdef PROTOTYPES
TET_EXPORT int tet_ss_ptalloc(struct ptab *pp)
#else
TET_EXPORT int tet_ss_ptalloc(pp)
struct ptab *pp;
#endif
{
	pp->pt_sdata = (char *) 0;
	return(0);
}

/* ARGSUSED */
#ifdef PROTOTYPES
TET_EXPORT void tet_ss_ptfree(struct ptab *pp)
#else
TET_EXPORT void tet_ss_ptfree(pp)
struct ptab *pp;
#endif
{
	/* nothing */
}

/*
**	tet_ss_serverloop() - server-specific server loop
**
**	this may be called from tet_si_servwait() if non-blocking message i/o
**	would block
**
**	tcm does not do non-blocking i/o, so this should never occur
*/

TET_EXPORT int tet_ss_serverloop PROTOLIST((void))
{
	error(0, "internal error - serverloop called!", (char *) 0);
	return(-1);
}

/*
**	tet_ss_process() - server-specific request process routine
**
**	would be called from tet_si_service() when state is PS_PROCESS
**
**	tcm only uses tet_si_clientloop() which itself returns as soon as a
**	process reaches this state, so tet_ss_process() should never be called
**/

#ifdef PROTOTYPES
TET_EXPORT void tet_ss_process(struct ptab *pp)
#else
TET_EXPORT void tet_ss_process(pp)
struct ptab *pp;
#endif
{
	error(0, "internal error - tet_ss_process called!",
		tet_r2a(&pp->pt_rid));
}

/*
 * The following functions are simply wrappers for the real functions
 * in tcm_bs.c, tcm_in.c and tcm_xt.c.  This is done so that tccd, xresd
 * and syncd cannot resolve these symbols in libapi.a.
 */

extern int tet_tcm_bs2md PROTOLIST((char *, struct ptab *));

#ifdef PROTOTYPES
TET_EXPORT int tet_ss_bs2md(char *from, struct ptab *pp)
#else
TET_EXPORT int tet_ss_bs2md(from, pp)
char *from;
struct ptab *pp;
#endif
{
	return tet_tcm_bs2md(from, pp);
}

extern int tet_tcm_md2bs PROTOLIST((struct ptab *, char **, int *, int));

#ifdef PROTOTYPES
TET_EXPORT int tet_ss_md2bs(struct ptab *pp, char **bp, int *lp, int offs)
#else
TET_EXPORT int tet_ss_md2bs(pp, bp, lp, offs)
struct ptab *pp;
char **bp;
int *lp, offs;
#endif
{
	return tet_tcm_md2bs(pp, bp, lp, offs);
}

extern int tet_tcm_tsconnect PROTOLIST((struct ptab *));

#ifdef PROTOTYPES
TET_EXPORT int tet_ss_tsconnect(struct ptab *pp)
#else
TET_EXPORT int tet_ss_tsconnect(pp)
struct ptab *pp;
#endif
{
	return tet_tcm_tsconnect(pp);
}

extern int tet_tcm_tsinfo PROTOLIST((struct ptab *, int));

#ifdef PROTOTYPES
TET_EXPORT int tet_ss_tsinfo(struct ptab *pp, int ptype)
#else
TET_EXPORT int tet_ss_tsinfo(pp, ptype)
struct ptab *pp;
int ptype;
#endif
{
	return tet_tcm_tsinfo(pp, ptype);
}

#ifdef __cplusplus
}
#endif

#endif /* -END-LITE-CUT- */