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
|
/*
* SCCS: @(#)sdasync.c 1.10 (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: @(#)sdasync.c 1.10 98/09/01 TETware release 3.3
NAME: sdasync.c
PRODUCT: TETware
AUTHOR: Andrew Dingwall, UniSoft Ltd.
DATE CREATED: April 1992
DESCRIPTION:
generic auto-sync request function
MODIFICATIONS:
Andrew Dingwall, UniSoft Ltd., October 1994
added support for sync message data
Andrew Dingwall, UniSoft Ltd., August 1996
added support for tetware-style syncing
Andrew Dingwall, UniSoft Ltd., June 1997
added xrid argument to tet_sdasync() -
this is required in order to make parallel remote and
distributed test cases work correctly
Andrew Dingwall, UniSoft Ltd., July 1998
Added support for shared API libraries.
Aaron Plattner, April 2010
Fixed warnings when compiled with GCC's -Wall option.
************************************************************************/
#include <stdio.h>
#include "dtmac.h"
#include "dtmsg.h"
#include "valmsg.h"
#include "synreq.h"
#include "error.h"
#include "servlib.h"
#include "dtetlib.h"
/*
** tet_sdasync() - perform a generic auto-sync request
**
** return 0 if successful or -1 on error
**
** if successful, the sysid and sync point numbers (for ER_OK)
** or sync states (for ER_SYNCERR or ER_TIMEDOUT) are stored in the
** array at *synreq which contains *nsys elements;
** also, the number of participating systems is returned indirectly
** through *nsys
*/
TET_IMPORT int tet_sdasync(snid, xrid, spno, vote, timeout, synreq, nsys)
long snid, xrid, spno;
int vote, timeout, *nsys;
struct synreq *synreq;
{
register struct valmsg *mp;
register struct synreq *sp;
register int n;
extern char tet_sderrmsg[];
/* get the SYNCD message buffer */
if ((mp = (struct valmsg *) tet_sdmsgbuf(valmsgsz(OP_AUSYNC_NVALUE(0)))) == (struct valmsg *) 0) {
tet_sderrno = ER_ERR;
return(-1);
}
/* set up the request message */
mp->vm_nvalue = OP_AUSYNC_NVALUE(0);
VM_SNID(mp) = snid;
VM_XRID(mp) = xrid;
VM_SPNO(mp) = spno;
VM_SVOTE(mp) = (long) vote;
VM_STIMEOUT(mp) = (long) timeout;
VM_MSFLAGS(mp) = 0L;
VM_MSDLEN(mp) = 0L;
/* perform the conversation */
if (timeout >= 0) {
if ((n = TALK_DELAY + timeout) < 0)
n = (int) ((unsigned) ~0 >> 1);
}
else
n = 0;
mp = (struct valmsg *) tet_sdtalk(OP_ASYNC, n);
/* handle the reply codes */
switch (tet_sderrno) {
case ER_OK:
case ER_SYNCERR:
case ER_TIMEDOUT:
if (!synreq || !nsys)
return(0);
break;
case ER_INVAL:
case ER_SNID:
case ER_SYSID:
case ER_DONE:
return(-1);
case ER_ERR:
if (!mp)
return(-1);
/* else fall through */
default:
error(0, tet_sderrmsg, tet_ptrepcode(tet_sderrno));
return(-1);
}
/* here to build the synreq list for a normal return */
for (n = 0, sp = synreq; n < *nsys && n < OP_AUSYNC_NSYS(mp); n++, sp++) {
sp->sy_sysid = (int) VM_SSYSID(mp, n);
switch (tet_sderrno) {
case ER_OK:
sp->sy_spno = VM_RSPNO(mp, n);
break;
case ER_SYNCERR:
case ER_TIMEDOUT:
sp->sy_state = (int) VM_STATE(mp, n);
break;
}
}
*nsys = OP_AUSYNC_NSYS(mp);
return(0);
}
|
