//
// Generated by dtk
// Translation Unit: f_pc_node_req.cpp
//

#include "f_pc/f_pc_node_req.h"
#include "SSystem/SComponent/c_malloc.h"
#include "SSystem/SComponent/c_node.h"
#include "SSystem/SStandard/s_basic.h"
#include "f_pc/f_pc_deletor.h"
#include "f_pc/f_pc_executor.h"
#include "f_pc/f_pc_layer.h"
#include "f_pc/f_pc_node.h"
#include "f_pc/f_pc_stdcreate_req.h"
#include "f_pc/f_pc_manager.h"

/* 8003F29C-8003F2DC       .text fpcNdRq_RequestQTo__FP19node_create_request */
void fpcNdRq_RequestQTo(node_create_request* i_NdCtReq) {
    fpcLy_CreatedMesg(i_NdCtReq->mpLayerClass);
    fpcLy_CancelQTo(&i_NdCtReq->mProcMthCls);
    cTg_SingleCut(&i_NdCtReq->mCreateTag);
}

static node_list_class l_fpcNdRq_Queue = {NULL, NULL, 0};

/* 8003F2DC-8003F328       .text fpcNdRq_ToRequestQ__FP19node_create_request */
void fpcNdRq_ToRequestQ(node_create_request* i_NdCtReq) {
    cTg_Addition(&l_fpcNdRq_Queue, &i_NdCtReq->mCreateTag);
    fpcLy_ToCancelQ(i_NdCtReq->mpLayerClass, &i_NdCtReq->mProcMthCls);
    fpcLy_CreatingMesg(i_NdCtReq->mpLayerClass);
}

/* 8003F328-8003F380       .text fpcNdRq_phase_IsCreated__FP19node_create_request */
cPhs_State fpcNdRq_phase_IsCreated(node_create_request* i_NdCtReq) {
    if (fpcCtRq_IsCreatingByID(i_NdCtReq->mCreatingID) == TRUE) {
        return cPhs_INIT_e;
    } else {
        if (fpcEx_IsExist(i_NdCtReq->mCreatingID) == TRUE) {
            return cPhs_NEXT_e;
        } else {
            return cPhs_STOP_e;
        }
    }
}

/* 8003F380-8003F3DC       .text fpcNdRq_phase_Create__FP19node_create_request */
cPhs_State fpcNdRq_phase_Create(node_create_request* i_NdCtReq) {
    i_NdCtReq->mCreatingID = fpcSCtRq_Request(i_NdCtReq->mpLayerClass, i_NdCtReq->mProcName,
        (stdCreateFunc)i_NdCtReq->mpNodeCrReqMthCls->mpPostMethodFunc, i_NdCtReq,
        i_NdCtReq->mpUserData);
    if (i_NdCtReq->mCreatingID == fpcM_ERROR_PROCESS_ID_e) {
        return cPhs_STOP_e;
     } else {
        return cPhs_NEXT_e;
     }
}

/* 8003F3DC-8003F3E4       .text fpcNdRq_phase_IsDeleteTiming__FP19node_create_request */
cPhs_State fpcNdRq_phase_IsDeleteTiming(node_create_request* i_NdCtReq) {
    return cPhs_NEXT_e;
}

/* 8003F3E4-8003F414       .text fpcNdRq_phase_IsDeleted__FP19node_create_request */
cPhs_State fpcNdRq_phase_IsDeleted(node_create_request* i_NdCtReq) {
    if (fpcDt_IsComplete() == FALSE) {
        return cPhs_INIT_e;
     } else {
        return cPhs_NEXT_e;
     }
}

/* 8003F414-8003F468       .text fpcNdRq_phase_Delete__FP19node_create_request */
cPhs_State fpcNdRq_phase_Delete(node_create_request* i_NdCtReq) {
    if (i_NdCtReq->mNodeProc.mpNodeProc != NULL) {
        if (fpcDt_Delete(&i_NdCtReq->mNodeProc.mpNodeProc->base) == FALSE) {
            return cPhs_INIT_e;
        }
        i_NdCtReq->mNodeProc.mpNodeProc = NULL;
    }
    return cPhs_NEXT_e;
}

/* 8003F468-8003F4B0       .text fpcNdRq_DoPhase__FP19node_create_request */
cPhs_State fpcNdRq_DoPhase(node_create_request* i_NdCtReq) {
    cPhs_State result = cPhs_Handler(&i_NdCtReq->mReqPhsProc, i_NdCtReq->mpPhsHandler, i_NdCtReq);
    if (result == cPhs_NEXT_e) {
        return fpcNdRq_DoPhase(i_NdCtReq);
    }
    return result;
}

/* 8003F4B0-8003F514       .text fpcNdRq_Execute__FP19node_create_request */
cPhs_State fpcNdRq_Execute(node_create_request* i_NdCtReq) {
    cPhs_State result = fpcNdRq_DoPhase(i_NdCtReq);
    switch (result) {
    case cPhs_INIT_e:
    case cPhs_LOADING_e:
        return cPhs_INIT_e;
    case cPhs_COMPLEATE_e:
        return cPhs_NEXT_e;
    case cPhs_ERROR_e:
    case cPhs_STOP_e:
        return cPhs_STOP_e;
    default:
        return result;
    }
}

/* 8003F514-8003F57C       .text fpcNdRq_Delete__FP19node_create_request */
BOOL fpcNdRq_Delete(node_create_request* i_NdCtReq) {
    fpcNdRq_RequestQTo(i_NdCtReq);
    if (
        i_NdCtReq->mpNodeCrReqMthCls != NULL &&
        i_NdCtReq->mpNodeCrReqMthCls->mpUnkFunc != NULL &&
        fpcMtd_Method(i_NdCtReq->mpNodeCrReqMthCls->mpUnkFunc, i_NdCtReq) == FALSE
    )
        return FALSE;
    cMl::free(i_NdCtReq);
    return TRUE;
}

/* 8003F57C-8003F5D4       .text fpcNdRq_Cancel__FP19node_create_request */
BOOL fpcNdRq_Cancel(node_create_request* i_NdCtReq) {
    if (
        i_NdCtReq->mpNodeCrReqMthCls != NULL &&
        fpcMtd_Method(i_NdCtReq->mpNodeCrReqMthCls->mpCancelFunc, i_NdCtReq) == FALSE
    )
        return FALSE;
    return fpcNdRq_Delete(i_NdCtReq);
}

/* 8003F5D4-8003F6BC       .text fpcNdRq_Handler__Fv */
s32 fpcNdRq_Handler() {
    node_class* currentNode = l_fpcNdRq_Queue.mpHead;
    while (currentNode != NULL) {
        node_create_request* req = ((request_node_class*)currentNode)->mNodeCrReq;
        switch (req->mpNodeCrReqMthCls->mpExecuteFunc(req)) {
        case cPhs_STOP_e:
        case cPhs_ERROR_e:
            currentNode = NODE_GET_NEXT(currentNode);
            if (fpcNdRq_Cancel(req) == FALSE) {
                return 0;
            }
            break;
        case cPhs_COMPLEATE_e:
            currentNode = NODE_GET_NEXT(currentNode);
            if (fpcNdRq_Delete(req) == FALSE) {
                return 0;
            }
            break;
        default:
            currentNode = NODE_GET_NEXT(currentNode);
            break;
        }
    }
    return 1;
}

/* 8003F6BC-8003F728       .text fpcNdRq_IsPossibleTarget__FP18process_node_class */
s32 fpcNdRq_IsPossibleTarget(process_node_class* i_procNode) {
    fpc_ProcID bsPcId = i_procNode->base.mBsPcId;
    request_node_class* currentNode;
    node_create_request* currentNdCr;
    currentNode = (request_node_class*)l_fpcNdRq_Queue.mpHead;
    while (currentNode != NULL) {
        currentNdCr = currentNode->mNodeCrReq;
        if ((currentNdCr->mParameter == 2 || currentNdCr->mParameter == 4 || currentNdCr->mParameter == 1) && currentNdCr->mNodeProc.mProcId == bsPcId)
            return 0;
        currentNode = (request_node_class*)NODE_GET_NEXT((&currentNode->base));
    }
    return 1;
}

/* 8003F728-8003F774       .text fpcNdRq_IsIng__FP18process_node_class */
s32 fpcNdRq_IsIng(process_node_class* i_procNode) {
    request_node_class* currentNode;
    node_create_request* currentNodeReq;
    fpc_ProcID bsPcId = i_procNode->base.mBsPcId;
    currentNode = (request_node_class*)l_fpcNdRq_Queue.mpHead;
    while (currentNode != NULL) {
        currentNodeReq = currentNode->mNodeCrReq;
        if (currentNodeReq->mCreatingID == bsPcId)
            return 1;
        currentNode = (request_node_class*)NODE_GET_NEXT((&currentNode->base));
    }
    return 0;
}

/* 8003F774-8003F8EC       .text fpcNdRq_Create__FUl */
node_create_request* fpcNdRq_Create(u32 i_requestSize) {
    static node_create_request clear = {
        NULL, NULL,       NULL, NULL,       0,      NULL, NULL,   NULL, NULL,
        0,    NULL,       NULL, NULL,       0,      0,    NULL,   5,    0xFFFFFFFF,
        NULL, 0xFFFFFFFE, NULL, 0xFFFFFFFE, 0x7FFF, NULL, 0x7FFF,
    };

    node_create_request* req = (node_create_request*)cMl::memalignB(-4, i_requestSize);
    if (req != NULL) {
        static uint request_id = 0;
        sBs_ClearArea(req, i_requestSize);
        *req = clear;
        cTg_Create(&req->mCreateTag, req);
        fpcMtdTg_Init(&req->mProcMthCls, (process_method_tag_func)fpcNdRq_Cancel, req);
        req->mRequestId = request_id++;
    }
    return req;
}

/* 8003F8EC-8003F988       .text fpcNdRq_ChangeNode__FUlP18process_node_classsPv */
node_create_request* fpcNdRq_ChangeNode(u32 i_requestSize, process_node_class* i_procNode,
                                        s16 i_procName, void* i_data) {
    static cPhs__Handler methods[] = {
        (cPhs__Handler)fpcNdRq_phase_IsDeleteTiming,
        (cPhs__Handler)fpcNdRq_phase_Delete,
        (cPhs__Handler)fpcNdRq_phase_IsDeleted,
        (cPhs__Handler)fpcNdRq_phase_Create,
        (cPhs__Handler)fpcNdRq_phase_IsCreated,
        NULL,
    };

    if (fpcNdRq_IsPossibleTarget(i_procNode) == 1 && fpcNdRq_IsIng(i_procNode) == 0) {
        node_create_request* req = fpcNdRq_Create(i_requestSize);
        if (req != NULL) {
            req->mpPhsHandler = methods;
            req->mNodeProc.mpNodeProc = i_procNode;
            req->mNodeProc.mProcId = i_procNode->base.mBsPcId;
            req->mpLayerClass = i_procNode->base.mLyTg.mpLayer;
            req->mProcName = i_procName;
            req->mpUserData = i_data;
        }
        return req;
    } else {
        return NULL;
    }
}

/* 8003F988-8003FA14       .text fpcNdRq_DeleteNode__FUlP18process_node_class */
node_create_request* fpcNdRq_DeleteNode(u32 i_requestSize, process_node_class* i_procNode) {
    static cPhs__Handler methods[] = {
        (cPhs__Handler)fpcNdRq_phase_IsDeleteTiming,
        (cPhs__Handler)fpcNdRq_phase_Delete,
        (cPhs__Handler)fpcNdRq_phase_IsDeleted,
        NULL,
    };

    if (fpcNdRq_IsPossibleTarget(i_procNode) == 1 && fpcNdRq_IsIng(i_procNode) == 0) {
        node_create_request* req = fpcNdRq_Create(i_requestSize);
        if (req != NULL) {
            req->mpPhsHandler = methods;
            req->mNodeProc.mpNodeProc = i_procNode;
            req->mNodeProc.mProcId = i_procNode->base.mBsPcId;
            req->mpLayerClass = i_procNode->base.mLyTg.mpLayer;
        }
        return req;
    } else {
        return NULL;
    }
}

/* 8003FA14-8003FAC0       .text fpcNdRq_CreateNode__FUlsPv */
node_create_request* fpcNdRq_CreateNode(u32 i_requestSize, s16 i_procName, void* i_data) {
    static cPhs__Handler methods[] = {
        (cPhs__Handler)fpcNdRq_phase_Create,
        (cPhs__Handler)fpcNdRq_phase_IsCreated,
        NULL,
    };

    layer_class* layer = fpcLy_CurrentLayer();
    if (layer->mLayerID != 0 && fpcNdRq_IsPossibleTarget(layer->mpPcNode) == 0) {
        return NULL;
    } else {
        node_create_request* req = fpcNdRq_Create(i_requestSize);
        if (req != NULL) {
            req->mpPhsHandler = methods;
            if (layer->mLayerID != 0) {
                req->mNodeProc.mpNodeProc = layer->mpPcNode;
                req->mNodeProc.mProcId = layer->mpPcNode->base.mBsPcId;
            }
            req->mpLayerClass = layer;
            req->mProcName = i_procName;
            req->mpUserData = i_data;
        }
        return req;
    }
}

/* 8003FAC0-8003FB70       .text fpcNdRq_Request__FUliP18process_node_classsPvP32node_create_request_method_class */
node_create_request* fpcNdRq_Request(u32 i_requestSize, int i_reqType,
                                     process_node_class* i_procNode, s16 i_procName, void* i_data,
                                     node_create_request_method_class* i_nodeCtRqMtd) {
    node_create_request* req;
    switch (i_reqType) {
    case 0:
        req = fpcNdRq_CreateNode(i_requestSize, i_procName, i_data);
        break;
    case 1:
        req = fpcNdRq_DeleteNode(i_requestSize, i_procNode);
        break;
    case 2:
        req = fpcNdRq_ChangeNode(i_requestSize, i_procNode, i_procName, i_data);
        break;
    case 4:
        break;
    }

    if (req != NULL) {
        req->mParameter = i_reqType;
        req->mpNodeCrReqMthCls = i_nodeCtRqMtd;
        fpcNdRq_ToRequestQ(req);
    }

    return req;
}

/* 8003FB70-8003FBE8       .text fpcNdRq_ReChangeNode__FUisPv */
s32 fpcNdRq_ReChangeNode(uint i_requestID, s16 i_procName, void* i_data) {
    request_node_class* currentNode;
    node_create_request* found;
    currentNode = (request_node_class*)l_fpcNdRq_Queue.mpHead;
    while (currentNode != NULL) {
        found = currentNode->mNodeCrReq;
        if (found->mParameter == 2 && found->mRequestId == i_requestID) {
            if (found->mCreatingID == -2) {
                found->mProcName = i_procName;
                found->mpUserData = i_data;
                return 1;
            }
            return 0;
        }
        currentNode = (request_node_class*)NODE_GET_NEXT((&currentNode->base));
    }
    return 0;
}

/* 8003FBE8-8003FC08       .text fpcNdRq_ReRequest__FUisPv */
s32 fpcNdRq_ReRequest(uint i_requestID, s16 i_procName, void* i_data) {
    return fpcNdRq_ReChangeNode(i_requestID, i_procName, i_data);
}