-
Notifications
You must be signed in to change notification settings - Fork 1
/
Copy pathmetadata.h
184 lines (154 loc) · 5.15 KB
/
metadata.h
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
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
/*
Copyright (c) 2011, Charles Smith
All rights reserved.
Redistribution and use in source and binary forms, with or without
modification,
are permitted provided that the following conditions are met:
* Redistributions of source code must retain the above copyright notice,
this
list of conditions and the following disclaimer.
* Redistributions in binary form must reproduce the above copyright notice,
this
list of conditions and the following disclaimer in the documentation
and/or
other materials provided with the distribution.
* Neither the name of Vallona Networks nor the names of its contributors
may be used to endorse or promote products derived from this software
without
specific prior written permission.
THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS" AND
ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED
WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE
DISCLAIMED.
IN NO EVENT SHALL THE COPYRIGHT HOLDER OR CONTRIBUTORS BE LIABLE FOR ANY
DIRECT,
INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING,
BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF
LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE
OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF
ADVISED
OF THE POSSIBILITY OF SUCH DAMAGE.
*/
#ifndef _METADATA_H
#define _METADATA_H
#include <cstring>
#include <iostream>
#include <string>
using namespace std;
#include "checksum.h"
#include "dirent.h"
#include "fileio.h"
#include "frame.h"
#include "saratoga.h"
#include "sarflags.h"
#include "screen.h"
#include "timestamp.h"
namespace saratoga {
/*
**********************************************************************
* METADATA
**********************************************************************
*/
class metadata : public frame
{
private:
Fflag _flags; // Frame Flags
session_t _session; // Session #
checksums::checksum _csum; // What the Checksum is
sardir::dirent _dir; // What's in the directory entry
protected:
bool _badframe; // Are we a good or bad data frame
char* _payload; // Complete payload of frame
size_t _paylen; // Length of payload
public:
// This is how we assemble a local metadata
// To get ready for transmission
metadata(const enum f_descriptor, const enum f_transfer,
const enum f_progress,
const session_t, // Session ID
sarfile::fileio*); // File info
// We have received a remote frame that is METADATA
metadata(char*, // Pointer to buffer received
const size_t); // Total length of buffer
~metadata() { this->clear(); };
void clear()
{
if (_paylen > 0)
delete[] _payload; // Delete frames payload
_csum.clear(); // Delete the checksum
_dir.clear(); // Delete the directory entry
_paylen = 0; // Set it's length to 0
_session = 0;
_flags = 0;
};
// Copy Constructor
metadata(const metadata& old)
{
if (old._paylen > 0) {
_payload = new char[old._paylen];
memcpy(_payload, old._payload, old._paylen);
} else
_payload = nullptr;
_paylen = old._paylen;
_flags = old._flags;
_session = old._session;
_csum = old._csum;
_dir = old._dir;
_badframe = old._badframe;
};
metadata& operator=(const metadata& old)
{
if (old._paylen > 0) {
_payload = new char[old._paylen];
memcpy(_payload, old._payload, old._paylen);
} else
_payload = nullptr;
_paylen = old._paylen;
_flags = old._flags;
_session = old._session;
_csum = old._csum;
_dir = old._dir;
_badframe = old._badframe;
return (*this);
};
bool badframe() { return _badframe; };
size_t paylen() { return _paylen; };
char* payload() { return _payload; };
flag_t flags() { return _flags.get(); };
// Get various flags applicable to metadata
enum f_descriptor descriptor();
enum f_transfer transfer();
enum f_progress progress();
enum f_udptype metadata_udptype();
enum f_csumlen csumlen();
enum f_csumtype csumtype();
// Set various flags applicable to metadata
enum f_descriptor descriptor(f_descriptor);
enum f_transfer transfer(f_transfer);
enum f_progress progress(f_progress);
enum f_udptype metadata_udptype(f_udptype);
enum f_csumlen csumlen(f_csumlen);
enum f_csumtype csumtype(f_csumtype);
// Yes I am a METADATA frame
f_frametype type() { return F_FRAMETYPE_METADATA; };
// What is the session number for this transaction
session_t session() { return _session; };
// The checksum
checksums::checksum checksum() { return _csum; };
// The directory entry
sardir::dirent dir() { return _dir; };
// The number of bytes in the checksum
size_t bytes();
ssize_t tx(sarnet::udp* sock) { return (sock->tx(_payload, _paylen)); };
ssize_t rx()
{
string s = "METADATA RX: ";
s += this->print();
cout << s << endl;
return (-1);
};
string print();
};
} // Namespace saratoga
#endif // _METADATA_H