Package pyspark :: Module accumulators :: Class AccumulatorServer

Class AccumulatorServer

SocketServer.BaseServer --+    
                          |    
     SocketServer.TCPServer --+
                              |
                             AccumulatorServer

A simple TCP server that intercepts shutdown() in order to interrupt our continuous polling on the handler.

Instance Methods

shutdown(self)
Stops the serve_forever loop.

source code

Inherited from SocketServer.TCPServer: __init__, close_request, fileno, get_request, server_activate, server_bind, server_close, shutdown_request

Inherited from SocketServer.BaseServer: finish_request, handle_error, handle_request, handle_timeout, process_request, serve_forever, verify_request

Class Variables

server_shutdown = False

Inherited from SocketServer.TCPServer: address_family, allow_reuse_address, request_queue_size, socket_type

Inherited from SocketServer.BaseServer: timeout

Method Details

shutdown(self)

source code

Stops the serve_forever loop.

Blocks until the loop has finished. This must be called while serve_forever() is running in another thread, or it will deadlock.

Overrides: SocketServer.BaseServer.shutdown: (inherited documentation)