-
Notifications
You must be signed in to change notification settings - Fork 0
Expand file tree
/
Copy pathTOCCommand.java
More file actions
204 lines (187 loc) · 5.46 KB
/
TOCCommand.java
File metadata and controls
204 lines (187 loc) · 5.46 KB
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
/*
Copyright 2006, Astrophysics Research Institute, Liverpool John Moores University.
This file is part of org.estar.toop.
org.estar.toop is free software; you can redistribute it and/or modify
it under the terms of the GNU General Public License as published by
the Free Software Foundation; either version 2 of the License, or
(at your option) any later version.
org.estar.toop is distributed in the hope that it will be useful,
but WITHOUT ANY WARRANTY; without even the implied warranty of
MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
GNU General Public License for more details.
You should have received a copy of the GNU General Public License
along with org.estar.toop; if not, write to the Free Software
Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA
*/
// TOCCommand.java
// $Header: /space/home/eng/cjm/cvs/org_estar_toop/TOCCommand.java,v 1.2 2007-01-30 18:35:31 cjm Exp $
package org.estar.toop;
import java.io.*;
import java.util.*;
import ngat.util.*;
import ngat.util.logging.*;
/**
* TOCCommand, generic command implementation.
* @author Steve Fraser, Chris Mottram
* @version $Revision$
*/
class TOCCommand implements Logging, Runnable
{
/**
* Revision control system version id.
*/
public final static String RCSID = "$Id$";
/**
* Classname for logging.
*/
public static final String CLASS = "TOCCommand";
/**
* Class logger.
*/
protected Logger logger = null;
/**
* Instance of the client. Used to send the command to the RCS TOCA.
*/
protected TOCAClient tocaClient = null;
/**
* Instance of the TOC session data.
*/
protected TOCSessionData sessionData = null;
/**
* The command string to send to the RCS TOCA using the TOCClient.
*/
protected String commandString = null;
/**
* An error string generated if something went wrong.
*/
protected String errorString = null;
/**
* Boolean set to whether the command was completed successfully or not.
*/
protected boolean successful = false;
/**
* The logger instance is created. The tocaClient instance is initialised.
* @see #tocaClient
* @see #logger
*/
public TOCCommand()
{
super();
tocaClient = new TOCAClient();
logger = LogManager.getLogger(this);
}
/**
* Set the session data.
* @param data The data.
* @see #sessionData
*/
public void setSessionData(TOCSessionData data)
{
sessionData = data;
}
/**
* Run method. Configures the instance of tocaClient using sessionData.
* Runs the client to communicate with the RCS TOCA and get the results.
* @see #tocaClient
*/
public void run()
{
String host = null;
int port;
logger.log(INFO, 1, CLASS, RCSID,"run","TOCCommand : Started.");
try
{
port = sessionData.getTOCSPort();
}
catch(Exception e)
{
successful = false;
errorString = new String(this.getClass().getName()+":run:Getting TOCS port failed:"+e);
logger.log(INFO, 1, CLASS, RCSID,"run",errorString);
logger.dumpStack(1,e);
return;
}
tocaClient.setCommand(commandString);
tocaClient.setHost(sessionData.getTOCSHost());
tocaClient.setPort(port);
logger.log(INFO, 1, CLASS, RCSID,"run","TOCCommand : Calling ("+sessionData.getTOCSHost()+","+port+
") with command "+commandString+".");
tocaClient.run();
successful = (tocaClient.isError() == false);
if(tocaClient.isError())
{
errorString = tocaClient.getErrorCode()+":"+tocaClient.getErrorMessage();
}
}
/**
* Get the reply error string generated by this command.
* @return The reply string.
* @see #tocaClient
*/
public String getReplyString()
{
return tocaClient.getReply();
}
/**
* Returns the reply string value for the specified reply keyword,
* if it exists in the list of reply keyword values.
* @param keyword The keyword.
* @return The reply keyword's string value. If the keyword does not exist, null is returned.
* @see #tocaClient
* @see TOCAClient#getReplyValue
*/
public String getReplyValue(String keyword)
{
return tocaClient.getReplyValue(keyword);
}
/**
* Returns the reply int value for the specified reply keyword,
* if it exists in the list of reply keyword values.
* @param keyword The keyword.
* @return The reply keyword's int value.
* @exception NGATPropertyException Thrown if the value is not a valid integer.
* @see #tocaClient
* @see TOCAClient#getReplyValueInt
*/
public int getReplyValueInt(String keyword) throws NGATPropertyException
{
return tocaClient.getReplyValueInt(keyword);
}
/**
* Returns the reply double value for the specified reply keyword,
* if it exists in the list of reply keyword values.
* @param keyword The keyword.
* @return The reply keyword's double value.
* @exception NGATPropertyException Thrown if the value is not a valid double.
* @see #tocaClient
* @see TOCAClient#getReplyValueDouble
*/
public double getReplyValueDouble(String keyword) throws NGATPropertyException
{
return tocaClient.getReplyValueDouble(keyword);
}
/**
* Get any error string generated by this command.
* @return The error string.
* @see #errorString
*/
public String getErrorString()
{
return errorString;
}
/**
* Get whether the command was completed successfully or not.
* @return A boolean, true if the command was completed successfully, flase if not.
* @see #successful
*/
public boolean getSuccessful()
{
return successful;
}
}
/*
** $Log: not supported by cvs2svn $
** Revision 1.1 2005/06/06 14:44:55 cjm
** Initial revision
**
*/