diff options
author | Christian Grothoff <christian@grothoff.org> | 2013-09-30 21:03:31 +0000 |
---|---|---|
committer | Christian Grothoff <christian@grothoff.org> | 2013-09-30 21:03:31 +0000 |
commit | 6d5b099541c60303b664547f18f4aaa864e33d68 (patch) | |
tree | 3169f571d3f66ec23ab540d17c012f00103688f2 /src/core/gnunet-service-core_sessions.c | |
parent | a0ba5b741b56036bd35bd9ba88164324b2ff7ada (diff) | |
download | gnunet-6d5b099541c60303b664547f18f4aaa864e33d68.tar.gz gnunet-6d5b099541c60303b664547f18f4aaa864e33d68.zip |
-getting core, nse, testbed, ats-tool and peerinfo-tool to compile again (part of #3047)
Diffstat (limited to 'src/core/gnunet-service-core_sessions.c')
-rw-r--r-- | src/core/gnunet-service-core_sessions.c | 35 |
1 files changed, 17 insertions, 18 deletions
diff --git a/src/core/gnunet-service-core_sessions.c b/src/core/gnunet-service-core_sessions.c index f1a53bee8..6c66086bd 100644 --- a/src/core/gnunet-service-core_sessions.c +++ b/src/core/gnunet-service-core_sessions.c | |||
@@ -147,7 +147,7 @@ struct Session | |||
147 | /** | 147 | /** |
148 | * Map of peer identities to 'struct Session'. | 148 | * Map of peer identities to 'struct Session'. |
149 | */ | 149 | */ |
150 | static struct GNUNET_CONTAINER_MultiHashMap *sessions; | 150 | static struct GNUNET_CONTAINER_MultiPeerMap *sessions; |
151 | 151 | ||
152 | 152 | ||
153 | /** | 153 | /** |
@@ -160,7 +160,7 @@ static struct GNUNET_CONTAINER_MultiHashMap *sessions; | |||
160 | static struct Session * | 160 | static struct Session * |
161 | find_session (const struct GNUNET_PeerIdentity *peer) | 161 | find_session (const struct GNUNET_PeerIdentity *peer) |
162 | { | 162 | { |
163 | return GNUNET_CONTAINER_multihashmap_get (sessions, &peer->hashPubKey); | 163 | return GNUNET_CONTAINER_multipeermap_get (sessions, peer); |
164 | } | 164 | } |
165 | 165 | ||
166 | 166 | ||
@@ -202,12 +202,11 @@ GSC_SESSIONS_end (const struct GNUNET_PeerIdentity *pid) | |||
202 | GSC_CLIENTS_notify_clients_about_neighbour (&session->peer, | 202 | GSC_CLIENTS_notify_clients_about_neighbour (&session->peer, |
203 | session->tmap, NULL); | 203 | session->tmap, NULL); |
204 | GNUNET_assert (GNUNET_YES == | 204 | GNUNET_assert (GNUNET_YES == |
205 | GNUNET_CONTAINER_multihashmap_remove (sessions, | 205 | GNUNET_CONTAINER_multipeermap_remove (sessions, |
206 | &session-> | 206 | &session->peer, |
207 | peer.hashPubKey, | ||
208 | session)); | 207 | session)); |
209 | GNUNET_STATISTICS_set (GSC_stats, gettext_noop ("# peers connected"), | 208 | GNUNET_STATISTICS_set (GSC_stats, gettext_noop ("# peers connected"), |
210 | GNUNET_CONTAINER_multihashmap_size (sessions), | 209 | GNUNET_CONTAINER_multipeermap_size (sessions), |
211 | GNUNET_NO); | 210 | GNUNET_NO); |
212 | GSC_TYPEMAP_destroy (session->tmap); | 211 | GSC_TYPEMAP_destroy (session->tmap); |
213 | session->tmap = NULL; | 212 | session->tmap = NULL; |
@@ -273,11 +272,11 @@ GSC_SESSIONS_create (const struct GNUNET_PeerIdentity *peer, | |||
273 | session->typemap_task = | 272 | session->typemap_task = |
274 | GNUNET_SCHEDULER_add_now (&transmit_typemap_task, session); | 273 | GNUNET_SCHEDULER_add_now (&transmit_typemap_task, session); |
275 | GNUNET_assert (GNUNET_OK == | 274 | GNUNET_assert (GNUNET_OK == |
276 | GNUNET_CONTAINER_multihashmap_put (sessions, &peer->hashPubKey, | 275 | GNUNET_CONTAINER_multipeermap_put (sessions, peer, |
277 | session, | 276 | session, |
278 | GNUNET_CONTAINER_MULTIHASHMAPOPTION_UNIQUE_ONLY)); | 277 | GNUNET_CONTAINER_MULTIHASHMAPOPTION_UNIQUE_ONLY)); |
279 | GNUNET_STATISTICS_set (GSC_stats, gettext_noop ("# peers connected"), | 278 | GNUNET_STATISTICS_set (GSC_stats, gettext_noop ("# peers connected"), |
280 | GNUNET_CONTAINER_multihashmap_size (sessions), | 279 | GNUNET_CONTAINER_multipeermap_size (sessions), |
281 | GNUNET_NO); | 280 | GNUNET_NO); |
282 | GSC_CLIENTS_notify_clients_about_neighbour (peer, | 281 | GSC_CLIENTS_notify_clients_about_neighbour (peer, |
283 | NULL, session->tmap); | 282 | NULL, session->tmap); |
@@ -293,7 +292,7 @@ GSC_SESSIONS_create (const struct GNUNET_PeerIdentity *peer, | |||
293 | * @return GNUNET_OK (continue to iterate) | 292 | * @return GNUNET_OK (continue to iterate) |
294 | */ | 293 | */ |
295 | static int | 294 | static int |
296 | notify_client_about_session (void *cls, const struct GNUNET_HashCode * key, | 295 | notify_client_about_session (void *cls, const struct GNUNET_PeerIdentity * key, |
297 | void *value) | 296 | void *value) |
298 | { | 297 | { |
299 | struct GSC_Client *client = cls; | 298 | struct GSC_Client *client = cls; |
@@ -315,7 +314,7 @@ void | |||
315 | GSC_SESSIONS_notify_client_about_sessions (struct GSC_Client *client) | 314 | GSC_SESSIONS_notify_client_about_sessions (struct GSC_Client *client) |
316 | { | 315 | { |
317 | /* notify new client about existing sessions */ | 316 | /* notify new client about existing sessions */ |
318 | GNUNET_CONTAINER_multihashmap_iterate (sessions, ¬ify_client_about_session, | 317 | GNUNET_CONTAINER_multipeermap_iterate (sessions, ¬ify_client_about_session, |
319 | client); | 318 | client); |
320 | } | 319 | } |
321 | 320 | ||
@@ -559,7 +558,7 @@ try_transmission (struct Session *session) | |||
559 | * @return always GNUNET_OK | 558 | * @return always GNUNET_OK |
560 | */ | 559 | */ |
561 | static int | 560 | static int |
562 | do_send_message (void *cls, const struct GNUNET_HashCode * key, void *value) | 561 | do_send_message (void *cls, const struct GNUNET_PeerIdentity * key, void *value) |
563 | { | 562 | { |
564 | const struct GNUNET_MessageHeader *hdr = cls; | 563 | const struct GNUNET_MessageHeader *hdr = cls; |
565 | struct Session *session = value; | 564 | struct Session *session = value; |
@@ -586,7 +585,7 @@ GSC_SESSIONS_broadcast (const struct GNUNET_MessageHeader *msg) | |||
586 | { | 585 | { |
587 | if (NULL == sessions) | 586 | if (NULL == sessions) |
588 | return; | 587 | return; |
589 | GNUNET_CONTAINER_multihashmap_iterate (sessions, &do_send_message, | 588 | GNUNET_CONTAINER_multipeermap_iterate (sessions, &do_send_message, |
590 | (void *) msg); | 589 | (void *) msg); |
591 | } | 590 | } |
592 | 591 | ||
@@ -652,7 +651,7 @@ GSC_SESSIONS_transmit (struct GSC_ClientActiveRequest *car, | |||
652 | */ | 651 | */ |
653 | #include "core.h" | 652 | #include "core.h" |
654 | static int | 653 | static int |
655 | queue_connect_message (void *cls, const struct GNUNET_HashCode * key, void *value) | 654 | queue_connect_message (void *cls, const struct GNUNET_PeerIdentity * key, void *value) |
656 | { | 655 | { |
657 | struct GNUNET_SERVER_TransmitContext *tc = cls; | 656 | struct GNUNET_SERVER_TransmitContext *tc = cls; |
658 | struct Session *session = value; | 657 | struct Session *session = value; |
@@ -687,7 +686,7 @@ GSC_SESSIONS_handle_client_iterate_peers (void *cls, | |||
687 | struct GNUNET_SERVER_TransmitContext *tc; | 686 | struct GNUNET_SERVER_TransmitContext *tc; |
688 | 687 | ||
689 | tc = GNUNET_SERVER_transmit_context_create (client); | 688 | tc = GNUNET_SERVER_transmit_context_create (client); |
690 | GNUNET_CONTAINER_multihashmap_iterate (sessions, &queue_connect_message, tc); | 689 | GNUNET_CONTAINER_multipeermap_iterate (sessions, &queue_connect_message, tc); |
691 | done_msg.size = htons (sizeof (struct GNUNET_MessageHeader)); | 690 | done_msg.size = htons (sizeof (struct GNUNET_MessageHeader)); |
692 | done_msg.type = htons (GNUNET_MESSAGE_TYPE_CORE_ITERATE_PEERS_END); | 691 | done_msg.type = htons (GNUNET_MESSAGE_TYPE_CORE_ITERATE_PEERS_END); |
693 | GNUNET_SERVER_transmit_context_append_message (tc, &done_msg); | 692 | GNUNET_SERVER_transmit_context_append_message (tc, &done_msg); |
@@ -760,7 +759,7 @@ GSC_SESSIONS_add_to_typemap (const struct GNUNET_PeerIdentity *peer, | |||
760 | void | 759 | void |
761 | GSC_SESSIONS_init () | 760 | GSC_SESSIONS_init () |
762 | { | 761 | { |
763 | sessions = GNUNET_CONTAINER_multihashmap_create (128, GNUNET_NO); | 762 | sessions = GNUNET_CONTAINER_multipeermap_create (128, GNUNET_NO); |
764 | } | 763 | } |
765 | 764 | ||
766 | 765 | ||
@@ -773,7 +772,7 @@ GSC_SESSIONS_init () | |||
773 | * @return GNUNET_OK (continue to iterate) | 772 | * @return GNUNET_OK (continue to iterate) |
774 | */ | 773 | */ |
775 | static int | 774 | static int |
776 | free_session_helper (void *cls, const struct GNUNET_HashCode * key, void *value) | 775 | free_session_helper (void *cls, const struct GNUNET_PeerIdentity * key, void *value) |
777 | { | 776 | { |
778 | struct Session *session = value; | 777 | struct Session *session = value; |
779 | 778 | ||
@@ -790,8 +789,8 @@ GSC_SESSIONS_done () | |||
790 | { | 789 | { |
791 | if (NULL != sessions) | 790 | if (NULL != sessions) |
792 | { | 791 | { |
793 | GNUNET_CONTAINER_multihashmap_iterate (sessions, &free_session_helper, NULL); | 792 | GNUNET_CONTAINER_multipeermap_iterate (sessions, &free_session_helper, NULL); |
794 | GNUNET_CONTAINER_multihashmap_destroy (sessions); | 793 | GNUNET_CONTAINER_multipeermap_destroy (sessions); |
795 | sessions = NULL; | 794 | sessions = NULL; |
796 | } | 795 | } |
797 | } | 796 | } |