diff options
Diffstat (limited to 'providers/bundles/org.eclipse.ecf.provider.filetransfer.httpclient4/src/org/eclipse/ecf/internal/provider/filetransfer/httpclient4/CloseMonitoringSocket.java')
| -rw-r--r-- | providers/bundles/org.eclipse.ecf.provider.filetransfer.httpclient4/src/org/eclipse/ecf/internal/provider/filetransfer/httpclient4/CloseMonitoringSocket.java | 136 |
1 files changed, 68 insertions, 68 deletions
diff --git a/providers/bundles/org.eclipse.ecf.provider.filetransfer.httpclient4/src/org/eclipse/ecf/internal/provider/filetransfer/httpclient4/CloseMonitoringSocket.java b/providers/bundles/org.eclipse.ecf.provider.filetransfer.httpclient4/src/org/eclipse/ecf/internal/provider/filetransfer/httpclient4/CloseMonitoringSocket.java index f455935b7..5b1454e06 100644 --- a/providers/bundles/org.eclipse.ecf.provider.filetransfer.httpclient4/src/org/eclipse/ecf/internal/provider/filetransfer/httpclient4/CloseMonitoringSocket.java +++ b/providers/bundles/org.eclipse.ecf.provider.filetransfer.httpclient4/src/org/eclipse/ecf/internal/provider/filetransfer/httpclient4/CloseMonitoringSocket.java @@ -1,69 +1,69 @@ -/*******************************************************************************
-* Copyright (c) 2009 IBM, and others.
-* All rights reserved. This program and the accompanying materials
-* are made available under the terms of the Eclipse Public License v1.0
-* which accompanies this distribution, and is available at
-* http://www.eclipse.org/legal/epl-v10.html
-*
-* Contributors:
-* Thomas Joiner - extracted implementation from the Socket factories
-******************************************************************************/
-
-package org.eclipse.ecf.internal.provider.filetransfer.httpclient4;
-
-import java.io.IOException;
-import java.net.Socket;
-import javax.net.ssl.SSLSocket;
-import org.eclipse.ecf.core.util.Trace;
-import org.eclipse.ecf.filetransfer.events.socket.ISocketEvent;
-import org.eclipse.ecf.filetransfer.events.socket.ISocketEventSource;
-import org.eclipse.ecf.filetransfer.events.socket.ISocketListener;
-import org.eclipse.ecf.provider.filetransfer.events.socket.AbstractSocketWrapper;
-import org.eclipse.ecf.provider.filetransfer.events.socket.SocketClosedEvent;
-
-class CloseMonitoringSocket extends AbstractSocketWrapper {
-
- private boolean closed = false;
- private final ISocketListener spyListener;
- private final ISocketEventSource source;
- private Socket wrappedSocket;
-
- public CloseMonitoringSocket(Socket toWrap, ISocketListener spyListener, ISocketEventSource source) {
- super(toWrap);
- this.spyListener = spyListener;
- this.source = source;
- }
-
- public synchronized void close() throws IOException {
- if (!closed) {
- closed = true;
-
- try {
- Trace.trace(Activator.PLUGIN_ID, "closing socket " + this.toString()); //$NON-NLS-1$
- super.close();
- } finally {
- fireEvent(new SocketClosedEvent(source, getSocket(), (wrappedSocket != null ? wrappedSocket : this)));
- }
- }
- }
-
- private void fireEvent(ISocketEvent event) {
- if (spyListener != null) {
- spyListener.handleSocketEvent(event);
- }
- event.getSource().fireEvent(event);
- }
-
- public boolean isSecure() {
- return getSocket() instanceof SSLSocket;
- }
-
- Socket getWrappedSocket() {
- return wrappedSocket;
- }
-
- void setWrappedSocket(Socket wrappedSocket) {
- this.wrappedSocket = wrappedSocket;
- }
-
+/******************************************************************************* +* Copyright (c) 2009 IBM, and others. +* All rights reserved. This program and the accompanying materials +* are made available under the terms of the Eclipse Public License v1.0 +* which accompanies this distribution, and is available at +* http://www.eclipse.org/legal/epl-v10.html +* +* Contributors: +* Thomas Joiner - extracted implementation from the Socket factories +******************************************************************************/ + +package org.eclipse.ecf.internal.provider.filetransfer.httpclient4; + +import java.io.IOException; +import java.net.Socket; +import javax.net.ssl.SSLSocket; +import org.eclipse.ecf.core.util.Trace; +import org.eclipse.ecf.filetransfer.events.socket.ISocketEvent; +import org.eclipse.ecf.filetransfer.events.socket.ISocketEventSource; +import org.eclipse.ecf.filetransfer.events.socket.ISocketListener; +import org.eclipse.ecf.provider.filetransfer.events.socket.AbstractSocketWrapper; +import org.eclipse.ecf.provider.filetransfer.events.socket.SocketClosedEvent; + +class CloseMonitoringSocket extends AbstractSocketWrapper { + + private boolean closed = false; + private final ISocketListener spyListener; + private final ISocketEventSource source; + private Socket wrappedSocket; + + public CloseMonitoringSocket(Socket toWrap, ISocketListener spyListener, ISocketEventSource source) { + super(toWrap); + this.spyListener = spyListener; + this.source = source; + } + + public synchronized void close() throws IOException { + if (!closed) { + closed = true; + + try { + Trace.trace(Activator.PLUGIN_ID, "closing socket " + this.toString()); //$NON-NLS-1$ + super.close(); + } finally { + fireEvent(new SocketClosedEvent(source, getSocket(), (wrappedSocket != null ? wrappedSocket : this))); + } + } + } + + private void fireEvent(ISocketEvent event) { + if (spyListener != null) { + spyListener.handleSocketEvent(event); + } + event.getSource().fireEvent(event); + } + + public boolean isSecure() { + return getSocket() instanceof SSLSocket; + } + + Socket getWrappedSocket() { + return wrappedSocket; + } + + void setWrappedSocket(Socket wrappedSocket) { + this.wrappedSocket = wrappedSocket; + } + }
\ No newline at end of file |