fwp_vres_params_t vparams;
fwp_vres_d_t fwp_vresd;
int rv;
+ size_t bytes;
/* Prepare vres parameters */
basic = fres_contract_get_basic(vres->new);
fwp_sched = fres_contract_get_block(vres->new, FRES_BLOCK_FWP_SCHED);
- //fwp_fna_network_budget_to_bytes(FRSH_NETPF_FWP, &basic->budget, &vparams.budget);
- vparams.budget = basic->budget.tv_nsec/1000000;
+ frsh_network_budget_to_bytes(FRSH_NETPF_FWP, &basic->budget, &bytes);
+ vparams.budget = bytes;
vparams.period = basic->period;
vparams.ac_id = fwp_sched->ac_id;
/* Create vres */
rc = _fwp_vres_send(vres->ac_sockd, msgb);
if (!(rc < 0)) {
FWP_DEBUG("Message sent through AC%d\n",ac_id);
- /* Switch to this in the future */
- //curr_budget+= msgb->len;
- curr_budget++;
+ curr_budget+= msgb->len;
+ } else {
+ FWP_DEBUG("Message sent error %d\n",rc);
}
fwp_msgb_free(msgb);