MyReposirory
Fork of MQTT by
Revision 48:c11d59168c0a, committed 2017-05-25
- Comitter:
- irayya
- Date:
- Thu May 25 05:16:45 2017 +0000
- Parent:
- 47:d3feba7f242a
- Commit message:
- gateway program
Changed in this revision
MQTTAsync.h | Show annotated file Show diff for this revision Revisions of this file |
MQTTClient.h | Show annotated file Show diff for this revision Revisions of this file |
diff -r d3feba7f242a -r c11d59168c0a MQTTAsync.h --- a/MQTTAsync.h Sat Oct 03 10:53:36 2015 +0000 +++ b/MQTTAsync.h Thu May 25 05:16:45 2017 +0000 @@ -169,7 +169,7 @@ // how many concurrent operations should we allow? Each one will require a function pointer struct Operations { - unsigned short id; + unsigne resultHandlerFP fp; const char* topic; // if this is a publish, store topic name in case republishing is required Message* message; // for publish, @@ -225,7 +225,6 @@ return sent; } - template<class Network, class Timer, class Thread, class Mutex> int MQTT::Async<Network, Timer, Thread, Mutex>::decodePacket(int* value, int timeout) { char c;
diff -r d3feba7f242a -r c11d59168c0a MQTTClient.h --- a/MQTTClient.h Sat Oct 03 10:53:36 2015 +0000 +++ b/MQTTClient.h Thu May 25 05:16:45 2017 +0000 @@ -70,7 +70,8 @@ int getNext() { - return next = (next == MAX_PACKET_ID) ? 1 : ++next; + return next = (next == MAX_PACKET_ID) ? 1 : next; + } private: