X-Git-Url: https://git.novaco.in/?a=blobdiff_plain;f=transports%2Fstratum_http.py;h=6e13aac41f0736531dbb62df11016413cf17f470;hb=08cf934e360070582956a69ad0d077d6d6092025;hp=25e07387de4c24a48dce7baed421eddc8858c1eb;hpb=54dbaa1d8ae01b09fb24ceb7e247024add7aab32;p=electrum-server.git diff --git a/transports/stratum_http.py b/transports/stratum_http.py index 25e0738..6e13aac 100644 --- a/transports/stratum_http.py +++ b/transports/stratum_http.py @@ -47,11 +47,7 @@ from the processor point of view: """ -def random_string(N): - import random, string - return ''.join(random.choice(string.ascii_uppercase + string.digits) for x in range(N)) - - +from processor import random_string def get_version(request): @@ -259,7 +255,6 @@ class StratumJSONRPCServer(SocketServer.TCPServer, StratumJSONRPCDispatcher): self.sessions = {} - def create_session(self): session_id = random_string(10) self.sessions[session_id] = HttpSession(session_id) @@ -283,7 +278,8 @@ class HttpSession(Session): def __init__(self, session_id): Session.__init__(self) self.pending_responses = Queue.Queue() - print "new http session", session_id + self.address = session_id + self.name = "HTTP session" def send_response(self, response): raw_response = json.dumps(response) @@ -307,6 +303,7 @@ class HttpServer(threading.Thread): self.server = StratumThreadedJSONRPCServer(( self.host, self.port)) self.server.dispatcher = self.dispatcher self.server.register_function(None, 'server.stop') + self.server.register_function(None, 'server.info') print "HTTP server started." self.server.serve_forever()