NetworkTableEntry.cpp

#include "networktables2/NetworkTableEntry.h"
#include "networktables2/AbstractNetworkTableEntryStore.h"


NetworkTableEntry::NetworkTableEntry(std::string& _name, NetworkTableEntryType* _type, EntryValue _value)
  : name(_name), type(_type){
        id = UNKNOWN_ID;
        sequenceNumber = 0;
        value = type->copyValue(_value);
        m_isNew = true;
        m_isDirty = false;
}

NetworkTableEntry::NetworkTableEntry(EntryId _id, std::string& _name, SequenceNumber _sequenceNumber, NetworkTableEntryType* _type, EntryValue _value)
 :name(_name), type(_type){
        id = _id;
        sequenceNumber = _sequenceNumber;
        value = type->copyValue(_value);
        m_isNew = true;
        m_isDirty = false;
}

NetworkTableEntry::~NetworkTableEntry(){
  type->deleteValue(value);
}

EntryId NetworkTableEntry::GetId() {
        return id;
}

EntryValue NetworkTableEntry::GetValue(){
        return value;
}

NetworkTableEntryType* NetworkTableEntry::GetType(){
        return type;
}

bool NetworkTableEntry::PutValue(SequenceNumber newSequenceNumber, EntryValue newValue) {
        if( (sequenceNumber < newSequenceNumber && newSequenceNumber - sequenceNumber < HALF_OF_SEQUENCE_NUMBERS)
                        || (sequenceNumber > newSequenceNumber && sequenceNumber - newSequenceNumber > HALF_OF_SEQUENCE_NUMBERS) ){
          EntryValue newValueCopy = type->copyValue(newValue);
          type->deleteValue(value);
          value = newValueCopy;
          sequenceNumber = newSequenceNumber;
          return true;
        }
        return false;
}
void NetworkTableEntry::ForcePut(SequenceNumber newSequenceNumber, EntryValue newValue) {
  EntryValue newValueCopy = type->copyValue(newValue);
  type->deleteValue(value);
  value = newValueCopy;
  sequenceNumber = newSequenceNumber;
}
void NetworkTableEntry::ForcePut(SequenceNumber newSequenceNumber, NetworkTableEntryType* newType, EntryValue newValue) {
        type->deleteValue(value);
        type = newType;
        value = newType->copyValue(newValue);
        sequenceNumber = newSequenceNumber;
}


void NetworkTableEntry::MakeDirty() {
        m_isDirty = true;
}
void NetworkTableEntry::MakeClean() {
        m_isDirty = false;
}
bool NetworkTableEntry::IsDirty(){
        return m_isDirty;
}

void NetworkTableEntry::SendValue(DataIOStream& iostream){
        type->sendValue(value, iostream);
}

SequenceNumber NetworkTableEntry::GetSequenceNumber() {
        return sequenceNumber;
}
void NetworkTableEntry::SetId(EntryId _id){
        if(id!=UNKNOWN_ID)
                throw IllegalStateException("Cannot set the Id of a table entry that already has a valid id");
        id = _id;
}
void NetworkTableEntry::ClearId() {
        id = UNKNOWN_ID;
}

void NetworkTableEntry::Send(NetworkTableConnection& connection) {
        connection.sendEntryAssignment(*this);
}
void NetworkTableEntry::FireListener(TableListenerManager& listenerManager) {
        listenerManager.FireTableListeners(name, value, m_isNew);
        m_isNew = false;
}