diff --git a/include/uvgrtp/media_stream.hh b/include/uvgrtp/media_stream.hh index 97187e8..69f998a 100644 --- a/include/uvgrtp/media_stream.hh +++ b/include/uvgrtp/media_stream.hh @@ -10,9 +10,9 @@ #ifndef _WIN32 #include #include -#endif +#else #include - +#endif namespace uvgrtp { // forward declarations diff --git a/src/rtcp.cc b/src/rtcp.cc index f128c76..fb96196 100644 --- a/src/rtcp.cc +++ b/src/rtcp.cc @@ -49,7 +49,7 @@ uvgrtp::rtcp::rtcp(std::shared_ptr rtp, std::shared_ptrget_ssrc()), + rtcp_pkt_sent_count_(0), initial_(true), ssrc_(ssrc), num_receivers_(0), ipv6_(false), socket_address_({}), diff --git a/src/socket.cc b/src/socket.cc index 8561cf2..472bf64 100644 --- a/src/socket.cc +++ b/src/socket.cc @@ -244,14 +244,10 @@ std::string uvgrtp::socket::get_socket_path_string() const std::string uvgrtp::socket::sockaddr_to_string(const sockaddr_in& addr) const { // tyhjennä turhat "ipv6 supportit" pois + int addr_len = INET6_ADDRSTRLEN; char* c_string = new char[INET_ADDRSTRLEN]; memset(c_string, 0, INET_ADDRSTRLEN); - if (addr.sin_family == AF_INET6) - { - addr_len = INET6_ADDRSTRLEN; - } - char* addr_string = new char[addr_len]; memset(addr_string, 0, addr_len); @@ -316,16 +312,17 @@ rtp_error_t uvgrtp::socket::__sendto(sockaddr_in& addr, sockaddr_in6& addr6, boo #ifndef _WIN32 if (ipv6) { - nsend = ::sendto(socket_, buf, buf_len, send_flags, (const struct sockaddr*)&addr6, sizeof(addr6))); + nsend = ::sendto(socket_, buf, buf_len, send_flags, (const struct sockaddr*)&addr6, sizeof(addr6)); } else { - nsend = ::sendto(socket_, buf, buf_len, send_flags, (const struct sockaddr*)&addr, sizeof(addr))); + nsend = ::sendto(socket_, buf, buf_len, send_flags, (const struct sockaddr*)&addr, sizeof(addr)); } - if ((nsend == -1) { + if (nsend == -1) { UVG_LOG_ERROR("Failed to send data: %s", strerror(errno)); - if (bytes_sent) + if (bytes_sent) { *bytes_sent = -1; + } return RTP_SEND_ERROR; } #else @@ -353,8 +350,9 @@ rtp_error_t uvgrtp::socket::__sendto(sockaddr_in& addr, sockaddr_in6& addr6, boo nsend = sent_bytes; #endif - if (bytes_sent) + if (bytes_sent) { *bytes_sent = nsend; + } #ifndef NDEBUG ++sent_packets_; diff --git a/src/socket.hh b/src/socket.hh index 6460725..ef02d27 100644 --- a/src/socket.hh +++ b/src/socket.hh @@ -202,7 +202,7 @@ namespace uvgrtp { rtp_error_t __sendtov(sockaddr_in& addr, sockaddr_in6& addr6, bool ipv6, buf_vec& buffers, int send_flags, int *bytes_sent); rtp_error_t __sendtov(sockaddr_in& addr, sockaddr_in6& addr6, bool ipv6, uvgrtp::pkt_vec& buffers, int send_flags, int *bytes_sent); - SOCKET socket_; + socket_t socket_; sockaddr_in remote_address_; sockaddr_in local_address_; sockaddr_in6 remote_ip6_address_;