/dports/databases/mariadb105-client/mariadb-10.5.15/storage/columnstore/columnstore/utils/messageqcpp/ |
H A D | bytestream.h | 90 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 D | bytestream.cpp | 47 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 D | bytestream.h | 90 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 D | bytestream.cpp | 47 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 D | slavecomm.h | 78 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 D | masterdbrmnode.h | 177 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 D | slavecomm.h | 78 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 D | masterdbrmnode.h | 177 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 D | ByteStream.cpp | 132 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 D | ByteStream.h | 141 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 D | bytestream.cpp | 58 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 D | bytestream.cpp | 59 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 D | bytestream.cpp | 58 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 D | bytestream.cpp | 58 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 D | serialize.cpp | 39 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 D | ddlpkg.h | 58 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 D | serialize.cpp | 39 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 D | ddlpkg.h | 58 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 D | we_ddlcommandproc.h | 58 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 D | we_dmlcommandproc.h | 78 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 D | we_dataloader.h | 71 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 D | we_ddlcommandproc.h | 58 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 D | we_dmlcommandproc.h | 78 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 D | we_dataloader.h | 71 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 D | ByteStream.cpp | 27 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()
|