Finish semaphore source code

guowenxue

2018-12-07 6af36ae37c67c2682b44914badffab5fa9c52d06

Finish semaphore source code

 ch6_ipc/semaphore.c

@@ -9,7 +9,7 @@
#include <sys/sem.h>

#define FTOK_PATH            "/dev/zero"
#define FTOK_PROJID          0x666
#define FTOK_PROJID          0x22

union semun 
{
@@ -18,18 +18,53 @@
    unsigned short *arry;
};

int semaphore_init(void);
int semaphore_p(int semid);
int semaphore_v(int semid);
void semaphore_term(int semid);

int main(int argc, char **argv)
{
    int            semid;
    pid_t          pid;
    int            i;

    if( (semid=init_set(1)) < 0)
    if( (semid=semaphore_init()) < 0)
    {
	
    printf("semaphore initial failure: %s\n", strerror(errno)); 
        return -1;
    }

    if( (pid=fork()) < 0)
    {
        printf("fork() failure: %s\n", strerror(errno));
        return -2;
    }
    else if( 0 == pid)  /* child process */
    {
        printf("Child process start running and do something now...\n");
        sleep(3);
        printf("Child process do something over...\n");
        semaphore_v(semid);

        sleep(1);

        printf("Child process exit now\n");
        exit(0);
}

int init_set(int nums)
    printf("Parent process P operator wait child process over\n");
    semaphore_p(semid);
    printf("Parent start do something now...\n");
    sleep(2);
    printf("Child process exit and ");


    semaphore_term(semid);
    return 0;
}

int semaphore_init(void)
{
    key_t          key;
    int            semid;
@@ -41,20 +76,72 @@
    return -1;
    } 
    
    semid = semget(key, nums, IPC_CREAT|IPC_EXCL|0644);
    semid = semget(key, 1, IPC_CREAT|0644);
    if( semid < 0)
    {
    printf("semget() get semid failure: %s\n", strerror(errno)); 
    return -2;
    }


    sem_union.val = 1;
    sem_union.val = 0;
    if( semctl(semid, 0, SETVAL, sem_union)<0 )
    {
    printf("semctl() set initial value failure: %s\n", strerror(errno)); 
    return -3;
    }

    printf("Semaphore get key_t[0x%x] and semid[%d]\n", key, semid);

    return semid;
}

void semaphore_term(int semid)
{
    union semun    sem_union;
		    
    if( semctl(semid, 0, IPC_RMID, sem_union)<0 )
    {
    printf("semctl() delete semaphore ID failure: %s\n", strerror(errno)); 
    }

    return ;
}



int semaphore_p(int semid)
{
    struct sembuf _sembuf;

    _sembuf.sem_num = 0;
    _sembuf.sem_op = -1;
    _sembuf.sem_flg = SEM_UNDO; //  IPC_NOWAIT  SEM_UNDO


    if( semop(semid, &_sembuf, 1) < 0 )
    { 
        printf("semop P operator failure: %s\n", strerror(errno));
        return -1;
    }

    return 0;
}

int semaphore_v(int semid)
{
    struct sembuf _sembuf;

    _sembuf.sem_num = 0;
    _sembuf.sem_op = 1;
    _sembuf.sem_flg = SEM_UNDO; //  IPC_NOWAIT  SEM_UNDO

    if( semop(semid, &_sembuf, 1) < 0 )
    { 
        printf("semop V operator failure: %s\n", strerror(errno));
        return -1;
    }

    return 0;
}