More Simulation Framework features

webrtc/modules/remote_bitrate_estimator/test/packet.h

 /*
  *  Copyright (c) 2015 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 16 matching lines @@
  public:
   enum Type { kMedia, kFeedback };
 
   Packet();
   Packet(int flow_id, int64_t send_time_us, size_t payload_size);
   virtual ~Packet();
 
   virtual bool operator<(const Packet& rhs) const;
 
   virtual int flow_id() const { return flow_id_; }
-  virtual int64_t creation_time_us() const { return creation_time_us_; }
   virtual void set_send_time_us(int64_t send_time_us);
   virtual int64_t send_time_us() const { return send_time_us_; }
   virtual size_t payload_size() const { return payload_size_; }
   virtual Packet::Type GetPacketType() const = 0;
-  void set_sender_timestamp_us(int64_t sender_timestamp_us) {
+  virtual void set_sender_timestamp_us(int64_t sender_timestamp_us) {
     sender_timestamp_us_ = sender_timestamp_us;
   }
-  int64_t sender_timestamp_us() const { return sender_timestamp_us_; }
+  virtual int64_t creation_time_ms() const {
+    return (creation_time_us_ + 500) / 1000;
+  }
+  virtual int64_t sender_timestamp_ms() const {
+    return (sender_timestamp_us_ + 500) / 1000;
+  }
+  virtual int64_t send_time_ms() const { return (send_time_us_ + 500) / 1000; }
 
  protected:
   int flow_id_;
   int64_t creation_time_us_;  // Time when the packet was created.
   int64_t send_time_us_;  // Time the packet left last processor touching it.
   int64_t sender_timestamp_us_;  // Time the packet left the Sender.
   size_t payload_size_;  // Size of the (non-existent, simulated) payload.
 };
 
 class MediaPacket : public Packet {
  public:
   MediaPacket();
   MediaPacket(int flow_id,
               int64_t send_time_us,
               size_t payload_size,
               uint16_t sequence_number);
   MediaPacket(int flow_id,
               int64_t send_time_us,
               size_t payload_size,
               const RTPHeader& header);
   MediaPacket(int64_t send_time_us, uint32_t sequence_number);
+
   virtual ~MediaPacket() {}
 
   int64_t GetAbsSendTimeInMs() const {
     int64_t timestamp = header_.extension.absoluteSendTime
                         << kAbsSendTimeInterArrivalUpshift;
     return 1000.0 * timestamp / static_cast<double>(1 << kInterArrivalShift);
   }
   void SetAbsSendTimeMs(int64_t abs_send_time_ms);
   const RTPHeader& header() const { return header_; }
   virtual Packet::Type GetPacketType() const { return kMedia; }
   uint16_t sequence_number() const { return header_.sequenceNumber; }
-  int64_t send_time_ms() const { return send_time_us_ / 1000; }
 
  private:
   static const int kAbsSendTimeFraction = 18;
   static const int kAbsSendTimeInterArrivalUpshift = 8;
   static const int kInterArrivalShift =
       kAbsSendTimeFraction + kAbsSendTimeInterArrivalUpshift;
 
   RTPHeader header_;
 };
 
 class FeedbackPacket : public Packet {
  public:
   FeedbackPacket(int flow_id,
                  int64_t this_send_time_us,
                  int64_t latest_send_time_ms)
       : Packet(flow_id, this_send_time_us, 0),
         latest_send_time_ms_(latest_send_time_ms) {}
   virtual ~FeedbackPacket() {}
 
   virtual Packet::Type GetPacketType() const { return kFeedback; }
   int64_t latest_send_time_ms() const { return latest_send_time_ms_; }
 
  private:
-  int64_t latest_send_time_ms_;  // Time stamp for the latest sent packet.
+  int64_t latest_send_time_ms_;  // Time stamp for the latest sent FbPacket.
 };
 
 class RembFeedback : public FeedbackPacket {
  public:
   RembFeedback(int flow_id,
                int64_t send_time_us,
                int64_t latest_send_time_ms,
                uint32_t estimated_bps,
                RTCPReportBlock report_block);
   virtual ~RembFeedback() {}
@@ skipping 74 matching lines @@
 };
 
 typedef std::list<Packet*> Packets;
 typedef std::list<Packet*>::iterator PacketsIt;
 typedef std::list<Packet*>::const_iterator PacketsConstIt;
 
 }  // namespace bwe
 }  // namespace testing
 }  // namespace webrtc
 #endif  // WEBRTC_MODULES_REMOTE_BITRATE_ESTIMATOR_TEST_PACKET_H_