92 lines
2.9 KiB
Ruby
92 lines
2.9 KiB
Ruby
require 'formula'
|
|
|
|
class Zeromq < Formula
|
|
homepage 'http://www.zeromq.org/'
|
|
url 'http://download.zeromq.org/zeromq-3.2.3.tar.gz'
|
|
sha1 '6857a3a0e908eca58f7c0f90e2ba4695f6700957'
|
|
|
|
head 'https://github.com/zeromq/libzmq.git'
|
|
|
|
option :universal
|
|
option 'with-pgm', 'Build with PGM extension'
|
|
|
|
depends_on 'pkg-config' => :build
|
|
depends_on 'libpgm' if build.include? 'with-pgm'
|
|
|
|
if build.head?
|
|
depends_on :automake
|
|
depends_on :libtool
|
|
end
|
|
|
|
fails_with :llvm do
|
|
build 2326
|
|
cause "Segfault while linking"
|
|
end
|
|
|
|
# Address lack of strndup on 10.6, fixed upstream
|
|
# https://github.com/zeromq/zeromq3-x/commit/400cbc208a768c4df5039f401dd2688eede6e1ca
|
|
def patches; DATA; end unless build.head?
|
|
|
|
def install
|
|
ENV.universal_binary if build.universal?
|
|
|
|
args = ["--disable-dependency-tracking", "--prefix=#{prefix}"]
|
|
if build.include? 'with-pgm'
|
|
# Use HB libpgm-5.2 because their internal 5.1 is b0rked.
|
|
ENV['OpenPGM_CFLAGS'] = %x[pkg-config --cflags openpgm-5.2].chomp
|
|
ENV['OpenPGM_LIBS'] = %x[pkg-config --libs openpgm-5.2].chomp
|
|
args << "--with-system-pgm"
|
|
end
|
|
|
|
system "./autogen.sh" if build.head?
|
|
system "./configure", *args
|
|
system "make"
|
|
system "make install"
|
|
end
|
|
|
|
def caveats; <<-EOS.undent
|
|
To install the zmq gem on 10.6 with the system Ruby on a 64-bit machine,
|
|
you may need to do:
|
|
|
|
ARCHFLAGS="-arch x86_64" gem install zmq -- --with-zmq-dir=#{opt_prefix}
|
|
EOS
|
|
end
|
|
end
|
|
|
|
__END__
|
|
diff --git a/tests/test_disconnect_inproc.cpp b/tests/test_disconnect_inproc.cpp
|
|
index 7875083..d6b68c6 100644
|
|
--- a/tests/test_disconnect_inproc.cpp
|
|
+++ b/tests/test_disconnect_inproc.cpp
|
|
@@ -40,16 +40,14 @@ int main(int argc, char** argv) {
|
|
zmq_msg_t msg;
|
|
zmq_msg_init (&msg);
|
|
zmq_msg_recv (&msg, pubSocket, 0);
|
|
- int msgSize = zmq_msg_size(&msg);
|
|
char* buffer = (char*)zmq_msg_data(&msg);
|
|
|
|
if (buffer[0] == 0) {
|
|
assert(isSubscribed);
|
|
- printf("unsubscribing from '%s'\n", strndup(buffer + 1, msgSize - 1));
|
|
isSubscribed = false;
|
|
- } else {
|
|
+ }
|
|
+ else {
|
|
assert(!isSubscribed);
|
|
- printf("subscribing on '%s'\n", strndup(buffer + 1, msgSize - 1));
|
|
isSubscribed = true;
|
|
}
|
|
|
|
@@ -66,11 +64,6 @@ int main(int argc, char** argv) {
|
|
zmq_msg_t msg;
|
|
zmq_msg_init (&msg);
|
|
zmq_msg_recv (&msg, subSocket, 0);
|
|
- int msgSize = zmq_msg_size(&msg);
|
|
- char* buffer = (char*)zmq_msg_data(&msg);
|
|
-
|
|
- printf("received on subscriber '%s'\n", strndup(buffer, msgSize));
|
|
-
|
|
zmq_getsockopt (subSocket, ZMQ_RCVMORE, &more, &more_size);
|
|
zmq_msg_close (&msg);
|
|
|
|
|