HttpStream.cpp

Go to the documentation of this file.

 
#include <dcl/Object.h>
#if __DCL_HAVE_ALLOC_DEBUG
#undef __DCL_ALLOC_LEVEL
#define __DCL_ALLOC_LEVEL   __DCL_ALLOC_INTERNAL
#endif
 
#include <dcl/HttpServlet.h>
#include <dcl/HttpStream.h>
 
#define __DEBUG_THIS    0
#if __DEBUG_THIS
#define __DCL_TRACE1_N  __DCL_TRACE1
#define __DCL_TRACE2_N  __DCL_TRACE2
#define __DCL_TRACE3_N  __DCL_TRACE3
#else
#define __DCL_TRACE1_N(fmt, arg)
#define __DCL_TRACE2_N(fmt, arg1, arg2)
#define __DCL_TRACE3_N(fmt, arg1, arg2, arg3)
#endif
 
#if __DCL_DEBUG
#undef __THIS_FILE__
static const char_t* __THIS_FILE__ = __T("dcl/HttpStream.cpp");
#endif
 
__DCL_BEGIN_NAMESPACE
 
IMPLEMENT_CLASSINFO(HttpInputStream, InputStream)
 
HttpInputStream::HttpInputStream(
            HttpServletContext* _ctx
            )
{
    __DCL_ASSERT(_ctx != NULL);
    __ctx = _ctx;
}
 
size_t HttpInputStream::read(
                void* _buf,
                size_t _n
                ) __DCL_THROWS1(IOException*)
{
    size_t nTotalRead = 0;
    while(nTotalRead < _n) {
        size_t nRead = __ctx->read(
                            (void*)(((byte_t*)_buf) + nTotalRead),
                            _n - nTotalRead
                            );
        if (nRead)
            nTotalRead += nRead;
        else {
            break;
        }
    }
    return nTotalRead;
}
 
IMPLEMENT_CLASSINFO(HttpOutputStream, OutputStream)
 
HttpOutputStream::HttpOutputStream(HttpServletContext* _ctx)
{
    __DCL_ASSERT(_ctx != NULL);
    __ctx = _ctx;
}
 
OutputStream& HttpOutputStream::write(const void* _buf, size_t _n)
            __DCL_THROWS1(IOException*)
{
    __ctx->write(_buf, _n);
    return *this;
}
 
__DCL_END_NAMESPACE