123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119112011211122112311241125112611271128112911301131113211331134113511361137113811391140114111421143114411451146114711481149115011511152115311541155115611571158115911601161116211631164116511661167116811691170117111721173117411751176117711781179118011811182118311841185118611871188118911901191119211931194119511961197119811991200120112021203120412051206120712081209121012111212121312141215121612171218121912201221122212231224122512261227122812291230123112321233123412351236123712381239124012411242124312441245124612471248124912501251125212531254125512561257125812591260126112621263126412651266126712681269127012711272127312741275127612771278127912801281128212831284128512861287128812891290129112921293129412951296129712981299130013011302130313041305130613071308130913101311131213131314131513161317131813191320132113221323132413251326132713281329133013311332133313341335133613371338133913401341134213431344134513461347134813491350135113521353135413551356135713581359136013611362136313641365136613671368136913701371137213731374137513761377137813791380138113821383138413851386138713881389139013911392139313941395139613971398139914001401140214031404140514061407140814091410141114121413141414151416141714181419142014211422142314241425142614271428142914301431143214331434143514361437143814391440144114421443144414451446144714481449145014511452145314541455145614571458145914601461146214631464146514661467146814691470147114721473147414751476147714781479148014811482148314841485148614871488148914901491149214931494149514961497149814991500150115021503150415051506150715081509151015111512151315141515151615171518151915201521152215231524152515261527152815291530153115321533153415351536153715381539154015411542154315441545154615471548154915501551155215531554155515561557155815591560156115621563156415651566156715681569157015711572157315741575157615771578157915801581158215831584158515861587158815891590159115921593159415951596159715981599160016011602160316041605160616071608160916101611161216131614161516161617161816191620162116221623162416251626162716281629163016311632163316341635163616371638163916401641164216431644164516461647164816491650165116521653165416551656165716581659166016611662166316641665166616671668166916701671167216731674167516761677167816791680168116821683168416851686168716881689169016911692169316941695169616971698169917001701170217031704170517061707170817091710171117121713171417151716171717181719172017211722172317241725172617271728172917301731173217331734173517361737173817391740174117421743174417451746174717481749175017511752175317541755175617571758175917601761176217631764176517661767176817691770177117721773177417751776177717781779178017811782178317841785178617871788178917901791179217931794179517961797179817991800180118021803180418051806180718081809181018111812181318141815181618171818181918201821182218231824182518261827182818291830183118321833183418351836183718381839184018411842184318441845184618471848184918501851185218531854185518561857185818591860186118621863186418651866186718681869187018711872187318741875187618771878187918801881188218831884188518861887188818891890189118921893189418951896189718981899190019011902190319041905190619071908190919101911191219131914191519161917191819191920192119221923192419251926192719281929193019311932193319341935193619371938193919401941194219431944194519461947194819491950195119521953195419551956195719581959196019611962196319641965196619671968196919701971197219731974197519761977197819791980198119821983198419851986198719881989199019911992199319941995199619971998199920002001200220032004200520062007200820092010201120122013201420152016201720182019202020212022202320242025202620272028202920302031203220332034203520362037203820392040204120422043204420452046204720482049205020512052205320542055205620572058205920602061206220632064206520662067206820692070207120722073207420752076207720782079208020812082208320842085208620872088208920902091209220932094209520962097209820992100210121022103210421052106210721082109211021112112211321142115211621172118211921202121212221232124212521262127212821292130213121322133213421352136213721382139214021412142214321442145214621472148214921502151215221532154215521562157215821592160216121622163216421652166216721682169217021712172217321742175217621772178217921802181218221832184218521862187218821892190219121922193219421952196219721982199220022012202220322042205220622072208220922102211221222132214221522162217221822192220222122222223222422252226222722282229223022312232223322342235223622372238223922402241224222432244224522462247224822492250225122522253225422552256225722582259226022612262226322642265226622672268226922702271227222732274227522762277227822792280228122822283228422852286228722882289229022912292229322942295229622972298229923002301230223032304230523062307230823092310231123122313231423152316231723182319232023212322232323242325232623272328232923302331233223332334233523362337233823392340234123422343234423452346234723482349235023512352235323542355235623572358235923602361236223632364236523662367236823692370237123722373237423752376237723782379238023812382238323842385238623872388238923902391239223932394239523962397239823992400240124022403240424052406240724082409241024112412241324142415241624172418241924202421242224232424242524262427242824292430243124322433243424352436243724382439244024412442244324442445244624472448244924502451245224532454245524562457245824592460246124622463246424652466246724682469247024712472247324742475247624772478247924802481248224832484248524862487248824892490249124922493249424952496249724982499250025012502250325042505250625072508250925102511251225132514251525162517251825192520252125222523252425252526252725282529253025312532253325342535253625372538253925402541254225432544254525462547254825492550255125522553255425552556255725582559256025612562256325642565256625672568256925702571257225732574257525762577257825792580258125822583258425852586258725882589259025912592259325942595259625972598259926002601260226032604260526062607260826092610261126122613261426152616261726182619262026212622262326242625262626272628262926302631263226332634263526362637263826392640264126422643264426452646264726482649265026512652265326542655265626572658265926602661266226632664266526662667266826692670267126722673267426752676267726782679268026812682268326842685268626872688268926902691269226932694269526962697269826992700270127022703270427052706270727082709271027112712271327142715271627172718271927202721272227232724272527262727272827292730273127322733273427352736273727382739274027412742274327442745274627472748274927502751275227532754275527562757275827592760276127622763276427652766276727682769277027712772277327742775277627772778277927802781278227832784278527862787278827892790279127922793279427952796279727982799280028012802280328042805280628072808280928102811281228132814281528162817281828192820282128222823282428252826282728282829283028312832283328342835283628372838283928402841284228432844284528462847284828492850285128522853285428552856285728582859286028612862286328642865286628672868286928702871287228732874287528762877287828792880288128822883288428852886288728882889289028912892289328942895289628972898289929002901290229032904290529062907290829092910291129122913291429152916291729182919292029212922292329242925292629272928292929302931293229332934293529362937293829392940294129422943294429452946294729482949295029512952295329542955295629572958295929602961296229632964296529662967296829692970297129722973297429752976297729782979298029812982298329842985298629872988298929902991299229932994299529962997299829993000300130023003300430053006300730083009301030113012301330143015301630173018301930203021302230233024302530263027302830293030303130323033303430353036303730383039304030413042304330443045304630473048304930503051305230533054305530563057305830593060306130623063306430653066 |
- #define RELAY_PRIVATE
- #include "or.h"
- #include "addressmap.h"
- #include "buffers.h"
- #include "channel.h"
- #include "circpathbias.h"
- #include "circuitbuild.h"
- #include "circuitlist.h"
- #include "circuituse.h"
- #include "config.h"
- #include "connection.h"
- #include "connection_edge.h"
- #include "connection_or.h"
- #include "control.h"
- #include "geoip.h"
- #include "main.h"
- #include "networkstatus.h"
- #include "nodelist.h"
- #include "onion.h"
- #include "policies.h"
- #include "reasons.h"
- #include "relay.h"
- #include "rendcache.h"
- #include "rendcommon.h"
- #include "router.h"
- #include "routerlist.h"
- #include "routerparse.h"
- #include "scheduler.h"
- static edge_connection_t *relay_lookup_conn(circuit_t *circ, cell_t *cell,
- cell_direction_t cell_direction,
- crypt_path_t *layer_hint);
- static int connection_edge_process_relay_cell(cell_t *cell, circuit_t *circ,
- edge_connection_t *conn,
- crypt_path_t *layer_hint);
- static void circuit_consider_sending_sendme(circuit_t *circ,
- crypt_path_t *layer_hint);
- static void circuit_resume_edge_reading(circuit_t *circ,
- crypt_path_t *layer_hint);
- static int circuit_resume_edge_reading_helper(edge_connection_t *conn,
- circuit_t *circ,
- crypt_path_t *layer_hint);
- static int circuit_consider_stop_edge_reading(circuit_t *circ,
- crypt_path_t *layer_hint);
- static int circuit_queue_streams_are_blocked(circuit_t *circ);
- static void adjust_exit_policy_from_exitpolicy_failure(origin_circuit_t *circ,
- entry_connection_t *conn,
- node_t *node,
- const tor_addr_t *addr);
- #if 0
- static int get_max_middle_cells(void);
- #endif
- #define CELL_QUEUE_HIGHWATER_SIZE 256
- #define CELL_QUEUE_LOWWATER_SIZE 64
- uint64_t stats_n_relay_cells_relayed = 0;
- uint64_t stats_n_relay_cells_delivered = 0;
- static tor_weak_rng_t stream_choice_rng = TOR_WEAK_RNG_INIT;
- static void
- relay_set_digest(crypto_digest_t *digest, cell_t *cell)
- {
- char integrity[4];
- relay_header_t rh;
- crypto_digest_add_bytes(digest, (char*)cell->payload, CELL_PAYLOAD_SIZE);
- crypto_digest_get_digest(digest, integrity, 4);
- relay_header_unpack(&rh, cell->payload);
- memcpy(rh.integrity, integrity, 4);
- relay_header_pack(cell->payload, &rh);
- }
- static int
- relay_digest_matches(crypto_digest_t *digest, cell_t *cell)
- {
- uint32_t received_integrity, calculated_integrity;
- relay_header_t rh;
- crypto_digest_t *backup_digest=NULL;
- backup_digest = crypto_digest_dup(digest);
- relay_header_unpack(&rh, cell->payload);
- memcpy(&received_integrity, rh.integrity, 4);
- memset(rh.integrity, 0, 4);
- relay_header_pack(cell->payload, &rh);
- crypto_digest_add_bytes(digest, (char*) cell->payload, CELL_PAYLOAD_SIZE);
- crypto_digest_get_digest(digest, (char*) &calculated_integrity, 4);
- if (calculated_integrity != received_integrity) {
-
- crypto_digest_assign(digest, backup_digest);
-
- memcpy(rh.integrity, &received_integrity, 4);
- relay_header_pack(cell->payload, &rh);
- crypto_digest_free(backup_digest);
- return 0;
- }
- crypto_digest_free(backup_digest);
- return 1;
- }
- static int
- relay_crypt_one_payload(crypto_cipher_t *cipher, uint8_t *in,
- int encrypt_mode)
- {
- (void)encrypt_mode;
- crypto_cipher_crypt_inplace(cipher, (char*) in, CELL_PAYLOAD_SIZE);
- return 0;
- }
- int
- circuit_receive_relay_cell(cell_t *cell, circuit_t *circ,
- cell_direction_t cell_direction)
- {
- channel_t *chan = NULL;
- crypt_path_t *layer_hint=NULL;
- char recognized=0;
- int reason;
- tor_assert(cell);
- tor_assert(circ);
- tor_assert(cell_direction == CELL_DIRECTION_OUT ||
- cell_direction == CELL_DIRECTION_IN);
- if (circ->marked_for_close)
- return 0;
- if (relay_crypt(circ, cell, cell_direction, &layer_hint, &recognized) < 0) {
- log_warn(LD_BUG,"relay crypt failed. Dropping connection.");
- return -END_CIRC_REASON_INTERNAL;
- }
- if (recognized) {
- edge_connection_t *conn = NULL;
- if (circ->purpose == CIRCUIT_PURPOSE_PATH_BIAS_TESTING) {
- pathbias_check_probe_response(circ, cell);
-
- return 0;
- }
- conn = relay_lookup_conn(circ, cell, cell_direction, layer_hint);
- if (cell_direction == CELL_DIRECTION_OUT) {
- ++stats_n_relay_cells_delivered;
- log_debug(LD_OR,"Sending away from origin.");
- if ((reason=connection_edge_process_relay_cell(cell, circ, conn, NULL))
- < 0) {
- log_fn(LOG_PROTOCOL_WARN, LD_PROTOCOL,
- "connection_edge_process_relay_cell (away from origin) "
- "failed.");
- return reason;
- }
- }
- if (cell_direction == CELL_DIRECTION_IN) {
- ++stats_n_relay_cells_delivered;
- log_debug(LD_OR,"Sending to origin.");
- if ((reason = connection_edge_process_relay_cell(cell, circ, conn,
- layer_hint)) < 0) {
- log_warn(LD_OR,
- "connection_edge_process_relay_cell (at origin) failed.");
- return reason;
- }
- }
- return 0;
- }
-
- if (cell_direction == CELL_DIRECTION_OUT) {
- cell->circ_id = circ->n_circ_id;
- chan = circ->n_chan;
- } else if (! CIRCUIT_IS_ORIGIN(circ)) {
- cell->circ_id = TO_OR_CIRCUIT(circ)->p_circ_id;
- chan = TO_OR_CIRCUIT(circ)->p_chan;
- } else {
- log_fn(LOG_PROTOCOL_WARN, LD_OR,
- "Dropping unrecognized inbound cell on origin circuit.");
-
- if (circ->purpose == CIRCUIT_PURPOSE_PATH_BIAS_TESTING) {
- TO_ORIGIN_CIRCUIT(circ)->path_state = PATH_STATE_USE_FAILED;
- return -END_CIRC_REASON_TORPROTOCOL;
- } else {
- return 0;
- }
- }
- if (!chan) {
-
- if (! CIRCUIT_IS_ORIGIN(circ) &&
- TO_OR_CIRCUIT(circ)->rend_splice &&
- cell_direction == CELL_DIRECTION_OUT) {
- or_circuit_t *splice_ = TO_OR_CIRCUIT(circ)->rend_splice;
- tor_assert(circ->purpose == CIRCUIT_PURPOSE_REND_ESTABLISHED);
- tor_assert(splice_->base_.purpose == CIRCUIT_PURPOSE_REND_ESTABLISHED);
- cell->circ_id = splice_->p_circ_id;
- cell->command = CELL_RELAY;
- if ((reason = circuit_receive_relay_cell(cell, TO_CIRCUIT(splice_),
- CELL_DIRECTION_IN)) < 0) {
- log_warn(LD_REND, "Error relaying cell across rendezvous; closing "
- "circuits");
-
- circuit_mark_for_close(circ, -reason);
- return reason;
- }
- return 0;
- }
- log_fn(LOG_PROTOCOL_WARN, LD_PROTOCOL,
- "Didn't recognize cell, but circ stops here! Closing circ.");
- return -END_CIRC_REASON_TORPROTOCOL;
- }
- log_debug(LD_OR,"Passing on unrecognized cell.");
- ++stats_n_relay_cells_relayed;
- append_cell_to_circuit_queue(circ, chan, cell, cell_direction, 0);
- return 0;
- }
- int
- relay_crypt(circuit_t *circ, cell_t *cell, cell_direction_t cell_direction,
- crypt_path_t **layer_hint, char *recognized)
- {
- relay_header_t rh;
- tor_assert(circ);
- tor_assert(cell);
- tor_assert(recognized);
- tor_assert(cell_direction == CELL_DIRECTION_IN ||
- cell_direction == CELL_DIRECTION_OUT);
- if (cell_direction == CELL_DIRECTION_IN) {
- if (CIRCUIT_IS_ORIGIN(circ)) {
- crypt_path_t *thishop, *cpath = TO_ORIGIN_CIRCUIT(circ)->cpath;
- thishop = cpath;
- if (thishop->state != CPATH_STATE_OPEN) {
- log_fn(LOG_PROTOCOL_WARN, LD_PROTOCOL,
- "Relay cell before first created cell? Closing.");
- return -1;
- }
- do {
- tor_assert(thishop);
- if (relay_crypt_one_payload(thishop->b_crypto, cell->payload, 0) < 0)
- return -1;
- relay_header_unpack(&rh, cell->payload);
- if (rh.recognized == 0) {
-
- if (relay_digest_matches(thishop->b_digest, cell)) {
- *recognized = 1;
- *layer_hint = thishop;
- return 0;
- }
- }
- thishop = thishop->next;
- } while (thishop != cpath && thishop->state == CPATH_STATE_OPEN);
- log_fn(LOG_PROTOCOL_WARN, LD_OR,
- "Incoming cell at client not recognized. Closing.");
- return -1;
- } else {
- if (relay_crypt_one_payload(TO_OR_CIRCUIT(circ)->p_crypto,
- cell->payload, 1) < 0)
- return -1;
- }
- } else {
-
- if (relay_crypt_one_payload(TO_OR_CIRCUIT(circ)->n_crypto,
- cell->payload, 0) < 0)
- return -1;
- relay_header_unpack(&rh, cell->payload);
- if (rh.recognized == 0) {
-
- if (relay_digest_matches(TO_OR_CIRCUIT(circ)->n_digest, cell)) {
- *recognized = 1;
- return 0;
- }
- }
- }
- return 0;
- }
- static int
- circuit_package_relay_cell(cell_t *cell, circuit_t *circ,
- cell_direction_t cell_direction,
- crypt_path_t *layer_hint, streamid_t on_stream,
- const char *filename, int lineno)
- {
- channel_t *chan;
- if (circ->marked_for_close) {
-
- return 0;
- }
- if (cell_direction == CELL_DIRECTION_OUT) {
- crypt_path_t *thishop;
- chan = circ->n_chan;
- if (!chan) {
- log_warn(LD_BUG,"outgoing relay cell sent from %s:%d has n_chan==NULL."
- " Dropping.", filename, lineno);
- return 0;
- }
- if (!CIRCUIT_IS_ORIGIN(circ)) {
- log_warn(LD_BUG,"outgoing relay cell sent from %s:%d on non-origin "
- "circ. Dropping.", filename, lineno);
- return 0;
- }
- relay_set_digest(layer_hint->f_digest, cell);
- thishop = layer_hint;
-
- do {
- tor_assert(thishop);
-
- log_debug(LD_OR,"crypting a layer of the relay cell.");
- if (relay_crypt_one_payload(thishop->f_crypto, cell->payload, 1) < 0) {
- return -1;
- }
- thishop = thishop->prev;
- } while (thishop != TO_ORIGIN_CIRCUIT(circ)->cpath->prev);
- } else {
- or_circuit_t *or_circ;
- if (CIRCUIT_IS_ORIGIN(circ)) {
-
- log_warn(LD_BUG,"incoming relay cell at origin circuit. Dropping.");
- assert_circuit_ok(circ);
- return 0;
- }
- or_circ = TO_OR_CIRCUIT(circ);
- chan = or_circ->p_chan;
- relay_set_digest(or_circ->p_digest, cell);
- if (relay_crypt_one_payload(or_circ->p_crypto, cell->payload, 1) < 0)
- return -1;
- }
- ++stats_n_relay_cells_relayed;
- append_cell_to_circuit_queue(circ, chan, cell, cell_direction, on_stream);
- return 0;
- }
- static edge_connection_t *
- relay_lookup_conn(circuit_t *circ, cell_t *cell,
- cell_direction_t cell_direction, crypt_path_t *layer_hint)
- {
- edge_connection_t *tmpconn;
- relay_header_t rh;
- relay_header_unpack(&rh, cell->payload);
- if (!rh.stream_id)
- return NULL;
-
- if (CIRCUIT_IS_ORIGIN(circ)) {
- for (tmpconn = TO_ORIGIN_CIRCUIT(circ)->p_streams; tmpconn;
- tmpconn=tmpconn->next_stream) {
- if (rh.stream_id == tmpconn->stream_id &&
- !tmpconn->base_.marked_for_close &&
- tmpconn->cpath_layer == layer_hint) {
- log_debug(LD_APP,"found conn for stream %d.", rh.stream_id);
- return tmpconn;
- }
- }
- } else {
- for (tmpconn = TO_OR_CIRCUIT(circ)->n_streams; tmpconn;
- tmpconn=tmpconn->next_stream) {
- if (rh.stream_id == tmpconn->stream_id &&
- !tmpconn->base_.marked_for_close) {
- log_debug(LD_EXIT,"found conn for stream %d.", rh.stream_id);
- if (cell_direction == CELL_DIRECTION_OUT ||
- connection_edge_is_rendezvous_stream(tmpconn))
- return tmpconn;
- }
- }
- for (tmpconn = TO_OR_CIRCUIT(circ)->resolving_streams; tmpconn;
- tmpconn=tmpconn->next_stream) {
- if (rh.stream_id == tmpconn->stream_id &&
- !tmpconn->base_.marked_for_close) {
- log_debug(LD_EXIT,"found conn for stream %d.", rh.stream_id);
- return tmpconn;
- }
- }
- }
- return NULL;
- }
- void
- relay_header_pack(uint8_t *dest, const relay_header_t *src)
- {
- set_uint8(dest, src->command);
- set_uint16(dest+1, htons(src->recognized));
- set_uint16(dest+3, htons(src->stream_id));
- memcpy(dest+5, src->integrity, 4);
- set_uint16(dest+9, htons(src->length));
- }
- void
- relay_header_unpack(relay_header_t *dest, const uint8_t *src)
- {
- dest->command = get_uint8(src);
- dest->recognized = ntohs(get_uint16(src+1));
- dest->stream_id = ntohs(get_uint16(src+3));
- memcpy(dest->integrity, src+5, 4);
- dest->length = ntohs(get_uint16(src+9));
- }
- static const char *
- relay_command_to_string(uint8_t command)
- {
- static char buf[64];
- switch (command) {
- case RELAY_COMMAND_BEGIN: return "BEGIN";
- case RELAY_COMMAND_DATA: return "DATA";
- case RELAY_COMMAND_END: return "END";
- case RELAY_COMMAND_CONNECTED: return "CONNECTED";
- case RELAY_COMMAND_SENDME: return "SENDME";
- case RELAY_COMMAND_EXTEND: return "EXTEND";
- case RELAY_COMMAND_EXTENDED: return "EXTENDED";
- case RELAY_COMMAND_TRUNCATE: return "TRUNCATE";
- case RELAY_COMMAND_TRUNCATED: return "TRUNCATED";
- case RELAY_COMMAND_DROP: return "DROP";
- case RELAY_COMMAND_RESOLVE: return "RESOLVE";
- case RELAY_COMMAND_RESOLVED: return "RESOLVED";
- case RELAY_COMMAND_BEGIN_DIR: return "BEGIN_DIR";
- case RELAY_COMMAND_ESTABLISH_INTRO: return "ESTABLISH_INTRO";
- case RELAY_COMMAND_ESTABLISH_RENDEZVOUS: return "ESTABLISH_RENDEZVOUS";
- case RELAY_COMMAND_INTRODUCE1: return "INTRODUCE1";
- case RELAY_COMMAND_INTRODUCE2: return "INTRODUCE2";
- case RELAY_COMMAND_RENDEZVOUS1: return "RENDEZVOUS1";
- case RELAY_COMMAND_RENDEZVOUS2: return "RENDEZVOUS2";
- case RELAY_COMMAND_INTRO_ESTABLISHED: return "INTRO_ESTABLISHED";
- case RELAY_COMMAND_RENDEZVOUS_ESTABLISHED:
- return "RENDEZVOUS_ESTABLISHED";
- case RELAY_COMMAND_INTRODUCE_ACK: return "INTRODUCE_ACK";
- case RELAY_COMMAND_EXTEND2: return "EXTEND2";
- case RELAY_COMMAND_EXTENDED2: return "EXTENDED2";
- default:
- tor_snprintf(buf, sizeof(buf), "Unrecognized relay command %u",
- (unsigned)command);
- return buf;
- }
- }
- int
- relay_send_command_from_edge_(streamid_t stream_id, circuit_t *circ,
- uint8_t relay_command, const char *payload,
- size_t payload_len, crypt_path_t *cpath_layer,
- const char *filename, int lineno)
- {
- cell_t cell;
- relay_header_t rh;
- cell_direction_t cell_direction;
-
- tor_assert(circ);
- tor_assert(payload_len <= RELAY_PAYLOAD_SIZE);
- memset(&cell, 0, sizeof(cell_t));
- cell.command = CELL_RELAY;
- if (cpath_layer) {
- cell.circ_id = circ->n_circ_id;
- cell_direction = CELL_DIRECTION_OUT;
- } else if (! CIRCUIT_IS_ORIGIN(circ)) {
- cell.circ_id = TO_OR_CIRCUIT(circ)->p_circ_id;
- cell_direction = CELL_DIRECTION_IN;
- } else {
- return -1;
- }
- memset(&rh, 0, sizeof(rh));
- rh.command = relay_command;
- rh.stream_id = stream_id;
- rh.length = payload_len;
- relay_header_pack(cell.payload, &rh);
- if (payload_len)
- memcpy(cell.payload+RELAY_HEADER_SIZE, payload, payload_len);
- log_debug(LD_OR,"delivering %d cell %s.", relay_command,
- cell_direction == CELL_DIRECTION_OUT ? "forward" : "backward");
-
- if (relay_command == RELAY_COMMAND_END && circ->dirreq_id)
- geoip_change_dirreq_state(circ->dirreq_id, DIRREQ_TUNNELED,
- DIRREQ_END_CELL_SENT);
- if (cell_direction == CELL_DIRECTION_OUT && circ->n_chan) {
-
- channel_timestamp_client(circ->n_chan);
- }
- if (cell_direction == CELL_DIRECTION_OUT) {
- origin_circuit_t *origin_circ = TO_ORIGIN_CIRCUIT(circ);
- if (origin_circ->remaining_relay_early_cells > 0 &&
- (relay_command == RELAY_COMMAND_EXTEND ||
- relay_command == RELAY_COMMAND_EXTEND2 ||
- cpath_layer != origin_circ->cpath)) {
-
- cell.command = CELL_RELAY_EARLY;
- --origin_circ->remaining_relay_early_cells;
- log_debug(LD_OR, "Sending a RELAY_EARLY cell; %d remaining.",
- (int)origin_circ->remaining_relay_early_cells);
-
- origin_circ->relay_early_commands[
- origin_circ->relay_early_cells_sent++] = relay_command;
- } else if (relay_command == RELAY_COMMAND_EXTEND ||
- relay_command == RELAY_COMMAND_EXTEND2) {
-
- smartlist_t *commands_list = smartlist_new();
- int i = 0;
- char *commands = NULL;
- for (; i < origin_circ->relay_early_cells_sent; i++)
- smartlist_add(commands_list, (char *)
- relay_command_to_string(origin_circ->relay_early_commands[i]));
- commands = smartlist_join_strings(commands_list, ",", 0, NULL);
- log_warn(LD_BUG, "Uh-oh. We're sending a RELAY_COMMAND_EXTEND cell, "
- "but we have run out of RELAY_EARLY cells on that circuit. "
- "Commands sent before: %s", commands);
- tor_free(commands);
- smartlist_free(commands_list);
- }
- }
- if (circuit_package_relay_cell(&cell, circ, cell_direction, cpath_layer,
- stream_id, filename, lineno) < 0) {
- log_warn(LD_BUG,"circuit_package_relay_cell failed. Closing.");
- circuit_mark_for_close(circ, END_CIRC_REASON_INTERNAL);
- return -1;
- }
- return 0;
- }
- int
- connection_edge_send_command(edge_connection_t *fromconn,
- uint8_t relay_command, const char *payload,
- size_t payload_len)
- {
-
- circuit_t *circ;
- crypt_path_t *cpath_layer = fromconn->cpath_layer;
- tor_assert(fromconn);
- circ = fromconn->on_circuit;
- if (fromconn->base_.marked_for_close) {
- log_warn(LD_BUG,
- "called on conn that's already marked for close at %s:%d.",
- fromconn->base_.marked_for_close_file,
- fromconn->base_.marked_for_close);
- return 0;
- }
- if (!circ) {
- if (fromconn->base_.type == CONN_TYPE_AP) {
- log_info(LD_APP,"no circ. Closing conn.");
- connection_mark_unattached_ap(EDGE_TO_ENTRY_CONN(fromconn),
- END_STREAM_REASON_INTERNAL);
- } else {
- log_info(LD_EXIT,"no circ. Closing conn.");
- fromconn->edge_has_sent_end = 1;
- fromconn->end_reason = END_STREAM_REASON_INTERNAL;
- connection_mark_for_close(TO_CONN(fromconn));
- }
- return -1;
- }
- if (circ->marked_for_close) {
-
- return -1;
- }
- return relay_send_command_from_edge(fromconn->stream_id, circ,
- relay_command, payload,
- payload_len, cpath_layer);
- }
- #define MAX_RESOLVE_FAILURES 3
- static int
- edge_reason_is_retriable(int reason)
- {
- return reason == END_STREAM_REASON_HIBERNATING ||
- reason == END_STREAM_REASON_RESOURCELIMIT ||
- reason == END_STREAM_REASON_EXITPOLICY ||
- reason == END_STREAM_REASON_RESOLVEFAILED ||
- reason == END_STREAM_REASON_MISC ||
- reason == END_STREAM_REASON_NOROUTE;
- }
- static int
- connection_ap_process_end_not_open(
- relay_header_t *rh, cell_t *cell, origin_circuit_t *circ,
- entry_connection_t *conn, crypt_path_t *layer_hint)
- {
- node_t *exitrouter;
- int reason = *(cell->payload+RELAY_HEADER_SIZE);
- int control_reason;
- edge_connection_t *edge_conn = ENTRY_TO_EDGE_CONN(conn);
- (void) layer_hint;
- if (rh->length > 0) {
- if (reason == END_STREAM_REASON_TORPROTOCOL ||
- reason == END_STREAM_REASON_DESTROY) {
-
- circ->path_state = PATH_STATE_USE_FAILED;
- return -END_CIRC_REASON_TORPROTOCOL;
- } else if (reason == END_STREAM_REASON_INTERNAL) {
-
- } else {
-
- pathbias_mark_use_success(circ);
- }
- }
- if (rh->length == 0) {
- reason = END_STREAM_REASON_MISC;
- }
- control_reason = reason | END_STREAM_REASON_FLAG_REMOTE;
- if (edge_reason_is_retriable(reason) &&
-
- !connection_edge_is_rendezvous_stream(edge_conn)) {
- const char *chosen_exit_digest =
- circ->build_state->chosen_exit->identity_digest;
- log_info(LD_APP,"Address '%s' refused due to '%s'. Considering retrying.",
- safe_str(conn->socks_request->address),
- stream_end_reason_to_string(reason));
- exitrouter = node_get_mutable_by_id(chosen_exit_digest);
- switch (reason) {
- case END_STREAM_REASON_EXITPOLICY: {
- tor_addr_t addr;
- tor_addr_make_unspec(&addr);
- if (rh->length >= 5) {
- int ttl = -1;
- tor_addr_make_unspec(&addr);
- if (rh->length == 5 || rh->length == 9) {
- tor_addr_from_ipv4n(&addr,
- get_uint32(cell->payload+RELAY_HEADER_SIZE+1));
- if (rh->length == 9)
- ttl = (int)ntohl(get_uint32(cell->payload+RELAY_HEADER_SIZE+5));
- } else if (rh->length == 17 || rh->length == 21) {
- tor_addr_from_ipv6_bytes(&addr,
- (char*)(cell->payload+RELAY_HEADER_SIZE+1));
- if (rh->length == 21)
- ttl = (int)ntohl(get_uint32(cell->payload+RELAY_HEADER_SIZE+17));
- }
- if (tor_addr_is_null(&addr)) {
- log_info(LD_APP,"Address '%s' resolved to 0.0.0.0. Closing,",
- safe_str(conn->socks_request->address));
- connection_mark_unattached_ap(conn, END_STREAM_REASON_TORPROTOCOL);
- return 0;
- }
- if ((tor_addr_family(&addr) == AF_INET &&
- !conn->entry_cfg.ipv4_traffic) ||
- (tor_addr_family(&addr) == AF_INET6 &&
- !conn->entry_cfg.ipv6_traffic)) {
- log_fn(LOG_PROTOCOL_WARN, LD_APP,
- "Got an EXITPOLICY failure on a connection with a "
- "mismatched family. Closing.");
- connection_mark_unattached_ap(conn, END_STREAM_REASON_TORPROTOCOL);
- return 0;
- }
- if (get_options()->ClientDNSRejectInternalAddresses &&
- tor_addr_is_internal(&addr, 0)) {
- log_info(LD_APP,"Address '%s' resolved to internal. Closing,",
- safe_str(conn->socks_request->address));
- connection_mark_unattached_ap(conn, END_STREAM_REASON_TORPROTOCOL);
- return 0;
- }
- client_dns_set_addressmap(conn,
- conn->socks_request->address, &addr,
- conn->chosen_exit_name, ttl);
- {
- char new_addr[TOR_ADDR_BUF_LEN];
- tor_addr_to_str(new_addr, &addr, sizeof(new_addr), 1);
- if (strcmp(conn->socks_request->address, new_addr)) {
- strlcpy(conn->socks_request->address, new_addr,
- sizeof(conn->socks_request->address));
- control_event_stream_status(conn, STREAM_EVENT_REMAP, 0);
- }
- }
- }
-
- adjust_exit_policy_from_exitpolicy_failure(circ,
- conn,
- exitrouter,
- &addr);
- if (conn->chosen_exit_optional ||
- conn->chosen_exit_retries) {
-
- conn->chosen_exit_optional = 0;
-
- conn->chosen_exit_retries = 0;
- tor_free(conn->chosen_exit_name);
- }
- if (connection_ap_detach_retriable(conn, circ, control_reason) >= 0)
- return 0;
-
- break;
- }
- case END_STREAM_REASON_CONNECTREFUSED:
- if (!conn->chosen_exit_optional)
- break;
-
-
- case END_STREAM_REASON_RESOLVEFAILED:
- case END_STREAM_REASON_TIMEOUT:
- case END_STREAM_REASON_MISC:
- case END_STREAM_REASON_NOROUTE:
- if (client_dns_incr_failures(conn->socks_request->address)
- < MAX_RESOLVE_FAILURES) {
-
- circuit_log_path(LOG_INFO,LD_APP,circ);
-
- mark_circuit_unusable_for_new_conns(circ);
- if (conn->chosen_exit_optional) {
-
- conn->chosen_exit_optional = 0;
- tor_free(conn->chosen_exit_name);
- }
- if (connection_ap_detach_retriable(conn, circ, control_reason) >= 0)
- return 0;
-
- } else {
- log_notice(LD_APP,
- "Have tried resolving or connecting to address '%s' "
- "at %d different places. Giving up.",
- safe_str(conn->socks_request->address),
- MAX_RESOLVE_FAILURES);
-
- client_dns_clear_failures(conn->socks_request->address);
- }
- break;
- case END_STREAM_REASON_HIBERNATING:
- case END_STREAM_REASON_RESOURCELIMIT:
- if (exitrouter) {
- policies_set_node_exitpolicy_to_reject_all(exitrouter);
- }
- if (conn->chosen_exit_optional) {
-
- conn->chosen_exit_optional = 0;
- tor_free(conn->chosen_exit_name);
- }
- if (connection_ap_detach_retriable(conn, circ, control_reason) >= 0)
- return 0;
-
- break;
- }
- log_info(LD_APP,"Giving up on retrying; conn can't be handled.");
- }
- log_info(LD_APP,
- "Edge got end (%s) before we're connected. Marking for close.",
- stream_end_reason_to_string(rh->length > 0 ? reason : -1));
- circuit_log_path(LOG_INFO,LD_APP,circ);
-
- if (!ENTRY_TO_CONN(conn)->marked_for_close)
- connection_mark_unattached_ap(conn, control_reason);
- return 0;
- }
- static void
- adjust_exit_policy_from_exitpolicy_failure(origin_circuit_t *circ,
- entry_connection_t *conn,
- node_t *node,
- const tor_addr_t *addr)
- {
- int make_reject_all = 0;
- const sa_family_t family = tor_addr_family(addr);
- if (node) {
- tor_addr_t tmp;
- int asked_for_family = tor_addr_parse(&tmp, conn->socks_request->address);
- if (family == AF_UNSPEC) {
- make_reject_all = 1;
- } else if (node_exit_policy_is_exact(node, family) &&
- asked_for_family != -1 && !conn->chosen_exit_name) {
- make_reject_all = 1;
- }
- if (make_reject_all) {
- log_info(LD_APP,
- "Exitrouter %s seems to be more restrictive than its exit "
- "policy. Not using this router as exit for now.",
- node_describe(node));
- policies_set_node_exitpolicy_to_reject_all(node);
- }
- }
- if (family != AF_UNSPEC)
- addr_policy_append_reject_addr(&circ->prepend_policy, addr);
- }
- static void
- remap_event_helper(entry_connection_t *conn, const tor_addr_t *new_addr)
- {
- tor_addr_to_str(conn->socks_request->address, new_addr,
- sizeof(conn->socks_request->address),
- 1);
- control_event_stream_status(conn, STREAM_EVENT_REMAP,
- REMAP_STREAM_SOURCE_EXIT);
- }
- STATIC int
- connected_cell_parse(const relay_header_t *rh, const cell_t *cell,
- tor_addr_t *addr_out, int *ttl_out)
- {
- uint32_t bytes;
- const uint8_t *payload = cell->payload + RELAY_HEADER_SIZE;
- tor_addr_make_unspec(addr_out);
- *ttl_out = -1;
- if (rh->length == 0)
- return 0;
- if (rh->length < 4)
- return -1;
- bytes = ntohl(get_uint32(payload));
-
- if (bytes != 0) {
-
- tor_addr_from_ipv4h(addr_out, bytes);
- if (rh->length >= 8) {
- bytes = ntohl(get_uint32(payload + 4));
- if (bytes <= INT32_MAX)
- *ttl_out = bytes;
- }
- } else {
- if (rh->length < 25)
- return -1;
- if (get_uint8(payload + 4) != 6)
- return -1;
- tor_addr_from_ipv6_bytes(addr_out, (char*)(payload + 5));
- bytes = ntohl(get_uint32(payload + 21));
- if (bytes <= INT32_MAX)
- *ttl_out = (int) bytes;
- }
- return 0;
- }
- STATIC void
- address_ttl_free(address_ttl_t *addr)
- {
- if (!addr)
- return;
- tor_free(addr->hostname);
- tor_free(addr);
- }
- STATIC int
- resolved_cell_parse(const cell_t *cell, const relay_header_t *rh,
- smartlist_t *addresses_out, int *errcode_out)
- {
- const uint8_t *cp;
- uint8_t answer_type;
- size_t answer_len;
- address_ttl_t *addr;
- size_t remaining;
- int errcode = 0;
- smartlist_t *addrs;
- tor_assert(cell);
- tor_assert(rh);
- tor_assert(addresses_out);
- tor_assert(errcode_out);
- *errcode_out = 0;
- if (rh->length > RELAY_PAYLOAD_SIZE)
- return -1;
- addrs = smartlist_new();
- cp = cell->payload + RELAY_HEADER_SIZE;
- remaining = rh->length;
- while (remaining) {
- const uint8_t *cp_orig = cp;
- if (remaining < 2)
- goto err;
- answer_type = *cp++;
- answer_len = *cp++;
- if (remaining < 2 + answer_len + 4) {
- goto err;
- }
- if (answer_type == RESOLVED_TYPE_IPV4) {
- if (answer_len != 4) {
- goto err;
- }
- addr = tor_malloc_zero(sizeof(*addr));
- tor_addr_from_ipv4n(&addr->addr, get_uint32(cp));
- cp += 4;
- addr->ttl = ntohl(get_uint32(cp));
- cp += 4;
- smartlist_add(addrs, addr);
- } else if (answer_type == RESOLVED_TYPE_IPV6) {
- if (answer_len != 16)
- goto err;
- addr = tor_malloc_zero(sizeof(*addr));
- tor_addr_from_ipv6_bytes(&addr->addr, (const char*) cp);
- cp += 16;
- addr->ttl = ntohl(get_uint32(cp));
- cp += 4;
- smartlist_add(addrs, addr);
- } else if (answer_type == RESOLVED_TYPE_HOSTNAME) {
- if (answer_len == 0) {
- goto err;
- }
- addr = tor_malloc_zero(sizeof(*addr));
- addr->hostname = tor_memdup_nulterm(cp, answer_len);
- cp += answer_len;
- addr->ttl = ntohl(get_uint32(cp));
- cp += 4;
- smartlist_add(addrs, addr);
- } else if (answer_type == RESOLVED_TYPE_ERROR_TRANSIENT ||
- answer_type == RESOLVED_TYPE_ERROR) {
- errcode = answer_type;
-
- cp += answer_len + 4;
- } else {
- cp += answer_len + 4;
- }
- tor_assert(((ssize_t)remaining) >= (cp - cp_orig));
- remaining -= (cp - cp_orig);
- }
- if (errcode && smartlist_len(addrs) == 0) {
-
- *errcode_out = errcode;
- }
- smartlist_add_all(addresses_out, addrs);
- smartlist_free(addrs);
- return 0;
- err:
-
- SMARTLIST_FOREACH(addrs, address_ttl_t *, a, address_ttl_free(a));
- smartlist_free(addrs);
- return -1;
- }
- static void
- connection_ap_handshake_socks_got_resolved_cell(entry_connection_t *conn,
- int error_code,
- smartlist_t *results)
- {
- address_ttl_t *addr_ipv4 = NULL;
- address_ttl_t *addr_ipv6 = NULL;
- address_ttl_t *addr_hostname = NULL;
- address_ttl_t *addr_best = NULL;
-
- if (error_code) {
- tor_assert(error_code == RESOLVED_TYPE_ERROR ||
- error_code == RESOLVED_TYPE_ERROR_TRANSIENT);
- connection_ap_handshake_socks_resolved(conn,
- error_code,0,NULL,-1,-1);
- return;
- }
-
- SMARTLIST_FOREACH_BEGIN(results, address_ttl_t *, addr) {
- if (addr->hostname) {
- if (!addr_hostname) {
- addr_hostname = addr;
- }
- } else if (tor_addr_family(&addr->addr) == AF_INET) {
- if (!addr_ipv4 && conn->entry_cfg.ipv4_traffic) {
- addr_ipv4 = addr;
- }
- } else if (tor_addr_family(&addr->addr) == AF_INET6) {
- if (!addr_ipv6 && conn->entry_cfg.ipv6_traffic) {
- addr_ipv6 = addr;
- }
- }
- } SMARTLIST_FOREACH_END(addr);
-
- if (conn->socks_request->command == SOCKS_COMMAND_RESOLVE_PTR) {
- if (addr_hostname) {
- connection_ap_handshake_socks_resolved(conn,
- RESOLVED_TYPE_HOSTNAME,
- strlen(addr_hostname->hostname),
- (uint8_t*)addr_hostname->hostname,
- addr_hostname->ttl,-1);
- } else {
- connection_ap_handshake_socks_resolved(conn,
- RESOLVED_TYPE_ERROR,0,NULL,-1,-1);
- }
- return;
- }
- if (conn->entry_cfg.prefer_ipv6) {
- addr_best = addr_ipv6 ? addr_ipv6 : addr_ipv4;
- } else {
- addr_best = addr_ipv4 ? addr_ipv4 : addr_ipv6;
- }
-
- if (! addr_best) {
- connection_ap_handshake_socks_resolved(conn,
- RESOLVED_TYPE_ERROR,0,NULL,-1,-1);
- return;
- }
- connection_ap_handshake_socks_resolved_addr(conn,
- &addr_best->addr,
- addr_best->ttl,
- -1);
- remap_event_helper(conn, &addr_best->addr);
- }
- STATIC int
- connection_edge_process_resolved_cell(edge_connection_t *conn,
- const cell_t *cell,
- const relay_header_t *rh)
- {
- entry_connection_t *entry_conn = EDGE_TO_ENTRY_CONN(conn);
- smartlist_t *resolved_addresses = NULL;
- int errcode = 0;
- if (conn->base_.state != AP_CONN_STATE_RESOLVE_WAIT) {
- log_fn(LOG_PROTOCOL_WARN, LD_APP, "Got a 'resolved' cell while "
- "not in state resolve_wait. Dropping.");
- return 0;
- }
- tor_assert(SOCKS_COMMAND_IS_RESOLVE(entry_conn->socks_request->command));
- resolved_addresses = smartlist_new();
- if (resolved_cell_parse(cell, rh, resolved_addresses, &errcode)) {
- log_fn(LOG_PROTOCOL_WARN, LD_PROTOCOL,
- "Dropping malformed 'resolved' cell");
- connection_mark_unattached_ap(entry_conn, END_STREAM_REASON_TORPROTOCOL);
- goto done;
- }
- if (get_options()->ClientDNSRejectInternalAddresses) {
- int orig_len = smartlist_len(resolved_addresses);
- SMARTLIST_FOREACH_BEGIN(resolved_addresses, address_ttl_t *, addr) {
- if (addr->hostname == NULL && tor_addr_is_internal(&addr->addr, 0)) {
- log_info(LD_APP, "Got a resolved cell with answer %s; dropping that "
- "answer.",
- safe_str_client(fmt_addr(&addr->addr)));
- address_ttl_free(addr);
- SMARTLIST_DEL_CURRENT(resolved_addresses, addr);
- }
- } SMARTLIST_FOREACH_END(addr);
- if (orig_len && smartlist_len(resolved_addresses) == 0) {
- log_info(LD_APP, "Got a resolved cell with only private addresses; "
- "dropping it.");
- connection_ap_handshake_socks_resolved(entry_conn,
- RESOLVED_TYPE_ERROR_TRANSIENT,
- 0, NULL, 0, TIME_MAX);
- connection_mark_unattached_ap(entry_conn,
- END_STREAM_REASON_TORPROTOCOL);
- goto done;
- }
- }
- connection_ap_handshake_socks_got_resolved_cell(entry_conn,
- errcode,
- resolved_addresses);
- connection_mark_unattached_ap(entry_conn,
- END_STREAM_REASON_DONE |
- END_STREAM_REASON_FLAG_ALREADY_SOCKS_REPLIED);
- done:
- SMARTLIST_FOREACH(resolved_addresses, address_ttl_t *, addr,
- address_ttl_free(addr));
- smartlist_free(resolved_addresses);
- return 0;
- }
- static int
- connection_edge_process_relay_cell_not_open(
- relay_header_t *rh, cell_t *cell, circuit_t *circ,
- edge_connection_t *conn, crypt_path_t *layer_hint)
- {
- if (rh->command == RELAY_COMMAND_END) {
- if (CIRCUIT_IS_ORIGIN(circ) && conn->base_.type == CONN_TYPE_AP) {
- return connection_ap_process_end_not_open(rh, cell,
- TO_ORIGIN_CIRCUIT(circ),
- EDGE_TO_ENTRY_CONN(conn),
- layer_hint);
- } else {
-
- conn->edge_has_sent_end = 1;
- conn->end_reason = *(cell->payload+RELAY_HEADER_SIZE) |
- END_STREAM_REASON_FLAG_REMOTE;
- connection_mark_for_close(TO_CONN(conn));
- return 0;
- }
- }
- if (conn->base_.type == CONN_TYPE_AP &&
- rh->command == RELAY_COMMAND_CONNECTED) {
- tor_addr_t addr;
- int ttl;
- entry_connection_t *entry_conn = EDGE_TO_ENTRY_CONN(conn);
- tor_assert(CIRCUIT_IS_ORIGIN(circ));
- if (conn->base_.state != AP_CONN_STATE_CONNECT_WAIT) {
- log_fn(LOG_PROTOCOL_WARN, LD_APP,
- "Got 'connected' while not in state connect_wait. Dropping.");
- return 0;
- }
- CONNECTION_AP_EXPECT_NONPENDING(entry_conn);
- conn->base_.state = AP_CONN_STATE_OPEN;
- log_info(LD_APP,"'connected' received for circid %u streamid %d "
- "after %d seconds.",
- (unsigned)circ->n_circ_id,
- rh->stream_id,
- (int)(time(NULL) - conn->base_.timestamp_lastread));
- if (connected_cell_parse(rh, cell, &addr, &ttl) < 0) {
- log_fn(LOG_PROTOCOL_WARN, LD_APP,
- "Got a badly formatted connected cell. Closing.");
- connection_edge_end(conn, END_STREAM_REASON_TORPROTOCOL);
- connection_mark_unattached_ap(entry_conn, END_STREAM_REASON_TORPROTOCOL);
- }
- if (tor_addr_family(&addr) != AF_UNSPEC) {
- const sa_family_t family = tor_addr_family(&addr);
- if (tor_addr_is_null(&addr) ||
- (get_options()->ClientDNSRejectInternalAddresses &&
- tor_addr_is_internal(&addr, 0))) {
- log_info(LD_APP, "...but it claims the IP address was %s. Closing.",
- fmt_addr(&addr));
- connection_edge_end(conn, END_STREAM_REASON_TORPROTOCOL);
- connection_mark_unattached_ap(entry_conn,
- END_STREAM_REASON_TORPROTOCOL);
- return 0;
- }
- if ((family == AF_INET && ! entry_conn->entry_cfg.ipv4_traffic) ||
- (family == AF_INET6 && ! entry_conn->entry_cfg.ipv6_traffic)) {
- log_fn(LOG_PROTOCOL_WARN, LD_APP,
- "Got a connected cell to %s with unsupported address family."
- " Closing.", fmt_addr(&addr));
- connection_edge_end(conn, END_STREAM_REASON_TORPROTOCOL);
- connection_mark_unattached_ap(entry_conn,
- END_STREAM_REASON_TORPROTOCOL);
- return 0;
- }
- client_dns_set_addressmap(entry_conn,
- entry_conn->socks_request->address, &addr,
- entry_conn->chosen_exit_name, ttl);
- remap_event_helper(entry_conn, &addr);
- }
- circuit_log_path(LOG_INFO,LD_APP,TO_ORIGIN_CIRCUIT(circ));
-
- tor_assert(entry_conn->socks_request != NULL);
- if (!entry_conn->socks_request->has_finished)
- connection_ap_handshake_socks_reply(entry_conn, NULL, 0, 0);
-
- log_debug(LD_APP, "considering");
- if (TO_CONN(conn)->linked_conn &&
- TO_CONN(conn)->linked_conn->type == CONN_TYPE_DIR) {
- connection_t *dirconn = TO_CONN(conn)->linked_conn;
- log_debug(LD_APP, "it is! %d", dirconn->purpose);
- switch (dirconn->purpose) {
- case DIR_PURPOSE_FETCH_CERTIFICATE:
- if (consensus_is_waiting_for_certs())
- control_event_bootstrap(BOOTSTRAP_STATUS_LOADING_KEYS, 0);
- break;
- case DIR_PURPOSE_FETCH_CONSENSUS:
- control_event_bootstrap(BOOTSTRAP_STATUS_LOADING_STATUS, 0);
- break;
- case DIR_PURPOSE_FETCH_SERVERDESC:
- case DIR_PURPOSE_FETCH_MICRODESC:
- if (TO_DIR_CONN(dirconn)->router_purpose == ROUTER_PURPOSE_GENERAL)
- control_event_bootstrap(BOOTSTRAP_STATUS_LOADING_DESCRIPTORS,
- count_loading_descriptors_progress());
- break;
- }
- }
-
- if (entry_conn->pending_optimistic_data) {
- buf_free(entry_conn->pending_optimistic_data);
- entry_conn->pending_optimistic_data = NULL;
- }
-
- if (connection_edge_package_raw_inbuf(conn, 1, NULL) < 0) {
-
- connection_mark_for_close(TO_CONN(conn));
- return 0;
- }
- return 0;
- }
- if (conn->base_.type == CONN_TYPE_AP &&
- rh->command == RELAY_COMMAND_RESOLVED) {
- return connection_edge_process_resolved_cell(conn, cell, rh);
- }
- log_fn(LOG_PROTOCOL_WARN, LD_PROTOCOL,
- "Got an unexpected relay command %d, in state %d (%s). Dropping.",
- rh->command, conn->base_.state,
- conn_state_to_string(conn->base_.type, conn->base_.state));
- return 0;
- }
- static int
- connection_edge_process_relay_cell(cell_t *cell, circuit_t *circ,
- edge_connection_t *conn,
- crypt_path_t *layer_hint)
- {
- static int num_seen=0;
- relay_header_t rh;
- unsigned domain = layer_hint?LD_APP:LD_EXIT;
- int reason;
- int optimistic_data = 0;
- tor_assert(cell);
- tor_assert(circ);
- relay_header_unpack(&rh, cell->payload);
- num_seen++;
- log_debug(domain, "Now seen %d relay cells here (command %d, stream %d).",
- num_seen, rh.command, rh.stream_id);
- if (rh.length > RELAY_PAYLOAD_SIZE) {
- log_fn(LOG_PROTOCOL_WARN, LD_PROTOCOL,
- "Relay cell length field too long. Closing circuit.");
- return - END_CIRC_REASON_TORPROTOCOL;
- }
- if (rh.stream_id == 0) {
- switch (rh.command) {
- case RELAY_COMMAND_BEGIN:
- case RELAY_COMMAND_CONNECTED:
- case RELAY_COMMAND_END:
- case RELAY_COMMAND_RESOLVE:
- case RELAY_COMMAND_RESOLVED:
- case RELAY_COMMAND_BEGIN_DIR:
- log_fn(LOG_PROTOCOL_WARN, LD_PROTOCOL, "Relay command %d with zero "
- "stream_id. Dropping.", (int)rh.command);
- return 0;
- default:
- ;
- }
- }
-
- if (conn && !connection_state_is_open(TO_CONN(conn))) {
- if (conn->base_.type == CONN_TYPE_EXIT &&
- (conn->base_.state == EXIT_CONN_STATE_CONNECTING ||
- conn->base_.state == EXIT_CONN_STATE_RESOLVING) &&
- rh.command == RELAY_COMMAND_DATA) {
-
- optimistic_data = 1;
- } else if (rh.stream_id == 0 && rh.command == RELAY_COMMAND_DATA) {
- log_warn(LD_BUG, "Somehow I had a connection that matched a "
- "data cell with stream ID 0.");
- } else {
- return connection_edge_process_relay_cell_not_open(
- &rh, cell, circ, conn, layer_hint);
- }
- }
- switch (rh.command) {
- case RELAY_COMMAND_DROP:
- return 0;
- case RELAY_COMMAND_BEGIN:
- case RELAY_COMMAND_BEGIN_DIR:
- if (layer_hint &&
- circ->purpose != CIRCUIT_PURPOSE_S_REND_JOINED) {
- log_fn(LOG_PROTOCOL_WARN, LD_APP,
- "Relay begin request unsupported at AP. Dropping.");
- return 0;
- }
- if (circ->purpose == CIRCUIT_PURPOSE_S_REND_JOINED &&
- layer_hint != TO_ORIGIN_CIRCUIT(circ)->cpath->prev) {
- log_fn(LOG_PROTOCOL_WARN, LD_APP,
- "Relay begin request to Hidden Service "
- "from intermediary node. Dropping.");
- return 0;
- }
- if (conn) {
- log_fn(LOG_PROTOCOL_WARN, domain,
- "Begin cell for known stream. Dropping.");
- return 0;
- }
- if (rh.command == RELAY_COMMAND_BEGIN_DIR &&
- circ->purpose != CIRCUIT_PURPOSE_S_REND_JOINED) {
-
- static uint64_t next_id = 0;
- circ->dirreq_id = ++next_id;
- TO_OR_CIRCUIT(circ)->p_chan->dirreq_id = circ->dirreq_id;
- }
- return connection_exit_begin_conn(cell, circ);
- case RELAY_COMMAND_DATA:
- ++stats_n_data_cells_received;
- if (( layer_hint && --layer_hint->deliver_window < 0) ||
- (!layer_hint && --circ->deliver_window < 0)) {
- log_fn(LOG_PROTOCOL_WARN, LD_PROTOCOL,
- "(relay data) circ deliver_window below 0. Killing.");
- if (conn) {
-
- connection_edge_end(conn, END_STREAM_REASON_TORPROTOCOL);
- connection_mark_for_close(TO_CONN(conn));
- }
- return -END_CIRC_REASON_TORPROTOCOL;
- }
- log_debug(domain,"circ deliver_window now %d.", layer_hint ?
- layer_hint->deliver_window : circ->deliver_window);
- circuit_consider_sending_sendme(circ, layer_hint);
- if (rh.stream_id == 0) {
- log_fn(LOG_PROTOCOL_WARN, LD_PROTOCOL, "Relay data cell with zero "
- "stream_id. Dropping.");
- return 0;
- } else if (!conn) {
- log_info(domain,"data cell dropped, unknown stream (streamid %d).",
- rh.stream_id);
- return 0;
- }
- if (--conn->deliver_window < 0) {
- log_fn(LOG_PROTOCOL_WARN, LD_PROTOCOL,
- "(relay data) conn deliver_window below 0. Killing.");
- return -END_CIRC_REASON_TORPROTOCOL;
- }
- stats_n_data_bytes_received += rh.length;
- connection_write_to_buf((char*)(cell->payload + RELAY_HEADER_SIZE),
- rh.length, TO_CONN(conn));
- if (!optimistic_data) {
-
- connection_edge_consider_sending_sendme(conn);
- }
- return 0;
- case RELAY_COMMAND_END:
- reason = rh.length > 0 ?
- get_uint8(cell->payload+RELAY_HEADER_SIZE) : END_STREAM_REASON_MISC;
- if (!conn) {
- log_info(domain,"end cell (%s) dropped, unknown stream.",
- stream_end_reason_to_string(reason));
- return 0;
- }
- log_info(domain,TOR_SOCKET_T_FORMAT": end cell (%s) for stream %d. "
- "Removing stream.",
- conn->base_.s,
- stream_end_reason_to_string(reason),
- conn->stream_id);
- if (conn->base_.type == CONN_TYPE_AP) {
- entry_connection_t *entry_conn = EDGE_TO_ENTRY_CONN(conn);
- if (entry_conn->socks_request &&
- !entry_conn->socks_request->has_finished)
- log_warn(LD_BUG,
- "open stream hasn't sent socks answer yet? Closing.");
- }
-
- conn->edge_has_sent_end = 1;
- if (!conn->end_reason)
- conn->end_reason = reason | END_STREAM_REASON_FLAG_REMOTE;
- if (!conn->base_.marked_for_close) {
-
- connection_mark_and_flush(TO_CONN(conn));
- }
- return 0;
- case RELAY_COMMAND_EXTEND:
- case RELAY_COMMAND_EXTEND2: {
- static uint64_t total_n_extend=0, total_nonearly=0;
- total_n_extend++;
- if (rh.stream_id) {
- log_fn(LOG_PROTOCOL_WARN, domain,
- "'extend' cell received for non-zero stream. Dropping.");
- return 0;
- }
- if (cell->command != CELL_RELAY_EARLY &&
- !networkstatus_get_param(NULL,"AllowNonearlyExtend",0,0,1)) {
- #define EARLY_WARNING_INTERVAL 3600
- static ratelim_t early_warning_limit =
- RATELIM_INIT(EARLY_WARNING_INTERVAL);
- char *m;
- if (cell->command == CELL_RELAY) {
- ++total_nonearly;
- if ((m = rate_limit_log(&early_warning_limit, approx_time()))) {
- double percentage = ((double)total_nonearly)/total_n_extend;
- percentage *= 100;
- log_fn(LOG_PROTOCOL_WARN, domain, "EXTEND cell received, "
- "but not via RELAY_EARLY. Dropping.%s", m);
- log_fn(LOG_PROTOCOL_WARN, domain, " (We have dropped %.02f%% of "
- "all EXTEND cells for this reason)", percentage);
- tor_free(m);
- }
- } else {
- log_fn(LOG_WARN, domain,
- "EXTEND cell received, in a cell with type %d! Dropping.",
- cell->command);
- }
- return 0;
- }
- return circuit_extend(cell, circ);
- }
- case RELAY_COMMAND_EXTENDED:
- case RELAY_COMMAND_EXTENDED2:
- if (!layer_hint) {
- log_fn(LOG_PROTOCOL_WARN, LD_PROTOCOL,
- "'extended' unsupported at non-origin. Dropping.");
- return 0;
- }
- log_debug(domain,"Got an extended cell! Yay.");
- {
- extended_cell_t extended_cell;
- if (extended_cell_parse(&extended_cell, rh.command,
- (const uint8_t*)cell->payload+RELAY_HEADER_SIZE,
- rh.length)<0) {
- log_warn(LD_PROTOCOL,
- "Can't parse EXTENDED cell; killing circuit.");
- return -END_CIRC_REASON_TORPROTOCOL;
- }
- if ((reason = circuit_finish_handshake(TO_ORIGIN_CIRCUIT(circ),
- &extended_cell.created_cell)) < 0) {
- circuit_mark_for_close(circ, -reason);
- return 0;
- }
- }
- if ((reason=circuit_send_next_onion_skin(TO_ORIGIN_CIRCUIT(circ)))<0) {
- log_info(domain,"circuit_send_next_onion_skin() failed.");
- return reason;
- }
- return 0;
- case RELAY_COMMAND_TRUNCATE:
- if (layer_hint) {
- log_fn(LOG_PROTOCOL_WARN, LD_APP,
- "'truncate' unsupported at origin. Dropping.");
- return 0;
- }
- if (circ->n_hop) {
- if (circ->n_chan)
- log_warn(LD_BUG, "n_chan and n_hop set on the same circuit!");
- extend_info_free(circ->n_hop);
- circ->n_hop = NULL;
- tor_free(circ->n_chan_create_cell);
- circuit_set_state(circ, CIRCUIT_STATE_OPEN);
- }
- if (circ->n_chan) {
- uint8_t trunc_reason = get_uint8(cell->payload + RELAY_HEADER_SIZE);
- circuit_clear_cell_queue(circ, circ->n_chan);
- channel_send_destroy(circ->n_circ_id, circ->n_chan,
- trunc_reason);
- circuit_set_n_circid_chan(circ, 0, NULL);
- }
- log_debug(LD_EXIT, "Processed 'truncate', replying.");
- {
- char payload[1];
- payload[0] = (char)END_CIRC_REASON_REQUESTED;
- relay_send_command_from_edge(0, circ, RELAY_COMMAND_TRUNCATED,
- payload, sizeof(payload), NULL);
- }
- return 0;
- case RELAY_COMMAND_TRUNCATED:
- if (!layer_hint) {
- log_fn(LOG_PROTOCOL_WARN, LD_EXIT,
- "'truncated' unsupported at non-origin. Dropping.");
- return 0;
- }
- circuit_truncated(TO_ORIGIN_CIRCUIT(circ), layer_hint,
- get_uint8(cell->payload + RELAY_HEADER_SIZE));
- return 0;
- case RELAY_COMMAND_CONNECTED:
- if (conn) {
- log_fn(LOG_PROTOCOL_WARN, LD_PROTOCOL,
- "'connected' unsupported while open. Closing circ.");
- return -END_CIRC_REASON_TORPROTOCOL;
- }
- log_info(domain,
- "'connected' received on circid %u for streamid %d, "
- "no conn attached anymore. Ignoring.",
- (unsigned)circ->n_circ_id, rh.stream_id);
- return 0;
- case RELAY_COMMAND_SENDME:
- if (!rh.stream_id) {
- if (layer_hint) {
- if (layer_hint->package_window + CIRCWINDOW_INCREMENT >
- CIRCWINDOW_START_MAX) {
- static struct ratelim_t exit_warn_ratelim = RATELIM_INIT(600);
- log_fn_ratelim(&exit_warn_ratelim, LOG_WARN, LD_PROTOCOL,
- "Unexpected sendme cell from exit relay. "
- "Closing circ.");
- return -END_CIRC_REASON_TORPROTOCOL;
- }
- layer_hint->package_window += CIRCWINDOW_INCREMENT;
- log_debug(LD_APP,"circ-level sendme at origin, packagewindow %d.",
- layer_hint->package_window);
- circuit_resume_edge_reading(circ, layer_hint);
- } else {
- if (circ->package_window + CIRCWINDOW_INCREMENT >
- CIRCWINDOW_START_MAX) {
- static struct ratelim_t client_warn_ratelim = RATELIM_INIT(600);
- log_fn_ratelim(&client_warn_ratelim,LOG_PROTOCOL_WARN, LD_PROTOCOL,
- "Unexpected sendme cell from client. "
- "Closing circ (window %d).",
- circ->package_window);
- return -END_CIRC_REASON_TORPROTOCOL;
- }
- circ->package_window += CIRCWINDOW_INCREMENT;
- log_debug(LD_APP,
- "circ-level sendme at non-origin, packagewindow %d.",
- circ->package_window);
- circuit_resume_edge_reading(circ, layer_hint);
- }
- return 0;
- }
- if (!conn) {
- log_info(domain,"sendme cell dropped, unknown stream (streamid %d).",
- rh.stream_id);
- return 0;
- }
- conn->package_window += STREAMWINDOW_INCREMENT;
- log_debug(domain,"stream-level sendme, packagewindow now %d.",
- conn->package_window);
- if (circuit_queue_streams_are_blocked(circ)) {
-
- return 0;
- }
- connection_start_reading(TO_CONN(conn));
-
- if (connection_edge_package_raw_inbuf(conn, 1, NULL) < 0) {
-
- connection_mark_for_close(TO_CONN(conn));
- return 0;
- }
- return 0;
- case RELAY_COMMAND_RESOLVE:
- if (layer_hint) {
- log_fn(LOG_PROTOCOL_WARN, LD_APP,
- "resolve request unsupported at AP; dropping.");
- return 0;
- } else if (conn) {
- log_fn(LOG_PROTOCOL_WARN, domain,
- "resolve request for known stream; dropping.");
- return 0;
- } else if (circ->purpose != CIRCUIT_PURPOSE_OR) {
- log_fn(LOG_PROTOCOL_WARN, domain,
- "resolve request on circ with purpose %d; dropping",
- circ->purpose);
- return 0;
- }
- connection_exit_begin_resolve(cell, TO_OR_CIRCUIT(circ));
- return 0;
- case RELAY_COMMAND_RESOLVED:
- if (conn) {
- log_fn(LOG_PROTOCOL_WARN, domain,
- "'resolved' unsupported while open. Closing circ.");
- return -END_CIRC_REASON_TORPROTOCOL;
- }
- log_info(domain,
- "'resolved' received, no conn attached anymore. Ignoring.");
- return 0;
- case RELAY_COMMAND_ESTABLISH_INTRO:
- case RELAY_COMMAND_ESTABLISH_RENDEZVOUS:
- case RELAY_COMMAND_INTRODUCE1:
- case RELAY_COMMAND_INTRODUCE2:
- case RELAY_COMMAND_INTRODUCE_ACK:
- case RELAY_COMMAND_RENDEZVOUS1:
- case RELAY_COMMAND_RENDEZVOUS2:
- case RELAY_COMMAND_INTRO_ESTABLISHED:
- case RELAY_COMMAND_RENDEZVOUS_ESTABLISHED:
- rend_process_relay_cell(circ, layer_hint,
- rh.command, rh.length,
- cell->payload+RELAY_HEADER_SIZE);
- return 0;
- }
- log_fn(LOG_PROTOCOL_WARN, LD_PROTOCOL,
- "Received unknown relay command %d. Perhaps the other side is using "
- "a newer version of Tor? Dropping.",
- rh.command);
- return 0;
- }
- uint64_t stats_n_data_cells_packaged = 0;
- uint64_t stats_n_data_bytes_packaged = 0;
- uint64_t stats_n_data_cells_received = 0;
- uint64_t stats_n_data_bytes_received = 0;
- int
- connection_edge_package_raw_inbuf(edge_connection_t *conn, int package_partial,
- int *max_cells)
- {
- size_t bytes_to_process, length;
- char payload[CELL_PAYLOAD_SIZE];
- circuit_t *circ;
- const unsigned domain = conn->base_.type == CONN_TYPE_AP ? LD_APP : LD_EXIT;
- int sending_from_optimistic = 0;
- entry_connection_t *entry_conn =
- conn->base_.type == CONN_TYPE_AP ? EDGE_TO_ENTRY_CONN(conn) : NULL;
- const int sending_optimistically =
- entry_conn &&
- conn->base_.type == CONN_TYPE_AP &&
- conn->base_.state != AP_CONN_STATE_OPEN;
- crypt_path_t *cpath_layer = conn->cpath_layer;
- tor_assert(conn);
- if (conn->base_.marked_for_close) {
- log_warn(LD_BUG,
- "called on conn that's already marked for close at %s:%d.",
- conn->base_.marked_for_close_file, conn->base_.marked_for_close);
- return 0;
- }
- if (max_cells && *max_cells <= 0)
- return 0;
- repeat_connection_edge_package_raw_inbuf:
- circ = circuit_get_by_edge_conn(conn);
- if (!circ) {
- log_info(domain,"conn has no circuit! Closing.");
- conn->end_reason = END_STREAM_REASON_CANT_ATTACH;
- return -1;
- }
- if (circuit_consider_stop_edge_reading(circ, cpath_layer))
- return 0;
- if (conn->package_window <= 0) {
- log_info(domain,"called with package_window %d. Skipping.",
- conn->package_window);
- connection_stop_reading(TO_CONN(conn));
- return 0;
- }
- sending_from_optimistic = entry_conn &&
- entry_conn->sending_optimistic_data != NULL;
- if (PREDICT_UNLIKELY(sending_from_optimistic)) {
- bytes_to_process = buf_datalen(entry_conn->sending_optimistic_data);
- if (PREDICT_UNLIKELY(!bytes_to_process)) {
- log_warn(LD_BUG, "sending_optimistic_data was non-NULL but empty");
- bytes_to_process = connection_get_inbuf_len(TO_CONN(conn));
- sending_from_optimistic = 0;
- }
- } else {
- bytes_to_process = connection_get_inbuf_len(TO_CONN(conn));
- }
- if (!bytes_to_process)
- return 0;
- if (!package_partial && bytes_to_process < RELAY_PAYLOAD_SIZE)
- return 0;
- if (bytes_to_process > RELAY_PAYLOAD_SIZE) {
- length = RELAY_PAYLOAD_SIZE;
- } else {
- length = bytes_to_process;
- }
- stats_n_data_bytes_packaged += length;
- stats_n_data_cells_packaged += 1;
- if (PREDICT_UNLIKELY(sending_from_optimistic)) {
-
- fetch_from_buf(payload, length, entry_conn->sending_optimistic_data);
- if (!buf_datalen(entry_conn->sending_optimistic_data)) {
- buf_free(entry_conn->sending_optimistic_data);
- entry_conn->sending_optimistic_data = NULL;
- }
- } else {
- connection_fetch_from_buf(payload, length, TO_CONN(conn));
- }
- log_debug(domain,TOR_SOCKET_T_FORMAT": Packaging %d bytes (%d waiting).",
- conn->base_.s,
- (int)length, (int)connection_get_inbuf_len(TO_CONN(conn)));
- if (sending_optimistically && !sending_from_optimistic) {
-
- if (!entry_conn->pending_optimistic_data)
- entry_conn->pending_optimistic_data = buf_new();
- write_to_buf(payload, length, entry_conn->pending_optimistic_data);
- }
- if (connection_edge_send_command(conn, RELAY_COMMAND_DATA,
- payload, length) < 0 )
-
- return 0;
- if (!cpath_layer) {
- tor_assert(circ->package_window > 0);
- circ->package_window--;
- } else {
- tor_assert(cpath_layer->package_window > 0);
- cpath_layer->package_window--;
- }
- if (--conn->package_window <= 0) {
- connection_stop_reading(TO_CONN(conn));
- log_debug(domain,"conn->package_window reached 0.");
- circuit_consider_stop_edge_reading(circ, cpath_layer);
- return 0;
- }
- log_debug(domain,"conn->package_window is now %d",conn->package_window);
- if (max_cells) {
- *max_cells -= 1;
- if (*max_cells <= 0)
- return 0;
- }
-
- goto repeat_connection_edge_package_raw_inbuf;
- }
- void
- connection_edge_consider_sending_sendme(edge_connection_t *conn)
- {
- circuit_t *circ;
- if (connection_outbuf_too_full(TO_CONN(conn)))
- return;
- circ = circuit_get_by_edge_conn(conn);
- if (!circ) {
-
- log_info(LD_APP,"No circuit associated with conn. Skipping.");
- return;
- }
- while (conn->deliver_window <= STREAMWINDOW_START - STREAMWINDOW_INCREMENT) {
- log_debug(conn->base_.type == CONN_TYPE_AP ?LD_APP:LD_EXIT,
- "Outbuf %d, Queuing stream sendme.",
- (int)conn->base_.outbuf_flushlen);
- conn->deliver_window += STREAMWINDOW_INCREMENT;
- if (connection_edge_send_command(conn, RELAY_COMMAND_SENDME,
- NULL, 0) < 0) {
- log_warn(LD_APP,"connection_edge_send_command failed. Skipping.");
- return;
- }
- }
- }
- static void
- circuit_resume_edge_reading(circuit_t *circ, crypt_path_t *layer_hint)
- {
- if (circuit_queue_streams_are_blocked(circ)) {
- log_debug(layer_hint?LD_APP:LD_EXIT,"Too big queue, no resuming");
- return;
- }
- log_debug(layer_hint?LD_APP:LD_EXIT,"resuming");
- if (CIRCUIT_IS_ORIGIN(circ))
- circuit_resume_edge_reading_helper(TO_ORIGIN_CIRCUIT(circ)->p_streams,
- circ, layer_hint);
- else
- circuit_resume_edge_reading_helper(TO_OR_CIRCUIT(circ)->n_streams,
- circ, layer_hint);
- }
- void
- stream_choice_seed_weak_rng(void)
- {
- crypto_seed_weak_rng(&stream_choice_rng);
- }
- static int
- circuit_resume_edge_reading_helper(edge_connection_t *first_conn,
- circuit_t *circ,
- crypt_path_t *layer_hint)
- {
- edge_connection_t *conn;
- int n_packaging_streams, n_streams_left;
- int packaged_this_round;
- int cells_on_queue;
- int cells_per_conn;
- edge_connection_t *chosen_stream = NULL;
- int max_to_package;
- if (first_conn == NULL) {
-
- return 0;
- }
-
- max_to_package = circ->package_window;
- if (CIRCUIT_IS_ORIGIN(circ)) {
- cells_on_queue = circ->n_chan_cells.n;
- } else {
- or_circuit_t *or_circ = TO_OR_CIRCUIT(circ);
- cells_on_queue = or_circ->p_chan_cells.n;
- }
- if (CELL_QUEUE_HIGHWATER_SIZE - cells_on_queue < max_to_package)
- max_to_package = CELL_QUEUE_HIGHWATER_SIZE - cells_on_queue;
-
-
- {
- int num_streams = 0;
- for (conn = first_conn; conn; conn = conn->next_stream) {
- num_streams++;
- if (tor_weak_random_one_in_n(&stream_choice_rng, num_streams)) {
- chosen_stream = conn;
- }
-
- }
- }
-
- n_packaging_streams = 0;
-
- for (conn=chosen_stream; conn; conn = conn->next_stream) {
-
- if (conn->base_.marked_for_close || conn->package_window <= 0)
- continue;
- if (!layer_hint || conn->cpath_layer == layer_hint) {
- connection_start_reading(TO_CONN(conn));
- if (connection_get_inbuf_len(TO_CONN(conn)) > 0)
- ++n_packaging_streams;
- }
- }
-
- for (conn = first_conn; conn != chosen_stream; conn = conn->next_stream) {
- if (conn->base_.marked_for_close || conn->package_window <= 0)
- continue;
- if (!layer_hint || conn->cpath_layer == layer_hint) {
- connection_start_reading(TO_CONN(conn));
- if (connection_get_inbuf_len(TO_CONN(conn)) > 0)
- ++n_packaging_streams;
- }
- }
- if (n_packaging_streams == 0)
- return 0;
- again:
- cells_per_conn = CEIL_DIV(max_to_package, n_packaging_streams);
- packaged_this_round = 0;
- n_streams_left = 0;
-
- for (conn=first_conn; conn; conn=conn->next_stream) {
- if (conn->base_.marked_for_close || conn->package_window <= 0)
- continue;
- if (!layer_hint || conn->cpath_layer == layer_hint) {
- int n = cells_per_conn, r;
-
- r = connection_edge_package_raw_inbuf(conn, 1, &n);
-
- packaged_this_round += (cells_per_conn-n);
- if (r<0) {
-
- connection_mark_for_close(TO_CONN(conn));
- continue;
- }
-
- if (connection_get_inbuf_len(TO_CONN(conn)))
- ++n_streams_left;
-
- if (circuit_consider_stop_edge_reading(circ, layer_hint))
- return -1;
-
- }
- }
-
- if (packaged_this_round && packaged_this_round < max_to_package &&
- n_streams_left) {
- max_to_package -= packaged_this_round;
- n_packaging_streams = n_streams_left;
- goto again;
- }
- return 0;
- }
- static int
- circuit_consider_stop_edge_reading(circuit_t *circ, crypt_path_t *layer_hint)
- {
- edge_connection_t *conn = NULL;
- unsigned domain = layer_hint ? LD_APP : LD_EXIT;
- if (!layer_hint) {
- or_circuit_t *or_circ = TO_OR_CIRCUIT(circ);
- log_debug(domain,"considering circ->package_window %d",
- circ->package_window);
- if (circ->package_window <= 0) {
- log_debug(domain,"yes, not-at-origin. stopped.");
- for (conn = or_circ->n_streams; conn; conn=conn->next_stream)
- connection_stop_reading(TO_CONN(conn));
- return 1;
- }
- return 0;
- }
-
- log_debug(domain,"considering layer_hint->package_window %d",
- layer_hint->package_window);
- if (layer_hint->package_window <= 0) {
- log_debug(domain,"yes, at-origin. stopped.");
- for (conn = TO_ORIGIN_CIRCUIT(circ)->p_streams; conn;
- conn=conn->next_stream) {
- if (conn->cpath_layer == layer_hint)
- connection_stop_reading(TO_CONN(conn));
- }
- return 1;
- }
- return 0;
- }
- static void
- circuit_consider_sending_sendme(circuit_t *circ, crypt_path_t *layer_hint)
- {
- while ((layer_hint ? layer_hint->deliver_window : circ->deliver_window) <=
- CIRCWINDOW_START - CIRCWINDOW_INCREMENT) {
- log_debug(LD_CIRC,"Queuing circuit sendme.");
- if (layer_hint)
- layer_hint->deliver_window += CIRCWINDOW_INCREMENT;
- else
- circ->deliver_window += CIRCWINDOW_INCREMENT;
- if (relay_send_command_from_edge(0, circ, RELAY_COMMAND_SENDME,
- NULL, 0, layer_hint) < 0) {
- log_warn(LD_CIRC,
- "relay_send_command_from_edge failed. Circuit's closed.");
- return;
- }
- }
- }
- #ifdef ACTIVE_CIRCUITS_PARANOIA
- #define assert_cmux_ok_paranoid(chan) \
- assert_circuit_mux_okay(chan)
- #else
- #define assert_cmux_ok_paranoid(chan)
- #endif
- static size_t total_cells_allocated = 0;
- static inline void
- packed_cell_free_unchecked(packed_cell_t *cell)
- {
- --total_cells_allocated;
- tor_free(cell);
- }
- STATIC packed_cell_t *
- packed_cell_new(void)
- {
- ++total_cells_allocated;
- return tor_malloc_zero(sizeof(packed_cell_t));
- }
- void
- packed_cell_free(packed_cell_t *cell)
- {
- if (!cell)
- return;
- packed_cell_free_unchecked(cell);
- }
- void
- dump_cell_pool_usage(int severity)
- {
- int n_circs = 0;
- int n_cells = 0;
- SMARTLIST_FOREACH_BEGIN(circuit_get_global_list(), circuit_t *, c) {
- n_cells += c->n_chan_cells.n;
- if (!CIRCUIT_IS_ORIGIN(c))
- n_cells += TO_OR_CIRCUIT(c)->p_chan_cells.n;
- ++n_circs;
- }
- SMARTLIST_FOREACH_END(c);
- tor_log(severity, LD_MM,
- "%d cells allocated on %d circuits. %d cells leaked.",
- n_cells, n_circs, (int)total_cells_allocated - n_cells);
- }
- static inline packed_cell_t *
- packed_cell_copy(const cell_t *cell, int wide_circ_ids)
- {
- packed_cell_t *c = packed_cell_new();
- cell_pack(c, cell, wide_circ_ids);
- return c;
- }
- void
- cell_queue_append(cell_queue_t *queue, packed_cell_t *cell)
- {
- TOR_SIMPLEQ_INSERT_TAIL(&queue->head, cell, next);
- ++queue->n;
- }
- void
- cell_queue_append_packed_copy(circuit_t *circ, cell_queue_t *queue,
- int exitward, const cell_t *cell,
- int wide_circ_ids, int use_stats)
- {
- packed_cell_t *copy = packed_cell_copy(cell, wide_circ_ids);
- (void)circ;
- (void)exitward;
- (void)use_stats;
- copy->inserted_time = (uint32_t) monotime_coarse_absolute_msec();
- cell_queue_append(queue, copy);
- }
- void
- cell_queue_init(cell_queue_t *queue)
- {
- memset(queue, 0, sizeof(cell_queue_t));
- TOR_SIMPLEQ_INIT(&queue->head);
- }
- void
- cell_queue_clear(cell_queue_t *queue)
- {
- packed_cell_t *cell;
- while ((cell = TOR_SIMPLEQ_FIRST(&queue->head))) {
- TOR_SIMPLEQ_REMOVE_HEAD(&queue->head, next);
- packed_cell_free_unchecked(cell);
- }
- TOR_SIMPLEQ_INIT(&queue->head);
- queue->n = 0;
- }
- STATIC packed_cell_t *
- cell_queue_pop(cell_queue_t *queue)
- {
- packed_cell_t *cell = TOR_SIMPLEQ_FIRST(&queue->head);
- if (!cell)
- return NULL;
- TOR_SIMPLEQ_REMOVE_HEAD(&queue->head, next);
- --queue->n;
- return cell;
- }
- void
- destroy_cell_queue_init(destroy_cell_queue_t *queue)
- {
- memset(queue, 0, sizeof(destroy_cell_queue_t));
- TOR_SIMPLEQ_INIT(&queue->head);
- }
- void
- destroy_cell_queue_clear(destroy_cell_queue_t *queue)
- {
- destroy_cell_t *cell;
- while ((cell = TOR_SIMPLEQ_FIRST(&queue->head))) {
- TOR_SIMPLEQ_REMOVE_HEAD(&queue->head, next);
- tor_free(cell);
- }
- TOR_SIMPLEQ_INIT(&queue->head);
- queue->n = 0;
- }
- STATIC destroy_cell_t *
- destroy_cell_queue_pop(destroy_cell_queue_t *queue)
- {
- destroy_cell_t *cell = TOR_SIMPLEQ_FIRST(&queue->head);
- if (!cell)
- return NULL;
- TOR_SIMPLEQ_REMOVE_HEAD(&queue->head, next);
- --queue->n;
- return cell;
- }
- void
- destroy_cell_queue_append(destroy_cell_queue_t *queue,
- circid_t circid,
- uint8_t reason)
- {
- destroy_cell_t *cell = tor_malloc_zero(sizeof(destroy_cell_t));
- cell->circid = circid;
- cell->reason = reason;
-
- cell->inserted_time = (uint32_t) monotime_coarse_absolute_msec();
- TOR_SIMPLEQ_INSERT_TAIL(&queue->head, cell, next);
- ++queue->n;
- }
- static packed_cell_t *
- destroy_cell_to_packed_cell(destroy_cell_t *inp, int wide_circ_ids)
- {
- packed_cell_t *packed = packed_cell_new();
- cell_t cell;
- memset(&cell, 0, sizeof(cell));
- cell.circ_id = inp->circid;
- cell.command = CELL_DESTROY;
- cell.payload[0] = inp->reason;
- cell_pack(packed, &cell, wide_circ_ids);
- tor_free(inp);
- return packed;
- }
- size_t
- packed_cell_mem_cost(void)
- {
- return sizeof(packed_cell_t);
- }
- STATIC size_t
- cell_queues_get_total_allocation(void)
- {
- return total_cells_allocated * packed_cell_mem_cost();
- }
- #define MEMORY_PRESSURE_INTERVAL (30*60)
- static time_t last_time_under_memory_pressure = 0;
- STATIC int
- cell_queues_check_size(void)
- {
- time_t now = time(NULL);
- size_t alloc = cell_queues_get_total_allocation();
- alloc += buf_get_total_allocation();
- alloc += tor_zlib_get_total_allocation();
- const size_t rend_cache_total = rend_cache_get_total_allocation();
- alloc += rend_cache_total;
- const size_t geoip_client_cache_total =
- geoip_client_cache_total_allocation();
- alloc += geoip_client_cache_total;
- if (alloc >= get_options()->MaxMemInQueues_low_threshold) {
- last_time_under_memory_pressure = approx_time();
- if (alloc >= get_options()->MaxMemInQueues) {
-
- if (rend_cache_total > get_options()->MaxMemInQueues / 5) {
- const size_t bytes_to_remove =
- rend_cache_total - (size_t)(get_options()->MaxMemInQueues / 10);
- rend_cache_clean_v2_descs_as_dir(now, bytes_to_remove);
- alloc -= rend_cache_total;
- alloc += rend_cache_get_total_allocation();
- }
- if (geoip_client_cache_total > get_options()->MaxMemInQueues / 5) {
- const size_t bytes_to_remove =
- geoip_client_cache_total -
- (size_t)(get_options()->MaxMemInQueues / 10);
- alloc -= geoip_client_cache_handle_oom(now, bytes_to_remove);
- }
- circuits_handle_oom(alloc);
- return 1;
- }
- }
- return 0;
- }
- int
- have_been_under_memory_pressure(void)
- {
- return last_time_under_memory_pressure + MEMORY_PRESSURE_INTERVAL
- < approx_time();
- }
- void
- update_circuit_on_cmux_(circuit_t *circ, cell_direction_t direction,
- const char *file, int lineno)
- {
- channel_t *chan = NULL;
- or_circuit_t *or_circ = NULL;
- circuitmux_t *cmux = NULL;
- tor_assert(circ);
-
- if (direction == CELL_DIRECTION_OUT) {
- chan = circ->n_chan;
- } else {
- or_circ = TO_OR_CIRCUIT(circ);
- chan = or_circ->p_chan;
- }
- tor_assert(chan);
- tor_assert(chan->cmux);
-
- cmux = chan->cmux;
-
- if (! circuitmux_is_circuit_attached(cmux, circ)) {
- log_warn(LD_BUG, "called on non-attached circuit from %s:%d",
- file, lineno);
- return;
- }
- tor_assert(circuitmux_attached_circuit_direction(cmux, circ) == direction);
- assert_cmux_ok_paranoid(chan);
-
- if (direction == CELL_DIRECTION_OUT) {
- circuitmux_set_num_cells(cmux, circ, circ->n_chan_cells.n);
- } else {
- circuitmux_set_num_cells(cmux, circ, or_circ->p_chan_cells.n);
- }
- assert_cmux_ok_paranoid(chan);
- }
- void
- channel_unlink_all_circuits(channel_t *chan, smartlist_t *circuits_out)
- {
- tor_assert(chan);
- tor_assert(chan->cmux);
- circuitmux_detach_all_circuits(chan->cmux, circuits_out);
- chan->num_n_circuits = 0;
- chan->num_p_circuits = 0;
- }
- static int
- set_streams_blocked_on_circ(circuit_t *circ, channel_t *chan,
- int block, streamid_t stream_id)
- {
- edge_connection_t *edge = NULL;
- int n = 0;
- if (circ->n_chan == chan) {
- circ->streams_blocked_on_n_chan = block;
- if (CIRCUIT_IS_ORIGIN(circ))
- edge = TO_ORIGIN_CIRCUIT(circ)->p_streams;
- } else {
- circ->streams_blocked_on_p_chan = block;
- tor_assert(!CIRCUIT_IS_ORIGIN(circ));
- edge = TO_OR_CIRCUIT(circ)->n_streams;
- }
- for (; edge; edge = edge->next_stream) {
- connection_t *conn = TO_CONN(edge);
- if (stream_id && edge->stream_id != stream_id)
- continue;
- if (edge->edge_blocked_on_circ != block) {
- ++n;
- edge->edge_blocked_on_circ = block;
- }
- if (!conn->read_event) {
-
- continue;
- }
- if (block) {
- if (connection_is_reading(conn))
- connection_stop_reading(conn);
- } else {
-
- if (!connection_is_reading(conn))
- connection_start_reading(conn);
- }
- }
- return n;
- }
- static uint8_t
- packed_cell_get_command(const packed_cell_t *cell, int wide_circ_ids)
- {
- if (wide_circ_ids) {
- return get_uint8(cell->body+4);
- } else {
- return get_uint8(cell->body+2);
- }
- }
- circid_t
- packed_cell_get_circid(const packed_cell_t *cell, int wide_circ_ids)
- {
- if (wide_circ_ids) {
- return ntohl(get_uint32(cell->body));
- } else {
- return ntohs(get_uint16(cell->body));
- }
- }
- MOCK_IMPL(int,
- channel_flush_from_first_active_circuit, (channel_t *chan, int max))
- {
- circuitmux_t *cmux = NULL;
- int n_flushed = 0;
- cell_queue_t *queue;
- destroy_cell_queue_t *destroy_queue=NULL;
- circuit_t *circ;
- or_circuit_t *or_circ;
- int streams_blocked;
- packed_cell_t *cell;
-
- tor_assert(chan);
- tor_assert(chan->cmux);
- cmux = chan->cmux;
-
- while (n_flushed < max) {
- circ = circuitmux_get_first_active_circuit(cmux, &destroy_queue);
- if (destroy_queue) {
- destroy_cell_t *dcell;
-
-
- tor_assert(destroy_queue->n > 0);
- dcell = destroy_cell_queue_pop(destroy_queue);
-
- tor_assert(dcell);
-
- cell = destroy_cell_to_packed_cell(dcell, chan->wide_circ_ids);
-
- channel_write_packed_cell(chan, cell);
-
- circuitmux_notify_xmit_destroy(cmux);
- cell = NULL;
- ++n_flushed;
- continue;
- }
-
- if (!circ) break;
- assert_cmux_ok_paranoid(chan);
- if (circ->n_chan == chan) {
- queue = &circ->n_chan_cells;
- streams_blocked = circ->streams_blocked_on_n_chan;
- } else {
- or_circ = TO_OR_CIRCUIT(circ);
- tor_assert(or_circ->p_chan == chan);
- queue = &TO_OR_CIRCUIT(circ)->p_chan_cells;
- streams_blocked = circ->streams_blocked_on_p_chan;
- }
-
- if ( queue->n == 0 ) {
- log_warn(LD_BUG, "Found a supposedly active circuit with no cells "
- "to send. Trying to recover.");
- circuitmux_set_num_cells(cmux, circ, 0);
- if (! circ->marked_for_close)
- circuit_mark_for_close(circ, END_CIRC_REASON_INTERNAL);
- continue;
- }
- tor_assert(queue->n > 0);
-
- cell = cell_queue_pop(queue);
-
- if (get_options()->CellStatistics ||
- get_options()->TestingEnableCellStatsEvent) {
- uint32_t msec_waiting;
- uint32_t msec_now = (uint32_t)monotime_coarse_absolute_msec();
- msec_waiting = msec_now - cell->inserted_time;
- if (get_options()->CellStatistics && !CIRCUIT_IS_ORIGIN(circ)) {
- or_circ = TO_OR_CIRCUIT(circ);
- or_circ->total_cell_waiting_time += msec_waiting;
- or_circ->processed_cells++;
- }
- if (get_options()->TestingEnableCellStatsEvent) {
- uint8_t command = packed_cell_get_command(cell, chan->wide_circ_ids);
- testing_cell_stats_entry_t *ent =
- tor_malloc_zero(sizeof(testing_cell_stats_entry_t));
- ent->command = command;
- ent->waiting_time = msec_waiting / 10;
- ent->removed = 1;
- if (circ->n_chan == chan)
- ent->exitward = 1;
- if (!circ->testing_cell_stats)
- circ->testing_cell_stats = smartlist_new();
- smartlist_add(circ->testing_cell_stats, ent);
- }
- }
-
- if (queue->n == 0 && chan->dirreq_id)
- geoip_change_dirreq_state(chan->dirreq_id,
- DIRREQ_TUNNELED,
- DIRREQ_CIRC_QUEUE_FLUSHED);
-
- channel_write_packed_cell(chan, cell);
- cell = NULL;
-
-
- ++n_flushed;
-
- circuitmux_notify_xmit_cells(cmux, circ, 1);
- circuitmux_set_num_cells(cmux, circ, queue->n);
- if (queue->n == 0)
- log_debug(LD_GENERAL, "Made a circuit inactive.");
-
- if (streams_blocked && queue->n <= CELL_QUEUE_LOWWATER_SIZE)
- set_streams_blocked_on_circ(circ, chan, 0, 0);
-
- }
-
- assert_cmux_ok_paranoid(chan);
- return n_flushed;
- }
- #if 0
- static int
- get_max_middle_cells(void)
- {
- return ORCIRC_MAX_MIDDLE_CELLS;
- }
- #endif
- void
- append_cell_to_circuit_queue(circuit_t *circ, channel_t *chan,
- cell_t *cell, cell_direction_t direction,
- streamid_t fromstream)
- {
- or_circuit_t *orcirc = NULL;
- cell_queue_t *queue;
- int streams_blocked;
- #if 0
- uint32_t tgt_max_middle_cells, p_len, n_len, tmp, hard_max_middle_cells;
- #endif
- int exitward;
- if (circ->marked_for_close)
- return;
- exitward = (direction == CELL_DIRECTION_OUT);
- if (exitward) {
- queue = &circ->n_chan_cells;
- streams_blocked = circ->streams_blocked_on_n_chan;
- } else {
- orcirc = TO_OR_CIRCUIT(circ);
- queue = &orcirc->p_chan_cells;
- streams_blocked = circ->streams_blocked_on_p_chan;
- }
-
- #if 0
-
- if ((circ->n_chan != NULL) && CIRCUIT_IS_ORCIRC(circ)) {
- orcirc = TO_OR_CIRCUIT(circ);
- if (orcirc->p_chan) {
-
-
- tgt_max_middle_cells = get_max_middle_cells();
- if (tgt_max_middle_cells > 0) {
-
- if (orcirc->max_middle_cells == 0) {
- orcirc->max_middle_cells = tgt_max_middle_cells;
- } else {
- if (tgt_max_middle_cells > orcirc->max_middle_cells) {
-
- orcirc->max_middle_cells = tgt_max_middle_cells;
- } else if (tgt_max_middle_cells < orcirc->max_middle_cells) {
-
- n_len = circ->n_chan_cells.n;
- p_len = orcirc->p_chan_cells.n;
- tmp = tgt_max_middle_cells;
- if (tmp < n_len) tmp = n_len;
- if (tmp < p_len) tmp = p_len;
- orcirc->max_middle_cells = tmp;
- }
-
- }
- } else {
-
- orcirc->max_middle_cells = 0;
- }
-
- if (orcirc->max_middle_cells > 0) {
- hard_max_middle_cells =
- (uint32_t)(((double)orcirc->max_middle_cells) *
- ORCIRC_MAX_MIDDLE_KILL_THRESH);
- if ((unsigned)queue->n + 1 >= hard_max_middle_cells) {
-
- log_warn(LD_CIRC,
- "Got a cell exceeding the hard cap of %u in the "
- "%s direction on middle circ ID %u on chan ID "
- U64_FORMAT "; killing the circuit.",
- hard_max_middle_cells,
- (direction == CELL_DIRECTION_OUT) ? "n" : "p",
- (direction == CELL_DIRECTION_OUT) ?
- circ->n_circ_id : orcirc->p_circ_id,
- U64_PRINTF_ARG(
- (direction == CELL_DIRECTION_OUT) ?
- circ->n_chan->global_identifier :
- orcirc->p_chan->global_identifier));
- circuit_mark_for_close(circ, END_CIRC_REASON_RESOURCELIMIT);
- return;
- } else if ((unsigned)queue->n + 1 == orcirc->max_middle_cells) {
-
- log_warn(LD_CIRC,
- "While trying to queue a cell, reached the soft cap of %u "
- "in the %s direction on middle circ ID %u "
- "on chan ID " U64_FORMAT ".",
- orcirc->max_middle_cells,
- (direction == CELL_DIRECTION_OUT) ? "n" : "p",
- (direction == CELL_DIRECTION_OUT) ?
- circ->n_circ_id : orcirc->p_circ_id,
- U64_PRINTF_ARG(
- (direction == CELL_DIRECTION_OUT) ?
- circ->n_chan->global_identifier :
- orcirc->p_chan->global_identifier));
- }
- }
- }
- }
- #endif
- cell_queue_append_packed_copy(circ, queue, exitward, cell,
- chan->wide_circ_ids, 1);
- if (PREDICT_UNLIKELY(cell_queues_check_size())) {
-
- if (circ->marked_for_close)
- return;
- }
-
- if (!streams_blocked && queue->n >= CELL_QUEUE_HIGHWATER_SIZE)
- set_streams_blocked_on_circ(circ, chan, 1, 0);
- if (streams_blocked && fromstream) {
-
- set_streams_blocked_on_circ(circ, chan, 1, fromstream);
- }
- update_circuit_on_cmux(circ, direction);
- if (queue->n == 1) {
-
- log_debug(LD_GENERAL, "Made a circuit active.");
- }
-
- scheduler_channel_has_waiting_cells(chan);
- }
- int
- append_address_to_payload(uint8_t *payload_out, const tor_addr_t *addr)
- {
- uint32_t a;
- switch (tor_addr_family(addr)) {
- case AF_INET:
- payload_out[0] = RESOLVED_TYPE_IPV4;
- payload_out[1] = 4;
- a = tor_addr_to_ipv4n(addr);
- memcpy(payload_out+2, &a, 4);
- return 6;
- case AF_INET6:
- payload_out[0] = RESOLVED_TYPE_IPV6;
- payload_out[1] = 16;
- memcpy(payload_out+2, tor_addr_to_in6_addr8(addr), 16);
- return 18;
- case AF_UNSPEC:
- default:
- return -1;
- }
- }
- const uint8_t *
- decode_address_from_payload(tor_addr_t *addr_out, const uint8_t *payload,
- int payload_len)
- {
- if (payload_len < 2)
- return NULL;
- if (payload_len < 2+payload[1])
- return NULL;
- switch (payload[0]) {
- case RESOLVED_TYPE_IPV4:
- if (payload[1] != 4)
- return NULL;
- tor_addr_from_ipv4n(addr_out, get_uint32(payload+2));
- break;
- case RESOLVED_TYPE_IPV6:
- if (payload[1] != 16)
- return NULL;
- tor_addr_from_ipv6_bytes(addr_out, (char*)(payload+2));
- break;
- default:
- tor_addr_make_unspec(addr_out);
- break;
- }
- return payload + 2 + payload[1];
- }
- void
- circuit_clear_cell_queue(circuit_t *circ, channel_t *chan)
- {
- cell_queue_t *queue;
- cell_direction_t direction;
- if (circ->n_chan == chan) {
- queue = &circ->n_chan_cells;
- direction = CELL_DIRECTION_OUT;
- } else {
- or_circuit_t *orcirc = TO_OR_CIRCUIT(circ);
- tor_assert(orcirc->p_chan == chan);
- queue = &orcirc->p_chan_cells;
- direction = CELL_DIRECTION_IN;
- }
-
- cell_queue_clear(queue);
-
- if (chan->cmux && circuitmux_is_circuit_attached(chan->cmux, circ))
- update_circuit_on_cmux(circ, direction);
- }
- void
- assert_circuit_mux_okay(channel_t *chan)
- {
- tor_assert(chan);
- tor_assert(chan->cmux);
- circuitmux_assert_okay(chan->cmux);
- }
- static int
- circuit_queue_streams_are_blocked(circuit_t *circ)
- {
- if (CIRCUIT_IS_ORIGIN(circ)) {
- return circ->streams_blocked_on_n_chan;
- } else {
- return circ->streams_blocked_on_p_chan;
- }
- }
|