Free cookie consent management tool by TermsFeed Policy Generator

source: branches/3.1/sources/HeuristicLab.CEDMA.Operators/SplitScopeToItemsResultWriter.cs @ 15160

Last change on this file since 15160 was 538, checked in by gkronber, 16 years ago

added operators to help with the transformation form the result-tree to the item/statement-graph. ticket #261 (Items are stored multiple times in the result entries in the CEDMA DB)

File size: 3.9 KB
Line 
1#region License Information
2/* HeuristicLab
3 * Copyright (C) 2002-2008 Heuristic and Evolutionary Algorithms Laboratory (HEAL)
4 *
5 * This file is part of HeuristicLab.
6 *
7 * HeuristicLab is free software: you can redistribute it and/or modify
8 * it under the terms of the GNU General Public License as published by
9 * the Free Software Foundation, either version 3 of the License, or
10 * (at your option) any later version.
11 *
12 * HeuristicLab is distributed in the hope that it will be useful,
13 * but WITHOUT ANY WARRANTY; without even the implied warranty of
14 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
15 * GNU General Public License for more details.
16 *
17 * You should have received a copy of the GNU General Public License
18 * along with HeuristicLab. If not, see <http://www.gnu.org/licenses/>.
19 */
20#endregion
21
22using System;
23using System.Collections.Generic;
24using System.Text;
25using HeuristicLab.Core;
26using HeuristicLab.Data;
27using System.Threading;
28using HeuristicLab.CEDMA.DB.Interfaces;
29using System.ServiceModel;
30
31namespace HeuristicLab.CEDMA.Operators {
32  public class SplitScopeToItemsResultWriter : OperatorBase {
33    public override string Description {
34      get { return "TASK."; }
35    }
36
37    public SplitScopeToItemsResultWriter()
38      : base() {
39      AddVariableInfo(new VariableInfo("AgentId", "Id of the agent whose results should be transformed.", typeof(IntData), VariableKind.In));
40      AddVariableInfo(new VariableInfo("CedmaServerUri", "Uri of the CEDMA server", typeof(StringData), VariableKind.In));
41    }
42
43    public override IOperation Apply(IScope scope) {
44      string serverUrl = GetVariableValue<StringData>("CedmaServerUri", scope, true).Data;
45      long agentId = GetVariableValue<IntData>("AgentId", scope, true).Data;
46
47      NetTcpBinding binding = new NetTcpBinding();
48      binding.MaxReceivedMessageSize = 10000000; // 10Mbytes
49      binding.ReaderQuotas.MaxStringContentLength = 10000000; // also 10M chars
50      binding.ReaderQuotas.MaxArrayLength = 10000000; // also 10M elements;
51      binding.Security.Mode = SecurityMode.None;
52      using(ChannelFactory<IDatabase> factory = new ChannelFactory<IDatabase>(binding)) {
53        IDatabase database = factory.CreateChannel(new EndpointAddress(serverUrl));
54        TransformResults(database, agentId);
55      }
56      return null;
57    }
58
59    private void TransformResults(IDatabase database, long agentId) {
60      TransformResults(database, database.GetResults(agentId));
61      foreach(AgentEntry subAgent in database.GetSubAgents(agentId)) {
62        TransformResults(database, subAgent.Id);
63      }
64    }
65
66    private void TransformResults(IDatabase database, ICollection<ResultEntry> results) {
67      foreach(ResultEntry entry in results) {
68        byte[] rawData = database.GetResultRawData(entry.Id);
69        object resultItem = PersistenceManager.RestoreFromGZip(rawData);
70        if(resultItem is IScope) {
71          IScope resultScope = resultItem as IScope;
72          IVariable funTreeVariable = resultScope.GetVariable("FunctionTree");
73          if(funTreeVariable != null) {
74            long newResultId = 0;
75            if(entry.AgentId.HasValue) {
76              newResultId = database.InsertResult(entry.AgentId.Value, funTreeVariable.Name, resultScope.Name, PersistenceManager.SaveToGZip(funTreeVariable.Value));
77            } else if(entry.ParentResultId.HasValue) {
78              newResultId = database.InsertSubResult(entry.ParentResultId.Value, funTreeVariable.Name, resultScope.Name, PersistenceManager.SaveToGZip(funTreeVariable.Value));
79            }
80            foreach(IVariable var in resultScope.Variables) {
81              if(var != funTreeVariable) {
82                database.InsertSubResult(newResultId, var.Name, "", PersistenceManager.SaveToGZip(var.Value));
83              }
84            }
85          }
86        }
87        TransformResults(database, database.GetSubResults(entry.Id));
88      }
89    }
90  }
91}
Note: See TracBrowser for help on using the repository browser.