Move Socket to dcpomatic_socket.{cc,h}.

1 files changed, 0 insertions, 129 deletions

diff --git a/src/lib/util.cc b/src/lib/util.cc
index 807883ca0..c298a1946 100644
--- a/src/lib/util.cc
+++ b/src/lib/util.cc
@@ -480,135 +480,6 @@ dcp_audio_frame_rate (int fs)
 	return 96000;
 }
 
-Socket::Socket (int timeout)
-	: _deadline (_io_service)
-	, _socket (_io_service)
-	, _acceptor (0)
-	, _timeout (timeout)
-{
-	_deadline.expires_at (boost::posix_time::pos_infin);
-	check ();
-}
-
-Socket::~Socket ()
-{
-	delete _acceptor;
-}
-
-void
-Socket::check ()
-{
-	if (_deadline.expires_at() <= boost::asio::deadline_timer::traits_type::now ()) {
-		if (_acceptor) {
-			_acceptor->cancel ();
-		} else {
-			_socket.close ();
-		}
-		_deadline.expires_at (boost::posix_time::pos_infin);
-	}
-
-	_deadline.async_wait (boost::bind (&Socket::check, this));
-}
-
-/** Blocking connect.
- *  @param endpoint End-point to connect to.
- */
-void
-Socket::connect (boost::asio::ip::tcp::endpoint endpoint)
-{
-	_deadline.expires_from_now (boost::posix_time::seconds (_timeout));
-	boost::system::error_code ec = boost::asio::error::would_block;
-	_socket.async_connect (endpoint, boost::lambda::var(ec) = boost::lambda::_1);
-	do {
-		_io_service.run_one();
-	} while (ec == boost::asio::error::would_block);
-
-	if (ec) {
-		throw NetworkError (String::compose (_("error during async_connect (%1)"), ec.value ()));
-	}
-
-	if (!_socket.is_open ()) {
-		throw NetworkError (_("connect timed out"));
-	}
-}
-
-void
-Socket::accept (int port)
-{
-	_acceptor = new boost::asio::ip::tcp::acceptor (_io_service, boost::asio::ip::tcp::endpoint (boost::asio::ip::tcp::v4(), port));
-	
-	_deadline.expires_from_now (boost::posix_time::seconds (_timeout));
-	boost::system::error_code ec = boost::asio::error::would_block;
-	_acceptor->async_accept (_socket, boost::lambda::var(ec) = boost::lambda::_1);
-	do {
-		_io_service.run_one ();
-	} while (ec == boost::asio::error::would_block);
-
-	delete _acceptor;
-	_acceptor = 0;
-	
-	if (ec) {
-		throw NetworkError (String::compose (_("error during async_accept (%1)"), ec.value ()));
-	}
-}
-
-/** Blocking write.
- *  @param data Buffer to write.
- *  @param size Number of bytes to write.
- */
-void
-Socket::write (uint8_t const * data, int size)
-{
-	_deadline.expires_from_now (boost::posix_time::seconds (_timeout));
-	boost::system::error_code ec = boost::asio::error::would_block;
-
-	boost::asio::async_write (_socket, boost::asio::buffer (data, size), boost::lambda::var(ec) = boost::lambda::_1);
-	
-	do {
-		_io_service.run_one ();
-	} while (ec == boost::asio::error::would_block);
-
-	if (ec) {
-		throw NetworkError (String::compose (_("error during async_write (%1)"), ec.value ()));
-	}
-}
-
-void
-Socket::write (uint32_t v)
-{
-	v = htonl (v);
-	write (reinterpret_cast<uint8_t*> (&v), 4);
-}
-
-/** Blocking read.
- *  @param data Buffer to read to.
- *  @param size Number of bytes to read.
- */
-void
-Socket::read (uint8_t* data, int size)
-{
-	_deadline.expires_from_now (boost::posix_time::seconds (_timeout));
-	boost::system::error_code ec = boost::asio::error::would_block;
-
-	boost::asio::async_read (_socket, boost::asio::buffer (data, size), boost::lambda::var(ec) = boost::lambda::_1);
-
-	do {
-		_io_service.run_one ();
-	} while (ec == boost::asio::error::would_block);
-	
-	if (ec) {
-		throw NetworkError (String::compose (_("error during async_read (%1)"), ec.value ()));
-	}
-}
-
-uint32_t
-Socket::read_uint32 ()
-{
-	uint32_t v;
-	read (reinterpret_cast<uint8_t *> (&v), 4);
-	return ntohl (v);
-}
-
 /** Round a number up to the nearest multiple of another number.
  *  @param c Index.
  *  @param s Array of numbers to round, indexed by c.