Sync.cs 34 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037103810391040104110421043104410451046104710481049105010511052
  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. "CgpzeW5jLnByb3RvEgZwcm90b3MaDnVzZXJpbmZvLnByb3RvIhAKDlJlc3Rv",
  22. "cmVSZXF1ZXN0IqEBCg9SZXN0b3JlUmVzcG9uc2USHwoFVXNlcnMYASADKAsy",
  23. "EC5wcm90b3MuVXNlckluZm8SDAoEU3RlcBgCIAEoBBIxCgVzdGF0ZRgDIAMo",
  24. "CzIiLnByb3Rvcy5SZXN0b3JlUmVzcG9uc2UuU3RhdGVFbnRyeRosCgpTdGF0",
  25. "ZUVudHJ5EgsKA2tleRgBIAEoCRINCgV2YWx1ZRgCIAEoDDoCOAEiewoLU3lu",
  26. "Y1JlcXVlc3QSDAoEU3RlcBgBIAEoBBIvCgZWYWx1ZXMYAiADKAsyHy5wcm90",
  27. "b3MuU3luY1JlcXVlc3QuVmFsdWVzRW50cnkaLQoLVmFsdWVzRW50cnkSCwoD",
  28. "a2V5GAEgASgJEg0KBXZhbHVlGAIgASgMOgI4ASKNAQoMU3luY1Jlc3BvbnNl",
  29. "Eg4KBlN0YXR1cxgBIAEoCBIMCgRTdGVwGAIgASgEEjAKBlZhbHVlcxgDIAMo",
  30. "CzIgLnByb3Rvcy5TeW5jUmVzcG9uc2UuVmFsdWVzRW50cnkaLQoLVmFsdWVz",
  31. "RW50cnkSCwoDa2V5GAEgASgJEg0KBXZhbHVlGAIgASgMOgI4ASJ1CghTeW5j",
  32. "UHVzaBIMCgRTdGVwGAEgASgEEiwKBlZhbHVlcxgCIAMoCzIcLnByb3Rvcy5T",
  33. "eW5jUHVzaC5WYWx1ZXNFbnRyeRotCgtWYWx1ZXNFbnRyeRILCgNrZXkYASAB",
  34. "KAkSDQoFdmFsdWUYAiABKAw6AjgBInkKCk1hc3RlclB1c2gSDAoEU3RlcBgB",
  35. "IAEoBBIuCgZWYWx1ZXMYAiADKAsyHi5wcm90b3MuTWFzdGVyUHVzaC5WYWx1",
  36. "ZXNFbnRyeRotCgtWYWx1ZXNFbnRyeRILCgNrZXkYASABKAkSDQoFdmFsdWUY",
  37. "AiABKAw6AjgBIn0KDE1hc3Rlck5vdGlmeRIMCgRTdGVwGAEgASgEEjAKBlZh",
  38. "bHVlcxgCIAMoCzIgLnByb3Rvcy5NYXN0ZXJOb3RpZnkuVmFsdWVzRW50cnka",
  39. "LQoLVmFsdWVzRW50cnkSCwoDa2V5GAEgASgJEg0KBXZhbHVlGAIgASgMOgI4",
  40. "AWIGcHJvdG8z"));
  41. descriptor = pbr::FileDescriptor.FromGeneratedCode(descriptorData,
  42. new pbr::FileDescriptor[] { global::Protos.UserinfoReflection.Descriptor, },
  43. new pbr::GeneratedClrTypeInfo(null, new pbr::GeneratedClrTypeInfo[] {
  44. new pbr::GeneratedClrTypeInfo(typeof(global::Protos.RestoreRequest), global::Protos.RestoreRequest.Parser, null, null, null, null),
  45. new pbr::GeneratedClrTypeInfo(typeof(global::Protos.RestoreResponse), global::Protos.RestoreResponse.Parser, new[]{ "Users", "Step", "State" }, null, null, new pbr::GeneratedClrTypeInfo[] { null, }),
  46. new pbr::GeneratedClrTypeInfo(typeof(global::Protos.SyncRequest), global::Protos.SyncRequest.Parser, new[]{ "Step", "Values" }, null, null, new pbr::GeneratedClrTypeInfo[] { null, }),
  47. new pbr::GeneratedClrTypeInfo(typeof(global::Protos.SyncResponse), global::Protos.SyncResponse.Parser, new[]{ "Status", "Step", "Values" }, null, null, new pbr::GeneratedClrTypeInfo[] { null, }),
  48. new pbr::GeneratedClrTypeInfo(typeof(global::Protos.SyncPush), global::Protos.SyncPush.Parser, new[]{ "Step", "Values" }, null, null, new pbr::GeneratedClrTypeInfo[] { null, }),
  49. new pbr::GeneratedClrTypeInfo(typeof(global::Protos.MasterPush), global::Protos.MasterPush.Parser, new[]{ "Step", "Values" }, null, null, new pbr::GeneratedClrTypeInfo[] { null, }),
  50. new pbr::GeneratedClrTypeInfo(typeof(global::Protos.MasterNotify), global::Protos.MasterNotify.Parser, new[]{ "Step", "Values" }, null, null, new pbr::GeneratedClrTypeInfo[] { null, })
  51. }));
  52. }
  53. #endregion
  54. }
  55. #region Messages
  56. /// <summary>
  57. /// 载入游戏请求
  58. /// </summary>
  59. public sealed partial class RestoreRequest : pb::IMessage<RestoreRequest> {
  60. private static readonly pb::MessageParser<RestoreRequest> _parser = new pb::MessageParser<RestoreRequest>(() => new RestoreRequest());
  61. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  62. public static pb::MessageParser<RestoreRequest> Parser { get { return _parser; } }
  63. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  64. public static pbr::MessageDescriptor Descriptor {
  65. get { return global::Protos.SyncReflection.Descriptor.MessageTypes[0]; }
  66. }
  67. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  68. pbr::MessageDescriptor pb::IMessage.Descriptor {
  69. get { return Descriptor; }
  70. }
  71. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  72. public RestoreRequest() {
  73. OnConstruction();
  74. }
  75. partial void OnConstruction();
  76. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  77. public RestoreRequest(RestoreRequest other) : this() {
  78. }
  79. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  80. public RestoreRequest Clone() {
  81. return new RestoreRequest(this);
  82. }
  83. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  84. public override bool Equals(object other) {
  85. return Equals(other as RestoreRequest);
  86. }
  87. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  88. public bool Equals(RestoreRequest other) {
  89. if (ReferenceEquals(other, null)) {
  90. return false;
  91. }
  92. if (ReferenceEquals(other, this)) {
  93. return true;
  94. }
  95. return true;
  96. }
  97. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  98. public override int GetHashCode() {
  99. int hash = 1;
  100. return hash;
  101. }
  102. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  103. public override string ToString() {
  104. return pb::JsonFormatter.ToDiagnosticString(this);
  105. }
  106. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  107. public void WriteTo(pb::CodedOutputStream output) {
  108. }
  109. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  110. public int CalculateSize() {
  111. int size = 0;
  112. return size;
  113. }
  114. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  115. public void MergeFrom(RestoreRequest other) {
  116. if (other == null) {
  117. return;
  118. }
  119. }
  120. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  121. public void MergeFrom(pb::CodedInputStream input) {
  122. uint tag;
  123. while ((tag = input.ReadTag()) != 0) {
  124. switch(tag) {
  125. default:
  126. input.SkipLastField();
  127. break;
  128. }
  129. }
  130. }
  131. }
  132. /// <summary>
  133. /// 载入游戏响应
  134. /// </summary>
  135. public sealed partial class RestoreResponse : pb::IMessage<RestoreResponse> {
  136. private static readonly pb::MessageParser<RestoreResponse> _parser = new pb::MessageParser<RestoreResponse>(() => new RestoreResponse());
  137. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  138. public static pb::MessageParser<RestoreResponse> Parser { get { return _parser; } }
  139. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  140. public static pbr::MessageDescriptor Descriptor {
  141. get { return global::Protos.SyncReflection.Descriptor.MessageTypes[1]; }
  142. }
  143. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  144. pbr::MessageDescriptor pb::IMessage.Descriptor {
  145. get { return Descriptor; }
  146. }
  147. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  148. public RestoreResponse() {
  149. OnConstruction();
  150. }
  151. partial void OnConstruction();
  152. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  153. public RestoreResponse(RestoreResponse other) : this() {
  154. users_ = other.users_.Clone();
  155. step_ = other.step_;
  156. state_ = other.state_.Clone();
  157. }
  158. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  159. public RestoreResponse Clone() {
  160. return new RestoreResponse(this);
  161. }
  162. /// <summary>Field number for the "Users" field.</summary>
  163. public const int UsersFieldNumber = 1;
  164. private static readonly pb::FieldCodec<global::Protos.UserInfo> _repeated_users_codec
  165. = pb::FieldCodec.ForMessage(10, global::Protos.UserInfo.Parser);
  166. private readonly pbc::RepeatedField<global::Protos.UserInfo> users_ = new pbc::RepeatedField<global::Protos.UserInfo>();
  167. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  168. public pbc::RepeatedField<global::Protos.UserInfo> Users {
  169. get { return users_; }
  170. }
  171. /// <summary>Field number for the "Step" field.</summary>
  172. public const int StepFieldNumber = 2;
  173. private ulong step_;
  174. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  175. public ulong Step {
  176. get { return step_; }
  177. set {
  178. step_ = value;
  179. }
  180. }
  181. /// <summary>Field number for the "state" field.</summary>
  182. public const int StateFieldNumber = 3;
  183. private static readonly pbc::MapField<string, pb::ByteString>.Codec _map_state_codec
  184. = new pbc::MapField<string, pb::ByteString>.Codec(pb::FieldCodec.ForString(10), pb::FieldCodec.ForBytes(18), 26);
  185. private readonly pbc::MapField<string, pb::ByteString> state_ = new pbc::MapField<string, pb::ByteString>();
  186. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  187. public pbc::MapField<string, pb::ByteString> State {
  188. get { return state_; }
  189. }
  190. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  191. public override bool Equals(object other) {
  192. return Equals(other as RestoreResponse);
  193. }
  194. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  195. public bool Equals(RestoreResponse other) {
  196. if (ReferenceEquals(other, null)) {
  197. return false;
  198. }
  199. if (ReferenceEquals(other, this)) {
  200. return true;
  201. }
  202. if(!users_.Equals(other.users_)) return false;
  203. if (Step != other.Step) return false;
  204. if (!State.Equals(other.State)) return false;
  205. return true;
  206. }
  207. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  208. public override int GetHashCode() {
  209. int hash = 1;
  210. hash ^= users_.GetHashCode();
  211. if (Step != 0UL) hash ^= Step.GetHashCode();
  212. hash ^= State.GetHashCode();
  213. return hash;
  214. }
  215. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  216. public override string ToString() {
  217. return pb::JsonFormatter.ToDiagnosticString(this);
  218. }
  219. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  220. public void WriteTo(pb::CodedOutputStream output) {
  221. users_.WriteTo(output, _repeated_users_codec);
  222. if (Step != 0UL) {
  223. output.WriteRawTag(16);
  224. output.WriteUInt64(Step);
  225. }
  226. state_.WriteTo(output, _map_state_codec);
  227. }
  228. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  229. public int CalculateSize() {
  230. int size = 0;
  231. size += users_.CalculateSize(_repeated_users_codec);
  232. if (Step != 0UL) {
  233. size += 1 + pb::CodedOutputStream.ComputeUInt64Size(Step);
  234. }
  235. size += state_.CalculateSize(_map_state_codec);
  236. return size;
  237. }
  238. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  239. public void MergeFrom(RestoreResponse other) {
  240. if (other == null) {
  241. return;
  242. }
  243. users_.Add(other.users_);
  244. if (other.Step != 0UL) {
  245. Step = other.Step;
  246. }
  247. state_.Add(other.state_);
  248. }
  249. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  250. public void MergeFrom(pb::CodedInputStream input) {
  251. uint tag;
  252. while ((tag = input.ReadTag()) != 0) {
  253. switch(tag) {
  254. default:
  255. input.SkipLastField();
  256. break;
  257. case 10: {
  258. users_.AddEntriesFrom(input, _repeated_users_codec);
  259. break;
  260. }
  261. case 16: {
  262. Step = input.ReadUInt64();
  263. break;
  264. }
  265. case 26: {
  266. state_.AddEntriesFrom(input, _map_state_codec);
  267. break;
  268. }
  269. }
  270. }
  271. }
  272. }
  273. /// <summary>
  274. /// 同步消息
  275. /// </summary>
  276. public sealed partial class SyncRequest : pb::IMessage<SyncRequest> {
  277. private static readonly pb::MessageParser<SyncRequest> _parser = new pb::MessageParser<SyncRequest>(() => new SyncRequest());
  278. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  279. public static pb::MessageParser<SyncRequest> Parser { get { return _parser; } }
  280. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  281. public static pbr::MessageDescriptor Descriptor {
  282. get { return global::Protos.SyncReflection.Descriptor.MessageTypes[2]; }
  283. }
  284. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  285. pbr::MessageDescriptor pb::IMessage.Descriptor {
  286. get { return Descriptor; }
  287. }
  288. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  289. public SyncRequest() {
  290. OnConstruction();
  291. }
  292. partial void OnConstruction();
  293. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  294. public SyncRequest(SyncRequest other) : this() {
  295. step_ = other.step_;
  296. values_ = other.values_.Clone();
  297. }
  298. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  299. public SyncRequest Clone() {
  300. return new SyncRequest(this);
  301. }
  302. /// <summary>Field number for the "Step" field.</summary>
  303. public const int StepFieldNumber = 1;
  304. private ulong step_;
  305. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  306. public ulong Step {
  307. get { return step_; }
  308. set {
  309. step_ = value;
  310. }
  311. }
  312. /// <summary>Field number for the "Values" field.</summary>
  313. public const int ValuesFieldNumber = 2;
  314. private static readonly pbc::MapField<string, pb::ByteString>.Codec _map_values_codec
  315. = new pbc::MapField<string, pb::ByteString>.Codec(pb::FieldCodec.ForString(10), pb::FieldCodec.ForBytes(18), 18);
  316. private readonly pbc::MapField<string, pb::ByteString> values_ = new pbc::MapField<string, pb::ByteString>();
  317. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  318. public pbc::MapField<string, pb::ByteString> Values {
  319. get { return values_; }
  320. }
  321. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  322. public override bool Equals(object other) {
  323. return Equals(other as SyncRequest);
  324. }
  325. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  326. public bool Equals(SyncRequest other) {
  327. if (ReferenceEquals(other, null)) {
  328. return false;
  329. }
  330. if (ReferenceEquals(other, this)) {
  331. return true;
  332. }
  333. if (Step != other.Step) return false;
  334. if (!Values.Equals(other.Values)) return false;
  335. return true;
  336. }
  337. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  338. public override int GetHashCode() {
  339. int hash = 1;
  340. if (Step != 0UL) hash ^= Step.GetHashCode();
  341. hash ^= Values.GetHashCode();
  342. return hash;
  343. }
  344. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  345. public override string ToString() {
  346. return pb::JsonFormatter.ToDiagnosticString(this);
  347. }
  348. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  349. public void WriteTo(pb::CodedOutputStream output) {
  350. if (Step != 0UL) {
  351. output.WriteRawTag(8);
  352. output.WriteUInt64(Step);
  353. }
  354. values_.WriteTo(output, _map_values_codec);
  355. }
  356. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  357. public int CalculateSize() {
  358. int size = 0;
  359. if (Step != 0UL) {
  360. size += 1 + pb::CodedOutputStream.ComputeUInt64Size(Step);
  361. }
  362. size += values_.CalculateSize(_map_values_codec);
  363. return size;
  364. }
  365. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  366. public void MergeFrom(SyncRequest other) {
  367. if (other == null) {
  368. return;
  369. }
  370. if (other.Step != 0UL) {
  371. Step = other.Step;
  372. }
  373. values_.Add(other.values_);
  374. }
  375. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  376. public void MergeFrom(pb::CodedInputStream input) {
  377. uint tag;
  378. while ((tag = input.ReadTag()) != 0) {
  379. switch(tag) {
  380. default:
  381. input.SkipLastField();
  382. break;
  383. case 8: {
  384. Step = input.ReadUInt64();
  385. break;
  386. }
  387. case 18: {
  388. values_.AddEntriesFrom(input, _map_values_codec);
  389. break;
  390. }
  391. }
  392. }
  393. }
  394. }
  395. /// <summary>
  396. /// 同步消息响应
  397. /// </summary>
  398. public sealed partial class SyncResponse : pb::IMessage<SyncResponse> {
  399. private static readonly pb::MessageParser<SyncResponse> _parser = new pb::MessageParser<SyncResponse>(() => new SyncResponse());
  400. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  401. public static pb::MessageParser<SyncResponse> Parser { get { return _parser; } }
  402. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  403. public static pbr::MessageDescriptor Descriptor {
  404. get { return global::Protos.SyncReflection.Descriptor.MessageTypes[3]; }
  405. }
  406. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  407. pbr::MessageDescriptor pb::IMessage.Descriptor {
  408. get { return Descriptor; }
  409. }
  410. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  411. public SyncResponse() {
  412. OnConstruction();
  413. }
  414. partial void OnConstruction();
  415. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  416. public SyncResponse(SyncResponse other) : this() {
  417. status_ = other.status_;
  418. step_ = other.step_;
  419. values_ = other.values_.Clone();
  420. }
  421. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  422. public SyncResponse Clone() {
  423. return new SyncResponse(this);
  424. }
  425. /// <summary>Field number for the "Status" field.</summary>
  426. public const int StatusFieldNumber = 1;
  427. private bool status_;
  428. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  429. public bool Status {
  430. get { return status_; }
  431. set {
  432. status_ = value;
  433. }
  434. }
  435. /// <summary>Field number for the "Step" field.</summary>
  436. public const int StepFieldNumber = 2;
  437. private ulong step_;
  438. /// <summary>
  439. /// status=false时才有值
  440. /// </summary>
  441. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  442. public ulong Step {
  443. get { return step_; }
  444. set {
  445. step_ = value;
  446. }
  447. }
  448. /// <summary>Field number for the "Values" field.</summary>
  449. public const int ValuesFieldNumber = 3;
  450. private static readonly pbc::MapField<string, pb::ByteString>.Codec _map_values_codec
  451. = new pbc::MapField<string, pb::ByteString>.Codec(pb::FieldCodec.ForString(10), pb::FieldCodec.ForBytes(18), 26);
  452. private readonly pbc::MapField<string, pb::ByteString> values_ = new pbc::MapField<string, pb::ByteString>();
  453. /// <summary>
  454. /// status=false时才有值
  455. /// </summary>
  456. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  457. public pbc::MapField<string, pb::ByteString> Values {
  458. get { return values_; }
  459. }
  460. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  461. public override bool Equals(object other) {
  462. return Equals(other as SyncResponse);
  463. }
  464. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  465. public bool Equals(SyncResponse other) {
  466. if (ReferenceEquals(other, null)) {
  467. return false;
  468. }
  469. if (ReferenceEquals(other, this)) {
  470. return true;
  471. }
  472. if (Status != other.Status) return false;
  473. if (Step != other.Step) return false;
  474. if (!Values.Equals(other.Values)) return false;
  475. return true;
  476. }
  477. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  478. public override int GetHashCode() {
  479. int hash = 1;
  480. if (Status != false) hash ^= Status.GetHashCode();
  481. if (Step != 0UL) hash ^= Step.GetHashCode();
  482. hash ^= Values.GetHashCode();
  483. return hash;
  484. }
  485. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  486. public override string ToString() {
  487. return pb::JsonFormatter.ToDiagnosticString(this);
  488. }
  489. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  490. public void WriteTo(pb::CodedOutputStream output) {
  491. if (Status != false) {
  492. output.WriteRawTag(8);
  493. output.WriteBool(Status);
  494. }
  495. if (Step != 0UL) {
  496. output.WriteRawTag(16);
  497. output.WriteUInt64(Step);
  498. }
  499. values_.WriteTo(output, _map_values_codec);
  500. }
  501. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  502. public int CalculateSize() {
  503. int size = 0;
  504. if (Status != false) {
  505. size += 1 + 1;
  506. }
  507. if (Step != 0UL) {
  508. size += 1 + pb::CodedOutputStream.ComputeUInt64Size(Step);
  509. }
  510. size += values_.CalculateSize(_map_values_codec);
  511. return size;
  512. }
  513. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  514. public void MergeFrom(SyncResponse other) {
  515. if (other == null) {
  516. return;
  517. }
  518. if (other.Status != false) {
  519. Status = other.Status;
  520. }
  521. if (other.Step != 0UL) {
  522. Step = other.Step;
  523. }
  524. values_.Add(other.values_);
  525. }
  526. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  527. public void MergeFrom(pb::CodedInputStream input) {
  528. uint tag;
  529. while ((tag = input.ReadTag()) != 0) {
  530. switch(tag) {
  531. default:
  532. input.SkipLastField();
  533. break;
  534. case 8: {
  535. Status = input.ReadBool();
  536. break;
  537. }
  538. case 16: {
  539. Step = input.ReadUInt64();
  540. break;
  541. }
  542. case 26: {
  543. values_.AddEntriesFrom(input, _map_values_codec);
  544. break;
  545. }
  546. }
  547. }
  548. }
  549. }
  550. /// <summary>
  551. /// 同步消息推送
  552. /// </summary>
  553. public sealed partial class SyncPush : pb::IMessage<SyncPush> {
  554. private static readonly pb::MessageParser<SyncPush> _parser = new pb::MessageParser<SyncPush>(() => new SyncPush());
  555. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  556. public static pb::MessageParser<SyncPush> Parser { get { return _parser; } }
  557. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  558. public static pbr::MessageDescriptor Descriptor {
  559. get { return global::Protos.SyncReflection.Descriptor.MessageTypes[4]; }
  560. }
  561. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  562. pbr::MessageDescriptor pb::IMessage.Descriptor {
  563. get { return Descriptor; }
  564. }
  565. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  566. public SyncPush() {
  567. OnConstruction();
  568. }
  569. partial void OnConstruction();
  570. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  571. public SyncPush(SyncPush other) : this() {
  572. step_ = other.step_;
  573. values_ = other.values_.Clone();
  574. }
  575. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  576. public SyncPush Clone() {
  577. return new SyncPush(this);
  578. }
  579. /// <summary>Field number for the "Step" field.</summary>
  580. public const int StepFieldNumber = 1;
  581. private ulong step_;
  582. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  583. public ulong Step {
  584. get { return step_; }
  585. set {
  586. step_ = value;
  587. }
  588. }
  589. /// <summary>Field number for the "Values" field.</summary>
  590. public const int ValuesFieldNumber = 2;
  591. private static readonly pbc::MapField<string, pb::ByteString>.Codec _map_values_codec
  592. = new pbc::MapField<string, pb::ByteString>.Codec(pb::FieldCodec.ForString(10), pb::FieldCodec.ForBytes(18), 18);
  593. private readonly pbc::MapField<string, pb::ByteString> values_ = new pbc::MapField<string, pb::ByteString>();
  594. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  595. public pbc::MapField<string, pb::ByteString> Values {
  596. get { return values_; }
  597. }
  598. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  599. public override bool Equals(object other) {
  600. return Equals(other as SyncPush);
  601. }
  602. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  603. public bool Equals(SyncPush other) {
  604. if (ReferenceEquals(other, null)) {
  605. return false;
  606. }
  607. if (ReferenceEquals(other, this)) {
  608. return true;
  609. }
  610. if (Step != other.Step) return false;
  611. if (!Values.Equals(other.Values)) return false;
  612. return true;
  613. }
  614. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  615. public override int GetHashCode() {
  616. int hash = 1;
  617. if (Step != 0UL) hash ^= Step.GetHashCode();
  618. hash ^= Values.GetHashCode();
  619. return hash;
  620. }
  621. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  622. public override string ToString() {
  623. return pb::JsonFormatter.ToDiagnosticString(this);
  624. }
  625. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  626. public void WriteTo(pb::CodedOutputStream output) {
  627. if (Step != 0UL) {
  628. output.WriteRawTag(8);
  629. output.WriteUInt64(Step);
  630. }
  631. values_.WriteTo(output, _map_values_codec);
  632. }
  633. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  634. public int CalculateSize() {
  635. int size = 0;
  636. if (Step != 0UL) {
  637. size += 1 + pb::CodedOutputStream.ComputeUInt64Size(Step);
  638. }
  639. size += values_.CalculateSize(_map_values_codec);
  640. return size;
  641. }
  642. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  643. public void MergeFrom(SyncPush other) {
  644. if (other == null) {
  645. return;
  646. }
  647. if (other.Step != 0UL) {
  648. Step = other.Step;
  649. }
  650. values_.Add(other.values_);
  651. }
  652. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  653. public void MergeFrom(pb::CodedInputStream input) {
  654. uint tag;
  655. while ((tag = input.ReadTag()) != 0) {
  656. switch(tag) {
  657. default:
  658. input.SkipLastField();
  659. break;
  660. case 8: {
  661. Step = input.ReadUInt64();
  662. break;
  663. }
  664. case 18: {
  665. values_.AddEntriesFrom(input, _map_values_codec);
  666. break;
  667. }
  668. }
  669. }
  670. }
  671. }
  672. /// <summary>
  673. /// 服务器合并用户操作给master
  674. /// </summary>
  675. public sealed partial class MasterPush : pb::IMessage<MasterPush> {
  676. private static readonly pb::MessageParser<MasterPush> _parser = new pb::MessageParser<MasterPush>(() => new MasterPush());
  677. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  678. public static pb::MessageParser<MasterPush> Parser { get { return _parser; } }
  679. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  680. public static pbr::MessageDescriptor Descriptor {
  681. get { return global::Protos.SyncReflection.Descriptor.MessageTypes[5]; }
  682. }
  683. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  684. pbr::MessageDescriptor pb::IMessage.Descriptor {
  685. get { return Descriptor; }
  686. }
  687. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  688. public MasterPush() {
  689. OnConstruction();
  690. }
  691. partial void OnConstruction();
  692. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  693. public MasterPush(MasterPush other) : this() {
  694. step_ = other.step_;
  695. values_ = other.values_.Clone();
  696. }
  697. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  698. public MasterPush Clone() {
  699. return new MasterPush(this);
  700. }
  701. /// <summary>Field number for the "Step" field.</summary>
  702. public const int StepFieldNumber = 1;
  703. private ulong step_;
  704. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  705. public ulong Step {
  706. get { return step_; }
  707. set {
  708. step_ = value;
  709. }
  710. }
  711. /// <summary>Field number for the "Values" field.</summary>
  712. public const int ValuesFieldNumber = 2;
  713. private static readonly pbc::MapField<string, pb::ByteString>.Codec _map_values_codec
  714. = new pbc::MapField<string, pb::ByteString>.Codec(pb::FieldCodec.ForString(10), pb::FieldCodec.ForBytes(18), 18);
  715. private readonly pbc::MapField<string, pb::ByteString> values_ = new pbc::MapField<string, pb::ByteString>();
  716. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  717. public pbc::MapField<string, pb::ByteString> Values {
  718. get { return values_; }
  719. }
  720. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  721. public override bool Equals(object other) {
  722. return Equals(other as MasterPush);
  723. }
  724. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  725. public bool Equals(MasterPush other) {
  726. if (ReferenceEquals(other, null)) {
  727. return false;
  728. }
  729. if (ReferenceEquals(other, this)) {
  730. return true;
  731. }
  732. if (Step != other.Step) return false;
  733. if (!Values.Equals(other.Values)) return false;
  734. return true;
  735. }
  736. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  737. public override int GetHashCode() {
  738. int hash = 1;
  739. if (Step != 0UL) hash ^= Step.GetHashCode();
  740. hash ^= Values.GetHashCode();
  741. return hash;
  742. }
  743. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  744. public override string ToString() {
  745. return pb::JsonFormatter.ToDiagnosticString(this);
  746. }
  747. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  748. public void WriteTo(pb::CodedOutputStream output) {
  749. if (Step != 0UL) {
  750. output.WriteRawTag(8);
  751. output.WriteUInt64(Step);
  752. }
  753. values_.WriteTo(output, _map_values_codec);
  754. }
  755. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  756. public int CalculateSize() {
  757. int size = 0;
  758. if (Step != 0UL) {
  759. size += 1 + pb::CodedOutputStream.ComputeUInt64Size(Step);
  760. }
  761. size += values_.CalculateSize(_map_values_codec);
  762. return size;
  763. }
  764. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  765. public void MergeFrom(MasterPush other) {
  766. if (other == null) {
  767. return;
  768. }
  769. if (other.Step != 0UL) {
  770. Step = other.Step;
  771. }
  772. values_.Add(other.values_);
  773. }
  774. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  775. public void MergeFrom(pb::CodedInputStream input) {
  776. uint tag;
  777. while ((tag = input.ReadTag()) != 0) {
  778. switch(tag) {
  779. default:
  780. input.SkipLastField();
  781. break;
  782. case 8: {
  783. Step = input.ReadUInt64();
  784. break;
  785. }
  786. case 18: {
  787. values_.AddEntriesFrom(input, _map_values_codec);
  788. break;
  789. }
  790. }
  791. }
  792. }
  793. }
  794. /// <summary>
  795. /// 主机广播消息给flower
  796. /// </summary>
  797. public sealed partial class MasterNotify : pb::IMessage<MasterNotify> {
  798. private static readonly pb::MessageParser<MasterNotify> _parser = new pb::MessageParser<MasterNotify>(() => new MasterNotify());
  799. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  800. public static pb::MessageParser<MasterNotify> Parser { get { return _parser; } }
  801. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  802. public static pbr::MessageDescriptor Descriptor {
  803. get { return global::Protos.SyncReflection.Descriptor.MessageTypes[6]; }
  804. }
  805. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  806. pbr::MessageDescriptor pb::IMessage.Descriptor {
  807. get { return Descriptor; }
  808. }
  809. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  810. public MasterNotify() {
  811. OnConstruction();
  812. }
  813. partial void OnConstruction();
  814. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  815. public MasterNotify(MasterNotify other) : this() {
  816. step_ = other.step_;
  817. values_ = other.values_.Clone();
  818. }
  819. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  820. public MasterNotify Clone() {
  821. return new MasterNotify(this);
  822. }
  823. /// <summary>Field number for the "Step" field.</summary>
  824. public const int StepFieldNumber = 1;
  825. private ulong step_;
  826. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  827. public ulong Step {
  828. get { return step_; }
  829. set {
  830. step_ = value;
  831. }
  832. }
  833. /// <summary>Field number for the "Values" field.</summary>
  834. public const int ValuesFieldNumber = 2;
  835. private static readonly pbc::MapField<string, pb::ByteString>.Codec _map_values_codec
  836. = new pbc::MapField<string, pb::ByteString>.Codec(pb::FieldCodec.ForString(10), pb::FieldCodec.ForBytes(18), 18);
  837. private readonly pbc::MapField<string, pb::ByteString> values_ = new pbc::MapField<string, pb::ByteString>();
  838. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  839. public pbc::MapField<string, pb::ByteString> Values {
  840. get { return values_; }
  841. }
  842. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  843. public override bool Equals(object other) {
  844. return Equals(other as MasterNotify);
  845. }
  846. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  847. public bool Equals(MasterNotify other) {
  848. if (ReferenceEquals(other, null)) {
  849. return false;
  850. }
  851. if (ReferenceEquals(other, this)) {
  852. return true;
  853. }
  854. if (Step != other.Step) return false;
  855. if (!Values.Equals(other.Values)) return false;
  856. return true;
  857. }
  858. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  859. public override int GetHashCode() {
  860. int hash = 1;
  861. if (Step != 0UL) hash ^= Step.GetHashCode();
  862. hash ^= Values.GetHashCode();
  863. return hash;
  864. }
  865. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  866. public override string ToString() {
  867. return pb::JsonFormatter.ToDiagnosticString(this);
  868. }
  869. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  870. public void WriteTo(pb::CodedOutputStream output) {
  871. if (Step != 0UL) {
  872. output.WriteRawTag(8);
  873. output.WriteUInt64(Step);
  874. }
  875. values_.WriteTo(output, _map_values_codec);
  876. }
  877. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  878. public int CalculateSize() {
  879. int size = 0;
  880. if (Step != 0UL) {
  881. size += 1 + pb::CodedOutputStream.ComputeUInt64Size(Step);
  882. }
  883. size += values_.CalculateSize(_map_values_codec);
  884. return size;
  885. }
  886. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  887. public void MergeFrom(MasterNotify other) {
  888. if (other == null) {
  889. return;
  890. }
  891. if (other.Step != 0UL) {
  892. Step = other.Step;
  893. }
  894. values_.Add(other.values_);
  895. }
  896. [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
  897. public void MergeFrom(pb::CodedInputStream input) {
  898. uint tag;
  899. while ((tag = input.ReadTag()) != 0) {
  900. switch(tag) {
  901. default:
  902. input.SkipLastField();
  903. break;
  904. case 8: {
  905. Step = input.ReadUInt64();
  906. break;
  907. }
  908. case 18: {
  909. values_.AddEntriesFrom(input, _map_values_codec);
  910. break;
  911. }
  912. }
  913. }
  914. }
  915. }
  916. #endregion
  917. }
  918. #endregion Designer generated code