folly::IOBuf 분석 — zero-copy buffer chain의 기본 단위

1
HTTP Response = [header bytes] + [chunked body] + [trailer]

1
header IOBuf ──▶ body IOBuf ──▶ trailer IOBuf
2
   [128B]          [102400B]        [16B]

1
// folly/io/IOBuf.h (요약)
2
class IOBuf {
3
  uint8_t* data_;          // 현재 valid data 시작
4
  uint64_t length_;        // valid data 크기
5
  uint8_t* buf_;           // 전체 buffer 시작
6
  uint64_t capacity_;      // 전체 buffer 크기
7

8
  IOBuf* next_;            // chain 다음
9
  IOBuf* prev_;            // chain 이전
10

11
  SharedInfo* shared_;     // ref-count
12
  uint64_t flagsAndSharedInfo_;
13
};

1
#include <folly/io/IOBuf.h>
2

3
// 1) 새 IOBuf 생성
4
auto buf = folly::IOBuf::create(1024);          // capacity 1024
5
buf->append(100);                                // length를 100으로
6

7
// 2) 데이터 쓰기
8
std::memcpy(buf->writableTail() - 100, "hello", 5);
9

10
// 3) headroom 활용
11
buf->reserve(64, 0);   // 앞에 64B 여유
12
buf->prepend(10);       // length가 10 늘어남, data_가 앞으로
13

14
// 4) chain 연결
15
auto buf2 = folly::IOBuf::create(2048);
16
buf2->append(500);
17
buf->prependChain(std::move(buf2));   // buf ← buf2
18

19
// 5) 전체 길이
20
size_t total = buf->computeChainDataLength();

1
auto a = folly::IOBuf::create(1024);
2
a->append(100);
3

4
auto b = a->clone();   // ref-count 증가, data 공유
5
// a와 b는 같은 buffer를 가리킴 — copy 없음
6

7
a->writableData()[0] = 'x';
8
// b->data()[0] 도 'x' — 의도하지 않은 mutation 가능

1
auto b = a->clone();
2
b->unshare();   // 자기 카피 생성, ref-count 분리
3
b->writableData()[0] = 'x';   // 안전

1
uint8_t* external = ...;   // 외부 할당
2
auto buf = folly::IOBuf::takeOwnership(external, length, [external] {
3
  free(external);
4
});

1
const char* msg = "hello";
2
auto buf = folly::IOBuf::wrapBuffer(msg, 5);
3
// buf는 msg를 가리킴, ref-count 없음, free 안 함

1
auto current = buf.get();
2
do {
3
  std::cout << "len=" << current->length() << "\n";
4
  current = current->next();
5
} while (current != buf.get());

1
// 1. clone 후 mutation
2
auto b = a->clone();
3
b->writableData()[0] = 'x';   // a의 데이터도 바뀜 — unshare() 먼저
4

5
// 2. wrapBuffer + lifetime 미준수
6
auto buf = folly::IOBuf::wrapBuffer(tempStr.data(), tempStr.size());
7
return buf;   // tempStr 소멸 — buf는 dangling
8

9
// 3. chain 길이를 매번 computeChainDataLength
10
for (...) {
11
  if (buf->computeChainDataLength() > N) ...   // O(chain length) — 매번
12
}
13
// 캐시하거나 IOBufQueue로
14

15
// 4. IOBuf chain 위에서 직접 parse
16
parse(buf->data(), buf->length());   // chain의 첫 노드만 본다 — 잘못
17
// → Cursor 사용