上传补羊重连机制
This commit is contained in:
liwei1dao
parent
3bb79c6ec7
commit
8ad90274dd
40
modules/parkour/api_reconnectroom.go
Normal file
40
modules/parkour/api_reconnectroom.go
Normal file
@ -0,0 +1,40 @@
|
||||
package parkour
|
||||
|
||||
import (
|
||||
"fmt"
|
||||
"go_dreamfactory/comm"
|
||||
"go_dreamfactory/pb"
|
||||
)
|
||||
|
||||
//参数校验
|
||||
func (this *apiComp) ReconnectRoomCheck(session comm.IUserSession, req *pb.ParkourReconnectRoomReq) (errdata *pb.ErrorData) {
|
||||
return
|
||||
}
|
||||
|
||||
///匹配请求
|
||||
func (this *apiComp) ReconnectRoom(session comm.IUserSession, req *pb.ParkourReconnectRoomReq) (errdata *pb.ErrorData) {
|
||||
var (
|
||||
room *RaceItem
|
||||
race *pb.DBRace
|
||||
ok bool
|
||||
)
|
||||
if errdata = this.ReconnectRoomCheck(session, req); errdata != nil {
|
||||
return
|
||||
}
|
||||
this.module.lock.RLock()
|
||||
room, ok = this.module.battles[req.Battleid]
|
||||
this.module.lock.RUnlock()
|
||||
if ok {
|
||||
room.lock.Lock()
|
||||
room.Session[session.GetUserId()] = session.Clone()
|
||||
room.lock.Unlock()
|
||||
race = &pb.DBRace{
|
||||
Id: room.Id,
|
||||
ServicePath: fmt.Sprintf("%s/%s", this.service.GetType(), this.service.GetId()),
|
||||
Redmember: room.RedMember,
|
||||
Bulemember: room.BuleMember,
|
||||
}
|
||||
}
|
||||
session.SendMsg(string(this.module.GetType()), "reconnectroom", &pb.ParkourReconnectRoomResp{Race: race})
|
||||
return
|
||||
}
|
||||
@ -1691,6 +1691,101 @@ func (x *ParkourAllWeekRewardResp) GetAward() []*UserAtno {
|
||||
return nil
|
||||
}
|
||||
|
||||
//重连
|
||||
type ParkourReconnectRoomReq struct {
|
||||
state protoimpl.MessageState
|
||||
sizeCache protoimpl.SizeCache
|
||||
unknownFields protoimpl.UnknownFields
|
||||
|
||||
Battleid string `protobuf:"bytes,1,opt,name=battleid,proto3" json:"battleid"`
|
||||
}
|
||||
|
||||
func (x *ParkourReconnectRoomReq) Reset() {
|
||||
*x = ParkourReconnectRoomReq{}
|
||||
if protoimpl.UnsafeEnabled {
|
||||
mi := &file_parkour_parkour_msg_proto_msgTypes[32]
|
||||
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
||||
ms.StoreMessageInfo(mi)
|
||||
}
|
||||
}
|
||||
|
||||
func (x *ParkourReconnectRoomReq) String() string {
|
||||
return protoimpl.X.MessageStringOf(x)
|
||||
}
|
||||
|
||||
func (*ParkourReconnectRoomReq) ProtoMessage() {}
|
||||
|
||||
func (x *ParkourReconnectRoomReq) ProtoReflect() protoreflect.Message {
|
||||
mi := &file_parkour_parkour_msg_proto_msgTypes[32]
|
||||
if protoimpl.UnsafeEnabled && x != nil {
|
||||
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
||||
if ms.LoadMessageInfo() == nil {
|
||||
ms.StoreMessageInfo(mi)
|
||||
}
|
||||
return ms
|
||||
}
|
||||
return mi.MessageOf(x)
|
||||
}
|
||||
|
||||
// Deprecated: Use ParkourReconnectRoomReq.ProtoReflect.Descriptor instead.
|
||||
func (*ParkourReconnectRoomReq) Descriptor() ([]byte, []int) {
|
||||
return file_parkour_parkour_msg_proto_rawDescGZIP(), []int{32}
|
||||
}
|
||||
|
||||
func (x *ParkourReconnectRoomReq) GetBattleid() string {
|
||||
if x != nil {
|
||||
return x.Battleid
|
||||
}
|
||||
return ""
|
||||
}
|
||||
|
||||
type ParkourReconnectRoomResp struct {
|
||||
state protoimpl.MessageState
|
||||
sizeCache protoimpl.SizeCache
|
||||
unknownFields protoimpl.UnknownFields
|
||||
|
||||
Race *DBRace `protobuf:"bytes,1,opt,name=race,proto3" json:"race"`
|
||||
}
|
||||
|
||||
func (x *ParkourReconnectRoomResp) Reset() {
|
||||
*x = ParkourReconnectRoomResp{}
|
||||
if protoimpl.UnsafeEnabled {
|
||||
mi := &file_parkour_parkour_msg_proto_msgTypes[33]
|
||||
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
||||
ms.StoreMessageInfo(mi)
|
||||
}
|
||||
}
|
||||
|
||||
func (x *ParkourReconnectRoomResp) String() string {
|
||||
return protoimpl.X.MessageStringOf(x)
|
||||
}
|
||||
|
||||
func (*ParkourReconnectRoomResp) ProtoMessage() {}
|
||||
|
||||
func (x *ParkourReconnectRoomResp) ProtoReflect() protoreflect.Message {
|
||||
mi := &file_parkour_parkour_msg_proto_msgTypes[33]
|
||||
if protoimpl.UnsafeEnabled && x != nil {
|
||||
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
||||
if ms.LoadMessageInfo() == nil {
|
||||
ms.StoreMessageInfo(mi)
|
||||
}
|
||||
return ms
|
||||
}
|
||||
return mi.MessageOf(x)
|
||||
}
|
||||
|
||||
// Deprecated: Use ParkourReconnectRoomResp.ProtoReflect.Descriptor instead.
|
||||
func (*ParkourReconnectRoomResp) Descriptor() ([]byte, []int) {
|
||||
return file_parkour_parkour_msg_proto_rawDescGZIP(), []int{33}
|
||||
}
|
||||
|
||||
func (x *ParkourReconnectRoomResp) GetRace() *DBRace {
|
||||
if x != nil {
|
||||
return x.Race
|
||||
}
|
||||
return nil
|
||||
}
|
||||
|
||||
//服务端协议--------------------------------------------------------------------------------------------------------------------------
|
||||
///匹配请求 RPC消息定义 服务器自用 客户端不用理会
|
||||
type RPCParkourJoinMatchReq struct {
|
||||
@ -1706,7 +1801,7 @@ type RPCParkourJoinMatchReq struct {
|
||||
func (x *RPCParkourJoinMatchReq) Reset() {
|
||||
*x = RPCParkourJoinMatchReq{}
|
||||
if protoimpl.UnsafeEnabled {
|
||||
mi := &file_parkour_parkour_msg_proto_msgTypes[32]
|
||||
mi := &file_parkour_parkour_msg_proto_msgTypes[34]
|
||||
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
||||
ms.StoreMessageInfo(mi)
|
||||
}
|
||||
@ -1719,7 +1814,7 @@ func (x *RPCParkourJoinMatchReq) String() string {
|
||||
func (*RPCParkourJoinMatchReq) ProtoMessage() {}
|
||||
|
||||
func (x *RPCParkourJoinMatchReq) ProtoReflect() protoreflect.Message {
|
||||
mi := &file_parkour_parkour_msg_proto_msgTypes[32]
|
||||
mi := &file_parkour_parkour_msg_proto_msgTypes[34]
|
||||
if protoimpl.UnsafeEnabled && x != nil {
|
||||
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
||||
if ms.LoadMessageInfo() == nil {
|
||||
@ -1732,7 +1827,7 @@ func (x *RPCParkourJoinMatchReq) ProtoReflect() protoreflect.Message {
|
||||
|
||||
// Deprecated: Use RPCParkourJoinMatchReq.ProtoReflect.Descriptor instead.
|
||||
func (*RPCParkourJoinMatchReq) Descriptor() ([]byte, []int) {
|
||||
return file_parkour_parkour_msg_proto_rawDescGZIP(), []int{32}
|
||||
return file_parkour_parkour_msg_proto_rawDescGZIP(), []int{34}
|
||||
}
|
||||
|
||||
func (x *RPCParkourJoinMatchReq) GetCaptainid() string {
|
||||
@ -1766,7 +1861,7 @@ type RPCParkourJoinMatchResp struct {
|
||||
func (x *RPCParkourJoinMatchResp) Reset() {
|
||||
*x = RPCParkourJoinMatchResp{}
|
||||
if protoimpl.UnsafeEnabled {
|
||||
mi := &file_parkour_parkour_msg_proto_msgTypes[33]
|
||||
mi := &file_parkour_parkour_msg_proto_msgTypes[35]
|
||||
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
||||
ms.StoreMessageInfo(mi)
|
||||
}
|
||||
@ -1779,7 +1874,7 @@ func (x *RPCParkourJoinMatchResp) String() string {
|
||||
func (*RPCParkourJoinMatchResp) ProtoMessage() {}
|
||||
|
||||
func (x *RPCParkourJoinMatchResp) ProtoReflect() protoreflect.Message {
|
||||
mi := &file_parkour_parkour_msg_proto_msgTypes[33]
|
||||
mi := &file_parkour_parkour_msg_proto_msgTypes[35]
|
||||
if protoimpl.UnsafeEnabled && x != nil {
|
||||
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
||||
if ms.LoadMessageInfo() == nil {
|
||||
@ -1792,7 +1887,7 @@ func (x *RPCParkourJoinMatchResp) ProtoReflect() protoreflect.Message {
|
||||
|
||||
// Deprecated: Use RPCParkourJoinMatchResp.ProtoReflect.Descriptor instead.
|
||||
func (*RPCParkourJoinMatchResp) Descriptor() ([]byte, []int) {
|
||||
return file_parkour_parkour_msg_proto_rawDescGZIP(), []int{33}
|
||||
return file_parkour_parkour_msg_proto_rawDescGZIP(), []int{35}
|
||||
}
|
||||
|
||||
//取消匹配
|
||||
@ -1807,7 +1902,7 @@ type RPCParkourCancelMatchReq struct {
|
||||
func (x *RPCParkourCancelMatchReq) Reset() {
|
||||
*x = RPCParkourCancelMatchReq{}
|
||||
if protoimpl.UnsafeEnabled {
|
||||
mi := &file_parkour_parkour_msg_proto_msgTypes[34]
|
||||
mi := &file_parkour_parkour_msg_proto_msgTypes[36]
|
||||
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
||||
ms.StoreMessageInfo(mi)
|
||||
}
|
||||
@ -1820,7 +1915,7 @@ func (x *RPCParkourCancelMatchReq) String() string {
|
||||
func (*RPCParkourCancelMatchReq) ProtoMessage() {}
|
||||
|
||||
func (x *RPCParkourCancelMatchReq) ProtoReflect() protoreflect.Message {
|
||||
mi := &file_parkour_parkour_msg_proto_msgTypes[34]
|
||||
mi := &file_parkour_parkour_msg_proto_msgTypes[36]
|
||||
if protoimpl.UnsafeEnabled && x != nil {
|
||||
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
||||
if ms.LoadMessageInfo() == nil {
|
||||
@ -1833,7 +1928,7 @@ func (x *RPCParkourCancelMatchReq) ProtoReflect() protoreflect.Message {
|
||||
|
||||
// Deprecated: Use RPCParkourCancelMatchReq.ProtoReflect.Descriptor instead.
|
||||
func (*RPCParkourCancelMatchReq) Descriptor() ([]byte, []int) {
|
||||
return file_parkour_parkour_msg_proto_rawDescGZIP(), []int{34}
|
||||
return file_parkour_parkour_msg_proto_rawDescGZIP(), []int{36}
|
||||
}
|
||||
|
||||
func (x *RPCParkourCancelMatchReq) GetCaptainid() string {
|
||||
@ -1852,7 +1947,7 @@ type RPCParkourCancelMatchResp struct {
|
||||
func (x *RPCParkourCancelMatchResp) Reset() {
|
||||
*x = RPCParkourCancelMatchResp{}
|
||||
if protoimpl.UnsafeEnabled {
|
||||
mi := &file_parkour_parkour_msg_proto_msgTypes[35]
|
||||
mi := &file_parkour_parkour_msg_proto_msgTypes[37]
|
||||
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
||||
ms.StoreMessageInfo(mi)
|
||||
}
|
||||
@ -1865,7 +1960,7 @@ func (x *RPCParkourCancelMatchResp) String() string {
|
||||
func (*RPCParkourCancelMatchResp) ProtoMessage() {}
|
||||
|
||||
func (x *RPCParkourCancelMatchResp) ProtoReflect() protoreflect.Message {
|
||||
mi := &file_parkour_parkour_msg_proto_msgTypes[35]
|
||||
mi := &file_parkour_parkour_msg_proto_msgTypes[37]
|
||||
if protoimpl.UnsafeEnabled && x != nil {
|
||||
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
||||
if ms.LoadMessageInfo() == nil {
|
||||
@ -1878,7 +1973,7 @@ func (x *RPCParkourCancelMatchResp) ProtoReflect() protoreflect.Message {
|
||||
|
||||
// Deprecated: Use RPCParkourCancelMatchResp.ProtoReflect.Descriptor instead.
|
||||
func (*RPCParkourCancelMatchResp) Descriptor() ([]byte, []int) {
|
||||
return file_parkour_parkour_msg_proto_rawDescGZIP(), []int{35}
|
||||
return file_parkour_parkour_msg_proto_rawDescGZIP(), []int{37}
|
||||
}
|
||||
|
||||
///匹配成功通知请求
|
||||
@ -1894,7 +1989,7 @@ type RPCParkourMatchSuccReq struct {
|
||||
func (x *RPCParkourMatchSuccReq) Reset() {
|
||||
*x = RPCParkourMatchSuccReq{}
|
||||
if protoimpl.UnsafeEnabled {
|
||||
mi := &file_parkour_parkour_msg_proto_msgTypes[36]
|
||||
mi := &file_parkour_parkour_msg_proto_msgTypes[38]
|
||||
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
||||
ms.StoreMessageInfo(mi)
|
||||
}
|
||||
@ -1907,7 +2002,7 @@ func (x *RPCParkourMatchSuccReq) String() string {
|
||||
func (*RPCParkourMatchSuccReq) ProtoMessage() {}
|
||||
|
||||
func (x *RPCParkourMatchSuccReq) ProtoReflect() protoreflect.Message {
|
||||
mi := &file_parkour_parkour_msg_proto_msgTypes[36]
|
||||
mi := &file_parkour_parkour_msg_proto_msgTypes[38]
|
||||
if protoimpl.UnsafeEnabled && x != nil {
|
||||
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
||||
if ms.LoadMessageInfo() == nil {
|
||||
@ -1920,7 +2015,7 @@ func (x *RPCParkourMatchSuccReq) ProtoReflect() protoreflect.Message {
|
||||
|
||||
// Deprecated: Use RPCParkourMatchSuccReq.ProtoReflect.Descriptor instead.
|
||||
func (*RPCParkourMatchSuccReq) Descriptor() ([]byte, []int) {
|
||||
return file_parkour_parkour_msg_proto_rawDescGZIP(), []int{36}
|
||||
return file_parkour_parkour_msg_proto_rawDescGZIP(), []int{38}
|
||||
}
|
||||
|
||||
func (x *RPCParkourMatchSuccReq) GetRed() []*DBRaceMember {
|
||||
@ -1947,7 +2042,7 @@ type RPCParkourMatchSuccResp struct {
|
||||
func (x *RPCParkourMatchSuccResp) Reset() {
|
||||
*x = RPCParkourMatchSuccResp{}
|
||||
if protoimpl.UnsafeEnabled {
|
||||
mi := &file_parkour_parkour_msg_proto_msgTypes[37]
|
||||
mi := &file_parkour_parkour_msg_proto_msgTypes[39]
|
||||
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
||||
ms.StoreMessageInfo(mi)
|
||||
}
|
||||
@ -1960,7 +2055,7 @@ func (x *RPCParkourMatchSuccResp) String() string {
|
||||
func (*RPCParkourMatchSuccResp) ProtoMessage() {}
|
||||
|
||||
func (x *RPCParkourMatchSuccResp) ProtoReflect() protoreflect.Message {
|
||||
mi := &file_parkour_parkour_msg_proto_msgTypes[37]
|
||||
mi := &file_parkour_parkour_msg_proto_msgTypes[39]
|
||||
if protoimpl.UnsafeEnabled && x != nil {
|
||||
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
||||
if ms.LoadMessageInfo() == nil {
|
||||
@ -1973,7 +2068,7 @@ func (x *RPCParkourMatchSuccResp) ProtoReflect() protoreflect.Message {
|
||||
|
||||
// Deprecated: Use RPCParkourMatchSuccResp.ProtoReflect.Descriptor instead.
|
||||
func (*RPCParkourMatchSuccResp) Descriptor() ([]byte, []int) {
|
||||
return file_parkour_parkour_msg_proto_rawDescGZIP(), []int{37}
|
||||
return file_parkour_parkour_msg_proto_rawDescGZIP(), []int{39}
|
||||
}
|
||||
|
||||
//托管求情
|
||||
@ -1989,7 +2084,7 @@ type RPC_ParkourTrusteeshipReq struct {
|
||||
func (x *RPC_ParkourTrusteeshipReq) Reset() {
|
||||
*x = RPC_ParkourTrusteeshipReq{}
|
||||
if protoimpl.UnsafeEnabled {
|
||||
mi := &file_parkour_parkour_msg_proto_msgTypes[38]
|
||||
mi := &file_parkour_parkour_msg_proto_msgTypes[40]
|
||||
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
||||
ms.StoreMessageInfo(mi)
|
||||
}
|
||||
@ -2002,7 +2097,7 @@ func (x *RPC_ParkourTrusteeshipReq) String() string {
|
||||
func (*RPC_ParkourTrusteeshipReq) ProtoMessage() {}
|
||||
|
||||
func (x *RPC_ParkourTrusteeshipReq) ProtoReflect() protoreflect.Message {
|
||||
mi := &file_parkour_parkour_msg_proto_msgTypes[38]
|
||||
mi := &file_parkour_parkour_msg_proto_msgTypes[40]
|
||||
if protoimpl.UnsafeEnabled && x != nil {
|
||||
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
||||
if ms.LoadMessageInfo() == nil {
|
||||
@ -2015,7 +2110,7 @@ func (x *RPC_ParkourTrusteeshipReq) ProtoReflect() protoreflect.Message {
|
||||
|
||||
// Deprecated: Use RPC_ParkourTrusteeshipReq.ProtoReflect.Descriptor instead.
|
||||
func (*RPC_ParkourTrusteeshipReq) Descriptor() ([]byte, []int) {
|
||||
return file_parkour_parkour_msg_proto_rawDescGZIP(), []int{38}
|
||||
return file_parkour_parkour_msg_proto_rawDescGZIP(), []int{40}
|
||||
}
|
||||
|
||||
func (x *RPC_ParkourTrusteeshipReq) GetBattleid() string {
|
||||
@ -2041,7 +2136,7 @@ type RPC_ParkourTrusteeshipResp struct {
|
||||
func (x *RPC_ParkourTrusteeshipResp) Reset() {
|
||||
*x = RPC_ParkourTrusteeshipResp{}
|
||||
if protoimpl.UnsafeEnabled {
|
||||
mi := &file_parkour_parkour_msg_proto_msgTypes[39]
|
||||
mi := &file_parkour_parkour_msg_proto_msgTypes[41]
|
||||
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
||||
ms.StoreMessageInfo(mi)
|
||||
}
|
||||
@ -2054,7 +2149,7 @@ func (x *RPC_ParkourTrusteeshipResp) String() string {
|
||||
func (*RPC_ParkourTrusteeshipResp) ProtoMessage() {}
|
||||
|
||||
func (x *RPC_ParkourTrusteeshipResp) ProtoReflect() protoreflect.Message {
|
||||
mi := &file_parkour_parkour_msg_proto_msgTypes[39]
|
||||
mi := &file_parkour_parkour_msg_proto_msgTypes[41]
|
||||
if protoimpl.UnsafeEnabled && x != nil {
|
||||
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
||||
if ms.LoadMessageInfo() == nil {
|
||||
@ -2067,7 +2162,7 @@ func (x *RPC_ParkourTrusteeshipResp) ProtoReflect() protoreflect.Message {
|
||||
|
||||
// Deprecated: Use RPC_ParkourTrusteeshipResp.ProtoReflect.Descriptor instead.
|
||||
func (*RPC_ParkourTrusteeshipResp) Descriptor() ([]byte, []int) {
|
||||
return file_parkour_parkour_msg_proto_rawDescGZIP(), []int{39}
|
||||
return file_parkour_parkour_msg_proto_rawDescGZIP(), []int{41}
|
||||
}
|
||||
|
||||
var File_parkour_parkour_msg_proto protoreflect.FileDescriptor
|
||||
@ -2210,7 +2305,14 @@ var file_parkour_parkour_msg_proto_rawDesc = []byte{
|
||||
0x72, 0x65, 0x77, 0x61, 0x72, 0x64, 0x45, 0x6e, 0x74, 0x72, 0x79, 0x12, 0x10, 0x0a, 0x03, 0x6b,
|
||||
0x65, 0x79, 0x18, 0x01, 0x20, 0x01, 0x28, 0x05, 0x52, 0x03, 0x6b, 0x65, 0x79, 0x12, 0x14, 0x0a,
|
||||
0x05, 0x76, 0x61, 0x6c, 0x75, 0x65, 0x18, 0x02, 0x20, 0x01, 0x28, 0x08, 0x52, 0x05, 0x76, 0x61,
|
||||
0x6c, 0x75, 0x65, 0x3a, 0x02, 0x38, 0x01, 0x22, 0x7e, 0x0a, 0x16, 0x52, 0x50, 0x43, 0x50, 0x61,
|
||||
0x6c, 0x75, 0x65, 0x3a, 0x02, 0x38, 0x01, 0x22, 0x35, 0x0a, 0x17, 0x50, 0x61, 0x72, 0x6b, 0x6f,
|
||||
0x75, 0x72, 0x52, 0x65, 0x63, 0x6f, 0x6e, 0x6e, 0x65, 0x63, 0x74, 0x52, 0x6f, 0x6f, 0x6d, 0x52,
|
||||
0x65, 0x71, 0x12, 0x1a, 0x0a, 0x08, 0x62, 0x61, 0x74, 0x74, 0x6c, 0x65, 0x69, 0x64, 0x18, 0x01,
|
||||
0x20, 0x01, 0x28, 0x09, 0x52, 0x08, 0x62, 0x61, 0x74, 0x74, 0x6c, 0x65, 0x69, 0x64, 0x22, 0x37,
|
||||
0x0a, 0x18, 0x50, 0x61, 0x72, 0x6b, 0x6f, 0x75, 0x72, 0x52, 0x65, 0x63, 0x6f, 0x6e, 0x6e, 0x65,
|
||||
0x63, 0x74, 0x52, 0x6f, 0x6f, 0x6d, 0x52, 0x65, 0x73, 0x70, 0x12, 0x1b, 0x0a, 0x04, 0x72, 0x61,
|
||||
0x63, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x07, 0x2e, 0x44, 0x42, 0x52, 0x61, 0x63,
|
||||
0x65, 0x52, 0x04, 0x72, 0x61, 0x63, 0x65, 0x22, 0x7e, 0x0a, 0x16, 0x52, 0x50, 0x43, 0x50, 0x61,
|
||||
0x72, 0x6b, 0x6f, 0x75, 0x72, 0x4a, 0x6f, 0x69, 0x6e, 0x4d, 0x61, 0x74, 0x63, 0x68, 0x52, 0x65,
|
||||
0x71, 0x12, 0x1c, 0x0a, 0x09, 0x63, 0x61, 0x70, 0x74, 0x61, 0x69, 0x6e, 0x69, 0x64, 0x18, 0x01,
|
||||
0x20, 0x01, 0x28, 0x09, 0x52, 0x09, 0x63, 0x61, 0x70, 0x74, 0x61, 0x69, 0x6e, 0x69, 0x64, 0x12,
|
||||
@ -2255,7 +2357,7 @@ func file_parkour_parkour_msg_proto_rawDescGZIP() []byte {
|
||||
return file_parkour_parkour_msg_proto_rawDescData
|
||||
}
|
||||
|
||||
var file_parkour_parkour_msg_proto_msgTypes = make([]protoimpl.MessageInfo, 41)
|
||||
var file_parkour_parkour_msg_proto_msgTypes = make([]protoimpl.MessageInfo, 43)
|
||||
var file_parkour_parkour_msg_proto_goTypes = []interface{}{
|
||||
(*ParkourInfoReq)(nil), // 0: ParkourInfoReq
|
||||
(*ParkourInfoResp)(nil), // 1: ParkourInfoResp
|
||||
@ -2289,41 +2391,44 @@ var file_parkour_parkour_msg_proto_goTypes = []interface{}{
|
||||
(*ParkourWeekRewardResp)(nil), // 29: ParkourWeekRewardResp
|
||||
(*ParkourAllWeekRewardReq)(nil), // 30: ParkourAllWeekRewardReq
|
||||
(*ParkourAllWeekRewardResp)(nil), // 31: ParkourAllWeekRewardResp
|
||||
(*RPCParkourJoinMatchReq)(nil), // 32: RPCParkourJoinMatchReq
|
||||
(*RPCParkourJoinMatchResp)(nil), // 33: RPCParkourJoinMatchResp
|
||||
(*RPCParkourCancelMatchReq)(nil), // 34: RPCParkourCancelMatchReq
|
||||
(*RPCParkourCancelMatchResp)(nil), // 35: RPCParkourCancelMatchResp
|
||||
(*RPCParkourMatchSuccReq)(nil), // 36: RPCParkourMatchSuccReq
|
||||
(*RPCParkourMatchSuccResp)(nil), // 37: RPCParkourMatchSuccResp
|
||||
(*RPC_ParkourTrusteeshipReq)(nil), // 38: RPC_ParkourTrusteeshipReq
|
||||
(*RPC_ParkourTrusteeshipResp)(nil), // 39: RPC_ParkourTrusteeshipResp
|
||||
nil, // 40: ParkourAllWeekRewardResp.WeekrewardEntry
|
||||
(*DBParkour)(nil), // 41: DBParkour
|
||||
(RaceType)(0), // 42: RaceType
|
||||
(*DBRace)(nil), // 43: DBRace
|
||||
(*UserAtno)(nil), // 44: UserAtno
|
||||
(*DBRaceMember)(nil), // 45: DBRaceMember
|
||||
(*ParkourReconnectRoomReq)(nil), // 32: ParkourReconnectRoomReq
|
||||
(*ParkourReconnectRoomResp)(nil), // 33: ParkourReconnectRoomResp
|
||||
(*RPCParkourJoinMatchReq)(nil), // 34: RPCParkourJoinMatchReq
|
||||
(*RPCParkourJoinMatchResp)(nil), // 35: RPCParkourJoinMatchResp
|
||||
(*RPCParkourCancelMatchReq)(nil), // 36: RPCParkourCancelMatchReq
|
||||
(*RPCParkourCancelMatchResp)(nil), // 37: RPCParkourCancelMatchResp
|
||||
(*RPCParkourMatchSuccReq)(nil), // 38: RPCParkourMatchSuccReq
|
||||
(*RPCParkourMatchSuccResp)(nil), // 39: RPCParkourMatchSuccResp
|
||||
(*RPC_ParkourTrusteeshipReq)(nil), // 40: RPC_ParkourTrusteeshipReq
|
||||
(*RPC_ParkourTrusteeshipResp)(nil), // 41: RPC_ParkourTrusteeshipResp
|
||||
nil, // 42: ParkourAllWeekRewardResp.WeekrewardEntry
|
||||
(*DBParkour)(nil), // 43: DBParkour
|
||||
(RaceType)(0), // 44: RaceType
|
||||
(*DBRace)(nil), // 45: DBRace
|
||||
(*UserAtno)(nil), // 46: UserAtno
|
||||
(*DBRaceMember)(nil), // 47: DBRaceMember
|
||||
}
|
||||
var file_parkour_parkour_msg_proto_depIdxs = []int32{
|
||||
41, // 0: ParkourInfoResp.info:type_name -> DBParkour
|
||||
42, // 1: ParkourRaceMatchReq.rtype:type_name -> RaceType
|
||||
42, // 2: ParkourRaceMatchCancelReq.rtype:type_name -> RaceType
|
||||
43, // 3: ParkourRaceMatchSuccPush.race:type_name -> DBRace
|
||||
41, // 4: ParkourInfoChangePush.Info:type_name -> DBParkour
|
||||
43, // 5: ParkourRaceOverPush.race:type_name -> DBRace
|
||||
44, // 6: ParkourRaceOverPush.award:type_name -> UserAtno
|
||||
44, // 7: ParkourWeekRewardResp.award:type_name -> UserAtno
|
||||
40, // 8: ParkourAllWeekRewardResp.weekreward:type_name -> ParkourAllWeekRewardResp.WeekrewardEntry
|
||||
44, // 9: ParkourAllWeekRewardResp.award:type_name -> UserAtno
|
||||
45, // 10: RPCParkourJoinMatchReq.member:type_name -> DBRaceMember
|
||||
45, // 11: RPCParkourJoinMatchReq.ais:type_name -> DBRaceMember
|
||||
45, // 12: RPCParkourMatchSuccReq.red:type_name -> DBRaceMember
|
||||
45, // 13: RPCParkourMatchSuccReq.bule:type_name -> DBRaceMember
|
||||
14, // [14:14] is the sub-list for method output_type
|
||||
14, // [14:14] is the sub-list for method input_type
|
||||
14, // [14:14] is the sub-list for extension type_name
|
||||
14, // [14:14] is the sub-list for extension extendee
|
||||
0, // [0:14] is the sub-list for field type_name
|
||||
43, // 0: ParkourInfoResp.info:type_name -> DBParkour
|
||||
44, // 1: ParkourRaceMatchReq.rtype:type_name -> RaceType
|
||||
44, // 2: ParkourRaceMatchCancelReq.rtype:type_name -> RaceType
|
||||
45, // 3: ParkourRaceMatchSuccPush.race:type_name -> DBRace
|
||||
43, // 4: ParkourInfoChangePush.Info:type_name -> DBParkour
|
||||
45, // 5: ParkourRaceOverPush.race:type_name -> DBRace
|
||||
46, // 6: ParkourRaceOverPush.award:type_name -> UserAtno
|
||||
46, // 7: ParkourWeekRewardResp.award:type_name -> UserAtno
|
||||
42, // 8: ParkourAllWeekRewardResp.weekreward:type_name -> ParkourAllWeekRewardResp.WeekrewardEntry
|
||||
46, // 9: ParkourAllWeekRewardResp.award:type_name -> UserAtno
|
||||
45, // 10: ParkourReconnectRoomResp.race:type_name -> DBRace
|
||||
47, // 11: RPCParkourJoinMatchReq.member:type_name -> DBRaceMember
|
||||
47, // 12: RPCParkourJoinMatchReq.ais:type_name -> DBRaceMember
|
||||
47, // 13: RPCParkourMatchSuccReq.red:type_name -> DBRaceMember
|
||||
47, // 14: RPCParkourMatchSuccReq.bule:type_name -> DBRaceMember
|
||||
15, // [15:15] is the sub-list for method output_type
|
||||
15, // [15:15] is the sub-list for method input_type
|
||||
15, // [15:15] is the sub-list for extension type_name
|
||||
15, // [15:15] is the sub-list for extension extendee
|
||||
0, // [0:15] is the sub-list for field type_name
|
||||
}
|
||||
|
||||
func init() { file_parkour_parkour_msg_proto_init() }
|
||||
@ -2719,7 +2824,7 @@ func file_parkour_parkour_msg_proto_init() {
|
||||
}
|
||||
}
|
||||
file_parkour_parkour_msg_proto_msgTypes[32].Exporter = func(v interface{}, i int) interface{} {
|
||||
switch v := v.(*RPCParkourJoinMatchReq); i {
|
||||
switch v := v.(*ParkourReconnectRoomReq); i {
|
||||
case 0:
|
||||
return &v.state
|
||||
case 1:
|
||||
@ -2731,7 +2836,7 @@ func file_parkour_parkour_msg_proto_init() {
|
||||
}
|
||||
}
|
||||
file_parkour_parkour_msg_proto_msgTypes[33].Exporter = func(v interface{}, i int) interface{} {
|
||||
switch v := v.(*RPCParkourJoinMatchResp); i {
|
||||
switch v := v.(*ParkourReconnectRoomResp); i {
|
||||
case 0:
|
||||
return &v.state
|
||||
case 1:
|
||||
@ -2743,7 +2848,7 @@ func file_parkour_parkour_msg_proto_init() {
|
||||
}
|
||||
}
|
||||
file_parkour_parkour_msg_proto_msgTypes[34].Exporter = func(v interface{}, i int) interface{} {
|
||||
switch v := v.(*RPCParkourCancelMatchReq); i {
|
||||
switch v := v.(*RPCParkourJoinMatchReq); i {
|
||||
case 0:
|
||||
return &v.state
|
||||
case 1:
|
||||
@ -2755,7 +2860,7 @@ func file_parkour_parkour_msg_proto_init() {
|
||||
}
|
||||
}
|
||||
file_parkour_parkour_msg_proto_msgTypes[35].Exporter = func(v interface{}, i int) interface{} {
|
||||
switch v := v.(*RPCParkourCancelMatchResp); i {
|
||||
switch v := v.(*RPCParkourJoinMatchResp); i {
|
||||
case 0:
|
||||
return &v.state
|
||||
case 1:
|
||||
@ -2767,7 +2872,7 @@ func file_parkour_parkour_msg_proto_init() {
|
||||
}
|
||||
}
|
||||
file_parkour_parkour_msg_proto_msgTypes[36].Exporter = func(v interface{}, i int) interface{} {
|
||||
switch v := v.(*RPCParkourMatchSuccReq); i {
|
||||
switch v := v.(*RPCParkourCancelMatchReq); i {
|
||||
case 0:
|
||||
return &v.state
|
||||
case 1:
|
||||
@ -2779,7 +2884,7 @@ func file_parkour_parkour_msg_proto_init() {
|
||||
}
|
||||
}
|
||||
file_parkour_parkour_msg_proto_msgTypes[37].Exporter = func(v interface{}, i int) interface{} {
|
||||
switch v := v.(*RPCParkourMatchSuccResp); i {
|
||||
switch v := v.(*RPCParkourCancelMatchResp); i {
|
||||
case 0:
|
||||
return &v.state
|
||||
case 1:
|
||||
@ -2791,7 +2896,7 @@ func file_parkour_parkour_msg_proto_init() {
|
||||
}
|
||||
}
|
||||
file_parkour_parkour_msg_proto_msgTypes[38].Exporter = func(v interface{}, i int) interface{} {
|
||||
switch v := v.(*RPC_ParkourTrusteeshipReq); i {
|
||||
switch v := v.(*RPCParkourMatchSuccReq); i {
|
||||
case 0:
|
||||
return &v.state
|
||||
case 1:
|
||||
@ -2803,6 +2908,30 @@ func file_parkour_parkour_msg_proto_init() {
|
||||
}
|
||||
}
|
||||
file_parkour_parkour_msg_proto_msgTypes[39].Exporter = func(v interface{}, i int) interface{} {
|
||||
switch v := v.(*RPCParkourMatchSuccResp); i {
|
||||
case 0:
|
||||
return &v.state
|
||||
case 1:
|
||||
return &v.sizeCache
|
||||
case 2:
|
||||
return &v.unknownFields
|
||||
default:
|
||||
return nil
|
||||
}
|
||||
}
|
||||
file_parkour_parkour_msg_proto_msgTypes[40].Exporter = func(v interface{}, i int) interface{} {
|
||||
switch v := v.(*RPC_ParkourTrusteeshipReq); i {
|
||||
case 0:
|
||||
return &v.state
|
||||
case 1:
|
||||
return &v.sizeCache
|
||||
case 2:
|
||||
return &v.unknownFields
|
||||
default:
|
||||
return nil
|
||||
}
|
||||
}
|
||||
file_parkour_parkour_msg_proto_msgTypes[41].Exporter = func(v interface{}, i int) interface{} {
|
||||
switch v := v.(*RPC_ParkourTrusteeshipResp); i {
|
||||
case 0:
|
||||
return &v.state
|
||||
@ -2821,7 +2950,7 @@ func file_parkour_parkour_msg_proto_init() {
|
||||
GoPackagePath: reflect.TypeOf(x{}).PkgPath(),
|
||||
RawDescriptor: file_parkour_parkour_msg_proto_rawDesc,
|
||||
NumEnums: 0,
|
||||
NumMessages: 41,
|
||||
NumMessages: 43,
|
||||
NumExtensions: 0,
|
||||
NumServices: 0,
|
||||
},
|
||||
|
||||
Loading…
Reference in New Issue
Block a user