|
@@ -19,6 +19,7 @@
|
|
*/
|
|
*/
|
|
|
|
|
|
#include "qemu/osdep.h"
|
|
#include "qemu/osdep.h"
|
|
|
|
+#include "qemu/thread.h"
|
|
#include "qapi/error.h"
|
|
#include "qapi/error.h"
|
|
#include "crypto/pbkdf.h"
|
|
#include "crypto/pbkdf.h"
|
|
#ifndef _WIN32
|
|
#ifndef _WIN32
|
|
@@ -85,12 +86,28 @@ static int qcrypto_pbkdf2_get_thread_cpu(unsigned long long *val_ms,
|
|
#endif
|
|
#endif
|
|
}
|
|
}
|
|
|
|
|
|
-uint64_t qcrypto_pbkdf2_count_iters(QCryptoHashAlgorithm hash,
|
|
|
|
- const uint8_t *key, size_t nkey,
|
|
|
|
- const uint8_t *salt, size_t nsalt,
|
|
|
|
- size_t nout,
|
|
|
|
- Error **errp)
|
|
|
|
|
|
+typedef struct CountItersData {
|
|
|
|
+ QCryptoHashAlgorithm hash;
|
|
|
|
+ const uint8_t *key;
|
|
|
|
+ size_t nkey;
|
|
|
|
+ const uint8_t *salt;
|
|
|
|
+ size_t nsalt;
|
|
|
|
+ size_t nout;
|
|
|
|
+ uint64_t iterations;
|
|
|
|
+ Error **errp;
|
|
|
|
+} CountItersData;
|
|
|
|
+
|
|
|
|
+static void *threaded_qcrypto_pbkdf2_count_iters(void *data)
|
|
{
|
|
{
|
|
|
|
+ CountItersData *iters_data = (CountItersData *) data;
|
|
|
|
+ QCryptoHashAlgorithm hash = iters_data->hash;
|
|
|
|
+ const uint8_t *key = iters_data->key;
|
|
|
|
+ size_t nkey = iters_data->nkey;
|
|
|
|
+ const uint8_t *salt = iters_data->salt;
|
|
|
|
+ size_t nsalt = iters_data->nsalt;
|
|
|
|
+ size_t nout = iters_data->nout;
|
|
|
|
+ Error **errp = iters_data->errp;
|
|
|
|
+
|
|
uint64_t ret = -1;
|
|
uint64_t ret = -1;
|
|
g_autofree uint8_t *out = g_new(uint8_t, nout);
|
|
g_autofree uint8_t *out = g_new(uint8_t, nout);
|
|
uint64_t iterations = (1 << 15);
|
|
uint64_t iterations = (1 << 15);
|
|
@@ -114,7 +131,10 @@ uint64_t qcrypto_pbkdf2_count_iters(QCryptoHashAlgorithm hash,
|
|
|
|
|
|
delta_ms = end_ms - start_ms;
|
|
delta_ms = end_ms - start_ms;
|
|
|
|
|
|
- if (delta_ms > 500) {
|
|
|
|
|
|
+ if (delta_ms == 0) { /* sanity check */
|
|
|
|
+ error_setg(errp, "Unable to get accurate CPU usage");
|
|
|
|
+ goto cleanup;
|
|
|
|
+ } else if (delta_ms > 500) {
|
|
break;
|
|
break;
|
|
} else if (delta_ms < 100) {
|
|
} else if (delta_ms < 100) {
|
|
iterations = iterations * 10;
|
|
iterations = iterations * 10;
|
|
@@ -129,5 +149,24 @@ uint64_t qcrypto_pbkdf2_count_iters(QCryptoHashAlgorithm hash,
|
|
|
|
|
|
cleanup:
|
|
cleanup:
|
|
memset(out, 0, nout);
|
|
memset(out, 0, nout);
|
|
- return ret;
|
|
|
|
|
|
+ iters_data->iterations = ret;
|
|
|
|
+ return NULL;
|
|
|
|
+}
|
|
|
|
+
|
|
|
|
+uint64_t qcrypto_pbkdf2_count_iters(QCryptoHashAlgorithm hash,
|
|
|
|
+ const uint8_t *key, size_t nkey,
|
|
|
|
+ const uint8_t *salt, size_t nsalt,
|
|
|
|
+ size_t nout,
|
|
|
|
+ Error **errp)
|
|
|
|
+{
|
|
|
|
+ CountItersData data = {
|
|
|
|
+ hash, key, nkey, salt, nsalt, nout, 0, errp
|
|
|
|
+ };
|
|
|
|
+ QemuThread thread;
|
|
|
|
+
|
|
|
|
+ qemu_thread_create(&thread, "pbkdf2", threaded_qcrypto_pbkdf2_count_iters,
|
|
|
|
+ &data, QEMU_THREAD_JOINABLE);
|
|
|
|
+ qemu_thread_join(&thread);
|
|
|
|
+
|
|
|
|
+ return data.iterations;
|
|
}
|
|
}
|