
b6a052fe0 Helper for setting TCP_USER_TIMEOUT socket option (#1188) 3fa9b6944 Add RedisModule adapter (#1182) d13c091e9 Fix wincrypt symbols conflict 5d84c8cfd Add a test ensuring we don't clobber connection error. 3f95fcdae Don't attempt to set a timeout if we are in an error state. aacb84b8d Fix typo in makefile. 563b062e3 Accept -nan per the RESP3 spec recommendation. 04c1b5b02 Fix colliding option values 4ca8e73f6 Rework searching for openssl cd208812f Attempt to find the correct path for openssl. 011f7093c Allow specifying the keepalive interval e9243d4f7 Cmake static or shared (#1160) 1cbd5bc76 Write a version file for the CMake package (#1165) 6f5bae8c6 fix typo acd09461d CMakeLists.txt: respect BUILD_SHARED_LIBS 97fcf0fd1 Add sdevent adapter ccff093bc Bump dev version for the next release cycle. c14775b4e Prepare for v1.1.0 GA f0bdf8405 Add support for nan in RESP3 double (#1133) 991b0b0b3 Add an example that calls redisCommandArgv (#1140) a36686f84 CI updates (#1139) 8ad4985e9 fix flag reference 7583ebb1b Make freeing a NULL redisAsyncContext a no op. 2c53dea7f Update version in dev branch. f063370ed Prepare for v1.1.0-rc1 2b069573a CI fixes in preparation of release e1e9eb40d Add author information to release-drafter template. afc29ee1a Update for mingw cross compile ceb8a8815 fixed cpp build error with adapters/libhv.h 3b15a04b5 Fixup of PR734: Coverage of hiredis.c (#1124) c245df9fb CMake corrections for building on Windows (#1122) 9c338a598 Fix PUSH handler tests for Redis >= 7.0.5 6d5c3ee74 Install on windows fixes (#1117) 68b29e1ad Add timeout support to libhv adapter. (#1109) 722e3409c Additional include directory given by pkg-config (#1118) bd9ccb8c4 Use __attribute__ when building with clang on windows 5392adc26 set default SSL certificate directory 560e66486 Minor refactor d756f68a5 Add libhv example to our standard Makefile a66916719 Add adapters/libhv 855b48a81 Fix pkgconfig for hiredis_ssl 79ae5ffc6 Fix protocol error (#1106) 61b5b299f Use a windows specific keepalive function. (#1104) fce8abc1c Introduce .close method for redisContextFuncs cfb6ca881 Add REDIS_OPT_PREFER_UNSPEC (#1101) cc7c35ce6 Update documentation to explain redisConnectWithOptions. bc8d837b7 fix heap-buffer-overflow (#957) ca4a0e850 uvadapter: reduce number of uv_poll_start calls 35d398c90 Fix cmake config path on Linux. CMake config files were installed to `/usr/local/share/hiredis`, which is not recognizable by `find_package()`. I'm not sure why it was set that way. Given the commit introducing it is for Windows, I keep that behavior consistent there, but fix the rest. 10c78c6e1 Add possibility to prefer IPv6, IPv4 or unspecified 1abe0c828 fuzzer: No alloc in redisFormatCommand() when fail 329eaf9ba Fix heap-buffer-overflow issue in redisvFormatCommad eaae7321c Polling adapter requires sockcompat.h 0a5fa3dde Regression test for off-by-one parsing error 9e174e8f7 Add do while(0) protection for macros 4ad99c69a Rework asSleep to be a generic millisleep function. 75cb6c1ea Do store command timeout in the context for redisSetTimeout (#593) c57cad658 CMake: remove dict.c form hiredis_sources 8491a65a9 Add Github Actions CI workflow for hiredis: Arm, Arm64, 386, windows. (#943) 77e4f09ea Merge pull request #964 from afcidk/fix-createDoubleObject 9219f7e7c Merge pull request #901 from devnexen/illumos_test_fix 810cc6104 Merge pull request #905 from sundb/master df8b74d69 Merge pull request #1091 from redis/ssl-error-ub-fix 0ed6cdec3 Fix some undefined behaviour 507a6dcaa Merge pull request #1090 from Nordix/subscribe-oom-error b044eaa6a Copy error to redisAsyncContext when finding subscribe cb e0200b797 Merge pull request #1087 from redis/const-and-non-const-callback 6a3e96ad2 Maintain backward compatibiliy withour onConnect callback. e7afd998f Merge pull request #1079 from SukkaW/drop-macos-10.15-runner 17c8fe079 Merge pull request #931 from kristjanvalur/pr2 b808c0c20 Merge pull request #1083 from chayim/ck-drafter 367a82bf0 Merge pull request #1085 from stanhu/ssl-improve-options-setting 71119a71d Make it possible to set SSL verify mode dd7979ac1 Merge pull request #1084 from stanhu/sh-improve-ssl-docs c71116178 Improve example for SSL initialization in README.md 5c9b6b571 Release drafter a606ccf2a CI: use recommended `vmactions/freebsd-vm@v0` 0865c115b Merge pull request #1080 from Nordix/readme-corrections f6cee7142 Fix README typos 06be7ff31 Merge pull request #1050 from smmir-cent/fix-cmake-version 7dd833d54 CI: bump macos runner version f69fac769 Drop `const` on redisAsyncContext in redisConnectCallback Since the callback is now re-entrant, it can call apis such as redisAsyncDisconnect() 005d7edeb Support calling redisAsyncDisconnect from the onConnected callback, by deferring context deletion 6ed060920 Add async regression test for issue #931 eaa2a7ee7 Merge pull request #932 from kristjanvalur/pr3 2ccef30f3 Add regression test for issue #945 4b901d44a Initial async tests 31c91408e Polling adapter and example 8a15f4d65 Merge pull request #1057 from orgads/static-name 902dd047f Merge pull request #1054 from kristjanvalur/pr08 c78d0926b Merge pull request #1074 from michael-grunder/kristjanvalur-pr4 2b115d56c Whitespace 1343988ce Fix typos 47b57aa24 Add some documentation on connect/disconnect callbacks and command callbacks a890d9ce2 Merge pull request #1073 from michael-grunder/kristjanvalur-pr1 f246ee433 Whitespace, style 94c1985bd Use correct type for getsockopt() 5e002bc21 Support failed async connects on windows. 5d68ad2f4 Merge pull request #1072 from michael-grunder/fix-redis7-unit-tests f4b6ed289 Fix tests so they work for Redis 7.0 95a0c1283 Merge pull request #1058 from orgads/win64 eedb37a65 Fix warnings on Win64 47c3ecefc Merge pull request #1062 from yossigo/fix-push-notification-order e23d91c97 Merge pull request #1061 from yossigo/update-redis-apt 34211ad54 Merge pull request #1063 from redis/fix-windows-tests 9957af7e3 Whitelist hiredis repo path in cygwin b455b3381 Handle push notifications before or after reply. aed9ce446 Use official repository for redis package. d7683f35a Merge pull request #1047 from Nordix/unsubscribe-handling 7c44a9d7e Merge pull request #1045 from Nordix/sds-updates dd4bf9783 Use the same name for static and shared libraries ff57c18b9 Embed debug information in windows static lib, rather than create a .pdb file 8310ad4f5 fix cmake version 7123b87f6 Handle any pipelined unsubscribe in async b6fb548fc Ignore pubsub replies without a channel/pattern 00b82683b Handle overflows as errors instead of asserting 64062a1d4 Catch size_t overflows in sds.c 066c6de79 Use size_t/long to avoid truncation c6657ef65 Merge branch 'redis:master' into master 50cdcab49 Fix potential fault at createDoubleObject fd033e983 Remove semicolon after do-while in _EL_CLEANUP 664c415e7 Illumos test fixes, error message difference fot bad hostname test. git-subtree-dir: deps/hiredis git-subtree-split: b6a052fe0959dae69e16b9d74449faeb1b70dbe1
281 lines
9.0 KiB
C
281 lines
9.0 KiB
C
/* SDSLib 2.0 -- A C dynamic strings library
|
|
*
|
|
* Copyright (c) 2006-2015, Salvatore Sanfilippo <antirez at gmail dot com>
|
|
* Copyright (c) 2015, Oran Agra
|
|
* Copyright (c) 2015, Redis Labs, Inc
|
|
* All rights reserved.
|
|
*
|
|
* Redistribution and use in source and binary forms, with or without
|
|
* modification, are permitted provided that the following conditions are met:
|
|
*
|
|
* * Redistributions of source code must retain the above copyright notice,
|
|
* this list of conditions and the following disclaimer.
|
|
* * Redistributions in binary form must reproduce the above copyright
|
|
* notice, this list of conditions and the following disclaimer in the
|
|
* documentation and/or other materials provided with the distribution.
|
|
* * Neither the name of Redis nor the names of its contributors may be used
|
|
* to endorse or promote products derived from this software without
|
|
* specific prior written permission.
|
|
*
|
|
* THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS"
|
|
* AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
|
|
* IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
|
|
* ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT OWNER OR CONTRIBUTORS BE
|
|
* LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR
|
|
* CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF
|
|
* SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS
|
|
* INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN
|
|
* CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE)
|
|
* ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE
|
|
* POSSIBILITY OF SUCH DAMAGE.
|
|
*/
|
|
|
|
#ifndef __SDS_H
|
|
#define __SDS_H
|
|
|
|
#define SDS_MAX_PREALLOC (1024*1024)
|
|
#ifdef _MSC_VER
|
|
typedef long long ssize_t;
|
|
#define SSIZE_MAX (LLONG_MAX >> 1)
|
|
#ifndef __clang__
|
|
#define __attribute__(x)
|
|
#endif
|
|
#endif
|
|
|
|
#include <sys/types.h>
|
|
#include <stdarg.h>
|
|
#include <stdint.h>
|
|
|
|
typedef char *sds;
|
|
|
|
/* Note: sdshdr5 is never used, we just access the flags byte directly.
|
|
* However is here to document the layout of type 5 SDS strings. */
|
|
struct __attribute__ ((__packed__)) sdshdr5 {
|
|
unsigned char flags; /* 3 lsb of type, and 5 msb of string length */
|
|
char buf[];
|
|
};
|
|
struct __attribute__ ((__packed__)) sdshdr8 {
|
|
uint8_t len; /* used */
|
|
uint8_t alloc; /* excluding the header and null terminator */
|
|
unsigned char flags; /* 3 lsb of type, 5 unused bits */
|
|
char buf[];
|
|
};
|
|
struct __attribute__ ((__packed__)) sdshdr16 {
|
|
uint16_t len; /* used */
|
|
uint16_t alloc; /* excluding the header and null terminator */
|
|
unsigned char flags; /* 3 lsb of type, 5 unused bits */
|
|
char buf[];
|
|
};
|
|
struct __attribute__ ((__packed__)) sdshdr32 {
|
|
uint32_t len; /* used */
|
|
uint32_t alloc; /* excluding the header and null terminator */
|
|
unsigned char flags; /* 3 lsb of type, 5 unused bits */
|
|
char buf[];
|
|
};
|
|
struct __attribute__ ((__packed__)) sdshdr64 {
|
|
uint64_t len; /* used */
|
|
uint64_t alloc; /* excluding the header and null terminator */
|
|
unsigned char flags; /* 3 lsb of type, 5 unused bits */
|
|
char buf[];
|
|
};
|
|
|
|
#define SDS_TYPE_5 0
|
|
#define SDS_TYPE_8 1
|
|
#define SDS_TYPE_16 2
|
|
#define SDS_TYPE_32 3
|
|
#define SDS_TYPE_64 4
|
|
#define SDS_TYPE_MASK 7
|
|
#define SDS_TYPE_BITS 3
|
|
#define SDS_HDR_VAR(T,s) struct sdshdr##T *sh = (struct sdshdr##T *)((s)-(sizeof(struct sdshdr##T)));
|
|
#define SDS_HDR(T,s) ((struct sdshdr##T *)((s)-(sizeof(struct sdshdr##T))))
|
|
#define SDS_TYPE_5_LEN(f) ((f)>>SDS_TYPE_BITS)
|
|
|
|
static inline size_t sdslen(const sds s) {
|
|
unsigned char flags = s[-1];
|
|
switch(flags&SDS_TYPE_MASK) {
|
|
case SDS_TYPE_5:
|
|
return SDS_TYPE_5_LEN(flags);
|
|
case SDS_TYPE_8:
|
|
return SDS_HDR(8,s)->len;
|
|
case SDS_TYPE_16:
|
|
return SDS_HDR(16,s)->len;
|
|
case SDS_TYPE_32:
|
|
return SDS_HDR(32,s)->len;
|
|
case SDS_TYPE_64:
|
|
return SDS_HDR(64,s)->len;
|
|
}
|
|
return 0;
|
|
}
|
|
|
|
static inline size_t sdsavail(const sds s) {
|
|
unsigned char flags = s[-1];
|
|
switch(flags&SDS_TYPE_MASK) {
|
|
case SDS_TYPE_5: {
|
|
return 0;
|
|
}
|
|
case SDS_TYPE_8: {
|
|
SDS_HDR_VAR(8,s);
|
|
return sh->alloc - sh->len;
|
|
}
|
|
case SDS_TYPE_16: {
|
|
SDS_HDR_VAR(16,s);
|
|
return sh->alloc - sh->len;
|
|
}
|
|
case SDS_TYPE_32: {
|
|
SDS_HDR_VAR(32,s);
|
|
return sh->alloc - sh->len;
|
|
}
|
|
case SDS_TYPE_64: {
|
|
SDS_HDR_VAR(64,s);
|
|
return sh->alloc - sh->len;
|
|
}
|
|
}
|
|
return 0;
|
|
}
|
|
|
|
static inline void sdssetlen(sds s, size_t newlen) {
|
|
unsigned char flags = s[-1];
|
|
switch(flags&SDS_TYPE_MASK) {
|
|
case SDS_TYPE_5:
|
|
{
|
|
unsigned char *fp = ((unsigned char*)s)-1;
|
|
*fp = (unsigned char)(SDS_TYPE_5 | (newlen << SDS_TYPE_BITS));
|
|
}
|
|
break;
|
|
case SDS_TYPE_8:
|
|
SDS_HDR(8,s)->len = (uint8_t)newlen;
|
|
break;
|
|
case SDS_TYPE_16:
|
|
SDS_HDR(16,s)->len = (uint16_t)newlen;
|
|
break;
|
|
case SDS_TYPE_32:
|
|
SDS_HDR(32,s)->len = (uint32_t)newlen;
|
|
break;
|
|
case SDS_TYPE_64:
|
|
SDS_HDR(64,s)->len = (uint64_t)newlen;
|
|
break;
|
|
}
|
|
}
|
|
|
|
static inline void sdsinclen(sds s, size_t inc) {
|
|
unsigned char flags = s[-1];
|
|
switch(flags&SDS_TYPE_MASK) {
|
|
case SDS_TYPE_5:
|
|
{
|
|
unsigned char *fp = ((unsigned char*)s)-1;
|
|
unsigned char newlen = SDS_TYPE_5_LEN(flags)+(unsigned char)inc;
|
|
*fp = SDS_TYPE_5 | (newlen << SDS_TYPE_BITS);
|
|
}
|
|
break;
|
|
case SDS_TYPE_8:
|
|
SDS_HDR(8,s)->len += (uint8_t)inc;
|
|
break;
|
|
case SDS_TYPE_16:
|
|
SDS_HDR(16,s)->len += (uint16_t)inc;
|
|
break;
|
|
case SDS_TYPE_32:
|
|
SDS_HDR(32,s)->len += (uint32_t)inc;
|
|
break;
|
|
case SDS_TYPE_64:
|
|
SDS_HDR(64,s)->len += (uint64_t)inc;
|
|
break;
|
|
}
|
|
}
|
|
|
|
/* sdsalloc() = sdsavail() + sdslen() */
|
|
static inline size_t sdsalloc(const sds s) {
|
|
unsigned char flags = s[-1];
|
|
switch(flags&SDS_TYPE_MASK) {
|
|
case SDS_TYPE_5:
|
|
return SDS_TYPE_5_LEN(flags);
|
|
case SDS_TYPE_8:
|
|
return SDS_HDR(8,s)->alloc;
|
|
case SDS_TYPE_16:
|
|
return SDS_HDR(16,s)->alloc;
|
|
case SDS_TYPE_32:
|
|
return SDS_HDR(32,s)->alloc;
|
|
case SDS_TYPE_64:
|
|
return SDS_HDR(64,s)->alloc;
|
|
}
|
|
return 0;
|
|
}
|
|
|
|
static inline void sdssetalloc(sds s, size_t newlen) {
|
|
unsigned char flags = s[-1];
|
|
switch(flags&SDS_TYPE_MASK) {
|
|
case SDS_TYPE_5:
|
|
/* Nothing to do, this type has no total allocation info. */
|
|
break;
|
|
case SDS_TYPE_8:
|
|
SDS_HDR(8,s)->alloc = (uint8_t)newlen;
|
|
break;
|
|
case SDS_TYPE_16:
|
|
SDS_HDR(16,s)->alloc = (uint16_t)newlen;
|
|
break;
|
|
case SDS_TYPE_32:
|
|
SDS_HDR(32,s)->alloc = (uint32_t)newlen;
|
|
break;
|
|
case SDS_TYPE_64:
|
|
SDS_HDR(64,s)->alloc = (uint64_t)newlen;
|
|
break;
|
|
}
|
|
}
|
|
|
|
sds sdsnewlen(const void *init, size_t initlen);
|
|
sds sdsnew(const char *init);
|
|
sds sdsempty(void);
|
|
sds sdsdup(const sds s);
|
|
void sdsfree(sds s);
|
|
sds sdsgrowzero(sds s, size_t len);
|
|
sds sdscatlen(sds s, const void *t, size_t len);
|
|
sds sdscat(sds s, const char *t);
|
|
sds sdscatsds(sds s, const sds t);
|
|
sds sdscpylen(sds s, const char *t, size_t len);
|
|
sds sdscpy(sds s, const char *t);
|
|
|
|
sds sdscatvprintf(sds s, const char *fmt, va_list ap);
|
|
#ifdef __GNUC__
|
|
sds sdscatprintf(sds s, const char *fmt, ...)
|
|
__attribute__((format(printf, 2, 3)));
|
|
#else
|
|
sds sdscatprintf(sds s, const char *fmt, ...);
|
|
#endif
|
|
|
|
sds sdscatfmt(sds s, char const *fmt, ...);
|
|
sds sdstrim(sds s, const char *cset);
|
|
int sdsrange(sds s, ssize_t start, ssize_t end);
|
|
void sdsupdatelen(sds s);
|
|
void sdsclear(sds s);
|
|
int sdscmp(const sds s1, const sds s2);
|
|
sds *sdssplitlen(const char *s, int len, const char *sep, int seplen, int *count);
|
|
void sdsfreesplitres(sds *tokens, int count);
|
|
void sdstolower(sds s);
|
|
void sdstoupper(sds s);
|
|
sds sdsfromlonglong(long long value);
|
|
sds sdscatrepr(sds s, const char *p, size_t len);
|
|
sds *sdssplitargs(const char *line, int *argc);
|
|
sds sdsmapchars(sds s, const char *from, const char *to, size_t setlen);
|
|
sds sdsjoin(char **argv, int argc, char *sep);
|
|
sds sdsjoinsds(sds *argv, int argc, const char *sep, size_t seplen);
|
|
|
|
/* Low level functions exposed to the user API */
|
|
sds sdsMakeRoomFor(sds s, size_t addlen);
|
|
void sdsIncrLen(sds s, int incr);
|
|
sds sdsRemoveFreeSpace(sds s);
|
|
size_t sdsAllocSize(sds s);
|
|
void *sdsAllocPtr(sds s);
|
|
|
|
/* Export the allocator used by SDS to the program using SDS.
|
|
* Sometimes the program SDS is linked to, may use a different set of
|
|
* allocators, but may want to allocate or free things that SDS will
|
|
* respectively free or allocate. */
|
|
void *sds_malloc(size_t size);
|
|
void *sds_realloc(void *ptr, size_t size);
|
|
void sds_free(void *ptr);
|
|
|
|
#ifdef REDIS_TEST
|
|
int sdsTest(int argc, char *argv[]);
|
|
#endif
|
|
|
|
#endif
|