|
|
@ -390,6 +390,11 @@ public class RtmpConnection implements RtmpPublisher, PacketRxHandler, ThreadCon
|
|
|
|
} else if (thread instanceof WriteThread && thread.isAlive()) {
|
|
|
|
} else if (thread instanceof WriteThread && thread.isAlive()) {
|
|
|
|
((WriteThread) thread).shutdown();
|
|
|
|
((WriteThread) thread).shutdown();
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
try {
|
|
|
|
|
|
|
|
thread.join();
|
|
|
|
|
|
|
|
} catch (InterruptedException ie) {
|
|
|
|
|
|
|
|
ie.printStackTrace();
|
|
|
|
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
if (socket != null) {
|
|
|
|
if (socket != null) {
|
|
|
@ -437,4 +442,4 @@ public class RtmpConnection implements RtmpPublisher, PacketRxHandler, ThreadCon
|
|
|
|
audio.getHeader().setAbsoluteTimestamp(dts);
|
|
|
|
audio.getHeader().setAbsoluteTimestamp(dts);
|
|
|
|
writeThread.send(audio);
|
|
|
|
writeThread.send(audio);
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|