C에서 Linux와 공유 메모리를 사용하는 방법
내 프로젝트 중 하나에 문제가 좀 있어.
공유 메모리의 사용 예에 대해 잘 문서화되어 있는 것을 찾고 있습니다.fork()하지만 성공하지 못했다.
기본적으로 사용자가 프로그램을 시작할 때 공유 메모리에 current_path(char*인 current_path)와 file_name(char*이기도 한 file_name)의 두 가지 값을 저장해야 하는 시나리오입니다.
명령어 인수에 따라 새로운 프로세스가 시작됩니다.fork()이 프로세스에서는 file_name 변수가 읽기 전용인 동안 공유 메모리에 저장된 current_path 변수를 읽고 수정해야 합니다.
예를 들어 코드(가능한 경우)와 함께 공유 메모리에 대한 좋은 튜토리얼이 있습니까?
두 가지 접근법이 있습니다.shmget그리고.mmap에 대해 설명하겠습니다.mmap좀 더 현대적이고 유연하지만man shmget(또는 이 튜토리얼)을 참조하십시오.
그mmap()이 함수는 접근 및 권한을 제어하기 위해 고도로 맞춤 가능한 매개 변수를 사용하여 메모리 버퍼를 할당하고 필요에 따라 파일 시스템 스토리지로 백업할 수 있습니다.
다음 함수는 프로세스가 하위 프로세스와 공유할 수 있는 메모리 내 버퍼를 만듭니다.
#include <stdio.h>
#include <stdlib.h>
#include <sys/mman.h>
void* create_shared_memory(size_t size) {
// Our memory buffer will be readable and writable:
int protection = PROT_READ | PROT_WRITE;
// The buffer will be shared (meaning other processes can access it), but
// anonymous (meaning third-party processes cannot obtain an address for it),
// so only this process and its children will be able to use it:
int visibility = MAP_SHARED | MAP_ANONYMOUS;
// The remaining parameters to `mmap()` are not important for this use case,
// but the manpage for `mmap` explains their purpose.
return mmap(NULL, size, protection, visibility, -1, 0);
}
다음은 위에서 정의한 함수를 사용하여 버퍼를 할당하는 예제 프로그램입니다.부모 프로세스는 메시지를 작성하고 포크를 설정한 후 자녀가 버퍼를 수정할 때까지 기다립니다.두 프로세스 모두 공유 메모리를 읽고 쓸 수 있습니다.
#include <string.h>
#include <unistd.h>
int main() {
char parent_message[] = "hello"; // parent process will write this message
char child_message[] = "goodbye"; // child process will then write this one
void* shmem = create_shared_memory(128);
memcpy(shmem, parent_message, sizeof(parent_message));
int pid = fork();
if (pid == 0) {
printf("Child read: %s\n", shmem);
memcpy(shmem, child_message, sizeof(child_message));
printf("Child wrote: %s\n", shmem);
} else {
printf("Parent read: %s\n", shmem);
sleep(1);
printf("After 1s, parent read: %s\n", shmem);
}
}
공유 메모리의 예를 다음에 나타냅니다.
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <sys/types.h>
#include <sys/ipc.h>
#include <sys/shm.h>
#define SHM_SIZE 1024 /* make it a 1K shared memory segment */
int main(int argc, char *argv[])
{
key_t key;
int shmid;
char *data;
int mode;
if (argc > 2) {
fprintf(stderr, "usage: shmdemo [data_to_write]\n");
exit(1);
}
/* make the key: */
if ((key = ftok("hello.txt", 'R')) == -1) /*Here the file must exist */
{
perror("ftok");
exit(1);
}
/* create the segment: */
if ((shmid = shmget(key, SHM_SIZE, 0644 | IPC_CREAT)) == -1) {
perror("shmget");
exit(1);
}
/* attach to the segment to get a pointer to it: */
if ((data = shmat(shmid, NULL, 0)) == (void *)-1) {
perror("shmat");
exit(1);
}
/* read or modify the segment, based on the command line: */
if (argc == 2) {
printf("writing to segment: \"%s\"\n", argv[1]);
strncpy(data, argv[1], SHM_SIZE);
} else
printf("segment contains: \"%s\"\n", data);
/* detach from the segment: */
if (shmdt(data) == -1) {
perror("shmdt");
exit(1);
}
return 0;
}
순서:
ftok을 사용하여 경로 이름 및 프로젝트 식별자를 System V IPC 키로 변환
공유 메모리 세그먼트를 할당하는 shmget 사용
shmat를 사용하여 shmid로 식별된 공유 메모리세그먼트를 호출 프로세스의 주소 공간에 부가합니다.
메모리 영역에 대한 작업을 수행합니다.
shmdt를 사용하여 분리
이것들은 공유 메모리 사용에 관한 것입니다.
#include<sys/ipc.h>
#include<sys/shm.h>
int shmid;
int shmkey = 12222;//u can choose it as your choice
int main()
{
//now your main starting
shmid = shmget(shmkey,1024,IPC_CREAT);
// 1024 = your preferred size for share memory
// IPC_CREAT its a flag to create shared memory
//now attach a memory to this share memory
char *shmpointer = shmat(shmid,NULL);
//do your work with the shared memory
//read -write will be done with the *shmppointer
//after your work is done deattach the pointer
shmdt(&shmpointer, NULL);
이 코드 샘플을 사용해 보고 테스트했습니다.출처: http://www.makelinux.net/alp/035
#include <stdio.h>
#include <sys/shm.h>
#include <sys/stat.h>
int main ()
{
int segment_id;
char* shared_memory;
struct shmid_ds shmbuffer;
int segment_size;
const int shared_segment_size = 0x6400;
/* Allocate a shared memory segment. */
segment_id = shmget (IPC_PRIVATE, shared_segment_size,
IPC_CREAT | IPC_EXCL | S_IRUSR | S_IWUSR);
/* Attach the shared memory segment. */
shared_memory = (char*) shmat (segment_id, 0, 0);
printf ("shared memory attached at address %p\n", shared_memory);
/* Determine the segment's size. */
shmctl (segment_id, IPC_STAT, &shmbuffer);
segment_size = shmbuffer.shm_segsz;
printf ("segment size: %d\n", segment_size);
/* Write a string to the shared memory segment. */
sprintf (shared_memory, "Hello, world.");
/* Detach the shared memory segment. */
shmdt (shared_memory);
/* Reattach the shared memory segment, at a different address. */
shared_memory = (char*) shmat (segment_id, (void*) 0x5000000, 0);
printf ("shared memory reattached at address %p\n", shared_memory);
/* Print out the string from shared memory. */
printf ("%s\n", shared_memory);
/* Detach the shared memory segment. */
shmdt (shared_memory);
/* Deallocate the shared memory segment. */
shmctl (segment_id, IPC_RMID, 0);
return 0;
}
다음은 mmap의 예를 제시하겠습니다.
#include <sys/mman.h>
#include <sys/types.h>
#include <sys/stat.h>
#include <fcntl.h>
/*
* pvtmMmapAlloc - creates a memory mapped file area.
* The return value is a page-aligned memory value, or NULL if there is a failure.
* Here's the list of arguments:
* @mmapFileName - the name of the memory mapped file
* @size - the size of the memory mapped file (should be a multiple of the system page for best performance)
* @create - determines whether or not the area should be created.
*/
void* pvtmMmapAlloc (char * mmapFileName, size_t size, char create)
{
void * retv = NULL;
if (create)
{
mode_t origMask = umask(0);
int mmapFd = open(mmapFileName, O_CREAT|O_RDWR, 00666);
umask(origMask);
if (mmapFd < 0)
{
perror("open mmapFd failed");
return NULL;
}
if ((ftruncate(mmapFd, size) == 0))
{
int result = lseek(mmapFd, size - 1, SEEK_SET);
if (result == -1)
{
perror("lseek mmapFd failed");
close(mmapFd);
return NULL;
}
/* Something needs to be written at the end of the file to
* have the file actually have the new size.
* Just writing an empty string at the current file position will do.
* Note:
* - The current position in the file is at the end of the stretched
* file due to the call to lseek().
* - The current position in the file is at the end of the stretched
* file due to the call to lseek().
* - An empty string is actually a single '\0' character, so a zero-byte
* will be written at the last byte of the file.
*/
result = write(mmapFd, "", 1);
if (result != 1)
{
perror("write mmapFd failed");
close(mmapFd);
return NULL;
}
retv = mmap(NULL, size,
PROT_READ | PROT_WRITE, MAP_SHARED, mmapFd, 0);
if (retv == MAP_FAILED || retv == NULL)
{
perror("mmap");
close(mmapFd);
return NULL;
}
}
}
else
{
int mmapFd = open(mmapFileName, O_RDWR, 00666);
if (mmapFd < 0)
{
return NULL;
}
int result = lseek(mmapFd, 0, SEEK_END);
if (result == -1)
{
perror("lseek mmapFd failed");
close(mmapFd);
return NULL;
}
if (result == 0)
{
perror("The file has 0 bytes");
close(mmapFd);
return NULL;
}
retv = mmap(NULL, size,
PROT_READ | PROT_WRITE, MAP_SHARED, mmapFd, 0);
if (retv == MAP_FAILED || retv == NULL)
{
perror("mmap");
close(mmapFd);
return NULL;
}
close(mmapFd);
}
return retv;
}
언급URL : https://stackoverflow.com/questions/5656530/how-to-use-shared-memory-with-linux-in-c
'programing' 카테고리의 다른 글
| JavaScript에 상수가 있나요? (0) | 2023.01.21 |
|---|---|
| junit & java : 비공개 메서드 테스트 (0) | 2023.01.21 |
| PHP interafce mysql()은 동작하지 않지만 mysqli()는 동작합니다.왜일까요? (0) | 2023.01.21 |
| Python에서 현재 CPU 및 RAM 사용량을 얻는 방법은 무엇입니까? (0) | 2023.01.21 |
| 라라벨:글로벌 어레이의 데이터와 상수를 저장할 수 있는 장소 (0) | 2023.01.21 |