/* -*- 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 . */ #pragma once #include #include #include #include #include #include #include #include #include #include #include #include "binaryany.hxx" #include "marshal.hxx" #include "writerstate.hxx" namespace binaryurp { class Bridge; } namespace binaryurp { class Writer: public salhelper::Thread { public: explicit Writer(rtl::Reference< Bridge > const & bridge); // Only called from Bridge::reader_ thread, and only before Bridge::writer_ // thread is unblocked: void sendDirectRequest( rtl::ByteSequence const & tid, OUString const & oid, com::sun::star::uno::TypeDescription const & type, com::sun::star::uno::TypeDescription const & member, std::vector< BinaryAny > const & inArguments); // Only called from Bridge::reader_ thread, and only before Bridge::writer_ // thread is unblocked: void sendDirectReply( rtl::ByteSequence const & tid, com::sun::star::uno::TypeDescription const & member, bool exception, BinaryAny const & returnValue, std::vector< BinaryAny > const & outArguments); void queueRequest( rtl::ByteSequence const & tid, OUString const & oid, com::sun::star::uno::TypeDescription const & type, com::sun::star::uno::TypeDescription const & member, std::vector< BinaryAny >&& inArguments); void queueReply( rtl::ByteSequence const & tid, com::sun::star::uno::TypeDescription const & member, bool setter, bool exception, BinaryAny const & returnValue, std::vector< BinaryAny >&& outArguments, bool setCurrentContextMode); void unblock(); void stop(); private: virtual ~Writer() override; virtual void execute() override; void sendRequest( rtl::ByteSequence const & tid, OUString const & oid, com::sun::star::uno::TypeDescription const & type, com::sun::star::uno::TypeDescription const & member, std::vector< BinaryAny > const & inArguments, bool currentContextMode, com::sun::star::uno::UnoInterfaceReference const & currentContext); void sendReply( rtl::ByteSequence const & tid, com::sun::star::uno::TypeDescription const & member, bool setter, bool exception, BinaryAny const & returnValue, std::vector< BinaryAny > const & outArguments); void sendMessage(std::vector< unsigned char > const & buffer); struct Item { Item(); // Request: Item( rtl::ByteSequence theTid, OUString theOid, com::sun::star::uno::TypeDescription theType, com::sun::star::uno::TypeDescription theMember, std::vector< BinaryAny >&& inArguments, com::sun::star::uno::UnoInterfaceReference theCurrentContext); // Reply: Item( rtl::ByteSequence theTid, com::sun::star::uno::TypeDescription theMember, bool theSetter, bool theException, BinaryAny theReturnValue, std::vector< BinaryAny >&& outArguments, bool theSetCurrentContextMode); rtl::ByteSequence tid; // request + reply OUString oid; // request com::sun::star::uno::TypeDescription type; // request com::sun::star::uno::TypeDescription member; // request + reply com::sun::star::uno::UnoInterfaceReference currentContext; // request BinaryAny returnValue; // reply std::vector< BinaryAny > arguments; // request: inArguments; reply: outArguments bool request; bool setter; // reply bool exception; // reply bool setCurrentContextMode; // reply }; rtl::Reference< Bridge > bridge_; WriterState state_; Marshal marshal_; com::sun::star::uno::TypeDescription lastType_; OUString lastOid_; rtl::ByteSequence lastTid_; osl::Condition unblocked_; osl::Condition items_; std::mutex mutex_; std::deque< Item > queue_; bool stop_; }; } /* vim:set shiftwidth=4 softtabstop=4 expandtab: */ ov-4.4 LibreOffice 核心代码仓库文档基金会

path: root/cppuhelper/source/access_control.cxx

Age	Commit message (Expand)	Author
2024-04-27	loplugin:ostr in cppu,cppuhelper	Noel Grandin
2024-03-29	tdf#146619 Drop unused 'using namespace' in: cppu/ cppuhelper/	Gabor Kelemen
2023-03-20	cppuhelper : use constexpr OUStringLiteral instead of a function	Arnaud VERSINI
2019-07-31	Improved loplugin:stringconstant (now that GCC 7 supports it): cppuhelper	Stephan Bergmann
2018-10-24	remove more rtl::OUString and OString prefixes	Noel Grandin
2018-10-09	Extend loplugin:redundantinline to catch inline functions w/o external linkage	Stephan Bergmann
2018-09-10	tdf#42949 Fix IWYU warnings in include/cppuhelper/*	Gabor Kelemen
2018-01-19	SAL_W32 is just an alias for _WIN32	Stephan Bergmann