We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent c65cf86 commit b04e48eCopy full SHA for b04e48e
1 file changed
up_client_socket/cpp/src/SocketUTransport.cpp
@@ -167,8 +167,12 @@ struct SocketUTransport::Impl {
167
__LINE__, umsg.DebugString());
168
169
auto& attributes = umsg.attributes();
170
- auto key = makeKey(attributes.source());
+ auto key = makeKey(attributes.sink(), attributes.source());
171
auto ptr = callback_data_.find(key);
172
+ if (ptr == nullptr) {
173
+ key = makeKey(attributes.sink());
174
+ ptr = callback_data_.find(key);
175
+ }
176
if (ptr != nullptr) {
177
unique_lock<mutex> lock(ptr->mtx);
178
for (auto callback : ptr->listeners) {
0 commit comments