wvp-pro.git - Gitblit

old mode 100644 new mode 100755

			@@ -31,6 +31,7 @@
			import javax.sip.message.Response;
			import java.text.ParseException;
			import java.util.HashMap;
			import java.util.List;
			import java.util.Map;

			/**
			@@ -138,7 +139,7 @@
			logger.info("[收到bye] {} 通知设备停止推流时未找到设备信息", streamId);
			}
			try {
			logger.warn("[停止点播] {}/{}", sendRtpItem.getDeviceId(), sendRtpItem.getChannelId());
			logger.info("[停止点播] {}/{}", sendRtpItem.getDeviceId(), sendRtpItem.getChannelId());
			cmder.streamByeCmd(device, sendRtpItem.getChannelId(), streamId, null);
			} catch (InvalidArgumentException \| ParseException \| SipException \|
			SsrcTransactionNotFoundException e) {
			@@ -149,7 +150,7 @@
			}else {

			// 可能是设备发送的停止
			SsrcTransaction ssrcTransaction = streamSession.getSsrcTransaction(null, null, callIdHeader.getCallId(), null);
			SsrcTransaction ssrcTransaction = streamSession.getSsrcTransactionByCallId(callIdHeader.getCallId());
			if (ssrcTransaction == null) {
			return;
			}
			@@ -178,7 +179,7 @@
			if (mediaServerItem != null) {
			mediaServerService.releaseSsrc(mediaServerItem.getId(), ssrcTransaction.getSsrc());
			}
			streamSession.remove(device.getDeviceId(), channel.getChannelId(), ssrcTransaction.getStream());
			streamSession.removeByCallId(device.getDeviceId(), channel.getChannelId(), ssrcTransaction.getCallId());
			}
			}
			}