Feature/brokerless p2p #164
Conversation
|
Build status:
|
|
Build status:
|
|
Build status:
|
|
Build status:
|
|
Build status:
|
| uxrObjectId * object_id = &brokerlessEntityMap.queue[hash_index].id; | ||
|
|
||
| // TODO (pablogs9): request_id is related to the uxr_buffer_request_data request, so it can determine some limitations imposed into the communication -> NOT IMPLEMENTED BY NOW | ||
| 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 🙂
| @@ -72,7 +72,7 @@ int main(int args, char** argv) | |||
|
|
|||
| 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.
| @@ -23,6 +23,7 @@ | |||
| #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.
|
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? |
TODO: