Safe

frameStream.py

@@ -30,16 +30,12 @@ def start(self):
                 pass
         print("Stream from the remote device is ended")
 
-
-
-
 
-
 class VideoStreamWidget(object):
     def __init__(self, src=0, onRPI=False):
         self.sender = imagezmq.ImageSender(connect_to='tcp://*:5555', REQ_REP=False)
         self.sender.zmq_socket.setsockopt(zmq.CONFLATE, 1)
-        self.sender.zmq_socket.setsockopt(zmq.SNDHWM, 1)
+        self.sender.zmq_socket.setsockopt(zmq.., 1)
         self.sender.zmq_socket.setsockopt( zmq.LINGER, 0 )
 
         if onRPI == False:

server.py

@@ -194,7 +194,7 @@ def encoding_img(IMAGE_FILES):
     while streaming_flag:
         rpi_name, img = image_hub.recv_image()
 
-#        success, img = cap.read()
+#       success, img = cap.read()
         imgc = cv2.resize(img, (0, 0), None, 0.25, 0.25)
         # converting image to RGB from BGR
         imgc = cv2.cvtColor(img, cv2.COLOR_BGR2RGB)
@@ -240,10 +240,10 @@ def encoding_img(IMAGE_FILES):
             break
 
 
-def start_streaming():
-    fs = frameStream()
-    fs.start()
-    print("STREAM THREAD JOINED")
+# def start_streaming():
+#     fs = frameStream()
+#     fs.start()
+#     print("STREAM THREAD JOINED")
 
 
 @app.route('/video_feed')
@@ -255,14 +255,13 @@ def video_feed():
     print("Other frame stream:", streaming_flag)
     if streaming_flag == False:
         streaming_flag = True
-        streamer = Thread(target = start_streaming, args=())
-        streamer.start()
+        #streamer = Thread(target = start_streaming, args=())
+        #streamer.start()
         print("Remote capture started")
     return Response(gen(room_number),
                     mimetype='multipart/x-mixed-replace; boundary=frame')
 
 
 def start_server():
     app.run(debug=False , host="0.0.0.0", port="80")
-    print("Program ended")
-
+    print("Program ended")