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
|