FEATURE: Add multi store APIs

[ing-eoking]

🔗 Related Issue

• jam2in/arcus-works#589

⌨️ What I did

• store 관련 bulk 명령어 수행을 추가합니다.
  • set, add, replace, append, prepend, cas
  • store 관련 명령어 send 과정에서 response를 나중에 한번에 처리하는 memcached_send_bulk를 추가합니다.

🤔 Others

• delete, incr, decr 관련 multi 명령어는 store가 아닌 다른 모듈에 있어 별도의 PR로 올릴 예정입니다.
• Memcached::Fast::Safe 에서 flag 값은 모두 0으로 설정되는 것을 확인했습니다.
  • bulk 명령어 내 모든 명령은 모두 동일한 플래그값을 갖습니다.

[ing-eoking]

활용 예제

• 코드

#include "config.hpp"
#include <iostream>
#include <map>

#include "libmemcached/memcached.h"

using namespace std;

#define MAX_NUMBER 7

memcached_st *mc;

bool mc_init() {
    mc = memcached_create(NULL);
    if (mc == NULL) return false;
    //if (MEMCACHED_SUCCESS != memcached_server_add(mc, "127.0.0.1", 54321))
    if (MEMCACHED_SUCCESS != arcus_connect(mc, "127.0.0.1:2181", "test"))
        return true;
    return false;
}

int main(int argc, char **argv) {
    if (mc_init()) return -1;

    uint32_t flags= 10;
    vector< pair<string, string> > kv;
    vector<const char *> keys, values;
    vector<size_t> keys_length, values_length;

    for (int i = 0; i < MAX_NUMBER; i++)
        kv.push_back(make_pair("key" + to_string(i), to_string(i)));

    for (int i = 0; i < MAX_NUMBER; i++) {
        keys.push_back(kv[i].first.c_str());
        keys_length.push_back(kv[i].first.length());
        values.push_back(kv[i].second.c_str());
        values_length.push_back(kv[i].second.length());
    }

    vector<memcached_return_t> results(MAX_NUMBER);
    memcached_set_bulk(mc, (char **)(&keys[0]),   (size_t *)(&keys_length[0]), MAX_NUMBER,
                           (char **)(&values[0]), (size_t *)(&values_length[0]), NULL, flags,
                           (memcached_return_t *)(&results[0]));
    for (int i = 0; i < MAX_NUMBER; i++)
        cout << string(keys[i]) << " : " << memcached_strerror(mc, results[i]) << endl;

    return 0;
}

• 결과
  • 모두 성공한 경우

  key0 : STORED
  key1 : STORED
  key2 : STORED
  key3 : STORED
  key4 : STORED
  key5 : STORED
  key6 : STORED
  

  • 중간에 에러 발생(key3에 대하여 TYPE_MISMATCH 에러 강제 발생)

  key0 : STORED
  key1 : STORED
  key2 : STORED
  key3 : COLLECTION TYPE MISMATCH
  key4 : STORED
  key5 : STORED
  key6 : STORED
  

[namsic]

이 조건문이 없으면 어떻게 동작하게 되나요?

[ing-eoking]

C-Client 내부적으로 cas가 0인 경우 cas를 제외하고 보내게 됩니다.
그러므로 서버로 아래와 같이 보내게 된다고 생각하시면 될 것 같습니다.

cas i 0 0 1
1

이 경우 서버는 ERROR no matching command 반환하게 되며,
PROTOCOL_ERROR 이후 reconnect로 인한 CONNECTION_FAILURE를 반환하게 됩니다.

[namsic]

여기서 확인하지 않는 것이 좋겠습니다.

[jhpark816]

cas 값 검사는 아래 함수에서 수행합시다.

• memcached_cas()
• memcached_cas_bulk()

[jhpark816]

@namsic approve한 상태인가요?

[namsic]

@jhpark816 approve 이후 수정이 있어서, 다시 확인 중입니다.

[jhpark816]

일부 리뷰

[jhpark816]

{ 문자는 다음 라인에서 시작

[jhpark816]

cas 값 검사는 아래 함수에서 수행합시다.

• memcached_cas()
• memcached_cas_bulk()

[jhpark816]

이 위치에서 memcached_key_test() 수행하는 것이 맞을 것입니다.

[jhpark816]

number_of_keys 보다는 keys 인자 앞에 bulk_count 두는 것이 맞지 않는 지 ?

[jhpark816]

memcached_send_bulk_ascii() 함수를 별도로 두는 방안도 검토해 보았나요?

[ing-eoking]

검토 결과 memcached_send_ascii와 response 부분을 제외한 많은 로직이 일치하게 됩니다.
(Validation 검사, 명령어 벡터 구성)

그래서 새로 구성하는 것보다는 memcached_send_ascii를 활용하는 방안이 낫다고 생각했습니다.

[ing-eoking]

해당 작업은 @uhm0311 이 하고 있으므로 PR 닫겠습니다.