123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119112011211122112311241125112611271128112911301131113211331134113511361137113811391140114111421143114411451146114711481149115011511152115311541155115611571158115911601161116211631164116511661167116811691170117111721173117411751176117711781179118011811182118311841185118611871188118911901191119211931194119511961197119811991200120112021203120412051206120712081209121012111212121312141215121612171218121912201221122212231224122512261227122812291230123112321233123412351236123712381239124012411242124312441245124612471248124912501251125212531254125512561257125812591260126112621263126412651266126712681269127012711272127312741275127612771278127912801281128212831284128512861287128812891290129112921293129412951296129712981299130013011302130313041305130613071308130913101311131213131314131513161317131813191320132113221323132413251326132713281329133013311332133313341335133613371338133913401341134213431344134513461347134813491350135113521353135413551356135713581359136013611362136313641365136613671368136913701371137213731374137513761377137813791380138113821383138413851386138713881389139013911392139313941395139613971398139914001401140214031404140514061407140814091410141114121413141414151416141714181419142014211422142314241425142614271428142914301431143214331434143514361437143814391440144114421443144414451446144714481449145014511452145314541455145614571458145914601461146214631464146514661467146814691470147114721473147414751476147714781479148014811482148314841485148614871488148914901491149214931494149514961497149814991500150115021503150415051506150715081509151015111512151315141515151615171518151915201521152215231524152515261527152815291530153115321533153415351536153715381539154015411542154315441545154615471548154915501551155215531554155515561557155815591560156115621563156415651566156715681569157015711572157315741575157615771578157915801581158215831584158515861587158815891590159115921593159415951596159715981599160016011602160316041605160616071608160916101611161216131614161516161617161816191620162116221623162416251626162716281629163016311632163316341635163616371638163916401641164216431644164516461647164816491650165116521653165416551656165716581659166016611662166316641665166616671668166916701671167216731674167516761677167816791680168116821683168416851686168716881689169016911692169316941695169616971698169917001701170217031704170517061707170817091710171117121713171417151716171717181719172017211722172317241725172617271728172917301731173217331734173517361737173817391740174117421743174417451746174717481749175017511752175317541755175617571758175917601761176217631764176517661767176817691770177117721773177417751776177717781779178017811782178317841785178617871788178917901791179217931794179517961797179817991800180118021803180418051806180718081809181018111812181318141815181618171818181918201821182218231824182518261827182818291830183118321833183418351836183718381839184018411842184318441845184618471848184918501851185218531854185518561857185818591860186118621863186418651866186718681869187018711872187318741875187618771878187918801881188218831884188518861887188818891890189118921893189418951896189718981899190019011902190319041905190619071908190919101911191219131914191519161917191819191920192119221923192419251926192719281929193019311932193319341935193619371938193919401941194219431944194519461947194819491950195119521953195419551956195719581959196019611962196319641965196619671968196919701971197219731974197519761977197819791980198119821983198419851986198719881989199019911992199319941995199619971998199920002001200220032004200520062007200820092010201120122013201420152016201720182019202020212022202320242025202620272028202920302031203220332034203520362037203820392040204120422043204420452046204720482049205020512052205320542055205620572058205920602061206220632064206520662067206820692070207120722073207420752076207720782079208020812082208320842085208620872088208920902091209220932094209520962097209820992100210121022103210421052106210721082109211021112112211321142115211621172118211921202121212221232124212521262127212821292130213121322133213421352136213721382139214021412142214321442145214621472148214921502151215221532154215521562157215821592160216121622163216421652166216721682169217021712172217321742175217621772178217921802181218221832184218521862187218821892190219121922193219421952196219721982199220022012202220322042205220622072208220922102211221222132214221522162217221822192220222122222223222422252226222722282229223022312232223322342235223622372238223922402241224222432244224522462247224822492250225122522253225422552256225722582259226022612262226322642265226622672268226922702271227222732274227522762277227822792280228122822283228422852286228722882289229022912292229322942295229622972298229923002301230223032304230523062307230823092310231123122313231423152316231723182319232023212322232323242325232623272328232923302331233223332334233523362337233823392340234123422343234423452346234723482349235023512352235323542355235623572358235923602361236223632364236523662367236823692370237123722373237423752376237723782379238023812382238323842385238623872388238923902391239223932394239523962397239823992400240124022403240424052406240724082409241024112412241324142415241624172418241924202421242224232424242524262427242824292430243124322433243424352436243724382439244024412442244324442445244624472448244924502451245224532454245524562457245824592460246124622463246424652466246724682469247024712472247324742475247624772478247924802481248224832484248524862487248824892490249124922493249424952496249724982499250025012502250325042505250625072508250925102511251225132514251525162517251825192520252125222523252425252526252725282529253025312532253325342535253625372538253925402541254225432544254525462547254825492550255125522553255425552556255725582559256025612562256325642565256625672568256925702571257225732574257525762577257825792580258125822583258425852586258725882589259025912592259325942595259625972598259926002601260226032604260526062607260826092610261126122613261426152616261726182619262026212622262326242625262626272628262926302631263226332634263526362637263826392640264126422643264426452646264726482649265026512652265326542655265626572658265926602661266226632664266526662667266826692670267126722673267426752676267726782679268026812682268326842685268626872688268926902691269226932694269526962697269826992700270127022703270427052706270727082709271027112712271327142715271627172718271927202721272227232724272527262727272827292730273127322733273427352736273727382739274027412742274327442745274627472748274927502751275227532754275527562757275827592760276127622763276427652766276727682769277027712772277327742775277627772778277927802781278227832784278527862787278827892790279127922793279427952796279727982799280028012802280328042805280628072808280928102811281228132814281528162817281828192820282128222823282428252826282728282829283028312832283328342835283628372838283928402841284228432844284528462847284828492850285128522853285428552856285728582859286028612862286328642865286628672868286928702871287228732874287528762877287828792880288128822883288428852886288728882889289028912892289328942895289628972898289929002901290229032904290529062907290829092910291129122913291429152916291729182919292029212922292329242925292629272928292929302931293229332934293529362937293829392940294129422943294429452946294729482949295029512952295329542955295629572958295929602961296229632964296529662967296829692970297129722973297429752976297729782979298029812982298329842985298629872988298929902991299229932994299529962997299829993000300130023003300430053006300730083009301030113012301330143015301630173018301930203021302230233024302530263027302830293030303130323033303430353036303730383039304030413042304330443045304630473048304930503051305230533054305530563057305830593060306130623063306430653066306730683069307030713072307330743075307630773078307930803081308230833084308530863087308830893090309130923093309430953096309730983099310031013102310331043105310631073108310931103111311231133114311531163117311831193120312131223123312431253126312731283129313031313132313331343135313631373138313931403141314231433144314531463147314831493150315131523153315431553156315731583159316031613162316331643165316631673168316931703171317231733174317531763177317831793180318131823183318431853186318731883189319031913192319331943195319631973198319932003201320232033204320532063207320832093210321132123213321432153216321732183219322032213222322332243225322632273228322932303231323232333234323532363237323832393240324132423243324432453246324732483249325032513252325332543255325632573258325932603261326232633264326532663267326832693270327132723273327432753276327732783279328032813282328332843285328632873288328932903291329232933294329532963297329832993300330133023303330433053306330733083309331033113312331333143315331633173318331933203321332233233324332533263327332833293330333133323333333433353336333733383339334033413342334333443345334633473348334933503351335233533354335533563357335833593360336133623363336433653366 |
- #include <stdio.h>
- #include <stdlib.h>
- #include <unistd.h>
- #include <string.h>
- #include <stdint.h>
- #include "hton.h"
- #include "MBIMAggregationTestFixtureConf11.h"
- #include "Constants.h"
- #include "TestsUtils.h"
- #include "linux/msm_ipa.h"
- #define AGGREGATION_LOOP 4
- #define IPV4_DST_ADDR_OFFSET (16)
- class MBIMAggregationScenarios {
- public:
-
- static bool MBIMAggregationTest(Pipe* input, Pipe* output, enum ipa_ip_type m_eIP);
-
-
- static bool MBIMDeaggregationTest(Pipe* input,
- Pipe* output, enum ipa_ip_type m_eIP);
-
-
- static bool MBIMDeaggregationOnePacketTest(Pipe* input, Pipe* output, enum ipa_ip_type m_eIP);
-
-
- static bool MBIMDeaggregationAndAggregationTest(Pipe* input, Pipe* output, enum ipa_ip_type m_eIP);
-
-
-
- static bool MBIMMultipleDeaggregationAndAggregationTest(
- Pipe* input, Pipe* output,
- enum ipa_ip_type m_eIP);
-
-
- static bool MBIMAggregationLoopTest(Pipe* input,
- Pipe* output, enum ipa_ip_type m_eIP);
-
-
- static bool MBIMAggregationTimeLimitTest(Pipe* input, Pipe* output, enum ipa_ip_type m_eIP);
-
-
- static bool MBIMAggregationByteLimitTest(Pipe* input, Pipe* output, enum ipa_ip_type m_eIP);
- static bool MBIMAggregationByteLimitTestFC(Pipe* input, Pipe* output, enum ipa_ip_type m_eIP);
- static bool MBIMAggregationDualDpTestFC(Pipe* input, Pipe* output1, Pipe* output2, enum ipa_ip_type m_eIP);
-
-
- static bool MBIMDeaggregationMultipleNDPTest(Pipe* input, Pipe* output, enum ipa_ip_type m_eIP);
-
-
-
- static bool MBIMAggregation2PipesTest(Pipe* input1, Pipe* input2, Pipe* output, enum ipa_ip_type m_eIP);
-
-
- static bool MBIMAggregationTimeLimitLoopTest(Pipe* input, Pipe* output, enum ipa_ip_type m_eIP);
-
-
- static bool MBIMAggregation0LimitsTest(Pipe* input, Pipe* output, enum ipa_ip_type m_eIP);
-
-
- static bool MBIMAggregationMultiplePacketsTest(Pipe* input, Pipe* output, enum ipa_ip_type m_eIP);
-
-
- static bool MBIMAggregationDifferentStreamIdsTest(Pipe* input, Pipe* output, enum ipa_ip_type m_eIP);
-
-
-
- static bool MBIMAggregationNoInterleavingStreamIdsTest(
- Pipe* input, Pipe* output,
- enum ipa_ip_type m_eIP);
- private:
-
-
- static bool DeaggragateAndComparePackets(
- Byte pAggregatedPacket[MAX_PACKET_SIZE],
- Byte pExpectedPackets[MAX_PACKETS_IN_MBIM_TESTS][MAX_PACKET_SIZE],
- int pPacketsSizes[MAX_PACKETS_IN_MBIM_TESTS], int nNumPackets,
- int nAggregatedPacketSize);
-
- static void AggregatePackets(
- Byte pAggregatedPacket[MAX_PACKET_SIZE],
- Byte pPackets[NUM_PACKETS][MAX_PACKET_SIZE],
- int pPacketsSizes[NUM_PACKETS], int nNumPackets,
- int nAggregatedPacketSize);
-
-
- static void AggregatePacketsWithStreamId(
- Byte pAggregatedPacket[MAX_PACKET_SIZE],
- Byte pPackets[NUM_PACKETS][MAX_PACKET_SIZE],
- int pPacketsSizes[NUM_PACKETS], int nNumPackets,
- int nAggregatedPacketSize, Byte pPacketsStreamId[NUM_PACKETS]);
-
-
- static bool DeaggragateAndCompareOnePacket(
- Byte pAggregatedPacket[MAX_PACKET_SIZE],
- Byte pExpectedPacket[MAX_PACKET_SIZE], int nPacketsSize,
- int nAggregatedPacketSize);
-
-
- static bool DeaggragateAndComparePacketsWithStreamId(
- Byte pAggregatedPacket[MAX_PACKET_SIZE],
- Byte pExpectedPackets[][MAX_PACKET_SIZE], int pPacketsSizes[],
- int nNumPackets, int nAggregatedPacketSize,
- Byte pPacketsStreamId[NUM_PACKETS]);
- };
- bool MBIMAggregationScenarios::MBIMAggregationTest(
- Pipe* input, Pipe* output, enum ipa_ip_type m_eIP)
- {
-
- Byte pPackets[NUM_PACKETS][MAX_PACKET_SIZE];
-
- int pPacketsSizes[NUM_PACKETS];
-
- Byte pReceivedPacket[2*MAX_PACKET_SIZE];
-
-
- int nTotalPacketsSize = MAX_PACKET_SIZE - (4 * NUM_PACKETS) - 24;
- uint32_t nIPv4DSTAddr;
- size_t pIpPacketsSizes[NUM_PACKETS];
-
- for (int i = 0; i < NUM_PACKETS; i++)
- {
- if (NUM_PACKETS - 1 == i)
- pPacketsSizes[i] = nTotalPacketsSize;
- else
- pPacketsSizes[i] = nTotalPacketsSize / NUM_PACKETS;
- while (0 != pPacketsSizes[i] % 4)
- {
- pPacketsSizes[i]++;
- }
- nTotalPacketsSize -= pPacketsSizes[i];
-
- pIpPacketsSizes[i] = MAX_PACKET_SIZE;
- if (!LoadDefaultPacket(m_eIP, pPackets[i], pIpPacketsSizes[i]))
- {
- LOG_MSG_ERROR("Failed default Packet");
- return false;
- }
- nIPv4DSTAddr = ntohl(0x7F000001);
- memcpy (&pPackets[i][IPV4_DST_ADDR_OFFSET],&nIPv4DSTAddr,
- sizeof(nIPv4DSTAddr));
- int size = pIpPacketsSizes[i];
- while (size < pPacketsSizes[i])
- {
- pPackets[i][size] = i;
- size++;
- }
- }
-
- for (int i = 0; i < NUM_PACKETS; i++)
- {
- LOG_MSG_DEBUG("Sending packet %d into the USB pipe(%d bytes)\n", i,
- pPacketsSizes[i]);
- int nBytesSent = input->Send(pPackets[i], pPacketsSizes[i]);
- if (pPacketsSizes[i] != nBytesSent)
- {
- LOG_MSG_DEBUG("Sending packet %d into the USB pipe(%d bytes) "
- "failed!\n", i, pPacketsSizes[i]);
- return false;
- }
- }
-
- LOG_MSG_DEBUG("Reading packet from the USB pipe(%d bytes should be there)"
- "\n", MAX_PACKET_SIZE);
- int nBytesReceived = output->Receive(pReceivedPacket, MAX_PACKET_SIZE);
- if (MAX_PACKET_SIZE != nBytesReceived)
- {
- LOG_MSG_DEBUG("Receiving aggregated packet from the USB pipe(%d bytes) "
- "failed!\n", MAX_PACKET_SIZE);
- print_buff(pReceivedPacket, nBytesReceived);
- return false;
- }
-
- return DeaggragateAndComparePackets(pReceivedPacket, pPackets,
- pPacketsSizes, NUM_PACKETS, nBytesReceived);
- }
- bool MBIMAggregationScenarios::MBIMDeaggregationTest(
- Pipe* input, Pipe* output, enum ipa_ip_type m_eIP)
- {
- bool bTestResult = true;
-
- Byte pExpectedPackets[NUM_PACKETS][MAX_PACKET_SIZE];
-
- int pPacketsSizes[NUM_PACKETS];
-
- Byte pReceivedPackets[NUM_PACKETS][MAX_PACKET_SIZE];
-
-
-
- int nTotalPacketsSize = MAX_PACKET_SIZE - (4 * NUM_PACKETS) - 24;
-
- Byte pAggregatedPacket[MAX_PACKET_SIZE] = {0};
- uint32_t nIPv4DSTAddr;
- size_t pIpPacketsSizes[NUM_PACKETS];
-
- for (int i = 0; i < NUM_PACKETS; i++)
- {
- if (NUM_PACKETS - 1 == i)
- pPacketsSizes[i] = nTotalPacketsSize;
- else
- pPacketsSizes[i] = nTotalPacketsSize / NUM_PACKETS;
- while (0 != pPacketsSizes[i] % 4)
- {
- pPacketsSizes[i]++;
- }
- nTotalPacketsSize -= pPacketsSizes[i];
-
- pIpPacketsSizes[i] = MAX_PACKET_SIZE;
- if (!LoadDefaultPacket(m_eIP, pExpectedPackets[i],
- pIpPacketsSizes[i]))
- {
- LOG_MSG_ERROR("Failed default Packet");
- return false;
- }
- nIPv4DSTAddr = ntohl(0x7F000001);
- memcpy (&pExpectedPackets[i][IPV4_DST_ADDR_OFFSET],&nIPv4DSTAddr,
- sizeof(nIPv4DSTAddr));
- int size = pIpPacketsSizes[i];
- while (size < pPacketsSizes[i])
- {
- pExpectedPackets[i][size] = i;
- size++;
- }
- }
-
- AggregatePackets(pAggregatedPacket, pExpectedPackets, pPacketsSizes,
- NUM_PACKETS, MAX_PACKET_SIZE);
-
- LOG_MSG_DEBUG("Sending aggregated packet into the USB pipe(%d bytes)\n",
- sizeof(pAggregatedPacket));
- int nBytesSent = input->Send(pAggregatedPacket, sizeof(pAggregatedPacket));
- if (sizeof(pAggregatedPacket) != nBytesSent)
- {
- LOG_MSG_DEBUG("Sending aggregated packet into the USB pipe(%d bytes) "
- "failed!\n", sizeof(pAggregatedPacket));
- return false;
- }
-
- for (int i = 0; i < NUM_PACKETS; i++)
- {
- LOG_MSG_DEBUG("Reading packet %d from the USB pipe(%d bytes should be "
- "there)\n", i, pPacketsSizes[i]);
- int nBytesReceived = output->Receive(pReceivedPackets[i],
- pPacketsSizes[i]);
- if (pPacketsSizes[i] != nBytesReceived)
- {
- LOG_MSG_DEBUG("Receiving packet %d from the USB pipe(%d bytes) "
- "failed!\n", i, pPacketsSizes[i]);
- print_buff(pReceivedPackets[i], nBytesReceived);
- return false;
- }
- }
-
- LOG_MSG_DEBUG("Checking sent.vs.received packet\n");
- for (int i = 0; i < NUM_PACKETS; i++)
- bTestResult &= !memcmp(pExpectedPackets[i], pReceivedPackets[i],
- pPacketsSizes[i]);
- return bTestResult;
- }
- bool MBIMAggregationScenarios::MBIMDeaggregationOnePacketTest(
- Pipe* input, Pipe* output,
- enum ipa_ip_type m_eIP)
- {
- bool bTestResult = true;
-
- Byte pExpectedPackets[1][MAX_PACKET_SIZE];
-
- int pPacketsSizes[1] = {100};
-
- Byte pReceivedPackets[1][MAX_PACKET_SIZE];
-
-
-
- int nTotalAggregatedPacketSize = 100 + 12 + 16;
-
- Byte pAggregatedPacket[MAX_PACKET_SIZE] = {0};
- uint32_t nIPv4DSTAddr;
- size_t pIpPacketsSizes[1];
-
- pIpPacketsSizes[0] = 100;
- if (!LoadDefaultPacket(m_eIP, pExpectedPackets[0], pIpPacketsSizes[0]))
- {
- LOG_MSG_ERROR("Failed default Packet");
- return false;
- }
- nIPv4DSTAddr = ntohl(0x7F000001);
- memcpy (&pExpectedPackets[0][IPV4_DST_ADDR_OFFSET],&nIPv4DSTAddr,
- sizeof(nIPv4DSTAddr));
- int size = pIpPacketsSizes[0];
- while (size < pPacketsSizes[0])
- {
- pExpectedPackets[0][size] = 0;
- size++;
- }
-
- AggregatePackets(pAggregatedPacket, pExpectedPackets, pPacketsSizes, 1,
- nTotalAggregatedPacketSize);
-
- LOG_MSG_DEBUG("Sending aggregated packet into the USB pipe(%d bytes)\n",
- nTotalAggregatedPacketSize);
- int nBytesSent = input->Send(pAggregatedPacket, nTotalAggregatedPacketSize);
- if (nTotalAggregatedPacketSize != nBytesSent)
- {
- LOG_MSG_DEBUG("Sending aggregated packet into the USB pipe(%d bytes) "
- "failed!\n", nTotalAggregatedPacketSize);
- return false;
- }
-
- for (int i = 0; i < 1; i++)
- {
- LOG_MSG_DEBUG("Reading packet %d from the USB pipe(%d bytes should be "
- "there)\n", i, pPacketsSizes[i]);
- int nBytesReceived = output->Receive(pReceivedPackets[i],
- pPacketsSizes[i]);
- if (pPacketsSizes[i] != nBytesReceived)
- {
- LOG_MSG_DEBUG("Receiving packet %d from the USB pipe(%d bytes) "
- "failed!\n", i, pPacketsSizes[i]);
- print_buff(pReceivedPackets[i], nBytesReceived);
- return false;
- }
- }
-
- LOG_MSG_DEBUG("Checking sent.vs.received packet\n");
- for (int i = 0; i < 1; i++)
- bTestResult &= !memcmp(pExpectedPackets[i], pReceivedPackets[i],
- pPacketsSizes[i]);
- return bTestResult;
- }
- bool MBIMAggregationScenarios::MBIMDeaggregationAndAggregationTest(
- Pipe* input, Pipe* output,
- enum ipa_ip_type m_eIP)
- {
-
- Byte pPackets[NUM_PACKETS][MAX_PACKET_SIZE];
-
- int pPacketsSizes[NUM_PACKETS];
-
- Byte pReceivedPacket[MAX_PACKET_SIZE];
-
-
-
- int nTotalPacketsSize = MAX_PACKET_SIZE - (4 * NUM_PACKETS) - 24;
-
- Byte pAggregatedPacket[MAX_PACKET_SIZE] = {0};
- uint32_t nIPv4DSTAddr;
- size_t pIpPacketsSizes[NUM_PACKETS];
-
- for (int i = 0; i < NUM_PACKETS; i++)
- {
- if (NUM_PACKETS - 1 == i)
- pPacketsSizes[i] = nTotalPacketsSize;
- else
- pPacketsSizes[i] = nTotalPacketsSize / NUM_PACKETS;
- while (0 != pPacketsSizes[i] % 4)
- pPacketsSizes[i]++;
- nTotalPacketsSize -= pPacketsSizes[i];
-
- pIpPacketsSizes[i] = MAX_PACKET_SIZE;
- if (!LoadDefaultPacket(m_eIP, pPackets[i], pIpPacketsSizes[i]))
- {
- LOG_MSG_ERROR("Failed default Packet");
- return false;
- }
- nIPv4DSTAddr = ntohl(0x7F000001);
- memcpy (&pPackets[i][IPV4_DST_ADDR_OFFSET],&nIPv4DSTAddr,
- sizeof(nIPv4DSTAddr));
- int size = pIpPacketsSizes[i];
- while (size < pPacketsSizes[i])
- {
- pPackets[i][size] = i;
- size++;
- }
- }
-
- AggregatePackets(pAggregatedPacket, pPackets, pPacketsSizes, NUM_PACKETS,
- MAX_PACKET_SIZE);
-
- LOG_MSG_DEBUG("Sending aggregated packet into the USB pipe(%d bytes)\n",
- MAX_PACKET_SIZE);
- int nBytesSent = input->Send(pAggregatedPacket, MAX_PACKET_SIZE);
- if (MAX_PACKET_SIZE != nBytesSent)
- {
- LOG_MSG_DEBUG("Sending aggregated packet into the USB pipe(%d bytes) "
- "failed!\n", MAX_PACKET_SIZE);
- return false;
- }
-
- LOG_MSG_DEBUG("Reading aggregated packet from the USB pipe(%d bytes should "
- "be there)\n", MAX_PACKET_SIZE);
- int nBytesReceived = output->Receive(pReceivedPacket, MAX_PACKET_SIZE);
- if (MAX_PACKET_SIZE != nBytesReceived)
- {
- LOG_MSG_DEBUG("Receiving aggregated packet from the USB pipe(%d bytes) "
- "failed!\n", MAX_PACKET_SIZE);
- LOG_MSG_DEBUG("Received %d bytes\n", nBytesReceived);
- print_buff(pReceivedPacket, nBytesReceived);
- return false;
- }
-
- LOG_MSG_DEBUG("Checking sent.vs.received packet\n");
- return DeaggragateAndComparePackets(pReceivedPacket, pPackets, pPacketsSizes,
- NUM_PACKETS, nBytesReceived);
- }
- bool MBIMAggregationScenarios::MBIMMultipleDeaggregationAndAggregationTest(
- Pipe* input, Pipe* output,
- enum ipa_ip_type m_eIP)
- {
-
- Byte pPackets[NUM_PACKETS][MAX_PACKET_SIZE];
-
- int pPacketsSizes[NUM_PACKETS];
-
- Byte pReceivedPacket[MAX_PACKET_SIZE];
-
-
-
- int nTotalPacketsSize = MAX_PACKET_SIZE - (4 * NUM_PACKETS) - 24;
-
- Byte pAggregatedPacket[NUM_PACKETS][MAX_PACKET_SIZE];
- uint32_t nIPv4DSTAddr;
- size_t pIpPacketsSizes[NUM_PACKETS];
-
- for (int i = 0; i < NUM_PACKETS; i++)
- {
- if (NUM_PACKETS - 1 == i)
- pPacketsSizes[i] = nTotalPacketsSize;
- else
- pPacketsSizes[i] = nTotalPacketsSize / NUM_PACKETS;
- while (0 != pPacketsSizes[i] % 4)
- pPacketsSizes[i]++;
- nTotalPacketsSize -= pPacketsSizes[i];
-
- pIpPacketsSizes[i] = MAX_PACKET_SIZE;
- if (!LoadDefaultPacket(m_eIP, pPackets[i], pIpPacketsSizes[i]))
- {
- LOG_MSG_ERROR("Failed default Packet");
- return false;
- }
- nIPv4DSTAddr = ntohl(0x7F000001);
- memcpy (&pPackets[i][IPV4_DST_ADDR_OFFSET],&nIPv4DSTAddr,
- sizeof(nIPv4DSTAddr));
- int size = pIpPacketsSizes[i];
- while (size < pPacketsSizes[i])
- {
- pPackets[i][size] = i;
- size++;
- }
- }
-
- for (int i = 0; i < NUM_PACKETS; i++)
- AggregatePackets(pAggregatedPacket[i], &pPackets[i], &pPacketsSizes[i],
- 1, pPacketsSizes[i] + 12 + 16);
-
- for (int i = 0; i < NUM_PACKETS; i++)
- {
- LOG_MSG_DEBUG("Sending aggregated packet %d into the USB pipe(%d "
- "bytes)\n", i, pPacketsSizes[i] + 12 + 16);
- int nBytesSent = input->Send(pAggregatedPacket[i],
- pPacketsSizes[i] + 12 + 16);
- if (pPacketsSizes[i] + 12 + 16 != nBytesSent)
- {
- LOG_MSG_DEBUG("Sending aggregated packet %d into the USB pipe(%d "
- "bytes) failed!\n", i, pPacketsSizes[i] + 12 + 16);
- return false;
- }
- }
-
- LOG_MSG_DEBUG("Reading aggregated packet from the USB pipe(%d bytes should "
- "be there)\n", MAX_PACKET_SIZE);
- int nBytesReceived = output->Receive(pReceivedPacket, MAX_PACKET_SIZE);
- if (MAX_PACKET_SIZE != nBytesReceived)
- {
- LOG_MSG_DEBUG("Receiving aggregated packet from the USB pipe(%d bytes) "
- "failed!\n", MAX_PACKET_SIZE);
- LOG_MSG_DEBUG("Received %d bytes\n", nBytesReceived);
- print_buff(pReceivedPacket, nBytesReceived);
- return false;
- }
-
- LOG_MSG_DEBUG("Checking sent.vs.received packet\n");
- return DeaggragateAndComparePackets(pReceivedPacket, pPackets,
- pPacketsSizes, NUM_PACKETS, nBytesReceived);
- }
- bool MBIMAggregationScenarios::MBIMAggregationLoopTest(
- Pipe* input, Pipe* output, enum ipa_ip_type m_eIP)
- {
-
- Byte pPackets[NUM_PACKETS][MAX_PACKET_SIZE];
-
- int pPacketsSizes[NUM_PACKETS];
-
- Byte pReceivedPacket[MAX_PACKET_SIZE];
-
-
- int nTotalPacketsSize = MAX_PACKET_SIZE - (4 * NUM_PACKETS) - 24;
- uint32_t nIPv4DSTAddr;
- size_t pIpPacketsSizes[NUM_PACKETS];
-
- for (int i = 0; i < NUM_PACKETS; i++)
- {
- if (NUM_PACKETS - 1 == i)
- pPacketsSizes[i] = nTotalPacketsSize;
- else
- pPacketsSizes[i] = nTotalPacketsSize / NUM_PACKETS;
- while (0 != pPacketsSizes[i] % 4)
- pPacketsSizes[i]++;
- nTotalPacketsSize -= pPacketsSizes[i];
-
- pIpPacketsSizes[i] = MAX_PACKET_SIZE;
- if (!LoadDefaultPacket(m_eIP, pPackets[i], pIpPacketsSizes[i]))
- {
- LOG_MSG_ERROR("Failed default Packet");
- return false;
- }
- nIPv4DSTAddr = ntohl(0x7F000001);
- memcpy (&pPackets[i][IPV4_DST_ADDR_OFFSET],&nIPv4DSTAddr,
- sizeof(nIPv4DSTAddr));
- int size = pIpPacketsSizes[i];
- while (size < pPacketsSizes[i])
- {
- pPackets[i][size] = i;
- size++;
- }
- }
- int num_iters = AGGREGATION_LOOP - 1;
- for (int j = 0; j < num_iters; j++)
- {
-
- for (int i = 0; i < NUM_PACKETS; i++)
- {
- LOG_MSG_DEBUG("Sending packet %d into the USB pipe(%d bytes)\n", i,
- pPacketsSizes[i]);
- int nBytesSent = input->Send(pPackets[i], pPacketsSizes[i]);
- if (pPacketsSizes[i] != nBytesSent)
- {
- LOG_MSG_DEBUG("Sending packet %d into the USB pipe(%d bytes) "
- "failed!\n", i, pPacketsSizes[i]);
- return false;
- }
- }
- memset(pReceivedPacket, 0, sizeof(pReceivedPacket));
-
- LOG_MSG_DEBUG("Reading packet from the USB pipe(%d bytes should be "
- "there)\n", MAX_PACKET_SIZE);
- int nBytesReceived = output->Receive(pReceivedPacket, MAX_PACKET_SIZE);
- if (MAX_PACKET_SIZE != nBytesReceived)
- {
- LOG_MSG_DEBUG("Receiving aggregated packet from the USB pipe(%d "
- "bytes) failed!\n", MAX_PACKET_SIZE);
- print_buff(pReceivedPacket, nBytesReceived);
- return false;
- }
- LOG_MSG_DEBUG("Checking sent.vs.received packet\n");
- if (false == DeaggragateAndComparePackets(pReceivedPacket, pPackets,
- pPacketsSizes, NUM_PACKETS, nBytesReceived))
- {
- LOG_MSG_DEBUG("Comparing aggregated packet failed!\n");
- return false;
- }
- }
- return true;
- }
- bool MBIMAggregationScenarios::MBIMAggregationTimeLimitTest(
- Pipe* input, Pipe* output,
- enum ipa_ip_type m_eIP)
- {
-
- Byte pPackets[1][MAX_PACKET_SIZE];
-
- int pPacketsSizes[1] = {0};
-
- Byte pReceivedPacket[MAX_PACKET_SIZE] = {0};
-
- int nTotalPacketsSize = 24;
- uint32_t nIPv4DSTAddr;
- size_t pIpPacketsSizes[1];
-
- for (int i = 0; i < 1 ; i++)
- {
- pPacketsSizes[i] = 52 + 4*i;
- nTotalPacketsSize += pPacketsSizes[i] + 4;
-
- pIpPacketsSizes[i] = MAX_PACKET_SIZE;
- if (!LoadDefaultPacket(m_eIP, pPackets[i], pIpPacketsSizes[i]))
- {
- LOG_MSG_ERROR("Failed default Packet");
- return false;
- }
- nIPv4DSTAddr = ntohl(0x7F000001);
- memcpy (&pPackets[i][IPV4_DST_ADDR_OFFSET],&nIPv4DSTAddr,
- sizeof(nIPv4DSTAddr));
- int size = pIpPacketsSizes[i];
- while (size < pPacketsSizes[i])
- {
- pPackets[i][size] = i;
- size++;
- }
- }
- int nAllPacketsSizes = 0;
- for (int i = 0; i < 1; i++)
- nAllPacketsSizes += pPacketsSizes[i];
- while (0 != nAllPacketsSizes % 4)
- {
- nAllPacketsSizes++;
- nTotalPacketsSize++;
- }
-
- for (int i = 0; i < 1; i++)
- {
- LOG_MSG_DEBUG("Sending packet %d into the USB pipe(%d bytes)\n", i,
- pPacketsSizes[i]);
- int nBytesSent = input->Send(pPackets[i], pPacketsSizes[i]);
- if (pPacketsSizes[i] != nBytesSent)
- {
- LOG_MSG_DEBUG("Sending packet %d into the USB pipe(%d bytes) "
- "failed!\n", i, pPacketsSizes[i]);
- return false;
- }
- }
-
- LOG_MSG_DEBUG("Reading packet from the USB pipe(%d bytes should be "
- "there)\n", nTotalPacketsSize);
- int nBytesReceived = output->Receive(pReceivedPacket, nTotalPacketsSize);
-
- if (nTotalPacketsSize > nBytesReceived)
- {
- LOG_MSG_DEBUG("Receiving aggregated packet from the USB pipe(%d bytes) "
- "failed!\n", nTotalPacketsSize);
- print_buff(pReceivedPacket, nBytesReceived);
- return false;
- }
-
- LOG_MSG_DEBUG("Checking sent.vs.received packet\n");
- if (false == DeaggragateAndComparePackets(pReceivedPacket, pPackets,
- pPacketsSizes, 1, nBytesReceived))
- {
- LOG_MSG_DEBUG("Comparing aggregated packet failed!\n");
- print_buff(pReceivedPacket, nBytesReceived);
- return false;
- }
- return true;
- }
- bool MBIMAggregationScenarios::MBIMAggregationByteLimitTest(
- Pipe* input, Pipe* output,
- enum ipa_ip_type m_eIP)
- {
-
- Byte pPackets[2][MAX_PACKET_SIZE];
-
- int pPacketsSizes[2];
-
- Byte pReceivedPacket[2*MAX_PACKET_SIZE] = {0};
-
- int nTotalPacketsSize = 24;
- uint32_t nIPv4DSTAddr;
- size_t pIpPacketsSizes[2];
-
- for (int i = 0; i < 2; i++)
- {
- pPacketsSizes[i] = (MAX_PACKET_SIZE / 2) + 10;
- nTotalPacketsSize += pPacketsSizes[i] + 4;
-
- pIpPacketsSizes[i] = MAX_PACKET_SIZE;
- if (!LoadDefaultPacket(m_eIP, pPackets[i], pIpPacketsSizes[i]))
- {
- LOG_MSG_ERROR("Failed default Packet");
- return false;
- }
- nIPv4DSTAddr = ntohl(0x7F000001);
- memcpy (&pPackets[i][IPV4_DST_ADDR_OFFSET],&nIPv4DSTAddr,
- sizeof(nIPv4DSTAddr));
- int size = pIpPacketsSizes[i];
- while (size < pPacketsSizes[i])
- {
- pPackets[i][size] = i;
- size++;
- }
- }
-
- for (int i = 0; i < 2; i++)
- {
- LOG_MSG_DEBUG("Sending packet %d into the USB pipe(%d bytes)\n", i,
- pPacketsSizes[i]);
- int nBytesSent = input->Send(pPackets[i], pPacketsSizes[i]);
- if (pPacketsSizes[i] != nBytesSent)
- {
- LOG_MSG_DEBUG("Sending packet %d into the USB pipe(%d bytes) "
- "failed!\n", i, pPacketsSizes[i]);
- return false;
- }
- }
-
- LOG_MSG_DEBUG("Reading packet from the USB pipe(%d bytes should be "
- "there)\n", nTotalPacketsSize);
- int nBytesReceived = output->Receive(pReceivedPacket, nTotalPacketsSize);
-
- if (nTotalPacketsSize > nBytesReceived)
- {
- LOG_MSG_DEBUG("Receiving aggregated packet from the USB pipe(%d bytes) "
- "failed!\n", nTotalPacketsSize);
- print_buff(pReceivedPacket, nBytesReceived);
- return false;
- }
-
- LOG_MSG_DEBUG("Checking sent.vs.received packet\n");
- if (false == DeaggragateAndComparePackets(pReceivedPacket, pPackets,
- pPacketsSizes, 2, nBytesReceived))
- {
- LOG_MSG_DEBUG("Comparing aggregated packet failed!\n");
- return false;
- }
- return true;
- }
- bool MBIMAggregationScenarios::MBIMAggregationByteLimitTestFC(
- Pipe *input, Pipe *output,
- enum ipa_ip_type m_eIP)
- {
-
- Byte pPackets[2][MAX_PACKET_SIZE];
-
- int pPacketsSizes[2];
-
- Byte pReceivedPacket[2][MAX_PACKET_SIZE] = {0};
-
- int nTotalPacketsSize = 24 + (MAX_PACKET_SIZE / 2) + 8 + 4;
- uint32_t nIPv4DSTAddr;
- size_t pIpPacketsSizes[2];
- int nBytesReceived;
- for (int i = 0; i < 2; i++)
- {
- pPacketsSizes[i] = (MAX_PACKET_SIZE / 2) + 8;
-
- pIpPacketsSizes[i] = MAX_PACKET_SIZE;
- if (!LoadDefaultPacket(m_eIP, pPackets[i], pIpPacketsSizes[i]))
- {
- LOG_MSG_ERROR("Failed default Packet");
- return false;
- }
- nIPv4DSTAddr = ntohl(0x7F000001);
- memcpy (&pPackets[i][IPV4_DST_ADDR_OFFSET],&nIPv4DSTAddr,
- sizeof(nIPv4DSTAddr));
- int size = pIpPacketsSizes[i];
- while (size < pPacketsSizes[i])
- {
- pPackets[i][size] = i;
- size++;
- }
- }
-
- for (int i = 0; i < 2; i++)
- {
- LOG_MSG_DEBUG("Sending packet %d into the USB pipe(%d bytes)\n", i,
- pPacketsSizes[i]);
- int nBytesSent = input->Send(pPackets[i], pPacketsSizes[i]);
- if (pPacketsSizes[i] != nBytesSent)
- {
- LOG_MSG_DEBUG("Sending packet %d into the USB pipe(%d bytes) "
- "failed!\n", i, pPacketsSizes[i]);
- return false;
- }
- }
-
- LOG_MSG_DEBUG(
- "Reading packets from the USB pipe(%d bytes for each)"
- "\n", nTotalPacketsSize);
- for (int i = 0; i < 2; i++)
- {
- nBytesReceived = output->Receive(pReceivedPacket[i], MAX_PACKET_SIZE);
- if (nTotalPacketsSize != nBytesReceived)
- {
- LOG_MSG_ERROR(
- "Receiving aggregated packet from the USB pipe(%d bytes) "
- "failed!\n", nBytesReceived);
- print_buff(pReceivedPacket[i], nBytesReceived);
- return false;
- }
- }
-
- LOG_MSG_DEBUG("Checking sent.vs.received packets\n");
- for (int i = 0; i < 2; i++)
- {
- if (false == DeaggragateAndComparePackets(pReceivedPacket[i],
- &pPackets[i],
- (int *)&pPacketsSizes[i],
- 1,
- nBytesReceived))
- {
- LOG_MSG_DEBUG("Comparing aggregated packet failed!\n");
- return false;
- }
- }
- return true;
- }
- #define DUAL_FC_IP_PACKET_L ((MAX_PACKET_SIZE / 2) + 8)
- #define DUAL_FC_1_AGG_PACKET_L (12 + DUAL_FC_IP_PACKET_L + 12 + 4)
- #define DUAL_FC_2_AGG_PACKET_L (12 + DUAL_FC_IP_PACKET_L + DUAL_FC_IP_PACKET_L + 12 + 4 + 4)
- bool MBIMAggregationScenarios::MBIMAggregationDualDpTestFC(
- Pipe *input, Pipe *output1, Pipe *output2,
- enum ipa_ip_type m_eIP)
- {
- int i;
-
- Byte pPackets[4][MAX_PACKET_SIZE];
-
- int pPacketsSizes[4];
-
- Byte pReceivedPacket[2 * MAX_PACKET_SIZE] = {0};
- Byte pReceivedPacketFC[2][MAX_PACKET_SIZE] = {0};
- uint32_t nIPv4DSTAddr;
- size_t pIpPacketsSizes[4];
- int nBytesReceived;
- for (i = 0; i < 4; i++)
- {
- pPacketsSizes[i] = DUAL_FC_IP_PACKET_L;
-
- pIpPacketsSizes[i] = MAX_PACKET_SIZE;
- if (!LoadDefaultPacket(m_eIP, pPackets[i], pIpPacketsSizes[i]))
- {
- LOG_MSG_ERROR("Failed default Packet");
- return false;
- }
- nIPv4DSTAddr = ntohl(0x7F000001 + (i & 0x1));
- memcpy(&pPackets[i][IPV4_DST_ADDR_OFFSET], &nIPv4DSTAddr,
- sizeof(nIPv4DSTAddr));
- int size = pIpPacketsSizes[i];
- while (size < pPacketsSizes[i])
- {
- pPackets[i][size] = 0xAA;
- size++;
- }
- }
-
- for (int i = 0; i < 4; i++)
- {
- LOG_MSG_DEBUG("Sending packet %d into the USB pipe(%d bytes)\n", i,
- pPacketsSizes[i]);
- int nBytesSent = input->Send(pPackets[i], pPacketsSizes[i]);
- if (pPacketsSizes[i] != nBytesSent)
- {
- LOG_MSG_DEBUG("Sending packet %d into the USB pipe(%d bytes) "
- "failed!\n", i, pPacketsSizes[i]);
- return false;
- }
- }
-
- LOG_MSG_DEBUG(
- "Reading packets from the FC pipe (%d bytes for each)"
- "\n", DUAL_FC_1_AGG_PACKET_L);
- for (i = 0; i < 2; i++)
- {
- nBytesReceived = output1->Receive(pReceivedPacketFC[i], MAX_PACKET_SIZE);
- if (DUAL_FC_1_AGG_PACKET_L != nBytesReceived)
- {
- LOG_MSG_ERROR(
- "Receiving aggregated packet from the USB pipe (%d bytes) "
- "failed!\n", nBytesReceived);
- print_buff(pReceivedPacketFC[i], nBytesReceived);
- return false;
- }
- }
- for (i = 0; i < 2; i++)
- {
- if (false == DeaggragateAndComparePackets(pReceivedPacketFC[i],
- &pPackets[i * 2],
- (int *)&pPacketsSizes[i * 2],
- 1,
- nBytesReceived))
- {
- LOG_MSG_DEBUG("Comparing aggregated packet failed!\n");
- return false;
- }
- }
-
- LOG_MSG_DEBUG(
- "Reading packet from the non-FC pipe (%d bytes)"
- "\n", DUAL_FC_2_AGG_PACKET_L);
- nBytesReceived = output2->Receive(pReceivedPacket, MAX_PACKET_SIZE);
- if (DUAL_FC_2_AGG_PACKET_L != nBytesReceived)
- {
- LOG_MSG_ERROR(
- "Receiving aggregated packet from the USB pipe (%d bytes) "
- "failed!\n", nBytesReceived);
- print_buff(pReceivedPacket, nBytesReceived);
- return false;
- }
-
- nIPv4DSTAddr = ntohl(0x7F000002);
- memcpy(&pPackets[0][IPV4_DST_ADDR_OFFSET], &nIPv4DSTAddr, sizeof(nIPv4DSTAddr));
- memcpy(&pPackets[2][IPV4_DST_ADDR_OFFSET], &nIPv4DSTAddr, sizeof(nIPv4DSTAddr));
- if (false == DeaggragateAndComparePackets(&pReceivedPacket[0], pPackets,
- (int *)&pPacketsSizes, 2, nBytesReceived))
- {
- LOG_MSG_DEBUG("Comparing aggregated packet failed!\n");
- print_buff(pReceivedPacket, nBytesReceived);
- return false;
- }
- return true;
- }
- bool MBIMAggregationScenarios::MBIMDeaggregationMultipleNDPTest(
- Pipe* input, Pipe* output,
- enum ipa_ip_type m_eIP)
- {
- bool bTestResult = true;
-
- Byte pExpectedPackets[NUM_PACKETS][MAX_PACKET_SIZE];
-
- int pPacketsSizes[NUM_PACKETS];
-
- Byte pReceivedPackets[NUM_PACKETS][MAX_PACKET_SIZE];
-
-
-
- int nTotalPacketsSize = MAX_PACKET_SIZE - (4 * NUM_PACKETS) - 36;
-
- Byte pAggregatedPacket[MAX_PACKET_SIZE] = {0};
-
-
- Byte pPacketsStreamId[NUM_PACKETS] = {0};
- uint32_t nIPv4DSTAddr;
- size_t pIpPacketsSizes[NUM_PACKETS];
-
- for (int i = 0; i < NUM_PACKETS; i++)
- {
- if (NUM_PACKETS - 1 == i)
- pPacketsSizes[i] = nTotalPacketsSize;
- else {
- pPacketsSizes[i] = nTotalPacketsSize / NUM_PACKETS;
- pPacketsSizes[i] += (pPacketsSizes[i] % 4 == 0 ? 0 :
- 4 - pPacketsSizes[i] % 4);
- }
- nTotalPacketsSize -= pPacketsSizes[i];
- pPacketsStreamId[i] = i < 3 ? 0 : 1;
-
- pIpPacketsSizes[i] = MAX_PACKET_SIZE;
- if (!LoadDefaultPacket(m_eIP, pExpectedPackets[i],
- pIpPacketsSizes[i]))
- {
- LOG_MSG_ERROR("Failed default Packet");
- return false;
- }
- nIPv4DSTAddr = ntohl(0x7F000001);
- memcpy (&pExpectedPackets[i][IPV4_DST_ADDR_OFFSET],&nIPv4DSTAddr,
- sizeof(nIPv4DSTAddr));
- int size = pIpPacketsSizes[i];
- while (size < pPacketsSizes[i])
- {
- pExpectedPackets[i][size] = i;
- size++;
- }
- }
-
- AggregatePacketsWithStreamId(pAggregatedPacket, pExpectedPackets,
- pPacketsSizes, NUM_PACKETS, MAX_PACKET_SIZE, pPacketsStreamId);
-
- LOG_MSG_DEBUG("Sending aggregated packet into the USB pipe(%d bytes)\n",
- sizeof(pAggregatedPacket));
- int nBytesSent = input->Send(pAggregatedPacket, sizeof(pAggregatedPacket));
- if (sizeof(pAggregatedPacket) != nBytesSent)
- {
- LOG_MSG_DEBUG("Sending aggregated packet into the USB pipe(%d bytes) "
- "failed!\n", sizeof(pAggregatedPacket));
- return false;
- }
-
- for (int i = 0; i < NUM_PACKETS; i++)
- {
- LOG_MSG_DEBUG("Reading packet %d from the USB pipe(%d bytes should be "
- "there)\n", i, pPacketsSizes[i]);
- int nBytesReceived = output->Receive(pReceivedPackets[i],
- pPacketsSizes[i]);
- if (pPacketsSizes[i] != nBytesReceived)
- {
- LOG_MSG_DEBUG("Receiving packet %d from the USB pipe(%d bytes) "
- "failed!\n", i, pPacketsSizes[i]);
- print_buff(pReceivedPackets[i], nBytesReceived);
- return false;
- }
- }
-
- LOG_MSG_DEBUG("Checking sent.vs.received packet\n");
- for (int i = 0; i < NUM_PACKETS; i++)
- bTestResult &= !memcmp(pExpectedPackets[i], pReceivedPackets[i],
- pPacketsSizes[i]);
- return bTestResult;
- }
- bool MBIMAggregationScenarios::MBIMAggregation2PipesTest(
- Pipe* input1, Pipe* input2, Pipe* output, enum ipa_ip_type m_eIP)
- {
-
- Byte pPackets[NUM_PACKETS][MAX_PACKET_SIZE];
-
- int pPacketsSizes[NUM_PACKETS];
-
- Byte pReceivedPacket[2*MAX_PACKET_SIZE];
-
-
- int nTotalPacketsSize = MAX_PACKET_SIZE - (4 * NUM_PACKETS) - 24;
-
- Byte pAggregatedPacket[2][MAX_PACKET_SIZE];
-
- int nAggregatedPacketSize[2] = {0};
- uint32_t nIPv4DSTAddr;
- size_t pIpPacketsSizes[NUM_PACKETS];
-
- for (int i = 0; i < NUM_PACKETS; i++)
- {
- if (NUM_PACKETS - 1 == i)
- pPacketsSizes[i] = nTotalPacketsSize;
- else
- pPacketsSizes[i] = nTotalPacketsSize / NUM_PACKETS;
- while (0 != pPacketsSizes[i] % 4)
- pPacketsSizes[i]++;
- nTotalPacketsSize -= pPacketsSizes[i];
-
- pIpPacketsSizes[i] = MAX_PACKET_SIZE;
- if (!LoadDefaultPacket(m_eIP, pPackets[i], pIpPacketsSizes[i]))
- {
- LOG_MSG_ERROR("Failed default Packet");
- return false;
- }
- nIPv4DSTAddr = ntohl(0x7F000001);
- memcpy (&pPackets[i][IPV4_DST_ADDR_OFFSET],&nIPv4DSTAddr,
- sizeof(nIPv4DSTAddr));
- int size = pIpPacketsSizes[i];
- while (size < pPacketsSizes[i])
- {
- pPackets[i][size] = i;
- size++;
- }
- }
- nAggregatedPacketSize[0] += pPacketsSizes[0] + pPacketsSizes[1];
- nAggregatedPacketSize[0] += 12;
- nAggregatedPacketSize[0] += 12 + 4*2;
-
- AggregatePackets(pAggregatedPacket[0], pPackets, pPacketsSizes, 2,
- nAggregatedPacketSize[0]);
-
- LOG_MSG_DEBUG("Sending aggregated packet into the USB pipe(%d "
- "bytes)\n", nAggregatedPacketSize[0]);
- int nBytesSent = input1->Send(pAggregatedPacket[0],
- nAggregatedPacketSize[0]);
- if (nAggregatedPacketSize[0] != nBytesSent)
- {
- LOG_MSG_DEBUG("Sending aggregated packet into the USB pipe(%d bytes) "
- "failed!\n", nAggregatedPacketSize[0]);
- return false;
- }
-
- for (int i = 2; i < NUM_PACKETS; i++)
- {
- LOG_MSG_DEBUG("Sending packet %d into the USB pipe(%d bytes)\n", i,
- pPacketsSizes[i]);
- int nBytesSent = input2->Send(pPackets[i], pPacketsSizes[i]);
- if (pPacketsSizes[i] != nBytesSent)
- {
- LOG_MSG_DEBUG("Sending packet %d into the USB pipe(%d bytes) "
- "failed!\n", i, pPacketsSizes[i]);
- return false;
- }
- }
-
- LOG_MSG_DEBUG("Reading packet from the USB pipe(%d bytes should be "
- "there)\n", MAX_PACKET_SIZE);
- int nBytesReceived = output->Receive(pReceivedPacket, MAX_PACKET_SIZE);
- if (MAX_PACKET_SIZE != nBytesReceived)
- {
- LOG_MSG_DEBUG("Receiving aggregated packet from the USB pipe(%d bytes) "
- "failed!\n", MAX_PACKET_SIZE);
- print_buff(pReceivedPacket, nBytesReceived);
- return false;
- }
-
- return DeaggragateAndComparePackets(pReceivedPacket, pPackets, pPacketsSizes, NUM_PACKETS, nBytesReceived);
- }
- bool MBIMAggregationScenarios::MBIMAggregationTimeLimitLoopTest(
- Pipe* input, Pipe* output,
- enum ipa_ip_type m_eIP)
- {
-
- Byte pPackets[1][MAX_PACKET_SIZE];
-
- int pPacketsSizes[1] = {0};
-
- Byte pReceivedPacket[MAX_PACKET_SIZE] = {0};
-
- int nTotalPacketsSize = 24;
- uint32_t nIPv4DSTAddr;
- size_t pIpPacketsSizes[NUM_PACKETS];
-
- for (int i = 0; i < 1 ; i++)
- {
- pPacketsSizes[i] = 52 + 4*i;
- nTotalPacketsSize += pPacketsSizes[i] + 4;
-
- pIpPacketsSizes[i] = MAX_PACKET_SIZE;
- if (!LoadDefaultPacket(m_eIP, pPackets[i], pIpPacketsSizes[i]))
- {
- LOG_MSG_ERROR("Failed default Packet");
- return false;
- }
- nIPv4DSTAddr = ntohl(0x7F000001);
- memcpy (&pPackets[i][IPV4_DST_ADDR_OFFSET],&nIPv4DSTAddr,
- sizeof(nIPv4DSTAddr));
- int size = pIpPacketsSizes[i];
- while (size < pPacketsSizes[i])
- {
- pPackets[i][size] = i;
- size++;
- }
- }
- int nAllPacketsSizes = 0;
- for (int i = 0; i < 1; i++)
- nAllPacketsSizes += pPacketsSizes[i];
- while (0 != nAllPacketsSizes % 4)
- {
- nAllPacketsSizes++;
- nTotalPacketsSize++;
- }
- for (int k = 0; k < AGGREGATION_LOOP; k++)
- {
-
- for (int i = 0; i < 1; i++)
- {
- LOG_MSG_DEBUG("Sending packet %d into the USB pipe(%d bytes)\n", i,
- pPacketsSizes[i]);
- int nBytesSent = input->Send(pPackets[i], pPacketsSizes[i]);
- if (pPacketsSizes[i] != nBytesSent)
- {
- LOG_MSG_DEBUG("Sending packet %d into the USB pipe(%d bytes) "
- "failed!\n", i, pPacketsSizes[i]);
- return false;
- }
- }
-
- LOG_MSG_DEBUG("Reading packet from the USB pipe(%d bytes should be "
- "there)\n", nTotalPacketsSize);
- int nBytesReceived = output->Receive(pReceivedPacket,
- nTotalPacketsSize);
-
- if (nTotalPacketsSize > nBytesReceived)
- {
- LOG_MSG_DEBUG("Receiving aggregated packet from the USB pipe(%d "
- "bytes) failed!\n", nTotalPacketsSize);
- print_buff(pReceivedPacket, nBytesReceived);
- return false;
- }
-
- LOG_MSG_DEBUG("Checking sent.vs.received packet\n");
- if (false == DeaggragateAndComparePackets(pReceivedPacket, pPackets,
- pPacketsSizes, 1, nBytesReceived))
- {
- LOG_MSG_DEBUG("Comparing aggregated packet failed!\n");
- return false;
- }
- }
- return true;
- }
- bool MBIMAggregationScenarios::MBIMAggregation0LimitsTest(
- Pipe* input, Pipe* output,
- enum ipa_ip_type m_eIP)
- {
-
- Byte pPackets[NUM_PACKETS][MAX_PACKET_SIZE];
-
- int pPacketsSizes[NUM_PACKETS];
-
- Byte pReceivedPackets[NUM_PACKETS][MAX_PACKET_SIZE];
-
- int pAggragatedPacketsSizes[NUM_PACKETS] = {0};
- uint32_t nIPv4DSTAddr;
- size_t pIpPacketsSizes[NUM_PACKETS];
-
- for (int i = 0; i < NUM_PACKETS ; i++)
- {
- pPacketsSizes[i] = 52 + 4*i;
-
- pIpPacketsSizes[i] = MAX_PACKET_SIZE;
- if (!LoadDefaultPacket(m_eIP, pPackets[i], pIpPacketsSizes[i]))
- {
- LOG_MSG_ERROR("Failed default Packet");
- return false;
- }
- nIPv4DSTAddr = ntohl(0x7F000001);
- memcpy (&pPackets[i][IPV4_DST_ADDR_OFFSET],&nIPv4DSTAddr,
- sizeof(nIPv4DSTAddr));
- int size = pIpPacketsSizes[i];
- while (size < pPacketsSizes[i])
- {
- pPackets[i][size] = i;
- size++;
- }
- }
-
- for (int i = 0; i < NUM_PACKETS; i++)
- {
- pAggragatedPacketsSizes[i] += pPacketsSizes[i];
- while (0 != pAggragatedPacketsSizes[i] % 4)
- pAggragatedPacketsSizes[i]++;
- pAggragatedPacketsSizes[i] += 28;
- }
-
- for (int i = 0; i < NUM_PACKETS; i++)
- {
- LOG_MSG_DEBUG("Sending packet %d into the USB pipe(%d bytes)\n", i,
- pPacketsSizes[i]);
- int nBytesSent = input->Send(pPackets[i], pPacketsSizes[i]);
- if (pPacketsSizes[i] != nBytesSent)
- {
- LOG_MSG_DEBUG("Sending packet %d into the USB pipe(%d bytes) "
- "failed!\n", i, pPacketsSizes[i]);
- return false;
- }
- }
-
- for (int i = 0; i < NUM_PACKETS; i++)
- {
- LOG_MSG_DEBUG("Reading packet %d from the USB pipe(%d bytes should be "
- "there)\n", i, pAggragatedPacketsSizes[i]);
- int nBytesReceived = output->Receive(pReceivedPackets[i],
- pAggragatedPacketsSizes[i]);
-
- if (pAggragatedPacketsSizes[i] > nBytesReceived)
- {
- LOG_MSG_DEBUG("Receiving aggregated packet %d from the USB pipe(%d "
- "bytes) failed!\n", i, pAggragatedPacketsSizes[i]);
- print_buff(pReceivedPackets[i], nBytesReceived);
- return false;
- }
- pAggragatedPacketsSizes[i] = nBytesReceived;
- }
-
- LOG_MSG_DEBUG("Checking sent.vs.received packet\n");
- for (int i = 0; i < NUM_PACKETS; i++)
- {
- if (false == DeaggragateAndCompareOnePacket(pReceivedPackets[i],
- pPackets[i], pPacketsSizes[i], pAggragatedPacketsSizes[i]))
- {
- LOG_MSG_DEBUG("Comparing aggregated packet %d failed!\n", i);
- return false;
- }
- }
- return true;
- }
- bool MBIMAggregationScenarios::MBIMAggregationMultiplePacketsTest(
- Pipe* input, Pipe* output,
- enum ipa_ip_type m_eIP)
- {
-
- Byte pPackets[MAX_PACKETS_IN_NDP + 1][MAX_PACKET_SIZE];
-
- int pPacketsSizes[MAX_PACKETS_IN_NDP + 1];
-
- Byte pReceivedPacket[2*MAX_PACKET_SIZE];
- uint32_t nIPv4DSTAddr;
- size_t pIpPacketsSizes[MAX_PACKETS_IN_NDP + 1];
-
-
- int nTotalPacketsSize = MAX_PACKET_SIZE - (4 * (MAX_PACKETS_IN_NDP + 1)) - 24;
-
- for (int i = 0; i < MAX_PACKETS_IN_NDP + 1; i++)
- {
- if (MAX_PACKETS_IN_NDP == i)
- pPacketsSizes[i] = nTotalPacketsSize;
- else
- {
- pPacketsSizes[i] = nTotalPacketsSize / (MAX_PACKETS_IN_NDP + 1);
- pPacketsSizes[i] += (pPacketsSizes[i] % 4 == 0 ? 0 :
- 4 - pPacketsSizes[i] % 4);
- }
- nTotalPacketsSize -= pPacketsSizes[i];
-
- pIpPacketsSizes[i] = MAX_PACKET_SIZE;
- if (!LoadDefaultPacket(m_eIP, pPackets[i], pIpPacketsSizes[i]))
- {
- LOG_MSG_ERROR("Failed default Packet");
- return false;
- }
- nIPv4DSTAddr = ntohl(0x7F000001);
- memcpy (&pPackets[i][IPV4_DST_ADDR_OFFSET],&nIPv4DSTAddr,
- sizeof(nIPv4DSTAddr));
- int size = pIpPacketsSizes[i];
- while (size < pPacketsSizes[i])
- {
- pPackets[i][size] = i;
- size++;
- }
- }
-
- for (int i = 0; i < MAX_PACKETS_IN_NDP + 1; i++)
- {
- LOG_MSG_DEBUG("Sending packet %d into the USB pipe(%d bytes)\n", i,
- pPacketsSizes[i]);
- int nBytesSent = input->Send(pPackets[i], pPacketsSizes[i]);
- if (pPacketsSizes[i] != nBytesSent)
- {
- LOG_MSG_DEBUG("Sending packet %d into the USB pipe(%d bytes) "
- "failed!\n", i, pPacketsSizes[i]);
- return false;
- }
- }
-
- LOG_MSG_DEBUG("Reading packet from the USB pipe(%d bytes should be "
- "there)\n", MAX_PACKET_SIZE);
- int nBytesReceived = output->Receive(pReceivedPacket, MAX_PACKET_SIZE);
- if (MAX_PACKET_SIZE != nBytesReceived)
- {
- LOG_MSG_DEBUG("Receiving aggregated packet from the USB pipe(%d bytes) "
- "failed!\n", MAX_PACKET_SIZE);
- print_buff(pReceivedPacket, nBytesReceived);
- return false;
- }
-
- return DeaggragateAndComparePackets(pReceivedPacket, pPackets,
- pPacketsSizes, MAX_PACKETS_IN_NDP+1, nBytesReceived);
- }
- bool MBIMAggregationScenarios::MBIMAggregationDifferentStreamIdsTest(
- Pipe* input, Pipe* output,
- enum ipa_ip_type m_eIP)
- {
-
- Byte pPackets[NUM_PACKETS][MAX_PACKET_SIZE];
-
- int pPacketsSizes[NUM_PACKETS];
-
- Byte pReceivedPacket[2*MAX_PACKET_SIZE];
-
-
- int nTotalPacketsSize = MAX_PACKET_SIZE - (16 * NUM_PACKETS) - 12;
- uint32_t nIPv4DSTAddr;
- size_t pIpPacketsSizes[NUM_PACKETS];
- Byte pPacketsStreamId[NUM_PACKETS];
-
- for (int i = 0; i < NUM_PACKETS; i++)
- {
- pPacketsStreamId[i] = i;
- if (NUM_PACKETS - 1 == i)
- pPacketsSizes[i] = nTotalPacketsSize + 12;
- else
- pPacketsSizes[i] = nTotalPacketsSize / NUM_PACKETS;
- while (0 != pPacketsSizes[i] % 4)
- pPacketsSizes[i]++;
- nTotalPacketsSize -= pPacketsSizes[i];
-
- pIpPacketsSizes[i] = MAX_PACKET_SIZE;
- if (!LoadDefaultPacket(m_eIP, pPackets[i], pIpPacketsSizes[i]))
- {
- LOG_MSG_ERROR("Failed default Packet");
- return false;
- }
- int size = pIpPacketsSizes[i];
- while (size < pPacketsSizes[i])
- {
- pPackets[i][size] = i;
- size++;
- }
- }
- nIPv4DSTAddr = ntohl(0x7F000001);
- memcpy (&pPackets[0][IPV4_DST_ADDR_OFFSET],&nIPv4DSTAddr,
- sizeof(nIPv4DSTAddr));
- nIPv4DSTAddr = ntohl(0xC0A80101);
- memcpy (&pPackets[1][IPV4_DST_ADDR_OFFSET],&nIPv4DSTAddr,
- sizeof(nIPv4DSTAddr));
- nIPv4DSTAddr = ntohl(0xC0A80102);
- memcpy (&pPackets[2][IPV4_DST_ADDR_OFFSET],&nIPv4DSTAddr,
- sizeof(nIPv4DSTAddr));
- nIPv4DSTAddr = ntohl(0xC0A80103);
- memcpy (&pPackets[3][IPV4_DST_ADDR_OFFSET],&nIPv4DSTAddr,
- sizeof(nIPv4DSTAddr));
- nIPv4DSTAddr = ntohl(0xC0A80104);
- memcpy (&pPackets[4][IPV4_DST_ADDR_OFFSET],&nIPv4DSTAddr,
- sizeof(nIPv4DSTAddr));
-
- for (int i = 0; i < NUM_PACKETS; i++)
- {
- LOG_MSG_DEBUG("Sending packet %d into the USB pipe(%d bytes)\n", i,
- pPacketsSizes[i]);
- int nBytesSent = input->Send(pPackets[i], pPacketsSizes[i]);
- if (pPacketsSizes[i] != nBytesSent)
- {
- LOG_MSG_DEBUG("Sending packet %d into the USB pipe(%d bytes) "
- "failed!\n", i, pPacketsSizes[i]);
- return false;
- }
- }
-
- LOG_MSG_DEBUG("Reading packet from the USB pipe(%d bytes should be "
- "there)\n", MAX_PACKET_SIZE + 12);
- int nBytesReceived = output->Receive(pReceivedPacket, MAX_PACKET_SIZE + 12);
- if (MAX_PACKET_SIZE + 12 != nBytesReceived)
- {
- LOG_MSG_DEBUG("Receiving aggregated packet from the USB pipe(%d bytes) "
- "failed!\n", MAX_PACKET_SIZE + 12);
- print_buff(pReceivedPacket, nBytesReceived + 12);
- return false;
- }
-
- return DeaggragateAndComparePacketsWithStreamId(pReceivedPacket, pPackets,
- pPacketsSizes, NUM_PACKETS, nBytesReceived, pPacketsStreamId);
- }
- bool MBIMAggregationScenarios::MBIMAggregationNoInterleavingStreamIdsTest(
- Pipe* input, Pipe* output,
- enum ipa_ip_type m_eIP)
- {
-
- Byte pPackets[NUM_PACKETS][MAX_PACKET_SIZE];
-
- int pPacketsSizes[NUM_PACKETS];
-
- Byte pReceivedPacket[2*MAX_PACKET_SIZE];
-
-
- int nTotalPacketsSize = MAX_PACKET_SIZE - (16 * NUM_PACKETS) - 12;
- uint32_t nIPv4DSTAddr;
- size_t pIpPacketsSizes[NUM_PACKETS];
- Byte pPacketsStreamId[NUM_PACKETS];
-
- for (int i = 0; i < NUM_PACKETS; i++)
- {
- pPacketsStreamId[i] = i % 2;
- if (NUM_PACKETS - 1 == i)
- pPacketsSizes[i] = nTotalPacketsSize + 12;
- else
- pPacketsSizes[i] = nTotalPacketsSize / NUM_PACKETS;
- while (0 != pPacketsSizes[i] % 4)
- pPacketsSizes[i]++;
- nTotalPacketsSize -= pPacketsSizes[i];
-
- pIpPacketsSizes[i] = MAX_PACKET_SIZE;
- if (!LoadDefaultPacket(m_eIP, pPackets[i], pIpPacketsSizes[i]))
- {
- LOG_MSG_ERROR("Failed default Packet");
- return false;
- }
- int size = pIpPacketsSizes[i];
- while (size < pPacketsSizes[i])
- {
- pPackets[i][size] = i;
- size++;
- }
- }
- nIPv4DSTAddr = ntohl(0x7F000001);
- memcpy (&pPackets[0][IPV4_DST_ADDR_OFFSET],&nIPv4DSTAddr,
- sizeof(nIPv4DSTAddr));
- nIPv4DSTAddr = ntohl(0xC0A80101);
- memcpy (&pPackets[1][IPV4_DST_ADDR_OFFSET],&nIPv4DSTAddr,
- sizeof(nIPv4DSTAddr));
- nIPv4DSTAddr = ntohl(0x7F000001);
- memcpy (&pPackets[2][IPV4_DST_ADDR_OFFSET],&nIPv4DSTAddr,
- sizeof(nIPv4DSTAddr));
- nIPv4DSTAddr = ntohl(0xC0A80101);
- memcpy (&pPackets[3][IPV4_DST_ADDR_OFFSET],&nIPv4DSTAddr,
- sizeof(nIPv4DSTAddr));
- nIPv4DSTAddr = ntohl(0x7F000001);
- memcpy (&pPackets[4][IPV4_DST_ADDR_OFFSET],&nIPv4DSTAddr,
- sizeof(nIPv4DSTAddr));
-
- for (int i = 0; i < NUM_PACKETS; i++)
- {
- LOG_MSG_DEBUG("Sending packet %d into the USB pipe(%d bytes)\n", i,
- pPacketsSizes[i]);
- int nBytesSent = input->Send(pPackets[i], pPacketsSizes[i]);
- if (pPacketsSizes[i] != nBytesSent)
- {
- LOG_MSG_DEBUG("Sending packet %d into the USB pipe(%d bytes) "
- "failed!\n", i, pPacketsSizes[i]);
- return false;
- }
- }
-
- LOG_MSG_DEBUG("Reading packet from the USB pipe(%d bytes should be "
- "there)\n", MAX_PACKET_SIZE + 12);
- int nBytesReceived = output->Receive(pReceivedPacket,
- MAX_PACKET_SIZE + 12);
- if (MAX_PACKET_SIZE + 12 != nBytesReceived)
- {
- LOG_MSG_DEBUG("Receiving aggregated packet from the USB pipe(%d bytes)"
- " failed!\n", MAX_PACKET_SIZE + 12);
- print_buff(pReceivedPacket, nBytesReceived + 12);
- return false;
- }
-
- return DeaggragateAndComparePacketsWithStreamId(pReceivedPacket, pPackets,
- pPacketsSizes, NUM_PACKETS, nBytesReceived, pPacketsStreamId);
- }
- bool MBIMAggregationScenarios::DeaggragateAndComparePackets(
- Byte pAggregatedPacket[MAX_PACKET_SIZE],
- Byte pExpectedPackets[MAX_PACKETS_IN_MBIM_TESTS][MAX_PACKET_SIZE],
- int pPacketsSizes[MAX_PACKETS_IN_MBIM_TESTS], int nNumPackets, int nAggregatedPacketSize)
- {
- int nPacketNum = 0;
- int i = 0;
- int nNdpStart = 0;
- Byte pNdpIndex[2] = {0};
- Byte pNdpLen[2] = {0};
- if (0x4e != pAggregatedPacket[i] || 0x43 != pAggregatedPacket[i+1] ||
- 0x4d != pAggregatedPacket[i+2]|| 0x48 != pAggregatedPacket[i+3])
- {
- LOG_MSG_DEBUG("Error: Wrong NTH16 signature: 0x%02x 0x%02x 0x%02x "
- "0x%02x(should be 0x4e, 0x43, 0x4d, 0x48)\n",
- pAggregatedPacket[i], pAggregatedPacket[i+1],
- pAggregatedPacket[i+2], pAggregatedPacket[i+3]);
- return false;
- }
- i += 4;
- if (0x0c != pAggregatedPacket[i] || 0x00 != pAggregatedPacket[i+1])
- {
- LOG_MSG_DEBUG("Error: Wrong header length: 0x%02x 0x%02x(should be 0x0c, "
- "0x00)\n",
- pAggregatedPacket[i], pAggregatedPacket[i+1]);
- return false;
- }
- i += 4;
- if ((nAggregatedPacketSize & 0x00FF) != pAggregatedPacket[i] ||
- (nAggregatedPacketSize >> 8) != pAggregatedPacket[i+1])
- {
- LOG_MSG_DEBUG("Error: Wrong aggregated packet length: 0x%02x 0x%02x"
- "(should be 0x%02x, 0x%02x)\n",
- pAggregatedPacket[i], pAggregatedPacket[i+1],
- nAggregatedPacketSize & 0x00FF, nAggregatedPacketSize >> 8);
- return false;
- }
- i += 2;
- pNdpIndex[0] = pAggregatedPacket[i];
- pNdpIndex[1] = pAggregatedPacket[i+1];
-
- while (0x00 != pNdpIndex[0] || 0x00 != pNdpIndex[1])
- {
- i = pNdpIndex[0] + 256*pNdpIndex[1];
- nNdpStart = i;
- if (0x49 != pAggregatedPacket[i] || 0x50 != pAggregatedPacket[i + 1] ||
- 0x53 != pAggregatedPacket[i + 2] || 0x00 != pAggregatedPacket[i + 3])
- {
- LOG_MSG_DEBUG("Error: Wrong NDP16 signature: 0x%02x 0x%02x "
- "0x%02x 0x%02x(should be 0x49, 0x50, 0x53, 0x00)\n",
- pAggregatedPacket[i], pAggregatedPacket[i + 1],
- pAggregatedPacket[i + 2], pAggregatedPacket[i + 3]);
- return false;
- }
- i += 4;
- pNdpLen[0] = pAggregatedPacket[i];
- pNdpLen[1] = pAggregatedPacket[i+1];
- if (0x00 != pAggregatedPacket[nNdpStart + pNdpLen[0] + 256*pNdpLen[1] - 2] ||
- 0x00 != pAggregatedPacket[nNdpStart + pNdpLen[0] + 256*pNdpLen[1] -1])
- {
- LOG_MSG_DEBUG("Error: Wrong end of NDP: 0x%02x 0x%02x(should be 0x00,"
- " 0x00)\n",
- pAggregatedPacket[nNdpStart + pNdpLen[0] + 256*pNdpLen[1] - 2],
- pAggregatedPacket[nNdpStart + pNdpLen[0] + 256*pNdpLen[1] - 1]);
- return false;
- }
- i += 2;
- pNdpIndex[0] = pAggregatedPacket[i];
- pNdpIndex[1] = pAggregatedPacket[i+1];
- i += 2;
- while (i <= nNdpStart + pNdpLen[0] + 256*pNdpLen[1] - 2)
- {
- Byte pDatagramIndex[2] = {0};
- Byte pDatagramLen[2] = {0};
- int packetIndex = 0;
- pDatagramIndex[0] = pAggregatedPacket[i];
- pDatagramIndex[1] = pAggregatedPacket[i+1];
- i += 2;
- if (0x00 == pDatagramIndex[0] && 0x00 == pDatagramIndex[1])
- break;
- if (nPacketNum >= nNumPackets)
- {
- LOG_MSG_DEBUG("Error: wrong number of packets: %d(should be %d)\n",
- nPacketNum, nNumPackets);
- return false;
- }
- pDatagramLen[0] = pAggregatedPacket[i];
- pDatagramLen[1] = pAggregatedPacket[i+1];
- i += 2;
- packetIndex = pDatagramIndex[0] + 256*pDatagramIndex[1];
- if (pDatagramLen[0] + 256*pDatagramLen[1] != pPacketsSizes[nPacketNum])
- {
- LOG_MSG_DEBUG("Error: Wrong packet %d length: 0x%02x 0x%02x"
- "(should be %d)\n", nPacketNum, pDatagramLen[0],
- pDatagramLen[1], pPacketsSizes[nPacketNum]);
- return false;
- }
- if (0 != memcmp(pExpectedPackets[nPacketNum],
- &pAggregatedPacket[packetIndex], pPacketsSizes[nPacketNum]))
- {
- LOG_MSG_DEBUG("Error: Comparison of packet %d failed!\n",
- nPacketNum);
- return false;
- }
- nPacketNum++;
- }
- }
- return true;
- }
- void MBIMAggregationScenarios::AggregatePackets(
- Byte pAggregatedPacket[MAX_PACKET_SIZE],
- Byte pPackets[NUM_PACKETS][MAX_PACKET_SIZE],
- int pPacketsSizes[NUM_PACKETS], int nNumPackets,
- int nAggregatedPacketSize)
- {
- int i = 0;
- int pDatagramIndexes[NUM_PACKETS] = {0};
- int nNdpIndex = 0;
- int nNdpLen = 0;
-
- pAggregatedPacket[i] = 0x4e;
- pAggregatedPacket[i+1] = 0x43;
- pAggregatedPacket[i+2] = 0x4d;
- pAggregatedPacket[i+3] = 0x48;
- i += 4;
-
- pAggregatedPacket[i] = 0x0c;
- pAggregatedPacket[i+1] = 0x00;
- i += 2;
-
- pAggregatedPacket[i] = 0x00;
- pAggregatedPacket[i+1] = 0x00;
- i += 2;
-
- pAggregatedPacket[i] = nAggregatedPacketSize & 0x00FF;
- pAggregatedPacket[i+1] = nAggregatedPacketSize >> 8;
- i += 2;
-
- for (int j = 0; j < nNumPackets; j++)
- nNdpIndex += pPacketsSizes[j];
- nNdpIndex += i + 2;
- while (0 != nNdpIndex % 4)
- nNdpIndex++;
- pAggregatedPacket[i] = nNdpIndex & 0x00FF;
- pAggregatedPacket[i+1] = nNdpIndex >> 8;
- i += 2;
-
- for (int j = 0; j < nNumPackets; j++)
- {
- pDatagramIndexes[j] = i;
- for (int k = 0; k < pPacketsSizes[j]; k++)
- {
- pAggregatedPacket[i] = pPackets[j][k];
- i++;
- }
- }
- while (i < nNdpIndex)
- {
- pAggregatedPacket[i] = 0x00;
- i++;
- }
-
- pAggregatedPacket[i] = 0x49;
- pAggregatedPacket[i+1] = 0x50;
- pAggregatedPacket[i+2] = 0x53;
- pAggregatedPacket[i+3] = 0x00;
- i += 4;
-
- nNdpLen = 4*nNumPackets + 8 + 2;
- while (nNdpLen % 4 != 0)
- nNdpLen += 2;
- pAggregatedPacket[i] = nNdpLen & 0x00FF;
- pAggregatedPacket[i+1] = nNdpLen >> 8;
- i += 2;
-
- pAggregatedPacket[i] = 0x00;
- pAggregatedPacket[i+1] = 0x00;
- i += 2;
- for (int j = 0; j < nNumPackets; j++)
- {
-
- pAggregatedPacket[i] = pDatagramIndexes[j] & 0x00FF;
- pAggregatedPacket[i+1] = pDatagramIndexes[j] >> 8;
- i += 2;
-
- pAggregatedPacket[i] = pPacketsSizes[j] & 0x00FF;
- pAggregatedPacket[i+1] = pPacketsSizes[j] >> 8;
- i += 2;
- }
-
- while (i < nAggregatedPacketSize)
- {
- pAggregatedPacket[i] = 0x00;
- i++;
- }
- }
- void MBIMAggregationScenarios::AggregatePacketsWithStreamId(
- Byte pAggregatedPacket[MAX_PACKET_SIZE],
- Byte pPackets[NUM_PACKETS][MAX_PACKET_SIZE],
- int pPacketsSizes[NUM_PACKETS], int nNumPackets, int nAggregatedPacketSize,
- Byte pPacketsStreamId[NUM_PACKETS])
- {
- int i = 0;
- int n = 0;
- int pDatagramIndexes[NUM_PACKETS] = {0};
- int nNdpIndex[NUM_PACKETS] = {0};
- int nNdpLen = 0;
- Byte currStreamId = pPacketsStreamId[0];
- int nNdpFirstPacket[NUM_PACKETS] = {0};
- int nNdpAfterLastPacket[NUM_PACKETS] = {0};
- int nNumNDPs = 0;
- for (n = 0; n < nNumPackets; n++)
- {
- if (currStreamId != pPacketsStreamId[n])
- {
- nNdpAfterLastPacket[nNumNDPs] = n;
- nNumNDPs++;
- nNdpFirstPacket[nNumNDPs] = n;
- currStreamId = pPacketsStreamId[n];
- }
- }
- nNdpAfterLastPacket[nNumNDPs] = n;
- nNumNDPs++;
-
- nNdpIndex[0] += 12;
- for (int j = 0; j < nNumNDPs; j++)
- {
- for (n = nNdpFirstPacket[j]; n < nNdpAfterLastPacket[j]; n++)
- nNdpIndex[j] += pPacketsSizes[n];
- while (0 != nNdpIndex[j] % 4)
- nNdpIndex[j]++;
- if (j < nNumNDPs - 1)
- nNdpIndex[j+1] += nNdpIndex[j] + 12 + 4*(nNdpAfterLastPacket[j] -
- nNdpFirstPacket[j]);
- }
-
-
- pAggregatedPacket[i] = 0x4e;
- pAggregatedPacket[i+1] = 0x43;
- pAggregatedPacket[i+2] = 0x4d;
- pAggregatedPacket[i+3] = 0x48;
- i += 4;
-
- pAggregatedPacket[i] = 0x0c;
- pAggregatedPacket[i+1] = 0x00;
- i += 2;
-
- pAggregatedPacket[i] = 0x00;
- pAggregatedPacket[i+1] = 0x00;
- i += 2;
-
- pAggregatedPacket[i] = nAggregatedPacketSize & 0x00FF;
- pAggregatedPacket[i+1] = nAggregatedPacketSize >> 8;;
- i += 2;
-
- pAggregatedPacket[i] = nNdpIndex[0] & 0x00FF;
- pAggregatedPacket[i+1] = nNdpIndex[0] >> 8;
- i += 2;
- for (n = 0; n < nNumNDPs; n++)
- {
-
- for (int j = nNdpFirstPacket[n]; j < nNdpAfterLastPacket[n]; j++)
- {
- pDatagramIndexes[j] = i;
- for (int k = 0; k < pPacketsSizes[j]; k++)
- {
- pAggregatedPacket[i] = pPackets[j][k];
- i++;
- }
- }
- while (i < nNdpIndex[n])
- {
- pAggregatedPacket[i] = 0x00;
- i++;
- }
-
- pAggregatedPacket[i] = 0x49;
- pAggregatedPacket[i+1] = 0x50;
- pAggregatedPacket[i+2] = 0x53;
- pAggregatedPacket[i+3] = pPacketsStreamId[nNdpFirstPacket[n]];
- i += 4;
-
- nNdpLen = 4*(nNdpAfterLastPacket[n] - nNdpFirstPacket[n]) + 8 + 2;
- while (nNdpLen % 4 != 0)
- nNdpLen += 2;
- pAggregatedPacket[i] = nNdpLen & 0x00FF;
- pAggregatedPacket[i+1] = nNdpLen >> 8;
- i += 2;
-
- pAggregatedPacket[i] = nNdpIndex[n+1] & 0x00FF;
- pAggregatedPacket[i+1] = nNdpIndex[n+1] >> 8;
- i += 2;
- for (int j = nNdpFirstPacket[n]; j < nNdpAfterLastPacket[n]; j++)
- {
-
- pAggregatedPacket[i] = pDatagramIndexes[j] & 0x00FF;
- pAggregatedPacket[i+1] = pDatagramIndexes[j] >> 8;
- i += 2;
-
- pAggregatedPacket[i] = pPacketsSizes[j] & 0x00FF;
- pAggregatedPacket[i+1] = pPacketsSizes[j] >> 8;
- i += 2;
- }
-
- while (i < nNdpIndex[n] + nNdpLen)
- {
- pAggregatedPacket[i] = 0x00;
- i++;
- }
- }
- }
- bool MBIMAggregationScenarios::DeaggragateAndCompareOnePacket(
- Byte pAggregatedPacket[MAX_PACKET_SIZE],
- Byte pExpectedPacket[MAX_PACKET_SIZE], int nPacketsSize,
- int nAggregatedPacketSize)
- {
- int nPacketNum = 0;
- int i = 0;
- int nNdpStart = 0;
- Byte pNdpIndex[2] = {0};
- Byte pNdpLen[2] = {0};
- if (0x4e != pAggregatedPacket[i] || 0x43 != pAggregatedPacket[i+1] ||
- 0x4d != pAggregatedPacket[i+2]|| 0x48 != pAggregatedPacket[i+3])
- {
- LOG_MSG_DEBUG("Error: Wrong NTH16 signature: 0x%02x 0x%02x 0x%02x "
- "0x%02x(should be 0x4e, 0x43, 0x4d, 0x48)\n",
- pAggregatedPacket[i], pAggregatedPacket[i+1],
- pAggregatedPacket[i+2], pAggregatedPacket[i+3]);
- return false;
- }
- i += 4;
- if (0x0c != pAggregatedPacket[i] || 0x00 != pAggregatedPacket[i+1])
- {
- LOG_MSG_DEBUG("Error: Wrong header length: 0x%02x 0x%02x(should be 0x0c,"
- " 0x00)\n", pAggregatedPacket[i], pAggregatedPacket[i+1]);
- return false;
- }
- i += 4;
- if ((nAggregatedPacketSize & 0x00FF) != pAggregatedPacket[i] ||
- (nAggregatedPacketSize >> 8) != pAggregatedPacket[i+1])
- {
- LOG_MSG_DEBUG("Error: Wrong aggregated packet length: 0x%02x 0x%02x"
- "(should be 0x%02x, 0x%02x)\n",
- pAggregatedPacket[i], pAggregatedPacket[i+1],
- nAggregatedPacketSize & 0x00FF, nAggregatedPacketSize >> 8);
- return false;
- }
- i += 2;
- pNdpIndex[0] = pAggregatedPacket[i];
- pNdpIndex[1] = pAggregatedPacket[i+1];
-
- while (0x00 != pNdpIndex[0] || 0x00 != pNdpIndex[1])
- {
- i = pNdpIndex[0] + 256*pNdpIndex[1];
- nNdpStart = i;
- if (0x49 != pAggregatedPacket[i] || 0x50 != pAggregatedPacket[i+1] ||
- 0x53 != pAggregatedPacket[i+2] || 0x00 != pAggregatedPacket[i+3])
- {
- LOG_MSG_DEBUG("Error: Wrong NDP16 signature: 0x%02x 0x%02x "
- "0x%02x 0x%02x(should be 0x49, 0x50, 0x53, 0x00)\n",
- pAggregatedPacket[i], pAggregatedPacket[i+1],
- pAggregatedPacket[i+2], pAggregatedPacket[i+3]);
- return false;
- }
- i += 4;
- pNdpLen[0] = pAggregatedPacket[i];
- pNdpLen[1] = pAggregatedPacket[i+1];
- if (0x00 != pAggregatedPacket[nNdpStart + pNdpLen[0] + 256*pNdpLen[1] - 2] ||
- 0x00 != pAggregatedPacket[nNdpStart + pNdpLen[0] + 256*pNdpLen[1] -1])
- {
- LOG_MSG_DEBUG("Error: Wrong end of NDP: 0x%02x 0x%02x(should be "
- "0x00, 0x00)\n",
- pAggregatedPacket[nNdpStart + pNdpLen[0] + 256*pNdpLen[1] - 2],
- pAggregatedPacket[nNdpStart + pNdpLen[0] + 256*pNdpLen[1] - 1]);
- return false;
- }
- i += 2;
- pNdpIndex[0] = pAggregatedPacket[i];
- pNdpIndex[1] = pAggregatedPacket[i+1];
- i += 2;
- while (i <= nNdpStart + pNdpLen[0] + 256*pNdpLen[1] - 2)
- {
- Byte pDatagramIndex[2] = {0};
- Byte pDatagramLen[2] = {0};
- int packetIndex = 0;
- pDatagramIndex[0] = pAggregatedPacket[i];
- pDatagramIndex[1] = pAggregatedPacket[i+1];
- i += 2;
- if (0x00 == pDatagramIndex[0] && 0x00 == pDatagramIndex[1])
- break;
- if (nPacketNum > 1)
- {
- LOG_MSG_DEBUG("Error: wrong number of packets: %d(should be %d)\n",
- nPacketNum, 1);
- return false;
- }
- pDatagramLen[0] = pAggregatedPacket[i];
- pDatagramLen[1] = pAggregatedPacket[i+1];
- i += 2;
- packetIndex = pDatagramIndex[0] + 256*pDatagramIndex[1];
- if (pDatagramLen[0] + 256*pDatagramLen[1] != nPacketsSize)
- {
- LOG_MSG_DEBUG("Error: Wrong packet %d length: 0x%02x 0x%02x"
- "(should be %d)\n", nPacketNum, pDatagramLen[0],
- pDatagramLen[1], nPacketsSize);
- return false;
- }
- if (0 != memcmp(pExpectedPacket, &pAggregatedPacket[packetIndex],
- nPacketsSize))
- {
- LOG_MSG_DEBUG("Error: Comparison of packet %d failed!\n",
- nPacketNum);
- return false;
- }
- nPacketNum++;
- }
- }
- return true;
- }
- bool MBIMAggregationScenarios::DeaggragateAndComparePacketsWithStreamId(
- Byte pAggregatedPacket[MAX_PACKET_SIZE],
- Byte pExpectedPackets[][MAX_PACKET_SIZE], int pPacketsSizes[],
- int nNumPackets, int nAggregatedPacketSize,
- Byte pPacketsStreamId[NUM_PACKETS])
- {
- int nPacketNum = 0;
- int i = 0;
- int nNdpStart = 0;
- Byte pNdpIndex[2] = {0};
- Byte pNdpLen[2] = {0};
- if (0x4e != pAggregatedPacket[i] || 0x43 != pAggregatedPacket[i+1] ||
- 0x4d != pAggregatedPacket[i+2]|| 0x48 != pAggregatedPacket[i+3])
- {
- LOG_MSG_DEBUG("Error: Wrong NTH16 signature: 0x%02x 0x%02x 0x%02x "
- "0x%02x(should be 0x4e, 0x43, 0x4d, 0x48)\n",
- pAggregatedPacket[i], pAggregatedPacket[i+1],
- pAggregatedPacket[i+2], pAggregatedPacket[i+3]);
- return false;
- }
- i += 4;
- if (0x0c != pAggregatedPacket[i] || 0x00 != pAggregatedPacket[i+1])
- {
- LOG_MSG_DEBUG("Error: Wrong header length: 0x%02x 0x%02x(should be "
- "0x0c, 0x00)\n",pAggregatedPacket[i], pAggregatedPacket[i+1]);
- return false;
- }
- i += 4;
- if ((nAggregatedPacketSize & 0x00FF) != pAggregatedPacket[i] ||
- (nAggregatedPacketSize >> 8) != pAggregatedPacket[i+1])
- {
- LOG_MSG_DEBUG("Error: Wrong aggregated packet length: 0x%02x 0x%02x"
- "(should be 0x%02x, 0x%02x)\n", pAggregatedPacket[i],
- pAggregatedPacket[i+1], nAggregatedPacketSize & 0x00FF,
- nAggregatedPacketSize >> 8);
- return false;
- }
- i += 2;
- pNdpIndex[0] = pAggregatedPacket[i];
- pNdpIndex[1] = pAggregatedPacket[i+1];
-
- while (0x00 != pNdpIndex[0] || 0x00 != pNdpIndex[1])
- {
- i = pNdpIndex[0] + 256*pNdpIndex[1];
- nNdpStart = i;
- if (0x49 != pAggregatedPacket[i] || 0x50 != pAggregatedPacket[i+1] ||
- 0x53 != pAggregatedPacket[i+2])
- {
- LOG_MSG_DEBUG("Error: Wrong NDP16 signature: 0x%02x 0x%02x 0x%02x"
- "(should be 0x49, 0x50, 0x53)\n", pAggregatedPacket[i],
- pAggregatedPacket[i+1], pAggregatedPacket[i+2]);
- return false;
- }
- if (pPacketsStreamId[nPacketNum] != pAggregatedPacket[i+3])
- {
- LOG_MSG_DEBUG("Error: Wrong NDP stream id: 0x%02x(should be 0x%02x)\n",
- pAggregatedPacket[i+3], pPacketsStreamId[nPacketNum]);
- return false;
- }
- i += 4;
- pNdpLen[0] = pAggregatedPacket[i];
- pNdpLen[1] = pAggregatedPacket[i+1];
- if (0x00 != pAggregatedPacket[nNdpStart + pNdpLen[0] + 256*pNdpLen[1] - 2] ||
- 0x00 != pAggregatedPacket[nNdpStart + pNdpLen[0] + 256*pNdpLen[1] -1])
- {
- LOG_MSG_DEBUG("Error: Wrong end of NDP: 0x%02x 0x%02x(should be 0x00, "
- "0x00)\n",
- pAggregatedPacket[nNdpStart + pNdpLen[0] + 256*pNdpLen[1] - 2],
- pAggregatedPacket[nNdpStart + pNdpLen[0] + 256*pNdpLen[1] - 1]);
- return false;
- }
- i += 2;
- pNdpIndex[0] = pAggregatedPacket[i];
- pNdpIndex[1] = pAggregatedPacket[i+1];
- i += 2;
- while (i <= nNdpStart + pNdpLen[0] + 256*pNdpLen[1] - 2)
- {
- Byte pDatagramIndex[2] = {0};
- Byte pDatagramLen[2] = {0};
- int packetIndex = 0;
- pDatagramIndex[0] = pAggregatedPacket[i];
- pDatagramIndex[1] = pAggregatedPacket[i+1];
- i += 2;
- if (0x00 == pDatagramIndex[0] && 0x00 == pDatagramIndex[1])
- break;
- if (nPacketNum >= nNumPackets)
- {
- LOG_MSG_DEBUG("Error: wrong number of packets: %d(should be %d)\n",
- nPacketNum, nNumPackets);
- return false;
- }
- pDatagramLen[0] = pAggregatedPacket[i];
- pDatagramLen[1] = pAggregatedPacket[i+1];
- i += 2;
- packetIndex = pDatagramIndex[0] + 256*pDatagramIndex[1];
- if (pDatagramLen[0] + 256*pDatagramLen[1] != (int)pPacketsSizes[nPacketNum])
- {
- LOG_MSG_DEBUG("Error: Wrong packet %d length: 0x%02x 0x%02x"
- "(should be %d)\n", nPacketNum, pDatagramLen[0],
- pDatagramLen[1], pPacketsSizes[nPacketNum]);
- return false;
- }
- if (0 != memcmp(pExpectedPackets[nPacketNum],
- &pAggregatedPacket[packetIndex], pPacketsSizes[nPacketNum]))
- {
- LOG_MSG_DEBUG("Error: Comparison of packet %d failed!\n",
- nPacketNum);
- return false;
- }
- nPacketNum++;
- }
- }
- return true;
- }
- class MBIMAggregationTest: public MBIMAggregationTestFixtureConf11 {
- public:
-
- MBIMAggregationTest(bool generic_agg) :
- MBIMAggregationTestFixtureConf11(generic_agg)
- {
- if (generic_agg)
- m_name = "GenMBIMAggregationTest";
- else
- m_name = "MBIMAggregationTest";
- m_description = "MBIM Aggregation test - sends 5 packets and receives 1 "
- "aggregated packet";
- }
-
- virtual bool AddRules()
- {
- return AddRules1HeaderAggregation();
- }
-
- bool TestLogic()
- {
- return MBIMAggregationScenarios::MBIMAggregationTest(&m_UsbToIpaPipe,
- &m_IpaToUsbPipeAgg, m_eIP);
- }
-
- };
- class MBIMDeaggregationTest: public MBIMAggregationTestFixtureConf11 {
- public:
-
- MBIMDeaggregationTest(bool generic_agg) :
- MBIMAggregationTestFixtureConf11(generic_agg)
- {
- if (generic_agg)
- m_name = "GenMBIMDeaggregationTest";
- else
- m_name = "MBIMDeaggregationTest";
- m_description = "MBIM Deaggregation test - sends an aggregated packet made from"
- "5 packets and receives 5 packets";
- }
-
- virtual bool AddRules()
- {
- return AddRulesDeaggregation();
- }
-
- bool TestLogic()
- {
- return MBIMAggregationScenarios::MBIMDeaggregationTest(&m_UsbToIpaPipeDeagg, &m_IpaToUsbPipe, m_eIP);
- }
-
- };
- class MBIMDeaggregationOnePacketTest: public MBIMAggregationTestFixtureConf11 {
- public:
-
- MBIMDeaggregationOnePacketTest(bool generic_agg) :
- MBIMAggregationTestFixtureConf11(generic_agg)
- {
- if (generic_agg)
- m_name = "GenMBIMDeaggregationOnePacketTest";
- else
- m_name = "MBIMDeaggregationOnePacketTest";
- m_description = "MBIM Deaggregation one packet test - sends an aggregated packet made"
- "of 1 packet and receives 1 packet";
- }
-
- virtual bool AddRules()
- {
- return AddRulesDeaggregation();
- }
-
- bool TestLogic()
- {
- return MBIMAggregationScenarios::MBIMDeaggregationOnePacketTest(&m_UsbToIpaPipeDeagg, &m_IpaToUsbPipe, m_eIP);
- }
-
- };
- class MBIMDeaggregationAndAggregationTest: public MBIMAggregationTestFixtureConf11 {
- public:
-
- MBIMDeaggregationAndAggregationTest(bool generic_agg)
- : MBIMAggregationTestFixtureConf11(generic_agg)
- {
- if (generic_agg)
- m_name = "GenMBIMDeaggregationAndAggregationTest";
- else
- m_name = "MBIMDeaggregationAndAggregationTest";
- m_description = "MBIM Deaggregation and Aggregation test - sends an aggregated "
- "packet made from 5 packets and receives the same aggregated packet";
- }
-
- virtual bool AddRules()
- {
- return AddRules1HeaderAggregation();
- }
-
- bool TestLogic()
- {
- return MBIMAggregationScenarios::MBIMDeaggregationAndAggregationTest(
- &m_UsbToIpaPipeDeagg, &m_IpaToUsbPipeAgg, m_eIP);
- }
-
- };
- class MBIMMultipleDeaggregationAndAggregationTest:
- public MBIMAggregationTestFixtureConf11 {
- public:
-
- MBIMMultipleDeaggregationAndAggregationTest(bool generic_agg) :
- MBIMAggregationTestFixtureConf11(generic_agg)
- {
- if (generic_agg)
- m_name = "GenMBIMMultipleDeaggregationAndAggregationTest";
- else
- m_name = "MBIMMultipleDeaggregationAndAggregationTest";
- m_description = "MBIM Multiple Deaggregation and Aggregation test - sends 5 aggregated "
- "packets each one made of 1 packet and receives an aggregated packet made of the"
- "5 packets";
- }
-
- virtual bool AddRules()
- {
- return AddRules1HeaderAggregation();
- }
-
- bool TestLogic()
- {
- return MBIMAggregationScenarios::MBIMMultipleDeaggregationAndAggregationTest(
- &m_UsbToIpaPipeDeagg, &m_IpaToUsbPipeAgg, m_eIP);
- }
-
- };
- class MBIMAggregationLoopTest: public MBIMAggregationTestFixtureConf11 {
- public:
-
- MBIMAggregationLoopTest(bool generic_agg)
- : MBIMAggregationTestFixtureConf11(generic_agg)
- {
- if (generic_agg)
- m_name = "GenMBIMggregationLoopTest";
- else
- m_name = "MBIMggregationLoopTest";
- m_description = "MBIM Aggregation Loop test - sends 5 packets and expects to"
- "receives 1 aggregated packet a few times";
- }
-
- virtual bool AddRules()
- {
- return AddRules1HeaderAggregation();
- }
-
- bool TestLogic()
- {
- return MBIMAggregationScenarios::MBIMAggregationLoopTest(
- &m_UsbToIpaPipe, &m_IpaToUsbPipeAgg, m_eIP);
- }
-
- };
- class MBIMAggregationTimeLimitTest: public MBIMAggregationTestFixtureConf11 {
- public:
-
- MBIMAggregationTimeLimitTest(bool generic_agg)
- : MBIMAggregationTestFixtureConf11(generic_agg)
- {
- if (generic_agg)
- m_name = "GenMBIMAggregationTimeLimitTest";
- else
- m_name = "MBIMAggregationTimeLimitTest";
- m_description = "MBIM Aggregation time limit test - sends 1 small packet "
- "smaller than the byte limit and receives 1 aggregated packet";
- }
-
- virtual bool AddRules()
- {
- return AddRules1HeaderAggregationTime();
- }
-
- bool TestLogic()
- {
- return MBIMAggregationScenarios::MBIMAggregationTimeLimitTest(
- &m_UsbToIpaPipe, &m_IpaToUsbPipeAggTime, m_eIP);
- }
-
- };
- class MBIMAggregationByteLimitTest: public MBIMAggregationTestFixtureConf11 {
- public:
-
- MBIMAggregationByteLimitTest(bool generic_agg)
- : MBIMAggregationTestFixtureConf11(generic_agg)
- {
- if (generic_agg)
- m_name = "GenMBIMAggregationByteLimitTest";
- else
- m_name = "MBIMAggregationByteLimitTest";
- m_description = "MBIM Aggregation byte limit test - sends 2 packets that together "
- "are larger than the byte limit ";
- }
-
- virtual bool AddRules()
- {
- return AddRules1HeaderAggregation();
- }
-
- bool TestLogic()
- {
- return MBIMAggregationScenarios::MBIMAggregationByteLimitTest(
- &m_UsbToIpaPipe, &m_IpaToUsbPipeAgg, m_eIP);
- }
-
- };
- class MBIMAggregationByteLimitTestFC: public MBIMAggregationTestFixtureConf11 {
- public:
-
- MBIMAggregationByteLimitTestFC(bool generic_agg)
- : MBIMAggregationTestFixtureConf11(generic_agg) {
- if (generic_agg)
- m_name = "GenMBIMAggregationByteLimitTestFC";
- else
- m_name = "MBIMAggregationByteLimitTestFC";
- m_description = "MBIMAggregationByteLimitTestFC - Send 4 IP packet with FC"
- "and expect 4 aggregated MBIM packets.";
- }
-
- virtual bool AddRules() {
- return AddRules1HeaderAggregation(true);
- }
-
- bool TestLogic()
- {
- return MBIMAggregationScenarios::MBIMAggregationByteLimitTestFC(
- &m_UsbToIpaPipe, &m_IpaToUsbPipeAgg, m_eIP);
- }
- };
- class MBIMAggregationDualDpTestFC : public MBIMAggregationTestFixtureConf11
- {
- public:
-
- MBIMAggregationDualDpTestFC(bool generic_agg)
- : MBIMAggregationTestFixtureConf11(generic_agg)
- {
- if (generic_agg) m_name = "GenMBIMAggregationDualDpTestFC";
- else m_name = "MBIMAggregationDualDpTestFC";
- m_description = "MBIMAggregationDualDpTestFC - Send IP packets "
- "on two datapathes: one with FC and one without. "
- "Expect 2 aggregated MBIM packets on pipe with FC. "
- "Expect one aggregated MBIM packet on pipe without FC. ";
- }
-
- virtual bool AddRules()
- {
- return AddRulesAggDualFC(&m_UsbToIpaPipe,
- &m_IpaToUsbPipeAggTime,
- &m_IpaToUsbPipeAgg);
- }
-
- bool TestLogic()
- {
- return MBIMAggregationScenarios::MBIMAggregationDualDpTestFC(
- &m_UsbToIpaPipe, &m_IpaToUsbPipeAggTime, &m_IpaToUsbPipeAgg, m_eIP);
- }
- };
- class MBIMAggregationDualDpTestFcRoutingBased : public MBIMAggregationTestFixtureConf11
- {
- public:
-
- MBIMAggregationDualDpTestFcRoutingBased(bool generic_agg)
- : MBIMAggregationTestFixtureConf11(generic_agg)
- {
- if (generic_agg) m_name = "GenMBIMAggregationDualDpTestFcRoutingBased";
- else m_name = "MBIMAggregationDualDpTestFcRoutingBased";
- m_description = "MBIMAggregationDualDpTestFcRoutingBased - Send IP packets "
- "on two datapathes: one with RT based FC and one without. "
- "Expect 2 aggregated MBIM packets on pipe with RT based FC. "
- "Expect one aggregated MBIM packet on pipe without RT based FC. ";
- }
-
- virtual bool AddRules()
- {
- return AddRulesAggDualFcRoutingBased(&m_UsbToIpaPipe,
- &m_IpaToUsbPipeAggTime,
- &m_IpaToUsbPipeAgg);
- }
-
- bool TestLogic()
- {
- return MBIMAggregationScenarios::MBIMAggregationDualDpTestFC(
- &m_UsbToIpaPipe, &m_IpaToUsbPipeAggTime, &m_IpaToUsbPipeAgg, m_eIP);
- }
- };
- class MBIMDeaggregationMultipleNDPTest: public MBIMAggregationTestFixtureConf11 {
- public:
-
- MBIMDeaggregationMultipleNDPTest(bool generic_agg)
- : MBIMAggregationTestFixtureConf11(generic_agg)
- {
- if (generic_agg)
- m_name = "GenMBIMDeaggregationMultipleNDPTest";
- else
- m_name = "MBIMDeaggregationMultipleNDPTest";
- m_description = "MBIM Deaggregation multiple NDP test - sends an aggregated"
- "packet made from 5 packets and 2 NDPs and receives 5 packets";
- }
-
- virtual bool AddRules()
- {
- return AddRulesDeaggregation();
- }
-
- bool TestLogic()
- {
- return MBIMAggregationScenarios::MBIMDeaggregationMultipleNDPTest(
- &m_UsbToIpaPipeDeagg, &m_IpaToUsbPipe, m_eIP);
- }
-
- };
- class MBIMAggregation2PipesTest: public MBIMAggregationTestFixtureConf11 {
- public:
-
- MBIMAggregation2PipesTest(bool generic_agg)
- : MBIMAggregationTestFixtureConf11(generic_agg)
- {
- if (generic_agg)
- m_name = "GenMBIMAggregation2PipesTest";
- else
- m_name = "MBIMAggregation2PipesTest";
- m_description = "MBIM Aggregation 2 pipes test - sends 3 packets from one pipe"
- "and an aggregated packet made of 2 packets from another pipe and "
- "receives 1 aggregated packet made of all 5 packets";
- }
-
- virtual bool AddRules()
- {
- return AddRules1HeaderAggregation();
- }
-
- bool TestLogic()
- {
- return MBIMAggregationScenarios::MBIMAggregation2PipesTest(
- &m_UsbToIpaPipeDeagg, &m_UsbToIpaPipe, &m_IpaToUsbPipeAgg, m_eIP);
- }
-
- };
- class MBIMAggregationTimeLimitLoopTest: public MBIMAggregationTestFixtureConf11 {
- public:
-
- MBIMAggregationTimeLimitLoopTest(bool generic_agg)
- : MBIMAggregationTestFixtureConf11(generic_agg)
- {
- if (generic_agg)
- m_name = "GenMBIMAggregationTimeLimitLoopTest";
- else
- m_name = "MBIMAggregationTimeLimitLoopTest";
- m_description = "MBIM Aggregation time limit loop test - sends 5 small packet "
- "smaller than the byte limit and receives 5 aggregated packet";
- }
-
- virtual bool AddRules()
- {
- return AddRules1HeaderAggregationTime();
- }
-
- bool TestLogic()
- {
- return MBIMAggregationScenarios::MBIMAggregationTimeLimitLoopTest(
- &m_UsbToIpaPipe, &m_IpaToUsbPipeAggTime, m_eIP);
- }
-
- };
- class MBIMAggregationMultiplePacketsTest: public MBIMAggregationTestFixtureConf11 {
- public:
-
- MBIMAggregationMultiplePacketsTest(bool generic_agg)
- : MBIMAggregationTestFixtureConf11(generic_agg)
- {
- if (generic_agg)
- m_name = "GenMBIMAggregationMultiplePacketsTest";
- else
- m_name = "MBIMAggregationMultiplePacketsTest";
- m_description = "MBIM Aggregation multiple packets test - sends 9 packets "
- "with same stream ID and receives 1 aggregated packet with 2 NDPs";
- this->m_runInRegression = false;
- }
-
- virtual bool AddRules()
- {
- return AddRules1HeaderAggregation();
- }
-
- bool TestLogic()
- {
- return MBIMAggregationScenarios::MBIMAggregationMultiplePacketsTest(
- &m_UsbToIpaPipe, &m_IpaToUsbPipeAgg, m_eIP);
- }
-
- };
- class MBIMAggregation0LimitsTest: public MBIMAggregationTestFixtureConf11 {
- public:
-
- MBIMAggregation0LimitsTest(bool generic_agg)
- : MBIMAggregationTestFixtureConf11(generic_agg)
- {
- if (generic_agg)
- m_name = "GenMBIMAggregation0LimitsTest";
- else
- m_name = "MBIMAggregation0LimitsTest";
- m_description = "MBIM Aggregation 0 limits test - sends 5 packets and expects"
- "to get each packet back aggregated (both size and time limits are 0)";
- }
-
- virtual bool AddRules()
- {
- return AddRules1HeaderAggregation0Limits();
- }
-
- bool TestLogic()
- {
- return MBIMAggregationScenarios::MBIMAggregation0LimitsTest(
- &m_UsbToIpaPipe, &m_IpaToUsbPipeAgg0Limits, m_eIP);
- }
-
- };
- class MBIMAggregationDifferentStreamIdsTest:
- public MBIMAggregationTestFixtureConf11 {
- public:
-
- MBIMAggregationDifferentStreamIdsTest(bool generic_agg)
- : MBIMAggregationTestFixtureConf11(generic_agg)
- {
- if (generic_agg)
- m_name = "GenMBIMAggregationDifferentStreamIdsTest";
- else
- m_name = "MBIMAggregationDifferentStreamIdsTest";
- m_description = "MBIM Aggregation different stream IDs test - sends 5 packets"
- "with different stream IDs and receives 1 aggregated packet made of 5"
- "NDPs";
- }
-
- virtual bool AddRules()
- {
- m_eIP = IPA_IP_v4;
- const char aBypass[NUM_PACKETS][20] = {{"Bypass1"}, {"Bypass2"}, {"Bypass3"},
- {"Bypass4"}, {"Bypass5"}};
- uint32_t nTableHdl[NUM_PACKETS];
- bool bRetVal = true;
- IPAFilteringTable cFilterTable0;
- struct ipa_flt_rule_add sFilterRuleEntry;
- struct ipa_ioc_get_hdr sGetHeader[NUM_PACKETS];
- uint8_t aHeadertoAdd[NUM_PACKETS][4];
- int hdrSize;
- for (int i = 0; i < NUM_PACKETS; i++) {
- if (mGenericAgg) {
- hdrSize = 4;
- aHeadertoAdd[i][0] = 0x49;
- aHeadertoAdd[i][1] = 0x50;
- aHeadertoAdd[i][2] = 0x53;
- aHeadertoAdd[i][3] = (uint8_t)i;
- } else {
- hdrSize = 1;
- aHeadertoAdd[i][0] = (uint8_t)i;
- }
- }
- LOG_MSG_STACK("Entering Function");
- memset(&sFilterRuleEntry, 0, sizeof(sFilterRuleEntry));
- for (int i = 0; i < NUM_PACKETS; i++)
- memset(&sGetHeader[i], 0, sizeof(sGetHeader[i]));
-
-
- struct ipa_ioc_add_hdr * pHeaderDescriptor = NULL;
- pHeaderDescriptor = (struct ipa_ioc_add_hdr *) calloc(1,
- sizeof(struct ipa_ioc_add_hdr)
- + NUM_PACKETS * sizeof(struct ipa_hdr_add));
- if (!pHeaderDescriptor)
- {
- LOG_MSG_ERROR("calloc failed to allocate pHeaderDescriptor");
- bRetVal = false;
- goto bail;
- }
- pHeaderDescriptor->commit = true;
- pHeaderDescriptor->num_hdrs = NUM_PACKETS;
-
- strlcpy(pHeaderDescriptor->hdr[0].name, "StreamId0", sizeof(pHeaderDescriptor->hdr[0].name));
- memcpy(pHeaderDescriptor->hdr[0].hdr, (void*)&aHeadertoAdd[0],
- hdrSize);
- pHeaderDescriptor->hdr[0].hdr_len = hdrSize;
- pHeaderDescriptor->hdr[0].hdr_hdl = -1;
- pHeaderDescriptor->hdr[0].is_partial = false;
- pHeaderDescriptor->hdr[0].status = -1;
-
- strlcpy(pHeaderDescriptor->hdr[1].name, "StreamId1", sizeof(pHeaderDescriptor->hdr[1].name));
- memcpy(pHeaderDescriptor->hdr[1].hdr, (void*)&aHeadertoAdd[1],
- hdrSize);
- pHeaderDescriptor->hdr[1].hdr_len = hdrSize;
- pHeaderDescriptor->hdr[1].hdr_hdl = -1;
- pHeaderDescriptor->hdr[1].is_partial = false;
- pHeaderDescriptor->hdr[1].status = -1;
-
- strlcpy(pHeaderDescriptor->hdr[2].name, "StreamId2", sizeof(pHeaderDescriptor->hdr[2].name));
- memcpy(pHeaderDescriptor->hdr[2].hdr, (void*)&aHeadertoAdd[2],
- hdrSize);
- pHeaderDescriptor->hdr[2].hdr_len = hdrSize;
- pHeaderDescriptor->hdr[2].hdr_hdl = -1;
- pHeaderDescriptor->hdr[2].is_partial = false;
- pHeaderDescriptor->hdr[2].status = -1;
-
- strlcpy(pHeaderDescriptor->hdr[3].name, "StreamId3", sizeof(pHeaderDescriptor->hdr[3].name));
- memcpy(pHeaderDescriptor->hdr[3].hdr, (void*)&aHeadertoAdd[3],
- hdrSize);
- pHeaderDescriptor->hdr[3].hdr_len = hdrSize;
- pHeaderDescriptor->hdr[3].hdr_hdl = -1;
- pHeaderDescriptor->hdr[3].is_partial = false;
- pHeaderDescriptor->hdr[3].status = -1;
-
- strlcpy(pHeaderDescriptor->hdr[4].name, "StreamId4", sizeof(pHeaderDescriptor->hdr[4].name));
- memcpy(pHeaderDescriptor->hdr[4].hdr, (void*)&aHeadertoAdd[4],
- hdrSize);
- pHeaderDescriptor->hdr[4].hdr_len = hdrSize;
- pHeaderDescriptor->hdr[4].hdr_hdl = -1;
- pHeaderDescriptor->hdr[4].is_partial = false;
- pHeaderDescriptor->hdr[4].status = -1;
- for (int i = 0; i < NUM_PACKETS; i++)
- strlcpy(sGetHeader[i].name, pHeaderDescriptor->hdr[i].name, sizeof(sGetHeader[i].name));
- if (!m_HeaderInsertion.AddHeader(pHeaderDescriptor))
- {
- LOG_MSG_ERROR("m_HeaderInsertion.AddHeader(pHeaderDescriptor) Failed.");
- bRetVal = false;
- goto bail;
- }
- for (int i = 0; i < NUM_PACKETS; i++)
- {
- if (!m_HeaderInsertion.GetHeaderHandle(&sGetHeader[i]))
- {
- LOG_MSG_ERROR(" Failed");
- bRetVal = false;
- goto bail;
- }
- LOG_MSG_DEBUG("Received Header %d Handle = 0x%x", i, sGetHeader[i].hdl);
- }
- for (int i = 0; i < NUM_PACKETS; i++)
- {
- if (!CreateBypassRoutingTable(&m_Routing, m_eIP, aBypass[i],
- IPA_CLIENT_TEST2_CONS, sGetHeader[i].hdl,&nTableHdl[i]))
- {
- LOG_MSG_ERROR("CreateBypassRoutingTable Failed\n");
- bRetVal = false;
- goto bail;
- }
- }
- LOG_MSG_INFO("Creation of 5 bypass routing tables completed successfully");
-
- cFilterTable0.Init(m_eIP,IPA_CLIENT_TEST_PROD, false, NUM_PACKETS);
- LOG_MSG_INFO("Creation of filtering table completed successfully");
-
- cFilterTable0.GeneratePresetRule(1,sFilterRuleEntry);
- sFilterRuleEntry.at_rear = true;
- sFilterRuleEntry.flt_rule_hdl=-1;
- sFilterRuleEntry.status = -1;
- sFilterRuleEntry.rule.action=IPA_PASS_TO_ROUTING;
- sFilterRuleEntry.rule.rt_tbl_hdl=nTableHdl[0];
- sFilterRuleEntry.rule.attrib.attrib_mask = IPA_FLT_DST_ADDR;
- sFilterRuleEntry.rule.attrib.u.v4.dst_addr_mask = 0xFF0000FF;
- sFilterRuleEntry.rule.attrib.u.v4.dst_addr = 0x7F000001;
- if (
- ((uint8_t)-1 == cFilterTable0.AddRuleToTable(sFilterRuleEntry)) ||
- !m_Filtering.AddFilteringRule(cFilterTable0.GetFilteringTable())
- )
- {
- LOG_MSG_ERROR ("Adding Rule (0) to Filtering block Failed.");
- bRetVal = false;
- goto bail;
- }
- else
- {
- LOG_MSG_DEBUG("flt rule hdl0=0x%x, status=0x%x\n",
- cFilterTable0.ReadRuleFromTable(0)->flt_rule_hdl,
- cFilterTable0.ReadRuleFromTable(0)->status);
- }
-
- sFilterRuleEntry.flt_rule_hdl=-1;
- sFilterRuleEntry.status = -1;
- sFilterRuleEntry.rule.rt_tbl_hdl=nTableHdl[1];
- sFilterRuleEntry.rule.attrib.u.v4.dst_addr = 0xC0A80101;
- if (
- ((uint8_t)-1 == cFilterTable0.AddRuleToTable(sFilterRuleEntry)) ||
- !m_Filtering.AddFilteringRule(cFilterTable0.GetFilteringTable())
- )
- {
- LOG_MSG_ERROR ("Adding Rule(1) to Filtering block Failed.");
- bRetVal = false;
- goto bail;
- }
- else
- {
- LOG_MSG_DEBUG("flt rule hdl0=0x%x, status=0x%x\n",
- cFilterTable0.ReadRuleFromTable(1)->flt_rule_hdl,
- cFilterTable0.ReadRuleFromTable(1)->status);
- }
-
- sFilterRuleEntry.flt_rule_hdl=-1;
- sFilterRuleEntry.status = -1;
- sFilterRuleEntry.rule.rt_tbl_hdl=nTableHdl[2];
- sFilterRuleEntry.rule.attrib.u.v4.dst_addr = 0xC0A80102;
- if (
- ((uint8_t)-1 == cFilterTable0.AddRuleToTable(sFilterRuleEntry)) ||
- !m_Filtering.AddFilteringRule(cFilterTable0.GetFilteringTable())
- )
- {
- LOG_MSG_ERROR ("Adding Rule(2) to Filtering block Failed.");
- bRetVal = false;
- goto bail;
- }
- else
- {
- LOG_MSG_DEBUG("flt rule hdl0=0x%x, status=0x%x\n",
- cFilterTable0.ReadRuleFromTable(2)->flt_rule_hdl,
- cFilterTable0.ReadRuleFromTable(2)->status);
- }
-
- sFilterRuleEntry.flt_rule_hdl=-1;
- sFilterRuleEntry.status = -1;
- sFilterRuleEntry.rule.rt_tbl_hdl=nTableHdl[3];
- sFilterRuleEntry.rule.attrib.u.v4.dst_addr = 0xC0A80103;
- if (
- ((uint8_t)-1 == cFilterTable0.AddRuleToTable(sFilterRuleEntry)) ||
- !m_Filtering.AddFilteringRule(cFilterTable0.GetFilteringTable())
- )
- {
- LOG_MSG_ERROR ("Adding Rule(3) to Filtering block Failed.");
- bRetVal = false;
- goto bail;
- }
- else
- {
- LOG_MSG_DEBUG("flt rule hdl0=0x%x, status=0x%x\n",
- cFilterTable0.ReadRuleFromTable(2)->flt_rule_hdl,
- cFilterTable0.ReadRuleFromTable(2)->status);
- }
-
- sFilterRuleEntry.flt_rule_hdl=-1;
- sFilterRuleEntry.status = -1;
- sFilterRuleEntry.rule.rt_tbl_hdl=nTableHdl[4];
- sFilterRuleEntry.rule.attrib.u.v4.dst_addr = 0xC0A80104;
- if (
- ((uint8_t)-1 == cFilterTable0.AddRuleToTable(sFilterRuleEntry)) ||
- !m_Filtering.AddFilteringRule(cFilterTable0.GetFilteringTable())
- )
- {
- LOG_MSG_ERROR ("Adding Rule(4) to Filtering block Failed.");
- bRetVal = false;
- goto bail;
- }
- else
- {
- LOG_MSG_DEBUG("flt rule hdl0=0x%x, status=0x%x\n",
- cFilterTable0.ReadRuleFromTable(2)->flt_rule_hdl,
- cFilterTable0.ReadRuleFromTable(2)->status);
- }
- bail:
- Free(pHeaderDescriptor);
- LOG_MSG_STACK(
- "Leaving Function (Returning %s)", bRetVal?"True":"False");
- return bRetVal;
- }
-
- bool TestLogic()
- {
- return MBIMAggregationScenarios::MBIMAggregationDifferentStreamIdsTest(
- &m_UsbToIpaPipe, &m_IpaToUsbPipeAgg, m_eIP);
- }
-
- };
- class MBIMAggregationNoInterleavingStreamIdsTest:
- public MBIMAggregationTestFixtureConf11 {
- public:
-
- MBIMAggregationNoInterleavingStreamIdsTest(bool generic_agg)
- : MBIMAggregationTestFixtureConf11(generic_agg)
- {
- if (generic_agg)
- m_name = "GenMBIMAggregationNoInterleavingStreamIdsTest";
- else
- m_name = "MBIMAggregationNoInterleavingStreamIdsTest";
- m_description = "MBIM Aggregation no interleaving stream IDs test - sends 5 packets"
- "with interleaving stream IDs (0, 1, 0, 1, 0) and receives 1 aggregated "
- "packet made of 5 NDPs";
- }
-
- virtual bool AddRules()
- {
- m_eIP = IPA_IP_v4;
- const char aBypass[2][20] = {{"Bypass1"}, {"Bypass2"}};
- uint32_t nTableHdl[2];
- bool bRetVal = true;
- IPAFilteringTable cFilterTable0;
- struct ipa_flt_rule_add sFilterRuleEntry;
- struct ipa_ioc_get_hdr sGetHeader[2];
- uint8_t aHeadertoAdd[2][4];
- int hdrSize;
- for (int i = 0; i < 2; i++) {
- if (mGenericAgg) {
- hdrSize = 4;
- aHeadertoAdd[i][0] = 0x49;
- aHeadertoAdd[i][1] = 0x50;
- aHeadertoAdd[i][2] = 0x53;
- aHeadertoAdd[i][3] = (uint8_t)i;
- }
- else {
- hdrSize = 1;
- aHeadertoAdd[i][0] = (uint8_t)i;
- }
- }
- LOG_MSG_STACK("Entering Function");
- memset(&sFilterRuleEntry, 0, sizeof(sFilterRuleEntry));
- for (int i = 0; i < 2; i++)
- memset(&sGetHeader[i], 0, sizeof(sGetHeader[i]));
-
-
- struct ipa_ioc_add_hdr * pHeaderDescriptor = NULL;
- pHeaderDescriptor = (struct ipa_ioc_add_hdr *) calloc(1,
- sizeof(struct ipa_ioc_add_hdr)
- + 2 * sizeof(struct ipa_hdr_add));
- if (!pHeaderDescriptor)
- {
- LOG_MSG_ERROR("calloc failed to allocate pHeaderDescriptor");
- bRetVal = false;
- goto bail;
- }
- pHeaderDescriptor->commit = true;
- pHeaderDescriptor->num_hdrs = 2;
-
- strlcpy(pHeaderDescriptor->hdr[0].name, "StreamId0", sizeof(pHeaderDescriptor->hdr[0].name));
- memcpy(pHeaderDescriptor->hdr[0].hdr, (void*)&aHeadertoAdd[0],
- hdrSize);
- pHeaderDescriptor->hdr[0].hdr_len = hdrSize;
- pHeaderDescriptor->hdr[0].hdr_hdl = -1;
- pHeaderDescriptor->hdr[0].is_partial = false;
- pHeaderDescriptor->hdr[0].status = -1;
-
- strlcpy(pHeaderDescriptor->hdr[1].name, "StreamId1", sizeof(pHeaderDescriptor->hdr[1].name));
- memcpy(pHeaderDescriptor->hdr[1].hdr, (void*)&aHeadertoAdd[1],
- hdrSize);
- pHeaderDescriptor->hdr[1].hdr_len = hdrSize;
- pHeaderDescriptor->hdr[1].hdr_hdl = -1;
- pHeaderDescriptor->hdr[1].is_partial = false;
- pHeaderDescriptor->hdr[1].status = -1;
- for (int i = 0; i < 2; i++)
- strlcpy(sGetHeader[i].name, pHeaderDescriptor->hdr[i].name, sizeof(sGetHeader[i].name));
- if (!m_HeaderInsertion.AddHeader(pHeaderDescriptor))
- {
- LOG_MSG_ERROR("m_HeaderInsertion.AddHeader(pHeaderDescriptor) Failed.");
- bRetVal = false;
- goto bail;
- }
- for (int i = 0; i < 2; i++)
- {
- if (!m_HeaderInsertion.GetHeaderHandle(&sGetHeader[i]))
- {
- LOG_MSG_ERROR(" Failed");
- bRetVal = false;
- goto bail;
- }
- LOG_MSG_DEBUG("Received Header %d Handle = 0x%x", i, sGetHeader[i].hdl);
- }
- for (int i = 0; i < 2; i++)
- {
- if (!CreateBypassRoutingTable(&m_Routing, m_eIP, aBypass[i],
- IPA_CLIENT_TEST2_CONS, sGetHeader[i].hdl,&nTableHdl[i]))
- {
- LOG_MSG_ERROR("CreateBypassRoutingTable Failed\n");
- bRetVal = false;
- goto bail;
- }
- }
- LOG_MSG_INFO("Creation of 2 bypass routing tables completed successfully");
-
- cFilterTable0.Init(m_eIP,IPA_CLIENT_TEST_PROD, false, 2);
- LOG_MSG_INFO("Creation of filtering table completed successfully");
-
- cFilterTable0.GeneratePresetRule(1,sFilterRuleEntry);
- sFilterRuleEntry.at_rear = true;
- sFilterRuleEntry.flt_rule_hdl=-1;
- sFilterRuleEntry.status = -1;
- sFilterRuleEntry.rule.action=IPA_PASS_TO_ROUTING;
- sFilterRuleEntry.rule.rt_tbl_hdl=nTableHdl[0];
- sFilterRuleEntry.rule.attrib.attrib_mask = IPA_FLT_DST_ADDR;
- sFilterRuleEntry.rule.attrib.u.v4.dst_addr_mask = 0xFF0000FF;
- sFilterRuleEntry.rule.attrib.u.v4.dst_addr = 0x7F000001;
- if (
- ((uint8_t)-1 == cFilterTable0.AddRuleToTable(sFilterRuleEntry)) ||
- !m_Filtering.AddFilteringRule(cFilterTable0.GetFilteringTable())
- )
- {
- LOG_MSG_ERROR ("Adding Rule (0) to Filtering block Failed.");
- bRetVal = false;
- goto bail;
- }
- else
- {
- LOG_MSG_DEBUG("flt rule hdl0=0x%x, status=0x%x\n",
- cFilterTable0.ReadRuleFromTable(0)->flt_rule_hdl,
- cFilterTable0.ReadRuleFromTable(0)->status);
- }
-
- sFilterRuleEntry.flt_rule_hdl=-1;
- sFilterRuleEntry.status = -1;
- sFilterRuleEntry.rule.rt_tbl_hdl=nTableHdl[1];
- sFilterRuleEntry.rule.attrib.u.v4.dst_addr = 0xC0A80101;
- if (
- ((uint8_t)-1 == cFilterTable0.AddRuleToTable(sFilterRuleEntry)) ||
- !m_Filtering.AddFilteringRule(cFilterTable0.GetFilteringTable())
- )
- {
- LOG_MSG_ERROR ("Adding Rule(1) to Filtering block Failed.");
- bRetVal = false;
- goto bail;
- }
- else
- {
- LOG_MSG_DEBUG("flt rule hdl0=0x%x, status=0x%x\n",
- cFilterTable0.ReadRuleFromTable(1)->flt_rule_hdl,
- cFilterTable0.ReadRuleFromTable(1)->status);
- }
- bail:
- Free(pHeaderDescriptor);
- LOG_MSG_STACK(
- "Leaving Function (Returning %s)", bRetVal?"True":"False");
- return bRetVal;
- }
-
- bool TestLogic()
- {
- return MBIMAggregationScenarios::MBIMAggregationNoInterleavingStreamIdsTest(
- &m_UsbToIpaPipe, &m_IpaToUsbPipeAgg, m_eIP);
- }
-
- };
- static MBIMAggregationTest mbimAggregationTest(false);
- static MBIMDeaggregationTest mbimDeaggregationTest(false);
- static MBIMDeaggregationOnePacketTest mbimDeaggregationOnePacketTest(false);
- static MBIMDeaggregationAndAggregationTest mbimDeaggregationAndAggregationTest(false);
- static MBIMMultipleDeaggregationAndAggregationTest
- mbimMultipleDeaggregationAndAggregationTest(false);
- static MBIMAggregationLoopTest mbimAggregationLoopTest(false);
- static MBIMDeaggregationMultipleNDPTest mbimDeaggregationMultipleNDPTest(false);
- static MBIMAggregationMultiplePacketsTest mbimAggregationMultiplePacketsTest(false);
- static MBIMAggregation2PipesTest mbimAggregation2PipesTest(false);
- static MBIMAggregationNoInterleavingStreamIdsTest
- mbimAggregationNoInterleavingStreamIdsTest(false);
- static MBIMAggregationDifferentStreamIdsTest mbimAggregationDifferentStreamIdsTest(false);
- static MBIMAggregationTimeLimitTest mbimAggregationTimeLimitTest(false);
- static MBIMAggregationByteLimitTest mbimAggregationByteLimitTest(false);
- static MBIMAggregationTimeLimitLoopTest mbimAggregationTimeLimitLoopTest(false);
- static MBIMAggregation0LimitsTest mbimAggregation0LimitsTest(false);
- static MBIMAggregationTest genMbimAggregationTest(true);
- static MBIMDeaggregationTest genMbimDeaggregationTest(true);
- static MBIMDeaggregationOnePacketTest genMbimDeaggregationOnePacketTest(true);
- static MBIMDeaggregationAndAggregationTest genMbimDeaggregationAndAggregationTest(true);
- static MBIMMultipleDeaggregationAndAggregationTest genMbimMultipleDeaggregationAndAggregationTest(true);
- static MBIMAggregationLoopTest genMbimAggregationLoopTest(true);
- static MBIMDeaggregationMultipleNDPTest genMbimDeaggregationMultipleNDPTest(true);
- static MBIMAggregationMultiplePacketsTest genMbimAggregationMultiplePacketsTest(true);
- static MBIMAggregation2PipesTest genMbimAggregation2PipesTest(true);
- static MBIMAggregationNoInterleavingStreamIdsTest genMbimAggregationNoInterleavingStreamIdsTest(true);
- static MBIMAggregationDifferentStreamIdsTest genMbimAggregationDifferentStreamIdsTest(true);
- static MBIMAggregationTimeLimitTest genMbimAggregationTimeLimitTest(true);
- static MBIMAggregationByteLimitTest genMbimAggregationByteLimitTest(true);
- static MBIMAggregationByteLimitTestFC genMbimAggregationByteLimitTestFC(true);
- static MBIMAggregationDualDpTestFC genMBIMAggregationDualDpTestFC(true);
- static MBIMAggregationDualDpTestFcRoutingBased genMBIMAggregationDualDpTestFcRoutingBased(true);
- static MBIMAggregationTimeLimitLoopTest genMbimAggregationTimeLimitLoopTest(true);
- static MBIMAggregation0LimitsTest genMbimAggregation0LimitsTest(true);
|