greenplumn COstream 源码

greenplumn COstream 代码

文件路径：/src/backend/gporca/libgpos/src/io/COstream.cpp

//---------------------------------------------------------------------------
//	Greenplum Database
//	Copyright (C) 2009 - 2010 Greenplum, Inc.
//
//	@filename:
//		COstream.cpp
//
//	@doc:
//		Implementation of basic wide character output stream
//---------------------------------------------------------------------------

#include "gpos/io/COstream.h"

#include "gpos/common/clibwrapper.h"

using namespace gpos;


//---------------------------------------------------------------------------
//	@function:
//		COstream::COstream
//
//	@doc:
//		ctor
//
//---------------------------------------------------------------------------
COstream::COstream()
	: m_static_string_buffer(m_string_format_buffer, GPOS_OSTREAM_CONVBUF_SIZE)

{
}


IOstream &
COstream::AppendFormat(const WCHAR *format, ...)
{
	VA_LIST vl;

	VA_START(vl, format);

	m_static_string_buffer.Reset();
	m_static_string_buffer.AppendFormatVA(format, vl);

	VA_END(vl);

	(*this) << m_static_string_buffer.GetBuffer();
	return *this;
}


//---------------------------------------------------------------------------
//	@function:
//		COstream::operator<<
//
//	@doc:
//		write of CHAR with conversion
//
//---------------------------------------------------------------------------
IOstream &
COstream::operator<<(const CHAR *input_char)
{
	return AppendFormat(GPOS_WSZ_LIT("%s"), input_char);
}


//---------------------------------------------------------------------------
//	@function:
//		COstream::operator<<
//
//	@doc:
//		write a single WCHAR with conversion
//
//---------------------------------------------------------------------------
IOstream &
COstream::operator<<(const WCHAR input_char)
{
	return AppendFormat(GPOS_WSZ_LIT("%lc"), input_char);
}


//---------------------------------------------------------------------------
//	@function:
//		COstream::operator<<
//
//	@doc:
//		write a single CHAR with conversion
//
//---------------------------------------------------------------------------
IOstream &
COstream::operator<<(const CHAR input_char)
{
	return AppendFormat(GPOS_WSZ_LIT("%c"), input_char);
}


//---------------------------------------------------------------------------
//	@function:
//		COstream::operator<<
//
//	@doc:
//		write a ULONG with conversion
//
//---------------------------------------------------------------------------
IOstream &
COstream::operator<<(ULONG input_ulong)
{
	switch (GetStreamManipulator())
	{
		case EsmDec:
			return AppendFormat(GPOS_WSZ_LIT("%u"), input_ulong);

		case EsmHex:
			return AppendFormat(GPOS_WSZ_LIT("%x"), input_ulong);

		default:
			GPOS_ASSERT(!"Unexpected stream mode");
	}

	return *this;
}


//---------------------------------------------------------------------------
//	@function:
//		COstream::operator<<
//
//	@doc:
//		write a ULLONG with conversion
//
//---------------------------------------------------------------------------
IOstream &
COstream::operator<<(ULLONG input_ullong)
{
	switch (GetStreamManipulator())
	{
		case EsmDec:
			return AppendFormat(GPOS_WSZ_LIT("%llu"), input_ullong);

		case EsmHex:
			return AppendFormat(GPOS_WSZ_LIT("%llx"), input_ullong);

		default:
			GPOS_ASSERT(!"Unexpected stream mode");
	}

	return *this;
}


//---------------------------------------------------------------------------
//	@function:
//		COstream::operator<<
//
//	@doc:
//		write an INT with conversion
//
//---------------------------------------------------------------------------
IOstream &
COstream::operator<<(INT input_int)
{
	switch (GetStreamManipulator())
	{
		case EsmDec:
			return AppendFormat(GPOS_WSZ_LIT("%d"), input_int);

		case EsmHex:
			return AppendFormat(GPOS_WSZ_LIT("%x"), input_int);

		default:
			GPOS_ASSERT(!"Unexpected stream mode");
	}

	return *this;
}


//---------------------------------------------------------------------------
//	@function:
//		COstream::operator<<
//
//	@doc:
//		write a LINT with conversion
//
//---------------------------------------------------------------------------
IOstream &
COstream::operator<<(LINT input_long_int)
{
	switch (GetStreamManipulator())
	{
		case EsmDec:
			return AppendFormat(GPOS_WSZ_LIT("%lld"), input_long_int);

		case EsmHex:
			return AppendFormat(GPOS_WSZ_LIT("%llx"), input_long_int);

		default:
			GPOS_ASSERT(!"Unexpected stream mode");
	}

	return *this;
}


//---------------------------------------------------------------------------
//	@function:
//		COstream::operator<<
//
//	@doc:
//		write a double-precision floating point number
//
//---------------------------------------------------------------------------
IOstream &
COstream::operator<<(const DOUBLE input_double)
{
	if (m_fullPrecision)
	{
		return AppendFormat(GPOS_WSZ_LIT("%.17f"), input_double);
	}
	return AppendFormat(GPOS_WSZ_LIT("%f"), input_double);
}


//---------------------------------------------------------------------------
//	@function:
//		COstream::operator<<
//
//	@doc:
//		write a pointer with conversion
//
//---------------------------------------------------------------------------
IOstream &
COstream::operator<<(const void *input_pointer)
{
	return AppendFormat(GPOS_WSZ_LIT("%p"), input_pointer);
}

//---------------------------------------------------------------------------
//	@function:
//		COstream::operator<<
//
//	@doc:
//		Change the stream modifier
//
//---------------------------------------------------------------------------
IOstream &
COstream::operator<<(EStreamManipulator stream_manipulator)
{
	m_stream_manipulator = stream_manipulator;
	return *this;
}

//---------------------------------------------------------------------------
//	@function:
//		COstream::operator<<
//
//	@doc:
//		Return the stream modifier
//
//---------------------------------------------------------------------------
IOstream::EStreamManipulator
COstream::GetStreamManipulator() const
{
	return m_stream_manipulator;
}


//---------------------------------------------------------------------------
//	@function:
//		COstream::operator<<
//
//	@doc:
//		To support << std::endl
//
//---------------------------------------------------------------------------

IOstream &
COstream::operator<<(WOSTREAM &(*func_ptr)(WOSTREAM &) __attribute__((unused)))
{
// This extra safety check is not portable accross different C++
// standard-library implementations that may implement std::endl as a template.
// It is enabled only for GNU libstdc++, where it is known to work.
#if defined(GPOS_DEBUG) && defined(__GLIBCXX__)
	using TManip = WOSTREAM &(*) (WOSTREAM &);
	TManip tmf = func_ptr;
	GPOS_ASSERT(tmf == static_cast<TManip>(std::endl) &&
				"Only std::endl allowed");
#endif
	(*this) << '\n';
	return *this;
}

// EOF

相关信息

greenplumn 源码目录

相关文章

greenplumn CFileDescriptor 源码

greenplumn CFileReader 源码

greenplumn CFileWriter 源码

greenplumn COstreamBasic 源码

greenplumn COstreamStdString 源码

greenplumn COstreamString 源码

greenplumn ioutils 源码