1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
203
%j�[�
� @ s� d dl Z d dlZdd� Zdd� Zdd� ZG dd � d �Zed
kr�e� Zd Zd Z ej
ej fZ ee e �Z
eejd
��DZeje
j �Ze
je� x&er�e
j� eje
j �Ze
je� q�W W dQ R X e
j� edejde
j � dS )� Nc C s> t j� } | jdtd� | jdtd� | jdtd� | j� }|S )N�receiver_host_ip)�type�
receiver_port�file)�argparse�ArgumentParser� add_argument�str�int�
parse_args)�parser�args� r �I/tmp_amd/cage/export/cage/1/z5129432/Github/COMP9331_Socket/ass/sender.py�get_args s r c C s& t | �}td|� tt|��}|| S )Nz send package with checksum: )� get_checksum�print�bytes�list)�data�checksumr r r � add_checksum s
r c C s� d}xpt dt| �d�D ]\}|d t| �k rP| | }| |d }|||d> }q|d t| �krn|| | 7 }qd�qW ||d? }| d@ }|d }|d }||fS ) Nr � � � zSomething Wrong here� i�� � )�range�len)�msg�s�i�a�bZhighZlowr r r r ' s
r c @ s4 e Zd Zdd� Zdd� Zdd� Zdd� Zd d
� Zd S ) �Receiverc C sB || _ || _t� | _t� | _t� | _tjtjtj�| _ t
d� d S )NzSocket created!
) �
receiver_addr� buffer_sizer �package�payloadr �socket�AF_INET�
SOCK_DGRAM�sockr )�selfr% r& r r r �__init__A s zReceiver.__init__c C s* || _ t|�| _tt| j��| j | _d S )N)r( r r r r r' )r- r( r r r � make_packageI s
zReceiver.make_packagec C s | j j� d S )N)r, �close)r- r r r r0 M s zReceiver.closec C s | j j| jt�}td| j� |S )Nz send package with checksum: )r, �sendtor' r% r r )r- Z
sent_bytesr r r � send_packageO s zReceiver.send_packagec C sN xH| j � | jj| j�\}}|d }|dkr:td|� P qtd|� qqW d S )Nr r zreceived ACK from: zreceived NAK from: )r2 r, �recvfromr& r )r- Zpkg�addrZackr r r �send_good_packageS s
zReceiver.send_good_packageN)�__name__�
__module__� __qualname__r. r/ r0 r2 r5 r r r r r$ @ s
r$ �__main__z0.0.0.0i �rbz
SendZto)r) r r r r r$ r6 r
�hostr& r r r% �instance�openr �fd�readr r/ r5 r0 r r r r r �<module> s(