Package flumotion :: Package component :: Package misc :: Package httpserver :: Package httpcached :: Module strategy_base :: Class BlockRequester
[hide private]

Class BlockRequester

source code

             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 [hide private]
 
__init__(self, reqmgr, url, mtime=None)
x.__init__(...) initializes x; see help(type(x)) for signature
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 object: __delattr__, __format__, __getattribute__, __hash__, __new__, __reduce__, __reduce_ex__, __repr__, __setattr__, __sizeof__, __str__, __subclasshook__

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

Class Variables [hide private]
  logCategory = 'block-requester'
Implementors can provide a category to log their messages under.

Inherited from extern.log.log.Loggable: __implemented__

Properties [hide private]

Inherited from object: __class__

Method Details [hide private]

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

source code 

x.__init__(...) initializes x; see help(type(x)) for signature

Overrides: object.__init__
(inherited documentation)

serverError(self, getter, code, message)

source code 
Overrides: common.StreamConsumer.serverError

conditionFail(self, getter, code, message)

source code 
Overrides: common.StreamConsumer.conditionFail

streamNotAvailable(self, getter, code, message)

source code 
Overrides: common.StreamConsumer.streamNotAvailable

onData(self, getter, data)

source code 
Overrides: common.StreamConsumer.onData

streamDone(self, getter)

source code 
Overrides: common.StreamConsumer.streamDone