From f1f40a616b905a62fb9c6fc1bb6af30262debb0b Mon Sep 17 00:00:00 2001 From: David Ostrovsky Date: Fri, 14 Sep 2012 00:07:07 +0200 Subject: mork driver: get rid of infinite loop. Many thanks to Michael Stahl for helping out with debugging it. The problem was, that soffice.bin grabbed the mouse and keyboard. Michael pointed me out to alternate Xephyr X-Server. With it it was the matter of 5 min. to attach a debugger to soffice.bin and to find the problem. Change-Id: Ic8340fbd87e65945b12f4a928c73fa23a439d9f4 --- connectivity/source/drivers/mork/MConnection.hxx | 1 - connectivity/source/drivers/mork/MQueryHelper.cxx | 21 +++++++++++++ connectivity/source/drivers/mork/MQueryHelper.hxx | 2 ++ connectivity/source/drivers/mork/MResultSet.cxx | 37 ++++++++++++++--------- 4 files changed, 45 insertions(+), 16 deletions(-) diff --git a/connectivity/source/drivers/mork/MConnection.hxx b/connectivity/source/drivers/mork/MConnection.hxx index 72cf59222d71..fd478ffe52fd 100644 --- a/connectivity/source/drivers/mork/MConnection.hxx +++ b/connectivity/source/drivers/mork/MConnection.hxx @@ -109,7 +109,6 @@ namespace connectivity // Added to enable me to use SQLInterpreter which requires an // XNameAccess i/f to access tables. ::com::sun::star::uno::Reference< ::com::sun::star::sdbcx::XTablesSupplier > SAL_CALL createCatalog(); - }; } } diff --git a/connectivity/source/drivers/mork/MQueryHelper.cxx b/connectivity/source/drivers/mork/MQueryHelper.cxx index 6b4e351220e9..7803d6736a86 100644 --- a/connectivity/source/drivers/mork/MQueryHelper.cxx +++ b/connectivity/source/drivers/mork/MQueryHelper.cxx @@ -158,6 +158,26 @@ sal_Int32 MQueryHelper::getResultCount() const // ------------------------------------------------------------------------- +sal_Bool MQueryHelper::queryComplete() const +{ + return sal_True; +} + +sal_Bool MQueryHelper::checkRowAvailable( sal_Int32 nDBRow ) +{ +/* + while (!queryComplete() && getResultCount() <= (sal_uInt32)nDBRow) + { + if ( !m_aQueryHelper->waitForRow( nDBRow ) ) { + m_aError = m_aQueryHelper->getError(); + return( sal_False ); + } + } +*/ + return( getResultCount() > nDBRow ); +} + + sal_Bool MQueryHelper::getRowValue( ORowSetValue& rValue, sal_Int32 nDBRow,const rtl::OUString& aDBColumnName, sal_Int32 nType ) { SAL_INFO("connectivity.mork", "MQueryHelper::getRowValue()" ); @@ -185,6 +205,7 @@ sal_Bool MQueryHelper::getRowValue( ORowSetValue& rValue, sal_Int32 nDBRow,const sal_Int32 MQueryHelper::executeQuery(OConnection* xConnection) { +// OSL_FAIL( "MQueryHelper::executeQuery" ); SAL_INFO("connectivity.mork", "MQueryHelper::executeQuery()" ); reset(); diff --git a/connectivity/source/drivers/mork/MQueryHelper.hxx b/connectivity/source/drivers/mork/MQueryHelper.hxx index 2d186a8d1f58..82758370fb78 100644 --- a/connectivity/source/drivers/mork/MQueryHelper.hxx +++ b/connectivity/source/drivers/mork/MQueryHelper.hxx @@ -82,7 +82,9 @@ namespace connectivity MQueryHelperResultEntry* next(); MQueryHelperResultEntry* getByIndex( sal_uInt32 nRow ); sal_Bool isError() const; + sal_Bool queryComplete() const; sal_Int32 getResultCount() const; + sal_Bool checkRowAvailable( sal_Int32 nDBRow ); sal_Bool getRowValue( ORowSetValue& rValue, sal_Int32 nDBRow,const rtl::OUString& aDBColumnName, sal_Int32 nType ); sal_Int32 executeQuery(OConnection* xConnection); }; diff --git a/connectivity/source/drivers/mork/MResultSet.cxx b/connectivity/source/drivers/mork/MResultSet.cxx index d7d71173bffb..83639016ef4e 100644 --- a/connectivity/source/drivers/mork/MResultSet.cxx +++ b/connectivity/source/drivers/mork/MResultSet.cxx @@ -467,8 +467,8 @@ sal_Bool SAL_CALL OResultSet::isAfterLast( ) throw(SQLException, RuntimeExcepti ResultSetEntryGuard aGuard( *this ); OSL_TRACE("In/Out: OResultSet::isAfterLast" ); - return sal_True; -// return m_nRowPos > currentRowCount() && m_aQuery.queryComplete(); +// return sal_True; + return m_nRowPos > currentRowCount() && m_aQueryHelper.queryComplete(); } // ------------------------------------------------------------------------- sal_Bool SAL_CALL OResultSet::isFirst( ) throw(SQLException, RuntimeException) @@ -485,8 +485,8 @@ sal_Bool SAL_CALL OResultSet::isLast( ) throw(SQLException, RuntimeException) ResultSetEntryGuard aGuard( *this ); OSL_TRACE("In/Out: OResultSet::isLast" ); - return sal_True; -// return m_nRowPos == currentRowCount() && m_aQuery.queryComplete(); +// return sal_True; + return m_nRowPos == currentRowCount() && m_aQueryHelper.queryComplete(); } // ------------------------------------------------------------------------- void SAL_CALL OResultSet::beforeFirst( ) throw(SQLException, RuntimeException) @@ -1486,34 +1486,41 @@ sal_Bool OResultSet::isCount() const // // Check for valid row in m_aQuery // -sal_Bool OResultSet::validRow( sal_uInt32 /*nRow*/ ) +sal_Bool OResultSet::validRow( sal_uInt32 nRow) { - OSL_FAIL( "OResultSet::validRow() is not implemented" ); +// OSL_FAIL( "OResultSet::validRow() is not implemented" ); -/* - sal_Int32 nNumberOfRecords = m_aQuery.getRealRowCount(); - while ( nRow > (sal_uInt32)nNumberOfRecords && !m_aQuery.queryComplete() ) { + sal_Int32 nNumberOfRecords = m_aQueryHelper.getResultCount(); +//m_aQuery.getRealRowCount(); + + while ( nRow > (sal_uInt32)nNumberOfRecords && !m_aQueryHelper.queryComplete() ) { #if OSL_DEBUG_LEVEL > 0 OSL_TRACE("validRow: waiting..."); #endif - m_aQuery.checkRowAvailable( nRow ); + if (m_aQueryHelper.checkRowAvailable( nRow ) == sal_False) + { + OSL_TRACE("validRow(%u): return False", nRow); + return sal_False; + } +#if 0 if ( m_aQuery.hadError() ) { m_pStatement->getOwnConnection()->throwSQLException( m_aQuery.getError(), *this ); } - nNumberOfRecords = m_aQuery.getRealRowCount(); +#endif + nNumberOfRecords = m_aQueryHelper.getResultCount(); } if (( nRow == 0 ) || - ( nRow > (sal_uInt32)nNumberOfRecords && m_aQuery.queryComplete()) ){ + ( nRow > (sal_uInt32)nNumberOfRecords && m_aQueryHelper.queryComplete()) ){ OSL_TRACE("validRow(%u): return False", nRow); return sal_False; } #if OSL_DEBUG_LEVEL > 0 OSL_TRACE("validRow(%u): return True", nRow); #endif -*/ + return sal_True; } sal_Bool OResultSet::fillKeySet(sal_Int32 nMaxCardNumber) @@ -1596,16 +1603,16 @@ sal_Bool OResultSet::seekRow( eRowPosition pos, sal_Int32 nOffset ) else //The requested row has not been retrived until now. We should get the right card for it. nCurCard = nCurPos + deletedCount(); - while ( nCurCard > nNumberOfRecords ) { /* + while ( nCurCard > nNumberOfRecords ) { m_aQuery.checkRowAvailable( nCurCard ); if ( m_aQuery.hadError() ) { m_pStatement->getOwnConnection()->throwSQLException( m_aQuery.getError(), *this ); } -*/ nNumberOfRecords = m_aQueryHelper.getResultCount(); } +*/ if ( nCurCard > nNumberOfRecords) { fillKeySet(nNumberOfRecords); -- cgit