Hello!
I updated my actors to use zpoller to handle both pipe, and reply
sockets, it works fine under linux, but on windows it crashes when I
call zpoller_wait.
the output on stdout is:
actor1
actor2
actor3
test 00DC5960
actor4
void rep_actor(zsock_t *pipe, void *args) {
Thanks for the reply!
But how can I listen to both sockets, pipe and subscriber?
Are there any examples how to do that?
On 2017-09-29 22:14, Luca Boccassi wrote:
On Fri, 2017-09-29 at 11:38 +0200, Bachmair Florian - flexSolution GmbH
wrote:
Hi!
When I stop my application in roughly 1 out
Hi!
When I stop my application in roughly 1 out of 20 tries I get this error:
Assertion failed: pfd.revents & POLLIN (src/signaler.cpp:243) (here is
the corresponding line of code:
https://github.com/zeromq/libzmq/blob/v4.2.0/src/signaler.cpp#L243 )
Stack trace of thread 8576:
wrote:
Hello.
You can use vs2015 directory, open the czmq.sln with VS 2017 and
convert it to VS 2017 solution.
Greetings,
2017-07-27 7:05 GMT+02:00 Bachmair Florian - flexSolution GmbH
<florian.bachm...@flexsolution.eu
<mailto:florian.bachm...@flexsolution.eu>>:
Hi!
Hi!
I tried to compile CZMQ on Windows the first time, according to
https://github.com/zeromq/czmq#building-on-windows
libsodium and libzmq works fine, but for czmq the folder
*czmq\builds\msvc\build* is missing
Also I see that ther is no *vs2017* folder in *czmq\builds\msvc*, is
that a
in /home/flex/core-
1.0.0/emerson2/lib/native/libzmq.so
(zmq::socket_base_t::term_endpoint(char const*)+0x19c)
#3 0x638bfc0c in /home/flex/core-
1.0.0/emerson2/lib/native/libczmq.so
(zsock_disconnect+0x48)
On 2017-05-09 07:23, Bachmair Florian - flexSolution GmbH wrote:
Hi!
I'm using a JNI
/flex/core-1.0.0/emerson2/lib/native/libzmq.so
(zmq::socket_base_t::term_endpoint(char const*)+0x19c)
#3 0x638bfc0c in /home/flex/core-1.0.0/emerson2/lib/native/libczmq.so
(zsock_disconnect+0x48)
On 2017-05-09 07:23, Bachmair Florian - flexSolution GmbH wrote:
Hi!
I'm using a JNI Wrapper to use
Hi!
I'm using a JNI Wrapper to use czmq.(with the latest libzmq and czmq
from git,compiled yesterday on an arm)
Don't know if this is just a coincidents but this is how I reproduce the
error:
* start all Applications(6) (on the same host) they connect to each
other via TCP automatically
My bad, i used:
char *endpoint = (char*) malloc(sizeof(30));
instead of
char *endpoint = (char*) malloc(sizeof(char)*30);
I was lead to an library issue cause it worked fine on my developer machine.
Am 17.11.2016 um 08:03 schrieb Bachmair Florian - flexSolution GmbH:
Error occurs
Error occurs only on arm(raspberry pi 2)
Am 17.11.2016 um 07:53 schrieb Bachmair Florian - flexSolution GmbH:
Hi. I'm using czmq via a jni wrapper, and when I execute this
method(See methode at the bottom of this message), the application
crashes at the RED Codeline with
Any Ideas why
Hi. I'm using czmq via a jni wrapper, and when I execute this method(See
methode at the bottom of this message), the application crashes at the
RED Codeline with
Any Ideas why this happens?
*** Error in `java': malloc(): memory corruption: 0x64e01218 ***
=== Backtrace: =
hi!
is there an option to unsubscribe from ALL topics?
I have found
void zsocket_set_unsubscribe (void *zocket, char * unsubscribe);
Is the only option to save all topics and then unsubscribe from each of them?
Therefore I would have to save the topics(what I currently don't)
Or is there
Hi!
Is there a way to get a Timeout for a Request?
If I send a Request, it "hangs" till the other side Responses. If the
other Side is not up, I never get a response.
I would like to detect this on the Request side. Is that possible?
my current request code is:
JNIEXPORT jstring JNICALL
bindings for CZMQ using zproject, don't have a
> JNI generator yet. ... :)
>
> You could use inproc yes, except you still need to call the libzmq API to
> send/receive messages. It's probably better to look at finding the bottleneck.
>
> On Thu, Sep 3, 2015 at 4:20 PM, Bachmair F
:52 schrieb Bachmair Florian - flexSolution GmbH:
It's hard to tell.
For example If I get position while some machine is moving.
I can get values up to every 10 ms, so if the connections is broken
for 1 second I miss 100 messages.
I do send a timestamp with my messages, but It's hard to get
and only process the last one.
On Aug 27, 2015 20:42, Bachmair Florian - flexSolution GmbH
florian.bachm...@flexsolution.eu
mailto:florian.bachm...@flexsolution.eu wrote:
ok, thank you!
I have to think about that, because I want to use curve as well,
and therefore I would need tcp
it would block and only process the last one.
On Aug 27, 2015 20:42, Bachmair Florian - flexSolution GmbH
florian.bachm...@flexsolution.eu
mailto:florian.bachm...@flexsolution.eu wrote:
ok, thank you!
I have to think about that, because I want to use
needed. Switch to the UDP if don't need that reliability.
On 27.08.2015 14:07, Bachmair Florian - flexSolution GmbH wrote:
This does not work either :/
I'm unsing PUB/SUB via tcp.
I have captured the tcp connection with tcpdump and I saw that after
I unplug the cable I get tcp retransmission
27, 2015 11:38 AM, Bachmair Florian - flexSolution GmbH
florian.bachm...@flexsolution.eu
mailto:florian.bachm...@flexsolution.eu wrote:
Hello!
Is there a opportunity to tell the publisher not to resend messages?
I have two stations A and B
A publishes all the time
B
Hello!
Is there a opportunity to tell the publisher not to resend messages?
I have two stations A and B
A publishes all the time
B receives it
A-PUB 10
B-SUB 10
A-PUB 20
B-SUB 20
A-PUB 30
B-SUB 30
A-PUB 40
B-SUB 40
---unplug cable
A-PUB 50
A-PUB 60
A-PUB 70
---plug cable again
B-SUB 50
B-SUB
to set ZMQ_SNDHWM to 1. By the way which transport are you using?
On 27.08.2015 11:52, Bachmair Florian - flexSolution GmbH wrote:
I tried it, but it does not work!
Don't know If I get that right, but even If I set ZMQ_RECONNECT_IV to
-1 my PUB and SUB Sockets are reconnecting to each other
Hello!
Is there a way to determine the connection state of my subscriber?
Szenario
Host1Host2
Task 1
Task 2Task3
Task 1 publishes a topic.
Task 2 and Task 3 are subscribing this topic
Task 2 gets it, Task3 don't
If I restart
).
On Thu, Aug 13, 2015 at 1:16 AM, Bachmair Florian - flexSolution GmbH
florian.bachm...@flexsolution.eu
mailto:florian.bachm...@flexsolution.eu wrote:
Hello!
Is there a way to determine the connection state of my subscriber?
Szenario
Host1Host2
Hi!
I use zbeacon(see http://czmq.zeromq.org/manual:zbeacon) to let the
nodes send their port, so that other nodes can connect to them.
Is there a need to let the nodes to be SILENT after all nodes are
connected to each other? Or is that no problem, that let's say 100 nodes
send their ports
the metadata. This is the simplest way to share
connection data. See the zyre_test case as example.
On Tue, Jun 2, 2015 at 7:53 AM, Bachmair Florian - flexSolution GmbH
florian.bachm...@flexsolution.eu wrote:
Hi!
Till now I have configured all connection parameters in a sqlite
database
Hi!
Till now I have configured all connection parameters in a sqlite
database. But this can fast get messy if I have a lot of nodes. Now I
saw something like zbeacon or zyre to exchange connection data.
I want to use this with pub/sub.
If I use zyre I can see if a node joins, and is it then
Hi!
Is it possible to send Messages with a certain priority?
So that time critical messages will be sent first?
___
zeromq-dev mailing list
zeromq-dev@lists.zeromq.org
http://lists.zeromq.org/mailman/listinfo/zeromq-dev
messages.
In your message handling loop you can give priority to the urgent
socket by handling messages from the urgent first.
On Tue, May 26, 2015 at 11:49 AM, Bachmair Florian - flexSolution GmbH
florian.bachm...@flexsolution.eu
mailto:florian.bachm...@flexsolution.eu wrote:
Hi
hi!
Sometimes I get an assertion failed in my code.
Why is this? shouldn't it block, till a connection is established?
NIEXPORT jstring JNICALL Java_eu_flexsolution_core_JNI_1zeromq_request(
JNIEnv *env, jobject object, jstring address, jstring timestamp,
jstring format,
does not block. It returns -1 if the endpoint is
invalid, which presumably it is. Could you tell us what the value of
'addr' is ?
On Tue, May 19, 2015 at 9:40 AM, Bachmair Florian - flexSolution GmbH
florian.bachm...@flexsolution.eu wrote:
hi!
Sometimes I get an assertion failed in my code
ok that was not (my only) problem.
It is also during execution.
How can I print the strerror?
int rc = zsocket_connect(req, %s, addr);
zmq_strerror (zmq_errno ());
assert(rc == 0);
does not print anything for me
Am 19.05.2015 um 11:23 schrieb Bachmair Florian - flexSolution GmbH:
like
, which presumably it is. Could you tell us what the value of
'addr' is ?
On Tue, May 19, 2015 at 9:40 AM, Bachmair Florian - flexSolution GmbH
florian.bachm...@flexsolution.eu wrote:
hi!
Sometimes I get an assertion failed in my code.
Why is this? shouldn't it block, till a connection
but the assertion failed I get with that error
Das Argument ist ungültig (The Argument is invalid)
Am 19.05.2015 um 11:56 schrieb Bachmair Florian - flexSolution GmbH:
Thank you!
I get Die Ressource ist zur Zeit nicht verfügbar (The ressource is
temporarily not available)
what does
um 11:23 schrieb Bachmair Florian - flexSolution GmbH:
like that?
int rc = zsocket_connect(req, %s, addr);
zmq_strerror (zmq_errno ());
assert(rc == 0);
this does not work.
But I think I found the problem.
I start both applications at the same time, so the socket may not yet
socket, connect) just as a
sanity check for your system, and see what it takes to reproduce the
problem.
On Tue, May 19, 2015 at 11:58 AM, Bachmair Florian - flexSolution GmbH
florian.bachm...@flexsolution.eu wrote:
but the assertion failed I get with that error
Das Argument ist ungültig
hi!
I thought pub/sub works with simple prefix?
I publish two topics;
publish(Test, RAW, 17);
publish(.INT_[0], RAW, 14);
the first one is sucesfully received, the second isn't.
But why?
Thanks
Florian
___
zeromq-dev mailing list
That happend by accident, had a problem with curve.
PS: I use czmq in JNI wrappers, and there the debug output is
supressed..any chance to get this output visible in the console?
Am 06.05.2015 um 09:04 schrieb Bachmair Florian - flexSolution GmbH:
hi!
I thought pub/sub works with simple
Hi
void *req = zsocket_new(context, ZMQ_REQ);
int rc = zsocket_connect(req, %s, addr);
assert(rc==0);
s_sendmore(req, ts);
s_sendmore(req, f);
s_sendmore(req, cmd);
s_send(req, msg);
char* reply = s_recv(req); //hangs if REPLYER is not available
how can I solve
Hi!
I have a *char[] with parameter which I wanna hand over to my subscriber
thread.
I tried it with my own method which needs an void-pointer as well. There
I can read the parameters sucesffuly, but not If I start a Thread via
zthread_fork
Here's some sample code to Illustrate my problem
Hi!
I'm writing a class which can act as PUB, SUB, REQ, REP or any
combinations of that.
If I use more then one socket type, should I use the same context for
all of these or separate ones?
___
zeromq-dev mailing list
zeromq-dev@lists.zeromq.org
strcat works.
Cheers
W dniu 2015-03-18 o 07:22, Bachmair Florian - flexSolution GmbH pisze:
Here is my example: I did it with CURVE but it's the same without CURVE
I publish a String with 1024 'x' ending with \nENDE to determine that the
end is sent as well
publisher:
#include stdlib.h
Hi!
I have tried to send/publish string with 1000 characters. But the subscriber
only gets about 200-300 of these characters, the rest is cut off.
Is there a Limit?
___
zeromq-dev mailing list
zeromq-dev@lists.zeromq.org
Hello!
I have a pub/sub application with CURVE which works for TCP, but not for EPGM
int rc = zsocket_bind(pub, addr);
assert(rc !=-1)
gives me assertion failed: (rc!=-1)
___
zeromq-dev mailing list
zeromq-dev@lists.zeromq.org
Hi!
I have generated the certificates with 'makecert' and put it in individual
.curve folders for the subscriber and publisher.
If I let the publisher use the private certificate and the subscriber the
public one I get this output : CURVE I: cannot open client INITIATE vouch
But if I use
21:01
An: ZeroMQ development list
Betreff: Re: [zeromq-dev] zcertstore_insert: Assertion 'rc == 0' failed.
Can you get the stack backtrace?
On Mon, Mar 9, 2015 at 2:58 PM, Bachmair Florian - flexSolution GmbH
florian.bachm...@flexsolution.eu wrote:
I combiled it exactly like here: http
I get this error zcertstore_insert: Assertion 'rc == 0' failed.
When I execute this code:
#include czmq.h
static int s_send(void *socket, char *string);
static int s_sendmore(void *socket, char *string);
int main(void) {
puts(Publisher);
zctx_t *context =
Florian - flexSolution GmbH
florian.bachm...@flexsolution.eu wrote:
I get this error zcertstore_insert: Assertion 'rc == 0' failed.
When I execute this code:
#include czmq.h
static int s_send(void *socket, char *string);
static int s_sendmore(void *socket, char *string);
int main(void
this to encrypt the TCP connection, yes. You will not get CURVE's
authentication features.
On Tue, Mar 3, 2015 at 9:41 AM, Bachmair Florian - flexSolution GmbH
florian.bachm...@flexsolution.eumailto:florian.bachm...@flexsolution.eu
wrote:
Hi!
Due the case that curve-security is not yet
Hi!
Due the case that curve-security is not yet supported in java. I want to make a
little workaround:
The XSUB/XPUB-Proxy should connect to each other. This will be implemented in
C, where security is available.
The rest speaks via ipc to each other. Is it possible that XPUB/XSUB do
forward
Hi!
I have read about security the new security features of zeroMQ in
http://hintjens.com/blog:49. are those security capability also available in
the java bindings? If not, will they be soon? I have seen that they are
available in python, are they available in any other bindings?
Is ordinary
50 matches
Mail list logo
