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
|
/*
bpsendfile.c: test program to send a file as a bundle.
*/
/* */
/* Copyright (c) 2006, California Institute of Technology. */
/* All rights reserved. */
/* Author: Scott Burleigh, Jet Propulsion Laboratory */
/* */
#include <bpP.h>
static int run_bpsendfile(char *ownEid, char *destEid, char *fileName,
char *svcClass)
{
int priority = 0;
BpExtendedCOS extendedCOS = { 0, 0, 0 };
BpCustodySwitch custodySwitch = NoCustodyRequested;
BpSAP sap;
Sdr sdr;
Object fileRef;
struct stat statbuf;
int aduLength;
Object bundleZco;
Object newBundle;
if (svcClass == NULL)
{
priority = BP_STD_PRIORITY;
}
else
{
if (!bp_parse_class_of_service(svcClass, &extendedCOS,
&custodySwitch, &priority))
{
putErrmsg("Invalid class of service for bpsendfile.",
svcClass);
return 0;
}
}
if (bp_attach() < 0)
{
putErrmsg("Can't attach to BP.", NULL);
return 0;
}
if (bp_open(ownEid, &sap) < 0)
{
putErrmsg("Can't open own endpoint.", ownEid);
return 0;
}
if (stat(fileName, &statbuf) < 0)
{
bp_close(sap);
putSysErrmsg("Can't stat the file", fileName);
return 0;
}
aduLength = statbuf.st_size;
sdr = bp_get_sdr();
CHKZERO(sdr_begin_xn(sdr));
if (sdr_heap_depleted(sdr))
{
sdr_exit_xn(sdr);
bp_close(sap);
putErrmsg("Low on heap space, can't send file.", fileName);
return 0;
}
fileRef = zco_create_file_ref(sdr, fileName, NULL);
if (sdr_end_xn(sdr) < 0 || fileRef == 0)
{
bp_close(sap);
putErrmsg("bpsendfile can't create file ref.", NULL);
return 0;
}
bundleZco = ionCreateZco(ZcoFileSource, fileRef, 0, aduLength, NULL);
if (bundleZco == 0)
{
putErrmsg("bpsendfile can't create ZCO.", NULL);
}
else
{
if (bp_send(sap, destEid, NULL, 300, priority, custodySwitch,
0, 0, &extendedCOS, bundleZco, &newBundle) <= 0)
{
putErrmsg("bpsendfile can't send file in bundle.",
itoa(aduLength));
}
}
bp_close(sap);
writeErrmsgMemos();
PUTS("Stopping bpsendfile.");
CHKZERO(sdr_begin_xn(sdr));
zco_destroy_file_ref(sdr, fileRef);
if (sdr_end_xn(sdr) < 0)
{
putErrmsg("bpsendfile can't destroy file reference.", NULL);
}
bp_detach();
return 0;
}
#if defined (VXWORKS) || defined (RTEMS)
int bpsendfile(int a1, int a2, int a3, int a4, int a5,
int a6, int a7, int a8, int a9, int a10)
{
char *ownEid = (char *) a2;
char *destEid = (char *) a3;
char *fileName = (char *) a4;
char *classOfService = (char *) a5;
#else
int main(int argc, char **argv)
{
char *ownEid = NULL;
char *destEid = NULL;
char *fileName = NULL;
char *classOfService = NULL;
if (argc > 5) argc = 5;
switch (argc)
{
case 5:
classOfService = argv[4];
case 4:
fileName = argv[3];
case 3:
destEid = argv[2];
case 2:
ownEid = argv[1];
default:
break;
}
#endif
if (ownEid == NULL || destEid == NULL || fileName == NULL)
{
PUTS("Usage: bpsendfile <own endpoint ID> <destination \
endpoint ID> <file name> [<class of service>]");
PUTS("\tclass of service: " BP_PARSE_CLASS_OF_SERVICE_USAGE);
return 0;
}
return run_bpsendfile(ownEid, destEid, fileName, classOfService);
}
|
