From f0f1ce0017db9c6a06d1fdd8650ad01e11e8201b Mon Sep 17 00:00:00 2001 From: Christian Grothoff Date: Mon, 10 Oct 2011 08:02:30 +0000 Subject: [PATCH] core-new now compiles --- src/core/Makefile.am | 1 + src/core/gnunet-service-core_kx.c | 6 ++--- src/core/gnunet-service-core_sessions.c | 35 +++++++++++++++++++++++++ 3 files changed, 39 insertions(+), 3 deletions(-) diff --git a/src/core/Makefile.am b/src/core/Makefile.am index 65883d537..9c559f764 100644 --- a/src/core/Makefile.am +++ b/src/core/Makefile.am @@ -26,6 +26,7 @@ libgnunetcore_la_LDFLAGS = \ bin_PROGRAMS = \ gnunet-service-core \ + gnunet-service-core-new \ gnunet-core-list-connections gnunet_service_core_SOURCES = \ diff --git a/src/core/gnunet-service-core_kx.c b/src/core/gnunet-service-core_kx.c index 6c9e9437a..5c3098194 100644 --- a/src/core/gnunet-service-core_kx.c +++ b/src/core/gnunet-service-core_kx.c @@ -737,7 +737,7 @@ GSC_KX_handle_set_key (struct GSC_KeyExchangeInfo *kx, if (kx->public_key == NULL) { GNUNET_free_non_null (kx->skm_received); - kx->skm_received = GNUNET_copy_message (msg); + kx->skm_received = (struct SetKeyMessage*) GNUNET_copy_message (msg); return; } if (0 != @@ -866,7 +866,7 @@ GSC_KX_handle_ping (struct GSC_KeyExchangeInfo *kx, { /* defer */ GNUNET_free_non_null (kx->ping_received); - kx->ping_received = GNUNET_copy_message (msg); + kx->ping_received = (struct PingMessage*) GNUNET_copy_message (msg); return; } m = (const struct PingMessage*) msg; @@ -1065,7 +1065,7 @@ GSC_KX_handle_pong (struct GSC_KeyExchangeInfo *kx, const struct GNUNET_MessageH if (kx->status == KX_STATE_KEY_SENT) { GNUNET_free_non_null (kx->pong_received); - kx->pong_received = GNUNET_copy_message (msg); + kx->pong_received = (struct PongMessage*) GNUNET_copy_message (msg); } return; } diff --git a/src/core/gnunet-service-core_sessions.c b/src/core/gnunet-service-core_sessions.c index 6e1494373..93f9b6950 100644 --- a/src/core/gnunet-service-core_sessions.c +++ b/src/core/gnunet-service-core_sessions.c @@ -121,6 +121,41 @@ struct Session */ GNUNET_SCHEDULER_TaskIdentifier cork_task; + /** + * Tracking bandwidth for sending to this peer. + * // FIXME: unused! should it be used? + */ + struct GNUNET_BANDWIDTH_Tracker available_send_window; + + /** + * Tracking bandwidth for receiving from this peer. + * // FIXME: need to set it! + */ + struct GNUNET_BANDWIDTH_Tracker available_recv_window; + + /** + * Available bandwidth out for this peer (current target). + * // FIXME: check usage! + */ + struct GNUNET_BANDWIDTH_Value32NBO bw_out; + + /** + * Internal bandwidth limit set for this peer (initially typically + * set to "-1"). Actual "bw_out" is MIN of + * "bpm_out_internal_limit" and "bw_out_external_limit". + * // FIXME: check usage + */ + struct GNUNET_BANDWIDTH_Value32NBO bw_out_internal_limit; + + /** + * External bandwidth limit set for this peer by the + * peer that we are communicating with. "bw_out" is MIN of + * "bw_out_internal_limit" and "bw_out_external_limit". + * // FIXME: check usage + */ + struct GNUNET_BANDWIDTH_Value32NBO bw_out_external_limit; + + /** * Is the neighbour queue empty and thus ready for us * to transmit an encrypted message? -- 2.25.1