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
|
/*
* Copyright (c) 2001-2002 The Trustees of Indiana University.
* All rights reserved.
* Copyright (c) 1998-2001 University of Notre Dame.
* All rights reserved.
* Copyright (c) 1994-1998 The Ohio State University.
* All rights reserved.
*
* This file is part of the LAM/MPI software package. For license
* information, see the LICENSE file in the top level directory of the
* LAM/MPI source distribution.
*
* $HEADER$
* Ohio Trollius
* Copyright 1995 The Ohio State University
* GDB
*
* $Log: bfselect.c,v $
* Revision 6.3 2002/10/09 20:59:49 brbarret
* * Update tree to match the latest, greatest, license for LAM/MPI. And this
* one is even done properly :)
*
* Revision 6.2 1999/05/26 18:22:02 kmeyer1
* added copyright
*
* Revision 6.1 1996/11/23 23:56:34 nevin
* Ohio Release
*
* Revision 6.0 96/02/29 13:57:53 gdburns
* Ohio Release
*
* Function: - blocking probe on multiple SQL sync points
* Accepts: - synchronization array
* - array size
* - additional flags
* Returns: - index of matched sync pt or ERROR
* - updates bfk_type with probed sync point
* - does not return probed length
*/
#include <bfreq.h>
#include <events.h>
#include <net.h>
#include <terror.h>
#include <typical.h>
int
bfselect(pbfk, nbfk, flags, sync_index)
struct bfsync *pbfk;
int nbfk;
int4 flags;
int *sync_index;
{
struct bfreq *req; /* bufferd request */
struct nmsg nhreq; /* bufferd req msg */
struct nmsg nhprobe; /* probed message */
int i;
if ((nbfk < 0) || (nbfk > (MAXNMSGLEN / sizeof(struct bfsync)))) {
errno = EINVAL;
return(LAMERROR);
}
/*
* Send a query message to the buffer.
*/
req = (struct bfreq *) nhreq.nh_data;
req->bfq_req = BFQRECV;
req->bfq_event = pbfk->bfk_event;
req->bfq_type = pbfk->bfk_type;
req->bfq_flags = flags | KSYNCSQL;
/*
* Set up bufferd request message.
*/
nhreq.nh_dl_event = EVBUFFERD;
nhreq.nh_node = LOCAL;
nhreq.nh_event = EVBUFFERD;
nhreq.nh_type = DLCTL;
nhreq.nh_flags = flags & KTRACE;
nhreq.nh_length = (nbfk == 1) ? 0 : sizeof(struct bfsync) * nbfk;
nhreq.nh_msg = (char *) pbfk;
nhprobe.nh_flags = KPROBE | KSYNCSQL | (flags & KTRACE);
nhprobe.nh_msg = 0;
/*
* Receive probes using the full SQL wildcard until a probe
* matches one of the sync points.
*/
for (;;) {
nhprobe.nh_event = req->bfq_event | KEVENTHI;
nhprobe.nh_type = KTYPEHI | KTYPELO;
nhprobe.nh_length = MAXNMSGLEN;
if (dsfr(&nhreq, &nhprobe)) return(LAMERROR);
for (i = 0; i < nbfk; ++i) {
if (bfk_nh_cmp(pbfk + i, &nhprobe)) {
pbfk[i].bfk_type = nhprobe.nh_type;
*sync_index = i;
return(0);
}
}
}
}
|
