|
@@ -29,45 +29,48 @@ namespace Protos {
|
|
|
"ZUVudHJ5GiwKClN0YXRlRW50cnkSCwoDa2V5GAEgASgJEg0KBXZhbHVlGAIg",
|
|
|
"ASgMOgI4ASJ7CgtTeW5jUmVxdWVzdBIMCgRTdGVwGAEgASgEEi8KBlZhbHVl",
|
|
|
"cxgCIAMoCzIfLnByb3Rvcy5TeW5jUmVxdWVzdC5WYWx1ZXNFbnRyeRotCgtW",
|
|
|
- "YWx1ZXNFbnRyeRILCgNrZXkYASABKAkSDQoFdmFsdWUYAiABKAw6AjgBIo0B",
|
|
|
+ "YWx1ZXNFbnRyeRILCgNrZXkYASABKAkSDQoFdmFsdWUYAiABKAw6AjgBIpgB",
|
|
|
"CgxTeW5jUmVzcG9uc2USDgoGU3RhdHVzGAEgASgIEgwKBFN0ZXAYAiABKAQS",
|
|
|
"MAoGVmFsdWVzGAMgAygLMiAucHJvdG9zLlN5bmNSZXNwb25zZS5WYWx1ZXNF",
|
|
|
- "bnRyeRotCgtWYWx1ZXNFbnRyeRILCgNrZXkYASABKAkSDQoFdmFsdWUYAiAB",
|
|
|
- "KAw6AjgBIoYBCg9ETWVzc2FnZVJlcXVlc3QSDwoHVXNlcklEcxgBIAMoDRIz",
|
|
|
- "CgZWYWx1ZXMYAiADKAsyIy5wcm90b3MuRE1lc3NhZ2VSZXF1ZXN0LlZhbHVl",
|
|
|
- "c0VudHJ5Gi0KC1ZhbHVlc0VudHJ5EgsKA2tleRgBIAEoCRINCgV2YWx1ZRgC",
|
|
|
- "IAEoDDoCOAEiMgoQRE1lc3NhZ2VSZXNwb25zZRIeCgZSZXN1bHQYASABKAsy",
|
|
|
- "Di5wcm90b3MuUmVzdWx0Im8KDERNZXNzYWdlUHVzaBIwCgZWYWx1ZXMYASAD",
|
|
|
- "KAsyIC5wcm90b3MuRE1lc3NhZ2VQdXNoLlZhbHVlc0VudHJ5Gi0KC1ZhbHVl",
|
|
|
- "c0VudHJ5EgsKA2tleRgBIAEoCRINCgV2YWx1ZRgCIAEoDDoCOAEidQoIU3lu",
|
|
|
- "Y1B1c2gSDAoEU3RlcBgBIAEoBBIsCgZWYWx1ZXMYAiADKAsyHC5wcm90b3Mu",
|
|
|
- "U3luY1B1c2guVmFsdWVzRW50cnkaLQoLVmFsdWVzRW50cnkSCwoDa2V5GAEg",
|
|
|
- "ASgJEg0KBXZhbHVlGAIgASgMOgI4ASJ5CgpNYXN0ZXJQdXNoEgwKBFN0ZXAY",
|
|
|
- "ASABKAQSLgoGVmFsdWVzGAIgAygLMh4ucHJvdG9zLk1hc3RlclB1c2guVmFs",
|
|
|
- "dWVzRW50cnkaLQoLVmFsdWVzRW50cnkSCwoDa2V5GAEgASgJEg0KBXZhbHVl",
|
|
|
- "GAIgASgMOgI4ASJ9CgxNYXN0ZXJOb3RpZnkSDAoEU3RlcBgBIAEoBBIwCgZW",
|
|
|
- "YWx1ZXMYAiADKAsyIC5wcm90b3MuTWFzdGVyTm90aWZ5LlZhbHVlc0VudHJ5",
|
|
|
- "Gi0KC1ZhbHVlc0VudHJ5EgsKA2tleRgBIAEoCRINCgV2YWx1ZRgCIAEoDDoC",
|
|
|
- "OAEieQoRTWFzdGVyU3RvcmVOb3RpZnkSNQoGVmFsdWVzGAEgAygLMiUucHJv",
|
|
|
- "dG9zLk1hc3RlclN0b3JlTm90aWZ5LlZhbHVlc0VudHJ5Gi0KC1ZhbHVlc0Vu",
|
|
|
- "dHJ5EgsKA2tleRgBIAEoCRINCgV2YWx1ZRgCIAEoDDoCOAEiEwoRTWFzdGVy",
|
|
|
- "TG9hZFJlcXVlc3QimwEKEk1hc3RlckxvYWRSZXNwb25zZRIeCgZSZXN1bHQY",
|
|
|
- "ASABKAsyDi5wcm90b3MuUmVzdWx0EjYKBlZhbHVlcxgCIAMoCzImLnByb3Rv",
|
|
|
- "cy5NYXN0ZXJMb2FkUmVzcG9uc2UuVmFsdWVzRW50cnkaLQoLVmFsdWVzRW50",
|
|
|
- "cnkSCwoDa2V5GAEgASgJEg0KBXZhbHVlGAIgASgMOgI4AWIGcHJvdG8z"));
|
|
|
+ "bnRyeRIJCgFUGAQgASgEGi0KC1ZhbHVlc0VudHJ5EgsKA2tleRgBIAEoCRIN",
|
|
|
+ "CgV2YWx1ZRgCIAEoDDoCOAEihgEKD0RNZXNzYWdlUmVxdWVzdBIPCgdVc2Vy",
|
|
|
+ "SURzGAEgAygNEjMKBlZhbHVlcxgCIAMoCzIjLnByb3Rvcy5ETWVzc2FnZVJl",
|
|
|
+ "cXVlc3QuVmFsdWVzRW50cnkaLQoLVmFsdWVzRW50cnkSCwoDa2V5GAEgASgJ",
|
|
|
+ "Eg0KBXZhbHVlGAIgASgMOgI4ASIyChBETWVzc2FnZVJlc3BvbnNlEh4KBlJl",
|
|
|
+ "c3VsdBgBIAEoCzIOLnByb3Rvcy5SZXN1bHQibwoMRE1lc3NhZ2VQdXNoEjAK",
|
|
|
+ "BlZhbHVlcxgBIAMoCzIgLnByb3Rvcy5ETWVzc2FnZVB1c2guVmFsdWVzRW50",
|
|
|
+ "cnkaLQoLVmFsdWVzRW50cnkSCwoDa2V5GAEgASgJEg0KBXZhbHVlGAIgASgM",
|
|
|
+ "OgI4ASKAAQoIU3luY1B1c2gSDAoEU3RlcBgBIAEoBBIsCgZWYWx1ZXMYAiAD",
|
|
|
+ "KAsyHC5wcm90b3MuU3luY1B1c2guVmFsdWVzRW50cnkSCQoBVBgDIAEoBBot",
|
|
|
+ "CgtWYWx1ZXNFbnRyeRILCgNrZXkYASABKAkSDQoFdmFsdWUYAiABKAw6AjgB",
|
|
|
+ "IoQBCgpNYXN0ZXJQdXNoEgwKBFN0ZXAYASABKAQSLgoGVmFsdWVzGAIgAygL",
|
|
|
+ "Mh4ucHJvdG9zLk1hc3RlclB1c2guVmFsdWVzRW50cnkSCQoBVBgDIAEoBBot",
|
|
|
+ "CgtWYWx1ZXNFbnRyeRILCgNrZXkYASABKAkSDQoFdmFsdWUYAiABKAw6AjgB",
|
|
|
+ "In0KDE1hc3Rlck5vdGlmeRIMCgRTdGVwGAEgASgEEjAKBlZhbHVlcxgCIAMo",
|
|
|
+ "CzIgLnByb3Rvcy5NYXN0ZXJOb3RpZnkuVmFsdWVzRW50cnkaLQoLVmFsdWVz",
|
|
|
+ "RW50cnkSCwoDa2V5GAEgASgJEg0KBXZhbHVlGAIgASgMOgI4ASIhChRNYXN0",
|
|
|
+ "ZXJOb3RpZnlSZXNwb25zZRIJCgFUGAEgASgEInkKEU1hc3RlclN0b3JlTm90",
|
|
|
+ "aWZ5EjUKBlZhbHVlcxgBIAMoCzIlLnByb3Rvcy5NYXN0ZXJTdG9yZU5vdGlm",
|
|
|
+ "eS5WYWx1ZXNFbnRyeRotCgtWYWx1ZXNFbnRyeRILCgNrZXkYASABKAkSDQoF",
|
|
|
+ "dmFsdWUYAiABKAw6AjgBIhMKEU1hc3RlckxvYWRSZXF1ZXN0IpsBChJNYXN0",
|
|
|
+ "ZXJMb2FkUmVzcG9uc2USHgoGUmVzdWx0GAEgASgLMg4ucHJvdG9zLlJlc3Vs",
|
|
|
+ "dBI2CgZWYWx1ZXMYAiADKAsyJi5wcm90b3MuTWFzdGVyTG9hZFJlc3BvbnNl",
|
|
|
+ "LlZhbHVlc0VudHJ5Gi0KC1ZhbHVlc0VudHJ5EgsKA2tleRgBIAEoCRINCgV2",
|
|
|
+ "YWx1ZRgCIAEoDDoCOAFiBnByb3RvMw=="));
|
|
|
descriptor = pbr::FileDescriptor.FromGeneratedCode(descriptorData,
|
|
|
new pbr::FileDescriptor[] { global::Protos.UserinfoReflection.Descriptor, global::Protos.ResultReflection.Descriptor, },
|
|
|
new pbr::GeneratedClrTypeInfo(null, new pbr::GeneratedClrTypeInfo[] {
|
|
|
new pbr::GeneratedClrTypeInfo(typeof(global::Protos.RestoreRequest), global::Protos.RestoreRequest.Parser, null, null, null, null),
|
|
|
new pbr::GeneratedClrTypeInfo(typeof(global::Protos.RestoreResponse), global::Protos.RestoreResponse.Parser, new[]{ "Users", "Step", "State" }, null, null, new pbr::GeneratedClrTypeInfo[] { null, }),
|
|
|
new pbr::GeneratedClrTypeInfo(typeof(global::Protos.SyncRequest), global::Protos.SyncRequest.Parser, new[]{ "Step", "Values" }, null, null, new pbr::GeneratedClrTypeInfo[] { null, }),
|
|
|
- new pbr::GeneratedClrTypeInfo(typeof(global::Protos.SyncResponse), global::Protos.SyncResponse.Parser, new[]{ "Status", "Step", "Values" }, null, null, new pbr::GeneratedClrTypeInfo[] { null, }),
|
|
|
+ new pbr::GeneratedClrTypeInfo(typeof(global::Protos.SyncResponse), global::Protos.SyncResponse.Parser, new[]{ "Status", "Step", "Values", "T" }, null, null, new pbr::GeneratedClrTypeInfo[] { null, }),
|
|
|
new pbr::GeneratedClrTypeInfo(typeof(global::Protos.DMessageRequest), global::Protos.DMessageRequest.Parser, new[]{ "UserIDs", "Values" }, null, null, new pbr::GeneratedClrTypeInfo[] { null, }),
|
|
|
new pbr::GeneratedClrTypeInfo(typeof(global::Protos.DMessageResponse), global::Protos.DMessageResponse.Parser, new[]{ "Result" }, null, null, null),
|
|
|
new pbr::GeneratedClrTypeInfo(typeof(global::Protos.DMessagePush), global::Protos.DMessagePush.Parser, new[]{ "Values" }, null, null, new pbr::GeneratedClrTypeInfo[] { null, }),
|
|
|
- new pbr::GeneratedClrTypeInfo(typeof(global::Protos.SyncPush), global::Protos.SyncPush.Parser, new[]{ "Step", "Values" }, null, null, new pbr::GeneratedClrTypeInfo[] { null, }),
|
|
|
- new pbr::GeneratedClrTypeInfo(typeof(global::Protos.MasterPush), global::Protos.MasterPush.Parser, new[]{ "Step", "Values" }, null, null, new pbr::GeneratedClrTypeInfo[] { null, }),
|
|
|
+ new pbr::GeneratedClrTypeInfo(typeof(global::Protos.SyncPush), global::Protos.SyncPush.Parser, new[]{ "Step", "Values", "T" }, null, null, new pbr::GeneratedClrTypeInfo[] { null, }),
|
|
|
+ new pbr::GeneratedClrTypeInfo(typeof(global::Protos.MasterPush), global::Protos.MasterPush.Parser, new[]{ "Step", "Values", "T" }, null, null, new pbr::GeneratedClrTypeInfo[] { null, }),
|
|
|
new pbr::GeneratedClrTypeInfo(typeof(global::Protos.MasterNotify), global::Protos.MasterNotify.Parser, new[]{ "Step", "Values" }, null, null, new pbr::GeneratedClrTypeInfo[] { null, }),
|
|
|
+ new pbr::GeneratedClrTypeInfo(typeof(global::Protos.MasterNotifyResponse), global::Protos.MasterNotifyResponse.Parser, new[]{ "T" }, null, null, null),
|
|
|
new pbr::GeneratedClrTypeInfo(typeof(global::Protos.MasterStoreNotify), global::Protos.MasterStoreNotify.Parser, new[]{ "Values" }, null, null, new pbr::GeneratedClrTypeInfo[] { null, }),
|
|
|
new pbr::GeneratedClrTypeInfo(typeof(global::Protos.MasterLoadRequest), global::Protos.MasterLoadRequest.Parser, null, null, null, null),
|
|
|
new pbr::GeneratedClrTypeInfo(typeof(global::Protos.MasterLoadResponse), global::Protos.MasterLoadResponse.Parser, new[]{ "Result", "Values" }, null, null, new pbr::GeneratedClrTypeInfo[] { null, })
|
|
@@ -499,6 +502,7 @@ namespace Protos {
|
|
|
status_ = other.status_;
|
|
|
step_ = other.step_;
|
|
|
values_ = other.values_.Clone();
|
|
|
+ t_ = other.t_;
|
|
|
}
|
|
|
|
|
|
[global::System.Diagnostics.DebuggerNonUserCodeAttribute]
|
|
@@ -544,6 +548,20 @@ namespace Protos {
|
|
|
get { return values_; }
|
|
|
}
|
|
|
|
|
|
+ /// <summary>Field number for the "T" field.</summary>
|
|
|
+ public const int TFieldNumber = 4;
|
|
|
+ private ulong t_;
|
|
|
+ /// <summary>
|
|
|
+ /// 服务器收到sync request的时间戳(毫秒)
|
|
|
+ /// </summary>
|
|
|
+ [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
|
|
|
+ public ulong T {
|
|
|
+ get { return t_; }
|
|
|
+ set {
|
|
|
+ t_ = value;
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
[global::System.Diagnostics.DebuggerNonUserCodeAttribute]
|
|
|
public override bool Equals(object other) {
|
|
|
return Equals(other as SyncResponse);
|
|
@@ -560,6 +578,7 @@ namespace Protos {
|
|
|
if (Status != other.Status) return false;
|
|
|
if (Step != other.Step) return false;
|
|
|
if (!Values.Equals(other.Values)) return false;
|
|
|
+ if (T != other.T) return false;
|
|
|
return true;
|
|
|
}
|
|
|
|
|
@@ -569,6 +588,7 @@ namespace Protos {
|
|
|
if (Status != false) hash ^= Status.GetHashCode();
|
|
|
if (Step != 0UL) hash ^= Step.GetHashCode();
|
|
|
hash ^= Values.GetHashCode();
|
|
|
+ if (T != 0UL) hash ^= T.GetHashCode();
|
|
|
return hash;
|
|
|
}
|
|
|
|
|
@@ -588,6 +608,10 @@ namespace Protos {
|
|
|
output.WriteUInt64(Step);
|
|
|
}
|
|
|
values_.WriteTo(output, _map_values_codec);
|
|
|
+ if (T != 0UL) {
|
|
|
+ output.WriteRawTag(32);
|
|
|
+ output.WriteUInt64(T);
|
|
|
+ }
|
|
|
}
|
|
|
|
|
|
[global::System.Diagnostics.DebuggerNonUserCodeAttribute]
|
|
@@ -600,6 +624,9 @@ namespace Protos {
|
|
|
size += 1 + pb::CodedOutputStream.ComputeUInt64Size(Step);
|
|
|
}
|
|
|
size += values_.CalculateSize(_map_values_codec);
|
|
|
+ if (T != 0UL) {
|
|
|
+ size += 1 + pb::CodedOutputStream.ComputeUInt64Size(T);
|
|
|
+ }
|
|
|
return size;
|
|
|
}
|
|
|
|
|
@@ -615,6 +642,9 @@ namespace Protos {
|
|
|
Step = other.Step;
|
|
|
}
|
|
|
values_.Add(other.values_);
|
|
|
+ if (other.T != 0UL) {
|
|
|
+ T = other.T;
|
|
|
+ }
|
|
|
}
|
|
|
|
|
|
[global::System.Diagnostics.DebuggerNonUserCodeAttribute]
|
|
@@ -637,6 +667,10 @@ namespace Protos {
|
|
|
values_.AddEntriesFrom(input, _map_values_codec);
|
|
|
break;
|
|
|
}
|
|
|
+ case 32: {
|
|
|
+ T = input.ReadUInt64();
|
|
|
+ break;
|
|
|
+ }
|
|
|
}
|
|
|
}
|
|
|
}
|
|
@@ -1043,6 +1077,7 @@ namespace Protos {
|
|
|
public SyncPush(SyncPush other) : this() {
|
|
|
step_ = other.step_;
|
|
|
values_ = other.values_.Clone();
|
|
|
+ t_ = other.t_;
|
|
|
}
|
|
|
|
|
|
[global::System.Diagnostics.DebuggerNonUserCodeAttribute]
|
|
@@ -1071,6 +1106,20 @@ namespace Protos {
|
|
|
get { return values_; }
|
|
|
}
|
|
|
|
|
|
+ /// <summary>Field number for the "T" field.</summary>
|
|
|
+ public const int TFieldNumber = 3;
|
|
|
+ private ulong t_;
|
|
|
+ /// <summary>
|
|
|
+ /// 服务器开始推送时间戳
|
|
|
+ /// </summary>
|
|
|
+ [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
|
|
|
+ public ulong T {
|
|
|
+ get { return t_; }
|
|
|
+ set {
|
|
|
+ t_ = value;
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
[global::System.Diagnostics.DebuggerNonUserCodeAttribute]
|
|
|
public override bool Equals(object other) {
|
|
|
return Equals(other as SyncPush);
|
|
@@ -1086,6 +1135,7 @@ namespace Protos {
|
|
|
}
|
|
|
if (Step != other.Step) return false;
|
|
|
if (!Values.Equals(other.Values)) return false;
|
|
|
+ if (T != other.T) return false;
|
|
|
return true;
|
|
|
}
|
|
|
|
|
@@ -1094,6 +1144,7 @@ namespace Protos {
|
|
|
int hash = 1;
|
|
|
if (Step != 0UL) hash ^= Step.GetHashCode();
|
|
|
hash ^= Values.GetHashCode();
|
|
|
+ if (T != 0UL) hash ^= T.GetHashCode();
|
|
|
return hash;
|
|
|
}
|
|
|
|
|
@@ -1109,6 +1160,10 @@ namespace Protos {
|
|
|
output.WriteUInt64(Step);
|
|
|
}
|
|
|
values_.WriteTo(output, _map_values_codec);
|
|
|
+ if (T != 0UL) {
|
|
|
+ output.WriteRawTag(24);
|
|
|
+ output.WriteUInt64(T);
|
|
|
+ }
|
|
|
}
|
|
|
|
|
|
[global::System.Diagnostics.DebuggerNonUserCodeAttribute]
|
|
@@ -1118,6 +1173,9 @@ namespace Protos {
|
|
|
size += 1 + pb::CodedOutputStream.ComputeUInt64Size(Step);
|
|
|
}
|
|
|
size += values_.CalculateSize(_map_values_codec);
|
|
|
+ if (T != 0UL) {
|
|
|
+ size += 1 + pb::CodedOutputStream.ComputeUInt64Size(T);
|
|
|
+ }
|
|
|
return size;
|
|
|
}
|
|
|
|
|
@@ -1130,6 +1188,9 @@ namespace Protos {
|
|
|
Step = other.Step;
|
|
|
}
|
|
|
values_.Add(other.values_);
|
|
|
+ if (other.T != 0UL) {
|
|
|
+ T = other.T;
|
|
|
+ }
|
|
|
}
|
|
|
|
|
|
[global::System.Diagnostics.DebuggerNonUserCodeAttribute]
|
|
@@ -1148,6 +1209,10 @@ namespace Protos {
|
|
|
values_.AddEntriesFrom(input, _map_values_codec);
|
|
|
break;
|
|
|
}
|
|
|
+ case 24: {
|
|
|
+ T = input.ReadUInt64();
|
|
|
+ break;
|
|
|
+ }
|
|
|
}
|
|
|
}
|
|
|
}
|
|
@@ -1183,6 +1248,7 @@ namespace Protos {
|
|
|
public MasterPush(MasterPush other) : this() {
|
|
|
step_ = other.step_;
|
|
|
values_ = other.values_.Clone();
|
|
|
+ t_ = other.t_;
|
|
|
}
|
|
|
|
|
|
[global::System.Diagnostics.DebuggerNonUserCodeAttribute]
|
|
@@ -1211,6 +1277,20 @@ namespace Protos {
|
|
|
get { return values_; }
|
|
|
}
|
|
|
|
|
|
+ /// <summary>Field number for the "T" field.</summary>
|
|
|
+ public const int TFieldNumber = 3;
|
|
|
+ private ulong t_;
|
|
|
+ /// <summary>
|
|
|
+ /// 服务器开始推送时间戳
|
|
|
+ /// </summary>
|
|
|
+ [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
|
|
|
+ public ulong T {
|
|
|
+ get { return t_; }
|
|
|
+ set {
|
|
|
+ t_ = value;
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
[global::System.Diagnostics.DebuggerNonUserCodeAttribute]
|
|
|
public override bool Equals(object other) {
|
|
|
return Equals(other as MasterPush);
|
|
@@ -1226,6 +1306,7 @@ namespace Protos {
|
|
|
}
|
|
|
if (Step != other.Step) return false;
|
|
|
if (!Values.Equals(other.Values)) return false;
|
|
|
+ if (T != other.T) return false;
|
|
|
return true;
|
|
|
}
|
|
|
|
|
@@ -1234,6 +1315,7 @@ namespace Protos {
|
|
|
int hash = 1;
|
|
|
if (Step != 0UL) hash ^= Step.GetHashCode();
|
|
|
hash ^= Values.GetHashCode();
|
|
|
+ if (T != 0UL) hash ^= T.GetHashCode();
|
|
|
return hash;
|
|
|
}
|
|
|
|
|
@@ -1249,6 +1331,10 @@ namespace Protos {
|
|
|
output.WriteUInt64(Step);
|
|
|
}
|
|
|
values_.WriteTo(output, _map_values_codec);
|
|
|
+ if (T != 0UL) {
|
|
|
+ output.WriteRawTag(24);
|
|
|
+ output.WriteUInt64(T);
|
|
|
+ }
|
|
|
}
|
|
|
|
|
|
[global::System.Diagnostics.DebuggerNonUserCodeAttribute]
|
|
@@ -1258,6 +1344,9 @@ namespace Protos {
|
|
|
size += 1 + pb::CodedOutputStream.ComputeUInt64Size(Step);
|
|
|
}
|
|
|
size += values_.CalculateSize(_map_values_codec);
|
|
|
+ if (T != 0UL) {
|
|
|
+ size += 1 + pb::CodedOutputStream.ComputeUInt64Size(T);
|
|
|
+ }
|
|
|
return size;
|
|
|
}
|
|
|
|
|
@@ -1270,6 +1359,9 @@ namespace Protos {
|
|
|
Step = other.Step;
|
|
|
}
|
|
|
values_.Add(other.values_);
|
|
|
+ if (other.T != 0UL) {
|
|
|
+ T = other.T;
|
|
|
+ }
|
|
|
}
|
|
|
|
|
|
[global::System.Diagnostics.DebuggerNonUserCodeAttribute]
|
|
@@ -1288,6 +1380,10 @@ namespace Protos {
|
|
|
values_.AddEntriesFrom(input, _map_values_codec);
|
|
|
break;
|
|
|
}
|
|
|
+ case 24: {
|
|
|
+ T = input.ReadUInt64();
|
|
|
+ break;
|
|
|
+ }
|
|
|
}
|
|
|
}
|
|
|
}
|
|
@@ -1435,6 +1531,129 @@ namespace Protos {
|
|
|
}
|
|
|
|
|
|
/// <summary>
|
|
|
+ /// 主机广播消息给flower
|
|
|
+ /// </summary>
|
|
|
+ public sealed partial class MasterNotifyResponse : pb::IMessage<MasterNotifyResponse> {
|
|
|
+ private static readonly pb::MessageParser<MasterNotifyResponse> _parser = new pb::MessageParser<MasterNotifyResponse>(() => new MasterNotifyResponse());
|
|
|
+ [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
|
|
|
+ public static pb::MessageParser<MasterNotifyResponse> Parser { get { return _parser; } }
|
|
|
+
|
|
|
+ [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
|
|
|
+ public static pbr::MessageDescriptor Descriptor {
|
|
|
+ get { return global::Protos.SyncReflection.Descriptor.MessageTypes[10]; }
|
|
|
+ }
|
|
|
+
|
|
|
+ [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
|
|
|
+ pbr::MessageDescriptor pb::IMessage.Descriptor {
|
|
|
+ get { return Descriptor; }
|
|
|
+ }
|
|
|
+
|
|
|
+ [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
|
|
|
+ public MasterNotifyResponse() {
|
|
|
+ OnConstruction();
|
|
|
+ }
|
|
|
+
|
|
|
+ partial void OnConstruction();
|
|
|
+
|
|
|
+ [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
|
|
|
+ public MasterNotifyResponse(MasterNotifyResponse other) : this() {
|
|
|
+ t_ = other.t_;
|
|
|
+ }
|
|
|
+
|
|
|
+ [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
|
|
|
+ public MasterNotifyResponse Clone() {
|
|
|
+ return new MasterNotifyResponse(this);
|
|
|
+ }
|
|
|
+
|
|
|
+ /// <summary>Field number for the "T" field.</summary>
|
|
|
+ public const int TFieldNumber = 1;
|
|
|
+ private ulong t_;
|
|
|
+ /// <summary>
|
|
|
+ /// 服务器收到MasterNotify的时间戳(毫秒)
|
|
|
+ /// </summary>
|
|
|
+ [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
|
|
|
+ public ulong T {
|
|
|
+ get { return t_; }
|
|
|
+ set {
|
|
|
+ t_ = value;
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
|
|
|
+ public override bool Equals(object other) {
|
|
|
+ return Equals(other as MasterNotifyResponse);
|
|
|
+ }
|
|
|
+
|
|
|
+ [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
|
|
|
+ public bool Equals(MasterNotifyResponse other) {
|
|
|
+ if (ReferenceEquals(other, null)) {
|
|
|
+ return false;
|
|
|
+ }
|
|
|
+ if (ReferenceEquals(other, this)) {
|
|
|
+ return true;
|
|
|
+ }
|
|
|
+ if (T != other.T) return false;
|
|
|
+ return true;
|
|
|
+ }
|
|
|
+
|
|
|
+ [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
|
|
|
+ public override int GetHashCode() {
|
|
|
+ int hash = 1;
|
|
|
+ if (T != 0UL) hash ^= T.GetHashCode();
|
|
|
+ return hash;
|
|
|
+ }
|
|
|
+
|
|
|
+ [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
|
|
|
+ public override string ToString() {
|
|
|
+ return pb::JsonFormatter.ToDiagnosticString(this);
|
|
|
+ }
|
|
|
+
|
|
|
+ [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
|
|
|
+ public void WriteTo(pb::CodedOutputStream output) {
|
|
|
+ if (T != 0UL) {
|
|
|
+ output.WriteRawTag(8);
|
|
|
+ output.WriteUInt64(T);
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
|
|
|
+ public int CalculateSize() {
|
|
|
+ int size = 0;
|
|
|
+ if (T != 0UL) {
|
|
|
+ size += 1 + pb::CodedOutputStream.ComputeUInt64Size(T);
|
|
|
+ }
|
|
|
+ return size;
|
|
|
+ }
|
|
|
+
|
|
|
+ [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
|
|
|
+ public void MergeFrom(MasterNotifyResponse other) {
|
|
|
+ if (other == null) {
|
|
|
+ return;
|
|
|
+ }
|
|
|
+ if (other.T != 0UL) {
|
|
|
+ T = other.T;
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
|
|
|
+ public void MergeFrom(pb::CodedInputStream input) {
|
|
|
+ uint tag;
|
|
|
+ while ((tag = input.ReadTag()) != 0) {
|
|
|
+ switch(tag) {
|
|
|
+ default:
|
|
|
+ input.SkipLastField();
|
|
|
+ break;
|
|
|
+ case 8: {
|
|
|
+ T = input.ReadUInt64();
|
|
|
+ break;
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ }
|
|
|
+
|
|
|
+ /// <summary>
|
|
|
/// 主机存储状态
|
|
|
/// </summary>
|
|
|
public sealed partial class MasterStoreNotify : pb::IMessage<MasterStoreNotify> {
|
|
@@ -1444,7 +1663,7 @@ namespace Protos {
|
|
|
|
|
|
[global::System.Diagnostics.DebuggerNonUserCodeAttribute]
|
|
|
public static pbr::MessageDescriptor Descriptor {
|
|
|
- get { return global::Protos.SyncReflection.Descriptor.MessageTypes[10]; }
|
|
|
+ get { return global::Protos.SyncReflection.Descriptor.MessageTypes[11]; }
|
|
|
}
|
|
|
|
|
|
[global::System.Diagnostics.DebuggerNonUserCodeAttribute]
|
|
@@ -1556,7 +1775,7 @@ namespace Protos {
|
|
|
|
|
|
[global::System.Diagnostics.DebuggerNonUserCodeAttribute]
|
|
|
public static pbr::MessageDescriptor Descriptor {
|
|
|
- get { return global::Protos.SyncReflection.Descriptor.MessageTypes[11]; }
|
|
|
+ get { return global::Protos.SyncReflection.Descriptor.MessageTypes[12]; }
|
|
|
}
|
|
|
|
|
|
[global::System.Diagnostics.DebuggerNonUserCodeAttribute]
|
|
@@ -1648,7 +1867,7 @@ namespace Protos {
|
|
|
|
|
|
[global::System.Diagnostics.DebuggerNonUserCodeAttribute]
|
|
|
public static pbr::MessageDescriptor Descriptor {
|
|
|
- get { return global::Protos.SyncReflection.Descriptor.MessageTypes[12]; }
|
|
|
+ get { return global::Protos.SyncReflection.Descriptor.MessageTypes[13]; }
|
|
|
}
|
|
|
|
|
|
[global::System.Diagnostics.DebuggerNonUserCodeAttribute]
|