11783254300

Committed 11 Nov 2024 05:23PM UTC coverage: 45.767% (+0.09%) from 45.677%

Build # 11783254300

Build Type

push

github

Committed by

web-flow

Commit Message

Merge pull request #1978 from DMXControl/add_nodle_r4s

Add DMXControl Projects e.V. Nodle R4S

Run Details

7798 of 17938 branches covered (43.47%)

0 of 1 new or added line in 1 file covered. (0.0%)

721 existing lines in 11 files now uncovered.

22344 of 48821 relevant lines covered (45.77%)

64.39 hits per line

Source File
Press 'n' to go to next uncovered line, 'b' for previous

22.55

/common/rdm/RDMAPI.cpp

/*
 * This library is free software; you can redistribute it and/or
 * modify it under the terms of the GNU Lesser General Public
 * License as published by the Free Software Foundation; either
 * version 2.1 of the License, or (at your option) any later version.
 *
 * This library is distributed in the hope that it will be useful,
 * but WITHOUT ANY WARRANTY; without even the implied warranty of
 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
 * Lesser General Public License for more details.
 *
 * You should have received a copy of the GNU Lesser General Public
 * License along with this library; if not, write to the Free Software
 * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA
 *
 * RDMAPI.cpp
 * Provides a generic RDM API that can use different implementations.
 * Copyright (C) 2010 Simon Newton
 */

#include <stdint.h>
#include <string.h>
#include <algorithm>
#include <map>
#include <string>
#include <vector>
#include "ola/Callback.h"
#include "ola/Logging.h"
#include "ola/StringUtils.h"
#include "ola/base/Macro.h"
#include "ola/network/NetworkUtils.h"
#include "ola/rdm/RDMAPI.h"
#include "ola/rdm/RDMAPIImplInterface.h"
#include "ola/rdm/RDMEnums.h"
#include "ola/rdm/UID.h"
#include "ola/strings/Format.h"

namespace ola {
namespace rdm {

using std::map;
using std::string;
using std::vector;
using ola::SingleUseCallback1;
using ola::SingleUseCallback2;
using ola::SingleUseCallback4;
using ola::network::HostToNetwork;
using ola::network::NetworkToHost;
using ola::strings::IntToString;


/*
 * @brief Return the number of queues messages for a UID. Note that this is
 * cached on the client side so this number may not be correct.
 * @param uid the UID to fetch the outstanding message count for
 * @return the number of outstanding messages
 */
uint8_t RDMAPI::OutstandingMessagesCount(const UID &uid) {
  map<UID, uint8_t>::const_iterator iter = m_outstanding_messages.find(uid);

  if (iter == m_outstanding_messages.end())
    return 0;
  return iter->second;
}


/*
 * @brief Fetch a count of the proxied devices
 * @param universe the universe to perform the call on
 * @param uid the UID of the device to address this message to
 * @param callback the Callback to invoke when this request completes
 * @param error a pointer to a string which is set if an error occurs
 * @return false if an error occurred, true otherwise
 */
bool RDMAPI::GetProxiedDeviceCount(
    unsigned int universe,
    const UID &uid,
    SingleUseCallback3<void,
                       const ResponseStatus&,
                       uint16_t,
                       bool> *callback,
    string *error) {
  if (CheckCallback(error, callback))
    return false;
  if (CheckNotBroadcast(uid, error, callback))
    return false;

  RDMAPIImplInterface::rdm_callback *cb = NewSingleCallback(
    this,
    &RDMAPI::_HandleGetProxiedDeviceCount,
    callback);
  return CheckReturnStatus(
      m_impl->RDMGet(cb,
                     universe,
                     uid,
                     ROOT_RDM_DEVICE,
                     PID_PROXIED_DEVICE_COUNT),
      error);
}


/*
 * @brief Fetch a list of the proxied devices
 * @param universe the universe to perform the call on
 * @param uid the UID of the device to address this message to
 * @param callback the Callback to invoke when this request completes
 * @param error a pointer to a string which is set if an error occurs
 * @return false if an error occurred, true otherwise
 */
bool RDMAPI::GetProxiedDevices(
    unsigned int universe,
    const UID &uid,
    SingleUseCallback2<void,
                       const ResponseStatus&,
                       const vector<UID>&> *callback,
    string *error) {
  if (CheckCallback(error, callback))
    return false;
  if (CheckNotBroadcast(uid, error, callback))
    return false;

  RDMAPIImplInterface::rdm_callback *cb = NewSingleCallback(
    this,
    &RDMAPI::_HandleGetProxiedDevices,
    callback);
  return CheckReturnStatus(
      m_impl->RDMGet(cb,
                     universe,
                     uid,
                     ROOT_RDM_DEVICE,
                     PID_PROXIED_DEVICES),
      error);
}


/*
 * @brief Get the communication status report
 * @param universe the universe to perform the call on
 * @param uid the UID of the device to address this message to
 * @param callback the Callback to invoke when this request completes
 * @param error a pointer to a string which is set if an error occurs
 * @return false if an error occurred, true otherwise
 */
bool RDMAPI::GetCommStatus(
    unsigned int universe,
    const UID &uid,
    SingleUseCallback4<void,
                       const ResponseStatus&,
                       uint16_t,
                       uint16_t,
                       uint16_t> *callback,
    string *error) {
  if (CheckCallback(error, callback))
    return false;
  if (CheckNotBroadcast(uid, error, callback))
    return false;

  RDMAPIImplInterface::rdm_callback *cb = NewSingleCallback(
    this,
    &RDMAPI::_HandleGetCommStatus,
    callback);
  return CheckReturnStatus(
      m_impl->RDMGet(cb,
                     universe,
                     uid,
                     ROOT_RDM_DEVICE,
                     PID_COMMS_STATUS),
      error);
}


/*
 * @brief Clear the Communication status
 * @param universe the universe to perform the call on
 * @param uid the UID of the device to address this message to
 * @param callback the Callback to invoke when this request completes
 * @param error a pointer to a string which is set if an error occurs
 * @return false if an error occurred, true otherwise
 */
bool RDMAPI::ClearCommStatus(
    unsigned int universe,
    const UID &uid,
    SingleUseCallback1<void, const ResponseStatus&> *callback,
    string *error) {
  if (CheckCallback(error, callback))
    return false;
  RDMAPIImplInterface::rdm_callback *cb = NewSingleCallback(
    this,
    &RDMAPI::_HandleEmptyResponse,
    callback);
  return CheckReturnStatus(
      m_impl->RDMSet(cb,
                     universe,
                     uid,
                     ROOT_RDM_DEVICE,
                     PID_COMMS_STATUS),
      error);
}


/**
 * @brief Send a queued message request.
 */
bool RDMAPI::GetQueuedMessage(
        unsigned int universe,
        const UID &uid,
        rdm_status_type status_type,
        QueuedMessageHandler *handler,
        string *error) {
  if (!handler) {
    if (error)
      *error = "Callback is null, this is a programming error";
    return false;
  }

  RDMAPIImplInterface::rdm_pid_callback *cb = NewSingleCallback(
    this,
    &RDMAPI::_HandleQueuedMessage,
    handler);
  uint8_t type = status_type;
  return CheckReturnStatus(
      m_impl->RDMGet(cb,
                     universe,
                     uid,
                     ROOT_RDM_DEVICE,
                     PID_QUEUED_MESSAGE,
                     &type,
                     sizeof(type)),
      error);
}


/**
 * @brief Send a queued message request. When complete the callback will be run
 * and it's up to the caller to decode the message based on the PID.
 */
bool RDMAPI::GetQueuedMessage(
        unsigned int universe,
        const UID &uid,
        rdm_status_type status_type,
        SingleUseCallback3<void,
                           const ResponseStatus&,
                           uint16_t,
                           const string&> *callback,
        string *error) {
  if (CheckCallback(error, callback))
    return false;
  uint8_t type = status_type;
  return CheckReturnStatus(
      m_impl->RDMGet(callback,
                     universe,
                     uid,
                     ROOT_RDM_DEVICE,
                     PID_QUEUED_MESSAGE,
                     &type,
                     sizeof(type)),
      error);
}


/*
 * @brief Get the status information from a device
 * @param universe the universe to perform the call on
 * @param uid the UID of the device to address this message to
 * @param status_type the Status Type requested
 * @param callback the Callback to invoke when this request completes
 * @param error a pointer to a string which is set if an error occurs
 * @return false if an error occurred, true otherwise
 */
bool RDMAPI::GetStatusMessage(
    unsigned int universe,
    const UID &uid,
    rdm_status_type status_type,
    SingleUseCallback2<void,
                       const ResponseStatus&,
                       const vector<StatusMessage>&> *callback,
    string *error) {
  if (CheckCallback(error, callback))
    return false;
  if (CheckNotBroadcast(uid, error, callback))
    return false;

  RDMAPIImplInterface::rdm_callback *cb = NewSingleCallback(
    this,
    &RDMAPI::_HandleGetStatusMessage,
    callback);
  uint8_t type = static_cast<uint8_t>(status_type);
  return CheckReturnStatus(
      m_impl->RDMGet(cb,
                     universe,
                     uid,
                     ROOT_RDM_DEVICE,
                     PID_STATUS_MESSAGES,
                     &type,
                     sizeof(type)),
      error);
}


/*
 * @brief Fetch the description for a status id
 * @param universe the universe to perform the call on
 * @param uid the UID of the device to address this message to
 * @param callback the callback to invoke when this request completes
 * @param error a pointer to a string which is set if an error occurs
 * @return true if the request is sent correctly, false otherwise
 */
bool RDMAPI::GetStatusIdDescription(
    unsigned int universe,
    const UID &uid,
    uint16_t status_id,
    SingleUseCallback2<void, const ResponseStatus&, const string&> *callback,
    string *error) {
  if (CheckCallback(error, callback))
    return false;
  if (CheckNotBroadcast(uid, error, callback))
    return false;

  RDMAPIImplInterface::rdm_callback *cb = NewSingleCallback(
    this,
    &RDMAPI::_HandleLabelResponse,
    callback);
  status_id = HostToNetwork(status_id);
  return CheckReturnStatus(
      m_impl->RDMGet(cb,
                     universe,
                     uid,
                     ROOT_RDM_DEVICE,
                     PID_STATUS_ID_DESCRIPTION,
                     reinterpret_cast<const uint8_t*>(&status_id),
                     sizeof(status_id)),
      error);
}


/*
 * @brief Clear the status message queue
 * @param universe the universe to perform the call on
 * @param uid the UID of the device to address this message to
 * @param sub_device the sub device to use
 * @param callback the callback to invoke when this request completes
 * @param error a pointer to a string which is set if an error occurs
 * @return true if the request is sent correctly, false otherwise
 */
bool RDMAPI::ClearStatusId(
    unsigned int universe,
    const UID &uid,
    uint16_t sub_device,
    SingleUseCallback1<void, const ResponseStatus&> *callback,
    string *error) {
  if (CheckCallback(error, callback))
    return false;
  if (CheckValidSubDevice(sub_device, true, error, callback))
    return false;

  RDMAPIImplInterface::rdm_callback *cb = NewSingleCallback(
    this,
    &RDMAPI::_HandleEmptyResponse,
    callback);
  return CheckReturnStatus(
      m_impl->RDMSet(cb,
                     universe,
                     uid,
                     sub_device,
                     PID_CLEAR_STATUS_ID),
      error);
}


/*
 * @brief Get the reporting threshold for a device
 * @param universe the universe to perform the call on
 * @param uid the UID of the device to address this message to
 * @param sub_device the sub device to use
 * @param callback the callback to invoke when this request completes
 * @param error a pointer to a string which is set if an error occurs
 * @return true if the request is sent correctly, false otherwise
 */
bool RDMAPI::GetSubDeviceReporting(
    unsigned int universe,
    const UID &uid,
    uint16_t sub_device,
    SingleUseCallback2<void,
                       const ResponseStatus&,
                       uint8_t> *callback,
    string *error) {
  if (CheckCallback(error, callback))
    return false;
  if (CheckNotBroadcast(uid, error, callback))
    return false;
  if (CheckValidSubDevice(sub_device, false, error, callback))
    return false;

  RDMAPIImplInterface::rdm_callback *cb = NewSingleCallback(
    this,
    &RDMAPI::_HandleGetSubDeviceReporting,
    callback);
  return CheckReturnStatus(
      m_impl->RDMGet(cb,
                     universe,
                     uid,
                     sub_device,
                     PID_SUB_DEVICE_STATUS_REPORT_THRESHOLD),
      error);
}


/*
 * @brief Set the reporting threshold for a device
 * @param universe the universe to perform the call on
 * @param uid the UID of the device to address this message to
 * @param sub_device the sub device to use
 * @param status_type the Status Type to set the threshold as
 * @param callback the callback to invoke when this request completes
 * @param error a pointer to a string which is set if an error occurs
 * @return true if the request is sent correctly, false otherwise
 */
bool RDMAPI::SetSubDeviceReporting(
    unsigned int universe,
    const UID &uid,
    uint16_t sub_device,
    rdm_status_type status_type,
    SingleUseCallback1<void, const ResponseStatus&> *callback,
    string *error) {
  if (CheckCallback(error, callback))
    return false;
  if (CheckNotBroadcast(uid, error, callback))
    return false;
  if (CheckValidSubDevice(sub_device, true, error, callback))
    return false;

  RDMAPIImplInterface::rdm_callback *cb = NewSingleCallback(
    this,
    &RDMAPI::_HandleEmptyResponse,
    callback);
  uint8_t type = static_cast<uint8_t>(status_type);
  return CheckReturnStatus(
      m_impl->RDMSet(cb,
                     universe,
                     uid,
                     ROOT_RDM_DEVICE,
                     PID_SUB_DEVICE_STATUS_REPORT_THRESHOLD,
                     &type,
                     sizeof(type)),
      error);
}


/*
 * @brief Fetch the supported parameters list
 * @param universe the universe to perform the call on
 * @param uid the UID of the device to address this message to
 * @param sub_device the sub device to use
 * @param callback the callback to invoke when this request completes
 * @param error a pointer to a string which is set if an error occurs
 * @return true if the request is sent correctly, false otherwise
 */
bool RDMAPI::GetSupportedParameters(
    unsigned int universe,
    const UID &uid,
    uint16_t sub_device,
    SingleUseCallback2<void,
                       const ResponseStatus&,
                       const vector<uint16_t>&> *callback,
    string *error) {
  if (CheckCallback(error, callback))
    return false;
  if (CheckNotBroadcast(uid, error, callback))
    return false;
  if (CheckValidSubDevice(sub_device, false, error, callback))
    return false;

  RDMAPIImplInterface::rdm_callback *cb = NewSingleCallback(
    this,
    &RDMAPI::_HandleGetSupportedParameters,
    callback);
  return m_impl->RDMGet(cb,
                        universe,
                        uid,
                        sub_device,
                        PID_SUPPORTED_PARAMETERS);
}


/*
 * @brief Fetch the description of a param ID
 * @param universe the universe to perform the call on
 * @param uid the UID of the device to address this message to
 * @param pid the parameter id to fetch the description for
 * @param callback the callback to invoke when this request completes
 * @param error a pointer to a string which is set if an error occurs
 * @return true if the request is sent correctly, false otherwise
 */
bool RDMAPI::GetParameterDescription(
    unsigned int universe,
    const UID &uid,
    uint16_t pid,
    SingleUseCallback2<void,
                       const ResponseStatus&,
                       const ParameterDescriptor&> *callback,
    string *error) {
  if (CheckCallback(error, callback))
    return false;
  if (CheckNotBroadcast(uid, error, callback))
    return false;

  RDMAPIImplInterface::rdm_callback *cb = NewSingleCallback(
    this,
    &RDMAPI::_HandleGetParameterDescriptor,
    callback);
  pid = HostToNetwork(pid);
  return CheckReturnStatus(
      m_impl->RDMGet(cb,
                     universe,
                     uid,
                     ROOT_RDM_DEVICE,
                     PID_PARAMETER_DESCRIPTION,
                     reinterpret_cast<const uint8_t*>(&pid),
                     sizeof(pid)),
      error);
}


/*
 * @brief Fetch the device information
 * @param universe the universe to perform the call on
 * @param uid the UID to fetch the outstanding message count for
 * @param sub_device the sub device to use
 * @param callback the callback to invoke when this request completes
 * @param error a pointer to a string which is set if an error occurs
 * @return true if the request is sent correctly, false otherwise
 */
bool RDMAPI::GetDeviceInfo(
    unsigned int universe,
    const UID &uid,
    uint16_t sub_device,
    SingleUseCallback2<void,
                       const ResponseStatus&,
                       const DeviceDescriptor&> *callback,
    string *error) {
  if (CheckCallback(error, callback))
    return false;
  if (CheckNotBroadcast(uid, error, callback))
    return false;
  if (CheckValidSubDevice(sub_device, false, error, callback))
    return false;

  RDMAPIImplInterface::rdm_callback *cb = NewSingleCallback(
    this,
    &RDMAPI::_HandleGetDeviceDescriptor,
    callback);
  return CheckReturnStatus(
    m_impl->RDMGet(cb,
                   universe,
                   uid,
                   sub_device,
                   PID_DEVICE_INFO),
    error);
}


/*
 * @brief Fetch the product detail IDs.
 * @param universe the universe to perform the call on
 * @param uid the UID to fetch the outstanding message count for
 * @param sub_device the sub device to use
 * @param callback the callback to invoke when this request completes
 * @param error a pointer to a string which is set if an error occurs
 * @return true if the request is sent correctly, false otherwise
 */
bool RDMAPI::GetProductDetailIdList(
    unsigned int universe,
    const UID &uid,
    uint16_t sub_device,
    SingleUseCallback2<void,
                       const ResponseStatus&,
                       const vector<uint16_t>&> *callback,
    string *error) {
  if (CheckCallback(error, callback))
    return false;
  if (CheckNotBroadcast(uid, error, callback))
    return false;
  if (CheckValidSubDevice(sub_device, false, error, callback))
    return false;

  RDMAPIImplInterface::rdm_callback *cb = NewSingleCallback(
    this,
    &RDMAPI::_HandleGetProductDetailIdList,
    callback);
  return CheckReturnStatus(
    m_impl->RDMGet(cb,
                   universe,
                   uid,
                   sub_device,
                   PID_PRODUCT_DETAIL_ID_LIST),
    error);
}


/*
 * @brief Fetch the description for a device model.
 * @param universe the universe to perform the call on
 * @param uid the UID to fetch the outstanding message count for
 * @param sub_device the sub device to use
 * @param callback the callback to invoke when this request completes
 * @param error a pointer to a string which is set if an error occurs
 * @return true if the request is sent correctly, false otherwise
 */
bool RDMAPI::GetDeviceModelDescription(
    unsigned int universe,
    const UID &uid,
    uint16_t sub_device,
    SingleUseCallback2<void,
                       const ResponseStatus&,
                       const string&> *callback,
    string *error) {
  if (CheckCallback(error, callback))
    return false;
  if (CheckNotBroadcast(uid, error, callback))
    return false;
  if (CheckValidSubDevice(sub_device, false, error, callback))
    return false;

  RDMAPIImplInterface::rdm_callback *cb = NewSingleCallback(
    this,
    &RDMAPI::_HandleLabelResponse,
    callback);
  return CheckReturnStatus(
    m_impl->RDMGet(cb,
                   universe,
                   uid,
                   sub_device,
                   PID_DEVICE_MODEL_DESCRIPTION),
    error);
}


/*
 * @brief Fetch the manufacturer label for a device
 * @param universe the universe to perform the call on
 * @param uid the UID to fetch the outstanding message count for
 * @param sub_device the sub device to use
 * @param callback the callback to invoke when this request completes
 * @param error a pointer to a string which is set if an error occurs
 * @return true if the request is sent correctly, false otherwise
 */
bool RDMAPI::GetManufacturerLabel(
    unsigned int universe,
    const UID &uid,
    uint16_t sub_device,
    SingleUseCallback2<void,
                       const ResponseStatus&,
                       const string&> *callback,
    string *error) {
  if (CheckCallback(error, callback))
    return false;
  if (CheckNotBroadcast(uid, error, callback))
    return false;
  if (CheckValidSubDevice(sub_device, false, error, callback))
    return false;

  RDMAPIImplInterface::rdm_callback *cb = NewSingleCallback(
    this,
    &RDMAPI::_HandleLabelResponse,
    callback);
  return CheckReturnStatus(
    m_impl->RDMGet(cb,
                   universe,
                   uid,
                   sub_device,
                   PID_MANUFACTURER_LABEL),
    error);
}


/*
 * @brief Fetch the device label
 * @param universe the universe to perform the call on
 * @param uid the UID to fetch the outstanding message count for
 * @param sub_device the sub device to use
 * @param callback the callback to invoke when this request completes
 * @param error a pointer to a string which is set if an error occurs
 * @return true if the request is sent correctly, false otherwise
 */
bool RDMAPI::GetDeviceLabel(
    unsigned int universe,
    const UID &uid,
    uint16_t sub_device,
    SingleUseCallback2<void,
                       const ResponseStatus&,
                       const string&> *callback,
    string *error) {
  if (CheckCallback(error, callback))
    return false;
  if (CheckNotBroadcast(uid, error, callback))
    return false;
  if (CheckValidSubDevice(sub_device, false, error, callback))
    return false;

  RDMAPIImplInterface::rdm_callback *cb = NewSingleCallback(
    this,
    &RDMAPI::_HandleLabelResponse,
    callback);
  return CheckReturnStatus(
    m_impl->RDMGet(cb,
                   universe,
                   uid,
                   sub_device,
                   PID_DEVICE_LABEL),
    error);
}


/*
 * @brief Set the device label
 * @param universe the universe to perform the call on
 * @param uid the UID to fetch the outstanding message count for
 * @param sub_device the sub device to use
 * @param callback the callback to invoke when this request completes
 * @param error a pointer to a string which is set if an error occurs
 * @return true if the request is sent correctly, false otherwise
 */
bool RDMAPI::SetDeviceLabel(
    unsigned int universe,
    const UID &uid,
    uint16_t sub_device,
    const string &label,
    SingleUseCallback1<void, const ResponseStatus&> *callback,
    string *error) {
  if (CheckCallback(error, callback))
    return false;
  // It doesn't really make sense to broadcast this but allow it anyway
  if (CheckValidSubDevice(sub_device, true, error, callback))
    return false;

  RDMAPIImplInterface::rdm_callback *cb = NewSingleCallback(
    this,
    &RDMAPI::_HandleEmptyResponse,
    callback);
  return CheckReturnStatus(
    m_impl->RDMSet(cb,
                   universe,
                   uid,
                   sub_device,
                   PID_DEVICE_LABEL,
                   reinterpret_cast<const uint8_t*>(label.data()),
                   label.size()),
    error);
}


/*
 * @brief Check if a device is using the factory defaults
 * @param universe the universe to perform the call on
 * @param uid the UID to fetch the outstanding message count for
 * @param sub_device the sub device to use
 * @param callback the callback to invoke when this request completes
 * @param error a pointer to a string which is set if an error occurs
 * @return true if the request is sent correctly, false otherwise
 */
bool RDMAPI::GetFactoryDefaults(
    unsigned int universe,
    const UID &uid,
    uint16_t sub_device,
    SingleUseCallback2<void,
                       const ResponseStatus&,
                       bool> *callback,
    string *error) {
  if (CheckCallback(error, callback))
    return false;
  if (CheckNotBroadcast(uid, error, callback))
    return false;
  if (CheckValidSubDevice(sub_device, false, error, callback))
    return false;

  RDMAPIImplInterface::rdm_callback *cb = NewSingleCallback(
    this,
    &RDMAPI::_HandleBoolResponse,
    callback);
  return CheckReturnStatus(
    m_impl->RDMGet(cb,
                   universe,
                   uid,
                   sub_device,
                   PID_FACTORY_DEFAULTS),
    error);
}


/*
 * @brief Reset a device to factory defaults
 * @param universe the universe to perform the call on
 * @param uid the UID to fetch the outstanding message count for
 * @param sub_device the sub device to use
 * @param callback the callback to invoke when this request completes
 * @param error a pointer to a string which is set if an error occurs
 * @return true if the request is sent correctly, false otherwise
 */
bool RDMAPI::ResetToFactoryDefaults(
    unsigned int universe,
    const UID &uid,
    uint16_t sub_device,
    SingleUseCallback1<void, const ResponseStatus&> *callback,
    string *error) {
  if (CheckCallback(error, callback))
    return false;
  if (CheckNotBroadcast(uid, error, callback))
    return false;
  if (CheckValidSubDevice(sub_device, true, error, callback))
    return false;

  RDMAPIImplInterface::rdm_callback *cb = NewSingleCallback(
    this,
    &RDMAPI::_HandleEmptyResponse,
    callback);
  return CheckReturnStatus(
    m_impl->RDMSet(cb,
                   universe,
                   uid,
                   sub_device,
                   PID_FACTORY_DEFAULTS),
    error);
}


/*
 * @brief Get the list of languages this device supports
 * @param universe the universe to perform the call on
 * @param uid the UID to fetch the outstanding message count for
 * @param sub_device the sub device to use
 * @param callback the callback to invoke when this request completes
 * @param error a pointer to a string which is set if an error occurs
 * @return true if the request is sent correctly, false otherwise
 */
bool RDMAPI::GetLanguageCapabilities(
    unsigned int universe,
    const UID &uid,
    uint16_t sub_device,
    SingleUseCallback2<void,
                       const ResponseStatus&,
                       const vector<string>&> *callback,
    string *error) {
  if (CheckCallback(error, callback))
    return false;
  if (CheckNotBroadcast(uid, error, callback))
    return false;
  if (CheckValidSubDevice(sub_device, false, error, callback))
    return false;

  RDMAPIImplInterface::rdm_callback *cb = NewSingleCallback(
    this,
    &RDMAPI::_HandleGetLanguageCapabilities,
    callback);
  return CheckReturnStatus(
    m_impl->RDMGet(cb,
                   universe,
                   uid,
                   sub_device,
                   PID_LANGUAGE_CAPABILITIES),
    error);
}


/*
 * @brief Get the language for this device
 * @param universe the universe to perform the call on
 * @param uid the UID to fetch the outstanding message count for
 * @param sub_device the sub device to use
 * @param callback the callback to invoke when this request completes
 * @param error a pointer to a string which is set if an error occurs
 * @return true if the request is sent correctly, false otherwise
 */
bool RDMAPI::GetLanguage(
    unsigned int universe,
    const UID &uid,
    uint16_t sub_device,
    SingleUseCallback2<void,
                       const ResponseStatus&,
                       const string&> *callback,
    string *error) {
  if (CheckCallback(error, callback))
    return false;
  if (CheckNotBroadcast(uid, error, callback))
    return false;
  if (CheckValidSubDevice(sub_device, false, error, callback))
    return false;

  RDMAPIImplInterface::rdm_callback *cb = NewSingleCallback(
    this,
    &RDMAPI::_HandleGetLanguage,
    callback);
  return CheckReturnStatus(
    m_impl->RDMGet(cb,
                   universe,
                   uid,
                   sub_device,
                   PID_LANGUAGE),
    error);
}


/*
 * @brief Set the language for this device
 * @param universe the universe to perform the call on
 * @param uid the UID to fetch the outstanding message count for
 * @param sub_device the sub device to use
 * @param language the language code, only the first two characters are used
 * @param callback the callback to invoke when this request completes
 * @param error a pointer to a string which is set if an error occurs
 * @return true if the request is sent correctly, false otherwise
 */
bool RDMAPI::SetLanguage(
    unsigned int universe,
    const UID &uid,
    uint16_t sub_device,
    const string &language,
    SingleUseCallback1<void, const ResponseStatus&> *callback,
    string *error) {
  static const unsigned int DATA_SIZE = 2;
  if (CheckCallback(error, callback))
    return false;
  if (CheckValidSubDevice(sub_device, true, error, callback))
    return false;

  if (language.size() != DATA_SIZE) {
    if (error)
      *error = "Language must be a two letter code";
    delete callback;
    return false;
  }

  RDMAPIImplInterface::rdm_callback *cb = NewSingleCallback(
    this,
    &RDMAPI::_HandleEmptyResponse,
    callback);
  return CheckReturnStatus(
    m_impl->RDMSet(cb,
                   universe,
                   uid,
                   sub_device,
                   PID_LANGUAGE,
                   reinterpret_cast<const uint8_t*>(language.data()),
                   DATA_SIZE),
    error);
}


/*
 * @brief Get the software version label
 * @param universe the universe to perform the call on
 * @param uid the UID to fetch the outstanding message count for
 * @param sub_device the sub device to use
 * @param callback the callback to invoke when this request completes
 * @param error a pointer to a string which is set if an error occurs
 * @return true if the request is sent correctly, false otherwise
 */
bool RDMAPI::GetSoftwareVersionLabel(
    unsigned int universe,
    const UID &uid,
    uint16_t sub_device,
    SingleUseCallback2<void,
                       const ResponseStatus&,
                       const string&> *callback,
    string *error) {
  if (CheckCallback(error, callback))
    return false;
  if (CheckNotBroadcast(uid, error, callback))
    return false;
  if (CheckValidSubDevice(sub_device, false, error, callback))
    return false;

  RDMAPIImplInterface::rdm_callback *cb = NewSingleCallback(
    this,
    &RDMAPI::_HandleLabelResponse,
    callback);
  return CheckReturnStatus(
    m_impl->RDMGet(cb,
                   universe,
                   uid,
                   sub_device,
                   PID_SOFTWARE_VERSION_LABEL),
    error);
}


/*
 * @brief Get the boot software version.
 * @param universe the universe to perform the call on
 * @param uid the UID to fetch the outstanding message count for
 * @param sub_device the sub device to use
 * @param callback the callback to invoke when this request completes
 * @param error a pointer to a string which is set if an error occurs
 * @return true if the request is sent correctly, false otherwise
 */
bool RDMAPI::GetBootSoftwareVersion(
    unsigned int universe,
    const UID &uid,
    uint16_t sub_device,
    SingleUseCallback2<void,
                       const ResponseStatus&,
                       uint32_t> *callback,
    string *error) {
  if (CheckCallback(error, callback))
    return false;
  if (CheckNotBroadcast(uid, error, callback))
    return false;
  if (CheckValidSubDevice(sub_device, false, error, callback))
    return false;

  RDMAPIImplInterface::rdm_callback *cb = NewSingleCallback(
    this,
    &RDMAPI::_HandleGetBootSoftwareVersion,
    callback);
  return CheckReturnStatus(
    m_impl->RDMGet(cb,
                   universe,
                   uid,
                   sub_device,
                   PID_BOOT_SOFTWARE_VERSION_ID),
    error);
}


/*
 * @brief Get the boot software version label
 * @param universe the universe to perform the call on
 * @param uid the UID to fetch the outstanding message count for
 * @param sub_device the sub device to use
 * @param callback the callback to invoke when this request completes
 * @param error a pointer to a string which is set if an error occurs
 * @return true if the request is sent correctly, false otherwise
 */
bool RDMAPI::GetBootSoftwareVersionLabel(
    unsigned int universe,
    const UID &uid,
    uint16_t sub_device,
    SingleUseCallback2<void,
                       const ResponseStatus&,
                       const string&> *callback,
    string *error) {
  if (CheckCallback(error, callback))
    return false;
  if (CheckNotBroadcast(uid, error, callback))
    return false;
  if (CheckValidSubDevice(sub_device, false, error, callback))
    return false;

  RDMAPIImplInterface::rdm_callback *cb = NewSingleCallback(
    this,
    &RDMAPI::_HandleLabelResponse,
    callback);
  return CheckReturnStatus(
    m_impl->RDMGet(cb,
                   universe,
                   uid,
                   sub_device,
                   PID_BOOT_SOFTWARE_VERSION_LABEL),
    error);
}


/*
 * @brief Get the current DMX personality
 * @param universe the universe to perform the call on
 * @param uid the UID to fetch the outstanding message count for
 * @param sub_device the sub device to use
 * @param callback the callback to invoke when this request completes
 * @param error a pointer to a string which is set if an error occurs
 * @return true if the request is sent correctly, false otherwise
 */
bool RDMAPI::GetDMXPersonality(
    unsigned int universe,
    const UID &uid,
    uint16_t sub_device,
    SingleUseCallback3<void,
                       const ResponseStatus&,
                       uint8_t,
                       uint8_t> *callback,
    string *error) {
  if (CheckCallback(error, callback))
    return false;
  if (CheckNotBroadcast(uid, error, callback))
    return false;
  if (CheckValidSubDevice(sub_device, false, error, callback))
    return false;

  RDMAPIImplInterface::rdm_callback *cb = NewSingleCallback(
    this,
    &RDMAPI::_HandleGetDMXPersonality,
    callback);
  return CheckReturnStatus(
    m_impl->RDMGet(cb,
                   universe,
                   uid,
                   sub_device,
                   PID_DMX_PERSONALITY),
    error);
}


/*
 * @brief Set the DMX personality
 * @param universe the universe to perform the call on
 * @param uid the UID to fetch the outstanding message count for
 * @param sub_device the sub device to use
 * @param personality the value of the personality to choose
 * @param callback the callback to invoke when this request completes
 * @param error a pointer to a string which is set if an error occurs
 * @return true if the request is sent correctly, false otherwise
 */
bool RDMAPI::SetDMXPersonality(
    unsigned int universe,
    const UID &uid,
    uint16_t sub_device,
    uint8_t personality,
    SingleUseCallback1<void, const ResponseStatus&> *callback,
    string *error) {
  if (CheckCallback(error, callback))
    return false;
  if (CheckValidSubDevice(sub_device, true, error, callback))
    return false;

  RDMAPIImplInterface::rdm_callback *cb = NewSingleCallback(
    this,
    &RDMAPI::_HandleEmptyResponse,
    callback);
  return CheckReturnStatus(
    m_impl->RDMSet(cb,
                   universe,
                   uid,
                   sub_device,
                   PID_DMX_PERSONALITY,
                   &personality,
                   sizeof(personality)),
    error);
}


/*
 * @brief Get the description for a DMX personality
 * @param universe the universe to perform the call on
 * @param uid the UID to fetch the outstanding message count for
 * @param sub_device the sub device to use
 * @param personality the value of the personality to get the description of
 * @param callback the callback to invoke when this request completes
 * @param error a pointer to a string which is set if an error occurs
 * @return true if the request is sent correctly, false otherwise
 */
bool RDMAPI::GetDMXPersonalityDescription(
    unsigned int universe,
    const UID &uid,
    uint16_t sub_device,
    uint8_t personality,
    SingleUseCallback4<void,
                       const ResponseStatus&,
                       uint8_t,
                       uint16_t,
                       const string&> *callback,
    string *error) {
  if (CheckCallback(error, callback))
    return false;
  if (CheckNotBroadcast(uid, error, callback))
    return false;
  if (CheckValidSubDevice(sub_device, false, error, callback))
    return false;

  RDMAPIImplInterface::rdm_callback *cb = NewSingleCallback(
    this,
    &RDMAPI::_HandleGetDMXPersonalityDescription,
    callback);
  return CheckReturnStatus(
    m_impl->RDMGet(cb,
                   universe,
                   uid,
                   sub_device,
                   PID_DMX_PERSONALITY_DESCRIPTION,
                   &personality,
                   sizeof(personality)),
    error);
}


/*
 * @brief Get the DMX start address
 * @param universe the universe to perform the call on
 * @param uid the UID to fetch the outstanding message count for
 * @param sub_device the sub device to use
 * @param callback the callback to invoke when this request completes
 * @param error a pointer to a string which is set if an error occurs
 * @return true if the request is sent correctly, false otherwise
 */
bool RDMAPI::GetDMXAddress(
    unsigned int universe,
    const UID &uid,
    uint16_t sub_device,
    SingleUseCallback2<void,
                       const ResponseStatus&,
                       uint16_t> *callback,
    string *error) {

  return GenericGetU16(
    universe,
    uid,
    sub_device,
    callback,
    PID_DMX_START_ADDRESS,
    error);
}


/*
 * @brief Set the DMX start address
 * @param universe the universe to perform the call on
 * @param uid the UID to fetch the outstanding message count for
 * @param sub_device the sub device to use
 * @param start_address the new start address
 * @param callback the callback to invoke when this request completes
 * @param error a pointer to a string which is set if an error occurs
 * @return true if the request is sent correctly, false otherwise
 */
bool RDMAPI::SetDMXAddress(
    unsigned int universe,
    const UID &uid,
    uint16_t sub_device,
    uint16_t start_address,
    SingleUseCallback1<void, const ResponseStatus&> *callback,
    string *error) {

  return GenericSetU16(
    universe,
    uid,
    sub_device,
    start_address,
    callback,
    PID_DMX_START_ADDRESS,
    error);
}


/*
 * @brief Fetch the DMX slot info
 * @param universe the universe to perform the call on
 * @param uid the UID to fetch the outstanding message count for
 * @param sub_device the sub device to use
 * @param callback the callback to invoke when this request completes
 * @param error a pointer to a string which is set if an error occurs
 * @return true if the request is sent correctly, false otherwise
 */
bool RDMAPI::GetSlotInfo(
    unsigned int universe,
    const UID &uid,
    uint16_t sub_device,
    SingleUseCallback2<void,
                       const ResponseStatus&,
                       const vector<SlotDescriptor>&> *callback,
    string *error) {
  if (CheckCallback(error, callback))
    return false;
  if (CheckNotBroadcast(uid, error, callback))
    return false;
  if (CheckValidSubDevice(sub_device, false, error, callback))
    return false;

  RDMAPIImplInterface::rdm_callback *cb = NewSingleCallback(
    this,
    &RDMAPI::_HandleGetSlotInfo,
    callback);
  return CheckReturnStatus(
    m_impl->RDMGet(cb,
                   universe,
                   uid,
                   sub_device,
                   PID_SLOT_INFO),
    error);
}


/*
 * @brief Fetch a DMX slot description
 * @param universe the universe to perform the call on
 * @param uid the UID to fetch the outstanding message count for
 * @param sub_device the sub device to use
 * @param slot_offset the offset of the slot to get the description of
 * @param callback the callback to invoke when this request completes
 * @param error a pointer to a string which is set if an error occurs
 * @return true if the request is sent correctly, false otherwise
 */
bool RDMAPI::GetSlotDescription(
    unsigned int universe,
    const UID &uid,
    uint16_t sub_device,
    uint16_t slot_offset,
    SingleUseCallback3<void,
                       const ResponseStatus&,
                       uint16_t,
                       const string&> *callback,
    string *error) {
  if (CheckCallback(error, callback))
    return false;
  if (CheckNotBroadcast(uid, error, callback))
    return false;
  if (CheckValidSubDevice(sub_device, false, error, callback))
    return false;

  slot_offset = HostToNetwork(slot_offset);
  RDMAPIImplInterface::rdm_callback *cb = NewSingleCallback(
    this,
    &RDMAPI::_HandleGetSlotDescription,
    callback);
  return CheckReturnStatus(
    m_impl->RDMGet(cb,
                   universe,
                   uid,
                   sub_device,
                   PID_SLOT_DESCRIPTION,
                   reinterpret_cast<const uint8_t*>(&slot_offset),
                   sizeof(slot_offset)),
    error);
}


/*
 * @brief Get the default value for a slot
 * @param universe the universe to perform the call on
 * @param uid the UID to fetch the outstanding message count for
 * @param sub_device the sub device to use
 * @param callback the callback to invoke when this request completes
 * @param error a pointer to a string which is set if an error occurs
 * @return true if the request is sent correctly, false otherwise
 */
bool RDMAPI::GetSlotDefaultValues(
    unsigned int universe,
    const UID &uid,
    uint16_t sub_device,
    SingleUseCallback2<void,
                       const ResponseStatus&,
                       const vector<SlotDefault>&> *callback,
    string *error) {
  if (CheckCallback(error, callback))
    return false;
  if (CheckNotBroadcast(uid, error, callback))
    return false;
  if (CheckValidSubDevice(sub_device, false, error, callback))
    return false;

  RDMAPIImplInterface::rdm_callback *cb = NewSingleCallback(
    this,
    &RDMAPI::_HandleGetSlotDefaultValues,
    callback);
  return CheckReturnStatus(
    m_impl->RDMGet(cb,
                   universe,
                   uid,
                   sub_device,
                   PID_DEFAULT_SLOT_VALUE),
    error);
}


/*
 * @brief Get the definition for a sensor
 * @param universe the universe to perform the call on
 * @param uid the UID to fetch the outstanding message count for
 * @param sub_device the sub device to use
 * @param sensor_number the sensor index to get the descriptor for
 * @param callback the callback to invoke when this request completes
 * @param error a pointer to a string which is set if an error occurs
 * @return true if the request is sent correctly, false otherwise
 */
bool RDMAPI::GetSensorDefinition(
    unsigned int universe,
    const UID &uid,
    uint16_t sub_device,
    uint8_t sensor_number,
    SingleUseCallback2<void,
                       const ResponseStatus&,
                       const SensorDescriptor&> *callback,
    string *error) {
  if (CheckCallback(error, callback))
    return false;
  if (CheckNotBroadcast(uid, error, callback))
    return false;
  if (CheckValidSubDevice(sub_device, false, error, callback))
    return false;

  RDMAPIImplInterface::rdm_callback *cb = NewSingleCallback(
    this,
    &RDMAPI::_HandleGetSensorDefinition,
    callback);
  return CheckReturnStatus(
    m_impl->RDMGet(cb,
                   universe,
                   uid,
                   sub_device,
                   PID_SENSOR_DEFINITION,
                   &sensor_number,
                   sizeof(sensor_number)),
    error);
}


/*
 * @brief Get the value of a sensor
 * @param universe the universe to perform the call on
 * @param uid the UID to fetch the outstanding message count for
 * @param sub_device the sub device to use
 * @param sensor_number the sensor index to get the value of
 * @param callback the callback to invoke when this request completes
 * @param error a pointer to a string which is set if an error occurs
 * @return true if the request is sent correctly, false otherwise
 */
bool RDMAPI::GetSensorValue(
    unsigned int universe,
    const UID &uid,
    uint16_t sub_device,
    uint8_t sensor_number,
    SingleUseCallback2<void,
                       const ResponseStatus&,
                       const SensorValueDescriptor&> *callback,
    string *error) {
  if (CheckCallback(error, callback))
    return false;
  if (CheckNotBroadcast(uid, error, callback))
    return false;
  if (CheckValidSubDevice(sub_device, false, error, callback))
    return false;

  RDMAPIImplInterface::rdm_callback *cb = NewSingleCallback(
    this,
    &RDMAPI::_HandleSensorValue,
    callback);
  return CheckReturnStatus(
    m_impl->RDMGet(cb,
                   universe,
                   uid,
                   sub_device,
                   PID_SENSOR_VALUE,
                   &sensor_number,
                   sizeof(sensor_number)),
    error);
}


/*
 * @brief Reset a sensor
 * @param universe the universe to perform the call on
 * @param uid the UID to fetch the outstanding message count for
 * @param sub_device the sub device to use
 * @param sensor_number the sensor index to reset
 * @param callback the callback to invoke when this request completes
 * @param error a pointer to a string which is set if an error occurs
 * @return true if the request is sent correctly, false otherwise
 */
bool RDMAPI::SetSensorValue(
    unsigned int universe,
    const UID &uid,
    uint16_t sub_device,
    uint8_t sensor_number,
    SingleUseCallback2<void,
                       const ResponseStatus&,
                       const SensorValueDescriptor&> *callback,
    string *error) {
  if (CheckCallback(error, callback))
    return false;
  if (CheckValidSubDevice(sub_device, true, error, callback))
    return false;

  RDMAPIImplInterface::rdm_callback *cb = NewSingleCallback(
    this,
    &RDMAPI::_HandleSensorValue,
    callback);
  return CheckReturnStatus(
    m_impl->RDMSet(cb,
                   universe,
                   uid,
                   sub_device,
                   PID_SENSOR_VALUE,
                   &sensor_number,
                   sizeof(sensor_number)),
    error);
}


/*
 * @brief Put a sensor into record mode
 * @param universe the universe to perform the call on
 * @param uid the UID to fetch the outstanding message count for
 * @param sub_device the sub device to use
 * @param sensor_number the sensor index to record
 * @param callback the callback to invoke when this request completes
 * @param error a pointer to a string which is set if an error occurs
 * @return true if the request is sent correctly, false otherwise
 */
bool RDMAPI::RecordSensors(
    unsigned int universe,
    const UID &uid,
    uint16_t sub_device,
    uint8_t sensor_number,
    SingleUseCallback1<void, const ResponseStatus&> *callback,
    string *error) {
  if (CheckCallback(error, callback))
    return false;
  if (CheckValidSubDevice(sub_device, true, error, callback))
    return false;

  RDMAPIImplInterface::rdm_callback *cb = NewSingleCallback(
    this,
    &RDMAPI::_HandleEmptyResponse,
    callback);
  return CheckReturnStatus(
    m_impl->RDMSet(cb,
                   universe,
                   uid,
                   sub_device,
                   PID_RECORD_SENSORS,
                   &sensor_number,
                   sizeof(sensor_number)),
    error);
}


/*
 * @brief Get the device hours
 * @param universe the universe to perform the call on
 * @param uid the UID to fetch the outstanding message count for
 * @param sub_device the sub device to use
 * @param callback the callback to invoke when this request completes
 * @param error a pointer to a string which is set if an error occurs
 * @return true if the request is sent correctly, false otherwise
*/
bool RDMAPI::GetDeviceHours(
    unsigned int universe,
    const UID &uid,
    uint16_t sub_device,
    SingleUseCallback2<void, const ResponseStatus&, uint32_t> *callback,
    string *error) {
  if (CheckCallback(error, callback))
    return false;
  return GenericGetU32(
      universe,
      uid,
      sub_device,
      callback,
      PID_DEVICE_HOURS,
      error);
}


/*
 * @brief Set the device hours
 * @param universe the universe to perform the call on
 * @param uid the UID to fetch the outstanding message count for
 * @param sub_device the sub device to use
 * @param device_hours the number of device hours
 * @param callback the callback to invoke when this request completes
 * @param error a pointer to a string which is set if an error occurs
 * @return true if the request is sent correctly, false otherwise
*/
bool RDMAPI::SetDeviceHours(
    unsigned int universe,
    const UID &uid,
    uint16_t sub_device,
    uint32_t device_hours,
    SingleUseCallback1<void, const ResponseStatus&> *callback,
    string *error) {
  if (CheckCallback(error, callback))
    return false;
  return GenericSetU32(
      universe,
      uid,
      sub_device,
      device_hours,
      callback,
      PID_DEVICE_HOURS,
      error);
}


/*
* @brief Get the lamp hours
* @param universe the universe to perform the call on
* @param uid the UID to fetch the outstanding message count for
* @param sub_device the sub device to use
* @param callback the callback to invoke when this request completes
* @param error a pointer to a string which is set if an error occurs
* @return true if the request is sent correctly, false otherwise
*/
bool RDMAPI::GetLampHours(
    unsigned int universe,
    const UID &uid,
    uint16_t sub_device,
    SingleUseCallback2<void, const ResponseStatus&, uint32_t> *callback,
    string *error) {
  if (CheckCallback(error, callback))
    return false;
  return GenericGetU32(
      universe,
      uid,
      sub_device,
      callback,
      PID_LAMP_HOURS,
      error);
}


/*
 * @brief Set the lamp hours
 * @param universe the universe to perform the call on
 * @param uid the UID to fetch the outstanding message count for
 * @param sub_device the sub device to use
 * @param lamp_hours the number of lamp hours
 * @param callback the callback to invoke when this request completes
 * @param error a pointer to a string which is set if an error occurs
 * @return true if the request is sent correctly, false otherwise
*/
bool RDMAPI::SetLampHours(
    unsigned int universe,
    const UID &uid,
    uint16_t sub_device,
    uint32_t lamp_hours,
    SingleUseCallback1<void, const ResponseStatus&> *callback,
    string *error) {
  if (CheckCallback(error, callback))
    return false;
  return GenericSetU32(
      universe,
      uid,
      sub_device,
      lamp_hours,
      callback,
      PID_LAMP_STRIKES,
      error);
}


/*
* @brief Get the number of lamp strikes
* @param universe the universe to perform the call on
* @param uid the UID to fetch the outstanding message count for
* @param sub_device the sub device to use
* @param callback the callback to invoke when this request completes
* @param error a pointer to a string which is set if an error occurs
* @return true if the request is sent correctly, false otherwise
*/
bool RDMAPI::GetLampStrikes(
    unsigned int universe,
    const UID &uid,
    uint16_t sub_device,
    SingleUseCallback2<void, const ResponseStatus&, uint32_t> *callback,
    string *error) {
  if (CheckCallback(error, callback))
    return false;
  return GenericGetU32(
      universe,
      uid,
      sub_device,
      callback,
      PID_LAMP_STRIKES,
      error);
}


/*
 * @brief Set the lamp strikes
 * @param universe the universe to perform the call on
 * @param uid the UID to fetch the outstanding message count for
 * @param sub_device the sub device to use
 * @param lamp_strikes the number of lamp strikes
 * @param callback the callback to invoke when this request completes
 * @param error a pointer to a string which is set if an error occurs
 * @return true if the request is sent correctly, false otherwise
*/
bool RDMAPI::SetLampStrikes(
    unsigned int universe,
    const UID &uid,
    uint16_t sub_device,
    uint32_t lamp_strikes,
    SingleUseCallback1<void, const ResponseStatus&> *callback,
    string *error) {
  if (CheckCallback(error, callback))
    return false;
  return GenericSetU32(
      universe,
      uid,
      sub_device,
      lamp_strikes,
      callback,
      PID_LAMP_STRIKES,
      error);
}


/*
* @brief Get the state of the lamp
* @param universe the universe to perform the call on
* @param uid the UID to fetch the outstanding message count for
* @param sub_device the sub device to use
* @param callback the callback to invoke when this request completes
* @param error a pointer to a string which is set if an error occurs
* @return true if the request is sent correctly, false otherwise
*/
bool RDMAPI::GetLampState(
    unsigned int universe,
    const UID &uid,
    uint16_t sub_device,
    SingleUseCallback2<void, const ResponseStatus&, uint8_t> *callback,
    string *error) {
  if (CheckCallback(error, callback))
    return false;
  return GenericGetU8(
      universe,
      uid,
      sub_device,
      callback,
      PID_LAMP_STATE,
      error);
}


/*
 * @brief Set the lamp state
 * @param universe the universe to perform the call on
 * @param uid the UID to fetch the outstanding message count for
 * @param sub_device the sub device to use
 * @param lamp_state the new lamp state
 * @param callback the callback to invoke when this request completes
 * @param error a pointer to a string which is set if an error occurs
 * @return true if the request is sent correctly, false otherwise
*/
bool RDMAPI::SetLampState(
    unsigned int universe,
    const UID &uid,
    uint16_t sub_device,
    uint8_t lamp_state,
    SingleUseCallback1<void, const ResponseStatus&> *callback,
    string *error) {
  if (CheckCallback(error, callback))
    return false;
  return GenericSetU8(
      universe,
      uid,
      sub_device,
      lamp_state,
      callback,
      PID_LAMP_STATE,
      error);
}


/*
* @brief Get the mode of the lamp
* @param universe the universe to perform the call on
* @param uid the UID to fetch the outstanding message count for
* @param sub_device the sub device to use
* @param callback the callback to invoke when this request completes
* @param error a pointer to a string which is set if an error occurs
* @return true if the request is sent correctly, false otherwise
*/
bool RDMAPI::GetLampMode(
    unsigned int universe,
    const UID &uid,
    uint16_t sub_device,
    SingleUseCallback2<void, const ResponseStatus&, uint8_t> *callback,
    string *error) {
  if (CheckCallback(error, callback))
    return false;
  return GenericGetU8(
      universe,
      uid,
      sub_device,
      callback,
      PID_LAMP_ON_MODE,
      error);
}


/*
 * @brief Set the lamp mode
 * @param universe the universe to perform the call on
 * @param uid the UID to fetch the outstanding message count for
 * @param sub_device the sub device to use
 * @param lamp_mode the new lamp mode
 * @param callback the callback to invoke when this request completes
 * @param error a pointer to a string which is set if an error occurs
 * @return true if the request is sent correctly, false otherwise
*/
bool RDMAPI::SetLampMode(
    unsigned int universe,
    const UID &uid,
    uint16_t sub_device,
    uint8_t lamp_mode,
    SingleUseCallback1<void, const ResponseStatus&> *callback,
    string *error) {
  if (CheckCallback(error, callback))
    return false;
  return GenericSetU8(
      universe,
      uid,
      sub_device,
      lamp_mode,
      callback,
      PID_LAMP_ON_MODE,
      error);
}


/*
* @brief Get the number of device power cycles
* @param universe the universe to perform the call on
* @param uid the UID to fetch the outstanding message count for
* @param sub_device the sub device to use
* @param callback the callback to invoke when this request completes
* @param error a pointer to a string which is set if an error occurs
* @return true if the request is sent correctly, false otherwise
*/
bool RDMAPI::GetDevicePowerCycles(
    unsigned int universe,
    const UID &uid,
    uint16_t sub_device,
    SingleUseCallback2<void, const ResponseStatus&, uint32_t> *callback,
    string *error) {
  if (CheckCallback(error, callback))
    return false;
  return GenericGetU32(
      universe,
      uid,
      sub_device,
      callback,
      PID_DEVICE_POWER_CYCLES,
      error);
}


/*
 * @brief Set the number of power cycles
 * @param universe the universe to perform the call on
 * @param uid the UID to fetch the outstanding message count for
 * @param sub_device the sub device to use
 * @param power_cycles the number of power cycles
 * @param callback the callback to invoke when this request completes
 * @param error a pointer to a string which is set if an error occurs
 * @return true if the request is sent correctly, false otherwise
*/
bool RDMAPI::SetDevicePowerCycles(
    unsigned int universe,
    const UID &uid,
    uint16_t sub_device,
    uint32_t power_cycles,
    SingleUseCallback1<void, const ResponseStatus&> *callback,
    string *error) {
  if (CheckCallback(error, callback))
    return false;
  return GenericSetU32(
      universe,
      uid,
      sub_device,
      power_cycles,
      callback,
      PID_DEVICE_POWER_CYCLES,
      error);
}


/*
* @brief Get the display invert setting
* @param universe the universe to perform the call on
* @param uid the UID to fetch the outstanding message count for
* @param sub_device the sub device to use
* @param callback the callback to invoke when this request completes
* @param error a pointer to a string which is set if an error occurs
* @return true if the request is sent correctly, false otherwise
*/
bool RDMAPI::GetDisplayInvert(
    unsigned int universe,
    const UID &uid,
    uint16_t sub_device,
    SingleUseCallback2<void, const ResponseStatus&, uint8_t> *callback,
    string *error) {
  if (CheckCallback(error, callback))
    return false;
  return GenericGetU8(
      universe,
      uid,
      sub_device,
      callback,
      PID_DISPLAY_INVERT,
      error);
}


/*
 * @brief Set the display invert setting
 * @param universe the universe to perform the call on
 * @param uid the UID to fetch the outstanding message count for
 * @param sub_device the sub device to use
 * @param display_invert the new invert setting
 * @param callback the callback to invoke when this request completes
 * @param error a pointer to a string which is set if an error occurs
 * @return true if the request is sent correctly, false otherwise
*/
bool RDMAPI::SetDisplayInvert(
    unsigned int universe,
    const UID &uid,
    uint16_t sub_device,
    uint8_t display_invert,
    SingleUseCallback1<void, const ResponseStatus&> *callback,
    string *error) {
  if (CheckCallback(error, callback))
    return false;
  return GenericSetU8(
      universe,
      uid,
      sub_device,
      display_invert,
      callback,
      PID_DISPLAY_INVERT,
      error);
}


/*
* @brief Get the display level
* @param universe the universe to perform the call on
* @param uid the UID to fetch the outstanding message count for
* @param sub_device the sub device to use
* @param callback the callback to invoke when this request completes
* @param error a pointer to a string which is set if an error occurs
* @return true if the request is sent correctly, false otherwise
*/
bool RDMAPI::GetDisplayLevel(
    unsigned int universe,
    const UID &uid,
    uint16_t sub_device,
    SingleUseCallback2<void, const ResponseStatus&, uint8_t> *callback,
    string *error) {
  if (CheckCallback(error, callback))
    return false;
  return GenericGetU8(
      universe,
      uid,
      sub_device,
      callback,
      PID_DISPLAY_LEVEL,
      error);
}


/*
 * @brief Set the display level
 * @param universe the universe to perform the call on
 * @param uid the UID to fetch the outstanding message count for
 * @param sub_device the sub device to use
 * @param display_level the new setting
 * @param callback the callback to invoke when this request completes
 * @param error a pointer to a string which is set if an error occurs
 * @return true if the request is sent correctly, false otherwise
*/
bool RDMAPI::SetDisplayLevel(
    unsigned int universe,
    const UID &uid,
    uint16_t sub_device,
    uint8_t display_level,
    SingleUseCallback1<void, const ResponseStatus&> *callback,
    string *error) {
  if (CheckCallback(error, callback))
    return false;
  return GenericSetU8(
      universe,
      uid,
      sub_device,
      display_level,
      callback,
      PID_DISPLAY_LEVEL,
      error);
}


/*
* @brief Get the pan invert parameter
* @param universe the universe to perform the call on
* @param uid the UID to fetch the outstanding message count for
* @param sub_device the sub device to use
* @param callback the callback to invoke when this request completes
* @param error a pointer to a string which is set if an error occurs
* @return true if the request is sent correctly, false otherwise
*/
bool RDMAPI::GetPanInvert(
    unsigned int universe,
    const UID &uid,
    uint16_t sub_device,
    SingleUseCallback2<void, const ResponseStatus&, uint8_t> *callback,
    string *error) {
  if (CheckCallback(error, callback))
    return false;
  return GenericGetU8(
      universe,
      uid,
      sub_device,
      callback,
      PID_PAN_INVERT,
      error);
}


/*
 * @brief Invert the pan parameter
 * @param universe the universe to perform the call on
 * @param uid the UID to fetch the outstanding message count for
 * @param sub_device the sub device to use
 * @param invert set to true to invert
 * @param callback the callback to invoke when this request completes
 * @param error a pointer to a string which is set if an error occurs
 * @return true if the request is sent correctly, false otherwise
*/
bool RDMAPI::SetPanInvert(
    unsigned int universe,
    const UID &uid,
    uint16_t sub_device,
    uint8_t invert,
    SingleUseCallback1<void, const ResponseStatus&> *callback,
    string *error) {
  if (CheckCallback(error, callback))
    return false;
  return GenericSetU8(
      universe,
      uid,
      sub_device,
      invert,
      callback,
      PID_PAN_INVERT,
      error);
}


/*
* @brief Get the tilt invert parameter
* @param universe the universe to perform the call on
* @param uid the UID to fetch the outstanding message count for
* @param sub_device the sub device to use
* @param callback the callback to invoke when this request completes
* @param error a pointer to a string which is set if an error occurs
* @return true if the request is sent correctly, false otherwise
*/
bool RDMAPI::GetTiltInvert(
    unsigned int universe,
    const UID &uid,
    uint16_t sub_device,
    SingleUseCallback2<void, const ResponseStatus&, uint8_t> *callback,
    string *error) {
  if (CheckCallback(error, callback))
    return false;
  return GenericGetU8(
      universe,
      uid,
      sub_device,
      callback,
      PID_TILT_INVERT,
      error);
}


/*
 * @brief Invert the tilt parameter
 * @param universe the universe to perform the call on
 * @param uid the UID to fetch the outstanding message count for
 * @param sub_device the sub device to use
 * @param invert set to true to invert
 * @param callback the callback to invoke when this request completes
 * @param error a pointer to a string which is set if an error occurs
 * @return true if the request is sent correctly, false otherwise
*/
bool RDMAPI::SetTiltInvert(
    unsigned int universe,
    const UID &uid,
    uint16_t sub_device,
    uint8_t invert,
    SingleUseCallback1<void, const ResponseStatus&> *callback,
    string *error) {
  if (CheckCallback(error, callback))
    return false;
  return GenericSetU8(
      universe,
      uid,
      sub_device,
      invert,
      callback,
      PID_TILT_INVERT,
      error);
}


/*
* @brief Get the pan/tilt swap parameter
* @param universe the universe to perform the call on
* @param uid the UID to fetch the outstanding message count for
* @param sub_device the sub device to use
* @param callback the callback to invoke when this request completes
* @param error a pointer to a string which is set if an error occurs
* @return true if the request is sent correctly, false otherwise
*/
bool RDMAPI::GetPanTiltSwap(
    unsigned int universe,
    const UID &uid,
    uint16_t sub_device,
    SingleUseCallback2<void, const ResponseStatus&, uint8_t> *callback,
    string *error) {
  if (CheckCallback(error, callback))
    return false;
  return GenericGetU8(
      universe,
      uid,
      sub_device,
      callback,
      PID_PAN_TILT_SWAP,
      error);
}


/*
 * @brief Swap the pan and tilt actions
 * @param universe the universe to perform the call on
 * @param uid the UID to fetch the outstanding message count for
 * @param sub_device the sub device to use
 * @param swap, true to swap, false otherwise
 * @param callback the callback to invoke when this request completes
 * @param error a pointer to a string which is set if an error occurs
 * @return true if the request is sent correctly, false otherwise
*/
bool RDMAPI::SetPanTiltSwap(
    unsigned int universe,
    const UID &uid,
    uint16_t sub_device,
    uint8_t swap,
    SingleUseCallback1<void, const ResponseStatus&> *callback,
    string *error) {
  if (CheckCallback(error, callback))
    return false;
  return GenericSetU8(
      universe,
      uid,
      sub_device,
      swap,
      callback,
      PID_PAN_TILT_SWAP,
      error);
}


/*
 * @brief Get the clock value
 * @param universe the universe to perform the call on
 * @param uid the UID to fetch the outstanding message count for
 * @param sub_device the sub device to use
 * @param callback the callback to invoke when this request completes
 * @param error a pointer to a string which is set if an error occurs
 * @return true if the request is sent correctly, false otherwise
*/
bool RDMAPI::GetClock(
    unsigned int universe,
    const UID &uid,
    uint16_t sub_device,
    SingleUseCallback2<void,
                       const ResponseStatus&,
                       const ClockValue&> *callback,
    string *error) {
  if (CheckCallback(error, callback))
    return false;
  RDMAPIImplInterface::rdm_callback *cb = NewSingleCallback(
    this,
    &RDMAPI::_HandleClock,
    callback);
  return CheckReturnStatus(
      m_impl->RDMGet(cb,
                     universe,
                     uid,
                     sub_device,
                     PID_REAL_TIME_CLOCK),
      error);
}


/*
 * @brief Set the clock value
 * @param universe the universe to perform the call on
 * @param uid the UID to fetch the outstanding message count for
 * @param sub_device the sub device to use
 * @param clock, the new clock settings
 * @param callback the callback to invoke when this request completes
 * @param error a pointer to a string which is set if an error occurs
 * @return true if the request is sent correctly, false otherwise
*/
bool RDMAPI::SetClock(
    unsigned int universe,
    const UID &uid,
    uint16_t sub_device,
    const ClockValue &clock,
    SingleUseCallback1<void, const ResponseStatus&> *callback,
    string *error) {
  if (CheckCallback(error, callback))
    return false;
  ClockValue clock_data;
  memcpy(&clock_data, &clock, sizeof(clock_data));
  clock_data.year = HostToNetwork(clock_data.year);

  RDMAPIImplInterface::rdm_callback *cb = NewSingleCallback(
    this,
    &RDMAPI::_HandleEmptyResponse,
    callback);
  return CheckReturnStatus(
      m_impl->RDMSet(cb,
                     universe,
                     uid,
                     sub_device,
                     PID_REAL_TIME_CLOCK,
                     reinterpret_cast<const uint8_t*>(&clock_data),
                     sizeof(struct clock_value_s)),
      error);
}


/*
 * @brief Check the identify state for a device
 * @param universe the universe to perform the call on
 * @param uid the UID to fetch the outstanding message count for
 * @param sub_device the sub device to use
 * @param callback the callback to invoke when this request completes
 * @param error a pointer to a string which is set if an error occurs
 * @return true if the request is sent correctly, false otherwise
 */
bool RDMAPI::GetIdentifyDevice(
    unsigned int universe,
    const UID &uid,
    uint16_t sub_device,
    SingleUseCallback2<void, const ResponseStatus&, bool> *callback,
    string *error) {
  if (CheckCallback(error, callback))
    return false;
  if (CheckNotBroadcast(uid, error, callback))
    return false;
  if (CheckValidSubDevice(sub_device, false, error, callback))
    return false;

  RDMAPIImplInterface::rdm_callback *cb = NewSingleCallback(
    this,
    &RDMAPI::_HandleBoolResponse,
    callback);
  return CheckReturnStatus(
    m_impl->RDMGet(cb,
                   universe,
                   uid,
                   sub_device,
                   PID_IDENTIFY_DEVICE),
    error);
}


/*
 * @brief Change the identify state for a device
 * @param universe the universe to perform the call on
 * @param uid the UID to fetch the outstanding message count for
 * @param sub_device the sub device to use
 * @param mode the identify mode to set
 * @param callback the callback to invoke when this request completes
 * @param error a pointer to a string which is set if an error occurs
 * @return true if the request is sent correctly, false otherwise
*/
bool RDMAPI::IdentifyDevice(
    unsigned int universe,
    const UID &uid,
    uint16_t sub_device,
    bool mode,
    SingleUseCallback1<void, const ResponseStatus&> *callback,
    string *error) {
  if (CheckCallback(error, callback))
    return false;
  if (CheckValidSubDevice(sub_device, true, error, callback))
    return false;

  RDMAPIImplInterface::rdm_callback *cb = NewSingleCallback(
    this,
    &RDMAPI::_HandleEmptyResponse,
    callback);
  uint8_t option = mode;
  return CheckReturnStatus(
    m_impl->RDMSet(cb,
                   universe,
                   uid,
                   sub_device,
                   PID_IDENTIFY_DEVICE,
                   &option,
                   sizeof(option)),
    error);
}


/*
 * @brief Reset a device
 * @param universe the universe to perform the call on
 * @param uid the UID to fetch the outstanding message count for
 * @param sub_device the sub device to use
 * @param warm_reset true for a warm reset, false for a cold reset
 * @param callback the callback to invoke when this request completes
 * @param error a pointer to a string which is set if an error occurs
 * @return true if the request is sent correctly, false otherwise
*/
bool RDMAPI::ResetDevice(
    unsigned int universe,
    const UID &uid,
    uint16_t sub_device,
    bool warm_reset,
    SingleUseCallback1<void, const ResponseStatus&> *callback,
    string *error) {
  if (CheckCallback(error, callback))
    return false;
  if (CheckValidSubDevice(sub_device, true, error, callback))
    return false;

  RDMAPIImplInterface::rdm_callback *cb = NewSingleCallback(
    this,
    &RDMAPI::_HandleEmptyResponse,
    callback);
  uint8_t option = warm_reset ? RESET_WARM : RESET_COLD;
  return CheckReturnStatus(
    m_impl->RDMSet(cb,
                   universe,
                   uid,
                   sub_device,
                   PID_RESET_DEVICE,
                   &option,
                   sizeof(option)),
    error);
}


/*
 * @brief Get the power state for a device
 * @param universe the universe to perform the call on
 * @param uid the UID to fetch the outstanding message count for
 * @param sub_device the sub device to use
 * @param callback the callback to invoke when this request completes
 * @param error a pointer to a string which is set if an error occurs
 * @return true if the request is sent correctly, false otherwise
*/
bool RDMAPI::GetPowerState(
    unsigned int universe,
    const UID &uid,
    uint16_t sub_device,
    SingleUseCallback2<void, const ResponseStatus&, uint8_t> *callback,
    string *error) {
  if (CheckCallback(error, callback))
    return false;
  if (CheckNotBroadcast(uid, error, callback))
    return false;
  if (CheckValidSubDevice(sub_device, false, error, callback))
    return false;

  RDMAPIImplInterface::rdm_callback *cb = NewSingleCallback(
    this,
    &RDMAPI::_HandleU8Response,
    callback);
  return CheckReturnStatus(
    m_impl->RDMGet(cb,
                   universe,
                   uid,
                   sub_device,
                   PID_POWER_STATE),
    error);
}


/*
 * @brief Set the power state for a device.
 * @param universe the universe to perform the call on
 * @param uid the UID to fetch the outstanding message count for
 * @param sub_device the sub device to use
 * @param power_state the new power state
 * @param callback the callback to invoke when this request completes
 * @param error a pointer to a string which is set if an error occurs
 * @return true if the request is sent correctly, false otherwise
*/
bool RDMAPI::SetPowerState(
    unsigned int universe,
    const UID &uid,
    uint16_t sub_device,
    rdm_power_state power_state,
    SingleUseCallback1<void, const ResponseStatus&> *callback,
    string *error) {
  if (CheckCallback(error, callback))
    return false;
  if (CheckValidSubDevice(sub_device, true, error, callback))
    return false;

  RDMAPIImplInterface::rdm_callback *cb = NewSingleCallback(
    this,
    &RDMAPI::_HandleEmptyResponse,
    callback);
  uint8_t option = static_cast<uint8_t>(power_state);
  return CheckReturnStatus(
    m_impl->RDMSet(cb,
                   universe,
                   uid,
                   sub_device,
                   PID_POWER_STATE,
                   &option,
                   sizeof(option)),
    error);
}


/*
 * @brief Set the reset device for a device.
 * @param universe the universe to perform the call on
 * @param uid the UID to fetch the outstanding message count for
 * @param sub_device the sub device to use
 * @param reset_device the new reset device
 * @param callback the callback to invoke when this request completes
 * @param error a pointer to a string which is set if an error occurs
 * @return true if the request is sent correctly, false otherwise
*/
bool RDMAPI::SetResetDevice(
    unsigned int universe,
    const UID &uid,
    uint16_t sub_device,
    rdm_reset_device_mode reset_device,
    SingleUseCallback1<void, const ResponseStatus&> *callback,
    string *error) {
  if (CheckCallback(error, callback))
    return false;
  if (CheckValidSubDevice(sub_device, true, error, callback))
    return false;

  RDMAPIImplInterface::rdm_callback *cb = NewSingleCallback(
    this,
    &RDMAPI::_HandleEmptyResponse,
    callback);
  uint8_t option = static_cast<uint8_t>(reset_device);
  return CheckReturnStatus(
    m_impl->RDMSet(cb,
                   universe,
                   uid,
                   sub_device,
                   PID_RESET_DEVICE,
                   &option,
                   sizeof(option)),
    error);
}


/*
 * @brief Fetch the DNS hostname
 * @param universe the universe to perform the call on
 * @param uid the UID to fetch the DNS hostname for
 * @param sub_device the sub device to use
 * @param callback the callback to invoke when this request completes
 * @param error a pointer to a string which is set if an error occurs
 * @return true if the request is sent correctly, false otherwise
 */
bool RDMAPI::GetDnsHostname(
    unsigned int universe,
    const UID &uid,
    uint16_t sub_device,
    SingleUseCallback2<void,
                       const ResponseStatus&,
                       const string&> *callback,
    string *error) {
  if (CheckCallback(error, callback)) {
    return false;
  }
  if (CheckNotBroadcast(uid, error, callback)) {
    return false;
  }
  if (CheckValidSubDevice(sub_device, false, error, callback)) {
    return false;
  }

  RDMAPIImplInterface::rdm_callback *cb = NewSingleCallback(
    this,
    &RDMAPI::_HandleCustomLengthLabelResponse,
    callback,
    MAX_RDM_HOSTNAME_LENGTH);
  return CheckReturnStatus(
    m_impl->RDMGet(cb,
                   universe,
                   uid,
                   sub_device,
                   PID_DNS_HOSTNAME),
    error);
}


/*
 * @brief Set the DNS hostname
 * @param universe the universe to perform the call on
 * @param uid the UID to set the DNS hostname for
 * @param sub_device the sub device to use
 * @param callback the callback to invoke when this request completes
 * @param error a pointer to a string which is set if an error occurs
 * @return true if the request is sent correctly, false otherwise
 */
bool RDMAPI::SetDnsHostname(
    unsigned int universe,
    const UID &uid,
    uint16_t sub_device,
    const string &label,
    SingleUseCallback1<void, const ResponseStatus&> *callback,
    string *error) {
  if (CheckCallback(error, callback)) {
    return false;
  }
  // It doesn't really make sense to broadcast this but allow it anyway
  if (CheckValidSubDevice(sub_device, true, error, callback)) {
    return false;
  }

  RDMAPIImplInterface::rdm_callback *cb = NewSingleCallback(
    this,
    &RDMAPI::_HandleEmptyResponse,
    callback);
  return CheckReturnStatus(
    m_impl->RDMSet(cb,
                   universe,
                   uid,
                   sub_device,
                   PID_DNS_HOSTNAME,
                   reinterpret_cast<const uint8_t*>(label.data()),
                   label.size()),
    error);
}


/*
 * @brief Fetch the DNS domain name
 * @param universe the universe to perform the call on
 * @param uid the UID to fetch the DNS domain name for
 * @param sub_device the sub device to use
 * @param callback the callback to invoke when this request completes
 * @param error a pointer to a string which is set if an error occurs
 * @return true if the request is sent correctly, false otherwise
 */
bool RDMAPI::GetDnsDomainName(
    unsigned int universe,
    const UID &uid,
    uint16_t sub_device,
    SingleUseCallback2<void,
                       const ResponseStatus&,
                       const string&> *callback,
    string *error) {
  if (CheckCallback(error, callback)) {
    return false;
  }
  if (CheckNotBroadcast(uid, error, callback)) {
    return false;
  }
  if (CheckValidSubDevice(sub_device, false, error, callback)) {
    return false;
  }

  RDMAPIImplInterface::rdm_callback *cb = NewSingleCallback(
    this,
    &RDMAPI::_HandleCustomLengthLabelResponse,
    callback,
    MAX_RDM_DOMAIN_NAME_LENGTH);
  return CheckReturnStatus(
    m_impl->RDMGet(cb,
                   universe,
                   uid,
                   sub_device,
                   PID_DNS_DOMAIN_NAME),
    error);
}


/*
 * @brief Set the DNS domain name
 * @param universe the universe to perform the call on
 * @param uid the UID to set the DNS domain name for
 * @param sub_device the sub device to use
 * @param callback the callback to invoke when this request completes
 * @param error a pointer to a string which is set if an error occurs
 * @return true if the request is sent correctly, false otherwise
 */
bool RDMAPI::SetDnsDomainName(
    unsigned int universe,
    const UID &uid,
    uint16_t sub_device,
    const string &label,
    SingleUseCallback1<void, const ResponseStatus&> *callback,
    string *error) {
  if (CheckCallback(error, callback)) {
    return false;
  }

  if (CheckValidSubDevice(sub_device, true, error, callback)) {
    return false;
  }

  RDMAPIImplInterface::rdm_callback *cb = NewSingleCallback(
    this,
    &RDMAPI::_HandleEmptyResponse,
    callback);
  return CheckReturnStatus(
    m_impl->RDMSet(cb,
                   universe,
                   uid,
                   sub_device,
                   PID_DNS_DOMAIN_NAME,
                   reinterpret_cast<const uint8_t*>(label.data()),
                   label.size()),
    error);
}

/*
 * @brief Fetch the dimmer curve
 * @param universe the universe to perform the call on
 * @param uid the UID to fetch the dimmer curve information for
 * @param sub_device the sub device to use
 * @param callback the callback to invoke when this request completes
 * @param error a pointer to a string which is set if an error occurs
 * @return true if the request is sent correctly, false otherwise
 */
bool RDMAPI::GetCurve(
    unsigned int universe,
    const UID &uid,
    uint16_t sub_device,
    SingleUseCallback3<void,
                       const ResponseStatus&,
                       uint8_t,
                       uint8_t> *callback,
    string *error) {
  if (CheckCallback(error, callback)) {
    return false;
  }
  if (CheckNotBroadcast(uid, error, callback)) {
    return false;
  }
  if (CheckValidSubDevice(sub_device, false, error, callback)) {
    return false;
  }

  RDMAPIImplInterface::rdm_callback *cb = NewSingleCallback(
    this,
    &RDMAPI::_HandleGetCurve,
    callback);
  return CheckReturnStatus(
    m_impl->RDMGet(cb,
                   universe,
                   uid,
                   sub_device,
                   PID_CURVE),
    error);
}

/*
 * @brief Set the dimmer curve
 * @param universe the universe to perform the call on
 * @param uid the UID to set the dimmer curve for
 * @param sub_device the sub device to use
 * @param curve the index of the curve to set
 * @param callback the callback to invoke when this request completes
 * @param error a pointer to a string which is set if an error occurs
 * @return true if the request is sent correctly, false otherwise
 */
bool RDMAPI::SetCurve(
    unsigned int universe,
    const UID &uid,
    uint16_t sub_device,
    uint8_t curve,
    SingleUseCallback1<void, const ResponseStatus&> *callback,
    string *error) {
  if (CheckCallback(error, callback)) {
    return false;
  }

  if (CheckValidSubDevice(sub_device, true, error, callback)) {
    return false;
  }

  RDMAPIImplInterface::rdm_callback *cb = NewSingleCallback(
    this,
    &RDMAPI::_HandleEmptyResponse,
    callback);
  return CheckReturnStatus(
    m_impl->RDMSet(cb,
                   universe,
                   uid,
                   sub_device,
                   PID_CURVE,
                   &curve,
                   sizeof(curve)),
    error);
}

/*
 * @brief Fetch the dimmer curve description (name)
 * @param universe the universe to perform the call on
 * @param uid the UID to fetch the dimmer curve description for
 * @param sub_device the sub device to use
 * @param curve the id of the curve to fetch the description for
 * @param callback the callback to invoke when this request completes
 * @param error a pointer to a string which is set if an error occurs
 * @return true if the request is sent correctly, false otherwise
 */
bool RDMAPI::GetCurveDescription(
    unsigned int universe,
    const UID &uid,
    uint16_t sub_device,
    uint8_t curve,
    SingleUseCallback3<void,
                       const ResponseStatus&,
                       uint8_t,
                       const string&> *callback,
    string *error) {
  if (CheckCallback(error, callback)) {
    return false;
  }
  if (CheckNotBroadcast(uid, error, callback)) {
    return false;
  }
  if (CheckValidSubDevice(sub_device, false, error, callback)) {
    return false;
  }

  RDMAPIImplInterface::rdm_callback *cb = NewSingleCallback(
    this,
    &RDMAPI::_HandleGetCurveDescription,
    callback);
  return CheckReturnStatus(
    m_impl->RDMGet(cb,
                   universe,
                   uid,
                   sub_device,
                   PID_CURVE_DESCRIPTION,
                   &curve,
                   sizeof(curve)),
    error);
}

/*
 * @brief Fetch the dimmer info
 * @param universe the universe to perform the call on
 * @param uid the UID to fetch the dimmer info for
 * @param sub_device the sub device to use
 * @param callback the callback to invoke when this request completes
 * @param error a pointer to a string which is set if an error occurs
 * @return true if the request is sent correctly, false otherwise
 */
bool RDMAPI::GetDimmerInfo(
    unsigned int universe,
    const UID &uid,
    uint16_t sub_device,
    SingleUseCallback2<void,
                       const ResponseStatus&,
                       const DimmerInfoDescriptor&> *callback,
    string *error) {
  if (CheckCallback(error, callback)) {
    return false;
  }

  if (CheckNotBroadcast(uid, error, callback)) {
    return false;
  }

  if (CheckValidSubDevice(sub_device, false, error, callback)) {
    return false;
  }

  RDMAPIImplInterface::rdm_callback *cb = NewSingleCallback(
    this,
    &RDMAPI::_HandleGetDimmerInfo,
    callback);
  return CheckReturnStatus(
    m_impl->RDMGet(cb,
                   universe,
                   uid,
                   sub_device,
                   PID_DIMMER_INFO),
    error);
}

/*
 * @brief Fetch the dimmer minimum levels
 * @param universe the universe to perform the call on
 * @param uid the UID to fetch the dimmer info for
 * @param sub_device the sub device to use
 * @param callback the callback to invoke when this request completes
 * @param error a pointer to a string which is set if an error occurs
 * @return true if the request is sent correctly, false otherwise
 */
bool RDMAPI::GetDimmerMinimumLevels(
    unsigned int universe,
    const UID &uid,
    uint16_t sub_device,
    SingleUseCallback2<void,
                       const ResponseStatus&,
                       const DimmerMinimumDescriptor&> *callback,
    string *error) {
  if (CheckCallback(error, callback)) {
    return false;
  }

  if (CheckNotBroadcast(uid, error, callback)) {
    return false;
  }

  if (CheckValidSubDevice(sub_device, false, error, callback)) {
    return false;
  }

  RDMAPIImplInterface::rdm_callback *cb = NewSingleCallback(
    this,
    &RDMAPI::_HandleGetDimmerMinimumLevels,
    callback);
  return CheckReturnStatus(
    m_impl->RDMGet(cb,
                   universe,
                   uid,
                   sub_device,
                   PID_MINIMUM_LEVEL),
    error);
}

/*
 * @brief Set the dimmer minimum levels
 * @param universe the universe to perform the call on
 * @param uid the UID to set the dimmer curve for
 * @param sub_device the sub device to use
 * @param min_increasing the value for dimmer minimum while increasing
 * @param min_decreasing the value for dimmer minimum while decreasing
 * @param on_below_min the value set to either true or false to indicate whether
 *        or not the dimmer stays on when minimum is exceeded
 * @param callback the callback to invoke when this request completes
 * @param error a pointer to a string which is set if an error occurs
 * @return true if the request is sent correctly, false otherwise
 */
bool RDMAPI::SetDimmerMinimumLevels(
    unsigned int universe,
    const UID &uid,
    uint16_t sub_device,
    uint16_t min_increasing,
    uint16_t min_decreasing,
    bool on_below_min,
    SingleUseCallback1<void, const ResponseStatus&> *callback,
    string *error) {
  if (CheckCallback(error, callback)) {
    return false;
  }

  if (CheckValidSubDevice(sub_device, true, error, callback)) {
    return false;
  }

  PACK(
  struct minimum_levels {
    uint16_t min_increasing;
    uint16_t min_decreasing;
    uint8_t on_below_min;
  });
  STATIC_ASSERT(sizeof(minimum_levels) == 5);
  struct minimum_levels raw_levels;

  raw_levels.min_increasing = HostToNetwork(min_increasing);
  raw_levels.min_decreasing = HostToNetwork(min_decreasing);
  raw_levels.on_below_min = on_below_min;

  RDMAPIImplInterface::rdm_callback *cb = NewSingleCallback(
    this,
    &RDMAPI::_HandleEmptyResponse,
    callback);
  return CheckReturnStatus(
    m_impl->RDMSet(cb,
                   universe,
                   uid,
                   sub_device,
                   PID_MINIMUM_LEVEL,
                   reinterpret_cast<const uint8_t*>(&raw_levels),
                   sizeof(raw_levels)),
    error);
}

/*
 * @brief Fetch the dimmer maximum level
 * @param universe the universe to perform the call on
 * @param uid the UID to fetch the dimmer info for
 * @param sub_device the sub device to use
 * @param callback the callback to invoke when this request completes
 * @param error a pointer to a string which is set if an error occurs
 * @return true if the request is sent correctly, false otherwise
 */
bool RDMAPI::GetDimmerMaximumLevel(
    unsigned int universe,
    const UID &uid,
    uint16_t sub_device,
    SingleUseCallback2<void, const ResponseStatus&, uint16_t> *callback,
    string *error) {

  return GenericGetU16(
      universe,
      uid,
      sub_device,
      callback,
      PID_MAXIMUM_LEVEL,
      error);
}

/*
 * @brief Set the dimmer maximum level
 * @param universe the universe to perform the call on
 * @param uid the UID to fetch the outstanding message count for
 * @param sub_device the sub device to use
 * @param maximum_level the new maximum level
 * @param callback the callback to invoke when this request completes
 * @param error a pointer to a string which is set if an error occurs
 * @return true if the request is sent correctly, false otherwise
 */
bool RDMAPI::SetDimmerMaximumLevel(
    unsigned int universe,
    const UID &uid,
    uint16_t sub_device,
    uint16_t maximum_level,
    SingleUseCallback1<void, const ResponseStatus&> *callback,
    string *error) {

  return GenericSetU16(
      universe,
      uid,
      sub_device,
      maximum_level,
      callback,
      PID_MAXIMUM_LEVEL,
      error);
}

/*
 * @brief Check if a device is in self test mode.
 * @param universe the universe to perform the call on
 * @param uid the UID to fetch the outstanding message count for
 * @param sub_device the sub device to use
 * @param callback the callback to invoke when this request completes
 * @param error a pointer to a string which is set if an error occurs
 * @return true if the request is sent correctly, false otherwise
*/
bool RDMAPI::SelfTestEnabled(
    unsigned int universe,
    const UID &uid,
    uint16_t sub_device,
    SingleUseCallback2<void, const ResponseStatus&, bool> *callback,
    string *error) {
  if (CheckCallback(error, callback))
    return false;
  if (CheckNotBroadcast(uid, error, callback))
    return false;
  if (CheckValidSubDevice(sub_device, false, error, callback))
    return false;

  RDMAPIImplInterface::rdm_callback *cb = NewSingleCallback(
    this,
    &RDMAPI::_HandleBoolResponse,
    callback);
  return CheckReturnStatus(
    m_impl->RDMGet(cb,
                   universe,
                   uid,
                   sub_device,
                   PID_PERFORM_SELFTEST),
    error);
}


/*
 * @brief Perform a self test on a device.
 * @param universe the universe to perform the call on
 * @param uid the UID to fetch the outstanding message count for
 * @param sub_device the sub device to use
 * @param self_test_number the number of the self test to perform.
 * @param callback the callback to invoke when this request completes
 * @param error a pointer to a string which is set if an error occurs
 * @return true if the request is sent correctly, false otherwise
*/
bool RDMAPI::PerformSelfTest(
    unsigned int universe,
    const UID &uid,
    uint16_t sub_device,
    uint8_t self_test_number,
    SingleUseCallback1<void, const ResponseStatus&> *callback,
    string *error) {
  if (CheckCallback(error, callback))
    return false;
  if (CheckValidSubDevice(sub_device, true, error, callback))
    return false;

  RDMAPIImplInterface::rdm_callback *cb = NewSingleCallback(
    this,
    &RDMAPI::_HandleEmptyResponse,
    callback);
  return CheckReturnStatus(
    m_impl->RDMSet(cb,
                   universe,
                   uid,
                   sub_device,
                   PID_PERFORM_SELFTEST,
                   &self_test_number,
                   sizeof(self_test_number)),
    error);
}


/*
 * @brief Fetch the description of a self test.
 * @param universe the universe to perform the call on
 * @param uid the UID to fetch the outstanding message count for
 * @param sub_device the sub device to use
 * @param self_test_number the number of the self test to fetch the description
 *   of.
 * @param callback the callback to invoke when this request completes
 * @param error a pointer to a string which is set if an error occurs
 * @return true if the request is sent correctly, false otherwise
*/
bool RDMAPI::SelfTestDescription(
    unsigned int universe,
    const UID &uid,
    uint16_t sub_device,
    uint8_t self_test_number,
    SingleUseCallback3<void, const ResponseStatus&, uint8_t,
                       const string&> *callback,
    string *error) {
  if (CheckCallback(error, callback))
    return false;
  if (CheckNotBroadcast(uid, error, callback))
    return false;
  if (CheckValidSubDevice(sub_device, false, error, callback))
    return false;

  RDMAPIImplInterface::rdm_callback *cb = NewSingleCallback(
    this,
    &RDMAPI::_HandleSelfTestDescription,
    callback);
  return CheckReturnStatus(
    m_impl->RDMGet(cb,
                   universe,
                   uid,
                   sub_device,
                   PID_SELF_TEST_DESCRIPTION,
                   &self_test_number,
                   sizeof(self_test_number)),
    error);
}


/*
 * @brief Capture the current state into a preset.
 * @param universe the universe to perform the call on
 * @param uid the UID to fetch the outstanding message count for
 * @param sub_device the sub device to use
 * @param scene the number of the preset scene to store
 * @param fade_up_time the time in 10s of a second to fade up this scene.
 * @param fade_down_time the time in 10s of a second to fade down the previous
 *   scene.
 * @param wait_time the time in 10s of a second to hold this scene when the
 *   playback mode is PRESET_PLAYBACK_ALL
 * @param callback the callback to invoke when this request completes
 * @param error a pointer to a string which is set if an error occurs
 * @return true if the request is sent correctly, false otherwise
*/
bool RDMAPI::CapturePreset(
    unsigned int universe,
    const UID &uid,
    uint16_t sub_device,
    uint16_t scene,
    uint16_t fade_up_time,
    uint16_t fade_down_time,
    uint16_t wait_time,
    SingleUseCallback1<void, const ResponseStatus&> *callback,
    string *error) {
  if (CheckCallback(error, callback))
    return false;
  if (CheckValidSubDevice(sub_device, true, error, callback))
    return false;

  PACK(
  struct preset_config {
    uint16_t scene;
    uint16_t fade_up_time;
    uint16_t fade_down_time;
    uint16_t wait_time;
  });
  STATIC_ASSERT(sizeof(preset_config) == 8);
  struct preset_config raw_config;

  raw_config.scene = HostToNetwork(scene);
  raw_config.fade_up_time = HostToNetwork(fade_up_time);
  raw_config.fade_down_time = HostToNetwork(fade_down_time);
  raw_config.wait_time = HostToNetwork(wait_time);

  RDMAPIImplInterface::rdm_callback *cb = NewSingleCallback(
    this,
    &RDMAPI::_HandleEmptyResponse,
    callback);
  return CheckReturnStatus(
    m_impl->RDMSet(cb,
                   universe,
                   uid,
                   sub_device,
                   PID_CAPTURE_PRESET,
                   reinterpret_cast<const uint8_t*>(&raw_config),
                   sizeof(raw_config)),
    error);
}


/*
 * @brief Fetch the current playback mode.
 * @param universe the universe to perform the call on
 * @param uid the UID to fetch the outstanding message count for
 * @param sub_device the sub device to use
 * @param callback the callback to invoke when this request completes
 * @param error a pointer to a string which is set if an error occurs
 * @return true if the request is sent correctly, false otherwise
*/
bool RDMAPI::PresetPlaybackMode(
    unsigned int universe,
    const UID &uid,
    uint16_t sub_device,
    SingleUseCallback3<void,
                       const ResponseStatus&,
                       uint16_t,
                       uint8_t> *callback,
    string *error) {
  if (CheckCallback(error, callback))
    return false;
  if (CheckNotBroadcast(uid, error, callback))
    return false;
  if (CheckValidSubDevice(sub_device, false, error, callback))
    return false;

  RDMAPIImplInterface::rdm_callback *cb = NewSingleCallback(
    this,
    &RDMAPI::_HandlePlaybackMode,
    callback);
  return CheckReturnStatus(
    m_impl->RDMGet(cb,
                   universe,
                   uid,
                   sub_device,
                   PID_PRESET_PLAYBACK,
                   NULL,
                   0),
    error);
}


/*
 * @brief Set the current playback mode.
 * @param universe the universe to perform the call on
 * @param uid the UID to fetch the outstanding message count for
 * @param sub_device the sub device to use
 * @param playback_mode the playback scene to use, PRESET_PLAYBACK_OFF or
 *   PRESET_PLAYBACK_ALL.
 * @param level the level to use for the scene.
 * @param callback the callback to invoke when this request completes
 * @param error a pointer to a string which is set if an error occurs
 * @return true if the request is sent correctly, false otherwise
*/
bool RDMAPI::SetPresetPlaybackMode(
    unsigned int universe,
    const UID &uid,
    uint16_t sub_device,
    uint16_t playback_mode,
    uint8_t level,
    SingleUseCallback1<void, const ResponseStatus&> *callback,
    string *error) {

  if (CheckCallback(error, callback))
    return false;
  if (CheckValidSubDevice(sub_device, true, error, callback))
    return false;

  PACK(
  struct preset_config {
    uint16_t mode;
    uint8_t level;
  });
  STATIC_ASSERT(sizeof(preset_config) == 3);
  struct preset_config raw_config;

  raw_config.mode = HostToNetwork(playback_mode);
  raw_config.level = level;

  RDMAPIImplInterface::rdm_callback *cb = NewSingleCallback(
    this,
    &RDMAPI::_HandleEmptyResponse,
    callback);
  return CheckReturnStatus(
    m_impl->RDMSet(cb,
                   universe,
                   uid,
                   sub_device,
                   PID_PRESET_PLAYBACK,
                   reinterpret_cast<const uint8_t*>(&raw_config),
                   sizeof(raw_config)),
    error);
}


// Handlers follow. These are invoked by the RDMAPIImpl when responses arrive
// ----------------------------------------------------------------------------

/*
 * @brief Handle a response that contains a custom length ASCII string
 */
void RDMAPI::_HandleCustomLengthLabelResponse(
    SingleUseCallback2<void,
                       const ResponseStatus&,
                       const string&> *callback,
    uint8_t max_length,
    const ResponseStatus &status,
    const string &data) {
  ResponseStatus response_status = status;
  if (status.WasAcked() && data.size() > max_length) {
    std::ostringstream str;
    str << "PDL needs to be <= " << static_cast<int>(max_length) << ", was "
        << data.size();
    response_status.error = str.str();
  }

  string label = data;
  ShortenString(&label);
  callback->Run(response_status, label);
}


/*
 * @brief Handle a response that contains a 32 byte ASCII string
 */
void RDMAPI::_HandleLabelResponse(
    SingleUseCallback2<void,
                       const ResponseStatus&,
                       const string&> *callback,
    const ResponseStatus &status,
    const string &data) {
  _HandleCustomLengthLabelResponse(callback,
                                   MAX_RDM_STRING_LENGTH,
                                   status,
                                   data);
}


/*
 * @brief Handle a response that contains a bool
 */
void RDMAPI::_HandleBoolResponse(
    SingleUseCallback2<void,
                       const ResponseStatus&,
                       bool> *callback,
    const ResponseStatus &status,
    const string &data) {
  static const unsigned int DATA_SIZE = 1;
  ResponseStatus response_status = status;
  bool option = false;

  if (response_status.WasAcked()) {
    if (data.size() == DATA_SIZE) {
      option = data.data()[0];
    } else {
      SetIncorrectPDL(&response_status, data.size(), DATA_SIZE);
    }
  }
  callback->Run(response_status, option);
}


/*
 * @brief Handle a response that contains a uint8_t
 */
void RDMAPI::_HandleU8Response(
    SingleUseCallback2<void,
                       const ResponseStatus&,
                       uint8_t> *callback,
    const ResponseStatus &status,
    const string &data) {
  ResponseStatus response_status = status;
  uint8_t value = 0;

  if (response_status.WasAcked()) {
    if (data.size() == sizeof(value)) {
      value = data.data()[0];
    } else {
      SetIncorrectPDL(&response_status, data.size(), sizeof(value));
    }
  }
  callback->Run(response_status, value);
}

/*
 * @brief Handle a response that contains a uint16_t
 */
void RDMAPI::_HandleU16Response(
    SingleUseCallback2<void,
                       const ResponseStatus&,
                       uint16_t> *callback,
    const ResponseStatus &status,
    const string &data) {
  ResponseStatus response_status = status;
  uint16_t value = 0;

  if (response_status.WasAcked()) {
    if (data.size() == sizeof(value)) {
      const uint16_t *ptr = reinterpret_cast<const uint16_t*>(data.data());
      value = NetworkToHost(*ptr);
    } else {
      SetIncorrectPDL(&response_status, data.size(), sizeof(value));
    }
  }
  callback->Run(response_status, value);
}


/*
 * @brief Handle a response that contains a uint32_t
 */
void RDMAPI::_HandleU32Response(
    SingleUseCallback2<void,
                       const ResponseStatus&,
                       uint32_t> *callback,
    const ResponseStatus &status,
    const string &data) {
  ResponseStatus response_status = status;
  uint32_t value = 0;

  if (response_status.WasAcked()) {
    if (data.size() == sizeof(value)) {
      const uint32_t *ptr = reinterpret_cast<const uint32_t*>(data.data());
      value = NetworkToHost(*ptr);
    } else {
      SetIncorrectPDL(&response_status, data.size(), sizeof(value));
    }
  }
  callback->Run(response_status, value);
}


/*
 * @brief Handle a response that doesn't contain any data
 */
void RDMAPI::_HandleEmptyResponse(
    SingleUseCallback1<void, const ResponseStatus&> *callback,
    const ResponseStatus &status,
    const string &data) {
  ResponseStatus response_status = status;
  if (response_status.WasAcked() && !data.empty())
    SetIncorrectPDL(&response_status, data.size(), 0);
  callback->Run(response_status);
}


/*
 * @brief Handle a PROXIED_DEVICE_COUNT get response
 */
void RDMAPI::_HandleGetProxiedDeviceCount(
    SingleUseCallback3<void,
                       const ResponseStatus&,
                       uint16_t,
                       bool> *callback,
    const ResponseStatus &status,
    const string &data) {
  static const unsigned int DATA_SIZE = 3;
  ResponseStatus response_status = status;

  uint16_t device_count = 0;
  bool list_change = false;

  if (response_status.WasAcked()) {
    if (data.size() >= DATA_SIZE) {
      struct {
        uint16_t device_count;
        uint8_t list_change;
      } unpacked_data;
      memcpy(&unpacked_data, data.data(), DATA_SIZE);
      device_count = NetworkToHost(unpacked_data.device_count);
      list_change = unpacked_data.list_change;
    } else {
      SetIncorrectPDL(&response_status, data.size(), DATA_SIZE);
    }
  }
  callback->Run(response_status, device_count, list_change);
}


/*
 * @brief Handle a PROXIED_DEVICES get response
 */
void RDMAPI::_HandleGetProxiedDevices(
    SingleUseCallback2<void,
                       const ResponseStatus&,
                       const vector<UID>&> *callback,
    const ResponseStatus &status,
    const string &data) {
  ResponseStatus response_status = status;
  vector<UID> uids;

  unsigned int data_size = data.size();
  if (response_status.WasAcked()) {
    if (data_size % UID::UID_SIZE == 0) {
      const uint8_t *start = reinterpret_cast<const uint8_t*>(data.data());
      for (const uint8_t *ptr = start; ptr < start + data_size;
           ptr += UID::UID_SIZE) {
        UID uid(ptr);
        uids.push_back(uid);
      }
    } else {
      response_status.error = ("PDL size not a multiple of " +
          IntToString(static_cast<int>(UID::UID_SIZE)) + " : " +
          IntToString(static_cast<int>(data_size)));
    }
  }
  callback->Run(response_status, uids);
}


/*
 * @brief Handle a get COMMS_STATUS response
 */
void RDMAPI::_HandleGetCommStatus(
    SingleUseCallback4<void,
                       const ResponseStatus&,
                       uint16_t,
                       uint16_t,
                       uint16_t> *callback,
    const ResponseStatus &status,
    const string &data) {
  static const unsigned int DATA_SIZE = 6;
  ResponseStatus response_status = status;

  uint16_t short_message = 0, length_mismatch = 0, checksum_fail = 0;

  if (response_status.WasAcked()) {
    if (data.size() >= DATA_SIZE) {
      struct {
        uint16_t short_message;
        uint16_t length_mismatch;
        uint16_t checksum_fail;
      } unpacked_data;
      memcpy(&unpacked_data, data.data(), DATA_SIZE);
      short_message = NetworkToHost(unpacked_data.short_message);
      length_mismatch = NetworkToHost(unpacked_data.length_mismatch);
      checksum_fail = NetworkToHost(unpacked_data.checksum_fail);
    } else {
      SetIncorrectPDL(&response_status, data.size(), DATA_SIZE);
    }
  }
  callback->Run(response_status, short_message, length_mismatch,
                checksum_fail);
}


/*
 * @brief Handle a QUEUED_MESSAGE response
 */
void RDMAPI::_HandleQueuedMessage(
    QueuedMessageHandler *handler,
    const ResponseStatus &status,
    uint16_t pid,
    const string &data) {

  // now we need to switch on pid, and dispatch to the handler
  // we should also pass the uid here
  handler->DefaultHandler(status, pid, data);
}


/*
 * @brief Handle a STATUS_MESSAGES response
 */
void RDMAPI::_HandleGetStatusMessage(
    SingleUseCallback2<void,
                       const ResponseStatus&,
                       const vector<StatusMessage>&> *callback,
    const ResponseStatus &status,
    const string &data) {

  // Seriously WTF, learn how to align data structures
  struct status_message {
    uint8_t sub_device_hi;
    uint8_t sub_device_lo;
    uint8_t status_type;
    uint8_t message_id_hi;
    uint8_t message_id_lo;
    uint8_t value_1_hi;
    uint8_t value_1_lo;
    uint8_t value_2_hi;
    uint8_t value_2_lo;
  } message;

  ResponseStatus response_status = status;
  vector<StatusMessage> messages;
  unsigned int data_size = data.size();

  if (response_status.WasAcked()) {
    if (data_size % sizeof(message) == 0) {
      const uint8_t *start = reinterpret_cast<const uint8_t*>(data.data());
      for (const uint8_t *ptr = start; ptr < start + data_size;
           ptr += sizeof(message)) {
        memcpy(&message, ptr, sizeof(message));
        StatusMessage msg_object;
        msg_object.sub_device = (message.sub_device_hi << 8) +
            message.sub_device_lo;
        msg_object.status_message_id = (message.message_id_hi << 8) +
            message.message_id_lo;
        msg_object.value1 = (message.value_1_hi << 8) + message.value_1_lo;
        msg_object.value2 = (message.value_2_hi << 8) + message.value_2_lo;
        msg_object.status_type = message.status_type;
        messages.push_back(msg_object);
      }
    } else {
      response_status.error = ("PDL size not a multiple of " +
          IntToString(static_cast<int>(sizeof(message))) + " : " +
          IntToString(static_cast<int>(data_size)));
    }
  }
  callback->Run(response_status, messages);
}


/*
 * @brief Handle a get SUB_DEVICE_STATUS_REPORT_THRESHOLD message
 */
void RDMAPI::_HandleGetSubDeviceReporting(
    SingleUseCallback2<void,
                       const ResponseStatus&,
                       uint8_t> *callback,
    const ResponseStatus &status,
    const string &data) {
  ResponseStatus response_status = status;
  uint8_t status_type = 0;

  if (response_status.WasAcked()) {
    if (data.size() == sizeof(status_type)) {
      status_type = data.data()[0];
    } else {
      SetIncorrectPDL(&response_status, data.size(), sizeof(status_type));
    }
  }
  callback->Run(response_status, status_type);
}


/*
 * @brief Handle a SUPPORTED_PARAMETERS Get command
 */
void RDMAPI::_HandleGetSupportedParameters(
    SingleUseCallback2<void,
                       const ResponseStatus&,
                       const vector<uint16_t>&> *callback,
    const ResponseStatus &status,
    const string &data) {
  ResponseStatus response_status = status;
  vector<uint16_t> pids;

  unsigned int data_size = data.size();
  if (response_status.WasAcked()) {
    if (data_size % 2 == 0) {
      const uint16_t *start = reinterpret_cast<const uint16_t*>(data.data());
      const uint16_t *end = start + (data_size / sizeof(*start));
      for (const uint16_t *ptr = start; ptr < end; ptr++) {
        pids.push_back(NetworkToHost(*ptr));
      }
    } else {
      response_status.error = ("PDL size not a multiple of 2 : " +
          IntToString(static_cast<int>(data_size)));
    }
    sort(pids.begin(), pids.end());
  }
  callback->Run(response_status, pids);
}


/*
 * @brief Handle a PARAMETER_DESCRIPTION message
 */
void RDMAPI::_HandleGetParameterDescriptor(
    SingleUseCallback2<void,
                       const ResponseStatus&,
                       const ParameterDescriptor&> *callback,
    const ResponseStatus &status,
    const string &data) {
  ResponseStatus response_status = status;
  ParameterDescriptor description;

  if (response_status.WasAcked()) {
    PACK(
    struct param_description {
      uint16_t pid;
      uint8_t pdl_size;
      uint8_t data_type;
      uint8_t command_class;
      uint8_t type;
      uint8_t unit;
      uint8_t prefix;
      uint32_t min_value;
      uint32_t max_value;
      uint32_t default_value;
      // +1 for a null since it's not clear in the spec if this is null
      // terminated
      char description[MAX_RDM_STRING_LENGTH + 1];
    });
    STATIC_ASSERT(sizeof(param_description) == 53);
    struct param_description raw_description;

    unsigned int max = sizeof(raw_description) - 1;
    unsigned int min = max - MAX_RDM_STRING_LENGTH;
    unsigned int data_size = data.size();
    if (data_size >= min && data_size <= max) {
      memcpy(&raw_description, data.data(),
             std::min(static_cast<unsigned int>(data.size()), max));
      raw_description.description[MAX_RDM_STRING_LENGTH] = 0;

      description.pid = NetworkToHost(raw_description.pid);
      description.pdl_size = raw_description.pdl_size;
      description.data_type = raw_description.data_type;
      description.command_class = raw_description.command_class;
      description.unit = raw_description.unit;
      description.prefix = raw_description.prefix;
      description.min_value = NetworkToHost(raw_description.min_value);
      description.default_value = NetworkToHost(raw_description.default_value);
      description.max_value = NetworkToHost(raw_description.max_value);
      unsigned int label_size = data_size - (
          sizeof(raw_description) - MAX_RDM_STRING_LENGTH - 1);
      description.description = string(raw_description.description,
                                       label_size);
      ShortenString(&description.description);
    } else {
      std::ostringstream str;
      str << data_size << " needs to be between " << min << " and " << max;
      response_status.error = str.str();
    }
  }
  callback->Run(response_status, description);
}


/*
 * @brief Handle a DEVICE_INFO Get command
 */
void RDMAPI::_HandleGetDeviceDescriptor(
    SingleUseCallback2<void,
                       const ResponseStatus&,
                       const DeviceDescriptor&> *callback,
    const ResponseStatus &status,
    const string &data) {
  ResponseStatus response_status = status;
  DeviceDescriptor device_info;

  if (response_status.WasAcked()) {
    unsigned int data_size = data.size();
    if (data_size == sizeof(device_info)) {
      memcpy(&device_info, data.data(), sizeof(device_info));
      device_info.device_model = NetworkToHost(device_info.device_model);
      device_info.product_category =
        NetworkToHost(device_info.product_category);
      device_info.software_version =
        NetworkToHost(device_info.software_version);
      device_info.dmx_footprint =
        NetworkToHost(device_info.dmx_footprint);
      device_info.dmx_start_address =
        NetworkToHost(device_info.dmx_start_address);
      device_info.sub_device_count =
        NetworkToHost(device_info.sub_device_count);
    } else {
      SetIncorrectPDL(&response_status, data.size(), sizeof(device_info));
    }
  }
  callback->Run(response_status, device_info);
}


/*
 * @brief Handle a PRODUCT_DETAIL_ID_LIST response
 */
void RDMAPI::_HandleGetProductDetailIdList(
    SingleUseCallback2<void,
                       const ResponseStatus&,
                       const vector<uint16_t>&> *callback,
    const ResponseStatus &status,
    const string &data) {
  static const unsigned int MAX_DETAIL_IDS = 6;
  ResponseStatus response_status = status;
  vector<uint16_t> product_detail_ids;

  if (response_status.WasAcked()) {
    unsigned int data_size = data.size();
    if (data_size > MAX_DETAIL_IDS * sizeof(uint16_t)) {
      std::ostringstream str;
      str << "PDL needs to be <= " << (MAX_DETAIL_IDS * sizeof(uint16_t)) <<
        ", was " << data_size;
      response_status.error = str.str();
    } else if (data_size % 2) {
      std::ostringstream str;
      str << "PDL needs to be a multiple of 2, was " << data_size;
      response_status.error = str.str();
    } else {
      const uint16_t *start = reinterpret_cast<const uint16_t*>(data.data());
      const uint16_t *end = start + (data_size / sizeof(*start));
      for (const uint16_t *ptr = start; ptr < end; ptr++) {
        product_detail_ids.push_back(NetworkToHost(*ptr));
      }
    }
  }
  callback->Run(response_status, product_detail_ids);
}


/*
 * @brief Handle a LANGUAGE_CAPABILITIES response
 */
void RDMAPI::_HandleGetLanguageCapabilities(
    SingleUseCallback2<void,
                       const ResponseStatus&,
                       const vector<string>&> *callback,
    const ResponseStatus &status,
    const string &data) {
  ResponseStatus response_status = status;
  vector<string> languages;

  if (response_status.WasAcked()) {
    unsigned int data_size = data.size();
    if (data_size % 2) {
      std::ostringstream str;
      str << "PDL needs to be a multiple of 2, was " << data_size;
      response_status.error = str.str();
    } else {
      const char *ptr = data.data();
      const char *end = data.data() + data.size();
      while (ptr < end) {
        languages.push_back(string(ptr, 2));
        ptr+=2;
      }
    }
  }
  callback->Run(response_status, languages);
}


/*
 * @brief Handle a LANGUAGE response
 */
void RDMAPI::_HandleGetLanguage(
    SingleUseCallback2<void,
                       const ResponseStatus&,
                       const string&> *callback,
    const ResponseStatus &status,
    const string &data) {
  ResponseStatus response_status = status;
  static const unsigned int DATA_SIZE = 2;
  if (response_status.WasAcked() && data.size() != DATA_SIZE) {
    SetIncorrectPDL(&response_status, data.size(), DATA_SIZE);
  }
  callback->Run(response_status, data);
}


/*
 * @brief Handle a BOOT_SOFTWARE_VERSION_ID response
 */
void RDMAPI::_HandleGetBootSoftwareVersion(
    SingleUseCallback2<void,
                       const ResponseStatus&,
                       uint32_t> *callback,
    const ResponseStatus &status,
    const string &data) {
  ResponseStatus response_status = status;
  static const unsigned int DATA_SIZE = 4;
  uint32_t boot_version = 0;
  if (response_status.WasAcked()) {
    if (data.size() != DATA_SIZE) {
      SetIncorrectPDL(&response_status, data.size(), DATA_SIZE);
    } else {
      boot_version = *(reinterpret_cast<const uint32_t*>(data.data()));
      boot_version = NetworkToHost(boot_version);
    }
  }
  callback->Run(response_status, boot_version);
}


/*
 * @brief Handle a get DMX_PERSONALITY response
 */
void RDMAPI::_HandleGetDMXPersonality(
    SingleUseCallback3<void,
                       const ResponseStatus&,
                       uint8_t,
                       uint8_t> *callback,
    const ResponseStatus &status,
    const string &data) {
  ResponseStatus response_status = status;
  static const unsigned int DATA_SIZE = 2;
  uint8_t current_personality = 0;
  uint8_t personality_count = 0;
  if (response_status.WasAcked()) {
    if (data.size() != DATA_SIZE) {
      SetIncorrectPDL(&response_status, data.size(), DATA_SIZE);
    } else {
      current_personality = data[0];
      personality_count = data[1];
    }
  }
  callback->Run(response_status, current_personality, personality_count);
}


/*
 * @brief Handle a get DMX_PERSONALITY_DESCRIPTION response
 */
void RDMAPI::_HandleGetDMXPersonalityDescription(
    SingleUseCallback4<void,
                       const ResponseStatus&,
                       uint8_t,
                       uint16_t,
                       const string&> *callback,
    const ResponseStatus &status,
    const string &data) {
  ResponseStatus response_status = status;

  uint8_t personality = 0;
  uint16_t dmx_slots = 0;
  string description;

  if (response_status.WasAcked()) {
    PACK(
    struct personality_description {
      uint8_t personality;
      uint16_t dmx_slots;
      // +1 for a null since it's not clear in the spec if this is null
      // terminated
      char description[MAX_RDM_STRING_LENGTH + 1];
    });
    STATIC_ASSERT(sizeof(personality_description) == 36);
    struct personality_description raw_description;

    unsigned int max = sizeof(personality_description) - 1;
    unsigned int min = max - MAX_RDM_STRING_LENGTH;
    unsigned int data_size = data.size();
    if (data_size >= min && data_size <= max) {
      memcpy(&raw_description, data.data(),
             std::min(static_cast<unsigned int>(data.size()), max));
      personality = raw_description.personality;
      dmx_slots = NetworkToHost(raw_description.dmx_slots);
      description = string(raw_description.description, data_size - min);
      ShortenString(&description);
    } else {
      std::ostringstream str;
      str << data_size << " needs to be between " << min << " and " << max;
      response_status.error = str.str();
    }
  }
  callback->Run(response_status, personality, dmx_slots, description);
}


/*
 * @brief Handle a get SLOT_INFO response
 */
void RDMAPI::_HandleGetSlotInfo(
    SingleUseCallback2<void,
                       const ResponseStatus&,
                       const vector<SlotDescriptor>&> *callback,
    const ResponseStatus &status,
    const string &data) {
  ResponseStatus response_status = status;
  vector<SlotDescriptor> slots;
  SlotDescriptor slot_info;
  unsigned int slot_info_size = sizeof(slot_info);

  unsigned int data_size = data.size();
  if (response_status.WasAcked()) {
    if (data_size % slot_info_size) {
      response_status.error = ("PDL size not a multiple of " +
          IntToString(slot_info_size) + ", was " +
          IntToString(static_cast<int>(data_size)));
    } else {
      const uint8_t *ptr = reinterpret_cast<const uint8_t*>(data.data());
      const uint8_t *end = ptr + data.size();
      while (ptr < end) {
        memcpy(&slot_info, ptr, slot_info_size);
        slot_info.slot_offset = NetworkToHost(slot_info.slot_offset);
        slot_info.slot_label = NetworkToHost(slot_info.slot_label);
        slots.push_back(slot_info);
      }
    }
  }
  callback->Run(response_status, slots);
}


/*
 * @brief Handle a get SLOT_DESCRIPTION response
 */
void RDMAPI::_HandleGetSlotDescription(
    SingleUseCallback3<void,
                       const ResponseStatus&,
                       uint16_t,
                       const string&> *callback,
    const ResponseStatus &status,
    const string &data) {
  ResponseStatus response_status = status;

  uint16_t slot_index = 0;
  string description;

  if (response_status.WasAcked()) {
    PACK(
    struct slot_description {
      uint16_t slot_index;
      // +1 for a null since it's not clear in the spec if this is null
      // terminated
      char description[MAX_RDM_STRING_LENGTH + 1];
    });
    STATIC_ASSERT(sizeof(slot_description) == 35);
    struct slot_description raw_description;

    unsigned int max = sizeof(raw_description) - 1;
    unsigned int min = max - MAX_RDM_STRING_LENGTH;
    unsigned int data_size = data.size();
    if (data_size >= min && data_size <= max) {
      raw_description.description[MAX_RDM_STRING_LENGTH] = 0;
      memcpy(&raw_description, data.data(), data.size());
      slot_index = NetworkToHost(raw_description.slot_index);
      description = string(raw_description.description,
                           data.size() - min);
      ShortenString(&description);
    } else {
      std::ostringstream str;
      str << data_size << " needs to be between " << min << " and " << max;
      response_status.error = str.str();
    }
  }
  callback->Run(response_status, slot_index, description);
}


/*
 * @brief Handle a get DEFAULT_SLOT_VALUE response
 */
void RDMAPI::_HandleGetSlotDefaultValues(
    SingleUseCallback2<void,
                       const ResponseStatus&,
                       const vector<SlotDefault>&> *callback,
    const ResponseStatus &status,
    const string &data) {
  ResponseStatus response_status = status;
  vector<SlotDefault> slots;
  SlotDefault slot_default;
  unsigned int slot_default_size = sizeof(slot_default);

  unsigned int data_size = data.size();
  if (response_status.WasAcked()) {
    if (data_size % slot_default_size) {
      response_status.error = ("PDL size not a multiple of " +
          IntToString(slot_default_size) + ", was " +
          IntToString(static_cast<int>(data_size)));
    } else {
      const uint8_t *ptr = reinterpret_cast<const uint8_t*>(data.data());
      const uint8_t *end = ptr + data.size();
      while (ptr < end) {
        memcpy(&slot_default, ptr, slot_default_size);
        slot_default.slot_offset = NetworkToHost(slot_default.slot_offset);
        slots.push_back(slot_default);
      }
    }
  }
  callback->Run(response_status, slots);
}


/*
 * @brief Handle a SENSOR_DEFINITION response
 */
void RDMAPI::_HandleGetSensorDefinition(
    SingleUseCallback2<void,
                       const ResponseStatus&,
                       const SensorDescriptor&> *callback,
    const ResponseStatus &status,
    const string &data) {
  ResponseStatus response_status = status;
  SensorDescriptor sensor;

  if (response_status.WasAcked()) {
    PACK(
    struct sensor_definition_s {
      uint8_t sensor_number;
      uint8_t type;
      uint8_t unit;
      uint8_t prefix;
      int16_t range_min;
      int16_t range_max;
      int16_t normal_min;
      int16_t normal_max;
      uint8_t recorded_value_support;
      char description[MAX_RDM_STRING_LENGTH + 1];
    });
    STATIC_ASSERT(sizeof(sensor_definition_s) == 46);
    struct sensor_definition_s raw_description;

    unsigned int max = sizeof(raw_description) - 1;
    unsigned int min = max - MAX_RDM_STRING_LENGTH;
    unsigned int data_size = data.size();
    if (data_size >= min && data_size <= max) {
      memcpy(&raw_description, data.data(),
             std::min(static_cast<unsigned int>(data.size()), max));

      sensor.sensor_number = raw_description.sensor_number;
      sensor.type = raw_description.type;
      sensor.unit = raw_description.unit;
      sensor.prefix = raw_description.prefix;
      sensor.range_min = NetworkToHost(raw_description.range_min);
      sensor.range_max = NetworkToHost(raw_description.range_max);
      sensor.normal_min = NetworkToHost(raw_description.normal_min);
      sensor.normal_max = NetworkToHost(raw_description.normal_max);
      sensor.recorded_value_support = raw_description.recorded_value_support;
      sensor.description = string(raw_description.description,
                                  data_size - min);
      ShortenString(&sensor.description);
    } else {
      std::ostringstream str;
      str << data_size << " needs to be between " << min << " and " << max;
      response_status.error = str.str();
    }
  }
  callback->Run(response_status, sensor);
}


/*
 * @brief Handle a SENSOR_VALUE response
 */
void RDMAPI::_HandleSensorValue(
    SingleUseCallback2<void,
                       const ResponseStatus&,
                       const SensorValueDescriptor&> *callback,
    const ResponseStatus &status,
    const string &data) {
  ResponseStatus response_status = status;
  SensorValueDescriptor sensor;

  if (response_status.WasAcked()) {
    unsigned int data_size = data.size();
    if (data_size == sizeof(sensor)) {
      memcpy(&sensor, data.data(), sizeof(sensor));
      sensor.present_value = NetworkToHost(sensor.present_value);
      sensor.lowest = NetworkToHost(sensor.lowest);
      sensor.highest = NetworkToHost(sensor.highest);
      sensor.recorded = NetworkToHost(sensor.recorded);
    } else {
      SetIncorrectPDL(&response_status, data.size(), sizeof(sensor));
    }
  }
  callback->Run(response_status, sensor);
}


/*
 * @brief Handle a REAL_TIME_CLOCK response
 */
void RDMAPI::_HandleClock(
    SingleUseCallback2<void,
                       const ResponseStatus&,
                       const ClockValue&> *callback,
    const ResponseStatus &status,
    const string &data) {
  ResponseStatus response_status = status;
  ClockValue clock;

  if (response_status.WasAcked()) {
    unsigned int data_size = data.size();
    if (data_size == sizeof(clock)) {
      memcpy(&clock, data.data(), sizeof(clock));
      clock.year = NetworkToHost(clock.year);
    } else {
      SetIncorrectPDL(&response_status, data.size(), sizeof(clock));
    }
  }
  callback->Run(response_status, clock);
}


/**
 * @brief Handle a PID_SELF_TEST_DESCRIPTION response.
 */
void RDMAPI::_HandleSelfTestDescription(
    SingleUseCallback3<void,
                       const ResponseStatus&,
                       uint8_t,
                       const string&> *callback,
    const ResponseStatus &status,
    const string &data) {
  ResponseStatus response_status = status;

  uint8_t self_test_number = 0;
  string description;

  if (response_status.WasAcked()) {
    PACK(
    struct self_test_description {
      uint8_t self_test_number;
      // +1 for a null since it's not clear in the spec if this is null
      // terminated
      char description[MAX_RDM_STRING_LENGTH + 1];
    });
    STATIC_ASSERT(sizeof(self_test_description) == 34);
    struct self_test_description raw_description;

    unsigned int max = sizeof(raw_description) - 1;
    unsigned int min = max - MAX_RDM_STRING_LENGTH;
    unsigned int data_size = data.size();
    if (data_size >= min && data_size <= max) {
      raw_description.description[MAX_RDM_STRING_LENGTH] = 0;
      memcpy(&raw_description, data.data(), data.size());
      self_test_number = raw_description.self_test_number;
      description = string(raw_description.description,
                           data.size() - min);
      ShortenString(&description);
    } else {
      std::ostringstream str;
      str << data_size << " needs to be between " << min << " and " << max;
      response_status.error = str.str();
    }
  }
  callback->Run(response_status, self_test_number, description);
}


/**
 * @brief Handle a PID_PRESET_PLAYBACK response
 */
void RDMAPI::_HandlePlaybackMode(
    SingleUseCallback3<void,
                       const ResponseStatus&,
                       uint16_t,
                       uint8_t> *callback,
    const ResponseStatus &status,
    const string &data) {
  ResponseStatus response_status = status;

  uint16_t mode = 0;
  uint8_t level = 0;

  if (response_status.WasAcked()) {
    PACK(
    struct preset_mode {
      uint16_t mode;
      uint8_t level;
    });
    STATIC_ASSERT(sizeof(preset_mode) == 3);
    struct preset_mode raw_config;

    if (data.size() >= sizeof(raw_config)) {
      memcpy(&raw_config, data.data(), data.size());
      mode = NetworkToHost(raw_config.mode);
      level = raw_config.level;
    } else {
      std::ostringstream str;
      str << data.size() << " needs to be more than " << sizeof(raw_config);
      response_status.error = str.str();
    }
  }
  callback->Run(response_status, mode, level);
}

/*
 * @brief Handle a get CURVE response
 */
void RDMAPI::_HandleGetCurve(
    SingleUseCallback3<void,
                       const ResponseStatus&,
                       uint8_t,
                       uint8_t> *callback,
    const ResponseStatus &status,
    const string &data) {
  ResponseStatus response_status = status;
  static const unsigned int DATA_SIZE = 2;
  uint8_t active_curve = 0;
  uint8_t curve_count = 0;
  if (response_status.WasAcked()) {
    if (data.size() != DATA_SIZE) {
      SetIncorrectPDL(&response_status, data.size(), DATA_SIZE);
    } else {
      active_curve = data[0];
      curve_count = data[1];
    }
  }
  callback->Run(response_status, active_curve, curve_count);
}

/*
 * @brief Handle a get CURVE_DESCRIPTION response
 */
void RDMAPI::_HandleGetCurveDescription(
    SingleUseCallback3<void,
                       const ResponseStatus&,
                       uint8_t,
                       const string&> *callback,
    const ResponseStatus &status,
    const string &data) {
  ResponseStatus response_status = status;

  uint8_t requested_curve = 0;
  string description;

  if (response_status.WasAcked()) {
    PACK(
    struct curve_description {
      uint8_t curve;
      // +1 for a null since it's not clear in the spec if this is null
      // terminated
      char description[MAX_RDM_STRING_LENGTH + 1];
    });
    STATIC_ASSERT(sizeof(curve_description) == 34);
    struct curve_description raw_description;

    unsigned int max = sizeof(curve_description) - 1;
    unsigned int min = max - MAX_RDM_STRING_LENGTH;
    unsigned int data_size = data.size();
    if (data_size >= min && data_size <= max) {
      memcpy(&raw_description, data.data(),
             std::min(static_cast<unsigned int>(data.size()), max));
      requested_curve = raw_description.curve;
      description = string(raw_description.description, data_size - min);
      ShortenString(&description);
    } else {
      std::ostringstream str;
      str << data_size << " needs to be between " << min << " and " << max;
      response_status.error = str.str();
    }
  }
  callback->Run(response_status, requested_curve, description);
}

/*
 * @brief Handle a get DIMMER_INFO response
 */
void RDMAPI::_HandleGetDimmerInfo(
    SingleUseCallback2<void,
                       const ResponseStatus&,
                       const DimmerInfoDescriptor&> *callback,
    const ResponseStatus &status,
    const string &data) {
  ResponseStatus response_status = status;
  DimmerInfoDescriptor dimmer_info;

  if (response_status.WasAcked()) {
    PACK(
    struct dimmer_info_s {
      uint16_t min_level_lower_limit;
      uint16_t min_level_upper_limit;
      uint16_t max_level_lower_limit;
      uint16_t max_level_upper_limit;
      uint8_t curves_supported;
      uint8_t resolution;
      uint8_t split_levels_supported;
    });
    STATIC_ASSERT(sizeof(dimmer_info_s) == 11);
    struct dimmer_info_s raw_description;

    unsigned int data_size = data.size();
    if (data_size == sizeof(dimmer_info_s)) {
      memcpy(&raw_description, data.data(), data_size);

      dimmer_info.min_level_lower_limit =
          NetworkToHost(raw_description.min_level_lower_limit);
      dimmer_info.min_level_upper_limit =
          NetworkToHost(raw_description.min_level_upper_limit);
      dimmer_info.max_level_lower_limit =
          NetworkToHost(raw_description.max_level_lower_limit);
      dimmer_info.max_level_upper_limit =
          NetworkToHost(raw_description.max_level_upper_limit);
      dimmer_info.curves_supported = raw_description.curves_supported;
      dimmer_info.resolution = raw_description.resolution;
      dimmer_info.split_levels_supported =
          raw_description.split_levels_supported;
    } else {
      std::ostringstream str;
      str << data_size << " needs to be " << sizeof(dimmer_info_s);
      response_status.error = str.str();
    }
  }
  callback->Run(response_status, dimmer_info);
}

/*
 * @brief Handle a get MINIMUM_LEVEL response
 */
void RDMAPI::_HandleGetDimmerMinimumLevels(
    SingleUseCallback2<void,
                       const ResponseStatus&,
                       const DimmerMinimumDescriptor&> *callback,
    const ResponseStatus &status,
    const string &data) {
  ResponseStatus response_status = status;
  DimmerMinimumDescriptor dimmer_mins;

  if (response_status.WasAcked()) {
    PACK(
    struct dimmer_min_s {
      uint16_t min_level_increasing;
      uint16_t min_level_decreasing;
      uint8_t on_below_min;
    });
    STATIC_ASSERT(sizeof(dimmer_min_s) == 5);
    struct dimmer_min_s raw_description;

    unsigned int data_size = data.size();
    if (data_size == sizeof(dimmer_min_s)) {
      memcpy(&raw_description, data.data(), data_size);

      dimmer_mins.min_level_increasing =
          NetworkToHost(raw_description.min_level_increasing);
      dimmer_mins.min_level_decreasing =
          NetworkToHost(raw_description.min_level_decreasing);
      dimmer_mins.on_below_min = raw_description.on_below_min;
    } else {
      std::ostringstream str;
      str << data_size << " needs to be " << sizeof(dimmer_min_s);
      response_status.error = str.str();
    }
  }
  callback->Run(response_status, dimmer_mins);
}


//-----------------------------------------------------------------------------
// Private methods follow

// @brief get a 8 bit value
bool RDMAPI::GenericGetU8(
    unsigned int universe,
    const UID &uid,
    uint8_t sub_device,
    SingleUseCallback2<void, const ResponseStatus&, uint8_t> *callback,
    uint16_t pid,
    string *error) {
  if (CheckNotBroadcast(uid, error, callback))
    return false;
  if (CheckValidSubDevice(sub_device, false, error, callback))
    return false;
  if (CheckCallback(error, callback))
    return false;

  RDMAPIImplInterface::rdm_callback *cb = NewSingleCallback(
    this,
    &RDMAPI::_HandleU8Response,
    callback);
  return CheckReturnStatus(
    m_impl->RDMGet(cb,
                   universe,
                   uid,
                   sub_device,
                   pid),
    error);
}


// @brief set an 8 bit value
bool RDMAPI::GenericSetU8(
    unsigned int universe,
    const UID &uid,
    uint16_t sub_device,
    uint8_t value,
    SingleUseCallback1<void, const ResponseStatus&> *callback,
    uint16_t pid,
    string *error) {
  if (CheckValidSubDevice(sub_device, true, error, callback))
    return false;
  if (CheckCallback(error, callback))
    return false;

  RDMAPIImplInterface::rdm_callback *cb = NewSingleCallback(
    this,
    &RDMAPI::_HandleEmptyResponse,
    callback);
  return CheckReturnStatus(
    m_impl->RDMSet(cb,
                   universe,
                   uid,
                   sub_device,
                   pid,
                   &value,
                   sizeof(value)),
    error);
}


// @brief get a 16 bit value
bool RDMAPI::GenericGetU16(
    unsigned int universe,
    const UID &uid,
    uint16_t sub_device,
    SingleUseCallback2<void, const ResponseStatus&, uint16_t> *callback,
    uint16_t pid,
    string *error) {
  if (CheckNotBroadcast(uid, error, callback))
    return false;
  if (CheckValidSubDevice(sub_device, false, error, callback))
    return false;
  if (CheckCallback(error, callback))
    return false;

  RDMAPIImplInterface::rdm_callback *cb = NewSingleCallback(
    this,
    &RDMAPI::_HandleU16Response,
    callback);
  return CheckReturnStatus(
    m_impl->RDMGet(cb,
                   universe,
                   uid,
                   sub_device,
                   pid),
    error);
}


// @brief set a 16 bit value
bool RDMAPI::GenericSetU16(
    unsigned int universe,
    const UID &uid,
    uint16_t sub_device,
    uint16_t value,
    SingleUseCallback1<void, const ResponseStatus&> *callback,
    uint16_t pid,
    string *error) {
  if (CheckValidSubDevice(sub_device, true, error, callback))
    return false;
  if (CheckCallback(error, callback))
    return false;

  value = HostToNetwork(value);
  RDMAPIImplInterface::rdm_callback *cb = NewSingleCallback(
    this,
    &RDMAPI::_HandleEmptyResponse,
    callback);
  return CheckReturnStatus(
    m_impl->RDMSet(cb,
                   universe,
                   uid,
                   sub_device,
                   pid,
                   reinterpret_cast<const uint8_t*>(&value),
                   sizeof(value)),
    error);
}


// @brief get a 32 bit value
bool RDMAPI::GenericGetU32(
    unsigned int universe,
    const UID &uid,
    uint16_t sub_device,
    SingleUseCallback2<void, const ResponseStatus&, uint32_t> *callback,
    uint16_t pid,
    string *error) {
  if (CheckNotBroadcast(uid, error, callback))
    return false;
  if (CheckValidSubDevice(sub_device, false, error, callback))
    return false;
  if (CheckCallback(error, callback))
    return false;

  RDMAPIImplInterface::rdm_callback *cb = NewSingleCallback(
    this,
    &RDMAPI::_HandleU32Response,
    callback);
  return CheckReturnStatus(
    m_impl->RDMGet(cb,
                   universe,
                   uid,
                   sub_device,
                   pid),
    error);
}


// @brief set a 32 bit value
bool RDMAPI::GenericSetU32(
    unsigned int universe,
    const UID &uid,
    uint16_t sub_device,
    uint32_t value,
    SingleUseCallback1<void, const ResponseStatus&> *callback,
    uint16_t pid,
    string *error) {
  if (CheckValidSubDevice(sub_device, true, error, callback))
    return false;
  if (CheckCallback(error, callback))
    return false;

  value = HostToNetwork(value);
  RDMAPIImplInterface::rdm_callback *cb = NewSingleCallback(
    this,
    &RDMAPI::_HandleEmptyResponse,
    callback);
  return CheckReturnStatus(
    m_impl->RDMSet(cb,
                   universe,
                   uid,
                   sub_device,
                   pid,
                   reinterpret_cast<const uint8_t*>(&value),
                   sizeof(value)),
    error);
}


// @brief Checks the status of a rdm command and sets error appropriately
bool RDMAPI::CheckReturnStatus(bool status, string *error) {
  if (!status && error)
    *error = "Unable to send RDM command";
  return status;
}

// Mark a ResponseStatus as malformed due to a length mismatch
void RDMAPI::SetIncorrectPDL(ResponseStatus *status,
                             unsigned int actual,
                             unsigned int expected) {
  status->error = ("PDL mismatch, " +
    IntToString(actual) + " != " +
    IntToString(expected) + " (expected)");
}
}  // namespace rdm
}  // namespace ola

OpenLightingProject / ola / 11783254300

Source File Press 'n' to go to next uncovered line, 'b' for previous

Source File
Press 'n' to go to next uncovered line, 'b' for previous