fwp/mngr/fwp_mngr.c

   1 #include <frm_generic.h>
   2 #include <forb.h>
   3 #include <error.h>
   4 #include <errno.h>
   5 #include <fres_sa_scenario.h>
   6 #include <stdbool.h>
   7 #include <ul_log.h>
   8 #include <frsh_distributed.h>
   9 #include "res_dummy.h"
  10 #include <stdio.h>
  11
  12 int dummy_admission_test(struct fres_sa_scenario *scenario, void *priv,
  13                                 bool *schedulable)
  14 {
  15         struct fres_sa_contract *c;
  16
  17         printf("Dummy admission test:\n");
  18
  19         fres_sa_scenario_for_each_contract(scenario, c) {
  20                 fres_block_basic *basic;
  21                 char id[40];
  22                 fres_contract_id_to_string(id, &c->contract->id, sizeof(id));
  23                 basic = fres_contract_get_basic(c->contract);
  24
  25                 printf("  processing: id=%s, period=%ld ms, budget=%ld ms\n",
  26                        id,
  27                        fosa_rel_time_to_msec(basic->period),
  28                        fosa_rel_time_to_msec(basic->budget));
  29
  30         }
  31         *schedulable = scenario->num_contracts <= 3;
  32         printf("=> %s\n", schedulable?"schedulable":"not schedulable");
  33
  34         return 0;
  35 }
  36
  37 static const struct fres_res_manager frm = {
  38         .res_type = FRSH_RT_NETWORK,
  39         .res_id = FRSH_NETPF_FWP,
  40         .admission_test = dummy_admission_test,
  41         .priv = NULL
  42 };
  43
  44 int main(int argc, char *argv[])
  45 {
  46         forb_orb orb;
  47         int ret;
  48
  49         orb = forb_init(&argc, &argv, "frm_fwp");
  50         if (!orb) error(1, errno, "forb_init");
  51
  52         ret = frm_register_and_run(orb, &frm);
  53
  54         if (ret != 0) {
  55                 error(1, errno, "frm_generic_run");
  56         }
  57
  58         return 0;
  59 }