Read recv timestamps from socket (posix only).

webrtc/base/macasyncsocket.cc

 /*
  *  Copyright 2010 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 170 matching lines @@
                       reinterpret_cast<sockaddr*>(&saddr), len);
 
   if (sent == SOCKET_ERROR) {
     error_ = errno;
   }
 
   return sent;
 }
 
 // Read data received from the remote end we're connected to.
-int MacAsyncSocket::Recv(void* buffer, size_t length) {
+int MacAsyncSocket::Recv(void* buffer, size_t length, int64_t* timestamp) {
+  if (timestamp) {
+    *timestamp = -1;
+  }
   int received = ::recv(native_socket_, reinterpret_cast<char*>(buffer),
                         length, 0);
   if (received == SOCKET_ERROR) error_ = errno;
 
   // Recv should only be called when there is data to read
   ASSERT((received != 0) || (length == 0));
   return received;
 }
 
 // Read data received from any remote party
-int MacAsyncSocket::RecvFrom(void* buffer, size_t length,
-                             SocketAddress* out_addr) {
+int MacAsyncSocket::RecvFrom(void* buffer,
+                             size_t length,
+                             SocketAddress* out_addr,
+                             int64_t* timestamp) {
+  if (timestamp) {
+    *timestamp = -1;
+  }
   sockaddr_storage saddr;
   socklen_t addr_len = sizeof(saddr);
   int received = ::recvfrom(native_socket_, reinterpret_cast<char*>(buffer),
                             length, 0, reinterpret_cast<sockaddr*>(&saddr),
                             &addr_len);
   if (received >= 0 && out_addr != NULL) {
     SocketAddressFromSockAddrStorage(saddr, out_addr);
   } else if (received == SOCKET_ERROR) {
     error_ = errno;
   }
@@ skipping 254 matching lines @@
       this_socket->current_callbacks_ &= ~kCFSocketWriteCallBack;
       this_socket->SignalWriteEvent(this_socket);
       break;
 
     default:
       ASSERT(false && "Invalid callback type for socket");
   }
 }
 
 }  // namespace rtc