Read recv timestamps from socket (posix only).

webrtc/base/openssladapter.cc

 /*
  *  Copyright 2008 The WebRTC Project Authors. All rights reserved.
  *
  *  Use of this source code is governed by a BSD-style license
  *  that can be found in the LICENSE file in the root of the source
  *  tree. An additional intellectual property rights grant can be found
  *  in the file PATENTS.  All contributing project authors may
  *  be found in the AUTHORS file in the root of the source tree.
  */
 
@@ skipping 101 matching lines @@
   if (b == NULL)
     return 0;
   return 1;
 }
 
 static int socket_read(BIO* b, char* out, int outl) {
   if (!out)
     return -1;
   rtc::AsyncSocket* socket = static_cast<rtc::AsyncSocket*>(b->ptr);
   BIO_clear_retry_flags(b);
-  int result = socket->Recv(out, outl);
+  int64_t timestamp;
+  int result = socket->Recv(out, outl, &timestamp);
   if (result > 0) {
     return result;
   } else if (result == 0) {
     b->num = 1;
   } else if (socket->IsBlocking()) {
     BIO_set_retry_read(b);
   }
   return -1;
 }
 
@@ skipping 384 matching lines @@
   if (socket_->GetState() == Socket::CS_CONNECTED &&
       addr == socket_->GetRemoteAddress()) {
     return Send(pv, cb);
   }
 
   SetError(ENOTCONN);
 
   return SOCKET_ERROR;
 }
 
-int
-OpenSSLAdapter::Recv(void* pv, size_t cb) {
+int OpenSSLAdapter::Recv(void* pv, size_t cb, int64_t* timestamp) {
   //LOG(LS_INFO) << "OpenSSLAdapter::Recv(" << cb << ")";
   switch (state_) {
 
   case SSL_NONE:
-    return AsyncSocketAdapter::Recv(pv, cb);
+    return AsyncSocketAdapter::Recv(pv, cb, timestamp);
 
   case SSL_WAIT:
   case SSL_CONNECTING:
     SetError(EWOULDBLOCK);
     return SOCKET_ERROR;
 
   case SSL_CONNECTED:
     break;
 
   case SSL_ERROR:
@@ skipping 28 matching lines @@
     break;
   default:
     //LOG(LS_INFO) << " -- error " << code;
     Error("SSL_read", (code ? code : -1), false);
     break;
   }
 
   return SOCKET_ERROR;
 }
 
-int
-OpenSSLAdapter::RecvFrom(void* pv, size_t cb, SocketAddress* paddr) {
+int OpenSSLAdapter::RecvFrom(void* pv,
+                             size_t cb,
+                             SocketAddress* paddr,
+                             int64_t* timestamp) {
   if (socket_->GetState() == Socket::CS_CONNECTED) {
-    int ret = Recv(pv, cb);
+    int ret = Recv(pv, cb, timestamp);
 
     *paddr = GetRemoteAddress();
 
     return ret;
   }
 
   SetError(ENOTCONN);
 
   return SOCKET_ERROR;
 }
@@ skipping 361 matching lines @@
   if (ssl_mode_ == SSL_MODE_DTLS) {
     SSL_CTX_set_read_ahead(ctx, 1);
   }
 
   return ctx;
 }
 
 } // namespace rtc
 
 #endif  // HAVE_OPENSSL_SSL_H