This function is to bulk insert directly to storage provider bypassing in memory, assumes rgKeys and rgVals are not sds strings */
| 3015 | |
| 3016 | /* This function is to bulk insert directly to storage provider bypassing in memory, assumes rgKeys and rgVals are not sds strings */ |
| 3017 | void redisDbPersistentData::bulkDirectStorageInsert(char **rgKeys, size_t *rgcbKeys, char **rgVals, size_t *rgcbVals, size_t celem) |
| 3018 | { |
| 3019 | if (g_pserver->cluster_enabled) { |
| 3020 | aeAcquireLock(); |
| 3021 | for (size_t i = 0; i < celem; i++) { |
| 3022 | slotToKeyUpdateKeyCore(rgKeys[i], rgcbKeys[i], 1); |
| 3023 | } |
| 3024 | aeReleaseLock(); |
| 3025 | } |
| 3026 | m_spstorage->bulkInsert(rgKeys, rgcbKeys, rgVals, rgcbVals, celem); |
| 3027 | } |
| 3028 | |
| 3029 | void redisDbPersistentData::commitChanges(const redisDbPersistentDataSnapshot **psnapshotFree) |
| 3030 | { |
no test coverage detected