Sync.cs 46 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037103810391040104110421043104410451046104710481049105010511052105310541055105610571058105910601061106210631064106510661067106810691070107110721073107410751076107710781079108010811082108310841085108610871088108910901091109210931094109510961097109810991100110111021103110411051106110711081109111011111112111311141115111611171118111911201121112211231124112511261127112811291130113111321133113411351136113711381139114011411142114311441145114611471148114911501151115211531154115511561157115811591160116111621163116411651166116711681169117011711172117311741175117611771178117911801181118211831184118511861187118811891190119111921193119411951196119711981199120012011202120312041205120612071208120912101211121212131214121512161217121812191220122112221223122412251226122712281229123012311232123312341235123612371238123912401241124212431244124512461247124812491250125112521253125412551256125712581259126012611262126312641265126612671268126912701271127212731274127512761277127812791280128112821283128412851286128712881289129012911292129312941295129612971298129913001301130213031304130513061307130813091310131113121313131413151316131713181319132013211322132313241325132613271328132913301331133213331334133513361337133813391340134113421343134413451346134713481349135013511352135313541355135613571358135913601361136213631364136513661367136813691370137113721373137413751376137713781379138013811382138313841385138613871388138913901391139213931394139513961397139813991400140114021403140414051406140714081409141014111412
  1. // Generated by the protocol buffer compiler. DO NOT EDIT!
  2. // source: sync.proto
  3. #pragma warning disable 1591, 0612, 3021
  4. #region Designer generated code
  5. using pb = global::Google.Protobuf;
  6. using pbc = global::Google.Protobuf.Collections;
  7. using pbr = global::Google.Protobuf.Reflection;
  8. using scg = global::System.Collections.Generic;
  9. namespace Protos {
  10. /// <summary>Holder for reflection information generated from sync.proto</summary>
  11. public static partial class SyncReflection {
  12. #region Descriptor
  13. /// <summary>File descriptor for sync.proto</summary>
  14. public static pbr::FileDescriptor Descriptor {
  15. get { return descriptor; }
  16. }
  17. private static pbr::FileDescriptor descriptor;
  18. static SyncReflection() {
  19. byte[] descriptorData = global::System.Convert.FromBase64String(
  20. string.Concat(
  21. "CgpzeW5jLnByb3RvEgZwcm90b3MaDnVzZXJpbmZvLnByb3RvGgxyZXN1bHQu",
  22. "cHJvdG8iEAoOUmVzdG9yZVJlcXVlc3QioQEKD1Jlc3RvcmVSZXNwb25zZRIf",
  23. "CgVVc2VycxgBIAMoCzIQLnByb3Rvcy5Vc2VySW5mbxIMCgRTdGVwGAIgASgE",
  24. "EjEKBXN0YXRlGAMgAygLMiIucHJvdG9zLlJlc3RvcmVSZXNwb25zZS5TdGF0",
  25. "ZUVudHJ5GiwKClN0YXRlRW50cnkSCwoDa2V5GAEgASgJEg0KBXZhbHVlGAIg",
  26. "ASgMOgI4ASJ7CgtTeW5jUmVxdWVzdBIMCgRTdGVwGAEgASgEEi8KBlZhbHVl",
  27. "cxgCIAMoCzIfLnByb3Rvcy5TeW5jUmVxdWVzdC5WYWx1ZXNFbnRyeRotCgtW",
  28. "YWx1ZXNFbnRyeRILCgNrZXkYASABKAkSDQoFdmFsdWUYAiABKAw6AjgBIo0B",
  29. "CgxTeW5jUmVzcG9uc2USDgoGU3RhdHVzGAEgASgIEgwKBFN0ZXAYAiABKAQS",
  30. "MAoGVmFsdWVzGAMgAygLMiAucHJvdG9zLlN5bmNSZXNwb25zZS5WYWx1ZXNF",
  31. "bnRyeRotCgtWYWx1ZXNFbnRyeRILCgNrZXkYASABKAkSDQoFdmFsdWUYAiAB",
  32. "KAw6AjgBInUKCFN5bmNQdXNoEgwKBFN0ZXAYASABKAQSLAoGVmFsdWVzGAIg",
  33. "AygLMhwucHJvdG9zLlN5bmNQdXNoLlZhbHVlc0VudHJ5Gi0KC1ZhbHVlc0Vu",
  34. "dHJ5EgsKA2tleRgBIAEoCRINCgV2YWx1ZRgCIAEoDDoCOAEieQoKTWFzdGVy",
  35. "UHVzaBIMCgRTdGVwGAEgASgEEi4KBlZhbHVlcxgCIAMoCzIeLnByb3Rvcy5N",
  36. "YXN0ZXJQdXNoLlZhbHVlc0VudHJ5Gi0KC1ZhbHVlc0VudHJ5EgsKA2tleRgB",
  37. "IAEoCRINCgV2YWx1ZRgCIAEoDDoCOAEifQoMTWFzdGVyTm90aWZ5EgwKBFN0",
  38. "ZXAYASABKAQSMAoGVmFsdWVzGAIgAygLMiAucHJvdG9zLk1hc3Rlck5vdGlm",
  39. "eS5WYWx1ZXNFbnRyeRotCgtWYWx1ZXNFbnRyeRILCgNrZXkYASABKAkSDQoF",
  40. "dmFsdWUYAiABKAw6AjgBInkKEU1hc3RlclN0b3JlTm90aWZ5EjUKBlZhbHVl",
  41. "cxgBIAMoCzIlLnByb3Rvcy5NYXN0ZXJTdG9yZU5vdGlmeS5WYWx1ZXNFbnRy",
  42. "eRotCgtWYWx1ZXNFbnRyeRILCgNrZXkYASABKAkSDQoFdmFsdWUYAiABKAw6",
  43. "AjgBIhMKEU1hc3RlckxvYWRSZXF1ZXN0IpsBChJNYXN0ZXJMb2FkUmVzcG9u",
  44. "c2USHgoGUmVzdWx0GAEgASgLMg4ucHJvdG9zLlJlc3VsdBI2CgZWYWx1ZXMY",
  45. "AiADKAsyJi5wcm90b3MuTWFzdGVyTG9hZFJlc3BvbnNlLlZhbHVlc0VudHJ5",
  46. "Gi0KC1ZhbHVlc0VudHJ5EgsKA2tleRgBIAEoCRINCgV2YWx1ZRgCIAEoDDoC",
  47. "OAFiBnByb3RvMw=="));
  48. descriptor = pbr::FileDescriptor.FromGeneratedCode(descriptorData,
  49. new pbr::FileDescriptor[] { global::Protos.UserinfoReflection.Descriptor, global::Protos.ResultReflection.Descriptor, },
  50. new pbr::GeneratedClrTypeInfo(null, new pbr::GeneratedClrTypeInfo[] {
  51. new pbr::GeneratedClrTypeInfo(typeof(global::Protos.RestoreRequest), global::Protos.RestoreRequest.Parser, null, null, null, null),
  52. new pbr::GeneratedClrTypeInfo(typeof(global::Protos.RestoreResponse), global::Protos.RestoreResponse.Parser, new[]{ "Users", "Step", "State" }, null, null, new pbr::GeneratedClrTypeInfo[] { null, }),
  53. new pbr::GeneratedClrTypeInfo(typeof(global::Protos.SyncRequest), global::Protos.SyncRequest.Parser, new[]{ "Step", "Values" }, null, null, new pbr::GeneratedClrTypeInfo[] { null, }),
  54. new pbr::GeneratedClrTypeInfo(typeof(global::Protos.SyncResponse), global::Protos.SyncResponse.Parser, new[]{ "Status", "Step", "Values" }, null, null, new pbr::GeneratedClrTypeInfo[] { null, }),
  55. new pbr::GeneratedClrTypeInfo(typeof(global::Protos.SyncPush), global::Protos.SyncPush.Parser, new[]{ "Step", "Values" }, null, null, new pbr::GeneratedClrTypeInfo[] { null, }),
  56. new pbr::GeneratedClrTypeInfo(typeof(global::Protos.MasterPush), global::Protos.MasterPush.Parser, new[]{ "Step", "Values" }, null, null, new pbr::GeneratedClrTypeInfo[] { null, }),
  57. new pbr::GeneratedClrTypeInfo(typeof(global::Protos.MasterNotify), global::Protos.MasterNotify.Parser, new[]{ "Step", "Values" }, null, null, new pbr::GeneratedClrTypeInfo[] { null, }),
  58. new pbr::GeneratedClrTypeInfo(typeof(global::Protos.MasterStoreNotify), global::Protos.MasterStoreNotify.Parser, new[]{ "Values" }, null, null, new pbr::GeneratedClrTypeInfo[] { null, }),
  59. new pbr::GeneratedClrTypeInfo(typeof(global::Protos.MasterLoadRequest), global::Protos.MasterLoadRequest.Parser, null, null, null, null),
  60. new pbr::GeneratedClrTypeInfo(typeof(global::Protos.MasterLoadResponse), global::Protos.MasterLoadResponse.Parser, new[]{ "Result", "Values" }, null, null, new pbr::GeneratedClrTypeInfo[] { null, })
  61. }));
  62. }
  63. #endregion
  64. }
  65. #region Messages
  66. /// <summary>
  67. /// 载入游戏请求
  68. /// </summary>
  69. public sealed partial class RestoreRequest : pb::IMessage<RestoreRequest> {
  70. private static readonly pb::MessageParser<RestoreRequest> _parser = new pb::MessageParser<RestoreRequest>(() => new RestoreRequest());
  71. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  72. public static pb::MessageParser<RestoreRequest> Parser { get { return _parser; } }
  73. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  74. public static pbr::MessageDescriptor Descriptor {
  75. get { return global::Protos.SyncReflection.Descriptor.MessageTypes[0]; }
  76. }
  77. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  78. pbr::MessageDescriptor pb::IMessage.Descriptor {
  79. get { return Descriptor; }
  80. }
  81. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  82. public RestoreRequest() {
  83. OnConstruction();
  84. }
  85. partial void OnConstruction();
  86. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  87. public RestoreRequest(RestoreRequest other) : this() {
  88. }
  89. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  90. public RestoreRequest Clone() {
  91. return new RestoreRequest(this);
  92. }
  93. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  94. public override bool Equals(object other) {
  95. return Equals(other as RestoreRequest);
  96. }
  97. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  98. public bool Equals(RestoreRequest other) {
  99. if (ReferenceEquals(other, null)) {
  100. return false;
  101. }
  102. if (ReferenceEquals(other, this)) {
  103. return true;
  104. }
  105. return true;
  106. }
  107. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  108. public override int GetHashCode() {
  109. int hash = 1;
  110. return hash;
  111. }
  112. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  113. public override string ToString() {
  114. return pb::JsonFormatter.ToDiagnosticString(this);
  115. }
  116. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  117. public void WriteTo(pb::CodedOutputStream output) {
  118. }
  119. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  120. public int CalculateSize() {
  121. int size = 0;
  122. return size;
  123. }
  124. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  125. public void MergeFrom(RestoreRequest other) {
  126. if (other == null) {
  127. return;
  128. }
  129. }
  130. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  131. public void MergeFrom(pb::CodedInputStream input) {
  132. uint tag;
  133. while ((tag = input.ReadTag()) != 0) {
  134. switch(tag) {
  135. default:
  136. input.SkipLastField();
  137. break;
  138. }
  139. }
  140. }
  141. }
  142. /// <summary>
  143. /// 载入游戏响应
  144. /// </summary>
  145. public sealed partial class RestoreResponse : pb::IMessage<RestoreResponse> {
  146. private static readonly pb::MessageParser<RestoreResponse> _parser = new pb::MessageParser<RestoreResponse>(() => new RestoreResponse());
  147. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  148. public static pb::MessageParser<RestoreResponse> Parser { get { return _parser; } }
  149. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  150. public static pbr::MessageDescriptor Descriptor {
  151. get { return global::Protos.SyncReflection.Descriptor.MessageTypes[1]; }
  152. }
  153. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  154. pbr::MessageDescriptor pb::IMessage.Descriptor {
  155. get { return Descriptor; }
  156. }
  157. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  158. public RestoreResponse() {
  159. OnConstruction();
  160. }
  161. partial void OnConstruction();
  162. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  163. public RestoreResponse(RestoreResponse other) : this() {
  164. users_ = other.users_.Clone();
  165. step_ = other.step_;
  166. state_ = other.state_.Clone();
  167. }
  168. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  169. public RestoreResponse Clone() {
  170. return new RestoreResponse(this);
  171. }
  172. /// <summary>Field number for the "Users" field.</summary>
  173. public const int UsersFieldNumber = 1;
  174. private static readonly pb::FieldCodec<global::Protos.UserInfo> _repeated_users_codec
  175. = pb::FieldCodec.ForMessage(10, global::Protos.UserInfo.Parser);
  176. private readonly pbc::RepeatedField<global::Protos.UserInfo> users_ = new pbc::RepeatedField<global::Protos.UserInfo>();
  177. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  178. public pbc::RepeatedField<global::Protos.UserInfo> Users {
  179. get { return users_; }
  180. }
  181. /// <summary>Field number for the "Step" field.</summary>
  182. public const int StepFieldNumber = 2;
  183. private ulong step_;
  184. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  185. public ulong Step {
  186. get { return step_; }
  187. set {
  188. step_ = value;
  189. }
  190. }
  191. /// <summary>Field number for the "state" field.</summary>
  192. public const int StateFieldNumber = 3;
  193. private static readonly pbc::MapField<string, pb::ByteString>.Codec _map_state_codec
  194. = new pbc::MapField<string, pb::ByteString>.Codec(pb::FieldCodec.ForString(10), pb::FieldCodec.ForBytes(18), 26);
  195. private readonly pbc::MapField<string, pb::ByteString> state_ = new pbc::MapField<string, pb::ByteString>();
  196. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  197. public pbc::MapField<string, pb::ByteString> State {
  198. get { return state_; }
  199. }
  200. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  201. public override bool Equals(object other) {
  202. return Equals(other as RestoreResponse);
  203. }
  204. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  205. public bool Equals(RestoreResponse other) {
  206. if (ReferenceEquals(other, null)) {
  207. return false;
  208. }
  209. if (ReferenceEquals(other, this)) {
  210. return true;
  211. }
  212. if(!users_.Equals(other.users_)) return false;
  213. if (Step != other.Step) return false;
  214. if (!State.Equals(other.State)) return false;
  215. return true;
  216. }
  217. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  218. public override int GetHashCode() {
  219. int hash = 1;
  220. hash ^= users_.GetHashCode();
  221. if (Step != 0UL) hash ^= Step.GetHashCode();
  222. hash ^= State.GetHashCode();
  223. return hash;
  224. }
  225. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  226. public override string ToString() {
  227. return pb::JsonFormatter.ToDiagnosticString(this);
  228. }
  229. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  230. public void WriteTo(pb::CodedOutputStream output) {
  231. users_.WriteTo(output, _repeated_users_codec);
  232. if (Step != 0UL) {
  233. output.WriteRawTag(16);
  234. output.WriteUInt64(Step);
  235. }
  236. state_.WriteTo(output, _map_state_codec);
  237. }
  238. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  239. public int CalculateSize() {
  240. int size = 0;
  241. size += users_.CalculateSize(_repeated_users_codec);
  242. if (Step != 0UL) {
  243. size += 1 + pb::CodedOutputStream.ComputeUInt64Size(Step);
  244. }
  245. size += state_.CalculateSize(_map_state_codec);
  246. return size;
  247. }
  248. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  249. public void MergeFrom(RestoreResponse other) {
  250. if (other == null) {
  251. return;
  252. }
  253. users_.Add(other.users_);
  254. if (other.Step != 0UL) {
  255. Step = other.Step;
  256. }
  257. state_.Add(other.state_);
  258. }
  259. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  260. public void MergeFrom(pb::CodedInputStream input) {
  261. uint tag;
  262. while ((tag = input.ReadTag()) != 0) {
  263. switch(tag) {
  264. default:
  265. input.SkipLastField();
  266. break;
  267. case 10: {
  268. users_.AddEntriesFrom(input, _repeated_users_codec);
  269. break;
  270. }
  271. case 16: {
  272. Step = input.ReadUInt64();
  273. break;
  274. }
  275. case 26: {
  276. state_.AddEntriesFrom(input, _map_state_codec);
  277. break;
  278. }
  279. }
  280. }
  281. }
  282. }
  283. /// <summary>
  284. /// 同步消息
  285. /// </summary>
  286. public sealed partial class SyncRequest : pb::IMessage<SyncRequest> {
  287. private static readonly pb::MessageParser<SyncRequest> _parser = new pb::MessageParser<SyncRequest>(() => new SyncRequest());
  288. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  289. public static pb::MessageParser<SyncRequest> Parser { get { return _parser; } }
  290. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  291. public static pbr::MessageDescriptor Descriptor {
  292. get { return global::Protos.SyncReflection.Descriptor.MessageTypes[2]; }
  293. }
  294. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  295. pbr::MessageDescriptor pb::IMessage.Descriptor {
  296. get { return Descriptor; }
  297. }
  298. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  299. public SyncRequest() {
  300. OnConstruction();
  301. }
  302. partial void OnConstruction();
  303. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  304. public SyncRequest(SyncRequest other) : this() {
  305. step_ = other.step_;
  306. values_ = other.values_.Clone();
  307. }
  308. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  309. public SyncRequest Clone() {
  310. return new SyncRequest(this);
  311. }
  312. /// <summary>Field number for the "Step" field.</summary>
  313. public const int StepFieldNumber = 1;
  314. private ulong step_;
  315. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  316. public ulong Step {
  317. get { return step_; }
  318. set {
  319. step_ = value;
  320. }
  321. }
  322. /// <summary>Field number for the "Values" field.</summary>
  323. public const int ValuesFieldNumber = 2;
  324. private static readonly pbc::MapField<string, pb::ByteString>.Codec _map_values_codec
  325. = new pbc::MapField<string, pb::ByteString>.Codec(pb::FieldCodec.ForString(10), pb::FieldCodec.ForBytes(18), 18);
  326. private readonly pbc::MapField<string, pb::ByteString> values_ = new pbc::MapField<string, pb::ByteString>();
  327. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  328. public pbc::MapField<string, pb::ByteString> Values {
  329. get { return values_; }
  330. }
  331. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  332. public override bool Equals(object other) {
  333. return Equals(other as SyncRequest);
  334. }
  335. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  336. public bool Equals(SyncRequest other) {
  337. if (ReferenceEquals(other, null)) {
  338. return false;
  339. }
  340. if (ReferenceEquals(other, this)) {
  341. return true;
  342. }
  343. if (Step != other.Step) return false;
  344. if (!Values.Equals(other.Values)) return false;
  345. return true;
  346. }
  347. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  348. public override int GetHashCode() {
  349. int hash = 1;
  350. if (Step != 0UL) hash ^= Step.GetHashCode();
  351. hash ^= Values.GetHashCode();
  352. return hash;
  353. }
  354. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  355. public override string ToString() {
  356. return pb::JsonFormatter.ToDiagnosticString(this);
  357. }
  358. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  359. public void WriteTo(pb::CodedOutputStream output) {
  360. if (Step != 0UL) {
  361. output.WriteRawTag(8);
  362. output.WriteUInt64(Step);
  363. }
  364. values_.WriteTo(output, _map_values_codec);
  365. }
  366. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  367. public int CalculateSize() {
  368. int size = 0;
  369. if (Step != 0UL) {
  370. size += 1 + pb::CodedOutputStream.ComputeUInt64Size(Step);
  371. }
  372. size += values_.CalculateSize(_map_values_codec);
  373. return size;
  374. }
  375. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  376. public void MergeFrom(SyncRequest other) {
  377. if (other == null) {
  378. return;
  379. }
  380. if (other.Step != 0UL) {
  381. Step = other.Step;
  382. }
  383. values_.Add(other.values_);
  384. }
  385. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  386. public void MergeFrom(pb::CodedInputStream input) {
  387. uint tag;
  388. while ((tag = input.ReadTag()) != 0) {
  389. switch(tag) {
  390. default:
  391. input.SkipLastField();
  392. break;
  393. case 8: {
  394. Step = input.ReadUInt64();
  395. break;
  396. }
  397. case 18: {
  398. values_.AddEntriesFrom(input, _map_values_codec);
  399. break;
  400. }
  401. }
  402. }
  403. }
  404. }
  405. /// <summary>
  406. /// 同步消息响应
  407. /// </summary>
  408. public sealed partial class SyncResponse : pb::IMessage<SyncResponse> {
  409. private static readonly pb::MessageParser<SyncResponse> _parser = new pb::MessageParser<SyncResponse>(() => new SyncResponse());
  410. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  411. public static pb::MessageParser<SyncResponse> Parser { get { return _parser; } }
  412. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  413. public static pbr::MessageDescriptor Descriptor {
  414. get { return global::Protos.SyncReflection.Descriptor.MessageTypes[3]; }
  415. }
  416. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  417. pbr::MessageDescriptor pb::IMessage.Descriptor {
  418. get { return Descriptor; }
  419. }
  420. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  421. public SyncResponse() {
  422. OnConstruction();
  423. }
  424. partial void OnConstruction();
  425. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  426. public SyncResponse(SyncResponse other) : this() {
  427. status_ = other.status_;
  428. step_ = other.step_;
  429. values_ = other.values_.Clone();
  430. }
  431. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  432. public SyncResponse Clone() {
  433. return new SyncResponse(this);
  434. }
  435. /// <summary>Field number for the "Status" field.</summary>
  436. public const int StatusFieldNumber = 1;
  437. private bool status_;
  438. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  439. public bool Status {
  440. get { return status_; }
  441. set {
  442. status_ = value;
  443. }
  444. }
  445. /// <summary>Field number for the "Step" field.</summary>
  446. public const int StepFieldNumber = 2;
  447. private ulong step_;
  448. /// <summary>
  449. /// status=false时才有值
  450. /// </summary>
  451. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  452. public ulong Step {
  453. get { return step_; }
  454. set {
  455. step_ = value;
  456. }
  457. }
  458. /// <summary>Field number for the "Values" field.</summary>
  459. public const int ValuesFieldNumber = 3;
  460. private static readonly pbc::MapField<string, pb::ByteString>.Codec _map_values_codec
  461. = new pbc::MapField<string, pb::ByteString>.Codec(pb::FieldCodec.ForString(10), pb::FieldCodec.ForBytes(18), 26);
  462. private readonly pbc::MapField<string, pb::ByteString> values_ = new pbc::MapField<string, pb::ByteString>();
  463. /// <summary>
  464. /// status=false时才有值
  465. /// </summary>
  466. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  467. public pbc::MapField<string, pb::ByteString> Values {
  468. get { return values_; }
  469. }
  470. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  471. public override bool Equals(object other) {
  472. return Equals(other as SyncResponse);
  473. }
  474. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  475. public bool Equals(SyncResponse other) {
  476. if (ReferenceEquals(other, null)) {
  477. return false;
  478. }
  479. if (ReferenceEquals(other, this)) {
  480. return true;
  481. }
  482. if (Status != other.Status) return false;
  483. if (Step != other.Step) return false;
  484. if (!Values.Equals(other.Values)) return false;
  485. return true;
  486. }
  487. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  488. public override int GetHashCode() {
  489. int hash = 1;
  490. if (Status != false) hash ^= Status.GetHashCode();
  491. if (Step != 0UL) hash ^= Step.GetHashCode();
  492. hash ^= Values.GetHashCode();
  493. return hash;
  494. }
  495. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  496. public override string ToString() {
  497. return pb::JsonFormatter.ToDiagnosticString(this);
  498. }
  499. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  500. public void WriteTo(pb::CodedOutputStream output) {
  501. if (Status != false) {
  502. output.WriteRawTag(8);
  503. output.WriteBool(Status);
  504. }
  505. if (Step != 0UL) {
  506. output.WriteRawTag(16);
  507. output.WriteUInt64(Step);
  508. }
  509. values_.WriteTo(output, _map_values_codec);
  510. }
  511. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  512. public int CalculateSize() {
  513. int size = 0;
  514. if (Status != false) {
  515. size += 1 + 1;
  516. }
  517. if (Step != 0UL) {
  518. size += 1 + pb::CodedOutputStream.ComputeUInt64Size(Step);
  519. }
  520. size += values_.CalculateSize(_map_values_codec);
  521. return size;
  522. }
  523. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  524. public void MergeFrom(SyncResponse other) {
  525. if (other == null) {
  526. return;
  527. }
  528. if (other.Status != false) {
  529. Status = other.Status;
  530. }
  531. if (other.Step != 0UL) {
  532. Step = other.Step;
  533. }
  534. values_.Add(other.values_);
  535. }
  536. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  537. public void MergeFrom(pb::CodedInputStream input) {
  538. uint tag;
  539. while ((tag = input.ReadTag()) != 0) {
  540. switch(tag) {
  541. default:
  542. input.SkipLastField();
  543. break;
  544. case 8: {
  545. Status = input.ReadBool();
  546. break;
  547. }
  548. case 16: {
  549. Step = input.ReadUInt64();
  550. break;
  551. }
  552. case 26: {
  553. values_.AddEntriesFrom(input, _map_values_codec);
  554. break;
  555. }
  556. }
  557. }
  558. }
  559. }
  560. /// <summary>
  561. /// 同步消息推送
  562. /// </summary>
  563. public sealed partial class SyncPush : pb::IMessage<SyncPush> {
  564. private static readonly pb::MessageParser<SyncPush> _parser = new pb::MessageParser<SyncPush>(() => new SyncPush());
  565. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  566. public static pb::MessageParser<SyncPush> Parser { get { return _parser; } }
  567. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  568. public static pbr::MessageDescriptor Descriptor {
  569. get { return global::Protos.SyncReflection.Descriptor.MessageTypes[4]; }
  570. }
  571. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  572. pbr::MessageDescriptor pb::IMessage.Descriptor {
  573. get { return Descriptor; }
  574. }
  575. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  576. public SyncPush() {
  577. OnConstruction();
  578. }
  579. partial void OnConstruction();
  580. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  581. public SyncPush(SyncPush other) : this() {
  582. step_ = other.step_;
  583. values_ = other.values_.Clone();
  584. }
  585. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  586. public SyncPush Clone() {
  587. return new SyncPush(this);
  588. }
  589. /// <summary>Field number for the "Step" field.</summary>
  590. public const int StepFieldNumber = 1;
  591. private ulong step_;
  592. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  593. public ulong Step {
  594. get { return step_; }
  595. set {
  596. step_ = value;
  597. }
  598. }
  599. /// <summary>Field number for the "Values" field.</summary>
  600. public const int ValuesFieldNumber = 2;
  601. private static readonly pbc::MapField<string, pb::ByteString>.Codec _map_values_codec
  602. = new pbc::MapField<string, pb::ByteString>.Codec(pb::FieldCodec.ForString(10), pb::FieldCodec.ForBytes(18), 18);
  603. private readonly pbc::MapField<string, pb::ByteString> values_ = new pbc::MapField<string, pb::ByteString>();
  604. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  605. public pbc::MapField<string, pb::ByteString> Values {
  606. get { return values_; }
  607. }
  608. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  609. public override bool Equals(object other) {
  610. return Equals(other as SyncPush);
  611. }
  612. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  613. public bool Equals(SyncPush other) {
  614. if (ReferenceEquals(other, null)) {
  615. return false;
  616. }
  617. if (ReferenceEquals(other, this)) {
  618. return true;
  619. }
  620. if (Step != other.Step) return false;
  621. if (!Values.Equals(other.Values)) return false;
  622. return true;
  623. }
  624. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  625. public override int GetHashCode() {
  626. int hash = 1;
  627. if (Step != 0UL) hash ^= Step.GetHashCode();
  628. hash ^= Values.GetHashCode();
  629. return hash;
  630. }
  631. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  632. public override string ToString() {
  633. return pb::JsonFormatter.ToDiagnosticString(this);
  634. }
  635. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  636. public void WriteTo(pb::CodedOutputStream output) {
  637. if (Step != 0UL) {
  638. output.WriteRawTag(8);
  639. output.WriteUInt64(Step);
  640. }
  641. values_.WriteTo(output, _map_values_codec);
  642. }
  643. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  644. public int CalculateSize() {
  645. int size = 0;
  646. if (Step != 0UL) {
  647. size += 1 + pb::CodedOutputStream.ComputeUInt64Size(Step);
  648. }
  649. size += values_.CalculateSize(_map_values_codec);
  650. return size;
  651. }
  652. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  653. public void MergeFrom(SyncPush other) {
  654. if (other == null) {
  655. return;
  656. }
  657. if (other.Step != 0UL) {
  658. Step = other.Step;
  659. }
  660. values_.Add(other.values_);
  661. }
  662. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  663. public void MergeFrom(pb::CodedInputStream input) {
  664. uint tag;
  665. while ((tag = input.ReadTag()) != 0) {
  666. switch(tag) {
  667. default:
  668. input.SkipLastField();
  669. break;
  670. case 8: {
  671. Step = input.ReadUInt64();
  672. break;
  673. }
  674. case 18: {
  675. values_.AddEntriesFrom(input, _map_values_codec);
  676. break;
  677. }
  678. }
  679. }
  680. }
  681. }
  682. /// <summary>
  683. /// 服务器合并用户操作给master
  684. /// </summary>
  685. public sealed partial class MasterPush : pb::IMessage<MasterPush> {
  686. private static readonly pb::MessageParser<MasterPush> _parser = new pb::MessageParser<MasterPush>(() => new MasterPush());
  687. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  688. public static pb::MessageParser<MasterPush> Parser { get { return _parser; } }
  689. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  690. public static pbr::MessageDescriptor Descriptor {
  691. get { return global::Protos.SyncReflection.Descriptor.MessageTypes[5]; }
  692. }
  693. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  694. pbr::MessageDescriptor pb::IMessage.Descriptor {
  695. get { return Descriptor; }
  696. }
  697. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  698. public MasterPush() {
  699. OnConstruction();
  700. }
  701. partial void OnConstruction();
  702. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  703. public MasterPush(MasterPush other) : this() {
  704. step_ = other.step_;
  705. values_ = other.values_.Clone();
  706. }
  707. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  708. public MasterPush Clone() {
  709. return new MasterPush(this);
  710. }
  711. /// <summary>Field number for the "Step" field.</summary>
  712. public const int StepFieldNumber = 1;
  713. private ulong step_;
  714. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  715. public ulong Step {
  716. get { return step_; }
  717. set {
  718. step_ = value;
  719. }
  720. }
  721. /// <summary>Field number for the "Values" field.</summary>
  722. public const int ValuesFieldNumber = 2;
  723. private static readonly pbc::MapField<string, pb::ByteString>.Codec _map_values_codec
  724. = new pbc::MapField<string, pb::ByteString>.Codec(pb::FieldCodec.ForString(10), pb::FieldCodec.ForBytes(18), 18);
  725. private readonly pbc::MapField<string, pb::ByteString> values_ = new pbc::MapField<string, pb::ByteString>();
  726. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  727. public pbc::MapField<string, pb::ByteString> Values {
  728. get { return values_; }
  729. }
  730. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  731. public override bool Equals(object other) {
  732. return Equals(other as MasterPush);
  733. }
  734. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  735. public bool Equals(MasterPush other) {
  736. if (ReferenceEquals(other, null)) {
  737. return false;
  738. }
  739. if (ReferenceEquals(other, this)) {
  740. return true;
  741. }
  742. if (Step != other.Step) return false;
  743. if (!Values.Equals(other.Values)) return false;
  744. return true;
  745. }
  746. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  747. public override int GetHashCode() {
  748. int hash = 1;
  749. if (Step != 0UL) hash ^= Step.GetHashCode();
  750. hash ^= Values.GetHashCode();
  751. return hash;
  752. }
  753. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  754. public override string ToString() {
  755. return pb::JsonFormatter.ToDiagnosticString(this);
  756. }
  757. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  758. public void WriteTo(pb::CodedOutputStream output) {
  759. if (Step != 0UL) {
  760. output.WriteRawTag(8);
  761. output.WriteUInt64(Step);
  762. }
  763. values_.WriteTo(output, _map_values_codec);
  764. }
  765. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  766. public int CalculateSize() {
  767. int size = 0;
  768. if (Step != 0UL) {
  769. size += 1 + pb::CodedOutputStream.ComputeUInt64Size(Step);
  770. }
  771. size += values_.CalculateSize(_map_values_codec);
  772. return size;
  773. }
  774. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  775. public void MergeFrom(MasterPush other) {
  776. if (other == null) {
  777. return;
  778. }
  779. if (other.Step != 0UL) {
  780. Step = other.Step;
  781. }
  782. values_.Add(other.values_);
  783. }
  784. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  785. public void MergeFrom(pb::CodedInputStream input) {
  786. uint tag;
  787. while ((tag = input.ReadTag()) != 0) {
  788. switch(tag) {
  789. default:
  790. input.SkipLastField();
  791. break;
  792. case 8: {
  793. Step = input.ReadUInt64();
  794. break;
  795. }
  796. case 18: {
  797. values_.AddEntriesFrom(input, _map_values_codec);
  798. break;
  799. }
  800. }
  801. }
  802. }
  803. }
  804. /// <summary>
  805. /// 主机广播消息给flower
  806. /// </summary>
  807. public sealed partial class MasterNotify : pb::IMessage<MasterNotify> {
  808. private static readonly pb::MessageParser<MasterNotify> _parser = new pb::MessageParser<MasterNotify>(() => new MasterNotify());
  809. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  810. public static pb::MessageParser<MasterNotify> Parser { get { return _parser; } }
  811. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  812. public static pbr::MessageDescriptor Descriptor {
  813. get { return global::Protos.SyncReflection.Descriptor.MessageTypes[6]; }
  814. }
  815. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  816. pbr::MessageDescriptor pb::IMessage.Descriptor {
  817. get { return Descriptor; }
  818. }
  819. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  820. public MasterNotify() {
  821. OnConstruction();
  822. }
  823. partial void OnConstruction();
  824. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  825. public MasterNotify(MasterNotify other) : this() {
  826. step_ = other.step_;
  827. values_ = other.values_.Clone();
  828. }
  829. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  830. public MasterNotify Clone() {
  831. return new MasterNotify(this);
  832. }
  833. /// <summary>Field number for the "Step" field.</summary>
  834. public const int StepFieldNumber = 1;
  835. private ulong step_;
  836. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  837. public ulong Step {
  838. get { return step_; }
  839. set {
  840. step_ = value;
  841. }
  842. }
  843. /// <summary>Field number for the "Values" field.</summary>
  844. public const int ValuesFieldNumber = 2;
  845. private static readonly pbc::MapField<string, pb::ByteString>.Codec _map_values_codec
  846. = new pbc::MapField<string, pb::ByteString>.Codec(pb::FieldCodec.ForString(10), pb::FieldCodec.ForBytes(18), 18);
  847. private readonly pbc::MapField<string, pb::ByteString> values_ = new pbc::MapField<string, pb::ByteString>();
  848. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  849. public pbc::MapField<string, pb::ByteString> Values {
  850. get { return values_; }
  851. }
  852. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  853. public override bool Equals(object other) {
  854. return Equals(other as MasterNotify);
  855. }
  856. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  857. public bool Equals(MasterNotify other) {
  858. if (ReferenceEquals(other, null)) {
  859. return false;
  860. }
  861. if (ReferenceEquals(other, this)) {
  862. return true;
  863. }
  864. if (Step != other.Step) return false;
  865. if (!Values.Equals(other.Values)) return false;
  866. return true;
  867. }
  868. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  869. public override int GetHashCode() {
  870. int hash = 1;
  871. if (Step != 0UL) hash ^= Step.GetHashCode();
  872. hash ^= Values.GetHashCode();
  873. return hash;
  874. }
  875. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  876. public override string ToString() {
  877. return pb::JsonFormatter.ToDiagnosticString(this);
  878. }
  879. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  880. public void WriteTo(pb::CodedOutputStream output) {
  881. if (Step != 0UL) {
  882. output.WriteRawTag(8);
  883. output.WriteUInt64(Step);
  884. }
  885. values_.WriteTo(output, _map_values_codec);
  886. }
  887. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  888. public int CalculateSize() {
  889. int size = 0;
  890. if (Step != 0UL) {
  891. size += 1 + pb::CodedOutputStream.ComputeUInt64Size(Step);
  892. }
  893. size += values_.CalculateSize(_map_values_codec);
  894. return size;
  895. }
  896. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  897. public void MergeFrom(MasterNotify other) {
  898. if (other == null) {
  899. return;
  900. }
  901. if (other.Step != 0UL) {
  902. Step = other.Step;
  903. }
  904. values_.Add(other.values_);
  905. }
  906. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  907. public void MergeFrom(pb::CodedInputStream input) {
  908. uint tag;
  909. while ((tag = input.ReadTag()) != 0) {
  910. switch(tag) {
  911. default:
  912. input.SkipLastField();
  913. break;
  914. case 8: {
  915. Step = input.ReadUInt64();
  916. break;
  917. }
  918. case 18: {
  919. values_.AddEntriesFrom(input, _map_values_codec);
  920. break;
  921. }
  922. }
  923. }
  924. }
  925. }
  926. /// <summary>
  927. /// 主机存储状态
  928. /// </summary>
  929. public sealed partial class MasterStoreNotify : pb::IMessage<MasterStoreNotify> {
  930. private static readonly pb::MessageParser<MasterStoreNotify> _parser = new pb::MessageParser<MasterStoreNotify>(() => new MasterStoreNotify());
  931. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  932. public static pb::MessageParser<MasterStoreNotify> Parser { get { return _parser; } }
  933. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  934. public static pbr::MessageDescriptor Descriptor {
  935. get { return global::Protos.SyncReflection.Descriptor.MessageTypes[7]; }
  936. }
  937. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  938. pbr::MessageDescriptor pb::IMessage.Descriptor {
  939. get { return Descriptor; }
  940. }
  941. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  942. public MasterStoreNotify() {
  943. OnConstruction();
  944. }
  945. partial void OnConstruction();
  946. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  947. public MasterStoreNotify(MasterStoreNotify other) : this() {
  948. values_ = other.values_.Clone();
  949. }
  950. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  951. public MasterStoreNotify Clone() {
  952. return new MasterStoreNotify(this);
  953. }
  954. /// <summary>Field number for the "Values" field.</summary>
  955. public const int ValuesFieldNumber = 1;
  956. private static readonly pbc::MapField<string, pb::ByteString>.Codec _map_values_codec
  957. = new pbc::MapField<string, pb::ByteString>.Codec(pb::FieldCodec.ForString(10), pb::FieldCodec.ForBytes(18), 10);
  958. private readonly pbc::MapField<string, pb::ByteString> values_ = new pbc::MapField<string, pb::ByteString>();
  959. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  960. public pbc::MapField<string, pb::ByteString> Values {
  961. get { return values_; }
  962. }
  963. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  964. public override bool Equals(object other) {
  965. return Equals(other as MasterStoreNotify);
  966. }
  967. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  968. public bool Equals(MasterStoreNotify other) {
  969. if (ReferenceEquals(other, null)) {
  970. return false;
  971. }
  972. if (ReferenceEquals(other, this)) {
  973. return true;
  974. }
  975. if (!Values.Equals(other.Values)) return false;
  976. return true;
  977. }
  978. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  979. public override int GetHashCode() {
  980. int hash = 1;
  981. hash ^= Values.GetHashCode();
  982. return hash;
  983. }
  984. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  985. public override string ToString() {
  986. return pb::JsonFormatter.ToDiagnosticString(this);
  987. }
  988. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  989. public void WriteTo(pb::CodedOutputStream output) {
  990. values_.WriteTo(output, _map_values_codec);
  991. }
  992. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  993. public int CalculateSize() {
  994. int size = 0;
  995. size += values_.CalculateSize(_map_values_codec);
  996. return size;
  997. }
  998. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  999. public void MergeFrom(MasterStoreNotify other) {
  1000. if (other == null) {
  1001. return;
  1002. }
  1003. values_.Add(other.values_);
  1004. }
  1005. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  1006. public void MergeFrom(pb::CodedInputStream input) {
  1007. uint tag;
  1008. while ((tag = input.ReadTag()) != 0) {
  1009. switch(tag) {
  1010. default:
  1011. input.SkipLastField();
  1012. break;
  1013. case 10: {
  1014. values_.AddEntriesFrom(input, _map_values_codec);
  1015. break;
  1016. }
  1017. }
  1018. }
  1019. }
  1020. }
  1021. /// <summary>
  1022. /// 主机读取状态
  1023. /// </summary>
  1024. public sealed partial class MasterLoadRequest : pb::IMessage<MasterLoadRequest> {
  1025. private static readonly pb::MessageParser<MasterLoadRequest> _parser = new pb::MessageParser<MasterLoadRequest>(() => new MasterLoadRequest());
  1026. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  1027. public static pb::MessageParser<MasterLoadRequest> Parser { get { return _parser; } }
  1028. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  1029. public static pbr::MessageDescriptor Descriptor {
  1030. get { return global::Protos.SyncReflection.Descriptor.MessageTypes[8]; }
  1031. }
  1032. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  1033. pbr::MessageDescriptor pb::IMessage.Descriptor {
  1034. get { return Descriptor; }
  1035. }
  1036. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  1037. public MasterLoadRequest() {
  1038. OnConstruction();
  1039. }
  1040. partial void OnConstruction();
  1041. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  1042. public MasterLoadRequest(MasterLoadRequest other) : this() {
  1043. }
  1044. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  1045. public MasterLoadRequest Clone() {
  1046. return new MasterLoadRequest(this);
  1047. }
  1048. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  1049. public override bool Equals(object other) {
  1050. return Equals(other as MasterLoadRequest);
  1051. }
  1052. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  1053. public bool Equals(MasterLoadRequest other) {
  1054. if (ReferenceEquals(other, null)) {
  1055. return false;
  1056. }
  1057. if (ReferenceEquals(other, this)) {
  1058. return true;
  1059. }
  1060. return true;
  1061. }
  1062. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  1063. public override int GetHashCode() {
  1064. int hash = 1;
  1065. return hash;
  1066. }
  1067. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  1068. public override string ToString() {
  1069. return pb::JsonFormatter.ToDiagnosticString(this);
  1070. }
  1071. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  1072. public void WriteTo(pb::CodedOutputStream output) {
  1073. }
  1074. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  1075. public int CalculateSize() {
  1076. int size = 0;
  1077. return size;
  1078. }
  1079. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  1080. public void MergeFrom(MasterLoadRequest other) {
  1081. if (other == null) {
  1082. return;
  1083. }
  1084. }
  1085. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  1086. public void MergeFrom(pb::CodedInputStream input) {
  1087. uint tag;
  1088. while ((tag = input.ReadTag()) != 0) {
  1089. switch(tag) {
  1090. default:
  1091. input.SkipLastField();
  1092. break;
  1093. }
  1094. }
  1095. }
  1096. }
  1097. /// <summary>
  1098. /// 同步消息响应
  1099. /// </summary>
  1100. public sealed partial class MasterLoadResponse : pb::IMessage<MasterLoadResponse> {
  1101. private static readonly pb::MessageParser<MasterLoadResponse> _parser = new pb::MessageParser<MasterLoadResponse>(() => new MasterLoadResponse());
  1102. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  1103. public static pb::MessageParser<MasterLoadResponse> Parser { get { return _parser; } }
  1104. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  1105. public static pbr::MessageDescriptor Descriptor {
  1106. get { return global::Protos.SyncReflection.Descriptor.MessageTypes[9]; }
  1107. }
  1108. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  1109. pbr::MessageDescriptor pb::IMessage.Descriptor {
  1110. get { return Descriptor; }
  1111. }
  1112. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  1113. public MasterLoadResponse() {
  1114. OnConstruction();
  1115. }
  1116. partial void OnConstruction();
  1117. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  1118. public MasterLoadResponse(MasterLoadResponse other) : this() {
  1119. Result = other.result_ != null ? other.Result.Clone() : null;
  1120. values_ = other.values_.Clone();
  1121. }
  1122. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  1123. public MasterLoadResponse Clone() {
  1124. return new MasterLoadResponse(this);
  1125. }
  1126. /// <summary>Field number for the "Result" field.</summary>
  1127. public const int ResultFieldNumber = 1;
  1128. private global::Protos.Result result_;
  1129. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  1130. public global::Protos.Result Result {
  1131. get { return result_; }
  1132. set {
  1133. result_ = value;
  1134. }
  1135. }
  1136. /// <summary>Field number for the "Values" field.</summary>
  1137. public const int ValuesFieldNumber = 2;
  1138. private static readonly pbc::MapField<string, pb::ByteString>.Codec _map_values_codec
  1139. = new pbc::MapField<string, pb::ByteString>.Codec(pb::FieldCodec.ForString(10), pb::FieldCodec.ForBytes(18), 18);
  1140. private readonly pbc::MapField<string, pb::ByteString> values_ = new pbc::MapField<string, pb::ByteString>();
  1141. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  1142. public pbc::MapField<string, pb::ByteString> Values {
  1143. get { return values_; }
  1144. }
  1145. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  1146. public override bool Equals(object other) {
  1147. return Equals(other as MasterLoadResponse);
  1148. }
  1149. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  1150. public bool Equals(MasterLoadResponse other) {
  1151. if (ReferenceEquals(other, null)) {
  1152. return false;
  1153. }
  1154. if (ReferenceEquals(other, this)) {
  1155. return true;
  1156. }
  1157. if (!object.Equals(Result, other.Result)) return false;
  1158. if (!Values.Equals(other.Values)) return false;
  1159. return true;
  1160. }
  1161. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  1162. public override int GetHashCode() {
  1163. int hash = 1;
  1164. if (result_ != null) hash ^= Result.GetHashCode();
  1165. hash ^= Values.GetHashCode();
  1166. return hash;
  1167. }
  1168. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  1169. public override string ToString() {
  1170. return pb::JsonFormatter.ToDiagnosticString(this);
  1171. }
  1172. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  1173. public void WriteTo(pb::CodedOutputStream output) {
  1174. if (result_ != null) {
  1175. output.WriteRawTag(10);
  1176. output.WriteMessage(Result);
  1177. }
  1178. values_.WriteTo(output, _map_values_codec);
  1179. }
  1180. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  1181. public int CalculateSize() {
  1182. int size = 0;
  1183. if (result_ != null) {
  1184. size += 1 + pb::CodedOutputStream.ComputeMessageSize(Result);
  1185. }
  1186. size += values_.CalculateSize(_map_values_codec);
  1187. return size;
  1188. }
  1189. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  1190. public void MergeFrom(MasterLoadResponse other) {
  1191. if (other == null) {
  1192. return;
  1193. }
  1194. if (other.result_ != null) {
  1195. if (result_ == null) {
  1196. result_ = new global::Protos.Result();
  1197. }
  1198. Result.MergeFrom(other.Result);
  1199. }
  1200. values_.Add(other.values_);
  1201. }
  1202. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  1203. public void MergeFrom(pb::CodedInputStream input) {
  1204. uint tag;
  1205. while ((tag = input.ReadTag()) != 0) {
  1206. switch(tag) {
  1207. default:
  1208. input.SkipLastField();
  1209. break;
  1210. case 10: {
  1211. if (result_ == null) {
  1212. result_ = new global::Protos.Result();
  1213. }
  1214. input.ReadMessage(result_);
  1215. break;
  1216. }
  1217. case 18: {
  1218. values_.AddEntriesFrom(input, _map_values_codec);
  1219. break;
  1220. }
  1221. }
  1222. }
  1223. }
  1224. }
  1225. #endregion
  1226. }
  1227. #endregion Designer generated code