成人免费xxxxx在线视频软件_久久精品久久久_亚洲国产精品久久久_天天色天天色_亚洲人成一区_欧美一级欧美三级在线观看

一文搞定Linux共享內存原理

系統 Linux
在Linux系統中,每個進程都有獨立的虛擬內存空間,也就是說不同的進程訪問同一段虛擬內存地址所得到的數據是不一樣的,這是因為不同進程相同的虛擬內存地址會映射到不同的物理內存地址上。

[[427282]]

在Linux系統中,每個進程都有獨立的虛擬內存空間,也就是說不同的進程訪問同一段虛擬內存地址所得到的數據是不一樣的,這是因為不同進程相同的虛擬內存地址會映射到不同的物理內存地址上。

但有時候為了讓不同進程之間進行通信,需要讓不同進程共享相同的物理內存,Linux通過 共享內存 來實現這個功能。下面先來介紹一下Linux系統的共享內存的使用。

共享內存使用

1. 獲取共享內存

要使用共享內存,首先需要使用 shmget() 函數獲取共享內存,shmget() 函數的原型如下: 

  1. int shmget(key_t key, size_t sizeint shmflg); 
  • 參數 key 一般由 ftok() 函數生成,用于標識系統的唯一IPC資源。
  • 參數 size 指定創建的共享內存大小。
  • 參數 shmflg 指定 shmget() 函數的動作,比如傳入 IPC_CREAT 表示要創建新的共享內存。

函數調用成功時返回一個新建或已經存在的的共享內存標識符,取決于shmflg的參數。失敗返回-1,并設置錯誤碼。

2. 關聯共享內存

shmget() 函數返回的是一個標識符,而不是可用的內存地址,所以還需要調用 shmat() 函數把共享內存關聯到某個虛擬內存地址上。shmat() 函數的原型如下: 

  1. void *shmat(int shmid, const void *shmaddr, int shmflg); 
  • 參數 shmid 是 shmget() 函數返回的標識符。
  • 參數 shmaddr 是要關聯的虛擬內存地址,如果傳入0,表示由系統自動選擇合適的虛擬內存地址。
  • 參數 shmflg 若指定了 SHM_RDONLY 位,則以只讀方式連接此段,否則以讀寫方式連接此段。

函數調用成功返回一個可用的指針(虛擬內存地址),出錯返回-1。

3. 取消關聯共享內存

當一個進程不需要共享內存的時候,就需要取消共享內存與虛擬內存地址的關聯。取消關聯共享內存通過 shmdt() 函數實現,原型如下: 

  1. int shmdt(const void *shmaddr); 

參數 shmaddr 是要取消關聯的虛擬內存地址,也就是 shmat() 函數返回的值。

函數調用成功返回0,出錯返回-1。

共享內存使用例子

下面通過一個例子來介紹一下共享內存的使用方法。在這個例子中,有兩個進程,分別為 進程A 和 進程B,進程A 創建一塊共享內存,然后寫入數據,進程B 獲取這塊共享內存并且讀取其內容。

進程A

  1. #include <stdio.h> 
  2. #include <unistd.h> 
  3. #include <sys/types.h> 
  4. #include <sys/ipc.h> 
  5. #include <sys/shm.h> 
  6.  
  7. #define SHM_PATH "/tmp/shm" 
  8. #define SHM_SIZE 128 
  9.  
  10. int main(int argc, char *argv[]) 
  11.     int shmid; 
  12.     char *addr; 
  13.     key_t key = ftok(SHM_PATH, 0x6666); 
  14.      
  15.     shmid = shmget(key, SHM_SIZE, IPC_CREAT|IPC_EXCL|0666); 
  16.     if (shmid < 0) { 
  17.         printf("failed to create share memory\n"); 
  18.         return -1; 
  19.     } 
  20.      
  21.     addr = shmat(shmid, NULL, 0); 
  22.     if (addr <= 0) { 
  23.         printf("failed to map share memory\n"); 
  24.         return -1; 
  25.     } 
  26.      
  27.     sprintf(addr, "%s""Hello World\n"); 
  28.      
  29.     return 0; 

進程B

  1. #include <stdio.h> 
  2. #include <string.h> 
  3. #include <unistd.h> 
  4. #include <sys/types.h> 
  5. #include <sys/ipc.h> 
  6. #include <sys/shm.h> 
  7.  
  8. #define SHM_PATH "/tmp/shm" 
  9. #define SHM_SIZE 128 
  10.  
  11. int main(int argc, char *argv[]) 
  12.     int shmid; 
  13.     char *addr; 
  14.     key_t key = ftok(SHM_PATH, 0x6666); 
  15.      
  16.     char buf[128]; 
  17.      
  18.     shmid = shmget(key, SHM_SIZE, IPC_CREAT); 
  19.     if (shmid < 0) { 
  20.         printf("failed to get share memory\n"); 
  21.         return -1; 
  22.     } 
  23.      
  24.     addr = shmat(shmid, NULL, 0); 
  25.     if (addr <= 0) { 
  26.         printf("failed to map share memory\n"); 
  27.         return -1; 
  28.     } 
  29.      
  30.     strcpy(buf, addr, 128); 
  31.     printf("%s", buf); 
  32.      
  33.     return 0; 

測試時先運行進程A,然后再運行進程B,可以看到進程B會打印出 “Hello World”,說明共享內存已經創建成功并且讀取。

共享內存實現原理

我們先通過一幅圖來了解一下共享內存的大概原理,如下圖: 

 

通過上圖可知,共享內存是通過將不同進程的虛擬內存地址映射到相同的物理內存地址來實現的,下面將會介紹Linux的實現方式。

在Linux內核中,每個共享內存都由一個名為 struct shmid_kernel 的結構體來管理,而且Linux限制了系統最大能創建的共享內存為128個。通過類型為 struct shmid_kernel 結構的數組來管理,如下: 

  1. struct shmid_ds { 
  2.  struct ipc_perm  shm_perm; /* operation perms */ 
  3.  int   shm_segsz; /* size of segment (bytes) */ 
  4.  __kernel_time_t  shm_atime; /* last attach time */ 
  5.  __kernel_time_t  shm_dtime; /* last detach time */ 
  6.  __kernel_time_t  shm_ctime; /* last change time */ 
  7.  __kernel_ipc_pid_t shm_cpid; /* pid of creator */ 
  8.  __kernel_ipc_pid_t shm_lpid; /* pid of last operator */ 
  9.  unsigned short  shm_nattch; /* noof current attaches */ 
  10.  unsigned short   shm_unused; /* compatibility */ 
  11.  void    *shm_unused2; /* ditto - used by DIPC */ 
  12.  void   *shm_unused3; /* unused */ 
  13. }; 
  14.  
  15. struct shmid_kernel 
  16. {  
  17.  struct shmid_ds  u; 
  18.  /* the following are private */ 
  19.  unsigned long  shm_npages; /* size of segment (pages) */ 
  20.  pte_t   *shm_pages; /* array of ptrs to frames -> SHMMAX */  
  21.  struct vm_area_struct *attaches; /* descriptors for attaches */ 
  22. }; 
  23.  
  24. static struct shmid_kernel *shm_segs[SHMMNI]; // SHMMNI等于128 

從注釋可以知道 struct shmid_kernel 結構體各個字段的作用,比如 shm_npages 字段表示共享內存使用了多少個內存頁。而 shm_pages 字段指向了共享內存映射的虛擬內存頁表項數組等。

另外 struct shmid_ds 結構體用于管理共享內存的信息,而 shm_segs數組 用于管理系統中所有的共享內存。

shmget() 函數實現

通過前面的例子可知,要使用共享內存,首先需要調用 shmget() 函數來創建或者獲取一塊共享內存。shmget() 函數的實現如下: 

  1. asmlinkage long sys_shmget (key_t keyint sizeint shmflg) 
  2.  struct shmid_kernel *shp; 
  3.  int err, id = 0; 
  4.  
  5.  down(&current->mm->mmap_sem); 
  6.  spin_lock(&shm_lock); 
  7.  if (size < 0 || size > shmmax) { 
  8.   err = -EINVAL; 
  9.  } else if (key == IPC_PRIVATE) { 
  10.   err = newseg(key, shmflg, size); 
  11.  } else if ((id = findkey (key)) == -1) { 
  12.   if (!(shmflg & IPC_CREAT)) 
  13.    err = -ENOENT; 
  14.   else 
  15.    err = newseg(key, shmflg, size); 
  16.  } else if ((shmflg & IPC_CREAT) && (shmflg & IPC_EXCL)) { 
  17.   err = -EEXIST; 
  18.  } else { 
  19.   shp = shm_segs[id]; 
  20.   if (shp->u.shm_perm.mode & SHM_DEST) 
  21.    err = -EIDRM; 
  22.   else if (size > shp->u.shm_segsz) 
  23.    err = -EINVAL; 
  24.   else if (ipcperms (&shp->u.shm_perm, shmflg)) 
  25.    err = -EACCES; 
  26.   else 
  27.    err = (int) shp->u.shm_perm.seq * SHMMNI + id; 
  28.  } 
  29.  spin_unlock(&shm_lock); 
  30.  up(&current->mm->mmap_sem); 
  31.  return err; 

shmget() 函數的實現比較簡單,首先調用 findkey() 函數查找值為key的共享內存是否已經被創建,findkey() 函數返回共享內存在 shm_segs數組 的索引。如果找到,那么直接返回共享內存的標識符即可。否則就調用 newseg() 函數創建新的共享內存。newseg() 函數的實現也比較簡單,就是創建一個新的 struct shmid_kernel 結構體,然后設置其各個字段的值,并且保存到 shm_segs數組 中。

shmat() 函數實現

shmat() 函數用于將共享內存映射到本地虛擬內存地址,由于 shmat() 函數的實現比較復雜,所以我們分段來分析這個函數: 

  1. asmlinkage long sys_shmat (int shmid, char *shmaddr, int shmflg, ulong *raddr) 
  2.  struct shmid_kernel *shp; 
  3.  struct vm_area_struct *shmd; 
  4.  int err = -EINVAL; 
  5.  unsigned int id; 
  6.  unsigned long addr; 
  7.  unsigned long len; 
  8.  
  9.  down(&current->mm->mmap_sem); 
  10.  spin_lock(&shm_lock); 
  11.  if (shmid < 0) 
  12.   goto out
  13.  
  14.  shp = shm_segs[id = (unsigned int) shmid % SHMMNI]; 
  15.  if (shp == IPC_UNUSED || shp == IPC_NOID) 
  16.   goto out

上面這段代碼主要通過 shmid 標識符來找到共享內存描述符,上面說過系統中所有的共享內存到保存在 shm_segs 數組中。 

  1. if (!(addr = (ulong) shmaddr)) { 
  2.  if (shmflg & SHM_REMAP) 
  3.   goto out
  4.  err = -ENOMEM; 
  5.  addr = 0; 
  6. again: 
  7.  if (!(addr = get_unmapped_area(addr, shp->u.shm_segsz))) // 獲取一個空閑的虛擬內存空間 
  8.   goto out
  9.  if(addr & (SHMLBA - 1)) { 
  10.   addr = (addr + (SHMLBA - 1)) & ~(SHMLBA - 1); 
  11.   goto again; 
  12.  } 
  13. else if (addr & (SHMLBA-1)) { 
  14.  if (shmflg & SHM_RND) 
  15.   addr &= ~(SHMLBA-1);       /* round down */ 
  16.  else 
  17.   goto out

上面的代碼主要找到一個可用的虛擬內存地址,如果在調用 shmat() 函數時沒有指定了虛擬內存地址,那么就通過 get_unmapped_area() 函數來獲取一個可用的虛擬內存地址。 

  1. spin_unlock(&shm_lock); 
  2.  err = -ENOMEM; 
  3.  shmd = kmem_cache_alloc(vm_area_cachep, SLAB_KERNEL); 
  4.  spin_lock(&shm_lock); 
  5.  if (!shmd) 
  6.   goto out
  7.  if ((shp != shm_segs[id]) || (shp->u.shm_perm.seq != (unsigned int) shmid / SHMMNI)) { 
  8.   kmem_cache_free(vm_area_cachep, shmd); 
  9.   err = -EIDRM; 
  10.   goto out
  11.  } 

上面的代碼主要通過調用 kmem_cache_alloc() 函數創建一個 vm_area_struct 結構,在內存管理一章知道,vm_area_struct 結構用于管理進程的虛擬內存空間。 

  1. shmd->vm_private_data = shm_segs + id; 
  2.  shmd->vm_start = addr; 
  3.  shmd->vm_end = addr + shp->shm_npages * PAGE_SIZE; 
  4.  shmd->vm_mm = current->mm; 
  5.  shmd->vm_page_prot = (shmflg & SHM_RDONLY) ? PAGE_READONLY : PAGE_SHARED; 
  6.  shmd->vm_flags = VM_SHM | VM_MAYSHARE | VM_SHARED 
  7.     | VM_MAYREAD | VM_MAYEXEC | VM_READ | VM_EXEC 
  8.     | ((shmflg & SHM_RDONLY) ? 0 : VM_MAYWRITE | VM_WRITE); 
  9.  shmd->vm_file = NULL
  10.  shmd->vm_offset = 0; 
  11.  shmd->vm_ops = &shm_vm_ops; 
  12.  
  13.  shp->u.shm_nattch++;     /* prevent destruction */ 
  14.  spin_unlock(&shm_lock); 
  15.  err = shm_map(shmd); 
  16.  spin_lock(&shm_lock); 
  17.  if (err) 
  18.   goto failed_shm_map; 
  19.  
  20.  insert_attach(shp,shmd);  /* insert shmd into shp->attaches */ 
  21.  
  22.  shp->u.shm_lpid = current->pid; 
  23.  shp->u.shm_atime = CURRENT_TIME
  24.  
  25.  *raddr = addr; 
  26.  err = 0; 
  27. out
  28.  spin_unlock(&shm_lock); 
  29.  up(&current->mm->mmap_sem); 
  30.  return err; 
  31.  ... 

上面的代碼主要是設置剛創建的 vm_area_struct 結構的各個字段,比較重要的是設置其 vm_ops 字段為 shm_vm_ops,shm_vm_ops 定義如下: 

  1. static struct vm_operations_struct shm_vm_ops = { 
  2.  shm_open,  /* open - callback for a new vm-area open */ 
  3.  shm_close,  /* close - callback for when the vm-area is released */ 
  4.  NULL,   /* no need to sync pages at unmap */ 
  5.  NULL,   /* protect */ 
  6.  NULL,   /* sync */ 
  7.  NULL,   /* advise */ 
  8.  shm_nopage,  /* nopage */ 
  9.  NULL,   /* wppage */ 
  10.  shm_swapout  /* swapout */ 
  11. }; 

shm_vm_ops 的 nopage 回調為 shm_nopage() 函數,也就是說,當發生頁缺失異常時將會調用此函數來恢復內存的映射。

從上面的代碼可看出,shmat() 函數只是申請了進程的虛擬內存空間,而共享內存的物理空間并沒有申請,那么在什么時候申請物理內存呢?答案就是當進程發生缺頁異常的時候會調用 shm_nopage() 函數來恢復進程的虛擬內存地址到物理內存地址的映射。

shm_nopage() 函數實現

shm_nopage() 函數是當發生內存缺頁異常時被調用的,代碼如下: 

  1. tatic struct page * shm_nopage(struct vm_area_struct * shmd, unsigned long address, int no_share) 
  2.  pte_t pte; 
  3.  struct shmid_kernel *shp; 
  4.  unsigned int idx; 
  5.  struct page * page; 
  6.  
  7.  shp = *(struct shmid_kernel **) shmd->vm_private_data; 
  8.  idx = (address - shmd->vm_start + shmd->vm_offset) >> PAGE_SHIFT; 
  9.  
  10.  spin_lock(&shm_lock); 
  11. again: 
  12.  pte = shp->shm_pages[idx]; // 共享內存的頁表項 
  13.  if (!pte_present(pte)) {   // 如果內存頁不存在 
  14.   if (pte_none(pte)) { 
  15.    spin_unlock(&shm_lock); 
  16.    page = get_free_highpage(GFP_HIGHUSER); // 申請一個新的物理內存頁 
  17.    if (!page) 
  18.     goto oom; 
  19.    clear_highpage(page); 
  20.    spin_lock(&shm_lock); 
  21.    if (pte_val(pte) != pte_val(shp->shm_pages[idx])) 
  22.     goto changed; 
  23.   } else { 
  24.    ... 
  25.   } 
  26.   shm_rss++; 
  27.   pte = pte_mkdirty(mk_pte(page, PAGE_SHARED));   // 創建頁表項 
  28.   shp->shm_pages[idx] = pte;                      // 保存共享內存的頁表項 
  29.  } else 
  30.   --current->maj_flt;  /* was incremented in do_no_page */ 
  31.  
  32. done: 
  33.  get_page(pte_page(pte)); 
  34.  spin_unlock(&shm_lock); 
  35.  current->min_flt++; 
  36.  return pte_page(pte); 
  37.  ... 

shm_nopage() 函數的主要功能是當發生內存缺頁時,申請新的物理內存頁,并映射到共享內存中。由于使用共享內存時會映射到相同的物理內存頁上,從而不同進程可以共用此塊內存。  

 

責任編輯:龐桂玉 來源: 良許Linux
相關推薦

2024-01-09 08:24:47

JMM核心線程

2024-03-26 00:33:59

JVM內存對象

2021-10-25 16:01:01

Linux設備樹字符串

2021-08-31 07:02:34

數據響應Vue偵測數據變化

2021-05-12 18:22:36

Linux 內存管理

2019-09-23 10:51:14

JavaJava虛擬機Linux

2025-04-09 05:22:00

2023-12-15 15:55:24

Linux線程同步

2025-06-09 04:00:00

2021-03-28 18:40:02

LinuxWindowsJava

2021-08-13 05:50:01

ContainerdDockerKubernetes

2020-10-29 08:55:04

微服務

2021-04-30 19:53:53

HugePages大內存頁物理

2021-10-20 07:18:51

Linux延時隊列

2020-01-14 12:08:32

內存安全

2022-08-17 18:25:37

Java分布式搜索引擎

2021-08-31 07:02:20

Diff算法DOM

2023-09-08 08:20:46

ThreadLoca多線程工具

2025-04-07 03:02:00

電腦內存數據

2021-04-02 06:17:10

大數加減乘除數據結構算法
點贊
收藏

51CTO技術棧公眾號

主站蜘蛛池模板: 91欧美精品成人综合在线观看 | 欧美在线a| 伊人网在线看 | 成人在线精品 | 日韩一区二区三区在线观看 | 草久久久 | 成人在线一区二区三区 | 精品视频在线观看 | 精品av天堂毛片久久久借种 | 日韩午夜电影 | 中文字幕日韩专区 | 九九综合 | 一级毛片视频 | 欧美成人精品激情在线观看 | 亚洲欧美视频一区 | 午夜精品福利视频 | 亚洲伦理自拍 | 日本午夜免费福利视频 | 久久影音先锋 | 色吧综合网 | 日韩欧美在线视频一区 | 免费观看日韩精品 | 盗摄精品av一区二区三区 | 久久久久国产一区二区三区四区 | 日本免费一区二区三区 | 天堂成人av| 亚洲欧美综合 | 色.com| 欧美日韩国产中文 | 日韩精品视频在线 | 国产一区二区影院 | 久久久久久久av | 一区二区三区视频在线 | 国产精品一区免费 | 午夜免费在线观看 | 国产激情 | 成人在线播放 | 九九热re| 亚洲国产精品视频 | 久久国产精品免费一区二区三区 | 国产一区二区三区免费 |