a way of
disabling Nagle's algorithm (TCP_NODELAY sockopt).
On Thu, Jan 16, 2014 at 4:24 AM, Bruno D. Rodrigues
bruno.rodrig...@litux.org wrote:
Without looking at the code I assume ØMQ is not trying to send each
individual message as a TCP PDU but instead, as the name implies, queues
Without looking at the code I assume ØMQ is not trying to send each individual
message as a TCP PDU but instead, as the name implies, queues messages so it
can batch them together and get the performance.
This then means the wire will be filled up when some internal buffer fills, or
after a
of
performance which approach would be preferable?
Gesendet: Mittwoch, 15. Januar 2014 um 01:33 Uhr
Von: Bruno D. Rodrigues bruno.rodrig...@litux.org
An: zeromq-dev@lists.zeromq.org zeromq-dev@lists.zeromq.org
Betreff: Re: [zeromq-dev] Pub/sub pattern: Binding two sources to same
address
, 2014 at 4:24 AM, Bruno D. Rodrigues
bruno.rodrig...@litux.org wrote:
Without looking at the code I assume ØMQ is not trying to send each
individual message as a TCP PDU but instead, as the name implies, queues
messages so it can batch them together and get the performance.
This then means
make distclean
./autogen.sh ?
On Jan 16, 2014, at 18:31, Greg Ward g...@gerg.ca wrote:
On 16 January 2014, Lindley French said:
After pulling down libzmq master at
53d0199e50https://github.com/zeromq/libzmq/commit/53d0199e50ddc9fad07b5cf64113cdbf7a0fbf04,
my build on linux breaks:
*** No
both PUB and ROUTER drop messages.
the HWM is default 1K since v3 if I recall from the documentation.
On Jan 16, 2014, at 19:03, Lindley French lindl...@gmail.com wrote:
Well, aside from the router issue I do like the arrangement for easily
handling different messages in different places.
Dumb question, but why not a simple PUSH/PULL pattern and no queues? Each
consumer PULLs one message to process. The process pushing data (which may be
more than one) will block when the HWM is hit (all consumers are busy, and the
“queue” from the producer is full). No need for
before throwing messages away. I haven't been able to find any options to
coax the publisher into blocking when this limit is hit.
Here is my push/pull pattern code that I had tried:
http://pastebin.com/CJLaY5zk
On Wed, Jan 15, 2014 at 12:43 PM, Bruno D. Rodrigues
bruno.rodrig
Inline
On Jan 14, 2014, at 11:19, Toon Peters toon.pet...@tass.be wrote:
Dear All,
I'm currently trying to improve our ZeroMQ implementation on our TCP/IP stack
called PicoTCP (All the source files can be found at
http://github.com/tass-belgium/picotcp/)
I'm currently trying to figure
/ar6bH8vq
Gesendet: Montag, 13. Januar 2014 um 09:57 Uhr
Von: Bruno D. Rodrigues bruno.rodrig...@litux.org
An: zeromq-dev@lists.zeromq.org zeromq-dev@lists.zeromq.org
Betreff: Re: [zeromq-dev] Pub/sub pattern: Binding two sources to same
address not working
Thats the part I couldn’t
: Dienstag, 14. Januar 2014 um 12:59 Uhr
Von: Bruno D. Rodrigues bruno.rodrig...@litux.org
An: zeromq-dev@lists.zeromq.org zeromq-dev@lists.zeromq.org
Betreff: Re: [zeromq-dev] Pub/sub pattern: Binding two sources to same
address not working
https://gist.github.com/davipt/8417197
Launch *one
type. Or is the only correct way
to specify a different port for every fan-out node?
Gesendet: Sonntag, 12. Januar 2014 um 23:33 Uhr
Von: Bruno D. Rodrigues bruno.rodrig...@litux.org
An: ZeroMQ development list zeromq-dev@lists.zeromq.org
Betreff: Re: [zeromq-dev] Pub/sub pattern: Binding
https://github.com/zeromq/libzmq/pull/821
On Jan 13, 2014, at 16:53, Mathias Hablützel h...@zhaw.ch wrote:
Hi everyone,
Hit this little problem:
$ make all
Making all in src
/Applications/Xcode.app/Contents/Developer/usr/bin/make all-am
CXX libzmq_la-address.lo
CXX
with Windows based DLL imports
and exports:
https://www.gnu.org/software/gnulib/manual/html_node/Exported-Symbols-of-Shared-Libraries.html#Exported-Symbols-of-Shared-Libraries
On 13 January 2014 12:33, Bruno D. Rodrigues bruno.rodrig...@litux.orgwrote:
https://github.com/zeromq/libzmq/pull/821
It was hard for me to understand what are you trying to do but I guess the
simple answer is no, you can't have the same port (ip+port to be correct)
bound multiple times. That's how TCP works.
--
Bruno Rodrigues
Sent from my iPhone
No dia 12/01/2014, às 21:51, Andreas Bauer b...@gmx.net
something like this? http://twister.net.co (I’m not promoting it, as I couldn’t
even compile it on my Mac)
On Jan 11, 2014, at 10:36, Apostolis Xekoukoulotakis xekou...@gmail.com wrote:
One alternative to a mesh network is of course peer to peer encryption.
All browsers nowadays can persist
On Jan 9, 2014, at 10:52, Bjorn Reese bre...@mail1.stofanet.dk wrote:
On 01/09/2014 09:06 AM, Pieter Hintjens wrote:
* Many public hotspots, especially in the US, block client-to-client traffic.
If you are talking about wireless isolation, then they only block
multicasting. This means
The documentation recommends creating one single context per process,
and when creating it you specify how many zeromq threads to use.
--
Bruno Rodrigues
Sent from my iPhone
No dia 09/01/2014, às 13:33, Jan Drabner j...@jdrabner.eu escreveu:
Hey there,
We are currently doing research for
I don’t know too many details about FON, but we have an ISP in Portugal that
provides FON over all their clients (if they accept) and as soon as I connect
to one FON hotstpot, the device automatically connects to any other. No idea if
it’s just because it’s the same name, or if there is any
Straight from the sockets documentation, Router won’t ever block and will
either discard the message if nothing is connected, or queue up to the HWM (and
then drop) if there is a connection. This applies to Router and PUB. It’s a
little bit more complicated than this (queue vs. plain drop) if
I’ve just sent a pull request to fix the broken jar file
https://github.com/zeromq/jzmq/pull/277
On Jan 4, 2014, at 21:41, Bruno D. Rodrigues bruno.rodrig...@litux.org wrote:
I’ve just grabbed the latest version and indeed it’s weird what is happening.
make creates a jar file inside src
I’ve just grabbed the latest version and indeed it’s weird what is happening.
make creates a jar file inside src/main/c++/zmq.jar, which has a wrong folder
hierarchy, like you show, with a ../java.
but if you ignore that file and run mvn clean -Dmaven.test.skip, then there is
a correct jar
Try out my fork, which is the same code but with a tweaked perf's local_thr,
remote_thr and proxy
https://github.com/davipt/libzmq/tree/fix-002-proxy_lat_thr
First try the original throughput test, using push-pull. My results on a
MacBook Pro (on Linux it’s much better btw):
idavi:perf bruno$
read the man page ;)
recv returns the size of the message, but if the buffer you give is smaller
than the message, zmq won’t write more bytes than the ones available.
the more flag is unrelated to the buffer size. It just means that multiple
messages (parts) can be gathered together as a whole
zmq_msg_recv() if you want to allocate a buffer
large enough for each message.
Now, if you're trying to be clever and only reallocate when the next message
is bigger than any you've seen so far, maybe there would be some benefit to a
new API method.
On Fri, Jan 3, 2014 at 1:14 PM, Bruno D
size – then I
need to call it again – and then does it give me the next length bytes? Or
have I already just lost those bytes?
From: Bruno D. Rodrigues bruno.rodrig...@litux.org
Reply-To: ZeroMQ development list zeromq-dev@lists.zeromq.org
Date: Friday, January 3, 2014 at 12:14 PM
No, it’s not that clear at the beginning, as you state yourself on the book.
There’s a reuse of the same words for slightly different things and that is
quite confusing until the boom paw moment.
There is at least one thing called message. It contains a length, the data, and
a flag stating if
poll on an additional pair of zmq inproc:// sockets ;)
On Dec 31, 2013, at 12:41, Matt Connolly matt.conno...@me.com wrote:
Zmq poller can also wake on standard file descriptors (eg unix socket). If
your custom event can write to a unix socket or pipe you might be in luck.
Cheers
Matt.
Use the identity for routing and a first message from your own for
authentication. Now if the auth fails, I have no idea how to “disconnect” that
peer :( but you can keep your own hash and never reply back to such peer.
On Dec 28, 2013, at 15:17, Dmitriy Vsekhvalnov dvsekhval...@gmail.com
On Dec 28, 2013, at 17:26, Michael Powell mwpowell...@gmail.com wrote:
On Sat, Dec 28, 2013 at 11:05 AM, Daniel Krikun dkrik...@gmail.com wrote:
What I wanted to say is that while patterns do simplify development, they
have there peculiarities, in the example above, i'm doing non-blocking
. How can i track identity or peer?
On Sat, Dec 28, 2013 at 7:38 PM, Bruno D. Rodrigues
bruno.rodrig...@litux.org wrote:
Use the identity for routing and a first message from your own for
authentication. Now if the auth fails, I have no idea how to “disconnect”
that peer :( but you can
I recall apache activemq (jms) had a ttl system that worked like this (back in
2008, no idea how it works now):
- messages gets queued individually
- when a consumer connects, messages gets popped from the queue, and if the ttl
elapsed, they’d get discarded instead of piped into the consumer.
.
On Dec 28, 2013 9:06 PM, Bruno D. Rodrigues bruno.rodrig...@litux.org
wrote:
On Dec 28, 2013, at 17:26, Michael Powell mwpowell...@gmail.com wrote:
On Sat, Dec 28, 2013 at 11:05 AM, Daniel Krikun dkrik...@gmail.com wrote:
What I wanted to say is that while patterns do simplify development
is not concrete business feature, it's very common
and ubiquitous
thing.
Agree?
2013/12/28 Bruno D. Rodrigues bruno.rodrig...@litux.org
I recall apache activemq (jms) had a ttl system that worked like this
(back in 2008, no idea how it works now):
- messages gets queued individually
- when
On Dec 22, 2013, at 21:33, Randall Nortman rn...@wonderclown.net wrote:
I am developing a new application using zmq in an unusual (from what
I've seen so far) way. I'd like to solicit input, particularly about
reasons this may be a terrible idea. It is essentially a variation on
an
connect a ZMQ_STREAM to a ZMTP socket.
Whatever connexion you make, the server will use a random 5 bytes identity
for the first connexion to a given socket, and will increment it for the
next one.
Le 17/12/2013 23:44, Bruno D. Rodrigues a écrit :
From my experience if you set the dealer identity
Check the new IMMEDIATE flag
--
Bruno Rodrigues
Sent from my iPhone
No dia 17/12/2013, às 08:57, artemv zmq artemv@gmail.com escreveu:
hello there, devs
do we have any updates here?
2013/12/14 artemv zmq artemv@gmail.com
Ok. I set HWM to 0. Launched DEALER (my client) , and
I’ll ask again, isn’t this what the IMMEDIATE does? With this on, send fails
right away if the connection is not yet established (for the relevant socket
types of course)
On Dec 17, 2013, at 17:35, artemv zmq artemv@gmail.com wrote:
hello there,
I have a proposition to the core of ZMQ:
From my experience if you set the dealer identity before connecting,
by design it will always use that value. It's when the identity is not
set manually and the router calculates a unique id that it will
change.
--
Bruno Rodrigues
Sent from my iPhone
No dia 17/12/2013, às 22:33, Greg Ward
I'm not using windows but if there is anything I could help a fellow
colleague from Técnico, in Portuguese, just ask me ;)
--
Bruno Rodrigues
Sent from my iPhone
No dia 13/12/2013, às 12:35, Francisco Freire francisco.m.fre...@gmail.com
escreveu:
Hi,
I'm doing some research at Instituto
The client, being the one doing the connect, should also always send a first
hello, and hence it’s a simple multi dealer (clients) - router (server) pattern.
On Dec 13, 2013, at 21:39, Kelly Sommers kell.somm...@gmail.com wrote:
Hey everyone!
I'm looking to have a server that can accept
all implementation shall talk to all implementations without issues, or else
report a bug and provide a fix ;)
On Dec 12, 2013, at 13:01, Dmitriy Vsekhvalnov dvsekhval...@gmail.com wrote:
Thanks Doron.
How about NetMQ to JeroMQ?
On Thu, Dec 12, 2013 at 4:05 PM, Doron Somech
On Dec 12, 2013, at 17:40, Randall Nortman rn...@wonderclown.net wrote:
On Thu, Dec 12, 2013 at 06:46:12PM +0200, artemv zmq wrote:
[...]
Now my question is going more to networking field. I want that kind of
situations when I can lose connection __but__ nor FIN, neither RST will be
, Dec 11, 2013 at 12:38 AM, Bruno D. Rodrigues
bruno.rodrig...@litux.org wrote:
Xsub xpub for distribution load balancing
What is Xsub xpub? Could you please explain these terms or give me a link to
an online resource where these terms are explained in detail?
Thanks in advance,
-Asif
(not
batching!) applications on ZMQ?
BR
-artemv
2013/12/11 Bruno D. Rodrigues bruno.rodrig...@litux.org
zeromq.org - learn the basics - http://zeromq.org/intro:read-the-manual - the
guide - http://zguide.zeromq.org/page:all
I just gave you a short description of how Ømq is solving
On Dec 11, 2013, at 14:43, Pieter Hintjens p...@imatix.com wrote:
On Wed, Dec 11, 2013 at 1:40 PM, Andrew Hume and...@research.att.com wrote:
i’ve just switched to using poller and wanted to verify my “pattern”.
i have 4 incoming sockets. 3 are (very) low volume but need low latency
the
I’m gonna answer from my own experience but I’m sure someone with better
knowledge will correct me ;)
1. Albeit I’m using java and even the jeromq codebase, I’ve solved it by simply
synchronizing the access to the socket.recv and socket.send (mutex, whatever
it’s called on your language), and
as requested I’ve created a ticket and updated the branch with the latest code
and a perf/README.txt explaining how to run it (basically the instructions
below)
https://github.com/zeromq/libzmq/issues/757
On Nov 10, 2013, at 13:08, Bruno D. Rodrigues bruno.rodrig...@litux.org wrote:
I’ve
/SUB.
So, then again, what is happening with the zmq_proxy?
On Nov 7, 2013, at 22:15, Bruno D. Rodrigues bruno.rodrig...@litux.org wrote:
I’ve been testing a lot of combinations of ZeroMQ over Java, between the pure
jeromq base and the jzmq JNI libzmq C code. Albeit my impression so far
Rodrigues
Sent from my iPhone
No dia 10/11/2013, às 18:53, Pieter Hintjens p...@imatix.com escreveu:
On Sun, Nov 10, 2013 at 2:08 PM, Bruno D. Rodrigues
bruno.rodrig...@litux.org wrote:
I’ve branched the code to add the proxy code for testing:
https://github.com/davipt/libzmq/tree/fix-002
I'm unable to test this but as I see a sleep 0.5 and a constant delay
increase of 1sec I'd suggest the receiver to instead of sleeping a
fixed time, to poll, with a timeout value until the next tick. That
way if the receive and your code takes 0.75s, the poll can Sleep only
Up to 0.25s, but more
With the current master, I get all pass on macosx as long as I run ulimit -n
8192 before.
The test_many_sockets fails because it creates 5K sockets. The shutdown may
fail for similar reasons.
Testsuite summary for
, 2013 at 12:18 PM, Bruno D. Rodrigues
bruno.rodrig...@litux.org wrote:
With the current master, I get all pass on macosx as long as I run ulimit -n
8192 before.
The test_many_sockets fails because it creates 5K sockets. The shutdown may
fail for similar reasons
not crash or assert when this
condition hits.
On Sat, Nov 9, 2013 at 1:19 PM, Bruno D. Rodrigues
bruno.rodrig...@litux.org wrote:
So if the limits are raised should the test fail or still pass albeit
is not testing anything?
I don't think it's a good idea to have tests depending
probably when they are attempted to be used.
Will follow the create socket and try to understand what is failing here…
On Nov 9, 2013, at 20:54, Bruno D. Rodrigues bruno.rodrig...@litux.org wrote:
so this means that even with ulimit -n 256, zmq still happily creates 1024
sockets without returning
I’ve been testing a lot of combinations of ZeroMQ over Java, between the pure
jeromq base and the jzmq JNI libzmq C code. Albeit my impression so far is that
jeromq is way faster than the binding - not that the code isn’t great, but my
feeling so far is that the JNI jump slows everything down -
Wth? This is standard configure like millions of other packages. Just run
with --help. Or in this case you'd need ./configure --prefix=/tmp/foo. But
it's irrelevant because as already said the compiled files are on the
sources, src/.libs as standard.
--
Bruno Rodrigues
Sent from my iPhone
No
It’s quite simple, it’s just sad that there is no links to the right places on
the documentation.
About the Mac version, I only had issues with my Mac Mini running 10.6 because
there is no Oracle Java 7 nor 6, and the Mac java 6 crashed. On the other hand
I can’t recall anymore if it crashed
Most probably OS limits. Check ulimit -n
A 14/10/2013, às 13:40, ljs linj...@163.com escreveu:
1.zmq mode PUB / SUB, PUB on the service side, when each client and server
connected to the SUB, the service side of the gradual increase in the number
of connections, when the number of
receive directly into your buffer, it just does the
copying from a zmq_msg_t to your buffer.
It was probably created to mimic the BSD sockets API.
You could prevent out-of-memory with socket option of ZMQ_MAXMSGSIZE.
On Sat, Oct 12, 2013 at 4:45 AM, Bruno D. Rodrigues
bruno.rodrig
Hello all,
I'm curious about a comment on a certain behaviour of zmq_recv that affected me
when using it over the Java bindings.
The sentence in question is the following: http://api.zeromq.org/3-2:zmq-recv
The zmq_recv() function shall return number of bytes in the message if
successful. Note
61 matches
Mail list logo
