11

controller/index.py

@@ -223,7 +223,8 @@ class oa2RtspStartView(TemplateView):
                     return JsonResponse({'msg': 'stop yes', 'code': 0})
                 else:
                     return JsonResponse({'msg': 'stop no', 'code': 0})
-            threading.Thread(target=runSendRtspMsg_thread, args=(UID, PWD, MSG)).start()
+            # threading.Thread(target=runSendRtspMsg_thread, args=(UID, PWD, MSG)).start()
+            send_flag = self.runSendRtspMsg(UID,PWD,MSG)
             res_json = {
                 'endpointId': id,
                 'manufacturerName': 'Axis',
@@ -239,7 +240,8 @@ class oa2RtspStartView(TemplateView):
                 'authorizationTypes': ['NONE'],
                 'uri': 'rtsp://{RESP_SERVER_DOMAIN}:443/{stream_name}'.format(RESP_SERVER_DOMAIN=RESP_SERVER_DOMAIN,stream_name=ur_qs[0]['rtsp_url'])
             }
-            redisObj.set_data(key=key, val=str(res_json), expire=30)
+            if send_flag:
+                redisObj.set_data(key=key, val=str(res_json), expire=30)
             return JsonResponse(res_json, safe=False)
         else:
             return JsonResponse({'msg': 'wrong'})