initial commit

1 files changed, 476 insertions, 0 deletions

diff --git a/src/Platform_PSP.c b/src/Platform_PSP.c
new file mode 100644
index 0000000..984fa4a
--- /dev/null
+++ b/src/Platform_PSP.c
@@ -0,0 +1,476 @@
+#include "Core.h"
+#if defined CC_BUILD_PSP
+#include "_PlatformBase.h"
+#include "Stream.h"
+#include "ExtMath.h"
+#include "Funcs.h"
+#include "Window.h"
+#include "Utils.h"
+#include "Errors.h"
+
+#include <errno.h>
+#include <stdlib.h>
+#include <string.h>
+#include <arpa/inet.h>
+#include <pspkernel.h>
+#include <psputility.h>
+#include <pspsdk.h>
+#include <pspnet.h>
+#include <pspnet_inet.h>
+#include <pspnet_resolver.h>
+#include <pspnet_apctl.h>
+#include <psprtc.h>
+#include "_PlatformConsole.h"
+
+const cc_result ReturnCode_FileShareViolation = 1000000000; // not used
+const cc_result ReturnCode_FileNotFound     = ENOENT;
+const cc_result ReturnCode_SocketInProgess  = EINPROGRESS;
+const cc_result ReturnCode_SocketWouldBlock = EWOULDBLOCK;
+const cc_result ReturnCode_DirectoryExists  = EEXIST;
+const char* Platform_AppNameSuffix = " PSP";
+
+PSP_MODULE_INFO("ClassiCube", PSP_MODULE_USER, 1, 0);
+PSP_MAIN_THREAD_ATTR(PSP_THREAD_ATTR_USER);
+
+PSP_DISABLE_AUTOSTART_PTHREAD() // reduces .elf size by 140 kb
+
+
+/*########################################################################################################################*
+*------------------------------------------------------Logging/Time-------------------------------------------------------*
+*#########################################################################################################################*/
+cc_uint64 Stopwatch_ElapsedMicroseconds(cc_uint64 beg, cc_uint64 end) {
+	if (end < beg) return 0;
+	return end - beg;
+}
+
+void Platform_Log(const char* msg, int len) {
+	int fd = sceKernelStdout();
+	sceIoWrite(fd, msg, len);
+	
+	//sceIoDevctl("emulator:", 2, msg, len, NULL, 0);
+	//cc_string str = String_Init(msg, len, len);
+	//cc_file file = 0;
+	//File_Open(&file, &str);
+	//File_Close(file);	
+}
+
+TimeMS DateTime_CurrentUTC(void) {
+	struct SceKernelTimeval cur;
+	sceKernelLibcGettimeofday(&cur, NULL);
+	return (cc_uint64)cur.tv_sec + UNIX_EPOCH_SECONDS;
+}
+
+void DateTime_CurrentLocal(struct DateTime* t) {
+	ScePspDateTime curTime;
+	sceRtcGetCurrentClockLocalTime(&curTime);
+
+	t->year   = curTime.year;
+	t->month  = curTime.month;
+	t->day    = curTime.day;
+	t->hour   = curTime.hour;
+	t->minute = curTime.minute;
+	t->second = curTime.second;
+}
+
+#define US_PER_SEC 1000000ULL
+cc_uint64 Stopwatch_Measure(void) {
+	// TODO: sceKernelGetSystemTimeWide
+	struct SceKernelTimeval cur;
+	sceKernelLibcGettimeofday(&cur, NULL);
+	return (cc_uint64)cur.tv_sec * US_PER_SEC + cur.tv_usec;
+}
+
+
+/*########################################################################################################################*
+*-----------------------------------------------------Directory/File------------------------------------------------------*
+*#########################################################################################################################*/
+static const cc_string root_path = String_FromConst("ms0:/PSP/GAME/ClassiCube/");
+
+static void GetNativePath(char* str, const cc_string* path) {
+	Mem_Copy(str, root_path.buffer, root_path.length);
+	str += root_path.length;
+	String_EncodeUtf8(str, path);
+}
+
+#define GetSCEResult(result) (result >= 0 ? 0 : result & 0xFFFF)
+
+cc_result Directory_Create(const cc_string* path) {
+	char str[NATIVE_STR_LEN];
+	GetNativePath(str, path);
+	
+	int result = sceIoMkdir(str, 0777);
+	return GetSCEResult(result);
+}
+
+int File_Exists(const cc_string* path) {
+	char str[NATIVE_STR_LEN];
+	SceIoStat sb;
+	GetNativePath(str, path);
+	return sceIoGetstat(str, &sb) == 0 && (sb.st_attr & FIO_SO_IFREG) != 0;
+}
+
+cc_result Directory_Enum(const cc_string* dirPath, void* obj, Directory_EnumCallback callback) {
+	cc_string path; char pathBuffer[FILENAME_SIZE];
+	char str[NATIVE_STR_LEN];
+	int res;
+
+	GetNativePath(str, dirPath);
+	SceUID uid = sceIoDopen(str);
+	if (uid < 0) return GetSCEResult(uid); // error
+
+	String_InitArray(path, pathBuffer);
+	SceIoDirent entry;
+
+	while ((res = sceIoDread(uid, &entry)) > 0) {
+		path.length = 0;
+		String_Format1(&path, "%s/", dirPath);
+
+		// ignore . and .. entry (PSP does return them)
+		char* src = entry.d_name;
+		if (src[0] == '.' && src[1] == '\0')                  continue;
+		if (src[0] == '.' && src[1] == '.' && src[2] == '\0') continue;
+		
+		int len = String_Length(src);
+		String_AppendUtf8(&path, src, len);
+
+		if (entry.d_stat.st_attr & FIO_SO_IFDIR) {
+			res = Directory_Enum(&path, obj, callback);
+			if (res) break;
+		} else {
+			callback(&path, obj);
+		}
+	}
+
+	sceIoDclose(uid);
+	return GetSCEResult(res);
+}
+
+static cc_result File_Do(cc_file* file, const cc_string* path, int mode) {
+	char str[NATIVE_STR_LEN];
+	GetNativePath(str, path);
+	
+	int result = sceIoOpen(str, mode, 0777);
+	*file      = result;
+	return GetSCEResult(result);
+}
+
+cc_result File_Open(cc_file* file, const cc_string* path) {
+	return File_Do(file, path, PSP_O_RDONLY);
+}
+cc_result File_Create(cc_file* file, const cc_string* path) {
+	return File_Do(file, path, PSP_O_RDWR | PSP_O_CREAT | PSP_O_TRUNC);
+}
+cc_result File_OpenOrCreate(cc_file* file, const cc_string* path) {
+	return File_Do(file, path, PSP_O_RDWR | PSP_O_CREAT);
+}
+
+cc_result File_Read(cc_file file, void* data, cc_uint32 count, cc_uint32* bytesRead) {
+	int result = sceIoRead(file, data, count);
+	*bytesRead = result;
+	return GetSCEResult(result);
+}
+
+cc_result File_Write(cc_file file, const void* data, cc_uint32 count, cc_uint32* bytesWrote) {
+	int result  = sceIoWrite(file, data, count);
+	*bytesWrote = result;
+	return GetSCEResult(result);
+}
+
+cc_result File_Close(cc_file file) {
+	int result = sceIoClose(file);
+	return GetSCEResult(result);
+}
+
+cc_result File_Seek(cc_file file, int offset, int seekType) {
+	static cc_uint8 modes[3] = { PSP_SEEK_SET, PSP_SEEK_CUR, PSP_SEEK_END };
+	
+	int result = sceIoLseek32(file, offset, modes[seekType]);
+	return GetSCEResult(result);
+}
+
+cc_result File_Position(cc_file file, cc_uint32* pos) {
+	int result = sceIoLseek32(file, 0, PSP_SEEK_CUR);
+	*pos       = result;
+	return GetSCEResult(result);
+}
+
+cc_result File_Length(cc_file file, cc_uint32* len) {
+	int curPos = sceIoLseek32(file, 0, PSP_SEEK_CUR);
+	if (curPos < 0) { *len = -1; return GetSCEResult(curPos); }
+	
+	*len = sceIoLseek32(file, 0, PSP_SEEK_END);
+	sceIoLseek32(file, curPos, PSP_SEEK_SET); // restore position
+	return 0;
+}
+
+
+/*########################################################################################################################*
+*--------------------------------------------------------Threading--------------------------------------------------------*
+*#########################################################################################################################*/
+// !!! NOTE: PSP uses cooperative multithreading (not preemptive multithreading) !!!
+void Thread_Sleep(cc_uint32 milliseconds) { 
+	sceKernelDelayThread(milliseconds * 1000); 
+}
+
+static int ExecThread(unsigned int argc, void *argv) {
+	Thread_StartFunc* func = (Thread_StartFunc*)argv;
+	(*func)();
+	return 0;
+}
+
+void Thread_Run(void** handle, Thread_StartFunc func, int stackSize, const char* name) {
+	#define CC_THREAD_PRIORITY 17 // TODO: 18?
+	#define CC_THREAD_ATTRS 0 // TODO PSP_THREAD_ATTR_VFPU?
+	Thread_StartFunc func_ = func;
+	
+	int threadID = sceKernelCreateThread(name, ExecThread, CC_THREAD_PRIORITY, 
+										stackSize, CC_THREAD_ATTRS, NULL);
+										
+	*handle = (void*)threadID;
+	sceKernelStartThread(threadID, sizeof(func_), (void*)&func_);
+}
+
+void Thread_Detach(void* handle) {
+	sceKernelDeleteThread((int)handle); // TODO don't call this??
+}
+
+void Thread_Join(void* handle) {
+	sceKernelWaitThreadEnd((int)handle, NULL);
+	sceKernelDeleteThread((int)handle);
+}
+
+void* Mutex_Create(const char* name) {
+	SceLwMutexWorkarea* ptr = (SceLwMutexWorkarea*)Mem_Alloc(1, sizeof(SceLwMutexWorkarea), "mutex");
+	int res = sceKernelCreateLwMutex(ptr, name, 0, 0, NULL);
+	if (res) Logger_Abort2(res, "Creating mutex");
+	return ptr;
+}
+
+void Mutex_Free(void* handle) {
+	int res = sceKernelDeleteLwMutex((SceLwMutexWorkarea*)handle);
+	if (res) Logger_Abort2(res, "Destroying mutex");
+	Mem_Free(handle);
+}
+
+void Mutex_Lock(void* handle) {
+	int res = sceKernelLockLwMutex((SceLwMutexWorkarea*)handle, 1, NULL);
+	if (res) Logger_Abort2(res, "Locking mutex");
+}
+
+void Mutex_Unlock(void* handle) {
+	int res = sceKernelUnlockLwMutex((SceLwMutexWorkarea*)handle, 1);
+	if (res) Logger_Abort2(res, "Unlocking mutex");
+}
+
+void* Waitable_Create(const char* name) {
+	int evid = sceKernelCreateEventFlag(name, PSP_EVENT_WAITMULTIPLE, 0, NULL);
+	if (evid < 0) Logger_Abort2(evid, "Creating waitable");
+	return (void*)evid;
+}
+
+void Waitable_Free(void* handle) {
+	sceKernelDeleteEventFlag((int)handle);
+}
+
+void Waitable_Signal(void* handle) {
+	int res = sceKernelSetEventFlag((int)handle, 0x1);
+	if (res < 0) Logger_Abort2(res, "Signalling event");
+}
+
+void Waitable_Wait(void* handle) {
+	u32 match;
+	int res = sceKernelWaitEventFlag((int)handle, 0x1, PSP_EVENT_WAITAND | PSP_EVENT_WAITCLEAR, &match, NULL);
+	if (res < 0) Logger_Abort2(res, "Event wait");
+}
+
+void Waitable_WaitFor(void* handle, cc_uint32 milliseconds) {
+	SceUInt timeout = milliseconds * 1000;
+	u32 match;
+	int res = sceKernelWaitEventFlag((int)handle, 0x1, PSP_EVENT_WAITAND | PSP_EVENT_WAITCLEAR, &match, &timeout);
+	if (res < 0) Logger_Abort2(res, "Event timed wait");
+}
+
+
+/*########################################################################################################################*
+*---------------------------------------------------------Socket----------------------------------------------------------*
+*#########################################################################################################################*/
+cc_result Socket_ParseAddress(const cc_string* address, int port, cc_sockaddr* addrs, int* numValidAddrs) {
+	struct sockaddr_in* addr4 = (struct sockaddr_in*)addrs[0].data;
+	char str[NATIVE_STR_LEN];
+	char buf[1024];
+	int rid, ret;
+	
+	String_EncodeUtf8(str, address);
+	*numValidAddrs = 1;
+
+	if (sceNetInetInetPton(AF_INET, str, &addr4->sin_addr) <= 0) {
+		/* Fallback to resolving as DNS name */
+		if (sceNetResolverCreate(&rid, buf, sizeof(buf)) < 0) 
+			return ERR_INVALID_ARGUMENT;
+
+		ret = sceNetResolverStartNtoA(rid, str, &addr4->sin_addr, 1 /* timeout */, 5 /* retries */);
+		sceNetResolverDelete(rid);
+		if (ret < 0) return ret;
+	}
+	
+	addr4->sin_family = AF_INET;
+	addr4->sin_port   = htons(port);
+		
+	addrs[0].size = sizeof(*addr4);
+	return 0;
+}
+
+cc_result Socket_Connect(cc_socket* s, cc_sockaddr* addr, cc_bool nonblocking) {
+	struct sockaddr* raw = (struct sockaddr*)addr->data;
+	int res;
+
+	*s = sceNetInetSocket(raw->sa_family, SOCK_STREAM, IPPROTO_TCP);
+	if (*s < 0) return sceNetInetGetErrno();
+	
+	if (nonblocking) {
+		int on = 1;
+		sceNetInetSetsockopt(*s, SOL_SOCKET, SO_NONBLOCK, &on, sizeof(int));
+	}
+
+	res = sceNetInetConnect(*s, raw, addr->size);
+	return res < 0 ? sceNetInetGetErrno() : 0;
+}
+
+cc_result Socket_Read(cc_socket s, cc_uint8* data, cc_uint32 count, cc_uint32* modified) {
+	int recvCount = sceNetInetRecv(s, data, count, 0);
+	if (recvCount >= 0) { *modified = recvCount; return 0; }
+	
+	*modified = 0; 
+	return sceNetInetGetErrno();
+}
+
+cc_result Socket_Write(cc_socket s, const cc_uint8* data, cc_uint32 count, cc_uint32* modified) {
+	int sentCount = sceNetInetSend(s, data, count, 0);
+	if (sentCount >= 0) { *modified = sentCount; return 0; }
+	
+	*modified = 0; 
+	return sceNetInetGetErrno();
+}
+
+void Socket_Close(cc_socket s) {
+	sceNetInetShutdown(s, SHUT_RDWR);
+	sceNetInetClose(s);
+}
+
+static cc_result Socket_Poll(cc_socket s, int mode, cc_bool* success) {
+	fd_set set;
+	struct SceNetInetTimeval time = { 0 };
+	int selectCount;
+
+	FD_ZERO(&set);
+	FD_SET(s, &set);
+
+	if (mode == SOCKET_POLL_READ) {
+		selectCount = sceNetInetSelect(s + 1, &set, NULL, NULL, &time);
+	} else {
+		selectCount = sceNetInetSelect(s + 1, NULL, &set, NULL, &time);
+	}
+
+	if (selectCount == -1) {
+		*success = false; 
+		return errno;
+	}
+	
+	*success = FD_ISSET(s, &set) != 0; 
+	return 0;
+}
+
+cc_result Socket_CheckReadable(cc_socket s, cc_bool* readable) {
+	return Socket_Poll(s, SOCKET_POLL_READ, readable);
+}
+
+cc_result Socket_CheckWritable(cc_socket s, cc_bool* writable) {
+	socklen_t resultSize = sizeof(socklen_t);
+	cc_result res = Socket_Poll(s, SOCKET_POLL_WRITE, writable);
+	if (res || *writable) return res;
+
+	// https://stackoverflow.com/questions/29479953/so-error-value-after-successful-socket-operation
+	sceNetInetGetsockopt(s, SOL_SOCKET, SO_ERROR, &res, &resultSize);
+	return res;
+}
+
+
+/*########################################################################################################################*
+*--------------------------------------------------------Platform---------------------------------------------------------*
+*#########################################################################################################################*/
+static void InitNetworking(void) {
+    sceUtilityLoadNetModule(PSP_NET_MODULE_COMMON);
+    sceUtilityLoadNetModule(PSP_NET_MODULE_INET);    
+    int res;
+
+    res = sceNetInit(128 * 1024, 0x20, 4096, 0x20, 4096);
+    if (res < 0) { Platform_Log1("sceNetInit failed: %i", &res); return; }
+
+    res = sceNetInetInit();
+    if (res < 0) { Platform_Log1("sceNetInetInit failed: %i", &res); return; }
+
+    res = sceNetResolverInit();
+    if (res < 0) { Platform_Log1("sceNetResolverInit failed: %i", &res); return; }
+
+    res = sceNetApctlInit(10 * 1024, 0x30);
+    if (res < 0) { Platform_Log1("sceNetApctlInit failed: %i", &res); return; }
+    
+    res = sceNetApctlConnect(1); // 1 = first profile
+    if (res) { Platform_Log1("sceNetApctlConnect failed: %i", &res); return; }
+
+    for (int try = 0; try < 20; try++) {
+        int state;
+        res = sceNetApctlGetState(&state);
+        if (res) { Platform_Log1("sceNetApctlGetState failed: %i", &res); return; }
+        
+        if (state == PSP_NET_APCTL_STATE_GOT_IP) break;
+
+        // not successful yet? try polling again in 50 ms
+        sceKernelDelayThread(50 * 1000);
+    }
+}
+
+void Platform_Init(void) {
+	InitNetworking();
+	/*pspDebugSioInit();*/ 
+	
+	// Disabling FPU exceptions avoids sometimes crashing with this line in Physics.c
+	//  *tx = vel->x == 0.0f ? MATH_LARGENUM : Math_AbsF(dx / vel->x);
+	// TODO: work out why this error is actually happening (inexact or underflow?) and properly fix it
+	pspSdkDisableFPUExceptions();
+	
+	// Create root directory
+	Directory_Create(&String_Empty);
+}
+void Platform_Free(void) { }
+
+cc_bool Platform_DescribeError(cc_result res, cc_string* dst) {
+	char chars[NATIVE_STR_LEN];
+	int len;
+
+	/* For unrecognised error codes, strerror_r might return messages */
+	/*  such as 'No error information', which is not very useful */
+	/* (could check errno here but quicker just to skip entirely) */
+	if (res >= 1000) return false;
+
+	len = strerror_r(res, chars, NATIVE_STR_LEN);
+	if (len == -1) return false;
+
+	len = String_CalcLen(chars, NATIVE_STR_LEN);
+	String_AppendUtf8(dst, chars, len);
+	return true;
+}
+
+cc_bool Process_OpenSupported = false;
+cc_result Process_StartOpen(const cc_string* args) {
+	return ERR_NOT_SUPPORTED;
+}
+
+
+/*########################################################################################################################*
+*-------------------------------------------------------Encryption--------------------------------------------------------*
+*#########################################################################################################################*/
+static cc_result GetMachineID(cc_uint32* key) {
+	return ERR_NOT_SUPPORTED;
+}
+#endif