Function sync_timer_new

lib_fiber/c/src/sync/sync_timer.c:18–44

};

static SYNC_TIMER *sync_timer_new(void)
{
	SYNC_TIMER *timer = (SYNC_TIMER*) mem_calloc(1, sizeof(SYNC_TIMER));
	socket_t in, out;
	FILE_EVENT *fe;

	pthread_mutex_init(&timer->lock, NULL);
	timer->box = mbox_create(MBOX_T_MPSC);
//	timer->waiters = timer_cache_create();
	timer->tid = thread_self();

	out = mbox_out(timer->box);
	assert(out != INVALID_SOCKET);
	fe = fiber_file_open(out);
	assert(fe);
	fe->type |= TYPE_INTERNAL | TYPE_EVENTABLE;

	in = mbox_in(timer->box);
	assert(in != INVALID_SOCKET);
	if (in != out) {
		fe = fiber_file_open(in);
		assert(fe);
		fe->type |= TYPE_INTERNAL | TYPE_EVENTABLE;
	}

	return timer;
}

static void sync_timer_free(SYNC_TIMER *timer)
{