| | |
| | | if (callId != null) { |
| | | // 权限校验 |
| | | StreamAuthorityInfo streamAuthorityInfo = redisCatchStorage.getStreamAuthorityInfo(app, stream); |
| | | if (streamAuthorityInfo.getCallId().equals(callId)) { |
| | | if (streamAuthorityInfo != null |
| | | && streamAuthorityInfo.getCallId() != null |
| | | && streamAuthorityInfo.getCallId().equals(callId)) { |
| | | authority = true; |
| | | }else { |
| | | throw new ControllerException(ErrorCode.ERROR400); |
| | |
| | | try { |
| | | Thread.sleep(1000); |
| | | } catch (InterruptedException e) { |
| | | e.printStackTrace(); |
| | | logger.error("[线程休眠失败], {}", e.getMessage()); |
| | | } |
| | | if (useSourceIpAsStreamIp != null && useSourceIpAsStreamIp) { |
| | | String host = request.getHeader("Host"); |