Bug #8386 » openssl_thread_safety.patch
| ext/openssl/ossl.c | ||
|---|---|---|
|
#endif
|
||
|
}
|
||
|
/**
|
||
|
* Stores locks needed for OpenSSL thread safety
|
||
|
*/
|
||
|
static VALUE* ossl_locks;
|
||
|
static void ossl_lock_callback(int mode, int type, char *file, int line)
|
||
|
{
|
||
|
if (mode & CRYPTO_LOCK) {
|
||
|
rb_mutex_lock(ossl_locks[type]);
|
||
|
} else {
|
||
|
rb_mutex_unlock(ossl_locks[type]);
|
||
|
}
|
||
|
}
|
||
|
static unsigned long ossl_thread_id(void)
|
||
|
{
|
||
|
return NUM2ULONG(rb_obj_id(rb_thread_current()));
|
||
|
}
|
||
|
static void Init_ossl_locks(void)
|
||
|
{
|
||
|
ossl_locks = (VALUE*) OPENSSL_malloc(CRYPTO_num_locks() * sizeof(VALUE));
|
||
|
for (int i = 0; i < CRYPTO_num_locks(); i++) {
|
||
|
ossl_locks[i] = rb_mutex_new();
|
||
|
rb_global_variable(&(ossl_locks[i]));
|
||
|
}
|
||
|
CRYPTO_set_id_callback((unsigned long (*)())ossl_thread_id);
|
||
|
CRYPTO_set_locking_callback((void (*)())ossl_lock_callback);
|
||
|
}
|
||
|
/*
|
||
|
* OpenSSL provides SSL, TLS and general purpose cryptography. It wraps the
|
||
|
* OpenSSL[http://www.openssl.org/] library.
|
||
| ... | ... | |
|
* Init main module
|
||
|
*/
|
||
|
mOSSL = rb_define_module("OpenSSL");
|
||
|
rb_global_variable(&mOSSL);
|
||
|
/*
|
||
|
* OpenSSL ruby extension version
|
||
| ... | ... | |
|
* common for all classes under OpenSSL module
|
||
|
*/
|
||
|
eOSSLError = rb_define_class_under(mOSSL,"OpenSSLError",rb_eStandardError);
|
||
|
rb_global_variable(&eOSSLError);
|
||
|
/*
|
||
|
* Verify callback Proc index for ext-data
|
||
| ... | ... | |
|
* Init debug core
|
||
|
*/
|
||
|
dOSSL = Qfalse;
|
||
|
rb_global_variable(&dOSSL);
|
||
|
rb_define_module_function(mOSSL, "debug", ossl_debug_get, 0);
|
||
|
rb_define_module_function(mOSSL, "debug=", ossl_debug_set, 1);
|
||
|
rb_define_module_function(mOSSL, "errors", ossl_get_errors, 0);
|
||
| ... | ... | |
|
*/
|
||
|
ossl_s_to_der = rb_intern("to_der");
|
||
|
Init_ossl_locks();
|
||
|
/*
|
||
|
* Init components
|
||
|
*/
|
||