package org.umu.cops.stack;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
import java.io.IOException;
import java.io.OutputStream;
import java.net.Socket;
*/
abstract public class COPSMsg {
+ private static final Logger logger = LoggerFactory.getLogger(COPSMsg.class);
+
/**
* The COPS header that is associated with all COPS messages
*/
* @throws IOException
*/
public final void writeData(final Socket socket) throws IOException {
- // checkSanity();
+ logger.info("Writing data for OPCode - " + _hdr.getOpCode());
_hdr.writeData(socket, _hdr.getHdrLength() + getDataLength());
writeBody(socket);
}
package org.umu.cops.stack;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
import org.umu.cops.stack.COPSHeader.Flag;
import org.umu.cops.stack.COPSHeader.OPCode;
public class COPSMsgParser {
+ public final static Logger logger = LoggerFactory.getLogger(COPSMsgParser.class);
+
/**
* Transforms a COPS message streaming in from a Socket connection into a COPSMsg object
* @param socket - the socket
* @throws IOException
*/
private static COPSHeaderData readHeader(final Socket socket) throws IOException {
+ logger.info("Reading COPS Header");
final byte[] data = new byte[8];
final int bytesRead = readData(socket, data, 8);
if (bytesRead != 8) throw new IOException("Expected 8 bytes, read in " + bytesRead);
}
private static COPSMsg readBody(final Socket socket, final COPSHeaderData hdrData) throws IOException, COPSException {
+ logger.info("Reading COPS Body of type - " + hdrData.header.getOpCode());
final int expectedBytes = hdrData.msgByteCount - hdrData.header.getHdrLength();
final byte[] buffer = new byte[expectedBytes];
final int nread = readData(socket, buffer, expectedBytes);
* @throws IOException
*/
public static void writeData(final Socket socket, final byte[] data, final int len) throws IOException {
- logger.info("Writing COPS data");
+ logger.trace("Writing COPS data");
socket.getOutputStream().write(data, 0, len);
}