#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <unistd.h>

#include <fcntl.h>
#include <sys/time.h>
#include <time.h>

#include <pthread.h>

#ifdef WIN32
#include <windows.h>
//#include "../pthread.h"
#else
#include <sys/socket.h>
#include <netdb.h>
#include <netinet/in.h>
#include <netinet/ip.h>
#include <netinet/tcp.h>
#include <errno.h>
#endif

#include "common.h"
#include "debug.h"
#include "threads.h"

int create_prio_thread(pthread_t *tid, threadfn func, void *arg, int newprio) //0 to 99
{
  pthread_attr_t tattr;
  int ret;
  struct sched_param param;

  /* initialized with default attributes */
  ret = pthread_attr_init (&tattr);

  /* safe to get existing scheduling param */
  ret = pthread_attr_getschedparam (&tattr, &param);

  /* set the priority; others are unchanged */
  param.sched_priority = newprio;

  /* setting the new scheduling param */
  ret = pthread_attr_setschedparam (&tattr, &param);

	pthread_attr_setstacksize(&tattr, 1024*100);

  /* with new priority specified */
	while (1) {
		ret = pthread_create (tid, &tattr, func, arg);
		if (ret==EAGAIN) {
			usleep(10000);
			continue;
		}
		if (ret!=0) return 0;
		break;
	}
	pthread_detach(*tid);
	usleep(1000); // wait 1ms
	return ret;
}