#include <stdio.h>
#include <stdlib.h>
#include "types.h"
#include "TaskListInfo.h"


// Singleton TaskList Pool
TaskListInfo TaskListInfo::taskListPool;   

TaskListInfo::TaskListInfo() {
    // 最初の一つは自分
    first = last = this;
    next = prev = this;
    waiter = NULL;
}

void
TaskListInfo::freePool() { 
    for(TaskListPtr p = taskListPool.waiter; p; ) {
	TaskListPtr next = p->waiter;
	p->waiter = NULL;
	free(p);
	p = next;
    }
}

int
TaskListInfo::extend_pool(int num)
{
    TaskListPtr q = (TaskListPtr)malloc(sizeof(TaskList)*(num+1)+DEFAULT_ALIGNMENT);

    // First Queue is previous pool
    q->waiter = waiter; waiter = q;
    q = (TaskListPtr)ROUND_UP_ALIGN((long)q, DEFAULT_ALIGNMENT);
    q++;

    /* Connect all free queue in the pool */
    TaskListPtr p = q;
    for (; num-- > 0; p++) {
	p->waiter = NULL;
	taskListPool.addLast(p);
    }

    return 0;
}

/**
 * Task をプールから取って来て返す
 *
 * @param [cmd] タスクコマンド
 */
TaskListPtr
TaskListInfo::create()
{
    TaskListPtr q =  taskListPool.poll();
    if (! q)  {
	taskListPool.extend_pool(64);
	q = taskListPool.poll();
    }
    q->init();
    return q;
}


void
TaskListInfo::free_(TaskListPtr q)
{
    q->waiter = NULL;
    taskListPool.addLast(q);
}

void
TaskListInfo::freeAll()
{
    TaskListPtr t;
    if (getLast()->next==0) getLast()->next = this;
    while((t=poll())) free_(t);
}


/*!
  TaskListInfo は空にならない。最低1個は要素が入っていて
  1個目は特別扱いする。getFirst すると first->next を返す
 */

/*!
  最初の1個は特別扱いなので、それの後に追加していく
 */
void
TaskListInfo::addFirst(TaskList* e)
{
    e->prev = first;
    e->next = first->next;
    first->next->prev = e;
    first->next = e;
}

void
TaskListInfo::addLast(TaskList* e)
{
#ifdef CHECK
    if (find(e)) { 
	fprintf(stderr,"Add duplicate task %0x\n",(int)e);
	return; 
       // ...  
    }
#endif
    e->next = first;
    e->prev = last;
    last->next = e;
    last = e;
}

TaskList*
TaskListInfo::getFirst()
{
    if (empty()) return NULL;
    return first->next;
}

TaskList*
TaskListInfo::getLast()
{
    if (empty()) return NULL;
    return last;
}

int
TaskListInfo::remove(TaskList* e)
{
#ifdef CHECK
    if (!find(e)) { 
	fprintf(stderr,"Remove non existing task %0x\n",(int)e);
	return 0; 
       // ...  
    }
#endif
    e->prev->next = e->next;
    e->next->prev = e->prev;

    if (first->next == e) {
	first->next = e->next;
    }
    if (last == e) {
	last = e->prev;
    }

    e->prev = NULL;
    e->next = NULL;

    return 1;
}

/*!
  リストの先頭を取得および削除する。リストが空の場合は NULL を返す。
 */

TaskList*
TaskListInfo::poll()
{
    TaskList* e = first->next;
    if (e == this) {
	return NULL;
    }
    remove(e);
    return e;
}

void
TaskListInfo::moveToFirst(TaskList* e)
{
    remove(e);
    addFirst(e);
}

/*!
  リスト内の指定された位置にある要素を返す。
  要素数を超えた位置を指定した場合 NULL を返す。
 */

TaskList*
TaskListInfo::get(int index)
{
    TaskList* e = first->next;
    for (int i = 0; i < index; i++) {
	if (e == this) return NULL;
	e = e->next;
    }
    return e;
}

TaskList*
TaskListInfo::find(TaskList* task)
{
    TaskList* e = first->next;
    for(;;) {
	if (e == this) return NULL;
	if (e == task) break;
	e = e->next;
    }
    return e;
}

int
TaskListInfo::empty()
{
    return next == this;
}

TaskList*
TaskListInfo::getNext(TaskList* q) 
{
    if (q->next==this) return NULL;
    return q->next;
}

int
TaskListInfo::length() 
{
    int i = 1;
    if (empty()) return 0;
    TaskList* e = first;
    while((e = e->next) != this ) i++;
    return i;
}




/* end */