kinetic_message.c File Reference

#include "kinetic_message.h"
#include "kinetic_logger.h"

Go to the source code of this file.

Macros
#define	CONFIG_FIELD_BYTE_BUFFER(_name, _proto_name, _field, _entry)

Functions
void	KineticMessage_ConfigureKeyValue (KineticMessage *const message, const KineticEntry *entry)
void	KineticMessage_ConfigureKeyRange (KineticMessage *const message, const KineticKeyRange *range)

Macro Definition Documentation

#define CONFIG_FIELD_BYTE_BUFFER	(		_name,
			_proto_name,
			_field,
			_entry
	)

Value:

{ \
    if ((_entry)->_name.array.data != NULL \
        && (_entry)->_name.array.len > 0 \
        && (_entry)->_name.bytesUsed > 0 \
        && (_entry)->_name.bytesUsed <= (_entry)->_name.array.len) \
    { \
        (_field)._proto_name.data = (_entry)->_name.array.data; \
        (_field)._proto_name.len = (_entry)->_name.bytesUsed; \
        (_field).has_ ## _proto_name = true; \
    } \
    else { \
        (_field).has_ ## _proto_name = false; \
    } \
}

Definition at line 24 of file kinetic_message.c.

Function Documentation

void KineticMessage_ConfigureKeyValue	(	KineticMessage *const	message,
		const KineticEntry *	entry
	)

Definition at line 39 of file kinetic_message.c.

References KineticEntry::algorithm, KineticMessage::body, Com__Seagate__Kinetic__Proto__Command__Algorithm_from_KineticAlgorithm(), Com__Seagate__Kinetic__Proto__Command__Synchronization_from_KineticSynchronization(), KineticMessage::command, CONFIG_FIELD_BYTE_BUFFER, KineticEntry::force, KineticMessage::keyValue, KINETIC_ASSERT, KineticEntry::metadataOnly, and KineticEntry::synchronization.

void KineticMessage_ConfigureKeyRange	(	KineticMessage *const	message,
		const KineticKeyRange *	range
	)

Definition at line 80 of file kinetic_message.c.

References ByteBuffer::array, KineticMessage::body, ByteBuffer::bytesUsed, KineticMessage::command, ByteArray::data, KineticKeyRange::endKey, KineticKeyRange::endKeyInclusive, KineticMessage::keyRange, KINETIC_ASSERT, ByteArray::len, KineticKeyRange::maxReturned, KineticKeyRange::reverse, KineticKeyRange::startKey, and KineticKeyRange::startKeyInclusive.