binaryurp/source/writer.hxx

   1 /* -*- Mode: C++; tab-width: 4; indent-tabs-mode: nil; c-basic-offset: 4 -*- */
   2 /*
   3  * This file is part of the LibreOffice project.
   4  *
   5  * This Source Code Form is subject to the terms of the Mozilla Public
   6  * License, v. 2.0. If a copy of the MPL was not distributed with this
   7  * file, You can obtain one at http://mozilla.org/MPL/2.0/.
   8  *
   9  * This file incorporates work covered by the following license notice:
  10  *
  11  *   Licensed to the Apache Software Foundation (ASF) under one or more
  12  *   contributor license agreements. See the NOTICE file distributed
  13  *   with this work for additional information regarding copyright
  14  *   ownership. The ASF licenses this file to you under the Apache
  15  *   License, Version 2.0 (the "License"); you may not use this file
  16  *   except in compliance with the License. You may obtain a copy of
  17  *   the License at http://www.apache.org/licenses/LICENSE-2.0 .
  18  */
  19
  20 #ifndef INCLUDED_BINARYURP_SOURCE_WRITER_HXX
  21 #define INCLUDED_BINARYURP_SOURCE_WRITER_HXX
  22
  23 #include <sal/config.h>
  24
  25 #include <deque>
  26 #include <vector>
  27
  28 #include <osl/conditn.hxx>
  29 #include <osl/mutex.hxx>
  30 #include <rtl/byteseq.hxx>
  31 #include <rtl/ref.hxx>
  32 #include <rtl/ustring.hxx>
  33 #include <salhelper/thread.hxx>
  34 #include <typelib/typedescription.hxx>
  35 #include <uno/dispatcher.hxx>
  36
  37 #include "binaryany.hxx"
  38 #include "marshal.hxx"
  39 #include "writerstate.hxx"
  40
  41 namespace binaryurp { class Bridge; }
  42
  43 namespace binaryurp {
  44
  45 class Writer: public salhelper::Thread
  46 {
  47 public:
  48     explicit Writer(rtl::Reference< Bridge > const & bridge);
  49
  50     // Only called from Bridge::reader_ thread, and only before Bridge::writer_
  51     // thread is unblocked:
  52     void sendDirectRequest(
  53         rtl::ByteSequence const & tid, OUString const & oid,
  54         com::sun::star::uno::TypeDescription const & type,
  55         com::sun::star::uno::TypeDescription const & member,
  56         std::vector< BinaryAny > const & inArguments);
  57
  58     // Only called from Bridge::reader_ thread, and only before Bridge::writer_
  59     // thread is unblocked:
  60     void sendDirectReply(
  61         rtl::ByteSequence const & tid,
  62         com::sun::star::uno::TypeDescription const & member,
  63         bool exception, BinaryAny const & returnValue,
  64         std::vector< BinaryAny > const & outArguments);
  65
  66     void queueRequest(
  67         rtl::ByteSequence const & tid, OUString const & oid,
  68         com::sun::star::uno::TypeDescription const & type,
  69         com::sun::star::uno::TypeDescription const & member,
  70         std::vector< BinaryAny > const & inArguments);
  71
  72     void queueReply(
  73         rtl::ByteSequence const & tid,
  74         com::sun::star::uno::TypeDescription const & member, bool setter,
  75         bool exception, BinaryAny const & returnValue,
  76         std::vector< BinaryAny > const & outArguments,
  77         bool setCurrentContextMode);
  78
  79     void unblock();
  80
  81     void stop();
  82
  83 private:
  84     virtual ~Writer() override;
  85
  86     virtual void execute() override;
  87
  88     void sendRequest(
  89         rtl::ByteSequence const & tid, OUString const & oid,
  90         com::sun::star::uno::TypeDescription const & type,
  91         com::sun::star::uno::TypeDescription const & member,
  92         std::vector< BinaryAny > const & inArguments, bool currentContextMode,
  93         com::sun::star::uno::UnoInterfaceReference const & currentContext);
  94
  95     void sendReply(
  96         rtl::ByteSequence const & tid,
  97         com::sun::star::uno::TypeDescription const & member, bool setter,
  98         bool exception, BinaryAny const & returnValue,
  99         std::vector< BinaryAny > const & outArguments);
 100
 101     void sendMessage(std::vector< unsigned char > const & buffer);
 102
 103     struct Item {
 104         Item();
 105
 106         // Request:
 107         Item(
 108             rtl::ByteSequence const & theTid, OUString const & theOid,
 109             com::sun::star::uno::TypeDescription const & theType,
 110             com::sun::star::uno::TypeDescription const & theMember,
 111             std::vector< BinaryAny > const & inArguments,
 112             com::sun::star::uno::UnoInterfaceReference const &
 113                 theCurrentContext);
 114
 115         // Reply:
 116         Item(
 117             rtl::ByteSequence const & theTid,
 118             com::sun::star::uno::TypeDescription const & theMember,
 119             bool theSetter, bool theException, BinaryAny const & theReturnValue,
 120             std::vector< BinaryAny > const & outArguments,
 121             bool theSetCurrentContextMode);
 122
 123         bool request;
 124
 125         rtl::ByteSequence tid; // request + reply
 126
 127         OUString oid; // request
 128
 129         com::sun::star::uno::TypeDescription type; // request
 130
 131         com::sun::star::uno::TypeDescription member; // request + reply
 132
 133         bool setter; // reply
 134
 135         std::vector< BinaryAny > arguments;
 136             // request: inArguments; reply: outArguments
 137
 138         bool exception; // reply
 139
 140         BinaryAny returnValue; // reply
 141
 142         com::sun::star::uno::UnoInterfaceReference currentContext; // request
 143
 144         bool setCurrentContextMode; // reply
 145     };
 146
 147     rtl::Reference< Bridge > bridge_;
 148     WriterState state_;
 149     Marshal marshal_;
 150     com::sun::star::uno::TypeDescription lastType_;
 151     OUString lastOid_;
 152     rtl::ByteSequence lastTid_;
 153     osl::Condition unblocked_;
 154     osl::Condition items_;
 155
 156     osl::Mutex mutex_;
 157     std::deque< Item > queue_;
 158     bool stop_;
 159 };
 160
 161 }
 162
 163 #endif
 164
 165 /* vim:set shiftwidth=4 softtabstop=4 expandtab: */