diff --git a/offloading_binaries/TCPServer/Makefile b/offloading_binaries/TCPServer/Makefile deleted file mode 100644 index 6f47b9e..0000000 --- a/offloading_binaries/TCPServer/Makefile +++ /dev/null @@ -1,20 +0,0 @@ -CC = gcc -CFLAGS = -pie -fPIE -TARGET = TCPServer - -OBJS = $(patsubst %.c, %.o, $(wildcard *.c)) -HEADERS = $(wildcard *.h) - -all: $(TARGET) - -%.o: %.c $(HEADERS) - $(CC) $(CFLAGS) -c $< -o $@ - -.PRECIOUS: $(TARGET) $(OBJS) - -$(TARGET): $(OBJS) - $(CC) $(OBJS) -Wall $(CFLAGS) -o $@ - -clean: - -rm -f *.o - -rm -f $(TARGET) diff --git a/offloading_binaries/TCPServer/TCPServer b/offloading_binaries/TCPServer/TCPServer deleted file mode 100755 index cf04ffd..0000000 Binary files a/offloading_binaries/TCPServer/TCPServer and /dev/null differ diff --git a/offloading_binaries/TCPServer/main.c b/offloading_binaries/TCPServer/main.c deleted file mode 100644 index 5c14665..0000000 --- a/offloading_binaries/TCPServer/main.c +++ /dev/null @@ -1,133 +0,0 @@ -/* - * This program is free software: you can redistribute it and/or modify - * it under the terms of the GNU General Public License as published by - * the Free Software Foundation, either version 3 of the License, or - * (at your option) any later version. - */ - -#include -#include -#include -#include -#include -#include -#include -#include -#include -#include -#include -#include -#include -#include -#include - -#define ETH_P_IP 0x0800 /* Internet Protocol packet */ -#define ETH_ALEN 6 /* from */ -#define ETH_P_ALL 0x0003 - -#define MY_DEST_MAC0 0xba -#define MY_DEST_MAC1 0xf6 -#define MY_DEST_MAC2 0xb1 -#define MY_DEST_MAC3 0x71 -#define MY_DEST_MAC4 0x09 -#define MY_DEST_MAC5 0x64 - -#define DEFAULT_IF "wlan0" -#define BUF_SIZ 8192 - -int main(int argc, char *argv[]) -{ - int slotLength = 10000; // in microseconds - int quota = 1000000000; // Bytes per slot, default 1GB/slot - int sentInSlot = 0, slot = 1; - double elapsedTime; - - struct iovec iov; - int sockfd, listenfd; - struct ifreq if_idx; - struct ifreq if_mac; - int tx_len = 0; - char sendbuf[BUF_SIZ]; - struct ether_header *eh = (struct ether_header *) sendbuf; - struct iphdr *iph = (struct iphdr *) (sendbuf + sizeof(struct ether_header)); - struct sockaddr_ll socket_address; - char ifName[IFNAMSIZ]; - int i, j, ret, sendsize=1488, packet_num=1000000000, offset = 0, port; - int fd; /* file descriptor for file to send */ - struct sockaddr_in servaddr,cliaddr; - socklen_t clilen; - struct timeval t_start,t_end,t_now; - - signal(SIGPIPE, SIG_IGN); - - if (argc > 1) - port = atoi(argv[1]); - else - { - printf("Usage: TCPServer port rate"); - exit(1); - } - - if (argc > 2) - quota = atoi(argv[2]) / (1000000 / slotLength); - - - listenfd = socket(AF_INET, SOCK_STREAM, 0); - - - bzero(&servaddr,sizeof(servaddr)); - servaddr.sin_family = AF_INET; - servaddr.sin_addr.s_addr = htonl(INADDR_ANY); - servaddr.sin_port = htons(port); - bind(listenfd, (struct sockaddr *)&servaddr, sizeof(servaddr)); - listen(listenfd, 1); - - for(;;) - { - clilen=sizeof(cliaddr); - sockfd = accept(listenfd,(struct sockaddr *)&cliaddr, &clilen); - printf("Accepted.\n"); - //setsockopt(sd, SOL_SOCKET, SO_NOSIGPIPE, (void *)&set, sizeof(int)); - - gettimeofday(&t_start, NULL); - while (offset < packet_num) - { - if ((packet_num - offset) < quota) - { - quota = packet_num - offset; - } - while (sentInSlot < quota) - { - ret = send(sockfd, sendbuf, (quota - sentInSlot < 4096) ? quota - sentInSlot : 4096, 0); - if (ret <= 0) - { - printf("send fail\n"); - slot = 1; - sentInSlot = 0; - offset = 0; - goto RESTART; - } - offset += ret; - sentInSlot = sentInSlot + ret; - } - gettimeofday(&t_now, NULL); - elapsedTime = (t_now.tv_sec-t_start.tv_sec)*1000000.0+(t_now.tv_usec-t_start.tv_usec); - //printf("sent %d, quota %d, packet_num %d, usleep %lf\n", offset, quota, packet_num, slotLength * slot - elapsedTime); - if (elapsedTime < slotLength * slot) - { - usleep((int)(slotLength * slot - elapsedTime)); - } - sentInSlot = 0; - slot++; - - } -RESTART: - close(sockfd); - gettimeofday(&t_end, NULL); - printf("%lf\n", (t_end.tv_sec-t_start.tv_sec)*1000.0+(t_end.tv_usec-t_start.tv_usec)/1000.0); - } - - close(fd); - - return 0; -} diff --git a/offloading_binaries/client_recv_normaltcp/client_recv_normaltcp b/offloading_binaries/client_recv_normaltcp/client_recv_normaltcp index 3583e56..87af88f 100755 Binary files a/offloading_binaries/client_recv_normaltcp/client_recv_normaltcp and b/offloading_binaries/client_recv_normaltcp/client_recv_normaltcp differ diff --git a/offloading_binaries/client_recv_normaltcp/main.c b/offloading_binaries/client_recv_normaltcp/main.c index 37e75bc..9c106b4 100644 --- a/offloading_binaries/client_recv_normaltcp/main.c +++ b/offloading_binaries/client_recv_normaltcp/main.c @@ -52,8 +52,8 @@ int main(int argc, char *argv[]) sockfd = socket(AF_INET, SOCK_STREAM, 0); bzero(&servaddr, sizeof(servaddr)); servaddr.sin_family = AF_INET; - servaddr.sin_addr.s_addr = inet_addr(argv[2]); - servaddr.sin_port = htons(atoi(argv[3])); + servaddr.sin_addr.s_addr = inet_addr(argv[1]); + servaddr.sin_port = htons(atoi(argv[2])); // connect socket if (connect(sockfd, (struct sockaddr *)&servaddr, sizeof(servaddr)) < 0) @@ -84,8 +84,8 @@ int main(int argc, char *argv[]) if (ret <= 0) { - if (errno == 0) - { + if (errno == 0 || errno == 2) + { if (argc > 4) close(fd); break; @@ -109,8 +109,6 @@ int main(int argc, char *argv[]) total_bytes_recv, elapsedTime, total_bytes_recv * 8 / elapsedTime); close(sockfd); - if (argc > 4) - close(fd); return 0; } diff --git a/offloading_binaries/client_recv_normaltcp/main.o b/offloading_binaries/client_recv_normaltcp/main.o index e22cc65..10c288a 100644 Binary files a/offloading_binaries/client_recv_normaltcp/main.o and b/offloading_binaries/client_recv_normaltcp/main.o differ diff --git a/offloading_binaries/makeall.sh b/offloading_binaries/makeall.sh index f8d57e3..6248c20 100644 --- a/offloading_binaries/makeall.sh +++ b/offloading_binaries/makeall.sh @@ -1,3 +1,4 @@ +# client sender cd client_send_normaltcp_sendfile && make cd ../ cd client_send_normaltcp_splice && make @@ -8,14 +9,20 @@ cd client_send_normaludp && make cd ../ cd client_send_normaltcp && make cd ../ +# client read file only cd client_readfile_only && make cd ../ +# client receiver cd client_recv_normaltcp_splice && make cd ../ cd client_recv_normaltcp && make cd ../ cd client_recv_normaludp && make cd ../ +# server sender +cd server_send_normaltcp && make +cd ../ +# server receiver cd server_recv_normaltcp && make cd ../ cd server_recv_normaludp && make diff --git a/offloading_binaries/server_send_normaltcp/Makefile b/offloading_binaries/server_send_normaltcp/Makefile new file mode 100644 index 0000000..6c73a48 --- /dev/null +++ b/offloading_binaries/server_send_normaltcp/Makefile @@ -0,0 +1,18 @@ +#CC = /media/Lucifer/android/lib/android-18-toolchain/bin/arm-linux-androideabi-gcc +CC1 = arm-linux-androideabi-gcc +CC2 = gcc +CFLAGS = -pie -fPIE +TARGET1 = server_m_send_normaltcp +TARGET2 = server_send_normaltcp + +all: $(TARGET1) $(TARGET2) + +$(TARGET1): main.c + $(CC1) main.c -Wall $(CFLAGS) -o $@ + +$(TARGET2): main.c + $(CC2) main.c -Wall $(CFLAGS) -o $@ + +clean: + -rm -f $(TARGET1) + -rm -f $(TARGET2) diff --git a/offloading_binaries/server_send_normaltcp/main.c b/offloading_binaries/server_send_normaltcp/main.c new file mode 100644 index 0000000..90a00b9 --- /dev/null +++ b/offloading_binaries/server_send_normaltcp/main.c @@ -0,0 +1,221 @@ +/* + * Initial commit by Yibo @ Jul. 28, 2015 + * Last update by Yanzi @ Sept. 26, 2016 + */ + +#include +#include +#include +#include +#include +#include +#include +#include +#include +#include +#include +#include +#include +#include +#include +#include +#include +#include +#include + +#define BUF_SIZ 65536 + +char isNumber(char number[]) +{ + int i = 0; + + //checking for negative numbers + if (number[0] == '-') + i = 1; + for (; number[i] != 0; i++) + { + //if (number[i] > '9' || number[i] < '0') + if (!isdigit(number[i])) + return 0; + } + return 1; +} + +int main(int argc, char *argv[]) +{ + // defaults + uint slotLength = 10000; // in microseconds, for bandwidth control + uint quota = 1000000000; // default bytes per slot, default 1GB/slot + uint sentInSlot = 0, slot = 1; + uint total_bytes_sent = 0; + // for timing + double elapsedTime; + struct timeval t_start, t_end, t_now; + // for socket + int fd; // file descriptor of file to send + int listenfd, sockfd; // socket + char sendbuf[BUF_SIZ]; + struct sockaddr_in servaddr, cliaddr; + socklen_t clilen; + // for misc + int ret; + int sendsize = 1460; // 1500 MTU - 20 IPv4 - 20 TCP + uint bytes2send = 0; + struct stat st; + unsigned char listenOnce = 0; + + signal(SIGPIPE, SIG_IGN); + + if (argc < 3) + { + printf("Usage: %s <[optional] bandwidth (bps)> <[optional] listenOnce ([0]/1)> <[optional] sendsize (bytes)>\n", argv[0]); + exit(0); + } + + // set bandwidth + if (argc > 3) + quota = atoi(argv[3]) / 8 / (1000000 / slotLength); + + // only one session + if (argc > 4) + listenOnce = atoi(argv[4]); + + // set sendsize (if larger than 1460 will do packetization (fragmentation)) + if (argc > 5) + sendsize = atoi(argv[5]); + + // adjust slotLength to address packet size issue in the end + if ((quota % sendsize) > 0) + { + // printf("quota:%d,sendsize:%d,slotLength:%d\n", quota, sendsize, slotLength); + slotLength = (uint)((double)(quota / sendsize + 1) * sendsize / quota * slotLength); + quota = (quota / sendsize + 1) * sendsize; + // printf("quota:%d,sendsize:%d,slotLength:%d\n", quota, sendsize, slotLength); + } + + // listen to socket + listenfd = socket(AF_INET, SOCK_STREAM, 0); + // bind socket and listen + bzero(&servaddr, sizeof(servaddr)); + servaddr.sin_family = AF_INET; + servaddr.sin_addr.s_addr = htonl(INADDR_ANY); + servaddr.sin_port = htons(atoi(argv[1])); + bind(listenfd, (struct sockaddr *)&servaddr, sizeof(servaddr)); + listen(listenfd, 1); + + for (;;) + { + clilen = sizeof(cliaddr); + + // wait for one client and accept it once found + sockfd = accept(listenfd, (struct sockaddr *)&cliaddr, &clilen); + printf("Accepted client at %s\n", inet_ntoa(cliaddr.sin_addr)); + + // get file size (bytes2send) + if (isNumber(argv[2])) + { + // set bytes to send + bytes2send = atoi(argv[2]); + // open file descriptor + fd = open("/dev/zero", O_RDONLY); + if (fd == -1) + { + fprintf(stderr, "! Unable to open /data/local/tmp/bigfile.\n"); + exit(1); + } + } + else + { + // open file descriptor + fd = open(argv[2], O_RDONLY); + if (fd == -1) + { + fprintf(stderr, "! Unable to open file %s.\n", argv[2]); + exit(1); + } + fstat(fd, &st); + bytes2send = st.st_size; + printf("bytes2send:%d\n", bytes2send); + } + // clear total_bytes_sent to 0 + total_bytes_sent = 0; + sentInSlot = 0; + slot = 1; + + // start timing + gettimeofday(&t_start, NULL); + + // start to send + while (total_bytes_sent < bytes2send) + { + if ((bytes2send - total_bytes_sent) < quota) + { + quota = bytes2send - total_bytes_sent; + } + // send in slots + while (sentInSlot < quota) + { + // printf( + // "before: total_bytes_sent %d, sentInSlot %d, quota - sentInSlot %d\n", + // total_bytes_sent, sentInSlot, quota - sentInSlot); + read(fd, sendbuf, (quota - sentInSlot < sendsize) ? (quota - sentInSlot) : sendsize); + ret = send( + sockfd, sendbuf, + (quota - sentInSlot < sendsize) ? (quota - sentInSlot) : sendsize, 0); + + if (ret <= 0) + { + fprintf(stderr, "! Fail to send: ret:%d, err:%d; wait for 100us..\n", ret, errno); + total_bytes_sent = bytes2send + 1; + break; + } + total_bytes_sent += ret; + sentInSlot += ret; + // printf( + // "after: total_bytes_sent %d, sentInSlot %d, quota - sentInSlot %d\n", + // total_bytes_sent, sentInSlot, quota - sentInSlot); + } + // workaround to break the while loop when error happens + if (total_bytes_sent > bytes2send) + { + break; + } + // control bandwidth + gettimeofday(&t_now, NULL); + elapsedTime = (t_now.tv_sec - t_start.tv_sec) * 1000000.0 + (t_now.tv_usec - t_start.tv_usec); + if (elapsedTime < slotLength * slot) + { + // printf( + // "sent %d, quota %d, bytes2send %d, usleep %lfus\n", + // total_bytes_sent, quota, bytes2send, slotLength * slot - elapsedTime); + usleep((int)(slotLength * slot - elapsedTime)); + } + sentInSlot = 0; + ++slot; + } + + // end timing + if (total_bytes_sent == bytes2send) + { + gettimeofday(&t_end, NULL); + elapsedTime = (t_end.tv_sec - t_start.tv_sec) + (t_end.tv_usec - t_start.tv_usec) / 1000000.0; + printf( + "sent(bytes):%d\nduration(s):%lf\nthroughput(bps):%lf\n", + total_bytes_sent, elapsedTime, total_bytes_sent * 8 / elapsedTime); + } + else + { + fprintf(stderr, "! error: total_bytes_sent > bytes2send\n"); + } + + close(sockfd); + close(fd); + + if (listenOnce) + break; + } + + close(listenfd); + + return 0; +} \ No newline at end of file diff --git a/offloading_binaries/TCPServer/main.o b/offloading_binaries/server_send_normaltcp/main.o similarity index 100% rename from offloading_binaries/TCPServer/main.o rename to offloading_binaries/server_send_normaltcp/main.o diff --git a/offloading_binaries/server_send_normaltcp/server_m_send_normaltcp b/offloading_binaries/server_send_normaltcp/server_m_send_normaltcp new file mode 100755 index 0000000..90506ce Binary files /dev/null and b/offloading_binaries/server_send_normaltcp/server_m_send_normaltcp differ diff --git a/offloading_binaries/server_send_normaltcp/server_send_normaltcp b/offloading_binaries/server_send_normaltcp/server_send_normaltcp new file mode 100755 index 0000000..ab0c119 Binary files /dev/null and b/offloading_binaries/server_send_normaltcp/server_send_normaltcp differ