Lines Matching refs:request
15 For request-based servers (including socket-based):
17 - client address verification before further looking at the request
19 at the request before anything else, e.g. logging)
21 - synchronous (one request is handled at a time)
22 - forking (each request is handled by a new process)
23 - threading (each request is handled by a new thread)
65 with your request handler class.
67 The request handler class must be different for datagram or stream
68 services. This can be hidden by using the request handler
83 class will essentially render the service "deaf" while one request is
88 In some cases, it may be appropriate to process part of a request
90 the request data. This can be implemented by using a synchronous
91 server and doing an explicit fork in the request handler class
98 decide which request to work on next (or whether to handle a new
99 incoming request). This is particularly important for stream services
113 - split generic "request" functionality out into BaseServer class.
176 - get_request() -> request, client_address
178 - verify_request(request, client_address)
180 - process_request(request, client_address)
181 - shutdown_request(request)
182 - close_request(request)
187 - finish_request(request, client_address)
222 """Handle one request at a time until shutdown.
234 # shutdown request and wastes cpu at all other times.
254 # finishing a request is fairly arbitrary. Remember:
260 # or create a new thread to finish the request
261 # - finish_request() instantiates the request handler class;
262 # this constructor will handle the request all by itself
265 """Handle one request, possibly blocking.
283 """Handle one request, without blocking.
290 request, client_address = self.get_request()
293 if self.verify_request(request, client_address):
295 self.process_request(request, client_address)
297 self.handle_error(request, client_address)
298 self.shutdown_request(request)
301 """Called if no new request arrives within self.timeout.
307 def verify_request(self, request, client_address):
308 """Verify the request. May be overridden.
310 Return True if we should proceed with this request.
315 def process_request(self, request, client_address):
321 self.finish_request(request, client_address)
322 self.shutdown_request(request)
332 def finish_request(self, request, client_address):
333 """Finish one request by instantiating RequestHandlerClass."""
334 self.RequestHandlerClass(request, client_address, self)
336 def shutdown_request(self, request):
337 """Called to shutdown and close an individual request."""
338 self.close_request(request)
340 def close_request(self, request):
341 """Called to clean up an individual request."""
344 def handle_error(self, request, client_address):
351 print 'Exception happened during processing of request from',
376 - get_request() -> request, client_address
378 - verify_request(request, client_address)
379 - process_request(request, client_address)
380 - shutdown_request(request)
381 - close_request(request)
386 - finish_request(request, client_address)
458 """Get the request and client address from the socket.
465 def shutdown_request(self, request):
466 """Called to shutdown and close an individual request."""
470 request.shutdown(socket.SHUT_WR)
473 self.close_request(request)
475 def close_request(self, request):
476 """Called to clean up an individual request."""
477 request.close()
498 def shutdown_request(self, request):
500 self.close_request(request)
502 def close_request(self, request):
508 """Mix-in class to handle each request in a new process."""
553 def process_request(self, request, client_address):
554 """Fork a new subprocess to process the request."""
562 self.close_request(request) #close handle in parent process
568 self.finish_request(request, client_address)
569 self.shutdown_request(request)
573 self.handle_error(request, client_address)
574 self.shutdown_request(request)
580 """Mix-in class to handle each request in a new thread."""
586 def process_request_thread(self, request, client_address):
593 self.finish_request(request, client_address)
594 self.shutdown_request(request)
596 self.handle_error(request, client_address)
597 self.shutdown_request(request)
599 def process_request(self, request, client_address):
600 """Start a new thread to process the request."""
602 args = (request, client_address))
627 """Base class for request handler classes.
629 This class is instantiated for each request to be handled. The
630 constructor sets the instance variables request, client_address
635 The handle() method can find the request as self.request, the
638 separate instance is created for each request, the handle() method
643 def __init__(self, request, client_address, server):
644 self.request = request
666 # - rfile: a file object from which receives the request is read
685 # A timeout to apply to the request socket, if not None.
693 self.connection = self.request
726 self.packet, self.socket = self.request
