Merge pull request #14 from kwan3854/v2.0.0

Adds robust chunking support for large RPC messages

Author: kwan3854

Assets/SampleRpc/HelloWorld.cs

@@ -24,24 +24,26 @@ public static partial class HelloWorldReflection {
     static HelloWorldReflection() {
       byte[] descriptorData = global::System.Convert.FromBase64String(
           string.Concat(
-            "ChBIZWxsb1dvcmxkLnByb3RvEgpoZWxsb3dvcmxkIhwKDEhlbGxvUmVxdWVz",
-            "dBIMCgRuYW1lGAEgASgJIiEKDUhlbGxvUmVzcG9uc2USEAoIZ3JlZXRpbmcY",
-            "ASABKAkyTwoMSGVsbG9TZXJ2aWNlEj8KCFNheUhlbGxvEhguaGVsbG93b3Js",
-            "ZC5IZWxsb1JlcXVlc3QaGS5oZWxsb3dvcmxkLkhlbGxvUmVzcG9uc2VCDaoC",
-            "CkhlbGxvV29ybGRiBnByb3RvMw=="));
+            "ChBIZWxsb1dvcmxkLnByb3RvEgpoZWxsb3dvcmxkIkYKDEhlbGxvUmVxdWVz",
+            "dBIMCgRuYW1lGAEgASgJEhMKC2xvbmdNZXNzYWdlGAIgASgJEhMKC3JlcGVh",
+            "dENvdW50GAMgASgFImoKDUhlbGxvUmVzcG9uc2USEAoIZ3JlZXRpbmcYASAB",
+            "KAkSFQoNZWNob2VkTWVzc2FnZRgCIAEoCRITCgtwcm9jZXNzZWRBdBgDIAEo",
+            "CRIbChNvcmlnaW5hbE1lc3NhZ2VTaXplGAQgASgFMk8KDEhlbGxvU2Vydmlj",
+            "ZRI/CghTYXlIZWxsbxIYLmhlbGxvd29ybGQuSGVsbG9SZXF1ZXN0GhkuaGVs",
+            "bG93b3JsZC5IZWxsb1Jlc3BvbnNlQg2qAgpIZWxsb1dvcmxkYgZwcm90bzM="));
       descriptor = pbr::FileDescriptor.FromGeneratedCode(descriptorData,
           new pbr::FileDescriptor[] { },
           new pbr::GeneratedClrTypeInfo(null, null, new pbr::GeneratedClrTypeInfo[] {
-            new pbr::GeneratedClrTypeInfo(typeof(global::HelloWorld.HelloRequest), global::HelloWorld.HelloRequest.Parser, new[]{ "Name" }, null, null, null, null),
-            new pbr::GeneratedClrTypeInfo(typeof(global::HelloWorld.HelloResponse), global::HelloWorld.HelloResponse.Parser, new[]{ "Greeting" }, null, null, null, null)
+            new pbr::GeneratedClrTypeInfo(typeof(global::HelloWorld.HelloRequest), global::HelloWorld.HelloRequest.Parser, new[]{ "Name", "LongMessage", "RepeatCount" }, null, null, null, null),
+            new pbr::GeneratedClrTypeInfo(typeof(global::HelloWorld.HelloResponse), global::HelloWorld.HelloResponse.Parser, new[]{ "Greeting", "EchoedMessage", "ProcessedAt", "OriginalMessageSize" }, null, null, null, null)
           }));
     }
     #endregion
 
   }
   #region Messages
   /// <summary>
-  /// 요청 메시지
+  /// Request message for chunking test
   /// </summary>
   [global::System.Diagnostics.DebuggerDisplayAttribute("{ToString(),nq}")]
   public sealed partial class HelloRequest : pb::IMessage<HelloRequest>
@@ -79,6 +81,8 @@ public HelloRequest() {
     [global::System.CodeDom.Compiler.GeneratedCode("protoc", null)]
     public HelloRequest(HelloRequest other) : this() {
       name_ = other.name_;
+      longMessage_ = other.longMessage_;
+      repeatCount_ = other.repeatCount_;
       _unknownFields = pb::UnknownFieldSet.Clone(other._unknownFields);
     }
 
@@ -100,6 +104,36 @@ public string Name {
       }
     }
 
+    /// <summary>Field number for the "longMessage" field.</summary>
+    public const int LongMessageFieldNumber = 2;
+    private string longMessage_ = "";
+    /// <summary>
+    /// Very long string for testing chunking functionality
+    /// </summary>
+    [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
+    [global::System.CodeDom.Compiler.GeneratedCode("protoc", null)]
+    public string LongMessage {
+      get { return longMessage_; }
+      set {
+        longMessage_ = pb::ProtoPreconditions.CheckNotNull(value, "value");
+      }
+    }
+
+    /// <summary>Field number for the "repeatCount" field.</summary>
+    public const int RepeatCountFieldNumber = 3;
+    private int repeatCount_;
+    /// <summary>
+    /// Optional: number of times to repeat the response
+    /// </summary>
+    [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
+    [global::System.CodeDom.Compiler.GeneratedCode("protoc", null)]
+    public int RepeatCount {
+      get { return repeatCount_; }
+      set {
+        repeatCount_ = value;
+      }
+    }
+
     [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
     [global::System.CodeDom.Compiler.GeneratedCode("protoc", null)]
     public override bool Equals(object other) {
@@ -116,6 +150,8 @@ public bool Equals(HelloRequest other) {
         return true;
       }
       if (Name != other.Name) return false;
+      if (LongMessage != other.LongMessage) return false;
+      if (RepeatCount != other.RepeatCount) return false;
       return Equals(_unknownFields, other._unknownFields);
     }
 
@@ -124,6 +160,8 @@ public bool Equals(HelloRequest other) {
     public override int GetHashCode() {
       int hash = 1;
       if (Name.Length != 0) hash ^= Name.GetHashCode();
+      if (LongMessage.Length != 0) hash ^= LongMessage.GetHashCode();
+      if (RepeatCount != 0) hash ^= RepeatCount.GetHashCode();
       if (_unknownFields != null) {
         hash ^= _unknownFields.GetHashCode();
       }
@@ -146,6 +184,14 @@ public void WriteTo(pb::CodedOutputStream output) {
         output.WriteRawTag(10);
         output.WriteString(Name);
       }
+      if (LongMessage.Length != 0) {
+        output.WriteRawTag(18);
+        output.WriteString(LongMessage);
+      }
+      if (RepeatCount != 0) {
+        output.WriteRawTag(24);
+        output.WriteInt32(RepeatCount);
+      }
       if (_unknownFields != null) {
         _unknownFields.WriteTo(output);
       }
@@ -160,6 +206,14 @@ public void WriteTo(pb::CodedOutputStream output) {
         output.WriteRawTag(10);
         output.WriteString(Name);
       }
+      if (LongMessage.Length != 0) {
+        output.WriteRawTag(18);
+        output.WriteString(LongMessage);
+      }
+      if (RepeatCount != 0) {
+        output.WriteRawTag(24);
+        output.WriteInt32(RepeatCount);
+      }
       if (_unknownFields != null) {
         _unknownFields.WriteTo(ref output);
       }
@@ -173,6 +227,12 @@ public int CalculateSize() {
       if (Name.Length != 0) {
         size += 1 + pb::CodedOutputStream.ComputeStringSize(Name);
       }
+      if (LongMessage.Length != 0) {
+        size += 1 + pb::CodedOutputStream.ComputeStringSize(LongMessage);
+      }
+      if (RepeatCount != 0) {
+        size += 1 + pb::CodedOutputStream.ComputeInt32Size(RepeatCount);
+      }
       if (_unknownFields != null) {
         size += _unknownFields.CalculateSize();
       }
@@ -188,6 +248,12 @@ public void MergeFrom(HelloRequest other) {
       if (other.Name.Length != 0) {
         Name = other.Name;
       }
+      if (other.LongMessage.Length != 0) {
+        LongMessage = other.LongMessage;
+      }
+      if (other.RepeatCount != 0) {
+        RepeatCount = other.RepeatCount;
+      }
       _unknownFields = pb::UnknownFieldSet.MergeFrom(_unknownFields, other._unknownFields);
     }
 
@@ -211,6 +277,14 @@ public void MergeFrom(pb::CodedInputStream input) {
             Name = input.ReadString();
             break;
           }
+          case 18: {
+            LongMessage = input.ReadString();
+            break;
+          }
+          case 24: {
+            RepeatCount = input.ReadInt32();
+            break;
+          }
         }
       }
     #endif
@@ -234,6 +308,14 @@ public void MergeFrom(pb::CodedInputStream input) {
             Name = input.ReadString();
             break;
           }
+          case 18: {
+            LongMessage = input.ReadString();
+            break;
+          }
+          case 24: {
+            RepeatCount = input.ReadInt32();
+            break;
+          }
         }
       }
     }
@@ -242,7 +324,7 @@ public void MergeFrom(pb::CodedInputStream input) {
   }
 
   /// <summary>
-  /// 응답 메시지
+  /// Response message
   /// </summary>
   [global::System.Diagnostics.DebuggerDisplayAttribute("{ToString(),nq}")]
   public sealed partial class HelloResponse : pb::IMessage<HelloResponse>
@@ -280,6 +362,9 @@ public HelloResponse() {
     [global::System.CodeDom.Compiler.GeneratedCode("protoc", null)]
     public HelloResponse(HelloResponse other) : this() {
       greeting_ = other.greeting_;
+      echoedMessage_ = other.echoedMessage_;
+      processedAt_ = other.processedAt_;
+      originalMessageSize_ = other.originalMessageSize_;
       _unknownFields = pb::UnknownFieldSet.Clone(other._unknownFields);
     }
 
@@ -301,6 +386,51 @@ public string Greeting {
       }
     }
 
+    /// <summary>Field number for the "echoedMessage" field.</summary>
+    public const int EchoedMessageFieldNumber = 2;
+    private string echoedMessage_ = "";
+    /// <summary>
+    /// Echo back the long message to test bidirectional chunking
+    /// </summary>
+    [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
+    [global::System.CodeDom.Compiler.GeneratedCode("protoc", null)]
+    public string EchoedMessage {
+      get { return echoedMessage_; }
+      set {
+        echoedMessage_ = pb::ProtoPreconditions.CheckNotNull(value, "value");
+      }
+    }
+
+    /// <summary>Field number for the "processedAt" field.</summary>
+    public const int ProcessedAtFieldNumber = 3;
+    private string processedAt_ = "";
+    /// <summary>
+    /// Timestamp when the message was processed
+    /// </summary>
+    [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
+    [global::System.CodeDom.Compiler.GeneratedCode("protoc", null)]
+    public string ProcessedAt {
+      get { return processedAt_; }
+      set {
+        processedAt_ = pb::ProtoPreconditions.CheckNotNull(value, "value");
+      }
+    }
+
+    /// <summary>Field number for the "originalMessageSize" field.</summary>
+    public const int OriginalMessageSizeFieldNumber = 4;
+    private int originalMessageSize_;
+    /// <summary>
+    /// Size information for debugging
+    /// </summary>
+    [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
+    [global::System.CodeDom.Compiler.GeneratedCode("protoc", null)]
+    public int OriginalMessageSize {
+      get { return originalMessageSize_; }
+      set {
+        originalMessageSize_ = value;
+      }
+    }
+
     [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
     [global::System.CodeDom.Compiler.GeneratedCode("protoc", null)]
     public override bool Equals(object other) {
@@ -317,6 +447,9 @@ public bool Equals(HelloResponse other) {
         return true;
       }
       if (Greeting != other.Greeting) return false;
+      if (EchoedMessage != other.EchoedMessage) return false;
+      if (ProcessedAt != other.ProcessedAt) return false;
+      if (OriginalMessageSize != other.OriginalMessageSize) return false;
       return Equals(_unknownFields, other._unknownFields);
     }
 
@@ -325,6 +458,9 @@ public bool Equals(HelloResponse other) {
     public override int GetHashCode() {
       int hash = 1;
       if (Greeting.Length != 0) hash ^= Greeting.GetHashCode();
+      if (EchoedMessage.Length != 0) hash ^= EchoedMessage.GetHashCode();
+      if (ProcessedAt.Length != 0) hash ^= ProcessedAt.GetHashCode();
+      if (OriginalMessageSize != 0) hash ^= OriginalMessageSize.GetHashCode();
       if (_unknownFields != null) {
         hash ^= _unknownFields.GetHashCode();
       }
@@ -347,6 +483,18 @@ public void WriteTo(pb::CodedOutputStream output) {
         output.WriteRawTag(10);
         output.WriteString(Greeting);
       }
+      if (EchoedMessage.Length != 0) {
+        output.WriteRawTag(18);
+        output.WriteString(EchoedMessage);
+      }
+      if (ProcessedAt.Length != 0) {
+        output.WriteRawTag(26);
+        output.WriteString(ProcessedAt);
+      }
+      if (OriginalMessageSize != 0) {
+        output.WriteRawTag(32);
+        output.WriteInt32(OriginalMessageSize);
+      }
       if (_unknownFields != null) {
         _unknownFields.WriteTo(output);
       }
@@ -361,6 +509,18 @@ public void WriteTo(pb::CodedOutputStream output) {
         output.WriteRawTag(10);
         output.WriteString(Greeting);
       }
+      if (EchoedMessage.Length != 0) {
+        output.WriteRawTag(18);
+        output.WriteString(EchoedMessage);
+      }
+      if (ProcessedAt.Length != 0) {
+        output.WriteRawTag(26);
+        output.WriteString(ProcessedAt);
+      }
+      if (OriginalMessageSize != 0) {
+        output.WriteRawTag(32);
+        output.WriteInt32(OriginalMessageSize);
+      }
       if (_unknownFields != null) {
         _unknownFields.WriteTo(ref output);
       }
@@ -374,6 +534,15 @@ public int CalculateSize() {
       if (Greeting.Length != 0) {
         size += 1 + pb::CodedOutputStream.ComputeStringSize(Greeting);
       }
+      if (EchoedMessage.Length != 0) {
+        size += 1 + pb::CodedOutputStream.ComputeStringSize(EchoedMessage);
+      }
+      if (ProcessedAt.Length != 0) {
+        size += 1 + pb::CodedOutputStream.ComputeStringSize(ProcessedAt);
+      }
+      if (OriginalMessageSize != 0) {
+        size += 1 + pb::CodedOutputStream.ComputeInt32Size(OriginalMessageSize);
+      }
       if (_unknownFields != null) {
         size += _unknownFields.CalculateSize();
       }
@@ -389,6 +558,15 @@ public void MergeFrom(HelloResponse other) {
       if (other.Greeting.Length != 0) {
         Greeting = other.Greeting;
       }
+      if (other.EchoedMessage.Length != 0) {
+        EchoedMessage = other.EchoedMessage;
+      }
+      if (other.ProcessedAt.Length != 0) {
+        ProcessedAt = other.ProcessedAt;
+      }
+      if (other.OriginalMessageSize != 0) {
+        OriginalMessageSize = other.OriginalMessageSize;
+      }
       _unknownFields = pb::UnknownFieldSet.MergeFrom(_unknownFields, other._unknownFields);
     }
 
@@ -412,6 +590,18 @@ public void MergeFrom(pb::CodedInputStream input) {
             Greeting = input.ReadString();
             break;
           }
+          case 18: {
+            EchoedMessage = input.ReadString();
+            break;
+          }
+          case 26: {
+            ProcessedAt = input.ReadString();
+            break;
+          }
+          case 32: {
+            OriginalMessageSize = input.ReadInt32();
+            break;
+          }
         }
       }
     #endif
@@ -435,6 +625,18 @@ public void MergeFrom(pb::CodedInputStream input) {
             Greeting = input.ReadString();
             break;
           }
+          case 18: {
+            EchoedMessage = input.ReadString();
+            break;
+          }
+          case 26: {
+            ProcessedAt = input.ReadString();
+            break;
+          }
+          case 32: {
+            OriginalMessageSize = input.ReadInt32();
+            break;
+          }
         }
       }
     }