Filip Krakowski

I created a small minimal working example program where each of two threads sends messages using `ucp_am_send_nbx`. https://gist.github.com/krakowski/8a30c6bf3e94b727e9e1ac268cbb8045 The assertion does not always fail, as it works most of the...

@dmitrygx Thanks for looking into this! It works for me most of the time, too. I'm not really sure how I can reproduce this reliably. If I hit the right...

@dmitrygx I just updated my gist. This version crashes every time I try to run it. https://gist.github.com/krakowski/8a30c6bf3e94b727e9e1ac268cbb8045 Things I changed: * Use the same buffer for `ucp_am_send_nbx`s `header` and `buffer`...

Strange... I will try to debug it further tomorrow to see why the assertion fails on my machine. I also could not really find out what `max_iov` stands for. Can...

@dmitrygx I managed to narrow down the problem a bit more. The crash does only occur, when UCX chooses `shm` and `tcp` as transports. Running the demo app with `UCX_TLS=tcp`...

~Sure, here is the output:~ #### Edit --- I updated the demo to use UCX's logging functions for a more readable output : https://gist.github.com/krakowski/8a30c6bf3e94b727e9e1ac268cbb8045 Here's the updated output: `Client Side`...

@dmitrygx Your solution works! I noticed that the first transport lane after reconfiguration changed from `posix/memory` to `sysv/memory`. Here's the output: `Client Side` ``` $ UCX_LOG_LEVEL=info UCX_TLS=shm,tcp ./openucx_examples client [1651415190.175301]...

Sure, I'm glad I can help :slightly_smiling_face: `master` ``` $ UCX_TLS=tcp,shm UCX_LOG_LEVEL=info ucx_info -eptw -u tra -P intra -A 127.0.0.1 [1651489956.267674] [alpha:33246:0] ucp_context.c:1855 UCX INFO Version 1.14.0 (loaded from /usr/lib/libucp.so.0)...

I could fix this in the `one-to-one` case by using `flatMap` instead of `subscribe`, though I'm not sure if this is correct since I removed the `SubscribeOnlyOnceLifter`. ```java public static...

I implemented a [failing test](https://github.com/krakowski/reactive-grpc/blob/c7eb05ea23bb9994334af7cc93b4c0c69dbe187d/reactor/reactor-grpc-test/src/test/java/com/salesforce/reactorgrpc/ReactorContextPropagationTest.java) for this issue. - `oneToMany` - :heavy_check_mark: - `oneToOne` - :x: - `manyToOne` - :x: - `manyToMany` - :x: