gmane.network.zeromq.devel

nzmqt question: how to stop?

Marco Trapanese — 2012-05-26T15:41:06

Hello,

when my Qt application ends the zmq engine is still running.
The examples provided hasn't any destructor or stop method.

As far as I know the QRunnable class doesn't have a way to stop. So I 
tried to inherit QThread which has the quit slot.

In my application I use other QThread classes and there is no problem to 
terminate on exit.

Only the zmq class remains active.
Here my constructor:

explicit FemtoClient(QObject* parent) : QThread(parent) {
     m_address = "tcp://blablabla";
     ZMQContext* context = createDefaultContext(this);
     context->start();
     m_socket = context->createSocket(ZMQSocket::TYP_DEALER);
     connect(m_socket, SIGNAL(messageReceived(const QList<QByteArray> 
&)), this, SLOT(requestReceived(const QList<QByteArray> &)));
     timerout = new QTimer(this);
     timerout->setInterval(2500);
     timerout->setSingleShot(true);
     connect(timerout, SIGNAL(timeout()), this, SLOT(timerout_timeout()));
}

the run() and stop() slot:

void run() {
     m_socket->connectTo(m_ser

Support multipart with SNDMORE and RCVMORE?

zhiguo zhao — 2012-05-26T15:19:07

Hi, all.

     Please consider below items.
     I.
            If is a short msg, It can be handle in one time with zmq_send
and zmq_recv, This will match 80%.
    2.
           If to process a long message,(may be 1G size) and result is
short,(just like do a message digest), client can send more times with
SNDMORE, and server will reply only onces to get result,  2 plus 1 with
match 98%.

         CLIENT       -----------------------------------   SERVER
        send(msg_p1, MORE)      ->                           recv

 digest(msg_p1)
        send(msg_p2, MORE)      ->                           recv

 digest(msg_p2)
        send(msg_pn)      ->                                        recv

  mdvalue = digest_result(msg_pn)
            recv                             <----
send(mdvalue)
   3.
          If to process a long message and result is long too, just think
that do  3des-cbc encrypt a big file, It make me fool, I can't find a
solution.

         CLIENT       -----------------------------------   SE

Pub/Sub over PGM with many topics

Ambalu, Robert — 2012-05-25T14:00:07

Hi, I'm new to zeroMQ and am trying to understand how pub.sub over multicast would work in my scenario.
I want to have one publisher which publishes say 10k different topics.  I can have N subscriber processes, each of which can subscribe to multiple topics
So, use case example.  Say my publisher is publishing market data for 10k different instruments, my subscriber app only handles 100 stocks so it only want to get messages for those 100 stocks.  In addition, I don't want to have my app do any type of topic resolution, but if possible let zeromq handle the topic multiplexing.
So I was thinking on the subscriber side, for every topic I have it looks like I would have to create a separate SUB socket to the same pgm multicast channel, but set with a different SUBSCRIBE topic.  Then I would have to poll on all sockets ( essentially, all topics ) and then dish out to the appropriate pollitem ( which in this case would be my object, so say data for AAPL would be subscribed to my an AAPL pollitem handler which

PUSH/PULL not working in this example

Sam Zaroug — 2012-05-25T08:01:15

Hi Folks,


I ve the following client server executables that arent working on my machine (attached)


please, note: 
- replace boost  calls with std::cout if you dont use boost in your dev env.


the reciever seems to wait forever, and the sender exit without waiting for the message being processed.
if you uncomment the _sleep(1) on the sending side things works just fine.


I wondering if there is any logical explanation to this simple senario?




Kind Regards


Brownviper1966






       _______________________________________________
zeromq-dev mailing list
zeromq-dev< at >lists.zeromq.org
http://lists.zeromq.org/mailman/listinfo/zeromq-dev

3.1 stability status

2012-05-25T14:24:13

Hello,

I plan to bring ZeroMQ into my codebase to start testing out its pub/sub
capabilities. I had brought in ZeroMQ 2.1 in a former project and found
it a bit painful to resolve the uuid dependency on the embedded Linux
platform we use. I hear 3.1 no longer contains that dependency and am
interested in jumping to that revision if it is fairly stable. There are
also some other features in 3.1 that I could benefit from. Is there a
timeframe as to when 3.1 will be considered the new "stable release"?
Are there any big issues with it today?

 

/Jon

 

_______________________________________________
zeromq-dev mailing list
zeromq-dev< at >lists.zeromq.org
http://lists.zeromq.org/mailman/listinfo/zeromq-dev

several binds on the same ipc

Tarek Ziadé — 2012-05-24T12:17:58

Hey

I am trying to solve an issue I have with a broker that opens a zmq 
router socket and just relay calls to workers via a socket dealer.

The problem is that I don't know how to prevent a second broker to bind 
itself to the same ipc.

Consider the following scripts where I isolate the issue:

The server: http://tarek.pastebin.mozilla.org/1649175
The client: http://tarek.pastebin.mozilla.org/1649176

If I run them they happily interact. Now I can run a second server. It 
will bind the socket but won't do anything or even error out.

If I stop the first server, the client will simply lock, as it seems to 
have a sticky connection to the first server - and won't communicate
with the second server until I restart it.

As far as I understand, we can only bind() *once*, which make sense.

So my question is - shouldn't the second attempt to bind() the socket 
raise an error ? maybe this is related to the python binding ?

If not, how can I know if there's already a socket bound to the ipc ?

Cheers
Tarek

exhausting limited FDs

Chick Corea — 2012-05-24T03:02:25

I have a non-hypothetical concern re: FD usage with ZMQ.  Admittedly,
I am a typical programmer having implemented most inter-proc comm via
bare sockets.

As I understand the general use-model, a program would would use
multiple TCP ports for the various message-types to be sent between
servers and clients, PUB/SUB, REQ/REP, PUSH/PULL.  That being the
case, comm between two procs, a server could easily use 2 or more
sockets for each client.  If a proc is limited to 5k FDs then the
number of clients simultaneously connected is limited to less than
2.5k before it has to start managing those FDs with some kind of LRU
algorith with reconnects as necessary.

That seems to be the inevitable outcome of not being able to map an
endpoint to multiple sockets.  Is that correct?

What's the solution?   Is that actually acceptable?

Thank you.

FWIW, ZMQ seems very promising to use in my current project.  I have
two key concerns re: it; this is one of them.

CZC

Downloads site - removed historic folder

Pieter Hintjens — 2012-05-23T16:11:05

Hi all,

We used to move old versions of 0MQ tarballs into /historic.

People rightly complained because this kept breaking things for anyone
linking to a tarball.

I've killed that folder and all past and present releases of 0MQ and
related projects are now simply in the main downloads directory at
http://download.zeromq.org/

-Pieter

Ps. if you were linking to a tarball in /historic sorry, you'll have
one last fix to make.

ZeroMQ for Android

Boris Gulay — 2012-05-23T14:20:19

I've successfully compiled and tested libzmq v2.2 for Android using
latest ndk (r8). I've used static linking for libuuid and libzmq, so I
have only one native file to copy on the device: libjzmq. I believe it;s
better than compile al libraries to .so because on android all such
files are private to the application and separate files just slows down
startup of the application.

Should I write new description of the build process on android page?

_______________________________________________
zeromq-dev mailing list
zeromq-dev< at >lists.zeromq.org
http://lists.zeromq.org/mailman/listinfo/zeromq-dev

June meetup / drinkup in Bay Are?

Pieter Hintjens — 2012-05-22T20:58:01

Hi all,

Any interest in a meetup in the Bay Area on the 9th of June?

We have office space downtown SF.

-Pieter

Code-style question

Marco Trapanese — 2012-05-22T18:11:51

Hello,

currently I'm using zmq on several projects to control remote 
applications. In fact, I send 'commands' rather 'data'.

The architecture of the whole software is pretty simple. There are the 
basic functions that do the hard job (my own API). Let's call 'em 
func1(), func2() ...

Then I wrote a raw protocol to call these functions through the zmq 
connection. After a message is received, I check the first part to 
decode the command and the followings to get the parameters (if any). 
Something like this:

void parseMessage() {
// receive the message, get cmd, argc and argv[]

switch (cmd) {
case CMD1:
func1();
break;

case CMD2:
if (argc == 1) func2(argv[0]);
break;
}
}


I wonder how do you implement such an interface. Do you use a method 
like this or there is something more flexible/elegant?

Thanks
Marco

Android configuration scripts

Victor Perron — 2012-05-22T02:56:17

Hello on this list,

At my work I had to generate an Android-compatible .so that could be loaded
directly in an APK, and use Jzmq.

The result, a collection of harmless configuration scripts, is presented
there:

http://iso3103.blogspot.jp/2012/05/java-zeromq-for-android.html
and associated github
https://github.com/vperron/android-jzeromq

I've seen quite a lot of questions about this matter on the web, so maybe
that could be of any help.

I have a few questions though :
- Do you zmq devs think it is an acceptable way to go ?
- Do you, people interested with zeromq on Android, meet issues using this ?
- Wouldn't it be more useful converted in some other way, for e.g a post on
the :build wiki or a 'target' in the distribution ?
- Am I totally wrong and there is a straightforward way ?

Thanks a lot ,
best regards

std::numeric_limits invalid

Steven McCoy — 2012-05-22T01:54:33

Not supported with MSVC, needs an alternative method.  C99 route is an
alternative:  SIZE_MAX.  I'm sure something old hates that.

https://github.com/zeromq/libzmq/blob/master/src/decoder.cpp#L117

Newbie question: How to reroute messages to differentworkers (C#)

Frank Gynnild — 2012-05-21T19:15:47

_______________________________________________
zeromq-dev mailing list
zeromq-dev< at >lists.zeromq.org
http://lists.zeromq.org/mailman/listinfo/zeromq-dev

zermoq java bindings - docs

David Starkweather — 2012-05-21T15:49:16

Hello,

Just started using the java bindings to zeromq. Where are the docs for
using the api ? 

Specifically, is there a way to send an empty message ?

Thanks,
David Stark

Build fails on Solaris / Sun C++: multimap::insert insocket_base.cpp:550

Ivan Pechorin — 2012-05-20T12:36:12

Hello!

libzmq master fails to compile with Sun C++ on Solaris. I used just
./autogen.sh && ./configure && gmake

The error is:

"socket_base.cpp", line 550: Error: Could not find a match for
std::multimap<std::string, zmq::own_t*, std::less<std::string>,
std::allocator<std::pair<const std::string,
zmq::own_t*>>>::insert(std::pair<std::string, zmq::own_t*>) needed in
zmq::socket_base_t::add_endpoint(const char*, zmq::own_t*).

Please, see config.log and full build output here:
https://zeromq.jira.com/browse/LIBZMQ-368

It seems like the solution is to use insert(endpoints_t::value_type(first,
second)) instead of insert(std::make_pair(first, second))
Please, see pull request https://github.com/zeromq/libzmq/pull/342


--- a/src/socket_base.cpp
+++ b/src/socket_base.cpp
< at >< at > -547,7 +547,7 < at >< at > void zmq::socket_base_t::add_endpoint (const char
*addr_, own_t *endpoint_)
{
    //  Activate the session. Make it a child of this socket.
    launch_child (endpoint_);
-   endpoints.insert (std::make_pair (std::string (add

Paxos & ZeroMQ

Tom Cocagne — 2012-05-20T06:40:43

At today's ZeroMQ meetup in Chicago, a surprising amount of interest
was expressed in a Paxos/ZeroMQ side project I've been working on for
the past few months. At the request of several of the attendees, I've
made the code publicly available on GitHub for the perusal of anyone
that's interested.

There are two separate repositories. One repository contains a pure
Paxos implementation that is independent of any particular application
domain or networking infrastructure. The lack of such a library was
the biggest stumbling block for me, personally, when it came to
understanding how Paxos worked and how to put it into practice.
Hopefully others in the community will find it useful.

The second repository uses the pure Paxos library in conjunction with
ZeroMQ to implement a simple, distributed key-value database. This
project was born out of my frustration with the lack of a simple,
embeddable database for which there is no single point of failure. As
it stands, the code doesn't quite solve that problem yet but

Strict aliasing problem

Bjorn Reese — 2012-05-17T09:14:38

I cannot compile the master branch with g++ 4.4 because of this commit:

https://github.com/zeromq/libzmq/commit/c995de65847d8a97dc75294fb1b9b6a057fd3c1d

I get errors like this:

options.cpp: In member function ‘int zmq::options_t::setsockopt(int, 
const void*, size_t)’:
options.cpp:328:52: error: dereferencing type-punned pointer will break 
strict-aliasing rules

Actually, these kind of errors is what the abovementioned commit is
trying to fix, but it did not get it right.

I can see three possible solutions:

1. As the only standards-compliant way "casting" between
    pointer-to-object and pointer-to-function is through a union, the
    zmq_monitor_fn type could be changed to something like:

    typedef union
    {
      void *object;
      void (*function)(void *s, int event, zmq_event_data_t *data);
    } zmq_monitor_fn;

    and the various places where the monitor function is used, must be
    changed appropriately.

    This is not a good solution because it creates an awkward API for
    call

Is there advantage of using zmq_device comparable withpolling

Serg V. Gulko — 2012-05-16T22:03:49

Hello! 

I trying to figure out is there any advantage(except more compact
notation) of using ZMQ_FORWARDER device as long same stuff can be build
using zmq_poll.

Serg



_______________________________________________
zeromq-dev mailing list
zeromq-dev< at >lists.zeromq.org
http://lists.zeromq.org/mailman/listinfo/zeromq-dev

Using closed socket with JZMQ

motoplux — 2012-05-16T14:00:10

JZMQ dev suggest me to post here, since he has not had time to look into yet.

Hi everyone,
I'm recently playing with Zmq (v2.2.0) and its Java binder (v1.0.0),
and I run into a problem.

On Windows, I was getting a crash as an unhandled exception in javaw.exe.

This was due to my fault, because I was trying to send data through an
already closed ZMQ socket,
but it takes me lot of time to find the problem because the crash
wasn't giving me
any details on what was going on (the call stack location reported the
runtime library msvcr).

So I wrote two little spike both using the java binder and the plain
zmq api, and, surprise, I wasn't getting
any excetpion with the plain zmq. Just the zqm_send it's returing -1
when I try to send data to a closed socket.

Furthermore, I tested the java spike code on Linux too, and the
behaviour is different again: the
program ends with

java: Socket.cpp:543: void* get_socket(JNIEnv, _jobject, int):
Assertion `s' failed.

Here the two spikes I used

**** JZMQ spike****

package

Compilation warning on GCC 4.4

Boris Gulay — 2012-05-15T15:15:33

When compiling on GCC 4.4+ the following warning message is issued:

ctx.hpp:56: note: the mangling of 'va_list' has changed in GCC 4.4

Is everything OK?

_______________________________________________
zeromq-dev mailing list
zeromq-dev< at >lists.zeromq.org
http://lists.zeromq.org/mailman/listinfo/zeromq-dev