size_t addr_out_len;
- /**
- * Sender's ip address to distinguish between incoming connections
- */
- //char * addr_inbound_str;
-
-
- /**
- * Sender's ip address specified by transport
- */
- //struct sockaddr_in * addr_outbound;
-
/**
* Did we initiate the connection (GNUNET_YES) or the other peer (GNUNET_NO)?
*/
*/
struct GNUNET_CRYPTO_HashAsciiEncoded hash;
- //struct HTTP_Message * pending_outbound_msg;
+ /**
+ * Head of dll used to store outbound messages
+ */
struct HTTP_Message * pending_outbound_msg_head;
+
+ /**
+ * Tail of dll used to store outbound messages
+ */
struct HTTP_Message * pending_outbound_msg_tail;
+ /**
+ * Incoming message
+ */
struct HTTP_Message * pending_inbound_msg;
+ /**
+ * curl handle for outbound transmissions
+ */
CURL *curl_handle;
+ /**
+ * Message tokenizer for incoming data
+ */
struct GNUNET_SERVER_MessageStreamTokenizer * msgtok;
};
*/
static GNUNET_SCHEDULER_TaskIdentifier http_task_v6;
-
/**
* The task sending data
*/
const char *sender_address,
uint16_t sender_address_len)
{
- GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "Testcase recieved new message from peer `%s' (`%s') with type %u and length %u\n", GNUNET_i2s(peer), sender_address, ntohs(message->type), ntohs(message->size));
+ GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "Testcase recieved new message from peer `%s' with type %u and length %u\n", GNUNET_i2s(peer), ntohs(message->type), ntohs(message->size));
if ((ntohs(message->type) == 40) && (fail_multiple_msgs_in_transmission == 1))
fail_multiple_msgs_in_transmission++;
if ((ntohs(message->type) == 41) && (fail_multiple_msgs_in_transmission == 2))