提交 13d0ac5b 编写于 作者: wafwerar's avatar wafwerar

TS-1368: Rename MD5

上级 cd7f69a7
...@@ -177,10 +177,10 @@ static int32_t getSmlMd5ChildTableName(TAOS_SML_DATA_POINT* point, char* tableNa ...@@ -177,10 +177,10 @@ static int32_t getSmlMd5ChildTableName(TAOS_SML_DATA_POINT* point, char* tableNa
} }
size_t len = 0; size_t len = 0;
char* keyJoined = taosStringBuilderGetResult(&sb, &len); char* keyJoined = taosStringBuilderGetResult(&sb, &len);
TAOS_MD5_CTX context; T_MD5_CTX context;
taos_MD5Init(&context); tMD5Init(&context);
taos_MD5Update(&context, (uint8_t *)keyJoined, (uint32_t)len); tMD5Update(&context, (uint8_t *)keyJoined, (uint32_t)len);
taos_MD5Final(&context); tMD5Final(&context);
uint64_t digest1 = *(uint64_t*)(context.digest); uint64_t digest1 = *(uint64_t*)(context.digest);
uint64_t digest2 = *(uint64_t*)(context.digest + 8); uint64_t digest2 = *(uint64_t*)(context.digest + 8);
*tableNameLen = snprintf(tableName, *tableNameLen, *tableNameLen = snprintf(tableName, *tableNameLen,
......
...@@ -350,10 +350,10 @@ int32_t httpShrinkTableName(HttpContext *pContext, int32_t pos, char *name) { ...@@ -350,10 +350,10 @@ int32_t httpShrinkTableName(HttpContext *pContext, int32_t pos, char *name) {
return pos; return pos;
} }
TAOS_MD5_CTX context; T_MD5_CTX context;
taos_MD5Init(&context); tMD5Init(&context);
taos_MD5Update(&context, (uint8_t *)name, (uint32_t)len); tMD5Update(&context, (uint8_t *)name, (uint32_t)len);
taos_MD5Final(&context); tMD5Final(&context);
int32_t table_name = httpAddToSqlCmdBuffer( int32_t table_name = httpAddToSqlCmdBuffer(
pContext, "%02x%02x%02x%02x%02x%02x%02x%02x%02x%02x%02x%02x%02x%02x%02x%02x", context.digest[0], pContext, "%02x%02x%02x%02x%02x%02x%02x%02x%02x%02x%02x%02x%02x%02x%02x%02x", context.digest[0],
......
...@@ -1541,14 +1541,14 @@ static SRpcHead *rpcDecompressRpcMsg(SRpcHead *pHead) { ...@@ -1541,14 +1541,14 @@ static SRpcHead *rpcDecompressRpcMsg(SRpcHead *pHead) {
} }
static int rpcAuthenticateMsg(void *pMsg, int msgLen, void *pAuth, void *pKey) { static int rpcAuthenticateMsg(void *pMsg, int msgLen, void *pAuth, void *pKey) {
TAOS_MD5_CTX context; T_MD5_CTX context;
int ret = -1; int ret = -1;
taos_MD5Init(&context); tMD5Init(&context);
taos_MD5Update(&context, (uint8_t *)pKey, TSDB_KEY_LEN); tMD5Update(&context, (uint8_t *)pKey, TSDB_KEY_LEN);
taos_MD5Update(&context, (uint8_t *)pMsg, msgLen); tMD5Update(&context, (uint8_t *)pMsg, msgLen);
taos_MD5Update(&context, (uint8_t *)pKey, TSDB_KEY_LEN); tMD5Update(&context, (uint8_t *)pKey, TSDB_KEY_LEN);
taos_MD5Final(&context); tMD5Final(&context);
if (memcmp(context.digest, pAuth, sizeof(context.digest)) == 0) ret = 0; if (memcmp(context.digest, pAuth, sizeof(context.digest)) == 0) ret = 0;
...@@ -1556,13 +1556,13 @@ static int rpcAuthenticateMsg(void *pMsg, int msgLen, void *pAuth, void *pKey) { ...@@ -1556,13 +1556,13 @@ static int rpcAuthenticateMsg(void *pMsg, int msgLen, void *pAuth, void *pKey) {
} }
static void rpcBuildAuthHead(void *pMsg, int msgLen, void *pAuth, void *pKey) { static void rpcBuildAuthHead(void *pMsg, int msgLen, void *pAuth, void *pKey) {
TAOS_MD5_CTX context; T_MD5_CTX context;
taos_MD5Init(&context); tMD5Init(&context);
taos_MD5Update(&context, (uint8_t *)pKey, TSDB_KEY_LEN); tMD5Update(&context, (uint8_t *)pKey, TSDB_KEY_LEN);
taos_MD5Update(&context, (uint8_t *)pMsg, msgLen); tMD5Update(&context, (uint8_t *)pMsg, msgLen);
taos_MD5Update(&context, (uint8_t *)pKey, TSDB_KEY_LEN); tMD5Update(&context, (uint8_t *)pKey, TSDB_KEY_LEN);
taos_MD5Final(&context); tMD5Final(&context);
memcpy(pAuth, context.digest, sizeof(context.digest)); memcpy(pAuth, context.digest, sizeof(context.digest));
} }
......
...@@ -31,11 +31,17 @@ typedef struct { ...@@ -31,11 +31,17 @@ typedef struct {
uint32_t i[2]; /* number of _bits_ handled mod 2^64 */ uint32_t i[2]; /* number of _bits_ handled mod 2^64 */
uint32_t buf[4]; /* scratch buffer */ uint32_t buf[4]; /* scratch buffer */
uint8_t in[64]; /* input buffer */ uint8_t in[64]; /* input buffer */
uint8_t digest[16]; /* actual digest after taos_MD5Final call */ uint8_t digest[16]; /* actual digest after tMD5Final call */
} TAOS_MD5_CTX; } MD5_CTX;
void taos_MD5Init(TAOS_MD5_CTX *mdContext); typedef MD5_CTX T_MD5_CTX;
void taos_MD5Update(TAOS_MD5_CTX *mdContext, uint8_t *inBuf, unsigned int inLen);
void taos_MD5Final(TAOS_MD5_CTX *mdContext); void MD5Init(T_MD5_CTX *mdContext);
void MD5Update(T_MD5_CTX *mdContext, uint8_t *inBuf, unsigned int inLen);
void MD5Final(T_MD5_CTX *mdContext);
void tMD5Init(T_MD5_CTX *mdContext);
void tMD5Update(T_MD5_CTX *mdContext, uint8_t *inBuf, unsigned int inLen);
void tMD5Final(T_MD5_CTX *mdContext);
#endif #endif
...@@ -47,10 +47,10 @@ void jsonKeyMd5(void *pMsg, int msgLen, void *pKey); ...@@ -47,10 +47,10 @@ void jsonKeyMd5(void *pMsg, int msgLen, void *pKey);
bool isValidateTag(char *input); bool isValidateTag(char *input);
static FORCE_INLINE void taosEncryptPass(uint8_t *inBuf, size_t inLen, char *target) { static FORCE_INLINE void taosEncryptPass(uint8_t *inBuf, size_t inLen, char *target) {
TAOS_MD5_CTX context; T_MD5_CTX context;
taos_MD5Init(&context); tMD5Init(&context);
taos_MD5Update(&context, inBuf, (unsigned int)inLen); tMD5Update(&context, inBuf, (unsigned int)inLen);
taos_MD5Final(&context); tMD5Final(&context);
memcpy(target, context.digest, TSDB_KEY_LEN); memcpy(target, context.digest, TSDB_KEY_LEN);
} }
......
...@@ -2,9 +2,9 @@ ...@@ -2,9 +2,9 @@
*********************************************************************** ***********************************************************************
** Message-digest routines: ** ** Message-digest routines: **
** To form the message digest for a message M ** ** To form the message digest for a message M **
** (1) Initialize a context buffer mdContext using taos_MD5Init ** ** (1) Initialize a context buffer mdContext using tMD5Init **
** (2) Call taos_MD5Update on mdContext and M ** ** (2) Call tMD5Update on mdContext and M **
** (3) Call taos_MD5Final on mdContext ** ** (3) Call tMD5Final on mdContext **
** The message digest is now in mdContext->digest[0...15] ** ** The message digest is now in mdContext->digest[0...15] **
*********************************************************************** ***********************************************************************
*/ */
...@@ -82,11 +82,11 @@ static uint8_t PADDING[64] = {0x80, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x ...@@ -82,11 +82,11 @@ static uint8_t PADDING[64] = {0x80, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x
(a) += (b); \ (a) += (b); \
} }
/* The routine taos_MD5Init initializes the message-digest context /* The routine tMD5Init initializes the message-digest context
mdContext. All fields are set to zero. mdContext. All fields are set to zero.
*/ */
void taos_MD5Init(TAOS_MD5_CTX *mdContext) { void tMD5Init(T_MD5_CTX *mdContext) {
memset(mdContext, 0, sizeof(TAOS_MD5_CTX)); memset(mdContext, 0, sizeof(T_MD5_CTX));
/* Load magic initialization constants. */ /* Load magic initialization constants. */
mdContext->buf[0] = (uint32_t)0x67452301; mdContext->buf[0] = (uint32_t)0x67452301;
...@@ -94,12 +94,15 @@ void taos_MD5Init(TAOS_MD5_CTX *mdContext) { ...@@ -94,12 +94,15 @@ void taos_MD5Init(TAOS_MD5_CTX *mdContext) {
mdContext->buf[2] = (uint32_t)0x98badcfe; mdContext->buf[2] = (uint32_t)0x98badcfe;
mdContext->buf[3] = (uint32_t)0x10325476; mdContext->buf[3] = (uint32_t)0x10325476;
} }
void MD5Init(MD5_CTX *mdContext) {
return tMD5Init(mdContext);
}
/* The routine taos_MD5Update updates the message-digest context to /* The routine tMD5Update updates the message-digest context to
account for the presence of each of the characters inBuf[0..inLen-1] account for the presence of each of the characters inBuf[0..inLen-1]
in the message whose digest is being computed. in the message whose digest is being computed.
*/ */
void taos_MD5Update(TAOS_MD5_CTX *mdContext, uint8_t *inBuf, unsigned int inLen) { void tMD5Update(T_MD5_CTX *mdContext, uint8_t *inBuf, unsigned int inLen) {
uint32_t in[16]; uint32_t in[16];
int mdi; int mdi;
unsigned int i, ii; unsigned int i, ii;
...@@ -126,11 +129,14 @@ void taos_MD5Update(TAOS_MD5_CTX *mdContext, uint8_t *inBuf, unsigned int inLen) ...@@ -126,11 +129,14 @@ void taos_MD5Update(TAOS_MD5_CTX *mdContext, uint8_t *inBuf, unsigned int inLen)
} }
} }
} }
void MD5Update(MD5_CTX *mdContext, uint8_t *inBuf, unsigned int inLen) {
return tMD5Update(mdContext, inBuf, inLen);
}
/* The routine taos_MD5Final terminates the message-digest computation and /* The routine tMD5Final terminates the message-digest computation and
ends with the desired message digest in mdContext->digest[0...15]. ends with the desired message digest in mdContext->digest[0...15].
*/ */
void taos_MD5Final(TAOS_MD5_CTX *mdContext) { void tMD5Final(T_MD5_CTX *mdContext) {
uint32_t in[16]; uint32_t in[16];
int mdi; int mdi;
unsigned int i, ii; unsigned int i, ii;
...@@ -145,7 +151,7 @@ void taos_MD5Final(TAOS_MD5_CTX *mdContext) { ...@@ -145,7 +151,7 @@ void taos_MD5Final(TAOS_MD5_CTX *mdContext) {
/* pad out to 56 mod 64 */ /* pad out to 56 mod 64 */
padLen = (mdi < 56) ? (56 - mdi) : (120 - mdi); padLen = (mdi < 56) ? (56 - mdi) : (120 - mdi);
taos_MD5Update(mdContext, PADDING, padLen); tMD5Update(mdContext, PADDING, padLen);
/* append length in bits and transform */ /* append length in bits and transform */
for (i = 0, ii = 0; i < 14; i++, ii += 4) for (i = 0, ii = 0; i < 14; i++, ii += 4)
...@@ -161,6 +167,9 @@ void taos_MD5Final(TAOS_MD5_CTX *mdContext) { ...@@ -161,6 +167,9 @@ void taos_MD5Final(TAOS_MD5_CTX *mdContext) {
mdContext->digest[ii + 3] = (uint8_t)((mdContext->buf[i] >> 24) & 0xFF); mdContext->digest[ii + 3] = (uint8_t)((mdContext->buf[i] >> 24) & 0xFF);
} }
} }
void MD5Final(MD5_CTX *mdContext) {
return tMD5Final(mdContext);
}
/* Basic MD5 step. Transforms buf based on in. /* Basic MD5 step. Transforms buf based on in.
*/ */
......
...@@ -455,11 +455,11 @@ char *taosIpStr(uint32_t ipInt) { ...@@ -455,11 +455,11 @@ char *taosIpStr(uint32_t ipInt) {
} }
void jsonKeyMd5(void *pMsg, int msgLen, void *pKey) { void jsonKeyMd5(void *pMsg, int msgLen, void *pKey) {
TAOS_MD5_CTX context; T_MD5_CTX context;
taos_MD5Init(&context); tMD5Init(&context);
taos_MD5Update(&context, (uint8_t *)pMsg, msgLen); tMD5Update(&context, (uint8_t *)pMsg, msgLen);
taos_MD5Final(&context); tMD5Final(&context);
memcpy(pKey, context.digest, sizeof(context.digest)); memcpy(pKey, context.digest, sizeof(context.digest));
} }
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册