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
|
/**
* @file lliobuffer.h
* @author Phoenix
* @date 2005-05-04
* @brief Declaration of buffers for use in IO Pipes.
*
* Copyright (c) 2005-$CurrentYear$, Linden Research, Inc.
* $License$
*/
#ifndef LL_LLIOBUFFER_H
#define LL_LLIOBUFFER_H
#include "lliopipe.h"
/**
* @class LLIOBuffer
* @brief This class is an io class that represents an automtically
* resizing io buffer.
* @see LLIOPipe
*
* This class is currently impelemented quick and dirty, but should be
* correct. This class should be extended to have a more flexible
* (and capped) memory allocation and usage scheme. Eventually, I
* would like to have the ability to share this buffer between
* different objects.
*/
class LLIOBuffer : public LLIOPipe
{
public:
LLIOBuffer();
virtual ~LLIOBuffer();
/**
* @brief Return a raw pointer to the current data set.
*
* The pointer returned can be used for reading or even adjustment
* if you are a bit crazy up to size() bytes into memory.
* @return A potentially NULL pointer to the raw buffer data
*/
U8* data() const;
/**
* @brief Return the size of the buffer
*/
S64 size() const;
/**
* @brief Return a raw pointer to the current read position in the data.
*
* The pointer returned can be used for reading or even adjustment
* if you are a bit crazy up to bytesLeft() bytes into memory.
* @return A potentially NULL pointer to the buffer data starting
* at the read point
*/
U8* current() const;
/**
* @brief Return the number of unprocessed bytes in buffer.
*/
S64 bytesLeft() const;
/**
* @brief Move the buffer offsets back to the beginning.
*
* This method effectively clears what has been stored here,
* without mucking around with memory allocation.
*/
void clear();
/**
* @brief Enumeration passed into the seek function
*
* The READ head is used for where to start processing data for
* the next link in the chain, while the WRITE head specifies
* where new data processed from the previous link in the chain
* will be written.
*/
enum EHead
{
READ,
WRITE
};
/**
* @brief Seek to a place in the buffer
*
* @param head The READ or WRITE head.
* @param delta The offset from the current position to seek.
* @return The status of the operation. status >= if head moved.
*/
EStatus seek(EHead head, S64 delta);
public:
/* @name LLIOPipe virtual implementations
*/
//@{
protected:
/**
* @brief Process the data in buffer
*/
virtual EStatus process_impl(
const LLChannelDescriptors& channels,
buffer_ptr_t& buffer,
bool& eos,
LLSD& context,
LLPumpIO* pump);
//@}
protected:
U8* mBuffer;
S64 mBufferSize;
U8* mReadHead;
U8* mWriteHead;
};
#endif // LL_LLIOBUFFER_H
|
