1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162116311641165116611671168116911701171117211731174117511761177117811791180118111821183118411851186118711881189119011911192119311941195119611971198119912001201120212031204120512061207120812091210121112121213121412151216121712181219122012211222122312241225122612271228122912301231123212331234123512361237123812391240124112421243124412451246124712481249125012511252125312541255125612571258125912601261126212631264126512661267126812691270127112721273127412751276127712781279128012811282128312841285128612871288128912901291129212931294129512961297129812991300130113021303130413051306130713081309131013111312131313141315131613171318131913201321132213231324132513261327132813291330133113321333133413351336133713381339134013411342134313441345134613471348134913501351135213531354135513561357135813591360136113621363136413651366136713681369137013711372137313741375137613771378137913801381138213831384138513861387138813891390139113921393139413951396139713981399140014011402140314041405140614071408140914101411141214131414141514161417141814191420142114221423142414251426142714281429143014311432143314341435143614371438143914401441144214431444144514461447144814491450145114521453145414551456145714581459146014611462146314641465146614671468146914701471147214731474147514761477147814791480148114821483148414851486148714881489149014911492149314941495149614971498149915001501150215031504150515061507150815091510151115121513151415151516151715181519152015211522152315241525152615271528152915301531153215331534153515361537153815391540154115421543154415451546154715481549155015511552155315541555155615571558155915601561156215631564156515661567156815691570157115721573157415751576157715781579158015811582158315841585158615871588158915901591159215931594159515961597159815991600160116021603160416051606160716081609161016111612161316141615161616171618161916201621162216231624162516261627162816291630163116321633163416351636163716381639164016411642164316441645164616471648164916501651165216531654165516561657165816591660166116621663166416651666166716681669167016711672167316741675167616771678167916801681168216831684168516861687168816891690169116921693169416951696169716981699170017011702170317041705170617071708170917101711171217131714171517161717171817191720172117221723172417251726172717281729173017311732173317341735173617371738173917401741174217431744174517461747174817491750175117521753175417551756175717581759176017611762176317641765176617671768176917701771177217731774177517761777177817791780178117821783178417851786178717881789179017911792179317941795179617971798179918001801180218031804180518061807180818091810181118121813181418151816181718181819182018211822182318241825182618271828182918301831183218331834183518361837183818391840184118421843184418451846184718481849185018511852185318541855185618571858185918601861186218631864186518661867186818691870187118721873187418751876187718781879188018811882188318841885188618871888188918901891189218931894189518961897189818991900190119021903190419051906190719081909191019111912191319141915191619171918191919201921192219231924192519261927192819291930193119321933193419351936193719381939194019411942194319441945194619471948194919501951195219531954195519561957195819591960196119621963196419651966196719681969197019711972197319741975197619771978197919801981198219831984198519861987198819891990199119921993199419951996199719981999200020012002200320042005200620072008200920102011201220132014201520162017201820192020202120222023202420252026202720282029203020312032203320342035203620372038203920402041204220432044204520462047204820492050205120522053205420552056205720582059206020612062206320642065206620672068206920702071207220732074207520762077207820792080208120822083208420852086208720882089209020912092209320942095209620972098209921002101210221032104210521062107210821092110211121122113211421152116211721182119212021212122212321242125212621272128212921302131213221332134213521362137213821392140214121422143214421452146214721482149215021512152215321542155215621572158215921602161216221632164216521662167216821692170217121722173217421752176217721782179218021812182218321842185218621872188218921902191219221932194219521962197219821992200220122022203220422052206220722082209221022112212221322142215221622172218221922202221222222232224222522262227222822292230223122322233223422352236223722382239224022412242224322442245224622472248224922502251225222532254225522562257225822592260226122622263226422652266226722682269227022712272227322742275227622772278227922802281228222832284228522862287228822892290229122922293229422952296229722982299230023012302230323042305230623072308230923102311231223132314231523162317231823192320232123222323232423252326232723282329233023312332233323342335233623372338233923402341234223432344234523462347234823492350235123522353235423552356235723582359236023612362236323642365236623672368236923702371237223732374237523762377237823792380238123822383238423852386238723882389239023912392239323942395239623972398239924002401240224032404240524062407240824092410241124122413241424152416241724182419242024212422242324242425242624272428242924302431243224332434243524362437243824392440244124422443244424452446244724482449245024512452245324542455245624572458245924602461246224632464246524662467246824692470247124722473247424752476247724782479248024812482248324842485248624872488248924902491249224932494249524962497249824992500250125022503250425052506250725082509251025112512251325142515251625172518251925202521252225232524252525262527252825292530253125322533253425352536253725382539254025412542254325442545254625472548254925502551255225532554255525562557255825592560256125622563256425652566256725682569257025712572257325742575257625772578257925802581258225832584258525862587258825892590259125922593259425952596259725982599260026012602260326042605260626072608260926102611261226132614261526162617261826192620262126222623262426252626262726282629263026312632263326342635263626372638263926402641264226432644264526462647264826492650265126522653265426552656265726582659266026612662266326642665266626672668266926702671267226732674267526762677267826792680268126822683268426852686268726882689269026912692269326942695269626972698269927002701270227032704270527062707270827092710271127122713271427152716271727182719272027212722272327242725272627272728272927302731273227332734273527362737273827392740274127422743274427452746274727482749275027512752275327542755275627572758275927602761276227632764276527662767276827692770277127722773277427752776277727782779278027812782278327842785278627872788278927902791279227932794279527962797279827992800280128022803280428052806280728082809281028112812281328142815281628172818281928202821282228232824282528262827282828292830283128322833283428352836283728382839284028412842284328442845284628472848284928502851285228532854285528562857285828592860286128622863286428652866286728682869287028712872287328742875287628772878287928802881288228832884288528862887288828892890289128922893289428952896289728982899290029012902290329042905290629072908290929102911291229132914291529162917291829192920292129222923292429252926292729282929293029312932293329342935293629372938293929402941294229432944294529462947294829492950295129522953295429552956295729582959296029612962296329642965296629672968296929702971297229732974297529762977297829792980298129822983298429852986298729882989299029912992299329942995299629972998299930003001300230033004300530063007300830093010301130123013301430153016301730183019302030213022302330243025302630273028302930303031303230333034303530363037303830393040304130423043304430453046304730483049305030513052305330543055305630573058305930603061306230633064306530663067306830693070307130723073307430753076307730783079308030813082308330843085308630873088308930903091309230933094309530963097309830993100310131023103310431053106310731083109311031113112311331143115311631173118311931203121312231233124312531263127312831293130313131323133313431353136313731383139314031413142314331443145314631473148314931503151315231533154315531563157315831593160316131623163316431653166316731683169317031713172317331743175317631773178317931803181318231833184318531863187318831893190319131923193319431953196319731983199320032013202320332043205320632073208320932103211321232133214321532163217321832193220322132223223322432253226322732283229323032313232323332343235323632373238323932403241324232433244324532463247324832493250325132523253325432553256325732583259326032613262326332643265326632673268326932703271327232733274327532763277327832793280328132823283328432853286328732883289329032913292329332943295329632973298329933003301330233033304330533063307330833093310331133123313331433153316331733183319332033213322332333243325332633273328332933303331333233333334333533363337333833393340334133423343334433453346334733483349335033513352335333543355335633573358335933603361336233633364336533663367336833693370337133723373337433753376337733783379338033813382338333843385338633873388338933903391339233933394339533963397339833993400340134023403340434053406340734083409341034113412341334143415341634173418341934203421342234233424342534263427342834293430343134323433343434353436343734383439344034413442344334443445344634473448344934503451345234533454345534563457345834593460346134623463346434653466346734683469347034713472347334743475347634773478347934803481348234833484348534863487348834893490349134923493349434953496349734983499350035013502350335043505350635073508350935103511351235133514351535163517351835193520352135223523352435253526352735283529353035313532353335343535353635373538353935403541354235433544354535463547354835493550355135523553355435553556355735583559356035613562356335643565356635673568356935703571357235733574357535763577357835793580358135823583358435853586358735883589359035913592359335943595359635973598359936003601360236033604360536063607360836093610361136123613361436153616361736183619362036213622362336243625362636273628362936303631363236333634363536363637363836393640364136423643364436453646364736483649365036513652365336543655365636573658365936603661366236633664366536663667366836693670367136723673367436753676367736783679368036813682368336843685368636873688368936903691369236933694369536963697369836993700370137023703370437053706370737083709371037113712371337143715371637173718371937203721372237233724372537263727372837293730373137323733373437353736373737383739374037413742374337443745374637473748374937503751375237533754375537563757375837593760376137623763376437653766376737683769377037713772377337743775377637773778377937803781378237833784378537863787378837893790379137923793379437953796379737983799380038013802380338043805380638073808380938103811381238133814381538163817381838193820382138223823382438253826382738283829383038313832383338343835383638373838383938403841384238433844384538463847384838493850385138523853385438553856385738583859386038613862386338643865386638673868386938703871387238733874387538763877387838793880388138823883388438853886388738883889389038913892389338943895389638973898389939003901390239033904390539063907390839093910391139123913391439153916391739183919392039213922392339243925392639273928392939303931393239333934393539363937393839393940394139423943394439453946394739483949395039513952395339543955395639573958395939603961396239633964396539663967396839693970397139723973397439753976397739783979398039813982398339843985398639873988398939903991399239933994399539963997399839994000400140024003400440054006400740084009401040114012401340144015401640174018401940204021402240234024402540264027402840294030403140324033403440354036403740384039404040414042404340444045404640474048404940504051405240534054405540564057405840594060406140624063406440654066406740684069407040714072407340744075407640774078407940804081408240834084408540864087408840894090409140924093409440954096409740984099410041014102410341044105410641074108410941104111411241134114411541164117411841194120412141224123412441254126412741284129413041314132413341344135413641374138413941404141414241434144414541464147414841494150415141524153415441554156415741584159416041614162416341644165416641674168416941704171417241734174417541764177417841794180418141824183418441854186418741884189419041914192419341944195419641974198419942004201420242034204420542064207420842094210421142124213421442154216421742184219422042214222422342244225422642274228422942304231423242334234423542364237423842394240424142424243424442454246424742484249425042514252425342544255425642574258425942604261426242634264426542664267426842694270427142724273427442754276427742784279428042814282428342844285428642874288428942904291429242934294429542964297429842994300430143024303430443054306430743084309431043114312431343144315431643174318431943204321432243234324432543264327432843294330433143324333433443354336433743384339434043414342434343444345434643474348434943504351435243534354435543564357435843594360436143624363436443654366436743684369437043714372437343744375437643774378437943804381438243834384438543864387438843894390439143924393439443954396439743984399440044014402440344044405440644074408440944104411441244134414441544164417441844194420442144224423442444254426442744284429443044314432443344344435443644374438443944404441444244434444444544464447444844494450445144524453445444554456445744584459446044614462446344644465446644674468446944704471447244734474447544764477447844794480448144824483448444854486448744884489449044914492449344944495449644974498449945004501450245034504450545064507450845094510451145124513451445154516451745184519452045214522452345244525452645274528452945304531453245334534453545364537453845394540454145424543454445454546454745484549455045514552455345544555455645574558455945604561456245634564456545664567456845694570457145724573457445754576457745784579458045814582458345844585458645874588458945904591459245934594459545964597459845994600460146024603460446054606460746084609461046114612461346144615461646174618461946204621462246234624462546264627462846294630463146324633463446354636463746384639464046414642464346444645464646474648464946504651465246534654465546564657465846594660466146624663466446654666466746684669467046714672467346744675467646774678467946804681468246834684468546864687468846894690469146924693469446954696469746984699470047014702470347044705470647074708470947104711471247134714471547164717471847194720472147224723472447254726472747284729473047314732473347344735473647374738473947404741474247434744474547464747474847494750475147524753475447554756475747584759476047614762476347644765476647674768476947704771477247734774477547764777477847794780478147824783478447854786478747884789479047914792479347944795479647974798479948004801480248034804480548064807480848094810481148124813481448154816481748184819482048214822482348244825482648274828482948304831483248334834483548364837483848394840484148424843484448454846484748484849485048514852485348544855485648574858485948604861486248634864486548664867486848694870487148724873487448754876487748784879488048814882488348844885488648874888488948904891489248934894489548964897489848994900490149024903490449054906490749084909491049114912491349144915491649174918491949204921492249234924492549264927492849294930493149324933493449354936493749384939494049414942494349444945494649474948494949504951495249534954495549564957495849594960496149624963496449654966496749684969497049714972497349744975497649774978497949804981498249834984498549864987498849894990499149924993499449954996499749984999500050015002500350045005500650075008500950105011501250135014501550165017501850195020502150225023502450255026502750285029503050315032503350345035503650375038503950405041504250435044504550465047504850495050505150525053505450555056505750585059506050615062506350645065506650675068506950705071507250735074507550765077507850795080508150825083508450855086508750885089509050915092509350945095509650975098509951005101510251035104510551065107510851095110511151125113511451155116511751185119512051215122512351245125512651275128512951305131513251335134513551365137513851395140514151425143514451455146514751485149515051515152515351545155515651575158515951605161516251635164516551665167516851695170517151725173517451755176517751785179518051815182518351845185518651875188518951905191519251935194519551965197519851995200520152025203520452055206520752085209521052115212521352145215521652175218521952205221522252235224522552265227522852295230523152325233523452355236523752385239524052415242524352445245524652475248524952505251525252535254525552565257525852595260526152625263526452655266526752685269527052715272527352745275527652775278527952805281528252835284528552865287528852895290529152925293529452955296529752985299530053015302530353045305530653075308530953105311531253135314531553165317531853195320532153225323532453255326532753285329533053315332533353345335533653375338533953405341534253435344534553465347534853495350535153525353535453555356535753585359536053615362536353645365536653675368536953705371537253735374537553765377537853795380538153825383538453855386538753885389539053915392539353945395539653975398539954005401540254035404540554065407540854095410541154125413541454155416541754185419542054215422542354245425542654275428542954305431543254335434543554365437543854395440544154425443544454455446544754485449545054515452545354545455545654575458545954605461546254635464546554665467546854695470547154725473547454755476547754785479548054815482548354845485548654875488548954905491549254935494549554965497549854995500550155025503550455055506550755085509551055115512551355145515551655175518551955205521552255235524552555265527552855295530553155325533553455355536553755385539554055415542554355445545554655475548554955505551555255535554555555565557555855595560556155625563556455655566556755685569557055715572557355745575557655775578557955805581558255835584558555865587558855895590559155925593559455955596559755985599560056015602560356045605560656075608560956105611561256135614561556165617561856195620562156225623562456255626562756285629563056315632563356345635563656375638563956405641564256435644564556465647564856495650565156525653565456555656565756585659566056615662566356645665566656675668566956705671567256735674567556765677567856795680568156825683568456855686568756885689569056915692569356945695569656975698569957005701570257035704570557065707570857095710571157125713571457155716571757185719572057215722572357245725572657275728572957305731573257335734573557365737 |
- /* Copyright (c) 2001-2004, Roger Dingledine.
- * Copyright (c) 2004-2006, Roger Dingledine, Nick Mathewson.
- * Copyright (c) 2007-2018, The Tor Project, Inc. */
- /* See LICENSE for licensing information */
- #include "orconfig.h"
- #define CONFIG_PRIVATE
- #define PT_PRIVATE
- #define ROUTERSET_PRIVATE
- #include "or/or.h"
- #include "lib/net/address.h"
- #include "or/addressmap.h"
- #include "or/bridges.h"
- #include "or/circuitmux_ewma.h"
- #include "or/circuitbuild.h"
- #include "or/config.h"
- #include "or/confparse.h"
- #include "or/connection.h"
- #include "or/connection_edge.h"
- #include "test/test.h"
- #include "common/util.h"
- #include "or/connection_or.h"
- #include "or/control.h"
- #include "or/cpuworker.h"
- #include "or/dirserv.h"
- #include "or/dirauth/dirvote.h"
- #include "or/dns.h"
- #include "or/entrynodes.h"
- #include "or/transports.h"
- #include "or/ext_orport.h"
- #include "or/geoip.h"
- #include "or/hibernate.h"
- #include "or/main.h"
- #include "or/networkstatus.h"
- #include "or/nodelist.h"
- #include "or/policies.h"
- #include "or/rendclient.h"
- #include "or/rendservice.h"
- #include "or/router.h"
- #include "or/routerlist.h"
- #include "or/routerset.h"
- #include "or/statefile.h"
- #include "test/test_helpers.h"
- #include "or/dir_server_st.h"
- #include "or/port_cfg_st.h"
- #include "or/routerinfo_st.h"
- #include "lib/fs/conffile.h"
- #include "lib/meminfo/meminfo.h"
- #include "lib/net/gethostname.h"
- static void
- test_config_addressmap(void *arg)
- {
- char buf[1024];
- char address[256];
- time_t expires = TIME_MAX;
- (void)arg;
- strlcpy(buf, "MapAddress .invalidwildcard.com *.torserver.exit\n" // invalid
- "MapAddress *invalidasterisk.com *.torserver.exit\n" // invalid
- "MapAddress *.google.com *.torserver.exit\n"
- "MapAddress *.yahoo.com *.google.com.torserver.exit\n"
- "MapAddress *.cn.com www.cnn.com\n"
- "MapAddress *.cnn.com www.cnn.com\n"
- "MapAddress ex.com www.cnn.com\n"
- "MapAddress ey.com *.cnn.com\n"
- "MapAddress www.torproject.org 1.1.1.1\n"
- "MapAddress other.torproject.org "
- "this.torproject.org.otherserver.exit\n"
- "MapAddress test.torproject.org 2.2.2.2\n"
- "MapAddress www.google.com 3.3.3.3\n"
- "MapAddress www.example.org 4.4.4.4\n"
- "MapAddress 4.4.4.4 7.7.7.7\n"
- "MapAddress 4.4.4.4 5.5.5.5\n"
- "MapAddress www.infiniteloop.org 6.6.6.6\n"
- "MapAddress 6.6.6.6 www.infiniteloop.org\n"
- , sizeof(buf));
- config_get_lines(buf, &(get_options_mutable()->AddressMap), 0);
- config_register_addressmaps(get_options());
- /* Use old interface for now, so we don't need to rewrite the unit tests */
- #define addressmap_rewrite(a,s,eo,ao) \
- addressmap_rewrite((a),(s), ~0, (eo),(ao))
- /* MapAddress .invalidwildcard.com .torserver.exit - no match */
- strlcpy(address, "www.invalidwildcard.com", sizeof(address));
- tt_assert(!addressmap_rewrite(address, sizeof(address), &expires, NULL));
- /* MapAddress *invalidasterisk.com .torserver.exit - no match */
- strlcpy(address, "www.invalidasterisk.com", sizeof(address));
- tt_assert(!addressmap_rewrite(address, sizeof(address), &expires, NULL));
- /* Where no mapping for FQDN match on top-level domain */
- /* MapAddress .google.com .torserver.exit */
- strlcpy(address, "reader.google.com", sizeof(address));
- tt_assert(addressmap_rewrite(address, sizeof(address), &expires, NULL));
- tt_str_op(address,OP_EQ, "reader.torserver.exit");
- /* MapAddress *.yahoo.com *.google.com.torserver.exit */
- strlcpy(address, "reader.yahoo.com", sizeof(address));
- tt_assert(addressmap_rewrite(address, sizeof(address), &expires, NULL));
- tt_str_op(address,OP_EQ, "reader.google.com.torserver.exit");
- /*MapAddress *.cnn.com www.cnn.com */
- strlcpy(address, "cnn.com", sizeof(address));
- tt_assert(addressmap_rewrite(address, sizeof(address), &expires, NULL));
- tt_str_op(address,OP_EQ, "www.cnn.com");
- /* MapAddress .cn.com www.cnn.com */
- strlcpy(address, "www.cn.com", sizeof(address));
- tt_assert(addressmap_rewrite(address, sizeof(address), &expires, NULL));
- tt_str_op(address,OP_EQ, "www.cnn.com");
- /* MapAddress ex.com www.cnn.com - no match */
- strlcpy(address, "www.ex.com", sizeof(address));
- tt_assert(!addressmap_rewrite(address, sizeof(address), &expires, NULL));
- /* MapAddress ey.com *.cnn.com - invalid expression */
- strlcpy(address, "ey.com", sizeof(address));
- tt_assert(!addressmap_rewrite(address, sizeof(address), &expires, NULL));
- /* Where mapping for FQDN match on FQDN */
- strlcpy(address, "www.google.com", sizeof(address));
- tt_assert(addressmap_rewrite(address, sizeof(address), &expires, NULL));
- tt_str_op(address,OP_EQ, "3.3.3.3");
- strlcpy(address, "www.torproject.org", sizeof(address));
- tt_assert(addressmap_rewrite(address, sizeof(address), &expires, NULL));
- tt_str_op(address,OP_EQ, "1.1.1.1");
- strlcpy(address, "other.torproject.org", sizeof(address));
- tt_assert(addressmap_rewrite(address, sizeof(address), &expires, NULL));
- tt_str_op(address,OP_EQ, "this.torproject.org.otherserver.exit");
- strlcpy(address, "test.torproject.org", sizeof(address));
- tt_assert(addressmap_rewrite(address, sizeof(address), &expires, NULL));
- tt_str_op(address,OP_EQ, "2.2.2.2");
- /* Test a chain of address mappings and the order in which they were added:
- "MapAddress www.example.org 4.4.4.4"
- "MapAddress 4.4.4.4 7.7.7.7"
- "MapAddress 4.4.4.4 5.5.5.5"
- */
- strlcpy(address, "www.example.org", sizeof(address));
- tt_assert(addressmap_rewrite(address, sizeof(address), &expires, NULL));
- tt_str_op(address,OP_EQ, "5.5.5.5");
- /* Test infinite address mapping results in no change */
- strlcpy(address, "www.infiniteloop.org", sizeof(address));
- tt_assert(addressmap_rewrite(address, sizeof(address), &expires, NULL));
- tt_str_op(address,OP_EQ, "www.infiniteloop.org");
- /* Test we don't find false positives */
- strlcpy(address, "www.example.com", sizeof(address));
- tt_assert(!addressmap_rewrite(address, sizeof(address), &expires, NULL));
- /* Test top-level-domain matching a bit harder */
- config_free_lines(get_options_mutable()->AddressMap);
- addressmap_clear_configured();
- strlcpy(buf, "MapAddress *.com *.torserver.exit\n"
- "MapAddress *.torproject.org 1.1.1.1\n"
- "MapAddress *.net 2.2.2.2\n"
- , sizeof(buf));
- config_get_lines(buf, &(get_options_mutable()->AddressMap), 0);
- config_register_addressmaps(get_options());
- strlcpy(address, "www.abc.com", sizeof(address));
- tt_assert(addressmap_rewrite(address, sizeof(address), &expires, NULL));
- tt_str_op(address,OP_EQ, "www.abc.torserver.exit");
- strlcpy(address, "www.def.com", sizeof(address));
- tt_assert(addressmap_rewrite(address, sizeof(address), &expires, NULL));
- tt_str_op(address,OP_EQ, "www.def.torserver.exit");
- strlcpy(address, "www.torproject.org", sizeof(address));
- tt_assert(addressmap_rewrite(address, sizeof(address), &expires, NULL));
- tt_str_op(address,OP_EQ, "1.1.1.1");
- strlcpy(address, "test.torproject.org", sizeof(address));
- tt_assert(addressmap_rewrite(address, sizeof(address), &expires, NULL));
- tt_str_op(address,OP_EQ, "1.1.1.1");
- strlcpy(address, "torproject.net", sizeof(address));
- tt_assert(addressmap_rewrite(address, sizeof(address), &expires, NULL));
- tt_str_op(address,OP_EQ, "2.2.2.2");
- /* We don't support '*' as a mapping directive */
- config_free_lines(get_options_mutable()->AddressMap);
- addressmap_clear_configured();
- strlcpy(buf, "MapAddress * *.torserver.exit\n", sizeof(buf));
- config_get_lines(buf, &(get_options_mutable()->AddressMap), 0);
- config_register_addressmaps(get_options());
- strlcpy(address, "www.abc.com", sizeof(address));
- tt_assert(!addressmap_rewrite(address, sizeof(address), &expires, NULL));
- strlcpy(address, "www.def.net", sizeof(address));
- tt_assert(!addressmap_rewrite(address, sizeof(address), &expires, NULL));
- strlcpy(address, "www.torproject.org", sizeof(address));
- tt_assert(!addressmap_rewrite(address, sizeof(address), &expires, NULL));
- #undef addressmap_rewrite
- done:
- config_free_lines(get_options_mutable()->AddressMap);
- get_options_mutable()->AddressMap = NULL;
- addressmap_free_all();
- }
- static int
- is_private_dir(const char* path)
- {
- struct stat st;
- int r = stat(path, &st);
- if (r) {
- return 0;
- }
- #if !defined (_WIN32)
- if ((st.st_mode & (S_IFDIR | 0777)) != (S_IFDIR | 0700)) {
- return 0;
- }
- #endif
- return 1;
- }
- static void
- test_config_check_or_create_data_subdir(void *arg)
- {
- or_options_t *options = get_options_mutable();
- char *datadir;
- const char *subdir = "test_stats";
- char *subpath;
- struct stat st;
- int r;
- #if !defined (_WIN32)
- unsigned group_permission;
- #endif
- (void)arg;
- tor_free(options->DataDirectory);
- datadir = options->DataDirectory = tor_strdup(get_fname("datadir-0"));
- subpath = get_datadir_fname(subdir);
- #if defined (_WIN32)
- tt_int_op(mkdir(options->DataDirectory), OP_EQ, 0);
- #else
- tt_int_op(mkdir(options->DataDirectory, 0700), OP_EQ, 0);
- #endif
- r = stat(subpath, &st);
- // The subdirectory shouldn't exist yet,
- // but should be created by the call to check_or_create_data_subdir.
- tt_assert(r && (errno == ENOENT));
- tt_assert(!check_or_create_data_subdir(subdir));
- tt_assert(is_private_dir(subpath));
- // The check should return 0, if the directory already exists
- // and is private to the user.
- tt_assert(!check_or_create_data_subdir(subdir));
- r = stat(subpath, &st);
- if (r) {
- tt_abort_perror("stat");
- }
- #if !defined (_WIN32)
- group_permission = st.st_mode | 0070;
- r = chmod(subpath, group_permission);
- if (r) {
- tt_abort_perror("chmod");
- }
- // If the directory exists, but its mode is too permissive
- // a call to check_or_create_data_subdir should reset the mode.
- tt_assert(!is_private_dir(subpath));
- tt_assert(!check_or_create_data_subdir(subdir));
- tt_assert(is_private_dir(subpath));
- #endif /* !defined (_WIN32) */
- done:
- rmdir(subpath);
- tor_free(datadir);
- tor_free(subpath);
- }
- static void
- test_config_write_to_data_subdir(void *arg)
- {
- or_options_t* options = get_options_mutable();
- char *datadir;
- char *cp = NULL;
- const char* subdir = "test_stats";
- const char* fname = "test_file";
- const char* str =
- "Lorem ipsum dolor sit amet, consetetur sadipscing\n"
- "elitr, sed diam nonumy eirmod\n"
- "tempor invidunt ut labore et dolore magna aliquyam\n"
- "erat, sed diam voluptua.\n"
- "At vero eos et accusam et justo duo dolores et ea\n"
- "rebum. Stet clita kasd gubergren,\n"
- "no sea takimata sanctus est Lorem ipsum dolor sit amet.\n"
- "Lorem ipsum dolor sit amet,\n"
- "consetetur sadipscing elitr, sed diam nonumy eirmod\n"
- "tempor invidunt ut labore et dolore\n"
- "magna aliquyam erat, sed diam voluptua. At vero eos et\n"
- "accusam et justo duo dolores et\n"
- "ea rebum. Stet clita kasd gubergren, no sea takimata\n"
- "sanctus est Lorem ipsum dolor sit amet.";
- char* filepath = NULL;
- (void)arg;
- tor_free(options->DataDirectory);
- datadir = options->DataDirectory = tor_strdup(get_fname("datadir-1"));
- filepath = get_datadir_fname2(subdir, fname);
- #if defined (_WIN32)
- tt_int_op(mkdir(options->DataDirectory), OP_EQ, 0);
- #else
- tt_int_op(mkdir(options->DataDirectory, 0700), OP_EQ, 0);
- #endif
- // Write attempt should fail, if subdirectory doesn't exist.
- tt_assert(write_to_data_subdir(subdir, fname, str, NULL));
- tt_assert(! check_or_create_data_subdir(subdir));
- // Content of file after write attempt should be
- // equal to the original string.
- tt_assert(!write_to_data_subdir(subdir, fname, str, NULL));
- cp = read_file_to_str(filepath, 0, NULL);
- tt_str_op(cp,OP_EQ, str);
- tor_free(cp);
- // A second write operation should overwrite the old content.
- tt_assert(!write_to_data_subdir(subdir, fname, str, NULL));
- cp = read_file_to_str(filepath, 0, NULL);
- tt_str_op(cp,OP_EQ, str);
- tor_free(cp);
- done:
- (void) unlink(filepath);
- rmdir(options->DataDirectory);
- tor_free(datadir);
- tor_free(filepath);
- tor_free(cp);
- }
- /* Test helper function: Make sure that a bridge line gets parsed
- * properly. Also make sure that the resulting bridge_line_t structure
- * has its fields set correctly. */
- static void
- good_bridge_line_test(const char *string, const char *test_addrport,
- const char *test_digest, const char *test_transport,
- const smartlist_t *test_socks_args)
- {
- char *tmp = NULL;
- bridge_line_t *bridge_line = parse_bridge_line(string);
- tt_assert(bridge_line);
- /* test addrport */
- tmp = tor_strdup(fmt_addrport(&bridge_line->addr, bridge_line->port));
- tt_str_op(test_addrport,OP_EQ, tmp);
- tor_free(tmp);
- /* If we were asked to validate a digest, but we did not get a
- digest after parsing, we failed. */
- if (test_digest && tor_digest_is_zero(bridge_line->digest))
- tt_abort();
- /* If we were not asked to validate a digest, and we got a digest
- after parsing, we failed again. */
- if (!test_digest && !tor_digest_is_zero(bridge_line->digest))
- tt_abort();
- /* If we were asked to validate a digest, and we got a digest after
- parsing, make sure it's correct. */
- if (test_digest) {
- tmp = tor_strdup(hex_str(bridge_line->digest, DIGEST_LEN));
- tor_strlower(tmp);
- tt_str_op(test_digest,OP_EQ, tmp);
- tor_free(tmp);
- }
- /* If we were asked to validate a transport name, make sure tha it
- matches with the transport name that was parsed. */
- if (test_transport && !bridge_line->transport_name)
- tt_abort();
- if (!test_transport && bridge_line->transport_name)
- tt_abort();
- if (test_transport)
- tt_str_op(test_transport,OP_EQ, bridge_line->transport_name);
- /* Validate the SOCKS argument smartlist. */
- if (test_socks_args && !bridge_line->socks_args)
- tt_abort();
- if (!test_socks_args && bridge_line->socks_args)
- tt_abort();
- if (test_socks_args)
- tt_assert(smartlist_strings_eq(test_socks_args,
- bridge_line->socks_args));
- done:
- tor_free(tmp);
- bridge_line_free(bridge_line);
- }
- /* Test helper function: Make sure that a bridge line is
- * unparseable. */
- static void
- bad_bridge_line_test(const char *string)
- {
- bridge_line_t *bridge_line = parse_bridge_line(string);
- if (bridge_line)
- TT_FAIL(("%s was supposed to fail, but it didn't.", string));
- tt_ptr_op(bridge_line, OP_EQ, NULL);
- done:
- bridge_line_free(bridge_line);
- }
- static void
- test_config_parse_bridge_line(void *arg)
- {
- (void) arg;
- good_bridge_line_test("192.0.2.1:4123",
- "192.0.2.1:4123", NULL, NULL, NULL);
- good_bridge_line_test("192.0.2.1",
- "192.0.2.1:443", NULL, NULL, NULL);
- good_bridge_line_test("transport [::1]",
- "[::1]:443", NULL, "transport", NULL);
- good_bridge_line_test("transport 192.0.2.1:12 "
- "4352e58420e68f5e40bf7c74faddccd9d1349413",
- "192.0.2.1:12",
- "4352e58420e68f5e40bf7c74faddccd9d1349413",
- "transport", NULL);
- {
- smartlist_t *sl_tmp = smartlist_new();
- smartlist_add_asprintf(sl_tmp, "twoandtwo=five");
- good_bridge_line_test("transport 192.0.2.1:12 "
- "4352e58420e68f5e40bf7c74faddccd9d1349413 twoandtwo=five",
- "192.0.2.1:12", "4352e58420e68f5e40bf7c74faddccd9d1349413",
- "transport", sl_tmp);
- SMARTLIST_FOREACH(sl_tmp, char *, s, tor_free(s));
- smartlist_free(sl_tmp);
- }
- {
- smartlist_t *sl_tmp = smartlist_new();
- smartlist_add_asprintf(sl_tmp, "twoandtwo=five");
- smartlist_add_asprintf(sl_tmp, "z=z");
- good_bridge_line_test("transport 192.0.2.1:12 twoandtwo=five z=z",
- "192.0.2.1:12", NULL, "transport", sl_tmp);
- SMARTLIST_FOREACH(sl_tmp, char *, s, tor_free(s));
- smartlist_free(sl_tmp);
- }
- {
- smartlist_t *sl_tmp = smartlist_new();
- smartlist_add_asprintf(sl_tmp, "dub=come");
- smartlist_add_asprintf(sl_tmp, "save=me");
- good_bridge_line_test("transport 192.0.2.1:12 "
- "4352e58420e68f5e40bf7c74faddccd9d1349666 "
- "dub=come save=me",
- "192.0.2.1:12",
- "4352e58420e68f5e40bf7c74faddccd9d1349666",
- "transport", sl_tmp);
- SMARTLIST_FOREACH(sl_tmp, char *, s, tor_free(s));
- smartlist_free(sl_tmp);
- }
- good_bridge_line_test("192.0.2.1:1231 "
- "4352e58420e68f5e40bf7c74faddccd9d1349413",
- "192.0.2.1:1231",
- "4352e58420e68f5e40bf7c74faddccd9d1349413",
- NULL, NULL);
- /* Empty line */
- bad_bridge_line_test("");
- /* bad transport name */
- bad_bridge_line_test("tr$n_sp0r7 190.20.2.2");
- /* weird ip address */
- bad_bridge_line_test("a.b.c.d");
- /* invalid fpr */
- bad_bridge_line_test("2.2.2.2:1231 4352e58420e68f5e40bf7c74faddccd9d1349");
- /* no k=v in the end */
- bad_bridge_line_test("obfs2 2.2.2.2:1231 "
- "4352e58420e68f5e40bf7c74faddccd9d1349413 what");
- /* no addrport */
- bad_bridge_line_test("asdw");
- /* huge k=v value that can't fit in SOCKS fields */
- bad_bridge_line_test(
- "obfs2 2.2.2.2:1231 aaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaa"
- "aaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaa"
- "aaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaa"
- "aaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaa"
- "aaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaa"
- "aaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaa"
- "aaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaa"
- "aaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaa"
- "aa=b");
- }
- static void
- test_config_parse_transport_options_line(void *arg)
- {
- smartlist_t *options_sl = NULL, *sl_tmp = NULL;
- (void) arg;
- { /* too small line */
- options_sl = get_options_from_transport_options_line("valley", NULL);
- tt_ptr_op(options_sl, OP_EQ, NULL);
- }
- { /* no k=v values */
- options_sl = get_options_from_transport_options_line("hit it!", NULL);
- tt_ptr_op(options_sl, OP_EQ, NULL);
- }
- { /* correct line, but wrong transport specified */
- options_sl =
- get_options_from_transport_options_line("trebuchet k=v", "rook");
- tt_ptr_op(options_sl, OP_EQ, NULL);
- }
- { /* correct -- no transport specified */
- sl_tmp = smartlist_new();
- smartlist_add_asprintf(sl_tmp, "ladi=dadi");
- smartlist_add_asprintf(sl_tmp, "weliketo=party");
- options_sl =
- get_options_from_transport_options_line("rook ladi=dadi weliketo=party",
- NULL);
- tt_assert(options_sl);
- tt_assert(smartlist_strings_eq(options_sl, sl_tmp));
- SMARTLIST_FOREACH(sl_tmp, char *, s, tor_free(s));
- smartlist_free(sl_tmp);
- sl_tmp = NULL;
- SMARTLIST_FOREACH(options_sl, char *, s, tor_free(s));
- smartlist_free(options_sl);
- options_sl = NULL;
- }
- { /* correct -- correct transport specified */
- sl_tmp = smartlist_new();
- smartlist_add_asprintf(sl_tmp, "ladi=dadi");
- smartlist_add_asprintf(sl_tmp, "weliketo=party");
- options_sl =
- get_options_from_transport_options_line("rook ladi=dadi weliketo=party",
- "rook");
- tt_assert(options_sl);
- tt_assert(smartlist_strings_eq(options_sl, sl_tmp));
- SMARTLIST_FOREACH(sl_tmp, char *, s, tor_free(s));
- smartlist_free(sl_tmp);
- sl_tmp = NULL;
- SMARTLIST_FOREACH(options_sl, char *, s, tor_free(s));
- smartlist_free(options_sl);
- options_sl = NULL;
- }
- done:
- if (options_sl) {
- SMARTLIST_FOREACH(options_sl, char *, s, tor_free(s));
- smartlist_free(options_sl);
- }
- if (sl_tmp) {
- SMARTLIST_FOREACH(sl_tmp, char *, s, tor_free(s));
- smartlist_free(sl_tmp);
- }
- }
- /* Mocks needed for the compute_max_mem_in_queues test */
- static int get_total_system_memory_mock(size_t *mem_out);
- static size_t total_system_memory_output = 0;
- static int total_system_memory_return = 0;
- static int
- get_total_system_memory_mock(size_t *mem_out)
- {
- if (! mem_out)
- return -1;
- *mem_out = total_system_memory_output;
- return total_system_memory_return;
- }
- /* Mocks needed for the transport plugin line test */
- static void pt_kickstart_proxy_mock(const smartlist_t *transport_list,
- char **proxy_argv, int is_server);
- static int transport_add_from_config_mock(const tor_addr_t *addr,
- uint16_t port, const char *name,
- int socks_ver);
- static int transport_is_needed_mock(const char *transport_name);
- static int pt_kickstart_proxy_mock_call_count = 0;
- static int transport_add_from_config_mock_call_count = 0;
- static int transport_is_needed_mock_call_count = 0;
- static int transport_is_needed_mock_return = 0;
- static void
- pt_kickstart_proxy_mock(const smartlist_t *transport_list,
- char **proxy_argv, int is_server)
- {
- (void) transport_list;
- (void) proxy_argv;
- (void) is_server;
- /* XXXX check that args are as expected. */
- ++pt_kickstart_proxy_mock_call_count;
- free_execve_args(proxy_argv);
- }
- static int
- transport_add_from_config_mock(const tor_addr_t *addr,
- uint16_t port, const char *name,
- int socks_ver)
- {
- (void) addr;
- (void) port;
- (void) name;
- (void) socks_ver;
- /* XXXX check that args are as expected. */
- ++transport_add_from_config_mock_call_count;
- return 0;
- }
- static int
- transport_is_needed_mock(const char *transport_name)
- {
- (void) transport_name;
- /* XXXX check that arg is as expected. */
- ++transport_is_needed_mock_call_count;
- return transport_is_needed_mock_return;
- }
- /**
- * Test parsing for the ClientTransportPlugin and ServerTransportPlugin config
- * options.
- */
- static void
- test_config_parse_transport_plugin_line(void *arg)
- {
- (void)arg;
- or_options_t *options = get_options_mutable();
- int r, tmp;
- int old_pt_kickstart_proxy_mock_call_count;
- int old_transport_add_from_config_mock_call_count;
- int old_transport_is_needed_mock_call_count;
- /* Bad transport lines - too short */
- r = parse_transport_line(options, "bad", 1, 0);
- tt_int_op(r, OP_LT, 0);
- r = parse_transport_line(options, "bad", 1, 1);
- tt_int_op(r, OP_LT, 0);
- r = parse_transport_line(options, "bad bad", 1, 0);
- tt_int_op(r, OP_LT, 0);
- r = parse_transport_line(options, "bad bad", 1, 1);
- tt_int_op(r, OP_LT, 0);
- /* Test transport list parsing */
- r = parse_transport_line(options,
- "transport_1 exec /usr/bin/fake-transport", 1, 0);
- tt_int_op(r, OP_EQ, 0);
- r = parse_transport_line(options,
- "transport_1 exec /usr/bin/fake-transport", 1, 1);
- tt_int_op(r, OP_EQ, 0);
- r = parse_transport_line(options,
- "transport_1,transport_2 exec /usr/bin/fake-transport", 1, 0);
- tt_int_op(r, OP_EQ, 0);
- r = parse_transport_line(options,
- "transport_1,transport_2 exec /usr/bin/fake-transport", 1, 1);
- tt_int_op(r, OP_EQ, 0);
- /* Bad transport identifiers */
- r = parse_transport_line(options,
- "transport_* exec /usr/bin/fake-transport", 1, 0);
- tt_int_op(r, OP_LT, 0);
- r = parse_transport_line(options,
- "transport_* exec /usr/bin/fake-transport", 1, 1);
- tt_int_op(r, OP_LT, 0);
- /* Check SOCKS cases for client transport */
- r = parse_transport_line(options,
- "transport_1 socks4 1.2.3.4:567", 1, 0);
- tt_int_op(r, OP_EQ, 0);
- r = parse_transport_line(options,
- "transport_1 socks5 1.2.3.4:567", 1, 0);
- tt_int_op(r, OP_EQ, 0);
- /* Proxy case for server transport */
- r = parse_transport_line(options,
- "transport_1 proxy 1.2.3.4:567", 1, 1);
- tt_int_op(r, OP_EQ, 0);
- /* Multiple-transport error exit */
- r = parse_transport_line(options,
- "transport_1,transport_2 socks5 1.2.3.4:567", 1, 0);
- tt_int_op(r, OP_LT, 0);
- r = parse_transport_line(options,
- "transport_1,transport_2 proxy 1.2.3.4:567", 1, 1);
- tt_int_op(r, OP_LT, 0);
- /* No port error exit */
- r = parse_transport_line(options,
- "transport_1 socks5 1.2.3.4", 1, 0);
- tt_int_op(r, OP_LT, 0);
- r = parse_transport_line(options,
- "transport_1 proxy 1.2.3.4", 1, 1);
- tt_int_op(r, OP_LT, 0);
- /* Unparsable address error exit */
- r = parse_transport_line(options,
- "transport_1 socks5 1.2.3:6x7", 1, 0);
- tt_int_op(r, OP_LT, 0);
- r = parse_transport_line(options,
- "transport_1 proxy 1.2.3:6x7", 1, 1);
- tt_int_op(r, OP_LT, 0);
- /* "Strange {Client|Server}TransportPlugin field" error exit */
- r = parse_transport_line(options,
- "transport_1 foo bar", 1, 0);
- tt_int_op(r, OP_LT, 0);
- r = parse_transport_line(options,
- "transport_1 foo bar", 1, 1);
- tt_int_op(r, OP_LT, 0);
- /* No sandbox mode error exit */
- tmp = options->Sandbox;
- options->Sandbox = 1;
- r = parse_transport_line(options,
- "transport_1 exec /usr/bin/fake-transport", 1, 0);
- tt_int_op(r, OP_LT, 0);
- r = parse_transport_line(options,
- "transport_1 exec /usr/bin/fake-transport", 1, 1);
- tt_int_op(r, OP_LT, 0);
- options->Sandbox = tmp;
- /*
- * These final test cases cover code paths that only activate without
- * validate_only, so they need mocks in place.
- */
- MOCK(pt_kickstart_proxy, pt_kickstart_proxy_mock);
- old_pt_kickstart_proxy_mock_call_count =
- pt_kickstart_proxy_mock_call_count;
- r = parse_transport_line(options,
- "transport_1 exec /usr/bin/fake-transport", 0, 1);
- tt_int_op(r, OP_EQ, 0);
- tt_assert(pt_kickstart_proxy_mock_call_count ==
- old_pt_kickstart_proxy_mock_call_count + 1);
- UNMOCK(pt_kickstart_proxy);
- /* This one hits a log line in the !validate_only case only */
- r = parse_transport_line(options,
- "transport_1 proxy 1.2.3.4:567", 0, 1);
- tt_int_op(r, OP_EQ, 0);
- /* Check mocked client transport cases */
- MOCK(pt_kickstart_proxy, pt_kickstart_proxy_mock);
- MOCK(transport_add_from_config, transport_add_from_config_mock);
- MOCK(transport_is_needed, transport_is_needed_mock);
- /* Unnecessary transport case */
- transport_is_needed_mock_return = 0;
- old_pt_kickstart_proxy_mock_call_count =
- pt_kickstart_proxy_mock_call_count;
- old_transport_add_from_config_mock_call_count =
- transport_add_from_config_mock_call_count;
- old_transport_is_needed_mock_call_count =
- transport_is_needed_mock_call_count;
- r = parse_transport_line(options,
- "transport_1 exec /usr/bin/fake-transport", 0, 0);
- /* Should have succeeded */
- tt_int_op(r, OP_EQ, 0);
- /* transport_is_needed() should have been called */
- tt_assert(transport_is_needed_mock_call_count ==
- old_transport_is_needed_mock_call_count + 1);
- /*
- * pt_kickstart_proxy() and transport_add_from_config() should
- * not have been called.
- */
- tt_assert(pt_kickstart_proxy_mock_call_count ==
- old_pt_kickstart_proxy_mock_call_count);
- tt_assert(transport_add_from_config_mock_call_count ==
- old_transport_add_from_config_mock_call_count);
- /* Necessary transport case */
- transport_is_needed_mock_return = 1;
- old_pt_kickstart_proxy_mock_call_count =
- pt_kickstart_proxy_mock_call_count;
- old_transport_add_from_config_mock_call_count =
- transport_add_from_config_mock_call_count;
- old_transport_is_needed_mock_call_count =
- transport_is_needed_mock_call_count;
- r = parse_transport_line(options,
- "transport_1 exec /usr/bin/fake-transport", 0, 0);
- /* Should have succeeded */
- tt_int_op(r, OP_EQ, 0);
- /*
- * transport_is_needed() and pt_kickstart_proxy() should have been
- * called.
- */
- tt_assert(pt_kickstart_proxy_mock_call_count ==
- old_pt_kickstart_proxy_mock_call_count + 1);
- tt_assert(transport_is_needed_mock_call_count ==
- old_transport_is_needed_mock_call_count + 1);
- /* transport_add_from_config() should not have been called. */
- tt_assert(transport_add_from_config_mock_call_count ==
- old_transport_add_from_config_mock_call_count);
- /* proxy case */
- transport_is_needed_mock_return = 1;
- old_pt_kickstart_proxy_mock_call_count =
- pt_kickstart_proxy_mock_call_count;
- old_transport_add_from_config_mock_call_count =
- transport_add_from_config_mock_call_count;
- old_transport_is_needed_mock_call_count =
- transport_is_needed_mock_call_count;
- r = parse_transport_line(options,
- "transport_1 socks5 1.2.3.4:567", 0, 0);
- /* Should have succeeded */
- tt_int_op(r, OP_EQ, 0);
- /*
- * transport_is_needed() and transport_add_from_config() should have
- * been called.
- */
- tt_assert(transport_add_from_config_mock_call_count ==
- old_transport_add_from_config_mock_call_count + 1);
- tt_assert(transport_is_needed_mock_call_count ==
- old_transport_is_needed_mock_call_count + 1);
- /* pt_kickstart_proxy() should not have been called. */
- tt_assert(pt_kickstart_proxy_mock_call_count ==
- old_pt_kickstart_proxy_mock_call_count);
- /* Done with mocked client transport cases */
- UNMOCK(transport_is_needed);
- UNMOCK(transport_add_from_config);
- UNMOCK(pt_kickstart_proxy);
- done:
- /* Make sure we undo all mocks */
- UNMOCK(pt_kickstart_proxy);
- UNMOCK(transport_add_from_config);
- UNMOCK(transport_is_needed);
- return;
- }
- // Tests if an options with MyFamily fingerprints missing '$' normalises
- // them correctly and also ensure it also works with multiple fingerprints
- static void
- test_config_fix_my_family(void *arg)
- {
- char *err = NULL;
- config_line_t *family = tor_malloc_zero(sizeof(config_line_t));
- family->key = tor_strdup("MyFamily");
- family->value = tor_strdup("$1111111111111111111111111111111111111111, "
- "1111111111111111111111111111111111111112, "
- "$1111111111111111111111111111111111111113");
- config_line_t *family2 = tor_malloc_zero(sizeof(config_line_t));
- family2->key = tor_strdup("MyFamily");
- family2->value = tor_strdup("1111111111111111111111111111111111111114");
- config_line_t *family3 = tor_malloc_zero(sizeof(config_line_t));
- family3->key = tor_strdup("MyFamily");
- family3->value = tor_strdup("$1111111111111111111111111111111111111115");
- family->next = family2;
- family2->next = family3;
- family3->next = NULL;
- or_options_t* options = options_new();
- or_options_t* defaults = options_new();
- (void) arg;
- options_init(options);
- options_init(defaults);
- options->MyFamily_lines = family;
- options_validate(NULL, options, defaults, 0, &err) ;
- if (err != NULL) {
- TT_FAIL(("options_validate failed: %s", err));
- }
- const char *valid[] = { "$1111111111111111111111111111111111111111",
- "$1111111111111111111111111111111111111112",
- "$1111111111111111111111111111111111111113",
- "$1111111111111111111111111111111111111114",
- "$1111111111111111111111111111111111111115" };
- int ret_size = 0;
- config_line_t *ret;
- for (ret = options->MyFamily; ret && ret_size < 5; ret = ret->next) {
- tt_str_op(ret->value, OP_EQ, valid[ret_size]);
- ret_size++;
- }
- tt_int_op(ret_size, OP_EQ, 5);
- done:
- tor_free(err);
- or_options_free(options);
- or_options_free(defaults);
- }
- static int n_hostname_01010101 = 0;
- /** This mock function is meant to replace tor_lookup_hostname().
- * It answers with 1.1.1.1 as IP adddress that resulted from lookup.
- * This function increments <b>n_hostname_01010101</b> counter by one
- * every time it is called.
- */
- static int
- tor_lookup_hostname_01010101(const char *name, uint32_t *addr)
- {
- n_hostname_01010101++;
- if (name && addr) {
- *addr = ntohl(0x01010101);
- }
- return 0;
- }
- static int n_hostname_localhost = 0;
- /** This mock function is meant to replace tor_lookup_hostname().
- * It answers with 127.0.0.1 as IP adddress that resulted from lookup.
- * This function increments <b>n_hostname_localhost</b> counter by one
- * every time it is called.
- */
- static int
- tor_lookup_hostname_localhost(const char *name, uint32_t *addr)
- {
- n_hostname_localhost++;
- if (name && addr) {
- *addr = 0x7f000001;
- }
- return 0;
- }
- static int n_hostname_failure = 0;
- /** This mock function is meant to replace tor_lookup_hostname().
- * It pretends to fail by returning -1 to caller. Also, this function
- * increments <b>n_hostname_failure</b> every time it is called.
- */
- static int
- tor_lookup_hostname_failure(const char *name, uint32_t *addr)
- {
- (void)name;
- (void)addr;
- n_hostname_failure++;
- return -1;
- }
- static int n_gethostname_replacement = 0;
- /** This mock function is meant to replace tor_gethostname(). It
- * responds with string "onionrouter!" as hostname. This function
- * increments <b>n_gethostname_replacement</b> by one every time
- * it is called.
- */
- static int
- tor_gethostname_replacement(char *name, size_t namelen)
- {
- n_gethostname_replacement++;
- if (name && namelen) {
- strlcpy(name,"onionrouter!",namelen);
- }
- return 0;
- }
- static int n_gethostname_localhost = 0;
- /** This mock function is meant to replace tor_gethostname(). It
- * responds with string "127.0.0.1" as hostname. This function
- * increments <b>n_gethostname_localhost</b> by one every time
- * it is called.
- */
- static int
- tor_gethostname_localhost(char *name, size_t namelen)
- {
- n_gethostname_localhost++;
- if (name && namelen) {
- strlcpy(name,"127.0.0.1",namelen);
- }
- return 0;
- }
- static int n_gethostname_failure = 0;
- /** This mock function is meant to replace tor_gethostname.
- * It pretends to fail by returning -1. This function increments
- * <b>n_gethostname_failure</b> by one every time it is called.
- */
- static int
- tor_gethostname_failure(char *name, size_t namelen)
- {
- (void)name;
- (void)namelen;
- n_gethostname_failure++;
- return -1;
- }
- static int n_get_interface_address = 0;
- /** This mock function is meant to replace get_interface_address().
- * It answers with address 8.8.8.8. This function increments
- * <b>n_get_interface_address</b> by one every time it is called.
- */
- static int
- get_interface_address_08080808(int severity, uint32_t *addr)
- {
- (void)severity;
- n_get_interface_address++;
- if (addr) {
- *addr = ntohl(0x08080808);
- }
- return 0;
- }
- static int n_get_interface_address6 = 0;
- static sa_family_t last_address6_family;
- /** This mock function is meant to replace get_interface_address6().
- * It answers with IP address 9.9.9.9 iff both of the following are true:
- * - <b>family</b> is AF_INET
- * - <b>addr</b> pointer is not NULL.
- * This function increments <b>n_get_interface_address6</b> by one every
- * time it is called.
- */
- static int
- get_interface_address6_replacement(int severity, sa_family_t family,
- tor_addr_t *addr)
- {
- (void)severity;
- last_address6_family = family;
- n_get_interface_address6++;
- if ((family != AF_INET) || !addr) {
- return -1;
- }
- tor_addr_from_ipv4h(addr,0x09090909);
- return 0;
- }
- static int n_get_interface_address_failure = 0;
- /**
- * This mock function is meant to replace get_interface_address().
- * It pretends to fail getting interface address by returning -1.
- * <b>n_get_interface_address_failure</b> is incremented by one
- * every time this function is called.
- */
- static int
- get_interface_address_failure(int severity, uint32_t *addr)
- {
- (void)severity;
- (void)addr;
- n_get_interface_address_failure++;
- return -1;
- }
- static int n_get_interface_address6_failure = 0;
- /**
- * This mock function is meant to replace get_interface_addres6().
- * It will pretend to fail by return -1.
- * <b>n_get_interface_address6_failure</b> is incremented by one
- * every time this function is called and <b>last_address6_family</b>
- * is assigned the value of <b>family</b> argument.
- */
- static int
- get_interface_address6_failure(int severity, sa_family_t family,
- tor_addr_t *addr)
- {
- (void)severity;
- (void)addr;
- n_get_interface_address6_failure++;
- last_address6_family = family;
- return -1;
- }
- static void
- test_config_resolve_my_address(void *arg)
- {
- or_options_t *options;
- uint32_t resolved_addr;
- const char *method_used;
- char *hostname_out = NULL;
- int retval;
- int prev_n_hostname_01010101;
- int prev_n_hostname_localhost;
- int prev_n_hostname_failure;
- int prev_n_gethostname_replacement;
- int prev_n_gethostname_failure;
- int prev_n_gethostname_localhost;
- int prev_n_get_interface_address;
- int prev_n_get_interface_address_failure;
- int prev_n_get_interface_address6;
- int prev_n_get_interface_address6_failure;
- (void)arg;
- options = options_new();
- options_init(options);
- /*
- * CASE 1:
- * If options->Address is a valid IPv4 address string, we want
- * the corresponding address to be parsed and returned.
- */
- options->Address = tor_strdup("128.52.128.105");
- retval = resolve_my_address(LOG_NOTICE,options,&resolved_addr,
- &method_used,&hostname_out);
- tt_want(retval == 0);
- tt_want_str_op(method_used,OP_EQ,"CONFIGURED");
- tt_want(hostname_out == NULL);
- tt_assert(resolved_addr == 0x80348069);
- tor_free(options->Address);
- /*
- * CASE 2:
- * If options->Address is a valid DNS address, we want resolve_my_address()
- * function to ask tor_lookup_hostname() for help with resolving it
- * and return the address that was resolved (in host order).
- */
- MOCK(tor_lookup_hostname,tor_lookup_hostname_01010101);
- tor_free(options->Address);
- options->Address = tor_strdup("www.torproject.org");
- prev_n_hostname_01010101 = n_hostname_01010101;
- retval = resolve_my_address(LOG_NOTICE,options,&resolved_addr,
- &method_used,&hostname_out);
- tt_want(retval == 0);
- tt_want(n_hostname_01010101 == prev_n_hostname_01010101 + 1);
- tt_want_str_op(method_used,OP_EQ,"RESOLVED");
- tt_want_str_op(hostname_out,OP_EQ,"www.torproject.org");
- tt_assert(resolved_addr == 0x01010101);
- UNMOCK(tor_lookup_hostname);
- tor_free(options->Address);
- tor_free(hostname_out);
- /*
- * CASE 3:
- * Given that options->Address is NULL, we want resolve_my_address()
- * to try and use tor_gethostname() to get hostname AND use
- * tor_lookup_hostname() to get IP address.
- */
- resolved_addr = 0;
- tor_free(options->Address);
- options->Address = NULL;
- MOCK(tor_gethostname,tor_gethostname_replacement);
- MOCK(tor_lookup_hostname,tor_lookup_hostname_01010101);
- prev_n_gethostname_replacement = n_gethostname_replacement;
- prev_n_hostname_01010101 = n_hostname_01010101;
- retval = resolve_my_address(LOG_NOTICE,options,&resolved_addr,
- &method_used,&hostname_out);
- tt_want(retval == 0);
- tt_want(n_gethostname_replacement == prev_n_gethostname_replacement + 1);
- tt_want(n_hostname_01010101 == prev_n_hostname_01010101 + 1);
- tt_want_str_op(method_used,OP_EQ,"GETHOSTNAME");
- tt_want_str_op(hostname_out,OP_EQ,"onionrouter!");
- tt_assert(resolved_addr == 0x01010101);
- UNMOCK(tor_gethostname);
- UNMOCK(tor_lookup_hostname);
- tor_free(hostname_out);
- /*
- * CASE 4:
- * Given that options->Address is a local host address, we want
- * resolve_my_address() function to fail.
- */
- resolved_addr = 0;
- tor_free(options->Address);
- options->Address = tor_strdup("127.0.0.1");
- retval = resolve_my_address(LOG_NOTICE,options,&resolved_addr,
- &method_used,&hostname_out);
- tt_want(resolved_addr == 0);
- tt_int_op(retval, OP_EQ, -1);
- tor_free(options->Address);
- tor_free(hostname_out);
- /*
- * CASE 5:
- * We want resolve_my_address() to fail if DNS address in options->Address
- * cannot be resolved.
- */
- MOCK(tor_lookup_hostname,tor_lookup_hostname_failure);
- prev_n_hostname_failure = n_hostname_failure;
- tor_free(options->Address);
- options->Address = tor_strdup("www.tor-project.org");
- retval = resolve_my_address(LOG_NOTICE,options,&resolved_addr,
- &method_used,&hostname_out);
- tt_want(n_hostname_failure == prev_n_hostname_failure + 1);
- tt_int_op(retval, OP_EQ, -1);
- UNMOCK(tor_lookup_hostname);
- tor_free(options->Address);
- tor_free(hostname_out);
- /*
- * CASE 6:
- * If options->Address is NULL AND gettting local hostname fails, we want
- * resolve_my_address() to fail as well.
- */
- MOCK(tor_gethostname,tor_gethostname_failure);
- prev_n_gethostname_failure = n_gethostname_failure;
- retval = resolve_my_address(LOG_NOTICE,options,&resolved_addr,
- &method_used,&hostname_out);
- tt_want(n_gethostname_failure == prev_n_gethostname_failure + 1);
- tt_int_op(retval, OP_EQ, -1);
- UNMOCK(tor_gethostname);
- tor_free(hostname_out);
- /*
- * CASE 7:
- * We want resolve_my_address() to try and get network interface address via
- * get_interface_address() if hostname returned by tor_gethostname() cannot be
- * resolved into IP address.
- */
- MOCK(tor_gethostname,tor_gethostname_replacement);
- MOCK(tor_lookup_hostname,tor_lookup_hostname_failure);
- MOCK(get_interface_address,get_interface_address_08080808);
- prev_n_gethostname_replacement = n_gethostname_replacement;
- prev_n_get_interface_address = n_get_interface_address;
- retval = resolve_my_address(LOG_NOTICE,options,&resolved_addr,
- &method_used,&hostname_out);
- tt_want(retval == 0);
- tt_want_int_op(n_gethostname_replacement, OP_EQ,
- prev_n_gethostname_replacement + 1);
- tt_want_int_op(n_get_interface_address, OP_EQ,
- prev_n_get_interface_address + 1);
- tt_want_str_op(method_used,OP_EQ,"INTERFACE");
- tt_want(hostname_out == NULL);
- tt_assert(resolved_addr == 0x08080808);
- UNMOCK(get_interface_address);
- tor_free(hostname_out);
- /*
- * CASE 8:
- * Suppose options->Address is NULL AND hostname returned by tor_gethostname()
- * is unresolvable. We want resolve_my_address to fail if
- * get_interface_address() fails.
- */
- MOCK(get_interface_address,get_interface_address_failure);
- prev_n_get_interface_address_failure = n_get_interface_address_failure;
- prev_n_gethostname_replacement = n_gethostname_replacement;
- retval = resolve_my_address(LOG_NOTICE,options,&resolved_addr,
- &method_used,&hostname_out);
- tt_want(n_get_interface_address_failure ==
- prev_n_get_interface_address_failure + 1);
- tt_want(n_gethostname_replacement ==
- prev_n_gethostname_replacement + 1);
- tt_int_op(retval, OP_EQ, -1);
- UNMOCK(get_interface_address);
- tor_free(hostname_out);
- /*
- * CASE 9:
- * Given that options->Address is NULL AND tor_lookup_hostname()
- * fails AND hostname returned by gethostname() resolves
- * to local IP address, we want resolve_my_address() function to
- * call get_interface_address6(.,AF_INET,.) and return IP address
- * the latter function has found.
- */
- MOCK(tor_lookup_hostname,tor_lookup_hostname_failure);
- MOCK(tor_gethostname,tor_gethostname_replacement);
- MOCK(get_interface_address6,get_interface_address6_replacement);
- prev_n_gethostname_replacement = n_gethostname_replacement;
- prev_n_hostname_failure = n_hostname_failure;
- prev_n_get_interface_address6 = n_get_interface_address6;
- retval = resolve_my_address(LOG_NOTICE,options,&resolved_addr,
- &method_used,&hostname_out);
- tt_want(last_address6_family == AF_INET);
- tt_want(n_get_interface_address6 == prev_n_get_interface_address6 + 1);
- tt_want(n_hostname_failure == prev_n_hostname_failure + 1);
- tt_want(n_gethostname_replacement == prev_n_gethostname_replacement + 1);
- tt_want(retval == 0);
- tt_want_str_op(method_used,OP_EQ,"INTERFACE");
- tt_assert(resolved_addr == 0x09090909);
- UNMOCK(tor_lookup_hostname);
- UNMOCK(tor_gethostname);
- UNMOCK(get_interface_address6);
- tor_free(hostname_out);
- /*
- * CASE 10: We want resolve_my_address() to fail if all of the following
- * are true:
- * 1. options->Address is not NULL
- * 2. ... but it cannot be converted to struct in_addr by
- * tor_inet_aton()
- * 3. ... and tor_lookup_hostname() fails to resolve the
- * options->Address
- */
- MOCK(tor_lookup_hostname,tor_lookup_hostname_failure);
- prev_n_hostname_failure = n_hostname_failure;
- tor_free(options->Address);
- options->Address = tor_strdup("some_hostname");
- retval = resolve_my_address(LOG_NOTICE, options, &resolved_addr,
- &method_used,&hostname_out);
- tt_want(n_hostname_failure == prev_n_hostname_failure + 1);
- tt_int_op(retval, OP_EQ, -1);
- UNMOCK(tor_gethostname);
- UNMOCK(tor_lookup_hostname);
- tor_free(hostname_out);
- /*
- * CASE 11:
- * Suppose the following sequence of events:
- * 1. options->Address is NULL
- * 2. tor_gethostname() succeeds to get hostname of machine Tor
- * if running on.
- * 3. Hostname from previous step cannot be converted to
- * address by using tor_inet_aton() function.
- * 4. However, tor_lookup_hostname() succeeds in resolving the
- * hostname from step 2.
- * 5. Unfortunately, tor_addr_is_internal() deems this address
- * to be internal.
- * 6. get_interface_address6(.,AF_INET,.) returns non-internal
- * IPv4
- *
- * We want resolve_my_addr() to succeed with method "INTERFACE"
- * and address from step 6.
- */
- tor_free(options->Address);
- options->Address = NULL;
- MOCK(tor_gethostname,tor_gethostname_replacement);
- MOCK(tor_lookup_hostname,tor_lookup_hostname_localhost);
- MOCK(get_interface_address6,get_interface_address6_replacement);
- prev_n_gethostname_replacement = n_gethostname_replacement;
- prev_n_hostname_localhost = n_hostname_localhost;
- prev_n_get_interface_address6 = n_get_interface_address6;
- retval = resolve_my_address(LOG_DEBUG, options, &resolved_addr,
- &method_used,&hostname_out);
- tt_want(n_gethostname_replacement == prev_n_gethostname_replacement + 1);
- tt_want(n_hostname_localhost == prev_n_hostname_localhost + 1);
- tt_want(n_get_interface_address6 == prev_n_get_interface_address6 + 1);
- tt_str_op(method_used,OP_EQ,"INTERFACE");
- tt_ptr_op(hostname_out, OP_EQ, NULL);
- tt_int_op(retval, OP_EQ, 0);
- /*
- * CASE 11b:
- * 1-5 as above.
- * 6. get_interface_address6() fails.
- *
- * In this subcase, we want resolve_my_address() to fail.
- */
- UNMOCK(get_interface_address6);
- MOCK(get_interface_address6,get_interface_address6_failure);
- prev_n_gethostname_replacement = n_gethostname_replacement;
- prev_n_hostname_localhost = n_hostname_localhost;
- prev_n_get_interface_address6_failure = n_get_interface_address6_failure;
- retval = resolve_my_address(LOG_DEBUG, options, &resolved_addr,
- &method_used,&hostname_out);
- tt_want(n_gethostname_replacement == prev_n_gethostname_replacement + 1);
- tt_want(n_hostname_localhost == prev_n_hostname_localhost + 1);
- tt_want(n_get_interface_address6_failure ==
- prev_n_get_interface_address6_failure + 1);
- tt_int_op(retval, OP_EQ, -1);
- UNMOCK(tor_gethostname);
- UNMOCK(tor_lookup_hostname);
- UNMOCK(get_interface_address6);
- /* CASE 12:
- * Suppose the following happens:
- * 1. options->Address is NULL AND options->DirAuthorities is non-NULL
- * 2. tor_gethostname() succeeds in getting hostname of a machine ...
- * 3. ... which is successfully parsed by tor_inet_aton() ...
- * 4. into IPv4 address that tor_addr_is_inernal() considers to be
- * internal.
- *
- * In this case, we want resolve_my_address() to fail.
- */
- tor_free(options->Address);
- options->Address = NULL;
- options->DirAuthorities = tor_malloc_zero(sizeof(config_line_t));
- MOCK(tor_gethostname,tor_gethostname_localhost);
- prev_n_gethostname_localhost = n_gethostname_localhost;
- retval = resolve_my_address(LOG_DEBUG, options, &resolved_addr,
- &method_used,&hostname_out);
- tt_want(n_gethostname_localhost == prev_n_gethostname_localhost + 1);
- tt_int_op(retval, OP_EQ, -1);
- UNMOCK(tor_gethostname);
- done:
- tor_free(options->Address);
- tor_free(options->DirAuthorities);
- or_options_free(options);
- tor_free(hostname_out);
- UNMOCK(tor_gethostname);
- UNMOCK(tor_lookup_hostname);
- UNMOCK(get_interface_address);
- UNMOCK(get_interface_address6);
- UNMOCK(tor_gethostname);
- }
- static void
- test_config_adding_trusted_dir_server(void *arg)
- {
- (void)arg;
- const char digest[DIGEST_LEN] = "";
- dir_server_t *ds = NULL;
- tor_addr_port_t ipv6;
- int rv = -1;
- clear_dir_servers();
- routerlist_free_all();
- /* create a trusted ds without an IPv6 address and port */
- ds = trusted_dir_server_new("ds", "127.0.0.1", 9059, 9060, NULL, digest,
- NULL, V3_DIRINFO, 1.0);
- tt_assert(ds);
- dir_server_add(ds);
- tt_int_op(get_n_authorities(V3_DIRINFO), OP_EQ, 1);
- tt_int_op(smartlist_len(router_get_fallback_dir_servers()), OP_EQ, 1);
- /* create a trusted ds with an IPv6 address and port */
- rv = tor_addr_port_parse(LOG_WARN, "[::1]:9061", &ipv6.addr, &ipv6.port, -1);
- tt_int_op(rv, OP_EQ, 0);
- ds = trusted_dir_server_new("ds", "127.0.0.1", 9059, 9060, &ipv6, digest,
- NULL, V3_DIRINFO, 1.0);
- tt_assert(ds);
- dir_server_add(ds);
- tt_int_op(get_n_authorities(V3_DIRINFO), OP_EQ, 2);
- tt_int_op(smartlist_len(router_get_fallback_dir_servers()), OP_EQ, 2);
- done:
- clear_dir_servers();
- routerlist_free_all();
- }
- static void
- test_config_adding_fallback_dir_server(void *arg)
- {
- (void)arg;
- const char digest[DIGEST_LEN] = "";
- dir_server_t *ds = NULL;
- tor_addr_t ipv4;
- tor_addr_port_t ipv6;
- int rv = -1;
- clear_dir_servers();
- routerlist_free_all();
- rv = tor_addr_parse(&ipv4, "127.0.0.1");
- tt_int_op(rv, OP_EQ, AF_INET);
- /* create a trusted ds without an IPv6 address and port */
- ds = fallback_dir_server_new(&ipv4, 9059, 9060, NULL, digest, 1.0);
- tt_assert(ds);
- dir_server_add(ds);
- tt_int_op(smartlist_len(router_get_fallback_dir_servers()), OP_EQ, 1);
- /* create a trusted ds with an IPv6 address and port */
- rv = tor_addr_port_parse(LOG_WARN, "[::1]:9061", &ipv6.addr, &ipv6.port, -1);
- tt_int_op(rv, OP_EQ, 0);
- ds = fallback_dir_server_new(&ipv4, 9059, 9060, &ipv6, digest, 1.0);
- tt_assert(ds);
- dir_server_add(ds);
- tt_int_op(smartlist_len(router_get_fallback_dir_servers()), OP_EQ, 2);
- done:
- clear_dir_servers();
- routerlist_free_all();
- }
- /* No secrets here:
- * v3ident is `echo "onion" | shasum | cut -d" " -f1 | tr "a-f" "A-F"`
- * fingerprint is `echo "unionem" | shasum | cut -d" " -f1 | tr "a-f" "A-F"`
- * with added spaces
- */
- #define TEST_DIR_AUTH_LINE_START \
- "foobar orport=12345 " \
- "v3ident=14C131DFC5C6F93646BE72FA1401C02A8DF2E8B4 "
- #define TEST_DIR_AUTH_LINE_END \
- "1.2.3.4:54321 " \
- "FDB2 FBD2 AAA5 25FA 2999 E617 5091 5A32 C777 3B17"
- #define TEST_DIR_AUTH_IPV6_FLAG \
- "ipv6=[feed::beef]:9 "
- static void
- test_config_parsing_trusted_dir_server(void *arg)
- {
- (void)arg;
- int rv = -1;
- /* parse a trusted dir server without an IPv6 address and port */
- rv = parse_dir_authority_line(TEST_DIR_AUTH_LINE_START
- TEST_DIR_AUTH_LINE_END,
- V3_DIRINFO, 1);
- tt_int_op(rv, OP_EQ, 0);
- /* parse a trusted dir server with an IPv6 address and port */
- rv = parse_dir_authority_line(TEST_DIR_AUTH_LINE_START
- TEST_DIR_AUTH_IPV6_FLAG
- TEST_DIR_AUTH_LINE_END,
- V3_DIRINFO, 1);
- tt_int_op(rv, OP_EQ, 0);
- /* Since we are only validating, there is no cleanup. */
- done:
- ;
- }
- #undef TEST_DIR_AUTH_LINE_START
- #undef TEST_DIR_AUTH_LINE_END
- #undef TEST_DIR_AUTH_IPV6_FLAG
- /* No secrets here:
- * id is `echo "syn-propanethial-S-oxide" | shasum | cut -d" " -f1`
- */
- #define TEST_DIR_FALLBACK_LINE \
- "1.2.3.4:54321 orport=12345 " \
- "id=50e643986f31ea1235bcc1af17a1c5c5cfc0ee54 "
- #define TEST_DIR_FALLBACK_IPV6_FLAG \
- "ipv6=[2015:c0de::deed]:9"
- static void
- test_config_parsing_fallback_dir_server(void *arg)
- {
- (void)arg;
- int rv = -1;
- /* parse a trusted dir server without an IPv6 address and port */
- rv = parse_dir_fallback_line(TEST_DIR_FALLBACK_LINE, 1);
- tt_int_op(rv, OP_EQ, 0);
- /* parse a trusted dir server with an IPv6 address and port */
- rv = parse_dir_fallback_line(TEST_DIR_FALLBACK_LINE
- TEST_DIR_FALLBACK_IPV6_FLAG,
- 1);
- tt_int_op(rv, OP_EQ, 0);
- /* Since we are only validating, there is no cleanup. */
- done:
- ;
- }
- #undef TEST_DIR_FALLBACK_LINE
- #undef TEST_DIR_FALLBACK_IPV6_FLAG
- static void
- test_config_adding_default_trusted_dir_servers(void *arg)
- {
- (void)arg;
- clear_dir_servers();
- routerlist_free_all();
- /* Assume we only have one bridge authority */
- add_default_trusted_dir_authorities(BRIDGE_DIRINFO);
- tt_int_op(get_n_authorities(BRIDGE_DIRINFO), OP_EQ, 1);
- tt_int_op(smartlist_len(router_get_fallback_dir_servers()), OP_EQ, 1);
- /* Assume we have eight V3 authorities */
- add_default_trusted_dir_authorities(V3_DIRINFO);
- tt_int_op(get_n_authorities(V3_DIRINFO), OP_EQ, 9);
- tt_int_op(smartlist_len(router_get_fallback_dir_servers()), OP_EQ, 10);
- done:
- clear_dir_servers();
- routerlist_free_all();
- }
- static int n_add_default_fallback_dir_servers_known_default = 0;
- /**
- * This mock function is meant to replace add_default_fallback_dir_servers().
- * It will parse and add one known default fallback dir server,
- * which has a dir_port of 99.
- * <b>n_add_default_fallback_dir_servers_known_default</b> is incremented by
- * one every time this function is called.
- */
- static void
- add_default_fallback_dir_servers_known_default(void)
- {
- int i;
- const char *fallback[] = {
- "127.0.0.1:60099 orport=9009 "
- "id=0923456789012345678901234567890123456789",
- NULL
- };
- for (i=0; fallback[i]; i++) {
- if (parse_dir_fallback_line(fallback[i], 0)<0) {
- log_err(LD_BUG, "Couldn't parse internal FallbackDir line %s",
- fallback[i]);
- }
- }
- n_add_default_fallback_dir_servers_known_default++;
- }
- /* Test all the different combinations of adding dir servers */
- static void
- test_config_adding_dir_servers(void *arg)
- {
- (void)arg;
- /* allocate options */
- or_options_t *options = tor_malloc_zero(sizeof(or_options_t));
- /* Allocate and populate configuration lines:
- *
- * Use the same format as the hard-coded directories in
- * add_default_trusted_dir_authorities().
- * Zeroing the structure has the same effect as initialising to:
- * { NULL, NULL, NULL, CONFIG_LINE_NORMAL, 0};
- */
- config_line_t *test_dir_authority = tor_malloc_zero(sizeof(config_line_t));
- test_dir_authority->key = tor_strdup("DirAuthority");
- test_dir_authority->value = tor_strdup(
- "D0 orport=9000 "
- "v3ident=0023456789012345678901234567890123456789 "
- "127.0.0.1:60090 0123 4567 8901 2345 6789 0123 4567 8901 2345 6789"
- );
- config_line_t *test_alt_bridge_authority = tor_malloc_zero(
- sizeof(config_line_t));
- test_alt_bridge_authority->key = tor_strdup("AlternateBridgeAuthority");
- test_alt_bridge_authority->value = tor_strdup(
- "B1 orport=9001 bridge "
- "127.0.0.1:60091 1123 4567 8901 2345 6789 0123 4567 8901 2345 6789"
- );
- config_line_t *test_alt_dir_authority = tor_malloc_zero(
- sizeof(config_line_t));
- test_alt_dir_authority->key = tor_strdup("AlternateDirAuthority");
- test_alt_dir_authority->value = tor_strdup(
- "A2 orport=9002 "
- "v3ident=0223456789012345678901234567890123456789 "
- "127.0.0.1:60092 2123 4567 8901 2345 6789 0123 4567 8901 2345 6789"
- );
- /* Use the format specified in the manual page */
- config_line_t *test_fallback_directory = tor_malloc_zero(
- sizeof(config_line_t));
- test_fallback_directory->key = tor_strdup("FallbackDir");
- test_fallback_directory->value = tor_strdup(
- "127.0.0.1:60093 orport=9003 id=0323456789012345678901234567890123456789"
- );
- /* We need to know if add_default_fallback_dir_servers is called,
- * whatever the size of the list in fallback_dirs.inc,
- * so we use a version of add_default_fallback_dir_servers that adds
- * one known default fallback directory. */
- MOCK(add_default_fallback_dir_servers,
- add_default_fallback_dir_servers_known_default);
- /* There are 16 different cases, covering each combination of set/NULL for:
- * DirAuthorities, AlternateBridgeAuthority, AlternateDirAuthority &
- * FallbackDir. (We always set UseDefaultFallbackDirs to 1.)
- * But validate_dir_servers() ensures that:
- * "You cannot set both DirAuthority and Alternate*Authority."
- * This reduces the number of cases to 10.
- *
- * Let's count these cases using binary, with 1 meaning set & 0 meaning NULL
- * So 1001 or case 9 is:
- * DirAuthorities set,
- * AlternateBridgeAuthority NULL,
- * AlternateDirAuthority NULL
- * FallbackDir set
- * The valid cases are cases 0-9 counting using this method, as every case
- * greater than or equal to 10 = 1010 is invalid.
- *
- * 1. Outcome: Use Set Directory Authorities
- * - No Default Authorities
- * - Use AlternateBridgeAuthority, AlternateDirAuthority, and FallbackDir
- * if they are set
- * Cases expected to yield this outcome:
- * 8 & 9 (the 2 valid cases where DirAuthorities is set)
- * 6 & 7 (the 2 cases where DirAuthorities is NULL, and
- * AlternateBridgeAuthority and AlternateDirAuthority are both set)
- *
- * 2. Outcome: Use Set Bridge Authority
- * - Use Default Non-Bridge Directory Authorities
- * - Use FallbackDir if it is set, otherwise use default FallbackDir
- * Cases expected to yield this outcome:
- * 4 & 5 (the 2 cases where DirAuthorities is NULL,
- * AlternateBridgeAuthority is set, and
- * AlternateDirAuthority is NULL)
- *
- * 3. Outcome: Use Set Alternate Directory Authority
- * - Use Default Bridge Authorities
- * - Use FallbackDir if it is set, otherwise No Default Fallback Directories
- * Cases expected to yield this outcome:
- * 2 & 3 (the 2 cases where DirAuthorities and AlternateBridgeAuthority
- * are both NULL, but AlternateDirAuthority is set)
- *
- * 4. Outcome: Use Set Custom Fallback Directory
- * - Use Default Bridge & Directory Authorities
- * Cases expected to yield this outcome:
- * 1 (DirAuthorities, AlternateBridgeAuthority and AlternateDirAuthority
- * are all NULL, but FallbackDir is set)
- *
- * 5. Outcome: Use All Defaults
- * - Use Default Bridge & Directory Authorities, and
- * Default Fallback Directories
- * Cases expected to yield this outcome:
- * 0 (DirAuthorities, AlternateBridgeAuthority, AlternateDirAuthority
- * and FallbackDir are all NULL)
- */
- /*
- * Find out how many default Bridge, Non-Bridge and Fallback Directories
- * are hard-coded into this build.
- * This code makes some assumptions about the implementation.
- * If they are wrong, one or more of cases 0-5 could fail.
- */
- int n_default_alt_bridge_authority = 0;
- int n_default_alt_dir_authority = 0;
- int n_default_fallback_dir = 0;
- #define n_default_authorities ((n_default_alt_bridge_authority) \
- + (n_default_alt_dir_authority))
- /* Pre-Count Number of Authorities of Each Type
- * Use 0000: No Directory Authorities or Fallback Directories Set
- */
- {
- /* clear fallback dirs counter */
- n_add_default_fallback_dir_servers_known_default = 0;
- /* clear options*/
- memset(options, 0, sizeof(or_options_t));
- /* clear any previous dir servers:
- consider_adding_dir_servers() should do this anyway */
- clear_dir_servers();
- /* assign options: 0000 */
- options->DirAuthorities = NULL;
- options->AlternateBridgeAuthority = NULL;
- options->AlternateDirAuthority = NULL;
- options->FallbackDir = NULL;
- options->UseDefaultFallbackDirs = 1;
- /* parse options - ensure we always update by passing NULL old_options */
- consider_adding_dir_servers(options, NULL);
- /* check outcome */
- /* we must have added the default fallback dirs */
- tt_int_op(n_add_default_fallback_dir_servers_known_default, OP_EQ, 1);
- /* we have more fallbacks than just the authorities */
- tt_assert(networkstatus_consensus_can_use_extra_fallbacks(options) == 1);
- {
- /* fallback_dir_servers */
- const smartlist_t *fallback_servers = router_get_fallback_dir_servers();
- /* Count Bridge Authorities */
- SMARTLIST_FOREACH(fallback_servers,
- dir_server_t *,
- ds,
- /* increment the found counter if it's a bridge auth */
- n_default_alt_bridge_authority +=
- ((ds->is_authority && (ds->type & BRIDGE_DIRINFO)) ?
- 1 : 0)
- );
- /* If we have no default bridge authority, something has gone wrong */
- tt_int_op(n_default_alt_bridge_authority, OP_GE, 1);
- /* Count v3 Authorities */
- SMARTLIST_FOREACH(fallback_servers,
- dir_server_t *,
- ds,
- /* increment found counter if it's a v3 auth */
- n_default_alt_dir_authority +=
- ((ds->is_authority && (ds->type & V3_DIRINFO)) ?
- 1 : 0)
- );
- /* If we have no default authorities, something has gone really wrong */
- tt_int_op(n_default_alt_dir_authority, OP_GE, 1);
- /* Calculate Fallback Directory Count */
- n_default_fallback_dir = (smartlist_len(fallback_servers) -
- n_default_alt_bridge_authority -
- n_default_alt_dir_authority);
- /* If we have a negative count, something has gone really wrong,
- * or some authorities aren't being added as fallback directories.
- * (networkstatus_consensus_can_use_extra_fallbacks depends on all
- * authorities being fallback directories.) */
- tt_int_op(n_default_fallback_dir, OP_GE, 0);
- }
- }
- /*
- * 1. Outcome: Use Set Directory Authorities
- * - No Default Authorities
- * - Use AlternateBridgeAuthority, AlternateDirAuthority, and FallbackDir
- * if they are set
- * Cases expected to yield this outcome:
- * 8 & 9 (the 2 valid cases where DirAuthorities is set)
- * 6 & 7 (the 2 cases where DirAuthorities is NULL, and
- * AlternateBridgeAuthority and AlternateDirAuthority are both set)
- */
- /* Case 9: 1001 - DirAuthorities Set, AlternateBridgeAuthority Not Set,
- AlternateDirAuthority Not Set, FallbackDir Set */
- {
- /* clear fallback dirs counter */
- n_add_default_fallback_dir_servers_known_default = 0;
- /* clear options*/
- memset(options, 0, sizeof(or_options_t));
- /* clear any previous dir servers:
- consider_adding_dir_servers() should do this anyway */
- clear_dir_servers();
- /* assign options: 1001 */
- options->DirAuthorities = test_dir_authority;
- options->AlternateBridgeAuthority = NULL;
- options->AlternateDirAuthority = NULL;
- options->FallbackDir = test_fallback_directory;
- options->UseDefaultFallbackDirs = 1;
- /* parse options - ensure we always update by passing NULL old_options */
- consider_adding_dir_servers(options, NULL);
- /* check outcome */
- /* we must not have added the default fallback dirs */
- tt_int_op(n_add_default_fallback_dir_servers_known_default, OP_EQ, 0);
- /* we have more fallbacks than just the authorities */
- tt_assert(networkstatus_consensus_can_use_extra_fallbacks(options) == 1);
- {
- /* trusted_dir_servers */
- const smartlist_t *dir_servers = router_get_trusted_dir_servers();
- /* D0, (No B1), (No A2) */
- tt_int_op(smartlist_len(dir_servers), OP_EQ, 1);
- /* DirAuthority - D0 - dir_port: 60090 */
- int found_D0 = 0;
- SMARTLIST_FOREACH(dir_servers,
- dir_server_t *,
- ds,
- /* increment the found counter if dir_port matches */
- found_D0 +=
- (ds->dir_port == 60090 ?
- 1 : 0)
- );
- tt_int_op(found_D0, OP_EQ, 1);
- /* (No AlternateBridgeAuthority) - B1 - dir_port: 60091 */
- int found_B1 = 0;
- SMARTLIST_FOREACH(dir_servers,
- dir_server_t *,
- ds,
- /* increment the found counter if dir_port matches */
- found_B1 +=
- (ds->dir_port == 60091 ?
- 1 : 0)
- );
- tt_int_op(found_B1, OP_EQ, 0);
- /* (No AlternateDirAuthority) - A2 - dir_port: 60092 */
- int found_A2 = 0;
- SMARTLIST_FOREACH(dir_servers,
- dir_server_t *,
- ds,
- /* increment the found counter if dir_port matches */
- found_A2 +=
- (ds->dir_port == 60092 ?
- 1 : 0)
- );
- tt_int_op(found_A2, OP_EQ, 0);
- }
- {
- /* fallback_dir_servers */
- const smartlist_t *fallback_servers = router_get_fallback_dir_servers();
- /* D0, (No B1), (No A2), Custom Fallback */
- tt_int_op(smartlist_len(fallback_servers), OP_EQ, 2);
- /* DirAuthority - D0 - dir_port: 60090 */
- int found_D0 = 0;
- SMARTLIST_FOREACH(fallback_servers,
- dir_server_t *,
- ds,
- /* increment the found counter if dir_port matches */
- found_D0 +=
- (ds->dir_port == 60090 ?
- 1 : 0)
- );
- tt_int_op(found_D0, OP_EQ, 1);
- /* (No AlternateBridgeAuthority) - B1 - dir_port: 60091 */
- int found_B1 = 0;
- SMARTLIST_FOREACH(fallback_servers,
- dir_server_t *,
- ds,
- /* increment the found counter if dir_port matches */
- found_B1 +=
- (ds->dir_port == 60091 ?
- 1 : 0)
- );
- tt_int_op(found_B1, OP_EQ, 0);
- /* (No AlternateDirAuthority) - A2 - dir_port: 60092 */
- int found_A2 = 0;
- SMARTLIST_FOREACH(fallback_servers,
- dir_server_t *,
- ds,
- /* increment the found counter if dir_port matches */
- found_A2 +=
- (ds->dir_port == 60092 ?
- 1 : 0)
- );
- tt_int_op(found_A2, OP_EQ, 0);
- /* Custom FallbackDir - No Nickname - dir_port: 60093 */
- int found_non_default_fallback = 0;
- SMARTLIST_FOREACH(fallback_servers,
- dir_server_t *,
- ds,
- /* increment the found counter if dir_port matches */
- found_non_default_fallback +=
- (ds->dir_port == 60093 ?
- 1 : 0)
- );
- tt_int_op(found_non_default_fallback, OP_EQ, 1);
- /* (No Default FallbackDir) - No Nickname - dir_port: 60099 */
- int found_default_fallback = 0;
- SMARTLIST_FOREACH(fallback_servers,
- dir_server_t *,
- ds,
- /* increment the found counter if dir_port matches */
- found_default_fallback +=
- (ds->dir_port == 60099 ?
- 1 : 0)
- );
- tt_int_op(found_default_fallback, OP_EQ, 0);
- }
- }
- /* Case 8: 1000 - DirAuthorities Set, Others Not Set */
- {
- /* clear fallback dirs counter */
- n_add_default_fallback_dir_servers_known_default = 0;
- /* clear options*/
- memset(options, 0, sizeof(or_options_t));
- /* clear any previous dir servers:
- consider_adding_dir_servers() should do this anyway */
- clear_dir_servers();
- /* assign options: 1000 */
- options->DirAuthorities = test_dir_authority;
- options->AlternateBridgeAuthority = NULL;
- options->AlternateDirAuthority = NULL;
- options->FallbackDir = NULL;
- options->UseDefaultFallbackDirs = 1;
- /* parse options - ensure we always update by passing NULL old_options */
- consider_adding_dir_servers(options, NULL);
- /* check outcome */
- /* we must not have added the default fallback dirs */
- tt_int_op(n_add_default_fallback_dir_servers_known_default, OP_EQ, 0);
- /* we just have the authorities */
- tt_assert(networkstatus_consensus_can_use_extra_fallbacks(options) == 0);
- {
- /* trusted_dir_servers */
- const smartlist_t *dir_servers = router_get_trusted_dir_servers();
- /* D0, (No B1), (No A2) */
- tt_int_op(smartlist_len(dir_servers), OP_EQ, 1);
- /* DirAuthority - D0 - dir_port: 60090 */
- int found_D0 = 0;
- SMARTLIST_FOREACH(dir_servers,
- dir_server_t *,
- ds,
- /* increment the found counter if dir_port matches */
- found_D0 +=
- (ds->dir_port == 60090 ?
- 1 : 0)
- );
- tt_int_op(found_D0, OP_EQ, 1);
- /* (No AlternateBridgeAuthority) - B1 - dir_port: 60091 */
- int found_B1 = 0;
- SMARTLIST_FOREACH(dir_servers,
- dir_server_t *,
- ds,
- /* increment the found counter if dir_port matches */
- found_B1 +=
- (ds->dir_port == 60091 ?
- 1 : 0)
- );
- tt_int_op(found_B1, OP_EQ, 0);
- /* (No AlternateDirAuthority) - A2 - dir_port: 60092 */
- int found_A2 = 0;
- SMARTLIST_FOREACH(dir_servers,
- dir_server_t *,
- ds,
- /* increment the found counter if dir_port matches */
- found_A2 +=
- (ds->dir_port == 60092 ?
- 1 : 0)
- );
- tt_int_op(found_A2, OP_EQ, 0);
- }
- {
- /* fallback_dir_servers */
- const smartlist_t *fallback_servers = router_get_fallback_dir_servers();
- /* D0, (No B1), (No A2), (No Fallback) */
- tt_int_op(smartlist_len(fallback_servers), OP_EQ, 1);
- /* DirAuthority - D0 - dir_port: 60090 */
- int found_D0 = 0;
- SMARTLIST_FOREACH(fallback_servers,
- dir_server_t *,
- ds,
- /* increment the found counter if dir_port matches */
- found_D0 +=
- (ds->dir_port == 60090 ?
- 1 : 0)
- );
- tt_int_op(found_D0, OP_EQ, 1);
- /* (No AlternateBridgeAuthority) - B1 - dir_port: 60091 */
- int found_B1 = 0;
- SMARTLIST_FOREACH(fallback_servers,
- dir_server_t *,
- ds,
- /* increment the found counter if dir_port matches */
- found_B1 +=
- (ds->dir_port == 60091 ?
- 1 : 0)
- );
- tt_int_op(found_B1, OP_EQ, 0);
- /* (No AlternateDirAuthority) - A2 - dir_port: 60092 */
- int found_A2 = 0;
- SMARTLIST_FOREACH(fallback_servers,
- dir_server_t *,
- ds,
- /* increment the found counter if dir_port matches */
- found_A2 +=
- (ds->dir_port == 60092 ?
- 1 : 0)
- );
- tt_int_op(found_A2, OP_EQ, 0);
- /* (No Custom FallbackDir) - No Nickname - dir_port: 60093 */
- int found_non_default_fallback = 0;
- SMARTLIST_FOREACH(fallback_servers,
- dir_server_t *,
- ds,
- /* increment the found counter if dir_port matches */
- found_non_default_fallback +=
- (ds->dir_port == 60093 ?
- 1 : 0)
- );
- tt_int_op(found_non_default_fallback, OP_EQ, 0);
- /* (No Default FallbackDir) - No Nickname - dir_port: 60099 */
- int found_default_fallback = 0;
- SMARTLIST_FOREACH(fallback_servers,
- dir_server_t *,
- ds,
- /* increment the found counter if dir_port matches */
- found_default_fallback +=
- (ds->dir_port == 60099 ?
- 1 : 0)
- );
- tt_int_op(found_default_fallback, OP_EQ, 0);
- }
- }
- /* Case 7: 0111 - DirAuthorities Not Set, Others Set */
- {
- /* clear fallback dirs counter */
- n_add_default_fallback_dir_servers_known_default = 0;
- /* clear options*/
- memset(options, 0, sizeof(or_options_t));
- /* clear any previous dir servers:
- consider_adding_dir_servers() should do this anyway */
- clear_dir_servers();
- /* assign options: 0111 */
- options->DirAuthorities = NULL;
- options->AlternateBridgeAuthority = test_alt_bridge_authority;
- options->AlternateDirAuthority = test_alt_dir_authority;
- options->FallbackDir = test_fallback_directory;
- options->UseDefaultFallbackDirs = 1;
- /* parse options - ensure we always update by passing NULL old_options */
- consider_adding_dir_servers(options, NULL);
- /* check outcome */
- /* we must not have added the default fallback dirs */
- tt_int_op(n_add_default_fallback_dir_servers_known_default, OP_EQ, 0);
- /* we have more fallbacks than just the authorities */
- tt_assert(networkstatus_consensus_can_use_extra_fallbacks(options) == 1);
- {
- /* trusted_dir_servers */
- const smartlist_t *dir_servers = router_get_trusted_dir_servers();
- /* (No D0), B1, A2 */
- tt_int_op(smartlist_len(dir_servers), OP_EQ, 2);
- /* (No DirAuthority) - D0 - dir_port: 60090 */
- int found_D0 = 0;
- SMARTLIST_FOREACH(dir_servers,
- dir_server_t *,
- ds,
- /* increment the found counter if dir_port matches */
- found_D0 +=
- (ds->dir_port == 60090 ?
- 1 : 0)
- );
- tt_int_op(found_D0, OP_EQ, 0);
- /* AlternateBridgeAuthority - B1 - dir_port: 60091 */
- int found_B1 = 0;
- SMARTLIST_FOREACH(dir_servers,
- dir_server_t *,
- ds,
- /* increment the found counter if dir_port matches */
- found_B1 +=
- (ds->dir_port == 60091 ?
- 1 : 0)
- );
- tt_int_op(found_B1, OP_EQ, 1);
- /* AlternateDirAuthority - A2 - dir_port: 60092 */
- int found_A2 = 0;
- SMARTLIST_FOREACH(dir_servers,
- dir_server_t *,
- ds,
- /* increment the found counter if dir_port matches */
- found_A2 +=
- (ds->dir_port == 60092 ?
- 1 : 0)
- );
- tt_int_op(found_A2, OP_EQ, 1);
- }
- {
- /* fallback_dir_servers */
- const smartlist_t *fallback_servers = router_get_fallback_dir_servers();
- /* (No D0), B1, A2, Custom Fallback */
- tt_int_op(smartlist_len(fallback_servers), OP_EQ, 3);
- /* (No DirAuthority) - D0 - dir_port: 60090 */
- int found_D0 = 0;
- SMARTLIST_FOREACH(fallback_servers,
- dir_server_t *,
- ds,
- /* increment the found counter if dir_port matches */
- found_D0 +=
- (ds->dir_port == 60090 ?
- 1 : 0)
- );
- tt_int_op(found_D0, OP_EQ, 0);
- /* AlternateBridgeAuthority - B1 - dir_port: 60091 */
- int found_B1 = 0;
- SMARTLIST_FOREACH(fallback_servers,
- dir_server_t *,
- ds,
- /* increment the found counter if dir_port matches */
- found_B1 +=
- (ds->dir_port == 60091 ?
- 1 : 0)
- );
- tt_int_op(found_B1, OP_EQ, 1);
- /* AlternateDirAuthority - A2 - dir_port: 60092 */
- int found_A2 = 0;
- SMARTLIST_FOREACH(fallback_servers,
- dir_server_t *,
- ds,
- /* increment the found counter if dir_port matches */
- found_A2 +=
- (ds->dir_port == 60092 ?
- 1 : 0)
- );
- tt_int_op(found_A2, OP_EQ, 1);
- /* Custom FallbackDir - No Nickname - dir_port: 60093 */
- int found_non_default_fallback = 0;
- SMARTLIST_FOREACH(fallback_servers,
- dir_server_t *,
- ds,
- /* increment the found counter if dir_port matches */
- found_non_default_fallback +=
- (ds->dir_port == 60093 ?
- 1 : 0)
- );
- tt_int_op(found_non_default_fallback, OP_EQ, 1);
- /* (No Default FallbackDir) - No Nickname - dir_port: 60099 */
- int found_default_fallback = 0;
- SMARTLIST_FOREACH(fallback_servers,
- dir_server_t *,
- ds,
- /* increment the found counter if dir_port matches */
- found_default_fallback +=
- (ds->dir_port == 60099 ?
- 1 : 0)
- );
- tt_int_op(found_default_fallback, OP_EQ, 0);
- }
- }
- /* Case 6: 0110 - DirAuthorities Not Set, AlternateBridgeAuthority &
- AlternateDirAuthority Set, FallbackDir Not Set */
- {
- /* clear fallback dirs counter */
- n_add_default_fallback_dir_servers_known_default = 0;
- /* clear options*/
- memset(options, 0, sizeof(or_options_t));
- /* clear any previous dir servers:
- consider_adding_dir_servers() should do this anyway */
- clear_dir_servers();
- /* assign options: 0110 */
- options->DirAuthorities = NULL;
- options->AlternateBridgeAuthority = test_alt_bridge_authority;
- options->AlternateDirAuthority = test_alt_dir_authority;
- options->FallbackDir = NULL;
- options->UseDefaultFallbackDirs = 1;
- /* parse options - ensure we always update by passing NULL old_options */
- consider_adding_dir_servers(options, NULL);
- /* check outcome */
- /* we must not have added the default fallback dirs */
- tt_int_op(n_add_default_fallback_dir_servers_known_default, OP_EQ, 0);
- /* we have more fallbacks than just the authorities */
- tt_assert(networkstatus_consensus_can_use_extra_fallbacks(options) == 0);
- {
- /* trusted_dir_servers */
- const smartlist_t *dir_servers = router_get_trusted_dir_servers();
- /* (No D0), B1, A2 */
- tt_int_op(smartlist_len(dir_servers), OP_EQ, 2);
- /* (No DirAuthority) - D0 - dir_port: 60090 */
- int found_D0 = 0;
- SMARTLIST_FOREACH(dir_servers,
- dir_server_t *,
- ds,
- /* increment the found counter if dir_port matches */
- found_D0 +=
- (ds->dir_port == 60090 ?
- 1 : 0)
- );
- tt_int_op(found_D0, OP_EQ, 0);
- /* AlternateBridgeAuthority - B1 - dir_port: 60091 */
- int found_B1 = 0;
- SMARTLIST_FOREACH(dir_servers,
- dir_server_t *,
- ds,
- /* increment the found counter if dir_port matches */
- found_B1 +=
- (ds->dir_port == 60091 ?
- 1 : 0)
- );
- tt_int_op(found_B1, OP_EQ, 1);
- /* AlternateDirAuthority - A2 - dir_port: 60092 */
- int found_A2 = 0;
- SMARTLIST_FOREACH(dir_servers,
- dir_server_t *,
- ds,
- /* increment the found counter if dir_port matches */
- found_A2 +=
- (ds->dir_port == 60092 ?
- 1 : 0)
- );
- tt_int_op(found_A2, OP_EQ, 1);
- }
- {
- /* fallback_dir_servers */
- const smartlist_t *fallback_servers = router_get_fallback_dir_servers();
- /* (No D0), B1, A2, (No Fallback) */
- tt_int_op(smartlist_len(fallback_servers), OP_EQ, 2);
- /* (No DirAuthority) - D0 - dir_port: 60090 */
- int found_D0 = 0;
- SMARTLIST_FOREACH(fallback_servers,
- dir_server_t *,
- ds,
- /* increment the found counter if dir_port matches */
- found_D0 +=
- (ds->dir_port == 60090 ?
- 1 : 0)
- );
- tt_int_op(found_D0, OP_EQ, 0);
- /* AlternateBridgeAuthority - B1 - dir_port: 60091 */
- int found_B1 = 0;
- SMARTLIST_FOREACH(fallback_servers,
- dir_server_t *,
- ds,
- /* increment the found counter if dir_port matches */
- found_B1 +=
- (ds->dir_port == 60091 ?
- 1 : 0)
- );
- tt_int_op(found_B1, OP_EQ, 1);
- /* AlternateDirAuthority - A2 - dir_port: 60092 */
- int found_A2 = 0;
- SMARTLIST_FOREACH(fallback_servers,
- dir_server_t *,
- ds,
- /* increment the found counter if dir_port matches */
- found_A2 +=
- (ds->dir_port == 60092 ?
- 1 : 0)
- );
- tt_int_op(found_A2, OP_EQ, 1);
- /* (No Custom FallbackDir) - No Nickname - dir_port: 60093 */
- int found_non_default_fallback = 0;
- SMARTLIST_FOREACH(fallback_servers,
- dir_server_t *,
- ds,
- /* increment the found counter if dir_port matches */
- found_non_default_fallback +=
- (ds->dir_port == 60093 ?
- 1 : 0)
- );
- tt_int_op(found_non_default_fallback, OP_EQ, 0);
- /* (No Default FallbackDir) - No Nickname - dir_port: 60099 */
- int found_default_fallback = 0;
- SMARTLIST_FOREACH(fallback_servers,
- dir_server_t *,
- ds,
- /* increment the found counter if dir_port matches */
- found_default_fallback +=
- (ds->dir_port == 60099 ?
- 1 : 0)
- );
- tt_int_op(found_default_fallback, OP_EQ, 0);
- }
- }
- /*
- 2. Outcome: Use Set Bridge Authority
- - Use Default Non-Bridge Directory Authorities
- - Use FallbackDir if it is set, otherwise use default FallbackDir
- Cases expected to yield this outcome:
- 4 & 5 (the 2 cases where DirAuthorities is NULL,
- AlternateBridgeAuthority is set, and
- AlternateDirAuthority is NULL)
- */
- /* Case 5: 0101 - DirAuthorities Not Set, AlternateBridgeAuthority Set,
- AlternateDirAuthority Not Set, FallbackDir Set */
- {
- /* clear fallback dirs counter */
- n_add_default_fallback_dir_servers_known_default = 0;
- /* clear options*/
- memset(options, 0, sizeof(or_options_t));
- /* clear any previous dir servers:
- consider_adding_dir_servers() should do this anyway */
- clear_dir_servers();
- /* assign options: 0101 */
- options->DirAuthorities = NULL;
- options->AlternateBridgeAuthority = test_alt_bridge_authority;
- options->AlternateDirAuthority = NULL;
- options->FallbackDir = test_fallback_directory;
- options->UseDefaultFallbackDirs = 1;
- /* parse options - ensure we always update by passing NULL old_options */
- consider_adding_dir_servers(options, NULL);
- /* check outcome */
- /* we must not have added the default fallback dirs */
- tt_int_op(n_add_default_fallback_dir_servers_known_default, OP_EQ, 0);
- /* we have more fallbacks than just the authorities */
- tt_assert(networkstatus_consensus_can_use_extra_fallbacks(options) == 1);
- {
- /* trusted_dir_servers */
- const smartlist_t *dir_servers = router_get_trusted_dir_servers();
- /* (No D0), B1, (No A2), Default v3 Non-Bridge Authorities */
- tt_assert(smartlist_len(dir_servers) == 1 + n_default_alt_dir_authority);
- /* (No DirAuthorities) - D0 - dir_port: 60090 */
- int found_D0 = 0;
- SMARTLIST_FOREACH(dir_servers,
- dir_server_t *,
- ds,
- /* increment the found counter if dir_port matches */
- found_D0 +=
- (ds->dir_port == 60090 ?
- 1 : 0)
- );
- tt_int_op(found_D0, OP_EQ, 0);
- /* AlternateBridgeAuthority - B1 - dir_port: 60091 */
- int found_B1 = 0;
- SMARTLIST_FOREACH(dir_servers,
- dir_server_t *,
- ds,
- /* increment the found counter if dir_port matches */
- found_B1 +=
- (ds->dir_port == 60091 ?
- 1 : 0)
- );
- tt_int_op(found_B1, OP_EQ, 1);
- /* (No AlternateDirAuthority) - A2 - dir_port: 60092 */
- int found_A2 = 0;
- SMARTLIST_FOREACH(dir_servers,
- dir_server_t *,
- ds,
- /* increment the found counter if dir_port matches */
- found_A2 +=
- (ds->dir_port == 60092 ?
- 1 : 0)
- );
- tt_int_op(found_A2, OP_EQ, 0);
- /* There's no easy way of checking that we have included all the
- * default v3 non-Bridge directory authorities, so let's assume that
- * if the total count above is correct, we have the right ones.
- */
- }
- {
- /* fallback_dir_servers */
- const smartlist_t *fallback_servers = router_get_fallback_dir_servers();
- /* (No D0), B1, (No A2), Default v3 Non-Bridge Authorities,
- * Custom Fallback */
- tt_assert(smartlist_len(fallback_servers) ==
- 2 + n_default_alt_dir_authority);
- /* (No DirAuthorities) - D0 - dir_port: 60090 */
- int found_D0 = 0;
- SMARTLIST_FOREACH(fallback_servers,
- dir_server_t *,
- ds,
- /* increment the found counter if dir_port matches */
- found_D0 +=
- (ds->dir_port == 60090 ?
- 1 : 0)
- );
- tt_int_op(found_D0, OP_EQ, 0);
- /* AlternateBridgeAuthority - B1 - dir_port: 60091 */
- int found_B1 = 0;
- SMARTLIST_FOREACH(fallback_servers,
- dir_server_t *,
- ds,
- /* increment the found counter if dir_port matches */
- found_B1 +=
- (ds->dir_port == 60091 ?
- 1 : 0)
- );
- tt_int_op(found_B1, OP_EQ, 1);
- /* (No AlternateDirAuthority) - A2 - dir_port: 60092 */
- int found_A2 = 0;
- SMARTLIST_FOREACH(fallback_servers,
- dir_server_t *,
- ds,
- /* increment the found counter if dir_port matches */
- found_A2 +=
- (ds->dir_port == 60092 ?
- 1 : 0)
- );
- tt_int_op(found_A2, OP_EQ, 0);
- /* Custom FallbackDir - No Nickname - dir_port: 60093 */
- int found_non_default_fallback = 0;
- SMARTLIST_FOREACH(fallback_servers,
- dir_server_t *,
- ds,
- /* increment the found counter if dir_port matches */
- found_non_default_fallback +=
- (ds->dir_port == 60093 ?
- 1 : 0)
- );
- tt_int_op(found_non_default_fallback, OP_EQ, 1);
- /* (No Default FallbackDir) - No Nickname - dir_port: 60099 */
- int found_default_fallback = 0;
- SMARTLIST_FOREACH(fallback_servers,
- dir_server_t *,
- ds,
- /* increment the found counter if dir_port matches */
- found_default_fallback +=
- (ds->dir_port == 60099 ?
- 1 : 0)
- );
- tt_int_op(found_default_fallback, OP_EQ, 0);
- /* There's no easy way of checking that we have included all the
- * default v3 non-Bridge directory authorities, so let's assume that
- * if the total count above is correct, we have the right ones.
- */
- }
- }
- /* Case 4: 0100 - DirAuthorities Not Set, AlternateBridgeAuthority Set,
- AlternateDirAuthority & FallbackDir Not Set */
- {
- /* clear fallback dirs counter */
- n_add_default_fallback_dir_servers_known_default = 0;
- /* clear options*/
- memset(options, 0, sizeof(or_options_t));
- /* clear any previous dir servers:
- consider_adding_dir_servers() should do this anyway */
- clear_dir_servers();
- /* assign options: 0100 */
- options->DirAuthorities = NULL;
- options->AlternateBridgeAuthority = test_alt_bridge_authority;
- options->AlternateDirAuthority = NULL;
- options->FallbackDir = NULL;
- options->UseDefaultFallbackDirs = 1;
- /* parse options - ensure we always update by passing NULL old_options */
- consider_adding_dir_servers(options, NULL);
- /* check outcome */
- /* we must have added the default fallback dirs */
- tt_int_op(n_add_default_fallback_dir_servers_known_default, OP_EQ, 1);
- /* we have more fallbacks than just the authorities */
- tt_assert(networkstatus_consensus_can_use_extra_fallbacks(options) == 1);
- {
- /* trusted_dir_servers */
- const smartlist_t *dir_servers = router_get_trusted_dir_servers();
- /* (No D0), B1, (No A2), Default v3 Non-Bridge Authorities */
- tt_assert(smartlist_len(dir_servers) == 1 + n_default_alt_dir_authority);
- /* (No DirAuthorities) - D0 - dir_port: 60090 */
- int found_D0 = 0;
- SMARTLIST_FOREACH(dir_servers,
- dir_server_t *,
- ds,
- /* increment the found counter if dir_port matches */
- found_D0 +=
- (ds->dir_port == 60090 ?
- 1 : 0)
- );
- tt_int_op(found_D0, OP_EQ, 0);
- /* AlternateBridgeAuthority - B1 - dir_port: 60091 */
- int found_B1 = 0;
- SMARTLIST_FOREACH(dir_servers,
- dir_server_t *,
- ds,
- /* increment the found counter if dir_port matches */
- found_B1 +=
- (ds->dir_port == 60091 ?
- 1 : 0)
- );
- tt_int_op(found_B1, OP_EQ, 1);
- /* (No AlternateDirAuthority) - A2 - dir_port: 60092 */
- int found_A2 = 0;
- SMARTLIST_FOREACH(dir_servers,
- dir_server_t *,
- ds,
- /* increment the found counter if dir_port matches */
- found_A2 +=
- (ds->dir_port == 60092 ?
- 1 : 0)
- );
- tt_int_op(found_A2, OP_EQ, 0);
- /* There's no easy way of checking that we have included all the
- * default v3 non-Bridge directory authorities, so let's assume that
- * if the total count above is correct, we have the right ones.
- */
- }
- {
- /* fallback_dir_servers */
- const smartlist_t *fallback_servers = router_get_fallback_dir_servers();
- /* (No D0), B1, (No A2), Default v3 Non-Bridge Authorities,
- * Default Fallback */
- tt_assert(smartlist_len(fallback_servers) ==
- 2 + n_default_alt_dir_authority);
- /* (No DirAuthorities) - D0 - dir_port: 60090 */
- int found_D0 = 0;
- SMARTLIST_FOREACH(fallback_servers,
- dir_server_t *,
- ds,
- /* increment the found counter if dir_port matches */
- found_D0 +=
- (ds->dir_port == 60090 ?
- 1 : 0)
- );
- tt_int_op(found_D0, OP_EQ, 0);
- /* AlternateBridgeAuthority - B1 - dir_port: 60091 */
- int found_B1 = 0;
- SMARTLIST_FOREACH(fallback_servers,
- dir_server_t *,
- ds,
- /* increment the found counter if dir_port matches */
- found_B1 +=
- (ds->dir_port == 60091 ?
- 1 : 0)
- );
- tt_int_op(found_B1, OP_EQ, 1);
- /* (No AlternateDirAuthority) - A2 - dir_port: 60092 */
- int found_A2 = 0;
- SMARTLIST_FOREACH(fallback_servers,
- dir_server_t *,
- ds,
- /* increment the found counter if dir_port matches */
- found_A2 +=
- (ds->dir_port == 60092 ?
- 1 : 0)
- );
- tt_int_op(found_A2, OP_EQ, 0);
- /* (No Custom FallbackDir) - No Nickname - dir_port: 60093 */
- int found_non_default_fallback = 0;
- SMARTLIST_FOREACH(fallback_servers,
- dir_server_t *,
- ds,
- /* increment the found counter if dir_port matches */
- found_non_default_fallback +=
- (ds->dir_port == 60093 ?
- 1 : 0)
- );
- tt_int_op(found_non_default_fallback, OP_EQ, 0);
- /* Default FallbackDir - No Nickname - dir_port: 60099 */
- int found_default_fallback = 0;
- SMARTLIST_FOREACH(fallback_servers,
- dir_server_t *,
- ds,
- /* increment the found counter if dir_port matches */
- found_default_fallback +=
- (ds->dir_port == 60099 ?
- 1 : 0)
- );
- tt_int_op(found_default_fallback, OP_EQ, 1);
- /* There's no easy way of checking that we have included all the
- * default v3 non-Bridge directory authorities, so let's assume that
- * if the total count above is correct, we have the right ones.
- */
- }
- }
- /*
- 3. Outcome: Use Set Alternate Directory Authority
- - Use Default Bridge Authorities
- - Use FallbackDir if it is set, otherwise No Default Fallback Directories
- Cases expected to yield this outcome:
- 2 & 3 (the 2 cases where DirAuthorities and AlternateBridgeAuthority
- are both NULL, but AlternateDirAuthority is set)
- */
- /* Case 3: 0011 - DirAuthorities & AlternateBridgeAuthority Not Set,
- AlternateDirAuthority & FallbackDir Set */
- {
- /* clear fallback dirs counter */
- n_add_default_fallback_dir_servers_known_default = 0;
- /* clear options*/
- memset(options, 0, sizeof(or_options_t));
- /* clear any previous dir servers:
- consider_adding_dir_servers() should do this anyway */
- clear_dir_servers();
- /* assign options: 0011 */
- options->DirAuthorities = NULL;
- options->AlternateBridgeAuthority = NULL;
- options->AlternateDirAuthority = test_alt_dir_authority;
- options->FallbackDir = test_fallback_directory;
- options->UseDefaultFallbackDirs = 1;
- /* parse options - ensure we always update by passing NULL old_options */
- consider_adding_dir_servers(options, NULL);
- /* check outcome */
- /* we must not have added the default fallback dirs */
- tt_int_op(n_add_default_fallback_dir_servers_known_default, OP_EQ, 0);
- /* we have more fallbacks than just the authorities */
- tt_assert(networkstatus_consensus_can_use_extra_fallbacks(options) == 1);
- {
- /* trusted_dir_servers */
- const smartlist_t *dir_servers = router_get_trusted_dir_servers();
- /* (No D0), (No B1), Default Bridge Authorities, A2 */
- tt_assert(smartlist_len(dir_servers) ==
- 1 + n_default_alt_bridge_authority);
- /* (No DirAuthorities) - D0 - dir_port: 60090 */
- int found_D0 = 0;
- SMARTLIST_FOREACH(dir_servers,
- dir_server_t *,
- ds,
- /* increment the found counter if dir_port matches */
- found_D0 +=
- (ds->dir_port == 60090 ?
- 1 : 0)
- );
- tt_int_op(found_D0, OP_EQ, 0);
- /* (No AlternateBridgeAuthority) - B1 - dir_port: 60091 */
- int found_B1 = 0;
- SMARTLIST_FOREACH(dir_servers,
- dir_server_t *,
- ds,
- /* increment the found counter if dir_port matches */
- found_B1 +=
- (ds->dir_port == 60091 ?
- 1 : 0)
- );
- tt_int_op(found_B1, OP_EQ, 0);
- /* AlternateDirAuthority - A2 - dir_port: 60092 */
- int found_A2 = 0;
- SMARTLIST_FOREACH(dir_servers,
- dir_server_t *,
- ds,
- /* increment the found counter if dir_port matches */
- found_A2 +=
- (ds->dir_port == 60092 ?
- 1 : 0)
- );
- tt_int_op(found_A2, OP_EQ, 1);
- /* There's no easy way of checking that we have included all the
- * default Bridge authorities (except for hard-coding tonga's details),
- * so let's assume that if the total count above is correct,
- * we have the right ones.
- */
- }
- {
- /* fallback_dir_servers */
- const smartlist_t *fallback_servers = router_get_fallback_dir_servers();
- /* (No D0), (No B1), Default Bridge Authorities, A2,
- * Custom Fallback Directory, (No Default Fallback Directories) */
- tt_assert(smartlist_len(fallback_servers) ==
- 2 + n_default_alt_bridge_authority);
- /* (No DirAuthorities) - D0 - dir_port: 60090 */
- int found_D0 = 0;
- SMARTLIST_FOREACH(fallback_servers,
- dir_server_t *,
- ds,
- /* increment the found counter if dir_port matches */
- found_D0 +=
- (ds->dir_port == 60090 ?
- 1 : 0)
- );
- tt_int_op(found_D0, OP_EQ, 0);
- /* (No AlternateBridgeAuthority) - B1 - dir_port: 60091 */
- int found_B1 = 0;
- SMARTLIST_FOREACH(fallback_servers,
- dir_server_t *,
- ds,
- /* increment the found counter if dir_port matches */
- found_B1 +=
- (ds->dir_port == 60091 ?
- 1 : 0)
- );
- tt_int_op(found_B1, OP_EQ, 0);
- /* AlternateDirAuthority - A2 - dir_port: 60092 */
- int found_A2 = 0;
- SMARTLIST_FOREACH(fallback_servers,
- dir_server_t *,
- ds,
- /* increment the found counter if dir_port matches */
- found_A2 +=
- (ds->dir_port == 60092 ?
- 1 : 0)
- );
- tt_int_op(found_A2, OP_EQ, 1);
- /* Custom FallbackDir - No Nickname - dir_port: 60093 */
- int found_non_default_fallback = 0;
- SMARTLIST_FOREACH(fallback_servers,
- dir_server_t *,
- ds,
- /* increment the found counter if dir_port matches */
- found_non_default_fallback +=
- (ds->dir_port == 60093 ?
- 1 : 0)
- );
- tt_int_op(found_non_default_fallback, OP_EQ, 1);
- /* (No Default FallbackDir) - No Nickname - dir_port: 60099 */
- int found_default_fallback = 0;
- SMARTLIST_FOREACH(fallback_servers,
- dir_server_t *,
- ds,
- /* increment the found counter if dir_port matches */
- found_default_fallback +=
- (ds->dir_port == 60099 ?
- 1 : 0)
- );
- tt_int_op(found_default_fallback, OP_EQ, 0);
- /* There's no easy way of checking that we have included all the
- * default Bridge authorities (except for hard-coding tonga's details),
- * so let's assume that if the total count above is correct,
- * we have the right ones.
- */
- }
- }
- /* Case 2: 0010 - DirAuthorities & AlternateBridgeAuthority Not Set,
- AlternateDirAuthority Set, FallbackDir Not Set */
- {
- /* clear fallback dirs counter */
- n_add_default_fallback_dir_servers_known_default = 0;
- /* clear options*/
- memset(options, 0, sizeof(or_options_t));
- /* clear any previous dir servers:
- consider_adding_dir_servers() should do this anyway */
- clear_dir_servers();
- /* assign options: 0010 */
- options->DirAuthorities = NULL;
- options->AlternateBridgeAuthority = NULL;
- options->AlternateDirAuthority = test_alt_dir_authority;
- options->FallbackDir = NULL;
- options->UseDefaultFallbackDirs = 1;
- /* parse options - ensure we always update by passing NULL old_options */
- consider_adding_dir_servers(options, NULL);
- /* check outcome */
- /* we must not have added the default fallback dirs */
- tt_int_op(n_add_default_fallback_dir_servers_known_default, OP_EQ, 0);
- /* we just have the authorities */
- tt_assert(networkstatus_consensus_can_use_extra_fallbacks(options) == 0);
- {
- /* trusted_dir_servers */
- const smartlist_t *dir_servers = router_get_trusted_dir_servers();
- /* (No D0), (No B1), Default Bridge Authorities, A2,
- * No Default or Custom Fallback Directories */
- tt_assert(smartlist_len(dir_servers) ==
- 1 + n_default_alt_bridge_authority);
- /* (No DirAuthorities) - D0 - dir_port: 60090 */
- int found_D0 = 0;
- SMARTLIST_FOREACH(dir_servers,
- dir_server_t *,
- ds,
- /* increment the found counter if dir_port matches */
- found_D0 +=
- (ds->dir_port == 60090 ?
- 1 : 0)
- );
- tt_int_op(found_D0, OP_EQ, 0);
- /* (No AlternateBridgeAuthority) - B1 - dir_port: 60091 */
- int found_B1 = 0;
- SMARTLIST_FOREACH(dir_servers,
- dir_server_t *,
- ds,
- /* increment the found counter if dir_port matches */
- found_B1 +=
- (ds->dir_port == 60091 ?
- 1 : 0)
- );
- tt_int_op(found_B1, OP_EQ, 0);
- /* AlternateDirAuthority - A2 - dir_port: 60092 */
- int found_A2 = 0;
- SMARTLIST_FOREACH(dir_servers,
- dir_server_t *,
- ds,
- /* increment the found counter if dir_port matches */
- found_A2 +=
- (ds->dir_port == 60092 ?
- 1 : 0)
- );
- tt_int_op(found_A2, OP_EQ, 1);
- /* There's no easy way of checking that we have included all the
- * default Bridge authorities (except for hard-coding tonga's details),
- * so let's assume that if the total count above is correct,
- * we have the right ones.
- */
- }
- {
- /* fallback_dir_servers */
- const smartlist_t *fallback_servers = router_get_fallback_dir_servers();
- /* (No D0), (No B1), Default Bridge Authorities, A2,
- * No Custom or Default Fallback Directories */
- tt_assert(smartlist_len(fallback_servers) ==
- 1 + n_default_alt_bridge_authority);
- /* (No DirAuthorities) - D0 - dir_port: 60090 */
- int found_D0 = 0;
- SMARTLIST_FOREACH(fallback_servers,
- dir_server_t *,
- ds,
- /* increment the found counter if dir_port matches */
- found_D0 +=
- (ds->dir_port == 60090 ?
- 1 : 0)
- );
- tt_int_op(found_D0, OP_EQ, 0);
- /* (No AlternateBridgeAuthority) - B1 - dir_port: 60091 */
- int found_B1 = 0;
- SMARTLIST_FOREACH(fallback_servers,
- dir_server_t *,
- ds,
- /* increment the found counter if dir_port matches */
- found_B1 +=
- (ds->dir_port == 60091 ?
- 1 : 0)
- );
- tt_int_op(found_B1, OP_EQ, 0);
- /* AlternateDirAuthority - A2 - dir_port: 60092 */
- int found_A2 = 0;
- SMARTLIST_FOREACH(fallback_servers,
- dir_server_t *,
- ds,
- /* increment the found counter if dir_port matches */
- found_A2 +=
- (ds->dir_port == 60092 ?
- 1 : 0)
- );
- tt_int_op(found_A2, OP_EQ, 1);
- /* (No Custom FallbackDir) - No Nickname - dir_port: 60093 */
- int found_non_default_fallback = 0;
- SMARTLIST_FOREACH(fallback_servers,
- dir_server_t *,
- ds,
- /* increment the found counter if dir_port matches */
- found_non_default_fallback +=
- (ds->dir_port == 60093 ?
- 1 : 0)
- );
- tt_int_op(found_non_default_fallback, OP_EQ, 0);
- /* (No Default FallbackDir) - No Nickname - dir_port: 60099 */
- int found_default_fallback = 0;
- SMARTLIST_FOREACH(fallback_servers,
- dir_server_t *,
- ds,
- /* increment the found counter if dir_port matches */
- found_default_fallback +=
- (ds->dir_port == 60099 ?
- 1 : 0)
- );
- tt_int_op(found_default_fallback, OP_EQ, 0);
- /* There's no easy way of checking that we have included all the
- * default Bridge authorities (except for hard-coding tonga's details),
- * so let's assume that if the total count above is correct,
- * we have the right ones.
- */
- }
- }
- /*
- 4. Outcome: Use Set Custom Fallback Directory
- - Use Default Bridge & Directory Authorities
- Cases expected to yield this outcome:
- 1 (DirAuthorities, AlternateBridgeAuthority and AlternateDirAuthority
- are all NULL, but FallbackDir is set)
- */
- /* Case 1: 0001 - DirAuthorities, AlternateBridgeAuthority
- & AlternateDirAuthority Not Set, FallbackDir Set */
- {
- /* clear fallback dirs counter */
- n_add_default_fallback_dir_servers_known_default = 0;
- /* clear options*/
- memset(options, 0, sizeof(or_options_t));
- /* clear any previous dir servers:
- consider_adding_dir_servers() should do this anyway */
- clear_dir_servers();
- /* assign options: 0001 */
- options->DirAuthorities = NULL;
- options->AlternateBridgeAuthority = NULL;
- options->AlternateDirAuthority = NULL;
- options->FallbackDir = test_fallback_directory;
- options->UseDefaultFallbackDirs = 1;
- /* parse options - ensure we always update by passing NULL old_options */
- consider_adding_dir_servers(options, NULL);
- /* check outcome */
- /* we must not have added the default fallback dirs */
- tt_int_op(n_add_default_fallback_dir_servers_known_default, OP_EQ, 0);
- /* we have more fallbacks than just the authorities */
- tt_assert(networkstatus_consensus_can_use_extra_fallbacks(options) == 1);
- {
- /* trusted_dir_servers */
- const smartlist_t *dir_servers = router_get_trusted_dir_servers();
- /* (No D0), (No B1), Default Bridge Authorities,
- * (No A2), Default v3 Directory Authorities */
- tt_assert(smartlist_len(dir_servers) == n_default_authorities);
- /* (No DirAuthorities) - D0 - dir_port: 60090 */
- int found_D0 = 0;
- SMARTLIST_FOREACH(dir_servers,
- dir_server_t *,
- ds,
- /* increment the found counter if dir_port matches */
- found_D0 +=
- (ds->dir_port == 60090 ?
- 1 : 0)
- );
- tt_int_op(found_D0, OP_EQ, 0);
- /* (No AlternateBridgeAuthority) - B1 - dir_port: 60091 */
- int found_B1 = 0;
- SMARTLIST_FOREACH(dir_servers,
- dir_server_t *,
- ds,
- /* increment the found counter if dir_port matches */
- found_B1 +=
- (ds->dir_port == 60091 ?
- 1 : 0)
- );
- tt_int_op(found_B1, OP_EQ, 0);
- /* (No AlternateDirAuthority) - A2 - dir_port: 60092 */
- int found_A2 = 0;
- SMARTLIST_FOREACH(dir_servers,
- dir_server_t *,
- ds,
- /* increment the found counter if dir_port matches */
- found_A2 +=
- (ds->dir_port == 60092 ?
- 1 : 0)
- );
- tt_int_op(found_A2, OP_EQ, 0);
- /* There's no easy way of checking that we have included all the
- * default Bridge & V3 Directory authorities, so let's assume that
- * if the total count above is correct, we have the right ones.
- */
- }
- {
- /* fallback_dir_servers */
- const smartlist_t *fallback_servers = router_get_fallback_dir_servers();
- /* (No D0), (No B1), Default Bridge Authorities,
- * (No A2), Default v3 Directory Authorities,
- * Custom Fallback Directory, (No Default Fallback Directories) */
- tt_assert(smartlist_len(fallback_servers) ==
- 1 + n_default_authorities);
- /* (No DirAuthorities) - D0 - dir_port: 60090 */
- int found_D0 = 0;
- SMARTLIST_FOREACH(fallback_servers,
- dir_server_t *,
- ds,
- /* increment the found counter if dir_port matches */
- found_D0 +=
- (ds->dir_port == 60090 ?
- 1 : 0)
- );
- tt_int_op(found_D0, OP_EQ, 0);
- /* (No AlternateBridgeAuthority) - B1 - dir_port: 60091 */
- int found_B1 = 0;
- SMARTLIST_FOREACH(fallback_servers,
- dir_server_t *,
- ds,
- /* increment the found counter if dir_port matches */
- found_B1 +=
- (ds->dir_port == 60091 ?
- 1 : 0)
- );
- tt_int_op(found_B1, OP_EQ, 0);
- /* (No AlternateDirAuthority) - A2 - dir_port: 60092 */
- int found_A2 = 0;
- SMARTLIST_FOREACH(fallback_servers,
- dir_server_t *,
- ds,
- /* increment the found counter if dir_port matches */
- found_A2 +=
- (ds->dir_port == 60092 ?
- 1 : 0)
- );
- tt_int_op(found_A2, OP_EQ, 0);
- /* Custom FallbackDir - No Nickname - dir_port: 60093 */
- int found_non_default_fallback = 0;
- SMARTLIST_FOREACH(fallback_servers,
- dir_server_t *,
- ds,
- /* increment the found counter if dir_port matches */
- found_non_default_fallback +=
- (ds->dir_port == 60093 ?
- 1 : 0)
- );
- tt_int_op(found_non_default_fallback, OP_EQ, 1);
- /* (No Default FallbackDir) - No Nickname - dir_port: 60099 */
- int found_default_fallback = 0;
- SMARTLIST_FOREACH(fallback_servers,
- dir_server_t *,
- ds,
- /* increment the found counter if dir_port matches */
- found_default_fallback +=
- (ds->dir_port == 60099 ?
- 1 : 0)
- );
- tt_int_op(found_default_fallback, OP_EQ, 0);
- /* There's no easy way of checking that we have included all the
- * default Bridge & V3 Directory authorities, so let's assume that
- * if the total count above is correct, we have the right ones.
- */
- }
- }
- /*
- 5. Outcome: Use All Defaults
- - Use Default Bridge & Directory Authorities, Default Fallback Directories
- Cases expected to yield this outcome:
- 0 (DirAuthorities, AlternateBridgeAuthority, AlternateDirAuthority
- and FallbackDir are all NULL)
- */
- /* Case 0: 0000 - All Not Set */
- {
- /* clear fallback dirs counter */
- n_add_default_fallback_dir_servers_known_default = 0;
- /* clear options*/
- memset(options, 0, sizeof(or_options_t));
- /* clear any previous dir servers:
- consider_adding_dir_servers() should do this anyway */
- clear_dir_servers();
- /* assign options: 0001 */
- options->DirAuthorities = NULL;
- options->AlternateBridgeAuthority = NULL;
- options->AlternateDirAuthority = NULL;
- options->FallbackDir = NULL;
- options->UseDefaultFallbackDirs = 1;
- /* parse options - ensure we always update by passing NULL old_options */
- consider_adding_dir_servers(options, NULL);
- /* check outcome */
- /* we must have added the default fallback dirs */
- tt_int_op(n_add_default_fallback_dir_servers_known_default, OP_EQ, 1);
- /* we have more fallbacks than just the authorities */
- tt_assert(networkstatus_consensus_can_use_extra_fallbacks(options) == 1);
- {
- /* trusted_dir_servers */
- const smartlist_t *dir_servers = router_get_trusted_dir_servers();
- /* (No D0), (No B1), Default Bridge Authorities,
- * (No A2), Default v3 Directory Authorities */
- tt_assert(smartlist_len(dir_servers) == n_default_authorities);
- /* (No DirAuthorities) - D0 - dir_port: 60090 */
- int found_D0 = 0;
- SMARTLIST_FOREACH(dir_servers,
- dir_server_t *,
- ds,
- /* increment the found counter if dir_port matches */
- found_D0 +=
- (ds->dir_port == 60090 ?
- 1 : 0)
- );
- tt_int_op(found_D0, OP_EQ, 0);
- /* (No AlternateBridgeAuthority) - B1 - dir_port: 60091 */
- int found_B1 = 0;
- SMARTLIST_FOREACH(dir_servers,
- dir_server_t *,
- ds,
- /* increment the found counter if dir_port matches */
- found_B1 +=
- (ds->dir_port == 60091 ?
- 1 : 0)
- );
- tt_int_op(found_B1, OP_EQ, 0);
- /* (No AlternateDirAuthority) - A2 - dir_port: 60092 */
- int found_A2 = 0;
- SMARTLIST_FOREACH(dir_servers,
- dir_server_t *,
- ds,
- /* increment the found counter if dir_port matches */
- found_A2 +=
- (ds->dir_port == 60092 ?
- 1 : 0)
- );
- tt_int_op(found_A2, OP_EQ, 0);
- /* There's no easy way of checking that we have included all the
- * default Bridge & V3 Directory authorities, so let's assume that
- * if the total count above is correct, we have the right ones.
- */
- }
- {
- /* fallback_dir_servers */
- const smartlist_t *fallback_servers = router_get_fallback_dir_servers();
- /* (No D0), (No B1), Default Bridge Authorities,
- * (No A2), Default v3 Directory Authorities,
- * (No Custom Fallback Directory), Default Fallback Directories */
- tt_assert(smartlist_len(fallback_servers) ==
- n_default_authorities + n_default_fallback_dir);
- /* (No DirAuthorities) - D0 - dir_port: 60090 */
- int found_D0 = 0;
- SMARTLIST_FOREACH(fallback_servers,
- dir_server_t *,
- ds,
- /* increment the found counter if dir_port matches */
- found_D0 +=
- (ds->dir_port == 60090 ?
- 1 : 0)
- );
- tt_int_op(found_D0, OP_EQ, 0);
- /* (No AlternateBridgeAuthority) - B1 - dir_port: 60091 */
- int found_B1 = 0;
- SMARTLIST_FOREACH(fallback_servers,
- dir_server_t *,
- ds,
- /* increment the found counter if dir_port matches */
- found_B1 +=
- (ds->dir_port == 60091 ?
- 1 : 0)
- );
- tt_int_op(found_B1, OP_EQ, 0);
- /* (No AlternateDirAuthority) - A2 - dir_port: 60092 */
- int found_A2 = 0;
- SMARTLIST_FOREACH(fallback_servers,
- dir_server_t *,
- ds,
- /* increment the found counter if dir_port matches */
- found_A2 +=
- (ds->dir_port == 60092 ?
- 1 : 0)
- );
- tt_int_op(found_A2, OP_EQ, 0);
- /* Custom FallbackDir - No Nickname - dir_port: 60093 */
- int found_non_default_fallback = 0;
- SMARTLIST_FOREACH(fallback_servers,
- dir_server_t *,
- ds,
- /* increment the found counter if dir_port matches */
- found_non_default_fallback +=
- (ds->dir_port == 60093 ?
- 1 : 0)
- );
- tt_int_op(found_non_default_fallback, OP_EQ, 0);
- /* (No Default FallbackDir) - No Nickname - dir_port: 60099 */
- int found_default_fallback = 0;
- SMARTLIST_FOREACH(fallback_servers,
- dir_server_t *,
- ds,
- /* increment the found counter if dir_port matches */
- found_default_fallback +=
- (ds->dir_port == 60099 ?
- 1 : 0)
- );
- tt_int_op(found_default_fallback, OP_EQ, 1);
- /* There's no easy way of checking that we have included all the
- * default Bridge & V3 Directory authorities, and the default
- * Fallback Directories, so let's assume that if the total count
- * above is correct, we have the right ones.
- */
- }
- }
- done:
- clear_dir_servers();
- tor_free(test_dir_authority->key);
- tor_free(test_dir_authority->value);
- tor_free(test_dir_authority);
- tor_free(test_alt_dir_authority->key);
- tor_free(test_alt_dir_authority->value);
- tor_free(test_alt_dir_authority);
- tor_free(test_alt_bridge_authority->key);
- tor_free(test_alt_bridge_authority->value);
- tor_free(test_alt_bridge_authority);
- tor_free(test_fallback_directory->key);
- tor_free(test_fallback_directory->value);
- tor_free(test_fallback_directory);
- options->DirAuthorities = NULL;
- options->AlternateBridgeAuthority = NULL;
- options->AlternateDirAuthority = NULL;
- options->FallbackDir = NULL;
- or_options_free(options);
- UNMOCK(add_default_fallback_dir_servers);
- }
- static void
- test_config_default_dir_servers(void *arg)
- {
- or_options_t *opts = NULL;
- (void)arg;
- int trusted_count = 0;
- int fallback_count = 0;
- /* new set of options should stop fallback parsing */
- opts = tor_malloc_zero(sizeof(or_options_t));
- opts->UseDefaultFallbackDirs = 0;
- /* set old_options to NULL to force dir update */
- consider_adding_dir_servers(opts, NULL);
- trusted_count = smartlist_len(router_get_trusted_dir_servers());
- fallback_count = smartlist_len(router_get_fallback_dir_servers());
- or_options_free(opts);
- opts = NULL;
- /* assume a release will never go out with less than 7 authorities */
- tt_int_op(trusted_count, OP_GE, 7);
- /* if we disable the default fallbacks, there must not be any extra */
- tt_assert(fallback_count == trusted_count);
- opts = tor_malloc_zero(sizeof(or_options_t));
- opts->UseDefaultFallbackDirs = 1;
- consider_adding_dir_servers(opts, opts);
- trusted_count = smartlist_len(router_get_trusted_dir_servers());
- fallback_count = smartlist_len(router_get_fallback_dir_servers());
- or_options_free(opts);
- opts = NULL;
- /* assume a release will never go out with less than 7 authorities */
- tt_int_op(trusted_count, OP_GE, 7);
- /* XX/teor - allow for default fallbacks to be added without breaking
- * the unit tests. Set a minimum fallback count once the list is stable. */
- tt_assert(fallback_count >= trusted_count);
- done:
- or_options_free(opts);
- }
- static int mock_router_pick_published_address_result = 0;
- static int
- mock_router_pick_published_address(const or_options_t *options,
- uint32_t *addr, int cache_only)
- {
- (void)options;
- (void)addr;
- (void)cache_only;
- return mock_router_pick_published_address_result;
- }
- static int mock_router_my_exit_policy_is_reject_star_result = 0;
- static int
- mock_router_my_exit_policy_is_reject_star(void)
- {
- return mock_router_my_exit_policy_is_reject_star_result;
- }
- static int mock_advertised_server_mode_result = 0;
- static int
- mock_advertised_server_mode(void)
- {
- return mock_advertised_server_mode_result;
- }
- static routerinfo_t *mock_router_get_my_routerinfo_result = NULL;
- static const routerinfo_t *
- mock_router_get_my_routerinfo(void)
- {
- return mock_router_get_my_routerinfo_result;
- }
- static void
- test_config_directory_fetch(void *arg)
- {
- (void)arg;
- /* Test Setup */
- or_options_t *options = tor_malloc_zero(sizeof(or_options_t));
- routerinfo_t routerinfo;
- memset(&routerinfo, 0, sizeof(routerinfo));
- mock_router_pick_published_address_result = -1;
- mock_router_my_exit_policy_is_reject_star_result = 1;
- mock_advertised_server_mode_result = 0;
- mock_router_get_my_routerinfo_result = NULL;
- MOCK(router_pick_published_address, mock_router_pick_published_address);
- MOCK(router_my_exit_policy_is_reject_star,
- mock_router_my_exit_policy_is_reject_star);
- MOCK(advertised_server_mode, mock_advertised_server_mode);
- MOCK(router_get_my_routerinfo, mock_router_get_my_routerinfo);
- /* Clients can use multiple directory mirrors for bootstrap */
- memset(options, 0, sizeof(or_options_t));
- options->ClientOnly = 1;
- tt_assert(server_mode(options) == 0);
- tt_assert(public_server_mode(options) == 0);
- tt_int_op(directory_fetches_from_authorities(options), OP_EQ, 0);
- tt_int_op(networkstatus_consensus_can_use_multiple_directories(options),
- OP_EQ, 1);
- /* Bridge Clients can use multiple directory mirrors for bootstrap */
- memset(options, 0, sizeof(or_options_t));
- options->UseBridges = 1;
- tt_assert(server_mode(options) == 0);
- tt_assert(public_server_mode(options) == 0);
- tt_int_op(directory_fetches_from_authorities(options), OP_EQ, 0);
- tt_int_op(networkstatus_consensus_can_use_multiple_directories(options),
- OP_EQ, 1);
- /* Bridge Relays (Bridges) must act like clients, and use multiple
- * directory mirrors for bootstrap */
- memset(options, 0, sizeof(or_options_t));
- options->BridgeRelay = 1;
- options->ORPort_set = 1;
- tt_assert(server_mode(options) == 1);
- tt_assert(public_server_mode(options) == 0);
- tt_int_op(directory_fetches_from_authorities(options), OP_EQ, 0);
- tt_int_op(networkstatus_consensus_can_use_multiple_directories(options),
- OP_EQ, 1);
- /* Clients set to FetchDirInfoEarly must fetch it from the authorities,
- * but can use multiple authorities for bootstrap */
- memset(options, 0, sizeof(or_options_t));
- options->FetchDirInfoEarly = 1;
- tt_assert(server_mode(options) == 0);
- tt_assert(public_server_mode(options) == 0);
- tt_int_op(directory_fetches_from_authorities(options), OP_EQ, 1);
- tt_int_op(networkstatus_consensus_can_use_multiple_directories(options),
- OP_EQ, 1);
- /* OR servers only fetch the consensus from the authorities when they don't
- * know their own address, but never use multiple directories for bootstrap
- */
- memset(options, 0, sizeof(or_options_t));
- options->ORPort_set = 1;
- mock_router_pick_published_address_result = -1;
- tt_assert(server_mode(options) == 1);
- tt_assert(public_server_mode(options) == 1);
- tt_int_op(directory_fetches_from_authorities(options), OP_EQ, 1);
- tt_int_op(networkstatus_consensus_can_use_multiple_directories(options),
- OP_EQ, 0);
- mock_router_pick_published_address_result = 0;
- tt_assert(server_mode(options) == 1);
- tt_assert(public_server_mode(options) == 1);
- tt_int_op(directory_fetches_from_authorities(options), OP_EQ, 0);
- tt_int_op(networkstatus_consensus_can_use_multiple_directories(options),
- OP_EQ, 0);
- /* Exit OR servers only fetch the consensus from the authorities when they
- * refuse unknown exits, but never use multiple directories for bootstrap
- */
- memset(options, 0, sizeof(or_options_t));
- options->ORPort_set = 1;
- options->ExitRelay = 1;
- mock_router_pick_published_address_result = 0;
- mock_router_my_exit_policy_is_reject_star_result = 0;
- mock_advertised_server_mode_result = 1;
- mock_router_get_my_routerinfo_result = &routerinfo;
- routerinfo.supports_tunnelled_dir_requests = 1;
- options->RefuseUnknownExits = 1;
- tt_assert(server_mode(options) == 1);
- tt_assert(public_server_mode(options) == 1);
- tt_int_op(directory_fetches_from_authorities(options), OP_EQ, 1);
- tt_int_op(networkstatus_consensus_can_use_multiple_directories(options),
- OP_EQ, 0);
- options->RefuseUnknownExits = 0;
- mock_router_pick_published_address_result = 0;
- tt_assert(server_mode(options) == 1);
- tt_assert(public_server_mode(options) == 1);
- tt_int_op(directory_fetches_from_authorities(options), OP_EQ, 0);
- tt_int_op(networkstatus_consensus_can_use_multiple_directories(options),
- OP_EQ, 0);
- /* Dir servers fetch the consensus from the authorities, unless they are not
- * advertising themselves (hibernating) or have no routerinfo or are not
- * advertising their dirport, and never use multiple directories for
- * bootstrap. This only applies if they are also OR servers.
- * (We don't care much about the behaviour of non-OR directory servers.) */
- memset(options, 0, sizeof(or_options_t));
- options->DirPort_set = 1;
- options->ORPort_set = 1;
- options->DirCache = 1;
- mock_router_pick_published_address_result = 0;
- mock_router_my_exit_policy_is_reject_star_result = 1;
- mock_advertised_server_mode_result = 1;
- routerinfo.dir_port = 1;
- mock_router_get_my_routerinfo_result = &routerinfo;
- tt_assert(server_mode(options) == 1);
- tt_assert(public_server_mode(options) == 1);
- tt_int_op(directory_fetches_from_authorities(options), OP_EQ, 1);
- tt_int_op(networkstatus_consensus_can_use_multiple_directories(options),
- OP_EQ, 0);
- mock_advertised_server_mode_result = 0;
- routerinfo.dir_port = 1;
- mock_router_get_my_routerinfo_result = &routerinfo;
- tt_assert(server_mode(options) == 1);
- tt_assert(public_server_mode(options) == 1);
- tt_int_op(directory_fetches_from_authorities(options), OP_EQ, 0);
- tt_int_op(networkstatus_consensus_can_use_multiple_directories(options),
- OP_EQ, 0);
- mock_advertised_server_mode_result = 1;
- mock_router_get_my_routerinfo_result = NULL;
- tt_assert(server_mode(options) == 1);
- tt_assert(public_server_mode(options) == 1);
- tt_int_op(directory_fetches_from_authorities(options), OP_EQ, 0);
- tt_int_op(networkstatus_consensus_can_use_multiple_directories(options),
- OP_EQ, 0);
- mock_advertised_server_mode_result = 1;
- routerinfo.dir_port = 0;
- routerinfo.supports_tunnelled_dir_requests = 0;
- mock_router_get_my_routerinfo_result = &routerinfo;
- tt_assert(server_mode(options) == 1);
- tt_assert(public_server_mode(options) == 1);
- tt_int_op(directory_fetches_from_authorities(options), OP_EQ, 0);
- tt_int_op(networkstatus_consensus_can_use_multiple_directories(options),
- OP_EQ, 0);
- mock_advertised_server_mode_result = 1;
- routerinfo.dir_port = 1;
- routerinfo.supports_tunnelled_dir_requests = 1;
- mock_router_get_my_routerinfo_result = &routerinfo;
- tt_assert(server_mode(options) == 1);
- tt_assert(public_server_mode(options) == 1);
- tt_int_op(directory_fetches_from_authorities(options), OP_EQ, 1);
- tt_int_op(networkstatus_consensus_can_use_multiple_directories(options),
- OP_EQ, 0);
- done:
- tor_free(options);
- UNMOCK(router_pick_published_address);
- UNMOCK(router_get_my_routerinfo);
- UNMOCK(advertised_server_mode);
- UNMOCK(router_my_exit_policy_is_reject_star);
- }
- static void
- test_config_default_fallback_dirs(void *arg)
- {
- const char *fallback[] = {
- #include "../or/fallback_dirs.inc"
- NULL
- };
- int n_included_fallback_dirs = 0;
- int n_added_fallback_dirs = 0;
- (void)arg;
- clear_dir_servers();
- while (fallback[n_included_fallback_dirs])
- n_included_fallback_dirs++;
- add_default_fallback_dir_servers();
- n_added_fallback_dirs = smartlist_len(router_get_fallback_dir_servers());
- tt_assert(n_included_fallback_dirs == n_added_fallback_dirs);
- done:
- clear_dir_servers();
- }
- static void
- test_config_port_cfg_line_extract_addrport(void *arg)
- {
- (void)arg;
- int unixy = 0;
- const char *rest = NULL;
- char *a = NULL;
- tt_int_op(port_cfg_line_extract_addrport("", &a, &unixy, &rest), OP_EQ, 0);
- tt_int_op(unixy, OP_EQ, 0);
- tt_str_op(a, OP_EQ, "");
- tt_str_op(rest, OP_EQ, "");
- tor_free(a);
- tt_int_op(port_cfg_line_extract_addrport("hello", &a, &unixy, &rest),
- OP_EQ, 0);
- tt_int_op(unixy, OP_EQ, 0);
- tt_str_op(a, OP_EQ, "hello");
- tt_str_op(rest, OP_EQ, "");
- tor_free(a);
- tt_int_op(port_cfg_line_extract_addrport(" flipperwalt gersplut",
- &a, &unixy, &rest), OP_EQ, 0);
- tt_int_op(unixy, OP_EQ, 0);
- tt_str_op(a, OP_EQ, "flipperwalt");
- tt_str_op(rest, OP_EQ, "gersplut");
- tor_free(a);
- tt_int_op(port_cfg_line_extract_addrport(" flipperwalt \t gersplut",
- &a, &unixy, &rest), OP_EQ, 0);
- tt_int_op(unixy, OP_EQ, 0);
- tt_str_op(a, OP_EQ, "flipperwalt");
- tt_str_op(rest, OP_EQ, "gersplut");
- tor_free(a);
- tt_int_op(port_cfg_line_extract_addrport("flipperwalt \t gersplut",
- &a, &unixy, &rest), OP_EQ, 0);
- tt_int_op(unixy, OP_EQ, 0);
- tt_str_op(a, OP_EQ, "flipperwalt");
- tt_str_op(rest, OP_EQ, "gersplut");
- tor_free(a);
- tt_int_op(port_cfg_line_extract_addrport("unix:flipperwalt \t gersplut",
- &a, &unixy, &rest), OP_EQ, 0);
- tt_int_op(unixy, OP_EQ, 1);
- tt_str_op(a, OP_EQ, "flipperwalt");
- tt_str_op(rest, OP_EQ, "gersplut");
- tor_free(a);
- tt_int_op(port_cfg_line_extract_addrport("lolol",
- &a, &unixy, &rest), OP_EQ, 0);
- tt_int_op(unixy, OP_EQ, 0);
- tt_str_op(a, OP_EQ, "lolol");
- tt_str_op(rest, OP_EQ, "");
- tor_free(a);
- tt_int_op(port_cfg_line_extract_addrport("unix:lolol",
- &a, &unixy, &rest), OP_EQ, 0);
- tt_int_op(unixy, OP_EQ, 1);
- tt_str_op(a, OP_EQ, "lolol");
- tt_str_op(rest, OP_EQ, "");
- tor_free(a);
- tt_int_op(port_cfg_line_extract_addrport("unix:lolol ",
- &a, &unixy, &rest), OP_EQ, 0);
- tt_int_op(unixy, OP_EQ, 1);
- tt_str_op(a, OP_EQ, "lolol");
- tt_str_op(rest, OP_EQ, "");
- tor_free(a);
- tt_int_op(port_cfg_line_extract_addrport(" unix:lolol",
- &a, &unixy, &rest), OP_EQ, 0);
- tt_int_op(unixy, OP_EQ, 1);
- tt_str_op(a, OP_EQ, "lolol");
- tt_str_op(rest, OP_EQ, "");
- tor_free(a);
- tt_int_op(port_cfg_line_extract_addrport("foobar:lolol",
- &a, &unixy, &rest), OP_EQ, 0);
- tt_int_op(unixy, OP_EQ, 0);
- tt_str_op(a, OP_EQ, "foobar:lolol");
- tt_str_op(rest, OP_EQ, "");
- tor_free(a);
- tt_int_op(port_cfg_line_extract_addrport(":lolol",
- &a, &unixy, &rest), OP_EQ, 0);
- tt_int_op(unixy, OP_EQ, 0);
- tt_str_op(a, OP_EQ, ":lolol");
- tt_str_op(rest, OP_EQ, "");
- tor_free(a);
- tt_int_op(port_cfg_line_extract_addrport("unix:\"lolol\"",
- &a, &unixy, &rest), OP_EQ, 0);
- tt_int_op(unixy, OP_EQ, 1);
- tt_str_op(a, OP_EQ, "lolol");
- tt_str_op(rest, OP_EQ, "");
- tor_free(a);
- tt_int_op(port_cfg_line_extract_addrport("unix:\"lolol\" ",
- &a, &unixy, &rest), OP_EQ, 0);
- tt_int_op(unixy, OP_EQ, 1);
- tt_str_op(a, OP_EQ, "lolol");
- tt_str_op(rest, OP_EQ, "");
- tor_free(a);
- tt_int_op(port_cfg_line_extract_addrport("unix:\"lolol\" foo ",
- &a, &unixy, &rest), OP_EQ, 0);
- tt_int_op(unixy, OP_EQ, 1);
- tt_str_op(a, OP_EQ, "lolol");
- tt_str_op(rest, OP_EQ, "foo ");
- tor_free(a);
- tt_int_op(port_cfg_line_extract_addrport("unix:\"lol ol\" foo ",
- &a, &unixy, &rest), OP_EQ, 0);
- tt_int_op(unixy, OP_EQ, 1);
- tt_str_op(a, OP_EQ, "lol ol");
- tt_str_op(rest, OP_EQ, "foo ");
- tor_free(a);
- tt_int_op(port_cfg_line_extract_addrport("unix:\"lol\\\" ol\" foo ",
- &a, &unixy, &rest), OP_EQ, 0);
- tt_int_op(unixy, OP_EQ, 1);
- tt_str_op(a, OP_EQ, "lol\" ol");
- tt_str_op(rest, OP_EQ, "foo ");
- tor_free(a);
- tt_int_op(port_cfg_line_extract_addrport("unix:\"lol\\\" ol foo ",
- &a, &unixy, &rest), OP_EQ, -1);
- tor_free(a);
- tt_int_op(port_cfg_line_extract_addrport("unix:\"lol\\0\" ol foo ",
- &a, &unixy, &rest), OP_EQ, -1);
- tor_free(a);
- done:
- tor_free(a);
- }
- static config_line_t *
- mock_config_line(const char *key, const char *val)
- {
- config_line_t *config_line = tor_malloc(sizeof(config_line_t));
- memset(config_line, 0, sizeof(config_line_t));
- config_line->key = tor_strdup(key);
- config_line->value = tor_strdup(val);
- return config_line;
- }
- static void
- test_config_parse_port_config__ports__no_ports_given(void *data)
- {
- (void)data;
- int ret;
- smartlist_t *slout = NULL;
- port_cfg_t *port_cfg = NULL;
- slout = smartlist_new();
- // Test no defaultport, no defaultaddress and no out
- ret = parse_port_config(NULL, NULL, "DNS", 0, NULL, 0, 0);
- tt_int_op(ret, OP_EQ, 0);
- // Test with defaultport, no defaultaddress and no out
- ret = parse_port_config(NULL, NULL, "DNS", 0, NULL, 42, 0);
- tt_int_op(ret, OP_EQ, 0);
- // Test no defaultport, with defaultaddress and no out
- ret = parse_port_config(NULL, NULL, "DNS", 0, "127.0.0.2", 0, 0);
- tt_int_op(ret, OP_EQ, 0);
- // Test with defaultport, with defaultaddress and no out
- ret = parse_port_config(NULL, NULL, "DNS", 0, "127.0.0.2", 42, 0);
- tt_int_op(ret, OP_EQ, 0);
- // Test no defaultport, no defaultaddress and with out
- ret = parse_port_config(slout, NULL, "DNS", 0, NULL, 0, 0);
- tt_int_op(ret, OP_EQ, 0);
- tt_int_op(smartlist_len(slout), OP_EQ, 0);
- // Test with defaultport, no defaultaddress and with out
- ret = parse_port_config(slout, NULL, "DNS", 0, NULL, 42, 0);
- tt_int_op(ret, OP_EQ, 0);
- tt_int_op(smartlist_len(slout), OP_EQ, 0);
- // Test no defaultport, with defaultaddress and with out
- ret = parse_port_config(slout, NULL, "DNS", 0, "127.0.0.2", 0, 0);
- tt_int_op(ret, OP_EQ, 0);
- tt_int_op(smartlist_len(slout), OP_EQ, 0);
- // Test with defaultport, with defaultaddress and out, adds a new port cfg
- SMARTLIST_FOREACH(slout,port_cfg_t *,pf,port_cfg_free(pf));
- smartlist_clear(slout);
- ret = parse_port_config(slout, NULL, "DNS", 0, "127.0.0.2", 42, 0);
- tt_int_op(ret, OP_EQ, 0);
- tt_int_op(smartlist_len(slout), OP_EQ, 1);
- port_cfg = (port_cfg_t *)smartlist_get(slout, 0);
- tt_int_op(port_cfg->port, OP_EQ, 42);
- tt_int_op(port_cfg->is_unix_addr, OP_EQ, 0);
- // Test with defaultport, with defaultaddress and out, adds a new port cfg
- // for a unix address
- SMARTLIST_FOREACH(slout,port_cfg_t *,pf,port_cfg_free(pf));
- smartlist_clear(slout);
- ret = parse_port_config(slout, NULL, "DNS", 0, "/foo/bar/unixdomain",
- 42, CL_PORT_IS_UNIXSOCKET);
- tt_int_op(ret, OP_EQ, 0);
- tt_int_op(smartlist_len(slout), OP_EQ, 1);
- port_cfg = (port_cfg_t *)smartlist_get(slout, 0);
- tt_int_op(port_cfg->port, OP_EQ, 0);
- tt_int_op(port_cfg->is_unix_addr, OP_EQ, 1);
- tt_str_op(port_cfg->unix_addr, OP_EQ, "/foo/bar/unixdomain");
- done:
- if (slout)
- SMARTLIST_FOREACH(slout,port_cfg_t *,pf,port_cfg_free(pf));
- smartlist_free(slout);
- }
- static void
- test_config_parse_port_config__ports__ports_given(void *data)
- {
- (void)data;
- int ret;
- smartlist_t *slout = NULL;
- port_cfg_t *port_cfg = NULL;
- config_line_t *config_port_invalid = NULL, *config_port_valid = NULL;
- tor_addr_t addr;
- slout = smartlist_new();
- // Test error when encounters an invalid Port specification
- config_port_invalid = mock_config_line("DNSPort", "");
- ret = parse_port_config(NULL, config_port_invalid, "DNS", 0, NULL,
- 0, 0);
- tt_int_op(ret, OP_EQ, -1);
- // Test error when encounters an empty unix domain specification
- config_free_lines(config_port_invalid); config_port_invalid = NULL;
- config_port_invalid = mock_config_line("DNSPort", "unix:");
- ret = parse_port_config(NULL, config_port_invalid, "DNS", 0, NULL,
- 0, 0);
- tt_int_op(ret, OP_EQ, -1);
- // Test error when encounters a unix domain specification but the listener
- // doesn't support domain sockets
- config_port_valid = mock_config_line("DNSPort", "unix:/tmp/foo/bar");
- ret = parse_port_config(NULL, config_port_valid, "DNS",
- CONN_TYPE_AP_DNS_LISTENER, NULL, 0, 0);
- tt_int_op(ret, OP_EQ, -1);
- // Test valid unix domain
- SMARTLIST_FOREACH(slout,port_cfg_t *,pf,port_cfg_free(pf));
- smartlist_clear(slout);
- ret = parse_port_config(slout, config_port_valid, "SOCKS",
- CONN_TYPE_AP_LISTENER, NULL, 0, 0);
- #ifdef _WIN32
- tt_int_op(ret, OP_EQ, -1);
- #else
- tt_int_op(ret, OP_EQ, 0);
- tt_int_op(smartlist_len(slout), OP_EQ, 1);
- port_cfg = (port_cfg_t *)smartlist_get(slout, 0);
- tt_int_op(port_cfg->port, OP_EQ, 0);
- tt_int_op(port_cfg->is_unix_addr, OP_EQ, 1);
- tt_str_op(port_cfg->unix_addr, OP_EQ, "/tmp/foo/bar");
- /* Test entry port defaults as initialised in parse_port_config */
- tt_int_op(port_cfg->entry_cfg.dns_request, OP_EQ, 1);
- tt_int_op(port_cfg->entry_cfg.ipv4_traffic, OP_EQ, 1);
- tt_int_op(port_cfg->entry_cfg.onion_traffic, OP_EQ, 1);
- tt_int_op(port_cfg->entry_cfg.cache_ipv4_answers, OP_EQ, 0);
- tt_int_op(port_cfg->entry_cfg.prefer_ipv6_virtaddr, OP_EQ, 1);
- #endif /* defined(_WIN32) */
- // Test failure if we have no ipv4 and no ipv6 and no onion (DNS only)
- config_free_lines(config_port_invalid); config_port_invalid = NULL;
- config_port_invalid = mock_config_line("SOCKSPort",
- "unix:/tmp/foo/bar NoIPv4Traffic "
- "NoIPv6Traffic "
- "NoOnionTraffic");
- ret = parse_port_config(NULL, config_port_invalid, "SOCKS",
- CONN_TYPE_AP_LISTENER, NULL, 0,
- CL_PORT_TAKES_HOSTNAMES);
- tt_int_op(ret, OP_EQ, -1);
- // Test failure if we have no DNS and we're a DNSPort
- config_free_lines(config_port_invalid); config_port_invalid = NULL;
- config_port_invalid = mock_config_line("DNSPort",
- "127.0.0.1:80 NoDNSRequest");
- ret = parse_port_config(NULL, config_port_invalid, "DNS",
- CONN_TYPE_AP_DNS_LISTENER, NULL, 0,
- CL_PORT_TAKES_HOSTNAMES);
- tt_int_op(ret, OP_EQ, -1);
- // If we're a DNSPort, DNS only is ok
- // Use a port because DNSPort doesn't support sockets
- config_free_lines(config_port_valid); config_port_valid = NULL;
- SMARTLIST_FOREACH(slout,port_cfg_t *,pf,port_cfg_free(pf));
- smartlist_clear(slout);
- config_port_valid = mock_config_line("DNSPort", "127.0.0.1:80 "
- "NoIPv6Traffic "
- "NoIPv4Traffic NoOnionTraffic");
- ret = parse_port_config(slout, config_port_valid, "DNS",
- CONN_TYPE_AP_DNS_LISTENER, NULL, 0,
- CL_PORT_TAKES_HOSTNAMES);
- tt_int_op(ret, OP_EQ, 0);
- tt_int_op(smartlist_len(slout), OP_EQ, 1);
- port_cfg = (port_cfg_t *)smartlist_get(slout, 0);
- tt_int_op(port_cfg->entry_cfg.dns_request, OP_EQ, 1);
- tt_int_op(port_cfg->entry_cfg.ipv4_traffic, OP_EQ, 0);
- tt_int_op(port_cfg->entry_cfg.ipv6_traffic, OP_EQ, 0);
- tt_int_op(port_cfg->entry_cfg.onion_traffic, OP_EQ, 0);
- // Test failure if we have DNS but no ipv4 and no ipv6
- config_free_lines(config_port_invalid); config_port_invalid = NULL;
- config_port_invalid = mock_config_line("SOCKSPort",
- "NoIPv6Traffic "
- "unix:/tmp/foo/bar NoIPv4Traffic");
- ret = parse_port_config(NULL, config_port_invalid, "SOCKS",
- CONN_TYPE_AP_LISTENER, NULL, 0,
- CL_PORT_TAKES_HOSTNAMES);
- tt_int_op(ret, OP_EQ, -1);
- // Test success with no DNS, no ipv4, no ipv6 (only onion, using separate
- // options)
- config_free_lines(config_port_valid); config_port_valid = NULL;
- SMARTLIST_FOREACH(slout,port_cfg_t *,pf,port_cfg_free(pf));
- smartlist_clear(slout);
- config_port_valid = mock_config_line("SOCKSPort", "unix:/tmp/foo/bar "
- "NoIPv6Traffic "
- "NoDNSRequest NoIPv4Traffic");
- ret = parse_port_config(slout, config_port_valid, "SOCKS",
- CONN_TYPE_AP_LISTENER, NULL, 0,
- CL_PORT_TAKES_HOSTNAMES);
- #ifdef _WIN32
- tt_int_op(ret, OP_EQ, -1);
- #else
- tt_int_op(ret, OP_EQ, 0);
- tt_int_op(smartlist_len(slout), OP_EQ, 1);
- port_cfg = (port_cfg_t *)smartlist_get(slout, 0);
- tt_int_op(port_cfg->entry_cfg.dns_request, OP_EQ, 0);
- tt_int_op(port_cfg->entry_cfg.ipv4_traffic, OP_EQ, 0);
- tt_int_op(port_cfg->entry_cfg.ipv6_traffic, OP_EQ, 0);
- tt_int_op(port_cfg->entry_cfg.onion_traffic, OP_EQ, 1);
- #endif /* defined(_WIN32) */
- // Test success with quoted unix: address.
- config_free_lines(config_port_valid); config_port_valid = NULL;
- SMARTLIST_FOREACH(slout,port_cfg_t *,pf,port_cfg_free(pf));
- smartlist_clear(slout);
- config_port_valid = mock_config_line("SOCKSPort", "unix:\"/tmp/foo/ bar\" "
- "NoIPv6Traffic "
- "NoDNSRequest NoIPv4Traffic");
- ret = parse_port_config(slout, config_port_valid, "SOCKS",
- CONN_TYPE_AP_LISTENER, NULL, 0,
- CL_PORT_TAKES_HOSTNAMES);
- #ifdef _WIN32
- tt_int_op(ret, OP_EQ, -1);
- #else
- tt_int_op(ret, OP_EQ, 0);
- tt_int_op(smartlist_len(slout), OP_EQ, 1);
- port_cfg = (port_cfg_t *)smartlist_get(slout, 0);
- tt_int_op(port_cfg->entry_cfg.dns_request, OP_EQ, 0);
- tt_int_op(port_cfg->entry_cfg.ipv4_traffic, OP_EQ, 0);
- tt_int_op(port_cfg->entry_cfg.ipv6_traffic, OP_EQ, 0);
- tt_int_op(port_cfg->entry_cfg.onion_traffic, OP_EQ, 1);
- #endif /* defined(_WIN32) */
- // Test failure with broken quoted unix: address.
- config_free_lines(config_port_valid); config_port_valid = NULL;
- SMARTLIST_FOREACH(slout,port_cfg_t *,pf,port_cfg_free(pf));
- smartlist_clear(slout);
- config_port_valid = mock_config_line("SOCKSPort", "unix:\"/tmp/foo/ bar "
- "NoIPv6Traffic "
- "NoDNSRequest NoIPv4Traffic");
- ret = parse_port_config(slout, config_port_valid, "SOCKS",
- CONN_TYPE_AP_LISTENER, NULL, 0,
- CL_PORT_TAKES_HOSTNAMES);
- tt_int_op(ret, OP_EQ, -1);
- // Test failure with empty quoted unix: address.
- config_free_lines(config_port_valid); config_port_valid = NULL;
- SMARTLIST_FOREACH(slout,port_cfg_t *,pf,port_cfg_free(pf));
- smartlist_clear(slout);
- config_port_valid = mock_config_line("SOCKSPort", "unix:\"\" "
- "NoIPv6Traffic "
- "NoDNSRequest NoIPv4Traffic");
- ret = parse_port_config(slout, config_port_valid, "SOCKS",
- CONN_TYPE_AP_LISTENER, NULL, 0,
- CL_PORT_TAKES_HOSTNAMES);
- tt_int_op(ret, OP_EQ, -1);
- // Test success with OnionTrafficOnly (no DNS, no ipv4, no ipv6)
- config_free_lines(config_port_valid); config_port_valid = NULL;
- SMARTLIST_FOREACH(slout,port_cfg_t *,pf,port_cfg_free(pf));
- smartlist_clear(slout);
- config_port_valid = mock_config_line("SOCKSPort", "unix:/tmp/foo/bar "
- "OnionTrafficOnly");
- ret = parse_port_config(slout, config_port_valid, "SOCKS",
- CONN_TYPE_AP_LISTENER, NULL, 0,
- CL_PORT_TAKES_HOSTNAMES);
- #ifdef _WIN32
- tt_int_op(ret, OP_EQ, -1);
- #else
- tt_int_op(ret, OP_EQ, 0);
- tt_int_op(smartlist_len(slout), OP_EQ, 1);
- port_cfg = (port_cfg_t *)smartlist_get(slout, 0);
- tt_int_op(port_cfg->entry_cfg.dns_request, OP_EQ, 0);
- tt_int_op(port_cfg->entry_cfg.ipv4_traffic, OP_EQ, 0);
- tt_int_op(port_cfg->entry_cfg.ipv6_traffic, OP_EQ, 0);
- tt_int_op(port_cfg->entry_cfg.onion_traffic, OP_EQ, 1);
- #endif /* defined(_WIN32) */
- // Test success with no ipv4 but take ipv6
- config_free_lines(config_port_valid); config_port_valid = NULL;
- SMARTLIST_FOREACH(slout,port_cfg_t *,pf,port_cfg_free(pf));
- smartlist_clear(slout);
- config_port_valid = mock_config_line("SOCKSPort", "unix:/tmp/foo/bar "
- "NoIPv4Traffic IPv6Traffic");
- ret = parse_port_config(slout, config_port_valid, "SOCKS",
- CONN_TYPE_AP_LISTENER, NULL, 0,
- CL_PORT_TAKES_HOSTNAMES);
- #ifdef _WIN32
- tt_int_op(ret, OP_EQ, -1);
- #else
- tt_int_op(ret, OP_EQ, 0);
- tt_int_op(smartlist_len(slout), OP_EQ, 1);
- port_cfg = (port_cfg_t *)smartlist_get(slout, 0);
- tt_int_op(port_cfg->entry_cfg.ipv4_traffic, OP_EQ, 0);
- tt_int_op(port_cfg->entry_cfg.ipv6_traffic, OP_EQ, 1);
- #endif /* defined(_WIN32) */
- // Test success with both ipv4 and ipv6
- config_free_lines(config_port_valid); config_port_valid = NULL;
- SMARTLIST_FOREACH(slout,port_cfg_t *,pf,port_cfg_free(pf));
- smartlist_clear(slout);
- config_port_valid = mock_config_line("SOCKSPort", "unix:/tmp/foo/bar "
- "IPv4Traffic IPv6Traffic");
- ret = parse_port_config(slout, config_port_valid, "SOCKS",
- CONN_TYPE_AP_LISTENER, NULL, 0,
- CL_PORT_TAKES_HOSTNAMES);
- #ifdef _WIN32
- tt_int_op(ret, OP_EQ, -1);
- #else
- tt_int_op(ret, OP_EQ, 0);
- tt_int_op(smartlist_len(slout), OP_EQ, 1);
- port_cfg = (port_cfg_t *)smartlist_get(slout, 0);
- tt_int_op(port_cfg->entry_cfg.ipv4_traffic, OP_EQ, 1);
- tt_int_op(port_cfg->entry_cfg.ipv6_traffic, OP_EQ, 1);
- #endif /* defined(_WIN32) */
- // Test failure if we specify world writable for an IP Port
- config_free_lines(config_port_invalid); config_port_invalid = NULL;
- config_port_invalid = mock_config_line("DNSPort", "42 WorldWritable");
- ret = parse_port_config(NULL, config_port_invalid, "DNS", 0,
- "127.0.0.3", 0, 0);
- tt_int_op(ret, OP_EQ, -1);
- // Test failure if we specify group writable for an IP Port
- config_free_lines(config_port_invalid); config_port_invalid = NULL;
- config_port_invalid = mock_config_line("DNSPort", "42 GroupWritable");
- ret = parse_port_config(NULL, config_port_invalid, "DNS", 0,
- "127.0.0.3", 0, 0);
- tt_int_op(ret, OP_EQ, -1);
- // Test failure if we specify group writable for an IP Port
- config_free_lines(config_port_invalid); config_port_invalid = NULL;
- config_port_invalid = mock_config_line("DNSPort", "42 RelaxDirModeCheck");
- ret = parse_port_config(NULL, config_port_invalid, "DNS", 0,
- "127.0.0.3", 0, 0);
- tt_int_op(ret, OP_EQ, -1);
- // Test success with only a port (this will fail without a default address)
- config_free_lines(config_port_valid); config_port_valid = NULL;
- config_port_valid = mock_config_line("DNSPort", "42");
- ret = parse_port_config(NULL, config_port_valid, "DNS", 0,
- "127.0.0.3", 0, 0);
- tt_int_op(ret, OP_EQ, 0);
- // Test success with only a port and isolate destination port
- config_free_lines(config_port_valid); config_port_valid = NULL;
- SMARTLIST_FOREACH(slout,port_cfg_t *,pf,port_cfg_free(pf));
- smartlist_clear(slout);
- config_port_valid = mock_config_line("DNSPort", "42 IsolateDestPort");
- ret = parse_port_config(slout, config_port_valid, "DNS", 0,
- "127.0.0.3", 0, 0);
- tt_int_op(ret, OP_EQ, 0);
- tt_int_op(smartlist_len(slout), OP_EQ, 1);
- port_cfg = (port_cfg_t *)smartlist_get(slout, 0);
- tt_int_op(port_cfg->entry_cfg.isolation_flags, OP_EQ,
- ISO_DEFAULT | ISO_DESTPORT);
- // Test success with a negative isolate destination port, and plural
- config_free_lines(config_port_valid); config_port_valid = NULL;
- SMARTLIST_FOREACH(slout,port_cfg_t *,pf,port_cfg_free(pf));
- smartlist_clear(slout);
- config_port_valid = mock_config_line("DNSPort", "42 NoIsolateDestPorts");
- ret = parse_port_config(slout, config_port_valid, "DNS", 0,
- "127.0.0.3", 0, 0);
- tt_int_op(ret, OP_EQ, 0);
- tt_int_op(smartlist_len(slout), OP_EQ, 1);
- port_cfg = (port_cfg_t *)smartlist_get(slout, 0);
- tt_int_op(port_cfg->entry_cfg.isolation_flags, OP_EQ,
- ISO_DEFAULT & ~ISO_DESTPORT);
- // Test success with isolate destination address
- config_free_lines(config_port_valid); config_port_valid = NULL;
- SMARTLIST_FOREACH(slout,port_cfg_t *,pf,port_cfg_free(pf));
- smartlist_clear(slout);
- config_port_valid = mock_config_line("DNSPort", "42 IsolateDestAddr");
- ret = parse_port_config(slout, config_port_valid, "DNS", 0,
- "127.0.0.3", 0, 0);
- tt_int_op(ret, OP_EQ, 0);
- tt_int_op(smartlist_len(slout), OP_EQ, 1);
- port_cfg = (port_cfg_t *)smartlist_get(slout, 0);
- tt_int_op(port_cfg->entry_cfg.isolation_flags, OP_EQ,
- ISO_DEFAULT | ISO_DESTADDR);
- // Test success with isolate socks AUTH
- config_free_lines(config_port_valid); config_port_valid = NULL;
- SMARTLIST_FOREACH(slout,port_cfg_t *,pf,port_cfg_free(pf));
- smartlist_clear(slout);
- config_port_valid = mock_config_line("DNSPort", "42 IsolateSOCKSAuth");
- ret = parse_port_config(slout, config_port_valid, "DNS", 0,
- "127.0.0.3", 0, 0);
- tt_int_op(ret, OP_EQ, 0);
- tt_int_op(smartlist_len(slout), OP_EQ, 1);
- port_cfg = (port_cfg_t *)smartlist_get(slout, 0);
- tt_int_op(port_cfg->entry_cfg.isolation_flags, OP_EQ,
- ISO_DEFAULT | ISO_SOCKSAUTH);
- // Test success with isolate client protocol
- config_free_lines(config_port_valid); config_port_valid = NULL;
- SMARTLIST_FOREACH(slout,port_cfg_t *,pf,port_cfg_free(pf));
- smartlist_clear(slout);
- config_port_valid = mock_config_line("DNSPort", "42 IsolateClientProtocol");
- ret = parse_port_config(slout, config_port_valid, "DNS", 0,
- "127.0.0.3", 0, 0);
- tt_int_op(ret, OP_EQ, 0);
- tt_int_op(smartlist_len(slout), OP_EQ, 1);
- port_cfg = (port_cfg_t *)smartlist_get(slout, 0);
- tt_int_op(port_cfg->entry_cfg.isolation_flags, OP_EQ,
- ISO_DEFAULT | ISO_CLIENTPROTO);
- // Test success with isolate client address
- config_free_lines(config_port_valid); config_port_valid = NULL;
- SMARTLIST_FOREACH(slout,port_cfg_t *,pf,port_cfg_free(pf));
- smartlist_clear(slout);
- config_port_valid = mock_config_line("DNSPort", "42 IsolateClientAddr");
- ret = parse_port_config(slout, config_port_valid, "DNS", 0,
- "127.0.0.3", 0, 0);
- tt_int_op(ret, OP_EQ, 0);
- tt_int_op(smartlist_len(slout), OP_EQ, 1);
- port_cfg = (port_cfg_t *)smartlist_get(slout, 0);
- tt_int_op(port_cfg->entry_cfg.isolation_flags, OP_EQ,
- ISO_DEFAULT | ISO_CLIENTADDR);
- // Test success with ignored unknown options
- config_free_lines(config_port_valid); config_port_valid = NULL;
- config_port_valid = mock_config_line("DNSPort", "42 ThisOptionDoesntExist");
- ret = parse_port_config(NULL, config_port_valid, "DNS", 0,
- "127.0.0.3", 0, 0);
- tt_int_op(ret, OP_EQ, 0);
- // Test success with no isolate socks AUTH
- config_free_lines(config_port_valid); config_port_valid = NULL;
- SMARTLIST_FOREACH(slout,port_cfg_t *,pf,port_cfg_free(pf));
- smartlist_clear(slout);
- config_port_valid = mock_config_line("DNSPort", "42 NoIsolateSOCKSAuth");
- ret = parse_port_config(slout, config_port_valid, "DNS", 0,
- "127.0.0.3", 0, 0);
- tt_int_op(ret, OP_EQ, 0);
- tt_int_op(smartlist_len(slout), OP_EQ, 1);
- port_cfg = (port_cfg_t *)smartlist_get(slout, 0);
- tt_int_op(port_cfg->entry_cfg.socks_prefer_no_auth, OP_EQ, 1);
- // Test success with prefer ipv6
- config_free_lines(config_port_valid); config_port_valid = NULL;
- SMARTLIST_FOREACH(slout,port_cfg_t *,pf,port_cfg_free(pf));
- smartlist_clear(slout);
- config_port_valid = mock_config_line("SOCKSPort",
- "42 IPv6Traffic PreferIPv6");
- ret = parse_port_config(slout, config_port_valid, "SOCKS",
- CONN_TYPE_AP_LISTENER, "127.0.0.42", 0,
- CL_PORT_TAKES_HOSTNAMES);
- tt_int_op(ret, OP_EQ, 0);
- tt_int_op(smartlist_len(slout), OP_EQ, 1);
- port_cfg = (port_cfg_t *)smartlist_get(slout, 0);
- tt_int_op(port_cfg->entry_cfg.prefer_ipv6, OP_EQ, 1);
- // Test success with cache ipv4 DNS
- config_free_lines(config_port_valid); config_port_valid = NULL;
- SMARTLIST_FOREACH(slout,port_cfg_t *,pf,port_cfg_free(pf));
- smartlist_clear(slout);
- config_port_valid = mock_config_line("DNSPort", "42 CacheIPv4DNS");
- ret = parse_port_config(slout, config_port_valid, "DNS", 0,
- "127.0.0.42", 0, 0);
- tt_int_op(ret, OP_EQ, 0);
- tt_int_op(smartlist_len(slout), OP_EQ, 1);
- port_cfg = (port_cfg_t *)smartlist_get(slout, 0);
- tt_int_op(port_cfg->entry_cfg.cache_ipv4_answers, OP_EQ, 1);
- tt_int_op(port_cfg->entry_cfg.cache_ipv6_answers, OP_EQ, 0);
- // Test success with cache ipv6 DNS
- config_free_lines(config_port_valid); config_port_valid = NULL;
- SMARTLIST_FOREACH(slout,port_cfg_t *,pf,port_cfg_free(pf));
- smartlist_clear(slout);
- config_port_valid = mock_config_line("DNSPort", "42 CacheIPv6DNS");
- ret = parse_port_config(slout, config_port_valid, "DNS", 0,
- "127.0.0.42", 0, 0);
- tt_int_op(ret, OP_EQ, 0);
- tt_int_op(smartlist_len(slout), OP_EQ, 1);
- port_cfg = (port_cfg_t *)smartlist_get(slout, 0);
- tt_int_op(port_cfg->entry_cfg.cache_ipv4_answers, OP_EQ, 0);
- tt_int_op(port_cfg->entry_cfg.cache_ipv6_answers, OP_EQ, 1);
- // Test success with no cache ipv4 DNS
- config_free_lines(config_port_valid); config_port_valid = NULL;
- SMARTLIST_FOREACH(slout,port_cfg_t *,pf,port_cfg_free(pf));
- smartlist_clear(slout);
- config_port_valid = mock_config_line("DNSPort", "42 NoCacheIPv4DNS");
- ret = parse_port_config(slout, config_port_valid, "DNS", 0,
- "127.0.0.42", 0, 0);
- tt_int_op(ret, OP_EQ, 0);
- tt_int_op(smartlist_len(slout), OP_EQ, 1);
- port_cfg = (port_cfg_t *)smartlist_get(slout, 0);
- tt_int_op(port_cfg->entry_cfg.cache_ipv4_answers, OP_EQ, 0);
- tt_int_op(port_cfg->entry_cfg.cache_ipv6_answers, OP_EQ, 0);
- // Test success with cache DNS
- config_free_lines(config_port_valid); config_port_valid = NULL;
- SMARTLIST_FOREACH(slout,port_cfg_t *,pf,port_cfg_free(pf));
- smartlist_clear(slout);
- config_port_valid = mock_config_line("DNSPort", "42 CacheDNS");
- ret = parse_port_config(slout, config_port_valid, "DNS", 0,
- "127.0.0.42", 0, CL_PORT_TAKES_HOSTNAMES);
- tt_int_op(ret, OP_EQ, 0);
- tt_int_op(smartlist_len(slout), OP_EQ, 1);
- port_cfg = (port_cfg_t *)smartlist_get(slout, 0);
- tt_int_op(port_cfg->entry_cfg.cache_ipv4_answers, OP_EQ, 1);
- tt_int_op(port_cfg->entry_cfg.cache_ipv6_answers, OP_EQ, 1);
- // Test success with use cached ipv4 DNS
- config_free_lines(config_port_valid); config_port_valid = NULL;
- SMARTLIST_FOREACH(slout,port_cfg_t *,pf,port_cfg_free(pf));
- smartlist_clear(slout);
- config_port_valid = mock_config_line("DNSPort", "42 UseIPv4Cache");
- ret = parse_port_config(slout, config_port_valid, "DNS", 0,
- "127.0.0.42", 0, 0);
- tt_int_op(ret, OP_EQ, 0);
- tt_int_op(smartlist_len(slout), OP_EQ, 1);
- port_cfg = (port_cfg_t *)smartlist_get(slout, 0);
- tt_int_op(port_cfg->entry_cfg.use_cached_ipv4_answers, OP_EQ, 1);
- tt_int_op(port_cfg->entry_cfg.use_cached_ipv6_answers, OP_EQ, 0);
- // Test success with use cached ipv6 DNS
- config_free_lines(config_port_valid); config_port_valid = NULL;
- SMARTLIST_FOREACH(slout,port_cfg_t *,pf,port_cfg_free(pf));
- smartlist_clear(slout);
- config_port_valid = mock_config_line("DNSPort", "42 UseIPv6Cache");
- ret = parse_port_config(slout, config_port_valid, "DNS", 0,
- "127.0.0.42", 0, 0);
- tt_int_op(ret, OP_EQ, 0);
- tt_int_op(smartlist_len(slout), OP_EQ, 1);
- port_cfg = (port_cfg_t *)smartlist_get(slout, 0);
- tt_int_op(port_cfg->entry_cfg.use_cached_ipv4_answers, OP_EQ, 0);
- tt_int_op(port_cfg->entry_cfg.use_cached_ipv6_answers, OP_EQ, 1);
- // Test success with use cached DNS
- config_free_lines(config_port_valid); config_port_valid = NULL;
- SMARTLIST_FOREACH(slout,port_cfg_t *,pf,port_cfg_free(pf));
- smartlist_clear(slout);
- config_port_valid = mock_config_line("DNSPort", "42 UseDNSCache");
- ret = parse_port_config(slout, config_port_valid, "DNS", 0,
- "127.0.0.42", 0, 0);
- tt_int_op(ret, OP_EQ, 0);
- tt_int_op(smartlist_len(slout), OP_EQ, 1);
- port_cfg = (port_cfg_t *)smartlist_get(slout, 0);
- tt_int_op(port_cfg->entry_cfg.use_cached_ipv4_answers, OP_EQ, 1);
- tt_int_op(port_cfg->entry_cfg.use_cached_ipv6_answers, OP_EQ, 1);
- // Test success with not preferring ipv6 automap
- config_free_lines(config_port_valid); config_port_valid = NULL;
- SMARTLIST_FOREACH(slout,port_cfg_t *,pf,port_cfg_free(pf));
- smartlist_clear(slout);
- config_port_valid = mock_config_line("DNSPort", "42 NoPreferIPv6Automap");
- ret = parse_port_config(slout, config_port_valid, "DNS", 0,
- "127.0.0.42", 0, 0);
- tt_int_op(ret, OP_EQ, 0);
- tt_int_op(smartlist_len(slout), OP_EQ, 1);
- port_cfg = (port_cfg_t *)smartlist_get(slout, 0);
- tt_int_op(port_cfg->entry_cfg.prefer_ipv6_virtaddr, OP_EQ, 0);
- // Test success with prefer SOCKS no auth
- config_free_lines(config_port_valid); config_port_valid = NULL;
- SMARTLIST_FOREACH(slout,port_cfg_t *,pf,port_cfg_free(pf));
- smartlist_clear(slout);
- config_port_valid = mock_config_line("DNSPort", "42 PreferSOCKSNoAuth");
- ret = parse_port_config(slout, config_port_valid, "DNS", 0,
- "127.0.0.42", 0, 0);
- tt_int_op(ret, OP_EQ, 0);
- tt_int_op(smartlist_len(slout), OP_EQ, 1);
- port_cfg = (port_cfg_t *)smartlist_get(slout, 0);
- tt_int_op(port_cfg->entry_cfg.socks_prefer_no_auth, OP_EQ, 1);
- // Test failure with both a zero port and a non-zero port
- config_free_lines(config_port_invalid); config_port_invalid = NULL;
- config_free_lines(config_port_valid); config_port_valid = NULL;
- SMARTLIST_FOREACH(slout,port_cfg_t *,pf,port_cfg_free(pf));
- smartlist_clear(slout);
- config_port_invalid = mock_config_line("DNSPort", "0");
- config_port_valid = mock_config_line("DNSPort", "42");
- config_port_invalid->next = config_port_valid;
- ret = parse_port_config(slout, config_port_invalid, "DNS", 0,
- "127.0.0.42", 0, 0);
- tt_int_op(ret, OP_EQ, -1);
- // Test success with warn non-local control
- SMARTLIST_FOREACH(slout,port_cfg_t *,pf,port_cfg_free(pf));
- smartlist_clear(slout);
- ret = parse_port_config(slout, config_port_valid, "Control",
- CONN_TYPE_CONTROL_LISTENER, "127.0.0.42", 0,
- CL_PORT_WARN_NONLOCAL);
- tt_int_op(ret, OP_EQ, 0);
- // Test success with warn non-local listener
- SMARTLIST_FOREACH(slout,port_cfg_t *,pf,port_cfg_free(pf));
- smartlist_clear(slout);
- ret = parse_port_config(slout, config_port_valid, "ExtOR",
- CONN_TYPE_EXT_OR_LISTENER, "127.0.0.42", 0,
- CL_PORT_WARN_NONLOCAL);
- tt_int_op(ret, OP_EQ, 0);
- // Test success with warn non-local other
- SMARTLIST_FOREACH(slout,port_cfg_t *,pf,port_cfg_free(pf));
- smartlist_clear(slout);
- ret = parse_port_config(slout, config_port_valid, "DNS", 0,
- "127.0.0.42", 0, CL_PORT_WARN_NONLOCAL);
- tt_int_op(ret, OP_EQ, 0);
- // Test success with warn non-local other without out
- ret = parse_port_config(NULL, config_port_valid, "DNS", 0,
- "127.0.0.42", 0, CL_PORT_WARN_NONLOCAL);
- tt_int_op(ret, OP_EQ, 0);
- // Test success with both ipv4 and ipv6 but without stream options
- config_free_lines(config_port_invalid); config_port_invalid = NULL;
- config_port_valid = NULL;
- SMARTLIST_FOREACH(slout,port_cfg_t *,pf,port_cfg_free(pf));
- smartlist_clear(slout);
- config_port_valid = mock_config_line("DNSPort", "42 IPv4Traffic "
- "IPv6Traffic");
- ret = parse_port_config(slout, config_port_valid, "DNS", 0,
- "127.0.0.44", 0,
- CL_PORT_TAKES_HOSTNAMES |
- CL_PORT_NO_STREAM_OPTIONS);
- tt_int_op(ret, OP_EQ, 0);
- tt_int_op(smartlist_len(slout), OP_EQ, 1);
- port_cfg = (port_cfg_t *)smartlist_get(slout, 0);
- tt_int_op(port_cfg->entry_cfg.ipv4_traffic, OP_EQ, 1);
- tt_int_op(port_cfg->entry_cfg.ipv6_traffic, OP_EQ, 1);
- // Test failure for a SessionGroup argument with invalid value
- config_free_lines(config_port_invalid); config_port_invalid = NULL;
- SMARTLIST_FOREACH(slout,port_cfg_t *,pf,port_cfg_free(pf));
- smartlist_clear(slout);
- config_port_invalid = mock_config_line("DNSPort", "42 SessionGroup=invalid");
- ret = parse_port_config(slout, config_port_invalid, "DNS", 0,
- "127.0.0.44", 0, CL_PORT_NO_STREAM_OPTIONS);
- tt_int_op(ret, OP_EQ, -1);
- // TODO: this seems wrong. Shouldn't it be the other way around?
- // Potential bug.
- // Test failure for a SessionGroup argument with valid value but with stream
- // options allowed
- config_free_lines(config_port_invalid); config_port_invalid = NULL;
- SMARTLIST_FOREACH(slout,port_cfg_t *,pf,port_cfg_free(pf));
- smartlist_clear(slout);
- config_port_invalid = mock_config_line("DNSPort", "42 SessionGroup=123");
- ret = parse_port_config(slout, config_port_invalid, "DNS", 0,
- "127.0.0.44", 0, 0);
- tt_int_op(ret, OP_EQ, -1);
- // Test failure for more than one SessionGroup argument
- config_free_lines(config_port_invalid); config_port_invalid = NULL;
- SMARTLIST_FOREACH(slout,port_cfg_t *,pf,port_cfg_free(pf));
- smartlist_clear(slout);
- config_port_invalid = mock_config_line("DNSPort", "42 SessionGroup=123 "
- "SessionGroup=321");
- ret = parse_port_config(slout, config_port_invalid, "DNS", 0,
- "127.0.0.44", 0, CL_PORT_NO_STREAM_OPTIONS);
- tt_int_op(ret, OP_EQ, -1);
- // Test success with a sessiongroup options
- config_free_lines(config_port_valid); config_port_valid = NULL;
- SMARTLIST_FOREACH(slout,port_cfg_t *,pf,port_cfg_free(pf));
- smartlist_clear(slout);
- config_port_valid = mock_config_line("DNSPort", "42 SessionGroup=1111122");
- ret = parse_port_config(slout, config_port_valid, "DNS", 0,
- "127.0.0.44", 0, CL_PORT_NO_STREAM_OPTIONS);
- tt_int_op(ret, OP_EQ, 0);
- tt_int_op(smartlist_len(slout), OP_EQ, 1);
- port_cfg = (port_cfg_t *)smartlist_get(slout, 0);
- tt_int_op(port_cfg->entry_cfg.session_group, OP_EQ, 1111122);
- // Test success with a zero unix domain socket, and doesnt add it to out
- config_free_lines(config_port_valid); config_port_valid = NULL;
- SMARTLIST_FOREACH(slout,port_cfg_t *,pf,port_cfg_free(pf));
- smartlist_clear(slout);
- config_port_valid = mock_config_line("DNSPort", "0");
- ret = parse_port_config(slout, config_port_valid, "DNS", 0,
- "127.0.0.45", 0, CL_PORT_IS_UNIXSOCKET);
- tt_int_op(ret, OP_EQ, 0);
- tt_int_op(smartlist_len(slout), OP_EQ, 0);
- // Test success with a one unix domain socket, and doesnt add it to out
- config_free_lines(config_port_valid); config_port_valid = NULL;
- SMARTLIST_FOREACH(slout,port_cfg_t *,pf,port_cfg_free(pf));
- smartlist_clear(slout);
- config_port_valid = mock_config_line("DNSPort", "something");
- ret = parse_port_config(slout, config_port_valid, "DNS", 0,
- "127.0.0.45", 0, CL_PORT_IS_UNIXSOCKET);
- tt_int_op(ret, OP_EQ, 0);
- tt_int_op(smartlist_len(slout), OP_EQ, 1);
- port_cfg = (port_cfg_t *)smartlist_get(slout, 0);
- tt_int_op(port_cfg->is_unix_addr, OP_EQ, 1);
- tt_str_op(port_cfg->unix_addr, OP_EQ, "something");
- // Test success with a port of auto - it uses the default address
- config_free_lines(config_port_valid); config_port_valid = NULL;
- SMARTLIST_FOREACH(slout,port_cfg_t *,pf,port_cfg_free(pf));
- smartlist_clear(slout);
- config_port_valid = mock_config_line("DNSPort", "auto");
- ret = parse_port_config(slout, config_port_valid, "DNS", 0,
- "127.0.0.46", 0, 0);
- tt_int_op(ret, OP_EQ, 0);
- tt_int_op(smartlist_len(slout), OP_EQ, 1);
- port_cfg = (port_cfg_t *)smartlist_get(slout, 0);
- tt_int_op(port_cfg->port, OP_EQ, CFG_AUTO_PORT);
- tor_addr_parse(&addr, "127.0.0.46");
- tt_assert(tor_addr_eq(&port_cfg->addr, &addr))
- // Test success with parsing both an address and an auto port
- config_free_lines(config_port_valid); config_port_valid = NULL;
- SMARTLIST_FOREACH(slout,port_cfg_t *,pf,port_cfg_free(pf));
- smartlist_clear(slout);
- config_port_valid = mock_config_line("DNSPort", "127.0.0.122:auto");
- ret = parse_port_config(slout, config_port_valid, "DNS", 0,
- "127.0.0.46", 0, 0);
- tt_int_op(ret, OP_EQ, 0);
- tt_int_op(smartlist_len(slout), OP_EQ, 1);
- port_cfg = (port_cfg_t *)smartlist_get(slout, 0);
- tt_int_op(port_cfg->port, OP_EQ, CFG_AUTO_PORT);
- tor_addr_parse(&addr, "127.0.0.122");
- tt_assert(tor_addr_eq(&port_cfg->addr, &addr))
- // Test failure when asked to parse an invalid address followed by auto
- config_free_lines(config_port_invalid); config_port_invalid = NULL;
- config_port_invalid = mock_config_line("DNSPort", "invalidstuff!!:auto");
- MOCK(tor_addr_lookup, mock_tor_addr_lookup__fail_on_bad_addrs);
- ret = parse_port_config(NULL, config_port_invalid, "DNS", 0,
- "127.0.0.46", 0, 0);
- UNMOCK(tor_addr_lookup);
- tt_int_op(ret, OP_EQ, -1);
- // Test success with parsing both an address and a real port
- config_free_lines(config_port_valid); config_port_valid = NULL;
- SMARTLIST_FOREACH(slout,port_cfg_t *,pf,port_cfg_free(pf));
- smartlist_clear(slout);
- config_port_valid = mock_config_line("DNSPort", "127.0.0.123:656");
- ret = parse_port_config(slout, config_port_valid, "DNS", 0,
- "127.0.0.46", 0, 0);
- tt_int_op(ret, OP_EQ, 0);
- tt_int_op(smartlist_len(slout), OP_EQ, 1);
- port_cfg = (port_cfg_t *)smartlist_get(slout, 0);
- tt_int_op(port_cfg->port, OP_EQ, 656);
- tor_addr_parse(&addr, "127.0.0.123");
- tt_assert(tor_addr_eq(&port_cfg->addr, &addr))
- // Test failure if we can't parse anything at all
- config_free_lines(config_port_invalid); config_port_invalid = NULL;
- SMARTLIST_FOREACH(slout,port_cfg_t *,pf,port_cfg_free(pf));
- smartlist_clear(slout);
- config_port_invalid = mock_config_line("DNSPort", "something wrong");
- ret = parse_port_config(slout, config_port_invalid, "DNS", 0,
- "127.0.0.46", 0, 0);
- tt_int_op(ret, OP_EQ, -1);
- // Test failure if we find both an address, a port and an auto
- config_free_lines(config_port_invalid); config_port_invalid = NULL;
- SMARTLIST_FOREACH(slout,port_cfg_t *,pf,port_cfg_free(pf));
- smartlist_clear(slout);
- config_port_invalid = mock_config_line("DNSPort", "127.0.1.0:123:auto");
- ret = parse_port_config(slout, config_port_invalid, "DNS", 0,
- "127.0.0.46", 0, 0);
- tt_int_op(ret, OP_EQ, -1);
- // Test that default to group writeable default sets group writeable for
- // domain socket
- config_free_lines(config_port_valid); config_port_valid = NULL;
- SMARTLIST_FOREACH(slout,port_cfg_t *,pf,port_cfg_free(pf));
- smartlist_clear(slout);
- config_port_valid = mock_config_line("SOCKSPort", "unix:/tmp/somewhere");
- ret = parse_port_config(slout, config_port_valid, "SOCKS",
- CONN_TYPE_AP_LISTENER, "127.0.0.46", 0,
- CL_PORT_DFLT_GROUP_WRITABLE);
- #ifdef _WIN32
- tt_int_op(ret, OP_EQ, -1);
- #else
- tt_int_op(ret, OP_EQ, 0);
- tt_int_op(smartlist_len(slout), OP_EQ, 1);
- port_cfg = (port_cfg_t *)smartlist_get(slout, 0);
- tt_int_op(port_cfg->is_group_writable, OP_EQ, 1);
- #endif /* defined(_WIN32) */
- done:
- if (slout)
- SMARTLIST_FOREACH(slout,port_cfg_t *,pf,port_cfg_free(pf));
- smartlist_free(slout);
- config_free_lines(config_port_invalid); config_port_invalid = NULL;
- config_free_lines(config_port_valid); config_port_valid = NULL;
- }
- static void
- test_config_parse_port_config__ports__server_options(void *data)
- {
- (void)data;
- int ret;
- smartlist_t *slout = NULL;
- port_cfg_t *port_cfg = NULL;
- config_line_t *config_port_invalid = NULL, *config_port_valid = NULL;
- slout = smartlist_new();
- // Test success with NoAdvertise option
- config_free_lines(config_port_valid); config_port_valid = NULL;
- config_port_valid = mock_config_line("DNSPort",
- "127.0.0.124:656 NoAdvertise");
- ret = parse_port_config(slout, config_port_valid, "DNS", 0, NULL, 0,
- CL_PORT_SERVER_OPTIONS);
- tt_int_op(ret, OP_EQ, 0);
- tt_int_op(smartlist_len(slout), OP_EQ, 1);
- port_cfg = (port_cfg_t *)smartlist_get(slout, 0);
- tt_int_op(port_cfg->server_cfg.no_advertise, OP_EQ, 1);
- tt_int_op(port_cfg->server_cfg.no_listen, OP_EQ, 0);
- // Test success with NoListen option
- config_free_lines(config_port_valid); config_port_valid = NULL;
- SMARTLIST_FOREACH(slout,port_cfg_t *,pf,port_cfg_free(pf));
- smartlist_clear(slout);
- config_port_valid = mock_config_line("DNSPort", "127.0.0.124:656 NoListen");
- ret = parse_port_config(slout, config_port_valid, "DNS", 0, NULL, 0,
- CL_PORT_SERVER_OPTIONS);
- tt_int_op(ret, OP_EQ, 0);
- tt_int_op(smartlist_len(slout), OP_EQ, 1);
- port_cfg = (port_cfg_t *)smartlist_get(slout, 0);
- tt_int_op(port_cfg->server_cfg.no_advertise, OP_EQ, 0);
- tt_int_op(port_cfg->server_cfg.no_listen, OP_EQ, 1);
- // Test failure with both NoAdvertise and NoListen option
- config_free_lines(config_port_invalid); config_port_invalid = NULL;
- SMARTLIST_FOREACH(slout,port_cfg_t *,pf,port_cfg_free(pf));
- smartlist_clear(slout);
- config_port_invalid = mock_config_line("DNSPort", "127.0.0.124:656 NoListen "
- "NoAdvertise");
- ret = parse_port_config(slout, config_port_invalid, "DNS", 0, NULL,
- 0, CL_PORT_SERVER_OPTIONS);
- tt_int_op(ret, OP_EQ, -1);
- // Test success with IPv4Only
- config_free_lines(config_port_valid); config_port_valid = NULL;
- SMARTLIST_FOREACH(slout,port_cfg_t *,pf,port_cfg_free(pf));
- smartlist_clear(slout);
- config_port_valid = mock_config_line("DNSPort", "127.0.0.124:656 IPv4Only");
- ret = parse_port_config(slout, config_port_valid, "DNS", 0, NULL, 0,
- CL_PORT_SERVER_OPTIONS);
- tt_int_op(ret, OP_EQ, 0);
- tt_int_op(smartlist_len(slout), OP_EQ, 1);
- port_cfg = (port_cfg_t *)smartlist_get(slout, 0);
- tt_int_op(port_cfg->server_cfg.bind_ipv4_only, OP_EQ, 1);
- tt_int_op(port_cfg->server_cfg.bind_ipv6_only, OP_EQ, 0);
- // Test success with IPv6Only
- config_free_lines(config_port_valid); config_port_valid = NULL;
- SMARTLIST_FOREACH(slout,port_cfg_t *,pf,port_cfg_free(pf));
- smartlist_clear(slout);
- config_port_valid = mock_config_line("DNSPort", "[::1]:656 IPv6Only");
- ret = parse_port_config(slout, config_port_valid, "DNS", 0, NULL, 0,
- CL_PORT_SERVER_OPTIONS);
- tt_int_op(ret, OP_EQ, 0);
- tt_int_op(smartlist_len(slout), OP_EQ, 1);
- port_cfg = (port_cfg_t *)smartlist_get(slout, 0);
- tt_int_op(port_cfg->server_cfg.bind_ipv4_only, OP_EQ, 0);
- tt_int_op(port_cfg->server_cfg.bind_ipv6_only, OP_EQ, 1);
- // Test failure with both IPv4Only and IPv6Only
- config_free_lines(config_port_invalid); config_port_invalid = NULL;
- SMARTLIST_FOREACH(slout,port_cfg_t *,pf,port_cfg_free(pf));
- smartlist_clear(slout);
- config_port_invalid = mock_config_line("DNSPort", "127.0.0.124:656 IPv6Only "
- "IPv4Only");
- ret = parse_port_config(slout, config_port_invalid, "DNS", 0, NULL,
- 0, CL_PORT_SERVER_OPTIONS);
- tt_int_op(ret, OP_EQ, -1);
- // Test success with invalid parameter
- config_free_lines(config_port_valid); config_port_valid = NULL;
- SMARTLIST_FOREACH(slout,port_cfg_t *,pf,port_cfg_free(pf));
- smartlist_clear(slout);
- config_port_valid = mock_config_line("DNSPort", "127.0.0.124:656 unknown");
- ret = parse_port_config(slout, config_port_valid, "DNS", 0, NULL, 0,
- CL_PORT_SERVER_OPTIONS);
- tt_int_op(ret, OP_EQ, 0);
- tt_int_op(smartlist_len(slout), OP_EQ, 1);
- // Test failure when asked to bind only to ipv6 but gets an ipv4 address
- config_free_lines(config_port_invalid); config_port_invalid = NULL;
- SMARTLIST_FOREACH(slout,port_cfg_t *,pf,port_cfg_free(pf));
- smartlist_clear(slout);
- config_port_invalid = mock_config_line("DNSPort",
- "127.0.0.124:656 IPv6Only");
- ret = parse_port_config(slout, config_port_invalid, "DNS", 0, NULL,
- 0, CL_PORT_SERVER_OPTIONS);
- tt_int_op(ret, OP_EQ, -1);
- // Test failure when asked to bind only to ipv4 but gets an ipv6 address
- config_free_lines(config_port_invalid); config_port_invalid = NULL;
- SMARTLIST_FOREACH(slout,port_cfg_t *,pf,port_cfg_free(pf));
- smartlist_clear(slout);
- config_port_invalid = mock_config_line("DNSPort", "[::1]:656 IPv4Only");
- ret = parse_port_config(slout, config_port_invalid, "DNS", 0, NULL,
- 0, CL_PORT_SERVER_OPTIONS);
- tt_int_op(ret, OP_EQ, -1);
- // Check for failure with empty unix: address.
- config_free_lines(config_port_invalid); config_port_invalid = NULL;
- SMARTLIST_FOREACH(slout,port_cfg_t *,pf,port_cfg_free(pf));
- smartlist_clear(slout);
- config_port_invalid = mock_config_line("ORPort", "unix:\"\"");
- ret = parse_port_config(slout, config_port_invalid, "ORPort", 0, NULL,
- 0, CL_PORT_SERVER_OPTIONS);
- tt_int_op(ret, OP_EQ, -1);
- done:
- if (slout)
- SMARTLIST_FOREACH(slout,port_cfg_t *,pf,port_cfg_free(pf));
- smartlist_free(slout);
- config_free_lines(config_port_invalid); config_port_invalid = NULL;
- config_free_lines(config_port_valid); config_port_valid = NULL;
- }
- static void
- test_config_parse_log_severity(void *data)
- {
- int ret;
- const char *severity_log_lines[] = {
- "debug file /tmp/debug.log",
- "debug\tfile /tmp/debug.log",
- "[handshake]debug [~net,~mm]info notice stdout",
- "[handshake]debug\t[~net,~mm]info\tnotice\tstdout",
- NULL
- };
- int i;
- log_severity_list_t *severity;
- (void) data;
- severity = tor_malloc(sizeof(log_severity_list_t));
- for (i = 0; severity_log_lines[i]; i++) {
- memset(severity, 0, sizeof(log_severity_list_t));
- ret = parse_log_severity_config(&severity_log_lines[i], severity);
- tt_int_op(ret, OP_EQ, 0);
- }
- done:
- tor_free(severity);
- }
- static void
- test_config_include_limit(void *data)
- {
- (void)data;
- config_line_t *result = NULL;
- char *torrc_path = NULL;
- char *dir = tor_strdup(get_fname("test_include_limit"));
- tt_ptr_op(dir, OP_NE, NULL);
- #ifdef _WIN32
- tt_int_op(mkdir(dir), OP_EQ, 0);
- #else
- tt_int_op(mkdir(dir, 0700), OP_EQ, 0);
- #endif
- tor_asprintf(&torrc_path, "%s"PATH_SEPARATOR"torrc", dir);
- char torrc_contents[1000];
- tor_snprintf(torrc_contents, sizeof(torrc_contents), "%%include %s",
- torrc_path);
- tt_int_op(write_str_to_file(torrc_path, torrc_contents, 0), OP_EQ, 0);
- tt_int_op(config_get_lines_include(torrc_contents, &result, 0, NULL, NULL),
- OP_EQ, -1);
- done:
- config_free_lines(result);
- tor_free(torrc_path);
- tor_free(dir);
- }
- static void
- test_config_include_does_not_exist(void *data)
- {
- (void)data;
- config_line_t *result = NULL;
- char *dir = tor_strdup(get_fname("test_include_does_not_exist"));
- char *missing_path = NULL;
- tt_ptr_op(dir, OP_NE, NULL);
- #ifdef _WIN32
- tt_int_op(mkdir(dir), OP_EQ, 0);
- #else
- tt_int_op(mkdir(dir, 0700), OP_EQ, 0);
- #endif
- tor_asprintf(&missing_path, "%s"PATH_SEPARATOR"missing", dir);
- char torrc_contents[1000];
- tor_snprintf(torrc_contents, sizeof(torrc_contents), "%%include %s",
- missing_path);
- tt_int_op(config_get_lines_include(torrc_contents, &result, 0, NULL, NULL),
- OP_EQ, -1);
- done:
- config_free_lines(result);
- tor_free(dir);
- tor_free(missing_path);
- }
- static void
- test_config_include_error_in_included_file(void *data)
- {
- (void)data;
- config_line_t *result = NULL;
- char *dir = tor_strdup(get_fname("test_error_in_included_file"));
- char *invalid_path = NULL;
- tt_ptr_op(dir, OP_NE, NULL);
- #ifdef _WIN32
- tt_int_op(mkdir(dir), OP_EQ, 0);
- #else
- tt_int_op(mkdir(dir, 0700), OP_EQ, 0);
- #endif
- tor_asprintf(&invalid_path, "%s"PATH_SEPARATOR"invalid", dir);
- tt_int_op(write_str_to_file(invalid_path, "unclosed \"", 0), OP_EQ, 0);
- char torrc_contents[1000];
- tor_snprintf(torrc_contents, sizeof(torrc_contents), "%%include %s",
- invalid_path);
- tt_int_op(config_get_lines_include(torrc_contents, &result, 0, NULL, NULL),
- OP_EQ, -1);
- done:
- config_free_lines(result);
- tor_free(dir);
- tor_free(invalid_path);
- }
- static void
- test_config_include_empty_file_folder(void *data)
- {
- (void)data;
- config_line_t *result = NULL;
- char *folder_path = NULL;
- char *file_path = NULL;
- char *dir = tor_strdup(get_fname("test_include_empty_file_folder"));
- tt_ptr_op(dir, OP_NE, NULL);
- #ifdef _WIN32
- tt_int_op(mkdir(dir), OP_EQ, 0);
- #else
- tt_int_op(mkdir(dir, 0700), OP_EQ, 0);
- #endif
- tor_asprintf(&folder_path, "%s"PATH_SEPARATOR"empty_dir", dir);
- #ifdef _WIN32
- tt_int_op(mkdir(folder_path), OP_EQ, 0);
- #else
- tt_int_op(mkdir(folder_path, 0700), OP_EQ, 0);
- #endif
- tor_asprintf(&file_path, "%s"PATH_SEPARATOR"empty_file", dir);
- tt_int_op(write_str_to_file(file_path, "", 0), OP_EQ, 0);
- char torrc_contents[1000];
- tor_snprintf(torrc_contents, sizeof(torrc_contents),
- "%%include %s\n"
- "%%include %s\n",
- folder_path, file_path);
- int include_used;
- tt_int_op(config_get_lines_include(torrc_contents, &result, 0,&include_used,
- NULL), OP_EQ, 0);
- tt_ptr_op(result, OP_EQ, NULL);
- tt_int_op(include_used, OP_EQ, 1);
- done:
- config_free_lines(result);
- tor_free(folder_path);
- tor_free(file_path);
- tor_free(dir);
- }
- #ifndef _WIN32
- static void
- test_config_include_no_permission(void *data)
- {
- (void)data;
- config_line_t *result = NULL;
- char *folder_path = NULL;
- char *dir = NULL;
- if (geteuid() == 0)
- tt_skip();
- dir = tor_strdup(get_fname("test_include_forbidden_folder"));
- tt_ptr_op(dir, OP_NE, NULL);
- tt_int_op(mkdir(dir, 0700), OP_EQ, 0);
- tor_asprintf(&folder_path, "%s"PATH_SEPARATOR"forbidden_dir", dir);
- tt_int_op(mkdir(folder_path, 0100), OP_EQ, 0);
- char torrc_contents[1000];
- tor_snprintf(torrc_contents, sizeof(torrc_contents),
- "%%include %s\n",
- folder_path);
- int include_used;
- tt_int_op(config_get_lines_include(torrc_contents, &result, 0,
- &include_used, NULL),
- OP_EQ, -1);
- tt_ptr_op(result, OP_EQ, NULL);
- done:
- config_free_lines(result);
- tor_free(folder_path);
- if (dir)
- chmod(dir, 0700);
- tor_free(dir);
- }
- #endif
- static void
- test_config_include_recursion_before_after(void *data)
- {
- (void)data;
- config_line_t *result = NULL;
- char *torrc_path = NULL;
- char *dir = tor_strdup(get_fname("test_include_recursion_before_after"));
- tt_ptr_op(dir, OP_NE, NULL);
- #ifdef _WIN32
- tt_int_op(mkdir(dir), OP_EQ, 0);
- #else
- tt_int_op(mkdir(dir, 0700), OP_EQ, 0);
- #endif
- tor_asprintf(&torrc_path, "%s"PATH_SEPARATOR"torrc", dir);
- char file_contents[1000];
- const int limit = MAX_INCLUDE_RECURSION_LEVEL;
- int i;
- // Loop backwards so file_contents has the contents of the first file by the
- // end of the loop
- for (i = limit; i > 0; i--) {
- if (i < limit) {
- tor_snprintf(file_contents, sizeof(file_contents),
- "Test %d\n"
- "%%include %s%d\n"
- "Test %d\n",
- i, torrc_path, i + 1, 2 * limit - i);
- } else {
- tor_snprintf(file_contents, sizeof(file_contents), "Test %d\n", i);
- }
- if (i > 1) {
- char *file_path = NULL;
- tor_asprintf(&file_path, "%s%d", torrc_path, i);
- tt_int_op(write_str_to_file(file_path, file_contents, 0), OP_EQ, 0);
- tor_free(file_path);
- }
- }
- int include_used;
- tt_int_op(config_get_lines_include(file_contents, &result, 0, &include_used,
- NULL), OP_EQ, 0);
- tt_ptr_op(result, OP_NE, NULL);
- tt_int_op(include_used, OP_EQ, 1);
- int len = 0;
- config_line_t *next;
- for (next = result; next != NULL; next = next->next) {
- char expected[10];
- tor_snprintf(expected, sizeof(expected), "%d", len + 1);
- tt_str_op(next->key, OP_EQ, "Test");
- tt_str_op(next->value, OP_EQ, expected);
- len++;
- }
- tt_int_op(len, OP_EQ, 2 * limit - 1);
- done:
- config_free_lines(result);
- tor_free(dir);
- tor_free(torrc_path);
- }
- static void
- test_config_include_recursion_after_only(void *data)
- {
- (void)data;
- config_line_t *result = NULL;
- char *torrc_path = NULL;
- char *dir = tor_strdup(get_fname("test_include_recursion_after_only"));
- tt_ptr_op(dir, OP_NE, NULL);
- #ifdef _WIN32
- tt_int_op(mkdir(dir), OP_EQ, 0);
- #else
- tt_int_op(mkdir(dir, 0700), OP_EQ, 0);
- #endif
- tor_asprintf(&torrc_path, "%s"PATH_SEPARATOR"torrc", dir);
- char file_contents[1000];
- const int limit = MAX_INCLUDE_RECURSION_LEVEL;
- int i;
- // Loop backwards so file_contents has the contents of the first file by the
- // end of the loop
- for (i = limit; i > 0; i--) {
- int n = (i - limit - 1) * -1;
- if (i < limit) {
- tor_snprintf(file_contents, sizeof(file_contents),
- "%%include %s%d\n"
- "Test %d\n",
- torrc_path, i + 1, n);
- } else {
- tor_snprintf(file_contents, sizeof(file_contents), "Test %d\n", n);
- }
- if (i > 1) {
- char *file_path = NULL;
- tor_asprintf(&file_path, "%s%d", torrc_path, i);
- tt_int_op(write_str_to_file(file_path, file_contents, 0), OP_EQ, 0);
- tor_free(file_path);
- }
- }
- int include_used;
- tt_int_op(config_get_lines_include(file_contents, &result, 0, &include_used,
- NULL), OP_EQ, 0);
- tt_ptr_op(result, OP_NE, NULL);
- tt_int_op(include_used, OP_EQ, 1);
- int len = 0;
- config_line_t *next;
- for (next = result; next != NULL; next = next->next) {
- char expected[10];
- tor_snprintf(expected, sizeof(expected), "%d", len + 1);
- tt_str_op(next->key, OP_EQ, "Test");
- tt_str_op(next->value, OP_EQ, expected);
- len++;
- }
- tt_int_op(len, OP_EQ, limit);
- done:
- config_free_lines(result);
- tor_free(dir);
- tor_free(torrc_path);
- }
- static void
- test_config_include_folder_order(void *data)
- {
- (void)data;
- config_line_t *result = NULL;
- char *torrcd = NULL;
- char *path = NULL;
- char *path2 = NULL;
- char *dir = tor_strdup(get_fname("test_include_folder_order"));
- tt_ptr_op(dir, OP_NE, NULL);
- #ifdef _WIN32
- tt_int_op(mkdir(dir), OP_EQ, 0);
- #else
- tt_int_op(mkdir(dir, 0700), OP_EQ, 0);
- #endif
- tor_asprintf(&torrcd, "%s"PATH_SEPARATOR"%s", dir, "torrc.d");
- #ifdef _WIN32
- tt_int_op(mkdir(torrcd), OP_EQ, 0);
- #else
- tt_int_op(mkdir(torrcd, 0700), OP_EQ, 0);
- #endif
- // test that files in subfolders are ignored
- tor_asprintf(&path, "%s"PATH_SEPARATOR"%s", torrcd, "subfolder");
- #ifdef _WIN32
- tt_int_op(mkdir(path), OP_EQ, 0);
- #else
- tt_int_op(mkdir(path, 0700), OP_EQ, 0);
- #endif
- tor_asprintf(&path2, "%s"PATH_SEPARATOR"%s", path, "01_ignore");
- tt_int_op(write_str_to_file(path2, "ShouldNotSee 1\n", 0), OP_EQ, 0);
- tor_free(path);
- // test that files starting with . are ignored
- tor_asprintf(&path, "%s"PATH_SEPARATOR"%s", torrcd, ".dot");
- tt_int_op(write_str_to_file(path, "ShouldNotSee 2\n", 0), OP_EQ, 0);
- tor_free(path);
- // test file order
- tor_asprintf(&path, "%s"PATH_SEPARATOR"%s", torrcd, "01_1st");
- tt_int_op(write_str_to_file(path, "Test 1\n", 0), OP_EQ, 0);
- tor_free(path);
- tor_asprintf(&path, "%s"PATH_SEPARATOR"%s", torrcd, "02_2nd");
- tt_int_op(write_str_to_file(path, "Test 2\n", 0), OP_EQ, 0);
- tor_free(path);
- tor_asprintf(&path, "%s"PATH_SEPARATOR"%s", torrcd, "aa_3rd");
- tt_int_op(write_str_to_file(path, "Test 3\n", 0), OP_EQ, 0);
- tor_free(path);
- tor_asprintf(&path, "%s"PATH_SEPARATOR"%s", torrcd, "ab_4th");
- tt_int_op(write_str_to_file(path, "Test 4\n", 0), OP_EQ, 0);
- tor_free(path);
- char torrc_contents[1000];
- tor_snprintf(torrc_contents, sizeof(torrc_contents),
- "%%include %s\n",
- torrcd);
- int include_used;
- tt_int_op(config_get_lines_include(torrc_contents, &result, 0, &include_used,
- NULL), OP_EQ, 0);
- tt_ptr_op(result, OP_NE, NULL);
- tt_int_op(include_used, OP_EQ, 1);
- int len = 0;
- config_line_t *next;
- for (next = result; next != NULL; next = next->next) {
- char expected[10];
- tor_snprintf(expected, sizeof(expected), "%d", len + 1);
- tt_str_op(next->key, OP_EQ, "Test");
- tt_str_op(next->value, OP_EQ, expected);
- len++;
- }
- tt_int_op(len, OP_EQ, 4);
- done:
- config_free_lines(result);
- tor_free(torrcd);
- tor_free(path);
- tor_free(path2);
- tor_free(dir);
- }
- static void
- test_config_include_path_syntax(void *data)
- {
- (void)data;
- config_line_t *result = NULL;
- char *dir = tor_strdup(get_fname("test_include_path_syntax"));
- char *esc_dir = NULL, *dir_with_pathsep = NULL,
- *esc_dir_with_pathsep = NULL, *torrc_contents = NULL;
- tt_ptr_op(dir, OP_NE, NULL);
- #ifdef _WIN32
- tt_int_op(mkdir(dir), OP_EQ, 0);
- #else
- tt_int_op(mkdir(dir, 0700), OP_EQ, 0);
- #endif
- esc_dir = esc_for_log(dir);
- tor_asprintf(&dir_with_pathsep, "%s%s", dir, PATH_SEPARATOR);
- esc_dir_with_pathsep = esc_for_log(dir_with_pathsep);
- tor_asprintf(&torrc_contents,
- "%%include %s\n"
- "%%include %s%s \n" // space to avoid suppressing newline
- "%%include %s\n",
- esc_dir,
- dir, PATH_SEPARATOR,
- esc_dir_with_pathsep);
- int include_used;
- tt_int_op(config_get_lines_include(torrc_contents, &result, 0,&include_used,
- NULL), OP_EQ, 0);
- tt_ptr_op(result, OP_EQ, NULL);
- tt_int_op(include_used, OP_EQ, 1);
- done:
- config_free_lines(result);
- tor_free(dir);
- tor_free(torrc_contents);
- tor_free(esc_dir);
- tor_free(dir_with_pathsep);
- tor_free(esc_dir_with_pathsep);
- }
- static void
- test_config_include_not_processed(void *data)
- {
- (void)data;
- char torrc_contents[1000] = "%include does_not_exist\n";
- config_line_t *result = NULL;
- tt_int_op(config_get_lines(torrc_contents, &result, 0),OP_EQ, 0);
- tt_ptr_op(result, OP_NE, NULL);
- int len = 0;
- config_line_t *next;
- for (next = result; next != NULL; next = next->next) {
- tt_str_op(next->key, OP_EQ, "%include");
- tt_str_op(next->value, OP_EQ, "does_not_exist");
- len++;
- }
- tt_int_op(len, OP_EQ, 1);
- done:
- config_free_lines(result);
- }
- static void
- test_config_include_has_include(void *data)
- {
- (void)data;
- config_line_t *result = NULL;
- char *dir = tor_strdup(get_fname("test_include_has_include"));
- tt_ptr_op(dir, OP_NE, NULL);
- #ifdef _WIN32
- tt_int_op(mkdir(dir), OP_EQ, 0);
- #else
- tt_int_op(mkdir(dir, 0700), OP_EQ, 0);
- #endif
- char torrc_contents[1000] = "Test 1\n";
- int include_used;
- tt_int_op(config_get_lines_include(torrc_contents, &result, 0,&include_used,
- NULL), OP_EQ, 0);
- tt_int_op(include_used, OP_EQ, 0);
- config_free_lines(result);
- tor_snprintf(torrc_contents, sizeof(torrc_contents), "%%include %s\n", dir);
- tt_int_op(config_get_lines_include(torrc_contents, &result, 0,&include_used,
- NULL), OP_EQ, 0);
- tt_int_op(include_used, OP_EQ, 1);
- done:
- config_free_lines(result);
- tor_free(dir);
- }
- static void
- test_config_include_flag_both_without(void *data)
- {
- (void)data;
- char *errmsg = NULL;
- char conf_empty[1000];
- tor_snprintf(conf_empty, sizeof(conf_empty),
- "DataDirectory %s\n",
- get_fname(NULL));
- // test with defaults-torrc and torrc without include
- int ret = options_init_from_string(conf_empty, conf_empty, CMD_RUN_UNITTESTS,
- NULL, &errmsg);
- tt_int_op(ret, OP_EQ, 0);
- const or_options_t *options = get_options();
- tt_int_op(options->IncludeUsed, OP_EQ, 0);
- done:
- tor_free(errmsg);
- }
- static void
- test_config_include_flag_torrc_only(void *data)
- {
- (void)data;
- char *errmsg = NULL;
- char *path = NULL;
- char *dir = tor_strdup(get_fname("test_include_flag_torrc_only"));
- tt_ptr_op(dir, OP_NE, NULL);
- #ifdef _WIN32
- tt_int_op(mkdir(dir), OP_EQ, 0);
- #else
- tt_int_op(mkdir(dir, 0700), OP_EQ, 0);
- #endif
- tor_asprintf(&path, "%s"PATH_SEPARATOR"%s", dir, "dummy");
- tt_int_op(write_str_to_file(path, "\n", 0), OP_EQ, 0);
- char conf_empty[1000];
- tor_snprintf(conf_empty, sizeof(conf_empty),
- "DataDirectory %s\n",
- get_fname(NULL));
- char conf_include[1000];
- tor_snprintf(conf_include, sizeof(conf_include), "%%include %s", path);
- // test with defaults-torrc without include and torrc with include
- int ret = options_init_from_string(conf_empty, conf_include,
- CMD_RUN_UNITTESTS, NULL, &errmsg);
- tt_int_op(ret, OP_EQ, 0);
- const or_options_t *options = get_options();
- tt_int_op(options->IncludeUsed, OP_EQ, 1);
- done:
- tor_free(errmsg);
- tor_free(path);
- tor_free(dir);
- }
- static void
- test_config_include_flag_defaults_only(void *data)
- {
- (void)data;
- char *errmsg = NULL;
- char *path = NULL;
- char *dir = tor_strdup(get_fname("test_include_flag_defaults_only"));
- tt_ptr_op(dir, OP_NE, NULL);
- #ifdef _WIN32
- tt_int_op(mkdir(dir), OP_EQ, 0);
- #else
- tt_int_op(mkdir(dir, 0700), OP_EQ, 0);
- #endif
- tor_asprintf(&path, "%s"PATH_SEPARATOR"%s", dir, "dummy");
- tt_int_op(write_str_to_file(path, "\n", 0), OP_EQ, 0);
- char conf_empty[1000];
- tor_snprintf(conf_empty, sizeof(conf_empty),
- "DataDirectory %s\n",
- get_fname(NULL));
- char conf_include[1000];
- tor_snprintf(conf_include, sizeof(conf_include), "%%include %s", path);
- // test with defaults-torrc with include and torrc without include
- int ret = options_init_from_string(conf_include, conf_empty,
- CMD_RUN_UNITTESTS, NULL, &errmsg);
- tt_int_op(ret, OP_EQ, 0);
- const or_options_t *options = get_options();
- tt_int_op(options->IncludeUsed, OP_EQ, 0);
- done:
- tor_free(errmsg);
- tor_free(path);
- tor_free(dir);
- }
- static void
- test_config_dup_and_filter(void *arg)
- {
- (void)arg;
- /* Test normal input. */
- config_line_t *line = NULL;
- config_line_append(&line, "abc", "def");
- config_line_append(&line, "ghi", "jkl");
- config_line_append(&line, "ABCD", "mno");
- config_line_t *line_dup = config_lines_dup_and_filter(line, "aBc");
- tt_ptr_op(line_dup, OP_NE, NULL);
- tt_ptr_op(line_dup->next, OP_NE, NULL);
- tt_ptr_op(line_dup->next->next, OP_EQ, NULL);
- tt_str_op(line_dup->key, OP_EQ, "abc");
- tt_str_op(line_dup->value, OP_EQ, "def");
- tt_str_op(line_dup->next->key, OP_EQ, "ABCD");
- tt_str_op(line_dup->next->value, OP_EQ, "mno");
- /* empty output */
- config_free_lines(line_dup);
- line_dup = config_lines_dup_and_filter(line, "skdjfsdkljf");
- tt_ptr_op(line_dup, OP_EQ, NULL);
- /* empty input */
- config_free_lines(line_dup);
- line_dup = config_lines_dup_and_filter(NULL, "abc");
- tt_ptr_op(line_dup, OP_EQ, NULL);
- done:
- config_free_lines(line);
- config_free_lines(line_dup);
- }
- /* If we're not configured to be a bridge, but we set
- * BridgeDistribution, then options_validate () should return -1. */
- static void
- test_config_check_bridge_distribution_setting_not_a_bridge(void *arg)
- {
- or_options_t* options = get_options_mutable();
- or_options_t* old_options = options;
- or_options_t* default_options = options;
- char* message = NULL;
- int ret;
- (void)arg;
- options->BridgeRelay = 0;
- options->BridgeDistribution = (char*)("https");
- ret = options_validate(old_options, options, default_options, 0, &message);
- tt_int_op(ret, OP_EQ, -1);
- tt_str_op(message, OP_EQ, "You set BridgeDistribution, but you "
- "didn't set BridgeRelay!");
- done:
- tor_free(message);
- options->BridgeDistribution = NULL;
- }
- /* If the BridgeDistribution setting was valid, 0 should be returned. */
- static void
- test_config_check_bridge_distribution_setting_valid(void *arg)
- {
- int ret = check_bridge_distribution_setting("https");
- (void)arg;
- tt_int_op(ret, OP_EQ, 0);
- done:
- return;
- }
- /* If the BridgeDistribution setting was invalid, -1 should be returned. */
- static void
- test_config_check_bridge_distribution_setting_invalid(void *arg)
- {
- int ret = check_bridge_distribution_setting("hyphens-are-allowed");
- (void)arg;
- tt_int_op(ret, OP_EQ, 0);
- ret = check_bridge_distribution_setting("asterisks*are*forbidden");
- tt_int_op(ret, OP_EQ, -1);
- done:
- return;
- }
- /* If the BridgeDistribution setting was unrecognised, a warning should be
- * logged and 0 should be returned. */
- static void
- test_config_check_bridge_distribution_setting_unrecognised(void *arg)
- {
- int ret = check_bridge_distribution_setting("unicorn");
- (void)arg;
- tt_int_op(ret, OP_EQ, 0);
- done:
- return;
- }
- static void
- test_config_include_opened_file_list(void *data)
- {
- (void)data;
- config_line_t *result = NULL;
- smartlist_t *opened_files = smartlist_new();
- char *dir = tor_strdup(get_fname("test_include_opened_file_list"));
- tt_ptr_op(dir, OP_NE, NULL);
- #ifdef _WIN32
- tt_int_op(mkdir(dir), OP_EQ, 0);
- #else
- tt_int_op(mkdir(dir, 0700), OP_EQ, 0);
- #endif
- char torrcd[PATH_MAX+1];
- tor_snprintf(torrcd, sizeof(torrcd), "%s"PATH_SEPARATOR"%s", dir, "torrc.d");
- #ifdef _WIN32
- tt_int_op(mkdir(torrcd), OP_EQ, 0);
- #else
- tt_int_op(mkdir(torrcd, 0700), OP_EQ, 0);
- #endif
- char subfolder[PATH_MAX+1];
- tor_snprintf(subfolder, sizeof(subfolder), "%s"PATH_SEPARATOR"%s", torrcd,
- "subfolder");
- #ifdef _WIN32
- tt_int_op(mkdir(subfolder), OP_EQ, 0);
- #else
- tt_int_op(mkdir(subfolder, 0700), OP_EQ, 0);
- #endif
- char path[PATH_MAX+1];
- tor_snprintf(path, sizeof(path), "%s"PATH_SEPARATOR"%s", subfolder,
- "01_file_in_subfolder");
- tt_int_op(write_str_to_file(path, "Test 1\n", 0), OP_EQ, 0);
- char empty[PATH_MAX+1];
- tor_snprintf(empty, sizeof(empty), "%s"PATH_SEPARATOR"%s", torrcd, "empty");
- tt_int_op(write_str_to_file(empty, "", 0), OP_EQ, 0);
- char file[PATH_MAX+1];
- tor_snprintf(file, sizeof(file), "%s"PATH_SEPARATOR"%s", torrcd, "file");
- tt_int_op(write_str_to_file(file, "Test 2\n", 0), OP_EQ, 0);
- char dot[PATH_MAX+1];
- tor_snprintf(dot, sizeof(dot), "%s"PATH_SEPARATOR"%s", torrcd, ".dot");
- tt_int_op(write_str_to_file(dot, "Test 3\n", 0), OP_EQ, 0);
- char torrc_contents[1000];
- tor_snprintf(torrc_contents, sizeof(torrc_contents),
- "%%include %s\n",
- torrcd);
- int include_used;
- tt_int_op(config_get_lines_include(torrc_contents, &result, 0, &include_used,
- opened_files), OP_EQ, 0);
- tt_ptr_op(result, OP_NE, NULL);
- tt_int_op(include_used, OP_EQ, 1);
- tt_int_op(smartlist_len(opened_files), OP_EQ, 4);
- tt_int_op(smartlist_contains_string(opened_files, torrcd), OP_EQ, 1);
- tt_int_op(smartlist_contains_string(opened_files, subfolder), OP_EQ, 1);
- // files inside subfolders are not opended, only the subfolder is opened
- tt_int_op(smartlist_contains_string(opened_files, empty), OP_EQ, 1);
- tt_int_op(smartlist_contains_string(opened_files, file), OP_EQ, 1);
- // dot files are not opened as we ignore them when we get their name from
- // their parent folder
- done:
- SMARTLIST_FOREACH(opened_files, char *, f, tor_free(f));
- smartlist_free(opened_files);
- config_free_lines(result);
- tor_free(dir);
- }
- static void
- test_config_compute_max_mem_in_queues(void *data)
- {
- #define GIGABYTE(x) (U64_LITERAL(x) << 30)
- #define MEGABYTE(x) (U64_LITERAL(x) << 20)
- (void)data;
- MOCK(get_total_system_memory, get_total_system_memory_mock);
- /* We are unable to detect the amount of memory on the system. Tor will try
- * to use some sensible default values for 64-bit and 32-bit systems. */
- total_system_memory_return = -1;
- #if SIZEOF_VOID_P >= 8
- /* We are on a 64-bit system. */
- tt_u64_op(compute_real_max_mem_in_queues(0, 0), OP_EQ, GIGABYTE(8));
- #else
- /* We are on a 32-bit system. */
- tt_u64_op(compute_real_max_mem_in_queues(0, 0), OP_EQ, GIGABYTE(1));
- #endif
- /* We are able to detect the amount of RAM on the system. */
- total_system_memory_return = 0;
- /* We are running on a system with one gigabyte of RAM. */
- total_system_memory_output = GIGABYTE(1);
- /* We have 0.75 * RAM available. */
- tt_u64_op(compute_real_max_mem_in_queues(0, 0), OP_EQ,
- 3 * (GIGABYTE(1) / 4));
- /* We are running on a tiny machine with 256 MB of RAM. */
- total_system_memory_output = MEGABYTE(256);
- /* We will now enforce a minimum of 256 MB of RAM available for the
- * MaxMemInQueues here, even though we should only have had 0.75 * 256 = 192
- * MB available. */
- tt_u64_op(compute_real_max_mem_in_queues(0, 0), OP_EQ, MEGABYTE(256));
- #if SIZEOF_SIZE_T > 4
- /* We are running on a machine with 8 GB of RAM. */
- total_system_memory_output = GIGABYTE(8);
- /* We will have 0.4 * RAM available. */
- tt_u64_op(compute_real_max_mem_in_queues(0, 0), OP_EQ,
- 2 * (GIGABYTE(8) / 5));
- /* We are running on a machine with 16 GB of RAM. */
- total_system_memory_output = GIGABYTE(16);
- /* We will have 0.4 * RAM available. */
- tt_u64_op(compute_real_max_mem_in_queues(0, 0), OP_EQ,
- 2 * (GIGABYTE(16) / 5));
- /* We are running on a machine with 32 GB of RAM. */
- total_system_memory_output = GIGABYTE(32);
- /* We will at maximum get MAX_DEFAULT_MEMORY_QUEUE_SIZE here. */
- tt_u64_op(compute_real_max_mem_in_queues(0, 0), OP_EQ,
- MAX_DEFAULT_MEMORY_QUEUE_SIZE);
- #endif
- done:
- UNMOCK(get_total_system_memory);
- #undef GIGABYTE
- #undef MEGABYTE
- }
- #define CONFIG_TEST(name, flags) \
- { #name, test_config_ ## name, flags, NULL, NULL }
- struct testcase_t config_tests[] = {
- CONFIG_TEST(adding_trusted_dir_server, TT_FORK),
- CONFIG_TEST(adding_fallback_dir_server, TT_FORK),
- CONFIG_TEST(parsing_trusted_dir_server, 0),
- CONFIG_TEST(parsing_fallback_dir_server, 0),
- CONFIG_TEST(adding_default_trusted_dir_servers, TT_FORK),
- CONFIG_TEST(adding_dir_servers, TT_FORK),
- CONFIG_TEST(default_dir_servers, TT_FORK),
- CONFIG_TEST(default_fallback_dirs, 0),
- CONFIG_TEST(resolve_my_address, TT_FORK),
- CONFIG_TEST(addressmap, 0),
- CONFIG_TEST(parse_bridge_line, 0),
- CONFIG_TEST(parse_transport_options_line, 0),
- CONFIG_TEST(parse_transport_plugin_line, TT_FORK),
- CONFIG_TEST(check_or_create_data_subdir, TT_FORK),
- CONFIG_TEST(write_to_data_subdir, TT_FORK),
- CONFIG_TEST(fix_my_family, 0),
- CONFIG_TEST(directory_fetch, 0),
- CONFIG_TEST(port_cfg_line_extract_addrport, 0),
- CONFIG_TEST(parse_port_config__ports__no_ports_given, 0),
- CONFIG_TEST(parse_port_config__ports__server_options, 0),
- CONFIG_TEST(parse_port_config__ports__ports_given, 0),
- CONFIG_TEST(parse_log_severity, 0),
- CONFIG_TEST(include_limit, 0),
- CONFIG_TEST(include_does_not_exist, 0),
- CONFIG_TEST(include_error_in_included_file, 0),
- CONFIG_TEST(include_empty_file_folder, 0),
- #ifndef _WIN32
- CONFIG_TEST(include_no_permission, 0),
- #endif
- CONFIG_TEST(include_recursion_before_after, 0),
- CONFIG_TEST(include_recursion_after_only, 0),
- CONFIG_TEST(include_folder_order, 0),
- CONFIG_TEST(include_path_syntax, 0),
- CONFIG_TEST(include_not_processed, 0),
- CONFIG_TEST(include_has_include, 0),
- CONFIG_TEST(include_flag_both_without, TT_FORK),
- CONFIG_TEST(include_flag_torrc_only, TT_FORK),
- CONFIG_TEST(include_flag_defaults_only, TT_FORK),
- CONFIG_TEST(dup_and_filter, 0),
- CONFIG_TEST(check_bridge_distribution_setting_not_a_bridge, TT_FORK),
- CONFIG_TEST(check_bridge_distribution_setting_valid, 0),
- CONFIG_TEST(check_bridge_distribution_setting_invalid, 0),
- CONFIG_TEST(check_bridge_distribution_setting_unrecognised, 0),
- CONFIG_TEST(include_opened_file_list, 0),
- CONFIG_TEST(compute_max_mem_in_queues, 0),
- END_OF_TESTCASES
- };
|