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
|
#include <stdlib.h>
#include "xdr.h"
int db__send_float(float d)
{
XDR xdrs;
int stat;
stat = DB_OK;
xdr_begin_send (&xdrs);
if(!xdr_float (&xdrs, &d))
stat = DB_PROTOCOL_ERR;
xdr_end_send (&xdrs);
if (stat == DB_PROTOCOL_ERR)
db_protocol_error();
return stat;
}
int db__recv_float (float *d)
{
XDR xdrs;
int stat;
stat = DB_OK;
xdr_begin_recv (&xdrs);
if(!xdr_float (&xdrs, d))
stat = DB_PROTOCOL_ERR;
xdr_end_recv (&xdrs);
if (stat == DB_PROTOCOL_ERR)
db_protocol_error();
return stat;
}
int db__send_float_array (float *x, int n)
{
XDR xdrs;
int i;
int stat;
stat = DB_OK;
xdr_begin_send (&xdrs);
if(!xdr_int (&xdrs, &n))
stat = DB_PROTOCOL_ERR;
for (i = 0; stat == DB_OK && i < n; i++)
{
if(!xdr_float (&xdrs, x))
stat = DB_PROTOCOL_ERR;
x++;
}
xdr_end_send (&xdrs);
if (stat == DB_PROTOCOL_ERR)
db_protocol_error();
return stat;
}
/* returns an allocated array of floats */
/* caller is responsible for free() */
int db__recv_float_array (float **x, int *n)
{
XDR xdrs;
int i, count, stat;
float y, *a;
*x = NULL;
*n = 0;
stat = DB_OK;
xdr_begin_recv (&xdrs);
if (xdr_int (&xdrs, &count))
{
if (count <= 0)
stat = DB_PROTOCOL_ERR;
a = (float *)db_calloc (count, sizeof (float));
if (a == NULL && stat == DB_OK)
stat = DB_MEMORY_ERR;
for (i = 0; i < count; i++)
{
if (!xdr_float (&xdrs, &y))
{
stat = DB_PROTOCOL_ERR;
break;
}
if (a) a[i] = y;
}
if (stat != DB_OK)
{
if (a != NULL) free(a);
a = NULL;
}
}
else
stat = DB_PROTOCOL_ERR;
if (stat == DB_OK)
{
*x = a;
*n = count;
}
else if (stat == DB_PROTOCOL_ERR)
db_protocol_error();
xdr_end_recv (&xdrs);
return stat;
}
|
