failnix/targets/wasm-host/linux.c

#include "../lib_cored.h"

#include "bh_platform.h"
#include "wasm_export.h"

#include "__WASM_ARRAY_FILE__"
#include <stdio.h>

void fail_start_trace_wasm(wasm_exec_env_t exec_env) {}
void fail_stop_trace_wasm(wasm_exec_env_t exec_env) {}
void fail_marker_positive_wasm(wasm_exec_env_t exec_env) {}
void fail_marker_negative_wasm(wasm_exec_env_t exec_env) {}
void fail_marker_detected_wasm(wasm_exec_env_t exec_env) {}

#define STACK_SIZE (4 * 1024)
#define HEAP_SIZE STACK_SIZE
#define RUNTIME_POOL_SIZE 4 * STACK_SIZE

int main(int argc, char *argv[]) {
  char error_buf[128];

  /* initialize the wasm runtime */
  static char global_heap_buf[RUNTIME_POOL_SIZE];
  static RuntimeInitArgs init_args;
  memset(&init_args, 0, sizeof(RuntimeInitArgs));

  // init_args.mem_alloc_type = Alloc_With_System_Allocator;
  init_args.mem_alloc_type = Alloc_With_Pool;
  init_args.mem_alloc_option.pool.heap_buf = global_heap_buf;
  init_args.mem_alloc_option.pool.heap_size = sizeof(global_heap_buf);
  init_args.max_thread_num = 1;
  if (!wasm_runtime_full_init(&init_args)) {
    return 1;
  }

  static NativeSymbol native_symbols[] = {
      {"fail_start_trace", fail_start_trace_wasm, "()"},
      {"fail_stop_trace", fail_stop_trace_wasm, "()"},
      {"fail_marker_positive", fail_marker_positive_wasm, "()"},
      {"fail_marker_negative", fail_marker_negative_wasm, "()"},
      {"fail_marker_detected", fail_marker_detected_wasm, "()"},
  };
  int n_native_symbols = sizeof(native_symbols) / sizeof(NativeSymbol);
  if (!wasm_runtime_register_natives("env", native_symbols, n_native_symbols)) {
    return 1;
  }

  /* parse the WASM file from buffer and create a WASM module */
  wasm_module_t module = wasm_runtime_load(__WASM_ARRAY__, __WASM_ARRAY_LEN__,
                                           error_buf, sizeof(error_buf));

  if (!module) {
    printf("Load failed: %s\n", error_buf);
    return 1;
  }

  /* create an instance of the WASM module (WASM linear memory is ready) */
  wasm_module_inst_t module_inst = wasm_runtime_instantiate(
      module, STACK_SIZE, HEAP_SIZE, error_buf, sizeof(error_buf));

  if (!module_inst) {
    printf("Inst failed: %s\n", error_buf);
    return 1;
  }

  wasm_exec_env_t exec_env =
      wasm_runtime_create_exec_env(module_inst, STACK_SIZE);
  uint32_t args[FILTER_COUNT];

  wasm_function_inst_t init_func =
      wasm_runtime_lookup_function(module_inst, "init_outputs");
  args[0] = 100;
  args[1] = 142;
  args[2] = 100;
  if (!wasm_runtime_call_wasm(exec_env, init_func, 3, args)) {
    printf("Failed to call init_outputs\n");
    return 1;
  }

  // CoRed vote
  wasm_function_inst_t func =
      wasm_runtime_lookup_function(module_inst, "wasm_module");
  args[0] = 0;
  args[1] = 0;
  args[2] = 0;
  if (!wasm_runtime_call_wasm(exec_env, func, 0, args)) {
    printf("Failed to call wasm_module\n");
    return 1;
  }
  sign_t static_sig = args[0];

  // Obtain dynamic signature produced by CoRed
  wasm_function_inst_t cored_res_func =
      wasm_runtime_lookup_function(module_inst, "get_cored_res");
  args[0] = 0;
  args[1] = 0;
  args[2] = 0;
  if (!wasm_runtime_call_wasm(exec_env, cored_res_func, 0, args)) {
    printf("Failed to call get_cored_res\n");
    return 1;
  }
  enc_t cored_res = args[0];

  wasm_runtime_destroy_exec_env(exec_env);
  wasm_runtime_deinstantiate(module_inst);
  wasm_runtime_unload(module);
  wasm_runtime_destroy();

  sign_t vote_result_sig;
  switch (static_sig) {
  case SIG_s_XYZ:
  case SIG_s_XY:
  case SIG_s_XZ:
    vote_result_sig = SIG_X;
    break;
  case SIG_s_YZ:
    vote_result_sig = SIG_Y;
    break;
  default:
    printf("ERROR: Unknown static_sig %d\n", static_sig);
    break;
  }

  // Inversely apply constant program flow signature.
  printf("Inversely apply: cored_res=%d static_sig=%d\n", cored_res,
         static_sig);
  cored_res -= static_sig;

  /* Validate Vote result */
  printf(
      "Validating vote result: cored_res=%d THE_A=%d vote_result_sig = % d\n ",
      cored_res, THE_A, vote_result_sig);
  if (!check(cored_res, THE_A, vote_result_sig)) {
    printf("Validation failed :(\n");
    return 1;
  }

  plain_t res = decode(cored_res, THE_A, vote_result_sig);
  // printf("Decoded result: %d (%f)\n", res, q_to_float(res));
  if (res == 100) {
    printf("Marker Positive\n");
    return 0;
  } else {
    printf("Marker Negative\n");
    return 1;
  }
}