InputStreamReader Class Reference

#include <InputStreamReader.h>

Inheritance diagram for InputStreamReader:

Public Member Functions
virtual String	toString () const
	InputStreamReader (InputStream &__noclose__ _input, CharsetDecoder &_decoder)
	InputStreamReader (InputStream *__destroy__ _pInput, CharsetDecoder *__destroy__ _pDecoder=NULL) __DCL_THROWS1(IOException *)
virtual	~InputStreamReader ()
virtual void	close () __DCL_THROWS1(IOException *)
virtual size_t	read (wchar_t *_buf, size_t _n) __DCL_THROWS1(IOException *)
Public Member Functions inherited from Object
virtual void	destroy ()
String	className () const
bool	isInstanceOf (const std::type_info &typeinfo) const
virtual const std::type_info &	typeInfo () const

Protected Attributes
InputStream *	__input
CharsetDecoder *	__decoder
bool	__closeDestroy

Additional Inherited Members
Protected Member Functions inherited from Object
virtual	~Object ()
	Object ()

Detailed Description

Definition at line 25 of file InputStreamReader.h.

Constructor & Destructor Documentation

InputStreamReader() [1/2]

InputStreamReader::InputStreamReader	(	InputStream &__noclose__	_input,
		CharsetDecoder &	_decoder )

참조된 스트림과 디코더로 객체를 구성한다. _input과 _decoder는 객체의 생명주기동안 유효해야 하며, _input은 close()에서 close하지 않는다.

Parameters

_input	A InputStream
_decoder	A CharsetDecoder

Definition at line 46 of file InputStreamReader.cpp.

{
    __input = &_input;
    __decoder = &_decoder;
    __closeDestroy = false;
    __extraBytes = 0;
}

InputStreamReader() [2/2]

InputStreamReader::InputStreamReader	(	InputStream *__destroy__	_pInput,
		CharsetDecoder *__destroy__	_pDecoder = NULL )

넘겨받은 스트림과 디코더로 객체를 구성한다. close()에서 _pInput의 close()가 호출되고 pInput과 _pDecoder는 파괴된다.

Parameters

_pInput	A InputStream
_pDecoder	NULL이면 처음 읽는 2~4바이트를 사용하여 BOM을 검사 한 후, 확인이 안되면 LocaleEncoder를 사용한다.

Definition at line 57 of file InputStreamReader.cpp.

{
    __DCL_ASSERT_PARAM(_pInput != NULL);
 
    __input = _pInput;
    __decoder = _pDecoder;
    __closeDestroy = true;
    __extraBytes = 0;
}

~InputStreamReader()

InputStreamReader::~InputStreamReader ( )

virtual

객체의 파괴를 수행한다. close하지 않았으면 close()하며 예외가 발생하면 무시한다.

Definition at line 70 of file InputStreamReader.cpp.

{
    if (__input) {
        try {
            close();
        }
        catch (Exception* e) {
            __DCL_TRACE1(L"%ls\n", e->toString().data());
            e->destroy();
        }
    }
}

Member Function Documentation

close()

void InputStreamReader::close ( )

virtual

객체를 닫는다. 넘겨받은 InputStream과 CharsetDecoder는 파괴된다.

Definition at line 83 of file InputStreamReader.cpp.

{
    __DCL_ASSERT_HANDLE(__input != NULL);
 
    Exception* e = NULL;
    InputStream* input = __input;
    CharsetDecoder* decoder = __decoder;
    __input = NULL;
    __decoder = NULL;
    __extraBytes = 0;
 
    if (__closeDestroy) {
        if (decoder)
            decoder->destroy();
 
        try {
            input->close();
        }
        catch (Exception* cause) {
            e = cause;
        }
        input->destroy();
    }
 
    if (e)
        throw e;
}

read()

size_t InputStreamReader::read ( wchar_t * _buf, size_t _n )

virtual

텍스트를 읽는다.

Parameters

_buf	버퍼
_n	_buf의 길이, _buf가 가리키는 버퍼의 wchar_t의 개수

Implements Reader.

Definition at line 112 of file InputStreamReader.cpp.

{
    __DCL_ASSERT_HANDLE(__input != NULL);
    __DCL_ASSERT_PARAM(_buf != NULL);
 
    if (!_n)
        return 0;
 
    if (!__decoder) {
        char bom[4];
        if (__input->available() >= sizeof(bom)) {
            size_t readCount = __input->read(bom, sizeof(bom));
            if ((readCount == 4) && IS_UTF32(bom))
                __decoder = new UTF32Decoder();
            else if ((readCount >= 3) && IS_UTF8(bom))
                __decoder = new UTF8Decoder();
            else if ((readCount >= 2) && IS_UTF16(bom))
                __decoder = new UTF16Decoder();
 
            memcpy(__extra, bom, readCount);
            __extraBytes = readCount;
        }
 
        if (!__decoder)
            __decoder = new LocaleDecoder();
    }
 
    wchar_t* outCur = _buf;
    wchar_t* outEnd = _buf + _n;
 
#define __BUFFER_SIZE__     1024
    byte_t inBuf[__BUFFER_SIZE__ + __EXTRA_MAX];
    size_t extraCount = __extraBytes;
 
    // Non-Block이 가능한 양 만큼
    size_t availCount = __input->available();
    memcpy(inBuf, __extra, extraCount);
 
    size_t outCount;
    while ((outCount = outEnd - outCur) && availCount) {
        size_t readCount = __MIN(__MAX(outCount, __EXTRA_MAX), availCount, __BUFFER_SIZE__);
        readCount = __input->read(inBuf + extraCount, readCount);
        availCount -= readCount;
 
        size_t inCount = readCount + extraCount;
        if (!inCount)
            break;
 
        size_t inCountSave = inCount;
        int r = __decoder->decode(inBuf, inCount, outCur, outCount);
        /*__DCL_TRACE4(__T("%ls read[%d], extra[%d], out[%d]\n"),
                __decoder->className(), readCount, extraCount, outCount);*/
        extraCount = inCountSave - inCount;
        switch (r) {
            case CS_SOURCE_FEW: {
                __DCL_ASSERT(extraCount <= __EXTRA_MAX);
                if (inCount > 0)
                    memmove(inBuf, inBuf + inCount, extraCount);
                break;
            }
            case CS_NOERROR: {
                __DCL_ASSERT(extraCount == 0);
                break;
            }
            default: {
                throw(new IOException(toString(), new CharsetConvertException(r)));
            }
        }
        outCur += outCount;
    }
 
    // 이곳에서 Block 될 수 있다.
    if ((outCount = outEnd - outCur) > 0) {
        size_t readCount = __MIN(__MAX(outCount, __EXTRA_MAX), __BUFFER_SIZE__);
        readCount = __input->read(inBuf + extraCount, readCount);
        size_t inCount = readCount + extraCount;
 
        if (inCount) {
            size_t inCountSave = inCount;
            int r = __decoder->decode(inBuf, inCount, outCur, outCount);
            /*__DCL_TRACE4(__T("%ls read[%d], extra[%d], out[%d]\n"),
                    __decoder->className(), readCount, extraCount, outCount);*/
            extraCount = inCountSave - inCount;
            switch (r) {
                case CS_SOURCE_FEW: {
                    __DCL_ASSERT(extraCount <= __EXTRA_MAX);
                    if (inCount > 0)
                        memmove(inBuf, inBuf + inCount, extraCount);
                    break;
                }
                case CS_NOERROR: {
                    __DCL_ASSERT(extraCount == 0);
                    break;
                }
                default: {
                    throw(new IOException(className(), new CharsetConvertException(r)));
                }
            }
            outCur += outCount;
        }
    }
 
    memcpy(__extra, inBuf, extraCount);
    __extraBytes = extraCount;
 
    return outCur - _buf;
}

toString()

virtual String InputStreamReader::toString ( ) const

virtual

파생클래스를 위한 생성자이다. 객체의 구성에 대하여 간략한 요약을 리턴한다.

Reimplemented from Object.

Member Data Documentation

__closeDestroy

bool InputStreamReader::__closeDestroy

protected

Definition at line 95 of file InputStreamReader.h.

__decoder

CharsetDecoder* InputStreamReader::__decoder

protected

Definition at line 94 of file InputStreamReader.h.

__input

InputStream* InputStreamReader::__input

protected

Definition at line 93 of file InputStreamReader.h.

---

The documentation for this class was generated from the following files:

• InputStreamReader.h
• InputStreamReader.cpp