*** empty log message ***

wb/exp/wb/src/wb_provider.cpp

-/* 
- * Proview   $Id: wb_provider.cpp,v 1.3 2005-09-20 13:21:45 claes Exp $
- * Copyright (C) 2005 SSAB Oxelsund AB.
- *
- * 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 the program, if not, write to the Free Software 
- * Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA.
- */
-
-extern "C" {
-#include <unistd.h>
-#include <sys/types.h>
-#include <sys/ipc.h>
-#include <sys/msg.h>
-#include <fcntl.h>
-#include <string.h>
-#include <stdio.h>
-}
-extern "C" {
-#include "pwr.h"
-#include "pwr_class.h"
-#include "co_cdh.h"
-#include "wb_ldh_msg.h"
-}
-
-#include "wb_vext.h"
-#include "wb_provider.h"
-
-void wb_procom::put( vext_sAMsg *msg, int size, pwr_tStatus *sts)
-{
-  *sts = LDH__SUCCESS;
-  msg->Any.message_type = 1;
-  switch ( m_type) {
-  case procom_eType_Ipc:
-    if ( msgsnd( m_msgsndid, (void *)msg, size, 0) == -1) {
-      *sts = LDH__MSGSND;
-      return;
-    }
-  case procom_eType_Local:
-    memcpy( &m_msg, msg, sizeof(m_msg));
-    break;
-  }
-}
-
-void wb_procom::receive( vext_sQMsg *msg, int size, pwr_tStatus *sts)
-{
-  if ( !m_connected) {
-    key_t key;
-    int fd = -1;
-
-    fd = open( m_key, O_RDWR | O_CREAT, 0777);
-    if ( fd < 0) {
-      *sts = LDH__NOPROV;
-      return;
-    }
-    close( fd);
-
-    key = ftok( m_key, 0);
-
-    m_msgrcvid = msgget( (key_t)key, 0666 | IPC_CREAT);
-    if ( m_msgrcvid == -1) {
-      *sts = LDH__MSGGET;
-      return;
-    }
-    m_msgsndid = msgget( (key_t)(key + 1), 0666 | IPC_CREAT);
-    if ( m_msgsndid == -1) {
-      *sts = LDH__MSGGET;
-      return;
-    }
-    m_connected = 1;
-  }
-
-  if ( msgrcv( m_msgrcvid, (void *)msg, size, 0, 0) == -1) {
-    *sts = LDH__MSGRCV;
-    return;
-  }
-  *sts = LDH__SUCCESS;
-}
-
-void wb_procom::provideObject( pwr_tStatus sts, pwr_tOix oix, pwr_tOix fthoix, pwr_tOix bwsoix,
-		      pwr_tOix fwsoix, pwr_tOix fchoix, pwr_tOix lchoix, pwr_tCid cid,
-		      char *name, char *longname)
-{
-  vext_sAMsg amsg;
-  pwr_tStatus asts;
-
-  amsg.Object.Type = vext_eMsgType_Object;
-  amsg.Object.Status = sts;
-  amsg.Object.oix = oix;
-  amsg.Object.fthoix = fthoix;
-  amsg.Object.bwsoix = bwsoix;
-  amsg.Object.fwsoix = fwsoix;
-  amsg.Object.fchoix = fchoix;
-  amsg.Object.lchoix = lchoix;
-  amsg.Object.cid = cid;
-  if ( ODD(sts)) {
-    strcpy( amsg.Object.name, name);
-    strcpy( amsg.Object.longname, longname);
-  }
-
-  put( &amsg, sizeof(amsg), &asts);
-}
-
-void wb_procom::provideBody( pwr_tStatus sts, pwr_tOix oix, int size, void *body)
-{
-  vext_sAMsg amsg;
-  pwr_tStatus asts;
-
-  amsg.Object.Type = vext_eMsgType_ObjectBody;
-  amsg.ObjectBody.Status = sts;
-  amsg.ObjectBody.oix = oix;
-  if ( (int)sizeof(amsg.ObjectBody.body) < size)
-    size = sizeof(amsg.ObjectBody.body);
-  amsg.ObjectBody.size = size;
-  if ( ODD(sts))
-    memcpy( amsg.ObjectBody.body, body, size);
-  put( &amsg, sizeof(amsg), &asts);
-}
-
-void wb_procom::provideStatus( pwr_tStatus sts)
-{
-  vext_sAMsg amsg;
-  pwr_tStatus asts;
-
-  amsg.Object.Type = vext_eMsgType_Status;
-  amsg.Any.Status = sts;
-  put( &amsg, sizeof(amsg), &asts);
-}
-
-void wb_procom::dispatch( vext_sQMsg *qmsg)
-{
-  switch( qmsg->Any.Type) {
-  case vext_eMsgType_Object:
-    printf( "Object\n");
-    m_provider->object( this);
-    break;
-  case vext_eMsgType_ObjectOid:
-    printf( "ObjectOid %d\n", qmsg->Oid.Oix);
-    m_provider->objectOid( this, qmsg->Oid.Oix);
-    break;
-  case vext_eMsgType_ObjectBody:
-    printf( "ObjectBody %d\n", qmsg->Oid.Oix);
-    m_provider->objectBody( this, qmsg->Oid.Oix);
-    break;
-  case vext_eMsgType_ObjectName:
-    printf( "ObjectName %s\n", qmsg->ObjectName.Name);
-    m_provider->objectName( this, qmsg->ObjectName.Name);
-    break;
-  case vext_eMsgType_CreateObject:
-    printf( "CreateObject %s\n", qmsg->CreateObject.Name);
-    m_provider->createObject( this, qmsg->CreateObject.DestOix, qmsg->CreateObject.DestType,
-			      qmsg->CreateObject.Cid, qmsg->CreateObject.Name);
-    break;
-  case vext_eMsgType_MoveObject:
-    printf( "MoveObject %d\n", qmsg->Oid.Oix);
-    m_provider->moveObject( this, qmsg->MoveObject.Oix, qmsg->MoveObject.DestOix, 
-			      qmsg->MoveObject.DestType);
-    break;
-  case vext_eMsgType_CopyObject:
-    printf( "CopyObject %d\n", qmsg->Oid.Oix);
-    m_provider->copyObject( this, qmsg->CopyObject.Oix, qmsg->CopyObject.DestOix, 
-			      qmsg->CopyObject.DestType, qmsg->CopyObject.Name);
-    break;
-  case vext_eMsgType_DeleteObject:
-    printf( "DeleteObject %d\n", qmsg->Oid.Oix);
-    m_provider->deleteObject( this, qmsg->DeleteObject.Oix);
-    break;
-  case vext_eMsgType_DeleteFamily:
-    printf( "DeleteFamily %d\n", qmsg->Oid.Oix);
-    m_provider->deleteFamily( this, qmsg->DeleteFamily.Oix);
-    break;
-  case vext_eMsgType_RenameObject:
-    printf( "RenameObject %d\n", qmsg->Oid.Oix);
-    m_provider->renameObject( this, qmsg->RenameObject.Oix, qmsg->RenameObject.Name);
-    break;
-  case vext_eMsgType_WriteAttr:
-    printf( "WriteAttr %d\n", qmsg->Oid.Oix);
-    m_provider->writeAttribute( this, qmsg->WriteAttr.Oix, qmsg->WriteAttr.Offset, 
-				qmsg->WriteAttr.Size, qmsg->WriteAttr.Buffer);
-    break;
-  case vext_eMsgType_Commit:
-    printf( "Commit\n");
-    m_provider->commit( this);
-    break;
-  case vext_eMsgType_Abort:
-    printf( "Abort\n");
-    m_provider->abort( this);
-    break;
-  default:
-    ;
-  }
-}
-
-int wb_procom::lmsgsnd( int msgid, const void *msg_ptr, size_t msg_sz, int msgflg)
-{
-  dispatch( (vext_sQMsg *)msg_ptr);
-  return 0;
-}
-
-int wb_procom::lmsgrcv( int msgid, const void *msg_ptr, size_t msg_sz, int msgtype, 
-			int msgflg)
-{
-  memcpy( (void *)msg_ptr, &m_msg, sizeof(m_msg));
-  return 0;
-}
-
-void wb_procom::mainloop()
-{
-  vext_sQMsg qmsg;
-  pwr_tStatus sts;
-
-  for (;;) {
-    receive( &qmsg, sizeof(qmsg), &sts);
-    dispatch( &qmsg);
-  }
-}
-
-