comin_var_request.cpp

Go to the documentation of this file.

 
#include "comin.h"
 
#include "comin_state.hpp"
#include "comin_var_request.hpp"
#include "comin_variable.hpp"
 
static void var_request_add_element(const t_comin_var_descriptor& var_desc,
                                    bool lmodexclusive) {
  if (auto it = comin_var_request_find(&var_desc); it) {
    if (it->lmodexclusive) {
      // Another plugin has allocated this variable exclusively.
      comin_error_set(COMIN_ERROR_VAR_REQUEST_EXISTS_IS_LMODEXCLUSIVE);
      return;
    } else if (lmodexclusive) {
      // This plugin wants exclusive access but the variable already exists
      comin_error_set(COMIN_ERROR_VAR_REQUEST_EXISTS_REQUEST_LMODEXCLUSIVE);
      return;
    } else {
      // Variable exists but is not exclusive. Just record the plugin as new
      // user.
      it->moduleID.push_back(comin_current_get_plugin_id());
    }
  } else {
    auto& var_request_list = comin::state.comin_var_request_list;
 
    t_comin_request_item req;
    req.descriptor    = var_desc;
    req.lmodexclusive = lmodexclusive;
    req.moduleID.push_back(comin_current_get_plugin_id());
    var_request_list.push_back(std::move(req));
  }
}
 
extern "C" {

  void comin_var_request_add(t_comin_var_descriptor var_desc,
                             bool lmodexclusive) {
    if (comin_state_is_primary_done()) {
      comin_error_set(COMIN_ERROR_VAR_REQUEST_AFTER_PRIMARYCONSTRUCTOR);
      return;
    }
 
    if (var_desc.id == -1) {
      t_comin_var_descriptor dom_desc = var_desc;
 
      for (int dom = 1; dom <= comin_descrdata_get_global_n_dom(); ++dom) {
        dom_desc.id = dom;
 
        var_request_add_element(dom_desc, lmodexclusive);
      }
    } else {
      var_request_add_element(var_desc, lmodexclusive);
    }
  }
 
  t_comin_request_item*
  comin_var_request_find(const t_comin_var_descriptor* var_desc) {
    auto& var_request_list = comin::state.comin_var_request_list;
 
    auto it = std::find_if(var_request_list.begin(), var_request_list.end(),
                           [&](const t_comin_request_item& a) {
                             return a.descriptor == *var_desc;
                           });
 
    if (it != var_request_list.end())
      return &*it;
    else
      return nullptr;
  }
 
  comin::keyval::Map*
  comin_var_request_get_metadata(t_comin_request_item* req) {
    return &req->metadata;
  }
 
  t_comin_var_descriptor*
  comin_var_request_get_descriptor(t_comin_request_item* req) {
    return &req->descriptor;
  }
 
  t_comin_var_request_list_iterator* comin_request_list_iterator_begin() {
    auto& var_request_list = comin::state.comin_var_request_list;
 
    return new t_comin_var_request_list_iterator{var_request_list.begin()};
  }
 
  bool comin_request_list_iterator_is_end(
      const t_comin_var_request_list_iterator* it) {
    auto& var_request_list = comin::state.comin_var_request_list;
 
    return it->it == var_request_list.end();
  }
 
  t_comin_request_item*
  comin_request_list_iterator_next(t_comin_var_request_list_iterator* it) {
    auto& current = *it->it;
    ++it->it;
    return &current;
  }
 
  void
  comin_request_list_iterator_delete(t_comin_var_request_list_iterator** it) {
    delete *it;
    *it = nullptr;
  }
}