echoCommand#

이전의 echo 명령어의 핸들러 함수인 echoCommand 함수를 다시 한 번 살펴보자.

echoCommand 함수는 addReplyBulk 함수를 통해서 사용자(client)가 넘겨준 인자를 그대로 응답을 보낸다.

addReplyBulk의 파라미터와 client 구조체를 살펴보면 우리가 커맨드라인에 보낸 명령은 argv 를 통해 전달되며 **argv 의 타입은 robj 이다. 즉, 우리가 커맨드라인에 보낸 명령은 robj 포인터의 배열 로 전달된다.

robj (serverObject)#

robj 객체에 대해서 살펴보자. server.h 를 확인해보면 robj 는 serverObject 의 typedef 이다.

1
typedef struct serverObject robj;

server.h의 serverObject 객체는 다음과 같다.

해당 구조체 정의 위의 매크로와 주석을 살펴보면 (server.h의 697 line~) 각 필드에 대응하는 값들이 어떤 역할을 하는지 알 수 있다.

type 필드는 해당 객체가 Redis의 어떤 데이터 타입인지(REDIS_STRING, REDIS_LIST, REDIS_HASH, REDIS_MODULE, REDIS_STREAM 등)를 나타내며, encoding 필드는 해당 객체가 메모리에서 어떤 방식으로 인코딩되어 있는지(OBJ_ENCODING_RAW, OBJ_ENCODING_INT, OBJ_ENCODING_EMBSTR 등)를 나타낸다. lru 필드는 객체에 대한 캐시 정책(LRU) 정보를, hasexpire 필드는 만료 시간을 가지고 있는지 여부를, refcount 필드는 참조 횟수를 나타냅니다.

정리하자면 robj (serverObject)는 Redis의 내부의 객체들을 추상화한 객체라고 요약할 수 있다.

processInputBuffer(clinet *c)#

command line이 어떻게 처리되는지 확인하기 위해 networking.c의 processInputBuffer 함수를 살펴보자.

processInputBuffer 함수에서 parseCommand 를 통해 명령어를 파싱하는데, 커맨드라인을 RESP 형식으로 파싱하기 위해서는 processMultibulkBuffer 함수를 이용한다. (networking.c)

해당 함수의 동작을 요약하면

1. RESP 프로토콜을 분석하여 명령어 인자 개수 (c→argc) 를 파악하고, 이에 따라 argv 배열을 위한 메모리 공간을 할당한다. (networking.c 의 2876 line 주석 참고)

2. 인자 개수 만큼 반복하며 각 인자를 처리한다. (2911 line의 while (c->multibulklen))

   1
   // networking.c 의 processInputBuffer 함수 일부 (line 2999 ~)
   2
   else {
   3
     // 새로운 문자열 robj(Redis Object)를 생성하고, 이를 c->argv 배열에 추가
   4
    c->argv[c->argc++] = createStringObject(c->querybuf + c->qb_pos, c->bulklen);
   5
    // 이하 생략
   

   • 각 인자의 데이터를 통해 새로운 SDS를 생성하고, 이를 robj 로 래핑한다.
   • 이렇게 생성된 robj 의 포인터를 c->argv 배열의 다음 빈 슬롯에 저장한다.

따라서 echo hello 라는 명령어가 입력되었다면 다음과 같은 argv 배열이 할당된다.

SDS (Simple Dynamic String) 와 addReply (Redis에서 문자열을 응답하는 방식)#

우리의 목표는 echoPunchDrunkard_abc와 같은 새로운 문자열을 클라이언트에게 응답하는 것이다.

Redis에서 문자열을 응답하기 위해서 addReply 함수 계열을 사용하고, 문자열을 다루는데는 SDS 라이브러리를 사용한다.

SDS (Simple Dynamic String)

sds는 Redis 에서 문자열을 다루기 위해 만들어진 문자열 라이브러리이다.

1
+--------+-------------------------------+-----------+
2
| Header | Binary safe C alike string... | Null term |
3
+--------+-------------------------------+-----------+
4
         |
5
         `-> Pointer returned to the user.

위와 같은 메모리 배치를 이용하여 (앞에 header를 붙이는 방식) C의 일반적인 문자열과 호환되며, 개별 문자에 접근하기 쉽고, 단일 할당을 통해 캐시 지역성을 높여 성능이 좋다고 한다.

우리가 해야하는 작업은 접두사 문자열 (echoPunchDrunkard_)와 인자로 들어온 문자열 (argv[1]) 을 합쳐 새로운 sds 문자열을 만드는 것이다. 이를 위해 sdscatfmt 함수를 사용할 수 있다.

sdscatfmt 함수

sdscatfmt는 printf와 유사한 포맷팅 기능을 제공하면서 기존 SDS에 문자열을 이어붙이는(append) 함수이다.

1
sds sdscatfmt(sds s, char const *fmt, ...);

• s: 내용을 이어붙일 대상 SDS 문자열, 새로운 SDS 문자열을 생성하고 싶다면 sdsempty() 전달
• fmt : 포맷팅 규칙을 정의 (예: %s, %S (SDS 문자열의 경우))

addReplyBulkSds

Redis에서 sds 타입의 문자열을 직접 응답으로 보는 함수로 networking.c 에 addReplyBulkSds 가 존재한다.

함수의 동작을 확인해보면 인자로 받은 sds 를 응답으로 전송한 후, 메모리를 해제하는 역할을 한다.