Python Unlocked by unknow

Author:unknow
Language: eng
Format: epub
Publisher: Packt Publishing

Once we use up memory of a single computer, or have files distributed over multiple computers in a network, the file-based algorithm will not work. We will need to sort incoming streams from upstream servers, and send the sorted stream to the downstream. If we look at the following code carefully, we will see that we have not changed the underlying mechanism. We are still using heapq.merge to merge elements, but now, we are getting elements from the network instead. The following client code is simple, it just starts sending sorted lines by lines on receive of the next command from a downstream server:

import socket import sys from sort2 import dosort2 HOST = '127.0.0.1' PORT = 9002 NCLIENTS = 2 class Client(object): def __init__(self,HOST,PORT,filename): self.skt = socket.socket(socket.AF_INET,socket.SOCK_STREAM) self.skt.connect((HOST,PORT)) self.filename = filename self.skt.setblocking(True) def run(self): for line in dosort2(self.filename): print("for",line) data = self.skt.recv(1024) print("data cmd",data) if data == b'next\r\n': data = None self.skt.send(line[1].encode()) else: print("got from server",data) print("closing socket") self.skt.close() c = Client(HOST,PORT,sys.argv[1]) c.run()

Download

Copyright Disclaimer:
This site does not store any files on its server. We only index and link to content provided by other sites. Please contact the content providers to delete copyright contents if any and email us, we'll remove relevant links or contents immediately.