iframe-proxy | Sunbelt Computer Software

43 lines (29 loc) · 1.04 KB

import threading
import socketserver
class ThreadedTCPServer(socketserver.ThreadingMixIn, socketserver.TCPServer):
class ThreadedTCPRequestHandler(socketserver.BaseRequestHandler):
    def handle(self):
        data = self.request.recv(1024)
        self.server.queue.add(data)
class Queue:
    def __init__(self, ip, port):
        self.server = ThreadedTCPServer((ip, port), ThreadedTCPRequestHandler)
        self.server.queue = self
        self.server_thread = threading.Thread(target=self.server.serve_forever)
        self.server_thread.daemon = True
        self.messages = []
    def start_server(self):
        self.server_thread.start()
        print("Server loop running in thread:", self.server_thread.name)
    def stop_server(self):
        self.server.shutdown()
        self.server.server_close()
    def add(self, message):
        self.messages.append(message)
    def view(self):
        return self.messages
    def get(self):
        return self.messages.pop()
    def exists(self):
        return len(self.messages)

Sunbelt Computer Software

PL/B Language Development and Support

Provide feedback

Saved searches

Use saved searches to filter your results more quickly

Uh oh!

Sunbelt Computer Software

PL/B Language Development and Support

Uh oh!

FilesExpand file tree

codex_queue.py

Latest commit

History

codex_queue.py

File metadata and controls