Package flumotion :: Package component :: Package misc :: Package httpserver :: Package httpcached :: Module strategy_base :: Class BlockRequester

type BlockRequester

             object --+    
                      |    
  common.StreamConsumer --+
                          |
extern.log.log.Loggable --+
                          |
                         BlockRequester

Retrieves a block of data using a range request. A modification time can be specified for the retrieval to fail if the requested file modification time changed.

The data is returned as a block by triggering the deferred returned by calling the retrieve method.

It can recover request failures up to MAX_RESUME_COUNT times.

Instance Methods

__init__(self, reqmgr, url, mtime=None)

source code

retrieve(self, offset, size)

source code

serverError(self, getter, code, message)

source code

conditionFail(self, getter, code, message)

source code

streamNotAvailable(self, getter, code, message)

source code

onData(self, getter, data)

source code

streamDone(self, getter)

source code

_retrieve(self)

source code

_cleanup(self)

source code

Inherited from common.StreamConsumer: onInfo

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

Class Variables

logCategory = 'block-requester'
Implementors can provide a category to log their messages under.

Inherited from extern.log.log.Loggable: __implemented__

Method Details

init(self, reqmgr, url, mtime=None)
(Constructor)

Overrides: object.__init__: (inherited documentation)

serverError(self, getter, code, message)

Overrides: common.StreamConsumer.serverError

conditionFail(self, getter, code, message)

Overrides: common.StreamConsumer.conditionFail

streamNotAvailable(self, getter, code, message)

Overrides: common.StreamConsumer.streamNotAvailable

onData(self, getter, data)

Overrides: common.StreamConsumer.onData

streamDone(self, getter)

Overrides: common.StreamConsumer.streamDone