disconnect_options.h

Go to the documentation of this file.

/****************************************************************************
 * Copyright (c) 2016-2017 Frank Pagliughi <fpagliughi@mindspring.com>
 *
 * 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:
 *    Frank Pagliughi - initial implementation and documentation
 ***************************************************************************/

#ifndef __mqtt_disconnect_options_h
#define __mqtt_disconnect_options_h

#include "MQTTAsync.h"
#include "mqtt/token.h"
#include <chrono>

namespace mqtt {


class disconnect_options
{
    static const MQTTAsync_disconnectOptions DFLT_C_STRUCT;

    MQTTAsync_disconnectOptions opts_;

    token_ptr tok_;

    friend class async_client;
    friend class disconnect_options_test;

public:
    disconnect_options();
    disconnect_options(int timeout, const token_ptr& tok);
    template <class Rep, class Period>
    disconnect_options(const std::chrono::duration<Rep, Period>& to,
                       const token_ptr& tok) : disconnect_options() {
        set_timeout(to);
        set_token(tok);
    }
    disconnect_options(const disconnect_options& opt);
    disconnect_options(disconnect_options&& opt);
    disconnect_options& operator=(const disconnect_options& opt);
    disconnect_options& operator=(disconnect_options&& opt);
    std::chrono::milliseconds get_timeout() const {
        return std::chrono::milliseconds(opts_.timeout);
    }
    void set_timeout(int timeout) { opts_.timeout = timeout; }
    template <class Rep, class Period>
    void set_timeout(const std::chrono::duration<Rep, Period>& to) {
        // TODO: check range
        set_timeout((int) to_milliseconds_count(to));
    }
    void set_token(const token_ptr& tok);
    token_ptr get_token() const { return tok_; }
};

// end namespace 'mqtt'
}

#endif      // __mqtt_disconnect_options_h