X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?p=sim%2Fe2-interface.git;a=blobdiff_plain;f=e2sim%2Fsrc%2FSCTP%2Fe2sim_sctp.cpp;h=ce9d6498ceeee497f0babd3b9ec8612c1de6251f;hp=de68ec71a7f3654327e1ed79f4c797a0662ea27f;hb=a9733dbcc47e93a3b2843056f1d587196296c324;hpb=3ebf932d23dcbec9ed19f4a51f9d00a0a54f5124 diff --git a/e2sim/src/SCTP/e2sim_sctp.cpp b/e2sim/src/SCTP/e2sim_sctp.cpp index de68ec7..ce9d649 100644 --- a/e2sim/src/SCTP/e2sim_sctp.cpp +++ b/e2sim/src/SCTP/e2sim_sctp.cpp @@ -206,6 +206,7 @@ int sctp_accept_connection(const char *server_ip_str, const int server_fd) //Blocking call client_fd = accept(server_fd, &client_addr, &client_addr_size); + fprintf(stderr, "client fd is %d\n", client_fd); if(client_fd == -1){ perror("accept()"); close(client_fd); @@ -231,7 +232,10 @@ int sctp_accept_connection(const char *server_ip_str, const int server_fd) int sctp_send_data(int &socket_fd, sctp_buffer_t &data) { + fprintf(stderr,"in sctp send data func\n"); + fprintf(stderr,"data.len is %d", data.len); int sent_len = send(socket_fd, (void*)(&(data.buffer[0])), data.len, 0); + fprintf(stderr,"after getting sent_len\n"); if(sent_len == -1) { perror("[SCTP] sctp_send_data"); @@ -243,6 +247,7 @@ int sctp_send_data(int &socket_fd, sctp_buffer_t &data) int sctp_send_data_X2AP(int &socket_fd, sctp_buffer_t &data) { + /* int sent_len = sctp_sendmsg(socket_fd, (void*)(&(data.buffer[0])), data.len, NULL, 0, (uint32_t) X2AP_PPID, 0, 0, 0, 0); @@ -250,7 +255,8 @@ int sctp_send_data_X2AP(int &socket_fd, sctp_buffer_t &data) perror("[SCTP] sctp_send_data"); exit(1); } - + */ + return 1; } /* @@ -263,11 +269,15 @@ Outcome of recv() int sctp_receive_data(int &socket_fd, sctp_buffer_t &data) { //clear out the data before receiving + fprintf(stderr, "receive data1\n"); memset(data.buffer, 0, sizeof(data.buffer)); + fprintf(stderr, "receive data2\n"); data.len = 0; //receive data from the socket int recv_len = recv(socket_fd, &(data.buffer), sizeof(data.buffer), 0); + fprintf(stderr, "receive data3\n"); + if(recv_len == -1) { perror("[SCTP] recv");