SocketWrapper.java

package com.renomad.minum.web;

import com.renomad.minum.logging.ILogger;

import java.io.*;
import java.net.Socket;
import java.net.SocketAddress;
import java.nio.charset.Charset;

/**
 * This wraps Sockets to make them more particular to our use case
 */
final class SocketWrapper implements ISocketWrapper {

    private final Socket socket;
    private final String hostName;
    private final BufferedOutputStream writer;
    private final ILogger logger;
    private final IServer server;
    private final BufferedInputStream bufferedInputStream;

    /**
     * Constructor
     * @param socket a socket we intend to wrap with methods applicable to our use cases
     * @param logger not much more to say on this param
     * @param timeoutMillis we'll configure the socket to timeout after this many milliseconds.
     */
    SocketWrapper(Socket socket, IServer server, ILogger logger, int timeoutMillis, String hostName) throws IOException {
        this.socket = socket;
        this.hostName = hostName;
        logger.logTrace(() -> String.format("Setting timeout of %d milliseconds on socket %s", timeoutMillis, socket));
        this.socket.setSoTimeout(timeoutMillis);
        this.bufferedInputStream = new BufferedInputStream(socket.getInputStream());
        writer = new BufferedOutputStream(socket.getOutputStream());
        this.logger = logger;
        this.server = server;
    }

    @Override
    public void send(String msg) throws IOException {
        writer.write(msg.getBytes(Charset.defaultCharset()));
    }

    @Override
    public void send(byte[] bodyContents) throws IOException {
        writer.write(bodyContents);
    }

    @Override
    public void send(byte[] bodyContents, int off, int len) throws IOException {
        writer.write(bodyContents, off, len);
    }

    @Override
    public void send(int b) throws IOException {
        writer.write(b);
    }

    @Override
    public void sendHttpLine(String msg) throws IOException {
        logger.logTrace(() -> String.format("%s sending: \"%s\"", this, msg));
        send(msg + WebEngine.HTTP_CRLF);
    }

    @Override
    public int getLocalPort() {
        return socket.getLocalPort();
    }

    @Override
    public SocketAddress getRemoteAddrWithPort() {
        return socket.getRemoteSocketAddress();
    }

    @Override
    public String getRemoteAddr() {
        return socket.getInetAddress().getHostAddress();
    }

    @Override
    public HttpServerType getServerType() {
        return server.getServerType();
    }

    @Override
    public void close() throws IOException {
        logger.logTrace(() -> "close called on " + this);
        socket.close();
        if (server != null) server.removeMyRecord(this);
    }

    @Override
    public InputStream getInputStream() {
        return bufferedInputStream;
    }

    /**
     * Note that since we are indicating just the remote address
     * as the unique value, in cases like tests where we are operating as
     * sometimes server or client, you might see the server as the remote.
     */
    @Override
    public String toString() {
        return "(SocketWrapper for remote address: " + this.getRemoteAddrWithPort().toString() + ")";
    }

    @Override
    public String getHostName() {
        return hostName;
    }

    @Override
    public void flush() throws IOException {
        this.writer.flush();
    }
}


















Active mutators

CONDITIONALS_BOUNDARY
EMPTY_RETURNS
FALSE_RETURNS
INCREMENTS
INVERT_NEGS
MATH
NEGATE_CONDITIONALS
NULL_RETURNS
PRIMITIVE_RETURNS
TRUE_RETURNS
VOID_METHOD_CALLS

Tests examined

com.renomad.minum.FunctionalTests (2021 ms)
com.renomad.minum.web.WebPerformanceTests.test2(com.renomad.minum.web.WebPerformanceTests) (608 ms)
com.renomad.minum.web.WebPerformanceTests.test3(com.renomad.minum.web.WebPerformanceTests) (621 ms)
com.renomad.minum.web.WebPerformanceTests.test1(com.renomad.minum.web.WebPerformanceTests) (625 ms)
com.renomad.minum.web.WebTests (906 ms)
com.renomad.minum.web.ServerTests (182 ms)
com.renomad.minum.web.SocketWrapperTests.testSendingSingleByte(com.renomad.minum.web.SocketWrapperTests) (2 ms)

Report generated by PIT 1.17.0

1		package com.renomad.minum.web;
2
3		import com.renomad.minum.logging.ILogger;
4
5		import java.io.*;
6		import java.net.Socket;
7		import java.net.SocketAddress;
8		import java.nio.charset.Charset;
9
10		/**
11		* This wraps Sockets to make them more particular to our use case
12		*/
13		final class SocketWrapper implements ISocketWrapper {
14
15		private final Socket socket;
16		private final String hostName;
17		private final BufferedOutputStream writer;
18		private final ILogger logger;
19		private final IServer server;
20		private final BufferedInputStream bufferedInputStream;
21
22		/**
23		* Constructor
24		* @param socket a socket we intend to wrap with methods applicable to our use cases
25		* @param logger not much more to say on this param
26		* @param timeoutMillis we'll configure the socket to timeout after this many milliseconds.
27		*/
28		SocketWrapper(Socket socket, IServer server, ILogger logger, int timeoutMillis, String hostName) throws IOException {
29		this.socket = socket;
30		this.hostName = hostName;
31		logger.logTrace(() -> String.format("Setting timeout of %d milliseconds on socket %s", timeoutMillis, socket));
32	1 1. <init> : removed call to java/net/Socket::setSoTimeout → TIMED_OUT	this.socket.setSoTimeout(timeoutMillis);
33		this.bufferedInputStream = new BufferedInputStream(socket.getInputStream());
34		writer = new BufferedOutputStream(socket.getOutputStream());
35		this.logger = logger;
36		this.server = server;
37		}
38
39		@Override
40		public void send(String msg) throws IOException {
41	1 1. send : removed call to java/io/BufferedOutputStream::write → TIMED_OUT	writer.write(msg.getBytes(Charset.defaultCharset()));
42		}
43
44		@Override
45		public void send(byte[] bodyContents) throws IOException {
46	1 1. send : removed call to java/io/BufferedOutputStream::write → TIMED_OUT	writer.write(bodyContents);
47		}
48
49		@Override
50		public void send(byte[] bodyContents, int off, int len) throws IOException {
51	1 1. send : removed call to java/io/BufferedOutputStream::write → KILLED	writer.write(bodyContents, off, len);
52		}
53
54		@Override
55		public void send(int b) throws IOException {
56	1 1. send : removed call to java/io/BufferedOutputStream::write → KILLED	writer.write(b);
57		}
58
59		@Override
60		public void sendHttpLine(String msg) throws IOException {
61		logger.logTrace(() -> String.format("%s sending: \"%s\"", this, msg));
62	1 1. sendHttpLine : removed call to com/renomad/minum/web/SocketWrapper::send → KILLED	send(msg + WebEngine.HTTP_CRLF);
63		}
64
65		@Override
66		public int getLocalPort() {
67	1 1. getLocalPort : replaced int return with 0 for com/renomad/minum/web/SocketWrapper::getLocalPort → KILLED	return socket.getLocalPort();
68		}
69
70		@Override
71		public SocketAddress getRemoteAddrWithPort() {
72	1 1. getRemoteAddrWithPort : replaced return value with null for com/renomad/minum/web/SocketWrapper::getRemoteAddrWithPort → KILLED	return socket.getRemoteSocketAddress();
73		}
74
75		@Override
76		public String getRemoteAddr() {
77	1 1. getRemoteAddr : replaced return value with "" for com/renomad/minum/web/SocketWrapper::getRemoteAddr → KILLED	return socket.getInetAddress().getHostAddress();
78		}
79
80		@Override
81		public HttpServerType getServerType() {
82	1 1. getServerType : replaced return value with null for com/renomad/minum/web/SocketWrapper::getServerType → KILLED	return server.getServerType();
83		}
84
85		@Override
86		public void close() throws IOException {
87		logger.logTrace(() -> "close called on " + this);
88	1 1. close : removed call to java/net/Socket::close → KILLED	socket.close();
89	2 1. close : negated conditional → TIMED_OUT 2. close : removed call to com/renomad/minum/web/IServer::removeMyRecord → TIMED_OUT	if (server != null) server.removeMyRecord(this);
90		}
91
92		@Override
93		public InputStream getInputStream() {
94	1 1. getInputStream : replaced return value with null for com/renomad/minum/web/SocketWrapper::getInputStream → TIMED_OUT	return bufferedInputStream;
95		}
96
97		/**
98		* Note that since we are indicating just the remote address
99		* as the unique value, in cases like tests where we are operating as
100		* sometimes server or client, you might see the server as the remote.
101		*/
102		@Override
103		public String toString() {
104	1 1. toString : replaced return value with "" for com/renomad/minum/web/SocketWrapper::toString → KILLED	return "(SocketWrapper for remote address: " + this.getRemoteAddrWithPort().toString() + ")";
105		}
106
107		@Override
108		public String getHostName() {
109	1 1. getHostName : replaced return value with "" for com/renomad/minum/web/SocketWrapper::getHostName → KILLED	return hostName;
110		}
111
112		@Override
113		public void flush() throws IOException {
114	1 1. flush : removed call to java/io/BufferedOutputStream::flush → KILLED	this.writer.flush();
115		}
116		}
		Mutations
32		1.1 Location : <init> Killed by : none removed call to java/net/Socket::setSoTimeout → TIMED_OUT
41		1.1 Location : send Killed by : none removed call to java/io/BufferedOutputStream::write → TIMED_OUT
46		1.1 Location : send Killed by : none removed call to java/io/BufferedOutputStream::write → TIMED_OUT
51		1.1 Location : send Killed by : com.renomad.minum.FunctionalTests removed call to java/io/BufferedOutputStream::write → KILLED
56		1.1 Location : send Killed by : com.renomad.minum.web.SocketWrapperTests.testSendingSingleByte(com.renomad.minum.web.SocketWrapperTests) removed call to java/io/BufferedOutputStream::write → KILLED
62		1.1 Location : sendHttpLine Killed by : com.renomad.minum.web.WebPerformanceTests.test2(com.renomad.minum.web.WebPerformanceTests) removed call to com/renomad/minum/web/SocketWrapper::send → KILLED
67		1.1 Location : getLocalPort Killed by : com.renomad.minum.FunctionalTests replaced int return with 0 for com/renomad/minum/web/SocketWrapper::getLocalPort → KILLED
72		1.1 Location : getRemoteAddrWithPort Killed by : com.renomad.minum.web.ServerTests replaced return value with null for com/renomad/minum/web/SocketWrapper::getRemoteAddrWithPort → KILLED
77		1.1 Location : getRemoteAddr Killed by : com.renomad.minum.web.WebPerformanceTests.test2(com.renomad.minum.web.WebPerformanceTests) replaced return value with "" for com/renomad/minum/web/SocketWrapper::getRemoteAddr → KILLED
82		1.1 Location : getServerType Killed by : com.renomad.minum.FunctionalTests replaced return value with null for com/renomad/minum/web/SocketWrapper::getServerType → KILLED
88		1.1 Location : close Killed by : com.renomad.minum.web.WebTests removed call to java/net/Socket::close → KILLED
89		1.1 Location : close Killed by : none negated conditional → TIMED_OUT 2.2 Location : close Killed by : none removed call to com/renomad/minum/web/IServer::removeMyRecord → TIMED_OUT
94		1.1 Location : getInputStream Killed by : none replaced return value with null for com/renomad/minum/web/SocketWrapper::getInputStream → TIMED_OUT
104		1.1 Location : toString Killed by : com.renomad.minum.web.WebTests replaced return value with "" for com/renomad/minum/web/SocketWrapper::toString → KILLED
109		1.1 Location : getHostName Killed by : com.renomad.minum.FunctionalTests replaced return value with "" for com/renomad/minum/web/SocketWrapper::getHostName → KILLED
114		1.1 Location : flush Killed by : com.renomad.minum.web.WebPerformanceTests.test2(com.renomad.minum.web.WebPerformanceTests) removed call to java/io/BufferedOutputStream::flush → KILLED

SocketWrapper.java

Mutations

Active mutators

Tests examined