akmhoque | 1712a39 | 2012-11-08 12:00:30 -0600 | [diff] [blame] | 1 | //1. Make the necessary includes and set up the variables: |
| 2 | #include <sys/types.h> |
| 3 | #include <sys/socket.h> |
| 4 | #include <stdio.h> |
| 5 | #include <sys/un.h> |
| 6 | #include <unistd.h> |
| 7 | #include <stdlib.h> |
| 8 | #include <string.h> |
akmhoque | 9504180 | 2012-11-16 09:18:02 -0600 | [diff] [blame] | 9 | #include <netinet/in.h> |
| 10 | #include <netdb.h> |
| 11 | #include <arpa/inet.h> |
| 12 | #include <getopt.h> |
| 13 | |
| 14 | struct option longopts[] = |
| 15 | { |
| 16 | { "server_ip", required_argument, NULL, 's'}, |
| 17 | { "server_port", required_argument, NULL, 'p'}, |
| 18 | { 0 } |
| 19 | }; |
akmhoque | 1712a39 | 2012-11-08 12:00:30 -0600 | [diff] [blame] | 20 | |
akmhoque | 1771c41 | 2012-11-09 13:06:08 -0600 | [diff] [blame] | 21 | static int |
| 22 | usage(char *progname) |
| 23 | { |
akmhoque | b77b95f | 2013-02-08 12:28:47 -0600 | [diff] [blame] | 24 | printf("Usage: %s [OPTIONS...]\n\ |
| 25 | NLSR API client....\n\ |
| 26 | nlsrc -s server_ip -p server_port add|del name|neighbor name_prefix [faceX] \n\ |
| 27 | option -- description\n\n\ |
| 28 | add|del -- specify whether you want to add or delete.\n\ |
| 29 | name|neighbor -- specify whether you are adding a name or a neighbor.\n\ |
| 30 | name_prefix -- name of the prefix for the name|neighbor.\n\ |
| 31 | faceX -- face ID for neighbor if the third argument is neighbor.\n\n\ |
| 32 | Examples:\n\ |
| 33 | 1) nlsrc -s 127.0.0.1 -p 9696 add name /ndn/memphis.edu/test \n", progname); |
akmhoque | 1771c41 | 2012-11-09 13:06:08 -0600 | [diff] [blame] | 34 | |
akmhoque | b77b95f | 2013-02-08 12:28:47 -0600 | [diff] [blame] | 35 | exit(1); |
akmhoque | 1771c41 | 2012-11-09 13:06:08 -0600 | [diff] [blame] | 36 | } |
| 37 | |
akmhoque | 1712a39 | 2012-11-08 12:00:30 -0600 | [diff] [blame] | 38 | int main(int argc, char *argv[]) |
| 39 | { |
| 40 | int sockfd; |
| 41 | int len; |
akmhoque | 9504180 | 2012-11-16 09:18:02 -0600 | [diff] [blame] | 42 | struct sockaddr_in address; |
akmhoque | 1712a39 | 2012-11-08 12:00:30 -0600 | [diff] [blame] | 43 | int result; |
akmhoque | b77b95f | 2013-02-08 12:28:47 -0600 | [diff] [blame] | 44 | int bytesSent; |
akmhoque | 9504180 | 2012-11-16 09:18:02 -0600 | [diff] [blame] | 45 | char *server_address, *server_port; |
| 46 | |
akmhoque | b77b95f | 2013-02-08 12:28:47 -0600 | [diff] [blame] | 47 | int command_len=0; |
akmhoque | 1712a39 | 2012-11-08 12:00:30 -0600 | [diff] [blame] | 48 | int i; |
akmhoque | 1771c41 | 2012-11-09 13:06:08 -0600 | [diff] [blame] | 49 | |
Adam Alyyan | b5fff37 | 2013-01-09 14:32:52 -0600 | [diff] [blame] | 50 | if (argc < 8) |
akmhoque | b77b95f | 2013-02-08 12:28:47 -0600 | [diff] [blame] | 51 | usage(argv[0]); |
Adam Alyyan | b5fff37 | 2013-01-09 14:32:52 -0600 | [diff] [blame] | 52 | |
akmhoque | b77b95f | 2013-02-08 12:28:47 -0600 | [diff] [blame] | 53 | if (strcmp(argv[6], "neighbor") == 0 && argc < 9) |
| 54 | usage(argv[0]); |
Adam Alyyan | b5fff37 | 2013-01-09 14:32:52 -0600 | [diff] [blame] | 55 | |
akmhoque | b77b95f | 2013-02-08 12:28:47 -0600 | [diff] [blame] | 56 | if (strcmp(argv[6], "name") != 0 && strcmp(argv[6], "neighbor") != 0) |
| 57 | usage(argv[0]); |
akmhoque | 1771c41 | 2012-11-09 13:06:08 -0600 | [diff] [blame] | 58 | |
akmhoque | 9504180 | 2012-11-16 09:18:02 -0600 | [diff] [blame] | 59 | while ((result = getopt_long(argc, argv, "s:p:", longopts, 0)) != -1) |
| 60 | { |
| 61 | switch (result) |
| 62 | { |
| 63 | case 's': |
| 64 | server_address = optarg; |
| 65 | break; |
| 66 | case 'p': |
| 67 | server_port = optarg; |
| 68 | break; |
| 69 | } |
| 70 | } |
| 71 | |
| 72 | |
akmhoque | 562caef | 2012-11-09 13:29:06 -0600 | [diff] [blame] | 73 | char recv_buffer[1024]; |
| 74 | bzero(recv_buffer,1024); |
| 75 | |
akmhoque | b77b95f | 2013-02-08 12:28:47 -0600 | [diff] [blame] | 76 | for(i=5;i<argc;i++) |
| 77 | command_len+=(strlen(argv[i])+1); |
| 78 | char *command=malloc(command_len); |
| 79 | memset(command, 0, command_len); |
| 80 | for(i=5;i<argc;i++) |
akmhoque | 1712a39 | 2012-11-08 12:00:30 -0600 | [diff] [blame] | 81 | { |
akmhoque | b77b95f | 2013-02-08 12:28:47 -0600 | [diff] [blame] | 82 | memcpy(command+strlen(command),argv[i],strlen(argv[i])); |
| 83 | if ( i < argc-1 ) |
akmhoque | 1712a39 | 2012-11-08 12:00:30 -0600 | [diff] [blame] | 84 | memcpy(command+strlen(command)," ",1); |
| 85 | } |
| 86 | |
akmhoque | 9504180 | 2012-11-16 09:18:02 -0600 | [diff] [blame] | 87 | sockfd = socket(AF_INET, SOCK_STREAM, 0); |
| 88 | //address.sun_family = AF_UNIX; |
| 89 | //strcpy(address.sun_path, "/tmp/nlsr_api_server_socket"); |
| 90 | address.sin_family = AF_INET; |
| 91 | address.sin_addr.s_addr = inet_addr(server_address); |
Adam Alyyan | b5fff37 | 2013-01-09 14:32:52 -0600 | [diff] [blame] | 92 | address.sin_port = htons(atoi(server_port)); |
akmhoque | 9504180 | 2012-11-16 09:18:02 -0600 | [diff] [blame] | 93 | |
akmhoque | 1712a39 | 2012-11-08 12:00:30 -0600 | [diff] [blame] | 94 | len = sizeof(address); |
| 95 | result = connect(sockfd, (struct sockaddr *)&address, len); |
akmhoque | 1771c41 | 2012-11-09 13:06:08 -0600 | [diff] [blame] | 96 | if(result == -1) |
| 97 | { |
akmhoque | 1712a39 | 2012-11-08 12:00:30 -0600 | [diff] [blame] | 98 | perror("oops nlsrc "); |
| 99 | exit(1); |
| 100 | } |
akmhoque | 562caef | 2012-11-09 13:29:06 -0600 | [diff] [blame] | 101 | printf("Command to send: %s \n",command); |
akmhoque | b77b95f | 2013-02-08 12:28:47 -0600 | [diff] [blame] | 102 | bytesSent=send(sockfd, command, strlen(command),0); |
| 103 | printf("Command len: %d, Bytes sent: %d \n",(int)strlen(command), bytesSent); |
akmhoque | 562caef | 2012-11-09 13:29:06 -0600 | [diff] [blame] | 104 | recv(sockfd, recv_buffer, 1024, 0); |
| 105 | printf("%s\n",recv_buffer); |
akmhoque | 1771c41 | 2012-11-09 13:06:08 -0600 | [diff] [blame] | 106 | free(command); |
akmhoque | 1712a39 | 2012-11-08 12:00:30 -0600 | [diff] [blame] | 107 | close(sockfd); |
akmhoque | b77b95f | 2013-02-08 12:28:47 -0600 | [diff] [blame] | 108 | exit(0); |
akmhoque | 1712a39 | 2012-11-08 12:00:30 -0600 | [diff] [blame] | 109 | } |