YangWX/crossdesk
1
0
Fork 0
mirror of https://github.com/kunkundi/crossdesk.git synced 2025-10-26 12:15:34 +08:00
Code Issues Packages Projects Releases Wiki Activity

Check ice status by using ice_transmission::state_ instead of nice_agent_get_component_state() method

Browse Source
This commit is contained in:
dijunkun
2024-06-14 13:43:21 +08:00
parent c575a9170c
commit 28fb35faf5
2 changed files with 25 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
src/ice/ice_agent.cpp
View File

@@ -228,11 +228,11 @@ int IceAgent::Send(const char *data, size_t size) {
return -1;
}
if (NiceComponentState::NICE_COMPONENT_STATE_READY !=
nice_agent_get_component_state(agent_, stream_id_, 1)) {
LOG_ERROR("Nice agent not ready");
return -1;
}
// if (NiceComponentState::NICE_COMPONENT_STATE_READY !=
// nice_agent_get_component_state(agent_, stream_id_, 1)) {
// LOG_ERROR("Nice agent not ready");
// return -1;
// }
nice_agent_send(agent_, stream_id_, 1, size, data);
return 0;

20
src/transmission/ice_transmission.cpp
View File

@@ -53,6 +53,10 @@ int IceTransmission::InitIceTransmission(
return -1;
}
if (state_ != NICE_COMPONENT_STATE_READY) {
return -2;
}
return ice_agent_->Send(data, size);
});
rtp_video_receiver_->SetOnReceiveCompleteFrame(
@@ -73,6 +77,10 @@ int IceTransmission::InitIceTransmission(
return -1;
}
if (state_ != NICE_COMPONENT_STATE_READY) {
return -2;
}
return ice_agent_->Send(data, size);
});
@@ -93,6 +101,10 @@ int IceTransmission::InitIceTransmission(
return -1;
}
if (state_ != NICE_COMPONENT_STATE_READY) {
return -2;
}
return ice_agent_->Send(data, size);
});
@@ -106,6 +118,10 @@ int IceTransmission::InitIceTransmission(
return -1;
}
if (state_ != NICE_COMPONENT_STATE_READY) {
return -2;
}
return ice_agent_->Send(data, size);
});
@@ -119,6 +135,10 @@ int IceTransmission::InitIceTransmission(
return -1;
}
if (state_ != NICE_COMPONENT_STATE_READY) {
return -2;
}
return ice_agent_->Send(data, size);
});
rtp_data_receiver_->SetOnReceiveData(