aboutsummaryrefslogtreecommitdiff
path: root/src/core/gnunet-service-core_sessions.c
diff options
context:
space:
mode:
authorChristian Grothoff <christian@grothoff.org>2013-09-30 21:03:31 +0000
committerChristian Grothoff <christian@grothoff.org>2013-09-30 21:03:31 +0000
commit6d5b099541c60303b664547f18f4aaa864e33d68 (patch)
tree3169f571d3f66ec23ab540d17c012f00103688f2 /src/core/gnunet-service-core_sessions.c
parenta0ba5b741b56036bd35bd9ba88164324b2ff7ada (diff)
downloadgnunet-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.c35
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 */
150static struct GNUNET_CONTAINER_MultiHashMap *sessions; 150static struct GNUNET_CONTAINER_MultiPeerMap *sessions;
151 151
152 152
153/** 153/**
@@ -160,7 +160,7 @@ static struct GNUNET_CONTAINER_MultiHashMap *sessions;
160static struct Session * 160static struct Session *
161find_session (const struct GNUNET_PeerIdentity *peer) 161find_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 */
295static int 294static int
296notify_client_about_session (void *cls, const struct GNUNET_HashCode * key, 295notify_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
315GSC_SESSIONS_notify_client_about_sessions (struct GSC_Client *client) 314GSC_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, &notify_client_about_session, 317 GNUNET_CONTAINER_multipeermap_iterate (sessions, &notify_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 */
561static int 560static int
562do_send_message (void *cls, const struct GNUNET_HashCode * key, void *value) 561do_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"
654static int 653static int
655queue_connect_message (void *cls, const struct GNUNET_HashCode * key, void *value) 654queue_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,
760void 759void
761GSC_SESSIONS_init () 760GSC_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 */
775static int 774static int
776free_session_helper (void *cls, const struct GNUNET_HashCode * key, void *value) 775free_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}