Method ProcessBatch

core/modules/generic_encap.cc:128–163

}

void GenericEncap::ProcessBatch(Context *ctx, bess::PacketBatch *batch) {
  int cnt = batch->cnt();

  int encap_size = encap_size_;

  char headers[bess::PacketBatch::kMaxBurst][MAX_HEADER_SIZE] __ymm_aligned;

  for (int i = 0; i < num_fields_; i++) {
    uint64_t value = fields_[i].value;

    int attr_id = fields_[i].attr_id;
    int offset = (attr_id >= 0) ? attr_offset(attr_id) : 0;

    char *header = headers[0] + fields_[i].pos;

    for (int j = 0; j < cnt; j++, header += MAX_HEADER_SIZE) {
      bess::Packet *pkt = batch->pkts()[j];
      *(reinterpret_cast<uint64_t *>(header)) =
          (attr_id < 0) ? value : get_attr_with_offset<uint64_t>(offset, pkt);
    }
  }

  for (int i = 0; i < cnt; i++) {
    bess::Packet *pkt = batch->pkts()[i];

    char *p = static_cast<char *>(pkt->prepend(encap_size));

    if (unlikely(!p)) {
      continue;
    }

    bess::utils::CopyInlined(p, headers[i], encap_size);
  }

  RunNextModule(ctx, batch);
}

ADD_MODULE(GenericEncap, "generic_encap",
           "encapsulates packets with constant values and metadata attributes")