all

Author: sanxincao

.vscode/ipch/100f666c63c44fd5/mmap_address.bin

@@ -0,0 +1,89 @@
+//common.c
+#include "common.h"
+
+/*
+key_t GetKey(const char * pathname)
+{
+    //int fd = open(pathname,O_CREAT,0666);
+    int fd = open("log.txt",O_RDWR|O_CREAT,S_IRWXU);
+    if(fd < 0)
+    {
+        perror("open file error");
+        return -1;
+    }
+    close(fd);
+    return ftok(pathname,0);
+}
+*/
+
+int GetShmId(key_t key)
+{
+    int shmid;
+
+    shmid = shmget(key,SHM_SIZE,IPC_CREAT|0666);
+    if(shmid < 0)
+    {
+        perror("Receiver: Shmget Error");
+        exit(EXIT_FAILURE);
+    }
+
+    return shmid;
+}
+
+/*
+* create mutex + semaphore
+* init those value
+*/
+void SemInit()
+{
+     /*
+     * Funtion Prototype: 
+     *
+     *  sem_t *sem_open(const char *name, int oflag,
+     *                  mode_t mode, unsigned int value);
+     *                 
+     * name     : MUTEX_NAME    "mutex_shm"
+     * oflag    : O_CREAT       Create and initialize it if not exist
+     * mode_t   : file perssion -rw-r--r--
+     * value    : 1
+     */
+     if((sem_open(MUTEX_NAME,O_CREAT,0644,1)) < 0)
+     {
+        perror("sem_open");
+        exit(EXIT_FAILURE);
+     }
+
+     if((sem_open(FULL_NAME,O_CREAT,0644,0)) < 0){
+        perror("sem_open");
+        exit(EXIT_FAILURE);
+     }
+}
+
+
+/*
+* close and unlink semaphore that we crated
+*/
+void SemDestroy()
+{
+    sem_t * mutexPtr = sem_open(MUTEX_NAME,O_CREAT); 
+    sem_t * fullPtr= sem_open(FULL_NAME,O_CREAT);
+
+    /* Destroy mutex */
+    sem_close(mutexPtr);                // int sem_close(sem_t *sem);
+    sem_unlink(MUTEX_NAME);         // int sem_unlink(const char *name);
+
+    /* Destory full*/
+    sem_close(fullPtr);
+    sem_unlink(FULL_NAME);
+}
+
+
+void  P(sem_t *semPtr)
+{
+    sem_wait(semPtr);                   //int sem_wait(sem_t *sem);
+}
+
+void  V(sem_t *semPtr)
+{
+    sem_post(semPtr);                   //int sem_post(sem_t *sem);
+}

.vscode/ipch/100f6b6c63c45854/mmap_address.bin

@@ -0,0 +1,51 @@
+//common.h
+#ifndef   _COMMON_H_
+#define   _COMMON_H_
+
+
+#include <stdio.h>
+#include <stdlib.h>
+#include <string.h>
+
+#include <sys/stat.h>
+#include <fcntl.h>
+#include <pthread.h>  
+#include <semaphore.h>
+
+#include <sys/types.h>
+
+
+#include <unistd.h>
+
+#include <sys/ipc.h>
+#include <sys/shm.h>
+
+
+static const char * MUTEX_NAME = "mutex_shm";
+static const char * FULL_NAME  = "full_shm";
+//static const char * PATH_NAME = "tmp/shmtemp";
+
+
+//constant define
+#define SHM_SIZE 1024
+
+#define KEY_NUM 1000
+
+/*
+key_t GetKey(const char * pathname);
+*/
+
+int GetShmId(key_t key);
+/*
+* create mutex + semaphore
+* init those value
+*/
+void SemInit();
+
+void SemDestroy();
+
+void  P(sem_t *sem);
+
+void  V(sem_t *sem);
+
+#endif

.vscode/ipch/9180a492c5fead1/mmap_address.bin

@@ -0,0 +1,22 @@
+//init.c
+#include "common.h"
+
+int main(int argc, char const *argv[])
+{
+    key_t key;
+    int semid;          //semaphore id
+    int shmid;          //shared memory id
+
+
+    /* Create key*/
+    key = KEY_NUM;
+
+    /* Initialize Semaphore*/
+    SemInit();
+
+    /* TODO Initialize Shared Memory*/ 
+    GetShmId(key);
+
+    printf("End of initialize\n");
+    return 0;
+}

.vscode/ipch/a0d8008661ba4a8e/mmap_address.bin

@@ -0,0 +1,48 @@
+//receiver.c
+#include "common.h"
+//key
+key_t key;
+
+//shared memory
+int shmid;
+char * shmptr;
+char result[SHM_SIZE];
+
+//semaphore 
+sem_t * full;
+sem_t * mutex;
+                            //semaphore
+
+
+void Init()
+{
+    key = KEY_NUM;                  //init key
+    shmid  = GetShmId(key);         // init shared memory
+    shmptr = shmat(shmid,NULL,0);       // attach segement to vitural ...?
+    //semaphore init
+    full = sem_open(FULL_NAME,O_CREAT);
+    mutex = sem_open(MUTEX_NAME,O_CREAT);
+}
+
+void ReadMessage()
+{
+    P(full);
+    P(mutex);                       
+    strcpy(result,shmptr);
+    V(mutex);
+}
+
+int main(int argc, char const *argv[])
+{
+
+
+    Init();
+
+    /*waiting for user to input message*/
+    ReadMessage();
+
+    printf("Receiver : message is %s\n",result);
+    SemDestroy();
+    printf("Receiver :  Process End \n");
+    return 0;
+}

.vscode/ipch/a6f5433611532f31/SENDER.ipch

@@ -0,0 +1,53 @@
+//sender.c
+#include "common.h"
+#include <stdio.h>
+
+//key
+key_t key;
+
+//shared memory
+int shmid;
+char * shmptr;
+char input[SHM_SIZE];
+
+//semaphore 
+sem_t * full;
+sem_t * mutex;
+                            //semaphore
+
+
+void Init()
+{
+    key = KEY_NUM;                  //init key
+    shmid  = GetShmId(key);         // init shared memory
+    shmptr = shmat(shmid,NULL,0);       // attach segement to vitural ...?
+    //semaphore init
+    full = sem_open(FULL_NAME,O_CREAT);
+    mutex = sem_open(MUTEX_NAME,O_CREAT);
+}
+
+void SaveMessage()
+{
+
+    P(mutex);                       
+    strcpy(shmptr,input);
+    V(mutex);
+
+    V(full);
+}
+
+int main(int argc, char const *argv[])
+{
+
+
+    Init();
+
+    /*waiting for user to input message*/
+
+    fgets(input, 1024, stdin);              //input message from shell 
+
+    SaveMessage();
+
+    printf("Sender:  Process End\n");
+    return 0;
+}