7 import org.umu.cops.prpdp.COPSPdpConnection;
8 import org.umu.cops.prpdp.COPSPdpReqStateMan;
9 import org.umu.cops.stack.COPSPepId;
10 import org.umu.cops.stack.COPSReqMsg;
12 import javax.annotation.concurrent.ThreadSafe;
13 import java.net.Socket;
16 * Class for managing an provisioning connection at the PDP side for receiving and brokering out COPS messages.
19 public class PCMMPdpConnection extends COPSPdpConnection {
22 * PDP policy data processor class
24 protected final PCMMPdpDataProcess _thisProcess;
27 * Creates a new PDP connection
29 * @param pepId PEP-ID of the connected PEP
30 * @param sock Socket connected to PEP
31 * @param process Object for processing policy data
33 public PCMMPdpConnection(final COPSPepId pepId, final Socket sock, final PCMMPdpDataProcess process,
34 final short kaTimer, final short acctTimer) {
35 super(pepId, sock, process, kaTimer, acctTimer);
36 _thisProcess = process;
40 * Returns an instance of a COPSPdpReqStateMan
41 * @param reqMsg - the request on which to create the state manager
42 * @return - the state manager
44 protected COPSPdpReqStateMan createStateManager(final COPSReqMsg reqMsg) {
45 return new PCMMPdpReqStateMan(reqMsg.getHeader().getClientType(), reqMsg.getClientHandle(), _thisProcess,