1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162116311641165116611671168116911701171117211731174117511761177117811791180118111821183118411851186118711881189119011911192119311941195119611971198119912001201120212031204120512061207120812091210121112121213121412151216121712181219122012211222122312241225122612271228122912301231123212331234123512361237123812391240124112421243124412451246124712481249125012511252125312541255125612571258125912601261126212631264126512661267126812691270127112721273127412751276127712781279128012811282128312841285128612871288128912901291129212931294129512961297129812991300130113021303130413051306130713081309131013111312131313141315131613171318131913201321132213231324132513261327132813291330133113321333133413351336133713381339134013411342134313441345134613471348134913501351135213531354135513561357135813591360136113621363136413651366136713681369137013711372137313741375137613771378137913801381138213831384138513861387138813891390139113921393139413951396139713981399140014011402140314041405140614071408140914101411141214131414141514161417141814191420142114221423142414251426142714281429143014311432143314341435143614371438143914401441144214431444144514461447144814491450145114521453145414551456145714581459146014611462146314641465146614671468146914701471147214731474147514761477147814791480148114821483148414851486148714881489149014911492149314941495149614971498149915001501150215031504150515061507150815091510151115121513151415151516151715181519152015211522152315241525152615271528152915301531153215331534153515361537153815391540154115421543154415451546154715481549155015511552155315541555155615571558155915601561156215631564156515661567156815691570157115721573157415751576157715781579158015811582158315841585158615871588158915901591159215931594159515961597159815991600160116021603160416051606160716081609161016111612161316141615161616171618161916201621162216231624162516261627162816291630163116321633163416351636163716381639164016411642164316441645164616471648164916501651165216531654165516561657165816591660166116621663166416651666166716681669167016711672167316741675167616771678167916801681168216831684168516861687168816891690169116921693169416951696169716981699170017011702170317041705170617071708170917101711171217131714171517161717171817191720172117221723172417251726172717281729173017311732173317341735173617371738173917401741174217431744174517461747174817491750175117521753175417551756175717581759176017611762176317641765176617671768176917701771177217731774177517761777177817791780178117821783178417851786178717881789179017911792179317941795179617971798179918001801180218031804180518061807180818091810181118121813181418151816181718181819182018211822182318241825182618271828182918301831183218331834183518361837183818391840184118421843184418451846184718481849185018511852185318541855185618571858185918601861186218631864186518661867186818691870187118721873187418751876187718781879188018811882188318841885188618871888188918901891189218931894189518961897189818991900190119021903190419051906190719081909191019111912191319141915191619171918191919201921192219231924192519261927192819291930193119321933193419351936193719381939194019411942194319441945194619471948194919501951195219531954195519561957195819591960196119621963196419651966196719681969197019711972197319741975197619771978197919801981198219831984198519861987198819891990199119921993199419951996199719981999200020012002200320042005200620072008200920102011201220132014201520162017201820192020202120222023202420252026202720282029203020312032203320342035203620372038203920402041204220432044204520462047204820492050205120522053205420552056205720582059206020612062206320642065206620672068206920702071207220732074207520762077207820792080208120822083208420852086208720882089209020912092209320942095209620972098209921002101210221032104210521062107210821092110211121122113211421152116211721182119212021212122212321242125212621272128212921302131213221332134213521362137213821392140214121422143214421452146214721482149215021512152215321542155215621572158215921602161216221632164216521662167216821692170217121722173217421752176217721782179218021812182218321842185218621872188218921902191219221932194219521962197219821992200220122022203220422052206220722082209221022112212221322142215221622172218221922202221222222232224222522262227222822292230223122322233223422352236223722382239224022412242224322442245224622472248224922502251225222532254225522562257225822592260226122622263226422652266226722682269227022712272227322742275227622772278227922802281228222832284228522862287228822892290229122922293229422952296229722982299230023012302230323042305230623072308230923102311231223132314231523162317231823192320232123222323232423252326232723282329233023312332233323342335233623372338233923402341234223432344234523462347234823492350235123522353235423552356235723582359236023612362236323642365236623672368236923702371237223732374237523762377237823792380238123822383238423852386238723882389239023912392239323942395239623972398239924002401240224032404240524062407240824092410241124122413241424152416241724182419242024212422242324242425242624272428242924302431243224332434243524362437243824392440244124422443244424452446244724482449245024512452245324542455245624572458245924602461246224632464246524662467246824692470247124722473247424752476247724782479248024812482248324842485248624872488248924902491249224932494249524962497249824992500250125022503250425052506250725082509251025112512251325142515251625172518251925202521252225232524252525262527252825292530253125322533253425352536253725382539254025412542254325442545254625472548254925502551255225532554255525562557255825592560256125622563256425652566256725682569257025712572257325742575257625772578257925802581258225832584258525862587258825892590259125922593259425952596259725982599260026012602260326042605260626072608260926102611261226132614261526162617261826192620262126222623262426252626262726282629263026312632263326342635263626372638263926402641264226432644264526462647264826492650265126522653265426552656265726582659266026612662266326642665266626672668266926702671267226732674267526762677267826792680268126822683268426852686268726882689269026912692269326942695269626972698269927002701270227032704270527062707270827092710271127122713271427152716271727182719272027212722272327242725272627272728272927302731273227332734273527362737273827392740274127422743274427452746274727482749275027512752275327542755275627572758275927602761276227632764276527662767276827692770277127722773277427752776277727782779278027812782278327842785278627872788278927902791279227932794279527962797279827992800280128022803280428052806280728082809281028112812281328142815281628172818281928202821282228232824282528262827282828292830283128322833283428352836283728382839284028412842284328442845284628472848284928502851285228532854285528562857285828592860286128622863286428652866286728682869287028712872287328742875287628772878287928802881288228832884288528862887288828892890289128922893289428952896289728982899290029012902290329042905290629072908290929102911291229132914291529162917291829192920292129222923292429252926292729282929293029312932293329342935293629372938293929402941294229432944294529462947294829492950295129522953295429552956295729582959296029612962296329642965296629672968296929702971297229732974297529762977297829792980298129822983298429852986298729882989299029912992299329942995299629972998299930003001300230033004300530063007300830093010301130123013301430153016301730183019302030213022302330243025302630273028302930303031303230333034303530363037303830393040304130423043304430453046304730483049305030513052305330543055305630573058305930603061306230633064306530663067306830693070307130723073307430753076307730783079308030813082308330843085308630873088308930903091309230933094309530963097309830993100310131023103310431053106310731083109311031113112311331143115311631173118311931203121312231233124312531263127312831293130313131323133313431353136313731383139314031413142314331443145314631473148314931503151315231533154315531563157315831593160316131623163316431653166316731683169317031713172317331743175317631773178317931803181318231833184318531863187318831893190319131923193319431953196319731983199320032013202320332043205320632073208320932103211321232133214321532163217321832193220322132223223322432253226322732283229323032313232323332343235323632373238323932403241324232433244324532463247324832493250325132523253325432553256325732583259326032613262326332643265326632673268326932703271327232733274327532763277327832793280328132823283328432853286328732883289329032913292329332943295329632973298329933003301330233033304330533063307330833093310331133123313331433153316331733183319332033213322332333243325332633273328332933303331333233333334333533363337333833393340334133423343334433453346334733483349335033513352335333543355335633573358335933603361336233633364336533663367336833693370337133723373337433753376337733783379338033813382338333843385338633873388338933903391339233933394339533963397339833993400340134023403340434053406340734083409341034113412341334143415341634173418341934203421342234233424342534263427342834293430343134323433343434353436343734383439344034413442344334443445344634473448344934503451345234533454345534563457345834593460346134623463346434653466346734683469347034713472347334743475347634773478 |
- #define TOR_CHANNEL_INTERNAL_
- #define CHANNEL_PRIVATE_
- #include "or.h"
- #include "channel.h"
- #include "channeltls.h"
- #include "channelpadding.h"
- #include "circuitbuild.h"
- #include "circuitlist.h"
- #include "circuitstats.h"
- #include "config.h"
- #include "connection_or.h"
- #include "circuitmux.h"
- #include "entrynodes.h"
- #include "geoip.h"
- #include "main.h"
- #include "nodelist.h"
- #include "relay.h"
- #include "rephist.h"
- #include "router.h"
- #include "routerlist.h"
- #include "scheduler.h"
- #include "compat_time.h"
- #include "networkstatus.h"
- #include "rendservice.h"
- static smartlist_t *all_channels = NULL;
- static smartlist_t *active_channels = NULL;
- static smartlist_t *finished_channels = NULL;
- static smartlist_t *all_listeners = NULL;
- static smartlist_t *active_listeners = NULL;
- static smartlist_t *finished_listeners = NULL;
- static HT_HEAD(channel_gid_map, channel_s) channel_gid_map = HT_INITIALIZER();
- static unsigned
- channel_id_hash(const channel_t *chan)
- {
- return (unsigned) chan->global_identifier;
- }
- static int
- channel_id_eq(const channel_t *a, const channel_t *b)
- {
- return a->global_identifier == b->global_identifier;
- }
- HT_PROTOTYPE(channel_gid_map, channel_s, gidmap_node,
- channel_id_hash, channel_id_eq)
- HT_GENERATE2(channel_gid_map, channel_s, gidmap_node,
- channel_id_hash, channel_id_eq,
- 0.6, tor_reallocarray_, tor_free_)
- HANDLE_IMPL(channel, channel_s,)
- static uint64_t n_channels_allocated = 0;
- static HT_HEAD(channel_idmap, channel_idmap_entry_s) channel_identity_map =
- HT_INITIALIZER();
- typedef struct channel_idmap_entry_s {
- HT_ENTRY(channel_idmap_entry_s) node;
- uint8_t digest[DIGEST_LEN];
- TOR_LIST_HEAD(channel_list_s, channel_s) channel_list;
- } channel_idmap_entry_t;
- static inline unsigned
- channel_idmap_hash(const channel_idmap_entry_t *ent)
- {
- return (unsigned) siphash24g(ent->digest, DIGEST_LEN);
- }
- static inline int
- channel_idmap_eq(const channel_idmap_entry_t *a,
- const channel_idmap_entry_t *b)
- {
- return tor_memeq(a->digest, b->digest, DIGEST_LEN);
- }
- HT_PROTOTYPE(channel_idmap, channel_idmap_entry_s, node, channel_idmap_hash,
- channel_idmap_eq)
- HT_GENERATE2(channel_idmap, channel_idmap_entry_s, node, channel_idmap_hash,
- channel_idmap_eq, 0.5, tor_reallocarray_, tor_free_)
- static void channel_remove_from_digest_map(channel_t *chan);
- static void channel_force_xfree(channel_t *chan);
- static void channel_free_list(smartlist_t *channels,
- int mark_for_close);
- static void channel_listener_free_list(smartlist_t *channels,
- int mark_for_close);
- static void channel_listener_force_xfree(channel_listener_t *chan_l);
- int
- channel_state_is_valid(channel_state_t state)
- {
- int is_valid;
- switch (state) {
- case CHANNEL_STATE_CLOSED:
- case CHANNEL_STATE_CLOSING:
- case CHANNEL_STATE_ERROR:
- case CHANNEL_STATE_MAINT:
- case CHANNEL_STATE_OPENING:
- case CHANNEL_STATE_OPEN:
- is_valid = 1;
- break;
- case CHANNEL_STATE_LAST:
- default:
- is_valid = 0;
- }
- return is_valid;
- }
- int
- channel_listener_state_is_valid(channel_listener_state_t state)
- {
- int is_valid;
- switch (state) {
- case CHANNEL_LISTENER_STATE_CLOSED:
- case CHANNEL_LISTENER_STATE_LISTENING:
- case CHANNEL_LISTENER_STATE_CLOSING:
- case CHANNEL_LISTENER_STATE_ERROR:
- is_valid = 1;
- break;
- case CHANNEL_LISTENER_STATE_LAST:
- default:
- is_valid = 0;
- }
- return is_valid;
- }
- int
- channel_state_can_transition(channel_state_t from, channel_state_t to)
- {
- int is_valid;
- switch (from) {
- case CHANNEL_STATE_CLOSED:
- is_valid = (to == CHANNEL_STATE_OPENING);
- break;
- case CHANNEL_STATE_CLOSING:
- is_valid = (to == CHANNEL_STATE_CLOSED ||
- to == CHANNEL_STATE_ERROR);
- break;
- case CHANNEL_STATE_ERROR:
- is_valid = 0;
- break;
- case CHANNEL_STATE_MAINT:
- is_valid = (to == CHANNEL_STATE_CLOSING ||
- to == CHANNEL_STATE_ERROR ||
- to == CHANNEL_STATE_OPEN);
- break;
- case CHANNEL_STATE_OPENING:
- is_valid = (to == CHANNEL_STATE_CLOSING ||
- to == CHANNEL_STATE_ERROR ||
- to == CHANNEL_STATE_OPEN);
- break;
- case CHANNEL_STATE_OPEN:
- is_valid = (to == CHANNEL_STATE_CLOSING ||
- to == CHANNEL_STATE_ERROR ||
- to == CHANNEL_STATE_MAINT);
- break;
- case CHANNEL_STATE_LAST:
- default:
- is_valid = 0;
- }
- return is_valid;
- }
- int
- channel_listener_state_can_transition(channel_listener_state_t from,
- channel_listener_state_t to)
- {
- int is_valid;
- switch (from) {
- case CHANNEL_LISTENER_STATE_CLOSED:
- is_valid = (to == CHANNEL_LISTENER_STATE_LISTENING);
- break;
- case CHANNEL_LISTENER_STATE_CLOSING:
- is_valid = (to == CHANNEL_LISTENER_STATE_CLOSED ||
- to == CHANNEL_LISTENER_STATE_ERROR);
- break;
- case CHANNEL_LISTENER_STATE_ERROR:
- is_valid = 0;
- break;
- case CHANNEL_LISTENER_STATE_LISTENING:
- is_valid = (to == CHANNEL_LISTENER_STATE_CLOSING ||
- to == CHANNEL_LISTENER_STATE_ERROR);
- break;
- case CHANNEL_LISTENER_STATE_LAST:
- default:
- is_valid = 0;
- }
- return is_valid;
- }
- const char *
- channel_state_to_string(channel_state_t state)
- {
- const char *descr;
- switch (state) {
- case CHANNEL_STATE_CLOSED:
- descr = "closed";
- break;
- case CHANNEL_STATE_CLOSING:
- descr = "closing";
- break;
- case CHANNEL_STATE_ERROR:
- descr = "channel error";
- break;
- case CHANNEL_STATE_MAINT:
- descr = "temporarily suspended for maintenance";
- break;
- case CHANNEL_STATE_OPENING:
- descr = "opening";
- break;
- case CHANNEL_STATE_OPEN:
- descr = "open";
- break;
- case CHANNEL_STATE_LAST:
- default:
- descr = "unknown or invalid channel state";
- }
- return descr;
- }
- const char *
- channel_listener_state_to_string(channel_listener_state_t state)
- {
- const char *descr;
- switch (state) {
- case CHANNEL_LISTENER_STATE_CLOSED:
- descr = "closed";
- break;
- case CHANNEL_LISTENER_STATE_CLOSING:
- descr = "closing";
- break;
- case CHANNEL_LISTENER_STATE_ERROR:
- descr = "channel listener error";
- break;
- case CHANNEL_LISTENER_STATE_LISTENING:
- descr = "listening";
- break;
- case CHANNEL_LISTENER_STATE_LAST:
- default:
- descr = "unknown or invalid channel listener state";
- }
- return descr;
- }
- void
- channel_register(channel_t *chan)
- {
- tor_assert(chan);
- tor_assert(chan->global_identifier);
-
- if (chan->registered) return;
- log_debug(LD_CHANNEL,
- "Registering channel %p (ID " U64_FORMAT ") "
- "in state %s (%d) with digest %s",
- chan, U64_PRINTF_ARG(chan->global_identifier),
- channel_state_to_string(chan->state), chan->state,
- hex_str(chan->identity_digest, DIGEST_LEN));
-
- if (!all_channels) all_channels = smartlist_new();
- smartlist_add(all_channels, chan);
- channel_t *oldval = HT_REPLACE(channel_gid_map, &channel_gid_map, chan);
- tor_assert(! oldval);
-
- if (CHANNEL_FINISHED(chan)) {
-
- if (!finished_channels) finished_channels = smartlist_new();
- smartlist_add(finished_channels, chan);
- mainloop_schedule_postloop_cleanup();
- } else {
-
- if (!active_channels) active_channels = smartlist_new();
- smartlist_add(active_channels, chan);
- if (!CHANNEL_IS_CLOSING(chan)) {
-
- if (!tor_digest_is_zero(chan->identity_digest)) {
-
- channel_add_to_digest_map(chan);
- } else {
- log_info(LD_CHANNEL,
- "Channel %p (global ID " U64_FORMAT ") "
- "in state %s (%d) registered with no identity digest",
- chan, U64_PRINTF_ARG(chan->global_identifier),
- channel_state_to_string(chan->state), chan->state);
- }
- }
- }
-
- chan->registered = 1;
- }
- void
- channel_unregister(channel_t *chan)
- {
- tor_assert(chan);
-
- if (!(chan->registered)) return;
-
- if (CHANNEL_FINISHED(chan)) {
-
- if (finished_channels) smartlist_remove(finished_channels, chan);
- } else {
-
- if (active_channels) smartlist_remove(active_channels, chan);
- }
-
- if (all_channels) smartlist_remove(all_channels, chan);
- channel_t *oldval = HT_REMOVE(channel_gid_map, &channel_gid_map, chan);
- tor_assert(oldval == NULL || oldval == chan);
-
- chan->registered = 0;
-
- if (!tor_digest_is_zero(chan->identity_digest) &&
- !(CHANNEL_CONDEMNED(chan))) {
-
- channel_remove_from_digest_map(chan);
- }
- }
- void
- channel_listener_register(channel_listener_t *chan_l)
- {
- tor_assert(chan_l);
-
- if (chan_l->registered) return;
- log_debug(LD_CHANNEL,
- "Registering channel listener %p (ID " U64_FORMAT ") "
- "in state %s (%d)",
- chan_l, U64_PRINTF_ARG(chan_l->global_identifier),
- channel_listener_state_to_string(chan_l->state),
- chan_l->state);
-
- if (!all_listeners) all_listeners = smartlist_new();
- smartlist_add(all_listeners, chan_l);
-
- if (chan_l->state == CHANNEL_LISTENER_STATE_CLOSED ||
- chan_l->state == CHANNEL_LISTENER_STATE_ERROR) {
-
- if (!finished_listeners) finished_listeners = smartlist_new();
- smartlist_add(finished_listeners, chan_l);
- } else {
-
- if (!active_listeners) active_listeners = smartlist_new();
- smartlist_add(active_listeners, chan_l);
- }
-
- chan_l->registered = 1;
- }
- void
- channel_listener_unregister(channel_listener_t *chan_l)
- {
- tor_assert(chan_l);
-
- if (!(chan_l->registered)) return;
-
- if (chan_l->state == CHANNEL_LISTENER_STATE_CLOSED ||
- chan_l->state == CHANNEL_LISTENER_STATE_ERROR) {
-
- if (finished_listeners) smartlist_remove(finished_listeners, chan_l);
- } else {
-
- if (active_listeners) smartlist_remove(active_listeners, chan_l);
- }
-
- if (all_listeners) smartlist_remove(all_listeners, chan_l);
-
- chan_l->registered = 0;
- }
- STATIC void
- channel_add_to_digest_map(channel_t *chan)
- {
- channel_idmap_entry_t *ent, search;
- tor_assert(chan);
-
- tor_assert(!CHANNEL_CONDEMNED(chan));
-
- tor_assert(!tor_digest_is_zero(chan->identity_digest));
- memcpy(search.digest, chan->identity_digest, DIGEST_LEN);
- ent = HT_FIND(channel_idmap, &channel_identity_map, &search);
- if (! ent) {
- ent = tor_malloc(sizeof(channel_idmap_entry_t));
- memcpy(ent->digest, chan->identity_digest, DIGEST_LEN);
- TOR_LIST_INIT(&ent->channel_list);
- HT_INSERT(channel_idmap, &channel_identity_map, ent);
- }
- TOR_LIST_INSERT_HEAD(&ent->channel_list, chan, next_with_same_id);
- log_debug(LD_CHANNEL,
- "Added channel %p (global ID " U64_FORMAT ") "
- "to identity map in state %s (%d) with digest %s",
- chan, U64_PRINTF_ARG(chan->global_identifier),
- channel_state_to_string(chan->state), chan->state,
- hex_str(chan->identity_digest, DIGEST_LEN));
- }
- static void
- channel_remove_from_digest_map(channel_t *chan)
- {
- channel_idmap_entry_t *ent, search;
- tor_assert(chan);
-
- tor_assert(!tor_digest_is_zero(chan->identity_digest));
-
- TOR_LIST_REMOVE(chan, next_with_same_id);
- memcpy(search.digest, chan->identity_digest, DIGEST_LEN);
- ent = HT_FIND(channel_idmap, &channel_identity_map, &search);
-
- if (ent) {
-
- if (TOR_LIST_EMPTY(&ent->channel_list)) {
- HT_REMOVE(channel_idmap, &channel_identity_map, ent);
- tor_free(ent);
- }
- log_debug(LD_CHANNEL,
- "Removed channel %p (global ID " U64_FORMAT ") from "
- "identity map in state %s (%d) with digest %s",
- chan, U64_PRINTF_ARG(chan->global_identifier),
- channel_state_to_string(chan->state), chan->state,
- hex_str(chan->identity_digest, DIGEST_LEN));
- } else {
-
- log_warn(LD_BUG,
- "Trying to remove channel %p (global ID " U64_FORMAT ") with "
- "digest %s from identity map, but couldn't find any with "
- "that digest",
- chan, U64_PRINTF_ARG(chan->global_identifier),
- hex_str(chan->identity_digest, DIGEST_LEN));
- }
- }
- channel_t *
- channel_find_by_global_id(uint64_t global_identifier)
- {
- channel_t lookup;
- channel_t *rv = NULL;
- lookup.global_identifier = global_identifier;
- rv = HT_FIND(channel_gid_map, &channel_gid_map, &lookup);
- if (rv) {
- tor_assert(rv->global_identifier == global_identifier);
- }
- return rv;
- }
- static int
- channel_remote_identity_matches(const channel_t *chan,
- const char *rsa_id_digest,
- const ed25519_public_key_t *ed_id)
- {
- if (BUG(!chan))
- return 0;
- if (rsa_id_digest) {
- if (tor_memneq(rsa_id_digest, chan->identity_digest, DIGEST_LEN))
- return 0;
- }
- if (ed_id) {
- if (tor_memneq(ed_id->pubkey, chan->ed25519_identity.pubkey,
- ED25519_PUBKEY_LEN))
- return 0;
- }
- return 1;
- }
- channel_t *
- channel_find_by_remote_identity(const char *rsa_id_digest,
- const ed25519_public_key_t *ed_id)
- {
- channel_t *rv = NULL;
- channel_idmap_entry_t *ent, search;
- tor_assert(rsa_id_digest);
- if (ed_id && ed25519_public_key_is_zero(ed_id)) {
-
- ed_id = NULL;
- }
- memcpy(search.digest, rsa_id_digest, DIGEST_LEN);
- ent = HT_FIND(channel_idmap, &channel_identity_map, &search);
- if (ent) {
- rv = TOR_LIST_FIRST(&ent->channel_list);
- }
- while (rv && ! channel_remote_identity_matches(rv, rsa_id_digest, ed_id)) {
- rv = channel_next_with_rsa_identity(rv);
- }
- return rv;
- }
- channel_t *
- channel_next_with_rsa_identity(channel_t *chan)
- {
- tor_assert(chan);
- return TOR_LIST_NEXT(chan, next_with_same_id);
- }
- void
- channel_check_for_duplicates(void)
- {
- channel_idmap_entry_t **iter;
- channel_t *chan;
- int total_relay_connections = 0, total_relays = 0, total_canonical = 0;
- int total_half_canonical = 0;
- int total_gt_one_connection = 0, total_gt_two_connections = 0;
- int total_gt_four_connections = 0;
- HT_FOREACH(iter, channel_idmap, &channel_identity_map) {
- int connections_to_relay = 0;
-
- if (!connection_or_digest_is_known_relay((char*)(*iter)->digest))
- continue;
- total_relays++;
- for (chan = TOR_LIST_FIRST(&(*iter)->channel_list); chan;
- chan = channel_next_with_rsa_identity(chan)) {
- if (CHANNEL_CONDEMNED(chan) || !CHANNEL_IS_OPEN(chan))
- continue;
- connections_to_relay++;
- total_relay_connections++;
- if (chan->is_canonical(chan, 0)) total_canonical++;
- if (!chan->is_canonical_to_peer && chan->is_canonical(chan, 0)
- && chan->is_canonical(chan, 1)) {
- total_half_canonical++;
- }
- }
- if (connections_to_relay > 1) total_gt_one_connection++;
- if (connections_to_relay > 2) total_gt_two_connections++;
- if (connections_to_relay > 4) total_gt_four_connections++;
- }
- #define MIN_RELAY_CONNECTIONS_TO_WARN 5
-
- if (total_relays > MIN_RELAY_CONNECTIONS_TO_WARN &&
- total_relay_connections >= 1.5*total_relays) {
- log_notice(LD_OR,
- "Your relay has a very large number of connections to other relays. "
- "Is your outbound address the same as your relay address? "
- "Found %d connections to %d relays. Found %d current canonical "
- "connections, in %d of which we were a non-canonical peer. "
- "%d relays had more than 1 connection, %d had more than 2, and "
- "%d had more than 4 connections.",
- total_relay_connections, total_relays, total_canonical,
- total_half_canonical, total_gt_one_connection,
- total_gt_two_connections, total_gt_four_connections);
- } else {
- log_info(LD_OR, "Performed connection pruning. "
- "Found %d connections to %d relays. Found %d current canonical "
- "connections, in %d of which we were a non-canonical peer. "
- "%d relays had more than 1 connection, %d had more than 2, and "
- "%d had more than 4 connections.",
- total_relay_connections, total_relays, total_canonical,
- total_half_canonical, total_gt_one_connection,
- total_gt_two_connections, total_gt_four_connections);
- }
- }
- void
- channel_init(channel_t *chan)
- {
- tor_assert(chan);
-
- chan->global_identifier = ++n_channels_allocated;
-
- chan->timestamp_last_had_circuits = time(NULL);
-
- chan->last_warned_circ_ids_exhausted.rate = 3600;
-
- memset(&chan->next_with_same_id, 0, sizeof(chan->next_with_same_id));
-
- channel_timestamp_created(chan);
-
- chan->has_been_open = 0;
-
- chan->scheduler_state = SCHED_CHAN_IDLE;
-
- chan->sched_heap_idx = -1;
- }
- void
- channel_init_listener(channel_listener_t *chan_l)
- {
- tor_assert(chan_l);
-
- chan_l->global_identifier = ++n_channels_allocated;
-
- channel_listener_timestamp_created(chan_l);
- }
- void
- channel_free_(channel_t *chan)
- {
- if (!chan) return;
-
- tor_assert(CHANNEL_FINISHED(chan));
-
- tor_assert(!(chan->registered));
- log_debug(LD_CHANNEL,
- "Freeing channel " U64_FORMAT " at %p",
- U64_PRINTF_ARG(chan->global_identifier), chan);
-
- scheduler_release_channel(chan);
-
- if (chan->cmux) {
- circuitmux_set_policy(chan->cmux, NULL);
- }
-
- timer_free(chan->padding_timer);
- channel_handle_free(chan->timer_handle);
- channel_handles_clear(chan);
-
- if (chan->free_fn) chan->free_fn(chan);
- channel_clear_remote_end(chan);
-
- if (chan->cmux) {
- circuitmux_detach_all_circuits(chan->cmux, NULL);
- circuitmux_mark_destroyed_circids_usable(chan->cmux, chan);
- circuitmux_free(chan->cmux);
- chan->cmux = NULL;
- }
- tor_free(chan);
- }
- void
- channel_listener_free_(channel_listener_t *chan_l)
- {
- if (!chan_l) return;
- log_debug(LD_CHANNEL,
- "Freeing channel_listener_t " U64_FORMAT " at %p",
- U64_PRINTF_ARG(chan_l->global_identifier),
- chan_l);
-
- tor_assert(chan_l->state == CHANNEL_LISTENER_STATE_CLOSED ||
- chan_l->state == CHANNEL_LISTENER_STATE_ERROR);
-
- tor_assert(!(chan_l->registered));
-
- if (chan_l->free_fn) chan_l->free_fn(chan_l);
- tor_free(chan_l);
- }
- static void
- channel_force_xfree(channel_t *chan)
- {
- tor_assert(chan);
- log_debug(LD_CHANNEL,
- "Force-freeing channel " U64_FORMAT " at %p",
- U64_PRINTF_ARG(chan->global_identifier), chan);
-
- scheduler_release_channel(chan);
-
- if (chan->cmux) {
- circuitmux_set_policy(chan->cmux, NULL);
- }
-
- timer_free(chan->padding_timer);
- channel_handle_free(chan->timer_handle);
- channel_handles_clear(chan);
-
- if (chan->free_fn) chan->free_fn(chan);
- channel_clear_remote_end(chan);
-
- if (chan->cmux) {
- circuitmux_free(chan->cmux);
- chan->cmux = NULL;
- }
- tor_free(chan);
- }
- static void
- channel_listener_force_xfree(channel_listener_t *chan_l)
- {
- tor_assert(chan_l);
- log_debug(LD_CHANNEL,
- "Force-freeing channel_listener_t " U64_FORMAT " at %p",
- U64_PRINTF_ARG(chan_l->global_identifier),
- chan_l);
-
- if (chan_l->free_fn) chan_l->free_fn(chan_l);
-
- if (chan_l->incoming_list) {
- SMARTLIST_FOREACH_BEGIN(chan_l->incoming_list,
- channel_t *, qchan) {
- channel_mark_for_close(qchan);
- } SMARTLIST_FOREACH_END(qchan);
- smartlist_free(chan_l->incoming_list);
- chan_l->incoming_list = NULL;
- }
- tor_free(chan_l);
- }
- void
- channel_listener_set_listener_fn(channel_listener_t *chan_l,
- channel_listener_fn_ptr listener)
- {
- tor_assert(chan_l);
- tor_assert(chan_l->state == CHANNEL_LISTENER_STATE_LISTENING);
- log_debug(LD_CHANNEL,
- "Setting listener callback for channel listener %p "
- "(global ID " U64_FORMAT ") to %p",
- chan_l, U64_PRINTF_ARG(chan_l->global_identifier),
- listener);
- chan_l->listener = listener;
- if (chan_l->listener) channel_listener_process_incoming(chan_l);
- }
- channel_cell_handler_fn_ptr
- channel_get_cell_handler(channel_t *chan)
- {
- tor_assert(chan);
- if (CHANNEL_CAN_HANDLE_CELLS(chan))
- return chan->cell_handler;
- return NULL;
- }
- channel_var_cell_handler_fn_ptr
- channel_get_var_cell_handler(channel_t *chan)
- {
- tor_assert(chan);
- if (CHANNEL_CAN_HANDLE_CELLS(chan))
- return chan->var_cell_handler;
- return NULL;
- }
- void
- channel_set_cell_handlers(channel_t *chan,
- channel_cell_handler_fn_ptr cell_handler,
- channel_var_cell_handler_fn_ptr
- var_cell_handler)
- {
- tor_assert(chan);
- tor_assert(CHANNEL_CAN_HANDLE_CELLS(chan));
- log_debug(LD_CHANNEL,
- "Setting cell_handler callback for channel %p to %p",
- chan, cell_handler);
- log_debug(LD_CHANNEL,
- "Setting var_cell_handler callback for channel %p to %p",
- chan, var_cell_handler);
-
- chan->cell_handler = cell_handler;
- chan->var_cell_handler = var_cell_handler;
- }
- void
- channel_mark_for_close(channel_t *chan)
- {
- tor_assert(chan != NULL);
- tor_assert(chan->close != NULL);
-
- if (CHANNEL_CONDEMNED(chan))
- return;
- log_debug(LD_CHANNEL,
- "Closing channel %p (global ID " U64_FORMAT ") "
- "by request",
- chan, U64_PRINTF_ARG(chan->global_identifier));
-
- chan->reason_for_closing = CHANNEL_CLOSE_REQUESTED;
-
- channel_change_state(chan, CHANNEL_STATE_CLOSING);
-
- chan->close(chan);
-
- }
- void
- channel_listener_mark_for_close(channel_listener_t *chan_l)
- {
- tor_assert(chan_l != NULL);
- tor_assert(chan_l->close != NULL);
-
- if (chan_l->state == CHANNEL_LISTENER_STATE_CLOSING ||
- chan_l->state == CHANNEL_LISTENER_STATE_CLOSED ||
- chan_l->state == CHANNEL_LISTENER_STATE_ERROR) return;
- log_debug(LD_CHANNEL,
- "Closing channel listener %p (global ID " U64_FORMAT ") "
- "by request",
- chan_l, U64_PRINTF_ARG(chan_l->global_identifier));
-
- chan_l->reason_for_closing = CHANNEL_LISTENER_CLOSE_REQUESTED;
-
- channel_listener_change_state(chan_l, CHANNEL_LISTENER_STATE_CLOSING);
-
- chan_l->close(chan_l);
-
- }
- void
- channel_close_from_lower_layer(channel_t *chan)
- {
- tor_assert(chan != NULL);
-
- if (CHANNEL_CONDEMNED(chan))
- return;
- log_debug(LD_CHANNEL,
- "Closing channel %p (global ID " U64_FORMAT ") "
- "due to lower-layer event",
- chan, U64_PRINTF_ARG(chan->global_identifier));
-
- chan->reason_for_closing = CHANNEL_CLOSE_FROM_BELOW;
-
- channel_change_state(chan, CHANNEL_STATE_CLOSING);
- }
- void
- channel_close_for_error(channel_t *chan)
- {
- tor_assert(chan != NULL);
-
- if (CHANNEL_CONDEMNED(chan))
- return;
- log_debug(LD_CHANNEL,
- "Closing channel %p due to lower-layer error",
- chan);
-
- chan->reason_for_closing = CHANNEL_CLOSE_FOR_ERROR;
-
- channel_change_state(chan, CHANNEL_STATE_CLOSING);
- }
- void
- channel_closed(channel_t *chan)
- {
- tor_assert(chan);
- tor_assert(CHANNEL_CONDEMNED(chan));
-
- if (CHANNEL_FINISHED(chan))
- return;
-
- if (! chan->has_been_open)
- circuit_n_chan_done(chan, 0, 0);
-
- circuit_unlink_all_from_channel(chan, END_CIRC_REASON_CHANNEL_CLOSED);
- if (chan->reason_for_closing != CHANNEL_CLOSE_FOR_ERROR) {
- channel_change_state(chan, CHANNEL_STATE_CLOSED);
- } else {
- channel_change_state(chan, CHANNEL_STATE_ERROR);
- }
- }
- void
- channel_clear_identity_digest(channel_t *chan)
- {
- int state_not_in_map;
- tor_assert(chan);
- log_debug(LD_CHANNEL,
- "Clearing remote endpoint digest on channel %p with "
- "global ID " U64_FORMAT,
- chan, U64_PRINTF_ARG(chan->global_identifier));
- state_not_in_map = CHANNEL_CONDEMNED(chan);
- if (!state_not_in_map && chan->registered &&
- !tor_digest_is_zero(chan->identity_digest))
-
- channel_remove_from_digest_map(chan);
- memset(chan->identity_digest, 0,
- sizeof(chan->identity_digest));
- }
- void
- channel_set_identity_digest(channel_t *chan,
- const char *identity_digest,
- const ed25519_public_key_t *ed_identity)
- {
- int was_in_digest_map, should_be_in_digest_map, state_not_in_map;
- tor_assert(chan);
- log_debug(LD_CHANNEL,
- "Setting remote endpoint digest on channel %p with "
- "global ID " U64_FORMAT " to digest %s",
- chan, U64_PRINTF_ARG(chan->global_identifier),
- identity_digest ?
- hex_str(identity_digest, DIGEST_LEN) : "(null)");
- state_not_in_map = CHANNEL_CONDEMNED(chan);
- was_in_digest_map =
- !state_not_in_map &&
- chan->registered &&
- !tor_digest_is_zero(chan->identity_digest);
- should_be_in_digest_map =
- !state_not_in_map &&
- chan->registered &&
- (identity_digest &&
- !tor_digest_is_zero(identity_digest));
- if (was_in_digest_map)
-
- channel_remove_from_digest_map(chan);
- if (identity_digest) {
- memcpy(chan->identity_digest,
- identity_digest,
- sizeof(chan->identity_digest));
- } else {
- memset(chan->identity_digest, 0,
- sizeof(chan->identity_digest));
- }
- if (ed_identity) {
- memcpy(&chan->ed25519_identity, ed_identity, sizeof(*ed_identity));
- } else {
- memset(&chan->ed25519_identity, 0, sizeof(*ed_identity));
- }
-
- if (should_be_in_digest_map)
- channel_add_to_digest_map(chan);
- }
- void
- channel_clear_remote_end(channel_t *chan)
- {
- int state_not_in_map;
- tor_assert(chan);
- log_debug(LD_CHANNEL,
- "Clearing remote endpoint identity on channel %p with "
- "global ID " U64_FORMAT,
- chan, U64_PRINTF_ARG(chan->global_identifier));
- state_not_in_map = CHANNEL_CONDEMNED(chan);
- if (!state_not_in_map && chan->registered &&
- !tor_digest_is_zero(chan->identity_digest))
-
- channel_remove_from_digest_map(chan);
- memset(chan->identity_digest, 0,
- sizeof(chan->identity_digest));
- }
- static int
- write_packed_cell(channel_t *chan, packed_cell_t *cell)
- {
- int ret = -1;
- size_t cell_bytes;
- tor_assert(chan);
- tor_assert(cell);
-
- tor_assert(CHANNEL_CAN_HANDLE_CELLS(chan));
- {
- circid_t circ_id;
- if (packed_cell_is_destroy(chan, cell, &circ_id)) {
- channel_note_destroy_not_pending(chan, circ_id);
- }
- }
-
- cell_bytes = get_cell_network_size(chan->wide_circ_ids);
-
- if (!CHANNEL_IS_OPEN(chan)) {
- goto done;
- }
-
- if (chan->write_packed_cell(chan, cell) < 0) {
- goto done;
- }
-
- channel_timestamp_xmit(chan);
-
- ++(chan->n_cells_xmitted);
- chan->n_bytes_xmitted += cell_bytes;
-
- ret = 0;
- done:
- return ret;
- }
- int
- channel_write_packed_cell(channel_t *chan, packed_cell_t *cell)
- {
- int ret = -1;
- tor_assert(chan);
- tor_assert(cell);
- if (CHANNEL_IS_CLOSING(chan)) {
- log_debug(LD_CHANNEL, "Discarding %p on closing channel %p with "
- "global ID "U64_FORMAT, cell, chan,
- U64_PRINTF_ARG(chan->global_identifier));
- goto end;
- }
- log_debug(LD_CHANNEL,
- "Writing %p to channel %p with global ID "
- U64_FORMAT, cell, chan, U64_PRINTF_ARG(chan->global_identifier));
- ret = write_packed_cell(chan, cell);
- end:
-
- packed_cell_free(cell);
- return ret;
- }
- static void
- channel_change_state_(channel_t *chan, channel_state_t to_state)
- {
- channel_state_t from_state;
- unsigned char was_active, is_active;
- unsigned char was_in_id_map, is_in_id_map;
- tor_assert(chan);
- from_state = chan->state;
- tor_assert(channel_state_is_valid(from_state));
- tor_assert(channel_state_is_valid(to_state));
- tor_assert(channel_state_can_transition(chan->state, to_state));
-
- if (from_state == to_state) {
- log_debug(LD_CHANNEL,
- "Got no-op transition from \"%s\" to itself on channel %p"
- "(global ID " U64_FORMAT ")",
- channel_state_to_string(to_state),
- chan, U64_PRINTF_ARG(chan->global_identifier));
- return;
- }
-
- if (to_state == CHANNEL_STATE_CLOSING ||
- to_state == CHANNEL_STATE_CLOSED ||
- to_state == CHANNEL_STATE_ERROR) {
- tor_assert(chan->reason_for_closing != CHANNEL_NOT_CLOSING);
- }
- log_debug(LD_CHANNEL,
- "Changing state of channel %p (global ID " U64_FORMAT
- ") from \"%s\" to \"%s\"",
- chan,
- U64_PRINTF_ARG(chan->global_identifier),
- channel_state_to_string(chan->state),
- channel_state_to_string(to_state));
- chan->state = to_state;
-
- if (chan->registered) {
- was_active = !(from_state == CHANNEL_STATE_CLOSED ||
- from_state == CHANNEL_STATE_ERROR);
- is_active = !(to_state == CHANNEL_STATE_CLOSED ||
- to_state == CHANNEL_STATE_ERROR);
-
- if (was_active && !is_active) {
- if (active_channels) smartlist_remove(active_channels, chan);
- if (!finished_channels) finished_channels = smartlist_new();
- smartlist_add(finished_channels, chan);
- mainloop_schedule_postloop_cleanup();
- }
-
- else if (!was_active && is_active) {
- if (finished_channels) smartlist_remove(finished_channels, chan);
- if (!active_channels) active_channels = smartlist_new();
- smartlist_add(active_channels, chan);
- }
- if (!tor_digest_is_zero(chan->identity_digest)) {
-
- was_in_id_map = !(from_state == CHANNEL_STATE_CLOSING ||
- from_state == CHANNEL_STATE_CLOSED ||
- from_state == CHANNEL_STATE_ERROR);
- is_in_id_map = !(to_state == CHANNEL_STATE_CLOSING ||
- to_state == CHANNEL_STATE_CLOSED ||
- to_state == CHANNEL_STATE_ERROR);
- if (!was_in_id_map && is_in_id_map) channel_add_to_digest_map(chan);
- else if (was_in_id_map && !is_in_id_map)
- channel_remove_from_digest_map(chan);
- }
- }
-
- if (to_state == CHANNEL_STATE_CLOSING ||
- to_state == CHANNEL_STATE_CLOSED ||
- to_state == CHANNEL_STATE_ERROR) {
- scheduler_release_channel(chan);
- } else if (to_state == CHANNEL_STATE_MAINT) {
- scheduler_channel_doesnt_want_writes(chan);
- }
- }
- void
- channel_change_state(channel_t *chan, channel_state_t to_state)
- {
- tor_assert(to_state != CHANNEL_STATE_OPEN);
- channel_change_state_(chan, to_state);
- }
- void
- channel_change_state_open(channel_t *chan)
- {
- channel_change_state_(chan, CHANNEL_STATE_OPEN);
-
- channel_do_open_actions(chan);
- chan->has_been_open = 1;
- }
- void
- channel_listener_change_state(channel_listener_t *chan_l,
- channel_listener_state_t to_state)
- {
- channel_listener_state_t from_state;
- unsigned char was_active, is_active;
- tor_assert(chan_l);
- from_state = chan_l->state;
- tor_assert(channel_listener_state_is_valid(from_state));
- tor_assert(channel_listener_state_is_valid(to_state));
- tor_assert(channel_listener_state_can_transition(chan_l->state, to_state));
-
- if (from_state == to_state) {
- log_debug(LD_CHANNEL,
- "Got no-op transition from \"%s\" to itself on channel "
- "listener %p (global ID " U64_FORMAT ")",
- channel_listener_state_to_string(to_state),
- chan_l, U64_PRINTF_ARG(chan_l->global_identifier));
- return;
- }
-
- if (to_state == CHANNEL_LISTENER_STATE_CLOSING ||
- to_state == CHANNEL_LISTENER_STATE_CLOSED ||
- to_state == CHANNEL_LISTENER_STATE_ERROR) {
- tor_assert(chan_l->reason_for_closing != CHANNEL_LISTENER_NOT_CLOSING);
- }
- log_debug(LD_CHANNEL,
- "Changing state of channel listener %p (global ID " U64_FORMAT
- "from \"%s\" to \"%s\"",
- chan_l, U64_PRINTF_ARG(chan_l->global_identifier),
- channel_listener_state_to_string(chan_l->state),
- channel_listener_state_to_string(to_state));
- chan_l->state = to_state;
-
- if (chan_l->registered) {
- was_active = !(from_state == CHANNEL_LISTENER_STATE_CLOSED ||
- from_state == CHANNEL_LISTENER_STATE_ERROR);
- is_active = !(to_state == CHANNEL_LISTENER_STATE_CLOSED ||
- to_state == CHANNEL_LISTENER_STATE_ERROR);
-
- if (was_active && !is_active) {
- if (active_listeners) smartlist_remove(active_listeners, chan_l);
- if (!finished_listeners) finished_listeners = smartlist_new();
- smartlist_add(finished_listeners, chan_l);
- mainloop_schedule_postloop_cleanup();
- }
-
- else if (!was_active && is_active) {
- if (finished_listeners) smartlist_remove(finished_listeners, chan_l);
- if (!active_listeners) active_listeners = smartlist_new();
- smartlist_add(active_listeners, chan_l);
- }
- }
- if (to_state == CHANNEL_LISTENER_STATE_CLOSED ||
- to_state == CHANNEL_LISTENER_STATE_ERROR) {
- tor_assert(!(chan_l->incoming_list) ||
- smartlist_len(chan_l->incoming_list) == 0);
- }
- }
- #define MAX_CELLS_TO_GET_FROM_CIRCUITS_FOR_UNLIMITED 256
- MOCK_IMPL(ssize_t,
- channel_flush_some_cells, (channel_t *chan, ssize_t num_cells))
- {
- unsigned int unlimited = 0;
- ssize_t flushed = 0;
- int clamped_num_cells;
- tor_assert(chan);
- if (num_cells < 0) unlimited = 1;
- if (!unlimited && num_cells <= flushed) goto done;
-
- if (CHANNEL_IS_OPEN(chan)) {
- if (circuitmux_num_cells(chan->cmux) > 0) {
-
- if (unlimited) {
- clamped_num_cells = MAX_CELLS_TO_GET_FROM_CIRCUITS_FOR_UNLIMITED;
- } else {
- if (num_cells - flushed >
- MAX_CELLS_TO_GET_FROM_CIRCUITS_FOR_UNLIMITED) {
- clamped_num_cells = MAX_CELLS_TO_GET_FROM_CIRCUITS_FOR_UNLIMITED;
- } else {
- clamped_num_cells = (int)(num_cells - flushed);
- }
- }
-
- flushed = channel_flush_from_first_active_circuit(
- chan, clamped_num_cells);
- }
- }
- done:
- return flushed;
- }
- MOCK_IMPL(int,
- channel_more_to_flush, (channel_t *chan))
- {
- tor_assert(chan);
- if (circuitmux_num_cells(chan->cmux) > 0) return 1;
-
- return 0;
- }
- void
- channel_notify_flushed(channel_t *chan)
- {
- tor_assert(chan);
- if (chan->dirreq_id != 0)
- geoip_change_dirreq_state(chan->dirreq_id,
- DIRREQ_TUNNELED,
- DIRREQ_CHANNEL_BUFFER_FLUSHED);
- }
- void
- channel_listener_process_incoming(channel_listener_t *listener)
- {
- tor_assert(listener);
-
- tor_assert(listener->state == CHANNEL_LISTENER_STATE_LISTENING ||
- listener->state == CHANNEL_LISTENER_STATE_CLOSING);
- tor_assert(listener->listener);
- log_debug(LD_CHANNEL,
- "Processing queue of incoming connections for channel "
- "listener %p (global ID " U64_FORMAT ")",
- listener, U64_PRINTF_ARG(listener->global_identifier));
- if (!(listener->incoming_list)) return;
- SMARTLIST_FOREACH_BEGIN(listener->incoming_list,
- channel_t *, chan) {
- tor_assert(chan);
- log_debug(LD_CHANNEL,
- "Handling incoming channel %p (" U64_FORMAT ") "
- "for listener %p (" U64_FORMAT ")",
- chan,
- U64_PRINTF_ARG(chan->global_identifier),
- listener,
- U64_PRINTF_ARG(listener->global_identifier));
-
- channel_mark_incoming(chan);
- listener->listener(listener, chan);
- } SMARTLIST_FOREACH_END(chan);
- smartlist_free(listener->incoming_list);
- listener->incoming_list = NULL;
- }
- void
- channel_do_open_actions(channel_t *chan)
- {
- tor_addr_t remote_addr;
- int started_here;
- time_t now = time(NULL);
- int close_origin_circuits = 0;
- tor_assert(chan);
- started_here = channel_is_outgoing(chan);
- if (started_here) {
- circuit_build_times_network_is_live(get_circuit_build_times_mutable());
- router_set_status(chan->identity_digest, 1);
- } else {
-
- if (channel_is_client(chan)) {
- if (channel_get_addr_if_possible(chan, &remote_addr)) {
- char *transport_name = NULL;
- channel_tls_t *tlschan = BASE_CHAN_TO_TLS(chan);
- if (chan->get_transport_name(chan, &transport_name) < 0)
- transport_name = NULL;
- geoip_note_client_seen(GEOIP_CLIENT_CONNECT,
- &remote_addr, transport_name,
- now);
- tor_free(transport_name);
-
- if (tlschan && tlschan->conn) {
- dos_new_client_conn(tlschan->conn);
- }
- }
-
- }
- }
-
- if (chan->padding_enabled || get_options()->ConnectionPadding == 1) {
- if (!get_options()->ConnectionPadding) {
-
- channelpadding_disable_padding_on_channel(chan);
- } else if (get_options()->Tor2webMode &&
- !networkstatus_get_param(NULL,
- CHANNELPADDING_TOR2WEB_PARAM,
- CHANNELPADDING_TOR2WEB_DEFAULT, 0, 1)) {
-
- channelpadding_disable_padding_on_channel(chan);
- } else if (rend_service_allow_non_anonymous_connection(get_options()) &&
- !networkstatus_get_param(NULL,
- CHANNELPADDING_SOS_PARAM,
- CHANNELPADDING_SOS_DEFAULT, 0, 1)) {
-
- channelpadding_disable_padding_on_channel(chan);
- } else if (get_options()->ReducedConnectionPadding) {
-
- channelpadding_reduce_padding_on_channel(chan);
- }
- }
- circuit_n_chan_done(chan, 1, close_origin_circuits);
- }
- void
- channel_listener_queue_incoming(channel_listener_t *listener,
- channel_t *incoming)
- {
- int need_to_queue = 0;
- tor_assert(listener);
- tor_assert(listener->state == CHANNEL_LISTENER_STATE_LISTENING);
- tor_assert(incoming);
- log_debug(LD_CHANNEL,
- "Queueing incoming channel %p (global ID " U64_FORMAT ") on "
- "channel listener %p (global ID " U64_FORMAT ")",
- incoming, U64_PRINTF_ARG(incoming->global_identifier),
- listener, U64_PRINTF_ARG(listener->global_identifier));
-
- if (!(listener->listener)) need_to_queue = 1;
- if (listener->incoming_list &&
- (smartlist_len(listener->incoming_list) > 0))
- need_to_queue = 1;
-
- if (need_to_queue && !(listener->incoming_list)) {
- listener->incoming_list = smartlist_new();
- }
-
- channel_listener_timestamp_active(listener);
- channel_listener_timestamp_accepted(listener);
- ++(listener->n_accepted);
-
- if (!need_to_queue) {
- tor_assert(listener->listener);
- listener->listener(listener, incoming);
- }
-
- else {
- tor_assert(listener->incoming_list);
- smartlist_add(listener->incoming_list, incoming);
- if (listener->listener) channel_listener_process_incoming(listener);
- }
- }
- void
- channel_process_cell(channel_t *chan, cell_t *cell)
- {
- tor_assert(chan);
- tor_assert(CHANNEL_IS_CLOSING(chan) || CHANNEL_IS_MAINT(chan) ||
- CHANNEL_IS_OPEN(chan));
- tor_assert(cell);
-
- if (!chan->cell_handler)
- return;
-
- channel_timestamp_recv(chan);
-
- ++(chan->n_cells_recved);
- chan->n_bytes_recved += get_cell_network_size(chan->wide_circ_ids);
- log_debug(LD_CHANNEL,
- "Processing incoming cell_t %p for channel %p (global ID "
- U64_FORMAT ")", cell, chan,
- U64_PRINTF_ARG(chan->global_identifier));
- chan->cell_handler(chan, cell);
- }
- int
- packed_cell_is_destroy(channel_t *chan,
- const packed_cell_t *packed_cell,
- circid_t *circid_out)
- {
- if (chan->wide_circ_ids) {
- if (packed_cell->body[4] == CELL_DESTROY) {
- *circid_out = ntohl(get_uint32(packed_cell->body));
- return 1;
- }
- } else {
- if (packed_cell->body[2] == CELL_DESTROY) {
- *circid_out = ntohs(get_uint16(packed_cell->body));
- return 1;
- }
- }
- return 0;
- }
- int
- channel_send_destroy(circid_t circ_id, channel_t *chan, int reason)
- {
- tor_assert(chan);
- if (circ_id == 0) {
- log_warn(LD_BUG, "Attempted to send a destroy cell for circID 0 "
- "on a channel " U64_FORMAT " at %p in state %s (%d)",
- U64_PRINTF_ARG(chan->global_identifier),
- chan, channel_state_to_string(chan->state),
- chan->state);
- return 0;
- }
-
- if (!CHANNEL_CONDEMNED(chan) && chan->cmux) {
- channel_note_destroy_pending(chan, circ_id);
- circuitmux_append_destroy_cell(chan, chan->cmux, circ_id, reason);
- log_debug(LD_OR,
- "Sending destroy (circID %u) on channel %p "
- "(global ID " U64_FORMAT ")",
- (unsigned)circ_id, chan,
- U64_PRINTF_ARG(chan->global_identifier));
- } else {
- log_warn(LD_BUG,
- "Someone called channel_send_destroy() for circID %u "
- "on a channel " U64_FORMAT " at %p in state %s (%d)",
- (unsigned)circ_id, U64_PRINTF_ARG(chan->global_identifier),
- chan, channel_state_to_string(chan->state),
- chan->state);
- }
- return 0;
- }
- void
- channel_dumpstats(int severity)
- {
- if (all_channels && smartlist_len(all_channels) > 0) {
- tor_log(severity, LD_GENERAL,
- "Dumping statistics about %d channels:",
- smartlist_len(all_channels));
- tor_log(severity, LD_GENERAL,
- "%d are active, and %d are done and waiting for cleanup",
- (active_channels != NULL) ?
- smartlist_len(active_channels) : 0,
- (finished_channels != NULL) ?
- smartlist_len(finished_channels) : 0);
- SMARTLIST_FOREACH(all_channels, channel_t *, chan,
- channel_dump_statistics(chan, severity));
- tor_log(severity, LD_GENERAL,
- "Done spamming about channels now");
- } else {
- tor_log(severity, LD_GENERAL,
- "No channels to dump");
- }
- }
- void
- channel_listener_dumpstats(int severity)
- {
- if (all_listeners && smartlist_len(all_listeners) > 0) {
- tor_log(severity, LD_GENERAL,
- "Dumping statistics about %d channel listeners:",
- smartlist_len(all_listeners));
- tor_log(severity, LD_GENERAL,
- "%d are active and %d are done and waiting for cleanup",
- (active_listeners != NULL) ?
- smartlist_len(active_listeners) : 0,
- (finished_listeners != NULL) ?
- smartlist_len(finished_listeners) : 0);
- SMARTLIST_FOREACH(all_listeners, channel_listener_t *, chan_l,
- channel_listener_dump_statistics(chan_l, severity));
- tor_log(severity, LD_GENERAL,
- "Done spamming about channel listeners now");
- } else {
- tor_log(severity, LD_GENERAL,
- "No channel listeners to dump");
- }
- }
- void
- channel_run_cleanup(void)
- {
- channel_t *tmp = NULL;
-
- if (!finished_channels || smartlist_len(finished_channels) == 0) return;
-
- SMARTLIST_FOREACH_BEGIN(finished_channels, channel_t *, curr) {
- tmp = curr;
-
- SMARTLIST_DEL_CURRENT(finished_channels, curr);
-
- channel_unregister(tmp);
-
- channel_free(tmp);
- } SMARTLIST_FOREACH_END(curr);
- }
- void
- channel_listener_run_cleanup(void)
- {
- channel_listener_t *tmp = NULL;
-
- if (!finished_listeners || smartlist_len(finished_listeners) == 0) return;
-
- SMARTLIST_FOREACH_BEGIN(finished_listeners, channel_listener_t *, curr) {
- tmp = curr;
-
- SMARTLIST_DEL_CURRENT(finished_listeners, curr);
-
- channel_listener_unregister(tmp);
-
- channel_listener_free(tmp);
- } SMARTLIST_FOREACH_END(curr);
- }
- static void
- channel_free_list(smartlist_t *channels, int mark_for_close)
- {
- if (!channels) return;
- SMARTLIST_FOREACH_BEGIN(channels, channel_t *, curr) {
-
- tor_assert(curr);
- log_debug(LD_CHANNEL,
- "Cleaning up channel %p (global ID " U64_FORMAT ") "
- "in state %s (%d)",
- curr, U64_PRINTF_ARG(curr->global_identifier),
- channel_state_to_string(curr->state), curr->state);
-
- if (curr->cmux) {
- circuitmux_detach_all_circuits(curr->cmux, NULL);
- }
- SMARTLIST_DEL_CURRENT(channels, curr);
- channel_unregister(curr);
- if (mark_for_close) {
- if (!CHANNEL_CONDEMNED(curr)) {
- channel_mark_for_close(curr);
- }
- channel_force_xfree(curr);
- } else channel_free(curr);
- } SMARTLIST_FOREACH_END(curr);
- }
- static void
- channel_listener_free_list(smartlist_t *listeners, int mark_for_close)
- {
- if (!listeners) return;
- SMARTLIST_FOREACH_BEGIN(listeners, channel_listener_t *, curr) {
-
- tor_assert(curr);
- log_debug(LD_CHANNEL,
- "Cleaning up channel listener %p (global ID " U64_FORMAT ") "
- "in state %s (%d)",
- curr, U64_PRINTF_ARG(curr->global_identifier),
- channel_listener_state_to_string(curr->state), curr->state);
- channel_listener_unregister(curr);
- if (mark_for_close) {
- if (!(curr->state == CHANNEL_LISTENER_STATE_CLOSING ||
- curr->state == CHANNEL_LISTENER_STATE_CLOSED ||
- curr->state == CHANNEL_LISTENER_STATE_ERROR)) {
- channel_listener_mark_for_close(curr);
- }
- channel_listener_force_xfree(curr);
- } else channel_listener_free(curr);
- } SMARTLIST_FOREACH_END(curr);
- }
- void
- channel_free_all(void)
- {
- log_debug(LD_CHANNEL,
- "Shutting down channels...");
-
- if (finished_channels) {
- channel_free_list(finished_channels, 0);
- smartlist_free(finished_channels);
- finished_channels = NULL;
- }
-
- if (finished_listeners) {
- channel_listener_free_list(finished_listeners, 0);
- smartlist_free(finished_listeners);
- finished_listeners = NULL;
- }
-
- if (active_channels) {
- channel_free_list(active_channels, 1);
- smartlist_free(active_channels);
- active_channels = NULL;
- }
-
- if (active_listeners) {
- channel_listener_free_list(active_listeners, 1);
- smartlist_free(active_listeners);
- active_listeners = NULL;
- }
-
- if (all_channels) {
- channel_free_list(all_channels, 1);
- smartlist_free(all_channels);
- all_channels = NULL;
- }
-
- if (all_listeners) {
- channel_listener_free_list(all_listeners, 1);
- smartlist_free(all_listeners);
- all_listeners = NULL;
- }
-
- log_debug(LD_CHANNEL,
- "Freeing channel_identity_map");
-
- HT_CLEAR(channel_idmap, &channel_identity_map);
-
- log_debug(LD_CHANNEL,
- "Freeing channel_gid_map");
- HT_CLEAR(channel_gid_map, &channel_gid_map);
- log_debug(LD_CHANNEL,
- "Done cleaning up after channels");
- }
- channel_t *
- channel_connect(const tor_addr_t *addr, uint16_t port,
- const char *id_digest,
- const ed25519_public_key_t *ed_id)
- {
- return channel_tls_connect(addr, port, id_digest, ed_id);
- }
- int
- channel_is_better(channel_t *a, channel_t *b)
- {
- int a_is_canonical, b_is_canonical;
- tor_assert(a);
- tor_assert(b);
-
- if (!channel_is_bad_for_new_circs(a) && channel_is_bad_for_new_circs(b))
- return 1;
- if (channel_is_bad_for_new_circs(a) && !channel_is_bad_for_new_circs(b))
- return 0;
-
- a_is_canonical = channel_is_canonical(a);
- b_is_canonical = channel_is_canonical(b);
- if (a_is_canonical && !b_is_canonical) return 1;
- if (!a_is_canonical && b_is_canonical) return 0;
-
- if (a->is_canonical_to_peer && !b->is_canonical_to_peer) return 1;
- if (!a->is_canonical_to_peer && b->is_canonical_to_peer) return 0;
-
- if (channel_when_created(a) < channel_when_created(b)) return 1;
- else if (channel_when_created(a) > channel_when_created(b)) return 0;
- if (channel_num_circuits(a) > channel_num_circuits(b)) return 1;
- else return 0;
- }
- channel_t *
- channel_get_for_extend(const char *rsa_id_digest,
- const ed25519_public_key_t *ed_id,
- const tor_addr_t *target_addr,
- const char **msg_out,
- int *launch_out)
- {
- channel_t *chan, *best = NULL;
- int n_inprogress_goodaddr = 0, n_old = 0;
- int n_noncanonical = 0;
- tor_assert(msg_out);
- tor_assert(launch_out);
- chan = channel_find_by_remote_identity(rsa_id_digest, ed_id);
-
- for (; chan; chan = channel_next_with_rsa_identity(chan)) {
- tor_assert(tor_memeq(chan->identity_digest,
- rsa_id_digest, DIGEST_LEN));
- if (CHANNEL_CONDEMNED(chan))
- continue;
-
- if (channel_is_client(chan)) {
- continue;
- }
-
- if (!channel_remote_identity_matches(chan, rsa_id_digest, ed_id)) {
- continue;
- }
-
- if (!CHANNEL_IS_OPEN(chan)) {
-
- if (channel_matches_target_addr_for_extend(chan, target_addr))
- ++n_inprogress_goodaddr;
- continue;
- }
-
- if (channel_is_bad_for_new_circs(chan)) {
- ++n_old;
- continue;
- }
-
- if (!channel_is_canonical(chan) &&
- channel_is_canonical_is_reliable(chan) &&
- !channel_matches_target_addr_for_extend(chan, target_addr)) {
- ++n_noncanonical;
- continue;
- }
- if (!best) {
- best = chan;
- continue;
- }
- if (channel_is_better(chan, best))
- best = chan;
- }
- if (best) {
- *msg_out = "Connection is fine; using it.";
- *launch_out = 0;
- return best;
- } else if (n_inprogress_goodaddr) {
- *msg_out = "Connection in progress; waiting.";
- *launch_out = 0;
- return NULL;
- } else if (n_old || n_noncanonical) {
- *msg_out = "Connections all too old, or too non-canonical. "
- " Launching a new one.";
- *launch_out = 1;
- return NULL;
- } else {
- *msg_out = "Not connected. Connecting.";
- *launch_out = 1;
- return NULL;
- }
- }
- const char *
- channel_describe_transport(channel_t *chan)
- {
- tor_assert(chan);
- tor_assert(chan->describe_transport);
- return chan->describe_transport(chan);
- }
- const char *
- channel_listener_describe_transport(channel_listener_t *chan_l)
- {
- tor_assert(chan_l);
- tor_assert(chan_l->describe_transport);
- return chan_l->describe_transport(chan_l);
- }
- MOCK_IMPL(void,
- channel_dump_statistics, (channel_t *chan, int severity))
- {
- double avg, interval, age;
- time_t now = time(NULL);
- tor_addr_t remote_addr;
- int have_remote_addr;
- char *remote_addr_str;
- tor_assert(chan);
- age = (double)(now - chan->timestamp_created);
- tor_log(severity, LD_GENERAL,
- "Channel " U64_FORMAT " (at %p) with transport %s is in state "
- "%s (%d)",
- U64_PRINTF_ARG(chan->global_identifier), chan,
- channel_describe_transport(chan),
- channel_state_to_string(chan->state), chan->state);
- tor_log(severity, LD_GENERAL,
- " * Channel " U64_FORMAT " was created at " U64_FORMAT
- " (" U64_FORMAT " seconds ago) "
- "and last active at " U64_FORMAT " (" U64_FORMAT " seconds ago)",
- U64_PRINTF_ARG(chan->global_identifier),
- U64_PRINTF_ARG(chan->timestamp_created),
- U64_PRINTF_ARG(now - chan->timestamp_created),
- U64_PRINTF_ARG(chan->timestamp_active),
- U64_PRINTF_ARG(now - chan->timestamp_active));
-
- if (!tor_digest_is_zero(chan->identity_digest)) {
- tor_log(severity, LD_GENERAL,
- " * Channel " U64_FORMAT " says it is connected "
- "to an OR with digest %s",
- U64_PRINTF_ARG(chan->global_identifier),
- hex_str(chan->identity_digest, DIGEST_LEN));
- } else {
- tor_log(severity, LD_GENERAL,
- " * Channel " U64_FORMAT " does not know the digest"
- " of the OR it is connected to",
- U64_PRINTF_ARG(chan->global_identifier));
- }
-
- have_remote_addr = channel_get_addr_if_possible(chan, &remote_addr);
- if (have_remote_addr) {
- char *actual = tor_strdup(channel_get_actual_remote_descr(chan));
- remote_addr_str = tor_addr_to_str_dup(&remote_addr);
- tor_log(severity, LD_GENERAL,
- " * Channel " U64_FORMAT " says its remote address"
- " is %s, and gives a canonical description of \"%s\" and an "
- "actual description of \"%s\"",
- U64_PRINTF_ARG(chan->global_identifier),
- safe_str(remote_addr_str),
- safe_str(channel_get_canonical_remote_descr(chan)),
- safe_str(actual));
- tor_free(remote_addr_str);
- tor_free(actual);
- } else {
- char *actual = tor_strdup(channel_get_actual_remote_descr(chan));
- tor_log(severity, LD_GENERAL,
- " * Channel " U64_FORMAT " does not know its remote "
- "address, but gives a canonical description of \"%s\" and an "
- "actual description of \"%s\"",
- U64_PRINTF_ARG(chan->global_identifier),
- channel_get_canonical_remote_descr(chan),
- actual);
- tor_free(actual);
- }
-
- tor_log(severity, LD_GENERAL,
- " * Channel " U64_FORMAT " has these marks: %s %s %s "
- "%s %s %s",
- U64_PRINTF_ARG(chan->global_identifier),
- channel_is_bad_for_new_circs(chan) ?
- "bad_for_new_circs" : "!bad_for_new_circs",
- channel_is_canonical(chan) ?
- "canonical" : "!canonical",
- channel_is_canonical_is_reliable(chan) ?
- "is_canonical_is_reliable" :
- "!is_canonical_is_reliable",
- channel_is_client(chan) ?
- "client" : "!client",
- channel_is_local(chan) ?
- "local" : "!local",
- channel_is_incoming(chan) ?
- "incoming" : "outgoing");
-
- tor_log(severity, LD_GENERAL,
- " * Channel " U64_FORMAT " has %d active circuits out of"
- " %d in total",
- U64_PRINTF_ARG(chan->global_identifier),
- (chan->cmux != NULL) ?
- circuitmux_num_active_circuits(chan->cmux) : 0,
- (chan->cmux != NULL) ?
- circuitmux_num_circuits(chan->cmux) : 0);
-
- tor_log(severity, LD_GENERAL,
- " * Channel " U64_FORMAT " was last used by a "
- "client at " U64_FORMAT " (" U64_FORMAT " seconds ago)",
- U64_PRINTF_ARG(chan->global_identifier),
- U64_PRINTF_ARG(chan->timestamp_client),
- U64_PRINTF_ARG(now - chan->timestamp_client));
- tor_log(severity, LD_GENERAL,
- " * Channel " U64_FORMAT " last received a cell "
- "at " U64_FORMAT " (" U64_FORMAT " seconds ago)",
- U64_PRINTF_ARG(chan->global_identifier),
- U64_PRINTF_ARG(chan->timestamp_recv),
- U64_PRINTF_ARG(now - chan->timestamp_recv));
- tor_log(severity, LD_GENERAL,
- " * Channel " U64_FORMAT " last transmitted a cell "
- "at " U64_FORMAT " (" U64_FORMAT " seconds ago)",
- U64_PRINTF_ARG(chan->global_identifier),
- U64_PRINTF_ARG(chan->timestamp_xmit),
- U64_PRINTF_ARG(now - chan->timestamp_xmit));
-
- tor_log(severity, LD_GENERAL,
- " * Channel " U64_FORMAT " has received "
- U64_FORMAT " bytes in " U64_FORMAT " cells and transmitted "
- U64_FORMAT " bytes in " U64_FORMAT " cells",
- U64_PRINTF_ARG(chan->global_identifier),
- U64_PRINTF_ARG(chan->n_bytes_recved),
- U64_PRINTF_ARG(chan->n_cells_recved),
- U64_PRINTF_ARG(chan->n_bytes_xmitted),
- U64_PRINTF_ARG(chan->n_cells_xmitted));
- if (now > chan->timestamp_created &&
- chan->timestamp_created > 0) {
- if (chan->n_bytes_recved > 0) {
- avg = (double)(chan->n_bytes_recved) / age;
- tor_log(severity, LD_GENERAL,
- " * Channel " U64_FORMAT " has averaged %f "
- "bytes received per second",
- U64_PRINTF_ARG(chan->global_identifier), avg);
- }
- if (chan->n_cells_recved > 0) {
- avg = (double)(chan->n_cells_recved) / age;
- if (avg >= 1.0) {
- tor_log(severity, LD_GENERAL,
- " * Channel " U64_FORMAT " has averaged %f "
- "cells received per second",
- U64_PRINTF_ARG(chan->global_identifier), avg);
- } else if (avg >= 0.0) {
- interval = 1.0 / avg;
- tor_log(severity, LD_GENERAL,
- " * Channel " U64_FORMAT " has averaged %f "
- "seconds between received cells",
- U64_PRINTF_ARG(chan->global_identifier), interval);
- }
- }
- if (chan->n_bytes_xmitted > 0) {
- avg = (double)(chan->n_bytes_xmitted) / age;
- tor_log(severity, LD_GENERAL,
- " * Channel " U64_FORMAT " has averaged %f "
- "bytes transmitted per second",
- U64_PRINTF_ARG(chan->global_identifier), avg);
- }
- if (chan->n_cells_xmitted > 0) {
- avg = (double)(chan->n_cells_xmitted) / age;
- if (avg >= 1.0) {
- tor_log(severity, LD_GENERAL,
- " * Channel " U64_FORMAT " has averaged %f "
- "cells transmitted per second",
- U64_PRINTF_ARG(chan->global_identifier), avg);
- } else if (avg >= 0.0) {
- interval = 1.0 / avg;
- tor_log(severity, LD_GENERAL,
- " * Channel " U64_FORMAT " has averaged %f "
- "seconds between transmitted cells",
- U64_PRINTF_ARG(chan->global_identifier), interval);
- }
- }
- }
-
- channel_dump_transport_statistics(chan, severity);
- }
- void
- channel_listener_dump_statistics(channel_listener_t *chan_l, int severity)
- {
- double avg, interval, age;
- time_t now = time(NULL);
- tor_assert(chan_l);
- age = (double)(now - chan_l->timestamp_created);
- tor_log(severity, LD_GENERAL,
- "Channel listener " U64_FORMAT " (at %p) with transport %s is in "
- "state %s (%d)",
- U64_PRINTF_ARG(chan_l->global_identifier), chan_l,
- channel_listener_describe_transport(chan_l),
- channel_listener_state_to_string(chan_l->state), chan_l->state);
- tor_log(severity, LD_GENERAL,
- " * Channel listener " U64_FORMAT " was created at " U64_FORMAT
- " (" U64_FORMAT " seconds ago) "
- "and last active at " U64_FORMAT " (" U64_FORMAT " seconds ago)",
- U64_PRINTF_ARG(chan_l->global_identifier),
- U64_PRINTF_ARG(chan_l->timestamp_created),
- U64_PRINTF_ARG(now - chan_l->timestamp_created),
- U64_PRINTF_ARG(chan_l->timestamp_active),
- U64_PRINTF_ARG(now - chan_l->timestamp_active));
- tor_log(severity, LD_GENERAL,
- " * Channel listener " U64_FORMAT " last accepted an incoming "
- "channel at " U64_FORMAT " (" U64_FORMAT " seconds ago) "
- "and has accepted " U64_FORMAT " channels in total",
- U64_PRINTF_ARG(chan_l->global_identifier),
- U64_PRINTF_ARG(chan_l->timestamp_accepted),
- U64_PRINTF_ARG(now - chan_l->timestamp_accepted),
- U64_PRINTF_ARG(chan_l->n_accepted));
-
- if (now > chan_l->timestamp_created &&
- chan_l->timestamp_created > 0 &&
- chan_l->n_accepted > 0) {
- avg = (double)(chan_l->n_accepted) / age;
- if (avg >= 1.0) {
- tor_log(severity, LD_GENERAL,
- " * Channel listener " U64_FORMAT " has averaged %f incoming "
- "channels per second",
- U64_PRINTF_ARG(chan_l->global_identifier), avg);
- } else if (avg >= 0.0) {
- interval = 1.0 / avg;
- tor_log(severity, LD_GENERAL,
- " * Channel listener " U64_FORMAT " has averaged %f seconds "
- "between incoming channels",
- U64_PRINTF_ARG(chan_l->global_identifier), interval);
- }
- }
-
- channel_listener_dump_transport_statistics(chan_l, severity);
- }
- void
- channel_dump_transport_statistics(channel_t *chan, int severity)
- {
- tor_assert(chan);
- if (chan->dumpstats) chan->dumpstats(chan, severity);
- }
- void
- channel_listener_dump_transport_statistics(channel_listener_t *chan_l,
- int severity)
- {
- tor_assert(chan_l);
- if (chan_l->dumpstats) chan_l->dumpstats(chan_l, severity);
- }
- const char *
- channel_get_actual_remote_descr(channel_t *chan)
- {
- tor_assert(chan);
- tor_assert(chan->get_remote_descr);
-
- return chan->get_remote_descr(chan, GRD_FLAG_ORIGINAL);
- }
- const char *
- channel_get_actual_remote_address(channel_t *chan)
- {
-
- return chan->get_remote_descr(chan, GRD_FLAG_ORIGINAL|GRD_FLAG_ADDR_ONLY);
- }
- const char *
- channel_get_canonical_remote_descr(channel_t *chan)
- {
- tor_assert(chan);
- tor_assert(chan->get_remote_descr);
-
- return chan->get_remote_descr(chan, 0);
- }
- MOCK_IMPL(int,
- channel_get_addr_if_possible,(channel_t *chan, tor_addr_t *addr_out))
- {
- tor_assert(chan);
- tor_assert(addr_out);
- if (chan->get_remote_addr)
- return chan->get_remote_addr(chan, addr_out);
-
- else return 0;
- }
- int
- channel_has_queued_writes(channel_t *chan)
- {
- tor_assert(chan);
- tor_assert(chan->has_queued_writes);
-
- return chan->has_queued_writes(chan);
- }
- int
- channel_is_bad_for_new_circs(channel_t *chan)
- {
- tor_assert(chan);
- return chan->is_bad_for_new_circs;
- }
- void
- channel_mark_bad_for_new_circs(channel_t *chan)
- {
- tor_assert(chan);
- chan->is_bad_for_new_circs = 1;
- }
- int
- channel_is_client(const channel_t *chan)
- {
- tor_assert(chan);
- return chan->is_client;
- }
- void
- channel_mark_client(channel_t *chan)
- {
- tor_assert(chan);
- chan->is_client = 1;
- }
- void
- channel_clear_client(channel_t *chan)
- {
- tor_assert(chan);
- chan->is_client = 0;
- }
- int
- channel_is_canonical(channel_t *chan)
- {
- tor_assert(chan);
- tor_assert(chan->is_canonical);
- return chan->is_canonical(chan, 0);
- }
- int
- channel_is_canonical_is_reliable(channel_t *chan)
- {
- tor_assert(chan);
- tor_assert(chan->is_canonical);
- return chan->is_canonical(chan, 1);
- }
- int
- channel_is_incoming(channel_t *chan)
- {
- tor_assert(chan);
- return chan->is_incoming;
- }
- void
- channel_mark_incoming(channel_t *chan)
- {
- tor_assert(chan);
- chan->is_incoming = 1;
- }
- int
- channel_is_local(channel_t *chan)
- {
- tor_assert(chan);
- return chan->is_local;
- }
- void
- channel_mark_local(channel_t *chan)
- {
- tor_assert(chan);
- chan->is_local = 1;
- }
- void
- channel_mark_remote(channel_t *chan)
- {
- tor_assert(chan);
- chan->is_local = 0;
- }
- int
- channel_is_outgoing(channel_t *chan)
- {
- tor_assert(chan);
- return !(chan->is_incoming);
- }
- void
- channel_mark_outgoing(channel_t *chan)
- {
- tor_assert(chan);
- chan->is_incoming = 0;
- }
- int
- channel_num_cells_writeable(channel_t *chan)
- {
- int result;
- tor_assert(chan);
- tor_assert(chan->num_cells_writeable);
- if (chan->state == CHANNEL_STATE_OPEN) {
-
- result = chan->num_cells_writeable(chan);
- if (result < 0) result = 0;
- } else {
-
- result = 0;
- }
- return result;
- }
- void
- channel_timestamp_created(channel_t *chan)
- {
- time_t now = time(NULL);
- tor_assert(chan);
- chan->timestamp_created = now;
- }
- void
- channel_listener_timestamp_created(channel_listener_t *chan_l)
- {
- time_t now = time(NULL);
- tor_assert(chan_l);
- chan_l->timestamp_created = now;
- }
- void
- channel_timestamp_active(channel_t *chan)
- {
- time_t now = time(NULL);
- tor_assert(chan);
- monotime_coarse_get(&chan->timestamp_xfer);
- chan->timestamp_active = now;
-
- monotime_coarse_zero(&chan->next_padding_time);
- }
- void
- channel_listener_timestamp_active(channel_listener_t *chan_l)
- {
- time_t now = time(NULL);
- tor_assert(chan_l);
- chan_l->timestamp_active = now;
- }
- void
- channel_listener_timestamp_accepted(channel_listener_t *chan_l)
- {
- time_t now = time(NULL);
- tor_assert(chan_l);
- chan_l->timestamp_active = now;
- chan_l->timestamp_accepted = now;
- }
- void
- channel_timestamp_client(channel_t *chan)
- {
- time_t now = time(NULL);
- tor_assert(chan);
- chan->timestamp_client = now;
- }
- void
- channel_timestamp_recv(channel_t *chan)
- {
- time_t now = time(NULL);
- tor_assert(chan);
- monotime_coarse_get(&chan->timestamp_xfer);
- chan->timestamp_active = now;
- chan->timestamp_recv = now;
-
- monotime_coarse_zero(&chan->next_padding_time);
- }
- void
- channel_timestamp_xmit(channel_t *chan)
- {
- time_t now = time(NULL);
- tor_assert(chan);
- monotime_coarse_get(&chan->timestamp_xfer);
- chan->timestamp_active = now;
- chan->timestamp_xmit = now;
-
- monotime_coarse_zero(&chan->next_padding_time);
- }
- time_t
- channel_when_created(channel_t *chan)
- {
- tor_assert(chan);
- return chan->timestamp_created;
- }
- time_t
- channel_when_last_client(channel_t *chan)
- {
- tor_assert(chan);
- return chan->timestamp_client;
- }
- time_t
- channel_when_last_xmit(channel_t *chan)
- {
- tor_assert(chan);
- return chan->timestamp_xmit;
- }
- int
- channel_matches_extend_info(channel_t *chan, extend_info_t *extend_info)
- {
- tor_assert(chan);
- tor_assert(chan->matches_extend_info);
- tor_assert(extend_info);
- return chan->matches_extend_info(chan, extend_info);
- }
- int
- channel_matches_target_addr_for_extend(channel_t *chan,
- const tor_addr_t *target)
- {
- tor_assert(chan);
- tor_assert(chan->matches_target);
- tor_assert(target);
- return chan->matches_target(chan, target);
- }
- unsigned int
- channel_num_circuits(channel_t *chan)
- {
- tor_assert(chan);
- return chan->num_n_circuits +
- chan->num_p_circuits;
- }
- MOCK_IMPL(void,
- channel_set_circid_type,(channel_t *chan,
- crypto_pk_t *identity_rcvd,
- int consider_identity))
- {
- int started_here;
- crypto_pk_t *our_identity;
- tor_assert(chan);
- started_here = channel_is_outgoing(chan);
- if (! consider_identity) {
- if (started_here)
- chan->circ_id_type = CIRC_ID_TYPE_HIGHER;
- else
- chan->circ_id_type = CIRC_ID_TYPE_LOWER;
- return;
- }
- our_identity = started_here ?
- get_tlsclient_identity_key() : get_server_identity_key();
- if (identity_rcvd) {
- if (crypto_pk_cmp_keys(our_identity, identity_rcvd) < 0) {
- chan->circ_id_type = CIRC_ID_TYPE_LOWER;
- } else {
- chan->circ_id_type = CIRC_ID_TYPE_HIGHER;
- }
- } else {
- chan->circ_id_type = CIRC_ID_TYPE_NEITHER;
- }
- }
- static int
- channel_sort_by_ed25519_identity(const void **a_, const void **b_)
- {
- const channel_t *a = *a_,
- *b = *b_;
- return fast_memcmp(&a->ed25519_identity.pubkey,
- &b->ed25519_identity.pubkey,
- sizeof(a->ed25519_identity.pubkey));
- }
- static void
- channel_rsa_id_group_set_badness(struct channel_list_s *lst, int force)
- {
-
- channel_t *chan = TOR_LIST_FIRST(lst);
- if (!chan)
- return;
-
- if (PREDICT_LIKELY(!TOR_LIST_NEXT(chan, next_with_same_id))) {
- connection_or_single_set_badness_(
- time(NULL), BASE_CHAN_TO_TLS(chan)->conn, force);
- return;
- }
- smartlist_t *channels = smartlist_new();
- TOR_LIST_FOREACH(chan, lst, next_with_same_id) {
- if (BASE_CHAN_TO_TLS(chan)->conn) {
- smartlist_add(channels, chan);
- }
- }
- smartlist_sort(channels, channel_sort_by_ed25519_identity);
- const ed25519_public_key_t *common_ed25519_identity = NULL;
-
- smartlist_t *or_conns = smartlist_new();
- SMARTLIST_FOREACH_BEGIN(channels, channel_t *, channel) {
- if (!common_ed25519_identity)
- common_ed25519_identity = &channel->ed25519_identity;
- if (! ed25519_pubkey_eq(&channel->ed25519_identity,
- common_ed25519_identity)) {
- connection_or_group_set_badness_(or_conns, force);
- smartlist_clear(or_conns);
- common_ed25519_identity = &channel->ed25519_identity;
- }
- smartlist_add(or_conns, BASE_CHAN_TO_TLS(channel)->conn);
- } SMARTLIST_FOREACH_END(channel);
- connection_or_group_set_badness_(or_conns, force);
-
- smartlist_free(or_conns);
- smartlist_free(channels);
- }
- void
- channel_update_bad_for_new_circs(const char *digest, int force)
- {
- if (digest) {
- channel_idmap_entry_t *ent;
- channel_idmap_entry_t search;
- memset(&search, 0, sizeof(search));
- memcpy(search.digest, digest, DIGEST_LEN);
- ent = HT_FIND(channel_idmap, &channel_identity_map, &search);
- if (ent) {
- channel_rsa_id_group_set_badness(&ent->channel_list, force);
- }
- return;
- }
-
- channel_idmap_entry_t **iter;
- HT_FOREACH(iter, channel_idmap, &channel_identity_map) {
- channel_rsa_id_group_set_badness(&(*iter)->channel_list, force);
- }
- }
|