1
0
mirror of https://github.com/mariadb-corporation/mariadb-connector-c.git synced 2025-08-08 14:02:17 +03:00

Merge remote-tracking branch 'origin/3.4' into HEAD

This commit is contained in:
Sergei Golubchik
2024-08-03 16:38:02 +02:00
3 changed files with 35 additions and 16 deletions

View File

@@ -20,6 +20,13 @@ ELSE()
UNSET(CRYPTO_PLUGIN) UNSET(CRYPTO_PLUGIN)
ENDIF() ENDIF()
# GCC < 3.9 does not support thread-local storage in C
IF(CMAKE_C_COMPILER_ID MATCHES "GNU" AND CMAKE_C_COMPILER_VERSION VERSION_LESS "4.9")
SET(HAVE_C_THREAD_LOCAL 0)
ELSE()
SET(HAVE_C_THREAD_LOCAL 1)
ENDIF()
#native password #native password
REGISTER_PLUGIN(TARGET mysql_native_password REGISTER_PLUGIN(TARGET mysql_native_password
TYPE MARIADB_CLIENT_PLUGIN_AUTH TYPE MARIADB_CLIENT_PLUGIN_AUTH
@@ -62,6 +69,12 @@ IF(CRYPTO_PLUGIN)
INCLUDES ${REF10_DIR} INCLUDES ${REF10_DIR}
LIBRARIES ${CRYPT_LIBS} LIBRARIES ${CRYPT_LIBS}
COMPILE_OPTIONS -DMYSQL_CLIENT=1) COMPILE_OPTIONS -DMYSQL_CLIENT=1)
SET_PROPERTY(TARGET client_ed25519 PROPERTY C_STANDARD 11)
IF(HAVE_C_THREAD_LOCAL)
TARGET_COMPILE_DEFINITIONS(client_ed25519 PRIVATE -DHAVE_THREAD_LOCAL)
ENDIF()
IF(MSVC) IF(MSVC)
# Silence conversion (integer truncation) warnings from reference code # Silence conversion (integer truncation) warnings from reference code
SET_SOURCE_FILES_PROPERTIES(${REF10_SOURCES} PROPERTY COMPILE_FLAGS "-DMYSQL_CLIENT=1 /wd4244 /wd4146") SET_SOURCE_FILES_PROPERTIES(${REF10_SOURCES} PROPERTY COMPILE_FLAGS "-DMYSQL_CLIENT=1 /wd4244 /wd4146")

View File

@@ -88,15 +88,20 @@ struct st_mysql_client_plugin_AUTHENTICATION _mysql_client_plugin_declaration_ =
auth_ed25519_hash auth_ed25519_hash
}; };
#ifdef HAVE_THREAD_LOCAL
/* pk will be used in the future auth_ed25519_hash() call, after the authentication */
static _Thread_local unsigned char pk[CRYPTO_PUBLICKEYBYTES];
#endif
static int auth_ed25519_client(MYSQL_PLUGIN_VIO *vio, MYSQL *mysql) static int auth_ed25519_client(MYSQL_PLUGIN_VIO *vio, MYSQL *mysql)
{ {
unsigned char *packet, unsigned char *packet,
signature[CRYPTO_BYTES + NONCE_BYTES], signature[CRYPTO_BYTES + NONCE_BYTES];
pk[CRYPTO_PUBLICKEYBYTES]; #ifndef HAVE_THREAD_LOCAL
unsigned char pk[CRYPTO_PUBLICKEYBYTES];
#endif
unsigned long long pkt_len; unsigned long long pkt_len;
size_t pwlen= strlen(mysql->passwd); size_t pwlen= strlen(mysql->passwd);
char *newpw;
/* /*
Step 1: Server sends nonce Step 1: Server sends nonce
@@ -117,26 +122,27 @@ static int auth_ed25519_client(MYSQL_PLUGIN_VIO *vio, MYSQL *mysql)
if (vio->write_packet(vio, signature, CRYPTO_BYTES)) if (vio->write_packet(vio, signature, CRYPTO_BYTES))
return CR_ERROR; return CR_ERROR;
/* save pk for the future auth_ed25519_hash() call */
if ((newpw= realloc(mysql->passwd, pwlen + 1 + sizeof(pk))))
{
memcpy(newpw + pwlen + 1, pk, sizeof(pk));
mysql->passwd= newpw;
}
return CR_OK; return CR_OK;
} }
/* }}} */ /* }}} */
/* {{{ static int auth_ed25519_hash */ /* {{{ static int auth_ed25519_hash */
static int auth_ed25519_hash(MYSQL *mysql, unsigned char *out, size_t *outlen) static int auth_ed25519_hash(MYSQL *mysql __attribute__((unused)),
unsigned char *out, size_t *outlen)
{ {
#ifndef HAVE_THREAD_LOCAL
unsigned char pk[CRYPTO_PUBLICKEYBYTES];
#endif
if (*outlen < CRYPTO_PUBLICKEYBYTES) if (*outlen < CRYPTO_PUBLICKEYBYTES)
return 1; return 1;
*outlen= CRYPTO_PUBLICKEYBYTES; *outlen= CRYPTO_PUBLICKEYBYTES;
#ifndef HAVE_THREAD_LOCAL
crypto_sign_keypair(pk, (unsigned char*)mysql->passwd, strlen(mysql->passwd));
#endif
/* use the cached value */ /* use the cached value */
memcpy(out, mysql->passwd + strlen(mysql->passwd) + 1, CRYPTO_PUBLICKEYBYTES); memcpy(out, pk, CRYPTO_PUBLICKEYBYTES);
return 0; return 0;
} }
/* }}} */ /* }}} */

View File

@@ -1125,8 +1125,8 @@ static int bulk_with_unit_result_insert(MYSQL *my)
check_stmt_rc(rc, stmt); check_stmt_rc(rc, stmt);
/* allocate memory */ /* allocate memory */
buffer= calloc(TEST_ARRAY_SIZE, sizeof(char *)); buffer= calloc(TEST_ARRAY_SIZE, sizeof *buffer);
lengths= (unsigned long *)calloc(sizeof(long), TEST_ARRAY_SIZE); lengths= calloc(TEST_ARRAY_SIZE, sizeof *lengths);
for (i=0; i < TEST_ARRAY_SIZE; i++) for (i=0; i < TEST_ARRAY_SIZE; i++)
{ {
@@ -1251,7 +1251,7 @@ static int bulk_with_unit_result_delete(MYSQL *my)
rc= mysql_stmt_attr_set(stmt, STMT_ATTR_ARRAY_SIZE, &array_size); rc= mysql_stmt_attr_set(stmt, STMT_ATTR_ARRAY_SIZE, &array_size);
check_stmt_rc(rc, stmt); check_stmt_rc(rc, stmt);
vals= (unsigned int *)calloc(sizeof(int), 5); vals= calloc(5, sizeof *vals);
memset(bind, 0, sizeof(MYSQL_BIND) * 1); memset(bind, 0, sizeof(MYSQL_BIND) * 1);
bind[0].buffer_type= MYSQL_TYPE_LONG; bind[0].buffer_type= MYSQL_TYPE_LONG;
bind[0].buffer= vals; bind[0].buffer= vals;
@@ -1359,7 +1359,7 @@ static int bulk_with_unit_result_update(MYSQL *my)
rc= mysql_stmt_attr_set(stmt, STMT_ATTR_ARRAY_SIZE, &array_size); rc= mysql_stmt_attr_set(stmt, STMT_ATTR_ARRAY_SIZE, &array_size);
check_stmt_rc(rc, stmt); check_stmt_rc(rc, stmt);
vals= (unsigned int *)calloc(sizeof(int), 5); vals= calloc(5, sizeof *vals);
memset(bind, 0, sizeof(MYSQL_BIND) * 1); memset(bind, 0, sizeof(MYSQL_BIND) * 1);
bind[0].buffer_type= MYSQL_TYPE_LONG; bind[0].buffer_type= MYSQL_TYPE_LONG;
bind[0].buffer= vals; bind[0].buffer= vals;