rpc.pb.go 114 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162116311641165116611671168116911701171117211731174117511761177117811791180118111821183118411851186118711881189119011911192119311941195119611971198119912001201120212031204120512061207120812091210121112121213121412151216121712181219122012211222122312241225122612271228122912301231123212331234123512361237123812391240124112421243124412451246124712481249125012511252125312541255125612571258125912601261126212631264126512661267126812691270127112721273127412751276127712781279128012811282128312841285128612871288128912901291129212931294129512961297129812991300130113021303130413051306130713081309131013111312131313141315131613171318131913201321132213231324132513261327132813291330133113321333133413351336133713381339134013411342134313441345134613471348134913501351135213531354135513561357135813591360136113621363136413651366136713681369137013711372137313741375137613771378137913801381138213831384138513861387138813891390139113921393139413951396139713981399140014011402140314041405140614071408140914101411141214131414141514161417141814191420142114221423142414251426142714281429143014311432143314341435143614371438143914401441144214431444144514461447144814491450145114521453145414551456145714581459146014611462146314641465146614671468146914701471147214731474147514761477147814791480148114821483148414851486148714881489149014911492149314941495149614971498149915001501150215031504150515061507150815091510151115121513151415151516151715181519152015211522152315241525152615271528152915301531153215331534153515361537153815391540154115421543154415451546154715481549155015511552155315541555155615571558155915601561156215631564156515661567156815691570157115721573157415751576157715781579158015811582158315841585158615871588158915901591159215931594159515961597159815991600160116021603160416051606160716081609161016111612161316141615161616171618161916201621162216231624162516261627162816291630163116321633163416351636163716381639164016411642164316441645164616471648164916501651165216531654165516561657165816591660166116621663166416651666166716681669167016711672167316741675167616771678167916801681168216831684168516861687168816891690169116921693169416951696169716981699170017011702170317041705170617071708170917101711171217131714171517161717171817191720172117221723172417251726172717281729173017311732173317341735173617371738173917401741174217431744174517461747174817491750175117521753175417551756175717581759176017611762176317641765176617671768176917701771177217731774177517761777177817791780178117821783178417851786178717881789179017911792179317941795179617971798179918001801180218031804180518061807180818091810181118121813181418151816181718181819182018211822182318241825182618271828182918301831183218331834183518361837183818391840184118421843184418451846184718481849185018511852185318541855185618571858185918601861186218631864186518661867186818691870187118721873187418751876187718781879188018811882188318841885188618871888188918901891189218931894189518961897189818991900190119021903190419051906190719081909191019111912191319141915191619171918191919201921192219231924192519261927192819291930193119321933193419351936193719381939194019411942194319441945194619471948194919501951195219531954195519561957195819591960196119621963196419651966196719681969197019711972197319741975197619771978197919801981198219831984198519861987198819891990199119921993199419951996199719981999200020012002200320042005200620072008200920102011201220132014201520162017201820192020202120222023202420252026202720282029203020312032203320342035203620372038203920402041204220432044204520462047204820492050205120522053205420552056205720582059206020612062206320642065206620672068206920702071207220732074207520762077207820792080208120822083208420852086208720882089209020912092209320942095209620972098209921002101210221032104210521062107210821092110211121122113211421152116211721182119212021212122212321242125212621272128212921302131213221332134213521362137213821392140214121422143214421452146214721482149215021512152215321542155215621572158215921602161216221632164216521662167216821692170217121722173217421752176217721782179218021812182218321842185218621872188218921902191219221932194219521962197219821992200220122022203220422052206220722082209221022112212221322142215221622172218221922202221222222232224222522262227222822292230223122322233223422352236223722382239224022412242224322442245224622472248224922502251225222532254225522562257225822592260226122622263226422652266226722682269227022712272227322742275227622772278227922802281228222832284228522862287228822892290229122922293229422952296229722982299230023012302230323042305230623072308230923102311231223132314231523162317231823192320232123222323232423252326232723282329233023312332233323342335233623372338233923402341234223432344234523462347234823492350235123522353235423552356235723582359236023612362236323642365236623672368236923702371237223732374237523762377237823792380238123822383238423852386238723882389239023912392239323942395239623972398239924002401240224032404240524062407240824092410241124122413241424152416241724182419242024212422242324242425242624272428242924302431243224332434243524362437243824392440244124422443244424452446244724482449245024512452245324542455245624572458245924602461246224632464246524662467246824692470247124722473247424752476247724782479248024812482248324842485248624872488248924902491249224932494249524962497249824992500250125022503250425052506250725082509251025112512251325142515251625172518251925202521252225232524252525262527252825292530253125322533253425352536253725382539254025412542254325442545254625472548254925502551255225532554255525562557255825592560256125622563256425652566256725682569257025712572257325742575257625772578257925802581258225832584258525862587258825892590259125922593259425952596259725982599260026012602260326042605260626072608260926102611261226132614261526162617261826192620262126222623262426252626262726282629263026312632263326342635263626372638263926402641264226432644264526462647264826492650265126522653265426552656265726582659266026612662266326642665266626672668266926702671267226732674267526762677267826792680268126822683268426852686268726882689269026912692269326942695269626972698269927002701270227032704270527062707270827092710271127122713271427152716271727182719272027212722272327242725272627272728272927302731273227332734273527362737273827392740274127422743274427452746274727482749275027512752275327542755275627572758275927602761276227632764276527662767276827692770277127722773277427752776277727782779278027812782278327842785278627872788278927902791279227932794279527962797279827992800280128022803280428052806280728082809281028112812281328142815281628172818281928202821282228232824282528262827282828292830283128322833283428352836283728382839284028412842284328442845284628472848284928502851285228532854285528562857285828592860286128622863286428652866286728682869287028712872287328742875287628772878287928802881288228832884288528862887288828892890289128922893289428952896289728982899290029012902290329042905290629072908290929102911291229132914291529162917291829192920292129222923292429252926292729282929293029312932293329342935293629372938293929402941294229432944294529462947294829492950295129522953295429552956295729582959296029612962296329642965296629672968296929702971297229732974297529762977297829792980298129822983298429852986298729882989299029912992299329942995299629972998299930003001300230033004300530063007300830093010301130123013301430153016301730183019302030213022302330243025302630273028302930303031303230333034303530363037303830393040304130423043304430453046304730483049305030513052305330543055305630573058305930603061306230633064306530663067306830693070307130723073307430753076307730783079308030813082308330843085308630873088308930903091309230933094309530963097309830993100310131023103310431053106310731083109311031113112311331143115311631173118311931203121312231233124312531263127312831293130313131323133313431353136313731383139314031413142314331443145314631473148314931503151315231533154315531563157315831593160316131623163316431653166316731683169317031713172317331743175317631773178317931803181318231833184318531863187318831893190319131923193319431953196319731983199320032013202320332043205320632073208320932103211321232133214321532163217321832193220322132223223322432253226322732283229323032313232323332343235323632373238323932403241324232433244324532463247324832493250325132523253325432553256325732583259326032613262326332643265326632673268326932703271327232733274327532763277327832793280328132823283328432853286328732883289329032913292329332943295329632973298329933003301330233033304330533063307330833093310331133123313331433153316331733183319332033213322332333243325332633273328332933303331333233333334333533363337333833393340334133423343334433453346334733483349335033513352335333543355335633573358335933603361336233633364336533663367336833693370337133723373337433753376337733783379338033813382338333843385338633873388338933903391339233933394339533963397339833993400340134023403340434053406340734083409341034113412341334143415341634173418341934203421342234233424342534263427342834293430343134323433343434353436343734383439344034413442344334443445344634473448344934503451345234533454345534563457345834593460346134623463346434653466346734683469347034713472347334743475347634773478347934803481348234833484348534863487348834893490349134923493349434953496349734983499350035013502350335043505350635073508350935103511351235133514351535163517351835193520352135223523352435253526352735283529353035313532353335343535353635373538353935403541354235433544354535463547354835493550355135523553355435553556355735583559356035613562356335643565356635673568356935703571357235733574357535763577357835793580358135823583358435853586358735883589359035913592359335943595359635973598359936003601360236033604360536063607360836093610361136123613361436153616361736183619362036213622362336243625362636273628362936303631363236333634363536363637363836393640364136423643364436453646364736483649365036513652365336543655365636573658365936603661366236633664366536663667366836693670367136723673367436753676367736783679368036813682368336843685368636873688368936903691369236933694369536963697369836993700370137023703370437053706370737083709371037113712371337143715371637173718371937203721372237233724372537263727372837293730373137323733373437353736373737383739374037413742374337443745374637473748374937503751375237533754375537563757375837593760376137623763376437653766376737683769377037713772377337743775377637773778377937803781378237833784378537863787378837893790379137923793379437953796379737983799380038013802380338043805380638073808380938103811381238133814381538163817381838193820382138223823382438253826382738283829383038313832383338343835383638373838383938403841384238433844384538463847384838493850385138523853385438553856385738583859386038613862386338643865386638673868386938703871387238733874387538763877387838793880388138823883388438853886388738883889389038913892389338943895389638973898389939003901390239033904390539063907390839093910391139123913391439153916391739183919392039213922392339243925392639273928392939303931393239333934393539363937393839393940394139423943394439453946394739483949395039513952395339543955395639573958395939603961396239633964396539663967396839693970397139723973397439753976397739783979398039813982398339843985398639873988398939903991399239933994399539963997399839994000400140024003400440054006400740084009401040114012401340144015401640174018401940204021402240234024402540264027402840294030403140324033403440354036403740384039404040414042404340444045404640474048404940504051405240534054405540564057405840594060406140624063406440654066406740684069407040714072407340744075407640774078407940804081408240834084408540864087408840894090409140924093409440954096409740984099410041014102410341044105410641074108410941104111411241134114
  1. // Code generated by protoc-gen-gogo. DO NOT EDIT.
  2. // source: rpcpb/rpc.proto
  3. /*
  4. Package rpcpb is a generated protocol buffer package.
  5. It is generated from these files:
  6. rpcpb/rpc.proto
  7. It has these top-level messages:
  8. Etcd
  9. Member
  10. Tester
  11. Request
  12. Response
  13. */
  14. package rpcpb
  15. import proto "github.com/golang/protobuf/proto"
  16. import fmt "fmt"
  17. import math "math"
  18. import _ "github.com/gogo/protobuf/gogoproto"
  19. import context "golang.org/x/net/context"
  20. import grpc "google.golang.org/grpc"
  21. import io "io"
  22. // Reference imports to suppress errors if they are not otherwise used.
  23. var _ = proto.Marshal
  24. var _ = fmt.Errorf
  25. var _ = math.Inf
  26. // This is a compile-time assertion to ensure that this generated file
  27. // is compatible with the proto package it is being compiled against.
  28. // A compilation error at this line likely means your copy of the
  29. // proto package needs to be updated.
  30. const _ = proto.ProtoPackageIsVersion2 // please upgrade the proto package
  31. type Operation int32
  32. const (
  33. Operation_NotStarted Operation = 0
  34. // InitialStartEtcd is only called to start etcd very first time.
  35. Operation_InitialStartEtcd Operation = 1
  36. // RestartEtcd is sent to restart killed etcd.
  37. Operation_RestartEtcd Operation = 2
  38. // KillEtcd pauses etcd process while keeping data directories
  39. // and previous etcd configurations.
  40. Operation_KillEtcd Operation = 3
  41. // FailArchive is sent when consistency check failed,
  42. // thus need to archive etcd data directories.
  43. Operation_FailArchive Operation = 4
  44. // DestroyEtcdAgent destroys etcd process, etcd data, and agent server.
  45. Operation_DestroyEtcdAgent Operation = 5
  46. Operation_BlackholePeerPortTxRx Operation = 100
  47. Operation_UnblackholePeerPortTxRx Operation = 101
  48. Operation_DelayPeerPortTxRx Operation = 102
  49. Operation_UndelayPeerPortTxRx Operation = 103
  50. )
  51. var Operation_name = map[int32]string{
  52. 0: "NotStarted",
  53. 1: "InitialStartEtcd",
  54. 2: "RestartEtcd",
  55. 3: "KillEtcd",
  56. 4: "FailArchive",
  57. 5: "DestroyEtcdAgent",
  58. 100: "BlackholePeerPortTxRx",
  59. 101: "UnblackholePeerPortTxRx",
  60. 102: "DelayPeerPortTxRx",
  61. 103: "UndelayPeerPortTxRx",
  62. }
  63. var Operation_value = map[string]int32{
  64. "NotStarted": 0,
  65. "InitialStartEtcd": 1,
  66. "RestartEtcd": 2,
  67. "KillEtcd": 3,
  68. "FailArchive": 4,
  69. "DestroyEtcdAgent": 5,
  70. "BlackholePeerPortTxRx": 100,
  71. "UnblackholePeerPortTxRx": 101,
  72. "DelayPeerPortTxRx": 102,
  73. "UndelayPeerPortTxRx": 103,
  74. }
  75. func (x Operation) String() string {
  76. return proto.EnumName(Operation_name, int32(x))
  77. }
  78. func (Operation) EnumDescriptor() ([]byte, []int) { return fileDescriptorRpc, []int{0} }
  79. type FailureCase int32
  80. const (
  81. FailureCase_KILL_ONE_FOLLOWER FailureCase = 0
  82. FailureCase_KILL_ONE_FOLLOWER_UNTIL_TRIGGER_SNAPSHOT FailureCase = 1
  83. FailureCase_KILL_LEADER FailureCase = 2
  84. FailureCase_KILL_LEADER_UNTIL_TRIGGER_SNAPSHOT FailureCase = 3
  85. FailureCase_KILL_QUORUM FailureCase = 4
  86. FailureCase_KILL_ALL FailureCase = 5
  87. FailureCase_BLACKHOLE_PEER_PORT_TX_RX_ONE_FOLLOWER FailureCase = 100
  88. FailureCase_BLACKHOLE_PEER_PORT_TX_RX_ONE_FOLLOWER_UNTIL_TRIGGER_SNAPSHOT FailureCase = 101
  89. FailureCase_BLACKHOLE_PEER_PORT_TX_RX_LEADER FailureCase = 102
  90. FailureCase_BLACKHOLE_PEER_PORT_TX_RX_LEADER_UNTIL_TRIGGER_SNAPSHOT FailureCase = 103
  91. FailureCase_BLACKHOLE_PEER_PORT_TX_RX_QUORUM FailureCase = 104
  92. FailureCase_BLACKHOLE_PEER_PORT_TX_RX_ALL FailureCase = 105
  93. FailureCase_DELAY_PEER_PORT_TX_RX_ONE_FOLLOWER FailureCase = 200
  94. FailureCase_RANDOM_DELAY_PEER_PORT_TX_RX_ONE_FOLLOWER FailureCase = 201
  95. FailureCase_DELAY_PEER_PORT_TX_RX_ONE_FOLLOWER_UNTIL_TRIGGER_SNAPSHOT FailureCase = 202
  96. FailureCase_RANDOM_DELAY_PEER_PORT_TX_RX_ONE_FOLLOWER_UNTIL_TRIGGER_SNAPSHOT FailureCase = 203
  97. FailureCase_DELAY_PEER_PORT_TX_RX_LEADER FailureCase = 204
  98. FailureCase_RANDOM_DELAY_PEER_PORT_TX_RX_LEADER FailureCase = 205
  99. FailureCase_DELAY_PEER_PORT_TX_RX_LEADER_UNTIL_TRIGGER_SNAPSHOT FailureCase = 206
  100. FailureCase_RANDOM_DELAY_PEER_PORT_TX_RX_LEADER_UNTIL_TRIGGER_SNAPSHOT FailureCase = 207
  101. FailureCase_DELAY_PEER_PORT_TX_RX_QUORUM FailureCase = 208
  102. FailureCase_RANDOM_DELAY_PEER_PORT_TX_RX_QUORUM FailureCase = 209
  103. FailureCase_DELAY_PEER_PORT_TX_RX_ALL FailureCase = 210
  104. FailureCase_RANDOM_DELAY_PEER_PORT_TX_RX_ALL FailureCase = 211
  105. // NO_FAIL_WITH_STRESS runs no-op failure injection for specified period
  106. // while stressers are still sending requests.
  107. FailureCase_NO_FAIL_WITH_STRESS FailureCase = 300
  108. // NO_FAIL_WITH_NO_STRESS_FOR_LIVENESS runs no-op failure injection
  109. // with all stressers stopped.
  110. FailureCase_NO_FAIL_WITH_NO_STRESS_FOR_LIVENESS FailureCase = 301
  111. FailureCase_FAILPOINTS FailureCase = 400
  112. FailureCase_EXTERNAL FailureCase = 500
  113. )
  114. var FailureCase_name = map[int32]string{
  115. 0: "KILL_ONE_FOLLOWER",
  116. 1: "KILL_ONE_FOLLOWER_UNTIL_TRIGGER_SNAPSHOT",
  117. 2: "KILL_LEADER",
  118. 3: "KILL_LEADER_UNTIL_TRIGGER_SNAPSHOT",
  119. 4: "KILL_QUORUM",
  120. 5: "KILL_ALL",
  121. 100: "BLACKHOLE_PEER_PORT_TX_RX_ONE_FOLLOWER",
  122. 101: "BLACKHOLE_PEER_PORT_TX_RX_ONE_FOLLOWER_UNTIL_TRIGGER_SNAPSHOT",
  123. 102: "BLACKHOLE_PEER_PORT_TX_RX_LEADER",
  124. 103: "BLACKHOLE_PEER_PORT_TX_RX_LEADER_UNTIL_TRIGGER_SNAPSHOT",
  125. 104: "BLACKHOLE_PEER_PORT_TX_RX_QUORUM",
  126. 105: "BLACKHOLE_PEER_PORT_TX_RX_ALL",
  127. 200: "DELAY_PEER_PORT_TX_RX_ONE_FOLLOWER",
  128. 201: "RANDOM_DELAY_PEER_PORT_TX_RX_ONE_FOLLOWER",
  129. 202: "DELAY_PEER_PORT_TX_RX_ONE_FOLLOWER_UNTIL_TRIGGER_SNAPSHOT",
  130. 203: "RANDOM_DELAY_PEER_PORT_TX_RX_ONE_FOLLOWER_UNTIL_TRIGGER_SNAPSHOT",
  131. 204: "DELAY_PEER_PORT_TX_RX_LEADER",
  132. 205: "RANDOM_DELAY_PEER_PORT_TX_RX_LEADER",
  133. 206: "DELAY_PEER_PORT_TX_RX_LEADER_UNTIL_TRIGGER_SNAPSHOT",
  134. 207: "RANDOM_DELAY_PEER_PORT_TX_RX_LEADER_UNTIL_TRIGGER_SNAPSHOT",
  135. 208: "DELAY_PEER_PORT_TX_RX_QUORUM",
  136. 209: "RANDOM_DELAY_PEER_PORT_TX_RX_QUORUM",
  137. 210: "DELAY_PEER_PORT_TX_RX_ALL",
  138. 211: "RANDOM_DELAY_PEER_PORT_TX_RX_ALL",
  139. 300: "NO_FAIL_WITH_STRESS",
  140. 301: "NO_FAIL_WITH_NO_STRESS_FOR_LIVENESS",
  141. 400: "FAILPOINTS",
  142. 500: "EXTERNAL",
  143. }
  144. var FailureCase_value = map[string]int32{
  145. "KILL_ONE_FOLLOWER": 0,
  146. "KILL_ONE_FOLLOWER_UNTIL_TRIGGER_SNAPSHOT": 1,
  147. "KILL_LEADER": 2,
  148. "KILL_LEADER_UNTIL_TRIGGER_SNAPSHOT": 3,
  149. "KILL_QUORUM": 4,
  150. "KILL_ALL": 5,
  151. "BLACKHOLE_PEER_PORT_TX_RX_ONE_FOLLOWER": 100,
  152. "BLACKHOLE_PEER_PORT_TX_RX_ONE_FOLLOWER_UNTIL_TRIGGER_SNAPSHOT": 101,
  153. "BLACKHOLE_PEER_PORT_TX_RX_LEADER": 102,
  154. "BLACKHOLE_PEER_PORT_TX_RX_LEADER_UNTIL_TRIGGER_SNAPSHOT": 103,
  155. "BLACKHOLE_PEER_PORT_TX_RX_QUORUM": 104,
  156. "BLACKHOLE_PEER_PORT_TX_RX_ALL": 105,
  157. "DELAY_PEER_PORT_TX_RX_ONE_FOLLOWER": 200,
  158. "RANDOM_DELAY_PEER_PORT_TX_RX_ONE_FOLLOWER": 201,
  159. "DELAY_PEER_PORT_TX_RX_ONE_FOLLOWER_UNTIL_TRIGGER_SNAPSHOT": 202,
  160. "RANDOM_DELAY_PEER_PORT_TX_RX_ONE_FOLLOWER_UNTIL_TRIGGER_SNAPSHOT": 203,
  161. "DELAY_PEER_PORT_TX_RX_LEADER": 204,
  162. "RANDOM_DELAY_PEER_PORT_TX_RX_LEADER": 205,
  163. "DELAY_PEER_PORT_TX_RX_LEADER_UNTIL_TRIGGER_SNAPSHOT": 206,
  164. "RANDOM_DELAY_PEER_PORT_TX_RX_LEADER_UNTIL_TRIGGER_SNAPSHOT": 207,
  165. "DELAY_PEER_PORT_TX_RX_QUORUM": 208,
  166. "RANDOM_DELAY_PEER_PORT_TX_RX_QUORUM": 209,
  167. "DELAY_PEER_PORT_TX_RX_ALL": 210,
  168. "RANDOM_DELAY_PEER_PORT_TX_RX_ALL": 211,
  169. "NO_FAIL_WITH_STRESS": 300,
  170. "NO_FAIL_WITH_NO_STRESS_FOR_LIVENESS": 301,
  171. "FAILPOINTS": 400,
  172. "EXTERNAL": 500,
  173. }
  174. func (x FailureCase) String() string {
  175. return proto.EnumName(FailureCase_name, int32(x))
  176. }
  177. func (FailureCase) EnumDescriptor() ([]byte, []int) { return fileDescriptorRpc, []int{1} }
  178. type StressType int32
  179. const (
  180. StressType_KV StressType = 0
  181. StressType_LEASE StressType = 1
  182. StressType_ELECTION_RUNNER StressType = 2
  183. StressType_WATCH_RUNNER StressType = 3
  184. StressType_LOCK_RACER_RUNNER StressType = 4
  185. StressType_LEASE_RUNNER StressType = 5
  186. )
  187. var StressType_name = map[int32]string{
  188. 0: "KV",
  189. 1: "LEASE",
  190. 2: "ELECTION_RUNNER",
  191. 3: "WATCH_RUNNER",
  192. 4: "LOCK_RACER_RUNNER",
  193. 5: "LEASE_RUNNER",
  194. }
  195. var StressType_value = map[string]int32{
  196. "KV": 0,
  197. "LEASE": 1,
  198. "ELECTION_RUNNER": 2,
  199. "WATCH_RUNNER": 3,
  200. "LOCK_RACER_RUNNER": 4,
  201. "LEASE_RUNNER": 5,
  202. }
  203. func (x StressType) String() string {
  204. return proto.EnumName(StressType_name, int32(x))
  205. }
  206. func (StressType) EnumDescriptor() ([]byte, []int) { return fileDescriptorRpc, []int{2} }
  207. type Etcd struct {
  208. Name string `protobuf:"bytes,1,opt,name=Name,proto3" json:"Name,omitempty" yaml:"name"`
  209. DataDir string `protobuf:"bytes,2,opt,name=DataDir,proto3" json:"DataDir,omitempty" yaml:"data-dir"`
  210. WALDir string `protobuf:"bytes,3,opt,name=WALDir,proto3" json:"WALDir,omitempty" yaml:"wal-dir"`
  211. // HeartbeatIntervalMs is the time (in milliseconds) of a heartbeat interval.
  212. // Default value is 100, which is 100ms.
  213. HeartbeatIntervalMs int64 `protobuf:"varint,11,opt,name=HeartbeatIntervalMs,proto3" json:"HeartbeatIntervalMs,omitempty" yaml:"heartbeat-interval"`
  214. // ElectionTimeoutMs is the time (in milliseconds) for an election to timeout.
  215. // Default value is 1000, which is 1s.
  216. ElectionTimeoutMs int64 `protobuf:"varint,12,opt,name=ElectionTimeoutMs,proto3" json:"ElectionTimeoutMs,omitempty" yaml:"election-timeout"`
  217. ListenClientURLs []string `protobuf:"bytes,21,rep,name=ListenClientURLs" json:"ListenClientURLs,omitempty" yaml:"listen-client-urls"`
  218. AdvertiseClientURLs []string `protobuf:"bytes,22,rep,name=AdvertiseClientURLs" json:"AdvertiseClientURLs,omitempty" yaml:"advertise-client-urls"`
  219. ClientAutoTLS bool `protobuf:"varint,23,opt,name=ClientAutoTLS,proto3" json:"ClientAutoTLS,omitempty" yaml:"auto-tls"`
  220. ClientCertAuth bool `protobuf:"varint,24,opt,name=ClientCertAuth,proto3" json:"ClientCertAuth,omitempty" yaml:"client-cert-auth"`
  221. ClientCertFile string `protobuf:"bytes,25,opt,name=ClientCertFile,proto3" json:"ClientCertFile,omitempty" yaml:"cert-file"`
  222. ClientKeyFile string `protobuf:"bytes,26,opt,name=ClientKeyFile,proto3" json:"ClientKeyFile,omitempty" yaml:"key-file"`
  223. ClientTrustedCAFile string `protobuf:"bytes,27,opt,name=ClientTrustedCAFile,proto3" json:"ClientTrustedCAFile,omitempty" yaml:"trusted-ca-file"`
  224. ListenPeerURLs []string `protobuf:"bytes,31,rep,name=ListenPeerURLs" json:"ListenPeerURLs,omitempty" yaml:"listen-peer-urls"`
  225. AdvertisePeerURLs []string `protobuf:"bytes,32,rep,name=AdvertisePeerURLs" json:"AdvertisePeerURLs,omitempty" yaml:"initial-advertise-peer-urls"`
  226. PeerAutoTLS bool `protobuf:"varint,33,opt,name=PeerAutoTLS,proto3" json:"PeerAutoTLS,omitempty" yaml:"peer-auto-tls"`
  227. PeerClientCertAuth bool `protobuf:"varint,34,opt,name=PeerClientCertAuth,proto3" json:"PeerClientCertAuth,omitempty" yaml:"peer-client-cert-auth"`
  228. PeerCertFile string `protobuf:"bytes,35,opt,name=PeerCertFile,proto3" json:"PeerCertFile,omitempty" yaml:"peer-cert-file"`
  229. PeerKeyFile string `protobuf:"bytes,36,opt,name=PeerKeyFile,proto3" json:"PeerKeyFile,omitempty" yaml:"peer-key-file"`
  230. PeerTrustedCAFile string `protobuf:"bytes,37,opt,name=PeerTrustedCAFile,proto3" json:"PeerTrustedCAFile,omitempty" yaml:"peer-trusted-ca-file"`
  231. InitialCluster string `protobuf:"bytes,41,opt,name=InitialCluster,proto3" json:"InitialCluster,omitempty" yaml:"initial-cluster"`
  232. InitialClusterState string `protobuf:"bytes,42,opt,name=InitialClusterState,proto3" json:"InitialClusterState,omitempty" yaml:"initial-cluster-state"`
  233. InitialClusterToken string `protobuf:"bytes,43,opt,name=InitialClusterToken,proto3" json:"InitialClusterToken,omitempty" yaml:"initial-cluster-token"`
  234. SnapshotCount int64 `protobuf:"varint,51,opt,name=SnapshotCount,proto3" json:"SnapshotCount,omitempty" yaml:"snapshot-count"`
  235. QuotaBackendBytes int64 `protobuf:"varint,52,opt,name=QuotaBackendBytes,proto3" json:"QuotaBackendBytes,omitempty" yaml:"quota-backend-bytes"`
  236. PreVote bool `protobuf:"varint,63,opt,name=PreVote,proto3" json:"PreVote,omitempty" yaml:"pre-vote"`
  237. InitialCorruptCheck bool `protobuf:"varint,64,opt,name=InitialCorruptCheck,proto3" json:"InitialCorruptCheck,omitempty" yaml:"initial-corrupt-check"`
  238. }
  239. func (m *Etcd) Reset() { *m = Etcd{} }
  240. func (m *Etcd) String() string { return proto.CompactTextString(m) }
  241. func (*Etcd) ProtoMessage() {}
  242. func (*Etcd) Descriptor() ([]byte, []int) { return fileDescriptorRpc, []int{0} }
  243. type Member struct {
  244. // EtcdExecPath is the executable etcd binary path in agent server.
  245. EtcdExecPath string `protobuf:"bytes,1,opt,name=EtcdExecPath,proto3" json:"EtcdExecPath,omitempty" yaml:"etcd-exec-path"`
  246. // AgentAddr is the agent HTTP server address.
  247. AgentAddr string `protobuf:"bytes,11,opt,name=AgentAddr,proto3" json:"AgentAddr,omitempty" yaml:"agent-addr"`
  248. // FailpointHTTPAddr is the agent's failpoints HTTP server address.
  249. FailpointHTTPAddr string `protobuf:"bytes,12,opt,name=FailpointHTTPAddr,proto3" json:"FailpointHTTPAddr,omitempty" yaml:"failpoint-http-addr"`
  250. // BaseDir is the base directory where all logs and etcd data are stored.
  251. BaseDir string `protobuf:"bytes,101,opt,name=BaseDir,proto3" json:"BaseDir,omitempty" yaml:"base-dir"`
  252. // EtcdLogPath is the log file to store current etcd server logs.
  253. EtcdLogPath string `protobuf:"bytes,102,opt,name=EtcdLogPath,proto3" json:"EtcdLogPath,omitempty" yaml:"etcd-log-path"`
  254. // EtcdClientProxy is true when client traffic needs to be proxied.
  255. // If true, listen client URL port must be different than advertise client URL port.
  256. EtcdClientProxy bool `protobuf:"varint,201,opt,name=EtcdClientProxy,proto3" json:"EtcdClientProxy,omitempty" yaml:"etcd-client-proxy"`
  257. // EtcdPeerProxy is true when peer traffic needs to be proxied.
  258. // If true, listen peer URL port must be different than advertise peer URL port.
  259. EtcdPeerProxy bool `protobuf:"varint,202,opt,name=EtcdPeerProxy,proto3" json:"EtcdPeerProxy,omitempty" yaml:"etcd-peer-proxy"`
  260. // EtcdClientEndpoint is the etcd client endpoint.
  261. EtcdClientEndpoint string `protobuf:"bytes,301,opt,name=EtcdClientEndpoint,proto3" json:"EtcdClientEndpoint,omitempty" yaml:"etcd-client-endpoint"`
  262. // Etcd defines etcd binary configuration flags.
  263. Etcd *Etcd `protobuf:"bytes,302,opt,name=Etcd" json:"Etcd,omitempty" yaml:"etcd"`
  264. // ClientCertData contains cert file contents from this member's etcd server.
  265. ClientCertData string `protobuf:"bytes,401,opt,name=ClientCertData,proto3" json:"ClientCertData,omitempty" yaml:"client-cert-data"`
  266. ClientCertPath string `protobuf:"bytes,402,opt,name=ClientCertPath,proto3" json:"ClientCertPath,omitempty" yaml:"client-cert-path"`
  267. // ClientKeyData contains key file contents from this member's etcd server.
  268. ClientKeyData string `protobuf:"bytes,403,opt,name=ClientKeyData,proto3" json:"ClientKeyData,omitempty" yaml:"client-key-data"`
  269. ClientKeyPath string `protobuf:"bytes,404,opt,name=ClientKeyPath,proto3" json:"ClientKeyPath,omitempty" yaml:"client-key-path"`
  270. // ClientTrustedCAData contains trusted CA file contents from this member's etcd server.
  271. ClientTrustedCAData string `protobuf:"bytes,405,opt,name=ClientTrustedCAData,proto3" json:"ClientTrustedCAData,omitempty" yaml:"client-trusted-ca-data"`
  272. ClientTrustedCAPath string `protobuf:"bytes,406,opt,name=ClientTrustedCAPath,proto3" json:"ClientTrustedCAPath,omitempty" yaml:"client-trusted-ca-path"`
  273. // PeerCertData contains cert file contents from this member's etcd server.
  274. PeerCertData string `protobuf:"bytes,501,opt,name=PeerCertData,proto3" json:"PeerCertData,omitempty" yaml:"peer-cert-data"`
  275. PeerCertPath string `protobuf:"bytes,502,opt,name=PeerCertPath,proto3" json:"PeerCertPath,omitempty" yaml:"peer-cert-path"`
  276. // PeerKeyData contains key file contents from this member's etcd server.
  277. PeerKeyData string `protobuf:"bytes,503,opt,name=PeerKeyData,proto3" json:"PeerKeyData,omitempty" yaml:"peer-key-data"`
  278. PeerKeyPath string `protobuf:"bytes,504,opt,name=PeerKeyPath,proto3" json:"PeerKeyPath,omitempty" yaml:"peer-key-path"`
  279. // PeerTrustedCAData contains trusted CA file contents from this member's etcd server.
  280. PeerTrustedCAData string `protobuf:"bytes,505,opt,name=PeerTrustedCAData,proto3" json:"PeerTrustedCAData,omitempty" yaml:"peer-trusted-ca-data"`
  281. PeerTrustedCAPath string `protobuf:"bytes,506,opt,name=PeerTrustedCAPath,proto3" json:"PeerTrustedCAPath,omitempty" yaml:"peer-trusted-ca-path"`
  282. }
  283. func (m *Member) Reset() { *m = Member{} }
  284. func (m *Member) String() string { return proto.CompactTextString(m) }
  285. func (*Member) ProtoMessage() {}
  286. func (*Member) Descriptor() ([]byte, []int) { return fileDescriptorRpc, []int{1} }
  287. type Tester struct {
  288. TesterDataDir string `protobuf:"bytes,1,opt,name=TesterDataDir,proto3" json:"TesterDataDir,omitempty" yaml:"tester-data-dir"`
  289. TesterNetwork string `protobuf:"bytes,2,opt,name=TesterNetwork,proto3" json:"TesterNetwork,omitempty" yaml:"tester-network"`
  290. TesterAddr string `protobuf:"bytes,3,opt,name=TesterAddr,proto3" json:"TesterAddr,omitempty" yaml:"tester-addr"`
  291. // DelayLatencyMsRv is the delay latency in milliseconds,
  292. // to inject to simulated slow network.
  293. DelayLatencyMs uint32 `protobuf:"varint,11,opt,name=DelayLatencyMs,proto3" json:"DelayLatencyMs,omitempty" yaml:"delay-latency-ms"`
  294. // DelayLatencyMsRv is the delay latency random variable in milliseconds.
  295. DelayLatencyMsRv uint32 `protobuf:"varint,12,opt,name=DelayLatencyMsRv,proto3" json:"DelayLatencyMsRv,omitempty" yaml:"delay-latency-ms-rv"`
  296. // UpdatedDelayLatencyMs is the update delay latency in milliseconds,
  297. // to inject to simulated slow network. It's the final latency to apply,
  298. // in case the latency numbers are randomly generated from given delay latency field.
  299. UpdatedDelayLatencyMs uint32 `protobuf:"varint,13,opt,name=UpdatedDelayLatencyMs,proto3" json:"UpdatedDelayLatencyMs,omitempty" yaml:"updated-delay-latency-ms"`
  300. // RoundLimit is the limit of rounds to run failure set (-1 to run without limits).
  301. RoundLimit int32 `protobuf:"varint,21,opt,name=RoundLimit,proto3" json:"RoundLimit,omitempty" yaml:"round-limit"`
  302. // ExitOnFailure is true, then exit tester on first failure.
  303. ExitOnFailure bool `protobuf:"varint,22,opt,name=ExitOnFailure,proto3" json:"ExitOnFailure,omitempty" yaml:"exit-on-failure"`
  304. // ConsistencyCheck is true to check consistency (revision, hash).
  305. ConsistencyCheck bool `protobuf:"varint,23,opt,name=ConsistencyCheck,proto3" json:"ConsistencyCheck,omitempty" yaml:"consistency-check"`
  306. // EnablePprof is true to enable profiler.
  307. EnablePprof bool `protobuf:"varint,24,opt,name=EnablePprof,proto3" json:"EnablePprof,omitempty" yaml:"enable-pprof"`
  308. // FailureCases is the selected test cases to schedule.
  309. // If empty, run all failure cases.
  310. FailureCases []string `protobuf:"bytes,31,rep,name=FailureCases" json:"FailureCases,omitempty" yaml:"failure-cases"`
  311. // FailureDelayMs is the delay duration after failure is injected.
  312. // Useful when triggering snapshot or no-op failure cases.
  313. FailureDelayMs uint32 `protobuf:"varint,32,opt,name=FailureDelayMs,proto3" json:"FailureDelayMs,omitempty" yaml:"failure-delay-ms"`
  314. // FailureShuffle is true to randomize failure injecting order.
  315. FailureShuffle bool `protobuf:"varint,33,opt,name=FailureShuffle,proto3" json:"FailureShuffle,omitempty" yaml:"failure-shuffle"`
  316. // FailpointCommands is the list of "gofail" commands (e.g. panic("etcd-tester"),1*sleep(1000)).
  317. FailpointCommands []string `protobuf:"bytes,34,rep,name=FailpointCommands" json:"FailpointCommands,omitempty" yaml:"failpoint-commands"`
  318. // RunnerExecPath is a path of etcd-runner binary.
  319. RunnerExecPath string `protobuf:"bytes,41,opt,name=RunnerExecPath,proto3" json:"RunnerExecPath,omitempty" yaml:"runner-exec-path"`
  320. // ExternalExecPath is a path of script for enabling/disabling an external fault injector.
  321. ExternalExecPath string `protobuf:"bytes,42,opt,name=ExternalExecPath,proto3" json:"ExternalExecPath,omitempty" yaml:"external-exec-path"`
  322. // StressTypes is the list of stresser names:
  323. // keys, lease, nop, election-runner, watch-runner, lock-racer-runner, lease-runner.
  324. StressTypes []string `protobuf:"bytes,101,rep,name=StressTypes" json:"StressTypes,omitempty" yaml:"stress-types"`
  325. // StressKeySize is the size of each small key written into etcd.
  326. StressKeySize int32 `protobuf:"varint,102,opt,name=StressKeySize,proto3" json:"StressKeySize,omitempty" yaml:"stress-key-size"`
  327. // StressKeySizeLarge is the size of each large key written into etcd.
  328. StressKeySizeLarge int32 `protobuf:"varint,103,opt,name=StressKeySizeLarge,proto3" json:"StressKeySizeLarge,omitempty" yaml:"stress-key-size-large"`
  329. // StressKeySuffixRange is the count of key range written into etcd.
  330. // Stress keys are created with "fmt.Sprintf("foo%016x", rand.Intn(keySuffixRange)".
  331. StressKeySuffixRange int32 `protobuf:"varint,104,opt,name=StressKeySuffixRange,proto3" json:"StressKeySuffixRange,omitempty" yaml:"stress-key-suffix-range"`
  332. // StressKeySuffixRangeTxn is the count of key range written into etcd txn (max 100).
  333. // Stress keys are created with "fmt.Sprintf("/k%03d", i)".
  334. StressKeySuffixRangeTxn int32 `protobuf:"varint,105,opt,name=StressKeySuffixRangeTxn,proto3" json:"StressKeySuffixRangeTxn,omitempty" yaml:"stress-key-suffix-range-txn"`
  335. // StressKeyTxnOps is the number of operations per a transaction (max 64).
  336. StressKeyTxnOps int32 `protobuf:"varint,106,opt,name=StressKeyTxnOps,proto3" json:"StressKeyTxnOps,omitempty" yaml:"stress-key-txn-ops"`
  337. // StressClients is the number of concurrent stressing clients
  338. // with "one" shared TCP connection.
  339. StressClients int32 `protobuf:"varint,201,opt,name=StressClients,proto3" json:"StressClients,omitempty" yaml:"stress-clients"`
  340. // StressQPS is the maximum number of stresser requests per second.
  341. StressQPS int32 `protobuf:"varint,202,opt,name=StressQPS,proto3" json:"StressQPS,omitempty" yaml:"stress-qps"`
  342. }
  343. func (m *Tester) Reset() { *m = Tester{} }
  344. func (m *Tester) String() string { return proto.CompactTextString(m) }
  345. func (*Tester) ProtoMessage() {}
  346. func (*Tester) Descriptor() ([]byte, []int) { return fileDescriptorRpc, []int{2} }
  347. type Request struct {
  348. Operation Operation `protobuf:"varint,1,opt,name=Operation,proto3,enum=rpcpb.Operation" json:"Operation,omitempty"`
  349. // Member contains the same Member object from tester configuration.
  350. Member *Member `protobuf:"bytes,2,opt,name=Member" json:"Member,omitempty"`
  351. // Tester contains tester configuration.
  352. Tester *Tester `protobuf:"bytes,3,opt,name=Tester" json:"Tester,omitempty"`
  353. }
  354. func (m *Request) Reset() { *m = Request{} }
  355. func (m *Request) String() string { return proto.CompactTextString(m) }
  356. func (*Request) ProtoMessage() {}
  357. func (*Request) Descriptor() ([]byte, []int) { return fileDescriptorRpc, []int{3} }
  358. type Response struct {
  359. Success bool `protobuf:"varint,1,opt,name=Success,proto3" json:"Success,omitempty"`
  360. Status string `protobuf:"bytes,2,opt,name=Status,proto3" json:"Status,omitempty"`
  361. // Member contains the same Member object from tester request.
  362. Member *Member `protobuf:"bytes,3,opt,name=Member" json:"Member,omitempty"`
  363. }
  364. func (m *Response) Reset() { *m = Response{} }
  365. func (m *Response) String() string { return proto.CompactTextString(m) }
  366. func (*Response) ProtoMessage() {}
  367. func (*Response) Descriptor() ([]byte, []int) { return fileDescriptorRpc, []int{4} }
  368. func init() {
  369. proto.RegisterType((*Etcd)(nil), "rpcpb.Etcd")
  370. proto.RegisterType((*Member)(nil), "rpcpb.Member")
  371. proto.RegisterType((*Tester)(nil), "rpcpb.Tester")
  372. proto.RegisterType((*Request)(nil), "rpcpb.Request")
  373. proto.RegisterType((*Response)(nil), "rpcpb.Response")
  374. proto.RegisterEnum("rpcpb.Operation", Operation_name, Operation_value)
  375. proto.RegisterEnum("rpcpb.FailureCase", FailureCase_name, FailureCase_value)
  376. proto.RegisterEnum("rpcpb.StressType", StressType_name, StressType_value)
  377. }
  378. // Reference imports to suppress errors if they are not otherwise used.
  379. var _ context.Context
  380. var _ grpc.ClientConn
  381. // This is a compile-time assertion to ensure that this generated file
  382. // is compatible with the grpc package it is being compiled against.
  383. const _ = grpc.SupportPackageIsVersion4
  384. // Client API for Transport service
  385. type TransportClient interface {
  386. Transport(ctx context.Context, opts ...grpc.CallOption) (Transport_TransportClient, error)
  387. }
  388. type transportClient struct {
  389. cc *grpc.ClientConn
  390. }
  391. func NewTransportClient(cc *grpc.ClientConn) TransportClient {
  392. return &transportClient{cc}
  393. }
  394. func (c *transportClient) Transport(ctx context.Context, opts ...grpc.CallOption) (Transport_TransportClient, error) {
  395. stream, err := grpc.NewClientStream(ctx, &_Transport_serviceDesc.Streams[0], c.cc, "/rpcpb.Transport/Transport", opts...)
  396. if err != nil {
  397. return nil, err
  398. }
  399. x := &transportTransportClient{stream}
  400. return x, nil
  401. }
  402. type Transport_TransportClient interface {
  403. Send(*Request) error
  404. Recv() (*Response, error)
  405. grpc.ClientStream
  406. }
  407. type transportTransportClient struct {
  408. grpc.ClientStream
  409. }
  410. func (x *transportTransportClient) Send(m *Request) error {
  411. return x.ClientStream.SendMsg(m)
  412. }
  413. func (x *transportTransportClient) Recv() (*Response, error) {
  414. m := new(Response)
  415. if err := x.ClientStream.RecvMsg(m); err != nil {
  416. return nil, err
  417. }
  418. return m, nil
  419. }
  420. // Server API for Transport service
  421. type TransportServer interface {
  422. Transport(Transport_TransportServer) error
  423. }
  424. func RegisterTransportServer(s *grpc.Server, srv TransportServer) {
  425. s.RegisterService(&_Transport_serviceDesc, srv)
  426. }
  427. func _Transport_Transport_Handler(srv interface{}, stream grpc.ServerStream) error {
  428. return srv.(TransportServer).Transport(&transportTransportServer{stream})
  429. }
  430. type Transport_TransportServer interface {
  431. Send(*Response) error
  432. Recv() (*Request, error)
  433. grpc.ServerStream
  434. }
  435. type transportTransportServer struct {
  436. grpc.ServerStream
  437. }
  438. func (x *transportTransportServer) Send(m *Response) error {
  439. return x.ServerStream.SendMsg(m)
  440. }
  441. func (x *transportTransportServer) Recv() (*Request, error) {
  442. m := new(Request)
  443. if err := x.ServerStream.RecvMsg(m); err != nil {
  444. return nil, err
  445. }
  446. return m, nil
  447. }
  448. var _Transport_serviceDesc = grpc.ServiceDesc{
  449. ServiceName: "rpcpb.Transport",
  450. HandlerType: (*TransportServer)(nil),
  451. Methods: []grpc.MethodDesc{},
  452. Streams: []grpc.StreamDesc{
  453. {
  454. StreamName: "Transport",
  455. Handler: _Transport_Transport_Handler,
  456. ServerStreams: true,
  457. ClientStreams: true,
  458. },
  459. },
  460. Metadata: "rpcpb/rpc.proto",
  461. }
  462. func (m *Etcd) Marshal() (dAtA []byte, err error) {
  463. size := m.Size()
  464. dAtA = make([]byte, size)
  465. n, err := m.MarshalTo(dAtA)
  466. if err != nil {
  467. return nil, err
  468. }
  469. return dAtA[:n], nil
  470. }
  471. func (m *Etcd) MarshalTo(dAtA []byte) (int, error) {
  472. var i int
  473. _ = i
  474. var l int
  475. _ = l
  476. if len(m.Name) > 0 {
  477. dAtA[i] = 0xa
  478. i++
  479. i = encodeVarintRpc(dAtA, i, uint64(len(m.Name)))
  480. i += copy(dAtA[i:], m.Name)
  481. }
  482. if len(m.DataDir) > 0 {
  483. dAtA[i] = 0x12
  484. i++
  485. i = encodeVarintRpc(dAtA, i, uint64(len(m.DataDir)))
  486. i += copy(dAtA[i:], m.DataDir)
  487. }
  488. if len(m.WALDir) > 0 {
  489. dAtA[i] = 0x1a
  490. i++
  491. i = encodeVarintRpc(dAtA, i, uint64(len(m.WALDir)))
  492. i += copy(dAtA[i:], m.WALDir)
  493. }
  494. if m.HeartbeatIntervalMs != 0 {
  495. dAtA[i] = 0x58
  496. i++
  497. i = encodeVarintRpc(dAtA, i, uint64(m.HeartbeatIntervalMs))
  498. }
  499. if m.ElectionTimeoutMs != 0 {
  500. dAtA[i] = 0x60
  501. i++
  502. i = encodeVarintRpc(dAtA, i, uint64(m.ElectionTimeoutMs))
  503. }
  504. if len(m.ListenClientURLs) > 0 {
  505. for _, s := range m.ListenClientURLs {
  506. dAtA[i] = 0xaa
  507. i++
  508. dAtA[i] = 0x1
  509. i++
  510. l = len(s)
  511. for l >= 1<<7 {
  512. dAtA[i] = uint8(uint64(l)&0x7f | 0x80)
  513. l >>= 7
  514. i++
  515. }
  516. dAtA[i] = uint8(l)
  517. i++
  518. i += copy(dAtA[i:], s)
  519. }
  520. }
  521. if len(m.AdvertiseClientURLs) > 0 {
  522. for _, s := range m.AdvertiseClientURLs {
  523. dAtA[i] = 0xb2
  524. i++
  525. dAtA[i] = 0x1
  526. i++
  527. l = len(s)
  528. for l >= 1<<7 {
  529. dAtA[i] = uint8(uint64(l)&0x7f | 0x80)
  530. l >>= 7
  531. i++
  532. }
  533. dAtA[i] = uint8(l)
  534. i++
  535. i += copy(dAtA[i:], s)
  536. }
  537. }
  538. if m.ClientAutoTLS {
  539. dAtA[i] = 0xb8
  540. i++
  541. dAtA[i] = 0x1
  542. i++
  543. if m.ClientAutoTLS {
  544. dAtA[i] = 1
  545. } else {
  546. dAtA[i] = 0
  547. }
  548. i++
  549. }
  550. if m.ClientCertAuth {
  551. dAtA[i] = 0xc0
  552. i++
  553. dAtA[i] = 0x1
  554. i++
  555. if m.ClientCertAuth {
  556. dAtA[i] = 1
  557. } else {
  558. dAtA[i] = 0
  559. }
  560. i++
  561. }
  562. if len(m.ClientCertFile) > 0 {
  563. dAtA[i] = 0xca
  564. i++
  565. dAtA[i] = 0x1
  566. i++
  567. i = encodeVarintRpc(dAtA, i, uint64(len(m.ClientCertFile)))
  568. i += copy(dAtA[i:], m.ClientCertFile)
  569. }
  570. if len(m.ClientKeyFile) > 0 {
  571. dAtA[i] = 0xd2
  572. i++
  573. dAtA[i] = 0x1
  574. i++
  575. i = encodeVarintRpc(dAtA, i, uint64(len(m.ClientKeyFile)))
  576. i += copy(dAtA[i:], m.ClientKeyFile)
  577. }
  578. if len(m.ClientTrustedCAFile) > 0 {
  579. dAtA[i] = 0xda
  580. i++
  581. dAtA[i] = 0x1
  582. i++
  583. i = encodeVarintRpc(dAtA, i, uint64(len(m.ClientTrustedCAFile)))
  584. i += copy(dAtA[i:], m.ClientTrustedCAFile)
  585. }
  586. if len(m.ListenPeerURLs) > 0 {
  587. for _, s := range m.ListenPeerURLs {
  588. dAtA[i] = 0xfa
  589. i++
  590. dAtA[i] = 0x1
  591. i++
  592. l = len(s)
  593. for l >= 1<<7 {
  594. dAtA[i] = uint8(uint64(l)&0x7f | 0x80)
  595. l >>= 7
  596. i++
  597. }
  598. dAtA[i] = uint8(l)
  599. i++
  600. i += copy(dAtA[i:], s)
  601. }
  602. }
  603. if len(m.AdvertisePeerURLs) > 0 {
  604. for _, s := range m.AdvertisePeerURLs {
  605. dAtA[i] = 0x82
  606. i++
  607. dAtA[i] = 0x2
  608. i++
  609. l = len(s)
  610. for l >= 1<<7 {
  611. dAtA[i] = uint8(uint64(l)&0x7f | 0x80)
  612. l >>= 7
  613. i++
  614. }
  615. dAtA[i] = uint8(l)
  616. i++
  617. i += copy(dAtA[i:], s)
  618. }
  619. }
  620. if m.PeerAutoTLS {
  621. dAtA[i] = 0x88
  622. i++
  623. dAtA[i] = 0x2
  624. i++
  625. if m.PeerAutoTLS {
  626. dAtA[i] = 1
  627. } else {
  628. dAtA[i] = 0
  629. }
  630. i++
  631. }
  632. if m.PeerClientCertAuth {
  633. dAtA[i] = 0x90
  634. i++
  635. dAtA[i] = 0x2
  636. i++
  637. if m.PeerClientCertAuth {
  638. dAtA[i] = 1
  639. } else {
  640. dAtA[i] = 0
  641. }
  642. i++
  643. }
  644. if len(m.PeerCertFile) > 0 {
  645. dAtA[i] = 0x9a
  646. i++
  647. dAtA[i] = 0x2
  648. i++
  649. i = encodeVarintRpc(dAtA, i, uint64(len(m.PeerCertFile)))
  650. i += copy(dAtA[i:], m.PeerCertFile)
  651. }
  652. if len(m.PeerKeyFile) > 0 {
  653. dAtA[i] = 0xa2
  654. i++
  655. dAtA[i] = 0x2
  656. i++
  657. i = encodeVarintRpc(dAtA, i, uint64(len(m.PeerKeyFile)))
  658. i += copy(dAtA[i:], m.PeerKeyFile)
  659. }
  660. if len(m.PeerTrustedCAFile) > 0 {
  661. dAtA[i] = 0xaa
  662. i++
  663. dAtA[i] = 0x2
  664. i++
  665. i = encodeVarintRpc(dAtA, i, uint64(len(m.PeerTrustedCAFile)))
  666. i += copy(dAtA[i:], m.PeerTrustedCAFile)
  667. }
  668. if len(m.InitialCluster) > 0 {
  669. dAtA[i] = 0xca
  670. i++
  671. dAtA[i] = 0x2
  672. i++
  673. i = encodeVarintRpc(dAtA, i, uint64(len(m.InitialCluster)))
  674. i += copy(dAtA[i:], m.InitialCluster)
  675. }
  676. if len(m.InitialClusterState) > 0 {
  677. dAtA[i] = 0xd2
  678. i++
  679. dAtA[i] = 0x2
  680. i++
  681. i = encodeVarintRpc(dAtA, i, uint64(len(m.InitialClusterState)))
  682. i += copy(dAtA[i:], m.InitialClusterState)
  683. }
  684. if len(m.InitialClusterToken) > 0 {
  685. dAtA[i] = 0xda
  686. i++
  687. dAtA[i] = 0x2
  688. i++
  689. i = encodeVarintRpc(dAtA, i, uint64(len(m.InitialClusterToken)))
  690. i += copy(dAtA[i:], m.InitialClusterToken)
  691. }
  692. if m.SnapshotCount != 0 {
  693. dAtA[i] = 0x98
  694. i++
  695. dAtA[i] = 0x3
  696. i++
  697. i = encodeVarintRpc(dAtA, i, uint64(m.SnapshotCount))
  698. }
  699. if m.QuotaBackendBytes != 0 {
  700. dAtA[i] = 0xa0
  701. i++
  702. dAtA[i] = 0x3
  703. i++
  704. i = encodeVarintRpc(dAtA, i, uint64(m.QuotaBackendBytes))
  705. }
  706. if m.PreVote {
  707. dAtA[i] = 0xf8
  708. i++
  709. dAtA[i] = 0x3
  710. i++
  711. if m.PreVote {
  712. dAtA[i] = 1
  713. } else {
  714. dAtA[i] = 0
  715. }
  716. i++
  717. }
  718. if m.InitialCorruptCheck {
  719. dAtA[i] = 0x80
  720. i++
  721. dAtA[i] = 0x4
  722. i++
  723. if m.InitialCorruptCheck {
  724. dAtA[i] = 1
  725. } else {
  726. dAtA[i] = 0
  727. }
  728. i++
  729. }
  730. return i, nil
  731. }
  732. func (m *Member) Marshal() (dAtA []byte, err error) {
  733. size := m.Size()
  734. dAtA = make([]byte, size)
  735. n, err := m.MarshalTo(dAtA)
  736. if err != nil {
  737. return nil, err
  738. }
  739. return dAtA[:n], nil
  740. }
  741. func (m *Member) MarshalTo(dAtA []byte) (int, error) {
  742. var i int
  743. _ = i
  744. var l int
  745. _ = l
  746. if len(m.EtcdExecPath) > 0 {
  747. dAtA[i] = 0xa
  748. i++
  749. i = encodeVarintRpc(dAtA, i, uint64(len(m.EtcdExecPath)))
  750. i += copy(dAtA[i:], m.EtcdExecPath)
  751. }
  752. if len(m.AgentAddr) > 0 {
  753. dAtA[i] = 0x5a
  754. i++
  755. i = encodeVarintRpc(dAtA, i, uint64(len(m.AgentAddr)))
  756. i += copy(dAtA[i:], m.AgentAddr)
  757. }
  758. if len(m.FailpointHTTPAddr) > 0 {
  759. dAtA[i] = 0x62
  760. i++
  761. i = encodeVarintRpc(dAtA, i, uint64(len(m.FailpointHTTPAddr)))
  762. i += copy(dAtA[i:], m.FailpointHTTPAddr)
  763. }
  764. if len(m.BaseDir) > 0 {
  765. dAtA[i] = 0xaa
  766. i++
  767. dAtA[i] = 0x6
  768. i++
  769. i = encodeVarintRpc(dAtA, i, uint64(len(m.BaseDir)))
  770. i += copy(dAtA[i:], m.BaseDir)
  771. }
  772. if len(m.EtcdLogPath) > 0 {
  773. dAtA[i] = 0xb2
  774. i++
  775. dAtA[i] = 0x6
  776. i++
  777. i = encodeVarintRpc(dAtA, i, uint64(len(m.EtcdLogPath)))
  778. i += copy(dAtA[i:], m.EtcdLogPath)
  779. }
  780. if m.EtcdClientProxy {
  781. dAtA[i] = 0xc8
  782. i++
  783. dAtA[i] = 0xc
  784. i++
  785. if m.EtcdClientProxy {
  786. dAtA[i] = 1
  787. } else {
  788. dAtA[i] = 0
  789. }
  790. i++
  791. }
  792. if m.EtcdPeerProxy {
  793. dAtA[i] = 0xd0
  794. i++
  795. dAtA[i] = 0xc
  796. i++
  797. if m.EtcdPeerProxy {
  798. dAtA[i] = 1
  799. } else {
  800. dAtA[i] = 0
  801. }
  802. i++
  803. }
  804. if len(m.EtcdClientEndpoint) > 0 {
  805. dAtA[i] = 0xea
  806. i++
  807. dAtA[i] = 0x12
  808. i++
  809. i = encodeVarintRpc(dAtA, i, uint64(len(m.EtcdClientEndpoint)))
  810. i += copy(dAtA[i:], m.EtcdClientEndpoint)
  811. }
  812. if m.Etcd != nil {
  813. dAtA[i] = 0xf2
  814. i++
  815. dAtA[i] = 0x12
  816. i++
  817. i = encodeVarintRpc(dAtA, i, uint64(m.Etcd.Size()))
  818. n1, err := m.Etcd.MarshalTo(dAtA[i:])
  819. if err != nil {
  820. return 0, err
  821. }
  822. i += n1
  823. }
  824. if len(m.ClientCertData) > 0 {
  825. dAtA[i] = 0x8a
  826. i++
  827. dAtA[i] = 0x19
  828. i++
  829. i = encodeVarintRpc(dAtA, i, uint64(len(m.ClientCertData)))
  830. i += copy(dAtA[i:], m.ClientCertData)
  831. }
  832. if len(m.ClientCertPath) > 0 {
  833. dAtA[i] = 0x92
  834. i++
  835. dAtA[i] = 0x19
  836. i++
  837. i = encodeVarintRpc(dAtA, i, uint64(len(m.ClientCertPath)))
  838. i += copy(dAtA[i:], m.ClientCertPath)
  839. }
  840. if len(m.ClientKeyData) > 0 {
  841. dAtA[i] = 0x9a
  842. i++
  843. dAtA[i] = 0x19
  844. i++
  845. i = encodeVarintRpc(dAtA, i, uint64(len(m.ClientKeyData)))
  846. i += copy(dAtA[i:], m.ClientKeyData)
  847. }
  848. if len(m.ClientKeyPath) > 0 {
  849. dAtA[i] = 0xa2
  850. i++
  851. dAtA[i] = 0x19
  852. i++
  853. i = encodeVarintRpc(dAtA, i, uint64(len(m.ClientKeyPath)))
  854. i += copy(dAtA[i:], m.ClientKeyPath)
  855. }
  856. if len(m.ClientTrustedCAData) > 0 {
  857. dAtA[i] = 0xaa
  858. i++
  859. dAtA[i] = 0x19
  860. i++
  861. i = encodeVarintRpc(dAtA, i, uint64(len(m.ClientTrustedCAData)))
  862. i += copy(dAtA[i:], m.ClientTrustedCAData)
  863. }
  864. if len(m.ClientTrustedCAPath) > 0 {
  865. dAtA[i] = 0xb2
  866. i++
  867. dAtA[i] = 0x19
  868. i++
  869. i = encodeVarintRpc(dAtA, i, uint64(len(m.ClientTrustedCAPath)))
  870. i += copy(dAtA[i:], m.ClientTrustedCAPath)
  871. }
  872. if len(m.PeerCertData) > 0 {
  873. dAtA[i] = 0xaa
  874. i++
  875. dAtA[i] = 0x1f
  876. i++
  877. i = encodeVarintRpc(dAtA, i, uint64(len(m.PeerCertData)))
  878. i += copy(dAtA[i:], m.PeerCertData)
  879. }
  880. if len(m.PeerCertPath) > 0 {
  881. dAtA[i] = 0xb2
  882. i++
  883. dAtA[i] = 0x1f
  884. i++
  885. i = encodeVarintRpc(dAtA, i, uint64(len(m.PeerCertPath)))
  886. i += copy(dAtA[i:], m.PeerCertPath)
  887. }
  888. if len(m.PeerKeyData) > 0 {
  889. dAtA[i] = 0xba
  890. i++
  891. dAtA[i] = 0x1f
  892. i++
  893. i = encodeVarintRpc(dAtA, i, uint64(len(m.PeerKeyData)))
  894. i += copy(dAtA[i:], m.PeerKeyData)
  895. }
  896. if len(m.PeerKeyPath) > 0 {
  897. dAtA[i] = 0xc2
  898. i++
  899. dAtA[i] = 0x1f
  900. i++
  901. i = encodeVarintRpc(dAtA, i, uint64(len(m.PeerKeyPath)))
  902. i += copy(dAtA[i:], m.PeerKeyPath)
  903. }
  904. if len(m.PeerTrustedCAData) > 0 {
  905. dAtA[i] = 0xca
  906. i++
  907. dAtA[i] = 0x1f
  908. i++
  909. i = encodeVarintRpc(dAtA, i, uint64(len(m.PeerTrustedCAData)))
  910. i += copy(dAtA[i:], m.PeerTrustedCAData)
  911. }
  912. if len(m.PeerTrustedCAPath) > 0 {
  913. dAtA[i] = 0xd2
  914. i++
  915. dAtA[i] = 0x1f
  916. i++
  917. i = encodeVarintRpc(dAtA, i, uint64(len(m.PeerTrustedCAPath)))
  918. i += copy(dAtA[i:], m.PeerTrustedCAPath)
  919. }
  920. return i, nil
  921. }
  922. func (m *Tester) Marshal() (dAtA []byte, err error) {
  923. size := m.Size()
  924. dAtA = make([]byte, size)
  925. n, err := m.MarshalTo(dAtA)
  926. if err != nil {
  927. return nil, err
  928. }
  929. return dAtA[:n], nil
  930. }
  931. func (m *Tester) MarshalTo(dAtA []byte) (int, error) {
  932. var i int
  933. _ = i
  934. var l int
  935. _ = l
  936. if len(m.TesterDataDir) > 0 {
  937. dAtA[i] = 0xa
  938. i++
  939. i = encodeVarintRpc(dAtA, i, uint64(len(m.TesterDataDir)))
  940. i += copy(dAtA[i:], m.TesterDataDir)
  941. }
  942. if len(m.TesterNetwork) > 0 {
  943. dAtA[i] = 0x12
  944. i++
  945. i = encodeVarintRpc(dAtA, i, uint64(len(m.TesterNetwork)))
  946. i += copy(dAtA[i:], m.TesterNetwork)
  947. }
  948. if len(m.TesterAddr) > 0 {
  949. dAtA[i] = 0x1a
  950. i++
  951. i = encodeVarintRpc(dAtA, i, uint64(len(m.TesterAddr)))
  952. i += copy(dAtA[i:], m.TesterAddr)
  953. }
  954. if m.DelayLatencyMs != 0 {
  955. dAtA[i] = 0x58
  956. i++
  957. i = encodeVarintRpc(dAtA, i, uint64(m.DelayLatencyMs))
  958. }
  959. if m.DelayLatencyMsRv != 0 {
  960. dAtA[i] = 0x60
  961. i++
  962. i = encodeVarintRpc(dAtA, i, uint64(m.DelayLatencyMsRv))
  963. }
  964. if m.UpdatedDelayLatencyMs != 0 {
  965. dAtA[i] = 0x68
  966. i++
  967. i = encodeVarintRpc(dAtA, i, uint64(m.UpdatedDelayLatencyMs))
  968. }
  969. if m.RoundLimit != 0 {
  970. dAtA[i] = 0xa8
  971. i++
  972. dAtA[i] = 0x1
  973. i++
  974. i = encodeVarintRpc(dAtA, i, uint64(m.RoundLimit))
  975. }
  976. if m.ExitOnFailure {
  977. dAtA[i] = 0xb0
  978. i++
  979. dAtA[i] = 0x1
  980. i++
  981. if m.ExitOnFailure {
  982. dAtA[i] = 1
  983. } else {
  984. dAtA[i] = 0
  985. }
  986. i++
  987. }
  988. if m.ConsistencyCheck {
  989. dAtA[i] = 0xb8
  990. i++
  991. dAtA[i] = 0x1
  992. i++
  993. if m.ConsistencyCheck {
  994. dAtA[i] = 1
  995. } else {
  996. dAtA[i] = 0
  997. }
  998. i++
  999. }
  1000. if m.EnablePprof {
  1001. dAtA[i] = 0xc0
  1002. i++
  1003. dAtA[i] = 0x1
  1004. i++
  1005. if m.EnablePprof {
  1006. dAtA[i] = 1
  1007. } else {
  1008. dAtA[i] = 0
  1009. }
  1010. i++
  1011. }
  1012. if len(m.FailureCases) > 0 {
  1013. for _, s := range m.FailureCases {
  1014. dAtA[i] = 0xfa
  1015. i++
  1016. dAtA[i] = 0x1
  1017. i++
  1018. l = len(s)
  1019. for l >= 1<<7 {
  1020. dAtA[i] = uint8(uint64(l)&0x7f | 0x80)
  1021. l >>= 7
  1022. i++
  1023. }
  1024. dAtA[i] = uint8(l)
  1025. i++
  1026. i += copy(dAtA[i:], s)
  1027. }
  1028. }
  1029. if m.FailureDelayMs != 0 {
  1030. dAtA[i] = 0x80
  1031. i++
  1032. dAtA[i] = 0x2
  1033. i++
  1034. i = encodeVarintRpc(dAtA, i, uint64(m.FailureDelayMs))
  1035. }
  1036. if m.FailureShuffle {
  1037. dAtA[i] = 0x88
  1038. i++
  1039. dAtA[i] = 0x2
  1040. i++
  1041. if m.FailureShuffle {
  1042. dAtA[i] = 1
  1043. } else {
  1044. dAtA[i] = 0
  1045. }
  1046. i++
  1047. }
  1048. if len(m.FailpointCommands) > 0 {
  1049. for _, s := range m.FailpointCommands {
  1050. dAtA[i] = 0x92
  1051. i++
  1052. dAtA[i] = 0x2
  1053. i++
  1054. l = len(s)
  1055. for l >= 1<<7 {
  1056. dAtA[i] = uint8(uint64(l)&0x7f | 0x80)
  1057. l >>= 7
  1058. i++
  1059. }
  1060. dAtA[i] = uint8(l)
  1061. i++
  1062. i += copy(dAtA[i:], s)
  1063. }
  1064. }
  1065. if len(m.RunnerExecPath) > 0 {
  1066. dAtA[i] = 0xca
  1067. i++
  1068. dAtA[i] = 0x2
  1069. i++
  1070. i = encodeVarintRpc(dAtA, i, uint64(len(m.RunnerExecPath)))
  1071. i += copy(dAtA[i:], m.RunnerExecPath)
  1072. }
  1073. if len(m.ExternalExecPath) > 0 {
  1074. dAtA[i] = 0xd2
  1075. i++
  1076. dAtA[i] = 0x2
  1077. i++
  1078. i = encodeVarintRpc(dAtA, i, uint64(len(m.ExternalExecPath)))
  1079. i += copy(dAtA[i:], m.ExternalExecPath)
  1080. }
  1081. if len(m.StressTypes) > 0 {
  1082. for _, s := range m.StressTypes {
  1083. dAtA[i] = 0xaa
  1084. i++
  1085. dAtA[i] = 0x6
  1086. i++
  1087. l = len(s)
  1088. for l >= 1<<7 {
  1089. dAtA[i] = uint8(uint64(l)&0x7f | 0x80)
  1090. l >>= 7
  1091. i++
  1092. }
  1093. dAtA[i] = uint8(l)
  1094. i++
  1095. i += copy(dAtA[i:], s)
  1096. }
  1097. }
  1098. if m.StressKeySize != 0 {
  1099. dAtA[i] = 0xb0
  1100. i++
  1101. dAtA[i] = 0x6
  1102. i++
  1103. i = encodeVarintRpc(dAtA, i, uint64(m.StressKeySize))
  1104. }
  1105. if m.StressKeySizeLarge != 0 {
  1106. dAtA[i] = 0xb8
  1107. i++
  1108. dAtA[i] = 0x6
  1109. i++
  1110. i = encodeVarintRpc(dAtA, i, uint64(m.StressKeySizeLarge))
  1111. }
  1112. if m.StressKeySuffixRange != 0 {
  1113. dAtA[i] = 0xc0
  1114. i++
  1115. dAtA[i] = 0x6
  1116. i++
  1117. i = encodeVarintRpc(dAtA, i, uint64(m.StressKeySuffixRange))
  1118. }
  1119. if m.StressKeySuffixRangeTxn != 0 {
  1120. dAtA[i] = 0xc8
  1121. i++
  1122. dAtA[i] = 0x6
  1123. i++
  1124. i = encodeVarintRpc(dAtA, i, uint64(m.StressKeySuffixRangeTxn))
  1125. }
  1126. if m.StressKeyTxnOps != 0 {
  1127. dAtA[i] = 0xd0
  1128. i++
  1129. dAtA[i] = 0x6
  1130. i++
  1131. i = encodeVarintRpc(dAtA, i, uint64(m.StressKeyTxnOps))
  1132. }
  1133. if m.StressClients != 0 {
  1134. dAtA[i] = 0xc8
  1135. i++
  1136. dAtA[i] = 0xc
  1137. i++
  1138. i = encodeVarintRpc(dAtA, i, uint64(m.StressClients))
  1139. }
  1140. if m.StressQPS != 0 {
  1141. dAtA[i] = 0xd0
  1142. i++
  1143. dAtA[i] = 0xc
  1144. i++
  1145. i = encodeVarintRpc(dAtA, i, uint64(m.StressQPS))
  1146. }
  1147. return i, nil
  1148. }
  1149. func (m *Request) Marshal() (dAtA []byte, err error) {
  1150. size := m.Size()
  1151. dAtA = make([]byte, size)
  1152. n, err := m.MarshalTo(dAtA)
  1153. if err != nil {
  1154. return nil, err
  1155. }
  1156. return dAtA[:n], nil
  1157. }
  1158. func (m *Request) MarshalTo(dAtA []byte) (int, error) {
  1159. var i int
  1160. _ = i
  1161. var l int
  1162. _ = l
  1163. if m.Operation != 0 {
  1164. dAtA[i] = 0x8
  1165. i++
  1166. i = encodeVarintRpc(dAtA, i, uint64(m.Operation))
  1167. }
  1168. if m.Member != nil {
  1169. dAtA[i] = 0x12
  1170. i++
  1171. i = encodeVarintRpc(dAtA, i, uint64(m.Member.Size()))
  1172. n2, err := m.Member.MarshalTo(dAtA[i:])
  1173. if err != nil {
  1174. return 0, err
  1175. }
  1176. i += n2
  1177. }
  1178. if m.Tester != nil {
  1179. dAtA[i] = 0x1a
  1180. i++
  1181. i = encodeVarintRpc(dAtA, i, uint64(m.Tester.Size()))
  1182. n3, err := m.Tester.MarshalTo(dAtA[i:])
  1183. if err != nil {
  1184. return 0, err
  1185. }
  1186. i += n3
  1187. }
  1188. return i, nil
  1189. }
  1190. func (m *Response) Marshal() (dAtA []byte, err error) {
  1191. size := m.Size()
  1192. dAtA = make([]byte, size)
  1193. n, err := m.MarshalTo(dAtA)
  1194. if err != nil {
  1195. return nil, err
  1196. }
  1197. return dAtA[:n], nil
  1198. }
  1199. func (m *Response) MarshalTo(dAtA []byte) (int, error) {
  1200. var i int
  1201. _ = i
  1202. var l int
  1203. _ = l
  1204. if m.Success {
  1205. dAtA[i] = 0x8
  1206. i++
  1207. if m.Success {
  1208. dAtA[i] = 1
  1209. } else {
  1210. dAtA[i] = 0
  1211. }
  1212. i++
  1213. }
  1214. if len(m.Status) > 0 {
  1215. dAtA[i] = 0x12
  1216. i++
  1217. i = encodeVarintRpc(dAtA, i, uint64(len(m.Status)))
  1218. i += copy(dAtA[i:], m.Status)
  1219. }
  1220. if m.Member != nil {
  1221. dAtA[i] = 0x1a
  1222. i++
  1223. i = encodeVarintRpc(dAtA, i, uint64(m.Member.Size()))
  1224. n4, err := m.Member.MarshalTo(dAtA[i:])
  1225. if err != nil {
  1226. return 0, err
  1227. }
  1228. i += n4
  1229. }
  1230. return i, nil
  1231. }
  1232. func encodeVarintRpc(dAtA []byte, offset int, v uint64) int {
  1233. for v >= 1<<7 {
  1234. dAtA[offset] = uint8(v&0x7f | 0x80)
  1235. v >>= 7
  1236. offset++
  1237. }
  1238. dAtA[offset] = uint8(v)
  1239. return offset + 1
  1240. }
  1241. func (m *Etcd) Size() (n int) {
  1242. var l int
  1243. _ = l
  1244. l = len(m.Name)
  1245. if l > 0 {
  1246. n += 1 + l + sovRpc(uint64(l))
  1247. }
  1248. l = len(m.DataDir)
  1249. if l > 0 {
  1250. n += 1 + l + sovRpc(uint64(l))
  1251. }
  1252. l = len(m.WALDir)
  1253. if l > 0 {
  1254. n += 1 + l + sovRpc(uint64(l))
  1255. }
  1256. if m.HeartbeatIntervalMs != 0 {
  1257. n += 1 + sovRpc(uint64(m.HeartbeatIntervalMs))
  1258. }
  1259. if m.ElectionTimeoutMs != 0 {
  1260. n += 1 + sovRpc(uint64(m.ElectionTimeoutMs))
  1261. }
  1262. if len(m.ListenClientURLs) > 0 {
  1263. for _, s := range m.ListenClientURLs {
  1264. l = len(s)
  1265. n += 2 + l + sovRpc(uint64(l))
  1266. }
  1267. }
  1268. if len(m.AdvertiseClientURLs) > 0 {
  1269. for _, s := range m.AdvertiseClientURLs {
  1270. l = len(s)
  1271. n += 2 + l + sovRpc(uint64(l))
  1272. }
  1273. }
  1274. if m.ClientAutoTLS {
  1275. n += 3
  1276. }
  1277. if m.ClientCertAuth {
  1278. n += 3
  1279. }
  1280. l = len(m.ClientCertFile)
  1281. if l > 0 {
  1282. n += 2 + l + sovRpc(uint64(l))
  1283. }
  1284. l = len(m.ClientKeyFile)
  1285. if l > 0 {
  1286. n += 2 + l + sovRpc(uint64(l))
  1287. }
  1288. l = len(m.ClientTrustedCAFile)
  1289. if l > 0 {
  1290. n += 2 + l + sovRpc(uint64(l))
  1291. }
  1292. if len(m.ListenPeerURLs) > 0 {
  1293. for _, s := range m.ListenPeerURLs {
  1294. l = len(s)
  1295. n += 2 + l + sovRpc(uint64(l))
  1296. }
  1297. }
  1298. if len(m.AdvertisePeerURLs) > 0 {
  1299. for _, s := range m.AdvertisePeerURLs {
  1300. l = len(s)
  1301. n += 2 + l + sovRpc(uint64(l))
  1302. }
  1303. }
  1304. if m.PeerAutoTLS {
  1305. n += 3
  1306. }
  1307. if m.PeerClientCertAuth {
  1308. n += 3
  1309. }
  1310. l = len(m.PeerCertFile)
  1311. if l > 0 {
  1312. n += 2 + l + sovRpc(uint64(l))
  1313. }
  1314. l = len(m.PeerKeyFile)
  1315. if l > 0 {
  1316. n += 2 + l + sovRpc(uint64(l))
  1317. }
  1318. l = len(m.PeerTrustedCAFile)
  1319. if l > 0 {
  1320. n += 2 + l + sovRpc(uint64(l))
  1321. }
  1322. l = len(m.InitialCluster)
  1323. if l > 0 {
  1324. n += 2 + l + sovRpc(uint64(l))
  1325. }
  1326. l = len(m.InitialClusterState)
  1327. if l > 0 {
  1328. n += 2 + l + sovRpc(uint64(l))
  1329. }
  1330. l = len(m.InitialClusterToken)
  1331. if l > 0 {
  1332. n += 2 + l + sovRpc(uint64(l))
  1333. }
  1334. if m.SnapshotCount != 0 {
  1335. n += 2 + sovRpc(uint64(m.SnapshotCount))
  1336. }
  1337. if m.QuotaBackendBytes != 0 {
  1338. n += 2 + sovRpc(uint64(m.QuotaBackendBytes))
  1339. }
  1340. if m.PreVote {
  1341. n += 3
  1342. }
  1343. if m.InitialCorruptCheck {
  1344. n += 3
  1345. }
  1346. return n
  1347. }
  1348. func (m *Member) Size() (n int) {
  1349. var l int
  1350. _ = l
  1351. l = len(m.EtcdExecPath)
  1352. if l > 0 {
  1353. n += 1 + l + sovRpc(uint64(l))
  1354. }
  1355. l = len(m.AgentAddr)
  1356. if l > 0 {
  1357. n += 1 + l + sovRpc(uint64(l))
  1358. }
  1359. l = len(m.FailpointHTTPAddr)
  1360. if l > 0 {
  1361. n += 1 + l + sovRpc(uint64(l))
  1362. }
  1363. l = len(m.BaseDir)
  1364. if l > 0 {
  1365. n += 2 + l + sovRpc(uint64(l))
  1366. }
  1367. l = len(m.EtcdLogPath)
  1368. if l > 0 {
  1369. n += 2 + l + sovRpc(uint64(l))
  1370. }
  1371. if m.EtcdClientProxy {
  1372. n += 3
  1373. }
  1374. if m.EtcdPeerProxy {
  1375. n += 3
  1376. }
  1377. l = len(m.EtcdClientEndpoint)
  1378. if l > 0 {
  1379. n += 2 + l + sovRpc(uint64(l))
  1380. }
  1381. if m.Etcd != nil {
  1382. l = m.Etcd.Size()
  1383. n += 2 + l + sovRpc(uint64(l))
  1384. }
  1385. l = len(m.ClientCertData)
  1386. if l > 0 {
  1387. n += 2 + l + sovRpc(uint64(l))
  1388. }
  1389. l = len(m.ClientCertPath)
  1390. if l > 0 {
  1391. n += 2 + l + sovRpc(uint64(l))
  1392. }
  1393. l = len(m.ClientKeyData)
  1394. if l > 0 {
  1395. n += 2 + l + sovRpc(uint64(l))
  1396. }
  1397. l = len(m.ClientKeyPath)
  1398. if l > 0 {
  1399. n += 2 + l + sovRpc(uint64(l))
  1400. }
  1401. l = len(m.ClientTrustedCAData)
  1402. if l > 0 {
  1403. n += 2 + l + sovRpc(uint64(l))
  1404. }
  1405. l = len(m.ClientTrustedCAPath)
  1406. if l > 0 {
  1407. n += 2 + l + sovRpc(uint64(l))
  1408. }
  1409. l = len(m.PeerCertData)
  1410. if l > 0 {
  1411. n += 2 + l + sovRpc(uint64(l))
  1412. }
  1413. l = len(m.PeerCertPath)
  1414. if l > 0 {
  1415. n += 2 + l + sovRpc(uint64(l))
  1416. }
  1417. l = len(m.PeerKeyData)
  1418. if l > 0 {
  1419. n += 2 + l + sovRpc(uint64(l))
  1420. }
  1421. l = len(m.PeerKeyPath)
  1422. if l > 0 {
  1423. n += 2 + l + sovRpc(uint64(l))
  1424. }
  1425. l = len(m.PeerTrustedCAData)
  1426. if l > 0 {
  1427. n += 2 + l + sovRpc(uint64(l))
  1428. }
  1429. l = len(m.PeerTrustedCAPath)
  1430. if l > 0 {
  1431. n += 2 + l + sovRpc(uint64(l))
  1432. }
  1433. return n
  1434. }
  1435. func (m *Tester) Size() (n int) {
  1436. var l int
  1437. _ = l
  1438. l = len(m.TesterDataDir)
  1439. if l > 0 {
  1440. n += 1 + l + sovRpc(uint64(l))
  1441. }
  1442. l = len(m.TesterNetwork)
  1443. if l > 0 {
  1444. n += 1 + l + sovRpc(uint64(l))
  1445. }
  1446. l = len(m.TesterAddr)
  1447. if l > 0 {
  1448. n += 1 + l + sovRpc(uint64(l))
  1449. }
  1450. if m.DelayLatencyMs != 0 {
  1451. n += 1 + sovRpc(uint64(m.DelayLatencyMs))
  1452. }
  1453. if m.DelayLatencyMsRv != 0 {
  1454. n += 1 + sovRpc(uint64(m.DelayLatencyMsRv))
  1455. }
  1456. if m.UpdatedDelayLatencyMs != 0 {
  1457. n += 1 + sovRpc(uint64(m.UpdatedDelayLatencyMs))
  1458. }
  1459. if m.RoundLimit != 0 {
  1460. n += 2 + sovRpc(uint64(m.RoundLimit))
  1461. }
  1462. if m.ExitOnFailure {
  1463. n += 3
  1464. }
  1465. if m.ConsistencyCheck {
  1466. n += 3
  1467. }
  1468. if m.EnablePprof {
  1469. n += 3
  1470. }
  1471. if len(m.FailureCases) > 0 {
  1472. for _, s := range m.FailureCases {
  1473. l = len(s)
  1474. n += 2 + l + sovRpc(uint64(l))
  1475. }
  1476. }
  1477. if m.FailureDelayMs != 0 {
  1478. n += 2 + sovRpc(uint64(m.FailureDelayMs))
  1479. }
  1480. if m.FailureShuffle {
  1481. n += 3
  1482. }
  1483. if len(m.FailpointCommands) > 0 {
  1484. for _, s := range m.FailpointCommands {
  1485. l = len(s)
  1486. n += 2 + l + sovRpc(uint64(l))
  1487. }
  1488. }
  1489. l = len(m.RunnerExecPath)
  1490. if l > 0 {
  1491. n += 2 + l + sovRpc(uint64(l))
  1492. }
  1493. l = len(m.ExternalExecPath)
  1494. if l > 0 {
  1495. n += 2 + l + sovRpc(uint64(l))
  1496. }
  1497. if len(m.StressTypes) > 0 {
  1498. for _, s := range m.StressTypes {
  1499. l = len(s)
  1500. n += 2 + l + sovRpc(uint64(l))
  1501. }
  1502. }
  1503. if m.StressKeySize != 0 {
  1504. n += 2 + sovRpc(uint64(m.StressKeySize))
  1505. }
  1506. if m.StressKeySizeLarge != 0 {
  1507. n += 2 + sovRpc(uint64(m.StressKeySizeLarge))
  1508. }
  1509. if m.StressKeySuffixRange != 0 {
  1510. n += 2 + sovRpc(uint64(m.StressKeySuffixRange))
  1511. }
  1512. if m.StressKeySuffixRangeTxn != 0 {
  1513. n += 2 + sovRpc(uint64(m.StressKeySuffixRangeTxn))
  1514. }
  1515. if m.StressKeyTxnOps != 0 {
  1516. n += 2 + sovRpc(uint64(m.StressKeyTxnOps))
  1517. }
  1518. if m.StressClients != 0 {
  1519. n += 2 + sovRpc(uint64(m.StressClients))
  1520. }
  1521. if m.StressQPS != 0 {
  1522. n += 2 + sovRpc(uint64(m.StressQPS))
  1523. }
  1524. return n
  1525. }
  1526. func (m *Request) Size() (n int) {
  1527. var l int
  1528. _ = l
  1529. if m.Operation != 0 {
  1530. n += 1 + sovRpc(uint64(m.Operation))
  1531. }
  1532. if m.Member != nil {
  1533. l = m.Member.Size()
  1534. n += 1 + l + sovRpc(uint64(l))
  1535. }
  1536. if m.Tester != nil {
  1537. l = m.Tester.Size()
  1538. n += 1 + l + sovRpc(uint64(l))
  1539. }
  1540. return n
  1541. }
  1542. func (m *Response) Size() (n int) {
  1543. var l int
  1544. _ = l
  1545. if m.Success {
  1546. n += 2
  1547. }
  1548. l = len(m.Status)
  1549. if l > 0 {
  1550. n += 1 + l + sovRpc(uint64(l))
  1551. }
  1552. if m.Member != nil {
  1553. l = m.Member.Size()
  1554. n += 1 + l + sovRpc(uint64(l))
  1555. }
  1556. return n
  1557. }
  1558. func sovRpc(x uint64) (n int) {
  1559. for {
  1560. n++
  1561. x >>= 7
  1562. if x == 0 {
  1563. break
  1564. }
  1565. }
  1566. return n
  1567. }
  1568. func sozRpc(x uint64) (n int) {
  1569. return sovRpc(uint64((x << 1) ^ uint64((int64(x) >> 63))))
  1570. }
  1571. func (m *Etcd) Unmarshal(dAtA []byte) error {
  1572. l := len(dAtA)
  1573. iNdEx := 0
  1574. for iNdEx < l {
  1575. preIndex := iNdEx
  1576. var wire uint64
  1577. for shift := uint(0); ; shift += 7 {
  1578. if shift >= 64 {
  1579. return ErrIntOverflowRpc
  1580. }
  1581. if iNdEx >= l {
  1582. return io.ErrUnexpectedEOF
  1583. }
  1584. b := dAtA[iNdEx]
  1585. iNdEx++
  1586. wire |= (uint64(b) & 0x7F) << shift
  1587. if b < 0x80 {
  1588. break
  1589. }
  1590. }
  1591. fieldNum := int32(wire >> 3)
  1592. wireType := int(wire & 0x7)
  1593. if wireType == 4 {
  1594. return fmt.Errorf("proto: Etcd: wiretype end group for non-group")
  1595. }
  1596. if fieldNum <= 0 {
  1597. return fmt.Errorf("proto: Etcd: illegal tag %d (wire type %d)", fieldNum, wire)
  1598. }
  1599. switch fieldNum {
  1600. case 1:
  1601. if wireType != 2 {
  1602. return fmt.Errorf("proto: wrong wireType = %d for field Name", wireType)
  1603. }
  1604. var stringLen uint64
  1605. for shift := uint(0); ; shift += 7 {
  1606. if shift >= 64 {
  1607. return ErrIntOverflowRpc
  1608. }
  1609. if iNdEx >= l {
  1610. return io.ErrUnexpectedEOF
  1611. }
  1612. b := dAtA[iNdEx]
  1613. iNdEx++
  1614. stringLen |= (uint64(b) & 0x7F) << shift
  1615. if b < 0x80 {
  1616. break
  1617. }
  1618. }
  1619. intStringLen := int(stringLen)
  1620. if intStringLen < 0 {
  1621. return ErrInvalidLengthRpc
  1622. }
  1623. postIndex := iNdEx + intStringLen
  1624. if postIndex > l {
  1625. return io.ErrUnexpectedEOF
  1626. }
  1627. m.Name = string(dAtA[iNdEx:postIndex])
  1628. iNdEx = postIndex
  1629. case 2:
  1630. if wireType != 2 {
  1631. return fmt.Errorf("proto: wrong wireType = %d for field DataDir", wireType)
  1632. }
  1633. var stringLen uint64
  1634. for shift := uint(0); ; shift += 7 {
  1635. if shift >= 64 {
  1636. return ErrIntOverflowRpc
  1637. }
  1638. if iNdEx >= l {
  1639. return io.ErrUnexpectedEOF
  1640. }
  1641. b := dAtA[iNdEx]
  1642. iNdEx++
  1643. stringLen |= (uint64(b) & 0x7F) << shift
  1644. if b < 0x80 {
  1645. break
  1646. }
  1647. }
  1648. intStringLen := int(stringLen)
  1649. if intStringLen < 0 {
  1650. return ErrInvalidLengthRpc
  1651. }
  1652. postIndex := iNdEx + intStringLen
  1653. if postIndex > l {
  1654. return io.ErrUnexpectedEOF
  1655. }
  1656. m.DataDir = string(dAtA[iNdEx:postIndex])
  1657. iNdEx = postIndex
  1658. case 3:
  1659. if wireType != 2 {
  1660. return fmt.Errorf("proto: wrong wireType = %d for field WALDir", wireType)
  1661. }
  1662. var stringLen uint64
  1663. for shift := uint(0); ; shift += 7 {
  1664. if shift >= 64 {
  1665. return ErrIntOverflowRpc
  1666. }
  1667. if iNdEx >= l {
  1668. return io.ErrUnexpectedEOF
  1669. }
  1670. b := dAtA[iNdEx]
  1671. iNdEx++
  1672. stringLen |= (uint64(b) & 0x7F) << shift
  1673. if b < 0x80 {
  1674. break
  1675. }
  1676. }
  1677. intStringLen := int(stringLen)
  1678. if intStringLen < 0 {
  1679. return ErrInvalidLengthRpc
  1680. }
  1681. postIndex := iNdEx + intStringLen
  1682. if postIndex > l {
  1683. return io.ErrUnexpectedEOF
  1684. }
  1685. m.WALDir = string(dAtA[iNdEx:postIndex])
  1686. iNdEx = postIndex
  1687. case 11:
  1688. if wireType != 0 {
  1689. return fmt.Errorf("proto: wrong wireType = %d for field HeartbeatIntervalMs", wireType)
  1690. }
  1691. m.HeartbeatIntervalMs = 0
  1692. for shift := uint(0); ; shift += 7 {
  1693. if shift >= 64 {
  1694. return ErrIntOverflowRpc
  1695. }
  1696. if iNdEx >= l {
  1697. return io.ErrUnexpectedEOF
  1698. }
  1699. b := dAtA[iNdEx]
  1700. iNdEx++
  1701. m.HeartbeatIntervalMs |= (int64(b) & 0x7F) << shift
  1702. if b < 0x80 {
  1703. break
  1704. }
  1705. }
  1706. case 12:
  1707. if wireType != 0 {
  1708. return fmt.Errorf("proto: wrong wireType = %d for field ElectionTimeoutMs", wireType)
  1709. }
  1710. m.ElectionTimeoutMs = 0
  1711. for shift := uint(0); ; shift += 7 {
  1712. if shift >= 64 {
  1713. return ErrIntOverflowRpc
  1714. }
  1715. if iNdEx >= l {
  1716. return io.ErrUnexpectedEOF
  1717. }
  1718. b := dAtA[iNdEx]
  1719. iNdEx++
  1720. m.ElectionTimeoutMs |= (int64(b) & 0x7F) << shift
  1721. if b < 0x80 {
  1722. break
  1723. }
  1724. }
  1725. case 21:
  1726. if wireType != 2 {
  1727. return fmt.Errorf("proto: wrong wireType = %d for field ListenClientURLs", wireType)
  1728. }
  1729. var stringLen uint64
  1730. for shift := uint(0); ; shift += 7 {
  1731. if shift >= 64 {
  1732. return ErrIntOverflowRpc
  1733. }
  1734. if iNdEx >= l {
  1735. return io.ErrUnexpectedEOF
  1736. }
  1737. b := dAtA[iNdEx]
  1738. iNdEx++
  1739. stringLen |= (uint64(b) & 0x7F) << shift
  1740. if b < 0x80 {
  1741. break
  1742. }
  1743. }
  1744. intStringLen := int(stringLen)
  1745. if intStringLen < 0 {
  1746. return ErrInvalidLengthRpc
  1747. }
  1748. postIndex := iNdEx + intStringLen
  1749. if postIndex > l {
  1750. return io.ErrUnexpectedEOF
  1751. }
  1752. m.ListenClientURLs = append(m.ListenClientURLs, string(dAtA[iNdEx:postIndex]))
  1753. iNdEx = postIndex
  1754. case 22:
  1755. if wireType != 2 {
  1756. return fmt.Errorf("proto: wrong wireType = %d for field AdvertiseClientURLs", wireType)
  1757. }
  1758. var stringLen uint64
  1759. for shift := uint(0); ; shift += 7 {
  1760. if shift >= 64 {
  1761. return ErrIntOverflowRpc
  1762. }
  1763. if iNdEx >= l {
  1764. return io.ErrUnexpectedEOF
  1765. }
  1766. b := dAtA[iNdEx]
  1767. iNdEx++
  1768. stringLen |= (uint64(b) & 0x7F) << shift
  1769. if b < 0x80 {
  1770. break
  1771. }
  1772. }
  1773. intStringLen := int(stringLen)
  1774. if intStringLen < 0 {
  1775. return ErrInvalidLengthRpc
  1776. }
  1777. postIndex := iNdEx + intStringLen
  1778. if postIndex > l {
  1779. return io.ErrUnexpectedEOF
  1780. }
  1781. m.AdvertiseClientURLs = append(m.AdvertiseClientURLs, string(dAtA[iNdEx:postIndex]))
  1782. iNdEx = postIndex
  1783. case 23:
  1784. if wireType != 0 {
  1785. return fmt.Errorf("proto: wrong wireType = %d for field ClientAutoTLS", wireType)
  1786. }
  1787. var v int
  1788. for shift := uint(0); ; shift += 7 {
  1789. if shift >= 64 {
  1790. return ErrIntOverflowRpc
  1791. }
  1792. if iNdEx >= l {
  1793. return io.ErrUnexpectedEOF
  1794. }
  1795. b := dAtA[iNdEx]
  1796. iNdEx++
  1797. v |= (int(b) & 0x7F) << shift
  1798. if b < 0x80 {
  1799. break
  1800. }
  1801. }
  1802. m.ClientAutoTLS = bool(v != 0)
  1803. case 24:
  1804. if wireType != 0 {
  1805. return fmt.Errorf("proto: wrong wireType = %d for field ClientCertAuth", wireType)
  1806. }
  1807. var v int
  1808. for shift := uint(0); ; shift += 7 {
  1809. if shift >= 64 {
  1810. return ErrIntOverflowRpc
  1811. }
  1812. if iNdEx >= l {
  1813. return io.ErrUnexpectedEOF
  1814. }
  1815. b := dAtA[iNdEx]
  1816. iNdEx++
  1817. v |= (int(b) & 0x7F) << shift
  1818. if b < 0x80 {
  1819. break
  1820. }
  1821. }
  1822. m.ClientCertAuth = bool(v != 0)
  1823. case 25:
  1824. if wireType != 2 {
  1825. return fmt.Errorf("proto: wrong wireType = %d for field ClientCertFile", wireType)
  1826. }
  1827. var stringLen uint64
  1828. for shift := uint(0); ; shift += 7 {
  1829. if shift >= 64 {
  1830. return ErrIntOverflowRpc
  1831. }
  1832. if iNdEx >= l {
  1833. return io.ErrUnexpectedEOF
  1834. }
  1835. b := dAtA[iNdEx]
  1836. iNdEx++
  1837. stringLen |= (uint64(b) & 0x7F) << shift
  1838. if b < 0x80 {
  1839. break
  1840. }
  1841. }
  1842. intStringLen := int(stringLen)
  1843. if intStringLen < 0 {
  1844. return ErrInvalidLengthRpc
  1845. }
  1846. postIndex := iNdEx + intStringLen
  1847. if postIndex > l {
  1848. return io.ErrUnexpectedEOF
  1849. }
  1850. m.ClientCertFile = string(dAtA[iNdEx:postIndex])
  1851. iNdEx = postIndex
  1852. case 26:
  1853. if wireType != 2 {
  1854. return fmt.Errorf("proto: wrong wireType = %d for field ClientKeyFile", wireType)
  1855. }
  1856. var stringLen uint64
  1857. for shift := uint(0); ; shift += 7 {
  1858. if shift >= 64 {
  1859. return ErrIntOverflowRpc
  1860. }
  1861. if iNdEx >= l {
  1862. return io.ErrUnexpectedEOF
  1863. }
  1864. b := dAtA[iNdEx]
  1865. iNdEx++
  1866. stringLen |= (uint64(b) & 0x7F) << shift
  1867. if b < 0x80 {
  1868. break
  1869. }
  1870. }
  1871. intStringLen := int(stringLen)
  1872. if intStringLen < 0 {
  1873. return ErrInvalidLengthRpc
  1874. }
  1875. postIndex := iNdEx + intStringLen
  1876. if postIndex > l {
  1877. return io.ErrUnexpectedEOF
  1878. }
  1879. m.ClientKeyFile = string(dAtA[iNdEx:postIndex])
  1880. iNdEx = postIndex
  1881. case 27:
  1882. if wireType != 2 {
  1883. return fmt.Errorf("proto: wrong wireType = %d for field ClientTrustedCAFile", wireType)
  1884. }
  1885. var stringLen uint64
  1886. for shift := uint(0); ; shift += 7 {
  1887. if shift >= 64 {
  1888. return ErrIntOverflowRpc
  1889. }
  1890. if iNdEx >= l {
  1891. return io.ErrUnexpectedEOF
  1892. }
  1893. b := dAtA[iNdEx]
  1894. iNdEx++
  1895. stringLen |= (uint64(b) & 0x7F) << shift
  1896. if b < 0x80 {
  1897. break
  1898. }
  1899. }
  1900. intStringLen := int(stringLen)
  1901. if intStringLen < 0 {
  1902. return ErrInvalidLengthRpc
  1903. }
  1904. postIndex := iNdEx + intStringLen
  1905. if postIndex > l {
  1906. return io.ErrUnexpectedEOF
  1907. }
  1908. m.ClientTrustedCAFile = string(dAtA[iNdEx:postIndex])
  1909. iNdEx = postIndex
  1910. case 31:
  1911. if wireType != 2 {
  1912. return fmt.Errorf("proto: wrong wireType = %d for field ListenPeerURLs", wireType)
  1913. }
  1914. var stringLen uint64
  1915. for shift := uint(0); ; shift += 7 {
  1916. if shift >= 64 {
  1917. return ErrIntOverflowRpc
  1918. }
  1919. if iNdEx >= l {
  1920. return io.ErrUnexpectedEOF
  1921. }
  1922. b := dAtA[iNdEx]
  1923. iNdEx++
  1924. stringLen |= (uint64(b) & 0x7F) << shift
  1925. if b < 0x80 {
  1926. break
  1927. }
  1928. }
  1929. intStringLen := int(stringLen)
  1930. if intStringLen < 0 {
  1931. return ErrInvalidLengthRpc
  1932. }
  1933. postIndex := iNdEx + intStringLen
  1934. if postIndex > l {
  1935. return io.ErrUnexpectedEOF
  1936. }
  1937. m.ListenPeerURLs = append(m.ListenPeerURLs, string(dAtA[iNdEx:postIndex]))
  1938. iNdEx = postIndex
  1939. case 32:
  1940. if wireType != 2 {
  1941. return fmt.Errorf("proto: wrong wireType = %d for field AdvertisePeerURLs", wireType)
  1942. }
  1943. var stringLen uint64
  1944. for shift := uint(0); ; shift += 7 {
  1945. if shift >= 64 {
  1946. return ErrIntOverflowRpc
  1947. }
  1948. if iNdEx >= l {
  1949. return io.ErrUnexpectedEOF
  1950. }
  1951. b := dAtA[iNdEx]
  1952. iNdEx++
  1953. stringLen |= (uint64(b) & 0x7F) << shift
  1954. if b < 0x80 {
  1955. break
  1956. }
  1957. }
  1958. intStringLen := int(stringLen)
  1959. if intStringLen < 0 {
  1960. return ErrInvalidLengthRpc
  1961. }
  1962. postIndex := iNdEx + intStringLen
  1963. if postIndex > l {
  1964. return io.ErrUnexpectedEOF
  1965. }
  1966. m.AdvertisePeerURLs = append(m.AdvertisePeerURLs, string(dAtA[iNdEx:postIndex]))
  1967. iNdEx = postIndex
  1968. case 33:
  1969. if wireType != 0 {
  1970. return fmt.Errorf("proto: wrong wireType = %d for field PeerAutoTLS", wireType)
  1971. }
  1972. var v int
  1973. for shift := uint(0); ; shift += 7 {
  1974. if shift >= 64 {
  1975. return ErrIntOverflowRpc
  1976. }
  1977. if iNdEx >= l {
  1978. return io.ErrUnexpectedEOF
  1979. }
  1980. b := dAtA[iNdEx]
  1981. iNdEx++
  1982. v |= (int(b) & 0x7F) << shift
  1983. if b < 0x80 {
  1984. break
  1985. }
  1986. }
  1987. m.PeerAutoTLS = bool(v != 0)
  1988. case 34:
  1989. if wireType != 0 {
  1990. return fmt.Errorf("proto: wrong wireType = %d for field PeerClientCertAuth", wireType)
  1991. }
  1992. var v int
  1993. for shift := uint(0); ; shift += 7 {
  1994. if shift >= 64 {
  1995. return ErrIntOverflowRpc
  1996. }
  1997. if iNdEx >= l {
  1998. return io.ErrUnexpectedEOF
  1999. }
  2000. b := dAtA[iNdEx]
  2001. iNdEx++
  2002. v |= (int(b) & 0x7F) << shift
  2003. if b < 0x80 {
  2004. break
  2005. }
  2006. }
  2007. m.PeerClientCertAuth = bool(v != 0)
  2008. case 35:
  2009. if wireType != 2 {
  2010. return fmt.Errorf("proto: wrong wireType = %d for field PeerCertFile", wireType)
  2011. }
  2012. var stringLen uint64
  2013. for shift := uint(0); ; shift += 7 {
  2014. if shift >= 64 {
  2015. return ErrIntOverflowRpc
  2016. }
  2017. if iNdEx >= l {
  2018. return io.ErrUnexpectedEOF
  2019. }
  2020. b := dAtA[iNdEx]
  2021. iNdEx++
  2022. stringLen |= (uint64(b) & 0x7F) << shift
  2023. if b < 0x80 {
  2024. break
  2025. }
  2026. }
  2027. intStringLen := int(stringLen)
  2028. if intStringLen < 0 {
  2029. return ErrInvalidLengthRpc
  2030. }
  2031. postIndex := iNdEx + intStringLen
  2032. if postIndex > l {
  2033. return io.ErrUnexpectedEOF
  2034. }
  2035. m.PeerCertFile = string(dAtA[iNdEx:postIndex])
  2036. iNdEx = postIndex
  2037. case 36:
  2038. if wireType != 2 {
  2039. return fmt.Errorf("proto: wrong wireType = %d for field PeerKeyFile", wireType)
  2040. }
  2041. var stringLen uint64
  2042. for shift := uint(0); ; shift += 7 {
  2043. if shift >= 64 {
  2044. return ErrIntOverflowRpc
  2045. }
  2046. if iNdEx >= l {
  2047. return io.ErrUnexpectedEOF
  2048. }
  2049. b := dAtA[iNdEx]
  2050. iNdEx++
  2051. stringLen |= (uint64(b) & 0x7F) << shift
  2052. if b < 0x80 {
  2053. break
  2054. }
  2055. }
  2056. intStringLen := int(stringLen)
  2057. if intStringLen < 0 {
  2058. return ErrInvalidLengthRpc
  2059. }
  2060. postIndex := iNdEx + intStringLen
  2061. if postIndex > l {
  2062. return io.ErrUnexpectedEOF
  2063. }
  2064. m.PeerKeyFile = string(dAtA[iNdEx:postIndex])
  2065. iNdEx = postIndex
  2066. case 37:
  2067. if wireType != 2 {
  2068. return fmt.Errorf("proto: wrong wireType = %d for field PeerTrustedCAFile", wireType)
  2069. }
  2070. var stringLen uint64
  2071. for shift := uint(0); ; shift += 7 {
  2072. if shift >= 64 {
  2073. return ErrIntOverflowRpc
  2074. }
  2075. if iNdEx >= l {
  2076. return io.ErrUnexpectedEOF
  2077. }
  2078. b := dAtA[iNdEx]
  2079. iNdEx++
  2080. stringLen |= (uint64(b) & 0x7F) << shift
  2081. if b < 0x80 {
  2082. break
  2083. }
  2084. }
  2085. intStringLen := int(stringLen)
  2086. if intStringLen < 0 {
  2087. return ErrInvalidLengthRpc
  2088. }
  2089. postIndex := iNdEx + intStringLen
  2090. if postIndex > l {
  2091. return io.ErrUnexpectedEOF
  2092. }
  2093. m.PeerTrustedCAFile = string(dAtA[iNdEx:postIndex])
  2094. iNdEx = postIndex
  2095. case 41:
  2096. if wireType != 2 {
  2097. return fmt.Errorf("proto: wrong wireType = %d for field InitialCluster", wireType)
  2098. }
  2099. var stringLen uint64
  2100. for shift := uint(0); ; shift += 7 {
  2101. if shift >= 64 {
  2102. return ErrIntOverflowRpc
  2103. }
  2104. if iNdEx >= l {
  2105. return io.ErrUnexpectedEOF
  2106. }
  2107. b := dAtA[iNdEx]
  2108. iNdEx++
  2109. stringLen |= (uint64(b) & 0x7F) << shift
  2110. if b < 0x80 {
  2111. break
  2112. }
  2113. }
  2114. intStringLen := int(stringLen)
  2115. if intStringLen < 0 {
  2116. return ErrInvalidLengthRpc
  2117. }
  2118. postIndex := iNdEx + intStringLen
  2119. if postIndex > l {
  2120. return io.ErrUnexpectedEOF
  2121. }
  2122. m.InitialCluster = string(dAtA[iNdEx:postIndex])
  2123. iNdEx = postIndex
  2124. case 42:
  2125. if wireType != 2 {
  2126. return fmt.Errorf("proto: wrong wireType = %d for field InitialClusterState", wireType)
  2127. }
  2128. var stringLen uint64
  2129. for shift := uint(0); ; shift += 7 {
  2130. if shift >= 64 {
  2131. return ErrIntOverflowRpc
  2132. }
  2133. if iNdEx >= l {
  2134. return io.ErrUnexpectedEOF
  2135. }
  2136. b := dAtA[iNdEx]
  2137. iNdEx++
  2138. stringLen |= (uint64(b) & 0x7F) << shift
  2139. if b < 0x80 {
  2140. break
  2141. }
  2142. }
  2143. intStringLen := int(stringLen)
  2144. if intStringLen < 0 {
  2145. return ErrInvalidLengthRpc
  2146. }
  2147. postIndex := iNdEx + intStringLen
  2148. if postIndex > l {
  2149. return io.ErrUnexpectedEOF
  2150. }
  2151. m.InitialClusterState = string(dAtA[iNdEx:postIndex])
  2152. iNdEx = postIndex
  2153. case 43:
  2154. if wireType != 2 {
  2155. return fmt.Errorf("proto: wrong wireType = %d for field InitialClusterToken", wireType)
  2156. }
  2157. var stringLen uint64
  2158. for shift := uint(0); ; shift += 7 {
  2159. if shift >= 64 {
  2160. return ErrIntOverflowRpc
  2161. }
  2162. if iNdEx >= l {
  2163. return io.ErrUnexpectedEOF
  2164. }
  2165. b := dAtA[iNdEx]
  2166. iNdEx++
  2167. stringLen |= (uint64(b) & 0x7F) << shift
  2168. if b < 0x80 {
  2169. break
  2170. }
  2171. }
  2172. intStringLen := int(stringLen)
  2173. if intStringLen < 0 {
  2174. return ErrInvalidLengthRpc
  2175. }
  2176. postIndex := iNdEx + intStringLen
  2177. if postIndex > l {
  2178. return io.ErrUnexpectedEOF
  2179. }
  2180. m.InitialClusterToken = string(dAtA[iNdEx:postIndex])
  2181. iNdEx = postIndex
  2182. case 51:
  2183. if wireType != 0 {
  2184. return fmt.Errorf("proto: wrong wireType = %d for field SnapshotCount", wireType)
  2185. }
  2186. m.SnapshotCount = 0
  2187. for shift := uint(0); ; shift += 7 {
  2188. if shift >= 64 {
  2189. return ErrIntOverflowRpc
  2190. }
  2191. if iNdEx >= l {
  2192. return io.ErrUnexpectedEOF
  2193. }
  2194. b := dAtA[iNdEx]
  2195. iNdEx++
  2196. m.SnapshotCount |= (int64(b) & 0x7F) << shift
  2197. if b < 0x80 {
  2198. break
  2199. }
  2200. }
  2201. case 52:
  2202. if wireType != 0 {
  2203. return fmt.Errorf("proto: wrong wireType = %d for field QuotaBackendBytes", wireType)
  2204. }
  2205. m.QuotaBackendBytes = 0
  2206. for shift := uint(0); ; shift += 7 {
  2207. if shift >= 64 {
  2208. return ErrIntOverflowRpc
  2209. }
  2210. if iNdEx >= l {
  2211. return io.ErrUnexpectedEOF
  2212. }
  2213. b := dAtA[iNdEx]
  2214. iNdEx++
  2215. m.QuotaBackendBytes |= (int64(b) & 0x7F) << shift
  2216. if b < 0x80 {
  2217. break
  2218. }
  2219. }
  2220. case 63:
  2221. if wireType != 0 {
  2222. return fmt.Errorf("proto: wrong wireType = %d for field PreVote", wireType)
  2223. }
  2224. var v int
  2225. for shift := uint(0); ; shift += 7 {
  2226. if shift >= 64 {
  2227. return ErrIntOverflowRpc
  2228. }
  2229. if iNdEx >= l {
  2230. return io.ErrUnexpectedEOF
  2231. }
  2232. b := dAtA[iNdEx]
  2233. iNdEx++
  2234. v |= (int(b) & 0x7F) << shift
  2235. if b < 0x80 {
  2236. break
  2237. }
  2238. }
  2239. m.PreVote = bool(v != 0)
  2240. case 64:
  2241. if wireType != 0 {
  2242. return fmt.Errorf("proto: wrong wireType = %d for field InitialCorruptCheck", wireType)
  2243. }
  2244. var v int
  2245. for shift := uint(0); ; shift += 7 {
  2246. if shift >= 64 {
  2247. return ErrIntOverflowRpc
  2248. }
  2249. if iNdEx >= l {
  2250. return io.ErrUnexpectedEOF
  2251. }
  2252. b := dAtA[iNdEx]
  2253. iNdEx++
  2254. v |= (int(b) & 0x7F) << shift
  2255. if b < 0x80 {
  2256. break
  2257. }
  2258. }
  2259. m.InitialCorruptCheck = bool(v != 0)
  2260. default:
  2261. iNdEx = preIndex
  2262. skippy, err := skipRpc(dAtA[iNdEx:])
  2263. if err != nil {
  2264. return err
  2265. }
  2266. if skippy < 0 {
  2267. return ErrInvalidLengthRpc
  2268. }
  2269. if (iNdEx + skippy) > l {
  2270. return io.ErrUnexpectedEOF
  2271. }
  2272. iNdEx += skippy
  2273. }
  2274. }
  2275. if iNdEx > l {
  2276. return io.ErrUnexpectedEOF
  2277. }
  2278. return nil
  2279. }
  2280. func (m *Member) Unmarshal(dAtA []byte) error {
  2281. l := len(dAtA)
  2282. iNdEx := 0
  2283. for iNdEx < l {
  2284. preIndex := iNdEx
  2285. var wire uint64
  2286. for shift := uint(0); ; shift += 7 {
  2287. if shift >= 64 {
  2288. return ErrIntOverflowRpc
  2289. }
  2290. if iNdEx >= l {
  2291. return io.ErrUnexpectedEOF
  2292. }
  2293. b := dAtA[iNdEx]
  2294. iNdEx++
  2295. wire |= (uint64(b) & 0x7F) << shift
  2296. if b < 0x80 {
  2297. break
  2298. }
  2299. }
  2300. fieldNum := int32(wire >> 3)
  2301. wireType := int(wire & 0x7)
  2302. if wireType == 4 {
  2303. return fmt.Errorf("proto: Member: wiretype end group for non-group")
  2304. }
  2305. if fieldNum <= 0 {
  2306. return fmt.Errorf("proto: Member: illegal tag %d (wire type %d)", fieldNum, wire)
  2307. }
  2308. switch fieldNum {
  2309. case 1:
  2310. if wireType != 2 {
  2311. return fmt.Errorf("proto: wrong wireType = %d for field EtcdExecPath", wireType)
  2312. }
  2313. var stringLen uint64
  2314. for shift := uint(0); ; shift += 7 {
  2315. if shift >= 64 {
  2316. return ErrIntOverflowRpc
  2317. }
  2318. if iNdEx >= l {
  2319. return io.ErrUnexpectedEOF
  2320. }
  2321. b := dAtA[iNdEx]
  2322. iNdEx++
  2323. stringLen |= (uint64(b) & 0x7F) << shift
  2324. if b < 0x80 {
  2325. break
  2326. }
  2327. }
  2328. intStringLen := int(stringLen)
  2329. if intStringLen < 0 {
  2330. return ErrInvalidLengthRpc
  2331. }
  2332. postIndex := iNdEx + intStringLen
  2333. if postIndex > l {
  2334. return io.ErrUnexpectedEOF
  2335. }
  2336. m.EtcdExecPath = string(dAtA[iNdEx:postIndex])
  2337. iNdEx = postIndex
  2338. case 11:
  2339. if wireType != 2 {
  2340. return fmt.Errorf("proto: wrong wireType = %d for field AgentAddr", wireType)
  2341. }
  2342. var stringLen uint64
  2343. for shift := uint(0); ; shift += 7 {
  2344. if shift >= 64 {
  2345. return ErrIntOverflowRpc
  2346. }
  2347. if iNdEx >= l {
  2348. return io.ErrUnexpectedEOF
  2349. }
  2350. b := dAtA[iNdEx]
  2351. iNdEx++
  2352. stringLen |= (uint64(b) & 0x7F) << shift
  2353. if b < 0x80 {
  2354. break
  2355. }
  2356. }
  2357. intStringLen := int(stringLen)
  2358. if intStringLen < 0 {
  2359. return ErrInvalidLengthRpc
  2360. }
  2361. postIndex := iNdEx + intStringLen
  2362. if postIndex > l {
  2363. return io.ErrUnexpectedEOF
  2364. }
  2365. m.AgentAddr = string(dAtA[iNdEx:postIndex])
  2366. iNdEx = postIndex
  2367. case 12:
  2368. if wireType != 2 {
  2369. return fmt.Errorf("proto: wrong wireType = %d for field FailpointHTTPAddr", wireType)
  2370. }
  2371. var stringLen uint64
  2372. for shift := uint(0); ; shift += 7 {
  2373. if shift >= 64 {
  2374. return ErrIntOverflowRpc
  2375. }
  2376. if iNdEx >= l {
  2377. return io.ErrUnexpectedEOF
  2378. }
  2379. b := dAtA[iNdEx]
  2380. iNdEx++
  2381. stringLen |= (uint64(b) & 0x7F) << shift
  2382. if b < 0x80 {
  2383. break
  2384. }
  2385. }
  2386. intStringLen := int(stringLen)
  2387. if intStringLen < 0 {
  2388. return ErrInvalidLengthRpc
  2389. }
  2390. postIndex := iNdEx + intStringLen
  2391. if postIndex > l {
  2392. return io.ErrUnexpectedEOF
  2393. }
  2394. m.FailpointHTTPAddr = string(dAtA[iNdEx:postIndex])
  2395. iNdEx = postIndex
  2396. case 101:
  2397. if wireType != 2 {
  2398. return fmt.Errorf("proto: wrong wireType = %d for field BaseDir", wireType)
  2399. }
  2400. var stringLen uint64
  2401. for shift := uint(0); ; shift += 7 {
  2402. if shift >= 64 {
  2403. return ErrIntOverflowRpc
  2404. }
  2405. if iNdEx >= l {
  2406. return io.ErrUnexpectedEOF
  2407. }
  2408. b := dAtA[iNdEx]
  2409. iNdEx++
  2410. stringLen |= (uint64(b) & 0x7F) << shift
  2411. if b < 0x80 {
  2412. break
  2413. }
  2414. }
  2415. intStringLen := int(stringLen)
  2416. if intStringLen < 0 {
  2417. return ErrInvalidLengthRpc
  2418. }
  2419. postIndex := iNdEx + intStringLen
  2420. if postIndex > l {
  2421. return io.ErrUnexpectedEOF
  2422. }
  2423. m.BaseDir = string(dAtA[iNdEx:postIndex])
  2424. iNdEx = postIndex
  2425. case 102:
  2426. if wireType != 2 {
  2427. return fmt.Errorf("proto: wrong wireType = %d for field EtcdLogPath", wireType)
  2428. }
  2429. var stringLen uint64
  2430. for shift := uint(0); ; shift += 7 {
  2431. if shift >= 64 {
  2432. return ErrIntOverflowRpc
  2433. }
  2434. if iNdEx >= l {
  2435. return io.ErrUnexpectedEOF
  2436. }
  2437. b := dAtA[iNdEx]
  2438. iNdEx++
  2439. stringLen |= (uint64(b) & 0x7F) << shift
  2440. if b < 0x80 {
  2441. break
  2442. }
  2443. }
  2444. intStringLen := int(stringLen)
  2445. if intStringLen < 0 {
  2446. return ErrInvalidLengthRpc
  2447. }
  2448. postIndex := iNdEx + intStringLen
  2449. if postIndex > l {
  2450. return io.ErrUnexpectedEOF
  2451. }
  2452. m.EtcdLogPath = string(dAtA[iNdEx:postIndex])
  2453. iNdEx = postIndex
  2454. case 201:
  2455. if wireType != 0 {
  2456. return fmt.Errorf("proto: wrong wireType = %d for field EtcdClientProxy", wireType)
  2457. }
  2458. var v int
  2459. for shift := uint(0); ; shift += 7 {
  2460. if shift >= 64 {
  2461. return ErrIntOverflowRpc
  2462. }
  2463. if iNdEx >= l {
  2464. return io.ErrUnexpectedEOF
  2465. }
  2466. b := dAtA[iNdEx]
  2467. iNdEx++
  2468. v |= (int(b) & 0x7F) << shift
  2469. if b < 0x80 {
  2470. break
  2471. }
  2472. }
  2473. m.EtcdClientProxy = bool(v != 0)
  2474. case 202:
  2475. if wireType != 0 {
  2476. return fmt.Errorf("proto: wrong wireType = %d for field EtcdPeerProxy", wireType)
  2477. }
  2478. var v int
  2479. for shift := uint(0); ; shift += 7 {
  2480. if shift >= 64 {
  2481. return ErrIntOverflowRpc
  2482. }
  2483. if iNdEx >= l {
  2484. return io.ErrUnexpectedEOF
  2485. }
  2486. b := dAtA[iNdEx]
  2487. iNdEx++
  2488. v |= (int(b) & 0x7F) << shift
  2489. if b < 0x80 {
  2490. break
  2491. }
  2492. }
  2493. m.EtcdPeerProxy = bool(v != 0)
  2494. case 301:
  2495. if wireType != 2 {
  2496. return fmt.Errorf("proto: wrong wireType = %d for field EtcdClientEndpoint", wireType)
  2497. }
  2498. var stringLen uint64
  2499. for shift := uint(0); ; shift += 7 {
  2500. if shift >= 64 {
  2501. return ErrIntOverflowRpc
  2502. }
  2503. if iNdEx >= l {
  2504. return io.ErrUnexpectedEOF
  2505. }
  2506. b := dAtA[iNdEx]
  2507. iNdEx++
  2508. stringLen |= (uint64(b) & 0x7F) << shift
  2509. if b < 0x80 {
  2510. break
  2511. }
  2512. }
  2513. intStringLen := int(stringLen)
  2514. if intStringLen < 0 {
  2515. return ErrInvalidLengthRpc
  2516. }
  2517. postIndex := iNdEx + intStringLen
  2518. if postIndex > l {
  2519. return io.ErrUnexpectedEOF
  2520. }
  2521. m.EtcdClientEndpoint = string(dAtA[iNdEx:postIndex])
  2522. iNdEx = postIndex
  2523. case 302:
  2524. if wireType != 2 {
  2525. return fmt.Errorf("proto: wrong wireType = %d for field Etcd", wireType)
  2526. }
  2527. var msglen int
  2528. for shift := uint(0); ; shift += 7 {
  2529. if shift >= 64 {
  2530. return ErrIntOverflowRpc
  2531. }
  2532. if iNdEx >= l {
  2533. return io.ErrUnexpectedEOF
  2534. }
  2535. b := dAtA[iNdEx]
  2536. iNdEx++
  2537. msglen |= (int(b) & 0x7F) << shift
  2538. if b < 0x80 {
  2539. break
  2540. }
  2541. }
  2542. if msglen < 0 {
  2543. return ErrInvalidLengthRpc
  2544. }
  2545. postIndex := iNdEx + msglen
  2546. if postIndex > l {
  2547. return io.ErrUnexpectedEOF
  2548. }
  2549. if m.Etcd == nil {
  2550. m.Etcd = &Etcd{}
  2551. }
  2552. if err := m.Etcd.Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
  2553. return err
  2554. }
  2555. iNdEx = postIndex
  2556. case 401:
  2557. if wireType != 2 {
  2558. return fmt.Errorf("proto: wrong wireType = %d for field ClientCertData", wireType)
  2559. }
  2560. var stringLen uint64
  2561. for shift := uint(0); ; shift += 7 {
  2562. if shift >= 64 {
  2563. return ErrIntOverflowRpc
  2564. }
  2565. if iNdEx >= l {
  2566. return io.ErrUnexpectedEOF
  2567. }
  2568. b := dAtA[iNdEx]
  2569. iNdEx++
  2570. stringLen |= (uint64(b) & 0x7F) << shift
  2571. if b < 0x80 {
  2572. break
  2573. }
  2574. }
  2575. intStringLen := int(stringLen)
  2576. if intStringLen < 0 {
  2577. return ErrInvalidLengthRpc
  2578. }
  2579. postIndex := iNdEx + intStringLen
  2580. if postIndex > l {
  2581. return io.ErrUnexpectedEOF
  2582. }
  2583. m.ClientCertData = string(dAtA[iNdEx:postIndex])
  2584. iNdEx = postIndex
  2585. case 402:
  2586. if wireType != 2 {
  2587. return fmt.Errorf("proto: wrong wireType = %d for field ClientCertPath", wireType)
  2588. }
  2589. var stringLen uint64
  2590. for shift := uint(0); ; shift += 7 {
  2591. if shift >= 64 {
  2592. return ErrIntOverflowRpc
  2593. }
  2594. if iNdEx >= l {
  2595. return io.ErrUnexpectedEOF
  2596. }
  2597. b := dAtA[iNdEx]
  2598. iNdEx++
  2599. stringLen |= (uint64(b) & 0x7F) << shift
  2600. if b < 0x80 {
  2601. break
  2602. }
  2603. }
  2604. intStringLen := int(stringLen)
  2605. if intStringLen < 0 {
  2606. return ErrInvalidLengthRpc
  2607. }
  2608. postIndex := iNdEx + intStringLen
  2609. if postIndex > l {
  2610. return io.ErrUnexpectedEOF
  2611. }
  2612. m.ClientCertPath = string(dAtA[iNdEx:postIndex])
  2613. iNdEx = postIndex
  2614. case 403:
  2615. if wireType != 2 {
  2616. return fmt.Errorf("proto: wrong wireType = %d for field ClientKeyData", wireType)
  2617. }
  2618. var stringLen uint64
  2619. for shift := uint(0); ; shift += 7 {
  2620. if shift >= 64 {
  2621. return ErrIntOverflowRpc
  2622. }
  2623. if iNdEx >= l {
  2624. return io.ErrUnexpectedEOF
  2625. }
  2626. b := dAtA[iNdEx]
  2627. iNdEx++
  2628. stringLen |= (uint64(b) & 0x7F) << shift
  2629. if b < 0x80 {
  2630. break
  2631. }
  2632. }
  2633. intStringLen := int(stringLen)
  2634. if intStringLen < 0 {
  2635. return ErrInvalidLengthRpc
  2636. }
  2637. postIndex := iNdEx + intStringLen
  2638. if postIndex > l {
  2639. return io.ErrUnexpectedEOF
  2640. }
  2641. m.ClientKeyData = string(dAtA[iNdEx:postIndex])
  2642. iNdEx = postIndex
  2643. case 404:
  2644. if wireType != 2 {
  2645. return fmt.Errorf("proto: wrong wireType = %d for field ClientKeyPath", wireType)
  2646. }
  2647. var stringLen uint64
  2648. for shift := uint(0); ; shift += 7 {
  2649. if shift >= 64 {
  2650. return ErrIntOverflowRpc
  2651. }
  2652. if iNdEx >= l {
  2653. return io.ErrUnexpectedEOF
  2654. }
  2655. b := dAtA[iNdEx]
  2656. iNdEx++
  2657. stringLen |= (uint64(b) & 0x7F) << shift
  2658. if b < 0x80 {
  2659. break
  2660. }
  2661. }
  2662. intStringLen := int(stringLen)
  2663. if intStringLen < 0 {
  2664. return ErrInvalidLengthRpc
  2665. }
  2666. postIndex := iNdEx + intStringLen
  2667. if postIndex > l {
  2668. return io.ErrUnexpectedEOF
  2669. }
  2670. m.ClientKeyPath = string(dAtA[iNdEx:postIndex])
  2671. iNdEx = postIndex
  2672. case 405:
  2673. if wireType != 2 {
  2674. return fmt.Errorf("proto: wrong wireType = %d for field ClientTrustedCAData", wireType)
  2675. }
  2676. var stringLen uint64
  2677. for shift := uint(0); ; shift += 7 {
  2678. if shift >= 64 {
  2679. return ErrIntOverflowRpc
  2680. }
  2681. if iNdEx >= l {
  2682. return io.ErrUnexpectedEOF
  2683. }
  2684. b := dAtA[iNdEx]
  2685. iNdEx++
  2686. stringLen |= (uint64(b) & 0x7F) << shift
  2687. if b < 0x80 {
  2688. break
  2689. }
  2690. }
  2691. intStringLen := int(stringLen)
  2692. if intStringLen < 0 {
  2693. return ErrInvalidLengthRpc
  2694. }
  2695. postIndex := iNdEx + intStringLen
  2696. if postIndex > l {
  2697. return io.ErrUnexpectedEOF
  2698. }
  2699. m.ClientTrustedCAData = string(dAtA[iNdEx:postIndex])
  2700. iNdEx = postIndex
  2701. case 406:
  2702. if wireType != 2 {
  2703. return fmt.Errorf("proto: wrong wireType = %d for field ClientTrustedCAPath", wireType)
  2704. }
  2705. var stringLen uint64
  2706. for shift := uint(0); ; shift += 7 {
  2707. if shift >= 64 {
  2708. return ErrIntOverflowRpc
  2709. }
  2710. if iNdEx >= l {
  2711. return io.ErrUnexpectedEOF
  2712. }
  2713. b := dAtA[iNdEx]
  2714. iNdEx++
  2715. stringLen |= (uint64(b) & 0x7F) << shift
  2716. if b < 0x80 {
  2717. break
  2718. }
  2719. }
  2720. intStringLen := int(stringLen)
  2721. if intStringLen < 0 {
  2722. return ErrInvalidLengthRpc
  2723. }
  2724. postIndex := iNdEx + intStringLen
  2725. if postIndex > l {
  2726. return io.ErrUnexpectedEOF
  2727. }
  2728. m.ClientTrustedCAPath = string(dAtA[iNdEx:postIndex])
  2729. iNdEx = postIndex
  2730. case 501:
  2731. if wireType != 2 {
  2732. return fmt.Errorf("proto: wrong wireType = %d for field PeerCertData", wireType)
  2733. }
  2734. var stringLen uint64
  2735. for shift := uint(0); ; shift += 7 {
  2736. if shift >= 64 {
  2737. return ErrIntOverflowRpc
  2738. }
  2739. if iNdEx >= l {
  2740. return io.ErrUnexpectedEOF
  2741. }
  2742. b := dAtA[iNdEx]
  2743. iNdEx++
  2744. stringLen |= (uint64(b) & 0x7F) << shift
  2745. if b < 0x80 {
  2746. break
  2747. }
  2748. }
  2749. intStringLen := int(stringLen)
  2750. if intStringLen < 0 {
  2751. return ErrInvalidLengthRpc
  2752. }
  2753. postIndex := iNdEx + intStringLen
  2754. if postIndex > l {
  2755. return io.ErrUnexpectedEOF
  2756. }
  2757. m.PeerCertData = string(dAtA[iNdEx:postIndex])
  2758. iNdEx = postIndex
  2759. case 502:
  2760. if wireType != 2 {
  2761. return fmt.Errorf("proto: wrong wireType = %d for field PeerCertPath", wireType)
  2762. }
  2763. var stringLen uint64
  2764. for shift := uint(0); ; shift += 7 {
  2765. if shift >= 64 {
  2766. return ErrIntOverflowRpc
  2767. }
  2768. if iNdEx >= l {
  2769. return io.ErrUnexpectedEOF
  2770. }
  2771. b := dAtA[iNdEx]
  2772. iNdEx++
  2773. stringLen |= (uint64(b) & 0x7F) << shift
  2774. if b < 0x80 {
  2775. break
  2776. }
  2777. }
  2778. intStringLen := int(stringLen)
  2779. if intStringLen < 0 {
  2780. return ErrInvalidLengthRpc
  2781. }
  2782. postIndex := iNdEx + intStringLen
  2783. if postIndex > l {
  2784. return io.ErrUnexpectedEOF
  2785. }
  2786. m.PeerCertPath = string(dAtA[iNdEx:postIndex])
  2787. iNdEx = postIndex
  2788. case 503:
  2789. if wireType != 2 {
  2790. return fmt.Errorf("proto: wrong wireType = %d for field PeerKeyData", wireType)
  2791. }
  2792. var stringLen uint64
  2793. for shift := uint(0); ; shift += 7 {
  2794. if shift >= 64 {
  2795. return ErrIntOverflowRpc
  2796. }
  2797. if iNdEx >= l {
  2798. return io.ErrUnexpectedEOF
  2799. }
  2800. b := dAtA[iNdEx]
  2801. iNdEx++
  2802. stringLen |= (uint64(b) & 0x7F) << shift
  2803. if b < 0x80 {
  2804. break
  2805. }
  2806. }
  2807. intStringLen := int(stringLen)
  2808. if intStringLen < 0 {
  2809. return ErrInvalidLengthRpc
  2810. }
  2811. postIndex := iNdEx + intStringLen
  2812. if postIndex > l {
  2813. return io.ErrUnexpectedEOF
  2814. }
  2815. m.PeerKeyData = string(dAtA[iNdEx:postIndex])
  2816. iNdEx = postIndex
  2817. case 504:
  2818. if wireType != 2 {
  2819. return fmt.Errorf("proto: wrong wireType = %d for field PeerKeyPath", wireType)
  2820. }
  2821. var stringLen uint64
  2822. for shift := uint(0); ; shift += 7 {
  2823. if shift >= 64 {
  2824. return ErrIntOverflowRpc
  2825. }
  2826. if iNdEx >= l {
  2827. return io.ErrUnexpectedEOF
  2828. }
  2829. b := dAtA[iNdEx]
  2830. iNdEx++
  2831. stringLen |= (uint64(b) & 0x7F) << shift
  2832. if b < 0x80 {
  2833. break
  2834. }
  2835. }
  2836. intStringLen := int(stringLen)
  2837. if intStringLen < 0 {
  2838. return ErrInvalidLengthRpc
  2839. }
  2840. postIndex := iNdEx + intStringLen
  2841. if postIndex > l {
  2842. return io.ErrUnexpectedEOF
  2843. }
  2844. m.PeerKeyPath = string(dAtA[iNdEx:postIndex])
  2845. iNdEx = postIndex
  2846. case 505:
  2847. if wireType != 2 {
  2848. return fmt.Errorf("proto: wrong wireType = %d for field PeerTrustedCAData", wireType)
  2849. }
  2850. var stringLen uint64
  2851. for shift := uint(0); ; shift += 7 {
  2852. if shift >= 64 {
  2853. return ErrIntOverflowRpc
  2854. }
  2855. if iNdEx >= l {
  2856. return io.ErrUnexpectedEOF
  2857. }
  2858. b := dAtA[iNdEx]
  2859. iNdEx++
  2860. stringLen |= (uint64(b) & 0x7F) << shift
  2861. if b < 0x80 {
  2862. break
  2863. }
  2864. }
  2865. intStringLen := int(stringLen)
  2866. if intStringLen < 0 {
  2867. return ErrInvalidLengthRpc
  2868. }
  2869. postIndex := iNdEx + intStringLen
  2870. if postIndex > l {
  2871. return io.ErrUnexpectedEOF
  2872. }
  2873. m.PeerTrustedCAData = string(dAtA[iNdEx:postIndex])
  2874. iNdEx = postIndex
  2875. case 506:
  2876. if wireType != 2 {
  2877. return fmt.Errorf("proto: wrong wireType = %d for field PeerTrustedCAPath", wireType)
  2878. }
  2879. var stringLen uint64
  2880. for shift := uint(0); ; shift += 7 {
  2881. if shift >= 64 {
  2882. return ErrIntOverflowRpc
  2883. }
  2884. if iNdEx >= l {
  2885. return io.ErrUnexpectedEOF
  2886. }
  2887. b := dAtA[iNdEx]
  2888. iNdEx++
  2889. stringLen |= (uint64(b) & 0x7F) << shift
  2890. if b < 0x80 {
  2891. break
  2892. }
  2893. }
  2894. intStringLen := int(stringLen)
  2895. if intStringLen < 0 {
  2896. return ErrInvalidLengthRpc
  2897. }
  2898. postIndex := iNdEx + intStringLen
  2899. if postIndex > l {
  2900. return io.ErrUnexpectedEOF
  2901. }
  2902. m.PeerTrustedCAPath = string(dAtA[iNdEx:postIndex])
  2903. iNdEx = postIndex
  2904. default:
  2905. iNdEx = preIndex
  2906. skippy, err := skipRpc(dAtA[iNdEx:])
  2907. if err != nil {
  2908. return err
  2909. }
  2910. if skippy < 0 {
  2911. return ErrInvalidLengthRpc
  2912. }
  2913. if (iNdEx + skippy) > l {
  2914. return io.ErrUnexpectedEOF
  2915. }
  2916. iNdEx += skippy
  2917. }
  2918. }
  2919. if iNdEx > l {
  2920. return io.ErrUnexpectedEOF
  2921. }
  2922. return nil
  2923. }
  2924. func (m *Tester) Unmarshal(dAtA []byte) error {
  2925. l := len(dAtA)
  2926. iNdEx := 0
  2927. for iNdEx < l {
  2928. preIndex := iNdEx
  2929. var wire uint64
  2930. for shift := uint(0); ; shift += 7 {
  2931. if shift >= 64 {
  2932. return ErrIntOverflowRpc
  2933. }
  2934. if iNdEx >= l {
  2935. return io.ErrUnexpectedEOF
  2936. }
  2937. b := dAtA[iNdEx]
  2938. iNdEx++
  2939. wire |= (uint64(b) & 0x7F) << shift
  2940. if b < 0x80 {
  2941. break
  2942. }
  2943. }
  2944. fieldNum := int32(wire >> 3)
  2945. wireType := int(wire & 0x7)
  2946. if wireType == 4 {
  2947. return fmt.Errorf("proto: Tester: wiretype end group for non-group")
  2948. }
  2949. if fieldNum <= 0 {
  2950. return fmt.Errorf("proto: Tester: illegal tag %d (wire type %d)", fieldNum, wire)
  2951. }
  2952. switch fieldNum {
  2953. case 1:
  2954. if wireType != 2 {
  2955. return fmt.Errorf("proto: wrong wireType = %d for field TesterDataDir", wireType)
  2956. }
  2957. var stringLen uint64
  2958. for shift := uint(0); ; shift += 7 {
  2959. if shift >= 64 {
  2960. return ErrIntOverflowRpc
  2961. }
  2962. if iNdEx >= l {
  2963. return io.ErrUnexpectedEOF
  2964. }
  2965. b := dAtA[iNdEx]
  2966. iNdEx++
  2967. stringLen |= (uint64(b) & 0x7F) << shift
  2968. if b < 0x80 {
  2969. break
  2970. }
  2971. }
  2972. intStringLen := int(stringLen)
  2973. if intStringLen < 0 {
  2974. return ErrInvalidLengthRpc
  2975. }
  2976. postIndex := iNdEx + intStringLen
  2977. if postIndex > l {
  2978. return io.ErrUnexpectedEOF
  2979. }
  2980. m.TesterDataDir = string(dAtA[iNdEx:postIndex])
  2981. iNdEx = postIndex
  2982. case 2:
  2983. if wireType != 2 {
  2984. return fmt.Errorf("proto: wrong wireType = %d for field TesterNetwork", wireType)
  2985. }
  2986. var stringLen uint64
  2987. for shift := uint(0); ; shift += 7 {
  2988. if shift >= 64 {
  2989. return ErrIntOverflowRpc
  2990. }
  2991. if iNdEx >= l {
  2992. return io.ErrUnexpectedEOF
  2993. }
  2994. b := dAtA[iNdEx]
  2995. iNdEx++
  2996. stringLen |= (uint64(b) & 0x7F) << shift
  2997. if b < 0x80 {
  2998. break
  2999. }
  3000. }
  3001. intStringLen := int(stringLen)
  3002. if intStringLen < 0 {
  3003. return ErrInvalidLengthRpc
  3004. }
  3005. postIndex := iNdEx + intStringLen
  3006. if postIndex > l {
  3007. return io.ErrUnexpectedEOF
  3008. }
  3009. m.TesterNetwork = string(dAtA[iNdEx:postIndex])
  3010. iNdEx = postIndex
  3011. case 3:
  3012. if wireType != 2 {
  3013. return fmt.Errorf("proto: wrong wireType = %d for field TesterAddr", wireType)
  3014. }
  3015. var stringLen uint64
  3016. for shift := uint(0); ; shift += 7 {
  3017. if shift >= 64 {
  3018. return ErrIntOverflowRpc
  3019. }
  3020. if iNdEx >= l {
  3021. return io.ErrUnexpectedEOF
  3022. }
  3023. b := dAtA[iNdEx]
  3024. iNdEx++
  3025. stringLen |= (uint64(b) & 0x7F) << shift
  3026. if b < 0x80 {
  3027. break
  3028. }
  3029. }
  3030. intStringLen := int(stringLen)
  3031. if intStringLen < 0 {
  3032. return ErrInvalidLengthRpc
  3033. }
  3034. postIndex := iNdEx + intStringLen
  3035. if postIndex > l {
  3036. return io.ErrUnexpectedEOF
  3037. }
  3038. m.TesterAddr = string(dAtA[iNdEx:postIndex])
  3039. iNdEx = postIndex
  3040. case 11:
  3041. if wireType != 0 {
  3042. return fmt.Errorf("proto: wrong wireType = %d for field DelayLatencyMs", wireType)
  3043. }
  3044. m.DelayLatencyMs = 0
  3045. for shift := uint(0); ; shift += 7 {
  3046. if shift >= 64 {
  3047. return ErrIntOverflowRpc
  3048. }
  3049. if iNdEx >= l {
  3050. return io.ErrUnexpectedEOF
  3051. }
  3052. b := dAtA[iNdEx]
  3053. iNdEx++
  3054. m.DelayLatencyMs |= (uint32(b) & 0x7F) << shift
  3055. if b < 0x80 {
  3056. break
  3057. }
  3058. }
  3059. case 12:
  3060. if wireType != 0 {
  3061. return fmt.Errorf("proto: wrong wireType = %d for field DelayLatencyMsRv", wireType)
  3062. }
  3063. m.DelayLatencyMsRv = 0
  3064. for shift := uint(0); ; shift += 7 {
  3065. if shift >= 64 {
  3066. return ErrIntOverflowRpc
  3067. }
  3068. if iNdEx >= l {
  3069. return io.ErrUnexpectedEOF
  3070. }
  3071. b := dAtA[iNdEx]
  3072. iNdEx++
  3073. m.DelayLatencyMsRv |= (uint32(b) & 0x7F) << shift
  3074. if b < 0x80 {
  3075. break
  3076. }
  3077. }
  3078. case 13:
  3079. if wireType != 0 {
  3080. return fmt.Errorf("proto: wrong wireType = %d for field UpdatedDelayLatencyMs", wireType)
  3081. }
  3082. m.UpdatedDelayLatencyMs = 0
  3083. for shift := uint(0); ; shift += 7 {
  3084. if shift >= 64 {
  3085. return ErrIntOverflowRpc
  3086. }
  3087. if iNdEx >= l {
  3088. return io.ErrUnexpectedEOF
  3089. }
  3090. b := dAtA[iNdEx]
  3091. iNdEx++
  3092. m.UpdatedDelayLatencyMs |= (uint32(b) & 0x7F) << shift
  3093. if b < 0x80 {
  3094. break
  3095. }
  3096. }
  3097. case 21:
  3098. if wireType != 0 {
  3099. return fmt.Errorf("proto: wrong wireType = %d for field RoundLimit", wireType)
  3100. }
  3101. m.RoundLimit = 0
  3102. for shift := uint(0); ; shift += 7 {
  3103. if shift >= 64 {
  3104. return ErrIntOverflowRpc
  3105. }
  3106. if iNdEx >= l {
  3107. return io.ErrUnexpectedEOF
  3108. }
  3109. b := dAtA[iNdEx]
  3110. iNdEx++
  3111. m.RoundLimit |= (int32(b) & 0x7F) << shift
  3112. if b < 0x80 {
  3113. break
  3114. }
  3115. }
  3116. case 22:
  3117. if wireType != 0 {
  3118. return fmt.Errorf("proto: wrong wireType = %d for field ExitOnFailure", wireType)
  3119. }
  3120. var v int
  3121. for shift := uint(0); ; shift += 7 {
  3122. if shift >= 64 {
  3123. return ErrIntOverflowRpc
  3124. }
  3125. if iNdEx >= l {
  3126. return io.ErrUnexpectedEOF
  3127. }
  3128. b := dAtA[iNdEx]
  3129. iNdEx++
  3130. v |= (int(b) & 0x7F) << shift
  3131. if b < 0x80 {
  3132. break
  3133. }
  3134. }
  3135. m.ExitOnFailure = bool(v != 0)
  3136. case 23:
  3137. if wireType != 0 {
  3138. return fmt.Errorf("proto: wrong wireType = %d for field ConsistencyCheck", wireType)
  3139. }
  3140. var v int
  3141. for shift := uint(0); ; shift += 7 {
  3142. if shift >= 64 {
  3143. return ErrIntOverflowRpc
  3144. }
  3145. if iNdEx >= l {
  3146. return io.ErrUnexpectedEOF
  3147. }
  3148. b := dAtA[iNdEx]
  3149. iNdEx++
  3150. v |= (int(b) & 0x7F) << shift
  3151. if b < 0x80 {
  3152. break
  3153. }
  3154. }
  3155. m.ConsistencyCheck = bool(v != 0)
  3156. case 24:
  3157. if wireType != 0 {
  3158. return fmt.Errorf("proto: wrong wireType = %d for field EnablePprof", wireType)
  3159. }
  3160. var v int
  3161. for shift := uint(0); ; shift += 7 {
  3162. if shift >= 64 {
  3163. return ErrIntOverflowRpc
  3164. }
  3165. if iNdEx >= l {
  3166. return io.ErrUnexpectedEOF
  3167. }
  3168. b := dAtA[iNdEx]
  3169. iNdEx++
  3170. v |= (int(b) & 0x7F) << shift
  3171. if b < 0x80 {
  3172. break
  3173. }
  3174. }
  3175. m.EnablePprof = bool(v != 0)
  3176. case 31:
  3177. if wireType != 2 {
  3178. return fmt.Errorf("proto: wrong wireType = %d for field FailureCases", wireType)
  3179. }
  3180. var stringLen uint64
  3181. for shift := uint(0); ; shift += 7 {
  3182. if shift >= 64 {
  3183. return ErrIntOverflowRpc
  3184. }
  3185. if iNdEx >= l {
  3186. return io.ErrUnexpectedEOF
  3187. }
  3188. b := dAtA[iNdEx]
  3189. iNdEx++
  3190. stringLen |= (uint64(b) & 0x7F) << shift
  3191. if b < 0x80 {
  3192. break
  3193. }
  3194. }
  3195. intStringLen := int(stringLen)
  3196. if intStringLen < 0 {
  3197. return ErrInvalidLengthRpc
  3198. }
  3199. postIndex := iNdEx + intStringLen
  3200. if postIndex > l {
  3201. return io.ErrUnexpectedEOF
  3202. }
  3203. m.FailureCases = append(m.FailureCases, string(dAtA[iNdEx:postIndex]))
  3204. iNdEx = postIndex
  3205. case 32:
  3206. if wireType != 0 {
  3207. return fmt.Errorf("proto: wrong wireType = %d for field FailureDelayMs", wireType)
  3208. }
  3209. m.FailureDelayMs = 0
  3210. for shift := uint(0); ; shift += 7 {
  3211. if shift >= 64 {
  3212. return ErrIntOverflowRpc
  3213. }
  3214. if iNdEx >= l {
  3215. return io.ErrUnexpectedEOF
  3216. }
  3217. b := dAtA[iNdEx]
  3218. iNdEx++
  3219. m.FailureDelayMs |= (uint32(b) & 0x7F) << shift
  3220. if b < 0x80 {
  3221. break
  3222. }
  3223. }
  3224. case 33:
  3225. if wireType != 0 {
  3226. return fmt.Errorf("proto: wrong wireType = %d for field FailureShuffle", wireType)
  3227. }
  3228. var v int
  3229. for shift := uint(0); ; shift += 7 {
  3230. if shift >= 64 {
  3231. return ErrIntOverflowRpc
  3232. }
  3233. if iNdEx >= l {
  3234. return io.ErrUnexpectedEOF
  3235. }
  3236. b := dAtA[iNdEx]
  3237. iNdEx++
  3238. v |= (int(b) & 0x7F) << shift
  3239. if b < 0x80 {
  3240. break
  3241. }
  3242. }
  3243. m.FailureShuffle = bool(v != 0)
  3244. case 34:
  3245. if wireType != 2 {
  3246. return fmt.Errorf("proto: wrong wireType = %d for field FailpointCommands", wireType)
  3247. }
  3248. var stringLen uint64
  3249. for shift := uint(0); ; shift += 7 {
  3250. if shift >= 64 {
  3251. return ErrIntOverflowRpc
  3252. }
  3253. if iNdEx >= l {
  3254. return io.ErrUnexpectedEOF
  3255. }
  3256. b := dAtA[iNdEx]
  3257. iNdEx++
  3258. stringLen |= (uint64(b) & 0x7F) << shift
  3259. if b < 0x80 {
  3260. break
  3261. }
  3262. }
  3263. intStringLen := int(stringLen)
  3264. if intStringLen < 0 {
  3265. return ErrInvalidLengthRpc
  3266. }
  3267. postIndex := iNdEx + intStringLen
  3268. if postIndex > l {
  3269. return io.ErrUnexpectedEOF
  3270. }
  3271. m.FailpointCommands = append(m.FailpointCommands, string(dAtA[iNdEx:postIndex]))
  3272. iNdEx = postIndex
  3273. case 41:
  3274. if wireType != 2 {
  3275. return fmt.Errorf("proto: wrong wireType = %d for field RunnerExecPath", wireType)
  3276. }
  3277. var stringLen uint64
  3278. for shift := uint(0); ; shift += 7 {
  3279. if shift >= 64 {
  3280. return ErrIntOverflowRpc
  3281. }
  3282. if iNdEx >= l {
  3283. return io.ErrUnexpectedEOF
  3284. }
  3285. b := dAtA[iNdEx]
  3286. iNdEx++
  3287. stringLen |= (uint64(b) & 0x7F) << shift
  3288. if b < 0x80 {
  3289. break
  3290. }
  3291. }
  3292. intStringLen := int(stringLen)
  3293. if intStringLen < 0 {
  3294. return ErrInvalidLengthRpc
  3295. }
  3296. postIndex := iNdEx + intStringLen
  3297. if postIndex > l {
  3298. return io.ErrUnexpectedEOF
  3299. }
  3300. m.RunnerExecPath = string(dAtA[iNdEx:postIndex])
  3301. iNdEx = postIndex
  3302. case 42:
  3303. if wireType != 2 {
  3304. return fmt.Errorf("proto: wrong wireType = %d for field ExternalExecPath", wireType)
  3305. }
  3306. var stringLen uint64
  3307. for shift := uint(0); ; shift += 7 {
  3308. if shift >= 64 {
  3309. return ErrIntOverflowRpc
  3310. }
  3311. if iNdEx >= l {
  3312. return io.ErrUnexpectedEOF
  3313. }
  3314. b := dAtA[iNdEx]
  3315. iNdEx++
  3316. stringLen |= (uint64(b) & 0x7F) << shift
  3317. if b < 0x80 {
  3318. break
  3319. }
  3320. }
  3321. intStringLen := int(stringLen)
  3322. if intStringLen < 0 {
  3323. return ErrInvalidLengthRpc
  3324. }
  3325. postIndex := iNdEx + intStringLen
  3326. if postIndex > l {
  3327. return io.ErrUnexpectedEOF
  3328. }
  3329. m.ExternalExecPath = string(dAtA[iNdEx:postIndex])
  3330. iNdEx = postIndex
  3331. case 101:
  3332. if wireType != 2 {
  3333. return fmt.Errorf("proto: wrong wireType = %d for field StressTypes", wireType)
  3334. }
  3335. var stringLen uint64
  3336. for shift := uint(0); ; shift += 7 {
  3337. if shift >= 64 {
  3338. return ErrIntOverflowRpc
  3339. }
  3340. if iNdEx >= l {
  3341. return io.ErrUnexpectedEOF
  3342. }
  3343. b := dAtA[iNdEx]
  3344. iNdEx++
  3345. stringLen |= (uint64(b) & 0x7F) << shift
  3346. if b < 0x80 {
  3347. break
  3348. }
  3349. }
  3350. intStringLen := int(stringLen)
  3351. if intStringLen < 0 {
  3352. return ErrInvalidLengthRpc
  3353. }
  3354. postIndex := iNdEx + intStringLen
  3355. if postIndex > l {
  3356. return io.ErrUnexpectedEOF
  3357. }
  3358. m.StressTypes = append(m.StressTypes, string(dAtA[iNdEx:postIndex]))
  3359. iNdEx = postIndex
  3360. case 102:
  3361. if wireType != 0 {
  3362. return fmt.Errorf("proto: wrong wireType = %d for field StressKeySize", wireType)
  3363. }
  3364. m.StressKeySize = 0
  3365. for shift := uint(0); ; shift += 7 {
  3366. if shift >= 64 {
  3367. return ErrIntOverflowRpc
  3368. }
  3369. if iNdEx >= l {
  3370. return io.ErrUnexpectedEOF
  3371. }
  3372. b := dAtA[iNdEx]
  3373. iNdEx++
  3374. m.StressKeySize |= (int32(b) & 0x7F) << shift
  3375. if b < 0x80 {
  3376. break
  3377. }
  3378. }
  3379. case 103:
  3380. if wireType != 0 {
  3381. return fmt.Errorf("proto: wrong wireType = %d for field StressKeySizeLarge", wireType)
  3382. }
  3383. m.StressKeySizeLarge = 0
  3384. for shift := uint(0); ; shift += 7 {
  3385. if shift >= 64 {
  3386. return ErrIntOverflowRpc
  3387. }
  3388. if iNdEx >= l {
  3389. return io.ErrUnexpectedEOF
  3390. }
  3391. b := dAtA[iNdEx]
  3392. iNdEx++
  3393. m.StressKeySizeLarge |= (int32(b) & 0x7F) << shift
  3394. if b < 0x80 {
  3395. break
  3396. }
  3397. }
  3398. case 104:
  3399. if wireType != 0 {
  3400. return fmt.Errorf("proto: wrong wireType = %d for field StressKeySuffixRange", wireType)
  3401. }
  3402. m.StressKeySuffixRange = 0
  3403. for shift := uint(0); ; shift += 7 {
  3404. if shift >= 64 {
  3405. return ErrIntOverflowRpc
  3406. }
  3407. if iNdEx >= l {
  3408. return io.ErrUnexpectedEOF
  3409. }
  3410. b := dAtA[iNdEx]
  3411. iNdEx++
  3412. m.StressKeySuffixRange |= (int32(b) & 0x7F) << shift
  3413. if b < 0x80 {
  3414. break
  3415. }
  3416. }
  3417. case 105:
  3418. if wireType != 0 {
  3419. return fmt.Errorf("proto: wrong wireType = %d for field StressKeySuffixRangeTxn", wireType)
  3420. }
  3421. m.StressKeySuffixRangeTxn = 0
  3422. for shift := uint(0); ; shift += 7 {
  3423. if shift >= 64 {
  3424. return ErrIntOverflowRpc
  3425. }
  3426. if iNdEx >= l {
  3427. return io.ErrUnexpectedEOF
  3428. }
  3429. b := dAtA[iNdEx]
  3430. iNdEx++
  3431. m.StressKeySuffixRangeTxn |= (int32(b) & 0x7F) << shift
  3432. if b < 0x80 {
  3433. break
  3434. }
  3435. }
  3436. case 106:
  3437. if wireType != 0 {
  3438. return fmt.Errorf("proto: wrong wireType = %d for field StressKeyTxnOps", wireType)
  3439. }
  3440. m.StressKeyTxnOps = 0
  3441. for shift := uint(0); ; shift += 7 {
  3442. if shift >= 64 {
  3443. return ErrIntOverflowRpc
  3444. }
  3445. if iNdEx >= l {
  3446. return io.ErrUnexpectedEOF
  3447. }
  3448. b := dAtA[iNdEx]
  3449. iNdEx++
  3450. m.StressKeyTxnOps |= (int32(b) & 0x7F) << shift
  3451. if b < 0x80 {
  3452. break
  3453. }
  3454. }
  3455. case 201:
  3456. if wireType != 0 {
  3457. return fmt.Errorf("proto: wrong wireType = %d for field StressClients", wireType)
  3458. }
  3459. m.StressClients = 0
  3460. for shift := uint(0); ; shift += 7 {
  3461. if shift >= 64 {
  3462. return ErrIntOverflowRpc
  3463. }
  3464. if iNdEx >= l {
  3465. return io.ErrUnexpectedEOF
  3466. }
  3467. b := dAtA[iNdEx]
  3468. iNdEx++
  3469. m.StressClients |= (int32(b) & 0x7F) << shift
  3470. if b < 0x80 {
  3471. break
  3472. }
  3473. }
  3474. case 202:
  3475. if wireType != 0 {
  3476. return fmt.Errorf("proto: wrong wireType = %d for field StressQPS", wireType)
  3477. }
  3478. m.StressQPS = 0
  3479. for shift := uint(0); ; shift += 7 {
  3480. if shift >= 64 {
  3481. return ErrIntOverflowRpc
  3482. }
  3483. if iNdEx >= l {
  3484. return io.ErrUnexpectedEOF
  3485. }
  3486. b := dAtA[iNdEx]
  3487. iNdEx++
  3488. m.StressQPS |= (int32(b) & 0x7F) << shift
  3489. if b < 0x80 {
  3490. break
  3491. }
  3492. }
  3493. default:
  3494. iNdEx = preIndex
  3495. skippy, err := skipRpc(dAtA[iNdEx:])
  3496. if err != nil {
  3497. return err
  3498. }
  3499. if skippy < 0 {
  3500. return ErrInvalidLengthRpc
  3501. }
  3502. if (iNdEx + skippy) > l {
  3503. return io.ErrUnexpectedEOF
  3504. }
  3505. iNdEx += skippy
  3506. }
  3507. }
  3508. if iNdEx > l {
  3509. return io.ErrUnexpectedEOF
  3510. }
  3511. return nil
  3512. }
  3513. func (m *Request) Unmarshal(dAtA []byte) error {
  3514. l := len(dAtA)
  3515. iNdEx := 0
  3516. for iNdEx < l {
  3517. preIndex := iNdEx
  3518. var wire uint64
  3519. for shift := uint(0); ; shift += 7 {
  3520. if shift >= 64 {
  3521. return ErrIntOverflowRpc
  3522. }
  3523. if iNdEx >= l {
  3524. return io.ErrUnexpectedEOF
  3525. }
  3526. b := dAtA[iNdEx]
  3527. iNdEx++
  3528. wire |= (uint64(b) & 0x7F) << shift
  3529. if b < 0x80 {
  3530. break
  3531. }
  3532. }
  3533. fieldNum := int32(wire >> 3)
  3534. wireType := int(wire & 0x7)
  3535. if wireType == 4 {
  3536. return fmt.Errorf("proto: Request: wiretype end group for non-group")
  3537. }
  3538. if fieldNum <= 0 {
  3539. return fmt.Errorf("proto: Request: illegal tag %d (wire type %d)", fieldNum, wire)
  3540. }
  3541. switch fieldNum {
  3542. case 1:
  3543. if wireType != 0 {
  3544. return fmt.Errorf("proto: wrong wireType = %d for field Operation", wireType)
  3545. }
  3546. m.Operation = 0
  3547. for shift := uint(0); ; shift += 7 {
  3548. if shift >= 64 {
  3549. return ErrIntOverflowRpc
  3550. }
  3551. if iNdEx >= l {
  3552. return io.ErrUnexpectedEOF
  3553. }
  3554. b := dAtA[iNdEx]
  3555. iNdEx++
  3556. m.Operation |= (Operation(b) & 0x7F) << shift
  3557. if b < 0x80 {
  3558. break
  3559. }
  3560. }
  3561. case 2:
  3562. if wireType != 2 {
  3563. return fmt.Errorf("proto: wrong wireType = %d for field Member", wireType)
  3564. }
  3565. var msglen int
  3566. for shift := uint(0); ; shift += 7 {
  3567. if shift >= 64 {
  3568. return ErrIntOverflowRpc
  3569. }
  3570. if iNdEx >= l {
  3571. return io.ErrUnexpectedEOF
  3572. }
  3573. b := dAtA[iNdEx]
  3574. iNdEx++
  3575. msglen |= (int(b) & 0x7F) << shift
  3576. if b < 0x80 {
  3577. break
  3578. }
  3579. }
  3580. if msglen < 0 {
  3581. return ErrInvalidLengthRpc
  3582. }
  3583. postIndex := iNdEx + msglen
  3584. if postIndex > l {
  3585. return io.ErrUnexpectedEOF
  3586. }
  3587. if m.Member == nil {
  3588. m.Member = &Member{}
  3589. }
  3590. if err := m.Member.Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
  3591. return err
  3592. }
  3593. iNdEx = postIndex
  3594. case 3:
  3595. if wireType != 2 {
  3596. return fmt.Errorf("proto: wrong wireType = %d for field Tester", wireType)
  3597. }
  3598. var msglen int
  3599. for shift := uint(0); ; shift += 7 {
  3600. if shift >= 64 {
  3601. return ErrIntOverflowRpc
  3602. }
  3603. if iNdEx >= l {
  3604. return io.ErrUnexpectedEOF
  3605. }
  3606. b := dAtA[iNdEx]
  3607. iNdEx++
  3608. msglen |= (int(b) & 0x7F) << shift
  3609. if b < 0x80 {
  3610. break
  3611. }
  3612. }
  3613. if msglen < 0 {
  3614. return ErrInvalidLengthRpc
  3615. }
  3616. postIndex := iNdEx + msglen
  3617. if postIndex > l {
  3618. return io.ErrUnexpectedEOF
  3619. }
  3620. if m.Tester == nil {
  3621. m.Tester = &Tester{}
  3622. }
  3623. if err := m.Tester.Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
  3624. return err
  3625. }
  3626. iNdEx = postIndex
  3627. default:
  3628. iNdEx = preIndex
  3629. skippy, err := skipRpc(dAtA[iNdEx:])
  3630. if err != nil {
  3631. return err
  3632. }
  3633. if skippy < 0 {
  3634. return ErrInvalidLengthRpc
  3635. }
  3636. if (iNdEx + skippy) > l {
  3637. return io.ErrUnexpectedEOF
  3638. }
  3639. iNdEx += skippy
  3640. }
  3641. }
  3642. if iNdEx > l {
  3643. return io.ErrUnexpectedEOF
  3644. }
  3645. return nil
  3646. }
  3647. func (m *Response) Unmarshal(dAtA []byte) error {
  3648. l := len(dAtA)
  3649. iNdEx := 0
  3650. for iNdEx < l {
  3651. preIndex := iNdEx
  3652. var wire uint64
  3653. for shift := uint(0); ; shift += 7 {
  3654. if shift >= 64 {
  3655. return ErrIntOverflowRpc
  3656. }
  3657. if iNdEx >= l {
  3658. return io.ErrUnexpectedEOF
  3659. }
  3660. b := dAtA[iNdEx]
  3661. iNdEx++
  3662. wire |= (uint64(b) & 0x7F) << shift
  3663. if b < 0x80 {
  3664. break
  3665. }
  3666. }
  3667. fieldNum := int32(wire >> 3)
  3668. wireType := int(wire & 0x7)
  3669. if wireType == 4 {
  3670. return fmt.Errorf("proto: Response: wiretype end group for non-group")
  3671. }
  3672. if fieldNum <= 0 {
  3673. return fmt.Errorf("proto: Response: illegal tag %d (wire type %d)", fieldNum, wire)
  3674. }
  3675. switch fieldNum {
  3676. case 1:
  3677. if wireType != 0 {
  3678. return fmt.Errorf("proto: wrong wireType = %d for field Success", wireType)
  3679. }
  3680. var v int
  3681. for shift := uint(0); ; shift += 7 {
  3682. if shift >= 64 {
  3683. return ErrIntOverflowRpc
  3684. }
  3685. if iNdEx >= l {
  3686. return io.ErrUnexpectedEOF
  3687. }
  3688. b := dAtA[iNdEx]
  3689. iNdEx++
  3690. v |= (int(b) & 0x7F) << shift
  3691. if b < 0x80 {
  3692. break
  3693. }
  3694. }
  3695. m.Success = bool(v != 0)
  3696. case 2:
  3697. if wireType != 2 {
  3698. return fmt.Errorf("proto: wrong wireType = %d for field Status", wireType)
  3699. }
  3700. var stringLen uint64
  3701. for shift := uint(0); ; shift += 7 {
  3702. if shift >= 64 {
  3703. return ErrIntOverflowRpc
  3704. }
  3705. if iNdEx >= l {
  3706. return io.ErrUnexpectedEOF
  3707. }
  3708. b := dAtA[iNdEx]
  3709. iNdEx++
  3710. stringLen |= (uint64(b) & 0x7F) << shift
  3711. if b < 0x80 {
  3712. break
  3713. }
  3714. }
  3715. intStringLen := int(stringLen)
  3716. if intStringLen < 0 {
  3717. return ErrInvalidLengthRpc
  3718. }
  3719. postIndex := iNdEx + intStringLen
  3720. if postIndex > l {
  3721. return io.ErrUnexpectedEOF
  3722. }
  3723. m.Status = string(dAtA[iNdEx:postIndex])
  3724. iNdEx = postIndex
  3725. case 3:
  3726. if wireType != 2 {
  3727. return fmt.Errorf("proto: wrong wireType = %d for field Member", wireType)
  3728. }
  3729. var msglen int
  3730. for shift := uint(0); ; shift += 7 {
  3731. if shift >= 64 {
  3732. return ErrIntOverflowRpc
  3733. }
  3734. if iNdEx >= l {
  3735. return io.ErrUnexpectedEOF
  3736. }
  3737. b := dAtA[iNdEx]
  3738. iNdEx++
  3739. msglen |= (int(b) & 0x7F) << shift
  3740. if b < 0x80 {
  3741. break
  3742. }
  3743. }
  3744. if msglen < 0 {
  3745. return ErrInvalidLengthRpc
  3746. }
  3747. postIndex := iNdEx + msglen
  3748. if postIndex > l {
  3749. return io.ErrUnexpectedEOF
  3750. }
  3751. if m.Member == nil {
  3752. m.Member = &Member{}
  3753. }
  3754. if err := m.Member.Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
  3755. return err
  3756. }
  3757. iNdEx = postIndex
  3758. default:
  3759. iNdEx = preIndex
  3760. skippy, err := skipRpc(dAtA[iNdEx:])
  3761. if err != nil {
  3762. return err
  3763. }
  3764. if skippy < 0 {
  3765. return ErrInvalidLengthRpc
  3766. }
  3767. if (iNdEx + skippy) > l {
  3768. return io.ErrUnexpectedEOF
  3769. }
  3770. iNdEx += skippy
  3771. }
  3772. }
  3773. if iNdEx > l {
  3774. return io.ErrUnexpectedEOF
  3775. }
  3776. return nil
  3777. }
  3778. func skipRpc(dAtA []byte) (n int, err error) {
  3779. l := len(dAtA)
  3780. iNdEx := 0
  3781. for iNdEx < l {
  3782. var wire uint64
  3783. for shift := uint(0); ; shift += 7 {
  3784. if shift >= 64 {
  3785. return 0, ErrIntOverflowRpc
  3786. }
  3787. if iNdEx >= l {
  3788. return 0, io.ErrUnexpectedEOF
  3789. }
  3790. b := dAtA[iNdEx]
  3791. iNdEx++
  3792. wire |= (uint64(b) & 0x7F) << shift
  3793. if b < 0x80 {
  3794. break
  3795. }
  3796. }
  3797. wireType := int(wire & 0x7)
  3798. switch wireType {
  3799. case 0:
  3800. for shift := uint(0); ; shift += 7 {
  3801. if shift >= 64 {
  3802. return 0, ErrIntOverflowRpc
  3803. }
  3804. if iNdEx >= l {
  3805. return 0, io.ErrUnexpectedEOF
  3806. }
  3807. iNdEx++
  3808. if dAtA[iNdEx-1] < 0x80 {
  3809. break
  3810. }
  3811. }
  3812. return iNdEx, nil
  3813. case 1:
  3814. iNdEx += 8
  3815. return iNdEx, nil
  3816. case 2:
  3817. var length int
  3818. for shift := uint(0); ; shift += 7 {
  3819. if shift >= 64 {
  3820. return 0, ErrIntOverflowRpc
  3821. }
  3822. if iNdEx >= l {
  3823. return 0, io.ErrUnexpectedEOF
  3824. }
  3825. b := dAtA[iNdEx]
  3826. iNdEx++
  3827. length |= (int(b) & 0x7F) << shift
  3828. if b < 0x80 {
  3829. break
  3830. }
  3831. }
  3832. iNdEx += length
  3833. if length < 0 {
  3834. return 0, ErrInvalidLengthRpc
  3835. }
  3836. return iNdEx, nil
  3837. case 3:
  3838. for {
  3839. var innerWire uint64
  3840. var start int = iNdEx
  3841. for shift := uint(0); ; shift += 7 {
  3842. if shift >= 64 {
  3843. return 0, ErrIntOverflowRpc
  3844. }
  3845. if iNdEx >= l {
  3846. return 0, io.ErrUnexpectedEOF
  3847. }
  3848. b := dAtA[iNdEx]
  3849. iNdEx++
  3850. innerWire |= (uint64(b) & 0x7F) << shift
  3851. if b < 0x80 {
  3852. break
  3853. }
  3854. }
  3855. innerWireType := int(innerWire & 0x7)
  3856. if innerWireType == 4 {
  3857. break
  3858. }
  3859. next, err := skipRpc(dAtA[start:])
  3860. if err != nil {
  3861. return 0, err
  3862. }
  3863. iNdEx = start + next
  3864. }
  3865. return iNdEx, nil
  3866. case 4:
  3867. return iNdEx, nil
  3868. case 5:
  3869. iNdEx += 4
  3870. return iNdEx, nil
  3871. default:
  3872. return 0, fmt.Errorf("proto: illegal wireType %d", wireType)
  3873. }
  3874. }
  3875. panic("unreachable")
  3876. }
  3877. var (
  3878. ErrInvalidLengthRpc = fmt.Errorf("proto: negative length found during unmarshaling")
  3879. ErrIntOverflowRpc = fmt.Errorf("proto: integer overflow")
  3880. )
  3881. func init() { proto.RegisterFile("rpcpb/rpc.proto", fileDescriptorRpc) }
  3882. var fileDescriptorRpc = []byte{
  3883. // 2480 bytes of a gzipped FileDescriptorProto
  3884. 0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0x8c, 0x59, 0x5b, 0x57, 0xdb, 0xd8,
  3885. 0x15, 0x46, 0x38, 0x30, 0x70, 0xb8, 0x99, 0x43, 0x08, 0x4a, 0x32, 0xc1, 0x44, 0x99, 0xa4, 0x84,
  3886. 0x56, 0xa4, 0x4d, 0x66, 0xb5, 0x4d, 0xe6, 0x92, 0x18, 0xa3, 0x04, 0x17, 0x61, 0x3b, 0xc7, 0x22,
  3887. 0xc9, 0x3c, 0xb9, 0x42, 0x3e, 0xc6, 0x2a, 0x42, 0x72, 0xa4, 0x63, 0xc6, 0xcc, 0x1f, 0xe8, 0x6b,
  3888. 0xef, 0xab, 0x0f, 0x5d, 0xfd, 0x05, 0x9d, 0xfe, 0x8e, 0xcc, 0xf4, 0x36, 0x6d, 0xdf, 0xdd, 0x36,
  3889. 0x5d, 0xfd, 0x03, 0x5e, 0xbd, 0x4d, 0x9f, 0xba, 0xce, 0xc5, 0xf6, 0x91, 0x6c, 0x43, 0xde, 0x7c,
  3890. 0xf6, 0xfe, 0xbe, 0x4f, 0xfb, 0xec, 0x2d, 0x9d, 0xbd, 0x0f, 0x80, 0x85, 0xb0, 0xe1, 0x34, 0x0e,
  3891. 0xee, 0x84, 0x0d, 0x67, 0xb3, 0x11, 0x06, 0x24, 0x80, 0x13, 0xcc, 0x70, 0x45, 0x3f, 0x74, 0x49,
  3892. 0xbd, 0x79, 0xb0, 0xe9, 0x04, 0xc7, 0x77, 0x0e, 0x83, 0xc3, 0xe0, 0x0e, 0xf3, 0x1e, 0x34, 0x6b,
  3893. 0x6c, 0xc5, 0x16, 0xec, 0x17, 0x67, 0x69, 0x5f, 0xce, 0x81, 0x0b, 0x06, 0x71, 0xaa, 0xf0, 0x06,
  3894. 0xb8, 0x50, 0xb0, 0x8f, 0xb1, 0xaa, 0xac, 0x29, 0xeb, 0xd3, 0x5b, 0x0b, 0x9d, 0x76, 0x66, 0xe6,
  3895. 0xd4, 0x3e, 0xf6, 0x1e, 0x68, 0xbe, 0x7d, 0x8c, 0x35, 0xc4, 0x9c, 0x50, 0x07, 0x6f, 0x6d, 0xdb,
  3896. 0xc4, 0xde, 0x76, 0x43, 0x75, 0x9c, 0xe1, 0x96, 0x3a, 0xed, 0xcc, 0x02, 0xc7, 0x55, 0x6d, 0x62,
  3897. 0xeb, 0x55, 0x37, 0xd4, 0x50, 0x17, 0x03, 0x37, 0xc0, 0xe4, 0xf3, 0xac, 0x49, 0xd1, 0x29, 0x86,
  3898. 0x86, 0x9d, 0x76, 0x66, 0x9e, 0xa3, 0x3f, 0xb6, 0x3d, 0x0e, 0x16, 0x08, 0x58, 0x04, 0x4b, 0x3b,
  3899. 0xd8, 0x0e, 0xc9, 0x01, 0xb6, 0x49, 0xde, 0x27, 0x38, 0x3c, 0xb1, 0xbd, 0xbd, 0x48, 0x9d, 0x59,
  3900. 0x53, 0xd6, 0x53, 0x5b, 0xd7, 0x3a, 0xed, 0xcc, 0x65, 0x4e, 0xac, 0x77, 0x41, 0xba, 0x2b, 0x50,
  3901. 0x1a, 0x1a, 0xc6, 0x84, 0x79, 0xb0, 0x68, 0x78, 0xd8, 0x21, 0x6e, 0xe0, 0x5b, 0xee, 0x31, 0x0e,
  3902. 0x9a, 0x64, 0x2f, 0x52, 0x67, 0x99, 0xdc, 0xd5, 0x4e, 0x3b, 0xb3, 0xc2, 0xe5, 0xb0, 0x80, 0xe8,
  3903. 0x84, 0x63, 0x34, 0x34, 0xc8, 0x82, 0x79, 0x90, 0x36, 0xdd, 0x88, 0x60, 0x3f, 0xe7, 0xb9, 0xd8,
  3904. 0x27, 0xfb, 0xc8, 0x8c, 0xd4, 0xe5, 0xb5, 0xd4, 0xfa, 0xb4, 0x1c, 0x98, 0xc7, 0x10, 0xba, 0xc3,
  3905. 0x20, 0x7a, 0x33, 0xf4, 0x22, 0x0d, 0x0d, 0xd0, 0x20, 0x02, 0x4b, 0xd9, 0xea, 0x09, 0x0e, 0x89,
  3906. 0x1b, 0x61, 0x49, 0xed, 0x12, 0x53, 0x5b, 0xeb, 0xb4, 0x33, 0x6f, 0x73, 0x35, 0xbb, 0x0b, 0x8a,
  3907. 0x0b, 0x0e, 0x23, 0xc3, 0xfb, 0x60, 0x8e, 0xaf, 0xb2, 0x4d, 0x12, 0x58, 0x66, 0x59, 0x5d, 0x59,
  3908. 0x53, 0xd6, 0xa7, 0xe4, 0xda, 0xd8, 0x4d, 0x12, 0xe8, 0x84, 0x0a, 0xc4, 0x91, 0x30, 0x07, 0xe6,
  3909. 0xb9, 0x21, 0x87, 0x43, 0x6a, 0xac, 0xab, 0x2a, 0xe3, 0x4a, 0x19, 0x12, 0xcf, 0x77, 0x70, 0x48,
  3910. 0x74, 0xbb, 0x49, 0xea, 0x1a, 0x4a, 0x50, 0xe0, 0xfb, 0xb2, 0xc8, 0x63, 0xd7, 0xc3, 0xea, 0x65,
  3911. 0x56, 0xee, 0x8b, 0x9d, 0x76, 0x26, 0x2d, 0x44, 0x28, 0xbb, 0xe6, 0x7a, 0x38, 0xc6, 0xa6, 0xd8,
  3912. 0x7e, 0xf4, 0xbb, 0xf8, 0x94, 0x91, 0xaf, 0x24, 0xdf, 0xac, 0x23, 0x7c, 0x2a, 0xb8, 0x71, 0x24,
  3913. 0x34, 0xc1, 0x12, 0x37, 0x58, 0x61, 0x33, 0x22, 0xb8, 0x9a, 0xcb, 0x32, 0x81, 0xab, 0x4c, 0xe0,
  3914. 0x4a, 0xa7, 0x9d, 0xb9, 0xc4, 0x05, 0x08, 0x77, 0xeb, 0x8e, 0x2d, 0x74, 0x86, 0xd1, 0x68, 0x2e,
  3915. 0x78, 0xb9, 0x4a, 0x18, 0x87, 0xac, 0x2a, 0x19, 0x56, 0x15, 0x29, 0x17, 0xa2, 0xc6, 0x0d, 0x8c,
  3916. 0x43, 0x51, 0x90, 0x04, 0x05, 0x5a, 0x60, 0xb1, 0x57, 0xa2, 0x9e, 0xce, 0x1a, 0xd3, 0xb9, 0xd5,
  3917. 0x69, 0x67, 0x34, 0xae, 0xe3, 0xfa, 0x2e, 0x71, 0x6d, 0x4f, 0xef, 0x57, 0x59, 0x92, 0x1c, 0x14,
  3918. 0x80, 0x0f, 0xc0, 0x0c, 0xfd, 0xdd, 0xad, 0xef, 0x75, 0x56, 0x23, 0xb5, 0xd3, 0xce, 0x5c, 0xe4,
  3919. 0x7a, 0x8c, 0xdd, 0x2f, 0xb2, 0x0c, 0x86, 0x25, 0x00, 0xe9, 0x32, 0x51, 0x66, 0x8d, 0x49, 0x48,
  3920. 0x2f, 0x1c, 0x93, 0x18, 0xac, 0xf5, 0x10, 0x2e, 0xfc, 0x00, 0xcc, 0x32, 0x6b, 0xb7, 0xda, 0x37,
  3921. 0x58, 0xbe, 0x2f, 0x77, 0xda, 0x99, 0x65, 0x59, 0xab, 0x5f, 0xf2, 0x18, 0xbc, 0xbb, 0x99, 0x6e,
  3922. 0xb9, 0xdf, 0x61, 0xec, 0xe4, 0x66, 0xfa, 0x35, 0x97, 0xc1, 0x70, 0x0f, 0x2c, 0xd2, 0x65, 0xbc,
  3923. 0xde, 0x37, 0x99, 0x42, 0xa6, 0xd3, 0xce, 0x5c, 0x95, 0x14, 0x06, 0x8a, 0x3e, 0xc8, 0x84, 0x5b,
  3924. 0x60, 0x3e, 0xcf, 0x4b, 0x91, 0xf3, 0xa8, 0x3d, 0x54, 0x6f, 0x27, 0xdf, 0x9d, 0x6e, 0xa9, 0x1c,
  3925. 0x0e, 0xd0, 0x50, 0x82, 0x41, 0xbf, 0xe8, 0xb8, 0xa5, 0x4c, 0x6c, 0x82, 0xd5, 0x0d, 0x26, 0x24,
  3926. 0x25, 0x38, 0x21, 0xa4, 0x47, 0x14, 0xa6, 0xa1, 0x61, 0xe4, 0x41, 0x4d, 0x2b, 0x38, 0xc2, 0xbe,
  3927. 0xfa, 0xd5, 0xf3, 0x34, 0x09, 0x85, 0x0d, 0x68, 0x32, 0x32, 0x7c, 0x08, 0xe6, 0xca, 0xbe, 0xdd,
  3928. 0x88, 0xea, 0x01, 0xc9, 0x05, 0x4d, 0x9f, 0xa8, 0xf7, 0xd8, 0x59, 0x28, 0x95, 0x2d, 0x12, 0x6e,
  3929. 0xdd, 0xa1, 0x7e, 0x0d, 0xc5, 0xf1, 0xd0, 0x04, 0x8b, 0x4f, 0x9b, 0x01, 0xb1, 0xb7, 0x6c, 0xe7,
  3930. 0x08, 0xfb, 0xd5, 0xad, 0x53, 0x82, 0x23, 0xf5, 0x5d, 0x26, 0xb2, 0xda, 0x69, 0x67, 0xae, 0x70,
  3931. 0x91, 0x97, 0x14, 0xa2, 0x1f, 0x70, 0x8c, 0x7e, 0x40, 0x41, 0x1a, 0x1a, 0x24, 0xd2, 0x56, 0x52,
  3932. 0x0a, 0xf1, 0xb3, 0x80, 0x60, 0xf5, 0x61, 0xf2, 0xb8, 0x6a, 0x84, 0x58, 0x3f, 0x09, 0x68, 0x76,
  3933. 0xba, 0x18, 0x39, 0x23, 0x41, 0x18, 0x36, 0x1b, 0x24, 0x57, 0xc7, 0xce, 0x91, 0xfa, 0x28, 0xf9,
  3934. 0x1a, 0xf7, 0x32, 0xc2, 0x51, 0xba, 0x43, 0x61, 0x52, 0x46, 0x24, 0xb2, 0xf6, 0xcb, 0x19, 0x30,
  3935. 0xb9, 0x87, 0x8f, 0x0f, 0x70, 0x48, 0x5f, 0x69, 0xda, 0x05, 0x8d, 0x16, 0x76, 0x4a, 0x36, 0xa9,
  3936. 0x8b, 0x2e, 0x28, 0xe5, 0x06, 0x13, 0xa7, 0xaa, 0xe3, 0x16, 0x76, 0xf4, 0x86, 0x4d, 0xbf, 0x8b,
  3937. 0x18, 0x1c, 0xde, 0x03, 0xd3, 0xd9, 0x43, 0x7a, 0xac, 0x56, 0xab, 0x21, 0x6b, 0x59, 0xd3, 0x5b,
  3938. 0xcb, 0x9d, 0x76, 0x66, 0x51, 0x9c, 0xbe, 0xd4, 0xa5, 0xdb, 0xd5, 0x6a, 0xa8, 0xa1, 0x3e, 0x8e,
  3939. 0xe6, 0xf3, 0xb1, 0xed, 0x7a, 0x8d, 0xc0, 0xf5, 0xc9, 0x8e, 0x65, 0x95, 0x18, 0x79, 0x96, 0x91,
  3940. 0xa5, 0x7c, 0xd6, 0xba, 0x10, 0xbd, 0x4e, 0x48, 0x43, 0xa8, 0x0c, 0x12, 0x69, 0x3e, 0xb7, 0xec,
  3941. 0x08, 0xd3, 0x66, 0x8b, 0x93, 0x07, 0xe8, 0x81, 0x1d, 0x61, 0xd1, 0x9a, 0x05, 0x86, 0x7e, 0x84,
  3942. 0x74, 0x07, 0x66, 0x70, 0xc8, 0xf6, 0x5b, 0x4b, 0x7e, 0x84, 0x6c, 0xbf, 0x5e, 0x70, 0x28, 0xb6,
  3943. 0x2b, 0x83, 0xe1, 0x13, 0xb0, 0x40, 0x97, 0xfc, 0x54, 0x28, 0x85, 0x41, 0xeb, 0x54, 0xfd, 0x4c,
  3944. 0x61, 0x85, 0x78, 0xbb, 0xd3, 0xce, 0xa8, 0x92, 0x80, 0x38, 0x4f, 0x1a, 0x14, 0xa3, 0xa1, 0x24,
  3945. 0x0b, 0x66, 0xc1, 0x1c, 0x35, 0xd1, 0xef, 0x92, 0xcb, 0x7c, 0xce, 0x65, 0xa4, 0xcf, 0x8f, 0xc9,
  3946. 0xb0, 0xef, 0x59, 0x88, 0xc4, 0x19, 0xf4, 0x74, 0xeb, 0xab, 0x1a, 0x7e, 0x95, 0x25, 0x45, 0xfd,
  3947. 0x74, 0x3c, 0x79, 0x24, 0xc8, 0xe1, 0x60, 0x01, 0xd3, 0xd0, 0x10, 0x2e, 0xfc, 0x06, 0x1f, 0x88,
  3948. 0xd4, 0x5f, 0x53, 0x8d, 0x99, 0xbb, 0x33, 0x9b, 0x6c, 0xae, 0xda, 0xa4, 0x36, 0x79, 0x2c, 0xa2,
  3949. 0x82, 0x1a, 0xe2, 0xb3, 0xd3, 0xb6, 0xdc, 0x00, 0xe9, 0xf0, 0xa3, 0xfe, 0x90, 0x0f, 0x3c, 0x23,
  3950. 0xda, 0x28, 0x1d, 0x95, 0x62, 0x8d, 0x90, 0x72, 0xe2, 0x2a, 0xac, 0x2a, 0x3f, 0x3a, 0x53, 0x85,
  3951. 0x57, 0x26, 0xc1, 0xa1, 0x39, 0xed, 0x35, 0x49, 0x16, 0xca, 0x8f, 0x53, 0xc9, 0x23, 0x4d, 0x88,
  3952. 0xd0, 0x23, 0x96, 0x47, 0x12, 0x67, 0xc4, 0x24, 0x58, 0x1c, 0x3f, 0x39, 0x4b, 0x82, 0x87, 0x11,
  3953. 0x67, 0x40, 0x6b, 0xa0, 0x33, 0xb3, 0x58, 0x7e, 0xca, 0x85, 0xae, 0x77, 0xda, 0x99, 0x6b, 0x31,
  3954. 0x21, 0xe9, 0xb0, 0xe6, 0x21, 0x0d, 0xa3, 0x0f, 0x51, 0x65, 0xe1, 0xfd, 0xec, 0x0d, 0x54, 0x79,
  3955. 0x94, 0xc3, 0xe8, 0xf0, 0xc3, 0x7e, 0x3b, 0x63, 0x41, 0xfe, 0x2b, 0x35, 0xba, 0x9f, 0xf1, 0xe0,
  3956. 0x62, 0x78, 0x99, 0xcf, 0xc2, 0xf9, 0xf7, 0x19, 0x7c, 0x71, 0x78, 0xc8, 0x78, 0xf8, 0x5e, 0xaf,
  3957. 0x1f, 0xb2, 0xc7, 0xff, 0x27, 0x35, 0xb2, 0x21, 0xf2, 0xa7, 0xcb, 0x68, 0x89, 0xcc, 0x9e, 0xfd,
  3958. 0xdf, 0xd1, 0x64, 0xf1, 0x21, 0x4b, 0x68, 0x58, 0x48, 0x74, 0x53, 0xf6, 0xfc, 0x2f, 0x53, 0xe7,
  3959. 0xb5, 0x53, 0x1e, 0xc6, 0x20, 0x75, 0x40, 0x8f, 0x85, 0xf4, 0xbf, 0x73, 0xf5, 0x78, 0x64, 0x83,
  3960. 0x54, 0xed, 0x17, 0x73, 0x60, 0xd2, 0xc2, 0xac, 0xcb, 0x3e, 0x02, 0x73, 0xfc, 0x57, 0xf7, 0xfe,
  3961. 0xa1, 0x0c, 0x0c, 0x79, 0xcc, 0xad, 0xf7, 0xaf, 0x21, 0x71, 0x02, 0xed, 0x7f, 0xdc, 0x50, 0xc0,
  3962. 0xe4, 0xe3, 0x20, 0x3c, 0x12, 0x37, 0x18, 0xa9, 0x4c, 0x42, 0xc1, 0xe7, 0xfe, 0x9e, 0x80, 0xc0,
  3963. 0xc3, 0x6f, 0x02, 0xc0, 0x0d, 0xec, 0xa0, 0xe6, 0xbb, 0xba, 0xd4, 0x69, 0x67, 0x60, 0x8c, 0xcd,
  3964. 0x0f, 0x68, 0x09, 0x49, 0xe7, 0xca, 0x6d, 0xec, 0xd9, 0xa7, 0xa6, 0x4d, 0xb0, 0xef, 0x9c, 0x8a,
  3965. 0x4b, 0xcd, 0x9c, 0xfc, 0x59, 0x57, 0xa9, 0x5f, 0xf7, 0x38, 0x40, 0x3f, 0xa6, 0x73, 0x65, 0x9c,
  3966. 0x02, 0xbf, 0x03, 0xd2, 0x71, 0x0b, 0x3a, 0x61, 0xbd, 0x62, 0x4e, 0xee, 0x15, 0x49, 0x19, 0x3d,
  3967. 0x3c, 0xd1, 0xd0, 0x00, 0x0f, 0x7e, 0x04, 0x96, 0xf7, 0x1b, 0x55, 0x9b, 0xe0, 0x6a, 0x22, 0xae,
  3968. 0x39, 0x26, 0x78, 0xa3, 0xd3, 0xce, 0x64, 0xb8, 0x60, 0x93, 0xc3, 0xf4, 0xc1, 0xf8, 0x86, 0x2b,
  3969. 0xd0, 0x1c, 0xa1, 0xa0, 0xe9, 0x57, 0x4d, 0xf7, 0xd8, 0x25, 0xea, 0xf2, 0x9a, 0xb2, 0x3e, 0x21,
  3970. 0xe7, 0x28, 0xa4, 0x3e, 0xdd, 0xa3, 0x4e, 0x0d, 0x49, 0x48, 0x5a, 0x5e, 0xa3, 0xe5, 0x92, 0xa2,
  3971. 0x4f, 0x1b, 0x5b, 0x33, 0xc4, 0xea, 0xa5, 0x81, 0x46, 0xd0, 0x72, 0x89, 0x1e, 0xf8, 0x7a, 0x8d,
  3972. 0x03, 0x68, 0x23, 0x90, 0x09, 0x70, 0x07, 0xa4, 0x73, 0x81, 0x1f, 0xb1, 0x69, 0xdc, 0x39, 0xe5,
  3973. 0xd3, 0xc1, 0x4a, 0xb2, 0x29, 0x39, 0x7d, 0x44, 0x77, 0x32, 0x18, 0x60, 0xc1, 0xfb, 0x60, 0xc6,
  3974. 0xf0, 0xed, 0x03, 0x0f, 0x97, 0x1a, 0x61, 0x50, 0x13, 0x17, 0xa2, 0x95, 0x4e, 0x3b, 0xb3, 0x24,
  3975. 0x22, 0x61, 0x4e, 0xbd, 0x41, 0xbd, 0xb4, 0x33, 0xf6, 0xb1, 0xf0, 0x7d, 0x30, 0x2b, 0xe2, 0xc9,
  3976. 0xd9, 0x11, 0xee, 0x5e, 0x20, 0xa4, 0xaf, 0x51, 0x44, 0xaf, 0x3b, 0xd4, 0xad, 0xa1, 0x18, 0x9a,
  3977. 0xbe, 0x28, 0x62, 0xcd, 0xb2, 0xba, 0x47, 0x2f, 0x0e, 0x89, 0x17, 0xa5, 0xcb, 0xe7, 0x05, 0x61,
  3978. 0x2f, 0x4a, 0x9c, 0x42, 0x47, 0x5a, 0x61, 0x29, 0xd7, 0x9b, 0xb5, 0x9a, 0x87, 0xc5, 0x6d, 0x41,
  3979. 0x4a, 0x65, 0x57, 0x24, 0xe2, 0x80, 0xbe, 0x86, 0x60, 0xc0, 0x5d, 0x69, 0x32, 0xc9, 0x05, 0xc7,
  3980. 0xc7, 0xb6, 0x5f, 0x8d, 0x54, 0x2d, 0x79, 0xe1, 0xed, 0x4f, 0x26, 0x8e, 0xc0, 0xc8, 0x83, 0x49,
  3981. 0x97, 0x47, 0x77, 0x85, 0x9a, 0xbe, 0x8f, 0xc3, 0xde, 0x70, 0x75, 0x3b, 0xd9, 0xd5, 0x42, 0xe6,
  3982. 0x97, 0xc7, 0xab, 0x04, 0x85, 0xde, 0xc0, 0x8d, 0x16, 0xc1, 0xa1, 0x6f, 0x7b, 0x3d, 0x19, 0x3e,
  3983. 0x61, 0x4b, 0x01, 0x61, 0x81, 0x90, 0x85, 0x06, 0x68, 0xb4, 0xbc, 0x65, 0x12, 0xe2, 0x28, 0xb2,
  3984. 0x4e, 0x1b, 0x38, 0x52, 0x31, 0xdb, 0x96, 0x54, 0xde, 0x88, 0x39, 0x75, 0x42, 0xbd, 0x1a, 0x92,
  3985. 0xb1, 0xf4, 0x2d, 0xe5, 0xcb, 0x5d, 0x7c, 0x5a, 0x76, 0x3f, 0xc1, 0x6c, 0x6c, 0x9a, 0x90, 0x53,
  3986. 0x2b, 0xc8, 0xf4, 0xbc, 0x8d, 0xdc, 0x4f, 0xe8, 0x5b, 0x1a, 0x23, 0xd0, 0x71, 0x25, 0x66, 0x30,
  3987. 0xed, 0xf0, 0x10, 0xab, 0x87, 0x4c, 0x46, 0x9a, 0x62, 0x13, 0x32, 0xba, 0x47, 0x61, 0x1a, 0x1a,
  3988. 0xc2, 0x85, 0xcf, 0xc0, 0xc5, 0xbe, 0xb5, 0x59, 0xab, 0xb9, 0x2d, 0x64, 0xfb, 0x87, 0x58, 0xad,
  3989. 0x33, 0x4d, 0xad, 0xd3, 0xce, 0xac, 0x0e, 0x6a, 0x32, 0x9c, 0x1e, 0x52, 0xa0, 0x86, 0x86, 0xf2,
  3990. 0xe1, 0x77, 0xc1, 0xca, 0x30, 0xbb, 0xd5, 0xf2, 0x55, 0x97, 0x49, 0x4b, 0xd7, 0xd9, 0x11, 0xd2,
  3991. 0x3a, 0x69, 0xf9, 0x1a, 0x1a, 0x25, 0x43, 0xc7, 0xc8, 0x9e, 0xcb, 0x6a, 0xf9, 0xc5, 0x46, 0xa4,
  3992. 0x7e, 0x8f, 0x29, 0x4b, 0x25, 0x95, 0x94, 0x49, 0xcb, 0xd7, 0x83, 0x46, 0xa4, 0xa1, 0x24, 0xab,
  3993. 0x5f, 0x16, 0xde, 0xdd, 0x23, 0x3e, 0x8d, 0x4e, 0xc4, 0xae, 0x36, 0x5c, 0x87, 0xcf, 0x05, 0x51,
  3994. 0xaf, 0x2c, 0x82, 0x00, 0xdf, 0x05, 0xd3, 0xdc, 0xf0, 0xb4, 0x54, 0xe6, 0x43, 0xe8, 0x84, 0x3c,
  3995. 0xc0, 0x0b, 0xf6, 0x4b, 0xfa, 0xf4, 0x3e, 0x50, 0xfb, 0xbe, 0x02, 0xde, 0x42, 0xf8, 0x65, 0x13,
  3996. 0x47, 0x04, 0x6e, 0x82, 0xe9, 0x62, 0x03, 0x87, 0x36, 0x71, 0x03, 0x9f, 0xf5, 0xa6, 0xf9, 0xbb,
  3997. 0x69, 0x31, 0x39, 0xf6, 0xec, 0xa8, 0x0f, 0x81, 0x37, 0xbb, 0x57, 0x0f, 0x95, 0x8f, 0x99, 0x73,
  3998. 0x02, 0xcc, 0x8d, 0xa8, 0x7b, 0x2f, 0xb9, 0xd9, 0x6d, 0x80, 0xac, 0xdf, 0xf4, 0x61, 0xdc, 0x88,
  3999. 0x84, 0x53, 0x73, 0xc0, 0x14, 0xc2, 0x51, 0x23, 0xf0, 0x23, 0x0c, 0x55, 0xf0, 0x56, 0xb9, 0xe9,
  4000. 0x38, 0x38, 0x8a, 0x58, 0x1c, 0x53, 0xa8, 0xbb, 0x84, 0x97, 0xc0, 0x24, 0xbd, 0x5e, 0x36, 0x23,
  4001. 0xde, 0xfa, 0x90, 0x58, 0x49, 0xb1, 0xa4, 0xce, 0x88, 0x65, 0xe3, 0x2f, 0x8a, 0xb4, 0x47, 0x38,
  4002. 0x0f, 0x40, 0x21, 0x20, 0x65, 0x62, 0x87, 0x04, 0x57, 0xd3, 0x63, 0xf0, 0x22, 0x48, 0x8b, 0x3b,
  4003. 0x16, 0xb3, 0xd1, 0xb9, 0x38, 0xad, 0xc0, 0x05, 0x30, 0x83, 0x70, 0xd4, 0x33, 0x8c, 0xc3, 0x59,
  4004. 0x30, 0xb5, 0xeb, 0x7a, 0x1e, 0x5b, 0xa5, 0xa8, 0x9b, 0x1e, 0x18, 0xd9, 0xd0, 0xa9, 0xbb, 0x27,
  4005. 0x38, 0x7d, 0x81, 0xaa, 0x6c, 0xe3, 0x88, 0x84, 0xc1, 0x29, 0x45, 0xb0, 0xbb, 0x52, 0x7a, 0x02,
  4006. 0x5e, 0x06, 0xcb, 0x5b, 0x9e, 0xed, 0x1c, 0xd5, 0x03, 0x8f, 0xfd, 0x4d, 0xa4, 0x14, 0x84, 0xc4,
  4007. 0x6a, 0xa1, 0x56, 0xba, 0x0a, 0xaf, 0x82, 0x95, 0x7d, 0xff, 0x60, 0xa8, 0x13, 0xc3, 0x65, 0xb0,
  4008. 0xc8, 0x8e, 0xc5, 0x98, 0xb9, 0x06, 0x57, 0xc0, 0xd2, 0xbe, 0x5f, 0x1d, 0x70, 0x1c, 0x6e, 0xfc,
  4009. 0x63, 0x8a, 0xc7, 0x23, 0x4e, 0x64, 0xca, 0xdf, 0xcd, 0x9b, 0x66, 0xa5, 0x58, 0x30, 0x2a, 0x8f,
  4010. 0x8b, 0xa6, 0x59, 0x7c, 0x6e, 0xa0, 0xf4, 0x18, 0xfc, 0x1a, 0x58, 0x1f, 0x30, 0x57, 0xf6, 0x0b,
  4011. 0x56, 0xde, 0xac, 0x58, 0x28, 0xff, 0xe4, 0x89, 0x81, 0x2a, 0xe5, 0x42, 0xb6, 0x54, 0xde, 0x29,
  4012. 0x5a, 0x3c, 0x05, 0x0c, 0x6d, 0x1a, 0xd9, 0x6d, 0x03, 0xa5, 0xc7, 0xe1, 0x2d, 0xa0, 0x49, 0x86,
  4013. 0x51, 0xc4, 0x54, 0x8f, 0xf8, 0x74, 0xbf, 0x88, 0xf6, 0xf7, 0xd2, 0x17, 0x58, 0xee, 0xa8, 0x21,
  4014. 0x6b, 0x9a, 0xe9, 0x09, 0xb8, 0x01, 0x6e, 0x6d, 0x99, 0xd9, 0xdc, 0xee, 0x4e, 0xd1, 0x34, 0x2a,
  4015. 0x25, 0xc3, 0x40, 0x95, 0x52, 0x11, 0x59, 0x15, 0xeb, 0x45, 0x05, 0xbd, 0x88, 0x47, 0x5c, 0x85,
  4016. 0x59, 0xf0, 0xc1, 0x9b, 0x61, 0x47, 0x45, 0x83, 0xe1, 0x3b, 0x60, 0x6d, 0xb4, 0x84, 0xd8, 0x5b,
  4017. 0x0d, 0xbe, 0x07, 0xbe, 0x75, 0x1e, 0x6a, 0xd4, 0x23, 0x0e, 0xcf, 0x7e, 0x84, 0xc8, 0x42, 0x1d,
  4018. 0x5e, 0x07, 0xd7, 0x46, 0xa3, 0x68, 0x6a, 0x5c, 0xf8, 0x15, 0xa0, 0x6d, 0x1b, 0x66, 0xf6, 0xa3,
  4019. 0xb3, 0xd3, 0xf2, 0x4a, 0x81, 0x9b, 0xe0, 0x36, 0xca, 0x16, 0xb6, 0x8b, 0x7b, 0x95, 0x37, 0xc0,
  4020. 0x7f, 0xa6, 0xc0, 0x0f, 0xc1, 0xfd, 0xf3, 0x81, 0xa3, 0x36, 0xf8, 0xb9, 0x02, 0x0d, 0xf0, 0xe8,
  4021. 0x8d, 0x9f, 0x37, 0x4a, 0xe6, 0x37, 0x0a, 0xbc, 0x0e, 0xde, 0x1e, 0xce, 0x17, 0x75, 0xf8, 0xad,
  4022. 0x02, 0xd7, 0xc1, 0x8d, 0x33, 0x9f, 0x24, 0x90, 0xbf, 0x53, 0xe0, 0xb7, 0xc1, 0xbd, 0xb3, 0x20,
  4023. 0xa3, 0xc2, 0xf8, 0xbd, 0x02, 0x1f, 0x82, 0x07, 0x6f, 0xf0, 0x8c, 0x51, 0x02, 0x7f, 0x38, 0x63,
  4024. 0x1f, 0xa2, 0xd8, 0x5f, 0x9c, 0xbf, 0x0f, 0x81, 0xfc, 0xa3, 0x02, 0x57, 0xc1, 0xe5, 0xe1, 0x10,
  4025. 0xfa, 0x4e, 0xfc, 0x49, 0x81, 0x37, 0xc1, 0xda, 0x99, 0x4a, 0x14, 0xf6, 0x67, 0x05, 0xaa, 0x60,
  4026. 0xa9, 0x50, 0xac, 0x3c, 0xce, 0xe6, 0xcd, 0xca, 0xf3, 0xbc, 0xb5, 0x53, 0x29, 0x5b, 0xc8, 0x28,
  4027. 0x97, 0xd3, 0xbf, 0x1a, 0xa7, 0xa1, 0xc4, 0x3c, 0x85, 0xa2, 0x70, 0x56, 0x1e, 0x17, 0x51, 0xc5,
  4028. 0xcc, 0x3f, 0x33, 0x0a, 0x14, 0xf9, 0xe9, 0x38, 0x5c, 0x00, 0x80, 0xc2, 0x4a, 0xc5, 0x7c, 0xc1,
  4029. 0x2a, 0xa7, 0x7f, 0x90, 0x82, 0x73, 0x60, 0xca, 0x78, 0x61, 0x19, 0xa8, 0x90, 0x35, 0xd3, 0xff,
  4030. 0x4c, 0x6d, 0x04, 0x00, 0xf4, 0xc7, 0x0a, 0x38, 0x09, 0xc6, 0x77, 0x9f, 0xa5, 0xc7, 0xe0, 0x34,
  4031. 0x98, 0x30, 0x8d, 0x6c, 0xd9, 0x48, 0x2b, 0x70, 0x09, 0x2c, 0x18, 0xa6, 0x91, 0xb3, 0xf2, 0xc5,
  4032. 0x42, 0x05, 0xed, 0x17, 0x0a, 0xec, 0xdc, 0x48, 0x83, 0xd9, 0xe7, 0x59, 0x2b, 0xb7, 0xd3, 0xb5,
  4033. 0xa4, 0xe8, 0xf9, 0x64, 0x16, 0x73, 0xbb, 0x15, 0x94, 0xcd, 0x19, 0xa8, 0x6b, 0xbe, 0x40, 0x81,
  4034. 0x4c, 0xa8, 0x6b, 0x99, 0xb8, 0xfb, 0x10, 0x4c, 0x5b, 0xa1, 0xed, 0x47, 0x8d, 0x20, 0x24, 0xf0,
  4035. 0xae, 0xbc, 0x98, 0x17, 0x67, 0xbd, 0xe8, 0x63, 0x57, 0x16, 0x7a, 0x6b, 0xde, 0x4e, 0xb4, 0xb1,
  4036. 0x75, 0xe5, 0xeb, 0xca, 0xd6, 0xc5, 0x57, 0x7f, 0x5b, 0x1d, 0x7b, 0xf5, 0x7a, 0x55, 0xf9, 0xe2,
  4037. 0xf5, 0xaa, 0xf2, 0xd7, 0xd7, 0xab, 0xca, 0xcf, 0xff, 0xbe, 0x3a, 0x76, 0x30, 0xc9, 0xfe, 0x87,
  4038. 0x74, 0xef, 0xff, 0x01, 0x00, 0x00, 0xff, 0xff, 0x10, 0x53, 0x17, 0x6b, 0x8c, 0x1a, 0x00, 0x00,
  4039. }