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
|
/*
*
* Copyright (C) 2002-2010, OFFIS e.V.
* All rights reserved. See COPYRIGHT file for details.
*
* This software and supporting documentation were developed by
*
* OFFIS e.V.
* R&D Division Health
* Escherweg 2
* D-26121 Oldenburg, Germany
*
*
* Module: dcmdata
*
* Author: Marco Eichelberg
*
* Purpose: DcmOutputBufferStream and related classes,
* implements output to blocks of memory as needed in the dcmnet module.
*
* Last Update: $Author: joergr $
* Update Date: $Date: 2010-10-14 13:14:08 $
* CVS/RCS Revision: $Revision: 1.10 $
* Status: $State: Exp $
*
* CVS/RCS Log at end of file
*
*/
#include "dcmtk/config/osconfig.h"
#include "dcmtk/dcmdata/dcostrmb.h"
#include "dcmtk/dcmdata/dcerror.h"
DcmBufferConsumer::DcmBufferConsumer(void *buf, offile_off_t bufLen)
: DcmConsumer()
, buffer_(OFstatic_cast(unsigned char *, buf))
, bufSize_(bufLen)
, filled_(0)
, status_(EC_Normal)
{
if ((buffer_ == NULL) || (bufSize_ == 0)) status_ = EC_IllegalCall;
}
DcmBufferConsumer::~DcmBufferConsumer()
{
}
OFBool DcmBufferConsumer::good() const
{
return status_.good();
}
OFCondition DcmBufferConsumer::status() const
{
return status_;
}
OFBool DcmBufferConsumer::isFlushed() const
{
return (filled_ == 0);
}
offile_off_t DcmBufferConsumer::avail() const
{
return bufSize_ - filled_;
}
offile_off_t DcmBufferConsumer::write(const void *buf, offile_off_t buflen)
{
offile_off_t result = 0;
if (status_.good() && buf && buflen)
{
result = bufSize_ - filled_;
if (result > buflen) result = buflen;
memcpy(buffer_+ filled_, buf, OFstatic_cast(size_t, result));
filled_ += result;
}
return result;
}
void DcmBufferConsumer::flush()
{
// nothing to flush
}
void DcmBufferConsumer::flushBuffer(void *& buffer, offile_off_t& length)
{
buffer = buffer_;
length = filled_;
filled_ = 0;
}
/* ======================================================================= */
DcmOutputBufferStream::DcmOutputBufferStream(void *buf, offile_off_t bufLen)
: DcmOutputStream(&consumer_) // safe because DcmOutputStream only stores pointer
, consumer_(buf, bufLen)
{
}
DcmOutputBufferStream::~DcmOutputBufferStream()
{
#ifdef DEBUG
if (! isFlushed())
{
DCMDATA_WARN("DcmOutputBufferStream: Closing unflushed DcmOutputBufferStream, loss of data!");
}
#endif
}
void DcmOutputBufferStream::flushBuffer(void *& buffer, offile_off_t& length)
{
consumer_.flushBuffer(buffer, length);
}
/*
* CVS/RCS Log:
* $Log: dcostrmb.cc,v $
* Revision 1.10 2010-10-14 13:14:08 joergr
* Updated copyright header. Added reference to COPYRIGHT file.
*
* Revision 1.9 2010-02-22 11:39:54 uli
* Remove some unneeded includes.
*
* Revision 1.8 2009-12-04 17:10:00 joergr
* Slightly modified some log messages.
*
* Revision 1.7 2009-11-04 09:58:10 uli
* Switched to logging mechanism provided by the "new" oflog module
*
* Revision 1.6 2007-02-19 16:06:10 meichel
* Class DcmOutputStream and related classes are now safe for use with
* large files (2 GBytes or more) if supported by compiler and operating system.
*
* Revision 1.5 2006/08/15 15:49:54 meichel
* Updated all code in module dcmdata to correctly compile when
* all standard C++ classes remain in namespace std.
*
* Revision 1.4 2005/12/08 15:41:21 meichel
* Changed include path schema for all DCMTK header files
*
* Revision 1.3 2004/02/04 16:36:47 joergr
* Adapted type casts to new-style typecast operators defined in ofcast.h.
*
* Revision 1.2 2002/09/19 08:32:28 joergr
* Added explicit type casts to keep Sun CC 2.0.1 quiet.
*
* Revision 1.1 2002/08/27 16:55:53 meichel
* Initial release of new DICOM I/O stream classes that add support for stream
* compression (deflated little endian explicit VR transfer syntax)
*
*
*/
|
