diff options
Diffstat (limited to 'libs/libmosquitto/src/handle_connack.c')
-rw-r--r-- | libs/libmosquitto/src/handle_connack.c | 110 |
1 files changed, 0 insertions, 110 deletions
diff --git a/libs/libmosquitto/src/handle_connack.c b/libs/libmosquitto/src/handle_connack.c deleted file mode 100644 index 19b6a66160..0000000000 --- a/libs/libmosquitto/src/handle_connack.c +++ /dev/null @@ -1,110 +0,0 @@ -/* -Copyright (c) 2009-2019 Roger Light <roger@atchoo.org> - -All rights reserved. This program and the accompanying materials -are made available under the terms of the Eclipse Public License v1.0 -and Eclipse Distribution License v1.0 which accompany this distribution. - -The Eclipse Public License is available at - http://www.eclipse.org/legal/epl-v10.html -and the Eclipse Distribution License is available at - http://www.eclipse.org/org/documents/edl-v10.php. - -Contributors: - Roger Light - initial implementation and documentation. -*/ - -#include "config.h" - -#include <assert.h> - -#include "mosquitto.h" -#include "logging_mosq.h" -#include "memory_mosq.h" -#include "messages_mosq.h" -#include "mqtt_protocol.h" -#include "net_mosq.h" -#include "packet_mosq.h" -#include "property_mosq.h" -#include "read_handle.h" - -int handle__connack(struct mosquitto *mosq) -{ - uint8_t connect_flags; - uint8_t reason_code; - int rc; - mosquitto_property *properties = NULL; - char *clientid = NULL; - - assert(mosq); - rc = packet__read_byte(&mosq->in_packet, &connect_flags); - if(rc) return rc; - rc = packet__read_byte(&mosq->in_packet, &reason_code); - if(rc) return rc; - - if(mosq->protocol == mosq_p_mqtt5){ - rc = property__read_all(CMD_CONNACK, &mosq->in_packet, &properties); - if(rc) return rc; - } - - mosquitto_property_read_string(properties, MQTT_PROP_ASSIGNED_CLIENT_IDENTIFIER, &clientid, false); - if(clientid){ - if(mosq->id){ - /* We've been sent a client identifier but already have one. This - * shouldn't happen. */ - free(clientid); - mosquitto_property_free_all(&properties); - return MOSQ_ERR_PROTOCOL; - }else{ - mosq->id = clientid; - clientid = NULL; - } - } - - mosquitto_property_read_byte(properties, MQTT_PROP_MAXIMUM_QOS, &mosq->maximum_qos, false); - mosquitto_property_read_int16(properties, MQTT_PROP_RECEIVE_MAXIMUM, &mosq->msgs_out.inflight_maximum, false); - mosquitto_property_read_int16(properties, MQTT_PROP_SERVER_KEEP_ALIVE, &mosq->keepalive, false); - mosquitto_property_read_int32(properties, MQTT_PROP_MAXIMUM_PACKET_SIZE, &mosq->maximum_packet_size, false); - - mosq->msgs_out.inflight_quota = mosq->msgs_out.inflight_maximum; - - log__printf(mosq, MOSQ_LOG_DEBUG, "Client %s received CONNACK (%d)", mosq->id, reason_code); - pthread_mutex_lock(&mosq->callback_mutex); - if(mosq->on_connect){ - mosq->in_callback = true; - mosq->on_connect(mosq, mosq->userdata, reason_code); - mosq->in_callback = false; - } - if(mosq->on_connect_with_flags){ - mosq->in_callback = true; - mosq->on_connect_with_flags(mosq, mosq->userdata, reason_code, connect_flags); - mosq->in_callback = false; - } - if(mosq->on_connect_v5){ - mosq->in_callback = true; - mosq->on_connect_v5(mosq, mosq->userdata, reason_code, connect_flags, properties); - mosq->in_callback = false; - } - pthread_mutex_unlock(&mosq->callback_mutex); - mosquitto_property_free_all(&properties); - - switch(reason_code){ - case 0: - pthread_mutex_lock(&mosq->state_mutex); - if(mosq->state != mosq_cs_disconnecting){ - mosq->state = mosq_cs_connected; - } - pthread_mutex_unlock(&mosq->state_mutex); - message__retry_check(mosq); - return MOSQ_ERR_SUCCESS; - case 1: - case 2: - case 3: - case 4: - case 5: - return MOSQ_ERR_CONN_REFUSED; - default: - return MOSQ_ERR_PROTOCOL; - } -} - |