Method alloc_block

src/core/algorithm/flat/flat_streamer_entity.cc:812–854

}

int FlatStreamerEntity::alloc_block(const BlockLocation &next,
                                    BlockLocation *block) {
  if (segments_.size() <= 1 ||
      segments_.back()->padding_size() < linear_block_size()) {
    int ret = this->alloc_segment();
    if (ailego_unlikely(ret != 0)) {
      return ret;
    }
  }

  auto &segment = segments_.back();
  size_t block_index = segment->data_size() / linear_block_size();
  if (block_index == kMaxBlockId) {
    LOG_ERROR("Failed to alloc block, exceed max count %zu per segment",
              kMaxBlockId);
    return IndexError_IndexFull;
  }

  BlockHeader header;
  header.next = next;
  header.vector_count = 0;
  header.column_major = false;

  size_t hd_off = segment->data_size() + linear_block_size() - sizeof(header);
  if (segment->write(hd_off, &header, sizeof(header)) != sizeof(header)) {
    LOG_ERROR("Failed to write block header");
    return IndexError_WriteData;
  }

  size_t del_off = hd_off - sizeof(DeletionMap);
  DeletionMap reset_del_map{};
  if (segment->write(del_off, &reset_del_map, sizeof(reset_del_map)) !=
      sizeof(reset_del_map)) {
    LOG_ERROR("Failed to write block deletion map");
    return IndexError_WriteData;
  }

  ++meta_.header.block_count;
  block->segment_id = segments_.size() - 1;
  block->block_index = (segment->data_size() / linear_block_size()) - 1;

  return 0;
}

int FlatStreamerEntity::add_to_block(const BlockLocation &block, uint64_t key,
                                     const void *data, size_t size) {