MessageGenerator.cs 40 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841
  1. #region Copyright notice and license
  2. // Protocol Buffers - Google's data interchange format
  3. // Copyright 2008 Google Inc. All rights reserved.
  4. // http://github.com/jskeet/dotnet-protobufs/
  5. // Original C++/Java/Python code:
  6. // http://code.google.com/p/protobuf/
  7. //
  8. // Redistribution and use in source and binary forms, with or without
  9. // modification, are permitted provided that the following conditions are
  10. // met:
  11. //
  12. // * Redistributions of source code must retain the above copyright
  13. // notice, this list of conditions and the following disclaimer.
  14. // * Redistributions in binary form must reproduce the above
  15. // copyright notice, this list of conditions and the following disclaimer
  16. // in the documentation and/or other materials provided with the
  17. // distribution.
  18. // * Neither the name of Google Inc. nor the names of its
  19. // contributors may be used to endorse or promote products derived from
  20. // this software without specific prior written permission.
  21. //
  22. // THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS
  23. // "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT
  24. // LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR
  25. // A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT
  26. // OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,
  27. // SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT
  28. // LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
  29. // DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
  30. // THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
  31. // (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE
  32. // OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
  33. #endregion
  34. using System;
  35. using System.Collections.Generic;
  36. using Google.ProtocolBuffers.DescriptorProtos;
  37. using Google.ProtocolBuffers.Descriptors;
  38. namespace Google.ProtocolBuffers.ProtoGen
  39. {
  40. internal class MessageGenerator : SourceGeneratorBase<MessageDescriptor>, ISourceGenerator
  41. {
  42. private string[] _fieldNames;
  43. internal MessageGenerator(MessageDescriptor descriptor) : base(descriptor)
  44. {
  45. }
  46. private string ClassName
  47. {
  48. get { return Descriptor.Name; }
  49. }
  50. private string FullClassName
  51. {
  52. get { return GetClassName(Descriptor); }
  53. }
  54. /// <summary>
  55. /// Get an identifier that uniquely identifies this type within the file.
  56. /// This is used to declare static variables related to this type at the
  57. /// outermost file scope.
  58. /// </summary>
  59. private static string GetUniqueFileScopeIdentifier(IDescriptor descriptor)
  60. {
  61. return "static_" + descriptor.FullName.Replace(".", "_");
  62. }
  63. internal void GenerateStaticVariables(TextGenerator writer)
  64. {
  65. // Because descriptor.proto (Google.ProtocolBuffers.DescriptorProtos) is
  66. // used in the construction of descriptors, we have a tricky bootstrapping
  67. // problem. To help control static initialization order, we make sure all
  68. // descriptors and other static data that depends on them are members of
  69. // the proto-descriptor class. This way, they will be initialized in
  70. // a deterministic order.
  71. string identifier = GetUniqueFileScopeIdentifier(Descriptor);
  72. if (!UseLiteRuntime)
  73. {
  74. // The descriptor for this type.
  75. string access = Descriptor.File.CSharpOptions.NestClasses ? "private" : "internal";
  76. writer.WriteLine("{0} static pbd::MessageDescriptor internal__{1}__Descriptor;", access, identifier);
  77. writer.WriteLine(
  78. "{0} static pb::FieldAccess.FieldAccessorTable<{1}, {1}.Builder> internal__{2}__FieldAccessorTable;",
  79. access, FullClassName, identifier);
  80. }
  81. // Generate static members for all nested types.
  82. foreach (MessageDescriptor nestedMessage in Descriptor.NestedTypes)
  83. {
  84. new MessageGenerator(nestedMessage).GenerateStaticVariables(writer);
  85. }
  86. }
  87. internal void GenerateStaticVariableInitializers(TextGenerator writer)
  88. {
  89. string identifier = GetUniqueFileScopeIdentifier(Descriptor);
  90. if (!UseLiteRuntime)
  91. {
  92. writer.Write("internal__{0}__Descriptor = ", identifier);
  93. if (Descriptor.ContainingType == null)
  94. {
  95. writer.WriteLine("Descriptor.MessageTypes[{0}];", Descriptor.Index);
  96. }
  97. else
  98. {
  99. writer.WriteLine("internal__{0}__Descriptor.NestedTypes[{1}];",
  100. GetUniqueFileScopeIdentifier(Descriptor.ContainingType), Descriptor.Index);
  101. }
  102. writer.WriteLine("internal__{0}__FieldAccessorTable = ", identifier);
  103. writer.WriteLine(
  104. " new pb::FieldAccess.FieldAccessorTable<{1}, {1}.Builder>(internal__{0}__Descriptor,",
  105. identifier, FullClassName);
  106. writer.Print(" new string[] { ");
  107. foreach (FieldDescriptor field in Descriptor.Fields)
  108. {
  109. writer.Write("\"{0}\", ", field.CSharpOptions.PropertyName);
  110. }
  111. writer.WriteLine("});");
  112. }
  113. // Generate static member initializers for all nested types.
  114. foreach (MessageDescriptor nestedMessage in Descriptor.NestedTypes)
  115. {
  116. new MessageGenerator(nestedMessage).GenerateStaticVariableInitializers(writer);
  117. }
  118. foreach (FieldDescriptor extension in Descriptor.Extensions)
  119. {
  120. new ExtensionGenerator(extension).GenerateStaticVariableInitializers(writer);
  121. }
  122. }
  123. public string[] FieldNames
  124. {
  125. get
  126. {
  127. if (_fieldNames == null)
  128. {
  129. List<string> names = new List<string>();
  130. foreach (FieldDescriptor fieldDescriptor in Descriptor.Fields)
  131. {
  132. names.Add(fieldDescriptor.Name);
  133. }
  134. //if you change this, the search must also change in GenerateBuilderParsingMethods
  135. names.Sort(StringComparer.Ordinal);
  136. _fieldNames = names.ToArray();
  137. }
  138. return _fieldNames;
  139. }
  140. }
  141. internal int FieldOrdinal(FieldDescriptor field)
  142. {
  143. return Array.BinarySearch(FieldNames, field.Name, StringComparer.Ordinal);
  144. }
  145. private IFieldSourceGenerator CreateFieldGenerator(FieldDescriptor fieldDescriptor)
  146. {
  147. return SourceGenerators.CreateFieldGenerator(fieldDescriptor, FieldOrdinal(fieldDescriptor));
  148. }
  149. public void Generate(TextGenerator writer)
  150. {
  151. writer.WriteLine("[global::System.Diagnostics.DebuggerNonUserCodeAttribute()]");
  152. writer.WriteLine("[global::System.Runtime.CompilerServices.CompilerGeneratedAttribute()]");
  153. writer.WriteLine("[global::System.CodeDom.Compiler.GeneratedCodeAttribute(\"{0}\", \"{1}\")]",
  154. GetType().Assembly.GetName().Name, GetType().Assembly.GetName().Version);
  155. writer.WriteLine("{0} sealed partial class {1} : pb::{2}Message{3}<{1}, {1}.Builder> {{",
  156. ClassAccessLevel, ClassName,
  157. Descriptor.Proto.ExtensionRangeCount > 0 ? "Extendable" : "Generated",
  158. RuntimeSuffix);
  159. writer.Indent();
  160. // Must call BuildPartial() to make sure all lists are made read-only
  161. writer.WriteLine("private static readonly {0} defaultInstance = new Builder().BuildPartial();", ClassName);
  162. if (OptimizeSpeed)
  163. {
  164. writer.WriteLine("private static readonly string[] _{0}FieldNames = new string[] {{ {2}{1}{2} }};",
  165. NameHelpers.UnderscoresToCamelCase(ClassName), String.Join("\", \"", FieldNames),
  166. FieldNames.Length > 0 ? "\"" : "");
  167. List<string> tags = new List<string>();
  168. foreach (string name in FieldNames)
  169. {
  170. tags.Add(WireFormat.MakeTag(Descriptor.FindFieldByName(name)).ToString());
  171. }
  172. writer.WriteLine("private static readonly uint[] _{0}FieldTags = new uint[] {{ {1} }};",
  173. NameHelpers.UnderscoresToCamelCase(ClassName), String.Join(", ", tags.ToArray()));
  174. }
  175. writer.WriteLine("public static {0} DefaultInstance {{", ClassName);
  176. writer.WriteLine(" get { return defaultInstance; }");
  177. writer.WriteLine("}");
  178. writer.WriteLine();
  179. writer.WriteLine("public override {0} DefaultInstanceForType {{", ClassName);
  180. writer.WriteLine(" get { return defaultInstance; }");
  181. writer.WriteLine("}");
  182. writer.WriteLine();
  183. writer.WriteLine("protected override {0} ThisMessage {{", ClassName);
  184. writer.WriteLine(" get { return this; }");
  185. writer.WriteLine("}");
  186. writer.WriteLine();
  187. if (!UseLiteRuntime)
  188. {
  189. writer.WriteLine("public static pbd::MessageDescriptor Descriptor {");
  190. writer.WriteLine(" get {{ return {0}.internal__{1}__Descriptor; }}",
  191. DescriptorUtil.GetFullUmbrellaClassName(Descriptor),
  192. GetUniqueFileScopeIdentifier(Descriptor));
  193. writer.WriteLine("}");
  194. writer.WriteLine();
  195. writer.WriteLine(
  196. "protected override pb::FieldAccess.FieldAccessorTable<{0}, {0}.Builder> InternalFieldAccessors {{",
  197. ClassName);
  198. writer.WriteLine(" get {{ return {0}.internal__{1}__FieldAccessorTable; }}",
  199. DescriptorUtil.GetFullUmbrellaClassName(Descriptor),
  200. GetUniqueFileScopeIdentifier(Descriptor));
  201. writer.WriteLine("}");
  202. writer.WriteLine();
  203. }
  204. // Extensions don't need to go in an extra nested type
  205. WriteChildren(writer, null, Descriptor.Extensions);
  206. if (Descriptor.EnumTypes.Count + Descriptor.NestedTypes.Count > 0)
  207. {
  208. writer.WriteLine("#region Nested types");
  209. writer.WriteLine("[global::System.Diagnostics.DebuggerNonUserCodeAttribute()]");
  210. writer.WriteLine("[global::System.Runtime.CompilerServices.CompilerGeneratedAttribute()]");
  211. writer.WriteLine("[global::System.CodeDom.Compiler.GeneratedCodeAttribute(\"{0}\", \"{1}\")]",
  212. GetType().Assembly.GetName().Name, GetType().Assembly.GetName().Version);
  213. writer.WriteLine("public static class Types {");
  214. writer.Indent();
  215. WriteChildren(writer, null, Descriptor.EnumTypes);
  216. WriteChildren(writer, null, Descriptor.NestedTypes);
  217. writer.Outdent();
  218. writer.WriteLine("}");
  219. writer.WriteLine("#endregion");
  220. writer.WriteLine();
  221. }
  222. foreach (FieldDescriptor fieldDescriptor in Descriptor.Fields)
  223. {
  224. if (Descriptor.File.CSharpOptions.ClsCompliance && GetFieldConstantName(fieldDescriptor).StartsWith("_"))
  225. {
  226. writer.WriteLine("[global::System.CLSCompliant(false)]");
  227. }
  228. // Rats: we lose the debug comment here :(
  229. writer.WriteLine("public const int {0} = {1};", GetFieldConstantName(fieldDescriptor),
  230. fieldDescriptor.FieldNumber);
  231. CreateFieldGenerator(fieldDescriptor).GenerateMembers(writer);
  232. writer.WriteLine();
  233. }
  234. if (OptimizeSpeed)
  235. {
  236. GenerateIsInitialized(writer);
  237. GenerateMessageSerializationMethods(writer);
  238. }
  239. if (UseLiteRuntime)
  240. {
  241. GenerateLiteRuntimeMethods(writer);
  242. }
  243. GenerateParseFromMethods(writer);
  244. GenerateBuilder(writer);
  245. // Force the static initialization code for the file to run, since it may
  246. // initialize static variables declared in this class.
  247. writer.WriteLine("static {0}() {{", ClassName);
  248. // We call object.ReferenceEquals() just to make it a valid statement on its own.
  249. // Another option would be GetType(), but that causes problems in DescriptorProtoFile,
  250. // where the bootstrapping is somewhat recursive - type initializers call
  251. // each other, effectively. We temporarily see Descriptor as null.
  252. writer.WriteLine(" object.ReferenceEquals({0}.Descriptor, null);",
  253. DescriptorUtil.GetFullUmbrellaClassName(Descriptor));
  254. writer.WriteLine("}");
  255. writer.Outdent();
  256. writer.WriteLine("}");
  257. writer.WriteLine();
  258. }
  259. private void GenerateLiteRuntimeMethods(TextGenerator writer)
  260. {
  261. bool callbase = Descriptor.Proto.ExtensionRangeCount > 0;
  262. writer.WriteLine("#region Lite runtime methods");
  263. writer.WriteLine("public override int GetHashCode() {");
  264. writer.Indent();
  265. writer.WriteLine("int hash = GetType().GetHashCode();");
  266. foreach (FieldDescriptor fieldDescriptor in Descriptor.Fields)
  267. {
  268. CreateFieldGenerator(fieldDescriptor).WriteHash(writer);
  269. }
  270. if (callbase)
  271. {
  272. writer.WriteLine("hash ^= base.GetHashCode();");
  273. }
  274. writer.WriteLine("return hash;");
  275. writer.Outdent();
  276. writer.WriteLine("}");
  277. writer.WriteLine();
  278. writer.WriteLine("public override bool Equals(object obj) {");
  279. writer.Indent();
  280. writer.WriteLine("{0} other = obj as {0};", ClassName);
  281. writer.WriteLine("if (other == null) return false;");
  282. foreach (FieldDescriptor fieldDescriptor in Descriptor.Fields)
  283. {
  284. CreateFieldGenerator(fieldDescriptor).WriteEquals(writer);
  285. }
  286. if (callbase)
  287. {
  288. writer.WriteLine("if (!base.Equals(other)) return false;");
  289. }
  290. writer.WriteLine("return true;");
  291. writer.Outdent();
  292. writer.WriteLine("}");
  293. writer.WriteLine();
  294. writer.WriteLine("public override void PrintTo(global::System.IO.TextWriter writer) {");
  295. writer.Indent();
  296. List<FieldDescriptor> sorted = new List<FieldDescriptor>(Descriptor.Fields);
  297. sorted.Sort(
  298. new Comparison<FieldDescriptor>(
  299. delegate(FieldDescriptor a, FieldDescriptor b) { return a.FieldNumber.CompareTo(b.FieldNumber); }));
  300. foreach (FieldDescriptor fieldDescriptor in sorted)
  301. {
  302. CreateFieldGenerator(fieldDescriptor).WriteToString(writer);
  303. }
  304. if (callbase)
  305. {
  306. writer.WriteLine("base.PrintTo(writer);");
  307. }
  308. writer.Outdent();
  309. writer.WriteLine("}");
  310. writer.WriteLine("#endregion");
  311. writer.WriteLine();
  312. }
  313. private void GenerateMessageSerializationMethods(TextGenerator writer)
  314. {
  315. List<FieldDescriptor> sortedFields = new List<FieldDescriptor>(Descriptor.Fields);
  316. sortedFields.Sort((f1, f2) => f1.FieldNumber.CompareTo(f2.FieldNumber));
  317. List<DescriptorProto.Types.ExtensionRange> sortedExtensions =
  318. new List<DescriptorProto.Types.ExtensionRange>(Descriptor.Proto.ExtensionRangeList);
  319. sortedExtensions.Sort((r1, r2) => (r1.Start.CompareTo(r2.Start)));
  320. writer.WriteLine("public override void WriteTo(pb::ICodedOutputStream output) {");
  321. writer.Indent();
  322. // Make sure we've computed the serialized length, so that packed fields are generated correctly.
  323. writer.WriteLine("int size = SerializedSize;");
  324. writer.WriteLine("string[] field_names = _{0}FieldNames;", NameHelpers.UnderscoresToCamelCase(ClassName));
  325. if (Descriptor.Proto.ExtensionRangeList.Count > 0)
  326. {
  327. writer.WriteLine(
  328. "pb::ExtendableMessage{1}<{0}, {0}.Builder>.ExtensionWriter extensionWriter = CreateExtensionWriter(this);",
  329. ClassName, RuntimeSuffix);
  330. }
  331. // Merge the fields and the extension ranges, both sorted by field number.
  332. for (int i = 0, j = 0; i < Descriptor.Fields.Count || j < sortedExtensions.Count;)
  333. {
  334. if (i == Descriptor.Fields.Count)
  335. {
  336. GenerateSerializeOneExtensionRange(writer, sortedExtensions[j++]);
  337. }
  338. else if (j == sortedExtensions.Count)
  339. {
  340. GenerateSerializeOneField(writer, sortedFields[i++]);
  341. }
  342. else if (sortedFields[i].FieldNumber < sortedExtensions[j].Start)
  343. {
  344. GenerateSerializeOneField(writer, sortedFields[i++]);
  345. }
  346. else
  347. {
  348. GenerateSerializeOneExtensionRange(writer, sortedExtensions[j++]);
  349. }
  350. }
  351. if (!UseLiteRuntime)
  352. {
  353. if (Descriptor.Proto.Options.MessageSetWireFormat)
  354. {
  355. writer.WriteLine("UnknownFields.WriteAsMessageSetTo(output);");
  356. }
  357. else
  358. {
  359. writer.WriteLine("UnknownFields.WriteTo(output);");
  360. }
  361. }
  362. writer.Outdent();
  363. writer.WriteLine("}");
  364. writer.WriteLine();
  365. writer.WriteLine("private int memoizedSerializedSize = -1;");
  366. writer.WriteLine("public override int SerializedSize {");
  367. writer.Indent();
  368. writer.WriteLine("get {");
  369. writer.Indent();
  370. writer.WriteLine("int size = memoizedSerializedSize;");
  371. writer.WriteLine("if (size != -1) return size;");
  372. writer.WriteLine();
  373. writer.WriteLine("size = 0;");
  374. foreach (FieldDescriptor field in Descriptor.Fields)
  375. {
  376. CreateFieldGenerator(field).GenerateSerializedSizeCode(writer);
  377. }
  378. if (Descriptor.Proto.ExtensionRangeCount > 0)
  379. {
  380. writer.WriteLine("size += ExtensionsSerializedSize;");
  381. }
  382. if (!UseLiteRuntime)
  383. {
  384. if (Descriptor.Options.MessageSetWireFormat)
  385. {
  386. writer.WriteLine("size += UnknownFields.SerializedSizeAsMessageSet;");
  387. }
  388. else
  389. {
  390. writer.WriteLine("size += UnknownFields.SerializedSize;");
  391. }
  392. }
  393. writer.WriteLine("memoizedSerializedSize = size;");
  394. writer.WriteLine("return size;");
  395. writer.Outdent();
  396. writer.WriteLine("}");
  397. writer.Outdent();
  398. writer.WriteLine("}");
  399. writer.WriteLine();
  400. }
  401. private void GenerateSerializeOneField(TextGenerator writer, FieldDescriptor fieldDescriptor)
  402. {
  403. CreateFieldGenerator(fieldDescriptor).GenerateSerializationCode(writer);
  404. }
  405. private static void GenerateSerializeOneExtensionRange(TextGenerator writer,
  406. DescriptorProto.Types.ExtensionRange extensionRange)
  407. {
  408. writer.WriteLine("extensionWriter.WriteUntil({0}, output);", extensionRange.End);
  409. }
  410. private void GenerateParseFromMethods(TextGenerator writer)
  411. {
  412. // Note: These are separate from GenerateMessageSerializationMethods()
  413. // because they need to be generated even for messages that are optimized
  414. // for code size.
  415. writer.WriteLine("public static {0} ParseFrom(pb::ByteString data) {{", ClassName);
  416. writer.WriteLine(" return ((Builder) CreateBuilder().MergeFrom(data)).BuildParsed();");
  417. writer.WriteLine("}");
  418. writer.WriteLine(
  419. "public static {0} ParseFrom(pb::ByteString data, pb::ExtensionRegistry extensionRegistry) {{",
  420. ClassName);
  421. writer.WriteLine(" return ((Builder) CreateBuilder().MergeFrom(data, extensionRegistry)).BuildParsed();");
  422. writer.WriteLine("}");
  423. writer.WriteLine("public static {0} ParseFrom(byte[] data) {{", ClassName);
  424. writer.WriteLine(" return ((Builder) CreateBuilder().MergeFrom(data)).BuildParsed();");
  425. writer.WriteLine("}");
  426. writer.WriteLine("public static {0} ParseFrom(byte[] data, pb::ExtensionRegistry extensionRegistry) {{",
  427. ClassName);
  428. writer.WriteLine(" return ((Builder) CreateBuilder().MergeFrom(data, extensionRegistry)).BuildParsed();");
  429. writer.WriteLine("}");
  430. writer.WriteLine("public static {0} ParseFrom(global::System.IO.Stream input) {{", ClassName);
  431. writer.WriteLine(" return ((Builder) CreateBuilder().MergeFrom(input)).BuildParsed();");
  432. writer.WriteLine("}");
  433. writer.WriteLine(
  434. "public static {0} ParseFrom(global::System.IO.Stream input, pb::ExtensionRegistry extensionRegistry) {{",
  435. ClassName);
  436. writer.WriteLine(" return ((Builder) CreateBuilder().MergeFrom(input, extensionRegistry)).BuildParsed();");
  437. writer.WriteLine("}");
  438. writer.WriteLine("public static {0} ParseDelimitedFrom(global::System.IO.Stream input) {{", ClassName);
  439. writer.WriteLine(" return CreateBuilder().MergeDelimitedFrom(input).BuildParsed();");
  440. writer.WriteLine("}");
  441. writer.WriteLine(
  442. "public static {0} ParseDelimitedFrom(global::System.IO.Stream input, pb::ExtensionRegistry extensionRegistry) {{",
  443. ClassName);
  444. writer.WriteLine(" return CreateBuilder().MergeDelimitedFrom(input, extensionRegistry).BuildParsed();");
  445. writer.WriteLine("}");
  446. writer.WriteLine("public static {0} ParseFrom(pb::ICodedInputStream input) {{", ClassName);
  447. writer.WriteLine(" return ((Builder) CreateBuilder().MergeFrom(input)).BuildParsed();");
  448. writer.WriteLine("}");
  449. writer.WriteLine(
  450. "public static {0} ParseFrom(pb::ICodedInputStream input, pb::ExtensionRegistry extensionRegistry) {{",
  451. ClassName);
  452. writer.WriteLine(" return ((Builder) CreateBuilder().MergeFrom(input, extensionRegistry)).BuildParsed();");
  453. writer.WriteLine("}");
  454. }
  455. /// <summary>
  456. /// Returns whether or not the specified message type has any required fields.
  457. /// If it doesn't, calls to check for initialization can be optimised.
  458. /// TODO(jonskeet): Move this into MessageDescriptor?
  459. /// </summary>
  460. private static bool HasRequiredFields(MessageDescriptor descriptor,
  461. Dictionary<MessageDescriptor, object> alreadySeen)
  462. {
  463. if (alreadySeen.ContainsKey(descriptor))
  464. {
  465. // The type is already in cache. This means that either:
  466. // a. The type has no required fields.
  467. // b. We are in the midst of checking if the type has required fields,
  468. // somewhere up the stack. In this case, we know that if the type
  469. // has any required fields, they'll be found when we return to it,
  470. // and the whole call to HasRequiredFields() will return true.
  471. // Therefore, we don't have to check if this type has required fields
  472. // here.
  473. return false;
  474. }
  475. alreadySeen[descriptor] = descriptor; // Value is irrelevant
  476. // If the type has extensions, an extension with message type could contain
  477. // required fields, so we have to be conservative and assume such an
  478. // extension exists.
  479. if (descriptor.Extensions.Count > 0)
  480. {
  481. return true;
  482. }
  483. foreach (FieldDescriptor field in descriptor.Fields)
  484. {
  485. if (field.IsRequired)
  486. {
  487. return true;
  488. }
  489. // Message or group
  490. if (field.MappedType == MappedType.Message)
  491. {
  492. if (HasRequiredFields(field.MessageType, alreadySeen))
  493. {
  494. return true;
  495. }
  496. }
  497. }
  498. return false;
  499. }
  500. private void GenerateBuilder(TextGenerator writer)
  501. {
  502. writer.WriteLine("public static Builder CreateBuilder() { return new Builder(); }");
  503. writer.WriteLine("public override Builder ToBuilder() { return CreateBuilder(this); }");
  504. writer.WriteLine("public override Builder CreateBuilderForType() { return new Builder(); }");
  505. writer.WriteLine("public static Builder CreateBuilder({0} prototype) {{", ClassName);
  506. writer.WriteLine(" return (Builder) new Builder().MergeFrom(prototype);");
  507. writer.WriteLine("}");
  508. writer.WriteLine();
  509. writer.WriteLine("[global::System.Diagnostics.DebuggerNonUserCodeAttribute()]");
  510. writer.WriteLine("[global::System.Runtime.CompilerServices.CompilerGeneratedAttribute()]");
  511. writer.WriteLine("[global::System.CodeDom.Compiler.GeneratedCodeAttribute(\"{0}\", \"{1}\")]",
  512. GetType().Assembly.GetName().Name, GetType().Assembly.GetName().Version);
  513. writer.WriteLine("{0} sealed partial class Builder : pb::{2}Builder{3}<{1}, Builder> {{",
  514. ClassAccessLevel, ClassName,
  515. Descriptor.Proto.ExtensionRangeCount > 0 ? "Extendable" : "Generated", RuntimeSuffix);
  516. writer.Indent();
  517. writer.WriteLine("protected override Builder ThisBuilder {");
  518. writer.WriteLine(" get { return this; }");
  519. writer.WriteLine("}");
  520. GenerateCommonBuilderMethods(writer);
  521. if (OptimizeSpeed)
  522. {
  523. GenerateBuilderParsingMethods(writer);
  524. }
  525. foreach (FieldDescriptor field in Descriptor.Fields)
  526. {
  527. writer.WriteLine();
  528. // No field comment :(
  529. CreateFieldGenerator(field).GenerateBuilderMembers(writer);
  530. }
  531. writer.Outdent();
  532. writer.WriteLine("}");
  533. }
  534. private void GenerateCommonBuilderMethods(TextGenerator writer)
  535. {
  536. writer.WriteLine("public Builder() {{}}", ClassAccessLevel);
  537. writer.WriteLine();
  538. writer.WriteLine("{0} result = new {0}();", ClassName);
  539. writer.WriteLine();
  540. writer.WriteLine("protected override {0} MessageBeingBuilt {{", ClassName);
  541. writer.WriteLine(" get { return result; }");
  542. writer.WriteLine("}");
  543. writer.WriteLine();
  544. writer.WriteLine("public override Builder Clear() {");
  545. writer.WriteLine(" result = new {0}();", ClassName);
  546. writer.WriteLine(" return this;");
  547. writer.WriteLine("}");
  548. writer.WriteLine();
  549. writer.WriteLine("public override Builder Clone() {");
  550. writer.WriteLine(" return new Builder().MergeFrom(result);");
  551. writer.WriteLine("}");
  552. writer.WriteLine();
  553. if (!UseLiteRuntime)
  554. {
  555. writer.WriteLine("public override pbd::MessageDescriptor DescriptorForType {");
  556. writer.WriteLine(" get {{ return {0}.Descriptor; }}", FullClassName);
  557. writer.WriteLine("}");
  558. writer.WriteLine();
  559. }
  560. writer.WriteLine("public override {0} DefaultInstanceForType {{", ClassName);
  561. writer.WriteLine(" get {{ return {0}.DefaultInstance; }}", FullClassName);
  562. writer.WriteLine("}");
  563. writer.WriteLine();
  564. writer.WriteLine("public override {0} BuildPartial() {{", ClassName);
  565. writer.Indent();
  566. writer.WriteLine("if (result == null) {");
  567. writer.WriteLine(
  568. " throw new global::System.InvalidOperationException(\"build() has already been called on this Builder\");");
  569. writer.WriteLine("}");
  570. foreach (FieldDescriptor field in Descriptor.Fields)
  571. {
  572. CreateFieldGenerator(field).GenerateBuildingCode(writer);
  573. }
  574. writer.WriteLine("{0} returnMe = result;", ClassName);
  575. writer.WriteLine("result = null;");
  576. writer.WriteLine("return returnMe;");
  577. writer.Outdent();
  578. writer.WriteLine("}");
  579. writer.WriteLine();
  580. if (OptimizeSpeed)
  581. {
  582. writer.WriteLine("public override Builder MergeFrom(pb::IMessage{0} other) {{", RuntimeSuffix);
  583. writer.WriteLine(" if (other is {0}) {{", ClassName);
  584. writer.WriteLine(" return MergeFrom(({0}) other);", ClassName);
  585. writer.WriteLine(" } else {");
  586. writer.WriteLine(" base.MergeFrom(other);");
  587. writer.WriteLine(" return this;");
  588. writer.WriteLine(" }");
  589. writer.WriteLine("}");
  590. writer.WriteLine();
  591. writer.WriteLine("public override Builder MergeFrom({0} other) {{", ClassName);
  592. // Optimization: If other is the default instance, we know none of its
  593. // fields are set so we can skip the merge.
  594. writer.Indent();
  595. writer.WriteLine("if (other == {0}.DefaultInstance) return this;", FullClassName);
  596. foreach (FieldDescriptor field in Descriptor.Fields)
  597. {
  598. CreateFieldGenerator(field).GenerateMergingCode(writer);
  599. }
  600. // if message type has extensions
  601. if (Descriptor.Proto.ExtensionRangeCount > 0)
  602. {
  603. writer.WriteLine(" this.MergeExtensionFields(other);");
  604. }
  605. if (!UseLiteRuntime)
  606. {
  607. writer.WriteLine("this.MergeUnknownFields(other.UnknownFields);");
  608. }
  609. writer.WriteLine("return this;");
  610. writer.Outdent();
  611. writer.WriteLine("}");
  612. writer.WriteLine();
  613. }
  614. }
  615. private void GenerateBuilderParsingMethods(TextGenerator writer)
  616. {
  617. List<FieldDescriptor> sortedFields = new List<FieldDescriptor>(Descriptor.Fields);
  618. sortedFields.Sort((f1, f2) => f1.FieldNumber.CompareTo(f2.FieldNumber));
  619. writer.WriteLine("public override Builder MergeFrom(pb::ICodedInputStream input) {");
  620. writer.WriteLine(" return MergeFrom(input, pb::ExtensionRegistry.Empty);");
  621. writer.WriteLine("}");
  622. writer.WriteLine();
  623. writer.WriteLine(
  624. "public override Builder MergeFrom(pb::ICodedInputStream input, pb::ExtensionRegistry extensionRegistry) {");
  625. writer.Indent();
  626. if (!UseLiteRuntime)
  627. {
  628. writer.WriteLine("pb::UnknownFieldSet.Builder unknownFields = null;");
  629. }
  630. writer.WriteLine("uint tag;");
  631. writer.WriteLine("string field_name;");
  632. writer.WriteLine("while (input.ReadTag(out tag, out field_name)) {");
  633. writer.Indent();
  634. writer.WriteLine("if(tag == 0 && field_name != null) {");
  635. writer.Indent();
  636. //if you change from StringComparer.Ordinal, the array sort in FieldNames { get; } must also change
  637. writer.WriteLine(
  638. "int field_ordinal = global::System.Array.BinarySearch(_{0}FieldNames, field_name, global::System.StringComparer.Ordinal);",
  639. NameHelpers.UnderscoresToCamelCase(ClassName));
  640. writer.WriteLine("if(field_ordinal >= 0)");
  641. writer.WriteLine(" tag = _{0}FieldTags[field_ordinal];", NameHelpers.UnderscoresToCamelCase(ClassName));
  642. writer.WriteLine("else {");
  643. if (!UseLiteRuntime)
  644. {
  645. writer.WriteLine(" if (unknownFields == null) {"); // First unknown field - create builder now
  646. writer.WriteLine(" unknownFields = pb::UnknownFieldSet.CreateBuilder(this.UnknownFields);");
  647. writer.WriteLine(" }");
  648. }
  649. writer.WriteLine(" ParseUnknownField(input, {0}extensionRegistry, tag, field_name);",
  650. UseLiteRuntime ? "" : "unknownFields, ");
  651. writer.WriteLine(" continue;");
  652. writer.WriteLine("}");
  653. writer.Outdent();
  654. writer.WriteLine("}");
  655. writer.WriteLine("switch (tag) {");
  656. writer.Indent();
  657. writer.WriteLine("case 0: {"); // 0 signals EOF / limit reached
  658. writer.WriteLine(" throw pb::InvalidProtocolBufferException.InvalidTag();");
  659. writer.WriteLine("}");
  660. writer.WriteLine("default: {");
  661. writer.WriteLine(" if (pb::WireFormat.IsEndGroupTag(tag)) {");
  662. if (!UseLiteRuntime)
  663. {
  664. writer.WriteLine(" if (unknownFields != null) {");
  665. writer.WriteLine(" this.UnknownFields = unknownFields.Build();");
  666. writer.WriteLine(" }");
  667. }
  668. writer.WriteLine(" return this;"); // it's an endgroup tag
  669. writer.WriteLine(" }");
  670. if (!UseLiteRuntime)
  671. {
  672. writer.WriteLine(" if (unknownFields == null) {"); // First unknown field - create builder now
  673. writer.WriteLine(" unknownFields = pb::UnknownFieldSet.CreateBuilder(this.UnknownFields);");
  674. writer.WriteLine(" }");
  675. }
  676. writer.WriteLine(" ParseUnknownField(input, {0}extensionRegistry, tag, field_name);",
  677. UseLiteRuntime ? "" : "unknownFields, ");
  678. writer.WriteLine(" break;");
  679. writer.WriteLine("}");
  680. foreach (FieldDescriptor field in sortedFields)
  681. {
  682. WireFormat.WireType wt = WireFormat.GetWireType(field.FieldType);
  683. uint tag = WireFormat.MakeTag(field.FieldNumber, wt);
  684. if (field.IsRepeated &&
  685. (wt == WireFormat.WireType.Varint || wt == WireFormat.WireType.Fixed32 ||
  686. wt == WireFormat.WireType.Fixed64))
  687. {
  688. writer.WriteLine("case {0}:",
  689. WireFormat.MakeTag(field.FieldNumber, WireFormat.WireType.LengthDelimited));
  690. }
  691. writer.WriteLine("case {0}: {{", tag);
  692. writer.Indent();
  693. CreateFieldGenerator(field).GenerateParsingCode(writer);
  694. writer.WriteLine("break;");
  695. writer.Outdent();
  696. writer.WriteLine("}");
  697. }
  698. writer.Outdent();
  699. writer.WriteLine("}");
  700. writer.Outdent();
  701. writer.WriteLine("}");
  702. writer.WriteLine();
  703. if (!UseLiteRuntime)
  704. {
  705. writer.WriteLine("if (unknownFields != null) {");
  706. writer.WriteLine(" this.UnknownFields = unknownFields.Build();");
  707. writer.WriteLine("}");
  708. }
  709. writer.WriteLine("return this;");
  710. writer.Outdent();
  711. writer.WriteLine("}");
  712. writer.WriteLine();
  713. }
  714. private void GenerateIsInitialized(TextGenerator writer)
  715. {
  716. writer.WriteLine("public override bool IsInitialized {");
  717. writer.Indent();
  718. writer.WriteLine("get {");
  719. writer.Indent();
  720. // Check that all required fields in this message are set.
  721. // TODO(kenton): We can optimize this when we switch to putting all the
  722. // "has" fields into a single bitfield.
  723. foreach (FieldDescriptor field in Descriptor.Fields)
  724. {
  725. if (field.IsRequired)
  726. {
  727. writer.WriteLine("if (!has{0}) return false;", field.CSharpOptions.PropertyName);
  728. }
  729. }
  730. // Now check that all embedded messages are initialized.
  731. foreach (FieldDescriptor field in Descriptor.Fields)
  732. {
  733. if (field.FieldType != FieldType.Message ||
  734. !HasRequiredFields(field.MessageType, new Dictionary<MessageDescriptor, object>()))
  735. {
  736. continue;
  737. }
  738. string propertyName = NameHelpers.UnderscoresToPascalCase(GetFieldName(field));
  739. if (field.IsRepeated)
  740. {
  741. writer.WriteLine("foreach ({0} element in {1}List) {{", GetClassName(field.MessageType),
  742. propertyName);
  743. writer.WriteLine(" if (!element.IsInitialized) return false;");
  744. writer.WriteLine("}");
  745. }
  746. else if (field.IsOptional)
  747. {
  748. writer.WriteLine("if (Has{0}) {{", propertyName);
  749. writer.WriteLine(" if (!{0}.IsInitialized) return false;", propertyName);
  750. writer.WriteLine("}");
  751. }
  752. else
  753. {
  754. writer.WriteLine("if (!{0}.IsInitialized) return false;", propertyName);
  755. }
  756. }
  757. if (Descriptor.Proto.ExtensionRangeCount > 0)
  758. {
  759. writer.WriteLine("if (!ExtensionsAreInitialized) return false;");
  760. }
  761. writer.WriteLine("return true;");
  762. writer.Outdent();
  763. writer.WriteLine("}");
  764. writer.Outdent();
  765. writer.WriteLine("}");
  766. writer.WriteLine();
  767. }
  768. internal void GenerateExtensionRegistrationCode(TextGenerator writer)
  769. {
  770. foreach (FieldDescriptor extension in Descriptor.Extensions)
  771. {
  772. new ExtensionGenerator(extension).GenerateExtensionRegistrationCode(writer);
  773. }
  774. foreach (MessageDescriptor nestedMessage in Descriptor.NestedTypes)
  775. {
  776. new MessageGenerator(nestedMessage).GenerateExtensionRegistrationCode(writer);
  777. }
  778. }
  779. }
  780. }