Repository: geode Updated Branches: refs/heads/next-gen-native-client-software-grant 340f2fca8 -> fc9f1f6f5
http://git-wip-us.apache.org/repos/asf/geode/blob/fc9f1f6f/src/clicache/src/impl/PdxWriterWithTypeCollector.cpp ---------------------------------------------------------------------- diff --git a/src/clicache/src/impl/PdxWriterWithTypeCollector.cpp b/src/clicache/src/impl/PdxWriterWithTypeCollector.cpp index 1c8f55f..3992994 100644 --- a/src/clicache/src/impl/PdxWriterWithTypeCollector.cpp +++ b/src/clicache/src/impl/PdxWriterWithTypeCollector.cpp @@ -18,7 +18,7 @@ #include "PdxWriterWithTypeCollector.hpp" #include "../DataOutput.hpp" #include <gfcpp/GeodeTypeIds.hpp> -#include "../GemFireClassIds.hpp" +#include "../GeodeClassIds.hpp" #include "PdxHelper.hpp" using namespace System; @@ -33,327 +33,327 @@ namespace Apache namespace Internal { - void PdxWriterWithTypeCollector::initialize() - { - m_offsets = gcnew System::Collections::Generic::List<Int32>(); - m_pdxType = gcnew PdxType(m_pdxClassName, true); - } - - Int32 PdxWriterWithTypeCollector::calculateLenWithOffsets() - { - int bufferLen = m_dataOutput->BufferLength - m_startPositionOffset; - Int32 totalOffsets = 0; - if(m_offsets->Count > 0) - totalOffsets = m_offsets->Count - 1;//for first var len no need to append offset - Int32 totalLen = bufferLen - PdxHelper::PdxHeader + totalOffsets; - - - if(totalLen <= 0xff) - return totalLen; - else if (totalLen + totalOffsets <= 0xffff) - return totalLen + totalOffsets ; - else - return totalLen + totalOffsets*3 ; - } - - void PdxWriterWithTypeCollector::AddOffset() - { - int bufferLen = m_dataOutput->BufferLength - m_startPositionOffset; - int offset = bufferLen - PdxHelper::PdxHeader; - - m_offsets->Add(offset); - } - - void PdxWriterWithTypeCollector::EndObjectWriting() - {//write header - PdxLocalWriter::WritePdxHeader(); - } - - void PdxWriterWithTypeCollector::WriteOffsets(Int32 len) - { - if(len <= 0xff) - { - for(int i = m_offsets->Count-1; i >0 ; i--) - m_dataOutput->WriteByte((Byte)m_offsets[i]); - } - else if(len <= 0xffff) - { - for(int i = m_offsets->Count-1; i >0 ; i--) - m_dataOutput->WriteUInt16((UInt16)m_offsets[i]); - } - else - { - for(int i = m_offsets->Count-1; i >0 ; i--) - m_dataOutput->WriteUInt32((UInt32)m_offsets[i]); - } - } - - bool PdxWriterWithTypeCollector::isFieldWritingStarted() - { - return m_pdxType->Totalfields > 0; - } - - IPdxWriter^ PdxWriterWithTypeCollector::WriteUnreadFields(IPdxUnreadFields^ unread) - { - PdxLocalWriter::WriteUnreadFields(unread); - return this; - } - - IPdxWriter^ PdxWriterWithTypeCollector::WriteByte( String^ fieldName, SByte value ) - { - m_pdxType->AddFixedLengthTypeField(fieldName, "byte", PdxTypes::BYTE, GemFireClassIds::BYTE_SIZE); - PdxLocalWriter::WriteByte(fieldName, value); - return this; - } - - IPdxWriter^ PdxWriterWithTypeCollector::WriteSByte( String^ fieldName, SByte value ) - { - m_pdxType->AddFixedLengthTypeField( fieldName, "byte", PdxTypes::BYTE, GemFireClassIds::BYTE_SIZE); - PdxLocalWriter::WriteSByte(fieldName, value); - return this; - } - - IPdxWriter^ PdxWriterWithTypeCollector::WriteBoolean( String^ fieldName, bool value ) - { - m_pdxType->AddFixedLengthTypeField(fieldName, "boolean", PdxTypes::BOOLEAN, GemFireClassIds::BOOLEAN_SIZE); - PdxLocalWriter::WriteBoolean(fieldName, value); - return this; - } - - IPdxWriter^ PdxWriterWithTypeCollector::WriteChar( String^ fieldName, Char value ) - { - m_pdxType->AddFixedLengthTypeField(fieldName, "char", PdxTypes::CHAR, GemFireClassIds::CHAR_SIZE); - PdxLocalWriter::WriteChar(fieldName, value); - return this; - } - - IPdxWriter^ PdxWriterWithTypeCollector::WriteUInt16( String^ fieldName, uint16_t value ) - { - m_pdxType->AddFixedLengthTypeField(fieldName, "short", PdxTypes::SHORT, GemFireClassIds::SHORT_SIZE); - PdxLocalWriter::WriteUInt16(fieldName, value); - return this; - } - - IPdxWriter^ PdxWriterWithTypeCollector::WriteUInt32( String^ fieldName, uint32_t value ) - { - m_pdxType->AddFixedLengthTypeField(fieldName, "int", PdxTypes::INT, GemFireClassIds::INTEGER_SIZE); - PdxLocalWriter::WriteUInt32(fieldName, value); - return this; - } - - IPdxWriter^ PdxWriterWithTypeCollector::WriteUInt64( String^ fieldName, uint64_t value ) - { - m_pdxType->AddFixedLengthTypeField(fieldName, "long", PdxTypes::LONG, GemFireClassIds::LONG_SIZE); - PdxLocalWriter::WriteUInt64(fieldName, value); - return this; - } - - IPdxWriter^ PdxWriterWithTypeCollector::WriteShort( String^ fieldName, int16_t value ) - { - m_pdxType->AddFixedLengthTypeField(fieldName, "short", PdxTypes::SHORT, GemFireClassIds::SHORT_SIZE); - PdxLocalWriter::WriteShort(fieldName, value); - return this; - } - - IPdxWriter^ PdxWriterWithTypeCollector::WriteInt( String^ fieldName, int32_t value ) - { - m_pdxType->AddFixedLengthTypeField(fieldName, "int", PdxTypes::INT, GemFireClassIds::INTEGER_SIZE); - PdxLocalWriter::WriteInt(fieldName, value); - return this; - } - - IPdxWriter^ PdxWriterWithTypeCollector::WriteLong( String^ fieldName, Int64 value ) - { - m_pdxType->AddFixedLengthTypeField(fieldName, "long", PdxTypes::LONG, GemFireClassIds::LONG_SIZE); - PdxLocalWriter::WriteLong(fieldName, value); - return this; - } - - IPdxWriter^ PdxWriterWithTypeCollector::WriteFloat( String^ fieldName, float value ) - { - m_pdxType->AddFixedLengthTypeField(fieldName, "float", PdxTypes::FLOAT, GemFireClassIds::FLOAT_SIZE); - PdxLocalWriter::WriteFloat(fieldName, value); - return this; - } - - IPdxWriter^ PdxWriterWithTypeCollector::WriteDouble( String^ fieldName, double value ) - { - m_pdxType->AddFixedLengthTypeField(fieldName, "double", PdxTypes::DOUBLE, GemFireClassIds::DOUBLE_SIZE); - PdxLocalWriter::WriteDouble(fieldName, value); - return this; - } - - IPdxWriter^ PdxWriterWithTypeCollector::WriteString( String^ fieldName, String^ value ) - { - m_pdxType->AddVariableLengthTypeField(fieldName, "String", PdxTypes::STRING); - PdxLocalWriter::WriteString(fieldName, value); - return this; - } - - IPdxWriter^ PdxWriterWithTypeCollector::WriteUTFHuge( String^ fieldName, String^ value ) - { - m_pdxType->AddVariableLengthTypeField(fieldName, "stringUTFHuge", PdxTypes::STRING); - PdxLocalWriter::WriteUTFHuge(fieldName, value); - return this; - } - - IPdxWriter^ PdxWriterWithTypeCollector::WriteASCIIHuge( String^ fieldName, String^ value ) - { - m_pdxType->AddVariableLengthTypeField(fieldName, "stringASCIIHuge", PdxTypes::STRING); - PdxLocalWriter::WriteASCIIHuge(fieldName, value); - return this; - } - - IPdxWriter^ PdxWriterWithTypeCollector::WriteObject( String^ fieldName, Object^ obj ) - { - m_pdxType->AddVariableLengthTypeField(fieldName, /*obj->GetType()->FullName*/"Object", PdxTypes::OBJECT); - PdxLocalWriter::WriteObject(fieldName, obj); - return this; - } - - //TODO: - //IPdxWriter^ PdxWriterWithTypeCollector::WriteMap( String^ fieldName, System::Collections::IDictionary^ map ); - - IPdxWriter^ PdxWriterWithTypeCollector::WriteCollection( String^ fieldName, System::Collections::IList^ obj) - { - m_pdxType->AddVariableLengthTypeField(fieldName, /*obj->GetType()->FullName*/"Collection", apache::geode::client::GeodeTypeIds::CacheableArrayList); - PdxLocalWriter::WriteCollection(fieldName, obj); - return this; - } - - IPdxWriter^ PdxWriterWithTypeCollector::WriteDate( String^ fieldName, System::DateTime date) - { - m_pdxType->AddFixedLengthTypeField(fieldName, "Date", PdxTypes::DATE, GemFireClassIds::DATE_SIZE); - PdxLocalWriter::WriteDate(fieldName, date); - return this; - } - - IPdxWriter^ PdxWriterWithTypeCollector::WriteBooleanArray( String^ fieldName, array<bool>^ boolArray) - { - m_pdxType->AddVariableLengthTypeField(fieldName, "bool[]", PdxTypes::BOOLEAN_ARRAY); - PdxLocalWriter::WriteBooleanArray(fieldName, boolArray); - return this; - } - - IPdxWriter^ PdxWriterWithTypeCollector::WriteCharArray(String^ fieldName, array<Char>^ charArray) - { - m_pdxType->AddVariableLengthTypeField(fieldName, "char[]", PdxTypes::CHAR_ARRAY); - PdxLocalWriter::WriteCharArray(fieldName, charArray); - return this; - } - - IPdxWriter^ PdxWriterWithTypeCollector::WriteByteArray(String^ fieldName, array<Byte>^ byteArray) - { - m_pdxType->AddVariableLengthTypeField(fieldName, "byte[]", PdxTypes::BYTE_ARRAY); - PdxLocalWriter::WriteByteArray(fieldName, byteArray); - return this; - } - - IPdxWriter^ PdxWriterWithTypeCollector::WriteSByteArray(String^ fieldName, array<SByte>^ sbyteArray) - { - m_pdxType->AddVariableLengthTypeField(fieldName, "byte[]", PdxTypes::BYTE_ARRAY); - PdxLocalWriter::WriteSByteArray(fieldName, sbyteArray); - return this; - } - - IPdxWriter^ PdxWriterWithTypeCollector::WriteShortArray(String^ fieldName, array<System::Int16>^ shortArray) - { - m_pdxType->AddVariableLengthTypeField(fieldName, "short[]", PdxTypes::SHORT_ARRAY); - PdxLocalWriter::WriteShortArray(fieldName, shortArray); - return this; - } - - IPdxWriter^ PdxWriterWithTypeCollector::WriteUnsignedShortArray(String^ fieldName, array<System::UInt16>^ ushortArray) - { - m_pdxType->AddVariableLengthTypeField(fieldName, "short[]", PdxTypes::SHORT_ARRAY); - PdxLocalWriter::WriteUnsignedShortArray(fieldName, ushortArray); - return this; - } - - IPdxWriter^ PdxWriterWithTypeCollector::WriteIntArray(String^ fieldName, array<System::Int32>^ intArray) - { - m_pdxType->AddVariableLengthTypeField(fieldName, "int[]", PdxTypes::INT_ARRAY); - PdxLocalWriter::WriteIntArray(fieldName, intArray); - return this; - } - - IPdxWriter^ PdxWriterWithTypeCollector::WriteUnsignedIntArray(String^ fieldName, array<System::UInt32>^ uintArray) - { - m_pdxType->AddVariableLengthTypeField(fieldName, "int[]", PdxTypes::INT_ARRAY); - PdxLocalWriter::WriteUnsignedIntArray(fieldName, uintArray); - return this; - } - - IPdxWriter^ PdxWriterWithTypeCollector::WriteLongArray(String^ fieldName, array<Int64>^ longArray) - { - m_pdxType->AddVariableLengthTypeField(fieldName, "long[]", PdxTypes::LONG_ARRAY); - PdxLocalWriter::WriteLongArray(fieldName, longArray); - return this; - } - - IPdxWriter^ PdxWriterWithTypeCollector::WriteUnsignedLongArray(String^ fieldName, array<System::UInt64>^ ulongArray) - { - m_pdxType->AddVariableLengthTypeField(fieldName, "long[]", PdxTypes::LONG_ARRAY); - PdxLocalWriter::WriteUnsignedLongArray(fieldName, ulongArray); - return this; - } - - IPdxWriter^ PdxWriterWithTypeCollector::WriteFloatArray(String^ fieldName, array<float>^ floatArray) - { - m_pdxType->AddVariableLengthTypeField(fieldName, "float[]", PdxTypes::FLOAT_ARRAY); - PdxLocalWriter::WriteFloatArray(fieldName, floatArray); - return this; - } - - IPdxWriter^ PdxWriterWithTypeCollector::WriteDoubleArray(String^ fieldName, array<double>^ doubleArray) - { - m_pdxType->AddVariableLengthTypeField(fieldName, "double[]", PdxTypes::DOUBLE_ARRAY); - PdxLocalWriter::WriteDoubleArray(fieldName, doubleArray); - return this; - } - - IPdxWriter^ PdxWriterWithTypeCollector::WriteStringArray(String^ fieldName, array<String^>^ stringArray) - { - m_pdxType->AddVariableLengthTypeField(fieldName, "String[]", PdxTypes::STRING_ARRAY); - PdxLocalWriter::WriteStringArray(fieldName, stringArray); - return this; - } - - IPdxWriter^ PdxWriterWithTypeCollector::WriteObjectArray(String^ fieldName, List<Object^>^ objectArray) - { - m_pdxType->AddVariableLengthTypeField(fieldName, "Object[]", PdxTypes::OBJECT_ARRAY); - PdxLocalWriter::WriteObjectArray(fieldName, objectArray); - return this; - } - - IPdxWriter^ PdxWriterWithTypeCollector::WriteArrayOfByteArrays(String^ fieldName, array<array<Byte>^>^ byteArrays) - { - m_pdxType->AddVariableLengthTypeField(fieldName, "byte[][]", PdxTypes::ARRAY_OF_BYTE_ARRAYS); - PdxLocalWriter::WriteArrayOfByteArrays(fieldName, byteArrays); - return this; - - } - - //TODO: - //IPdxWriter^ PdxWriterWithTypeCollector::WriteEnum(String^ fieldName, Enum e) ; - //IPdxWriter^ PdxWriterWithTypeCollector::WriteInetAddress(String^ fieldName, InetAddress address); - - - IPdxWriter^ PdxWriterWithTypeCollector::MarkIdentityField(String^ fieldName) - { - PdxFieldType^ pft = m_pdxType->GetPdxField(fieldName); - - if(pft == nullptr) - { - throw gcnew IllegalStateException( - "Field must be written to IPdxWriter before calling MarkIdentityField "); - } - - pft->IdentityField = true; - return this; - } // namespace Client - } // namespace Geode -} // namespace Apache + void PdxWriterWithTypeCollector::initialize() + { + m_offsets = gcnew System::Collections::Generic::List<Int32>(); + m_pdxType = gcnew PdxType(m_pdxClassName, true); + } + + Int32 PdxWriterWithTypeCollector::calculateLenWithOffsets() + { + int bufferLen = m_dataOutput->BufferLength - m_startPositionOffset; + Int32 totalOffsets = 0; + if (m_offsets->Count > 0) + totalOffsets = m_offsets->Count - 1;//for first var len no need to append offset + Int32 totalLen = bufferLen - PdxHelper::PdxHeader + totalOffsets; + + + if (totalLen <= 0xff) + return totalLen; + else if (totalLen + totalOffsets <= 0xffff) + return totalLen + totalOffsets; + else + return totalLen + totalOffsets * 3; + } + + void PdxWriterWithTypeCollector::AddOffset() + { + int bufferLen = m_dataOutput->BufferLength - m_startPositionOffset; + int offset = bufferLen - PdxHelper::PdxHeader; + + m_offsets->Add(offset); + } + + void PdxWriterWithTypeCollector::EndObjectWriting() + {//write header + PdxLocalWriter::WritePdxHeader(); + } + + void PdxWriterWithTypeCollector::WriteOffsets(Int32 len) + { + if (len <= 0xff) + { + for (int i = m_offsets->Count - 1; i > 0; i--) + m_dataOutput->WriteByte((Byte)m_offsets[i]); + } + else if (len <= 0xffff) + { + for (int i = m_offsets->Count - 1; i > 0; i--) + m_dataOutput->WriteUInt16((UInt16)m_offsets[i]); + } + else + { + for (int i = m_offsets->Count - 1; i > 0; i--) + m_dataOutput->WriteUInt32((UInt32)m_offsets[i]); + } + } + + bool PdxWriterWithTypeCollector::isFieldWritingStarted() + { + return m_pdxType->Totalfields > 0; + } + + IPdxWriter^ PdxWriterWithTypeCollector::WriteUnreadFields(IPdxUnreadFields^ unread) + { + PdxLocalWriter::WriteUnreadFields(unread); + return this; + } + + IPdxWriter^ PdxWriterWithTypeCollector::WriteByte(String^ fieldName, SByte value) + { + m_pdxType->AddFixedLengthTypeField(fieldName, "byte", PdxTypes::BYTE, GeodeClassIds::BYTE_SIZE); + PdxLocalWriter::WriteByte(fieldName, value); + return this; + } + + IPdxWriter^ PdxWriterWithTypeCollector::WriteSByte(String^ fieldName, SByte value) + { + m_pdxType->AddFixedLengthTypeField(fieldName, "byte", PdxTypes::BYTE, GeodeClassIds::BYTE_SIZE); + PdxLocalWriter::WriteSByte(fieldName, value); + return this; + } + + IPdxWriter^ PdxWriterWithTypeCollector::WriteBoolean(String^ fieldName, bool value) + { + m_pdxType->AddFixedLengthTypeField(fieldName, "boolean", PdxTypes::BOOLEAN, GeodeClassIds::BOOLEAN_SIZE); + PdxLocalWriter::WriteBoolean(fieldName, value); + return this; + } + + IPdxWriter^ PdxWriterWithTypeCollector::WriteChar(String^ fieldName, Char value) + { + m_pdxType->AddFixedLengthTypeField(fieldName, "char", PdxTypes::CHAR, GeodeClassIds::CHAR_SIZE); + PdxLocalWriter::WriteChar(fieldName, value); + return this; + } + + IPdxWriter^ PdxWriterWithTypeCollector::WriteUInt16(String^ fieldName, uint16_t value) + { + m_pdxType->AddFixedLengthTypeField(fieldName, "short", PdxTypes::SHORT, GeodeClassIds::SHORT_SIZE); + PdxLocalWriter::WriteUInt16(fieldName, value); + return this; + } + + IPdxWriter^ PdxWriterWithTypeCollector::WriteUInt32(String^ fieldName, uint32_t value) + { + m_pdxType->AddFixedLengthTypeField(fieldName, "int", PdxTypes::INT, GeodeClassIds::INTEGER_SIZE); + PdxLocalWriter::WriteUInt32(fieldName, value); + return this; + } + + IPdxWriter^ PdxWriterWithTypeCollector::WriteUInt64(String^ fieldName, uint64_t value) + { + m_pdxType->AddFixedLengthTypeField(fieldName, "long", PdxTypes::LONG, GeodeClassIds::LONG_SIZE); + PdxLocalWriter::WriteUInt64(fieldName, value); + return this; + } + + IPdxWriter^ PdxWriterWithTypeCollector::WriteShort(String^ fieldName, int16_t value) + { + m_pdxType->AddFixedLengthTypeField(fieldName, "short", PdxTypes::SHORT, GeodeClassIds::SHORT_SIZE); + PdxLocalWriter::WriteShort(fieldName, value); + return this; + } + + IPdxWriter^ PdxWriterWithTypeCollector::WriteInt(String^ fieldName, int32_t value) + { + m_pdxType->AddFixedLengthTypeField(fieldName, "int", PdxTypes::INT, GeodeClassIds::INTEGER_SIZE); + PdxLocalWriter::WriteInt(fieldName, value); + return this; + } + + IPdxWriter^ PdxWriterWithTypeCollector::WriteLong(String^ fieldName, Int64 value) + { + m_pdxType->AddFixedLengthTypeField(fieldName, "long", PdxTypes::LONG, GeodeClassIds::LONG_SIZE); + PdxLocalWriter::WriteLong(fieldName, value); + return this; + } + + IPdxWriter^ PdxWriterWithTypeCollector::WriteFloat(String^ fieldName, float value) + { + m_pdxType->AddFixedLengthTypeField(fieldName, "float", PdxTypes::FLOAT, GeodeClassIds::FLOAT_SIZE); + PdxLocalWriter::WriteFloat(fieldName, value); + return this; + } + + IPdxWriter^ PdxWriterWithTypeCollector::WriteDouble(String^ fieldName, double value) + { + m_pdxType->AddFixedLengthTypeField(fieldName, "double", PdxTypes::DOUBLE, GeodeClassIds::DOUBLE_SIZE); + PdxLocalWriter::WriteDouble(fieldName, value); + return this; + } + + IPdxWriter^ PdxWriterWithTypeCollector::WriteString(String^ fieldName, String^ value) + { + m_pdxType->AddVariableLengthTypeField(fieldName, "String", PdxTypes::STRING); + PdxLocalWriter::WriteString(fieldName, value); + return this; + } + + IPdxWriter^ PdxWriterWithTypeCollector::WriteUTFHuge(String^ fieldName, String^ value) + { + m_pdxType->AddVariableLengthTypeField(fieldName, "stringUTFHuge", PdxTypes::STRING); + PdxLocalWriter::WriteUTFHuge(fieldName, value); + return this; + } + + IPdxWriter^ PdxWriterWithTypeCollector::WriteASCIIHuge(String^ fieldName, String^ value) + { + m_pdxType->AddVariableLengthTypeField(fieldName, "stringASCIIHuge", PdxTypes::STRING); + PdxLocalWriter::WriteASCIIHuge(fieldName, value); + return this; + } + + IPdxWriter^ PdxWriterWithTypeCollector::WriteObject(String^ fieldName, Object^ obj) + { + m_pdxType->AddVariableLengthTypeField(fieldName, /*obj->GetType()->FullName*/"Object", PdxTypes::OBJECT); + PdxLocalWriter::WriteObject(fieldName, obj); + return this; + } + + //TODO: + //IPdxWriter^ PdxWriterWithTypeCollector::WriteMap( String^ fieldName, System::Collections::IDictionary^ map ); + + IPdxWriter^ PdxWriterWithTypeCollector::WriteCollection(String^ fieldName, System::Collections::IList^ obj) + { + m_pdxType->AddVariableLengthTypeField(fieldName, /*obj->GetType()->FullName*/"Collection", apache::geode::client::GeodeTypeIds::CacheableArrayList); + PdxLocalWriter::WriteCollection(fieldName, obj); + return this; + } + + IPdxWriter^ PdxWriterWithTypeCollector::WriteDate(String^ fieldName, System::DateTime date) + { + m_pdxType->AddFixedLengthTypeField(fieldName, "Date", PdxTypes::DATE, GeodeClassIds::DATE_SIZE); + PdxLocalWriter::WriteDate(fieldName, date); + return this; + } + + IPdxWriter^ PdxWriterWithTypeCollector::WriteBooleanArray(String^ fieldName, array<bool>^ boolArray) + { + m_pdxType->AddVariableLengthTypeField(fieldName, "bool[]", PdxTypes::BOOLEAN_ARRAY); + PdxLocalWriter::WriteBooleanArray(fieldName, boolArray); + return this; + } + + IPdxWriter^ PdxWriterWithTypeCollector::WriteCharArray(String^ fieldName, array<Char>^ charArray) + { + m_pdxType->AddVariableLengthTypeField(fieldName, "char[]", PdxTypes::CHAR_ARRAY); + PdxLocalWriter::WriteCharArray(fieldName, charArray); + return this; + } + + IPdxWriter^ PdxWriterWithTypeCollector::WriteByteArray(String^ fieldName, array<Byte>^ byteArray) + { + m_pdxType->AddVariableLengthTypeField(fieldName, "byte[]", PdxTypes::BYTE_ARRAY); + PdxLocalWriter::WriteByteArray(fieldName, byteArray); + return this; + } + + IPdxWriter^ PdxWriterWithTypeCollector::WriteSByteArray(String^ fieldName, array<SByte>^ sbyteArray) + { + m_pdxType->AddVariableLengthTypeField(fieldName, "byte[]", PdxTypes::BYTE_ARRAY); + PdxLocalWriter::WriteSByteArray(fieldName, sbyteArray); + return this; + } + + IPdxWriter^ PdxWriterWithTypeCollector::WriteShortArray(String^ fieldName, array<System::Int16>^ shortArray) + { + m_pdxType->AddVariableLengthTypeField(fieldName, "short[]", PdxTypes::SHORT_ARRAY); + PdxLocalWriter::WriteShortArray(fieldName, shortArray); + return this; + } + + IPdxWriter^ PdxWriterWithTypeCollector::WriteUnsignedShortArray(String^ fieldName, array<System::UInt16>^ ushortArray) + { + m_pdxType->AddVariableLengthTypeField(fieldName, "short[]", PdxTypes::SHORT_ARRAY); + PdxLocalWriter::WriteUnsignedShortArray(fieldName, ushortArray); + return this; + } + + IPdxWriter^ PdxWriterWithTypeCollector::WriteIntArray(String^ fieldName, array<System::Int32>^ intArray) + { + m_pdxType->AddVariableLengthTypeField(fieldName, "int[]", PdxTypes::INT_ARRAY); + PdxLocalWriter::WriteIntArray(fieldName, intArray); + return this; + } + + IPdxWriter^ PdxWriterWithTypeCollector::WriteUnsignedIntArray(String^ fieldName, array<System::UInt32>^ uintArray) + { + m_pdxType->AddVariableLengthTypeField(fieldName, "int[]", PdxTypes::INT_ARRAY); + PdxLocalWriter::WriteUnsignedIntArray(fieldName, uintArray); + return this; + } + + IPdxWriter^ PdxWriterWithTypeCollector::WriteLongArray(String^ fieldName, array<Int64>^ longArray) + { + m_pdxType->AddVariableLengthTypeField(fieldName, "long[]", PdxTypes::LONG_ARRAY); + PdxLocalWriter::WriteLongArray(fieldName, longArray); + return this; + } + + IPdxWriter^ PdxWriterWithTypeCollector::WriteUnsignedLongArray(String^ fieldName, array<System::UInt64>^ ulongArray) + { + m_pdxType->AddVariableLengthTypeField(fieldName, "long[]", PdxTypes::LONG_ARRAY); + PdxLocalWriter::WriteUnsignedLongArray(fieldName, ulongArray); + return this; + } + + IPdxWriter^ PdxWriterWithTypeCollector::WriteFloatArray(String^ fieldName, array<float>^ floatArray) + { + m_pdxType->AddVariableLengthTypeField(fieldName, "float[]", PdxTypes::FLOAT_ARRAY); + PdxLocalWriter::WriteFloatArray(fieldName, floatArray); + return this; + } + + IPdxWriter^ PdxWriterWithTypeCollector::WriteDoubleArray(String^ fieldName, array<double>^ doubleArray) + { + m_pdxType->AddVariableLengthTypeField(fieldName, "double[]", PdxTypes::DOUBLE_ARRAY); + PdxLocalWriter::WriteDoubleArray(fieldName, doubleArray); + return this; + } + + IPdxWriter^ PdxWriterWithTypeCollector::WriteStringArray(String^ fieldName, array<String^>^ stringArray) + { + m_pdxType->AddVariableLengthTypeField(fieldName, "String[]", PdxTypes::STRING_ARRAY); + PdxLocalWriter::WriteStringArray(fieldName, stringArray); + return this; + } + + IPdxWriter^ PdxWriterWithTypeCollector::WriteObjectArray(String^ fieldName, List<Object^>^ objectArray) + { + m_pdxType->AddVariableLengthTypeField(fieldName, "Object[]", PdxTypes::OBJECT_ARRAY); + PdxLocalWriter::WriteObjectArray(fieldName, objectArray); + return this; + } + + IPdxWriter^ PdxWriterWithTypeCollector::WriteArrayOfByteArrays(String^ fieldName, array<array<Byte>^>^ byteArrays) + { + m_pdxType->AddVariableLengthTypeField(fieldName, "byte[][]", PdxTypes::ARRAY_OF_BYTE_ARRAYS); + PdxLocalWriter::WriteArrayOfByteArrays(fieldName, byteArrays); + return this; + + } + + //TODO: + //IPdxWriter^ PdxWriterWithTypeCollector::WriteEnum(String^ fieldName, Enum e) ; + //IPdxWriter^ PdxWriterWithTypeCollector::WriteInetAddress(String^ fieldName, InetAddress address); + + + IPdxWriter^ PdxWriterWithTypeCollector::MarkIdentityField(String^ fieldName) + { + PdxFieldType^ pft = m_pdxType->GetPdxField(fieldName); + + if (pft == nullptr) + { + throw gcnew IllegalStateException( + "Field must be written to IPdxWriter before calling MarkIdentityField "); + } + + pft->IdentityField = true; + return this; + } // namespace Client + } // namespace Geode + } // namespace Apache } } \ No newline at end of file
