package org.umu.cops.ospdp;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-import org.umu.cops.stack.*;
-import org.umu.cops.stack.COPSHeader.OPCode;
+import org.umu.cops.prpdp.COPSPdpConnection;
+import org.umu.cops.prpdp.COPSPdpReqStateMan;
+import org.umu.cops.stack.COPSPepId;
+import org.umu.cops.stack.COPSReqMsg;
-import java.io.IOException;
+import javax.annotation.concurrent.ThreadSafe;
import java.net.Socket;
-import java.util.Date;
-import java.util.Map;
-import java.util.concurrent.ConcurrentHashMap;
/**
* Class for managing an outsourcing connection at the PDP side.
*/
-public class COPSPdpOSConnection implements Runnable {
-
- public final static Logger logger = LoggerFactory.getLogger(COPSPdpOSConnection.class);
-
- /**
- Socket connected to PEP
- */
- private Socket _sock;
-
- /**
- PEP identifier
- */
- private COPSPepId _pepId;
-
- /**
- Time of the latest keep-alive sent
- */
- private Date _lastKa;
-
- /**
- * Time of the latest keep-alive received
- */
- protected Date _lastRecKa;
-
- /**
- Maps a Client Handle to a Handler
- */
- protected final Map<String, COPSPdpOSReqStateMan> _managerMap;
-
- /**
- * PDP policy data processor class
- */
- protected COPSPdpOSDataProcess _process;
-
- /**
- Accounting timer value (secs)
- */
- protected short _acctTimer;
-
- /**
- Keep-alive timer value (secs)
- */
- protected short _kaTimer;
+@ThreadSafe
+public class COPSPdpOSConnection extends COPSPdpConnection {
/**
- COPS error returned by PEP
+ * The PDP OS Data Process object
*/
- protected COPSError _error;
+ private COPSPdpOSDataProcess _thisProcess;
/**
* Creates a new PDP connection
* @param sock Socket connected to PEP
* @param process Object for processing policy data
*/
- public COPSPdpOSConnection(COPSPepId pepId, Socket sock, COPSPdpOSDataProcess process) {
- _sock = sock;
- _pepId = pepId;
-
- _lastKa = new Date();
- _managerMap = new ConcurrentHashMap<>();
-
- _kaTimer = 0;
- _process = process;
- }
-
- /**
- * Gets the time of that latest keep-alive sent
- * @return Time of that latest keep-alive sent
- */
- public Date getLastKAlive() {
- return _lastKa;
- }
-
- /**
- * Sets the keep-alive timer value
- * @param kaTimer Keep-alive timer value (secs)
- */
- public void setKaTimer(short kaTimer) {
- _kaTimer = kaTimer;
- }
-
- /**
- * Gets the keep-alive timer value
- * @return Keep-alive timer value (secs)
- */
- public short getKaTimer() {
- return _kaTimer;
- }
-
- /**
- * Sets the accounting timer value
- * @param acctTimer Accounting timer value (secs)
- */
- public void setAccTimer(short acctTimer) {
- _acctTimer = acctTimer;
- }
-
- /**
- * Gets the accounting timer value
- * @return Accounting timer value (secs)
- */
- public short getAcctTimer() {
- return _acctTimer;
- }
-
- /**
- * Gets the PEP-ID
- * @return The ID of the PEP, as a <tt>String</tt>
- */
- public String getPepId() {
- return _pepId.getData().str();
- }
-
- /**
- * Checks whether the socket to the PEP is closed or not
- * @return <tt>true</tt> if closed, <tt>false</tt> otherwise
- */
- public boolean isClosed() {
- return _sock.isClosed();
- }
-
- /**
- * Closes the socket to the PEP
- * @throws IOException
- */
- protected void close()
- throws IOException {
- _sock.close();
- }
-
- /**
- * Gets the socket to the PEP
- * @return Socket connected to the PEP
- */
- public Socket getSocket() {
- return _sock;
- }
-
- /**
- * Main loop
- */
- public void run() {
- Date _lastSendKa = new Date();
- _lastRecKa = new Date();
- try {
- while (!_sock.isClosed()) {
- if (_sock.getInputStream().available() != 0) {
-// _lastmessage = processMessage(_sock);
- processMessage(_sock);
- _lastRecKa = new Date();
- }
-
- // Keep Alive
- if (_kaTimer > 0) {
- // Timeout at PDP
- int _startTime = (int) (_lastRecKa.getTime());
- int cTime = (int) (new Date().getTime());
-
- if ((cTime - _startTime) > _kaTimer*1000) {
- _sock.close();
- // Notify all Request State Managers
- notifyNoKAAllReqStateMan();
- }
-
- // Send to PEP
- _startTime = (int) (_lastSendKa.getTime());
- cTime = (int) (new Date().getTime());
-
- if ((cTime - _startTime) > ((_kaTimer*3/4)*1000)) {
- // TODO - is 0 ok for a clientType here???
- final COPSKAMsg msg = new COPSKAMsg(null);
- COPSTransceiver.sendMsg(msg, _sock);
- _lastSendKa = new Date();
- }
- }
-
- try {
- Thread.sleep(500);
- } catch (Exception e) {
- logger.error("Exception caught while sleeping", e);
- }
-
- }
- } catch (Exception e) {
- logger.error("Error processing COPS message from socket", e);
- }
-
- // connection closed by server
- // COPSDebug.out(getClass().getName(),"Connection closed by client");
- try {
- _sock.close();
- } catch (IOException e) {
- logger.error("Error closing socket", e);
- }
-
- // Notify all Request State Managers
- try {
- notifyCloseAllReqStateMan();
- } catch (COPSPdpException e) {
- logger.error("Error closing state managers", e);
- }
- }
-
- /**
- * Gets a COPS message from the socket and processes it
- * @param conn Socket connected to the PEP
- */
- private void processMessage(Socket conn) throws COPSPdpException, COPSException, IOException {
- COPSMsg msg = COPSTransceiver.receiveMsg(conn);
-
- if (msg.getHeader().getOpCode().equals(OPCode.CC)) {
- handleClientCloseMsg(conn, msg);
- } else if (msg.getHeader().getOpCode().equals(OPCode.KA)) {
- handleKeepAliveMsg(conn, msg);
- } else if (msg.getHeader().getOpCode().equals(OPCode.REQ)) {
- handleRequestMsg(conn, msg);
- } else if (msg.getHeader().getOpCode().equals(OPCode.RPT)) {
- handleReportMsg(conn, msg);
- } else if (msg.getHeader().getOpCode().equals(OPCode.DRQ)) {
- handleDeleteRequestMsg(conn, msg);
- } else if (msg.getHeader().getOpCode().equals(OPCode.SSC)) {
- handleSyncComplete(conn, msg);
- } else {
- throw new COPSPdpException("Message not expected (" + msg.getHeader().getOpCode() + ").");
- }
- }
-
- /**
- * Handle Client Close Message, close the passed connection
- *
- * @param conn a Socket
- * @param msg a COPSMsg
- *
- *
- * <Client-Close> ::= <Common Header>
- * <Error>
- * [<Integrity>]
- *
- * Not support [<Integrity>]
- *
- */
- private void handleClientCloseMsg(Socket conn, COPSMsg msg) {
- COPSClientCloseMsg cMsg = (COPSClientCloseMsg) msg;
- _error = cMsg.getError();
-
- // COPSDebug.out(getClass().getName(),"Got close request, closing connection " +
- // conn.getInetAddress() + ":" + conn.getPort() + ":[Error " + _error.getDescription() + "]");
-
- try {
- // Support
- if (cMsg.getIntegrity() != null) {
- logger.error("Unsupported objects (Integrity) to connection " + conn.getInetAddress());
- }
-
- conn.close();
- } catch (Exception unae) {
- logger.error("Unexpected exception while closing the connection", unae);
- }
- }
-
- /**
- * Gets the occurred COPS Error
- * @return <tt>COPSError</tt> object
- */
- protected COPSError getError() {
- return _error;
- }
-
- /**
- * Handle Keep Alive Message
- *
- * <Keep-Alive> ::= <Common Header>
- * [<Integrity>]
- *
- * Not support [<Integrity>]
- *
- * @param conn a Socket
- * @param msg a COPSMsg
- *
- */
- private void handleKeepAliveMsg(Socket conn, COPSMsg msg) {
- COPSKAMsg cMsg = (COPSKAMsg) msg;
-
- COPSKAMsg kaMsg = (COPSKAMsg) msg;
- try {
- // Support
- if (cMsg.getIntegrity() != null) {
- logger.error("Unsupported objects (Integrity) to connection " + conn.getInetAddress());
- }
-
- kaMsg.writeData(conn);
- } catch (Exception unae) {
- logger.error("Unexpected exception writing COPS data", unae);
- }
- }
-
- /**
- * Handle Delete Request Message
- *
- * <Delete Request> ::= <Common Header>
- * <Client Handle>
- * <Reason>
- * [<Integrity>]
- *
- * Not support [<Integrity>]
- *
- * @param conn a Socket
- * @param msg a COPSMsg
- *
- */
- private void handleDeleteRequestMsg(Socket conn, COPSMsg msg)
- throws COPSPdpException {
- COPSDeleteMsg cMsg = (COPSDeleteMsg) msg;
- // COPSDebug.out(getClass().getName(),"Removing ClientHandle for " +
- // conn.getInetAddress() + ":" + conn.getPort() + ":[Reason " + cMsg.getReason().getDescription() + "]");
-
- // Support
- if (cMsg.getIntegrity() != null) {
- logger.error("Unsupported objects (Integrity) to connection " + conn.getInetAddress());
- }
-
- // Delete clientHandler
- if (_managerMap.remove(cMsg.getClientHandle().getId().str()) == null) {
- // COPSDebug.out(getClass().getName(),"Missing for ClientHandle " +
- // cMsg.getClientHandle().getId().getData());
- }
-
- final COPSPdpOSReqStateMan man = _managerMap.get(cMsg.getClientHandle().getId().str());
- if (man == null) {
- logger.warn("State manager not found for ID - " + cMsg.getClientHandle().getId().str());
- } else {
- man.processDeleteRequestState(cMsg);
- }
-
- }
-
- /**
- * Handle Request Message
- *
- * <Request> ::= <Common Header>
- * <Client Handle>
- * <Context>
- * *(<Named ClientSI>)
- * [<Integrity>]
- * <Named ClientSI> ::= <*(<PRID> <EPD>)>
- *
- * Not support [<Integrity>]
- *
- * @param conn a Socket
- * @param msg a COPSMsg
- *
- */
- private void handleRequestMsg(Socket conn, COPSMsg msg) throws COPSPdpException {
- final COPSReqMsg reqMsg = (COPSReqMsg) msg;
- final COPSHeader header = reqMsg.getHeader();
- final short cType = header.getClientType();
-
- // Support
- if (reqMsg.getIntegrity() != null) {
- logger.error("Unsupported objects (Integrity) to connection " + conn.getInetAddress());
- }
-
- final COPSPdpOSReqStateMan man;
- if (_managerMap.get(reqMsg.getClientHandle().getId().str()) == null) {
- man = new COPSPdpOSReqStateMan(cType, reqMsg.getClientHandle().getId().str());
- _managerMap.put(reqMsg.getClientHandle().getId().str(),man);
- man.setDataProcess(_process);
- man.initRequestState(_sock);
- } else {
- man = _managerMap.get(reqMsg.getClientHandle().getId().str());
- }
- man.processRequest(reqMsg);
- }
-
- /**
- * Handle Report Message
- *
- * <Report State> ::= <Common Header>
- * <Client Handle>
- * <Report Type>
- * *(<Named ClientSI>)
- * [<Integrity>]
- *
- * Not support [<Integrity>]
- *
- * @param conn a Socket
- * @param msg a COPSMsg
- *
- */
- private void handleReportMsg(Socket conn, COPSMsg msg) throws COPSPdpException {
- COPSReportMsg repMsg = (COPSReportMsg) msg;
- // COPSHandle handle = repMsg.getClientHandle();
- // COPSHeader header = repMsg.getHeader();
-
- // Support
- if (repMsg.getIntegrity() != null) {
- logger.error("Unsupported objects (Integrity) to connection " + conn.getInetAddress());
- }
-
- COPSPdpOSReqStateMan man = _managerMap.get(repMsg.getClientHandle().getId().str());
- if (man == null) {
- logger.warn("State manager not found for ID - " + repMsg.getClientHandle().getId().str());
- } else {
- man.processReport(repMsg);
- }
- }
-
- /**
- * Method handleSyncComplete
- *
- * @param conn a Socket
- * @param msg a COPSMsg
- *
- */
- private void handleSyncComplete(Socket conn, COPSMsg msg) throws COPSPdpException {
- final COPSSyncStateMsg cMsg = (COPSSyncStateMsg) msg;
-
- // Support
- if (cMsg.getIntegrity() != null) {
- logger.error("Unsupported objects (Integrity) to connection " + conn.getInetAddress());
- }
-
- final COPSPdpOSReqStateMan man = _managerMap.get(cMsg.getClientHandle().getId().str());
- if (man == null) {
- logger.warn("State manager not found for ID - " + cMsg.getClientHandle().getId().str());
- } else {
- man.processSyncComplete(cMsg);
- }
- }
-
- /**
- * Requests a COPS sync from the PEP
- * @throws COPSException
- * @throws COPSPdpException
- */
- protected void syncAllRequestState() throws COPSException, COPSPdpException {
- for (final COPSPdpOSReqStateMan man : _managerMap.values()) {
- man.syncRequestState();
- }
- }
-
- private void notifyCloseAllReqStateMan() throws COPSPdpException {
- for (final COPSPdpOSReqStateMan man : _managerMap.values()) {
- man.processClosedConnection(_error);
- }
+ public COPSPdpOSConnection(final COPSPepId pepId, final Socket sock, final COPSPdpOSDataProcess process) {
+ super(pepId, sock, process);
+ this._thisProcess = process;
}
- private void notifyNoKAAllReqStateMan() throws COPSPdpException {
- for (final COPSPdpOSReqStateMan man : _managerMap.values()) {
- man.processNoKAConnection();
- }
+ @Override
+ protected COPSPdpReqStateMan createStateManager(final COPSReqMsg reqMsg) {
+ return new COPSPdpOSReqStateMan(reqMsg.getHeader().getClientType(), reqMsg.getClientHandle(), _thisProcess,
+ _sock);
}
}
Code Review / packetcable.git / blobdiff