/***************************************************************************************
 *
 *  IMPORTANT: READ BEFORE DOWNLOADING, COPYING, INSTALLING OR USING.
 *
 *  By downloading, copying, installing or using the software you agree to this license.
 *  If you do not agree to this license, do not download, install, 
 *  copy or use the software.
 *
 *  Copyright (C) 2014-2024, Happytimesoft Corporation, all rights reserved.
 *
 *  Redistribution and use in binary forms, with or without modification, are permitted.
 *
 *  Unless required by applicable law or agreed to in writing, software distributed 
 *  under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR
 *  CONDITIONS OF ANY KIND, either express or implied. See the License for the specific
 *  language governing permissions and limitations under the License.
 *
****************************************************************************************/

/***************************************************************************************/
#include "sys_inc.h"


/***************************************************************************************/
HT_API void * sys_os_create_mutex()
{
	void * p_mutex = NULL;

#ifdef IOS

    static int index = 0;
    char name[32] = {'\0'};
    snprintf(name, sizeof(name), "testmutex%u", (uint32)time(NULL)+index++);

    p_mutex = sem_open(name, O_CREAT, 0644, 1);
    if (p_mutex == SEM_FAILED)
    {
        log_print(HT_LOG_ERR, "%s, sem_open failed. name=%s\r\n", __FUNCTION__, name);
        return NULL;
    }

#elif __WINDOWS_OS__

	p_mutex  = CreateMutex(NULL, FALSE, NULL);

#elif __LINUX_OS__
	
	int ret;

	p_mutex = (sem_t *)malloc(sizeof(sem_t));
	ret = sem_init((sem_t *)p_mutex, 0, 1);
	if (ret != 0)
	{
		free(p_mutex);
		return NULL;
	}

#endif

	return p_mutex;
}

HT_API void * sys_os_create_sig()
{	
	void * p_sig = NULL;
    
#ifdef IOS
    
    static int index = 0;
    char name[32] = {'\0'};
    snprintf(name, sizeof(name), "testsig%u", (uint32)time(NULL)+index++);
    
    p_sig = sem_open(name, O_CREAT, 0644, 1);
    if (p_sig == SEM_FAILED)
    {
        log_print(HT_LOG_ERR, "%s, sem_open failed. name=%s\r\n", __FUNCTION__, name);
        return NULL;
    }

#elif __WINDOWS_OS__

	p_sig = CreateEvent(NULL, FALSE, FALSE, NULL);

#elif __LINUX_OS__

	int ret;

	p_sig = malloc(sizeof(sem_t));
	ret = sem_init((sem_t *)p_sig, 0, 0);
	if (ret != 0)
	{
		free(p_sig);
		return NULL;
	}

#endif

	return p_sig;
}

HT_API void sys_os_destroy_sig_mutex(void * ptr)
{
	if (ptr == NULL)
	{
		return;
	}
	
#ifdef IOS
    
    sem_close((sem_t *)ptr);
    
#elif __WINDOWS_OS__

	CloseHandle(ptr);

#elif __LINUX_OS__

	sem_destroy((sem_t *)ptr);
	free(ptr);

#endif
}

HT_API int sys_os_mutex_enter(void * p_sem)
{
	int ret;
	
	if (p_sem == NULL)
	{
		return -1;
	}
	
#if	__LINUX_OS__

	ret = sem_wait((sem_t *)p_sem);
	if (ret != 0)
	{
		return -1;
	}
	
#elif __WINDOWS_OS__

	ret = WaitForSingleObject(p_sem, INFINITE);
	if (ret == WAIT_FAILED)
	{
		return -1;
	}
	
#endif

	return 0;
}

HT_API void sys_os_mutex_leave(void * p_sem)
{
	if (p_sem == NULL)
	{
		return;
	}
	
#if	__LINUX_OS__

	sem_post((sem_t *)p_sem);
	
#elif __WINDOWS_OS__

	ReleaseMutex(p_sem);
	
#endif
}

HT_API int sys_os_sig_wait(void * p_sig)
{
	int ret;
		
	if (p_sig == NULL)
	{
		return -1;
	}
	
#if	__LINUX_OS__

	ret = sem_wait((sem_t *)p_sig);
	if (ret != 0)
	{
		return -1;
	}
	
#elif __WINDOWS_OS__

	ret = WaitForSingleObject(p_sig, INFINITE);
	if (ret == WAIT_FAILED)
	{
		return -1;
	}
	
#endif

	return 0;
}

HT_API int sys_os_sig_wait_timeout(void * p_sig, uint32 ms)
{
#ifdef IOS
    
	if (p_sig == NULL)
	{
		return -1;
	}
	
    while (ms > 0)
    {
        if (sem_trywait((sem_t *)p_sig) == 0)
        {
            return 0;
        }
        
        usleep(1000);
        
        ms -= 1;
    }
    
    return -1;
    
#elif __LINUX_OS__

    int ret;
	struct timespec ts;
	struct timeval tt;

	if (p_sig == NULL) 
	{
		return -1;
	}
	
	gettimeofday(&tt,NULL);

	tt.tv_sec = tt.tv_sec + ms / 1000;
	tt.tv_usec = tt.tv_usec + (ms % 1000) * 1000;
	tt.tv_sec += tt.tv_usec / (1000 * 1000);
	tt.tv_usec = tt.tv_usec % (1000 * 1000);
	
	ts.tv_sec = tt.tv_sec;
	ts.tv_nsec = tt.tv_usec * 1000;

	ret = sem_timedwait((sem_t *)p_sig, &ts);
	if (ret == -1 && errno == ETIMEDOUT)
	{
		return -1;
	}	
	else
	{
		return 0;
	}
	
#elif __WINDOWS_OS__

	DWORD ret;

	if (p_sig == NULL)
	{
		return -1;
	}
	
	ret = WaitForSingleObject(p_sig, ms);
	if (ret == WAIT_FAILED)
	{
		return -1;
	}	
	else if (ret == WAIT_TIMEOUT)
	{
		return -1;
	}
	
#endif

	return 0;
}

HT_API void sys_os_sig_sign(void * p_sig)
{
	if (p_sig == NULL)
	{
		return;
	}
	
#if	__LINUX_OS__

	sem_post((sem_t *)p_sig);
	
#elif __WINDOWS_OS__

	SetEvent(p_sig);
	
#endif
}

HT_API pthread_t sys_os_create_thread(void * thread_func, void * argv)
{
	pthread_t tid = 0;

#if	__LINUX_OS__

	int ret = pthread_create(&tid, NULL, (void *(*)(void *))thread_func, argv);
	if (ret != 0)
	{
		log_print(HT_LOG_ERR, "%s, pthread_create failed, ret = %d\r\n", __FUNCTION__, ret);		
	}

	pthread_detach(tid);

#elif __WINDOWS_OS__

	HANDLE hret = CreateThread(NULL, 0, (LPTHREAD_START_ROUTINE)thread_func, argv, 0, &tid);
	if (hret == NULL || tid == 0)
	{
		log_print(HT_LOG_ERR, "%s, CreateThread hret=%u, tid=%u, err=%u\r\n", __FUNCTION__, hret, tid, GetLastError());
	}

	CloseHandle(hret);

#endif

	return tid;
}

HT_API uint32 sys_os_get_ms()
{
	uint32 ms = 0;

#if __LINUX_OS__

	struct timeval tv;
	gettimeofday(&tv, NULL);
	
	ms = tv.tv_sec * 1000 + tv.tv_usec/1000;

#elif __WINDOWS_OS__

	ms = GetTickCount();

#endif

	return ms;
}

HT_API uint32 sys_os_get_uptime()
{
	uint32 upt = 0;

#ifdef ANDROID

    upt = (uint32)time(NULL);
    
#elif __LINUX_OS__

    int rlen;
	char bufs[512];
	char * ptr;	
	FILE * file;

	file = fopen("/proc/uptime", "rb");
	if (NULL == file)
	{
		return (uint32)time(NULL);
    }
    
	rlen = fread(bufs, 1, sizeof(bufs)-1, file);
	fclose(file);

	if (rlen <= 0)
	{
		return (uint32)time(NULL);
	}
	
	bufs[rlen] = '\0';
	ptr = bufs;
	
	while (*ptr != '\0' && *ptr != ' ' && *ptr != '\r' && *ptr != '\n')
	{
	    ptr++;
	}
	
	if (*ptr == ' ')
	{
		*ptr = '\0';
	}	
	else
	{
		return (uint32)time(NULL);
    }
    
	upt = (uint32)strtod(bufs, NULL);

#elif __WINDOWS_OS__

	LARGE_INTEGER freq;
	LARGE_INTEGER cur;
	
	QueryPerformanceFrequency(&freq);
	QueryPerformanceCounter(&cur);
	
	upt = (uint32) (cur.QuadPart / freq.QuadPart);

#endif

	return upt;
}

HT_API char * sys_os_get_socket_error()
{
	char * p_estr = NULL;
	
#if __LINUX_OS__

	p_estr = strerror(errno);
	
#elif __WINDOWS_OS__

	int err = WSAGetLastError();
	static char err_buf[24];
	snprintf(err_buf, sizeof(err_buf), "WSAE-%d", err);
	p_estr = err_buf;
	
#endif

	return p_estr;
}

HT_API int sys_os_get_socket_error_num()
{
	int sockerr;
	
#if __LINUX_OS__

	sockerr = errno;
	
#elif __WINDOWS_OS__

	sockerr = WSAGetLastError();
	
#endif

	return sockerr;
}