Example for external messaging. #22
Conversation
|
|
||
| test handler/MessageHandler data/ByteArray: | ||
| copy := data.copy // Data can be neutered as part of the transfer. | ||
| process_send_ EXTERNAL_PID TYPE data |
There was a problem hiding this comment.
Maybe it is worth abstracting a little bit over this. If you end up with a symbolic name for external message handlers then having a wrapper, so you can add a helper for sending messages and maybe for receiving them with a lambda instead of a full SystemMessageHandler_ would be nice.
You could have a --copy flag for the sending (default to true) like in the Artemis package: https://github.com/toitware/toit-artemis/blob/main/src/artemis.toit#L339.
| main: | ||
| print "starting" | ||
| handler := MessageHandler | ||
| set_system_message_handler_ (TYPE + 1) handler |
| @@ -0,0 +1 @@ | |||
| # set(EXTRA_COMPONENT_DIRS ${EXTRA_COMPONENT_DIRS} ${CMAKE_CURRENT_SOURCE_DIR}/src) | |||
| static toit_err_t on_message(void* user_context, int sender, int type, void* data, int length); | ||
| static toit_err_t on_removed(void* user_context); | ||
|
|
||
| typedef struct process_t { |
There was a problem hiding this comment.
| typedef struct process_t { | |
| typedef struct { |
|
|
||
| typedef struct process_t { | ||
| toit_process_context_t* process_context; | ||
| } process_t; |
There was a problem hiding this comment.
| } process_t; | |
| } foo_context_t; |
| .on_message = &on_message, | ||
| .on_removed = &on_removed, | ||
| }; | ||
| toit_err_t err = toit_set_callbacks(process_context, cbs); |
There was a problem hiding this comment.
This would be the natural place to provide the user_context.
| printf("unable to allocate user context\n"); | ||
| return; | ||
| } | ||
| toit_add_external_process(user_context, "toit.io/external-test", &start); |
There was a problem hiding this comment.
Maybe don't provide the user context just yet?
| static toit_err_t start(void* user_context, toit_process_context_t* process_context) { | ||
| printf("starting process\n"); | ||
| process_t* process = (process_t*)(user_context); | ||
| process->process_context = process_context; |
There was a problem hiding this comment.
It would be great if this was closer to the malloc.
|
Abandoning, as the code was integrated in other repositories/PRs. |
No description provided.