Adding test for unordered, fragmented SCTP message delivery.

webrtc/api/test/mockpeerconnectionobservers.h

 /*
  *  Copyright 2012 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 56 matching lines @@
   bool result() const { return result_; }
 
  private:
   bool called_;
   bool result_;
 };
 
 class MockDataChannelObserver : public webrtc::DataChannelObserver {
  public:
   explicit MockDataChannelObserver(webrtc::DataChannelInterface* channel)
-     : channel_(channel), received_message_count_(0) {
+      : channel_(channel) {
     channel_->RegisterObserver(this);
     state_ = channel_->state();
   }
   virtual ~MockDataChannelObserver() {
     channel_->UnregisterObserver();
   }
 
   void OnBufferedAmountChange(uint64_t previous_amount) override {}
 
   void OnStateChange() override { state_ = channel_->state(); }
   void OnMessage(const DataBuffer& buffer) override {
-    last_message_.assign(buffer.data.data<char>(), buffer.data.size());
-    ++received_message_count_;
+    messages_.push_back(
+        std::string(buffer.data.data<char>(), buffer.data.size()));
   }
 
   bool IsOpen() const { return state_ == DataChannelInterface::kOpen; }
-  const std::string& last_message() const { return last_message_; }
-  size_t received_message_count() const { return received_message_count_; }
+  std::vector<std::string> messages() const { return messages_; }
+  std::string last_message() const {
+    return messages_.empty() ? std::string() : messages_.back();
+  }
+  size_t received_message_count() const { return messages_.size(); }
 
  private:
   rtc::scoped_refptr<webrtc::DataChannelInterface> channel_;
   DataChannelInterface::DataState state_;
-  std::string last_message_;
-  size_t received_message_count_;
+  std::vector<std::string> messages_;
 };
 
 class MockStatsObserver : public webrtc::StatsObserver {
  public:
   MockStatsObserver() : called_(false), stats_() {}
   virtual ~MockStatsObserver() {}
 
   virtual void OnComplete(const StatsReports& reports) {
     ASSERT(!called_);
     called_ = true;
@@ skipping 106 matching lines @@
     int bytes_sent;
     int available_receive_bandwidth;
     std::string dtls_cipher;
     std::string srtp_cipher;
   } stats_;
 };
 
 }  // namespace webrtc
 
 #endif  // WEBRTC_API_TEST_MOCKPEERCONNECTIONOBSERVERS_H_