diff options
author | Matthias Wachs <wachs@net.in.tum.de> | 2014-03-26 10:54:04 +0000 |
---|---|---|
committer | Matthias Wachs <wachs@net.in.tum.de> | 2014-03-26 10:54:04 +0000 |
commit | c279072752d3c79a0550c489e944b5ab7d270266 (patch) | |
tree | 6579c1719d41d5eae6ce649aba5ca2a62e649b2b /src/transport/gnunet-service-transport_neighbours.c | |
parent | 37391a04e13e7380085ea5fc5fa228e33761ed7b (diff) | |
download | gnunet-c279072752d3c79a0550c489e944b5ab7d270266.tar.gz gnunet-c279072752d3c79a0550c489e944b5ab7d270266.zip |
removing blacklist state not required anymore
Diffstat (limited to 'src/transport/gnunet-service-transport_neighbours.c')
-rw-r--r-- | src/transport/gnunet-service-transport_neighbours.c | 64 |
1 files changed, 9 insertions, 55 deletions
diff --git a/src/transport/gnunet-service-transport_neighbours.c b/src/transport/gnunet-service-transport_neighbours.c index 258967261..5cdeb621a 100644 --- a/src/transport/gnunet-service-transport_neighbours.c +++ b/src/transport/gnunet-service-transport_neighbours.c | |||
@@ -1095,7 +1095,6 @@ disconnect_neighbour (struct NeighbourMapEntry *n) | |||
1095 | send_disconnect (n); | 1095 | send_disconnect (n); |
1096 | set_state (n, GNUNET_TRANSPORT_PS_DISCONNECT); | 1096 | set_state (n, GNUNET_TRANSPORT_PS_DISCONNECT); |
1097 | break; | 1097 | break; |
1098 | case GNUNET_TRANSPORT_PS_CONNECT_RECV_BLACKLIST_INBOUND: | ||
1099 | case GNUNET_TRANSPORT_PS_CONNECT_RECV_ATS: | 1098 | case GNUNET_TRANSPORT_PS_CONNECT_RECV_ATS: |
1100 | case GNUNET_TRANSPORT_PS_CONNECT_RECV_BLACKLIST: | 1099 | case GNUNET_TRANSPORT_PS_CONNECT_RECV_BLACKLIST: |
1101 | /* we never ACK'ed the other peer's request, no need to send DISCONNECT */ | 1100 | /* we never ACK'ed the other peer's request, no need to send DISCONNECT */ |
@@ -2203,7 +2202,6 @@ GST_neighbours_try_connect (const struct GNUNET_PeerIdentity *target) | |||
2203 | break; | 2202 | break; |
2204 | case GNUNET_TRANSPORT_PS_INIT_ATS: | 2203 | case GNUNET_TRANSPORT_PS_INIT_ATS: |
2205 | case GNUNET_TRANSPORT_PS_CONNECT_SENT: | 2204 | case GNUNET_TRANSPORT_PS_CONNECT_SENT: |
2206 | case GNUNET_TRANSPORT_PS_CONNECT_RECV_BLACKLIST_INBOUND: | ||
2207 | case GNUNET_TRANSPORT_PS_CONNECT_RECV_ATS: | 2205 | case GNUNET_TRANSPORT_PS_CONNECT_RECV_ATS: |
2208 | case GNUNET_TRANSPORT_PS_CONNECT_RECV_BLACKLIST: | 2206 | case GNUNET_TRANSPORT_PS_CONNECT_RECV_BLACKLIST: |
2209 | case GNUNET_TRANSPORT_PS_CONNECT_RECV_ACK: | 2207 | case GNUNET_TRANSPORT_PS_CONNECT_RECV_ACK: |
@@ -2327,34 +2325,6 @@ handle_connect_blacklist_check_cont (void *cls, | |||
2327 | } | 2325 | } |
2328 | #endif | 2326 | #endif |
2329 | break; | 2327 | break; |
2330 | case GNUNET_TRANSPORT_PS_CONNECT_RECV_BLACKLIST_INBOUND: | ||
2331 | if (GNUNET_OK == result) | ||
2332 | { | ||
2333 | /* We received a connect request and blacklist allowed to communicate | ||
2334 | * with this peer, request an address from ATS*/ | ||
2335 | set_state_and_timeout (n, GNUNET_TRANSPORT_PS_CONNECT_RECV_ATS, | ||
2336 | GNUNET_TIME_relative_to_absolute (ATS_RESPONSE_TIMEOUT)); | ||
2337 | |||
2338 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, | ||
2339 | "Requesting address for peer %s to ATS\n", | ||
2340 | GNUNET_i2s (peer)); | ||
2341 | if (NULL == n->suggest_handle) | ||
2342 | n->suggest_handle = GNUNET_ATS_suggest_address (GST_ats, peer, | ||
2343 | &address_suggest_cont, n); | ||
2344 | GNUNET_ATS_reset_backoff (GST_ats, peer); | ||
2345 | } | ||
2346 | else | ||
2347 | { | ||
2348 | /* We received a CONNECT message from a peer, but blacklist denies to | ||
2349 | * communicate with this peer and this address | ||
2350 | * - Previous state: NOT_CONNECTED: | ||
2351 | * We can free the neighbour, since the CONNECT created it | ||
2352 | * - Previous state INIT_ATS: | ||
2353 | * | ||
2354 | * */ | ||
2355 | free_neighbour (n, GNUNET_NO); | ||
2356 | } | ||
2357 | break; | ||
2358 | case GNUNET_TRANSPORT_PS_CONNECT_RECV_ATS: | 2328 | case GNUNET_TRANSPORT_PS_CONNECT_RECV_ATS: |
2359 | /* waiting on ATS suggestion, don't care about blacklist */ | 2329 | /* waiting on ATS suggestion, don't care about blacklist */ |
2360 | break; | 2330 | break; |
@@ -2603,19 +2573,19 @@ GST_neighbours_handle_connect (const struct GNUNET_MessageHeader *message, | |||
2603 | switch (n->state) | 2573 | switch (n->state) |
2604 | { | 2574 | { |
2605 | case GNUNET_TRANSPORT_PS_NOT_CONNECTED: | 2575 | case GNUNET_TRANSPORT_PS_NOT_CONNECTED: |
2606 | /* Check if we are allowed to connect with this peer and this address */ | 2576 | /* Request an address from ATS to send CONNECT_ACK to this peer */ |
2607 | set_state_and_timeout (n, GNUNET_TRANSPORT_PS_CONNECT_RECV_BLACKLIST_INBOUND, | 2577 | set_state_and_timeout (n, GNUNET_TRANSPORT_PS_CONNECT_RECV_ATS, |
2608 | GNUNET_TIME_relative_to_absolute (BLACKLIST_RESPONSE_TIMEOUT)); | 2578 | GNUNET_TIME_relative_to_absolute (ATS_RESPONSE_TIMEOUT)); |
2609 | connect_check_blacklist (peer, ts, address, session); | 2579 | if (NULL == n->suggest_handle) |
2580 | GNUNET_ATS_suggest_address (GST_ats, peer, address_suggest_cont, n); | ||
2610 | break; | 2581 | break; |
2611 | case GNUNET_TRANSPORT_PS_INIT_ATS: | 2582 | case GNUNET_TRANSPORT_PS_INIT_ATS: |
2612 | /* CONNECT message takes priority over us asking ATS for address */ | 2583 | /* CONNECT message takes priority over us asking ATS for address: |
2613 | set_state_and_timeout (n, GNUNET_TRANSPORT_PS_CONNECT_RECV_BLACKLIST_INBOUND, | 2584 | * Wait for ATS to suggest an address and send CONNECT_ACK */ |
2614 | GNUNET_TIME_relative_to_absolute (BLACKLIST_RESPONSE_TIMEOUT)); | 2585 | set_state_and_timeout (n, GNUNET_TRANSPORT_PS_CONNECT_RECV_ATS, |
2615 | connect_check_blacklist (peer, ts, address, session); | 2586 | GNUNET_TIME_relative_to_absolute (ATS_RESPONSE_TIMEOUT)); |
2616 | break; | 2587 | break; |
2617 | case GNUNET_TRANSPORT_PS_CONNECT_SENT: | 2588 | case GNUNET_TRANSPORT_PS_CONNECT_SENT: |
2618 | case GNUNET_TRANSPORT_PS_CONNECT_RECV_BLACKLIST_INBOUND: | ||
2619 | case GNUNET_TRANSPORT_PS_CONNECT_RECV_ATS: | 2589 | case GNUNET_TRANSPORT_PS_CONNECT_RECV_ATS: |
2620 | case GNUNET_TRANSPORT_PS_CONNECT_RECV_BLACKLIST: | 2590 | case GNUNET_TRANSPORT_PS_CONNECT_RECV_BLACKLIST: |
2621 | case GNUNET_TRANSPORT_PS_CONNECT_RECV_ACK: | 2591 | case GNUNET_TRANSPORT_PS_CONNECT_RECV_ACK: |
@@ -2793,9 +2763,6 @@ switch_address_bl_check_cont (void *cls, | |||
2793 | GNUNET_TIME_relative_to_absolute (SETUP_CONNECTION_TIMEOUT)); | 2763 | GNUNET_TIME_relative_to_absolute (SETUP_CONNECTION_TIMEOUT)); |
2794 | send_session_connect (&n->primary_address); | 2764 | send_session_connect (&n->primary_address); |
2795 | break; | 2765 | break; |
2796 | case GNUNET_TRANSPORT_PS_CONNECT_RECV_BLACKLIST_INBOUND: | ||
2797 | /* We received an suggestion while waiting for a CONNECT blacklist check, | ||
2798 | * this suggestion was permitted by a blacklist check, so send ACK*/ | ||
2799 | case GNUNET_TRANSPORT_PS_CONNECT_RECV_ATS: | 2766 | case GNUNET_TRANSPORT_PS_CONNECT_RECV_ATS: |
2800 | /* We requested an address and ATS suggests one: | 2767 | /* We requested an address and ATS suggests one: |
2801 | * set primary address and send CONNECT_ACK message*/ | 2768 | * set primary address and send CONNECT_ACK message*/ |
@@ -3219,16 +3186,6 @@ master_task (void *cls, | |||
3219 | return; | 3186 | return; |
3220 | } | 3187 | } |
3221 | break; | 3188 | break; |
3222 | case GNUNET_TRANSPORT_PS_CONNECT_RECV_BLACKLIST_INBOUND: | ||
3223 | if (0 == delay.rel_value_us) | ||
3224 | { | ||
3225 | GNUNET_log (GNUNET_ERROR_TYPE_INFO, | ||
3226 | "Connection to `%s' timed out waiting BLACKLIST to approve address to use for received CONNECT\n", | ||
3227 | GNUNET_i2s (&n->id)); | ||
3228 | free_neighbour (n, GNUNET_NO); | ||
3229 | return; | ||
3230 | } | ||
3231 | break; | ||
3232 | case GNUNET_TRANSPORT_PS_CONNECT_RECV_ATS: | 3189 | case GNUNET_TRANSPORT_PS_CONNECT_RECV_ATS: |
3233 | if (0 == delay.rel_value_us) | 3190 | if (0 == delay.rel_value_us) |
3234 | { | 3191 | { |
@@ -3464,7 +3421,6 @@ GST_neighbours_handle_connect_ack (const struct GNUNET_MessageHeader *message, | |||
3464 | GNUNET_YES); | 3421 | GNUNET_YES); |
3465 | send_session_ack_message (n); | 3422 | send_session_ack_message (n); |
3466 | break; | 3423 | break; |
3467 | case GNUNET_TRANSPORT_PS_CONNECT_RECV_BLACKLIST_INBOUND: | ||
3468 | case GNUNET_TRANSPORT_PS_CONNECT_RECV_ATS: | 3424 | case GNUNET_TRANSPORT_PS_CONNECT_RECV_ATS: |
3469 | case GNUNET_TRANSPORT_PS_CONNECT_RECV_BLACKLIST: | 3425 | case GNUNET_TRANSPORT_PS_CONNECT_RECV_BLACKLIST: |
3470 | case GNUNET_TRANSPORT_PS_CONNECT_RECV_ACK: | 3426 | case GNUNET_TRANSPORT_PS_CONNECT_RECV_ACK: |
@@ -3605,7 +3561,6 @@ GST_neighbours_session_terminated (const struct GNUNET_PeerIdentity *peer, | |||
3605 | set_state_and_timeout (n, GNUNET_TRANSPORT_PS_INIT_ATS, | 3561 | set_state_and_timeout (n, GNUNET_TRANSPORT_PS_INIT_ATS, |
3606 | GNUNET_TIME_relative_to_absolute (ATS_RESPONSE_TIMEOUT)); | 3562 | GNUNET_TIME_relative_to_absolute (ATS_RESPONSE_TIMEOUT)); |
3607 | break; | 3563 | break; |
3608 | case GNUNET_TRANSPORT_PS_CONNECT_RECV_BLACKLIST_INBOUND: | ||
3609 | case GNUNET_TRANSPORT_PS_CONNECT_RECV_ATS: | 3564 | case GNUNET_TRANSPORT_PS_CONNECT_RECV_ATS: |
3610 | case GNUNET_TRANSPORT_PS_CONNECT_RECV_BLACKLIST: | 3565 | case GNUNET_TRANSPORT_PS_CONNECT_RECV_BLACKLIST: |
3611 | case GNUNET_TRANSPORT_PS_CONNECT_RECV_ACK: | 3566 | case GNUNET_TRANSPORT_PS_CONNECT_RECV_ACK: |
@@ -3994,7 +3949,6 @@ GST_neighbour_get_latency (const struct GNUNET_PeerIdentity *peer) | |||
3994 | return n->latency; | 3949 | return n->latency; |
3995 | case GNUNET_TRANSPORT_PS_NOT_CONNECTED: | 3950 | case GNUNET_TRANSPORT_PS_NOT_CONNECTED: |
3996 | case GNUNET_TRANSPORT_PS_INIT_ATS: | 3951 | case GNUNET_TRANSPORT_PS_INIT_ATS: |
3997 | case GNUNET_TRANSPORT_PS_CONNECT_RECV_BLACKLIST_INBOUND: | ||
3998 | case GNUNET_TRANSPORT_PS_CONNECT_RECV_ATS: | 3952 | case GNUNET_TRANSPORT_PS_CONNECT_RECV_ATS: |
3999 | case GNUNET_TRANSPORT_PS_CONNECT_RECV_BLACKLIST: | 3953 | case GNUNET_TRANSPORT_PS_CONNECT_RECV_BLACKLIST: |
4000 | case GNUNET_TRANSPORT_PS_CONNECT_RECV_ACK: | 3954 | case GNUNET_TRANSPORT_PS_CONNECT_RECV_ACK: |