This file is part of GNUnet.
Copyright (C) 2010-2015 GNUnet e.V.
- GNUnet is free software; you can redistribute it and/or modify
- it under the terms of the GNU General Public License as published
- by the Free Software Foundation; either version 3, or (at your
- option) any later version.
+ GNUnet is free software: you can redistribute it and/or modify it
+ under the terms of the GNU Affero General Public License as published
+ by the Free Software Foundation, either version 3 of the License,
+ or (at your option) any later version.
GNUnet is distributed in the hope that it will be useful, but
WITHOUT ANY WARRANTY; without even the implied warranty of
MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
- General Public License for more details.
+ Affero General Public License for more details.
- You should have received a copy of the GNU General Public License
- along with GNUnet; see the file COPYING. If not, write to the
- Free Software Foundation, Inc., 51 Franklin Street, Fifth Floor,
- Boston, MA 02110-1301, USA.
+ You should have received a copy of the GNU Affero General Public License
+ along with this program. If not, see <http://www.gnu.org/licenses/>.
+
+ SPDX-License-Identifier: AGPL3.0-or-later
*/
/**
/**
- * Message we send to the other peer to notify him that we intentionally
+ * Message we send to the other peer to notify it that we intentionally
* are disconnecting (to reduce timeouts). This is just a friendly
* notification, peers must not rely on always receiving disconnect
* messages.
connect_msg->header.size = htons (sizeof(buf));
connect_msg->header.type = htons (GNUNET_MESSAGE_TYPE_TRANSPORT_CONNECT);
connect_msg->id = n->id;
- connect_msg->quota_in = n->primary_address.bandwidth_in;
connect_msg->quota_out = bandwidth_min;
GST_clients_broadcast (&connect_msg->header,
GNUNET_NO);
struct GNUNET_TIME_Absolute timeout)
{
if (GNUNET_TRANSPORT_is_connected (s) &&
- ! GNUNET_TRANSPORT_is_connected (n->state) )
+ (! GNUNET_TRANSPORT_is_connected (n->state)) )
{
neighbours_connect_notification (n);
GNUNET_STATISTICS_set (GST_stats,
++neighbours_connected,
GNUNET_NO);
}
- if (! GNUNET_TRANSPORT_is_connected (s) &&
- GNUNET_TRANSPORT_is_connected (n->state) )
+ if ((! GNUNET_TRANSPORT_is_connected (s)) &&
+ GNUNET_TRANSPORT_is_connected (n->state) )
{
GNUNET_STATISTICS_set (GST_stats,
gettext_noop ("# peers connected"),
}
GNUNET_assert (GNUNET_YES ==
GNUNET_CONTAINER_multipeermap_remove (neighbours,
- &n->id, n));
+ &n->id,
+ n));
/* Cancel address requests for this peer */
if (NULL != n->suggest_handle)
}
if (NULL == mq)
return; /* no more messages */
+ if (NULL == n->primary_address.address)
+ {
+ /* transmit_send_continuation() caused us to drop session,
+ can't try transmission anymore. */
+ return;
+ }
+
+
GNUNET_CONTAINER_DLL_remove (n->messages_head,
n->messages_tail,
mq);
/**
* Send a ACK message to the neighbour to confirm that we
- * got his SYN_ACK.
+ * got its SYN_ACK.
*
* @param n neighbour to send the ACK to
*/