diff options
Diffstat (limited to 'mmss/iface.c')
-rw-r--r-- | mmss/iface.c | 18 |
1 files changed, 9 insertions, 9 deletions
diff --git a/mmss/iface.c b/mmss/iface.c index 0661c0e..cecfed0 100644 --- a/mmss/iface.c +++ b/mmss/iface.c @@ -29,31 +29,31 @@ #include <stdlib.h> -gmrf_addr_t gmrf_iface_get_addr(gmrf_context_t *ctx, gmrf_iface_t *iface) { +gmrf_addr_t gmrf_iface_get_addr(gmrf_t *gmrf, gmrf_iface_t *iface) { return iface->address; } -size_t gmrf_iface_get_mtu(gmrf_context_t *ctx, gmrf_iface_t *iface) { +size_t gmrf_iface_get_mtu(gmrf_t *gmrf, gmrf_iface_t *iface) { return iface->net->mtu; } -static void enqueue(mmss_context_t *ctx, gmrf_iface_t *source, gmrf_iface_t *dest, const void *data, size_t len) { +static void enqueue(mmss_t *mmss, gmrf_iface_t *source, gmrf_iface_t *dest, const void *data, size_t len) { mmss_packet_t *packet = calloc(1, sizeof(mmss_packet_t) + len); - packet->sent = ctx->now; + packet->sent = mmss->now; packet->source = source; packet->dest = dest; packet->len = len; memcpy(packet->data, data, len); - mmss_queue_put(ctx, &ctx->packet_queue, packet, ctx->now+1); + mmss_queue_put(mmss, &mmss->packet_queue, packet, mmss->now+1); } -bool gmrf_iface_send(gmrf_context_t *ctx, gmrf_iface_t *iface, const void *data, size_t len, const gmrf_addr_t *dest) { +bool gmrf_iface_send(gmrf_t *gmrf, gmrf_iface_t *iface, const void *data, size_t len, const gmrf_addr_t *dest) { gmrf_iface_t *dest_iface; for (dest_iface = iface->net->interfaces; dest_iface; dest_iface = dest_iface->network_next) { if (gmrf_addr_equal(&dest_iface->address, dest)) { - enqueue(ctx->mmss, iface, dest_iface, data, len); + enqueue(gmrf->mmss, iface, dest_iface, data, len); break; } } @@ -61,10 +61,10 @@ bool gmrf_iface_send(gmrf_context_t *ctx, gmrf_iface_t *iface, const void *data, return true; } -bool gmrf_iface_send_bc(gmrf_context_t *ctx, gmrf_iface_t *iface, const void *data, size_t len) { +bool gmrf_iface_send_bc(gmrf_t *gmrf, gmrf_iface_t *iface, const void *data, size_t len) { gmrf_iface_t *dest_iface; for (dest_iface = iface->net->interfaces; dest_iface; dest_iface = dest_iface->network_next) - enqueue(ctx->mmss, iface, dest_iface, data, len); + enqueue(gmrf->mmss, iface, dest_iface, data, len); return true; } |