read.cpp 170 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037103810391040104110421043104410451046104710481049105010511052105310541055105610571058105910601061106210631064106510661067106810691070107110721073107410751076107710781079108010811082108310841085108610871088108910901091109210931094109510961097109810991100110111021103110411051106110711081109111011111112111311141115111611171118111911201121112211231124112511261127112811291130113111321133113411351136113711381139114011411142114311441145114611471148114911501151115211531154115511561157115811591160116111621163116411651166116711681169117011711172117311741175117611771178117911801181118211831184118511861187118811891190119111921193119411951196119711981199120012011202120312041205120612071208120912101211121212131214121512161217121812191220122112221223122412251226122712281229123012311232123312341235123612371238123912401241124212431244124512461247124812491250125112521253125412551256125712581259126012611262126312641265126612671268126912701271127212731274127512761277127812791280128112821283128412851286128712881289129012911292129312941295129612971298129913001301130213031304130513061307130813091310131113121313131413151316131713181319132013211322132313241325132613271328132913301331133213331334133513361337133813391340134113421343134413451346134713481349135013511352135313541355135613571358135913601361136213631364136513661367136813691370137113721373137413751376137713781379138013811382138313841385138613871388138913901391139213931394139513961397139813991400140114021403140414051406140714081409141014111412141314141415141614171418141914201421142214231424142514261427142814291430143114321433143414351436143714381439144014411442144314441445144614471448144914501451145214531454145514561457145814591460146114621463146414651466146714681469147014711472147314741475147614771478147914801481148214831484148514861487148814891490149114921493149414951496149714981499150015011502150315041505150615071508150915101511151215131514151515161517151815191520152115221523152415251526152715281529153015311532153315341535153615371538153915401541154215431544154515461547154815491550155115521553155415551556155715581559156015611562156315641565156615671568156915701571157215731574157515761577157815791580158115821583158415851586158715881589159015911592159315941595159615971598159916001601160216031604160516061607160816091610161116121613161416151616161716181619162016211622162316241625162616271628162916301631163216331634163516361637163816391640164116421643164416451646164716481649165016511652165316541655165616571658165916601661166216631664166516661667166816691670167116721673167416751676167716781679168016811682168316841685168616871688168916901691169216931694169516961697169816991700170117021703170417051706170717081709171017111712171317141715171617171718171917201721172217231724172517261727172817291730173117321733173417351736173717381739174017411742174317441745174617471748174917501751175217531754175517561757175817591760176117621763176417651766176717681769177017711772177317741775177617771778177917801781178217831784178517861787178817891790179117921793179417951796179717981799180018011802180318041805180618071808180918101811181218131814181518161817181818191820182118221823182418251826182718281829183018311832183318341835183618371838183918401841184218431844184518461847184818491850185118521853185418551856185718581859186018611862186318641865186618671868186918701871187218731874187518761877187818791880188118821883188418851886188718881889189018911892189318941895189618971898189919001901190219031904190519061907190819091910191119121913191419151916191719181919192019211922192319241925192619271928192919301931193219331934193519361937193819391940194119421943194419451946194719481949195019511952195319541955195619571958195919601961196219631964196519661967196819691970197119721973197419751976197719781979198019811982198319841985198619871988198919901991199219931994199519961997199819992000200120022003200420052006200720082009201020112012201320142015201620172018201920202021202220232024202520262027202820292030203120322033203420352036203720382039204020412042204320442045204620472048204920502051205220532054205520562057205820592060206120622063206420652066206720682069207020712072207320742075207620772078207920802081208220832084208520862087208820892090209120922093209420952096209720982099210021012102210321042105210621072108210921102111211221132114211521162117211821192120212121222123212421252126212721282129213021312132213321342135213621372138213921402141214221432144214521462147214821492150215121522153215421552156215721582159216021612162216321642165216621672168216921702171217221732174217521762177217821792180218121822183218421852186218721882189219021912192219321942195219621972198219922002201220222032204220522062207220822092210221122122213221422152216221722182219222022212222222322242225222622272228222922302231223222332234223522362237223822392240224122422243224422452246224722482249225022512252225322542255225622572258225922602261226222632264226522662267226822692270227122722273227422752276227722782279228022812282228322842285228622872288228922902291229222932294229522962297229822992300230123022303230423052306230723082309231023112312231323142315231623172318231923202321232223232324232523262327232823292330233123322333233423352336233723382339234023412342234323442345234623472348234923502351235223532354235523562357235823592360236123622363236423652366236723682369237023712372237323742375237623772378237923802381238223832384238523862387238823892390239123922393239423952396239723982399240024012402240324042405240624072408240924102411241224132414241524162417241824192420242124222423242424252426242724282429243024312432243324342435243624372438243924402441244224432444244524462447244824492450245124522453245424552456245724582459246024612462246324642465246624672468246924702471247224732474247524762477247824792480248124822483248424852486248724882489249024912492249324942495249624972498249925002501250225032504250525062507250825092510251125122513251425152516251725182519252025212522252325242525252625272528252925302531253225332534253525362537253825392540254125422543254425452546254725482549255025512552255325542555255625572558255925602561256225632564256525662567256825692570257125722573257425752576257725782579258025812582258325842585258625872588258925902591259225932594259525962597259825992600260126022603260426052606260726082609261026112612261326142615261626172618261926202621262226232624262526262627262826292630263126322633263426352636263726382639264026412642264326442645264626472648264926502651265226532654265526562657265826592660266126622663266426652666266726682669267026712672267326742675267626772678267926802681268226832684268526862687268826892690269126922693269426952696269726982699270027012702270327042705270627072708270927102711271227132714271527162717271827192720272127222723272427252726272727282729273027312732273327342735273627372738273927402741274227432744274527462747274827492750275127522753275427552756275727582759276027612762276327642765276627672768276927702771277227732774277527762777277827792780278127822783278427852786278727882789279027912792279327942795279627972798279928002801280228032804280528062807280828092810281128122813281428152816281728182819282028212822282328242825282628272828282928302831283228332834283528362837283828392840284128422843284428452846284728482849285028512852285328542855285628572858285928602861286228632864286528662867286828692870287128722873287428752876287728782879288028812882288328842885288628872888288928902891289228932894289528962897289828992900290129022903290429052906290729082909291029112912291329142915291629172918291929202921292229232924292529262927292829292930293129322933293429352936293729382939294029412942294329442945294629472948294929502951295229532954295529562957295829592960296129622963296429652966296729682969297029712972297329742975297629772978297929802981298229832984298529862987298829892990299129922993299429952996299729982999300030013002300330043005300630073008300930103011301230133014301530163017301830193020302130223023302430253026302730283029303030313032303330343035303630373038303930403041304230433044304530463047304830493050305130523053305430553056305730583059306030613062306330643065306630673068306930703071307230733074307530763077307830793080308130823083308430853086308730883089309030913092309330943095309630973098309931003101310231033104310531063107310831093110311131123113311431153116311731183119312031213122312331243125312631273128312931303131313231333134313531363137313831393140314131423143314431453146314731483149315031513152315331543155315631573158315931603161316231633164316531663167316831693170317131723173317431753176317731783179318031813182318331843185318631873188318931903191319231933194319531963197319831993200320132023203320432053206320732083209321032113212321332143215321632173218321932203221322232233224322532263227322832293230323132323233323432353236323732383239324032413242324332443245324632473248324932503251325232533254325532563257325832593260326132623263326432653266326732683269327032713272327332743275327632773278327932803281328232833284328532863287328832893290329132923293329432953296329732983299330033013302330333043305330633073308330933103311331233133314331533163317331833193320332133223323332433253326332733283329333033313332333333343335333633373338333933403341334233433344334533463347334833493350335133523353335433553356335733583359336033613362336333643365336633673368336933703371337233733374337533763377337833793380338133823383338433853386338733883389339033913392339333943395339633973398339934003401340234033404340534063407340834093410341134123413341434153416341734183419342034213422342334243425342634273428342934303431343234333434343534363437343834393440344134423443344434453446344734483449345034513452345334543455345634573458345934603461346234633464346534663467346834693470347134723473347434753476347734783479348034813482348334843485348634873488348934903491349234933494349534963497349834993500350135023503350435053506350735083509351035113512351335143515351635173518351935203521352235233524352535263527352835293530353135323533353435353536353735383539354035413542354335443545354635473548354935503551355235533554355535563557355835593560356135623563356435653566356735683569357035713572357335743575357635773578357935803581358235833584358535863587358835893590359135923593359435953596359735983599360036013602360336043605360636073608360936103611361236133614361536163617361836193620362136223623362436253626362736283629363036313632363336343635363636373638363936403641364236433644364536463647364836493650365136523653365436553656365736583659366036613662366336643665366636673668366936703671367236733674367536763677367836793680368136823683368436853686368736883689369036913692369336943695369636973698369937003701370237033704370537063707370837093710371137123713371437153716371737183719372037213722372337243725372637273728372937303731373237333734373537363737373837393740374137423743374437453746374737483749375037513752375337543755375637573758375937603761376237633764376537663767376837693770377137723773377437753776377737783779378037813782378337843785378637873788378937903791379237933794379537963797379837993800380138023803380438053806380738083809381038113812381338143815381638173818381938203821382238233824382538263827382838293830383138323833383438353836383738383839384038413842384338443845384638473848384938503851385238533854385538563857385838593860386138623863386438653866386738683869387038713872387338743875387638773878387938803881388238833884388538863887388838893890389138923893389438953896389738983899390039013902390339043905390639073908390939103911391239133914391539163917391839193920392139223923392439253926392739283929393039313932393339343935393639373938393939403941394239433944394539463947394839493950395139523953395439553956395739583959396039613962396339643965396639673968396939703971397239733974397539763977397839793980398139823983398439853986398739883989399039913992399339943995399639973998399940004001400240034004400540064007400840094010401140124013401440154016401740184019402040214022402340244025402640274028402940304031403240334034403540364037403840394040404140424043404440454046404740484049405040514052405340544055405640574058405940604061406240634064406540664067406840694070407140724073407440754076407740784079408040814082408340844085408640874088408940904091409240934094409540964097409840994100410141024103410441054106410741084109411041114112411341144115411641174118411941204121412241234124412541264127412841294130413141324133413441354136413741384139414041414142414341444145414641474148414941504151415241534154415541564157415841594160416141624163416441654166416741684169417041714172417341744175417641774178417941804181418241834184418541864187418841894190419141924193419441954196419741984199420042014202420342044205420642074208420942104211421242134214421542164217421842194220422142224223422442254226422742284229423042314232423342344235423642374238423942404241424242434244424542464247424842494250425142524253425442554256425742584259426042614262426342644265426642674268426942704271427242734274427542764277427842794280428142824283428442854286428742884289429042914292429342944295429642974298429943004301430243034304430543064307430843094310431143124313431443154316431743184319432043214322432343244325432643274328432943304331433243334334433543364337433843394340434143424343434443454346434743484349435043514352435343544355435643574358435943604361436243634364436543664367436843694370437143724373437443754376437743784379438043814382438343844385438643874388438943904391439243934394439543964397439843994400440144024403440444054406440744084409441044114412441344144415441644174418441944204421442244234424442544264427442844294430443144324433443444354436443744384439444044414442444344444445444644474448444944504451445244534454445544564457445844594460446144624463446444654466446744684469447044714472447344744475447644774478447944804481448244834484448544864487448844894490449144924493449444954496449744984499450045014502450345044505450645074508450945104511451245134514451545164517451845194520452145224523452445254526452745284529453045314532453345344535453645374538453945404541454245434544454545464547454845494550455145524553455445554556455745584559456045614562456345644565456645674568456945704571457245734574457545764577457845794580458145824583458445854586458745884589459045914592459345944595459645974598459946004601460246034604460546064607460846094610461146124613461446154616461746184619462046214622462346244625462646274628462946304631463246334634463546364637463846394640464146424643464446454646464746484649465046514652465346544655465646574658465946604661466246634664466546664667466846694670467146724673467446754676467746784679468046814682468346844685468646874688468946904691469246934694469546964697469846994700470147024703470447054706470747084709471047114712471347144715471647174718471947204721472247234724472547264727472847294730473147324733473447354736473747384739474047414742474347444745474647474748474947504751475247534754475547564757475847594760476147624763476447654766476747684769477047714772477347744775477647774778477947804781478247834784478547864787478847894790479147924793479447954796479747984799480048014802480348044805480648074808480948104811481248134814481548164817481848194820482148224823482448254826482748284829483048314832483348344835483648374838483948404841484248434844484548464847484848494850485148524853485448554856485748584859486048614862486348644865486648674868486948704871487248734874487548764877487848794880488148824883488448854886488748884889489048914892489348944895489648974898489949004901490249034904490549064907490849094910491149124913491449154916491749184919492049214922492349244925492649274928492949304931493249334934493549364937493849394940494149424943494449454946494749484949495049514952495349544955495649574958495949604961496249634964496549664967496849694970497149724973497449754976497749784979498049814982498349844985498649874988498949904991499249934994499549964997
  1. //
  2. // read.cpp
  3. // ~~~~~~~~
  4. //
  5. // Copyright (c) 2003-2019 Christopher M. Kohlhoff (chris at kohlhoff dot com)
  6. //
  7. // Distributed under the Boost Software License, Version 1.0. (See accompanying
  8. // file LICENSE_1_0.txt or copy at http://www.boost.org/LICENSE_1_0.txt)
  9. //
  10. // Disable autolinking for unit tests.
  11. #if !defined(BOOST_ALL_NO_LIB)
  12. #define BOOST_ALL_NO_LIB 1
  13. #endif // !defined(BOOST_ALL_NO_LIB)
  14. // Test that header file is self-contained.
  15. #include <boost/asio/read.hpp>
  16. #include <cstring>
  17. #include <vector>
  18. #include "archetypes/async_result.hpp"
  19. #include <boost/asio/io_context.hpp>
  20. #include <boost/asio/post.hpp>
  21. #include <boost/asio/streambuf.hpp>
  22. #include "unit_test.hpp"
  23. #if defined(BOOST_ASIO_HAS_BOOST_BIND)
  24. # include <boost/bind.hpp>
  25. #else // defined(BOOST_ASIO_HAS_BOOST_BIND)
  26. # include <functional>
  27. #endif // defined(BOOST_ASIO_HAS_BOOST_BIND)
  28. #if defined(BOOST_ASIO_HAS_BOOST_ARRAY)
  29. #include <boost/array.hpp>
  30. #endif // defined(BOOST_ASIO_HAS_BOOST_ARRAY)
  31. #if defined(BOOST_ASIO_HAS_STD_ARRAY)
  32. # include <array>
  33. #endif // defined(BOOST_ASIO_HAS_STD_ARRAY)
  34. using namespace std; // For memcmp, memcpy and memset.
  35. class test_stream
  36. {
  37. public:
  38. typedef boost::asio::io_context::executor_type executor_type;
  39. test_stream(boost::asio::io_context& io_context)
  40. : io_context_(io_context),
  41. length_(0),
  42. position_(0),
  43. next_read_length_(0)
  44. {
  45. }
  46. executor_type get_executor() BOOST_ASIO_NOEXCEPT
  47. {
  48. return io_context_.get_executor();
  49. }
  50. void reset(const void* data, size_t length)
  51. {
  52. BOOST_ASIO_CHECK(length <= max_length);
  53. memcpy(data_, data, length);
  54. length_ = length;
  55. position_ = 0;
  56. next_read_length_ = length;
  57. }
  58. void next_read_length(size_t length)
  59. {
  60. next_read_length_ = length;
  61. }
  62. template <typename Iterator>
  63. bool check_buffers(Iterator begin, Iterator end, size_t length)
  64. {
  65. if (length != position_)
  66. return false;
  67. Iterator iter = begin;
  68. size_t checked_length = 0;
  69. for (; iter != end && checked_length < length; ++iter)
  70. {
  71. size_t buffer_length = boost::asio::buffer_size(*iter);
  72. if (buffer_length > length - checked_length)
  73. buffer_length = length - checked_length;
  74. if (memcmp(data_ + checked_length, iter->data(), buffer_length) != 0)
  75. return false;
  76. checked_length += buffer_length;
  77. }
  78. return true;
  79. }
  80. template <typename Const_Buffers>
  81. bool check_buffers(const Const_Buffers& buffers, size_t length)
  82. {
  83. return check_buffers(boost::asio::buffer_sequence_begin(buffers),
  84. boost::asio::buffer_sequence_end(buffers), length);
  85. }
  86. template <typename Mutable_Buffers>
  87. size_t read_some(const Mutable_Buffers& buffers)
  88. {
  89. size_t n = boost::asio::buffer_copy(buffers,
  90. boost::asio::buffer(data_, length_) + position_,
  91. next_read_length_);
  92. position_ += n;
  93. return n;
  94. }
  95. template <typename Mutable_Buffers>
  96. size_t read_some(const Mutable_Buffers& buffers,
  97. boost::system::error_code& ec)
  98. {
  99. ec = boost::system::error_code();
  100. return read_some(buffers);
  101. }
  102. template <typename Mutable_Buffers, typename Handler>
  103. void async_read_some(const Mutable_Buffers& buffers,
  104. BOOST_ASIO_MOVE_ARG(Handler) handler)
  105. {
  106. size_t bytes_transferred = read_some(buffers);
  107. boost::asio::post(get_executor(),
  108. boost::asio::detail::bind_handler(
  109. BOOST_ASIO_MOVE_CAST(Handler)(handler),
  110. boost::system::error_code(), bytes_transferred));
  111. }
  112. private:
  113. boost::asio::io_context& io_context_;
  114. enum { max_length = 8192 };
  115. char data_[max_length];
  116. size_t length_;
  117. size_t position_;
  118. size_t next_read_length_;
  119. };
  120. static const char read_data[]
  121. = "ABCDEFGHIJKLMNOPQRSTUVWXYZabcdefghijklmnopqrstuvwxyz";
  122. void test_2_arg_zero_buffers_read()
  123. {
  124. boost::asio::io_context ioc;
  125. test_stream s(ioc);
  126. std::vector<boost::asio::mutable_buffer> buffers;
  127. size_t bytes_transferred = boost::asio::read(s, buffers);
  128. BOOST_ASIO_CHECK(bytes_transferred == 0);
  129. }
  130. void test_2_arg_mutable_buffer_read()
  131. {
  132. boost::asio::io_context ioc;
  133. test_stream s(ioc);
  134. char read_buf[sizeof(read_data)];
  135. boost::asio::mutable_buffer buffers
  136. = boost::asio::buffer(read_buf, sizeof(read_buf));
  137. s.reset(read_data, sizeof(read_data));
  138. memset(read_buf, 0, sizeof(read_buf));
  139. size_t bytes_transferred = boost::asio::read(s, buffers);
  140. BOOST_ASIO_CHECK(bytes_transferred == sizeof(read_data));
  141. BOOST_ASIO_CHECK(s.check_buffers(buffers, sizeof(read_data)));
  142. s.reset(read_data, sizeof(read_data));
  143. s.next_read_length(1);
  144. memset(read_buf, 0, sizeof(read_buf));
  145. bytes_transferred = boost::asio::read(s, buffers);
  146. BOOST_ASIO_CHECK(bytes_transferred == sizeof(read_data));
  147. BOOST_ASIO_CHECK(s.check_buffers(buffers, sizeof(read_data)));
  148. s.reset(read_data, sizeof(read_data));
  149. s.next_read_length(10);
  150. memset(read_buf, 0, sizeof(read_buf));
  151. bytes_transferred = boost::asio::read(s, buffers);
  152. BOOST_ASIO_CHECK(bytes_transferred == sizeof(read_data));
  153. BOOST_ASIO_CHECK(s.check_buffers(buffers, sizeof(read_data)));
  154. }
  155. void test_2_arg_vector_buffers_read()
  156. {
  157. boost::asio::io_context ioc;
  158. test_stream s(ioc);
  159. char read_buf[sizeof(read_data)];
  160. std::vector<boost::asio::mutable_buffer> buffers;
  161. buffers.push_back(boost::asio::buffer(read_buf, 32));
  162. buffers.push_back(boost::asio::buffer(read_buf, 39) + 32);
  163. buffers.push_back(boost::asio::buffer(read_buf) + 39);
  164. s.reset(read_data, sizeof(read_data));
  165. memset(read_buf, 0, sizeof(read_buf));
  166. size_t bytes_transferred = boost::asio::read(s, buffers);
  167. BOOST_ASIO_CHECK(bytes_transferred == sizeof(read_data));
  168. BOOST_ASIO_CHECK(s.check_buffers(buffers, sizeof(read_data)));
  169. s.reset(read_data, sizeof(read_data));
  170. s.next_read_length(1);
  171. memset(read_buf, 0, sizeof(read_buf));
  172. bytes_transferred = boost::asio::read(s, buffers);
  173. BOOST_ASIO_CHECK(bytes_transferred == sizeof(read_data));
  174. BOOST_ASIO_CHECK(s.check_buffers(buffers, sizeof(read_data)));
  175. s.reset(read_data, sizeof(read_data));
  176. s.next_read_length(10);
  177. memset(read_buf, 0, sizeof(read_buf));
  178. bytes_transferred = boost::asio::read(s, buffers);
  179. BOOST_ASIO_CHECK(bytes_transferred == sizeof(read_data));
  180. BOOST_ASIO_CHECK(s.check_buffers(buffers, sizeof(read_data)));
  181. }
  182. void test_2_arg_dynamic_string_read()
  183. {
  184. boost::asio::io_context ioc;
  185. test_stream s(ioc);
  186. std::string data;
  187. boost::asio::dynamic_string_buffer<char, std::string::traits_type,
  188. std::string::allocator_type> sb
  189. = boost::asio::dynamic_buffer(data, sizeof(read_data));
  190. s.reset(read_data, sizeof(read_data));
  191. sb.consume(sb.size());
  192. size_t bytes_transferred = boost::asio::read(s, sb);
  193. BOOST_ASIO_CHECK(bytes_transferred == sizeof(read_data));
  194. BOOST_ASIO_CHECK(sb.size() == sizeof(read_data));
  195. BOOST_ASIO_CHECK(s.check_buffers(sb.data(0, sb.size()), sizeof(read_data)));
  196. s.reset(read_data, sizeof(read_data));
  197. s.next_read_length(1);
  198. sb.consume(sb.size());
  199. bytes_transferred = boost::asio::read(s, sb);
  200. BOOST_ASIO_CHECK(bytes_transferred == sizeof(read_data));
  201. BOOST_ASIO_CHECK(sb.size() == sizeof(read_data));
  202. BOOST_ASIO_CHECK(s.check_buffers(sb.data(0, sb.size()), sizeof(read_data)));
  203. s.reset(read_data, sizeof(read_data));
  204. s.next_read_length(10);
  205. sb.consume(sb.size());
  206. bytes_transferred = boost::asio::read(s, sb);
  207. BOOST_ASIO_CHECK(bytes_transferred == sizeof(read_data));
  208. BOOST_ASIO_CHECK(sb.size() == sizeof(read_data));
  209. BOOST_ASIO_CHECK(s.check_buffers(sb.data(0, sb.size()), sizeof(read_data)));
  210. }
  211. void test_2_arg_streambuf_read()
  212. {
  213. #if !defined(BOOST_ASIO_NO_DYNAMIC_BUFFER_V1)
  214. boost::asio::io_context ioc;
  215. test_stream s(ioc);
  216. boost::asio::streambuf sb(sizeof(read_data));
  217. s.reset(read_data, sizeof(read_data));
  218. sb.consume(sb.size());
  219. size_t bytes_transferred = boost::asio::read(s, sb);
  220. BOOST_ASIO_CHECK(bytes_transferred == sizeof(read_data));
  221. BOOST_ASIO_CHECK(sb.size() == sizeof(read_data));
  222. BOOST_ASIO_CHECK(s.check_buffers(sb.data(), sizeof(read_data)));
  223. s.reset(read_data, sizeof(read_data));
  224. s.next_read_length(1);
  225. sb.consume(sb.size());
  226. bytes_transferred = boost::asio::read(s, sb);
  227. BOOST_ASIO_CHECK(bytes_transferred == sizeof(read_data));
  228. BOOST_ASIO_CHECK(sb.size() == sizeof(read_data));
  229. BOOST_ASIO_CHECK(s.check_buffers(sb.data(), sizeof(read_data)));
  230. s.reset(read_data, sizeof(read_data));
  231. s.next_read_length(10);
  232. sb.consume(sb.size());
  233. bytes_transferred = boost::asio::read(s, sb);
  234. BOOST_ASIO_CHECK(bytes_transferred == sizeof(read_data));
  235. BOOST_ASIO_CHECK(sb.size() == sizeof(read_data));
  236. BOOST_ASIO_CHECK(s.check_buffers(sb.data(), sizeof(read_data)));
  237. #endif // !defined(BOOST_ASIO_NO_DYNAMIC_BUFFER_V1)
  238. }
  239. void test_3_arg_nothrow_zero_buffers_read()
  240. {
  241. boost::asio::io_context ioc;
  242. test_stream s(ioc);
  243. std::vector<boost::asio::mutable_buffer> buffers;
  244. boost::system::error_code error;
  245. size_t bytes_transferred = boost::asio::read(s, buffers, error);
  246. BOOST_ASIO_CHECK(bytes_transferred == 0);
  247. BOOST_ASIO_CHECK(!error);
  248. }
  249. void test_3_arg_nothrow_mutable_buffer_read()
  250. {
  251. boost::asio::io_context ioc;
  252. test_stream s(ioc);
  253. char read_buf[sizeof(read_data)];
  254. boost::asio::mutable_buffer buffers
  255. = boost::asio::buffer(read_buf, sizeof(read_buf));
  256. s.reset(read_data, sizeof(read_data));
  257. memset(read_buf, 0, sizeof(read_buf));
  258. boost::system::error_code error;
  259. size_t bytes_transferred = boost::asio::read(s, buffers, error);
  260. BOOST_ASIO_CHECK(bytes_transferred == sizeof(read_data));
  261. BOOST_ASIO_CHECK(s.check_buffers(buffers, sizeof(read_data)));
  262. BOOST_ASIO_CHECK(!error);
  263. s.reset(read_data, sizeof(read_data));
  264. s.next_read_length(1);
  265. memset(read_buf, 0, sizeof(read_buf));
  266. bytes_transferred = boost::asio::read(s, buffers, error);
  267. BOOST_ASIO_CHECK(bytes_transferred == sizeof(read_data));
  268. BOOST_ASIO_CHECK(s.check_buffers(buffers, sizeof(read_data)));
  269. BOOST_ASIO_CHECK(!error);
  270. s.reset(read_data, sizeof(read_data));
  271. s.next_read_length(10);
  272. memset(read_buf, 0, sizeof(read_buf));
  273. bytes_transferred = boost::asio::read(s, buffers, error);
  274. BOOST_ASIO_CHECK(bytes_transferred == sizeof(read_data));
  275. BOOST_ASIO_CHECK(s.check_buffers(buffers, sizeof(read_data)));
  276. BOOST_ASIO_CHECK(!error);
  277. }
  278. void test_3_arg_nothrow_vector_buffers_read()
  279. {
  280. boost::asio::io_context ioc;
  281. test_stream s(ioc);
  282. char read_buf[sizeof(read_data)];
  283. std::vector<boost::asio::mutable_buffer> buffers;
  284. buffers.push_back(boost::asio::buffer(read_buf, 32));
  285. buffers.push_back(boost::asio::buffer(read_buf, 39) + 32);
  286. buffers.push_back(boost::asio::buffer(read_buf) + 39);
  287. s.reset(read_data, sizeof(read_data));
  288. memset(read_buf, 0, sizeof(read_buf));
  289. boost::system::error_code error;
  290. size_t bytes_transferred = boost::asio::read(s, buffers, error);
  291. BOOST_ASIO_CHECK(bytes_transferred == sizeof(read_data));
  292. BOOST_ASIO_CHECK(s.check_buffers(buffers, sizeof(read_data)));
  293. BOOST_ASIO_CHECK(!error);
  294. s.reset(read_data, sizeof(read_data));
  295. s.next_read_length(1);
  296. memset(read_buf, 0, sizeof(read_buf));
  297. bytes_transferred = boost::asio::read(s, buffers, error);
  298. BOOST_ASIO_CHECK(bytes_transferred == sizeof(read_data));
  299. BOOST_ASIO_CHECK(s.check_buffers(buffers, sizeof(read_data)));
  300. BOOST_ASIO_CHECK(!error);
  301. s.reset(read_data, sizeof(read_data));
  302. s.next_read_length(10);
  303. memset(read_buf, 0, sizeof(read_buf));
  304. bytes_transferred = boost::asio::read(s, buffers, error);
  305. BOOST_ASIO_CHECK(bytes_transferred == sizeof(read_data));
  306. BOOST_ASIO_CHECK(s.check_buffers(buffers, sizeof(read_data)));
  307. BOOST_ASIO_CHECK(!error);
  308. }
  309. void test_3_arg_nothrow_dynamic_string_read()
  310. {
  311. boost::asio::io_context ioc;
  312. test_stream s(ioc);
  313. std::string data;
  314. boost::asio::dynamic_string_buffer<char, std::string::traits_type,
  315. std::string::allocator_type> sb
  316. = boost::asio::dynamic_buffer(data, sizeof(read_data));
  317. s.reset(read_data, sizeof(read_data));
  318. sb.consume(sb.size());
  319. boost::system::error_code error;
  320. size_t bytes_transferred = boost::asio::read(s, sb, error);
  321. BOOST_ASIO_CHECK(bytes_transferred == sizeof(read_data));
  322. BOOST_ASIO_CHECK(sb.size() == sizeof(read_data));
  323. BOOST_ASIO_CHECK(s.check_buffers(sb.data(0, sb.size()), sizeof(read_data)));
  324. BOOST_ASIO_CHECK(!error);
  325. s.reset(read_data, sizeof(read_data));
  326. s.next_read_length(1);
  327. sb.consume(sb.size());
  328. bytes_transferred = boost::asio::read(s, sb, error);
  329. BOOST_ASIO_CHECK(bytes_transferred == sizeof(read_data));
  330. BOOST_ASIO_CHECK(sb.size() == sizeof(read_data));
  331. BOOST_ASIO_CHECK(s.check_buffers(sb.data(0, sb.size()), sizeof(read_data)));
  332. BOOST_ASIO_CHECK(!error);
  333. s.reset(read_data, sizeof(read_data));
  334. s.next_read_length(10);
  335. sb.consume(sb.size());
  336. bytes_transferred = boost::asio::read(s, sb, error);
  337. BOOST_ASIO_CHECK(bytes_transferred == sizeof(read_data));
  338. BOOST_ASIO_CHECK(sb.size() == sizeof(read_data));
  339. BOOST_ASIO_CHECK(s.check_buffers(sb.data(0, sb.size()), sizeof(read_data)));
  340. BOOST_ASIO_CHECK(!error);
  341. }
  342. void test_3_arg_nothrow_streambuf_read()
  343. {
  344. #if !defined(BOOST_ASIO_NO_DYNAMIC_BUFFER_V1)
  345. boost::asio::io_context ioc;
  346. test_stream s(ioc);
  347. boost::asio::streambuf sb(sizeof(read_data));
  348. s.reset(read_data, sizeof(read_data));
  349. sb.consume(sb.size());
  350. boost::system::error_code error;
  351. size_t bytes_transferred = boost::asio::read(s, sb, error);
  352. BOOST_ASIO_CHECK(bytes_transferred == sizeof(read_data));
  353. BOOST_ASIO_CHECK(sb.size() == sizeof(read_data));
  354. BOOST_ASIO_CHECK(s.check_buffers(sb.data(), sizeof(read_data)));
  355. BOOST_ASIO_CHECK(!error);
  356. s.reset(read_data, sizeof(read_data));
  357. s.next_read_length(1);
  358. sb.consume(sb.size());
  359. bytes_transferred = boost::asio::read(s, sb, error);
  360. BOOST_ASIO_CHECK(bytes_transferred == sizeof(read_data));
  361. BOOST_ASIO_CHECK(sb.size() == sizeof(read_data));
  362. BOOST_ASIO_CHECK(s.check_buffers(sb.data(), sizeof(read_data)));
  363. BOOST_ASIO_CHECK(!error);
  364. s.reset(read_data, sizeof(read_data));
  365. s.next_read_length(10);
  366. sb.consume(sb.size());
  367. bytes_transferred = boost::asio::read(s, sb, error);
  368. BOOST_ASIO_CHECK(bytes_transferred == sizeof(read_data));
  369. BOOST_ASIO_CHECK(sb.size() == sizeof(read_data));
  370. BOOST_ASIO_CHECK(s.check_buffers(sb.data(), sizeof(read_data)));
  371. BOOST_ASIO_CHECK(!error);
  372. #endif // !defined(BOOST_ASIO_NO_DYNAMIC_BUFFER_V1)
  373. }
  374. bool old_style_transfer_all(const boost::system::error_code& ec,
  375. size_t /*bytes_transferred*/)
  376. {
  377. return !!ec;
  378. }
  379. struct short_transfer
  380. {
  381. short_transfer() {}
  382. #if defined(BOOST_ASIO_HAS_MOVE)
  383. short_transfer(short_transfer&&) {}
  384. #else // defined(BOOST_ASIO_HAS_MOVE)
  385. short_transfer(const short_transfer&) {}
  386. #endif // defined(BOOST_ASIO_HAS_MOVE)
  387. size_t operator()(const boost::system::error_code& ec,
  388. size_t /*bytes_transferred*/)
  389. {
  390. return !!ec ? 0 : 3;
  391. }
  392. };
  393. void test_3_arg_mutable_buffer_read()
  394. {
  395. boost::asio::io_context ioc;
  396. test_stream s(ioc);
  397. char read_buf[sizeof(read_data)];
  398. boost::asio::mutable_buffer buffers
  399. = boost::asio::buffer(read_buf, sizeof(read_buf));
  400. s.reset(read_data, sizeof(read_data));
  401. memset(read_buf, 0, sizeof(read_buf));
  402. size_t bytes_transferred = boost::asio::read(s, buffers,
  403. boost::asio::transfer_all());
  404. BOOST_ASIO_CHECK(bytes_transferred == sizeof(read_data));
  405. BOOST_ASIO_CHECK(s.check_buffers(buffers, sizeof(read_data)));
  406. s.reset(read_data, sizeof(read_data));
  407. s.next_read_length(1);
  408. memset(read_buf, 0, sizeof(read_buf));
  409. bytes_transferred = boost::asio::read(s, buffers,
  410. boost::asio::transfer_all());
  411. BOOST_ASIO_CHECK(bytes_transferred == sizeof(read_data));
  412. BOOST_ASIO_CHECK(s.check_buffers(buffers, sizeof(read_data)));
  413. s.reset(read_data, sizeof(read_data));
  414. s.next_read_length(10);
  415. memset(read_buf, 0, sizeof(read_buf));
  416. bytes_transferred = boost::asio::read(s, buffers,
  417. boost::asio::transfer_all());
  418. BOOST_ASIO_CHECK(bytes_transferred == sizeof(read_data));
  419. BOOST_ASIO_CHECK(s.check_buffers(buffers, sizeof(read_data)));
  420. s.reset(read_data, sizeof(read_data));
  421. memset(read_buf, 0, sizeof(read_buf));
  422. bytes_transferred = boost::asio::read(s, buffers,
  423. boost::asio::transfer_at_least(1));
  424. BOOST_ASIO_CHECK(bytes_transferred == sizeof(read_data));
  425. BOOST_ASIO_CHECK(s.check_buffers(buffers, sizeof(read_data)));
  426. s.reset(read_data, sizeof(read_data));
  427. s.next_read_length(1);
  428. memset(read_buf, 0, sizeof(read_buf));
  429. bytes_transferred = boost::asio::read(s, buffers,
  430. boost::asio::transfer_at_least(1));
  431. BOOST_ASIO_CHECK(bytes_transferred == 1);
  432. BOOST_ASIO_CHECK(s.check_buffers(buffers, 1));
  433. s.reset(read_data, sizeof(read_data));
  434. s.next_read_length(10);
  435. memset(read_buf, 0, sizeof(read_buf));
  436. bytes_transferred = boost::asio::read(s, buffers,
  437. boost::asio::transfer_at_least(1));
  438. BOOST_ASIO_CHECK(bytes_transferred == 10);
  439. BOOST_ASIO_CHECK(s.check_buffers(buffers, 10));
  440. s.reset(read_data, sizeof(read_data));
  441. memset(read_buf, 0, sizeof(read_buf));
  442. bytes_transferred = boost::asio::read(s, buffers,
  443. boost::asio::transfer_at_least(10));
  444. BOOST_ASIO_CHECK(bytes_transferred == sizeof(read_data));
  445. BOOST_ASIO_CHECK(s.check_buffers(buffers, sizeof(read_data)));
  446. s.reset(read_data, sizeof(read_data));
  447. s.next_read_length(1);
  448. memset(read_buf, 0, sizeof(read_buf));
  449. bytes_transferred = boost::asio::read(s, buffers,
  450. boost::asio::transfer_at_least(10));
  451. BOOST_ASIO_CHECK(bytes_transferred == 10);
  452. BOOST_ASIO_CHECK(s.check_buffers(buffers, 10));
  453. s.reset(read_data, sizeof(read_data));
  454. s.next_read_length(10);
  455. memset(read_buf, 0, sizeof(read_buf));
  456. bytes_transferred = boost::asio::read(s, buffers,
  457. boost::asio::transfer_at_least(10));
  458. BOOST_ASIO_CHECK(bytes_transferred == 10);
  459. BOOST_ASIO_CHECK(s.check_buffers(buffers, 10));
  460. s.reset(read_data, sizeof(read_data));
  461. memset(read_buf, 0, sizeof(read_buf));
  462. bytes_transferred = boost::asio::read(s, buffers,
  463. boost::asio::transfer_at_least(42));
  464. BOOST_ASIO_CHECK(bytes_transferred == sizeof(read_data));
  465. BOOST_ASIO_CHECK(s.check_buffers(buffers, sizeof(read_data)));
  466. s.reset(read_data, sizeof(read_data));
  467. s.next_read_length(1);
  468. memset(read_buf, 0, sizeof(read_buf));
  469. bytes_transferred = boost::asio::read(s, buffers,
  470. boost::asio::transfer_at_least(42));
  471. BOOST_ASIO_CHECK(bytes_transferred == 42);
  472. BOOST_ASIO_CHECK(s.check_buffers(buffers, 42));
  473. s.reset(read_data, sizeof(read_data));
  474. s.next_read_length(10);
  475. memset(read_buf, 0, sizeof(read_buf));
  476. bytes_transferred = boost::asio::read(s, buffers,
  477. boost::asio::transfer_at_least(42));
  478. BOOST_ASIO_CHECK(bytes_transferred == 50);
  479. BOOST_ASIO_CHECK(s.check_buffers(buffers, 50));
  480. s.reset(read_data, sizeof(read_data));
  481. memset(read_buf, 0, sizeof(read_buf));
  482. bytes_transferred = boost::asio::read(s, buffers,
  483. boost::asio::transfer_exactly(1));
  484. BOOST_ASIO_CHECK(bytes_transferred == 1);
  485. BOOST_ASIO_CHECK(s.check_buffers(buffers, 1));
  486. s.reset(read_data, sizeof(read_data));
  487. s.next_read_length(1);
  488. memset(read_buf, 0, sizeof(read_buf));
  489. bytes_transferred = boost::asio::read(s, buffers,
  490. boost::asio::transfer_exactly(1));
  491. BOOST_ASIO_CHECK(bytes_transferred == 1);
  492. BOOST_ASIO_CHECK(s.check_buffers(buffers, 1));
  493. s.reset(read_data, sizeof(read_data));
  494. s.next_read_length(10);
  495. memset(read_buf, 0, sizeof(read_buf));
  496. bytes_transferred = boost::asio::read(s, buffers,
  497. boost::asio::transfer_exactly(1));
  498. BOOST_ASIO_CHECK(bytes_transferred == 1);
  499. BOOST_ASIO_CHECK(s.check_buffers(buffers, 1));
  500. s.reset(read_data, sizeof(read_data));
  501. memset(read_buf, 0, sizeof(read_buf));
  502. bytes_transferred = boost::asio::read(s, buffers,
  503. boost::asio::transfer_exactly(10));
  504. BOOST_ASIO_CHECK(bytes_transferred == 10);
  505. BOOST_ASIO_CHECK(s.check_buffers(buffers, 10));
  506. s.reset(read_data, sizeof(read_data));
  507. s.next_read_length(1);
  508. memset(read_buf, 0, sizeof(read_buf));
  509. bytes_transferred = boost::asio::read(s, buffers,
  510. boost::asio::transfer_exactly(10));
  511. BOOST_ASIO_CHECK(bytes_transferred == 10);
  512. BOOST_ASIO_CHECK(s.check_buffers(buffers, 10));
  513. s.reset(read_data, sizeof(read_data));
  514. s.next_read_length(10);
  515. memset(read_buf, 0, sizeof(read_buf));
  516. bytes_transferred = boost::asio::read(s, buffers,
  517. boost::asio::transfer_exactly(10));
  518. BOOST_ASIO_CHECK(bytes_transferred == 10);
  519. BOOST_ASIO_CHECK(s.check_buffers(buffers, 10));
  520. s.reset(read_data, sizeof(read_data));
  521. memset(read_buf, 0, sizeof(read_buf));
  522. bytes_transferred = boost::asio::read(s, buffers,
  523. boost::asio::transfer_exactly(42));
  524. BOOST_ASIO_CHECK(bytes_transferred == 42);
  525. BOOST_ASIO_CHECK(s.check_buffers(buffers, 42));
  526. s.reset(read_data, sizeof(read_data));
  527. s.next_read_length(1);
  528. memset(read_buf, 0, sizeof(read_buf));
  529. bytes_transferred = boost::asio::read(s, buffers,
  530. boost::asio::transfer_exactly(42));
  531. BOOST_ASIO_CHECK(bytes_transferred == 42);
  532. BOOST_ASIO_CHECK(s.check_buffers(buffers, 42));
  533. s.reset(read_data, sizeof(read_data));
  534. s.next_read_length(10);
  535. memset(read_buf, 0, sizeof(read_buf));
  536. bytes_transferred = boost::asio::read(s, buffers,
  537. boost::asio::transfer_exactly(42));
  538. BOOST_ASIO_CHECK(bytes_transferred == 42);
  539. BOOST_ASIO_CHECK(s.check_buffers(buffers, 42));
  540. s.reset(read_data, sizeof(read_data));
  541. memset(read_buf, 0, sizeof(read_buf));
  542. bytes_transferred = boost::asio::read(s, buffers, old_style_transfer_all);
  543. BOOST_ASIO_CHECK(bytes_transferred == sizeof(read_data));
  544. BOOST_ASIO_CHECK(s.check_buffers(buffers, sizeof(read_data)));
  545. s.reset(read_data, sizeof(read_data));
  546. s.next_read_length(1);
  547. memset(read_buf, 0, sizeof(read_buf));
  548. bytes_transferred = boost::asio::read(s, buffers, old_style_transfer_all);
  549. BOOST_ASIO_CHECK(bytes_transferred == sizeof(read_data));
  550. BOOST_ASIO_CHECK(s.check_buffers(buffers, sizeof(read_data)));
  551. s.reset(read_data, sizeof(read_data));
  552. s.next_read_length(10);
  553. memset(read_buf, 0, sizeof(read_buf));
  554. bytes_transferred = boost::asio::read(s, buffers, old_style_transfer_all);
  555. BOOST_ASIO_CHECK(bytes_transferred == sizeof(read_data));
  556. BOOST_ASIO_CHECK(s.check_buffers(buffers, sizeof(read_data)));
  557. s.reset(read_data, sizeof(read_data));
  558. memset(read_buf, 0, sizeof(read_buf));
  559. bytes_transferred = boost::asio::read(s, buffers, short_transfer());
  560. BOOST_ASIO_CHECK(bytes_transferred == sizeof(read_data));
  561. BOOST_ASIO_CHECK(s.check_buffers(buffers, sizeof(read_data)));
  562. s.reset(read_data, sizeof(read_data));
  563. s.next_read_length(1);
  564. memset(read_buf, 0, sizeof(read_buf));
  565. bytes_transferred = boost::asio::read(s, buffers, short_transfer());
  566. BOOST_ASIO_CHECK(bytes_transferred == sizeof(read_data));
  567. BOOST_ASIO_CHECK(s.check_buffers(buffers, sizeof(read_data)));
  568. s.reset(read_data, sizeof(read_data));
  569. s.next_read_length(10);
  570. memset(read_buf, 0, sizeof(read_buf));
  571. bytes_transferred = boost::asio::read(s, buffers, short_transfer());
  572. BOOST_ASIO_CHECK(bytes_transferred == sizeof(read_data));
  573. BOOST_ASIO_CHECK(s.check_buffers(buffers, sizeof(read_data)));
  574. }
  575. void test_3_arg_vector_buffers_read()
  576. {
  577. boost::asio::io_context ioc;
  578. test_stream s(ioc);
  579. char read_buf[sizeof(read_data)];
  580. std::vector<boost::asio::mutable_buffer> buffers;
  581. buffers.push_back(boost::asio::buffer(read_buf, 32));
  582. buffers.push_back(boost::asio::buffer(read_buf, 39) + 32);
  583. buffers.push_back(boost::asio::buffer(read_buf) + 39);
  584. s.reset(read_data, sizeof(read_data));
  585. memset(read_buf, 0, sizeof(read_buf));
  586. size_t bytes_transferred = boost::asio::read(s, buffers,
  587. boost::asio::transfer_all());
  588. BOOST_ASIO_CHECK(bytes_transferred == sizeof(read_data));
  589. BOOST_ASIO_CHECK(s.check_buffers(buffers, sizeof(read_data)));
  590. s.reset(read_data, sizeof(read_data));
  591. s.next_read_length(1);
  592. memset(read_buf, 0, sizeof(read_buf));
  593. bytes_transferred = boost::asio::read(s, buffers,
  594. boost::asio::transfer_all());
  595. BOOST_ASIO_CHECK(bytes_transferred == sizeof(read_data));
  596. BOOST_ASIO_CHECK(s.check_buffers(buffers, sizeof(read_data)));
  597. s.reset(read_data, sizeof(read_data));
  598. s.next_read_length(10);
  599. memset(read_buf, 0, sizeof(read_buf));
  600. bytes_transferred = boost::asio::read(s, buffers,
  601. boost::asio::transfer_all());
  602. BOOST_ASIO_CHECK(bytes_transferred == sizeof(read_data));
  603. BOOST_ASIO_CHECK(s.check_buffers(buffers, sizeof(read_data)));
  604. s.reset(read_data, sizeof(read_data));
  605. memset(read_buf, 0, sizeof(read_buf));
  606. bytes_transferred = boost::asio::read(s, buffers,
  607. boost::asio::transfer_at_least(1));
  608. BOOST_ASIO_CHECK(bytes_transferred == sizeof(read_data));
  609. BOOST_ASIO_CHECK(s.check_buffers(buffers, sizeof(read_data)));
  610. s.reset(read_data, sizeof(read_data));
  611. s.next_read_length(1);
  612. memset(read_buf, 0, sizeof(read_buf));
  613. bytes_transferred = boost::asio::read(s, buffers,
  614. boost::asio::transfer_at_least(1));
  615. BOOST_ASIO_CHECK(bytes_transferred == 1);
  616. BOOST_ASIO_CHECK(s.check_buffers(buffers, 1));
  617. s.reset(read_data, sizeof(read_data));
  618. s.next_read_length(10);
  619. memset(read_buf, 0, sizeof(read_buf));
  620. bytes_transferred = boost::asio::read(s, buffers,
  621. boost::asio::transfer_at_least(1));
  622. BOOST_ASIO_CHECK(bytes_transferred == 10);
  623. BOOST_ASIO_CHECK(s.check_buffers(buffers, 10));
  624. s.reset(read_data, sizeof(read_data));
  625. memset(read_buf, 0, sizeof(read_buf));
  626. bytes_transferred = boost::asio::read(s, buffers,
  627. boost::asio::transfer_at_least(10));
  628. BOOST_ASIO_CHECK(bytes_transferred == sizeof(read_data));
  629. BOOST_ASIO_CHECK(s.check_buffers(buffers, sizeof(read_data)));
  630. s.reset(read_data, sizeof(read_data));
  631. s.next_read_length(1);
  632. memset(read_buf, 0, sizeof(read_buf));
  633. bytes_transferred = boost::asio::read(s, buffers,
  634. boost::asio::transfer_at_least(10));
  635. BOOST_ASIO_CHECK(bytes_transferred == 10);
  636. BOOST_ASIO_CHECK(s.check_buffers(buffers, 10));
  637. s.reset(read_data, sizeof(read_data));
  638. s.next_read_length(10);
  639. memset(read_buf, 0, sizeof(read_buf));
  640. bytes_transferred = boost::asio::read(s, buffers,
  641. boost::asio::transfer_at_least(10));
  642. BOOST_ASIO_CHECK(bytes_transferred == 10);
  643. BOOST_ASIO_CHECK(s.check_buffers(buffers, 10));
  644. s.reset(read_data, sizeof(read_data));
  645. memset(read_buf, 0, sizeof(read_buf));
  646. bytes_transferred = boost::asio::read(s, buffers,
  647. boost::asio::transfer_at_least(42));
  648. BOOST_ASIO_CHECK(bytes_transferred == sizeof(read_data));
  649. BOOST_ASIO_CHECK(s.check_buffers(buffers, sizeof(read_data)));
  650. s.reset(read_data, sizeof(read_data));
  651. s.next_read_length(1);
  652. memset(read_buf, 0, sizeof(read_buf));
  653. bytes_transferred = boost::asio::read(s, buffers,
  654. boost::asio::transfer_at_least(42));
  655. BOOST_ASIO_CHECK(bytes_transferred == 42);
  656. BOOST_ASIO_CHECK(s.check_buffers(buffers, 42));
  657. s.reset(read_data, sizeof(read_data));
  658. s.next_read_length(10);
  659. memset(read_buf, 0, sizeof(read_buf));
  660. bytes_transferred = boost::asio::read(s, buffers,
  661. boost::asio::transfer_at_least(42));
  662. BOOST_ASIO_CHECK(bytes_transferred == 50);
  663. BOOST_ASIO_CHECK(s.check_buffers(buffers, 50));
  664. s.reset(read_data, sizeof(read_data));
  665. memset(read_buf, 0, sizeof(read_buf));
  666. bytes_transferred = boost::asio::read(s, buffers,
  667. boost::asio::transfer_exactly(1));
  668. BOOST_ASIO_CHECK(bytes_transferred == 1);
  669. BOOST_ASIO_CHECK(s.check_buffers(buffers, 1));
  670. s.reset(read_data, sizeof(read_data));
  671. s.next_read_length(1);
  672. memset(read_buf, 0, sizeof(read_buf));
  673. bytes_transferred = boost::asio::read(s, buffers,
  674. boost::asio::transfer_exactly(1));
  675. BOOST_ASIO_CHECK(bytes_transferred == 1);
  676. BOOST_ASIO_CHECK(s.check_buffers(buffers, 1));
  677. s.reset(read_data, sizeof(read_data));
  678. s.next_read_length(10);
  679. memset(read_buf, 0, sizeof(read_buf));
  680. bytes_transferred = boost::asio::read(s, buffers,
  681. boost::asio::transfer_exactly(1));
  682. BOOST_ASIO_CHECK(bytes_transferred == 1);
  683. BOOST_ASIO_CHECK(s.check_buffers(buffers, 1));
  684. s.reset(read_data, sizeof(read_data));
  685. memset(read_buf, 0, sizeof(read_buf));
  686. bytes_transferred = boost::asio::read(s, buffers,
  687. boost::asio::transfer_exactly(10));
  688. BOOST_ASIO_CHECK(bytes_transferred == 10);
  689. BOOST_ASIO_CHECK(s.check_buffers(buffers, 10));
  690. s.reset(read_data, sizeof(read_data));
  691. s.next_read_length(1);
  692. memset(read_buf, 0, sizeof(read_buf));
  693. bytes_transferred = boost::asio::read(s, buffers,
  694. boost::asio::transfer_exactly(10));
  695. BOOST_ASIO_CHECK(bytes_transferred == 10);
  696. BOOST_ASIO_CHECK(s.check_buffers(buffers, 10));
  697. s.reset(read_data, sizeof(read_data));
  698. s.next_read_length(10);
  699. memset(read_buf, 0, sizeof(read_buf));
  700. bytes_transferred = boost::asio::read(s, buffers,
  701. boost::asio::transfer_exactly(10));
  702. BOOST_ASIO_CHECK(bytes_transferred == 10);
  703. BOOST_ASIO_CHECK(s.check_buffers(buffers, 10));
  704. s.reset(read_data, sizeof(read_data));
  705. memset(read_buf, 0, sizeof(read_buf));
  706. bytes_transferred = boost::asio::read(s, buffers,
  707. boost::asio::transfer_exactly(42));
  708. BOOST_ASIO_CHECK(bytes_transferred == 42);
  709. BOOST_ASIO_CHECK(s.check_buffers(buffers, 42));
  710. s.reset(read_data, sizeof(read_data));
  711. s.next_read_length(1);
  712. memset(read_buf, 0, sizeof(read_buf));
  713. bytes_transferred = boost::asio::read(s, buffers,
  714. boost::asio::transfer_exactly(42));
  715. BOOST_ASIO_CHECK(bytes_transferred == 42);
  716. BOOST_ASIO_CHECK(s.check_buffers(buffers, 42));
  717. s.reset(read_data, sizeof(read_data));
  718. s.next_read_length(10);
  719. memset(read_buf, 0, sizeof(read_buf));
  720. bytes_transferred = boost::asio::read(s, buffers,
  721. boost::asio::transfer_exactly(42));
  722. BOOST_ASIO_CHECK(bytes_transferred == 42);
  723. BOOST_ASIO_CHECK(s.check_buffers(buffers, 42));
  724. s.reset(read_data, sizeof(read_data));
  725. memset(read_buf, 0, sizeof(read_buf));
  726. bytes_transferred = boost::asio::read(s, buffers, old_style_transfer_all);
  727. BOOST_ASIO_CHECK(bytes_transferred == sizeof(read_data));
  728. BOOST_ASIO_CHECK(s.check_buffers(buffers, sizeof(read_data)));
  729. s.reset(read_data, sizeof(read_data));
  730. s.next_read_length(1);
  731. memset(read_buf, 0, sizeof(read_buf));
  732. bytes_transferred = boost::asio::read(s, buffers, old_style_transfer_all);
  733. BOOST_ASIO_CHECK(bytes_transferred == sizeof(read_data));
  734. BOOST_ASIO_CHECK(s.check_buffers(buffers, sizeof(read_data)));
  735. s.reset(read_data, sizeof(read_data));
  736. s.next_read_length(10);
  737. memset(read_buf, 0, sizeof(read_buf));
  738. bytes_transferred = boost::asio::read(s, buffers, old_style_transfer_all);
  739. BOOST_ASIO_CHECK(bytes_transferred == sizeof(read_data));
  740. BOOST_ASIO_CHECK(s.check_buffers(buffers, sizeof(read_data)));
  741. s.reset(read_data, sizeof(read_data));
  742. memset(read_buf, 0, sizeof(read_buf));
  743. bytes_transferred = boost::asio::read(s, buffers, short_transfer());
  744. BOOST_ASIO_CHECK(bytes_transferred == sizeof(read_data));
  745. BOOST_ASIO_CHECK(s.check_buffers(buffers, sizeof(read_data)));
  746. s.reset(read_data, sizeof(read_data));
  747. s.next_read_length(1);
  748. memset(read_buf, 0, sizeof(read_buf));
  749. bytes_transferred = boost::asio::read(s, buffers, short_transfer());
  750. BOOST_ASIO_CHECK(bytes_transferred == sizeof(read_data));
  751. BOOST_ASIO_CHECK(s.check_buffers(buffers, sizeof(read_data)));
  752. s.reset(read_data, sizeof(read_data));
  753. s.next_read_length(10);
  754. memset(read_buf, 0, sizeof(read_buf));
  755. bytes_transferred = boost::asio::read(s, buffers, short_transfer());
  756. BOOST_ASIO_CHECK(bytes_transferred == sizeof(read_data));
  757. BOOST_ASIO_CHECK(s.check_buffers(buffers, sizeof(read_data)));
  758. }
  759. void test_3_arg_dynamic_string_read()
  760. {
  761. boost::asio::io_context ioc;
  762. test_stream s(ioc);
  763. std::string data;
  764. boost::asio::dynamic_string_buffer<char, std::string::traits_type,
  765. std::string::allocator_type> sb
  766. = boost::asio::dynamic_buffer(data, sizeof(read_data));
  767. s.reset(read_data, sizeof(read_data));
  768. sb.consume(sb.size());
  769. size_t bytes_transferred = boost::asio::read(s, sb,
  770. boost::asio::transfer_all());
  771. BOOST_ASIO_CHECK(bytes_transferred == sizeof(read_data));
  772. BOOST_ASIO_CHECK(sb.size() == sizeof(read_data));
  773. BOOST_ASIO_CHECK(s.check_buffers(sb.data(0, sb.size()), sizeof(read_data)));
  774. s.reset(read_data, sizeof(read_data));
  775. s.next_read_length(1);
  776. sb.consume(sb.size());
  777. bytes_transferred = boost::asio::read(s, sb,
  778. boost::asio::transfer_all());
  779. BOOST_ASIO_CHECK(bytes_transferred == sizeof(read_data));
  780. BOOST_ASIO_CHECK(sb.size() == sizeof(read_data));
  781. BOOST_ASIO_CHECK(s.check_buffers(sb.data(0, sb.size()), sizeof(read_data)));
  782. s.reset(read_data, sizeof(read_data));
  783. s.next_read_length(10);
  784. sb.consume(sb.size());
  785. bytes_transferred = boost::asio::read(s, sb,
  786. boost::asio::transfer_all());
  787. BOOST_ASIO_CHECK(bytes_transferred == sizeof(read_data));
  788. BOOST_ASIO_CHECK(sb.size() == sizeof(read_data));
  789. BOOST_ASIO_CHECK(s.check_buffers(sb.data(0, sb.size()), sizeof(read_data)));
  790. s.reset(read_data, sizeof(read_data));
  791. sb.consume(sb.size());
  792. bytes_transferred = boost::asio::read(s, sb,
  793. boost::asio::transfer_at_least(1));
  794. BOOST_ASIO_CHECK(bytes_transferred == sizeof(read_data));
  795. BOOST_ASIO_CHECK(sb.size() == sizeof(read_data));
  796. BOOST_ASIO_CHECK(s.check_buffers(sb.data(0, sb.size()), sizeof(read_data)));
  797. s.reset(read_data, sizeof(read_data));
  798. s.next_read_length(1);
  799. sb.consume(sb.size());
  800. bytes_transferred = boost::asio::read(s, sb,
  801. boost::asio::transfer_at_least(1));
  802. BOOST_ASIO_CHECK(bytes_transferred == 1);
  803. BOOST_ASIO_CHECK(sb.size() == 1);
  804. BOOST_ASIO_CHECK(s.check_buffers(sb.data(0, sb.size()), 1));
  805. s.reset(read_data, sizeof(read_data));
  806. s.next_read_length(10);
  807. sb.consume(sb.size());
  808. bytes_transferred = boost::asio::read(s, sb,
  809. boost::asio::transfer_at_least(1));
  810. BOOST_ASIO_CHECK(bytes_transferred == 10);
  811. BOOST_ASIO_CHECK(sb.size() == 10);
  812. BOOST_ASIO_CHECK(s.check_buffers(sb.data(0, sb.size()), 10));
  813. s.reset(read_data, sizeof(read_data));
  814. sb.consume(sb.size());
  815. bytes_transferred = boost::asio::read(s, sb,
  816. boost::asio::transfer_at_least(10));
  817. BOOST_ASIO_CHECK(bytes_transferred == sizeof(read_data));
  818. BOOST_ASIO_CHECK(sb.size() == sizeof(read_data));
  819. BOOST_ASIO_CHECK(s.check_buffers(sb.data(0, sb.size()), sizeof(read_data)));
  820. s.reset(read_data, sizeof(read_data));
  821. s.next_read_length(1);
  822. sb.consume(sb.size());
  823. bytes_transferred = boost::asio::read(s, sb,
  824. boost::asio::transfer_at_least(10));
  825. BOOST_ASIO_CHECK(bytes_transferred == 10);
  826. BOOST_ASIO_CHECK(sb.size() == 10);
  827. BOOST_ASIO_CHECK(s.check_buffers(sb.data(0, sb.size()), 10));
  828. s.reset(read_data, sizeof(read_data));
  829. s.next_read_length(10);
  830. sb.consume(sb.size());
  831. bytes_transferred = boost::asio::read(s, sb,
  832. boost::asio::transfer_at_least(10));
  833. BOOST_ASIO_CHECK(bytes_transferred == 10);
  834. BOOST_ASIO_CHECK(sb.size() == 10);
  835. BOOST_ASIO_CHECK(s.check_buffers(sb.data(0, sb.size()), 10));
  836. s.reset(read_data, sizeof(read_data));
  837. sb.consume(sb.size());
  838. bytes_transferred = boost::asio::read(s, sb,
  839. boost::asio::transfer_at_least(42));
  840. BOOST_ASIO_CHECK(bytes_transferred == sizeof(read_data));
  841. BOOST_ASIO_CHECK(sb.size() == sizeof(read_data));
  842. BOOST_ASIO_CHECK(s.check_buffers(sb.data(0, sb.size()), sizeof(read_data)));
  843. s.reset(read_data, sizeof(read_data));
  844. s.next_read_length(1);
  845. sb.consume(sb.size());
  846. bytes_transferred = boost::asio::read(s, sb,
  847. boost::asio::transfer_at_least(42));
  848. BOOST_ASIO_CHECK(bytes_transferred == 42);
  849. BOOST_ASIO_CHECK(sb.size() == 42);
  850. BOOST_ASIO_CHECK(s.check_buffers(sb.data(0, sb.size()), 42));
  851. s.reset(read_data, sizeof(read_data));
  852. s.next_read_length(10);
  853. sb.consume(sb.size());
  854. bytes_transferred = boost::asio::read(s, sb,
  855. boost::asio::transfer_at_least(42));
  856. BOOST_ASIO_CHECK(bytes_transferred == 50);
  857. BOOST_ASIO_CHECK(sb.size() == 50);
  858. BOOST_ASIO_CHECK(s.check_buffers(sb.data(0, sb.size()), 50));
  859. s.reset(read_data, sizeof(read_data));
  860. sb.consume(sb.size());
  861. bytes_transferred = boost::asio::read(s, sb,
  862. boost::asio::transfer_exactly(1));
  863. BOOST_ASIO_CHECK(bytes_transferred == 1);
  864. BOOST_ASIO_CHECK(sb.size() == 1);
  865. BOOST_ASIO_CHECK(s.check_buffers(sb.data(0, sb.size()), 1));
  866. s.reset(read_data, sizeof(read_data));
  867. s.next_read_length(1);
  868. sb.consume(sb.size());
  869. bytes_transferred = boost::asio::read(s, sb,
  870. boost::asio::transfer_exactly(1));
  871. BOOST_ASIO_CHECK(bytes_transferred == 1);
  872. BOOST_ASIO_CHECK(sb.size() == 1);
  873. BOOST_ASIO_CHECK(s.check_buffers(sb.data(0, sb.size()), 1));
  874. s.reset(read_data, sizeof(read_data));
  875. s.next_read_length(10);
  876. sb.consume(sb.size());
  877. bytes_transferred = boost::asio::read(s, sb,
  878. boost::asio::transfer_exactly(1));
  879. BOOST_ASIO_CHECK(bytes_transferred == 1);
  880. BOOST_ASIO_CHECK(sb.size() == 1);
  881. BOOST_ASIO_CHECK(s.check_buffers(sb.data(0, sb.size()), 1));
  882. s.reset(read_data, sizeof(read_data));
  883. sb.consume(sb.size());
  884. bytes_transferred = boost::asio::read(s, sb,
  885. boost::asio::transfer_exactly(10));
  886. BOOST_ASIO_CHECK(bytes_transferred == 10);
  887. BOOST_ASIO_CHECK(sb.size() == 10);
  888. BOOST_ASIO_CHECK(s.check_buffers(sb.data(0, sb.size()), 10));
  889. s.reset(read_data, sizeof(read_data));
  890. s.next_read_length(1);
  891. sb.consume(sb.size());
  892. bytes_transferred = boost::asio::read(s, sb,
  893. boost::asio::transfer_exactly(10));
  894. BOOST_ASIO_CHECK(bytes_transferred == 10);
  895. BOOST_ASIO_CHECK(sb.size() == 10);
  896. BOOST_ASIO_CHECK(s.check_buffers(sb.data(0, sb.size()), 10));
  897. s.reset(read_data, sizeof(read_data));
  898. s.next_read_length(10);
  899. sb.consume(sb.size());
  900. bytes_transferred = boost::asio::read(s, sb,
  901. boost::asio::transfer_exactly(10));
  902. BOOST_ASIO_CHECK(bytes_transferred == 10);
  903. BOOST_ASIO_CHECK(sb.size() == 10);
  904. BOOST_ASIO_CHECK(s.check_buffers(sb.data(0, sb.size()), 10));
  905. s.reset(read_data, sizeof(read_data));
  906. sb.consume(sb.size());
  907. bytes_transferred = boost::asio::read(s, sb,
  908. boost::asio::transfer_exactly(42));
  909. BOOST_ASIO_CHECK(bytes_transferred == 42);
  910. BOOST_ASIO_CHECK(sb.size() == 42);
  911. BOOST_ASIO_CHECK(s.check_buffers(sb.data(0, sb.size()), 42));
  912. s.reset(read_data, sizeof(read_data));
  913. s.next_read_length(1);
  914. sb.consume(sb.size());
  915. bytes_transferred = boost::asio::read(s, sb,
  916. boost::asio::transfer_exactly(42));
  917. BOOST_ASIO_CHECK(bytes_transferred == 42);
  918. BOOST_ASIO_CHECK(sb.size() == 42);
  919. BOOST_ASIO_CHECK(s.check_buffers(sb.data(0, sb.size()), 42));
  920. s.reset(read_data, sizeof(read_data));
  921. s.next_read_length(10);
  922. sb.consume(sb.size());
  923. bytes_transferred = boost::asio::read(s, sb,
  924. boost::asio::transfer_exactly(42));
  925. BOOST_ASIO_CHECK(bytes_transferred == 42);
  926. BOOST_ASIO_CHECK(sb.size() == 42);
  927. BOOST_ASIO_CHECK(s.check_buffers(sb.data(0, sb.size()), 42));
  928. s.reset(read_data, sizeof(read_data));
  929. sb.consume(sb.size());
  930. bytes_transferred = boost::asio::read(s, sb, old_style_transfer_all);
  931. BOOST_ASIO_CHECK(bytes_transferred == sizeof(read_data));
  932. BOOST_ASIO_CHECK(sb.size() == sizeof(read_data));
  933. BOOST_ASIO_CHECK(s.check_buffers(sb.data(0, sb.size()), sizeof(read_data)));
  934. s.reset(read_data, sizeof(read_data));
  935. s.next_read_length(1);
  936. sb.consume(sb.size());
  937. bytes_transferred = boost::asio::read(s, sb, old_style_transfer_all);
  938. BOOST_ASIO_CHECK(bytes_transferred == sizeof(read_data));
  939. BOOST_ASIO_CHECK(sb.size() == sizeof(read_data));
  940. BOOST_ASIO_CHECK(s.check_buffers(sb.data(0, sb.size()), sizeof(read_data)));
  941. s.reset(read_data, sizeof(read_data));
  942. s.next_read_length(10);
  943. sb.consume(sb.size());
  944. bytes_transferred = boost::asio::read(s, sb, old_style_transfer_all);
  945. BOOST_ASIO_CHECK(bytes_transferred == sizeof(read_data));
  946. BOOST_ASIO_CHECK(sb.size() == sizeof(read_data));
  947. BOOST_ASIO_CHECK(s.check_buffers(sb.data(0, sb.size()), sizeof(read_data)));
  948. s.reset(read_data, sizeof(read_data));
  949. sb.consume(sb.size());
  950. bytes_transferred = boost::asio::read(s, sb, short_transfer());
  951. BOOST_ASIO_CHECK(bytes_transferred == sizeof(read_data));
  952. BOOST_ASIO_CHECK(sb.size() == sizeof(read_data));
  953. BOOST_ASIO_CHECK(s.check_buffers(sb.data(0, sb.size()), sizeof(read_data)));
  954. s.reset(read_data, sizeof(read_data));
  955. s.next_read_length(1);
  956. sb.consume(sb.size());
  957. bytes_transferred = boost::asio::read(s, sb, short_transfer());
  958. BOOST_ASIO_CHECK(bytes_transferred == sizeof(read_data));
  959. BOOST_ASIO_CHECK(sb.size() == sizeof(read_data));
  960. BOOST_ASIO_CHECK(s.check_buffers(sb.data(0, sb.size()), sizeof(read_data)));
  961. s.reset(read_data, sizeof(read_data));
  962. s.next_read_length(10);
  963. sb.consume(sb.size());
  964. bytes_transferred = boost::asio::read(s, sb, short_transfer());
  965. BOOST_ASIO_CHECK(bytes_transferred == sizeof(read_data));
  966. BOOST_ASIO_CHECK(sb.size() == sizeof(read_data));
  967. BOOST_ASIO_CHECK(s.check_buffers(sb.data(0, sb.size()), sizeof(read_data)));
  968. }
  969. void test_3_arg_streambuf_read()
  970. {
  971. #if !defined(BOOST_ASIO_NO_DYNAMIC_BUFFER_V1)
  972. boost::asio::io_context ioc;
  973. test_stream s(ioc);
  974. boost::asio::streambuf sb(sizeof(read_data));
  975. s.reset(read_data, sizeof(read_data));
  976. sb.consume(sb.size());
  977. size_t bytes_transferred = boost::asio::read(s, sb,
  978. boost::asio::transfer_all());
  979. BOOST_ASIO_CHECK(bytes_transferred == sizeof(read_data));
  980. BOOST_ASIO_CHECK(sb.size() == sizeof(read_data));
  981. BOOST_ASIO_CHECK(s.check_buffers(sb.data(), sizeof(read_data)));
  982. s.reset(read_data, sizeof(read_data));
  983. s.next_read_length(1);
  984. sb.consume(sb.size());
  985. bytes_transferred = boost::asio::read(s, sb,
  986. boost::asio::transfer_all());
  987. BOOST_ASIO_CHECK(bytes_transferred == sizeof(read_data));
  988. BOOST_ASIO_CHECK(sb.size() == sizeof(read_data));
  989. BOOST_ASIO_CHECK(s.check_buffers(sb.data(), sizeof(read_data)));
  990. s.reset(read_data, sizeof(read_data));
  991. s.next_read_length(10);
  992. sb.consume(sb.size());
  993. bytes_transferred = boost::asio::read(s, sb,
  994. boost::asio::transfer_all());
  995. BOOST_ASIO_CHECK(bytes_transferred == sizeof(read_data));
  996. BOOST_ASIO_CHECK(sb.size() == sizeof(read_data));
  997. BOOST_ASIO_CHECK(s.check_buffers(sb.data(), sizeof(read_data)));
  998. s.reset(read_data, sizeof(read_data));
  999. sb.consume(sb.size());
  1000. bytes_transferred = boost::asio::read(s, sb,
  1001. boost::asio::transfer_at_least(1));
  1002. BOOST_ASIO_CHECK(bytes_transferred == sizeof(read_data));
  1003. BOOST_ASIO_CHECK(sb.size() == sizeof(read_data));
  1004. BOOST_ASIO_CHECK(s.check_buffers(sb.data(), sizeof(read_data)));
  1005. s.reset(read_data, sizeof(read_data));
  1006. s.next_read_length(1);
  1007. sb.consume(sb.size());
  1008. bytes_transferred = boost::asio::read(s, sb,
  1009. boost::asio::transfer_at_least(1));
  1010. BOOST_ASIO_CHECK(bytes_transferred == 1);
  1011. BOOST_ASIO_CHECK(sb.size() == 1);
  1012. BOOST_ASIO_CHECK(s.check_buffers(sb.data(), 1));
  1013. s.reset(read_data, sizeof(read_data));
  1014. s.next_read_length(10);
  1015. sb.consume(sb.size());
  1016. bytes_transferred = boost::asio::read(s, sb,
  1017. boost::asio::transfer_at_least(1));
  1018. BOOST_ASIO_CHECK(bytes_transferred == 10);
  1019. BOOST_ASIO_CHECK(sb.size() == 10);
  1020. BOOST_ASIO_CHECK(s.check_buffers(sb.data(), 10));
  1021. s.reset(read_data, sizeof(read_data));
  1022. sb.consume(sb.size());
  1023. bytes_transferred = boost::asio::read(s, sb,
  1024. boost::asio::transfer_at_least(10));
  1025. BOOST_ASIO_CHECK(bytes_transferred == sizeof(read_data));
  1026. BOOST_ASIO_CHECK(sb.size() == sizeof(read_data));
  1027. BOOST_ASIO_CHECK(s.check_buffers(sb.data(), sizeof(read_data)));
  1028. s.reset(read_data, sizeof(read_data));
  1029. s.next_read_length(1);
  1030. sb.consume(sb.size());
  1031. bytes_transferred = boost::asio::read(s, sb,
  1032. boost::asio::transfer_at_least(10));
  1033. BOOST_ASIO_CHECK(bytes_transferred == 10);
  1034. BOOST_ASIO_CHECK(sb.size() == 10);
  1035. BOOST_ASIO_CHECK(s.check_buffers(sb.data(), 10));
  1036. s.reset(read_data, sizeof(read_data));
  1037. s.next_read_length(10);
  1038. sb.consume(sb.size());
  1039. bytes_transferred = boost::asio::read(s, sb,
  1040. boost::asio::transfer_at_least(10));
  1041. BOOST_ASIO_CHECK(bytes_transferred == 10);
  1042. BOOST_ASIO_CHECK(sb.size() == 10);
  1043. BOOST_ASIO_CHECK(s.check_buffers(sb.data(), 10));
  1044. s.reset(read_data, sizeof(read_data));
  1045. sb.consume(sb.size());
  1046. bytes_transferred = boost::asio::read(s, sb,
  1047. boost::asio::transfer_at_least(42));
  1048. BOOST_ASIO_CHECK(bytes_transferred == sizeof(read_data));
  1049. BOOST_ASIO_CHECK(sb.size() == sizeof(read_data));
  1050. BOOST_ASIO_CHECK(s.check_buffers(sb.data(), sizeof(read_data)));
  1051. s.reset(read_data, sizeof(read_data));
  1052. s.next_read_length(1);
  1053. sb.consume(sb.size());
  1054. bytes_transferred = boost::asio::read(s, sb,
  1055. boost::asio::transfer_at_least(42));
  1056. BOOST_ASIO_CHECK(bytes_transferred == 42);
  1057. BOOST_ASIO_CHECK(sb.size() == 42);
  1058. BOOST_ASIO_CHECK(s.check_buffers(sb.data(), 42));
  1059. s.reset(read_data, sizeof(read_data));
  1060. s.next_read_length(10);
  1061. sb.consume(sb.size());
  1062. bytes_transferred = boost::asio::read(s, sb,
  1063. boost::asio::transfer_at_least(42));
  1064. BOOST_ASIO_CHECK(bytes_transferred == 50);
  1065. BOOST_ASIO_CHECK(sb.size() == 50);
  1066. BOOST_ASIO_CHECK(s.check_buffers(sb.data(), 50));
  1067. s.reset(read_data, sizeof(read_data));
  1068. sb.consume(sb.size());
  1069. bytes_transferred = boost::asio::read(s, sb,
  1070. boost::asio::transfer_exactly(1));
  1071. BOOST_ASIO_CHECK(bytes_transferred == 1);
  1072. BOOST_ASIO_CHECK(sb.size() == 1);
  1073. BOOST_ASIO_CHECK(s.check_buffers(sb.data(), 1));
  1074. s.reset(read_data, sizeof(read_data));
  1075. s.next_read_length(1);
  1076. sb.consume(sb.size());
  1077. bytes_transferred = boost::asio::read(s, sb,
  1078. boost::asio::transfer_exactly(1));
  1079. BOOST_ASIO_CHECK(bytes_transferred == 1);
  1080. BOOST_ASIO_CHECK(sb.size() == 1);
  1081. BOOST_ASIO_CHECK(s.check_buffers(sb.data(), 1));
  1082. s.reset(read_data, sizeof(read_data));
  1083. s.next_read_length(10);
  1084. sb.consume(sb.size());
  1085. bytes_transferred = boost::asio::read(s, sb,
  1086. boost::asio::transfer_exactly(1));
  1087. BOOST_ASIO_CHECK(bytes_transferred == 1);
  1088. BOOST_ASIO_CHECK(sb.size() == 1);
  1089. BOOST_ASIO_CHECK(s.check_buffers(sb.data(), 1));
  1090. s.reset(read_data, sizeof(read_data));
  1091. sb.consume(sb.size());
  1092. bytes_transferred = boost::asio::read(s, sb,
  1093. boost::asio::transfer_exactly(10));
  1094. BOOST_ASIO_CHECK(bytes_transferred == 10);
  1095. BOOST_ASIO_CHECK(sb.size() == 10);
  1096. BOOST_ASIO_CHECK(s.check_buffers(sb.data(), 10));
  1097. s.reset(read_data, sizeof(read_data));
  1098. s.next_read_length(1);
  1099. sb.consume(sb.size());
  1100. bytes_transferred = boost::asio::read(s, sb,
  1101. boost::asio::transfer_exactly(10));
  1102. BOOST_ASIO_CHECK(bytes_transferred == 10);
  1103. BOOST_ASIO_CHECK(sb.size() == 10);
  1104. BOOST_ASIO_CHECK(s.check_buffers(sb.data(), 10));
  1105. s.reset(read_data, sizeof(read_data));
  1106. s.next_read_length(10);
  1107. sb.consume(sb.size());
  1108. bytes_transferred = boost::asio::read(s, sb,
  1109. boost::asio::transfer_exactly(10));
  1110. BOOST_ASIO_CHECK(bytes_transferred == 10);
  1111. BOOST_ASIO_CHECK(sb.size() == 10);
  1112. BOOST_ASIO_CHECK(s.check_buffers(sb.data(), 10));
  1113. s.reset(read_data, sizeof(read_data));
  1114. sb.consume(sb.size());
  1115. bytes_transferred = boost::asio::read(s, sb,
  1116. boost::asio::transfer_exactly(42));
  1117. BOOST_ASIO_CHECK(bytes_transferred == 42);
  1118. BOOST_ASIO_CHECK(sb.size() == 42);
  1119. BOOST_ASIO_CHECK(s.check_buffers(sb.data(), 42));
  1120. s.reset(read_data, sizeof(read_data));
  1121. s.next_read_length(1);
  1122. sb.consume(sb.size());
  1123. bytes_transferred = boost::asio::read(s, sb,
  1124. boost::asio::transfer_exactly(42));
  1125. BOOST_ASIO_CHECK(bytes_transferred == 42);
  1126. BOOST_ASIO_CHECK(sb.size() == 42);
  1127. BOOST_ASIO_CHECK(s.check_buffers(sb.data(), 42));
  1128. s.reset(read_data, sizeof(read_data));
  1129. s.next_read_length(10);
  1130. sb.consume(sb.size());
  1131. bytes_transferred = boost::asio::read(s, sb,
  1132. boost::asio::transfer_exactly(42));
  1133. BOOST_ASIO_CHECK(bytes_transferred == 42);
  1134. BOOST_ASIO_CHECK(sb.size() == 42);
  1135. BOOST_ASIO_CHECK(s.check_buffers(sb.data(), 42));
  1136. s.reset(read_data, sizeof(read_data));
  1137. sb.consume(sb.size());
  1138. bytes_transferred = boost::asio::read(s, sb, old_style_transfer_all);
  1139. BOOST_ASIO_CHECK(bytes_transferred == sizeof(read_data));
  1140. BOOST_ASIO_CHECK(sb.size() == sizeof(read_data));
  1141. BOOST_ASIO_CHECK(s.check_buffers(sb.data(), sizeof(read_data)));
  1142. s.reset(read_data, sizeof(read_data));
  1143. s.next_read_length(1);
  1144. sb.consume(sb.size());
  1145. bytes_transferred = boost::asio::read(s, sb, old_style_transfer_all);
  1146. BOOST_ASIO_CHECK(bytes_transferred == sizeof(read_data));
  1147. BOOST_ASIO_CHECK(sb.size() == sizeof(read_data));
  1148. BOOST_ASIO_CHECK(s.check_buffers(sb.data(), sizeof(read_data)));
  1149. s.reset(read_data, sizeof(read_data));
  1150. s.next_read_length(10);
  1151. sb.consume(sb.size());
  1152. bytes_transferred = boost::asio::read(s, sb, old_style_transfer_all);
  1153. BOOST_ASIO_CHECK(bytes_transferred == sizeof(read_data));
  1154. BOOST_ASIO_CHECK(sb.size() == sizeof(read_data));
  1155. BOOST_ASIO_CHECK(s.check_buffers(sb.data(), sizeof(read_data)));
  1156. s.reset(read_data, sizeof(read_data));
  1157. sb.consume(sb.size());
  1158. bytes_transferred = boost::asio::read(s, sb, short_transfer());
  1159. BOOST_ASIO_CHECK(bytes_transferred == sizeof(read_data));
  1160. BOOST_ASIO_CHECK(sb.size() == sizeof(read_data));
  1161. BOOST_ASIO_CHECK(s.check_buffers(sb.data(), sizeof(read_data)));
  1162. s.reset(read_data, sizeof(read_data));
  1163. s.next_read_length(1);
  1164. sb.consume(sb.size());
  1165. bytes_transferred = boost::asio::read(s, sb, short_transfer());
  1166. BOOST_ASIO_CHECK(bytes_transferred == sizeof(read_data));
  1167. BOOST_ASIO_CHECK(sb.size() == sizeof(read_data));
  1168. BOOST_ASIO_CHECK(s.check_buffers(sb.data(), sizeof(read_data)));
  1169. s.reset(read_data, sizeof(read_data));
  1170. s.next_read_length(10);
  1171. sb.consume(sb.size());
  1172. bytes_transferred = boost::asio::read(s, sb, short_transfer());
  1173. BOOST_ASIO_CHECK(bytes_transferred == sizeof(read_data));
  1174. BOOST_ASIO_CHECK(sb.size() == sizeof(read_data));
  1175. BOOST_ASIO_CHECK(s.check_buffers(sb.data(), sizeof(read_data)));
  1176. #endif // !defined(BOOST_ASIO_NO_DYNAMIC_BUFFER_V1)
  1177. }
  1178. void test_4_arg_mutable_buffer_read()
  1179. {
  1180. boost::asio::io_context ioc;
  1181. test_stream s(ioc);
  1182. char read_buf[sizeof(read_data)];
  1183. boost::asio::mutable_buffer buffers
  1184. = boost::asio::buffer(read_buf, sizeof(read_buf));
  1185. s.reset(read_data, sizeof(read_data));
  1186. memset(read_buf, 0, sizeof(read_buf));
  1187. boost::system::error_code error;
  1188. size_t bytes_transferred = boost::asio::read(s, buffers,
  1189. boost::asio::transfer_all(), error);
  1190. BOOST_ASIO_CHECK(bytes_transferred == sizeof(read_data));
  1191. BOOST_ASIO_CHECK(s.check_buffers(buffers, sizeof(read_data)));
  1192. BOOST_ASIO_CHECK(!error);
  1193. s.reset(read_data, sizeof(read_data));
  1194. s.next_read_length(1);
  1195. memset(read_buf, 0, sizeof(read_buf));
  1196. error = boost::system::error_code();
  1197. bytes_transferred = boost::asio::read(s, buffers,
  1198. boost::asio::transfer_all(), error);
  1199. BOOST_ASIO_CHECK(bytes_transferred == sizeof(read_data));
  1200. BOOST_ASIO_CHECK(s.check_buffers(buffers, sizeof(read_data)));
  1201. BOOST_ASIO_CHECK(!error);
  1202. s.reset(read_data, sizeof(read_data));
  1203. s.next_read_length(10);
  1204. memset(read_buf, 0, sizeof(read_buf));
  1205. error = boost::system::error_code();
  1206. bytes_transferred = boost::asio::read(s, buffers,
  1207. boost::asio::transfer_all(), error);
  1208. BOOST_ASIO_CHECK(bytes_transferred == sizeof(read_data));
  1209. BOOST_ASIO_CHECK(s.check_buffers(buffers, sizeof(read_data)));
  1210. BOOST_ASIO_CHECK(!error);
  1211. s.reset(read_data, sizeof(read_data));
  1212. memset(read_buf, 0, sizeof(read_buf));
  1213. error = boost::system::error_code();
  1214. bytes_transferred = boost::asio::read(s, buffers,
  1215. boost::asio::transfer_at_least(1), error);
  1216. BOOST_ASIO_CHECK(bytes_transferred == sizeof(read_data));
  1217. BOOST_ASIO_CHECK(s.check_buffers(buffers, sizeof(read_data)));
  1218. BOOST_ASIO_CHECK(!error);
  1219. s.reset(read_data, sizeof(read_data));
  1220. s.next_read_length(1);
  1221. memset(read_buf, 0, sizeof(read_buf));
  1222. error = boost::system::error_code();
  1223. bytes_transferred = boost::asio::read(s, buffers,
  1224. boost::asio::transfer_at_least(1), error);
  1225. BOOST_ASIO_CHECK(bytes_transferred == 1);
  1226. BOOST_ASIO_CHECK(s.check_buffers(buffers, 1));
  1227. BOOST_ASIO_CHECK(!error);
  1228. s.reset(read_data, sizeof(read_data));
  1229. s.next_read_length(10);
  1230. memset(read_buf, 0, sizeof(read_buf));
  1231. error = boost::system::error_code();
  1232. bytes_transferred = boost::asio::read(s, buffers,
  1233. boost::asio::transfer_at_least(1), error);
  1234. BOOST_ASIO_CHECK(bytes_transferred == 10);
  1235. BOOST_ASIO_CHECK(s.check_buffers(buffers, 10));
  1236. BOOST_ASIO_CHECK(!error);
  1237. s.reset(read_data, sizeof(read_data));
  1238. memset(read_buf, 0, sizeof(read_buf));
  1239. error = boost::system::error_code();
  1240. bytes_transferred = boost::asio::read(s, buffers,
  1241. boost::asio::transfer_at_least(10), error);
  1242. BOOST_ASIO_CHECK(bytes_transferred == sizeof(read_data));
  1243. BOOST_ASIO_CHECK(s.check_buffers(buffers, sizeof(read_data)));
  1244. BOOST_ASIO_CHECK(!error);
  1245. s.reset(read_data, sizeof(read_data));
  1246. s.next_read_length(1);
  1247. memset(read_buf, 0, sizeof(read_buf));
  1248. error = boost::system::error_code();
  1249. bytes_transferred = boost::asio::read(s, buffers,
  1250. boost::asio::transfer_at_least(10), error);
  1251. BOOST_ASIO_CHECK(bytes_transferred == 10);
  1252. BOOST_ASIO_CHECK(s.check_buffers(buffers, 10));
  1253. BOOST_ASIO_CHECK(!error);
  1254. s.reset(read_data, sizeof(read_data));
  1255. s.next_read_length(10);
  1256. memset(read_buf, 0, sizeof(read_buf));
  1257. error = boost::system::error_code();
  1258. bytes_transferred = boost::asio::read(s, buffers,
  1259. boost::asio::transfer_at_least(10), error);
  1260. BOOST_ASIO_CHECK(bytes_transferred == 10);
  1261. BOOST_ASIO_CHECK(s.check_buffers(buffers, 10));
  1262. BOOST_ASIO_CHECK(!error);
  1263. s.reset(read_data, sizeof(read_data));
  1264. memset(read_buf, 0, sizeof(read_buf));
  1265. error = boost::system::error_code();
  1266. bytes_transferred = boost::asio::read(s, buffers,
  1267. boost::asio::transfer_at_least(42), error);
  1268. BOOST_ASIO_CHECK(bytes_transferred == sizeof(read_data));
  1269. BOOST_ASIO_CHECK(s.check_buffers(buffers, sizeof(read_data)));
  1270. BOOST_ASIO_CHECK(!error);
  1271. s.reset(read_data, sizeof(read_data));
  1272. s.next_read_length(1);
  1273. memset(read_buf, 0, sizeof(read_buf));
  1274. error = boost::system::error_code();
  1275. bytes_transferred = boost::asio::read(s, buffers,
  1276. boost::asio::transfer_at_least(42), error);
  1277. BOOST_ASIO_CHECK(bytes_transferred == 42);
  1278. BOOST_ASIO_CHECK(s.check_buffers(buffers, 42));
  1279. BOOST_ASIO_CHECK(!error);
  1280. s.reset(read_data, sizeof(read_data));
  1281. s.next_read_length(10);
  1282. memset(read_buf, 0, sizeof(read_buf));
  1283. error = boost::system::error_code();
  1284. bytes_transferred = boost::asio::read(s, buffers,
  1285. boost::asio::transfer_at_least(42), error);
  1286. BOOST_ASIO_CHECK(bytes_transferred == 50);
  1287. BOOST_ASIO_CHECK(s.check_buffers(buffers, 50));
  1288. BOOST_ASIO_CHECK(!error);
  1289. s.reset(read_data, sizeof(read_data));
  1290. memset(read_buf, 0, sizeof(read_buf));
  1291. error = boost::system::error_code();
  1292. bytes_transferred = boost::asio::read(s, buffers,
  1293. boost::asio::transfer_exactly(1), error);
  1294. BOOST_ASIO_CHECK(bytes_transferred == 1);
  1295. BOOST_ASIO_CHECK(s.check_buffers(buffers, 1));
  1296. BOOST_ASIO_CHECK(!error);
  1297. s.reset(read_data, sizeof(read_data));
  1298. s.next_read_length(1);
  1299. memset(read_buf, 0, sizeof(read_buf));
  1300. error = boost::system::error_code();
  1301. bytes_transferred = boost::asio::read(s, buffers,
  1302. boost::asio::transfer_exactly(1), error);
  1303. BOOST_ASIO_CHECK(bytes_transferred == 1);
  1304. BOOST_ASIO_CHECK(s.check_buffers(buffers, 1));
  1305. BOOST_ASIO_CHECK(!error);
  1306. s.reset(read_data, sizeof(read_data));
  1307. s.next_read_length(10);
  1308. memset(read_buf, 0, sizeof(read_buf));
  1309. error = boost::system::error_code();
  1310. bytes_transferred = boost::asio::read(s, buffers,
  1311. boost::asio::transfer_exactly(1), error);
  1312. BOOST_ASIO_CHECK(bytes_transferred == 1);
  1313. BOOST_ASIO_CHECK(s.check_buffers(buffers, 1));
  1314. BOOST_ASIO_CHECK(!error);
  1315. s.reset(read_data, sizeof(read_data));
  1316. memset(read_buf, 0, sizeof(read_buf));
  1317. error = boost::system::error_code();
  1318. bytes_transferred = boost::asio::read(s, buffers,
  1319. boost::asio::transfer_exactly(10), error);
  1320. BOOST_ASIO_CHECK(bytes_transferred == 10);
  1321. BOOST_ASIO_CHECK(s.check_buffers(buffers, 10));
  1322. BOOST_ASIO_CHECK(!error);
  1323. s.reset(read_data, sizeof(read_data));
  1324. s.next_read_length(1);
  1325. memset(read_buf, 0, sizeof(read_buf));
  1326. error = boost::system::error_code();
  1327. bytes_transferred = boost::asio::read(s, buffers,
  1328. boost::asio::transfer_exactly(10), error);
  1329. BOOST_ASIO_CHECK(bytes_transferred == 10);
  1330. BOOST_ASIO_CHECK(s.check_buffers(buffers, 10));
  1331. BOOST_ASIO_CHECK(!error);
  1332. s.reset(read_data, sizeof(read_data));
  1333. s.next_read_length(10);
  1334. memset(read_buf, 0, sizeof(read_buf));
  1335. error = boost::system::error_code();
  1336. bytes_transferred = boost::asio::read(s, buffers,
  1337. boost::asio::transfer_exactly(10), error);
  1338. BOOST_ASIO_CHECK(bytes_transferred == 10);
  1339. BOOST_ASIO_CHECK(s.check_buffers(buffers, 10));
  1340. BOOST_ASIO_CHECK(!error);
  1341. s.reset(read_data, sizeof(read_data));
  1342. memset(read_buf, 0, sizeof(read_buf));
  1343. error = boost::system::error_code();
  1344. bytes_transferred = boost::asio::read(s, buffers,
  1345. boost::asio::transfer_exactly(42), error);
  1346. BOOST_ASIO_CHECK(bytes_transferred == 42);
  1347. BOOST_ASIO_CHECK(s.check_buffers(buffers, 42));
  1348. BOOST_ASIO_CHECK(!error);
  1349. s.reset(read_data, sizeof(read_data));
  1350. s.next_read_length(1);
  1351. memset(read_buf, 0, sizeof(read_buf));
  1352. error = boost::system::error_code();
  1353. bytes_transferred = boost::asio::read(s, buffers,
  1354. boost::asio::transfer_exactly(42), error);
  1355. BOOST_ASIO_CHECK(bytes_transferred == 42);
  1356. BOOST_ASIO_CHECK(s.check_buffers(buffers, 42));
  1357. BOOST_ASIO_CHECK(!error);
  1358. s.reset(read_data, sizeof(read_data));
  1359. s.next_read_length(10);
  1360. memset(read_buf, 0, sizeof(read_buf));
  1361. error = boost::system::error_code();
  1362. bytes_transferred = boost::asio::read(s, buffers,
  1363. boost::asio::transfer_exactly(42), error);
  1364. BOOST_ASIO_CHECK(bytes_transferred == 42);
  1365. BOOST_ASIO_CHECK(s.check_buffers(buffers, 42));
  1366. BOOST_ASIO_CHECK(!error);
  1367. s.reset(read_data, sizeof(read_data));
  1368. memset(read_buf, 0, sizeof(read_buf));
  1369. bytes_transferred = boost::asio::read(s, buffers,
  1370. old_style_transfer_all, error);
  1371. BOOST_ASIO_CHECK(bytes_transferred == sizeof(read_data));
  1372. BOOST_ASIO_CHECK(s.check_buffers(buffers, sizeof(read_data)));
  1373. BOOST_ASIO_CHECK(!error);
  1374. s.reset(read_data, sizeof(read_data));
  1375. s.next_read_length(1);
  1376. memset(read_buf, 0, sizeof(read_buf));
  1377. error = boost::system::error_code();
  1378. bytes_transferred = boost::asio::read(s, buffers,
  1379. old_style_transfer_all, error);
  1380. BOOST_ASIO_CHECK(bytes_transferred == sizeof(read_data));
  1381. BOOST_ASIO_CHECK(s.check_buffers(buffers, sizeof(read_data)));
  1382. BOOST_ASIO_CHECK(!error);
  1383. s.reset(read_data, sizeof(read_data));
  1384. s.next_read_length(10);
  1385. memset(read_buf, 0, sizeof(read_buf));
  1386. error = boost::system::error_code();
  1387. bytes_transferred = boost::asio::read(s, buffers,
  1388. old_style_transfer_all, error);
  1389. BOOST_ASIO_CHECK(bytes_transferred == sizeof(read_data));
  1390. BOOST_ASIO_CHECK(s.check_buffers(buffers, sizeof(read_data)));
  1391. BOOST_ASIO_CHECK(!error);
  1392. s.reset(read_data, sizeof(read_data));
  1393. memset(read_buf, 0, sizeof(read_buf));
  1394. bytes_transferred = boost::asio::read(s, buffers, short_transfer(), error);
  1395. BOOST_ASIO_CHECK(bytes_transferred == sizeof(read_data));
  1396. BOOST_ASIO_CHECK(s.check_buffers(buffers, sizeof(read_data)));
  1397. BOOST_ASIO_CHECK(!error);
  1398. s.reset(read_data, sizeof(read_data));
  1399. s.next_read_length(1);
  1400. memset(read_buf, 0, sizeof(read_buf));
  1401. error = boost::system::error_code();
  1402. bytes_transferred = boost::asio::read(s, buffers, short_transfer(), error);
  1403. BOOST_ASIO_CHECK(bytes_transferred == sizeof(read_data));
  1404. BOOST_ASIO_CHECK(s.check_buffers(buffers, sizeof(read_data)));
  1405. BOOST_ASIO_CHECK(!error);
  1406. s.reset(read_data, sizeof(read_data));
  1407. s.next_read_length(10);
  1408. memset(read_buf, 0, sizeof(read_buf));
  1409. error = boost::system::error_code();
  1410. bytes_transferred = boost::asio::read(s, buffers, short_transfer(), error);
  1411. BOOST_ASIO_CHECK(bytes_transferred == sizeof(read_data));
  1412. BOOST_ASIO_CHECK(s.check_buffers(buffers, sizeof(read_data)));
  1413. BOOST_ASIO_CHECK(!error);
  1414. }
  1415. void test_4_arg_vector_buffers_read()
  1416. {
  1417. boost::asio::io_context ioc;
  1418. test_stream s(ioc);
  1419. char read_buf[sizeof(read_data)];
  1420. std::vector<boost::asio::mutable_buffer> buffers;
  1421. buffers.push_back(boost::asio::buffer(read_buf, 32));
  1422. buffers.push_back(boost::asio::buffer(read_buf, 39) + 32);
  1423. buffers.push_back(boost::asio::buffer(read_buf) + 39);
  1424. s.reset(read_data, sizeof(read_data));
  1425. memset(read_buf, 0, sizeof(read_buf));
  1426. boost::system::error_code error;
  1427. size_t bytes_transferred = boost::asio::read(s, buffers,
  1428. boost::asio::transfer_all(), error);
  1429. BOOST_ASIO_CHECK(bytes_transferred == sizeof(read_data));
  1430. BOOST_ASIO_CHECK(s.check_buffers(buffers, sizeof(read_data)));
  1431. BOOST_ASIO_CHECK(!error);
  1432. s.reset(read_data, sizeof(read_data));
  1433. s.next_read_length(1);
  1434. memset(read_buf, 0, sizeof(read_buf));
  1435. error = boost::system::error_code();
  1436. bytes_transferred = boost::asio::read(s, buffers,
  1437. boost::asio::transfer_all(), error);
  1438. BOOST_ASIO_CHECK(bytes_transferred == sizeof(read_data));
  1439. BOOST_ASIO_CHECK(s.check_buffers(buffers, sizeof(read_data)));
  1440. BOOST_ASIO_CHECK(!error);
  1441. s.reset(read_data, sizeof(read_data));
  1442. s.next_read_length(10);
  1443. memset(read_buf, 0, sizeof(read_buf));
  1444. error = boost::system::error_code();
  1445. bytes_transferred = boost::asio::read(s, buffers,
  1446. boost::asio::transfer_all(), error);
  1447. BOOST_ASIO_CHECK(bytes_transferred == sizeof(read_data));
  1448. BOOST_ASIO_CHECK(s.check_buffers(buffers, sizeof(read_data)));
  1449. BOOST_ASIO_CHECK(!error);
  1450. s.reset(read_data, sizeof(read_data));
  1451. memset(read_buf, 0, sizeof(read_buf));
  1452. error = boost::system::error_code();
  1453. bytes_transferred = boost::asio::read(s, buffers,
  1454. boost::asio::transfer_at_least(1), error);
  1455. BOOST_ASIO_CHECK(bytes_transferred == sizeof(read_data));
  1456. BOOST_ASIO_CHECK(s.check_buffers(buffers, sizeof(read_data)));
  1457. BOOST_ASIO_CHECK(!error);
  1458. s.reset(read_data, sizeof(read_data));
  1459. s.next_read_length(1);
  1460. memset(read_buf, 0, sizeof(read_buf));
  1461. error = boost::system::error_code();
  1462. bytes_transferred = boost::asio::read(s, buffers,
  1463. boost::asio::transfer_at_least(1), error);
  1464. BOOST_ASIO_CHECK(bytes_transferred == 1);
  1465. BOOST_ASIO_CHECK(s.check_buffers(buffers, 1));
  1466. BOOST_ASIO_CHECK(!error);
  1467. s.reset(read_data, sizeof(read_data));
  1468. s.next_read_length(10);
  1469. memset(read_buf, 0, sizeof(read_buf));
  1470. error = boost::system::error_code();
  1471. bytes_transferred = boost::asio::read(s, buffers,
  1472. boost::asio::transfer_at_least(1), error);
  1473. BOOST_ASIO_CHECK(bytes_transferred == 10);
  1474. BOOST_ASIO_CHECK(s.check_buffers(buffers, 10));
  1475. BOOST_ASIO_CHECK(!error);
  1476. s.reset(read_data, sizeof(read_data));
  1477. memset(read_buf, 0, sizeof(read_buf));
  1478. error = boost::system::error_code();
  1479. bytes_transferred = boost::asio::read(s, buffers,
  1480. boost::asio::transfer_at_least(10), error);
  1481. BOOST_ASIO_CHECK(bytes_transferred == sizeof(read_data));
  1482. BOOST_ASIO_CHECK(s.check_buffers(buffers, sizeof(read_data)));
  1483. BOOST_ASIO_CHECK(!error);
  1484. s.reset(read_data, sizeof(read_data));
  1485. s.next_read_length(1);
  1486. memset(read_buf, 0, sizeof(read_buf));
  1487. error = boost::system::error_code();
  1488. bytes_transferred = boost::asio::read(s, buffers,
  1489. boost::asio::transfer_at_least(10), error);
  1490. BOOST_ASIO_CHECK(bytes_transferred == 10);
  1491. BOOST_ASIO_CHECK(s.check_buffers(buffers, 10));
  1492. BOOST_ASIO_CHECK(!error);
  1493. s.reset(read_data, sizeof(read_data));
  1494. s.next_read_length(10);
  1495. memset(read_buf, 0, sizeof(read_buf));
  1496. error = boost::system::error_code();
  1497. bytes_transferred = boost::asio::read(s, buffers,
  1498. boost::asio::transfer_at_least(10), error);
  1499. BOOST_ASIO_CHECK(bytes_transferred == 10);
  1500. BOOST_ASIO_CHECK(s.check_buffers(buffers, 10));
  1501. BOOST_ASIO_CHECK(!error);
  1502. s.reset(read_data, sizeof(read_data));
  1503. memset(read_buf, 0, sizeof(read_buf));
  1504. error = boost::system::error_code();
  1505. bytes_transferred = boost::asio::read(s, buffers,
  1506. boost::asio::transfer_at_least(42), error);
  1507. BOOST_ASIO_CHECK(bytes_transferred == sizeof(read_data));
  1508. BOOST_ASIO_CHECK(s.check_buffers(buffers, sizeof(read_data)));
  1509. BOOST_ASIO_CHECK(!error);
  1510. s.reset(read_data, sizeof(read_data));
  1511. s.next_read_length(1);
  1512. memset(read_buf, 0, sizeof(read_buf));
  1513. error = boost::system::error_code();
  1514. bytes_transferred = boost::asio::read(s, buffers,
  1515. boost::asio::transfer_at_least(42), error);
  1516. BOOST_ASIO_CHECK(bytes_transferred == 42);
  1517. BOOST_ASIO_CHECK(s.check_buffers(buffers, 42));
  1518. BOOST_ASIO_CHECK(!error);
  1519. s.reset(read_data, sizeof(read_data));
  1520. s.next_read_length(10);
  1521. memset(read_buf, 0, sizeof(read_buf));
  1522. error = boost::system::error_code();
  1523. bytes_transferred = boost::asio::read(s, buffers,
  1524. boost::asio::transfer_at_least(42), error);
  1525. BOOST_ASIO_CHECK(bytes_transferred == 50);
  1526. BOOST_ASIO_CHECK(s.check_buffers(buffers, 50));
  1527. BOOST_ASIO_CHECK(!error);
  1528. s.reset(read_data, sizeof(read_data));
  1529. memset(read_buf, 0, sizeof(read_buf));
  1530. error = boost::system::error_code();
  1531. bytes_transferred = boost::asio::read(s, buffers,
  1532. boost::asio::transfer_exactly(1), error);
  1533. BOOST_ASIO_CHECK(bytes_transferred == 1);
  1534. BOOST_ASIO_CHECK(s.check_buffers(buffers, 1));
  1535. BOOST_ASIO_CHECK(!error);
  1536. s.reset(read_data, sizeof(read_data));
  1537. s.next_read_length(1);
  1538. memset(read_buf, 0, sizeof(read_buf));
  1539. error = boost::system::error_code();
  1540. bytes_transferred = boost::asio::read(s, buffers,
  1541. boost::asio::transfer_exactly(1), error);
  1542. BOOST_ASIO_CHECK(bytes_transferred == 1);
  1543. BOOST_ASIO_CHECK(s.check_buffers(buffers, 1));
  1544. BOOST_ASIO_CHECK(!error);
  1545. s.reset(read_data, sizeof(read_data));
  1546. s.next_read_length(10);
  1547. memset(read_buf, 0, sizeof(read_buf));
  1548. error = boost::system::error_code();
  1549. bytes_transferred = boost::asio::read(s, buffers,
  1550. boost::asio::transfer_exactly(1), error);
  1551. BOOST_ASIO_CHECK(bytes_transferred == 1);
  1552. BOOST_ASIO_CHECK(s.check_buffers(buffers, 1));
  1553. BOOST_ASIO_CHECK(!error);
  1554. s.reset(read_data, sizeof(read_data));
  1555. memset(read_buf, 0, sizeof(read_buf));
  1556. error = boost::system::error_code();
  1557. bytes_transferred = boost::asio::read(s, buffers,
  1558. boost::asio::transfer_exactly(10), error);
  1559. BOOST_ASIO_CHECK(bytes_transferred == 10);
  1560. BOOST_ASIO_CHECK(s.check_buffers(buffers, 10));
  1561. BOOST_ASIO_CHECK(!error);
  1562. s.reset(read_data, sizeof(read_data));
  1563. s.next_read_length(1);
  1564. memset(read_buf, 0, sizeof(read_buf));
  1565. error = boost::system::error_code();
  1566. bytes_transferred = boost::asio::read(s, buffers,
  1567. boost::asio::transfer_exactly(10), error);
  1568. BOOST_ASIO_CHECK(bytes_transferred == 10);
  1569. BOOST_ASIO_CHECK(s.check_buffers(buffers, 10));
  1570. BOOST_ASIO_CHECK(!error);
  1571. s.reset(read_data, sizeof(read_data));
  1572. s.next_read_length(10);
  1573. memset(read_buf, 0, sizeof(read_buf));
  1574. error = boost::system::error_code();
  1575. bytes_transferred = boost::asio::read(s, buffers,
  1576. boost::asio::transfer_exactly(10), error);
  1577. BOOST_ASIO_CHECK(bytes_transferred == 10);
  1578. BOOST_ASIO_CHECK(s.check_buffers(buffers, 10));
  1579. BOOST_ASIO_CHECK(!error);
  1580. s.reset(read_data, sizeof(read_data));
  1581. memset(read_buf, 0, sizeof(read_buf));
  1582. error = boost::system::error_code();
  1583. bytes_transferred = boost::asio::read(s, buffers,
  1584. boost::asio::transfer_exactly(42), error);
  1585. BOOST_ASIO_CHECK(bytes_transferred == 42);
  1586. BOOST_ASIO_CHECK(s.check_buffers(buffers, 42));
  1587. BOOST_ASIO_CHECK(!error);
  1588. s.reset(read_data, sizeof(read_data));
  1589. s.next_read_length(1);
  1590. memset(read_buf, 0, sizeof(read_buf));
  1591. error = boost::system::error_code();
  1592. bytes_transferred = boost::asio::read(s, buffers,
  1593. boost::asio::transfer_exactly(42), error);
  1594. BOOST_ASIO_CHECK(bytes_transferred == 42);
  1595. BOOST_ASIO_CHECK(s.check_buffers(buffers, 42));
  1596. BOOST_ASIO_CHECK(!error);
  1597. s.reset(read_data, sizeof(read_data));
  1598. s.next_read_length(10);
  1599. memset(read_buf, 0, sizeof(read_buf));
  1600. error = boost::system::error_code();
  1601. bytes_transferred = boost::asio::read(s, buffers,
  1602. boost::asio::transfer_exactly(42), error);
  1603. BOOST_ASIO_CHECK(bytes_transferred == 42);
  1604. BOOST_ASIO_CHECK(s.check_buffers(buffers, 42));
  1605. BOOST_ASIO_CHECK(!error);
  1606. s.reset(read_data, sizeof(read_data));
  1607. memset(read_buf, 0, sizeof(read_buf));
  1608. bytes_transferred = boost::asio::read(s, buffers,
  1609. old_style_transfer_all, error);
  1610. BOOST_ASIO_CHECK(bytes_transferred == sizeof(read_data));
  1611. BOOST_ASIO_CHECK(s.check_buffers(buffers, sizeof(read_data)));
  1612. BOOST_ASIO_CHECK(!error);
  1613. s.reset(read_data, sizeof(read_data));
  1614. s.next_read_length(1);
  1615. memset(read_buf, 0, sizeof(read_buf));
  1616. error = boost::system::error_code();
  1617. bytes_transferred = boost::asio::read(s, buffers,
  1618. old_style_transfer_all, error);
  1619. BOOST_ASIO_CHECK(bytes_transferred == sizeof(read_data));
  1620. BOOST_ASIO_CHECK(s.check_buffers(buffers, sizeof(read_data)));
  1621. BOOST_ASIO_CHECK(!error);
  1622. s.reset(read_data, sizeof(read_data));
  1623. s.next_read_length(10);
  1624. memset(read_buf, 0, sizeof(read_buf));
  1625. error = boost::system::error_code();
  1626. bytes_transferred = boost::asio::read(s, buffers,
  1627. old_style_transfer_all, error);
  1628. BOOST_ASIO_CHECK(bytes_transferred == sizeof(read_data));
  1629. BOOST_ASIO_CHECK(s.check_buffers(buffers, sizeof(read_data)));
  1630. BOOST_ASIO_CHECK(!error);
  1631. s.reset(read_data, sizeof(read_data));
  1632. memset(read_buf, 0, sizeof(read_buf));
  1633. bytes_transferred = boost::asio::read(s, buffers, short_transfer(), error);
  1634. BOOST_ASIO_CHECK(bytes_transferred == sizeof(read_data));
  1635. BOOST_ASIO_CHECK(s.check_buffers(buffers, sizeof(read_data)));
  1636. BOOST_ASIO_CHECK(!error);
  1637. s.reset(read_data, sizeof(read_data));
  1638. s.next_read_length(1);
  1639. memset(read_buf, 0, sizeof(read_buf));
  1640. error = boost::system::error_code();
  1641. bytes_transferred = boost::asio::read(s, buffers, short_transfer(), error);
  1642. BOOST_ASIO_CHECK(bytes_transferred == sizeof(read_data));
  1643. BOOST_ASIO_CHECK(s.check_buffers(buffers, sizeof(read_data)));
  1644. BOOST_ASIO_CHECK(!error);
  1645. s.reset(read_data, sizeof(read_data));
  1646. s.next_read_length(10);
  1647. memset(read_buf, 0, sizeof(read_buf));
  1648. error = boost::system::error_code();
  1649. bytes_transferred = boost::asio::read(s, buffers, short_transfer(), error);
  1650. BOOST_ASIO_CHECK(bytes_transferred == sizeof(read_data));
  1651. BOOST_ASIO_CHECK(s.check_buffers(buffers, sizeof(read_data)));
  1652. BOOST_ASIO_CHECK(!error);
  1653. }
  1654. void test_4_arg_dynamic_string_read()
  1655. {
  1656. boost::asio::io_context ioc;
  1657. test_stream s(ioc);
  1658. std::string data;
  1659. boost::asio::dynamic_string_buffer<char, std::string::traits_type,
  1660. std::string::allocator_type> sb
  1661. = boost::asio::dynamic_buffer(data, sizeof(read_data));
  1662. s.reset(read_data, sizeof(read_data));
  1663. sb.consume(sb.size());
  1664. boost::system::error_code error;
  1665. size_t bytes_transferred = boost::asio::read(s, sb,
  1666. boost::asio::transfer_all(), error);
  1667. BOOST_ASIO_CHECK(bytes_transferred == sizeof(read_data));
  1668. BOOST_ASIO_CHECK(sb.size() == sizeof(read_data));
  1669. BOOST_ASIO_CHECK(s.check_buffers(sb.data(0, sb.size()), sizeof(read_data)));
  1670. BOOST_ASIO_CHECK(!error);
  1671. s.reset(read_data, sizeof(read_data));
  1672. s.next_read_length(1);
  1673. sb.consume(sb.size());
  1674. error = boost::system::error_code();
  1675. bytes_transferred = boost::asio::read(s, sb,
  1676. boost::asio::transfer_all(), error);
  1677. BOOST_ASIO_CHECK(bytes_transferred == sizeof(read_data));
  1678. BOOST_ASIO_CHECK(sb.size() == sizeof(read_data));
  1679. BOOST_ASIO_CHECK(s.check_buffers(sb.data(0, sb.size()), sizeof(read_data)));
  1680. BOOST_ASIO_CHECK(!error);
  1681. s.reset(read_data, sizeof(read_data));
  1682. s.next_read_length(10);
  1683. sb.consume(sb.size());
  1684. error = boost::system::error_code();
  1685. bytes_transferred = boost::asio::read(s, sb,
  1686. boost::asio::transfer_all(), error);
  1687. BOOST_ASIO_CHECK(bytes_transferred == sizeof(read_data));
  1688. BOOST_ASIO_CHECK(sb.size() == sizeof(read_data));
  1689. BOOST_ASIO_CHECK(s.check_buffers(sb.data(0, sb.size()), sizeof(read_data)));
  1690. BOOST_ASIO_CHECK(!error);
  1691. s.reset(read_data, sizeof(read_data));
  1692. sb.consume(sb.size());
  1693. error = boost::system::error_code();
  1694. bytes_transferred = boost::asio::read(s, sb,
  1695. boost::asio::transfer_at_least(1), error);
  1696. BOOST_ASIO_CHECK(bytes_transferred == sizeof(read_data));
  1697. BOOST_ASIO_CHECK(sb.size() == sizeof(read_data));
  1698. BOOST_ASIO_CHECK(s.check_buffers(sb.data(0, sb.size()), sizeof(read_data)));
  1699. BOOST_ASIO_CHECK(!error);
  1700. s.reset(read_data, sizeof(read_data));
  1701. s.next_read_length(1);
  1702. sb.consume(sb.size());
  1703. error = boost::system::error_code();
  1704. bytes_transferred = boost::asio::read(s, sb,
  1705. boost::asio::transfer_at_least(1), error);
  1706. BOOST_ASIO_CHECK(bytes_transferred == 1);
  1707. BOOST_ASIO_CHECK(sb.size() == 1);
  1708. BOOST_ASIO_CHECK(s.check_buffers(sb.data(0, sb.size()), 1));
  1709. BOOST_ASIO_CHECK(!error);
  1710. s.reset(read_data, sizeof(read_data));
  1711. s.next_read_length(10);
  1712. sb.consume(sb.size());
  1713. error = boost::system::error_code();
  1714. bytes_transferred = boost::asio::read(s, sb,
  1715. boost::asio::transfer_at_least(1), error);
  1716. BOOST_ASIO_CHECK(bytes_transferred == 10);
  1717. BOOST_ASIO_CHECK(sb.size() == 10);
  1718. BOOST_ASIO_CHECK(s.check_buffers(sb.data(0, sb.size()), 10));
  1719. BOOST_ASIO_CHECK(!error);
  1720. s.reset(read_data, sizeof(read_data));
  1721. sb.consume(sb.size());
  1722. error = boost::system::error_code();
  1723. bytes_transferred = boost::asio::read(s, sb,
  1724. boost::asio::transfer_at_least(10), error);
  1725. BOOST_ASIO_CHECK(bytes_transferred == sizeof(read_data));
  1726. BOOST_ASIO_CHECK(sb.size() == sizeof(read_data));
  1727. BOOST_ASIO_CHECK(s.check_buffers(sb.data(0, sb.size()), sizeof(read_data)));
  1728. BOOST_ASIO_CHECK(!error);
  1729. s.reset(read_data, sizeof(read_data));
  1730. s.next_read_length(1);
  1731. sb.consume(sb.size());
  1732. error = boost::system::error_code();
  1733. bytes_transferred = boost::asio::read(s, sb,
  1734. boost::asio::transfer_at_least(10), error);
  1735. BOOST_ASIO_CHECK(bytes_transferred == 10);
  1736. BOOST_ASIO_CHECK(sb.size() == 10);
  1737. BOOST_ASIO_CHECK(s.check_buffers(sb.data(0, sb.size()), 10));
  1738. BOOST_ASIO_CHECK(!error);
  1739. s.reset(read_data, sizeof(read_data));
  1740. s.next_read_length(10);
  1741. sb.consume(sb.size());
  1742. error = boost::system::error_code();
  1743. bytes_transferred = boost::asio::read(s, sb,
  1744. boost::asio::transfer_at_least(10), error);
  1745. BOOST_ASIO_CHECK(bytes_transferred == 10);
  1746. BOOST_ASIO_CHECK(sb.size() == 10);
  1747. BOOST_ASIO_CHECK(s.check_buffers(sb.data(0, sb.size()), 10));
  1748. BOOST_ASIO_CHECK(!error);
  1749. s.reset(read_data, sizeof(read_data));
  1750. sb.consume(sb.size());
  1751. error = boost::system::error_code();
  1752. bytes_transferred = boost::asio::read(s, sb,
  1753. boost::asio::transfer_at_least(42), error);
  1754. BOOST_ASIO_CHECK(bytes_transferred == sizeof(read_data));
  1755. BOOST_ASIO_CHECK(sb.size() == sizeof(read_data));
  1756. BOOST_ASIO_CHECK(s.check_buffers(sb.data(0, sb.size()), sizeof(read_data)));
  1757. BOOST_ASIO_CHECK(!error);
  1758. s.reset(read_data, sizeof(read_data));
  1759. s.next_read_length(1);
  1760. sb.consume(sb.size());
  1761. error = boost::system::error_code();
  1762. bytes_transferred = boost::asio::read(s, sb,
  1763. boost::asio::transfer_at_least(42), error);
  1764. BOOST_ASIO_CHECK(bytes_transferred == 42);
  1765. BOOST_ASIO_CHECK(sb.size() == 42);
  1766. BOOST_ASIO_CHECK(s.check_buffers(sb.data(0, sb.size()), 42));
  1767. BOOST_ASIO_CHECK(!error);
  1768. s.reset(read_data, sizeof(read_data));
  1769. s.next_read_length(10);
  1770. sb.consume(sb.size());
  1771. error = boost::system::error_code();
  1772. bytes_transferred = boost::asio::read(s, sb,
  1773. boost::asio::transfer_at_least(42), error);
  1774. BOOST_ASIO_CHECK(bytes_transferred == 50);
  1775. BOOST_ASIO_CHECK(sb.size() == 50);
  1776. BOOST_ASIO_CHECK(s.check_buffers(sb.data(0, sb.size()), 50));
  1777. BOOST_ASIO_CHECK(!error);
  1778. s.reset(read_data, sizeof(read_data));
  1779. sb.consume(sb.size());
  1780. error = boost::system::error_code();
  1781. bytes_transferred = boost::asio::read(s, sb,
  1782. boost::asio::transfer_exactly(1), error);
  1783. BOOST_ASIO_CHECK(bytes_transferred == 1);
  1784. BOOST_ASIO_CHECK(sb.size() == 1);
  1785. BOOST_ASIO_CHECK(s.check_buffers(sb.data(0, sb.size()), 1));
  1786. BOOST_ASIO_CHECK(!error);
  1787. s.reset(read_data, sizeof(read_data));
  1788. s.next_read_length(1);
  1789. sb.consume(sb.size());
  1790. error = boost::system::error_code();
  1791. bytes_transferred = boost::asio::read(s, sb,
  1792. boost::asio::transfer_exactly(1), error);
  1793. BOOST_ASIO_CHECK(bytes_transferred == 1);
  1794. BOOST_ASIO_CHECK(sb.size() == 1);
  1795. BOOST_ASIO_CHECK(s.check_buffers(sb.data(0, sb.size()), 1));
  1796. BOOST_ASIO_CHECK(!error);
  1797. s.reset(read_data, sizeof(read_data));
  1798. s.next_read_length(10);
  1799. sb.consume(sb.size());
  1800. error = boost::system::error_code();
  1801. bytes_transferred = boost::asio::read(s, sb,
  1802. boost::asio::transfer_exactly(1), error);
  1803. BOOST_ASIO_CHECK(bytes_transferred == 1);
  1804. BOOST_ASIO_CHECK(sb.size() == 1);
  1805. BOOST_ASIO_CHECK(s.check_buffers(sb.data(0, sb.size()), 1));
  1806. BOOST_ASIO_CHECK(!error);
  1807. s.reset(read_data, sizeof(read_data));
  1808. sb.consume(sb.size());
  1809. error = boost::system::error_code();
  1810. bytes_transferred = boost::asio::read(s, sb,
  1811. boost::asio::transfer_exactly(10), error);
  1812. BOOST_ASIO_CHECK(bytes_transferred == 10);
  1813. BOOST_ASIO_CHECK(sb.size() == 10);
  1814. BOOST_ASIO_CHECK(s.check_buffers(sb.data(0, sb.size()), 10));
  1815. BOOST_ASIO_CHECK(!error);
  1816. s.reset(read_data, sizeof(read_data));
  1817. s.next_read_length(1);
  1818. sb.consume(sb.size());
  1819. error = boost::system::error_code();
  1820. bytes_transferred = boost::asio::read(s, sb,
  1821. boost::asio::transfer_exactly(10), error);
  1822. BOOST_ASIO_CHECK(bytes_transferred == 10);
  1823. BOOST_ASIO_CHECK(sb.size() == 10);
  1824. BOOST_ASIO_CHECK(s.check_buffers(sb.data(0, sb.size()), 10));
  1825. BOOST_ASIO_CHECK(!error);
  1826. s.reset(read_data, sizeof(read_data));
  1827. s.next_read_length(10);
  1828. sb.consume(sb.size());
  1829. error = boost::system::error_code();
  1830. bytes_transferred = boost::asio::read(s, sb,
  1831. boost::asio::transfer_exactly(10), error);
  1832. BOOST_ASIO_CHECK(bytes_transferred == 10);
  1833. BOOST_ASIO_CHECK(sb.size() == 10);
  1834. BOOST_ASIO_CHECK(s.check_buffers(sb.data(0, sb.size()), 10));
  1835. BOOST_ASIO_CHECK(!error);
  1836. s.reset(read_data, sizeof(read_data));
  1837. sb.consume(sb.size());
  1838. error = boost::system::error_code();
  1839. bytes_transferred = boost::asio::read(s, sb,
  1840. boost::asio::transfer_exactly(42), error);
  1841. BOOST_ASIO_CHECK(bytes_transferred == 42);
  1842. BOOST_ASIO_CHECK(sb.size() == 42);
  1843. BOOST_ASIO_CHECK(s.check_buffers(sb.data(0, sb.size()), 42));
  1844. BOOST_ASIO_CHECK(!error);
  1845. s.reset(read_data, sizeof(read_data));
  1846. s.next_read_length(1);
  1847. sb.consume(sb.size());
  1848. error = boost::system::error_code();
  1849. bytes_transferred = boost::asio::read(s, sb,
  1850. boost::asio::transfer_exactly(42), error);
  1851. BOOST_ASIO_CHECK(bytes_transferred == 42);
  1852. BOOST_ASIO_CHECK(sb.size() == 42);
  1853. BOOST_ASIO_CHECK(s.check_buffers(sb.data(0, sb.size()), 42));
  1854. BOOST_ASIO_CHECK(!error);
  1855. s.reset(read_data, sizeof(read_data));
  1856. s.next_read_length(10);
  1857. sb.consume(sb.size());
  1858. error = boost::system::error_code();
  1859. bytes_transferred = boost::asio::read(s, sb,
  1860. boost::asio::transfer_exactly(42), error);
  1861. BOOST_ASIO_CHECK(bytes_transferred == 42);
  1862. BOOST_ASIO_CHECK(sb.size() == 42);
  1863. BOOST_ASIO_CHECK(s.check_buffers(sb.data(0, sb.size()), 42));
  1864. BOOST_ASIO_CHECK(!error);
  1865. s.reset(read_data, sizeof(read_data));
  1866. sb.consume(sb.size());
  1867. bytes_transferred = boost::asio::read(s, sb,
  1868. old_style_transfer_all, error);
  1869. BOOST_ASIO_CHECK(bytes_transferred == sizeof(read_data));
  1870. BOOST_ASIO_CHECK(sb.size() == sizeof(read_data));
  1871. BOOST_ASIO_CHECK(s.check_buffers(sb.data(0, sb.size()), sizeof(read_data)));
  1872. BOOST_ASIO_CHECK(!error);
  1873. s.reset(read_data, sizeof(read_data));
  1874. s.next_read_length(1);
  1875. sb.consume(sb.size());
  1876. error = boost::system::error_code();
  1877. bytes_transferred = boost::asio::read(s, sb,
  1878. old_style_transfer_all, error);
  1879. BOOST_ASIO_CHECK(bytes_transferred == sizeof(read_data));
  1880. BOOST_ASIO_CHECK(sb.size() == sizeof(read_data));
  1881. BOOST_ASIO_CHECK(s.check_buffers(sb.data(0, sb.size()), sizeof(read_data)));
  1882. BOOST_ASIO_CHECK(!error);
  1883. s.reset(read_data, sizeof(read_data));
  1884. s.next_read_length(10);
  1885. sb.consume(sb.size());
  1886. error = boost::system::error_code();
  1887. bytes_transferred = boost::asio::read(s, sb,
  1888. old_style_transfer_all, error);
  1889. BOOST_ASIO_CHECK(bytes_transferred == sizeof(read_data));
  1890. BOOST_ASIO_CHECK(sb.size() == sizeof(read_data));
  1891. BOOST_ASIO_CHECK(s.check_buffers(sb.data(0, sb.size()), sizeof(read_data)));
  1892. BOOST_ASIO_CHECK(!error);
  1893. s.reset(read_data, sizeof(read_data));
  1894. sb.consume(sb.size());
  1895. bytes_transferred = boost::asio::read(s, sb, short_transfer(), error);
  1896. BOOST_ASIO_CHECK(bytes_transferred == sizeof(read_data));
  1897. BOOST_ASIO_CHECK(sb.size() == sizeof(read_data));
  1898. BOOST_ASIO_CHECK(s.check_buffers(sb.data(0, sb.size()), sizeof(read_data)));
  1899. BOOST_ASIO_CHECK(!error);
  1900. s.reset(read_data, sizeof(read_data));
  1901. s.next_read_length(1);
  1902. sb.consume(sb.size());
  1903. error = boost::system::error_code();
  1904. bytes_transferred = boost::asio::read(s, sb, short_transfer(), error);
  1905. BOOST_ASIO_CHECK(bytes_transferred == sizeof(read_data));
  1906. BOOST_ASIO_CHECK(sb.size() == sizeof(read_data));
  1907. BOOST_ASIO_CHECK(s.check_buffers(sb.data(0, sb.size()), sizeof(read_data)));
  1908. BOOST_ASIO_CHECK(!error);
  1909. s.reset(read_data, sizeof(read_data));
  1910. s.next_read_length(10);
  1911. sb.consume(sb.size());
  1912. error = boost::system::error_code();
  1913. bytes_transferred = boost::asio::read(s, sb, short_transfer(), error);
  1914. BOOST_ASIO_CHECK(bytes_transferred == sizeof(read_data));
  1915. BOOST_ASIO_CHECK(sb.size() == sizeof(read_data));
  1916. BOOST_ASIO_CHECK(s.check_buffers(sb.data(0, sb.size()), sizeof(read_data)));
  1917. BOOST_ASIO_CHECK(!error);
  1918. }
  1919. void test_4_arg_streambuf_read()
  1920. {
  1921. #if !defined(BOOST_ASIO_NO_DYNAMIC_BUFFER_V1)
  1922. boost::asio::io_context ioc;
  1923. test_stream s(ioc);
  1924. boost::asio::streambuf sb(sizeof(read_data));
  1925. s.reset(read_data, sizeof(read_data));
  1926. sb.consume(sb.size());
  1927. boost::system::error_code error;
  1928. size_t bytes_transferred = boost::asio::read(s, sb,
  1929. boost::asio::transfer_all(), error);
  1930. BOOST_ASIO_CHECK(bytes_transferred == sizeof(read_data));
  1931. BOOST_ASIO_CHECK(sb.size() == sizeof(read_data));
  1932. BOOST_ASIO_CHECK(s.check_buffers(sb.data(), sizeof(read_data)));
  1933. BOOST_ASIO_CHECK(!error);
  1934. s.reset(read_data, sizeof(read_data));
  1935. s.next_read_length(1);
  1936. sb.consume(sb.size());
  1937. error = boost::system::error_code();
  1938. bytes_transferred = boost::asio::read(s, sb,
  1939. boost::asio::transfer_all(), error);
  1940. BOOST_ASIO_CHECK(bytes_transferred == sizeof(read_data));
  1941. BOOST_ASIO_CHECK(sb.size() == sizeof(read_data));
  1942. BOOST_ASIO_CHECK(s.check_buffers(sb.data(), sizeof(read_data)));
  1943. BOOST_ASIO_CHECK(!error);
  1944. s.reset(read_data, sizeof(read_data));
  1945. s.next_read_length(10);
  1946. sb.consume(sb.size());
  1947. error = boost::system::error_code();
  1948. bytes_transferred = boost::asio::read(s, sb,
  1949. boost::asio::transfer_all(), error);
  1950. BOOST_ASIO_CHECK(bytes_transferred == sizeof(read_data));
  1951. BOOST_ASIO_CHECK(sb.size() == sizeof(read_data));
  1952. BOOST_ASIO_CHECK(s.check_buffers(sb.data(), sizeof(read_data)));
  1953. BOOST_ASIO_CHECK(!error);
  1954. s.reset(read_data, sizeof(read_data));
  1955. sb.consume(sb.size());
  1956. error = boost::system::error_code();
  1957. bytes_transferred = boost::asio::read(s, sb,
  1958. boost::asio::transfer_at_least(1), error);
  1959. BOOST_ASIO_CHECK(bytes_transferred == sizeof(read_data));
  1960. BOOST_ASIO_CHECK(sb.size() == sizeof(read_data));
  1961. BOOST_ASIO_CHECK(s.check_buffers(sb.data(), sizeof(read_data)));
  1962. BOOST_ASIO_CHECK(!error);
  1963. s.reset(read_data, sizeof(read_data));
  1964. s.next_read_length(1);
  1965. sb.consume(sb.size());
  1966. error = boost::system::error_code();
  1967. bytes_transferred = boost::asio::read(s, sb,
  1968. boost::asio::transfer_at_least(1), error);
  1969. BOOST_ASIO_CHECK(bytes_transferred == 1);
  1970. BOOST_ASIO_CHECK(sb.size() == 1);
  1971. BOOST_ASIO_CHECK(s.check_buffers(sb.data(), 1));
  1972. BOOST_ASIO_CHECK(!error);
  1973. s.reset(read_data, sizeof(read_data));
  1974. s.next_read_length(10);
  1975. sb.consume(sb.size());
  1976. error = boost::system::error_code();
  1977. bytes_transferred = boost::asio::read(s, sb,
  1978. boost::asio::transfer_at_least(1), error);
  1979. BOOST_ASIO_CHECK(bytes_transferred == 10);
  1980. BOOST_ASIO_CHECK(sb.size() == 10);
  1981. BOOST_ASIO_CHECK(s.check_buffers(sb.data(), 10));
  1982. BOOST_ASIO_CHECK(!error);
  1983. s.reset(read_data, sizeof(read_data));
  1984. sb.consume(sb.size());
  1985. error = boost::system::error_code();
  1986. bytes_transferred = boost::asio::read(s, sb,
  1987. boost::asio::transfer_at_least(10), error);
  1988. BOOST_ASIO_CHECK(bytes_transferred == sizeof(read_data));
  1989. BOOST_ASIO_CHECK(sb.size() == sizeof(read_data));
  1990. BOOST_ASIO_CHECK(s.check_buffers(sb.data(), sizeof(read_data)));
  1991. BOOST_ASIO_CHECK(!error);
  1992. s.reset(read_data, sizeof(read_data));
  1993. s.next_read_length(1);
  1994. sb.consume(sb.size());
  1995. error = boost::system::error_code();
  1996. bytes_transferred = boost::asio::read(s, sb,
  1997. boost::asio::transfer_at_least(10), error);
  1998. BOOST_ASIO_CHECK(bytes_transferred == 10);
  1999. BOOST_ASIO_CHECK(sb.size() == 10);
  2000. BOOST_ASIO_CHECK(s.check_buffers(sb.data(), 10));
  2001. BOOST_ASIO_CHECK(!error);
  2002. s.reset(read_data, sizeof(read_data));
  2003. s.next_read_length(10);
  2004. sb.consume(sb.size());
  2005. error = boost::system::error_code();
  2006. bytes_transferred = boost::asio::read(s, sb,
  2007. boost::asio::transfer_at_least(10), error);
  2008. BOOST_ASIO_CHECK(bytes_transferred == 10);
  2009. BOOST_ASIO_CHECK(sb.size() == 10);
  2010. BOOST_ASIO_CHECK(s.check_buffers(sb.data(), 10));
  2011. BOOST_ASIO_CHECK(!error);
  2012. s.reset(read_data, sizeof(read_data));
  2013. sb.consume(sb.size());
  2014. error = boost::system::error_code();
  2015. bytes_transferred = boost::asio::read(s, sb,
  2016. boost::asio::transfer_at_least(42), error);
  2017. BOOST_ASIO_CHECK(bytes_transferred == sizeof(read_data));
  2018. BOOST_ASIO_CHECK(sb.size() == sizeof(read_data));
  2019. BOOST_ASIO_CHECK(s.check_buffers(sb.data(), sizeof(read_data)));
  2020. BOOST_ASIO_CHECK(!error);
  2021. s.reset(read_data, sizeof(read_data));
  2022. s.next_read_length(1);
  2023. sb.consume(sb.size());
  2024. error = boost::system::error_code();
  2025. bytes_transferred = boost::asio::read(s, sb,
  2026. boost::asio::transfer_at_least(42), error);
  2027. BOOST_ASIO_CHECK(bytes_transferred == 42);
  2028. BOOST_ASIO_CHECK(sb.size() == 42);
  2029. BOOST_ASIO_CHECK(s.check_buffers(sb.data(), 42));
  2030. BOOST_ASIO_CHECK(!error);
  2031. s.reset(read_data, sizeof(read_data));
  2032. s.next_read_length(10);
  2033. sb.consume(sb.size());
  2034. error = boost::system::error_code();
  2035. bytes_transferred = boost::asio::read(s, sb,
  2036. boost::asio::transfer_at_least(42), error);
  2037. BOOST_ASIO_CHECK(bytes_transferred == 50);
  2038. BOOST_ASIO_CHECK(sb.size() == 50);
  2039. BOOST_ASIO_CHECK(s.check_buffers(sb.data(), 50));
  2040. BOOST_ASIO_CHECK(!error);
  2041. s.reset(read_data, sizeof(read_data));
  2042. sb.consume(sb.size());
  2043. error = boost::system::error_code();
  2044. bytes_transferred = boost::asio::read(s, sb,
  2045. boost::asio::transfer_exactly(1), error);
  2046. BOOST_ASIO_CHECK(bytes_transferred == 1);
  2047. BOOST_ASIO_CHECK(sb.size() == 1);
  2048. BOOST_ASIO_CHECK(s.check_buffers(sb.data(), 1));
  2049. BOOST_ASIO_CHECK(!error);
  2050. s.reset(read_data, sizeof(read_data));
  2051. s.next_read_length(1);
  2052. sb.consume(sb.size());
  2053. error = boost::system::error_code();
  2054. bytes_transferred = boost::asio::read(s, sb,
  2055. boost::asio::transfer_exactly(1), error);
  2056. BOOST_ASIO_CHECK(bytes_transferred == 1);
  2057. BOOST_ASIO_CHECK(sb.size() == 1);
  2058. BOOST_ASIO_CHECK(s.check_buffers(sb.data(), 1));
  2059. BOOST_ASIO_CHECK(!error);
  2060. s.reset(read_data, sizeof(read_data));
  2061. s.next_read_length(10);
  2062. sb.consume(sb.size());
  2063. error = boost::system::error_code();
  2064. bytes_transferred = boost::asio::read(s, sb,
  2065. boost::asio::transfer_exactly(1), error);
  2066. BOOST_ASIO_CHECK(bytes_transferred == 1);
  2067. BOOST_ASIO_CHECK(sb.size() == 1);
  2068. BOOST_ASIO_CHECK(s.check_buffers(sb.data(), 1));
  2069. BOOST_ASIO_CHECK(!error);
  2070. s.reset(read_data, sizeof(read_data));
  2071. sb.consume(sb.size());
  2072. error = boost::system::error_code();
  2073. bytes_transferred = boost::asio::read(s, sb,
  2074. boost::asio::transfer_exactly(10), error);
  2075. BOOST_ASIO_CHECK(bytes_transferred == 10);
  2076. BOOST_ASIO_CHECK(sb.size() == 10);
  2077. BOOST_ASIO_CHECK(s.check_buffers(sb.data(), 10));
  2078. BOOST_ASIO_CHECK(!error);
  2079. s.reset(read_data, sizeof(read_data));
  2080. s.next_read_length(1);
  2081. sb.consume(sb.size());
  2082. error = boost::system::error_code();
  2083. bytes_transferred = boost::asio::read(s, sb,
  2084. boost::asio::transfer_exactly(10), error);
  2085. BOOST_ASIO_CHECK(bytes_transferred == 10);
  2086. BOOST_ASIO_CHECK(sb.size() == 10);
  2087. BOOST_ASIO_CHECK(s.check_buffers(sb.data(), 10));
  2088. BOOST_ASIO_CHECK(!error);
  2089. s.reset(read_data, sizeof(read_data));
  2090. s.next_read_length(10);
  2091. sb.consume(sb.size());
  2092. error = boost::system::error_code();
  2093. bytes_transferred = boost::asio::read(s, sb,
  2094. boost::asio::transfer_exactly(10), error);
  2095. BOOST_ASIO_CHECK(bytes_transferred == 10);
  2096. BOOST_ASIO_CHECK(sb.size() == 10);
  2097. BOOST_ASIO_CHECK(s.check_buffers(sb.data(), 10));
  2098. BOOST_ASIO_CHECK(!error);
  2099. s.reset(read_data, sizeof(read_data));
  2100. sb.consume(sb.size());
  2101. error = boost::system::error_code();
  2102. bytes_transferred = boost::asio::read(s, sb,
  2103. boost::asio::transfer_exactly(42), error);
  2104. BOOST_ASIO_CHECK(bytes_transferred == 42);
  2105. BOOST_ASIO_CHECK(sb.size() == 42);
  2106. BOOST_ASIO_CHECK(s.check_buffers(sb.data(), 42));
  2107. BOOST_ASIO_CHECK(!error);
  2108. s.reset(read_data, sizeof(read_data));
  2109. s.next_read_length(1);
  2110. sb.consume(sb.size());
  2111. error = boost::system::error_code();
  2112. bytes_transferred = boost::asio::read(s, sb,
  2113. boost::asio::transfer_exactly(42), error);
  2114. BOOST_ASIO_CHECK(bytes_transferred == 42);
  2115. BOOST_ASIO_CHECK(sb.size() == 42);
  2116. BOOST_ASIO_CHECK(s.check_buffers(sb.data(), 42));
  2117. BOOST_ASIO_CHECK(!error);
  2118. s.reset(read_data, sizeof(read_data));
  2119. s.next_read_length(10);
  2120. sb.consume(sb.size());
  2121. error = boost::system::error_code();
  2122. bytes_transferred = boost::asio::read(s, sb,
  2123. boost::asio::transfer_exactly(42), error);
  2124. BOOST_ASIO_CHECK(bytes_transferred == 42);
  2125. BOOST_ASIO_CHECK(sb.size() == 42);
  2126. BOOST_ASIO_CHECK(s.check_buffers(sb.data(), 42));
  2127. BOOST_ASIO_CHECK(!error);
  2128. s.reset(read_data, sizeof(read_data));
  2129. sb.consume(sb.size());
  2130. bytes_transferred = boost::asio::read(s, sb,
  2131. old_style_transfer_all, error);
  2132. BOOST_ASIO_CHECK(bytes_transferred == sizeof(read_data));
  2133. BOOST_ASIO_CHECK(sb.size() == sizeof(read_data));
  2134. BOOST_ASIO_CHECK(s.check_buffers(sb.data(), sizeof(read_data)));
  2135. BOOST_ASIO_CHECK(!error);
  2136. s.reset(read_data, sizeof(read_data));
  2137. s.next_read_length(1);
  2138. sb.consume(sb.size());
  2139. error = boost::system::error_code();
  2140. bytes_transferred = boost::asio::read(s, sb,
  2141. old_style_transfer_all, error);
  2142. BOOST_ASIO_CHECK(bytes_transferred == sizeof(read_data));
  2143. BOOST_ASIO_CHECK(sb.size() == sizeof(read_data));
  2144. BOOST_ASIO_CHECK(s.check_buffers(sb.data(), sizeof(read_data)));
  2145. BOOST_ASIO_CHECK(!error);
  2146. s.reset(read_data, sizeof(read_data));
  2147. s.next_read_length(10);
  2148. sb.consume(sb.size());
  2149. error = boost::system::error_code();
  2150. bytes_transferred = boost::asio::read(s, sb,
  2151. old_style_transfer_all, error);
  2152. BOOST_ASIO_CHECK(bytes_transferred == sizeof(read_data));
  2153. BOOST_ASIO_CHECK(sb.size() == sizeof(read_data));
  2154. BOOST_ASIO_CHECK(s.check_buffers(sb.data(), sizeof(read_data)));
  2155. BOOST_ASIO_CHECK(!error);
  2156. s.reset(read_data, sizeof(read_data));
  2157. sb.consume(sb.size());
  2158. bytes_transferred = boost::asio::read(s, sb, short_transfer(), error);
  2159. BOOST_ASIO_CHECK(bytes_transferred == sizeof(read_data));
  2160. BOOST_ASIO_CHECK(sb.size() == sizeof(read_data));
  2161. BOOST_ASIO_CHECK(s.check_buffers(sb.data(), sizeof(read_data)));
  2162. BOOST_ASIO_CHECK(!error);
  2163. s.reset(read_data, sizeof(read_data));
  2164. s.next_read_length(1);
  2165. sb.consume(sb.size());
  2166. error = boost::system::error_code();
  2167. bytes_transferred = boost::asio::read(s, sb, short_transfer(), error);
  2168. BOOST_ASIO_CHECK(bytes_transferred == sizeof(read_data));
  2169. BOOST_ASIO_CHECK(sb.size() == sizeof(read_data));
  2170. BOOST_ASIO_CHECK(s.check_buffers(sb.data(), sizeof(read_data)));
  2171. BOOST_ASIO_CHECK(!error);
  2172. s.reset(read_data, sizeof(read_data));
  2173. s.next_read_length(10);
  2174. sb.consume(sb.size());
  2175. error = boost::system::error_code();
  2176. bytes_transferred = boost::asio::read(s, sb, short_transfer(), error);
  2177. BOOST_ASIO_CHECK(bytes_transferred == sizeof(read_data));
  2178. BOOST_ASIO_CHECK(sb.size() == sizeof(read_data));
  2179. BOOST_ASIO_CHECK(s.check_buffers(sb.data(), sizeof(read_data)));
  2180. BOOST_ASIO_CHECK(!error);
  2181. #endif // !defined(BOOST_ASIO_NO_DYNAMIC_BUFFER_V1)
  2182. }
  2183. void async_read_handler(const boost::system::error_code& e,
  2184. size_t bytes_transferred, size_t expected_bytes_transferred, bool* called)
  2185. {
  2186. *called = true;
  2187. BOOST_ASIO_CHECK(!e);
  2188. BOOST_ASIO_CHECK(bytes_transferred == expected_bytes_transferred);
  2189. }
  2190. void test_3_arg_mutable_buffer_async_read()
  2191. {
  2192. #if defined(BOOST_ASIO_HAS_BOOST_BIND)
  2193. namespace bindns = boost;
  2194. #else // defined(BOOST_ASIO_HAS_BOOST_BIND)
  2195. namespace bindns = std;
  2196. using std::placeholders::_1;
  2197. using std::placeholders::_2;
  2198. #endif // defined(BOOST_ASIO_HAS_BOOST_BIND)
  2199. boost::asio::io_context ioc;
  2200. test_stream s(ioc);
  2201. char read_buf[sizeof(read_data)];
  2202. boost::asio::mutable_buffer buffers
  2203. = boost::asio::buffer(read_buf, sizeof(read_buf));
  2204. s.reset(read_data, sizeof(read_data));
  2205. memset(read_buf, 0, sizeof(read_buf));
  2206. bool called = false;
  2207. boost::asio::async_read(s, buffers,
  2208. bindns::bind(async_read_handler,
  2209. _1, _2, sizeof(read_data), &called));
  2210. ioc.restart();
  2211. ioc.run();
  2212. BOOST_ASIO_CHECK(called);
  2213. BOOST_ASIO_CHECK(s.check_buffers(buffers, sizeof(read_data)));
  2214. s.reset(read_data, sizeof(read_data));
  2215. s.next_read_length(1);
  2216. memset(read_buf, 0, sizeof(read_buf));
  2217. called = false;
  2218. boost::asio::async_read(s, buffers,
  2219. bindns::bind(async_read_handler,
  2220. _1, _2, sizeof(read_data), &called));
  2221. ioc.restart();
  2222. ioc.run();
  2223. BOOST_ASIO_CHECK(called);
  2224. BOOST_ASIO_CHECK(s.check_buffers(buffers, sizeof(read_data)));
  2225. s.reset(read_data, sizeof(read_data));
  2226. s.next_read_length(10);
  2227. memset(read_buf, 0, sizeof(read_buf));
  2228. called = false;
  2229. boost::asio::async_read(s, buffers,
  2230. bindns::bind(async_read_handler,
  2231. _1, _2, sizeof(read_data), &called));
  2232. ioc.restart();
  2233. ioc.run();
  2234. BOOST_ASIO_CHECK(called);
  2235. BOOST_ASIO_CHECK(s.check_buffers(buffers, sizeof(read_data)));
  2236. s.reset(read_data, sizeof(read_data));
  2237. memset(read_buf, 0, sizeof(read_buf));
  2238. int i = boost::asio::async_read(s, buffers, archetypes::lazy_handler());
  2239. BOOST_ASIO_CHECK(i == 42);
  2240. ioc.restart();
  2241. ioc.run();
  2242. BOOST_ASIO_CHECK(s.check_buffers(buffers, sizeof(read_data)));
  2243. }
  2244. void test_3_arg_boost_array_buffers_async_read()
  2245. {
  2246. #if defined(BOOST_ASIO_HAS_BOOST_BIND)
  2247. namespace bindns = boost;
  2248. #else // defined(BOOST_ASIO_HAS_BOOST_BIND)
  2249. namespace bindns = std;
  2250. using std::placeholders::_1;
  2251. using std::placeholders::_2;
  2252. #endif // defined(BOOST_ASIO_HAS_BOOST_BIND)
  2253. #if defined(BOOST_ASIO_HAS_BOOST_ARRAY)
  2254. boost::asio::io_context ioc;
  2255. test_stream s(ioc);
  2256. char read_buf[sizeof(read_data)];
  2257. boost::array<boost::asio::mutable_buffer, 2> buffers = { {
  2258. boost::asio::buffer(read_buf, 32),
  2259. boost::asio::buffer(read_buf) + 32 } };
  2260. s.reset(read_data, sizeof(read_data));
  2261. memset(read_buf, 0, sizeof(read_buf));
  2262. bool called = false;
  2263. boost::asio::async_read(s, buffers,
  2264. bindns::bind(async_read_handler,
  2265. _1, _2, sizeof(read_data), &called));
  2266. ioc.restart();
  2267. ioc.run();
  2268. BOOST_ASIO_CHECK(called);
  2269. BOOST_ASIO_CHECK(s.check_buffers(buffers, sizeof(read_data)));
  2270. s.reset(read_data, sizeof(read_data));
  2271. s.next_read_length(1);
  2272. memset(read_buf, 0, sizeof(read_buf));
  2273. called = false;
  2274. boost::asio::async_read(s, buffers,
  2275. bindns::bind(async_read_handler,
  2276. _1, _2, sizeof(read_data), &called));
  2277. ioc.restart();
  2278. ioc.run();
  2279. BOOST_ASIO_CHECK(called);
  2280. BOOST_ASIO_CHECK(s.check_buffers(buffers, sizeof(read_data)));
  2281. s.reset(read_data, sizeof(read_data));
  2282. s.next_read_length(10);
  2283. memset(read_buf, 0, sizeof(read_buf));
  2284. called = false;
  2285. boost::asio::async_read(s, buffers,
  2286. bindns::bind(async_read_handler,
  2287. _1, _2, sizeof(read_data), &called));
  2288. ioc.restart();
  2289. ioc.run();
  2290. BOOST_ASIO_CHECK(called);
  2291. BOOST_ASIO_CHECK(s.check_buffers(buffers, sizeof(read_data)));
  2292. s.reset(read_data, sizeof(read_data));
  2293. memset(read_buf, 0, sizeof(read_buf));
  2294. int i = boost::asio::async_read(s, buffers, archetypes::lazy_handler());
  2295. BOOST_ASIO_CHECK(i == 42);
  2296. ioc.restart();
  2297. ioc.run();
  2298. BOOST_ASIO_CHECK(s.check_buffers(buffers, sizeof(read_data)));
  2299. #endif // defined(BOOST_ASIO_HAS_BOOST_ARRAY)
  2300. }
  2301. void test_3_arg_std_array_buffers_async_read()
  2302. {
  2303. #if defined(BOOST_ASIO_HAS_BOOST_BIND)
  2304. namespace bindns = boost;
  2305. #else // defined(BOOST_ASIO_HAS_BOOST_BIND)
  2306. namespace bindns = std;
  2307. using std::placeholders::_1;
  2308. using std::placeholders::_2;
  2309. #endif // defined(BOOST_ASIO_HAS_BOOST_BIND)
  2310. #if defined(BOOST_ASIO_HAS_STD_ARRAY)
  2311. boost::asio::io_context ioc;
  2312. test_stream s(ioc);
  2313. char read_buf[sizeof(read_data)];
  2314. std::array<boost::asio::mutable_buffer, 2> buffers = { {
  2315. boost::asio::buffer(read_buf, 32),
  2316. boost::asio::buffer(read_buf) + 32 } };
  2317. s.reset(read_data, sizeof(read_data));
  2318. memset(read_buf, 0, sizeof(read_buf));
  2319. bool called = false;
  2320. boost::asio::async_read(s, buffers,
  2321. bindns::bind(async_read_handler,
  2322. _1, _2, sizeof(read_data), &called));
  2323. ioc.restart();
  2324. ioc.run();
  2325. BOOST_ASIO_CHECK(called);
  2326. BOOST_ASIO_CHECK(s.check_buffers(buffers, sizeof(read_data)));
  2327. s.reset(read_data, sizeof(read_data));
  2328. s.next_read_length(1);
  2329. memset(read_buf, 0, sizeof(read_buf));
  2330. called = false;
  2331. boost::asio::async_read(s, buffers,
  2332. bindns::bind(async_read_handler,
  2333. _1, _2, sizeof(read_data), &called));
  2334. ioc.restart();
  2335. ioc.run();
  2336. BOOST_ASIO_CHECK(called);
  2337. BOOST_ASIO_CHECK(s.check_buffers(buffers, sizeof(read_data)));
  2338. s.reset(read_data, sizeof(read_data));
  2339. s.next_read_length(10);
  2340. memset(read_buf, 0, sizeof(read_buf));
  2341. called = false;
  2342. boost::asio::async_read(s, buffers,
  2343. bindns::bind(async_read_handler,
  2344. _1, _2, sizeof(read_data), &called));
  2345. ioc.restart();
  2346. ioc.run();
  2347. BOOST_ASIO_CHECK(called);
  2348. BOOST_ASIO_CHECK(s.check_buffers(buffers, sizeof(read_data)));
  2349. s.reset(read_data, sizeof(read_data));
  2350. memset(read_buf, 0, sizeof(read_buf));
  2351. int i = boost::asio::async_read(s, buffers, archetypes::lazy_handler());
  2352. BOOST_ASIO_CHECK(i == 42);
  2353. ioc.restart();
  2354. ioc.run();
  2355. BOOST_ASIO_CHECK(s.check_buffers(buffers, sizeof(read_data)));
  2356. #endif // defined(BOOST_ASIO_HAS_STD_ARRAY)
  2357. }
  2358. void test_3_arg_vector_buffers_async_read()
  2359. {
  2360. #if defined(BOOST_ASIO_HAS_BOOST_BIND)
  2361. namespace bindns = boost;
  2362. #else // defined(BOOST_ASIO_HAS_BOOST_BIND)
  2363. namespace bindns = std;
  2364. using std::placeholders::_1;
  2365. using std::placeholders::_2;
  2366. #endif // defined(BOOST_ASIO_HAS_BOOST_BIND)
  2367. boost::asio::io_context ioc;
  2368. test_stream s(ioc);
  2369. char read_buf[sizeof(read_data)];
  2370. std::vector<boost::asio::mutable_buffer> buffers;
  2371. buffers.push_back(boost::asio::buffer(read_buf, 32));
  2372. buffers.push_back(boost::asio::buffer(read_buf, 39) + 32);
  2373. buffers.push_back(boost::asio::buffer(read_buf) + 39);
  2374. s.reset(read_data, sizeof(read_data));
  2375. memset(read_buf, 0, sizeof(read_buf));
  2376. bool called = false;
  2377. boost::asio::async_read(s, buffers,
  2378. bindns::bind(async_read_handler,
  2379. _1, _2, sizeof(read_data), &called));
  2380. ioc.restart();
  2381. ioc.run();
  2382. BOOST_ASIO_CHECK(called);
  2383. BOOST_ASIO_CHECK(s.check_buffers(buffers, sizeof(read_data)));
  2384. s.reset(read_data, sizeof(read_data));
  2385. s.next_read_length(1);
  2386. memset(read_buf, 0, sizeof(read_buf));
  2387. called = false;
  2388. boost::asio::async_read(s, buffers,
  2389. bindns::bind(async_read_handler,
  2390. _1, _2, sizeof(read_data), &called));
  2391. ioc.restart();
  2392. ioc.run();
  2393. BOOST_ASIO_CHECK(called);
  2394. BOOST_ASIO_CHECK(s.check_buffers(buffers, sizeof(read_data)));
  2395. s.reset(read_data, sizeof(read_data));
  2396. s.next_read_length(10);
  2397. memset(read_buf, 0, sizeof(read_buf));
  2398. called = false;
  2399. boost::asio::async_read(s, buffers,
  2400. bindns::bind(async_read_handler,
  2401. _1, _2, sizeof(read_data), &called));
  2402. ioc.restart();
  2403. ioc.run();
  2404. BOOST_ASIO_CHECK(called);
  2405. BOOST_ASIO_CHECK(s.check_buffers(buffers, sizeof(read_data)));
  2406. s.reset(read_data, sizeof(read_data));
  2407. memset(read_buf, 0, sizeof(read_buf));
  2408. int i = boost::asio::async_read(s, buffers, archetypes::lazy_handler());
  2409. BOOST_ASIO_CHECK(i == 42);
  2410. ioc.restart();
  2411. ioc.run();
  2412. BOOST_ASIO_CHECK(s.check_buffers(buffers, sizeof(read_data)));
  2413. }
  2414. void test_3_arg_dynamic_string_async_read()
  2415. {
  2416. #if defined(BOOST_ASIO_HAS_BOOST_BIND)
  2417. namespace bindns = boost;
  2418. #else // defined(BOOST_ASIO_HAS_BOOST_BIND)
  2419. namespace bindns = std;
  2420. using std::placeholders::_1;
  2421. using std::placeholders::_2;
  2422. #endif // defined(BOOST_ASIO_HAS_BOOST_BIND)
  2423. boost::asio::io_context ioc;
  2424. test_stream s(ioc);
  2425. std::string data;
  2426. boost::asio::dynamic_string_buffer<char, std::string::traits_type,
  2427. std::string::allocator_type> sb
  2428. = boost::asio::dynamic_buffer(data, sizeof(read_data));
  2429. s.reset(read_data, sizeof(read_data));
  2430. sb.consume(sb.size());
  2431. bool called = false;
  2432. boost::asio::async_read(s, sb,
  2433. bindns::bind(async_read_handler,
  2434. _1, _2, sizeof(read_data), &called));
  2435. ioc.restart();
  2436. ioc.run();
  2437. BOOST_ASIO_CHECK(called);
  2438. BOOST_ASIO_CHECK(sb.size() == sizeof(read_data));
  2439. BOOST_ASIO_CHECK(s.check_buffers(sb.data(0, sb.size()), sizeof(read_data)));
  2440. s.reset(read_data, sizeof(read_data));
  2441. s.next_read_length(1);
  2442. sb.consume(sb.size());
  2443. called = false;
  2444. boost::asio::async_read(s, sb,
  2445. bindns::bind(async_read_handler,
  2446. _1, _2, sizeof(read_data), &called));
  2447. ioc.restart();
  2448. ioc.run();
  2449. BOOST_ASIO_CHECK(called);
  2450. BOOST_ASIO_CHECK(sb.size() == sizeof(read_data));
  2451. BOOST_ASIO_CHECK(s.check_buffers(sb.data(0, sb.size()), sizeof(read_data)));
  2452. s.reset(read_data, sizeof(read_data));
  2453. s.next_read_length(10);
  2454. sb.consume(sb.size());
  2455. called = false;
  2456. boost::asio::async_read(s, sb,
  2457. bindns::bind(async_read_handler,
  2458. _1, _2, sizeof(read_data), &called));
  2459. ioc.restart();
  2460. ioc.run();
  2461. BOOST_ASIO_CHECK(called);
  2462. BOOST_ASIO_CHECK(sb.size() == sizeof(read_data));
  2463. BOOST_ASIO_CHECK(s.check_buffers(sb.data(0, sb.size()), sizeof(read_data)));
  2464. s.reset(read_data, sizeof(read_data));
  2465. sb.consume(sb.size());
  2466. int i = boost::asio::async_read(s, sb, archetypes::lazy_handler());
  2467. BOOST_ASIO_CHECK(i == 42);
  2468. ioc.restart();
  2469. ioc.run();
  2470. BOOST_ASIO_CHECK(sb.size() == sizeof(read_data));
  2471. BOOST_ASIO_CHECK(s.check_buffers(sb.data(0, sb.size()), sizeof(read_data)));
  2472. }
  2473. void test_3_arg_streambuf_async_read()
  2474. {
  2475. #if !defined(BOOST_ASIO_NO_DYNAMIC_BUFFER_V1)
  2476. #if defined(BOOST_ASIO_HAS_BOOST_BIND)
  2477. namespace bindns = boost;
  2478. #else // defined(BOOST_ASIO_HAS_BOOST_BIND)
  2479. namespace bindns = std;
  2480. using std::placeholders::_1;
  2481. using std::placeholders::_2;
  2482. #endif // defined(BOOST_ASIO_HAS_BOOST_BIND)
  2483. boost::asio::io_context ioc;
  2484. test_stream s(ioc);
  2485. boost::asio::streambuf sb(sizeof(read_data));
  2486. s.reset(read_data, sizeof(read_data));
  2487. sb.consume(sb.size());
  2488. bool called = false;
  2489. boost::asio::async_read(s, sb,
  2490. bindns::bind(async_read_handler,
  2491. _1, _2, sizeof(read_data), &called));
  2492. ioc.restart();
  2493. ioc.run();
  2494. BOOST_ASIO_CHECK(called);
  2495. BOOST_ASIO_CHECK(sb.size() == sizeof(read_data));
  2496. BOOST_ASIO_CHECK(s.check_buffers(sb.data(), sizeof(read_data)));
  2497. s.reset(read_data, sizeof(read_data));
  2498. s.next_read_length(1);
  2499. sb.consume(sb.size());
  2500. called = false;
  2501. boost::asio::async_read(s, sb,
  2502. bindns::bind(async_read_handler,
  2503. _1, _2, sizeof(read_data), &called));
  2504. ioc.restart();
  2505. ioc.run();
  2506. BOOST_ASIO_CHECK(called);
  2507. BOOST_ASIO_CHECK(sb.size() == sizeof(read_data));
  2508. BOOST_ASIO_CHECK(s.check_buffers(sb.data(), sizeof(read_data)));
  2509. s.reset(read_data, sizeof(read_data));
  2510. s.next_read_length(10);
  2511. sb.consume(sb.size());
  2512. called = false;
  2513. boost::asio::async_read(s, sb,
  2514. bindns::bind(async_read_handler,
  2515. _1, _2, sizeof(read_data), &called));
  2516. ioc.restart();
  2517. ioc.run();
  2518. BOOST_ASIO_CHECK(called);
  2519. BOOST_ASIO_CHECK(sb.size() == sizeof(read_data));
  2520. BOOST_ASIO_CHECK(s.check_buffers(sb.data(), sizeof(read_data)));
  2521. s.reset(read_data, sizeof(read_data));
  2522. sb.consume(sb.size());
  2523. int i = boost::asio::async_read(s, sb, archetypes::lazy_handler());
  2524. BOOST_ASIO_CHECK(i == 42);
  2525. ioc.restart();
  2526. ioc.run();
  2527. BOOST_ASIO_CHECK(sb.size() == sizeof(read_data));
  2528. BOOST_ASIO_CHECK(s.check_buffers(sb.data(), sizeof(read_data)));
  2529. #endif // !defined(BOOST_ASIO_NO_DYNAMIC_BUFFER_V1)
  2530. }
  2531. void test_4_arg_mutable_buffer_async_read()
  2532. {
  2533. #if defined(BOOST_ASIO_HAS_BOOST_BIND)
  2534. namespace bindns = boost;
  2535. #else // defined(BOOST_ASIO_HAS_BOOST_BIND)
  2536. namespace bindns = std;
  2537. using std::placeholders::_1;
  2538. using std::placeholders::_2;
  2539. #endif // defined(BOOST_ASIO_HAS_BOOST_BIND)
  2540. boost::asio::io_context ioc;
  2541. test_stream s(ioc);
  2542. char read_buf[sizeof(read_data)];
  2543. boost::asio::mutable_buffer buffers
  2544. = boost::asio::buffer(read_buf, sizeof(read_buf));
  2545. s.reset(read_data, sizeof(read_data));
  2546. memset(read_buf, 0, sizeof(read_buf));
  2547. bool called = false;
  2548. boost::asio::async_read(s, buffers, boost::asio::transfer_all(),
  2549. bindns::bind(async_read_handler,
  2550. _1, _2, sizeof(read_data), &called));
  2551. ioc.restart();
  2552. ioc.run();
  2553. BOOST_ASIO_CHECK(called);
  2554. BOOST_ASIO_CHECK(s.check_buffers(buffers, sizeof(read_data)));
  2555. s.reset(read_data, sizeof(read_data));
  2556. s.next_read_length(1);
  2557. memset(read_buf, 0, sizeof(read_buf));
  2558. called = false;
  2559. boost::asio::async_read(s, buffers, boost::asio::transfer_all(),
  2560. bindns::bind(async_read_handler,
  2561. _1, _2, sizeof(read_data), &called));
  2562. ioc.restart();
  2563. ioc.run();
  2564. BOOST_ASIO_CHECK(called);
  2565. BOOST_ASIO_CHECK(s.check_buffers(buffers, sizeof(read_data)));
  2566. s.reset(read_data, sizeof(read_data));
  2567. s.next_read_length(10);
  2568. memset(read_buf, 0, sizeof(read_buf));
  2569. called = false;
  2570. boost::asio::async_read(s, buffers, boost::asio::transfer_all(),
  2571. bindns::bind(async_read_handler,
  2572. _1, _2, sizeof(read_data), &called));
  2573. ioc.restart();
  2574. ioc.run();
  2575. BOOST_ASIO_CHECK(called);
  2576. BOOST_ASIO_CHECK(s.check_buffers(buffers, sizeof(read_data)));
  2577. s.reset(read_data, sizeof(read_data));
  2578. memset(read_buf, 0, sizeof(read_buf));
  2579. called = false;
  2580. boost::asio::async_read(s, buffers, boost::asio::transfer_at_least(1),
  2581. bindns::bind(async_read_handler,
  2582. _1, _2, sizeof(read_data), &called));
  2583. ioc.restart();
  2584. ioc.run();
  2585. BOOST_ASIO_CHECK(called);
  2586. BOOST_ASIO_CHECK(s.check_buffers(buffers, sizeof(read_data)));
  2587. s.reset(read_data, sizeof(read_data));
  2588. s.next_read_length(1);
  2589. memset(read_buf, 0, sizeof(read_buf));
  2590. called = false;
  2591. boost::asio::async_read(s, buffers, boost::asio::transfer_at_least(1),
  2592. bindns::bind(async_read_handler,
  2593. _1, _2, 1, &called));
  2594. ioc.restart();
  2595. ioc.run();
  2596. BOOST_ASIO_CHECK(called);
  2597. BOOST_ASIO_CHECK(s.check_buffers(buffers, 1));
  2598. s.reset(read_data, sizeof(read_data));
  2599. s.next_read_length(10);
  2600. memset(read_buf, 0, sizeof(read_buf));
  2601. called = false;
  2602. boost::asio::async_read(s, buffers, boost::asio::transfer_at_least(1),
  2603. bindns::bind(async_read_handler,
  2604. _1, _2, 10, &called));
  2605. ioc.restart();
  2606. ioc.run();
  2607. BOOST_ASIO_CHECK(called);
  2608. BOOST_ASIO_CHECK(s.check_buffers(buffers, 10));
  2609. s.reset(read_data, sizeof(read_data));
  2610. memset(read_buf, 0, sizeof(read_buf));
  2611. called = false;
  2612. boost::asio::async_read(s, buffers, boost::asio::transfer_at_least(10),
  2613. bindns::bind(async_read_handler,
  2614. _1, _2, sizeof(read_data), &called));
  2615. ioc.restart();
  2616. ioc.run();
  2617. BOOST_ASIO_CHECK(called);
  2618. BOOST_ASIO_CHECK(s.check_buffers(buffers, sizeof(read_data)));
  2619. s.reset(read_data, sizeof(read_data));
  2620. s.next_read_length(1);
  2621. memset(read_buf, 0, sizeof(read_buf));
  2622. called = false;
  2623. boost::asio::async_read(s, buffers, boost::asio::transfer_at_least(10),
  2624. bindns::bind(async_read_handler,
  2625. _1, _2, 10, &called));
  2626. ioc.restart();
  2627. ioc.run();
  2628. BOOST_ASIO_CHECK(called);
  2629. BOOST_ASIO_CHECK(s.check_buffers(buffers, 10));
  2630. s.reset(read_data, sizeof(read_data));
  2631. s.next_read_length(10);
  2632. memset(read_buf, 0, sizeof(read_buf));
  2633. called = false;
  2634. boost::asio::async_read(s, buffers, boost::asio::transfer_at_least(10),
  2635. bindns::bind(async_read_handler,
  2636. _1, _2, 10, &called));
  2637. ioc.restart();
  2638. ioc.run();
  2639. BOOST_ASIO_CHECK(called);
  2640. BOOST_ASIO_CHECK(s.check_buffers(buffers, 10));
  2641. s.reset(read_data, sizeof(read_data));
  2642. memset(read_buf, 0, sizeof(read_buf));
  2643. called = false;
  2644. boost::asio::async_read(s, buffers, boost::asio::transfer_at_least(42),
  2645. bindns::bind(async_read_handler,
  2646. _1, _2, sizeof(read_data), &called));
  2647. ioc.restart();
  2648. ioc.run();
  2649. BOOST_ASIO_CHECK(called);
  2650. BOOST_ASIO_CHECK(s.check_buffers(buffers, sizeof(read_data)));
  2651. s.reset(read_data, sizeof(read_data));
  2652. s.next_read_length(1);
  2653. memset(read_buf, 0, sizeof(read_buf));
  2654. called = false;
  2655. boost::asio::async_read(s, buffers, boost::asio::transfer_at_least(42),
  2656. bindns::bind(async_read_handler,
  2657. _1, _2, 42, &called));
  2658. ioc.restart();
  2659. ioc.run();
  2660. BOOST_ASIO_CHECK(called);
  2661. BOOST_ASIO_CHECK(s.check_buffers(buffers, 42));
  2662. s.reset(read_data, sizeof(read_data));
  2663. s.next_read_length(10);
  2664. memset(read_buf, 0, sizeof(read_buf));
  2665. called = false;
  2666. boost::asio::async_read(s, buffers, boost::asio::transfer_at_least(42),
  2667. bindns::bind(async_read_handler,
  2668. _1, _2, 50, &called));
  2669. ioc.restart();
  2670. ioc.run();
  2671. BOOST_ASIO_CHECK(called);
  2672. BOOST_ASIO_CHECK(s.check_buffers(buffers, 50));
  2673. s.reset(read_data, sizeof(read_data));
  2674. memset(read_buf, 0, sizeof(read_buf));
  2675. called = false;
  2676. boost::asio::async_read(s, buffers, boost::asio::transfer_exactly(1),
  2677. bindns::bind(async_read_handler,
  2678. _1, _2, 1, &called));
  2679. ioc.restart();
  2680. ioc.run();
  2681. BOOST_ASIO_CHECK(called);
  2682. BOOST_ASIO_CHECK(s.check_buffers(buffers, 1));
  2683. s.reset(read_data, sizeof(read_data));
  2684. s.next_read_length(1);
  2685. memset(read_buf, 0, sizeof(read_buf));
  2686. called = false;
  2687. boost::asio::async_read(s, buffers, boost::asio::transfer_exactly(1),
  2688. bindns::bind(async_read_handler,
  2689. _1, _2, 1, &called));
  2690. ioc.restart();
  2691. ioc.run();
  2692. BOOST_ASIO_CHECK(called);
  2693. BOOST_ASIO_CHECK(s.check_buffers(buffers, 1));
  2694. s.reset(read_data, sizeof(read_data));
  2695. s.next_read_length(10);
  2696. memset(read_buf, 0, sizeof(read_buf));
  2697. called = false;
  2698. boost::asio::async_read(s, buffers, boost::asio::transfer_exactly(1),
  2699. bindns::bind(async_read_handler,
  2700. _1, _2, 1, &called));
  2701. ioc.restart();
  2702. ioc.run();
  2703. BOOST_ASIO_CHECK(called);
  2704. BOOST_ASIO_CHECK(s.check_buffers(buffers, 1));
  2705. s.reset(read_data, sizeof(read_data));
  2706. memset(read_buf, 0, sizeof(read_buf));
  2707. called = false;
  2708. boost::asio::async_read(s, buffers, boost::asio::transfer_exactly(10),
  2709. bindns::bind(async_read_handler,
  2710. _1, _2, 10, &called));
  2711. ioc.restart();
  2712. ioc.run();
  2713. BOOST_ASIO_CHECK(called);
  2714. BOOST_ASIO_CHECK(s.check_buffers(buffers, 10));
  2715. s.reset(read_data, sizeof(read_data));
  2716. s.next_read_length(1);
  2717. memset(read_buf, 0, sizeof(read_buf));
  2718. called = false;
  2719. boost::asio::async_read(s, buffers, boost::asio::transfer_exactly(10),
  2720. bindns::bind(async_read_handler,
  2721. _1, _2, 10, &called));
  2722. ioc.restart();
  2723. ioc.run();
  2724. BOOST_ASIO_CHECK(called);
  2725. BOOST_ASIO_CHECK(s.check_buffers(buffers, 10));
  2726. s.reset(read_data, sizeof(read_data));
  2727. s.next_read_length(10);
  2728. memset(read_buf, 0, sizeof(read_buf));
  2729. called = false;
  2730. boost::asio::async_read(s, buffers, boost::asio::transfer_exactly(10),
  2731. bindns::bind(async_read_handler,
  2732. _1, _2, 10, &called));
  2733. ioc.restart();
  2734. ioc.run();
  2735. BOOST_ASIO_CHECK(called);
  2736. BOOST_ASIO_CHECK(s.check_buffers(buffers, 10));
  2737. s.reset(read_data, sizeof(read_data));
  2738. memset(read_buf, 0, sizeof(read_buf));
  2739. called = false;
  2740. boost::asio::async_read(s, buffers, boost::asio::transfer_exactly(42),
  2741. bindns::bind(async_read_handler,
  2742. _1, _2, 42, &called));
  2743. ioc.restart();
  2744. ioc.run();
  2745. BOOST_ASIO_CHECK(called);
  2746. BOOST_ASIO_CHECK(s.check_buffers(buffers, 42));
  2747. s.reset(read_data, sizeof(read_data));
  2748. s.next_read_length(1);
  2749. memset(read_buf, 0, sizeof(read_buf));
  2750. called = false;
  2751. boost::asio::async_read(s, buffers, boost::asio::transfer_exactly(42),
  2752. bindns::bind(async_read_handler,
  2753. _1, _2, 42, &called));
  2754. ioc.restart();
  2755. ioc.run();
  2756. BOOST_ASIO_CHECK(called);
  2757. BOOST_ASIO_CHECK(s.check_buffers(buffers, 42));
  2758. s.reset(read_data, sizeof(read_data));
  2759. s.next_read_length(10);
  2760. memset(read_buf, 0, sizeof(read_buf));
  2761. called = false;
  2762. boost::asio::async_read(s, buffers, boost::asio::transfer_exactly(42),
  2763. bindns::bind(async_read_handler,
  2764. _1, _2, 42, &called));
  2765. ioc.restart();
  2766. ioc.run();
  2767. BOOST_ASIO_CHECK(called);
  2768. BOOST_ASIO_CHECK(s.check_buffers(buffers, 42));
  2769. s.reset(read_data, sizeof(read_data));
  2770. memset(read_buf, 0, sizeof(read_buf));
  2771. called = false;
  2772. boost::asio::async_read(s, buffers, old_style_transfer_all,
  2773. bindns::bind(async_read_handler,
  2774. _1, _2, sizeof(read_data), &called));
  2775. ioc.restart();
  2776. ioc.run();
  2777. BOOST_ASIO_CHECK(called);
  2778. BOOST_ASIO_CHECK(s.check_buffers(buffers, sizeof(read_data)));
  2779. s.reset(read_data, sizeof(read_data));
  2780. s.next_read_length(1);
  2781. memset(read_buf, 0, sizeof(read_buf));
  2782. called = false;
  2783. boost::asio::async_read(s, buffers, old_style_transfer_all,
  2784. bindns::bind(async_read_handler,
  2785. _1, _2, sizeof(read_data), &called));
  2786. ioc.restart();
  2787. ioc.run();
  2788. BOOST_ASIO_CHECK(called);
  2789. BOOST_ASIO_CHECK(s.check_buffers(buffers, sizeof(read_data)));
  2790. s.reset(read_data, sizeof(read_data));
  2791. s.next_read_length(10);
  2792. memset(read_buf, 0, sizeof(read_buf));
  2793. called = false;
  2794. boost::asio::async_read(s, buffers, old_style_transfer_all,
  2795. bindns::bind(async_read_handler,
  2796. _1, _2, sizeof(read_data), &called));
  2797. ioc.restart();
  2798. ioc.run();
  2799. BOOST_ASIO_CHECK(called);
  2800. BOOST_ASIO_CHECK(s.check_buffers(buffers, sizeof(read_data)));
  2801. s.reset(read_data, sizeof(read_data));
  2802. memset(read_buf, 0, sizeof(read_buf));
  2803. called = false;
  2804. boost::asio::async_read(s, buffers, short_transfer(),
  2805. bindns::bind(async_read_handler,
  2806. _1, _2, sizeof(read_data), &called));
  2807. ioc.restart();
  2808. ioc.run();
  2809. BOOST_ASIO_CHECK(called);
  2810. BOOST_ASIO_CHECK(s.check_buffers(buffers, sizeof(read_data)));
  2811. s.reset(read_data, sizeof(read_data));
  2812. s.next_read_length(1);
  2813. memset(read_buf, 0, sizeof(read_buf));
  2814. called = false;
  2815. boost::asio::async_read(s, buffers, short_transfer(),
  2816. bindns::bind(async_read_handler,
  2817. _1, _2, sizeof(read_data), &called));
  2818. ioc.restart();
  2819. ioc.run();
  2820. BOOST_ASIO_CHECK(called);
  2821. BOOST_ASIO_CHECK(s.check_buffers(buffers, sizeof(read_data)));
  2822. s.reset(read_data, sizeof(read_data));
  2823. s.next_read_length(10);
  2824. memset(read_buf, 0, sizeof(read_buf));
  2825. called = false;
  2826. boost::asio::async_read(s, buffers, short_transfer(),
  2827. bindns::bind(async_read_handler,
  2828. _1, _2, sizeof(read_data), &called));
  2829. ioc.restart();
  2830. ioc.run();
  2831. BOOST_ASIO_CHECK(called);
  2832. BOOST_ASIO_CHECK(s.check_buffers(buffers, sizeof(read_data)));
  2833. s.reset(read_data, sizeof(read_data));
  2834. memset(read_buf, 0, sizeof(read_buf));
  2835. int i = boost::asio::async_read(s, buffers,
  2836. short_transfer(), archetypes::lazy_handler());
  2837. BOOST_ASIO_CHECK(i == 42);
  2838. ioc.restart();
  2839. ioc.run();
  2840. BOOST_ASIO_CHECK(s.check_buffers(buffers, sizeof(read_data)));
  2841. }
  2842. void test_4_arg_boost_array_buffers_async_read()
  2843. {
  2844. #if defined(BOOST_ASIO_HAS_BOOST_BIND)
  2845. namespace bindns = boost;
  2846. #else // defined(BOOST_ASIO_HAS_BOOST_BIND)
  2847. namespace bindns = std;
  2848. using std::placeholders::_1;
  2849. using std::placeholders::_2;
  2850. #endif // defined(BOOST_ASIO_HAS_BOOST_BIND)
  2851. #if defined(BOOST_ASIO_HAS_BOOST_ARRAY)
  2852. boost::asio::io_context ioc;
  2853. test_stream s(ioc);
  2854. char read_buf[sizeof(read_data)];
  2855. boost::array<boost::asio::mutable_buffer, 2> buffers = { {
  2856. boost::asio::buffer(read_buf, 32),
  2857. boost::asio::buffer(read_buf) + 32 } };
  2858. s.reset(read_data, sizeof(read_data));
  2859. memset(read_buf, 0, sizeof(read_buf));
  2860. bool called = false;
  2861. boost::asio::async_read(s, buffers, boost::asio::transfer_all(),
  2862. bindns::bind(async_read_handler,
  2863. _1, _2, sizeof(read_data), &called));
  2864. ioc.restart();
  2865. ioc.run();
  2866. BOOST_ASIO_CHECK(called);
  2867. BOOST_ASIO_CHECK(s.check_buffers(buffers, sizeof(read_data)));
  2868. s.reset(read_data, sizeof(read_data));
  2869. s.next_read_length(1);
  2870. memset(read_buf, 0, sizeof(read_buf));
  2871. called = false;
  2872. boost::asio::async_read(s, buffers, boost::asio::transfer_all(),
  2873. bindns::bind(async_read_handler,
  2874. _1, _2, sizeof(read_data), &called));
  2875. ioc.restart();
  2876. ioc.run();
  2877. BOOST_ASIO_CHECK(called);
  2878. BOOST_ASIO_CHECK(s.check_buffers(buffers, sizeof(read_data)));
  2879. s.reset(read_data, sizeof(read_data));
  2880. s.next_read_length(10);
  2881. memset(read_buf, 0, sizeof(read_buf));
  2882. called = false;
  2883. boost::asio::async_read(s, buffers, boost::asio::transfer_all(),
  2884. bindns::bind(async_read_handler,
  2885. _1, _2, sizeof(read_data), &called));
  2886. ioc.restart();
  2887. ioc.run();
  2888. BOOST_ASIO_CHECK(called);
  2889. BOOST_ASIO_CHECK(s.check_buffers(buffers, sizeof(read_data)));
  2890. s.reset(read_data, sizeof(read_data));
  2891. memset(read_buf, 0, sizeof(read_buf));
  2892. called = false;
  2893. boost::asio::async_read(s, buffers, boost::asio::transfer_at_least(1),
  2894. bindns::bind(async_read_handler,
  2895. _1, _2, sizeof(read_data), &called));
  2896. ioc.restart();
  2897. ioc.run();
  2898. BOOST_ASIO_CHECK(called);
  2899. BOOST_ASIO_CHECK(s.check_buffers(buffers, sizeof(read_data)));
  2900. s.reset(read_data, sizeof(read_data));
  2901. s.next_read_length(1);
  2902. memset(read_buf, 0, sizeof(read_buf));
  2903. called = false;
  2904. boost::asio::async_read(s, buffers, boost::asio::transfer_at_least(1),
  2905. bindns::bind(async_read_handler,
  2906. _1, _2, 1, &called));
  2907. ioc.restart();
  2908. ioc.run();
  2909. BOOST_ASIO_CHECK(called);
  2910. BOOST_ASIO_CHECK(s.check_buffers(buffers, 1));
  2911. s.reset(read_data, sizeof(read_data));
  2912. s.next_read_length(10);
  2913. memset(read_buf, 0, sizeof(read_buf));
  2914. called = false;
  2915. boost::asio::async_read(s, buffers, boost::asio::transfer_at_least(1),
  2916. bindns::bind(async_read_handler,
  2917. _1, _2, 10, &called));
  2918. ioc.restart();
  2919. ioc.run();
  2920. BOOST_ASIO_CHECK(called);
  2921. BOOST_ASIO_CHECK(s.check_buffers(buffers, 10));
  2922. s.reset(read_data, sizeof(read_data));
  2923. memset(read_buf, 0, sizeof(read_buf));
  2924. called = false;
  2925. boost::asio::async_read(s, buffers, boost::asio::transfer_at_least(10),
  2926. bindns::bind(async_read_handler,
  2927. _1, _2, sizeof(read_data), &called));
  2928. ioc.restart();
  2929. ioc.run();
  2930. BOOST_ASIO_CHECK(called);
  2931. BOOST_ASIO_CHECK(s.check_buffers(buffers, sizeof(read_data)));
  2932. s.reset(read_data, sizeof(read_data));
  2933. s.next_read_length(1);
  2934. memset(read_buf, 0, sizeof(read_buf));
  2935. called = false;
  2936. boost::asio::async_read(s, buffers, boost::asio::transfer_at_least(10),
  2937. bindns::bind(async_read_handler,
  2938. _1, _2, 10, &called));
  2939. ioc.restart();
  2940. ioc.run();
  2941. BOOST_ASIO_CHECK(called);
  2942. BOOST_ASIO_CHECK(s.check_buffers(buffers, 10));
  2943. s.reset(read_data, sizeof(read_data));
  2944. s.next_read_length(10);
  2945. memset(read_buf, 0, sizeof(read_buf));
  2946. called = false;
  2947. boost::asio::async_read(s, buffers, boost::asio::transfer_at_least(10),
  2948. bindns::bind(async_read_handler,
  2949. _1, _2, 10, &called));
  2950. ioc.restart();
  2951. ioc.run();
  2952. BOOST_ASIO_CHECK(called);
  2953. BOOST_ASIO_CHECK(s.check_buffers(buffers, 10));
  2954. s.reset(read_data, sizeof(read_data));
  2955. memset(read_buf, 0, sizeof(read_buf));
  2956. called = false;
  2957. boost::asio::async_read(s, buffers, boost::asio::transfer_at_least(42),
  2958. bindns::bind(async_read_handler,
  2959. _1, _2, sizeof(read_data), &called));
  2960. ioc.restart();
  2961. ioc.run();
  2962. BOOST_ASIO_CHECK(called);
  2963. BOOST_ASIO_CHECK(s.check_buffers(buffers, sizeof(read_data)));
  2964. s.reset(read_data, sizeof(read_data));
  2965. s.next_read_length(1);
  2966. memset(read_buf, 0, sizeof(read_buf));
  2967. called = false;
  2968. boost::asio::async_read(s, buffers, boost::asio::transfer_at_least(42),
  2969. bindns::bind(async_read_handler,
  2970. _1, _2, 42, &called));
  2971. ioc.restart();
  2972. ioc.run();
  2973. BOOST_ASIO_CHECK(called);
  2974. BOOST_ASIO_CHECK(s.check_buffers(buffers, 42));
  2975. s.reset(read_data, sizeof(read_data));
  2976. s.next_read_length(10);
  2977. memset(read_buf, 0, sizeof(read_buf));
  2978. called = false;
  2979. boost::asio::async_read(s, buffers, boost::asio::transfer_at_least(42),
  2980. bindns::bind(async_read_handler,
  2981. _1, _2, 50, &called));
  2982. ioc.restart();
  2983. ioc.run();
  2984. BOOST_ASIO_CHECK(called);
  2985. BOOST_ASIO_CHECK(s.check_buffers(buffers, 50));
  2986. s.reset(read_data, sizeof(read_data));
  2987. memset(read_buf, 0, sizeof(read_buf));
  2988. called = false;
  2989. boost::asio::async_read(s, buffers, boost::asio::transfer_exactly(1),
  2990. bindns::bind(async_read_handler,
  2991. _1, _2, 1, &called));
  2992. ioc.restart();
  2993. ioc.run();
  2994. BOOST_ASIO_CHECK(called);
  2995. BOOST_ASIO_CHECK(s.check_buffers(buffers, 1));
  2996. s.reset(read_data, sizeof(read_data));
  2997. s.next_read_length(1);
  2998. memset(read_buf, 0, sizeof(read_buf));
  2999. called = false;
  3000. boost::asio::async_read(s, buffers, boost::asio::transfer_exactly(1),
  3001. bindns::bind(async_read_handler,
  3002. _1, _2, 1, &called));
  3003. ioc.restart();
  3004. ioc.run();
  3005. BOOST_ASIO_CHECK(called);
  3006. BOOST_ASIO_CHECK(s.check_buffers(buffers, 1));
  3007. s.reset(read_data, sizeof(read_data));
  3008. s.next_read_length(10);
  3009. memset(read_buf, 0, sizeof(read_buf));
  3010. called = false;
  3011. boost::asio::async_read(s, buffers, boost::asio::transfer_exactly(1),
  3012. bindns::bind(async_read_handler,
  3013. _1, _2, 1, &called));
  3014. ioc.restart();
  3015. ioc.run();
  3016. BOOST_ASIO_CHECK(called);
  3017. BOOST_ASIO_CHECK(s.check_buffers(buffers, 1));
  3018. s.reset(read_data, sizeof(read_data));
  3019. memset(read_buf, 0, sizeof(read_buf));
  3020. called = false;
  3021. boost::asio::async_read(s, buffers, boost::asio::transfer_exactly(10),
  3022. bindns::bind(async_read_handler,
  3023. _1, _2, 10, &called));
  3024. ioc.restart();
  3025. ioc.run();
  3026. BOOST_ASIO_CHECK(called);
  3027. BOOST_ASIO_CHECK(s.check_buffers(buffers, 10));
  3028. s.reset(read_data, sizeof(read_data));
  3029. s.next_read_length(1);
  3030. memset(read_buf, 0, sizeof(read_buf));
  3031. called = false;
  3032. boost::asio::async_read(s, buffers, boost::asio::transfer_exactly(10),
  3033. bindns::bind(async_read_handler,
  3034. _1, _2, 10, &called));
  3035. ioc.restart();
  3036. ioc.run();
  3037. BOOST_ASIO_CHECK(called);
  3038. BOOST_ASIO_CHECK(s.check_buffers(buffers, 10));
  3039. s.reset(read_data, sizeof(read_data));
  3040. s.next_read_length(10);
  3041. memset(read_buf, 0, sizeof(read_buf));
  3042. called = false;
  3043. boost::asio::async_read(s, buffers, boost::asio::transfer_exactly(10),
  3044. bindns::bind(async_read_handler,
  3045. _1, _2, 10, &called));
  3046. ioc.restart();
  3047. ioc.run();
  3048. BOOST_ASIO_CHECK(called);
  3049. BOOST_ASIO_CHECK(s.check_buffers(buffers, 10));
  3050. s.reset(read_data, sizeof(read_data));
  3051. memset(read_buf, 0, sizeof(read_buf));
  3052. called = false;
  3053. boost::asio::async_read(s, buffers, boost::asio::transfer_exactly(42),
  3054. bindns::bind(async_read_handler,
  3055. _1, _2, 42, &called));
  3056. ioc.restart();
  3057. ioc.run();
  3058. BOOST_ASIO_CHECK(called);
  3059. BOOST_ASIO_CHECK(s.check_buffers(buffers, 42));
  3060. s.reset(read_data, sizeof(read_data));
  3061. s.next_read_length(1);
  3062. memset(read_buf, 0, sizeof(read_buf));
  3063. called = false;
  3064. boost::asio::async_read(s, buffers, boost::asio::transfer_exactly(42),
  3065. bindns::bind(async_read_handler,
  3066. _1, _2, 42, &called));
  3067. ioc.restart();
  3068. ioc.run();
  3069. BOOST_ASIO_CHECK(called);
  3070. BOOST_ASIO_CHECK(s.check_buffers(buffers, 42));
  3071. s.reset(read_data, sizeof(read_data));
  3072. s.next_read_length(10);
  3073. memset(read_buf, 0, sizeof(read_buf));
  3074. called = false;
  3075. boost::asio::async_read(s, buffers, boost::asio::transfer_exactly(42),
  3076. bindns::bind(async_read_handler,
  3077. _1, _2, 42, &called));
  3078. ioc.restart();
  3079. ioc.run();
  3080. BOOST_ASIO_CHECK(called);
  3081. BOOST_ASIO_CHECK(s.check_buffers(buffers, 42));
  3082. s.reset(read_data, sizeof(read_data));
  3083. memset(read_buf, 0, sizeof(read_buf));
  3084. called = false;
  3085. boost::asio::async_read(s, buffers, old_style_transfer_all,
  3086. bindns::bind(async_read_handler,
  3087. _1, _2, sizeof(read_data), &called));
  3088. ioc.restart();
  3089. ioc.run();
  3090. BOOST_ASIO_CHECK(called);
  3091. BOOST_ASIO_CHECK(s.check_buffers(buffers, sizeof(read_data)));
  3092. s.reset(read_data, sizeof(read_data));
  3093. s.next_read_length(1);
  3094. memset(read_buf, 0, sizeof(read_buf));
  3095. called = false;
  3096. boost::asio::async_read(s, buffers, old_style_transfer_all,
  3097. bindns::bind(async_read_handler,
  3098. _1, _2, sizeof(read_data), &called));
  3099. ioc.restart();
  3100. ioc.run();
  3101. BOOST_ASIO_CHECK(called);
  3102. BOOST_ASIO_CHECK(s.check_buffers(buffers, sizeof(read_data)));
  3103. s.reset(read_data, sizeof(read_data));
  3104. s.next_read_length(10);
  3105. memset(read_buf, 0, sizeof(read_buf));
  3106. called = false;
  3107. boost::asio::async_read(s, buffers, old_style_transfer_all,
  3108. bindns::bind(async_read_handler,
  3109. _1, _2, sizeof(read_data), &called));
  3110. ioc.restart();
  3111. ioc.run();
  3112. BOOST_ASIO_CHECK(called);
  3113. BOOST_ASIO_CHECK(s.check_buffers(buffers, sizeof(read_data)));
  3114. s.reset(read_data, sizeof(read_data));
  3115. memset(read_buf, 0, sizeof(read_buf));
  3116. called = false;
  3117. boost::asio::async_read(s, buffers, short_transfer(),
  3118. bindns::bind(async_read_handler,
  3119. _1, _2, sizeof(read_data), &called));
  3120. ioc.restart();
  3121. ioc.run();
  3122. BOOST_ASIO_CHECK(called);
  3123. BOOST_ASIO_CHECK(s.check_buffers(buffers, sizeof(read_data)));
  3124. s.reset(read_data, sizeof(read_data));
  3125. s.next_read_length(1);
  3126. memset(read_buf, 0, sizeof(read_buf));
  3127. called = false;
  3128. boost::asio::async_read(s, buffers, short_transfer(),
  3129. bindns::bind(async_read_handler,
  3130. _1, _2, sizeof(read_data), &called));
  3131. ioc.restart();
  3132. ioc.run();
  3133. BOOST_ASIO_CHECK(called);
  3134. BOOST_ASIO_CHECK(s.check_buffers(buffers, sizeof(read_data)));
  3135. s.reset(read_data, sizeof(read_data));
  3136. s.next_read_length(10);
  3137. memset(read_buf, 0, sizeof(read_buf));
  3138. called = false;
  3139. boost::asio::async_read(s, buffers, short_transfer(),
  3140. bindns::bind(async_read_handler,
  3141. _1, _2, sizeof(read_data), &called));
  3142. ioc.restart();
  3143. ioc.run();
  3144. BOOST_ASIO_CHECK(called);
  3145. BOOST_ASIO_CHECK(s.check_buffers(buffers, sizeof(read_data)));
  3146. s.reset(read_data, sizeof(read_data));
  3147. memset(read_buf, 0, sizeof(read_buf));
  3148. int i = boost::asio::async_read(s, buffers,
  3149. short_transfer(), archetypes::lazy_handler());
  3150. BOOST_ASIO_CHECK(i == 42);
  3151. ioc.restart();
  3152. ioc.run();
  3153. BOOST_ASIO_CHECK(s.check_buffers(buffers, sizeof(read_data)));
  3154. #endif // defined(BOOST_ASIO_HAS_BOOST_ARRAY)
  3155. }
  3156. void test_4_arg_std_array_buffers_async_read()
  3157. {
  3158. #if defined(BOOST_ASIO_HAS_BOOST_BIND)
  3159. namespace bindns = boost;
  3160. #else // defined(BOOST_ASIO_HAS_BOOST_BIND)
  3161. namespace bindns = std;
  3162. using std::placeholders::_1;
  3163. using std::placeholders::_2;
  3164. #endif // defined(BOOST_ASIO_HAS_BOOST_BIND)
  3165. #if defined(BOOST_ASIO_HAS_STD_ARRAY)
  3166. boost::asio::io_context ioc;
  3167. test_stream s(ioc);
  3168. char read_buf[sizeof(read_data)];
  3169. std::array<boost::asio::mutable_buffer, 2> buffers = { {
  3170. boost::asio::buffer(read_buf, 32),
  3171. boost::asio::buffer(read_buf) + 32 } };
  3172. s.reset(read_data, sizeof(read_data));
  3173. memset(read_buf, 0, sizeof(read_buf));
  3174. bool called = false;
  3175. boost::asio::async_read(s, buffers, boost::asio::transfer_all(),
  3176. bindns::bind(async_read_handler,
  3177. _1, _2, sizeof(read_data), &called));
  3178. ioc.restart();
  3179. ioc.run();
  3180. BOOST_ASIO_CHECK(called);
  3181. BOOST_ASIO_CHECK(s.check_buffers(buffers, sizeof(read_data)));
  3182. s.reset(read_data, sizeof(read_data));
  3183. s.next_read_length(1);
  3184. memset(read_buf, 0, sizeof(read_buf));
  3185. called = false;
  3186. boost::asio::async_read(s, buffers, boost::asio::transfer_all(),
  3187. bindns::bind(async_read_handler,
  3188. _1, _2, sizeof(read_data), &called));
  3189. ioc.restart();
  3190. ioc.run();
  3191. BOOST_ASIO_CHECK(called);
  3192. BOOST_ASIO_CHECK(s.check_buffers(buffers, sizeof(read_data)));
  3193. s.reset(read_data, sizeof(read_data));
  3194. s.next_read_length(10);
  3195. memset(read_buf, 0, sizeof(read_buf));
  3196. called = false;
  3197. boost::asio::async_read(s, buffers, boost::asio::transfer_all(),
  3198. bindns::bind(async_read_handler,
  3199. _1, _2, sizeof(read_data), &called));
  3200. ioc.restart();
  3201. ioc.run();
  3202. BOOST_ASIO_CHECK(called);
  3203. BOOST_ASIO_CHECK(s.check_buffers(buffers, sizeof(read_data)));
  3204. s.reset(read_data, sizeof(read_data));
  3205. memset(read_buf, 0, sizeof(read_buf));
  3206. called = false;
  3207. boost::asio::async_read(s, buffers, boost::asio::transfer_at_least(1),
  3208. bindns::bind(async_read_handler,
  3209. _1, _2, sizeof(read_data), &called));
  3210. ioc.restart();
  3211. ioc.run();
  3212. BOOST_ASIO_CHECK(called);
  3213. BOOST_ASIO_CHECK(s.check_buffers(buffers, sizeof(read_data)));
  3214. s.reset(read_data, sizeof(read_data));
  3215. s.next_read_length(1);
  3216. memset(read_buf, 0, sizeof(read_buf));
  3217. called = false;
  3218. boost::asio::async_read(s, buffers, boost::asio::transfer_at_least(1),
  3219. bindns::bind(async_read_handler,
  3220. _1, _2, 1, &called));
  3221. ioc.restart();
  3222. ioc.run();
  3223. BOOST_ASIO_CHECK(called);
  3224. BOOST_ASIO_CHECK(s.check_buffers(buffers, 1));
  3225. s.reset(read_data, sizeof(read_data));
  3226. s.next_read_length(10);
  3227. memset(read_buf, 0, sizeof(read_buf));
  3228. called = false;
  3229. boost::asio::async_read(s, buffers, boost::asio::transfer_at_least(1),
  3230. bindns::bind(async_read_handler,
  3231. _1, _2, 10, &called));
  3232. ioc.restart();
  3233. ioc.run();
  3234. BOOST_ASIO_CHECK(called);
  3235. BOOST_ASIO_CHECK(s.check_buffers(buffers, 10));
  3236. s.reset(read_data, sizeof(read_data));
  3237. memset(read_buf, 0, sizeof(read_buf));
  3238. called = false;
  3239. boost::asio::async_read(s, buffers, boost::asio::transfer_at_least(10),
  3240. bindns::bind(async_read_handler,
  3241. _1, _2, sizeof(read_data), &called));
  3242. ioc.restart();
  3243. ioc.run();
  3244. BOOST_ASIO_CHECK(called);
  3245. BOOST_ASIO_CHECK(s.check_buffers(buffers, sizeof(read_data)));
  3246. s.reset(read_data, sizeof(read_data));
  3247. s.next_read_length(1);
  3248. memset(read_buf, 0, sizeof(read_buf));
  3249. called = false;
  3250. boost::asio::async_read(s, buffers, boost::asio::transfer_at_least(10),
  3251. bindns::bind(async_read_handler,
  3252. _1, _2, 10, &called));
  3253. ioc.restart();
  3254. ioc.run();
  3255. BOOST_ASIO_CHECK(called);
  3256. BOOST_ASIO_CHECK(s.check_buffers(buffers, 10));
  3257. s.reset(read_data, sizeof(read_data));
  3258. s.next_read_length(10);
  3259. memset(read_buf, 0, sizeof(read_buf));
  3260. called = false;
  3261. boost::asio::async_read(s, buffers, boost::asio::transfer_at_least(10),
  3262. bindns::bind(async_read_handler,
  3263. _1, _2, 10, &called));
  3264. ioc.restart();
  3265. ioc.run();
  3266. BOOST_ASIO_CHECK(called);
  3267. BOOST_ASIO_CHECK(s.check_buffers(buffers, 10));
  3268. s.reset(read_data, sizeof(read_data));
  3269. memset(read_buf, 0, sizeof(read_buf));
  3270. called = false;
  3271. boost::asio::async_read(s, buffers, boost::asio::transfer_at_least(42),
  3272. bindns::bind(async_read_handler,
  3273. _1, _2, sizeof(read_data), &called));
  3274. ioc.restart();
  3275. ioc.run();
  3276. BOOST_ASIO_CHECK(called);
  3277. BOOST_ASIO_CHECK(s.check_buffers(buffers, sizeof(read_data)));
  3278. s.reset(read_data, sizeof(read_data));
  3279. s.next_read_length(1);
  3280. memset(read_buf, 0, sizeof(read_buf));
  3281. called = false;
  3282. boost::asio::async_read(s, buffers, boost::asio::transfer_at_least(42),
  3283. bindns::bind(async_read_handler,
  3284. _1, _2, 42, &called));
  3285. ioc.restart();
  3286. ioc.run();
  3287. BOOST_ASIO_CHECK(called);
  3288. BOOST_ASIO_CHECK(s.check_buffers(buffers, 42));
  3289. s.reset(read_data, sizeof(read_data));
  3290. s.next_read_length(10);
  3291. memset(read_buf, 0, sizeof(read_buf));
  3292. called = false;
  3293. boost::asio::async_read(s, buffers, boost::asio::transfer_at_least(42),
  3294. bindns::bind(async_read_handler,
  3295. _1, _2, 50, &called));
  3296. ioc.restart();
  3297. ioc.run();
  3298. BOOST_ASIO_CHECK(called);
  3299. BOOST_ASIO_CHECK(s.check_buffers(buffers, 50));
  3300. s.reset(read_data, sizeof(read_data));
  3301. memset(read_buf, 0, sizeof(read_buf));
  3302. called = false;
  3303. boost::asio::async_read(s, buffers, boost::asio::transfer_exactly(1),
  3304. bindns::bind(async_read_handler,
  3305. _1, _2, 1, &called));
  3306. ioc.restart();
  3307. ioc.run();
  3308. BOOST_ASIO_CHECK(called);
  3309. BOOST_ASIO_CHECK(s.check_buffers(buffers, 1));
  3310. s.reset(read_data, sizeof(read_data));
  3311. s.next_read_length(1);
  3312. memset(read_buf, 0, sizeof(read_buf));
  3313. called = false;
  3314. boost::asio::async_read(s, buffers, boost::asio::transfer_exactly(1),
  3315. bindns::bind(async_read_handler,
  3316. _1, _2, 1, &called));
  3317. ioc.restart();
  3318. ioc.run();
  3319. BOOST_ASIO_CHECK(called);
  3320. BOOST_ASIO_CHECK(s.check_buffers(buffers, 1));
  3321. s.reset(read_data, sizeof(read_data));
  3322. s.next_read_length(10);
  3323. memset(read_buf, 0, sizeof(read_buf));
  3324. called = false;
  3325. boost::asio::async_read(s, buffers, boost::asio::transfer_exactly(1),
  3326. bindns::bind(async_read_handler,
  3327. _1, _2, 1, &called));
  3328. ioc.restart();
  3329. ioc.run();
  3330. BOOST_ASIO_CHECK(called);
  3331. BOOST_ASIO_CHECK(s.check_buffers(buffers, 1));
  3332. s.reset(read_data, sizeof(read_data));
  3333. memset(read_buf, 0, sizeof(read_buf));
  3334. called = false;
  3335. boost::asio::async_read(s, buffers, boost::asio::transfer_exactly(10),
  3336. bindns::bind(async_read_handler,
  3337. _1, _2, 10, &called));
  3338. ioc.restart();
  3339. ioc.run();
  3340. BOOST_ASIO_CHECK(called);
  3341. BOOST_ASIO_CHECK(s.check_buffers(buffers, 10));
  3342. s.reset(read_data, sizeof(read_data));
  3343. s.next_read_length(1);
  3344. memset(read_buf, 0, sizeof(read_buf));
  3345. called = false;
  3346. boost::asio::async_read(s, buffers, boost::asio::transfer_exactly(10),
  3347. bindns::bind(async_read_handler,
  3348. _1, _2, 10, &called));
  3349. ioc.restart();
  3350. ioc.run();
  3351. BOOST_ASIO_CHECK(called);
  3352. BOOST_ASIO_CHECK(s.check_buffers(buffers, 10));
  3353. s.reset(read_data, sizeof(read_data));
  3354. s.next_read_length(10);
  3355. memset(read_buf, 0, sizeof(read_buf));
  3356. called = false;
  3357. boost::asio::async_read(s, buffers, boost::asio::transfer_exactly(10),
  3358. bindns::bind(async_read_handler,
  3359. _1, _2, 10, &called));
  3360. ioc.restart();
  3361. ioc.run();
  3362. BOOST_ASIO_CHECK(called);
  3363. BOOST_ASIO_CHECK(s.check_buffers(buffers, 10));
  3364. s.reset(read_data, sizeof(read_data));
  3365. memset(read_buf, 0, sizeof(read_buf));
  3366. called = false;
  3367. boost::asio::async_read(s, buffers, boost::asio::transfer_exactly(42),
  3368. bindns::bind(async_read_handler,
  3369. _1, _2, 42, &called));
  3370. ioc.restart();
  3371. ioc.run();
  3372. BOOST_ASIO_CHECK(called);
  3373. BOOST_ASIO_CHECK(s.check_buffers(buffers, 42));
  3374. s.reset(read_data, sizeof(read_data));
  3375. s.next_read_length(1);
  3376. memset(read_buf, 0, sizeof(read_buf));
  3377. called = false;
  3378. boost::asio::async_read(s, buffers, boost::asio::transfer_exactly(42),
  3379. bindns::bind(async_read_handler,
  3380. _1, _2, 42, &called));
  3381. ioc.restart();
  3382. ioc.run();
  3383. BOOST_ASIO_CHECK(called);
  3384. BOOST_ASIO_CHECK(s.check_buffers(buffers, 42));
  3385. s.reset(read_data, sizeof(read_data));
  3386. s.next_read_length(10);
  3387. memset(read_buf, 0, sizeof(read_buf));
  3388. called = false;
  3389. boost::asio::async_read(s, buffers, boost::asio::transfer_exactly(42),
  3390. bindns::bind(async_read_handler,
  3391. _1, _2, 42, &called));
  3392. ioc.restart();
  3393. ioc.run();
  3394. BOOST_ASIO_CHECK(called);
  3395. BOOST_ASIO_CHECK(s.check_buffers(buffers, 42));
  3396. s.reset(read_data, sizeof(read_data));
  3397. memset(read_buf, 0, sizeof(read_buf));
  3398. called = false;
  3399. boost::asio::async_read(s, buffers, old_style_transfer_all,
  3400. bindns::bind(async_read_handler,
  3401. _1, _2, sizeof(read_data), &called));
  3402. ioc.restart();
  3403. ioc.run();
  3404. BOOST_ASIO_CHECK(called);
  3405. BOOST_ASIO_CHECK(s.check_buffers(buffers, sizeof(read_data)));
  3406. s.reset(read_data, sizeof(read_data));
  3407. s.next_read_length(1);
  3408. memset(read_buf, 0, sizeof(read_buf));
  3409. called = false;
  3410. boost::asio::async_read(s, buffers, old_style_transfer_all,
  3411. bindns::bind(async_read_handler,
  3412. _1, _2, sizeof(read_data), &called));
  3413. ioc.restart();
  3414. ioc.run();
  3415. BOOST_ASIO_CHECK(called);
  3416. BOOST_ASIO_CHECK(s.check_buffers(buffers, sizeof(read_data)));
  3417. s.reset(read_data, sizeof(read_data));
  3418. s.next_read_length(10);
  3419. memset(read_buf, 0, sizeof(read_buf));
  3420. called = false;
  3421. boost::asio::async_read(s, buffers, old_style_transfer_all,
  3422. bindns::bind(async_read_handler,
  3423. _1, _2, sizeof(read_data), &called));
  3424. ioc.restart();
  3425. ioc.run();
  3426. BOOST_ASIO_CHECK(called);
  3427. BOOST_ASIO_CHECK(s.check_buffers(buffers, sizeof(read_data)));
  3428. s.reset(read_data, sizeof(read_data));
  3429. memset(read_buf, 0, sizeof(read_buf));
  3430. called = false;
  3431. boost::asio::async_read(s, buffers, short_transfer(),
  3432. bindns::bind(async_read_handler,
  3433. _1, _2, sizeof(read_data), &called));
  3434. ioc.restart();
  3435. ioc.run();
  3436. BOOST_ASIO_CHECK(called);
  3437. BOOST_ASIO_CHECK(s.check_buffers(buffers, sizeof(read_data)));
  3438. s.reset(read_data, sizeof(read_data));
  3439. s.next_read_length(1);
  3440. memset(read_buf, 0, sizeof(read_buf));
  3441. called = false;
  3442. boost::asio::async_read(s, buffers, short_transfer(),
  3443. bindns::bind(async_read_handler,
  3444. _1, _2, sizeof(read_data), &called));
  3445. ioc.restart();
  3446. ioc.run();
  3447. BOOST_ASIO_CHECK(called);
  3448. BOOST_ASIO_CHECK(s.check_buffers(buffers, sizeof(read_data)));
  3449. s.reset(read_data, sizeof(read_data));
  3450. s.next_read_length(10);
  3451. memset(read_buf, 0, sizeof(read_buf));
  3452. called = false;
  3453. boost::asio::async_read(s, buffers, short_transfer(),
  3454. bindns::bind(async_read_handler,
  3455. _1, _2, sizeof(read_data), &called));
  3456. ioc.restart();
  3457. ioc.run();
  3458. BOOST_ASIO_CHECK(called);
  3459. BOOST_ASIO_CHECK(s.check_buffers(buffers, sizeof(read_data)));
  3460. s.reset(read_data, sizeof(read_data));
  3461. memset(read_buf, 0, sizeof(read_buf));
  3462. int i = boost::asio::async_read(s, buffers,
  3463. short_transfer(), archetypes::lazy_handler());
  3464. BOOST_ASIO_CHECK(i == 42);
  3465. ioc.restart();
  3466. ioc.run();
  3467. BOOST_ASIO_CHECK(s.check_buffers(buffers, sizeof(read_data)));
  3468. #endif // defined(BOOST_ASIO_HAS_STD_ARRAY)
  3469. }
  3470. void test_4_arg_vector_buffers_async_read()
  3471. {
  3472. #if defined(BOOST_ASIO_HAS_BOOST_BIND)
  3473. namespace bindns = boost;
  3474. #else // defined(BOOST_ASIO_HAS_BOOST_BIND)
  3475. namespace bindns = std;
  3476. using std::placeholders::_1;
  3477. using std::placeholders::_2;
  3478. #endif // defined(BOOST_ASIO_HAS_BOOST_BIND)
  3479. boost::asio::io_context ioc;
  3480. test_stream s(ioc);
  3481. char read_buf[sizeof(read_data)];
  3482. std::vector<boost::asio::mutable_buffer> buffers;
  3483. buffers.push_back(boost::asio::buffer(read_buf, 32));
  3484. buffers.push_back(boost::asio::buffer(read_buf, 39) + 32);
  3485. buffers.push_back(boost::asio::buffer(read_buf) + 39);
  3486. s.reset(read_data, sizeof(read_data));
  3487. memset(read_buf, 0, sizeof(read_buf));
  3488. bool called = false;
  3489. boost::asio::async_read(s, buffers, boost::asio::transfer_all(),
  3490. bindns::bind(async_read_handler,
  3491. _1, _2, sizeof(read_data), &called));
  3492. ioc.restart();
  3493. ioc.run();
  3494. BOOST_ASIO_CHECK(called);
  3495. BOOST_ASIO_CHECK(s.check_buffers(buffers, sizeof(read_data)));
  3496. s.reset(read_data, sizeof(read_data));
  3497. s.next_read_length(1);
  3498. memset(read_buf, 0, sizeof(read_buf));
  3499. called = false;
  3500. boost::asio::async_read(s, buffers, boost::asio::transfer_all(),
  3501. bindns::bind(async_read_handler,
  3502. _1, _2, sizeof(read_data), &called));
  3503. ioc.restart();
  3504. ioc.run();
  3505. BOOST_ASIO_CHECK(called);
  3506. BOOST_ASIO_CHECK(s.check_buffers(buffers, sizeof(read_data)));
  3507. s.reset(read_data, sizeof(read_data));
  3508. s.next_read_length(10);
  3509. memset(read_buf, 0, sizeof(read_buf));
  3510. called = false;
  3511. boost::asio::async_read(s, buffers, boost::asio::transfer_all(),
  3512. bindns::bind(async_read_handler,
  3513. _1, _2, sizeof(read_data), &called));
  3514. ioc.restart();
  3515. ioc.run();
  3516. BOOST_ASIO_CHECK(called);
  3517. BOOST_ASIO_CHECK(s.check_buffers(buffers, sizeof(read_data)));
  3518. s.reset(read_data, sizeof(read_data));
  3519. memset(read_buf, 0, sizeof(read_buf));
  3520. called = false;
  3521. boost::asio::async_read(s, buffers, boost::asio::transfer_at_least(1),
  3522. bindns::bind(async_read_handler,
  3523. _1, _2, sizeof(read_data), &called));
  3524. ioc.restart();
  3525. ioc.run();
  3526. BOOST_ASIO_CHECK(called);
  3527. BOOST_ASIO_CHECK(s.check_buffers(buffers, sizeof(read_data)));
  3528. s.reset(read_data, sizeof(read_data));
  3529. s.next_read_length(1);
  3530. memset(read_buf, 0, sizeof(read_buf));
  3531. called = false;
  3532. boost::asio::async_read(s, buffers, boost::asio::transfer_at_least(1),
  3533. bindns::bind(async_read_handler,
  3534. _1, _2, 1, &called));
  3535. ioc.restart();
  3536. ioc.run();
  3537. BOOST_ASIO_CHECK(called);
  3538. BOOST_ASIO_CHECK(s.check_buffers(buffers, 1));
  3539. s.reset(read_data, sizeof(read_data));
  3540. s.next_read_length(10);
  3541. memset(read_buf, 0, sizeof(read_buf));
  3542. called = false;
  3543. boost::asio::async_read(s, buffers, boost::asio::transfer_at_least(1),
  3544. bindns::bind(async_read_handler,
  3545. _1, _2, 10, &called));
  3546. ioc.restart();
  3547. ioc.run();
  3548. BOOST_ASIO_CHECK(called);
  3549. BOOST_ASIO_CHECK(s.check_buffers(buffers, 10));
  3550. s.reset(read_data, sizeof(read_data));
  3551. memset(read_buf, 0, sizeof(read_buf));
  3552. called = false;
  3553. boost::asio::async_read(s, buffers, boost::asio::transfer_at_least(10),
  3554. bindns::bind(async_read_handler,
  3555. _1, _2, sizeof(read_data), &called));
  3556. ioc.restart();
  3557. ioc.run();
  3558. BOOST_ASIO_CHECK(called);
  3559. BOOST_ASIO_CHECK(s.check_buffers(buffers, sizeof(read_data)));
  3560. s.reset(read_data, sizeof(read_data));
  3561. s.next_read_length(1);
  3562. memset(read_buf, 0, sizeof(read_buf));
  3563. called = false;
  3564. boost::asio::async_read(s, buffers, boost::asio::transfer_at_least(10),
  3565. bindns::bind(async_read_handler,
  3566. _1, _2, 10, &called));
  3567. ioc.restart();
  3568. ioc.run();
  3569. BOOST_ASIO_CHECK(called);
  3570. BOOST_ASIO_CHECK(s.check_buffers(buffers, 10));
  3571. s.reset(read_data, sizeof(read_data));
  3572. s.next_read_length(10);
  3573. memset(read_buf, 0, sizeof(read_buf));
  3574. called = false;
  3575. boost::asio::async_read(s, buffers, boost::asio::transfer_at_least(10),
  3576. bindns::bind(async_read_handler,
  3577. _1, _2, 10, &called));
  3578. ioc.restart();
  3579. ioc.run();
  3580. BOOST_ASIO_CHECK(called);
  3581. BOOST_ASIO_CHECK(s.check_buffers(buffers, 10));
  3582. s.reset(read_data, sizeof(read_data));
  3583. memset(read_buf, 0, sizeof(read_buf));
  3584. called = false;
  3585. boost::asio::async_read(s, buffers, boost::asio::transfer_at_least(42),
  3586. bindns::bind(async_read_handler,
  3587. _1, _2, sizeof(read_data), &called));
  3588. ioc.restart();
  3589. ioc.run();
  3590. BOOST_ASIO_CHECK(called);
  3591. BOOST_ASIO_CHECK(s.check_buffers(buffers, sizeof(read_data)));
  3592. s.reset(read_data, sizeof(read_data));
  3593. s.next_read_length(1);
  3594. memset(read_buf, 0, sizeof(read_buf));
  3595. called = false;
  3596. boost::asio::async_read(s, buffers, boost::asio::transfer_at_least(42),
  3597. bindns::bind(async_read_handler,
  3598. _1, _2, 42, &called));
  3599. ioc.restart();
  3600. ioc.run();
  3601. BOOST_ASIO_CHECK(called);
  3602. BOOST_ASIO_CHECK(s.check_buffers(buffers, 42));
  3603. s.reset(read_data, sizeof(read_data));
  3604. s.next_read_length(10);
  3605. memset(read_buf, 0, sizeof(read_buf));
  3606. called = false;
  3607. boost::asio::async_read(s, buffers, boost::asio::transfer_at_least(42),
  3608. bindns::bind(async_read_handler,
  3609. _1, _2, 50, &called));
  3610. ioc.restart();
  3611. ioc.run();
  3612. BOOST_ASIO_CHECK(called);
  3613. BOOST_ASIO_CHECK(s.check_buffers(buffers, 50));
  3614. s.reset(read_data, sizeof(read_data));
  3615. memset(read_buf, 0, sizeof(read_buf));
  3616. called = false;
  3617. boost::asio::async_read(s, buffers, boost::asio::transfer_exactly(1),
  3618. bindns::bind(async_read_handler,
  3619. _1, _2, 1, &called));
  3620. ioc.restart();
  3621. ioc.run();
  3622. BOOST_ASIO_CHECK(called);
  3623. BOOST_ASIO_CHECK(s.check_buffers(buffers, 1));
  3624. s.reset(read_data, sizeof(read_data));
  3625. s.next_read_length(1);
  3626. memset(read_buf, 0, sizeof(read_buf));
  3627. called = false;
  3628. boost::asio::async_read(s, buffers, boost::asio::transfer_exactly(1),
  3629. bindns::bind(async_read_handler,
  3630. _1, _2, 1, &called));
  3631. ioc.restart();
  3632. ioc.run();
  3633. BOOST_ASIO_CHECK(called);
  3634. BOOST_ASIO_CHECK(s.check_buffers(buffers, 1));
  3635. s.reset(read_data, sizeof(read_data));
  3636. s.next_read_length(10);
  3637. memset(read_buf, 0, sizeof(read_buf));
  3638. called = false;
  3639. boost::asio::async_read(s, buffers, boost::asio::transfer_exactly(1),
  3640. bindns::bind(async_read_handler,
  3641. _1, _2, 1, &called));
  3642. ioc.restart();
  3643. ioc.run();
  3644. BOOST_ASIO_CHECK(called);
  3645. BOOST_ASIO_CHECK(s.check_buffers(buffers, 1));
  3646. s.reset(read_data, sizeof(read_data));
  3647. memset(read_buf, 0, sizeof(read_buf));
  3648. called = false;
  3649. boost::asio::async_read(s, buffers, boost::asio::transfer_exactly(10),
  3650. bindns::bind(async_read_handler,
  3651. _1, _2, 10, &called));
  3652. ioc.restart();
  3653. ioc.run();
  3654. BOOST_ASIO_CHECK(called);
  3655. BOOST_ASIO_CHECK(s.check_buffers(buffers, 10));
  3656. s.reset(read_data, sizeof(read_data));
  3657. s.next_read_length(1);
  3658. memset(read_buf, 0, sizeof(read_buf));
  3659. called = false;
  3660. boost::asio::async_read(s, buffers, boost::asio::transfer_exactly(10),
  3661. bindns::bind(async_read_handler,
  3662. _1, _2, 10, &called));
  3663. ioc.restart();
  3664. ioc.run();
  3665. BOOST_ASIO_CHECK(called);
  3666. BOOST_ASIO_CHECK(s.check_buffers(buffers, 10));
  3667. s.reset(read_data, sizeof(read_data));
  3668. s.next_read_length(10);
  3669. memset(read_buf, 0, sizeof(read_buf));
  3670. called = false;
  3671. boost::asio::async_read(s, buffers, boost::asio::transfer_exactly(10),
  3672. bindns::bind(async_read_handler,
  3673. _1, _2, 10, &called));
  3674. ioc.restart();
  3675. ioc.run();
  3676. BOOST_ASIO_CHECK(called);
  3677. BOOST_ASIO_CHECK(s.check_buffers(buffers, 10));
  3678. s.reset(read_data, sizeof(read_data));
  3679. memset(read_buf, 0, sizeof(read_buf));
  3680. called = false;
  3681. boost::asio::async_read(s, buffers, boost::asio::transfer_exactly(42),
  3682. bindns::bind(async_read_handler,
  3683. _1, _2, 42, &called));
  3684. ioc.restart();
  3685. ioc.run();
  3686. BOOST_ASIO_CHECK(called);
  3687. BOOST_ASIO_CHECK(s.check_buffers(buffers, 42));
  3688. s.reset(read_data, sizeof(read_data));
  3689. s.next_read_length(1);
  3690. memset(read_buf, 0, sizeof(read_buf));
  3691. called = false;
  3692. boost::asio::async_read(s, buffers, boost::asio::transfer_exactly(42),
  3693. bindns::bind(async_read_handler,
  3694. _1, _2, 42, &called));
  3695. ioc.restart();
  3696. ioc.run();
  3697. BOOST_ASIO_CHECK(called);
  3698. BOOST_ASIO_CHECK(s.check_buffers(buffers, 42));
  3699. s.reset(read_data, sizeof(read_data));
  3700. s.next_read_length(10);
  3701. memset(read_buf, 0, sizeof(read_buf));
  3702. called = false;
  3703. boost::asio::async_read(s, buffers, boost::asio::transfer_exactly(42),
  3704. bindns::bind(async_read_handler,
  3705. _1, _2, 42, &called));
  3706. ioc.restart();
  3707. ioc.run();
  3708. BOOST_ASIO_CHECK(called);
  3709. BOOST_ASIO_CHECK(s.check_buffers(buffers, 42));
  3710. s.reset(read_data, sizeof(read_data));
  3711. memset(read_buf, 0, sizeof(read_buf));
  3712. called = false;
  3713. boost::asio::async_read(s, buffers, old_style_transfer_all,
  3714. bindns::bind(async_read_handler,
  3715. _1, _2, sizeof(read_data), &called));
  3716. ioc.restart();
  3717. ioc.run();
  3718. BOOST_ASIO_CHECK(called);
  3719. BOOST_ASIO_CHECK(s.check_buffers(buffers, sizeof(read_data)));
  3720. s.reset(read_data, sizeof(read_data));
  3721. s.next_read_length(1);
  3722. memset(read_buf, 0, sizeof(read_buf));
  3723. called = false;
  3724. boost::asio::async_read(s, buffers, old_style_transfer_all,
  3725. bindns::bind(async_read_handler,
  3726. _1, _2, sizeof(read_data), &called));
  3727. ioc.restart();
  3728. ioc.run();
  3729. BOOST_ASIO_CHECK(called);
  3730. BOOST_ASIO_CHECK(s.check_buffers(buffers, sizeof(read_data)));
  3731. s.reset(read_data, sizeof(read_data));
  3732. s.next_read_length(10);
  3733. memset(read_buf, 0, sizeof(read_buf));
  3734. called = false;
  3735. boost::asio::async_read(s, buffers, old_style_transfer_all,
  3736. bindns::bind(async_read_handler,
  3737. _1, _2, sizeof(read_data), &called));
  3738. ioc.restart();
  3739. ioc.run();
  3740. BOOST_ASIO_CHECK(called);
  3741. BOOST_ASIO_CHECK(s.check_buffers(buffers, sizeof(read_data)));
  3742. s.reset(read_data, sizeof(read_data));
  3743. memset(read_buf, 0, sizeof(read_buf));
  3744. called = false;
  3745. boost::asio::async_read(s, buffers, short_transfer(),
  3746. bindns::bind(async_read_handler,
  3747. _1, _2, sizeof(read_data), &called));
  3748. ioc.restart();
  3749. ioc.run();
  3750. BOOST_ASIO_CHECK(called);
  3751. BOOST_ASIO_CHECK(s.check_buffers(buffers, sizeof(read_data)));
  3752. s.reset(read_data, sizeof(read_data));
  3753. s.next_read_length(1);
  3754. memset(read_buf, 0, sizeof(read_buf));
  3755. called = false;
  3756. boost::asio::async_read(s, buffers, short_transfer(),
  3757. bindns::bind(async_read_handler,
  3758. _1, _2, sizeof(read_data), &called));
  3759. ioc.restart();
  3760. ioc.run();
  3761. BOOST_ASIO_CHECK(called);
  3762. BOOST_ASIO_CHECK(s.check_buffers(buffers, sizeof(read_data)));
  3763. s.reset(read_data, sizeof(read_data));
  3764. s.next_read_length(10);
  3765. memset(read_buf, 0, sizeof(read_buf));
  3766. called = false;
  3767. boost::asio::async_read(s, buffers, short_transfer(),
  3768. bindns::bind(async_read_handler,
  3769. _1, _2, sizeof(read_data), &called));
  3770. ioc.restart();
  3771. ioc.run();
  3772. BOOST_ASIO_CHECK(called);
  3773. BOOST_ASIO_CHECK(s.check_buffers(buffers, sizeof(read_data)));
  3774. s.reset(read_data, sizeof(read_data));
  3775. memset(read_buf, 0, sizeof(read_buf));
  3776. int i = boost::asio::async_read(s, buffers,
  3777. short_transfer(), archetypes::lazy_handler());
  3778. BOOST_ASIO_CHECK(i == 42);
  3779. ioc.restart();
  3780. ioc.run();
  3781. BOOST_ASIO_CHECK(s.check_buffers(buffers, sizeof(read_data)));
  3782. }
  3783. void test_4_arg_dynamic_string_async_read()
  3784. {
  3785. #if defined(BOOST_ASIO_HAS_BOOST_BIND)
  3786. namespace bindns = boost;
  3787. #else // defined(BOOST_ASIO_HAS_BOOST_BIND)
  3788. namespace bindns = std;
  3789. using std::placeholders::_1;
  3790. using std::placeholders::_2;
  3791. #endif // defined(BOOST_ASIO_HAS_BOOST_BIND)
  3792. boost::asio::io_context ioc;
  3793. test_stream s(ioc);
  3794. std::string data;
  3795. boost::asio::dynamic_string_buffer<char, std::string::traits_type,
  3796. std::string::allocator_type> sb
  3797. = boost::asio::dynamic_buffer(data, sizeof(read_data));
  3798. s.reset(read_data, sizeof(read_data));
  3799. sb.consume(sb.size());
  3800. bool called = false;
  3801. boost::asio::async_read(s, sb, boost::asio::transfer_all(),
  3802. bindns::bind(async_read_handler,
  3803. _1, _2, sizeof(read_data), &called));
  3804. ioc.restart();
  3805. ioc.run();
  3806. BOOST_ASIO_CHECK(called);
  3807. BOOST_ASIO_CHECK(sb.size() == sizeof(read_data));
  3808. BOOST_ASIO_CHECK(s.check_buffers(sb.data(0, sb.size()), sizeof(read_data)));
  3809. s.reset(read_data, sizeof(read_data));
  3810. s.next_read_length(1);
  3811. sb.consume(sb.size());
  3812. called = false;
  3813. boost::asio::async_read(s, sb, boost::asio::transfer_all(),
  3814. bindns::bind(async_read_handler,
  3815. _1, _2, sizeof(read_data), &called));
  3816. ioc.restart();
  3817. ioc.run();
  3818. BOOST_ASIO_CHECK(called);
  3819. BOOST_ASIO_CHECK(sb.size() == sizeof(read_data));
  3820. BOOST_ASIO_CHECK(s.check_buffers(sb.data(0, sb.size()), sizeof(read_data)));
  3821. s.reset(read_data, sizeof(read_data));
  3822. s.next_read_length(10);
  3823. sb.consume(sb.size());
  3824. called = false;
  3825. boost::asio::async_read(s, sb, boost::asio::transfer_all(),
  3826. bindns::bind(async_read_handler,
  3827. _1, _2, sizeof(read_data), &called));
  3828. ioc.restart();
  3829. ioc.run();
  3830. BOOST_ASIO_CHECK(called);
  3831. BOOST_ASIO_CHECK(sb.size() == sizeof(read_data));
  3832. BOOST_ASIO_CHECK(s.check_buffers(sb.data(0, sb.size()), sizeof(read_data)));
  3833. s.reset(read_data, sizeof(read_data));
  3834. sb.consume(sb.size());
  3835. called = false;
  3836. boost::asio::async_read(s, sb, boost::asio::transfer_at_least(1),
  3837. bindns::bind(async_read_handler,
  3838. _1, _2, sizeof(read_data), &called));
  3839. ioc.restart();
  3840. ioc.run();
  3841. BOOST_ASIO_CHECK(called);
  3842. BOOST_ASIO_CHECK(sb.size() == sizeof(read_data));
  3843. BOOST_ASIO_CHECK(s.check_buffers(sb.data(0, sb.size()), sizeof(read_data)));
  3844. s.reset(read_data, sizeof(read_data));
  3845. s.next_read_length(1);
  3846. sb.consume(sb.size());
  3847. called = false;
  3848. boost::asio::async_read(s, sb, boost::asio::transfer_at_least(1),
  3849. bindns::bind(async_read_handler,
  3850. _1, _2, 1, &called));
  3851. ioc.restart();
  3852. ioc.run();
  3853. BOOST_ASIO_CHECK(called);
  3854. BOOST_ASIO_CHECK(sb.size() == 1);
  3855. BOOST_ASIO_CHECK(s.check_buffers(sb.data(0, sb.size()), 1));
  3856. s.reset(read_data, sizeof(read_data));
  3857. s.next_read_length(10);
  3858. sb.consume(sb.size());
  3859. called = false;
  3860. boost::asio::async_read(s, sb, boost::asio::transfer_at_least(1),
  3861. bindns::bind(async_read_handler,
  3862. _1, _2, 10, &called));
  3863. ioc.restart();
  3864. ioc.run();
  3865. BOOST_ASIO_CHECK(called);
  3866. BOOST_ASIO_CHECK(sb.size() == 10);
  3867. BOOST_ASIO_CHECK(s.check_buffers(sb.data(0, sb.size()), 10));
  3868. s.reset(read_data, sizeof(read_data));
  3869. sb.consume(sb.size());
  3870. called = false;
  3871. boost::asio::async_read(s, sb, boost::asio::transfer_at_least(10),
  3872. bindns::bind(async_read_handler,
  3873. _1, _2, sizeof(read_data), &called));
  3874. ioc.restart();
  3875. ioc.run();
  3876. BOOST_ASIO_CHECK(called);
  3877. BOOST_ASIO_CHECK(sb.size() == sizeof(read_data));
  3878. BOOST_ASIO_CHECK(s.check_buffers(sb.data(0, sb.size()), sizeof(read_data)));
  3879. s.reset(read_data, sizeof(read_data));
  3880. s.next_read_length(1);
  3881. sb.consume(sb.size());
  3882. called = false;
  3883. boost::asio::async_read(s, sb, boost::asio::transfer_at_least(10),
  3884. bindns::bind(async_read_handler,
  3885. _1, _2, 10, &called));
  3886. ioc.restart();
  3887. ioc.run();
  3888. BOOST_ASIO_CHECK(called);
  3889. BOOST_ASIO_CHECK(sb.size() == 10);
  3890. BOOST_ASIO_CHECK(s.check_buffers(sb.data(0, sb.size()), 10));
  3891. s.reset(read_data, sizeof(read_data));
  3892. s.next_read_length(10);
  3893. sb.consume(sb.size());
  3894. called = false;
  3895. boost::asio::async_read(s, sb, boost::asio::transfer_at_least(10),
  3896. bindns::bind(async_read_handler,
  3897. _1, _2, 10, &called));
  3898. ioc.restart();
  3899. ioc.run();
  3900. BOOST_ASIO_CHECK(called);
  3901. BOOST_ASIO_CHECK(sb.size() == 10);
  3902. BOOST_ASIO_CHECK(s.check_buffers(sb.data(0, sb.size()), 10));
  3903. s.reset(read_data, sizeof(read_data));
  3904. sb.consume(sb.size());
  3905. called = false;
  3906. boost::asio::async_read(s, sb, boost::asio::transfer_at_least(42),
  3907. bindns::bind(async_read_handler,
  3908. _1, _2, sizeof(read_data), &called));
  3909. ioc.restart();
  3910. ioc.run();
  3911. BOOST_ASIO_CHECK(called);
  3912. BOOST_ASIO_CHECK(sb.size() == sizeof(read_data));
  3913. BOOST_ASIO_CHECK(s.check_buffers(sb.data(0, sb.size()), sizeof(read_data)));
  3914. s.reset(read_data, sizeof(read_data));
  3915. s.next_read_length(1);
  3916. sb.consume(sb.size());
  3917. called = false;
  3918. boost::asio::async_read(s, sb, boost::asio::transfer_at_least(42),
  3919. bindns::bind(async_read_handler,
  3920. _1, _2, 42, &called));
  3921. ioc.restart();
  3922. ioc.run();
  3923. BOOST_ASIO_CHECK(called);
  3924. BOOST_ASIO_CHECK(sb.size() == 42);
  3925. BOOST_ASIO_CHECK(s.check_buffers(sb.data(0, sb.size()), 42));
  3926. s.reset(read_data, sizeof(read_data));
  3927. s.next_read_length(10);
  3928. sb.consume(sb.size());
  3929. called = false;
  3930. boost::asio::async_read(s, sb, boost::asio::transfer_at_least(42),
  3931. bindns::bind(async_read_handler,
  3932. _1, _2, 50, &called));
  3933. ioc.restart();
  3934. ioc.run();
  3935. BOOST_ASIO_CHECK(called);
  3936. BOOST_ASIO_CHECK(sb.size() == 50);
  3937. BOOST_ASIO_CHECK(s.check_buffers(sb.data(0, sb.size()), 50));
  3938. s.reset(read_data, sizeof(read_data));
  3939. sb.consume(sb.size());
  3940. called = false;
  3941. boost::asio::async_read(s, sb, boost::asio::transfer_exactly(1),
  3942. bindns::bind(async_read_handler,
  3943. _1, _2, 1, &called));
  3944. ioc.restart();
  3945. ioc.run();
  3946. BOOST_ASIO_CHECK(called);
  3947. BOOST_ASIO_CHECK(sb.size() == 1);
  3948. BOOST_ASIO_CHECK(s.check_buffers(sb.data(0, sb.size()), 1));
  3949. s.reset(read_data, sizeof(read_data));
  3950. s.next_read_length(1);
  3951. sb.consume(sb.size());
  3952. called = false;
  3953. boost::asio::async_read(s, sb, boost::asio::transfer_exactly(1),
  3954. bindns::bind(async_read_handler,
  3955. _1, _2, 1, &called));
  3956. ioc.restart();
  3957. ioc.run();
  3958. BOOST_ASIO_CHECK(called);
  3959. BOOST_ASIO_CHECK(sb.size() == 1);
  3960. BOOST_ASIO_CHECK(s.check_buffers(sb.data(0, sb.size()), 1));
  3961. s.reset(read_data, sizeof(read_data));
  3962. s.next_read_length(10);
  3963. sb.consume(sb.size());
  3964. called = false;
  3965. boost::asio::async_read(s, sb, boost::asio::transfer_exactly(1),
  3966. bindns::bind(async_read_handler,
  3967. _1, _2, 1, &called));
  3968. ioc.restart();
  3969. ioc.run();
  3970. BOOST_ASIO_CHECK(called);
  3971. BOOST_ASIO_CHECK(sb.size() == 1);
  3972. BOOST_ASIO_CHECK(s.check_buffers(sb.data(0, sb.size()), 1));
  3973. s.reset(read_data, sizeof(read_data));
  3974. sb.consume(sb.size());
  3975. called = false;
  3976. boost::asio::async_read(s, sb, boost::asio::transfer_exactly(10),
  3977. bindns::bind(async_read_handler,
  3978. _1, _2, 10, &called));
  3979. ioc.restart();
  3980. ioc.run();
  3981. BOOST_ASIO_CHECK(called);
  3982. BOOST_ASIO_CHECK(sb.size() == 10);
  3983. BOOST_ASIO_CHECK(s.check_buffers(sb.data(0, sb.size()), 10));
  3984. s.reset(read_data, sizeof(read_data));
  3985. s.next_read_length(1);
  3986. sb.consume(sb.size());
  3987. called = false;
  3988. boost::asio::async_read(s, sb, boost::asio::transfer_exactly(10),
  3989. bindns::bind(async_read_handler,
  3990. _1, _2, 10, &called));
  3991. ioc.restart();
  3992. ioc.run();
  3993. BOOST_ASIO_CHECK(called);
  3994. BOOST_ASIO_CHECK(sb.size() == 10);
  3995. BOOST_ASIO_CHECK(s.check_buffers(sb.data(0, sb.size()), 10));
  3996. s.reset(read_data, sizeof(read_data));
  3997. s.next_read_length(10);
  3998. sb.consume(sb.size());
  3999. called = false;
  4000. boost::asio::async_read(s, sb, boost::asio::transfer_exactly(10),
  4001. bindns::bind(async_read_handler,
  4002. _1, _2, 10, &called));
  4003. ioc.restart();
  4004. ioc.run();
  4005. BOOST_ASIO_CHECK(called);
  4006. BOOST_ASIO_CHECK(sb.size() == 10);
  4007. BOOST_ASIO_CHECK(s.check_buffers(sb.data(0, sb.size()), 10));
  4008. s.reset(read_data, sizeof(read_data));
  4009. sb.consume(sb.size());
  4010. called = false;
  4011. boost::asio::async_read(s, sb, boost::asio::transfer_exactly(42),
  4012. bindns::bind(async_read_handler,
  4013. _1, _2, 42, &called));
  4014. ioc.restart();
  4015. ioc.run();
  4016. BOOST_ASIO_CHECK(called);
  4017. BOOST_ASIO_CHECK(sb.size() == 42);
  4018. BOOST_ASIO_CHECK(s.check_buffers(sb.data(0, sb.size()), 42));
  4019. s.reset(read_data, sizeof(read_data));
  4020. s.next_read_length(1);
  4021. sb.consume(sb.size());
  4022. called = false;
  4023. boost::asio::async_read(s, sb, boost::asio::transfer_exactly(42),
  4024. bindns::bind(async_read_handler,
  4025. _1, _2, 42, &called));
  4026. ioc.restart();
  4027. ioc.run();
  4028. BOOST_ASIO_CHECK(called);
  4029. BOOST_ASIO_CHECK(sb.size() == 42);
  4030. BOOST_ASIO_CHECK(s.check_buffers(sb.data(0, sb.size()), 42));
  4031. s.reset(read_data, sizeof(read_data));
  4032. s.next_read_length(10);
  4033. sb.consume(sb.size());
  4034. called = false;
  4035. boost::asio::async_read(s, sb, boost::asio::transfer_exactly(42),
  4036. bindns::bind(async_read_handler,
  4037. _1, _2, 42, &called));
  4038. ioc.restart();
  4039. ioc.run();
  4040. BOOST_ASIO_CHECK(called);
  4041. BOOST_ASIO_CHECK(sb.size() == 42);
  4042. BOOST_ASIO_CHECK(s.check_buffers(sb.data(0, sb.size()), 42));
  4043. s.reset(read_data, sizeof(read_data));
  4044. sb.consume(sb.size());
  4045. called = false;
  4046. boost::asio::async_read(s, sb, old_style_transfer_all,
  4047. bindns::bind(async_read_handler,
  4048. _1, _2, sizeof(read_data), &called));
  4049. ioc.restart();
  4050. ioc.run();
  4051. BOOST_ASIO_CHECK(called);
  4052. BOOST_ASIO_CHECK(sb.size() == sizeof(read_data));
  4053. BOOST_ASIO_CHECK(s.check_buffers(sb.data(0, sb.size()), sizeof(read_data)));
  4054. s.reset(read_data, sizeof(read_data));
  4055. s.next_read_length(1);
  4056. sb.consume(sb.size());
  4057. called = false;
  4058. boost::asio::async_read(s, sb, old_style_transfer_all,
  4059. bindns::bind(async_read_handler,
  4060. _1, _2, sizeof(read_data), &called));
  4061. ioc.restart();
  4062. ioc.run();
  4063. BOOST_ASIO_CHECK(called);
  4064. BOOST_ASIO_CHECK(sb.size() == sizeof(read_data));
  4065. BOOST_ASIO_CHECK(s.check_buffers(sb.data(0, sb.size()), sizeof(read_data)));
  4066. s.reset(read_data, sizeof(read_data));
  4067. s.next_read_length(10);
  4068. sb.consume(sb.size());
  4069. called = false;
  4070. boost::asio::async_read(s, sb, old_style_transfer_all,
  4071. bindns::bind(async_read_handler,
  4072. _1, _2, sizeof(read_data), &called));
  4073. ioc.restart();
  4074. ioc.run();
  4075. BOOST_ASIO_CHECK(called);
  4076. BOOST_ASIO_CHECK(sb.size() == sizeof(read_data));
  4077. BOOST_ASIO_CHECK(s.check_buffers(sb.data(0, sb.size()), sizeof(read_data)));
  4078. s.reset(read_data, sizeof(read_data));
  4079. sb.consume(sb.size());
  4080. called = false;
  4081. boost::asio::async_read(s, sb, short_transfer(),
  4082. bindns::bind(async_read_handler,
  4083. _1, _2, sizeof(read_data), &called));
  4084. ioc.restart();
  4085. ioc.run();
  4086. BOOST_ASIO_CHECK(called);
  4087. BOOST_ASIO_CHECK(sb.size() == sizeof(read_data));
  4088. BOOST_ASIO_CHECK(s.check_buffers(sb.data(0, sb.size()), sizeof(read_data)));
  4089. s.reset(read_data, sizeof(read_data));
  4090. s.next_read_length(1);
  4091. sb.consume(sb.size());
  4092. called = false;
  4093. boost::asio::async_read(s, sb, short_transfer(),
  4094. bindns::bind(async_read_handler,
  4095. _1, _2, sizeof(read_data), &called));
  4096. ioc.restart();
  4097. ioc.run();
  4098. BOOST_ASIO_CHECK(called);
  4099. BOOST_ASIO_CHECK(sb.size() == sizeof(read_data));
  4100. BOOST_ASIO_CHECK(s.check_buffers(sb.data(0, sb.size()), sizeof(read_data)));
  4101. s.reset(read_data, sizeof(read_data));
  4102. s.next_read_length(10);
  4103. sb.consume(sb.size());
  4104. called = false;
  4105. boost::asio::async_read(s, sb, short_transfer(),
  4106. bindns::bind(async_read_handler,
  4107. _1, _2, sizeof(read_data), &called));
  4108. ioc.restart();
  4109. ioc.run();
  4110. BOOST_ASIO_CHECK(called);
  4111. BOOST_ASIO_CHECK(sb.size() == sizeof(read_data));
  4112. BOOST_ASIO_CHECK(s.check_buffers(sb.data(0, sb.size()), sizeof(read_data)));
  4113. s.reset(read_data, sizeof(read_data));
  4114. sb.consume(sb.size());
  4115. int i = boost::asio::async_read(s, sb,
  4116. short_transfer(), archetypes::lazy_handler());
  4117. BOOST_ASIO_CHECK(i == 42);
  4118. ioc.restart();
  4119. ioc.run();
  4120. BOOST_ASIO_CHECK(sb.size() == sizeof(read_data));
  4121. BOOST_ASIO_CHECK(s.check_buffers(sb.data(0, sb.size()), sizeof(read_data)));
  4122. }
  4123. void test_4_arg_streambuf_async_read()
  4124. {
  4125. #if !defined(BOOST_ASIO_NO_DYNAMIC_BUFFER_V1)
  4126. #if defined(BOOST_ASIO_HAS_BOOST_BIND)
  4127. namespace bindns = boost;
  4128. #else // defined(BOOST_ASIO_HAS_BOOST_BIND)
  4129. namespace bindns = std;
  4130. using std::placeholders::_1;
  4131. using std::placeholders::_2;
  4132. #endif // defined(BOOST_ASIO_HAS_BOOST_BIND)
  4133. boost::asio::io_context ioc;
  4134. test_stream s(ioc);
  4135. boost::asio::streambuf sb(sizeof(read_data));
  4136. s.reset(read_data, sizeof(read_data));
  4137. sb.consume(sb.size());
  4138. bool called = false;
  4139. boost::asio::async_read(s, sb, boost::asio::transfer_all(),
  4140. bindns::bind(async_read_handler,
  4141. _1, _2, sizeof(read_data), &called));
  4142. ioc.restart();
  4143. ioc.run();
  4144. BOOST_ASIO_CHECK(called);
  4145. BOOST_ASIO_CHECK(sb.size() == sizeof(read_data));
  4146. BOOST_ASIO_CHECK(s.check_buffers(sb.data(), sizeof(read_data)));
  4147. s.reset(read_data, sizeof(read_data));
  4148. s.next_read_length(1);
  4149. sb.consume(sb.size());
  4150. called = false;
  4151. boost::asio::async_read(s, sb, boost::asio::transfer_all(),
  4152. bindns::bind(async_read_handler,
  4153. _1, _2, sizeof(read_data), &called));
  4154. ioc.restart();
  4155. ioc.run();
  4156. BOOST_ASIO_CHECK(called);
  4157. BOOST_ASIO_CHECK(sb.size() == sizeof(read_data));
  4158. BOOST_ASIO_CHECK(s.check_buffers(sb.data(), sizeof(read_data)));
  4159. s.reset(read_data, sizeof(read_data));
  4160. s.next_read_length(10);
  4161. sb.consume(sb.size());
  4162. called = false;
  4163. boost::asio::async_read(s, sb, boost::asio::transfer_all(),
  4164. bindns::bind(async_read_handler,
  4165. _1, _2, sizeof(read_data), &called));
  4166. ioc.restart();
  4167. ioc.run();
  4168. BOOST_ASIO_CHECK(called);
  4169. BOOST_ASIO_CHECK(sb.size() == sizeof(read_data));
  4170. BOOST_ASIO_CHECK(s.check_buffers(sb.data(), sizeof(read_data)));
  4171. s.reset(read_data, sizeof(read_data));
  4172. sb.consume(sb.size());
  4173. called = false;
  4174. boost::asio::async_read(s, sb, boost::asio::transfer_at_least(1),
  4175. bindns::bind(async_read_handler,
  4176. _1, _2, sizeof(read_data), &called));
  4177. ioc.restart();
  4178. ioc.run();
  4179. BOOST_ASIO_CHECK(called);
  4180. BOOST_ASIO_CHECK(sb.size() == sizeof(read_data));
  4181. BOOST_ASIO_CHECK(s.check_buffers(sb.data(), sizeof(read_data)));
  4182. s.reset(read_data, sizeof(read_data));
  4183. s.next_read_length(1);
  4184. sb.consume(sb.size());
  4185. called = false;
  4186. boost::asio::async_read(s, sb, boost::asio::transfer_at_least(1),
  4187. bindns::bind(async_read_handler,
  4188. _1, _2, 1, &called));
  4189. ioc.restart();
  4190. ioc.run();
  4191. BOOST_ASIO_CHECK(called);
  4192. BOOST_ASIO_CHECK(sb.size() == 1);
  4193. BOOST_ASIO_CHECK(s.check_buffers(sb.data(), 1));
  4194. s.reset(read_data, sizeof(read_data));
  4195. s.next_read_length(10);
  4196. sb.consume(sb.size());
  4197. called = false;
  4198. boost::asio::async_read(s, sb, boost::asio::transfer_at_least(1),
  4199. bindns::bind(async_read_handler,
  4200. _1, _2, 10, &called));
  4201. ioc.restart();
  4202. ioc.run();
  4203. BOOST_ASIO_CHECK(called);
  4204. BOOST_ASIO_CHECK(sb.size() == 10);
  4205. BOOST_ASIO_CHECK(s.check_buffers(sb.data(), 10));
  4206. s.reset(read_data, sizeof(read_data));
  4207. sb.consume(sb.size());
  4208. called = false;
  4209. boost::asio::async_read(s, sb, boost::asio::transfer_at_least(10),
  4210. bindns::bind(async_read_handler,
  4211. _1, _2, sizeof(read_data), &called));
  4212. ioc.restart();
  4213. ioc.run();
  4214. BOOST_ASIO_CHECK(called);
  4215. BOOST_ASIO_CHECK(sb.size() == sizeof(read_data));
  4216. BOOST_ASIO_CHECK(s.check_buffers(sb.data(), sizeof(read_data)));
  4217. s.reset(read_data, sizeof(read_data));
  4218. s.next_read_length(1);
  4219. sb.consume(sb.size());
  4220. called = false;
  4221. boost::asio::async_read(s, sb, boost::asio::transfer_at_least(10),
  4222. bindns::bind(async_read_handler,
  4223. _1, _2, 10, &called));
  4224. ioc.restart();
  4225. ioc.run();
  4226. BOOST_ASIO_CHECK(called);
  4227. BOOST_ASIO_CHECK(sb.size() == 10);
  4228. BOOST_ASIO_CHECK(s.check_buffers(sb.data(), 10));
  4229. s.reset(read_data, sizeof(read_data));
  4230. s.next_read_length(10);
  4231. sb.consume(sb.size());
  4232. called = false;
  4233. boost::asio::async_read(s, sb, boost::asio::transfer_at_least(10),
  4234. bindns::bind(async_read_handler,
  4235. _1, _2, 10, &called));
  4236. ioc.restart();
  4237. ioc.run();
  4238. BOOST_ASIO_CHECK(called);
  4239. BOOST_ASIO_CHECK(sb.size() == 10);
  4240. BOOST_ASIO_CHECK(s.check_buffers(sb.data(), 10));
  4241. s.reset(read_data, sizeof(read_data));
  4242. sb.consume(sb.size());
  4243. called = false;
  4244. boost::asio::async_read(s, sb, boost::asio::transfer_at_least(42),
  4245. bindns::bind(async_read_handler,
  4246. _1, _2, sizeof(read_data), &called));
  4247. ioc.restart();
  4248. ioc.run();
  4249. BOOST_ASIO_CHECK(called);
  4250. BOOST_ASIO_CHECK(sb.size() == sizeof(read_data));
  4251. BOOST_ASIO_CHECK(s.check_buffers(sb.data(), sizeof(read_data)));
  4252. s.reset(read_data, sizeof(read_data));
  4253. s.next_read_length(1);
  4254. sb.consume(sb.size());
  4255. called = false;
  4256. boost::asio::async_read(s, sb, boost::asio::transfer_at_least(42),
  4257. bindns::bind(async_read_handler,
  4258. _1, _2, 42, &called));
  4259. ioc.restart();
  4260. ioc.run();
  4261. BOOST_ASIO_CHECK(called);
  4262. BOOST_ASIO_CHECK(sb.size() == 42);
  4263. BOOST_ASIO_CHECK(s.check_buffers(sb.data(), 42));
  4264. s.reset(read_data, sizeof(read_data));
  4265. s.next_read_length(10);
  4266. sb.consume(sb.size());
  4267. called = false;
  4268. boost::asio::async_read(s, sb, boost::asio::transfer_at_least(42),
  4269. bindns::bind(async_read_handler,
  4270. _1, _2, 50, &called));
  4271. ioc.restart();
  4272. ioc.run();
  4273. BOOST_ASIO_CHECK(called);
  4274. BOOST_ASIO_CHECK(sb.size() == 50);
  4275. BOOST_ASIO_CHECK(s.check_buffers(sb.data(), 50));
  4276. s.reset(read_data, sizeof(read_data));
  4277. sb.consume(sb.size());
  4278. called = false;
  4279. boost::asio::async_read(s, sb, boost::asio::transfer_exactly(1),
  4280. bindns::bind(async_read_handler,
  4281. _1, _2, 1, &called));
  4282. ioc.restart();
  4283. ioc.run();
  4284. BOOST_ASIO_CHECK(called);
  4285. BOOST_ASIO_CHECK(sb.size() == 1);
  4286. BOOST_ASIO_CHECK(s.check_buffers(sb.data(), 1));
  4287. s.reset(read_data, sizeof(read_data));
  4288. s.next_read_length(1);
  4289. sb.consume(sb.size());
  4290. called = false;
  4291. boost::asio::async_read(s, sb, boost::asio::transfer_exactly(1),
  4292. bindns::bind(async_read_handler,
  4293. _1, _2, 1, &called));
  4294. ioc.restart();
  4295. ioc.run();
  4296. BOOST_ASIO_CHECK(called);
  4297. BOOST_ASIO_CHECK(sb.size() == 1);
  4298. BOOST_ASIO_CHECK(s.check_buffers(sb.data(), 1));
  4299. s.reset(read_data, sizeof(read_data));
  4300. s.next_read_length(10);
  4301. sb.consume(sb.size());
  4302. called = false;
  4303. boost::asio::async_read(s, sb, boost::asio::transfer_exactly(1),
  4304. bindns::bind(async_read_handler,
  4305. _1, _2, 1, &called));
  4306. ioc.restart();
  4307. ioc.run();
  4308. BOOST_ASIO_CHECK(called);
  4309. BOOST_ASIO_CHECK(sb.size() == 1);
  4310. BOOST_ASIO_CHECK(s.check_buffers(sb.data(), 1));
  4311. s.reset(read_data, sizeof(read_data));
  4312. sb.consume(sb.size());
  4313. called = false;
  4314. boost::asio::async_read(s, sb, boost::asio::transfer_exactly(10),
  4315. bindns::bind(async_read_handler,
  4316. _1, _2, 10, &called));
  4317. ioc.restart();
  4318. ioc.run();
  4319. BOOST_ASIO_CHECK(called);
  4320. BOOST_ASIO_CHECK(sb.size() == 10);
  4321. BOOST_ASIO_CHECK(s.check_buffers(sb.data(), 10));
  4322. s.reset(read_data, sizeof(read_data));
  4323. s.next_read_length(1);
  4324. sb.consume(sb.size());
  4325. called = false;
  4326. boost::asio::async_read(s, sb, boost::asio::transfer_exactly(10),
  4327. bindns::bind(async_read_handler,
  4328. _1, _2, 10, &called));
  4329. ioc.restart();
  4330. ioc.run();
  4331. BOOST_ASIO_CHECK(called);
  4332. BOOST_ASIO_CHECK(sb.size() == 10);
  4333. BOOST_ASIO_CHECK(s.check_buffers(sb.data(), 10));
  4334. s.reset(read_data, sizeof(read_data));
  4335. s.next_read_length(10);
  4336. sb.consume(sb.size());
  4337. called = false;
  4338. boost::asio::async_read(s, sb, boost::asio::transfer_exactly(10),
  4339. bindns::bind(async_read_handler,
  4340. _1, _2, 10, &called));
  4341. ioc.restart();
  4342. ioc.run();
  4343. BOOST_ASIO_CHECK(called);
  4344. BOOST_ASIO_CHECK(sb.size() == 10);
  4345. BOOST_ASIO_CHECK(s.check_buffers(sb.data(), 10));
  4346. s.reset(read_data, sizeof(read_data));
  4347. sb.consume(sb.size());
  4348. called = false;
  4349. boost::asio::async_read(s, sb, boost::asio::transfer_exactly(42),
  4350. bindns::bind(async_read_handler,
  4351. _1, _2, 42, &called));
  4352. ioc.restart();
  4353. ioc.run();
  4354. BOOST_ASIO_CHECK(called);
  4355. BOOST_ASIO_CHECK(sb.size() == 42);
  4356. BOOST_ASIO_CHECK(s.check_buffers(sb.data(), 42));
  4357. s.reset(read_data, sizeof(read_data));
  4358. s.next_read_length(1);
  4359. sb.consume(sb.size());
  4360. called = false;
  4361. boost::asio::async_read(s, sb, boost::asio::transfer_exactly(42),
  4362. bindns::bind(async_read_handler,
  4363. _1, _2, 42, &called));
  4364. ioc.restart();
  4365. ioc.run();
  4366. BOOST_ASIO_CHECK(called);
  4367. BOOST_ASIO_CHECK(sb.size() == 42);
  4368. BOOST_ASIO_CHECK(s.check_buffers(sb.data(), 42));
  4369. s.reset(read_data, sizeof(read_data));
  4370. s.next_read_length(10);
  4371. sb.consume(sb.size());
  4372. called = false;
  4373. boost::asio::async_read(s, sb, boost::asio::transfer_exactly(42),
  4374. bindns::bind(async_read_handler,
  4375. _1, _2, 42, &called));
  4376. ioc.restart();
  4377. ioc.run();
  4378. BOOST_ASIO_CHECK(called);
  4379. BOOST_ASIO_CHECK(sb.size() == 42);
  4380. BOOST_ASIO_CHECK(s.check_buffers(sb.data(), 42));
  4381. s.reset(read_data, sizeof(read_data));
  4382. sb.consume(sb.size());
  4383. called = false;
  4384. boost::asio::async_read(s, sb, old_style_transfer_all,
  4385. bindns::bind(async_read_handler,
  4386. _1, _2, sizeof(read_data), &called));
  4387. ioc.restart();
  4388. ioc.run();
  4389. BOOST_ASIO_CHECK(called);
  4390. BOOST_ASIO_CHECK(sb.size() == sizeof(read_data));
  4391. BOOST_ASIO_CHECK(s.check_buffers(sb.data(), sizeof(read_data)));
  4392. s.reset(read_data, sizeof(read_data));
  4393. s.next_read_length(1);
  4394. sb.consume(sb.size());
  4395. called = false;
  4396. boost::asio::async_read(s, sb, old_style_transfer_all,
  4397. bindns::bind(async_read_handler,
  4398. _1, _2, sizeof(read_data), &called));
  4399. ioc.restart();
  4400. ioc.run();
  4401. BOOST_ASIO_CHECK(called);
  4402. BOOST_ASIO_CHECK(sb.size() == sizeof(read_data));
  4403. BOOST_ASIO_CHECK(s.check_buffers(sb.data(), sizeof(read_data)));
  4404. s.reset(read_data, sizeof(read_data));
  4405. s.next_read_length(10);
  4406. sb.consume(sb.size());
  4407. called = false;
  4408. boost::asio::async_read(s, sb, old_style_transfer_all,
  4409. bindns::bind(async_read_handler,
  4410. _1, _2, sizeof(read_data), &called));
  4411. ioc.restart();
  4412. ioc.run();
  4413. BOOST_ASIO_CHECK(called);
  4414. BOOST_ASIO_CHECK(sb.size() == sizeof(read_data));
  4415. BOOST_ASIO_CHECK(s.check_buffers(sb.data(), sizeof(read_data)));
  4416. s.reset(read_data, sizeof(read_data));
  4417. sb.consume(sb.size());
  4418. called = false;
  4419. boost::asio::async_read(s, sb, short_transfer(),
  4420. bindns::bind(async_read_handler,
  4421. _1, _2, sizeof(read_data), &called));
  4422. ioc.restart();
  4423. ioc.run();
  4424. BOOST_ASIO_CHECK(called);
  4425. BOOST_ASIO_CHECK(sb.size() == sizeof(read_data));
  4426. BOOST_ASIO_CHECK(s.check_buffers(sb.data(), sizeof(read_data)));
  4427. s.reset(read_data, sizeof(read_data));
  4428. s.next_read_length(1);
  4429. sb.consume(sb.size());
  4430. called = false;
  4431. boost::asio::async_read(s, sb, short_transfer(),
  4432. bindns::bind(async_read_handler,
  4433. _1, _2, sizeof(read_data), &called));
  4434. ioc.restart();
  4435. ioc.run();
  4436. BOOST_ASIO_CHECK(called);
  4437. BOOST_ASIO_CHECK(sb.size() == sizeof(read_data));
  4438. BOOST_ASIO_CHECK(s.check_buffers(sb.data(), sizeof(read_data)));
  4439. s.reset(read_data, sizeof(read_data));
  4440. s.next_read_length(10);
  4441. sb.consume(sb.size());
  4442. called = false;
  4443. boost::asio::async_read(s, sb, short_transfer(),
  4444. bindns::bind(async_read_handler,
  4445. _1, _2, sizeof(read_data), &called));
  4446. ioc.restart();
  4447. ioc.run();
  4448. BOOST_ASIO_CHECK(called);
  4449. BOOST_ASIO_CHECK(sb.size() == sizeof(read_data));
  4450. BOOST_ASIO_CHECK(s.check_buffers(sb.data(), sizeof(read_data)));
  4451. s.reset(read_data, sizeof(read_data));
  4452. sb.consume(sb.size());
  4453. int i = boost::asio::async_read(s, sb,
  4454. short_transfer(), archetypes::lazy_handler());
  4455. BOOST_ASIO_CHECK(i == 42);
  4456. ioc.restart();
  4457. ioc.run();
  4458. BOOST_ASIO_CHECK(sb.size() == sizeof(read_data));
  4459. BOOST_ASIO_CHECK(s.check_buffers(sb.data(), sizeof(read_data)));
  4460. #endif // !defined(BOOST_ASIO_NO_DYNAMIC_BUFFER_V1)
  4461. }
  4462. BOOST_ASIO_TEST_SUITE
  4463. (
  4464. "read",
  4465. BOOST_ASIO_TEST_CASE(test_2_arg_zero_buffers_read)
  4466. BOOST_ASIO_TEST_CASE(test_2_arg_mutable_buffer_read)
  4467. BOOST_ASIO_TEST_CASE(test_2_arg_vector_buffers_read)
  4468. BOOST_ASIO_TEST_CASE(test_2_arg_dynamic_string_read)
  4469. BOOST_ASIO_TEST_CASE(test_2_arg_streambuf_read)
  4470. BOOST_ASIO_TEST_CASE(test_3_arg_nothrow_zero_buffers_read)
  4471. BOOST_ASIO_TEST_CASE(test_3_arg_nothrow_mutable_buffer_read)
  4472. BOOST_ASIO_TEST_CASE(test_3_arg_nothrow_vector_buffers_read)
  4473. BOOST_ASIO_TEST_CASE(test_3_arg_nothrow_dynamic_string_read)
  4474. BOOST_ASIO_TEST_CASE(test_3_arg_nothrow_streambuf_read)
  4475. BOOST_ASIO_TEST_CASE(test_3_arg_mutable_buffer_read)
  4476. BOOST_ASIO_TEST_CASE(test_3_arg_vector_buffers_read)
  4477. BOOST_ASIO_TEST_CASE(test_3_arg_dynamic_string_read)
  4478. BOOST_ASIO_TEST_CASE(test_3_arg_streambuf_read)
  4479. BOOST_ASIO_TEST_CASE(test_4_arg_mutable_buffer_read)
  4480. BOOST_ASIO_TEST_CASE(test_4_arg_vector_buffers_read)
  4481. BOOST_ASIO_TEST_CASE(test_4_arg_dynamic_string_read)
  4482. BOOST_ASIO_TEST_CASE(test_4_arg_streambuf_read)
  4483. BOOST_ASIO_TEST_CASE(test_3_arg_mutable_buffer_async_read)
  4484. BOOST_ASIO_TEST_CASE(test_3_arg_boost_array_buffers_async_read)
  4485. BOOST_ASIO_TEST_CASE(test_3_arg_std_array_buffers_async_read)
  4486. BOOST_ASIO_TEST_CASE(test_3_arg_vector_buffers_async_read)
  4487. BOOST_ASIO_TEST_CASE(test_3_arg_dynamic_string_async_read)
  4488. BOOST_ASIO_TEST_CASE(test_3_arg_streambuf_async_read)
  4489. BOOST_ASIO_TEST_CASE(test_4_arg_mutable_buffer_async_read)
  4490. BOOST_ASIO_TEST_CASE(test_4_arg_vector_buffers_async_read)
  4491. BOOST_ASIO_TEST_CASE(test_4_arg_boost_array_buffers_async_read)
  4492. BOOST_ASIO_TEST_CASE(test_4_arg_std_array_buffers_async_read)
  4493. BOOST_ASIO_TEST_CASE(test_4_arg_dynamic_string_async_read)
  4494. BOOST_ASIO_TEST_CASE(test_4_arg_streambuf_async_read)
  4495. )