运行 Crystal程序时程序接收到IOT信号但没有处理(6)

Program received and didn't handle signal IOT (6), when run Crystal program

我有链接到 C 库的程序 "nats"

@[Link("nats")]
lib LibNats
  fun natsConnection_ConnectTo(connection: UInt64*, connstr: UInt8*)
  fun natsConnection_PublishString(connection: UInt64*, key: UInt8*, value: UInt8*)
  fun natsConnection_Subscribe(sub: UInt64*, connection: UInt64*, key: UInt8*, cb: (UInt64*, UInt64*, UInt64*) -> Void)
end

connection = uninitialized UInt64
s = uninitialized UInt64

LibNats.natsConnection_ConnectTo(pointerof(connection), "nats://localhost:4222")
LibNats.natsConnection_Subscribe(pointerof(s), pointerof(connection), "qwe", ->(c, s, m) {
  puts m
})
LibNats.natsConnection_PublishString(pointerof(connection), "qwe", "{}")

在 运行 之后,我收到错误:Program received and didn't handle signal IOT (6)

为了解决问题,我使用显式指针 Pointer(UInt64).new(...) 而不是 pointerof(...):

LibNats.natsConnection_ConnectTo(pointerof(connection), "nats://localhost:4222")
LibNats.natsConnection_Subscribe(pointerof(s), Pointer(UInt64).new(connection), "qwe", ->(c, s, m) {
  puts m
})
LibNats.natsConnection_PublishString(Pointer(UInt64).new(connection), "qwe", "{}")

查看 include file 第一个函数是:

NATS_EXTERN natsStatus
natsConnection_ConnectTo(natsConnection **nc, const char *urls);

看看那里的双指针,而在你的绑定中你只使用一个指针。

这在 C 库中很常见:你有一些数据结构 (natsConnection),你通常通过引用传递它(因此是一个指针),但你在 "constructor" 函数,您要存储该指针的位置,通常由函数本身为其分配内存。

无论如何,解释真的很长,我现在没有时间,但试试这个:

@[Link("nats")]
lib LibNats
  type Conn = Void*
  type Sub = Void*

  alias Status = Int32

  fun natsConnection_ConnectTo(connection : Conn*, connstr : UInt8*) : Status
  fun natsConnection_PublishString(connection : Conn, key : UInt8*, value : UInt8*) : Status
  fun natsConnection_Subscribe(sub : Sub*, connection : Conn, key : UInt8*, cb : (UInt64*, UInt64*, UInt64*) -> Void) : Status
end

status = LibNats.natsConnection_ConnectTo(out connection, "nats://localhost:4222")
abort "natsConnection_ConnectTo failed" if status != 0

status = LibNats.natsConnection_Subscribe(out subscription, connection, "qwe", ->(c, s, m) {
  puts m
})
abort "natsConnection_Subscribe failed" if status != 0

status = LibNats.natsConnection_PublishString(connection, "qwe", "{}")
abort "natsConnection_PublishString failed" if status != 0

另请阅读 out keyword 并确保检查错误。