Offers a IPushProducer interface to a caching session. It starts
producing data from the specified point.
If the data is already cached by the session, it produce data with a
reactor loop reading the data from the session by block.
If the data is not yet cached, it starts a request using the request
manager and pipeline the data to the specified consumer.
It can recover request failures up to MAX_RESUME_COUNT times.
It's not used yet in the context of http-server. Until now, the
simulations show that using a producer with long-lived HTTP requests
instead of short lived block request is less efficient and produce bigger
latency for the clients. At least when used with HTTP proxies.
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
Inherited from common.StreamConsumer :
onInfo
Inherited from extern.log.log.Loggable :
__providedBy__ ,
__provides__ ,
debug ,
doLog ,
error ,
info ,
log ,
logFunction ,
logObjectName ,
warning ,
warningFailure ,
writeMarker
|