2 * \file sender_adaptive.c
3 * sends data according to the actual budget and period
7 #include "test_config.h"
13 #include <sys/socket.h>
14 #include <netinet/in.h>
15 #include <arpa/inet.h>
18 #include "fwp_confdefs.h"
19 #include <fres_sa_scenario.h>
24 * Mac address conversion functions
27 * Char to number conversion
31 if( (a >= '0') && (a <= '9') )
33 else if ( (a >= 'A') && (a <= 'F') )
35 else if ( (a >= 'a') && (a <= 'f') )
41 * Mac addres char to number conversion
42 * @param mac mac address in string format
44 * @return Mac address in long long format
46 long long mac_addr_string_to_number(char * mac)
64 mac_num[10] = mac[15];
65 mac_num[11] = mac[16];
69 for(ix = 0; ix <= 12 ; ix++)
72 for(ix2 = 1; ix2 < 12 - ix; ix2++)
74 number += atoint(mac_num[ix]) * help;
78 printf("%llu \n", number);
82 char * prepare_msg(int size) {
84 char * ret = (char*)malloc(size*sizeof(char));
85 for(i=0; i<size; i++) {
86 ret[i] = '0'; //just insert some characters
91 int main(int argc, char* argv[])
95 frsh_resource_id_t resource_id = TEST_RESOURCE_ID;
96 frsh_stream_id_t port = TEST_STREAM_ID;
97 long int num_msg = TEST_NUM_MSG;
98 size_t msg_size = MSGBUFFSIZE;
99 int time_period = 100;
104 frsh_send_endpoint_t sepoint;
106 frsh_send_endpoint_protocol_info_t send_pinfo;
107 frsh_contract_t contract;
108 frsh_rel_time_t budget, period;
111 bool opt_daemon = false;
112 char *opt_pidfile = NULL;
113 frsh_rel_time_t zero = fosa_msec_to_rel_time(0);
115 frsh_utilization_set_t utilization_set;
116 utilization_set.size = 4;
117 utilization_set.utilizations[1].period = fosa_msec_to_rel_time(100);
118 utilization_set.utilizations[1].budget = fosa_usec_to_rel_time(3);
119 utilization_set.utilizations[1].deadline = fosa_msec_to_rel_time(100);
120 utilization_set.utilizations[2].period = fosa_msec_to_rel_time(100);
121 utilization_set.utilizations[2].budget = fosa_usec_to_rel_time(9);
122 utilization_set.utilizations[2].deadline = fosa_msec_to_rel_time(100);
123 utilization_set.utilizations[3].period = fosa_msec_to_rel_time(100);
124 utilization_set.utilizations[3].budget = fosa_usec_to_rel_time(14);
125 utilization_set.utilizations[3].deadline = fosa_msec_to_rel_time(100);
128 while ((opt = getopt (argc, argv, "e:d:p:s:m:t:a:")) != -1) {
133 opt_pidfile = optarg;
136 dst_ip = inet_addr(optarg);
142 num_msg = atoi(optarg);
145 msg_size = atoi(optarg);
148 time_period = atoi(optarg);
151 strcpy(mac_addr, optarg);
154 printf("Usage: %s -e -d dst_ip_addr -p port"
155 "-m num_msg -s msg_size -a mac_addr\n",
161 forb_daemon_prepare(opt_pidfile);
164 send_pinfo.body = NULL;
165 WVPASSNE(frsh_send_endpoint_create(resource_id, dst_ip, port, send_pinfo, &sepoint), 0);
167 /* Contract parameters */
168 WVFRSH(frsh_contract_init(&contract));
169 WVFRSH(frsh_network_bytes_to_budget(resource_id, msg_size, &utilization_set.utilizations[0].budget));
170 utilization_set.utilizations[0].period = fosa_msec_to_rel_time(time_period);
171 WVFRSH(frsh_contract_set_basic_params(&contract,
172 &utilization_set.utilizations[0].budget,
173 &utilization_set.utilizations[0].period,
176 WVFRSH(frsh_contract_set_resource_and_label(&contract,FRSH_RT_NETWORK,
177 resource_id, "net_cont"));
179 /* Add fwp block with MAC address */
180 fres_block_fwp *fwp_block;
181 WVPASS((fwp_block = (fres_block_fwp*)malloc(sizeof(fres_block_fwp))) != NULL);
182 fwp_block->mac_address = mac_addr_string_to_number(mac_addr);
183 WVPASS(fres_contract_add_block(contract, FRES_BLOCK_FWP, fwp_block) == 0);
185 /* Add spare capacity block */
186 //TODO: Delete extra spare capacity block initialization, since spare capacity is initialized in set_reclamation_params function
187 //fres_block_spare_capacity *s;
188 //WVPASS((s = malloc(sizeof(*s))) != NULL);
189 //s->budget = (fosa_rel_time_t)budget;
190 //s->budget = (fosa_rel_time_t)utilization_set.utilizations[0].budget;
191 //s->period = (fosa_rel_time_t)utilization_set.utilizations[0].period;
192 //WVPASS(fres_contract_add_spare_capacity(contract, s) == 0);
194 WVFRSH(frsh_contract_set_reclamation_params(&contract,
196 &utilization_set.utilizations[utilization_set.size-1].budget,
197 &utilization_set.utilizations[utilization_set.size-1].period,
203 WVFRSH(frsh_contract_negotiate(&contract, &vres));
204 WVFRSH(frsh_send_endpoint_bind(vres, sepoint));
210 while (count != num_msg) {
212 WVPASS(frsh_vres_get_budget_and_period (vres, &budget, &period) == 0);
213 WVFRSH(frsh_network_budget_to_bytes(resource_id, &budget, &msg_size));
215 //TODO: Delete printf below
216 printf("msg_size....%d\n", msg_size);
217 printf("count....%d\n", count);
219 msg = prepare_msg(msg_size);
220 WVPASSEQ(frsh_send_sync(sepoint, msg, msg_size), msg_size);
223 frsh_contract_cancel(vres);
224 frsh_contract_destroy((struct fres_contract **)contract);
225 printf("Test PASSED!\n");