sub_semc.c

unix下进行电报传输的源码。采用信号灯技术避免文件冲突等等

#include <stdio.h>
#include <sys/types.h>
#include <sys/ipc.h>
#include <sys/sem.h>
#include "nfcnet.h"
int  semset(void);
int  semopena(int semset_semid,int semset_semno);
int  semopenr(int semset_semid,int semset_semno);
int  semclose(int semset_semid,int semset_semno);
main()
{ int status; int semset_semid, semset_semno;
  semset_semno=0;
  semset_semid=semset();
  if(semset_semid==-1)exit(1);
  printf("semset_semid=%d\n",semset_semid);
  printf("begin semopena e\n");
  status=semopena(semset_semid,semset_semno);
  printf("status=%d\n",status);
  status=semclose(semset_semid,semset_semno);
  printf("status=%d\n",status);
  printf("begin semopenr e\n");
  status=semopenr(semset_semid,semset_semno);
  printf("status=%d\n",status);
  status=semclose(semset_semid,semset_semno);
  printf("status=%d\n",status);
  printf("begin semopena r e\n");
  status=semopena(semset_semid,semset_semno);
  printf("status=%d\n",status);
  status=semopenr(semset_semid,semset_semno);
  printf("status=%d\n",status);
  status=semclose(semset_semid,semset_semno);
  printf("status=%d\n",status);
  printf("begin semopenr a\n");
  status=semopenr(semset_semid,semset_semno);
  printf("status=%d\n",status);
  status=semopena(semset_semid,semset_semno);
  printf("status=%d\n",status);
}
int  semset(void)
{ int semset_semid;
  key_t semset_key=   P_SEMSKEY;
  int semset_nsems=   P_SEMNUMB;
  int semset_semflg=  IPC_CREAT|P_SEMACCESS;
  semset_semid=semget(semset_key,semset_nsems,semset_semflg);
  return semset_semid;
}
int  semopena(int semset_semid,int semset_semno)
{ extern int errno; int status; 
  int semset_semflg=P_SEMACCESS;
  struct sembuf *semset_sops;
  struct sembuf semset_sopsbuf;
  size_t semset_nsops=1;
  semset_sops=&semset_sopsbuf;
  semset_sopsbuf.sem_num=semset_semno;
  semset_sopsbuf.sem_op=-1;
  semset_sopsbuf.sem_flg=semset_semflg;
  status=semop(semset_semid,semset_sops,semset_nsops); 
  if(status==-1) {return -1;} else {return 0;}
}
int  semopenr(int semset_semid,int semset_semno)
{ extern int errno; int status;
  int semset_semflg=P_SEMACCESS|IPC_NOWAIT;
  struct sembuf *semset_sops;
  struct sembuf semset_sopsbuf;
  size_t semset_nsops=1;
  semset_sops=&semset_sopsbuf;
  semset_sopsbuf.sem_num=semset_semno;
  semset_sopsbuf.sem_op=-1;
  semset_sopsbuf.sem_flg=semset_semflg;
  status=semop(semset_semid,semset_sops,semset_nsops); 
  if(status==-1) {return -1;} else {return 0;}
}
int semclose(int semset_semid, int semset_semno)
{ extern int errno; int status;
  int semset_semflg=P_SEMACCESS|IPC_NOWAIT;
  struct sembuf *semset_sops;
  struct sembuf semset_sopsbuf;
  size_t semset_nsops=1;
  semset_sops=&semset_sopsbuf;
  semset_sopsbuf.sem_num=semset_semno;
  semset_sopsbuf.sem_op=1;
  semset_sopsbuf.sem_flg=semset_semflg;
  status=semop(semset_semid,semset_sops,semset_nsops); 
  if(status==-1) {return -1;} else {return 0;}
}