SocketTest.cs 123 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119112011211122112311241125112611271128112911301131113211331134113511361137113811391140114111421143114411451146114711481149115011511152115311541155115611571158115911601161116211631164116511661167116811691170117111721173117411751176117711781179118011811182118311841185118611871188118911901191119211931194119511961197119811991200120112021203120412051206120712081209121012111212121312141215121612171218121912201221122212231224122512261227122812291230123112321233123412351236123712381239124012411242124312441245124612471248124912501251125212531254125512561257125812591260126112621263126412651266126712681269127012711272127312741275127612771278127912801281128212831284128512861287128812891290129112921293129412951296129712981299130013011302130313041305130613071308130913101311131213131314131513161317131813191320132113221323132413251326132713281329133013311332133313341335133613371338133913401341134213431344134513461347134813491350135113521353135413551356135713581359136013611362136313641365136613671368136913701371137213731374137513761377137813791380138113821383138413851386138713881389139013911392139313941395139613971398139914001401140214031404140514061407140814091410141114121413141414151416141714181419142014211422142314241425142614271428142914301431143214331434143514361437143814391440144114421443144414451446144714481449145014511452145314541455145614571458145914601461146214631464146514661467146814691470147114721473147414751476147714781479148014811482148314841485148614871488148914901491149214931494149514961497149814991500150115021503150415051506150715081509151015111512151315141515151615171518151915201521152215231524152515261527152815291530153115321533153415351536153715381539154015411542154315441545154615471548154915501551155215531554155515561557155815591560156115621563156415651566156715681569157015711572157315741575157615771578157915801581158215831584158515861587158815891590159115921593159415951596159715981599160016011602160316041605160616071608160916101611161216131614161516161617161816191620162116221623162416251626162716281629163016311632163316341635163616371638163916401641164216431644164516461647164816491650165116521653165416551656165716581659166016611662166316641665166616671668166916701671167216731674167516761677167816791680168116821683168416851686168716881689169016911692169316941695169616971698169917001701170217031704170517061707170817091710171117121713171417151716171717181719172017211722172317241725172617271728172917301731173217331734173517361737173817391740174117421743174417451746174717481749175017511752175317541755175617571758175917601761176217631764176517661767176817691770177117721773177417751776177717781779178017811782178317841785178617871788178917901791179217931794179517961797179817991800180118021803180418051806180718081809181018111812181318141815181618171818181918201821182218231824182518261827182818291830183118321833183418351836183718381839184018411842184318441845184618471848184918501851185218531854185518561857185818591860186118621863186418651866186718681869187018711872187318741875187618771878187918801881188218831884188518861887188818891890189118921893189418951896189718981899190019011902190319041905190619071908190919101911191219131914191519161917191819191920192119221923192419251926192719281929193019311932193319341935193619371938193919401941194219431944194519461947194819491950195119521953195419551956195719581959196019611962196319641965196619671968196919701971197219731974197519761977197819791980198119821983198419851986198719881989199019911992199319941995199619971998199920002001200220032004200520062007200820092010201120122013201420152016201720182019202020212022202320242025202620272028202920302031203220332034203520362037203820392040204120422043204420452046204720482049205020512052205320542055205620572058205920602061206220632064206520662067206820692070207120722073207420752076207720782079208020812082208320842085208620872088208920902091209220932094209520962097209820992100210121022103210421052106210721082109211021112112211321142115211621172118211921202121212221232124212521262127212821292130213121322133213421352136213721382139214021412142214321442145214621472148214921502151215221532154215521562157215821592160216121622163216421652166216721682169217021712172217321742175217621772178217921802181218221832184218521862187218821892190219121922193219421952196219721982199220022012202220322042205220622072208220922102211221222132214221522162217221822192220222122222223222422252226222722282229223022312232223322342235223622372238223922402241224222432244224522462247224822492250225122522253225422552256225722582259226022612262226322642265226622672268226922702271227222732274227522762277227822792280228122822283228422852286228722882289229022912292229322942295229622972298229923002301230223032304230523062307230823092310231123122313231423152316231723182319232023212322232323242325232623272328232923302331233223332334233523362337233823392340234123422343234423452346234723482349235023512352235323542355235623572358235923602361236223632364236523662367236823692370237123722373237423752376237723782379238023812382238323842385238623872388238923902391239223932394239523962397239823992400240124022403240424052406240724082409241024112412241324142415241624172418241924202421242224232424242524262427242824292430243124322433243424352436243724382439244024412442244324442445244624472448244924502451245224532454245524562457245824592460246124622463246424652466246724682469247024712472247324742475247624772478247924802481248224832484248524862487248824892490249124922493249424952496249724982499250025012502250325042505250625072508250925102511251225132514251525162517251825192520252125222523252425252526252725282529253025312532253325342535253625372538253925402541254225432544254525462547254825492550255125522553255425552556255725582559256025612562256325642565256625672568256925702571257225732574257525762577257825792580258125822583258425852586258725882589259025912592259325942595259625972598259926002601260226032604260526062607260826092610261126122613261426152616261726182619262026212622262326242625262626272628262926302631263226332634263526362637263826392640264126422643264426452646264726482649265026512652265326542655265626572658265926602661266226632664266526662667266826692670267126722673267426752676267726782679268026812682268326842685268626872688268926902691269226932694269526962697269826992700270127022703270427052706270727082709271027112712271327142715271627172718271927202721272227232724272527262727272827292730273127322733273427352736273727382739274027412742274327442745274627472748274927502751275227532754275527562757275827592760276127622763276427652766276727682769277027712772277327742775277627772778277927802781278227832784278527862787278827892790279127922793279427952796279727982799280028012802280328042805280628072808280928102811281228132814281528162817281828192820282128222823282428252826282728282829283028312832283328342835283628372838283928402841284228432844284528462847284828492850285128522853285428552856285728582859286028612862286328642865286628672868286928702871287228732874287528762877287828792880288128822883288428852886288728882889289028912892289328942895289628972898289929002901290229032904290529062907290829092910291129122913291429152916291729182919292029212922292329242925292629272928292929302931293229332934293529362937293829392940294129422943294429452946294729482949295029512952295329542955295629572958295929602961296229632964296529662967296829692970297129722973297429752976297729782979298029812982298329842985298629872988298929902991299229932994299529962997299829993000300130023003300430053006300730083009301030113012301330143015301630173018301930203021302230233024302530263027302830293030303130323033303430353036303730383039304030413042304330443045304630473048304930503051305230533054305530563057305830593060306130623063306430653066306730683069307030713072307330743075307630773078307930803081308230833084308530863087308830893090309130923093309430953096309730983099310031013102310331043105310631073108310931103111311231133114311531163117311831193120312131223123312431253126312731283129313031313132313331343135313631373138313931403141314231433144314531463147314831493150315131523153315431553156315731583159316031613162316331643165316631673168316931703171317231733174317531763177317831793180318131823183318431853186318731883189319031913192319331943195319631973198319932003201320232033204320532063207320832093210321132123213321432153216321732183219322032213222322332243225322632273228322932303231323232333234323532363237323832393240324132423243324432453246324732483249325032513252325332543255325632573258325932603261326232633264326532663267326832693270327132723273327432753276327732783279328032813282328332843285328632873288328932903291329232933294329532963297329832993300330133023303330433053306330733083309331033113312331333143315331633173318331933203321332233233324332533263327332833293330333133323333333433353336333733383339334033413342334333443345334633473348334933503351335233533354335533563357335833593360336133623363336433653366336733683369337033713372337333743375337633773378337933803381338233833384338533863387338833893390339133923393339433953396339733983399340034013402340334043405340634073408340934103411341234133414341534163417341834193420342134223423342434253426342734283429343034313432343334343435343634373438343934403441344234433444344534463447344834493450345134523453345434553456345734583459346034613462346334643465346634673468346934703471347234733474347534763477347834793480348134823483348434853486348734883489349034913492349334943495349634973498349935003501350235033504350535063507350835093510351135123513351435153516351735183519352035213522352335243525352635273528352935303531353235333534353535363537353835393540354135423543354435453546354735483549355035513552355335543555355635573558355935603561356235633564356535663567356835693570357135723573357435753576357735783579358035813582358335843585358635873588358935903591359235933594359535963597359835993600360136023603360436053606360736083609361036113612361336143615361636173618361936203621362236233624362536263627362836293630363136323633363436353636363736383639364036413642364336443645364636473648364936503651365236533654365536563657365836593660366136623663366436653666366736683669367036713672367336743675367636773678367936803681368236833684368536863687368836893690369136923693369436953696369736983699370037013702370337043705370637073708370937103711371237133714371537163717371837193720372137223723372437253726372737283729373037313732373337343735373637373738373937403741374237433744374537463747374837493750375137523753375437553756375737583759376037613762376337643765376637673768376937703771377237733774377537763777377837793780378137823783378437853786378737883789379037913792379337943795379637973798379938003801380238033804380538063807380838093810381138123813381438153816381738183819382038213822382338243825382638273828382938303831383238333834383538363837383838393840384138423843384438453846384738483849385038513852385338543855385638573858385938603861386238633864386538663867386838693870387138723873387438753876387738783879388038813882388338843885388638873888388938903891389238933894389538963897389838993900390139023903390439053906390739083909391039113912391339143915391639173918391939203921392239233924392539263927392839293930393139323933393439353936393739383939394039413942394339443945394639473948394939503951395239533954395539563957395839593960396139623963396439653966396739683969397039713972397339743975397639773978397939803981398239833984398539863987398839893990399139923993399439953996399739983999400040014002400340044005400640074008400940104011401240134014401540164017401840194020402140224023402440254026402740284029403040314032403340344035403640374038403940404041404240434044404540464047404840494050405140524053405440554056405740584059406040614062406340644065406640674068406940704071407240734074407540764077407840794080408140824083408440854086408740884089409040914092409340944095409640974098409941004101410241034104410541064107410841094110411141124113411441154116411741184119412041214122412341244125412641274128412941304131413241334134413541364137413841394140414141424143414441454146414741484149415041514152415341544155415641574158415941604161416241634164416541664167416841694170417141724173417441754176417741784179418041814182418341844185418641874188418941904191419241934194419541964197419841994200420142024203420442054206420742084209421042114212421342144215421642174218421942204221422242234224422542264227422842294230423142324233423442354236423742384239424042414242424342444245424642474248424942504251425242534254425542564257425842594260426142624263426442654266426742684269427042714272427342744275427642774278427942804281428242834284428542864287428842894290429142924293429442954296429742984299430043014302430343044305430643074308430943104311431243134314431543164317431843194320432143224323432443254326432743284329433043314332433343344335433643374338433943404341434243434344434543464347434843494350435143524353435443554356435743584359436043614362436343644365436643674368436943704371437243734374437543764377437843794380438143824383438443854386438743884389439043914392439343944395439643974398439944004401440244034404440544064407
  1. // System.Net.Sockets.SocketTest.cs
  2. //
  3. // Authors:
  4. // Brad Fitzpatrick ([email protected])
  5. // Gonzalo Paniagua Javier ([email protected])
  6. //
  7. // (C) Copyright 2003 Brad Fitzpatrick
  8. // Copyright (c) 2005 Novell, Inc. (http://www.novell.com)
  9. //
  10. using System;
  11. using System.Diagnostics;
  12. using System.Linq;
  13. using System.Collections;
  14. using System.Threading;
  15. using System.Reflection;
  16. using System.Text.RegularExpressions;
  17. using System.Net;
  18. using System.Net.Sockets;
  19. using NUnit.Framework;
  20. using System.IO;
  21. using System.Collections.Generic;
  22. namespace MonoTests.System.Net.Sockets
  23. {
  24. [TestFixture]
  25. public class SocketTest
  26. {
  27. // note: also used in SocketCas tests
  28. public const string BogusAddress = "192.168.244.244";
  29. public const int BogusPort = 23483;
  30. [Test]
  31. public void ConnectIPAddressAny ()
  32. {
  33. IPEndPoint ep = new IPEndPoint (IPAddress.Any, 0);
  34. /* UDP sockets use Any to disconnect
  35. try {
  36. using (Socket s = new Socket (AddressFamily.InterNetwork, SocketType.Dgram, ProtocolType.Udp)) {
  37. s.Connect (ep);
  38. s.Close ();
  39. }
  40. Assert.Fail ("#1");
  41. } catch (SocketException ex) {
  42. Assert.AreEqual (10049, ex.ErrorCode, "#2");
  43. }
  44. */
  45. try {
  46. using (Socket s = new Socket (AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp)) {
  47. s.Connect (ep);
  48. s.Close ();
  49. }
  50. Assert.Fail ("#3");
  51. } catch (SocketException ex) {
  52. Assert.AreEqual (10049, ex.ErrorCode, "#4");
  53. }
  54. }
  55. [Test]
  56. [Ignore ("Bug #75158")] // Looks like MS fails after the .ctor, when you try to use the socket
  57. public void IncompatibleAddress ()
  58. {
  59. IPEndPoint epIPv6 = new IPEndPoint (IPAddress.IPv6Any,
  60. 0);
  61. try {
  62. using (Socket s = new Socket (AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.IP)) {
  63. s.Connect (epIPv6);
  64. s.Close ();
  65. }
  66. Assert.Fail ("#1");
  67. } catch (SocketException ex) {
  68. // address incompatible with protocol
  69. int expectedError = 10047;
  70. Assert.AreEqual (expectedError, ex.ErrorCode,
  71. "#2");
  72. }
  73. }
  74. [Test]
  75. [Category ("InetAccess")]
  76. public void BogusEndConnect ()
  77. {
  78. IPAddress ipOne = IPAddress.Parse (BogusAddress);
  79. IPEndPoint ipEP = new IPEndPoint (ipOne, BogusPort);
  80. Socket sock = new Socket (ipEP.AddressFamily, SocketType.Stream, ProtocolType.Tcp);
  81. IAsyncResult ar = sock.BeginConnect (ipEP, null, null);
  82. try {
  83. // should raise an exception because connect was bogus
  84. sock.EndConnect (ar);
  85. Assert.Fail ("#1");
  86. } catch (SocketException ex) {
  87. // Actual error code depends on network configuration.
  88. var error = (SocketError) ex.ErrorCode;
  89. Assert.That (error == SocketError.TimedOut ||
  90. error == SocketError.ConnectionRefused ||
  91. error == SocketError.NetworkUnreachable ||
  92. error == SocketError.HostUnreachable, "#2");
  93. }
  94. }
  95. [Test]
  96. [ExpectedException (typeof (ArgumentNullException))]
  97. public void SelectEmpty ()
  98. {
  99. ArrayList list = new ArrayList ();
  100. Socket.Select (list, list, list, 1000);
  101. }
  102. private bool BlockingConnect (bool block)
  103. {
  104. IPEndPoint ep = new IPEndPoint(IPAddress.Loopback, 1234);
  105. Socket server = new Socket(AddressFamily.InterNetwork,
  106. SocketType.Stream,
  107. ProtocolType.Tcp);
  108. server.Bind(ep);
  109. server.Blocking=block;
  110. server.Listen(0);
  111. Socket conn = new Socket (AddressFamily.InterNetwork,
  112. SocketType.Stream,
  113. ProtocolType.Tcp);
  114. conn.Connect (ep);
  115. Socket client = null;
  116. var sw = Stopwatch.StartNew ();
  117. while (sw.ElapsedMilliseconds < 100)
  118. {
  119. try {
  120. client = server.Accept();
  121. break;
  122. }
  123. catch (SocketException ex) {
  124. if (ex.SocketErrorCode == SocketError.WouldBlock)
  125. continue;
  126. throw;
  127. }
  128. }
  129. Assert.IsNotNull (client, "Couldn't accept a client connection within 100ms.");
  130. bool client_block = client.Blocking;
  131. client.Close();
  132. conn.Close();
  133. server.Close();
  134. return(client_block);
  135. }
  136. [Test]
  137. public void AcceptBlockingStatus()
  138. {
  139. bool block;
  140. block = BlockingConnect(true);
  141. Assert.AreEqual (block, true, "BlockingStatus01");
  142. block = BlockingConnect(false);
  143. Assert.AreEqual (block, false, "BlockingStatus02");
  144. }
  145. static bool CFAConnected = false;
  146. static ManualResetEvent CFACalledBack;
  147. private static void CFACallback (IAsyncResult asyncResult)
  148. {
  149. Socket sock = (Socket)asyncResult.AsyncState;
  150. CFAConnected = sock.Connected;
  151. if (sock.Connected) {
  152. sock.EndConnect (asyncResult);
  153. }
  154. CFACalledBack.Set ();
  155. }
  156. [Test] // Connect (IPEndPoint)
  157. public void Connect1_RemoteEP_Null ()
  158. {
  159. Socket s = new Socket (AddressFamily.InterNetwork,
  160. SocketType.Stream, ProtocolType.Tcp);
  161. try {
  162. s.Connect ((IPEndPoint) null);
  163. Assert.Fail ("#1");
  164. } catch (ArgumentNullException ex) {
  165. Assert.AreEqual (typeof (ArgumentNullException), ex.GetType (), "#2");
  166. Assert.IsNull (ex.InnerException, "#3");
  167. Assert.IsNotNull (ex.Message, "#4");
  168. Assert.AreEqual ("remoteEP", ex.ParamName, "#5");
  169. }
  170. }
  171. [Test]
  172. public void ConnectFailAsync ()
  173. {
  174. Socket sock = new Socket (AddressFamily.InterNetwork,
  175. SocketType.Stream,
  176. ProtocolType.Tcp);
  177. sock.Blocking = false;
  178. CFACalledBack = new ManualResetEvent (false);
  179. CFACalledBack.Reset ();
  180. /* Need a port that is not being used for
  181. * anything...
  182. */
  183. sock.BeginConnect (new IPEndPoint (IPAddress.Loopback,
  184. 114),
  185. new AsyncCallback (CFACallback),
  186. sock);
  187. CFACalledBack.WaitOne ();
  188. Assert.AreEqual (CFAConnected, false, "ConnectFail");
  189. }
  190. [Test]
  191. public void SetSocketOptionBoolean ()
  192. {
  193. IPEndPoint ep = new IPEndPoint (IPAddress.Loopback, 1);
  194. Socket sock = new Socket (ep.Address.AddressFamily, SocketType.Stream, ProtocolType.Tcp);
  195. try {
  196. sock.SetSocketOption (SocketOptionLevel.Socket, SocketOptionName.KeepAlive, true);
  197. } finally {
  198. sock.Close ();
  199. }
  200. }
  201. [Test]
  202. public void TestSelect1 ()
  203. {
  204. Socket srv = CreateServer ();
  205. ClientSocket clnt = new ClientSocket (srv.LocalEndPoint);
  206. Thread th = new Thread (new ThreadStart (clnt.ConnectSleepClose));
  207. Socket acc = null;
  208. try {
  209. th.Start ();
  210. acc = srv.Accept ();
  211. clnt.Write ();
  212. ArrayList list = new ArrayList ();
  213. ArrayList empty = new ArrayList ();
  214. list.Add (acc);
  215. Socket.Select (list, empty, empty, 100);
  216. Assert.AreEqual (0, empty.Count, "#01");
  217. Assert.AreEqual (1, list.Count, "#02");
  218. Socket.Select (empty, list, empty, 100);
  219. Assert.AreEqual (0, empty.Count, "#03");
  220. Assert.AreEqual (1, list.Count, "#04");
  221. Socket.Select (list, empty, empty, -1);
  222. Assert.AreEqual (0, empty.Count, "#05");
  223. Assert.AreEqual (1, list.Count, "#06");
  224. // Need to read the 10 bytes from the client to avoid a RST
  225. byte [] bytes = new byte [10];
  226. acc.Receive (bytes);
  227. } finally {
  228. if (acc != null)
  229. acc.Close ();
  230. srv.Close ();
  231. }
  232. }
  233. static Socket CreateServer ()
  234. {
  235. Socket sock = new Socket (AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
  236. sock.Bind (new IPEndPoint (IPAddress.Loopback, 0));
  237. sock.Listen (1);
  238. return sock;
  239. }
  240. class ClientSocket {
  241. Socket sock;
  242. EndPoint ep;
  243. public ClientSocket (EndPoint ep)
  244. {
  245. this.ep = ep;
  246. sock = new Socket (AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
  247. }
  248. public void ConnectSleepClose ()
  249. {
  250. sock.Connect (ep);
  251. Thread.Sleep (2000);
  252. sock.Close ();
  253. }
  254. public void Write ()
  255. {
  256. byte [] b = new byte [10];
  257. sock.Send (b);
  258. }
  259. }
  260. byte[] buf = new byte[100];
  261. [Test]
  262. [ExpectedException (typeof (ObjectDisposedException))]
  263. public void Disposed2 ()
  264. {
  265. Socket s = new Socket(AddressFamily.InterNetwork, SocketType.Dgram, ProtocolType.Udp);
  266. s.Close();
  267. s.Blocking = true;
  268. }
  269. [Test]
  270. [ExpectedException (typeof (ObjectDisposedException))]
  271. public void Disposed6 ()
  272. {
  273. Socket s = new Socket(AddressFamily.InterNetwork, SocketType.Dgram, ProtocolType.Udp);
  274. s.Close();
  275. s.Listen (5);
  276. }
  277. [Test]
  278. [ExpectedException (typeof (ObjectDisposedException))]
  279. public void Disposed7 ()
  280. {
  281. Socket s = new Socket(AddressFamily.InterNetwork, SocketType.Dgram, ProtocolType.Udp);
  282. s.Close();
  283. s.Poll (100, 0);
  284. }
  285. [Test]
  286. [ExpectedException (typeof (ObjectDisposedException))]
  287. public void Disposed15 ()
  288. {
  289. Socket s = new Socket(AddressFamily.InterNetwork, SocketType.Dgram, ProtocolType.Udp);
  290. s.Close();
  291. s.Send (buf);
  292. }
  293. [Test]
  294. [ExpectedException (typeof (ObjectDisposedException))]
  295. public void Disposed16 ()
  296. {
  297. Socket s = new Socket(AddressFamily.InterNetwork, SocketType.Dgram, ProtocolType.Udp);
  298. s.Close();
  299. s.Send (buf, 0);
  300. }
  301. [Test]
  302. [ExpectedException (typeof (ObjectDisposedException))]
  303. public void Disposed17 ()
  304. {
  305. Socket s = new Socket(AddressFamily.InterNetwork, SocketType.Dgram, ProtocolType.Udp);
  306. s.Close();
  307. s.Send (buf, 10, 0);
  308. }
  309. [Test]
  310. [ExpectedException (typeof (ObjectDisposedException))]
  311. public void Disposed18 ()
  312. {
  313. Socket s = new Socket(AddressFamily.InterNetwork, SocketType.Dgram, ProtocolType.Udp);
  314. s.Close();
  315. s.Send (buf, 0, 10, 0);
  316. }
  317. [Test]
  318. [ExpectedException (typeof (ObjectDisposedException))]
  319. public void Disposed19 ()
  320. {
  321. Socket s = new Socket(AddressFamily.InterNetwork, SocketType.Dgram, ProtocolType.Udp);
  322. EndPoint ep = new IPEndPoint (IPAddress.Any, 31337);
  323. s.Close();
  324. s.SendTo (buf, 0, ep);
  325. }
  326. [Test]
  327. [ExpectedException (typeof (ObjectDisposedException))]
  328. public void Disposed20 ()
  329. {
  330. Socket s = new Socket(AddressFamily.InterNetwork, SocketType.Dgram, ProtocolType.Udp);
  331. EndPoint ep = new IPEndPoint (IPAddress.Any, 31337);
  332. s.Close();
  333. s.SendTo (buf, 10, 0, ep);
  334. }
  335. [Test]
  336. [ExpectedException (typeof (ObjectDisposedException))]
  337. public void Disposed21 ()
  338. {
  339. Socket s = new Socket(AddressFamily.InterNetwork, SocketType.Dgram, ProtocolType.Udp);
  340. EndPoint ep = new IPEndPoint (IPAddress.Any, 31337);
  341. s.Close();
  342. s.SendTo (buf, 0, 10, 0, ep);
  343. }
  344. [Test]
  345. [ExpectedException (typeof (ObjectDisposedException))]
  346. public void Disposed22 ()
  347. {
  348. Socket s = new Socket(AddressFamily.InterNetwork, SocketType.Dgram, ProtocolType.Udp);
  349. EndPoint ep = new IPEndPoint (IPAddress.Any, 31337);
  350. s.Close();
  351. s.SendTo (buf, ep);
  352. }
  353. [Test]
  354. [ExpectedException (typeof (ObjectDisposedException))]
  355. public void Disposed23 ()
  356. {
  357. Socket s = new Socket(AddressFamily.InterNetwork, SocketType.Dgram, ProtocolType.Udp);
  358. s.Close();
  359. s.Shutdown (0);
  360. }
  361. [Test]
  362. public void GetHashCodeTest ()
  363. {
  364. Socket server = new Socket (AddressFamily.InterNetwork,
  365. SocketType.Stream, ProtocolType.Tcp);
  366. IPEndPoint ep = new IPEndPoint (IPAddress.Loopback,
  367. 9010);
  368. server.Bind (ep);
  369. server.Listen (1);
  370. Socket client = new Socket (AddressFamily.InterNetwork,
  371. SocketType.Stream, ProtocolType.Tcp);
  372. int hashcodeA = client.GetHashCode ();
  373. client.Connect (ep);
  374. int hashcodeB = client.GetHashCode ();
  375. Assert.AreEqual (hashcodeA, hashcodeB, "#1");
  376. client.Close ();
  377. int hashcodeC = client.GetHashCode ();
  378. Assert.AreEqual (hashcodeB, hashcodeC, "#2");
  379. server.Close ();
  380. }
  381. static ManualResetEvent SocketError_event = new ManualResetEvent (false);
  382. private static void SocketError_callback (IAsyncResult ar)
  383. {
  384. Socket sock = (Socket)ar.AsyncState;
  385. if(sock.Connected) {
  386. sock.EndConnect (ar);
  387. }
  388. SocketError_event.Set ();
  389. }
  390. [Test]
  391. public void SocketErrorTest ()
  392. {
  393. Socket sock = new Socket (AddressFamily.InterNetwork,
  394. SocketType.Stream,
  395. ProtocolType.Tcp);
  396. IPEndPoint ep = new IPEndPoint (IPAddress.Loopback,
  397. BogusPort);
  398. SocketError_event.Reset ();
  399. sock.Blocking = false;
  400. sock.BeginConnect (ep, new AsyncCallback(SocketError_callback),
  401. sock);
  402. if (SocketError_event.WaitOne (2000, false) == false) {
  403. Assert.Fail ("SocketError wait timed out");
  404. }
  405. Assert.AreEqual (false, sock.Connected, "SocketError #1");
  406. int error;
  407. error = (int)sock.GetSocketOption (SocketOptionLevel.Socket, SocketOptionName.Error);
  408. Assert.AreEqual (10061, error, "SocketError #2");
  409. error = (int)sock.GetSocketOption (SocketOptionLevel.Socket, SocketOptionName.Error);
  410. Assert.AreEqual (10061, error, "SocketError #3");
  411. sock.Close ();
  412. }
  413. [Test]
  414. public void SocketInformationCtor ()
  415. {
  416. }
  417. [Test]
  418. public void DontFragmentDefaultTcp ()
  419. {
  420. Socket sock = new Socket (AddressFamily.InterNetwork,
  421. SocketType.Stream,
  422. ProtocolType.Tcp);
  423. Assert.AreEqual (false, sock.DontFragment, "DontFragmentDefaultTcp");
  424. sock.Close ();
  425. }
  426. [Test]
  427. [Category ("NotWorking")] // DontFragment doesn't work
  428. public void DontFragmentChangeTcp ()
  429. {
  430. Socket sock = new Socket (AddressFamily.InterNetwork,
  431. SocketType.Stream,
  432. ProtocolType.Tcp);
  433. sock.DontFragment = true;
  434. Assert.AreEqual (true, sock.DontFragment, "DontFragmentChangeTcp");
  435. sock.Close ();
  436. }
  437. [Test]
  438. public void DontFragmentDefaultUdp ()
  439. {
  440. Socket sock = new Socket (AddressFamily.InterNetwork,
  441. SocketType.Dgram,
  442. ProtocolType.Udp);
  443. Assert.AreEqual (false, sock.DontFragment, "DontFragmentDefaultUdp");
  444. sock.Close ();
  445. }
  446. [Test]
  447. [Category ("NotWorking")] // DontFragment doesn't work
  448. public void DontFragmentChangeUdp ()
  449. {
  450. Socket sock = new Socket (AddressFamily.InterNetwork,
  451. SocketType.Dgram,
  452. ProtocolType.Udp);
  453. sock.DontFragment = true;
  454. Assert.AreEqual (true, sock.DontFragment, "DontFragmentChangeUdp");
  455. sock.Close ();
  456. }
  457. [Test]
  458. [ExpectedException (typeof(ObjectDisposedException))]
  459. public void DontFragmentClosed ()
  460. {
  461. Socket sock = new Socket (AddressFamily.InterNetwork,
  462. SocketType.Stream,
  463. ProtocolType.Tcp);
  464. sock.Close ();
  465. bool val = sock.DontFragment;
  466. }
  467. [Test]
  468. [Category ("NotWorking")] // Need to pick a non-IP AddressFamily that "works" on both mono and ms, this one only works on ms
  469. public void DontFragment ()
  470. {
  471. Socket sock = new Socket (AddressFamily.NetBios,
  472. SocketType.Seqpacket,
  473. ProtocolType.Unspecified);
  474. try {
  475. sock.DontFragment = true;
  476. Assert.Fail ("DontFragment #1");
  477. } catch (NotSupportedException) {
  478. } catch {
  479. Assert.Fail ("DontFragment #2");
  480. } finally {
  481. sock.Close ();
  482. }
  483. }
  484. [Test]
  485. public void EnableBroadcastDefaultTcp ()
  486. {
  487. Socket sock = new Socket (AddressFamily.InterNetwork,
  488. SocketType.Stream,
  489. ProtocolType.Tcp);
  490. try {
  491. bool value = sock.EnableBroadcast;
  492. Assert.Fail ("EnableBroadcastDefaultTcp #1");
  493. } catch (SocketException ex) {
  494. Assert.AreEqual (10042, ex.ErrorCode, "EnableBroadcastDefaultTcp #2");
  495. } catch {
  496. Assert.Fail ("EnableBroadcastDefaultTcp #2");
  497. } finally {
  498. sock.Close ();
  499. }
  500. }
  501. [Test]
  502. public void EnableBroadcastDefaultUdp ()
  503. {
  504. Socket sock = new Socket (AddressFamily.InterNetwork,
  505. SocketType.Dgram,
  506. ProtocolType.Udp);
  507. Assert.AreEqual (false, sock.EnableBroadcast, "EnableBroadcastDefaultUdp");
  508. sock.Close ();
  509. }
  510. [Test]
  511. public void EnableBroadcastChangeTcp ()
  512. {
  513. Socket sock = new Socket (AddressFamily.InterNetwork,
  514. SocketType.Stream,
  515. ProtocolType.Tcp);
  516. try {
  517. sock.EnableBroadcast = true;
  518. Assert.Fail ("EnableBroadcastChangeTcp #1");
  519. } catch (SocketException ex) {
  520. Assert.AreEqual (10042, ex.ErrorCode, "EnableBroadcastChangeTcp #2");
  521. } catch {
  522. Assert.Fail ("EnableBroadcastChangeTcp #2");
  523. } finally {
  524. sock.Close ();
  525. }
  526. }
  527. [Test]
  528. public void EnableBroadcastChangeUdp ()
  529. {
  530. Socket sock = new Socket (AddressFamily.InterNetwork,
  531. SocketType.Dgram,
  532. ProtocolType.Udp);
  533. sock.EnableBroadcast = true;
  534. Assert.AreEqual (true, sock.EnableBroadcast, "EnableBroadcastChangeUdp");
  535. sock.Close ();
  536. }
  537. [Test]
  538. [ExpectedException (typeof(ObjectDisposedException))]
  539. public void EnableBroadcastClosed ()
  540. {
  541. Socket sock = new Socket (AddressFamily.InterNetwork,
  542. SocketType.Dgram,
  543. ProtocolType.Udp);
  544. sock.Close ();
  545. bool val = sock.EnableBroadcast;
  546. }
  547. /* Can't test the default for ExclusiveAddressUse as
  548. * it's different on different versions and service
  549. * packs of windows
  550. */
  551. [Test]
  552. [Category ("NotWorking")] // Not supported on Linux
  553. public void ExclusiveAddressUseUnbound ()
  554. {
  555. Socket sock = new Socket (AddressFamily.InterNetwork,
  556. SocketType.Stream,
  557. ProtocolType.Tcp);
  558. sock.ExclusiveAddressUse = true;
  559. Assert.AreEqual (true, sock.ExclusiveAddressUse, "ExclusiveAddressUseUnbound");
  560. sock.Close ();
  561. }
  562. [Test]
  563. [ExpectedException (typeof(InvalidOperationException))]
  564. [Category ("NotWorking")] // Not supported on Linux
  565. public void ExclusiveAddressUseBound ()
  566. {
  567. Socket sock = new Socket (AddressFamily.InterNetwork,
  568. SocketType.Stream,
  569. ProtocolType.Tcp);
  570. sock.Bind (new IPEndPoint (IPAddress.Any, 1235));
  571. sock.ExclusiveAddressUse = true;
  572. sock.Close ();
  573. }
  574. [Test]
  575. [ExpectedException (typeof(ObjectDisposedException))]
  576. public void ExclusiveAddressUseClosed ()
  577. {
  578. Socket sock = new Socket (AddressFamily.InterNetwork,
  579. SocketType.Stream,
  580. ProtocolType.Tcp);
  581. sock.Close ();
  582. bool val = sock.ExclusiveAddressUse;
  583. }
  584. [Test]
  585. public void IsBoundTcp ()
  586. {
  587. Socket sock = new Socket (AddressFamily.InterNetwork,
  588. SocketType.Stream,
  589. ProtocolType.Tcp);
  590. IPEndPoint ep = new IPEndPoint (IPAddress.Loopback,
  591. BogusPort);
  592. Assert.AreEqual (false, sock.IsBound, "IsBoundTcp #1");
  593. sock.Bind (ep);
  594. Assert.AreEqual (true, sock.IsBound, "IsBoundTcp #2");
  595. sock.Listen (1);
  596. Socket sock2 = new Socket (AddressFamily.InterNetwork,
  597. SocketType.Stream,
  598. ProtocolType.Tcp);
  599. Assert.AreEqual (false, sock2.IsBound, "IsBoundTcp #3");
  600. sock2.Connect (ep);
  601. Assert.AreEqual (true, sock2.IsBound, "IsBoundTcp #4");
  602. sock2.Close ();
  603. Assert.AreEqual (true, sock2.IsBound, "IsBoundTcp #5");
  604. sock.Close ();
  605. Assert.AreEqual (true, sock.IsBound, "IsBoundTcp #6");
  606. }
  607. [Test]
  608. public void IsBoundUdp ()
  609. {
  610. Socket sock = new Socket (AddressFamily.InterNetwork,
  611. SocketType.Dgram,
  612. ProtocolType.Udp);
  613. IPEndPoint ep = new IPEndPoint (IPAddress.Loopback,
  614. BogusPort);
  615. Assert.AreEqual (false, sock.IsBound, "IsBoundUdp #1");
  616. sock.Bind (ep);
  617. Assert.AreEqual (true, sock.IsBound, "IsBoundUdp #2");
  618. sock.Close ();
  619. Assert.AreEqual (true, sock.IsBound, "IsBoundUdp #3");
  620. sock = new Socket (AddressFamily.InterNetwork,
  621. SocketType.Dgram,
  622. ProtocolType.Udp);
  623. Assert.AreEqual (false, sock.IsBound, "IsBoundUdp #4");
  624. sock.Connect (ep);
  625. Assert.AreEqual (true, sock.IsBound, "IsBoundUdp #5");
  626. sock.Close ();
  627. Assert.AreEqual (true, sock.IsBound, "IsBoundUdp #6");
  628. }
  629. [Test]
  630. /* Should not throw an exception */
  631. public void IsBoundClosed ()
  632. {
  633. Socket sock = new Socket (AddressFamily.InterNetwork,
  634. SocketType.Stream,
  635. ProtocolType.Tcp);
  636. sock.Close ();
  637. bool val = sock.IsBound;
  638. }
  639. /* Nothing much to test for LingerState */
  640. [Test]
  641. public void MulticastLoopbackDefaultTcp ()
  642. {
  643. Socket sock = new Socket (AddressFamily.InterNetwork,
  644. SocketType.Stream,
  645. ProtocolType.Tcp);
  646. try {
  647. bool value = sock.MulticastLoopback;
  648. Assert.Fail ("MulticastLoopbackDefaultTcp #1");
  649. } catch (SocketException ex) {
  650. Assert.AreEqual (10042, ex.ErrorCode, "MulticastLoopbackDefaultTcp #2");
  651. } catch {
  652. Assert.Fail ("MulticastLoopbackDefaultTcp #2");
  653. } finally {
  654. sock.Close ();
  655. }
  656. }
  657. [Test]
  658. public void MulticastLoopbackChangeTcp ()
  659. {
  660. Socket sock = new Socket (AddressFamily.InterNetwork,
  661. SocketType.Stream,
  662. ProtocolType.Tcp);
  663. try {
  664. sock.MulticastLoopback = false;
  665. Assert.Fail ("MulticastLoopbackChangeTcp #1");
  666. } catch (SocketException ex) {
  667. Assert.AreEqual (10042, ex.ErrorCode, "MulticastLoopbackChangeTcp #2");
  668. } catch {
  669. Assert.Fail ("MulticastLoopbackChangeTcp #2");
  670. } finally {
  671. sock.Close ();
  672. }
  673. }
  674. [Test]
  675. public void MulticastLoopbackDefaultUdp ()
  676. {
  677. Socket sock = new Socket (AddressFamily.InterNetwork,
  678. SocketType.Dgram,
  679. ProtocolType.Udp);
  680. Assert.AreEqual (true, sock.MulticastLoopback, "MulticastLoopbackDefaultUdp");
  681. sock.Close ();
  682. }
  683. [Test]
  684. public void MulticastLoopbackChangeUdp ()
  685. {
  686. Socket sock = new Socket (AddressFamily.InterNetwork,
  687. SocketType.Dgram,
  688. ProtocolType.Udp);
  689. sock.MulticastLoopback = false;
  690. Assert.AreEqual (false, sock.MulticastLoopback, "MulticastLoopbackChangeUdp");
  691. sock.Close ();
  692. }
  693. [Test]
  694. [ExpectedException (typeof(ObjectDisposedException))]
  695. public void MulticastLoopbackClosed ()
  696. {
  697. Socket sock = new Socket (AddressFamily.InterNetwork,
  698. SocketType.Stream,
  699. ProtocolType.Tcp);
  700. sock.Close ();
  701. bool val = sock.MulticastLoopback;
  702. }
  703. /* OSSupportsIPv6 depends on the environment */
  704. [Test]
  705. [Category("NotWorking")] // We have different defaults for perf reasons
  706. public void ReceiveBufferSizeDefault ()
  707. {
  708. Socket sock = new Socket (AddressFamily.InterNetwork,
  709. SocketType.Stream,
  710. ProtocolType.Tcp);
  711. Assert.AreEqual (8192, sock.ReceiveBufferSize, "ReceiveBufferSizeDefault");
  712. sock.Close ();
  713. }
  714. [Test]
  715. [Category("NotWorking")] // We have different defaults for perf reasons
  716. public void ReceiveBufferSizeDefaultUdp ()
  717. {
  718. Socket sock = new Socket (AddressFamily.InterNetwork,
  719. SocketType.Dgram,
  720. ProtocolType.Udp);
  721. Assert.AreEqual (8192, sock.ReceiveBufferSize, "ReceiveBufferSizeDefaultUdp");
  722. sock.Close ();
  723. }
  724. [Test]
  725. public void ReceiveBufferSizeChange ()
  726. {
  727. Socket sock = new Socket (AddressFamily.InterNetwork,
  728. SocketType.Stream,
  729. ProtocolType.Tcp);
  730. sock.ReceiveBufferSize = 16384;
  731. Assert.AreEqual (16384, sock.ReceiveBufferSize, "ReceiveBufferSizeChange");
  732. sock.Close ();
  733. }
  734. [Test]
  735. [Category("NotWorking")] // We cannot totally remove buffers (minimum is set to 256
  736. public void BuffersCheck_None ()
  737. {
  738. using (Socket s = new Socket (AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp)) {
  739. int original = s.ReceiveBufferSize;
  740. s.ReceiveBufferSize = 0;
  741. Assert.AreEqual (0, s.ReceiveBufferSize, "ReceiveBufferSize " + original.ToString ());
  742. original = s.SendBufferSize;
  743. s.SendBufferSize = 0;
  744. Assert.AreEqual (0, s.SendBufferSize, "SendBufferSize " + original.ToString ());
  745. }
  746. }
  747. [Test]
  748. [ExpectedException (typeof(ObjectDisposedException))]
  749. public void ReceiveBufferSizeClosed ()
  750. {
  751. Socket sock = new Socket (AddressFamily.InterNetwork,
  752. SocketType.Stream,
  753. ProtocolType.Tcp);
  754. sock.Close ();
  755. int val = sock.ReceiveBufferSize;
  756. }
  757. [Test]
  758. [Category("NotWorking")] // We have different defaults for perf reasons
  759. public void SendBufferSizeDefault ()
  760. {
  761. Socket sock = new Socket (AddressFamily.InterNetwork,
  762. SocketType.Stream,
  763. ProtocolType.Tcp);
  764. Assert.AreEqual (8192, sock.SendBufferSize, "SendBufferSizeDefault");
  765. sock.Close ();
  766. }
  767. [Test]
  768. [Category("NotWorking")] // We have different defaults for perf reasons
  769. public void SendBufferSizeDefaultUdp ()
  770. {
  771. Socket sock = new Socket (AddressFamily.InterNetwork,
  772. SocketType.Dgram,
  773. ProtocolType.Udp);
  774. Assert.AreEqual (8192, sock.SendBufferSize, "SendBufferSizeDefaultUdp");
  775. sock.Close ();
  776. }
  777. [Test]
  778. public void SendBufferSizeChange ()
  779. {
  780. Socket sock = new Socket (AddressFamily.InterNetwork,
  781. SocketType.Stream,
  782. ProtocolType.Tcp);
  783. sock.SendBufferSize = 16384;
  784. Assert.AreEqual (16384, sock.SendBufferSize, "SendBufferSizeChange");
  785. sock.Close ();
  786. }
  787. [Test]
  788. [ExpectedException (typeof(ObjectDisposedException))]
  789. public void SendBufferSizeClosed ()
  790. {
  791. Socket sock = new Socket (AddressFamily.InterNetwork,
  792. SocketType.Stream,
  793. ProtocolType.Tcp);
  794. sock.Close ();
  795. int val = sock.SendBufferSize;
  796. }
  797. /* No test for TTL default as it's platform dependent */
  798. [Test]
  799. public void TtlChange ()
  800. {
  801. Socket sock = new Socket (AddressFamily.InterNetwork,
  802. SocketType.Stream,
  803. ProtocolType.Tcp);
  804. sock.Ttl = 255;
  805. Assert.AreEqual (255, sock.Ttl, "TtlChange");
  806. sock.Close ();
  807. }
  808. [Test]
  809. [Category ("NotOnMac")] // Mac doesn't throw when overflowing the ttl
  810. public void TtlChangeOverflow ()
  811. {
  812. Socket sock = new Socket (AddressFamily.InterNetwork,
  813. SocketType.Stream,
  814. ProtocolType.Tcp);
  815. try {
  816. sock.Ttl = 256;
  817. Assert.Fail ("TtlChangeOverflow #1");
  818. } catch (SocketException ex) {
  819. Assert.AreEqual (10022, ex.ErrorCode,
  820. "TtlChangeOverflow #2");
  821. } catch {
  822. Assert.Fail ("TtlChangeoverflow #3");
  823. } finally {
  824. sock.Close ();
  825. }
  826. }
  827. /* Apparently you can set TTL=0 on the ms runtime!!
  828. try {
  829. sock.Ttl = 0;
  830. Assert.Fail ("TtlChangeOverflow #4");
  831. } catch (SocketException ex) {
  832. Assert.AreEqual (10022, ex.ErrorCode,
  833. "TtlChangeOverflow #5");
  834. } catch {
  835. Assert.Fail ("TtlChangeOverflow #6");
  836. } finally {
  837. sock.Close ();
  838. }
  839. */
  840. [Test]
  841. [ExpectedException (typeof(ObjectDisposedException))]
  842. public void TtlClosed ()
  843. {
  844. Socket sock = new Socket (AddressFamily.InterNetwork,
  845. SocketType.Stream,
  846. ProtocolType.Tcp);
  847. sock.Close ();
  848. int val = sock.Ttl;
  849. }
  850. [Test]
  851. public void UseOnlyOverlappedIODefault ()
  852. {
  853. Socket sock = new Socket (AddressFamily.InterNetwork,
  854. SocketType.Stream,
  855. ProtocolType.Tcp);
  856. Assert.AreEqual (false, sock.UseOnlyOverlappedIO, "UseOnlyOverlappedIODefault");
  857. sock.Close ();
  858. }
  859. //
  860. // We need this because the Linux kernel in certain configurations
  861. // will end up rounding up the values passed on to the kernel
  862. // for socket send/receive timeouts.
  863. //
  864. int Approximate (int target, int value)
  865. {
  866. int epsilon = 10;
  867. if (value > target-10 && value < target+10)
  868. return target;
  869. return value;
  870. }
  871. [Test]
  872. public void UseOnlyOverlappedIOChange ()
  873. {
  874. Socket sock = new Socket (AddressFamily.InterNetwork,
  875. SocketType.Stream,
  876. ProtocolType.Tcp);
  877. sock.UseOnlyOverlappedIO = true;
  878. Assert.AreEqual (true, sock.UseOnlyOverlappedIO, "UseOnlyOverlappedIOChange");
  879. sock.Close ();
  880. }
  881. [Test]
  882. /* Should not throw an exception */
  883. public void UseOnlyOverlappedIOClosed ()
  884. {
  885. Socket sock = new Socket (AddressFamily.InterNetwork,
  886. SocketType.Stream,
  887. ProtocolType.Tcp);
  888. sock.Close ();
  889. bool val = sock.UseOnlyOverlappedIO;
  890. }
  891. [Test]
  892. public void SendTimeoutDefault ()
  893. {
  894. Socket sock = new Socket (AddressFamily.InterNetwork,
  895. SocketType.Stream,
  896. ProtocolType.Tcp);
  897. Assert.AreEqual (0, sock.SendTimeout, "SendTimeoutDefault");
  898. sock.Close ();
  899. }
  900. [Test]
  901. public void SendTimeoutChange ()
  902. {
  903. Socket sock = new Socket (AddressFamily.InterNetwork,
  904. SocketType.Stream,
  905. ProtocolType.Tcp);
  906. /* Should be rounded up to 500, according to
  907. * the MSDN docs, but the MS runtime doesn't
  908. */
  909. sock.SendTimeout = 50;
  910. Assert.AreEqual (50, Approximate (50, sock.SendTimeout), "SendTimeoutChange #1");
  911. sock.SendTimeout = 2000;
  912. Assert.AreEqual (2000, Approximate (2000, sock.SendTimeout), "SendTimeoutChange #2");
  913. sock.SendTimeout = 0;
  914. Assert.AreEqual (0, Approximate (0, sock.SendTimeout), "SendTimeoutChange #3");
  915. /* Should be the same as setting 0 */
  916. sock.SendTimeout = -1;
  917. Assert.AreEqual (0, sock.SendTimeout, "SendTimeoutChange #4");
  918. sock.SendTimeout = 65536;
  919. Assert.AreEqual (65536, Approximate (65536, sock.SendTimeout), "SendTimeoutChange #5");
  920. try {
  921. sock.SendTimeout = -2;
  922. Assert.Fail ("SendTimeoutChange #8");
  923. } catch (ArgumentOutOfRangeException) {
  924. } catch {
  925. Assert.Fail ("SendTimeoutChange #9");
  926. } finally {
  927. sock.Close ();
  928. }
  929. }
  930. [Test]
  931. [ExpectedException (typeof(ObjectDisposedException))]
  932. public void SendTimeoutClosed ()
  933. {
  934. Socket sock = new Socket (AddressFamily.InterNetwork,
  935. SocketType.Stream,
  936. ProtocolType.Tcp);
  937. sock.Close ();
  938. int val = sock.SendTimeout;
  939. }
  940. [Test]
  941. public void ReceiveTimeoutDefault ()
  942. {
  943. Socket sock = new Socket (AddressFamily.InterNetwork,
  944. SocketType.Stream,
  945. ProtocolType.Tcp);
  946. Assert.AreEqual (0, sock.ReceiveTimeout, "ReceiveTimeoutDefault");
  947. sock.Close ();
  948. }
  949. [Test]
  950. public void ReceiveTimeoutChange ()
  951. {
  952. Socket sock = new Socket (AddressFamily.InterNetwork,
  953. SocketType.Stream,
  954. ProtocolType.Tcp);
  955. sock.ReceiveTimeout = 50;
  956. Assert.AreEqual (50, Approximate (50, sock.ReceiveTimeout), "ReceiveTimeoutChange #1");
  957. sock.ReceiveTimeout = 2000;
  958. Assert.AreEqual (2000, Approximate (2000, sock.ReceiveTimeout), "ReceiveTimeoutChange #2");
  959. sock.ReceiveTimeout = 0;
  960. Assert.AreEqual (0, sock.ReceiveTimeout, "ReceiveTimeoutChange #3");
  961. /* Should be the same as setting 0 */
  962. sock.ReceiveTimeout = -1;
  963. Assert.AreEqual (0, sock.ReceiveTimeout, "ReceiveTimeoutChange #4");
  964. sock.ReceiveTimeout = 65536;
  965. Assert.AreEqual (65536, Approximate (65536, sock.ReceiveTimeout), "ReceiveTimeoutChange #5");
  966. try {
  967. sock.ReceiveTimeout = -2;
  968. Assert.Fail ("ReceiveTimeoutChange #8");
  969. } catch (ArgumentOutOfRangeException) {
  970. } catch {
  971. Assert.Fail ("ReceiveTimeoutChange #9");
  972. } finally {
  973. sock.Close ();
  974. }
  975. }
  976. [Test]
  977. [ExpectedException (typeof(ObjectDisposedException))]
  978. public void ReceiveTimeoutClosed ()
  979. {
  980. Socket sock = new Socket (AddressFamily.InterNetwork,
  981. SocketType.Stream,
  982. ProtocolType.Tcp);
  983. sock.Close ();
  984. int val = sock.ReceiveTimeout;
  985. }
  986. [Test]
  987. public void NoDelayDefaultTcp ()
  988. {
  989. Socket sock = new Socket (AddressFamily.InterNetwork,
  990. SocketType.Stream,
  991. ProtocolType.Tcp);
  992. Assert.AreEqual (false, sock.NoDelay, "NoDelayDefaultTcp");
  993. sock.Close ();
  994. }
  995. [Test]
  996. public void NoDelayChangeTcp ()
  997. {
  998. Socket sock = new Socket (AddressFamily.InterNetwork,
  999. SocketType.Stream,
  1000. ProtocolType.Tcp);
  1001. sock.NoDelay = true;
  1002. Assert.AreEqual (true, sock.NoDelay, "NoDelayChangeTcp");
  1003. sock.Close ();
  1004. }
  1005. [Test]
  1006. public void NoDelayDefaultUdp ()
  1007. {
  1008. Socket sock = new Socket (AddressFamily.InterNetwork,
  1009. SocketType.Dgram,
  1010. ProtocolType.Udp);
  1011. try {
  1012. bool val = sock.NoDelay;
  1013. Assert.Fail ("NoDelayDefaultUdp #1");
  1014. } catch (SocketException ex) {
  1015. Assert.AreEqual (10042, ex.ErrorCode,
  1016. "NoDelayDefaultUdp #2");
  1017. } catch {
  1018. Assert.Fail ("NoDelayDefaultUdp #3");
  1019. } finally {
  1020. sock.Close ();
  1021. }
  1022. }
  1023. [Test]
  1024. public void NoDelayChangeUdp ()
  1025. {
  1026. Socket sock = new Socket (AddressFamily.InterNetwork,
  1027. SocketType.Dgram,
  1028. ProtocolType.Udp);
  1029. try {
  1030. sock.NoDelay = true;
  1031. Assert.Fail ("NoDelayChangeUdp #1");
  1032. } catch (SocketException ex) {
  1033. Assert.AreEqual (10042, ex.ErrorCode,
  1034. "NoDelayChangeUdp #2");
  1035. } catch {
  1036. Assert.Fail ("NoDelayChangeUdp #3");
  1037. } finally {
  1038. sock.Close ();
  1039. }
  1040. }
  1041. [Test]
  1042. [ExpectedException (typeof(ObjectDisposedException))]
  1043. public void NoDelayClosed ()
  1044. {
  1045. Socket sock = new Socket (AddressFamily.InterNetwork,
  1046. SocketType.Stream,
  1047. ProtocolType.Tcp);
  1048. sock.Close ();
  1049. bool val = sock.NoDelay;
  1050. }
  1051. static bool BAAccepted = false;
  1052. static Socket BASocket = null;
  1053. static ManualResetEvent BACalledBack = new ManualResetEvent (false);
  1054. private static void BACallback (IAsyncResult asyncResult)
  1055. {
  1056. Socket sock = (Socket)asyncResult.AsyncState;
  1057. BASocket = sock.EndAccept (asyncResult);
  1058. BAAccepted = true;
  1059. BACalledBack.Set ();
  1060. }
  1061. [Test]
  1062. [ExpectedException (typeof(InvalidOperationException))]
  1063. public void BeginAcceptNotBound ()
  1064. {
  1065. Socket sock = new Socket (AddressFamily.InterNetwork,
  1066. SocketType.Stream,
  1067. ProtocolType.Tcp);
  1068. sock.BeginAccept (BACallback, sock);
  1069. sock.Close ();
  1070. }
  1071. [Test]
  1072. [ExpectedException (typeof(InvalidOperationException))]
  1073. public void BeginAcceptNotListening ()
  1074. {
  1075. Socket sock = new Socket (AddressFamily.InterNetwork,
  1076. SocketType.Stream,
  1077. ProtocolType.Tcp);
  1078. sock.Bind (new IPEndPoint (IPAddress.Any, 1236));
  1079. sock.BeginAccept (BACallback, sock);
  1080. sock.Close ();
  1081. }
  1082. [Test]
  1083. public void BeginAccept ()
  1084. {
  1085. Socket sock = new Socket (AddressFamily.InterNetwork,
  1086. SocketType.Stream,
  1087. ProtocolType.Tcp);
  1088. IPEndPoint ep = new IPEndPoint (IPAddress.Loopback,
  1089. 1237);
  1090. sock.Bind (ep);
  1091. sock.Listen (1);
  1092. BACalledBack.Reset ();
  1093. sock.BeginAccept (BACallback, sock);
  1094. Socket conn = new Socket (AddressFamily.InterNetwork,
  1095. SocketType.Stream,
  1096. ProtocolType.Tcp);
  1097. conn.Connect (ep);
  1098. if (BACalledBack.WaitOne (2000, false) == false) {
  1099. Assert.Fail ("BeginAccept wait timed out");
  1100. }
  1101. Assert.AreEqual (true, BAAccepted, "BeginAccept #1");
  1102. Assert.AreEqual (true, BASocket.Connected, "BeginAccept #2");
  1103. Assert.AreEqual (false, sock.Connected, "BeginAccept #3");
  1104. Assert.AreEqual (true, conn.Connected, "BeginAccept #4");
  1105. BASocket.Close ();
  1106. conn.Close ();
  1107. sock.Close ();
  1108. }
  1109. [Test]
  1110. [ExpectedException (typeof(ObjectDisposedException))]
  1111. public void BeginAcceptClosed ()
  1112. {
  1113. Socket sock = new Socket (AddressFamily.InterNetwork,
  1114. SocketType.Stream,
  1115. ProtocolType.Tcp);
  1116. sock.Close ();
  1117. sock.BeginAccept (BACallback, sock);
  1118. }
  1119. static bool BADAccepted = false;
  1120. static Socket BADSocket = null;
  1121. static byte[] BADBytes;
  1122. static int BADByteCount;
  1123. static ManualResetEvent BADCalledBack = new ManualResetEvent (false);
  1124. private static void BADCallback (IAsyncResult asyncResult)
  1125. {
  1126. Socket sock = (Socket)asyncResult.AsyncState;
  1127. BADSocket = sock.EndAccept (out BADBytes,
  1128. out BADByteCount,
  1129. asyncResult);
  1130. BADAccepted = true;
  1131. BADCalledBack.Set ();
  1132. }
  1133. [Test]
  1134. public void BeginAcceptData ()
  1135. {
  1136. Socket sock = new Socket (AddressFamily.InterNetwork,
  1137. SocketType.Stream,
  1138. ProtocolType.Tcp);
  1139. IPEndPoint ep = new IPEndPoint (IPAddress.Loopback,
  1140. 1238);
  1141. sock.Bind (ep);
  1142. sock.Listen (1);
  1143. BADCalledBack.Reset ();
  1144. sock.BeginAccept (256, BADCallback, sock);
  1145. Socket conn = new Socket (AddressFamily.InterNetwork,
  1146. SocketType.Stream,
  1147. ProtocolType.Tcp);
  1148. byte[] send_bytes = new byte[] {10, 11, 12, 13};
  1149. conn.Connect (ep);
  1150. conn.Send (send_bytes);
  1151. if (BADCalledBack.WaitOne (2000, false) == false) {
  1152. Assert.Fail ("BeginAcceptData wait timed out");
  1153. }
  1154. Assert.AreEqual (true, BADAccepted, "BeginAcceptData #1");
  1155. Assert.AreEqual (true, BADSocket.Connected, "BeginAcceptData #2");
  1156. Assert.AreEqual (false, sock.Connected, "BeginAcceptData #3");
  1157. Assert.AreEqual (true, conn.Connected, "BeginAcceptData #4");
  1158. Assert.AreEqual (send_bytes.Length, BADByteCount, "BeginAcceptData #5");
  1159. /* The MS runtime gives the returned data in a
  1160. * much bigger array. TODO: investigate
  1161. * whether it the size correlates to the first
  1162. * parameter in BeginAccept()
  1163. */
  1164. Assert.IsFalse (BADBytes.Length == send_bytes.Length,
  1165. "BeginAcceptData #6");
  1166. for(int i = 0; i < send_bytes.Length; i++) {
  1167. Assert.AreEqual (send_bytes[i], BADBytes[i], "BeginAcceptData #" + (i+7).ToString ());
  1168. }
  1169. BADSocket.Close ();
  1170. conn.Close ();
  1171. sock.Close ();
  1172. }
  1173. [Test]
  1174. [ExpectedException (typeof(ObjectDisposedException))]
  1175. public void BeginAcceptDataClosed ()
  1176. {
  1177. Socket sock = new Socket (AddressFamily.InterNetwork,
  1178. SocketType.Stream,
  1179. ProtocolType.Tcp);
  1180. sock.Close ();
  1181. sock.BeginAccept (256, BADCallback, sock);
  1182. }
  1183. [Test]
  1184. public void BeginAcceptSocketUdp ()
  1185. {
  1186. Socket sock = new Socket (AddressFamily.InterNetwork,
  1187. SocketType.Stream,
  1188. ProtocolType.Tcp);
  1189. Socket acc = new Socket (AddressFamily.InterNetwork,
  1190. SocketType.Dgram,
  1191. ProtocolType.Udp);
  1192. IPEndPoint ep = new IPEndPoint (IPAddress.Loopback,
  1193. 1239);
  1194. sock.Bind (ep);
  1195. sock.Listen (1);
  1196. try {
  1197. sock.BeginAccept (acc, 256, BADCallback, sock);
  1198. Assert.Fail ("BeginAcceptSocketUdp #1");
  1199. } catch (SocketException ex) {
  1200. Assert.AreEqual (10022, ex.ErrorCode, "BeginAcceptSocketUdp #2");
  1201. } catch {
  1202. Assert.Fail ("BeginAcceptSocketUdp #3");
  1203. } finally {
  1204. acc.Close ();
  1205. sock.Close ();
  1206. }
  1207. }
  1208. [Test]
  1209. public void BeginAcceptSocketBound ()
  1210. {
  1211. Socket sock = new Socket (AddressFamily.InterNetwork,
  1212. SocketType.Stream,
  1213. ProtocolType.Tcp);
  1214. Socket acc = new Socket (AddressFamily.InterNetwork,
  1215. SocketType.Stream,
  1216. ProtocolType.Tcp);
  1217. IPEndPoint ep1 = new IPEndPoint (IPAddress.Loopback,
  1218. 1240);
  1219. IPEndPoint ep2 = new IPEndPoint (IPAddress.Loopback,
  1220. 1241);
  1221. sock.Bind (ep1);
  1222. sock.Listen (1);
  1223. acc.Bind (ep2);
  1224. try {
  1225. sock.BeginAccept (acc, 256, BADCallback, sock);
  1226. Assert.Fail ("BeginAcceptSocketBound #1");
  1227. } catch (InvalidOperationException) {
  1228. } catch {
  1229. Assert.Fail ("BeginAcceptSocketBound #2");
  1230. } finally {
  1231. acc.Close ();
  1232. sock.Close ();
  1233. }
  1234. }
  1235. [Test]
  1236. public void BeginAcceptSocket ()
  1237. {
  1238. Socket sock = new Socket (AddressFamily.InterNetwork,
  1239. SocketType.Stream,
  1240. ProtocolType.Tcp);
  1241. Socket acc = new Socket (AddressFamily.InterNetwork,
  1242. SocketType.Stream,
  1243. ProtocolType.Tcp);
  1244. IPEndPoint ep = new IPEndPoint (IPAddress.Loopback,
  1245. 1242);
  1246. sock.Bind (ep);
  1247. sock.Listen (1);
  1248. BADCalledBack.Reset ();
  1249. sock.BeginAccept (acc, 256, BADCallback, sock);
  1250. Socket conn = new Socket (AddressFamily.InterNetwork,
  1251. SocketType.Stream,
  1252. ProtocolType.Tcp);
  1253. byte[] send_bytes = new byte[] {10, 11, 12, 13};
  1254. conn.Connect (ep);
  1255. conn.Send (send_bytes);
  1256. if (BADCalledBack.WaitOne (2000, false) == false) {
  1257. Assert.Fail ("BeginAcceptSocket wait timed out");
  1258. }
  1259. Assert.AreEqual (true, BADAccepted, "BeginAcceptSocket #1");
  1260. Assert.AreEqual (true, BADSocket.Connected, "BeginAcceptSocket #2");
  1261. Assert.AreEqual (false, sock.Connected, "BeginAcceptSocket #3");
  1262. Assert.AreEqual (true, conn.Connected, "BeginAcceptSocket #4");
  1263. Assert.AreEqual (send_bytes.Length, BADByteCount, "BeginAcceptSocket #5");
  1264. Assert.AreEqual (AddressFamily.InterNetwork, acc.AddressFamily, "BeginAcceptSocket #6");
  1265. Assert.AreEqual (SocketType.Stream, acc.SocketType, "BeginAcceptSocket #7");
  1266. Assert.AreEqual (ProtocolType.Tcp, acc.ProtocolType, "BeginAcceptSocket #8");
  1267. Assert.AreEqual (conn.LocalEndPoint, acc.RemoteEndPoint, "BeginAcceptSocket #9");
  1268. /* The MS runtime gives the returned data in a
  1269. * much bigger array. TODO: investigate
  1270. * whether it the size correlates to the first
  1271. * parameter in BeginAccept()
  1272. */
  1273. Assert.IsFalse (BADBytes.Length == send_bytes.Length,
  1274. "BeginAcceptSocket #10");
  1275. for(int i = 0; i < send_bytes.Length; i++) {
  1276. Assert.AreEqual (send_bytes[i], BADBytes[i], "BeginAcceptSocket #" + (i+11).ToString ());
  1277. }
  1278. BADSocket.Close ();
  1279. conn.Close ();
  1280. acc.Close ();
  1281. sock.Close ();
  1282. }
  1283. [Test]
  1284. public void BeginAcceptSocketClosed ()
  1285. {
  1286. Socket sock = new Socket (AddressFamily.InterNetwork,
  1287. SocketType.Stream,
  1288. ProtocolType.Tcp);
  1289. Socket acc = new Socket (AddressFamily.InterNetwork,
  1290. SocketType.Stream,
  1291. ProtocolType.Tcp);
  1292. sock.Close ();
  1293. try {
  1294. sock.BeginAccept (acc, 256, BADCallback, null);
  1295. Assert.Fail ("BeginAcceptSocketClosed #1");
  1296. } catch (ObjectDisposedException) {
  1297. } catch {
  1298. Assert.Fail ("BeginAcceptSocketClosed #2");
  1299. } finally {
  1300. acc.Close ();
  1301. }
  1302. }
  1303. [Test]
  1304. public void BeginAcceptSocketAccClosed ()
  1305. {
  1306. Socket sock = new Socket (AddressFamily.InterNetwork,
  1307. SocketType.Stream,
  1308. ProtocolType.Tcp);
  1309. Socket acc = new Socket (AddressFamily.InterNetwork,
  1310. SocketType.Stream,
  1311. ProtocolType.Tcp);
  1312. IPEndPoint ep = new IPEndPoint (IPAddress.Loopback,
  1313. 1243);
  1314. sock.Bind (ep);
  1315. sock.Listen (1);
  1316. acc.Close ();
  1317. BADCalledBack.Reset ();
  1318. try {
  1319. sock.BeginAccept (acc, 256, BADCallback, null);
  1320. Assert.Fail ("BeginAcceptSocketAccClosed #1");
  1321. } catch (ObjectDisposedException) {
  1322. } catch {
  1323. Assert.Fail ("BeginAcceptSocketAccClosed #2");
  1324. } finally {
  1325. sock.Close ();
  1326. }
  1327. }
  1328. static bool BCConnected = false;
  1329. static ManualResetEvent BCCalledBack = new ManualResetEvent (false);
  1330. private static void BCCallback (IAsyncResult asyncResult)
  1331. {
  1332. Socket sock = (Socket)asyncResult.AsyncState;
  1333. try {
  1334. sock.EndConnect (asyncResult);
  1335. } catch (Exception e) {
  1336. Console.WriteLine ("BCCallback exception:");
  1337. Console.WriteLine (e);
  1338. throw;
  1339. }
  1340. BCConnected = true;
  1341. BCCalledBack.Set ();
  1342. }
  1343. [Test]
  1344. public void BeginConnectAddressPort ()
  1345. {
  1346. Socket sock = new Socket (AddressFamily.InterNetwork,
  1347. SocketType.Stream,
  1348. ProtocolType.Tcp);
  1349. Socket listen = new Socket (AddressFamily.InterNetwork,
  1350. SocketType.Stream,
  1351. ProtocolType.Tcp);
  1352. IPAddress ip = IPAddress.Loopback;
  1353. IPEndPoint ep = new IPEndPoint (ip, 1244);
  1354. listen.Bind (ep);
  1355. listen.Listen (1);
  1356. BCCalledBack.Reset ();
  1357. BCConnected = false;
  1358. sock.BeginConnect (ip, 1244, BCCallback, sock);
  1359. if (BCCalledBack.WaitOne (2000, false) == false) {
  1360. Assert.Fail ("BeginConnectAddressPort wait timed out");
  1361. }
  1362. Assert.AreEqual (true, BCConnected, "BeginConnectAddressPort #1");
  1363. sock.Close ();
  1364. listen.Close ();
  1365. }
  1366. [Test]
  1367. public void BeginConnectAddressPortNull ()
  1368. {
  1369. Socket sock = new Socket (AddressFamily.InterNetwork,
  1370. SocketType.Stream,
  1371. ProtocolType.Tcp);
  1372. IPAddress ip = null;
  1373. try {
  1374. sock.BeginConnect (ip, 1244, BCCallback,
  1375. sock);
  1376. Assert.Fail ("BeginConnectAddressPortNull #1");
  1377. } catch (ArgumentNullException) {
  1378. } catch {
  1379. Assert.Fail ("BeginConnectAddressPortNull #2");
  1380. } finally {
  1381. sock.Close ();
  1382. }
  1383. }
  1384. [Test]
  1385. public void BeginConnectAddressPortListen ()
  1386. {
  1387. Socket sock = new Socket (AddressFamily.InterNetwork,
  1388. SocketType.Stream,
  1389. ProtocolType.Tcp);
  1390. IPAddress ip = IPAddress.Loopback;
  1391. IPEndPoint ep = new IPEndPoint (ip, 1245);
  1392. sock.Bind (ep);
  1393. sock.Listen (1);
  1394. try {
  1395. sock.BeginConnect (ip, 1245, BCCallback, sock);
  1396. Assert.Fail ("BeginConnectAddressPortListen #1");
  1397. } catch (InvalidOperationException) {
  1398. } catch {
  1399. Assert.Fail ("BeginConnectAddressPortListen #2");
  1400. } finally {
  1401. sock.Close ();
  1402. }
  1403. }
  1404. [Test]
  1405. [ExpectedException (typeof(ObjectDisposedException))]
  1406. public void BeginConnectAddressPortClosed ()
  1407. {
  1408. Socket sock = new Socket (AddressFamily.InterNetwork,
  1409. SocketType.Stream,
  1410. ProtocolType.Tcp);
  1411. IPAddress ip = IPAddress.Loopback;
  1412. sock.Close ();
  1413. sock.BeginConnect (ip, 1244, BCCallback, sock);
  1414. }
  1415. [Test]
  1416. [Category ("NotOnMac")]
  1417. /*
  1418. * This is not a Mono bug.
  1419. *
  1420. * By default, only 127.0.0.1 is enabled and you must explicitly
  1421. * enable additional addresses using 'sudo ifconfig lo0 alias 127.0.0.1'.
  1422. *
  1423. * I tested this on Mac OS 10.7.4; a 'ping 127.0.0.2' does not work
  1424. * until I add that alias.
  1425. *
  1426. */
  1427. public void BeginConnectMultiple ()
  1428. {
  1429. Socket sock = new Socket (AddressFamily.InterNetwork,
  1430. SocketType.Stream,
  1431. ProtocolType.Tcp);
  1432. Socket listen = new Socket (AddressFamily.InterNetwork,
  1433. SocketType.Stream,
  1434. ProtocolType.Tcp);
  1435. IPEndPoint ep = new IPEndPoint (IPAddress.Loopback,
  1436. 1246);
  1437. IPAddress[] ips = new IPAddress[4];
  1438. ips[0] = IPAddress.Parse ("127.0.0.4");
  1439. ips[1] = IPAddress.Parse ("127.0.0.3");
  1440. ips[2] = IPAddress.Parse ("127.0.0.2");
  1441. ips[3] = IPAddress.Parse ("127.0.0.1");
  1442. listen.Bind (ep);
  1443. listen.Listen (1);
  1444. BCCalledBack.Reset ();
  1445. BCConnected = false;
  1446. sock.BeginConnect (ips, 1246, BCCallback, sock);
  1447. /* Longer wait here, because the ms runtime
  1448. * takes a lot longer to not connect
  1449. */
  1450. /*
  1451. if (BCCalledBack.WaitOne (30000, false) == false) {
  1452. Assert.Fail ("BeginConnectMultiple wait failed");
  1453. }
  1454. */
  1455. Assert.IsTrue (BCCalledBack.WaitOne (30000), "#0");
  1456. Assert.AreEqual (true, BCConnected, "BeginConnectMultiple #1");
  1457. Assert.AreEqual (AddressFamily.InterNetwork, sock.RemoteEndPoint.AddressFamily, "BeginConnectMultiple #2");
  1458. IPEndPoint remep = (IPEndPoint)sock.RemoteEndPoint;
  1459. Assert.AreEqual (IPAddress.Loopback, remep.Address, "BeginConnectMultiple #2");
  1460. sock.Close ();
  1461. listen.Close ();
  1462. }
  1463. [Test]
  1464. public void BeginConnectMultiple2 ()
  1465. {
  1466. Socket sock = new Socket (AddressFamily.InterNetwork,
  1467. SocketType.Stream,
  1468. ProtocolType.Tcp);
  1469. Socket listen = new Socket (AddressFamily.InterNetwork,
  1470. SocketType.Stream,
  1471. ProtocolType.Tcp);
  1472. // Need at least two addresses.
  1473. var ips = Dns.GetHostAddresses (string.Empty);
  1474. if (ips.Length < 1)
  1475. Assert.Ignore ("This test needs at least two IP addresses.");
  1476. var allIps = new IPAddress [ips.Length + 1];
  1477. allIps [0] = IPAddress.Loopback;
  1478. ips.CopyTo (allIps, 1);
  1479. /*
  1480. * Only bind to the loopback interface, so all the non-loopback
  1481. * IP addresses will fail. BeginConnect()/EndConnect() should
  1482. * succeed it it can connect to at least one of the requested
  1483. * addresses.
  1484. */
  1485. IPEndPoint ep = new IPEndPoint (IPAddress.Loopback, 1246);
  1486. listen.Bind (ep);
  1487. listen.Listen (1);
  1488. BCCalledBack.Reset ();
  1489. BCConnected = false;
  1490. sock.BeginConnect (allIps, 1246, BCCallback, sock);
  1491. /* Longer wait here, because the ms runtime
  1492. * takes a lot longer to not connect
  1493. */
  1494. if (BCCalledBack.WaitOne (10000, false) == false) {
  1495. Assert.Fail ("BeginConnectMultiple2 wait failed");
  1496. }
  1497. Assert.AreEqual (true, BCConnected, "BeginConnectMultiple2 #1");
  1498. Assert.AreEqual (AddressFamily.InterNetwork, sock.RemoteEndPoint.AddressFamily, "BeginConnectMultiple2 #2");
  1499. IPEndPoint remep = (IPEndPoint)sock.RemoteEndPoint;
  1500. Assert.AreEqual (IPAddress.Loopback, remep.Address, "BeginConnectMultiple2 #2");
  1501. sock.Close ();
  1502. listen.Close ();
  1503. }
  1504. [Test]
  1505. public void BeginConnectMultipleNull ()
  1506. {
  1507. Socket sock = new Socket (AddressFamily.InterNetwork,
  1508. SocketType.Stream,
  1509. ProtocolType.Tcp);
  1510. IPAddress[] ips = null;
  1511. try {
  1512. sock.BeginConnect (ips, 1246, BCCallback,
  1513. sock);
  1514. Assert.Fail ("BeginConnectMultipleNull #1");
  1515. } catch (ArgumentNullException) {
  1516. } catch {
  1517. Assert.Fail ("BeginConnectMultipleNull #2");
  1518. } finally {
  1519. sock.Close ();
  1520. }
  1521. }
  1522. [Test]
  1523. public void BeginConnectMultipleListen ()
  1524. {
  1525. Socket sock = new Socket (AddressFamily.InterNetwork,
  1526. SocketType.Stream,
  1527. ProtocolType.Tcp);
  1528. IPAddress[] ips = new IPAddress[4];
  1529. IPEndPoint ep = new IPEndPoint (IPAddress.Loopback,
  1530. 1247);
  1531. ips[0] = IPAddress.Parse ("127.0.0.4");
  1532. ips[1] = IPAddress.Parse ("127.0.0.3");
  1533. ips[2] = IPAddress.Parse ("127.0.0.2");
  1534. ips[3] = IPAddress.Parse ("127.0.0.1");
  1535. sock.Bind (ep);
  1536. sock.Listen (1);
  1537. try {
  1538. sock.BeginConnect (ips, 1247, BCCallback,
  1539. sock);
  1540. Assert.Fail ("BeginConnectMultipleListen #1");
  1541. } catch (InvalidOperationException) {
  1542. } catch {
  1543. Assert.Fail ("BeginConnectMultipleListen #2");
  1544. } finally {
  1545. sock.Close ();
  1546. }
  1547. }
  1548. [Test]
  1549. [ExpectedException (typeof(ObjectDisposedException))]
  1550. public void BeginConnectMultipleClosed ()
  1551. {
  1552. Socket sock = new Socket (AddressFamily.InterNetwork,
  1553. SocketType.Stream,
  1554. ProtocolType.Tcp);
  1555. IPAddress[] ips = new IPAddress[4];
  1556. ips[0] = IPAddress.Parse ("127.0.0.4");
  1557. ips[1] = IPAddress.Parse ("127.0.0.3");
  1558. ips[2] = IPAddress.Parse ("127.0.0.2");
  1559. ips[3] = IPAddress.Parse ("127.0.0.1");
  1560. sock.Close ();
  1561. sock.BeginConnect (ips, 1247, BCCallback, sock);
  1562. }
  1563. [Test]
  1564. public void BeginConnectHostPortNull ()
  1565. {
  1566. Socket sock = new Socket (AddressFamily.InterNetwork,
  1567. SocketType.Stream,
  1568. ProtocolType.Tcp);
  1569. try {
  1570. sock.BeginConnect ((string)null, 0,
  1571. BCCallback, sock);
  1572. Assert.Fail ("BeginConnectHostPort #1");
  1573. } catch (ArgumentNullException) {
  1574. } catch {
  1575. Assert.Fail ("BeginConnectHostPort #2");
  1576. } finally {
  1577. sock.Close ();
  1578. }
  1579. }
  1580. [Test]
  1581. public void BeginConnectHostPortListen ()
  1582. {
  1583. Socket sock = new Socket (AddressFamily.InterNetwork,
  1584. SocketType.Stream,
  1585. ProtocolType.Tcp);
  1586. IPAddress ip = IPAddress.Loopback;
  1587. IPEndPoint ep = new IPEndPoint (ip, 1248);
  1588. sock.Bind (ep);
  1589. sock.Listen (1);
  1590. try {
  1591. sock.BeginConnect ("localhost", 1248,
  1592. BCCallback, sock);
  1593. Assert.Fail ("BeginConnectHostPortListen #1");
  1594. } catch (InvalidOperationException) {
  1595. } catch {
  1596. Assert.Fail ("BeginConnectHostPortListen #2");
  1597. } finally {
  1598. sock.Close ();
  1599. }
  1600. }
  1601. [Test]
  1602. [Category ("NotWorking")] // Need to pick a non-IP AddressFamily that "works" on both mono and ms, this one only works on ms
  1603. public void BeginConnectHostPortNotIP ()
  1604. {
  1605. Socket sock = new Socket (AddressFamily.NetBios,
  1606. SocketType.Seqpacket,
  1607. ProtocolType.Unspecified);
  1608. try {
  1609. sock.BeginConnect ("localhost", 0, BCCallback,
  1610. sock);
  1611. Assert.Fail ("BeginConnectHostPortNotIP #1");
  1612. } catch (NotSupportedException) {
  1613. } catch {
  1614. Assert.Fail ("BeginConnectHostPortNotIP #2");
  1615. } finally {
  1616. sock.Close ();
  1617. }
  1618. }
  1619. [Test]
  1620. [ExpectedException (typeof(ObjectDisposedException))]
  1621. public void BeginConnectHostPortClosed ()
  1622. {
  1623. Socket sock = new Socket (AddressFamily.InterNetwork,
  1624. SocketType.Stream,
  1625. ProtocolType.Tcp);
  1626. sock.Close ();
  1627. sock.BeginConnect ("localhost", 0, BCCallback, sock);
  1628. }
  1629. static bool BDDisconnected = false;
  1630. static ManualResetEvent BDCalledBack = new ManualResetEvent (false);
  1631. private static void BDCallback (IAsyncResult asyncResult)
  1632. {
  1633. Socket sock = (Socket)asyncResult.AsyncState;
  1634. sock.EndDisconnect (asyncResult);
  1635. BDDisconnected = true;
  1636. BDCalledBack.Set ();
  1637. }
  1638. [Test]
  1639. [Category ("NotDotNet")] // "Needs XP or later"
  1640. public void BeginDisconnect ()
  1641. {
  1642. Socket sock = new Socket (AddressFamily.InterNetwork,
  1643. SocketType.Stream,
  1644. ProtocolType.Tcp);
  1645. Socket listen = new Socket (AddressFamily.InterNetwork,
  1646. SocketType.Stream,
  1647. ProtocolType.Tcp);
  1648. IPAddress ip = IPAddress.Loopback;
  1649. IPEndPoint ep = new IPEndPoint (ip, 1254);
  1650. listen.Bind (ep);
  1651. listen.Listen (1);
  1652. sock.Connect (ip, 1254);
  1653. Assert.AreEqual (true, sock.Connected, "BeginDisconnect #1");
  1654. sock.Shutdown (SocketShutdown.Both);
  1655. BDCalledBack.Reset ();
  1656. BDDisconnected = false;
  1657. sock.BeginDisconnect (false, BDCallback, sock);
  1658. if (BDCalledBack.WaitOne (2000, false) == false) {
  1659. Assert.Fail ("BeginDisconnect wait timed out");
  1660. }
  1661. Assert.AreEqual (true, BDDisconnected, "BeginDisconnect #2");
  1662. Assert.AreEqual (false, sock.Connected, "BeginDisconnect #3");
  1663. sock.Close ();
  1664. listen.Close ();
  1665. }
  1666. [Test]
  1667. public void BeginReceiveSocketError ()
  1668. {
  1669. }
  1670. [Test]
  1671. public void BeginReceiveGeneric ()
  1672. {
  1673. }
  1674. [Test]
  1675. public void BeginReceiveGenericSocketError ()
  1676. {
  1677. }
  1678. private static void BSCallback (IAsyncResult asyncResult)
  1679. {
  1680. Socket sock = (Socket)asyncResult.AsyncState;
  1681. sock.EndSend (asyncResult);
  1682. }
  1683. [Test]
  1684. public void BeginSendNotConnected ()
  1685. {
  1686. Socket sock = new Socket (AddressFamily.InterNetwork,
  1687. SocketType.Stream,
  1688. ProtocolType.Tcp);
  1689. byte[] send_bytes = new byte[] {10, 11, 12, 13};
  1690. try {
  1691. sock.BeginSend (send_bytes, 0,
  1692. send_bytes.Length,
  1693. SocketFlags.None, BSCallback,
  1694. sock);
  1695. Assert.Fail ("BeginSendNotConnected #1");
  1696. } catch (SocketException ex) {
  1697. Assert.AreEqual (10057, ex.ErrorCode, "BeginSendNotConnected #2");
  1698. } catch {
  1699. Assert.Fail ("BeginSendNotConnected #3");
  1700. } finally {
  1701. sock.Close ();
  1702. }
  1703. }
  1704. [Test]
  1705. public void BeginSendSocketError ()
  1706. {
  1707. }
  1708. [Test]
  1709. public void BeginSendGeneric ()
  1710. {
  1711. }
  1712. [Test]
  1713. public void BeginSendGenericSocketError ()
  1714. {
  1715. }
  1716. [Test]
  1717. public void BindTwice ()
  1718. {
  1719. Socket sock = new Socket (AddressFamily.InterNetwork,
  1720. SocketType.Stream,
  1721. ProtocolType.Tcp);
  1722. IPEndPoint ep1 = new IPEndPoint (IPAddress.Loopback,
  1723. 1256);
  1724. IPEndPoint ep2 = new IPEndPoint (IPAddress.Loopback,
  1725. 1257);
  1726. sock.Bind (ep1);
  1727. try {
  1728. sock.Bind (ep2);
  1729. Assert.Fail ("BindTwice #1");
  1730. } catch (SocketException ex) {
  1731. Assert.AreEqual (10022, ex.ErrorCode, "BindTwice #2");
  1732. } catch {
  1733. Assert.Fail ("BindTwice #3");
  1734. } finally {
  1735. sock.Close ();
  1736. }
  1737. }
  1738. [Test]
  1739. public void Close ()
  1740. {
  1741. Socket sock = new Socket (AddressFamily.InterNetwork,
  1742. SocketType.Stream,
  1743. ProtocolType.Tcp);
  1744. Socket listen = new Socket (AddressFamily.InterNetwork,
  1745. SocketType.Stream,
  1746. ProtocolType.Tcp);
  1747. IPEndPoint ep = new IPEndPoint (IPAddress.Loopback,
  1748. 1258);
  1749. listen.Bind (ep);
  1750. listen.Listen (1);
  1751. sock.Connect (ep);
  1752. Assert.AreEqual (true, sock.Connected, "Close #1");
  1753. sock.Close (2);
  1754. Thread.Sleep (3000);
  1755. Assert.AreEqual (false, sock.Connected, "Close #2");
  1756. listen.Close ();
  1757. }
  1758. [Test]
  1759. public void ConnectAddressPort ()
  1760. {
  1761. Socket sock = new Socket (AddressFamily.InterNetwork,
  1762. SocketType.Stream,
  1763. ProtocolType.Tcp);
  1764. Socket listen = new Socket (AddressFamily.InterNetwork,
  1765. SocketType.Stream,
  1766. ProtocolType.Tcp);
  1767. IPAddress ip = IPAddress.Loopback;
  1768. IPEndPoint ep = new IPEndPoint (ip, 1249);
  1769. listen.Bind (ep);
  1770. listen.Listen (1);
  1771. sock.Connect (ip, 1249);
  1772. Assert.AreEqual (true, sock.Connected, "ConnectAddressPort #1");
  1773. sock.Close ();
  1774. listen.Close ();
  1775. }
  1776. [Test]
  1777. public void ConnectAddressPortNull ()
  1778. {
  1779. Socket sock = new Socket (AddressFamily.InterNetwork,
  1780. SocketType.Stream,
  1781. ProtocolType.Tcp);
  1782. IPAddress ip = null;
  1783. try {
  1784. sock.Connect (ip, 1249);
  1785. Assert.Fail ("ConnectAddressPortNull #1");
  1786. } catch (ArgumentNullException) {
  1787. } catch {
  1788. Assert.Fail ("ConnectAddressPortNull #2");
  1789. } finally {
  1790. sock.Close ();
  1791. }
  1792. }
  1793. [Test]
  1794. public void ConnectAddressPortListen ()
  1795. {
  1796. Socket sock = new Socket (AddressFamily.InterNetwork,
  1797. SocketType.Stream,
  1798. ProtocolType.Tcp);
  1799. IPAddress ip = IPAddress.Loopback;
  1800. IPEndPoint ep = new IPEndPoint (ip, 1250);
  1801. sock.Bind (ep);
  1802. sock.Listen (1);
  1803. try {
  1804. sock.Connect (ip, 1250);
  1805. Assert.Fail ("ConnectAddressPortListen #1");
  1806. } catch (InvalidOperationException) {
  1807. } catch {
  1808. Assert.Fail ("ConnectAddressPortListen #2");
  1809. } finally {
  1810. sock.Close ();
  1811. }
  1812. }
  1813. [Test]
  1814. [ExpectedException (typeof(ObjectDisposedException))]
  1815. public void ConnectAddressPortClosed ()
  1816. {
  1817. Socket sock = new Socket (AddressFamily.InterNetwork,
  1818. SocketType.Stream,
  1819. ProtocolType.Tcp);
  1820. IPAddress ip = IPAddress.Loopback;
  1821. sock.Close ();
  1822. sock.Connect (ip, 1250);
  1823. }
  1824. [Test]
  1825. [Category ("NotOnMac")] // MacOSX trashes the fd after the failed connect attempt to 127.0.0.4
  1826. /*
  1827. * This is not a Mono bug.
  1828. *
  1829. * By default, only 127.0.0.1 is enabled and you must explicitly
  1830. * enable additional addresses using 'sudo ifconfig lo0 alias 127.0.0.1'.
  1831. *
  1832. * I tested this on Mac OS 10.7.4; a 'ping 127.0.0.2' does not work
  1833. * until I add that alias.
  1834. *
  1835. * However, after doing so, Mac OS treats these as separate addresses, ie. attempting
  1836. * to connect to 127.0.0.4 yields a connection refused.
  1837. *
  1838. * When using Connect(), the .NET runtime also throws an exception if connecting to
  1839. * any of the IP addresses fails. This is different with BeginConnect()/EndConnect()
  1840. * which succeeds when it can connect to at least one of the addresses.
  1841. *
  1842. */
  1843. public void ConnectMultiple ()
  1844. {
  1845. Socket sock = new Socket (AddressFamily.InterNetwork,
  1846. SocketType.Stream,
  1847. ProtocolType.Tcp);
  1848. Socket listen = new Socket (AddressFamily.InterNetwork,
  1849. SocketType.Stream,
  1850. ProtocolType.Tcp);
  1851. IPEndPoint ep = new IPEndPoint (IPAddress.Loopback,
  1852. 1251);
  1853. IPAddress[] ips = new IPAddress[4];
  1854. ips[0] = IPAddress.Parse ("127.0.0.4");
  1855. ips[1] = IPAddress.Parse ("127.0.0.3");
  1856. ips[2] = IPAddress.Parse ("127.0.0.2");
  1857. ips[3] = IPAddress.Parse ("127.0.0.1");
  1858. listen.Bind (ep);
  1859. listen.Listen (1);
  1860. sock.Connect (ips, 1251);
  1861. Assert.AreEqual (true, sock.Connected, "ConnectMultiple #1");
  1862. Assert.AreEqual (AddressFamily.InterNetwork, sock.RemoteEndPoint.AddressFamily, "ConnectMultiple #2");
  1863. IPEndPoint remep = (IPEndPoint)sock.RemoteEndPoint;
  1864. Assert.AreEqual (IPAddress.Loopback, remep.Address, "ConnectMultiple #2");
  1865. sock.Close ();
  1866. listen.Close ();
  1867. }
  1868. [Test]
  1869. public void ConnectMultiple2 ()
  1870. {
  1871. Socket sock = new Socket (AddressFamily.InterNetwork,
  1872. SocketType.Stream,
  1873. ProtocolType.Tcp);
  1874. Socket listen = new Socket (AddressFamily.InterNetwork,
  1875. SocketType.Stream,
  1876. ProtocolType.Tcp);
  1877. // Need at least two addresses.
  1878. var ips = Dns.GetHostAddresses (string.Empty);
  1879. if (ips.Length < 1)
  1880. Assert.Ignore ("This test needs at least two IP addresses.");
  1881. var allIps = new IPAddress [ips.Length + 1];
  1882. allIps [0] = IPAddress.Loopback;
  1883. ips.CopyTo (allIps, 1);
  1884. /*
  1885. * Bind to IPAddress.Any; Connect() will fail unless it can
  1886. * connect to all the addresses in allIps.
  1887. */
  1888. IPEndPoint ep = new IPEndPoint (IPAddress.Any, 1251);
  1889. listen.Bind (ep);
  1890. listen.Listen (1);
  1891. sock.Connect (allIps, 1251);
  1892. Assert.AreEqual (true, sock.Connected, "ConnectMultiple2 #1");
  1893. Assert.AreEqual (AddressFamily.InterNetwork, sock.RemoteEndPoint.AddressFamily, "ConnectMultiple2 #2");
  1894. IPEndPoint remep = (IPEndPoint)sock.RemoteEndPoint;
  1895. Assert.AreEqual (IPAddress.Loopback, remep.Address, "ConnectMultiple2 #3");
  1896. sock.Close ();
  1897. listen.Close ();
  1898. }
  1899. [Test]
  1900. public void ConnectMultipleNull ()
  1901. {
  1902. Socket sock = new Socket (AddressFamily.InterNetwork,
  1903. SocketType.Stream,
  1904. ProtocolType.Tcp);
  1905. IPAddress[] ips = null;
  1906. try {
  1907. sock.Connect (ips, 1251);
  1908. Assert.Fail ("ConnectMultipleNull #1");
  1909. } catch (ArgumentNullException) {
  1910. } catch {
  1911. Assert.Fail ("ConnectMultipleNull #2");
  1912. } finally {
  1913. sock.Close ();
  1914. }
  1915. }
  1916. [Test]
  1917. public void ConnectMultipleListen ()
  1918. {
  1919. Socket sock = new Socket (AddressFamily.InterNetwork,
  1920. SocketType.Stream,
  1921. ProtocolType.Tcp);
  1922. IPAddress[] ips = new IPAddress[4];
  1923. IPEndPoint ep = new IPEndPoint (IPAddress.Loopback,
  1924. 1252);
  1925. ips[0] = IPAddress.Parse ("127.0.0.4");
  1926. ips[1] = IPAddress.Parse ("127.0.0.3");
  1927. ips[2] = IPAddress.Parse ("127.0.0.2");
  1928. ips[3] = IPAddress.Parse ("127.0.0.1");
  1929. sock.Bind (ep);
  1930. sock.Listen (1);
  1931. try {
  1932. sock.Connect (ips, 1252);
  1933. Assert.Fail ("ConnectMultipleListen #1");
  1934. } catch (InvalidOperationException) {
  1935. } catch {
  1936. Assert.Fail ("ConnectMultipleListen #2");
  1937. } finally {
  1938. sock.Close ();
  1939. }
  1940. }
  1941. [Test]
  1942. [ExpectedException (typeof(ObjectDisposedException))]
  1943. public void ConnectMultipleClosed ()
  1944. {
  1945. Socket sock = new Socket (AddressFamily.InterNetwork,
  1946. SocketType.Stream,
  1947. ProtocolType.Tcp);
  1948. IPAddress[] ips = new IPAddress[4];
  1949. ips[0] = IPAddress.Parse ("127.0.0.4");
  1950. ips[1] = IPAddress.Parse ("127.0.0.3");
  1951. ips[2] = IPAddress.Parse ("127.0.0.2");
  1952. ips[3] = IPAddress.Parse ("127.0.0.1");
  1953. sock.Close ();
  1954. sock.Connect (ips, 1252);
  1955. }
  1956. [Test]
  1957. public void ConnectHostPortNull ()
  1958. {
  1959. Socket sock = new Socket (AddressFamily.InterNetwork,
  1960. SocketType.Stream,
  1961. ProtocolType.Tcp);
  1962. try {
  1963. sock.Connect ((string)null, 0);
  1964. Assert.Fail ("ConnectHostPort #1");
  1965. } catch (ArgumentNullException) {
  1966. } catch {
  1967. Assert.Fail ("ConnectHostPort #2");
  1968. } finally {
  1969. sock.Close ();
  1970. }
  1971. }
  1972. [Test]
  1973. public void ConnectHostPortListen ()
  1974. {
  1975. Socket sock = new Socket (AddressFamily.InterNetwork,
  1976. SocketType.Stream,
  1977. ProtocolType.Tcp);
  1978. IPAddress ip = IPAddress.Loopback;
  1979. IPEndPoint ep = new IPEndPoint (ip, 1253);
  1980. sock.Bind (ep);
  1981. sock.Listen (1);
  1982. try {
  1983. sock.Connect ("localhost", 1253);
  1984. Assert.Fail ("ConnectHostPortListen #1");
  1985. } catch (InvalidOperationException) {
  1986. } catch {
  1987. Assert.Fail ("ConnectHostPortListen #2");
  1988. } finally {
  1989. sock.Close ();
  1990. }
  1991. }
  1992. [Test]
  1993. [Category ("NotWorking")] // Need to pick a non-IP AddressFamily that "works" on both mono and ms, this one only works on ms
  1994. public void ConnectHostPortNotIP ()
  1995. {
  1996. Socket sock = new Socket (AddressFamily.NetBios,
  1997. SocketType.Seqpacket,
  1998. ProtocolType.Unspecified);
  1999. try {
  2000. sock.Connect ("localhost", 0);
  2001. Assert.Fail ("ConnectHostPortNotIP #1");
  2002. } catch (NotSupportedException) {
  2003. } catch {
  2004. Assert.Fail ("ConnectHostPortNotIP #2");
  2005. } finally {
  2006. sock.Close ();
  2007. }
  2008. }
  2009. [Test]
  2010. [ExpectedException (typeof(ObjectDisposedException))]
  2011. public void ConnectHostPortClosed ()
  2012. {
  2013. Socket sock = new Socket (AddressFamily.InterNetwork,
  2014. SocketType.Stream,
  2015. ProtocolType.Tcp);
  2016. sock.Close ();
  2017. sock.Connect ("localhost", 0);
  2018. }
  2019. [Test]
  2020. [Category ("NotDotNet")] // "Needs XP or later"
  2021. public void Disconnect ()
  2022. {
  2023. Socket sock = new Socket (AddressFamily.InterNetwork,
  2024. SocketType.Stream,
  2025. ProtocolType.Tcp);
  2026. Socket listen = new Socket (AddressFamily.InterNetwork,
  2027. SocketType.Stream,
  2028. ProtocolType.Tcp);
  2029. IPAddress ip = IPAddress.Loopback;
  2030. IPEndPoint ep = new IPEndPoint (ip, 1255);
  2031. listen.Bind (ep);
  2032. listen.Listen (1);
  2033. sock.Connect (ip, 1255);
  2034. Assert.AreEqual (true, sock.Connected, "Disconnect #1");
  2035. sock.Shutdown (SocketShutdown.Both);
  2036. sock.Disconnect (false);
  2037. Assert.AreEqual (false, sock.Connected, "BeginDisconnect #3");
  2038. sock.Close ();
  2039. listen.Close ();
  2040. }
  2041. [Test]
  2042. public void DuplicateAndClose ()
  2043. {
  2044. }
  2045. [Test]
  2046. public void IOControl ()
  2047. {
  2048. }
  2049. [Test]
  2050. public void TestDefaultsDualMode ()
  2051. {
  2052. using (var socket = new Socket (AddressFamily.InterNetworkV6, SocketType.Stream, ProtocolType.Tcp)){
  2053. Assert.IsTrue (socket.DualMode, "In Mono, DualMode must be true when constructing InterNetworkV6 sockets");
  2054. }
  2055. using (var socket = new Socket (SocketType.Stream, ProtocolType.Tcp)){
  2056. Assert.AreEqual (AddressFamily.InterNetworkV6, socket.AddressFamily, "When creating sockets of type stream/tcp, the address family should be InterNetworkV6");
  2057. Assert.IsTrue (socket.DualMode, "In Mono, DualMode must be true when constructing InterNetworkV6 sockets");
  2058. socket.DualMode = false;
  2059. Assert.IsFalse (socket.DualMode, "Setting of DualSocket should turn DualSockets off");
  2060. }
  2061. }
  2062. [Test]
  2063. public void ReceiveGeneric ()
  2064. {
  2065. int i;
  2066. IPEndPoint endpoint = new IPEndPoint(IPAddress.Loopback, 1258);
  2067. Socket listensock = new Socket (AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
  2068. listensock.Bind (endpoint);
  2069. listensock.Listen(1);
  2070. Socket sendsock = new Socket (AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
  2071. sendsock.Connect(endpoint);
  2072. Socket clientsock = listensock.Accept();
  2073. byte[] sendbuf = new byte[256];
  2074. for(i = 0; i < 256; i++) {
  2075. sendbuf[i] = (byte)i;
  2076. }
  2077. for (i = 4; i < 6; i++) {
  2078. Assert.AreEqual (sendbuf[i], (byte)i,
  2079. "#1/" + i.ToString());
  2080. }
  2081. SocketError err;
  2082. sendsock.Send (sendbuf, 0, 256, SocketFlags.None,
  2083. out err);
  2084. byte[] recvbuf = new byte[256];
  2085. List<ArraySegment<byte>> recvbuflist = new List<ArraySegment<byte>>(2);
  2086. recvbuflist.Add(new ArraySegment<byte>(recvbuf, 4, 2));
  2087. recvbuflist.Add(new ArraySegment<byte>(recvbuf, 20, 230));
  2088. clientsock.Receive (recvbuflist);
  2089. /* recvbuf should now hold the first 2 bytes
  2090. * of sendbuf from pos 4, and the next 230
  2091. * bytes of sendbuf from pos 20
  2092. */
  2093. for (i = 0; i < 2; i++) {
  2094. Assert.AreEqual (sendbuf[i], recvbuf[i + 4],
  2095. "#2/" + i.ToString());
  2096. }
  2097. for (i = 2; i < 232; i++) {
  2098. Assert.AreEqual (sendbuf[i], recvbuf[i + 18],
  2099. "#2/" + i.ToString());
  2100. }
  2101. sendsock.Close ();
  2102. clientsock.Close ();
  2103. listensock.Close ();
  2104. }
  2105. [Test]
  2106. public void SendGeneric ()
  2107. {
  2108. int i;
  2109. IPEndPoint endpoint = new IPEndPoint(IPAddress.Loopback, 1259);
  2110. Socket listensock = new Socket (AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
  2111. listensock.Bind (endpoint);
  2112. listensock.Listen(1);
  2113. Socket sendsock = new Socket (AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
  2114. sendsock.Connect(endpoint);
  2115. Socket clientsock = listensock.Accept();
  2116. byte[] sendbuf = new byte[256];
  2117. List<ArraySegment<byte>> sendbuflist = new List<ArraySegment<byte>>(2);
  2118. sendbuflist.Add(new ArraySegment<byte>(sendbuf, 4, 2));
  2119. sendbuflist.Add(new ArraySegment<byte>(sendbuf, 20, 230));
  2120. for(i = 0; i < 256; i++) {
  2121. sendbuf[i] = (byte)i;
  2122. }
  2123. for (i = 4; i < 6; i++) {
  2124. Assert.AreEqual (sendbuf[i], (byte)i,
  2125. "#1/" + i.ToString());
  2126. }
  2127. SocketError err;
  2128. sendsock.Send (sendbuflist, SocketFlags.None, out err);
  2129. byte[] recvbuf = new byte[256];
  2130. clientsock.Receive (recvbuf);
  2131. /* The first 2 bytes of recvbuf should now
  2132. * hold 2 bytes of sendbuf from pos 4, and the
  2133. * next 230 bytes of recvbuf should be sendbuf
  2134. * from pos 20
  2135. */
  2136. for (i = 0; i < 2; i++) {
  2137. Assert.AreEqual (recvbuf[i], sendbuf[i + 4],
  2138. "#2/" + i.ToString());
  2139. }
  2140. for (i = 2; i < 232; i++) {
  2141. Assert.AreEqual (recvbuf[i], sendbuf[i + 18],
  2142. "#2/" + i.ToString());
  2143. }
  2144. sendsock.Close ();
  2145. clientsock.Close ();
  2146. listensock.Close ();
  2147. }
  2148. [Test]
  2149. public void ListenNotBound ()
  2150. {
  2151. Socket sock = new Socket (AddressFamily.InterNetwork,
  2152. SocketType.Stream,
  2153. ProtocolType.Tcp);
  2154. try {
  2155. sock.Listen (1);
  2156. Assert.Fail ("ListenNotBound #1");
  2157. } catch (SocketException ex) {
  2158. Assert.AreEqual (10022, ex.ErrorCode, "ListenNotBound #2");
  2159. } catch {
  2160. Assert.Fail ("ListenNotBound #3");
  2161. } finally {
  2162. sock.Close ();
  2163. }
  2164. }
  2165. static Socket CWRSocket;
  2166. static bool CWRReceiving = true;
  2167. static ManualResetEvent CWRReady = new ManualResetEvent (false);
  2168. private static void CWRReceiveThread ()
  2169. {
  2170. byte[] buf = new byte[256];
  2171. try {
  2172. CWRSocket.Receive (buf);
  2173. } catch (SocketException) {
  2174. CWRReceiving = false;
  2175. }
  2176. CWRReady.Set ();
  2177. }
  2178. [Test]
  2179. public void CloseWhileReceiving ()
  2180. {
  2181. CWRSocket = new Socket (AddressFamily.InterNetwork,
  2182. SocketType.Dgram,
  2183. ProtocolType.Udp);
  2184. CWRSocket.Bind (new IPEndPoint (IPAddress.Loopback,
  2185. 1256));
  2186. Thread recv_thread = new Thread (new ThreadStart (CWRReceiveThread));
  2187. CWRReady.Reset ();
  2188. recv_thread.Start ();
  2189. Thread.Sleep (250); /* Wait for the thread to be already receiving */
  2190. CWRSocket.Close ();
  2191. if (CWRReady.WaitOne (1000, false) == false) {
  2192. Assert.Fail ("CloseWhileReceiving wait timed out");
  2193. }
  2194. Assert.IsFalse (CWRReceiving);
  2195. }
  2196. static bool RRCLastRead = false;
  2197. static ManualResetEvent RRCReady = new ManualResetEvent (false);
  2198. private static void RRCClientThread ()
  2199. {
  2200. byte[] bytes = new byte[8];
  2201. int readbyte;
  2202. Socket sock = new Socket (AddressFamily.InterNetwork,
  2203. SocketType.Stream,
  2204. ProtocolType.Tcp);
  2205. sock.Connect (new IPEndPoint (IPAddress.Loopback,
  2206. 1257));
  2207. NetworkStream stream = new NetworkStream (sock);
  2208. readbyte = stream.ReadByte ();
  2209. Assert.AreEqual (0, readbyte, "ReceiveRemoteClosed #1");
  2210. stream.Read (bytes, 0, 0);
  2211. readbyte = stream.ReadByte ();
  2212. Assert.AreEqual (0, readbyte, "ReceiveRemoteClosed #2");
  2213. stream.Read (bytes, 0, 0);
  2214. readbyte = stream.ReadByte ();
  2215. Assert.AreEqual (-1, readbyte, "ReceiveRemoteClosed #3");
  2216. sock.Close ();
  2217. RRCLastRead = true;
  2218. RRCReady.Set ();
  2219. }
  2220. [Test] // Receive (Byte [])
  2221. public void Receive1_Buffer_Null ()
  2222. {
  2223. Socket s = new Socket (AddressFamily.InterNetwork, SocketType.Stream,
  2224. ProtocolType.Tcp);
  2225. try {
  2226. s.Receive ((byte []) null);
  2227. Assert.Fail ("#1");
  2228. } catch (ArgumentNullException ex) {
  2229. Assert.AreEqual (typeof (ArgumentNullException), ex.GetType (), "#2");
  2230. Assert.IsNull (ex.InnerException, "#3");
  2231. Assert.IsNotNull (ex.Message, "#4");
  2232. Assert.AreEqual ("buffer", ex.ParamName, "#5");
  2233. } finally {
  2234. s.Close ();
  2235. }
  2236. }
  2237. [Test] // Receive (Byte [])
  2238. public void Receive1_Socket_Closed ()
  2239. {
  2240. Socket s = new Socket (AddressFamily.InterNetwork, SocketType.Stream,
  2241. ProtocolType.Tcp);
  2242. s.Close ();
  2243. try {
  2244. s.Receive ((byte []) null);
  2245. Assert.Fail ("#1");
  2246. } catch (ObjectDisposedException ex) {
  2247. // Cannot access a disposed object
  2248. Assert.AreEqual (typeof (ObjectDisposedException), ex.GetType (), "#2");
  2249. Assert.IsNull (ex.InnerException, "#3");
  2250. Assert.IsNotNull (ex.Message, "#4");
  2251. Assert.AreEqual (typeof (Socket).FullName, ex.ObjectName, "#5");
  2252. }
  2253. }
  2254. [Test] // Receive (Byte [], SocketFlags)
  2255. public void Receive2_Buffer_Null ()
  2256. {
  2257. Socket s = new Socket (AddressFamily.InterNetwork, SocketType.Stream,
  2258. ProtocolType.Tcp);
  2259. try {
  2260. s.Receive ((byte []) null, (SocketFlags) 666);
  2261. Assert.Fail ("#1");
  2262. } catch (ArgumentNullException ex) {
  2263. Assert.AreEqual (typeof (ArgumentNullException), ex.GetType (), "#2");
  2264. Assert.IsNull (ex.InnerException, "#3");
  2265. Assert.IsNotNull (ex.Message, "#4");
  2266. Assert.AreEqual ("buffer", ex.ParamName, "#5");
  2267. } finally {
  2268. s.Close ();
  2269. }
  2270. }
  2271. [Test] // Receive (Byte [], SocketFlags)
  2272. public void Receive2_Socket_Closed ()
  2273. {
  2274. Socket s = new Socket (AddressFamily.InterNetwork, SocketType.Stream,
  2275. ProtocolType.Tcp);
  2276. s.Close ();
  2277. try {
  2278. s.Receive ((byte []) null, (SocketFlags) 666);
  2279. Assert.Fail ("#1");
  2280. } catch (ObjectDisposedException ex) {
  2281. // Cannot access a disposed object
  2282. Assert.AreEqual (typeof (ObjectDisposedException), ex.GetType (), "#2");
  2283. Assert.IsNull (ex.InnerException, "#3");
  2284. Assert.IsNotNull (ex.Message, "#4");
  2285. Assert.AreEqual (typeof (Socket).FullName, ex.ObjectName, "#5");
  2286. }
  2287. }
  2288. [Test] // Receive (Byte [], Int32, SocketFlags)
  2289. public void Receive3_Buffer_Null ()
  2290. {
  2291. Socket s = new Socket (AddressFamily.InterNetwork, SocketType.Stream,
  2292. ProtocolType.Tcp);
  2293. try {
  2294. s.Receive ((byte []) null, 0, (SocketFlags) 666);
  2295. Assert.Fail ("#1");
  2296. } catch (ArgumentNullException ex) {
  2297. Assert.AreEqual (typeof (ArgumentNullException), ex.GetType (), "#2");
  2298. Assert.IsNull (ex.InnerException, "#3");
  2299. Assert.IsNotNull (ex.Message, "#4");
  2300. Assert.AreEqual ("buffer", ex.ParamName, "#5");
  2301. } finally {
  2302. s.Close ();
  2303. }
  2304. }
  2305. [Test] // Receive (Byte [], Int32, SocketFlags)
  2306. public void Receive3_Socket_Closed ()
  2307. {
  2308. Socket s = new Socket (AddressFamily.InterNetwork, SocketType.Stream,
  2309. ProtocolType.Tcp);
  2310. s.Close ();
  2311. try {
  2312. s.Receive ((byte []) null, 0, (SocketFlags) 666);
  2313. Assert.Fail ("#1");
  2314. } catch (ObjectDisposedException ex) {
  2315. // Cannot access a disposed object
  2316. Assert.AreEqual (typeof (ObjectDisposedException), ex.GetType (), "#2");
  2317. Assert.IsNull (ex.InnerException, "#3");
  2318. Assert.IsNotNull (ex.Message, "#4");
  2319. Assert.AreEqual (typeof (Socket).FullName, ex.ObjectName, "#5");
  2320. }
  2321. }
  2322. [Test] // Receive (Byte [], Int32, Int32, SocketFlags)
  2323. public void Receive4_Buffer_Null ()
  2324. {
  2325. Socket s = new Socket (AddressFamily.InterNetwork, SocketType.Stream,
  2326. ProtocolType.Tcp);
  2327. try {
  2328. s.Receive ((byte []) null, 0, 0, (SocketFlags) 666);
  2329. Assert.Fail ("#1");
  2330. } catch (ArgumentNullException ex) {
  2331. Assert.AreEqual (typeof (ArgumentNullException), ex.GetType (), "#2");
  2332. Assert.IsNull (ex.InnerException, "#3");
  2333. Assert.IsNotNull (ex.Message, "#4");
  2334. Assert.AreEqual ("buffer", ex.ParamName, "#5");
  2335. } finally {
  2336. s.Close ();
  2337. }
  2338. }
  2339. [Test] // Receive (Byte [], Int32, Int32, SocketFlags)
  2340. public void Receive4_Socket_Closed ()
  2341. {
  2342. Socket s = new Socket (AddressFamily.InterNetwork, SocketType.Stream,
  2343. ProtocolType.Tcp);
  2344. s.Close ();
  2345. try {
  2346. s.Receive ((byte []) null, 0, 0, (SocketFlags) 666);
  2347. Assert.Fail ("#1");
  2348. } catch (ObjectDisposedException ex) {
  2349. // Cannot access a disposed object
  2350. Assert.AreEqual (typeof (ObjectDisposedException), ex.GetType (), "#2");
  2351. Assert.IsNull (ex.InnerException, "#3");
  2352. Assert.IsNotNull (ex.Message, "#4");
  2353. Assert.AreEqual (typeof (Socket).FullName, ex.ObjectName, "#5");
  2354. }
  2355. }
  2356. [Test] // Receive (Byte [], Int32, Int32, SocketFlags, out SocketError)
  2357. public void Receive5_Buffer_Null ()
  2358. {
  2359. Socket s = new Socket (AddressFamily.InterNetwork, SocketType.Stream,
  2360. ProtocolType.Tcp);
  2361. SocketError error;
  2362. try {
  2363. s.Receive ((byte []) null, 0, 0, SocketFlags.None, out error);
  2364. Assert.Fail ("#1");
  2365. } catch (ArgumentNullException ex) {
  2366. Assert.AreEqual (typeof (ArgumentNullException), ex.GetType (), "#2");
  2367. Assert.IsNull (ex.InnerException, "#3");
  2368. Assert.IsNotNull (ex.Message, "#4");
  2369. Assert.AreEqual ("buffer", ex.ParamName, "#5");
  2370. } finally {
  2371. s.Close ();
  2372. }
  2373. }
  2374. [Test] // Receive (Byte [], Int32, Int32, SocketFlags, out SocketError)
  2375. public void Receive5_Socket_Closed ()
  2376. {
  2377. Socket s = new Socket (AddressFamily.InterNetwork, SocketType.Stream,
  2378. ProtocolType.Tcp);
  2379. s.Close ();
  2380. SocketError error;
  2381. try {
  2382. s.Receive ((byte []) null, 0, 0, SocketFlags.None, out error);
  2383. Assert.Fail ("#1");
  2384. } catch (ObjectDisposedException ex) {
  2385. // Cannot access a disposed object
  2386. Assert.AreEqual (typeof (ObjectDisposedException), ex.GetType (), "#2");
  2387. Assert.IsNull (ex.InnerException, "#3");
  2388. Assert.IsNotNull (ex.Message, "#4");
  2389. Assert.AreEqual (typeof (Socket).FullName, ex.ObjectName, "#5");
  2390. }
  2391. }
  2392. [Test] // Receive (IList<ArraySegment<Byte>>)
  2393. public void Receive6_Buffers_Null ()
  2394. {
  2395. Socket s = new Socket (AddressFamily.InterNetwork, SocketType.Stream,
  2396. ProtocolType.Tcp);
  2397. try {
  2398. s.Receive ((IList<ArraySegment<byte>>) null);
  2399. Assert.Fail ("#1");
  2400. } catch (ArgumentNullException ex) {
  2401. Assert.AreEqual (typeof (ArgumentNullException), ex.GetType (), "#2");
  2402. Assert.IsNull (ex.InnerException, "#3");
  2403. Assert.IsNotNull (ex.Message, "#4");
  2404. Assert.AreEqual ("buffers", ex.ParamName, "#5");
  2405. } finally {
  2406. s.Close ();
  2407. }
  2408. }
  2409. [Test] // Receive (IList<ArraySegment<Byte>>)
  2410. public void Receive6_Socket_Closed ()
  2411. {
  2412. Socket s = new Socket (AddressFamily.InterNetwork, SocketType.Stream,
  2413. ProtocolType.Tcp);
  2414. s.Close ();
  2415. try {
  2416. s.Receive ((IList<ArraySegment<byte>>) null);
  2417. Assert.Fail ("#1");
  2418. } catch (ObjectDisposedException ex) {
  2419. // Cannot access a disposed object
  2420. Assert.AreEqual (typeof (ObjectDisposedException), ex.GetType (), "#2");
  2421. Assert.IsNull (ex.InnerException, "#3");
  2422. Assert.IsNotNull (ex.Message, "#4");
  2423. Assert.AreEqual (typeof (Socket).FullName, ex.ObjectName, "#5");
  2424. }
  2425. }
  2426. [Test] // Receive (IList<ArraySegment<Byte>>, SocketFlags)
  2427. public void Receive7_Buffers_Null ()
  2428. {
  2429. Socket s = new Socket (AddressFamily.InterNetwork, SocketType.Stream,
  2430. ProtocolType.Tcp);
  2431. try {
  2432. s.Receive ((IList<ArraySegment<byte>>) null, (SocketFlags) 666);
  2433. Assert.Fail ("#1");
  2434. } catch (ArgumentNullException ex) {
  2435. Assert.AreEqual (typeof (ArgumentNullException), ex.GetType (), "#2");
  2436. Assert.IsNull (ex.InnerException, "#3");
  2437. Assert.IsNotNull (ex.Message, "#4");
  2438. Assert.AreEqual ("buffers", ex.ParamName, "#5");
  2439. } finally {
  2440. s.Close ();
  2441. }
  2442. }
  2443. [Test] // Receive (IList<ArraySegment<Byte>>, SocketFlags)
  2444. public void Receive7_Socket_Closed ()
  2445. {
  2446. Socket s = new Socket (AddressFamily.InterNetwork, SocketType.Stream,
  2447. ProtocolType.Tcp);
  2448. s.Close ();
  2449. try {
  2450. s.Receive ((IList<ArraySegment<byte>>) null, (SocketFlags) 666);
  2451. Assert.Fail ("#1");
  2452. } catch (ObjectDisposedException ex) {
  2453. // Cannot access a disposed object
  2454. Assert.AreEqual (typeof (ObjectDisposedException), ex.GetType (), "#2");
  2455. Assert.IsNull (ex.InnerException, "#3");
  2456. Assert.IsNotNull (ex.Message, "#4");
  2457. Assert.AreEqual (typeof (Socket).FullName, ex.ObjectName, "#5");
  2458. }
  2459. }
  2460. [Test] // Receive (IList<ArraySegment<Byte>>, SocketFlags, out SocketError)
  2461. public void Receive8_Buffers_Null ()
  2462. {
  2463. Socket s = new Socket (AddressFamily.InterNetwork, SocketType.Stream,
  2464. ProtocolType.Tcp);
  2465. SocketError error;
  2466. try {
  2467. s.Receive ((IList<ArraySegment<byte>>) null, (SocketFlags) 666,
  2468. out error);
  2469. Assert.Fail ("#1");
  2470. } catch (ArgumentNullException ex) {
  2471. Assert.AreEqual (typeof (ArgumentNullException), ex.GetType (), "#2");
  2472. Assert.IsNull (ex.InnerException, "#3");
  2473. Assert.IsNotNull (ex.Message, "#4");
  2474. Assert.AreEqual ("buffers", ex.ParamName, "#5");
  2475. } finally {
  2476. s.Close ();
  2477. }
  2478. }
  2479. [Test] // Receive (IList<ArraySegment<Byte>>, SocketFlags, out SocketError)
  2480. public void Receive8_Socket_Closed ()
  2481. {
  2482. Socket s = new Socket (AddressFamily.InterNetwork, SocketType.Stream,
  2483. ProtocolType.Tcp);
  2484. s.Close ();
  2485. SocketError error;
  2486. try {
  2487. s.Receive ((IList<ArraySegment<byte>>) null, (SocketFlags) 666,
  2488. out error);
  2489. Assert.Fail ("#1");
  2490. } catch (ObjectDisposedException ex) {
  2491. // Cannot access a disposed object
  2492. Assert.AreEqual (typeof (ObjectDisposedException), ex.GetType (), "#2");
  2493. Assert.IsNull (ex.InnerException, "#3");
  2494. Assert.IsNotNull (ex.Message, "#4");
  2495. Assert.AreEqual (typeof (Socket).FullName, ex.ObjectName, "#5");
  2496. } finally {
  2497. s.Close ();
  2498. }
  2499. }
  2500. [Test] // ReceiveFrom (Byte [], ref EndPoint)
  2501. public void ReceiveFrom1_Buffer_Null ()
  2502. {
  2503. Socket s = new Socket (AddressFamily.InterNetwork, SocketType.Stream,
  2504. ProtocolType.Tcp);
  2505. EndPoint remoteEP = new IPEndPoint (IPAddress.Loopback, 8001);
  2506. try {
  2507. s.ReceiveFrom ((Byte []) null, ref remoteEP);
  2508. Assert.Fail ("#1");
  2509. } catch (ArgumentNullException ex) {
  2510. Assert.AreEqual (typeof (ArgumentNullException), ex.GetType (), "#2");
  2511. Assert.IsNull (ex.InnerException, "#3");
  2512. Assert.IsNotNull (ex.Message, "#4");
  2513. Assert.AreEqual ("buffer", ex.ParamName, "#5");
  2514. } finally {
  2515. s.Close ();
  2516. }
  2517. }
  2518. [Test] // ReceiveFrom (Byte [], ref EndPoint)
  2519. public void ReceiveFrom1_RemoteEP_Null ()
  2520. {
  2521. Socket s = new Socket (AddressFamily.InterNetwork, SocketType.Stream,
  2522. ProtocolType.Tcp);
  2523. byte [] buffer = new byte [0];
  2524. EndPoint remoteEP = null;
  2525. try {
  2526. s.ReceiveFrom (buffer, ref remoteEP);
  2527. Assert.Fail ("#1");
  2528. } catch (ArgumentNullException ex) {
  2529. Assert.AreEqual (typeof (ArgumentNullException), ex.GetType (), "#2");
  2530. Assert.IsNull (ex.InnerException, "#3");
  2531. Assert.IsNotNull (ex.Message, "#4");
  2532. Assert.AreEqual ("remoteEP", ex.ParamName, "#5");
  2533. } finally {
  2534. s.Close ();
  2535. }
  2536. }
  2537. [Test] // ReceiveFrom (Byte [], ref EndPoint)
  2538. public void ReceiveFrom1_Socket_Closed ()
  2539. {
  2540. Socket s = new Socket (AddressFamily.InterNetwork, SocketType.Stream,
  2541. ProtocolType.Tcp);
  2542. s.Close ();
  2543. EndPoint remoteEP = new IPEndPoint (IPAddress.Loopback, 8001);
  2544. try {
  2545. s.ReceiveFrom ((Byte []) null, ref remoteEP);
  2546. Assert.Fail ("#1");
  2547. } catch (ObjectDisposedException ex) {
  2548. // Cannot access a disposed object
  2549. Assert.AreEqual (typeof (ObjectDisposedException), ex.GetType (), "#2");
  2550. Assert.IsNull (ex.InnerException, "#3");
  2551. Assert.IsNotNull (ex.Message, "#4");
  2552. Assert.AreEqual (typeof (Socket).FullName, ex.ObjectName, "#5");
  2553. }
  2554. }
  2555. [Test] // ReceiveFrom (Byte [], SocketFlags, ref EndPoint)
  2556. public void ReceiveFrom2_Buffer_Null ()
  2557. {
  2558. Socket s = new Socket (AddressFamily.InterNetwork, SocketType.Stream,
  2559. ProtocolType.Tcp);
  2560. EndPoint remoteEP = new IPEndPoint (IPAddress.Loopback, 8001);
  2561. try {
  2562. s.ReceiveFrom ((Byte []) null, (SocketFlags) 666, ref remoteEP);
  2563. Assert.Fail ("#1");
  2564. } catch (ArgumentNullException ex) {
  2565. Assert.AreEqual (typeof (ArgumentNullException), ex.GetType (), "#2");
  2566. Assert.IsNull (ex.InnerException, "#3");
  2567. Assert.IsNotNull (ex.Message, "#4");
  2568. Assert.AreEqual ("buffer", ex.ParamName, "#5");
  2569. } finally {
  2570. s.Close ();
  2571. }
  2572. }
  2573. [Test] // ReceiveFrom (Byte [], SocketFlags, ref EndPoint)
  2574. public void ReceiveFrom2_RemoteEP_Null ()
  2575. {
  2576. Socket s = new Socket (AddressFamily.InterNetwork, SocketType.Stream,
  2577. ProtocolType.Tcp);
  2578. byte [] buffer = new byte [5];
  2579. EndPoint remoteEP = null;
  2580. try {
  2581. s.ReceiveFrom (buffer, (SocketFlags) 666, ref remoteEP);
  2582. Assert.Fail ("#1");
  2583. } catch (ArgumentNullException ex) {
  2584. Assert.AreEqual (typeof (ArgumentNullException), ex.GetType (), "#2");
  2585. Assert.IsNull (ex.InnerException, "#3");
  2586. Assert.IsNotNull (ex.Message, "#4");
  2587. Assert.AreEqual ("remoteEP", ex.ParamName, "#5");
  2588. } finally {
  2589. s.Close ();
  2590. }
  2591. }
  2592. [Test] // ReceiveFrom (Byte [], SocketFlags, ref EndPoint)
  2593. public void ReceiveFrom2_Socket_Closed ()
  2594. {
  2595. Socket s = new Socket (AddressFamily.InterNetwork, SocketType.Stream,
  2596. ProtocolType.Tcp);
  2597. s.Close ();
  2598. EndPoint remoteEP = new IPEndPoint (IPAddress.Loopback, 8001);
  2599. try {
  2600. s.ReceiveFrom ((Byte []) null, (SocketFlags) 666, ref remoteEP);
  2601. Assert.Fail ("#1");
  2602. } catch (ObjectDisposedException ex) {
  2603. // Cannot access a disposed object
  2604. Assert.AreEqual (typeof (ObjectDisposedException), ex.GetType (), "#2");
  2605. Assert.IsNull (ex.InnerException, "#3");
  2606. Assert.IsNotNull (ex.Message, "#4");
  2607. Assert.AreEqual (typeof (Socket).FullName, ex.ObjectName, "#5");
  2608. }
  2609. }
  2610. [Test] // ReceiveFrom (Byte [], Int32, SocketFlags, ref EndPoint)
  2611. public void ReceiveFrom3_Buffer_Null ()
  2612. {
  2613. Socket s = new Socket (AddressFamily.InterNetwork, SocketType.Stream,
  2614. ProtocolType.Tcp);
  2615. EndPoint remoteEP = new IPEndPoint (IPAddress.Loopback, 8001);
  2616. try {
  2617. s.ReceiveFrom ((Byte []) null, 0, (SocketFlags) 666,
  2618. ref remoteEP);
  2619. Assert.Fail ("#1");
  2620. } catch (ArgumentNullException ex) {
  2621. Assert.AreEqual (typeof (ArgumentNullException), ex.GetType (), "#2");
  2622. Assert.IsNull (ex.InnerException, "#3");
  2623. Assert.IsNotNull (ex.Message, "#4");
  2624. Assert.AreEqual ("buffer", ex.ParamName, "#5");
  2625. } finally {
  2626. s.Close ();
  2627. }
  2628. }
  2629. [Test] // ReceiveFrom (Byte [], Int32, SocketFlags, ref EndPoint)
  2630. public void ReceiveFrom3_RemoteEP_Null ()
  2631. {
  2632. Socket s = new Socket (AddressFamily.InterNetwork, SocketType.Stream,
  2633. ProtocolType.Tcp);
  2634. byte [] buffer = new byte [5];
  2635. EndPoint remoteEP = null;
  2636. try {
  2637. s.ReceiveFrom (buffer, buffer.Length, (SocketFlags) 666, ref remoteEP);
  2638. Assert.Fail ("#1");
  2639. } catch (ArgumentNullException ex) {
  2640. Assert.AreEqual (typeof (ArgumentNullException), ex.GetType (), "#2");
  2641. Assert.IsNull (ex.InnerException, "#3");
  2642. Assert.IsNotNull (ex.Message, "#4");
  2643. Assert.AreEqual ("remoteEP", ex.ParamName, "#5");
  2644. } finally {
  2645. s.Close ();
  2646. }
  2647. }
  2648. [Test] // ReceiveFrom (Byte [], Int32, SocketFlags, ref EndPoint)
  2649. public void ReceiveFrom3_Size_OutOfRange ()
  2650. {
  2651. Socket s;
  2652. byte [] buffer = new byte [5];
  2653. EndPoint remoteEP = new IPEndPoint (IPAddress.Loopback, 8001);
  2654. // size negative
  2655. s = new Socket (AddressFamily.InterNetwork, SocketType.Stream,
  2656. ProtocolType.Tcp);
  2657. try {
  2658. s.ReceiveFrom (buffer, -1, (SocketFlags) 666, ref remoteEP);
  2659. Assert.Fail ("#A1");
  2660. } catch (ArgumentOutOfRangeException ex) {
  2661. // Specified argument was out of the range of valid values
  2662. Assert.AreEqual (typeof (ArgumentOutOfRangeException), ex.GetType (), "#A2");
  2663. Assert.IsNull (ex.InnerException, "#A3");
  2664. Assert.IsNotNull (ex.Message, "#A4");
  2665. Assert.AreEqual ("size", ex.ParamName, "#A5");
  2666. } finally {
  2667. s.Close ();
  2668. }
  2669. // size > buffer length
  2670. s = new Socket (AddressFamily.InterNetwork, SocketType.Stream,
  2671. ProtocolType.Tcp);
  2672. try {
  2673. s.ReceiveFrom (buffer, (buffer.Length + 1), (SocketFlags) 666,
  2674. ref remoteEP);
  2675. Assert.Fail ("#B1");
  2676. } catch (ArgumentOutOfRangeException ex) {
  2677. // Specified argument was out of the range of valid values
  2678. Assert.AreEqual (typeof (ArgumentOutOfRangeException), ex.GetType (), "#B2");
  2679. Assert.IsNull (ex.InnerException, "#B3");
  2680. Assert.IsNotNull (ex.Message, "#B4");
  2681. Assert.AreEqual ("size", ex.ParamName, "#B5");
  2682. } finally {
  2683. s.Close ();
  2684. }
  2685. }
  2686. [Test] // ReceiveFrom (Byte [], Int32, SocketFlags, ref EndPoint)
  2687. public void ReceiveFrom3_Socket_Closed ()
  2688. {
  2689. Socket s = new Socket (AddressFamily.InterNetwork, SocketType.Stream,
  2690. ProtocolType.Tcp);
  2691. s.Close ();
  2692. EndPoint remoteEP = new IPEndPoint (IPAddress.Loopback, 8001);
  2693. try {
  2694. s.ReceiveFrom ((Byte []) null, -1, (SocketFlags) 666,
  2695. ref remoteEP);
  2696. Assert.Fail ("#1");
  2697. } catch (ObjectDisposedException ex) {
  2698. // Cannot access a disposed object
  2699. Assert.AreEqual (typeof (ObjectDisposedException), ex.GetType (), "#2");
  2700. Assert.IsNull (ex.InnerException, "#3");
  2701. Assert.IsNotNull (ex.Message, "#4");
  2702. Assert.AreEqual (typeof (Socket).FullName, ex.ObjectName, "#5");
  2703. }
  2704. }
  2705. [Test] // ReceiveFrom (Byte [], Int32, Int32, SocketFlags, EndPoint)
  2706. public void ReceiveFrom4_Buffer_Null ()
  2707. {
  2708. Socket s = new Socket (AddressFamily.InterNetwork, SocketType.Stream,
  2709. ProtocolType.Tcp);
  2710. EndPoint remoteEP = new IPEndPoint (IPAddress.Loopback, 8001);
  2711. try {
  2712. s.ReceiveFrom ((Byte []) null, -1, -1, (SocketFlags) 666,
  2713. ref remoteEP);
  2714. Assert.Fail ("#1");
  2715. } catch (ArgumentNullException ex) {
  2716. Assert.AreEqual (typeof (ArgumentNullException), ex.GetType (), "#2");
  2717. Assert.IsNull (ex.InnerException, "#3");
  2718. Assert.IsNotNull (ex.Message, "#4");
  2719. Assert.AreEqual ("buffer", ex.ParamName, "#5");
  2720. }
  2721. }
  2722. [Test] // ReceiveFrom (Byte [], Int32, Int32, SocketFlags, EndPoint)
  2723. public void ReceiveFrom4_Offset_OutOfRange ()
  2724. {
  2725. Socket s;
  2726. byte [] buffer = new byte [5];
  2727. EndPoint remoteEP = new IPEndPoint (IPAddress.Loopback, 8001);
  2728. // offset negative
  2729. s = new Socket (AddressFamily.InterNetwork, SocketType.Stream,
  2730. ProtocolType.Tcp);
  2731. try {
  2732. s.ReceiveFrom (buffer, -1, 0, (SocketFlags) 666,
  2733. ref remoteEP);
  2734. Assert.Fail ("#A1");
  2735. } catch (ArgumentOutOfRangeException ex) {
  2736. // Specified argument was out of the range of valid values
  2737. Assert.AreEqual (typeof (ArgumentOutOfRangeException), ex.GetType (), "#A2");
  2738. Assert.IsNull (ex.InnerException, "#A3");
  2739. Assert.IsNotNull (ex.Message, "#A4");
  2740. Assert.AreEqual ("offset", ex.ParamName, "#A5");
  2741. } finally {
  2742. s.Close ();
  2743. }
  2744. // offset > buffer length
  2745. s = new Socket (AddressFamily.InterNetwork, SocketType.Stream,
  2746. ProtocolType.Tcp);
  2747. try {
  2748. s.ReceiveFrom (buffer, (buffer.Length + 1), 0, (SocketFlags) 666,
  2749. ref remoteEP);
  2750. Assert.Fail ("#B1");
  2751. } catch (ArgumentOutOfRangeException ex) {
  2752. // Specified argument was out of the range of valid values
  2753. Assert.AreEqual (typeof (ArgumentOutOfRangeException), ex.GetType (), "#B2");
  2754. Assert.IsNull (ex.InnerException, "#B3");
  2755. Assert.IsNotNull (ex.Message, "#B4");
  2756. Assert.AreEqual ("offset", ex.ParamName, "#B5");
  2757. } finally {
  2758. s.Close ();
  2759. }
  2760. }
  2761. [Test] // ReceiveFrom (Byte [], Int32, Int32, SocketFlags, ref IPEndPoint)
  2762. public void ReceiveFrom4_RemoteEP_Null ()
  2763. {
  2764. Socket s = new Socket (AddressFamily.InterNetwork, SocketType.Stream,
  2765. ProtocolType.Tcp);
  2766. byte [] buffer = new byte [5];
  2767. EndPoint remoteEP = null;
  2768. try {
  2769. s.ReceiveFrom (buffer, 0, buffer.Length, (SocketFlags) 666, ref remoteEP);
  2770. Assert.Fail ("#1");
  2771. } catch (ArgumentNullException ex) {
  2772. Assert.AreEqual (typeof (ArgumentNullException), ex.GetType (), "#2");
  2773. Assert.IsNull (ex.InnerException, "#3");
  2774. Assert.IsNotNull (ex.Message, "#4");
  2775. Assert.AreEqual ("remoteEP", ex.ParamName, "#5");
  2776. } finally {
  2777. s.Close ();
  2778. }
  2779. }
  2780. [Test] // ReceiveFrom (Byte [], Int32, Int32, SocketFlags, EndPoint)
  2781. public void ReceiveFrom4_Size_OutOfRange ()
  2782. {
  2783. Socket s;
  2784. byte [] buffer = new byte [5];
  2785. EndPoint remoteEP = new IPEndPoint (IPAddress.Loopback, 8001);
  2786. // size negative
  2787. s = new Socket (AddressFamily.InterNetwork, SocketType.Stream,
  2788. ProtocolType.Tcp);
  2789. try {
  2790. s.ReceiveFrom (buffer, 0, -1, (SocketFlags) 666,
  2791. ref remoteEP);
  2792. Assert.Fail ("#A1");
  2793. } catch (ArgumentOutOfRangeException ex) {
  2794. // Specified argument was out of the range of valid values
  2795. Assert.AreEqual (typeof (ArgumentOutOfRangeException), ex.GetType (), "#A2");
  2796. Assert.IsNull (ex.InnerException, "#A3");
  2797. Assert.IsNotNull (ex.Message, "#A4");
  2798. Assert.AreEqual ("size", ex.ParamName, "#A5");
  2799. } finally {
  2800. s.Close ();
  2801. }
  2802. // size > buffer length
  2803. s = new Socket (AddressFamily.InterNetwork, SocketType.Stream,
  2804. ProtocolType.Tcp);
  2805. try {
  2806. s.ReceiveFrom (buffer, 0, (buffer.Length + 1), (SocketFlags) 666,
  2807. ref remoteEP);
  2808. Assert.Fail ("#B1");
  2809. } catch (ArgumentOutOfRangeException ex) {
  2810. // Specified argument was out of the range of valid values
  2811. Assert.AreEqual (typeof (ArgumentOutOfRangeException), ex.GetType (), "#B2");
  2812. Assert.IsNull (ex.InnerException, "#B3");
  2813. Assert.IsNotNull (ex.Message, "#B4");
  2814. Assert.AreEqual ("size", ex.ParamName, "#B5");
  2815. } finally {
  2816. s.Close ();
  2817. }
  2818. // offset + size > buffer length
  2819. s = new Socket (AddressFamily.InterNetwork, SocketType.Stream,
  2820. ProtocolType.Tcp);
  2821. try {
  2822. s.ReceiveFrom (buffer, 2, 4, (SocketFlags) 666, ref remoteEP);
  2823. Assert.Fail ("#C1");
  2824. } catch (ArgumentOutOfRangeException ex) {
  2825. // Specified argument was out of the range of valid values
  2826. Assert.AreEqual (typeof (ArgumentOutOfRangeException), ex.GetType (), "#C2");
  2827. Assert.IsNull (ex.InnerException, "#C3");
  2828. Assert.IsNotNull (ex.Message, "#C4");
  2829. Assert.AreEqual ("size", ex.ParamName, "#C5");
  2830. } finally {
  2831. s.Close ();
  2832. }
  2833. }
  2834. [Test] // ReceiveFrom (Byte [], Int32, Int32, SocketFlags, ref EndPoint)
  2835. public void ReceiveFrom4_Socket_Closed ()
  2836. {
  2837. Socket s = new Socket (AddressFamily.InterNetwork, SocketType.Stream,
  2838. ProtocolType.Tcp);
  2839. s.Close ();
  2840. byte [] buffer = new byte [5];
  2841. EndPoint remoteEP = new IPEndPoint (IPAddress.Loopback, 8001);
  2842. try {
  2843. s.ReceiveFrom (buffer, -1, -1, (SocketFlags) 666,
  2844. ref remoteEP);
  2845. Assert.Fail ("#1");
  2846. } catch (ObjectDisposedException ex) {
  2847. // Cannot access a disposed object
  2848. Assert.AreEqual (typeof (ObjectDisposedException), ex.GetType (), "#2");
  2849. Assert.IsNull (ex.InnerException, "#3");
  2850. Assert.IsNotNull (ex.Message, "#4");
  2851. Assert.AreEqual (typeof (Socket).FullName, ex.ObjectName, "#5");
  2852. }
  2853. }
  2854. [Test]
  2855. public void ReceiveRemoteClosed ()
  2856. {
  2857. Socket sock = new Socket (AddressFamily.InterNetwork,
  2858. SocketType.Stream,
  2859. ProtocolType.Tcp);
  2860. sock.Bind (new IPEndPoint (IPAddress.Loopback, 1257));
  2861. sock.Listen (1);
  2862. RRCReady.Reset ();
  2863. Thread client_thread = new Thread (new ThreadStart (RRCClientThread));
  2864. client_thread.Start ();
  2865. Socket client = sock.Accept ();
  2866. NetworkStream stream = new NetworkStream (client);
  2867. stream.WriteByte (0x00);
  2868. stream.WriteByte (0x00);
  2869. client.Close ();
  2870. sock.Close ();
  2871. RRCReady.WaitOne (1000, false);
  2872. Assert.IsTrue (RRCLastRead);
  2873. }
  2874. //
  2875. // Test case for bug #471580
  2876. [Test]
  2877. public void UdpDoubleBind ()
  2878. {
  2879. Socket s = new Socket (AddressFamily.InterNetwork, SocketType.Dgram, ProtocolType.Udp);
  2880. s.SetSocketOption (SocketOptionLevel.Socket, SocketOptionName.ReuseAddress, 1);
  2881. s.Bind (new IPEndPoint (IPAddress.Any, 12345));
  2882. Socket ss = new Socket (AddressFamily.InterNetwork, SocketType.Dgram, ProtocolType.Udp);
  2883. ss.SetSocketOption (SocketOptionLevel.Socket, SocketOptionName.ReuseAddress, 1);
  2884. ss.Bind (new IPEndPoint (IPAddress.Any, 12345));
  2885. // If we make it this far, we succeeded.
  2886. ss.Close ();
  2887. s.Close ();
  2888. }
  2889. static bool? supportsPortReuse;
  2890. static bool SupportsPortReuse ()
  2891. {
  2892. if (supportsPortReuse.HasValue)
  2893. return supportsPortReuse.Value;
  2894. supportsPortReuse = (bool) typeof (Socket).GetMethod ("SupportsPortReuse",
  2895. BindingFlags.Static | BindingFlags.NonPublic)
  2896. .Invoke (null, new object [] {});
  2897. return supportsPortReuse.Value;
  2898. }
  2899. // Test case for bug #31557
  2900. [Test]
  2901. public void TcpDoubleBind ()
  2902. {
  2903. using (Socket s = new Socket (AddressFamily.InterNetwork,
  2904. SocketType.Stream, ProtocolType.Tcp))
  2905. using (Socket ss = new Socket (AddressFamily.InterNetwork,
  2906. SocketType.Stream, ProtocolType.Tcp)) {
  2907. s.SetSocketOption (SocketOptionLevel.Socket, SocketOptionName.ReuseAddress, true);
  2908. s.Bind (new IPEndPoint (IPAddress.Any, 12345));
  2909. s.Listen(1);
  2910. ss.SetSocketOption (SocketOptionLevel.Socket, SocketOptionName.ReuseAddress, true);
  2911. Exception ex = null;
  2912. try {
  2913. ss.Bind (new IPEndPoint (IPAddress.Any, 12345));
  2914. ss.Listen(1);
  2915. } catch (SocketException e) {
  2916. ex = e;
  2917. }
  2918. Assert.AreEqual (SupportsPortReuse (), ex == null);
  2919. }
  2920. }
  2921. [Test]
  2922. [Category ("NotOnMac")]
  2923. public void ConnectedProperty ()
  2924. {
  2925. TcpListener listener = new TcpListener (IPAddress.Loopback, 23456);
  2926. listener.Start();
  2927. Socket client = new Socket (AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
  2928. client.Connect (IPAddress.Loopback, 23456);
  2929. Socket server = listener.AcceptSocket ();
  2930. try {
  2931. server.EndSend(server.BeginSend (new byte[10], 0, 10, SocketFlags.None, null, null));
  2932. client.Close ();
  2933. try {
  2934. server.EndReceive (server.BeginReceive (new byte[10], 0, 10, SocketFlags.None, null, null));
  2935. } catch {
  2936. }
  2937. Assert.IsTrue (!client.Connected);
  2938. Assert.IsTrue (!server.Connected);
  2939. } finally {
  2940. listener.Stop ();
  2941. client.Close ();
  2942. server.Close ();
  2943. }
  2944. }
  2945. [Test] // GetSocketOption (SocketOptionLevel, SocketOptionName)
  2946. public void GetSocketOption1_Socket_Closed ()
  2947. {
  2948. Socket s = new Socket (AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
  2949. s.Close ();
  2950. try {
  2951. s.GetSocketOption (0, 0);
  2952. Assert.Fail ("#1");
  2953. } catch (ObjectDisposedException ex) {
  2954. // Cannot access a disposed object
  2955. Assert.AreEqual (typeof (ObjectDisposedException), ex.GetType (), "#2");
  2956. Assert.IsNull (ex.InnerException, "#3");
  2957. Assert.IsNotNull (ex.Message, "#4");
  2958. Assert.AreEqual (typeof (Socket).FullName, ex.ObjectName, "#5");
  2959. }
  2960. }
  2961. [Test] // GetSocketOption (SocketOptionLevel, SocketOptionName, Byte [])
  2962. public void GetSocketOption2_OptionValue_Null ()
  2963. {
  2964. Socket s = new Socket (AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
  2965. try {
  2966. s.GetSocketOption (SocketOptionLevel.Socket, SocketOptionName.Linger,
  2967. (byte []) null);
  2968. Assert.Fail ("#1");
  2969. } catch (SocketException ex) {
  2970. // The system detected an invalid pointer address in attempting
  2971. // to use a pointer argument in a call
  2972. Assert.AreEqual (typeof (SocketException), ex.GetType (), "#2");
  2973. Assert.AreEqual (10014, ex.ErrorCode, "#3");
  2974. Assert.IsNull (ex.InnerException, "#4");
  2975. Assert.IsNotNull (ex.Message, "#5");
  2976. Assert.AreEqual (10014, ex.NativeErrorCode, "#6");
  2977. Assert.AreEqual (SocketError.Fault, ex.SocketErrorCode, "#7");
  2978. }
  2979. }
  2980. [Test] // GetSocketOption (SocketOptionLevel, SocketOptionName, Byte [])
  2981. public void GetSocketOption2_Socket_Closed ()
  2982. {
  2983. Socket s = new Socket (AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
  2984. s.Close ();
  2985. try {
  2986. s.GetSocketOption (0, 0, (byte []) null);
  2987. Assert.Fail ("#1");
  2988. } catch (ObjectDisposedException ex) {
  2989. // Cannot access a disposed object
  2990. Assert.AreEqual (typeof (ObjectDisposedException), ex.GetType (), "#2");
  2991. Assert.IsNull (ex.InnerException, "#3");
  2992. Assert.IsNotNull (ex.Message, "#4");
  2993. Assert.AreEqual (typeof (Socket).FullName, ex.ObjectName, "#5");
  2994. }
  2995. }
  2996. [Test] // GetSocketOption (SocketOptionLevel, SocketOptionName, Int32)
  2997. public void GetSocketOption3_Socket_Closed ()
  2998. {
  2999. Socket s = new Socket (AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
  3000. s.Close ();
  3001. try {
  3002. s.GetSocketOption (0, 0, 0);
  3003. Assert.Fail ("#1");
  3004. } catch (ObjectDisposedException ex) {
  3005. // Cannot access a disposed object
  3006. Assert.AreEqual (typeof (ObjectDisposedException), ex.GetType (), "#2");
  3007. Assert.IsNull (ex.InnerException, "#3");
  3008. Assert.IsNotNull (ex.Message, "#4");
  3009. Assert.AreEqual (typeof (Socket).FullName, ex.ObjectName, "#5");
  3010. }
  3011. }
  3012. [Test] // SetSocketOption (SocketOptionLevel, SocketOptionName, Byte [])
  3013. public void SetSocketOption1_DontLinger ()
  3014. {
  3015. using (Socket s = new Socket (AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp)) {
  3016. s.SetSocketOption (SocketOptionLevel.Socket, SocketOptionName.DontLinger,
  3017. new byte [] { 0x00 });
  3018. s.SetSocketOption (SocketOptionLevel.Socket, SocketOptionName.DontLinger,
  3019. new byte [] { 0x01 });
  3020. }
  3021. }
  3022. [Test] // SetSocketOption (SocketOptionLevel, SocketOptionName, Byte [])
  3023. public void SetSocketOption1_DontLinger_Null ()
  3024. {
  3025. using (Socket s = new Socket (AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp)) {
  3026. try {
  3027. s.SetSocketOption (SocketOptionLevel.Socket,
  3028. SocketOptionName.DontLinger, (byte []) null);
  3029. Assert.Fail ("#1");
  3030. } catch (SocketException ex) {
  3031. // The system detected an invalid pointer address in attempting
  3032. // to use a pointer argument in a call
  3033. Assert.AreEqual (typeof (SocketException), ex.GetType (), "#2");
  3034. Assert.AreEqual (10014, ex.ErrorCode, "#3");
  3035. Assert.IsNull (ex.InnerException, "#4");
  3036. Assert.IsNotNull (ex.Message, "#5");
  3037. Assert.AreEqual (10014, ex.NativeErrorCode, "#6");
  3038. Assert.AreEqual (SocketError.Fault, ex.SocketErrorCode, "#7");
  3039. }
  3040. }
  3041. }
  3042. [Test] // SetSocketOption (SocketOptionLevel, SocketOptionName, Byte [])
  3043. public void SetSocketOption1_Linger_Null ()
  3044. {
  3045. using (Socket s = new Socket (AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp)) {
  3046. try {
  3047. s.SetSocketOption (SocketOptionLevel.Socket,
  3048. SocketOptionName.DontLinger, (byte []) null);
  3049. Assert.Fail ("#1");
  3050. } catch (SocketException ex) {
  3051. // The system detected an invalid pointer address in attempting
  3052. // to use a pointer argument in a call
  3053. Assert.AreEqual (typeof (SocketException), ex.GetType (), "#2");
  3054. Assert.AreEqual (10014, ex.ErrorCode, "#3");
  3055. Assert.IsNull (ex.InnerException, "#4");
  3056. Assert.IsNotNull (ex.Message, "#5");
  3057. Assert.AreEqual (10014, ex.NativeErrorCode, "#6");
  3058. Assert.AreEqual (SocketError.Fault, ex.SocketErrorCode, "#7");
  3059. }
  3060. }
  3061. }
  3062. [Test] // SetSocketOption (SocketOptionLevel, SocketOptionName, Byte [])
  3063. public void SetSocketOption1_Socket_Close ()
  3064. {
  3065. Socket s = new Socket (AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
  3066. s.Close ();
  3067. try {
  3068. s.SetSocketOption (SocketOptionLevel.Socket, SocketOptionName.DontLinger,
  3069. new byte [] { 0x00 });
  3070. Assert.Fail ("#1");
  3071. } catch (ObjectDisposedException ex) {
  3072. Assert.AreEqual (typeof (ObjectDisposedException), ex.GetType (), "#2");
  3073. Assert.IsNull (ex.InnerException, "#3");
  3074. Assert.IsNotNull (ex.Message, "#4");
  3075. Assert.AreEqual (typeof (Socket).FullName, ex.ObjectName, "#5");
  3076. }
  3077. }
  3078. [Test] // SetSocketOption (SocketOptionLevel, SocketOptionName, Int32)
  3079. public void SetSocketOption2_DontLinger ()
  3080. {
  3081. using (Socket s = new Socket (AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp)) {
  3082. s.SetSocketOption (SocketOptionLevel.Socket, SocketOptionName.DontLinger, 0);
  3083. s.SetSocketOption (SocketOptionLevel.Socket, SocketOptionName.DontLinger, 5);
  3084. }
  3085. }
  3086. [Test] // SetSocketOption (SocketOptionLevel, SocketOptionName, Int32)
  3087. [Category ("NotWorking")]
  3088. public void SetSocketOption2_Linger ()
  3089. {
  3090. using (Socket s = new Socket (AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp)) {
  3091. s.SetSocketOption (SocketOptionLevel.Socket, SocketOptionName.Linger, 0);
  3092. s.SetSocketOption (SocketOptionLevel.Socket, SocketOptionName.Linger, 5);
  3093. }
  3094. }
  3095. [Test] // SetSocketOption (SocketOptionLevel, SocketOptionName, Int32)
  3096. public void SetSocketOption2_Socket_Closed ()
  3097. {
  3098. Socket s = new Socket (AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
  3099. s.Close ();
  3100. try {
  3101. s.SetSocketOption (SocketOptionLevel.Socket, SocketOptionName.DontLinger, 0);
  3102. Assert.Fail ("#1");
  3103. } catch (ObjectDisposedException ex) {
  3104. // Cannot access a disposed object
  3105. Assert.AreEqual (typeof (ObjectDisposedException), ex.GetType (), "#2");
  3106. Assert.IsNull (ex.InnerException, "#3");
  3107. Assert.IsNotNull (ex.Message, "#4");
  3108. Assert.AreEqual (typeof (Socket).FullName, ex.ObjectName, "#5");
  3109. }
  3110. }
  3111. [Test] // SetSocketOption (SocketOptionLevel, SocketOptionName, Object)
  3112. public void SetSocketOption3_AddMembershipIPv4_IPv6MulticastOption ()
  3113. {
  3114. IPAddress mcast_addr = IPAddress.Parse ("239.255.255.250");
  3115. using (Socket s = new Socket (AddressFamily.InterNetwork, SocketType.Dgram, ProtocolType.Udp)) {
  3116. s.Bind (new IPEndPoint (IPAddress.Any, 1901));
  3117. try {
  3118. s.SetSocketOption (SocketOptionLevel.IP, SocketOptionName.AddMembership,
  3119. new IPv6MulticastOption (mcast_addr));
  3120. Assert.Fail ("#1");
  3121. } catch (ArgumentException ex) {
  3122. Assert.AreEqual (typeof (ArgumentException), ex.GetType (), "#2");
  3123. Assert.IsNull (ex.InnerException, "#3");
  3124. Assert.IsNotNull (ex.Message, "#4");
  3125. // The specified value is not a valid 'MulticastOption'
  3126. Assert.IsTrue (ex.Message.IndexOf ("'MulticastOption'") != -1, "#5:" + ex.Message);
  3127. Assert.AreEqual ("optionValue", ex.ParamName, "#6");
  3128. }
  3129. }
  3130. }
  3131. [Test] // SetSocketOption (SocketOptionLevel, SocketOptionName, Object)
  3132. public void SetSocketOption3_AddMembershipIPv4_MulticastOption ()
  3133. {
  3134. IPAddress mcast_addr = IPAddress.Parse ("239.255.255.250");
  3135. using (Socket s = new Socket (AddressFamily.InterNetwork, SocketType.Dgram, ProtocolType.Udp)) {
  3136. s.Bind (new IPEndPoint (IPAddress.Any, 1901));
  3137. s.SetSocketOption (SocketOptionLevel.IP, SocketOptionName.AddMembership,
  3138. new MulticastOption (mcast_addr));
  3139. }
  3140. }
  3141. [Test] // SetSocketOption (SocketOptionLevel, SocketOptionName, Object)
  3142. [Category ("NotWorking")]
  3143. public void SetSocketOption3_AddMembershipIPv4_Socket_NotBound ()
  3144. {
  3145. IPAddress mcast_addr = IPAddress.Parse ("239.255.255.250");
  3146. Socket s = new Socket (AddressFamily.InterNetwork, SocketType.Dgram, ProtocolType.Udp);
  3147. try {
  3148. s.SetSocketOption (SocketOptionLevel.IP, SocketOptionName.AddMembership,
  3149. new MulticastOption (mcast_addr));
  3150. Assert.Fail ("#1");
  3151. } catch (SocketException ex) {
  3152. // An invalid argument was supplied
  3153. Assert.AreEqual (typeof (SocketException), ex.GetType (), "#2");
  3154. Assert.AreEqual (10022, ex.ErrorCode, "#3");
  3155. Assert.IsNull (ex.InnerException, "#4");
  3156. Assert.IsNotNull (ex.Message, "#5");
  3157. Assert.AreEqual (10022, ex.NativeErrorCode, "#6");
  3158. Assert.AreEqual (SocketError.InvalidArgument, ex.SocketErrorCode, "#7");
  3159. } finally {
  3160. s.Close ();
  3161. }
  3162. }
  3163. [Test] // SetSocketOption (SocketOptionLevel, SocketOptionName, Object)
  3164. public void SetSocketOption3_AddMembershipIPv6_IPv6MulticastOption ()
  3165. {
  3166. if (!Socket.OSSupportsIPv6)
  3167. Assert.Ignore ("IPv6 not enabled.");
  3168. IPAddress mcast_addr = IPAddress.Parse ("ff02::1");
  3169. using (Socket s = new Socket (AddressFamily.InterNetworkV6, SocketType.Dgram, ProtocolType.Udp)) {
  3170. s.Bind (new IPEndPoint (IPAddress.IPv6Any, 1902));
  3171. s.SetSocketOption (SocketOptionLevel.IPv6, SocketOptionName.AddMembership,
  3172. new IPv6MulticastOption (mcast_addr));
  3173. }
  3174. }
  3175. [Test] // SetSocketOption (SocketOptionLevel, SocketOptionName, Object)
  3176. public void SetSocketOption3_AddMembershipIPv6_MulticastOption ()
  3177. {
  3178. if (!Socket.OSSupportsIPv6)
  3179. Assert.Ignore ("IPv6 not enabled.");
  3180. IPAddress mcast_addr = IPAddress.Parse ("ff02::1");
  3181. using (Socket s = new Socket (AddressFamily.InterNetworkV6, SocketType.Dgram, ProtocolType.Udp)) {
  3182. s.Bind (new IPEndPoint (IPAddress.IPv6Any, 1902));
  3183. try {
  3184. s.SetSocketOption (SocketOptionLevel.IPv6, SocketOptionName.AddMembership,
  3185. new MulticastOption (mcast_addr));
  3186. Assert.Fail ("#1");
  3187. } catch (ArgumentException ex) {
  3188. Assert.AreEqual (typeof (ArgumentException), ex.GetType (), "#2");
  3189. Assert.IsNull (ex.InnerException, "#3");
  3190. Assert.IsNotNull (ex.Message, "#4");
  3191. // The specified value is not a valid 'IPv6MulticastOption'
  3192. Assert.IsTrue (ex.Message.IndexOf ("'IPv6MulticastOption'") != -1, "#5:" + ex.Message);
  3193. Assert.AreEqual ("optionValue", ex.ParamName, "#6");
  3194. }
  3195. }
  3196. }
  3197. [Test] // SetSocketOption (SocketOptionLevel, SocketOptionName, Object)
  3198. [Category ("NotWorking")]
  3199. public void SetSocketOption3_AddMembershipIPv6_Socket_NotBound ()
  3200. {
  3201. IPAddress mcast_addr = IPAddress.Parse ("ff02::1");
  3202. Socket s = new Socket (AddressFamily.InterNetworkV6, SocketType.Dgram, ProtocolType.Udp);
  3203. try {
  3204. s.SetSocketOption (SocketOptionLevel.IPv6, SocketOptionName.AddMembership,
  3205. new IPv6MulticastOption (mcast_addr));
  3206. Assert.Fail ("#1");
  3207. } catch (SocketException ex) {
  3208. // An invalid argument was supplied
  3209. Assert.AreEqual (typeof (SocketException), ex.GetType (), "#2");
  3210. Assert.AreEqual (10022, ex.ErrorCode, "#3");
  3211. Assert.IsNull (ex.InnerException, "#4");
  3212. Assert.IsNotNull (ex.Message, "#5");
  3213. Assert.AreEqual (10022, ex.NativeErrorCode, "#6");
  3214. Assert.AreEqual (SocketError.InvalidArgument, ex.SocketErrorCode, "#7");
  3215. } finally {
  3216. s.Close ();
  3217. }
  3218. }
  3219. [Test] // SetSocketOption (SocketOptionLevel, SocketOptionName, Object)
  3220. public void SetSocketOption3_DontLinger_Boolean ()
  3221. {
  3222. using (Socket s = new Socket (AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp)) {
  3223. try {
  3224. s.SetSocketOption (SocketOptionLevel.Socket,
  3225. SocketOptionName.DontLinger, (object) false);
  3226. Assert.Fail ("#1");
  3227. } catch (ArgumentException ex) {
  3228. // The specified value is not valid
  3229. Assert.AreEqual (typeof (ArgumentException), ex.GetType (), "#2");
  3230. Assert.IsNull (ex.InnerException, "#3");
  3231. Assert.IsNotNull (ex.Message, "#4");
  3232. Assert.AreEqual ("optionValue", ex.ParamName, "#5");
  3233. }
  3234. }
  3235. }
  3236. [Test] // SetSocketOption (SocketOptionLevel, SocketOptionName, Object)
  3237. public void SetSocketOption3_DontLinger_Int32 ()
  3238. {
  3239. using (Socket s = new Socket (AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp)) {
  3240. try {
  3241. s.SetSocketOption (SocketOptionLevel.Socket,
  3242. SocketOptionName.DontLinger, (object) 0);
  3243. Assert.Fail ("#1");
  3244. } catch (ArgumentException ex) {
  3245. // The specified value is not valid
  3246. Assert.AreEqual (typeof (ArgumentException), ex.GetType (), "#2");
  3247. Assert.IsNull (ex.InnerException, "#3");
  3248. Assert.IsNotNull (ex.Message, "#4");
  3249. Assert.AreEqual ("optionValue", ex.ParamName, "#5");
  3250. }
  3251. }
  3252. }
  3253. [Test] // SetSocketOption (SocketOptionLevel, SocketOptionName, Object)
  3254. public void SetSocketOption3_DontLinger_LingerOption ()
  3255. {
  3256. using (Socket s = new Socket (AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp)) {
  3257. try {
  3258. s.SetSocketOption (SocketOptionLevel.Socket,
  3259. SocketOptionName.DontLinger, new LingerOption (true, 1000));
  3260. Assert.Fail ("#1");
  3261. } catch (ArgumentException ex) {
  3262. Assert.AreEqual (typeof (ArgumentException), ex.GetType (), "#2");
  3263. Assert.IsNull (ex.InnerException, "#3");
  3264. // The specified value is not valid
  3265. Assert.IsNotNull (ex.Message, "#4");
  3266. Assert.AreEqual ("optionValue", ex.ParamName, "#5");
  3267. }
  3268. }
  3269. }
  3270. [Test] // SetSocketOption (SocketOptionLevel, SocketOptionName, Object)
  3271. public void SetSocketOption3_Linger_Boolean ()
  3272. {
  3273. using (Socket s = new Socket (AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp)) {
  3274. try {
  3275. s.SetSocketOption (SocketOptionLevel.Socket,
  3276. SocketOptionName.Linger, (object) false);
  3277. Assert.Fail ("#1");
  3278. } catch (ArgumentException ex) {
  3279. Assert.AreEqual (typeof (ArgumentException), ex.GetType (), "#2");
  3280. Assert.IsNull (ex.InnerException, "#3");
  3281. // The specified value is not valid
  3282. Assert.IsNotNull (ex.Message, "#4");
  3283. Assert.AreEqual ("optionValue", ex.ParamName, "#5");
  3284. }
  3285. }
  3286. }
  3287. [Test] // SetSocketOption (SocketOptionLevel, SocketOptionName, Object)
  3288. public void SetSocketOption3_Linger_Int32 ()
  3289. {
  3290. using (Socket s = new Socket (AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp)) {
  3291. try {
  3292. s.SetSocketOption (SocketOptionLevel.Socket,
  3293. SocketOptionName.Linger, (object) 0);
  3294. Assert.Fail ("#1");
  3295. } catch (ArgumentException ex) {
  3296. Assert.AreEqual (typeof (ArgumentException), ex.GetType (), "#2");
  3297. Assert.IsNull (ex.InnerException, "#3");
  3298. // The specified value is not valid
  3299. Assert.IsNotNull (ex.Message, "#4");
  3300. Assert.AreEqual ("optionValue", ex.ParamName, "#5");
  3301. }
  3302. }
  3303. }
  3304. [Test] // SetSocketOption (SocketOptionLevel, SocketOptionName, Object)
  3305. public void SetSocketOption3_Linger_LingerOption ()
  3306. {
  3307. using (Socket s = new Socket (AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp)) {
  3308. s.SetSocketOption (SocketOptionLevel.Socket, SocketOptionName.Linger,
  3309. new LingerOption (false, 0));
  3310. s.SetSocketOption (SocketOptionLevel.Socket, SocketOptionName.Linger,
  3311. new LingerOption (true, 0));
  3312. s.SetSocketOption (SocketOptionLevel.Socket, SocketOptionName.Linger,
  3313. new LingerOption (false, 1000));
  3314. s.SetSocketOption (SocketOptionLevel.Socket, SocketOptionName.Linger,
  3315. new LingerOption (true, 1000));
  3316. }
  3317. }
  3318. [Test] // SetSocketOption (SocketOptionLevel, SocketOptionName, Object)
  3319. public void SetSocketOption3_DropMembershipIPv4_IPv6MulticastOption ()
  3320. {
  3321. IPAddress mcast_addr = IPAddress.Parse ("239.255.255.250");
  3322. using (Socket s = new Socket (AddressFamily.InterNetwork, SocketType.Dgram, ProtocolType.Udp)) {
  3323. s.Bind (new IPEndPoint (IPAddress.Any, 1901));
  3324. s.SetSocketOption (SocketOptionLevel.IP, SocketOptionName.AddMembership,
  3325. new MulticastOption (mcast_addr));
  3326. try {
  3327. s.SetSocketOption (SocketOptionLevel.IP, SocketOptionName.DropMembership,
  3328. new IPv6MulticastOption (mcast_addr));
  3329. Assert.Fail ("#1");
  3330. } catch (ArgumentException ex) {
  3331. Assert.AreEqual (typeof (ArgumentException), ex.GetType (), "#2");
  3332. Assert.IsNull (ex.InnerException, "#3");
  3333. Assert.IsNotNull (ex.Message, "#4");
  3334. // The specified value is not a valid 'MulticastOption'
  3335. Assert.IsTrue (ex.Message.IndexOf ("'MulticastOption'") != -1, "#5:" + ex.Message);
  3336. Assert.AreEqual ("optionValue", ex.ParamName, "#6");
  3337. }
  3338. }
  3339. }
  3340. [Test] // SetSocketOption (SocketOptionLevel, SocketOptionName, Object)
  3341. public void SetSocketOption3_DropMembershipIPv4_MulticastOption ()
  3342. {
  3343. IPAddress mcast_addr = IPAddress.Parse ("239.255.255.250");
  3344. using (Socket s = new Socket (AddressFamily.InterNetwork, SocketType.Dgram, ProtocolType.Udp)) {
  3345. MulticastOption option = new MulticastOption (mcast_addr);
  3346. s.Bind (new IPEndPoint (IPAddress.Any, 1901));
  3347. s.SetSocketOption (SocketOptionLevel.IP, SocketOptionName.AddMembership,
  3348. option);
  3349. s.SetSocketOption (SocketOptionLevel.IP, SocketOptionName.DropMembership,
  3350. option);
  3351. }
  3352. }
  3353. [Test] // SetSocketOption (SocketOptionLevel, SocketOptionName, Object)
  3354. [Category ("NotWorking")]
  3355. public void SetSocketOption3_DropMembershipIPv4_Socket_NotBound ()
  3356. {
  3357. IPAddress mcast_addr = IPAddress.Parse ("239.255.255.250");
  3358. Socket s = new Socket (AddressFamily.InterNetwork, SocketType.Dgram, ProtocolType.Udp);
  3359. try {
  3360. s.SetSocketOption (SocketOptionLevel.IP, SocketOptionName.DropMembership,
  3361. new MulticastOption (mcast_addr));
  3362. Assert.Fail ("#1");
  3363. } catch (SocketException ex) {
  3364. // An invalid argument was supplied
  3365. Assert.AreEqual (typeof (SocketException), ex.GetType (), "#2");
  3366. Assert.AreEqual (10022, ex.ErrorCode, "#3");
  3367. Assert.IsNull (ex.InnerException, "#4");
  3368. Assert.IsNotNull (ex.Message, "#5");
  3369. Assert.AreEqual (10022, ex.NativeErrorCode, "#6");
  3370. Assert.AreEqual (SocketError.InvalidArgument, ex.SocketErrorCode, "#7");
  3371. } finally {
  3372. s.Close ();
  3373. }
  3374. }
  3375. [Test] // SetSocketOption (SocketOptionLevel, SocketOptionName, Object)
  3376. public void SetSocketOption3_DropMembershipIPv6_IPv6MulticastOption ()
  3377. {
  3378. if (!Socket.OSSupportsIPv6)
  3379. Assert.Ignore ("IPv6 not enabled.");
  3380. using (Socket s = new Socket (AddressFamily.InterNetworkV6, SocketType.Dgram, ProtocolType.Udp)) {
  3381. IPv6MulticastOption option = new IPv6MulticastOption (
  3382. IPAddress.Parse ("ff02::1"));
  3383. s.Bind (new IPEndPoint (IPAddress.IPv6Any, 1902));
  3384. s.SetSocketOption (SocketOptionLevel.IPv6, SocketOptionName.AddMembership,
  3385. option);
  3386. s.SetSocketOption (SocketOptionLevel.IPv6, SocketOptionName.DropMembership,
  3387. option);
  3388. }
  3389. }
  3390. [Test] // SetSocketOption (SocketOptionLevel, SocketOptionName, Object)
  3391. public void SetSocketOption3_DropMembershipIPv6_MulticastOption ()
  3392. {
  3393. if (!Socket.OSSupportsIPv6)
  3394. Assert.Ignore ("IPv6 not enabled.");
  3395. IPAddress mcast_addr = IPAddress.Parse ("ff02::1");
  3396. using (Socket s = new Socket (AddressFamily.InterNetworkV6, SocketType.Dgram, ProtocolType.Udp)) {
  3397. s.Bind (new IPEndPoint (IPAddress.IPv6Any, 1902));
  3398. s.SetSocketOption (SocketOptionLevel.IPv6, SocketOptionName.AddMembership,
  3399. new IPv6MulticastOption (mcast_addr));
  3400. try {
  3401. s.SetSocketOption (SocketOptionLevel.IPv6, SocketOptionName.DropMembership,
  3402. new MulticastOption (mcast_addr));
  3403. Assert.Fail ("#1");
  3404. } catch (ArgumentException ex) {
  3405. Assert.AreEqual (typeof (ArgumentException), ex.GetType (), "#2");
  3406. Assert.IsNull (ex.InnerException, "#3");
  3407. Assert.IsNotNull (ex.Message, "#4");
  3408. // The specified value is not a valid 'IPv6MulticastOption'
  3409. Assert.IsTrue (ex.Message.IndexOf ("'IPv6MulticastOption'") != -1, "#5:" + ex.Message);
  3410. Assert.AreEqual ("optionValue", ex.ParamName, "#6");
  3411. }
  3412. }
  3413. }
  3414. [Test] // SetSocketOption (SocketOptionLevel, SocketOptionName, Object)
  3415. [Category ("NotWorking")]
  3416. public void SetSocketOption3_DropMembershipIPv6_Socket_NotBound ()
  3417. {
  3418. IPAddress mcast_addr = IPAddress.Parse ("ff02::1");
  3419. Socket s = new Socket (AddressFamily.InterNetworkV6, SocketType.Dgram, ProtocolType.Udp);
  3420. try {
  3421. s.SetSocketOption (SocketOptionLevel.IPv6, SocketOptionName.DropMembership,
  3422. new IPv6MulticastOption (mcast_addr));
  3423. Assert.Fail ("#1");
  3424. } catch (SocketException ex) {
  3425. // An invalid argument was supplied
  3426. Assert.AreEqual (typeof (SocketException), ex.GetType (), "#2");
  3427. Assert.AreEqual (10022, ex.ErrorCode, "#3");
  3428. Assert.IsNull (ex.InnerException, "#4");
  3429. Assert.IsNotNull (ex.Message, "#5");
  3430. Assert.AreEqual (10022, ex.NativeErrorCode, "#6");
  3431. Assert.AreEqual (SocketError.InvalidArgument, ex.SocketErrorCode, "#7");
  3432. } finally {
  3433. s.Close ();
  3434. }
  3435. }
  3436. [Test] // SetSocketOption (SocketOptionLevel, SocketOptionName, Object)
  3437. public void SetSocketOption3_OptionValue_Null ()
  3438. {
  3439. using (Socket s = new Socket (AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp)) {
  3440. try {
  3441. s.SetSocketOption (SocketOptionLevel.Socket,
  3442. SocketOptionName.Linger, (object) null);
  3443. Assert.Fail ("#1");
  3444. } catch (ArgumentNullException ex) {
  3445. Assert.AreEqual (typeof (ArgumentNullException), ex.GetType (), "#2");
  3446. Assert.IsNull (ex.InnerException, "#3");
  3447. Assert.IsNotNull (ex.Message, "#4");
  3448. Assert.AreEqual ("optionValue", ex.ParamName, "#5");
  3449. }
  3450. }
  3451. }
  3452. [Test] // SetSocketOption (SocketOptionLevel, SocketOptionName, Object)
  3453. public void SetSocketOption3_Socket_Closed ()
  3454. {
  3455. Socket s = new Socket (AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
  3456. s.Close ();
  3457. try {
  3458. s.SetSocketOption (SocketOptionLevel.Socket, SocketOptionName.Linger,
  3459. new LingerOption (false, 0));
  3460. Assert.Fail ("#1");
  3461. } catch (ObjectDisposedException ex) {
  3462. // Cannot access a disposed object
  3463. Assert.AreEqual (typeof (ObjectDisposedException), ex.GetType (), "#2");
  3464. Assert.IsNull (ex.InnerException, "#3");
  3465. Assert.IsNotNull (ex.Message, "#4");
  3466. Assert.AreEqual (typeof (Socket).FullName, ex.ObjectName, "#5");
  3467. }
  3468. }
  3469. [Test]
  3470. public void SetSocketOption_MulticastInterfaceIndex_Any ()
  3471. {
  3472. IPAddress ip = IPAddress.Parse ("239.255.255.250");
  3473. int index = 0;
  3474. using (Socket s = new Socket(AddressFamily.InterNetwork, SocketType.Dgram, ProtocolType.Udp))
  3475. {
  3476. s.SetSocketOption(SocketOptionLevel.IP, SocketOptionName.MulticastInterface, IPAddress.HostToNetworkOrder(index));
  3477. s.SetSocketOption(SocketOptionLevel.IP, SocketOptionName.AddMembership, new MulticastOption(ip, index));
  3478. }
  3479. }
  3480. [Test]
  3481. public void SetSocketOption_MulticastInterfaceIndex_Loopback ()
  3482. {
  3483. IPAddress ip = IPAddress.Parse ("239.255.255.250");
  3484. int index = 1;
  3485. using (Socket s = new Socket(AddressFamily.InterNetwork, SocketType.Dgram, ProtocolType.Udp))
  3486. {
  3487. s.SetSocketOption(SocketOptionLevel.IP, SocketOptionName.MulticastInterface, IPAddress.HostToNetworkOrder(index));
  3488. s.SetSocketOption(SocketOptionLevel.IP, SocketOptionName.AddMembership, new MulticastOption(ip, index));
  3489. }
  3490. }
  3491. [Test]
  3492. public void SetSocketOption_MulticastInterfaceIndex_Invalid ()
  3493. {
  3494. IPAddress ip = IPAddress.Parse ("239.255.255.250");
  3495. int index = 31415;
  3496. using (Socket s = new Socket(AddressFamily.InterNetwork, SocketType.Dgram, ProtocolType.Udp))
  3497. {
  3498. try
  3499. {
  3500. s.SetSocketOption(SocketOptionLevel.IP, SocketOptionName.MulticastInterface, IPAddress.HostToNetworkOrder(index));
  3501. Assert.Fail ("#1");
  3502. }
  3503. catch
  3504. {}
  3505. try
  3506. {
  3507. s.SetSocketOption(SocketOptionLevel.IP, SocketOptionName.AddMembership, new MulticastOption(ip, index));
  3508. Assert.Fail ("#2");
  3509. }
  3510. catch
  3511. {}
  3512. }
  3513. }
  3514. [Test]
  3515. public void Shutdown_NoConnect ()
  3516. {
  3517. Socket s = new Socket (AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
  3518. s.Bind (new IPEndPoint (IPAddress.Loopback, 0));
  3519. s.Listen (1);
  3520. try {
  3521. s.Shutdown (SocketShutdown.Both);
  3522. Assert.Fail ("#1");
  3523. } catch (SocketException exc) {
  3524. Assert.AreEqual (10057, exc.ErrorCode, "#2");
  3525. } finally {
  3526. s.Close ();
  3527. }
  3528. }
  3529. [Test]
  3530. [ExpectedException (typeof (NullReferenceException))]
  3531. public void ReceiveAsync_Null ()
  3532. {
  3533. using (Socket s = new Socket (AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp)) {
  3534. s.ReceiveAsync (null);
  3535. }
  3536. }
  3537. [Test]
  3538. [ExpectedException (typeof (NullReferenceException))]
  3539. public void ReceiveAsync_Default ()
  3540. {
  3541. using (Socket s = new Socket (AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp)) {
  3542. SocketAsyncEventArgs saea = new SocketAsyncEventArgs ();
  3543. s.ReceiveAsync (saea);
  3544. }
  3545. }
  3546. [Test]
  3547. [ExpectedException (typeof (NullReferenceException))]
  3548. public void ReceiveAsync_NullBuffer ()
  3549. {
  3550. using (Socket s = new Socket (AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp)) {
  3551. SocketAsyncEventArgs saea = new SocketAsyncEventArgs ();
  3552. saea.SetBuffer (null, 0, 0);
  3553. s.ReceiveAsync (null);
  3554. }
  3555. }
  3556. [Test]
  3557. [ExpectedException (typeof (ObjectDisposedException))]
  3558. public void ReceiveAsync_ClosedSocket ()
  3559. {
  3560. Socket s = new Socket (AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
  3561. s.Close ();
  3562. s.ReceiveAsync (null);
  3563. }
  3564. [Test]
  3565. [ExpectedException (typeof (NullReferenceException))]
  3566. public void SendAsync_Null ()
  3567. {
  3568. using (Socket s = new Socket (AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp)) {
  3569. s.SendAsync (null);
  3570. }
  3571. }
  3572. [Test]
  3573. [ExpectedException (typeof (NullReferenceException))]
  3574. public void SendAsync_Default ()
  3575. {
  3576. using (Socket s = new Socket (AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp)) {
  3577. SocketAsyncEventArgs saea = new SocketAsyncEventArgs ();
  3578. s.SendAsync (saea);
  3579. }
  3580. }
  3581. [Test]
  3582. [ExpectedException (typeof (NullReferenceException))]
  3583. public void SendAsync_NullBuffer ()
  3584. {
  3585. using (Socket s = new Socket (AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp)) {
  3586. SocketAsyncEventArgs saea = new SocketAsyncEventArgs ();
  3587. saea.SetBuffer (null, 0, 0);
  3588. s.SendAsync (null);
  3589. }
  3590. }
  3591. [Test]
  3592. [ExpectedException (typeof (ObjectDisposedException))]
  3593. public void SendAsync_ClosedSocket ()
  3594. {
  3595. Socket s = new Socket (AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
  3596. s.Close ();
  3597. s.SendAsync (null);
  3598. }
  3599. [Test]
  3600. public void SendAsyncFile ()
  3601. {
  3602. Socket serverSocket = StartSocketServer ();
  3603. Socket clientSocket = new Socket (AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
  3604. clientSocket.Connect (serverSocket.LocalEndPoint);
  3605. clientSocket.NoDelay = true;
  3606. // Initialize buffer used to create testing file
  3607. var buffer = new byte [1024];
  3608. for (int i = 0; i < 1024; ++i)
  3609. buffer [i] = (byte) (i % 256);
  3610. string temp = Path.GetTempFileName ();
  3611. try {
  3612. // Testing file creation
  3613. using (StreamWriter sw = new StreamWriter (temp)) {
  3614. sw.Write (buffer);
  3615. }
  3616. var m = new ManualResetEvent (false);
  3617. // Async Send File to server
  3618. clientSocket.BeginSendFile(temp, (ar) => {
  3619. Socket client = (Socket) ar.AsyncState;
  3620. client.EndSendFile (ar);
  3621. m.Set ();
  3622. }, clientSocket);
  3623. if (!m.WaitOne (1500))
  3624. throw new TimeoutException ();
  3625. m.Reset ();
  3626. } finally {
  3627. if (File.Exists (temp))
  3628. File.Delete (temp);
  3629. clientSocket.Close ();
  3630. serverSocket.Close ();
  3631. }
  3632. }
  3633. [Test]
  3634. public void ConnectToIPV4EndPointUsingDualModelSocket () {
  3635. using (var server = new Socket (SocketType.Stream, ProtocolType.Tcp))
  3636. using (var client = new Socket (SocketType.Stream, ProtocolType.Tcp)) {
  3637. var host = new IPEndPoint (IPAddress.Loopback, 0);
  3638. server.Bind (host);
  3639. server.Listen (0);
  3640. var ep = server.LocalEndPoint as IPEndPoint;
  3641. client.Connect (ep);
  3642. client.Disconnect (true);
  3643. client.Connect (IPAddress.Loopback, ep.Port);
  3644. client.Disconnect (true);
  3645. client.Connect (new [] {IPAddress.Loopback}, ep.Port);
  3646. client.Disconnect (true);
  3647. }
  3648. }
  3649. [Test]
  3650. public void BeginConnectToIPV4EndPointUsingDualModelSocket () {
  3651. using (var server = new Socket (SocketType.Stream, ProtocolType.Tcp))
  3652. using (var client = new Socket (SocketType.Stream, ProtocolType.Tcp)) {
  3653. var host = new IPEndPoint (IPAddress.Loopback, 0);
  3654. server.Bind (host);
  3655. server.Listen (0);
  3656. var ep = server.LocalEndPoint as IPEndPoint;
  3657. var ar1 = client.BeginConnect (ep, BCCallback, client);
  3658. client.EndConnect (ar1);
  3659. client.Disconnect (true);
  3660. var ar2 = client.BeginConnect (IPAddress.Loopback, ep.Port, BCCallback, client);
  3661. client.EndConnect (ar2);
  3662. client.Disconnect (true);
  3663. var ar3 = client.BeginConnect (new [] {IPAddress.Loopback}, ep.Port, BCCallback, client);
  3664. client.EndConnect (ar3);
  3665. client.Disconnect (true);
  3666. }
  3667. }
  3668. Socket StartSocketServer ()
  3669. {
  3670. Socket listenSocket = new Socket (AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
  3671. listenSocket.Bind (new IPEndPoint (IPAddress.Loopback, 0));
  3672. listenSocket.Listen (1);
  3673. listenSocket.BeginAccept (new AsyncCallback (ReceiveCallback), listenSocket);
  3674. return listenSocket;
  3675. }
  3676. public static void ReceiveCallback (IAsyncResult AsyncCall)
  3677. {
  3678. byte[] bytes = new byte [1024];
  3679. Socket listener = (Socket)AsyncCall.AsyncState;
  3680. Socket client = listener.EndAccept (AsyncCall);
  3681. client.Receive (bytes, bytes.Length, 0);
  3682. client.Close ();
  3683. }
  3684. [Test]
  3685. public void UdpMulticasTimeToLive ()
  3686. {
  3687. /* see https://bugzilla.xamarin.com/show_bug.cgi?id=36941 */
  3688. using (Socket socket = new Socket (AddressFamily.InterNetwork, SocketType.Dgram, ProtocolType.Udp)) {
  3689. IPEndPoint end_point = new IPEndPoint (IPAddress.Any, 11000);
  3690. socket.SetSocketOption (SocketOptionLevel.Socket, SocketOptionName.ReuseAddress, 1);
  3691. socket.Bind (end_point);
  3692. socket.SetSocketOption (SocketOptionLevel.IP, SocketOptionName.MulticastTimeToLive, 19);
  3693. }
  3694. }
  3695. }
  3696. }