MySQL NDB API AccessViolationException

Question

Mam do czynienia z interesującym problemem, który występuje tylko w systemie Windows, podczas gdy w systemie Linux/Mono wszystko działa poprawnie. Zbudowałem wrapper C++ wokół biblioteki interfejsu API NDB MySQL Cluster, którą wywołuję z kodu C# poprzez P/Invoke. Do tej pory mam trzy metody:

1. init() który inicjuje środowisko i zwraca uchwyt
2. read() który odczytuje dane z bazy danych za pomocą uchwytu
3. release() który uwalnia zasoby

init() działa dobrze w każdej konfiguracji. Jednak read() rzuca AccessViolationException, ale tylko w systemie Windows i tylko w przypadku, gdy init() jest wywoływany w jednym wątku i read() w innym. Jeśli zrobimy wszystko w jednym wątku, to działa! Wszelkie przemyślenia na temat możliwej przyczyny zostaną docenione.

Aktualizacja 04.12.2016 - to samo zachowanie został zauważony za pomocą prostego C++ programu testowego gdzie init() jest wywoływane w jednym wątku i read() w innym. Dlatego błąd nie ma nic wspólnego z C#/C++, jest czymś w bibliotece API NDB, które można pobrać here (lib folder, mysqlclient.lib i ndbclient_static.lib).

C# Kod:

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++ Kod: (na podstawie przykładów z official documentation):

#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 
    .. 
} 

Answer 1

za pomocą MySQL listy Cluster korespondencji, znalazłem obejście tego problemu .

Jeśli chcesz odczytać dane poprzez NDB API w wątku innego niż ten, w którym powołuje ndb_init() i uzyskanych Ndb_cluster_connection, konieczne jest, aby zadzwonić mysql_thread_init() na początku tego drugiego wątku. Jednak nie jest to oczekiwane zachowanie, ani nie jest udokumentowane, dlatego zgłosiłem a bug.