mirrors
/
redis
mirror of https://mirror.osredm.com/root/redis.git
2
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Replace usage of _addReplyLongLongWithPrefix with specific bulk/mbulk functions to reduce condition checks in hotpath. (#13520) 

Instead of adding runtime logic to decide which prefix/shared object to
use when doing the reply we can simply use an inline method to avoid runtime
overhead of condition checks, and also keep the code change small.
Preliminary data show improvements on commands that heavily rely on
bulk/mbulk replies (example of LRANGE).

---------

Co-authored-by: debing.sun <debing.sun@redis.com>
This commit is contained in:
Filipe Oliveira (Redis) 2024-09-15 14:40:09 +01:00 committed by GitHub
parent af7fca797a
commit 7b69183a8d
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 32 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

35
src/networking.c
View File

@ -931,6 +931,33 @@ void addReplyHumanLongDouble(client *c, long double d) {
}
}
static inline void _addReplyLongLongSharedHdr(client *c, long long ll, char prefix,
robj *shared_hdr[OBJ_SHARED_BULKHDR_LEN])
{
char buf[128];
int len;
const int opt_hdr = ll < OBJ_SHARED_BULKHDR_LEN && ll >= 0;
if (opt_hdr) {
_addReplyToBufferOrList(c, shared_hdr[ll]->ptr, OBJ_SHARED_HDR_STRLEN(ll));
return;
}
buf[0] = prefix;
len = ll2string(buf + 1, sizeof(buf) - 1, ll);
buf[len + 1] = '\r';
buf[len + 2] = '\n';
_addReplyToBufferOrList(c, buf, len + 3);
}
static inline void _addReplyLongLongBulk(client *c, long long ll) {
_addReplyLongLongSharedHdr(c, ll, '$', shared.bulkhdr);
}
static inline void _addReplyLongLongMBulk(client *c, long long ll) {
_addReplyLongLongSharedHdr(c, ll, '*', shared.mbulkhdr);
}
/* Add a long long as integer reply or bulk len / multi bulk count.
* Basically this is used to output <prefix><long long><crlf>. */
static void _addReplyLongLongWithPrefix(client *c, long long ll, char prefix) {
@ -987,7 +1014,9 @@ void addReplyAggregateLen(client *c, long length, int prefix) {
}
void addReplyArrayLen(client *c, long length) {
addReplyAggregateLen(c,length,'*');
serverAssert(length >= 0);
if (prepareClientToWrite(c) != C_OK) return;
_addReplyLongLongMBulk(c, length);
}
void addReplyMapLen(client *c, long length) {
@ -1044,7 +1073,7 @@ void addReplyNullArray(client *c) {
void addReplyBulkLen(client *c, robj *obj) {
size_t len = stringObjectLen(obj);
if (prepareClientToWrite(c) != C_OK) return;
_addReplyLongLongWithPrefix(c, len, '$');
_addReplyLongLongBulk(c, len);
}
/* Add a Redis Object as a bulk reply */
@ -1057,7 +1086,7 @@ void addReplyBulk(client *c, robj *obj) {
/* Add a C buffer as bulk reply */
void addReplyBulkCBuffer(client *c, const void *p, size_t len) {
if (prepareClientToWrite(c) != C_OK) return;
_addReplyLongLongWithPrefix(c, len, '$');
_addReplyLongLongBulk(c, len);
_addReplyToBufferOrList(c, p, len);
_addReplyToBufferOrList(c, "\r\n", 2);
}