diff options
author | Thorvald Natvig <slicer@users.sourceforge.net> | 2007-06-29 19:30:55 +0400 |
---|---|---|
committer | Thorvald Natvig <slicer@users.sourceforge.net> | 2007-06-29 19:30:55 +0400 |
commit | e7b260e7efccfc92dc199bdc18de467143a91136 (patch) | |
tree | f427245c60ade0ec6e39a9574900b42aac8fe06c | |
parent | e19057f5204f2ca6c5a13aa9663110b3dedc963e (diff) |
Updates for new binary protocol.
git-svn-id: https://mumble.svn.sourceforge.net/svnroot/mumble/trunk@508 05730e5d-ab1b-0410-a4ac-84af385074fa
-rw-r--r-- | src/Connection.cpp | 2 | ||||
-rw-r--r-- | src/Message.cpp | 7 | ||||
-rw-r--r-- | src/PacketDataStream.h | 63 | ||||
-rw-r--r-- | src/mumble/ServerHandler.cpp | 2 | ||||
-rw-r--r-- | src/murmur/murmur.cpp | 2 |
5 files changed, 39 insertions, 37 deletions
diff --git a/src/Connection.cpp b/src/Connection.cpp index 080b26c32..be86fd794 100644 --- a/src/Connection.cpp +++ b/src/Connection.cpp @@ -102,8 +102,8 @@ void Connection::socketDisconnected() { void Connection::sendMessage(const Message *mMsg) { QByteArray qbaBuffer; - mMsg->messageToNetwork(qbaBuffer); + sendMessage(qbaBuffer); } diff --git a/src/Message.cpp b/src/Message.cpp index a762a73c7..c10008ddf 100644 --- a/src/Message.cpp +++ b/src/Message.cpp @@ -43,7 +43,8 @@ void Message::messageToNetwork(QByteArray &qbaOut) const { PacketDataStream qdsOut(qbaOut.data(), qbaOut.capacity()); qdsOut << messageType(); qdsOut << sPlayerId; - + saveStream(qdsOut); + qbaOut = QByteArray(qbaOut.constData(), qdsOut.size()); } @@ -261,9 +262,7 @@ void MessageSpeex::saveStream(PacketDataStream &qdsOut) const { } void MessageSpeex::restoreStream(PacketDataStream &qdsIn) { - unsigned short useq; - qdsIn >> useq; - iSeq = useq; + qdsIn >> iSeq; qdsIn >> ucFlags; qbaSpeexPacket = qdsIn.dataBlock(qdsIn.left()); } diff --git a/src/PacketDataStream.h b/src/PacketDataStream.h index 9260df416..ec631ee23 100644 --- a/src/PacketDataStream.h +++ b/src/PacketDataStream.h @@ -46,7 +46,7 @@ class PacketDataStream { quint32 size() const { return offset; } - + bool isValid() const { return ok; } @@ -56,12 +56,12 @@ class PacketDataStream { } void append(const quint32 v) { - if (offset < maxsize) + if (offset < maxsize) data[offset++] = v; else ok = false; }; - + void append(const char *d, quint32 len) { if (left() >= len) { memcpy(& data[offset], d, len); @@ -70,7 +70,7 @@ class PacketDataStream { ok = false; } } - + quint32 next() { if (offset < maxsize) return data[offset++]; @@ -79,7 +79,7 @@ class PacketDataStream { return 0; } }; - + const unsigned char *dataPtr() const { return reinterpret_cast<const unsigned char *>(& data[offset]); } @@ -87,7 +87,7 @@ class PacketDataStream { const char *charPtr() const { return reinterpret_cast<const char *>(& data[offset]); } - + QByteArray dataBlock(quint32 len) { if (len <= left()) { QByteArray a(charPtr(), len); @@ -98,7 +98,7 @@ class PacketDataStream { return QByteArray(); } } - + protected: void setup(unsigned char *d, int msize) { data = d; @@ -118,7 +118,7 @@ class PacketDataStream { PacketDataStream(unsigned char *d, int msize) { setup(d, msize); }; - + PacketDataStream &operator <<(const quint32 i) { if (i < 0x80) { append(i); @@ -151,13 +151,12 @@ class PacketDataStream { } else if ((v & 0xF0) == 0xE0) { i=(v & 0x0F) << 24 | next() << 16 | next() << 8 | next(); } else if ((v & 0xE0) == 0xC0) { - i=(v & 0x1F) << 16 | next() << 8 | next(); + i=(v & 0x1F) << 16 | next() << 8 | next(); } else if ((v & 0xC0) == 0x80) { i=(v & 0x3F) << 8 | next(); } else { i=(v & 0x7F); } - qWarning("Val %x %x", v, i); return *this; } @@ -166,11 +165,11 @@ class PacketDataStream { append(a.constData(), a.size()); return *this; } - + PacketDataStream &operator >>(QByteArray &a) { quint32 len; *this >> len; - if (len < left()) { + if (len > left()) { len = left(); ok = false; } @@ -178,16 +177,16 @@ class PacketDataStream { offset+=len; return *this; } - + PacketDataStream &operator <<(const QString &s) { return *this << s.toUtf8(); } - + // Using the data directly instead of through qbuff avoids a copy. PacketDataStream &operator >>(QString &s) { quint32 len; *this >> len; - if (len < left()) { + if (len > left()) { len = left(); ok = false; } @@ -200,7 +199,7 @@ class PacketDataStream { quint32 v = b ? 1 : 0; return *this << v; } - + PacketDataStream &operator >>(bool &b) { quint32 v; *this >> v; @@ -219,7 +218,7 @@ class PacketDataStream { return *this; \ } - + INTMAPOPERATOR(int); // Oh, how horribly this bugs // INTMAPOPERATOR(unsigned int); @@ -228,7 +227,7 @@ class PacketDataStream { INTMAPOPERATOR(unsigned short); INTMAPOPERATOR(char); INTMAPOPERATOR(unsigned char); - + template <typename T> PacketDataStream &operator <<(const QList<T> &l) { *this << l.size(); @@ -236,28 +235,29 @@ class PacketDataStream { *this << l.at(i); return *this; } - + template <typename T> PacketDataStream &operator >>(QList<T> &l) { l.clear(); quint32 len; *this >> len; - if (len < left()) { + if (len > left()) { len = left(); ok = false; } for(quint32 i=0;i<len;i++) { - T t; - *this >> t; - l.append(t); if (left() == 0) { ok = false; break; } + + T t; + *this >> t; + l.append(t); } return *this; } - + template <typename T> PacketDataStream &operator <<(const QSet<T> &s) { @@ -266,24 +266,25 @@ class PacketDataStream { *this << *i; return *this; } - + template <typename T> PacketDataStream &operator >>(QSet<T> &s) { s.clear(); quint32 len; *this >> len; - if (len < left()) { + if (len > left()) { len = left(); ok = false; } for(quint32 i=0;i<len;i++) { - T t; - *this >> t; - s.insert(t); if (left() == 0) { ok = false; break; } + + T t; + *this >> t; + s.insert(t); } return *this; } @@ -292,12 +293,12 @@ class PacketDataStream { PacketDataStream &operator <<(const QPair<T,U> &p) { return *this << p.first << p.second; } - + template <typename T,typename U> PacketDataStream &operator >>(QPair<T,U> &p) { return *this >> p.first >> p.second; } - + }; #else diff --git a/src/mumble/ServerHandler.cpp b/src/mumble/ServerHandler.cpp index ae08e1af5..a0b5f8cf6 100644 --- a/src/mumble/ServerHandler.cpp +++ b/src/mumble/ServerHandler.cpp @@ -117,7 +117,6 @@ void ServerHandler::sendMessage(Message *mMsg, bool forceTCP) QByteArray qbaBuffer; mMsg->sPlayerId = g.sId; mMsg->messageToNetwork(qbaBuffer); - bool mayUdp = !forceTCP && g.sId && ((mMsg->messageType() == Message::Speex) || (mMsg->messageType() == Message::MultiSpeex) || (mMsg->messageType() == Message::Ping)); ServerHandlerMessageEvent *shme=new ServerHandlerMessageEvent(qbaBuffer, mayUdp); @@ -231,6 +230,7 @@ void ServerHandler::serverConnectionConnected() { msaMsg.iMaxBandwidth = ai->getMaxBandwidth(); else msaMsg.iMaxBandwidth = 0; + cConnection->sendMessage(&msaMsg); emit connected(); } diff --git a/src/murmur/murmur.cpp b/src/murmur/murmur.cpp index 82c3867e9..7f2cffd40 100644 --- a/src/murmur/murmur.cpp +++ b/src/murmur/murmur.cpp @@ -108,7 +108,9 @@ int main(int argc, char **argv) bool detach = true; +#ifdef Q_NO_DEBUG qInstallMsgHandler(murmurMessageOutput); +#endif for(int i=1;i<argc;i++) { QString arg = QString(argv[i]).toLower(); |