1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
|
/*
This file is part of GNUnet.
Copyright (C) 2009-2013, 2016 GNUnet e.V.
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
Affero General Public License for more details.
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/>.
*/
/**
* @file transport/transport_api_offer_hello.c
* @brief library to offer HELLOs to transport service
* @author Christian Grothoff
*/
#include "platform.h"
#include "gnunet_util_lib.h"
#include "gnunet_hello_lib.h"
#include "gnunet_protocols.h"
#include "gnunet_transport_service.h"
/**
* Entry in linked list for all offer-HELLO requests.
*/
struct GNUNET_TRANSPORT_OfferHelloHandle
{
/**
* Transport service handle we use for transmission.
*/
struct GNUNET_MQ_Handle *mq;
/**
* Function to call once we are done.
*/
GNUNET_SCHEDULER_TaskCallback cont;
/**
* Closure for @e cont
*/
void *cls;
};
/**
* Done sending HELLO message to the service, notify application.
*
* @param cls the handle for the operation
*/
static void
finished_hello (void *cls)
{
struct GNUNET_TRANSPORT_OfferHelloHandle *ohh = cls;
if (NULL != ohh->cont)
ohh->cont (ohh->cls);
GNUNET_TRANSPORT_offer_hello_cancel (ohh);
}
/**
* Offer the transport service the HELLO of another peer. Note that
* the transport service may just ignore this message if the HELLO is
* malformed or useless due to our local configuration.
*
* @param cfg configuration
* @param hello the hello message
* @param cont continuation to call when HELLO has been sent,
* tc reason #GNUNET_SCHEDULER_REASON_TIMEOUT for fail
* tc reasong #GNUNET_SCHEDULER_REASON_READ_READY for success
* @param cont_cls closure for @a cont
* @return a `struct GNUNET_TRANSPORT_OfferHelloHandle` handle or NULL on failure,
* in case of failure @a cont will not be called
*
*/
struct GNUNET_TRANSPORT_OfferHelloHandle *
GNUNET_TRANSPORT_offer_hello (const struct GNUNET_CONFIGURATION_Handle *cfg,
const struct GNUNET_MessageHeader *hello,
GNUNET_SCHEDULER_TaskCallback cont,
void *cont_cls)
{
struct GNUNET_TRANSPORT_OfferHelloHandle *ohh
= GNUNET_new (struct GNUNET_TRANSPORT_OfferHelloHandle);
struct GNUNET_MQ_Envelope *env;
struct GNUNET_PeerIdentity peer;
if (GNUNET_OK !=
GNUNET_HELLO_get_id ((const struct GNUNET_HELLO_Message *) hello,
&peer))
{
GNUNET_break (0);
GNUNET_free (ohh);
return NULL;
}
ohh->mq = GNUNET_CLIENT_connect (cfg,
"transport",
NULL,
NULL,
ohh);
if (NULL == ohh->mq)
{
GNUNET_free (ohh);
return NULL;
}
ohh->cont = cont;
ohh->cls = cont_cls;
GNUNET_break (ntohs (hello->type) == GNUNET_MESSAGE_TYPE_HELLO);
env = GNUNET_MQ_msg_copy (hello);
GNUNET_MQ_notify_sent (env,
&finished_hello,
ohh);
GNUNET_MQ_send (ohh->mq,
env);
return ohh;
}
/**
* Cancel the request to transport to offer the HELLO message
*
* @param ohh the handle for the operation to cancel
*/
void
GNUNET_TRANSPORT_offer_hello_cancel (struct GNUNET_TRANSPORT_OfferHelloHandle *ohh)
{
GNUNET_MQ_destroy (ohh->mq);
GNUNET_free (ohh);
}
/* end of transport_api_offer_hello.c */
|
