#include <stdlib.h>

#include "synchronizedQueueContext.h"

extern __code code1(struct Context*);
extern __code code2(struct Context*);
extern __code code3(struct Context*);
extern __code code4(struct Context*);
extern __code code5(struct Context*);
extern __code code6(struct Context*);
extern __code code7(struct Context*);
extern __code meta(struct Context*);
extern __code allocate(struct Context*);
extern __code sender(struct Context*);
extern __code put(struct Context*);
extern __code receiver(struct Context*);
extern __code get(struct Context*);
extern __code exit_code(struct Context*);

__code initSynchronizedQueueContext(struct Context* context) {
    context->dataSize   = sizeof(union Data)*ALLOCATE_SIZE;
    context->code       = malloc(sizeof(__code*)*ALLOCATE_SIZE);
    context->data       = malloc(sizeof(union Data*)*ALLOCATE_SIZE);
    context->heap_start = malloc(context->dataSize);

    context->codeNum         = Exit;
    context->code[Code1]     = code1;
    context->code[Code2]     = code2;
    context->code[Code3]     = code3;
    context->code[Code4]     = code4;
    context->code[Code5]     = code5;
    context->code[Code6]     = code6;
    context->code[Code7]     = code7;
    context->code[Allocator] = allocate;
    context->code[Sender]    = sender;
    context->code[Put]       = put;
    context->code[Receiver]  = receiver;
    context->code[Get]       = get;
    context->code[Exit]      = exit_code;

    context->heap = context->heap_start;

    context->data[Allocate] = context->heap;
    context->heap          += sizeof(struct Allocate);

    context->data[Queue]    = context->heap;
    context->heap          += sizeof(struct Queue);
    context->data[Queue]->queue.first = 0;
    pthread_mutex_init(&context->data[Queue]->queue.mutex, NULL);

    context->dataNum = Queue;
}