Skip to content

Commit

Permalink
-
Browse files Browse the repository at this point in the history
  • Loading branch information
olofkallander committed Nov 9, 2023
1 parent 5d5a3bd commit 8c80f0d
Show file tree
Hide file tree
Showing 2 changed files with 5 additions and 8 deletions.
2 changes: 1 addition & 1 deletion test/integration/IceTransportTest.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -49,7 +49,7 @@ TEST_F(IceTransportEmuTest, plainNewApi)
cfgBuilder.url(baseUrl).withOpus().withVideo();

auto cfgInitiator(cfgBuilder);
cfgInitiator.delayIpv6(2500);
cfgInitiator.delayIpv6(250);

group.clients[0]->initiateCall(cfgInitiator.build());
group.clients[1]->joinCall(cfgBuilder.build());
Expand Down
11 changes: 4 additions & 7 deletions transport/TransportImpl.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -661,8 +661,6 @@ void TransportImpl::stop()
_isRunning = false;

_jobQueue.post(_jobCounter, [this]() { internalShutdown(); });
_isInitialized = false;

_jobQueue.post(_jobCounter, [this]() { internalUnregisterEndpoints(); });
}

Expand All @@ -675,16 +673,15 @@ void TransportImpl::internalShutdown()

if (_srtpClient)
{
_jobQueue.post(_jobCounter, [this]() {
_selectedRtp = nullptr;
_srtpClient->stop();
});
_selectedRtp = nullptr;
_srtpClient->stop();
}

if (_sctpAssociation)
{
_sctpAssociation->close();
}
_isInitialized = false;
}

void TransportImpl::internalUnregisterEndpoints()
Expand Down Expand Up @@ -2010,7 +2007,7 @@ void TransportImpl::onIceCompleted(ice::IceSession* session)
void TransportImpl::onIceStateChanged(ice::IceSession* session, const ice::IceSession::State state)
{
_iceState = state;
_isConnected = _selectedRtp && (!_srtpClient || _srtpClient->isConnected());
_isConnected = _selectedRtp && _srtpClient->isConnected();

switch (state)
{
Expand Down

0 comments on commit 8c80f0d

Please sign in to comment.