![[BACK]](/cvsweb/icons/back.gif){kind=icon}
Return to httpio.c CVS log ![[TXT]](/cvsweb/icons/text.gif){kind=icon}
![[DIR]](/cvsweb/icons/dir.gif){kind=icon}
Up to [Synchronet] / sbbs / sbbs3 / install|
Return to httpio.c CVS log | Up to [Synchronet] / sbbs / sbbs3 / install |
1.1 ! root 1: #include <stdio.h> ! 2: ! 3: #include <sys/param.h> ! 4: #include <sys/socket.h> ! 5: #include <sys/types.h> ! 6: #include <sys/uio.h> ! 7: #include <unistd.h> ! 8: #include <ctype.h> ! 9: #include <netdb.h> ! 10: #include <netinet/in.h> ! 11: #include <stdlib.h> ! 12: #include <string.h> ! 13: #include <arpa/inet.h> ! 14: ! 15: #include "sockwrap.h" ! 16: ! 17: #define MAX_SCHEME_LEN 10 ! 18: #define MAX_HOST_LEN 128 ! 19: #define MAX_INACTIVITY 30 /* Seconds */ ! 20: #define MAX_HEADER 1024 ! 21: ! 22: u_long resolve_ip(char *addr) ! 23: { ! 24: struct hostent* host; ! 25: char* p; ! 26: ! 27: if(*addr==0) ! 28: return(INADDR_NONE); ! 29: ! 30: for(p=addr;*p;p++) ! 31: if(*p!='.' && !isdigit(*p)) ! 32: break; ! 33: if(!(*p)) ! 34: return(inet_addr(addr)); ! 35: if((host=gethostbyname(addr))==NULL) ! 36: return(INADDR_NONE); ! 37: return(*((u_long*)host->h_addr_list[0])); ! 38: } ! 39: ! 40: int sockreadline(int sock, char *buf, size_t length, char *error) ! 41: { ! 42: char ch; ! 43: int i; ! 44: int rd; ! 45: #if 0 ! 46: time_t start; ! 47: ! 48: start=time(NULL); ! 49: for(i=0;TRUE;) { ! 50: if(!socket_check(sock,&rd,NULL,1000)) { ! 51: if(error != NULL) ! 52: strcpy(error, "Socket error"); ! 53: return(-1); ! 54: } ! 55: ! 56: if(!rd) { ! 57: if(time(NULL)-start>MAX_INACTIVITY) { ! 58: if(error != NULL) ! 59: strcpy(error,"Timed out"); ! 60: return(-1); /* time-out */ ! 61: } ! 62: continue; /* no data */ ! 63: } ! 64: ! 65: if(recv(sock, &ch, 1, 0)!=1) ! 66: break; ! 67: ! 68: if(ch=='\n') ! 69: break; ! 70: ! 71: if(i<length) ! 72: buf[i++]=ch; ! 73: } ! 74: #else ! 75: for(i=0;1;) { ! 76: if(!socket_check(sock,&rd,NULL,60000) || !rd || recv(sock, &ch, 1, 0)!=1) { ! 77: if(error != NULL) ! 78: strcpy(error,"Timed out"); ! 79: return(-1); /* time-out */ ! 80: } ! 81: ! 82: if(ch=='\n') ! 83: break; ! 84: ! 85: if(i<length) ! 86: buf[i++]=ch; ! 87: } ! 88: #endif ! 89: ! 90: /* Terminate at length if longer */ ! 91: if(i>length) ! 92: i=length; ! 93: ! 94: if(i>0 && buf[i-1]=='\r') ! 95: buf[--i]=0; ! 96: else ! 97: buf[i]=0; ! 98: ! 99: return(i); ! 100: } ! 101: ! 102: /* Error will hold the error message on a failed return... */ ! 103: /* Must be at least 128 bytes long */ ! 104: int http_get_fd(char *URL, size_t *len, char *error) ! 105: { ! 106: char host[MAX_HOST_LEN+1]; ! 107: ulong ip_addr; ! 108: int s=-1; ! 109: int port=80; ! 110: char *p; ! 111: char *path; ! 112: struct sockaddr_in addr; ! 113: char header[MAX_HEADER+1]; ! 114: ! 115: if(len != NULL) ! 116: *len=0; ! 117: if(error != NULL) ! 118: *error=0; ! 119: if(strncasecmp(URL, "http://", 7)) { ! 120: if(error!=NULL) ! 121: strcpy(error, "URL is not http"); ! 122: return(-1); ! 123: } ! 124: strncpy(host, URL+7, MAX_HOST_LEN); ! 125: host[MAX_HOST_LEN+1]=0; ! 126: if((p=strchr(host,'/'))==NULL) { ! 127: if(error!=NULL) ! 128: strcpy(error, "Host too long or no path info found"); ! 129: return(-1); ! 130: } ! 131: *p=0; ! 132: if((p=strchr(host,':'))!=NULL) { ! 133: *p=0; ! 134: port=atoi(p+1); ! 135: } ! 136: if((ip_addr=resolve_ip(host))==INADDR_NONE) { ! 137: if(error!=NULL) ! 138: strcpy(error, "Unable to resolve host"); ! 139: return(-1); ! 140: } ! 141: if((path=strchr(URL+7, '/'))==NULL) { ! 142: if(error!=NULL) ! 143: strcpy(error, "Path info not found"); ! 144: return(-1); ! 145: } ! 146: if ((s = socket(AF_INET, SOCK_STREAM, IPPROTO_IP)) < 0) { ! 147: if(error!=NULL) ! 148: strcpy(error, "Unable to create socket"); ! 149: return(-1); ! 150: } ! 151: memset(&addr,0,sizeof(addr)); ! 152: addr.sin_addr.s_addr = ip_addr; ! 153: addr.sin_family = AF_INET; ! 154: addr.sin_port = htons(port); ! 155: if (connect(s, (struct sockaddr*)&addr, sizeof (addr)) < 0) { ! 156: close(s); ! 157: if(error!=NULL) ! 158: strcpy(error, "Unable to connect"); ! 159: return(-1); ! 160: } ! 161: if(error!=NULL) ! 162: strcpy(error,"Unable to send request"); ! 163: if(write(s, "GET ", 4)!=4) { ! 164: close(s); ! 165: return(-1); ! 166: } ! 167: if(write(s, path, strlen(path))!=strlen(path)) { ! 168: close(s); ! 169: return(-1); ! 170: } ! 171: if(write(s, " HTTP/1.0\r\nHost: ", 17)!=17) { ! 172: close(s); ! 173: return(-1); ! 174: } ! 175: if(write(s, host, strlen(host))!=strlen(host)) { ! 176: close(s); ! 177: return(-1); ! 178: } ! 179: if(write(s, "\r\nConnection: close\r\n\r\n",23)!=23) { ! 180: close(s); ! 181: return(-1); ! 182: } ! 183: if(error!=NULL) ! 184: *error=0; ! 185: if(sockreadline(s, header, sizeof(header), error) < 0) { ! 186: close(s); ! 187: return(-1); ! 188: } ! 189: if(atoi(header+9)!=200) { ! 190: if(error != NULL) { ! 191: strncpy(error, header, 128); ! 192: error[127]=0; ! 193: } ! 194: close(s); ! 195: return(-1); ! 196: } ! 197: while(header[0]) { ! 198: if(sockreadline(s, header, sizeof(header), error) < 0) { ! 199: close(s); ! 200: return(-1); ! 201: } ! 202: if(len != NULL && strncasecmp(header,"content-length:",15)==0) { ! 203: *len=atol(header+15); ! 204: } ! 205: } ! 206: return(s); ! 207: }
This archive runs on limited infrastructure. Preserving old code on modern bandwidth. Automated agents are requested to crawl responsibly.