Propagate timestamps in pipeline, implement working disk writes.