aboutsummaryrefslogtreecommitdiff
path: root/src/psyc
diff options
context:
space:
mode:
authorGabor X Toth <*@tg-x.net>2015-09-26 17:10:17 +0000
committerGabor X Toth <*@tg-x.net>2015-09-26 17:10:17 +0000
commit0219647545ddc7c66dcab13414541cf57d792618 (patch)
tree40b99ee9f9b042828a28c7b27b22be4bf000f443 /src/psyc
parentf5a9bac85b73508da6794e1171b857e2582c8216 (diff)
downloadgnunet-0219647545ddc7c66dcab13414541cf57d792618.tar.gz
gnunet-0219647545ddc7c66dcab13414541cf57d792618.zip
multicast: removed membership test callback as clients check that already during join & replay
Diffstat (limited to 'src/psyc')
-rw-r--r--src/psyc/gnunet-service-psyc.c38
1 files changed, 0 insertions, 38 deletions
diff --git a/src/psyc/gnunet-service-psyc.c b/src/psyc/gnunet-service-psyc.c
index 36e3a7764..ceb0ca95b 100644
--- a/src/psyc/gnunet-service-psyc.c
+++ b/src/psyc/gnunet-service-psyc.c
@@ -826,41 +826,6 @@ mcast_recv_join_decision (void *cls, int is_admitted,
826} 826}
827 827
828 828
829/**
830 * Received result of GNUNET_PSYCSTORE_membership_test()
831 */
832static void
833store_recv_membership_test_result (void *cls, int64_t result,
834 const char *err_msg, uint16_t err_msg_size)
835{
836 struct GNUNET_MULTICAST_MembershipTestHandle *mth = cls;
837 GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
838 "%p GNUNET_PSYCSTORE_membership_test() returned %" PRId64 " (%.*s)\n",
839 mth, result, err_msg_size, err_msg);
840
841 GNUNET_MULTICAST_membership_test_result (mth, result);
842}
843
844
845/**
846 * Incoming membership test request from multicast.
847 */
848static void
849mcast_recv_membership_test (void *cls,
850 const struct GNUNET_CRYPTO_EcdsaPublicKey *slave_key,
851 uint64_t message_id, uint64_t group_generation,
852 struct GNUNET_MULTICAST_MembershipTestHandle *mth)
853{
854 struct Channel *chn = cls;
855 GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
856 "%p Received membership test request from multicast.\n",
857 mth);
858 GNUNET_PSYCSTORE_membership_test (store, &chn->pub_key, slave_key,
859 message_id, group_generation,
860 &store_recv_membership_test_result, mth);
861}
862
863
864static int 829static int
865store_recv_fragment_replay (void *cls, 830store_recv_fragment_replay (void *cls,
866 struct GNUNET_MULTICAST_MessageHeader *msg, 831 struct GNUNET_MULTICAST_MessageHeader *msg,
@@ -1617,7 +1582,6 @@ store_recv_master_counters (void *cls, int result, uint64_t max_fragment_id,
1617 mst->origin 1582 mst->origin
1618 = GNUNET_MULTICAST_origin_start (cfg, &mst->priv_key, max_fragment_id, 1583 = GNUNET_MULTICAST_origin_start (cfg, &mst->priv_key, max_fragment_id,
1619 mcast_recv_join_request, 1584 mcast_recv_join_request,
1620 mcast_recv_membership_test,
1621 mcast_recv_replay_fragment, 1585 mcast_recv_replay_fragment,
1622 mcast_recv_replay_message, 1586 mcast_recv_replay_message,
1623 mcast_recv_request, 1587 mcast_recv_request,
@@ -1665,7 +1629,6 @@ store_recv_slave_counters (void *cls, int result, uint64_t max_fragment_id,
1665 &slv->join_msg->header, 1629 &slv->join_msg->header,
1666 mcast_recv_join_request, 1630 mcast_recv_join_request,
1667 mcast_recv_join_decision, 1631 mcast_recv_join_decision,
1668 mcast_recv_membership_test,
1669 mcast_recv_replay_fragment, 1632 mcast_recv_replay_fragment,
1670 mcast_recv_replay_message, 1633 mcast_recv_replay_message,
1671 mcast_recv_message, chn); 1634 mcast_recv_message, chn);
@@ -1870,7 +1833,6 @@ client_recv_slave_join (void *cls, struct GNUNET_SERVER_Client *client,
1870 &slv->join_msg->header, 1833 &slv->join_msg->header,
1871 &mcast_recv_join_request, 1834 &mcast_recv_join_request,
1872 &mcast_recv_join_decision, 1835 &mcast_recv_join_decision,
1873 &mcast_recv_membership_test,
1874 &mcast_recv_replay_fragment, 1836 &mcast_recv_replay_fragment,
1875 &mcast_recv_replay_message, 1837 &mcast_recv_replay_message,
1876 &mcast_recv_message, chn); 1838 &mcast_recv_message, chn);