ProcessBuilderRemote.cs

Go to the documentation of this file.

// Copyright (c) 2014 Silicon Studio Corp. (http://siliconstudio.co.jp)
// This file is distributed under GPL v3. See LICENSE.md for details.
using System;
using System.Collections.Generic;
using System.ServiceModel;
using System.Threading.Tasks;

using SiliconStudio.Core.Diagnostics;
using SiliconStudio.Core.Serialization.Assets;
using SiliconStudio.Core.Storage;

namespace SiliconStudio.BuildEngine
{
    [ServiceBehavior(InstanceContextMode = InstanceContextMode.Single, UseSynchronizationContext = false)]
    public class ProcessBuilderRemote : IProcessBuilderRemote
    {
        private readonly LocalCommandContext commandContext;
        private readonly Command remoteCommand;
        private readonly BuildParameterCollection buildParameters;

        public CommandResultEntry Result { get; protected set; }

        public ProcessBuilderRemote(LocalCommandContext commandContext, Command remoteCommand, BuildParameterCollection buildParameters)
        {
            this.commandContext = commandContext;
            this.remoteCommand = remoteCommand;
            this.buildParameters = buildParameters;
        }

        public Command GetCommandToExecute()
        {
            return remoteCommand;
        }

        public BuildParameterCollection GetBuildParameters()
        {
            return buildParameters;
        }

        public void RegisterResult(CommandResultEntry commandResult)
        {
            Result = commandResult;
        }

        public void ForwardLog(SerializableLogMessage message)
        {
            commandContext.Logger.Log(new LogMessage(message.Module, message.Type, message.Text));
            if (message.ExceptionInfo != null)
                commandContext.Logger.Log(new LogMessage(message.Module, message.Type, message.ExceptionInfo.ToString()));
        }

        public async Task<ResultStatus> SpawnCommand(Command command)
        {
            Task<ResultStatus> task = commandContext.ScheduleAndExecuteCommand(command);
            commandContext.Step.AwaitSpawnedCommand(task);
            return await task;
        }

        public ObjectId ComputeInputHash(UrlType type, string filePath)
        {
            return commandContext.ComputeInputHash(type, filePath);
        }

        public Dictionary<ObjectUrl, ObjectId> GetOutputObjects()
        {
            var result = new Dictionary<ObjectUrl, ObjectId>();
            foreach (var outputObjects in commandContext.GetOutputObjectsGroups())
            {
                foreach (var outputObject in outputObjects)
                {
                    if (!result.ContainsKey(outputObject.Key))
                    {
                        result.Add(outputObject.Key, outputObject.Value.ObjectId);
                    }
                }
            }
            return result;
        }
    }
}