开通博客赚积分
发布资源赚积分
分类

源码开发语言/平台
当前位置：首页 > 源码/资料 > 通讯/手机编程 > 并口编程 > 查看源码
ipc.c
资源名称：PK1111.rar　[点击查看]
上传用户：sdtbys
上传日期：2009-12-06
资源大小：13k
文件大小：10k
源码类别：

并口编程

开发平台：

C/C++

ipc.c：源码内容
  1. #include <stdio.h>
  2. #include <sys/types.h>
  3. #include <sys/ipc.h>
  4. #include <sys/msg.h>
  5. #include <sys/sem.h>
  6. #include <sys/shm.h>
  7. #include <memory.h>
  8. #include <errno.h>
  10. extern int errno;
  11. #include "ipc.h"
  13. /* typedef long key_t  (IPC KEY) */ 
  14. /* ipcs|ipcrm  IPC msg|sem|shm IPC ID IPC KEY */
  15. /* struct ipc_perm { key_t key;
  16.                      ushort uid;
  17.                      ushort gid;
  18.                      ushort cid;
  19.                      ushort cgid;
  20.                      ushort mode;}
  21. */
  25. /**********************************************************
  26.  Function msgCreate
  27.    Create message queue
  28.  Parameters :
  29. key    : key which identify message queue
  30.  Return :
  31. iMsgId : message queue id
  33. ***********************************************************/
  34. int msgCreate(key_t key)
  35. {
  36.   int iMsgId;
  37.   
  38.   iMsgId=msgget(key,IPC_CREAT | IPC_EXCL | QPERM);
  39.   if (iMsgId<0) {
  40.      if (errno==EEXIST) {
  41.         ShowMsg("msg has exist! key=%d errno=%d error=%sn",key,errno,strerror(errno));
  42.         iMsgId=msgget(key,QPERM);
  43.         if (iMsgId<0) 
  44.         {
  45.         ShowMsg("msg open failed! key=%d errno=%d error=%sn",key,errno,strerror(errno));
  46.          return(MsgOpenFail);
  47.         }
  48.         return iMsgId;
  49.      }
  50.         ShowMsg("msg create failed! key=%d errno=%d error=%sn",key,errno,strerror(errno));
  51.      return MsgCreateFail;
  52.   };
  53.   return iMsgId;
  54. }
  56. /**********************************************************
  57.  Function msgOpen
  58.    Open message queue , this queue must be existed .
  59.  Parameters :
  60. key    : key which identify message queue
  61.  Return :
  62. iMsgId : message queue id
  64. ***********************************************************/
  65. int msgOpen(key_t key)  
  66. {
  67.   int iMsgId;
  69.   if ((iMsgId=msgget(key,QPERM))==-1) {
  70.      ShowMsg("msg open failed! key=%d errno=%d error=%sn",key,errno,strerror(errno));
  71.      return MsgOpenFail;
  72.   }
  73.   return iMsgId;
  74. }
  76. /**********************************************************
  77.  Function msgStatus
  78.    Output message queue status to a file
  79.  Parameters :
  80. iMsgId : message queue id
  81. fpOut  : output file handle
  83. ***********************************************************/
  84. int msgStatus(int iMsgId)
  85. {
  86.   struct msqid_ds msg_status;
  87.   int i;
  89.   if (msgctl(iMsgId,IPC_STAT,&msg_status) < 0 ) {
  90.      return MsgStateFail;
  91.   }
  92.   /*printf("nThe Msg Status is:"); */
  93.   ShowMsg("msg id=%inuid=%ingid=%inmode=%on"
  94.   "msgnum=%inmsgqbytes=%incbytes=%in"
  95.   "lspid=%inlrpid=%in",iMsgId,
  96.   msg_status.msg_perm.uid,msg_status.msg_perm.gid,
  97.   msg_status.msg_perm.mode,msg_status.msg_qnum,
  98.   msg_status.msg_qbytes,msg_status.msg_cbytes,msg_status.msg_lspid,
  99.   msg_status.msg_lrpid);
  100.   return(0);
  101. }
  104. /**********************************************************
  105.  Function msgSendBuf
  106.    Send info to message queue
  107.  Parameters :
  108. iMsgId   : message queue id
  109. lType    : message type identify message info in the same queue
  110. pszInfo  : info to be sent
  111. iInfoLen : length of info
  113. ***********************************************************/
  114. int msgSend(int iMsgId , long lType , char *pszInfo , int iInfoLen)
  115. {
  116.   Mesg mesg;
  118.   if (iInfoLen>MaxMesgLen)
  119.    { ShowMsg("msg len error! len=%d,maxlen=%dn",iInfoLen,MaxMesgLen);
  120.      return (MsgMesgLenBad);}
  122.   mesg.MesgId=lType;
  123.   memcpy(mesg.MesgText,pszInfo,iInfoLen);
  124.   if (msgsnd(iMsgId,&mesg,iInfoLen,0)==-1) {
  125.      ShowMsg("msg send failed! errno=%d error=%sn",errno,strerror(errno));
  126.      return MsgSendFail;
  127.   }
  128.   return (0);
  129. }
  131. /**********************************************************
  132.  Function msgRecvBuf
  133.    Receive info from message queue
  134.  Parameters :
  135. iMsgId   : message queue id
  136. lType    : message type identify message info in the same queue
  137. pszInfo  : info buffer to be received
  138. iRecvLen : length of info
  139. iTimeOut : timeout , if =0 , nowait .
  141. ***********************************************************/
  142. int msgRecv(int iMsgId , long *lType , char *pszInfo , int iExptLen)
  143. {
  144.   Mesg mesg;
  145.   int iRecvLen;
  147.   if (iExptLen>MaxMesgLen)
  148.    { ShowMsg("msg len error! len=%d,maxlen=%dn",iExptLen,MaxMesgLen);
  149.      return (MsgMesgLenBad);}
  151.    /*if ((iRecvLen=msgrcv(iMsgId,&mesg,iExptLen,lType,IPC_NOWAIT))==-1) {
  152.  return MsgRecvFail;
  153.      }*/
  155.      if ((iRecvLen=msgrcv(iMsgId,&mesg,iExptLen,*lType,0))==-1) {
  156.      ShowMsg("msg recv failed! errno=%d error=%sn",errno,strerror(errno));
  157.  return MsgRecvFail;
  158.   }
  159.   memcpy(pszInfo,mesg.MesgText,iRecvLen);
  160.   *lType=mesg.MesgId;
  161.   return iRecvLen;
  162. }
  164. /**********************************************************
  165.  Function msgRemove
  166.    Remove message queue
  167.  Parameters :
  168. iMsgId   : message queue id
  170. ***********************************************************/
  171. int msgRemove(int iMsgId)
  172. {
  173.   if (msgctl(iMsgId,IPC_RMID,0) <0) {
  174.      ShowMsg("msg remove failed! errno=%d error=%sn",errno,strerror(errno));
  175.      return MsgRemoveFail;
  176.   }
  177.   return (0);
  178. }
  180. /*************************************************************
  181. Function semCreate
  182.   Create one array semaphores 
  183. Parameters
  184. key : key of identifier
  185. *************************************************************/
  186. int semCreate(key_t key)
  187. {
  188.   int iSemId,iRet;
  190.   iSemId=semget(key,1,IPC_CREAT | IPC_EXCL | QPERM);
  191.   if (iSemId<0) {
  192.      if (errno==EEXIST) {
  193.         ShowMsg("sem existed! key=%d errno=%d error=%sn",key,errno,strerror(errno));
  194.         iSemId=semget(key,0,QPERM);
  195. if (iSemId<0) 
  196.     {
  197.      ShowMsg("sem open failed! key=%d errno=%d error=%sn",key,errno,strerror(errno));
  198.      return(SemOpenFail);
  199.     }
  200.         /************************************
  201.    iRet=semctl(iSemId,0,SETVAL,0);
  202.    if(iRet<0) return(SemSetValFail);
  203.         ************************************/
  204.         return(iSemId);
  205.      }
  206.      ShowMsg("sem create failed! key=%d errno=%d error=%sn",key,errno,strerror(errno));
  207.      return(SemCreateFail);
  208.   }
  210.   iRet=semctl(iSemId,0,SETVAL,0);
  211.   if(iRet<0) 
  212.   { 
  213.    ShowMsg("sem init 0 failed! key=%d sem=%d errno=%d error=%sn",key,iSemId,errno,strerror(errno));
  214.    return(SemSetValFail);
  215.   }
  216.   return(iSemId);
  217. }
  219. /*************************************************************
  220. Function semOpen
  221.   Open one array semaphores 
  222. Parameters
  223. key : key of identifier
  224. *************************************************************/
  225. int semOpen(key_t key)
  226. {
  227.   int iSemId,iRet;
  229.   iSemId=semget(key,0,QPERM);
  230.   if (iSemId<0) {
  231.      ShowMsg("sem open failed! key=%d errno=%d error=%sn",key,errno,strerror(errno));
  232.      return(SemOpenFail);
  233.   }
  234.   /*********************************
  235.   iRet=semctl(iSemId,0,SETVAL,0);
  236.   if(iRet<0) return(SemSetValFail);
  237.   **********************************/
  238.   return(iSemId);
  239. }
  241. /*************************************************************
  242. Function semOn
  243.   if value of semp is 1 , set to 0 
  244.   if not return false 
  245. Parameters
  246. iSemId : handle of semp
  247. *************************************************************/
  248. int semLock(int iSemId)
  249. { 
  250.   struct sembuf sembuf;
  252.   sembuf.sem_num=0;
  253.   sembuf.sem_op=-1;
  254. /*sembuf.sem_flg=IPC_NOWAIT | SEM_UNDO ;*/
  255.   sembuf.sem_flg=0;
  256.   if(semop(iSemId,&sembuf,1)<0)
  257.   {
  258.    ShowMsg("sem lock failed! errno=%d error=%sn",errno,strerror(errno));
  259.    return(SemLockFail);
  260.   }
  261.   return(0);
  262. }
  264. /*************************************************************
  265. Function semOff
  266.   if value of semp is 0 , add to 1 
  267.   if not return false 
  268. Parameters
  269. iSemId : handle of semp
  270. *************************************************************/
  271. int semUnlock(int iSemId)
  272. { 
  273.   int iRet;
  274.      
  275.   struct sembuf sembuf;
  277.   sembuf.sem_num=0;
  278.   sembuf.sem_op=1;
  279. /*sembuf.sem_flg=IPC_NOWAIT | SEM_UNDO ;*/
  280.   sembuf.sem_flg=0;
  281.   if(semop(iSemId,&sembuf,1)<0)
  282.  {
  283.    ShowMsg("sem unlock failed! errno=%d error=%sn",errno,strerror(errno));
  284.   return(SemUnlockFail);
  285.   }
  286.  
  287. /*iRet=semctl(iSemId,0,SETVAL,1);
  288.   if(iRet<0) return(SemSetValFail);*/
  290.   return(0);
  291. }
  293. /*************************************************************
  294. Function semRemove
  295.   remove semaphores 
  296. Parameters
  297. iSemId : handle of semp
  298. *************************************************************/
  299. int semRemove(int iSemId)
  300. {
  301.   int iRet;
  303.   iRet=semctl(iSemId,0,IPC_RMID,0);
  304.   if (iRet<0) {
  305.      ShowMsg("sem Remove Failed errno=%d error=%sn",errno,strerror(errno));
  306.      return(SemRemoveFail);
  307.   }
  308.   return(0);
  309. }
  311. int semGetVal(int iSemId)
  312. { int semval;
  313.   semval=semctl(iSemId,0,GETVAL,0);
  314.   return (semval);
  315. }
  316. int semSetVal(int  iSemId,int val)
  317. { 
  318. /*union semun semopt;
  319.   semopt.val=val;*/
  320.   semctl(iSemId,0,SETVAL,val);
  321. }
  323. int shmCreate(key_t key,int size)
  324. {
  325.   int iShmId;
  326.   
  327.   iShmId=shmget(key,size,IPC_CREAT | IPC_EXCL | QPERM);
  328.   if (iShmId<0) {
  329.      if (errno==EEXIST) {
  330.         ShowMsg("shm has exist! key=%d errno=%d error=%sn",key,errno,strerror(errno));
  331.         iShmId=shmget(key,size,QPERM);
  332.         if (iShmId<0) 
  333.         {
  334.         ShowMsg("shm open failed! key=%d errno=%d error=%sn",key,errno,strerror(errno));
  335.          return(ShmOpenFail);
  336.         }
  337.         return iShmId;
  338.      }
  339.         ShowMsg("shm create failed! key=%d errno=%d error=%sn",key,errno,strerror(errno));
  340.      return ShmCreateFail;
  341.   };
  342.   return iShmId;
  343. }
  345. int shmOpen(key_t key,int size)  
  346. {
  347.   int iShmId;
  349.   if ((iShmId=shmget(key,size,QPERM))==-1) {
  350.      ShowMsg("shm open failed! key=%d errno=%d error=%sn",key,errno,strerror(errno));
  351.      return ShmOpenFail;
  352.   }
  353.   return iShmId;
  354. }
  356. int shmRemove(int iShmId)
  357. {
  358.   int iRet;
  360.   iRet=shmctl(iShmId,IPC_RMID,0);
  361.   if (iRet<0) {
  362.      ShowMsg("shm Remove Failed errno=%d error=%sn",errno,strerror(errno));
  363.      return(ShmRemoveFail);
  364.   }
  365.   return(0);
  366. }
  368. char *shmConnect(int iShmId)
  369. { char *addr;
  370.   addr=shmat(iShmId,0,0);
  371.   if (addr==NULL)
  372.   { 
  373.      ShowMsg("shm Connect Failed errno=%d error=%sn",errno,strerror(errno));
  374.      return(NULL);
  375.   }
  376.   return(addr);
  377. }
  379. int shmDisConnect(char *addr)
  380. { 
  381.   if (shmdt(addr)!=0)
  382.   { 
  383.      ShowMsg("shm DisConnect Failed errno=%d error=%sn",errno,strerror(errno));
  384.      return(ShmDisConnectF);
  385.   }
  386.   return(0);
  387. }