اختبار :: POE :: العميل :: TCP اختبار :: POE :: العميل :: TCP هو مكون PoE الذي يوفر خدمات عميل TCP لحالات الاختبار.
التحميل الان

اختبار :: POE :: العميل :: TCP الترتيب والملخص

اختبار :: POE :: العميل :: TCP العلامات

TCP. الاختبارات بوي مكون poe حالات تجريبية خدمات عميل TCP

اختبار :: POE :: العميل :: TCP وصف

اختبار :: POE :: العميل :: TCP هو مكون PoE الذي يوفر خدمات عميل TCP لحالات الاختبار. اختبار :: POE :: Client :: TCP هو مكون PoE الذي يوفر خدمات عميل TCP لحالات الاختبار. استخدام المقبس؛ استخدام الاختبار :: المزيد من الاختبارات => 15؛ استخدم PoE qw (عجلة :: MocketFactory Wheel :: ReadWrite Filter :: LINE)؛ استخدام الاختبار :: POE :: العميل :: TCP؛ MyData = ("هذا اختبار"، "هذا اختبار آخر"، "هذا هو الاختبار الأخير،)؛ poe :: session-> session-> إنشاء (package_states => ،]، heap => {data => data،}،)؛ $ poe_kernel-> تشغيل ()؛ الخروج 0؛ Sub _Start {بلدي (kernel $ kernel، $ heap) = @ _ ؛ $ heap -> {listener} = poe :: wheel :: socketFactory-> جديد (bindaddress => '127.0.0.1'، screafevent => '_accept'، failureevent => '_failed'، socketdomain => af_inet، # مجموعات مقبس () Socket Sockettype => Sock_stream، # قم بتعيين ملف المقبس () نوع Socket Preprotocol => 'TCP'، # قم بتعيين إعادة استخدام بروتوكول المقبس () إعادة استخدام البروتوكول => 'ON'، # يتيح إعادة استخدام المنفذ)؛ $ heap -> {testc} = اختبار :: poe :: العميل :: TCP-> تفرخ ()؛ إرجاع؛ } Sub _Accept {بلدي (kernel $ kernel، كومة $، $ المقبس) = @ _ ؛ بلدي عجلة دولارات = POE :: Wheel :: ReadWrite-> جديد (مقبض => مقبس $، Inputeventvent => '_sock_in'، erorevent => '_sock_err'،)؛ $ heap -> {wheels} -> {$ عجلة-> معرف} = $ عجلة؛ إرجاع؛ } Sub _Failed {بلدي (kernel $ kernel، كومة $، errnum، $ errnum، $ ErrSrstr، $ wheel_id) =_ ؛ يموت "عجلة دولارات دولية rewherated $ errorated $ errnum: $ errstrn"؛ إرجاع؛ } Sub _sock_in {My ($ Heap، إدخال $، Wheel_ID $) = @ _ ؛ تمر ("تم إدخال المدخلات من العميل")؛ $ heap -> {wheels} -> {$ wheel_id} -> وضع ($ الإدخال) إذا $ heap -> {wheels} -> {$ wheel_id}؛ إرجاع؛ } sub _sock_err {بلدي (كومة كومة $، دولارات $) = @ _ ؛ تمر ("العميل غير متصل")؛ حذف كومة $ -> {Wheels} -> {$ wheel_id}؛ إرجاع؛ } Testc_ التسجيل {My (Kernel $ Kernel، $ المرسل، $ كائن) = @ _ ؛ تمر ($ _ )؛ بلدي Port $ = (Sockaddr_in ($ _ -> {Listener} -> GetSockname ())) ؛ Kernel-> Post ($ المرسل، "Connect"، {العنوان => '127.0.0.1'، Port => $ Port})؛ إرجاع؛ } testc_connected {بلدي (kernel $ kernel، كومة $، المرسل $ =_ ؛ تمر ($ _ )؛ Kernel-> Post ($ المرسل، 'send_to_server'، $ heap -> {data} -> )؛ إرجاع؛ } testc_flushed الفرعية {تمر ($ _ )؛ إرجاع؛ } Testc_Input الفرعي {My (كومة $، إدخال $) = @ _ ؛ تمر ("حصلت على شيء مرة أخرى من الخادم)؛ بياناتي $ = Shift @ {$ heap -> {data}}؛ طيب ($ إدخال بيانات EQ $، "البيانات المتطابقة: '$ input'")؛ ما لم يكن (Scalar @ @ {$ heap -> {data}}) {$ {{testc} -> إنهاء ()؛ إرجاع؛ } $ poe_kernel-> المشاركة ($ _ ، "send_to_server"، $ heap -> {data} -> )؛ إرجاع؛ } testc_disconected} تمر (دول دولار)؛ حذف كومة $ -> {عجلات}؛ حذف كومة $ -> {Listener}؛ $ heap -> {testc} -> اغلاق ()؛ إرجاع؛ } متطلبات: perl.

اختبار :: POE :: العميل :: TCP برامج ذات صلة