xref: /trunk/main/binaryurp/source/reader.hxx (revision cdf0e10c)
1 /*************************************************************************
2 *
3 * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER.
4 *
5 * Copyright 2000, 2011 Oracle and/or its affiliates.
6 *
7 * OpenOffice.org - a multi-platform office productivity suite
8 *
9 * This file is part of OpenOffice.org.
10 *
11 * OpenOffice.org is free software: you can redistribute it and/or modify
12 * it under the terms of the GNU Lesser General Public License version 3
13 * only, as published by the Free Software Foundation.
14 *
15 * OpenOffice.org is distributed in the hope that it will be useful,
16 * but WITHOUT ANY WARRANTY; without even the implied warranty of
17 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
18 * GNU Lesser General Public License version 3 for more details
19 * (a copy is included in the LICENSE file that accompanied this code).
20 *
21 * You should have received a copy of the GNU Lesser General Public License
22 * version 3 along with OpenOffice.org.  If not, see
23 * <http://www.openoffice.org/license.html>
24 * for a copy of the LGPLv3 License.
25 *
26 ************************************************************************/
27 
28 #ifndef INCLUDED_BINARYURP_SOURCE_READER_HXX
29 #define INCLUDED_BINARYURP_SOURCE_READER_HXX
30 
31 #include "sal/config.h"
32 
33 #include <cstddef>
34 
35 #include "boost/noncopyable.hpp"
36 #include "osl/thread.hxx"
37 #include "rtl/byteseq.hxx"
38 #include "rtl/ref.hxx"
39 #include "rtl/ustring.hxx"
40 #include "sal/types.h"
41 #include "salhelper/simplereferenceobject.hxx"
42 #include "typelib/typedescription.hxx"
43 
44 #include "readerstate.hxx"
45 
46 namespace binaryurp {
47     class BinaryAny;
48     class Bridge;
49     class Unmarshal;
50 }
51 
52 namespace binaryurp {
53 
54 class Reader:
55     public osl::Thread, public salhelper::SimpleReferenceObject,
56     private boost::noncopyable
57 {
58 public:
59     static void * operator new(std::size_t size)
60     { return Thread::operator new(size); }
61 
62     static void operator delete(void * pointer)
63     { Thread::operator delete(pointer); }
64 
65     explicit Reader(rtl::Reference< Bridge > const & bridge);
66 
67 private:
68     virtual ~Reader();
69 
70     virtual void SAL_CALL run();
71 
72     virtual void SAL_CALL onTerminated();
73 
74     void readMessage(Unmarshal & unmarshal);
75 
76     void readReplyMessage(Unmarshal & unmarshal, sal_uInt8 flags1);
77 
78     rtl::ByteSequence getTid(Unmarshal & unmarshal, bool newTid) const;
79 
80     rtl::Reference< Bridge > bridge_;
81     com::sun::star::uno::TypeDescription lastType_;
82     rtl::OUString lastOid_;
83     rtl::ByteSequence lastTid_;
84     ReaderState state_;
85 };
86 
87 }
88 
89 #endif
90