Delta streaming for variants.

This commit is contained in:
Andrzej Kapolka 2014-03-24 11:56:58 -07:00
parent 5b4478328c
commit 91c10a4f3a
2 changed files with 42 additions and 1 deletions

View file

@ -251,6 +251,24 @@ void Bitstream::readDelta(bool& value, bool reference) {
*this >> value; *this >> value;
} }
void Bitstream::writeDelta(const QVariant& value, const QVariant& reference) {
// QVariant only handles == for built-in types; we need to use our custom operators
const TypeStreamer* streamer = getTypeStreamers().value(value.userType());
if (value.userType() == reference.userType() && (!streamer || streamer->equal(value, reference))) {
*this << false;
return;
}
*this << true;
_typeStreamerStreamer << streamer;
streamer->writeRawDelta(*this, value, reference);
}
void Bitstream::readRawDelta(QVariant& value, const QVariant& reference) {
TypeReader typeReader;
_typeStreamerStreamer >> typeReader;
typeReader.readRawDelta(*this, value, reference);
}
void Bitstream::writeRawDelta(const QObject* value, const QObject* reference) { void Bitstream::writeRawDelta(const QObject* value, const QObject* reference) {
if (!value) { if (!value) {
_metaObjectStreamer << NULL; _metaObjectStreamer << NULL;
@ -959,8 +977,16 @@ void TypeReader::readDelta(Bitstream& in, QVariant& object, const QVariant& refe
} }
bool changed; bool changed;
in >> changed; in >> changed;
if (!changed) { if (changed) {
readRawDelta(in, object, reference);
} else {
object = reference; object = reference;
}
}
void TypeReader::readRawDelta(Bitstream& in, QVariant& object, const QVariant& reference) const {
if (_exactMatch) {
_streamer->readRawDelta(in, object, reference);
return; return;
} }
switch (_type) { switch (_type) {

View file

@ -275,9 +275,13 @@ public:
void writeDelta(bool value, bool reference); void writeDelta(bool value, bool reference);
void readDelta(bool& value, bool reference); void readDelta(bool& value, bool reference);
void writeDelta(const QVariant& value, const QVariant& reference);
template<class T> void writeDelta(const T& value, const T& reference); template<class T> void writeDelta(const T& value, const T& reference);
template<class T> void readDelta(T& value, const T& reference); template<class T> void readDelta(T& value, const T& reference);
void readRawDelta(QVariant& value, const QVariant& reference);
void writeRawDelta(const QObject* value, const QObject* reference); void writeRawDelta(const QObject* value, const QObject* reference);
void readRawDelta(QObject*& value, const QObject* reference); void readRawDelta(QObject*& value, const QObject* reference);
@ -653,6 +657,7 @@ public:
QVariant read(Bitstream& in) const; QVariant read(Bitstream& in) const;
void readDelta(Bitstream& in, QVariant& object, const QVariant& reference) const; void readDelta(Bitstream& in, QVariant& object, const QVariant& reference) const;
void readRawDelta(Bitstream& in, QVariant& object, const QVariant& reference) const;
bool matchesExactly(const TypeStreamer* streamer) const; bool matchesExactly(const TypeStreamer* streamer) const;
@ -761,12 +766,17 @@ public:
void setType(int type) { _type = type; } void setType(int type) { _type = type; }
int getType() const { return _type; } int getType() const { return _type; }
virtual bool equal(const QVariant& first, const QVariant& second) const = 0;
virtual void write(Bitstream& out, const QVariant& value) const = 0; virtual void write(Bitstream& out, const QVariant& value) const = 0;
virtual QVariant read(Bitstream& in) const = 0; virtual QVariant read(Bitstream& in) const = 0;
virtual void writeDelta(Bitstream& out, const QVariant& value, const QVariant& reference) const = 0; virtual void writeDelta(Bitstream& out, const QVariant& value, const QVariant& reference) const = 0;
virtual void readDelta(Bitstream& in, QVariant& value, const QVariant& reference) const = 0; virtual void readDelta(Bitstream& in, QVariant& value, const QVariant& reference) const = 0;
virtual void writeRawDelta(Bitstream& out, const QVariant& value, const QVariant& reference) const = 0;
virtual void readRawDelta(Bitstream& in, QVariant& value, const QVariant& reference) const = 0;
virtual const QVector<MetaField>& getMetaFields() const; virtual const QVector<MetaField>& getMetaFields() const;
virtual int getFieldIndex(const QByteArray& name) const; virtual int getFieldIndex(const QByteArray& name) const;
virtual void setField(QVariant& object, int index, const QVariant& value) const; virtual void setField(QVariant& object, int index, const QVariant& value) const;
@ -796,12 +806,17 @@ private:
template<class T> class SimpleTypeStreamer : public TypeStreamer { template<class T> class SimpleTypeStreamer : public TypeStreamer {
public: public:
virtual bool equal(const QVariant& first, const QVariant& second) const { return first.value<T>() == second.value<T>(); }
virtual void write(Bitstream& out, const QVariant& value) const { out << value.value<T>(); } virtual void write(Bitstream& out, const QVariant& value) const { out << value.value<T>(); }
virtual QVariant read(Bitstream& in) const { T value; in >> value; return QVariant::fromValue(value); } virtual QVariant read(Bitstream& in) const { T value; in >> value; return QVariant::fromValue(value); }
virtual void writeDelta(Bitstream& out, const QVariant& value, const QVariant& reference) const { virtual void writeDelta(Bitstream& out, const QVariant& value, const QVariant& reference) const {
out.writeDelta(value.value<T>(), reference.value<T>()); } out.writeDelta(value.value<T>(), reference.value<T>()); }
virtual void readDelta(Bitstream& in, QVariant& value, const QVariant& reference) const { virtual void readDelta(Bitstream& in, QVariant& value, const QVariant& reference) const {
in.readDelta(*static_cast<T*>(value.data()), reference.value<T>()); } in.readDelta(*static_cast<T*>(value.data()), reference.value<T>()); }
virtual void writeRawDelta(Bitstream& out, const QVariant& value, const QVariant& reference) const {
out.writeRawDelta(value.value<T>(), reference.value<T>()); }
virtual void readRawDelta(Bitstream& in, QVariant& value, const QVariant& reference) const {
in.readRawDelta(*static_cast<T*>(value.data()), reference.value<T>()); }
}; };
/// A streamer for types compiled by mtc. /// A streamer for types compiled by mtc.