, SO_RCVTIMEO ve SO_SNDTIMEO soket seçeneklerini yükseltmeden önce mi ayarlayabilirsiniz?

Question

SO_RCVTIMEO ve SO_SNDTIMEO soket seçeneklerini artırmaya devam edebilirsiniz?

Nasıl yapılıyor?

Not Zamanlayıcıları kullanabileceğinizi biliyorum, ancak özellikle bu soket seçeneklerini bilmek istiyorum. Eğer boost::asio::detail::socket_option olanları taklit etmek için kendi sınıfları yazmaya çekinmiyorsanız

Answer 1

Kesinlikle! Yükseltme ASIO, bu durumda SOCKET'in kendisi olan yerel/temel verilere erişmenizi sağlar.

boost::asio::ip::tcp::socket my_socket; 

Ve en Zaten open veya bind ya aslında my_socket kullanılabilir kılan bazı üye işlev aradım diyelim: Yani, sen olduğunu varsayalım. Sonra, temel SOCKET değerini elde etmek için :

Yani orada var! Boost's ASIO, aksi takdirde yapabileceğinizden çok daha hızlı bir şekilde birçok şey yapmanıza izin verir, ancak normal soket kitaplığı çağrılarına hala ihtiyacınız olan pek çok şey vardır. Bu onlardan biri olur.

Answer 2

senin hep boost/asio/socket_base.hpp örnekleri uygulayabilir, (mevcut Boost SVN itibariyle) Boost.Asio içine inşa edilecek görünür değil,

typedef boost::asio::detail::socket_option::timeval<SOL_SOCKET, SO_SNDTIMEO> 
    send_timeout; 
typedef boost::asio::detail::socket_option::timeval<SOL_SOCKET, SO_RCVTIMEO> 
    receive_timeout; 

(Açıkçası, sana boost::asio::detail::socket_option ad içine timeval sınıf enjekte demiyorum, ama şu an kullanmak için iyi bir şey gelmiyor olabilir :-P.): ve aşağıdakileri yapın

Düzenleme:tabanlı socket_option::timeval örnek uygulamam:

Answer 3

Bu soruna kolay bir çalışma, yerel okuma ve yazma işlevlerini kullanmak olabilir. 1sec zaman aşımı ile yazılı İçin

:

struct timeval tv = { 1, 0 }; 
setsockopt(socket.native_handle(), SOL_SOCKET, SO_SNDTIMEO, &tv, sizeof(tv)); 
ssize_t nsent = ::write(socket->native_handle(), buff, size); 
if (nsent > 0) { 
    BOOST_LOG_TRIVIAL(debug) << "Sent " << nsent << " bytes to remote client " << ep; 
} else if (nsent == 0) { 
BOOST_LOG_TRIVIAL(info) << "Client " << ep << " closed connection"; 
} else if (errno != EAGAIN) { 
    BOOST_LOG_TRIVIAL(info) << "Client " << ep << " error: " <<  strerror(errno); 
} 

1sec zaman aşımıyla okuma için:

struct timeval tv = { 1, 0 }; 
setsockopt(socket.native_handle(), SOL_SOCKET, SO_RCVTIMEO, &tv, sizeof(tv)); 
ssize_t nread = ::read(socket.native_handle(), buff, audio_buff_size); 
if (nread > 0) { 
} else if (nread == 0) { 
    BOOST_LOG_TRIVIAL(info) << "Source " << source << " server " << host << " closed connection"; 
    break; 
} else if (errno != EAGAIN) { 
    BOOST_LOG_TRIVIAL(info) << "Source " << source << " server " << host << " error: " << strerror(errno); 
    break; 
} 

Bu benim için iyi çalıştı.