diff options
Diffstat (limited to 'libs/libmosquitto/src/send_unsubscribe.c')
| -rw-r--r-- | libs/libmosquitto/src/send_unsubscribe.c | 99 |
1 files changed, 0 insertions, 99 deletions
diff --git a/libs/libmosquitto/src/send_unsubscribe.c b/libs/libmosquitto/src/send_unsubscribe.c deleted file mode 100644 index e7317151a5..0000000000 --- a/libs/libmosquitto/src/send_unsubscribe.c +++ /dev/null @@ -1,99 +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 <string.h> - -#ifdef WITH_BROKER -# include "mosquitto_broker_internal.h" -#endif - -#include "mosquitto.h" -#include "logging_mosq.h" -#include "memory_mosq.h" -#include "mqtt_protocol.h" -#include "packet_mosq.h" -#include "property_mosq.h" -#include "send_mosq.h" -#include "util_mosq.h" - - -int send__unsubscribe(struct mosquitto *mosq, int *mid, int topic_count, char *const *const topic, const mosquitto_property *properties) -{ - /* FIXME - only deals with a single topic */ - struct mosquitto__packet *packet = NULL; - uint32_t packetlen; - uint16_t local_mid; - int rc; - int proplen, varbytes; - int i; - - assert(mosq); - assert(topic); - - packet = mosquitto__calloc(1, sizeof(struct mosquitto__packet)); - if(!packet) return MOSQ_ERR_NOMEM; - - packetlen = 2; - - for(i=0; i<topic_count; i++){ - packetlen += 2+strlen(topic[i]); - } - if(mosq->protocol == mosq_p_mqtt5){ - proplen = property__get_length_all(properties); - varbytes = packet__varint_bytes(proplen); - packetlen += proplen + varbytes; - } - - packet->command = CMD_UNSUBSCRIBE | (1<<1); - packet->remaining_length = packetlen; - rc = packet__alloc(packet); - if(rc){ - mosquitto__free(packet); - return rc; - } - - /* Variable header */ - local_mid = mosquitto__mid_generate(mosq); - if(mid) *mid = (int)local_mid; - packet__write_uint16(packet, local_mid); - - if(mosq->protocol == mosq_p_mqtt5){ - /* We don't use User Property yet. */ - property__write_all(packet, properties, true); - } - - /* Payload */ - for(i=0; i<topic_count; i++){ - packet__write_string(packet, topic[i], strlen(topic[i])); - } - -#ifdef WITH_BROKER -# ifdef WITH_BRIDGE - for(i=0; i<topic_count; i++){ - log__printf(mosq, MOSQ_LOG_DEBUG, "Bridge %s sending UNSUBSCRIBE (Mid: %d, Topic: %s)", mosq->id, local_mid, topic[i]); - } -# endif -#else - for(i=0; i<topic_count; i++){ - log__printf(mosq, MOSQ_LOG_DEBUG, "Client %s sending UNSUBSCRIBE (Mid: %d, Topic: %s)", mosq->id, local_mid, topic[i]); - } -#endif - return packet__queue(mosq, packet); -} - |