Home
last modified time | relevance | path

Searched refs:ByteStream (Results 1 – 25 of 1638) sorted by relevance

12345678910>>...66

/dports/databases/mariadb105-client/mariadb-10.5.15/storage/columnstore/columnstore/utils/messageqcpp/
H A Dbytestream.h90 EXPORT ByteStream(const ByteStream& rhs);
95 EXPORT ByteStream& operator=(const ByteStream& rhs);
172 EXPORT ByteStream& operator<<(const ByteStream& bs);
242 EXPORT ByteStream& operator>>(ByteStream& bs);
381 inline ByteStream& operator+=(const ByteStream& rhs);
464 inline ByteStream::~ByteStream() in ~ByteStream()
526 inline ByteStream& ByteStream::operator+=(const ByteStream& rhs)
531 inline ByteStream operator+(const ByteStream& lhs, const ByteStream& rhs)
536 inline ByteStream& ByteStream::operator>>(Serializeable& s)
541 inline ByteStream& ByteStream::operator<<(const Serializeable& s)
[all …]
H A Dbytestream.cpp47 void ByteStream::doCopy(const ByteStream& rhs) in doCopy()
63 ByteStream::ByteStream(const ByteStream& rhs) : in ByteStream() function in messageqcpp::ByteStream
71 ByteStream::ByteStream(const SBS& rhs) : in ByteStream() function in messageqcpp::ByteStream
78 ByteStream& ByteStream::operator=(const ByteStream& rhs) in operator =()
95 ByteStream::ByteStream(uint32_t initSize) : in ByteStream() function in messageqcpp::ByteStream
266 ByteStream& ByteStream::operator>>(int8_t& b) in operator >>()
479 void ByteStream::swap(ByteStream& rhs) in swap()
564 ByteStream& ByteStream::operator<<(const ByteStream& bs) in operator <<()
575 ByteStream& ByteStream::operator>>(ByteStream& bs) in operator >>()
582 void ByteStream::peek(ByteStream& bs) const in peek()
[all …]
/dports/databases/mariadb105-server/mariadb-10.5.15/storage/columnstore/columnstore/utils/messageqcpp/
H A Dbytestream.h90 EXPORT ByteStream(const ByteStream& rhs);
95 EXPORT ByteStream& operator=(const ByteStream& rhs);
172 EXPORT ByteStream& operator<<(const ByteStream& bs);
242 EXPORT ByteStream& operator>>(ByteStream& bs);
381 inline ByteStream& operator+=(const ByteStream& rhs);
464 inline ByteStream::~ByteStream() in ~ByteStream()
526 inline ByteStream& ByteStream::operator+=(const ByteStream& rhs)
531 inline ByteStream operator+(const ByteStream& lhs, const ByteStream& rhs)
536 inline ByteStream& ByteStream::operator>>(Serializeable& s)
541 inline ByteStream& ByteStream::operator<<(const Serializeable& s)
[all …]
H A Dbytestream.cpp47 void ByteStream::doCopy(const ByteStream& rhs) in doCopy()
63 ByteStream::ByteStream(const ByteStream& rhs) : in ByteStream() function in messageqcpp::ByteStream
71 ByteStream::ByteStream(const SBS& rhs) : in ByteStream() function in messageqcpp::ByteStream
78 ByteStream& ByteStream::operator=(const ByteStream& rhs) in operator =()
95 ByteStream::ByteStream(uint32_t initSize) : in ByteStream() function in messageqcpp::ByteStream
266 ByteStream& ByteStream::operator>>(int8_t& b) in operator >>()
479 void ByteStream::swap(ByteStream& rhs) in swap()
564 ByteStream& ByteStream::operator<<(const ByteStream& bs) in operator <<()
575 ByteStream& ByteStream::operator>>(ByteStream& bs) in operator >>()
582 void ByteStream::peek(ByteStream& bs) const in peek()
[all …]
/dports/databases/mariadb105-client/mariadb-10.5.15/storage/columnstore/columnstore/versioning/BRM/
H A Dslavecomm.h78 void processCommand(messageqcpp::ByteStream& msg);
88 void do_deleteOID(messageqcpp::ByteStream& msg);
89 void do_deleteOIDs(messageqcpp::ByteStream& msg);
90 void do_setLocalHWM(messageqcpp::ByteStream& msg);
91 void do_bulkSetHWM(messageqcpp::ByteStream& msg);
95 void do_beginVBCopy(messageqcpp::ByteStream& msg);
96 void do_endVBCopy(messageqcpp::ByteStream& msg);
97 void do_vbRollback1(messageqcpp::ByteStream& msg);
99 void do_vbCommit(messageqcpp::ByteStream& msg);
118 void do_ownerCheck(messageqcpp::ByteStream& msg);
[all …]
H A Dmasterdbrmnode.h177 void distribute(messageqcpp::ByteStream* msg);
197 void doVerID(messageqcpp::ByteStream& msg, ThreadParams* p);
200 void doNewTxnID(messageqcpp::ByteStream& msg, ThreadParams* p);
201 void doCommitted(messageqcpp::ByteStream& msg, ThreadParams* p);
202 void doRolledBack(messageqcpp::ByteStream& msg, ThreadParams* p);
203 void doGetTxnID(messageqcpp::ByteStream& msg, ThreadParams* p);
204 void doSIDTIDMap(messageqcpp::ByteStream& msg, ThreadParams* p);
218 void doAllocOIDs(messageqcpp::ByteStream& msg, ThreadParams* p);
219 void doReturnOIDs(messageqcpp::ByteStream& msg, ThreadParams* p);
220 void doOidmSize(messageqcpp::ByteStream& msg, ThreadParams* p);
[all …]
/dports/databases/mariadb105-server/mariadb-10.5.15/storage/columnstore/columnstore/versioning/BRM/
H A Dslavecomm.h78 void processCommand(messageqcpp::ByteStream& msg);
88 void do_deleteOID(messageqcpp::ByteStream& msg);
89 void do_deleteOIDs(messageqcpp::ByteStream& msg);
90 void do_setLocalHWM(messageqcpp::ByteStream& msg);
91 void do_bulkSetHWM(messageqcpp::ByteStream& msg);
95 void do_beginVBCopy(messageqcpp::ByteStream& msg);
96 void do_endVBCopy(messageqcpp::ByteStream& msg);
97 void do_vbRollback1(messageqcpp::ByteStream& msg);
99 void do_vbCommit(messageqcpp::ByteStream& msg);
118 void do_ownerCheck(messageqcpp::ByteStream& msg);
[all …]
H A Dmasterdbrmnode.h177 void distribute(messageqcpp::ByteStream* msg);
197 void doVerID(messageqcpp::ByteStream& msg, ThreadParams* p);
200 void doNewTxnID(messageqcpp::ByteStream& msg, ThreadParams* p);
201 void doCommitted(messageqcpp::ByteStream& msg, ThreadParams* p);
202 void doRolledBack(messageqcpp::ByteStream& msg, ThreadParams* p);
203 void doGetTxnID(messageqcpp::ByteStream& msg, ThreadParams* p);
204 void doSIDTIDMap(messageqcpp::ByteStream& msg, ThreadParams* p);
218 void doAllocOIDs(messageqcpp::ByteStream& msg, ThreadParams* p);
219 void doReturnOIDs(messageqcpp::ByteStream& msg, ThreadParams* p);
220 void doOidmSize(messageqcpp::ByteStream& msg, ThreadParams* p);
[all …]
/dports/graphics/djvulibre/djvulibre-3.5.28/libdjvu/
H A DByteStream.cpp132 class ByteStream::Stdio : public ByteStream {
190 class ByteStream::Memory : public ByteStream
270 class ByteStream::Static : public ByteStream
321 ByteStream::~ByteStream() in ~ByteStream()
486 ByteStream::copy(ByteStream &bsfrom, size_t size) in copy()
1044 GP<ByteStream>
1050 GP<ByteStream>
1365 GP<ByteStream> errout = ByteStream::get_stderr();
1383 GP<ByteStream> errout = ByteStream::get_stderr();
1401 GP<ByteStream> strout = ByteStream::get_stdout();
[all …]
H A DByteStream.h141 virtual ~ByteStream();
282 ByteStream(const ByteStream &);
283 ByteStream & operator=(const ByteStream &);
304 static GP<ByteStream> create(
313 static GP<ByteStream> create(
320 static GP<ByteStream> create(
355 ByteStream::size(void) const in size()
357 ByteStream *bs=const_cast<ByteStream *>(this); in size()
371 class DJVUAPI ByteStream::Wrapper : public ByteStream
374 GP<ByteStream> gbs;
[all …]
/dports/games/ksirk/ksirk-21.12.3/ksirk/iris/src/xmpp/cutestuff/
H A Dbytestream.cpp58 class ByteStream::Private
68 ByteStream::ByteStream(QObject *parent) in ByteStream() function in ByteStream
76 ByteStream::~ByteStream() in ~ByteStream()
83 bool ByteStream::isOpen() const in isOpen()
93 void ByteStream::close() in close()
127 int ByteStream::bytesToWrite() const in bytesToWrite()
134 void ByteStream::clearReadBuffer() in clearReadBuffer()
141 void ByteStream::clearWriteBuffer() in clearWriteBuffer()
180 QByteArray & ByteStream::readBuf() in readBuf()
187 QByteArray & ByteStream::writeBuf() in writeBuf()
[all …]
/dports/net-im/kopete/kopete-21.12.3/protocols/groupwise/libgroupwise/
H A Dbytestream.cpp59 class ByteStream::Private
71 ByteStream::ByteStream(QObject *parent) in ByteStream() function in ByteStream
80 ByteStream::~ByteStream() in ~ByteStream()
87 bool ByteStream::isOpen() const in isOpen()
97 void ByteStream::close() in close()
138 int ByteStream::bytesToWrite() const in bytesToWrite()
146 void ByteStream::clearReadBuffer() in clearReadBuffer()
153 void ByteStream::clearWriteBuffer() in clearWriteBuffer()
197 QByteArray &ByteStream::readBuf() in readBuf()
204 QByteArray &ByteStream::writeBuf() in writeBuf()
[all …]
/dports/net-im/kopete/kopete-21.12.3/protocols/jabber/libiris/src/irisnet/noncore/cutestuff/
H A Dbytestream.cpp58 class ByteStream::Private
70 ByteStream::ByteStream(QObject *parent) in ByteStream() function in ByteStream
78 ByteStream::~ByteStream() in ~ByteStream()
117 qint64 ByteStream::bytesToWrite() const in bytesToWrite()
124 void ByteStream::clearReadBuffer() in clearReadBuffer()
131 void ByteStream::clearWriteBuffer() in clearWriteBuffer()
170 QByteArray & ByteStream::readBuf() in readBuf()
177 QByteArray & ByteStream::writeBuf() in writeBuf()
185 int ByteStream::tryWrite() in tryWrite()
213 int ByteStream::errorCode() const in errorCode()
[all …]
/dports/net-im/psi/psi-1.5/iris/src/irisnet/noncore/cutestuff/
H A Dbytestream.cpp58 class ByteStream::Private
70 ByteStream::ByteStream(QObject *parent) in ByteStream() function in ByteStream
78 ByteStream::~ByteStream() in ~ByteStream()
117 qint64 ByteStream::bytesToWrite() const in bytesToWrite()
124 void ByteStream::clearReadBuffer() in clearReadBuffer()
131 void ByteStream::clearWriteBuffer() in clearWriteBuffer()
170 QByteArray & ByteStream::readBuf() in readBuf()
177 QByteArray & ByteStream::writeBuf() in writeBuf()
185 int ByteStream::tryWrite() in tryWrite()
213 int ByteStream::errorCode() const in errorCode()
[all …]
/dports/databases/mariadb105-client/mariadb-10.5.15/storage/columnstore/columnstore/dbcon/ddlpackage/
H A Dserialize.cpp39 void write_vec(vector<T*>& v, ByteStream& bs) in write_vec()
49 void read_vec(vector<T*>& v, ByteStream& bs) in read_vec()
117 messageqcpp::ByteStream::quadbyte type; in unserialize()
397 messageqcpp::ByteStream::quadbyte cascade; in unserialize()
1136 messageqcpp::ByteStream::quadbyte ftype; in unserialize()
1137 messageqcpp::ByteStream::quadbyte length; in unserialize()
1139 messageqcpp::ByteStream::quadbyte scale; in unserialize()
1143 messageqcpp::ByteStream::octbyte nextVal; in unserialize()
1580 messageqcpp::ByteStream::quadbyte size; in serialize()
1656 messageqcpp::ByteStream::quadbyte type; in unserialize()
[all …]
H A Dddlpkg.h58 typedef messageqcpp::ByteStream::byte byte;
59 typedef messageqcpp::ByteStream::doublebyte doublebyte;
60 typedef messageqcpp::ByteStream::quadbyte quadbyte;
650 virtual int serialize(messageqcpp::ByteStream& bs);
678 virtual int serialize(messageqcpp::ByteStream& bs);
730 virtual int serialize(messageqcpp::ByteStream& bs);
784 virtual int serialize(messageqcpp::ByteStream& bs);
809 virtual int serialize(messageqcpp::ByteStream& bs);
835 virtual int serialize(messageqcpp::ByteStream& bs);
863 virtual int serialize(messageqcpp::ByteStream& bs);
[all …]
/dports/databases/mariadb105-server/mariadb-10.5.15/storage/columnstore/columnstore/dbcon/ddlpackage/
H A Dserialize.cpp39 void write_vec(vector<T*>& v, ByteStream& bs) in write_vec()
49 void read_vec(vector<T*>& v, ByteStream& bs) in read_vec()
117 messageqcpp::ByteStream::quadbyte type; in unserialize()
397 messageqcpp::ByteStream::quadbyte cascade; in unserialize()
1136 messageqcpp::ByteStream::quadbyte ftype; in unserialize()
1137 messageqcpp::ByteStream::quadbyte length; in unserialize()
1139 messageqcpp::ByteStream::quadbyte scale; in unserialize()
1143 messageqcpp::ByteStream::octbyte nextVal; in unserialize()
1580 messageqcpp::ByteStream::quadbyte size; in serialize()
1656 messageqcpp::ByteStream::quadbyte type; in unserialize()
[all …]
H A Dddlpkg.h58 typedef messageqcpp::ByteStream::byte byte;
59 typedef messageqcpp::ByteStream::doublebyte doublebyte;
60 typedef messageqcpp::ByteStream::quadbyte quadbyte;
650 virtual int serialize(messageqcpp::ByteStream& bs);
678 virtual int serialize(messageqcpp::ByteStream& bs);
730 virtual int serialize(messageqcpp::ByteStream& bs);
784 virtual int serialize(messageqcpp::ByteStream& bs);
809 virtual int serialize(messageqcpp::ByteStream& bs);
835 virtual int serialize(messageqcpp::ByteStream& bs);
863 virtual int serialize(messageqcpp::ByteStream& bs);
[all …]
/dports/databases/mariadb105-client/mariadb-10.5.15/storage/columnstore/columnstore/writeengine/server/
H A Dwe_ddlcommandproc.h58 EXPORT uint8_t writeSystable(messageqcpp::ByteStream& bs, std::string& err);
59 EXPORT uint8_t writeSyscolumn(messageqcpp::ByteStream& bs, std::string& err);
62 EXPORT uint8_t commitVersion(messageqcpp::ByteStream& bs, std::string& err);
63 EXPORT uint8_t rollbackBlocks(messageqcpp::ByteStream& bs, std::string& err);
64 EXPORT uint8_t rollbackVersion(messageqcpp::ByteStream& bs, std::string& err);
65 EXPORT uint8_t deleteSyscolumn(messageqcpp::ByteStream& bs, std::string& err);
67 EXPORT uint8_t deleteSystable(messageqcpp::ByteStream& bs, std::string& err);
69 EXPORT uint8_t dropFiles(messageqcpp::ByteStream& bs, std::string& err);
77 EXPORT uint8_t fillNewColumn(messageqcpp::ByteStream& bs, std::string& err);
84 EXPORT uint8_t deleteDDLLog(messageqcpp::ByteStream& bs, std::string& err);
[all …]
H A Dwe_dmlcommandproc.h78 EXPORT uint8_t commitVersion(messageqcpp::ByteStream& bs, std::string& err);
79 EXPORT uint8_t rollbackBlocks(messageqcpp::ByteStream& bs, std::string& err);
81 …EXPORT uint8_t processBatchInsert(messageqcpp::ByteStream& bs, std::string& err, ByteStream::quadb…
82 …EXPORT uint8_t processBatchInsertBinary(messageqcpp::ByteStream& bs, std::string& err, ByteStream:…
88 …EXPORT uint8_t processUpdate(messageqcpp::ByteStream& bs, std::string& err, ByteStream::quadbyte& …
91 …EXPORT uint8_t processDelete(messageqcpp::ByteStream& bs, std::string& err, ByteStream::quadbyte& …
95 EXPORT uint8_t updateSyscolumnNextval(ByteStream& bs, std::string& err);
96 EXPORT uint8_t processPurgeFDCache(ByteStream& bs, std::string& err);
97 EXPORT uint8_t processEndTransaction(ByteStream& bs, std::string& err);
98 EXPORT uint8_t processFixRows(ByteStream& bs, std::string& err, ByteStream::quadbyte& PMId);
[all …]
H A Dwe_dataloader.h71 void onReceiveKeepAlive(ByteStream& Ibs);
72 void onReceiveData(ByteStream& Ibs);
74 void onReceiveMode(ByteStream& Ibs);
77 void onReceiveAck(ByteStream& Ibs);
78 void onReceiveNak(ByteStream& Ibs);
79 void onReceiveError(ByteStream& Ibs);
81 void onReceiveJobId(ByteStream& Ibs);
82 void onReceiveJobData(ByteStream& Ibs);
84 void onReceiveCmdLineArgs(ByteStream& Ibs);
87 void onReceiveCleanup(ByteStream& Ibs);
[all …]
/dports/databases/mariadb105-server/mariadb-10.5.15/storage/columnstore/columnstore/writeengine/server/
H A Dwe_ddlcommandproc.h58 EXPORT uint8_t writeSystable(messageqcpp::ByteStream& bs, std::string& err);
59 EXPORT uint8_t writeSyscolumn(messageqcpp::ByteStream& bs, std::string& err);
62 EXPORT uint8_t commitVersion(messageqcpp::ByteStream& bs, std::string& err);
63 EXPORT uint8_t rollbackBlocks(messageqcpp::ByteStream& bs, std::string& err);
64 EXPORT uint8_t rollbackVersion(messageqcpp::ByteStream& bs, std::string& err);
65 EXPORT uint8_t deleteSyscolumn(messageqcpp::ByteStream& bs, std::string& err);
67 EXPORT uint8_t deleteSystable(messageqcpp::ByteStream& bs, std::string& err);
69 EXPORT uint8_t dropFiles(messageqcpp::ByteStream& bs, std::string& err);
77 EXPORT uint8_t fillNewColumn(messageqcpp::ByteStream& bs, std::string& err);
84 EXPORT uint8_t deleteDDLLog(messageqcpp::ByteStream& bs, std::string& err);
[all …]
H A Dwe_dmlcommandproc.h78 EXPORT uint8_t commitVersion(messageqcpp::ByteStream& bs, std::string& err);
79 EXPORT uint8_t rollbackBlocks(messageqcpp::ByteStream& bs, std::string& err);
81 …EXPORT uint8_t processBatchInsert(messageqcpp::ByteStream& bs, std::string& err, ByteStream::quadb…
82 …EXPORT uint8_t processBatchInsertBinary(messageqcpp::ByteStream& bs, std::string& err, ByteStream:…
88 …EXPORT uint8_t processUpdate(messageqcpp::ByteStream& bs, std::string& err, ByteStream::quadbyte& …
91 …EXPORT uint8_t processDelete(messageqcpp::ByteStream& bs, std::string& err, ByteStream::quadbyte& …
95 EXPORT uint8_t updateSyscolumnNextval(ByteStream& bs, std::string& err);
96 EXPORT uint8_t processPurgeFDCache(ByteStream& bs, std::string& err);
97 EXPORT uint8_t processEndTransaction(ByteStream& bs, std::string& err);
98 EXPORT uint8_t processFixRows(ByteStream& bs, std::string& err, ByteStream::quadbyte& PMId);
[all …]
H A Dwe_dataloader.h71 void onReceiveKeepAlive(ByteStream& Ibs);
72 void onReceiveData(ByteStream& Ibs);
74 void onReceiveMode(ByteStream& Ibs);
77 void onReceiveAck(ByteStream& Ibs);
78 void onReceiveNak(ByteStream& Ibs);
79 void onReceiveError(ByteStream& Ibs);
81 void onReceiveJobId(ByteStream& Ibs);
82 void onReceiveJobData(ByteStream& Ibs);
84 void onReceiveCmdLineArgs(ByteStream& Ibs);
87 void onReceiveCleanup(ByteStream& Ibs);
[all …]
/dports/graphics/rawstudio/rawstudio-2.0/plugins/load-rawspeed/rawspeed/
H A DByteStream.cpp27 ByteStream::ByteStream(const uchar8* _buffer, uint32 _size) : in ByteStream() function in RawSpeed::ByteStream
32 ByteStream::ByteStream(const ByteStream *b) : in ByteStream() function in RawSpeed::ByteStream
37 ByteStream::~ByteStream(void) { in ~ByteStream()
41 uint32 ByteStream::peekByte() { in peekByte()
45 void ByteStream::skipBytes(uint32 nbytes) { in skipBytes()
51 uchar8 ByteStream::getByte() { in getByte()
57 ushort16 ByteStream::getShort() { in getShort()
67 int ByteStream::getInt() { in getInt()
73 void ByteStream::setAbsoluteOffset(uint32 offset) { in setAbsoluteOffset()
79 void ByteStream::skipToMarker() { in skipToMarker()

12345678910>>...66