aboutsummaryrefslogtreecommitdiff
path: root/src/ats/gnunet-service-ats_addresses.c
diff options
context:
space:
mode:
authorMatthias Wachs <wachs@net.in.tum.de>2013-06-25 09:58:00 +0000
committerMatthias Wachs <wachs@net.in.tum.de>2013-06-25 09:58:00 +0000
commitefecad9df3e8847f45a4284ec717c32260460adc (patch)
tree703aab4408f54e4933869252406a3f4f77ccb9d4 /src/ats/gnunet-service-ats_addresses.c
parentc83d77d730a4ae94dff88ec0c6801fde14490f65 (diff)
downloadgnunet-efecad9df3e8847f45a4284ec717c32260460adc.tar.gz
gnunet-efecad9df3e8847f45a4284ec717c32260460adc.zip
completed normalizing with min max handlin
Diffstat (limited to 'src/ats/gnunet-service-ats_addresses.c')
-rw-r--r--src/ats/gnunet-service-ats_addresses.c8
1 files changed, 4 insertions, 4 deletions
diff --git a/src/ats/gnunet-service-ats_addresses.c b/src/ats/gnunet-service-ats_addresses.c
index 03400136a..f32c6a7c9 100644
--- a/src/ats/gnunet-service-ats_addresses.c
+++ b/src/ats/gnunet-service-ats_addresses.c
@@ -532,7 +532,7 @@ create_address (const struct GNUNET_PeerIdentity *peer,
532 532
533 for (c1 = 0; c1 < GNUNET_ATS_QualityPropertiesCount; c1 ++) 533 for (c1 = 0; c1 < GNUNET_ATS_QualityPropertiesCount; c1 ++)
534 { 534 {
535 aa->atsin[c1].index = 0; 535 aa->atsin[c1].avg_queue_index = 0;
536 for (c2 = 0; c2 < GAS_normalization_queue_length; c2++) 536 for (c2 = 0; c2 < GAS_normalization_queue_length; c2++)
537 aa->atsin[c1].atsi_abs[c2] = GNUNET_ATS_VALUE_UNDEFINED; 537 aa->atsin[c1].atsi_abs[c2] = GNUNET_ATS_VALUE_UNDEFINED;
538 } 538 }
@@ -809,7 +809,7 @@ GAS_addresses_add (struct GAS_Addresses_Handle *handle,
809 GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "Added new address for peer `%s' session id %u, %p\n", 809 GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "Added new address for peer `%s' session id %u, %p\n",
810 GNUNET_i2s (peer), session_id, aa); 810 GNUNET_i2s (peer), session_id, aa);
811 /* Tell solver about new address */ 811 /* Tell solver about new address */
812 GAS_normalization_normalize_property (aa, atsi, atsi_count); 812 GAS_normalization_normalize_property (handle->addresses, aa, atsi, atsi_count);
813 handle->s_add (handle->solver, handle->addresses, aa, addr_net); 813 handle->s_add (handle->solver, handle->addresses, aa, addr_net);
814 /* Notify performance clients about new address */ 814 /* Notify performance clients about new address */
815 GAS_performance_notify_all_clients (&aa->peer, 815 GAS_performance_notify_all_clients (&aa->peer,
@@ -853,7 +853,7 @@ GAS_addresses_add (struct GAS_Addresses_Handle *handle,
853 } 853 }
854 854
855 /* Notify solver about update with atsi information and session */ 855 /* Notify solver about update with atsi information and session */
856 GAS_normalization_normalize_property (ea, atsi, atsi_count); 856 GAS_normalization_normalize_property (handle->addresses, ea, atsi, atsi_count);
857 handle->s_update (handle->solver, handle->addresses, ea, session_id, ea->used, atsi_delta, atsi_delta_count); 857 handle->s_update (handle->solver, handle->addresses, ea, session_id, ea->used, atsi_delta, atsi_delta_count);
858 GNUNET_free_non_null (atsi_delta); 858 GNUNET_free_non_null (atsi_delta);
859 859
@@ -931,7 +931,7 @@ GAS_addresses_update (struct GAS_Addresses_Handle *handle,
931 prev_session = aa->session_id; 931 prev_session = aa->session_id;
932 aa->session_id = session_id; 932 aa->session_id = session_id;
933 933
934 GAS_normalization_normalize_property (aa, atsi, atsi_count); 934 GAS_normalization_normalize_property (handle->addresses, aa, atsi, atsi_count);
935 935
936 /* Tell solver about update */ 936 /* Tell solver about update */
937 handle->s_update (handle->solver, handle->addresses, aa, prev_session, aa->used, atsi_delta, atsi_delta_count); 937 handle->s_update (handle->solver, handle->addresses, aa, prev_session, aa->used, atsi_delta, atsi_delta_count);