01: package org.testng.remote;
02:
03: import java.io.IOException;
04:
05: import org.testng.SuiteRunner;
06: import org.testng.internal.Utils;
07: import org.testng.internal.remote.SlavePool;
08: import org.testng.remote.adapter.RemoteResultListener;
09: import org.testng.xml.XmlSuite;
10:
11: public class RemoteWorker {
12: protected RemoteResultListener m_listener;
13: private SlavePool m_slavePool;
14:
15: public RemoteWorker(RemoteResultListener listener,
16: SlavePool slavePool) {
17: m_listener = listener;
18: m_slavePool = slavePool;
19: }
20:
21: protected SlavePool getSlavePool() {
22: return m_slavePool;
23: }
24:
25: protected SuiteRunner sendSuite(ConnectionInfo ci, XmlSuite suite)
26: throws IOException, ClassNotFoundException {
27: log("Sending "
28: + suite.getName()
29: + " to "
30: + ci.getSocket().getInetAddress()
31: .getCanonicalHostName() + ":"
32: + ci.getSocket().getRemoteSocketAddress());
33: ci.getOos().writeObject(suite);
34: ci.getOos().flush();
35: SuiteRunner result = (SuiteRunner) ci.getOis().readObject();
36: log("Received results for " + result.getName());
37: return result;
38: }
39:
40: private void log(String string) {
41: Utils.log("", 2, string);
42: }
43:
44: }
|