Free cookie consent management tool by TermsFeed Policy Generator

source: trunk/sources/HeuristicLab.CEDMA.Server/ServerForm.cs @ 442

Last change on this file since 442 was 398, checked in by gkronber, 16 years ago

removed the distinction between controller agents and normal agents. Also removed the AgentScheduler because it is not needed anymore. (ticket #204)

File size: 3.8 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.ComponentModel;
25using System.Data;
26using System.Drawing;
27using System.Linq;
28using System.Text;
29using System.Windows.Forms;
30using System.ServiceModel;
31using System.ServiceModel.Description;
32using HeuristicLab.PluginInfrastructure;
33using System.Net;
34using HeuristicLab.CEDMA.DB;
35using HeuristicLab.CEDMA.DB.Interfaces;
36using System.Data.Common;
37using System.Threading;
38using HeuristicLab.Grid;
39
40namespace HeuristicLab.CEDMA.Server {
41  public partial class ServerForm : Form {
42    private ServiceHost host;
43    private Database database;
44    private static readonly string dbFile = AppDomain.CurrentDomain.BaseDirectory + "/test.db3";
45    private static readonly string connectionString = "Data Source=\""+dbFile+"\";Pooling=False";
46    public ServerForm() {
47      InitializeComponent();
48      // windows XP returns the external ip on index 0 while windows vista returns the external ip on index 2
49      if (System.Environment.OSVersion.Version.Major >= 6) {
50        addressTextBox.Text = "net.tcp://" + Dns.GetHostAddresses(Dns.GetHostName())[2] + ":8002/CEDMA/World";
51      } else {
52        addressTextBox.Text = "net.tcp://" + Dns.GetHostAddresses(Dns.GetHostName())[0] + ":8002/CEDMA/World";
53      }
54    }
55
56    private void InitRunScheduler() {
57      JobManager jobManager = new JobManager(gridAddress.Text);
58      jobManager.Reset();
59      RunScheduler scheduler = new RunScheduler(database, jobManager, addressTextBox.Text);
60      Thread runSchedulerThread = new Thread(scheduler.Run);
61      runSchedulerThread.Start();
62    }
63
64    private void InitDatabase() {
65      DbProviderFactory fact;
66      fact = DbProviderFactories.GetFactory("System.Data.SQLite");
67      if(!System.IO.File.Exists(dbFile)) {
68        database = new Database(connectionString);
69        database.CreateNew();
70      } else {
71        database = new Database(connectionString);
72      }
73    }
74
75    private void Start() {
76      InitDatabase();
77      InitRunScheduler();
78
79      host = new ServiceHost(database, new Uri(addressTextBox.Text));
80      ServiceThrottlingBehavior throttlingBehavior = new ServiceThrottlingBehavior();
81      throttlingBehavior.MaxConcurrentSessions = 20;
82      host.Description.Behaviors.Add(throttlingBehavior);
83      try {
84        NetTcpBinding binding = new NetTcpBinding();
85        binding.MaxReceivedMessageSize = 10000000; // 10Mbytes
86        binding.ReaderQuotas.MaxStringContentLength = 10000000; // also 10M chars
87        binding.ReaderQuotas.MaxArrayLength = 10000000; // also 10M elements;
88        binding.Security.Mode = SecurityMode.None;
89
90        host.AddServiceEndpoint(typeof(IDatabase), binding, addressTextBox.Text);
91        host.Open();
92      } catch (CommunicationException ex) {
93        MessageBox.Show("An exception occurred: " + ex.Message);
94        host.Abort();
95      }
96    }
97
98    private void startButton_Click(object sender, EventArgs e) {
99      Start();
100      startButton.Enabled = false;
101    }
102  }
103}
Note: See TracBrowser for help on using the repository browser.