Method handleReadHeader

src/IECoreImage/DisplayDriverServer.cpp:350–437

}

void DisplayDriverServer::Session::handleReadHeader( const boost::system::error_code& error )
{
	if (error)
	{
		msg( Msg::Error, "DisplayDriverServer::Session::handleReadHeader", error.message().c_str() );
		m_socket.close();
		return;
	}

	if ( !m_header.valid() )
	{
		msg( Msg::Error, "DisplayDriverServer::Session::handleReadHeader", "Invalid header!" );
		m_socket.close();
		return;
	}

	// get number of bytes ahead (unsigned int value)
	size_t bytesAhead = m_header.getDataSize();

	CharVectorData::ValueType &data = m_buffer->writable();
	data.resize( bytesAhead );

	// service
	switch( m_header.messageType() )
	{
	case DisplayDriverServerHeader::imageOpen:
		boost::asio::async_read( m_socket,
				boost::asio::buffer( &data[0], bytesAhead ),
				boost::bind( &DisplayDriverServer::Session::handleReadOpenParameters, SessionPtr(this), boost::asio::placeholders::error)
		);
		break;

	case DisplayDriverServerHeader::imageData:
		boost::asio::async_read( m_socket,
				boost::asio::buffer( &data[0], bytesAhead ),
				boost::bind(&DisplayDriverServer::Session::handleReadDataParameters, SessionPtr(this),
				boost::asio::placeholders::error));
		break;

	case DisplayDriverServerHeader::imageClose:
		if ( m_displayDriver )
		{
			try
			{
				if ( !m_mergeId.has_value() )
				{
					m_displayDriver->imageClose();
				}
				else
				{
					auto &m = m_mergeMap.at(m_mergeId.value()); // Error out if not found
					if ( --m.mergeCount <= 0 )
					{
						m_mergeMap.erase(m_mergeId.value());
						m_displayDriver->imageClose();
					}
				}
			}