api.pb.go 87 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119112011211122112311241125112611271128112911301131113211331134113511361137113811391140114111421143114411451146114711481149115011511152115311541155115611571158115911601161116211631164116511661167116811691170117111721173117411751176117711781179118011811182118311841185118611871188118911901191119211931194119511961197119811991200120112021203120412051206120712081209121012111212121312141215121612171218121912201221122212231224122512261227122812291230123112321233123412351236123712381239124012411242124312441245124612471248124912501251125212531254125512561257125812591260126112621263126412651266126712681269127012711272127312741275127612771278127912801281128212831284128512861287128812891290129112921293129412951296129712981299130013011302130313041305130613071308130913101311131213131314131513161317131813191320132113221323132413251326132713281329133013311332133313341335133613371338133913401341134213431344134513461347134813491350135113521353135413551356135713581359136013611362136313641365136613671368136913701371137213731374137513761377137813791380138113821383138413851386138713881389139013911392139313941395139613971398139914001401140214031404140514061407140814091410141114121413141414151416141714181419142014211422142314241425142614271428142914301431143214331434143514361437143814391440144114421443144414451446144714481449145014511452145314541455145614571458145914601461146214631464146514661467146814691470147114721473147414751476147714781479148014811482148314841485148614871488148914901491149214931494149514961497149814991500150115021503150415051506150715081509151015111512151315141515151615171518151915201521152215231524152515261527152815291530153115321533153415351536153715381539154015411542154315441545154615471548154915501551155215531554155515561557155815591560156115621563156415651566156715681569157015711572157315741575157615771578157915801581158215831584158515861587158815891590159115921593159415951596159715981599160016011602160316041605160616071608160916101611161216131614161516161617161816191620162116221623162416251626162716281629163016311632163316341635163616371638163916401641164216431644164516461647164816491650165116521653165416551656165716581659166016611662166316641665166616671668166916701671167216731674167516761677167816791680168116821683168416851686168716881689169016911692169316941695169616971698169917001701170217031704170517061707170817091710171117121713171417151716171717181719172017211722172317241725172617271728172917301731173217331734173517361737173817391740174117421743174417451746174717481749175017511752175317541755175617571758175917601761176217631764176517661767176817691770177117721773177417751776177717781779178017811782178317841785178617871788178917901791179217931794179517961797179817991800180118021803180418051806180718081809181018111812181318141815181618171818181918201821182218231824182518261827182818291830183118321833183418351836183718381839184018411842184318441845184618471848184918501851185218531854185518561857185818591860186118621863186418651866186718681869187018711872187318741875187618771878187918801881188218831884188518861887188818891890189118921893189418951896189718981899190019011902190319041905190619071908190919101911191219131914191519161917191819191920192119221923192419251926192719281929193019311932193319341935193619371938193919401941194219431944194519461947194819491950195119521953195419551956195719581959196019611962196319641965196619671968196919701971197219731974197519761977197819791980198119821983198419851986198719881989199019911992199319941995199619971998199920002001200220032004200520062007200820092010201120122013201420152016201720182019202020212022202320242025202620272028202920302031203220332034203520362037203820392040204120422043204420452046204720482049205020512052205320542055205620572058205920602061206220632064206520662067206820692070207120722073207420752076207720782079208020812082208320842085208620872088208920902091209220932094209520962097209820992100210121022103210421052106210721082109211021112112211321142115211621172118211921202121212221232124212521262127212821292130213121322133213421352136213721382139214021412142214321442145214621472148214921502151215221532154215521562157215821592160216121622163216421652166216721682169217021712172217321742175217621772178217921802181218221832184218521862187218821892190219121922193219421952196219721982199220022012202220322042205220622072208220922102211221222132214221522162217221822192220222122222223222422252226222722282229223022312232223322342235223622372238223922402241224222432244224522462247224822492250225122522253225422552256225722582259226022612262226322642265226622672268226922702271227222732274227522762277227822792280228122822283228422852286228722882289229022912292229322942295229622972298229923002301230223032304230523062307230823092310231123122313231423152316231723182319232023212322232323242325232623272328232923302331233223332334233523362337233823392340234123422343234423452346234723482349235023512352235323542355235623572358235923602361236223632364236523662367236823692370237123722373237423752376237723782379238023812382238323842385238623872388238923902391239223932394239523962397239823992400240124022403240424052406240724082409241024112412241324142415241624172418241924202421242224232424242524262427242824292430243124322433243424352436243724382439244024412442244324442445244624472448244924502451245224532454245524562457245824592460246124622463246424652466246724682469247024712472247324742475247624772478247924802481248224832484248524862487248824892490249124922493249424952496249724982499250025012502250325042505250625072508250925102511251225132514251525162517251825192520252125222523252425252526252725282529253025312532253325342535253625372538253925402541254225432544254525462547254825492550255125522553255425552556255725582559256025612562256325642565256625672568256925702571257225732574257525762577257825792580258125822583258425852586258725882589259025912592259325942595259625972598259926002601260226032604260526062607260826092610261126122613261426152616261726182619262026212622262326242625262626272628262926302631263226332634263526362637263826392640264126422643264426452646264726482649265026512652265326542655265626572658265926602661266226632664266526662667266826692670267126722673267426752676267726782679268026812682268326842685268626872688268926902691269226932694269526962697269826992700270127022703270427052706270727082709271027112712271327142715271627172718271927202721272227232724272527262727272827292730273127322733273427352736273727382739274027412742274327442745274627472748274927502751275227532754275527562757275827592760276127622763276427652766276727682769277027712772277327742775277627772778277927802781278227832784278527862787278827892790279127922793279427952796279727982799280028012802280328042805280628072808280928102811281228132814281528162817281828192820282128222823282428252826282728282829283028312832283328342835283628372838283928402841284228432844284528462847284828492850285128522853285428552856285728582859286028612862286328642865286628672868286928702871287228732874287528762877287828792880288128822883288428852886288728882889289028912892289328942895289628972898289929002901290229032904290529062907290829092910291129122913291429152916291729182919292029212922292329242925292629272928292929302931293229332934293529362937293829392940294129422943294429452946294729482949295029512952295329542955295629572958295929602961296229632964296529662967296829692970297129722973297429752976297729782979298029812982298329842985298629872988298929902991299229932994299529962997299829993000300130023003300430053006300730083009301030113012301330143015301630173018301930203021302230233024302530263027302830293030303130323033303430353036303730383039304030413042304330443045304630473048304930503051305230533054305530563057305830593060306130623063306430653066306730683069307030713072307330743075307630773078307930803081308230833084308530863087308830893090309130923093309430953096309730983099310031013102310331043105310631073108310931103111311231133114311531163117311831193120312131223123312431253126312731283129313031313132313331343135313631373138313931403141314231433144314531463147314831493150315131523153315431553156315731583159316031613162316331643165316631673168316931703171317231733174317531763177317831793180318131823183318431853186318731883189319031913192319331943195319631973198319932003201320232033204320532063207320832093210321132123213321432153216321732183219322032213222322332243225322632273228322932303231323232333234323532363237323832393240324132423243324432453246324732483249325032513252325332543255325632573258325932603261326232633264326532663267326832693270327132723273327432753276327732783279328032813282328332843285328632873288328932903291329232933294329532963297329832993300330133023303330433053306330733083309331033113312331333143315331633173318331933203321332233233324332533263327332833293330333133323333333433353336333733383339334033413342334333443345334633473348334933503351335233533354335533563357335833593360336133623363336433653366336733683369337033713372337333743375337633773378337933803381338233833384338533863387338833893390339133923393339433953396339733983399340034013402340334043405340634073408340934103411341234133414341534163417341834193420342134223423342434253426342734283429343034313432343334343435343634373438343934403441344234433444344534463447344834493450345134523453345434553456345734583459346034613462346334643465346634673468346934703471347234733474347534763477347834793480348134823483348434853486348734883489349034913492349334943495349634973498349935003501350235033504350535063507350835093510351135123513351435153516351735183519352035213522352335243525352635273528352935303531353235333534353535363537353835393540354135423543354435453546354735483549355035513552355335543555355635573558355935603561356235633564356535663567356835693570357135723573357435753576357735783579358035813582358335843585358635873588358935903591359235933594359535963597359835993600360136023603360436053606360736083609361036113612361336143615361636173618361936203621362236233624362536263627362836293630363136323633363436353636363736383639364036413642364336443645364636473648364936503651365236533654365536563657365836593660366136623663366436653666366736683669367036713672367336743675367636773678367936803681368236833684368536863687368836893690369136923693369436953696369736983699370037013702370337043705370637073708370937103711371237133714371537163717371837193720372137223723372437253726372737283729373037313732373337343735373637373738373937403741374237433744374537463747374837493750
  1. // Code generated by protoc-gen-gogo. DO NOT EDIT.
  2. // source: app/service/main/broadcast/api/grpc/v1/api.proto
  3. /*
  4. Package v1 is a generated protocol buffer package.
  5. It is generated from these files:
  6. app/service/main/broadcast/api/grpc/v1/api.proto
  7. It has these top-level messages:
  8. CloseReply
  9. CloseReq
  10. PingReply
  11. PingReq
  12. ConnectReq
  13. ConnectReply
  14. DisconnectReq
  15. DisconnectReply
  16. HeartbeatReq
  17. HeartbeatReply
  18. OnlineReq
  19. OnlineReply
  20. ReceiveReq
  21. ReceiveReply
  22. ServerListReq
  23. ServerListReply
  24. Backoff
  25. */
  26. package v1
  27. import proto "github.com/gogo/protobuf/proto"
  28. import fmt "fmt"
  29. import math "math"
  30. import _ "github.com/gogo/protobuf/gogoproto"
  31. import push_service_broadcast_model "go-common/app/service/main/broadcast/model"
  32. import context "golang.org/x/net/context"
  33. import grpc "google.golang.org/grpc"
  34. import binary "encoding/binary"
  35. import io "io"
  36. // Reference imports to suppress errors if they are not otherwise used.
  37. var _ = proto.Marshal
  38. var _ = fmt.Errorf
  39. var _ = math.Inf
  40. // This is a compile-time assertion to ensure that this generated file
  41. // is compatible with the proto package it is being compiled against.
  42. // A compilation error at this line likely means your copy of the
  43. // proto package needs to be updated.
  44. const _ = proto.GoGoProtoPackageIsVersion2 // please upgrade the proto package
  45. type CloseReply struct {
  46. }
  47. func (m *CloseReply) Reset() { *m = CloseReply{} }
  48. func (m *CloseReply) String() string { return proto.CompactTextString(m) }
  49. func (*CloseReply) ProtoMessage() {}
  50. func (*CloseReply) Descriptor() ([]byte, []int) { return fileDescriptorApi, []int{0} }
  51. type CloseReq struct {
  52. }
  53. func (m *CloseReq) Reset() { *m = CloseReq{} }
  54. func (m *CloseReq) String() string { return proto.CompactTextString(m) }
  55. func (*CloseReq) ProtoMessage() {}
  56. func (*CloseReq) Descriptor() ([]byte, []int) { return fileDescriptorApi, []int{1} }
  57. type PingReply struct {
  58. }
  59. func (m *PingReply) Reset() { *m = PingReply{} }
  60. func (m *PingReply) String() string { return proto.CompactTextString(m) }
  61. func (*PingReply) ProtoMessage() {}
  62. func (*PingReply) Descriptor() ([]byte, []int) { return fileDescriptorApi, []int{2} }
  63. type PingReq struct {
  64. }
  65. func (m *PingReq) Reset() { *m = PingReq{} }
  66. func (m *PingReq) String() string { return proto.CompactTextString(m) }
  67. func (*PingReq) ProtoMessage() {}
  68. func (*PingReq) Descriptor() ([]byte, []int) { return fileDescriptorApi, []int{3} }
  69. type ConnectReq struct {
  70. Server string `protobuf:"bytes,1,opt,name=server,proto3" json:"server,omitempty"`
  71. ServerKey string `protobuf:"bytes,2,opt,name=serverKey,proto3" json:"serverKey,omitempty"`
  72. Cookie string `protobuf:"bytes,3,opt,name=cookie,proto3" json:"cookie,omitempty"`
  73. Token []byte `protobuf:"bytes,4,opt,name=token,proto3" json:"token,omitempty"`
  74. }
  75. func (m *ConnectReq) Reset() { *m = ConnectReq{} }
  76. func (*ConnectReq) ProtoMessage() {}
  77. func (*ConnectReq) Descriptor() ([]byte, []int) { return fileDescriptorApi, []int{4} }
  78. func (m *ConnectReq) GetServer() string {
  79. if m != nil {
  80. return m.Server
  81. }
  82. return ""
  83. }
  84. func (m *ConnectReq) GetServerKey() string {
  85. if m != nil {
  86. return m.ServerKey
  87. }
  88. return ""
  89. }
  90. func (m *ConnectReq) GetCookie() string {
  91. if m != nil {
  92. return m.Cookie
  93. }
  94. return ""
  95. }
  96. func (m *ConnectReq) GetToken() []byte {
  97. if m != nil {
  98. return m.Token
  99. }
  100. return nil
  101. }
  102. type ConnectReply struct {
  103. Mid int64 `protobuf:"varint,1,opt,name=mid,proto3" json:"mid,omitempty"`
  104. Key string `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
  105. RoomID string `protobuf:"bytes,3,opt,name=roomID,proto3" json:"roomID,omitempty"`
  106. Platform string `protobuf:"bytes,4,opt,name=platform,proto3" json:"platform,omitempty"`
  107. Accepts []int32 `protobuf:"varint,5,rep,packed,name=accepts" json:"accepts,omitempty"`
  108. }
  109. func (m *ConnectReply) Reset() { *m = ConnectReply{} }
  110. func (m *ConnectReply) String() string { return proto.CompactTextString(m) }
  111. func (*ConnectReply) ProtoMessage() {}
  112. func (*ConnectReply) Descriptor() ([]byte, []int) { return fileDescriptorApi, []int{5} }
  113. func (m *ConnectReply) GetMid() int64 {
  114. if m != nil {
  115. return m.Mid
  116. }
  117. return 0
  118. }
  119. func (m *ConnectReply) GetKey() string {
  120. if m != nil {
  121. return m.Key
  122. }
  123. return ""
  124. }
  125. func (m *ConnectReply) GetRoomID() string {
  126. if m != nil {
  127. return m.RoomID
  128. }
  129. return ""
  130. }
  131. func (m *ConnectReply) GetPlatform() string {
  132. if m != nil {
  133. return m.Platform
  134. }
  135. return ""
  136. }
  137. func (m *ConnectReply) GetAccepts() []int32 {
  138. if m != nil {
  139. return m.Accepts
  140. }
  141. return nil
  142. }
  143. type DisconnectReq struct {
  144. Mid int64 `protobuf:"varint,1,opt,name=mid,proto3" json:"mid,omitempty"`
  145. Key string `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
  146. Server string `protobuf:"bytes,3,opt,name=server,proto3" json:"server,omitempty"`
  147. }
  148. func (m *DisconnectReq) Reset() { *m = DisconnectReq{} }
  149. func (m *DisconnectReq) String() string { return proto.CompactTextString(m) }
  150. func (*DisconnectReq) ProtoMessage() {}
  151. func (*DisconnectReq) Descriptor() ([]byte, []int) { return fileDescriptorApi, []int{6} }
  152. func (m *DisconnectReq) GetMid() int64 {
  153. if m != nil {
  154. return m.Mid
  155. }
  156. return 0
  157. }
  158. func (m *DisconnectReq) GetKey() string {
  159. if m != nil {
  160. return m.Key
  161. }
  162. return ""
  163. }
  164. func (m *DisconnectReq) GetServer() string {
  165. if m != nil {
  166. return m.Server
  167. }
  168. return ""
  169. }
  170. type DisconnectReply struct {
  171. Has bool `protobuf:"varint,1,opt,name=has,proto3" json:"has,omitempty"`
  172. }
  173. func (m *DisconnectReply) Reset() { *m = DisconnectReply{} }
  174. func (m *DisconnectReply) String() string { return proto.CompactTextString(m) }
  175. func (*DisconnectReply) ProtoMessage() {}
  176. func (*DisconnectReply) Descriptor() ([]byte, []int) { return fileDescriptorApi, []int{7} }
  177. func (m *DisconnectReply) GetHas() bool {
  178. if m != nil {
  179. return m.Has
  180. }
  181. return false
  182. }
  183. type HeartbeatReq struct {
  184. Mid int64 `protobuf:"varint,1,opt,name=mid,proto3" json:"mid,omitempty"`
  185. Key string `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
  186. Server string `protobuf:"bytes,3,opt,name=server,proto3" json:"server,omitempty"`
  187. }
  188. func (m *HeartbeatReq) Reset() { *m = HeartbeatReq{} }
  189. func (m *HeartbeatReq) String() string { return proto.CompactTextString(m) }
  190. func (*HeartbeatReq) ProtoMessage() {}
  191. func (*HeartbeatReq) Descriptor() ([]byte, []int) { return fileDescriptorApi, []int{8} }
  192. func (m *HeartbeatReq) GetMid() int64 {
  193. if m != nil {
  194. return m.Mid
  195. }
  196. return 0
  197. }
  198. func (m *HeartbeatReq) GetKey() string {
  199. if m != nil {
  200. return m.Key
  201. }
  202. return ""
  203. }
  204. func (m *HeartbeatReq) GetServer() string {
  205. if m != nil {
  206. return m.Server
  207. }
  208. return ""
  209. }
  210. type HeartbeatReply struct {
  211. }
  212. func (m *HeartbeatReply) Reset() { *m = HeartbeatReply{} }
  213. func (m *HeartbeatReply) String() string { return proto.CompactTextString(m) }
  214. func (*HeartbeatReply) ProtoMessage() {}
  215. func (*HeartbeatReply) Descriptor() ([]byte, []int) { return fileDescriptorApi, []int{9} }
  216. type OnlineReq struct {
  217. Server string `protobuf:"bytes,1,opt,name=server,proto3" json:"server,omitempty"`
  218. RoomCount map[string]int32 `protobuf:"bytes,2,rep,name=roomCount" json:"roomCount,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"varint,2,opt,name=value,proto3"`
  219. Sharding int32 `protobuf:"varint,3,opt,name=sharding,proto3" json:"sharding,omitempty"`
  220. }
  221. func (m *OnlineReq) Reset() { *m = OnlineReq{} }
  222. func (*OnlineReq) ProtoMessage() {}
  223. func (*OnlineReq) Descriptor() ([]byte, []int) { return fileDescriptorApi, []int{10} }
  224. func (m *OnlineReq) GetServer() string {
  225. if m != nil {
  226. return m.Server
  227. }
  228. return ""
  229. }
  230. func (m *OnlineReq) GetRoomCount() map[string]int32 {
  231. if m != nil {
  232. return m.RoomCount
  233. }
  234. return nil
  235. }
  236. func (m *OnlineReq) GetSharding() int32 {
  237. if m != nil {
  238. return m.Sharding
  239. }
  240. return 0
  241. }
  242. type OnlineReply struct {
  243. RoomCount map[string]int32 `protobuf:"bytes,1,rep,name=roomCount" json:"roomCount,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"varint,2,opt,name=value,proto3"`
  244. }
  245. func (m *OnlineReply) Reset() { *m = OnlineReply{} }
  246. func (*OnlineReply) ProtoMessage() {}
  247. func (*OnlineReply) Descriptor() ([]byte, []int) { return fileDescriptorApi, []int{11} }
  248. func (m *OnlineReply) GetRoomCount() map[string]int32 {
  249. if m != nil {
  250. return m.RoomCount
  251. }
  252. return nil
  253. }
  254. type ReceiveReq struct {
  255. Mid int64 `protobuf:"varint,1,opt,name=mid,proto3" json:"mid,omitempty"`
  256. Proto *push_service_broadcast_model.Proto `protobuf:"bytes,2,opt,name=proto" json:"proto,omitempty"`
  257. }
  258. func (m *ReceiveReq) Reset() { *m = ReceiveReq{} }
  259. func (m *ReceiveReq) String() string { return proto.CompactTextString(m) }
  260. func (*ReceiveReq) ProtoMessage() {}
  261. func (*ReceiveReq) Descriptor() ([]byte, []int) { return fileDescriptorApi, []int{12} }
  262. func (m *ReceiveReq) GetMid() int64 {
  263. if m != nil {
  264. return m.Mid
  265. }
  266. return 0
  267. }
  268. func (m *ReceiveReq) GetProto() *push_service_broadcast_model.Proto {
  269. if m != nil {
  270. return m.Proto
  271. }
  272. return nil
  273. }
  274. type ReceiveReply struct {
  275. Proto *push_service_broadcast_model.Proto `protobuf:"bytes,1,opt,name=proto" json:"proto,omitempty"`
  276. }
  277. func (m *ReceiveReply) Reset() { *m = ReceiveReply{} }
  278. func (m *ReceiveReply) String() string { return proto.CompactTextString(m) }
  279. func (*ReceiveReply) ProtoMessage() {}
  280. func (*ReceiveReply) Descriptor() ([]byte, []int) { return fileDescriptorApi, []int{13} }
  281. func (m *ReceiveReply) GetProto() *push_service_broadcast_model.Proto {
  282. if m != nil {
  283. return m.Proto
  284. }
  285. return nil
  286. }
  287. type ServerListReq struct {
  288. Platform string `protobuf:"bytes,1,opt,name=platform,proto3" json:"platform,omitempty"`
  289. }
  290. func (m *ServerListReq) Reset() { *m = ServerListReq{} }
  291. func (m *ServerListReq) String() string { return proto.CompactTextString(m) }
  292. func (*ServerListReq) ProtoMessage() {}
  293. func (*ServerListReq) Descriptor() ([]byte, []int) { return fileDescriptorApi, []int{14} }
  294. func (m *ServerListReq) GetPlatform() string {
  295. if m != nil {
  296. return m.Platform
  297. }
  298. return ""
  299. }
  300. type ServerListReply struct {
  301. Domain string `protobuf:"bytes,1,opt,name=domain,proto3" json:"domain"`
  302. TcpPort int32 `protobuf:"varint,2,opt,name=tcpPort,proto3" json:"tcp_port"`
  303. WsPort int32 `protobuf:"varint,3,opt,name=wsPort,proto3" json:"ws_port"`
  304. WssPort int32 `protobuf:"varint,4,opt,name=wssPort,proto3" json:"wss_port"`
  305. Heartbeat int32 `protobuf:"varint,5,opt,name=heartbeat,proto3" json:"heartbeat"`
  306. Nodes []string `protobuf:"bytes,6,rep,name=nodes" json:"nodes"`
  307. Backoff *Backoff `protobuf:"bytes,7,opt,name=backoff" json:"backoff"`
  308. HeartbeatMax int32 `protobuf:"varint,8,opt,name=heartbeatMax,proto3" json:"heartbeat_max"`
  309. }
  310. func (m *ServerListReply) Reset() { *m = ServerListReply{} }
  311. func (m *ServerListReply) String() string { return proto.CompactTextString(m) }
  312. func (*ServerListReply) ProtoMessage() {}
  313. func (*ServerListReply) Descriptor() ([]byte, []int) { return fileDescriptorApi, []int{15} }
  314. func (m *ServerListReply) GetDomain() string {
  315. if m != nil {
  316. return m.Domain
  317. }
  318. return ""
  319. }
  320. func (m *ServerListReply) GetTcpPort() int32 {
  321. if m != nil {
  322. return m.TcpPort
  323. }
  324. return 0
  325. }
  326. func (m *ServerListReply) GetWsPort() int32 {
  327. if m != nil {
  328. return m.WsPort
  329. }
  330. return 0
  331. }
  332. func (m *ServerListReply) GetWssPort() int32 {
  333. if m != nil {
  334. return m.WssPort
  335. }
  336. return 0
  337. }
  338. func (m *ServerListReply) GetHeartbeat() int32 {
  339. if m != nil {
  340. return m.Heartbeat
  341. }
  342. return 0
  343. }
  344. func (m *ServerListReply) GetNodes() []string {
  345. if m != nil {
  346. return m.Nodes
  347. }
  348. return nil
  349. }
  350. func (m *ServerListReply) GetBackoff() *Backoff {
  351. if m != nil {
  352. return m.Backoff
  353. }
  354. return nil
  355. }
  356. func (m *ServerListReply) GetHeartbeatMax() int32 {
  357. if m != nil {
  358. return m.HeartbeatMax
  359. }
  360. return 0
  361. }
  362. type Backoff struct {
  363. MaxDelay int32 `protobuf:"varint,1,opt,name=MaxDelay,proto3" json:"max_delay"`
  364. BaseDelay int32 `protobuf:"varint,2,opt,name=BaseDelay,proto3" json:"base_delay"`
  365. Factor float32 `protobuf:"fixed32,3,opt,name=Factor,proto3" json:"factor"`
  366. Jitter float32 `protobuf:"fixed32,4,opt,name=Jitter,proto3" json:"jitter"`
  367. }
  368. func (m *Backoff) Reset() { *m = Backoff{} }
  369. func (m *Backoff) String() string { return proto.CompactTextString(m) }
  370. func (*Backoff) ProtoMessage() {}
  371. func (*Backoff) Descriptor() ([]byte, []int) { return fileDescriptorApi, []int{16} }
  372. func (m *Backoff) GetMaxDelay() int32 {
  373. if m != nil {
  374. return m.MaxDelay
  375. }
  376. return 0
  377. }
  378. func (m *Backoff) GetBaseDelay() int32 {
  379. if m != nil {
  380. return m.BaseDelay
  381. }
  382. return 0
  383. }
  384. func (m *Backoff) GetFactor() float32 {
  385. if m != nil {
  386. return m.Factor
  387. }
  388. return 0
  389. }
  390. func (m *Backoff) GetJitter() float32 {
  391. if m != nil {
  392. return m.Jitter
  393. }
  394. return 0
  395. }
  396. func init() {
  397. proto.RegisterType((*CloseReply)(nil), "push.service.broadcast.CloseReply")
  398. proto.RegisterType((*CloseReq)(nil), "push.service.broadcast.CloseReq")
  399. proto.RegisterType((*PingReply)(nil), "push.service.broadcast.PingReply")
  400. proto.RegisterType((*PingReq)(nil), "push.service.broadcast.PingReq")
  401. proto.RegisterType((*ConnectReq)(nil), "push.service.broadcast.ConnectReq")
  402. proto.RegisterType((*ConnectReply)(nil), "push.service.broadcast.ConnectReply")
  403. proto.RegisterType((*DisconnectReq)(nil), "push.service.broadcast.DisconnectReq")
  404. proto.RegisterType((*DisconnectReply)(nil), "push.service.broadcast.DisconnectReply")
  405. proto.RegisterType((*HeartbeatReq)(nil), "push.service.broadcast.HeartbeatReq")
  406. proto.RegisterType((*HeartbeatReply)(nil), "push.service.broadcast.HeartbeatReply")
  407. proto.RegisterType((*OnlineReq)(nil), "push.service.broadcast.OnlineReq")
  408. proto.RegisterType((*OnlineReply)(nil), "push.service.broadcast.OnlineReply")
  409. proto.RegisterType((*ReceiveReq)(nil), "push.service.broadcast.ReceiveReq")
  410. proto.RegisterType((*ReceiveReply)(nil), "push.service.broadcast.ReceiveReply")
  411. proto.RegisterType((*ServerListReq)(nil), "push.service.broadcast.ServerListReq")
  412. proto.RegisterType((*ServerListReply)(nil), "push.service.broadcast.ServerListReply")
  413. proto.RegisterType((*Backoff)(nil), "push.service.broadcast.Backoff")
  414. }
  415. // Reference imports to suppress errors if they are not otherwise used.
  416. var _ context.Context
  417. var _ grpc.ClientConn
  418. // This is a compile-time assertion to ensure that this generated file
  419. // is compatible with the grpc package it is being compiled against.
  420. const _ = grpc.SupportPackageIsVersion4
  421. // Client API for Zerg service
  422. type ZergClient interface {
  423. // Ping Service
  424. Ping(ctx context.Context, in *PingReq, opts ...grpc.CallOption) (*PingReply, error)
  425. // Close Service
  426. Close(ctx context.Context, in *CloseReq, opts ...grpc.CallOption) (*CloseReply, error)
  427. // Connect
  428. Connect(ctx context.Context, in *ConnectReq, opts ...grpc.CallOption) (*ConnectReply, error)
  429. // Disconnect
  430. Disconnect(ctx context.Context, in *DisconnectReq, opts ...grpc.CallOption) (*DisconnectReply, error)
  431. // Heartbeat
  432. Heartbeat(ctx context.Context, in *HeartbeatReq, opts ...grpc.CallOption) (*HeartbeatReply, error)
  433. // RenewOnline
  434. RenewOnline(ctx context.Context, in *OnlineReq, opts ...grpc.CallOption) (*OnlineReply, error)
  435. // Receive
  436. Receive(ctx context.Context, in *ReceiveReq, opts ...grpc.CallOption) (*ReceiveReply, error)
  437. // ServerList
  438. ServerList(ctx context.Context, in *ServerListReq, opts ...grpc.CallOption) (*ServerListReply, error)
  439. }
  440. type zergClient struct {
  441. cc *grpc.ClientConn
  442. }
  443. func NewZergClient(cc *grpc.ClientConn) ZergClient {
  444. return &zergClient{cc}
  445. }
  446. func (c *zergClient) Ping(ctx context.Context, in *PingReq, opts ...grpc.CallOption) (*PingReply, error) {
  447. out := new(PingReply)
  448. err := grpc.Invoke(ctx, "/push.service.broadcast.Zerg/Ping", in, out, c.cc, opts...)
  449. if err != nil {
  450. return nil, err
  451. }
  452. return out, nil
  453. }
  454. func (c *zergClient) Close(ctx context.Context, in *CloseReq, opts ...grpc.CallOption) (*CloseReply, error) {
  455. out := new(CloseReply)
  456. err := grpc.Invoke(ctx, "/push.service.broadcast.Zerg/Close", in, out, c.cc, opts...)
  457. if err != nil {
  458. return nil, err
  459. }
  460. return out, nil
  461. }
  462. func (c *zergClient) Connect(ctx context.Context, in *ConnectReq, opts ...grpc.CallOption) (*ConnectReply, error) {
  463. out := new(ConnectReply)
  464. err := grpc.Invoke(ctx, "/push.service.broadcast.Zerg/Connect", in, out, c.cc, opts...)
  465. if err != nil {
  466. return nil, err
  467. }
  468. return out, nil
  469. }
  470. func (c *zergClient) Disconnect(ctx context.Context, in *DisconnectReq, opts ...grpc.CallOption) (*DisconnectReply, error) {
  471. out := new(DisconnectReply)
  472. err := grpc.Invoke(ctx, "/push.service.broadcast.Zerg/Disconnect", in, out, c.cc, opts...)
  473. if err != nil {
  474. return nil, err
  475. }
  476. return out, nil
  477. }
  478. func (c *zergClient) Heartbeat(ctx context.Context, in *HeartbeatReq, opts ...grpc.CallOption) (*HeartbeatReply, error) {
  479. out := new(HeartbeatReply)
  480. err := grpc.Invoke(ctx, "/push.service.broadcast.Zerg/Heartbeat", in, out, c.cc, opts...)
  481. if err != nil {
  482. return nil, err
  483. }
  484. return out, nil
  485. }
  486. func (c *zergClient) RenewOnline(ctx context.Context, in *OnlineReq, opts ...grpc.CallOption) (*OnlineReply, error) {
  487. out := new(OnlineReply)
  488. err := grpc.Invoke(ctx, "/push.service.broadcast.Zerg/RenewOnline", in, out, c.cc, opts...)
  489. if err != nil {
  490. return nil, err
  491. }
  492. return out, nil
  493. }
  494. func (c *zergClient) Receive(ctx context.Context, in *ReceiveReq, opts ...grpc.CallOption) (*ReceiveReply, error) {
  495. out := new(ReceiveReply)
  496. err := grpc.Invoke(ctx, "/push.service.broadcast.Zerg/Receive", in, out, c.cc, opts...)
  497. if err != nil {
  498. return nil, err
  499. }
  500. return out, nil
  501. }
  502. func (c *zergClient) ServerList(ctx context.Context, in *ServerListReq, opts ...grpc.CallOption) (*ServerListReply, error) {
  503. out := new(ServerListReply)
  504. err := grpc.Invoke(ctx, "/push.service.broadcast.Zerg/ServerList", in, out, c.cc, opts...)
  505. if err != nil {
  506. return nil, err
  507. }
  508. return out, nil
  509. }
  510. // Server API for Zerg service
  511. type ZergServer interface {
  512. // Ping Service
  513. Ping(context.Context, *PingReq) (*PingReply, error)
  514. // Close Service
  515. Close(context.Context, *CloseReq) (*CloseReply, error)
  516. // Connect
  517. Connect(context.Context, *ConnectReq) (*ConnectReply, error)
  518. // Disconnect
  519. Disconnect(context.Context, *DisconnectReq) (*DisconnectReply, error)
  520. // Heartbeat
  521. Heartbeat(context.Context, *HeartbeatReq) (*HeartbeatReply, error)
  522. // RenewOnline
  523. RenewOnline(context.Context, *OnlineReq) (*OnlineReply, error)
  524. // Receive
  525. Receive(context.Context, *ReceiveReq) (*ReceiveReply, error)
  526. // ServerList
  527. ServerList(context.Context, *ServerListReq) (*ServerListReply, error)
  528. }
  529. func RegisterZergServer(s *grpc.Server, srv ZergServer) {
  530. s.RegisterService(&_Zerg_serviceDesc, srv)
  531. }
  532. func _Zerg_Ping_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  533. in := new(PingReq)
  534. if err := dec(in); err != nil {
  535. return nil, err
  536. }
  537. if interceptor == nil {
  538. return srv.(ZergServer).Ping(ctx, in)
  539. }
  540. info := &grpc.UnaryServerInfo{
  541. Server: srv,
  542. FullMethod: "/push.service.broadcast.Zerg/Ping",
  543. }
  544. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  545. return srv.(ZergServer).Ping(ctx, req.(*PingReq))
  546. }
  547. return interceptor(ctx, in, info, handler)
  548. }
  549. func _Zerg_Close_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  550. in := new(CloseReq)
  551. if err := dec(in); err != nil {
  552. return nil, err
  553. }
  554. if interceptor == nil {
  555. return srv.(ZergServer).Close(ctx, in)
  556. }
  557. info := &grpc.UnaryServerInfo{
  558. Server: srv,
  559. FullMethod: "/push.service.broadcast.Zerg/Close",
  560. }
  561. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  562. return srv.(ZergServer).Close(ctx, req.(*CloseReq))
  563. }
  564. return interceptor(ctx, in, info, handler)
  565. }
  566. func _Zerg_Connect_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  567. in := new(ConnectReq)
  568. if err := dec(in); err != nil {
  569. return nil, err
  570. }
  571. if interceptor == nil {
  572. return srv.(ZergServer).Connect(ctx, in)
  573. }
  574. info := &grpc.UnaryServerInfo{
  575. Server: srv,
  576. FullMethod: "/push.service.broadcast.Zerg/Connect",
  577. }
  578. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  579. return srv.(ZergServer).Connect(ctx, req.(*ConnectReq))
  580. }
  581. return interceptor(ctx, in, info, handler)
  582. }
  583. func _Zerg_Disconnect_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  584. in := new(DisconnectReq)
  585. if err := dec(in); err != nil {
  586. return nil, err
  587. }
  588. if interceptor == nil {
  589. return srv.(ZergServer).Disconnect(ctx, in)
  590. }
  591. info := &grpc.UnaryServerInfo{
  592. Server: srv,
  593. FullMethod: "/push.service.broadcast.Zerg/Disconnect",
  594. }
  595. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  596. return srv.(ZergServer).Disconnect(ctx, req.(*DisconnectReq))
  597. }
  598. return interceptor(ctx, in, info, handler)
  599. }
  600. func _Zerg_Heartbeat_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  601. in := new(HeartbeatReq)
  602. if err := dec(in); err != nil {
  603. return nil, err
  604. }
  605. if interceptor == nil {
  606. return srv.(ZergServer).Heartbeat(ctx, in)
  607. }
  608. info := &grpc.UnaryServerInfo{
  609. Server: srv,
  610. FullMethod: "/push.service.broadcast.Zerg/Heartbeat",
  611. }
  612. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  613. return srv.(ZergServer).Heartbeat(ctx, req.(*HeartbeatReq))
  614. }
  615. return interceptor(ctx, in, info, handler)
  616. }
  617. func _Zerg_RenewOnline_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  618. in := new(OnlineReq)
  619. if err := dec(in); err != nil {
  620. return nil, err
  621. }
  622. if interceptor == nil {
  623. return srv.(ZergServer).RenewOnline(ctx, in)
  624. }
  625. info := &grpc.UnaryServerInfo{
  626. Server: srv,
  627. FullMethod: "/push.service.broadcast.Zerg/RenewOnline",
  628. }
  629. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  630. return srv.(ZergServer).RenewOnline(ctx, req.(*OnlineReq))
  631. }
  632. return interceptor(ctx, in, info, handler)
  633. }
  634. func _Zerg_Receive_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  635. in := new(ReceiveReq)
  636. if err := dec(in); err != nil {
  637. return nil, err
  638. }
  639. if interceptor == nil {
  640. return srv.(ZergServer).Receive(ctx, in)
  641. }
  642. info := &grpc.UnaryServerInfo{
  643. Server: srv,
  644. FullMethod: "/push.service.broadcast.Zerg/Receive",
  645. }
  646. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  647. return srv.(ZergServer).Receive(ctx, req.(*ReceiveReq))
  648. }
  649. return interceptor(ctx, in, info, handler)
  650. }
  651. func _Zerg_ServerList_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  652. in := new(ServerListReq)
  653. if err := dec(in); err != nil {
  654. return nil, err
  655. }
  656. if interceptor == nil {
  657. return srv.(ZergServer).ServerList(ctx, in)
  658. }
  659. info := &grpc.UnaryServerInfo{
  660. Server: srv,
  661. FullMethod: "/push.service.broadcast.Zerg/ServerList",
  662. }
  663. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  664. return srv.(ZergServer).ServerList(ctx, req.(*ServerListReq))
  665. }
  666. return interceptor(ctx, in, info, handler)
  667. }
  668. var _Zerg_serviceDesc = grpc.ServiceDesc{
  669. ServiceName: "push.service.broadcast.Zerg",
  670. HandlerType: (*ZergServer)(nil),
  671. Methods: []grpc.MethodDesc{
  672. {
  673. MethodName: "Ping",
  674. Handler: _Zerg_Ping_Handler,
  675. },
  676. {
  677. MethodName: "Close",
  678. Handler: _Zerg_Close_Handler,
  679. },
  680. {
  681. MethodName: "Connect",
  682. Handler: _Zerg_Connect_Handler,
  683. },
  684. {
  685. MethodName: "Disconnect",
  686. Handler: _Zerg_Disconnect_Handler,
  687. },
  688. {
  689. MethodName: "Heartbeat",
  690. Handler: _Zerg_Heartbeat_Handler,
  691. },
  692. {
  693. MethodName: "RenewOnline",
  694. Handler: _Zerg_RenewOnline_Handler,
  695. },
  696. {
  697. MethodName: "Receive",
  698. Handler: _Zerg_Receive_Handler,
  699. },
  700. {
  701. MethodName: "ServerList",
  702. Handler: _Zerg_ServerList_Handler,
  703. },
  704. },
  705. Streams: []grpc.StreamDesc{},
  706. Metadata: "app/service/main/broadcast/api/grpc/v1/api.proto",
  707. }
  708. func (m *CloseReply) Marshal() (dAtA []byte, err error) {
  709. size := m.Size()
  710. dAtA = make([]byte, size)
  711. n, err := m.MarshalTo(dAtA)
  712. if err != nil {
  713. return nil, err
  714. }
  715. return dAtA[:n], nil
  716. }
  717. func (m *CloseReply) MarshalTo(dAtA []byte) (int, error) {
  718. var i int
  719. _ = i
  720. var l int
  721. _ = l
  722. return i, nil
  723. }
  724. func (m *CloseReq) Marshal() (dAtA []byte, err error) {
  725. size := m.Size()
  726. dAtA = make([]byte, size)
  727. n, err := m.MarshalTo(dAtA)
  728. if err != nil {
  729. return nil, err
  730. }
  731. return dAtA[:n], nil
  732. }
  733. func (m *CloseReq) MarshalTo(dAtA []byte) (int, error) {
  734. var i int
  735. _ = i
  736. var l int
  737. _ = l
  738. return i, nil
  739. }
  740. func (m *PingReply) Marshal() (dAtA []byte, err error) {
  741. size := m.Size()
  742. dAtA = make([]byte, size)
  743. n, err := m.MarshalTo(dAtA)
  744. if err != nil {
  745. return nil, err
  746. }
  747. return dAtA[:n], nil
  748. }
  749. func (m *PingReply) MarshalTo(dAtA []byte) (int, error) {
  750. var i int
  751. _ = i
  752. var l int
  753. _ = l
  754. return i, nil
  755. }
  756. func (m *PingReq) Marshal() (dAtA []byte, err error) {
  757. size := m.Size()
  758. dAtA = make([]byte, size)
  759. n, err := m.MarshalTo(dAtA)
  760. if err != nil {
  761. return nil, err
  762. }
  763. return dAtA[:n], nil
  764. }
  765. func (m *PingReq) MarshalTo(dAtA []byte) (int, error) {
  766. var i int
  767. _ = i
  768. var l int
  769. _ = l
  770. return i, nil
  771. }
  772. func (m *ConnectReq) Marshal() (dAtA []byte, err error) {
  773. size := m.Size()
  774. dAtA = make([]byte, size)
  775. n, err := m.MarshalTo(dAtA)
  776. if err != nil {
  777. return nil, err
  778. }
  779. return dAtA[:n], nil
  780. }
  781. func (m *ConnectReq) MarshalTo(dAtA []byte) (int, error) {
  782. var i int
  783. _ = i
  784. var l int
  785. _ = l
  786. if len(m.Server) > 0 {
  787. dAtA[i] = 0xa
  788. i++
  789. i = encodeVarintApi(dAtA, i, uint64(len(m.Server)))
  790. i += copy(dAtA[i:], m.Server)
  791. }
  792. if len(m.ServerKey) > 0 {
  793. dAtA[i] = 0x12
  794. i++
  795. i = encodeVarintApi(dAtA, i, uint64(len(m.ServerKey)))
  796. i += copy(dAtA[i:], m.ServerKey)
  797. }
  798. if len(m.Cookie) > 0 {
  799. dAtA[i] = 0x1a
  800. i++
  801. i = encodeVarintApi(dAtA, i, uint64(len(m.Cookie)))
  802. i += copy(dAtA[i:], m.Cookie)
  803. }
  804. if len(m.Token) > 0 {
  805. dAtA[i] = 0x22
  806. i++
  807. i = encodeVarintApi(dAtA, i, uint64(len(m.Token)))
  808. i += copy(dAtA[i:], m.Token)
  809. }
  810. return i, nil
  811. }
  812. func (m *ConnectReply) Marshal() (dAtA []byte, err error) {
  813. size := m.Size()
  814. dAtA = make([]byte, size)
  815. n, err := m.MarshalTo(dAtA)
  816. if err != nil {
  817. return nil, err
  818. }
  819. return dAtA[:n], nil
  820. }
  821. func (m *ConnectReply) MarshalTo(dAtA []byte) (int, error) {
  822. var i int
  823. _ = i
  824. var l int
  825. _ = l
  826. if m.Mid != 0 {
  827. dAtA[i] = 0x8
  828. i++
  829. i = encodeVarintApi(dAtA, i, uint64(m.Mid))
  830. }
  831. if len(m.Key) > 0 {
  832. dAtA[i] = 0x12
  833. i++
  834. i = encodeVarintApi(dAtA, i, uint64(len(m.Key)))
  835. i += copy(dAtA[i:], m.Key)
  836. }
  837. if len(m.RoomID) > 0 {
  838. dAtA[i] = 0x1a
  839. i++
  840. i = encodeVarintApi(dAtA, i, uint64(len(m.RoomID)))
  841. i += copy(dAtA[i:], m.RoomID)
  842. }
  843. if len(m.Platform) > 0 {
  844. dAtA[i] = 0x22
  845. i++
  846. i = encodeVarintApi(dAtA, i, uint64(len(m.Platform)))
  847. i += copy(dAtA[i:], m.Platform)
  848. }
  849. if len(m.Accepts) > 0 {
  850. dAtA2 := make([]byte, len(m.Accepts)*10)
  851. var j1 int
  852. for _, num1 := range m.Accepts {
  853. num := uint64(num1)
  854. for num >= 1<<7 {
  855. dAtA2[j1] = uint8(uint64(num)&0x7f | 0x80)
  856. num >>= 7
  857. j1++
  858. }
  859. dAtA2[j1] = uint8(num)
  860. j1++
  861. }
  862. dAtA[i] = 0x2a
  863. i++
  864. i = encodeVarintApi(dAtA, i, uint64(j1))
  865. i += copy(dAtA[i:], dAtA2[:j1])
  866. }
  867. return i, nil
  868. }
  869. func (m *DisconnectReq) Marshal() (dAtA []byte, err error) {
  870. size := m.Size()
  871. dAtA = make([]byte, size)
  872. n, err := m.MarshalTo(dAtA)
  873. if err != nil {
  874. return nil, err
  875. }
  876. return dAtA[:n], nil
  877. }
  878. func (m *DisconnectReq) MarshalTo(dAtA []byte) (int, error) {
  879. var i int
  880. _ = i
  881. var l int
  882. _ = l
  883. if m.Mid != 0 {
  884. dAtA[i] = 0x8
  885. i++
  886. i = encodeVarintApi(dAtA, i, uint64(m.Mid))
  887. }
  888. if len(m.Key) > 0 {
  889. dAtA[i] = 0x12
  890. i++
  891. i = encodeVarintApi(dAtA, i, uint64(len(m.Key)))
  892. i += copy(dAtA[i:], m.Key)
  893. }
  894. if len(m.Server) > 0 {
  895. dAtA[i] = 0x1a
  896. i++
  897. i = encodeVarintApi(dAtA, i, uint64(len(m.Server)))
  898. i += copy(dAtA[i:], m.Server)
  899. }
  900. return i, nil
  901. }
  902. func (m *DisconnectReply) Marshal() (dAtA []byte, err error) {
  903. size := m.Size()
  904. dAtA = make([]byte, size)
  905. n, err := m.MarshalTo(dAtA)
  906. if err != nil {
  907. return nil, err
  908. }
  909. return dAtA[:n], nil
  910. }
  911. func (m *DisconnectReply) MarshalTo(dAtA []byte) (int, error) {
  912. var i int
  913. _ = i
  914. var l int
  915. _ = l
  916. if m.Has {
  917. dAtA[i] = 0x8
  918. i++
  919. if m.Has {
  920. dAtA[i] = 1
  921. } else {
  922. dAtA[i] = 0
  923. }
  924. i++
  925. }
  926. return i, nil
  927. }
  928. func (m *HeartbeatReq) Marshal() (dAtA []byte, err error) {
  929. size := m.Size()
  930. dAtA = make([]byte, size)
  931. n, err := m.MarshalTo(dAtA)
  932. if err != nil {
  933. return nil, err
  934. }
  935. return dAtA[:n], nil
  936. }
  937. func (m *HeartbeatReq) MarshalTo(dAtA []byte) (int, error) {
  938. var i int
  939. _ = i
  940. var l int
  941. _ = l
  942. if m.Mid != 0 {
  943. dAtA[i] = 0x8
  944. i++
  945. i = encodeVarintApi(dAtA, i, uint64(m.Mid))
  946. }
  947. if len(m.Key) > 0 {
  948. dAtA[i] = 0x12
  949. i++
  950. i = encodeVarintApi(dAtA, i, uint64(len(m.Key)))
  951. i += copy(dAtA[i:], m.Key)
  952. }
  953. if len(m.Server) > 0 {
  954. dAtA[i] = 0x1a
  955. i++
  956. i = encodeVarintApi(dAtA, i, uint64(len(m.Server)))
  957. i += copy(dAtA[i:], m.Server)
  958. }
  959. return i, nil
  960. }
  961. func (m *HeartbeatReply) Marshal() (dAtA []byte, err error) {
  962. size := m.Size()
  963. dAtA = make([]byte, size)
  964. n, err := m.MarshalTo(dAtA)
  965. if err != nil {
  966. return nil, err
  967. }
  968. return dAtA[:n], nil
  969. }
  970. func (m *HeartbeatReply) MarshalTo(dAtA []byte) (int, error) {
  971. var i int
  972. _ = i
  973. var l int
  974. _ = l
  975. return i, nil
  976. }
  977. func (m *OnlineReq) Marshal() (dAtA []byte, err error) {
  978. size := m.Size()
  979. dAtA = make([]byte, size)
  980. n, err := m.MarshalTo(dAtA)
  981. if err != nil {
  982. return nil, err
  983. }
  984. return dAtA[:n], nil
  985. }
  986. func (m *OnlineReq) MarshalTo(dAtA []byte) (int, error) {
  987. var i int
  988. _ = i
  989. var l int
  990. _ = l
  991. if len(m.Server) > 0 {
  992. dAtA[i] = 0xa
  993. i++
  994. i = encodeVarintApi(dAtA, i, uint64(len(m.Server)))
  995. i += copy(dAtA[i:], m.Server)
  996. }
  997. if len(m.RoomCount) > 0 {
  998. for k, _ := range m.RoomCount {
  999. dAtA[i] = 0x12
  1000. i++
  1001. v := m.RoomCount[k]
  1002. mapSize := 1 + len(k) + sovApi(uint64(len(k))) + 1 + sovApi(uint64(v))
  1003. i = encodeVarintApi(dAtA, i, uint64(mapSize))
  1004. dAtA[i] = 0xa
  1005. i++
  1006. i = encodeVarintApi(dAtA, i, uint64(len(k)))
  1007. i += copy(dAtA[i:], k)
  1008. dAtA[i] = 0x10
  1009. i++
  1010. i = encodeVarintApi(dAtA, i, uint64(v))
  1011. }
  1012. }
  1013. if m.Sharding != 0 {
  1014. dAtA[i] = 0x18
  1015. i++
  1016. i = encodeVarintApi(dAtA, i, uint64(m.Sharding))
  1017. }
  1018. return i, nil
  1019. }
  1020. func (m *OnlineReply) Marshal() (dAtA []byte, err error) {
  1021. size := m.Size()
  1022. dAtA = make([]byte, size)
  1023. n, err := m.MarshalTo(dAtA)
  1024. if err != nil {
  1025. return nil, err
  1026. }
  1027. return dAtA[:n], nil
  1028. }
  1029. func (m *OnlineReply) MarshalTo(dAtA []byte) (int, error) {
  1030. var i int
  1031. _ = i
  1032. var l int
  1033. _ = l
  1034. if len(m.RoomCount) > 0 {
  1035. for k, _ := range m.RoomCount {
  1036. dAtA[i] = 0xa
  1037. i++
  1038. v := m.RoomCount[k]
  1039. mapSize := 1 + len(k) + sovApi(uint64(len(k))) + 1 + sovApi(uint64(v))
  1040. i = encodeVarintApi(dAtA, i, uint64(mapSize))
  1041. dAtA[i] = 0xa
  1042. i++
  1043. i = encodeVarintApi(dAtA, i, uint64(len(k)))
  1044. i += copy(dAtA[i:], k)
  1045. dAtA[i] = 0x10
  1046. i++
  1047. i = encodeVarintApi(dAtA, i, uint64(v))
  1048. }
  1049. }
  1050. return i, nil
  1051. }
  1052. func (m *ReceiveReq) Marshal() (dAtA []byte, err error) {
  1053. size := m.Size()
  1054. dAtA = make([]byte, size)
  1055. n, err := m.MarshalTo(dAtA)
  1056. if err != nil {
  1057. return nil, err
  1058. }
  1059. return dAtA[:n], nil
  1060. }
  1061. func (m *ReceiveReq) MarshalTo(dAtA []byte) (int, error) {
  1062. var i int
  1063. _ = i
  1064. var l int
  1065. _ = l
  1066. if m.Mid != 0 {
  1067. dAtA[i] = 0x8
  1068. i++
  1069. i = encodeVarintApi(dAtA, i, uint64(m.Mid))
  1070. }
  1071. if m.Proto != nil {
  1072. dAtA[i] = 0x12
  1073. i++
  1074. i = encodeVarintApi(dAtA, i, uint64(m.Proto.Size()))
  1075. n3, err := m.Proto.MarshalTo(dAtA[i:])
  1076. if err != nil {
  1077. return 0, err
  1078. }
  1079. i += n3
  1080. }
  1081. return i, nil
  1082. }
  1083. func (m *ReceiveReply) Marshal() (dAtA []byte, err error) {
  1084. size := m.Size()
  1085. dAtA = make([]byte, size)
  1086. n, err := m.MarshalTo(dAtA)
  1087. if err != nil {
  1088. return nil, err
  1089. }
  1090. return dAtA[:n], nil
  1091. }
  1092. func (m *ReceiveReply) MarshalTo(dAtA []byte) (int, error) {
  1093. var i int
  1094. _ = i
  1095. var l int
  1096. _ = l
  1097. if m.Proto != nil {
  1098. dAtA[i] = 0xa
  1099. i++
  1100. i = encodeVarintApi(dAtA, i, uint64(m.Proto.Size()))
  1101. n4, err := m.Proto.MarshalTo(dAtA[i:])
  1102. if err != nil {
  1103. return 0, err
  1104. }
  1105. i += n4
  1106. }
  1107. return i, nil
  1108. }
  1109. func (m *ServerListReq) Marshal() (dAtA []byte, err error) {
  1110. size := m.Size()
  1111. dAtA = make([]byte, size)
  1112. n, err := m.MarshalTo(dAtA)
  1113. if err != nil {
  1114. return nil, err
  1115. }
  1116. return dAtA[:n], nil
  1117. }
  1118. func (m *ServerListReq) MarshalTo(dAtA []byte) (int, error) {
  1119. var i int
  1120. _ = i
  1121. var l int
  1122. _ = l
  1123. if len(m.Platform) > 0 {
  1124. dAtA[i] = 0xa
  1125. i++
  1126. i = encodeVarintApi(dAtA, i, uint64(len(m.Platform)))
  1127. i += copy(dAtA[i:], m.Platform)
  1128. }
  1129. return i, nil
  1130. }
  1131. func (m *ServerListReply) Marshal() (dAtA []byte, err error) {
  1132. size := m.Size()
  1133. dAtA = make([]byte, size)
  1134. n, err := m.MarshalTo(dAtA)
  1135. if err != nil {
  1136. return nil, err
  1137. }
  1138. return dAtA[:n], nil
  1139. }
  1140. func (m *ServerListReply) MarshalTo(dAtA []byte) (int, error) {
  1141. var i int
  1142. _ = i
  1143. var l int
  1144. _ = l
  1145. if len(m.Domain) > 0 {
  1146. dAtA[i] = 0xa
  1147. i++
  1148. i = encodeVarintApi(dAtA, i, uint64(len(m.Domain)))
  1149. i += copy(dAtA[i:], m.Domain)
  1150. }
  1151. if m.TcpPort != 0 {
  1152. dAtA[i] = 0x10
  1153. i++
  1154. i = encodeVarintApi(dAtA, i, uint64(m.TcpPort))
  1155. }
  1156. if m.WsPort != 0 {
  1157. dAtA[i] = 0x18
  1158. i++
  1159. i = encodeVarintApi(dAtA, i, uint64(m.WsPort))
  1160. }
  1161. if m.WssPort != 0 {
  1162. dAtA[i] = 0x20
  1163. i++
  1164. i = encodeVarintApi(dAtA, i, uint64(m.WssPort))
  1165. }
  1166. if m.Heartbeat != 0 {
  1167. dAtA[i] = 0x28
  1168. i++
  1169. i = encodeVarintApi(dAtA, i, uint64(m.Heartbeat))
  1170. }
  1171. if len(m.Nodes) > 0 {
  1172. for _, s := range m.Nodes {
  1173. dAtA[i] = 0x32
  1174. i++
  1175. l = len(s)
  1176. for l >= 1<<7 {
  1177. dAtA[i] = uint8(uint64(l)&0x7f | 0x80)
  1178. l >>= 7
  1179. i++
  1180. }
  1181. dAtA[i] = uint8(l)
  1182. i++
  1183. i += copy(dAtA[i:], s)
  1184. }
  1185. }
  1186. if m.Backoff != nil {
  1187. dAtA[i] = 0x3a
  1188. i++
  1189. i = encodeVarintApi(dAtA, i, uint64(m.Backoff.Size()))
  1190. n5, err := m.Backoff.MarshalTo(dAtA[i:])
  1191. if err != nil {
  1192. return 0, err
  1193. }
  1194. i += n5
  1195. }
  1196. if m.HeartbeatMax != 0 {
  1197. dAtA[i] = 0x40
  1198. i++
  1199. i = encodeVarintApi(dAtA, i, uint64(m.HeartbeatMax))
  1200. }
  1201. return i, nil
  1202. }
  1203. func (m *Backoff) Marshal() (dAtA []byte, err error) {
  1204. size := m.Size()
  1205. dAtA = make([]byte, size)
  1206. n, err := m.MarshalTo(dAtA)
  1207. if err != nil {
  1208. return nil, err
  1209. }
  1210. return dAtA[:n], nil
  1211. }
  1212. func (m *Backoff) MarshalTo(dAtA []byte) (int, error) {
  1213. var i int
  1214. _ = i
  1215. var l int
  1216. _ = l
  1217. if m.MaxDelay != 0 {
  1218. dAtA[i] = 0x8
  1219. i++
  1220. i = encodeVarintApi(dAtA, i, uint64(m.MaxDelay))
  1221. }
  1222. if m.BaseDelay != 0 {
  1223. dAtA[i] = 0x10
  1224. i++
  1225. i = encodeVarintApi(dAtA, i, uint64(m.BaseDelay))
  1226. }
  1227. if m.Factor != 0 {
  1228. dAtA[i] = 0x1d
  1229. i++
  1230. binary.LittleEndian.PutUint32(dAtA[i:], uint32(math.Float32bits(float32(m.Factor))))
  1231. i += 4
  1232. }
  1233. if m.Jitter != 0 {
  1234. dAtA[i] = 0x25
  1235. i++
  1236. binary.LittleEndian.PutUint32(dAtA[i:], uint32(math.Float32bits(float32(m.Jitter))))
  1237. i += 4
  1238. }
  1239. return i, nil
  1240. }
  1241. func encodeVarintApi(dAtA []byte, offset int, v uint64) int {
  1242. for v >= 1<<7 {
  1243. dAtA[offset] = uint8(v&0x7f | 0x80)
  1244. v >>= 7
  1245. offset++
  1246. }
  1247. dAtA[offset] = uint8(v)
  1248. return offset + 1
  1249. }
  1250. func (m *CloseReply) Size() (n int) {
  1251. var l int
  1252. _ = l
  1253. return n
  1254. }
  1255. func (m *CloseReq) Size() (n int) {
  1256. var l int
  1257. _ = l
  1258. return n
  1259. }
  1260. func (m *PingReply) Size() (n int) {
  1261. var l int
  1262. _ = l
  1263. return n
  1264. }
  1265. func (m *PingReq) Size() (n int) {
  1266. var l int
  1267. _ = l
  1268. return n
  1269. }
  1270. func (m *ConnectReq) Size() (n int) {
  1271. var l int
  1272. _ = l
  1273. l = len(m.Server)
  1274. if l > 0 {
  1275. n += 1 + l + sovApi(uint64(l))
  1276. }
  1277. l = len(m.ServerKey)
  1278. if l > 0 {
  1279. n += 1 + l + sovApi(uint64(l))
  1280. }
  1281. l = len(m.Cookie)
  1282. if l > 0 {
  1283. n += 1 + l + sovApi(uint64(l))
  1284. }
  1285. l = len(m.Token)
  1286. if l > 0 {
  1287. n += 1 + l + sovApi(uint64(l))
  1288. }
  1289. return n
  1290. }
  1291. func (m *ConnectReply) Size() (n int) {
  1292. var l int
  1293. _ = l
  1294. if m.Mid != 0 {
  1295. n += 1 + sovApi(uint64(m.Mid))
  1296. }
  1297. l = len(m.Key)
  1298. if l > 0 {
  1299. n += 1 + l + sovApi(uint64(l))
  1300. }
  1301. l = len(m.RoomID)
  1302. if l > 0 {
  1303. n += 1 + l + sovApi(uint64(l))
  1304. }
  1305. l = len(m.Platform)
  1306. if l > 0 {
  1307. n += 1 + l + sovApi(uint64(l))
  1308. }
  1309. if len(m.Accepts) > 0 {
  1310. l = 0
  1311. for _, e := range m.Accepts {
  1312. l += sovApi(uint64(e))
  1313. }
  1314. n += 1 + sovApi(uint64(l)) + l
  1315. }
  1316. return n
  1317. }
  1318. func (m *DisconnectReq) Size() (n int) {
  1319. var l int
  1320. _ = l
  1321. if m.Mid != 0 {
  1322. n += 1 + sovApi(uint64(m.Mid))
  1323. }
  1324. l = len(m.Key)
  1325. if l > 0 {
  1326. n += 1 + l + sovApi(uint64(l))
  1327. }
  1328. l = len(m.Server)
  1329. if l > 0 {
  1330. n += 1 + l + sovApi(uint64(l))
  1331. }
  1332. return n
  1333. }
  1334. func (m *DisconnectReply) Size() (n int) {
  1335. var l int
  1336. _ = l
  1337. if m.Has {
  1338. n += 2
  1339. }
  1340. return n
  1341. }
  1342. func (m *HeartbeatReq) Size() (n int) {
  1343. var l int
  1344. _ = l
  1345. if m.Mid != 0 {
  1346. n += 1 + sovApi(uint64(m.Mid))
  1347. }
  1348. l = len(m.Key)
  1349. if l > 0 {
  1350. n += 1 + l + sovApi(uint64(l))
  1351. }
  1352. l = len(m.Server)
  1353. if l > 0 {
  1354. n += 1 + l + sovApi(uint64(l))
  1355. }
  1356. return n
  1357. }
  1358. func (m *HeartbeatReply) Size() (n int) {
  1359. var l int
  1360. _ = l
  1361. return n
  1362. }
  1363. func (m *OnlineReq) Size() (n int) {
  1364. var l int
  1365. _ = l
  1366. l = len(m.Server)
  1367. if l > 0 {
  1368. n += 1 + l + sovApi(uint64(l))
  1369. }
  1370. if len(m.RoomCount) > 0 {
  1371. for k, v := range m.RoomCount {
  1372. _ = k
  1373. _ = v
  1374. mapEntrySize := 1 + len(k) + sovApi(uint64(len(k))) + 1 + sovApi(uint64(v))
  1375. n += mapEntrySize + 1 + sovApi(uint64(mapEntrySize))
  1376. }
  1377. }
  1378. if m.Sharding != 0 {
  1379. n += 1 + sovApi(uint64(m.Sharding))
  1380. }
  1381. return n
  1382. }
  1383. func (m *OnlineReply) Size() (n int) {
  1384. var l int
  1385. _ = l
  1386. if len(m.RoomCount) > 0 {
  1387. for k, v := range m.RoomCount {
  1388. _ = k
  1389. _ = v
  1390. mapEntrySize := 1 + len(k) + sovApi(uint64(len(k))) + 1 + sovApi(uint64(v))
  1391. n += mapEntrySize + 1 + sovApi(uint64(mapEntrySize))
  1392. }
  1393. }
  1394. return n
  1395. }
  1396. func (m *ReceiveReq) Size() (n int) {
  1397. var l int
  1398. _ = l
  1399. if m.Mid != 0 {
  1400. n += 1 + sovApi(uint64(m.Mid))
  1401. }
  1402. if m.Proto != nil {
  1403. l = m.Proto.Size()
  1404. n += 1 + l + sovApi(uint64(l))
  1405. }
  1406. return n
  1407. }
  1408. func (m *ReceiveReply) Size() (n int) {
  1409. var l int
  1410. _ = l
  1411. if m.Proto != nil {
  1412. l = m.Proto.Size()
  1413. n += 1 + l + sovApi(uint64(l))
  1414. }
  1415. return n
  1416. }
  1417. func (m *ServerListReq) Size() (n int) {
  1418. var l int
  1419. _ = l
  1420. l = len(m.Platform)
  1421. if l > 0 {
  1422. n += 1 + l + sovApi(uint64(l))
  1423. }
  1424. return n
  1425. }
  1426. func (m *ServerListReply) Size() (n int) {
  1427. var l int
  1428. _ = l
  1429. l = len(m.Domain)
  1430. if l > 0 {
  1431. n += 1 + l + sovApi(uint64(l))
  1432. }
  1433. if m.TcpPort != 0 {
  1434. n += 1 + sovApi(uint64(m.TcpPort))
  1435. }
  1436. if m.WsPort != 0 {
  1437. n += 1 + sovApi(uint64(m.WsPort))
  1438. }
  1439. if m.WssPort != 0 {
  1440. n += 1 + sovApi(uint64(m.WssPort))
  1441. }
  1442. if m.Heartbeat != 0 {
  1443. n += 1 + sovApi(uint64(m.Heartbeat))
  1444. }
  1445. if len(m.Nodes) > 0 {
  1446. for _, s := range m.Nodes {
  1447. l = len(s)
  1448. n += 1 + l + sovApi(uint64(l))
  1449. }
  1450. }
  1451. if m.Backoff != nil {
  1452. l = m.Backoff.Size()
  1453. n += 1 + l + sovApi(uint64(l))
  1454. }
  1455. if m.HeartbeatMax != 0 {
  1456. n += 1 + sovApi(uint64(m.HeartbeatMax))
  1457. }
  1458. return n
  1459. }
  1460. func (m *Backoff) Size() (n int) {
  1461. var l int
  1462. _ = l
  1463. if m.MaxDelay != 0 {
  1464. n += 1 + sovApi(uint64(m.MaxDelay))
  1465. }
  1466. if m.BaseDelay != 0 {
  1467. n += 1 + sovApi(uint64(m.BaseDelay))
  1468. }
  1469. if m.Factor != 0 {
  1470. n += 5
  1471. }
  1472. if m.Jitter != 0 {
  1473. n += 5
  1474. }
  1475. return n
  1476. }
  1477. func sovApi(x uint64) (n int) {
  1478. for {
  1479. n++
  1480. x >>= 7
  1481. if x == 0 {
  1482. break
  1483. }
  1484. }
  1485. return n
  1486. }
  1487. func sozApi(x uint64) (n int) {
  1488. return sovApi(uint64((x << 1) ^ uint64((int64(x) >> 63))))
  1489. }
  1490. func (m *CloseReply) Unmarshal(dAtA []byte) error {
  1491. l := len(dAtA)
  1492. iNdEx := 0
  1493. for iNdEx < l {
  1494. preIndex := iNdEx
  1495. var wire uint64
  1496. for shift := uint(0); ; shift += 7 {
  1497. if shift >= 64 {
  1498. return ErrIntOverflowApi
  1499. }
  1500. if iNdEx >= l {
  1501. return io.ErrUnexpectedEOF
  1502. }
  1503. b := dAtA[iNdEx]
  1504. iNdEx++
  1505. wire |= (uint64(b) & 0x7F) << shift
  1506. if b < 0x80 {
  1507. break
  1508. }
  1509. }
  1510. fieldNum := int32(wire >> 3)
  1511. wireType := int(wire & 0x7)
  1512. if wireType == 4 {
  1513. return fmt.Errorf("proto: CloseReply: wiretype end group for non-group")
  1514. }
  1515. if fieldNum <= 0 {
  1516. return fmt.Errorf("proto: CloseReply: illegal tag %d (wire type %d)", fieldNum, wire)
  1517. }
  1518. switch fieldNum {
  1519. default:
  1520. iNdEx = preIndex
  1521. skippy, err := skipApi(dAtA[iNdEx:])
  1522. if err != nil {
  1523. return err
  1524. }
  1525. if skippy < 0 {
  1526. return ErrInvalidLengthApi
  1527. }
  1528. if (iNdEx + skippy) > l {
  1529. return io.ErrUnexpectedEOF
  1530. }
  1531. iNdEx += skippy
  1532. }
  1533. }
  1534. if iNdEx > l {
  1535. return io.ErrUnexpectedEOF
  1536. }
  1537. return nil
  1538. }
  1539. func (m *CloseReq) Unmarshal(dAtA []byte) error {
  1540. l := len(dAtA)
  1541. iNdEx := 0
  1542. for iNdEx < l {
  1543. preIndex := iNdEx
  1544. var wire uint64
  1545. for shift := uint(0); ; shift += 7 {
  1546. if shift >= 64 {
  1547. return ErrIntOverflowApi
  1548. }
  1549. if iNdEx >= l {
  1550. return io.ErrUnexpectedEOF
  1551. }
  1552. b := dAtA[iNdEx]
  1553. iNdEx++
  1554. wire |= (uint64(b) & 0x7F) << shift
  1555. if b < 0x80 {
  1556. break
  1557. }
  1558. }
  1559. fieldNum := int32(wire >> 3)
  1560. wireType := int(wire & 0x7)
  1561. if wireType == 4 {
  1562. return fmt.Errorf("proto: CloseReq: wiretype end group for non-group")
  1563. }
  1564. if fieldNum <= 0 {
  1565. return fmt.Errorf("proto: CloseReq: illegal tag %d (wire type %d)", fieldNum, wire)
  1566. }
  1567. switch fieldNum {
  1568. default:
  1569. iNdEx = preIndex
  1570. skippy, err := skipApi(dAtA[iNdEx:])
  1571. if err != nil {
  1572. return err
  1573. }
  1574. if skippy < 0 {
  1575. return ErrInvalidLengthApi
  1576. }
  1577. if (iNdEx + skippy) > l {
  1578. return io.ErrUnexpectedEOF
  1579. }
  1580. iNdEx += skippy
  1581. }
  1582. }
  1583. if iNdEx > l {
  1584. return io.ErrUnexpectedEOF
  1585. }
  1586. return nil
  1587. }
  1588. func (m *PingReply) Unmarshal(dAtA []byte) error {
  1589. l := len(dAtA)
  1590. iNdEx := 0
  1591. for iNdEx < l {
  1592. preIndex := iNdEx
  1593. var wire uint64
  1594. for shift := uint(0); ; shift += 7 {
  1595. if shift >= 64 {
  1596. return ErrIntOverflowApi
  1597. }
  1598. if iNdEx >= l {
  1599. return io.ErrUnexpectedEOF
  1600. }
  1601. b := dAtA[iNdEx]
  1602. iNdEx++
  1603. wire |= (uint64(b) & 0x7F) << shift
  1604. if b < 0x80 {
  1605. break
  1606. }
  1607. }
  1608. fieldNum := int32(wire >> 3)
  1609. wireType := int(wire & 0x7)
  1610. if wireType == 4 {
  1611. return fmt.Errorf("proto: PingReply: wiretype end group for non-group")
  1612. }
  1613. if fieldNum <= 0 {
  1614. return fmt.Errorf("proto: PingReply: illegal tag %d (wire type %d)", fieldNum, wire)
  1615. }
  1616. switch fieldNum {
  1617. default:
  1618. iNdEx = preIndex
  1619. skippy, err := skipApi(dAtA[iNdEx:])
  1620. if err != nil {
  1621. return err
  1622. }
  1623. if skippy < 0 {
  1624. return ErrInvalidLengthApi
  1625. }
  1626. if (iNdEx + skippy) > l {
  1627. return io.ErrUnexpectedEOF
  1628. }
  1629. iNdEx += skippy
  1630. }
  1631. }
  1632. if iNdEx > l {
  1633. return io.ErrUnexpectedEOF
  1634. }
  1635. return nil
  1636. }
  1637. func (m *PingReq) Unmarshal(dAtA []byte) error {
  1638. l := len(dAtA)
  1639. iNdEx := 0
  1640. for iNdEx < l {
  1641. preIndex := iNdEx
  1642. var wire uint64
  1643. for shift := uint(0); ; shift += 7 {
  1644. if shift >= 64 {
  1645. return ErrIntOverflowApi
  1646. }
  1647. if iNdEx >= l {
  1648. return io.ErrUnexpectedEOF
  1649. }
  1650. b := dAtA[iNdEx]
  1651. iNdEx++
  1652. wire |= (uint64(b) & 0x7F) << shift
  1653. if b < 0x80 {
  1654. break
  1655. }
  1656. }
  1657. fieldNum := int32(wire >> 3)
  1658. wireType := int(wire & 0x7)
  1659. if wireType == 4 {
  1660. return fmt.Errorf("proto: PingReq: wiretype end group for non-group")
  1661. }
  1662. if fieldNum <= 0 {
  1663. return fmt.Errorf("proto: PingReq: illegal tag %d (wire type %d)", fieldNum, wire)
  1664. }
  1665. switch fieldNum {
  1666. default:
  1667. iNdEx = preIndex
  1668. skippy, err := skipApi(dAtA[iNdEx:])
  1669. if err != nil {
  1670. return err
  1671. }
  1672. if skippy < 0 {
  1673. return ErrInvalidLengthApi
  1674. }
  1675. if (iNdEx + skippy) > l {
  1676. return io.ErrUnexpectedEOF
  1677. }
  1678. iNdEx += skippy
  1679. }
  1680. }
  1681. if iNdEx > l {
  1682. return io.ErrUnexpectedEOF
  1683. }
  1684. return nil
  1685. }
  1686. func (m *ConnectReq) Unmarshal(dAtA []byte) error {
  1687. l := len(dAtA)
  1688. iNdEx := 0
  1689. for iNdEx < l {
  1690. preIndex := iNdEx
  1691. var wire uint64
  1692. for shift := uint(0); ; shift += 7 {
  1693. if shift >= 64 {
  1694. return ErrIntOverflowApi
  1695. }
  1696. if iNdEx >= l {
  1697. return io.ErrUnexpectedEOF
  1698. }
  1699. b := dAtA[iNdEx]
  1700. iNdEx++
  1701. wire |= (uint64(b) & 0x7F) << shift
  1702. if b < 0x80 {
  1703. break
  1704. }
  1705. }
  1706. fieldNum := int32(wire >> 3)
  1707. wireType := int(wire & 0x7)
  1708. if wireType == 4 {
  1709. return fmt.Errorf("proto: ConnectReq: wiretype end group for non-group")
  1710. }
  1711. if fieldNum <= 0 {
  1712. return fmt.Errorf("proto: ConnectReq: illegal tag %d (wire type %d)", fieldNum, wire)
  1713. }
  1714. switch fieldNum {
  1715. case 1:
  1716. if wireType != 2 {
  1717. return fmt.Errorf("proto: wrong wireType = %d for field Server", wireType)
  1718. }
  1719. var stringLen uint64
  1720. for shift := uint(0); ; shift += 7 {
  1721. if shift >= 64 {
  1722. return ErrIntOverflowApi
  1723. }
  1724. if iNdEx >= l {
  1725. return io.ErrUnexpectedEOF
  1726. }
  1727. b := dAtA[iNdEx]
  1728. iNdEx++
  1729. stringLen |= (uint64(b) & 0x7F) << shift
  1730. if b < 0x80 {
  1731. break
  1732. }
  1733. }
  1734. intStringLen := int(stringLen)
  1735. if intStringLen < 0 {
  1736. return ErrInvalidLengthApi
  1737. }
  1738. postIndex := iNdEx + intStringLen
  1739. if postIndex > l {
  1740. return io.ErrUnexpectedEOF
  1741. }
  1742. m.Server = string(dAtA[iNdEx:postIndex])
  1743. iNdEx = postIndex
  1744. case 2:
  1745. if wireType != 2 {
  1746. return fmt.Errorf("proto: wrong wireType = %d for field ServerKey", wireType)
  1747. }
  1748. var stringLen uint64
  1749. for shift := uint(0); ; shift += 7 {
  1750. if shift >= 64 {
  1751. return ErrIntOverflowApi
  1752. }
  1753. if iNdEx >= l {
  1754. return io.ErrUnexpectedEOF
  1755. }
  1756. b := dAtA[iNdEx]
  1757. iNdEx++
  1758. stringLen |= (uint64(b) & 0x7F) << shift
  1759. if b < 0x80 {
  1760. break
  1761. }
  1762. }
  1763. intStringLen := int(stringLen)
  1764. if intStringLen < 0 {
  1765. return ErrInvalidLengthApi
  1766. }
  1767. postIndex := iNdEx + intStringLen
  1768. if postIndex > l {
  1769. return io.ErrUnexpectedEOF
  1770. }
  1771. m.ServerKey = string(dAtA[iNdEx:postIndex])
  1772. iNdEx = postIndex
  1773. case 3:
  1774. if wireType != 2 {
  1775. return fmt.Errorf("proto: wrong wireType = %d for field Cookie", wireType)
  1776. }
  1777. var stringLen uint64
  1778. for shift := uint(0); ; shift += 7 {
  1779. if shift >= 64 {
  1780. return ErrIntOverflowApi
  1781. }
  1782. if iNdEx >= l {
  1783. return io.ErrUnexpectedEOF
  1784. }
  1785. b := dAtA[iNdEx]
  1786. iNdEx++
  1787. stringLen |= (uint64(b) & 0x7F) << shift
  1788. if b < 0x80 {
  1789. break
  1790. }
  1791. }
  1792. intStringLen := int(stringLen)
  1793. if intStringLen < 0 {
  1794. return ErrInvalidLengthApi
  1795. }
  1796. postIndex := iNdEx + intStringLen
  1797. if postIndex > l {
  1798. return io.ErrUnexpectedEOF
  1799. }
  1800. m.Cookie = string(dAtA[iNdEx:postIndex])
  1801. iNdEx = postIndex
  1802. case 4:
  1803. if wireType != 2 {
  1804. return fmt.Errorf("proto: wrong wireType = %d for field Token", wireType)
  1805. }
  1806. var byteLen int
  1807. for shift := uint(0); ; shift += 7 {
  1808. if shift >= 64 {
  1809. return ErrIntOverflowApi
  1810. }
  1811. if iNdEx >= l {
  1812. return io.ErrUnexpectedEOF
  1813. }
  1814. b := dAtA[iNdEx]
  1815. iNdEx++
  1816. byteLen |= (int(b) & 0x7F) << shift
  1817. if b < 0x80 {
  1818. break
  1819. }
  1820. }
  1821. if byteLen < 0 {
  1822. return ErrInvalidLengthApi
  1823. }
  1824. postIndex := iNdEx + byteLen
  1825. if postIndex > l {
  1826. return io.ErrUnexpectedEOF
  1827. }
  1828. m.Token = append(m.Token[:0], dAtA[iNdEx:postIndex]...)
  1829. if m.Token == nil {
  1830. m.Token = []byte{}
  1831. }
  1832. iNdEx = postIndex
  1833. default:
  1834. iNdEx = preIndex
  1835. skippy, err := skipApi(dAtA[iNdEx:])
  1836. if err != nil {
  1837. return err
  1838. }
  1839. if skippy < 0 {
  1840. return ErrInvalidLengthApi
  1841. }
  1842. if (iNdEx + skippy) > l {
  1843. return io.ErrUnexpectedEOF
  1844. }
  1845. iNdEx += skippy
  1846. }
  1847. }
  1848. if iNdEx > l {
  1849. return io.ErrUnexpectedEOF
  1850. }
  1851. return nil
  1852. }
  1853. func (m *ConnectReply) Unmarshal(dAtA []byte) error {
  1854. l := len(dAtA)
  1855. iNdEx := 0
  1856. for iNdEx < l {
  1857. preIndex := iNdEx
  1858. var wire uint64
  1859. for shift := uint(0); ; shift += 7 {
  1860. if shift >= 64 {
  1861. return ErrIntOverflowApi
  1862. }
  1863. if iNdEx >= l {
  1864. return io.ErrUnexpectedEOF
  1865. }
  1866. b := dAtA[iNdEx]
  1867. iNdEx++
  1868. wire |= (uint64(b) & 0x7F) << shift
  1869. if b < 0x80 {
  1870. break
  1871. }
  1872. }
  1873. fieldNum := int32(wire >> 3)
  1874. wireType := int(wire & 0x7)
  1875. if wireType == 4 {
  1876. return fmt.Errorf("proto: ConnectReply: wiretype end group for non-group")
  1877. }
  1878. if fieldNum <= 0 {
  1879. return fmt.Errorf("proto: ConnectReply: illegal tag %d (wire type %d)", fieldNum, wire)
  1880. }
  1881. switch fieldNum {
  1882. case 1:
  1883. if wireType != 0 {
  1884. return fmt.Errorf("proto: wrong wireType = %d for field Mid", wireType)
  1885. }
  1886. m.Mid = 0
  1887. for shift := uint(0); ; shift += 7 {
  1888. if shift >= 64 {
  1889. return ErrIntOverflowApi
  1890. }
  1891. if iNdEx >= l {
  1892. return io.ErrUnexpectedEOF
  1893. }
  1894. b := dAtA[iNdEx]
  1895. iNdEx++
  1896. m.Mid |= (int64(b) & 0x7F) << shift
  1897. if b < 0x80 {
  1898. break
  1899. }
  1900. }
  1901. case 2:
  1902. if wireType != 2 {
  1903. return fmt.Errorf("proto: wrong wireType = %d for field Key", wireType)
  1904. }
  1905. var stringLen uint64
  1906. for shift := uint(0); ; shift += 7 {
  1907. if shift >= 64 {
  1908. return ErrIntOverflowApi
  1909. }
  1910. if iNdEx >= l {
  1911. return io.ErrUnexpectedEOF
  1912. }
  1913. b := dAtA[iNdEx]
  1914. iNdEx++
  1915. stringLen |= (uint64(b) & 0x7F) << shift
  1916. if b < 0x80 {
  1917. break
  1918. }
  1919. }
  1920. intStringLen := int(stringLen)
  1921. if intStringLen < 0 {
  1922. return ErrInvalidLengthApi
  1923. }
  1924. postIndex := iNdEx + intStringLen
  1925. if postIndex > l {
  1926. return io.ErrUnexpectedEOF
  1927. }
  1928. m.Key = string(dAtA[iNdEx:postIndex])
  1929. iNdEx = postIndex
  1930. case 3:
  1931. if wireType != 2 {
  1932. return fmt.Errorf("proto: wrong wireType = %d for field RoomID", wireType)
  1933. }
  1934. var stringLen uint64
  1935. for shift := uint(0); ; shift += 7 {
  1936. if shift >= 64 {
  1937. return ErrIntOverflowApi
  1938. }
  1939. if iNdEx >= l {
  1940. return io.ErrUnexpectedEOF
  1941. }
  1942. b := dAtA[iNdEx]
  1943. iNdEx++
  1944. stringLen |= (uint64(b) & 0x7F) << shift
  1945. if b < 0x80 {
  1946. break
  1947. }
  1948. }
  1949. intStringLen := int(stringLen)
  1950. if intStringLen < 0 {
  1951. return ErrInvalidLengthApi
  1952. }
  1953. postIndex := iNdEx + intStringLen
  1954. if postIndex > l {
  1955. return io.ErrUnexpectedEOF
  1956. }
  1957. m.RoomID = string(dAtA[iNdEx:postIndex])
  1958. iNdEx = postIndex
  1959. case 4:
  1960. if wireType != 2 {
  1961. return fmt.Errorf("proto: wrong wireType = %d for field Platform", wireType)
  1962. }
  1963. var stringLen uint64
  1964. for shift := uint(0); ; shift += 7 {
  1965. if shift >= 64 {
  1966. return ErrIntOverflowApi
  1967. }
  1968. if iNdEx >= l {
  1969. return io.ErrUnexpectedEOF
  1970. }
  1971. b := dAtA[iNdEx]
  1972. iNdEx++
  1973. stringLen |= (uint64(b) & 0x7F) << shift
  1974. if b < 0x80 {
  1975. break
  1976. }
  1977. }
  1978. intStringLen := int(stringLen)
  1979. if intStringLen < 0 {
  1980. return ErrInvalidLengthApi
  1981. }
  1982. postIndex := iNdEx + intStringLen
  1983. if postIndex > l {
  1984. return io.ErrUnexpectedEOF
  1985. }
  1986. m.Platform = string(dAtA[iNdEx:postIndex])
  1987. iNdEx = postIndex
  1988. case 5:
  1989. if wireType == 0 {
  1990. var v int32
  1991. for shift := uint(0); ; shift += 7 {
  1992. if shift >= 64 {
  1993. return ErrIntOverflowApi
  1994. }
  1995. if iNdEx >= l {
  1996. return io.ErrUnexpectedEOF
  1997. }
  1998. b := dAtA[iNdEx]
  1999. iNdEx++
  2000. v |= (int32(b) & 0x7F) << shift
  2001. if b < 0x80 {
  2002. break
  2003. }
  2004. }
  2005. m.Accepts = append(m.Accepts, v)
  2006. } else if wireType == 2 {
  2007. var packedLen int
  2008. for shift := uint(0); ; shift += 7 {
  2009. if shift >= 64 {
  2010. return ErrIntOverflowApi
  2011. }
  2012. if iNdEx >= l {
  2013. return io.ErrUnexpectedEOF
  2014. }
  2015. b := dAtA[iNdEx]
  2016. iNdEx++
  2017. packedLen |= (int(b) & 0x7F) << shift
  2018. if b < 0x80 {
  2019. break
  2020. }
  2021. }
  2022. if packedLen < 0 {
  2023. return ErrInvalidLengthApi
  2024. }
  2025. postIndex := iNdEx + packedLen
  2026. if postIndex > l {
  2027. return io.ErrUnexpectedEOF
  2028. }
  2029. for iNdEx < postIndex {
  2030. var v int32
  2031. for shift := uint(0); ; shift += 7 {
  2032. if shift >= 64 {
  2033. return ErrIntOverflowApi
  2034. }
  2035. if iNdEx >= l {
  2036. return io.ErrUnexpectedEOF
  2037. }
  2038. b := dAtA[iNdEx]
  2039. iNdEx++
  2040. v |= (int32(b) & 0x7F) << shift
  2041. if b < 0x80 {
  2042. break
  2043. }
  2044. }
  2045. m.Accepts = append(m.Accepts, v)
  2046. }
  2047. } else {
  2048. return fmt.Errorf("proto: wrong wireType = %d for field Accepts", wireType)
  2049. }
  2050. default:
  2051. iNdEx = preIndex
  2052. skippy, err := skipApi(dAtA[iNdEx:])
  2053. if err != nil {
  2054. return err
  2055. }
  2056. if skippy < 0 {
  2057. return ErrInvalidLengthApi
  2058. }
  2059. if (iNdEx + skippy) > l {
  2060. return io.ErrUnexpectedEOF
  2061. }
  2062. iNdEx += skippy
  2063. }
  2064. }
  2065. if iNdEx > l {
  2066. return io.ErrUnexpectedEOF
  2067. }
  2068. return nil
  2069. }
  2070. func (m *DisconnectReq) Unmarshal(dAtA []byte) error {
  2071. l := len(dAtA)
  2072. iNdEx := 0
  2073. for iNdEx < l {
  2074. preIndex := iNdEx
  2075. var wire uint64
  2076. for shift := uint(0); ; shift += 7 {
  2077. if shift >= 64 {
  2078. return ErrIntOverflowApi
  2079. }
  2080. if iNdEx >= l {
  2081. return io.ErrUnexpectedEOF
  2082. }
  2083. b := dAtA[iNdEx]
  2084. iNdEx++
  2085. wire |= (uint64(b) & 0x7F) << shift
  2086. if b < 0x80 {
  2087. break
  2088. }
  2089. }
  2090. fieldNum := int32(wire >> 3)
  2091. wireType := int(wire & 0x7)
  2092. if wireType == 4 {
  2093. return fmt.Errorf("proto: DisconnectReq: wiretype end group for non-group")
  2094. }
  2095. if fieldNum <= 0 {
  2096. return fmt.Errorf("proto: DisconnectReq: illegal tag %d (wire type %d)", fieldNum, wire)
  2097. }
  2098. switch fieldNum {
  2099. case 1:
  2100. if wireType != 0 {
  2101. return fmt.Errorf("proto: wrong wireType = %d for field Mid", wireType)
  2102. }
  2103. m.Mid = 0
  2104. for shift := uint(0); ; shift += 7 {
  2105. if shift >= 64 {
  2106. return ErrIntOverflowApi
  2107. }
  2108. if iNdEx >= l {
  2109. return io.ErrUnexpectedEOF
  2110. }
  2111. b := dAtA[iNdEx]
  2112. iNdEx++
  2113. m.Mid |= (int64(b) & 0x7F) << shift
  2114. if b < 0x80 {
  2115. break
  2116. }
  2117. }
  2118. case 2:
  2119. if wireType != 2 {
  2120. return fmt.Errorf("proto: wrong wireType = %d for field Key", wireType)
  2121. }
  2122. var stringLen uint64
  2123. for shift := uint(0); ; shift += 7 {
  2124. if shift >= 64 {
  2125. return ErrIntOverflowApi
  2126. }
  2127. if iNdEx >= l {
  2128. return io.ErrUnexpectedEOF
  2129. }
  2130. b := dAtA[iNdEx]
  2131. iNdEx++
  2132. stringLen |= (uint64(b) & 0x7F) << shift
  2133. if b < 0x80 {
  2134. break
  2135. }
  2136. }
  2137. intStringLen := int(stringLen)
  2138. if intStringLen < 0 {
  2139. return ErrInvalidLengthApi
  2140. }
  2141. postIndex := iNdEx + intStringLen
  2142. if postIndex > l {
  2143. return io.ErrUnexpectedEOF
  2144. }
  2145. m.Key = string(dAtA[iNdEx:postIndex])
  2146. iNdEx = postIndex
  2147. case 3:
  2148. if wireType != 2 {
  2149. return fmt.Errorf("proto: wrong wireType = %d for field Server", wireType)
  2150. }
  2151. var stringLen uint64
  2152. for shift := uint(0); ; shift += 7 {
  2153. if shift >= 64 {
  2154. return ErrIntOverflowApi
  2155. }
  2156. if iNdEx >= l {
  2157. return io.ErrUnexpectedEOF
  2158. }
  2159. b := dAtA[iNdEx]
  2160. iNdEx++
  2161. stringLen |= (uint64(b) & 0x7F) << shift
  2162. if b < 0x80 {
  2163. break
  2164. }
  2165. }
  2166. intStringLen := int(stringLen)
  2167. if intStringLen < 0 {
  2168. return ErrInvalidLengthApi
  2169. }
  2170. postIndex := iNdEx + intStringLen
  2171. if postIndex > l {
  2172. return io.ErrUnexpectedEOF
  2173. }
  2174. m.Server = string(dAtA[iNdEx:postIndex])
  2175. iNdEx = postIndex
  2176. default:
  2177. iNdEx = preIndex
  2178. skippy, err := skipApi(dAtA[iNdEx:])
  2179. if err != nil {
  2180. return err
  2181. }
  2182. if skippy < 0 {
  2183. return ErrInvalidLengthApi
  2184. }
  2185. if (iNdEx + skippy) > l {
  2186. return io.ErrUnexpectedEOF
  2187. }
  2188. iNdEx += skippy
  2189. }
  2190. }
  2191. if iNdEx > l {
  2192. return io.ErrUnexpectedEOF
  2193. }
  2194. return nil
  2195. }
  2196. func (m *DisconnectReply) Unmarshal(dAtA []byte) error {
  2197. l := len(dAtA)
  2198. iNdEx := 0
  2199. for iNdEx < l {
  2200. preIndex := iNdEx
  2201. var wire uint64
  2202. for shift := uint(0); ; shift += 7 {
  2203. if shift >= 64 {
  2204. return ErrIntOverflowApi
  2205. }
  2206. if iNdEx >= l {
  2207. return io.ErrUnexpectedEOF
  2208. }
  2209. b := dAtA[iNdEx]
  2210. iNdEx++
  2211. wire |= (uint64(b) & 0x7F) << shift
  2212. if b < 0x80 {
  2213. break
  2214. }
  2215. }
  2216. fieldNum := int32(wire >> 3)
  2217. wireType := int(wire & 0x7)
  2218. if wireType == 4 {
  2219. return fmt.Errorf("proto: DisconnectReply: wiretype end group for non-group")
  2220. }
  2221. if fieldNum <= 0 {
  2222. return fmt.Errorf("proto: DisconnectReply: illegal tag %d (wire type %d)", fieldNum, wire)
  2223. }
  2224. switch fieldNum {
  2225. case 1:
  2226. if wireType != 0 {
  2227. return fmt.Errorf("proto: wrong wireType = %d for field Has", wireType)
  2228. }
  2229. var v int
  2230. for shift := uint(0); ; shift += 7 {
  2231. if shift >= 64 {
  2232. return ErrIntOverflowApi
  2233. }
  2234. if iNdEx >= l {
  2235. return io.ErrUnexpectedEOF
  2236. }
  2237. b := dAtA[iNdEx]
  2238. iNdEx++
  2239. v |= (int(b) & 0x7F) << shift
  2240. if b < 0x80 {
  2241. break
  2242. }
  2243. }
  2244. m.Has = bool(v != 0)
  2245. default:
  2246. iNdEx = preIndex
  2247. skippy, err := skipApi(dAtA[iNdEx:])
  2248. if err != nil {
  2249. return err
  2250. }
  2251. if skippy < 0 {
  2252. return ErrInvalidLengthApi
  2253. }
  2254. if (iNdEx + skippy) > l {
  2255. return io.ErrUnexpectedEOF
  2256. }
  2257. iNdEx += skippy
  2258. }
  2259. }
  2260. if iNdEx > l {
  2261. return io.ErrUnexpectedEOF
  2262. }
  2263. return nil
  2264. }
  2265. func (m *HeartbeatReq) Unmarshal(dAtA []byte) error {
  2266. l := len(dAtA)
  2267. iNdEx := 0
  2268. for iNdEx < l {
  2269. preIndex := iNdEx
  2270. var wire uint64
  2271. for shift := uint(0); ; shift += 7 {
  2272. if shift >= 64 {
  2273. return ErrIntOverflowApi
  2274. }
  2275. if iNdEx >= l {
  2276. return io.ErrUnexpectedEOF
  2277. }
  2278. b := dAtA[iNdEx]
  2279. iNdEx++
  2280. wire |= (uint64(b) & 0x7F) << shift
  2281. if b < 0x80 {
  2282. break
  2283. }
  2284. }
  2285. fieldNum := int32(wire >> 3)
  2286. wireType := int(wire & 0x7)
  2287. if wireType == 4 {
  2288. return fmt.Errorf("proto: HeartbeatReq: wiretype end group for non-group")
  2289. }
  2290. if fieldNum <= 0 {
  2291. return fmt.Errorf("proto: HeartbeatReq: illegal tag %d (wire type %d)", fieldNum, wire)
  2292. }
  2293. switch fieldNum {
  2294. case 1:
  2295. if wireType != 0 {
  2296. return fmt.Errorf("proto: wrong wireType = %d for field Mid", wireType)
  2297. }
  2298. m.Mid = 0
  2299. for shift := uint(0); ; shift += 7 {
  2300. if shift >= 64 {
  2301. return ErrIntOverflowApi
  2302. }
  2303. if iNdEx >= l {
  2304. return io.ErrUnexpectedEOF
  2305. }
  2306. b := dAtA[iNdEx]
  2307. iNdEx++
  2308. m.Mid |= (int64(b) & 0x7F) << shift
  2309. if b < 0x80 {
  2310. break
  2311. }
  2312. }
  2313. case 2:
  2314. if wireType != 2 {
  2315. return fmt.Errorf("proto: wrong wireType = %d for field Key", wireType)
  2316. }
  2317. var stringLen uint64
  2318. for shift := uint(0); ; shift += 7 {
  2319. if shift >= 64 {
  2320. return ErrIntOverflowApi
  2321. }
  2322. if iNdEx >= l {
  2323. return io.ErrUnexpectedEOF
  2324. }
  2325. b := dAtA[iNdEx]
  2326. iNdEx++
  2327. stringLen |= (uint64(b) & 0x7F) << shift
  2328. if b < 0x80 {
  2329. break
  2330. }
  2331. }
  2332. intStringLen := int(stringLen)
  2333. if intStringLen < 0 {
  2334. return ErrInvalidLengthApi
  2335. }
  2336. postIndex := iNdEx + intStringLen
  2337. if postIndex > l {
  2338. return io.ErrUnexpectedEOF
  2339. }
  2340. m.Key = string(dAtA[iNdEx:postIndex])
  2341. iNdEx = postIndex
  2342. case 3:
  2343. if wireType != 2 {
  2344. return fmt.Errorf("proto: wrong wireType = %d for field Server", wireType)
  2345. }
  2346. var stringLen uint64
  2347. for shift := uint(0); ; shift += 7 {
  2348. if shift >= 64 {
  2349. return ErrIntOverflowApi
  2350. }
  2351. if iNdEx >= l {
  2352. return io.ErrUnexpectedEOF
  2353. }
  2354. b := dAtA[iNdEx]
  2355. iNdEx++
  2356. stringLen |= (uint64(b) & 0x7F) << shift
  2357. if b < 0x80 {
  2358. break
  2359. }
  2360. }
  2361. intStringLen := int(stringLen)
  2362. if intStringLen < 0 {
  2363. return ErrInvalidLengthApi
  2364. }
  2365. postIndex := iNdEx + intStringLen
  2366. if postIndex > l {
  2367. return io.ErrUnexpectedEOF
  2368. }
  2369. m.Server = string(dAtA[iNdEx:postIndex])
  2370. iNdEx = postIndex
  2371. default:
  2372. iNdEx = preIndex
  2373. skippy, err := skipApi(dAtA[iNdEx:])
  2374. if err != nil {
  2375. return err
  2376. }
  2377. if skippy < 0 {
  2378. return ErrInvalidLengthApi
  2379. }
  2380. if (iNdEx + skippy) > l {
  2381. return io.ErrUnexpectedEOF
  2382. }
  2383. iNdEx += skippy
  2384. }
  2385. }
  2386. if iNdEx > l {
  2387. return io.ErrUnexpectedEOF
  2388. }
  2389. return nil
  2390. }
  2391. func (m *HeartbeatReply) Unmarshal(dAtA []byte) error {
  2392. l := len(dAtA)
  2393. iNdEx := 0
  2394. for iNdEx < l {
  2395. preIndex := iNdEx
  2396. var wire uint64
  2397. for shift := uint(0); ; shift += 7 {
  2398. if shift >= 64 {
  2399. return ErrIntOverflowApi
  2400. }
  2401. if iNdEx >= l {
  2402. return io.ErrUnexpectedEOF
  2403. }
  2404. b := dAtA[iNdEx]
  2405. iNdEx++
  2406. wire |= (uint64(b) & 0x7F) << shift
  2407. if b < 0x80 {
  2408. break
  2409. }
  2410. }
  2411. fieldNum := int32(wire >> 3)
  2412. wireType := int(wire & 0x7)
  2413. if wireType == 4 {
  2414. return fmt.Errorf("proto: HeartbeatReply: wiretype end group for non-group")
  2415. }
  2416. if fieldNum <= 0 {
  2417. return fmt.Errorf("proto: HeartbeatReply: illegal tag %d (wire type %d)", fieldNum, wire)
  2418. }
  2419. switch fieldNum {
  2420. default:
  2421. iNdEx = preIndex
  2422. skippy, err := skipApi(dAtA[iNdEx:])
  2423. if err != nil {
  2424. return err
  2425. }
  2426. if skippy < 0 {
  2427. return ErrInvalidLengthApi
  2428. }
  2429. if (iNdEx + skippy) > l {
  2430. return io.ErrUnexpectedEOF
  2431. }
  2432. iNdEx += skippy
  2433. }
  2434. }
  2435. if iNdEx > l {
  2436. return io.ErrUnexpectedEOF
  2437. }
  2438. return nil
  2439. }
  2440. func (m *OnlineReq) Unmarshal(dAtA []byte) error {
  2441. l := len(dAtA)
  2442. iNdEx := 0
  2443. for iNdEx < l {
  2444. preIndex := iNdEx
  2445. var wire uint64
  2446. for shift := uint(0); ; shift += 7 {
  2447. if shift >= 64 {
  2448. return ErrIntOverflowApi
  2449. }
  2450. if iNdEx >= l {
  2451. return io.ErrUnexpectedEOF
  2452. }
  2453. b := dAtA[iNdEx]
  2454. iNdEx++
  2455. wire |= (uint64(b) & 0x7F) << shift
  2456. if b < 0x80 {
  2457. break
  2458. }
  2459. }
  2460. fieldNum := int32(wire >> 3)
  2461. wireType := int(wire & 0x7)
  2462. if wireType == 4 {
  2463. return fmt.Errorf("proto: OnlineReq: wiretype end group for non-group")
  2464. }
  2465. if fieldNum <= 0 {
  2466. return fmt.Errorf("proto: OnlineReq: illegal tag %d (wire type %d)", fieldNum, wire)
  2467. }
  2468. switch fieldNum {
  2469. case 1:
  2470. if wireType != 2 {
  2471. return fmt.Errorf("proto: wrong wireType = %d for field Server", wireType)
  2472. }
  2473. var stringLen uint64
  2474. for shift := uint(0); ; shift += 7 {
  2475. if shift >= 64 {
  2476. return ErrIntOverflowApi
  2477. }
  2478. if iNdEx >= l {
  2479. return io.ErrUnexpectedEOF
  2480. }
  2481. b := dAtA[iNdEx]
  2482. iNdEx++
  2483. stringLen |= (uint64(b) & 0x7F) << shift
  2484. if b < 0x80 {
  2485. break
  2486. }
  2487. }
  2488. intStringLen := int(stringLen)
  2489. if intStringLen < 0 {
  2490. return ErrInvalidLengthApi
  2491. }
  2492. postIndex := iNdEx + intStringLen
  2493. if postIndex > l {
  2494. return io.ErrUnexpectedEOF
  2495. }
  2496. m.Server = string(dAtA[iNdEx:postIndex])
  2497. iNdEx = postIndex
  2498. case 2:
  2499. if wireType != 2 {
  2500. return fmt.Errorf("proto: wrong wireType = %d for field RoomCount", wireType)
  2501. }
  2502. var msglen int
  2503. for shift := uint(0); ; shift += 7 {
  2504. if shift >= 64 {
  2505. return ErrIntOverflowApi
  2506. }
  2507. if iNdEx >= l {
  2508. return io.ErrUnexpectedEOF
  2509. }
  2510. b := dAtA[iNdEx]
  2511. iNdEx++
  2512. msglen |= (int(b) & 0x7F) << shift
  2513. if b < 0x80 {
  2514. break
  2515. }
  2516. }
  2517. if msglen < 0 {
  2518. return ErrInvalidLengthApi
  2519. }
  2520. postIndex := iNdEx + msglen
  2521. if postIndex > l {
  2522. return io.ErrUnexpectedEOF
  2523. }
  2524. if m.RoomCount == nil {
  2525. m.RoomCount = make(map[string]int32)
  2526. }
  2527. var mapkey string
  2528. var mapvalue int32
  2529. for iNdEx < postIndex {
  2530. entryPreIndex := iNdEx
  2531. var wire uint64
  2532. for shift := uint(0); ; shift += 7 {
  2533. if shift >= 64 {
  2534. return ErrIntOverflowApi
  2535. }
  2536. if iNdEx >= l {
  2537. return io.ErrUnexpectedEOF
  2538. }
  2539. b := dAtA[iNdEx]
  2540. iNdEx++
  2541. wire |= (uint64(b) & 0x7F) << shift
  2542. if b < 0x80 {
  2543. break
  2544. }
  2545. }
  2546. fieldNum := int32(wire >> 3)
  2547. if fieldNum == 1 {
  2548. var stringLenmapkey uint64
  2549. for shift := uint(0); ; shift += 7 {
  2550. if shift >= 64 {
  2551. return ErrIntOverflowApi
  2552. }
  2553. if iNdEx >= l {
  2554. return io.ErrUnexpectedEOF
  2555. }
  2556. b := dAtA[iNdEx]
  2557. iNdEx++
  2558. stringLenmapkey |= (uint64(b) & 0x7F) << shift
  2559. if b < 0x80 {
  2560. break
  2561. }
  2562. }
  2563. intStringLenmapkey := int(stringLenmapkey)
  2564. if intStringLenmapkey < 0 {
  2565. return ErrInvalidLengthApi
  2566. }
  2567. postStringIndexmapkey := iNdEx + intStringLenmapkey
  2568. if postStringIndexmapkey > l {
  2569. return io.ErrUnexpectedEOF
  2570. }
  2571. mapkey = string(dAtA[iNdEx:postStringIndexmapkey])
  2572. iNdEx = postStringIndexmapkey
  2573. } else if fieldNum == 2 {
  2574. for shift := uint(0); ; shift += 7 {
  2575. if shift >= 64 {
  2576. return ErrIntOverflowApi
  2577. }
  2578. if iNdEx >= l {
  2579. return io.ErrUnexpectedEOF
  2580. }
  2581. b := dAtA[iNdEx]
  2582. iNdEx++
  2583. mapvalue |= (int32(b) & 0x7F) << shift
  2584. if b < 0x80 {
  2585. break
  2586. }
  2587. }
  2588. } else {
  2589. iNdEx = entryPreIndex
  2590. skippy, err := skipApi(dAtA[iNdEx:])
  2591. if err != nil {
  2592. return err
  2593. }
  2594. if skippy < 0 {
  2595. return ErrInvalidLengthApi
  2596. }
  2597. if (iNdEx + skippy) > postIndex {
  2598. return io.ErrUnexpectedEOF
  2599. }
  2600. iNdEx += skippy
  2601. }
  2602. }
  2603. m.RoomCount[mapkey] = mapvalue
  2604. iNdEx = postIndex
  2605. case 3:
  2606. if wireType != 0 {
  2607. return fmt.Errorf("proto: wrong wireType = %d for field Sharding", wireType)
  2608. }
  2609. m.Sharding = 0
  2610. for shift := uint(0); ; shift += 7 {
  2611. if shift >= 64 {
  2612. return ErrIntOverflowApi
  2613. }
  2614. if iNdEx >= l {
  2615. return io.ErrUnexpectedEOF
  2616. }
  2617. b := dAtA[iNdEx]
  2618. iNdEx++
  2619. m.Sharding |= (int32(b) & 0x7F) << shift
  2620. if b < 0x80 {
  2621. break
  2622. }
  2623. }
  2624. default:
  2625. iNdEx = preIndex
  2626. skippy, err := skipApi(dAtA[iNdEx:])
  2627. if err != nil {
  2628. return err
  2629. }
  2630. if skippy < 0 {
  2631. return ErrInvalidLengthApi
  2632. }
  2633. if (iNdEx + skippy) > l {
  2634. return io.ErrUnexpectedEOF
  2635. }
  2636. iNdEx += skippy
  2637. }
  2638. }
  2639. if iNdEx > l {
  2640. return io.ErrUnexpectedEOF
  2641. }
  2642. return nil
  2643. }
  2644. func (m *OnlineReply) Unmarshal(dAtA []byte) error {
  2645. l := len(dAtA)
  2646. iNdEx := 0
  2647. for iNdEx < l {
  2648. preIndex := iNdEx
  2649. var wire uint64
  2650. for shift := uint(0); ; shift += 7 {
  2651. if shift >= 64 {
  2652. return ErrIntOverflowApi
  2653. }
  2654. if iNdEx >= l {
  2655. return io.ErrUnexpectedEOF
  2656. }
  2657. b := dAtA[iNdEx]
  2658. iNdEx++
  2659. wire |= (uint64(b) & 0x7F) << shift
  2660. if b < 0x80 {
  2661. break
  2662. }
  2663. }
  2664. fieldNum := int32(wire >> 3)
  2665. wireType := int(wire & 0x7)
  2666. if wireType == 4 {
  2667. return fmt.Errorf("proto: OnlineReply: wiretype end group for non-group")
  2668. }
  2669. if fieldNum <= 0 {
  2670. return fmt.Errorf("proto: OnlineReply: illegal tag %d (wire type %d)", fieldNum, wire)
  2671. }
  2672. switch fieldNum {
  2673. case 1:
  2674. if wireType != 2 {
  2675. return fmt.Errorf("proto: wrong wireType = %d for field RoomCount", wireType)
  2676. }
  2677. var msglen int
  2678. for shift := uint(0); ; shift += 7 {
  2679. if shift >= 64 {
  2680. return ErrIntOverflowApi
  2681. }
  2682. if iNdEx >= l {
  2683. return io.ErrUnexpectedEOF
  2684. }
  2685. b := dAtA[iNdEx]
  2686. iNdEx++
  2687. msglen |= (int(b) & 0x7F) << shift
  2688. if b < 0x80 {
  2689. break
  2690. }
  2691. }
  2692. if msglen < 0 {
  2693. return ErrInvalidLengthApi
  2694. }
  2695. postIndex := iNdEx + msglen
  2696. if postIndex > l {
  2697. return io.ErrUnexpectedEOF
  2698. }
  2699. if m.RoomCount == nil {
  2700. m.RoomCount = make(map[string]int32)
  2701. }
  2702. var mapkey string
  2703. var mapvalue int32
  2704. for iNdEx < postIndex {
  2705. entryPreIndex := iNdEx
  2706. var wire uint64
  2707. for shift := uint(0); ; shift += 7 {
  2708. if shift >= 64 {
  2709. return ErrIntOverflowApi
  2710. }
  2711. if iNdEx >= l {
  2712. return io.ErrUnexpectedEOF
  2713. }
  2714. b := dAtA[iNdEx]
  2715. iNdEx++
  2716. wire |= (uint64(b) & 0x7F) << shift
  2717. if b < 0x80 {
  2718. break
  2719. }
  2720. }
  2721. fieldNum := int32(wire >> 3)
  2722. if fieldNum == 1 {
  2723. var stringLenmapkey uint64
  2724. for shift := uint(0); ; shift += 7 {
  2725. if shift >= 64 {
  2726. return ErrIntOverflowApi
  2727. }
  2728. if iNdEx >= l {
  2729. return io.ErrUnexpectedEOF
  2730. }
  2731. b := dAtA[iNdEx]
  2732. iNdEx++
  2733. stringLenmapkey |= (uint64(b) & 0x7F) << shift
  2734. if b < 0x80 {
  2735. break
  2736. }
  2737. }
  2738. intStringLenmapkey := int(stringLenmapkey)
  2739. if intStringLenmapkey < 0 {
  2740. return ErrInvalidLengthApi
  2741. }
  2742. postStringIndexmapkey := iNdEx + intStringLenmapkey
  2743. if postStringIndexmapkey > l {
  2744. return io.ErrUnexpectedEOF
  2745. }
  2746. mapkey = string(dAtA[iNdEx:postStringIndexmapkey])
  2747. iNdEx = postStringIndexmapkey
  2748. } else if fieldNum == 2 {
  2749. for shift := uint(0); ; shift += 7 {
  2750. if shift >= 64 {
  2751. return ErrIntOverflowApi
  2752. }
  2753. if iNdEx >= l {
  2754. return io.ErrUnexpectedEOF
  2755. }
  2756. b := dAtA[iNdEx]
  2757. iNdEx++
  2758. mapvalue |= (int32(b) & 0x7F) << shift
  2759. if b < 0x80 {
  2760. break
  2761. }
  2762. }
  2763. } else {
  2764. iNdEx = entryPreIndex
  2765. skippy, err := skipApi(dAtA[iNdEx:])
  2766. if err != nil {
  2767. return err
  2768. }
  2769. if skippy < 0 {
  2770. return ErrInvalidLengthApi
  2771. }
  2772. if (iNdEx + skippy) > postIndex {
  2773. return io.ErrUnexpectedEOF
  2774. }
  2775. iNdEx += skippy
  2776. }
  2777. }
  2778. m.RoomCount[mapkey] = mapvalue
  2779. iNdEx = postIndex
  2780. default:
  2781. iNdEx = preIndex
  2782. skippy, err := skipApi(dAtA[iNdEx:])
  2783. if err != nil {
  2784. return err
  2785. }
  2786. if skippy < 0 {
  2787. return ErrInvalidLengthApi
  2788. }
  2789. if (iNdEx + skippy) > l {
  2790. return io.ErrUnexpectedEOF
  2791. }
  2792. iNdEx += skippy
  2793. }
  2794. }
  2795. if iNdEx > l {
  2796. return io.ErrUnexpectedEOF
  2797. }
  2798. return nil
  2799. }
  2800. func (m *ReceiveReq) Unmarshal(dAtA []byte) error {
  2801. l := len(dAtA)
  2802. iNdEx := 0
  2803. for iNdEx < l {
  2804. preIndex := iNdEx
  2805. var wire uint64
  2806. for shift := uint(0); ; shift += 7 {
  2807. if shift >= 64 {
  2808. return ErrIntOverflowApi
  2809. }
  2810. if iNdEx >= l {
  2811. return io.ErrUnexpectedEOF
  2812. }
  2813. b := dAtA[iNdEx]
  2814. iNdEx++
  2815. wire |= (uint64(b) & 0x7F) << shift
  2816. if b < 0x80 {
  2817. break
  2818. }
  2819. }
  2820. fieldNum := int32(wire >> 3)
  2821. wireType := int(wire & 0x7)
  2822. if wireType == 4 {
  2823. return fmt.Errorf("proto: ReceiveReq: wiretype end group for non-group")
  2824. }
  2825. if fieldNum <= 0 {
  2826. return fmt.Errorf("proto: ReceiveReq: illegal tag %d (wire type %d)", fieldNum, wire)
  2827. }
  2828. switch fieldNum {
  2829. case 1:
  2830. if wireType != 0 {
  2831. return fmt.Errorf("proto: wrong wireType = %d for field Mid", wireType)
  2832. }
  2833. m.Mid = 0
  2834. for shift := uint(0); ; shift += 7 {
  2835. if shift >= 64 {
  2836. return ErrIntOverflowApi
  2837. }
  2838. if iNdEx >= l {
  2839. return io.ErrUnexpectedEOF
  2840. }
  2841. b := dAtA[iNdEx]
  2842. iNdEx++
  2843. m.Mid |= (int64(b) & 0x7F) << shift
  2844. if b < 0x80 {
  2845. break
  2846. }
  2847. }
  2848. case 2:
  2849. if wireType != 2 {
  2850. return fmt.Errorf("proto: wrong wireType = %d for field Proto", wireType)
  2851. }
  2852. var msglen int
  2853. for shift := uint(0); ; shift += 7 {
  2854. if shift >= 64 {
  2855. return ErrIntOverflowApi
  2856. }
  2857. if iNdEx >= l {
  2858. return io.ErrUnexpectedEOF
  2859. }
  2860. b := dAtA[iNdEx]
  2861. iNdEx++
  2862. msglen |= (int(b) & 0x7F) << shift
  2863. if b < 0x80 {
  2864. break
  2865. }
  2866. }
  2867. if msglen < 0 {
  2868. return ErrInvalidLengthApi
  2869. }
  2870. postIndex := iNdEx + msglen
  2871. if postIndex > l {
  2872. return io.ErrUnexpectedEOF
  2873. }
  2874. if m.Proto == nil {
  2875. m.Proto = &push_service_broadcast_model.Proto{}
  2876. }
  2877. if err := m.Proto.Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
  2878. return err
  2879. }
  2880. iNdEx = postIndex
  2881. default:
  2882. iNdEx = preIndex
  2883. skippy, err := skipApi(dAtA[iNdEx:])
  2884. if err != nil {
  2885. return err
  2886. }
  2887. if skippy < 0 {
  2888. return ErrInvalidLengthApi
  2889. }
  2890. if (iNdEx + skippy) > l {
  2891. return io.ErrUnexpectedEOF
  2892. }
  2893. iNdEx += skippy
  2894. }
  2895. }
  2896. if iNdEx > l {
  2897. return io.ErrUnexpectedEOF
  2898. }
  2899. return nil
  2900. }
  2901. func (m *ReceiveReply) Unmarshal(dAtA []byte) error {
  2902. l := len(dAtA)
  2903. iNdEx := 0
  2904. for iNdEx < l {
  2905. preIndex := iNdEx
  2906. var wire uint64
  2907. for shift := uint(0); ; shift += 7 {
  2908. if shift >= 64 {
  2909. return ErrIntOverflowApi
  2910. }
  2911. if iNdEx >= l {
  2912. return io.ErrUnexpectedEOF
  2913. }
  2914. b := dAtA[iNdEx]
  2915. iNdEx++
  2916. wire |= (uint64(b) & 0x7F) << shift
  2917. if b < 0x80 {
  2918. break
  2919. }
  2920. }
  2921. fieldNum := int32(wire >> 3)
  2922. wireType := int(wire & 0x7)
  2923. if wireType == 4 {
  2924. return fmt.Errorf("proto: ReceiveReply: wiretype end group for non-group")
  2925. }
  2926. if fieldNum <= 0 {
  2927. return fmt.Errorf("proto: ReceiveReply: illegal tag %d (wire type %d)", fieldNum, wire)
  2928. }
  2929. switch fieldNum {
  2930. case 1:
  2931. if wireType != 2 {
  2932. return fmt.Errorf("proto: wrong wireType = %d for field Proto", wireType)
  2933. }
  2934. var msglen int
  2935. for shift := uint(0); ; shift += 7 {
  2936. if shift >= 64 {
  2937. return ErrIntOverflowApi
  2938. }
  2939. if iNdEx >= l {
  2940. return io.ErrUnexpectedEOF
  2941. }
  2942. b := dAtA[iNdEx]
  2943. iNdEx++
  2944. msglen |= (int(b) & 0x7F) << shift
  2945. if b < 0x80 {
  2946. break
  2947. }
  2948. }
  2949. if msglen < 0 {
  2950. return ErrInvalidLengthApi
  2951. }
  2952. postIndex := iNdEx + msglen
  2953. if postIndex > l {
  2954. return io.ErrUnexpectedEOF
  2955. }
  2956. if m.Proto == nil {
  2957. m.Proto = &push_service_broadcast_model.Proto{}
  2958. }
  2959. if err := m.Proto.Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
  2960. return err
  2961. }
  2962. iNdEx = postIndex
  2963. default:
  2964. iNdEx = preIndex
  2965. skippy, err := skipApi(dAtA[iNdEx:])
  2966. if err != nil {
  2967. return err
  2968. }
  2969. if skippy < 0 {
  2970. return ErrInvalidLengthApi
  2971. }
  2972. if (iNdEx + skippy) > l {
  2973. return io.ErrUnexpectedEOF
  2974. }
  2975. iNdEx += skippy
  2976. }
  2977. }
  2978. if iNdEx > l {
  2979. return io.ErrUnexpectedEOF
  2980. }
  2981. return nil
  2982. }
  2983. func (m *ServerListReq) Unmarshal(dAtA []byte) error {
  2984. l := len(dAtA)
  2985. iNdEx := 0
  2986. for iNdEx < l {
  2987. preIndex := iNdEx
  2988. var wire uint64
  2989. for shift := uint(0); ; shift += 7 {
  2990. if shift >= 64 {
  2991. return ErrIntOverflowApi
  2992. }
  2993. if iNdEx >= l {
  2994. return io.ErrUnexpectedEOF
  2995. }
  2996. b := dAtA[iNdEx]
  2997. iNdEx++
  2998. wire |= (uint64(b) & 0x7F) << shift
  2999. if b < 0x80 {
  3000. break
  3001. }
  3002. }
  3003. fieldNum := int32(wire >> 3)
  3004. wireType := int(wire & 0x7)
  3005. if wireType == 4 {
  3006. return fmt.Errorf("proto: ServerListReq: wiretype end group for non-group")
  3007. }
  3008. if fieldNum <= 0 {
  3009. return fmt.Errorf("proto: ServerListReq: illegal tag %d (wire type %d)", fieldNum, wire)
  3010. }
  3011. switch fieldNum {
  3012. case 1:
  3013. if wireType != 2 {
  3014. return fmt.Errorf("proto: wrong wireType = %d for field Platform", wireType)
  3015. }
  3016. var stringLen uint64
  3017. for shift := uint(0); ; shift += 7 {
  3018. if shift >= 64 {
  3019. return ErrIntOverflowApi
  3020. }
  3021. if iNdEx >= l {
  3022. return io.ErrUnexpectedEOF
  3023. }
  3024. b := dAtA[iNdEx]
  3025. iNdEx++
  3026. stringLen |= (uint64(b) & 0x7F) << shift
  3027. if b < 0x80 {
  3028. break
  3029. }
  3030. }
  3031. intStringLen := int(stringLen)
  3032. if intStringLen < 0 {
  3033. return ErrInvalidLengthApi
  3034. }
  3035. postIndex := iNdEx + intStringLen
  3036. if postIndex > l {
  3037. return io.ErrUnexpectedEOF
  3038. }
  3039. m.Platform = string(dAtA[iNdEx:postIndex])
  3040. iNdEx = postIndex
  3041. default:
  3042. iNdEx = preIndex
  3043. skippy, err := skipApi(dAtA[iNdEx:])
  3044. if err != nil {
  3045. return err
  3046. }
  3047. if skippy < 0 {
  3048. return ErrInvalidLengthApi
  3049. }
  3050. if (iNdEx + skippy) > l {
  3051. return io.ErrUnexpectedEOF
  3052. }
  3053. iNdEx += skippy
  3054. }
  3055. }
  3056. if iNdEx > l {
  3057. return io.ErrUnexpectedEOF
  3058. }
  3059. return nil
  3060. }
  3061. func (m *ServerListReply) Unmarshal(dAtA []byte) error {
  3062. l := len(dAtA)
  3063. iNdEx := 0
  3064. for iNdEx < l {
  3065. preIndex := iNdEx
  3066. var wire uint64
  3067. for shift := uint(0); ; shift += 7 {
  3068. if shift >= 64 {
  3069. return ErrIntOverflowApi
  3070. }
  3071. if iNdEx >= l {
  3072. return io.ErrUnexpectedEOF
  3073. }
  3074. b := dAtA[iNdEx]
  3075. iNdEx++
  3076. wire |= (uint64(b) & 0x7F) << shift
  3077. if b < 0x80 {
  3078. break
  3079. }
  3080. }
  3081. fieldNum := int32(wire >> 3)
  3082. wireType := int(wire & 0x7)
  3083. if wireType == 4 {
  3084. return fmt.Errorf("proto: ServerListReply: wiretype end group for non-group")
  3085. }
  3086. if fieldNum <= 0 {
  3087. return fmt.Errorf("proto: ServerListReply: illegal tag %d (wire type %d)", fieldNum, wire)
  3088. }
  3089. switch fieldNum {
  3090. case 1:
  3091. if wireType != 2 {
  3092. return fmt.Errorf("proto: wrong wireType = %d for field Domain", wireType)
  3093. }
  3094. var stringLen uint64
  3095. for shift := uint(0); ; shift += 7 {
  3096. if shift >= 64 {
  3097. return ErrIntOverflowApi
  3098. }
  3099. if iNdEx >= l {
  3100. return io.ErrUnexpectedEOF
  3101. }
  3102. b := dAtA[iNdEx]
  3103. iNdEx++
  3104. stringLen |= (uint64(b) & 0x7F) << shift
  3105. if b < 0x80 {
  3106. break
  3107. }
  3108. }
  3109. intStringLen := int(stringLen)
  3110. if intStringLen < 0 {
  3111. return ErrInvalidLengthApi
  3112. }
  3113. postIndex := iNdEx + intStringLen
  3114. if postIndex > l {
  3115. return io.ErrUnexpectedEOF
  3116. }
  3117. m.Domain = string(dAtA[iNdEx:postIndex])
  3118. iNdEx = postIndex
  3119. case 2:
  3120. if wireType != 0 {
  3121. return fmt.Errorf("proto: wrong wireType = %d for field TcpPort", wireType)
  3122. }
  3123. m.TcpPort = 0
  3124. for shift := uint(0); ; shift += 7 {
  3125. if shift >= 64 {
  3126. return ErrIntOverflowApi
  3127. }
  3128. if iNdEx >= l {
  3129. return io.ErrUnexpectedEOF
  3130. }
  3131. b := dAtA[iNdEx]
  3132. iNdEx++
  3133. m.TcpPort |= (int32(b) & 0x7F) << shift
  3134. if b < 0x80 {
  3135. break
  3136. }
  3137. }
  3138. case 3:
  3139. if wireType != 0 {
  3140. return fmt.Errorf("proto: wrong wireType = %d for field WsPort", wireType)
  3141. }
  3142. m.WsPort = 0
  3143. for shift := uint(0); ; shift += 7 {
  3144. if shift >= 64 {
  3145. return ErrIntOverflowApi
  3146. }
  3147. if iNdEx >= l {
  3148. return io.ErrUnexpectedEOF
  3149. }
  3150. b := dAtA[iNdEx]
  3151. iNdEx++
  3152. m.WsPort |= (int32(b) & 0x7F) << shift
  3153. if b < 0x80 {
  3154. break
  3155. }
  3156. }
  3157. case 4:
  3158. if wireType != 0 {
  3159. return fmt.Errorf("proto: wrong wireType = %d for field WssPort", wireType)
  3160. }
  3161. m.WssPort = 0
  3162. for shift := uint(0); ; shift += 7 {
  3163. if shift >= 64 {
  3164. return ErrIntOverflowApi
  3165. }
  3166. if iNdEx >= l {
  3167. return io.ErrUnexpectedEOF
  3168. }
  3169. b := dAtA[iNdEx]
  3170. iNdEx++
  3171. m.WssPort |= (int32(b) & 0x7F) << shift
  3172. if b < 0x80 {
  3173. break
  3174. }
  3175. }
  3176. case 5:
  3177. if wireType != 0 {
  3178. return fmt.Errorf("proto: wrong wireType = %d for field Heartbeat", wireType)
  3179. }
  3180. m.Heartbeat = 0
  3181. for shift := uint(0); ; shift += 7 {
  3182. if shift >= 64 {
  3183. return ErrIntOverflowApi
  3184. }
  3185. if iNdEx >= l {
  3186. return io.ErrUnexpectedEOF
  3187. }
  3188. b := dAtA[iNdEx]
  3189. iNdEx++
  3190. m.Heartbeat |= (int32(b) & 0x7F) << shift
  3191. if b < 0x80 {
  3192. break
  3193. }
  3194. }
  3195. case 6:
  3196. if wireType != 2 {
  3197. return fmt.Errorf("proto: wrong wireType = %d for field Nodes", wireType)
  3198. }
  3199. var stringLen uint64
  3200. for shift := uint(0); ; shift += 7 {
  3201. if shift >= 64 {
  3202. return ErrIntOverflowApi
  3203. }
  3204. if iNdEx >= l {
  3205. return io.ErrUnexpectedEOF
  3206. }
  3207. b := dAtA[iNdEx]
  3208. iNdEx++
  3209. stringLen |= (uint64(b) & 0x7F) << shift
  3210. if b < 0x80 {
  3211. break
  3212. }
  3213. }
  3214. intStringLen := int(stringLen)
  3215. if intStringLen < 0 {
  3216. return ErrInvalidLengthApi
  3217. }
  3218. postIndex := iNdEx + intStringLen
  3219. if postIndex > l {
  3220. return io.ErrUnexpectedEOF
  3221. }
  3222. m.Nodes = append(m.Nodes, string(dAtA[iNdEx:postIndex]))
  3223. iNdEx = postIndex
  3224. case 7:
  3225. if wireType != 2 {
  3226. return fmt.Errorf("proto: wrong wireType = %d for field Backoff", wireType)
  3227. }
  3228. var msglen int
  3229. for shift := uint(0); ; shift += 7 {
  3230. if shift >= 64 {
  3231. return ErrIntOverflowApi
  3232. }
  3233. if iNdEx >= l {
  3234. return io.ErrUnexpectedEOF
  3235. }
  3236. b := dAtA[iNdEx]
  3237. iNdEx++
  3238. msglen |= (int(b) & 0x7F) << shift
  3239. if b < 0x80 {
  3240. break
  3241. }
  3242. }
  3243. if msglen < 0 {
  3244. return ErrInvalidLengthApi
  3245. }
  3246. postIndex := iNdEx + msglen
  3247. if postIndex > l {
  3248. return io.ErrUnexpectedEOF
  3249. }
  3250. if m.Backoff == nil {
  3251. m.Backoff = &Backoff{}
  3252. }
  3253. if err := m.Backoff.Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
  3254. return err
  3255. }
  3256. iNdEx = postIndex
  3257. case 8:
  3258. if wireType != 0 {
  3259. return fmt.Errorf("proto: wrong wireType = %d for field HeartbeatMax", wireType)
  3260. }
  3261. m.HeartbeatMax = 0
  3262. for shift := uint(0); ; shift += 7 {
  3263. if shift >= 64 {
  3264. return ErrIntOverflowApi
  3265. }
  3266. if iNdEx >= l {
  3267. return io.ErrUnexpectedEOF
  3268. }
  3269. b := dAtA[iNdEx]
  3270. iNdEx++
  3271. m.HeartbeatMax |= (int32(b) & 0x7F) << shift
  3272. if b < 0x80 {
  3273. break
  3274. }
  3275. }
  3276. default:
  3277. iNdEx = preIndex
  3278. skippy, err := skipApi(dAtA[iNdEx:])
  3279. if err != nil {
  3280. return err
  3281. }
  3282. if skippy < 0 {
  3283. return ErrInvalidLengthApi
  3284. }
  3285. if (iNdEx + skippy) > l {
  3286. return io.ErrUnexpectedEOF
  3287. }
  3288. iNdEx += skippy
  3289. }
  3290. }
  3291. if iNdEx > l {
  3292. return io.ErrUnexpectedEOF
  3293. }
  3294. return nil
  3295. }
  3296. func (m *Backoff) Unmarshal(dAtA []byte) error {
  3297. l := len(dAtA)
  3298. iNdEx := 0
  3299. for iNdEx < l {
  3300. preIndex := iNdEx
  3301. var wire uint64
  3302. for shift := uint(0); ; shift += 7 {
  3303. if shift >= 64 {
  3304. return ErrIntOverflowApi
  3305. }
  3306. if iNdEx >= l {
  3307. return io.ErrUnexpectedEOF
  3308. }
  3309. b := dAtA[iNdEx]
  3310. iNdEx++
  3311. wire |= (uint64(b) & 0x7F) << shift
  3312. if b < 0x80 {
  3313. break
  3314. }
  3315. }
  3316. fieldNum := int32(wire >> 3)
  3317. wireType := int(wire & 0x7)
  3318. if wireType == 4 {
  3319. return fmt.Errorf("proto: Backoff: wiretype end group for non-group")
  3320. }
  3321. if fieldNum <= 0 {
  3322. return fmt.Errorf("proto: Backoff: illegal tag %d (wire type %d)", fieldNum, wire)
  3323. }
  3324. switch fieldNum {
  3325. case 1:
  3326. if wireType != 0 {
  3327. return fmt.Errorf("proto: wrong wireType = %d for field MaxDelay", wireType)
  3328. }
  3329. m.MaxDelay = 0
  3330. for shift := uint(0); ; shift += 7 {
  3331. if shift >= 64 {
  3332. return ErrIntOverflowApi
  3333. }
  3334. if iNdEx >= l {
  3335. return io.ErrUnexpectedEOF
  3336. }
  3337. b := dAtA[iNdEx]
  3338. iNdEx++
  3339. m.MaxDelay |= (int32(b) & 0x7F) << shift
  3340. if b < 0x80 {
  3341. break
  3342. }
  3343. }
  3344. case 2:
  3345. if wireType != 0 {
  3346. return fmt.Errorf("proto: wrong wireType = %d for field BaseDelay", wireType)
  3347. }
  3348. m.BaseDelay = 0
  3349. for shift := uint(0); ; shift += 7 {
  3350. if shift >= 64 {
  3351. return ErrIntOverflowApi
  3352. }
  3353. if iNdEx >= l {
  3354. return io.ErrUnexpectedEOF
  3355. }
  3356. b := dAtA[iNdEx]
  3357. iNdEx++
  3358. m.BaseDelay |= (int32(b) & 0x7F) << shift
  3359. if b < 0x80 {
  3360. break
  3361. }
  3362. }
  3363. case 3:
  3364. if wireType != 5 {
  3365. return fmt.Errorf("proto: wrong wireType = %d for field Factor", wireType)
  3366. }
  3367. var v uint32
  3368. if (iNdEx + 4) > l {
  3369. return io.ErrUnexpectedEOF
  3370. }
  3371. v = uint32(binary.LittleEndian.Uint32(dAtA[iNdEx:]))
  3372. iNdEx += 4
  3373. m.Factor = float32(math.Float32frombits(v))
  3374. case 4:
  3375. if wireType != 5 {
  3376. return fmt.Errorf("proto: wrong wireType = %d for field Jitter", wireType)
  3377. }
  3378. var v uint32
  3379. if (iNdEx + 4) > l {
  3380. return io.ErrUnexpectedEOF
  3381. }
  3382. v = uint32(binary.LittleEndian.Uint32(dAtA[iNdEx:]))
  3383. iNdEx += 4
  3384. m.Jitter = float32(math.Float32frombits(v))
  3385. default:
  3386. iNdEx = preIndex
  3387. skippy, err := skipApi(dAtA[iNdEx:])
  3388. if err != nil {
  3389. return err
  3390. }
  3391. if skippy < 0 {
  3392. return ErrInvalidLengthApi
  3393. }
  3394. if (iNdEx + skippy) > l {
  3395. return io.ErrUnexpectedEOF
  3396. }
  3397. iNdEx += skippy
  3398. }
  3399. }
  3400. if iNdEx > l {
  3401. return io.ErrUnexpectedEOF
  3402. }
  3403. return nil
  3404. }
  3405. func skipApi(dAtA []byte) (n int, err error) {
  3406. l := len(dAtA)
  3407. iNdEx := 0
  3408. for iNdEx < l {
  3409. var wire uint64
  3410. for shift := uint(0); ; shift += 7 {
  3411. if shift >= 64 {
  3412. return 0, ErrIntOverflowApi
  3413. }
  3414. if iNdEx >= l {
  3415. return 0, io.ErrUnexpectedEOF
  3416. }
  3417. b := dAtA[iNdEx]
  3418. iNdEx++
  3419. wire |= (uint64(b) & 0x7F) << shift
  3420. if b < 0x80 {
  3421. break
  3422. }
  3423. }
  3424. wireType := int(wire & 0x7)
  3425. switch wireType {
  3426. case 0:
  3427. for shift := uint(0); ; shift += 7 {
  3428. if shift >= 64 {
  3429. return 0, ErrIntOverflowApi
  3430. }
  3431. if iNdEx >= l {
  3432. return 0, io.ErrUnexpectedEOF
  3433. }
  3434. iNdEx++
  3435. if dAtA[iNdEx-1] < 0x80 {
  3436. break
  3437. }
  3438. }
  3439. return iNdEx, nil
  3440. case 1:
  3441. iNdEx += 8
  3442. return iNdEx, nil
  3443. case 2:
  3444. var length int
  3445. for shift := uint(0); ; shift += 7 {
  3446. if shift >= 64 {
  3447. return 0, ErrIntOverflowApi
  3448. }
  3449. if iNdEx >= l {
  3450. return 0, io.ErrUnexpectedEOF
  3451. }
  3452. b := dAtA[iNdEx]
  3453. iNdEx++
  3454. length |= (int(b) & 0x7F) << shift
  3455. if b < 0x80 {
  3456. break
  3457. }
  3458. }
  3459. iNdEx += length
  3460. if length < 0 {
  3461. return 0, ErrInvalidLengthApi
  3462. }
  3463. return iNdEx, nil
  3464. case 3:
  3465. for {
  3466. var innerWire uint64
  3467. var start int = iNdEx
  3468. for shift := uint(0); ; shift += 7 {
  3469. if shift >= 64 {
  3470. return 0, ErrIntOverflowApi
  3471. }
  3472. if iNdEx >= l {
  3473. return 0, io.ErrUnexpectedEOF
  3474. }
  3475. b := dAtA[iNdEx]
  3476. iNdEx++
  3477. innerWire |= (uint64(b) & 0x7F) << shift
  3478. if b < 0x80 {
  3479. break
  3480. }
  3481. }
  3482. innerWireType := int(innerWire & 0x7)
  3483. if innerWireType == 4 {
  3484. break
  3485. }
  3486. next, err := skipApi(dAtA[start:])
  3487. if err != nil {
  3488. return 0, err
  3489. }
  3490. iNdEx = start + next
  3491. }
  3492. return iNdEx, nil
  3493. case 4:
  3494. return iNdEx, nil
  3495. case 5:
  3496. iNdEx += 4
  3497. return iNdEx, nil
  3498. default:
  3499. return 0, fmt.Errorf("proto: illegal wireType %d", wireType)
  3500. }
  3501. }
  3502. panic("unreachable")
  3503. }
  3504. var (
  3505. ErrInvalidLengthApi = fmt.Errorf("proto: negative length found during unmarshaling")
  3506. ErrIntOverflowApi = fmt.Errorf("proto: integer overflow")
  3507. )
  3508. func init() { proto.RegisterFile("app/service/main/broadcast/api/grpc/v1/api.proto", fileDescriptorApi) }
  3509. var fileDescriptorApi = []byte{
  3510. // 963 bytes of a gzipped FileDescriptorProto
  3511. 0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0xac, 0x55, 0x4f, 0x8f, 0xdb, 0x44,
  3512. 0x14, 0xc7, 0x49, 0x9c, 0xc4, 0x2f, 0xd9, 0xed, 0x32, 0xaa, 0x2a, 0xcb, 0x42, 0xeb, 0xd4, 0x0b,
  3513. 0x25, 0xa8, 0x25, 0x69, 0x17, 0x21, 0x41, 0xc5, 0x29, 0xbb, 0x54, 0x74, 0xcb, 0xc2, 0x6a, 0x2a,
  3514. 0x0e, 0xad, 0x2a, 0xad, 0x26, 0xce, 0x24, 0x31, 0xeb, 0x78, 0xbc, 0xb6, 0x93, 0x6c, 0x6e, 0x7c,
  3515. 0x0c, 0x8e, 0x48, 0xdc, 0xf8, 0x06, 0x7c, 0x03, 0x8e, 0x48, 0xdc, 0x23, 0xb4, 0xc7, 0x7c, 0x01,
  3516. 0xae, 0x68, 0xfe, 0xd8, 0x4e, 0x50, 0xbd, 0x1b, 0x04, 0x97, 0x64, 0xde, 0x9b, 0xdf, 0xfb, 0xbd,
  3517. 0x37, 0x3f, 0xcf, 0xbc, 0x07, 0x8f, 0x49, 0x18, 0x76, 0x63, 0x1a, 0xcd, 0x3c, 0x97, 0x76, 0x27,
  3518. 0xc4, 0x0b, 0xba, 0xfd, 0x88, 0x91, 0x81, 0x4b, 0xe2, 0xa4, 0x4b, 0x42, 0xaf, 0x3b, 0x8a, 0x42,
  3519. 0xb7, 0x3b, 0x7b, 0xc2, 0xd7, 0x9d, 0x30, 0x62, 0x09, 0x43, 0xf7, 0xc2, 0x69, 0x3c, 0xee, 0xa8,
  3520. 0x90, 0x4e, 0x86, 0xb6, 0x3e, 0x1e, 0x79, 0xc9, 0x78, 0xda, 0xef, 0xb8, 0x6c, 0xd2, 0x1d, 0xb1,
  3521. 0x11, 0xeb, 0x0a, 0x78, 0x7f, 0x3a, 0x14, 0x96, 0x30, 0xc4, 0x4a, 0xd2, 0x58, 0x8f, 0x6e, 0x48,
  3522. 0x3c, 0x61, 0x03, 0xea, 0xcb, 0x5f, 0x89, 0x76, 0x9a, 0x00, 0x47, 0x3e, 0x8b, 0x29, 0xa6, 0xa1,
  3523. 0xbf, 0x70, 0x00, 0xea, 0xca, 0xba, 0x74, 0x1a, 0x60, 0x9c, 0x79, 0xc1, 0x48, 0x6e, 0x18, 0x50,
  3524. 0x93, 0xc6, 0xa5, 0x33, 0x03, 0x38, 0x62, 0x41, 0x40, 0xdd, 0x04, 0xd3, 0x4b, 0x74, 0x0f, 0xaa,
  3525. 0x3c, 0x17, 0x8d, 0x4c, 0xad, 0xa5, 0xb5, 0x0d, 0xac, 0x2c, 0xf4, 0x1e, 0x18, 0x72, 0xf5, 0x82,
  3526. 0x2e, 0xcc, 0x92, 0xd8, 0xca, 0x1d, 0x3c, 0xca, 0x65, 0xec, 0xc2, 0xa3, 0x66, 0x59, 0x46, 0x49,
  3527. 0x0b, 0xdd, 0x05, 0x3d, 0x61, 0x17, 0x34, 0x30, 0x2b, 0x2d, 0xad, 0xdd, 0xc4, 0xd2, 0x78, 0x5a,
  3528. 0xf9, 0xf1, 0x27, 0xfb, 0x1d, 0xe7, 0x07, 0x0d, 0x9a, 0x59, 0xe2, 0xd0, 0x5f, 0xa0, 0x3d, 0x28,
  3529. 0x4f, 0xbc, 0x81, 0xc8, 0x5b, 0xc6, 0x7c, 0xc9, 0x3d, 0x17, 0x59, 0x3a, 0xbe, 0xe4, 0x89, 0x22,
  3530. 0xc6, 0x26, 0xcf, 0x8f, 0xd3, 0x44, 0xd2, 0x42, 0x16, 0xd4, 0x43, 0x9f, 0x24, 0x43, 0x16, 0x4d,
  3531. 0x44, 0x2e, 0x03, 0x67, 0x36, 0x32, 0xa1, 0x46, 0x5c, 0x97, 0x86, 0x49, 0x6c, 0xea, 0xad, 0x72,
  3532. 0x5b, 0xc7, 0xa9, 0xe9, 0xbc, 0x80, 0x9d, 0x63, 0x2f, 0x76, 0xf3, 0xd3, 0x6f, 0x59, 0x82, 0x52,
  3533. 0xa8, 0xbc, 0xae, 0x90, 0x73, 0x00, 0x77, 0xd6, 0xc9, 0xd4, 0x89, 0xc6, 0x24, 0x16, 0x74, 0x75,
  3534. 0xcc, 0x97, 0xce, 0x09, 0x34, 0xbf, 0xa2, 0x24, 0x4a, 0xfa, 0x94, 0xfc, 0xe7, 0x84, 0x7b, 0xb0,
  3535. 0xbb, 0xc6, 0xc5, 0xbf, 0xea, 0x1f, 0x1a, 0x18, 0xdf, 0x06, 0xbe, 0x17, 0xd0, 0x9b, 0x3e, 0xe5,
  3536. 0x37, 0x60, 0x70, 0xd5, 0x8e, 0xd8, 0x34, 0x48, 0xcc, 0x52, 0xab, 0xdc, 0x6e, 0x1c, 0x3e, 0xee,
  3537. 0xbc, 0xfd, 0xae, 0x76, 0x32, 0xb6, 0x0e, 0x4e, 0x43, 0xbe, 0x0c, 0x92, 0x68, 0x81, 0x73, 0x0a,
  3538. 0xae, 0x7d, 0x3c, 0x26, 0xd1, 0xc0, 0x0b, 0x46, 0xa2, 0x42, 0x1d, 0x67, 0xb6, 0xf5, 0x05, 0xec,
  3539. 0x6e, 0x06, 0xa6, 0xe7, 0xd3, 0xf2, 0xf3, 0xdd, 0x05, 0x7d, 0x46, 0xfc, 0x29, 0x15, 0x67, 0xd6,
  3540. 0xb1, 0x34, 0x9e, 0x96, 0x3e, 0xd3, 0xd4, 0x45, 0xf9, 0x59, 0x83, 0x46, 0x5a, 0x07, 0x57, 0xf5,
  3541. 0x6c, 0xbd, 0x7e, 0x4d, 0xd4, 0x7f, 0x78, 0x5b, 0xfd, 0xa1, 0xbf, 0x28, 0x3e, 0xc1, 0xff, 0x52,
  3542. 0xe5, 0x2b, 0x00, 0x4c, 0x5d, 0xea, 0xcd, 0xe8, 0xdb, 0xbf, 0xeb, 0xe7, 0xa0, 0x8b, 0x17, 0x2a,
  3543. 0xe2, 0x1b, 0x87, 0x07, 0x45, 0x15, 0xcb, 0xc7, 0x7c, 0xc6, 0xa1, 0x58, 0x46, 0x38, 0xcf, 0xa1,
  3544. 0x99, 0x51, 0x73, 0x01, 0x32, 0x2a, 0xed, 0x5f, 0x53, 0x3d, 0x84, 0x9d, 0x97, 0xe2, 0x16, 0x7c,
  3545. 0xed, 0xc5, 0xe2, 0x02, 0xae, 0x3f, 0x1c, 0x6d, 0xf3, 0xe1, 0x38, 0x7f, 0x95, 0xe0, 0xce, 0x3a,
  3546. 0x9a, 0xe7, 0x76, 0xa0, 0x3a, 0x60, 0xbc, 0x0b, 0x49, 0x74, 0x0f, 0x56, 0x4b, 0x5b, 0x79, 0xb0,
  3547. 0xfa, 0x47, 0x0f, 0xa0, 0x96, 0xb8, 0xe1, 0x19, 0x8b, 0x12, 0x29, 0x56, 0xaf, 0xb9, 0x5a, 0xda,
  3548. 0xf5, 0xc4, 0x0d, 0xcf, 0x43, 0x16, 0x25, 0x38, 0xdd, 0x44, 0x07, 0x50, 0x9d, 0xc7, 0x02, 0x26,
  3549. 0xae, 0x4d, 0xaf, 0xb1, 0x5a, 0xda, 0xb5, 0x79, 0x2c, 0x51, 0x6a, 0x8b, 0x93, 0xcd, 0x63, 0x89,
  3550. 0xaa, 0xe4, 0x64, 0xf3, 0x58, 0xc1, 0xd2, 0x4d, 0xf4, 0x10, 0x8c, 0x71, 0xfa, 0x1a, 0x4c, 0x5d,
  3551. 0x20, 0x77, 0x56, 0x4b, 0x3b, 0x77, 0xe2, 0x7c, 0x89, 0x6c, 0xd0, 0x03, 0x36, 0xa0, 0xb1, 0x59,
  3552. 0x6d, 0x95, 0xdb, 0x46, 0xcf, 0x58, 0x2d, 0x6d, 0xe9, 0xc0, 0xf2, 0x0f, 0x3d, 0x83, 0x5a, 0x9f,
  3553. 0xb8, 0x17, 0x6c, 0x38, 0x34, 0x6b, 0x42, 0x64, 0xbb, 0x48, 0xe4, 0x9e, 0x84, 0xc9, 0xe2, 0x55,
  3554. 0x0c, 0x4e, 0x17, 0xe8, 0x53, 0x68, 0x66, 0x59, 0x4f, 0xc9, 0x95, 0x59, 0x17, 0x85, 0xbd, 0xbb,
  3555. 0x5a, 0xda, 0x3b, 0x99, 0xff, 0x7c, 0x42, 0xae, 0xf0, 0x06, 0xcc, 0xf9, 0x45, 0x83, 0x9a, 0x22,
  3556. 0x46, 0x1f, 0x41, 0xfd, 0x94, 0x5c, 0x1d, 0x53, 0x9f, 0xc8, 0xfb, 0xa8, 0xce, 0x35, 0x21, 0x57,
  3557. 0xe7, 0x03, 0xee, 0xc4, 0xd9, 0x36, 0x7a, 0x04, 0x46, 0x8f, 0xc4, 0x54, 0x62, 0xa5, 0xf4, 0xbb,
  3558. 0xab, 0xa5, 0x0d, 0x7d, 0x12, 0x53, 0x05, 0xce, 0x01, 0xfc, 0x53, 0x3e, 0x23, 0x6e, 0xc2, 0x64,
  3559. 0x5f, 0x29, 0xc9, 0x4f, 0x39, 0x14, 0x1e, 0xac, 0x76, 0x38, 0xe6, 0xc4, 0x4b, 0x12, 0x1a, 0x09,
  3560. 0xf1, 0x15, 0xe6, 0x7b, 0xe1, 0xc1, 0x6a, 0xe7, 0xf0, 0x57, 0x1d, 0x2a, 0xaf, 0x69, 0x34, 0x42,
  3561. 0x27, 0x50, 0xe1, 0x43, 0x05, 0x15, 0x6a, 0xa5, 0x46, 0x8e, 0x75, 0xff, 0x66, 0x00, 0xbf, 0x67,
  3562. 0xa7, 0xa0, 0x8b, 0xc9, 0x85, 0x5a, 0x45, 0xd8, 0x74, 0xb0, 0x59, 0xce, 0x2d, 0x08, 0x4e, 0xf7,
  3563. 0x12, 0x6a, 0x6a, 0xd6, 0xa0, 0x62, 0x78, 0x36, 0x07, 0xac, 0xf7, 0x6f, 0xc5, 0x70, 0xd2, 0x37,
  3564. 0x00, 0x79, 0xc7, 0x47, 0x1f, 0x14, 0xc5, 0x6c, 0x8c, 0x18, 0xeb, 0xc3, 0x6d, 0x60, 0x9c, 0xfd,
  3565. 0x15, 0x18, 0x59, 0x7b, 0x47, 0x85, 0x05, 0xad, 0x4f, 0x13, 0xeb, 0xc1, 0x16, 0x28, 0x4e, 0xfd,
  3566. 0x1d, 0x34, 0x30, 0x0d, 0xe8, 0x5c, 0x76, 0x47, 0x74, 0xff, 0xd6, 0xee, 0x6f, 0x1d, 0x6c, 0xd1,
  3567. 0x60, 0xb9, 0xc8, 0xaa, 0x4f, 0x15, 0x8b, 0x9c, 0xf7, 0xc8, 0x62, 0x91, 0x37, 0x9a, 0xdd, 0x1b,
  3568. 0x80, 0xbc, 0x07, 0x15, 0x8b, 0xbc, 0xd1, 0xd5, 0x8a, 0x45, 0xfe, 0x47, 0x3b, 0xeb, 0xed, 0xfd,
  3569. 0x76, 0xbd, 0xaf, 0xfd, 0x7e, 0xbd, 0xaf, 0xfd, 0x79, 0xbd, 0xaf, 0xbd, 0x2e, 0xcd, 0x9e, 0xf4,
  3570. 0xab, 0xa2, 0x51, 0x7e, 0xf2, 0x77, 0x00, 0x00, 0x00, 0xff, 0xff, 0xca, 0x7c, 0xff, 0xf8, 0xf0,
  3571. 0x09, 0x00, 0x00,
  3572. }