diff --git a/src/ice_socket.h b/src/ice_socket.h index a35fb64269631f68116a4ad5621abddf79f17a00..ba12a1b04e02b414a20137afa9c557fa5a1c1b6c 100644 --- a/src/ice_socket.h +++ b/src/ice_socket.h @@ -46,7 +46,6 @@ class IceSocket void close(); ssize_t recv(unsigned char* buf, size_t len); ssize_t send(const unsigned char* buf, size_t len); - ssize_t getNextPacketSize() const; ssize_t waitForData(unsigned int timeout); void setOnRecv(IceRecvCb cb); uint16_t getTransportOverhead(); diff --git a/src/ice_transport.cpp b/src/ice_transport.cpp index 791b9303a4f2c01e1096a14e18f69289f04a3f75..750f4453dfb275303d27b7b0aa2e606512c8a9a0 100644 --- a/src/ice_transport.cpp +++ b/src/ice_transport.cpp @@ -934,17 +934,6 @@ IceTransport::send(int comp_id, const unsigned char* buf, size_t len) return len; } -ssize_t -IceTransport::getNextPacketSize(int comp_id) -{ - auto& io = compIO_[comp_id]; - std::lock_guard<std::mutex> lk(io.mutex); - if (io.queue.empty()) { - return 0; - } - return io.queue.front().datalen; -} - int IceTransport::waitForInitialization(unsigned timeout) { @@ -1053,14 +1042,6 @@ IceSocket::send(const unsigned char* buf, size_t len) return ice_transport_->send(compId_, buf, len); } -ssize_t -IceSocket::getNextPacketSize() const -{ - if (!ice_transport_.get()) - return -1; - return ice_transport_->getNextPacketSize(compId_); -} - ssize_t IceSocket::waitForData(unsigned int timeout) { diff --git a/src/ice_transport.h b/src/ice_transport.h index 990c88d1de979a95cfff6520a50187623a2ccd2a..9103e29db8164ad6dced94515146f9933ec7367b 100644 --- a/src/ice_transport.h +++ b/src/ice_transport.h @@ -200,8 +200,6 @@ class IceTransport { ssize_t send(int comp_id, const unsigned char* buf, size_t len); - ssize_t getNextPacketSize(int comp_id); - int waitForInitialization(unsigned timeout); int waitForNegotiation(unsigned timeout);