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");
192 case FRESCAN_REQ_NOT_ACCEPTED:
193 DEBUG(FRESCAN_BWRES_ENABLE_DEBUG, "negotiation FAIL\n");
195 ret = frescan_servers_destroy(net, req_data->ss);
196 if (ret != 0) return ret;
200 FRESCAN_ERROR("return_value unknown\n");
204 frescan_requests_free(req);
209 * frescan_bwres_renegotiate()
212 int frescan_bwres_renegotiate(frescan_network_t net,
213 const frsh_contract_t *contract,
218 frescan_request_id_t req;
219 frescan_request_data_t *req_data;
221 DEBUG(FRESCAN_BWRES_ENABLE_DEBUG, "preparing renegotiation request\n");
223 ret = frescan_requests_alloc(&req);
224 if (ret != 0) return ret;
226 ret = frescan_requests_get_data(req, &req_data);
227 if (ret != 0) return ret;
229 req_data->type = FRESCAN_REQ_RENEG;
231 req_data->contract = (frsh_contract_t *)contract;
232 req_data->request_node = the_networks[net].local_node;
236 ret = frescan_bwres_robjs_alloc(&req_data->robj, FRESCAN_BWRES_MX_PRIO);
237 if (ret != 0) return ret;
239 DEBUG(FRESCAN_BWRES_ENABLE_DEBUG, "enqueue renegotiation request\n");
241 ret = frescan_requests_enqueue(req);
242 if (ret != 0) return ret;
244 DEBUG(FRESCAN_BWRES_ENABLE_DEBUG, "wait for a reply\n");
246 ret = frescan_bwres_robjs_wait(req_data->robj);
247 if (ret != 0) return ret;
249 ret = frescan_bwres_robjs_free(req_data->robj);
250 if (ret != 0) return ret;
252 switch (req_data->return_value) {
253 case FRESCAN_REQ_ACCEPTED:
254 DEBUG(FRESCAN_BWRES_ENABLE_DEBUG, "renegotiation OK\n");
258 case FRESCAN_REQ_NOT_ACCEPTED:
259 DEBUG(FRESCAN_BWRES_ENABLE_DEBUG, "renegotiation FAIL\n");
264 FRESCAN_ERROR("return_value unknown\n");
268 frescan_requests_free(req);
273 * frescan_bwres_cancel()
276 int frescan_bwres_cancel(frescan_network_t net,
280 frescan_request_id_t req;
281 frescan_request_data_t *req_data;
283 DEBUG(FRESCAN_BWRES_ENABLE_DEBUG, "preparing cancel request\n");
285 ret = frescan_requests_alloc(&req);
286 if (ret != 0) return ret;
288 ret = frescan_requests_get_data(req, &req_data);
289 if (ret != 0) return ret;
291 req_data->type = FRESCAN_REQ_CANCEL;
293 req_data->request_node = the_networks[net].local_node;
297 ret = frescan_bwres_robjs_alloc(&req_data->robj, FRESCAN_BWRES_MX_PRIO);
298 if (ret != 0) return ret;
300 DEBUG(FRESCAN_BWRES_ENABLE_DEBUG, "enqueue cancel request\n");
302 ret = frescan_requests_enqueue(req);
303 if (ret != 0) return ret;
305 DEBUG(FRESCAN_BWRES_ENABLE_DEBUG, "wait for a signal\n");
307 ret = frescan_bwres_robjs_wait(req_data->robj);
308 if (ret != 0) return ret;
310 ret = frescan_bwres_robjs_free(req_data->robj);
311 if (ret != 0) return ret;
313 ret = frescan_servers_destroy(net, ss);
314 if (ret != 0) return ret;
316 frescan_requests_free(req);