-
Notifications
You must be signed in to change notification settings - Fork 2
/
Copy pathreciever.py
61 lines (45 loc) · 1.26 KB
/
reciever.py
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
# -*- coding: utf-8 -*-
"""
Created on Tue May 3 15:10:26 2022
@author: ACER
"""
# Reciever
import socket
import cv2
import pickle
import struct
def get_ip_address():
s = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
s.connect(("8.8.8.8", 80))
return s.getsockname()[0]
# Socket creation
cln_sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
host_ip = input(
f"Kindly input server Ip address \nEx:{get_ip_address()} \nif same as server hit 'y' and enter \nYour Input: ")
if host_ip == "y":
host_ip = get_ip_address()
print(f"Reciever IP {host_ip}")
port = 9999
socket_address = (host_ip, port)
cln_sock.connect(socket_address)
data = b""
payload_size = struct.calcsize("Q")
while True:
while len(data) < payload_size:
packet = cln_sock.recv(4*1024)
if not packet:
break
data += packet
packed_msg_size = data[:payload_size]
data = data[payload_size:]
msg_size = struct.unpack("Q", packed_msg_size)[0]
while len(data) < msg_size:
data += cln_sock.recv(4*1024)
frame_data = data[:msg_size]
data = data[msg_size:]
frame = pickle.loads(frame_data)
cv2.imshow("Recieved Video", frame)
key = cv2.waitKey(1) & 0xff
if key == ord('q'):
break
cln_sock.close()