X-Git-Url: https://main.carlh.net/gitweb/?a=blobdiff_plain;f=src%2Flib%2Fdcp_video.cc;h=655c373822ea750aedda3669a52fcccec4db913c;hb=9d045fa4e19d6b9a3f2ffcd67a5b69de823595e6;hp=6d270dab2613a1881e851ca747a935d95c3ab84a;hpb=5a5324ed3a381a86dfe0a6e3932c1d58fdcd596f;p=dcpomatic.git diff --git a/src/lib/dcp_video.cc b/src/lib/dcp_video.cc index 6d270dab2..655c37382 100644 --- a/src/lib/dcp_video.cc +++ b/src/lib/dcp_video.cc @@ -37,17 +37,15 @@ #include "log.h" #include "cross.h" #include "player_video.h" -#include "raw_convert.h" #include "compose.hpp" #include +#include #include #include #include -#include #include #include #include -#include #include #include #include @@ -61,9 +59,9 @@ using std::string; using std::cout; using boost::shared_ptr; -using boost::make_shared; using dcp::Size; using dcp::Data; +using dcp::raw_convert; #define DCI_COEFFICENT (48.0 / 52.37) @@ -111,7 +109,7 @@ DCPVideo::convert_to_xyz (shared_ptr frame, dcp::NoteHandler note ); } else { - xyz = dcp::xyz_to_xyz (image->data()[0], image->size(), image->stride()[0]); + xyz.reset (new dcp::OpenJPEGImage (image->data()[0], image->size(), image->stride()[0])); } return xyz; @@ -150,6 +148,7 @@ DCPVideo::encode_locally (dcp::NoteHandler note) /** Send this frame to a remote server for J2K encoding, then read the result. * @param serv Server to send to. + * @param timeout timeout in seconds. * @return Encoded data. */ Data @@ -157,10 +156,10 @@ DCPVideo::encode_remotely (EncodeServerDescription serv, int timeout) { boost::asio::io_service io_service; boost::asio::ip::tcp::resolver resolver (io_service); - boost::asio::ip::tcp::resolver::query query (serv.host_name(), raw_convert (Config::instance()->server_port_base ())); + boost::asio::ip::tcp::resolver::query query (serv.host_name(), raw_convert (ENCODE_FRAME_PORT)); boost::asio::ip::tcp::resolver::iterator endpoint_iterator = resolver.resolve (query); - shared_ptr socket = make_shared (timeout); + shared_ptr socket (new Socket (timeout)); socket->connect (*endpoint_iterator); @@ -178,17 +177,17 @@ DCPVideo::encode_remotely (EncodeServerDescription serv, int timeout) socket->write ((uint8_t *) xml.c_str(), xml.length() + 1); /* Send binary data */ - LOG_TIMING("start-remote-send thread=%1", boost::this_thread::get_id()); + LOG_TIMING("start-remote-send thread=%1", thread_id ()); _frame->send_binary (socket); /* Read the response (JPEG2000-encoded data); this blocks until the data is ready and sent back. */ - LOG_TIMING("start-remote-encode thread=%1", boost::this_thread::get_id ()); + LOG_TIMING("start-remote-encode thread=%1", thread_id ()); Data e (socket->read_uint32 ()); - LOG_TIMING("start-remote-receive thread=%1", boost::this_thread::get_id ()); + LOG_TIMING("start-remote-receive thread=%1", thread_id ()); socket->read (e.data().get(), e.size()); - LOG_TIMING("finish-remote-receive thread=%1", boost::this_thread::get_id ()); + LOG_TIMING("finish-remote-receive thread=%1", thread_id ()); LOG_DEBUG_ENCODE (N_("Finished remotely-encoded frame %1"), _index);