vcl/unx/kde/UnxCommandThread.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 <UnxCommandThread.hxx>
  21 #include <UnxNotifyThread.hxx>
  22
  23 #include <rtl/ustring.hxx>
  24 #include <rtl/ustrbuf.hxx>
  25
  26 #include <unistd.h>
  27 #include <string.h>
  28 #include <iostream>
  29
  30 using namespace ::com::sun::star;
  31
  32 //////////////////////////////////////////////////////////////////////////
  33 // UnxFilePickerCommandThread
  34 //////////////////////////////////////////////////////////////////////////
  35
  36 UnxFilePickerCommandThread::UnxFilePickerCommandThread( UnxFilePickerNotifyThread *pNotifyThread, int nReadFD )
  37     : m_pNotifyThread( pNotifyThread ),
  38       m_nReadFD( nReadFD )
  39 {
  40 }
  41
  42 UnxFilePickerCommandThread::~UnxFilePickerCommandThread()
  43 {
  44 }
  45
  46 sal_Bool SAL_CALL UnxFilePickerCommandThread::result()
  47 {
  48     ::osl::MutexGuard aGuard( m_aMutex );
  49
  50     return m_aResult;
  51 }
  52
  53 OUString SAL_CALL UnxFilePickerCommandThread::getCurrentFilter()
  54 {
  55     ::osl::MutexGuard aGuard( m_aMutex );
  56
  57     return m_aGetCurrentFilter;
  58 }
  59
  60 OUString SAL_CALL UnxFilePickerCommandThread::getDirectory()
  61 {
  62     ::osl::MutexGuard aGuard( m_aMutex );
  63
  64     return m_aGetDirectory;
  65 }
  66
  67 uno::Sequence< OUString > SAL_CALL UnxFilePickerCommandThread::getFiles()
  68 {
  69     ::osl::MutexGuard aGuard( m_aMutex );
  70
  71     sal_Int32 nSize = m_aGetFiles.size();
  72     uno::Sequence< OUString > aFiles( ( nSize > 1 )? nSize + 1: nSize );
  73
  74     if ( nSize == 1 )
  75         aFiles[0] = m_aGetFiles.front();
  76     else if ( nSize > 1 )
  77     {
  78         // First entry in the sequence must be the dirname, the others are the
  79         // filenames, so we have to rearrange the list...
  80
  81         OUString aFront = m_aGetFiles.front();
  82         sal_Int32 nLastSlash = aFront.lastIndexOf( '/' );
  83
  84         aFiles[0] = ( nLastSlash >= 0 )? aFront.copy( 0, nLastSlash ): OUString();
  85         ++nLastSlash;
  86
  87         sal_Int32 nIdx = 1;
  88         for ( ::std::list< OUString >::const_iterator it = m_aGetFiles.begin();
  89                 it != m_aGetFiles.end(); ++it, ++nIdx )
  90         {
  91             sal_Int32 nLength = (*it).getLength() - nLastSlash;
  92             aFiles[nIdx] = ( nLength >= 0 )? (*it).copy( nLastSlash, nLength ): OUString();
  93         }
  94     }
  95
  96     return aFiles;
  97 }
  98
  99 uno::Any SAL_CALL UnxFilePickerCommandThread::getValue()
 100 {
 101     ::osl::MutexGuard aGuard( m_aMutex );
 102
 103     return m_aGetValue;
 104 }
 105
 106 void SAL_CALL UnxFilePickerCommandThread::run()
 107 {
 108     if ( m_nReadFD < 0 )
 109         return;
 110
 111     sal_Int32 nBufferSize = 1024; // 1 is for testing, 1024 for real use
 112     sal_Char *pBuffer = new sal_Char[nBufferSize];
 113     sal_Char *pBufferEnd = pBuffer + nBufferSize;
 114
 115     sal_Char *pWhereToRead = pBuffer;
 116     sal_Char *pEntryBegin = pBuffer;
 117     sal_Int32 nBytesRead = 0;
 118     sal_Bool  bShouldExit = sal_False;
 119     while ( !bShouldExit && ( nBytesRead = read( m_nReadFD, pWhereToRead, pBufferEnd - pWhereToRead ) ) > 0 )
 120     {
 121         sal_Bool bFoundNL = sal_False;
 122         sal_Char *pWhereToReadEnd = pWhereToRead + nBytesRead;
 123         sal_Char *pEntryEnd = pWhereToRead;
 124         do {
 125             for ( ; pEntryEnd < pWhereToReadEnd && *pEntryEnd != '\n'; ++pEntryEnd )
 126                 ;
 127
 128             if ( pEntryEnd < pWhereToReadEnd )
 129             {
 130                 bFoundNL = sal_True;
 131                 *pEntryEnd = 0;
 132
 133                 if ( strcmp( pEntryBegin, "exited" ) == 0 )
 134                     bShouldExit = sal_True;
 135                 else
 136                     handleCommand( OUString( pEntryBegin, pEntryEnd - pEntryBegin, RTL_TEXTENCODING_UTF8 )/*, bQuit*/ );
 137
 138                 pEntryBegin = pEntryEnd + 1;
 139             }
 140         } while ( pEntryEnd < pWhereToReadEnd );
 141
 142         if ( bFoundNL )
 143         {
 144             if ( pEntryBegin < pBufferEnd )
 145                 memmove( pBuffer, pEntryBegin, pWhereToReadEnd - pEntryBegin );
 146         }
 147         else
 148         {
 149             // enlarge the buffer size
 150             nBufferSize *= 2;
 151             sal_Char *pNewBuffer = new sal_Char[nBufferSize];
 152             if ( pEntryBegin < pBufferEnd )
 153                 memcpy( pNewBuffer, pEntryBegin, pWhereToReadEnd - pEntryBegin );
 154
 155             delete[] pBuffer;
 156             pBuffer = pNewBuffer;
 157             pBufferEnd = pBuffer + nBufferSize;
 158         }
 159
 160         pWhereToRead = pBuffer + ( pWhereToReadEnd - pEntryBegin );
 161         pEntryBegin = pBuffer;
 162     }
 163 }
 164
 165 void SAL_CALL UnxFilePickerCommandThread::handleCommand( const OUString &rCommand )
 166 {
 167     ::osl::MutexGuard aGuard( m_aMutex );
 168
 169 #if OSL_DEBUG_LEVEL > 0
 170     ::std::cerr << "UnxFilePicker received: \"" <<
 171         OUStringToOString( rCommand, RTL_TEXTENCODING_ASCII_US ).getStr() << "\"" << ::std::endl;
 172 #endif
 173
 174     ::std::list< OUString > aList = tokenize( rCommand );
 175
 176     if ( aList.empty() )
 177         return;
 178
 179     OUString aCommandName = aList.front();
 180     aList.pop_front();
 181
 182     if ( aCommandName == "accept" )
 183     {
 184         m_aResult = sal_True;
 185         m_aExecCondition.set();
 186     }
 187     else if ( aCommandName == "reject" )
 188     {
 189         m_aResult = sal_False;
 190         m_aExecCondition.set();
 191     }
 192     else if ( aCommandName == "fileSelectionChanged" )
 193     {
 194         if ( m_pNotifyThread )
 195             m_pNotifyThread->fileSelectionChanged();
 196     }
 197     else if ( aCommandName == "files" )
 198     {
 199         m_aGetFiles = aList;
 200         m_aGetFilesCondition.set();
 201     }
 202     else if ( aCommandName == "value" )
 203     {
 204         OUString aType;
 205         if ( !aList.empty() )
 206         {
 207             aType = aList.front();
 208             aList.pop_front();
 209         }
 210
 211         if ( aType == "bool" )
 212         {
 213             sal_Bool bValue = !aList.empty() && aList.front().equalsIgnoreAsciiCase("true");
 214
 215             m_aGetValue <<= bValue;
 216             m_aGetValueCondition.set();
 217         }
 218         else if ( aType == "int" )
 219         {
 220             sal_Int32 nValue = 0;
 221             if ( !aList.empty() )
 222                 nValue = aList.front().toInt32();
 223
 224             m_aGetValue <<= nValue;
 225             m_aGetValueCondition.set();
 226         }
 227         else if ( aType == "string" )
 228         {
 229             OUString aValue;
 230             if ( !aList.empty() )
 231                 aValue = aList.front();
 232
 233             m_aGetValue <<= aValue;
 234             m_aGetValueCondition.set();
 235         }
 236         else if ( aType == "stringList" )
 237         {
 238             uno::Sequence< OUString > aSequence( aList.size() );
 239             sal_Int32 nIdx = 0;
 240             for ( ::std::list< OUString >::const_iterator it = aList.begin(); it != aList.end(); ++it, ++nIdx )
 241                 aSequence[nIdx] = (*it);
 242
 243             m_aGetValue <<= aSequence;
 244             m_aGetValueCondition.set();
 245         }
 246         else
 247         {
 248             m_aGetValue = uno::Any();
 249             m_aGetValueCondition.set();
 250         }
 251     }
 252     else if ( aCommandName == "currentFilter" )
 253     {
 254         m_aGetCurrentFilter = aList.empty()? OUString(): aList.front();
 255         m_aGetCurrentFilterCondition.set();
 256     }
 257     else if ( aCommandName == "currentDirectory" )
 258     {
 259         m_aGetDirectory = aList.empty()? OUString(): aList.front();
 260         m_aGetDirectoryCondition.set();
 261     }
 262     else
 263     {
 264 #if OSL_DEBUG_LEVEL > 0
 265         ::std::cerr << "Unrecognized command: "
 266             << OUStringToOString( aCommandName, RTL_TEXTENCODING_ASCII_US ).getStr() << "\"" << ::std::endl;
 267 #endif
 268     }
 269 }
 270
 271 ::std::list< OUString > SAL_CALL UnxFilePickerCommandThread::tokenize( const OUString &rCommand )
 272 {
 273     ::std::list< OUString > aList;
 274     OUStringBuffer aBuffer( 1024 );
 275
 276     const sal_Unicode *pUnicode = rCommand.getStr();
 277     const sal_Unicode *pEnd     = pUnicode + rCommand.getLength();
 278     sal_Bool bQuoted            = sal_False;
 279
 280     for ( ; pUnicode != pEnd; ++pUnicode )
 281     {
 282         if ( *pUnicode == '\\' )
 283         {
 284             ++pUnicode;
 285             if ( pUnicode != pEnd )
 286             {
 287                 if ( *pUnicode == 'n' )
 288                     aBuffer.appendAscii( "\n", 1 );
 289                 else
 290                     aBuffer.append( *pUnicode );
 291             }
 292         }
 293         else if ( *pUnicode == '"' )
 294             bQuoted = !bQuoted;
 295         else if ( *pUnicode == ' ' && !bQuoted )
 296             aList.push_back( aBuffer.makeStringAndClear() );
 297         else
 298             aBuffer.append( *pUnicode );
 299     }
 300     aList.push_back( aBuffer.makeStringAndClear() );
 301
 302     return aList;
 303 }
 304
 305 /* vim:set shiftwidth=4 softtabstop=4 expandtab: */