MySQL NDB API AccessViolationException

Я сталкиваюсь с интересной проблемой, которая возникает только в Windows, в то время как в Linux / Mono все работает нормально. Я создал оболочку C ++ вокруг библиотеки API MySQL Cluster NDB, которую я вызываю из кода C # через P / Invoke. Пока у меня есть три метода:

1. init() который инициализирует среду и возвращает дескриптор
2. read() который читает данные из базы данных, используя дескриптор
3. release() который высвобождает ресурсы

init() отлично работает в каждой настройке. Тем не мение, read() бросает AccessViolationException, но только на Windows и только в случае, когда init() вызывается в одном потоке и read() в другой. Если мы делаем все в одном потоке, это работает! Любые мысли о возможной причине будут оценены.

Обновление 4/4/2016 — такое же поведение было замечено с простой тестовой программой C ++, где init() вызывается в одном потоке и read() в другой. Следовательно, ошибка не имеет ничего общего с взаимодействием C # / C ++, это нечто внутри библиотеки API NDB, которую можно загрузить Вот (lib папка, mysqlclient.lib а также ndbclient_static.lib).

Код C #:

private const string ndbapi = "ndb";

[DllImport(ndbapi)]
public extern static IntPtr init(IntPtr conn_string);

[DllImport(ndbapi)]
public extern static void read(IntPtr ndb_cluster_conn);

[DllImport(ndbapi)]
public extern static void release(IntPtr ndb_cluster_conn, IntPtr char_arr_ptr);

private static IntPtr handle;

private static void InitNdb() {
unsafe {
fixed (byte* conn_buf = Encoding.UTF8.GetBytes("node1:1186")) {
handle = ndb_api_init(new IntPtr(conn_buf));
}
}
}
static void Main(string[] args) {
Thread t = new Thread(InitNdb);// IF I CALL InitNDB IN THE SAME THREAD, EVERYTHING WORKS
t.Start();
.. //waiting for Thread t to complete...
IntPtr bytes_read = read(handle);
...
}

Код C ++: (на основе примеров из официальная документация):

#if defined(WIN32)

#define DLLEXPORT __declspec(dllexport)
#define CALLCV __stdcall

#else

#define DLLEXPORT __attribute__((visibility("default")))
#define CALLCV __attribute__((cdecl))

#endif
..
extern "C" DLLEXPORT Ndb_cluster_connection* CALLCV init(char* connection_string) {

ndb_init();

// Object representing the cluster
Ndb_cluster_connection* cluster_connection = new Ndb_cluster_connection(connection_string);

if (cluster_connection->connect(3, 2, 1)) {
std::cout << "Cluster management server not ready,error:" << cluster_connection->get_latest_error_msg() << "\n";
exit(-1);
}
if (cluster_connection->wait_until_ready(10, 0) < 0) {
std::cout << "Cluster not ready within 10 secs, error:" << cluster_connection->get_latest_error_msg() << std::endl;
}

return cluster_connection;
}
extern "C" DLLEXPORT char** CALLCV read(Ndb_cluster_connection* cluster_connection) {
Ndb *ndb_obj = new Ndb(cluster_connection, db_name);
if (ndb_obj->init()) {
std::cout << "Error while initializing Ndb " << std::endl;
}

const NdbDictionary::Dictionary* dict = ndb_obj->getDictionary();
const NdbDictionary::Table *table = dict->getTable("table_name"); <-- THIS IS THE LINE THAT THROWS ACCESS VIOLATION EXCEPTION
..
}