Commit ebc65b40d3f653f1e33df409e311548bed703366
1 parent
7f79b925
添加收到invite消息后的日志，减少国标级联推送代理流的等待时间
Showing
2 changed files
with
3 additions
and
4 deletions
src/main/java/com/genersoft/iot/vmp/conf/UserSetting.java
| @@ -23,7 +23,7 @@ public class UserSetting { | @@ -23,7 +23,7 @@ public class UserSetting { | ||
| 23 | 23 | ||
| 24 | private Integer playTimeout = 18000; | 24 | private Integer playTimeout = 18000; |
| 25 | 25 | ||
| 26 | - private int platformPlayTimeout = 60000; | 26 | + private int platformPlayTimeout = 20000; |
| 27 | 27 | ||
| 28 | private Boolean interfaceAuthentication = Boolean.TRUE; | 28 | private Boolean interfaceAuthentication = Boolean.TRUE; |
| 29 | 29 |
src/main/java/com/genersoft/iot/vmp/gb28181/transmit/event/request/impl/InviteRequestProcessor.java
| @@ -147,6 +147,8 @@ public class InviteRequestProcessor extends SIPRequestProcessorParent implements | @@ -147,6 +147,8 @@ public class InviteRequestProcessor extends SIPRequestProcessorParent implements | ||
| 147 | return; | 147 | return; |
| 148 | } | 148 | } |
| 149 | 149 | ||
| 150 | + logger.info("[INVITE] requesterId: {}, callId: {}, 来自：{}：{}", | ||
| 151 | + requesterId, callIdHeader.getCallId(), request.getRemoteAddress(), request.getRemotePort()); | ||
| 150 | 152 | ||
| 151 | // 查询请求是否来自上级平台\设备 | 153 | // 查询请求是否来自上级平台\设备 |
| 152 | ParentPlatform platform = storager.queryParentPlatByServerGBId(requesterId); | 154 | ParentPlatform platform = storager.queryParentPlatByServerGBId(requesterId); |
| @@ -706,9 +708,6 @@ public class InviteRequestProcessor extends SIPRequestProcessorParent implements | @@ -706,9 +708,6 @@ public class InviteRequestProcessor extends SIPRequestProcessorParent implements | ||
| 706 | zlmHttpHookSubscribe.removeSubscribe(hookSubscribe); | 708 | zlmHttpHookSubscribe.removeSubscribe(hookSubscribe); |
| 707 | dynamicTask.stop(callIdHeader.getCallId()); | 709 | dynamicTask.stop(callIdHeader.getCallId()); |
| 708 | } | 710 | } |
| 709 | - | ||
| 710 | - | ||
| 711 | - | ||
| 712 | } else if ("push".equals(gbStream.getStreamType())) { | 711 | } else if ("push".equals(gbStream.getStreamType())) { |
| 713 | if (!platform.isStartOfflinePush()) { | 712 | if (!platform.isStartOfflinePush()) { |
| 714 | // 平台设置中关闭了拉起离线的推流则直接回复 | 713 | // 平台设置中关闭了拉起离线的推流则直接回复 |