mqtts_mock_server.cc

Go to the documentation of this file.

/*
 * Copyright (C) Max Dymond, <cmeister2@gmail.com>, et al.
 *
 * SPDX-License-Identifier: curl
 */

 
#include "proto_fuzzer/mqtts_mock_server.h"
 
#include <cstddef>
#include <memory>
#include <string>
 
#include "proto_fuzzer/mock_server.h"
 
namespace proto_fuzzer {

MqttsMockServer::MqttsMockServer() : transport_(TlsApplicationProtocol::kHttp11) {}

MqttsMockServer::~MqttsMockServer() { connection_.reset(); }

void MqttsMockServer::Install(CURL* easy) {
  MqttMockServer::Install(easy);
  transport_.Install(easy);
}

std::unique_ptr<MockConnection> MqttsMockServer::CreateConnection() { return transport_.CreateConnection(); }

int MqttsMockServer::negotiated_tls_version() const { return transport_.negotiated_tls_version(); }

std::size_t MqttsMockServer::completed_handshake_count() const { return transport_.completed_handshake_count(); }

std::string MqttsMockServer::negotiated_alpn() const { return transport_.negotiated_alpn(); }

void MqttsMockServer::ObserveState() {
#if defined(PROTO_FUZZER_OBSERVE_STATE)
  MqttMockServer::ObserveState();
  const volatile std::size_t mqtts_observation[] = {completed_handshake_count(),
                                                    static_cast<std::size_t>(negotiated_tls_version()),
                                                    negotiated_alpn().size(), packet_count()};
  (void)mqtts_observation;
#endif
}
 
}  // namespace proto_fuzzer