Класс ActionManagerServer

Граф наследования:ActionManagerServer:

Защищенные члены
void	ActionManagerServer (PlayerBase player)
override void	OnJumpStart ()
override bool	OnInputUserDataProcess (int userDataType, ParamsReadContext ctx)
override void	StartDeliveredAction ()
override void	OnActionEnd ()
override void	Update (int pCurrentCommandID)
override void	Interrupt ()
override ActionReciveData	GetReciveData ()

Защищенные данные
ActionBase	m_PendingAction
ref ActionReciveData	m_PendingActionReciveData

Подробное описание

Конструктор(ы)

ActionManagerServer()

void ActionManagerServer ( PlayerBase player )

inlineprotected

    {
        m_PendingAction             = null;
        m_PendingActionReciveData   = null;
    }

Перекрестные ссылки m_PendingAction и m_PendingActionReciveData.

Методы

GetReciveData()

override ActionReciveData GetReciveData ( )

inlineprotected

    {
        return m_PendingActionReciveData;
    }

Перекрестные ссылки m_PendingActionReciveData.

Interrupt()

override void Interrupt ( )

inlineprotected

    {
        super.Interrupt();
        
        if (m_CurrentActionData)
            DayZPlayerSyncJunctures.SendActionInterrupt(m_Player);
    }

Перекрестные ссылки m_CurrentActionData, m_Player и DayZPlayerSyncJunctures::SendActionInterrupt().

Используется в OnInputUserDataProcess(), StartDeliveredAction() и Update().

OnActionEnd()

override void OnActionEnd ( )

inlineprotected

    {
        //Debug.Log("Action ended - hard, STS = " + m_Player.GetSimulationTimeStamp());
        if (m_CurrentActionData)
        {
            m_CurrentActionData.m_Action.ClearActionJuncture(m_CurrentActionData);
 
            super.OnActionEnd();
        }
    }

Перекрестные ссылки m_CurrentActionData.

Используется в OnJumpStart() и Update().

OnInputUserDataProcess()

override bool OnInputUserDataProcess ( int userDataType, ParamsReadContext ctx )

inlineprotected

    {       
        switch (userDataType)
        {
            case INPUT_UDT_STANDARD_ACTION_START:
            {
                bool success = true;
                
                int actionID = 0;
                if (!ctx.Read(actionID))
                    return false;
                
                ActionBase recvAction = GetAction(actionID);
                if (!recvAction)
                    return false;
                
                if (!recvAction.ReadFromContext(ctx, m_PendingActionReciveData))
                    success = false;
                
                m_PendingAction = recvAction;
                    
                if (recvAction.UseAcknowledgment())
                {
                    int ackID;
                    if (!ctx.Read(ackID))
                        success = false;
                        
                    m_PendingActionAcknowledgmentID = ackID;
                }
                    
                break;
 
            }
 
            case INPUT_UDT_STANDARD_ACTION_END_REQUEST:
            {
                //Debug.Log("Action want end request, STS = " + m_Player.GetSimulationTimeStamp());
                int commandID = -10;
                ctx.Read(commandID);
                
                if (commandID == DayZPlayerConstants.CMD_ACTIONINT_INTERRUPT)
                {
                    //Print("INPUT_UDT_STANDARD_ACTION_END_REQUEST | CMD_ACTIONINT_INTERRUPT");
                    Interrupt();
                }
                else
                {
                    //Print("INPUT_UDT_STANDARD_ACTION_END_REQUEST | m_ActionWantEndRequest");
                    m_ActionWantEndRequest = true;
                }
            }
            
            case INPUT_UDT_STANDARD_ACTION_INPUT_END:
            {
                //Debug.Log("Action input ended, STS = " + m_Player.GetSimulationTimeStamp());
                m_ActionInputWantEnd = true;
            }
            default:
                return false;
        }
        
        if (!success)
        {
            //Debug.Log("[AM] OnInputUserDataProcess INPUT_UDT_STANDARD_ACTION_START Error");
            if (recvAction.UseAcknowledgment())
            {
                DayZPlayerSyncJunctures.SendActionAcknowledgment(m_Player, m_PendingActionAcknowledgmentID, false);
            }
            else
            {
                Interrupt();
            }
 
            return false;
        }
        return true;
        
    }

Перекрестные ссылки GetAction(), INPUT_UDT_STANDARD_ACTION_END_REQUEST, INPUT_UDT_STANDARD_ACTION_INPUT_END, INPUT_UDT_STANDARD_ACTION_START, Interrupt(), m_ActionInputWantEnd, m_ActionWantEndRequest, m_PendingAction, m_PendingActionAcknowledgmentID, m_PendingActionReciveData, m_Player и DayZPlayerSyncJunctures::SendActionAcknowledgment().

OnJumpStart()

override void OnJumpStart ( )

inlineprotected

    {
        if (m_CurrentActionData)
        {
            if (m_CurrentActionData.m_State == UA_AM_PENDING || m_CurrentActionData.m_State == UA_AM_REJECTED || m_CurrentActionData.m_State == UA_AM_ACCEPTED)
            {
                OnActionEnd();
                m_PendingActionAcknowledgmentID = -1;
            }
            else
            {
                m_CurrentActionData.m_Action.Interrupt(m_CurrentActionData);
            }
        }
    }

Перекрестные ссылки m_CurrentActionData, m_PendingActionAcknowledgmentID, OnActionEnd(), UA_AM_ACCEPTED, UA_AM_PENDING и UA_AM_REJECTED.

StartDeliveredAction()

override void StartDeliveredAction ( )

inlineprotected

error - expected action data

    {
        if (!m_CurrentActionData)
        {
            return;
        }
        
        m_Interrupted           = false;
 
        bool accepted           = false;        
        ActionBase pickedAction = m_CurrentActionData.m_Action;
        ActionTarget target     = m_CurrentActionData.m_Target;
        ItemBase item           = m_CurrentActionData.m_MainItem;
 
        if (LogManager.IsActionLogEnable())
        {
            if (target)
            {
                Debug.ActionLog("Item = " + item + ", " + target.DumpToString(), pickedAction.ToString() , "n/a", "DeliveredAction", m_Player.ToString());
            }
            else
            {
                Debug.ActionLog("Item = " + item + ", NULL", pickedAction.ToString() , "n/a", "DeliveredAction", m_Player.ToString());
            }
        }
 
        if (!m_Player.GetCommandModifier_Action() && !m_Player.GetCommand_Action() && !m_Player.IsSprinting() && pickedAction && pickedAction.Can(m_Player,target,item)) 
        {
            if (pickedAction.AddActionJuncture(m_CurrentActionData))
                accepted = true;
        }
        
        if (accepted)
        {
            if (LogManager.IsActionLogEnable())
            {
                Debug.ActionLog("Action accepted", pickedAction.ToString() , "n/a", "CheckDeliveredAction", m_Player.ToString() );
            }
            //Debug.Log("[AM] Action acccepted");
            if (pickedAction.UseAcknowledgment())
            {
                //Unlock target
                m_CurrentActionData.m_State = UA_AM_PENDING;
                DayZPlayerSyncJunctures.SendActionAcknowledgment(m_Player, m_PendingActionAcknowledgmentID, true);
            }
            else
            {
                m_CurrentActionData.m_State = UA_AM_ACCEPTED;
            }
        }
        else
        {
            if (LogManager.IsActionLogEnable())
            {
                Debug.ActionLog("Action rejected", pickedAction.ToString() , "n/a", "CheckDeliveredAction", m_Player.ToString() );
            }
 
            if (pickedAction.UseAcknowledgment())
            {
                DayZPlayerSyncJunctures.SendActionAcknowledgment(m_Player, m_PendingActionAcknowledgmentID, false);
            }
            else
            {
                Interrupt();
            }
        }
    }

Перекрестные ссылки Debug::ActionLog(), Interrupt(), LogManager::IsActionLogEnable(), m_CurrentActionData, m_Interrupted, m_PendingActionAcknowledgmentID, m_Player, DayZPlayerSyncJunctures::SendActionAcknowledgment(), UA_AM_ACCEPTED и UA_AM_PENDING.

Используется в Update().

Update()

override void Update ( int pCurrentCommandID )

inlineprotected

    {
        super.Update(pCurrentCommandID);
        int currentCommandID = m_Player.GetCurrentCommandID();
        
        //Debug.Log("m_ActionWantEnd " + m_ActionInputWantEnd);
        
        if (m_PendingAction)
        {
            if (m_CurrentActionData)
            {
                DayZPlayerSyncJunctures.SendActionAcknowledgment(m_Player, m_PendingActionAcknowledgmentID, false);
            }
            else
            {
                m_ActionWantEndRequest  = false;
                m_ActionInputWantEnd    = false;
                
                bool success            = true;
                ActionTarget target     = new ActionTarget(null, null, -1, vector.Zero, 0); 
                    
                if ( LogManager.IsActionLogEnable() )
                {   
                    Debug.ActionLog("n/a", m_PendingAction.ToString() , "n/a", "HandlePendingAction", m_Player.ToString() );
                }
 
                if (!m_PendingAction.SetupAction(m_Player,target,m_Player.GetItemInHands(),m_CurrentActionData))
                {
                    success = false;
                }
                //Debug.Log("[AM] Action data synced (" + m_Player + ") success: " + success);
            
                if (success)
                {
                    StartDeliveredAction();
                }
                else
                {
                    if (m_PendingAction.UseAcknowledgment())
                    {
                        DayZPlayerSyncJunctures.SendActionAcknowledgment(m_Player, m_PendingActionAcknowledgmentID, false);
                    }
                    else
                    {
                        Interrupt();
                    }
                }
            }
 
            m_PendingAction             = null;
            m_PendingActionReciveData   = null;
        }
    
        if (m_CurrentActionData)
        {           
            if (m_CurrentActionData.m_State != UA_AM_PENDING && m_CurrentActionData.m_State != UA_AM_REJECTED && m_CurrentActionData.m_State != UA_AM_ACCEPTED)
            {
                m_CurrentActionData.m_Action.OnUpdateServer(m_CurrentActionData);
            }
            
            //Debug.Log("m_CurrentActionData.m_State: " + m_CurrentActionData.m_State +" m_ActionWantEnd: " + m_ActionWantEndRequest );
            switch (m_CurrentActionData.m_State)
            {
                case UA_AM_PENDING:
                    break;
            
                case UA_AM_ACCEPTED:
                    // check currentCommandID before start or reject 
                
                    int condition_mask = ActionBase.ComputeConditionMask(m_Player, m_CurrentActionData.m_Target, m_CurrentActionData.m_MainItem);
                    bool canActionPerform = ((condition_mask & m_CurrentActionData.m_Action.m_ConditionMask) == condition_mask);
                    if (canActionPerform && ActionPossibilityCheck(currentCommandID))
                    {
                        m_CurrentActionData.m_State = UA_START;
                        m_CurrentActionData.m_Action.Start(m_CurrentActionData);
                    
                        if (m_CurrentActionData.m_Action && m_CurrentActionData.m_Action.IsInstant())
                            OnActionEnd();
                    }
                    else
                    {
                        Interrupt();
                    }
                    m_PendingActionAcknowledgmentID = -1;
                    break;
                
                case UA_AM_REJECTED:
                    OnActionEnd();
                    m_PendingActionAcknowledgmentID = -1;
                    break;
            
                default:
                    if (m_ActionInputWantEnd)
                    {
                        m_ActionInputWantEnd = false;
                        m_CurrentActionData.m_Action.EndInput(m_CurrentActionData);
                    }
                
                    if (m_ActionWantEndRequest)
                    {
                        m_ActionWantEndRequest = false;
                        m_CurrentActionData.m_Action.EndRequest(m_CurrentActionData);
                    }
                    break;
            }
        }
    }

Перекрестные ссылки Debug::ActionLog(), ActionPossibilityCheck(), ActionTarget, ActionBase::ComputeConditionMask(), Interrupt(), LogManager::IsActionLogEnable(), m_ActionInputWantEnd, m_ActionWantEndRequest, m_CurrentActionData, m_PendingAction, m_PendingActionAcknowledgmentID, m_PendingActionReciveData, m_Player, OnActionEnd(), DayZPlayerSyncJunctures::SendActionAcknowledgment(), ActionBase::SetupAction(), StartDeliveredAction(), UA_AM_ACCEPTED, UA_AM_PENDING, UA_AM_REJECTED, UA_START, ActionBase::UseAcknowledgment() и vector::Zero.

Поля

m_PendingAction

ActionBase m_PendingAction

protected

Используется в ActionManagerServer(), OnInputUserDataProcess() и Update().

m_PendingActionReciveData

ref ActionReciveData m_PendingActionReciveData

protected

Используется в ActionManagerServer(), GetReciveData(), OnInputUserDataProcess() и Update().

---

Объявления и описания членов класса находятся в файле:

• D:/Ishodniki/scripts/4_World/Classes/UserActionsComponent/ActionManagerServer.c