1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162116311641165116611671168116911701171117211731174117511761177117811791180118111821183118411851186118711881189119011911192119311941195119611971198119912001201120212031204120512061207120812091210121112121213121412151216121712181219122012211222122312241225122612271228122912301231123212331234123512361237123812391240124112421243124412451246124712481249125012511252125312541255125612571258125912601261126212631264126512661267126812691270127112721273127412751276127712781279128012811282128312841285128612871288128912901291129212931294129512961297129812991300130113021303130413051306130713081309131013111312131313141315131613171318131913201321132213231324132513261327132813291330133113321333133413351336133713381339134013411342134313441345134613471348134913501351135213531354135513561357135813591360136113621363136413651366136713681369137013711372137313741375137613771378137913801381138213831384138513861387138813891390139113921393139413951396139713981399140014011402140314041405140614071408140914101411141214131414141514161417141814191420142114221423142414251426142714281429143014311432143314341435143614371438143914401441144214431444144514461447144814491450145114521453145414551456145714581459146014611462146314641465146614671468146914701471147214731474147514761477147814791480148114821483148414851486148714881489149014911492149314941495149614971498149915001501150215031504150515061507150815091510151115121513151415151516151715181519152015211522152315241525152615271528152915301531153215331534153515361537153815391540154115421543154415451546154715481549155015511552155315541555155615571558155915601561156215631564156515661567156815691570157115721573157415751576157715781579158015811582158315841585158615871588158915901591159215931594159515961597159815991600160116021603160416051606160716081609161016111612161316141615161616171618161916201621162216231624162516261627162816291630163116321633163416351636163716381639164016411642164316441645164616471648164916501651165216531654165516561657165816591660166116621663166416651666166716681669167016711672167316741675167616771678167916801681168216831684168516861687168816891690169116921693169416951696169716981699170017011702170317041705170617071708170917101711171217131714171517161717171817191720172117221723172417251726172717281729173017311732173317341735173617371738173917401741174217431744174517461747174817491750175117521753175417551756175717581759176017611762176317641765176617671768176917701771177217731774177517761777177817791780178117821783178417851786178717881789179017911792179317941795179617971798179918001801180218031804180518061807180818091810181118121813181418151816181718181819182018211822182318241825182618271828182918301831183218331834183518361837183818391840184118421843184418451846184718481849185018511852185318541855185618571858185918601861186218631864186518661867186818691870187118721873187418751876187718781879188018811882188318841885188618871888188918901891189218931894189518961897189818991900190119021903190419051906190719081909191019111912191319141915191619171918191919201921192219231924192519261927192819291930193119321933193419351936193719381939194019411942194319441945194619471948194919501951195219531954195519561957195819591960196119621963196419651966196719681969197019711972197319741975197619771978197919801981198219831984198519861987198819891990199119921993199419951996199719981999200020012002200320042005200620072008200920102011201220132014201520162017201820192020202120222023202420252026202720282029203020312032203320342035203620372038203920402041204220432044204520462047204820492050205120522053205420552056205720582059206020612062206320642065206620672068206920702071207220732074207520762077207820792080208120822083208420852086208720882089209020912092209320942095209620972098209921002101210221032104210521062107210821092110211121122113211421152116211721182119212021212122212321242125212621272128212921302131213221332134213521362137213821392140214121422143214421452146214721482149215021512152215321542155215621572158215921602161216221632164216521662167216821692170217121722173217421752176217721782179218021812182218321842185218621872188218921902191219221932194219521962197219821992200220122022203220422052206220722082209221022112212221322142215221622172218221922202221222222232224222522262227222822292230223122322233223422352236223722382239224022412242224322442245224622472248224922502251225222532254225522562257225822592260226122622263226422652266226722682269227022712272227322742275227622772278227922802281228222832284228522862287228822892290229122922293229422952296229722982299230023012302230323042305230623072308230923102311231223132314231523162317231823192320232123222323232423252326232723282329233023312332233323342335233623372338233923402341234223432344234523462347234823492350235123522353235423552356235723582359236023612362236323642365236623672368236923702371237223732374237523762377237823792380238123822383238423852386238723882389239023912392239323942395239623972398239924002401240224032404240524062407240824092410241124122413241424152416241724182419242024212422242324242425242624272428242924302431243224332434243524362437243824392440244124422443244424452446244724482449245024512452245324542455245624572458245924602461246224632464246524662467246824692470247124722473247424752476247724782479248024812482248324842485248624872488248924902491249224932494249524962497249824992500250125022503250425052506250725082509251025112512251325142515251625172518251925202521252225232524252525262527252825292530253125322533253425352536253725382539254025412542254325442545254625472548254925502551255225532554255525562557255825592560256125622563256425652566256725682569257025712572257325742575257625772578257925802581258225832584258525862587258825892590259125922593259425952596259725982599260026012602260326042605260626072608260926102611261226132614261526162617261826192620262126222623262426252626262726282629263026312632263326342635263626372638263926402641264226432644264526462647264826492650265126522653265426552656265726582659266026612662266326642665266626672668266926702671267226732674267526762677267826792680268126822683268426852686268726882689269026912692269326942695269626972698269927002701270227032704270527062707270827092710271127122713271427152716271727182719272027212722272327242725272627272728272927302731273227332734273527362737273827392740274127422743274427452746274727482749275027512752275327542755275627572758275927602761276227632764276527662767276827692770277127722773277427752776277727782779278027812782278327842785278627872788278927902791279227932794279527962797279827992800280128022803280428052806280728082809281028112812281328142815281628172818281928202821282228232824282528262827282828292830283128322833283428352836283728382839284028412842284328442845284628472848284928502851285228532854285528562857285828592860286128622863286428652866286728682869287028712872287328742875287628772878287928802881288228832884288528862887288828892890289128922893289428952896289728982899290029012902290329042905290629072908290929102911291229132914291529162917291829192920292129222923292429252926292729282929293029312932293329342935293629372938293929402941294229432944294529462947294829492950295129522953295429552956295729582959296029612962296329642965296629672968296929702971297229732974297529762977297829792980298129822983298429852986298729882989299029912992299329942995299629972998299930003001300230033004300530063007300830093010301130123013301430153016301730183019302030213022302330243025302630273028302930303031303230333034303530363037303830393040304130423043304430453046304730483049305030513052305330543055305630573058305930603061306230633064306530663067306830693070307130723073307430753076307730783079308030813082308330843085308630873088308930903091309230933094309530963097309830993100310131023103310431053106310731083109311031113112311331143115311631173118311931203121312231233124312531263127312831293130313131323133313431353136313731383139314031413142314331443145314631473148314931503151315231533154315531563157315831593160316131623163316431653166316731683169317031713172317331743175317631773178317931803181318231833184318531863187318831893190319131923193319431953196319731983199320032013202320332043205320632073208320932103211321232133214321532163217321832193220322132223223322432253226322732283229323032313232323332343235323632373238323932403241324232433244324532463247324832493250325132523253325432553256325732583259326032613262326332643265326632673268326932703271327232733274327532763277327832793280328132823283328432853286328732883289329032913292329332943295329632973298329933003301330233033304330533063307330833093310331133123313331433153316331733183319332033213322332333243325332633273328332933303331333233333334333533363337333833393340334133423343334433453346334733483349335033513352335333543355335633573358335933603361336233633364336533663367336833693370337133723373337433753376337733783379338033813382338333843385338633873388338933903391339233933394339533963397339833993400340134023403340434053406340734083409341034113412341334143415341634173418341934203421342234233424342534263427342834293430343134323433343434353436343734383439344034413442344334443445344634473448344934503451345234533454345534563457345834593460346134623463346434653466346734683469347034713472347334743475347634773478347934803481348234833484348534863487348834893490349134923493349434953496349734983499350035013502350335043505350635073508350935103511351235133514351535163517351835193520352135223523352435253526352735283529353035313532353335343535353635373538353935403541354235433544354535463547354835493550355135523553355435553556355735583559356035613562356335643565356635673568356935703571357235733574357535763577357835793580358135823583358435853586358735883589359035913592359335943595359635973598359936003601360236033604360536063607360836093610361136123613361436153616361736183619362036213622362336243625362636273628362936303631363236333634363536363637363836393640364136423643364436453646364736483649365036513652365336543655365636573658365936603661366236633664366536663667366836693670367136723673367436753676367736783679368036813682368336843685368636873688368936903691369236933694369536963697369836993700370137023703370437053706370737083709371037113712371337143715371637173718371937203721372237233724372537263727372837293730373137323733373437353736373737383739374037413742374337443745374637473748374937503751375237533754375537563757375837593760376137623763376437653766376737683769377037713772377337743775377637773778377937803781378237833784378537863787378837893790379137923793379437953796379737983799380038013802380338043805380638073808380938103811381238133814381538163817381838193820382138223823382438253826382738283829383038313832383338343835383638373838383938403841384238433844384538463847384838493850385138523853385438553856385738583859386038613862386338643865386638673868386938703871387238733874387538763877387838793880388138823883388438853886388738883889389038913892389338943895389638973898389939003901390239033904390539063907390839093910391139123913391439153916391739183919392039213922392339243925392639273928392939303931393239333934393539363937393839393940394139423943394439453946394739483949395039513952395339543955395639573958395939603961396239633964396539663967396839693970397139723973397439753976397739783979398039813982398339843985398639873988398939903991399239933994399539963997399839994000400140024003400440054006400740084009401040114012401340144015401640174018401940204021402240234024402540264027402840294030403140324033403440354036403740384039404040414042404340444045404640474048404940504051405240534054405540564057405840594060406140624063406440654066406740684069407040714072407340744075407640774078407940804081408240834084408540864087408840894090409140924093409440954096409740984099410041014102410341044105410641074108410941104111411241134114411541164117411841194120412141224123412441254126412741284129413041314132413341344135413641374138413941404141414241434144414541464147414841494150415141524153415441554156415741584159416041614162416341644165416641674168416941704171417241734174417541764177417841794180418141824183418441854186418741884189419041914192419341944195419641974198419942004201420242034204420542064207420842094210421142124213421442154216421742184219422042214222422342244225422642274228422942304231423242334234423542364237423842394240424142424243424442454246424742484249425042514252425342544255425642574258425942604261426242634264426542664267426842694270427142724273427442754276427742784279428042814282428342844285428642874288428942904291429242934294429542964297429842994300430143024303430443054306430743084309431043114312431343144315431643174318431943204321432243234324432543264327432843294330433143324333433443354336433743384339434043414342434343444345434643474348434943504351435243534354435543564357435843594360436143624363436443654366436743684369437043714372437343744375437643774378437943804381438243834384438543864387438843894390439143924393439443954396439743984399440044014402440344044405440644074408440944104411441244134414441544164417441844194420442144224423442444254426442744284429443044314432443344344435443644374438443944404441444244434444444544464447444844494450445144524453445444554456 |
- // **********************************************************************
- // This file was generated by a TARS parser!
- // TARS version 3.0.6.
- // **********************************************************************
- #ifndef __HELLO_H_
- #define __HELLO_H_
- #include <map>
- #include <string>
- #include <vector>
- #include "tup/Tars.h"
- #include "tup/TarsJson.h"
- using namespace std;
- #include "servant/ServantProxy.h"
- #include "servant/Servant.h"
- #include "promise/promise.h"
- #include "servant/Application.h"
- namespace Test
- {
- enum EN_KEY
- {
- KEY1 = 1,
- KEY2 = 2,
- };
- inline string etos(const EN_KEY & e)
- {
- switch(e)
- {
- case KEY1: return "KEY1";
- case KEY2: return "KEY2";
- default: return "";
- }
- }
- inline int stoe(const string & s, EN_KEY & e)
- {
- if(s == "KEY1") { e=KEY1; return 0;}
- if(s == "KEY2") { e=KEY2; return 0;}
- return -1;
- }
- struct JsonKey : public tars::TarsStructBase
- {
- public:
- static string className()
- {
- return "Test.JsonKey";
- }
- static string MD5()
- {
- return "7b010a6336d210a506b1eb4bf4c1e014";
- }
- JsonKey()
- {
- resetDefautlt();
- }
- void resetDefautlt()
- {
- i = 0;
- }
- template<typename WriterT>
- void writeTo(tars::TarsOutputStream<WriterT>& _os) const
- {
- if (i != 0)
- {
- _os.write(i, 0);
- }
- }
- template<typename ReaderT>
- void readFrom(tars::TarsInputStream<ReaderT>& _is)
- {
- resetDefautlt();
- _is.read(i, 0, false);
- }
- tars::JsonValueObjPtr writeToJson() const
- {
- tars::JsonValueObjPtr p = new tars::JsonValueObj();
- p->value["i"] = tars::JsonOutput::writeJson(i);
- return p;
- }
- string writeToJsonString() const
- {
- return tars::TC_Json::writeValue(writeToJson());
- }
- void readFromJson(const tars::JsonValuePtr & p, bool isRequire = true)
- {
- resetDefautlt();
- if(NULL == p.get() || p->getType() != tars::eJsonTypeObj)
- {
- char s[128];
- snprintf(s, sizeof(s), "read 'struct' type mismatch, get type: %d.", (p.get() ? p->getType() : 0));
- throw tars::TC_Json_Exception(s);
- }
- tars::JsonValueObjPtr pObj=tars::JsonValueObjPtr::dynamicCast(p);
- tars::JsonInput::readJson(i,pObj->value["i"], false);
- }
- void readFromJsonString(const string & str)
- {
- readFromJson(tars::TC_Json::getValue(str));
- }
- ostream& display(ostream& _os, int _level=0) const
- {
- tars::TarsDisplayer _ds(_os, _level);
- _ds.display(i,"i");
- return _os;
- }
- ostream& displaySimple(ostream& _os, int _level=0) const
- {
- tars::TarsDisplayer _ds(_os, _level);
- _ds.displaySimple(i, false);
- return _os;
- }
- public:
- tars::Int32 i;
- };
- inline bool operator==(const JsonKey&l, const JsonKey&r)
- {
- return l.i == r.i;
- }
- inline bool operator!=(const JsonKey&l, const JsonKey&r)
- {
- return !(l == r);
- }
- inline ostream& operator<<(ostream & os,const JsonKey&r)
- {
- os << r.writeToJsonString();
- return os;
- }
- inline istream& operator>>(istream& is,JsonKey&l)
- {
- std::istreambuf_iterator<char> eos;
- std::string s(std::istreambuf_iterator<char>(is), eos);
- l.readFromJsonString(s);
- return is;
- }
- inline bool operator<(const JsonKey&l, const JsonKey&r)
- {
- if(l.i != r.i) return (l.i < r.i);
- return false;
- }
- inline bool operator<=(const JsonKey&l, const JsonKey&r)
- {
- return !(r < l);
- }
- inline bool operator>(const JsonKey&l, const JsonKey&r)
- {
- return r < l;
- }
- inline bool operator>=(const JsonKey&l, const JsonKey&r)
- {
- return !(l < r);
- }
- struct JsonData : public tars::TarsStructBase
- {
- public:
- static string className()
- {
- return "Test.JsonData";
- }
- static string MD5()
- {
- return "7e2b4e48c7c69de6efedb26120c23c90";
- }
- JsonData()
- {
- resetDefautlt();
- }
- void resetDefautlt()
- {
- c = 0;
- s = 0;
- i = 0;
- l = 0;
- f = 0;
- d = 0;
- uc = 0;
- us = 0;
- ui = 0;
- b = true;
- k = Test::KEY1;
- ss = "";
- data.clear();
- v.clear();
- im.clear();
- bm.clear();
- fm.clear();
- bv.clear();
- iv.clear();
- dv.clear();
- }
- template<typename WriterT>
- void writeTo(tars::TarsOutputStream<WriterT>& _os) const
- {
- if (c != 0)
- {
- _os.write(c, 0);
- }
- if (s != 0)
- {
- _os.write(s, 1);
- }
- if (i != 0)
- {
- _os.write(i, 2);
- }
- if (l != 0)
- {
- _os.write(l, 3);
- }
- if (f != 0)
- {
- _os.write(f, 4);
- }
- if (d != 0)
- {
- _os.write(d, 5);
- }
- if (uc != 0)
- {
- _os.write(uc, 6);
- }
- if (us != 0)
- {
- _os.write(us, 7);
- }
- if (ui != 0)
- {
- _os.write(ui, 8);
- }
- if (b != true)
- {
- _os.write(b, 9);
- }
- _os.write((tars::Int32)k, 10);
- if (ss != "")
- {
- _os.write(ss, 11);
- }
- if (data.size() > 0)
- {
- _os.write(data, 12);
- }
- if (v.size() > 0)
- {
- _os.write(v, 13);
- }
- if (im.size() > 0)
- {
- _os.write(im, 14);
- }
- if (bm.size() > 0)
- {
- _os.write(bm, 15);
- }
- if (fm.size() > 0)
- {
- _os.write(fm, 16);
- }
- if (bv.size() > 0)
- {
- _os.write(bv, 17);
- }
- if (iv.size() > 0)
- {
- _os.write(iv, 18);
- }
- if (dv.size() > 0)
- {
- _os.write(dv, 19);
- }
- }
- template<typename ReaderT>
- void readFrom(tars::TarsInputStream<ReaderT>& _is)
- {
- resetDefautlt();
- _is.read(c, 0, false);
- _is.read(s, 1, false);
- _is.read(i, 2, false);
- _is.read(l, 3, false);
- _is.read(f, 4, false);
- _is.read(d, 5, false);
- _is.read(uc, 6, false);
- _is.read(us, 7, false);
- _is.read(ui, 8, false);
- _is.read(b, 9, false);
- tars::Int32 eTemp10 = Test::KEY1;
- _is.read(eTemp10, 10, false);
- k = (Test::EN_KEY)eTemp10;
- _is.read(ss, 11, false);
- _is.read(data, 12, false);
- _is.read(v, 13, false);
- _is.read(im, 14, false);
- _is.read(bm, 15, false);
- _is.read(fm, 16, false);
- _is.read(bv, 17, false);
- _is.read(iv, 18, false);
- _is.read(dv, 19, false);
- }
- tars::JsonValueObjPtr writeToJson() const
- {
- tars::JsonValueObjPtr p = new tars::JsonValueObj();
- p->value["c"] = tars::JsonOutput::writeJson(c);
- p->value["s"] = tars::JsonOutput::writeJson(s);
- p->value["i"] = tars::JsonOutput::writeJson(i);
- p->value["l"] = tars::JsonOutput::writeJson(l);
- p->value["f"] = tars::JsonOutput::writeJson(f);
- p->value["d"] = tars::JsonOutput::writeJson(d);
- p->value["uc"] = tars::JsonOutput::writeJson(uc);
- p->value["us"] = tars::JsonOutput::writeJson(us);
- p->value["ui"] = tars::JsonOutput::writeJson(ui);
- p->value["b"] = tars::JsonOutput::writeJson(b);
- p->value["k"] = tars::JsonOutput::writeJson((tars::Int32)k);
- p->value["ss"] = tars::JsonOutput::writeJson(ss);
- p->value["data"] = tars::JsonOutput::writeJson(data);
- p->value["v"] = tars::JsonOutput::writeJson(v);
- p->value["im"] = tars::JsonOutput::writeJson(im);
- p->value["bm"] = tars::JsonOutput::writeJson(bm);
- p->value["fm"] = tars::JsonOutput::writeJson(fm);
- p->value["bv"] = tars::JsonOutput::writeJson(bv);
- p->value["iv"] = tars::JsonOutput::writeJson(iv);
- p->value["dv"] = tars::JsonOutput::writeJson(dv);
- return p;
- }
- string writeToJsonString() const
- {
- return tars::TC_Json::writeValue(writeToJson());
- }
- void readFromJson(const tars::JsonValuePtr & p, bool isRequire = true)
- {
- resetDefautlt();
- if(NULL == p.get() || p->getType() != tars::eJsonTypeObj)
- {
- char s[128];
- snprintf(s, sizeof(s), "read 'struct' type mismatch, get type: %d.", (p.get() ? p->getType() : 0));
- throw tars::TC_Json_Exception(s);
- }
- tars::JsonValueObjPtr pObj=tars::JsonValueObjPtr::dynamicCast(p);
- tars::JsonInput::readJson(c,pObj->value["c"], false);
- tars::JsonInput::readJson(s,pObj->value["s"], false);
- tars::JsonInput::readJson(i,pObj->value["i"], false);
- tars::JsonInput::readJson(l,pObj->value["l"], false);
- tars::JsonInput::readJson(f,pObj->value["f"], false);
- tars::JsonInput::readJson(d,pObj->value["d"], false);
- tars::JsonInput::readJson(uc,pObj->value["uc"], false);
- tars::JsonInput::readJson(us,pObj->value["us"], false);
- tars::JsonInput::readJson(ui,pObj->value["ui"], false);
- tars::JsonInput::readJson(b,pObj->value["b"], false);
- tars::JsonInput::readJson(k,pObj->value["k"], false);
- tars::JsonInput::readJson(ss,pObj->value["ss"], false);
- tars::JsonInput::readJson(data,pObj->value["data"], false);
- tars::JsonInput::readJson(v,pObj->value["v"], false);
- tars::JsonInput::readJson(im,pObj->value["im"], false);
- tars::JsonInput::readJson(bm,pObj->value["bm"], false);
- tars::JsonInput::readJson(fm,pObj->value["fm"], false);
- tars::JsonInput::readJson(bv,pObj->value["bv"], false);
- tars::JsonInput::readJson(iv,pObj->value["iv"], false);
- tars::JsonInput::readJson(dv,pObj->value["dv"], false);
- }
- void readFromJsonString(const string & str)
- {
- readFromJson(tars::TC_Json::getValue(str));
- }
- ostream& display(ostream& _os, int _level=0) const
- {
- tars::TarsDisplayer _ds(_os, _level);
- _ds.display(c,"c");
- _ds.display(s,"s");
- _ds.display(i,"i");
- _ds.display(l,"l");
- _ds.display(f,"f");
- _ds.display(d,"d");
- _ds.display(uc,"uc");
- _ds.display(us,"us");
- _ds.display(ui,"ui");
- _ds.display(b,"b");
- _ds.display((tars::Int32)k,"k");
- _ds.display(ss,"ss");
- _ds.display(data,"data");
- _ds.display(v,"v");
- _ds.display(im,"im");
- _ds.display(bm,"bm");
- _ds.display(fm,"fm");
- _ds.display(bv,"bv");
- _ds.display(iv,"iv");
- _ds.display(dv,"dv");
- return _os;
- }
- ostream& displaySimple(ostream& _os, int _level=0) const
- {
- tars::TarsDisplayer _ds(_os, _level);
- _ds.displaySimple(c, true);
- _ds.displaySimple(s, true);
- _ds.displaySimple(i, true);
- _ds.displaySimple(l, true);
- _ds.displaySimple(f, true);
- _ds.displaySimple(d, true);
- _ds.displaySimple(uc, true);
- _ds.displaySimple(us, true);
- _ds.displaySimple(ui, true);
- _ds.displaySimple(b, true);
- _ds.displaySimple((tars::Int32)k, true);
- _ds.displaySimple(ss, true);
- _ds.displaySimple(data, true);
- _ds.displaySimple(v, true);
- _ds.displaySimple(im, true);
- _ds.displaySimple(bm, true);
- _ds.displaySimple(fm, true);
- _ds.displaySimple(bv, true);
- _ds.displaySimple(iv, true);
- _ds.displaySimple(dv, false);
- return _os;
- }
- public:
- tars::Char c;
- tars::Short s;
- tars::Int32 i;
- tars::Int64 l;
- tars::Float f;
- tars::Double d;
- tars::UInt8 uc;
- tars::UInt16 us;
- tars::UInt32 ui;
- tars::Bool b;
- Test::EN_KEY k;
- std::string ss;
- map<Test::EN_KEY, std::string> data;
- vector<Test::EN_KEY> v;
- map<tars::Int32, std::string> im;
- map<tars::Bool, std::string> bm;
- map<tars::Float, std::string> fm;
- vector<tars::Bool> bv;
- vector<tars::Int32> iv;
- vector<tars::Double> dv;
- };
- inline bool operator==(const JsonData&l, const JsonData&r)
- {
- return l.c == r.c && l.s == r.s && l.i == r.i && l.l == r.l && tars::TC_Common::equal(l.f,r.f) && tars::TC_Common::equal(l.d,r.d) && l.uc == r.uc && l.us == r.us && l.ui == r.ui && l.b == r.b && l.k == r.k && l.ss == r.ss && l.data == r.data && l.v == r.v && l.im == r.im && l.bm == r.bm && tars::TC_Common::equal(l.fm,r.fm) && l.bv == r.bv && l.iv == r.iv && tars::TC_Common::equal(l.dv,r.dv);
- }
- inline bool operator!=(const JsonData&l, const JsonData&r)
- {
- return !(l == r);
- }
- inline ostream& operator<<(ostream & os,const JsonData&r)
- {
- os << r.writeToJsonString();
- return os;
- }
- inline istream& operator>>(istream& is,JsonData&l)
- {
- std::istreambuf_iterator<char> eos;
- std::string s(std::istreambuf_iterator<char>(is), eos);
- l.readFromJsonString(s);
- return is;
- }
- struct JsonMap : public tars::TarsStructBase
- {
- public:
- static string className()
- {
- return "Test.JsonMap";
- }
- static string MD5()
- {
- return "5bf0437e83ccb7e533b35c9747197b50";
- }
- JsonMap()
- {
- resetDefautlt();
- }
- void resetDefautlt()
- {
- json.clear();
- }
- template<typename WriterT>
- void writeTo(tars::TarsOutputStream<WriterT>& _os) const
- {
- if (json.size() > 0)
- {
- _os.write(json, 0);
- }
- }
- template<typename ReaderT>
- void readFrom(tars::TarsInputStream<ReaderT>& _is)
- {
- resetDefautlt();
- _is.read(json, 0, false);
- }
- tars::JsonValueObjPtr writeToJson() const
- {
- tars::JsonValueObjPtr p = new tars::JsonValueObj();
- p->value["json"] = tars::JsonOutput::writeJson(json);
- return p;
- }
- string writeToJsonString() const
- {
- return tars::TC_Json::writeValue(writeToJson());
- }
- void readFromJson(const tars::JsonValuePtr & p, bool isRequire = true)
- {
- resetDefautlt();
- if(NULL == p.get() || p->getType() != tars::eJsonTypeObj)
- {
- char s[128];
- snprintf(s, sizeof(s), "read 'struct' type mismatch, get type: %d.", (p.get() ? p->getType() : 0));
- throw tars::TC_Json_Exception(s);
- }
- tars::JsonValueObjPtr pObj=tars::JsonValueObjPtr::dynamicCast(p);
- tars::JsonInput::readJson(json,pObj->value["json"], false);
- }
- void readFromJsonString(const string & str)
- {
- readFromJson(tars::TC_Json::getValue(str));
- }
- ostream& display(ostream& _os, int _level=0) const
- {
- tars::TarsDisplayer _ds(_os, _level);
- _ds.display(json,"json");
- return _os;
- }
- ostream& displaySimple(ostream& _os, int _level=0) const
- {
- tars::TarsDisplayer _ds(_os, _level);
- _ds.displaySimple(json, false);
- return _os;
- }
- public:
- map<Test::JsonKey, Test::JsonData> json;
- };
- inline bool operator==(const JsonMap&l, const JsonMap&r)
- {
- return l.json == r.json;
- }
- inline bool operator!=(const JsonMap&l, const JsonMap&r)
- {
- return !(l == r);
- }
- inline ostream& operator<<(ostream & os,const JsonMap&r)
- {
- os << r.writeToJsonString();
- return os;
- }
- inline istream& operator>>(istream& is,JsonMap&l)
- {
- std::istreambuf_iterator<char> eos;
- std::string s(std::istreambuf_iterator<char>(is), eos);
- l.readFromJsonString(s);
- return is;
- }
- /* callback of async proxy for client */
- class HelloPrxCallback: public tars::ServantProxyCallback
- {
- public:
- virtual ~HelloPrxCallback(){}
- virtual void callback_testConHash(tars::Int32 ret, const std::string& sOut)
- { throw std::runtime_error("callback_testConHash() override incorrect."); }
- virtual void callback_testConHash_exception(tars::Int32 ret)
- { throw std::runtime_error("callback_testConHash_exception() override incorrect."); }
- virtual void callback_testCoro(tars::Bool ret, const std::string& sOut)
- { throw std::runtime_error("callback_testCoro() override incorrect."); }
- virtual void callback_testCoro_exception(tars::Int32 ret)
- { throw std::runtime_error("callback_testCoro_exception() override incorrect."); }
- virtual void callback_testDyeing(tars::Int32 ret, const std::string& strOut)
- { throw std::runtime_error("callback_testDyeing() override incorrect."); }
- virtual void callback_testDyeing_exception(tars::Int32 ret)
- { throw std::runtime_error("callback_testDyeing_exception() override incorrect."); }
- virtual void callback_testDyeingTrans(tars::Int32 ret)
- { throw std::runtime_error("callback_testDyeingTrans() override incorrect."); }
- virtual void callback_testDyeingTrans_exception(tars::Int32 ret)
- { throw std::runtime_error("callback_testDyeingTrans_exception() override incorrect."); }
- virtual void callback_testHello(tars::Int32 ret, const std::string& r)
- { throw std::runtime_error("callback_testHello() override incorrect."); }
- virtual void callback_testHello_exception(tars::Int32 ret)
- { throw std::runtime_error("callback_testHello_exception() override incorrect."); }
- virtual void callback_testPid(tars::Int32 ret, const std::string& r)
- { throw std::runtime_error("callback_testPid() override incorrect."); }
- virtual void callback_testPid_exception(tars::Int32 ret)
- { throw std::runtime_error("callback_testPid_exception() override incorrect."); }
- virtual void callback_testSyncTrans(tars::Int32 ret, const std::string& r)
- { throw std::runtime_error("callback_testSyncTrans() override incorrect."); }
- virtual void callback_testSyncTrans_exception(tars::Int32 ret)
- { throw std::runtime_error("callback_testSyncTrans_exception() override incorrect."); }
- virtual void callback_testTimeout(tars::Int32 ret)
- { throw std::runtime_error("callback_testTimeout() override incorrect."); }
- virtual void callback_testTimeout_exception(tars::Int32 ret)
- { throw std::runtime_error("callback_testTimeout_exception() override incorrect."); }
- virtual void callback_testTrans(tars::Int32 ret, const std::string& r)
- { throw std::runtime_error("callback_testTrans() override incorrect."); }
- virtual void callback_testTrans_exception(tars::Int32 ret)
- { throw std::runtime_error("callback_testTrans_exception() override incorrect."); }
- public:
- virtual const map<std::string, std::string> & getResponseContext() const
- {
- CallbackThreadData * pCbtd = CallbackThreadData::getData();
- assert(pCbtd != NULL);
- if(!pCbtd->getContextValid())
- {
- throw TC_Exception("cann't get response context");
- }
- return pCbtd->getResponseContext();
- }
- public:
- virtual int onDispatch(tars::ReqMessagePtr msg)
- {
- static ::std::string __Hello_all[]=
- {
- "testConHash",
- "testCoro",
- "testDyeing",
- "testDyeingTrans",
- "testHello",
- "testPid",
- "testSyncTrans",
- "testTimeout",
- "testTrans"
- };
- pair<string*, string*> r = equal_range(__Hello_all, __Hello_all+9, string(msg->request.sFuncName));
- if(r.first == r.second) return tars::TARSSERVERNOFUNCERR;
- switch(r.first - __Hello_all)
- {
- case 0:
- {
- if (msg->response->iRet != tars::TARSSERVERSUCCESS)
- {
- callback_testConHash_exception(msg->response->iRet);
- return msg->response->iRet;
- }
- tars::TarsInputStream<tars::BufferReader> _is;
- _is.setBuffer(msg->response->sBuffer);
- tars::Int32 _ret;
- _is.read(_ret, 0, true);
- std::string sOut;
- _is.read(sOut, 1, true);
- ServantProxyThreadData *pSptd = ServantProxyThreadData::getData();
- if (pSptd && pSptd->_traceCall)
- {
- string _trace_param_;
- int _trace_param_flag_ = pSptd->needTraceParam(ServantProxyThreadData::TraceContext::EST_CR, _is.size());
- if (ServantProxyThreadData::TraceContext::ENP_NORMAL == _trace_param_flag_)
- {
- tars::JsonValueObjPtr _p_ = new tars::JsonValueObj();
- _p_->value[""] = tars::JsonOutput::writeJson(_ret);
- _p_->value["sOut"] = tars::JsonOutput::writeJson(sOut);
- _trace_param_ = tars::TC_Json::writeValue(_p_);
- }
- else if(ServantProxyThreadData::TraceContext::ENP_OVERMAXLEN == _trace_param_flag_)
- {
- _trace_param_ = "{\"trace_param_over_max_len\":true}";
- }
- TARS_TRACE(pSptd->getTraceKey(ServantProxyThreadData::TraceContext::EST_CR), TRACE_ANNOTATION_CR, "", ServerConfig::Application + "." + ServerConfig::ServerName, "testConHash", 0, _trace_param_, "");
- }
- CallbackThreadData * pCbtd = CallbackThreadData::getData();
- assert(pCbtd != NULL);
- pCbtd->setResponseContext(msg->response->context);
- callback_testConHash(_ret, sOut);
- pCbtd->delResponseContext();
- return tars::TARSSERVERSUCCESS;
- }
- case 1:
- {
- if (msg->response->iRet != tars::TARSSERVERSUCCESS)
- {
- callback_testCoro_exception(msg->response->iRet);
- return msg->response->iRet;
- }
- tars::TarsInputStream<tars::BufferReader> _is;
- _is.setBuffer(msg->response->sBuffer);
- tars::Bool _ret = false;
- _is.read(_ret, 0, true);
- std::string sOut;
- _is.read(sOut, 2, true);
- ServantProxyThreadData *pSptd = ServantProxyThreadData::getData();
- if (pSptd && pSptd->_traceCall)
- {
- string _trace_param_;
- int _trace_param_flag_ = pSptd->needTraceParam(ServantProxyThreadData::TraceContext::EST_CR, _is.size());
- if (ServantProxyThreadData::TraceContext::ENP_NORMAL == _trace_param_flag_)
- {
- tars::JsonValueObjPtr _p_ = new tars::JsonValueObj();
- _p_->value[""] = tars::JsonOutput::writeJson(_ret);
- _p_->value["sOut"] = tars::JsonOutput::writeJson(sOut);
- _trace_param_ = tars::TC_Json::writeValue(_p_);
- }
- else if(ServantProxyThreadData::TraceContext::ENP_OVERMAXLEN == _trace_param_flag_)
- {
- _trace_param_ = "{\"trace_param_over_max_len\":true}";
- }
- TARS_TRACE(pSptd->getTraceKey(ServantProxyThreadData::TraceContext::EST_CR), TRACE_ANNOTATION_CR, "", ServerConfig::Application + "." + ServerConfig::ServerName, "testCoro", 0, _trace_param_, "");
- }
- CallbackThreadData * pCbtd = CallbackThreadData::getData();
- assert(pCbtd != NULL);
- pCbtd->setResponseContext(msg->response->context);
- callback_testCoro(_ret, sOut);
- pCbtd->delResponseContext();
- return tars::TARSSERVERSUCCESS;
- }
- case 2:
- {
- if (msg->response->iRet != tars::TARSSERVERSUCCESS)
- {
- callback_testDyeing_exception(msg->response->iRet);
- return msg->response->iRet;
- }
- tars::TarsInputStream<tars::BufferReader> _is;
- _is.setBuffer(msg->response->sBuffer);
- tars::Int32 _ret;
- _is.read(_ret, 0, true);
- std::string strOut;
- _is.read(strOut, 2, true);
- ServantProxyThreadData *pSptd = ServantProxyThreadData::getData();
- if (pSptd && pSptd->_traceCall)
- {
- string _trace_param_;
- int _trace_param_flag_ = pSptd->needTraceParam(ServantProxyThreadData::TraceContext::EST_CR, _is.size());
- if (ServantProxyThreadData::TraceContext::ENP_NORMAL == _trace_param_flag_)
- {
- tars::JsonValueObjPtr _p_ = new tars::JsonValueObj();
- _p_->value[""] = tars::JsonOutput::writeJson(_ret);
- _p_->value["strOut"] = tars::JsonOutput::writeJson(strOut);
- _trace_param_ = tars::TC_Json::writeValue(_p_);
- }
- else if(ServantProxyThreadData::TraceContext::ENP_OVERMAXLEN == _trace_param_flag_)
- {
- _trace_param_ = "{\"trace_param_over_max_len\":true}";
- }
- TARS_TRACE(pSptd->getTraceKey(ServantProxyThreadData::TraceContext::EST_CR), TRACE_ANNOTATION_CR, "", ServerConfig::Application + "." + ServerConfig::ServerName, "testDyeing", 0, _trace_param_, "");
- }
- CallbackThreadData * pCbtd = CallbackThreadData::getData();
- assert(pCbtd != NULL);
- pCbtd->setResponseContext(msg->response->context);
- callback_testDyeing(_ret, strOut);
- pCbtd->delResponseContext();
- return tars::TARSSERVERSUCCESS;
- }
- case 3:
- {
- if (msg->response->iRet != tars::TARSSERVERSUCCESS)
- {
- callback_testDyeingTrans_exception(msg->response->iRet);
- return msg->response->iRet;
- }
- tars::TarsInputStream<tars::BufferReader> _is;
- _is.setBuffer(msg->response->sBuffer);
- tars::Int32 _ret;
- _is.read(_ret, 0, true);
- ServantProxyThreadData *pSptd = ServantProxyThreadData::getData();
- if (pSptd && pSptd->_traceCall)
- {
- string _trace_param_;
- int _trace_param_flag_ = pSptd->needTraceParam(ServantProxyThreadData::TraceContext::EST_CR, _is.size());
- if (ServantProxyThreadData::TraceContext::ENP_NORMAL == _trace_param_flag_)
- {
- tars::JsonValueObjPtr _p_ = new tars::JsonValueObj();
- _p_->value[""] = tars::JsonOutput::writeJson(_ret);
- _trace_param_ = tars::TC_Json::writeValue(_p_);
- }
- else if(ServantProxyThreadData::TraceContext::ENP_OVERMAXLEN == _trace_param_flag_)
- {
- _trace_param_ = "{\"trace_param_over_max_len\":true}";
- }
- TARS_TRACE(pSptd->getTraceKey(ServantProxyThreadData::TraceContext::EST_CR), TRACE_ANNOTATION_CR, "", ServerConfig::Application + "." + ServerConfig::ServerName, "testDyeingTrans", 0, _trace_param_, "");
- }
- CallbackThreadData * pCbtd = CallbackThreadData::getData();
- assert(pCbtd != NULL);
- pCbtd->setResponseContext(msg->response->context);
- callback_testDyeingTrans(_ret);
- pCbtd->delResponseContext();
- return tars::TARSSERVERSUCCESS;
- }
- case 4:
- {
- if (msg->response->iRet != tars::TARSSERVERSUCCESS)
- {
- callback_testHello_exception(msg->response->iRet);
- return msg->response->iRet;
- }
- tars::TarsInputStream<tars::BufferReader> _is;
- _is.setBuffer(msg->response->sBuffer);
- tars::Int32 _ret;
- _is.read(_ret, 0, true);
- std::string r;
- _is.read(r, 3, true);
- ServantProxyThreadData *pSptd = ServantProxyThreadData::getData();
- if (pSptd && pSptd->_traceCall)
- {
- string _trace_param_;
- int _trace_param_flag_ = pSptd->needTraceParam(ServantProxyThreadData::TraceContext::EST_CR, _is.size());
- if (ServantProxyThreadData::TraceContext::ENP_NORMAL == _trace_param_flag_)
- {
- tars::JsonValueObjPtr _p_ = new tars::JsonValueObj();
- _p_->value[""] = tars::JsonOutput::writeJson(_ret);
- _p_->value["r"] = tars::JsonOutput::writeJson(r);
- _trace_param_ = tars::TC_Json::writeValue(_p_);
- }
- else if(ServantProxyThreadData::TraceContext::ENP_OVERMAXLEN == _trace_param_flag_)
- {
- _trace_param_ = "{\"trace_param_over_max_len\":true}";
- }
- TARS_TRACE(pSptd->getTraceKey(ServantProxyThreadData::TraceContext::EST_CR), TRACE_ANNOTATION_CR, "", ServerConfig::Application + "." + ServerConfig::ServerName, "testHello", 0, _trace_param_, "");
- }
- CallbackThreadData * pCbtd = CallbackThreadData::getData();
- assert(pCbtd != NULL);
- pCbtd->setResponseContext(msg->response->context);
- callback_testHello(_ret, r);
- pCbtd->delResponseContext();
- return tars::TARSSERVERSUCCESS;
- }
- case 5:
- {
- if (msg->response->iRet != tars::TARSSERVERSUCCESS)
- {
- callback_testPid_exception(msg->response->iRet);
- return msg->response->iRet;
- }
- tars::TarsInputStream<tars::BufferReader> _is;
- _is.setBuffer(msg->response->sBuffer);
- tars::Int32 _ret;
- _is.read(_ret, 0, true);
- std::string r;
- _is.read(r, 1, true);
- ServantProxyThreadData *pSptd = ServantProxyThreadData::getData();
- if (pSptd && pSptd->_traceCall)
- {
- string _trace_param_;
- int _trace_param_flag_ = pSptd->needTraceParam(ServantProxyThreadData::TraceContext::EST_CR, _is.size());
- if (ServantProxyThreadData::TraceContext::ENP_NORMAL == _trace_param_flag_)
- {
- tars::JsonValueObjPtr _p_ = new tars::JsonValueObj();
- _p_->value[""] = tars::JsonOutput::writeJson(_ret);
- _p_->value["r"] = tars::JsonOutput::writeJson(r);
- _trace_param_ = tars::TC_Json::writeValue(_p_);
- }
- else if(ServantProxyThreadData::TraceContext::ENP_OVERMAXLEN == _trace_param_flag_)
- {
- _trace_param_ = "{\"trace_param_over_max_len\":true}";
- }
- TARS_TRACE(pSptd->getTraceKey(ServantProxyThreadData::TraceContext::EST_CR), TRACE_ANNOTATION_CR, "", ServerConfig::Application + "." + ServerConfig::ServerName, "testPid", 0, _trace_param_, "");
- }
- CallbackThreadData * pCbtd = CallbackThreadData::getData();
- assert(pCbtd != NULL);
- pCbtd->setResponseContext(msg->response->context);
- callback_testPid(_ret, r);
- pCbtd->delResponseContext();
- return tars::TARSSERVERSUCCESS;
- }
- case 6:
- {
- if (msg->response->iRet != tars::TARSSERVERSUCCESS)
- {
- callback_testSyncTrans_exception(msg->response->iRet);
- return msg->response->iRet;
- }
- tars::TarsInputStream<tars::BufferReader> _is;
- _is.setBuffer(msg->response->sBuffer);
- tars::Int32 _ret;
- _is.read(_ret, 0, true);
- std::string r;
- _is.read(r, 3, true);
- ServantProxyThreadData *pSptd = ServantProxyThreadData::getData();
- if (pSptd && pSptd->_traceCall)
- {
- string _trace_param_;
- int _trace_param_flag_ = pSptd->needTraceParam(ServantProxyThreadData::TraceContext::EST_CR, _is.size());
- if (ServantProxyThreadData::TraceContext::ENP_NORMAL == _trace_param_flag_)
- {
- tars::JsonValueObjPtr _p_ = new tars::JsonValueObj();
- _p_->value[""] = tars::JsonOutput::writeJson(_ret);
- _p_->value["r"] = tars::JsonOutput::writeJson(r);
- _trace_param_ = tars::TC_Json::writeValue(_p_);
- }
- else if(ServantProxyThreadData::TraceContext::ENP_OVERMAXLEN == _trace_param_flag_)
- {
- _trace_param_ = "{\"trace_param_over_max_len\":true}";
- }
- TARS_TRACE(pSptd->getTraceKey(ServantProxyThreadData::TraceContext::EST_CR), TRACE_ANNOTATION_CR, "", ServerConfig::Application + "." + ServerConfig::ServerName, "testSyncTrans", 0, _trace_param_, "");
- }
- CallbackThreadData * pCbtd = CallbackThreadData::getData();
- assert(pCbtd != NULL);
- pCbtd->setResponseContext(msg->response->context);
- callback_testSyncTrans(_ret, r);
- pCbtd->delResponseContext();
- return tars::TARSSERVERSUCCESS;
- }
- case 7:
- {
- if (msg->response->iRet != tars::TARSSERVERSUCCESS)
- {
- callback_testTimeout_exception(msg->response->iRet);
- return msg->response->iRet;
- }
- tars::TarsInputStream<tars::BufferReader> _is;
- _is.setBuffer(msg->response->sBuffer);
- tars::Int32 _ret;
- _is.read(_ret, 0, true);
- ServantProxyThreadData *pSptd = ServantProxyThreadData::getData();
- if (pSptd && pSptd->_traceCall)
- {
- string _trace_param_;
- int _trace_param_flag_ = pSptd->needTraceParam(ServantProxyThreadData::TraceContext::EST_CR, _is.size());
- if (ServantProxyThreadData::TraceContext::ENP_NORMAL == _trace_param_flag_)
- {
- tars::JsonValueObjPtr _p_ = new tars::JsonValueObj();
- _p_->value[""] = tars::JsonOutput::writeJson(_ret);
- _trace_param_ = tars::TC_Json::writeValue(_p_);
- }
- else if(ServantProxyThreadData::TraceContext::ENP_OVERMAXLEN == _trace_param_flag_)
- {
- _trace_param_ = "{\"trace_param_over_max_len\":true}";
- }
- TARS_TRACE(pSptd->getTraceKey(ServantProxyThreadData::TraceContext::EST_CR), TRACE_ANNOTATION_CR, "", ServerConfig::Application + "." + ServerConfig::ServerName, "testTimeout", 0, _trace_param_, "");
- }
- CallbackThreadData * pCbtd = CallbackThreadData::getData();
- assert(pCbtd != NULL);
- pCbtd->setResponseContext(msg->response->context);
- callback_testTimeout(_ret);
- pCbtd->delResponseContext();
- return tars::TARSSERVERSUCCESS;
- }
- case 8:
- {
- if (msg->response->iRet != tars::TARSSERVERSUCCESS)
- {
- callback_testTrans_exception(msg->response->iRet);
- return msg->response->iRet;
- }
- tars::TarsInputStream<tars::BufferReader> _is;
- _is.setBuffer(msg->response->sBuffer);
- tars::Int32 _ret;
- _is.read(_ret, 0, true);
- std::string r;
- _is.read(r, 3, true);
- ServantProxyThreadData *pSptd = ServantProxyThreadData::getData();
- if (pSptd && pSptd->_traceCall)
- {
- string _trace_param_;
- int _trace_param_flag_ = pSptd->needTraceParam(ServantProxyThreadData::TraceContext::EST_CR, _is.size());
- if (ServantProxyThreadData::TraceContext::ENP_NORMAL == _trace_param_flag_)
- {
- tars::JsonValueObjPtr _p_ = new tars::JsonValueObj();
- _p_->value[""] = tars::JsonOutput::writeJson(_ret);
- _p_->value["r"] = tars::JsonOutput::writeJson(r);
- _trace_param_ = tars::TC_Json::writeValue(_p_);
- }
- else if(ServantProxyThreadData::TraceContext::ENP_OVERMAXLEN == _trace_param_flag_)
- {
- _trace_param_ = "{\"trace_param_over_max_len\":true}";
- }
- TARS_TRACE(pSptd->getTraceKey(ServantProxyThreadData::TraceContext::EST_CR), TRACE_ANNOTATION_CR, "", ServerConfig::Application + "." + ServerConfig::ServerName, "testTrans", 0, _trace_param_, "");
- }
- CallbackThreadData * pCbtd = CallbackThreadData::getData();
- assert(pCbtd != NULL);
- pCbtd->setResponseContext(msg->response->context);
- callback_testTrans(_ret, r);
- pCbtd->delResponseContext();
- return tars::TARSSERVERSUCCESS;
- }
- }
- return tars::TARSSERVERNOFUNCERR;
- }
- };
- typedef tars::TC_AutoPtr<HelloPrxCallback> HelloPrxCallbackPtr;
- //callback of promise async proxy for client
- class HelloPrxCallbackPromise: public tars::ServantProxyCallback
- {
- public:
- virtual ~HelloPrxCallbackPromise(){}
- public:
- struct PromisetestConHash: virtual public TC_HandleBase
- {
- public:
- tars::Int32 _ret;
- std::string sOut;
- map<std::string, std::string> _mRspContext;
- };
-
- typedef tars::TC_AutoPtr< HelloPrxCallbackPromise::PromisetestConHash > PromisetestConHashPtr;
- HelloPrxCallbackPromise(const tars::Promise< HelloPrxCallbackPromise::PromisetestConHashPtr > &promise)
- : _promise_testConHash(promise)
- {}
-
- virtual void callback_testConHash(const HelloPrxCallbackPromise::PromisetestConHashPtr &ptr)
- {
- _promise_testConHash.setValue(ptr);
- }
- virtual void callback_testConHash_exception(tars::Int32 ret)
- {
- std::string str("");
- str += "Function:testConHash_exception|Ret:";
- str += TC_Common::tostr(ret);
- _promise_testConHash.setException(tars::copyException(str, ret));
- }
- protected:
- tars::Promise< HelloPrxCallbackPromise::PromisetestConHashPtr > _promise_testConHash;
- public:
- struct PromisetestCoro: virtual public TC_HandleBase
- {
- public:
- tars::Bool _ret;
- std::string sOut;
- map<std::string, std::string> _mRspContext;
- };
-
- typedef tars::TC_AutoPtr< HelloPrxCallbackPromise::PromisetestCoro > PromisetestCoroPtr;
- HelloPrxCallbackPromise(const tars::Promise< HelloPrxCallbackPromise::PromisetestCoroPtr > &promise)
- : _promise_testCoro(promise)
- {}
-
- virtual void callback_testCoro(const HelloPrxCallbackPromise::PromisetestCoroPtr &ptr)
- {
- _promise_testCoro.setValue(ptr);
- }
- virtual void callback_testCoro_exception(tars::Int32 ret)
- {
- std::string str("");
- str += "Function:testCoro_exception|Ret:";
- str += TC_Common::tostr(ret);
- _promise_testCoro.setException(tars::copyException(str, ret));
- }
- protected:
- tars::Promise< HelloPrxCallbackPromise::PromisetestCoroPtr > _promise_testCoro;
- public:
- struct PromisetestDyeing: virtual public TC_HandleBase
- {
- public:
- tars::Int32 _ret;
- std::string strOut;
- map<std::string, std::string> _mRspContext;
- };
-
- typedef tars::TC_AutoPtr< HelloPrxCallbackPromise::PromisetestDyeing > PromisetestDyeingPtr;
- HelloPrxCallbackPromise(const tars::Promise< HelloPrxCallbackPromise::PromisetestDyeingPtr > &promise)
- : _promise_testDyeing(promise)
- {}
-
- virtual void callback_testDyeing(const HelloPrxCallbackPromise::PromisetestDyeingPtr &ptr)
- {
- _promise_testDyeing.setValue(ptr);
- }
- virtual void callback_testDyeing_exception(tars::Int32 ret)
- {
- std::string str("");
- str += "Function:testDyeing_exception|Ret:";
- str += TC_Common::tostr(ret);
- _promise_testDyeing.setException(tars::copyException(str, ret));
- }
- protected:
- tars::Promise< HelloPrxCallbackPromise::PromisetestDyeingPtr > _promise_testDyeing;
- public:
- struct PromisetestDyeingTrans: virtual public TC_HandleBase
- {
- public:
- tars::Int32 _ret;
- map<std::string, std::string> _mRspContext;
- };
-
- typedef tars::TC_AutoPtr< HelloPrxCallbackPromise::PromisetestDyeingTrans > PromisetestDyeingTransPtr;
- HelloPrxCallbackPromise(const tars::Promise< HelloPrxCallbackPromise::PromisetestDyeingTransPtr > &promise)
- : _promise_testDyeingTrans(promise)
- {}
-
- virtual void callback_testDyeingTrans(const HelloPrxCallbackPromise::PromisetestDyeingTransPtr &ptr)
- {
- _promise_testDyeingTrans.setValue(ptr);
- }
- virtual void callback_testDyeingTrans_exception(tars::Int32 ret)
- {
- std::string str("");
- str += "Function:testDyeingTrans_exception|Ret:";
- str += TC_Common::tostr(ret);
- _promise_testDyeingTrans.setException(tars::copyException(str, ret));
- }
- protected:
- tars::Promise< HelloPrxCallbackPromise::PromisetestDyeingTransPtr > _promise_testDyeingTrans;
- public:
- struct PromisetestHello: virtual public TC_HandleBase
- {
- public:
- tars::Int32 _ret;
- std::string r;
- map<std::string, std::string> _mRspContext;
- };
-
- typedef tars::TC_AutoPtr< HelloPrxCallbackPromise::PromisetestHello > PromisetestHelloPtr;
- HelloPrxCallbackPromise(const tars::Promise< HelloPrxCallbackPromise::PromisetestHelloPtr > &promise)
- : _promise_testHello(promise)
- {}
-
- virtual void callback_testHello(const HelloPrxCallbackPromise::PromisetestHelloPtr &ptr)
- {
- _promise_testHello.setValue(ptr);
- }
- virtual void callback_testHello_exception(tars::Int32 ret)
- {
- std::string str("");
- str += "Function:testHello_exception|Ret:";
- str += TC_Common::tostr(ret);
- _promise_testHello.setException(tars::copyException(str, ret));
- }
- protected:
- tars::Promise< HelloPrxCallbackPromise::PromisetestHelloPtr > _promise_testHello;
- public:
- struct PromisetestPid: virtual public TC_HandleBase
- {
- public:
- tars::Int32 _ret;
- std::string r;
- map<std::string, std::string> _mRspContext;
- };
-
- typedef tars::TC_AutoPtr< HelloPrxCallbackPromise::PromisetestPid > PromisetestPidPtr;
- HelloPrxCallbackPromise(const tars::Promise< HelloPrxCallbackPromise::PromisetestPidPtr > &promise)
- : _promise_testPid(promise)
- {}
-
- virtual void callback_testPid(const HelloPrxCallbackPromise::PromisetestPidPtr &ptr)
- {
- _promise_testPid.setValue(ptr);
- }
- virtual void callback_testPid_exception(tars::Int32 ret)
- {
- std::string str("");
- str += "Function:testPid_exception|Ret:";
- str += TC_Common::tostr(ret);
- _promise_testPid.setException(tars::copyException(str, ret));
- }
- protected:
- tars::Promise< HelloPrxCallbackPromise::PromisetestPidPtr > _promise_testPid;
- public:
- struct PromisetestSyncTrans: virtual public TC_HandleBase
- {
- public:
- tars::Int32 _ret;
- std::string r;
- map<std::string, std::string> _mRspContext;
- };
-
- typedef tars::TC_AutoPtr< HelloPrxCallbackPromise::PromisetestSyncTrans > PromisetestSyncTransPtr;
- HelloPrxCallbackPromise(const tars::Promise< HelloPrxCallbackPromise::PromisetestSyncTransPtr > &promise)
- : _promise_testSyncTrans(promise)
- {}
-
- virtual void callback_testSyncTrans(const HelloPrxCallbackPromise::PromisetestSyncTransPtr &ptr)
- {
- _promise_testSyncTrans.setValue(ptr);
- }
- virtual void callback_testSyncTrans_exception(tars::Int32 ret)
- {
- std::string str("");
- str += "Function:testSyncTrans_exception|Ret:";
- str += TC_Common::tostr(ret);
- _promise_testSyncTrans.setException(tars::copyException(str, ret));
- }
- protected:
- tars::Promise< HelloPrxCallbackPromise::PromisetestSyncTransPtr > _promise_testSyncTrans;
- public:
- struct PromisetestTimeout: virtual public TC_HandleBase
- {
- public:
- tars::Int32 _ret;
- map<std::string, std::string> _mRspContext;
- };
-
- typedef tars::TC_AutoPtr< HelloPrxCallbackPromise::PromisetestTimeout > PromisetestTimeoutPtr;
- HelloPrxCallbackPromise(const tars::Promise< HelloPrxCallbackPromise::PromisetestTimeoutPtr > &promise)
- : _promise_testTimeout(promise)
- {}
-
- virtual void callback_testTimeout(const HelloPrxCallbackPromise::PromisetestTimeoutPtr &ptr)
- {
- _promise_testTimeout.setValue(ptr);
- }
- virtual void callback_testTimeout_exception(tars::Int32 ret)
- {
- std::string str("");
- str += "Function:testTimeout_exception|Ret:";
- str += TC_Common::tostr(ret);
- _promise_testTimeout.setException(tars::copyException(str, ret));
- }
- protected:
- tars::Promise< HelloPrxCallbackPromise::PromisetestTimeoutPtr > _promise_testTimeout;
- public:
- struct PromisetestTrans: virtual public TC_HandleBase
- {
- public:
- tars::Int32 _ret;
- std::string r;
- map<std::string, std::string> _mRspContext;
- };
-
- typedef tars::TC_AutoPtr< HelloPrxCallbackPromise::PromisetestTrans > PromisetestTransPtr;
- HelloPrxCallbackPromise(const tars::Promise< HelloPrxCallbackPromise::PromisetestTransPtr > &promise)
- : _promise_testTrans(promise)
- {}
-
- virtual void callback_testTrans(const HelloPrxCallbackPromise::PromisetestTransPtr &ptr)
- {
- _promise_testTrans.setValue(ptr);
- }
- virtual void callback_testTrans_exception(tars::Int32 ret)
- {
- std::string str("");
- str += "Function:testTrans_exception|Ret:";
- str += TC_Common::tostr(ret);
- _promise_testTrans.setException(tars::copyException(str, ret));
- }
- protected:
- tars::Promise< HelloPrxCallbackPromise::PromisetestTransPtr > _promise_testTrans;
- public:
- virtual int onDispatch(tars::ReqMessagePtr msg)
- {
- static ::std::string __Hello_all[]=
- {
- "testConHash",
- "testCoro",
- "testDyeing",
- "testDyeingTrans",
- "testHello",
- "testPid",
- "testSyncTrans",
- "testTimeout",
- "testTrans"
- };
- pair<string*, string*> r = equal_range(__Hello_all, __Hello_all+9, string(msg->request.sFuncName));
- if(r.first == r.second) return tars::TARSSERVERNOFUNCERR;
- switch(r.first - __Hello_all)
- {
- case 0:
- {
- if (msg->response->iRet != tars::TARSSERVERSUCCESS)
- {
- callback_testConHash_exception(msg->response->iRet);
- return msg->response->iRet;
- }
- tars::TarsInputStream<tars::BufferReader> _is;
- _is.setBuffer(msg->response->sBuffer);
- HelloPrxCallbackPromise::PromisetestConHashPtr ptr = new HelloPrxCallbackPromise::PromisetestConHash();
- try
- {
- _is.read(ptr->_ret, 0, true);
- _is.read(ptr->sOut, 1, true);
- }
- catch(std::exception &ex)
- {
- callback_testConHash_exception(tars::TARSCLIENTDECODEERR);
- return tars::TARSCLIENTDECODEERR;
- }
- catch(...)
- {
- callback_testConHash_exception(tars::TARSCLIENTDECODEERR);
- return tars::TARSCLIENTDECODEERR;
- }
- ptr->_mRspContext = msg->response->context;
- callback_testConHash(ptr);
- return tars::TARSSERVERSUCCESS;
- }
- case 1:
- {
- if (msg->response->iRet != tars::TARSSERVERSUCCESS)
- {
- callback_testCoro_exception(msg->response->iRet);
- return msg->response->iRet;
- }
- tars::TarsInputStream<tars::BufferReader> _is;
- _is.setBuffer(msg->response->sBuffer);
- HelloPrxCallbackPromise::PromisetestCoroPtr ptr = new HelloPrxCallbackPromise::PromisetestCoro();
- try
- {
- ptr->_ret = false;
- _is.read(ptr->_ret, 0, true);
- _is.read(ptr->sOut, 2, true);
- }
- catch(std::exception &ex)
- {
- callback_testCoro_exception(tars::TARSCLIENTDECODEERR);
- return tars::TARSCLIENTDECODEERR;
- }
- catch(...)
- {
- callback_testCoro_exception(tars::TARSCLIENTDECODEERR);
- return tars::TARSCLIENTDECODEERR;
- }
- ptr->_mRspContext = msg->response->context;
- callback_testCoro(ptr);
- return tars::TARSSERVERSUCCESS;
- }
- case 2:
- {
- if (msg->response->iRet != tars::TARSSERVERSUCCESS)
- {
- callback_testDyeing_exception(msg->response->iRet);
- return msg->response->iRet;
- }
- tars::TarsInputStream<tars::BufferReader> _is;
- _is.setBuffer(msg->response->sBuffer);
- HelloPrxCallbackPromise::PromisetestDyeingPtr ptr = new HelloPrxCallbackPromise::PromisetestDyeing();
- try
- {
- _is.read(ptr->_ret, 0, true);
- _is.read(ptr->strOut, 2, true);
- }
- catch(std::exception &ex)
- {
- callback_testDyeing_exception(tars::TARSCLIENTDECODEERR);
- return tars::TARSCLIENTDECODEERR;
- }
- catch(...)
- {
- callback_testDyeing_exception(tars::TARSCLIENTDECODEERR);
- return tars::TARSCLIENTDECODEERR;
- }
- ptr->_mRspContext = msg->response->context;
- callback_testDyeing(ptr);
- return tars::TARSSERVERSUCCESS;
- }
- case 3:
- {
- if (msg->response->iRet != tars::TARSSERVERSUCCESS)
- {
- callback_testDyeingTrans_exception(msg->response->iRet);
- return msg->response->iRet;
- }
- tars::TarsInputStream<tars::BufferReader> _is;
- _is.setBuffer(msg->response->sBuffer);
- HelloPrxCallbackPromise::PromisetestDyeingTransPtr ptr = new HelloPrxCallbackPromise::PromisetestDyeingTrans();
- try
- {
- _is.read(ptr->_ret, 0, true);
- }
- catch(std::exception &ex)
- {
- callback_testDyeingTrans_exception(tars::TARSCLIENTDECODEERR);
- return tars::TARSCLIENTDECODEERR;
- }
- catch(...)
- {
- callback_testDyeingTrans_exception(tars::TARSCLIENTDECODEERR);
- return tars::TARSCLIENTDECODEERR;
- }
- ptr->_mRspContext = msg->response->context;
- callback_testDyeingTrans(ptr);
- return tars::TARSSERVERSUCCESS;
- }
- case 4:
- {
- if (msg->response->iRet != tars::TARSSERVERSUCCESS)
- {
- callback_testHello_exception(msg->response->iRet);
- return msg->response->iRet;
- }
- tars::TarsInputStream<tars::BufferReader> _is;
- _is.setBuffer(msg->response->sBuffer);
- HelloPrxCallbackPromise::PromisetestHelloPtr ptr = new HelloPrxCallbackPromise::PromisetestHello();
- try
- {
- _is.read(ptr->_ret, 0, true);
- _is.read(ptr->r, 3, true);
- }
- catch(std::exception &ex)
- {
- callback_testHello_exception(tars::TARSCLIENTDECODEERR);
- return tars::TARSCLIENTDECODEERR;
- }
- catch(...)
- {
- callback_testHello_exception(tars::TARSCLIENTDECODEERR);
- return tars::TARSCLIENTDECODEERR;
- }
- ptr->_mRspContext = msg->response->context;
- callback_testHello(ptr);
- return tars::TARSSERVERSUCCESS;
- }
- case 5:
- {
- if (msg->response->iRet != tars::TARSSERVERSUCCESS)
- {
- callback_testPid_exception(msg->response->iRet);
- return msg->response->iRet;
- }
- tars::TarsInputStream<tars::BufferReader> _is;
- _is.setBuffer(msg->response->sBuffer);
- HelloPrxCallbackPromise::PromisetestPidPtr ptr = new HelloPrxCallbackPromise::PromisetestPid();
- try
- {
- _is.read(ptr->_ret, 0, true);
- _is.read(ptr->r, 1, true);
- }
- catch(std::exception &ex)
- {
- callback_testPid_exception(tars::TARSCLIENTDECODEERR);
- return tars::TARSCLIENTDECODEERR;
- }
- catch(...)
- {
- callback_testPid_exception(tars::TARSCLIENTDECODEERR);
- return tars::TARSCLIENTDECODEERR;
- }
- ptr->_mRspContext = msg->response->context;
- callback_testPid(ptr);
- return tars::TARSSERVERSUCCESS;
- }
- case 6:
- {
- if (msg->response->iRet != tars::TARSSERVERSUCCESS)
- {
- callback_testSyncTrans_exception(msg->response->iRet);
- return msg->response->iRet;
- }
- tars::TarsInputStream<tars::BufferReader> _is;
- _is.setBuffer(msg->response->sBuffer);
- HelloPrxCallbackPromise::PromisetestSyncTransPtr ptr = new HelloPrxCallbackPromise::PromisetestSyncTrans();
- try
- {
- _is.read(ptr->_ret, 0, true);
- _is.read(ptr->r, 3, true);
- }
- catch(std::exception &ex)
- {
- callback_testSyncTrans_exception(tars::TARSCLIENTDECODEERR);
- return tars::TARSCLIENTDECODEERR;
- }
- catch(...)
- {
- callback_testSyncTrans_exception(tars::TARSCLIENTDECODEERR);
- return tars::TARSCLIENTDECODEERR;
- }
- ptr->_mRspContext = msg->response->context;
- callback_testSyncTrans(ptr);
- return tars::TARSSERVERSUCCESS;
- }
- case 7:
- {
- if (msg->response->iRet != tars::TARSSERVERSUCCESS)
- {
- callback_testTimeout_exception(msg->response->iRet);
- return msg->response->iRet;
- }
- tars::TarsInputStream<tars::BufferReader> _is;
- _is.setBuffer(msg->response->sBuffer);
- HelloPrxCallbackPromise::PromisetestTimeoutPtr ptr = new HelloPrxCallbackPromise::PromisetestTimeout();
- try
- {
- _is.read(ptr->_ret, 0, true);
- }
- catch(std::exception &ex)
- {
- callback_testTimeout_exception(tars::TARSCLIENTDECODEERR);
- return tars::TARSCLIENTDECODEERR;
- }
- catch(...)
- {
- callback_testTimeout_exception(tars::TARSCLIENTDECODEERR);
- return tars::TARSCLIENTDECODEERR;
- }
- ptr->_mRspContext = msg->response->context;
- callback_testTimeout(ptr);
- return tars::TARSSERVERSUCCESS;
- }
- case 8:
- {
- if (msg->response->iRet != tars::TARSSERVERSUCCESS)
- {
- callback_testTrans_exception(msg->response->iRet);
- return msg->response->iRet;
- }
- tars::TarsInputStream<tars::BufferReader> _is;
- _is.setBuffer(msg->response->sBuffer);
- HelloPrxCallbackPromise::PromisetestTransPtr ptr = new HelloPrxCallbackPromise::PromisetestTrans();
- try
- {
- _is.read(ptr->_ret, 0, true);
- _is.read(ptr->r, 3, true);
- }
- catch(std::exception &ex)
- {
- callback_testTrans_exception(tars::TARSCLIENTDECODEERR);
- return tars::TARSCLIENTDECODEERR;
- }
- catch(...)
- {
- callback_testTrans_exception(tars::TARSCLIENTDECODEERR);
- return tars::TARSCLIENTDECODEERR;
- }
- ptr->_mRspContext = msg->response->context;
- callback_testTrans(ptr);
- return tars::TARSSERVERSUCCESS;
- }
- }
- return tars::TARSSERVERNOFUNCERR;
- }
- };
- typedef tars::TC_AutoPtr<HelloPrxCallbackPromise> HelloPrxCallbackPromisePtr;
- /* callback of coroutine async proxy for client */
- class HelloCoroPrxCallback: public HelloPrxCallback
- {
- public:
- virtual ~HelloCoroPrxCallback(){}
- public:
- virtual const map<std::string, std::string> & getResponseContext() const { return _mRspContext; }
- virtual void setResponseContext(const map<std::string, std::string> &mContext) { _mRspContext = mContext; }
- public:
- int onDispatch(tars::ReqMessagePtr msg)
- {
- static ::std::string __Hello_all[]=
- {
- "testConHash",
- "testCoro",
- "testDyeing",
- "testDyeingTrans",
- "testHello",
- "testPid",
- "testSyncTrans",
- "testTimeout",
- "testTrans"
- };
- pair<string*, string*> r = equal_range(__Hello_all, __Hello_all+9, string(msg->request.sFuncName));
- if(r.first == r.second) return tars::TARSSERVERNOFUNCERR;
- switch(r.first - __Hello_all)
- {
- case 0:
- {
- if (msg->response->iRet != tars::TARSSERVERSUCCESS)
- {
- callback_testConHash_exception(msg->response->iRet);
- return msg->response->iRet;
- }
- tars::TarsInputStream<tars::BufferReader> _is;
- _is.setBuffer(msg->response->sBuffer);
- try
- {
- tars::Int32 _ret;
- _is.read(_ret, 0, true);
- std::string sOut;
- _is.read(sOut, 1, true);
- setResponseContext(msg->response->context);
- callback_testConHash(_ret, sOut);
- }
- catch(std::exception &ex)
- {
- callback_testConHash_exception(tars::TARSCLIENTDECODEERR);
- return tars::TARSCLIENTDECODEERR;
- }
- catch(...)
- {
- callback_testConHash_exception(tars::TARSCLIENTDECODEERR);
- return tars::TARSCLIENTDECODEERR;
- }
- return tars::TARSSERVERSUCCESS;
- }
- case 1:
- {
- if (msg->response->iRet != tars::TARSSERVERSUCCESS)
- {
- callback_testCoro_exception(msg->response->iRet);
- return msg->response->iRet;
- }
- tars::TarsInputStream<tars::BufferReader> _is;
- _is.setBuffer(msg->response->sBuffer);
- try
- {
- tars::Bool _ret = false;
- _is.read(_ret, 0, true);
- std::string sOut;
- _is.read(sOut, 2, true);
- setResponseContext(msg->response->context);
- callback_testCoro(_ret, sOut);
- }
- catch(std::exception &ex)
- {
- callback_testCoro_exception(tars::TARSCLIENTDECODEERR);
- return tars::TARSCLIENTDECODEERR;
- }
- catch(...)
- {
- callback_testCoro_exception(tars::TARSCLIENTDECODEERR);
- return tars::TARSCLIENTDECODEERR;
- }
- return tars::TARSSERVERSUCCESS;
- }
- case 2:
- {
- if (msg->response->iRet != tars::TARSSERVERSUCCESS)
- {
- callback_testDyeing_exception(msg->response->iRet);
- return msg->response->iRet;
- }
- tars::TarsInputStream<tars::BufferReader> _is;
- _is.setBuffer(msg->response->sBuffer);
- try
- {
- tars::Int32 _ret;
- _is.read(_ret, 0, true);
- std::string strOut;
- _is.read(strOut, 2, true);
- setResponseContext(msg->response->context);
- callback_testDyeing(_ret, strOut);
- }
- catch(std::exception &ex)
- {
- callback_testDyeing_exception(tars::TARSCLIENTDECODEERR);
- return tars::TARSCLIENTDECODEERR;
- }
- catch(...)
- {
- callback_testDyeing_exception(tars::TARSCLIENTDECODEERR);
- return tars::TARSCLIENTDECODEERR;
- }
- return tars::TARSSERVERSUCCESS;
- }
- case 3:
- {
- if (msg->response->iRet != tars::TARSSERVERSUCCESS)
- {
- callback_testDyeingTrans_exception(msg->response->iRet);
- return msg->response->iRet;
- }
- tars::TarsInputStream<tars::BufferReader> _is;
- _is.setBuffer(msg->response->sBuffer);
- try
- {
- tars::Int32 _ret;
- _is.read(_ret, 0, true);
- setResponseContext(msg->response->context);
- callback_testDyeingTrans(_ret);
- }
- catch(std::exception &ex)
- {
- callback_testDyeingTrans_exception(tars::TARSCLIENTDECODEERR);
- return tars::TARSCLIENTDECODEERR;
- }
- catch(...)
- {
- callback_testDyeingTrans_exception(tars::TARSCLIENTDECODEERR);
- return tars::TARSCLIENTDECODEERR;
- }
- return tars::TARSSERVERSUCCESS;
- }
- case 4:
- {
- if (msg->response->iRet != tars::TARSSERVERSUCCESS)
- {
- callback_testHello_exception(msg->response->iRet);
- return msg->response->iRet;
- }
- tars::TarsInputStream<tars::BufferReader> _is;
- _is.setBuffer(msg->response->sBuffer);
- try
- {
- tars::Int32 _ret;
- _is.read(_ret, 0, true);
- std::string r;
- _is.read(r, 3, true);
- setResponseContext(msg->response->context);
- callback_testHello(_ret, r);
- }
- catch(std::exception &ex)
- {
- callback_testHello_exception(tars::TARSCLIENTDECODEERR);
- return tars::TARSCLIENTDECODEERR;
- }
- catch(...)
- {
- callback_testHello_exception(tars::TARSCLIENTDECODEERR);
- return tars::TARSCLIENTDECODEERR;
- }
- return tars::TARSSERVERSUCCESS;
- }
- case 5:
- {
- if (msg->response->iRet != tars::TARSSERVERSUCCESS)
- {
- callback_testPid_exception(msg->response->iRet);
- return msg->response->iRet;
- }
- tars::TarsInputStream<tars::BufferReader> _is;
- _is.setBuffer(msg->response->sBuffer);
- try
- {
- tars::Int32 _ret;
- _is.read(_ret, 0, true);
- std::string r;
- _is.read(r, 1, true);
- setResponseContext(msg->response->context);
- callback_testPid(_ret, r);
- }
- catch(std::exception &ex)
- {
- callback_testPid_exception(tars::TARSCLIENTDECODEERR);
- return tars::TARSCLIENTDECODEERR;
- }
- catch(...)
- {
- callback_testPid_exception(tars::TARSCLIENTDECODEERR);
- return tars::TARSCLIENTDECODEERR;
- }
- return tars::TARSSERVERSUCCESS;
- }
- case 6:
- {
- if (msg->response->iRet != tars::TARSSERVERSUCCESS)
- {
- callback_testSyncTrans_exception(msg->response->iRet);
- return msg->response->iRet;
- }
- tars::TarsInputStream<tars::BufferReader> _is;
- _is.setBuffer(msg->response->sBuffer);
- try
- {
- tars::Int32 _ret;
- _is.read(_ret, 0, true);
- std::string r;
- _is.read(r, 3, true);
- setResponseContext(msg->response->context);
- callback_testSyncTrans(_ret, r);
- }
- catch(std::exception &ex)
- {
- callback_testSyncTrans_exception(tars::TARSCLIENTDECODEERR);
- return tars::TARSCLIENTDECODEERR;
- }
- catch(...)
- {
- callback_testSyncTrans_exception(tars::TARSCLIENTDECODEERR);
- return tars::TARSCLIENTDECODEERR;
- }
- return tars::TARSSERVERSUCCESS;
- }
- case 7:
- {
- if (msg->response->iRet != tars::TARSSERVERSUCCESS)
- {
- callback_testTimeout_exception(msg->response->iRet);
- return msg->response->iRet;
- }
- tars::TarsInputStream<tars::BufferReader> _is;
- _is.setBuffer(msg->response->sBuffer);
- try
- {
- tars::Int32 _ret;
- _is.read(_ret, 0, true);
- setResponseContext(msg->response->context);
- callback_testTimeout(_ret);
- }
- catch(std::exception &ex)
- {
- callback_testTimeout_exception(tars::TARSCLIENTDECODEERR);
- return tars::TARSCLIENTDECODEERR;
- }
- catch(...)
- {
- callback_testTimeout_exception(tars::TARSCLIENTDECODEERR);
- return tars::TARSCLIENTDECODEERR;
- }
- return tars::TARSSERVERSUCCESS;
- }
- case 8:
- {
- if (msg->response->iRet != tars::TARSSERVERSUCCESS)
- {
- callback_testTrans_exception(msg->response->iRet);
- return msg->response->iRet;
- }
- tars::TarsInputStream<tars::BufferReader> _is;
- _is.setBuffer(msg->response->sBuffer);
- try
- {
- tars::Int32 _ret;
- _is.read(_ret, 0, true);
- std::string r;
- _is.read(r, 3, true);
- setResponseContext(msg->response->context);
- callback_testTrans(_ret, r);
- }
- catch(std::exception &ex)
- {
- callback_testTrans_exception(tars::TARSCLIENTDECODEERR);
- return tars::TARSCLIENTDECODEERR;
- }
- catch(...)
- {
- callback_testTrans_exception(tars::TARSCLIENTDECODEERR);
- return tars::TARSCLIENTDECODEERR;
- }
- return tars::TARSSERVERSUCCESS;
- }
- }
- return tars::TARSSERVERNOFUNCERR;
- }
- protected:
- map<std::string, std::string> _mRspContext;
- };
- typedef tars::TC_AutoPtr<HelloCoroPrxCallback> HelloCoroPrxCallbackPtr;
- /* proxy for client */
- class HelloProxy : public tars::ServantProxy
- {
- public:
- typedef map<string, string> TARS_CONTEXT;
- tars::Int32 testConHash(std::string &sOut,const map<string, string> &context = TARS_CONTEXT(),map<string, string> * pResponseContext = NULL)
- {
- tars::TarsOutputStream<tars::BufferWriterVector> _os;
- _os.write(sOut, 1);
- ServantProxyThreadData *pSptd = ServantProxyThreadData::getData();
- if (pSptd && pSptd->_traceCall)
- {
- pSptd->newSpan();
- string _trace_param_;
- int _trace_param_flag_ = pSptd->needTraceParam(ServantProxyThreadData::TraceContext::EST_CS, _os.getLength());
- if (ServantProxyThreadData::TraceContext::ENP_NORMAL == _trace_param_flag_)
- {
- tars::JsonValueObjPtr _p_ = new tars::JsonValueObj();
- _trace_param_ = tars::TC_Json::writeValue(_p_);
- }
- else if(ServantProxyThreadData::TraceContext::ENP_OVERMAXLEN == _trace_param_flag_)
- {
- _trace_param_ = "{\"trace_param_over_max_len\":true}";
- }
- TARS_TRACE(pSptd->getTraceKey(ServantProxyThreadData::TraceContext::EST_CS), TRACE_ANNOTATION_CS, ServerConfig::Application + "." + ServerConfig::ServerName, tars_name(), "testConHash", 0, _trace_param_, "");
- }
- std::map<string, string> _mStatus;
- shared_ptr<tars::ResponsePacket> rep = tars_invoke(tars::TARSNORMAL,"testConHash", _os, context, _mStatus);
- if(pResponseContext)
- {
- pResponseContext->swap(rep->context);
- }
- tars::TarsInputStream<tars::BufferReader> _is;
- _is.setBuffer(rep->sBuffer);
- tars::Int32 _ret;
- _is.read(_ret, 0, true);
- _is.read(sOut, 1, true);
- if (pSptd && pSptd->_traceCall)
- {
- string _trace_param_;
- int _trace_param_flag_ = pSptd->needTraceParam(ServantProxyThreadData::TraceContext::EST_CR, _is.size());
- if (ServantProxyThreadData::TraceContext::ENP_NORMAL == _trace_param_flag_)
- {
- tars::JsonValueObjPtr _p_ = new tars::JsonValueObj();
- _p_->value[""] = tars::JsonOutput::writeJson(_ret);
- _p_->value["sOut"] = tars::JsonOutput::writeJson(sOut);
- _trace_param_ = tars::TC_Json::writeValue(_p_);
- }
- else if(ServantProxyThreadData::TraceContext::ENP_OVERMAXLEN == _trace_param_flag_)
- {
- _trace_param_ = "{\"trace_param_over_max_len\":true}";
- }
- TARS_TRACE(pSptd->getTraceKey(ServantProxyThreadData::TraceContext::EST_CR), TRACE_ANNOTATION_CR, ServerConfig::Application + "." + ServerConfig::ServerName, tars_name(), "testConHash", 0, _trace_param_, "");
- }
- return _ret;
- }
- void async_testConHash(HelloPrxCallbackPtr callback,const map<string, string>& context = TARS_CONTEXT())
- {
- tars::TarsOutputStream<tars::BufferWriterVector> _os;
- std::map<string, string> _mStatus;
- ServantProxyThreadData *pSptd = ServantProxyThreadData::getData();
- if (pSptd && pSptd->_traceCall)
- {
- pSptd->newSpan();
- string _trace_param_;
- int _trace_param_flag_ = pSptd->needTraceParam(ServantProxyThreadData::TraceContext::EST_CS, _os.getLength());
- if (ServantProxyThreadData::TraceContext::ENP_NORMAL == _trace_param_flag_)
- {
- tars::JsonValueObjPtr _p_ = new tars::JsonValueObj();
- _trace_param_ = tars::TC_Json::writeValue(_p_);
- }
- else if(ServantProxyThreadData::TraceContext::ENP_OVERMAXLEN == _trace_param_flag_)
- {
- _trace_param_ = "{\"trace_param_over_max_len\":true}";
- }
- TARS_TRACE(pSptd->getTraceKey(ServantProxyThreadData::TraceContext::EST_CS), TRACE_ANNOTATION_CS, ServerConfig::Application + "." + ServerConfig::ServerName, tars_name(), "testConHash", 0, _trace_param_, "");
- }
- tars_invoke_async(tars::TARSNORMAL,"testConHash", _os, context, _mStatus, callback);
- }
-
- tars::Future< HelloPrxCallbackPromise::PromisetestConHashPtr > promise_async_testConHash(const map<string, string>& context)
- {
- tars::Promise< HelloPrxCallbackPromise::PromisetestConHashPtr > promise;
- HelloPrxCallbackPromisePtr callback = new HelloPrxCallbackPromise(promise);
- tars::TarsOutputStream<tars::BufferWriterVector> _os;
- std::map<string, string> _mStatus;
- tars_invoke_async(tars::TARSNORMAL,"testConHash", _os, context, _mStatus, callback);
- return promise.getFuture();
- }
- void coro_testConHash(HelloCoroPrxCallbackPtr callback,const map<string, string>& context = TARS_CONTEXT())
- {
- tars::TarsOutputStream<tars::BufferWriterVector> _os;
- std::map<string, string> _mStatus;
- tars_invoke_async(tars::TARSNORMAL,"testConHash", _os, context, _mStatus, callback, true);
- }
- tars::Bool testCoro(const std::string & sIn,std::string &sOut,const map<string, string> &context = TARS_CONTEXT(),map<string, string> * pResponseContext = NULL)
- {
- tars::TarsOutputStream<tars::BufferWriterVector> _os;
- _os.write(sIn, 1);
- _os.write(sOut, 2);
- ServantProxyThreadData *pSptd = ServantProxyThreadData::getData();
- if (pSptd && pSptd->_traceCall)
- {
- pSptd->newSpan();
- string _trace_param_;
- int _trace_param_flag_ = pSptd->needTraceParam(ServantProxyThreadData::TraceContext::EST_CS, _os.getLength());
- if (ServantProxyThreadData::TraceContext::ENP_NORMAL == _trace_param_flag_)
- {
- tars::JsonValueObjPtr _p_ = new tars::JsonValueObj();
- _p_->value["sIn"] = tars::JsonOutput::writeJson(sIn);
- _trace_param_ = tars::TC_Json::writeValue(_p_);
- }
- else if(ServantProxyThreadData::TraceContext::ENP_OVERMAXLEN == _trace_param_flag_)
- {
- _trace_param_ = "{\"trace_param_over_max_len\":true}";
- }
- TARS_TRACE(pSptd->getTraceKey(ServantProxyThreadData::TraceContext::EST_CS), TRACE_ANNOTATION_CS, ServerConfig::Application + "." + ServerConfig::ServerName, tars_name(), "testCoro", 0, _trace_param_, "");
- }
- std::map<string, string> _mStatus;
- shared_ptr<tars::ResponsePacket> rep = tars_invoke(tars::TARSNORMAL,"testCoro", _os, context, _mStatus);
- if(pResponseContext)
- {
- pResponseContext->swap(rep->context);
- }
- tars::TarsInputStream<tars::BufferReader> _is;
- _is.setBuffer(rep->sBuffer);
- tars::Bool _ret = false;
- _is.read(_ret, 0, true);
- _is.read(sOut, 2, true);
- if (pSptd && pSptd->_traceCall)
- {
- string _trace_param_;
- int _trace_param_flag_ = pSptd->needTraceParam(ServantProxyThreadData::TraceContext::EST_CR, _is.size());
- if (ServantProxyThreadData::TraceContext::ENP_NORMAL == _trace_param_flag_)
- {
- tars::JsonValueObjPtr _p_ = new tars::JsonValueObj();
- _p_->value[""] = tars::JsonOutput::writeJson(_ret);
- _p_->value["sOut"] = tars::JsonOutput::writeJson(sOut);
- _trace_param_ = tars::TC_Json::writeValue(_p_);
- }
- else if(ServantProxyThreadData::TraceContext::ENP_OVERMAXLEN == _trace_param_flag_)
- {
- _trace_param_ = "{\"trace_param_over_max_len\":true}";
- }
- TARS_TRACE(pSptd->getTraceKey(ServantProxyThreadData::TraceContext::EST_CR), TRACE_ANNOTATION_CR, ServerConfig::Application + "." + ServerConfig::ServerName, tars_name(), "testCoro", 0, _trace_param_, "");
- }
- return _ret;
- }
- void async_testCoro(HelloPrxCallbackPtr callback,const std::string &sIn,const map<string, string>& context = TARS_CONTEXT())
- {
- tars::TarsOutputStream<tars::BufferWriterVector> _os;
- _os.write(sIn, 1);
- std::map<string, string> _mStatus;
- ServantProxyThreadData *pSptd = ServantProxyThreadData::getData();
- if (pSptd && pSptd->_traceCall)
- {
- pSptd->newSpan();
- string _trace_param_;
- int _trace_param_flag_ = pSptd->needTraceParam(ServantProxyThreadData::TraceContext::EST_CS, _os.getLength());
- if (ServantProxyThreadData::TraceContext::ENP_NORMAL == _trace_param_flag_)
- {
- tars::JsonValueObjPtr _p_ = new tars::JsonValueObj();
- _p_->value["sIn"] = tars::JsonOutput::writeJson(sIn);
- _trace_param_ = tars::TC_Json::writeValue(_p_);
- }
- else if(ServantProxyThreadData::TraceContext::ENP_OVERMAXLEN == _trace_param_flag_)
- {
- _trace_param_ = "{\"trace_param_over_max_len\":true}";
- }
- TARS_TRACE(pSptd->getTraceKey(ServantProxyThreadData::TraceContext::EST_CS), TRACE_ANNOTATION_CS, ServerConfig::Application + "." + ServerConfig::ServerName, tars_name(), "testCoro", 0, _trace_param_, "");
- }
- tars_invoke_async(tars::TARSNORMAL,"testCoro", _os, context, _mStatus, callback);
- }
-
- tars::Future< HelloPrxCallbackPromise::PromisetestCoroPtr > promise_async_testCoro(const std::string &sIn,const map<string, string>& context)
- {
- tars::Promise< HelloPrxCallbackPromise::PromisetestCoroPtr > promise;
- HelloPrxCallbackPromisePtr callback = new HelloPrxCallbackPromise(promise);
- tars::TarsOutputStream<tars::BufferWriterVector> _os;
- _os.write(sIn, 1);
- std::map<string, string> _mStatus;
- tars_invoke_async(tars::TARSNORMAL,"testCoro", _os, context, _mStatus, callback);
- return promise.getFuture();
- }
- void coro_testCoro(HelloCoroPrxCallbackPtr callback,const std::string &sIn,const map<string, string>& context = TARS_CONTEXT())
- {
- tars::TarsOutputStream<tars::BufferWriterVector> _os;
- _os.write(sIn, 1);
- std::map<string, string> _mStatus;
- tars_invoke_async(tars::TARSNORMAL,"testCoro", _os, context, _mStatus, callback, true);
- }
- tars::Int32 testDyeing(const std::string & strIn,std::string &strOut,const map<string, string> &context = TARS_CONTEXT(),map<string, string> * pResponseContext = NULL)
- {
- tars::TarsOutputStream<tars::BufferWriterVector> _os;
- _os.write(strIn, 1);
- _os.write(strOut, 2);
- ServantProxyThreadData *pSptd = ServantProxyThreadData::getData();
- if (pSptd && pSptd->_traceCall)
- {
- pSptd->newSpan();
- string _trace_param_;
- int _trace_param_flag_ = pSptd->needTraceParam(ServantProxyThreadData::TraceContext::EST_CS, _os.getLength());
- if (ServantProxyThreadData::TraceContext::ENP_NORMAL == _trace_param_flag_)
- {
- tars::JsonValueObjPtr _p_ = new tars::JsonValueObj();
- _p_->value["strIn"] = tars::JsonOutput::writeJson(strIn);
- _trace_param_ = tars::TC_Json::writeValue(_p_);
- }
- else if(ServantProxyThreadData::TraceContext::ENP_OVERMAXLEN == _trace_param_flag_)
- {
- _trace_param_ = "{\"trace_param_over_max_len\":true}";
- }
- TARS_TRACE(pSptd->getTraceKey(ServantProxyThreadData::TraceContext::EST_CS), TRACE_ANNOTATION_CS, ServerConfig::Application + "." + ServerConfig::ServerName, tars_name(), "testDyeing", 0, _trace_param_, "");
- }
- std::map<string, string> _mStatus;
- _mStatus.insert(std::make_pair(ServantProxy::STATUS_GRID_KEY, strIn));
- shared_ptr<tars::ResponsePacket> rep = tars_invoke(tars::TARSNORMAL,"testDyeing", _os, context, _mStatus);
- if(pResponseContext)
- {
- pResponseContext->swap(rep->context);
- }
- tars::TarsInputStream<tars::BufferReader> _is;
- _is.setBuffer(rep->sBuffer);
- tars::Int32 _ret;
- _is.read(_ret, 0, true);
- _is.read(strOut, 2, true);
- if (pSptd && pSptd->_traceCall)
- {
- string _trace_param_;
- int _trace_param_flag_ = pSptd->needTraceParam(ServantProxyThreadData::TraceContext::EST_CR, _is.size());
- if (ServantProxyThreadData::TraceContext::ENP_NORMAL == _trace_param_flag_)
- {
- tars::JsonValueObjPtr _p_ = new tars::JsonValueObj();
- _p_->value[""] = tars::JsonOutput::writeJson(_ret);
- _p_->value["strOut"] = tars::JsonOutput::writeJson(strOut);
- _trace_param_ = tars::TC_Json::writeValue(_p_);
- }
- else if(ServantProxyThreadData::TraceContext::ENP_OVERMAXLEN == _trace_param_flag_)
- {
- _trace_param_ = "{\"trace_param_over_max_len\":true}";
- }
- TARS_TRACE(pSptd->getTraceKey(ServantProxyThreadData::TraceContext::EST_CR), TRACE_ANNOTATION_CR, ServerConfig::Application + "." + ServerConfig::ServerName, tars_name(), "testDyeing", 0, _trace_param_, "");
- }
- return _ret;
- }
- void async_testDyeing(HelloPrxCallbackPtr callback,const std::string &strIn,const map<string, string>& context = TARS_CONTEXT())
- {
- tars::TarsOutputStream<tars::BufferWriterVector> _os;
- _os.write(strIn, 1);
- std::map<string, string> _mStatus;
- _mStatus.insert(std::make_pair(ServantProxy::STATUS_GRID_KEY, strIn));
- ServantProxyThreadData *pSptd = ServantProxyThreadData::getData();
- if (pSptd && pSptd->_traceCall)
- {
- pSptd->newSpan();
- string _trace_param_;
- int _trace_param_flag_ = pSptd->needTraceParam(ServantProxyThreadData::TraceContext::EST_CS, _os.getLength());
- if (ServantProxyThreadData::TraceContext::ENP_NORMAL == _trace_param_flag_)
- {
- tars::JsonValueObjPtr _p_ = new tars::JsonValueObj();
- _p_->value["strIn"] = tars::JsonOutput::writeJson(strIn);
- _trace_param_ = tars::TC_Json::writeValue(_p_);
- }
- else if(ServantProxyThreadData::TraceContext::ENP_OVERMAXLEN == _trace_param_flag_)
- {
- _trace_param_ = "{\"trace_param_over_max_len\":true}";
- }
- TARS_TRACE(pSptd->getTraceKey(ServantProxyThreadData::TraceContext::EST_CS), TRACE_ANNOTATION_CS, ServerConfig::Application + "." + ServerConfig::ServerName, tars_name(), "testDyeing", 0, _trace_param_, "");
- }
- tars_invoke_async(tars::TARSNORMAL,"testDyeing", _os, context, _mStatus, callback);
- }
-
- tars::Future< HelloPrxCallbackPromise::PromisetestDyeingPtr > promise_async_testDyeing(const std::string &strIn,const map<string, string>& context)
- {
- tars::Promise< HelloPrxCallbackPromise::PromisetestDyeingPtr > promise;
- HelloPrxCallbackPromisePtr callback = new HelloPrxCallbackPromise(promise);
- tars::TarsOutputStream<tars::BufferWriterVector> _os;
- _os.write(strIn, 1);
- std::map<string, string> _mStatus;
- _mStatus.insert(std::make_pair(ServantProxy::STATUS_GRID_KEY, strIn));
- tars_invoke_async(tars::TARSNORMAL,"testDyeing", _os, context, _mStatus, callback);
- return promise.getFuture();
- }
- void coro_testDyeing(HelloCoroPrxCallbackPtr callback,const std::string &strIn,const map<string, string>& context = TARS_CONTEXT())
- {
- tars::TarsOutputStream<tars::BufferWriterVector> _os;
- _os.write(strIn, 1);
- std::map<string, string> _mStatus;
- _mStatus.insert(std::make_pair(ServantProxy::STATUS_GRID_KEY, strIn));
- tars_invoke_async(tars::TARSNORMAL,"testDyeing", _os, context, _mStatus, callback, true);
- }
- tars::Int32 testDyeingTrans(const map<string, string> &context = TARS_CONTEXT(),map<string, string> * pResponseContext = NULL)
- {
- tars::TarsOutputStream<tars::BufferWriterVector> _os;
- ServantProxyThreadData *pSptd = ServantProxyThreadData::getData();
- if (pSptd && pSptd->_traceCall)
- {
- pSptd->newSpan();
- string _trace_param_;
- int _trace_param_flag_ = pSptd->needTraceParam(ServantProxyThreadData::TraceContext::EST_CS, _os.getLength());
- if (ServantProxyThreadData::TraceContext::ENP_NORMAL == _trace_param_flag_)
- {
- tars::JsonValueObjPtr _p_ = new tars::JsonValueObj();
- _trace_param_ = tars::TC_Json::writeValue(_p_);
- }
- else if(ServantProxyThreadData::TraceContext::ENP_OVERMAXLEN == _trace_param_flag_)
- {
- _trace_param_ = "{\"trace_param_over_max_len\":true}";
- }
- TARS_TRACE(pSptd->getTraceKey(ServantProxyThreadData::TraceContext::EST_CS), TRACE_ANNOTATION_CS, ServerConfig::Application + "." + ServerConfig::ServerName, tars_name(), "testDyeingTrans", 0, _trace_param_, "");
- }
- std::map<string, string> _mStatus;
- shared_ptr<tars::ResponsePacket> rep = tars_invoke(tars::TARSNORMAL,"testDyeingTrans", _os, context, _mStatus);
- if(pResponseContext)
- {
- pResponseContext->swap(rep->context);
- }
- tars::TarsInputStream<tars::BufferReader> _is;
- _is.setBuffer(rep->sBuffer);
- tars::Int32 _ret;
- _is.read(_ret, 0, true);
- if (pSptd && pSptd->_traceCall)
- {
- string _trace_param_;
- int _trace_param_flag_ = pSptd->needTraceParam(ServantProxyThreadData::TraceContext::EST_CR, _is.size());
- if (ServantProxyThreadData::TraceContext::ENP_NORMAL == _trace_param_flag_)
- {
- tars::JsonValueObjPtr _p_ = new tars::JsonValueObj();
- _p_->value[""] = tars::JsonOutput::writeJson(_ret);
- _trace_param_ = tars::TC_Json::writeValue(_p_);
- }
- else if(ServantProxyThreadData::TraceContext::ENP_OVERMAXLEN == _trace_param_flag_)
- {
- _trace_param_ = "{\"trace_param_over_max_len\":true}";
- }
- TARS_TRACE(pSptd->getTraceKey(ServantProxyThreadData::TraceContext::EST_CR), TRACE_ANNOTATION_CR, ServerConfig::Application + "." + ServerConfig::ServerName, tars_name(), "testDyeingTrans", 0, _trace_param_, "");
- }
- return _ret;
- }
- void async_testDyeingTrans(HelloPrxCallbackPtr callback,const map<string, string>& context = TARS_CONTEXT())
- {
- tars::TarsOutputStream<tars::BufferWriterVector> _os;
- std::map<string, string> _mStatus;
- ServantProxyThreadData *pSptd = ServantProxyThreadData::getData();
- if (pSptd && pSptd->_traceCall)
- {
- pSptd->newSpan();
- string _trace_param_;
- int _trace_param_flag_ = pSptd->needTraceParam(ServantProxyThreadData::TraceContext::EST_CS, _os.getLength());
- if (ServantProxyThreadData::TraceContext::ENP_NORMAL == _trace_param_flag_)
- {
- tars::JsonValueObjPtr _p_ = new tars::JsonValueObj();
- _trace_param_ = tars::TC_Json::writeValue(_p_);
- }
- else if(ServantProxyThreadData::TraceContext::ENP_OVERMAXLEN == _trace_param_flag_)
- {
- _trace_param_ = "{\"trace_param_over_max_len\":true}";
- }
- TARS_TRACE(pSptd->getTraceKey(ServantProxyThreadData::TraceContext::EST_CS), TRACE_ANNOTATION_CS, ServerConfig::Application + "." + ServerConfig::ServerName, tars_name(), "testDyeingTrans", 0, _trace_param_, "");
- }
- tars_invoke_async(tars::TARSNORMAL,"testDyeingTrans", _os, context, _mStatus, callback);
- }
-
- tars::Future< HelloPrxCallbackPromise::PromisetestDyeingTransPtr > promise_async_testDyeingTrans(const map<string, string>& context)
- {
- tars::Promise< HelloPrxCallbackPromise::PromisetestDyeingTransPtr > promise;
- HelloPrxCallbackPromisePtr callback = new HelloPrxCallbackPromise(promise);
- tars::TarsOutputStream<tars::BufferWriterVector> _os;
- std::map<string, string> _mStatus;
- tars_invoke_async(tars::TARSNORMAL,"testDyeingTrans", _os, context, _mStatus, callback);
- return promise.getFuture();
- }
- void coro_testDyeingTrans(HelloCoroPrxCallbackPtr callback,const map<string, string>& context = TARS_CONTEXT())
- {
- tars::TarsOutputStream<tars::BufferWriterVector> _os;
- std::map<string, string> _mStatus;
- tars_invoke_async(tars::TARSNORMAL,"testDyeingTrans", _os, context, _mStatus, callback, true);
- }
- tars::Int32 testHello(tars::Int32 index,const std::string & s,std::string &r,const map<string, string> &context = TARS_CONTEXT(),map<string, string> * pResponseContext = NULL)
- {
- tars::TarsOutputStream<tars::BufferWriterVector> _os;
- _os.write(index, 1);
- _os.write(s, 2);
- _os.write(r, 3);
- ServantProxyThreadData *pSptd = ServantProxyThreadData::getData();
- if (pSptd && pSptd->_traceCall)
- {
- pSptd->newSpan();
- string _trace_param_;
- int _trace_param_flag_ = pSptd->needTraceParam(ServantProxyThreadData::TraceContext::EST_CS, _os.getLength());
- if (ServantProxyThreadData::TraceContext::ENP_NORMAL == _trace_param_flag_)
- {
- tars::JsonValueObjPtr _p_ = new tars::JsonValueObj();
- _p_->value["index"] = tars::JsonOutput::writeJson(index);
- _p_->value["s"] = tars::JsonOutput::writeJson(s);
- _trace_param_ = tars::TC_Json::writeValue(_p_);
- }
- else if(ServantProxyThreadData::TraceContext::ENP_OVERMAXLEN == _trace_param_flag_)
- {
- _trace_param_ = "{\"trace_param_over_max_len\":true}";
- }
- TARS_TRACE(pSptd->getTraceKey(ServantProxyThreadData::TraceContext::EST_CS), TRACE_ANNOTATION_CS, ServerConfig::Application + "." + ServerConfig::ServerName, tars_name(), "testHello", 0, _trace_param_, "");
- }
- std::map<string, string> _mStatus;
- shared_ptr<tars::ResponsePacket> rep = tars_invoke(tars::TARSNORMAL,"testHello", _os, context, _mStatus);
- if(pResponseContext)
- {
- pResponseContext->swap(rep->context);
- }
- tars::TarsInputStream<tars::BufferReader> _is;
- _is.setBuffer(rep->sBuffer);
- tars::Int32 _ret;
- _is.read(_ret, 0, true);
- _is.read(r, 3, true);
- if (pSptd && pSptd->_traceCall)
- {
- string _trace_param_;
- int _trace_param_flag_ = pSptd->needTraceParam(ServantProxyThreadData::TraceContext::EST_CR, _is.size());
- if (ServantProxyThreadData::TraceContext::ENP_NORMAL == _trace_param_flag_)
- {
- tars::JsonValueObjPtr _p_ = new tars::JsonValueObj();
- _p_->value[""] = tars::JsonOutput::writeJson(_ret);
- _p_->value["r"] = tars::JsonOutput::writeJson(r);
- _trace_param_ = tars::TC_Json::writeValue(_p_);
- }
- else if(ServantProxyThreadData::TraceContext::ENP_OVERMAXLEN == _trace_param_flag_)
- {
- _trace_param_ = "{\"trace_param_over_max_len\":true}";
- }
- TARS_TRACE(pSptd->getTraceKey(ServantProxyThreadData::TraceContext::EST_CR), TRACE_ANNOTATION_CR, ServerConfig::Application + "." + ServerConfig::ServerName, tars_name(), "testHello", 0, _trace_param_, "");
- }
- return _ret;
- }
- void async_testHello(HelloPrxCallbackPtr callback,tars::Int32 index,const std::string &s,const map<string, string>& context = TARS_CONTEXT())
- {
- tars::TarsOutputStream<tars::BufferWriterVector> _os;
- _os.write(index, 1);
- _os.write(s, 2);
- std::map<string, string> _mStatus;
- ServantProxyThreadData *pSptd = ServantProxyThreadData::getData();
- if (pSptd && pSptd->_traceCall)
- {
- pSptd->newSpan();
- string _trace_param_;
- int _trace_param_flag_ = pSptd->needTraceParam(ServantProxyThreadData::TraceContext::EST_CS, _os.getLength());
- if (ServantProxyThreadData::TraceContext::ENP_NORMAL == _trace_param_flag_)
- {
- tars::JsonValueObjPtr _p_ = new tars::JsonValueObj();
- _p_->value["index"] = tars::JsonOutput::writeJson(index);
- _p_->value["s"] = tars::JsonOutput::writeJson(s);
- _trace_param_ = tars::TC_Json::writeValue(_p_);
- }
- else if(ServantProxyThreadData::TraceContext::ENP_OVERMAXLEN == _trace_param_flag_)
- {
- _trace_param_ = "{\"trace_param_over_max_len\":true}";
- }
- TARS_TRACE(pSptd->getTraceKey(ServantProxyThreadData::TraceContext::EST_CS), TRACE_ANNOTATION_CS, ServerConfig::Application + "." + ServerConfig::ServerName, tars_name(), "testHello", 0, _trace_param_, "");
- }
- tars_invoke_async(tars::TARSNORMAL,"testHello", _os, context, _mStatus, callback);
- }
-
- tars::Future< HelloPrxCallbackPromise::PromisetestHelloPtr > promise_async_testHello(tars::Int32 index,const std::string &s,const map<string, string>& context)
- {
- tars::Promise< HelloPrxCallbackPromise::PromisetestHelloPtr > promise;
- HelloPrxCallbackPromisePtr callback = new HelloPrxCallbackPromise(promise);
- tars::TarsOutputStream<tars::BufferWriterVector> _os;
- _os.write(index, 1);
- _os.write(s, 2);
- std::map<string, string> _mStatus;
- tars_invoke_async(tars::TARSNORMAL,"testHello", _os, context, _mStatus, callback);
- return promise.getFuture();
- }
- void coro_testHello(HelloCoroPrxCallbackPtr callback,tars::Int32 index,const std::string &s,const map<string, string>& context = TARS_CONTEXT())
- {
- tars::TarsOutputStream<tars::BufferWriterVector> _os;
- _os.write(index, 1);
- _os.write(s, 2);
- std::map<string, string> _mStatus;
- tars_invoke_async(tars::TARSNORMAL,"testHello", _os, context, _mStatus, callback, true);
- }
- tars::Int32 testPid(std::string &r,const map<string, string> &context = TARS_CONTEXT(),map<string, string> * pResponseContext = NULL)
- {
- tars::TarsOutputStream<tars::BufferWriterVector> _os;
- _os.write(r, 1);
- ServantProxyThreadData *pSptd = ServantProxyThreadData::getData();
- if (pSptd && pSptd->_traceCall)
- {
- pSptd->newSpan();
- string _trace_param_;
- int _trace_param_flag_ = pSptd->needTraceParam(ServantProxyThreadData::TraceContext::EST_CS, _os.getLength());
- if (ServantProxyThreadData::TraceContext::ENP_NORMAL == _trace_param_flag_)
- {
- tars::JsonValueObjPtr _p_ = new tars::JsonValueObj();
- _trace_param_ = tars::TC_Json::writeValue(_p_);
- }
- else if(ServantProxyThreadData::TraceContext::ENP_OVERMAXLEN == _trace_param_flag_)
- {
- _trace_param_ = "{\"trace_param_over_max_len\":true}";
- }
- TARS_TRACE(pSptd->getTraceKey(ServantProxyThreadData::TraceContext::EST_CS), TRACE_ANNOTATION_CS, ServerConfig::Application + "." + ServerConfig::ServerName, tars_name(), "testPid", 0, _trace_param_, "");
- }
- std::map<string, string> _mStatus;
- shared_ptr<tars::ResponsePacket> rep = tars_invoke(tars::TARSNORMAL,"testPid", _os, context, _mStatus);
- if(pResponseContext)
- {
- pResponseContext->swap(rep->context);
- }
- tars::TarsInputStream<tars::BufferReader> _is;
- _is.setBuffer(rep->sBuffer);
- tars::Int32 _ret;
- _is.read(_ret, 0, true);
- _is.read(r, 1, true);
- if (pSptd && pSptd->_traceCall)
- {
- string _trace_param_;
- int _trace_param_flag_ = pSptd->needTraceParam(ServantProxyThreadData::TraceContext::EST_CR, _is.size());
- if (ServantProxyThreadData::TraceContext::ENP_NORMAL == _trace_param_flag_)
- {
- tars::JsonValueObjPtr _p_ = new tars::JsonValueObj();
- _p_->value[""] = tars::JsonOutput::writeJson(_ret);
- _p_->value["r"] = tars::JsonOutput::writeJson(r);
- _trace_param_ = tars::TC_Json::writeValue(_p_);
- }
- else if(ServantProxyThreadData::TraceContext::ENP_OVERMAXLEN == _trace_param_flag_)
- {
- _trace_param_ = "{\"trace_param_over_max_len\":true}";
- }
- TARS_TRACE(pSptd->getTraceKey(ServantProxyThreadData::TraceContext::EST_CR), TRACE_ANNOTATION_CR, ServerConfig::Application + "." + ServerConfig::ServerName, tars_name(), "testPid", 0, _trace_param_, "");
- }
- return _ret;
- }
- void async_testPid(HelloPrxCallbackPtr callback,const map<string, string>& context = TARS_CONTEXT())
- {
- tars::TarsOutputStream<tars::BufferWriterVector> _os;
- std::map<string, string> _mStatus;
- ServantProxyThreadData *pSptd = ServantProxyThreadData::getData();
- if (pSptd && pSptd->_traceCall)
- {
- pSptd->newSpan();
- string _trace_param_;
- int _trace_param_flag_ = pSptd->needTraceParam(ServantProxyThreadData::TraceContext::EST_CS, _os.getLength());
- if (ServantProxyThreadData::TraceContext::ENP_NORMAL == _trace_param_flag_)
- {
- tars::JsonValueObjPtr _p_ = new tars::JsonValueObj();
- _trace_param_ = tars::TC_Json::writeValue(_p_);
- }
- else if(ServantProxyThreadData::TraceContext::ENP_OVERMAXLEN == _trace_param_flag_)
- {
- _trace_param_ = "{\"trace_param_over_max_len\":true}";
- }
- TARS_TRACE(pSptd->getTraceKey(ServantProxyThreadData::TraceContext::EST_CS), TRACE_ANNOTATION_CS, ServerConfig::Application + "." + ServerConfig::ServerName, tars_name(), "testPid", 0, _trace_param_, "");
- }
- tars_invoke_async(tars::TARSNORMAL,"testPid", _os, context, _mStatus, callback);
- }
-
- tars::Future< HelloPrxCallbackPromise::PromisetestPidPtr > promise_async_testPid(const map<string, string>& context)
- {
- tars::Promise< HelloPrxCallbackPromise::PromisetestPidPtr > promise;
- HelloPrxCallbackPromisePtr callback = new HelloPrxCallbackPromise(promise);
- tars::TarsOutputStream<tars::BufferWriterVector> _os;
- std::map<string, string> _mStatus;
- tars_invoke_async(tars::TARSNORMAL,"testPid", _os, context, _mStatus, callback);
- return promise.getFuture();
- }
- void coro_testPid(HelloCoroPrxCallbackPtr callback,const map<string, string>& context = TARS_CONTEXT())
- {
- tars::TarsOutputStream<tars::BufferWriterVector> _os;
- std::map<string, string> _mStatus;
- tars_invoke_async(tars::TARSNORMAL,"testPid", _os, context, _mStatus, callback, true);
- }
- tars::Int32 testSyncTrans(tars::Int32 index,const std::string & s,std::string &r,const map<string, string> &context = TARS_CONTEXT(),map<string, string> * pResponseContext = NULL)
- {
- tars::TarsOutputStream<tars::BufferWriterVector> _os;
- _os.write(index, 1);
- _os.write(s, 2);
- _os.write(r, 3);
- ServantProxyThreadData *pSptd = ServantProxyThreadData::getData();
- if (pSptd && pSptd->_traceCall)
- {
- pSptd->newSpan();
- string _trace_param_;
- int _trace_param_flag_ = pSptd->needTraceParam(ServantProxyThreadData::TraceContext::EST_CS, _os.getLength());
- if (ServantProxyThreadData::TraceContext::ENP_NORMAL == _trace_param_flag_)
- {
- tars::JsonValueObjPtr _p_ = new tars::JsonValueObj();
- _p_->value["index"] = tars::JsonOutput::writeJson(index);
- _p_->value["s"] = tars::JsonOutput::writeJson(s);
- _trace_param_ = tars::TC_Json::writeValue(_p_);
- }
- else if(ServantProxyThreadData::TraceContext::ENP_OVERMAXLEN == _trace_param_flag_)
- {
- _trace_param_ = "{\"trace_param_over_max_len\":true}";
- }
- TARS_TRACE(pSptd->getTraceKey(ServantProxyThreadData::TraceContext::EST_CS), TRACE_ANNOTATION_CS, ServerConfig::Application + "." + ServerConfig::ServerName, tars_name(), "testSyncTrans", 0, _trace_param_, "");
- }
- std::map<string, string> _mStatus;
- shared_ptr<tars::ResponsePacket> rep = tars_invoke(tars::TARSNORMAL,"testSyncTrans", _os, context, _mStatus);
- if(pResponseContext)
- {
- pResponseContext->swap(rep->context);
- }
- tars::TarsInputStream<tars::BufferReader> _is;
- _is.setBuffer(rep->sBuffer);
- tars::Int32 _ret;
- _is.read(_ret, 0, true);
- _is.read(r, 3, true);
- if (pSptd && pSptd->_traceCall)
- {
- string _trace_param_;
- int _trace_param_flag_ = pSptd->needTraceParam(ServantProxyThreadData::TraceContext::EST_CR, _is.size());
- if (ServantProxyThreadData::TraceContext::ENP_NORMAL == _trace_param_flag_)
- {
- tars::JsonValueObjPtr _p_ = new tars::JsonValueObj();
- _p_->value[""] = tars::JsonOutput::writeJson(_ret);
- _p_->value["r"] = tars::JsonOutput::writeJson(r);
- _trace_param_ = tars::TC_Json::writeValue(_p_);
- }
- else if(ServantProxyThreadData::TraceContext::ENP_OVERMAXLEN == _trace_param_flag_)
- {
- _trace_param_ = "{\"trace_param_over_max_len\":true}";
- }
- TARS_TRACE(pSptd->getTraceKey(ServantProxyThreadData::TraceContext::EST_CR), TRACE_ANNOTATION_CR, ServerConfig::Application + "." + ServerConfig::ServerName, tars_name(), "testSyncTrans", 0, _trace_param_, "");
- }
- return _ret;
- }
- void async_testSyncTrans(HelloPrxCallbackPtr callback,tars::Int32 index,const std::string &s,const map<string, string>& context = TARS_CONTEXT())
- {
- tars::TarsOutputStream<tars::BufferWriterVector> _os;
- _os.write(index, 1);
- _os.write(s, 2);
- std::map<string, string> _mStatus;
- ServantProxyThreadData *pSptd = ServantProxyThreadData::getData();
- if (pSptd && pSptd->_traceCall)
- {
- pSptd->newSpan();
- string _trace_param_;
- int _trace_param_flag_ = pSptd->needTraceParam(ServantProxyThreadData::TraceContext::EST_CS, _os.getLength());
- if (ServantProxyThreadData::TraceContext::ENP_NORMAL == _trace_param_flag_)
- {
- tars::JsonValueObjPtr _p_ = new tars::JsonValueObj();
- _p_->value["index"] = tars::JsonOutput::writeJson(index);
- _p_->value["s"] = tars::JsonOutput::writeJson(s);
- _trace_param_ = tars::TC_Json::writeValue(_p_);
- }
- else if(ServantProxyThreadData::TraceContext::ENP_OVERMAXLEN == _trace_param_flag_)
- {
- _trace_param_ = "{\"trace_param_over_max_len\":true}";
- }
- TARS_TRACE(pSptd->getTraceKey(ServantProxyThreadData::TraceContext::EST_CS), TRACE_ANNOTATION_CS, ServerConfig::Application + "." + ServerConfig::ServerName, tars_name(), "testSyncTrans", 0, _trace_param_, "");
- }
- tars_invoke_async(tars::TARSNORMAL,"testSyncTrans", _os, context, _mStatus, callback);
- }
-
- tars::Future< HelloPrxCallbackPromise::PromisetestSyncTransPtr > promise_async_testSyncTrans(tars::Int32 index,const std::string &s,const map<string, string>& context)
- {
- tars::Promise< HelloPrxCallbackPromise::PromisetestSyncTransPtr > promise;
- HelloPrxCallbackPromisePtr callback = new HelloPrxCallbackPromise(promise);
- tars::TarsOutputStream<tars::BufferWriterVector> _os;
- _os.write(index, 1);
- _os.write(s, 2);
- std::map<string, string> _mStatus;
- tars_invoke_async(tars::TARSNORMAL,"testSyncTrans", _os, context, _mStatus, callback);
- return promise.getFuture();
- }
- void coro_testSyncTrans(HelloCoroPrxCallbackPtr callback,tars::Int32 index,const std::string &s,const map<string, string>& context = TARS_CONTEXT())
- {
- tars::TarsOutputStream<tars::BufferWriterVector> _os;
- _os.write(index, 1);
- _os.write(s, 2);
- std::map<string, string> _mStatus;
- tars_invoke_async(tars::TARSNORMAL,"testSyncTrans", _os, context, _mStatus, callback, true);
- }
- tars::Int32 testTimeout(tars::Int32 timeout,const map<string, string> &context = TARS_CONTEXT(),map<string, string> * pResponseContext = NULL)
- {
- tars::TarsOutputStream<tars::BufferWriterVector> _os;
- _os.write(timeout, 1);
- ServantProxyThreadData *pSptd = ServantProxyThreadData::getData();
- if (pSptd && pSptd->_traceCall)
- {
- pSptd->newSpan();
- string _trace_param_;
- int _trace_param_flag_ = pSptd->needTraceParam(ServantProxyThreadData::TraceContext::EST_CS, _os.getLength());
- if (ServantProxyThreadData::TraceContext::ENP_NORMAL == _trace_param_flag_)
- {
- tars::JsonValueObjPtr _p_ = new tars::JsonValueObj();
- _p_->value["timeout"] = tars::JsonOutput::writeJson(timeout);
- _trace_param_ = tars::TC_Json::writeValue(_p_);
- }
- else if(ServantProxyThreadData::TraceContext::ENP_OVERMAXLEN == _trace_param_flag_)
- {
- _trace_param_ = "{\"trace_param_over_max_len\":true}";
- }
- TARS_TRACE(pSptd->getTraceKey(ServantProxyThreadData::TraceContext::EST_CS), TRACE_ANNOTATION_CS, ServerConfig::Application + "." + ServerConfig::ServerName, tars_name(), "testTimeout", 0, _trace_param_, "");
- }
- std::map<string, string> _mStatus;
- shared_ptr<tars::ResponsePacket> rep = tars_invoke(tars::TARSNORMAL,"testTimeout", _os, context, _mStatus);
- if(pResponseContext)
- {
- pResponseContext->swap(rep->context);
- }
- tars::TarsInputStream<tars::BufferReader> _is;
- _is.setBuffer(rep->sBuffer);
- tars::Int32 _ret;
- _is.read(_ret, 0, true);
- if (pSptd && pSptd->_traceCall)
- {
- string _trace_param_;
- int _trace_param_flag_ = pSptd->needTraceParam(ServantProxyThreadData::TraceContext::EST_CR, _is.size());
- if (ServantProxyThreadData::TraceContext::ENP_NORMAL == _trace_param_flag_)
- {
- tars::JsonValueObjPtr _p_ = new tars::JsonValueObj();
- _p_->value[""] = tars::JsonOutput::writeJson(_ret);
- _trace_param_ = tars::TC_Json::writeValue(_p_);
- }
- else if(ServantProxyThreadData::TraceContext::ENP_OVERMAXLEN == _trace_param_flag_)
- {
- _trace_param_ = "{\"trace_param_over_max_len\":true}";
- }
- TARS_TRACE(pSptd->getTraceKey(ServantProxyThreadData::TraceContext::EST_CR), TRACE_ANNOTATION_CR, ServerConfig::Application + "." + ServerConfig::ServerName, tars_name(), "testTimeout", 0, _trace_param_, "");
- }
- return _ret;
- }
- void async_testTimeout(HelloPrxCallbackPtr callback,tars::Int32 timeout,const map<string, string>& context = TARS_CONTEXT())
- {
- tars::TarsOutputStream<tars::BufferWriterVector> _os;
- _os.write(timeout, 1);
- std::map<string, string> _mStatus;
- ServantProxyThreadData *pSptd = ServantProxyThreadData::getData();
- if (pSptd && pSptd->_traceCall)
- {
- pSptd->newSpan();
- string _trace_param_;
- int _trace_param_flag_ = pSptd->needTraceParam(ServantProxyThreadData::TraceContext::EST_CS, _os.getLength());
- if (ServantProxyThreadData::TraceContext::ENP_NORMAL == _trace_param_flag_)
- {
- tars::JsonValueObjPtr _p_ = new tars::JsonValueObj();
- _p_->value["timeout"] = tars::JsonOutput::writeJson(timeout);
- _trace_param_ = tars::TC_Json::writeValue(_p_);
- }
- else if(ServantProxyThreadData::TraceContext::ENP_OVERMAXLEN == _trace_param_flag_)
- {
- _trace_param_ = "{\"trace_param_over_max_len\":true}";
- }
- TARS_TRACE(pSptd->getTraceKey(ServantProxyThreadData::TraceContext::EST_CS), TRACE_ANNOTATION_CS, ServerConfig::Application + "." + ServerConfig::ServerName, tars_name(), "testTimeout", 0, _trace_param_, "");
- }
- tars_invoke_async(tars::TARSNORMAL,"testTimeout", _os, context, _mStatus, callback);
- }
-
- tars::Future< HelloPrxCallbackPromise::PromisetestTimeoutPtr > promise_async_testTimeout(tars::Int32 timeout,const map<string, string>& context)
- {
- tars::Promise< HelloPrxCallbackPromise::PromisetestTimeoutPtr > promise;
- HelloPrxCallbackPromisePtr callback = new HelloPrxCallbackPromise(promise);
- tars::TarsOutputStream<tars::BufferWriterVector> _os;
- _os.write(timeout, 1);
- std::map<string, string> _mStatus;
- tars_invoke_async(tars::TARSNORMAL,"testTimeout", _os, context, _mStatus, callback);
- return promise.getFuture();
- }
- void coro_testTimeout(HelloCoroPrxCallbackPtr callback,tars::Int32 timeout,const map<string, string>& context = TARS_CONTEXT())
- {
- tars::TarsOutputStream<tars::BufferWriterVector> _os;
- _os.write(timeout, 1);
- std::map<string, string> _mStatus;
- tars_invoke_async(tars::TARSNORMAL,"testTimeout", _os, context, _mStatus, callback, true);
- }
- tars::Int32 testTrans(tars::Int32 index,const std::string & s,std::string &r,const map<string, string> &context = TARS_CONTEXT(),map<string, string> * pResponseContext = NULL)
- {
- tars::TarsOutputStream<tars::BufferWriterVector> _os;
- _os.write(index, 1);
- _os.write(s, 2);
- _os.write(r, 3);
- ServantProxyThreadData *pSptd = ServantProxyThreadData::getData();
- if (pSptd && pSptd->_traceCall)
- {
- pSptd->newSpan();
- string _trace_param_;
- int _trace_param_flag_ = pSptd->needTraceParam(ServantProxyThreadData::TraceContext::EST_CS, _os.getLength());
- if (ServantProxyThreadData::TraceContext::ENP_NORMAL == _trace_param_flag_)
- {
- tars::JsonValueObjPtr _p_ = new tars::JsonValueObj();
- _p_->value["index"] = tars::JsonOutput::writeJson(index);
- _p_->value["s"] = tars::JsonOutput::writeJson(s);
- _trace_param_ = tars::TC_Json::writeValue(_p_);
- }
- else if(ServantProxyThreadData::TraceContext::ENP_OVERMAXLEN == _trace_param_flag_)
- {
- _trace_param_ = "{\"trace_param_over_max_len\":true}";
- }
- TARS_TRACE(pSptd->getTraceKey(ServantProxyThreadData::TraceContext::EST_CS), TRACE_ANNOTATION_CS, ServerConfig::Application + "." + ServerConfig::ServerName, tars_name(), "testTrans", 0, _trace_param_, "");
- }
- std::map<string, string> _mStatus;
- shared_ptr<tars::ResponsePacket> rep = tars_invoke(tars::TARSNORMAL,"testTrans", _os, context, _mStatus);
- if(pResponseContext)
- {
- pResponseContext->swap(rep->context);
- }
- tars::TarsInputStream<tars::BufferReader> _is;
- _is.setBuffer(rep->sBuffer);
- tars::Int32 _ret;
- _is.read(_ret, 0, true);
- _is.read(r, 3, true);
- if (pSptd && pSptd->_traceCall)
- {
- string _trace_param_;
- int _trace_param_flag_ = pSptd->needTraceParam(ServantProxyThreadData::TraceContext::EST_CR, _is.size());
- if (ServantProxyThreadData::TraceContext::ENP_NORMAL == _trace_param_flag_)
- {
- tars::JsonValueObjPtr _p_ = new tars::JsonValueObj();
- _p_->value[""] = tars::JsonOutput::writeJson(_ret);
- _p_->value["r"] = tars::JsonOutput::writeJson(r);
- _trace_param_ = tars::TC_Json::writeValue(_p_);
- }
- else if(ServantProxyThreadData::TraceContext::ENP_OVERMAXLEN == _trace_param_flag_)
- {
- _trace_param_ = "{\"trace_param_over_max_len\":true}";
- }
- TARS_TRACE(pSptd->getTraceKey(ServantProxyThreadData::TraceContext::EST_CR), TRACE_ANNOTATION_CR, ServerConfig::Application + "." + ServerConfig::ServerName, tars_name(), "testTrans", 0, _trace_param_, "");
- }
- return _ret;
- }
- void async_testTrans(HelloPrxCallbackPtr callback,tars::Int32 index,const std::string &s,const map<string, string>& context = TARS_CONTEXT())
- {
- tars::TarsOutputStream<tars::BufferWriterVector> _os;
- _os.write(index, 1);
- _os.write(s, 2);
- std::map<string, string> _mStatus;
- ServantProxyThreadData *pSptd = ServantProxyThreadData::getData();
- if (pSptd && pSptd->_traceCall)
- {
- pSptd->newSpan();
- string _trace_param_;
- int _trace_param_flag_ = pSptd->needTraceParam(ServantProxyThreadData::TraceContext::EST_CS, _os.getLength());
- if (ServantProxyThreadData::TraceContext::ENP_NORMAL == _trace_param_flag_)
- {
- tars::JsonValueObjPtr _p_ = new tars::JsonValueObj();
- _p_->value["index"] = tars::JsonOutput::writeJson(index);
- _p_->value["s"] = tars::JsonOutput::writeJson(s);
- _trace_param_ = tars::TC_Json::writeValue(_p_);
- }
- else if(ServantProxyThreadData::TraceContext::ENP_OVERMAXLEN == _trace_param_flag_)
- {
- _trace_param_ = "{\"trace_param_over_max_len\":true}";
- }
- TARS_TRACE(pSptd->getTraceKey(ServantProxyThreadData::TraceContext::EST_CS), TRACE_ANNOTATION_CS, ServerConfig::Application + "." + ServerConfig::ServerName, tars_name(), "testTrans", 0, _trace_param_, "");
- }
- tars_invoke_async(tars::TARSNORMAL,"testTrans", _os, context, _mStatus, callback);
- }
-
- tars::Future< HelloPrxCallbackPromise::PromisetestTransPtr > promise_async_testTrans(tars::Int32 index,const std::string &s,const map<string, string>& context)
- {
- tars::Promise< HelloPrxCallbackPromise::PromisetestTransPtr > promise;
- HelloPrxCallbackPromisePtr callback = new HelloPrxCallbackPromise(promise);
- tars::TarsOutputStream<tars::BufferWriterVector> _os;
- _os.write(index, 1);
- _os.write(s, 2);
- std::map<string, string> _mStatus;
- tars_invoke_async(tars::TARSNORMAL,"testTrans", _os, context, _mStatus, callback);
- return promise.getFuture();
- }
- void coro_testTrans(HelloCoroPrxCallbackPtr callback,tars::Int32 index,const std::string &s,const map<string, string>& context = TARS_CONTEXT())
- {
- tars::TarsOutputStream<tars::BufferWriterVector> _os;
- _os.write(index, 1);
- _os.write(s, 2);
- std::map<string, string> _mStatus;
- tars_invoke_async(tars::TARSNORMAL,"testTrans", _os, context, _mStatus, callback, true);
- }
- HelloProxy* tars_hash(int64_t key)
- {
- return (HelloProxy*)ServantProxy::tars_hash(key);
- }
- HelloProxy* tars_consistent_hash(int64_t key)
- {
- return (HelloProxy*)ServantProxy::tars_consistent_hash(key);
- }
- HelloProxy* tars_open_trace(bool traceParam = false)
- {
- return (HelloProxy*)ServantProxy::tars_open_trace(traceParam);
- }
- HelloProxy* tars_set_timeout(int msecond)
- {
- return (HelloProxy*)ServantProxy::tars_set_timeout(msecond);
- }
- static const char* tars_prxname() { return "HelloProxy"; }
- };
- typedef tars::TC_AutoPtr<HelloProxy> HelloPrx;
- /* servant for server */
- class Hello : public tars::Servant
- {
- public:
- virtual ~Hello(){}
- virtual tars::Int32 testConHash(std::string &sOut,tars::TarsCurrentPtr current) = 0;
- static void async_response_testConHash(tars::TarsCurrentPtr current, tars::Int32 _ret, const std::string &sOut)
- {
- size_t _rsp_len_ = 0;
- if (current->getRequestVersion() == TUPVERSION )
- {
- UniAttribute<tars::BufferWriterVector, tars::BufferReader> tarsAttr;
- tarsAttr.setVersion(current->getRequestVersion());
- tarsAttr.put("", _ret);
- tarsAttr.put("tars_ret", _ret);
- tarsAttr.put("sOut", sOut);
- vector<char> sTupResponseBuffer;
- tarsAttr.encode(sTupResponseBuffer);
- current->sendResponse(tars::TARSSERVERSUCCESS, sTupResponseBuffer);
- _rsp_len_ = sTupResponseBuffer.size();
- }
- else if (current->getRequestVersion() == JSONVERSION)
- {
- tars::JsonValueObjPtr _p = new tars::JsonValueObj();
- _p->value["sOut"] = tars::JsonOutput::writeJson(sOut);
- _p->value["tars_ret"] = tars::JsonOutput::writeJson(_ret);
- vector<char> sJsonResponseBuffer;
- tars::TC_Json::writeValue(_p, sJsonResponseBuffer);
- current->sendResponse(tars::TARSSERVERSUCCESS, sJsonResponseBuffer);
- _rsp_len_ = sJsonResponseBuffer.size();
- }
- else
- {
- tars::TarsOutputStream<tars::BufferWriterVector> _os;
- _os.write(_ret, 0);
- _os.write(sOut, 1);
- current->sendResponse(tars::TARSSERVERSUCCESS, _os.getByteBuffer());
- _rsp_len_ = _os.getLength();
- }
- if (current->isTraced())
- {
- string _trace_param_;
- int _trace_param_flag_ = ServantProxyThreadData::needTraceParam(ServantProxyThreadData::TraceContext::EST_SS, current->getTraceKey(), _rsp_len_);
- if (ServantProxyThreadData::TraceContext::ENP_NORMAL == _trace_param_flag_)
- {
- tars::JsonValueObjPtr _p_ = new tars::JsonValueObj();
- _p_->value[""] = tars::JsonOutput::writeJson(_ret);
- _p_->value["sOut"] = tars::JsonOutput::writeJson(sOut);
- _trace_param_ = tars::TC_Json::writeValue(_p_);
- }
- else if(ServantProxyThreadData::TraceContext::ENP_OVERMAXLEN == _trace_param_flag_)
- {
- _trace_param_ = "{\"trace_param_over_max_len\":true}";
- }
- TARS_TRACE(current->getTraceKey(), TRACE_ANNOTATION_SS, "", ServerConfig::Application + "." + ServerConfig::ServerName, "testConHash", 0, _trace_param_, "");
- }
- }
- virtual tars::Bool testCoro(const std::string & sIn,std::string &sOut,tars::TarsCurrentPtr current) = 0;
- static void async_response_testCoro(tars::TarsCurrentPtr current, tars::Bool _ret, const std::string &sOut)
- {
- size_t _rsp_len_ = 0;
- if (current->getRequestVersion() == TUPVERSION )
- {
- UniAttribute<tars::BufferWriterVector, tars::BufferReader> tarsAttr;
- tarsAttr.setVersion(current->getRequestVersion());
- tarsAttr.put("", _ret);
- tarsAttr.put("tars_ret", _ret);
- tarsAttr.put("sOut", sOut);
- vector<char> sTupResponseBuffer;
- tarsAttr.encode(sTupResponseBuffer);
- current->sendResponse(tars::TARSSERVERSUCCESS, sTupResponseBuffer);
- _rsp_len_ = sTupResponseBuffer.size();
- }
- else if (current->getRequestVersion() == JSONVERSION)
- {
- tars::JsonValueObjPtr _p = new tars::JsonValueObj();
- _p->value["sOut"] = tars::JsonOutput::writeJson(sOut);
- _p->value["tars_ret"] = tars::JsonOutput::writeJson(_ret);
- vector<char> sJsonResponseBuffer;
- tars::TC_Json::writeValue(_p, sJsonResponseBuffer);
- current->sendResponse(tars::TARSSERVERSUCCESS, sJsonResponseBuffer);
- _rsp_len_ = sJsonResponseBuffer.size();
- }
- else
- {
- tars::TarsOutputStream<tars::BufferWriterVector> _os;
- _os.write(_ret, 0);
- _os.write(sOut, 2);
- current->sendResponse(tars::TARSSERVERSUCCESS, _os.getByteBuffer());
- _rsp_len_ = _os.getLength();
- }
- if (current->isTraced())
- {
- string _trace_param_;
- int _trace_param_flag_ = ServantProxyThreadData::needTraceParam(ServantProxyThreadData::TraceContext::EST_SS, current->getTraceKey(), _rsp_len_);
- if (ServantProxyThreadData::TraceContext::ENP_NORMAL == _trace_param_flag_)
- {
- tars::JsonValueObjPtr _p_ = new tars::JsonValueObj();
- _p_->value[""] = tars::JsonOutput::writeJson(_ret);
- _p_->value["sOut"] = tars::JsonOutput::writeJson(sOut);
- _trace_param_ = tars::TC_Json::writeValue(_p_);
- }
- else if(ServantProxyThreadData::TraceContext::ENP_OVERMAXLEN == _trace_param_flag_)
- {
- _trace_param_ = "{\"trace_param_over_max_len\":true}";
- }
- TARS_TRACE(current->getTraceKey(), TRACE_ANNOTATION_SS, "", ServerConfig::Application + "." + ServerConfig::ServerName, "testCoro", 0, _trace_param_, "");
- }
- }
- virtual tars::Int32 testDyeing(const std::string & strIn,std::string &strOut,tars::TarsCurrentPtr current) = 0;
- static void async_response_testDyeing(tars::TarsCurrentPtr current, tars::Int32 _ret, const std::string &strOut)
- {
- size_t _rsp_len_ = 0;
- if (current->getRequestVersion() == TUPVERSION )
- {
- UniAttribute<tars::BufferWriterVector, tars::BufferReader> tarsAttr;
- tarsAttr.setVersion(current->getRequestVersion());
- tarsAttr.put("", _ret);
- tarsAttr.put("tars_ret", _ret);
- tarsAttr.put("strOut", strOut);
- vector<char> sTupResponseBuffer;
- tarsAttr.encode(sTupResponseBuffer);
- current->sendResponse(tars::TARSSERVERSUCCESS, sTupResponseBuffer);
- _rsp_len_ = sTupResponseBuffer.size();
- }
- else if (current->getRequestVersion() == JSONVERSION)
- {
- tars::JsonValueObjPtr _p = new tars::JsonValueObj();
- _p->value["strOut"] = tars::JsonOutput::writeJson(strOut);
- _p->value["tars_ret"] = tars::JsonOutput::writeJson(_ret);
- vector<char> sJsonResponseBuffer;
- tars::TC_Json::writeValue(_p, sJsonResponseBuffer);
- current->sendResponse(tars::TARSSERVERSUCCESS, sJsonResponseBuffer);
- _rsp_len_ = sJsonResponseBuffer.size();
- }
- else
- {
- tars::TarsOutputStream<tars::BufferWriterVector> _os;
- _os.write(_ret, 0);
- _os.write(strOut, 2);
- current->sendResponse(tars::TARSSERVERSUCCESS, _os.getByteBuffer());
- _rsp_len_ = _os.getLength();
- }
- if (current->isTraced())
- {
- string _trace_param_;
- int _trace_param_flag_ = ServantProxyThreadData::needTraceParam(ServantProxyThreadData::TraceContext::EST_SS, current->getTraceKey(), _rsp_len_);
- if (ServantProxyThreadData::TraceContext::ENP_NORMAL == _trace_param_flag_)
- {
- tars::JsonValueObjPtr _p_ = new tars::JsonValueObj();
- _p_->value[""] = tars::JsonOutput::writeJson(_ret);
- _p_->value["strOut"] = tars::JsonOutput::writeJson(strOut);
- _trace_param_ = tars::TC_Json::writeValue(_p_);
- }
- else if(ServantProxyThreadData::TraceContext::ENP_OVERMAXLEN == _trace_param_flag_)
- {
- _trace_param_ = "{\"trace_param_over_max_len\":true}";
- }
- TARS_TRACE(current->getTraceKey(), TRACE_ANNOTATION_SS, "", ServerConfig::Application + "." + ServerConfig::ServerName, "testDyeing", 0, _trace_param_, "");
- }
- }
- virtual tars::Int32 testDyeingTrans(tars::TarsCurrentPtr current) = 0;
- static void async_response_testDyeingTrans(tars::TarsCurrentPtr current, tars::Int32 _ret)
- {
- size_t _rsp_len_ = 0;
- if (current->getRequestVersion() == TUPVERSION )
- {
- UniAttribute<tars::BufferWriterVector, tars::BufferReader> tarsAttr;
- tarsAttr.setVersion(current->getRequestVersion());
- tarsAttr.put("", _ret);
- tarsAttr.put("tars_ret", _ret);
- vector<char> sTupResponseBuffer;
- tarsAttr.encode(sTupResponseBuffer);
- current->sendResponse(tars::TARSSERVERSUCCESS, sTupResponseBuffer);
- _rsp_len_ = sTupResponseBuffer.size();
- }
- else if (current->getRequestVersion() == JSONVERSION)
- {
- tars::JsonValueObjPtr _p = new tars::JsonValueObj();
- _p->value["tars_ret"] = tars::JsonOutput::writeJson(_ret);
- vector<char> sJsonResponseBuffer;
- tars::TC_Json::writeValue(_p, sJsonResponseBuffer);
- current->sendResponse(tars::TARSSERVERSUCCESS, sJsonResponseBuffer);
- _rsp_len_ = sJsonResponseBuffer.size();
- }
- else
- {
- tars::TarsOutputStream<tars::BufferWriterVector> _os;
- _os.write(_ret, 0);
- current->sendResponse(tars::TARSSERVERSUCCESS, _os.getByteBuffer());
- _rsp_len_ = _os.getLength();
- }
- if (current->isTraced())
- {
- string _trace_param_;
- int _trace_param_flag_ = ServantProxyThreadData::needTraceParam(ServantProxyThreadData::TraceContext::EST_SS, current->getTraceKey(), _rsp_len_);
- if (ServantProxyThreadData::TraceContext::ENP_NORMAL == _trace_param_flag_)
- {
- tars::JsonValueObjPtr _p_ = new tars::JsonValueObj();
- _p_->value[""] = tars::JsonOutput::writeJson(_ret);
- _trace_param_ = tars::TC_Json::writeValue(_p_);
- }
- else if(ServantProxyThreadData::TraceContext::ENP_OVERMAXLEN == _trace_param_flag_)
- {
- _trace_param_ = "{\"trace_param_over_max_len\":true}";
- }
- TARS_TRACE(current->getTraceKey(), TRACE_ANNOTATION_SS, "", ServerConfig::Application + "." + ServerConfig::ServerName, "testDyeingTrans", 0, _trace_param_, "");
- }
- }
- virtual tars::Int32 testHello(tars::Int32 index,const std::string & s,std::string &r,tars::TarsCurrentPtr current) = 0;
- static void async_response_testHello(tars::TarsCurrentPtr current, tars::Int32 _ret, const std::string &r)
- {
- size_t _rsp_len_ = 0;
- if (current->getRequestVersion() == TUPVERSION )
- {
- UniAttribute<tars::BufferWriterVector, tars::BufferReader> tarsAttr;
- tarsAttr.setVersion(current->getRequestVersion());
- tarsAttr.put("", _ret);
- tarsAttr.put("tars_ret", _ret);
- tarsAttr.put("r", r);
- vector<char> sTupResponseBuffer;
- tarsAttr.encode(sTupResponseBuffer);
- current->sendResponse(tars::TARSSERVERSUCCESS, sTupResponseBuffer);
- _rsp_len_ = sTupResponseBuffer.size();
- }
- else if (current->getRequestVersion() == JSONVERSION)
- {
- tars::JsonValueObjPtr _p = new tars::JsonValueObj();
- _p->value["r"] = tars::JsonOutput::writeJson(r);
- _p->value["tars_ret"] = tars::JsonOutput::writeJson(_ret);
- vector<char> sJsonResponseBuffer;
- tars::TC_Json::writeValue(_p, sJsonResponseBuffer);
- current->sendResponse(tars::TARSSERVERSUCCESS, sJsonResponseBuffer);
- _rsp_len_ = sJsonResponseBuffer.size();
- }
- else
- {
- tars::TarsOutputStream<tars::BufferWriterVector> _os;
- _os.write(_ret, 0);
- _os.write(r, 3);
- current->sendResponse(tars::TARSSERVERSUCCESS, _os.getByteBuffer());
- _rsp_len_ = _os.getLength();
- }
- if (current->isTraced())
- {
- string _trace_param_;
- int _trace_param_flag_ = ServantProxyThreadData::needTraceParam(ServantProxyThreadData::TraceContext::EST_SS, current->getTraceKey(), _rsp_len_);
- if (ServantProxyThreadData::TraceContext::ENP_NORMAL == _trace_param_flag_)
- {
- tars::JsonValueObjPtr _p_ = new tars::JsonValueObj();
- _p_->value[""] = tars::JsonOutput::writeJson(_ret);
- _p_->value["r"] = tars::JsonOutput::writeJson(r);
- _trace_param_ = tars::TC_Json::writeValue(_p_);
- }
- else if(ServantProxyThreadData::TraceContext::ENP_OVERMAXLEN == _trace_param_flag_)
- {
- _trace_param_ = "{\"trace_param_over_max_len\":true}";
- }
- TARS_TRACE(current->getTraceKey(), TRACE_ANNOTATION_SS, "", ServerConfig::Application + "." + ServerConfig::ServerName, "testHello", 0, _trace_param_, "");
- }
- }
- virtual tars::Int32 testPid(std::string &r,tars::TarsCurrentPtr current) = 0;
- static void async_response_testPid(tars::TarsCurrentPtr current, tars::Int32 _ret, const std::string &r)
- {
- size_t _rsp_len_ = 0;
- if (current->getRequestVersion() == TUPVERSION )
- {
- UniAttribute<tars::BufferWriterVector, tars::BufferReader> tarsAttr;
- tarsAttr.setVersion(current->getRequestVersion());
- tarsAttr.put("", _ret);
- tarsAttr.put("tars_ret", _ret);
- tarsAttr.put("r", r);
- vector<char> sTupResponseBuffer;
- tarsAttr.encode(sTupResponseBuffer);
- current->sendResponse(tars::TARSSERVERSUCCESS, sTupResponseBuffer);
- _rsp_len_ = sTupResponseBuffer.size();
- }
- else if (current->getRequestVersion() == JSONVERSION)
- {
- tars::JsonValueObjPtr _p = new tars::JsonValueObj();
- _p->value["r"] = tars::JsonOutput::writeJson(r);
- _p->value["tars_ret"] = tars::JsonOutput::writeJson(_ret);
- vector<char> sJsonResponseBuffer;
- tars::TC_Json::writeValue(_p, sJsonResponseBuffer);
- current->sendResponse(tars::TARSSERVERSUCCESS, sJsonResponseBuffer);
- _rsp_len_ = sJsonResponseBuffer.size();
- }
- else
- {
- tars::TarsOutputStream<tars::BufferWriterVector> _os;
- _os.write(_ret, 0);
- _os.write(r, 1);
- current->sendResponse(tars::TARSSERVERSUCCESS, _os.getByteBuffer());
- _rsp_len_ = _os.getLength();
- }
- if (current->isTraced())
- {
- string _trace_param_;
- int _trace_param_flag_ = ServantProxyThreadData::needTraceParam(ServantProxyThreadData::TraceContext::EST_SS, current->getTraceKey(), _rsp_len_);
- if (ServantProxyThreadData::TraceContext::ENP_NORMAL == _trace_param_flag_)
- {
- tars::JsonValueObjPtr _p_ = new tars::JsonValueObj();
- _p_->value[""] = tars::JsonOutput::writeJson(_ret);
- _p_->value["r"] = tars::JsonOutput::writeJson(r);
- _trace_param_ = tars::TC_Json::writeValue(_p_);
- }
- else if(ServantProxyThreadData::TraceContext::ENP_OVERMAXLEN == _trace_param_flag_)
- {
- _trace_param_ = "{\"trace_param_over_max_len\":true}";
- }
- TARS_TRACE(current->getTraceKey(), TRACE_ANNOTATION_SS, "", ServerConfig::Application + "." + ServerConfig::ServerName, "testPid", 0, _trace_param_, "");
- }
- }
- virtual tars::Int32 testSyncTrans(tars::Int32 index,const std::string & s,std::string &r,tars::TarsCurrentPtr current) = 0;
- static void async_response_testSyncTrans(tars::TarsCurrentPtr current, tars::Int32 _ret, const std::string &r)
- {
- size_t _rsp_len_ = 0;
- if (current->getRequestVersion() == TUPVERSION )
- {
- UniAttribute<tars::BufferWriterVector, tars::BufferReader> tarsAttr;
- tarsAttr.setVersion(current->getRequestVersion());
- tarsAttr.put("", _ret);
- tarsAttr.put("tars_ret", _ret);
- tarsAttr.put("r", r);
- vector<char> sTupResponseBuffer;
- tarsAttr.encode(sTupResponseBuffer);
- current->sendResponse(tars::TARSSERVERSUCCESS, sTupResponseBuffer);
- _rsp_len_ = sTupResponseBuffer.size();
- }
- else if (current->getRequestVersion() == JSONVERSION)
- {
- tars::JsonValueObjPtr _p = new tars::JsonValueObj();
- _p->value["r"] = tars::JsonOutput::writeJson(r);
- _p->value["tars_ret"] = tars::JsonOutput::writeJson(_ret);
- vector<char> sJsonResponseBuffer;
- tars::TC_Json::writeValue(_p, sJsonResponseBuffer);
- current->sendResponse(tars::TARSSERVERSUCCESS, sJsonResponseBuffer);
- _rsp_len_ = sJsonResponseBuffer.size();
- }
- else
- {
- tars::TarsOutputStream<tars::BufferWriterVector> _os;
- _os.write(_ret, 0);
- _os.write(r, 3);
- current->sendResponse(tars::TARSSERVERSUCCESS, _os.getByteBuffer());
- _rsp_len_ = _os.getLength();
- }
- if (current->isTraced())
- {
- string _trace_param_;
- int _trace_param_flag_ = ServantProxyThreadData::needTraceParam(ServantProxyThreadData::TraceContext::EST_SS, current->getTraceKey(), _rsp_len_);
- if (ServantProxyThreadData::TraceContext::ENP_NORMAL == _trace_param_flag_)
- {
- tars::JsonValueObjPtr _p_ = new tars::JsonValueObj();
- _p_->value[""] = tars::JsonOutput::writeJson(_ret);
- _p_->value["r"] = tars::JsonOutput::writeJson(r);
- _trace_param_ = tars::TC_Json::writeValue(_p_);
- }
- else if(ServantProxyThreadData::TraceContext::ENP_OVERMAXLEN == _trace_param_flag_)
- {
- _trace_param_ = "{\"trace_param_over_max_len\":true}";
- }
- TARS_TRACE(current->getTraceKey(), TRACE_ANNOTATION_SS, "", ServerConfig::Application + "." + ServerConfig::ServerName, "testSyncTrans", 0, _trace_param_, "");
- }
- }
- virtual tars::Int32 testTimeout(tars::Int32 timeout,tars::TarsCurrentPtr current) = 0;
- static void async_response_testTimeout(tars::TarsCurrentPtr current, tars::Int32 _ret)
- {
- size_t _rsp_len_ = 0;
- if (current->getRequestVersion() == TUPVERSION )
- {
- UniAttribute<tars::BufferWriterVector, tars::BufferReader> tarsAttr;
- tarsAttr.setVersion(current->getRequestVersion());
- tarsAttr.put("", _ret);
- tarsAttr.put("tars_ret", _ret);
- vector<char> sTupResponseBuffer;
- tarsAttr.encode(sTupResponseBuffer);
- current->sendResponse(tars::TARSSERVERSUCCESS, sTupResponseBuffer);
- _rsp_len_ = sTupResponseBuffer.size();
- }
- else if (current->getRequestVersion() == JSONVERSION)
- {
- tars::JsonValueObjPtr _p = new tars::JsonValueObj();
- _p->value["tars_ret"] = tars::JsonOutput::writeJson(_ret);
- vector<char> sJsonResponseBuffer;
- tars::TC_Json::writeValue(_p, sJsonResponseBuffer);
- current->sendResponse(tars::TARSSERVERSUCCESS, sJsonResponseBuffer);
- _rsp_len_ = sJsonResponseBuffer.size();
- }
- else
- {
- tars::TarsOutputStream<tars::BufferWriterVector> _os;
- _os.write(_ret, 0);
- current->sendResponse(tars::TARSSERVERSUCCESS, _os.getByteBuffer());
- _rsp_len_ = _os.getLength();
- }
- if (current->isTraced())
- {
- string _trace_param_;
- int _trace_param_flag_ = ServantProxyThreadData::needTraceParam(ServantProxyThreadData::TraceContext::EST_SS, current->getTraceKey(), _rsp_len_);
- if (ServantProxyThreadData::TraceContext::ENP_NORMAL == _trace_param_flag_)
- {
- tars::JsonValueObjPtr _p_ = new tars::JsonValueObj();
- _p_->value[""] = tars::JsonOutput::writeJson(_ret);
- _trace_param_ = tars::TC_Json::writeValue(_p_);
- }
- else if(ServantProxyThreadData::TraceContext::ENP_OVERMAXLEN == _trace_param_flag_)
- {
- _trace_param_ = "{\"trace_param_over_max_len\":true}";
- }
- TARS_TRACE(current->getTraceKey(), TRACE_ANNOTATION_SS, "", ServerConfig::Application + "." + ServerConfig::ServerName, "testTimeout", 0, _trace_param_, "");
- }
- }
- virtual tars::Int32 testTrans(tars::Int32 index,const std::string & s,std::string &r,tars::TarsCurrentPtr current) = 0;
- static void async_response_testTrans(tars::TarsCurrentPtr current, tars::Int32 _ret, const std::string &r)
- {
- size_t _rsp_len_ = 0;
- if (current->getRequestVersion() == TUPVERSION )
- {
- UniAttribute<tars::BufferWriterVector, tars::BufferReader> tarsAttr;
- tarsAttr.setVersion(current->getRequestVersion());
- tarsAttr.put("", _ret);
- tarsAttr.put("tars_ret", _ret);
- tarsAttr.put("r", r);
- vector<char> sTupResponseBuffer;
- tarsAttr.encode(sTupResponseBuffer);
- current->sendResponse(tars::TARSSERVERSUCCESS, sTupResponseBuffer);
- _rsp_len_ = sTupResponseBuffer.size();
- }
- else if (current->getRequestVersion() == JSONVERSION)
- {
- tars::JsonValueObjPtr _p = new tars::JsonValueObj();
- _p->value["r"] = tars::JsonOutput::writeJson(r);
- _p->value["tars_ret"] = tars::JsonOutput::writeJson(_ret);
- vector<char> sJsonResponseBuffer;
- tars::TC_Json::writeValue(_p, sJsonResponseBuffer);
- current->sendResponse(tars::TARSSERVERSUCCESS, sJsonResponseBuffer);
- _rsp_len_ = sJsonResponseBuffer.size();
- }
- else
- {
- tars::TarsOutputStream<tars::BufferWriterVector> _os;
- _os.write(_ret, 0);
- _os.write(r, 3);
- current->sendResponse(tars::TARSSERVERSUCCESS, _os.getByteBuffer());
- _rsp_len_ = _os.getLength();
- }
- if (current->isTraced())
- {
- string _trace_param_;
- int _trace_param_flag_ = ServantProxyThreadData::needTraceParam(ServantProxyThreadData::TraceContext::EST_SS, current->getTraceKey(), _rsp_len_);
- if (ServantProxyThreadData::TraceContext::ENP_NORMAL == _trace_param_flag_)
- {
- tars::JsonValueObjPtr _p_ = new tars::JsonValueObj();
- _p_->value[""] = tars::JsonOutput::writeJson(_ret);
- _p_->value["r"] = tars::JsonOutput::writeJson(r);
- _trace_param_ = tars::TC_Json::writeValue(_p_);
- }
- else if(ServantProxyThreadData::TraceContext::ENP_OVERMAXLEN == _trace_param_flag_)
- {
- _trace_param_ = "{\"trace_param_over_max_len\":true}";
- }
- TARS_TRACE(current->getTraceKey(), TRACE_ANNOTATION_SS, "", ServerConfig::Application + "." + ServerConfig::ServerName, "testTrans", 0, _trace_param_, "");
- }
- }
- public:
- int onDispatch(tars::TarsCurrentPtr _current, vector<char> &_sResponseBuffer)
- {
- static ::std::string __Test__Hello_all[]=
- {
- "testConHash",
- "testCoro",
- "testDyeing",
- "testDyeingTrans",
- "testHello",
- "testPid",
- "testSyncTrans",
- "testTimeout",
- "testTrans"
- };
- pair<string*, string*> r = equal_range(__Test__Hello_all, __Test__Hello_all+9, _current->getFuncName());
- if(r.first == r.second) return tars::TARSSERVERNOFUNCERR;
- switch(r.first - __Test__Hello_all)
- {
- case 0:
- {
- tars::TarsInputStream<tars::BufferReader> _is;
- _is.setBuffer(_current->getRequestBuffer());
- std::string sOut;
- if (_current->getRequestVersion() == TUPVERSION)
- {
- UniAttribute<tars::BufferWriterVector, tars::BufferReader> tarsAttr;
- tarsAttr.setVersion(_current->getRequestVersion());
- tarsAttr.decode(_current->getRequestBuffer());
- tarsAttr.getByDefault("sOut", sOut, sOut);
- }
- else if (_current->getRequestVersion() == JSONVERSION)
- {
- tars::JsonValueObjPtr _jsonPtr = tars::JsonValueObjPtr::dynamicCast(tars::TC_Json::getValue(_current->getRequestBuffer()));
- tars::JsonInput::readJson(sOut, _jsonPtr->value["sOut"], false);
- }
- else
- {
- _is.read(sOut, 1, false);
- }
- ServantProxyThreadData *pSptd = ServantProxyThreadData::getData();
- if (pSptd && pSptd->_traceCall)
- {
- string _trace_param_;
- int _trace_param_flag_ = pSptd->needTraceParam(ServantProxyThreadData::TraceContext::EST_SR, _is.size());
- if (ServantProxyThreadData::TraceContext::ENP_NORMAL == _trace_param_flag_)
- {
- tars::JsonValueObjPtr _p_ = new tars::JsonValueObj();
- _trace_param_ = tars::TC_Json::writeValue(_p_);
- }
- else if(ServantProxyThreadData::TraceContext::ENP_OVERMAXLEN == _trace_param_flag_)
- {
- _trace_param_ = "{\"trace_param_over_max_len\":true}";
- }
- TARS_TRACE(pSptd->getTraceKey(ServantProxyThreadData::TraceContext::EST_SR), TRACE_ANNOTATION_SR, "", ServerConfig::Application + "." + ServerConfig::ServerName, "testConHash", 0, _trace_param_, "");
- }
- tars::Int32 _ret = testConHash(sOut, _current);
- if(_current->isResponse())
- {
- if (_current->getRequestVersion() == TUPVERSION)
- {
- UniAttribute<tars::BufferWriterVector, tars::BufferReader> tarsAttr;
- tarsAttr.setVersion(_current->getRequestVersion());
- tarsAttr.put("", _ret);
- tarsAttr.put("tars_ret", _ret);
- tarsAttr.put("sOut", sOut);
- tarsAttr.encode(_sResponseBuffer);
- }
- else if (_current->getRequestVersion() == JSONVERSION)
- {
- tars::JsonValueObjPtr _p = new tars::JsonValueObj();
- _p->value["sOut"] = tars::JsonOutput::writeJson(sOut);
- _p->value["tars_ret"] = tars::JsonOutput::writeJson(_ret);
- tars::TC_Json::writeValue(_p, _sResponseBuffer);
- }
- else
- {
- tars::TarsOutputStream<tars::BufferWriterVector> _os;
- _os.write(_ret, 0);
- _os.write(sOut, 1);
- _os.swap(_sResponseBuffer);
- }
- if (pSptd && pSptd->_traceCall)
- {
- string _trace_param_;
- int _trace_param_flag_ = pSptd->needTraceParam(ServantProxyThreadData::TraceContext::EST_SS, _sResponseBuffer.size());
- if (ServantProxyThreadData::TraceContext::ENP_NORMAL == _trace_param_flag_)
- {
- tars::JsonValueObjPtr _p_ = new tars::JsonValueObj();
- _p_->value[""] = tars::JsonOutput::writeJson(_ret);
- _p_->value["sOut"] = tars::JsonOutput::writeJson(sOut);
- _trace_param_ = tars::TC_Json::writeValue(_p_);
- }
- else if(ServantProxyThreadData::TraceContext::ENP_OVERMAXLEN == _trace_param_flag_)
- {
- _trace_param_ = "{\"trace_param_over_max_len\":true}";
- }
- TARS_TRACE(pSptd->getTraceKey(ServantProxyThreadData::TraceContext::EST_SS), TRACE_ANNOTATION_SS, "", ServerConfig::Application + "." + ServerConfig::ServerName, "testConHash", 0, _trace_param_, "");
- }
- }
- else if(pSptd && pSptd->_traceCall)
- {
- _current->setTrace(pSptd->_traceCall, pSptd->getTraceKey(ServantProxyThreadData::TraceContext::EST_SS));
- }
- return tars::TARSSERVERSUCCESS;
- }
- case 1:
- {
- tars::TarsInputStream<tars::BufferReader> _is;
- _is.setBuffer(_current->getRequestBuffer());
- std::string sIn;
- std::string sOut;
- if (_current->getRequestVersion() == TUPVERSION)
- {
- UniAttribute<tars::BufferWriterVector, tars::BufferReader> tarsAttr;
- tarsAttr.setVersion(_current->getRequestVersion());
- tarsAttr.decode(_current->getRequestBuffer());
- tarsAttr.get("sIn", sIn);
- tarsAttr.getByDefault("sOut", sOut, sOut);
- }
- else if (_current->getRequestVersion() == JSONVERSION)
- {
- tars::JsonValueObjPtr _jsonPtr = tars::JsonValueObjPtr::dynamicCast(tars::TC_Json::getValue(_current->getRequestBuffer()));
- tars::JsonInput::readJson(sIn, _jsonPtr->value["sIn"], true);
- tars::JsonInput::readJson(sOut, _jsonPtr->value["sOut"], false);
- }
- else
- {
- _is.read(sIn, 1, true);
- _is.read(sOut, 2, false);
- }
- ServantProxyThreadData *pSptd = ServantProxyThreadData::getData();
- if (pSptd && pSptd->_traceCall)
- {
- string _trace_param_;
- int _trace_param_flag_ = pSptd->needTraceParam(ServantProxyThreadData::TraceContext::EST_SR, _is.size());
- if (ServantProxyThreadData::TraceContext::ENP_NORMAL == _trace_param_flag_)
- {
- tars::JsonValueObjPtr _p_ = new tars::JsonValueObj();
- _p_->value["sIn"] = tars::JsonOutput::writeJson(sIn);
- _trace_param_ = tars::TC_Json::writeValue(_p_);
- }
- else if(ServantProxyThreadData::TraceContext::ENP_OVERMAXLEN == _trace_param_flag_)
- {
- _trace_param_ = "{\"trace_param_over_max_len\":true}";
- }
- TARS_TRACE(pSptd->getTraceKey(ServantProxyThreadData::TraceContext::EST_SR), TRACE_ANNOTATION_SR, "", ServerConfig::Application + "." + ServerConfig::ServerName, "testCoro", 0, _trace_param_, "");
- }
- tars::Bool _ret = testCoro(sIn,sOut, _current);
- if(_current->isResponse())
- {
- if (_current->getRequestVersion() == TUPVERSION)
- {
- UniAttribute<tars::BufferWriterVector, tars::BufferReader> tarsAttr;
- tarsAttr.setVersion(_current->getRequestVersion());
- tarsAttr.put("", _ret);
- tarsAttr.put("tars_ret", _ret);
- tarsAttr.put("sOut", sOut);
- tarsAttr.encode(_sResponseBuffer);
- }
- else if (_current->getRequestVersion() == JSONVERSION)
- {
- tars::JsonValueObjPtr _p = new tars::JsonValueObj();
- _p->value["sOut"] = tars::JsonOutput::writeJson(sOut);
- _p->value["tars_ret"] = tars::JsonOutput::writeJson(_ret);
- tars::TC_Json::writeValue(_p, _sResponseBuffer);
- }
- else
- {
- tars::TarsOutputStream<tars::BufferWriterVector> _os;
- _os.write(_ret, 0);
- _os.write(sOut, 2);
- _os.swap(_sResponseBuffer);
- }
- if (pSptd && pSptd->_traceCall)
- {
- string _trace_param_;
- int _trace_param_flag_ = pSptd->needTraceParam(ServantProxyThreadData::TraceContext::EST_SS, _sResponseBuffer.size());
- if (ServantProxyThreadData::TraceContext::ENP_NORMAL == _trace_param_flag_)
- {
- tars::JsonValueObjPtr _p_ = new tars::JsonValueObj();
- _p_->value[""] = tars::JsonOutput::writeJson(_ret);
- _p_->value["sOut"] = tars::JsonOutput::writeJson(sOut);
- _trace_param_ = tars::TC_Json::writeValue(_p_);
- }
- else if(ServantProxyThreadData::TraceContext::ENP_OVERMAXLEN == _trace_param_flag_)
- {
- _trace_param_ = "{\"trace_param_over_max_len\":true}";
- }
- TARS_TRACE(pSptd->getTraceKey(ServantProxyThreadData::TraceContext::EST_SS), TRACE_ANNOTATION_SS, "", ServerConfig::Application + "." + ServerConfig::ServerName, "testCoro", 0, _trace_param_, "");
- }
- }
- else if(pSptd && pSptd->_traceCall)
- {
- _current->setTrace(pSptd->_traceCall, pSptd->getTraceKey(ServantProxyThreadData::TraceContext::EST_SS));
- }
- return tars::TARSSERVERSUCCESS;
- }
- case 2:
- {
- tars::TarsInputStream<tars::BufferReader> _is;
- _is.setBuffer(_current->getRequestBuffer());
- std::string strIn;
- std::string strOut;
- if (_current->getRequestVersion() == TUPVERSION)
- {
- UniAttribute<tars::BufferWriterVector, tars::BufferReader> tarsAttr;
- tarsAttr.setVersion(_current->getRequestVersion());
- tarsAttr.decode(_current->getRequestBuffer());
- tarsAttr.get("strIn", strIn);
- tarsAttr.getByDefault("strOut", strOut, strOut);
- }
- else if (_current->getRequestVersion() == JSONVERSION)
- {
- tars::JsonValueObjPtr _jsonPtr = tars::JsonValueObjPtr::dynamicCast(tars::TC_Json::getValue(_current->getRequestBuffer()));
- tars::JsonInput::readJson(strIn, _jsonPtr->value["strIn"], true);
- tars::JsonInput::readJson(strOut, _jsonPtr->value["strOut"], false);
- }
- else
- {
- _is.read(strIn, 1, true);
- _is.read(strOut, 2, false);
- }
- ServantProxyThreadData *pSptd = ServantProxyThreadData::getData();
- if (pSptd && pSptd->_traceCall)
- {
- string _trace_param_;
- int _trace_param_flag_ = pSptd->needTraceParam(ServantProxyThreadData::TraceContext::EST_SR, _is.size());
- if (ServantProxyThreadData::TraceContext::ENP_NORMAL == _trace_param_flag_)
- {
- tars::JsonValueObjPtr _p_ = new tars::JsonValueObj();
- _p_->value["strIn"] = tars::JsonOutput::writeJson(strIn);
- _trace_param_ = tars::TC_Json::writeValue(_p_);
- }
- else if(ServantProxyThreadData::TraceContext::ENP_OVERMAXLEN == _trace_param_flag_)
- {
- _trace_param_ = "{\"trace_param_over_max_len\":true}";
- }
- TARS_TRACE(pSptd->getTraceKey(ServantProxyThreadData::TraceContext::EST_SR), TRACE_ANNOTATION_SR, "", ServerConfig::Application + "." + ServerConfig::ServerName, "testDyeing", 0, _trace_param_, "");
- }
- tars::Int32 _ret = testDyeing(strIn,strOut, _current);
- if(_current->isResponse())
- {
- if (_current->getRequestVersion() == TUPVERSION)
- {
- UniAttribute<tars::BufferWriterVector, tars::BufferReader> tarsAttr;
- tarsAttr.setVersion(_current->getRequestVersion());
- tarsAttr.put("", _ret);
- tarsAttr.put("tars_ret", _ret);
- tarsAttr.put("strOut", strOut);
- tarsAttr.encode(_sResponseBuffer);
- }
- else if (_current->getRequestVersion() == JSONVERSION)
- {
- tars::JsonValueObjPtr _p = new tars::JsonValueObj();
- _p->value["strOut"] = tars::JsonOutput::writeJson(strOut);
- _p->value["tars_ret"] = tars::JsonOutput::writeJson(_ret);
- tars::TC_Json::writeValue(_p, _sResponseBuffer);
- }
- else
- {
- tars::TarsOutputStream<tars::BufferWriterVector> _os;
- _os.write(_ret, 0);
- _os.write(strOut, 2);
- _os.swap(_sResponseBuffer);
- }
- if (pSptd && pSptd->_traceCall)
- {
- string _trace_param_;
- int _trace_param_flag_ = pSptd->needTraceParam(ServantProxyThreadData::TraceContext::EST_SS, _sResponseBuffer.size());
- if (ServantProxyThreadData::TraceContext::ENP_NORMAL == _trace_param_flag_)
- {
- tars::JsonValueObjPtr _p_ = new tars::JsonValueObj();
- _p_->value[""] = tars::JsonOutput::writeJson(_ret);
- _p_->value["strOut"] = tars::JsonOutput::writeJson(strOut);
- _trace_param_ = tars::TC_Json::writeValue(_p_);
- }
- else if(ServantProxyThreadData::TraceContext::ENP_OVERMAXLEN == _trace_param_flag_)
- {
- _trace_param_ = "{\"trace_param_over_max_len\":true}";
- }
- TARS_TRACE(pSptd->getTraceKey(ServantProxyThreadData::TraceContext::EST_SS), TRACE_ANNOTATION_SS, "", ServerConfig::Application + "." + ServerConfig::ServerName, "testDyeing", 0, _trace_param_, "");
- }
- }
- else if(pSptd && pSptd->_traceCall)
- {
- _current->setTrace(pSptd->_traceCall, pSptd->getTraceKey(ServantProxyThreadData::TraceContext::EST_SS));
- }
- return tars::TARSSERVERSUCCESS;
- }
- case 3:
- {
- tars::TarsInputStream<tars::BufferReader> _is;
- _is.setBuffer(_current->getRequestBuffer());
- if (_current->getRequestVersion() == TUPVERSION)
- {
- UniAttribute<tars::BufferWriterVector, tars::BufferReader> tarsAttr;
- tarsAttr.setVersion(_current->getRequestVersion());
- tarsAttr.decode(_current->getRequestBuffer());
- }
- else if (_current->getRequestVersion() == JSONVERSION)
- {
- tars::JsonValueObjPtr _jsonPtr = tars::JsonValueObjPtr::dynamicCast(tars::TC_Json::getValue(_current->getRequestBuffer()));
- }
- else
- {
- }
- ServantProxyThreadData *pSptd = ServantProxyThreadData::getData();
- if (pSptd && pSptd->_traceCall)
- {
- string _trace_param_;
- int _trace_param_flag_ = pSptd->needTraceParam(ServantProxyThreadData::TraceContext::EST_SR, _is.size());
- if (ServantProxyThreadData::TraceContext::ENP_NORMAL == _trace_param_flag_)
- {
- tars::JsonValueObjPtr _p_ = new tars::JsonValueObj();
- _trace_param_ = tars::TC_Json::writeValue(_p_);
- }
- else if(ServantProxyThreadData::TraceContext::ENP_OVERMAXLEN == _trace_param_flag_)
- {
- _trace_param_ = "{\"trace_param_over_max_len\":true}";
- }
- TARS_TRACE(pSptd->getTraceKey(ServantProxyThreadData::TraceContext::EST_SR), TRACE_ANNOTATION_SR, "", ServerConfig::Application + "." + ServerConfig::ServerName, "testDyeingTrans", 0, _trace_param_, "");
- }
- tars::Int32 _ret = testDyeingTrans(_current);
- if(_current->isResponse())
- {
- if (_current->getRequestVersion() == TUPVERSION)
- {
- UniAttribute<tars::BufferWriterVector, tars::BufferReader> tarsAttr;
- tarsAttr.setVersion(_current->getRequestVersion());
- tarsAttr.put("", _ret);
- tarsAttr.put("tars_ret", _ret);
- tarsAttr.encode(_sResponseBuffer);
- }
- else if (_current->getRequestVersion() == JSONVERSION)
- {
- tars::JsonValueObjPtr _p = new tars::JsonValueObj();
- _p->value["tars_ret"] = tars::JsonOutput::writeJson(_ret);
- tars::TC_Json::writeValue(_p, _sResponseBuffer);
- }
- else
- {
- tars::TarsOutputStream<tars::BufferWriterVector> _os;
- _os.write(_ret, 0);
- _os.swap(_sResponseBuffer);
- }
- if (pSptd && pSptd->_traceCall)
- {
- string _trace_param_;
- int _trace_param_flag_ = pSptd->needTraceParam(ServantProxyThreadData::TraceContext::EST_SS, _sResponseBuffer.size());
- if (ServantProxyThreadData::TraceContext::ENP_NORMAL == _trace_param_flag_)
- {
- tars::JsonValueObjPtr _p_ = new tars::JsonValueObj();
- _p_->value[""] = tars::JsonOutput::writeJson(_ret);
- _trace_param_ = tars::TC_Json::writeValue(_p_);
- }
- else if(ServantProxyThreadData::TraceContext::ENP_OVERMAXLEN == _trace_param_flag_)
- {
- _trace_param_ = "{\"trace_param_over_max_len\":true}";
- }
- TARS_TRACE(pSptd->getTraceKey(ServantProxyThreadData::TraceContext::EST_SS), TRACE_ANNOTATION_SS, "", ServerConfig::Application + "." + ServerConfig::ServerName, "testDyeingTrans", 0, _trace_param_, "");
- }
- }
- else if(pSptd && pSptd->_traceCall)
- {
- _current->setTrace(pSptd->_traceCall, pSptd->getTraceKey(ServantProxyThreadData::TraceContext::EST_SS));
- }
- return tars::TARSSERVERSUCCESS;
- }
- case 4:
- {
- tars::TarsInputStream<tars::BufferReader> _is;
- _is.setBuffer(_current->getRequestBuffer());
- tars::Int32 index;
- std::string s;
- std::string r;
- if (_current->getRequestVersion() == TUPVERSION)
- {
- UniAttribute<tars::BufferWriterVector, tars::BufferReader> tarsAttr;
- tarsAttr.setVersion(_current->getRequestVersion());
- tarsAttr.decode(_current->getRequestBuffer());
- tarsAttr.get("index", index);
- tarsAttr.get("s", s);
- tarsAttr.getByDefault("r", r, r);
- }
- else if (_current->getRequestVersion() == JSONVERSION)
- {
- tars::JsonValueObjPtr _jsonPtr = tars::JsonValueObjPtr::dynamicCast(tars::TC_Json::getValue(_current->getRequestBuffer()));
- tars::JsonInput::readJson(index, _jsonPtr->value["index"], true);
- tars::JsonInput::readJson(s, _jsonPtr->value["s"], true);
- tars::JsonInput::readJson(r, _jsonPtr->value["r"], false);
- }
- else
- {
- _is.read(index, 1, true);
- _is.read(s, 2, true);
- _is.read(r, 3, false);
- }
- ServantProxyThreadData *pSptd = ServantProxyThreadData::getData();
- if (pSptd && pSptd->_traceCall)
- {
- string _trace_param_;
- int _trace_param_flag_ = pSptd->needTraceParam(ServantProxyThreadData::TraceContext::EST_SR, _is.size());
- if (ServantProxyThreadData::TraceContext::ENP_NORMAL == _trace_param_flag_)
- {
- tars::JsonValueObjPtr _p_ = new tars::JsonValueObj();
- _p_->value["index"] = tars::JsonOutput::writeJson(index);
- _p_->value["s"] = tars::JsonOutput::writeJson(s);
- _trace_param_ = tars::TC_Json::writeValue(_p_);
- }
- else if(ServantProxyThreadData::TraceContext::ENP_OVERMAXLEN == _trace_param_flag_)
- {
- _trace_param_ = "{\"trace_param_over_max_len\":true}";
- }
- TARS_TRACE(pSptd->getTraceKey(ServantProxyThreadData::TraceContext::EST_SR), TRACE_ANNOTATION_SR, "", ServerConfig::Application + "." + ServerConfig::ServerName, "testHello", 0, _trace_param_, "");
- }
- tars::Int32 _ret = testHello(index,s,r, _current);
- if(_current->isResponse())
- {
- if (_current->getRequestVersion() == TUPVERSION)
- {
- UniAttribute<tars::BufferWriterVector, tars::BufferReader> tarsAttr;
- tarsAttr.setVersion(_current->getRequestVersion());
- tarsAttr.put("", _ret);
- tarsAttr.put("tars_ret", _ret);
- tarsAttr.put("r", r);
- tarsAttr.encode(_sResponseBuffer);
- }
- else if (_current->getRequestVersion() == JSONVERSION)
- {
- tars::JsonValueObjPtr _p = new tars::JsonValueObj();
- _p->value["r"] = tars::JsonOutput::writeJson(r);
- _p->value["tars_ret"] = tars::JsonOutput::writeJson(_ret);
- tars::TC_Json::writeValue(_p, _sResponseBuffer);
- }
- else
- {
- tars::TarsOutputStream<tars::BufferWriterVector> _os;
- _os.write(_ret, 0);
- _os.write(r, 3);
- _os.swap(_sResponseBuffer);
- }
- if (pSptd && pSptd->_traceCall)
- {
- string _trace_param_;
- int _trace_param_flag_ = pSptd->needTraceParam(ServantProxyThreadData::TraceContext::EST_SS, _sResponseBuffer.size());
- if (ServantProxyThreadData::TraceContext::ENP_NORMAL == _trace_param_flag_)
- {
- tars::JsonValueObjPtr _p_ = new tars::JsonValueObj();
- _p_->value[""] = tars::JsonOutput::writeJson(_ret);
- _p_->value["r"] = tars::JsonOutput::writeJson(r);
- _trace_param_ = tars::TC_Json::writeValue(_p_);
- }
- else if(ServantProxyThreadData::TraceContext::ENP_OVERMAXLEN == _trace_param_flag_)
- {
- _trace_param_ = "{\"trace_param_over_max_len\":true}";
- }
- TARS_TRACE(pSptd->getTraceKey(ServantProxyThreadData::TraceContext::EST_SS), TRACE_ANNOTATION_SS, "", ServerConfig::Application + "." + ServerConfig::ServerName, "testHello", 0, _trace_param_, "");
- }
- }
- else if(pSptd && pSptd->_traceCall)
- {
- _current->setTrace(pSptd->_traceCall, pSptd->getTraceKey(ServantProxyThreadData::TraceContext::EST_SS));
- }
- return tars::TARSSERVERSUCCESS;
- }
- case 5:
- {
- tars::TarsInputStream<tars::BufferReader> _is;
- _is.setBuffer(_current->getRequestBuffer());
- std::string r;
- if (_current->getRequestVersion() == TUPVERSION)
- {
- UniAttribute<tars::BufferWriterVector, tars::BufferReader> tarsAttr;
- tarsAttr.setVersion(_current->getRequestVersion());
- tarsAttr.decode(_current->getRequestBuffer());
- tarsAttr.getByDefault("r", r, r);
- }
- else if (_current->getRequestVersion() == JSONVERSION)
- {
- tars::JsonValueObjPtr _jsonPtr = tars::JsonValueObjPtr::dynamicCast(tars::TC_Json::getValue(_current->getRequestBuffer()));
- tars::JsonInput::readJson(r, _jsonPtr->value["r"], false);
- }
- else
- {
- _is.read(r, 1, false);
- }
- ServantProxyThreadData *pSptd = ServantProxyThreadData::getData();
- if (pSptd && pSptd->_traceCall)
- {
- string _trace_param_;
- int _trace_param_flag_ = pSptd->needTraceParam(ServantProxyThreadData::TraceContext::EST_SR, _is.size());
- if (ServantProxyThreadData::TraceContext::ENP_NORMAL == _trace_param_flag_)
- {
- tars::JsonValueObjPtr _p_ = new tars::JsonValueObj();
- _trace_param_ = tars::TC_Json::writeValue(_p_);
- }
- else if(ServantProxyThreadData::TraceContext::ENP_OVERMAXLEN == _trace_param_flag_)
- {
- _trace_param_ = "{\"trace_param_over_max_len\":true}";
- }
- TARS_TRACE(pSptd->getTraceKey(ServantProxyThreadData::TraceContext::EST_SR), TRACE_ANNOTATION_SR, "", ServerConfig::Application + "." + ServerConfig::ServerName, "testPid", 0, _trace_param_, "");
- }
- tars::Int32 _ret = testPid(r, _current);
- if(_current->isResponse())
- {
- if (_current->getRequestVersion() == TUPVERSION)
- {
- UniAttribute<tars::BufferWriterVector, tars::BufferReader> tarsAttr;
- tarsAttr.setVersion(_current->getRequestVersion());
- tarsAttr.put("", _ret);
- tarsAttr.put("tars_ret", _ret);
- tarsAttr.put("r", r);
- tarsAttr.encode(_sResponseBuffer);
- }
- else if (_current->getRequestVersion() == JSONVERSION)
- {
- tars::JsonValueObjPtr _p = new tars::JsonValueObj();
- _p->value["r"] = tars::JsonOutput::writeJson(r);
- _p->value["tars_ret"] = tars::JsonOutput::writeJson(_ret);
- tars::TC_Json::writeValue(_p, _sResponseBuffer);
- }
- else
- {
- tars::TarsOutputStream<tars::BufferWriterVector> _os;
- _os.write(_ret, 0);
- _os.write(r, 1);
- _os.swap(_sResponseBuffer);
- }
- if (pSptd && pSptd->_traceCall)
- {
- string _trace_param_;
- int _trace_param_flag_ = pSptd->needTraceParam(ServantProxyThreadData::TraceContext::EST_SS, _sResponseBuffer.size());
- if (ServantProxyThreadData::TraceContext::ENP_NORMAL == _trace_param_flag_)
- {
- tars::JsonValueObjPtr _p_ = new tars::JsonValueObj();
- _p_->value[""] = tars::JsonOutput::writeJson(_ret);
- _p_->value["r"] = tars::JsonOutput::writeJson(r);
- _trace_param_ = tars::TC_Json::writeValue(_p_);
- }
- else if(ServantProxyThreadData::TraceContext::ENP_OVERMAXLEN == _trace_param_flag_)
- {
- _trace_param_ = "{\"trace_param_over_max_len\":true}";
- }
- TARS_TRACE(pSptd->getTraceKey(ServantProxyThreadData::TraceContext::EST_SS), TRACE_ANNOTATION_SS, "", ServerConfig::Application + "." + ServerConfig::ServerName, "testPid", 0, _trace_param_, "");
- }
- }
- else if(pSptd && pSptd->_traceCall)
- {
- _current->setTrace(pSptd->_traceCall, pSptd->getTraceKey(ServantProxyThreadData::TraceContext::EST_SS));
- }
- return tars::TARSSERVERSUCCESS;
- }
- case 6:
- {
- tars::TarsInputStream<tars::BufferReader> _is;
- _is.setBuffer(_current->getRequestBuffer());
- tars::Int32 index;
- std::string s;
- std::string r;
- if (_current->getRequestVersion() == TUPVERSION)
- {
- UniAttribute<tars::BufferWriterVector, tars::BufferReader> tarsAttr;
- tarsAttr.setVersion(_current->getRequestVersion());
- tarsAttr.decode(_current->getRequestBuffer());
- tarsAttr.get("index", index);
- tarsAttr.get("s", s);
- tarsAttr.getByDefault("r", r, r);
- }
- else if (_current->getRequestVersion() == JSONVERSION)
- {
- tars::JsonValueObjPtr _jsonPtr = tars::JsonValueObjPtr::dynamicCast(tars::TC_Json::getValue(_current->getRequestBuffer()));
- tars::JsonInput::readJson(index, _jsonPtr->value["index"], true);
- tars::JsonInput::readJson(s, _jsonPtr->value["s"], true);
- tars::JsonInput::readJson(r, _jsonPtr->value["r"], false);
- }
- else
- {
- _is.read(index, 1, true);
- _is.read(s, 2, true);
- _is.read(r, 3, false);
- }
- ServantProxyThreadData *pSptd = ServantProxyThreadData::getData();
- if (pSptd && pSptd->_traceCall)
- {
- string _trace_param_;
- int _trace_param_flag_ = pSptd->needTraceParam(ServantProxyThreadData::TraceContext::EST_SR, _is.size());
- if (ServantProxyThreadData::TraceContext::ENP_NORMAL == _trace_param_flag_)
- {
- tars::JsonValueObjPtr _p_ = new tars::JsonValueObj();
- _p_->value["index"] = tars::JsonOutput::writeJson(index);
- _p_->value["s"] = tars::JsonOutput::writeJson(s);
- _trace_param_ = tars::TC_Json::writeValue(_p_);
- }
- else if(ServantProxyThreadData::TraceContext::ENP_OVERMAXLEN == _trace_param_flag_)
- {
- _trace_param_ = "{\"trace_param_over_max_len\":true}";
- }
- TARS_TRACE(pSptd->getTraceKey(ServantProxyThreadData::TraceContext::EST_SR), TRACE_ANNOTATION_SR, "", ServerConfig::Application + "." + ServerConfig::ServerName, "testSyncTrans", 0, _trace_param_, "");
- }
- tars::Int32 _ret = testSyncTrans(index,s,r, _current);
- if(_current->isResponse())
- {
- if (_current->getRequestVersion() == TUPVERSION)
- {
- UniAttribute<tars::BufferWriterVector, tars::BufferReader> tarsAttr;
- tarsAttr.setVersion(_current->getRequestVersion());
- tarsAttr.put("", _ret);
- tarsAttr.put("tars_ret", _ret);
- tarsAttr.put("r", r);
- tarsAttr.encode(_sResponseBuffer);
- }
- else if (_current->getRequestVersion() == JSONVERSION)
- {
- tars::JsonValueObjPtr _p = new tars::JsonValueObj();
- _p->value["r"] = tars::JsonOutput::writeJson(r);
- _p->value["tars_ret"] = tars::JsonOutput::writeJson(_ret);
- tars::TC_Json::writeValue(_p, _sResponseBuffer);
- }
- else
- {
- tars::TarsOutputStream<tars::BufferWriterVector> _os;
- _os.write(_ret, 0);
- _os.write(r, 3);
- _os.swap(_sResponseBuffer);
- }
- if (pSptd && pSptd->_traceCall)
- {
- string _trace_param_;
- int _trace_param_flag_ = pSptd->needTraceParam(ServantProxyThreadData::TraceContext::EST_SS, _sResponseBuffer.size());
- if (ServantProxyThreadData::TraceContext::ENP_NORMAL == _trace_param_flag_)
- {
- tars::JsonValueObjPtr _p_ = new tars::JsonValueObj();
- _p_->value[""] = tars::JsonOutput::writeJson(_ret);
- _p_->value["r"] = tars::JsonOutput::writeJson(r);
- _trace_param_ = tars::TC_Json::writeValue(_p_);
- }
- else if(ServantProxyThreadData::TraceContext::ENP_OVERMAXLEN == _trace_param_flag_)
- {
- _trace_param_ = "{\"trace_param_over_max_len\":true}";
- }
- TARS_TRACE(pSptd->getTraceKey(ServantProxyThreadData::TraceContext::EST_SS), TRACE_ANNOTATION_SS, "", ServerConfig::Application + "." + ServerConfig::ServerName, "testSyncTrans", 0, _trace_param_, "");
- }
- }
- else if(pSptd && pSptd->_traceCall)
- {
- _current->setTrace(pSptd->_traceCall, pSptd->getTraceKey(ServantProxyThreadData::TraceContext::EST_SS));
- }
- return tars::TARSSERVERSUCCESS;
- }
- case 7:
- {
- tars::TarsInputStream<tars::BufferReader> _is;
- _is.setBuffer(_current->getRequestBuffer());
- tars::Int32 timeout;
- if (_current->getRequestVersion() == TUPVERSION)
- {
- UniAttribute<tars::BufferWriterVector, tars::BufferReader> tarsAttr;
- tarsAttr.setVersion(_current->getRequestVersion());
- tarsAttr.decode(_current->getRequestBuffer());
- tarsAttr.get("timeout", timeout);
- }
- else if (_current->getRequestVersion() == JSONVERSION)
- {
- tars::JsonValueObjPtr _jsonPtr = tars::JsonValueObjPtr::dynamicCast(tars::TC_Json::getValue(_current->getRequestBuffer()));
- tars::JsonInput::readJson(timeout, _jsonPtr->value["timeout"], true);
- }
- else
- {
- _is.read(timeout, 1, true);
- }
- ServantProxyThreadData *pSptd = ServantProxyThreadData::getData();
- if (pSptd && pSptd->_traceCall)
- {
- string _trace_param_;
- int _trace_param_flag_ = pSptd->needTraceParam(ServantProxyThreadData::TraceContext::EST_SR, _is.size());
- if (ServantProxyThreadData::TraceContext::ENP_NORMAL == _trace_param_flag_)
- {
- tars::JsonValueObjPtr _p_ = new tars::JsonValueObj();
- _p_->value["timeout"] = tars::JsonOutput::writeJson(timeout);
- _trace_param_ = tars::TC_Json::writeValue(_p_);
- }
- else if(ServantProxyThreadData::TraceContext::ENP_OVERMAXLEN == _trace_param_flag_)
- {
- _trace_param_ = "{\"trace_param_over_max_len\":true}";
- }
- TARS_TRACE(pSptd->getTraceKey(ServantProxyThreadData::TraceContext::EST_SR), TRACE_ANNOTATION_SR, "", ServerConfig::Application + "." + ServerConfig::ServerName, "testTimeout", 0, _trace_param_, "");
- }
- tars::Int32 _ret = testTimeout(timeout, _current);
- if(_current->isResponse())
- {
- if (_current->getRequestVersion() == TUPVERSION)
- {
- UniAttribute<tars::BufferWriterVector, tars::BufferReader> tarsAttr;
- tarsAttr.setVersion(_current->getRequestVersion());
- tarsAttr.put("", _ret);
- tarsAttr.put("tars_ret", _ret);
- tarsAttr.encode(_sResponseBuffer);
- }
- else if (_current->getRequestVersion() == JSONVERSION)
- {
- tars::JsonValueObjPtr _p = new tars::JsonValueObj();
- _p->value["tars_ret"] = tars::JsonOutput::writeJson(_ret);
- tars::TC_Json::writeValue(_p, _sResponseBuffer);
- }
- else
- {
- tars::TarsOutputStream<tars::BufferWriterVector> _os;
- _os.write(_ret, 0);
- _os.swap(_sResponseBuffer);
- }
- if (pSptd && pSptd->_traceCall)
- {
- string _trace_param_;
- int _trace_param_flag_ = pSptd->needTraceParam(ServantProxyThreadData::TraceContext::EST_SS, _sResponseBuffer.size());
- if (ServantProxyThreadData::TraceContext::ENP_NORMAL == _trace_param_flag_)
- {
- tars::JsonValueObjPtr _p_ = new tars::JsonValueObj();
- _p_->value[""] = tars::JsonOutput::writeJson(_ret);
- _trace_param_ = tars::TC_Json::writeValue(_p_);
- }
- else if(ServantProxyThreadData::TraceContext::ENP_OVERMAXLEN == _trace_param_flag_)
- {
- _trace_param_ = "{\"trace_param_over_max_len\":true}";
- }
- TARS_TRACE(pSptd->getTraceKey(ServantProxyThreadData::TraceContext::EST_SS), TRACE_ANNOTATION_SS, "", ServerConfig::Application + "." + ServerConfig::ServerName, "testTimeout", 0, _trace_param_, "");
- }
- }
- else if(pSptd && pSptd->_traceCall)
- {
- _current->setTrace(pSptd->_traceCall, pSptd->getTraceKey(ServantProxyThreadData::TraceContext::EST_SS));
- }
- return tars::TARSSERVERSUCCESS;
- }
- case 8:
- {
- tars::TarsInputStream<tars::BufferReader> _is;
- _is.setBuffer(_current->getRequestBuffer());
- tars::Int32 index;
- std::string s;
- std::string r;
- if (_current->getRequestVersion() == TUPVERSION)
- {
- UniAttribute<tars::BufferWriterVector, tars::BufferReader> tarsAttr;
- tarsAttr.setVersion(_current->getRequestVersion());
- tarsAttr.decode(_current->getRequestBuffer());
- tarsAttr.get("index", index);
- tarsAttr.get("s", s);
- tarsAttr.getByDefault("r", r, r);
- }
- else if (_current->getRequestVersion() == JSONVERSION)
- {
- tars::JsonValueObjPtr _jsonPtr = tars::JsonValueObjPtr::dynamicCast(tars::TC_Json::getValue(_current->getRequestBuffer()));
- tars::JsonInput::readJson(index, _jsonPtr->value["index"], true);
- tars::JsonInput::readJson(s, _jsonPtr->value["s"], true);
- tars::JsonInput::readJson(r, _jsonPtr->value["r"], false);
- }
- else
- {
- _is.read(index, 1, true);
- _is.read(s, 2, true);
- _is.read(r, 3, false);
- }
- ServantProxyThreadData *pSptd = ServantProxyThreadData::getData();
- if (pSptd && pSptd->_traceCall)
- {
- string _trace_param_;
- int _trace_param_flag_ = pSptd->needTraceParam(ServantProxyThreadData::TraceContext::EST_SR, _is.size());
- if (ServantProxyThreadData::TraceContext::ENP_NORMAL == _trace_param_flag_)
- {
- tars::JsonValueObjPtr _p_ = new tars::JsonValueObj();
- _p_->value["index"] = tars::JsonOutput::writeJson(index);
- _p_->value["s"] = tars::JsonOutput::writeJson(s);
- _trace_param_ = tars::TC_Json::writeValue(_p_);
- }
- else if(ServantProxyThreadData::TraceContext::ENP_OVERMAXLEN == _trace_param_flag_)
- {
- _trace_param_ = "{\"trace_param_over_max_len\":true}";
- }
- TARS_TRACE(pSptd->getTraceKey(ServantProxyThreadData::TraceContext::EST_SR), TRACE_ANNOTATION_SR, "", ServerConfig::Application + "." + ServerConfig::ServerName, "testTrans", 0, _trace_param_, "");
- }
- tars::Int32 _ret = testTrans(index,s,r, _current);
- if(_current->isResponse())
- {
- if (_current->getRequestVersion() == TUPVERSION)
- {
- UniAttribute<tars::BufferWriterVector, tars::BufferReader> tarsAttr;
- tarsAttr.setVersion(_current->getRequestVersion());
- tarsAttr.put("", _ret);
- tarsAttr.put("tars_ret", _ret);
- tarsAttr.put("r", r);
- tarsAttr.encode(_sResponseBuffer);
- }
- else if (_current->getRequestVersion() == JSONVERSION)
- {
- tars::JsonValueObjPtr _p = new tars::JsonValueObj();
- _p->value["r"] = tars::JsonOutput::writeJson(r);
- _p->value["tars_ret"] = tars::JsonOutput::writeJson(_ret);
- tars::TC_Json::writeValue(_p, _sResponseBuffer);
- }
- else
- {
- tars::TarsOutputStream<tars::BufferWriterVector> _os;
- _os.write(_ret, 0);
- _os.write(r, 3);
- _os.swap(_sResponseBuffer);
- }
- if (pSptd && pSptd->_traceCall)
- {
- string _trace_param_;
- int _trace_param_flag_ = pSptd->needTraceParam(ServantProxyThreadData::TraceContext::EST_SS, _sResponseBuffer.size());
- if (ServantProxyThreadData::TraceContext::ENP_NORMAL == _trace_param_flag_)
- {
- tars::JsonValueObjPtr _p_ = new tars::JsonValueObj();
- _p_->value[""] = tars::JsonOutput::writeJson(_ret);
- _p_->value["r"] = tars::JsonOutput::writeJson(r);
- _trace_param_ = tars::TC_Json::writeValue(_p_);
- }
- else if(ServantProxyThreadData::TraceContext::ENP_OVERMAXLEN == _trace_param_flag_)
- {
- _trace_param_ = "{\"trace_param_over_max_len\":true}";
- }
- TARS_TRACE(pSptd->getTraceKey(ServantProxyThreadData::TraceContext::EST_SS), TRACE_ANNOTATION_SS, "", ServerConfig::Application + "." + ServerConfig::ServerName, "testTrans", 0, _trace_param_, "");
- }
- }
- else if(pSptd && pSptd->_traceCall)
- {
- _current->setTrace(pSptd->_traceCall, pSptd->getTraceKey(ServantProxyThreadData::TraceContext::EST_SS));
- }
- return tars::TARSSERVERSUCCESS;
- }
- }
- return tars::TARSSERVERNOFUNCERR;
- }
- };
- }
- #endif
|