--- /dev/null
+/**********************************************************************
+ * Copyright (c) 2003 IBM Corporation and others.
+ * All rights reserved. This program and the accompanying materials
+ * are made available under the terms of the Common Public License v1.0
+ * which accompanies this distribution, and is available at
+ * http://www.eclipse.org/legal/cpl-v10.html
+ *
+ * Contributors:
+ * IBM - Initial API and implementation
+ **********************************************************************/
+package net.sourceforge.phpdt.monitor.core.internal;
+
+import java.util.Date;
+import java.util.Properties;
+
+import net.sourceforge.phpdt.monitor.core.IProtocolAdapter;
+import net.sourceforge.phpdt.monitor.core.IRequest;
+/**
+ * A single TCP/IP request/response pair.
+ */
+public class Request implements IRequest {
+ protected Date date;
+ protected long responseTime = -1;
+ protected int localPort;
+ protected String remoteHost;
+ protected int remotePort;
+ protected byte[] request;
+ protected byte[] response;
+
+ protected String label;
+ protected IProtocolAdapter type;
+
+ protected Properties properties;
+
+ /**
+ * RequestResponse constructor comment.
+ */
+ public Request(IProtocolAdapter type, int localPort, String remoteHost, int remotePort) {
+ super();
+ this.type = type;
+ this.localPort = localPort;
+ this.remoteHost = remoteHost;
+ this.remotePort = remotePort;
+ date = new Date();
+ properties = new Properties();
+ MonitorManager.getInstance().addRequest(this);
+ }
+
+ public IProtocolAdapter getType() {
+ return type;
+ }
+
+ /**
+ * Add to the request.
+ *
+ * @param addRequest byte[]
+ */
+ public void addToRequest(byte[] addRequest) {
+ if (addRequest == null || addRequest.length == 0)
+ return;
+
+ if (request == null || request.length == 0) {
+ setRequest(addRequest);
+ return;
+ }
+
+ int size = request.length + addRequest.length;
+ byte[] b = new byte[size];
+ System.arraycopy(request, 0, b, 0, request.length);
+ System.arraycopy(addRequest, 0, b, request.length, addRequest.length);
+ request = b;
+ }
+
+ /**
+ * Add to the response.
+ *
+ * @param addResponse byte[]
+ */
+ public void addToResponse(byte[] addResponse) {
+ if (addResponse == null || addResponse.length == 0)
+ return;
+
+ if (response == null || response.length == 0) {
+ setResponse(addResponse);
+ return;
+ }
+
+ int size = response.length + addResponse.length;
+ byte[] b = new byte[size];
+ System.arraycopy(response, 0, b, 0, response.length);
+ System.arraycopy(addResponse, 0, b, response.length, addResponse.length);
+ response = b;
+ }
+
+ /**
+ * Return the date/time of this request.
+ *
+ * @return java.util.Date
+ */
+ public Date getDate() {
+ return date;
+ }
+
+ /**
+ * Returns the local port.
+ *
+ * @return int
+ */
+ public int getLocalPort() {
+ return localPort;
+ }
+
+ /**
+ * Returns the remote host.
+ *
+ * @return java.lang.String
+ */
+ public String getRemoteHost() {
+ return remoteHost;
+ }
+
+ /**
+ * Returns the remote port.
+ *
+ * @return int
+ */
+ public int getRemotePort() {
+ return remotePort;
+ }
+
+ /**
+ * Returns the request as a byte array.
+ *
+ * @return byte[]
+ */
+ public byte[] getRequest(byte type2) {
+ return request;
+ }
+
+ /**
+ * Returns the response as a byte array.
+ *
+ * @return byte[]
+ */
+ public byte[] getResponse(byte type2) {
+ return response;
+ }
+
+ /**
+ * Returns the response time in milliseconds.
+ *
+ * @return long
+ */
+ public long getResponseTime() {
+ return responseTime;
+ }
+
+ /**
+ * Returns the title, if one exists.
+ *
+ * @return java.lang.String
+ */
+ public String getLabel() {
+ if (label == null)
+ return getRemoteHost() + ":" + getRemotePort();
+ else
+ return label;
+ }
+
+ /**
+ * Set the request.
+ *
+ * @param request byte[]
+ */
+ protected void setRequest(byte[] request) {
+ if (request == null || request.length == 0)
+ return;
+
+ this.request = request;
+
+ MonitorManager.getInstance().requestChanged(this);
+ }
+
+ /**
+ * Set the response.
+ *
+ * @param response byte[]
+ */
+ protected void setResponse(byte[] response) {
+ if (response == null || response.length == 0)
+ return;
+
+ this.response = response;
+
+ responseTime = System.currentTimeMillis() - date.getTime();
+
+ MonitorManager.getInstance().requestChanged(this);
+ }
+
+ /**
+ * Sets the title.
+ *
+ * @param s java.lang.String
+ */
+ public void setLabel(String s) {
+ // property can only be set once
+ if (label != null)
+ return;
+
+ label = s;
+ MonitorManager.getInstance().requestChanged(this);
+ }
+
+ /**
+ *
+ */
+ public void addProperty(String key, Object value) {
+ try {
+ if (properties.containsKey(key))
+ properties.remove(key);
+ properties.put(key, value);
+ } catch (Exception e) {
+ Trace.trace(Trace.SEVERE, "Could not add property", e);
+ }
+ }
+
+ /**
+ *
+ */
+ public String getStringProperty(String key) {
+ try {
+ return (String) properties.get(key);
+ } catch (Exception e) {
+ return "";
+ }
+ }
+
+ /**
+ *
+ */
+ public Integer getIntegerProperty(String key) {
+ try {
+ return (Integer) properties.get(key);
+ } catch (Exception e) {
+ return null;
+ }
+ }
+
+ /**
+ *
+ */
+ public Object getObjectProperty(String key) {
+ try {
+ return properties.get(key);
+ } catch (Exception e) {
+ return null;
+ }
+ }
+
+ public void fireChangedEvent() {
+ MonitorManager.getInstance().requestChanged(this);
+ }
+}
\ No newline at end of file
git://git.phpeclipse.com / phpeclipse.git / blobdiff