반응형
C에서 Linux와 공유 메모리를 사용하는 방법
내 프로젝트 중 하나에 약간의 문제가 있습니다.
나는 공유 메모리를 사용하는 잘 문서화 된 예를 사용하고 노력 fork()했지만 성공하지 않았습니다.
: 기본적으로 시나리오는 사용자가 프로그램을 시작할 때, 나는 공유 메모리에 두 개의 값을 필요가 있습니다. CURRENT_PATH A는 문자 * 와 FILE_NAME 또한 문자 *를 .
인수에 따라 명령 새 프로세스가 시작 fork()되고 해당 프로세스 는 공유 메모리에 저장된 CURRENT_PATH 변수 를 읽고 수정해야 우리 하며 FILE_NAME 변수는 읽기 전용입니다.
저에게 지시 할 수있는 예제 코드 (심각한 경우)가있는 좋은 튜토리얼이있는 공유 메모리에?
고마워, bleepzter
두 가지 접근 방식이 있습니다 : 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: */
data = shmat(shmid, NULL, 0);
if (data == (char *)(-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
반응형
'IT' 카테고리의 다른 글
| mongoose 대 mongodb (nodejs 모듈 / 확장), 어느 것이 더 낫입니까? (0) | 2020.08.10 |
|---|---|
| c # .net의 디렉토리에있는 모든 파일을 반복하는 방법은 무엇입니까? (0) | 2020.08.10 |
| 특정 경로에 대한 변경 사항을 무시하는 'git log'만들기 (0) | 2020.08.10 |
| 함수에서 '벡터'를 반환해도되는 이유는 무엇입니까? (0) | 2020.08.10 |
| Python에서 만든 MD5 해시가 쉘에서 echo 및 md5sum을 사용하여 만든 것과 다른 이유는 무엇입니까? (0) | 2020.08.10 |