/branches/MULTITHREADING_DEVELOPMENT/libraries/libRemoteServices/src/org/gvsig/remoteClient/taskplanning/retrieving/URLRequest.java - Diff - Application: gvSIG desktop - gvSIG

Revision 5269 branches/MULTITHREADING_DEVELOPMENT/libraries/libRemoteServices/src/org/gvsig/remoteClient/taskplanning/retrieving/URLRequest.java

     	private String file;
     	private String fileName;
     	private boolean locked;
     	private int status;
     	private Vector listeners = new Vector();
     	private RetrieveEvent event = new RetrieveEvent();
     	private URLRetrieveTask worker;
-...
     		u += (file.charAt(0) == '/') ? file : "/"+file;
     		return new URL(u);
+    	}
     	/**
     	 * @return Returns the fileName.
     	 */
     	public String getFileName() {
     		return fileName;
+    	}
     	/**
     	 * @param fileName The fileName to set.
     	 */
     	public void setFileName(String fileName) {
     		this.fileName = fileName;
+    	}
     	/**
     	 * @return Returns the host.
     	 */
     	public String getHost() {
     		return host;
+    	}
     	/**
     	 * @param host The host to set.
     	 */
     	public void setHost(String host) {
     		this.host = host;
+    	}
     	/**
     	 * @return Returns the file.
     	 */
     	public String getFile() {
     		return file;
+    	}
     	/**
     	 * @param page The file to set.
     	 */
     	public void setFile(String page) {
     		this.file = page;
+    	}
     	/**
     	 * @return Returns the protocol.
     	 */
     	public String getProtocol() {
     		return protocol;
+    	}
     	/**
     	 * @param protocol The protocol to set.
     	 */
     	public void setProtocol(String protocol) {
     		this.protocol = protocol;
+    	}
     	/**
     	 * @return Returns the requestType.
     	 */
     	public int getRequestType() {
     		return requestType;
+    	}
     	/**
     	 * @param requestType The requestType to set.
     	 */
     	public void setRequestType(int requestType) {
     		this.requestType = requestType;
+    	}
     	/**
     	 * @return Returns the port.
     	 */
     	public int getPort() {
     		return port;
+    	}
     	/**
     	 * @param port The port to set.
     	 */
-...
     		this.port = port;
+    	}
     	protected void lock() {
     		locked = true;
+    	}
     	protected void unlock() {
     		locked = false;
+    	}
     	protected synchronized void setStatus(int status) {
     		event.setType(status);
     		fireEvent();
+    	}
     	protected synchronized int getStatus() {
     		return event.getType();
+    	}
     	public void addRetrieveListener(RetrieveListener l) {
     		if (l!=null)
     			listeners.add(l);
+    	}
     	public void removeRetrieveListener(RetrieveListener l) {
     		listeners.remove(l);
     		if (listeners.size()==0) {
     			// If no body listens at, then no body cares about the result;
     			// cancel the job
     			worker.cancel();
     			worker = null;
+    		}
+    	}
     	private void fireEvent() {
     		while (locked) { /* wait*/System.out.println("I'm locked"); }
     		Iterator it = listeners.iterator();
     		while (it.hasNext()) {
     			RetrieveListener listener = (RetrieveListener) it.next();
     			listener.transferEventReceived(event);
+    		}
+    	}
     	protected void setWorker(URLRetrieveTask worker) {
     		this.worker = worker;
+    	}
     	public int hashCode() {
     		if (hashCode == 0) {
     			int result = 17;
-...
     		if (this.requestType != other.requestType) return false;
     		return true;
+    	}
     	protected void lock() {
     		locked = true;
+    	}
     	protected void unlock() {
     		locked = false;
+    	}
     	protected synchronized void setStatus(int status) {
     		event.setType(status);
     		fireEvent();
+    	}
     	protected synchronized int getStatus() {
     		return event.getType();
+    	}
     	public void addRetrieveListener(RetrieveListener l) {
     		if (l!=null)
     			listeners.add(l);
+    	}
     	public void removeRetrieveListener(RetrieveListener l) {
     		listeners.remove(l);
     		if (listeners.size()==0)
     			// If no body listens then no body cares about the result;
     			// cancel the job
     			worker.cancel();
+    	}
     	private void fireEvent() {
     		while (locked) { /* wait*/System.out.println("I'm locked"); }
     		Iterator it = listeners.iterator();
     		while (it.hasNext()) {
     			RetrieveListener listener = (RetrieveListener) it.next();
     			listener.transferEventReceived(event);
+    		}
+    	}
     	protected void setWorker(URLRetrieveTask worker) {
     		this.worker = worker;
+    	}
+     }
+    }

Also available in: Unified diff