summaryrefslogtreecommitdiffstats
path: root/unotools/source/ucbhelper/ucblockbytes.hxx
diff options
context:
space:
mode:
authorDaniel Baumann <daniel.baumann@progress-linux.org>2024-04-27 16:51:28 +0000
committerDaniel Baumann <daniel.baumann@progress-linux.org>2024-04-27 16:51:28 +0000
commit940b4d1848e8c70ab7642901a68594e8016caffc (patch)
treeeb72f344ee6c3d9b80a7ecc079ea79e9fba8676d /unotools/source/ucbhelper/ucblockbytes.hxx
parentInitial commit. (diff)
downloadlibreoffice-upstream.tar.xz
libreoffice-upstream.zip
Adding upstream version 1:7.0.4.upstream/1%7.0.4upstream
Signed-off-by: Daniel Baumann <daniel.baumann@progress-linux.org>
Diffstat (limited to 'unotools/source/ucbhelper/ucblockbytes.hxx')
-rw-r--r--unotools/source/ucbhelper/ucblockbytes.hxx142
1 files changed, 142 insertions, 0 deletions
diff --git a/unotools/source/ucbhelper/ucblockbytes.hxx b/unotools/source/ucbhelper/ucblockbytes.hxx
new file mode 100644
index 000000000..df1e237e9
--- /dev/null
+++ b/unotools/source/ucbhelper/ucblockbytes.hxx
@@ -0,0 +1,142 @@
+/* -*- Mode: C++; tab-width: 4; indent-tabs-mode: nil; c-basic-offset: 4 -*- */
+/*
+ * This file is part of the LibreOffice project.
+ *
+ * This Source Code Form is subject to the terms of the Mozilla Public
+ * License, v. 2.0. If a copy of the MPL was not distributed with this
+ * file, You can obtain one at http://mozilla.org/MPL/2.0/.
+ *
+ * This file incorporates work covered by the following license notice:
+ *
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed
+ * with this work for additional information regarding copyright
+ * ownership. The ASF licenses this file to you under the Apache
+ * License, Version 2.0 (the "License"); you may not use this file
+ * except in compliance with the License. You may obtain a copy of
+ * the License at http://www.apache.org/licenses/LICENSE-2.0 .
+ */
+#ifndef INCLUDED_UNOTOOLS_UCBLOCKBYTES_HXX
+#define INCLUDED_UNOTOOLS_UCBLOCKBYTES_HXX
+
+#include <com/sun/star/uno/Reference.hxx>
+
+#include <osl/conditn.hxx>
+#include <osl/mutex.hxx>
+#include <tools/stream.hxx>
+#include <vcl/errcode.hxx>
+
+namespace com
+{
+ namespace sun
+ {
+ namespace star
+ {
+ namespace task
+ {
+ class XInteractionHandler;
+ }
+ namespace io
+ {
+ class XStream;
+ class XInputStream;
+ class XOutputStream;
+ class XSeekable;
+ }
+ namespace ucb
+ {
+ class XContent;
+ }
+ namespace beans
+ {
+ struct PropertyValue;
+ }
+ }
+ }
+}
+
+namespace utl
+{
+class UcbLockBytes;
+typedef tools::SvRef<UcbLockBytes> UcbLockBytesRef;
+
+class UcbLockBytes : public virtual SvLockBytes
+{
+ osl::Condition m_aInitialized;
+ osl::Condition m_aTerminated;
+ osl::Mutex m_aMutex;
+
+ css::uno::Reference < css::io::XInputStream > m_xInputStream;
+ css::uno::Reference < css::io::XOutputStream > m_xOutputStream;
+ css::uno::Reference < css::io::XSeekable > m_xSeekable;
+
+ ErrCode m_nError;
+
+ bool m_bTerminated;
+ bool m_bDontClose;
+ bool m_bStreamValid;
+
+ UcbLockBytes();
+protected:
+ virtual ~UcbLockBytes() override;
+
+public:
+ // properties: Referer, PostMimeType
+ static UcbLockBytesRef CreateLockBytes( const css::uno::Reference < css::ucb::XContent >& xContent,
+ const css::uno::Sequence < css::beans::PropertyValue >& rProps,
+ StreamMode eMode,
+ const css::uno::Reference < css::task::XInteractionHandler >& xInter );
+
+ static UcbLockBytesRef CreateInputLockBytes( const css::uno::Reference < css::io::XInputStream >& xContent );
+ static UcbLockBytesRef CreateLockBytes( const css::uno::Reference < css::io::XStream >& xContent );
+
+ // SvLockBytes
+ virtual ErrCode ReadAt(sal_uInt64 nPos, void *pBuffer, std::size_t nCount, std::size_t *pRead) const override;
+ virtual ErrCode WriteAt(sal_uInt64, const void*, std::size_t, std::size_t *pWritten) override;
+ virtual ErrCode Flush() const override;
+ virtual ErrCode SetSize(sal_uInt64) override;
+ virtual ErrCode Stat ( SvLockBytesStat *pStat ) const override;
+
+ void SetError( ErrCode nError )
+ { m_nError = nError; }
+
+ ErrCode const & GetError() const
+ { return m_nError; }
+
+ // calling this method delegates the responsibility to call closeinput to the caller!
+ css::uno::Reference < css::io::XInputStream > getInputStream();
+
+ bool setInputStream_Impl( const css::uno::Reference < css::io::XInputStream > &rxInputStream,
+ bool bSetXSeekable = true );
+ void setStream_Impl( const css::uno::Reference < css::io::XStream > &rxStream );
+ void terminate_Impl();
+
+ css::uno::Reference < css::io::XInputStream > getInputStream_Impl() const
+ {
+ osl::MutexGuard aGuard( const_cast< UcbLockBytes* >(this)->m_aMutex );
+ return m_xInputStream;
+ }
+
+ css::uno::Reference < css::io::XOutputStream > getOutputStream_Impl() const
+ {
+ osl::MutexGuard aGuard( const_cast< UcbLockBytes* >(this)->m_aMutex );
+ return m_xOutputStream;
+ }
+
+ css::uno::Reference < css::io::XSeekable > getSeekable_Impl() const
+ {
+ osl::MutexGuard aGuard( const_cast< UcbLockBytes* >(this)->m_aMutex );
+ return m_xSeekable;
+ }
+
+ void setDontClose_Impl()
+ { m_bDontClose = true; }
+
+ void SetStreamValid_Impl();
+};
+
+}
+
+#endif
+
+/* vim:set shiftwidth=4 softtabstop=4 expandtab: */