[asio :: udp] नॉन-क्रॉस-प्लेटफॉर्म व्यवहार

तो, स्थिति की कल्पना करें: हमारे पास एक क्रॉस-प्लेटफ़ॉर्म सर्वर है जिसे यूडीपी पर डेटा प्राप्त करना चाहिए। Asio के साथ सशस्त्र, आप एक सॉकेट बनाते हैं, प्राप्त डेटा के लिए एक बफर बनाते हैं, और सुनना शुरू करते हैं।

udp::socket receiver(ios, udp::endpoint(udp::v4(), port)); char read_buf[buf_len]; udp::endpoint sender_point; receiver.receive_from(buffer(read_buf, sizeof(read_buf)), sender_point); 

यदि बफर के लिए आबंटित किए गए डेटा से अधिक डेटा प्राप्त होता है तो क्या होता है?

Win / LINUX प्लेटफार्मों पर व्यवहार का एक बेमेल होगा। लिनक्स पर, ऑपरेशन सुचारू रूप से चलेगा, यह बिल्कुल अनुरोध के रूप में पढ़ा जाएगा, बाकी को छोड़ दिया जाएगा। विन पर, आपको रीड डेटा भी मिलेगा, लेकिन उसके बाद आपको एक अपवाद भी मिलेगा।

और यहाँ ऐसा क्यों होता है:

Get_from फ़ंक्शन का कार्य निम्न कोड का निष्पादन है

 #if defined(BOOST_WINDOWS) || defined(__CYGWIN__) int result = error_wrapper(::WSARecvFrom(s, bufs, recv_buf_count, &bytes_transferred, &recv_flags, addr, &tmp_addrlen, 0, 0), ec); *addrlen = (std::size_t)tmp_addrlen; ... if (result != 0) return socket_error_retval; ec = boost::system::error_code(); return bytes_transferred; #else // defined(BOOST_WINDOWS) || defined(__CYGWIN__) msghdr msg = msghdr(); init_msghdr_msg_name(msg.msg_name, addr); msg.msg_namelen = *addrlen; msg.msg_iov = bufs; msg.msg_iovlen = count; int result = error_wrapper(::recvmsg(s, &msg, flags), ec); *addrlen = msg.msg_namelen; if (result >= 0) ec = boost::system::error_code(); return result; 

विन के लिए WSARecvFrom और सॉकेट से डेटा प्राप्त करने के लिए लिनक्स के लिए recvmsg का उपयोग किया जाता है। फ़ंक्शन का परिणाम (सफल / सफल नहीं) अगले फ़ंक्शन द्वारा निर्धारित किया जाता है।

 template <typename ReturnType> inline ReturnType error_wrapper(ReturnType return_value, boost::system::error_code& ec) { #if defined(BOOST_WINDOWS) || defined(__CYGWIN__) ec = boost::system::error_code(WSAGetLastError(), boost::asio::error::get_system_category()); #else ec = boost::system::error_code(errno, boost::asio::error::get_system_category()); #endif return return_value; } 

WSARecvFrom फ़ंक्शन के विवरण से, यह निम्नानुसार है कि यह एक त्रुटि स्थिति देता है:

यदि कोई त्रुटि नहीं होती है और प्राप्त ऑपरेशन तुरंत पूरा हो गया है, तो WSARecvFrom शून्य देता है। अन्यथा, SOCKET_ERROR का मान लौटाया जाता है, और WSAGetLastError को कॉल करके एक विशिष्ट त्रुटि कोड प्राप्त किया जा सकता है।

जिनमें से एक है:

WSAEMSGSIZE
यह संदेश निर्दिष्ट बफ़र के लिए बहुत बड़ा था और (केवल अविश्वसनीय प्रोटोकॉल के लिए) संदेश का कोई अनुगामी भाग जो बफ़र में फिट नहीं था, को छोड़ दिया गया है।

आरईवी परिवार के कार्यों को सफलतापूर्वक पढ़ने के लिए बाइट्स की संख्या वापस मिलती है , या त्रुटी में स्थिति और स्थिति के मामले में -1। लेकिन उसकी गलतियों के बीच ऊपर के समान नहीं है। यह लिनक्स के लिए निकला एक गलती नहीं है? वास्तव में ऐसा नहीं है। एक त्रुटि कोड msg_flags फ़ील्ड में recvmsg फ़ंक्शन को दिए गए फ़ंक्शन को लिखा जाता है (अर्थात, इसे asio में उपयोग किया जाता है):

MSG_TRUNC
वास्तविक पैकेट लंबाई लौटाता है, भले ही वह प्रदान किए गए बफर से अधिक हो। यह ध्वज केवल पैकेट प्रोटोकॉल के साथ उपयोग किया जा सकता है।

इस प्रकार, विन में एक ही ऑपरेशन को त्रुटिपूर्ण और लिनक्स पर सही माना जाता है। जिसे स्पष्ट रूप से asio पर ध्यान नहीं दिया गया है।

आगामी कठिनाइयों में से एक विन के तहत यह निर्धारित करने में असमर्थता है कि सभी को एक डीटाग्राम नहीं पढ़ा गया था।

इस समस्या का एक संभावित समाधान उपलब्ध फ़ंक्शन का उपयोग करना हो सकता है। लेकिन यहाँ भी हम और भी भयावह बेमेल हो जाते हैं। विन प्लेटफार्मों पर यह फ़ंक्शन यूडीपी सॉकेट (सभी डेटाग्राम के डेटा का योग) में डेटा की कुल राशि लौटाता है, और लिनक्स प्लेटफार्मों पर, डेटाग्राम का आकार केवल पहला (अगले रीड पर संसाधित किया जाएगा) है।

और यहाँ उपरोक्त सभी का एक पूरा उदाहरण है:

स्रोत

आउटपुट जीत:

अपवाद: get_from: डेटाग्राम सॉकेट को भेजा गया संदेश आंतरिक संदेश बफर से बड़ा था या किसी अन्य नेटवर्क पैरामीटर से अधिक था। यह भी संभव है कि संदेश प्राप्त करने के लिए बफर संदेश के आकार से छोटा था।
कुछ परीक्षण
उपलब्ध: 36
उपलब्ध: 18
उपलब्ध: 0

आउटपुट लिनक्स:

कुछ परीक्षण
उपलब्ध: 18
उपलब्ध: 18
उपलब्ध: 0

बूस्ट संस्करण 1.44 और 1.49 पर इसका परीक्षण किया गया।

आपका ध्यान देने के लिए धन्यवाद।