diff --git a/src/remote/channelSearchManager.cpp b/src/remote/channelSearchManager.cpp index f205e51..6dd9b33 100644 --- a/src/remote/channelSearchManager.cpp +++ b/src/remote/channelSearchManager.cpp @@ -34,7 +34,6 @@ public: void setRecipient(const osiSockAddr& /*sendTo*/) {} void startMessage(epics::pvData::int8 /*command*/, std::size_t /*ensureCapacity*/, epics::pvData::int32 /*payloadSize*/) {} void ensureBuffer(std::size_t /*size*/) {} - void alignBuffer(std::size_t /*alignment*/) {} void flushSerializeBuffer() {} void cachedSerialize(const std::tr1::shared_ptr& field, epics::pvData::ByteBuffer* buffer) { diff --git a/src/remote/codec.cpp b/src/remote/codec.cpp index b3aaeba..3a4ea58 100644 --- a/src/remote/codec.cpp +++ b/src/remote/codec.cpp @@ -542,29 +542,6 @@ std::size_t AbstractCodec::alignedValue( return (value + k) & (~k); } - -void AbstractCodec::alignData(std::size_t alignment) { - - std::size_t k = (alignment - 1); - std::size_t pos = _socketBuffer.getPosition(); - std::size_t newpos = (pos + k) & (~k); - if (pos == newpos) - return; - - std::size_t diff = _socketBuffer.getLimit() - newpos; - if (diff > 0) - { - _socketBuffer.setPosition(newpos); - return; - } - - ensureData(diff); - - // position has changed, recalculate - newpos = (_socketBuffer.getPosition() + k) & (~k); - _socketBuffer.setPosition(newpos); -} - static const char PADDING_BYTES[] = { static_cast(0xFF), @@ -577,19 +554,6 @@ static const char PADDING_BYTES[] = static_cast(0xFF) }; -void AbstractCodec::alignBuffer(std::size_t alignment) { - - std::size_t k = (alignment - 1); - std::size_t pos = _sendBuffer.getPosition(); - std::size_t newpos = (pos + k) & (~k); - if (pos == newpos) - return; - - // for safety reasons we really pad (override previous message data) - std::size_t padCount = newpos - pos; - _sendBuffer.put(PADDING_BYTES, 0, padCount); -} - void AbstractCodec::startMessage( epics::pvData::int8 command, diff --git a/src/remote/pv/blockingUDP.h b/src/remote/pv/blockingUDP.h index 22a6165..97cedeb 100644 --- a/src/remote/pv/blockingUDP.h +++ b/src/remote/pv/blockingUDP.h @@ -129,10 +129,6 @@ public: virtual void ensureData(std::size_t size) OVERRIDE FINAL; - virtual void alignData(std::size_t alignment) OVERRIDE FINAL { - _receiveBuffer.align(alignment); - } - virtual bool directSerialize(epics::pvData::ByteBuffer* /*existingBuffer*/, const char* /*toSerialize*/, std::size_t /*elementCount*/, std::size_t /*elementSize*/) OVERRIDE FINAL { @@ -178,10 +174,6 @@ public: // noop } - virtual void alignBuffer(std::size_t alignment) OVERRIDE FINAL { - _sendBuffer.align(alignment); - } - virtual void cachedSerialize( const std::tr1::shared_ptr& field, epics::pvData::ByteBuffer* buffer) OVERRIDE FINAL { diff --git a/src/remote/pv/codec.h b/src/remote/pv/codec.h index 9f5fe60..32e8641 100644 --- a/src/remote/pv/codec.h +++ b/src/remote/pv/codec.h @@ -162,9 +162,7 @@ public: { } - virtual void alignBuffer(std::size_t alignment) OVERRIDE FINAL; virtual void ensureData(std::size_t size) OVERRIDE FINAL; - virtual void alignData(std::size_t alignment) OVERRIDE FINAL; virtual void startMessage( epics::pvData::int8 command, std::size_t ensureCapacity = 0,