aboutsummaryrefslogtreecommitdiff
path: root/src/transport/gnunet-service-transport_neighbours.c
diff options
context:
space:
mode:
authorMatthias Wachs <wachs@net.in.tum.de>2014-03-26 10:54:04 +0000
committerMatthias Wachs <wachs@net.in.tum.de>2014-03-26 10:54:04 +0000
commitc279072752d3c79a0550c489e944b5ab7d270266 (patch)
tree6579c1719d41d5eae6ce649aba5ca2a62e649b2b /src/transport/gnunet-service-transport_neighbours.c
parent37391a04e13e7380085ea5fc5fa228e33761ed7b (diff)
downloadgnunet-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.c64
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: