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

Merge pull request #1430 from abiliojr/exit-on-no-subscription

Browse Source 
mosquitto_sub: Exit on all subscription denied
This commit is contained in:
Roger Light 2019-11-06 13:13:38 +00:00 committed by GitHub
commit dc21bc513c
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 12 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
client/sub_client.c
View File

@ -143,15 +143,20 @@ void my_connect_callback(struct mosquitto *mosq, void *obj, int result, int flag
void my_subscribe_callback(struct mosquitto *mosq, void *obj, int mid, int qos_count, const int *granted_qos)
{
int i;
bool some_sub_allowed = (granted_qos[0] < 128);
bool should_print = cfg.debug && !cfg.quiet;
UNUSED(obj);
if(cfg.debug){
if(!cfg.quiet) printf("Subscribed (mid: %d): %d", mid, granted_qos[0]);
if(should_print) printf("Subscribed (mid: %d): %d", mid, granted_qos[0]);
for(i=1; i<qos_count; i++){
if(!cfg.quiet) printf(", %d", granted_qos[i]);
if(should_print) printf(", %d", granted_qos[i]);
some_sub_allowed |= (granted_qos[i] < 128);
}
if(!cfg.quiet) printf("\n");
if(should_print) printf("\n");
if(some_sub_allowed == false){
mosquitto_disconnect_v5(mosq, 0, cfg.disconnect_props);
err_printf(&cfg, "Not a single subscription was granted\n");
}
if(cfg.exit_after_sub){