d0kuhn/mosquitto
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Only process network errors for clients that have nothing to read.

Browse Source 
Closes #7.
This commit is contained in:
Roger A. Light 2018-11-04 22:26:59 +00:00
parent c26892244c
commit eff8fab1b4
2 changed files with 12 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
ChangeLog.txt
View File

@ -1,6 +1,12 @@
1.5.4 - 201810xx 1.5.4 - 201810xx
================ ================
Broker:
- Process all pending messages even when a client has disconnected. This means
a client that send a PUBLISH then DISCONNECT quickly, then disconnects will
have its DISCONNECT message processed properly and so no Will will be sent.
Closes #7.
Library: Library:
- Fix memory leak that occurred if mosquitto_reconnect() was used when TLS - Fix memory leak that occurred if mosquitto_reconnect() was used when TLS
errors were present. Closes #592. errors were present. Closes #592.

11
src/loop.c
View File

@ -813,14 +813,15 @@ static void loop_handle_reads_writes(struct mosquitto_db *db, struct pollfd *pol
continue; continue;
} }
}while(SSL_DATA_PENDING(context)); }while(SSL_DATA_PENDING(context));
} }else{
#ifdef WITH_EPOLL #ifdef WITH_EPOLL
if(events & (EPOLLERR | EPOLLHUP)){ if(events & (EPOLLERR | EPOLLHUP)){
#else #else
if(context->pollfd_index >= 0 && pollfds[context->pollfd_index].revents & (POLLERR | POLLNVAL | POLLHUP)){ if(context->pollfd_index >= 0 && pollfds[context->pollfd_index].revents & (POLLERR | POLLNVAL | POLLHUP)){
#endif #endif
do_disconnect(db, context); do_disconnect(db, context);
continue; continue;
}
} }
} }
} }