Feature/brokerless p2p #164
Conversation
|
Build status:
|
|
Build status:
|
|
Build status:
|
|
Build status:
|
|
Build status:
|
| if (object_id->type == UXR_DATAREADER_ID) | ||
| { | ||
| uxrStreamId stream = {0, 0, UXR_BROKERLESS, UXR_INPUT_STREAM}; | ||
| uxrStreamId stream = {0, 0, UXR_BROKERLESS_STREAM, UXR_INPUT_STREAM}; |
There was a problem hiding this comment.
Check this, have you changed the stream type enum also?
There was a problem hiding this comment.
yes, I just did it to maintain the coherence with the naming of the rest of the elements in the enum 🙂
| char* ip = argv[1]; | ||
| char* port = argv[2]; | ||
| uint32_t key = (args == 4) ? (uint32_t)atoi(argv[3]) : 0xCCCCDDDD; | ||
| uint32_t key = 0xCCCCDDDD; |
There was a problem hiding this comment.
This file should not be changed. Remember: keep unchanged.
| #define STREAM_HISTORY 8 | ||
| #define BUFFER_SIZE UXR_CONFIG_UDP_TRANSPORT_MTU * STREAM_HISTORY | ||
|
|
||
| bool sended = false; |
There was a problem hiding this comment.
This file should not be changed. Remember: keep unchanged.
| #define STREAM_HISTORY 8 | ||
| #define BUFFER_SIZE UXR_CONFIG_UDP_TRANSPORT_MTU * STREAM_HISTORY | ||
|
|
||
| uint32_t last_index = -1; |
There was a problem hiding this comment.
This file should not be changed. Remember: keep unchanged.
| UXR_RELIABLE_STREAM | ||
| UXR_RELIABLE_STREAM, | ||
| /** Identifies a brokerless stream. */ | ||
| UXR_BROKERLESS_STREAM |
There was a problem hiding this comment.
This is the stream name, in the other file UXR_BROKERLESS_STREAM is not being used.
There was a problem hiding this comment.
Everything is ok. My fault.
|
Build status:
|
|
Build status:
|
|
Build status:
|
|
Build status:
|
pablogs9
force-pushed
the
feature/brokerless_p2p
branch
from
eb5aae4 to
223d69b
Compare
|
Build status:
|
|
I think this is pretty cool - will it be worked on again? |
4 participants
TODO: