nmps_appl.c

Go to the documentation of this file.

/*
 * ProviewR   Open Source Process Control.
 * Copyright (C) 2005-2025 SSAB EMEA AB.
 *
 * This file is part of ProviewR.
 *
 * This program is free software; you can redistribute it and/or
 * modify it under the terms of the GNU General Public License as
 * published by the Free Software Foundation, either version 2 of
 * the License, or (at your option) any later version.
 *
 * This program is distributed in the hope that it will be useful
 * but WITHOUT ANY WARRANTY; without even the implied warranty of
 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
 * GNU General Public License for more details.
 *
 * You should have received a copy of the GNU General Public License
 * along with ProviewR. If not, see <http://www.gnu.org/licenses/>
 *
 * Linking ProviewR statically or dynamically with other modules is
 * making a combined work based on ProviewR. Thus, the terms and
 * conditions of the GNU General Public License cover the whole
 * combination.
 *
 * In addition, as a special exception, the copyright holders of
 * ProviewR give you permission to, from the build function in the
 * ProviewR Configurator, combine ProviewR with modules generated by the
 * ProviewR PLC Editor to a PLC program, regardless of the license
 * terms of these modules. You may copy and distribute the resulting
 * combined work under the terms of your choice, provided that every
 * copy of the combined work is accompanied by a complete copy of
 * the source code of ProviewR (the version used to produce the
 * combined work), being distributed under the terms of the GNU
 * General Public License plus this exception.
 */
 
/*************************************************************************
 *
*       PROGRAM         rs_nmps_appl
*
*       Modifierad
*               971002  Claes Sjöfors    Skapad
*
*       Funktion:       Applikationsgränssnitt mot Nmps.
**************************************************************************/
 
/*_Include filer_________________________________________________________*/
 
#include "pwr_nmpsclasses.h"
 
#include "co_cdh.h"
#include "co_string.h"
 
#include "rt_lck.h"
#include "rt_gdh_msg.h"
#include "rt_hash_msg.h"
#include "rs_nmps_msg.h"
 
#include "nmps.h"
#include "nmps_appl.h"
 
/* Global functions________________________________________________________*/
 
typedef struct nmpsappl_s_data_list {
  pwr_tObjid objid;
  pwr_tString80 name;
  unsigned int possession;
  pwr_tAddress object_ptr;
  gdh_tDlid subid;
  int remove;
  int pending_remove;
  struct nmpsappl_s_data_list* prev_ptr;
  struct nmpsappl_s_data_list* next_ptr;
} nmpsappl_t_data_list;
 
typedef struct nmpsappl_s_basectx {
  nmpsappl_t_cellist* cellist;
  int cellist_count;
  nmpsappl_t_ctx applctx_list;
  int applctx_count;
  nmpsappl_t_data_list* datalist;
} * nmpsappl_t_basectx;
 
/*_Global variables______________________________________________________*/
 
static nmpsappl_t_basectx nmpsappl_basectx = 0;
 
/*_Local functions________________________________________________________*/
 
static pwr_tStatus nmpsappl_data_db_create(nmpsappl_t_data_list** data_list,
    pwr_tObjid objid, int options, nmpsappl_t_data_list** datalist_ptr);
static pwr_tStatus nmpsappl_data_db_delete(
    nmpsappl_t_data_list** data_list, nmpsappl_t_data_list* data_ptr);
 
/****************************************************************************
* Name:         nmpsappl_data_db_create()
*
* Type          pwr_tStatus
*
* Type          Parameter       IOGF    Description
*
* Description:
*               Create an entry in the datalist for an objid.
*
**************************************************************************/
static pwr_tStatus nmpsappl_data_db_create(nmpsappl_t_data_list** data_list,
    pwr_tObjid objid, int options, nmpsappl_t_data_list** datalist_ptr)
{
  nmpsappl_t_data_list* next_ptr;
  pwr_tStatus sts;
  char name[80];
  pwr_sAttrRef attrref;
  pwr_tAddress object_ptr;
  gdh_tDlid subid;
 
  /* Get a direct link to the original object */
  attrref = cdh_ObjidToAref(objid);
  sts = gdh_DLRefObjectInfoAttrref(&attrref, &object_ptr, &subid);
  if (EVEN(sts))
    return sts;
 
  if (options & nmpsappl_mOption_NamePath)
    sts = gdh_ObjidToName(objid, name, sizeof(name), cdh_mName_path);
  else
    sts = gdh_ObjidToName(objid, name, sizeof(name), cdh_mName_object);
  if (EVEN(sts))
    return sts;
 
  *datalist_ptr = calloc(1, sizeof(nmpsappl_t_data_list));
  if (*datalist_ptr == 0)
    return NMPS__NOMEMORY;
 
  (*datalist_ptr)->object_ptr = object_ptr;
  (*datalist_ptr)->subid = subid;
  (*datalist_ptr)->objid = objid;
  strcpy((*datalist_ptr)->name, name);
 
  /* Insert first in list */
  next_ptr = *data_list;
  if (next_ptr != NULL)
    next_ptr->prev_ptr = *datalist_ptr;
  (*datalist_ptr)->next_ptr = next_ptr;
 
  *data_list = *datalist_ptr;
 
  return NMPS__SUCCESS;
}
 
/****************************************************************************
* Name:         nmpsappl_data_db_delete()
*
* Type          pwr_tStatus
*
* Type          Parameter       IOGF    Description
*
* Description:
*               Delete an entry in the datalist.
*
**************************************************************************/
static pwr_tStatus nmpsappl_data_db_delete(
    nmpsappl_t_data_list** data_list, nmpsappl_t_data_list* data_ptr)
{
  int sts;
 
  sts = gdh_DLUnrefObjectInfo(data_ptr->subid);
 
  if (data_ptr == *data_list) {
    /* Change the root */
    *data_list = data_ptr->next_ptr;
    if (*data_list)
      (*data_list)->prev_ptr = 0;
  }
 
  if (data_ptr->prev_ptr)
    data_ptr->prev_ptr->next_ptr = data_ptr->next_ptr;
  if (data_ptr->next_ptr)
    data_ptr->next_ptr->prev_ptr = data_ptr->prev_ptr;
 
  free(data_ptr);
 
  return NMPS__SUCCESS;
}
 
/****************************************************************************
* Name:         nmpsappl_cell_init()
*
* Type          pwr_tStatus
*
* Type          Parameter       IOGF    Description
*
* Description:
*
**************************************************************************/
static pwr_tStatus nmpsappl_cell_init(char* cell_name, pwr_tObjid* orig_objid,
    void** orig_cell, gdh_tSubid* orig_subid, pwr_tClassId* orig_class)
{
  pwr_sAttrRef attrref;
  pwr_tStatus sts;
  pwr_tObjid cell_objid;
 
  sts = gdh_NameToObjid(cell_name, &cell_objid);
  if (EVEN(sts))
    return NMPS__APPLCELL;
 
  /* It might already have been stored */
  memset(&attrref, 0, sizeof(attrref));
  attrref = cdh_ObjidToAref(cell_objid);
 
  sts = gdh_GetObjectClass(attrref.Objid, orig_class);
  if (EVEN(sts))
    return sts;
 
  /* Link to object */
  sts = gdh_DLRefObjectInfoAttrref(
      &attrref, (pwr_tAddress*)orig_cell, orig_subid);
  if (EVEN(sts))
    return NMPS__APPLCELL;
 
  return NMPS__SUCCESS;
}
 
pwr_tStatus nmpsappl_MirrorInit(pwr_tString80*
                                    cell_array, 
    unsigned long options, 
    nmpsappl_t_ctx* ctx 
    )
{
  pwr_tString80* cellname;
  nmpsappl_t_basectx basectx;
  nmpsappl_t_ctx applctx;
  nmpsappl_t_cellist* cellist_ptr;
  nmpsappl_t_cellist* c_ptr;
  int found;
  int sts;
  int maxsize;
  int i;
 
  if (nmpsappl_basectx == 0) {
    /* Base context is not yet created */
    nmpsappl_basectx = calloc(1, sizeof(*nmpsappl_basectx));
    if (nmpsappl_basectx == 0)
      return 0;
  }
  basectx = nmpsappl_basectx;
 
  if (basectx->applctx_count >= NMPSAPPL_APPLSESS_MAX)
    return NMPS__APPLSESSMAX;
 
  /* Create a context for this applikation call */
  applctx = calloc(1, sizeof(*applctx));
  if (applctx == 0)
    return 0;
 
  /* Insert applctx in basectx */
  applctx->next = basectx->applctx_list;
  basectx->applctx_list = applctx;
  applctx->index = basectx->applctx_count;
  applctx->index_mask = 1 << basectx->applctx_count;
  basectx->applctx_count++;
 
  *ctx = applctx;
 
  /* Add cells to cellist */
  cellname = cell_array;
  while (!streq((char*)cellname, "")) {
    str_ToUpper((char*)cellname, (char*)cellname);
 
    /* Check if cell already is inserted */
    cellist_ptr = basectx->cellist;
    found = 0;
    while (cellist_ptr) {
      if (streq((char*)cellname, cellist_ptr->name)) {
        found = 1;
        break;
      }
      cellist_ptr = cellist_ptr->next;
    }
    if (!found) {
      /* Insert cell last position in cellist */
 
      cellist_ptr = calloc(1, sizeof(nmpsappl_t_cellist));
      strcpy((char*)cellist_ptr->name, (char*)cellname);
      sts = nmpsappl_cell_init(cellist_ptr->name, &cellist_ptr->objid,
          &cellist_ptr->object_ptr, &cellist_ptr->subid, &cellist_ptr->classid);
      if (EVEN(sts))
        return sts;
 
      c_ptr = basectx->cellist;
      if (!c_ptr)
        basectx->cellist = cellist_ptr;
      else {
        while (c_ptr->next)
          c_ptr++;
        c_ptr->next = cellist_ptr;
      }
      basectx->cellist_count++;
    }
    if (applctx->cellist_count < NMPSAPPL_CELLIST_MAX) {
      applctx->cellist[applctx->cellist_count] = cellist_ptr;
      cellist_ptr->index_mask[applctx->index] = 1 << applctx->cellist_count;
      applctx->cellist_count++;
    } else
      return NMPS__APPLCELLIST; /* Cellist to large */
 
    cellname++;
  }
 
  /* Calculate the total size of the cell's in the list */
  applctx->total_cellsize = 0;
  for (i = 0; i < applctx->cellist_count; i++) {
    cellist_ptr = applctx->cellist[i];
    switch (cellist_ptr->classid) {
    case pwr_cClass_NMpsCell:
    case pwr_cClass_NMpsCell60:
    case pwr_cClass_NMpsCell120:
    case pwr_cClass_NMpsStoreCell:
    case pwr_cClass_NMpsStoreCell60:
    case pwr_cClass_NMpsStoreCell120:
      maxsize = ((pwr_sClass_NMpsCell*)cellist_ptr->object_ptr)->MaxSize;
      applctx->total_cellsize += maxsize;
      cellist_ptr->tmp_size = sizeof(pwr_sClass_NMpsCell)
          - sizeof(plc_t_DataInfo) * (30 - maxsize);
      break;
    case pwr_cClass_NMpsMirrorCell:
      maxsize = ((pwr_sClass_NMpsMirrorCell*)cellist_ptr->object_ptr)->MaxSize;
      applctx->total_cellsize += maxsize;
      cellist_ptr->tmp_size = sizeof(pwr_sClass_NMpsMirrorCell)
          - sizeof(plc_t_DataInfoMirCell) * (NMPS_CELLMIR_SIZE - maxsize)
          - sizeof(nmps_t_mircell_copyarea);
      break;
    }
    cellist_ptr->tmp_cell = (void*)calloc(1, cellist_ptr->tmp_size);
  }
 
  /* Allocate memory for the data objects array in applctx */
  if (options & nmpsappl_mOption_Remove)
    /* Remove requires the double size */
    applctx->datainfo = (nmpsappl_t_datainfo*)calloc(
        applctx->total_cellsize * 2, sizeof(nmpsappl_t_datainfo));
  else
    applctx->datainfo = (nmpsappl_t_datainfo*)calloc(
        applctx->total_cellsize, sizeof(nmpsappl_t_datainfo));
 
  lck_Create(&sts, lck_eLock_NMps);
  if (EVEN(sts))
    return sts;
 
  applctx->options = options;
 
  return NMPS__SUCCESS;
}
 
pwr_tStatus nmpsappl_Mirror(
    nmpsappl_t_ctx applctx, 
    int* data_count, 
    nmpsappl_t_datainfo**
        datainfo 
    )
{
  int i, j, k;
  int found;
  nmpsappl_t_cellist* cellist_ptr;
  nmpsappl_t_data_list* data_ptr;
  nmpsappl_t_data_list* data_next_ptr;
  int sts;
 
  /* Copy cell-objects into the temporary buffer, and hope that
     we will not be interuppted by the plc-program */
  for (i = 0; i < applctx->cellist_count; i++) {
    cellist_ptr = applctx->cellist[i];
    lck_LockNMps;
    memcpy(
        cellist_ptr->tmp_cell, cellist_ptr->object_ptr, cellist_ptr->tmp_size);
    lck_UnlockNMps;
  }
 
  applctx->data_count = 0;
  for (k = 0; k < applctx->cellist_count; k++) {
    cellist_ptr = applctx->cellist[k];
    switch (cellist_ptr->classid) {
    case pwr_cClass_NMpsCell:
    case pwr_cClass_NMpsCell60:
    case pwr_cClass_NMpsCell120:
    case pwr_cClass_NMpsStoreCell:
    case pwr_cClass_NMpsStoreCell60:
    case pwr_cClass_NMpsStoreCell120: {
      pwr_sClass_NMpsCell* object_ptr;
      plc_t_DataInfo* data_block_ptr;
 
      object_ptr = (pwr_sClass_NMpsCell*)cellist_ptr->tmp_cell;
      if (!(object_ptr->ReloadDone & NMPS_CELL_INITIALIZED))
        continue;
 
      data_block_ptr = (plc_t_DataInfo*)&object_ptr->Data1P;
      if (applctx->options & nmpsappl_mOption_ReverseOrder)
        data_block_ptr += object_ptr->LastIndex - 1;
      for (i = 0; i < object_ptr->LastIndex; i++) {
        /* Check that objid is not already inserted */
        found = 0;
        for (j = 0; j < applctx->data_count; j++) {
          if (cdh_ObjidIsEqual(applctx->datainfo[j].objid,
                  data_block_ptr->DataP.Aref.Objid)) {
            found = 1;
            break;
          }
        }
        if (!found) {
          applctx->datainfo[applctx->data_count].objid
              = data_block_ptr->DataP.Aref.Objid;
          applctx->datainfo[applctx->data_count].front
              = data_block_ptr->Data_Front;
          applctx->datainfo[applctx->data_count].back
              = data_block_ptr->Data_Back;
          applctx->datainfo[applctx->data_count].select
              = data_block_ptr->Data_Select;
          applctx->datainfo[applctx->data_count].cell_mask
              = cellist_ptr->index_mask[applctx->index];
          applctx->datainfo[applctx->data_count].removed = 0;
          applctx->data_count++;
        } else {
          applctx->datainfo[applctx->data_count].front
              |= data_block_ptr->Data_Front;
          applctx->datainfo[applctx->data_count].back
              |= data_block_ptr->Data_Back;
          if (data_block_ptr->Data_Select)
            applctx->datainfo[applctx->data_count].select = 1;
          applctx->datainfo[applctx->data_count].cell_mask
              |= cellist_ptr->index_mask[applctx->index];
        }
        if (applctx->options & nmpsappl_mOption_ReverseOrder)
          data_block_ptr--;
        else
          data_block_ptr++;
      }
      break;
    }
    case pwr_cClass_NMpsMirrorCell: {
      pwr_sClass_NMpsMirrorCell* object_ptr;
      plc_t_DataInfoMirCell* data_block_ptr;
 
      object_ptr = (pwr_sClass_NMpsMirrorCell*)cellist_ptr->tmp_cell;
 
      data_block_ptr = (plc_t_DataInfoMirCell*)&object_ptr->Data1P;
      for (i = 0; i < object_ptr->LastIndex; i++) {
        /* Check that objid is not already inserted */
        found = 0;
        for (j = 0; j < i; j++) {
          if (cdh_ObjidIsEqual(applctx->datainfo[j].objid,
                  data_block_ptr->DataP.Aref.Objid)) {
            found = 1;
            break;
          }
        }
        if (!found) {
          applctx->datainfo[applctx->data_count].objid
              = data_block_ptr->DataP.Aref.Objid;
          applctx->datainfo[applctx->data_count].select = 0;
          applctx->datainfo[applctx->data_count].front = 0;
          applctx->datainfo[applctx->data_count].back = 0;
          applctx->datainfo[applctx->data_count].cell_mask
              = cellist_ptr->index_mask[applctx->index];
          applctx->datainfo[applctx->data_count].removed = 0;
          applctx->data_count++;
        } else {
          applctx->datainfo[applctx->data_count].cell_mask
              |= cellist_ptr->index_mask[applctx->index];
        }
        data_block_ptr++;
      }
      break;
    }
    }
  }
 
  /* Insert new data-object in the data db, or find the old ones */
 
  /* Set the remove flag for all the dataobjects of this applctx */
  data_ptr = nmpsappl_basectx->datalist;
  while (data_ptr) {
    if (data_ptr->possession & applctx->index_mask)
      data_ptr->remove = 1;
    data_ptr = data_ptr->next_ptr;
  }
 
  for (i = 0; i < applctx->data_count; i++) {
    /* Try to find the data-object */
    found = 0;
    data_ptr = nmpsappl_basectx->datalist;
    while (data_ptr) {
      if (cdh_ObjidIsEqual(applctx->datainfo[i].objid, data_ptr->objid)) {
        if (data_ptr->possession & applctx->index_mask) {
          /* It already belongs to this application session */
          if (data_ptr->pending_remove)
            /* The object has reappleard */
            data_ptr->pending_remove = 0;
 
          applctx->datainfo[i].object_ptr = data_ptr->object_ptr;
          data_ptr->remove = 0;
          applctx->datainfo[i].newdata = 0;
        } else {
          /* A new object for this session, mark possession */
          if (data_ptr->pending_remove) {
            /* The object has reappleard from another session */
            data_ptr->pending_remove = 0;
            data_ptr->possession = 0;
          }
          data_ptr->possession |= applctx->index_mask;
          applctx->datainfo[i].object_ptr = data_ptr->object_ptr;
          applctx->datainfo[i].newdata = 1;
          data_ptr->remove = 0;
 
          /* Insert in new data list */
        }
        strcpy(applctx->datainfo[i].name, data_ptr->name);
        found = 1;
        break;
      }
      data_ptr = data_ptr->next_ptr;
    }
    if (!found) {
      /* A new object, insert it into the data database */
      sts = nmpsappl_data_db_create(&nmpsappl_basectx->datalist,
          applctx->datainfo[i].objid, applctx->options, &data_ptr);
      if (EVEN(sts))
        return sts;
 
      data_ptr->possession |= applctx->index_mask;
      applctx->datainfo[i].object_ptr = data_ptr->object_ptr;
      applctx->datainfo[i].newdata = 1;
      strcpy(applctx->datainfo[i].name, data_ptr->name);
 
      /* Insert in new data list */
    }
  }
 
  /* Mark objects for remove that was previously possessed by this
          session only */
  data_ptr = nmpsappl_basectx->datalist;
  while (data_ptr) {
    if (data_ptr->remove && data_ptr->possession & applctx->index_mask) {
      if (data_ptr->possession == applctx->index_mask
          && data_ptr->pending_remove) {
        /* Remove the object from the database */
        data_next_ptr = data_ptr->next_ptr;
        sts = nmpsappl_data_db_delete(&nmpsappl_basectx->datalist, data_ptr);
        if (EVEN(sts))
          return sts;
        data_ptr = data_next_ptr;
        continue;
      } else {
        /* Remove next scan */
        if (data_ptr->possession == applctx->index_mask)
          data_ptr->pending_remove = 1;
        else
          data_ptr->possession &= ~applctx->index_mask;
        if (applctx->options & nmpsappl_mOption_Remove) {
          /* Add the removed to the list */
          applctx->datainfo[applctx->data_count].objid = data_ptr->objid;
          applctx->datainfo[applctx->data_count].select = 0;
          applctx->datainfo[applctx->data_count].front = 0;
          applctx->datainfo[applctx->data_count].back = 0;
          applctx->datainfo[applctx->data_count].cell_mask = 0;
          applctx->datainfo[applctx->data_count].removed = 1;
          applctx->datainfo[i].object_ptr = data_ptr->object_ptr;
          applctx->datainfo[i].newdata = 0;
          strcpy(applctx->datainfo[i].name, data_ptr->name);
          applctx->data_count++;
        }
      }
    }
    data_ptr = data_ptr->next_ptr;
  }
 
  *datainfo = applctx->datainfo;
  *data_count = applctx->data_count;
  return NMPS__SUCCESS;
}
 
pwr_tStatus nmpsappl_RemoveData(
    nmpsappl_t_ctx applctx, 
    pwr_tObjid objid 
    )
{
  int k;
  nmpsappl_t_cellist* cellist_ptr;
 
  for (k = 0; k < applctx->cellist_count; k++) {
    cellist_ptr = applctx->cellist[k];
    switch (cellist_ptr->classid) {
    case pwr_cClass_NMpsCell:
    case pwr_cClass_NMpsCell60:
    case pwr_cClass_NMpsCell120:
    case pwr_cClass_NMpsStoreCell:
    case pwr_cClass_NMpsStoreCell60:
    case pwr_cClass_NMpsStoreCell120: {
      pwr_sClass_NMpsCell* object_ptr;
 
      object_ptr = (pwr_sClass_NMpsCell*)cellist_ptr->object_ptr;
      object_ptr->ExternOpType = NMPS_OPTYPE_EXTDELETE_OBJID;
      object_ptr->ExternObjId = objid;
      object_ptr->ExternFlag = 1;
      break;
    }
    default:
      break;
    }
  }
  return NMPS__SUCCESS;
}
 
pwr_tStatus nmpsappl_RemoveAndDeleteData(
    nmpsappl_t_ctx applctx, 
    pwr_tObjid objid 
    )
{
  int sts, k;
  nmpsappl_t_cellist* cellist_ptr;
 
  for (k = 0; k < applctx->cellist_count; k++) {
    cellist_ptr = applctx->cellist[k];
    switch (cellist_ptr->classid) {
    case pwr_cClass_NMpsCell:
    case pwr_cClass_NMpsCell60:
    case pwr_cClass_NMpsCell120:
    case pwr_cClass_NMpsStoreCell:
    case pwr_cClass_NMpsStoreCell60:
    case pwr_cClass_NMpsStoreCell120: {
      pwr_sClass_NMpsCell* object_ptr;
 
      object_ptr = (pwr_sClass_NMpsCell*)cellist_ptr->object_ptr;
      object_ptr->ExternOpType = NMPS_OPTYPE_EXTDELETE_OBJID;
      object_ptr->ExternObjId = objid;
      object_ptr->ExternFlag = 1;
      break;
    }
    default:
      break;
    }
  }
  sts = gdh_DeleteObject(objid);
  if (EVEN(sts))
    return sts;
 
  return NMPS__SUCCESS;
}
 
pwr_tStatus nmpsappl_SelectData(nmpsappl_t_ctx applctx, pwr_tObjid objid)
{
  int k;
  nmpsappl_t_cellist* cellist_ptr;
 
  for (k = 0; k < applctx->cellist_count; k++) {
    cellist_ptr = applctx->cellist[k];
    switch (cellist_ptr->classid) {
    case pwr_cClass_NMpsStoreCell: {
      pwr_sClass_NMpsCell* object_ptr;
 
      object_ptr = (pwr_sClass_NMpsCell*)cellist_ptr->object_ptr;
      object_ptr->ExternOpType = NMPS_OPTYPE_EXTSELECT_OBJID;
      object_ptr->ExternObjId = objid;
      object_ptr->ExternFlag = 1;
      break;
    }
    default:
      break;
    }
  }
 
  return NMPS__SUCCESS;
}
 
pwr_tStatus nmpsappl_TransportData(nmpsappl_t_ctx applctx, pwr_tObjid objid,
    unsigned int from_cell_mask, unsigned int to_cell_mask)
{
  int k;
  unsigned int mask;
  nmpsappl_t_cellist* cellist_ptr;
 
  /* Check that to cell is not busy or full */
  mask = 1;
  for (k = 0; k < applctx->cellist_count; k++, mask = mask << 1) {
    if (!(mask & to_cell_mask))
      continue;
 
    cellist_ptr = applctx->cellist[k];
    switch (cellist_ptr->classid) {
    case pwr_cClass_NMpsCell:
    case pwr_cClass_NMpsCell60:
    case pwr_cClass_NMpsCell120:
    case pwr_cClass_NMpsStoreCell:
    case pwr_cClass_NMpsStoreCell60:
    case pwr_cClass_NMpsStoreCell120: {
      pwr_sClass_NMpsCell* object_ptr;
 
      object_ptr = (pwr_sClass_NMpsCell*)cellist_ptr->object_ptr;
      if (object_ptr->ExternFlag)
        return NMPS__CELLEXTERNBUSY;
      if (object_ptr->CellFull)
        return NMPS__CELLFULL;
      break;
    }
    default:
      break;
    }
    break;
  }
 
  /* Remove data first */
  mask = 1;
  for (k = 0; k < applctx->cellist_count; k++, mask = mask << 1) {
    if (!(mask & from_cell_mask))
      continue;
 
    cellist_ptr = applctx->cellist[k];
    switch (cellist_ptr->classid) {
    case pwr_cClass_NMpsCell:
    case pwr_cClass_NMpsCell60:
    case pwr_cClass_NMpsCell120:
    case pwr_cClass_NMpsStoreCell:
    case pwr_cClass_NMpsStoreCell60:
    case pwr_cClass_NMpsStoreCell120: {
      pwr_sClass_NMpsCell* object_ptr;
 
      object_ptr = (pwr_sClass_NMpsCell*)cellist_ptr->object_ptr;
      if (object_ptr->ExternFlag)
        return NMPS__CELLEXTERNBUSY;
 
      object_ptr->ExternOpType = NMPS_OPTYPE_EXTREMOVE_OBJID;
      object_ptr->ExternObjId = objid;
      object_ptr->ExternFlag = 1;
      break;
    }
    default:
      break;
    }
  }
 
  /* Insert data */
  mask = 1;
  for (k = 0; k < applctx->cellist_count; k++, mask = mask << 1) {
    if (!(mask & to_cell_mask))
      continue;
 
    cellist_ptr = applctx->cellist[k];
    switch (cellist_ptr->classid) {
    case pwr_cClass_NMpsCell:
    case pwr_cClass_NMpsCell60:
    case pwr_cClass_NMpsCell120:
    case pwr_cClass_NMpsStoreCell:
    case pwr_cClass_NMpsStoreCell60:
    case pwr_cClass_NMpsStoreCell120: {
      pwr_sClass_NMpsCell* object_ptr;
 
      object_ptr = (pwr_sClass_NMpsCell*)cellist_ptr->object_ptr;
      if (object_ptr->ExternFlag)
        return NMPS__CELLEXTERNBUSY;
      if (object_ptr->CellFull)
        return NMPS__CELLFULL;
 
      object_ptr->ExternOpType = NMPS_OPTYPE_EXTINSERT;
      object_ptr->ExternObjId = objid;
      object_ptr->ExternFlag = 1;
      break;
    }
    default:
      break;
    }
    break;
  }
 
  return NMPS__SUCCESS;
}
 
pwr_tStatus nmpsappl_InsertData(
    nmpsappl_t_ctx applctx, pwr_tObjid objid, unsigned int cell_mask)
{
  int k;
  unsigned int mask;
  nmpsappl_t_cellist* cellist_ptr;
 
  /* Insert data */
  mask = 1;
  for (k = 0; k < applctx->cellist_count; k++, mask = mask << 1) {
    if (!(mask & cell_mask))
      continue;
 
    cellist_ptr = applctx->cellist[k];
    switch (cellist_ptr->classid) {
    case pwr_cClass_NMpsCell:
    case pwr_cClass_NMpsCell60:
    case pwr_cClass_NMpsCell120:
    case pwr_cClass_NMpsStoreCell:
    case pwr_cClass_NMpsStoreCell60:
    case pwr_cClass_NMpsStoreCell120: {
      pwr_sClass_NMpsCell* object_ptr;
 
      object_ptr = (pwr_sClass_NMpsCell*)cellist_ptr->object_ptr;
      if (object_ptr->ExternFlag)
        return NMPS__CELLEXTERNBUSY;
 
      object_ptr->ExternOpType = NMPS_OPTYPE_EXTINSERT;
      object_ptr->ExternObjId = objid;
      object_ptr->ExternFlag = 1;
      break;
    }
    default:
      break;
    }
    break;
  }
 
  return NMPS__SUCCESS;
}
 
pwr_tStatus nmpsappl_RemoveAndKeepData(
    nmpsappl_t_ctx applctx, pwr_tObjid objid, unsigned int cell_mask)
{
  int k;
  unsigned int mask;
  nmpsappl_t_cellist* cellist_ptr;
 
  /* Remove data first */
  mask = 1;
  for (k = 0; k < applctx->cellist_count; k++, mask = mask << 1) {
    if (!(mask & cell_mask))
      continue;
 
    cellist_ptr = applctx->cellist[k];
    switch (cellist_ptr->classid) {
    case pwr_cClass_NMpsCell:
    case pwr_cClass_NMpsCell60:
    case pwr_cClass_NMpsCell120:
    case pwr_cClass_NMpsStoreCell:
    case pwr_cClass_NMpsStoreCell60:
    case pwr_cClass_NMpsStoreCell120: {
      pwr_sClass_NMpsCell* object_ptr;
 
      object_ptr = (pwr_sClass_NMpsCell*)cellist_ptr->object_ptr;
      if (object_ptr->ExternFlag)
        return NMPS__CELLEXTERNBUSY;
 
      object_ptr->ExternOpType = NMPS_OPTYPE_EXTREMOVE_OBJID;
      object_ptr->ExternObjId = objid;
      object_ptr->ExternFlag = 1;
      break;
    }
    default:
      break;
    }
  }
 
  return NMPS__SUCCESS;
}