or.h 221 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119112011211122112311241125112611271128112911301131113211331134113511361137113811391140114111421143114411451146114711481149115011511152115311541155115611571158115911601161116211631164116511661167116811691170117111721173117411751176117711781179118011811182118311841185118611871188118911901191119211931194119511961197119811991200120112021203120412051206120712081209121012111212121312141215121612171218121912201221122212231224122512261227122812291230123112321233123412351236123712381239124012411242124312441245124612471248124912501251125212531254125512561257125812591260126112621263126412651266126712681269127012711272127312741275127612771278127912801281128212831284128512861287128812891290129112921293129412951296129712981299130013011302130313041305130613071308130913101311131213131314131513161317131813191320132113221323132413251326132713281329133013311332133313341335133613371338133913401341134213431344134513461347134813491350135113521353135413551356135713581359136013611362136313641365136613671368136913701371137213731374137513761377137813791380138113821383138413851386138713881389139013911392139313941395139613971398139914001401140214031404140514061407140814091410141114121413141414151416141714181419142014211422142314241425142614271428142914301431143214331434143514361437143814391440144114421443144414451446144714481449145014511452145314541455145614571458145914601461146214631464146514661467146814691470147114721473147414751476147714781479148014811482148314841485148614871488148914901491149214931494149514961497149814991500150115021503150415051506150715081509151015111512151315141515151615171518151915201521152215231524152515261527152815291530153115321533153415351536153715381539154015411542154315441545154615471548154915501551155215531554155515561557155815591560156115621563156415651566156715681569157015711572157315741575157615771578157915801581158215831584158515861587158815891590159115921593159415951596159715981599160016011602160316041605160616071608160916101611161216131614161516161617161816191620162116221623162416251626162716281629163016311632163316341635163616371638163916401641164216431644164516461647164816491650165116521653165416551656165716581659166016611662166316641665166616671668166916701671167216731674167516761677167816791680168116821683168416851686168716881689169016911692169316941695169616971698169917001701170217031704170517061707170817091710171117121713171417151716171717181719172017211722172317241725172617271728172917301731173217331734173517361737173817391740174117421743174417451746174717481749175017511752175317541755175617571758175917601761176217631764176517661767176817691770177117721773177417751776177717781779178017811782178317841785178617871788178917901791179217931794179517961797179817991800180118021803180418051806180718081809181018111812181318141815181618171818181918201821182218231824182518261827182818291830183118321833183418351836183718381839184018411842184318441845184618471848184918501851185218531854185518561857185818591860186118621863186418651866186718681869187018711872187318741875187618771878187918801881188218831884188518861887188818891890189118921893189418951896189718981899190019011902190319041905190619071908190919101911191219131914191519161917191819191920192119221923192419251926192719281929193019311932193319341935193619371938193919401941194219431944194519461947194819491950195119521953195419551956195719581959196019611962196319641965196619671968196919701971197219731974197519761977197819791980198119821983198419851986198719881989199019911992199319941995199619971998199920002001200220032004200520062007200820092010201120122013201420152016201720182019202020212022202320242025202620272028202920302031203220332034203520362037203820392040204120422043204420452046204720482049205020512052205320542055205620572058205920602061206220632064206520662067206820692070207120722073207420752076207720782079208020812082208320842085208620872088208920902091209220932094209520962097209820992100210121022103210421052106210721082109211021112112211321142115211621172118211921202121212221232124212521262127212821292130213121322133213421352136213721382139214021412142214321442145214621472148214921502151215221532154215521562157215821592160216121622163216421652166216721682169217021712172217321742175217621772178217921802181218221832184218521862187218821892190219121922193219421952196219721982199220022012202220322042205220622072208220922102211221222132214221522162217221822192220222122222223222422252226222722282229223022312232223322342235223622372238223922402241224222432244224522462247224822492250225122522253225422552256225722582259226022612262226322642265226622672268226922702271227222732274227522762277227822792280228122822283228422852286228722882289229022912292229322942295229622972298229923002301230223032304230523062307230823092310231123122313231423152316231723182319232023212322232323242325232623272328232923302331233223332334233523362337233823392340234123422343234423452346234723482349235023512352235323542355235623572358235923602361236223632364236523662367236823692370237123722373237423752376237723782379238023812382238323842385238623872388238923902391239223932394239523962397239823992400240124022403240424052406240724082409241024112412241324142415241624172418241924202421242224232424242524262427242824292430243124322433243424352436243724382439244024412442244324442445244624472448244924502451245224532454245524562457245824592460246124622463246424652466246724682469247024712472247324742475247624772478247924802481248224832484248524862487248824892490249124922493249424952496249724982499250025012502250325042505250625072508250925102511251225132514251525162517251825192520252125222523252425252526252725282529253025312532253325342535253625372538253925402541254225432544254525462547254825492550255125522553255425552556255725582559256025612562256325642565256625672568256925702571257225732574257525762577257825792580258125822583258425852586258725882589259025912592259325942595259625972598259926002601260226032604260526062607260826092610261126122613261426152616261726182619262026212622262326242625262626272628262926302631263226332634263526362637263826392640264126422643264426452646264726482649265026512652265326542655265626572658265926602661266226632664266526662667266826692670267126722673267426752676267726782679268026812682268326842685268626872688268926902691269226932694269526962697269826992700270127022703270427052706270727082709271027112712271327142715271627172718271927202721272227232724272527262727272827292730273127322733273427352736273727382739274027412742274327442745274627472748274927502751275227532754275527562757275827592760276127622763276427652766276727682769277027712772277327742775277627772778277927802781278227832784278527862787278827892790279127922793279427952796279727982799280028012802280328042805280628072808280928102811281228132814281528162817281828192820282128222823282428252826282728282829283028312832283328342835283628372838283928402841284228432844284528462847284828492850285128522853285428552856285728582859286028612862286328642865286628672868286928702871287228732874287528762877287828792880288128822883288428852886288728882889289028912892289328942895289628972898289929002901290229032904290529062907290829092910291129122913291429152916291729182919292029212922292329242925292629272928292929302931293229332934293529362937293829392940294129422943294429452946294729482949295029512952295329542955295629572958295929602961296229632964296529662967296829692970297129722973297429752976297729782979298029812982298329842985298629872988298929902991299229932994299529962997299829993000300130023003300430053006300730083009301030113012301330143015301630173018301930203021302230233024302530263027302830293030303130323033303430353036303730383039304030413042304330443045304630473048304930503051305230533054305530563057305830593060306130623063306430653066306730683069307030713072307330743075307630773078307930803081308230833084308530863087308830893090309130923093309430953096309730983099310031013102310331043105310631073108310931103111311231133114311531163117311831193120312131223123312431253126312731283129313031313132313331343135313631373138313931403141314231433144314531463147314831493150315131523153315431553156315731583159316031613162316331643165316631673168316931703171317231733174317531763177317831793180318131823183318431853186318731883189319031913192319331943195319631973198319932003201320232033204320532063207320832093210321132123213321432153216321732183219322032213222322332243225322632273228322932303231323232333234323532363237323832393240324132423243324432453246324732483249325032513252325332543255325632573258325932603261326232633264326532663267326832693270327132723273327432753276327732783279328032813282328332843285328632873288328932903291329232933294329532963297329832993300330133023303330433053306330733083309331033113312331333143315331633173318331933203321332233233324332533263327332833293330333133323333333433353336333733383339334033413342334333443345334633473348334933503351335233533354335533563357335833593360336133623363336433653366336733683369337033713372337333743375337633773378337933803381338233833384338533863387338833893390339133923393339433953396339733983399340034013402340334043405340634073408340934103411341234133414341534163417341834193420342134223423342434253426342734283429343034313432343334343435343634373438343934403441344234433444344534463447344834493450345134523453345434553456345734583459346034613462346334643465346634673468346934703471347234733474347534763477347834793480348134823483348434853486348734883489349034913492349334943495349634973498349935003501350235033504350535063507350835093510351135123513351435153516351735183519352035213522352335243525352635273528352935303531353235333534353535363537353835393540354135423543354435453546354735483549355035513552355335543555355635573558355935603561356235633564356535663567356835693570357135723573357435753576357735783579358035813582358335843585358635873588358935903591359235933594359535963597359835993600360136023603360436053606360736083609361036113612361336143615361636173618361936203621362236233624362536263627362836293630363136323633363436353636363736383639364036413642364336443645364636473648364936503651365236533654365536563657365836593660366136623663366436653666366736683669367036713672367336743675367636773678367936803681368236833684368536863687368836893690369136923693369436953696369736983699370037013702370337043705370637073708370937103711371237133714371537163717371837193720372137223723372437253726372737283729373037313732373337343735373637373738373937403741374237433744374537463747374837493750375137523753375437553756375737583759376037613762376337643765376637673768376937703771377237733774377537763777377837793780378137823783378437853786378737883789379037913792379337943795379637973798379938003801380238033804380538063807380838093810381138123813381438153816381738183819382038213822382338243825382638273828382938303831383238333834383538363837383838393840384138423843384438453846384738483849385038513852385338543855385638573858385938603861386238633864386538663867386838693870387138723873387438753876387738783879388038813882388338843885388638873888388938903891389238933894389538963897389838993900390139023903390439053906390739083909391039113912391339143915391639173918391939203921392239233924392539263927392839293930393139323933393439353936393739383939394039413942394339443945394639473948394939503951395239533954395539563957395839593960396139623963396439653966396739683969397039713972397339743975397639773978397939803981398239833984398539863987398839893990399139923993399439953996399739983999400040014002400340044005400640074008400940104011401240134014401540164017401840194020402140224023402440254026402740284029403040314032403340344035403640374038403940404041404240434044404540464047404840494050405140524053405440554056405740584059406040614062406340644065406640674068406940704071407240734074407540764077407840794080408140824083408440854086408740884089409040914092409340944095409640974098409941004101410241034104410541064107410841094110411141124113411441154116411741184119412041214122412341244125412641274128412941304131413241334134413541364137413841394140414141424143414441454146414741484149415041514152415341544155415641574158415941604161416241634164416541664167416841694170417141724173417441754176417741784179418041814182418341844185418641874188418941904191419241934194419541964197419841994200420142024203420442054206420742084209421042114212421342144215421642174218421942204221422242234224422542264227422842294230423142324233423442354236423742384239424042414242424342444245424642474248424942504251425242534254425542564257425842594260426142624263426442654266426742684269427042714272427342744275427642774278427942804281428242834284428542864287428842894290429142924293429442954296429742984299430043014302430343044305430643074308430943104311431243134314431543164317431843194320432143224323432443254326432743284329433043314332433343344335433643374338433943404341434243434344434543464347434843494350435143524353435443554356435743584359436043614362436343644365436643674368436943704371437243734374437543764377437843794380438143824383438443854386438743884389439043914392439343944395439643974398439944004401440244034404440544064407440844094410441144124413441444154416441744184419442044214422442344244425442644274428442944304431443244334434443544364437443844394440444144424443444444454446444744484449445044514452445344544455445644574458445944604461446244634464446544664467446844694470447144724473447444754476447744784479448044814482448344844485448644874488448944904491449244934494449544964497449844994500450145024503450445054506450745084509451045114512451345144515451645174518451945204521452245234524452545264527452845294530453145324533453445354536453745384539454045414542454345444545454645474548454945504551455245534554455545564557455845594560456145624563456445654566456745684569457045714572457345744575457645774578457945804581458245834584458545864587458845894590459145924593459445954596459745984599460046014602460346044605460646074608460946104611461246134614461546164617461846194620462146224623462446254626462746284629463046314632463346344635463646374638463946404641464246434644464546464647464846494650465146524653465446554656465746584659466046614662466346644665466646674668466946704671467246734674467546764677467846794680468146824683468446854686468746884689469046914692469346944695469646974698469947004701470247034704470547064707470847094710471147124713471447154716471747184719472047214722472347244725472647274728472947304731473247334734473547364737473847394740474147424743474447454746474747484749475047514752475347544755475647574758475947604761476247634764476547664767476847694770477147724773477447754776477747784779478047814782478347844785478647874788478947904791479247934794479547964797479847994800480148024803480448054806480748084809481048114812481348144815481648174818481948204821482248234824482548264827482848294830483148324833483448354836483748384839484048414842484348444845484648474848484948504851485248534854485548564857485848594860486148624863486448654866486748684869487048714872487348744875487648774878487948804881488248834884488548864887488848894890489148924893489448954896489748984899490049014902490349044905490649074908490949104911491249134914491549164917491849194920492149224923492449254926492749284929493049314932493349344935493649374938493949404941494249434944494549464947494849494950495149524953495449554956495749584959496049614962496349644965496649674968496949704971497249734974497549764977497849794980498149824983498449854986498749884989499049914992499349944995499649974998499950005001500250035004500550065007500850095010501150125013501450155016501750185019502050215022502350245025502650275028502950305031503250335034503550365037503850395040504150425043504450455046504750485049505050515052505350545055505650575058505950605061506250635064506550665067506850695070507150725073507450755076507750785079508050815082508350845085508650875088508950905091509250935094509550965097509850995100510151025103510451055106510751085109511051115112511351145115511651175118511951205121512251235124512551265127512851295130513151325133513451355136513751385139514051415142514351445145514651475148514951505151515251535154515551565157515851595160516151625163516451655166516751685169517051715172517351745175517651775178517951805181518251835184518551865187518851895190519151925193519451955196519751985199520052015202520352045205520652075208520952105211521252135214521552165217521852195220522152225223522452255226522752285229523052315232523352345235523652375238523952405241524252435244524552465247524852495250525152525253525452555256525752585259526052615262526352645265526652675268526952705271527252735274527552765277527852795280528152825283528452855286528752885289529052915292529352945295529652975298529953005301530253035304530553065307530853095310531153125313531453155316531753185319532053215322532353245325532653275328532953305331533253335334533553365337533853395340534153425343534453455346534753485349535053515352535353545355535653575358535953605361536253635364536553665367536853695370537153725373537453755376537753785379538053815382538353845385538653875388538953905391539253935394539553965397539853995400540154025403540454055406540754085409541054115412541354145415541654175418541954205421542254235424542554265427542854295430543154325433543454355436
  1. /* Copyright (c) 2001 Matej Pfajfar.
  2. * Copyright (c) 2001-2004, Roger Dingledine.
  3. * Copyright (c) 2004-2006, Roger Dingledine, Nick Mathewson.
  4. * Copyright (c) 2007-2017, The Tor Project, Inc. */
  5. /* See LICENSE for licensing information */
  6. /**
  7. * \file or.h
  8. * \brief Master header file for Tor-specific functionality.
  9. **/
  10. #ifndef TOR_OR_H
  11. #define TOR_OR_H
  12. #include "orconfig.h"
  13. #ifdef HAVE_UNISTD_H
  14. #include <unistd.h>
  15. #endif
  16. #ifdef HAVE_SIGNAL_H
  17. #include <signal.h>
  18. #endif
  19. #ifdef HAVE_NETDB_H
  20. #include <netdb.h>
  21. #endif
  22. #ifdef HAVE_SYS_PARAM_H
  23. #include <sys/param.h> /* FreeBSD needs this to know what version it is */
  24. #endif
  25. #include "torint.h"
  26. #ifdef HAVE_SYS_FCNTL_H
  27. #include <sys/fcntl.h>
  28. #endif
  29. #ifdef HAVE_FCNTL_H
  30. #include <fcntl.h>
  31. #endif
  32. #ifdef HAVE_SYS_IOCTL_H
  33. #include <sys/ioctl.h>
  34. #endif
  35. #ifdef HAVE_SYS_UN_H
  36. #include <sys/un.h>
  37. #endif
  38. #ifdef HAVE_SYS_STAT_H
  39. #include <sys/stat.h>
  40. #endif
  41. #ifdef HAVE_NETINET_IN_H
  42. #include <netinet/in.h>
  43. #endif
  44. #ifdef HAVE_ARPA_INET_H
  45. #include <arpa/inet.h>
  46. #endif
  47. #ifdef HAVE_ERRNO_H
  48. #include <errno.h>
  49. #endif
  50. #ifdef HAVE_ASSERT_H
  51. #include <assert.h>
  52. #endif
  53. #ifdef HAVE_TIME_H
  54. #include <time.h>
  55. #endif
  56. #ifdef _WIN32
  57. #include <winsock2.h>
  58. #include <io.h>
  59. #include <process.h>
  60. #include <direct.h>
  61. #include <windows.h>
  62. #endif
  63. #include "crypto.h"
  64. #include "crypto_format.h"
  65. #include "tortls.h"
  66. #include "torlog.h"
  67. #include "container.h"
  68. #include "compress.h"
  69. #include "address.h"
  70. #include "compat_libevent.h"
  71. #include "ht.h"
  72. #include "confline.h"
  73. #include "replaycache.h"
  74. #include "crypto_curve25519.h"
  75. #include "crypto_ed25519.h"
  76. #include "tor_queue.h"
  77. #include "util_format.h"
  78. #include "hs_circuitmap.h"
  79. /* These signals are defined to help handle_control_signal work.
  80. */
  81. #ifndef SIGHUP
  82. #define SIGHUP 1
  83. #endif
  84. #ifndef SIGINT
  85. #define SIGINT 2
  86. #endif
  87. #ifndef SIGUSR1
  88. #define SIGUSR1 10
  89. #endif
  90. #ifndef SIGUSR2
  91. #define SIGUSR2 12
  92. #endif
  93. #ifndef SIGTERM
  94. #define SIGTERM 15
  95. #endif
  96. /* Controller signals start at a high number so we don't
  97. * conflict with system-defined signals. */
  98. #define SIGNEWNYM 129
  99. #define SIGCLEARDNSCACHE 130
  100. #define SIGHEARTBEAT 131
  101. #if (SIZEOF_CELL_T != 0)
  102. /* On Irix, stdlib.h defines a cell_t type, so we need to make sure
  103. * that our stuff always calls cell_t something different. */
  104. #define cell_t tor_cell_t
  105. #endif
  106. #ifdef ENABLE_TOR2WEB_MODE
  107. #define NON_ANONYMOUS_MODE_ENABLED 1
  108. #endif
  109. /** Helper macro: Given a pointer to to.base_, of type from*, return &to. */
  110. #define DOWNCAST(to, ptr) ((to*)SUBTYPE_P(ptr, to, base_))
  111. /** Length of longest allowable configured nickname. */
  112. #define MAX_NICKNAME_LEN 19
  113. /** Length of a router identity encoded as a hexadecimal digest, plus
  114. * possible dollar sign. */
  115. #define MAX_HEX_NICKNAME_LEN (HEX_DIGEST_LEN+1)
  116. /** Maximum length of verbose router identifier: dollar sign, hex ID digest,
  117. * equal sign or tilde, nickname. */
  118. #define MAX_VERBOSE_NICKNAME_LEN (1+HEX_DIGEST_LEN+1+MAX_NICKNAME_LEN)
  119. /** Maximum size, in bytes, for resized buffers. */
  120. #define MAX_BUF_SIZE ((1<<24)-1) /* 16MB-1 */
  121. /** Maximum size, in bytes, for any directory object that we've downloaded. */
  122. #define MAX_DIR_DL_SIZE MAX_BUF_SIZE
  123. /** For HTTP parsing: Maximum number of bytes we'll accept in the headers
  124. * of an HTTP request or response. */
  125. #define MAX_HEADERS_SIZE 50000
  126. /** Maximum size, in bytes, for any directory object that we're accepting
  127. * as an upload. */
  128. #define MAX_DIR_UL_SIZE MAX_BUF_SIZE
  129. /** Maximum size, in bytes, of a single router descriptor uploaded to us
  130. * as a directory authority. Caches and clients fetch whatever descriptors
  131. * the authorities tell them to fetch, and don't care about size. */
  132. #define MAX_DESCRIPTOR_UPLOAD_SIZE 20000
  133. /** Maximum size of a single extrainfo document, as above. */
  134. #define MAX_EXTRAINFO_UPLOAD_SIZE 50000
  135. /** Minimum lifetime for an onion key in days. */
  136. #define MIN_ONION_KEY_LIFETIME_DAYS (1)
  137. /** Maximum lifetime for an onion key in days. */
  138. #define MAX_ONION_KEY_LIFETIME_DAYS (90)
  139. /** Default lifetime for an onion key in days. */
  140. #define DEFAULT_ONION_KEY_LIFETIME_DAYS (28)
  141. /** Minimum grace period for acceptance of an onion key in days.
  142. * The maximum value is defined in proposal #274 as being the current network
  143. * consensus parameter for "onion-key-rotation-days". */
  144. #define MIN_ONION_KEY_GRACE_PERIOD_DAYS (1)
  145. /** Default grace period for acceptance of an onion key in days. */
  146. #define DEFAULT_ONION_KEY_GRACE_PERIOD_DAYS (7)
  147. /** How often we should check the network consensus if it is time to rotate or
  148. * expire onion keys. */
  149. #define ONION_KEY_CONSENSUS_CHECK_INTERVAL (60*60)
  150. /** How often do we rotate TLS contexts? */
  151. #define MAX_SSL_KEY_LIFETIME_INTERNAL (2*60*60)
  152. /** How old do we allow a router to get before removing it
  153. * from the router list? In seconds. */
  154. #define ROUTER_MAX_AGE (60*60*48)
  155. /** How old can a router get before we (as a server) will no longer
  156. * consider it live? In seconds. */
  157. #define ROUTER_MAX_AGE_TO_PUBLISH (60*60*24)
  158. /** How old do we let a saved descriptor get before force-removing it? */
  159. #define OLD_ROUTER_DESC_MAX_AGE (60*60*24*5)
  160. /** Possible rules for generating circuit IDs on an OR connection. */
  161. typedef enum {
  162. CIRC_ID_TYPE_LOWER=0, /**< Pick from 0..1<<15-1. */
  163. CIRC_ID_TYPE_HIGHER=1, /**< Pick from 1<<15..1<<16-1. */
  164. /** The other side of a connection is an OP: never create circuits to it,
  165. * and let it use any circuit ID it wants. */
  166. CIRC_ID_TYPE_NEITHER=2
  167. } circ_id_type_t;
  168. #define circ_id_type_bitfield_t ENUM_BF(circ_id_type_t)
  169. #define CONN_TYPE_MIN_ 3
  170. /** Type for sockets listening for OR connections. */
  171. #define CONN_TYPE_OR_LISTENER 3
  172. /** A bidirectional TLS connection transmitting a sequence of cells.
  173. * May be from an OR to an OR, or from an OP to an OR. */
  174. #define CONN_TYPE_OR 4
  175. /** A TCP connection from an onion router to a stream's destination. */
  176. #define CONN_TYPE_EXIT 5
  177. /** Type for sockets listening for SOCKS connections. */
  178. #define CONN_TYPE_AP_LISTENER 6
  179. /** A SOCKS proxy connection from the user application to the onion
  180. * proxy. */
  181. #define CONN_TYPE_AP 7
  182. /** Type for sockets listening for HTTP connections to the directory server. */
  183. #define CONN_TYPE_DIR_LISTENER 8
  184. /** Type for HTTP connections to the directory server. */
  185. #define CONN_TYPE_DIR 9
  186. /* Type 10 is unused. */
  187. /** Type for listening for connections from user interface process. */
  188. #define CONN_TYPE_CONTROL_LISTENER 11
  189. /** Type for connections from user interface process. */
  190. #define CONN_TYPE_CONTROL 12
  191. /** Type for sockets listening for transparent connections redirected by pf or
  192. * netfilter. */
  193. #define CONN_TYPE_AP_TRANS_LISTENER 13
  194. /** Type for sockets listening for transparent connections redirected by
  195. * natd. */
  196. #define CONN_TYPE_AP_NATD_LISTENER 14
  197. /** Type for sockets listening for DNS requests. */
  198. #define CONN_TYPE_AP_DNS_LISTENER 15
  199. /** Type for connections from the Extended ORPort. */
  200. #define CONN_TYPE_EXT_OR 16
  201. /** Type for sockets listening for Extended ORPort connections. */
  202. #define CONN_TYPE_EXT_OR_LISTENER 17
  203. #define CONN_TYPE_MAX_ 17
  204. /* !!!! If _CONN_TYPE_MAX is ever over 31, we must grow the type field in
  205. * connection_t. */
  206. /* Proxy client types */
  207. #define PROXY_NONE 0
  208. #define PROXY_CONNECT 1
  209. #define PROXY_SOCKS4 2
  210. #define PROXY_SOCKS5 3
  211. /* !!!! If there is ever a PROXY_* type over 3, we must grow the proxy_type
  212. * field in or_connection_t */
  213. /* Pluggable transport proxy type. Don't use this in or_connection_t,
  214. * instead use the actual underlying proxy type (see above). */
  215. #define PROXY_PLUGGABLE 4
  216. /* Proxy client handshake states */
  217. /* We use a proxy but we haven't even connected to it yet. */
  218. #define PROXY_INFANT 1
  219. /* We use an HTTP proxy and we've sent the CONNECT command. */
  220. #define PROXY_HTTPS_WANT_CONNECT_OK 2
  221. /* We use a SOCKS4 proxy and we've sent the CONNECT command. */
  222. #define PROXY_SOCKS4_WANT_CONNECT_OK 3
  223. /* We use a SOCKS5 proxy and we try to negotiate without
  224. any authentication . */
  225. #define PROXY_SOCKS5_WANT_AUTH_METHOD_NONE 4
  226. /* We use a SOCKS5 proxy and we try to negotiate with
  227. Username/Password authentication . */
  228. #define PROXY_SOCKS5_WANT_AUTH_METHOD_RFC1929 5
  229. /* We use a SOCKS5 proxy and we just sent our credentials. */
  230. #define PROXY_SOCKS5_WANT_AUTH_RFC1929_OK 6
  231. /* We use a SOCKS5 proxy and we just sent our CONNECT command. */
  232. #define PROXY_SOCKS5_WANT_CONNECT_OK 7
  233. /* We use a proxy and we CONNECTed successfully!. */
  234. #define PROXY_CONNECTED 8
  235. /** True iff <b>x</b> is an edge connection. */
  236. #define CONN_IS_EDGE(x) \
  237. ((x)->type == CONN_TYPE_EXIT || (x)->type == CONN_TYPE_AP)
  238. /** State for any listener connection. */
  239. #define LISTENER_STATE_READY 0
  240. #define OR_CONN_STATE_MIN_ 1
  241. /** State for a connection to an OR: waiting for connect() to finish. */
  242. #define OR_CONN_STATE_CONNECTING 1
  243. /** State for a connection to an OR: waiting for proxy handshake to complete */
  244. #define OR_CONN_STATE_PROXY_HANDSHAKING 2
  245. /** State for an OR connection client: SSL is handshaking, not done
  246. * yet. */
  247. #define OR_CONN_STATE_TLS_HANDSHAKING 3
  248. /** State for a connection to an OR: We're doing a second SSL handshake for
  249. * renegotiation purposes. (V2 handshake only.) */
  250. #define OR_CONN_STATE_TLS_CLIENT_RENEGOTIATING 4
  251. /** State for a connection at an OR: We're waiting for the client to
  252. * renegotiate (to indicate a v2 handshake) or send a versions cell (to
  253. * indicate a v3 handshake) */
  254. #define OR_CONN_STATE_TLS_SERVER_RENEGOTIATING 5
  255. /** State for an OR connection: We're done with our SSL handshake, we've done
  256. * renegotiation, but we haven't yet negotiated link protocol versions and
  257. * sent a netinfo cell. */
  258. #define OR_CONN_STATE_OR_HANDSHAKING_V2 6
  259. /** State for an OR connection: We're done with our SSL handshake, but we
  260. * haven't yet negotiated link protocol versions, done a V3 handshake, and
  261. * sent a netinfo cell. */
  262. #define OR_CONN_STATE_OR_HANDSHAKING_V3 7
  263. /** State for an OR connection: Ready to send/receive cells. */
  264. #define OR_CONN_STATE_OPEN 8
  265. #define OR_CONN_STATE_MAX_ 8
  266. /** States of the Extended ORPort protocol. Be careful before changing
  267. * the numbers: they matter. */
  268. #define EXT_OR_CONN_STATE_MIN_ 1
  269. /** Extended ORPort authentication is waiting for the authentication
  270. * type selected by the client. */
  271. #define EXT_OR_CONN_STATE_AUTH_WAIT_AUTH_TYPE 1
  272. /** Extended ORPort authentication is waiting for the client nonce. */
  273. #define EXT_OR_CONN_STATE_AUTH_WAIT_CLIENT_NONCE 2
  274. /** Extended ORPort authentication is waiting for the client hash. */
  275. #define EXT_OR_CONN_STATE_AUTH_WAIT_CLIENT_HASH 3
  276. #define EXT_OR_CONN_STATE_AUTH_MAX 3
  277. /** Authentication finished and the Extended ORPort is now accepting
  278. * traffic. */
  279. #define EXT_OR_CONN_STATE_OPEN 4
  280. /** Extended ORPort is flushing its last messages and preparing to
  281. * start accepting OR connections. */
  282. #define EXT_OR_CONN_STATE_FLUSHING 5
  283. #define EXT_OR_CONN_STATE_MAX_ 5
  284. #define EXIT_CONN_STATE_MIN_ 1
  285. /** State for an exit connection: waiting for response from DNS farm. */
  286. #define EXIT_CONN_STATE_RESOLVING 1
  287. /** State for an exit connection: waiting for connect() to finish. */
  288. #define EXIT_CONN_STATE_CONNECTING 2
  289. /** State for an exit connection: open and ready to transmit data. */
  290. #define EXIT_CONN_STATE_OPEN 3
  291. /** State for an exit connection: waiting to be removed. */
  292. #define EXIT_CONN_STATE_RESOLVEFAILED 4
  293. #define EXIT_CONN_STATE_MAX_ 4
  294. /* The AP state values must be disjoint from the EXIT state values. */
  295. #define AP_CONN_STATE_MIN_ 5
  296. /** State for a SOCKS connection: waiting for SOCKS request. */
  297. #define AP_CONN_STATE_SOCKS_WAIT 5
  298. /** State for a SOCKS connection: got a y.onion URL; waiting to receive
  299. * rendezvous descriptor. */
  300. #define AP_CONN_STATE_RENDDESC_WAIT 6
  301. /** The controller will attach this connection to a circuit; it isn't our
  302. * job to do so. */
  303. #define AP_CONN_STATE_CONTROLLER_WAIT 7
  304. /** State for a SOCKS connection: waiting for a completed circuit. */
  305. #define AP_CONN_STATE_CIRCUIT_WAIT 8
  306. /** State for a SOCKS connection: sent BEGIN, waiting for CONNECTED. */
  307. #define AP_CONN_STATE_CONNECT_WAIT 9
  308. /** State for a SOCKS connection: sent RESOLVE, waiting for RESOLVED. */
  309. #define AP_CONN_STATE_RESOLVE_WAIT 10
  310. /** State for a SOCKS connection: ready to send and receive. */
  311. #define AP_CONN_STATE_OPEN 11
  312. /** State for a transparent natd connection: waiting for original
  313. * destination. */
  314. #define AP_CONN_STATE_NATD_WAIT 12
  315. #define AP_CONN_STATE_MAX_ 12
  316. /** True iff the AP_CONN_STATE_* value <b>s</b> means that the corresponding
  317. * edge connection is not attached to any circuit. */
  318. #define AP_CONN_STATE_IS_UNATTACHED(s) \
  319. ((s) <= AP_CONN_STATE_CIRCUIT_WAIT || (s) == AP_CONN_STATE_NATD_WAIT)
  320. #define DIR_CONN_STATE_MIN_ 1
  321. /** State for connection to directory server: waiting for connect(). */
  322. #define DIR_CONN_STATE_CONNECTING 1
  323. /** State for connection to directory server: sending HTTP request. */
  324. #define DIR_CONN_STATE_CLIENT_SENDING 2
  325. /** State for connection to directory server: reading HTTP response. */
  326. #define DIR_CONN_STATE_CLIENT_READING 3
  327. /** State for connection to directory server: happy and finished. */
  328. #define DIR_CONN_STATE_CLIENT_FINISHED 4
  329. /** State for connection at directory server: waiting for HTTP request. */
  330. #define DIR_CONN_STATE_SERVER_COMMAND_WAIT 5
  331. /** State for connection at directory server: sending HTTP response. */
  332. #define DIR_CONN_STATE_SERVER_WRITING 6
  333. #define DIR_CONN_STATE_MAX_ 6
  334. /** True iff the purpose of <b>conn</b> means that it's a server-side
  335. * directory connection. */
  336. #define DIR_CONN_IS_SERVER(conn) ((conn)->purpose == DIR_PURPOSE_SERVER)
  337. #define CONTROL_CONN_STATE_MIN_ 1
  338. /** State for a control connection: Authenticated and accepting v1 commands. */
  339. #define CONTROL_CONN_STATE_OPEN 1
  340. /** State for a control connection: Waiting for authentication; speaking
  341. * protocol v1. */
  342. #define CONTROL_CONN_STATE_NEEDAUTH 2
  343. #define CONTROL_CONN_STATE_MAX_ 2
  344. #define DIR_PURPOSE_MIN_ 4
  345. /** A connection to a directory server: set after a v2 rendezvous
  346. * descriptor is downloaded. */
  347. #define DIR_PURPOSE_HAS_FETCHED_RENDDESC_V2 4
  348. /** A connection to a directory server: download one or more server
  349. * descriptors. */
  350. #define DIR_PURPOSE_FETCH_SERVERDESC 6
  351. /** A connection to a directory server: download one or more extra-info
  352. * documents. */
  353. #define DIR_PURPOSE_FETCH_EXTRAINFO 7
  354. /** A connection to a directory server: upload a server descriptor. */
  355. #define DIR_PURPOSE_UPLOAD_DIR 8
  356. /** A connection to a directory server: upload a v3 networkstatus vote. */
  357. #define DIR_PURPOSE_UPLOAD_VOTE 10
  358. /** A connection to a directory server: upload a v3 consensus signature */
  359. #define DIR_PURPOSE_UPLOAD_SIGNATURES 11
  360. /** A connection to a directory server: download one or more v3 networkstatus
  361. * votes. */
  362. #define DIR_PURPOSE_FETCH_STATUS_VOTE 12
  363. /** A connection to a directory server: download a v3 detached signatures
  364. * object for a consensus. */
  365. #define DIR_PURPOSE_FETCH_DETACHED_SIGNATURES 13
  366. /** A connection to a directory server: download a v3 networkstatus
  367. * consensus. */
  368. #define DIR_PURPOSE_FETCH_CONSENSUS 14
  369. /** A connection to a directory server: download one or more directory
  370. * authority certificates. */
  371. #define DIR_PURPOSE_FETCH_CERTIFICATE 15
  372. /** Purpose for connection at a directory server. */
  373. #define DIR_PURPOSE_SERVER 16
  374. /** A connection to a hidden service directory server: upload a v2 rendezvous
  375. * descriptor. */
  376. #define DIR_PURPOSE_UPLOAD_RENDDESC_V2 17
  377. /** A connection to a hidden service directory server: download a v2 rendezvous
  378. * descriptor. */
  379. #define DIR_PURPOSE_FETCH_RENDDESC_V2 18
  380. /** A connection to a directory server: download a microdescriptor. */
  381. #define DIR_PURPOSE_FETCH_MICRODESC 19
  382. /** A connection to a hidden service directory: upload a v3 descriptor. */
  383. #define DIR_PURPOSE_UPLOAD_HSDESC 20
  384. /** A connection to a hidden service directory: fetch a v3 descriptor. */
  385. #define DIR_PURPOSE_FETCH_HSDESC 21
  386. /** A connection to a directory server: set after a hidden service descriptor
  387. * is downloaded. */
  388. #define DIR_PURPOSE_HAS_FETCHED_HSDESC 22
  389. #define DIR_PURPOSE_MAX_ 22
  390. /** True iff <b>p</b> is a purpose corresponding to uploading
  391. * data to a directory server. */
  392. #define DIR_PURPOSE_IS_UPLOAD(p) \
  393. ((p)==DIR_PURPOSE_UPLOAD_DIR || \
  394. (p)==DIR_PURPOSE_UPLOAD_VOTE || \
  395. (p)==DIR_PURPOSE_UPLOAD_SIGNATURES || \
  396. (p)==DIR_PURPOSE_UPLOAD_RENDDESC_V2 || \
  397. (p)==DIR_PURPOSE_UPLOAD_HSDESC)
  398. #define EXIT_PURPOSE_MIN_ 1
  399. /** This exit stream wants to do an ordinary connect. */
  400. #define EXIT_PURPOSE_CONNECT 1
  401. /** This exit stream wants to do a resolve (either normal or reverse). */
  402. #define EXIT_PURPOSE_RESOLVE 2
  403. #define EXIT_PURPOSE_MAX_ 2
  404. /* !!!! If any connection purpose is ever over 31, we must grow the type
  405. * field in connection_t. */
  406. /** Circuit state: I'm the origin, still haven't done all my handshakes. */
  407. #define CIRCUIT_STATE_BUILDING 0
  408. /** Circuit state: Waiting to process the onionskin. */
  409. #define CIRCUIT_STATE_ONIONSKIN_PENDING 1
  410. /** Circuit state: I'd like to deliver a create, but my n_chan is still
  411. * connecting. */
  412. #define CIRCUIT_STATE_CHAN_WAIT 2
  413. /** Circuit state: the circuit is open but we don't want to actually use it
  414. * until we find out if a better guard will be available.
  415. */
  416. #define CIRCUIT_STATE_GUARD_WAIT 3
  417. /** Circuit state: onionskin(s) processed, ready to send/receive cells. */
  418. #define CIRCUIT_STATE_OPEN 4
  419. #define CIRCUIT_PURPOSE_MIN_ 1
  420. /* these circuits were initiated elsewhere */
  421. #define CIRCUIT_PURPOSE_OR_MIN_ 1
  422. /** OR-side circuit purpose: normal circuit, at OR. */
  423. #define CIRCUIT_PURPOSE_OR 1
  424. /** OR-side circuit purpose: At OR, from the service, waiting for intro from
  425. * clients. */
  426. #define CIRCUIT_PURPOSE_INTRO_POINT 2
  427. /** OR-side circuit purpose: At OR, from the client, waiting for the service.
  428. */
  429. #define CIRCUIT_PURPOSE_REND_POINT_WAITING 3
  430. /** OR-side circuit purpose: At OR, both circuits have this purpose. */
  431. #define CIRCUIT_PURPOSE_REND_ESTABLISHED 4
  432. #define CIRCUIT_PURPOSE_OR_MAX_ 4
  433. /* these circuits originate at this node */
  434. /* here's how circ client-side purposes work:
  435. * normal circuits are C_GENERAL.
  436. * circuits that are c_introducing are either on their way to
  437. * becoming open, or they are open and waiting for a
  438. * suitable rendcirc before they send the intro.
  439. * circuits that are c_introduce_ack_wait have sent the intro,
  440. * but haven't gotten a response yet.
  441. * circuits that are c_establish_rend are either on their way
  442. * to becoming open, or they are open and have sent the
  443. * establish_rendezvous cell but haven't received an ack.
  444. * circuits that are c_rend_ready are open and have received a
  445. * rend ack, but haven't heard from the service yet. if they have a
  446. * buildstate->pending_final_cpath then they're expecting a
  447. * cell from the service, else they're not.
  448. * circuits that are c_rend_ready_intro_acked are open, and
  449. * some intro circ has sent its intro and received an ack.
  450. * circuits that are c_rend_joined are open, have heard from
  451. * the service, and are talking to it.
  452. */
  453. /** Client-side circuit purpose: Normal circuit, with cpath. */
  454. #define CIRCUIT_PURPOSE_C_GENERAL 5
  455. /** Client-side circuit purpose: at the client, connecting to intro point. */
  456. #define CIRCUIT_PURPOSE_C_INTRODUCING 6
  457. /** Client-side circuit purpose: at the client, sent INTRODUCE1 to intro point,
  458. * waiting for ACK/NAK. */
  459. #define CIRCUIT_PURPOSE_C_INTRODUCE_ACK_WAIT 7
  460. /** Client-side circuit purpose: at the client, introduced and acked, closing.
  461. */
  462. #define CIRCUIT_PURPOSE_C_INTRODUCE_ACKED 8
  463. /** Client-side circuit purpose: at the client, waiting for ack. */
  464. #define CIRCUIT_PURPOSE_C_ESTABLISH_REND 9
  465. /** Client-side circuit purpose: at the client, waiting for the service. */
  466. #define CIRCUIT_PURPOSE_C_REND_READY 10
  467. /** Client-side circuit purpose: at the client, waiting for the service,
  468. * INTRODUCE has been acknowledged. */
  469. #define CIRCUIT_PURPOSE_C_REND_READY_INTRO_ACKED 11
  470. /** Client-side circuit purpose: at the client, rendezvous established. */
  471. #define CIRCUIT_PURPOSE_C_REND_JOINED 12
  472. /** This circuit is used for build time measurement only */
  473. #define CIRCUIT_PURPOSE_C_MEASURE_TIMEOUT 13
  474. #define CIRCUIT_PURPOSE_C_MAX_ 13
  475. /** Hidden-service-side circuit purpose: at the service, waiting for
  476. * introductions. */
  477. #define CIRCUIT_PURPOSE_S_ESTABLISH_INTRO 14
  478. /** Hidden-service-side circuit purpose: at the service, successfully
  479. * established intro. */
  480. #define CIRCUIT_PURPOSE_S_INTRO 15
  481. /** Hidden-service-side circuit purpose: at the service, connecting to rend
  482. * point. */
  483. #define CIRCUIT_PURPOSE_S_CONNECT_REND 16
  484. /** Hidden-service-side circuit purpose: at the service, rendezvous
  485. * established. */
  486. #define CIRCUIT_PURPOSE_S_REND_JOINED 17
  487. /** A testing circuit; not meant to be used for actual traffic. */
  488. #define CIRCUIT_PURPOSE_TESTING 18
  489. /** A controller made this circuit and Tor should not use it. */
  490. #define CIRCUIT_PURPOSE_CONTROLLER 19
  491. /** This circuit is used for path bias probing only */
  492. #define CIRCUIT_PURPOSE_PATH_BIAS_TESTING 20
  493. #define CIRCUIT_PURPOSE_MAX_ 20
  494. /** A catch-all for unrecognized purposes. Currently we don't expect
  495. * to make or see any circuits with this purpose. */
  496. #define CIRCUIT_PURPOSE_UNKNOWN 255
  497. /** True iff the circuit purpose <b>p</b> is for a circuit that
  498. * originated at this node. */
  499. #define CIRCUIT_PURPOSE_IS_ORIGIN(p) ((p)>CIRCUIT_PURPOSE_OR_MAX_)
  500. /** True iff the circuit purpose <b>p</b> is for a circuit that originated
  501. * here to serve as a client. (Hidden services don't count here.) */
  502. #define CIRCUIT_PURPOSE_IS_CLIENT(p) \
  503. ((p)> CIRCUIT_PURPOSE_OR_MAX_ && \
  504. (p)<=CIRCUIT_PURPOSE_C_MAX_)
  505. /** True iff the circuit_t <b>c</b> is actually an origin_circuit_t. */
  506. #define CIRCUIT_IS_ORIGIN(c) (CIRCUIT_PURPOSE_IS_ORIGIN((c)->purpose))
  507. /** True iff the circuit purpose <b>p</b> is for an established rendezvous
  508. * circuit. */
  509. #define CIRCUIT_PURPOSE_IS_ESTABLISHED_REND(p) \
  510. ((p) == CIRCUIT_PURPOSE_C_REND_JOINED || \
  511. (p) == CIRCUIT_PURPOSE_S_REND_JOINED)
  512. /** True iff the circuit_t c is actually an or_circuit_t */
  513. #define CIRCUIT_IS_ORCIRC(c) (((circuit_t *)(c))->magic == OR_CIRCUIT_MAGIC)
  514. /** How many circuits do we want simultaneously in-progress to handle
  515. * a given stream? */
  516. #define MIN_CIRCUITS_HANDLING_STREAM 2
  517. /* These RELAY_COMMAND constants define values for relay cell commands, and
  518. * must match those defined in tor-spec.txt. */
  519. #define RELAY_COMMAND_BEGIN 1
  520. #define RELAY_COMMAND_DATA 2
  521. #define RELAY_COMMAND_END 3
  522. #define RELAY_COMMAND_CONNECTED 4
  523. #define RELAY_COMMAND_SENDME 5
  524. #define RELAY_COMMAND_EXTEND 6
  525. #define RELAY_COMMAND_EXTENDED 7
  526. #define RELAY_COMMAND_TRUNCATE 8
  527. #define RELAY_COMMAND_TRUNCATED 9
  528. #define RELAY_COMMAND_DROP 10
  529. #define RELAY_COMMAND_RESOLVE 11
  530. #define RELAY_COMMAND_RESOLVED 12
  531. #define RELAY_COMMAND_BEGIN_DIR 13
  532. #define RELAY_COMMAND_EXTEND2 14
  533. #define RELAY_COMMAND_EXTENDED2 15
  534. #define RELAY_COMMAND_ESTABLISH_INTRO 32
  535. #define RELAY_COMMAND_ESTABLISH_RENDEZVOUS 33
  536. #define RELAY_COMMAND_INTRODUCE1 34
  537. #define RELAY_COMMAND_INTRODUCE2 35
  538. #define RELAY_COMMAND_RENDEZVOUS1 36
  539. #define RELAY_COMMAND_RENDEZVOUS2 37
  540. #define RELAY_COMMAND_INTRO_ESTABLISHED 38
  541. #define RELAY_COMMAND_RENDEZVOUS_ESTABLISHED 39
  542. #define RELAY_COMMAND_INTRODUCE_ACK 40
  543. /* Reasons why an OR connection is closed. */
  544. #define END_OR_CONN_REASON_DONE 1
  545. #define END_OR_CONN_REASON_REFUSED 2 /* connection refused */
  546. #define END_OR_CONN_REASON_OR_IDENTITY 3
  547. #define END_OR_CONN_REASON_CONNRESET 4 /* connection reset by peer */
  548. #define END_OR_CONN_REASON_TIMEOUT 5
  549. #define END_OR_CONN_REASON_NO_ROUTE 6 /* no route to host/net */
  550. #define END_OR_CONN_REASON_IO_ERROR 7 /* read/write error */
  551. #define END_OR_CONN_REASON_RESOURCE_LIMIT 8 /* sockets, buffers, etc */
  552. #define END_OR_CONN_REASON_PT_MISSING 9 /* PT failed or not available */
  553. #define END_OR_CONN_REASON_MISC 10
  554. /* Reasons why we (or a remote OR) might close a stream. See tor-spec.txt for
  555. * documentation of these. The values must match. */
  556. #define END_STREAM_REASON_MISC 1
  557. #define END_STREAM_REASON_RESOLVEFAILED 2
  558. #define END_STREAM_REASON_CONNECTREFUSED 3
  559. #define END_STREAM_REASON_EXITPOLICY 4
  560. #define END_STREAM_REASON_DESTROY 5
  561. #define END_STREAM_REASON_DONE 6
  562. #define END_STREAM_REASON_TIMEOUT 7
  563. #define END_STREAM_REASON_NOROUTE 8
  564. #define END_STREAM_REASON_HIBERNATING 9
  565. #define END_STREAM_REASON_INTERNAL 10
  566. #define END_STREAM_REASON_RESOURCELIMIT 11
  567. #define END_STREAM_REASON_CONNRESET 12
  568. #define END_STREAM_REASON_TORPROTOCOL 13
  569. #define END_STREAM_REASON_NOTDIRECTORY 14
  570. #define END_STREAM_REASON_ENTRYPOLICY 15
  571. /* These high-numbered end reasons are not part of the official spec,
  572. * and are not intended to be put in relay end cells. They are here
  573. * to be more informative when sending back socks replies to the
  574. * application. */
  575. /* XXXX 256 is no longer used; feel free to reuse it. */
  576. /** We were unable to attach the connection to any circuit at all. */
  577. /* XXXX the ways we use this one don't make a lot of sense. */
  578. #define END_STREAM_REASON_CANT_ATTACH 257
  579. /** We can't connect to any directories at all, so we killed our streams
  580. * before they can time out. */
  581. #define END_STREAM_REASON_NET_UNREACHABLE 258
  582. /** This is a SOCKS connection, and the client used (or misused) the SOCKS
  583. * protocol in a way we couldn't handle. */
  584. #define END_STREAM_REASON_SOCKSPROTOCOL 259
  585. /** This is a transparent proxy connection, but we can't extract the original
  586. * target address:port. */
  587. #define END_STREAM_REASON_CANT_FETCH_ORIG_DEST 260
  588. /** This is a connection on the NATD port, and the destination IP:Port was
  589. * either ill-formed or out-of-range. */
  590. #define END_STREAM_REASON_INVALID_NATD_DEST 261
  591. /** The target address is in a private network (like 127.0.0.1 or 10.0.0.1);
  592. * you don't want to do that over a randomly chosen exit */
  593. #define END_STREAM_REASON_PRIVATE_ADDR 262
  594. /** Bitwise-and this value with endreason to mask out all flags. */
  595. #define END_STREAM_REASON_MASK 511
  596. /** Bitwise-or this with the argument to control_event_stream_status
  597. * to indicate that the reason came from an END cell. */
  598. #define END_STREAM_REASON_FLAG_REMOTE 512
  599. /** Bitwise-or this with the argument to control_event_stream_status
  600. * to indicate that we already sent a CLOSED stream event. */
  601. #define END_STREAM_REASON_FLAG_ALREADY_SENT_CLOSED 1024
  602. /** Bitwise-or this with endreason to indicate that we already sent
  603. * a socks reply, and no further reply needs to be sent from
  604. * connection_mark_unattached_ap(). */
  605. #define END_STREAM_REASON_FLAG_ALREADY_SOCKS_REPLIED 2048
  606. /** Reason for remapping an AP connection's address: we have a cached
  607. * answer. */
  608. #define REMAP_STREAM_SOURCE_CACHE 1
  609. /** Reason for remapping an AP connection's address: the exit node told us an
  610. * answer. */
  611. #define REMAP_STREAM_SOURCE_EXIT 2
  612. /* 'type' values to use in RESOLVED cells. Specified in tor-spec.txt. */
  613. #define RESOLVED_TYPE_HOSTNAME 0
  614. #define RESOLVED_TYPE_IPV4 4
  615. #define RESOLVED_TYPE_IPV6 6
  616. #define RESOLVED_TYPE_ERROR_TRANSIENT 0xF0
  617. #define RESOLVED_TYPE_ERROR 0xF1
  618. /* Negative reasons are internal: we never send them in a DESTROY or TRUNCATE
  619. * call; they only go to the controller for tracking */
  620. /* Closing introduction point that were opened in parallel. */
  621. #define END_CIRC_REASON_IP_NOW_REDUNDANT -4
  622. /** Our post-timeout circuit time measurement period expired.
  623. * We must give up now */
  624. #define END_CIRC_REASON_MEASUREMENT_EXPIRED -3
  625. /** We couldn't build a path for this circuit. */
  626. #define END_CIRC_REASON_NOPATH -2
  627. /** Catch-all "other" reason for closing origin circuits. */
  628. #define END_CIRC_AT_ORIGIN -1
  629. /* Reasons why we (or a remote OR) might close a circuit. See tor-spec.txt for
  630. * documentation of these. */
  631. #define END_CIRC_REASON_MIN_ 0
  632. #define END_CIRC_REASON_NONE 0
  633. #define END_CIRC_REASON_TORPROTOCOL 1
  634. #define END_CIRC_REASON_INTERNAL 2
  635. #define END_CIRC_REASON_REQUESTED 3
  636. #define END_CIRC_REASON_HIBERNATING 4
  637. #define END_CIRC_REASON_RESOURCELIMIT 5
  638. #define END_CIRC_REASON_CONNECTFAILED 6
  639. #define END_CIRC_REASON_OR_IDENTITY 7
  640. #define END_CIRC_REASON_CHANNEL_CLOSED 8
  641. #define END_CIRC_REASON_FINISHED 9
  642. #define END_CIRC_REASON_TIMEOUT 10
  643. #define END_CIRC_REASON_DESTROYED 11
  644. #define END_CIRC_REASON_NOSUCHSERVICE 12
  645. #define END_CIRC_REASON_MAX_ 12
  646. /** Bitwise-OR this with the argument to circuit_mark_for_close() or
  647. * control_event_circuit_status() to indicate that the reason was
  648. * passed through from a destroy or truncate cell. */
  649. #define END_CIRC_REASON_FLAG_REMOTE 512
  650. /** Length of 'y' portion of 'y.onion' URL. */
  651. #define REND_SERVICE_ID_LEN_BASE32 16
  652. /** Length of 'y.onion' including '.onion' URL. */
  653. #define REND_SERVICE_ADDRESS_LEN (16+1+5)
  654. /** Length of a binary-encoded rendezvous service ID. */
  655. #define REND_SERVICE_ID_LEN 10
  656. /** Time period for which a v2 descriptor will be valid. */
  657. #define REND_TIME_PERIOD_V2_DESC_VALIDITY (24*60*60)
  658. /** Time period within which two sets of v2 descriptors will be uploaded in
  659. * parallel. */
  660. #define REND_TIME_PERIOD_OVERLAPPING_V2_DESCS (60*60)
  661. /** Number of non-consecutive replicas (i.e. distributed somewhere
  662. * in the ring) for a descriptor. */
  663. #define REND_NUMBER_OF_NON_CONSECUTIVE_REPLICAS 2
  664. /** Number of consecutive replicas for a descriptor. */
  665. #define REND_NUMBER_OF_CONSECUTIVE_REPLICAS 3
  666. /** Length of v2 descriptor ID (32 base32 chars = 160 bits). */
  667. #define REND_DESC_ID_V2_LEN_BASE32 32
  668. /** Length of the base32-encoded secret ID part of versioned hidden service
  669. * descriptors. */
  670. #define REND_SECRET_ID_PART_LEN_BASE32 32
  671. /** Length of the base32-encoded hash of an introduction point's
  672. * identity key. */
  673. #define REND_INTRO_POINT_ID_LEN_BASE32 32
  674. /** Length of the descriptor cookie that is used for client authorization
  675. * to hidden services. */
  676. #define REND_DESC_COOKIE_LEN 16
  677. /** Length of the base64-encoded descriptor cookie that is used for
  678. * exchanging client authorization between hidden service and client. */
  679. #define REND_DESC_COOKIE_LEN_BASE64 22
  680. /** Length of client identifier in encrypted introduction points for hidden
  681. * service authorization type 'basic'. */
  682. #define REND_BASIC_AUTH_CLIENT_ID_LEN 4
  683. /** Multiple of the number of clients to which the real number of clients
  684. * is padded with fake clients for hidden service authorization type
  685. * 'basic'. */
  686. #define REND_BASIC_AUTH_CLIENT_MULTIPLE 16
  687. /** Length of client entry consisting of client identifier and encrypted
  688. * session key for hidden service authorization type 'basic'. */
  689. #define REND_BASIC_AUTH_CLIENT_ENTRY_LEN (REND_BASIC_AUTH_CLIENT_ID_LEN \
  690. + CIPHER_KEY_LEN)
  691. /** Maximum size of v2 hidden service descriptors. */
  692. #define REND_DESC_MAX_SIZE (20 * 1024)
  693. /** Legal characters for use in authorized client names for a hidden
  694. * service. */
  695. #define REND_LEGAL_CLIENTNAME_CHARACTERS \
  696. "abcdefghijklmnopqrstuvwxyzABCDEFGHIJKLMNOPQRSTUVWXYZ0123456789+-_"
  697. /** Maximum length of authorized client names for a hidden service. */
  698. #define REND_CLIENTNAME_MAX_LEN 16
  699. /** Length of the rendezvous cookie that is used to connect circuits at the
  700. * rendezvous point. */
  701. #define REND_COOKIE_LEN DIGEST_LEN
  702. /** Client authorization type that a hidden service performs. */
  703. typedef enum rend_auth_type_t {
  704. REND_NO_AUTH = 0,
  705. REND_BASIC_AUTH = 1,
  706. REND_STEALTH_AUTH = 2,
  707. } rend_auth_type_t;
  708. /** Client-side configuration of authorization for a hidden service. */
  709. typedef struct rend_service_authorization_t {
  710. uint8_t descriptor_cookie[REND_DESC_COOKIE_LEN];
  711. char onion_address[REND_SERVICE_ADDRESS_LEN+1];
  712. rend_auth_type_t auth_type;
  713. } rend_service_authorization_t;
  714. /** Client- and server-side data that is used for hidden service connection
  715. * establishment. Not all fields contain data depending on where this struct
  716. * is used. */
  717. typedef struct rend_data_t {
  718. /* Hidden service protocol version of this base object. */
  719. uint32_t version;
  720. /** List of HSDir fingerprints on which this request has been sent to. This
  721. * contains binary identity digest of the directory of size DIGEST_LEN. */
  722. smartlist_t *hsdirs_fp;
  723. /** Rendezvous cookie used by both, client and service. */
  724. char rend_cookie[REND_COOKIE_LEN];
  725. /** Number of streams associated with this rendezvous circuit. */
  726. int nr_streams;
  727. } rend_data_t;
  728. typedef struct rend_data_v2_t {
  729. /* Rendezvous base data. */
  730. rend_data_t base_;
  731. /** Onion address (without the .onion part) that a client requests. */
  732. char onion_address[REND_SERVICE_ID_LEN_BASE32+1];
  733. /** Descriptor ID for each replicas computed from the onion address. If
  734. * the onion address is empty, this array MUST be empty. We keep them so
  735. * we know when to purge our entry in the last hsdir request table. */
  736. char descriptor_id[REND_NUMBER_OF_NON_CONSECUTIVE_REPLICAS][DIGEST_LEN];
  737. /** (Optional) descriptor cookie that is used by a client. */
  738. char descriptor_cookie[REND_DESC_COOKIE_LEN];
  739. /** Authorization type for accessing a service used by a client. */
  740. rend_auth_type_t auth_type;
  741. /** Descriptor ID for a client request. The control port command HSFETCH
  742. * uses this. It's set if the descriptor query should only use this
  743. * descriptor ID. */
  744. char desc_id_fetch[DIGEST_LEN];
  745. /** Hash of the hidden service's PK used by a service. */
  746. char rend_pk_digest[DIGEST_LEN];
  747. } rend_data_v2_t;
  748. /* From a base rend_data_t object <b>d</d>, return the v2 object. */
  749. static inline
  750. rend_data_v2_t *TO_REND_DATA_V2(const rend_data_t *d)
  751. {
  752. tor_assert(d);
  753. tor_assert(d->version == 2);
  754. return DOWNCAST(rend_data_v2_t, d);
  755. }
  756. /* Stub because we can't include hs_ident.h. */
  757. struct hs_ident_edge_conn_t;
  758. struct hs_ident_dir_conn_t;
  759. struct hs_ident_circuit_t;
  760. /* Stub because we can't include hs_common.h. */
  761. struct hsdir_index_t;
  762. /** Time interval for tracking replays of DH public keys received in
  763. * INTRODUCE2 cells. Used only to avoid launching multiple
  764. * simultaneous attempts to connect to the same rendezvous point. */
  765. #define REND_REPLAY_TIME_INTERVAL (5 * 60)
  766. /** Used to indicate which way a cell is going on a circuit. */
  767. typedef enum {
  768. CELL_DIRECTION_IN=1, /**< The cell is moving towards the origin. */
  769. CELL_DIRECTION_OUT=2, /**< The cell is moving away from the origin. */
  770. } cell_direction_t;
  771. /** Initial value for both sides of a circuit transmission window when the
  772. * circuit is initialized. Measured in cells. */
  773. #define CIRCWINDOW_START 1000
  774. #define CIRCWINDOW_START_MIN 100
  775. #define CIRCWINDOW_START_MAX 1000
  776. /** Amount to increment a circuit window when we get a circuit SENDME. */
  777. #define CIRCWINDOW_INCREMENT 100
  778. /** Initial value on both sides of a stream transmission window when the
  779. * stream is initialized. Measured in cells. */
  780. #define STREAMWINDOW_START 500
  781. /** Amount to increment a stream window when we get a stream SENDME. */
  782. #define STREAMWINDOW_INCREMENT 50
  783. /** Maximum number of queued cells on a circuit for which we are the
  784. * midpoint before we give up and kill it. This must be >= circwindow
  785. * to avoid killing innocent circuits, and >= circwindow*2 to give
  786. * leaky-pipe a chance of working someday. The ORCIRC_MAX_MIDDLE_KILL_THRESH
  787. * ratio controls the margin of error between emitting a warning and
  788. * killing the circuit.
  789. */
  790. #define ORCIRC_MAX_MIDDLE_CELLS (CIRCWINDOW_START_MAX*2)
  791. /** Ratio of hard (circuit kill) to soft (warning) thresholds for the
  792. * ORCIRC_MAX_MIDDLE_CELLS tests.
  793. */
  794. #define ORCIRC_MAX_MIDDLE_KILL_THRESH (1.1f)
  795. /* Cell commands. These values are defined in tor-spec.txt. */
  796. #define CELL_PADDING 0
  797. #define CELL_CREATE 1
  798. #define CELL_CREATED 2
  799. #define CELL_RELAY 3
  800. #define CELL_DESTROY 4
  801. #define CELL_CREATE_FAST 5
  802. #define CELL_CREATED_FAST 6
  803. #define CELL_VERSIONS 7
  804. #define CELL_NETINFO 8
  805. #define CELL_RELAY_EARLY 9
  806. #define CELL_CREATE2 10
  807. #define CELL_CREATED2 11
  808. #define CELL_PADDING_NEGOTIATE 12
  809. #define CELL_VPADDING 128
  810. #define CELL_CERTS 129
  811. #define CELL_AUTH_CHALLENGE 130
  812. #define CELL_AUTHENTICATE 131
  813. #define CELL_AUTHORIZE 132
  814. #define CELL_COMMAND_MAX_ 132
  815. /** How long to test reachability before complaining to the user. */
  816. #define TIMEOUT_UNTIL_UNREACHABILITY_COMPLAINT (20*60)
  817. /** Legal characters in a nickname. */
  818. #define LEGAL_NICKNAME_CHARACTERS \
  819. "abcdefghijklmnopqrstuvwxyzABCDEFGHIJKLMNOPQRSTUVWXYZ0123456789"
  820. /** Name to use in client TLS certificates if no nickname is given. Once
  821. * Tor 0.1.2.x is obsolete, we can remove this. */
  822. #define DEFAULT_CLIENT_NICKNAME "client"
  823. /** Name chosen by routers that don't configure nicknames */
  824. #define UNNAMED_ROUTER_NICKNAME "Unnamed"
  825. /** Number of bytes in a SOCKS4 header. */
  826. #define SOCKS4_NETWORK_LEN 8
  827. /*
  828. * Relay payload:
  829. * Relay command [1 byte]
  830. * Recognized [2 bytes]
  831. * Stream ID [2 bytes]
  832. * Partial SHA-1 [4 bytes]
  833. * Length [2 bytes]
  834. * Relay payload [498 bytes]
  835. */
  836. /** Number of bytes in a cell, minus cell header. */
  837. #define CELL_PAYLOAD_SIZE 509
  838. /** Number of bytes in a cell transmitted over the network, in the longest
  839. * form */
  840. #define CELL_MAX_NETWORK_SIZE 514
  841. /** Maximum length of a header on a variable-length cell. */
  842. #define VAR_CELL_MAX_HEADER_SIZE 7
  843. static int get_cell_network_size(int wide_circ_ids);
  844. static inline int get_cell_network_size(int wide_circ_ids)
  845. {
  846. return wide_circ_ids ? CELL_MAX_NETWORK_SIZE : CELL_MAX_NETWORK_SIZE - 2;
  847. }
  848. static int get_var_cell_header_size(int wide_circ_ids);
  849. static inline int get_var_cell_header_size(int wide_circ_ids)
  850. {
  851. return wide_circ_ids ? VAR_CELL_MAX_HEADER_SIZE :
  852. VAR_CELL_MAX_HEADER_SIZE - 2;
  853. }
  854. static int get_circ_id_size(int wide_circ_ids);
  855. static inline int get_circ_id_size(int wide_circ_ids)
  856. {
  857. return wide_circ_ids ? 4 : 2;
  858. }
  859. /** Number of bytes in a relay cell's header (not including general cell
  860. * header). */
  861. #define RELAY_HEADER_SIZE (1+2+2+4+2)
  862. /** Largest number of bytes that can fit in a relay cell payload. */
  863. #define RELAY_PAYLOAD_SIZE (CELL_PAYLOAD_SIZE-RELAY_HEADER_SIZE)
  864. /** Identifies a circuit on an or_connection */
  865. typedef uint32_t circid_t;
  866. /** Identifies a stream on a circuit */
  867. typedef uint16_t streamid_t;
  868. /* channel_t typedef; struct channel_s is in channel.h */
  869. typedef struct channel_s channel_t;
  870. /* channel_listener_t typedef; struct channel_listener_s is in channel.h */
  871. typedef struct channel_listener_s channel_listener_t;
  872. /* channel states for channel_t */
  873. typedef enum {
  874. /*
  875. * Closed state - channel is inactive
  876. *
  877. * Permitted transitions from:
  878. * - CHANNEL_STATE_CLOSING
  879. * Permitted transitions to:
  880. * - CHANNEL_STATE_OPENING
  881. */
  882. CHANNEL_STATE_CLOSED = 0,
  883. /*
  884. * Opening state - channel is trying to connect
  885. *
  886. * Permitted transitions from:
  887. * - CHANNEL_STATE_CLOSED
  888. * Permitted transitions to:
  889. * - CHANNEL_STATE_CLOSING
  890. * - CHANNEL_STATE_ERROR
  891. * - CHANNEL_STATE_OPEN
  892. */
  893. CHANNEL_STATE_OPENING,
  894. /*
  895. * Open state - channel is active and ready for use
  896. *
  897. * Permitted transitions from:
  898. * - CHANNEL_STATE_MAINT
  899. * - CHANNEL_STATE_OPENING
  900. * Permitted transitions to:
  901. * - CHANNEL_STATE_CLOSING
  902. * - CHANNEL_STATE_ERROR
  903. * - CHANNEL_STATE_MAINT
  904. */
  905. CHANNEL_STATE_OPEN,
  906. /*
  907. * Maintenance state - channel is temporarily offline for subclass specific
  908. * maintenance activities such as TLS renegotiation.
  909. *
  910. * Permitted transitions from:
  911. * - CHANNEL_STATE_OPEN
  912. * Permitted transitions to:
  913. * - CHANNEL_STATE_CLOSING
  914. * - CHANNEL_STATE_ERROR
  915. * - CHANNEL_STATE_OPEN
  916. */
  917. CHANNEL_STATE_MAINT,
  918. /*
  919. * Closing state - channel is shutting down
  920. *
  921. * Permitted transitions from:
  922. * - CHANNEL_STATE_MAINT
  923. * - CHANNEL_STATE_OPEN
  924. * Permitted transitions to:
  925. * - CHANNEL_STATE_CLOSED,
  926. * - CHANNEL_STATE_ERROR
  927. */
  928. CHANNEL_STATE_CLOSING,
  929. /*
  930. * Error state - channel has experienced a permanent error
  931. *
  932. * Permitted transitions from:
  933. * - CHANNEL_STATE_CLOSING
  934. * - CHANNEL_STATE_MAINT
  935. * - CHANNEL_STATE_OPENING
  936. * - CHANNEL_STATE_OPEN
  937. * Permitted transitions to:
  938. * - None
  939. */
  940. CHANNEL_STATE_ERROR,
  941. /*
  942. * Placeholder for maximum state value
  943. */
  944. CHANNEL_STATE_LAST
  945. } channel_state_t;
  946. /* channel listener states for channel_listener_t */
  947. typedef enum {
  948. /*
  949. * Closed state - channel listener is inactive
  950. *
  951. * Permitted transitions from:
  952. * - CHANNEL_LISTENER_STATE_CLOSING
  953. * Permitted transitions to:
  954. * - CHANNEL_LISTENER_STATE_LISTENING
  955. */
  956. CHANNEL_LISTENER_STATE_CLOSED = 0,
  957. /*
  958. * Listening state - channel listener is listening for incoming
  959. * connections
  960. *
  961. * Permitted transitions from:
  962. * - CHANNEL_LISTENER_STATE_CLOSED
  963. * Permitted transitions to:
  964. * - CHANNEL_LISTENER_STATE_CLOSING
  965. * - CHANNEL_LISTENER_STATE_ERROR
  966. */
  967. CHANNEL_LISTENER_STATE_LISTENING,
  968. /*
  969. * Closing state - channel listener is shutting down
  970. *
  971. * Permitted transitions from:
  972. * - CHANNEL_LISTENER_STATE_LISTENING
  973. * Permitted transitions to:
  974. * - CHANNEL_LISTENER_STATE_CLOSED,
  975. * - CHANNEL_LISTENER_STATE_ERROR
  976. */
  977. CHANNEL_LISTENER_STATE_CLOSING,
  978. /*
  979. * Error state - channel listener has experienced a permanent error
  980. *
  981. * Permitted transitions from:
  982. * - CHANNEL_STATE_CLOSING
  983. * - CHANNEL_STATE_LISTENING
  984. * Permitted transitions to:
  985. * - None
  986. */
  987. CHANNEL_LISTENER_STATE_ERROR,
  988. /*
  989. * Placeholder for maximum state value
  990. */
  991. CHANNEL_LISTENER_STATE_LAST
  992. } channel_listener_state_t;
  993. /* TLS channel stuff */
  994. typedef struct channel_tls_s channel_tls_t;
  995. /* circuitmux_t typedef; struct circuitmux_s is in circuitmux.h */
  996. typedef struct circuitmux_s circuitmux_t;
  997. /** Parsed onion routing cell. All communication between nodes
  998. * is via cells. */
  999. typedef struct cell_t {
  1000. circid_t circ_id; /**< Circuit which received the cell. */
  1001. uint8_t command; /**< Type of the cell: one of CELL_PADDING, CELL_CREATE,
  1002. * CELL_DESTROY, etc */
  1003. uint8_t payload[CELL_PAYLOAD_SIZE]; /**< Cell body. */
  1004. } cell_t;
  1005. /** Parsed variable-length onion routing cell. */
  1006. typedef struct var_cell_t {
  1007. /** Type of the cell: CELL_VERSIONS, etc. */
  1008. uint8_t command;
  1009. /** Circuit thich received the cell */
  1010. circid_t circ_id;
  1011. /** Number of bytes actually stored in <b>payload</b> */
  1012. uint16_t payload_len;
  1013. /** Payload of this cell */
  1014. uint8_t payload[FLEXIBLE_ARRAY_MEMBER];
  1015. } var_cell_t;
  1016. /** A parsed Extended ORPort message. */
  1017. typedef struct ext_or_cmd_t {
  1018. uint16_t cmd; /** Command type */
  1019. uint16_t len; /** Body length */
  1020. char body[FLEXIBLE_ARRAY_MEMBER]; /** Message body */
  1021. } ext_or_cmd_t;
  1022. /** A cell as packed for writing to the network. */
  1023. typedef struct packed_cell_t {
  1024. /** Next cell queued on this circuit. */
  1025. TOR_SIMPLEQ_ENTRY(packed_cell_t) next;
  1026. char body[CELL_MAX_NETWORK_SIZE]; /**< Cell as packed for network. */
  1027. uint32_t inserted_time; /**< Time (in milliseconds since epoch, with high
  1028. * bits truncated) when this cell was inserted. */
  1029. } packed_cell_t;
  1030. /** A queue of cells on a circuit, waiting to be added to the
  1031. * or_connection_t's outbuf. */
  1032. typedef struct cell_queue_t {
  1033. /** Linked list of packed_cell_t*/
  1034. TOR_SIMPLEQ_HEAD(cell_simpleq, packed_cell_t) head;
  1035. int n; /**< The number of cells in the queue. */
  1036. } cell_queue_t;
  1037. /** Beginning of a RELAY cell payload. */
  1038. typedef struct {
  1039. uint8_t command; /**< The end-to-end relay command. */
  1040. uint16_t recognized; /**< Used to tell whether cell is for us. */
  1041. streamid_t stream_id; /**< Which stream is this cell associated with? */
  1042. char integrity[4]; /**< Used to tell whether cell is corrupted. */
  1043. uint16_t length; /**< How long is the payload body? */
  1044. } relay_header_t;
  1045. typedef struct buf_t buf_t;
  1046. typedef struct socks_request_t socks_request_t;
  1047. #define buf_t buf_t
  1048. typedef struct entry_port_cfg_t {
  1049. /* Client port types (socks, dns, trans, natd) only: */
  1050. uint8_t isolation_flags; /**< Zero or more isolation flags */
  1051. int session_group; /**< A session group, or -1 if this port is not in a
  1052. * session group. */
  1053. /* Socks only: */
  1054. /** When both no-auth and user/pass are advertised by a SOCKS client, select
  1055. * no-auth. */
  1056. unsigned int socks_prefer_no_auth : 1;
  1057. /** When ISO_SOCKSAUTH is in use, Keep-Alive circuits indefinitely. */
  1058. unsigned int socks_iso_keep_alive : 1;
  1059. /* Client port types only: */
  1060. unsigned int ipv4_traffic : 1;
  1061. unsigned int ipv6_traffic : 1;
  1062. unsigned int prefer_ipv6 : 1;
  1063. unsigned int dns_request : 1;
  1064. unsigned int onion_traffic : 1;
  1065. /** For a socks listener: should we cache IPv4/IPv6 DNS information that
  1066. * exit nodes tell us?
  1067. *
  1068. * @{ */
  1069. unsigned int cache_ipv4_answers : 1;
  1070. unsigned int cache_ipv6_answers : 1;
  1071. /** @} */
  1072. /** For a socks listeners: if we find an answer in our client-side DNS cache,
  1073. * should we use it?
  1074. *
  1075. * @{ */
  1076. unsigned int use_cached_ipv4_answers : 1;
  1077. unsigned int use_cached_ipv6_answers : 1;
  1078. /** @} */
  1079. /** For socks listeners: When we can automap an address to IPv4 or IPv6,
  1080. * do we prefer IPv6? */
  1081. unsigned int prefer_ipv6_virtaddr : 1;
  1082. } entry_port_cfg_t;
  1083. typedef struct server_port_cfg_t {
  1084. /* Server port types (or, dir) only: */
  1085. unsigned int no_advertise : 1;
  1086. unsigned int no_listen : 1;
  1087. unsigned int all_addrs : 1;
  1088. unsigned int bind_ipv4_only : 1;
  1089. unsigned int bind_ipv6_only : 1;
  1090. } server_port_cfg_t;
  1091. /* Values for connection_t.magic: used to make sure that downcasts (casts from
  1092. * connection_t to foo_connection_t) are safe. */
  1093. #define BASE_CONNECTION_MAGIC 0x7C3C304Eu
  1094. #define OR_CONNECTION_MAGIC 0x7D31FF03u
  1095. #define EDGE_CONNECTION_MAGIC 0xF0374013u
  1096. #define ENTRY_CONNECTION_MAGIC 0xbb4a5703
  1097. #define DIR_CONNECTION_MAGIC 0x9988ffeeu
  1098. #define CONTROL_CONNECTION_MAGIC 0x8abc765du
  1099. #define LISTENER_CONNECTION_MAGIC 0x1a1ac741u
  1100. /** Description of a connection to another host or process, and associated
  1101. * data.
  1102. *
  1103. * A connection is named based on what it's connected to -- an "OR
  1104. * connection" has a Tor node on the other end, an "exit
  1105. * connection" has a website or other server on the other end, and an
  1106. * "AP connection" has an application proxy (and thus a user) on the
  1107. * other end.
  1108. *
  1109. * Every connection has a type and a state. Connections never change
  1110. * their type, but can go through many state changes in their lifetime.
  1111. *
  1112. * Every connection has two associated input and output buffers.
  1113. * Listeners don't use them. For non-listener connections, incoming
  1114. * data is appended to conn->inbuf, and outgoing data is taken from
  1115. * conn->outbuf. Connections differ primarily in the functions called
  1116. * to fill and drain these buffers.
  1117. */
  1118. typedef struct connection_t {
  1119. uint32_t magic; /**< For memory debugging: must equal one of
  1120. * *_CONNECTION_MAGIC. */
  1121. uint8_t state; /**< Current state of this connection. */
  1122. unsigned int type:5; /**< What kind of connection is this? */
  1123. unsigned int purpose:5; /**< Only used for DIR and EXIT types currently. */
  1124. /* The next fields are all one-bit booleans. Some are only applicable to
  1125. * connection subtypes, but we hold them here anyway, to save space.
  1126. */
  1127. unsigned int read_blocked_on_bw:1; /**< Boolean: should we start reading
  1128. * again once the bandwidth throttler allows it? */
  1129. unsigned int write_blocked_on_bw:1; /**< Boolean: should we start writing
  1130. * again once the bandwidth throttler allows
  1131. * writes? */
  1132. unsigned int hold_open_until_flushed:1; /**< Despite this connection's being
  1133. * marked for close, do we flush it
  1134. * before closing it? */
  1135. unsigned int inbuf_reached_eof:1; /**< Boolean: did read() return 0 on this
  1136. * conn? */
  1137. /** Set to 1 when we're inside connection_flushed_some to keep us from
  1138. * calling connection_handle_write() recursively. */
  1139. unsigned int in_flushed_some:1;
  1140. /** True if connection_handle_write is currently running on this connection.
  1141. */
  1142. unsigned int in_connection_handle_write:1;
  1143. /* For linked connections:
  1144. */
  1145. unsigned int linked:1; /**< True if there is, or has been, a linked_conn. */
  1146. /** True iff we'd like to be notified about read events from the
  1147. * linked conn. */
  1148. unsigned int reading_from_linked_conn:1;
  1149. /** True iff we're willing to write to the linked conn. */
  1150. unsigned int writing_to_linked_conn:1;
  1151. /** True iff we're currently able to read on the linked conn, and our
  1152. * read_event should be made active with libevent. */
  1153. unsigned int active_on_link:1;
  1154. /** True iff we've called connection_close_immediate() on this linked
  1155. * connection. */
  1156. unsigned int linked_conn_is_closed:1;
  1157. /** CONNECT/SOCKS proxy client handshake state (for outgoing connections). */
  1158. unsigned int proxy_state:4;
  1159. /** Our socket; set to TOR_INVALID_SOCKET if this connection is closed,
  1160. * or has no socket. */
  1161. tor_socket_t s;
  1162. int conn_array_index; /**< Index into the global connection array. */
  1163. struct event *read_event; /**< Libevent event structure. */
  1164. struct event *write_event; /**< Libevent event structure. */
  1165. buf_t *inbuf; /**< Buffer holding data read over this connection. */
  1166. buf_t *outbuf; /**< Buffer holding data to write over this connection. */
  1167. size_t outbuf_flushlen; /**< How much data should we try to flush from the
  1168. * outbuf? */
  1169. time_t timestamp_lastread; /**< When was the last time libevent said we could
  1170. * read? */
  1171. time_t timestamp_lastwritten; /**< When was the last time libevent said we
  1172. * could write? */
  1173. time_t timestamp_created; /**< When was this connection_t created? */
  1174. int socket_family; /**< Address family of this connection's socket. Usually
  1175. * AF_INET, but it can also be AF_UNIX, or AF_INET6 */
  1176. tor_addr_t addr; /**< IP that socket "s" is directly connected to;
  1177. * may be the IP address for a proxy or pluggable transport,
  1178. * see "address" for the address of the final destination.
  1179. */
  1180. uint16_t port; /**< If non-zero, port that socket "s" is directly connected
  1181. * to; may be the port for a proxy or pluggable transport,
  1182. * see "address" for the port at the final destination. */
  1183. uint16_t marked_for_close; /**< Should we close this conn on the next
  1184. * iteration of the main loop? (If true, holds
  1185. * the line number where this connection was
  1186. * marked.) */
  1187. const char *marked_for_close_file; /**< For debugging: in which file were
  1188. * we marked for close? */
  1189. char *address; /**< FQDN (or IP) and port of the final destination for this
  1190. * connection; this is always the remote address, it is
  1191. * passed to a proxy or pluggable transport if one in use.
  1192. * See "addr" and "port" for the address that socket "s" is
  1193. * directly connected to.
  1194. * strdup into this, because free_connection() frees it. */
  1195. /** Another connection that's connected to this one in lieu of a socket. */
  1196. struct connection_t *linked_conn;
  1197. /** Unique identifier for this connection on this Tor instance. */
  1198. uint64_t global_identifier;
  1199. /** Bytes read since last call to control_event_conn_bandwidth_used().
  1200. * Only used if we're configured to emit CONN_BW events. */
  1201. uint32_t n_read_conn_bw;
  1202. /** Bytes written since last call to control_event_conn_bandwidth_used().
  1203. * Only used if we're configured to emit CONN_BW events. */
  1204. uint32_t n_written_conn_bw;
  1205. } connection_t;
  1206. /** Subtype of connection_t; used for a listener socket. */
  1207. typedef struct listener_connection_t {
  1208. connection_t base_;
  1209. /** If the connection is a CONN_TYPE_AP_DNS_LISTENER, this field points
  1210. * to the evdns_server_port it uses to listen to and answer connections. */
  1211. struct evdns_server_port *dns_server_port;
  1212. entry_port_cfg_t entry_cfg;
  1213. } listener_connection_t;
  1214. /** Minimum length of the random part of an AUTH_CHALLENGE cell. */
  1215. #define OR_AUTH_CHALLENGE_LEN 32
  1216. /**
  1217. * @name Certificate types for CERTS cells.
  1218. *
  1219. * These values are defined by the protocol, and affect how an X509
  1220. * certificate in a CERTS cell is interpreted and used.
  1221. *
  1222. * @{ */
  1223. /** A certificate that authenticates a TLS link key. The subject key
  1224. * must match the key used in the TLS handshake; it must be signed by
  1225. * the identity key. */
  1226. #define OR_CERT_TYPE_TLS_LINK 1
  1227. /** A self-signed identity certificate. The subject key must be a
  1228. * 1024-bit RSA key. */
  1229. #define OR_CERT_TYPE_ID_1024 2
  1230. /** A certificate that authenticates a key used in an AUTHENTICATE cell
  1231. * in the v3 handshake. The subject key must be a 1024-bit RSA key; it
  1232. * must be signed by the identity key */
  1233. #define OR_CERT_TYPE_AUTH_1024 3
  1234. /* DOCDOC */
  1235. #define OR_CERT_TYPE_RSA_ED_CROSSCERT 7
  1236. /**@}*/
  1237. /** The first supported type of AUTHENTICATE cell. It contains
  1238. * a bunch of structures signed with an RSA1024 key. The signed
  1239. * structures include a HMAC using negotiated TLS secrets, and a digest
  1240. * of all cells sent or received before the AUTHENTICATE cell (including
  1241. * the random server-generated AUTH_CHALLENGE cell).
  1242. */
  1243. #define AUTHTYPE_RSA_SHA256_TLSSECRET 1
  1244. /** As AUTHTYPE_RSA_SHA256_TLSSECRET, but instead of using the
  1245. * negotiated TLS secrets, uses exported keying material from the TLS
  1246. * session as described in RFC 5705.
  1247. *
  1248. * Not used by today's tors, since everything that supports this
  1249. * also supports ED25519_SHA3_5705, which is better.
  1250. **/
  1251. #define AUTHTYPE_RSA_SHA256_RFC5705 2
  1252. /** As AUTHTYPE_RSA_SHA256_RFC5705, but uses an Ed25519 identity key to
  1253. * authenticate. */
  1254. #define AUTHTYPE_ED25519_SHA256_RFC5705 3
  1255. /*
  1256. * NOTE: authchallenge_type_is_better() relies on these AUTHTYPE codes
  1257. * being sorted in order of preference. If we someday add one with
  1258. * a higher numerical value that we don't like as much, we should revise
  1259. * authchallenge_type_is_better().
  1260. */
  1261. /** The length of the part of the AUTHENTICATE cell body that the client and
  1262. * server can generate independently (when using RSA_SHA256_TLSSECRET). It
  1263. * contains everything except the client's timestamp, the client's randomly
  1264. * generated nonce, and the signature. */
  1265. #define V3_AUTH_FIXED_PART_LEN (8+(32*6))
  1266. /** The length of the part of the AUTHENTICATE cell body that the client
  1267. * signs. */
  1268. #define V3_AUTH_BODY_LEN (V3_AUTH_FIXED_PART_LEN + 8 + 16)
  1269. /** Structure to hold all the certificates we've received on an OR connection
  1270. */
  1271. typedef struct or_handshake_certs_t {
  1272. /** True iff we originated this connection. */
  1273. int started_here;
  1274. /** The cert for the 'auth' RSA key that's supposed to sign the AUTHENTICATE
  1275. * cell. Signed with the RSA identity key. */
  1276. tor_x509_cert_t *auth_cert;
  1277. /** The cert for the 'link' RSA key that was used to negotiate the TLS
  1278. * connection. Signed with the RSA identity key. */
  1279. tor_x509_cert_t *link_cert;
  1280. /** A self-signed identity certificate: the RSA identity key signed
  1281. * with itself. */
  1282. tor_x509_cert_t *id_cert;
  1283. /** The Ed25519 signing key, signed with the Ed25519 identity key. */
  1284. struct tor_cert_st *ed_id_sign;
  1285. /** A digest of the X509 link certificate for the TLS connection, signed
  1286. * with the Ed25519 siging key. */
  1287. struct tor_cert_st *ed_sign_link;
  1288. /** The Ed25519 authentication key (that's supposed to sign an AUTHENTICATE
  1289. * cell) , signed with the Ed25519 siging key. */
  1290. struct tor_cert_st *ed_sign_auth;
  1291. /** The Ed25519 identity key, crosssigned with the RSA identity key. */
  1292. uint8_t *ed_rsa_crosscert;
  1293. /** The length of <b>ed_rsa_crosscert</b> in bytes */
  1294. size_t ed_rsa_crosscert_len;
  1295. } or_handshake_certs_t;
  1296. /** Stores flags and information related to the portion of a v2/v3 Tor OR
  1297. * connection handshake that happens after the TLS handshake is finished.
  1298. */
  1299. typedef struct or_handshake_state_t {
  1300. /** When was the VERSIONS cell sent on this connection? Used to get
  1301. * an estimate of the skew in the returning NETINFO reply. */
  1302. time_t sent_versions_at;
  1303. /** True iff we originated this connection */
  1304. unsigned int started_here : 1;
  1305. /** True iff we have received and processed a VERSIONS cell. */
  1306. unsigned int received_versions : 1;
  1307. /** True iff we have received and processed an AUTH_CHALLENGE cell */
  1308. unsigned int received_auth_challenge : 1;
  1309. /** True iff we have received and processed a CERTS cell. */
  1310. unsigned int received_certs_cell : 1;
  1311. /** True iff we have received and processed an AUTHENTICATE cell */
  1312. unsigned int received_authenticate : 1;
  1313. /* True iff we've received valid authentication to some identity. */
  1314. unsigned int authenticated : 1;
  1315. unsigned int authenticated_rsa : 1;
  1316. unsigned int authenticated_ed25519 : 1;
  1317. /* True iff we have sent a netinfo cell */
  1318. unsigned int sent_netinfo : 1;
  1319. /** The signing->ed25519 link certificate corresponding to the x509
  1320. * certificate we used on the TLS connection (if this is a server-side
  1321. * connection). We make a copy of this here to prevent a race condition
  1322. * caused by TLS context rotation. */
  1323. struct tor_cert_st *own_link_cert;
  1324. /** True iff we should feed outgoing cells into digest_sent and
  1325. * digest_received respectively.
  1326. *
  1327. * From the server's side of the v3 handshake, we want to capture everything
  1328. * from the VERSIONS cell through and including the AUTH_CHALLENGE cell.
  1329. * From the client's, we want to capture everything from the VERSIONS cell
  1330. * through but *not* including the AUTHENTICATE cell.
  1331. *
  1332. * @{ */
  1333. unsigned int digest_sent_data : 1;
  1334. unsigned int digest_received_data : 1;
  1335. /**@}*/
  1336. /** Identity RSA digest that we have received and authenticated for our peer
  1337. * on this connection. */
  1338. uint8_t authenticated_rsa_peer_id[DIGEST_LEN];
  1339. /** Identity Ed25519 public key that we have received and authenticated for
  1340. * our peer on this connection. */
  1341. ed25519_public_key_t authenticated_ed25519_peer_id;
  1342. /** Digests of the cells that we have sent or received as part of a V3
  1343. * handshake. Used for making and checking AUTHENTICATE cells.
  1344. *
  1345. * @{
  1346. */
  1347. crypto_digest_t *digest_sent;
  1348. crypto_digest_t *digest_received;
  1349. /** @} */
  1350. /** Certificates that a connection initiator sent us in a CERTS cell; we're
  1351. * holding on to them until we get an AUTHENTICATE cell.
  1352. */
  1353. or_handshake_certs_t *certs;
  1354. } or_handshake_state_t;
  1355. /** Length of Extended ORPort connection identifier. */
  1356. #define EXT_OR_CONN_ID_LEN DIGEST_LEN /* 20 */
  1357. /*
  1358. * OR_CONN_HIGHWATER and OR_CONN_LOWWATER moved from connection_or.c so
  1359. * channeltls.c can see them too.
  1360. */
  1361. /** When adding cells to an OR connection's outbuf, keep adding until the
  1362. * outbuf is at least this long, or we run out of cells. */
  1363. #define OR_CONN_HIGHWATER (32*1024)
  1364. /** Add cells to an OR connection's outbuf whenever the outbuf's data length
  1365. * drops below this size. */
  1366. #define OR_CONN_LOWWATER (16*1024)
  1367. /** Subtype of connection_t for an "OR connection" -- that is, one that speaks
  1368. * cells over TLS. */
  1369. typedef struct or_connection_t {
  1370. connection_t base_;
  1371. /** Hash of the public RSA key for the other side's identity key, or zeroes
  1372. * if the other side hasn't shown us a valid identity key. */
  1373. char identity_digest[DIGEST_LEN];
  1374. /** Extended ORPort connection identifier. */
  1375. char *ext_or_conn_id;
  1376. /** This is the ClientHash value we expect to receive from the
  1377. * client during the Extended ORPort authentication protocol. We
  1378. * compute it upon receiving the ClientNoce from the client, and we
  1379. * compare it with the acual ClientHash value sent by the
  1380. * client. */
  1381. char *ext_or_auth_correct_client_hash;
  1382. /** String carrying the name of the pluggable transport
  1383. * (e.g. "obfs2") that is obfuscating this connection. If no
  1384. * pluggable transports are used, it's NULL. */
  1385. char *ext_or_transport;
  1386. char *nickname; /**< Nickname of OR on other side (if any). */
  1387. tor_tls_t *tls; /**< TLS connection state. */
  1388. int tls_error; /**< Last tor_tls error code. */
  1389. /** When we last used this conn for any client traffic. If not
  1390. * recent, we can rate limit it further. */
  1391. /* Channel using this connection */
  1392. channel_tls_t *chan;
  1393. tor_addr_t real_addr; /**< The actual address that this connection came from
  1394. * or went to. The <b>addr</b> field is prone to
  1395. * getting overridden by the address from the router
  1396. * descriptor matching <b>identity_digest</b>. */
  1397. /** Should this connection be used for extending circuits to the server
  1398. * matching the <b>identity_digest</b> field? Set to true if we're pretty
  1399. * sure we aren't getting MITMed, either because we're connected to an
  1400. * address listed in a server descriptor, or because an authenticated
  1401. * NETINFO cell listed the address we're connected to as recognized. */
  1402. unsigned int is_canonical:1;
  1403. /** True iff this is an outgoing connection. */
  1404. unsigned int is_outgoing:1;
  1405. unsigned int proxy_type:2; /**< One of PROXY_NONE...PROXY_SOCKS5 */
  1406. unsigned int wide_circ_ids:1;
  1407. /** True iff this connection has had its bootstrap failure logged with
  1408. * control_event_bootstrap_problem. */
  1409. unsigned int have_noted_bootstrap_problem:1;
  1410. uint16_t link_proto; /**< What protocol version are we using? 0 for
  1411. * "none negotiated yet." */
  1412. uint16_t idle_timeout; /**< How long can this connection sit with no
  1413. * circuits on it before we close it? Based on
  1414. * IDLE_CIRCUIT_TIMEOUT_{NON,}CANONICAL and
  1415. * on is_canonical, randomized. */
  1416. or_handshake_state_t *handshake_state; /**< If we are setting this connection
  1417. * up, state information to do so. */
  1418. time_t timestamp_lastempty; /**< When was the outbuf last completely empty?*/
  1419. /* bandwidth* and *_bucket only used by ORs in OPEN state: */
  1420. int bandwidthrate; /**< Bytes/s added to the bucket. (OPEN ORs only.) */
  1421. int bandwidthburst; /**< Max bucket size for this conn. (OPEN ORs only.) */
  1422. int read_bucket; /**< When this hits 0, stop receiving. Every second we
  1423. * add 'bandwidthrate' to this, capping it at
  1424. * bandwidthburst. (OPEN ORs only) */
  1425. int write_bucket; /**< When this hits 0, stop writing. Like read_bucket. */
  1426. /** Last emptied read token bucket in msec since midnight; only used if
  1427. * TB_EMPTY events are enabled. */
  1428. uint32_t read_emptied_time;
  1429. /** Last emptied write token bucket in msec since midnight; only used if
  1430. * TB_EMPTY events are enabled. */
  1431. uint32_t write_emptied_time;
  1432. /*
  1433. * Count the number of bytes flushed out on this orconn, and the number of
  1434. * bytes TLS actually sent - used for overhead estimation for scheduling.
  1435. */
  1436. uint64_t bytes_xmitted, bytes_xmitted_by_tls;
  1437. } or_connection_t;
  1438. /** Subtype of connection_t for an "edge connection" -- that is, an entry (ap)
  1439. * connection, or an exit. */
  1440. typedef struct edge_connection_t {
  1441. connection_t base_;
  1442. struct edge_connection_t *next_stream; /**< Points to the next stream at this
  1443. * edge, if any */
  1444. int package_window; /**< How many more relay cells can I send into the
  1445. * circuit? */
  1446. int deliver_window; /**< How many more relay cells can end at me? */
  1447. struct circuit_t *on_circuit; /**< The circuit (if any) that this edge
  1448. * connection is using. */
  1449. /** A pointer to which node in the circ this conn exits at. Set for AP
  1450. * connections and for hidden service exit connections. */
  1451. struct crypt_path_t *cpath_layer;
  1452. /** What rendezvous service are we querying for (if an AP) or providing (if
  1453. * an exit)? */
  1454. rend_data_t *rend_data;
  1455. /* Hidden service connection identifier for edge connections. Used by the HS
  1456. * client-side code to identify client SOCKS connections and by the
  1457. * service-side code to match HS circuits with their streams. */
  1458. struct hs_ident_edge_conn_t *hs_ident;
  1459. uint32_t address_ttl; /**< TTL for address-to-addr mapping on exit
  1460. * connection. Exit connections only. */
  1461. uint32_t begincell_flags; /** Flags sent or received in the BEGIN cell
  1462. * for this connection */
  1463. streamid_t stream_id; /**< The stream ID used for this edge connection on its
  1464. * circuit */
  1465. /** The reason why this connection is closing; passed to the controller. */
  1466. uint16_t end_reason;
  1467. /** Bytes read since last call to control_event_stream_bandwidth_used() */
  1468. uint32_t n_read;
  1469. /** Bytes written since last call to control_event_stream_bandwidth_used() */
  1470. uint32_t n_written;
  1471. /** True iff this connection is for a DNS request only. */
  1472. unsigned int is_dns_request:1;
  1473. /** True iff this connection is for a PTR DNS request. (exit only) */
  1474. unsigned int is_reverse_dns_lookup:1;
  1475. unsigned int edge_has_sent_end:1; /**< For debugging; only used on edge
  1476. * connections. Set once we've set the stream end,
  1477. * and check in connection_about_to_close_connection().
  1478. */
  1479. /** True iff we've blocked reading until the circuit has fewer queued
  1480. * cells. */
  1481. unsigned int edge_blocked_on_circ:1;
  1482. /** Unique ID for directory requests; this used to be in connection_t, but
  1483. * that's going away and being used on channels instead. We still tag
  1484. * edge connections with dirreq_id from circuits, so it's copied here. */
  1485. uint64_t dirreq_id;
  1486. } edge_connection_t;
  1487. /** Subtype of edge_connection_t for an "entry connection" -- that is, a SOCKS
  1488. * connection, a DNS request, a TransPort connection or a NATD connection */
  1489. typedef struct entry_connection_t {
  1490. edge_connection_t edge_;
  1491. /** Nickname of planned exit node -- used with .exit support. */
  1492. /* XXX prop220: we need to make chosen_exit_name able to encode Ed IDs too.
  1493. * That's logically part of the UI parts for prop220 though. */
  1494. char *chosen_exit_name;
  1495. socks_request_t *socks_request; /**< SOCKS structure describing request (AP
  1496. * only.) */
  1497. /* === Isolation related, AP only. === */
  1498. entry_port_cfg_t entry_cfg;
  1499. /** AP only: The newnym epoch in which we created this connection. */
  1500. unsigned nym_epoch;
  1501. /** AP only: The original requested address before we rewrote it. */
  1502. char *original_dest_address;
  1503. /* Other fields to isolate on already exist. The ClientAddr is addr. The
  1504. ClientProtocol is a combination of type and socks_request->
  1505. socks_version. SocksAuth is socks_request->username/password.
  1506. DestAddr is in socks_request->address. */
  1507. /** Number of times we've reassigned this application connection to
  1508. * a new circuit. We keep track because the timeout is longer if we've
  1509. * already retried several times. */
  1510. uint8_t num_socks_retries;
  1511. /** For AP connections only: buffer for data that we have sent
  1512. * optimistically, which we might need to re-send if we have to
  1513. * retry this connection. */
  1514. buf_t *pending_optimistic_data;
  1515. /* For AP connections only: buffer for data that we previously sent
  1516. * optimistically which we are currently re-sending as we retry this
  1517. * connection. */
  1518. buf_t *sending_optimistic_data;
  1519. /** If this is a DNSPort connection, this field holds the pending DNS
  1520. * request that we're going to try to answer. */
  1521. struct evdns_server_request *dns_server_request;
  1522. #define DEBUGGING_17659
  1523. #ifdef DEBUGGING_17659
  1524. uint16_t marked_pending_circ_line;
  1525. const char *marked_pending_circ_file;
  1526. #endif
  1527. #define NUM_CIRCUITS_LAUNCHED_THRESHOLD 10
  1528. /** Number of times we've launched a circuit to handle this stream. If
  1529. * it gets too high, that could indicate an inconsistency between our
  1530. * "launch a circuit to handle this stream" logic and our "attach our
  1531. * stream to one of the available circuits" logic. */
  1532. unsigned int num_circuits_launched:4;
  1533. /** True iff this stream must attach to a one-hop circuit (e.g. for
  1534. * begin_dir). */
  1535. unsigned int want_onehop:1;
  1536. /** True iff this stream should use a BEGIN_DIR relay command to establish
  1537. * itself rather than BEGIN (either via onehop or via a whole circuit). */
  1538. unsigned int use_begindir:1;
  1539. /** For AP connections only. If 1, and we fail to reach the chosen exit,
  1540. * stop requiring it. */
  1541. unsigned int chosen_exit_optional:1;
  1542. /** For AP connections only. If non-zero, this exit node was picked as
  1543. * a result of the TrackHostExit, and the value decrements every time
  1544. * we fail to complete a circuit to our chosen exit -- if it reaches
  1545. * zero, abandon the associated mapaddress. */
  1546. unsigned int chosen_exit_retries:3;
  1547. /** True iff this is an AP connection that came from a transparent or
  1548. * NATd connection */
  1549. unsigned int is_transparent_ap:1;
  1550. /** For AP connections only: Set if this connection's target exit node
  1551. * allows optimistic data (that is, data sent on this stream before
  1552. * the exit has sent a CONNECTED cell) and we have chosen to use it.
  1553. */
  1554. unsigned int may_use_optimistic_data : 1;
  1555. /** Are we a socks SocksSocket listener? */
  1556. unsigned int is_socks_socket:1;
  1557. } entry_connection_t;
  1558. /** Subtype of connection_t for an "directory connection" -- that is, an HTTP
  1559. * connection to retrieve or serve directory material. */
  1560. typedef struct dir_connection_t {
  1561. connection_t base_;
  1562. /** Which 'resource' did we ask the directory for? This is typically the part
  1563. * of the URL string that defines, relative to the directory conn purpose,
  1564. * what thing we want. For example, in router descriptor downloads by
  1565. * descriptor digest, it contains "d/", then one or more +-separated
  1566. * fingerprints.
  1567. **/
  1568. char *requested_resource;
  1569. unsigned int dirconn_direct:1; /**< Is this dirconn direct, or via Tor? */
  1570. /** If we're fetching descriptors, what router purpose shall we assign
  1571. * to them? */
  1572. uint8_t router_purpose;
  1573. /** List of spooled_resource_t for objects that we're spooling. We use
  1574. * it from back to front. */
  1575. smartlist_t *spool;
  1576. /** The compression object doing on-the-fly compression for spooled data. */
  1577. tor_compress_state_t *compress_state;
  1578. /** What rendezvous service are we querying for? */
  1579. rend_data_t *rend_data;
  1580. /* Hidden service connection identifier for dir connections: Used by HS
  1581. client-side code to fetch HS descriptors, and by the service-side code to
  1582. upload descriptors. */
  1583. struct hs_ident_dir_conn_t *hs_ident;
  1584. /** If this is a one-hop connection, tracks the state of the directory guard
  1585. * for this connection (if any). */
  1586. struct circuit_guard_state_t *guard_state;
  1587. char identity_digest[DIGEST_LEN]; /**< Hash of the public RSA key for
  1588. * the directory server's signing key. */
  1589. /** Unique ID for directory requests; this used to be in connection_t, but
  1590. * that's going away and being used on channels instead. The dirserver still
  1591. * needs this for the incoming side, so it's moved here. */
  1592. uint64_t dirreq_id;
  1593. #ifdef MEASUREMENTS_21206
  1594. /** Number of RELAY_DATA cells received. */
  1595. uint32_t data_cells_received;
  1596. /** Number of RELAY_DATA cells sent. */
  1597. uint32_t data_cells_sent;
  1598. #endif
  1599. } dir_connection_t;
  1600. /** Subtype of connection_t for an connection to a controller. */
  1601. typedef struct control_connection_t {
  1602. connection_t base_;
  1603. uint64_t event_mask; /**< Bitfield: which events does this controller
  1604. * care about?
  1605. * EVENT_MAX_ is >31, so we need a 64 bit mask */
  1606. /** True if we have sent a protocolinfo reply on this connection. */
  1607. unsigned int have_sent_protocolinfo:1;
  1608. /** True if we have received a takeownership command on this
  1609. * connection. */
  1610. unsigned int is_owning_control_connection:1;
  1611. /** List of ephemeral onion services belonging to this connection. */
  1612. smartlist_t *ephemeral_onion_services;
  1613. /** If we have sent an AUTHCHALLENGE reply on this connection and
  1614. * have not received a successful AUTHENTICATE command, points to
  1615. * the value which the client must send to authenticate itself;
  1616. * otherwise, NULL. */
  1617. char *safecookie_client_hash;
  1618. /** Amount of space allocated in incoming_cmd. */
  1619. uint32_t incoming_cmd_len;
  1620. /** Number of bytes currently stored in incoming_cmd. */
  1621. uint32_t incoming_cmd_cur_len;
  1622. /** A control command that we're reading from the inbuf, but which has not
  1623. * yet arrived completely. */
  1624. char *incoming_cmd;
  1625. } control_connection_t;
  1626. /** Cast a connection_t subtype pointer to a connection_t **/
  1627. #define TO_CONN(c) (&(((c)->base_)))
  1628. /** Cast a entry_connection_t subtype pointer to a edge_connection_t **/
  1629. #define ENTRY_TO_EDGE_CONN(c) (&(((c))->edge_))
  1630. /** Cast a entry_connection_t subtype pointer to a connection_t **/
  1631. #define ENTRY_TO_CONN(c) (TO_CONN(ENTRY_TO_EDGE_CONN(c)))
  1632. /** Convert a connection_t* to an or_connection_t*; assert if the cast is
  1633. * invalid. */
  1634. static or_connection_t *TO_OR_CONN(connection_t *);
  1635. /** Convert a connection_t* to a dir_connection_t*; assert if the cast is
  1636. * invalid. */
  1637. static dir_connection_t *TO_DIR_CONN(connection_t *);
  1638. /** Convert a connection_t* to an edge_connection_t*; assert if the cast is
  1639. * invalid. */
  1640. static edge_connection_t *TO_EDGE_CONN(connection_t *);
  1641. /** Convert a connection_t* to an entry_connection_t*; assert if the cast is
  1642. * invalid. */
  1643. static entry_connection_t *TO_ENTRY_CONN(connection_t *);
  1644. /** Convert a edge_connection_t* to an entry_connection_t*; assert if the cast
  1645. * is invalid. */
  1646. static entry_connection_t *EDGE_TO_ENTRY_CONN(edge_connection_t *);
  1647. /** Convert a connection_t* to an control_connection_t*; assert if the cast is
  1648. * invalid. */
  1649. static control_connection_t *TO_CONTROL_CONN(connection_t *);
  1650. /** Convert a connection_t* to an listener_connection_t*; assert if the cast is
  1651. * invalid. */
  1652. static listener_connection_t *TO_LISTENER_CONN(connection_t *);
  1653. static inline or_connection_t *TO_OR_CONN(connection_t *c)
  1654. {
  1655. tor_assert(c->magic == OR_CONNECTION_MAGIC);
  1656. return DOWNCAST(or_connection_t, c);
  1657. }
  1658. static inline dir_connection_t *TO_DIR_CONN(connection_t *c)
  1659. {
  1660. tor_assert(c->magic == DIR_CONNECTION_MAGIC);
  1661. return DOWNCAST(dir_connection_t, c);
  1662. }
  1663. static inline edge_connection_t *TO_EDGE_CONN(connection_t *c)
  1664. {
  1665. tor_assert(c->magic == EDGE_CONNECTION_MAGIC ||
  1666. c->magic == ENTRY_CONNECTION_MAGIC);
  1667. return DOWNCAST(edge_connection_t, c);
  1668. }
  1669. static inline entry_connection_t *TO_ENTRY_CONN(connection_t *c)
  1670. {
  1671. tor_assert(c->magic == ENTRY_CONNECTION_MAGIC);
  1672. return (entry_connection_t*) SUBTYPE_P(c, entry_connection_t, edge_.base_);
  1673. }
  1674. static inline entry_connection_t *EDGE_TO_ENTRY_CONN(edge_connection_t *c)
  1675. {
  1676. tor_assert(c->base_.magic == ENTRY_CONNECTION_MAGIC);
  1677. return (entry_connection_t*) SUBTYPE_P(c, entry_connection_t, edge_);
  1678. }
  1679. static inline control_connection_t *TO_CONTROL_CONN(connection_t *c)
  1680. {
  1681. tor_assert(c->magic == CONTROL_CONNECTION_MAGIC);
  1682. return DOWNCAST(control_connection_t, c);
  1683. }
  1684. static inline listener_connection_t *TO_LISTENER_CONN(connection_t *c)
  1685. {
  1686. tor_assert(c->magic == LISTENER_CONNECTION_MAGIC);
  1687. return DOWNCAST(listener_connection_t, c);
  1688. }
  1689. /** What action type does an address policy indicate: accept or reject? */
  1690. typedef enum {
  1691. ADDR_POLICY_ACCEPT=1,
  1692. ADDR_POLICY_REJECT=2,
  1693. } addr_policy_action_t;
  1694. #define addr_policy_action_bitfield_t ENUM_BF(addr_policy_action_t)
  1695. /** A reference-counted address policy rule. */
  1696. typedef struct addr_policy_t {
  1697. int refcnt; /**< Reference count */
  1698. /** What to do when the policy matches.*/
  1699. addr_policy_action_bitfield_t policy_type:2;
  1700. unsigned int is_private:1; /**< True iff this is the pseudo-address,
  1701. * "private". */
  1702. unsigned int is_canonical:1; /**< True iff this policy is the canonical
  1703. * copy (stored in a hash table to avoid
  1704. * duplication of common policies) */
  1705. maskbits_t maskbits; /**< Accept/reject all addresses <b>a</b> such that the
  1706. * first <b>maskbits</b> bits of <b>a</b> match
  1707. * <b>addr</b>. */
  1708. /** Base address to accept or reject.
  1709. *
  1710. * Note that wildcards are treated
  1711. * differntly depending on address family. An AF_UNSPEC address means
  1712. * "All addresses, IPv4 or IPv6." An AF_INET address with maskbits==0 means
  1713. * "All IPv4 addresses" and an AF_INET6 address with maskbits == 0 means
  1714. * "All IPv6 addresses".
  1715. **/
  1716. tor_addr_t addr;
  1717. uint16_t prt_min; /**< Lowest port number to accept/reject. */
  1718. uint16_t prt_max; /**< Highest port number to accept/reject. */
  1719. } addr_policy_t;
  1720. /** A cached_dir_t represents a cacheable directory object, along with its
  1721. * compressed form. */
  1722. typedef struct cached_dir_t {
  1723. char *dir; /**< Contents of this object, NUL-terminated. */
  1724. char *dir_compressed; /**< Compressed contents of this object. */
  1725. size_t dir_len; /**< Length of <b>dir</b> (not counting its NUL). */
  1726. size_t dir_compressed_len; /**< Length of <b>dir_compressed</b>. */
  1727. time_t published; /**< When was this object published. */
  1728. common_digests_t digests; /**< Digests of this object (networkstatus only) */
  1729. /** Sha3 digest (also ns only) */
  1730. uint8_t digest_sha3_as_signed[DIGEST256_LEN];
  1731. int refcnt; /**< Reference count for this cached_dir_t. */
  1732. } cached_dir_t;
  1733. /** Enum used to remember where a signed_descriptor_t is stored and how to
  1734. * manage the memory for signed_descriptor_body. */
  1735. typedef enum {
  1736. /** The descriptor isn't stored on disk at all: the copy in memory is
  1737. * canonical; the saved_offset field is meaningless. */
  1738. SAVED_NOWHERE=0,
  1739. /** The descriptor is stored in the cached_routers file: the
  1740. * signed_descriptor_body is meaningless; the signed_descriptor_len and
  1741. * saved_offset are used to index into the mmaped cache file. */
  1742. SAVED_IN_CACHE,
  1743. /** The descriptor is stored in the cached_routers.new file: the
  1744. * signed_descriptor_body and saved_offset fields are both set. */
  1745. /* FFFF (We could also mmap the file and grow the mmap as needed, or
  1746. * lazy-load the descriptor text by using seek and read. We don't, for
  1747. * now.)
  1748. */
  1749. SAVED_IN_JOURNAL
  1750. } saved_location_t;
  1751. #define saved_location_bitfield_t ENUM_BF(saved_location_t)
  1752. /** Enumeration: what directory object is being downloaded?
  1753. * This determines which schedule is selected to perform the download. */
  1754. typedef enum {
  1755. DL_SCHED_GENERIC = 0,
  1756. DL_SCHED_CONSENSUS = 1,
  1757. DL_SCHED_BRIDGE = 2,
  1758. } download_schedule_t;
  1759. #define download_schedule_bitfield_t ENUM_BF(download_schedule_t)
  1760. /** Enumeration: is the download schedule for downloading from an authority,
  1761. * or from any available directory mirror?
  1762. * During bootstrap, "any" means a fallback (or an authority, if there
  1763. * are no fallbacks).
  1764. * When we have a valid consensus, "any" means any directory server. */
  1765. typedef enum {
  1766. DL_WANT_ANY_DIRSERVER = 0,
  1767. DL_WANT_AUTHORITY = 1,
  1768. } download_want_authority_t;
  1769. #define download_want_authority_bitfield_t \
  1770. ENUM_BF(download_want_authority_t)
  1771. /** Enumeration: do we want to increment the schedule position each time a
  1772. * connection is attempted (these attempts can be concurrent), or do we want
  1773. * to increment the schedule position after a connection fails? */
  1774. typedef enum {
  1775. DL_SCHED_INCREMENT_FAILURE = 0,
  1776. DL_SCHED_INCREMENT_ATTEMPT = 1,
  1777. } download_schedule_increment_t;
  1778. #define download_schedule_increment_bitfield_t \
  1779. ENUM_BF(download_schedule_increment_t)
  1780. /** Enumeration: do we want to use the random exponential backoff
  1781. * mechanism? */
  1782. typedef enum {
  1783. DL_SCHED_DETERMINISTIC = 0,
  1784. DL_SCHED_RANDOM_EXPONENTIAL = 1,
  1785. } download_schedule_backoff_t;
  1786. #define download_schedule_backoff_bitfield_t \
  1787. ENUM_BF(download_schedule_backoff_t)
  1788. /** Information about our plans for retrying downloads for a downloadable
  1789. * directory object.
  1790. * Each type of downloadable directory object has a corresponding retry
  1791. * <b>schedule</b>, which can be different depending on whether the object is
  1792. * being downloaded from an authority or a mirror (<b>want_authority</b>).
  1793. * <b>next_attempt_at</b> contains the next time we will attempt to download
  1794. * the object.
  1795. * For schedules that <b>increment_on</b> failure, <b>n_download_failures</b>
  1796. * is used to determine the position in the schedule. (Each schedule is a
  1797. * smartlist of integer delays, parsed from a CSV option.) Every time a
  1798. * connection attempt fails, <b>n_download_failures</b> is incremented,
  1799. * the new delay value is looked up from the schedule, and
  1800. * <b>next_attempt_at</b> is set delay seconds from the time the previous
  1801. * connection failed. Therefore, at most one failure-based connection can be
  1802. * in progress for each download_status_t.
  1803. * For schedules that <b>increment_on</b> attempt, <b>n_download_attempts</b>
  1804. * is used to determine the position in the schedule. Every time a
  1805. * connection attempt is made, <b>n_download_attempts</b> is incremented,
  1806. * the new delay value is looked up from the schedule, and
  1807. * <b>next_attempt_at</b> is set delay seconds from the time the previous
  1808. * connection was attempted. Therefore, multiple concurrent attempted-based
  1809. * connections can be in progress for each download_status_t.
  1810. * After an object is successfully downloaded, any other concurrent connections
  1811. * are terminated. A new schedule which starts at position 0 is used for
  1812. * subsequent downloads of the same object.
  1813. */
  1814. typedef struct download_status_t {
  1815. time_t next_attempt_at; /**< When should we try downloading this object
  1816. * again? */
  1817. uint8_t n_download_failures; /**< Number of failed downloads of the most
  1818. * recent object, since the last success. */
  1819. uint8_t n_download_attempts; /**< Number of (potentially concurrent) attempts
  1820. * to download the most recent object, since
  1821. * the last success. */
  1822. download_schedule_bitfield_t schedule : 8; /**< What kind of object is being
  1823. * downloaded? This determines the
  1824. * schedule used for the download.
  1825. */
  1826. download_want_authority_bitfield_t want_authority : 1; /**< Is the download
  1827. * happening from an authority
  1828. * or a mirror? This determines
  1829. * the schedule used for the
  1830. * download. */
  1831. download_schedule_increment_bitfield_t increment_on : 1; /**< does this
  1832. * schedule increment on each attempt,
  1833. * or after each failure? */
  1834. download_schedule_backoff_bitfield_t backoff : 1; /**< do we use the
  1835. * deterministic schedule, or random
  1836. * exponential backoffs?
  1837. * Increment on failure schedules
  1838. * always use exponential backoff. */
  1839. uint8_t last_backoff_position; /**< number of attempts/failures, depending
  1840. * on increment_on, when we last recalculated
  1841. * the delay. Only updated if backoff
  1842. * == 1. */
  1843. int last_delay_used; /**< last delay used for random exponential backoff;
  1844. * only updated if backoff == 1 */
  1845. } download_status_t;
  1846. /** If n_download_failures is this high, the download can never happen. */
  1847. #define IMPOSSIBLE_TO_DOWNLOAD 255
  1848. /** The max size we expect router descriptor annotations we create to
  1849. * be. We'll accept larger ones if we see them on disk, but we won't
  1850. * create any that are larger than this. */
  1851. #define ROUTER_ANNOTATION_BUF_LEN 256
  1852. /** Information need to cache an onion router's descriptor. */
  1853. typedef struct signed_descriptor_t {
  1854. /** Pointer to the raw server descriptor, preceded by annotations. Not
  1855. * necessarily NUL-terminated. If saved_location is SAVED_IN_CACHE, this
  1856. * pointer is null. */
  1857. char *signed_descriptor_body;
  1858. /** Length of the annotations preceding the server descriptor. */
  1859. size_t annotations_len;
  1860. /** Length of the server descriptor. */
  1861. size_t signed_descriptor_len;
  1862. /** Digest of the server descriptor, computed as specified in
  1863. * dir-spec.txt. */
  1864. char signed_descriptor_digest[DIGEST_LEN];
  1865. /** Identity digest of the router. */
  1866. char identity_digest[DIGEST_LEN];
  1867. /** Declared publication time of the descriptor. */
  1868. time_t published_on;
  1869. /** For routerdescs only: digest of the corresponding extrainfo. */
  1870. char extra_info_digest[DIGEST_LEN];
  1871. /** For routerdescs only: A SHA256-digest of the extrainfo (if any) */
  1872. char extra_info_digest256[DIGEST256_LEN];
  1873. /** Certificate for ed25519 signing key. */
  1874. struct tor_cert_st *signing_key_cert;
  1875. /** For routerdescs only: Status of downloading the corresponding
  1876. * extrainfo. */
  1877. download_status_t ei_dl_status;
  1878. /** Where is the descriptor saved? */
  1879. saved_location_t saved_location;
  1880. /** If saved_location is SAVED_IN_CACHE or SAVED_IN_JOURNAL, the offset of
  1881. * this descriptor in the corresponding file. */
  1882. off_t saved_offset;
  1883. /** What position is this descriptor within routerlist->routers or
  1884. * routerlist->old_routers? -1 for none. */
  1885. int routerlist_index;
  1886. /** The valid-until time of the most recent consensus that listed this
  1887. * descriptor. 0 for "never listed in a consensus, so far as we know." */
  1888. time_t last_listed_as_valid_until;
  1889. /* If true, we do not ever try to save this object in the cache. */
  1890. unsigned int do_not_cache : 1;
  1891. /* If true, this item is meant to represent an extrainfo. */
  1892. unsigned int is_extrainfo : 1;
  1893. /* If true, we got an extrainfo for this item, and the digest was right,
  1894. * but it was incompatible. */
  1895. unsigned int extrainfo_is_bogus : 1;
  1896. /* If true, we are willing to transmit this item unencrypted. */
  1897. unsigned int send_unencrypted : 1;
  1898. } signed_descriptor_t;
  1899. /** A signed integer representing a country code. */
  1900. typedef int16_t country_t;
  1901. /** Information about another onion router in the network. */
  1902. typedef struct {
  1903. signed_descriptor_t cache_info;
  1904. char *nickname; /**< Human-readable OR name. */
  1905. uint32_t addr; /**< IPv4 address of OR, in host order. */
  1906. uint16_t or_port; /**< Port for TLS connections. */
  1907. uint16_t dir_port; /**< Port for HTTP directory connections. */
  1908. /** A router's IPv6 address, if it has one. */
  1909. /* XXXXX187 Actually these should probably be part of a list of addresses,
  1910. * not just a special case. Use abstractions to access these; don't do it
  1911. * directly. */
  1912. tor_addr_t ipv6_addr;
  1913. uint16_t ipv6_orport;
  1914. crypto_pk_t *onion_pkey; /**< Public RSA key for onions. */
  1915. crypto_pk_t *identity_pkey; /**< Public RSA key for signing. */
  1916. /** Public curve25519 key for onions */
  1917. curve25519_public_key_t *onion_curve25519_pkey;
  1918. /** What's the earliest expiration time on all the certs in this
  1919. * routerinfo? */
  1920. time_t cert_expiration_time;
  1921. char *platform; /**< What software/operating system is this OR using? */
  1922. char *protocol_list; /**< Encoded list of subprotocol versions supported
  1923. * by this OR */
  1924. /* link info */
  1925. uint32_t bandwidthrate; /**< How many bytes does this OR add to its token
  1926. * bucket per second? */
  1927. uint32_t bandwidthburst; /**< How large is this OR's token bucket? */
  1928. /** How many bytes/s is this router known to handle? */
  1929. uint32_t bandwidthcapacity;
  1930. smartlist_t *exit_policy; /**< What streams will this OR permit
  1931. * to exit on IPv4? NULL for 'reject *:*'. */
  1932. /** What streams will this OR permit to exit on IPv6?
  1933. * NULL for 'reject *:*' */
  1934. struct short_policy_t *ipv6_exit_policy;
  1935. long uptime; /**< How many seconds the router claims to have been up */
  1936. smartlist_t *declared_family; /**< Nicknames of router which this router
  1937. * claims are its family. */
  1938. char *contact_info; /**< Declared contact info for this router. */
  1939. unsigned int is_hibernating:1; /**< Whether the router claims to be
  1940. * hibernating */
  1941. unsigned int caches_extra_info:1; /**< Whether the router says it caches and
  1942. * serves extrainfo documents. */
  1943. unsigned int allow_single_hop_exits:1; /**< Whether the router says
  1944. * it allows single hop exits. */
  1945. unsigned int wants_to_be_hs_dir:1; /**< True iff this router claims to be
  1946. * a hidden service directory. */
  1947. unsigned int policy_is_reject_star:1; /**< True iff the exit policy for this
  1948. * router rejects everything. */
  1949. /** True if, after we have added this router, we should re-launch
  1950. * tests for it. */
  1951. unsigned int needs_retest_if_added:1;
  1952. /** True iff this router included "tunnelled-dir-server" in its descriptor,
  1953. * implying it accepts tunnelled directory requests, or it advertised
  1954. * dir_port > 0. */
  1955. unsigned int supports_tunnelled_dir_requests:1;
  1956. /** Used during voting to indicate that we should not include an entry for
  1957. * this routerinfo. Used only during voting. */
  1958. unsigned int omit_from_vote:1;
  1959. /** Tor can use this router for general positions in circuits; we got it
  1960. * from a directory server as usual, or we're an authority and a server
  1961. * uploaded it. */
  1962. #define ROUTER_PURPOSE_GENERAL 0
  1963. /** Tor should avoid using this router for circuit-building: we got it
  1964. * from a crontroller. If the controller wants to use it, it'll have to
  1965. * ask for it by identity. */
  1966. #define ROUTER_PURPOSE_CONTROLLER 1
  1967. /** Tor should use this router only for bridge positions in circuits: we got
  1968. * it via a directory request from the bridge itself, or a bridge
  1969. * authority. x*/
  1970. #define ROUTER_PURPOSE_BRIDGE 2
  1971. /** Tor should not use this router; it was marked in cached-descriptors with
  1972. * a purpose we didn't recognize. */
  1973. #define ROUTER_PURPOSE_UNKNOWN 255
  1974. /* In what way did we find out about this router? One of ROUTER_PURPOSE_*.
  1975. * Routers of different purposes are kept segregated and used for different
  1976. * things; see notes on ROUTER_PURPOSE_* macros above.
  1977. */
  1978. uint8_t purpose;
  1979. } routerinfo_t;
  1980. /** Information needed to keep and cache a signed extra-info document. */
  1981. typedef struct extrainfo_t {
  1982. signed_descriptor_t cache_info;
  1983. /** SHA256 digest of this document */
  1984. uint8_t digest256[DIGEST256_LEN];
  1985. /** The router's nickname. */
  1986. char nickname[MAX_NICKNAME_LEN+1];
  1987. /** True iff we found the right key for this extra-info, verified the
  1988. * signature, and found it to be bad. */
  1989. unsigned int bad_sig : 1;
  1990. /** If present, we didn't have the right key to verify this extra-info,
  1991. * so this is a copy of the signature in the document. */
  1992. char *pending_sig;
  1993. /** Length of pending_sig. */
  1994. size_t pending_sig_len;
  1995. } extrainfo_t;
  1996. /** Contents of a single router entry in a network status object.
  1997. */
  1998. typedef struct routerstatus_t {
  1999. time_t published_on; /**< When was this router published? */
  2000. char nickname[MAX_NICKNAME_LEN+1]; /**< The nickname this router says it
  2001. * has. */
  2002. char identity_digest[DIGEST_LEN]; /**< Digest of the router's identity
  2003. * key. */
  2004. /** Digest of the router's most recent descriptor or microdescriptor.
  2005. * If it's a descriptor, we only use the first DIGEST_LEN bytes. */
  2006. char descriptor_digest[DIGEST256_LEN];
  2007. uint32_t addr; /**< IPv4 address for this router, in host order. */
  2008. uint16_t or_port; /**< OR port for this router. */
  2009. uint16_t dir_port; /**< Directory port for this router. */
  2010. tor_addr_t ipv6_addr; /**< IPv6 address for this router. */
  2011. uint16_t ipv6_orport; /**<IPV6 OR port for this router. */
  2012. unsigned int is_authority:1; /**< True iff this router is an authority. */
  2013. unsigned int is_exit:1; /**< True iff this router is a good exit. */
  2014. unsigned int is_stable:1; /**< True iff this router stays up a long time. */
  2015. unsigned int is_fast:1; /**< True iff this router has good bandwidth. */
  2016. /** True iff this router is called 'running' in the consensus. We give it
  2017. * this funny name so that we don't accidentally use this bit as a view of
  2018. * whether we think the router is *currently* running. If that's what you
  2019. * want to know, look at is_running in node_t. */
  2020. unsigned int is_flagged_running:1;
  2021. unsigned int is_named:1; /**< True iff "nickname" belongs to this router. */
  2022. unsigned int is_unnamed:1; /**< True iff "nickname" belongs to another
  2023. * router. */
  2024. unsigned int is_valid:1; /**< True iff this router isn't invalid. */
  2025. unsigned int is_possible_guard:1; /**< True iff this router would be a good
  2026. * choice as an entry guard. */
  2027. unsigned int is_bad_exit:1; /**< True iff this node is a bad choice for
  2028. * an exit node. */
  2029. unsigned int is_hs_dir:1; /**< True iff this router is a v2-or-later hidden
  2030. * service directory. */
  2031. unsigned int is_v2_dir:1; /** True iff this router publishes an open DirPort
  2032. * or it claims to accept tunnelled dir requests.
  2033. */
  2034. /** True iff we have a proto line for this router, or a versions line
  2035. * from which we could infer the protocols. */
  2036. unsigned int protocols_known:1;
  2037. /** True iff this router has a version or protocol list that allows it to
  2038. * accept EXTEND2 cells */
  2039. unsigned int supports_extend2_cells:1;
  2040. /** True iff this router has a protocol list that allows it to negotiate
  2041. * ed25519 identity keys on a link handshake. */
  2042. unsigned int supports_ed25519_link_handshake:1;
  2043. /** True iff this router has a protocol list that allows it to be an
  2044. * introduction point supporting ed25519 authentication key which is part of
  2045. * the v3 protocol detailed in proposal 224. This requires HSIntro=4. */
  2046. unsigned int supports_ed25519_hs_intro : 1;
  2047. /** True iff this router has a protocol list that allows it to be an hidden
  2048. * service directory supporting version 3 as seen in proposal 224. This
  2049. * requires HSDir=2. */
  2050. unsigned int supports_v3_hsdir : 1;
  2051. unsigned int has_bandwidth:1; /**< The vote/consensus had bw info */
  2052. unsigned int has_exitsummary:1; /**< The vote/consensus had exit summaries */
  2053. unsigned int bw_is_unmeasured:1; /**< This is a consensus entry, with
  2054. * the Unmeasured flag set. */
  2055. uint32_t bandwidth_kb; /**< Bandwidth (capacity) of the router as reported in
  2056. * the vote/consensus, in kilobytes/sec. */
  2057. /** The consensus has guardfraction information for this router. */
  2058. unsigned int has_guardfraction:1;
  2059. /** The guardfraction value of this router. */
  2060. uint32_t guardfraction_percentage;
  2061. char *exitsummary; /**< exit policy summary -
  2062. * XXX weasel: this probably should not stay a string. */
  2063. /* ---- The fields below aren't derived from the networkstatus; they
  2064. * hold local information only. */
  2065. time_t last_dir_503_at; /**< When did this router last tell us that it
  2066. * was too busy to serve directory info? */
  2067. download_status_t dl_status;
  2068. } routerstatus_t;
  2069. /** A single entry in a parsed policy summary, describing a range of ports. */
  2070. typedef struct short_policy_entry_t {
  2071. uint16_t min_port, max_port;
  2072. } short_policy_entry_t;
  2073. /** A short_poliy_t is the parsed version of a policy summary. */
  2074. typedef struct short_policy_t {
  2075. /** True if the members of 'entries' are port ranges to accept; false if
  2076. * they are port ranges to reject */
  2077. unsigned int is_accept : 1;
  2078. /** The actual number of values in 'entries'. */
  2079. unsigned int n_entries : 31;
  2080. /** An array of 0 or more short_policy_entry_t values, each describing a
  2081. * range of ports that this policy accepts or rejects (depending on the
  2082. * value of is_accept).
  2083. */
  2084. short_policy_entry_t entries[FLEXIBLE_ARRAY_MEMBER];
  2085. } short_policy_t;
  2086. /** A microdescriptor is the smallest amount of information needed to build a
  2087. * circuit through a router. They are generated by the directory authorities,
  2088. * using information from the uploaded routerinfo documents. They are not
  2089. * self-signed, but are rather authenticated by having their hash in a signed
  2090. * networkstatus document. */
  2091. typedef struct microdesc_t {
  2092. /** Hashtable node, used to look up the microdesc by its digest. */
  2093. HT_ENTRY(microdesc_t) node;
  2094. /* Cache information */
  2095. /** When was this microdescriptor last listed in a consensus document?
  2096. * Once a microdesc has been unlisted long enough, we can drop it.
  2097. */
  2098. time_t last_listed;
  2099. /** Where is this microdescriptor currently stored? */
  2100. saved_location_bitfield_t saved_location : 3;
  2101. /** If true, do not attempt to cache this microdescriptor on disk. */
  2102. unsigned int no_save : 1;
  2103. /** If true, this microdesc has an entry in the microdesc_map */
  2104. unsigned int held_in_map : 1;
  2105. /** Reference count: how many node_ts have a reference to this microdesc? */
  2106. unsigned int held_by_nodes;
  2107. /** If saved_location == SAVED_IN_CACHE, this field holds the offset of the
  2108. * microdescriptor in the cache. */
  2109. off_t off;
  2110. /* The string containing the microdesc. */
  2111. /** A pointer to the encoded body of the microdescriptor. If the
  2112. * saved_location is SAVED_IN_CACHE, then the body is a pointer into an
  2113. * mmap'd region. Otherwise, it is a malloc'd string. The string might not
  2114. * be NUL-terminated; take the length from <b>bodylen</b>. */
  2115. char *body;
  2116. /** The length of the microdescriptor in <b>body</b>. */
  2117. size_t bodylen;
  2118. /** A SHA256-digest of the microdescriptor. */
  2119. char digest[DIGEST256_LEN];
  2120. /* Fields in the microdescriptor. */
  2121. /** As routerinfo_t.onion_pkey */
  2122. crypto_pk_t *onion_pkey;
  2123. /** As routerinfo_t.onion_curve25519_pkey */
  2124. curve25519_public_key_t *onion_curve25519_pkey;
  2125. /** Ed25519 identity key, if included. */
  2126. ed25519_public_key_t *ed25519_identity_pkey;
  2127. /** As routerinfo_t.ipv6_addr */
  2128. tor_addr_t ipv6_addr;
  2129. /** As routerinfo_t.ipv6_orport */
  2130. uint16_t ipv6_orport;
  2131. /** As routerinfo_t.family */
  2132. smartlist_t *family;
  2133. /** IPv4 exit policy summary */
  2134. short_policy_t *exit_policy;
  2135. /** IPv6 exit policy summary */
  2136. short_policy_t *ipv6_exit_policy;
  2137. } microdesc_t;
  2138. /** A node_t represents a Tor router.
  2139. *
  2140. * Specifically, a node_t is a Tor router as we are using it: a router that
  2141. * we are considering for circuits, connections, and so on. A node_t is a
  2142. * thin wrapper around the routerstatus, routerinfo, and microdesc for a
  2143. * single router, and provides a consistent interface for all of them.
  2144. *
  2145. * Also, a node_t has mutable state. While a routerinfo, a routerstatus,
  2146. * and a microdesc have[*] only the information read from a router
  2147. * descriptor, a consensus entry, and a microdescriptor (respectively)...
  2148. * a node_t has flags based on *our own current opinion* of the node.
  2149. *
  2150. * [*] Actually, there is some leftover information in each that is mutable.
  2151. * We should try to excise that.
  2152. */
  2153. typedef struct node_t {
  2154. /* Indexing information */
  2155. /** Used to look up the node_t by its identity digest. */
  2156. HT_ENTRY(node_t) ht_ent;
  2157. /** Position of the node within the list of nodes */
  2158. int nodelist_idx;
  2159. /** The identity digest of this node_t. No more than one node_t per
  2160. * identity may exist at a time. */
  2161. char identity[DIGEST_LEN];
  2162. microdesc_t *md;
  2163. routerinfo_t *ri;
  2164. routerstatus_t *rs;
  2165. /* local info: copied from routerstatus, then possibly frobbed based
  2166. * on experience. Authorities set this stuff directly. Note that
  2167. * these reflect knowledge of the primary (IPv4) OR port only. */
  2168. unsigned int is_running:1; /**< As far as we know, is this OR currently
  2169. * running? */
  2170. unsigned int is_valid:1; /**< Has a trusted dirserver validated this OR?
  2171. * (For Authdir: Have we validated this OR?) */
  2172. unsigned int is_fast:1; /** Do we think this is a fast OR? */
  2173. unsigned int is_stable:1; /** Do we think this is a stable OR? */
  2174. unsigned int is_possible_guard:1; /**< Do we think this is an OK guard? */
  2175. unsigned int is_exit:1; /**< Do we think this is an OK exit? */
  2176. unsigned int is_bad_exit:1; /**< Do we think this exit is censored, borked,
  2177. * or otherwise nasty? */
  2178. unsigned int is_hs_dir:1; /**< True iff this router is a hidden service
  2179. * directory according to the authorities. */
  2180. /* Local info: warning state. */
  2181. unsigned int name_lookup_warned:1; /**< Have we warned the user for referring
  2182. * to this (unnamed) router by nickname?
  2183. */
  2184. /** Local info: we treat this node as if it rejects everything */
  2185. unsigned int rejects_all:1;
  2186. /* Local info: derived. */
  2187. /** True if the IPv6 OR port is preferred over the IPv4 OR port.
  2188. * XX/teor - can this become out of date if the torrc changes? */
  2189. unsigned int ipv6_preferred:1;
  2190. /** According to the geoip db what country is this router in? */
  2191. /* XXXprop186 what is this suppose to mean with multiple OR ports? */
  2192. country_t country;
  2193. /* The below items are used only by authdirservers for
  2194. * reachability testing. */
  2195. /** When was the last time we could reach this OR? */
  2196. time_t last_reachable; /* IPv4. */
  2197. time_t last_reachable6; /* IPv6. */
  2198. /* Hidden service directory index data. This is used by a service or client
  2199. * in order to know what's the hs directory index for this node at the time
  2200. * the consensus is set. */
  2201. struct hsdir_index_t *hsdir_index;
  2202. } node_t;
  2203. /** Linked list of microdesc hash lines for a single router in a directory
  2204. * vote.
  2205. */
  2206. typedef struct vote_microdesc_hash_t {
  2207. /** Next element in the list, or NULL. */
  2208. struct vote_microdesc_hash_t *next;
  2209. /** The raw contents of the microdesc hash line, from the "m" through the
  2210. * newline. */
  2211. char *microdesc_hash_line;
  2212. } vote_microdesc_hash_t;
  2213. /** The claim about a single router, made in a vote. */
  2214. typedef struct vote_routerstatus_t {
  2215. routerstatus_t status; /**< Underlying 'status' object for this router.
  2216. * Flags are redundant. */
  2217. /** How many known-flags are allowed in a vote? This is the width of
  2218. * the flags field of vote_routerstatus_t */
  2219. #define MAX_KNOWN_FLAGS_IN_VOTE 64
  2220. uint64_t flags; /**< Bit-field for all recognized flags; index into
  2221. * networkstatus_t.known_flags. */
  2222. char *version; /**< The version that the authority says this router is
  2223. * running. */
  2224. char *protocols; /**< The protocols that this authority says this router
  2225. * provides. */
  2226. unsigned int has_measured_bw:1; /**< The vote had a measured bw */
  2227. /** True iff the vote included an entry for ed25519 ID, or included
  2228. * "id ed25519 none" to indicate that there was no ed25519 ID. */
  2229. unsigned int has_ed25519_listing:1;
  2230. /** True if the Ed25519 listing here is the consensus-opinion for the
  2231. * Ed25519 listing; false if there was no consensus on Ed25519 key status,
  2232. * or if this VRS doesn't reflect it. */
  2233. unsigned int ed25519_reflects_consensus:1;
  2234. uint32_t measured_bw_kb; /**< Measured bandwidth (capacity) of the router */
  2235. /** The hash or hashes that the authority claims this microdesc has. */
  2236. vote_microdesc_hash_t *microdesc;
  2237. /** Ed25519 identity for this router, or zero if it has none. */
  2238. uint8_t ed25519_id[ED25519_PUBKEY_LEN];
  2239. } vote_routerstatus_t;
  2240. /** A signature of some document by an authority. */
  2241. typedef struct document_signature_t {
  2242. /** Declared SHA-1 digest of this voter's identity key */
  2243. char identity_digest[DIGEST_LEN];
  2244. /** Declared SHA-1 digest of signing key used by this voter. */
  2245. char signing_key_digest[DIGEST_LEN];
  2246. /** Algorithm used to compute the digest of the document. */
  2247. digest_algorithm_t alg;
  2248. /** Signature of the signed thing. */
  2249. char *signature;
  2250. /** Length of <b>signature</b> */
  2251. int signature_len;
  2252. unsigned int bad_signature : 1; /**< Set to true if we've tried to verify
  2253. * the sig, and we know it's bad. */
  2254. unsigned int good_signature : 1; /**< Set to true if we've verified the sig
  2255. * as good. */
  2256. } document_signature_t;
  2257. /** Information about a single voter in a vote or a consensus. */
  2258. typedef struct networkstatus_voter_info_t {
  2259. /** Declared SHA-1 digest of this voter's identity key */
  2260. char identity_digest[DIGEST_LEN];
  2261. char *nickname; /**< Nickname of this voter */
  2262. /** Digest of this voter's "legacy" identity key, if any. In vote only; for
  2263. * consensuses, we treat legacy keys as additional signers. */
  2264. char legacy_id_digest[DIGEST_LEN];
  2265. char *address; /**< Address of this voter, in string format. */
  2266. uint32_t addr; /**< Address of this voter, in IPv4, in host order. */
  2267. uint16_t dir_port; /**< Directory port of this voter */
  2268. uint16_t or_port; /**< OR port of this voter */
  2269. char *contact; /**< Contact information for this voter. */
  2270. char vote_digest[DIGEST_LEN]; /**< Digest of this voter's vote, as signed. */
  2271. /* Nothing from here on is signed. */
  2272. /** The signature of the document and the signature's status. */
  2273. smartlist_t *sigs;
  2274. } networkstatus_voter_info_t;
  2275. typedef struct networkstatus_sr_info_t {
  2276. /* Indicate if the dirauth partitipates in the SR protocol with its vote.
  2277. * This is tied to the SR flag in the vote. */
  2278. unsigned int participate:1;
  2279. /* Both vote and consensus: Current and previous SRV. If list is empty,
  2280. * this means none were found in either the consensus or vote. */
  2281. struct sr_srv_t *previous_srv;
  2282. struct sr_srv_t *current_srv;
  2283. /* Vote only: List of commitments. */
  2284. smartlist_t *commits;
  2285. } networkstatus_sr_info_t;
  2286. /** Enumerates the possible seriousness values of a networkstatus document. */
  2287. typedef enum {
  2288. NS_TYPE_VOTE,
  2289. NS_TYPE_CONSENSUS,
  2290. NS_TYPE_OPINION,
  2291. } networkstatus_type_t;
  2292. /** Enumerates recognized flavors of a consensus networkstatus document. All
  2293. * flavors of a consensus are generated from the same set of votes, but they
  2294. * present different types information to different versions of Tor. */
  2295. typedef enum {
  2296. FLAV_NS = 0,
  2297. FLAV_MICRODESC = 1,
  2298. } consensus_flavor_t;
  2299. /** How many different consensus flavors are there? */
  2300. #define N_CONSENSUS_FLAVORS ((int)(FLAV_MICRODESC)+1)
  2301. /** A common structure to hold a v3 network status vote, or a v3 network
  2302. * status consensus. */
  2303. typedef struct networkstatus_t {
  2304. networkstatus_type_t type; /**< Vote, consensus, or opinion? */
  2305. consensus_flavor_t flavor; /**< If a consensus, what kind? */
  2306. unsigned int has_measured_bws : 1;/**< True iff this networkstatus contains
  2307. * measured= bandwidth values. */
  2308. time_t published; /**< Vote only: Time when vote was written. */
  2309. time_t valid_after; /**< Time after which this vote or consensus applies. */
  2310. time_t fresh_until; /**< Time before which this is the most recent vote or
  2311. * consensus. */
  2312. time_t valid_until; /**< Time after which this vote or consensus should not
  2313. * be used. */
  2314. /** Consensus only: what method was used to produce this consensus? */
  2315. int consensus_method;
  2316. /** Vote only: what methods is this voter willing to use? */
  2317. smartlist_t *supported_methods;
  2318. /** List of 'package' lines describing hashes of downloadable packages */
  2319. smartlist_t *package_lines;
  2320. /** How long does this vote/consensus claim that authorities take to
  2321. * distribute their votes to one another? */
  2322. int vote_seconds;
  2323. /** How long does this vote/consensus claim that authorities take to
  2324. * distribute their consensus signatures to one another? */
  2325. int dist_seconds;
  2326. /** Comma-separated list of recommended client software, or NULL if this
  2327. * voter has no opinion. */
  2328. char *client_versions;
  2329. char *server_versions;
  2330. /** Lists of subprotocol versions which are _recommended_ for relays and
  2331. * clients, or which are _require_ for relays and clients. Tor shouldn't
  2332. * make any more network connections if a required protocol is missing.
  2333. */
  2334. char *recommended_relay_protocols;
  2335. char *recommended_client_protocols;
  2336. char *required_relay_protocols;
  2337. char *required_client_protocols;
  2338. /** List of flags that this vote/consensus applies to routers. If a flag is
  2339. * not listed here, the voter has no opinion on what its value should be. */
  2340. smartlist_t *known_flags;
  2341. /** List of key=value strings for the parameters in this vote or
  2342. * consensus, sorted by key. */
  2343. smartlist_t *net_params;
  2344. /** List of key=value strings for the bw weight parameters in the
  2345. * consensus. */
  2346. smartlist_t *weight_params;
  2347. /** List of networkstatus_voter_info_t. For a vote, only one element
  2348. * is included. For a consensus, one element is included for every voter
  2349. * whose vote contributed to the consensus. */
  2350. smartlist_t *voters;
  2351. struct authority_cert_t *cert; /**< Vote only: the voter's certificate. */
  2352. /** Digests of this document, as signed. */
  2353. common_digests_t digests;
  2354. /** A SHA3-256 digest of the document, not including signatures: used for
  2355. * consensus diffs */
  2356. uint8_t digest_sha3_as_signed[DIGEST256_LEN];
  2357. /** List of router statuses, sorted by identity digest. For a vote,
  2358. * the elements are vote_routerstatus_t; for a consensus, the elements
  2359. * are routerstatus_t. */
  2360. smartlist_t *routerstatus_list;
  2361. /** If present, a map from descriptor digest to elements of
  2362. * routerstatus_list. */
  2363. digestmap_t *desc_digest_map;
  2364. /** Contains the shared random protocol data from a vote or consensus. */
  2365. networkstatus_sr_info_t sr_info;
  2366. } networkstatus_t;
  2367. /** A set of signatures for a networkstatus consensus. Unless otherwise
  2368. * noted, all fields are as for networkstatus_t. */
  2369. typedef struct ns_detached_signatures_t {
  2370. time_t valid_after;
  2371. time_t fresh_until;
  2372. time_t valid_until;
  2373. strmap_t *digests; /**< Map from flavor name to digestset_t */
  2374. strmap_t *signatures; /**< Map from flavor name to list of
  2375. * document_signature_t */
  2376. } ns_detached_signatures_t;
  2377. /** Allowable types of desc_store_t. */
  2378. typedef enum store_type_t {
  2379. ROUTER_STORE = 0,
  2380. EXTRAINFO_STORE = 1
  2381. } store_type_t;
  2382. /** A 'store' is a set of descriptors saved on disk, with accompanying
  2383. * journal, mmaped as needed, rebuilt as needed. */
  2384. typedef struct desc_store_t {
  2385. /** Filename (within DataDir) for the store. We append .tmp to this
  2386. * filename for a temporary file when rebuilding the store, and .new to this
  2387. * filename for the journal. */
  2388. const char *fname_base;
  2389. /** Human-readable description of what this store contains. */
  2390. const char *description;
  2391. tor_mmap_t *mmap; /**< A mmap for the main file in the store. */
  2392. store_type_t type; /**< What's stored in this store? */
  2393. /** The size of the router log, in bytes. */
  2394. size_t journal_len;
  2395. /** The size of the router store, in bytes. */
  2396. size_t store_len;
  2397. /** Total bytes dropped since last rebuild: this is space currently
  2398. * used in the cache and the journal that could be freed by a rebuild. */
  2399. size_t bytes_dropped;
  2400. } desc_store_t;
  2401. /** Contents of a directory of onion routers. */
  2402. typedef struct {
  2403. /** Map from server identity digest to a member of routers. */
  2404. struct digest_ri_map_t *identity_map;
  2405. /** Map from server descriptor digest to a signed_descriptor_t from
  2406. * routers or old_routers. */
  2407. struct digest_sd_map_t *desc_digest_map;
  2408. /** Map from extra-info digest to an extrainfo_t. Only exists for
  2409. * routers in routers or old_routers. */
  2410. struct digest_ei_map_t *extra_info_map;
  2411. /** Map from extra-info digests to a signed_descriptor_t for a router
  2412. * descriptor having that extra-info digest. Only exists for
  2413. * routers in routers or old_routers. */
  2414. struct digest_sd_map_t *desc_by_eid_map;
  2415. /** List of routerinfo_t for all currently live routers we know. */
  2416. smartlist_t *routers;
  2417. /** List of signed_descriptor_t for older router descriptors we're
  2418. * caching. */
  2419. smartlist_t *old_routers;
  2420. /** Store holding server descriptors. If present, any router whose
  2421. * cache_info.saved_location == SAVED_IN_CACHE is stored in this file
  2422. * starting at cache_info.saved_offset */
  2423. desc_store_t desc_store;
  2424. /** Store holding extra-info documents. */
  2425. desc_store_t extrainfo_store;
  2426. } routerlist_t;
  2427. /** Information on router used when extending a circuit. We don't need a
  2428. * full routerinfo_t to extend: we only need addr:port:keyid to build an OR
  2429. * connection, and onion_key to create the onionskin. Note that for onehop
  2430. * general-purpose tunnels, the onion_key is NULL. */
  2431. typedef struct extend_info_t {
  2432. char nickname[MAX_HEX_NICKNAME_LEN+1]; /**< This router's nickname for
  2433. * display. */
  2434. /** Hash of this router's RSA identity key. */
  2435. char identity_digest[DIGEST_LEN];
  2436. /** Ed25519 identity for this router, if any. */
  2437. ed25519_public_key_t ed_identity;
  2438. uint16_t port; /**< OR port. */
  2439. tor_addr_t addr; /**< IP address. */
  2440. crypto_pk_t *onion_key; /**< Current onionskin key. */
  2441. curve25519_public_key_t curve25519_onion_key;
  2442. } extend_info_t;
  2443. /** Certificate for v3 directory protocol: binds long-term authority identity
  2444. * keys to medium-term authority signing keys. */
  2445. typedef struct authority_cert_t {
  2446. /** Information relating to caching this cert on disk and looking it up. */
  2447. signed_descriptor_t cache_info;
  2448. /** This authority's long-term authority identity key. */
  2449. crypto_pk_t *identity_key;
  2450. /** This authority's medium-term signing key. */
  2451. crypto_pk_t *signing_key;
  2452. /** The digest of <b>signing_key</b> */
  2453. char signing_key_digest[DIGEST_LEN];
  2454. /** The listed expiration time of this certificate. */
  2455. time_t expires;
  2456. /** This authority's IPv4 address, in host order. */
  2457. uint32_t addr;
  2458. /** This authority's directory port. */
  2459. uint16_t dir_port;
  2460. } authority_cert_t;
  2461. /** Bitfield enum type listing types of information that directory authorities
  2462. * can be authoritative about, and that directory caches may or may not cache.
  2463. *
  2464. * Note that the granularity here is based on authority granularity and on
  2465. * cache capabilities. Thus, one particular bit may correspond in practice to
  2466. * a few types of directory info, so long as every authority that pronounces
  2467. * officially about one of the types prounounces officially about all of them,
  2468. * and so long as every cache that caches one of them caches all of them.
  2469. */
  2470. typedef enum {
  2471. NO_DIRINFO = 0,
  2472. /** Serves/signs v3 directory information: votes, consensuses, certs */
  2473. V3_DIRINFO = 1 << 2,
  2474. /** Serves bridge descriptors. */
  2475. BRIDGE_DIRINFO = 1 << 4,
  2476. /** Serves extrainfo documents. */
  2477. EXTRAINFO_DIRINFO=1 << 5,
  2478. /** Serves microdescriptors. */
  2479. MICRODESC_DIRINFO=1 << 6,
  2480. } dirinfo_type_t;
  2481. #define ALL_DIRINFO ((dirinfo_type_t)((1<<7)-1))
  2482. #define CRYPT_PATH_MAGIC 0x70127012u
  2483. struct fast_handshake_state_t;
  2484. struct ntor_handshake_state_t;
  2485. #define ONION_HANDSHAKE_TYPE_TAP 0x0000
  2486. #define ONION_HANDSHAKE_TYPE_FAST 0x0001
  2487. #define ONION_HANDSHAKE_TYPE_NTOR 0x0002
  2488. #define MAX_ONION_HANDSHAKE_TYPE 0x0002
  2489. typedef struct {
  2490. uint16_t tag;
  2491. union {
  2492. struct fast_handshake_state_t *fast;
  2493. crypto_dh_t *tap;
  2494. struct ntor_handshake_state_t *ntor;
  2495. } u;
  2496. } onion_handshake_state_t;
  2497. /** Holds accounting information for a single step in the layered encryption
  2498. * performed by a circuit. Used only at the client edge of a circuit. */
  2499. typedef struct crypt_path_t {
  2500. uint32_t magic;
  2501. /* crypto environments */
  2502. /** Encryption key and counter for cells heading towards the OR at this
  2503. * step. */
  2504. crypto_cipher_t *f_crypto;
  2505. /** Encryption key and counter for cells heading back from the OR at this
  2506. * step. */
  2507. crypto_cipher_t *b_crypto;
  2508. /** Digest state for cells heading towards the OR at this step. */
  2509. crypto_digest_t *f_digest; /* for integrity checking */
  2510. /** Digest state for cells heading away from the OR at this step. */
  2511. crypto_digest_t *b_digest;
  2512. /** Current state of the handshake as performed with the OR at this
  2513. * step. */
  2514. onion_handshake_state_t handshake_state;
  2515. /** Diffie-hellman handshake state for performing an introduction
  2516. * operations */
  2517. crypto_dh_t *rend_dh_handshake_state;
  2518. /** Negotiated key material shared with the OR at this step. */
  2519. char rend_circ_nonce[DIGEST_LEN];/* KH in tor-spec.txt */
  2520. /** Information to extend to the OR at this step. */
  2521. extend_info_t *extend_info;
  2522. /** Is the circuit built to this step? Must be one of:
  2523. * - CPATH_STATE_CLOSED (The circuit has not been extended to this step)
  2524. * - CPATH_STATE_AWAITING_KEYS (We have sent an EXTEND/CREATE to this step
  2525. * and not received an EXTENDED/CREATED)
  2526. * - CPATH_STATE_OPEN (The circuit has been extended to this step) */
  2527. uint8_t state;
  2528. #define CPATH_STATE_CLOSED 0
  2529. #define CPATH_STATE_AWAITING_KEYS 1
  2530. #define CPATH_STATE_OPEN 2
  2531. struct crypt_path_t *next; /**< Link to next crypt_path_t in the circuit.
  2532. * (The list is circular, so the last node
  2533. * links to the first.) */
  2534. struct crypt_path_t *prev; /**< Link to previous crypt_path_t in the
  2535. * circuit. */
  2536. int package_window; /**< How many cells are we allowed to originate ending
  2537. * at this step? */
  2538. int deliver_window; /**< How many cells are we willing to deliver originating
  2539. * at this step? */
  2540. } crypt_path_t;
  2541. /** A reference-counted pointer to a crypt_path_t, used only to share
  2542. * the final rendezvous cpath to be used on a service-side rendezvous
  2543. * circuit among multiple circuits built in parallel to the same
  2544. * destination rendezvous point. */
  2545. typedef struct {
  2546. /** The reference count. */
  2547. unsigned int refcount;
  2548. /** The pointer. Set to NULL when the crypt_path_t is put into use
  2549. * on an opened rendezvous circuit. */
  2550. crypt_path_t *cpath;
  2551. } crypt_path_reference_t;
  2552. #define CPATH_KEY_MATERIAL_LEN (20*2+16*2)
  2553. #define DH_KEY_LEN DH_BYTES
  2554. /** Information used to build a circuit. */
  2555. typedef struct {
  2556. /** Intended length of the final circuit. */
  2557. int desired_path_len;
  2558. /** How to extend to the planned exit node. */
  2559. extend_info_t *chosen_exit;
  2560. /** Whether every node in the circ must have adequate uptime. */
  2561. unsigned int need_uptime : 1;
  2562. /** Whether every node in the circ must have adequate capacity. */
  2563. unsigned int need_capacity : 1;
  2564. /** Whether the last hop was picked with exiting in mind. */
  2565. unsigned int is_internal : 1;
  2566. /** Did we pick this as a one-hop tunnel (not safe for other streams)?
  2567. * These are for encrypted dir conns that exit to this router, not
  2568. * for arbitrary exits from the circuit. */
  2569. unsigned int onehop_tunnel : 1;
  2570. /** The crypt_path_t to append after rendezvous: used for rendezvous. */
  2571. crypt_path_t *pending_final_cpath;
  2572. /** A ref-counted reference to the crypt_path_t to append after
  2573. * rendezvous; used on the service side. */
  2574. crypt_path_reference_t *service_pending_final_cpath_ref;
  2575. /** How many times has building a circuit for this task failed? */
  2576. int failure_count;
  2577. /** At what time should we give up on this task? */
  2578. time_t expiry_time;
  2579. } cpath_build_state_t;
  2580. /** "magic" value for an origin_circuit_t */
  2581. #define ORIGIN_CIRCUIT_MAGIC 0x35315243u
  2582. /** "magic" value for an or_circuit_t */
  2583. #define OR_CIRCUIT_MAGIC 0x98ABC04Fu
  2584. /** "magic" value for a circuit that would have been freed by circuit_free,
  2585. * but which we're keeping around until a cpuworker reply arrives. See
  2586. * circuit_free() for more documentation. */
  2587. #define DEAD_CIRCUIT_MAGIC 0xdeadc14c
  2588. struct create_cell_t;
  2589. /** Entry in the cell stats list of a circuit; used only if CELL_STATS
  2590. * events are enabled. */
  2591. typedef struct testing_cell_stats_entry_t {
  2592. uint8_t command; /**< cell command number. */
  2593. /** Waiting time in centiseconds if this event is for a removed cell,
  2594. * or 0 if this event is for adding a cell to the queue. 22 bits can
  2595. * store more than 11 hours, enough to assume that a circuit with this
  2596. * delay would long have been closed. */
  2597. unsigned int waiting_time:22;
  2598. unsigned int removed:1; /**< 0 for added to, 1 for removed from queue. */
  2599. unsigned int exitward:1; /**< 0 for app-ward, 1 for exit-ward. */
  2600. } testing_cell_stats_entry_t;
  2601. /**
  2602. * A circuit is a path over the onion routing
  2603. * network. Applications can connect to one end of the circuit, and can
  2604. * create exit connections at the other end of the circuit. AP and exit
  2605. * connections have only one circuit associated with them (and thus these
  2606. * connection types are closed when the circuit is closed), whereas
  2607. * OR connections multiplex many circuits at once, and stay standing even
  2608. * when there are no circuits running over them.
  2609. *
  2610. * A circuit_t structure can fill one of two roles. First, a or_circuit_t
  2611. * links two connections together: either an edge connection and an OR
  2612. * connection, or two OR connections. (When joined to an OR connection, a
  2613. * circuit_t affects only cells sent to a particular circID on that
  2614. * connection. When joined to an edge connection, a circuit_t affects all
  2615. * data.)
  2616. * Second, an origin_circuit_t holds the cipher keys and state for sending data
  2617. * along a given circuit. At the OP, it has a sequence of ciphers, each
  2618. * of which is shared with a single OR along the circuit. Separate
  2619. * ciphers are used for data going "forward" (away from the OP) and
  2620. * "backward" (towards the OP). At the OR, a circuit has only two stream
  2621. * ciphers: one for data going forward, and one for data going backward.
  2622. */
  2623. typedef struct circuit_t {
  2624. uint32_t magic; /**< For memory and type debugging: must equal
  2625. * ORIGIN_CIRCUIT_MAGIC or OR_CIRCUIT_MAGIC. */
  2626. /** The channel that is next in this circuit. */
  2627. channel_t *n_chan;
  2628. /**
  2629. * The circuit_id used in the next (forward) hop of this circuit;
  2630. * this is unique to n_chan, but this ordered pair is globally
  2631. * unique:
  2632. *
  2633. * (n_chan->global_identifier, n_circ_id)
  2634. */
  2635. circid_t n_circ_id;
  2636. /**
  2637. * Circuit mux associated with n_chan to which this circuit is attached;
  2638. * NULL if we have no n_chan.
  2639. */
  2640. circuitmux_t *n_mux;
  2641. /** Queue of cells waiting to be transmitted on n_chan */
  2642. cell_queue_t n_chan_cells;
  2643. /**
  2644. * The hop to which we want to extend this circuit. Should be NULL if
  2645. * the circuit has attached to a channel.
  2646. */
  2647. extend_info_t *n_hop;
  2648. /** True iff we are waiting for n_chan_cells to become less full before
  2649. * allowing p_streams to add any more cells. (Origin circuit only.) */
  2650. unsigned int streams_blocked_on_n_chan : 1;
  2651. /** True iff we are waiting for p_chan_cells to become less full before
  2652. * allowing n_streams to add any more cells. (OR circuit only.) */
  2653. unsigned int streams_blocked_on_p_chan : 1;
  2654. /** True iff we have queued a delete backwards on this circuit, but not put
  2655. * it on the output buffer. */
  2656. unsigned int p_delete_pending : 1;
  2657. /** True iff we have queued a delete forwards on this circuit, but not put
  2658. * it on the output buffer. */
  2659. unsigned int n_delete_pending : 1;
  2660. /** True iff this circuit has received a DESTROY cell in either direction */
  2661. unsigned int received_destroy : 1;
  2662. uint8_t state; /**< Current status of this circuit. */
  2663. uint8_t purpose; /**< Why are we creating this circuit? */
  2664. /** How many relay data cells can we package (read from edge streams)
  2665. * on this circuit before we receive a circuit-level sendme cell asking
  2666. * for more? */
  2667. int package_window;
  2668. /** How many relay data cells will we deliver (write to edge streams)
  2669. * on this circuit? When deliver_window gets low, we send some
  2670. * circuit-level sendme cells to indicate that we're willing to accept
  2671. * more. */
  2672. int deliver_window;
  2673. /** Temporary field used during circuits_handle_oom. */
  2674. uint32_t age_tmp;
  2675. /** For storage while n_chan is pending (state CIRCUIT_STATE_CHAN_WAIT). */
  2676. struct create_cell_t *n_chan_create_cell;
  2677. /** When did circuit construction actually begin (ie send the
  2678. * CREATE cell or begin cannibalization).
  2679. *
  2680. * Note: This timer will get reset if we decide to cannibalize
  2681. * a circuit. It may also get reset during certain phases of hidden
  2682. * service circuit use.
  2683. *
  2684. * We keep this timestamp with a higher resolution than most so that the
  2685. * circuit-build-time tracking code can get millisecond resolution.
  2686. */
  2687. struct timeval timestamp_began;
  2688. /** This timestamp marks when the init_circuit_base constructor ran. */
  2689. struct timeval timestamp_created;
  2690. /** When the circuit was first used, or 0 if the circuit is clean.
  2691. *
  2692. * XXXX Note that some code will artifically adjust this value backward
  2693. * in time in order to indicate that a circuit shouldn't be used for new
  2694. * streams, but that it can stay alive as long as it has streams on it.
  2695. * That's a kludge we should fix.
  2696. *
  2697. * XXX The CBT code uses this field to record when HS-related
  2698. * circuits entered certain states. This usage probably won't
  2699. * interfere with this field's primary purpose, but we should
  2700. * document it more thoroughly to make sure of that.
  2701. *
  2702. * XXX The SocksPort option KeepaliveIsolateSOCKSAuth will artificially
  2703. * adjust this value forward each time a suitable stream is attached to an
  2704. * already constructed circuit, potentially keeping the circuit alive
  2705. * indefinitely.
  2706. */
  2707. time_t timestamp_dirty;
  2708. uint16_t marked_for_close; /**< Should we close this circuit at the end of
  2709. * the main loop? (If true, holds the line number
  2710. * where this circuit was marked.) */
  2711. const char *marked_for_close_file; /**< For debugging: in which file was this
  2712. * circuit marked for close? */
  2713. /** For what reason (See END_CIRC_REASON...) is this circuit being closed?
  2714. * This field is set in circuit_mark_for_close and used later in
  2715. * circuit_about_to_free. */
  2716. int marked_for_close_reason;
  2717. /** As marked_for_close_reason, but reflects the underlying reason for
  2718. * closing this circuit.
  2719. */
  2720. int marked_for_close_orig_reason;
  2721. /** Unique ID for measuring tunneled network status requests. */
  2722. uint64_t dirreq_id;
  2723. /** Index in smartlist of all circuits (global_circuitlist). */
  2724. int global_circuitlist_idx;
  2725. /** Next circuit in the doubly-linked ring of circuits waiting to add
  2726. * cells to n_conn. NULL if we have no cells pending, or if we're not
  2727. * linked to an OR connection. */
  2728. struct circuit_t *next_active_on_n_chan;
  2729. /** Previous circuit in the doubly-linked ring of circuits waiting to add
  2730. * cells to n_conn. NULL if we have no cells pending, or if we're not
  2731. * linked to an OR connection. */
  2732. struct circuit_t *prev_active_on_n_chan;
  2733. /** Various statistics about cells being added to or removed from this
  2734. * circuit's queues; used only if CELL_STATS events are enabled and
  2735. * cleared after being sent to control port. */
  2736. smartlist_t *testing_cell_stats;
  2737. /** If set, points to an HS token that this circuit might be carrying.
  2738. * Used by the HS circuitmap. */
  2739. hs_token_t *hs_token;
  2740. /** Hashtable node: used to look up the circuit by its HS token using the HS
  2741. circuitmap. */
  2742. HT_ENTRY(circuit_t) hs_circuitmap_node;
  2743. } circuit_t;
  2744. /** Largest number of relay_early cells that we can send on a given
  2745. * circuit. */
  2746. #define MAX_RELAY_EARLY_CELLS_PER_CIRCUIT 8
  2747. /**
  2748. * Describes the circuit building process in simplified terms based
  2749. * on the path bias accounting state for a circuit.
  2750. *
  2751. * NOTE: These state values are enumerated in the order for which we
  2752. * expect circuits to transition through them. If you add states,
  2753. * you need to preserve this overall ordering. The various pathbias
  2754. * state transition and accounting functions (pathbias_mark_* and
  2755. * pathbias_count_*) contain ordinal comparisons to enforce proper
  2756. * state transitions for corrections.
  2757. *
  2758. * This state machine and the associated logic was created to prevent
  2759. * miscounting due to unknown cases of circuit reuse. See also tickets
  2760. * #6475 and #7802.
  2761. */
  2762. typedef enum {
  2763. /** This circuit is "new". It has not yet completed a first hop
  2764. * or been counted by the path bias code. */
  2765. PATH_STATE_NEW_CIRC = 0,
  2766. /** This circuit has completed one/two hops, and has been counted by
  2767. * the path bias logic. */
  2768. PATH_STATE_BUILD_ATTEMPTED = 1,
  2769. /** This circuit has been completely built */
  2770. PATH_STATE_BUILD_SUCCEEDED = 2,
  2771. /** Did we try to attach any SOCKS streams or hidserv introductions to
  2772. * this circuit?
  2773. *
  2774. * Note: If we ever implement end-to-end stream timing through test
  2775. * stream probes (#5707), we must *not* set this for those probes
  2776. * (or any other automatic streams) because the adversary could
  2777. * just tag at a later point.
  2778. */
  2779. PATH_STATE_USE_ATTEMPTED = 3,
  2780. /** Did any SOCKS streams or hidserv introductions actually succeed on
  2781. * this circuit?
  2782. *
  2783. * If any streams detatch/fail from this circuit, the code transitions
  2784. * the circuit back to PATH_STATE_USE_ATTEMPTED to ensure we probe. See
  2785. * pathbias_mark_use_rollback() for that.
  2786. */
  2787. PATH_STATE_USE_SUCCEEDED = 4,
  2788. /**
  2789. * This is a special state to indicate that we got a corrupted
  2790. * relay cell on a circuit and we don't intend to probe it.
  2791. */
  2792. PATH_STATE_USE_FAILED = 5,
  2793. /**
  2794. * This is a special state to indicate that we already counted
  2795. * the circuit. Used to guard against potential state machine
  2796. * violations.
  2797. */
  2798. PATH_STATE_ALREADY_COUNTED = 6,
  2799. } path_state_t;
  2800. #define path_state_bitfield_t ENUM_BF(path_state_t)
  2801. /** An origin_circuit_t holds data necessary to build and use a circuit.
  2802. */
  2803. typedef struct origin_circuit_t {
  2804. circuit_t base_;
  2805. /** Linked list of AP streams (or EXIT streams if hidden service)
  2806. * associated with this circuit. */
  2807. edge_connection_t *p_streams;
  2808. /** Bytes read from any attached stream since last call to
  2809. * control_event_circ_bandwidth_used(). Only used if we're configured
  2810. * to emit CIRC_BW events. */
  2811. uint32_t n_read_circ_bw;
  2812. /** Bytes written to any attached stream since last call to
  2813. * control_event_circ_bandwidth_used(). Only used if we're configured
  2814. * to emit CIRC_BW events. */
  2815. uint32_t n_written_circ_bw;
  2816. /** Build state for this circuit. It includes the intended path
  2817. * length, the chosen exit router, rendezvous information, etc.
  2818. */
  2819. cpath_build_state_t *build_state;
  2820. /** The doubly-linked list of crypt_path_t entries, one per hop,
  2821. * for this circuit. This includes ciphers for each hop,
  2822. * integrity-checking digests for each hop, and package/delivery
  2823. * windows for each hop.
  2824. */
  2825. crypt_path_t *cpath;
  2826. /** Holds all rendezvous data on either client or service side. */
  2827. rend_data_t *rend_data;
  2828. /** Holds hidden service identifier on either client or service side. This
  2829. * is for both introduction and rendezvous circuit. */
  2830. struct hs_ident_circuit_t *hs_ident;
  2831. /** Holds the data that the entry guard system uses to track the
  2832. * status of the guard this circuit is using, and thereby to determine
  2833. * whether this circuit can be used. */
  2834. struct circuit_guard_state_t *guard_state;
  2835. /** Index into global_origin_circuit_list for this circuit. -1 if not
  2836. * present. */
  2837. int global_origin_circuit_list_idx;
  2838. /** How many more relay_early cells can we send on this circuit, according
  2839. * to the specification? */
  2840. unsigned int remaining_relay_early_cells : 4;
  2841. /** Set if this circuit is insanely old and we already informed the user */
  2842. unsigned int is_ancient : 1;
  2843. /** Set if this circuit has already been opened. Used to detect
  2844. * cannibalized circuits. */
  2845. unsigned int has_opened : 1;
  2846. /**
  2847. * Path bias state machine. Used to ensure integrity of our
  2848. * circuit building and usage accounting. See path_state_t
  2849. * for more details.
  2850. */
  2851. path_state_bitfield_t path_state : 3;
  2852. /* If this flag is set, we should not consider attaching any more
  2853. * connections to this circuit. */
  2854. unsigned int unusable_for_new_conns : 1;
  2855. /**
  2856. * Tristate variable to guard against pathbias miscounting
  2857. * due to circuit purpose transitions changing the decision
  2858. * of pathbias_should_count(). This variable is informational
  2859. * only. The current results of pathbias_should_count() are
  2860. * the official decision for pathbias accounting.
  2861. */
  2862. uint8_t pathbias_shouldcount;
  2863. #define PATHBIAS_SHOULDCOUNT_UNDECIDED 0
  2864. #define PATHBIAS_SHOULDCOUNT_IGNORED 1
  2865. #define PATHBIAS_SHOULDCOUNT_COUNTED 2
  2866. /** For path probing. Store the temporary probe stream ID
  2867. * for response comparison */
  2868. streamid_t pathbias_probe_id;
  2869. /** For path probing. Store the temporary probe address nonce
  2870. * (in host byte order) for response comparison. */
  2871. uint32_t pathbias_probe_nonce;
  2872. /** Set iff this is a hidden-service circuit which has timed out
  2873. * according to our current circuit-build timeout, but which has
  2874. * been kept around because it might still succeed in connecting to
  2875. * its destination, and which is not a fully-connected rendezvous
  2876. * circuit.
  2877. *
  2878. * (We clear this flag for client-side rendezvous circuits when they
  2879. * are 'joined' to the other side's rendezvous circuit, so that
  2880. * connection_ap_handshake_attach_circuit can put client streams on
  2881. * the circuit. We also clear this flag for service-side rendezvous
  2882. * circuits when they are 'joined' to a client's rend circ, but only
  2883. * for symmetry with the client case. Client-side introduction
  2884. * circuits are closed when we get a joined rend circ, and
  2885. * service-side introduction circuits never have this flag set.) */
  2886. unsigned int hs_circ_has_timed_out : 1;
  2887. /** Set iff this circuit has been given a relaxed timeout because
  2888. * no circuits have opened. Used to prevent spamming logs. */
  2889. unsigned int relaxed_timeout : 1;
  2890. /** Set iff this is a service-side rendezvous circuit for which a
  2891. * new connection attempt has been launched. We consider launching
  2892. * a new service-side rend circ to a client when the previous one
  2893. * fails; now that we don't necessarily close a service-side rend
  2894. * circ when we launch a new one to the same client, this flag keeps
  2895. * us from launching two retries for the same failed rend circ. */
  2896. unsigned int hs_service_side_rend_circ_has_been_relaunched : 1;
  2897. /** What commands were sent over this circuit that decremented the
  2898. * RELAY_EARLY counter? This is for debugging task 878. */
  2899. uint8_t relay_early_commands[MAX_RELAY_EARLY_CELLS_PER_CIRCUIT];
  2900. /** How many RELAY_EARLY cells have been sent over this circuit? This is
  2901. * for debugging task 878, too. */
  2902. int relay_early_cells_sent;
  2903. /** The next stream_id that will be tried when we're attempting to
  2904. * construct a new AP stream originating at this circuit. */
  2905. streamid_t next_stream_id;
  2906. /* The intro key replaces the hidden service's public key if purpose is
  2907. * S_ESTABLISH_INTRO or S_INTRO, provided that no unversioned rendezvous
  2908. * descriptor is used. */
  2909. crypto_pk_t *intro_key;
  2910. /** Quasi-global identifier for this circuit; used for control.c */
  2911. /* XXXX NM This can get re-used after 2**32 circuits. */
  2912. uint32_t global_identifier;
  2913. /** True if we have associated one stream to this circuit, thereby setting
  2914. * the isolation paramaters for this circuit. Note that this doesn't
  2915. * necessarily mean that we've <em>attached</em> any streams to the circuit:
  2916. * we may only have marked up this circuit during the launch process.
  2917. */
  2918. unsigned int isolation_values_set : 1;
  2919. /** True iff any stream has <em>ever</em> been attached to this circuit.
  2920. *
  2921. * In a better world we could use timestamp_dirty for this, but
  2922. * timestamp_dirty is far too overloaded at the moment.
  2923. */
  2924. unsigned int isolation_any_streams_attached : 1;
  2925. /** A bitfield of ISO_* flags for every isolation field such that this
  2926. * circuit has had streams with more than one value for that field
  2927. * attached to it. */
  2928. uint8_t isolation_flags_mixed;
  2929. /** @name Isolation parameters
  2930. *
  2931. * If any streams have been associated with this circ (isolation_values_set
  2932. * == 1), and all streams associated with the circuit have had the same
  2933. * value for some field ((isolation_flags_mixed & ISO_FOO) == 0), then these
  2934. * elements hold the value for that field.
  2935. *
  2936. * Note again that "associated" is not the same as "attached": we
  2937. * preliminarily associate streams with a circuit while the circuit is being
  2938. * launched, so that we can tell whether we need to launch more circuits.
  2939. *
  2940. * @{
  2941. */
  2942. uint8_t client_proto_type;
  2943. uint8_t client_proto_socksver;
  2944. uint16_t dest_port;
  2945. tor_addr_t client_addr;
  2946. char *dest_address;
  2947. int session_group;
  2948. unsigned nym_epoch;
  2949. size_t socks_username_len;
  2950. uint8_t socks_password_len;
  2951. /* Note that the next two values are NOT NUL-terminated; see
  2952. socks_username_len and socks_password_len for their lengths. */
  2953. char *socks_username;
  2954. char *socks_password;
  2955. /** Global identifier for the first stream attached here; used by
  2956. * ISO_STREAM. */
  2957. uint64_t associated_isolated_stream_global_id;
  2958. /**@}*/
  2959. /** A list of addr_policy_t for this circuit in particular. Used by
  2960. * adjust_exit_policy_from_exitpolicy_failure.
  2961. */
  2962. smartlist_t *prepend_policy;
  2963. /** How long do we wait before closing this circuit if it remains
  2964. * completely idle after it was built, in seconds? This value
  2965. * is randomized on a per-circuit basis from CircuitsAvailableTimoeut
  2966. * to 2*CircuitsAvailableTimoeut. */
  2967. int circuit_idle_timeout;
  2968. } origin_circuit_t;
  2969. struct onion_queue_t;
  2970. /** An or_circuit_t holds information needed to implement a circuit at an
  2971. * OR. */
  2972. typedef struct or_circuit_t {
  2973. circuit_t base_;
  2974. /** Next circuit in the doubly-linked ring of circuits waiting to add
  2975. * cells to p_chan. NULL if we have no cells pending, or if we're not
  2976. * linked to an OR connection. */
  2977. struct circuit_t *next_active_on_p_chan;
  2978. /** Previous circuit in the doubly-linked ring of circuits waiting to add
  2979. * cells to p_chan. NULL if we have no cells pending, or if we're not
  2980. * linked to an OR connection. */
  2981. struct circuit_t *prev_active_on_p_chan;
  2982. /** Pointer to an entry on the onion queue, if this circuit is waiting for a
  2983. * chance to give an onionskin to a cpuworker. Used only in onion.c */
  2984. struct onion_queue_t *onionqueue_entry;
  2985. /** Pointer to a workqueue entry, if this circuit has given an onionskin to
  2986. * a cpuworker and is waiting for a response. Used to decide whether it is
  2987. * safe to free a circuit or if it is still in use by a cpuworker. */
  2988. struct workqueue_entry_s *workqueue_entry;
  2989. /** The circuit_id used in the previous (backward) hop of this circuit. */
  2990. circid_t p_circ_id;
  2991. /** Queue of cells waiting to be transmitted on p_conn. */
  2992. cell_queue_t p_chan_cells;
  2993. /** The channel that is previous in this circuit. */
  2994. channel_t *p_chan;
  2995. /**
  2996. * Circuit mux associated with p_chan to which this circuit is attached;
  2997. * NULL if we have no p_chan.
  2998. */
  2999. circuitmux_t *p_mux;
  3000. /** Linked list of Exit streams associated with this circuit. */
  3001. edge_connection_t *n_streams;
  3002. /** Linked list of Exit streams associated with this circuit that are
  3003. * still being resolved. */
  3004. edge_connection_t *resolving_streams;
  3005. /** The cipher used by intermediate hops for cells heading toward the
  3006. * OP. */
  3007. crypto_cipher_t *p_crypto;
  3008. /** The cipher used by intermediate hops for cells heading away from
  3009. * the OP. */
  3010. crypto_cipher_t *n_crypto;
  3011. /** The integrity-checking digest used by intermediate hops, for
  3012. * cells packaged here and heading towards the OP.
  3013. */
  3014. crypto_digest_t *p_digest;
  3015. /** The integrity-checking digest used by intermediate hops, for
  3016. * cells packaged at the OP and arriving here.
  3017. */
  3018. crypto_digest_t *n_digest;
  3019. /** Points to spliced circuit if purpose is REND_ESTABLISHED, and circuit
  3020. * is not marked for close. */
  3021. struct or_circuit_t *rend_splice;
  3022. /** Stores KH for the handshake. */
  3023. char rend_circ_nonce[DIGEST_LEN];/* KH in tor-spec.txt */
  3024. /** How many more relay_early cells can we send on this circuit, according
  3025. * to the specification? */
  3026. unsigned int remaining_relay_early_cells : 4;
  3027. /* We have already received an INTRODUCE1 cell on this circuit. */
  3028. unsigned int already_received_introduce1 : 1;
  3029. /** True iff this circuit was made with a CREATE_FAST cell. */
  3030. unsigned int is_first_hop : 1;
  3031. /** If set, this circuit carries HS traffic. Consider it in any HS
  3032. * statistics. */
  3033. unsigned int circuit_carries_hs_traffic_stats : 1;
  3034. /** Number of cells that were removed from circuit queue; reset every
  3035. * time when writing buffer stats to disk. */
  3036. uint32_t processed_cells;
  3037. /** Total time in milliseconds that cells spent in both app-ward and
  3038. * exit-ward queues of this circuit; reset every time when writing
  3039. * buffer stats to disk. */
  3040. uint64_t total_cell_waiting_time;
  3041. /** Maximum cell queue size for a middle relay; this is stored per circuit
  3042. * so append_cell_to_circuit_queue() can adjust it if it changes. If set
  3043. * to zero, it is initialized to the default value.
  3044. */
  3045. uint32_t max_middle_cells;
  3046. } or_circuit_t;
  3047. #if REND_COOKIE_LEN != DIGEST_LEN
  3048. #error "The REND_TOKEN_LEN macro assumes REND_COOKIE_LEN == DIGEST_LEN"
  3049. #endif
  3050. #define REND_TOKEN_LEN DIGEST_LEN
  3051. /** Convert a circuit subtype to a circuit_t. */
  3052. #define TO_CIRCUIT(x) (&((x)->base_))
  3053. /** Convert a circuit_t* to a pointer to the enclosing or_circuit_t. Assert
  3054. * if the cast is impossible. */
  3055. static or_circuit_t *TO_OR_CIRCUIT(circuit_t *);
  3056. static const or_circuit_t *CONST_TO_OR_CIRCUIT(const circuit_t *);
  3057. /** Convert a circuit_t* to a pointer to the enclosing origin_circuit_t.
  3058. * Assert if the cast is impossible. */
  3059. static origin_circuit_t *TO_ORIGIN_CIRCUIT(circuit_t *);
  3060. static const origin_circuit_t *CONST_TO_ORIGIN_CIRCUIT(const circuit_t *);
  3061. /** Return 1 iff <b>node</b> has Exit flag and no BadExit flag.
  3062. * Otherwise, return 0.
  3063. */
  3064. static inline int node_is_good_exit(const node_t *node)
  3065. {
  3066. return node->is_exit && ! node->is_bad_exit;
  3067. }
  3068. static inline or_circuit_t *TO_OR_CIRCUIT(circuit_t *x)
  3069. {
  3070. tor_assert(x->magic == OR_CIRCUIT_MAGIC);
  3071. return DOWNCAST(or_circuit_t, x);
  3072. }
  3073. static inline const or_circuit_t *CONST_TO_OR_CIRCUIT(const circuit_t *x)
  3074. {
  3075. tor_assert(x->magic == OR_CIRCUIT_MAGIC);
  3076. return DOWNCAST(or_circuit_t, x);
  3077. }
  3078. static inline origin_circuit_t *TO_ORIGIN_CIRCUIT(circuit_t *x)
  3079. {
  3080. tor_assert(x->magic == ORIGIN_CIRCUIT_MAGIC);
  3081. return DOWNCAST(origin_circuit_t, x);
  3082. }
  3083. static inline const origin_circuit_t *CONST_TO_ORIGIN_CIRCUIT(
  3084. const circuit_t *x)
  3085. {
  3086. tor_assert(x->magic == ORIGIN_CIRCUIT_MAGIC);
  3087. return DOWNCAST(origin_circuit_t, x);
  3088. }
  3089. /* limits for TCP send and recv buffer size used for constrained sockets */
  3090. #define MIN_CONSTRAINED_TCP_BUFFER 2048
  3091. #define MAX_CONSTRAINED_TCP_BUFFER 262144 /* 256k */
  3092. /** @name Isolation flags
  3093. Ways to isolate client streams
  3094. @{
  3095. */
  3096. /** Isolate based on destination port */
  3097. #define ISO_DESTPORT (1u<<0)
  3098. /** Isolate based on destination address */
  3099. #define ISO_DESTADDR (1u<<1)
  3100. /** Isolate based on SOCKS authentication */
  3101. #define ISO_SOCKSAUTH (1u<<2)
  3102. /** Isolate based on client protocol choice */
  3103. #define ISO_CLIENTPROTO (1u<<3)
  3104. /** Isolate based on client address */
  3105. #define ISO_CLIENTADDR (1u<<4)
  3106. /** Isolate based on session group (always on). */
  3107. #define ISO_SESSIONGRP (1u<<5)
  3108. /** Isolate based on newnym epoch (always on). */
  3109. #define ISO_NYM_EPOCH (1u<<6)
  3110. /** Isolate all streams (Internal only). */
  3111. #define ISO_STREAM (1u<<7)
  3112. /**@}*/
  3113. /** Default isolation level for ports. */
  3114. #define ISO_DEFAULT (ISO_CLIENTADDR|ISO_SOCKSAUTH|ISO_SESSIONGRP|ISO_NYM_EPOCH)
  3115. /** Indicates that we haven't yet set a session group on a port_cfg_t. */
  3116. #define SESSION_GROUP_UNSET -1
  3117. /** Session group reserved for directory connections */
  3118. #define SESSION_GROUP_DIRCONN -2
  3119. /** Session group reserved for resolve requests launched by a controller */
  3120. #define SESSION_GROUP_CONTROL_RESOLVE -3
  3121. /** First automatically allocated session group number */
  3122. #define SESSION_GROUP_FIRST_AUTO -4
  3123. /** Configuration for a single port that we're listening on. */
  3124. typedef struct port_cfg_t {
  3125. tor_addr_t addr; /**< The actual IP to listen on, if !is_unix_addr. */
  3126. int port; /**< The configured port, or CFG_AUTO_PORT to tell Tor to pick its
  3127. * own port. */
  3128. uint8_t type; /**< One of CONN_TYPE_*_LISTENER */
  3129. unsigned is_unix_addr : 1; /**< True iff this is an AF_UNIX address. */
  3130. unsigned is_group_writable : 1;
  3131. unsigned is_world_writable : 1;
  3132. unsigned relax_dirmode_check : 1;
  3133. entry_port_cfg_t entry_cfg;
  3134. server_port_cfg_t server_cfg;
  3135. /* Unix sockets only: */
  3136. /** Path for an AF_UNIX address */
  3137. char unix_addr[FLEXIBLE_ARRAY_MEMBER];
  3138. } port_cfg_t;
  3139. typedef struct routerset_t routerset_t;
  3140. /** A magic value for the (Socks|OR|...)Port options below, telling Tor
  3141. * to pick its own port. */
  3142. #define CFG_AUTO_PORT 0xc4005e
  3143. /** Enumeration of outbound address configuration types:
  3144. * Exit-only, OR-only, or both */
  3145. typedef enum {OUTBOUND_ADDR_EXIT, OUTBOUND_ADDR_OR,
  3146. OUTBOUND_ADDR_EXIT_AND_OR,
  3147. OUTBOUND_ADDR_MAX} outbound_addr_t;
  3148. /** Configuration options for a Tor process. */
  3149. typedef struct {
  3150. uint32_t magic_;
  3151. /** What should the tor process actually do? */
  3152. enum {
  3153. CMD_RUN_TOR=0, CMD_LIST_FINGERPRINT, CMD_HASH_PASSWORD,
  3154. CMD_VERIFY_CONFIG, CMD_RUN_UNITTESTS, CMD_DUMP_CONFIG,
  3155. CMD_KEYGEN,
  3156. CMD_KEY_EXPIRATION,
  3157. } command;
  3158. char *command_arg; /**< Argument for command-line option. */
  3159. config_line_t *Logs; /**< New-style list of configuration lines
  3160. * for logs */
  3161. int LogTimeGranularity; /**< Log resolution in milliseconds. */
  3162. int LogMessageDomains; /**< Boolean: Should we log the domain(s) in which
  3163. * each log message occurs? */
  3164. int TruncateLogFile; /**< Boolean: Should we truncate the log file
  3165. before we start writing? */
  3166. char *SyslogIdentityTag; /**< Identity tag to add for syslog logging. */
  3167. char *DebugLogFile; /**< Where to send verbose log messages. */
  3168. char *DataDirectory; /**< OR only: where to store long-term data. */
  3169. int DataDirectoryGroupReadable; /**< Boolean: Is the DataDirectory g+r? */
  3170. char *Nickname; /**< OR only: nickname of this onion router. */
  3171. char *Address; /**< OR only: configured address for this onion router. */
  3172. char *PidFile; /**< Where to store PID of Tor process. */
  3173. routerset_t *ExitNodes; /**< Structure containing nicknames, digests,
  3174. * country codes and IP address patterns of ORs to
  3175. * consider as exits. */
  3176. routerset_t *EntryNodes;/**< Structure containing nicknames, digests,
  3177. * country codes and IP address patterns of ORs to
  3178. * consider as entry points. */
  3179. int StrictNodes; /**< Boolean: When none of our EntryNodes or ExitNodes
  3180. * are up, or we need to access a node in ExcludeNodes,
  3181. * do we just fail instead? */
  3182. routerset_t *ExcludeNodes;/**< Structure containing nicknames, digests,
  3183. * country codes and IP address patterns of ORs
  3184. * not to use in circuits. But see StrictNodes
  3185. * above. */
  3186. routerset_t *ExcludeExitNodes;/**< Structure containing nicknames, digests,
  3187. * country codes and IP address patterns of
  3188. * ORs not to consider as exits. */
  3189. /** Union of ExcludeNodes and ExcludeExitNodes */
  3190. routerset_t *ExcludeExitNodesUnion_;
  3191. int DisableAllSwap; /**< Boolean: Attempt to call mlockall() on our
  3192. * process for all current and future memory. */
  3193. config_line_t *ExitPolicy; /**< Lists of exit policy components. */
  3194. int ExitPolicyRejectPrivate; /**< Should we not exit to reserved private
  3195. * addresses, and our own published addresses?
  3196. */
  3197. int ExitPolicyRejectLocalInterfaces; /**< Should we not exit to local
  3198. * interface addresses?
  3199. * Includes OutboundBindAddresses and
  3200. * configured ports. */
  3201. config_line_t *SocksPolicy; /**< Lists of socks policy components */
  3202. config_line_t *DirPolicy; /**< Lists of dir policy components */
  3203. /** Local address to bind outbound sockets */
  3204. config_line_t *OutboundBindAddress;
  3205. /** Local address to bind outbound relay sockets */
  3206. config_line_t *OutboundBindAddressOR;
  3207. /** Local address to bind outbound exit sockets */
  3208. config_line_t *OutboundBindAddressExit;
  3209. /** Addresses derived from the various OutboundBindAddress lines.
  3210. * [][0] is IPv4, [][1] is IPv6
  3211. */
  3212. tor_addr_t OutboundBindAddresses[OUTBOUND_ADDR_MAX][2];
  3213. /** Directory server only: which versions of
  3214. * Tor should we tell users to run? */
  3215. config_line_t *RecommendedVersions;
  3216. config_line_t *RecommendedClientVersions;
  3217. config_line_t *RecommendedServerVersions;
  3218. config_line_t *RecommendedPackages;
  3219. /** Whether dirservers allow router descriptors with private IPs. */
  3220. int DirAllowPrivateAddresses;
  3221. /** Whether routers accept EXTEND cells to routers with private IPs. */
  3222. int ExtendAllowPrivateAddresses;
  3223. char *User; /**< Name of user to run Tor as. */
  3224. config_line_t *ORPort_lines; /**< Ports to listen on for OR connections. */
  3225. /** Ports to listen on for extended OR connections. */
  3226. config_line_t *ExtORPort_lines;
  3227. /** Ports to listen on for SOCKS connections. */
  3228. config_line_t *SocksPort_lines;
  3229. /** Ports to listen on for transparent pf/netfilter connections. */
  3230. config_line_t *TransPort_lines;
  3231. const char *TransProxyType; /**< What kind of transparent proxy
  3232. * implementation are we using? */
  3233. /** Parsed value of TransProxyType. */
  3234. enum {
  3235. TPT_DEFAULT,
  3236. TPT_PF_DIVERT,
  3237. TPT_IPFW,
  3238. TPT_TPROXY,
  3239. } TransProxyType_parsed;
  3240. config_line_t *NATDPort_lines; /**< Ports to listen on for transparent natd
  3241. * connections. */
  3242. config_line_t *ControlPort_lines; /**< Ports to listen on for control
  3243. * connections. */
  3244. config_line_t *ControlSocket; /**< List of Unix Domain Sockets to listen on
  3245. * for control connections. */
  3246. int ControlSocketsGroupWritable; /**< Boolean: Are control sockets g+rw? */
  3247. int SocksSocketsGroupWritable; /**< Boolean: Are SOCKS sockets g+rw? */
  3248. /** Ports to listen on for directory connections. */
  3249. config_line_t *DirPort_lines;
  3250. config_line_t *DNSPort_lines; /**< Ports to listen on for DNS requests. */
  3251. /* MaxMemInQueues value as input by the user. We clean this up to be
  3252. * MaxMemInQueues. */
  3253. uint64_t MaxMemInQueues_raw;
  3254. uint64_t MaxMemInQueues;/**< If we have more memory than this allocated
  3255. * for queues and buffers, run the OOM handler */
  3256. /** Above this value, consider ourselves low on RAM. */
  3257. uint64_t MaxMemInQueues_low_threshold;
  3258. /** @name port booleans
  3259. *
  3260. * Derived booleans: For server ports and ControlPort, true iff there is a
  3261. * non-listener port on an AF_INET or AF_INET6 address of the given type
  3262. * configured in one of the _lines options above.
  3263. * For client ports, also true if there is a unix socket configured.
  3264. * If you are checking for client ports, you may want to use:
  3265. * SocksPort_set || TransPort_set || NATDPort_set || DNSPort_set
  3266. * rather than SocksPort_set.
  3267. *
  3268. * @{
  3269. */
  3270. unsigned int ORPort_set : 1;
  3271. unsigned int SocksPort_set : 1;
  3272. unsigned int TransPort_set : 1;
  3273. unsigned int NATDPort_set : 1;
  3274. unsigned int ControlPort_set : 1;
  3275. unsigned int DirPort_set : 1;
  3276. unsigned int DNSPort_set : 1;
  3277. unsigned int ExtORPort_set : 1;
  3278. /**@}*/
  3279. int AssumeReachable; /**< Whether to publish our descriptor regardless. */
  3280. int AuthoritativeDir; /**< Boolean: is this an authoritative directory? */
  3281. int V3AuthoritativeDir; /**< Boolean: is this an authoritative directory
  3282. * for version 3 directories? */
  3283. int VersioningAuthoritativeDir; /**< Boolean: is this an authoritative
  3284. * directory that's willing to recommend
  3285. * versions? */
  3286. int BridgeAuthoritativeDir; /**< Boolean: is this an authoritative directory
  3287. * that aggregates bridge descriptors? */
  3288. /** If set on a bridge authority, it will answer requests on its dirport
  3289. * for bridge statuses -- but only if the requests use this password. */
  3290. char *BridgePassword;
  3291. /** If BridgePassword is set, this is a SHA256 digest of the basic http
  3292. * authenticator for it. Used so we can do a time-independent comparison. */
  3293. char *BridgePassword_AuthDigest_;
  3294. int UseBridges; /**< Boolean: should we start all circuits with a bridge? */
  3295. config_line_t *Bridges; /**< List of bootstrap bridge addresses. */
  3296. config_line_t *ClientTransportPlugin; /**< List of client
  3297. transport plugins. */
  3298. config_line_t *ServerTransportPlugin; /**< List of client
  3299. transport plugins. */
  3300. /** List of TCP/IP addresses that transports should listen at. */
  3301. config_line_t *ServerTransportListenAddr;
  3302. /** List of options that must be passed to pluggable transports. */
  3303. config_line_t *ServerTransportOptions;
  3304. int BridgeRelay; /**< Boolean: are we acting as a bridge relay? We make
  3305. * this explicit so we can change how we behave in the
  3306. * future. */
  3307. /** Boolean: if we know the bridge's digest, should we get new
  3308. * descriptors from the bridge authorities or from the bridge itself? */
  3309. int UpdateBridgesFromAuthority;
  3310. int AvoidDiskWrites; /**< Boolean: should we never cache things to disk?
  3311. * Not used yet. */
  3312. int ClientOnly; /**< Boolean: should we never evolve into a server role? */
  3313. int ReducedConnectionPadding; /**< Boolean: Should we try to keep connections
  3314. open shorter and pad them less against
  3315. connection-level traffic analysis? */
  3316. /** Autobool: if auto, then connection padding will be negotiated by client
  3317. * and server. If 0, it will be fully disabled. If 1, the client will still
  3318. * pad to the server regardless of server support. */
  3319. int ConnectionPadding;
  3320. /** To what authority types do we publish our descriptor? Choices are
  3321. * "v1", "v2", "v3", "bridge", or "". */
  3322. smartlist_t *PublishServerDescriptor;
  3323. /** A bitfield of authority types, derived from PublishServerDescriptor. */
  3324. dirinfo_type_t PublishServerDescriptor_;
  3325. /** Boolean: do we publish hidden service descriptors to the HS auths? */
  3326. int PublishHidServDescriptors;
  3327. int FetchServerDescriptors; /**< Do we fetch server descriptors as normal? */
  3328. int FetchHidServDescriptors; /**< and hidden service descriptors? */
  3329. int MinUptimeHidServDirectoryV2; /**< As directory authority, accept hidden
  3330. * service directories after what time? */
  3331. int FetchUselessDescriptors; /**< Do we fetch non-running descriptors too? */
  3332. int AllDirActionsPrivate; /**< Should every directory action be sent
  3333. * through a Tor circuit? */
  3334. /** Run in 'tor2web mode'? (I.e. only make client connections to hidden
  3335. * services, and use a single hop for all hidden-service-related
  3336. * circuits.) */
  3337. int Tor2webMode;
  3338. /** A routerset that should be used when picking RPs for HS circuits. */
  3339. routerset_t *Tor2webRendezvousPoints;
  3340. /** Onion Services in HiddenServiceSingleHopMode make one-hop (direct)
  3341. * circuits between the onion service server, and the introduction and
  3342. * rendezvous points. (Onion service descriptors are still posted using
  3343. * 3-hop paths, to avoid onion service directories blocking the service.)
  3344. * This option makes every hidden service instance hosted by
  3345. * this tor instance a Single Onion Service.
  3346. * HiddenServiceSingleHopMode requires HiddenServiceNonAnonymousMode to be
  3347. * set to 1.
  3348. * Use rend_service_allow_non_anonymous_connection() or
  3349. * rend_service_reveal_startup_time() instead of using this option directly.
  3350. */
  3351. int HiddenServiceSingleHopMode;
  3352. /* Makes hidden service clients and servers non-anonymous on this tor
  3353. * instance. Allows the non-anonymous HiddenServiceSingleHopMode. Enables
  3354. * non-anonymous behaviour in the hidden service protocol.
  3355. * Use rend_service_non_anonymous_mode_enabled() instead of using this option
  3356. * directly.
  3357. */
  3358. int HiddenServiceNonAnonymousMode;
  3359. int ConnLimit; /**< Demanded minimum number of simultaneous connections. */
  3360. int ConnLimit_; /**< Maximum allowed number of simultaneous connections. */
  3361. int ConnLimit_high_thresh; /**< start trying to lower socket usage if we
  3362. * have this many. */
  3363. int ConnLimit_low_thresh; /**< try to get down to here after socket
  3364. * exhaustion. */
  3365. int RunAsDaemon; /**< If true, run in the background. (Unix only) */
  3366. int FascistFirewall; /**< Whether to prefer ORs reachable on open ports. */
  3367. smartlist_t *FirewallPorts; /**< Which ports our firewall allows
  3368. * (strings). */
  3369. config_line_t *ReachableAddresses; /**< IP:ports our firewall allows. */
  3370. config_line_t *ReachableORAddresses; /**< IP:ports for OR conns. */
  3371. config_line_t *ReachableDirAddresses; /**< IP:ports for Dir conns. */
  3372. int ConstrainedSockets; /**< Shrink xmit and recv socket buffers. */
  3373. uint64_t ConstrainedSockSize; /**< Size of constrained buffers. */
  3374. /** Whether we should drop exit streams from Tors that we don't know are
  3375. * relays. One of "0" (never refuse), "1" (always refuse), or "-1" (do
  3376. * what the consensus says, defaulting to 'refuse' if the consensus says
  3377. * nothing). */
  3378. int RefuseUnknownExits;
  3379. /** Application ports that require all nodes in circ to have sufficient
  3380. * uptime. */
  3381. smartlist_t *LongLivedPorts;
  3382. /** Application ports that are likely to be unencrypted and
  3383. * unauthenticated; we reject requests for them to prevent the
  3384. * user from screwing up and leaking plaintext secrets to an
  3385. * observer somewhere on the Internet. */
  3386. smartlist_t *RejectPlaintextPorts;
  3387. /** Related to RejectPlaintextPorts above, except this config option
  3388. * controls whether we warn (in the log and via a controller status
  3389. * event) every time a risky connection is attempted. */
  3390. smartlist_t *WarnPlaintextPorts;
  3391. /** Should we try to reuse the same exit node for a given host */
  3392. smartlist_t *TrackHostExits;
  3393. int TrackHostExitsExpire; /**< Number of seconds until we expire an
  3394. * addressmap */
  3395. config_line_t *AddressMap; /**< List of address map directives. */
  3396. int AutomapHostsOnResolve; /**< If true, when we get a resolve request for a
  3397. * hostname ending with one of the suffixes in
  3398. * <b>AutomapHostsSuffixes</b>, map it to a
  3399. * virtual address. */
  3400. /** List of suffixes for <b>AutomapHostsOnResolve</b>. The special value
  3401. * "." means "match everything." */
  3402. smartlist_t *AutomapHostsSuffixes;
  3403. int RendPostPeriod; /**< How often do we post each rendezvous service
  3404. * descriptor? Remember to publish them independently. */
  3405. int KeepalivePeriod; /**< How often do we send padding cells to keep
  3406. * connections alive? */
  3407. int SocksTimeout; /**< How long do we let a socks connection wait
  3408. * unattached before we fail it? */
  3409. int LearnCircuitBuildTimeout; /**< If non-zero, we attempt to learn a value
  3410. * for CircuitBuildTimeout based on timeout
  3411. * history. Use circuit_build_times_disabled()
  3412. * rather than checking this value directly. */
  3413. int CircuitBuildTimeout; /**< Cull non-open circuits that were born at
  3414. * least this many seconds ago. Used until
  3415. * adaptive algorithm learns a new value. */
  3416. int CircuitsAvailableTimeout; /**< Try to have an open circuit for at
  3417. least this long after last activity */
  3418. int CircuitStreamTimeout; /**< If non-zero, detach streams from circuits
  3419. * and try a new circuit if the stream has been
  3420. * waiting for this many seconds. If zero, use
  3421. * our default internal timeout schedule. */
  3422. int MaxOnionQueueDelay; /*< DOCDOC */
  3423. int NewCircuitPeriod; /**< How long do we use a circuit before building
  3424. * a new one? */
  3425. int MaxCircuitDirtiness; /**< Never use circs that were first used more than
  3426. this interval ago. */
  3427. uint64_t BandwidthRate; /**< How much bandwidth, on average, are we willing
  3428. * to use in a second? */
  3429. uint64_t BandwidthBurst; /**< How much bandwidth, at maximum, are we willing
  3430. * to use in a second? */
  3431. uint64_t MaxAdvertisedBandwidth; /**< How much bandwidth are we willing to
  3432. * tell other nodes we have? */
  3433. uint64_t RelayBandwidthRate; /**< How much bandwidth, on average, are we
  3434. * willing to use for all relayed conns? */
  3435. uint64_t RelayBandwidthBurst; /**< How much bandwidth, at maximum, will we
  3436. * use in a second for all relayed conns? */
  3437. uint64_t PerConnBWRate; /**< Long-term bw on a single TLS conn, if set. */
  3438. uint64_t PerConnBWBurst; /**< Allowed burst on a single TLS conn, if set. */
  3439. int NumCPUs; /**< How many CPUs should we try to use? */
  3440. config_line_t *RendConfigLines; /**< List of configuration lines
  3441. * for rendezvous services. */
  3442. config_line_t *HidServAuth; /**< List of configuration lines for client-side
  3443. * authorizations for hidden services */
  3444. char *ContactInfo; /**< Contact info to be published in the directory. */
  3445. int HeartbeatPeriod; /**< Log heartbeat messages after this many seconds
  3446. * have passed. */
  3447. char *HTTPProxy; /**< hostname[:port] to use as http proxy, if any. */
  3448. tor_addr_t HTTPProxyAddr; /**< Parsed IPv4 addr for http proxy, if any. */
  3449. uint16_t HTTPProxyPort; /**< Parsed port for http proxy, if any. */
  3450. char *HTTPProxyAuthenticator; /**< username:password string, if any. */
  3451. char *HTTPSProxy; /**< hostname[:port] to use as https proxy, if any. */
  3452. tor_addr_t HTTPSProxyAddr; /**< Parsed addr for https proxy, if any. */
  3453. uint16_t HTTPSProxyPort; /**< Parsed port for https proxy, if any. */
  3454. char *HTTPSProxyAuthenticator; /**< username:password string, if any. */
  3455. char *Socks4Proxy; /**< hostname:port to use as a SOCKS4 proxy, if any. */
  3456. tor_addr_t Socks4ProxyAddr; /**< Derived from Socks4Proxy. */
  3457. uint16_t Socks4ProxyPort; /**< Derived from Socks4Proxy. */
  3458. char *Socks5Proxy; /**< hostname:port to use as a SOCKS5 proxy, if any. */
  3459. tor_addr_t Socks5ProxyAddr; /**< Derived from Sock5Proxy. */
  3460. uint16_t Socks5ProxyPort; /**< Derived from Socks5Proxy. */
  3461. char *Socks5ProxyUsername; /**< Username for SOCKS5 authentication, if any */
  3462. char *Socks5ProxyPassword; /**< Password for SOCKS5 authentication, if any */
  3463. /** List of configuration lines for replacement directory authorities.
  3464. * If you just want to replace one class of authority at a time,
  3465. * use the "Alternate*Authority" options below instead. */
  3466. config_line_t *DirAuthorities;
  3467. /** List of fallback directory servers */
  3468. config_line_t *FallbackDir;
  3469. /** Whether to use the default hard-coded FallbackDirs */
  3470. int UseDefaultFallbackDirs;
  3471. /** Weight to apply to all directory authority rates if considering them
  3472. * along with fallbackdirs */
  3473. double DirAuthorityFallbackRate;
  3474. /** If set, use these main (currently v3) directory authorities and
  3475. * not the default ones. */
  3476. config_line_t *AlternateDirAuthority;
  3477. /** If set, use these bridge authorities and not the default one. */
  3478. config_line_t *AlternateBridgeAuthority;
  3479. config_line_t *MyFamily_lines; /**< Declared family for this OR. */
  3480. config_line_t *MyFamily; /**< Declared family for this OR, normalized */
  3481. config_line_t *NodeFamilies; /**< List of config lines for
  3482. * node families */
  3483. smartlist_t *NodeFamilySets; /**< List of parsed NodeFamilies values. */
  3484. config_line_t *AuthDirBadExit; /**< Address policy for descriptors to
  3485. * mark as bad exits. */
  3486. config_line_t *AuthDirReject; /**< Address policy for descriptors to
  3487. * reject. */
  3488. config_line_t *AuthDirInvalid; /**< Address policy for descriptors to
  3489. * never mark as valid. */
  3490. /** @name AuthDir...CC
  3491. *
  3492. * Lists of country codes to mark as BadExit, or Invalid, or to
  3493. * reject entirely.
  3494. *
  3495. * @{
  3496. */
  3497. smartlist_t *AuthDirBadExitCCs;
  3498. smartlist_t *AuthDirInvalidCCs;
  3499. smartlist_t *AuthDirRejectCCs;
  3500. /**@}*/
  3501. int AuthDirListBadExits; /**< True iff we should list bad exits,
  3502. * and vote for all other exits as good. */
  3503. int AuthDirMaxServersPerAddr; /**< Do not permit more than this
  3504. * number of servers per IP address. */
  3505. int AuthDirHasIPv6Connectivity; /**< Boolean: are we on IPv6? */
  3506. int AuthDirPinKeys; /**< Boolean: Do we enforce key-pinning? */
  3507. /** If non-zero, always vote the Fast flag for any relay advertising
  3508. * this amount of capacity or more. */
  3509. uint64_t AuthDirFastGuarantee;
  3510. /** If non-zero, this advertised capacity or more is always sufficient
  3511. * to satisfy the bandwidth requirement for the Guard flag. */
  3512. uint64_t AuthDirGuardBWGuarantee;
  3513. char *AccountingStart; /**< How long is the accounting interval, and when
  3514. * does it start? */
  3515. uint64_t AccountingMax; /**< How many bytes do we allow per accounting
  3516. * interval before hibernation? 0 for "never
  3517. * hibernate." */
  3518. /** How do we determine when our AccountingMax has been reached?
  3519. * "max" for when in or out reaches AccountingMax
  3520. * "sum" for when in plus out reaches AccountingMax
  3521. * "in" for when in reaches AccountingMax
  3522. * "out" for when out reaches AccountingMax */
  3523. char *AccountingRule_option;
  3524. enum { ACCT_MAX, ACCT_SUM, ACCT_IN, ACCT_OUT } AccountingRule;
  3525. /** Base64-encoded hash of accepted passwords for the control system. */
  3526. config_line_t *HashedControlPassword;
  3527. /** As HashedControlPassword, but not saved. */
  3528. config_line_t *HashedControlSessionPassword;
  3529. int CookieAuthentication; /**< Boolean: do we enable cookie-based auth for
  3530. * the control system? */
  3531. char *CookieAuthFile; /**< Filesystem location of a ControlPort
  3532. * authentication cookie. */
  3533. char *ExtORPortCookieAuthFile; /**< Filesystem location of Extended
  3534. * ORPort authentication cookie. */
  3535. int CookieAuthFileGroupReadable; /**< Boolean: Is the CookieAuthFile g+r? */
  3536. int ExtORPortCookieAuthFileGroupReadable; /**< Boolean: Is the
  3537. * ExtORPortCookieAuthFile g+r? */
  3538. int LeaveStreamsUnattached; /**< Boolean: Does Tor attach new streams to
  3539. * circuits itself (0), or does it expect a controller
  3540. * to cope? (1) */
  3541. int DisablePredictedCircuits; /**< Boolean: does Tor preemptively
  3542. * make circuits in the background (0),
  3543. * or not (1)? */
  3544. /** Process specifier for a controller that ‘owns’ this Tor
  3545. * instance. Tor will terminate if its owning controller does. */
  3546. char *OwningControllerProcess;
  3547. int ShutdownWaitLength; /**< When we get a SIGINT and we're a server, how
  3548. * long do we wait before exiting? */
  3549. char *SafeLogging; /**< Contains "relay", "1", "0" (meaning no scrubbing). */
  3550. /* Derived from SafeLogging */
  3551. enum {
  3552. SAFELOG_SCRUB_ALL, SAFELOG_SCRUB_RELAY, SAFELOG_SCRUB_NONE
  3553. } SafeLogging_;
  3554. int Sandbox; /**< Boolean: should sandboxing be enabled? */
  3555. int SafeSocks; /**< Boolean: should we outright refuse application
  3556. * connections that use socks4 or socks5-with-local-dns? */
  3557. #define LOG_PROTOCOL_WARN (get_options()->ProtocolWarnings ? \
  3558. LOG_WARN : LOG_INFO)
  3559. int ProtocolWarnings; /**< Boolean: when other parties screw up the Tor
  3560. * protocol, is it a warn or an info in our logs? */
  3561. int TestSocks; /**< Boolean: when we get a socks connection, do we loudly
  3562. * log whether it was DNS-leaking or not? */
  3563. int HardwareAccel; /**< Boolean: Should we enable OpenSSL hardware
  3564. * acceleration where available? */
  3565. /** Token Bucket Refill resolution in milliseconds. */
  3566. int TokenBucketRefillInterval;
  3567. char *AccelName; /**< Optional hardware acceleration engine name. */
  3568. char *AccelDir; /**< Optional hardware acceleration engine search dir. */
  3569. /** Boolean: Do we try to enter from a smallish number
  3570. * of fixed nodes? */
  3571. int UseEntryGuards_option;
  3572. /** Internal variable to remember whether we're actually acting on
  3573. * UseEntryGuards_option -- when we're a non-anonymous Tor2web client or
  3574. * Single Onion Service, it is alwasy false, otherwise we use the value of
  3575. * UseEntryGuards_option. */
  3576. int UseEntryGuards;
  3577. int NumEntryGuards; /**< How many entry guards do we try to establish? */
  3578. /** If 1, we use any guardfraction information we see in the
  3579. * consensus. If 0, we don't. If -1, let the consensus parameter
  3580. * decide. */
  3581. int UseGuardFraction;
  3582. int NumDirectoryGuards; /**< How many dir guards do we try to establish?
  3583. * If 0, use value from NumEntryGuards. */
  3584. int RephistTrackTime; /**< How many seconds do we keep rephist info? */
  3585. /** Should we always fetch our dir info on the mirror schedule (which
  3586. * means directly from the authorities) no matter our other config? */
  3587. int FetchDirInfoEarly;
  3588. /** Should we fetch our dir info at the start of the consensus period? */
  3589. int FetchDirInfoExtraEarly;
  3590. int DirCache; /**< Cache all directory documents and accept requests via
  3591. * tunnelled dir conns from clients. If 1, enabled (default);
  3592. * If 0, disabled. */
  3593. char *VirtualAddrNetworkIPv4; /**< Address and mask to hand out for virtual
  3594. * MAPADDRESS requests for IPv4 addresses */
  3595. char *VirtualAddrNetworkIPv6; /**< Address and mask to hand out for virtual
  3596. * MAPADDRESS requests for IPv6 addresses */
  3597. int ServerDNSSearchDomains; /**< Boolean: If set, we don't force exit
  3598. * addresses to be FQDNs, but rather search for them in
  3599. * the local domains. */
  3600. int ServerDNSDetectHijacking; /**< Boolean: If true, check for DNS failure
  3601. * hijacking. */
  3602. int ServerDNSRandomizeCase; /**< Boolean: Use the 0x20-hack to prevent
  3603. * DNS poisoning attacks. */
  3604. char *ServerDNSResolvConfFile; /**< If provided, we configure our internal
  3605. * resolver from the file here rather than from
  3606. * /etc/resolv.conf (Unix) or the registry (Windows). */
  3607. char *DirPortFrontPage; /**< This is a full path to a file with an html
  3608. disclaimer. This allows a server administrator to show
  3609. that they're running Tor and anyone visiting their server
  3610. will know this without any specialized knowledge. */
  3611. int DisableDebuggerAttachment; /**< Currently Linux only specific attempt to
  3612. disable ptrace; needs BSD testing. */
  3613. /** Boolean: if set, we start even if our resolv.conf file is missing
  3614. * or broken. */
  3615. int ServerDNSAllowBrokenConfig;
  3616. /** Boolean: if set, then even connections to private addresses will get
  3617. * rate-limited. */
  3618. int CountPrivateBandwidth;
  3619. smartlist_t *ServerDNSTestAddresses; /**< A list of addresses that definitely
  3620. * should be resolvable. Used for
  3621. * testing our DNS server. */
  3622. int EnforceDistinctSubnets; /**< If true, don't allow multiple routers in the
  3623. * same network zone in the same circuit. */
  3624. int PortForwarding; /**< If true, use NAT-PMP or UPnP to automatically
  3625. * forward the DirPort and ORPort on the NAT device */
  3626. char *PortForwardingHelper; /** < Filename or full path of the port
  3627. forwarding helper executable */
  3628. int AllowNonRFC953Hostnames; /**< If true, we allow connections to hostnames
  3629. * with weird characters. */
  3630. /** If true, we try resolving hostnames with weird characters. */
  3631. int ServerDNSAllowNonRFC953Hostnames;
  3632. /** If true, we try to download extra-info documents (and we serve them,
  3633. * if we are a cache). For authorities, this is always true. */
  3634. int DownloadExtraInfo;
  3635. /** If true, we convert "www.google.com.foo.exit" addresses on the
  3636. * socks/trans/natd ports into "www.google.com" addresses that
  3637. * exit from the node "foo". Disabled by default since attacking
  3638. * websites and exit relays can use it to manipulate your path
  3639. * selection. */
  3640. int AllowDotExit;
  3641. /** If true, we're configured to collect statistics on clients
  3642. * requesting network statuses from us as directory. */
  3643. int DirReqStatistics_option;
  3644. /** Internal variable to remember whether we're actually acting on
  3645. * DirReqStatistics_option -- yes if it's set and we're a server, else no. */
  3646. int DirReqStatistics;
  3647. /** If true, the user wants us to collect statistics on port usage. */
  3648. int ExitPortStatistics;
  3649. /** If true, the user wants us to collect connection statistics. */
  3650. int ConnDirectionStatistics;
  3651. /** If true, the user wants us to collect cell statistics. */
  3652. int CellStatistics;
  3653. /** If true, the user wants us to collect padding statistics. */
  3654. int PaddingStatistics;
  3655. /** If true, the user wants us to collect statistics as entry node. */
  3656. int EntryStatistics;
  3657. /** If true, the user wants us to collect statistics as hidden service
  3658. * directory, introduction point, or rendezvous point. */
  3659. int HiddenServiceStatistics_option;
  3660. /** Internal variable to remember whether we're actually acting on
  3661. * HiddenServiceStatistics_option -- yes if it's set and we're a server,
  3662. * else no. */
  3663. int HiddenServiceStatistics;
  3664. /** If true, include statistics file contents in extra-info documents. */
  3665. int ExtraInfoStatistics;
  3666. /** If true, do not believe anybody who tells us that a domain resolves
  3667. * to an internal address, or that an internal address has a PTR mapping.
  3668. * Helps avoid some cross-site attacks. */
  3669. int ClientDNSRejectInternalAddresses;
  3670. /** If true, do not accept any requests to connect to internal addresses
  3671. * over randomly chosen exits. */
  3672. int ClientRejectInternalAddresses;
  3673. /** If true, clients may connect over IPv4. If false, they will avoid
  3674. * connecting over IPv4. We enforce this for OR and Dir connections. */
  3675. int ClientUseIPv4;
  3676. /** If true, clients may connect over IPv6. If false, they will avoid
  3677. * connecting over IPv4. We enforce this for OR and Dir connections.
  3678. * Use fascist_firewall_use_ipv6() instead of accessing this value
  3679. * directly. */
  3680. int ClientUseIPv6;
  3681. /** If true, prefer an IPv6 OR port over an IPv4 one for entry node
  3682. * connections. If auto, bridge clients prefer IPv6, and other clients
  3683. * prefer IPv4. Use node_ipv6_or_preferred() instead of accessing this value
  3684. * directly. */
  3685. int ClientPreferIPv6ORPort;
  3686. /** If true, prefer an IPv6 directory port over an IPv4 one for direct
  3687. * directory connections. If auto, bridge clients prefer IPv6, and other
  3688. * clients prefer IPv4. Use fascist_firewall_prefer_ipv6_dirport() instead of
  3689. * accessing this value directly. */
  3690. int ClientPreferIPv6DirPort;
  3691. /** The length of time that we think a consensus should be fresh. */
  3692. int V3AuthVotingInterval;
  3693. /** The length of time we think it will take to distribute votes. */
  3694. int V3AuthVoteDelay;
  3695. /** The length of time we think it will take to distribute signatures. */
  3696. int V3AuthDistDelay;
  3697. /** The number of intervals we think a consensus should be valid. */
  3698. int V3AuthNIntervalsValid;
  3699. /** Should advertise and sign consensuses with a legacy key, for key
  3700. * migration purposes? */
  3701. int V3AuthUseLegacyKey;
  3702. /** Location of bandwidth measurement file */
  3703. char *V3BandwidthsFile;
  3704. /** Location of guardfraction file */
  3705. char *GuardfractionFile;
  3706. /** Authority only: key=value pairs that we add to our networkstatus
  3707. * consensus vote on the 'params' line. */
  3708. char *ConsensusParams;
  3709. /** Authority only: minimum number of measured bandwidths we must see
  3710. * before we only believe measured bandwidths to assign flags. */
  3711. int MinMeasuredBWsForAuthToIgnoreAdvertised;
  3712. /** The length of time that we think an initial consensus should be fresh.
  3713. * Only altered on testing networks. */
  3714. int TestingV3AuthInitialVotingInterval;
  3715. /** The length of time we think it will take to distribute initial votes.
  3716. * Only altered on testing networks. */
  3717. int TestingV3AuthInitialVoteDelay;
  3718. /** The length of time we think it will take to distribute initial
  3719. * signatures. Only altered on testing networks.*/
  3720. int TestingV3AuthInitialDistDelay;
  3721. /** Offset in seconds added to the starting time for consensus
  3722. voting. Only altered on testing networks. */
  3723. int TestingV3AuthVotingStartOffset;
  3724. /** If an authority has been around for less than this amount of time, it
  3725. * does not believe its reachability information is accurate. Only
  3726. * altered on testing networks. */
  3727. int TestingAuthDirTimeToLearnReachability;
  3728. /** Clients don't download any descriptor this recent, since it will
  3729. * probably not have propagated to enough caches. Only altered on testing
  3730. * networks. */
  3731. int TestingEstimatedDescriptorPropagationTime;
  3732. /** Schedule for when servers should download things in general. Only
  3733. * altered on testing networks. */
  3734. smartlist_t *TestingServerDownloadSchedule;
  3735. /** Schedule for when clients should download things in general. Only
  3736. * altered on testing networks. */
  3737. smartlist_t *TestingClientDownloadSchedule;
  3738. /** Schedule for when servers should download consensuses. Only altered
  3739. * on testing networks. */
  3740. smartlist_t *TestingServerConsensusDownloadSchedule;
  3741. /** Schedule for when clients should download consensuses. Only altered
  3742. * on testing networks. */
  3743. smartlist_t *TestingClientConsensusDownloadSchedule;
  3744. /** Schedule for when clients should download consensuses from authorities
  3745. * if they are bootstrapping (that is, they don't have a usable, reasonably
  3746. * live consensus). Only used by clients fetching from a list of fallback
  3747. * directory mirrors.
  3748. *
  3749. * This schedule is incremented by (potentially concurrent) connection
  3750. * attempts, unlike other schedules, which are incremented by connection
  3751. * failures. Only altered on testing networks. */
  3752. smartlist_t *ClientBootstrapConsensusAuthorityDownloadSchedule;
  3753. /** Schedule for when clients should download consensuses from fallback
  3754. * directory mirrors if they are bootstrapping (that is, they don't have a
  3755. * usable, reasonably live consensus). Only used by clients fetching from a
  3756. * list of fallback directory mirrors.
  3757. *
  3758. * This schedule is incremented by (potentially concurrent) connection
  3759. * attempts, unlike other schedules, which are incremented by connection
  3760. * failures. Only altered on testing networks. */
  3761. smartlist_t *ClientBootstrapConsensusFallbackDownloadSchedule;
  3762. /** Schedule for when clients should download consensuses from authorities
  3763. * if they are bootstrapping (that is, they don't have a usable, reasonably
  3764. * live consensus). Only used by clients which don't have or won't fetch
  3765. * from a list of fallback directory mirrors.
  3766. *
  3767. * This schedule is incremented by (potentially concurrent) connection
  3768. * attempts, unlike other schedules, which are incremented by connection
  3769. * failures. Only altered on testing networks. */
  3770. smartlist_t *ClientBootstrapConsensusAuthorityOnlyDownloadSchedule;
  3771. /** Schedule for when clients should download bridge descriptors. Only
  3772. * altered on testing networks. */
  3773. smartlist_t *TestingBridgeDownloadSchedule;
  3774. /** When directory clients have only a few descriptors to request, they
  3775. * batch them until they have more, or until this amount of time has
  3776. * passed. Only altered on testing networks. */
  3777. int TestingClientMaxIntervalWithoutRequest;
  3778. /** How long do we let a directory connection stall before expiring
  3779. * it? Only altered on testing networks. */
  3780. int TestingDirConnectionMaxStall;
  3781. /** How many times will we try to fetch a consensus before we give
  3782. * up? Only altered on testing networks. */
  3783. int TestingConsensusMaxDownloadTries;
  3784. /** How many times will a client try to fetch a consensus while
  3785. * bootstrapping using a list of fallback directories, before it gives up?
  3786. * Only altered on testing networks. */
  3787. int ClientBootstrapConsensusMaxDownloadTries;
  3788. /** How many times will a client try to fetch a consensus while
  3789. * bootstrapping using only a list of authorities, before it gives up?
  3790. * Only altered on testing networks. */
  3791. int ClientBootstrapConsensusAuthorityOnlyMaxDownloadTries;
  3792. /** How many simultaneous in-progress connections will we make when trying
  3793. * to fetch a consensus before we wait for one to complete, timeout, or
  3794. * error out? Only altered on testing networks. */
  3795. int ClientBootstrapConsensusMaxInProgressTries;
  3796. /** How many times will we try to download a router's descriptor before
  3797. * giving up? Only altered on testing networks. */
  3798. int TestingDescriptorMaxDownloadTries;
  3799. /** How many times will we try to download a microdescriptor before
  3800. * giving up? Only altered on testing networks. */
  3801. int TestingMicrodescMaxDownloadTries;
  3802. /** How many times will we try to fetch a certificate before giving
  3803. * up? Only altered on testing networks. */
  3804. int TestingCertMaxDownloadTries;
  3805. /** If true, we take part in a testing network. Change the defaults of a
  3806. * couple of other configuration options and allow to change the values
  3807. * of certain configuration options. */
  3808. int TestingTorNetwork;
  3809. /** Minimum value for the Exit flag threshold on testing networks. */
  3810. uint64_t TestingMinExitFlagThreshold;
  3811. /** Minimum value for the Fast flag threshold on testing networks. */
  3812. uint64_t TestingMinFastFlagThreshold;
  3813. /** Relays in a testing network which should be voted Exit
  3814. * regardless of exit policy. */
  3815. routerset_t *TestingDirAuthVoteExit;
  3816. int TestingDirAuthVoteExitIsStrict;
  3817. /** Relays in a testing network which should be voted Guard
  3818. * regardless of uptime and bandwidth. */
  3819. routerset_t *TestingDirAuthVoteGuard;
  3820. int TestingDirAuthVoteGuardIsStrict;
  3821. /** Relays in a testing network which should be voted HSDir
  3822. * regardless of uptime and DirPort. */
  3823. routerset_t *TestingDirAuthVoteHSDir;
  3824. int TestingDirAuthVoteHSDirIsStrict;
  3825. /** Enable CONN_BW events. Only altered on testing networks. */
  3826. int TestingEnableConnBwEvent;
  3827. /** Enable CELL_STATS events. Only altered on testing networks. */
  3828. int TestingEnableCellStatsEvent;
  3829. /** Enable TB_EMPTY events. Only altered on testing networks. */
  3830. int TestingEnableTbEmptyEvent;
  3831. /** If true, and we have GeoIP data, and we're a bridge, keep a per-country
  3832. * count of how many client addresses have contacted us so that we can help
  3833. * the bridge authority guess which countries have blocked access to us. */
  3834. int BridgeRecordUsageByCountry;
  3835. /** Optionally, IPv4 and IPv6 GeoIP data. */
  3836. char *GeoIPFile;
  3837. char *GeoIPv6File;
  3838. /** Autobool: if auto, then any attempt to Exclude{Exit,}Nodes a particular
  3839. * country code will exclude all nodes in ?? and A1. If true, all nodes in
  3840. * ?? and A1 are excluded. Has no effect if we don't know any GeoIP data. */
  3841. int GeoIPExcludeUnknown;
  3842. /** If true, SIGHUP should reload the torrc. Sometimes controllers want
  3843. * to make this false. */
  3844. int ReloadTorrcOnSIGHUP;
  3845. /* The main parameter for picking circuits within a connection.
  3846. *
  3847. * If this value is positive, when picking a cell to relay on a connection,
  3848. * we always relay from the circuit whose weighted cell count is lowest.
  3849. * Cells are weighted exponentially such that if one cell is sent
  3850. * 'CircuitPriorityHalflife' seconds before another, it counts for half as
  3851. * much.
  3852. *
  3853. * If this value is zero, we're disabling the cell-EWMA algorithm.
  3854. *
  3855. * If this value is negative, we're using the default approach
  3856. * according to either Tor or a parameter set in the consensus.
  3857. */
  3858. double CircuitPriorityHalflife;
  3859. /** Set to true if the TestingTorNetwork configuration option is set.
  3860. * This is used so that options_validate() has a chance to realize that
  3861. * the defaults have changed. */
  3862. int UsingTestNetworkDefaults_;
  3863. /** If 1, we try to use microdescriptors to build circuits. If 0, we don't.
  3864. * If -1, Tor decides. */
  3865. int UseMicrodescriptors;
  3866. /** File where we should write the ControlPort. */
  3867. char *ControlPortWriteToFile;
  3868. /** Should that file be group-readable? */
  3869. int ControlPortFileGroupReadable;
  3870. #define MAX_MAX_CLIENT_CIRCUITS_PENDING 1024
  3871. /** Maximum number of non-open general-purpose origin circuits to allow at
  3872. * once. */
  3873. int MaxClientCircuitsPending;
  3874. /** If 1, we always send optimistic data when it's supported. If 0, we
  3875. * never use it. If -1, we do what the consensus says. */
  3876. int OptimisticData;
  3877. /** If 1, we accept and launch no external network connections, except on
  3878. * control ports. */
  3879. int DisableNetwork;
  3880. /**
  3881. * Parameters for path-bias detection.
  3882. * @{
  3883. * These options override the default behavior of Tor's (**currently
  3884. * experimental**) path bias detection algorithm. To try to find broken or
  3885. * misbehaving guard nodes, Tor looks for nodes where more than a certain
  3886. * fraction of circuits through that guard fail to get built.
  3887. *
  3888. * The PathBiasCircThreshold option controls how many circuits we need to
  3889. * build through a guard before we make these checks. The
  3890. * PathBiasNoticeRate, PathBiasWarnRate and PathBiasExtremeRate options
  3891. * control what fraction of circuits must succeed through a guard so we
  3892. * won't write log messages. If less than PathBiasExtremeRate circuits
  3893. * succeed *and* PathBiasDropGuards is set to 1, we disable use of that
  3894. * guard.
  3895. *
  3896. * When we have seen more than PathBiasScaleThreshold circuits through a
  3897. * guard, we scale our observations by 0.5 (governed by the consensus) so
  3898. * that new observations don't get swamped by old ones.
  3899. *
  3900. * By default, or if a negative value is provided for one of these options,
  3901. * Tor uses reasonable defaults from the networkstatus consensus document.
  3902. * If no defaults are available there, these options default to 150, .70,
  3903. * .50, .30, 0, and 300 respectively.
  3904. */
  3905. int PathBiasCircThreshold;
  3906. double PathBiasNoticeRate;
  3907. double PathBiasWarnRate;
  3908. double PathBiasExtremeRate;
  3909. int PathBiasDropGuards;
  3910. int PathBiasScaleThreshold;
  3911. /** @} */
  3912. /**
  3913. * Parameters for path-bias use detection
  3914. * @{
  3915. * Similar to the above options, these options override the default behavior
  3916. * of Tor's (**currently experimental**) path use bias detection algorithm.
  3917. *
  3918. * Where as the path bias parameters govern thresholds for successfully
  3919. * building circuits, these four path use bias parameters govern thresholds
  3920. * only for circuit usage. Circuits which receive no stream usage are not
  3921. * counted by this detection algorithm. A used circuit is considered
  3922. * successful if it is capable of carrying streams or otherwise receiving
  3923. * well-formed responses to RELAY cells.
  3924. *
  3925. * By default, or if a negative value is provided for one of these options,
  3926. * Tor uses reasonable defaults from the networkstatus consensus document.
  3927. * If no defaults are available there, these options default to 20, .80,
  3928. * .60, and 100, respectively.
  3929. */
  3930. int PathBiasUseThreshold;
  3931. double PathBiasNoticeUseRate;
  3932. double PathBiasExtremeUseRate;
  3933. int PathBiasScaleUseThreshold;
  3934. /** @} */
  3935. int IPv6Exit; /**< Do we support exiting to IPv6 addresses? */
  3936. /** Fraction: */
  3937. double PathsNeededToBuildCircuits;
  3938. /** What expiry time shall we place on our SSL certs? "0" means we
  3939. * should guess a suitable value. */
  3940. int SSLKeyLifetime;
  3941. /** How long (seconds) do we keep a guard before picking a new one? */
  3942. int GuardLifetime;
  3943. /** Low-water mark for global scheduler - start sending when estimated
  3944. * queued size falls below this threshold.
  3945. */
  3946. uint64_t SchedulerLowWaterMark__;
  3947. /** High-water mark for global scheduler - stop sending when estimated
  3948. * queued size exceeds this threshold.
  3949. */
  3950. uint64_t SchedulerHighWaterMark__;
  3951. /** Flush size for global scheduler - flush this many cells at a time
  3952. * when sending.
  3953. */
  3954. int SchedulerMaxFlushCells__;
  3955. /** Is this an exit node? This is a tristate, where "1" means "yes, and use
  3956. * the default exit policy if none is given" and "0" means "no; exit policy
  3957. * is 'reject *'" and "auto" (-1) means "same as 1, but warn the user."
  3958. *
  3959. * XXXX Eventually, the default will be 0. */
  3960. int ExitRelay;
  3961. /** For how long (seconds) do we declare our signing keys to be valid? */
  3962. int SigningKeyLifetime;
  3963. /** For how long (seconds) do we declare our link keys to be valid? */
  3964. int TestingLinkCertLifetime;
  3965. /** For how long (seconds) do we declare our auth keys to be valid? */
  3966. int TestingAuthKeyLifetime;
  3967. /** How long before signing keys expire will we try to make a new one? */
  3968. int TestingSigningKeySlop;
  3969. /** How long before link keys expire will we try to make a new one? */
  3970. int TestingLinkKeySlop;
  3971. /** How long before auth keys expire will we try to make a new one? */
  3972. int TestingAuthKeySlop;
  3973. /** Force use of offline master key features: never generate a master
  3974. * ed25519 identity key except from tor --keygen */
  3975. int OfflineMasterKey;
  3976. enum {
  3977. FORCE_PASSPHRASE_AUTO=0,
  3978. FORCE_PASSPHRASE_ON,
  3979. FORCE_PASSPHRASE_OFF
  3980. } keygen_force_passphrase;
  3981. int use_keygen_passphrase_fd;
  3982. int keygen_passphrase_fd;
  3983. int change_key_passphrase;
  3984. char *master_key_fname;
  3985. /** Autobool: Do we try to retain capabilities if we can? */
  3986. int KeepBindCapabilities;
  3987. /** Maximum total size of unparseable descriptors to log during the
  3988. * lifetime of this Tor process.
  3989. */
  3990. uint64_t MaxUnparseableDescSizeToLog;
  3991. /** Bool (default: 1): Switch for the shared random protocol. Only
  3992. * relevant to a directory authority. If off, the authority won't
  3993. * participate in the protocol. If on (default), a flag is added to the
  3994. * vote indicating participation. */
  3995. int AuthDirSharedRandomness;
  3996. /** If 1, we skip all OOS checks. */
  3997. int DisableOOSCheck;
  3998. /** Autobool: Should we include Ed25519 identities in extend2 cells?
  3999. * If -1, we should do whatever the consensus parameter says. */
  4000. int ExtendByEd25519ID;
  4001. /** Bool (default: 1): When testing routerinfos as a directory authority,
  4002. * do we enforce Ed25519 identity match? */
  4003. /* NOTE: remove this option someday. */
  4004. int AuthDirTestEd25519LinkKeys;
  4005. /** Bool (default: 0): Tells if a %include was used on torrc */
  4006. int IncludeUsed;
  4007. /** The seconds after expiration which we as a relay should keep old
  4008. * consensuses around so that we can generate diffs from them. If 0,
  4009. * use the default. */
  4010. int MaxConsensusAgeForDiffs;
  4011. } or_options_t;
  4012. /** Persistent state for an onion router, as saved to disk. */
  4013. typedef struct {
  4014. uint32_t magic_;
  4015. /** The time at which we next plan to write the state to the disk. Equal to
  4016. * TIME_MAX if there are no savable changes, 0 if there are changes that
  4017. * should be saved right away. */
  4018. time_t next_write;
  4019. /** When was the state last written to disk? */
  4020. time_t LastWritten;
  4021. /** Fields for accounting bandwidth use. */
  4022. time_t AccountingIntervalStart;
  4023. uint64_t AccountingBytesReadInInterval;
  4024. uint64_t AccountingBytesWrittenInInterval;
  4025. int AccountingSecondsActive;
  4026. int AccountingSecondsToReachSoftLimit;
  4027. time_t AccountingSoftLimitHitAt;
  4028. uint64_t AccountingBytesAtSoftLimit;
  4029. uint64_t AccountingExpectedUsage;
  4030. /** A list of Entry Guard-related configuration lines. (pre-prop271) */
  4031. config_line_t *EntryGuards;
  4032. /** A list of guard-related configuration lines. (post-prop271) */
  4033. config_line_t *Guard;
  4034. config_line_t *TransportProxies;
  4035. /** Cached revision counters for active hidden services on this host */
  4036. config_line_t *HidServRevCounter;
  4037. /** These fields hold information on the history of bandwidth usage for
  4038. * servers. The "Ends" fields hold the time when we last updated the
  4039. * bandwidth usage. The "Interval" fields hold the granularity, in seconds,
  4040. * of the entries of Values. The "Values" lists hold decimal string
  4041. * representations of the number of bytes read or written in each
  4042. * interval. The "Maxima" list holds decimal strings describing the highest
  4043. * rate achieved during the interval.
  4044. */
  4045. time_t BWHistoryReadEnds;
  4046. int BWHistoryReadInterval;
  4047. smartlist_t *BWHistoryReadValues;
  4048. smartlist_t *BWHistoryReadMaxima;
  4049. time_t BWHistoryWriteEnds;
  4050. int BWHistoryWriteInterval;
  4051. smartlist_t *BWHistoryWriteValues;
  4052. smartlist_t *BWHistoryWriteMaxima;
  4053. time_t BWHistoryDirReadEnds;
  4054. int BWHistoryDirReadInterval;
  4055. smartlist_t *BWHistoryDirReadValues;
  4056. smartlist_t *BWHistoryDirReadMaxima;
  4057. time_t BWHistoryDirWriteEnds;
  4058. int BWHistoryDirWriteInterval;
  4059. smartlist_t *BWHistoryDirWriteValues;
  4060. smartlist_t *BWHistoryDirWriteMaxima;
  4061. /** Build time histogram */
  4062. config_line_t * BuildtimeHistogram;
  4063. unsigned int TotalBuildTimes;
  4064. unsigned int CircuitBuildAbandonedCount;
  4065. /** What version of Tor wrote this state file? */
  4066. char *TorVersion;
  4067. /** Holds any unrecognized values we found in the state file, in the order
  4068. * in which we found them. */
  4069. config_line_t *ExtraLines;
  4070. /** When did we last rotate our onion key? "0" for 'no idea'. */
  4071. time_t LastRotatedOnionKey;
  4072. } or_state_t;
  4073. /** Change the next_write time of <b>state</b> to <b>when</b>, unless the
  4074. * state is already scheduled to be written to disk earlier than <b>when</b>.
  4075. */
  4076. static inline void or_state_mark_dirty(or_state_t *state, time_t when)
  4077. {
  4078. if (state->next_write > when)
  4079. state->next_write = when;
  4080. }
  4081. #define MAX_SOCKS_REPLY_LEN 1024
  4082. #define MAX_SOCKS_ADDR_LEN 256
  4083. #define SOCKS_NO_AUTH 0x00
  4084. #define SOCKS_USER_PASS 0x02
  4085. /** Please open a TCP connection to this addr:port. */
  4086. #define SOCKS_COMMAND_CONNECT 0x01
  4087. /** Please turn this FQDN into an IP address, privately. */
  4088. #define SOCKS_COMMAND_RESOLVE 0xF0
  4089. /** Please turn this IP address into an FQDN, privately. */
  4090. #define SOCKS_COMMAND_RESOLVE_PTR 0xF1
  4091. /* || 0 is for -Wparentheses-equality (-Wall?) appeasement under clang */
  4092. #define SOCKS_COMMAND_IS_CONNECT(c) (((c)==SOCKS_COMMAND_CONNECT) || 0)
  4093. #define SOCKS_COMMAND_IS_RESOLVE(c) ((c)==SOCKS_COMMAND_RESOLVE || \
  4094. (c)==SOCKS_COMMAND_RESOLVE_PTR)
  4095. /** State of a SOCKS request from a user to an OP. Also used to encode other
  4096. * information for non-socks user request (such as those on TransPort and
  4097. * DNSPort) */
  4098. struct socks_request_t {
  4099. /** Which version of SOCKS did the client use? One of "0, 4, 5" -- where
  4100. * 0 means that no socks handshake ever took place, and this is just a
  4101. * stub connection (e.g. see connection_ap_make_link()). */
  4102. uint8_t socks_version;
  4103. /** If using socks5 authentication, which authentication type did we
  4104. * negotiate? currently we support 0 (no authentication) and 2
  4105. * (username/password). */
  4106. uint8_t auth_type;
  4107. /** What is this stream's goal? One of the SOCKS_COMMAND_* values */
  4108. uint8_t command;
  4109. /** Which kind of listener created this stream? */
  4110. uint8_t listener_type;
  4111. size_t replylen; /**< Length of <b>reply</b>. */
  4112. uint8_t reply[MAX_SOCKS_REPLY_LEN]; /**< Write an entry into this string if
  4113. * we want to specify our own socks reply,
  4114. * rather than using the default socks4 or
  4115. * socks5 socks reply. We use this for the
  4116. * two-stage socks5 handshake.
  4117. */
  4118. char address[MAX_SOCKS_ADDR_LEN]; /**< What address did the client ask to
  4119. connect to/resolve? */
  4120. uint16_t port; /**< What port did the client ask to connect to? */
  4121. unsigned int has_finished : 1; /**< Has the SOCKS handshake finished? Used to
  4122. * make sure we send back a socks reply for
  4123. * every connection. */
  4124. unsigned int got_auth : 1; /**< Have we received any authentication data? */
  4125. /** If this is set, we will choose "no authentication" instead of
  4126. * "username/password" authentication if both are offered. Used as input to
  4127. * parse_socks. */
  4128. unsigned int socks_prefer_no_auth : 1;
  4129. /** Number of bytes in username; 0 if username is NULL */
  4130. size_t usernamelen;
  4131. /** Number of bytes in password; 0 if password is NULL */
  4132. uint8_t passwordlen;
  4133. /** The negotiated username value if any (for socks5), or the entire
  4134. * authentication string (for socks4). This value is NOT nul-terminated;
  4135. * see usernamelen for its length. */
  4136. char *username;
  4137. /** The negotiated password value if any (for socks5). This value is NOT
  4138. * nul-terminated; see passwordlen for its length. */
  4139. char *password;
  4140. };
  4141. /********************************* circuitbuild.c **********************/
  4142. /** How many hops does a general-purpose circuit have by default? */
  4143. #define DEFAULT_ROUTE_LEN 3
  4144. /* Circuit Build Timeout "public" structures. */
  4145. /** Precision multiplier for the Bw weights */
  4146. #define BW_WEIGHT_SCALE 10000
  4147. #define BW_MIN_WEIGHT_SCALE 1
  4148. #define BW_MAX_WEIGHT_SCALE INT32_MAX
  4149. /** Total size of the circuit timeout history to accumulate.
  4150. * 1000 is approx 2.5 days worth of continual-use circuits. */
  4151. #define CBT_NCIRCUITS_TO_OBSERVE 1000
  4152. /** Width of the histogram bins in milliseconds */
  4153. #define CBT_BIN_WIDTH ((build_time_t)50)
  4154. /** Number of modes to use in the weighted-avg computation of Xm */
  4155. #define CBT_DEFAULT_NUM_XM_MODES 3
  4156. #define CBT_MIN_NUM_XM_MODES 1
  4157. #define CBT_MAX_NUM_XM_MODES 20
  4158. /** A build_time_t is milliseconds */
  4159. typedef uint32_t build_time_t;
  4160. /**
  4161. * CBT_BUILD_ABANDONED is our flag value to represent a force-closed
  4162. * circuit (Aka a 'right-censored' pareto value).
  4163. */
  4164. #define CBT_BUILD_ABANDONED ((build_time_t)(INT32_MAX-1))
  4165. #define CBT_BUILD_TIME_MAX ((build_time_t)(INT32_MAX))
  4166. /** Save state every 10 circuits */
  4167. #define CBT_SAVE_STATE_EVERY 10
  4168. /* Circuit build times consensus parameters */
  4169. /**
  4170. * How long to wait before actually closing circuits that take too long to
  4171. * build in terms of CDF quantile.
  4172. */
  4173. #define CBT_DEFAULT_CLOSE_QUANTILE 95
  4174. #define CBT_MIN_CLOSE_QUANTILE CBT_MIN_QUANTILE_CUTOFF
  4175. #define CBT_MAX_CLOSE_QUANTILE CBT_MAX_QUANTILE_CUTOFF
  4176. /**
  4177. * How many circuits count as recent when considering if the
  4178. * connection has gone gimpy or changed.
  4179. */
  4180. #define CBT_DEFAULT_RECENT_CIRCUITS 20
  4181. #define CBT_MIN_RECENT_CIRCUITS 3
  4182. #define CBT_MAX_RECENT_CIRCUITS 1000
  4183. /**
  4184. * Maximum count of timeouts that finish the first hop in the past
  4185. * RECENT_CIRCUITS before calculating a new timeout.
  4186. *
  4187. * This tells us whether to abandon timeout history and set
  4188. * the timeout back to whatever circuit_build_times_get_initial_timeout()
  4189. * gives us.
  4190. */
  4191. #define CBT_DEFAULT_MAX_RECENT_TIMEOUT_COUNT (CBT_DEFAULT_RECENT_CIRCUITS*9/10)
  4192. #define CBT_MIN_MAX_RECENT_TIMEOUT_COUNT 3
  4193. #define CBT_MAX_MAX_RECENT_TIMEOUT_COUNT 10000
  4194. /** Minimum circuits before estimating a timeout */
  4195. #define CBT_DEFAULT_MIN_CIRCUITS_TO_OBSERVE 100
  4196. #define CBT_MIN_MIN_CIRCUITS_TO_OBSERVE 1
  4197. #define CBT_MAX_MIN_CIRCUITS_TO_OBSERVE 10000
  4198. /** Cutoff percentile on the CDF for our timeout estimation. */
  4199. #define CBT_DEFAULT_QUANTILE_CUTOFF 80
  4200. #define CBT_MIN_QUANTILE_CUTOFF 10
  4201. #define CBT_MAX_QUANTILE_CUTOFF 99
  4202. double circuit_build_times_quantile_cutoff(void);
  4203. /** How often in seconds should we build a test circuit */
  4204. #define CBT_DEFAULT_TEST_FREQUENCY 10
  4205. #define CBT_MIN_TEST_FREQUENCY 1
  4206. #define CBT_MAX_TEST_FREQUENCY INT32_MAX
  4207. /** Lowest allowable value for CircuitBuildTimeout in milliseconds */
  4208. #define CBT_DEFAULT_TIMEOUT_MIN_VALUE (1500)
  4209. #define CBT_MIN_TIMEOUT_MIN_VALUE 500
  4210. #define CBT_MAX_TIMEOUT_MIN_VALUE INT32_MAX
  4211. /** Initial circuit build timeout in milliseconds */
  4212. #define CBT_DEFAULT_TIMEOUT_INITIAL_VALUE (60*1000)
  4213. #define CBT_MIN_TIMEOUT_INITIAL_VALUE CBT_MIN_TIMEOUT_MIN_VALUE
  4214. #define CBT_MAX_TIMEOUT_INITIAL_VALUE INT32_MAX
  4215. int32_t circuit_build_times_initial_timeout(void);
  4216. #if CBT_DEFAULT_MAX_RECENT_TIMEOUT_COUNT < CBT_MIN_MAX_RECENT_TIMEOUT_COUNT
  4217. #error "RECENT_CIRCUITS is set too low."
  4218. #endif
  4219. /** Information about the state of our local network connection */
  4220. typedef struct {
  4221. /** The timestamp we last completed a TLS handshake or received a cell */
  4222. time_t network_last_live;
  4223. /** If the network is not live, how many timeouts has this caused? */
  4224. int nonlive_timeouts;
  4225. /** Circular array of circuits that have made it to the first hop. Slot is
  4226. * 1 if circuit timed out, 0 if circuit succeeded */
  4227. int8_t *timeouts_after_firsthop;
  4228. /** Number of elements allocated for the above array */
  4229. int num_recent_circs;
  4230. /** Index into circular array. */
  4231. int after_firsthop_idx;
  4232. } network_liveness_t;
  4233. typedef struct circuit_build_times_s circuit_build_times_t;
  4234. /********************************* config.c ***************************/
  4235. /** An error from options_trial_assign() or options_init_from_string(). */
  4236. typedef enum setopt_err_t {
  4237. SETOPT_OK = 0,
  4238. SETOPT_ERR_MISC = -1,
  4239. SETOPT_ERR_PARSE = -2,
  4240. SETOPT_ERR_TRANSITION = -3,
  4241. SETOPT_ERR_SETTING = -4,
  4242. } setopt_err_t;
  4243. /********************************* connection_edge.c *************************/
  4244. /** Enumerates possible origins of a client-side address mapping. */
  4245. typedef enum {
  4246. /** We're remapping this address because the controller told us to. */
  4247. ADDRMAPSRC_CONTROLLER,
  4248. /** We're remapping this address because of an AutomapHostsOnResolve
  4249. * configuration. */
  4250. ADDRMAPSRC_AUTOMAP,
  4251. /** We're remapping this address because our configuration (via torrc, the
  4252. * command line, or a SETCONF command) told us to. */
  4253. ADDRMAPSRC_TORRC,
  4254. /** We're remapping this address because we have TrackHostExit configured,
  4255. * and we want to remember to use the same exit next time. */
  4256. ADDRMAPSRC_TRACKEXIT,
  4257. /** We're remapping this address because we got a DNS resolution from a
  4258. * Tor server that told us what its value was. */
  4259. ADDRMAPSRC_DNS,
  4260. /** No remapping has occurred. This isn't a possible value for an
  4261. * addrmap_entry_t; it's used as a null value when we need to answer "Why
  4262. * did this remapping happen." */
  4263. ADDRMAPSRC_NONE
  4264. } addressmap_entry_source_t;
  4265. #define addressmap_entry_source_bitfield_t ENUM_BF(addressmap_entry_source_t)
  4266. /********************************* control.c ***************************/
  4267. /** Used to indicate the type of a circuit event passed to the controller.
  4268. * The various types are defined in control-spec.txt */
  4269. typedef enum circuit_status_event_t {
  4270. CIRC_EVENT_LAUNCHED = 0,
  4271. CIRC_EVENT_BUILT = 1,
  4272. CIRC_EVENT_EXTENDED = 2,
  4273. CIRC_EVENT_FAILED = 3,
  4274. CIRC_EVENT_CLOSED = 4,
  4275. } circuit_status_event_t;
  4276. /** Used to indicate the type of a CIRC_MINOR event passed to the controller.
  4277. * The various types are defined in control-spec.txt . */
  4278. typedef enum circuit_status_minor_event_t {
  4279. CIRC_MINOR_EVENT_PURPOSE_CHANGED,
  4280. CIRC_MINOR_EVENT_CANNIBALIZED,
  4281. } circuit_status_minor_event_t;
  4282. /** Used to indicate the type of a stream event passed to the controller.
  4283. * The various types are defined in control-spec.txt */
  4284. typedef enum stream_status_event_t {
  4285. STREAM_EVENT_SENT_CONNECT = 0,
  4286. STREAM_EVENT_SENT_RESOLVE = 1,
  4287. STREAM_EVENT_SUCCEEDED = 2,
  4288. STREAM_EVENT_FAILED = 3,
  4289. STREAM_EVENT_CLOSED = 4,
  4290. STREAM_EVENT_NEW = 5,
  4291. STREAM_EVENT_NEW_RESOLVE = 6,
  4292. STREAM_EVENT_FAILED_RETRIABLE = 7,
  4293. STREAM_EVENT_REMAP = 8
  4294. } stream_status_event_t;
  4295. /** Used to indicate the type of an OR connection event passed to the
  4296. * controller. The various types are defined in control-spec.txt */
  4297. typedef enum or_conn_status_event_t {
  4298. OR_CONN_EVENT_LAUNCHED = 0,
  4299. OR_CONN_EVENT_CONNECTED = 1,
  4300. OR_CONN_EVENT_FAILED = 2,
  4301. OR_CONN_EVENT_CLOSED = 3,
  4302. OR_CONN_EVENT_NEW = 4,
  4303. } or_conn_status_event_t;
  4304. /** Used to indicate the type of a buildtime event */
  4305. typedef enum buildtimeout_set_event_t {
  4306. BUILDTIMEOUT_SET_EVENT_COMPUTED = 0,
  4307. BUILDTIMEOUT_SET_EVENT_RESET = 1,
  4308. BUILDTIMEOUT_SET_EVENT_SUSPENDED = 2,
  4309. BUILDTIMEOUT_SET_EVENT_DISCARD = 3,
  4310. BUILDTIMEOUT_SET_EVENT_RESUME = 4
  4311. } buildtimeout_set_event_t;
  4312. /** Execute the statement <b>stmt</b>, which may log events concerning the
  4313. * connection <b>conn</b>. To prevent infinite loops, disable log messages
  4314. * being sent to controllers if <b>conn</b> is a control connection.
  4315. *
  4316. * Stmt must not contain any return or goto statements.
  4317. */
  4318. #define CONN_LOG_PROTECT(conn, stmt) \
  4319. STMT_BEGIN \
  4320. int _log_conn_is_control; \
  4321. tor_assert(conn); \
  4322. _log_conn_is_control = (conn->type == CONN_TYPE_CONTROL); \
  4323. if (_log_conn_is_control) \
  4324. disable_control_logging(); \
  4325. STMT_BEGIN stmt; STMT_END; \
  4326. if (_log_conn_is_control) \
  4327. enable_control_logging(); \
  4328. STMT_END
  4329. /** Enum describing various stages of bootstrapping, for use with controller
  4330. * bootstrap status events. The values range from 0 to 100. */
  4331. typedef enum {
  4332. BOOTSTRAP_STATUS_UNDEF=-1,
  4333. BOOTSTRAP_STATUS_STARTING=0,
  4334. BOOTSTRAP_STATUS_CONN_DIR=5,
  4335. BOOTSTRAP_STATUS_HANDSHAKE=-2,
  4336. BOOTSTRAP_STATUS_HANDSHAKE_DIR=10,
  4337. BOOTSTRAP_STATUS_ONEHOP_CREATE=15,
  4338. BOOTSTRAP_STATUS_REQUESTING_STATUS=20,
  4339. BOOTSTRAP_STATUS_LOADING_STATUS=25,
  4340. BOOTSTRAP_STATUS_LOADING_KEYS=40,
  4341. BOOTSTRAP_STATUS_REQUESTING_DESCRIPTORS=45,
  4342. BOOTSTRAP_STATUS_LOADING_DESCRIPTORS=50,
  4343. BOOTSTRAP_STATUS_CONN_OR=80,
  4344. BOOTSTRAP_STATUS_HANDSHAKE_OR=85,
  4345. BOOTSTRAP_STATUS_CIRCUIT_CREATE=90,
  4346. BOOTSTRAP_STATUS_DONE=100
  4347. } bootstrap_status_t;
  4348. /********************************* directory.c ***************************/
  4349. /** A pair of digests created by dir_split_resource_info_fingerprint_pairs() */
  4350. typedef struct {
  4351. char first[DIGEST_LEN];
  4352. char second[DIGEST_LEN];
  4353. } fp_pair_t;
  4354. /********************************* dirserv.c ***************************/
  4355. /** An enum to describe what format we're generating a routerstatus line in.
  4356. */
  4357. typedef enum {
  4358. /** For use in a v2 opinion */
  4359. NS_V2,
  4360. /** For use in a consensus networkstatus document (ns flavor) */
  4361. NS_V3_CONSENSUS,
  4362. /** For use in a vote networkstatus document */
  4363. NS_V3_VOTE,
  4364. /** For passing to the controlport in response to a GETINFO request */
  4365. NS_CONTROL_PORT,
  4366. /** For use in a consensus networkstatus document (microdesc flavor) */
  4367. NS_V3_CONSENSUS_MICRODESC
  4368. } routerstatus_format_type_t;
  4369. #ifdef DIRSERV_PRIVATE
  4370. typedef struct measured_bw_line_t {
  4371. char node_id[DIGEST_LEN];
  4372. char node_hex[MAX_HEX_NICKNAME_LEN+1];
  4373. long int bw_kb;
  4374. } measured_bw_line_t;
  4375. #endif
  4376. /********************************* dirvote.c ************************/
  4377. /** Describes the schedule by which votes should be generated. */
  4378. typedef struct vote_timing_t {
  4379. /** Length in seconds between one consensus becoming valid and the next
  4380. * becoming valid. */
  4381. int vote_interval;
  4382. /** For how many intervals is a consensus valid? */
  4383. int n_intervals_valid;
  4384. /** Time in seconds allowed to propagate votes */
  4385. int vote_delay;
  4386. /** Time in seconds allowed to propagate signatures */
  4387. int dist_delay;
  4388. } vote_timing_t;
  4389. /********************************* geoip.c **************************/
  4390. /** Indicates an action that we might be noting geoip statistics on.
  4391. * Note that if we're noticing CONNECT, we're a bridge, and if we're noticing
  4392. * the others, we're not.
  4393. */
  4394. typedef enum {
  4395. /** We've noticed a connection as a bridge relay or entry guard. */
  4396. GEOIP_CLIENT_CONNECT = 0,
  4397. /** We've served a networkstatus consensus as a directory server. */
  4398. GEOIP_CLIENT_NETWORKSTATUS = 1,
  4399. } geoip_client_action_t;
  4400. /** Indicates either a positive reply or a reason for rejectng a network
  4401. * status request that will be included in geoip statistics. */
  4402. typedef enum {
  4403. /** Request is answered successfully. */
  4404. GEOIP_SUCCESS = 0,
  4405. /** V3 network status is not signed by a sufficient number of requested
  4406. * authorities. */
  4407. GEOIP_REJECT_NOT_ENOUGH_SIGS = 1,
  4408. /** Requested network status object is unavailable. */
  4409. GEOIP_REJECT_UNAVAILABLE = 2,
  4410. /** Requested network status not found. */
  4411. GEOIP_REJECT_NOT_FOUND = 3,
  4412. /** Network status has not been modified since If-Modified-Since time. */
  4413. GEOIP_REJECT_NOT_MODIFIED = 4,
  4414. /** Directory is busy. */
  4415. GEOIP_REJECT_BUSY = 5,
  4416. } geoip_ns_response_t;
  4417. #define GEOIP_NS_RESPONSE_NUM 6
  4418. /** Directory requests that we are measuring can be either direct or
  4419. * tunneled. */
  4420. typedef enum {
  4421. DIRREQ_DIRECT = 0,
  4422. DIRREQ_TUNNELED = 1,
  4423. } dirreq_type_t;
  4424. /** Possible states for either direct or tunneled directory requests that
  4425. * are relevant for determining network status download times. */
  4426. typedef enum {
  4427. /** Found that the client requests a network status; applies to both
  4428. * direct and tunneled requests; initial state of a request that we are
  4429. * measuring. */
  4430. DIRREQ_IS_FOR_NETWORK_STATUS = 0,
  4431. /** Finished writing a network status to the directory connection;
  4432. * applies to both direct and tunneled requests; completes a direct
  4433. * request. */
  4434. DIRREQ_FLUSHING_DIR_CONN_FINISHED = 1,
  4435. /** END cell sent to circuit that initiated a tunneled request. */
  4436. DIRREQ_END_CELL_SENT = 2,
  4437. /** Flushed last cell from queue of the circuit that initiated a
  4438. * tunneled request to the outbuf of the OR connection. */
  4439. DIRREQ_CIRC_QUEUE_FLUSHED = 3,
  4440. /** Flushed last byte from buffer of the channel belonging to the
  4441. * circuit that initiated a tunneled request; completes a tunneled
  4442. * request. */
  4443. DIRREQ_CHANNEL_BUFFER_FLUSHED = 4
  4444. } dirreq_state_t;
  4445. #define WRITE_STATS_INTERVAL (24*60*60)
  4446. /********************************* microdesc.c *************************/
  4447. typedef struct microdesc_cache_t microdesc_cache_t;
  4448. /********************************* networkstatus.c *********************/
  4449. /** Possible statuses of a version of Tor, given opinions from the directory
  4450. * servers. */
  4451. typedef enum version_status_t {
  4452. VS_RECOMMENDED=0, /**< This version is listed as recommended. */
  4453. VS_OLD=1, /**< This version is older than any recommended version. */
  4454. VS_NEW=2, /**< This version is newer than any recommended version. */
  4455. VS_NEW_IN_SERIES=3, /**< This version is newer than any recommended version
  4456. * in its series, but later recommended versions exist.
  4457. */
  4458. VS_UNRECOMMENDED=4, /**< This version is not recommended (general case). */
  4459. VS_EMPTY=5, /**< The version list was empty; no agreed-on versions. */
  4460. VS_UNKNOWN, /**< We have no idea. */
  4461. } version_status_t;
  4462. /********************************* policies.c ************************/
  4463. /** Outcome of applying an address policy to an address. */
  4464. typedef enum {
  4465. /** The address was accepted */
  4466. ADDR_POLICY_ACCEPTED=0,
  4467. /** The address was rejected */
  4468. ADDR_POLICY_REJECTED=-1,
  4469. /** Part of the address was unknown, but as far as we can tell, it was
  4470. * accepted. */
  4471. ADDR_POLICY_PROBABLY_ACCEPTED=1,
  4472. /** Part of the address was unknown, but as far as we can tell, it was
  4473. * rejected. */
  4474. ADDR_POLICY_PROBABLY_REJECTED=2,
  4475. } addr_policy_result_t;
  4476. /********************************* rephist.c ***************************/
  4477. /** Possible public/private key operations in Tor: used to keep track of where
  4478. * we're spending our time. */
  4479. typedef enum {
  4480. SIGN_DIR, SIGN_RTR,
  4481. VERIFY_DIR, VERIFY_RTR,
  4482. ENC_ONIONSKIN, DEC_ONIONSKIN,
  4483. TLS_HANDSHAKE_C, TLS_HANDSHAKE_S,
  4484. REND_CLIENT, REND_MID, REND_SERVER,
  4485. } pk_op_t;
  4486. /********************************* rendcommon.c ***************************/
  4487. /** Hidden-service side configuration of client authorization. */
  4488. typedef struct rend_authorized_client_t {
  4489. char *client_name;
  4490. uint8_t descriptor_cookie[REND_DESC_COOKIE_LEN];
  4491. crypto_pk_t *client_key;
  4492. } rend_authorized_client_t;
  4493. /** ASCII-encoded v2 hidden service descriptor. */
  4494. typedef struct rend_encoded_v2_service_descriptor_t {
  4495. char desc_id[DIGEST_LEN]; /**< Descriptor ID. */
  4496. char *desc_str; /**< Descriptor string. */
  4497. } rend_encoded_v2_service_descriptor_t;
  4498. /** The maximum number of non-circuit-build-timeout failures a hidden
  4499. * service client will tolerate while trying to build a circuit to an
  4500. * introduction point. See also rend_intro_point_t.unreachable_count. */
  4501. #define MAX_INTRO_POINT_REACHABILITY_FAILURES 5
  4502. /** The minimum and maximum number of distinct INTRODUCE2 cells which a
  4503. * hidden service's introduction point will receive before it begins to
  4504. * expire. */
  4505. #define INTRO_POINT_MIN_LIFETIME_INTRODUCTIONS 16384
  4506. /* Double the minimum value so the interval is [min, min * 2]. */
  4507. #define INTRO_POINT_MAX_LIFETIME_INTRODUCTIONS \
  4508. (INTRO_POINT_MIN_LIFETIME_INTRODUCTIONS * 2)
  4509. /** The minimum number of seconds that an introduction point will last
  4510. * before expiring due to old age. (If it receives
  4511. * INTRO_POINT_LIFETIME_INTRODUCTIONS INTRODUCE2 cells, it may expire
  4512. * sooner.)
  4513. *
  4514. * XXX Should this be configurable? */
  4515. #define INTRO_POINT_LIFETIME_MIN_SECONDS (18*60*60)
  4516. /** The maximum number of seconds that an introduction point will last
  4517. * before expiring due to old age.
  4518. *
  4519. * XXX Should this be configurable? */
  4520. #define INTRO_POINT_LIFETIME_MAX_SECONDS (24*60*60)
  4521. /** The maximum number of circuit creation retry we do to an intro point
  4522. * before giving up. We try to reuse intro point that fails during their
  4523. * lifetime so this is a hard limit on the amount of time we do that. */
  4524. #define MAX_INTRO_POINT_CIRCUIT_RETRIES 3
  4525. /** Introduction point information. Used both in rend_service_t (on
  4526. * the service side) and in rend_service_descriptor_t (on both the
  4527. * client and service side). */
  4528. typedef struct rend_intro_point_t {
  4529. extend_info_t *extend_info; /**< Extend info for connecting to this
  4530. * introduction point via a multi-hop path. */
  4531. crypto_pk_t *intro_key; /**< Introduction key that replaces the service
  4532. * key, if this descriptor is V2. */
  4533. /** (Client side only) Flag indicating that a timeout has occurred
  4534. * after sending an INTRODUCE cell to this intro point. After a
  4535. * timeout, an intro point should not be tried again during the same
  4536. * hidden service connection attempt, but it may be tried again
  4537. * during a future connection attempt. */
  4538. unsigned int timed_out : 1;
  4539. /** (Client side only) The number of times we have failed to build a
  4540. * circuit to this intro point for some reason other than our
  4541. * circuit-build timeout. See also MAX_INTRO_POINT_REACHABILITY_FAILURES. */
  4542. unsigned int unreachable_count : 3;
  4543. /** (Service side only) Flag indicating that this intro point was
  4544. * included in the last HS descriptor we generated. */
  4545. unsigned int listed_in_last_desc : 1;
  4546. /** (Service side only) A replay cache recording the RSA-encrypted parts
  4547. * of INTRODUCE2 cells this intro point's circuit has received. This is
  4548. * used to prevent replay attacks. */
  4549. replaycache_t *accepted_intro_rsa_parts;
  4550. /** (Service side only) Count of INTRODUCE2 cells accepted from this
  4551. * intro point.
  4552. */
  4553. int accepted_introduce2_count;
  4554. /** (Service side only) Number of maximum INTRODUCE2 cells that this IP
  4555. * will accept. This is a random value between
  4556. * INTRO_POINT_MIN_LIFETIME_INTRODUCTIONS and
  4557. * INTRO_POINT_MAX_LIFETIME_INTRODUCTIONS. */
  4558. int max_introductions;
  4559. /** (Service side only) The time at which this intro point was first
  4560. * published, or -1 if this intro point has not yet been
  4561. * published. */
  4562. time_t time_published;
  4563. /** (Service side only) The time at which this intro point should
  4564. * (start to) expire, or -1 if we haven't decided when this intro
  4565. * point should expire. */
  4566. time_t time_to_expire;
  4567. /** (Service side only) The amount of circuit creation we've made to this
  4568. * intro point. This is incremented every time we do a circuit relaunch on
  4569. * this object which is triggered when the circuit dies but the node is
  4570. * still in the consensus. After MAX_INTRO_POINT_CIRCUIT_RETRIES, we give
  4571. * up on it. */
  4572. unsigned int circuit_retries;
  4573. /** (Service side only) Set if this intro point has an established circuit
  4574. * and unset if it doesn't. */
  4575. unsigned int circuit_established:1;
  4576. } rend_intro_point_t;
  4577. #define REND_PROTOCOL_VERSION_BITMASK_WIDTH 16
  4578. /** Information used to connect to a hidden service. Used on both the
  4579. * service side and the client side. */
  4580. typedef struct rend_service_descriptor_t {
  4581. crypto_pk_t *pk; /**< This service's public key. */
  4582. int version; /**< Version of the descriptor format: 0 or 2. */
  4583. time_t timestamp; /**< Time when the descriptor was generated. */
  4584. /** Bitmask: which introduce/rendezvous protocols are supported?
  4585. * (We allow bits '0', '1', '2' and '3' to be set.) */
  4586. unsigned protocols : REND_PROTOCOL_VERSION_BITMASK_WIDTH;
  4587. /** List of the service's introduction points. Elements are removed if
  4588. * introduction attempts fail. */
  4589. smartlist_t *intro_nodes;
  4590. /** Has descriptor been uploaded to all hidden service directories? */
  4591. int all_uploads_performed;
  4592. /** List of hidden service directories to which an upload request for
  4593. * this descriptor could be sent. Smartlist exists only when at least one
  4594. * of the previous upload requests failed (otherwise it's not important
  4595. * to know which uploads succeeded and which not). */
  4596. smartlist_t *successful_uploads;
  4597. } rend_service_descriptor_t;
  4598. /********************************* routerlist.c ***************************/
  4599. /** Represents information about a single trusted or fallback directory
  4600. * server. */
  4601. typedef struct dir_server_t {
  4602. char *description;
  4603. char *nickname;
  4604. char *address; /**< Hostname. */
  4605. /* XX/teor - why do we duplicate the address and port fields here and in
  4606. * fake_status? Surely we could just use fake_status (#17867). */
  4607. tor_addr_t ipv6_addr; /**< IPv6 address if present; AF_UNSPEC if not */
  4608. uint32_t addr; /**< IPv4 address. */
  4609. uint16_t dir_port; /**< Directory port. */
  4610. uint16_t or_port; /**< OR port: Used for tunneling connections. */
  4611. uint16_t ipv6_orport; /**< OR port corresponding to ipv6_addr. */
  4612. double weight; /** Weight used when selecting this node at random */
  4613. char digest[DIGEST_LEN]; /**< Digest of identity key. */
  4614. char v3_identity_digest[DIGEST_LEN]; /**< Digest of v3 (authority only,
  4615. * high-security) identity key. */
  4616. unsigned int is_running:1; /**< True iff we think this server is running. */
  4617. unsigned int is_authority:1; /**< True iff this is a directory authority
  4618. * of some kind. */
  4619. /** True iff this server has accepted the most recent server descriptor
  4620. * we tried to upload to it. */
  4621. unsigned int has_accepted_serverdesc:1;
  4622. /** What kind of authority is this? (Bitfield.) */
  4623. dirinfo_type_t type;
  4624. time_t addr_current_at; /**< When was the document that we derived the
  4625. * address information from published? */
  4626. routerstatus_t fake_status; /**< Used when we need to pass this trusted
  4627. * dir_server_t to
  4628. * directory_request_set_routerstatus.
  4629. * as a routerstatus_t. Not updated by the
  4630. * router-status management code!
  4631. **/
  4632. } dir_server_t;
  4633. #define RELAY_REQUIRED_MIN_BANDWIDTH (75*1024)
  4634. #define BRIDGE_REQUIRED_MIN_BANDWIDTH (50*1024)
  4635. #define ROUTER_MAX_DECLARED_BANDWIDTH INT32_MAX
  4636. /* Flags for pick_directory_server() and pick_trusteddirserver(). */
  4637. /** Flag to indicate that we should not automatically be willing to use
  4638. * ourself to answer a directory request.
  4639. * Passed to router_pick_directory_server (et al).*/
  4640. #define PDS_ALLOW_SELF (1<<0)
  4641. /** Flag to indicate that if no servers seem to be up, we should mark all
  4642. * directory servers as up and try again.
  4643. * Passed to router_pick_directory_server (et al).*/
  4644. #define PDS_RETRY_IF_NO_SERVERS (1<<1)
  4645. /** Flag to indicate that we should not exclude directory servers that
  4646. * our ReachableAddress settings would exclude. This usually means that
  4647. * we're going to connect to the server over Tor, and so we don't need to
  4648. * worry about our firewall telling us we can't.
  4649. * Passed to router_pick_directory_server (et al).*/
  4650. #define PDS_IGNORE_FASCISTFIREWALL (1<<2)
  4651. /** Flag to indicate that we should not use any directory authority to which
  4652. * we have an existing directory connection for downloading server descriptors
  4653. * or extrainfo documents.
  4654. *
  4655. * Passed to router_pick_directory_server (et al)
  4656. */
  4657. #define PDS_NO_EXISTING_SERVERDESC_FETCH (1<<3)
  4658. /** Flag to indicate that we should not use any directory authority to which
  4659. * we have an existing directory connection for downloading microdescs.
  4660. *
  4661. * Passed to router_pick_directory_server (et al)
  4662. */
  4663. #define PDS_NO_EXISTING_MICRODESC_FETCH (1<<4)
  4664. /** Possible ways to weight routers when choosing one randomly. See
  4665. * routerlist_sl_choose_by_bandwidth() for more information.*/
  4666. typedef enum bandwidth_weight_rule_t {
  4667. NO_WEIGHTING, WEIGHT_FOR_EXIT, WEIGHT_FOR_MID, WEIGHT_FOR_GUARD,
  4668. WEIGHT_FOR_DIR
  4669. } bandwidth_weight_rule_t;
  4670. /** Flags to be passed to control router_choose_random_node() to indicate what
  4671. * kind of nodes to pick according to what algorithm. */
  4672. typedef enum {
  4673. CRN_NEED_UPTIME = 1<<0,
  4674. CRN_NEED_CAPACITY = 1<<1,
  4675. CRN_NEED_GUARD = 1<<2,
  4676. /* XXXX not used, apparently. */
  4677. CRN_WEIGHT_AS_EXIT = 1<<5,
  4678. CRN_NEED_DESC = 1<<6,
  4679. /* On clients, only provide nodes that satisfy ClientPreferIPv6OR */
  4680. CRN_PREF_ADDR = 1<<7,
  4681. /* On clients, only provide nodes that we can connect to directly, based on
  4682. * our firewall rules */
  4683. CRN_DIRECT_CONN = 1<<8
  4684. } router_crn_flags_t;
  4685. /** Return value for router_add_to_routerlist() and dirserv_add_descriptor() */
  4686. typedef enum was_router_added_t {
  4687. /* Router was added successfully. */
  4688. ROUTER_ADDED_SUCCESSFULLY = 1,
  4689. /* Extrainfo document was rejected because no corresponding router
  4690. * descriptor was found OR router descriptor was rejected because
  4691. * it was incompatible with its extrainfo document. */
  4692. ROUTER_BAD_EI = -1,
  4693. /* Router descriptor was rejected because it is already known. */
  4694. ROUTER_IS_ALREADY_KNOWN = -2,
  4695. /* General purpose router was rejected, because it was not listed
  4696. * in consensus. */
  4697. ROUTER_NOT_IN_CONSENSUS = -3,
  4698. /* Router was neither in directory consensus nor in any of
  4699. * networkstatus documents. Caching it to access later.
  4700. * (Applies to fetched descriptors only.) */
  4701. ROUTER_NOT_IN_CONSENSUS_OR_NETWORKSTATUS = -4,
  4702. /* Router was rejected by directory authority. */
  4703. ROUTER_AUTHDIR_REJECTS = -5,
  4704. /* Bridge descriptor was rejected because such bridge was not one
  4705. * of the bridges we have listed in our configuration. */
  4706. ROUTER_WAS_NOT_WANTED = -6,
  4707. /* Router descriptor was rejected because it was older than
  4708. * OLD_ROUTER_DESC_MAX_AGE. */
  4709. ROUTER_WAS_TOO_OLD = -7, /* note contrast with 'NOT_NEW' */
  4710. /* DOCDOC */
  4711. ROUTER_CERTS_EXPIRED = -8
  4712. } was_router_added_t;
  4713. /********************************* routerparse.c ************************/
  4714. #define MAX_STATUS_TAG_LEN 32
  4715. /** Structure to hold parsed Tor versions. This is a little messier
  4716. * than we would like it to be, because we changed version schemes with 0.1.0.
  4717. *
  4718. * See version-spec.txt for the whole business.
  4719. */
  4720. typedef struct tor_version_t {
  4721. int major;
  4722. int minor;
  4723. int micro;
  4724. /** Release status. For version in the post-0.1 format, this is always
  4725. * VER_RELEASE. */
  4726. enum { VER_PRE=0, VER_RC=1, VER_RELEASE=2, } status;
  4727. int patchlevel;
  4728. char status_tag[MAX_STATUS_TAG_LEN];
  4729. int svn_revision;
  4730. int git_tag_len;
  4731. char git_tag[DIGEST_LEN];
  4732. } tor_version_t;
  4733. #endif