external/srs
1
0
Fork 0
mirror of https://github.com/ossrs/srs.git synced 2025-02-15 04:42:04 +00:00
Code Issues Releases Wiki Activity

Update research zerocopy

Browse source
This commit is contained in:
winlin 2020-04-19 22:16:54 +08:00
parent c362bfc3ab
commit 2e9a561acf
2 changed files with 7 additions and 6 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

6
trunk/research/msg_zerocopy/client.cpp
View file

@ -28,8 +28,8 @@ int main(int argc, char** argv)
sockaddr_in peer; sockaddr_in peer;
memset(&peer, 0, sizeof(sockaddr_in)); memset(&peer, 0, sizeof(sockaddr_in));
int port = 8000; int port = atoi(argv[2]);
const char* host = "127.0.0.1"; char* host = argv[1];
peer.sin_family = AF_INET; peer.sin_family = AF_INET;
peer.sin_port = htons(port); peer.sin_port = htons(port);
peer.sin_addr.s_addr = inet_addr(host); peer.sin_addr.s_addr = inet_addr(host);
@ -54,7 +54,7 @@ int main(int argc, char** argv)
r0 = st_recvmsg(stfd, &msg, 0, ST_UTIME_NO_TIMEOUT); r0 = st_recvmsg(stfd, &msg, 0, ST_UTIME_NO_TIMEOUT);
assert(r0 > 0); assert(r0 > 0);
printf("From %s:%d %d bytes, flags %#x, %s\n", inet_ntoa(peer.sin_addr), ntohs(peer.sin_port), r0, printf("Pong %s:%d %d bytes, flags %#x, %s\n", inet_ntoa(peer.sin_addr), ntohs(peer.sin_port), r0,
msg.msg_flags, msg.msg_iov->iov_base); msg.msg_flags, msg.msg_iov->iov_base);
return 0; return 0;

7
trunk/research/msg_zerocopy/server.cpp
View file

@ -29,10 +29,11 @@ int main(int argc, char** argv)
sockaddr_in addr; sockaddr_in addr;
memset(&addr, 0, sizeof(sockaddr_in)); memset(&addr, 0, sizeof(sockaddr_in));
int port = 8000; int port = atoi(argv[2]);
char* host = argv[1];
addr.sin_family = AF_INET; addr.sin_family = AF_INET;
addr.sin_port = htons(port); addr.sin_port = htons(port);
addr.sin_addr.s_addr = inet_addr("0.0.0.0"); addr.sin_addr.s_addr = inet_addr(host);
r0 = bind(fd, (sockaddr *)&addr, sizeof(sockaddr_in)); r0 = bind(fd, (sockaddr *)&addr, sizeof(sockaddr_in));
assert(!r0); assert(!r0);
@ -40,7 +41,7 @@ int main(int argc, char** argv)
st_netfd_t stfd = st_netfd_open_socket(fd); st_netfd_t stfd = st_netfd_open_socket(fd);
assert(stfd); assert(stfd);
printf("Listen at udp://%d\n", port); printf("Listen at udp://%s:%d\n", host, port);
msghdr msg; msghdr msg;
memset(&msg, 0, sizeof(msghdr)); memset(&msg, 0, sizeof(msghdr));