From 8194c1e24afa66dd54f071a06550e928e6c1e9c2 Mon Sep 17 00:00:00 2001
From: Stefanos Kornilios Mitsis Poiitidis <skmp@nillware.com>
Date: Sun, 1 Jun 2014 13:54:11 +0300
Subject: [PATCH] Added missing coreio/* files...

---
 core/deps/coreio/coreio.cpp | 260 ++++++++++++++++++++++++++++++++++++
 core/deps/coreio/coreio.h   |  12 ++
 2 files changed, 272 insertions(+)
 create mode 100644 core/deps/coreio/coreio.cpp
 create mode 100644 core/deps/coreio/coreio.h

diff --git a/core/deps/coreio/coreio.cpp b/core/deps/coreio/coreio.cpp
new file mode 100644
index 000000000..3c4522ff7
--- /dev/null
+++ b/core/deps/coreio/coreio.cpp
@@ -0,0 +1,260 @@
+
+#include "coreio.h"
+
+#include <time.h>
+#include <stddef.h>
+#include <stdlib.h>
+#include <stdio.h>
+#define TRUE 1
+#define FALSE 0
+
+#pragma comment (lib, "wsock32.lib")
+
+#include <string>
+#include <sstream>
+
+#if HOST_OS == OS_LINUX
+	#include <sys/socket.h>
+	#include <netinet/in.h>
+	#include <netinet/ip.h>
+	#include <linux/tcp.h>
+	#include <netdb.h>
+	#include <unistd.h>
+#endif
+
+size_t HTTP_GET(string host, int port,string path, size_t offs, size_t len, void* pdata){
+    string request;
+    string response;
+
+    struct sockaddr_in serveraddr;
+    int sock;
+
+    std::stringstream request2;
+
+	if (len) {
+		request2 << "GET " << path << " HTTP/1.1"<<endl;
+		request2 << "User-Agent: reicastdc" << endl;
+		//request2 << "" << endl;
+		request2 << "Host: " << host << endl;
+		request2 << "Accept: */*" << endl;
+		request2 << "Range: bytes=" << offs << "-" << (offs + len-1) << endl;
+		request2 << endl;
+	}
+	else {
+		request2 << "HEAD " << path << " HTTP/1.1"<<endl;
+		request2 << "User-Agent: reicastdc" << endl;
+		//request2 << "" << endl;
+		request2 << "Host: " << host << endl;
+		request2 << endl;
+	}
+
+	request = request2.str();
+    //init winsock
+
+	static bool init = false;
+	if (!init) {
+#if HOST_OS == OS_WINDOWS
+		static WSADATA wsaData;
+		if (WSAStartup(MAKEWORD(2, 0), &wsaData) != 0)
+			die("WSAStartup fail");
+#endif
+		init = true;
+	}
+
+    //open socket
+    if ((sock = socket(PF_INET, SOCK_STREAM, IPPROTO_TCP)) < 0)
+        return -1;
+
+	
+    //connect
+    memset(&serveraddr, 0, sizeof(serveraddr));
+    serveraddr.sin_family      = AF_INET;
+	serveraddr.sin_addr.s_addr = *(int*)gethostbyname( host.c_str() )->h_addr_list[0];
+    serveraddr.sin_port        = htons((unsigned short) port);
+    if (connect(sock, (struct sockaddr *) &serveraddr, sizeof(serveraddr)) < 0)
+        return -1;
+
+#if HOST_OS == OS_WINDOWS
+	BOOL v = TRUE;
+#else
+	int v = 1;
+#endif
+
+	setsockopt(sock, IPPROTO_TCP, TCP_NODELAY, (const char*)&v, sizeof(v));
+    //send request
+    if (send(sock, request.c_str(), request.length(), 0) != request.length())
+        return -1;
+
+	/*
+    //get response
+    response = "";
+    resp_leng= BUFFERSIZE;
+    
+	*/
+
+	/*
+		parse headers ..
+	*/
+	size_t content_length = 0;
+	
+	size_t rv = content_length;
+
+	for (;;) {
+		stringstream ss;
+		for (;;) {
+			char t;
+			if (recv(sock, &t, 1, 0) <= 0)
+				goto _cleanup;
+
+			if (t != '\n'){
+				ss << t;
+				continue;
+			}
+
+			string ln = ss.str();
+
+			if (ln.size() == 1)
+				goto _data;
+			string CL = "Content-Length:";
+
+			if (ln.substr(0, CL.size()) == CL) {
+				sscanf(ln.substr(CL.size(), ln.npos).c_str(),"%d", &content_length);
+			}
+
+			break;
+		}
+	}
+
+_data:
+
+	if (len == 0) {
+
+	}
+	else {
+		verify(len == content_length);
+		u8* ptr = (u8*)pdata;
+		do
+		{
+			int rcv = recv(sock, (char*)ptr, len, 0);
+			verify(rcv > 0 && len>= rcv);
+			len -= rcv;
+			ptr += rcv;
+		}
+		while (len >0);
+	}
+
+	_cleanup:
+    //disconnect
+#if HOST_OS == OS_WINDOWS
+    closesocket(sock);
+#else
+	close(sock);
+#endif
+
+	/*
+    //cleanup
+    WSACleanup();
+	*/
+
+    return  rv;
+}
+
+struct CORE_FILE {
+	FILE* f;
+	string path;
+	size_t seek_ptr;
+
+	string host;
+	int port;
+};
+
+core_file* core_fopen(const char* filename)
+{
+	string p = filename;
+
+	CORE_FILE* rv = new CORE_FILE();
+	rv->f = 0;
+	rv->path = p;
+
+	if (p.substr(0,7)=="http://") {
+		rv->host = p.substr(7,p.npos);
+		rv->host = rv->host.substr(0, rv->host.find_first_of("/"));
+
+		rv->path = p.substr(p.find("/", 7), p.npos);
+		
+		rv->port = 80;
+		size_t pos = rv->host.find_first_of(":");
+		if (pos != rv->host.npos) {
+			string port = rv->host.substr(pos, rv->host.npos );
+			rv->host = rv->host.substr(0, rv->host.find_first_of(":"));
+			sscanf(port.c_str(),"%d",&rv->port);
+		}
+	} else {
+		rv->f = fopen(filename, "rb");
+	}
+
+	return (core_file*)rv;
+}
+
+size_t core_fseek(core_file* fc, size_t offs, size_t origin) {
+	CORE_FILE* f = (CORE_FILE*)fc;
+	
+	if (origin == SEEK_SET)
+		f->seek_ptr = offs;
+	else if (origin == SEEK_CUR)
+		f->seek_ptr += offs;
+	else
+		die("Invalid code path");
+
+	if (f->f)
+		fseek((FILE*)f, f->seek_ptr, SEEK_SET);
+
+	return 0;
+}
+
+int core_fread(core_file* fc, void* buff, size_t len)
+{
+	CORE_FILE* f = (CORE_FILE*)fc;
+
+	if (f->f) {
+		fread(buff,1,len,f->f);
+	} else {
+		HTTP_GET(f->host, f->port, f->path, f->seek_ptr, len, buff);
+	}
+
+	f->seek_ptr += len;
+
+	return len;
+}
+
+int core_fclose(core_file* fc)
+{
+	CORE_FILE* f = (CORE_FILE*)fc;
+
+	if (f->f) {
+		fclose((FILE*)f);
+	}
+	else {
+
+	}
+
+	delete f;
+
+	return 0;
+}
+
+size_t core_fsize(core_file* fc)
+{
+	CORE_FILE* f = (CORE_FILE*)fc;
+
+	if (f->f) {
+		size_t p=ftell(f->f);
+		fseek(f->f,0,SEEK_END);
+		size_t rv=ftell(f->f);
+		fseek(f->f,p,SEEK_SET);
+		return rv;
+	}
+	else {
+		return HTTP_GET(f->host, f->port, f->path, 0, 0,0);
+	}	
+}
\ No newline at end of file
diff --git a/core/deps/coreio/coreio.h b/core/deps/coreio/coreio.h
new file mode 100644
index 000000000..cdf28435c
--- /dev/null
+++ b/core/deps/coreio/coreio.h
@@ -0,0 +1,12 @@
+#pragma once
+#include "types.h"
+
+//#define core_file FILE
+typedef void* core_file;
+
+
+core_file* core_fopen(const char* filename);
+size_t core_fseek(core_file* fc, size_t offs, size_t origin);
+int core_fread(core_file* fc, void* buff, size_t len);
+int core_fclose(core_file* fc);
+size_t core_fsize(core_file* fc);
\ No newline at end of file