dm.pb.go 35 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037103810391040104110421043104410451046104710481049105010511052105310541055105610571058105910601061106210631064106510661067106810691070107110721073107410751076107710781079108010811082108310841085108610871088108910901091109210931094109510961097109810991100110111021103110411051106110711081109111011111112111311141115111611171118111911201121112211231124112511261127112811291130113111321133113411351136113711381139114011411142114311441145114611471148114911501151115211531154115511561157115811591160116111621163116411651166116711681169117011711172117311741175117611771178117911801181118211831184118511861187118811891190119111921193119411951196119711981199120012011202120312041205120612071208120912101211121212131214121512161217121812191220122112221223122412251226122712281229123012311232123312341235123612371238123912401241124212431244124512461247124812491250125112521253125412551256125712581259126012611262126312641265126612671268126912701271127212731274127512761277127812791280128112821283128412851286128712881289129012911292129312941295129612971298129913001301130213031304130513061307130813091310131113121313131413151316131713181319132013211322132313241325132613271328132913301331133213331334133513361337133813391340134113421343134413451346134713481349135013511352135313541355135613571358135913601361136213631364136513661367136813691370137113721373137413751376137713781379138013811382138313841385138613871388138913901391139213931394139513961397139813991400140114021403140414051406140714081409141014111412141314141415141614171418141914201421142214231424142514261427142814291430143114321433143414351436143714381439144014411442144314441445144614471448144914501451145214531454145514561457145814591460146114621463146414651466146714681469147014711472147314741475147614771478147914801481148214831484148514861487
  1. // Code generated by protoc-gen-gogo. DO NOT EDIT.
  2. // source: dm.proto
  3. package v1
  4. import proto "github.com/gogo/protobuf/proto"
  5. import fmt "fmt"
  6. import math "math"
  7. import _ "github.com/gogo/protobuf/gogoproto"
  8. import _ "google.golang.org/genproto/googleapis/api/annotations"
  9. import io "io"
  10. // Reference imports to suppress errors if they are not otherwise used.
  11. var _ = proto.Marshal
  12. var _ = fmt.Errorf
  13. var _ = math.Inf
  14. // This is a compile-time assertion to ensure that this generated file
  15. // is compatible with the proto package it is being compiled against.
  16. // A compilation error at this line likely means your copy of the
  17. // proto package needs to be updated.
  18. const _ = proto.GoGoProtoPackageIsVersion2 // please upgrade the proto package
  19. type SendMsgReq struct {
  20. Msg string `protobuf:"bytes,1,opt,name=Msg,proto3" json:"Msg,omitempty" form:"msg" validate:"required"`
  21. Ts string `protobuf:"bytes,2,opt,name=Ts,proto3" json:"Ts,omitempty" form:"ts" validate:"required"`
  22. RoomID int64 `protobuf:"varint,3,opt,name=RoomID,proto3" json:"RoomID,omitempty" form:"room_id" validate:"required"`
  23. Group string `protobuf:"bytes,4,opt,name=Group,proto3" json:"Group,omitempty" form:"group" validate:"required"`
  24. Sign string `protobuf:"bytes,5,opt,name=Sign,proto3" json:"Sign,omitempty" form:"sign" validate:"required"`
  25. XXX_NoUnkeyedLiteral struct{} `json:"-"`
  26. XXX_unrecognized []byte `json:"-"`
  27. XXX_sizecache int32 `json:"-"`
  28. }
  29. func (m *SendMsgReq) Reset() { *m = SendMsgReq{} }
  30. func (m *SendMsgReq) String() string { return proto.CompactTextString(m) }
  31. func (*SendMsgReq) ProtoMessage() {}
  32. func (*SendMsgReq) Descriptor() ([]byte, []int) {
  33. return fileDescriptor_dm_1bcdb7fd715c39b4, []int{0}
  34. }
  35. func (m *SendMsgReq) XXX_Unmarshal(b []byte) error {
  36. return m.Unmarshal(b)
  37. }
  38. func (m *SendMsgReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
  39. if deterministic {
  40. return xxx_messageInfo_SendMsgReq.Marshal(b, m, deterministic)
  41. } else {
  42. b = b[:cap(b)]
  43. n, err := m.MarshalTo(b)
  44. if err != nil {
  45. return nil, err
  46. }
  47. return b[:n], nil
  48. }
  49. }
  50. func (dst *SendMsgReq) XXX_Merge(src proto.Message) {
  51. xxx_messageInfo_SendMsgReq.Merge(dst, src)
  52. }
  53. func (m *SendMsgReq) XXX_Size() int {
  54. return m.Size()
  55. }
  56. func (m *SendMsgReq) XXX_DiscardUnknown() {
  57. xxx_messageInfo_SendMsgReq.DiscardUnknown(m)
  58. }
  59. var xxx_messageInfo_SendMsgReq proto.InternalMessageInfo
  60. func (m *SendMsgReq) GetMsg() string {
  61. if m != nil {
  62. return m.Msg
  63. }
  64. return ""
  65. }
  66. func (m *SendMsgReq) GetTs() string {
  67. if m != nil {
  68. return m.Ts
  69. }
  70. return ""
  71. }
  72. func (m *SendMsgReq) GetRoomID() int64 {
  73. if m != nil {
  74. return m.RoomID
  75. }
  76. return 0
  77. }
  78. func (m *SendMsgReq) GetGroup() string {
  79. if m != nil {
  80. return m.Group
  81. }
  82. return ""
  83. }
  84. func (m *SendMsgReq) GetSign() string {
  85. if m != nil {
  86. return m.Sign
  87. }
  88. return ""
  89. }
  90. type SendMsgResp struct {
  91. XXX_NoUnkeyedLiteral struct{} `json:"-"`
  92. XXX_unrecognized []byte `json:"-"`
  93. XXX_sizecache int32 `json:"-"`
  94. }
  95. func (m *SendMsgResp) Reset() { *m = SendMsgResp{} }
  96. func (m *SendMsgResp) String() string { return proto.CompactTextString(m) }
  97. func (*SendMsgResp) ProtoMessage() {}
  98. func (*SendMsgResp) Descriptor() ([]byte, []int) {
  99. return fileDescriptor_dm_1bcdb7fd715c39b4, []int{1}
  100. }
  101. func (m *SendMsgResp) XXX_Unmarshal(b []byte) error {
  102. return m.Unmarshal(b)
  103. }
  104. func (m *SendMsgResp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
  105. if deterministic {
  106. return xxx_messageInfo_SendMsgResp.Marshal(b, m, deterministic)
  107. } else {
  108. b = b[:cap(b)]
  109. n, err := m.MarshalTo(b)
  110. if err != nil {
  111. return nil, err
  112. }
  113. return b[:n], nil
  114. }
  115. }
  116. func (dst *SendMsgResp) XXX_Merge(src proto.Message) {
  117. xxx_messageInfo_SendMsgResp.Merge(dst, src)
  118. }
  119. func (m *SendMsgResp) XXX_Size() int {
  120. return m.Size()
  121. }
  122. func (m *SendMsgResp) XXX_DiscardUnknown() {
  123. xxx_messageInfo_SendMsgResp.DiscardUnknown(m)
  124. }
  125. var xxx_messageInfo_SendMsgResp proto.InternalMessageInfo
  126. type GetConfReq struct {
  127. Ts string `protobuf:"bytes,1,opt,name=Ts,proto3" json:"Ts,omitempty" form:"ts" validate:"required"`
  128. Sign string `protobuf:"bytes,2,opt,name=Sign,proto3" json:"Sign,omitempty" form:"sign" validate:"required"`
  129. Group string `protobuf:"bytes,3,opt,name=Group,proto3" json:"Group,omitempty" form:"group" validate:"required"`
  130. XXX_NoUnkeyedLiteral struct{} `json:"-"`
  131. XXX_unrecognized []byte `json:"-"`
  132. XXX_sizecache int32 `json:"-"`
  133. }
  134. func (m *GetConfReq) Reset() { *m = GetConfReq{} }
  135. func (m *GetConfReq) String() string { return proto.CompactTextString(m) }
  136. func (*GetConfReq) ProtoMessage() {}
  137. func (*GetConfReq) Descriptor() ([]byte, []int) {
  138. return fileDescriptor_dm_1bcdb7fd715c39b4, []int{2}
  139. }
  140. func (m *GetConfReq) XXX_Unmarshal(b []byte) error {
  141. return m.Unmarshal(b)
  142. }
  143. func (m *GetConfReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
  144. if deterministic {
  145. return xxx_messageInfo_GetConfReq.Marshal(b, m, deterministic)
  146. } else {
  147. b = b[:cap(b)]
  148. n, err := m.MarshalTo(b)
  149. if err != nil {
  150. return nil, err
  151. }
  152. return b[:n], nil
  153. }
  154. }
  155. func (dst *GetConfReq) XXX_Merge(src proto.Message) {
  156. xxx_messageInfo_GetConfReq.Merge(dst, src)
  157. }
  158. func (m *GetConfReq) XXX_Size() int {
  159. return m.Size()
  160. }
  161. func (m *GetConfReq) XXX_DiscardUnknown() {
  162. xxx_messageInfo_GetConfReq.DiscardUnknown(m)
  163. }
  164. var xxx_messageInfo_GetConfReq proto.InternalMessageInfo
  165. func (m *GetConfReq) GetTs() string {
  166. if m != nil {
  167. return m.Ts
  168. }
  169. return ""
  170. }
  171. func (m *GetConfReq) GetSign() string {
  172. if m != nil {
  173. return m.Sign
  174. }
  175. return ""
  176. }
  177. func (m *GetConfReq) GetGroup() string {
  178. if m != nil {
  179. return m.Group
  180. }
  181. return ""
  182. }
  183. type GetConfResp struct {
  184. WSPort []int64 `protobuf:"varint,1,rep,packed,name=WSPort" json:"ws_port"`
  185. WSSPort []int64 `protobuf:"varint,2,rep,packed,name=WSSPort" json:"wss_port"`
  186. TCPPort []int64 `protobuf:"varint,3,rep,packed,name=TCPPort" json:"tcp_port"`
  187. IPList []string `protobuf:"bytes,4,rep,name=IPList" json:"ip_list"`
  188. DomianList []string `protobuf:"bytes,5,rep,name=DomianList" json:"domain_list"`
  189. XXX_NoUnkeyedLiteral struct{} `json:"-"`
  190. XXX_unrecognized []byte `json:"-"`
  191. XXX_sizecache int32 `json:"-"`
  192. }
  193. func (m *GetConfResp) Reset() { *m = GetConfResp{} }
  194. func (m *GetConfResp) String() string { return proto.CompactTextString(m) }
  195. func (*GetConfResp) ProtoMessage() {}
  196. func (*GetConfResp) Descriptor() ([]byte, []int) {
  197. return fileDescriptor_dm_1bcdb7fd715c39b4, []int{3}
  198. }
  199. func (m *GetConfResp) XXX_Unmarshal(b []byte) error {
  200. return m.Unmarshal(b)
  201. }
  202. func (m *GetConfResp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
  203. if deterministic {
  204. return xxx_messageInfo_GetConfResp.Marshal(b, m, deterministic)
  205. } else {
  206. b = b[:cap(b)]
  207. n, err := m.MarshalTo(b)
  208. if err != nil {
  209. return nil, err
  210. }
  211. return b[:n], nil
  212. }
  213. }
  214. func (dst *GetConfResp) XXX_Merge(src proto.Message) {
  215. xxx_messageInfo_GetConfResp.Merge(dst, src)
  216. }
  217. func (m *GetConfResp) XXX_Size() int {
  218. return m.Size()
  219. }
  220. func (m *GetConfResp) XXX_DiscardUnknown() {
  221. xxx_messageInfo_GetConfResp.DiscardUnknown(m)
  222. }
  223. var xxx_messageInfo_GetConfResp proto.InternalMessageInfo
  224. func (m *GetConfResp) GetWSPort() []int64 {
  225. if m != nil {
  226. return m.WSPort
  227. }
  228. return nil
  229. }
  230. func (m *GetConfResp) GetWSSPort() []int64 {
  231. if m != nil {
  232. return m.WSSPort
  233. }
  234. return nil
  235. }
  236. func (m *GetConfResp) GetTCPPort() []int64 {
  237. if m != nil {
  238. return m.TCPPort
  239. }
  240. return nil
  241. }
  242. func (m *GetConfResp) GetIPList() []string {
  243. if m != nil {
  244. return m.IPList
  245. }
  246. return nil
  247. }
  248. func (m *GetConfResp) GetDomianList() []string {
  249. if m != nil {
  250. return m.DomianList
  251. }
  252. return nil
  253. }
  254. func init() {
  255. proto.RegisterType((*SendMsgReq)(nil), "live.openinterface.v1.SendMsgReq")
  256. proto.RegisterType((*SendMsgResp)(nil), "live.openinterface.v1.SendMsgResp")
  257. proto.RegisterType((*GetConfReq)(nil), "live.openinterface.v1.GetConfReq")
  258. proto.RegisterType((*GetConfResp)(nil), "live.openinterface.v1.GetConfResp")
  259. }
  260. func (m *SendMsgReq) Marshal() (dAtA []byte, err error) {
  261. size := m.Size()
  262. dAtA = make([]byte, size)
  263. n, err := m.MarshalTo(dAtA)
  264. if err != nil {
  265. return nil, err
  266. }
  267. return dAtA[:n], nil
  268. }
  269. func (m *SendMsgReq) MarshalTo(dAtA []byte) (int, error) {
  270. var i int
  271. _ = i
  272. var l int
  273. _ = l
  274. if len(m.Msg) > 0 {
  275. dAtA[i] = 0xa
  276. i++
  277. i = encodeVarintDm(dAtA, i, uint64(len(m.Msg)))
  278. i += copy(dAtA[i:], m.Msg)
  279. }
  280. if len(m.Ts) > 0 {
  281. dAtA[i] = 0x12
  282. i++
  283. i = encodeVarintDm(dAtA, i, uint64(len(m.Ts)))
  284. i += copy(dAtA[i:], m.Ts)
  285. }
  286. if m.RoomID != 0 {
  287. dAtA[i] = 0x18
  288. i++
  289. i = encodeVarintDm(dAtA, i, uint64(m.RoomID))
  290. }
  291. if len(m.Group) > 0 {
  292. dAtA[i] = 0x22
  293. i++
  294. i = encodeVarintDm(dAtA, i, uint64(len(m.Group)))
  295. i += copy(dAtA[i:], m.Group)
  296. }
  297. if len(m.Sign) > 0 {
  298. dAtA[i] = 0x2a
  299. i++
  300. i = encodeVarintDm(dAtA, i, uint64(len(m.Sign)))
  301. i += copy(dAtA[i:], m.Sign)
  302. }
  303. if m.XXX_unrecognized != nil {
  304. i += copy(dAtA[i:], m.XXX_unrecognized)
  305. }
  306. return i, nil
  307. }
  308. func (m *SendMsgResp) Marshal() (dAtA []byte, err error) {
  309. size := m.Size()
  310. dAtA = make([]byte, size)
  311. n, err := m.MarshalTo(dAtA)
  312. if err != nil {
  313. return nil, err
  314. }
  315. return dAtA[:n], nil
  316. }
  317. func (m *SendMsgResp) MarshalTo(dAtA []byte) (int, error) {
  318. var i int
  319. _ = i
  320. var l int
  321. _ = l
  322. if m.XXX_unrecognized != nil {
  323. i += copy(dAtA[i:], m.XXX_unrecognized)
  324. }
  325. return i, nil
  326. }
  327. func (m *GetConfReq) Marshal() (dAtA []byte, err error) {
  328. size := m.Size()
  329. dAtA = make([]byte, size)
  330. n, err := m.MarshalTo(dAtA)
  331. if err != nil {
  332. return nil, err
  333. }
  334. return dAtA[:n], nil
  335. }
  336. func (m *GetConfReq) MarshalTo(dAtA []byte) (int, error) {
  337. var i int
  338. _ = i
  339. var l int
  340. _ = l
  341. if len(m.Ts) > 0 {
  342. dAtA[i] = 0xa
  343. i++
  344. i = encodeVarintDm(dAtA, i, uint64(len(m.Ts)))
  345. i += copy(dAtA[i:], m.Ts)
  346. }
  347. if len(m.Sign) > 0 {
  348. dAtA[i] = 0x12
  349. i++
  350. i = encodeVarintDm(dAtA, i, uint64(len(m.Sign)))
  351. i += copy(dAtA[i:], m.Sign)
  352. }
  353. if len(m.Group) > 0 {
  354. dAtA[i] = 0x1a
  355. i++
  356. i = encodeVarintDm(dAtA, i, uint64(len(m.Group)))
  357. i += copy(dAtA[i:], m.Group)
  358. }
  359. if m.XXX_unrecognized != nil {
  360. i += copy(dAtA[i:], m.XXX_unrecognized)
  361. }
  362. return i, nil
  363. }
  364. func (m *GetConfResp) Marshal() (dAtA []byte, err error) {
  365. size := m.Size()
  366. dAtA = make([]byte, size)
  367. n, err := m.MarshalTo(dAtA)
  368. if err != nil {
  369. return nil, err
  370. }
  371. return dAtA[:n], nil
  372. }
  373. func (m *GetConfResp) MarshalTo(dAtA []byte) (int, error) {
  374. var i int
  375. _ = i
  376. var l int
  377. _ = l
  378. if len(m.WSPort) > 0 {
  379. dAtA2 := make([]byte, len(m.WSPort)*10)
  380. var j1 int
  381. for _, num1 := range m.WSPort {
  382. num := uint64(num1)
  383. for num >= 1<<7 {
  384. dAtA2[j1] = uint8(uint64(num)&0x7f | 0x80)
  385. num >>= 7
  386. j1++
  387. }
  388. dAtA2[j1] = uint8(num)
  389. j1++
  390. }
  391. dAtA[i] = 0xa
  392. i++
  393. i = encodeVarintDm(dAtA, i, uint64(j1))
  394. i += copy(dAtA[i:], dAtA2[:j1])
  395. }
  396. if len(m.WSSPort) > 0 {
  397. dAtA4 := make([]byte, len(m.WSSPort)*10)
  398. var j3 int
  399. for _, num1 := range m.WSSPort {
  400. num := uint64(num1)
  401. for num >= 1<<7 {
  402. dAtA4[j3] = uint8(uint64(num)&0x7f | 0x80)
  403. num >>= 7
  404. j3++
  405. }
  406. dAtA4[j3] = uint8(num)
  407. j3++
  408. }
  409. dAtA[i] = 0x12
  410. i++
  411. i = encodeVarintDm(dAtA, i, uint64(j3))
  412. i += copy(dAtA[i:], dAtA4[:j3])
  413. }
  414. if len(m.TCPPort) > 0 {
  415. dAtA6 := make([]byte, len(m.TCPPort)*10)
  416. var j5 int
  417. for _, num1 := range m.TCPPort {
  418. num := uint64(num1)
  419. for num >= 1<<7 {
  420. dAtA6[j5] = uint8(uint64(num)&0x7f | 0x80)
  421. num >>= 7
  422. j5++
  423. }
  424. dAtA6[j5] = uint8(num)
  425. j5++
  426. }
  427. dAtA[i] = 0x1a
  428. i++
  429. i = encodeVarintDm(dAtA, i, uint64(j5))
  430. i += copy(dAtA[i:], dAtA6[:j5])
  431. }
  432. if len(m.IPList) > 0 {
  433. for _, s := range m.IPList {
  434. dAtA[i] = 0x22
  435. i++
  436. l = len(s)
  437. for l >= 1<<7 {
  438. dAtA[i] = uint8(uint64(l)&0x7f | 0x80)
  439. l >>= 7
  440. i++
  441. }
  442. dAtA[i] = uint8(l)
  443. i++
  444. i += copy(dAtA[i:], s)
  445. }
  446. }
  447. if len(m.DomianList) > 0 {
  448. for _, s := range m.DomianList {
  449. dAtA[i] = 0x2a
  450. i++
  451. l = len(s)
  452. for l >= 1<<7 {
  453. dAtA[i] = uint8(uint64(l)&0x7f | 0x80)
  454. l >>= 7
  455. i++
  456. }
  457. dAtA[i] = uint8(l)
  458. i++
  459. i += copy(dAtA[i:], s)
  460. }
  461. }
  462. if m.XXX_unrecognized != nil {
  463. i += copy(dAtA[i:], m.XXX_unrecognized)
  464. }
  465. return i, nil
  466. }
  467. func encodeVarintDm(dAtA []byte, offset int, v uint64) int {
  468. for v >= 1<<7 {
  469. dAtA[offset] = uint8(v&0x7f | 0x80)
  470. v >>= 7
  471. offset++
  472. }
  473. dAtA[offset] = uint8(v)
  474. return offset + 1
  475. }
  476. func (m *SendMsgReq) Size() (n int) {
  477. if m == nil {
  478. return 0
  479. }
  480. var l int
  481. _ = l
  482. l = len(m.Msg)
  483. if l > 0 {
  484. n += 1 + l + sovDm(uint64(l))
  485. }
  486. l = len(m.Ts)
  487. if l > 0 {
  488. n += 1 + l + sovDm(uint64(l))
  489. }
  490. if m.RoomID != 0 {
  491. n += 1 + sovDm(uint64(m.RoomID))
  492. }
  493. l = len(m.Group)
  494. if l > 0 {
  495. n += 1 + l + sovDm(uint64(l))
  496. }
  497. l = len(m.Sign)
  498. if l > 0 {
  499. n += 1 + l + sovDm(uint64(l))
  500. }
  501. if m.XXX_unrecognized != nil {
  502. n += len(m.XXX_unrecognized)
  503. }
  504. return n
  505. }
  506. func (m *SendMsgResp) Size() (n int) {
  507. if m == nil {
  508. return 0
  509. }
  510. var l int
  511. _ = l
  512. if m.XXX_unrecognized != nil {
  513. n += len(m.XXX_unrecognized)
  514. }
  515. return n
  516. }
  517. func (m *GetConfReq) Size() (n int) {
  518. if m == nil {
  519. return 0
  520. }
  521. var l int
  522. _ = l
  523. l = len(m.Ts)
  524. if l > 0 {
  525. n += 1 + l + sovDm(uint64(l))
  526. }
  527. l = len(m.Sign)
  528. if l > 0 {
  529. n += 1 + l + sovDm(uint64(l))
  530. }
  531. l = len(m.Group)
  532. if l > 0 {
  533. n += 1 + l + sovDm(uint64(l))
  534. }
  535. if m.XXX_unrecognized != nil {
  536. n += len(m.XXX_unrecognized)
  537. }
  538. return n
  539. }
  540. func (m *GetConfResp) Size() (n int) {
  541. if m == nil {
  542. return 0
  543. }
  544. var l int
  545. _ = l
  546. if len(m.WSPort) > 0 {
  547. l = 0
  548. for _, e := range m.WSPort {
  549. l += sovDm(uint64(e))
  550. }
  551. n += 1 + sovDm(uint64(l)) + l
  552. }
  553. if len(m.WSSPort) > 0 {
  554. l = 0
  555. for _, e := range m.WSSPort {
  556. l += sovDm(uint64(e))
  557. }
  558. n += 1 + sovDm(uint64(l)) + l
  559. }
  560. if len(m.TCPPort) > 0 {
  561. l = 0
  562. for _, e := range m.TCPPort {
  563. l += sovDm(uint64(e))
  564. }
  565. n += 1 + sovDm(uint64(l)) + l
  566. }
  567. if len(m.IPList) > 0 {
  568. for _, s := range m.IPList {
  569. l = len(s)
  570. n += 1 + l + sovDm(uint64(l))
  571. }
  572. }
  573. if len(m.DomianList) > 0 {
  574. for _, s := range m.DomianList {
  575. l = len(s)
  576. n += 1 + l + sovDm(uint64(l))
  577. }
  578. }
  579. if m.XXX_unrecognized != nil {
  580. n += len(m.XXX_unrecognized)
  581. }
  582. return n
  583. }
  584. func sovDm(x uint64) (n int) {
  585. for {
  586. n++
  587. x >>= 7
  588. if x == 0 {
  589. break
  590. }
  591. }
  592. return n
  593. }
  594. func sozDm(x uint64) (n int) {
  595. return sovDm(uint64((x << 1) ^ uint64((int64(x) >> 63))))
  596. }
  597. func (m *SendMsgReq) Unmarshal(dAtA []byte) error {
  598. l := len(dAtA)
  599. iNdEx := 0
  600. for iNdEx < l {
  601. preIndex := iNdEx
  602. var wire uint64
  603. for shift := uint(0); ; shift += 7 {
  604. if shift >= 64 {
  605. return ErrIntOverflowDm
  606. }
  607. if iNdEx >= l {
  608. return io.ErrUnexpectedEOF
  609. }
  610. b := dAtA[iNdEx]
  611. iNdEx++
  612. wire |= (uint64(b) & 0x7F) << shift
  613. if b < 0x80 {
  614. break
  615. }
  616. }
  617. fieldNum := int32(wire >> 3)
  618. wireType := int(wire & 0x7)
  619. if wireType == 4 {
  620. return fmt.Errorf("proto: SendMsgReq: wiretype end group for non-group")
  621. }
  622. if fieldNum <= 0 {
  623. return fmt.Errorf("proto: SendMsgReq: illegal tag %d (wire type %d)", fieldNum, wire)
  624. }
  625. switch fieldNum {
  626. case 1:
  627. if wireType != 2 {
  628. return fmt.Errorf("proto: wrong wireType = %d for field Msg", wireType)
  629. }
  630. var stringLen uint64
  631. for shift := uint(0); ; shift += 7 {
  632. if shift >= 64 {
  633. return ErrIntOverflowDm
  634. }
  635. if iNdEx >= l {
  636. return io.ErrUnexpectedEOF
  637. }
  638. b := dAtA[iNdEx]
  639. iNdEx++
  640. stringLen |= (uint64(b) & 0x7F) << shift
  641. if b < 0x80 {
  642. break
  643. }
  644. }
  645. intStringLen := int(stringLen)
  646. if intStringLen < 0 {
  647. return ErrInvalidLengthDm
  648. }
  649. postIndex := iNdEx + intStringLen
  650. if postIndex > l {
  651. return io.ErrUnexpectedEOF
  652. }
  653. m.Msg = string(dAtA[iNdEx:postIndex])
  654. iNdEx = postIndex
  655. case 2:
  656. if wireType != 2 {
  657. return fmt.Errorf("proto: wrong wireType = %d for field Ts", wireType)
  658. }
  659. var stringLen uint64
  660. for shift := uint(0); ; shift += 7 {
  661. if shift >= 64 {
  662. return ErrIntOverflowDm
  663. }
  664. if iNdEx >= l {
  665. return io.ErrUnexpectedEOF
  666. }
  667. b := dAtA[iNdEx]
  668. iNdEx++
  669. stringLen |= (uint64(b) & 0x7F) << shift
  670. if b < 0x80 {
  671. break
  672. }
  673. }
  674. intStringLen := int(stringLen)
  675. if intStringLen < 0 {
  676. return ErrInvalidLengthDm
  677. }
  678. postIndex := iNdEx + intStringLen
  679. if postIndex > l {
  680. return io.ErrUnexpectedEOF
  681. }
  682. m.Ts = string(dAtA[iNdEx:postIndex])
  683. iNdEx = postIndex
  684. case 3:
  685. if wireType != 0 {
  686. return fmt.Errorf("proto: wrong wireType = %d for field RoomID", wireType)
  687. }
  688. m.RoomID = 0
  689. for shift := uint(0); ; shift += 7 {
  690. if shift >= 64 {
  691. return ErrIntOverflowDm
  692. }
  693. if iNdEx >= l {
  694. return io.ErrUnexpectedEOF
  695. }
  696. b := dAtA[iNdEx]
  697. iNdEx++
  698. m.RoomID |= (int64(b) & 0x7F) << shift
  699. if b < 0x80 {
  700. break
  701. }
  702. }
  703. case 4:
  704. if wireType != 2 {
  705. return fmt.Errorf("proto: wrong wireType = %d for field Group", wireType)
  706. }
  707. var stringLen uint64
  708. for shift := uint(0); ; shift += 7 {
  709. if shift >= 64 {
  710. return ErrIntOverflowDm
  711. }
  712. if iNdEx >= l {
  713. return io.ErrUnexpectedEOF
  714. }
  715. b := dAtA[iNdEx]
  716. iNdEx++
  717. stringLen |= (uint64(b) & 0x7F) << shift
  718. if b < 0x80 {
  719. break
  720. }
  721. }
  722. intStringLen := int(stringLen)
  723. if intStringLen < 0 {
  724. return ErrInvalidLengthDm
  725. }
  726. postIndex := iNdEx + intStringLen
  727. if postIndex > l {
  728. return io.ErrUnexpectedEOF
  729. }
  730. m.Group = string(dAtA[iNdEx:postIndex])
  731. iNdEx = postIndex
  732. case 5:
  733. if wireType != 2 {
  734. return fmt.Errorf("proto: wrong wireType = %d for field Sign", wireType)
  735. }
  736. var stringLen uint64
  737. for shift := uint(0); ; shift += 7 {
  738. if shift >= 64 {
  739. return ErrIntOverflowDm
  740. }
  741. if iNdEx >= l {
  742. return io.ErrUnexpectedEOF
  743. }
  744. b := dAtA[iNdEx]
  745. iNdEx++
  746. stringLen |= (uint64(b) & 0x7F) << shift
  747. if b < 0x80 {
  748. break
  749. }
  750. }
  751. intStringLen := int(stringLen)
  752. if intStringLen < 0 {
  753. return ErrInvalidLengthDm
  754. }
  755. postIndex := iNdEx + intStringLen
  756. if postIndex > l {
  757. return io.ErrUnexpectedEOF
  758. }
  759. m.Sign = string(dAtA[iNdEx:postIndex])
  760. iNdEx = postIndex
  761. default:
  762. iNdEx = preIndex
  763. skippy, err := skipDm(dAtA[iNdEx:])
  764. if err != nil {
  765. return err
  766. }
  767. if skippy < 0 {
  768. return ErrInvalidLengthDm
  769. }
  770. if (iNdEx + skippy) > l {
  771. return io.ErrUnexpectedEOF
  772. }
  773. m.XXX_unrecognized = append(m.XXX_unrecognized, dAtA[iNdEx:iNdEx+skippy]...)
  774. iNdEx += skippy
  775. }
  776. }
  777. if iNdEx > l {
  778. return io.ErrUnexpectedEOF
  779. }
  780. return nil
  781. }
  782. func (m *SendMsgResp) Unmarshal(dAtA []byte) error {
  783. l := len(dAtA)
  784. iNdEx := 0
  785. for iNdEx < l {
  786. preIndex := iNdEx
  787. var wire uint64
  788. for shift := uint(0); ; shift += 7 {
  789. if shift >= 64 {
  790. return ErrIntOverflowDm
  791. }
  792. if iNdEx >= l {
  793. return io.ErrUnexpectedEOF
  794. }
  795. b := dAtA[iNdEx]
  796. iNdEx++
  797. wire |= (uint64(b) & 0x7F) << shift
  798. if b < 0x80 {
  799. break
  800. }
  801. }
  802. fieldNum := int32(wire >> 3)
  803. wireType := int(wire & 0x7)
  804. if wireType == 4 {
  805. return fmt.Errorf("proto: SendMsgResp: wiretype end group for non-group")
  806. }
  807. if fieldNum <= 0 {
  808. return fmt.Errorf("proto: SendMsgResp: illegal tag %d (wire type %d)", fieldNum, wire)
  809. }
  810. switch fieldNum {
  811. default:
  812. iNdEx = preIndex
  813. skippy, err := skipDm(dAtA[iNdEx:])
  814. if err != nil {
  815. return err
  816. }
  817. if skippy < 0 {
  818. return ErrInvalidLengthDm
  819. }
  820. if (iNdEx + skippy) > l {
  821. return io.ErrUnexpectedEOF
  822. }
  823. m.XXX_unrecognized = append(m.XXX_unrecognized, dAtA[iNdEx:iNdEx+skippy]...)
  824. iNdEx += skippy
  825. }
  826. }
  827. if iNdEx > l {
  828. return io.ErrUnexpectedEOF
  829. }
  830. return nil
  831. }
  832. func (m *GetConfReq) Unmarshal(dAtA []byte) error {
  833. l := len(dAtA)
  834. iNdEx := 0
  835. for iNdEx < l {
  836. preIndex := iNdEx
  837. var wire uint64
  838. for shift := uint(0); ; shift += 7 {
  839. if shift >= 64 {
  840. return ErrIntOverflowDm
  841. }
  842. if iNdEx >= l {
  843. return io.ErrUnexpectedEOF
  844. }
  845. b := dAtA[iNdEx]
  846. iNdEx++
  847. wire |= (uint64(b) & 0x7F) << shift
  848. if b < 0x80 {
  849. break
  850. }
  851. }
  852. fieldNum := int32(wire >> 3)
  853. wireType := int(wire & 0x7)
  854. if wireType == 4 {
  855. return fmt.Errorf("proto: GetConfReq: wiretype end group for non-group")
  856. }
  857. if fieldNum <= 0 {
  858. return fmt.Errorf("proto: GetConfReq: illegal tag %d (wire type %d)", fieldNum, wire)
  859. }
  860. switch fieldNum {
  861. case 1:
  862. if wireType != 2 {
  863. return fmt.Errorf("proto: wrong wireType = %d for field Ts", wireType)
  864. }
  865. var stringLen uint64
  866. for shift := uint(0); ; shift += 7 {
  867. if shift >= 64 {
  868. return ErrIntOverflowDm
  869. }
  870. if iNdEx >= l {
  871. return io.ErrUnexpectedEOF
  872. }
  873. b := dAtA[iNdEx]
  874. iNdEx++
  875. stringLen |= (uint64(b) & 0x7F) << shift
  876. if b < 0x80 {
  877. break
  878. }
  879. }
  880. intStringLen := int(stringLen)
  881. if intStringLen < 0 {
  882. return ErrInvalidLengthDm
  883. }
  884. postIndex := iNdEx + intStringLen
  885. if postIndex > l {
  886. return io.ErrUnexpectedEOF
  887. }
  888. m.Ts = string(dAtA[iNdEx:postIndex])
  889. iNdEx = postIndex
  890. case 2:
  891. if wireType != 2 {
  892. return fmt.Errorf("proto: wrong wireType = %d for field Sign", wireType)
  893. }
  894. var stringLen uint64
  895. for shift := uint(0); ; shift += 7 {
  896. if shift >= 64 {
  897. return ErrIntOverflowDm
  898. }
  899. if iNdEx >= l {
  900. return io.ErrUnexpectedEOF
  901. }
  902. b := dAtA[iNdEx]
  903. iNdEx++
  904. stringLen |= (uint64(b) & 0x7F) << shift
  905. if b < 0x80 {
  906. break
  907. }
  908. }
  909. intStringLen := int(stringLen)
  910. if intStringLen < 0 {
  911. return ErrInvalidLengthDm
  912. }
  913. postIndex := iNdEx + intStringLen
  914. if postIndex > l {
  915. return io.ErrUnexpectedEOF
  916. }
  917. m.Sign = string(dAtA[iNdEx:postIndex])
  918. iNdEx = postIndex
  919. case 3:
  920. if wireType != 2 {
  921. return fmt.Errorf("proto: wrong wireType = %d for field Group", wireType)
  922. }
  923. var stringLen uint64
  924. for shift := uint(0); ; shift += 7 {
  925. if shift >= 64 {
  926. return ErrIntOverflowDm
  927. }
  928. if iNdEx >= l {
  929. return io.ErrUnexpectedEOF
  930. }
  931. b := dAtA[iNdEx]
  932. iNdEx++
  933. stringLen |= (uint64(b) & 0x7F) << shift
  934. if b < 0x80 {
  935. break
  936. }
  937. }
  938. intStringLen := int(stringLen)
  939. if intStringLen < 0 {
  940. return ErrInvalidLengthDm
  941. }
  942. postIndex := iNdEx + intStringLen
  943. if postIndex > l {
  944. return io.ErrUnexpectedEOF
  945. }
  946. m.Group = string(dAtA[iNdEx:postIndex])
  947. iNdEx = postIndex
  948. default:
  949. iNdEx = preIndex
  950. skippy, err := skipDm(dAtA[iNdEx:])
  951. if err != nil {
  952. return err
  953. }
  954. if skippy < 0 {
  955. return ErrInvalidLengthDm
  956. }
  957. if (iNdEx + skippy) > l {
  958. return io.ErrUnexpectedEOF
  959. }
  960. m.XXX_unrecognized = append(m.XXX_unrecognized, dAtA[iNdEx:iNdEx+skippy]...)
  961. iNdEx += skippy
  962. }
  963. }
  964. if iNdEx > l {
  965. return io.ErrUnexpectedEOF
  966. }
  967. return nil
  968. }
  969. func (m *GetConfResp) Unmarshal(dAtA []byte) error {
  970. l := len(dAtA)
  971. iNdEx := 0
  972. for iNdEx < l {
  973. preIndex := iNdEx
  974. var wire uint64
  975. for shift := uint(0); ; shift += 7 {
  976. if shift >= 64 {
  977. return ErrIntOverflowDm
  978. }
  979. if iNdEx >= l {
  980. return io.ErrUnexpectedEOF
  981. }
  982. b := dAtA[iNdEx]
  983. iNdEx++
  984. wire |= (uint64(b) & 0x7F) << shift
  985. if b < 0x80 {
  986. break
  987. }
  988. }
  989. fieldNum := int32(wire >> 3)
  990. wireType := int(wire & 0x7)
  991. if wireType == 4 {
  992. return fmt.Errorf("proto: GetConfResp: wiretype end group for non-group")
  993. }
  994. if fieldNum <= 0 {
  995. return fmt.Errorf("proto: GetConfResp: illegal tag %d (wire type %d)", fieldNum, wire)
  996. }
  997. switch fieldNum {
  998. case 1:
  999. if wireType == 0 {
  1000. var v int64
  1001. for shift := uint(0); ; shift += 7 {
  1002. if shift >= 64 {
  1003. return ErrIntOverflowDm
  1004. }
  1005. if iNdEx >= l {
  1006. return io.ErrUnexpectedEOF
  1007. }
  1008. b := dAtA[iNdEx]
  1009. iNdEx++
  1010. v |= (int64(b) & 0x7F) << shift
  1011. if b < 0x80 {
  1012. break
  1013. }
  1014. }
  1015. m.WSPort = append(m.WSPort, v)
  1016. } else if wireType == 2 {
  1017. var packedLen int
  1018. for shift := uint(0); ; shift += 7 {
  1019. if shift >= 64 {
  1020. return ErrIntOverflowDm
  1021. }
  1022. if iNdEx >= l {
  1023. return io.ErrUnexpectedEOF
  1024. }
  1025. b := dAtA[iNdEx]
  1026. iNdEx++
  1027. packedLen |= (int(b) & 0x7F) << shift
  1028. if b < 0x80 {
  1029. break
  1030. }
  1031. }
  1032. if packedLen < 0 {
  1033. return ErrInvalidLengthDm
  1034. }
  1035. postIndex := iNdEx + packedLen
  1036. if postIndex > l {
  1037. return io.ErrUnexpectedEOF
  1038. }
  1039. var elementCount int
  1040. var count int
  1041. for _, integer := range dAtA {
  1042. if integer < 128 {
  1043. count++
  1044. }
  1045. }
  1046. elementCount = count
  1047. if elementCount != 0 && len(m.WSPort) == 0 {
  1048. m.WSPort = make([]int64, 0, elementCount)
  1049. }
  1050. for iNdEx < postIndex {
  1051. var v int64
  1052. for shift := uint(0); ; shift += 7 {
  1053. if shift >= 64 {
  1054. return ErrIntOverflowDm
  1055. }
  1056. if iNdEx >= l {
  1057. return io.ErrUnexpectedEOF
  1058. }
  1059. b := dAtA[iNdEx]
  1060. iNdEx++
  1061. v |= (int64(b) & 0x7F) << shift
  1062. if b < 0x80 {
  1063. break
  1064. }
  1065. }
  1066. m.WSPort = append(m.WSPort, v)
  1067. }
  1068. } else {
  1069. return fmt.Errorf("proto: wrong wireType = %d for field WSPort", wireType)
  1070. }
  1071. case 2:
  1072. if wireType == 0 {
  1073. var v int64
  1074. for shift := uint(0); ; shift += 7 {
  1075. if shift >= 64 {
  1076. return ErrIntOverflowDm
  1077. }
  1078. if iNdEx >= l {
  1079. return io.ErrUnexpectedEOF
  1080. }
  1081. b := dAtA[iNdEx]
  1082. iNdEx++
  1083. v |= (int64(b) & 0x7F) << shift
  1084. if b < 0x80 {
  1085. break
  1086. }
  1087. }
  1088. m.WSSPort = append(m.WSSPort, v)
  1089. } else if wireType == 2 {
  1090. var packedLen int
  1091. for shift := uint(0); ; shift += 7 {
  1092. if shift >= 64 {
  1093. return ErrIntOverflowDm
  1094. }
  1095. if iNdEx >= l {
  1096. return io.ErrUnexpectedEOF
  1097. }
  1098. b := dAtA[iNdEx]
  1099. iNdEx++
  1100. packedLen |= (int(b) & 0x7F) << shift
  1101. if b < 0x80 {
  1102. break
  1103. }
  1104. }
  1105. if packedLen < 0 {
  1106. return ErrInvalidLengthDm
  1107. }
  1108. postIndex := iNdEx + packedLen
  1109. if postIndex > l {
  1110. return io.ErrUnexpectedEOF
  1111. }
  1112. var elementCount int
  1113. var count int
  1114. for _, integer := range dAtA {
  1115. if integer < 128 {
  1116. count++
  1117. }
  1118. }
  1119. elementCount = count
  1120. if elementCount != 0 && len(m.WSSPort) == 0 {
  1121. m.WSSPort = make([]int64, 0, elementCount)
  1122. }
  1123. for iNdEx < postIndex {
  1124. var v int64
  1125. for shift := uint(0); ; shift += 7 {
  1126. if shift >= 64 {
  1127. return ErrIntOverflowDm
  1128. }
  1129. if iNdEx >= l {
  1130. return io.ErrUnexpectedEOF
  1131. }
  1132. b := dAtA[iNdEx]
  1133. iNdEx++
  1134. v |= (int64(b) & 0x7F) << shift
  1135. if b < 0x80 {
  1136. break
  1137. }
  1138. }
  1139. m.WSSPort = append(m.WSSPort, v)
  1140. }
  1141. } else {
  1142. return fmt.Errorf("proto: wrong wireType = %d for field WSSPort", wireType)
  1143. }
  1144. case 3:
  1145. if wireType == 0 {
  1146. var v int64
  1147. for shift := uint(0); ; shift += 7 {
  1148. if shift >= 64 {
  1149. return ErrIntOverflowDm
  1150. }
  1151. if iNdEx >= l {
  1152. return io.ErrUnexpectedEOF
  1153. }
  1154. b := dAtA[iNdEx]
  1155. iNdEx++
  1156. v |= (int64(b) & 0x7F) << shift
  1157. if b < 0x80 {
  1158. break
  1159. }
  1160. }
  1161. m.TCPPort = append(m.TCPPort, v)
  1162. } else if wireType == 2 {
  1163. var packedLen int
  1164. for shift := uint(0); ; shift += 7 {
  1165. if shift >= 64 {
  1166. return ErrIntOverflowDm
  1167. }
  1168. if iNdEx >= l {
  1169. return io.ErrUnexpectedEOF
  1170. }
  1171. b := dAtA[iNdEx]
  1172. iNdEx++
  1173. packedLen |= (int(b) & 0x7F) << shift
  1174. if b < 0x80 {
  1175. break
  1176. }
  1177. }
  1178. if packedLen < 0 {
  1179. return ErrInvalidLengthDm
  1180. }
  1181. postIndex := iNdEx + packedLen
  1182. if postIndex > l {
  1183. return io.ErrUnexpectedEOF
  1184. }
  1185. var elementCount int
  1186. var count int
  1187. for _, integer := range dAtA {
  1188. if integer < 128 {
  1189. count++
  1190. }
  1191. }
  1192. elementCount = count
  1193. if elementCount != 0 && len(m.TCPPort) == 0 {
  1194. m.TCPPort = make([]int64, 0, elementCount)
  1195. }
  1196. for iNdEx < postIndex {
  1197. var v int64
  1198. for shift := uint(0); ; shift += 7 {
  1199. if shift >= 64 {
  1200. return ErrIntOverflowDm
  1201. }
  1202. if iNdEx >= l {
  1203. return io.ErrUnexpectedEOF
  1204. }
  1205. b := dAtA[iNdEx]
  1206. iNdEx++
  1207. v |= (int64(b) & 0x7F) << shift
  1208. if b < 0x80 {
  1209. break
  1210. }
  1211. }
  1212. m.TCPPort = append(m.TCPPort, v)
  1213. }
  1214. } else {
  1215. return fmt.Errorf("proto: wrong wireType = %d for field TCPPort", wireType)
  1216. }
  1217. case 4:
  1218. if wireType != 2 {
  1219. return fmt.Errorf("proto: wrong wireType = %d for field IPList", wireType)
  1220. }
  1221. var stringLen uint64
  1222. for shift := uint(0); ; shift += 7 {
  1223. if shift >= 64 {
  1224. return ErrIntOverflowDm
  1225. }
  1226. if iNdEx >= l {
  1227. return io.ErrUnexpectedEOF
  1228. }
  1229. b := dAtA[iNdEx]
  1230. iNdEx++
  1231. stringLen |= (uint64(b) & 0x7F) << shift
  1232. if b < 0x80 {
  1233. break
  1234. }
  1235. }
  1236. intStringLen := int(stringLen)
  1237. if intStringLen < 0 {
  1238. return ErrInvalidLengthDm
  1239. }
  1240. postIndex := iNdEx + intStringLen
  1241. if postIndex > l {
  1242. return io.ErrUnexpectedEOF
  1243. }
  1244. m.IPList = append(m.IPList, string(dAtA[iNdEx:postIndex]))
  1245. iNdEx = postIndex
  1246. case 5:
  1247. if wireType != 2 {
  1248. return fmt.Errorf("proto: wrong wireType = %d for field DomianList", wireType)
  1249. }
  1250. var stringLen uint64
  1251. for shift := uint(0); ; shift += 7 {
  1252. if shift >= 64 {
  1253. return ErrIntOverflowDm
  1254. }
  1255. if iNdEx >= l {
  1256. return io.ErrUnexpectedEOF
  1257. }
  1258. b := dAtA[iNdEx]
  1259. iNdEx++
  1260. stringLen |= (uint64(b) & 0x7F) << shift
  1261. if b < 0x80 {
  1262. break
  1263. }
  1264. }
  1265. intStringLen := int(stringLen)
  1266. if intStringLen < 0 {
  1267. return ErrInvalidLengthDm
  1268. }
  1269. postIndex := iNdEx + intStringLen
  1270. if postIndex > l {
  1271. return io.ErrUnexpectedEOF
  1272. }
  1273. m.DomianList = append(m.DomianList, string(dAtA[iNdEx:postIndex]))
  1274. iNdEx = postIndex
  1275. default:
  1276. iNdEx = preIndex
  1277. skippy, err := skipDm(dAtA[iNdEx:])
  1278. if err != nil {
  1279. return err
  1280. }
  1281. if skippy < 0 {
  1282. return ErrInvalidLengthDm
  1283. }
  1284. if (iNdEx + skippy) > l {
  1285. return io.ErrUnexpectedEOF
  1286. }
  1287. m.XXX_unrecognized = append(m.XXX_unrecognized, dAtA[iNdEx:iNdEx+skippy]...)
  1288. iNdEx += skippy
  1289. }
  1290. }
  1291. if iNdEx > l {
  1292. return io.ErrUnexpectedEOF
  1293. }
  1294. return nil
  1295. }
  1296. func skipDm(dAtA []byte) (n int, err error) {
  1297. l := len(dAtA)
  1298. iNdEx := 0
  1299. for iNdEx < l {
  1300. var wire uint64
  1301. for shift := uint(0); ; shift += 7 {
  1302. if shift >= 64 {
  1303. return 0, ErrIntOverflowDm
  1304. }
  1305. if iNdEx >= l {
  1306. return 0, io.ErrUnexpectedEOF
  1307. }
  1308. b := dAtA[iNdEx]
  1309. iNdEx++
  1310. wire |= (uint64(b) & 0x7F) << shift
  1311. if b < 0x80 {
  1312. break
  1313. }
  1314. }
  1315. wireType := int(wire & 0x7)
  1316. switch wireType {
  1317. case 0:
  1318. for shift := uint(0); ; shift += 7 {
  1319. if shift >= 64 {
  1320. return 0, ErrIntOverflowDm
  1321. }
  1322. if iNdEx >= l {
  1323. return 0, io.ErrUnexpectedEOF
  1324. }
  1325. iNdEx++
  1326. if dAtA[iNdEx-1] < 0x80 {
  1327. break
  1328. }
  1329. }
  1330. return iNdEx, nil
  1331. case 1:
  1332. iNdEx += 8
  1333. return iNdEx, nil
  1334. case 2:
  1335. var length int
  1336. for shift := uint(0); ; shift += 7 {
  1337. if shift >= 64 {
  1338. return 0, ErrIntOverflowDm
  1339. }
  1340. if iNdEx >= l {
  1341. return 0, io.ErrUnexpectedEOF
  1342. }
  1343. b := dAtA[iNdEx]
  1344. iNdEx++
  1345. length |= (int(b) & 0x7F) << shift
  1346. if b < 0x80 {
  1347. break
  1348. }
  1349. }
  1350. iNdEx += length
  1351. if length < 0 {
  1352. return 0, ErrInvalidLengthDm
  1353. }
  1354. return iNdEx, nil
  1355. case 3:
  1356. for {
  1357. var innerWire uint64
  1358. var start int = iNdEx
  1359. for shift := uint(0); ; shift += 7 {
  1360. if shift >= 64 {
  1361. return 0, ErrIntOverflowDm
  1362. }
  1363. if iNdEx >= l {
  1364. return 0, io.ErrUnexpectedEOF
  1365. }
  1366. b := dAtA[iNdEx]
  1367. iNdEx++
  1368. innerWire |= (uint64(b) & 0x7F) << shift
  1369. if b < 0x80 {
  1370. break
  1371. }
  1372. }
  1373. innerWireType := int(innerWire & 0x7)
  1374. if innerWireType == 4 {
  1375. break
  1376. }
  1377. next, err := skipDm(dAtA[start:])
  1378. if err != nil {
  1379. return 0, err
  1380. }
  1381. iNdEx = start + next
  1382. }
  1383. return iNdEx, nil
  1384. case 4:
  1385. return iNdEx, nil
  1386. case 5:
  1387. iNdEx += 4
  1388. return iNdEx, nil
  1389. default:
  1390. return 0, fmt.Errorf("proto: illegal wireType %d", wireType)
  1391. }
  1392. }
  1393. panic("unreachable")
  1394. }
  1395. var (
  1396. ErrInvalidLengthDm = fmt.Errorf("proto: negative length found during unmarshaling")
  1397. ErrIntOverflowDm = fmt.Errorf("proto: integer overflow")
  1398. )
  1399. func init() { proto.RegisterFile("dm.proto", fileDescriptor_dm_1bcdb7fd715c39b4) }
  1400. var fileDescriptor_dm_1bcdb7fd715c39b4 = []byte{
  1401. // 546 bytes of a gzipped FileDescriptorProto
  1402. 0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0x94, 0x93, 0x41, 0x6b, 0xdb, 0x3c,
  1403. 0x18, 0xc7, 0xb1, 0xdd, 0x26, 0xad, 0xf2, 0xbe, 0x6c, 0x08, 0x06, 0x26, 0x8c, 0xd8, 0x53, 0xb6,
  1404. 0x12, 0x18, 0xb5, 0x49, 0x37, 0x18, 0xe4, 0xb0, 0x43, 0x5a, 0x28, 0x85, 0x15, 0x42, 0x12, 0x28,
  1405. 0xec, 0x12, 0x9c, 0x58, 0xd1, 0x04, 0x91, 0xe4, 0x5a, 0x4a, 0xba, 0x4b, 0x2f, 0xfd, 0x0a, 0xfb,
  1406. 0x18, 0x3b, 0xef, 0x3b, 0xec, 0x38, 0xd8, 0x65, 0x27, 0x33, 0xc2, 0x4e, 0x39, 0xe6, 0x13, 0x0c,
  1407. 0x4b, 0x4e, 0x52, 0x46, 0xba, 0x91, 0x9b, 0xe5, 0xe7, 0xf7, 0xf3, 0xff, 0xd1, 0x63, 0x09, 0x1c,
  1408. 0xc4, 0x2c, 0x48, 0x52, 0xa1, 0x04, 0x7c, 0x32, 0xa1, 0x33, 0x1c, 0x88, 0x04, 0x73, 0xca, 0x15,
  1409. 0x4e, 0xc7, 0xd1, 0x08, 0x07, 0xb3, 0x66, 0xf5, 0x98, 0x50, 0xf5, 0x61, 0x3a, 0x0c, 0x46, 0x82,
  1410. 0x85, 0x44, 0x10, 0x11, 0x6a, 0x7a, 0x38, 0x1d, 0xeb, 0x95, 0x5e, 0xe8, 0x27, 0xf3, 0x95, 0xea,
  1411. 0x53, 0x22, 0x04, 0x99, 0xe0, 0x30, 0x4a, 0x68, 0x18, 0x71, 0x2e, 0x54, 0xa4, 0xa8, 0xe0, 0xd2,
  1412. 0x54, 0xd1, 0x67, 0x1b, 0x80, 0x1e, 0xe6, 0xf1, 0xa5, 0x24, 0x5d, 0x7c, 0x0d, 0x5f, 0x03, 0xe7,
  1413. 0x52, 0x12, 0xd7, 0xf2, 0xad, 0xc6, 0x61, 0x1b, 0x2d, 0x33, 0xaf, 0x36, 0x16, 0x29, 0x6b, 0x21,
  1414. 0x26, 0x09, 0xf2, 0x67, 0xd1, 0x84, 0xc6, 0x91, 0xc2, 0x2d, 0x94, 0xe2, 0xeb, 0x29, 0x4d, 0x71,
  1415. 0x8c, 0xba, 0x39, 0x0e, 0x4f, 0x80, 0xdd, 0x97, 0xae, 0xfd, 0xa7, 0xa4, 0x24, 0xf2, 0xb7, 0x4a,
  1416. 0x76, 0x5f, 0xc2, 0xb7, 0xa0, 0xd4, 0x15, 0x82, 0x5d, 0x9c, 0xb9, 0x8e, 0x6f, 0x35, 0x9c, 0xf6,
  1417. 0xd1, 0x32, 0xf3, 0x90, 0xf1, 0x52, 0x21, 0xd8, 0x80, 0xc6, 0xdb, 0x03, 0x0b, 0x0b, 0xb6, 0xc0,
  1418. 0xfe, 0x79, 0x2a, 0xa6, 0x89, 0xbb, 0xa7, 0x63, 0x9f, 0x2f, 0x33, 0xcf, 0x37, 0x3a, 0xc9, 0x5f,
  1419. 0x6f, 0x97, 0x8d, 0x02, 0xdf, 0x80, 0xbd, 0x1e, 0x25, 0xdc, 0xdd, 0xd7, 0x6a, 0x7d, 0x99, 0x79,
  1420. 0x9e, 0x51, 0x25, 0x25, 0x7c, 0xbb, 0xa9, 0x05, 0xf4, 0x3f, 0xa8, 0xac, 0x87, 0x25, 0x13, 0xf4,
  1421. 0xc5, 0x02, 0xe0, 0x1c, 0xab, 0x53, 0xc1, 0xc7, 0xf9, 0xf0, 0xcc, 0x18, 0xac, 0x9d, 0xc6, 0xb0,
  1422. 0x6a, 0xc5, 0xde, 0xb1, 0x95, 0xcd, 0xfe, 0x9d, 0x9d, 0xf7, 0x8f, 0x7e, 0x58, 0xa0, 0xb2, 0xee,
  1423. 0x5b, 0x26, 0xb0, 0x0e, 0x4a, 0x57, 0xbd, 0x8e, 0x48, 0x95, 0x6b, 0xf9, 0x4e, 0xc3, 0x69, 0x57,
  1424. 0x16, 0x99, 0x57, 0xbe, 0x91, 0x83, 0x44, 0xa4, 0xaa, 0x5b, 0x94, 0xe0, 0x11, 0x28, 0x5f, 0xf5,
  1425. 0x0c, 0x65, 0x6b, 0xea, 0xbf, 0x45, 0xe6, 0x1d, 0xdc, 0xc8, 0x02, 0x5b, 0x15, 0x73, 0xae, 0x7f,
  1426. 0xda, 0xd1, 0x9c, 0xb3, 0xe1, 0xd4, 0x28, 0x29, 0xb8, 0xa2, 0x98, 0x87, 0x5e, 0x74, 0xde, 0x51,
  1427. 0xa9, 0xdc, 0x3d, 0xdf, 0x69, 0x1c, 0x9a, 0x50, 0x9a, 0x0c, 0x26, 0x54, 0xaa, 0x6e, 0x51, 0x82,
  1428. 0x21, 0x00, 0x67, 0x82, 0xd1, 0x88, 0x6b, 0x70, 0x5f, 0x83, 0x8f, 0x16, 0x99, 0x57, 0x89, 0x05,
  1429. 0x8b, 0x28, 0x37, 0xf0, 0x3d, 0xe4, 0xe4, 0xce, 0x06, 0x76, 0xcc, 0xe0, 0x2d, 0x28, 0x4b, 0xcc,
  1430. 0x63, 0x26, 0x09, 0x7c, 0x16, 0x6c, 0xbd, 0x46, 0xc1, 0xe6, 0xd4, 0x57, 0xd1, 0xbf, 0x10, 0x99,
  1431. 0xa0, 0x97, 0x77, 0xdf, 0x7f, 0x7d, 0xb2, 0x5f, 0xa0, 0x7a, 0xf8, 0x31, 0x87, 0xc3, 0x1c, 0x3e,
  1432. 0x5e, 0xd3, 0xe1, 0xac, 0x19, 0xc6, 0x2c, 0x5c, 0x65, 0xde, 0x82, 0x32, 0x31, 0xf3, 0x7d, 0x30,
  1433. 0x7e, 0x73, 0x6e, 0x1e, 0x8c, 0xbf, 0xf7, 0x8b, 0x56, 0xf1, 0xf0, 0xaf, 0xf1, 0x45, 0x66, 0xfb,
  1434. 0xf1, 0xd7, 0x79, 0xcd, 0xfa, 0x36, 0xaf, 0x59, 0x3f, 0xe7, 0x35, 0xeb, 0xbd, 0x3d, 0x6b, 0x0e,
  1435. 0x4b, 0xfa, 0xb6, 0xbf, 0xfa, 0x1d, 0x00, 0x00, 0xff, 0xff, 0xab, 0x39, 0x6d, 0x7e, 0x5d, 0x04,
  1436. 0x00, 0x00,
  1437. }