class<\/span> Client<\/span><\/div> class<\/span> <<<\/span> self<\/span><\/div> def<\/span> accept<\/span>(<\/span>ip<\/span>,<\/span> port<\/span>)<\/span><\/div> server<\/span> =<\/span> CustomSocket<\/span>.<\/span>new<\/span><\/div> server<\/span>.<\/span>bind<\/span><\/div> server<\/span>.<\/span>listen<\/span>(<\/span>5<\/span>)<\/span><\/div> send_syn!<\/span>(<\/span>ip<\/span>,<\/span> port<\/span>,<\/span> server<\/span>.<\/span>local_port<\/span>)<\/span><\/div> Thread<\/span>.<\/span>new<\/span> do<\/span><\/div> begin<\/span><\/div> Timeout<\/span>::<\/span>timeout<\/span>(<\/span>5<\/span>)<\/span> {<\/span><\/div> session<\/span> =<\/span> server<\/span>.<\/span>accept<\/span><\/div> self<\/span>.<\/span>new<\/span>(<\/span>ip<\/span>,<\/span> port<\/span>,<\/span> session<\/span>)<\/span><\/div> }<\/span><\/div> rescue<\/span> Timeout<\/span>::<\/span>Error<\/span><\/div> end<\/span><\/div> end<\/span><\/div> server<\/span>.<\/span>local_port<\/span><\/div> end<\/span><\/div> <\/div>
private<\/span><\/div> def<\/span> send_syn!<\/span>(<\/span>ip<\/span>,<\/span> port<\/span>,<\/span> local_port<\/span>)<\/span><\/div> socket<\/span> =<\/span> CustomSocket<\/span>.<\/span>new<\/span><\/div> socket<\/span>.<\/span>bind<\/span>(<\/span>local_port<\/span>)<\/span><\/div> Timeout<\/span>::<\/span>timeout<\/span>(<\/span>0<\/span>.<\/span>3<\/span>)<\/span> {<\/span><\/div> socket<\/span>.<\/span>connect<\/span>(<\/span>ip<\/span>,<\/span> port<\/span>)<\/span><\/div> }<\/span><\/div> rescue<\/span> Timeout<\/span>::<\/span>Error<\/span><\/div> rescue<\/span> # Errno errors<\/span><\/div> ensure<\/span><\/div> if<\/span> socket<\/span> &&<\/span> !<\/span>socket<\/span>.<\/span>closed?<\/span><\/div> socket<\/span>.<\/span>close<\/span><\/div> end<\/span><\/div> end<\/span><\/div> end<\/span><\/div>end<\/span><\/div><\/pre><\/div>\n \n <\/div>\n\n