@@ -271,9 +271,10 @@ void FlutterPeerConnection::RTCPeerConnectionDispose(
271
271
result->Success ();
272
272
}
273
273
274
- void FlutterPeerConnection::CreateOffer (const EncodableMap& constraintsMap,
275
- RTCPeerConnection* pc,
276
- std::unique_ptr<MethodResultProxy> result) {
274
+ void FlutterPeerConnection::CreateOffer (
275
+ const EncodableMap& constraintsMap,
276
+ RTCPeerConnection* pc,
277
+ std::unique_ptr<MethodResultProxy> result) {
277
278
scoped_refptr<RTCMediaConstraints> constraints =
278
279
base_->ParseMediaConstraints (constraintsMap);
279
280
std::shared_ptr<MethodResultProxy> result_ptr (result.release ());
@@ -290,9 +291,10 @@ void FlutterPeerConnection::CreateOffer(const EncodableMap& constraintsMap,
290
291
constraints);
291
292
}
292
293
293
- void FlutterPeerConnection::CreateAnswer (const EncodableMap& constraintsMap,
294
- RTCPeerConnection* pc,
295
- std::unique_ptr<MethodResultProxy> result) {
294
+ void FlutterPeerConnection::CreateAnswer (
295
+ const EncodableMap& constraintsMap,
296
+ RTCPeerConnection* pc,
297
+ std::unique_ptr<MethodResultProxy> result) {
296
298
scoped_refptr<RTCMediaConstraints> constraints =
297
299
base_->ParseMediaConstraints (constraintsMap);
298
300
std::shared_ptr<MethodResultProxy> result_ptr (result.release ());
@@ -725,8 +727,9 @@ void FlutterPeerConnection::RtpTransceiverSetDirection(
725
727
}
726
728
}
727
729
728
- void FlutterPeerConnection::GetSenders (RTCPeerConnection* pc,
729
- std::unique_ptr<MethodResultProxy> result) {
730
+ void FlutterPeerConnection::GetSenders (
731
+ RTCPeerConnection* pc,
732
+ std::unique_ptr<MethodResultProxy> result) {
730
733
std::shared_ptr<MethodResultProxy> result_ptr (result.release ());
731
734
732
735
EncodableMap map;
@@ -752,57 +755,58 @@ void FlutterPeerConnection::AddIceCandidate(
752
755
EncodableMap statsToMap (const scoped_refptr<MediaRTCStats>& stats) {
753
756
EncodableMap report_map;
754
757
report_map[EncodableValue (" id" )] = EncodableValue (stats->id ().std_string ());
755
- report_map[EncodableValue (" type" )] = EncodableValue (stats->type ().std_string ());
758
+ report_map[EncodableValue (" type" )] =
759
+ EncodableValue (stats->type ().std_string ());
756
760
report_map[EncodableValue (" timestamp" )] =
757
761
EncodableValue (double (stats->timestamp_us ()));
758
762
EncodableMap values;
759
763
auto members = stats->Members ();
760
764
for (int i = 0 ; i < members.size (); i++) {
761
765
auto member = members[i];
762
- if (!member->IsDefined ()) {
766
+ if (!member->IsDefined ()) {
763
767
continue ;
764
768
}
765
- switch (member->GetType ())
766
- {
767
- case RTCStatsMember::Type::kBool :
768
- values[EncodableValue (member->GetName ().std_string ())] =
769
- EncodableValue (member->ValueBool ());
770
- break ;
771
- case RTCStatsMember::Type::kInt32 :
772
- values[EncodableValue (member->GetName ().std_string ())] =
773
- EncodableValue (member->ValueInt32 ());
774
- break ;
775
- case RTCStatsMember::Type::kUint32 :
776
- values[EncodableValue (member->GetName ().std_string ())] =
777
- EncodableValue ((int64_t )member->ValueUint32 ());
778
- break ;
779
- case RTCStatsMember::Type::kInt64 :
780
- values[EncodableValue (member->GetName ().std_string ())] =
781
- EncodableValue (member->ValueInt64 ());
782
- break ;
783
- case RTCStatsMember::Type::kUint64 :
784
- values[EncodableValue (member->GetName ().std_string ())] =
785
- EncodableValue ((int64_t )member->ValueUint64 ());
786
- break ;
787
- case RTCStatsMember::Type::kDouble :
788
- values[EncodableValue (member->GetName ().std_string ())] =
789
- EncodableValue (member->ValueDouble ());
790
- break ;
791
- case RTCStatsMember::Type::kString :
792
- values[EncodableValue (member->GetName ().std_string ())] =
793
- EncodableValue (member->ValueString ().std_string ());
794
- break ;
795
- default :
796
- break ;
769
+ switch (member->GetType ()) {
770
+ case RTCStatsMember::Type::kBool :
771
+ values[EncodableValue (member->GetName ().std_string ())] =
772
+ EncodableValue (member->ValueBool ());
773
+ break ;
774
+ case RTCStatsMember::Type::kInt32 :
775
+ values[EncodableValue (member->GetName ().std_string ())] =
776
+ EncodableValue (member->ValueInt32 ());
777
+ break ;
778
+ case RTCStatsMember::Type::kUint32 :
779
+ values[EncodableValue (member->GetName ().std_string ())] =
780
+ EncodableValue ((int64_t )member->ValueUint32 ());
781
+ break ;
782
+ case RTCStatsMember::Type::kInt64 :
783
+ values[EncodableValue (member->GetName ().std_string ())] =
784
+ EncodableValue (member->ValueInt64 ());
785
+ break ;
786
+ case RTCStatsMember::Type::kUint64 :
787
+ values[EncodableValue (member->GetName ().std_string ())] =
788
+ EncodableValue ((int64_t )member->ValueUint64 ());
789
+ break ;
790
+ case RTCStatsMember::Type::kDouble :
791
+ values[EncodableValue (member->GetName ().std_string ())] =
792
+ EncodableValue (member->ValueDouble ());
793
+ break ;
794
+ case RTCStatsMember::Type::kString :
795
+ values[EncodableValue (member->GetName ().std_string ())] =
796
+ EncodableValue (member->ValueString ().std_string ());
797
+ break ;
798
+ default :
799
+ break ;
797
800
}
798
801
}
799
802
report_map[EncodableValue (" values" )] = EncodableValue (values);
800
803
return report_map;
801
804
}
802
805
803
- void FlutterPeerConnection::GetStats (const std::string& track_id,
804
- RTCPeerConnection* pc,
805
- std::unique_ptr<MethodResultProxy> result) {
806
+ void FlutterPeerConnection::GetStats (
807
+ const std::string& track_id,
808
+ RTCPeerConnection* pc,
809
+ std::unique_ptr<MethodResultProxy> result) {
806
810
std::shared_ptr<MethodResultProxy> result_ptr (result.release ());
807
811
scoped_refptr<RTCMediaTrack> track = base_->MediaTracksForId (track_id);
808
812
if (track != nullptr ) {
@@ -849,23 +853,23 @@ void FlutterPeerConnection::GetStats(const std::string& track_id,
849
853
return ;
850
854
}
851
855
}
852
- if (!found) {
856
+ if (!found) {
853
857
result_ptr->Error (" GetStats" , " Track not found" );
854
858
}
855
859
} else {
856
860
pc->GetStats (
857
861
[result_ptr](const vector<scoped_refptr<MediaRTCStats>> reports) {
858
- std::vector<EncodableValue> list;
859
- for (int i = 0 ; i < reports.size (); i++) {
860
- list.push_back (EncodableValue (statsToMap (reports[i])));
861
- }
862
- EncodableMap params;
863
- params[EncodableValue (" stats" )] = EncodableValue (list);
864
- result_ptr->Success (EncodableValue (params));
865
- },
862
+ std::vector<EncodableValue> list;
863
+ for (int i = 0 ; i < reports.size (); i++) {
864
+ list.push_back (EncodableValue (statsToMap (reports[i])));
865
+ }
866
+ EncodableMap params;
867
+ params[EncodableValue (" stats" )] = EncodableValue (list);
868
+ result_ptr->Success (EncodableValue (params));
869
+ },
866
870
[result_ptr](const char * error) {
867
871
result_ptr->Error (" GetStats" , error);
868
- });
872
+ });
869
873
}
870
874
}
871
875
@@ -899,10 +903,11 @@ void FlutterPeerConnection::MediaStreamRemoveTrack(
899
903
result_ptr->Success ();
900
904
}
901
905
902
- void FlutterPeerConnection::AddTrack (RTCPeerConnection* pc,
903
- scoped_refptr<RTCMediaTrack> track,
904
- std::list<std::string> streamIds,
905
- std::unique_ptr<MethodResultProxy> result) {
906
+ void FlutterPeerConnection::AddTrack (
907
+ RTCPeerConnection* pc,
908
+ scoped_refptr<RTCMediaTrack> track,
909
+ std::list<std::string> streamIds,
910
+ std::unique_ptr<MethodResultProxy> result) {
906
911
std::shared_ptr<MethodResultProxy> result_ptr (result.release ());
907
912
std::string kind = track->kind ().std_string ();
908
913
std::vector<string> streamids;
@@ -938,9 +943,10 @@ FlutterPeerConnection::GetRtpSenderById(RTCPeerConnection* pc, std::string id) {
938
943
return result;
939
944
}
940
945
941
- void FlutterPeerConnection::RemoveTrack (RTCPeerConnection* pc,
942
- std::string senderId,
943
- std::unique_ptr<MethodResultProxy> result) {
946
+ void FlutterPeerConnection::RemoveTrack (
947
+ RTCPeerConnection* pc,
948
+ std::string senderId,
949
+ std::unique_ptr<MethodResultProxy> result) {
944
950
auto sender = GetRtpSenderById (pc, senderId);
945
951
if (nullptr == sender.get ()) {
946
952
result->Error (" RemoveTrack" , " not find RtpSender " );
0 commit comments