mirror of
https://github.com/mii443/libdatachannel.git
synced 2025-09-03 15:49:28 +00:00
Added PeerConnection::close() calls to test
This commit is contained in:
@ -50,6 +50,8 @@ void PeerConnection::close() {
|
|||||||
closeDataChannels();
|
closeDataChannels();
|
||||||
mDataChannels.clear();
|
mDataChannels.clear();
|
||||||
|
|
||||||
|
changeState(State::Disconnected);
|
||||||
|
|
||||||
// Close Transports
|
// Close Transports
|
||||||
if (auto transport = std::atomic_load(&mIceTransport))
|
if (auto transport = std::atomic_load(&mIceTransport))
|
||||||
transport->stop();
|
transport->stop();
|
||||||
@ -58,7 +60,6 @@ void PeerConnection::close() {
|
|||||||
if (auto transport = std::atomic_load(&mSctpTransport))
|
if (auto transport = std::atomic_load(&mSctpTransport))
|
||||||
transport->stop();
|
transport->stop();
|
||||||
|
|
||||||
// Change state
|
|
||||||
changeState(State::Closed);
|
changeState(State::Closed);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@ -102,8 +102,8 @@ int main(int argc, char **argv) {
|
|||||||
this_thread::sleep_for(3s);
|
this_thread::sleep_for(3s);
|
||||||
|
|
||||||
if (dc1->isOpen() && dc2->isOpen()) {
|
if (dc1->isOpen() && dc2->isOpen()) {
|
||||||
dc1->close();
|
pc1->close();
|
||||||
dc2->close();
|
pc2->close();
|
||||||
|
|
||||||
cout << "Success" << endl;
|
cout << "Success" << endl;
|
||||||
return 0;
|
return 0;
|
||||||
|
Reference in New Issue
Block a user