1:
2:
3:
4:
5:
6:
7:
8:
9:
10:
11:
12:
13:
14:
15:
16:
17:
18:
19:
20:
21:
22:
23:
24:
25:
26:
27:
28:
29:
30:
31:
32:
33:
34:
35:
36:
37:
38:
39:
40:
41:
42:
43:
44:
45:
46:
47:
48:
49:
50:
51:
52:
53:
54:
55:
56:
57:
58:
59:
60:
61:
62:
63:
64:
65:
66:
67:
68:
69:
70:
71:
72:
73:
74:
75:
76:
77:
78:
79:
80:
81:
82:
83:
84:
85:
86:
87:
88:
89:
90:
91:
92:
93:
94:
95:
96:
97:
98:
99:
100:
101:
102:
103:
104:
105:
106:
107:
108:
109:
110:
111:
112:
113:
114:
115:
116:
117:
118:
119:
120:
121:
122:
123:
124:
125:
126:
127:
128:
129:
130:
131:
132:
133:
134:
135:
136:
137:
138:
139:
140:
141:
142:
143:
144:
145:
146:
147:
148:
149:
150:
151:
152:
153:
154:
155:
156:
157:
158:
159:
160:
161:
162:
163:
164:
165:
166:
167:
168:
169:
170:
171:
172:
173:
174:
175:
176:
177:
178:
179:
180:
181:
182:
183:
184:
185:
186:
187:
188:
189:
190:
191:
192:
193:
194:
195:
196:
197:
198:
199:
200:
201:
202:
203:
204:
205:
206:
207:
208:
209:
210:
211:
212:
213:
214:
215:

procedure TForm1.bRunClick(Sender: TObject);
var
_ToolPath:    string;
_GamePath:    string;
step:         string;
i:            integer;
en:           string;

_mpi:         string;
_mpig:        string;
_mpiw:        string;
_mpis:        string;
_mpil:        string;
_mpilw:       string;
_mpin1:       string;
_mpils:       string;
_mpin2:       string;
_mpiport:     string;
begin
  // Command zusammenbauen


  //Nur wenn Games vorhanden
  if coGames.Items.Count >= 1 then
  begin

    //Erstmal speichern
      WriteCFG;

    // Engine wählen
    if rEngineEP1.Checked then
    begin
      _ToolPath := EP1_ToolPath;
    end;
    if rEngineEP2.Checked then
    begin
      _ToolPath := OB_ToolPath;
    end;

    // Ausgewähltes Game aus der Liste holen
    step  := GameList[coGames.ItemIndex];
    i     := Pos('#', step);
    Delete(step, 1, i);
    _GamePath := step;

    //Checkboxen interpretieren...
    if cMPISingle.Checked then
    begin
      _mpi    := '';
      _mpig   := '';
      _mpiw   := '';
      _mpis   := '';
      _mpil   := '';
      _mpilw  := '';
      _mpin1  := '';
      _mpils  := '';
      _mpin2  := '';
      _mpiport:= '';
    end
    else 
    begin

      _mpi := '-mpi ';

      if cMPIGraphics.Checked then
        _mpig := '-mpi_Graphics ' else _mpig := '';
      if cMPIWait.Checked then
        _mpiw := '-mpi_TimingWait ' else _mpiw := '';
      if cMPIStats.Checked then
        _mpis := '-mpi_ShowDistributeWorkStats ' else _mpis := '';
      if cLazyMaster.Checked then
        _mpil := '-mpi_NoMasterWorkerThreads ' else _mpil := '';
      if cMPIWorker.Checked then
      begin
        _mpilw :=    '-mpi_WorkerCount ';
        _mpin1 :=   fMaxWorkers.Text + ' ';
      end
      else
      begin
        _mpilw    := '';
        _mpin1  := '';
      end;
      if cSpeedLimit.Checked then
      begin
        _mpils :=    '-mpi_FileTransmitRate ';
        _mpin2 :=   fMaxSpeed.Text + ' ';
      end
      else
      begin
        _mpils    := '';
        _mpin2  := '';
      end;

      _mpiport:= '-mpi_Port ' + fMPIPort.Text;

    end;


    mCom.Clear;
    mLog.Lines.Add(TimeToStr(now) + ' : compiling started...');
    Cmd.CommandLine := _ToolPath + '\vbsp.exe -game "' + _GamePath + '" "' + fVMFPath.Text + '\' + liVMF.Items[liVMF.ItemIndex] + '"';
    Cmd.Execute;
    repeat
    Application.ProcessMessages;
    //Sleep(10);
    until Cmd.IsRunning=false;

    //Wenn MPI an, dann Workern sagen das es los geht.
    if NOT cMPISingle.Checked then
    begin
      //Welche Engine?
      if rEngineEP1.Checked then en := 'EP1';
      if rEngineEP2.Checked then en := 'EP2';

      i := 0;
      while i <> Server.Socket.ActiveConnections do
      begin
        Server.Socket.Connections[i].SendText('WORK#VIS#' + en +#13#10);
        Inc(i);
      end;
    end;



    Cmd.CommandLine := '"' + _ToolPath + '\vvis.exe" ' + _mpi + _mpig + _mpiw + _mpis + _mpil + _mpilw + _mpin1 + _mpils + _mpin2 + _mpiport + ' -game "' + _GamePath + '" "' + fVMFPath.Text + '\' + liVMF.Items[liVMF.ItemIndex] + '"';
    Cmd.Execute;
    repeat
    Application.ProcessMessages;
    //Sleep(10);
    until Cmd.IsRunning=false;

    //Wenn MPI an, dann Workern sagen das es los geht.
    if NOT cMPISingle.Checked then
    begin
      i := 0;
      while i <> Server.Socket.ActiveConnections do
      begin
        Server.Socket.Connections[i].SendText('WORK#RAD#' + en +#13#10);
        Inc(i);
      end;
    end;

    Cmd.CommandLine := '"' + _ToolPath + '\vrad.exe" ' + _mpi + _mpig + _mpiw + _mpis + _mpil + _mpilw + _mpin1 + _mpils + _mpin2 + _mpiport + ' -game "' + _GamePath + '" "' + fVMFPath.Text + '\' + liVMF.Items[liVMF.ItemIndex] + '"';
    Cmd.Execute;
    repeat
    Application.ProcessMessages;
    //Sleep(10);
    until Cmd.IsRunning=false;

  end;
end;

procedure TForm1.ServerClientRead(Sender: TObject; Socket: TCustomWinSocket);
var
rc:       string;
Liste:    TStringList;

o, i , j:        integer;
step:     string;
begin
  Liste := TStringList.Create;
  try
  rc := Socket.ReceiveText;

  // Ankommende Daten in Liste schreiben.
  Liste.Text := rc;


  //Befehle interpretieren und abarbeiten.

  o := Liste.Count;
  while o >= 1 do  // Wird solange gemacht wie noch Befehle in der
  begin            // Queue sind...
    // --- WORKER ADD ---
   i := Pos('ADDME#',Liste[0]);
    if i <> 0 then
    begin
      Inc(id);
      step := Liste[0];
      Delete(step, 1, 6);

      liWorkers.AddItem(step + 'Worker ID:' + IntToStr(id) , Socket);
      Socket.Sendtext('ADDED#' + #10);
    end;

   i := Pos('QUIT#',Liste[0]);
    if i <> 0 then
    begin
      step := Liste[0];
      i := 0;
      while i <> Server.Socket.ActiveConnections -1 do
      begin
        if Socket = Server.Socket.Connections[i] then
          j := i;
        
        Inc(i);
      end;

      liWorkers.Items.Delete(j);
      Socket.Close;



    end;

      Liste.Delete(0);
      Dec(o);
  end;



  finally
    Liste.Free;
  end;
end;