didas/incphub_test
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

feat: Changed client to accept messages to any destination

Browse Source
This commit is contained in:
Diogo Diniz
2026-06-30 15:36:44 +01:00
parent 9f7d1aae4f
commit 6a0df95eeb
2 changed files with 7 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
app/src/incphub/include/incphub/incphub_client.h
View File

@@ -36,14 +36,14 @@ int incphub_get_msg_buffer(incphub_cli_t *cli, uint8_t **buffer_ptr, size_t leng
/// @return INCPHUB_OK on success, an error otherwise /// @return INCPHUB_OK on success, an error otherwise
int incphub_release_msg_buffer(incphub_cli_t *cli, uint8_t *buffer); int incphub_release_msg_buffer(incphub_cli_t *cli, uint8_t *buffer);
/// @brief Attempts to send a message to the local interface /// @brief Attempts to send a message
/// @param cli Current client handle /// @param cli Current client handle
/// @param buffer The message buffer (gets consumed) /// @param buffer The message buffer (gets consumed)
/// @param length The message length /// @param length The message length
/// @param dst_port The destination NTL port /// @param dst_addr The destination address
/// @param max_delay The maximum time to wait for a resources, in ticks /// @param max_delay The maximum time to wait for a resources, in ticks
/// @return INCPHUB_OK on success, an error otherwise /// @return INCPHUB_OK on success, an error otherwise
int incphub_send_local(incphub_cli_t *cli, uint8_t *buffer, size_t length, ntl_port_t dst_port, TickType_t max_delay); int incphub_send_msg(incphub_cli_t *cli, uint8_t *buffer, size_t length, incphub_addr_t dst, TickType_t max_delay);
/// @brief Awaits the receival of a message /// @brief Awaits the receival of a message
/// @param cli Current client handle /// @param cli Current client handle

8
app/src/incphub/src/incphub_client.c
View File

@@ -59,13 +59,13 @@ int incphub_release_msg_buffer(incphub_cli_t *cli, uint8_t *buffer)
return release_msg_buffer(unwound); return release_msg_buffer(unwound);
} }
int incphub_send_local(incphub_cli_t *cli, uint8_t *buffer, size_t length, ntl_port_t dst_port, TickType_t max_delay) int incphub_send_msg(incphub_cli_t *cli, uint8_t *buffer, size_t length, incphub_addr_t dst, TickType_t max_delay)
{ {
if (cli == NULL) if (cli == NULL)
return INCPHUB_EINVAL; return INCPHUB_EINVAL;
if (buffer == NULL) if (buffer == NULL)
return INCPHUB_EINVAL; return INCPHUB_EINVAL;
if (dst_port == NTL_PORT_EMPTY) if (dst.port == NTL_PORT_EMPTY)
return INCPHUB_EINVAL; return INCPHUB_EINVAL;
// Unwind buffer pointer // Unwind buffer pointer
@@ -73,10 +73,10 @@ int incphub_send_local(incphub_cli_t *cli, uint8_t *buffer, size_t length, ntl_p
nil_packet_t *nil_packet = (nil_packet_t*)(ntl_packet - sizeof(ntl_header_t)); nil_packet_t *nil_packet = (nil_packet_t*)(ntl_packet - sizeof(ntl_header_t));
// Populate NTL header // Populate NTL header
ntl_build_header(&ntl_packet->header, dst_port, cli->port, length); ntl_build_header(&ntl_packet->header, dst.port, cli->port, length);
// Populate NIL header // Populate NIL header
nil_build_header(&nil_packet->header, NIL_ADDR_LOCALHOST, INCPHUB_LOCAL_NIL_ADDR, length + sizeof(ntl_header_t)); nil_build_header(&nil_packet->header, dst.addr, INCPHUB_LOCAL_NIL_ADDR, length + sizeof(ntl_header_t));
// Pass to ingest // Pass to ingest
return enqueue_message_ingest((uint8_t *)nil_packet, max_delay); return enqueue_message_ingest((uint8_t *)nil_packet, max_delay);