fpicker/source/unx/kde_unx/UnxCommandThread.cxx

   1 /*************************************************************************
   2  *
   3  *
   4  *
   5  *
   6  *
   7  *
   8  *
   9  *  The Contents of this file are made available subject to the terms of
  10  *  either of the following licenses
  11  *
  12  *         - GNU Lesser General Public License Version 2.1
  13  *         - Sun Industry Standards Source License Version 1.1
  14  *
  15  *  Sun Microsystems Inc., October, 2000
  16  *
  17  *  GNU Lesser General Public License Version 2.1
  18  *  =============================================
  19  *  Copyright 2000 by Sun Microsystems, Inc.
  20  *  901 San Antonio Road, Palo Alto, CA 94303, USA
  21  *
  22  *  This library is free software; you can redistribute it and/or
  23  *  modify it under the terms of the GNU Lesser General Public
  24  *  License version 2.1, as published by the Free Software Foundation.
  25  *
  26  *  This library is distributed in the hope that it will be useful,
  27  *  but WITHOUT ANY WARRANTY; without even the implied warranty of
  28  *  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
  29  *  Lesser General Public License for more details.
  30  *
  31  *  You should have received a copy of the GNU Lesser General Public
  32  *  License along with this library; if not, write to the Free Software
  33  *  Foundation, Inc., 59 Temple Place, Suite 330, Boston,
  34  *  MA  02111-1307  USA
  35  *
  36  *
  37  *  Sun Industry Standards Source License Version 1.1
  38  *  =================================================
  39  *  The contents of this file are subject to the Sun Industry Standards
  40  *  Source License Version 1.1 (the "License"); You may not use this file
  41  *  except in compliance with the License. You may obtain a copy of the
  42  *  License at http://www.openoffice.org/license.html.
  43  *
  44  *  Software provided under this License is provided on an "AS IS" basis,
  45  *  WITHOUT WARRANTY OF ANY KIND, EITHER EXPRESSED OR IMPLIED, INCLUDING,
  46  *  WITHOUT LIMITATION, WARRANTIES THAT THE SOFTWARE IS FREE OF DEFECTS,
  47  *  MERCHANTABLE, FIT FOR A PARTICULAR PURPOSE, OR NON-INFRINGING.
  48  *  See the License for the specific provisions governing your rights and
  49  *  obligations concerning the Software.
  50  *
  51  *  The Initial Developer of the Original Code is: Sun Microsystems, Inc.
  52  *
  53  *  Copyright: 2000 by Sun Microsystems, Inc.
  54  *
  55  *  All Rights Reserved.
  56  *
  57  *  Contributor(s): Jan Holesovsky <kendy@openoffice.org>
  58  *
  59  *
  60  ************************************************************************/
  61
  62 #ifndef _UNXCOMMANDTHREAD_HXX_
  63 #include <UnxCommandThread.hxx>
  64 #endif
  65
  66 #ifndef _UNXNOTIFYTHREAD_HXX_
  67 #include <UnxNotifyThread.hxx>
  68 #endif
  69
  70 #ifndef _RTL_USTRING_H_
  71 #include <rtl/ustring.hxx>
  72 #endif
  73
  74 #ifndef _RTL_USTRBUF_HXX_
  75 #include <rtl/ustrbuf.hxx>
  76 #endif
  77
  78 #include <unistd.h>
  79 #include <string.h>
  80 #include <iostream>
  81
  82 using namespace ::com::sun::star;
  83
  84 //////////////////////////////////////////////////////////////////////////
  85 // UnxFilePickerCommandThread
  86 //////////////////////////////////////////////////////////////////////////
  87
  88 UnxFilePickerCommandThread::UnxFilePickerCommandThread( UnxFilePickerNotifyThread *pNotifyThread, int nReadFD )
  89     : m_pNotifyThread( pNotifyThread ),
  90       m_nReadFD( nReadFD )
  91 {
  92 }
  93
  94 UnxFilePickerCommandThread::~UnxFilePickerCommandThread()
  95 {
  96 }
  97
  98 sal_Bool SAL_CALL UnxFilePickerCommandThread::result()
  99 {
 100     ::osl::MutexGuard aGuard( m_aMutex );
 101
 102     return m_aResult;
 103 }
 104
 105 ::rtl::OUString SAL_CALL UnxFilePickerCommandThread::getCurrentFilter()
 106 {
 107     ::osl::MutexGuard aGuard( m_aMutex );
 108
 109     return m_aGetCurrentFilter;
 110 }
 111
 112 ::rtl::OUString SAL_CALL UnxFilePickerCommandThread::getDirectory()
 113 {
 114     ::osl::MutexGuard aGuard( m_aMutex );
 115
 116     return m_aGetDirectory;
 117 }
 118
 119 uno::Sequence< ::rtl::OUString > SAL_CALL UnxFilePickerCommandThread::getFiles()
 120 {
 121     ::osl::MutexGuard aGuard( m_aMutex );
 122
 123     sal_Int32 nSize = m_aGetFiles.size();
 124     uno::Sequence< ::rtl::OUString > aFiles( ( nSize > 1 )? nSize + 1: nSize );
 125
 126     if ( nSize == 1 )
 127         aFiles[0] = m_aGetFiles.front();
 128     else if ( nSize > 1 )
 129     {
 130         // First entry in the sequence must be the dirname, the others are the
 131         // filenames, so we have to rearrange the list...
 132
 133         ::rtl::OUString aFront = m_aGetFiles.front();
 134         sal_Int32 nLastSlash = aFront.lastIndexOf( '/' );
 135
 136         aFiles[0] = ( nLastSlash >= 0 )? aFront.copy( 0, nLastSlash ): ::rtl::OUString();
 137         ++nLastSlash;
 138
 139         sal_Int32 nIdx = 1;
 140         for ( ::std::list< ::rtl::OUString >::const_iterator it = m_aGetFiles.begin();
 141                 it != m_aGetFiles.end(); ++it, ++nIdx )
 142         {
 143             sal_Int32 nLength = (*it).getLength() - nLastSlash;
 144             aFiles[nIdx] = ( nLength >= 0 )? (*it).copy( nLastSlash, nLength ): ::rtl::OUString();
 145         }
 146     }
 147
 148     return aFiles;
 149 }
 150
 151 uno::Any SAL_CALL UnxFilePickerCommandThread::getValue()
 152 {
 153     ::osl::MutexGuard aGuard( m_aMutex );
 154
 155     return m_aGetValue;
 156 }
 157
 158 void SAL_CALL UnxFilePickerCommandThread::run()
 159 {
 160     if ( m_nReadFD < 0 )
 161         return;
 162
 163     sal_Int32 nBufferSize = 1024; // 1 is for testing, 1024 for real use
 164     sal_Char *pBuffer = new sal_Char[nBufferSize];
 165     sal_Char *pBufferEnd = pBuffer + nBufferSize;
 166
 167     sal_Char *pWhereToRead = pBuffer;
 168     sal_Char *pEntryBegin = pBuffer;
 169     sal_Int32 nBytesRead = 0;
 170     sal_Bool  bShouldExit = sal_False;
 171     while ( !bShouldExit && ( nBytesRead = read( m_nReadFD, pWhereToRead, pBufferEnd - pWhereToRead ) ) > 0 )
 172     {
 173         sal_Bool bFoundNL = sal_False;
 174         sal_Char *pWhereToReadEnd = pWhereToRead + nBytesRead;
 175         sal_Char *pEntryEnd = pWhereToRead;
 176         do {
 177             for ( ; pEntryEnd < pWhereToReadEnd && *pEntryEnd != '\n'; ++pEntryEnd )
 178                 ;
 179
 180             if ( pEntryEnd < pWhereToReadEnd )
 181             {
 182                 bFoundNL = sal_True;
 183                 *pEntryEnd = 0;
 184
 185                 if ( strcmp( pEntryBegin, "exited" ) == 0 )
 186                     bShouldExit = sal_True;
 187                 else
 188                     handleCommand( ::rtl::OUString( pEntryBegin, pEntryEnd - pEntryBegin, RTL_TEXTENCODING_UTF8 )/*, bQuit*/ );
 189
 190                 pEntryBegin = pEntryEnd + 1;
 191             }
 192         } while ( pEntryEnd < pWhereToReadEnd );
 193
 194         if ( bFoundNL )
 195         {
 196             if ( pEntryBegin < pBufferEnd )
 197                 memmove( pBuffer, pEntryBegin, pWhereToReadEnd - pEntryBegin );
 198         }
 199         else
 200         {
 201             // enlarge the buffer size
 202             nBufferSize *= 2;
 203             sal_Char *pNewBuffer = new sal_Char[nBufferSize];
 204             if ( pEntryBegin < pBufferEnd )
 205                 memmove( pNewBuffer, pEntryBegin, pWhereToReadEnd - pEntryBegin );
 206
 207             delete[] pBuffer;
 208             pBuffer = pNewBuffer;
 209             pBufferEnd = pBuffer + nBufferSize;
 210         }
 211
 212         pWhereToRead = pBuffer + ( pWhereToReadEnd - pEntryBegin );
 213         pEntryBegin = pBuffer;
 214     }
 215 }
 216
 217 void SAL_CALL UnxFilePickerCommandThread::handleCommand( const ::rtl::OUString &rCommand )
 218 {
 219     ::osl::MutexGuard aGuard( m_aMutex );
 220
 221 #if OSL_DEBUG_LEVEL > 0
 222     ::std::cerr << "UnxFilePicker received: \"" <<
 223         OUStringToOString( rCommand, RTL_TEXTENCODING_ASCII_US ).getStr() << "\"" << ::std::endl;
 224 #endif
 225
 226     ::std::list< ::rtl::OUString > aList = tokenize( rCommand );
 227
 228     if ( aList.size() == 0 )
 229         return;
 230
 231     ::rtl::OUString aCommandName = aList.front();
 232     aList.pop_front();
 233
 234     if ( aCommandName.equalsAscii( "accept" ) )
 235     {
 236         m_aResult = sal_True;
 237         m_aExecCondition.set();
 238     }
 239     else if ( aCommandName.equalsAscii( "reject" ) )
 240     {
 241         m_aResult = sal_False;
 242         m_aExecCondition.set();
 243     }
 244     else if ( aCommandName.equalsAscii( "fileSelectionChanged" ) )
 245     {
 246         if ( m_pNotifyThread )
 247             m_pNotifyThread->fileSelectionChanged();
 248     }
 249     else if ( aCommandName.equalsAscii( "files" ) )
 250     {
 251         m_aGetFiles = aList;
 252         m_aGetFilesCondition.set();
 253     }
 254     else if ( aCommandName.equalsAscii( "value" ) )
 255     {
 256         ::rtl::OUString aType;
 257         if ( !aList.empty() )
 258         {
 259             aType = aList.front();
 260             aList.pop_front();
 261         }
 262
 263         if ( aType.equalsAscii( "bool" ) )
 264         {
 265             sal_Bool bValue = !aList.empty() && aList.front().equalsIgnoreAsciiCaseAscii( "true" );
 266
 267             m_aGetValue <<= bValue;
 268             m_aGetValueCondition.set();
 269         }
 270         else if ( aType.equalsAscii( "int" ) )
 271         {
 272             sal_Int32 nValue = 0;
 273             if ( !aList.empty() )
 274                 nValue = aList.front().toInt32();
 275
 276             m_aGetValue <<= nValue;
 277             m_aGetValueCondition.set();
 278         }
 279         else if ( aType.equalsAscii( "string" ) )
 280         {
 281             ::rtl::OUString aValue;
 282             if ( !aList.empty() )
 283                 aValue = aList.front();
 284
 285             m_aGetValue <<= aValue;
 286             m_aGetValueCondition.set();
 287         }
 288         else if ( aType.equalsAscii( "stringList" ) )
 289         {
 290             uno::Sequence< ::rtl::OUString > aSequence( aList.size() );
 291             sal_Int32 nIdx = 0;
 292             for ( ::std::list< ::rtl::OUString >::const_iterator it = aList.begin(); it != aList.end(); ++it, ++nIdx )
 293                 aSequence[nIdx] = (*it);
 294
 295             m_aGetValue <<= aSequence;
 296             m_aGetValueCondition.set();
 297         }
 298         else
 299         {
 300             m_aGetValue = uno::Any();
 301             m_aGetValueCondition.set();
 302         }
 303     }
 304     else if ( aCommandName.equalsAscii( "currentFilter" ) )
 305     {
 306         m_aGetCurrentFilter = aList.empty()? ::rtl::OUString(): aList.front();
 307         m_aGetCurrentFilterCondition.set();
 308     }
 309     else if ( aCommandName.equalsAscii( "currentDirectory" ) )
 310     {
 311         m_aGetDirectory = aList.empty()? ::rtl::OUString(): aList.front();
 312         m_aGetDirectoryCondition.set();
 313     }
 314     else
 315     {
 316 #if OSL_DEBUG_LEVEL > 0
 317         ::std::cerr << "Unrecognized command: "
 318             << OUStringToOString( aCommandName, RTL_TEXTENCODING_ASCII_US ).getStr() << "\"" << ::std::endl;
 319 #endif
 320     }
 321 }
 322
 323 ::std::list< ::rtl::OUString > SAL_CALL UnxFilePickerCommandThread::tokenize( const ::rtl::OUString &rCommand )
 324 {
 325     ::std::list< ::rtl::OUString > aList;
 326     ::rtl::OUStringBuffer aBuffer( 1024 );
 327
 328     const sal_Unicode *pUnicode = rCommand.getStr();
 329     const sal_Unicode *pEnd     = pUnicode + rCommand.getLength();
 330     sal_Bool bQuoted            = sal_False;
 331
 332     for ( ; pUnicode != pEnd; ++pUnicode )
 333     {
 334         if ( *pUnicode == '\\' )
 335         {
 336             ++pUnicode;
 337             if ( pUnicode != pEnd )
 338             {
 339                 if ( *pUnicode == 'n' )
 340                     aBuffer.appendAscii( "\n", 1 );
 341                 else
 342                     aBuffer.append( *pUnicode );
 343             }
 344         }
 345         else if ( *pUnicode == '"' )
 346             bQuoted = !bQuoted;
 347         else if ( *pUnicode == ' ' && !bQuoted )
 348             aList.push_back( aBuffer.makeStringAndClear() );
 349         else
 350             aBuffer.append( *pUnicode );
 351     }
 352     aList.push_back( aBuffer.makeStringAndClear() );
 353
 354     return aList;
 355 }