Commit a57f64b8 authored by Paul Asmuth's avatar Paul Asmuth
Browse files

continue from feed HEAD

parent d5fa1d53

fnord-feeds/LocalFeed.cc

+4 −0
Original line number Diff line number Diff line
@@ -117,6 +117,10 @@ std::vector<FeedEntry> LogStream::fetch(uint64_t offset, int batch_size) { 
    cursor = table->writer->getCursor();

  }



  if (offset == std::numeric_limits<uint64_t>::max()) {

    offset = head_offset_;

  }



  if (offset > 0) {

#ifndef FNORD_NOTRACE

    fnord::logTrace(

fnord-feeds/fn-feedtail.cc

+5 −1
Original line number Diff line number Diff line
@@ -134,8 +134,12 @@ int main(int argc, const char** argv) { 
    std::string offset_str;

    uint64_t offset = 0;

    if (URI::getParam(params, "offset", &offset_str)) {

      if (offset_str == "HEAD") {

        offset = std::numeric_limits<uint64_t>::max();

      } else {

        offset = std::stoul(offset_str);

      }

    }



    feed_reader.addSourceFeed(

        uri,

CRA Git | Maintained and supported by SUSTech CRA and CCSE