offset+msq+shm

openair2/SDAP/nr_sdap/nr_sdap.c

@@ -24,7 +24,25 @@
 #include <sys/msg.h>
 #include <stdio.h>
 #include <string.h>
+#include <sys/socket.h>
+#include <netinet/in.h>
+#include <arpa/inet.h>
+#include <sys/types.h>
+#include <netdb.h>
+#include <stdlib.h>
+#include <sys/shm.h>
+#include <unistd.h>
 
+#include <openair2/COMMON/platform_types.h>
+#include <openair3/UTILS/conversions.h>
+#include "common/utils/LOG/log.h"
+#include <common/utils/ocp_itti/intertask_interface.h>
+#include <openair2/COMMON/gtpv1_u_messages_types.h>
+#include <openair3/ocp-gtpu/gtp_itf.h>
+#include <openair2/LAYER2/PDCP_v10.1.0/pdcp.h>
+#include <openair2/LAYER2/nr_pdcp/nr_pdcp_oai_api.h>
+#include <openair2/LAYER2/nr_rlc/nr_rlc_oai_api.h>
+#include "openair2/SDAP/nr_sdap/nr_sdap.h"
 
 uint8_t nas_qfi;
 uint8_t nas_pduid;
@@ -173,10 +191,12 @@ void set_qfi_pduid(uint8_t qfi, uint8_t pduid){
   nas_pduid = pduid;
   return;
 }
-
+#define SHM_SIZE 10000000
 void *SP_task(void *arg){
     msgbuf readBuf;
     printf("SP任务启动成功\n");
+
+
     while(1) {
       int msgId = msgget(0x1234, 0777);
       if(msgId==-1){
@@ -189,6 +209,26 @@ void *SP_task(void *arg){
         }else{
           printf("消息队列读取成功\n");
           printf("接受的shmoffset:%d",readBuf.sq.shm_offset);
+          printf("接受的shmoffset:%d",readBuf.sq.offset);
+
+
+          int shmid_data;
+          uint8_t *shm;
+          if ((shmid_data = shmget((key_t)1, SHM_SIZE,0666)) < 0) {
+            perror("shmget");
+            exit(1);}
+          if ((shm = (uint8_t *) shmat(shmid_data, NULL, 0)) == (uint8_t *) -1) {
+            perror("shmat");
+            exit(1);
+            }
+
+
+
+          shm = shm + readBuf.sq.shm_offset*65536 + readBuf.sq.offset;
+          for(int i=0;i<8;i++){
+          printf("shm=%c ",*(shm+i));
+          }
+
           bool sdap_ret = sdap_data_req(readBuf.sq.ctxt_p,
                                         readBuf.sq.ue_id,
                                         readBuf.sq.srb_flag,
@@ -196,7 +236,7 @@ void *SP_task(void *arg){
                                         readBuf.sq.mui,
                                         readBuf.sq.confirm,
                                         readBuf.sq.sdu_buffer_size,
-                                        readBuf.sq.sdu_buffer,
+                                        shm,
                                         readBuf.sq.pt_mode,
                                         readBuf.sq.sourceL2Id,
                                         readBuf.sq.destinationL2Id,

openair3/ocp-gtpu/gtp_itf.cpp

@@ -1191,15 +1191,17 @@ static int Gtpv1uHandleGpdu(int h,
 
   shm = shm + shm_offset*65536 + offset;
 
-  printf("shm_addr=%p  msgbuf_addr=%p \n",shm,(sctxt->sdu_buffer+offset));
-  for(int i=0;i<8;i++){
-    printf("shm=%c ",*(shm+i));
-  }
-  printf("\n");
-  for(int i=0;i<8;i++){
-    printf("msgbuf=%c ",*(sctxt->sdu_buffer+i));
-  }
-  printf("\n");
+  // printf("shm_addr=%p  msgbuf_addr=%p \n",shm,(sctxt->sdu_buffer+offset));
+  // for(int i=0;i<8;i++){
+  //   printf("shm=%c ",*(shm+i));
+  // }
+  // printf("\n");
+  // for(int i=0;i<8;i++){
+  //   printf("msgbuf=%c ",*(sctxt->sdu_buffer+i));
+  // }
+  // printf("\n");
+
+  printf("shm=%d  offset=%d\n",shm_offset,offset);
 
 
   pthread_mutex_unlock(&globGtp.gtp_lock);