Package flumotion :: Package component :: Package common :: Package streamer :: Module mfdsresources :: Class MultiFdSinkStreamingResource

Class MultiFdSinkStreamingResource

twisted.web.resource.Resource --+    
                                |    
      extern.log.log.Loggable --+    
                                |    
  resources.HTTPStreamingResource --+
                                    |
          extern.log.log.Loggable --+
                                    |
                                   MultiFdSinkStreamingResource

Instance Methods

__init__(self, streamer, httpauth)

source code

source code

clientRemoved(self, sink, fd, reason, stats)

source code

_logWrite(self, request, stats)

source code

_removeClient(self, request, fd, stats)
Removes a request and add logging.

source code

handleAuthenticatedRequest(self, res, request)

source code

_formatHeaders(self, request)

source code

boolean

_writeHeaders(self, request)
Write out the HTTP headers for the incoming HTTP request.

source code

_handleNewClient(self, request)

source code

_render(self, request)

source code

render_GET(self, request)

source code

render_HEAD(self, request)

source code

Inherited from resources.HTTPStreamingResource: getMaxAllowedClients, logWrite, reachedServerLimits, removeAllClients, rotateLogs, setBandwidthLimit, setLogFilter, setRedirectionOnLimits, setRoot, setUserLimit

Inherited from resources.HTTPStreamingResource (private): _addClient, _getExtraLogArgs, _handleNotReady, _handleServerFull, _logRequestFromIP, _setRequestHeaders

Inherited from extern.log.log.Loggable: debug, doLog, error, info, log, logFunction, logObjectName, warning, warningFailure, writeMarker

Class Variables

Inherited from resources.HTTPStreamingResource: HTTP_NAME, HTTP_SERVER, __reserve_fds__, isLeaf, logCategory

Method Details

init(self, streamer, httpauth)
(Constructor)

Parameters:

streamer - Streamer

Overrides: resources.HTTPStreamingResource.__init__

(inherited documentation)

isReady(self)

Overrides: resources.HTTPStreamingResource.isReady

_removeClient(self, request, fd, stats)

Removes a request and add logging. Note that it does not disconnect the client; it is called in reaction to a client disconnecting.

Parameters:

request (twisted.protocols.http.Request) - the request
fd (int) - the file descriptor for the client being removed
stats (GValueArray) - the statistics for the removed client

Overrides: resources.HTTPStreamingResource._removeClient

_writeHeaders(self, request)

Write out the HTTP headers for the incoming HTTP request.

Returns: boolean: whether or not the file descriptor can be used further.