Skip to content
Merged
Changes from 1 commit
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
5 changes: 4 additions & 1 deletion livekit/src/room/participant/local_participant.rs
Original file line number Diff line number Diff line change
Expand Up @@ -736,7 +736,10 @@ impl LocalParticipant {
}

pub async fn perform_rpc(&self, data: PerformRpcData) -> Result<String, RpcError> {
let max_round_trip_latency = Duration::from_millis(2000);
// Maximum amount of time it should ever take for an RPC reqest to reach the destination, and the ACK to come back
// This is set to 7 seconds to account for various relay timeouts and retries in LiveKit Cloud that occur in rare cases

let max_round_trip_latency = Duration::from_millis(7000);

if data.payload.len() > MAX_PAYLOAD_BYTES {
return Err(RpcError::built_in(RpcErrorCode::RequestPayloadTooLarge, None));
Expand Down
Loading