calid · October 3, 2022 10:45 · calid · Mar 11, 2015 · pipcet · Mar 11, 2015
diff --git a/00-preamble.md b/00-preamble.md
diff --git a/01-wuclient-comparison.md b/01-wuclient-comparison.md
diff --git a/02-wuserver-comparison.md b/02-wuserver-comparison.md
diff --git a/03-misc-benchmark-comparison.md b/03-misc-benchmark-comparison.md
diff --git a/zmq-bench.c b/zmq-bench.c
 #include <zmq.h>
 #include <stdlib.h>
 #include <stdio.h>
 #include <unistd.h>
 #include <assert.h>
 #include <string.h>

 int main(void)
 {
    void *ctx = zmq_ctx_new();
    assert(ctx);

    void *socket = zmq_socket(ctx, ZMQ_PUB);
    assert(socket);

    pid_t p = getpid();

    char *endpoint = malloc(256);
    sprintf(endpoint, "ipc:///tmp/zmq-c-bench-%d", p);

    assert( -1 != zmq_bind(socket, endpoint) );

    int major, minor, patch;
    zmq_version(&major, &minor, &patch);

    printf("C ZMQ Version: %d.%d.%d\n", major, minor, patch);

    for ( int i = 0; i < (10 * 1000 * 1000); i++ ) {
        assert( -1 != zmq_send(socket, "ohhai", 5, 0) );
    }
 } 
diff --git a/zmq-bench.pl b/zmq-bench.pl
 #
 # Directly compare FFI::Platypus vs XS xsubs
 #

 use strict;
 use warnings;
 use v5.10;

 use FFI::Platypus::Declare;
 use ZMQ::LibZMQ3;

 use ZMQ::FFI::Constants qw(:all);

 use Benchmark qw(:all);

 lib 'libzmq.so';

 attach(
    ['zmq_ctx_new' => 'zmqffi_ctx_new']
        => [] => 'pointer'
 );

 attach(
    ['zmq_socket' => 'zmqffi_socket']
        => ['pointer', 'int'] => 'pointer'
 );

 attach(
    ['zmq_bind' => 'zmqffi_bind']
        => ['pointer', 'string'] => 'int'
 );

 attach(
    ['zmq_send' => 'zmqffi_send']
        => ['pointer', 'string', 'size_t', 'int'] => 'int'
 );

 attach(
    ['zmq_version' => 'zmqffi_version'] 
        => ['int*', 'int*', 'int*'] => 'void'
 );

 my $ffi_ctx = zmqffi_ctx_new();
 die 'ffi ctx error' unless $ffi_ctx;

 my $ffi_socket = zmqffi_socket($ffi_ctx, ZMQ_PUB);
 die 'ffi socket error' unless $ffi_socket;

 my $rv;

 $rv = zmqffi_bind($ffi_socket, "ipc:///tmp/zmq-ffi-bench-$$");
 die 'ffi bind error' if $rv == -1;

 my $xs_ctx = zmq_ctx_new();
 die 'xs ctx error' unless $xs_ctx;

 my $xs_socket = zmq_socket($xs_ctx, ZMQ_PUB);
 die 'xs socket error' unless $xs_socket;

 $rv = zmq_bind($xs_socket, "ipc:///tmp/zmq-xs-bench-$$");
 die 'xs bind error' if $rv == -1;


 my ($major, $minor, $patch);
 zmqffi_version(\$major, \$minor, \$patch);

 say "FFI ZMQ Version: " . join(".", $major, $minor, $patch);
 say "XS  ZMQ Version: " . join(".", ZMQ::LibZMQ3::zmq_version());


 my $r = timethese 10_000_000, {
    'XS'  => sub {
        die 'xs send error ' if -1 == zmq_send($xs_socket, 'ohhai', 5, 0);
    },

    'FFI' => sub {
        die 'ffi send error' if -1 == zmqffi_send($ffi_socket, 'ohhai', 5, 0);
    },
 };

 cmpthese($r);


diff --git a/zmq-ffi-wuclient.pl b/zmq-ffi-wuclient.pl
 use strict;
 use warnings;
 use v5.10;

 use ZMQ::FFI;
 use ZMQ::FFI::Constants qw(ZMQ_SUB);

 say "Collecting updates from weather station...";

 my $context = ZMQ::FFI->new();

 my $subscriber = $context->socket(ZMQ_SUB);
 $subscriber->connect("tcp://localhost:5556");

 my $filter = $ARGV[0] // "10001 ";
 $subscriber->subscribe($filter);

 my $update_nbr = 100;
 my $total_temp = 0;

 my ($string, $zipcode, $temperature, $relhumidity);

 for (1..$update_nbr) {
    $string = $subscriber->recv();

    ($zipcode, $temperature, $relhumidity) = split ' ', $string;
    $total_temp += $temperature;
 }

 printf "Average temperature for zipcode '%s' was %dF\n",
    $filter, int($total_temp / $update_nbr);
diff --git a/zmq-ffi-wuserver.pl b/zmq-ffi-wuserver.pl
 use strict;
 use warnings;

 use ZMQ::FFI;
 use ZMQ::FFI::Constants qw(ZMQ_PUB);

 my $context = ZMQ::FFI->new();

 my $publisher = $context->socket(ZMQ_PUB);
 $publisher->bind("tcp://*:5556");

 my ($zipcode, $temperature, $relhumidity, $update);

 # for (1..1_000_000) { # publish constant number when profiling
 while (1) {
    $zipcode     = rand(100_000);
    $temperature = rand(215) - 80;
    $relhumidity = rand(50) + 10;

    $update = sprintf(
        '%05d %d %d',
        $zipcode,$temperature,$relhumidity
    );

    $publisher->send($update);
 }
diff --git a/zmq-xs-wuclient.pl b/zmq-xs-wuclient.pl
 use strict;
 use warnings;
 use v5.10;

 use ZMQ::LibZMQ3;
 use ZMQ::Constants qw(ZMQ_SUB ZMQ_SUBSCRIBE);
 use zhelpers;

 say 'Collecting updates from weather server...';

 my $context = zmq_init();

 my $subscriber = zmq_socket($context, ZMQ_SUB);
 zmq_connect($subscriber, 'tcp://localhost:5556');

 my $filter = @ARGV ? $ARGV[0] : '10001 ';
 zmq_setsockopt($subscriber, ZMQ_SUBSCRIBE, $filter);

 my $update_nbr = 100;
 my $total_temp = 0;

 my ($string, $zipcode, $temperature, $relhumidity);

 for (1 .. $update_nbr) {
    $string = s_recv($subscriber);

    ($zipcode, $temperature, $relhumidity) = split ' ', $string;
    $total_temp += $temperature;
 }

 printf "Average temperature for zipcode '%s' was %dF\n",
    $filter, int($total_temp / $update_nbr);
diff --git a/zmq-xs-wuserver.pl b/zmq-xs-wuserver.pl
 use strict;
 use warnings;

 use ZMQ::LibZMQ3;
 use ZMQ::Constants qw(ZMQ_PUB);
 use zhelpers;

 my $context = zmq_init();

 my $publisher = zmq_socket($context, ZMQ_PUB);
 zmq_bind($publisher, 'tcp://*:5556');

 my ($zipcode, $temperature, $relhumidity, $update);

 # for (1..1_000_000) { # publish constant number when profiling
 while (1) {
    $zipcode     = rand(100_000);
    $temperature = rand(215) - 80;
    $relhumidity = rand(50) + 10;

    $update = sprintf(
        '%05d %d %d',
        $zipcode,$temperature,$relhumidity
    );

    s_send($publisher, $update);
 }
	#include <zmq.h>
	#include <stdlib.h>
	#include <stdio.h>
	#include <unistd.h>
	#include <assert.h>
	#include <string.h>

	int main(void)
	{
	void *ctx = zmq_ctx_new();
	assert(ctx);

	void *socket = zmq_socket(ctx, ZMQ_PUB);
	assert(socket);

	pid_t p = getpid();

	char *endpoint = malloc(256);
	sprintf(endpoint, "ipc:///tmp/zmq-c-bench-%d", p);

	assert( -1 != zmq_bind(socket, endpoint) );

	int major, minor, patch;
	zmq_version(&major, &minor, &patch);

	printf("C ZMQ Version: %d.%d.%d\n", major, minor, patch);

	for ( int i = 0; i < (10 * 1000 * 1000); i++ ) {
	assert( -1 != zmq_send(socket, "ohhai", 5, 0) );
	}
	}
	#
	# Directly compare FFI::Platypus vs XS xsubs
	#

	use strict;
	use warnings;
	use v5.10;

	use FFI::Platypus::Declare;
	use ZMQ::LibZMQ3;

	use ZMQ::FFI::Constants qw(:all);

	use Benchmark qw(:all);

	lib 'libzmq.so';

	attach(
	['zmq_ctx_new' => 'zmqffi_ctx_new']
	=> [] => 'pointer'
	);

	attach(
	['zmq_socket' => 'zmqffi_socket']
	=> ['pointer', 'int'] => 'pointer'
	);

	attach(
	['zmq_bind' => 'zmqffi_bind']
	=> ['pointer', 'string'] => 'int'
	);

	attach(
	['zmq_send' => 'zmqffi_send']
	=> ['pointer', 'string', 'size_t', 'int'] => 'int'
	);

	attach(
	['zmq_version' => 'zmqffi_version']
	=> ['int', 'int', 'int*'] => 'void'
	);

	my $ffi_ctx = zmqffi_ctx_new();
	die 'ffi ctx error' unless $ffi_ctx;

	my $ffi_socket = zmqffi_socket($ffi_ctx, ZMQ_PUB);
	die 'ffi socket error' unless $ffi_socket;

	my $rv;

	$rv = zmqffi_bind($ffi_socket, "ipc:///tmp/zmq-ffi-bench-$$");
	die 'ffi bind error' if $rv == -1;

	my $xs_ctx = zmq_ctx_new();
	die 'xs ctx error' unless $xs_ctx;

	my $xs_socket = zmq_socket($xs_ctx, ZMQ_PUB);
	die 'xs socket error' unless $xs_socket;

	$rv = zmq_bind($xs_socket, "ipc:///tmp/zmq-xs-bench-$$");
	die 'xs bind error' if $rv == -1;


	my ($major, $minor, $patch);
	zmqffi_version(\$major, \$minor, \$patch);

	say "FFI ZMQ Version: " . join(".", $major, $minor, $patch);
	say "XS ZMQ Version: " . join(".", ZMQ::LibZMQ3::zmq_version());


	my $r = timethese 10_000_000, {
	'XS' => sub {
	die 'xs send error ' if -1 == zmq_send($xs_socket, 'ohhai', 5, 0);
	},

	'FFI' => sub {
	die 'ffi send error' if -1 == zmqffi_send($ffi_socket, 'ohhai', 5, 0);
	},
	};

	cmpthese($r);
	use strict;
	use warnings;

	use ZMQ::FFI;
	use ZMQ::FFI::Constants qw(ZMQ_PUB);

	my $context = ZMQ::FFI->new();

	my $publisher = $context->socket(ZMQ_PUB);
	$publisher->bind("tcp://*:5556");

	my ($zipcode, $temperature, $relhumidity, $update);

	# for (1..1_000_000) { # publish constant number when profiling
	while (1) {
	$zipcode = rand(100_000);
	$temperature = rand(215) - 80;
	$relhumidity = rand(50) + 10;

	$update = sprintf(
	'%05d %d %d',
	$zipcode,$temperature,$relhumidity
	);

	$publisher->send($update);
	}