browser items moveToThread() also children

blazek · blazek · commit d0ea44aef3d8 · 2014-12-16T20:33:39.000+01:00
diff --git a/src/core/qgsdataitem.cpp b/src/core/qgsdataitem.cpp
@@ -224,6 +224,20 @@ void QgsDataItem::deleteLater( QVector<QgsDataItem*> &items )
   items.clear();
 }
 
+void QgsDataItem::moveToThread( QThread * targetThread )
+{
+  // QObject::moveToThread() cannot move objects with parent, but QgsDataItem is not using paren/children from QObject
+  foreach ( QgsDataItem* child, mChildren )
+  {
+    if ( !child ) // should not happen
+      continue;
+    QgsDebugMsg( "moveToThread child " + child->path() );
+    child->QObject::setParent( 0 ); // to be sure
+    child->moveToThread( targetThread );
+  }
+  QObject::moveToThread( targetThread );
+}
+
 QIcon QgsDataItem::icon()
 {
   if ( state() == Populating )
@@ -315,11 +329,8 @@ QVector<QgsDataItem*> QgsDataItem::runCreateChildren( QgsDataItem* item )
   {
     if ( !child ) // should not happen
       continue;
-    // The object cannot be moved if it has a parent.
     QgsDebugMsg( "moveToThread child " + child->path() );
-    child->setParent( 0 );
     child->moveToThread( QApplication::instance()->thread() ); // moves also children
-    child->setParent( item );
   }
   QgsDebugMsg( "finished path = " + item->path() );
   return children;
@@ -455,18 +466,7 @@ void QgsDataItem::setParent( QgsDataItem* parent )
 {
   if ( mParent )
   {
-    disconnect( this, SIGNAL( beginInsertItems( QgsDataItem*, int, int ) ),
-                mParent, SLOT( emitBeginInsertItems( QgsDataItem*, int, int ) ) );
-    disconnect( this, SIGNAL( endInsertItems() ),
-                mParent, SLOT( emitEndInsertItems() ) );
-    disconnect( this, SIGNAL( beginRemoveItems( QgsDataItem*, int, int ) ),
-                mParent, SLOT( emitBeginRemoveItems( QgsDataItem*, int, int ) ) );
-    disconnect( this, SIGNAL( endRemoveItems() ),
-                mParent, SLOT( emitEndRemoveItems() ) );
-    disconnect( this, SIGNAL( dataChanged( QgsDataItem* ) ),
-                mParent, SLOT( emitDataChanged( QgsDataItem* ) ) );
-    disconnect( this, SIGNAL( stateChanged( QgsDataItem*, QgsDataItem::State ) ),
-                mParent, SLOT( emitStateChanged( QgsDataItem*, QgsDataItem::State ) ) );
+    disconnect( this, 0, mParent, 0 );
   }
   if ( parent )
   {
diff --git a/src/core/qgsdataitem.h b/src/core/qgsdataitem.h
@@ -38,7 +38,8 @@ class QgsDataItem;
 typedef QgsDataItem * dataItem_t( QString, QgsDataItem* );
 
 
-/** base class for all items in the model */
+/** Base class for all items in the model.
+ *  Parent/children hierarchy is not based on QObject. */
 class CORE_EXPORT QgsDataItem : public QObject
 {
     Q_OBJECT
@@ -158,6 +159,9 @@ class CORE_EXPORT QgsDataItem : public QObject
     // deleteLater() items anc clear the vector
     static void deleteLater( QVector<QgsDataItem*> &items );
 
+    /** Move object and all its descendants to thread */
+    void moveToThread( QThread * targetThread );
+
   protected:
     virtual void populate( QVector<QgsDataItem*> children );
     virtual void refresh( QVector<QgsDataItem*> children );
diff --git a/src/providers/postgres/qgspostgresdataitems.cpp b/src/providers/postgres/qgspostgresdataitems.cpp
@@ -121,15 +121,17 @@ void QgsPGConnectionItem::editConnection()
   if ( nc.exec() )
   {
     // the parent should be updated
-    mParent->refresh();
+    if ( mParent )
+      mParent->refresh();
   }
 }
 
 void QgsPGConnectionItem::deleteConnection()
 {
   QgsPostgresConn::deleteConnection( mName );
   // the parent should be updated
-  mParent->refresh();
+  if ( mParent )
+    mParent->refresh();
 }
 
 void QgsPGConnectionItem::refreshConnection()
@@ -248,7 +250,8 @@ void QgsPGLayerItem::deleteLayer()
   else
   {
     QMessageBox::information( 0, tr( "Delete layer" ), tr( "Layer deleted successfully." ) );
-    mParent->refresh();
+    if ( mParent )
+      mParent->refresh();
   }
 }
 

Original file line number	Diff line number	Diff line change
`@@ -121,15 +121,17 @@ void QgsPGConnectionItem::editConnection()`
`121`	`121`	`if ( nc.exec() )`
`122`	`122`	`{`
`123`	`123`	`// the parent should be updated`
`124`		`- mParent->refresh();`
	`124`	`+ if ( mParent )`
	`125`	`+ mParent->refresh();`
`125`	`126`	`}`
`126`	`127`	`}`
`127`	`128`
`128`	`129`	`void QgsPGConnectionItem::deleteConnection()`
`129`	`130`	`{`
`130`	`131`	`QgsPostgresConn::deleteConnection( mName );`
`131`	`132`	`// the parent should be updated`
`132`		`- mParent->refresh();`
	`133`	`+ if ( mParent )`
	`134`	`+ mParent->refresh();`
`133`	`135`	`}`
`134`	`136`
`135`	`137`	`void QgsPGConnectionItem::refreshConnection()`
`@@ -248,7 +250,8 @@ void QgsPGLayerItem::deleteLayer()`
`248`	`250`	`else`
`249`	`251`	`{`
`250`	`252`	`QMessageBox::information( 0, tr( "Delete layer" ), tr( "Layer deleted successfully." ) );`
`251`		`- mParent->refresh();`
	`253`	`+ if ( mParent )`
	`254`	`+ mParent->refresh();`
`252`	`255`	`}`
`253`	`256`	`}`
`254`	`257`