Repository: ignite Updated Branches: refs/heads/ignite-1282 6b8932be5 -> d90d1e2ec
IGNITE-1282: .Net: RawReader -> GetRawReader, RawWriter -> GetRawWriter. Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/d90d1e2e Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/d90d1e2e Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/d90d1e2e Branch: refs/heads/ignite-1282 Commit: d90d1e2ec8f4789a1d23c73ce4905fccadb986dc Parents: 6b8932b Author: vozerov-gridgain <[email protected]> Authored: Thu Oct 8 17:02:23 2015 +0300 Committer: vozerov-gridgain <[email protected]> Committed: Thu Oct 8 17:02:23 2015 +0300 ---------------------------------------------------------------------- .../Cache/CacheAbstractTest.cs | 8 +++--- .../Cache/Query/CacheQueriesTest.cs | 4 +-- .../Compute/PortableClosureTaskTest.cs | 4 +-- .../Apache.Ignite.Core.Tests/EventsTest.cs | 4 +-- .../Apache.Ignite.Core.Tests/FutureTest.cs | 4 +-- .../Portable/PortableApiSelfTest.cs | 4 +-- .../Portable/PortableSelfTest.cs | 28 ++++++++++---------- .../Apache.Ignite.Core/Events/EventReader.cs | 2 +- .../Impl/Cache/CacheEntryFilterHolder.cs | 6 ++--- .../Impl/Cache/CacheEntryProcessorHolder.cs | 4 +-- .../Continuous/ContinuousQueryFilterHolder.cs | 4 +-- .../Impl/Cache/Store/CacheStore.cs | 2 +- .../Impl/Common/PortableResultWrapper.cs | 4 +-- .../Impl/Compute/Closure/ComputeActionJob.cs | 4 +-- .../Impl/Compute/Closure/ComputeFuncJob.cs | 4 +-- .../Impl/Compute/Closure/ComputeOutFuncJob.cs | 4 +-- .../Impl/Compute/ComputeFunc.cs | 4 +-- .../Impl/Compute/ComputeJob.cs | 4 +-- .../Impl/Compute/ComputeJobHolder.cs | 4 +-- .../Impl/Compute/ComputeOutFunc.cs | 4 +-- .../Impl/Datastream/StreamReceiverHolder.cs | 2 +- .../Apache.Ignite.Core/Impl/Events/Events.cs | 2 +- .../Impl/InteropExceptionHolder.cs | 2 +- .../Impl/Messaging/MessageFilterHolder.cs | 6 ++--- .../Impl/Messaging/Messaging.cs | 2 +- .../PortableOrSerializableObjectHolder.cs | 4 +-- .../Impl/Portable/PortableReaderImpl.cs | 2 +- .../Impl/Portable/PortableWriterImpl.cs | 2 +- .../Impl/Portable/SerializableObjectHolder.cs | 4 +-- .../Impl/Transactions/TransactionsImpl.cs | 2 +- .../Portable/IPortableReader.cs | 2 +- .../Portable/IPortableWriter.cs | 2 +- 32 files changed, 69 insertions(+), 69 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/d90d1e2e/modules/platforms/dotnet/Apache.Ignite.Core.Tests/Cache/CacheAbstractTest.cs ---------------------------------------------------------------------- diff --git a/modules/platforms/dotnet/Apache.Ignite.Core.Tests/Cache/CacheAbstractTest.cs b/modules/platforms/dotnet/Apache.Ignite.Core.Tests/Cache/CacheAbstractTest.cs index ae00c91..964f4e8 100644 --- a/modules/platforms/dotnet/Apache.Ignite.Core.Tests/Cache/CacheAbstractTest.cs +++ b/modules/platforms/dotnet/Apache.Ignite.Core.Tests/Cache/CacheAbstractTest.cs @@ -212,7 +212,7 @@ namespace Apache.Ignite.Core.Tests.Cache /** <inheritdoc /> */ public void WritePortable(IPortableWriter writer) { - var w = writer.RawWriter(); + var w = writer.GetRawWriter(); w.WriteBoolean(ThrowErr); w.WriteBoolean(ThrowErrPortable); @@ -225,7 +225,7 @@ namespace Apache.Ignite.Core.Tests.Cache /** <inheritdoc /> */ public void ReadPortable(IPortableReader reader) { - var r = reader.RawReader(); + var r = reader.GetRawReader(); ThrowErr = r.ReadBoolean(); ThrowErrPortable = r.ReadBoolean(); @@ -263,13 +263,13 @@ namespace Apache.Ignite.Core.Tests.Cache /** <inheritdoc /> */ public void WritePortable(IPortableWriter writer) { - writer.RawWriter().WriteString(Info); + writer.GetRawWriter().WriteString(Info); } /** <inheritdoc /> */ public void ReadPortable(IPortableReader reader) { - Info = reader.RawReader().ReadString(); + Info = reader.GetRawReader().ReadString(); } } http://git-wip-us.apache.org/repos/asf/ignite/blob/d90d1e2e/modules/platforms/dotnet/Apache.Ignite.Core.Tests/Cache/Query/CacheQueriesTest.cs ---------------------------------------------------------------------- diff --git a/modules/platforms/dotnet/Apache.Ignite.Core.Tests/Cache/Query/CacheQueriesTest.cs b/modules/platforms/dotnet/Apache.Ignite.Core.Tests/Cache/Query/CacheQueriesTest.cs index 18f04ef..ba104c0 100644 --- a/modules/platforms/dotnet/Apache.Ignite.Core.Tests/Cache/Query/CacheQueriesTest.cs +++ b/modules/platforms/dotnet/Apache.Ignite.Core.Tests/Cache/Query/CacheQueriesTest.cs @@ -912,7 +912,7 @@ namespace Apache.Ignite.Core.Tests.Cache.Query /** <inheritdoc /> */ public void WritePortable(IPortableWriter writer) { - var w = writer.RawWriter(); + var w = writer.GetRawWriter(); w.WriteBoolean(ThrowErr); } @@ -920,7 +920,7 @@ namespace Apache.Ignite.Core.Tests.Cache.Query /** <inheritdoc /> */ public void ReadPortable(IPortableReader reader) { - var r = reader.RawReader(); + var r = reader.GetRawReader(); ThrowErr = r.ReadBoolean(); } http://git-wip-us.apache.org/repos/asf/ignite/blob/d90d1e2e/modules/platforms/dotnet/Apache.Ignite.Core.Tests/Compute/PortableClosureTaskTest.cs ---------------------------------------------------------------------- diff --git a/modules/platforms/dotnet/Apache.Ignite.Core.Tests/Compute/PortableClosureTaskTest.cs b/modules/platforms/dotnet/Apache.Ignite.Core.Tests/Compute/PortableClosureTaskTest.cs index 3ca933e..598a7ea 100644 --- a/modules/platforms/dotnet/Apache.Ignite.Core.Tests/Compute/PortableClosureTaskTest.cs +++ b/modules/platforms/dotnet/Apache.Ignite.Core.Tests/Compute/PortableClosureTaskTest.cs @@ -178,13 +178,13 @@ namespace Apache.Ignite.Core.Tests.Compute /** <inheritDoc /> */ public void WritePortable(IPortableWriter writer) { - writer.RawWriter().WriteString(Msg); + writer.GetRawWriter().WriteString(Msg); } /** <inheritDoc /> */ public void ReadPortable(IPortableReader reader) { - Msg = reader.RawReader().ReadString(); + Msg = reader.GetRawReader().ReadString(); } } http://git-wip-us.apache.org/repos/asf/ignite/blob/d90d1e2e/modules/platforms/dotnet/Apache.Ignite.Core.Tests/EventsTest.cs ---------------------------------------------------------------------- diff --git a/modules/platforms/dotnet/Apache.Ignite.Core.Tests/EventsTest.cs b/modules/platforms/dotnet/Apache.Ignite.Core.Tests/EventsTest.cs index 9e82a09..de90cd3 100644 --- a/modules/platforms/dotnet/Apache.Ignite.Core.Tests/EventsTest.cs +++ b/modules/platforms/dotnet/Apache.Ignite.Core.Tests/EventsTest.cs @@ -912,13 +912,13 @@ namespace Apache.Ignite.Core.Tests /** <inheritdoc /> */ public void WritePortable(IPortableWriter writer) { - writer.RawWriter().WriteInt(_type); + writer.GetRawWriter().WriteInt(_type); } /** <inheritdoc /> */ public void ReadPortable(IPortableReader reader) { - _type = reader.RawReader().ReadInt(); + _type = reader.GetRawReader().ReadInt(); } } http://git-wip-us.apache.org/repos/asf/ignite/blob/d90d1e2e/modules/platforms/dotnet/Apache.Ignite.Core.Tests/FutureTest.cs ---------------------------------------------------------------------- diff --git a/modules/platforms/dotnet/Apache.Ignite.Core.Tests/FutureTest.cs b/modules/platforms/dotnet/Apache.Ignite.Core.Tests/FutureTest.cs index 993c604..226d4b4 100644 --- a/modules/platforms/dotnet/Apache.Ignite.Core.Tests/FutureTest.cs +++ b/modules/platforms/dotnet/Apache.Ignite.Core.Tests/FutureTest.cs @@ -224,14 +224,14 @@ namespace Apache.Ignite.Core.Tests public void WritePortable(IPortableWriter writer) { writer.WriteInt("a", A); - writer.RawWriter().WriteString(B); + writer.GetRawWriter().WriteString(B); } /** <inheritDoc /> */ public void ReadPortable(IPortableReader reader) { A = reader.ReadInt("a"); - B = reader.RawReader().ReadString(); + B = reader.GetRawReader().ReadString(); } /** <inheritDoc /> */ http://git-wip-us.apache.org/repos/asf/ignite/blob/d90d1e2e/modules/platforms/dotnet/Apache.Ignite.Core.Tests/Portable/PortableApiSelfTest.cs ---------------------------------------------------------------------- diff --git a/modules/platforms/dotnet/Apache.Ignite.Core.Tests/Portable/PortableApiSelfTest.cs b/modules/platforms/dotnet/Apache.Ignite.Core.Tests/Portable/PortableApiSelfTest.cs index 8c5bb0b..90f49a0 100644 --- a/modules/platforms/dotnet/Apache.Ignite.Core.Tests/Portable/PortableApiSelfTest.cs +++ b/modules/platforms/dotnet/Apache.Ignite.Core.Tests/Portable/PortableApiSelfTest.cs @@ -1513,14 +1513,14 @@ namespace Apache.Ignite.Core.Tests.Portable public void WritePortable(IPortableWriter writer) { writer.WriteInt("a", A); - writer.RawWriter().WriteInt(B); + writer.GetRawWriter().WriteInt(B); } /** <inheritDoc /> */ public void ReadPortable(IPortableReader reader) { A = reader.ReadInt("a"); - B = reader.RawReader().ReadInt(); + B = reader.GetRawReader().ReadInt(); } } http://git-wip-us.apache.org/repos/asf/ignite/blob/d90d1e2e/modules/platforms/dotnet/Apache.Ignite.Core.Tests/Portable/PortableSelfTest.cs ---------------------------------------------------------------------- diff --git a/modules/platforms/dotnet/Apache.Ignite.Core.Tests/Portable/PortableSelfTest.cs b/modules/platforms/dotnet/Apache.Ignite.Core.Tests/Portable/PortableSelfTest.cs index 9fc5a93..db9a2f7 100644 --- a/modules/platforms/dotnet/Apache.Ignite.Core.Tests/Portable/PortableSelfTest.cs +++ b/modules/platforms/dotnet/Apache.Ignite.Core.Tests/Portable/PortableSelfTest.cs @@ -1613,7 +1613,7 @@ namespace Apache.Ignite.Core.Tests.Portable { public unsafe void WritePortable(IPortableWriter writer) { - IPortableRawWriter rawWriter = writer.RawWriter(); + IPortableRawWriter rawWriter = writer.GetRawWriter(); rawWriter.WriteBoolean(PBool); rawWriter.WriteByte(PByte); @@ -1641,7 +1641,7 @@ namespace Apache.Ignite.Core.Tests.Portable public unsafe void ReadPortable(IPortableReader reader) { - IPortableRawReader rawReader = reader.RawReader(); + IPortableRawReader rawReader = reader.GetRawReader(); PBool = rawReader.ReadBoolean(); PByte = rawReader.ReadByte(); @@ -1735,7 +1735,7 @@ namespace Apache.Ignite.Core.Tests.Portable { PrimitiveFieldType obj0 = (PrimitiveFieldType)obj; - IPortableRawWriter rawWriter = writer.RawWriter(); + IPortableRawWriter rawWriter = writer.GetRawWriter(); rawWriter.WriteBoolean(obj0.PBool); rawWriter.WriteByte(obj0.PByte); @@ -1765,7 +1765,7 @@ namespace Apache.Ignite.Core.Tests.Portable { PrimitiveFieldType obj0 = (PrimitiveFieldType)obj; - IPortableRawReader rawReader = reader.RawReader(); + IPortableRawReader rawReader = reader.GetRawReader(); obj0.PBool = rawReader.ReadBoolean(); obj0.PByte = rawReader.ReadByte(); @@ -1819,7 +1819,7 @@ namespace Apache.Ignite.Core.Tests.Portable writer.WriteObject("inner", Inner); writer.WriteString("after", After); - IPortableRawWriter rawWriter = writer.RawWriter(); + IPortableRawWriter rawWriter = writer.GetRawWriter(); rawWriter.WriteString(RawBefore); rawWriter.WriteObject(RawInner); @@ -1833,7 +1833,7 @@ namespace Apache.Ignite.Core.Tests.Portable Inner = reader.ReadObject<HandleInner>("inner"); After = reader.ReadString("after"); - IPortableRawReader rawReader = reader.RawReader(); + IPortableRawReader rawReader = reader.GetRawReader(); RawBefore = rawReader.ReadString(); RawInner = rawReader.ReadObject<HandleInner>(); @@ -1858,7 +1858,7 @@ namespace Apache.Ignite.Core.Tests.Portable writer.WriteObject("outer", Outer); writer.WriteString("after", After); - IPortableRawWriter rawWriter = writer.RawWriter(); + IPortableRawWriter rawWriter = writer.GetRawWriter(); rawWriter.WriteString(RawBefore); rawWriter.WriteObject(RawOuter); @@ -1872,7 +1872,7 @@ namespace Apache.Ignite.Core.Tests.Portable Outer = reader.ReadObject<HandleOuter>("outer"); After = reader.ReadString("after"); - IPortableRawReader rawReader = reader.RawReader(); + IPortableRawReader rawReader = reader.GetRawReader(); RawBefore = rawReader.ReadString(); RawOuter = rawReader.ReadObject<HandleOuter>(); @@ -1894,7 +1894,7 @@ namespace Apache.Ignite.Core.Tests.Portable writer.WriteString("after", After); - IPortableRawWriter rawWriter = writer.RawWriter(); + IPortableRawWriter rawWriter = writer.GetRawWriter(); rawWriter.WriteString(RawBefore); @@ -1915,7 +1915,7 @@ namespace Apache.Ignite.Core.Tests.Portable After = reader0.ReadString("after"); - var rawReader = (PortableReaderImpl) reader.RawReader(); + var rawReader = (PortableReaderImpl) reader.GetRawReader(); RawBefore = rawReader.ReadString(); @@ -1965,7 +1965,7 @@ namespace Apache.Ignite.Core.Tests.Portable writer.WriteDecimal("val", Val); writer.WriteDecimalArray("valArr", ValArr); - IPortableRawWriter rawWriter = writer.RawWriter(); + IPortableRawWriter rawWriter = writer.GetRawWriter(); rawWriter.WriteDecimal(RawVal); rawWriter.WriteDecimalArray(RawValArr); @@ -1977,7 +1977,7 @@ namespace Apache.Ignite.Core.Tests.Portable Val = reader.ReadDecimal("val"); ValArr = reader.ReadDecimalArray("valArr"); - IPortableRawReader rawReader = reader.RawReader(); + IPortableRawReader rawReader = reader.GetRawReader(); RawVal = rawReader.ReadDecimal(); RawValArr = rawReader.ReadDecimalArray(); @@ -2042,7 +2042,7 @@ namespace Apache.Ignite.Core.Tests.Portable writer.WriteDateArray("locArr", LocArr); writer.WriteDateArray("utcArr", UtcArr); - IPortableRawWriter rawWriter = writer.RawWriter(); + IPortableRawWriter rawWriter = writer.GetRawWriter(); rawWriter.WriteDate(LocRaw); rawWriter.WriteDate(UtcRaw); @@ -2062,7 +2062,7 @@ namespace Apache.Ignite.Core.Tests.Portable LocArr = reader.ReadDateArray("locArr", true); UtcArr = reader.ReadDateArray("utcArr", false); - IPortableRawReader rawReader = reader.RawReader(); + IPortableRawReader rawReader = reader.GetRawReader(); LocRaw = rawReader.ReadDate(true).Value; UtcRaw = rawReader.ReadDate(false).Value; http://git-wip-us.apache.org/repos/asf/ignite/blob/d90d1e2e/modules/platforms/dotnet/Apache.Ignite.Core/Events/EventReader.cs ---------------------------------------------------------------------- diff --git a/modules/platforms/dotnet/Apache.Ignite.Core/Events/EventReader.cs b/modules/platforms/dotnet/Apache.Ignite.Core/Events/EventReader.cs index aa9f538..4eaef2c 100644 --- a/modules/platforms/dotnet/Apache.Ignite.Core/Events/EventReader.cs +++ b/modules/platforms/dotnet/Apache.Ignite.Core/Events/EventReader.cs @@ -34,7 +34,7 @@ namespace Apache.Ignite.Core.Events /// <exception cref="System.InvalidCastException">Incompatible event type.</exception> public static T Read<T>(IPortableReader reader) where T : IEvent { - var r = reader.RawReader(); + var r = reader.GetRawReader(); var clsId = r.ReadInt(); http://git-wip-us.apache.org/repos/asf/ignite/blob/d90d1e2e/modules/platforms/dotnet/Apache.Ignite.Core/Impl/Cache/CacheEntryFilterHolder.cs ---------------------------------------------------------------------- diff --git a/modules/platforms/dotnet/Apache.Ignite.Core/Impl/Cache/CacheEntryFilterHolder.cs b/modules/platforms/dotnet/Apache.Ignite.Core/Impl/Cache/CacheEntryFilterHolder.cs index 024895a..279979a 100644 --- a/modules/platforms/dotnet/Apache.Ignite.Core/Impl/Cache/CacheEntryFilterHolder.cs +++ b/modules/platforms/dotnet/Apache.Ignite.Core/Impl/Cache/CacheEntryFilterHolder.cs @@ -82,7 +82,7 @@ namespace Apache.Ignite.Core.Impl.Cache /// <returns>Invocation result.</returns> public int Invoke(IPortableStream input) { - var rawReader = _marsh.StartUnmarshal(input, _keepPortable).RawReader(); + var rawReader = _marsh.StartUnmarshal(input, _keepPortable).GetRawReader(); return _invoker(rawReader.ReadObject<object>(), rawReader.ReadObject<object>()) ? 1 : 0; } @@ -90,7 +90,7 @@ namespace Apache.Ignite.Core.Impl.Cache /** <inheritdoc /> */ public void WritePortable(IPortableWriter writer) { - var writer0 = (PortableWriterImpl)writer.RawWriter(); + var writer0 = (PortableWriterImpl)writer.GetRawWriter(); writer0.WithDetach(w => PortableUtils.WritePortableOrSerializable(w, _pred)); @@ -103,7 +103,7 @@ namespace Apache.Ignite.Core.Impl.Cache /// <param name="reader">The reader.</param> public CacheEntryFilterHolder(IPortableReader reader) { - var reader0 = (PortableReaderImpl)reader.RawReader(); + var reader0 = (PortableReaderImpl)reader.GetRawReader(); _pred = PortableUtils.ReadPortableOrSerializable<object>(reader0); http://git-wip-us.apache.org/repos/asf/ignite/blob/d90d1e2e/modules/platforms/dotnet/Apache.Ignite.Core/Impl/Cache/CacheEntryProcessorHolder.cs ---------------------------------------------------------------------- diff --git a/modules/platforms/dotnet/Apache.Ignite.Core/Impl/Cache/CacheEntryProcessorHolder.cs b/modules/platforms/dotnet/Apache.Ignite.Core/Impl/Cache/CacheEntryProcessorHolder.cs index 4d625c2..8b30536 100644 --- a/modules/platforms/dotnet/Apache.Ignite.Core/Impl/Cache/CacheEntryProcessorHolder.cs +++ b/modules/platforms/dotnet/Apache.Ignite.Core/Impl/Cache/CacheEntryProcessorHolder.cs @@ -103,7 +103,7 @@ namespace Apache.Ignite.Core.Impl.Cache /** <inheritDoc /> */ public void WritePortable(IPortableWriter writer) { - var writer0 = (PortableWriterImpl) writer.RawWriter(); + var writer0 = (PortableWriterImpl) writer.GetRawWriter(); writer0.WithDetach(w => PortableUtils.WritePortableOrSerializable(w, _proc)); writer0.WithDetach(w => PortableUtils.WritePortableOrSerializable(w, _arg)); @@ -115,7 +115,7 @@ namespace Apache.Ignite.Core.Impl.Cache /// <param name="reader">The reader.</param> public CacheEntryProcessorHolder(IPortableReader reader) { - var reader0 = (PortableReaderImpl) reader.RawReader(); + var reader0 = (PortableReaderImpl) reader.GetRawReader(); _proc = PortableUtils.ReadPortableOrSerializable<object>(reader0); _arg = PortableUtils.ReadPortableOrSerializable<object>(reader0); http://git-wip-us.apache.org/repos/asf/ignite/blob/d90d1e2e/modules/platforms/dotnet/Apache.Ignite.Core/Impl/Cache/Query/Continuous/ContinuousQueryFilterHolder.cs ---------------------------------------------------------------------- diff --git a/modules/platforms/dotnet/Apache.Ignite.Core/Impl/Cache/Query/Continuous/ContinuousQueryFilterHolder.cs b/modules/platforms/dotnet/Apache.Ignite.Core/Impl/Cache/Query/Continuous/ContinuousQueryFilterHolder.cs index 65da674..9b1f8f4 100644 --- a/modules/platforms/dotnet/Apache.Ignite.Core/Impl/Cache/Query/Continuous/ContinuousQueryFilterHolder.cs +++ b/modules/platforms/dotnet/Apache.Ignite.Core/Impl/Cache/Query/Continuous/ContinuousQueryFilterHolder.cs @@ -92,7 +92,7 @@ namespace Apache.Ignite.Core.Impl.Cache.Query.Continuous /// <param name="writer">Writer.</param> public void WritePortable(IPortableWriter writer) { - PortableWriterImpl rawWriter = (PortableWriterImpl) writer.RawWriter(); + PortableWriterImpl rawWriter = (PortableWriterImpl) writer.GetRawWriter(); PortableUtils.WritePortableOrSerializable(rawWriter, _keyTyp); PortableUtils.WritePortableOrSerializable(rawWriter, _valTyp); @@ -107,7 +107,7 @@ namespace Apache.Ignite.Core.Impl.Cache.Query.Continuous /// <param name="reader">The reader.</param> public ContinuousQueryFilterHolder(IPortableReader reader) { - PortableReaderImpl rawReader = (PortableReaderImpl) reader.RawReader(); + PortableReaderImpl rawReader = (PortableReaderImpl) reader.GetRawReader(); _keyTyp = PortableUtils.ReadPortableOrSerializable<Type>(rawReader); _valTyp = PortableUtils.ReadPortableOrSerializable<Type>(rawReader); http://git-wip-us.apache.org/repos/asf/ignite/blob/d90d1e2e/modules/platforms/dotnet/Apache.Ignite.Core/Impl/Cache/Store/CacheStore.cs ---------------------------------------------------------------------- diff --git a/modules/platforms/dotnet/Apache.Ignite.Core/Impl/Cache/Store/CacheStore.cs b/modules/platforms/dotnet/Apache.Ignite.Core/Impl/Cache/Store/CacheStore.cs index 85b968a..aac32c7 100644 --- a/modules/platforms/dotnet/Apache.Ignite.Core/Impl/Cache/Store/CacheStore.cs +++ b/modules/platforms/dotnet/Apache.Ignite.Core/Impl/Cache/Store/CacheStore.cs @@ -147,7 +147,7 @@ namespace Apache.Ignite.Core.Impl.Cache.Store IPortableReader reader = grid.Marshaller.StartUnmarshal(input, _convertPortable ? PortableMode.Deserialize : PortableMode.ForcePortable); - IPortableRawReader rawReader = reader.RawReader(); + IPortableRawReader rawReader = reader.GetRawReader(); int opType = rawReader.ReadByte(); http://git-wip-us.apache.org/repos/asf/ignite/blob/d90d1e2e/modules/platforms/dotnet/Apache.Ignite.Core/Impl/Common/PortableResultWrapper.cs ---------------------------------------------------------------------- diff --git a/modules/platforms/dotnet/Apache.Ignite.Core/Impl/Common/PortableResultWrapper.cs b/modules/platforms/dotnet/Apache.Ignite.Core/Impl/Common/PortableResultWrapper.cs index 71d842f..c9fddf3 100644 --- a/modules/platforms/dotnet/Apache.Ignite.Core/Impl/Common/PortableResultWrapper.cs +++ b/modules/platforms/dotnet/Apache.Ignite.Core/Impl/Common/PortableResultWrapper.cs @@ -34,7 +34,7 @@ namespace Apache.Ignite.Core.Impl.Common /// <param name="reader">The reader.</param> public PortableResultWrapper(IPortableReader reader) { - var reader0 = (PortableReaderImpl)reader.RawReader(); + var reader0 = (PortableReaderImpl)reader.GetRawReader(); _result = PortableUtils.ReadPortableOrSerializable<object>(reader0); } @@ -59,7 +59,7 @@ namespace Apache.Ignite.Core.Impl.Common /** <inheritDoc /> */ public void WritePortable(IPortableWriter writer) { - var writer0 = (PortableWriterImpl) writer.RawWriter(); + var writer0 = (PortableWriterImpl) writer.GetRawWriter(); writer0.WithDetach(w => PortableUtils.WritePortableOrSerializable(w, Result)); } http://git-wip-us.apache.org/repos/asf/ignite/blob/d90d1e2e/modules/platforms/dotnet/Apache.Ignite.Core/Impl/Compute/Closure/ComputeActionJob.cs ---------------------------------------------------------------------- diff --git a/modules/platforms/dotnet/Apache.Ignite.Core/Impl/Compute/Closure/ComputeActionJob.cs b/modules/platforms/dotnet/Apache.Ignite.Core/Impl/Compute/Closure/ComputeActionJob.cs index 58f8739..cc5e29f 100644 --- a/modules/platforms/dotnet/Apache.Ignite.Core/Impl/Compute/Closure/ComputeActionJob.cs +++ b/modules/platforms/dotnet/Apache.Ignite.Core/Impl/Compute/Closure/ComputeActionJob.cs @@ -63,7 +63,7 @@ namespace Apache.Ignite.Core.Impl.Compute.Closure /** <inheritDoc /> */ public void WritePortable(IPortableWriter writer) { - var writer0 = (PortableWriterImpl)writer.RawWriter(); + var writer0 = (PortableWriterImpl)writer.GetRawWriter(); writer0.WithDetach(w => PortableUtils.WritePortableOrSerializable(w, _action)); } @@ -74,7 +74,7 @@ namespace Apache.Ignite.Core.Impl.Compute.Closure /// <param name="reader">The reader.</param> public ComputeActionJob(IPortableReader reader) { - var reader0 = (PortableReaderImpl)reader.RawReader(); + var reader0 = (PortableReaderImpl)reader.GetRawReader(); _action = PortableUtils.ReadPortableOrSerializable<IComputeAction>(reader0); } http://git-wip-us.apache.org/repos/asf/ignite/blob/d90d1e2e/modules/platforms/dotnet/Apache.Ignite.Core/Impl/Compute/Closure/ComputeFuncJob.cs ---------------------------------------------------------------------- diff --git a/modules/platforms/dotnet/Apache.Ignite.Core/Impl/Compute/Closure/ComputeFuncJob.cs b/modules/platforms/dotnet/Apache.Ignite.Core/Impl/Compute/Closure/ComputeFuncJob.cs index d778632..072fe76 100644 --- a/modules/platforms/dotnet/Apache.Ignite.Core/Impl/Compute/Closure/ComputeFuncJob.cs +++ b/modules/platforms/dotnet/Apache.Ignite.Core/Impl/Compute/Closure/ComputeFuncJob.cs @@ -65,7 +65,7 @@ namespace Apache.Ignite.Core.Impl.Compute.Closure /** <inheritDoc /> */ public void WritePortable(IPortableWriter writer) { - PortableWriterImpl writer0 = (PortableWriterImpl) writer.RawWriter(); + PortableWriterImpl writer0 = (PortableWriterImpl) writer.GetRawWriter(); writer0.WithDetach(w => PortableUtils.WritePortableOrSerializable(w, _clo)); writer0.WithDetach(w => PortableUtils.WritePortableOrSerializable(w, _arg)); @@ -77,7 +77,7 @@ namespace Apache.Ignite.Core.Impl.Compute.Closure /// <param name="reader">The reader.</param> public ComputeFuncJob(IPortableReader reader) { - var reader0 = (PortableReaderImpl) reader.RawReader(); + var reader0 = (PortableReaderImpl) reader.GetRawReader(); _clo = PortableUtils.ReadPortableOrSerializable<IComputeFunc>(reader0); _arg = PortableUtils.ReadPortableOrSerializable<object>(reader0); http://git-wip-us.apache.org/repos/asf/ignite/blob/d90d1e2e/modules/platforms/dotnet/Apache.Ignite.Core/Impl/Compute/Closure/ComputeOutFuncJob.cs ---------------------------------------------------------------------- diff --git a/modules/platforms/dotnet/Apache.Ignite.Core/Impl/Compute/Closure/ComputeOutFuncJob.cs b/modules/platforms/dotnet/Apache.Ignite.Core/Impl/Compute/Closure/ComputeOutFuncJob.cs index b3adcc4..11ec157 100644 --- a/modules/platforms/dotnet/Apache.Ignite.Core/Impl/Compute/Closure/ComputeOutFuncJob.cs +++ b/modules/platforms/dotnet/Apache.Ignite.Core/Impl/Compute/Closure/ComputeOutFuncJob.cs @@ -60,14 +60,14 @@ namespace Apache.Ignite.Core.Impl.Compute.Closure /** <inheritDoc /> */ public void WritePortable(IPortableWriter writer) { - var writer0 = (PortableWriterImpl) writer.RawWriter(); + var writer0 = (PortableWriterImpl) writer.GetRawWriter(); writer0.WithDetach(w => PortableUtils.WritePortableOrSerializable(w, _clo)); } public ComputeOutFuncJob(IPortableReader reader) { - var reader0 = (PortableReaderImpl) reader.RawReader(); + var reader0 = (PortableReaderImpl) reader.GetRawReader(); _clo = PortableUtils.ReadPortableOrSerializable<IComputeOutFunc>(reader0); } http://git-wip-us.apache.org/repos/asf/ignite/blob/d90d1e2e/modules/platforms/dotnet/Apache.Ignite.Core/Impl/Compute/ComputeFunc.cs ---------------------------------------------------------------------- diff --git a/modules/platforms/dotnet/Apache.Ignite.Core/Impl/Compute/ComputeFunc.cs b/modules/platforms/dotnet/Apache.Ignite.Core/Impl/Compute/ComputeFunc.cs index e827136..4195120 100644 --- a/modules/platforms/dotnet/Apache.Ignite.Core/Impl/Compute/ComputeFunc.cs +++ b/modules/platforms/dotnet/Apache.Ignite.Core/Impl/Compute/ComputeFunc.cs @@ -73,7 +73,7 @@ namespace Apache.Ignite.Core.Impl.Compute /** <inheritDoc /> */ public void WritePortable(IPortableWriter writer) { - var writer0 = (PortableWriterImpl)writer.RawWriter(); + var writer0 = (PortableWriterImpl)writer.GetRawWriter(); writer0.WithDetach(w => PortableUtils.WritePortableOrSerializable(w, _func)); } @@ -84,7 +84,7 @@ namespace Apache.Ignite.Core.Impl.Compute /// <param name="reader">The reader.</param> public ComputeFuncWrapper(IPortableReader reader) { - var reader0 = (PortableReaderImpl)reader.RawReader(); + var reader0 = (PortableReaderImpl)reader.GetRawReader(); _func = PortableUtils.ReadPortableOrSerializable<object>(reader0); http://git-wip-us.apache.org/repos/asf/ignite/blob/d90d1e2e/modules/platforms/dotnet/Apache.Ignite.Core/Impl/Compute/ComputeJob.cs ---------------------------------------------------------------------- diff --git a/modules/platforms/dotnet/Apache.Ignite.Core/Impl/Compute/ComputeJob.cs b/modules/platforms/dotnet/Apache.Ignite.Core/Impl/Compute/ComputeJob.cs index c3c787f..61cc4d8 100644 --- a/modules/platforms/dotnet/Apache.Ignite.Core/Impl/Compute/ComputeJob.cs +++ b/modules/platforms/dotnet/Apache.Ignite.Core/Impl/Compute/ComputeJob.cs @@ -54,7 +54,7 @@ namespace Apache.Ignite.Core.Impl.Compute /// <param name="reader">The reader.</param> public ComputeJobWrapper(IPortableReader reader) { - var reader0 = (PortableReaderImpl)reader.RawReader(); + var reader0 = (PortableReaderImpl)reader.GetRawReader(); _job = PortableUtils.ReadPortableOrSerializable<object>(reader0); @@ -102,7 +102,7 @@ namespace Apache.Ignite.Core.Impl.Compute /** <inheritDoc /> */ public void WritePortable(IPortableWriter writer) { - var writer0 = (PortableWriterImpl)writer.RawWriter(); + var writer0 = (PortableWriterImpl)writer.GetRawWriter(); writer0.WithDetach(w => PortableUtils.WritePortableOrSerializable(w, Job)); } http://git-wip-us.apache.org/repos/asf/ignite/blob/d90d1e2e/modules/platforms/dotnet/Apache.Ignite.Core/Impl/Compute/ComputeJobHolder.cs ---------------------------------------------------------------------- diff --git a/modules/platforms/dotnet/Apache.Ignite.Core/Impl/Compute/ComputeJobHolder.cs b/modules/platforms/dotnet/Apache.Ignite.Core/Impl/Compute/ComputeJobHolder.cs index 91bf8ed..ab41100 100644 --- a/modules/platforms/dotnet/Apache.Ignite.Core/Impl/Compute/ComputeJobHolder.cs +++ b/modules/platforms/dotnet/Apache.Ignite.Core/Impl/Compute/ComputeJobHolder.cs @@ -51,7 +51,7 @@ namespace Apache.Ignite.Core.Impl.Compute { Debug.Assert(reader != null); - var reader0 = (PortableReaderImpl) reader.RawReader(); + var reader0 = (PortableReaderImpl) reader.GetRawReader(); _ignite = reader0.Marshaller.Ignite; @@ -218,7 +218,7 @@ namespace Apache.Ignite.Core.Impl.Compute /** <inheritDoc /> */ public void WritePortable(IPortableWriter writer) { - PortableWriterImpl writer0 = (PortableWriterImpl) writer.RawWriter(); + PortableWriterImpl writer0 = (PortableWriterImpl) writer.GetRawWriter(); writer0.WithDetach(w => PortableUtils.WritePortableOrSerializable(w, _job)); } http://git-wip-us.apache.org/repos/asf/ignite/blob/d90d1e2e/modules/platforms/dotnet/Apache.Ignite.Core/Impl/Compute/ComputeOutFunc.cs ---------------------------------------------------------------------- diff --git a/modules/platforms/dotnet/Apache.Ignite.Core/Impl/Compute/ComputeOutFunc.cs b/modules/platforms/dotnet/Apache.Ignite.Core/Impl/Compute/ComputeOutFunc.cs index b450b37..3b7e2b5 100644 --- a/modules/platforms/dotnet/Apache.Ignite.Core/Impl/Compute/ComputeOutFunc.cs +++ b/modules/platforms/dotnet/Apache.Ignite.Core/Impl/Compute/ComputeOutFunc.cs @@ -77,7 +77,7 @@ namespace Apache.Ignite.Core.Impl.Compute /** <inheritDoc /> */ public void WritePortable(IPortableWriter writer) { - var writer0 = (PortableWriterImpl)writer.RawWriter(); + var writer0 = (PortableWriterImpl)writer.GetRawWriter(); writer0.WithDetach(w => PortableUtils.WritePortableOrSerializable(w, _func)); } @@ -88,7 +88,7 @@ namespace Apache.Ignite.Core.Impl.Compute /// <param name="reader">The reader.</param> public ComputeOutFuncWrapper(IPortableReader reader) { - var reader0 = (PortableReaderImpl)reader.RawReader(); + var reader0 = (PortableReaderImpl)reader.GetRawReader(); _func = PortableUtils.ReadPortableOrSerializable<object>(reader0); http://git-wip-us.apache.org/repos/asf/ignite/blob/d90d1e2e/modules/platforms/dotnet/Apache.Ignite.Core/Impl/Datastream/StreamReceiverHolder.cs ---------------------------------------------------------------------- diff --git a/modules/platforms/dotnet/Apache.Ignite.Core/Impl/Datastream/StreamReceiverHolder.cs b/modules/platforms/dotnet/Apache.Ignite.Core/Impl/Datastream/StreamReceiverHolder.cs index 5a7c104..32cbc0b 100644 --- a/modules/platforms/dotnet/Apache.Ignite.Core/Impl/Datastream/StreamReceiverHolder.cs +++ b/modules/platforms/dotnet/Apache.Ignite.Core/Impl/Datastream/StreamReceiverHolder.cs @@ -89,7 +89,7 @@ namespace Apache.Ignite.Core.Impl.Datastream /** <inheritdoc /> */ public void WritePortable(IPortableWriter writer) { - var w = writer.RawWriter(); + var w = writer.GetRawWriter(); var writeAware = _rcv as IPortableWriteAware; http://git-wip-us.apache.org/repos/asf/ignite/blob/d90d1e2e/modules/platforms/dotnet/Apache.Ignite.Core/Impl/Events/Events.cs ---------------------------------------------------------------------- diff --git a/modules/platforms/dotnet/Apache.Ignite.Core/Impl/Events/Events.cs b/modules/platforms/dotnet/Apache.Ignite.Core/Impl/Events/Events.cs index ad1157e..726dd87 100644 --- a/modules/platforms/dotnet/Apache.Ignite.Core/Impl/Events/Events.cs +++ b/modules/platforms/dotnet/Apache.Ignite.Core/Impl/Events/Events.cs @@ -370,7 +370,7 @@ namespace Apache.Ignite.Core.Impl.Events /// <returns>Resulting list or null.</returns> protected static List<T> ReadEvents<T>(PortableReaderImpl portableReader) where T : IEvent { - var count = portableReader.RawReader().ReadInt(); + var count = portableReader.GetRawReader().ReadInt(); if (count == -1) return null; http://git-wip-us.apache.org/repos/asf/ignite/blob/d90d1e2e/modules/platforms/dotnet/Apache.Ignite.Core/Impl/InteropExceptionHolder.cs ---------------------------------------------------------------------- diff --git a/modules/platforms/dotnet/Apache.Ignite.Core/Impl/InteropExceptionHolder.cs b/modules/platforms/dotnet/Apache.Ignite.Core/Impl/InteropExceptionHolder.cs index 98d57da..918c3d6 100644 --- a/modules/platforms/dotnet/Apache.Ignite.Core/Impl/InteropExceptionHolder.cs +++ b/modules/platforms/dotnet/Apache.Ignite.Core/Impl/InteropExceptionHolder.cs @@ -59,7 +59,7 @@ namespace Apache.Ignite.Core.Impl /** <inheritDoc /> */ public void WritePortable(IPortableWriter writer) { - var writer0 = (PortableWriterImpl) writer.RawWriter(); + var writer0 = (PortableWriterImpl) writer.GetRawWriter(); if (writer0.IsPortable(_err)) { http://git-wip-us.apache.org/repos/asf/ignite/blob/d90d1e2e/modules/platforms/dotnet/Apache.Ignite.Core/Impl/Messaging/MessageFilterHolder.cs ---------------------------------------------------------------------- diff --git a/modules/platforms/dotnet/Apache.Ignite.Core/Impl/Messaging/MessageFilterHolder.cs b/modules/platforms/dotnet/Apache.Ignite.Core/Impl/Messaging/MessageFilterHolder.cs index fab60af..8666e9b 100644 --- a/modules/platforms/dotnet/Apache.Ignite.Core/Impl/Messaging/MessageFilterHolder.cs +++ b/modules/platforms/dotnet/Apache.Ignite.Core/Impl/Messaging/MessageFilterHolder.cs @@ -73,7 +73,7 @@ namespace Apache.Ignite.Core.Impl.Messaging /// <returns></returns> public int Invoke(IPortableStream input) { - var rawReader = _ignite.Marshaller.StartUnmarshal(input).RawReader(); + var rawReader = _ignite.Marshaller.StartUnmarshal(input).GetRawReader(); var nodeId = rawReader.ReadGuid(); @@ -152,7 +152,7 @@ namespace Apache.Ignite.Core.Impl.Messaging /** <inheritdoc /> */ public void WritePortable(IPortableWriter writer) { - var writer0 = (PortableWriterImpl)writer.RawWriter(); + var writer0 = (PortableWriterImpl)writer.GetRawWriter(); writer0.WithDetach(w => PortableUtils.WritePortableOrSerializable(w, Filter)); } @@ -163,7 +163,7 @@ namespace Apache.Ignite.Core.Impl.Messaging /// <param name="reader">The reader.</param> public MessageFilterHolder(IPortableReader reader) { - var reader0 = (PortableReaderImpl)reader.RawReader(); + var reader0 = (PortableReaderImpl)reader.GetRawReader(); _filter = PortableUtils.ReadPortableOrSerializable<object>(reader0); http://git-wip-us.apache.org/repos/asf/ignite/blob/d90d1e2e/modules/platforms/dotnet/Apache.Ignite.Core/Impl/Messaging/Messaging.cs ---------------------------------------------------------------------- diff --git a/modules/platforms/dotnet/Apache.Ignite.Core/Impl/Messaging/Messaging.cs b/modules/platforms/dotnet/Apache.Ignite.Core/Impl/Messaging/Messaging.cs index e8c4b4b..8170a91 100644 --- a/modules/platforms/dotnet/Apache.Ignite.Core/Impl/Messaging/Messaging.cs +++ b/modules/platforms/dotnet/Apache.Ignite.Core/Impl/Messaging/Messaging.cs @@ -197,7 +197,7 @@ namespace Apache.Ignite.Core.Impl.Messaging }, input => { - var id0 = Marshaller.StartUnmarshal(input).RawReader().ReadGuid(); + var id0 = Marshaller.StartUnmarshal(input).GetRawReader().ReadGuid(); Debug.Assert(IsAsync || id0.HasValue); http://git-wip-us.apache.org/repos/asf/ignite/blob/d90d1e2e/modules/platforms/dotnet/Apache.Ignite.Core/Impl/Portable/PortableOrSerializableObjectHolder.cs ---------------------------------------------------------------------- diff --git a/modules/platforms/dotnet/Apache.Ignite.Core/Impl/Portable/PortableOrSerializableObjectHolder.cs b/modules/platforms/dotnet/Apache.Ignite.Core/Impl/Portable/PortableOrSerializableObjectHolder.cs index 2d6afff..d2a2928 100644 --- a/modules/platforms/dotnet/Apache.Ignite.Core/Impl/Portable/PortableOrSerializableObjectHolder.cs +++ b/modules/platforms/dotnet/Apache.Ignite.Core/Impl/Portable/PortableOrSerializableObjectHolder.cs @@ -47,7 +47,7 @@ namespace Apache.Ignite.Core.Impl.Portable /** <inheritDoc /> */ public void WritePortable(IPortableWriter writer) { - var writer0 = (PortableWriterImpl)writer.RawWriter(); + var writer0 = (PortableWriterImpl)writer.GetRawWriter(); writer0.WithDetach(w => PortableUtils.WritePortableOrSerializable(w, Item)); } @@ -58,7 +58,7 @@ namespace Apache.Ignite.Core.Impl.Portable /// <param name="reader">The reader.</param> public PortableOrSerializableObjectHolder(IPortableReader reader) { - _item = PortableUtils.ReadPortableOrSerializable<object>((PortableReaderImpl)reader.RawReader()); + _item = PortableUtils.ReadPortableOrSerializable<object>((PortableReaderImpl)reader.GetRawReader()); } } } \ No newline at end of file http://git-wip-us.apache.org/repos/asf/ignite/blob/d90d1e2e/modules/platforms/dotnet/Apache.Ignite.Core/Impl/Portable/PortableReaderImpl.cs ---------------------------------------------------------------------- diff --git a/modules/platforms/dotnet/Apache.Ignite.Core/Impl/Portable/PortableReaderImpl.cs b/modules/platforms/dotnet/Apache.Ignite.Core/Impl/Portable/PortableReaderImpl.cs index 176ca27..cfc84fd 100644 --- a/modules/platforms/dotnet/Apache.Ignite.Core/Impl/Portable/PortableReaderImpl.cs +++ b/modules/platforms/dotnet/Apache.Ignite.Core/Impl/Portable/PortableReaderImpl.cs @@ -100,7 +100,7 @@ namespace Apache.Ignite.Core.Impl.Portable } /** <inheritdoc /> */ - public IPortableRawReader RawReader() + public IPortableRawReader GetRawReader() { MarkRaw(); http://git-wip-us.apache.org/repos/asf/ignite/blob/d90d1e2e/modules/platforms/dotnet/Apache.Ignite.Core/Impl/Portable/PortableWriterImpl.cs ---------------------------------------------------------------------- diff --git a/modules/platforms/dotnet/Apache.Ignite.Core/Impl/Portable/PortableWriterImpl.cs b/modules/platforms/dotnet/Apache.Ignite.Core/Impl/Portable/PortableWriterImpl.cs index 0495b68..2090496 100644 --- a/modules/platforms/dotnet/Apache.Ignite.Core/Impl/Portable/PortableWriterImpl.cs +++ b/modules/platforms/dotnet/Apache.Ignite.Core/Impl/Portable/PortableWriterImpl.cs @@ -1223,7 +1223,7 @@ namespace Apache.Ignite.Core.Impl.Portable /// <returns> /// Raw writer. /// </returns> - public IPortableRawWriter RawWriter() + public IPortableRawWriter GetRawWriter() { if (_curRawPos == 0) _curRawPos = _stream.Position; http://git-wip-us.apache.org/repos/asf/ignite/blob/d90d1e2e/modules/platforms/dotnet/Apache.Ignite.Core/Impl/Portable/SerializableObjectHolder.cs ---------------------------------------------------------------------- diff --git a/modules/platforms/dotnet/Apache.Ignite.Core/Impl/Portable/SerializableObjectHolder.cs b/modules/platforms/dotnet/Apache.Ignite.Core/Impl/Portable/SerializableObjectHolder.cs index 404376a..0c9ecc5 100644 --- a/modules/platforms/dotnet/Apache.Ignite.Core/Impl/Portable/SerializableObjectHolder.cs +++ b/modules/platforms/dotnet/Apache.Ignite.Core/Impl/Portable/SerializableObjectHolder.cs @@ -47,7 +47,7 @@ namespace Apache.Ignite.Core.Impl.Portable /** <inheritDoc /> */ public void WritePortable(IPortableWriter writer) { - var writer0 = (PortableWriterImpl)writer.RawWriter(); + var writer0 = (PortableWriterImpl)writer.GetRawWriter(); writer0.WithDetach(w => PortableUtils.WriteSerializable(w, Item)); } @@ -58,7 +58,7 @@ namespace Apache.Ignite.Core.Impl.Portable /// <param name="reader">The reader.</param> public SerializableObjectHolder(IPortableReader reader) { - _item = PortableUtils.ReadSerializable<object>((PortableReaderImpl)reader.RawReader()); + _item = PortableUtils.ReadSerializable<object>((PortableReaderImpl)reader.GetRawReader()); } } } \ No newline at end of file http://git-wip-us.apache.org/repos/asf/ignite/blob/d90d1e2e/modules/platforms/dotnet/Apache.Ignite.Core/Impl/Transactions/TransactionsImpl.cs ---------------------------------------------------------------------- diff --git a/modules/platforms/dotnet/Apache.Ignite.Core/Impl/Transactions/TransactionsImpl.cs b/modules/platforms/dotnet/Apache.Ignite.Core/Impl/Transactions/TransactionsImpl.cs index 4eaa53f..f2bc0f6 100644 --- a/modules/platforms/dotnet/Apache.Ignite.Core/Impl/Transactions/TransactionsImpl.cs +++ b/modules/platforms/dotnet/Apache.Ignite.Core/Impl/Transactions/TransactionsImpl.cs @@ -65,7 +65,7 @@ namespace Apache.Ignite.Core.Impl.Transactions DoInOp(OpCacheConfigParameters, stream => { - var reader = marsh.StartUnmarshal(stream).RawReader(); + var reader = marsh.StartUnmarshal(stream).GetRawReader(); concurrency = reader.ReadEnum<TransactionConcurrency>(); isolation = reader.ReadEnum<TransactionIsolation>(); http://git-wip-us.apache.org/repos/asf/ignite/blob/d90d1e2e/modules/platforms/dotnet/Apache.Ignite.Core/Portable/IPortableReader.cs ---------------------------------------------------------------------- diff --git a/modules/platforms/dotnet/Apache.Ignite.Core/Portable/IPortableReader.cs b/modules/platforms/dotnet/Apache.Ignite.Core/Portable/IPortableReader.cs index 71bd4f2..96f5757 100644 --- a/modules/platforms/dotnet/Apache.Ignite.Core/Portable/IPortableReader.cs +++ b/modules/platforms/dotnet/Apache.Ignite.Core/Portable/IPortableReader.cs @@ -335,6 +335,6 @@ namespace Apache.Ignite.Core.Portable /// Get raw reader. /// </summary> /// <returns>Raw reader.</returns> - IPortableRawReader RawReader(); + IPortableRawReader GetRawReader(); } } \ No newline at end of file http://git-wip-us.apache.org/repos/asf/ignite/blob/d90d1e2e/modules/platforms/dotnet/Apache.Ignite.Core/Portable/IPortableWriter.cs ---------------------------------------------------------------------- diff --git a/modules/platforms/dotnet/Apache.Ignite.Core/Portable/IPortableWriter.cs b/modules/platforms/dotnet/Apache.Ignite.Core/Portable/IPortableWriter.cs index 5bb2625..edca218 100644 --- a/modules/platforms/dotnet/Apache.Ignite.Core/Portable/IPortableWriter.cs +++ b/modules/platforms/dotnet/Apache.Ignite.Core/Portable/IPortableWriter.cs @@ -282,6 +282,6 @@ namespace Apache.Ignite.Core.Portable /// Get raw writer. /// </summary> /// <returns>Raw writer.</returns> - IPortableRawWriter RawWriter(); + IPortableRawWriter GetRawWriter(); } }
