I downloaded and built libzmq 3.2.2 from source. Running pkg-config --cflags libzmq returns -I/usr/local/include. I have a zmq.h file there and the version reads as follows:

define ZMQ_VERSION_MAJOR 3

define ZMQ_VERSION_MINOR 2

define ZMQ_VERSION_PATCH 2

Similarly, running pkg-config --libs-only-L libzmq returns -L/usr/local/lib and I have the following files there:

/usr/local/lib/libzmq.a
/usr/local/lib/libzmq.la
/usr/local/lib/libzmq.so
/usr/local/lib/libzmq.so.3
/usr/local/lib/libzmq.so.3.0.0

I previously had version 2.x.x installed through apt-get but I uninstalled that version.

Here's the full list of errors when I try to compile my code that uses zmq3 package:

/var/tmp/go-link-fvuXsH/000001.o: In function _cgo_e99ae710c4d9_C2func_zmq_poll': /home/ezbercih/code/go/src/github.com/pebbe/zmq3/polling.go:41: undefined reference tozmq_poll' /var/tmp/go-link-fvuXsH/000001.o: In function _cgo_e99ae710c4d9_Cfunc_zmq_poll': /home/ezbercih/code/go/src/github.com/pebbe/zmq3/polling.go:56: undefined reference tozmq_poll' /var/tmp/go-link-fvuXsH/000001.o: In function _cgo_e99ae710c4d9_C2func_zmq_getsockopt': /home/ezbercih/code/go/src/github.com/pebbe/zmq3/socketget.go:43: undefined reference tozmq_getsockopt' /var/tmp/go-link-fvuXsH/000001.o: In function _cgo_e99ae710c4d9_Cfunc_zmq_getsockopt': /home/ezbercih/code/go/src/github.com/pebbe/zmq3/socketget.go:59: undefined reference tozmq_getsockopt' /var/tmp/go-link-fvuXsH/000001.o: In function _cgo_e99ae710c4d9_C2func_zmq_setsockopt': /home/ezbercih/code/go/src/github.com/pebbe/zmq3/socketset.go:44: undefined reference tozmq_setsockopt' /var/tmp/go-link-fvuXsH/000001.o: In function _cgo_e99ae710c4d9_Cfunc_zmq_setsockopt': /home/ezbercih/code/go/src/github.com/pebbe/zmq3/socketset.go:69: undefined reference tozmq_setsockopt' /var/tmp/go-link-fvuXsH/000001.o: In function get_event': /home/ezbercih/code/go/src/github.com/pebbe/zmq3/zmq3.go:16: undefined reference tozmq_msg_data' /var/tmp/go-link-fvuXsH/000001.o: In function _cgo_e99ae710c4d9_C2func_zmq_bind': /home/ezbercih/code/go/src/github.com/pebbe/zmq3/zmq3.go:61: undefined reference tozmq_bind' /var/tmp/go-link-fvuXsH/000001.o: In function _cgo_e99ae710c4d9_C2func_zmq_close': /home/ezbercih/code/go/src/github.com/pebbe/zmq3/zmq3.go:76: undefined reference tozmq_close' /var/tmp/go-link-fvuXsH/000001.o: In function _cgo_e99ae710c4d9_C2func_zmq_connect': /home/ezbercih/code/go/src/github.com/pebbe/zmq3/zmq3.go:92: undefined reference tozmq_connect' /var/tmp/go-link-fvuXsH/000001.o: In function _cgo_e99ae710c4d9_C2func_zmq_ctx_get': /home/ezbercih/code/go/src/github.com/pebbe/zmq3/zmq3.go:109: undefined reference tozmq_ctx_get' /var/tmp/go-link-fvuXsH/000001.o: In function _cgo_e99ae710c4d9_C2func_zmq_ctx_new': /home/ezbercih/code/go/src/github.com/pebbe/zmq3/zmq3.go:122: undefined reference tozmq_ctx_new' /var/tmp/go-link-fvuXsH/000001.o: In function _cgo_e99ae710c4d9_C2func_zmq_ctx_set': /home/ezbercih/code/go/src/github.com/pebbe/zmq3/zmq3.go:139: undefined reference tozmq_ctx_set' /var/tmp/go-link-fvuXsH/000001.o: In function _cgo_e99ae710c4d9_C2func_zmq_disconnect': /home/ezbercih/code/go/src/github.com/pebbe/zmq3/zmq3.go:155: undefined reference tozmq_disconnect' /var/tmp/go-link-fvuXsH/000001.o: In function _cgo_e99ae710c4d9_C2func_zmq_msg_init': /home/ezbercih/code/go/src/github.com/pebbe/zmq3/zmq3.go:170: undefined reference tozmq_msg_init' /var/tmp/go-link-fvuXsH/000001.o: In function _cgo_e99ae710c4d9_C2func_zmq_msg_recv': /home/ezbercih/code/go/src/github.com/pebbe/zmq3/zmq3.go:188: undefined reference tozmq_msg_recv' /var/tmp/go-link-fvuXsH/000001.o: In function _cgo_e99ae710c4d9_C2func_zmq_proxy': /home/ezbercih/code/go/src/github.com/pebbe/zmq3/zmq3.go:205: undefined reference tozmq_proxy' /var/tmp/go-link-fvuXsH/000001.o: In function _cgo_e99ae710c4d9_C2func_zmq_send': /home/ezbercih/code/go/src/github.com/pebbe/zmq3/zmq3.go:224: undefined reference tozmq_send' /var/tmp/go-link-fvuXsH/000001.o: In function _cgo_e99ae710c4d9_C2func_zmq_socket': /home/ezbercih/code/go/src/github.com/pebbe/zmq3/zmq3.go:240: undefined reference tozmq_socket' /var/tmp/go-link-fvuXsH/000001.o: In function _cgo_e99ae710c4d9_C2func_zmq_socket_monitor': /home/ezbercih/code/go/src/github.com/pebbe/zmq3/zmq3.go:258: undefined reference tozmq_socket_monitor' /var/tmp/go-link-fvuXsH/000001.o: In function _cgo_e99ae710c4d9_C2func_zmq_unbind': /home/ezbercih/code/go/src/github.com/pebbe/zmq3/zmq3.go:274: undefined reference tozmq_unbind' /var/tmp/go-link-fvuXsH/000001.o: In function _cgo_e99ae710c4d9_Cfunc_zmq_bind': /home/ezbercih/code/go/src/github.com/pebbe/zmq3/zmq3.go:311: undefined reference tozmq_bind' /var/tmp/go-link-fvuXsH/000001.o: In function _cgo_e99ae710c4d9_Cfunc_zmq_close': /home/ezbercih/code/go/src/github.com/pebbe/zmq3/zmq3.go:322: undefined reference tozmq_close' /var/tmp/go-link-fvuXsH/000001.o: In function _cgo_e99ae710c4d9_Cfunc_zmq_connect': /home/ezbercih/code/go/src/github.com/pebbe/zmq3/zmq3.go:334: undefined reference tozmq_connect' /var/tmp/go-link-fvuXsH/000001.o: In function _cgo_e99ae710c4d9_Cfunc_zmq_ctx_get': /home/ezbercih/code/go/src/github.com/pebbe/zmq3/zmq3.go:347: undefined reference tozmq_ctx_get' /var/tmp/go-link-fvuXsH/000001.o: In function _cgo_e99ae710c4d9_Cfunc_zmq_ctx_new': /home/ezbercih/code/go/src/github.com/pebbe/zmq3/zmq3.go:356: undefined reference tozmq_ctx_new' /var/tmp/go-link-fvuXsH/000001.o: In function _cgo_e99ae710c4d9_Cfunc_zmq_ctx_set': /home/ezbercih/code/go/src/github.com/pebbe/zmq3/zmq3.go:369: undefined reference tozmq_ctx_set' /var/tmp/go-link-fvuXsH/000001.o: In function _cgo_e99ae710c4d9_Cfunc_zmq_disconnect': /home/ezbercih/code/go/src/github.com/pebbe/zmq3/zmq3.go:381: undefined reference tozmq_disconnect' /var/tmp/go-link-fvuXsH/000001.o: In function _cgo_e99ae710c4d9_Cfunc_zmq_msg_close': /home/ezbercih/code/go/src/github.com/pebbe/zmq3/zmq3.go:392: undefined reference tozmq_msg_close' /var/tmp/go-link-fvuXsH/000001.o: In function _cgo_e99ae710c4d9_Cfunc_zmq_msg_data': /home/ezbercih/code/go/src/github.com/pebbe/zmq3/zmq3.go:402: undefined reference tozmq_msg_data' /var/tmp/go-link-fvuXsH/000001.o: In function _cgo_e99ae710c4d9_Cfunc_zmq_msg_init': /home/ezbercih/code/go/src/github.com/pebbe/zmq3/zmq3.go:413: undefined reference tozmq_msg_init' /var/tmp/go-link-fvuXsH/000001.o: In function _cgo_e99ae710c4d9_Cfunc_zmq_msg_recv': /home/ezbercih/code/go/src/github.com/pebbe/zmq3/zmq3.go:427: undefined reference tozmq_msg_recv' /var/tmp/go-link-fvuXsH/000001.o: In function _cgo_e99ae710c4d9_Cfunc_zmq_proxy': /home/ezbercih/code/go/src/github.com/pebbe/zmq3/zmq3.go:440: undefined reference tozmq_proxy' /var/tmp/go-link-fvuXsH/000001.o: In function _cgo_e99ae710c4d9_Cfunc_zmq_send': /home/ezbercih/code/go/src/github.com/pebbe/zmq3/zmq3.go:455: undefined reference tozmq_send' /var/tmp/go-link-fvuXsH/000001.o: In function _cgo_e99ae710c4d9_Cfunc_zmq_socket': /home/ezbercih/code/go/src/github.com/pebbe/zmq3/zmq3.go:467: undefined reference tozmq_socket' /var/tmp/go-link-fvuXsH/000001.o: In function _cgo_e99ae710c4d9_Cfunc_zmq_socket_monitor': /home/ezbercih/code/go/src/github.com/pebbe/zmq3/zmq3.go:481: undefined reference tozmq_socket_monitor' /var/tmp/go-link-fvuXsH/000001.o: In function _cgo_e99ae710c4d9_Cfunc_zmq_strerror': /home/ezbercih/code/go/src/github.com/pebbe/zmq3/zmq3.go:492: undefined reference tozmq_strerror' /var/tmp/go-link-fvuXsH/000001.o: In function _cgo_e99ae710c4d9_Cfunc_zmq_unbind': /home/ezbercih/code/go/src/github.com/pebbe/zmq3/zmq3.go:504: undefined reference tozmq_unbind' /var/tmp/go-link-fvuXsH/000001.o: In function _cgo_e99ae710c4d9_Cfunc_zmq_version': /home/ezbercih/code/go/src/github.com/pebbe/zmq3/zmq3.go:515: undefined reference tozmq_version' collect2: error: ld returned 1 exit status crypto/tls.extensionStatusRequest: /home/ezbercih/go/pkg/tool/linux_amd64/6l: running gcc failed: unsuccessful exit status 0x100

Any suggestions?

Thanks!

I'm using websockets with zmq running on top of it.

go version go1.3.3 linux/amd64 libzmq Version: 3.2.4

The error in question is:

Assertion failed: ok (mailbox.cpp:84)
SIGABRT: abort
PC=0x3721c35877
signal arrived during cgo execution

I looked up the mailbox.cpp error and the general consensus is that it has to do with different threads trying to use the same zmq socket.

I have a coroutine running and it communicates with the other coroutines via channels, thus other coroutines do not directly access the zmq socket.

The trace is as follows:

goroutine 22 [syscall]:
runtime.cgocall(0x402790, 0x7fa0ba589b10)
    /usr/local/go/src/pkg/runtime/cgocall.c:143 +0xe5 fp=0x7fa0ba589ae8 sp=0x7fa0ba589aa0
github.com/pebbe/zmq3._C2func_zmq_send(0x12c4c80, 0xc20a78a380, 0x7d, 0x7fa000000001, 0x4784e0, 0xc20808600d, 0xc20a78a380)
    github.com/pebbe/zmq3/_obj/_cgo_defun.c:365 +0x36 fp=0x7fa0ba589b10 sp=0x7fa0ba589ae8
github.com/pebbe/zmq3.(*Socket).SendBytes(0xc208025410, 0xc20a78a380, 0x7d, 0x80, 0x1, 0x7fa0ba589c08, 0x0, 0x0)
    /data/Projects/messaging/src/github.com/pebbe/zmq3/zmq3.go:549 +0xf0 fp=0x7fa0ba589ba8 sp=0x7fa0ba589b10
github.com/pebbe/zmq3.(*Socket).Send(0xc208025410, 0xc20a78a280, 0x7d, 0x1, 0x7d, 0x0, 0x0)
    /data/Projects/messaging/src/github.com/pebbe/zmq3/zmq3.go:536 +0x76 fp=0x7fa0ba589bf0 sp=0x7fa0ba589ba8
github.com/pebbe/zmq3.(*Socket).sendMessage(0xc208025410, 0x1, 0x7fa0ba589f50, 0x1, 0x1, 0x0, 0x0, 0x0)
    /data/Projects/messaging/src/github.com/pebbe/zmq3/utils.go:59 +0x5f8 fp=0x7fa0ba589e98 sp=0x7fa0ba589bf0
github.com/pebbe/zmq3.(*Socket).SendMessageDontwait(0xc208025410, 0x7fa0ba589f50, 0x1, 0x1, 0xa5, 0x0, 0x0)
    /data/Projects/messaging/src/github.com/pebbe/zmq3/utils.go:25 +0x65 fp=0x7fa0ba589ee0 sp=0x7fa0ba589e98
plug.(*Dealer).Recv(0xc2080282b0)
    /data/Projects/messaging/src/plug/dealer.go:72 +0x2a7 fp=0x7fa0ba589fa0 sp=0x7fa0ba589ee0
runtime.goexit()
    /usr/local/go/src/pkg/runtime/proc.c:1445 fp=0x7fa0ba589fa8 sp=0x7fa0ba589fa0
created by main.main
    /data/Projects/messaging/src/wsServer.go:25 +0x25f

Any help would be appreciated.

Hi there, Is there any reason why we can't suppli Flag(DONTWAIT) to utils.SendMessage functions. If there is no particular reson, perhaps I can supply a pull request.

Thanks, Dragomir

$ go version
go version go1.1.2 darwin/amd64
mp@anane ~ $ clang --version
Apple LLVM version 5.0 (clang-500.2.79) (based on LLVM 3.3svn)
Target: x86_64-apple-darwin13.0.1
Thread model: posix
$ CC=clang go get github.com/pebbe/zmq3
# github.com/pebbe/zmq3
zmq3.go:446: cannot use _Ctype_size_t(size) (type C.size_t) as type C.ulong in function argument

Hi,

First of all, I'd like to thank you for the nice work you've done.

I'm trying to use the api but it is not compiling on my machine (ubuntu). I cloned libzmq repository and built it, which means I'm running libzmq 3.2.

This error is thrown in the C function get_event declared on zmq3.go

Best regards, Manuel Felício

Hello again, Is there any reason to name the package with the full version name, e.g. "zmq4" instead of just "zmq". I can't imagine one to use two versions of zmq in the same project.

Thanks, Dragomir

Hi. I'm trying to write a simple client listening to an epgm channel. But when I execute the code, I get the following error:

Invalid argument (session_base.cpp:490)
signal: aborted (core dumped)

When I add the line:

msg, _ := socket.Recv(0)

Am I establishing the context and socket correctly? Any ideas on how I can begin debugging this?

Here is my code:

package main

import (
    "fmt"
    zmq "github.com/pebbe/zmq3"
)

func main() {
    context, _ := zmq.NewContext()
    socket, _ := context.NewSocket(zmq.SUB)

    err := socket.Connect("epgm://address")
    if err != nil {
        panic(err.Error())
    }
    socket.SetSubscribe("")

    msg, _ := socket.Recv(0)

    fmt.Println(msg)

    socket.Close()
    context.Term()
}

Thanks for reading. Karl

I get the following when trying to get the zmq3 package. I am running ubuntu 14.04 and installed libzmq3-dev and also tried compiling from source. I run ldconfig for good measure, still the same error.

$ go get github.com/pebbe/zmq3

In file included from src/github.com/pebbe/zmq3/errors.go:5:0: zmq3.h:2:2: error: #error "You need ZeroMQ version 3 to build this" #error "You need ZeroMQ version 3 to build this"

Hi Peter,

I'm trying to get the zmq3 bindings up and running on a OS X 10.9 but I'm having some problems. I've already got zmq 3.2.4 installed via HomeBrew but I'm getting an error when I try to get the library (with go get ...). I've included the error below.

clang: error: argument unused during compilation: '-fno-eliminate-unused-debug-types'

Any ideas?

Thanks in advance,

Andy

On running CGO_CFLAGS=-I/usr/local/include CGO_LDFLAGS=-L/usr/local/lib go get github.com/pebbe/zmq3 I get the following. I am quite new to Go (but not ZMQ) and I see these on my output:

../../../../whirlwind/go/src/github.com/pebbe/zmq3/reactor.go:10: undefined: State ../../../../whirlwind/go/src/github.com/pebbe/zmq3/reactor.go:11: undefined: State ../../../../whirlwind/go/src/github.com/pebbe/zmq3/reactor.go:21: undefined: Socket ../../../../whirlwind/go/src/github.com/pebbe/zmq3/reactor.go:23: undefined: Poller ../../../../whirlwind/go/src/github.com/pebbe/zmq3/reactor.go:55: undefined: Socket ../../../../whirlwind/go/src/github.com/pebbe/zmq3/reactor.go:55: undefined: State ../../../../whirlwind/go/src/github.com/pebbe/zmq3/reactor.go:62: undefined: Socket ../../../../whirlwind/go/src/github.com/pebbe/zmq3/utils.go:17: undefined: Socket ../../../../whirlwind/go/src/github.com/pebbe/zmq3/utils.go:78: undefined: Socket ../../../../whirlwind/go/src/github.com/pebbe/zmq3/utils.go:78: too many errors

I am running go version go1.1.1 darwin/amd64 and zeromq-3.2.3. Thanks for any help already.

Suhail

This is probably more a comment rather an issue, but might cause some issues I'm not aware of at this moment. Reading the zeromq documentation, there a section "Multithreading with ØMQ": http://zguide.zeromq.org/page:all#Multithreading-with-MQ

If you need to start more than one proxy in an application, for example, you will want to run each in their own thread. It is easy to make the error of creating the proxy frontend and backend sockets in one thread, and then passing the sockets to the proxy in another thread. This may appear to work at first but will fail randomly in real use.

Remember: Do not use or close sockets except in the thread that created them.

In GO there's no control over threads. GO runtime scheduler assigns routines to various threads and it is basically a certainty that ZMQ sockets will be used in various threads. There's an option to lock go routine to specific thread (runtime.LockOSThread()), but that means ZMQ sockets cannot be used in more go routines, which is very restrictive considering IMHO.

So, does it even make sense to try to use ZMQ in GO? What is your opinion about this?

Using default options, zmq3 is about 1/10th the speed of jeromq::pull or c::pull.

I am running out of ideas how to explain this:

I have a producer using jeromq to push messages.

All consumers are NOP for now, they just pull the messages.

It works fine for clients written in jeromq and the provided benchmarking tool written in c.

However, if I connect using zmq3 the producer starts to stall as it dead locks on send. The go process is more or less idle.

Any ideas?