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
|
#include <string.h>
#include <stdlib.h>
#include "xdr.h"
db__send_string_array(a, count)
dbString *a;
int count;
{
int i;
int stat;
stat = db__send_int (count);
for (i = 0; stat==DB_OK && i < count; i++)
stat = db__send_string (&a[i]);
return stat;
}
/* note: dbString *a; ...(...,&a...) */
db__recv_string_array (a, n)
dbString **a;
int *n;
{
int i,count;
int stat;
dbString *b;
*n = 0;
*a = NULL;
stat = db__recv_int (&count);
if (stat != DB_OK)
return stat;
if (count < 0)
{
db_protocol_error();
return DB_PROTOCOL_ERR;
}
b = db_alloc_string_array(count);
if (b == NULL)
return DB_MEMORY_ERR;
for (i = 0; i < count; i++)
{
stat = db__recv_string (&b[i]);
if (stat != DB_OK)
{
db_free_string_array(b, count);
return stat;
}
}
*n = count;
*a = b;
return DB_OK;
}
db__send_string(x)
dbString *x;
{
XDR xdrs;
int len;
int stat;
char *s;
stat = DB_OK;
s = db_get_string (x);
if (s == NULL) s = ""; /* can't send a NULL string */
len = strlen(s)+1;
xdr_begin_send (&xdrs);
if(!xdr_int (&xdrs, &len))
stat = DB_PROTOCOL_ERR;
else if(!xdr_string (&xdrs, &s, len))
stat = DB_PROTOCOL_ERR;
xdr_end_send (&xdrs);
if (stat == DB_PROTOCOL_ERR)
db_protocol_error();
return stat;
}
/*
* db__recv_string (dbString *x)
* reads a string from transport
*
* returns DB_OK, DB_MEMORY_ERR, or DB_PROTOCOL_ERR
* x.s will be NULL if error
*
* NOTE: caller MUST initialize x by calling db_init_string()
*/
db__recv_string(x)
dbString *x;
{
XDR xdrs;
int len;
int stat;
char *s;
stat = DB_OK;
xdr_begin_recv (&xdrs);
if(!xdr_int (&xdrs, &len) || len <= 0) /* len will include the null byte */
{
stat = DB_PROTOCOL_ERR;
}
else
{
stat = db_enlarge_string (x, len);
}
s = db_get_string(x);
if(stat == DB_OK && !xdr_string (&xdrs, &s, len))
stat = DB_PROTOCOL_ERR;
xdr_end_recv (&xdrs);
if (stat == DB_PROTOCOL_ERR)
db_protocol_error();
return stat;
}
db__send_Cstring(s)
char *s;
{
dbString x;
db_init_string (&x);
db_set_string_no_copy (&x, s);
return db__send_string (&x);
}
|
