Package org.red5.server.net.rtmp

Class ReceivedMessageTaskQueue.DeadlockGuard

java.lang.Object

org.red5.server.net.rtmp.ReceivedMessageTaskQueue.DeadlockGuard

All Implemented Interfaces:

Runnable

Enclosing class:

ReceivedMessageTaskQueue

private class ReceivedMessageTaskQueue.DeadlockGuard
extends Object
implements Runnable

Prevents deadlocked message handling.

Field Summary

Fields

Modifier and Type	Field	Description
private final ReceivedMessageTask	task

Constructor Summary

Constructors

Modifier	Constructor	Description
private	DeadlockGuard(ReceivedMessageTask task)	Creates the deadlock guard to prevent a message task from taking too long to setProcessing.

Method Summary

Modifier and Type	Method	Description
void	run()	Save the reference to the task, and wait until the maxHandlingTimeout has elapsed.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

task

private final ReceivedMessageTask task

Constructor Details

DeadlockGuard

private DeadlockGuard(ReceivedMessageTask task)

Creates the deadlock guard to prevent a message task from taking too long to setProcessing.

Parameters:

task -

Method Details

run

public void run()

Save the reference to the task, and wait until the maxHandlingTimeout has elapsed. If it elapsed, remove task and stop its thread.

Specified by:

run in interface Runnable