Please use this template for reporting suspected bugs or requests for help.

Issue Description

Environment

• tag or commit hash on which this occured
• OS version: <e.g. ubuntu-16.04>
  ...

Minimal test code / Steps to reproduce the issue

What's the actual result?

What's the expected result?

Hi,
I'm trying to use server/client example to create more realistic POC with fbzmq. What I'm trying to achieve is the multiple clients accessing single server asynchronously. So, I guess I need DEALER socket on client and ROUTER socket on server, which allow non-blocking request/response. Right? Should I explicitly specify fbzmq::NonblockingFlag{true} on socket? On both sides? Should I do my own enveloping on messages when I work asynchronously or fbzmq makes it transparent for me?
Anything else I have to take into consideration when designing such a pattern?

Sincerely,
Ernest

Please use this template for reporting suspected bugs or requests for help.

Issue Description

From the current documentation and examples, it is unclear to me whether the API supports publishing a message on a specific topic. Is this possible using the fbzmq API?

Environment

• tag or commit hash on which this occured
• OS version: <e.g. ubuntu-16.04>
  Mint 18.3 (Ubuntu 16.04)

Minimal test code / Steps to reproduce the issue

What's the actual result?

Current send*() methods on the API do not seem to support publishing on a topic for a ZMQ_PUB socket.

What's the expected result?

send*() methods on the API have a parameter to publish on a topic.

Hi,
Quick question. Somewhere in the build script I saw jemalloc mentioned. How it would play with my application that uses tcmalloc tailored to work with shared memory allocated on hugepages? can I disable jemalloc? Can I (easily) replace it with my tcmalloc implementation?
Sincerely,
Ernest

Hi,
Am I supposed to be able to build the fbzmq in docker container running vanilla Ubuntu 16.04?

Sincerely,
Ernest

[ 50%] Building CXX object CMakeFiles/fbzmq.dir/service/logging/LogSample.cpp.o
/builder/powerpc_8540/build/sdk/build_dir/target-powerpc_8540_musl/fbzmq-2019.06.10.00/fbzmq/async/ZmqTimeout.cpp: In static member function 'static std::unique_ptr<fbzmq::ZmqTimeout> fbzmq::ZmqTimeout::make(fbzmq::ZmqEventLoop*, fbzmq::TimeoutCallback)':
/builder/powerpc_8540/build/sdk/build_dir/target-powerpc_8540_musl/fbzmq-2019.06.10.00/fbzmq/async/ZmqTimeout.cpp:40:59: error: 'new' of type 'fbzmq::{anonymous}::ZmqTimeoutWrapper' with extended alignment 16 [-Werror=aligned-new=]
       new ZmqTimeoutWrapper(eventLoop, std::move(callback)));
                                                           ^
/builder/powerpc_8540/build/sdk/build_dir/target-powerpc_8540_musl/fbzmq-2019.06.10.00/fbzmq/async/ZmqTimeout.cpp:40:59: note: uses 'void* operator new(std::size_t)', which does not have an alignment parameter
/builder/powerpc_8540/build/sdk/build_dir/target-powerpc_8540_musl/fbzmq-2019.06.10.00/fbzmq/async/ZmqTimeout.cpp:40:59: note: use '-faligned-new' to enable C++17 over-aligned new support

I'm guessing this is a C++17 feature being used.

https://downloads.openwrt.org/snapshots/faillogs/powerpc_8540/packages/fbzmq/compile.txt

Issue Description

The current dependency install script seems to be out of date.
I experienced the following issues:

• THRIFT_COMPILER_INCLUDE was set to NOTFOUND and I had to manually download the ThriftLibrary.cmake since the current script points to a tag that does not contain this script (and had to set to that path manually - how is it supposed to be set?)
• Afterwards PROTOCOL and TRANSPORT are still set to NOTFOUND and I have no clue as to which libraries these are.

Environment

• master branch, latest commit b542717
• OS version: ubuntu-16.04
  ...

Minimal test code / Steps to reproduce the issue

• setup clean ubuntu 16.04 vm, clone git, run deps_ubuntu_16.04.sh, run "cmake .."

What's the actual result?

• "CMake Error at CMakeLists.txt:32 (include):
  include could not find load file:

  THRIFT_COMPILER_INCLUDE-NOTFOUND/thrift/ThriftLibrary.cmake

  CMake Error at CMakeLists.txt:40 (thrift_object):
  Unknown CMake command "thrift_object".

  -- Configuring incomplete, errors occurred!
  See also "/home/c1/fbzmq/fbzmq/build/CMakeFiles/CMakeOutput.log"."

and:

• "CMake Error: The following variables are used in this project, but they are set to NOTFOUND.
  Please set them or make sure they are set and tested correctly in the CMake files:
  PROTOCOL
  linked by target "fbzmq" in directory /home/c1/fbzmq/fbzmq
  TRANSPORT
  linked by target "fbzmq" in directory /home/c1/fbzmq/fbzmq"

What's the expected result?

• cmake should run without errors

Hi,
I have a question about processing messages the right way. I see that the socked callback attached to the socket is executed in the same thread where the server's (referring to example server) method run() is called. Meaning it would kill any asynchronous calls to the server since the message processing (I guess message receiving made on zmq polling threads) may take a long time, and thus blocking parallel message processing. What is the right approach to employ in fbzmq? is there any build-in mechanism to offload message processing to a worker thread pool? Should I use my own? If later, how socket callback should treat the sendOne part of the server?
Sincerely,
E

Please use this template for reporting suspected bugs or requests for help.

Issue Description

Have support for Conan to load the library in CMake

Environment

Linux

• tag or commit hash on which this occured
• OS version: <e.g. ubuntu-16.04>
  ...

Minimal test code / Steps to reproduce the issue

What's the actual result?

What's the expected result?

hi,is this support windows platform ?

/usr/ports/net/fbzmq/work/fbzmq-2020.09.07.00/fbzmq/async/tests/ZmqEventLoopTest.cpp:292:36: error: lambda capture 'kCount' is not required to be captured for this use [-Werror,-Wunused-lambda-capture]
    evl.scheduleTimeoutAt(now, [i, kCount, &count, &evl]() noexcept {
                                 ~~^~~~~~
/usr/ports/net/fbzmq/work/fbzmq-2020.09.07.00/fbzmq/async/tests/ZmqEventLoopTest.cpp:320:36: error: lambda capture 'kCount' is not required to be captured for this use [-Werror,-Wunused-lambda-capture]
    evl.scheduleTimeoutAt(now, [i, kCount, &count, &evl]() noexcept {
                                 ~~^~~~~~
2 errors generated.

Version: 2020.09.07.00
clang-10
FreeBSD 12.2