Peter M. Groen / FlashMQ

MQTT-3.8.3-3

MQTT-3.6.1-1

[MQTT-2.3.1-1]

I have no explanation for it, but it happens (with QMQTT, should it
matter).

There were bugs in which authentication object was used when, causing
threadings bugs. Instead of getting from the 'sender', we can just store
a thread local pointer.

Files are simple serialized bytes prefaced by lengths. File is hashed to
verify integrity. This was also a good way preventing unexpected errors
when trying to crash the parser by having it load a different file.

This change includes some refactoring that was necessary:

- It 'fixes' looking at the wrong thread's authentiction. This is still
  wrong though. It will be fixed by a thread local pointer in the next
  commit.
- Deadlocks with yourself are handled in rwlockguard.
- QoSPacketQueue is now a class.
- Probably other tweaks.

This performs a whole lot better.

Also include a few stats.

Shifting signed integers is undefined and only sometimes produced
unexpected results.

Was detected in packet identifiers in QoS testing.

Instead of getting it from the sender of a packet. Sometimes there was
no sender.

This fixes a crash on retained messages, because those newly created
packets didn't have a sender to get the threaddata from. So, using a
special object for it is easier and more robust.

Encrypted version only.

Profiling showed it was significant enough to do so.

My IDE didn't understand them for finding symbols, apparently.

Fix websocket crash case

Fix infinite loop on lying about websocket frame sizes

This fixes infinite loops when you send a frame type that is not handled.

And check Qos.

When sending many 0xFF, it would overflow.

Found by using afl-fuzz.

This allows creation of multiple listeners, with different protocols
and/or SSL certificates.

Related change: settings is now a class that is copyable and assignable,
and is done so to each thread on reload.

Semi-related fix: fix crash in quit when multiple threads initiated it.
This came to light when testing the auth plugin settings.

And fixed an assert in CirBuf.read().