XOutputStream.cpp

Go to the documentation of this file.

#include <dcl/Config.h>
 
#ifdef __WINNT__
#include <windows.h>        // dcl/Thread.h
#endif
 
#include <dcl/XOutputStream.h>
 
#if __DCL_HAVE_THIS_FILE__
#undef __THIS_FILE__
static const char_t __THIS_FILE__[] = __T("dcl/XOutputStream.cpp");
#endif
 
__DCL_BEGIN_NAMESPACE
 
IMPLEMENT_CLASSINFO(XOutputStream, OutputStream)
 
String XOutputStream::toString() const
{
    StringBuilder r = className() + __T("(");
    if (__output)
        r += __output->toString();
    else
        r += __T("null");
    r += __T(")");
 
    return r;
}
 
XOutputStream::XOutputStream(OutputStream* __destroy__ _pOutput)
{
    __output = _pOutput;
}
 
OutputStream* XOutputStream::setOutputStream(OutputStream* __destroy__ _pOutput)
{
    OutputStream* r = __output;
    __output = _pOutput;
    return r;
}
 
XOutputStream::~XOutputStream()
{
    try {
        close();
    }
    catch (Exception* cause) {
        __DCL_TRACE1(__T("%ls\n"), cause->toString().data());
        cause->destroy();
    }
}
 
void XOutputStream::close()
    __DCL_THROWS1(IOException*)
{
    if (__output) {
        Thread::SingleLockMutex lockAndUnlock(__lock);
        Exception* e = NULL;
        OutputStream* output = __output;
        __output = NULL;
        try {
            output->close();
        }
        catch (Exception* cause) {
            e = cause;
        }
        output->destroy();
 
        if (e) {
            throw e;
        }
    }
}
 
void XOutputStream::flush()
    __DCL_THROWS1(IOException*)
{
    if (__output) {
        Thread::SingleLockMutex lockAndUnlock(__lock);
        __output->flush();
    }
}
 
OutputStream& XOutputStream::write(const void* _buf, size_t _nbytes)
    __DCL_THROWS1(IOException*)
{
    if (__output) {
        Thread::SingleLockMutex lockAndUnlock(__lock);
        __output->write(_buf, _nbytes);
    }
    return *this;
}
 
int XOutputStream::vprintf(const char* _format, va_list _arglist)
    __DCL_THROWS1(IOException*)
{
    int n = 0;
    if (__output) {
        Thread::SingleLockMutex lockAndUnlock(__lock);
        n = __output->vprintf(_format, _arglist);
    }
    return n;
}
 
__DCL_END_NAMESPACE