Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. Weโ€™ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

INTERNAL: Modify the term related to eflag #332

Merged
merged 1 commit into from
Dec 31, 2024
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
12 changes: 6 additions & 6 deletions arcus/multi_process.c
Original file line number Diff line number Diff line change
Expand Up @@ -133,14 +133,14 @@ static inline void process_child(memcached_st *proxy_mc)
uint32_t bkey_to_update = 0;
uint32_t value_to_update = 9999;

// update filter
uint32_t fvalue = 2001;
memcached_coll_update_filter_st update_filter;
memcached_coll_update_filter_init(&update_filter, (unsigned char *)&fvalue, sizeof(fvalue));
//memcached_bop_update_filter_set_bitwise(&update_filter, fwhere, MEMCACHED_COLL_BITWISE_AND);
// eflag update
uint32_t eflag_to_update = 2001;
memcached_coll_eflag_update_st eflag_update;
memcached_coll_eflag_update_init(&eflag_update, (unsigned char *)&eflag_to_update, sizeof(eflag_to_update));
// memcached_bop_eflag_update_set_bitwise(&eflag_update, offset, MEMCACHED_COLL_BITWISE_AND);

rc= memcached_bop_update(mc, key, strlen(key),
bkey_to_update, &update_filter,
bkey_to_update, &eflag_update,
(const char *)&value_to_update, sizeof(value_to_update));

if (rc != MEMCACHED_SUCCESS)
Expand Down
68 changes: 34 additions & 34 deletions docs/07-btree-API.md
Original file line number Diff line number Diff line change
Expand Up @@ -62,17 +62,17 @@ B+tree์˜ element flag์— ๋Œ€ํ•œ filtering์„ ์ง€์ •ํ•˜๊ธฐ ์œ„ํ•ด์„ , `eflag_fil
๋จผ์ €, `eflag_filter` ๊ตฌ์กฐ์ฒด๋ฅผ ์ƒ์„ฑํ•˜๋Š” API๋Š” ๋‹ค์Œ๊ณผ ๊ฐ™๋‹ค.
์ด๋ฅผ ํ†ตํ•ด, eflag์˜ ์ „์ฒด/๋ถ€๋ถ„ ๊ฐ’๊ณผ ํŠน์ • ๊ฐ’๊ณผ์˜ compare ์—ฐ์‚ฐ์„ ๋ช…์‹œํ•  ์ˆ˜ ์žˆ๋‹ค.

``` c
```c
memcached_return_t
memcached_coll_eflag_filter_init(memcached_ coll_eflag_filter_st *ptr,
const size_t fwhere,
const unsigned char *fvalue,
const size_t fvalue_length,
memcached_coll_eflag_filter_init(memcached_coll_eflag_filter_st *ptr,
const size_t offset,
const unsigned char *value,
const size_t value_length,
memcached_coll_comp_t comp_op)
```

- fwhere: eflag์—์„œ ๋น„๊ต ์—ฐ์‚ฐ์„ ์ทจํ•  ๋ฐ์ดํ„ฐ์˜ ์‹œ์ž‘ offset์„ ๋ฐ”์ดํŠธ ๋‹จ์œ„๋กœ ์ง€์ •ํ•œ๋‹ค.
- fvalue: ๋น„๊ต ์—ฐ์‚ฐ์„ ์ทจํ•  ๋ฐ์ดํ„ฐ ๊ฐ’์„ ์ง€์ •ํ•œ๋‹ค.
- offset: eflag์—์„œ ๋น„๊ต ์—ฐ์‚ฐ์„ ์ทจํ•  ๋ฐ์ดํ„ฐ์˜ ์‹œ์ž‘ offset์„ ๋ฐ”์ดํŠธ ๋‹จ์œ„๋กœ ์ง€์ •ํ•œ๋‹ค.
- value, value_length: ๋น„๊ต ์—ฐ์‚ฐ์„ ์ทจํ•  ๋ฐ์ดํ„ฐ ๊ฐ’์„ ์ง€์ •ํ•œ๋‹ค.
- comp_op: ๋น„๊ต ์—ฐ์‚ฐ์„ ์ง€์ •ํ•œ๋‹ค.
- MEMCACHED_COLL_COMP_EQ
- MEMCACHED_COLL_COMP_NE
Expand All @@ -81,43 +81,43 @@ memcached_coll_eflag_filter_init(memcached_ coll_eflag_filter_st *ptr,
- MEMCACHED_COLL_COMP_GT
- MEMCACHED_COLL_COMP_GE

๋น„๊ต ์—ฐ์‚ฐ์„ ์ทจํ•  ๋ฐ์ดํ„ฐ ๊ฐ’์ธ fvalue๋Š” ์—ฌ๋Ÿฌ ๊ฐ’์„ ์ง€์ •ํ•  ์ˆ˜๋„ ์žˆ์œผ๋ฉฐ, ๋‹ค์Œ๊ณผ ๊ฐ™์€ API๋ฅผ ์‚ฌ์šฉํ•œ๋‹ค.
๋น„๊ต ๋ฐ์ดํ„ฐ ๊ฐ’์€ ์ตœ๋Œ€ 100๊ฐœ fvalues๋ฅผ ์ง€์ •ํ•  ์ˆ˜ ์žˆ์œผ๋ฉฐ, MEMCACHED_COLL_COMP_EQ ์™€ MEMCACHED_COLL_COMP_NE ์—ฐ์‚ฐ์ž ๋งŒ์„ ์ง€์›ํ•œ๋‹ค.
๋น„๊ต ์—ฐ์‚ฐ์„ ์ทจํ•  ๋ฐ์ดํ„ฐ ๊ฐ’์ธ value๋Š” ์—ฌ๋Ÿฌ ๊ฐ’์„ ์ง€์ •ํ•  ์ˆ˜๋„ ์žˆ์œผ๋ฉฐ, ๋‹ค์Œ๊ณผ ๊ฐ™์€ API๋ฅผ ์‚ฌ์šฉํ•œ๋‹ค.
๋น„๊ต ๋ฐ์ดํ„ฐ ๊ฐ’์€ ์ตœ๋Œ€ 100๊ฐœ values๋ฅผ ์ง€์ •ํ•  ์ˆ˜ ์žˆ์œผ๋ฉฐ, MEMCACHED_COLL_COMP_EQ ์™€ MEMCACHED_COLL_COMP_NE ์—ฐ์‚ฐ์ž ๋งŒ์„ ์ง€์›ํ•œ๋‹ค.

``` c
```c
memcached_return_t
memcached_coll_eflags_filter_init(memcached_coll_eflag_filter_st *ptr,
const size_t fwhere,
const unsigned char *fvalues,
const size_t fvalue_length,
const size_t fvalue_count,
const size_t offset,
const unsigned char *values,
const size_t value_length,
const size_t value_count,
memcached_coll_comp_t comp_op)
```

- fwhere: eflag์—์„œ ๋น„๊ต ์—ฐ์‚ฐ์„ ์ทจํ•  ๋ฐ์ดํ„ฐ์˜ ์‹œ์ž‘ offset์„ ๋ฐ”์ดํŠธ ๋‹จ์œ„๋กœ ์ง€์ •ํ•œ๋‹ค.
- fvalues: ๋น„๊ต ์—ฐ์‚ฐ์„ ์ทจํ•  ๋ฐ์ดํ„ฐ ๊ฐ’์„ array ํ˜•ํƒœ๋กœ ์ง€์ •ํ•œ๋‹ค.
- fvalue_count: ๋น„๊ต ์—ฐ์‚ฐ์„ ์ทจํ•  ๋ฐ์ดํ„ฐ ๊ฐ’๋“ค์˜ ๊ฐœ์ˆ˜๋ฅผ ์ง€์ •ํ•œ๋‹ค.
- offset: eflag์—์„œ ๋น„๊ต ์—ฐ์‚ฐ์„ ์ทจํ•  ๋ฐ์ดํ„ฐ์˜ ์‹œ์ž‘ offset์„ ๋ฐ”์ดํŠธ ๋‹จ์œ„๋กœ ์ง€์ •ํ•œ๋‹ค.
- values, value_length: ๋น„๊ต ์—ฐ์‚ฐ์„ ์ทจํ•  ๋ฐ์ดํ„ฐ ๊ฐ’์„ array ํ˜•ํƒœ๋กœ ์ง€์ •ํ•œ๋‹ค.
- ๋ชจ๋“  ๊ฐ’์˜ ๊ธธ์ด๋Š” ๋™์ผํ•˜๊ฒŒ value_length์ด์–ด์•ผ ํ•œ๋‹ค.
- value_count: ๋น„๊ต ์—ฐ์‚ฐ์„ ์ทจํ•  ๋ฐ์ดํ„ฐ ๊ฐ’๋“ค์˜ ๊ฐœ์ˆ˜๋ฅผ ์ง€์ •ํ•œ๋‹ค.
- comp_op: ๋น„๊ต ์—ฐ์‚ฐ์„ ์ง€์ •ํ•œ๋‹ค.
- MEMCACHED_COLL_COMP_EQ
- MEMCACHED_COLL_COMP_NE

eflag์˜ ์ „์ฒด/๋ถ€๋ถ„ ๊ฐ’์— ๋Œ€ํ•ด ์–ด๋–ค operand๋กœ bitwise ์—ฐ์‚ฐ์„ ์ทจํ•จ์œผ๋กœ์จ eflag์˜ ํŠน์ • bit๋“ค๋งŒ์„ ๊ณจ๋ผ๋‚ด์–ด compareํ•  ์ˆ˜ ์žˆ๋‹ค.
์ด์™€ ๊ฐ™์ด `eflag_filter`์— bitwise ์—ฐ์‚ฐ์„ ์ถ”๊ฐ€ํ•  ๊ฒฝ์šฐ์—๋Š” ์•„๋ž˜์˜ API๋ฅผ ์ด์šฉํ•  ์ˆ˜ ์žˆ๋‹ค.

``` c
```c
memcached_return_t
memcached_coll_eflag_filter_set_bitwise(memcached_coll_eflag_filter_st *ptr,
memcached_coll_bitwise_t bitwise_op,
const unsigned char *foperand,
const size_t foperand_length)
const unsigned char *value,
const size_t value_length,
memcached_coll_bitwise_t bitwise_op)
```

- value, value_length: eflag์—์„œ bitwise ์—ฐ์‚ฐ์„ ์ทจํ•  operand๋ฅผ ์ง€์ •ํ•œ๋‹ค.
- bitwise_op: bitwise ์—ฐ์‚ฐ์„ ์ง€์ •ํ•œ๋‹ค.
- MEMCACHED_COLL_BITWISE_AND
- MEMCACHED_COLL_BITWISE_OR
- MEMCACHED_COLL_BITWISE_XOR
- foperand: eflag์—์„œ bitwise ์—ฐ์‚ฐ์„ ์ทจํ•  operand๋ฅผ ์ง€์ •ํ•œ๋‹ค.


## Element Flag Update ๊ตฌ์กฐ์ฒด

Expand All @@ -126,25 +126,25 @@ B+tree์˜ element flag๋ฅผ ๋ณ€๊ฒฝํ•˜๊ธฐ ์œ„ํ•ด์„  `eflag_update` ๊ตฌ์กฐ์ฒด๋ฅผ ์‚ฌ
๋จผ์ €, `eflag_update` ๊ตฌ์กฐ์ฒด๋ฅผ ์ƒ์„ฑํ•˜๋Š” API๋Š” ๋‹ค์Œ๊ณผ ๊ฐ™๋‹ค.
์ด๋ฅผ ํ†ตํ•ด, ์ƒˆ๋กœ ๋ณ€๊ฒฝํ•˜๊ณ ์ž ํ•˜๋Š” new element flag ๊ฐ’์„ ์ง€์ •ํ•  ์ˆ˜ ์žˆ๋‹ค.

``` c
```c
memcached_return_t
memcached_coll_eflag_update_init(memcached_coll_eflag_update_st *ptr,
const unsigned char *fvalue,
const size_t fvalue_length)
const unsigned char *value,
const size_t value_length)
```

๋งŒ์•ฝ, eflag์˜ ๋ถ€๋ถ„ ๊ฐ’๋งŒ์„ ๋ณ€๊ฒฝํ•˜๊ณ ์ž ํ•œ๋‹ค๋ฉด, ์•„๋ž˜์˜ ํ•จ์ˆ˜๋ฅผ ์ด์šฉํ•  ์ˆ˜ ์žˆ๋‹ค.
์•„๋ž˜ ํ•จ์ˆ˜๋กœ ๋ถ€๋ถ„ ๊ฐ’์˜ ์‹œ์ž‘ ์œ„์น˜๋ฅผ ๋ช…์‹œํ•˜์—ฌ์•ผ ํ•˜๊ณ , ๋ถ€๋ถ„ ๊ฐ’๊ณผ `eflag_update`์˜ init ์‹œ์— ๋ช…์‹œํ•œ fvalue์— ๋Œ€ํ•ด
์•„๋ž˜ ํ•จ์ˆ˜๋กœ ๋ถ€๋ถ„ ๊ฐ’์˜ ์‹œ์ž‘ ์œ„์น˜๋ฅผ ๋ช…์‹œํ•˜์—ฌ์•ผ ํ•˜๊ณ , ๋ถ€๋ถ„ ๊ฐ’๊ณผ `eflag_update`์˜ init ์‹œ์— ๋ช…์‹œํ•œ value์— ๋Œ€ํ•ด
์ทจํ•  bitwise ์—ฐ์‚ฐ์„ ๋ช…์‹œํ•˜์—ฌ์•ผ ํ•œ๋‹ค.

``` c
```c
memcached_return_t
memcached_coll_eflag_update_set_bitwise(memcached_coll_eflag_update_st *ptr,
const size_t fwhere,
const size_t offset,
memcached_coll_bitwise_t bitwise_op)
```

- fwhere: eflag์—์„œ ๋ถ€๋ถ„ ๋ณ€๊ฒฝํ•  ๋ถ€๋ถ„ ๋ฐ์ดํ„ฐ์˜ ์‹œ์ž‘ offset์„ ๋ฐ”์ดํŠธ ๋‹จ์œ„๋กœ ์ง€์ •ํ•œ๋‹ค.
- offset: eflag์—์„œ ๋ถ€๋ถ„ ๋ณ€๊ฒฝํ•  ๋ถ€๋ถ„ ๋ฐ์ดํ„ฐ์˜ ์‹œ์ž‘ offset์„ ๋ฐ”์ดํŠธ ๋‹จ์œ„๋กœ ์ง€์ •ํ•œ๋‹ค.
- bitwise_op: bitwise ์—ฐ์‚ฐ์„ ์ง€์ •ํ•œ๋‹ค.
- MEMCACHED_COLL_BITWISE_AND
- MEMCACHED_COLL_BITWISE_OR
Expand Down Expand Up @@ -400,20 +400,20 @@ memcached_return_t
memcached_bop_update(memcached_st *ptr,
const char *key, size_t key_length,
const uint64_t bkey, // bkey of 8 bytes unsigned integer type
memcached_coll_update_filter_st *update_filter,
memcached_coll_eflag_update_st *eflag_update,
const char *value, size_t value_length)

memcached_return_t
memcached_bop_ext_update(memcached_st *ptr,
const char *key, size_t key_length,
const unsigned char *bkey, size_t bkey_length, // bkey of byte array type
memcached_coll_update_filter_st *update_filter,
memcached_coll_eflag_update_st *eflag_update,
const char *value, size_t value_length)
```

- key, key_length: b+tree item์˜ key
- bkey ๋˜๋Š” bkey, bkey_length: element์˜ bkey
- update_filter: element์˜ eflag ๋ณ€๊ฒฝ ์š”์ฒญ์„ ๋‹ด์€ ๊ตฌ์กฐ์ฒด
- eflag_update: element์˜ eflag ๋ณ€๊ฒฝ ์š”์ฒญ์„ ๋‹ด์€ ๊ตฌ์กฐ์ฒด
- value, value_lenth: element์˜ new value

Response code๋Š” ์•„๋ž˜์™€ ๊ฐ™๋‹ค.
Expand All @@ -426,7 +426,7 @@ Response code๋Š” ์•„๋ž˜์™€ ๊ฐ™๋‹ค.
- MEMCACHED_NOTHING_TO_UPDATE: ๋ณ€๊ฒฝ์‚ฌํ•ญ์ด ๋ช…์‹œ๋˜์ง€ ์•Š์Œ.
- MEMCACHED_TYPE_MISMATCH: ์ฃผ์–ด์ง„ key์— ํ•ด๋‹นํ•˜๋Š” ์ž๋ฃŒ๊ตฌ์กฐ๊ฐ€ B+tree๊ฐ€ ์•„๋‹˜.
- MEMCACHED_BKEY_MISMATCH: ์ฃผ์–ด์ง„ bkey ์œ ํ˜•๊ณผ ํ•ด๋‹น B+tree์˜ bkey ์œ ํ˜•์ด ๋‹ค๋ฆ„.
- MEMCACHED_EFLAG_MISMATCH: update_filter์— ๋ช…์‹œ๋œ eflag ๋ฐ์ดํ„ฐ๊ฐ€ ์กด์žฌํ•˜์ง€ ์•Š์Œ.
- MEMCACHED_EFLAG_MISMATCH: eflag_update์— ๋ช…์‹œ๋œ eflag ๋ฐ์ดํ„ฐ๊ฐ€ ์กด์žฌํ•˜์ง€ ์•Š์Œ.


B+tree element๋ฅผ ๋ณ€๊ฒฝํ•˜๋Š” ์˜ˆ์ œ๋Š” ์•„๋ž˜์™€ ๊ฐ™๋‹ค.
Expand Down
Loading