frsh_api/tests/negotiation.cc

   1 #include <frsh.h>
   2 #include <error.h>
   3 #include <res_dummy.h>
   4 #include <getopt.h>
   5 #include <ul_logreg.h>
   6 #include <wvtest.h>
   7
   8 #define N 3
   9
  10 int b[N] = { 10, 20, 30 };
  11
  12 // TODO: Allow specifying loglevel in evironment
  13
  14 // static struct option long_opts[] = {
  15 //     { "loglevel", 1, 0, 'l' },
  16 //     { 0, 0, 0, 0}
  17 // };
  18
  19 // static void
  20 // usage(void)
  21 // {
  22 //      printf("usage: negotiation [ options ]\n");
  23 //      printf("  -l, --loglevel <number>|<domain>=<number>,...\n");
  24 // }
  25
  26 int ret;
  27 frsh_contract_t contract[N];
  28 frsh_vres_id_t vres[N];
  29 frsh_rel_time_t budget, period, deadline;
  30 int i;
  31
  32 WVTEST_MAIN("basic negotiation")
  33 {
  34 //      char opt;
  35
  36 //      while ((opt = getopt_long(argc, argv, "l:", &long_opts[0], NULL)) != EOF) {
  37 //              switch (opt) {
  38 //                      case 'l':
  39 //                              break;
  40 //                      case 'h':
  41 //                      /\*default:*\/
  42 //                              usage();
  43 //                              exit(opt == 'h' ? 0 : 1);
  44 //              }
  45 //      }
  46
  47         setenv("WVTEST_DIE_FAST", "", 1);
  48         ret = WVFRSH(frsh_init());
  49
  50         /* Negotiate N contracts */
  51         for (i=0; i<N; i++) {
  52                 ret = WVFRSH(frsh_contract_init(&contract[i]));
  53
  54                 ret = WVFRSH(frsh_contract_set_resource_and_label(
  55                         &contract[i],
  56                         DUMMY_RESOURCE_TYPE, DUMMY_RESOURCE_ID,
  57                         NULL));
  58
  59                 budget = fosa_msec_to_rel_time(b[i]);
  60                 period = fosa_msec_to_rel_time(100);
  61                 deadline = fosa_msec_to_rel_time(50);
  62                 ret = WVFRSH(frsh_contract_set_basic_params(&contract[i],
  63                                                             &budget,
  64                                                             &period,
  65                                                             FRSH_WT_BOUNDED,
  66                                                             FRSH_CT_REGULAR));
  67
  68                 ret = WVFRSH(frsh_contract_set_timing_reqs(&contract[i],
  69                                                            false, &deadline));
  70
  71                 ret = WVFRSH(frsh_contract_negotiate(&contract[i], &vres[i]));
  72         }
  73 }
  74
  75 WVTEST_MAIN("renegotiation")
  76 {
  77         for (i=0; i<2; i++) {
  78                 budget = fosa_msec_to_rel_time(2*b[i]);
  79                 period = fosa_msec_to_rel_time(110);
  80                 ret = WVFRSH(frsh_contract_set_basic_params(&contract[i],
  81                                                             &budget,
  82                                                             &period,
  83                                                             FRSH_WT_BOUNDED,
  84                                                             FRSH_CT_REGULAR));
  85
  86                 ret = WVFRSH(frsh_contract_renegotiate_sync(&contract[i], vres[i]));
  87         }
  88
  89         budget = fosa_msec_to_rel_time(2*b[2]);
  90         period = fosa_msec_to_rel_time(110);
  91         ret = WVFRSH(frsh_contract_set_basic_params(&contract[2],
  92                                                     &budget,
  93                                                     &period,
  94                                                     FRSH_WT_BOUNDED,
  95                                                     FRSH_CT_REGULAR));
  96
  97         WVPASS(frsh_contract_renegotiate_sync(&contract[2], vres[2]) == FRSH_ERR_CONTRACT_REJECTED);
  98 }
  99
 100 WVTEST_MAIN("cancelation")
 101 {
 102         /* Cancel N contracts */
 103         for (i=0; i<N; i++) {
 104                 ret = WVFRSH(frsh_contract_cancel(vres[i]));
 105         }
 106
 107         frsh_destroy();
 108 }