X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?a=blobdiff_plain;f=protocol_plugins.packetcable%2Fsrc%2Fmain%2Fjava%2Forg%2Fpcmm%2Frcd%2Fimpl%2FAbstractPCMMClient.java;fp=protocol_plugins.packetcable%2Fsrc%2Fmain%2Fjava%2Forg%2Fpcmm%2Frcd%2Fimpl%2FAbstractPCMMClient.java;h=0000000000000000000000000000000000000000;hb=3df63629a50c16333ae1465fa01bf5465bef885b;hp=6a29743c823b9c92ee08649c46e3701473067389;hpb=a06a930e945e767e04f20486711a666d86d85e4c;p=packetcable.git

diff --git a/protocol_plugins.packetcable/src/main/java/org/pcmm/rcd/impl/AbstractPCMMClient.java b/protocol_plugins.packetcable/src/main/java/org/pcmm/rcd/impl/AbstractPCMMClient.java
deleted file mode 100644
index 6a29743..0000000
--- a/protocol_plugins.packetcable/src/main/java/org/pcmm/rcd/impl/AbstractPCMMClient.java
+++ /dev/null
@@ -1,176 +0,0 @@
-/**
- @header@
- */
-package org.pcmm.rcd.impl;
-
-import java.io.IOException;
-import java.net.InetAddress;
-import java.net.Socket;
-import java.net.UnknownHostException;
-
-import org.pcmm.nio.PCMMChannel;
-// import org.junit.Assert;
-import org.pcmm.objects.MMVersionInfo;
-import org.pcmm.rcd.IPCMMClient;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-import org.umu.cops.stack.COPSMsg;
-
-/**
- * 
- * default implementation for {@link IPCMMClient}
- * 
- * 
- */
-public class AbstractPCMMClient implements IPCMMClient {
-
-	protected Logger logger = LoggerFactory.getLogger(AbstractPCMMClient.class);
-	/**
-	 * socket used to communicated with server.
-	 */
-	private Socket socket;
-
-	private String clientHanlde;
-
-	private MMVersionInfo versionInfo;
-
-	private PCMMChannel channel;
-
-	public AbstractPCMMClient() {
-	}
-
-	/*
-	 * (non-Javadoc)
-	 * 
-	 * @see pcmm.rcd.IPCMMClient#sendRequest(pcmm.messages.IMessage)
-	 */
-	public void sendRequest(COPSMsg requestMessage) {
-		try {
-			channel.sendMsg(requestMessage);
-		} catch (Exception e) {
-			logger.error(e.getMessage(), getSocket());
-		}
-	}
-
-	/*
-	 * (non-Javadoc)
-	 * 
-	 * @see org.pcmm.rcd.IPCMMClient#readMessage()
-	 */
-	public COPSMsg readMessage() {
-		try {
-			COPSMsg recvdMsg = channel.receiveMessage();
-			// logger.debug("received message : " + recvdMsg.getHeader());
-			return recvdMsg;
-		} catch (Exception e) {
-			logger.error(e.getMessage(), getSocket());
-		}
-		return null;
-	}
-
-	/*
-	 * (non-Javadoc)
-	 * 
-	 * @see pcmm.rcd.IPCMMClient#tryConnect(java.lang.String, int)
-	 */
-	public boolean tryConnect(String address, int port) {
-		try {
-			InetAddress addr = InetAddress.getByName(address);
-			tryConnect(addr, port);
-		} catch (UnknownHostException e) {
-			logger.error(e.getMessage());
-			return false;
-		}
-		return true;
-	}
-
-	/*
-	 * (non-Javadoc)
-	 * 
-	 * @see pcmm.rcd.IPCMMClient#tryConnect(java.net.InetAddress, int)
-	 */
-	public boolean tryConnect(InetAddress address, int port) {
-		try {
-			setSocket(new Socket(address, port));
-		} catch (IOException e) {
-			logger.error(e.getMessage());
-			return false;
-		}
-		return true;
-	}
-
-	/*
-	 * (non-Javadoc)
-	 * 
-	 * @see pcmm.rcd.IPCMMClient#disconnect()
-	 */
-	public boolean disconnect() {
-		if (isConnected()) {
-			try {
-				socket.close();
-				channel = null;
-			} catch (IOException e) {
-				logger.error(e.getMessage());
-			}
-		}
-		return true;
-	}
-
-	/**
-	 * @return the socket
-	 */
-	public Socket getSocket() {
-		return socket;
-	}
-
-	public PCMMChannel getChannel() {
-		return channel;
-	}
-
-	/**
-	 * @param socket
-	 *            the socket to set
-	 */
-	public void setSocket(Socket socket) {
-		this.socket = socket;
-		if (this.socket != null
-				&& (this.channel == null || !this.channel.getSocket().equals(
-						this.socket)))
-			channel = new PCMMChannel(this.socket);
-	}
-
-	/*
-	 * (non-Javadoc)
-	 * 
-	 * @see org.pcmm.rcd.IPCMMClient#isConnected()
-	 */
-	public boolean isConnected() {
-		return socket != null && socket.isConnected();
-	}
-
-	/**
-	 * @return the versionInfo
-	 */
-	public MMVersionInfo getVersionInfo() {
-		return versionInfo;
-	}
-
-	/**
-	 * @param versionInfo
-	 *            the versionInfo to set
-	 */
-	public void setVersionInfo(MMVersionInfo versionInfo) {
-		this.versionInfo = versionInfo;
-	}
-
-	@Override
-	public String getClientHandle() {
-		return clientHanlde;
-	}
-
-	@Override
-	public void setClientHandle(String handle) {
-		this.clientHanlde = handle;
-	}
-
-}