minor changes

This commit is contained in:
dborth 2010-06-23 17:22:02 +00:00
parent fdf9271890
commit beb49d317b
5 changed files with 128 additions and 156 deletions

View File

@ -114,33 +114,17 @@ void ResetBrowser()
browser.numEntries = 0; browser.numEntries = 0;
browser.selIndex = 0; browser.selIndex = 0;
browser.pageIndex = 0; browser.pageIndex = 0;
browser.size = 0;
// Clear any existing values
if(browserList != NULL)
{
free(browserList);
browserList = NULL;
}
// set aside space for 1 entry
browserList = (BROWSERENTRY *)malloc(sizeof(BROWSERENTRY));
memset(browserList, 0, sizeof(BROWSERENTRY));
browser.size = 1;
} }
bool AddBrowserEntry() bool AddBrowserEntry()
{ {
BROWSERENTRY * newBrowserList = (BROWSERENTRY *)realloc(browserList, (browser.size+1) * sizeof(BROWSERENTRY)); if(browser.size >= MAX_BROWSER_SIZE)
if(!newBrowserList) // failed to allocate required memory
{ {
ResetBrowser();
ErrorPrompt("Out of memory: too many files!"); ErrorPrompt("Out of memory: too many files!");
return false; return false; // out of space
}
else
{
browserList = newBrowserList;
} }
memset(&(browserList[browser.size]), 0, sizeof(BROWSERENTRY)); // clear the new entry memset(&(browserList[browser.size]), 0, sizeof(BROWSERENTRY)); // clear the new entry
browser.size++; browser.size++;
return true; return true;

View File

@ -15,6 +15,11 @@
#include <gccore.h> #include <gccore.h>
#define MAXJOLIET 255 #define MAXJOLIET 255
#ifdef HW_DOL
#define MAX_BROWSER_SIZE 1000
#else
#define MAX_BROWSER_SIZE 3000
#endif
typedef struct typedef struct
{ {

View File

@ -49,19 +49,13 @@ void UpdateCheck()
// we can only check for the update if we have internet + SD // we can only check for the update if we have internet + SD
if(!updateChecked && networkInit && (isMounted[DEVICE_SD] || isMounted[DEVICE_USB])) if(!updateChecked && networkInit && (isMounted[DEVICE_SD] || isMounted[DEVICE_USB]))
{ {
static char url[128];
int retval;
updateChecked = true; updateChecked = true;
static char url[128];
snprintf(url, 128, "http://vba-wii.googlecode.com/svn/trunk/update.xml"); snprintf(url, 128, "http://vba-wii.googlecode.com/svn/trunk/update.xml");
u8 * tmpbuffer = (u8 *)memalign(32,32768); u8 * tmpbuffer = (u8 *)memalign(32,32768);
memset(tmpbuffer, 0, 32768); memset(tmpbuffer, 0, 32768);
retval = http_request(url, NULL, tmpbuffer, 32768);
memset(url, 0, 128);
if (retval) if (http_request(url, NULL, tmpbuffer, 32768, SILENT) > 0)
{ {
mxml_node_t *xml; mxml_node_t *xml;
mxml_node_t *item; mxml_node_t *item;
@ -136,11 +130,12 @@ bool DownloadUpdate()
{ {
bool result = false; bool result = false;
if(strlen(updateURL) == 0 || strlen(appPath) == 0) if(updateURL[0] == 0 || appPath[0] == 0 || !ChangeInterface(appPath, NOTSILENT))
goto done; {
ErrorPrompt("Update failed!");
if(!ChangeInterface(appPath, NOTSILENT)) updateFound = false; // updating is finished (successful or not!)
goto done; return false;
}
// stop checking if devices were removed/inserted // stop checking if devices were removed/inserted
// since we're saving a file // since we're saving a file
@ -149,25 +144,22 @@ bool DownloadUpdate()
int device; int device;
FindDevice(appPath, &device); FindDevice(appPath, &device);
FILE * hfile;
char updateFile[50]; char updateFile[50];
sprintf(updateFile, "%s%s Update.zip", pathPrefix[device], APPNAME); sprintf(updateFile, "%s%s Update.zip", pathPrefix[device], APPNAME);
hfile = fopen (updateFile, "wb");
if (hfile > 0) FILE * hfile = fopen (updateFile, "wb");
if (hfile)
{ {
int retval; if(http_request(updateURL, hfile, NULL, (1024*1024*10), NOTSILENT) > 0)
retval = http_request(updateURL, hfile, NULL, (1024*1024*10));
fclose (hfile);
}
result = unzipArchive(updateFile, (char *)pathPrefix[device]); result = unzipArchive(updateFile, (char *)pathPrefix[device]);
fclose (hfile);
remove(updateFile); // delete update file remove(updateFile); // delete update file
}
// go back to checking if devices were inserted/removed // go back to checking if devices were inserted/removed
ResumeDeviceThread(); ResumeDeviceThread();
done:
if(result) if(result)
InfoPrompt("Update successful!"); InfoPrompt("Update successful!");
else else

View File

@ -25,29 +25,33 @@
#include "menu.h" #include "menu.h"
#include "http.h" #include "http.h"
#define TCP_CONNECT_TIMEOUT 4000 // 4 secs to make a connection
#define TCP_SEND_SIZE (32 * 1024)
#define TCP_RECV_SIZE (32 * 1024)
#define TCP_BLOCK_RECV_TIMEOUT 4000 // 4 secs to receive
#define TCP_BLOCK_SEND_TIMEOUT 4000 // 4 secs to send
#define TCP_BLOCK_SIZE 1024
#define HTTP_TIMEOUT 10000 // 10 secs to get an http response
#define IOS_O_NONBLOCK 0x04
static s32 tcp_socket(void) static s32 tcp_socket(void)
{ {
s32 s, res; s32 s, res;
s = net_socket(PF_INET, SOCK_STREAM, 0); s = net_socket(PF_INET, SOCK_STREAM, 0);
if (s < 0) if (s < 0)
{
return s; return s;
}
res = net_fcntl(s, F_GETFL, 0); res = net_fcntl(s, F_GETFL, 0);
if (res < 0) if (res < 0)
{ {
net_close(s); net_close(s);
return res; return res;
} }
res = net_fcntl(s, F_SETFL, res | 4); res = net_fcntl(s, F_SETFL, res | IOS_O_NONBLOCK);
if (res < 0) if (res < 0)
{ {
net_close(s); net_close(s);
return res; return res;
} }
@ -59,60 +63,44 @@ static s32 tcp_connect(char *host, const u16 port)
{ {
struct hostent *hp; struct hostent *hp;
struct sockaddr_in sa; struct sockaddr_in sa;
struct in_addr val;
fd_set myset;
struct timeval tv;
s32 s, res; s32 s, res;
s64 t;
hp = net_gethostbyname(host);
if (!hp || !(hp->h_addrtype == PF_INET))
{
return errno;
}
s = tcp_socket(); s = tcp_socket();
if (s < 0) if (s < 0)
return s; return s;
memset(&sa, 0, sizeof(struct sockaddr_in)); memset(&sa, 0, sizeof(struct sockaddr_in));
sa.sin_family = PF_INET; sa.sin_family= PF_INET;
sa.sin_len = sizeof(struct sockaddr_in); sa.sin_len = sizeof(struct sockaddr_in);
sa.sin_port = htons(port); sa.sin_port= htons(port);
if(strlen(host) < 16 && inet_aton(host, &val))
{
sa.sin_addr.s_addr = val.s_addr;
}
else
{
hp = net_gethostbyname (host);
if (!hp || !(hp->h_addrtype == PF_INET))
return errno;
memcpy((char *) &sa.sin_addr, hp->h_addr_list[0], hp->h_length); memcpy((char *) &sa.sin_addr, hp->h_addr_list[0], hp->h_length);
t = gettime();
while (true)
{
if (ticks_to_millisecs(diff_ticks(t, gettime())) > TCP_CONNECT_TIMEOUT)
{
net_close(s);
return -ETIMEDOUT;
} }
res = net_connect(s, (struct sockaddr *) &sa, res = net_connect (s, (struct sockaddr *) &sa, sizeof (sa));
sizeof(struct sockaddr_in));
if (res < 0) if (res == EINPROGRESS)
{ {
if (res == -EISCONN) tv.tv_sec = TCP_CONNECT_TIMEOUT;
break; tv.tv_usec = 0;
FD_ZERO(&myset);
if (res == -EINPROGRESS || res == -EALREADY) FD_SET(s, &myset);
{ if (net_select(s+1, NULL, &myset, NULL, &tv) <= 0)
usleep(20 * 1000); return -1;
continue;
} }
net_close(s);
return res;
}
break;
}
return s; return s;
} }
@ -138,22 +126,17 @@ static char * tcp_readln(const s32 s, const u16 max_length, const u64 start_time
if ((res == 0) || (res == -EAGAIN)) if ((res == 0) || (res == -EAGAIN))
{ {
usleep(20 * 1000); usleep(20 * 1000);
continue; continue;
} }
if (res < 0) if (res < 0)
{
break; break;
}
if ((c > 0) && (buf[c - 1] == '\r') && (buf[c] == '\n')) if ((c > 0) && (buf[c - 1] == '\r') && (buf[c] == '\n'))
{ {
if (c == 1) if (c == 1)
{ {
ret = strdup(""); ret = strdup("");
break; break;
} }
@ -166,21 +149,22 @@ static char * tcp_readln(const s32 s, const u16 max_length, const u64 start_time
if (c == max_length) if (c == max_length)
break; break;
usleep(300);
} }
free(buf); free(buf);
return ret; return ret;
} }
static int tcp_read(const s32 s, u8 **buffer, const u32 length) static int tcp_read(const s32 s, u8 *buffer, const u32 length)
{ {
u8 *p; char *p;
u32 step, left, block, received; u32 left, block, received, step=0;
s64 t; s64 t;
s32 res; s32 res;
step = 0; p = (char *)buffer;
p = *buffer;
left = length; left = length;
received = 0; received = 0;
@ -194,45 +178,40 @@ static int tcp_read(const s32 s, u8 **buffer, const u32 length)
} }
block = left; block = left;
if (block > 2048) if (block > TCP_RECV_SIZE)
block = 2048; block = TCP_RECV_SIZE;
res = net_read(s, p, block); res = net_read(s, p, block);
if ((res == 0) || (res == -EAGAIN)) if(res>0)
{ {
usleep(20 * 1000); received += res;
left -= res;
continue; p += res;
} }
else if (res < 0 && res != -EAGAIN)
if (res < 0)
{ {
break; break;
} }
received += res; usleep(1000);
left -= res;
p += res;
if ((received / TCP_BLOCK_SIZE) > step) if ((received / TCP_BLOCK_SIZE) > step)
{ {
t = gettime(); t = gettime ();
step++; step++;
} }
} }
return received;
return left == 0;
} }
static int tcp_write(const s32 s, const u8 *buffer, const u32 length) static int tcp_write(const s32 s, const u8 *buffer, const u32 length)
{ {
const u8 *p; const u8 *p;
u32 step, left, block, sent; u32 left, block, sent, step=0;
s64 t; s64 t;
s32 res; s32 res;
step = 0;
p = buffer; p = buffer;
left = length; left = length;
sent = 0; sent = 0;
@ -243,13 +222,12 @@ static int tcp_write(const s32 s, const u8 *buffer, const u32 length)
if (ticks_to_millisecs(diff_ticks(t, gettime())) if (ticks_to_millisecs(diff_ticks(t, gettime()))
> TCP_BLOCK_SEND_TIMEOUT) > TCP_BLOCK_SEND_TIMEOUT)
{ {
break; break;
} }
block = left; block = left;
if (block > 2048) if (block > TCP_SEND_SIZE)
block = 2048; block = TCP_SEND_SIZE;
res = net_write(s, p, block); res = net_write(s, p, block);
@ -260,18 +238,16 @@ static int tcp_write(const s32 s, const u8 *buffer, const u32 length)
} }
if (res < 0) if (res < 0)
{
break; break;
}
sent += res; sent += res;
left -= res; left -= res;
p += res; p += res;
usleep(100);
if ((sent / TCP_BLOCK_SIZE) > step) if ((sent / TCP_BLOCK_SIZE) > step)
{ {
t = gettime(); t = gettime ();
step++; step++;
} }
} }
@ -289,7 +265,7 @@ static bool http_split_url(char **host, char **path, const char *url)
p = url + 7; p = url + 7;
c = strchr(p, '/'); c = strchr(p, '/');
if (c[0] == 0) if (c == NULL || c[0] == 0)
return false; return false;
*host = strndup(p, c - p); *host = strndup(p, c - p);
@ -298,12 +274,13 @@ static bool http_split_url(char **host, char **path, const char *url)
return true; return true;
} }
#define MAX_SIZE (1024*1024*15)
/**************************************************************************** /****************************************************************************
* http_request * http_request
* Retrieves the specified URL, and stores it in the specified file or buffer * Retrieves the specified URL, and stores it in the specified file or buffer
***************************************************************************/ ***************************************************************************/
bool http_request(const char *url, FILE * hfile, u8 * buffer, int http_request(const char *url, FILE * hfile, u8 * buffer, u32 maxsize, bool silent)
const u32 max_size)
{ {
int res = 0; int res = 0;
char *http_host; char *http_host;
@ -312,14 +289,18 @@ bool http_request(const char *url, FILE * hfile, u8 * buffer,
http_res result; http_res result;
u32 http_status; u32 http_status;
u32 content_length = 0; u32 sizeread = 0, content_length = 0;
int linecount; int linecount;
if (!http_split_url(&http_host, &http_path, url))
return false;
if (hfile == NULL && buffer == NULL) if(maxsize > MAX_SIZE)
return false; return 0;
if (url == NULL || (hfile == NULL && buffer == NULL))
return 0;
if (!http_split_url(&http_host, &http_path, url))
return 0;
http_port = 80; http_port = 80;
http_status = 404; http_status = 404;
@ -329,11 +310,12 @@ bool http_request(const char *url, FILE * hfile, u8 * buffer,
if (s < 0) if (s < 0)
{ {
result = HTTPR_ERR_CONNECT; result = HTTPR_ERR_CONNECT;
return false; return 0;
} }
char *request = (char *) malloc(1024); char *request = (char *) malloc(1024);
char *r = request; char *r = request;
r += sprintf(r, "GET %s HTTP/1.1\r\n", http_path); r += sprintf(r, "GET %s HTTP/1.1\r\n", http_path);
r += sprintf(r, "Host: %s\r\n", http_host); r += sprintf(r, "Host: %s\r\n", http_host);
r += sprintf(r, "Cache-Control: no-cache\r\n\r\n"); r += sprintf(r, "Cache-Control: no-cache\r\n\r\n");
@ -368,24 +350,34 @@ bool http_request(const char *url, FILE * hfile, u8 * buffer,
} }
if (linecount == 32 || !content_length)
http_status = 404;
if (http_status != 200) if (http_status != 200)
{ {
result = HTTPR_ERR_STATUS; result = HTTPR_ERR_STATUS;
net_close(s); net_close(s);
return false; return 0;
} }
if (content_length > max_size)
// length unknown - just read as much as we can
if(content_length == 0)
{
content_length = maxsize;
}
else if (content_length > maxsize)
{ {
result = HTTPR_ERR_TOOBIG; result = HTTPR_ERR_TOOBIG;
net_close(s); net_close(s);
return false; return 0;
} }
if (buffer != NULL) if (buffer != NULL)
{ {
res = tcp_read(s, &buffer, content_length); if(!silent)
ShowAction("Downloading...");
sizeread = tcp_read(s, buffer, content_length);
if(!silent)
CancelAction();
} }
else else
{ {
@ -394,6 +386,7 @@ bool http_request(const char *url, FILE * hfile, u8 * buffer,
u32 bytesLeft = content_length; u32 bytesLeft = content_length;
u32 readSize; u32 readSize;
if(!silent)
ShowProgress("Downloading...", 0, content_length); ShowProgress("Downloading...", 0, content_length);
u8 * fbuffer = (u8 *) malloc(bufSize); u8 * fbuffer = (u8 *) malloc(bufSize);
if(fbuffer) if(fbuffer)
@ -405,31 +398,35 @@ bool http_request(const char *url, FILE * hfile, u8 * buffer,
else else
readSize = bufSize; readSize = bufSize;
res = tcp_read(s, &fbuffer, readSize); res = tcp_read(s, fbuffer, readSize);
if (!res)
break;
res = fwrite(fbuffer, 1, readSize, hfile);
if (!res) if (!res)
break; break;
bytesLeft -= readSize; sizeread += res;
ShowProgress("Downloading...", (content_length - bytesLeft), bytesLeft -= res;
content_length);
res = fwrite(fbuffer, 1, res, hfile);
if (!res)
break;
if(!silent)
ShowProgress("Downloading...", (content_length - bytesLeft), content_length);
} }
free(fbuffer); free(fbuffer);
} }
if(!silent)
CancelAction(); CancelAction();
} }
net_close(s); net_close(s);
if (!res) if (content_length < maxsize && sizeread != content_length)
{ {
result = HTTPR_ERR_RECEIVE; result = HTTPR_ERR_RECEIVE;
return false; return 0;
} }
result = HTTPR_OK; result = HTTPR_OK;
return true; return sizeread;
} }
#endif #endif

View File

@ -11,12 +11,6 @@
#ifndef _HTTP_H_ #ifndef _HTTP_H_
#define _HTTP_H_ #define _HTTP_H_
#define TCP_CONNECT_TIMEOUT 5000
#define TCP_BLOCK_SIZE (16 * 1024)
#define TCP_BLOCK_RECV_TIMEOUT 4000
#define TCP_BLOCK_SEND_TIMEOUT 4000
#define HTTP_TIMEOUT 300000
typedef enum { typedef enum {
HTTPR_OK, HTTPR_OK,
HTTPR_ERR_CONNECT, HTTPR_ERR_CONNECT,
@ -26,6 +20,6 @@ typedef enum {
HTTPR_ERR_RECEIVE HTTPR_ERR_RECEIVE
} http_res; } http_res;
bool http_request (const char *url, FILE * hfile, u8 * buffer, const u32 max_size); int http_request (const char *url, FILE * hfile, u8 * buffer, const u32 max_size, bool silent);
#endif #endif