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
*/
/**
#include "gnunet_crypto_lib.h"
#include "gnunet_time_lib.h"
-#include "gnunet_transport_service.h"
#include "gnunet_constants.h"
#define DEBUG_TRANSPORT GNUNET_EXTRA_LOGGING
/**
* Maximum frequency for re-evaluating latencies for all transport addresses.
*/
-#define LATENCY_EVALUATION_MAX_DELAY GNUNET_TIME_relative_multiply (GNUNET_TIME_UNIT_HOURS, 1)
+#define LATENCY_EVALUATION_MAX_DELAY \
+ GNUNET_TIME_relative_multiply (GNUNET_TIME_UNIT_HOURS, 1)
/**
* Maximum frequency for re-evaluating latencies for connected addresses.
*/
-#define CONNECTED_LATENCY_EVALUATION_MAX_DELAY GNUNET_TIME_relative_multiply (GNUNET_TIME_UNIT_MINUTES, 1)
+#define CONNECTED_LATENCY_EVALUATION_MAX_DELAY \
+ GNUNET_TIME_relative_multiply (GNUNET_TIME_UNIT_MINUTES, 1)
/**
* Similiar to GNUNET_TRANSPORT_NotifyDisconnect but in and out quotas are
* @param bandwidth_out outbound bandwidth in NBO
*
*/
-typedef void
-(*NotifyConnect) (void *cls,
- const struct GNUNET_PeerIdentity *peer,
- struct GNUNET_BANDWIDTH_Value32NBO bandwidth_in,
- struct GNUNET_BANDWIDTH_Value32NBO bandwidth_out);
+typedef void (*NotifyConnect) (
+ void *cls,
+ const struct GNUNET_PeerIdentity *peer,
+ struct GNUNET_BANDWIDTH_Value32NBO bandwidth_in,
+ struct GNUNET_BANDWIDTH_Value32NBO bandwidth_out);
GNUNET_NETWORK_STRUCT_BEGIN
+
/**
* Message from the transport service to the library
* asking to check if both processes agree about this
* receiver should print out an error message and disconnect.
*/
struct GNUNET_PeerIdentity self;
-
};
*/
struct GNUNET_MessageHeader header;
- /**
- * Identity of the new neighbour.
- */
- struct GNUNET_PeerIdentity id;
+#if (defined(GNUNET_TRANSPORT_COMMUNICATION_VERSION) || \
+ defined(GNUNET_TRANSPORT_CORE_VERSION))
/**
- * Current inbound quota for this peer
+ * Always zero, for alignment.
*/
- struct GNUNET_BANDWIDTH_Value32NBO quota_in;
+ uint32_t reserved GNUNET_PACKED;
+
+#else
/**
* Current outbound quota for this peer
*/
struct GNUNET_BANDWIDTH_Value32NBO quota_out;
+#endif
+
+ /**
+ * Identity of the new neighbour.
+ */
+ struct GNUNET_PeerIdentity id;
};
* Who got disconnected?
*/
struct GNUNET_PeerIdentity peer;
-
};
* Message used to set a particular bandwidth quota. Sent TO the
* service to set an incoming quota, sent FROM the service to update
* an outgoing quota.
+ *
+ * NOTE: no longer used in TNG!
*/
struct QuotaSetMessage
{
* About which peer are we talking here?
*/
struct GNUNET_PeerIdentity peer;
-
};
* Which peer sent the message?
*/
struct GNUNET_PeerIdentity peer;
-
};
*/
struct GNUNET_MessageHeader header;
+#if (defined(GNUNET_TRANSPORT_COMMUNICATION_VERSION) || \
+ defined(GNUNET_TRANSPORT_CORE_VERSION))
+
+ uint32_t reserved GNUNET_PACKED;
+
+#else
+
/**
* #GNUNET_OK if the transmission succeeded,
* #GNUNET_SYSERR if it failed (i.e. network disconnect);
* in either case, it is now OK for this client to
* send us another message for the given peer.
*/
- uint32_t success GNUNET_PACKED;
+ uint16_t success GNUNET_PACKED;
/**
* Size of message sent
*/
- uint32_t bytes_msg GNUNET_PACKED;
+ uint16_t bytes_msg GNUNET_PACKED;
/**
- * Size of message sent over wire
- * Includes plugin and protocol specific overhead
+ * Size of message sent over wire.
+ * Includes plugin and protocol specific overheads.
*/
uint32_t bytes_physical GNUNET_PACKED;
+#endif
+
/**
* Which peer can send more now?
*/
struct GNUNET_PeerIdentity peer;
-
};
+
/**
- * Message used to notify the transport API about an address to string
- * conversion. Message is followed by the string with the humand-readable
- * address. For each lookup, multiple results may be returned. The
- * last message must have a @e res of #GNUNET_OK and an @e addr_len
- * of zero.
+ * Message used to notify the transport API that it can
+ * send another message to the transport service.
+ * (Used to implement flow control.)
*/
-struct AddressToStringResultMessage
+struct RecvOkMessage
{
/**
- * Type will be #GNUNET_MESSAGE_TYPE_TRANSPORT_ADDRESS_TO_STRING_REPLY
+ * Type will be #GNUNET_MESSAGE_TYPE_TRANSPORT_RECV_OK
*/
struct GNUNET_MessageHeader header;
/**
- * #GNUNET_OK if the conversion succeeded,
- * #GNUNET_SYSERR if it failed
+ * Number of messages by which to increase the window, greater or
+ * equal to one.
*/
- uint32_t res GNUNET_PACKED;
+ uint32_t increase_window_delta GNUNET_PACKED;
/**
- * Length of the following string, zero if @e is #GNUNET_SYSERR
+ * Which peer can CORE handle more from now?
*/
- uint32_t addr_len GNUNET_PACKED;
+ struct GNUNET_PeerIdentity peer;
};
*/
uint32_t reserved GNUNET_PACKED;
+#if ! (defined(GNUNET_TRANSPORT_COMMUNICATION_VERSION) || \
+ defined(GNUNET_TRANSPORT_CORE_VERSION))
+
/**
* Allowed delay.
*/
struct GNUNET_TIME_RelativeNBO timeout;
+#endif
/**
* Which peer should receive the message?
*/
struct GNUNET_PeerIdentity peer;
+};
+
+
+#if ! (defined(GNUNET_TRANSPORT_COMMUNICATION_VERSION) || \
+ defined(GNUNET_TRANSPORT_CORE_VERSION))
+
+/**
+ * Message used to notify the transport API about an address to string
+ * conversion. Message is followed by the string with the humand-readable
+ * address. For each lookup, multiple results may be returned. The
+ * last message must have a @e res of #GNUNET_OK and an @e addr_len
+ * of zero.
+ */
+struct AddressToStringResultMessage
+{
+
+ /**
+ * Type will be #GNUNET_MESSAGE_TYPE_TRANSPORT_ADDRESS_TO_STRING_REPLY
+ */
+ struct GNUNET_MessageHeader header;
+
+ /**
+ * #GNUNET_OK if the conversion succeeded,
+ * #GNUNET_SYSERR if it failed
+ */
+ uint32_t res GNUNET_PACKED;
+
+ /**
+ * Length of the following string, zero if @e is #GNUNET_SYSERR
+ */
+ uint32_t addr_len GNUNET_PACKED;
};
* The identity of the peer to look up.
*/
struct GNUNET_PeerIdentity peer;
-
};
* The identity of the peer to look up.
*/
struct GNUNET_PeerIdentity peer;
-
};
* Length of the plugin name
*/
uint32_t pluginlen GNUNET_PACKED;
-
};
* Which peer is being blacklisted or queried?
*/
struct GNUNET_PeerIdentity peer;
-
};
/* followed by 0-terminated plugin name and
@e plugin_address_len bytes of plugin address */
-
};
-
-
-
-
-
-
-
+#else
/* *********************** TNG messages ***************** */
*/
struct GNUNET_MessageHeader header;
+ /**
+ * NBO encoding of `enum GNUNET_TRANSPORT_CommunicatorCharacteristics`
+ */
+ uint32_t cc;
+
/* Followed by the address prefix of the communicator */
};
struct GNUNET_TIME_RelativeNBO expiration;
/**
- * An `enum GNUNET_ATS_Network_Type` in NBO.
+ * An `enum GNUNET_NetworkType` in NBO.
*/
uint32_t nt;
* Address identifier.
*/
uint32_t aid GNUNET_PACKED;
-
};
*/
uint64_t fc_id GNUNET_PACKED;
+ /**
+ * How long does the communicator believe the address on which
+ * the message was received to remain valid?
+ */
+ struct GNUNET_TIME_RelativeNBO expected_address_validity;
+
/**
* Sender identifier.
*/
* Sender identifier of the original message.
*/
struct GNUNET_PeerIdentity sender;
-
};
struct GNUNET_PeerIdentity receiver;
/**
- * An `enum GNUNET_ATS_Network_Type` in NBO.
+ * An `enum GNUNET_NetworkType` in NBO.
*/
uint32_t nt;
+ /**
+ * Maximum transmission unit, in NBO. UINT32_MAX for unlimited.
+ */
+ uint32_t mtu;
+
+ /**
+ * An `enum GNUNET_TRANSPORT_ConnectionStatus` in NBO.
+ */
+ uint32_t cs;
+
/* followed by UTF-8 encoded, 0-terminated human-readable address */
};
* Receiver that can be addressed via the queue.
*/
struct GNUNET_PeerIdentity receiver;
-
};
/**
- * Transport tells communicator that it wants a new queue.
+ * Communicator tells transport how queue creation went down.
*/
struct GNUNET_TRANSPORT_CreateQueueResponse
{
/**
- * Type will be #GNUNET_MESSAGE_TYPE_TRANSPORT_QUEUE_CREATE_OK or #GNUNET_MESSAGE_TYPE_TRANSPORT_QUEUE_CREATE_FAIL.
+ * Type will be #GNUNET_MESSAGE_TYPE_TRANSPORT_QUEUE_CREATE_OK or
+ * #GNUNET_MESSAGE_TYPE_TRANSPORT_QUEUE_CREATE_FAIL.
*/
struct GNUNET_MessageHeader header;
* Receiver identifier.
*/
struct GNUNET_PeerIdentity receiver;
+};
+
+
+/**
+ * Message from communicator to transport service asking for
+ * transmission of a backchannel message with the given peer @e pid
+ * and communicator.
+ */
+struct GNUNET_TRANSPORT_CommunicatorBackchannel
+{
+ /**
+ * Type will be #GNUNET_MESSAGE_TYPE_TRANSPORT_COMMUNICATOR_BACKCHANNEL
+ */
+ struct GNUNET_MessageHeader header;
+
+ /**
+ * Always zero, for alignment.
+ */
+ uint32_t reserved;
+ /**
+ * Target peer.
+ */
+ struct GNUNET_PeerIdentity pid;
+
+ /* Followed by a `struct GNUNET_MessageHeader` with the encapsulated
+ message to the communicator */
+
+ /* Followed by the 0-terminated string specifying the desired
+ communicator at the target (@e pid) peer */
};
+/**
+ * Message from transport to communicator passing along a backchannel
+ * message from the given peer @e pid.
+ */
+struct GNUNET_TRANSPORT_CommunicatorBackchannelIncoming
+{
+ /**
+ * Type will be
+ * #GNUNET_MESSAGE_TYPE_TRANSPORT_COMMUNICATOR_BACKCHANNEL_INCOMING
+ */
+ struct GNUNET_MessageHeader header;
+
+ /**
+ * Always zero, for alignment.
+ */
+ uint32_t reserved;
+
+ /**
+ * Origin peer.
+ */
+ struct GNUNET_PeerIdentity pid;
+
+ /* Followed by a `struct GNUNET_MessageHeader` with the encapsulated
+ message to the communicator */
+};
/**
* Target identifier to monitor, all zeros for "all peers".
*/
struct GNUNET_PeerIdentity peer;
-
};
struct GNUNET_MessageHeader header;
/**
- * Network type (an `enum GNUNET_ATS_Network_Type` in NBO).
+ * Network type (an `enum GNUNET_NetworkType` in NBO).
*/
uint32_t nt GNUNET_PACKED;
struct GNUNET_TIME_RelativeNBO rtt;
/**
- * Is inbound (in NBO).
+ * Connection status (in NBO).
*/
- uint32_t is_inbound GNUNET_PACKED;
+ uint32_t cs GNUNET_PACKED;
/**
* Messages pending (in NBO).
*/
uint32_t num_bytes_pending GNUNET_PACKED;
- /* Followed by 0-terminated address of the peer
- (TODO: do we allow no address? If so,
- adjust transport_api2_monitor!) */
+ /* Followed by 0-terminated address of the peer */
+};
+
+
+/**
+ * Request to verify address.
+ */
+struct GNUNET_TRANSPORT_AddressToVerify
+{
+
+ /**
+ * Type will be #GNUNET_MESSAGE_TYPE_TRANSPORT_ADDRESS_CONSIDER_VERIFY.
+ */
+ struct GNUNET_MessageHeader header;
+
+ /**
+ * Reserved. 0.
+ */
+ uint32_t reserved;
+
+ /**
+ * Peer the address is from.
+ */
+ struct GNUNET_PeerIdentity peer;
+
+ /* followed by variable-size raw address */
+};
+
+
+/**
+ * Application client to TRANSPORT service: we would like to have
+ * address suggestions for this peer.
+ */
+struct ExpressPreferenceMessage
+{
+ /**
+ * Type is #GNUNET_MESSAGE_TYPE_TRANSPORT_SUGGEST or
+ * #GNUNET_MESSAGE_TYPE_TRANSPORT_SUGGEST_CANCEL to stop
+ * suggestions.
+ */
+ struct GNUNET_MessageHeader header;
+
+ /**
+ * What type of performance preference does the client have?
+ * A `enum GNUNET_MQ_PreferenceKind` in NBO.
+ */
+ uint32_t pk GNUNET_PACKED;
+
+ /**
+ * Peer to get address suggestions for.
+ */
+ struct GNUNET_PeerIdentity peer;
+ /**
+ * How much bandwidth in bytes/second does the application expect?
+ */
+ struct GNUNET_BANDWIDTH_Value32NBO bw;
};
+/**
+ * We got an address of another peer, TRANSPORT service
+ * should validate it. There is no response.
+ */
+struct RequestHelloValidationMessage
+{
+
+ /**
+ * Type is #GNUNET_MESSAGE_TYPE_TRANSPORT_REQUEST_HELLO_VALIDATION.
+ */
+ struct GNUNET_MessageHeader header;
+
+ /**
+ * What type of network does the other peer claim this is?
+ * A `enum GNUNET_NetworkType` in NBO.
+ */
+ uint32_t nt GNUNET_PACKED;
+
+ /**
+ * Peer to the address is presumably for.
+ */
+ struct GNUNET_PeerIdentity peer;
+
+ /**
+ * When does the address expire?
+ */
+ struct GNUNET_TIME_AbsoluteNBO expiration;
+ /* followed by 0-terminated address to validate */
+};
+#endif
GNUNET_NETWORK_STRUCT_END
projects / oweals / gnunet.git / blobdiff