From e38294a62d7f37c0661273a9a26fda16d557423f Mon Sep 17 00:00:00 2001 From: Jon Skeet Date: Tue, 9 Jun 2015 19:30:44 +0100 Subject: First pass at the mutable API. Quite a bit more to do - in particular, it's pretty slow right now. --- .../src/ProtocolBuffers/MessageStreamIterator.cs | 170 --------------------- 1 file changed, 170 deletions(-) delete mode 100644 csharp/src/ProtocolBuffers/MessageStreamIterator.cs (limited to 'csharp/src/ProtocolBuffers/MessageStreamIterator.cs') diff --git a/csharp/src/ProtocolBuffers/MessageStreamIterator.cs b/csharp/src/ProtocolBuffers/MessageStreamIterator.cs deleted file mode 100644 index 32d697ca..00000000 --- a/csharp/src/ProtocolBuffers/MessageStreamIterator.cs +++ /dev/null @@ -1,170 +0,0 @@ -#region Copyright notice and license - -// Protocol Buffers - Google's data interchange format -// Copyright 2008 Google Inc. All rights reserved. -// http://github.com/jskeet/dotnet-protobufs/ -// Original C++/Java/Python code: -// http://code.google.com/p/protobuf/ -// -// Redistribution and use in source and binary forms, with or without -// modification, are permitted provided that the following conditions are -// met: -// -// * Redistributions of source code must retain the above copyright -// notice, this list of conditions and the following disclaimer. -// * Redistributions in binary form must reproduce the above -// copyright notice, this list of conditions and the following disclaimer -// in the documentation and/or other materials provided with the -// distribution. -// * Neither the name of Google Inc. nor the names of its -// contributors may be used to endorse or promote products derived from -// this software without specific prior written permission. -// -// THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS -// "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT -// LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR -// A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT -// OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, -// SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT -// LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, -// DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY -// THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT -// (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE -// OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. - -#endregion - -using System; -using System.Collections; -using System.Collections.Generic; -using System.IO; - -namespace Google.ProtocolBuffers -{ - /// - /// Iterates over data created using a . - /// Unlike MessageStreamWriter, this class is not usually constructed directly with - /// a stream; instead it is provided with a way of opening a stream when iteration - /// is started. The stream is closed when the iteration is completed or the enumerator - /// is disposed. (This occurs naturally when using foreach.) - /// - public class MessageStreamIterator : IEnumerable - where TMessage : IMessage - { - private readonly StreamProvider streamProvider; - private readonly ExtensionRegistry extensionRegistry; - private readonly int sizeLimit; - - /// - /// The default instance of TMessage type used to construct builders while reading - /// - private static readonly TMessage defaultMessageInstance = CreateDefaultInstance(); - /// - /// Any exception (within reason) thrown in type ctor is caught and rethrown in the constructor. - /// This makes life a lot simpler for the caller. - /// - private static Exception typeInitializationException; - - - /// - /// Vastly simplified the reflection to simply obtain the default instance and use it to construct - /// the weak builder while simply casting the result. Ideally this class should have required a - /// TBuilder type argument with a new() constraint to construct the initial instance thereby the - /// reflection could be eliminated. - /// - private static TMessage CreateDefaultInstance() - { - try - { - return (TMessage)typeof(TMessage) - .GetProperty("DefaultInstance", typeof(TMessage), new Type[0]) - .GetValue(null, null); - } - catch (Exception e) - { - typeInitializationException = e; - return default(TMessage); - } - } - - private static readonly uint ExpectedTag = WireFormat.MakeTag(1, WireFormat.WireType.LengthDelimited); - - private MessageStreamIterator(StreamProvider streamProvider, ExtensionRegistry extensionRegistry, int sizeLimit) - { - if (ReferenceEquals(defaultMessageInstance, null)) - { - throw new System.Reflection.TargetInvocationException(typeInitializationException); - } - this.streamProvider = streamProvider; - this.extensionRegistry = extensionRegistry; - this.sizeLimit = sizeLimit; - } - - private MessageStreamIterator(StreamProvider streamProvider, ExtensionRegistry extensionRegistry) - : this(streamProvider, extensionRegistry, CodedInputStream.DefaultSizeLimit) - { - } - - /// - /// Creates a new instance which uses the same stream provider as this one, - /// but the specified extension registry. - /// - public MessageStreamIterator WithExtensionRegistry(ExtensionRegistry newRegistry) - { - return new MessageStreamIterator(streamProvider, newRegistry, sizeLimit); - } - - /// - /// Creates a new instance which uses the same stream provider and extension registry as this one, - /// but with the specified size limit. Note that this must be big enough for the largest message - /// and the tag and size preceding it. - /// - public MessageStreamIterator WithSizeLimit(int newSizeLimit) - { - return new MessageStreamIterator(streamProvider, extensionRegistry, newSizeLimit); - } - -#if CLIENTPROFILE - public static MessageStreamIterator FromFile(string file) - { - return new MessageStreamIterator(() => File.OpenRead(file), ExtensionRegistry.Empty); - } -#endif - - public static MessageStreamIterator FromStreamProvider(StreamProvider streamProvider) - { - return new MessageStreamIterator(streamProvider, ExtensionRegistry.Empty); - } - - public IEnumerator GetEnumerator() - { - using (Stream stream = streamProvider()) - { - CodedInputStream input = CodedInputStream.CreateInstance(stream); - input.SetSizeLimit(sizeLimit); - uint tag; - string name; - while (input.ReadTag(out tag, out name)) - { - if ((tag == 0 && name == "item") || (tag == ExpectedTag)) - { - IBuilder builder = defaultMessageInstance.WeakCreateBuilderForType(); - input.ReadMessage(builder, extensionRegistry); - yield return (TMessage)builder.WeakBuild(); - } - else - { - throw InvalidProtocolBufferException.InvalidMessageStreamTag(); - } - - input.ResetSizeCounter(); - } - } - } - - IEnumerator IEnumerable.GetEnumerator() - { - return GetEnumerator(); - } - } -} \ No newline at end of file -- cgit v1.2.3