* Transmit messages from the message queue to the service
* (if there are any, and if we are not already trying).
*
- * @param sh handle to use
+ * @param ph handle to use
*/
static void
do_transmit (struct GNUNET_ATS_PerformanceHandle *ph);
*/
/**
- * @file transport/gnunet-service-transport_ats.c
- * @brief automatic transport selection
+ * @file transport/gnunet-service-transport_math.c
+ * @brief automatic transport selection, LP code
* @author Matthias Wachs
*
*/
/**
* Initialize ATS
- * @param cfg configuration handle to retrieve configuration (to be removed)
* @return
*/
-
struct ATS_Handle *
ats_init (double D, double U, double R, int v_b_min, int v_n_min,
int max_iterations, struct GNUNET_TIME_Relative max_duration,
*/
/**
- * @file transport/gnunet-service-transport_ats.h
+ * @file transport/gnunet-service-ats_math.h
* @brief common internal definitions for transport service's ats code
* @author Matthias Wachs
*/
-#ifndef GNUNET_SERVICE_TRANSPORT_ATS_H
-#define GNUNET_SERVICE_TRANSPORT_ATS_H
+#ifndef GNUNET_SERVICE_TRANSPORT_MATH_H
+#define GNUNET_SERVICE_TRANSPORT_MATH_H
#include "platform.h"
#include "gnunet_constants.h"
* Register a new performance client.
*
* @param client handle of the new client
+ * @param flag flag specifying the type of the client
*/
void
GAS_performance_add_client (struct GNUNET_SERVER_Client *client,
* Register a new performance client.
*
* @param client handle of the new client
- * @param flag options for the client
+ * @param flag flag specifying the type of the client
*/
void
GAS_performance_add_client (struct GNUNET_SERVER_Client *client,
* Send a message to all of our current clients that have the right
* options set.
*
+ * @param sender origin of the message (used to check that this peer is
+ * known to be connected to the respective client)
* @param msg message to multicast
* @param can_drop can this message be discarded if the queue is too long
* @param options mask to use
* @param atsi_count number of entries in 'ats' array
* @param tmap_old previous type map for the neighbour, NULL for disconnect
* @param tmap_new updated type map for the neighbour, NULL for disconnect
- * @param is_new GNUNET_YES if this is a completely new neighbour
*/
void
GSC_CLIENTS_notify_client_about_neighbour (struct GSC_Client *client,
* We received a PONG message. Validate and update our status.
*
* @param kx key exchange context for the the PONG
- * @param m the encrypted PONG message itself
+ * @param msg the encrypted PONG message itself
*/
void
GSC_KX_handle_pong (struct GSC_KeyExchangeInfo *kx,
* pass on to the appropriate clients.
*
* @param kx key exchange context for encrypting the message
- * @param m encrypted message
+ * @param msg encrypted message
* @param atsi performance data
* @param atsi_count number of entries in ats (excluding 0-termination)
*/
* Test if any of the types from the types array is in the
* given type map.
*
- * @param map map to test
+ * @param tmap map to test
* @param types array of types
* @param tcnt number of entries in types
* @return GNUNET_YES if a type is in the map, GNUNET_NO if not
/**
* Add additional types to a given typemap.
*
- * @param map map to extend (not changed)
+ * @param tmap map to extend (not changed)
* @param types array of types to add
* @param tcnt number of entries in types
* @return updated type map (fresh copy)
/**
* Create an empty type map.
*
- * @param map a type map
+ * @return an empty type map
*/
struct GSC_TypeMap *
GSC_TYPEMAP_create ()
/**
* Free the given type map.
*
- * @param map a type map
+ * @param tmap a type map
*/
void
GSC_TYPEMAP_destroy (struct GSC_TypeMap *tmap)
* Test if any of the types from the types array is in the
* given type map.
*
- * @param map map to test
+ * @param tmap map to test
* @param types array of types
* @param tcnt number of entries in types
* @return GNUNET_YES if a type is in the map, GNUNET_NO if not
/**
* Add additional types to a given typemap.
*
- * @param map map to extend (not changed)
+ * @param tmap map to extend (not changed)
* @param types array of types to add
* @param tcnt number of entries in types
* @return updated type map (fresh copy)
/**
* Create an empty type map.
*
- * @param map a type map
+ * @return an empty type map
*/
struct GSC_TypeMap *
GSC_TYPEMAP_create (void);
/**
* Free the given type map.
*
- * @param map a type map
+ * @param tmap a type map
*/
void
GSC_TYPEMAP_destroy (struct GSC_TypeMap *tmap);
* @param cls closure
* @param peer id of the peer, NULL for last call
* @param hello hello message for the peer (can be NULL)
- * @param error message
+ * @param err_msg error message (not used)
*/
static void
process_hello (void *cls, const struct GNUNET_PeerIdentity *peer,
*/
/**
- * @file block/plugin_block_dht.c
+ * @file dht/plugin_block_dht.c
* @brief block plugin for DHT internals (right now, find-peer requests only);
* other plugins should be used to store "useful" data in the
* DHT (see fs block plugin)
*
* @param cls the container multihashmap to update
* @param plugin_name name of the plugin that produced this value;
- * special values can be used (i.e. '<zlib>' for zlib being
+ * special values can be used (i.e. '<zlib>' for zlib being
* used in the main libextractor library and yielding
* meta data).
* @param type libextractor-type describing the meta data
*/
/**
- * @file block/plugin_block_fs.c
+ * @file fs/plugin_block_fs.c
* @brief blocks used for file-sharing
* @author Christian Grothoff
*/
* Copy the given address information into
* the given buffer using the format of HELLOs.
*
- * @param addess the address
+ * @param address the address
* @param expiration expiration for the address
* @param target where to copy the address
* @param max maximum number of bytes to copy to target
/**
- * struct ieee80211_radiotap_iterator - tracks walk thru present radiotap args
- * @rtheader: pointer to the radiotap header we are walking through
- * @max_length: length of radiotap header in cpu byte ordering
- * @this_arg_index: IEEE80211_RADIOTAP_... index of current arg
- * @this_arg: pointer to current radiotap arg
- * @arg_index: internal next argument index
- * @arg: internal next argument pointer
- * @next_bitmap: internal pointer to next present uint32_t
- * @bitmap_shifter: internal shifter for curr uint32_t bitmap, b0 set == arg present
+ * struct ieee80211_radiotap_iterator - tracks walk through present radiotap args
*/
struct ieee80211_radiotap_iterator
{
+ /**
+ * pointer to the radiotap header we are walking through
+ */
struct ieee80211_radiotap_header *rtheader;
+
+ /**
+ * length of radiotap header in cpu byte ordering
+ */
int max_length;
+
+ /**
+ * IEEE80211_RADIOTAP_... index of current arg
+ */
int this_arg_index;
+
+ /**
+ * pointer to current radiotap arg
+ */
uint8_t *this_arg;
+
+ /**
+ * internal next argument index
+ */
int arg_index;
+
+ /**
+ * internal next argument pointer
+ */
uint8_t *arg;
+
+ /**
+ * internal pointer to next present uint32_t
+ */
uint32_t *next_bitmap;
+
+ /**
+ * internal shifter for curr uint32_t bitmap, b0 set == arg present
+ */
uint32_t bitmap_shifter;
};
* Function setting up file descriptors and scheduling task to run
*
* @param plugin plugin as closure
+ * @param now schedule task in 1ms, regardless of what curl may say
* @return GNUNET_SYSERR for hard failure, GNUNET_OK for ok
*/
static int
else
timeout = GNUNET_TIME_relative_multiply (GNUNET_TIME_UNIT_MILLISECONDS, to);
if (now == GNUNET_YES)
- timeout = GNUNET_TIME_relative_multiply (GNUNET_TIME_UNIT_MILLISECONDS, 1);
+ timeout = GNUNET_TIME_UNIT_MILLISECONDS;
if (mret != CURLM_OK)
{
* @param stream pointer where to write data
* @param size size of an individual element
* @param nmemb count of elements that can be written to the buffer
-* @param ptr destination pointer, passed to the libcurl handle
+* @param cls destination pointer, passed to the libcurl handle
* @return bytes read from stream
*/
static size_t
* @param stream pointer where to write data
* @param size size of an individual element
* @param nmemb count of elements that can be written to the buffer
- * @param ptr source pointer, passed to the libcurl handle
+ * @param cls source pointer, passed to the libcurl handle
* @return bytes written to stream, returning 0 will terminate connection!
*/
static size_t
*
* @param plugin the plugin
* @param peer peer's identity
+ * @param addr address
+ * @param addrlen address length
* @return NULL if we have no session
*/
static struct Session *
* function to free a session
* @param plugin pointer to the plugin
* @param queue pointer to the sessionqueue element to free
- * @param free_macendpoint if GNUNET_YES and mac endpoint would be empty, free mac endpoint
+ * @param do_free_macendpoint if GNUNET_YES and mac endpoint would be empty, free mac endpoint
*/
static void
free_session (struct Plugin *plugin, struct Sessionqueue *queue,
*/
/**
- * @file block/plugin_block_dns.c
+ * @file vpn/plugin_block_dns.c
* @brief block plugin for storing .gnunet-bindings
* @author Philipp Tölke
*/