Where communities thrive


  • Join over 1.5M+ people
  • Join over 100K+ communities
  • Free without limits
  • Create your own community
People
Repo info
Activity
  • Dec 06 09:24
    chip5441 opened #1631
  • Nov 12 07:43
    waxwax0099 edited #1630
  • Nov 12 07:43
    waxwax0099 opened #1630
  • Nov 05 03:14
    gdamore labeled #1629
  • Nov 05 02:09
    rty813 edited #1629
  • Nov 05 01:59
    rty813 edited #1629
  • Nov 05 01:59
    rty813 edited #1629
  • Nov 05 01:59
    rty813 edited #1629
  • Nov 05 01:57
    rty813 opened #1629
  • Nov 03 01:58
    waxwax0099 closed #1620
  • Nov 02 13:49
    waxwax0099 reopened #1620
  • Nov 02 13:48
    waxwax0099 closed #1620
  • Oct 20 19:26
    gdamore labeled #1626
  • Oct 20 19:22
    gdamore closed #1627
  • Oct 20 19:02
    gdamore labeled #1627
  • Oct 20 18:13
    polovik opened #1627
  • Oct 20 05:24
    tomghuang opened #1626
  • Oct 19 00:55

    gdamore on master

    Silence NNI_ASSERT warnings whe… (compare)

  • Oct 19 00:55
    gdamore closed #1621
  • Oct 17 06:02
    gdamore labeled #1605
jef-de-busser
@jef-de-busser
Regarding your remark about multiple --dial arguments, I overlooked that in the documentation. I'll read up on that first.
Thx!
jef-de-busser
@jef-de-busser
The above should have read "The 1 publisher was only for my test setup" obviously...
jef-de-busser
@jef-de-busser
BTW: when using nngcat the dialing sub does report that it's connected:
$ nngcat --sub0 --connect-ipc /tmp/test --format quoted -v -k --subscribe ""
Connected to: ipc:////tmp/test"
Florian Hülsmann
@cbix
Hi all, is this channel nng related? What can I use as a low latency, possibly UDP based transport? Is there a QUIC implementation for nng?
Cody Piersall
@codypiersall
The real chat happens on Discord now: https://discord.gg/byTJz6
No UDP/QUIC transports are available yet, but there are open issues for both: QUIC: nanomsg/nng#230 UDP: nanomsg/nng#168
Harris
@zhuzhzh
I want to write one 1-to-N model (similar to telnet server/client). 1 means one server, N means n clients. clients could connects to server at the same time. N usually is less than 20. what's the suggested protocol?
JaylinYu
@JaylinYu
pub/sub I believe
Harris
@zhuzhzh
pub/sub is unidirectional
while telnet is bidirectional
Garrett D'Amore
@gdamore
Req rep.
And I don’t really watch this channel.
Basically one to many is supported with any protocol except pair.
Harris
@zhuzhzh
thanks. I will try it.
Cody Piersall
@codypiersall
Req rep, and have the open as many contexts as max concurrent connections. Note that even with contexts, req/rep is still stateless, and you can't rely on a single context to be associated with a single client.
d3571ny
@qdk0901
Is there any API to get remaining messages count in the queue?
Garrett D'Amore
@gdamore
I don’t really use Gitter anymore.
But the answer to your question is no.
Gary Stuart
@gstuartml_gitlab
Hi. I'm new here. If this has already been discussed, please point me to the appropriate location) I'm using NanoMsg for C++. (#include <nng/compat/nanomsg/nn.h> #include <nng/compat/nanomsg/bus.h>). I have setup pair communications, for multiple nodes, and it is communicating fine, provided I send character strings. If I send binary values, I receive matching input until it gets to a 0x00 value, and then all remaining values are 0x00. I have seen that the default mode is binary, but not in all cases. I have not succeeded in verifying this mode. Does this implementation support binary data? Do I need to do something different? Thanks
Nate Kent
@neachdainn
@gstuartml_gitlab This channel isn't really alive anymore - it's moved to Discord
Obei Sideg
@obeis
Is there way to check number of message in message queue or at least is empty in pub/sub pattern?
Michael Riesch
@carlosvalderrama
Hello all, complete newbie here with two questions. 1) Have there been any efforts so far to use USB as transport medium?
And 2) is the nanomsg/nng project wire compatible with projects that base on ZeroMQ (In terms of protocols, I think this should be ZMTP/3.1)?
Garrett D'Amore
@gdamore
No and no. Sorry.
wangfeiily
@wangfeiily
Hi,everyone. Who can compare PIPELINE pattern with PUBSUB pattern ,which one is more stable ?
StudentXie
@StudentXie
Hello everyone, I would like to ask how to use Nanomsg on QT
wangfeiily
@wangfeiily
@StudentXie you can use it With C++ library , it doesn't matter what framework u use
wangfeiily
@wangfeiily
PIPELINE - aggregates messages from multiple sources and load balances them among many destinations.
can anybody tell me how to implement the PIPELINE . I tried many times ,but can't implement multiple sources and multiple destinations.
Garrett D'Amore
@gdamore
Please note that I rarely watch Gitter anymore. The conversation has moved to discord.
It’s really no different than any of the other patterns like req/rep in this regard.
What is confusing?
wangfeiily
@wangfeiily
I'm writing it in java. with pipeline pattern, i can only implement one push node(bind), multiple pull node(connect).
or multiple push node (connect) one pull node(bind).
It's not exactly like what you said on the web
can u help me ?
wangfeiily
@wangfeiily
if u can show me a demo, it would be better
Garrett D'Amore
@gdamore
You need to have multiple bind addresses. Each server for example should bind to its own address. Each client should then connect to each server. (So the client calls connect multiple times.)
You can swap server and client if you like. It doesn’t matter which side does connect and which does bind.
You cannot get many-to-many without having multiple bind addresses though. You can only bind one process to an address at a time (normally- there are some newer ways to get around that but they aren’t supported.)
wangfeiily
@wangfeiily
OK, I got it , thanks a lot.
Raymond-Sun
@Raymond-Sun
hello, the document protocol section mentioned:"The nng_pub0_open() function creates a pub version 0 socket and returns it at the location pointed to by s." , so, what is "version 0 socket"?
the document page title , such as "nng_pub_open(3) " , what is the meaning "(3)"
nng(7), what is the meaning "(7)"
Garrett D'Amore
@gdamore
Those are man page sections. Section 3 is for library functions. Section 7 is for device drivers. This is ancient UNIX (and also Linux history).
Raymond-Sun
@Raymond-Sun
hello, the document protocol section mentioned:"The nng_pub0_open() function creates a pub version 0 socket and returns it at the location pointed to by s." , so, what is "version 0 socket"?
Garrett D'Amore
@gdamore
The protocols are versioned. For pub and sub there is only version zero at this time.
alexzorin
@alexzorin

Hi! I have a rep TCP server which implements a small stateful protocol using a fixed pool of nng_aio/nng_ctx.

Ideally I'd like to drop (RST) peers which commit a protocol violation: free up the connection and context for another peer. I'm feeling that perhaps that this is a TCP-transport-specific idea and I'm not too sure how to marry what I'm trying to do with how the nng APIs are designed to be used.

One idea I've had has been to approach it in the same way as the REST server example, which involves closing and then recreating the nng_ctx for each new client.

Questions:

  1. Is it possible to do what I want (drop clients and free up the context) with a fixed pool of nng_ctx?
  2. If not, are there any example aio programs which demonstrate how to close/reuse/create contexts against a server socket? I'm not seeing how to do it without the benefit of something like nng_http_server which the REST example uses. Or just a description of the pattern more broadly.

Thank you for the great library!

Garrett D'Amore
@gdamore
We have moved off of gitter. Mostly because its client support is awful.