MessageGenerator.cs 40 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839
  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. writer.WriteLine("[global::System.CLSCompliant(false)]");
  226. // Rats: we lose the debug comment here :(
  227. writer.WriteLine("public const int {0} = {1};", GetFieldConstantName(fieldDescriptor),
  228. fieldDescriptor.FieldNumber);
  229. CreateFieldGenerator(fieldDescriptor).GenerateMembers(writer);
  230. writer.WriteLine();
  231. }
  232. if (OptimizeSpeed)
  233. {
  234. GenerateIsInitialized(writer);
  235. GenerateMessageSerializationMethods(writer);
  236. }
  237. if (UseLiteRuntime)
  238. {
  239. GenerateLiteRuntimeMethods(writer);
  240. }
  241. GenerateParseFromMethods(writer);
  242. GenerateBuilder(writer);
  243. // Force the static initialization code for the file to run, since it may
  244. // initialize static variables declared in this class.
  245. writer.WriteLine("static {0}() {{", ClassName);
  246. // We call object.ReferenceEquals() just to make it a valid statement on its own.
  247. // Another option would be GetType(), but that causes problems in DescriptorProtoFile,
  248. // where the bootstrapping is somewhat recursive - type initializers call
  249. // each other, effectively. We temporarily see Descriptor as null.
  250. writer.WriteLine(" object.ReferenceEquals({0}.Descriptor, null);",
  251. DescriptorUtil.GetFullUmbrellaClassName(Descriptor));
  252. writer.WriteLine("}");
  253. writer.Outdent();
  254. writer.WriteLine("}");
  255. writer.WriteLine();
  256. }
  257. private void GenerateLiteRuntimeMethods(TextGenerator writer)
  258. {
  259. bool callbase = Descriptor.Proto.ExtensionRangeCount > 0;
  260. writer.WriteLine("#region Lite runtime methods");
  261. writer.WriteLine("public override int GetHashCode() {");
  262. writer.Indent();
  263. writer.WriteLine("int hash = GetType().GetHashCode();");
  264. foreach (FieldDescriptor fieldDescriptor in Descriptor.Fields)
  265. {
  266. CreateFieldGenerator(fieldDescriptor).WriteHash(writer);
  267. }
  268. if (callbase)
  269. {
  270. writer.WriteLine("hash ^= base.GetHashCode();");
  271. }
  272. writer.WriteLine("return hash;");
  273. writer.Outdent();
  274. writer.WriteLine("}");
  275. writer.WriteLine();
  276. writer.WriteLine("public override bool Equals(object obj) {");
  277. writer.Indent();
  278. writer.WriteLine("{0} other = obj as {0};", ClassName);
  279. writer.WriteLine("if (other == null) return false;");
  280. foreach (FieldDescriptor fieldDescriptor in Descriptor.Fields)
  281. {
  282. CreateFieldGenerator(fieldDescriptor).WriteEquals(writer);
  283. }
  284. if (callbase)
  285. {
  286. writer.WriteLine("if (!base.Equals(other)) return false;");
  287. }
  288. writer.WriteLine("return true;");
  289. writer.Outdent();
  290. writer.WriteLine("}");
  291. writer.WriteLine();
  292. writer.WriteLine("public override void PrintTo(global::System.IO.TextWriter writer) {");
  293. writer.Indent();
  294. List<FieldDescriptor> sorted = new List<FieldDescriptor>(Descriptor.Fields);
  295. sorted.Sort(
  296. new Comparison<FieldDescriptor>(
  297. delegate(FieldDescriptor a, FieldDescriptor b) { return a.FieldNumber.CompareTo(b.FieldNumber); }));
  298. foreach (FieldDescriptor fieldDescriptor in sorted)
  299. {
  300. CreateFieldGenerator(fieldDescriptor).WriteToString(writer);
  301. }
  302. if (callbase)
  303. {
  304. writer.WriteLine("base.PrintTo(writer);");
  305. }
  306. writer.Outdent();
  307. writer.WriteLine("}");
  308. writer.WriteLine("#endregion");
  309. writer.WriteLine();
  310. }
  311. private void GenerateMessageSerializationMethods(TextGenerator writer)
  312. {
  313. List<FieldDescriptor> sortedFields = new List<FieldDescriptor>(Descriptor.Fields);
  314. sortedFields.Sort((f1, f2) => f1.FieldNumber.CompareTo(f2.FieldNumber));
  315. List<DescriptorProto.Types.ExtensionRange> sortedExtensions =
  316. new List<DescriptorProto.Types.ExtensionRange>(Descriptor.Proto.ExtensionRangeList);
  317. sortedExtensions.Sort((r1, r2) => (r1.Start.CompareTo(r2.Start)));
  318. writer.WriteLine("public override void WriteTo(pb::ICodedOutputStream output) {");
  319. writer.Indent();
  320. // Make sure we've computed the serialized length, so that packed fields are generated correctly.
  321. writer.WriteLine("int size = SerializedSize;");
  322. writer.WriteLine("string[] field_names = _{0}FieldNames;", NameHelpers.UnderscoresToCamelCase(ClassName));
  323. if (Descriptor.Proto.ExtensionRangeList.Count > 0)
  324. {
  325. writer.WriteLine(
  326. "pb::ExtendableMessage{1}<{0}, {0}.Builder>.ExtensionWriter extensionWriter = CreateExtensionWriter(this);",
  327. ClassName, RuntimeSuffix);
  328. }
  329. // Merge the fields and the extension ranges, both sorted by field number.
  330. for (int i = 0, j = 0; i < Descriptor.Fields.Count || j < sortedExtensions.Count;)
  331. {
  332. if (i == Descriptor.Fields.Count)
  333. {
  334. GenerateSerializeOneExtensionRange(writer, sortedExtensions[j++]);
  335. }
  336. else if (j == sortedExtensions.Count)
  337. {
  338. GenerateSerializeOneField(writer, sortedFields[i++]);
  339. }
  340. else if (sortedFields[i].FieldNumber < sortedExtensions[j].Start)
  341. {
  342. GenerateSerializeOneField(writer, sortedFields[i++]);
  343. }
  344. else
  345. {
  346. GenerateSerializeOneExtensionRange(writer, sortedExtensions[j++]);
  347. }
  348. }
  349. if (!UseLiteRuntime)
  350. {
  351. if (Descriptor.Proto.Options.MessageSetWireFormat)
  352. {
  353. writer.WriteLine("UnknownFields.WriteAsMessageSetTo(output);");
  354. }
  355. else
  356. {
  357. writer.WriteLine("UnknownFields.WriteTo(output);");
  358. }
  359. }
  360. writer.Outdent();
  361. writer.WriteLine("}");
  362. writer.WriteLine();
  363. writer.WriteLine("private int memoizedSerializedSize = -1;");
  364. writer.WriteLine("public override int SerializedSize {");
  365. writer.Indent();
  366. writer.WriteLine("get {");
  367. writer.Indent();
  368. writer.WriteLine("int size = memoizedSerializedSize;");
  369. writer.WriteLine("if (size != -1) return size;");
  370. writer.WriteLine();
  371. writer.WriteLine("size = 0;");
  372. foreach (FieldDescriptor field in Descriptor.Fields)
  373. {
  374. CreateFieldGenerator(field).GenerateSerializedSizeCode(writer);
  375. }
  376. if (Descriptor.Proto.ExtensionRangeCount > 0)
  377. {
  378. writer.WriteLine("size += ExtensionsSerializedSize;");
  379. }
  380. if (!UseLiteRuntime)
  381. {
  382. if (Descriptor.Options.MessageSetWireFormat)
  383. {
  384. writer.WriteLine("size += UnknownFields.SerializedSizeAsMessageSet;");
  385. }
  386. else
  387. {
  388. writer.WriteLine("size += UnknownFields.SerializedSize;");
  389. }
  390. }
  391. writer.WriteLine("memoizedSerializedSize = size;");
  392. writer.WriteLine("return size;");
  393. writer.Outdent();
  394. writer.WriteLine("}");
  395. writer.Outdent();
  396. writer.WriteLine("}");
  397. writer.WriteLine();
  398. }
  399. private void GenerateSerializeOneField(TextGenerator writer, FieldDescriptor fieldDescriptor)
  400. {
  401. CreateFieldGenerator(fieldDescriptor).GenerateSerializationCode(writer);
  402. }
  403. private static void GenerateSerializeOneExtensionRange(TextGenerator writer,
  404. DescriptorProto.Types.ExtensionRange extensionRange)
  405. {
  406. writer.WriteLine("extensionWriter.WriteUntil({0}, output);", extensionRange.End);
  407. }
  408. private void GenerateParseFromMethods(TextGenerator writer)
  409. {
  410. // Note: These are separate from GenerateMessageSerializationMethods()
  411. // because they need to be generated even for messages that are optimized
  412. // for code size.
  413. writer.WriteLine("public static {0} ParseFrom(pb::ByteString data) {{", ClassName);
  414. writer.WriteLine(" return ((Builder) CreateBuilder().MergeFrom(data)).BuildParsed();");
  415. writer.WriteLine("}");
  416. writer.WriteLine(
  417. "public static {0} ParseFrom(pb::ByteString data, pb::ExtensionRegistry extensionRegistry) {{",
  418. ClassName);
  419. writer.WriteLine(" return ((Builder) CreateBuilder().MergeFrom(data, extensionRegistry)).BuildParsed();");
  420. writer.WriteLine("}");
  421. writer.WriteLine("public static {0} ParseFrom(byte[] data) {{", ClassName);
  422. writer.WriteLine(" return ((Builder) CreateBuilder().MergeFrom(data)).BuildParsed();");
  423. writer.WriteLine("}");
  424. writer.WriteLine("public static {0} ParseFrom(byte[] data, pb::ExtensionRegistry extensionRegistry) {{",
  425. ClassName);
  426. writer.WriteLine(" return ((Builder) CreateBuilder().MergeFrom(data, extensionRegistry)).BuildParsed();");
  427. writer.WriteLine("}");
  428. writer.WriteLine("public static {0} ParseFrom(global::System.IO.Stream input) {{", ClassName);
  429. writer.WriteLine(" return ((Builder) CreateBuilder().MergeFrom(input)).BuildParsed();");
  430. writer.WriteLine("}");
  431. writer.WriteLine(
  432. "public static {0} ParseFrom(global::System.IO.Stream input, pb::ExtensionRegistry extensionRegistry) {{",
  433. ClassName);
  434. writer.WriteLine(" return ((Builder) CreateBuilder().MergeFrom(input, extensionRegistry)).BuildParsed();");
  435. writer.WriteLine("}");
  436. writer.WriteLine("public static {0} ParseDelimitedFrom(global::System.IO.Stream input) {{", ClassName);
  437. writer.WriteLine(" return CreateBuilder().MergeDelimitedFrom(input).BuildParsed();");
  438. writer.WriteLine("}");
  439. writer.WriteLine(
  440. "public static {0} ParseDelimitedFrom(global::System.IO.Stream input, pb::ExtensionRegistry extensionRegistry) {{",
  441. ClassName);
  442. writer.WriteLine(" return CreateBuilder().MergeDelimitedFrom(input, extensionRegistry).BuildParsed();");
  443. writer.WriteLine("}");
  444. writer.WriteLine("public static {0} ParseFrom(pb::ICodedInputStream input) {{", ClassName);
  445. writer.WriteLine(" return ((Builder) CreateBuilder().MergeFrom(input)).BuildParsed();");
  446. writer.WriteLine("}");
  447. writer.WriteLine(
  448. "public static {0} ParseFrom(pb::ICodedInputStream input, pb::ExtensionRegistry extensionRegistry) {{",
  449. ClassName);
  450. writer.WriteLine(" return ((Builder) CreateBuilder().MergeFrom(input, extensionRegistry)).BuildParsed();");
  451. writer.WriteLine("}");
  452. }
  453. /// <summary>
  454. /// Returns whether or not the specified message type has any required fields.
  455. /// If it doesn't, calls to check for initialization can be optimised.
  456. /// TODO(jonskeet): Move this into MessageDescriptor?
  457. /// </summary>
  458. private static bool HasRequiredFields(MessageDescriptor descriptor,
  459. Dictionary<MessageDescriptor, object> alreadySeen)
  460. {
  461. if (alreadySeen.ContainsKey(descriptor))
  462. {
  463. // The type is already in cache. This means that either:
  464. // a. The type has no required fields.
  465. // b. We are in the midst of checking if the type has required fields,
  466. // somewhere up the stack. In this case, we know that if the type
  467. // has any required fields, they'll be found when we return to it,
  468. // and the whole call to HasRequiredFields() will return true.
  469. // Therefore, we don't have to check if this type has required fields
  470. // here.
  471. return false;
  472. }
  473. alreadySeen[descriptor] = descriptor; // Value is irrelevant
  474. // If the type has extensions, an extension with message type could contain
  475. // required fields, so we have to be conservative and assume such an
  476. // extension exists.
  477. if (descriptor.Extensions.Count > 0)
  478. {
  479. return true;
  480. }
  481. foreach (FieldDescriptor field in descriptor.Fields)
  482. {
  483. if (field.IsRequired)
  484. {
  485. return true;
  486. }
  487. // Message or group
  488. if (field.MappedType == MappedType.Message)
  489. {
  490. if (HasRequiredFields(field.MessageType, alreadySeen))
  491. {
  492. return true;
  493. }
  494. }
  495. }
  496. return false;
  497. }
  498. private void GenerateBuilder(TextGenerator writer)
  499. {
  500. writer.WriteLine("public static Builder CreateBuilder() { return new Builder(); }");
  501. writer.WriteLine("public override Builder ToBuilder() { return CreateBuilder(this); }");
  502. writer.WriteLine("public override Builder CreateBuilderForType() { return new Builder(); }");
  503. writer.WriteLine("public static Builder CreateBuilder({0} prototype) {{", ClassName);
  504. writer.WriteLine(" return (Builder) new Builder().MergeFrom(prototype);");
  505. writer.WriteLine("}");
  506. writer.WriteLine();
  507. writer.WriteLine("[global::System.Diagnostics.DebuggerNonUserCodeAttribute()]");
  508. writer.WriteLine("[global::System.Runtime.CompilerServices.CompilerGeneratedAttribute()]");
  509. writer.WriteLine("[global::System.CodeDom.Compiler.GeneratedCodeAttribute(\"{0}\", \"{1}\")]",
  510. GetType().Assembly.GetName().Name, GetType().Assembly.GetName().Version);
  511. writer.WriteLine("{0} sealed partial class Builder : pb::{2}Builder{3}<{1}, Builder> {{",
  512. ClassAccessLevel, ClassName,
  513. Descriptor.Proto.ExtensionRangeCount > 0 ? "Extendable" : "Generated", RuntimeSuffix);
  514. writer.Indent();
  515. writer.WriteLine("protected override Builder ThisBuilder {");
  516. writer.WriteLine(" get { return this; }");
  517. writer.WriteLine("}");
  518. GenerateCommonBuilderMethods(writer);
  519. if (OptimizeSpeed)
  520. {
  521. GenerateBuilderParsingMethods(writer);
  522. }
  523. foreach (FieldDescriptor field in Descriptor.Fields)
  524. {
  525. writer.WriteLine();
  526. // No field comment :(
  527. CreateFieldGenerator(field).GenerateBuilderMembers(writer);
  528. }
  529. writer.Outdent();
  530. writer.WriteLine("}");
  531. }
  532. private void GenerateCommonBuilderMethods(TextGenerator writer)
  533. {
  534. writer.WriteLine("public Builder() {{}}", ClassAccessLevel);
  535. writer.WriteLine();
  536. writer.WriteLine("{0} result = new {0}();", ClassName);
  537. writer.WriteLine();
  538. writer.WriteLine("protected override {0} MessageBeingBuilt {{", ClassName);
  539. writer.WriteLine(" get { return result; }");
  540. writer.WriteLine("}");
  541. writer.WriteLine();
  542. writer.WriteLine("public override Builder Clear() {");
  543. writer.WriteLine(" result = new {0}();", ClassName);
  544. writer.WriteLine(" return this;");
  545. writer.WriteLine("}");
  546. writer.WriteLine();
  547. writer.WriteLine("public override Builder Clone() {");
  548. writer.WriteLine(" return new Builder().MergeFrom(result);");
  549. writer.WriteLine("}");
  550. writer.WriteLine();
  551. if (!UseLiteRuntime)
  552. {
  553. writer.WriteLine("public override pbd::MessageDescriptor DescriptorForType {");
  554. writer.WriteLine(" get {{ return {0}.Descriptor; }}", FullClassName);
  555. writer.WriteLine("}");
  556. writer.WriteLine();
  557. }
  558. writer.WriteLine("public override {0} DefaultInstanceForType {{", ClassName);
  559. writer.WriteLine(" get {{ return {0}.DefaultInstance; }}", FullClassName);
  560. writer.WriteLine("}");
  561. writer.WriteLine();
  562. writer.WriteLine("public override {0} BuildPartial() {{", ClassName);
  563. writer.Indent();
  564. writer.WriteLine("if (result == null) {");
  565. writer.WriteLine(
  566. " throw new global::System.InvalidOperationException(\"build() has already been called on this Builder\");");
  567. writer.WriteLine("}");
  568. foreach (FieldDescriptor field in Descriptor.Fields)
  569. {
  570. CreateFieldGenerator(field).GenerateBuildingCode(writer);
  571. }
  572. writer.WriteLine("{0} returnMe = result;", ClassName);
  573. writer.WriteLine("result = null;");
  574. writer.WriteLine("return returnMe;");
  575. writer.Outdent();
  576. writer.WriteLine("}");
  577. writer.WriteLine();
  578. if (OptimizeSpeed)
  579. {
  580. writer.WriteLine("public override Builder MergeFrom(pb::IMessage{0} other) {{", RuntimeSuffix);
  581. writer.WriteLine(" if (other is {0}) {{", ClassName);
  582. writer.WriteLine(" return MergeFrom(({0}) other);", ClassName);
  583. writer.WriteLine(" } else {");
  584. writer.WriteLine(" base.MergeFrom(other);");
  585. writer.WriteLine(" return this;");
  586. writer.WriteLine(" }");
  587. writer.WriteLine("}");
  588. writer.WriteLine();
  589. writer.WriteLine("public override Builder MergeFrom({0} other) {{", ClassName);
  590. // Optimization: If other is the default instance, we know none of its
  591. // fields are set so we can skip the merge.
  592. writer.Indent();
  593. writer.WriteLine("if (other == {0}.DefaultInstance) return this;", FullClassName);
  594. foreach (FieldDescriptor field in Descriptor.Fields)
  595. {
  596. CreateFieldGenerator(field).GenerateMergingCode(writer);
  597. }
  598. // if message type has extensions
  599. if (Descriptor.Proto.ExtensionRangeCount > 0)
  600. {
  601. writer.WriteLine(" this.MergeExtensionFields(other);");
  602. }
  603. if (!UseLiteRuntime)
  604. {
  605. writer.WriteLine("this.MergeUnknownFields(other.UnknownFields);");
  606. }
  607. writer.WriteLine("return this;");
  608. writer.Outdent();
  609. writer.WriteLine("}");
  610. writer.WriteLine();
  611. }
  612. }
  613. private void GenerateBuilderParsingMethods(TextGenerator writer)
  614. {
  615. List<FieldDescriptor> sortedFields = new List<FieldDescriptor>(Descriptor.Fields);
  616. sortedFields.Sort((f1, f2) => f1.FieldNumber.CompareTo(f2.FieldNumber));
  617. writer.WriteLine("public override Builder MergeFrom(pb::ICodedInputStream input) {");
  618. writer.WriteLine(" return MergeFrom(input, pb::ExtensionRegistry.Empty);");
  619. writer.WriteLine("}");
  620. writer.WriteLine();
  621. writer.WriteLine(
  622. "public override Builder MergeFrom(pb::ICodedInputStream input, pb::ExtensionRegistry extensionRegistry) {");
  623. writer.Indent();
  624. if (!UseLiteRuntime)
  625. {
  626. writer.WriteLine("pb::UnknownFieldSet.Builder unknownFields = null;");
  627. }
  628. writer.WriteLine("uint tag;");
  629. writer.WriteLine("string field_name;");
  630. writer.WriteLine("while (input.ReadTag(out tag, out field_name)) {");
  631. writer.Indent();
  632. writer.WriteLine("if(tag == 0 && field_name != null) {");
  633. writer.Indent();
  634. //if you change from StringComparer.Ordinal, the array sort in FieldNames { get; } must also change
  635. writer.WriteLine(
  636. "int field_ordinal = global::System.Array.BinarySearch(_{0}FieldNames, field_name, global::System.StringComparer.Ordinal);",
  637. NameHelpers.UnderscoresToCamelCase(ClassName));
  638. writer.WriteLine("if(field_ordinal >= 0)");
  639. writer.WriteLine(" tag = _{0}FieldTags[field_ordinal];", NameHelpers.UnderscoresToCamelCase(ClassName));
  640. writer.WriteLine("else {");
  641. if (!UseLiteRuntime)
  642. {
  643. writer.WriteLine(" if (unknownFields == null) {"); // First unknown field - create builder now
  644. writer.WriteLine(" unknownFields = pb::UnknownFieldSet.CreateBuilder(this.UnknownFields);");
  645. writer.WriteLine(" }");
  646. }
  647. writer.WriteLine(" ParseUnknownField(input, {0}extensionRegistry, tag, field_name);",
  648. UseLiteRuntime ? "" : "unknownFields, ");
  649. writer.WriteLine(" continue;");
  650. writer.WriteLine("}");
  651. writer.Outdent();
  652. writer.WriteLine("}");
  653. writer.WriteLine("switch (tag) {");
  654. writer.Indent();
  655. writer.WriteLine("case 0: {"); // 0 signals EOF / limit reached
  656. writer.WriteLine(" throw pb::InvalidProtocolBufferException.InvalidTag();");
  657. writer.WriteLine("}");
  658. writer.WriteLine("default: {");
  659. writer.WriteLine(" if (pb::WireFormat.IsEndGroupTag(tag)) {");
  660. if (!UseLiteRuntime)
  661. {
  662. writer.WriteLine(" if (unknownFields != null) {");
  663. writer.WriteLine(" this.UnknownFields = unknownFields.Build();");
  664. writer.WriteLine(" }");
  665. }
  666. writer.WriteLine(" return this;"); // it's an endgroup tag
  667. writer.WriteLine(" }");
  668. if (!UseLiteRuntime)
  669. {
  670. writer.WriteLine(" if (unknownFields == null) {"); // First unknown field - create builder now
  671. writer.WriteLine(" unknownFields = pb::UnknownFieldSet.CreateBuilder(this.UnknownFields);");
  672. writer.WriteLine(" }");
  673. }
  674. writer.WriteLine(" ParseUnknownField(input, {0}extensionRegistry, tag, field_name);",
  675. UseLiteRuntime ? "" : "unknownFields, ");
  676. writer.WriteLine(" break;");
  677. writer.WriteLine("}");
  678. foreach (FieldDescriptor field in sortedFields)
  679. {
  680. WireFormat.WireType wt = WireFormat.GetWireType(field.FieldType);
  681. uint tag = WireFormat.MakeTag(field.FieldNumber, wt);
  682. if (field.IsRepeated &&
  683. (wt == WireFormat.WireType.Varint || wt == WireFormat.WireType.Fixed32 ||
  684. wt == WireFormat.WireType.Fixed64))
  685. {
  686. writer.WriteLine("case {0}:",
  687. WireFormat.MakeTag(field.FieldNumber, WireFormat.WireType.LengthDelimited));
  688. }
  689. writer.WriteLine("case {0}: {{", tag);
  690. writer.Indent();
  691. CreateFieldGenerator(field).GenerateParsingCode(writer);
  692. writer.WriteLine("break;");
  693. writer.Outdent();
  694. writer.WriteLine("}");
  695. }
  696. writer.Outdent();
  697. writer.WriteLine("}");
  698. writer.Outdent();
  699. writer.WriteLine("}");
  700. writer.WriteLine();
  701. if (!UseLiteRuntime)
  702. {
  703. writer.WriteLine("if (unknownFields != null) {");
  704. writer.WriteLine(" this.UnknownFields = unknownFields.Build();");
  705. writer.WriteLine("}");
  706. }
  707. writer.WriteLine("return this;");
  708. writer.Outdent();
  709. writer.WriteLine("}");
  710. writer.WriteLine();
  711. }
  712. private void GenerateIsInitialized(TextGenerator writer)
  713. {
  714. writer.WriteLine("public override bool IsInitialized {");
  715. writer.Indent();
  716. writer.WriteLine("get {");
  717. writer.Indent();
  718. // Check that all required fields in this message are set.
  719. // TODO(kenton): We can optimize this when we switch to putting all the
  720. // "has" fields into a single bitfield.
  721. foreach (FieldDescriptor field in Descriptor.Fields)
  722. {
  723. if (field.IsRequired)
  724. {
  725. writer.WriteLine("if (!has{0}) return false;", field.CSharpOptions.PropertyName);
  726. }
  727. }
  728. // Now check that all embedded messages are initialized.
  729. foreach (FieldDescriptor field in Descriptor.Fields)
  730. {
  731. if (field.FieldType != FieldType.Message ||
  732. !HasRequiredFields(field.MessageType, new Dictionary<MessageDescriptor, object>()))
  733. {
  734. continue;
  735. }
  736. string propertyName = NameHelpers.UnderscoresToPascalCase(GetFieldName(field));
  737. if (field.IsRepeated)
  738. {
  739. writer.WriteLine("foreach ({0} element in {1}List) {{", GetClassName(field.MessageType),
  740. propertyName);
  741. writer.WriteLine(" if (!element.IsInitialized) return false;");
  742. writer.WriteLine("}");
  743. }
  744. else if (field.IsOptional)
  745. {
  746. writer.WriteLine("if (Has{0}) {{", propertyName);
  747. writer.WriteLine(" if (!{0}.IsInitialized) return false;", propertyName);
  748. writer.WriteLine("}");
  749. }
  750. else
  751. {
  752. writer.WriteLine("if (!{0}.IsInitialized) return false;", propertyName);
  753. }
  754. }
  755. if (Descriptor.Proto.ExtensionRangeCount > 0)
  756. {
  757. writer.WriteLine("if (!ExtensionsAreInitialized) return false;");
  758. }
  759. writer.WriteLine("return true;");
  760. writer.Outdent();
  761. writer.WriteLine("}");
  762. writer.Outdent();
  763. writer.WriteLine("}");
  764. writer.WriteLine();
  765. }
  766. internal void GenerateExtensionRegistrationCode(TextGenerator writer)
  767. {
  768. foreach (FieldDescriptor extension in Descriptor.Extensions)
  769. {
  770. new ExtensionGenerator(extension).GenerateExtensionRegistrationCode(writer);
  771. }
  772. foreach (MessageDescriptor nestedMessage in Descriptor.NestedTypes)
  773. {
  774. new MessageGenerator(nestedMessage).GenerateExtensionRegistrationCode(writer);
  775. }
  776. }
  777. }
  778. }