#define LIBGNUNET_PLUGIN_TRANSPORT_DONE libgnunet_plugin_transport_http_client_done
#endif
-
-#define VERBOSE_CURL GNUNET_YES
+#define VERBOSE_CURL GNUNET_NO
#include "platform.h"
#include "gnunet_protocols.h"
-#include "gnunet_connection_lib.h"
+#include "gnunet_common.h"
#include "gnunet_server_lib.h"
-#include "gnunet_service_lib.h"
-#include "gnunet_statistics_service.h"
-#include "gnunet_transport_service.h"
#include "gnunet_transport_plugin.h"
#include "plugin_transport_http_common.h"
#include <curl/curl.h>
/**
* Was session given to transport service?
*/
- int session_passed;
+ // int session_passed;
/**
* Client send handle
struct GNUNET_TIME_Absolute next_receive;
};
+
/**
* Encapsulation of all of the state of the plugin.
*/
GNUNET_SCHEDULER_TaskIdentifier client_perform_task;
};
+
/**
* Encapsulation of all of the state of the plugin.
*/
struct HTTP_Client_Plugin *p;
+
/**
- * Start session timeout
+ * Start session timeout for a session
+ * @param s the session
*/
static void
client_start_session_timeout (struct Session *s);
+
/**
- * Increment session timeout due to activity
+ * Increment session timeout due to activity for a session
+ * @param s the session
*/
static void
client_reschedule_session_timeout (struct Session *s);
+
/**
- * Cancel timeout
+ * Cancel timeout for a session
+ * @param s the session
*/
static void
client_stop_session_timeout (struct Session *s);
+
/**
* Function setting up file descriptors and scheduling task to run
*
client_schedule (struct HTTP_Client_Plugin *plugin, int now);
-int
+/**
+ * Does a session s exists?
+ *
+ * @param plugin the plugin
+ * @param s desired session
+ * @return GNUNET_YES or GNUNET_NO
+ */
+static int
client_exist_session (struct HTTP_Client_Plugin *plugin, struct Session *s)
{
struct Session * head;
#if VERBOSE_CURL
/**
* Function to log curl debug messages with GNUNET_log
+ *
* @param curl handle
* @param type curl_infotype
* @param data data
}
#endif
+
/**
* Function that can be used by the transport service to transmit
* a message using the plugin. Note that in the case of a
}
-void
+/**
+ * Delete session s
+ *
+ * @param s the session to delete
+ */
+static void
client_delete_session (struct Session *s)
{
struct HTTP_Client_Plugin *plugin = s->plugin;
}
+
static struct Session *
client_lookup_session (struct HTTP_Client_Plugin *plugin,
const struct GNUNET_HELLO_Address *address)
return NULL;
}
+
/**
* Callback method used with libcurl
* Method is called when libcurl needs to read data during sending
}
+/**
+ * Wake up a curl handle which was suspended
+ *
+ * @param cls the session
+ * @param tc task context
+ */
static void
client_wake_up (void *cls, const struct GNUNET_SCHEDULER_TaskContext *tc)
{
}
-
+/**
+ * Callback for message stream tokenixer
+ *
+ * @param cls the session
+ * @param client not used
+ * @param message the message received
+ * @return always GNUNET_OK
+ */
static int
client_receive_mst_cb (void *cls, void *client,
const struct GNUNET_MessageHeader *message)
}
+
/**
* Task performing curl operations
*
static void
client_run (void *cls, const struct GNUNET_SCHEDULER_TaskContext *tc);
+
/**
* Function setting up file descriptors and scheduling task to run
*
}
-
/**
* Task performing curl operations
*
GNUNET_assert (address != NULL);
GNUNET_assert (address->address != NULL);
-
/* find existing session */
s = client_lookup_session (plugin, address);
if (s != NULL)
return s;
}
+
+/**
+ * Setup http_client plugin
+ *
+ * @param plugin the plugin handle
+ * @return GNUNET_OK on success, GNUNET_SYSERR on error
+ */
static int
client_start (struct HTTP_Client_Plugin *plugin)
{
GNUNET_assert (GNUNET_OK == client_disconnect (s));
}
+
/**
-* Start session timeout
-*/
+ * Start session timeout for session s
+ *
+ * @param s the session
+ */
static void
client_start_session_timeout (struct Session *s)
{
s, (unsigned long long) CLIENT_SESSION_TIMEOUT.rel_value);
}
+
/**
-* Increment session timeout due to activity
-*/
+ * Increment session timeout due to activity for session s
+ *
+ * param s the session
+ */
static void
client_reschedule_session_timeout (struct Session *s)
{
s, (unsigned long long) CLIENT_SESSION_TIMEOUT.rel_value);
}
+
/**
-* Cancel timeout
-*/
+ * Cancel timeout due to activity for session s
+ *
+ * param s the session
+ */
static void
client_stop_session_timeout (struct Session *s)
{
return GNUNET_NO;
}
+
/**
* Exit point from the plugin.
+ *
+ * @param cls api as closure
+ * @return NULL
*/
void *
LIBGNUNET_PLUGIN_TRANSPORT_DONE (void *cls)
}
+/**
+ * Configure plugin
+ *
+ * @param plugin the plugin handle
+ * @return GNUNET_OK on success, GNUNET_SYSERR on failure
+ */
static int
client_configure_plugin (struct HTTP_Client_Plugin *plugin)
{