2 * @file frescan_bwres.c
4 * @brief FRESCAN bandwidth reservation layer
6 * This module contains function to negotiate contracts and get the
7 * corresponding frescan sporadic servers.
13 * @author Daniel Sangorrin <daniel.sangorrin@unican.es>
17 * -----------------------------------------------------------------------
18 * Copyright (C) 2006 - 2008 FRESCOR consortium partners:
20 * Universidad de Cantabria, SPAIN
21 * University of York, UK
22 * Scuola Superiore Sant'Anna, ITALY
23 * Kaiserslautern University, GERMANY
24 * Univ. Politécnica Valencia, SPAIN
25 * Czech Technical University in Prague, CZECH REPUBLIC
27 * Thales Communication S.A. FRANCE
28 * Visual Tools S.A. SPAIN
29 * Rapita Systems Ltd UK
32 * See http://www.frescor.org for a link to partners' websites
34 * FRESCOR project (FP6/2005/IST/5-034026) is funded
35 * in part by the European Union Sixth Framework Programme
36 * The European Union is not liable of any use that may be
39 * This file is part of FRESCAN
41 * FRESCAN is free software; you can redistribute it and/or modify
42 * it under the terms of the GNU General Public License as published by
43 * the Free Software Foundation; either version 2, or (at your option)
46 * FRESCAN is distributed in the hope that it will be useful, but
47 * WITHOUT ANY WARRANTY; without even the implied warranty of
48 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
49 * General Public License for more details.
51 * You should have received a copy of the GNU General Public License
52 * distributed with FRESCAN; see file COPYING. If not, write to the
53 * Free Software Foundation, 59 Temple Place - Suite 330, Boston, MA
56 * As a special exception, including FRESCAN header files in a file,
57 * instantiating FRESCAN generics or templates, or linking other files
58 * with FRESCAN objects to produce an executable application, does not
59 * by itself cause the resulting executable application to be covered
60 * by the GNU General Public License. This exception does not
61 * however invalidate any other reasons why the executable file might be
62 * covered by the GNU Public License.
63 * -----------------------------------------------------------------------
67 #include "frescan_bwres.h"
68 #include "frescan_bwres_requests.h"
69 #include "frescan_bwres_messages.h"
70 #include "frescan_bwres_threads.h"
71 #include "frescan_bwres_analysis.h"
72 #include "frescan_data.h"
73 #include "frescan_debug.h"
74 #include "frescan_config.h"
75 #include "frescan_servers.h"
78 * frescan_bwres_init()
80 * Init the frescan bandwidth reservation layer
83 int frescan_bwres_init(frescan_network_t net)
86 frescan_server_params_t server_params; // TODO: improve this...
87 frescan_sa_init_params_t sa_init_params; // TODO: improve this...
89 sa_init_params.max_prio = 30;
90 sa_init_params.min_prio = 1;
92 ret = frescan_sa_init(&the_networks[net].scenario,
94 if (ret != 0) return ret;
96 server_params.budget = 5;
97 server_params.period.tv_sec = 1;
98 server_params.period.tv_nsec = 0;
99 server_params.prio = FRESCAN_BWRES_NEG_MESSAGES_PRIO;
101 ret = frescan_servers_create(net, &server_params,
102 &the_networks[net].neg_messages_ss_id);
103 if (ret != 0) return ret;
105 // TODO: we have to add this negotiation contracts to the sa table
107 ret = frescan_bwres_robjs_init(FRESCAN_REPLY_OBJECTS_MX_CEILING);
108 if (ret != 0) return ret;
110 ret = frescan_requests_init(FRESCAN_REQUESTS_MX_CEILING);
111 if (ret != 0) return ret;
113 ret = frescan_messages_init(net);
114 if (ret != 0) return ret;
116 ret = frescan_manager_thread_create(net);
117 if (ret != 0) return ret;
119 ret = frescan_acceptor_thread_create(net);
120 if (ret != 0) return ret;
126 * frescan_bwres_negotiate()
128 * to negotiate a contract we follow the next steps:
130 * 1.- prepare a request
131 * 2.- enqueue the request
132 * 3.- wait in the reply object for a reply
133 * 4.- return the final values and free the request
136 int frescan_bwres_negotiate(frescan_network_t net,
137 const frsh_contract_t *contract,
142 frescan_request_id_t req;
143 frescan_request_data_t *req_data;
144 frescan_server_params_t server_params;
146 DEBUG(FRESCAN_BWRES_ENABLE_DEBUG, "preparing a negotiation request\n");
148 ret = frescan_requests_alloc(&req);
149 if (ret != 0) return ret;
151 ret = frescan_requests_get_data(req, &req_data);
152 if (ret != 0) return ret;
154 req_data->type = FRESCAN_REQ_NEG;
156 req_data->contract = (frsh_contract_t *)contract;
157 req_data->request_node = the_networks[net].local_node;
160 ret = frescan_bwres_robjs_alloc(&req_data->robj, FRESCAN_BWRES_MX_PRIO);
161 if (ret != 0) return ret;
163 // NOTE: we preallocate a server for the negotiation process
164 server_params.budget = 0;
165 server_params.period.tv_sec = 0;
166 server_params.period.tv_nsec = 0;
167 server_params.prio = 0;
169 ret = frescan_servers_create(net, &server_params, &req_data->ss);
170 if (ret != 0) return ret;
172 DEBUG(FRESCAN_BWRES_ENABLE_DEBUG, "enqueue the negotiation request\n");
174 ret = frescan_requests_enqueue(req);
175 if (ret != 0) return ret;
177 DEBUG(FRESCAN_BWRES_ENABLE_DEBUG, "wait for a reply\n");
179 ret = frescan_bwres_robjs_wait(req_data->robj);
180 if (ret != 0) return ret;
182 ret = frescan_bwres_robjs_free(req_data->robj);
183 if (ret != 0) return ret;
185 switch (req_data->return_value) {
186 case FRESCAN_REQ_ACCEPTED:
187 DEBUG(FRESCAN_BWRES_ENABLE_DEBUG, "negotiation OK\n");
190 server_params = req_data->final_values;
191 ret = frescan_servers_update(net, &server_params, *ss);
192 if (ret != 0) return ret;
195 case FRESCAN_REQ_NOT_ACCEPTED:
196 DEBUG(FRESCAN_BWRES_ENABLE_DEBUG, "negotiation FAIL\n");
198 ret = frescan_servers_destroy(net, req_data->ss);
199 if (ret != 0) return ret;
203 FRESCAN_ERROR("return_value unknown\n");
207 frescan_requests_free(req);
212 * frescan_bwres_renegotiate()
215 int frescan_bwres_renegotiate(frescan_network_t net,
216 const frsh_contract_t *contract,
221 frescan_request_id_t req;
222 frescan_request_data_t *req_data;
223 frescan_server_params_t server_params;
225 DEBUG(FRESCAN_BWRES_ENABLE_DEBUG, "preparing renegotiation request\n");
227 ret = frescan_requests_alloc(&req);
228 if (ret != 0) return ret;
230 ret = frescan_requests_get_data(req, &req_data);
231 if (ret != 0) return ret;
233 req_data->type = FRESCAN_REQ_RENEG;
235 req_data->contract = (frsh_contract_t *)contract;
236 req_data->request_node = the_networks[net].local_node;
240 ret = frescan_bwres_robjs_alloc(&req_data->robj, FRESCAN_BWRES_MX_PRIO);
241 if (ret != 0) return ret;
243 DEBUG(FRESCAN_BWRES_ENABLE_DEBUG, "enqueue renegotiation request\n");
245 ret = frescan_requests_enqueue(req);
246 if (ret != 0) return ret;
248 DEBUG(FRESCAN_BWRES_ENABLE_DEBUG, "wait for a reply\n");
250 ret = frescan_bwres_robjs_wait(req_data->robj);
251 if (ret != 0) return ret;
253 ret = frescan_bwres_robjs_free(req_data->robj);
254 if (ret != 0) return ret;
256 switch (req_data->return_value) {
257 case FRESCAN_REQ_ACCEPTED:
258 DEBUG(FRESCAN_BWRES_ENABLE_DEBUG, "renegotiation OK\n");
260 server_params = req_data->final_values;
261 ret = frescan_servers_update(net, &server_params, ss);
262 if (ret != 0) return ret;
265 case FRESCAN_REQ_NOT_ACCEPTED:
266 DEBUG(FRESCAN_BWRES_ENABLE_DEBUG, "negotiation FAIL\n");
268 if (ret != 0) return ret;
272 FRESCAN_ERROR("return_value unknown\n");
276 frescan_requests_free(req);
281 * frescan_bwres_cancel()
284 int frescan_bwres_cancel(frescan_network_t net,
288 frescan_request_id_t req;
289 frescan_request_data_t *req_data;
291 DEBUG(FRESCAN_BWRES_ENABLE_DEBUG, "preparing cancel request\n");
293 ret = frescan_requests_alloc(&req);
294 if (ret != 0) return ret;
296 ret = frescan_requests_get_data(req, &req_data);
297 if (ret != 0) return ret;
299 req_data->type = FRESCAN_REQ_CANCEL;
301 req_data->request_node = the_networks[net].local_node;
305 ret = frescan_bwres_robjs_alloc(&req_data->robj, FRESCAN_BWRES_MX_PRIO);
306 if (ret != 0) return ret;
308 DEBUG(FRESCAN_BWRES_ENABLE_DEBUG, "enqueue cancel request\n");
310 ret = frescan_requests_enqueue(req);
311 if (ret != 0) return ret;
313 DEBUG(FRESCAN_BWRES_ENABLE_DEBUG, "wait for a signal\n");
315 ret = frescan_bwres_robjs_wait(req_data->robj);
316 if (ret != 0) return ret;
318 ret = frescan_bwres_robjs_free(req_data->robj);
319 if (ret != 0) return ret;
321 ret = frescan_servers_destroy(net, ss);
322 if (ret != 0) return ret;
324 frescan_requests_free(req);