Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- # client recv_into
- import socket
- addr = ('127.0.0.1', 8080)
- file = 'test.bin'
- data = bytearray(8128)
- view = memoryview(data)
- with socket.socket() as sock:
- sock.connect(addr)
- print('Connected')
- with open(file, 'wb') as fd:
- while True:
- size = sock.recv_into(data)
- if not size:
- print('EOF')
- break
- fd.write(view[:size])
- print('{} has been written.'.format(file))
- ################################################################
- # server sendfile
- import threading
- import socket
- def handler(sock, file):
- with open(file, 'rb') as fd:
- sock.sendfile(fd)
- sock.close()
- addr = ('127.0.0.1', 8080)
- file_to_send = 'tunnel.sh'
- with socket.socket() as sock:
- sock.bind(addr)
- sock.listen(5)
- while True:
- client_sock, client_addr = sock.accept()
- threading.Thread(target=handler, args=(client_sock, file_to_send)).start()
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement