io/source/stm/odata.cxx

   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 #include <string.h>
  21 #include <unordered_map>
  22 #include <vector>
  23
  24 #include <cppuhelper/weak.hxx>
  25 #include <cppuhelper/implbase.hxx>
  26 #include <cppuhelper/supportsservice.hxx>
  27 #include <osl/endian.h>
  28
  29 #include <com/sun/star/io/NotConnectedException.hpp>
  30 #include <com/sun/star/io/XObjectInputStream.hpp>
  31 #include <com/sun/star/io/XObjectOutputStream.hpp>
  32 #include <com/sun/star/io/XActiveDataSource.hpp>
  33 #include <com/sun/star/io/XActiveDataSink.hpp>
  34 #include <com/sun/star/io/XMarkableStream.hpp>
  35 #include <com/sun/star/io/XConnectable.hpp>
  36 #include <com/sun/star/io/UnexpectedEOFException.hpp>
  37 #include <com/sun/star/io/WrongFormatException.hpp>
  38 #include <com/sun/star/lang/XServiceInfo.hpp>
  39 #include <com/sun/star/uno/XComponentContext.hpp>
  40
  41 using namespace ::cppu;
  42 using namespace ::osl;
  43 using namespace ::std;
  44 using namespace ::com::sun::star::io;
  45 using namespace ::com::sun::star::uno;
  46 using namespace ::com::sun::star::lang;
  47
  48 #include <services.hxx>
  49
  50 namespace io_stm {
  51
  52 class ODataInputStream :
  53     public WeakImplHelper <
  54                               XDataInputStream,
  55                               XActiveDataSink,
  56                               XConnectable,
  57                               XServiceInfo
  58                            >
  59 {
  60 public:
  61     ODataInputStream( )
  62         : m_bValidStream( false )
  63         {
  64         }
  65
  66 public: // XInputStream
  67     virtual sal_Int32 SAL_CALL readBytes(Sequence< sal_Int8 >& aData, sal_Int32 nBytesToRead) override;
  68     virtual sal_Int32 SAL_CALL readSomeBytes(Sequence< sal_Int8 >& aData, sal_Int32 nMaxBytesToRead) override;
  69     virtual void SAL_CALL skipBytes(sal_Int32 nBytesToSkip) override;
  70     virtual sal_Int32 SAL_CALL available() override;
  71     virtual void SAL_CALL closeInput() override;
  72
  73 public: // XDataInputStream
  74     virtual sal_Int8 SAL_CALL readBoolean() override;
  75     virtual sal_Int8 SAL_CALL readByte() override;
  76     virtual sal_Unicode SAL_CALL readChar() override;
  77     virtual sal_Int16 SAL_CALL readShort() override;
  78     virtual sal_Int32 SAL_CALL readLong() override;
  79     virtual sal_Int64 SAL_CALL readHyper() override;
  80     virtual float SAL_CALL readFloat() override;
  81     virtual double SAL_CALL readDouble() override;
  82     virtual OUString SAL_CALL readUTF() override;
  83
  84
  85 public: // XActiveDataSink
  86     virtual void SAL_CALL setInputStream(const Reference< XInputStream > & aStream) override;
  87     virtual Reference< XInputStream > SAL_CALL getInputStream() override;
  88
  89 public: // XConnectable
  90     virtual void SAL_CALL setPredecessor(const Reference < XConnectable >& aPredecessor) override;
  91     virtual Reference < XConnectable > SAL_CALL getPredecessor() override;
  92     virtual void SAL_CALL setSuccessor(const Reference < XConnectable >& aSuccessor) override;
  93     virtual Reference < XConnectable > SAL_CALL getSuccessor() override ;
  94
  95
  96 public: // XServiceInfo
  97     OUString                     SAL_CALL getImplementationName() override;
  98     Sequence< OUString >         SAL_CALL getSupportedServiceNames() override;
  99     sal_Bool                        SAL_CALL supportsService(const OUString& ServiceName) override;
 100
 101 protected:
 102
 103     Reference < XConnectable >  m_pred;
 104     Reference < XConnectable >  m_succ;
 105     Reference < XInputStream >  m_input;
 106     bool m_bValidStream;
 107 };
 108
 109 // XInputStream
 110 sal_Int32 ODataInputStream::readBytes(Sequence< sal_Int8 >& aData, sal_Int32 nBytesToRead)
 111 {
 112      if( !m_bValidStream )
 113      {
 114          throw NotConnectedException( );
 115      }
 116      sal_Int32 nRead = m_input->readBytes( aData , nBytesToRead );
 117      return nRead;
 118 }
 119
 120 sal_Int32 ODataInputStream::readSomeBytes(Sequence< sal_Int8 >& aData, sal_Int32 nMaxBytesToRead)
 121 {
 122      if( !m_bValidStream )
 123          throw NotConnectedException( );
 124      sal_Int32 nRead = m_input->readSomeBytes( aData , nMaxBytesToRead );
 125      return nRead;
 126 }
 127 void ODataInputStream::skipBytes(sal_Int32 nBytesToSkip)
 128 {
 129      if( !m_bValidStream )
 130          throw NotConnectedException( );
 131      m_input->skipBytes( nBytesToSkip );
 132 }
 133
 134
 135 sal_Int32 ODataInputStream::available()
 136 {
 137      if( !m_bValidStream )
 138          throw NotConnectedException( );
 139      sal_Int32 nAvail = m_input->available( );
 140      return nAvail;
 141 }
 142
 143 void ODataInputStream::closeInput()
 144 {
 145      if( !m_bValidStream )
 146          throw NotConnectedException( );
 147      m_input->closeInput( );
 148      setInputStream( Reference< XInputStream > () );
 149      setPredecessor( Reference < XConnectable >() );
 150      setSuccessor( Reference < XConnectable >() );
 151      m_bValidStream = false;
 152 }
 153
 154
 155 //== XDataInputStream ===========================================
 156
 157 // XDataInputStream
 158 sal_Int8 ODataInputStream::readBoolean()
 159 {
 160     return readByte();
 161 }
 162
 163 sal_Int8 ODataInputStream::readByte()
 164 {
 165     Sequence<sal_Int8> aTmp(1);
 166     if( 1 != readBytes( aTmp, 1 ) )
 167     {
 168         throw UnexpectedEOFException();
 169     }
 170     return aTmp.getConstArray()[0];
 171 }
 172
 173 sal_Unicode ODataInputStream::readChar()
 174 {
 175     Sequence<sal_Int8> aTmp(2);
 176     if( 2 != readBytes( aTmp, 2 ) )
 177     {
 178         throw UnexpectedEOFException();
 179     }
 180
 181     const sal_uInt8 * pBytes = reinterpret_cast<const sal_uInt8 *>(aTmp.getConstArray());
 182     return (static_cast<sal_Unicode>(pBytes[0]) << 8) + pBytes[1];
 183 }
 184
 185 sal_Int16 ODataInputStream::readShort()
 186 {
 187     Sequence<sal_Int8> aTmp(2);
 188     if( 2 != readBytes( aTmp, 2 ) )
 189     {
 190         throw UnexpectedEOFException();
 191     }
 192
 193     const sal_uInt8 * pBytes = reinterpret_cast<const sal_uInt8 *>(aTmp.getConstArray());
 194     return (static_cast<sal_Int16>(pBytes[0]) << 8) + pBytes[1];
 195 }
 196
 197
 198 sal_Int32 ODataInputStream::readLong()
 199 {
 200     Sequence<sal_Int8> aTmp(4);
 201     if( 4 != readBytes( aTmp, 4 ) )
 202     {
 203         throw UnexpectedEOFException( );
 204     }
 205
 206     const sal_uInt8 * pBytes = reinterpret_cast<const sal_uInt8 *>(aTmp.getConstArray());
 207     return (static_cast<sal_Int32>(pBytes[0]) << 24) + (static_cast<sal_Int32>(pBytes[1]) << 16) + (static_cast<sal_Int32>(pBytes[2]) << 8) + pBytes[3];
 208 }
 209
 210
 211 sal_Int64 ODataInputStream::readHyper()
 212 {
 213     Sequence<sal_Int8> aTmp(8);
 214     if( 8 != readBytes( aTmp, 8 ) )
 215     {
 216         throw UnexpectedEOFException( );
 217     }
 218
 219     const sal_uInt8 * pBytes = reinterpret_cast<const sal_uInt8 *>(aTmp.getConstArray());
 220     return
 221         (static_cast<sal_Int64>(pBytes[0]) << 56) +
 222         (static_cast<sal_Int64>(pBytes[1]) << 48) +
 223         (static_cast<sal_Int64>(pBytes[2]) << 40) +
 224         (static_cast<sal_Int64>(pBytes[3]) << 32) +
 225         (static_cast<sal_Int64>(pBytes[4]) << 24) +
 226         (static_cast<sal_Int64>(pBytes[5]) << 16) +
 227         (static_cast<sal_Int64>(pBytes[6]) << 8) +
 228         pBytes[7];
 229 }
 230
 231 float ODataInputStream::readFloat()
 232 {
 233     union { float f; sal_uInt32 n; } a;
 234     a.n = readLong();
 235     return a.f;
 236 }
 237
 238 double ODataInputStream::readDouble()
 239 {
 240     union { double d; struct { sal_uInt32 n1; sal_uInt32 n2; } ad; } a;
 241 #if defined OSL_LITENDIAN
 242     a.ad.n2 = readLong();
 243     a.ad.n1 = readLong();
 244 #else
 245     a.ad.n1 = readLong();
 246     a.ad.n2 = readLong();
 247 #endif
 248     return a.d;
 249 }
 250
 251 OUString ODataInputStream::readUTF()
 252 {
 253     sal_uInt16              nShortLen = static_cast<sal_uInt16>(readShort());
 254     sal_Int32               nUTFLen;
 255
 256     if( (sal_uInt16(0xffff)) == nShortLen )
 257     {
 258         // is interpreted as a sign, that string is longer than 64k
 259         // incompatible to older XDataInputStream-routines, when strings are exactly 64k
 260         nUTFLen = readLong();
 261     }
 262     else
 263     {
 264         nUTFLen = static_cast<sal_Int32>(nShortLen);
 265     }
 266
 267     Sequence<sal_Unicode>   aBuffer( nUTFLen );
 268     sal_Unicode *           pStr = aBuffer.getArray();
 269
 270     sal_Int32 nCount = 0;
 271     sal_Int32 nStrLen = 0;
 272     while( nCount < nUTFLen )
 273     {
 274         sal_uInt8 c = static_cast<sal_uInt8>(readByte());
 275         sal_uInt8 char2, char3;
 276         switch( c >> 4 )
 277         {
 278             case 0: case 1: case 2: case 3: case 4: case 5: case 6: case 7:
 279                 // 0xxxxxxx
 280                 nCount++;
 281                 pStr[nStrLen++] = c;
 282                 break;
 283
 284             case 12: case 13:
 285                 // 110x xxxx   10xx xxxx
 286                 nCount += 2;
 287                 if( nCount > nUTFLen )
 288                 {
 289                     throw WrongFormatException( );
 290                 }
 291
 292                 char2 = static_cast<sal_uInt8>(readByte());
 293                 if( (char2 & 0xC0) != 0x80 )
 294                 {
 295                     throw WrongFormatException( );
 296                 }
 297
 298                 pStr[nStrLen++] = (sal_Unicode(c & 0x1F) << 6) | (char2 & 0x3F);
 299                 break;
 300
 301             case 14:
 302             // 1110 xxxx  10xx xxxx  10xx xxxx
 303                 nCount += 3;
 304                 if( nCount > nUTFLen )
 305                 {
 306                     throw WrongFormatException( );
 307                 }
 308
 309                 char2 = static_cast<sal_uInt8>(readByte());
 310                 char3 = static_cast<sal_uInt8>(readByte());
 311
 312                 if( ((char2 & 0xC0) != 0x80) || ((char3 & 0xC0) != 0x80) ) {
 313                     throw WrongFormatException( );
 314                 }
 315                 pStr[nStrLen++] = (sal_Unicode(c & 0x0F) << 12) |
 316                                 (sal_Unicode(char2 & 0x3F) << 6) |
 317                                 (char3 & 0x3F);
 318                 break;
 319
 320             default:
 321                 // 10xx xxxx,  1111 xxxx
 322                 throw WrongFormatException();
 323                 //throw new UTFDataFormatException();
 324         }
 325     }
 326     return OUString( pStr, nStrLen );
 327 }
 328
 329
 330 // XActiveDataSource
 331 void ODataInputStream::setInputStream(const Reference< XInputStream > & aStream)
 332 {
 333
 334     if( m_input != aStream ) {
 335         m_input = aStream;
 336
 337         Reference < XConnectable > pred( m_input , UNO_QUERY );
 338         setPredecessor( pred );
 339     }
 340
 341     m_bValidStream = m_input.is();
 342 }
 343
 344 Reference< XInputStream > ODataInputStream::getInputStream()
 345 {
 346     return m_input;
 347 }
 348
 349
 350 // XDataSink
 351 void ODataInputStream::setSuccessor( const Reference < XConnectable > &r )
 352 {
 353      /// if the references match, nothing needs to be done
 354      if( m_succ != r ) {
 355          /// store the reference for later use
 356          m_succ = r;
 357
 358          if( m_succ.is() ) {
 359               /// set this instance as the sink !
 360               m_succ->setPredecessor( Reference< XConnectable > (
 361                   static_cast< XConnectable * >(this) ) );
 362          }
 363      }
 364 }
 365
 366 Reference < XConnectable > ODataInputStream::getSuccessor()
 367 {
 368     return m_succ;
 369 }
 370
 371
 372 // XDataSource
 373 void ODataInputStream::setPredecessor( const Reference < XConnectable > &r )
 374 {
 375     if( r != m_pred ) {
 376         m_pred = r;
 377         if( m_pred.is() ) {
 378             m_pred->setSuccessor( Reference< XConnectable > (
 379                 static_cast< XConnectable * >(this) ) );
 380         }
 381     }
 382 }
 383 Reference < XConnectable > ODataInputStream::getPredecessor()
 384 {
 385     return m_pred;
 386 }
 387
 388 // XServiceInfo
 389 OUString ODataInputStream::getImplementationName()
 390 {
 391     return ODataInputStream_getImplementationName();
 392 }
 393
 394 // XServiceInfo
 395 sal_Bool ODataInputStream::supportsService(const OUString& ServiceName)
 396 {
 397     return cppu::supportsService(this, ServiceName);
 398 }
 399
 400 // XServiceInfo
 401 Sequence< OUString > ODataInputStream::getSupportedServiceNames()
 402 {
 403     return ODataInputStream_getSupportedServiceNames();
 404 }
 405
 406 /***
 407 *
 408 * registration information
 409 *
 410 *
 411 ****/
 412
 413 Reference< XInterface > ODataInputStream_CreateInstance(
 414     SAL_UNUSED_PARAMETER const Reference < XComponentContext > & )
 415 {
 416     ODataInputStream *p = new ODataInputStream;
 417     return Reference< XInterface > ( static_cast<OWeakObject *>(p) );
 418 }
 419
 420 OUString ODataInputStream_getImplementationName()
 421 {
 422     return "com.sun.star.comp.io.stm.DataInputStream";
 423 }
 424
 425 Sequence<OUString> ODataInputStream_getSupportedServiceNames()
 426 {
 427     Sequence<OUString> aRet { "com.sun.star.io.DataInputStream" };
 428     return aRet;
 429 }
 430
 431
 432 class ODataOutputStream :
 433     public WeakImplHelper <
 434              XDataOutputStream,
 435              XActiveDataSource,
 436              XConnectable,
 437               XServiceInfo >
 438 {
 439 public:
 440     ODataOutputStream()
 441         : m_bValidStream( false )
 442         {
 443         }
 444
 445 public: // XOutputStream
 446     virtual void SAL_CALL writeBytes(const Sequence< sal_Int8 >& aData) override;
 447     virtual void SAL_CALL flush() override;
 448     virtual void SAL_CALL closeOutput() override;
 449
 450 public: // XDataOutputStream
 451     virtual void SAL_CALL writeBoolean(sal_Bool Value) override;
 452     virtual void SAL_CALL writeByte(sal_Int8 Value) override;
 453     virtual void SAL_CALL writeChar(sal_Unicode Value) override;
 454     virtual void SAL_CALL writeShort(sal_Int16 Value) override;
 455     virtual void SAL_CALL writeLong(sal_Int32 Value) override;
 456     virtual void SAL_CALL writeHyper(sal_Int64 Value) override;
 457     virtual void SAL_CALL writeFloat(float Value) override;
 458     virtual void SAL_CALL writeDouble(double Value) override;
 459     virtual void SAL_CALL writeUTF(const OUString& Value) override;
 460
 461 public: // XActiveDataSource
 462     virtual void SAL_CALL setOutputStream(const Reference< XOutputStream > & aStream) override;
 463     virtual Reference < XOutputStream > SAL_CALL getOutputStream() override;
 464
 465 public: // XConnectable
 466     virtual void SAL_CALL setPredecessor(const Reference < XConnectable >& aPredecessor) override;
 467     virtual Reference < XConnectable > SAL_CALL getPredecessor() override;
 468     virtual void SAL_CALL setSuccessor(const Reference < XConnectable >& aSuccessor) override;
 469     virtual Reference < XConnectable > SAL_CALL getSuccessor() override;
 470
 471 public: // XServiceInfo
 472     OUString                     SAL_CALL getImplementationName() override;
 473     Sequence< OUString >         SAL_CALL getSupportedServiceNames() override;
 474     sal_Bool                     SAL_CALL supportsService(const OUString& ServiceName) override;
 475
 476 protected:
 477     Reference < XConnectable >  m_succ;
 478     Reference < XConnectable >  m_pred;
 479     Reference<  XOutputStream > m_output;
 480     bool m_bValidStream;
 481 };
 482
 483 // XOutputStream
 484 void ODataOutputStream::writeBytes(const Sequence< sal_Int8 >& aData)
 485 {
 486     if( !m_bValidStream )
 487         throw NotConnectedException( );
 488     m_output->writeBytes( aData );
 489 }
 490
 491 void ODataOutputStream::flush()
 492 {
 493     if( !m_bValidStream )
 494         throw NotConnectedException();
 495     m_output->flush();
 496 }
 497
 498
 499 void ODataOutputStream::closeOutput()
 500 {
 501     if( !m_bValidStream )
 502         throw NotConnectedException();
 503     m_output->closeOutput();
 504     setOutputStream( Reference< XOutputStream > () );
 505     setPredecessor( Reference < XConnectable >() );
 506     setSuccessor( Reference < XConnectable >() );
 507 }
 508
 509 // XDataOutputStream
 510 void ODataOutputStream::writeBoolean(sal_Bool Value)
 511 {
 512     if( Value )
 513     {
 514         writeByte( 1 );
 515     }
 516     else
 517     {
 518         writeByte( 0 );
 519     }
 520 }
 521
 522
 523 void ODataOutputStream::writeByte(sal_Int8 Value)
 524 {
 525     writeBytes( { Value } );
 526 }
 527
 528 void ODataOutputStream::writeChar(sal_Unicode Value)
 529 {
 530     writeBytes( { sal_Int8(Value >> 8),
 531                   sal_Int8(Value) } );
 532 }
 533
 534
 535 void ODataOutputStream::writeShort(sal_Int16 Value)
 536 {
 537     writeBytes( { sal_Int8(Value >> 8),
 538                   sal_Int8(Value) } );
 539 }
 540
 541 void ODataOutputStream::writeLong(sal_Int32 Value)
 542 {
 543     writeBytes( { sal_Int8(Value >> 24),
 544                   sal_Int8(Value >> 16),
 545                   sal_Int8(Value >> 8),
 546                   sal_Int8(Value) } );
 547 }
 548
 549 void ODataOutputStream::writeHyper(sal_Int64 Value)
 550 {
 551     writeBytes( { sal_Int8(Value >> 56),
 552                   sal_Int8(Value >> 48),
 553                   sal_Int8(Value >> 40),
 554                   sal_Int8(Value >> 32),
 555                   sal_Int8(Value >> 24),
 556                   sal_Int8(Value >> 16),
 557                   sal_Int8(Value >> 8),
 558                   sal_Int8(Value) } );
 559 }
 560
 561
 562 void ODataOutputStream::writeFloat(float Value)
 563 {
 564     union { float f; sal_uInt32 n; } a;
 565     a.f = Value;
 566     writeLong( a.n );
 567 }
 568
 569 void ODataOutputStream::writeDouble(double Value)
 570 {
 571     union { double d; struct { sal_uInt32 n1; sal_uInt32 n2; } ad; } a;
 572     a.d = Value;
 573 #if defined OSL_LITENDIAN
 574     writeLong( a.ad.n2 );
 575     writeLong( a.ad.n1 );
 576 #else
 577     writeLong( a.ad.n1 );
 578     writeLong( a.ad.n2 );
 579 #endif
 580 }
 581
 582 void ODataOutputStream::writeUTF(const OUString& Value)
 583 {
 584     sal_Int32 nStrLen = Value.getLength();
 585     const sal_Unicode * pStr = Value.getStr();
 586     sal_Int32 nUTFLen = 0;
 587     sal_Int32 i;
 588
 589     for( i = 0 ; i < nStrLen ; i++ )
 590     {
 591         sal_uInt16 c = pStr[i];
 592         if( (c >= 0x0001) && (c <= 0x007F) )
 593         {
 594             nUTFLen++;
 595         }
 596         else if( c > 0x07FF )
 597         {
 598             nUTFLen += 3;
 599         }
 600         else
 601         {
 602             nUTFLen += 2;
 603         }
 604     }
 605
 606
 607     // compatibility mode for older implementations, where it was not possible
 608     // to write blocks bigger than 64 k. Note that there is a tradeoff. Blocks,
 609     // that are exactly 64k long can not be read by older routines when written
 610     // with these routines and the other way round !!!!!
 611     if( nUTFLen >= 0xFFFF ) {
 612         writeShort( sal_Int16(-1) );
 613         writeLong( nUTFLen );
 614     }
 615     else {
 616         writeShort( static_cast<sal_uInt16>(nUTFLen) );
 617     }
 618     for( i = 0 ; i < nStrLen ; i++ )
 619     {
 620         sal_uInt16 c = pStr[i];
 621         if( (c >= 0x0001) && (c <= 0x007F) )
 622         {
 623             writeByte(sal_Int8(c));
 624         }
 625         else if( c > 0x07FF )
 626         {
 627             writeByte(sal_Int8(0xE0 | ((c >> 12) & 0x0F)));
 628             writeByte(sal_Int8(0x80 | ((c >>  6) & 0x3F)));
 629             writeByte(sal_Int8(0x80 | ((c >>  0) & 0x3F)));
 630         }
 631         else
 632         {
 633             writeByte(sal_Int8(0xC0 | ((c >>  6) & 0x1F)));
 634             writeByte(sal_Int8(0x80 | ((c >>  0) & 0x3F)));
 635         }
 636     }
 637 }
 638
 639 // XActiveDataSource
 640 void ODataOutputStream::setOutputStream(const Reference< XOutputStream > & aStream)
 641 {
 642     if( m_output != aStream ) {
 643         m_output = aStream;
 644         m_bValidStream = m_output.is();
 645
 646         Reference < XConnectable > succ( m_output , UNO_QUERY );
 647         setSuccessor( succ );
 648     }
 649 }
 650
 651 Reference< XOutputStream > ODataOutputStream::getOutputStream()
 652 {
 653     return m_output;
 654 }
 655
 656
 657 // XDataSink
 658 void ODataOutputStream::setSuccessor( const Reference < XConnectable > &r )
 659 {
 660      /// if the references match, nothing needs to be done
 661      if( m_succ != r )
 662      {
 663          /// store the reference for later use
 664          m_succ = r;
 665
 666          if( m_succ.is() )
 667          {
 668               /// set this instance as the sink !
 669               m_succ->setPredecessor( Reference < XConnectable > (
 670                   static_cast< XConnectable * >(this) ));
 671          }
 672      }
 673 }
 674 Reference < XConnectable > ODataOutputStream::getSuccessor()
 675 {
 676     return m_succ;
 677 }
 678
 679
 680 // XDataSource
 681 void ODataOutputStream::setPredecessor( const Reference < XConnectable > &r )
 682 {
 683     if( r != m_pred ) {
 684         m_pred = r;
 685         if( m_pred.is() ) {
 686             m_pred->setSuccessor( Reference< XConnectable > (
 687                 static_cast< XConnectable * >(this) ));
 688         }
 689     }
 690 }
 691 Reference < XConnectable > ODataOutputStream::getPredecessor()
 692 {
 693     return m_pred;
 694 }
 695
 696
 697 // XServiceInfo
 698 OUString ODataOutputStream::getImplementationName()
 699 {
 700     return ODataOutputStream_getImplementationName();
 701 }
 702
 703 // XServiceInfo
 704 sal_Bool ODataOutputStream::supportsService(const OUString& ServiceName)
 705 {
 706     return cppu::supportsService(this, ServiceName);
 707 }
 708
 709 // XServiceInfo
 710 Sequence< OUString > ODataOutputStream::getSupportedServiceNames()
 711 {
 712     return ODataOutputStream_getSupportedServiceNames();
 713 }
 714
 715 Reference< XInterface > ODataOutputStream_CreateInstance(
 716     SAL_UNUSED_PARAMETER const Reference < XComponentContext > & )
 717 {
 718     ODataOutputStream *p = new ODataOutputStream;
 719     Reference< XInterface > xService = *p;
 720     return xService;
 721 }
 722
 723
 724 OUString ODataOutputStream_getImplementationName()
 725 {
 726     return "com.sun.star.comp.io.stm.DataOutputStream";
 727 }
 728
 729 Sequence<OUString> ODataOutputStream_getSupportedServiceNames()
 730 {
 731     Sequence<OUString> aRet { "com.sun.star.io.DataOutputStream" };
 732     return aRet;
 733 }
 734
 735
 736 struct equalObjectContainer_Impl
 737 {
 738     bool operator()(const Reference< XInterface > & s1,
 739                          const Reference< XInterface > & s2) const
 740       {
 741         return s1 == s2;
 742     }
 743 };
 744
 745
 746 struct hashObjectContainer_Impl
 747 {
 748     size_t operator()(const Reference< XInterface > & xRef) const
 749     {
 750         return reinterpret_cast<size_t>(xRef.get());
 751     }
 752 };
 753
 754 typedef std::unordered_map
 755 <
 756     Reference< XInterface >,
 757     sal_Int32,
 758     hashObjectContainer_Impl,
 759     equalObjectContainer_Impl
 760 > ObjectContainer_Impl;
 761
 762 class OObjectOutputStream:
 763     public ImplInheritanceHelper<
 764             ODataOutputStream, /* parent */
 765             XObjectOutputStream, XMarkableStream >
 766 {
 767 public:
 768     OObjectOutputStream()
 769         : m_nMaxId(0) ,
 770           m_bValidMarkable(false)
 771         {
 772         }
 773
 774 public:
 775     // XOutputStream
 776     virtual void SAL_CALL writeBytes(const Sequence< sal_Int8 >& aData) override
 777         { ODataOutputStream::writeBytes( aData ); }
 778
 779     virtual void SAL_CALL flush() override
 780         { ODataOutputStream::flush(); }
 781
 782     virtual void SAL_CALL closeOutput() override
 783         { ODataOutputStream::closeOutput(); }
 784
 785 public:
 786     // XDataOutputStream
 787     virtual void SAL_CALL writeBoolean(sal_Bool Value) override
 788                 { ODataOutputStream::writeBoolean( Value ); }
 789     virtual void SAL_CALL writeByte(sal_Int8 Value) override
 790                 { ODataOutputStream::writeByte( Value ); }
 791     virtual void SAL_CALL writeChar(sal_Unicode Value) override
 792                 { ODataOutputStream::writeChar( Value ); }
 793     virtual void SAL_CALL writeShort(sal_Int16 Value) override
 794                 { ODataOutputStream::writeShort( Value ); }
 795     virtual void SAL_CALL writeLong(sal_Int32 Value) override
 796                 { ODataOutputStream::writeLong( Value ); }
 797     virtual void SAL_CALL writeHyper(sal_Int64 Value) override
 798                 { ODataOutputStream::writeHyper( Value ); }
 799     virtual void SAL_CALL writeFloat(float Value) override
 800                 { ODataOutputStream::writeFloat( Value ); }
 801     virtual void SAL_CALL writeDouble(double Value) override
 802                 { ODataOutputStream::writeDouble( Value ); }
 803     virtual void SAL_CALL writeUTF(const OUString& Value) override
 804                 { ODataOutputStream::writeUTF( Value );}
 805
 806     // XObjectOutputStream
 807         virtual void SAL_CALL writeObject( const Reference< XPersistObject > & r ) override;
 808
 809 public: // XMarkableStream
 810     virtual sal_Int32 SAL_CALL createMark() override;
 811     virtual void SAL_CALL deleteMark(sal_Int32 Mark) override;
 812     virtual void SAL_CALL jumpToMark(sal_Int32 nMark) override;
 813     virtual void SAL_CALL jumpToFurthest() override;
 814     virtual sal_Int32 SAL_CALL offsetToMark(sal_Int32 nMark) override;
 815
 816 public: // XServiceInfo
 817     OUString                   SAL_CALL   getImplementationName() override;
 818     Sequence< OUString >       SAL_CALL   getSupportedServiceNames() override;
 819     sal_Bool                   SAL_CALL   supportsService(const OUString& ServiceName) override;
 820
 821 private:
 822     void connectToMarkable();
 823 private:
 824     ObjectContainer_Impl                m_mapObject;
 825     sal_Int32                           m_nMaxId;
 826     Reference< XMarkableStream >        m_rMarkable;
 827     bool                            m_bValidMarkable;
 828 };
 829
 830 void OObjectOutputStream::writeObject( const Reference< XPersistObject > & xPObj )
 831 {
 832
 833     connectToMarkable();
 834     bool bWriteObj = false;
 835     // create Mark to write length of info
 836     sal_uInt32 nInfoLenMark = m_rMarkable->createMark();
 837
 838     // length of the info data (is later rewritten)
 839     OObjectOutputStream::writeShort( 0 );
 840
 841     // write the object identifier
 842     if( xPObj.is() )
 843     {
 844         Reference< XInterface > rX( xPObj , UNO_QUERY );
 845
 846         ObjectContainer_Impl::const_iterator aIt
 847             = m_mapObject.find( rX );
 848         if( aIt == m_mapObject.end() )
 849         {
 850             // insert new object in hash table
 851             m_mapObject[ rX ] = ++m_nMaxId;
 852             ODataOutputStream::writeLong( m_nMaxId );
 853             ODataOutputStream::writeUTF( xPObj->getServiceName() );
 854             bWriteObj = true;
 855         }
 856         else
 857         {
 858             ODataOutputStream::writeLong( (*aIt).second );
 859             ODataOutputStream::writeUTF( OUString() );
 860         }
 861     }
 862     else
 863     {
 864         ODataOutputStream::writeLong( 0 );
 865         ODataOutputStream::writeUTF( OUString() );
 866     }
 867
 868     sal_uInt32 nObjLenMark = m_rMarkable->createMark();
 869     ODataOutputStream::writeLong( 0 );
 870
 871     sal_Int32 nInfoLen = m_rMarkable->offsetToMark( nInfoLenMark );
 872     m_rMarkable->jumpToMark( nInfoLenMark );
 873     // write length of the info data
 874     ODataOutputStream::writeShort( static_cast<sal_Int16>(nInfoLen) );
 875     // jump to the end of the stream
 876     m_rMarkable->jumpToFurthest();
 877
 878     if( bWriteObj )
 879         xPObj->write( Reference< XObjectOutputStream > (
 880             static_cast< XObjectOutputStream *  >(this) ) );
 881
 882     sal_Int32 nObjLen = m_rMarkable->offsetToMark( nObjLenMark ) -4;
 883     m_rMarkable->jumpToMark( nObjLenMark );
 884     // write length of the info data
 885     ODataOutputStream::writeLong( nObjLen );
 886     // jump to the end of the stream
 887     m_rMarkable->jumpToFurthest();
 888
 889     m_rMarkable->deleteMark( nObjLenMark );
 890     m_rMarkable->deleteMark( nInfoLenMark );
 891 }
 892
 893
 894 void OObjectOutputStream::connectToMarkable()
 895 {
 896     if( ! m_bValidMarkable ) {
 897         if( ! m_bValidStream )
 898         {
 899             throw NotConnectedException();
 900         }
 901
 902         // find the markable stream !
 903         Reference< XInterface > rTry(m_output);
 904         while( true ) {
 905             if( ! rTry.is() )
 906             {
 907                 throw NotConnectedException();
 908             }
 909             Reference < XMarkableStream > markable( rTry , UNO_QUERY );
 910             if( markable.is() )
 911             {
 912                 m_rMarkable = markable;
 913                 break;
 914             }
 915             Reference < XActiveDataSource > source( rTry , UNO_QUERY );
 916             rTry = source;
 917         }
 918         m_bValidMarkable = true;
 919     }
 920 }
 921
 922
 923 sal_Int32 OObjectOutputStream::createMark()
 924 {
 925     connectToMarkable();    // throws an exception, if a markable is not connected !
 926
 927     return m_rMarkable->createMark();
 928 }
 929
 930 void OObjectOutputStream::deleteMark(sal_Int32 Mark)
 931 {
 932     if( ! m_bValidMarkable )
 933     {
 934         throw NotConnectedException();
 935     }
 936     m_rMarkable->deleteMark( Mark );
 937 }
 938
 939 void OObjectOutputStream::jumpToMark(sal_Int32 nMark)
 940 {
 941     if( ! m_bValidMarkable )
 942     {
 943         throw NotConnectedException();
 944     }
 945     m_rMarkable->jumpToMark( nMark );
 946 }
 947
 948
 949 void OObjectOutputStream::jumpToFurthest()
 950 {
 951     connectToMarkable();
 952     m_rMarkable->jumpToFurthest();
 953 }
 954
 955 sal_Int32 OObjectOutputStream::offsetToMark(sal_Int32 nMark)
 956 {
 957     if( ! m_bValidMarkable )
 958     {
 959         throw NotConnectedException();
 960     }
 961     return m_rMarkable->offsetToMark( nMark );
 962 }
 963
 964
 965 Reference< XInterface > OObjectOutputStream_CreateInstance(
 966     SAL_UNUSED_PARAMETER const Reference < XComponentContext > & )
 967 {
 968     OObjectOutputStream *p = new OObjectOutputStream;
 969     return  Reference< XInterface > ( static_cast< OWeakObject *  >(p) );
 970 }
 971
 972 OUString OObjectOutputStream_getImplementationName()
 973 {
 974     return "com.sun.star.comp.io.stm.ObjectOutputStream";
 975 }
 976
 977 Sequence<OUString> OObjectOutputStream_getSupportedServiceNames()
 978 {
 979     Sequence<OUString> aRet { "com.sun.star.io.ObjectOutputStream" };
 980     return aRet;
 981 }
 982
 983 // XServiceInfo
 984 OUString OObjectOutputStream::getImplementationName()
 985 {
 986     return OObjectOutputStream_getImplementationName();
 987 }
 988
 989 // XServiceInfo
 990 sal_Bool OObjectOutputStream::supportsService(const OUString& ServiceName)
 991 {
 992     return cppu::supportsService(this, ServiceName);
 993 }
 994
 995 // XServiceInfo
 996 Sequence< OUString > OObjectOutputStream::getSupportedServiceNames()
 997 {
 998     return OObjectOutputStream_getSupportedServiceNames();
 999 }
1000
1001 class OObjectInputStream:
1002     public ImplInheritanceHelper<
1003         ODataInputStream, /* parent */
1004         XObjectInputStream, XMarkableStream >
1005 {
1006 public:
1007     explicit OObjectInputStream( const Reference < XComponentContext > &r)
1008         : m_rSMgr( r->getServiceManager() )
1009         , m_rCxt( r )
1010         , m_bValidMarkable(false)
1011         {
1012         }
1013
1014 public: // XInputStream
1015     virtual sal_Int32 SAL_CALL readBytes(Sequence< sal_Int8 >& aData, sal_Int32 nBytesToRead) override
1016         { return ODataInputStream::readBytes( aData , nBytesToRead ); }
1017
1018     virtual sal_Int32 SAL_CALL readSomeBytes(Sequence< sal_Int8 >& aData, sal_Int32 nMaxBytesToRead) override
1019         { return ODataInputStream::readSomeBytes( aData, nMaxBytesToRead ); }
1020
1021     virtual void SAL_CALL skipBytes(sal_Int32 nBytesToSkip) override
1022         { ODataInputStream::skipBytes( nBytesToSkip ); }
1023
1024     virtual sal_Int32 SAL_CALL available() override
1025         { return ODataInputStream::available(); }
1026
1027     virtual void SAL_CALL closeInput() override
1028         { ODataInputStream::closeInput(); }
1029
1030 public: // XDataInputStream
1031     virtual sal_Int8 SAL_CALL readBoolean() override
1032                 { return ODataInputStream::readBoolean(); }
1033     virtual sal_Int8 SAL_CALL readByte() override
1034                 { return ODataInputStream::readByte(); }
1035     virtual sal_Unicode SAL_CALL readChar() override
1036                 { return ODataInputStream::readChar(); }
1037     virtual sal_Int16 SAL_CALL readShort() override
1038                 { return ODataInputStream::readShort(); }
1039     virtual sal_Int32 SAL_CALL readLong() override
1040                 { return ODataInputStream::readLong(); }
1041     virtual sal_Int64 SAL_CALL readHyper() override
1042                 { return ODataInputStream::readHyper(); }
1043     virtual float SAL_CALL readFloat() override
1044                 { return ODataInputStream::readFloat(); }
1045     virtual double SAL_CALL readDouble() override
1046         { return ODataInputStream::readDouble(); }
1047     virtual OUString SAL_CALL readUTF() override
1048                 { return ODataInputStream::readUTF(); }
1049
1050 public: // XObjectInputStream
1051         virtual Reference< XPersistObject > SAL_CALL readObject( ) override;
1052
1053 public: // XMarkableStream
1054     virtual sal_Int32 SAL_CALL createMark() override;
1055     virtual void SAL_CALL deleteMark(sal_Int32 Mark) override;
1056     virtual void SAL_CALL jumpToMark(sal_Int32 nMark) override;
1057     virtual void SAL_CALL jumpToFurthest() override;
1058     virtual sal_Int32 SAL_CALL offsetToMark(sal_Int32 nMark) override;
1059
1060 public: // XServiceInfo
1061     OUString                     SAL_CALL getImplementationName() override;
1062     Sequence< OUString >         SAL_CALL getSupportedServiceNames() override;
1063     sal_Bool                     SAL_CALL supportsService(const OUString& ServiceName) override;
1064
1065 private:
1066     void connectToMarkable();
1067 private:
1068     Reference < XMultiComponentFactory > m_rSMgr;
1069     Reference < XComponentContext >     m_rCxt;
1070     bool                m_bValidMarkable;
1071     Reference < XMarkableStream > m_rMarkable;
1072     vector < Reference<  XPersistObject > > m_aPersistVector;
1073
1074 };
1075
1076 Reference< XPersistObject >  OObjectInputStream::readObject()
1077 {
1078     // check if chain contains a XMarkableStream
1079     connectToMarkable();
1080
1081     Reference< XPersistObject > xLoadedObj;
1082
1083     // create Mark to skip newer versions
1084     sal_uInt32 nMark = m_rMarkable->createMark();
1085     // length of the data
1086     sal_Int32 nLen = static_cast<sal_uInt16>(ODataInputStream::readShort());
1087     if( nLen < 0xc )
1088     {
1089         throw WrongFormatException();
1090     }
1091
1092     // read the object identifier
1093     sal_uInt32 nId = readLong();
1094
1095     // the name of the persist model
1096     // MM ???
1097     OUString aName = readUTF();
1098
1099     // Read the length of the object
1100     sal_Int32 nObjLen = readLong();
1101     if( 0 == nId && 0 != nObjLen )
1102     {
1103         throw WrongFormatException();
1104     }
1105
1106     // skip data of new version
1107     skipBytes( nLen - m_rMarkable->offsetToMark( nMark ) );
1108
1109     bool bLoadSuccessful = true;
1110     if( nId )
1111     {
1112         if( !aName.isEmpty() )
1113         {
1114             // load the object
1115             Reference< XInterface > x = m_rSMgr->createInstanceWithContext( aName, m_rCxt );
1116             xLoadedObj.set( x, UNO_QUERY );
1117             if( xLoadedObj.is() )
1118             {
1119                 sal_uInt32 nSize = m_aPersistVector.size();
1120                 if( nSize <= nId )
1121                 {
1122                     // grow to the right size
1123                     Reference< XPersistObject > xEmpty;
1124                     m_aPersistVector.insert( m_aPersistVector.end(), static_cast<long>(nId - nSize + 1), xEmpty );
1125                 }
1126
1127                 m_aPersistVector[nId] = xLoadedObj;
1128                 xLoadedObj->read( Reference< XObjectInputStream >(
1129                     static_cast< XObjectInputStream * >(this) ) );
1130             }
1131             else
1132             {
1133                 // no service with this name could be instantiated
1134                 bLoadSuccessful = false;
1135             }
1136         }
1137         else {
1138             if (nId >= m_aPersistVector.size())
1139             {
1140                 // id unknown, load failure !
1141                 bLoadSuccessful = false;
1142             }
1143             else
1144             {
1145                 // Object has already been read,
1146                 xLoadedObj = m_aPersistVector[nId];
1147             }
1148         }
1149     }
1150
1151     // skip to the position behind the object
1152     skipBytes( nObjLen + nLen - m_rMarkable->offsetToMark( nMark ) );
1153     m_rMarkable->deleteMark( nMark );
1154
1155     if( ! bLoadSuccessful )
1156     {
1157         throw WrongFormatException();
1158     }
1159     return xLoadedObj;
1160 }
1161
1162
1163 void OObjectInputStream::connectToMarkable()
1164 {
1165     if( ! m_bValidMarkable ) {
1166         if( ! m_bValidStream )
1167         {
1168             throw NotConnectedException( );
1169         }
1170
1171         // find the markable stream !
1172         Reference< XInterface > rTry(m_input);
1173         while( true ) {
1174             if( ! rTry.is() )
1175             {
1176                 throw NotConnectedException( );
1177             }
1178             Reference<  XMarkableStream > markable( rTry , UNO_QUERY );
1179             if( markable.is() )
1180             {
1181                 m_rMarkable = markable;
1182                 break;
1183             }
1184             Reference < XActiveDataSink > sink( rTry , UNO_QUERY );
1185             rTry = sink;
1186         }
1187         m_bValidMarkable = true;
1188     }
1189 }
1190
1191 sal_Int32 OObjectInputStream::createMark()
1192 {
1193     connectToMarkable();    // throws an exception, if a markable is not connected !
1194
1195     return m_rMarkable->createMark();
1196 }
1197
1198 void OObjectInputStream::deleteMark(sal_Int32 Mark)
1199 {
1200     if( ! m_bValidMarkable )
1201     {
1202         throw NotConnectedException();
1203     }
1204     m_rMarkable->deleteMark( Mark );
1205 }
1206
1207 void OObjectInputStream::jumpToMark(sal_Int32 nMark)
1208 {
1209     if( ! m_bValidMarkable )
1210     {
1211         throw NotConnectedException();
1212     }
1213     m_rMarkable->jumpToMark( nMark );
1214 }
1215 void OObjectInputStream::jumpToFurthest()
1216 {
1217     connectToMarkable();
1218     m_rMarkable->jumpToFurthest();
1219 }
1220
1221 sal_Int32 OObjectInputStream::offsetToMark(sal_Int32 nMark)
1222 {
1223     if( ! m_bValidMarkable )
1224     {
1225         throw NotConnectedException();
1226     }
1227     return m_rMarkable->offsetToMark( nMark );
1228 }
1229
1230 // XServiceInfo
1231 OUString OObjectInputStream::getImplementationName()
1232 {
1233     return OObjectInputStream_getImplementationName();
1234 }
1235
1236 // XServiceInfo
1237 sal_Bool OObjectInputStream::supportsService(const OUString& ServiceName)
1238 {
1239     return cppu::supportsService(this, ServiceName);
1240 }
1241
1242 // XServiceInfo
1243 Sequence< OUString > OObjectInputStream::getSupportedServiceNames()
1244 {
1245     return OObjectInputStream_getSupportedServiceNames();
1246 }
1247
1248 Reference< XInterface > OObjectInputStream_CreateInstance( const Reference < XComponentContext > & rCtx )
1249 {
1250     OObjectInputStream *p = new OObjectInputStream( rCtx );
1251     return Reference< XInterface> ( static_cast< OWeakObject * >(p) );
1252 }
1253
1254 OUString OObjectInputStream_getImplementationName()
1255 {
1256     return "com.sun.star.comp.io.stm.ObjectInputStream";
1257 }
1258
1259 Sequence<OUString> OObjectInputStream_getSupportedServiceNames()
1260 {
1261     Sequence<OUString> aRet { "com.sun.star.io.ObjectInputStream" };
1262     return aRet;
1263 }
1264
1265 }
1266
1267 /* vim:set shiftwidth=4 softtabstop=4 expandtab: */