diff options
Diffstat (limited to 'binfilter/bf_so3/source/persist/transbnd.cxx')
| -rw-r--r-- | binfilter/bf_so3/source/persist/transbnd.cxx | 434 |
1 files changed, 434 insertions, 0 deletions
diff --git a/binfilter/bf_so3/source/persist/transbnd.cxx b/binfilter/bf_so3/source/persist/transbnd.cxx new file mode 100644 index 000000000000..1e25ab3c5a3a --- /dev/null +++ b/binfilter/bf_so3/source/persist/transbnd.cxx @@ -0,0 +1,434 @@ +/* -*- Mode: C++; tab-width: 4; indent-tabs-mode: nil; c-basic-offset: 4 -*- */ +/************************************************************************* + * + * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER. + * + * Copyright 2000, 2010 Oracle and/or its affiliates. + * + * OpenOffice.org - a multi-platform office productivity suite + * + * This file is part of OpenOffice.org. + * + * OpenOffice.org is free software: you can redistribute it and/or modify + * it under the terms of the GNU Lesser General Public License version 3 + * only, as published by the Free Software Foundation. + * + * OpenOffice.org is distributed in the hope that it will be useful, + * but WITHOUT ANY WARRANTY; without even the implied warranty of + * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the + * GNU Lesser General Public License version 3 for more details + * (a copy is included in the LICENSE file that accompanied this code). + * + * You should have received a copy of the GNU Lesser General Public License + * version 3 along with OpenOffice.org. If not, see + * <http://www.openoffice.org/license.html> + * for a copy of the LGPLv3 License. + * + ************************************************************************/ + +#define _TRANSBND_CXX "$Revision: 1.5 $" + +#include <com/sun/star/beans/PropertyValue.hpp> + +#include <com/sun/star/ucb/XContent.hpp> +#include <com/sun/star/ucb/XCommandProcessor.hpp> +#include <com/sun/star/container/XNameAccess.hpp> + +#ifndef _RTL_USTRING_ +#include <rtl/ustring.h> +#endif + +#include <osl/mutex.hxx> + +#include <tools/solar.h> +#include <tools/debug.hxx> +#include <tools/datetime.hxx> +#include <tools/errcode.hxx> +#include <tools/link.hxx> +#include <tools/ref.hxx> +#include <tools/stream.hxx> +#include <tools/string.hxx> +#include <tools/urlobj.hxx> + +#include <vcl/svapp.hxx> + +#include <bf_svtools/cancel.hxx> +#include <bf_svtools/inethist.hxx> +#include <bf_svtools/svarray.hxx> + +#include <bf_so3/binding.hxx> +#include <binddata.hxx> +#include <bf_so3/transbnd.hxx> +#include <bf_so3/transprt.hxx> +#include <transuno.hxx> +#include <bf_so3/so2defs.hxx> + +#include <algorithm> + +using namespace com::sun::star::sdbc; +using namespace com::sun::star::beans; +using namespace com::sun::star::ucb; +using namespace com::sun::star::uno; +using namespace com::sun::star::container; + +namespace binfilter { + + +/*======================================================================== + * + * SvBinding implementation. + * + *======================================================================*/ +/* + * SvBinding. + */ +/* + * ~SvBinding. + */ +SvBinding::~SvBinding (void) +{ + delete m_pTransport; + delete m_pCancelable; +} + +/* + * OnStart. + */ +void SvBinding::OnStart (void) +{ + SvBindingRef xThis (this); + if (m_xCallback.Is()) + { + SolarMutexGuard aAppGuard; + if (m_xCallback.Is()) + m_xCallback->InitStartTime(); + } +} + +/* + * OnError. + */ +void SvBinding::OnError (ErrCode eErrCode) +{ + SvBindingRef xThis (this); + m_eErrCode = eErrCode; + + if (m_xCallback.Is()) + { + SolarMutexGuard aAppGuard; + if (m_xCallback.Is()) + m_xCallback->OnStopBinding (m_eErrCode, String()); + } + + DELETEZ (m_pTransport); + DELETEZ (m_pCancelable); +} + +/* + * OnMimeAvailable. + */ +void SvBinding::OnMimeAvailable (const String &rMime) +{ + m_aMime = rMime; + m_bMimeAvail = TRUE; +} + +/* + * OnExpiresAvailable. + */ +void SvBinding::OnExpiresAvailable (const DateTime &rExpires) +{ + m_aExpires = rExpires; +} + +/* + * OnHeaderAvailable. + */ +void SvBinding::OnHeaderAvailable (const String &rName, const String &rValue) +{ + if (!m_xHeadIter.Is()) + m_xHeadIter = new SvKeyValueIterator; + + m_xHeadIter->Append (SvKeyValue (rName, rValue)); +} + +/* + * OnDataAvailable. + */ +void SvBinding::OnDataAvailable ( + SvStatusCallbackType eType, ULONG nSize, SvLockBytes *pLockBytes) +{ + SvBindingRef xThis (this); + + if (!m_xLockBytes.Is()) + m_xLockBytes = pLockBytes; + + switch (eType) + { + case SVBSCF_FIRSTDATANOTIFICATION: + case SVBSCF_INTERMEDIATEDATANOTIFICATION: + if (m_bMimeAvail && m_xLockBytes.Is() && nSize) + { + osl::SolarMutex &rAppMutex = Application::GetSolarMutex(); + if (m_xCallback.Is() && rAppMutex.tryToAcquire()) + { + m_xCallback->OnDataAvailable ( + eType, nSize, *m_xLockBytes); + rAppMutex.release(); + } + } + break; + + case SVBSCF_LASTDATANOTIFICATION: + m_bComplete = TRUE; + OnError (ERRCODE_NONE); + break; + + default: // Ignored. + break; + } +} + +/* + * OnProgress. + */ +void SvBinding::OnProgress ( + ULONG nNow, ULONG nEnd, SvBindStatus eStat) +{ + SvBindingRef xThis (this); + if (m_xCallback.Is()) + { + osl::SolarMutex &rAppMutex = Application::GetSolarMutex(); + if (m_xCallback.Is() && rAppMutex.tryToAcquire()) + { + m_xCallback->OnProgress ( + nNow, nEnd, eStat, m_aUrlObj.GetMainURL( INetURLObject::DECODE_TO_IURI )); + rAppMutex.release(); + } + } +} + +/* + * OnRedirect. + */ +void SvBinding::OnRedirect (const String &rUrl) +{ + SvBindingRef xThis (this); + if (m_xCallback.Is()) + { + SolarMutexGuard aAppGuard; + + INetURLHistory::GetOrCreate()->PutUrl (m_aUrlObj); + m_aUrlObj.SetURL (rUrl); + + if (m_xCallback.Is()) + m_xCallback->OnProgress (0, 0, SVBINDSTATUS_REDIRECTING, rUrl); + } +} + +/* + * ShouldUseFtpProxy. + */ +BOOL SvBinding::ShouldUseFtpProxy (const String &rUrl) +{ + return BAPP()->ShouldUseFtpProxy (rUrl); +} + +/* + * ~SvBindStatusCallback. + */ +SvBindStatusCallback::~SvBindStatusCallback (void) +{ +} + +/* + * SetProgressCallback. + */ +Link SvBindStatusCallback::m_aProgressCallback; + +void SvBindStatusCallback::SetProgressCallback (const Link &rLink) +{ + m_aProgressCallback = rLink; +} + +/* + * InitStartTime. + */ +void SvBindStatusCallback::InitStartTime (void) +{ + m_nStartTicks = Time::GetSystemTicks(); +} + +/* + * OnProgress. + */ +void SvBindStatusCallback::OnProgress ( + ULONG nNow, ULONG nMax, SvBindStatus eStat, const String& rStatusText) +{ + ULONG nTicks = std::max((Time::GetSystemTicks() - m_nStartTicks), (ULONG) 1); + + SvProgressArg aArg (rStatusText); + aArg.nProgress = nNow; + aArg.nMax = nMax; + aArg.eStatus = eStat; + aArg.nRate = (float)((nNow * 1000.0) / nTicks); + + m_aProgressCallback.Call (&aArg); +} + +/* + * OnDataAvailable (SvLockBytes). + */ +void SvBindStatusCallback::OnDataAvailable ( + SvStatusCallbackType eType, ULONG, SvLockBytes&) +{ + SvBindStatusCallbackRef xThis (this); + + if (!m_bInAvailableCall) + { + do + { + m_bInAvailableCall = TRUE; + + m_bReloadPending |= + (eType == SVBSCF_RELOADAVAILABLENOTIFICATION); + if (m_bReloadPending) + { + m_bReloadPending = FALSE; + m_aReloadLink.Call (this); + } + + m_bPartPending |= + (eType == SVBSCF_NEWPARTAVAILABLENOTIFICATION); + if (m_bPartPending) + { + m_bPartPending = FALSE; + m_aPartLink.Call (this); + } + + m_bDataPending |= + ((eType == SVBSCF_FIRSTDATANOTIFICATION) || + (eType == SVBSCF_LASTDATANOTIFICATION ) || + (eType == SVBSCF_INTERMEDIATEDATANOTIFICATION)); + if (m_bDataPending) + { + m_bDataPending = FALSE; + m_aDataLink.Call (this); + } + + m_bInAvailableCall = FALSE; + } while (m_bDataPending || m_bPartPending || m_bReloadPending); + } + else + { + switch (eType) + { + case SVBSCF_RELOADAVAILABLENOTIFICATION: + m_bReloadPending = TRUE; + break; + + case SVBSCF_NEWPARTAVAILABLENOTIFICATION: + m_bPartPending = TRUE; + break; + + default: + m_bDataPending = TRUE; + break; + } + } + + if (m_bDonePending) + { + m_bDonePending = FALSE; + m_aDoneLink.Call (this); + } +} + +/* + * OnDataAvailable (SvStream). + */ +void SvBindStatusCallback::OnDataAvailable ( + SvStatusCallbackType eType, ULONG, SvStream&) +{ + SvLockBytes aLB(NULL); + OnDataAvailable (eType, 0, aLB); +} + +/* + * OnStopBinding. + */ +void SvBindStatusCallback::OnStopBinding ( + ErrCode eErrCode, const String &rStatusText) +{ + (void)eErrCode; + (void)rStatusText; + + if (!m_bInAvailableCall) + m_aDoneLink.Call (this); + else + m_bDonePending = TRUE; +} + +/*======================================================================== + * + * SvKeyValueIterator implementation. + * + *======================================================================*/ +SV_DECL_PTRARR_DEL(SvKeyValueList_Impl, SvKeyValue*, 0, 4) +SV_IMPL_PTRARR(SvKeyValueList_Impl, SvKeyValue*); + +/* + * SvKeyValueIterator. + */ +SvKeyValueIterator::SvKeyValueIterator (void) + : m_pList (new SvKeyValueList_Impl), + m_nPos (0) +{ +} + +/* + * ~SvKeyValueIterator. + */ +SvKeyValueIterator::~SvKeyValueIterator (void) +{ + delete m_pList; +} + +/* + * GetFirst. + */ +BOOL SvKeyValueIterator::GetFirst (SvKeyValue &rKeyVal) +{ + m_nPos = m_pList->Count(); + return GetNext (rKeyVal); +} + +/* + * GetNext. + */ +BOOL SvKeyValueIterator::GetNext (SvKeyValue &rKeyVal) +{ + if (m_nPos > 0) + { + rKeyVal = *m_pList->GetObject(--m_nPos); + return TRUE; + } + else + { + // Nothing to do. + return FALSE; + } +} + +/* + * Append. + */ +void SvKeyValueIterator::Append (const SvKeyValue &rKeyVal) +{ + SvKeyValue *pKeyVal = new SvKeyValue (rKeyVal); + m_pList->C40_INSERT(SvKeyValue, pKeyVal, m_pList->Count()); +} + +} + +/* vim:set shiftwidth=4 softtabstop=4 expandtab: */ |