我面临一个仅在 Windows 上发生的有趣问题,而在 Linux/Mono 上一切正常。我围绕 MySQL Cluster NDB API 库构建了一个 C++ 包装器,我通过 P/Invoke 从 C# 代码调用该库。到目前为止,我有三种方法:
init()
它初始化环境并返回一个句柄read()
它使用句柄从数据库中读取数据release()
释放资源
init()
在每个设置中都可以正常工作。但是,read()
throws AccessViolationException
,但仅在 Windows 上,并且仅在init()
一个线程和另一个线程中调用when 的情况下read()
。如果我们在一个线程中做所有事情,它就可以工作!任何关于可能原因的想法将不胜感激。
2016 年 12 月 4日更新init()
-在一个线程和另一个线程中调用的简单 C++ 测试程序中发现了相同的行为read()
。因此,该错误与 C#/C++ 互操作无关,它是 NDB API 库中的内容,可以在此处下载(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
..
}