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
|
/* dataprovider.cpp
Copyright (C) 2004 Klarälvdalens Datakonsult AB
This file is part of TQGPGME.
TQGPGME is free software; you can redistribute it and/or modify it
under the terms of the GNU General Public License as published by
the Free Software Foundation; either version 2 of the License, or
(at your option) any later version.
TQGPGME is distributed in the hope that it will be useful, but
WITHOUT ANY WARRANTY; without even the implied warranty of
MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
General Public License for more details.
You should have received a copy of the GNU General Public License
along with TQGPGME; if not, write to the Free Software Foundation,
Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA. */
#include <config.h>
#include <qgpgme/dataprovider.h>
#include <string.h>
#include <errno.h>
#include <assert.h>
#include <unistd.h>
static bool resizeAndInit( TQByteArray & ba, size_t newSize ) {
const size_t oldSize = ba.size();
bool ok = ba.resize( newSize );
if ( ok )
memset( ba.data() + oldSize, 0, newSize - oldSize );
return ok;
}
QGpgME::TQByteArrayDataProvider::TQByteArrayDataProvider()
: GpgME::DataProvider(), mOff( 0 ) {}
QGpgME::TQByteArrayDataProvider::TQByteArrayDataProvider( const TQByteArray & initialData )
: GpgME::DataProvider(), mArray( initialData ), mOff( 0 ) {}
QGpgME::TQByteArrayDataProvider::~TQByteArrayDataProvider() {}
ssize_t QGpgME::TQByteArrayDataProvider::read( void * buffer, size_t bufSize ) {
#ifndef NDEBUG
//tqDebug( "QGpgME::TQByteArrayDataProvider::read( %p, %d )", buffer, bufSize );
#endif
if ( bufSize == 0 )
return 0;
if ( mOff >= mArray.size() )
return 0; // EOF
size_t amount = TQMIN( bufSize, mArray.size() - mOff );
assert( amount > 0 );
memcpy( buffer, mArray.data() + mOff, amount );
mOff += amount;
return amount;
}
ssize_t QGpgME::TQByteArrayDataProvider::write( const void * buffer, size_t bufSize ) {
#ifndef NDEBUG
tqDebug( "QGpgME::TQByteArrayDataProvider::write( %p, %d )", buffer, bufSize );
#endif
if ( bufSize == 0 )
return 0;
if ( mOff >= mArray.size() )
resizeAndInit( mArray, mOff + bufSize );
if ( mOff >= mArray.size() ) {
errno = EIO;
return -1;
}
assert( bufSize <= mArray.size() - mOff );
memcpy( mArray.data() + mOff, buffer, bufSize );
mOff += bufSize;
return bufSize;
}
off_t QGpgME::TQByteArrayDataProvider::seek( off_t offset, int whence ) {
#ifndef NDEBUG
tqDebug( "QGpgME::TQByteArrayDataProvider::seek( %d, %d )", int(offset), whence );
#endif
int newOffset = mOff;
switch ( whence ) {
case SEEK_SET:
newOffset = offset;
break;
case SEEK_CUR:
newOffset += offset;
break;
case SEEK_END:
newOffset = mArray.size() + offset;
break;
default:
errno = EINVAL;
return (off_t)-1;
}
return mOff = newOffset;
}
void QGpgME::TQByteArrayDataProvider::release() {
#ifndef NDEBUG
tqDebug( "QGpgME::TQByteArrayDataProvider::release()" );
#endif
mArray = TQByteArray();
}
|
