#include <stdio.h>
#include <kernel/OS.h>
#include <string.h>
#include <sys/time.h>

#include "sys/socket.h"
#include "netinet/in.h"
#include "arpa/inet.h"
#include "sys/select.h"

#define THREADS	2
#define TIME	10

int32 test_thread(void *data)
{
	int tnum = *(int*)data;
	int sock = 0;
	uint32 num = 0;
	bigtime_t tn;

	printf("Thread %d, starting test...\n", tnum + 1);

	tn = real_time_clock();

	while (real_time_clock() - tn <= TIME) {
		sock = socket(AF_INET, SOCK_DGRAM , 0);
		if (sock < 0) {
			printf("Failed! Socket could not be created.\n");
			printf("Error was %d [%s]\n", sock, strerror(sock));
			printf("This was after I had created %ld socket%s\n",
				num, num == 1 ? "" : "s");
			return -1;
		}
		closesocket(sock);
		num++;
	}

	printf( "Thread %d:\n"
		"       sockets created : %5ld\n"
		"       test time       : %5d seconds\n"
		"       average         : %5ld sockets/sec\n",
		tnum + 1, num, TIME, num / TIME);
}

#define TEST_PHRASE "Hello loopback!"
	
int main(int argc, char **argv)
{
	thread_id t[THREADS];
	int i;
	status_t retval;
		
	for (i=0;i<THREADS;i++) {
		t[i] = spawn_thread(test_thread, "socket test thread", 
			B_NORMAL_PRIORITY, &i);
		if (t[i] >= 0)
			resume_thread(t[i]);
	}

	for (i=0;i<THREADS;i++) {
		wait_for_thread(t[i], &retval);
	}

	printf("Test complete.\n");

	return (0);
}