diff options
author | Omar Tarabai <tarabai@devegypt.com> | 2014-07-14 17:40:32 +0000 |
---|---|---|
committer | Omar Tarabai <tarabai@devegypt.com> | 2014-07-14 17:40:32 +0000 |
commit | 600e56e89d1d1fc7417e8be20c40e197c9d58b2a (patch) | |
tree | 7191cb9f3e2c64fa1c6f78dee49f79d442249c37 /src/fs/gnunet-service-fs.c | |
parent | c937c2c64700475cc04e7ee3d912bd9dff7e33b2 (diff) | |
download | gnunet-600e56e89d1d1fc7417e8be20c40e197c9d58b2a.tar.gz gnunet-600e56e89d1d1fc7417e8be20c40e197c9d58b2a.zip |
fs now uses peerstore to store respect value
Diffstat (limited to 'src/fs/gnunet-service-fs.c')
-rw-r--r-- | src/fs/gnunet-service-fs.c | 22 |
1 files changed, 16 insertions, 6 deletions
diff --git a/src/fs/gnunet-service-fs.c b/src/fs/gnunet-service-fs.c index a9be40080..b824e6dc6 100644 --- a/src/fs/gnunet-service-fs.c +++ b/src/fs/gnunet-service-fs.c | |||
@@ -552,6 +552,21 @@ consider_peer_for_forwarding (void *cls, const struct GNUNET_HashCode * key, | |||
552 | 552 | ||
553 | 553 | ||
554 | /** | 554 | /** |
555 | * Function called after the creation of a connected peer record is complete. | ||
556 | * | ||
557 | * @param cls closure (unused) | ||
558 | * @param cp handle to the newly created connected peer record | ||
559 | */ | ||
560 | static void | ||
561 | connected_peer_cb (void *cls, struct GSF_ConnectedPeer *cp) | ||
562 | { | ||
563 | if (NULL == cp) | ||
564 | return; | ||
565 | GSF_iterate_pending_requests_ (&consider_peer_for_forwarding, cp); | ||
566 | } | ||
567 | |||
568 | |||
569 | /** | ||
555 | * Method called whenever a given peer connects. | 570 | * Method called whenever a given peer connects. |
556 | * | 571 | * |
557 | * @param cls closure, not used | 572 | * @param cls closure, not used |
@@ -560,14 +575,9 @@ consider_peer_for_forwarding (void *cls, const struct GNUNET_HashCode * key, | |||
560 | static void | 575 | static void |
561 | peer_connect_handler (void *cls, const struct GNUNET_PeerIdentity *peer) | 576 | peer_connect_handler (void *cls, const struct GNUNET_PeerIdentity *peer) |
562 | { | 577 | { |
563 | struct GSF_ConnectedPeer *cp; | ||
564 | |||
565 | if (0 == memcmp (&my_id, peer, sizeof (struct GNUNET_PeerIdentity))) | 578 | if (0 == memcmp (&my_id, peer, sizeof (struct GNUNET_PeerIdentity))) |
566 | return; | 579 | return; |
567 | cp = GSF_peer_connect_handler_ (peer); | 580 | GSF_peer_connect_handler_ (peer, &connected_peer_cb, NULL); |
568 | if (NULL == cp) | ||
569 | return; | ||
570 | GSF_iterate_pending_requests_ (&consider_peer_for_forwarding, cp); | ||
571 | } | 581 | } |
572 | 582 | ||
573 | 583 | ||