http://git-wip-us.apache.org/repos/asf/geode-native/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
