|
@@ 533-538 (lines=6) @@
|
| 530 |
|
} |
| 531 |
|
|
| 532 |
|
// Queue it |
| 533 |
|
if ( !$trx->addItem( $text, $row->bt_text_id ) ) { |
| 534 |
|
$this->debug( "$titleText: committing blob with " . $trx->getSize() . " items" ); |
| 535 |
|
$trx->commit(); |
| 536 |
|
$trx = new CgzCopyTransaction( $this, $this->pageBlobClass ); |
| 537 |
|
$lbFactory->waitForReplication(); |
| 538 |
|
} |
| 539 |
|
} |
| 540 |
|
} |
| 541 |
|
|
|
@@ 685-690 (lines=6) @@
|
| 682 |
|
continue; |
| 683 |
|
} |
| 684 |
|
|
| 685 |
|
if ( !$trx->addItem( $text, $row->old_id ) ) { |
| 686 |
|
$this->debug( "[orphan]: committing blob with " . $trx->getSize() . " rows" ); |
| 687 |
|
$trx->commit(); |
| 688 |
|
$trx = new CgzCopyTransaction( $this, $this->orphanBlobClass ); |
| 689 |
|
$lbFactory->waitForReplication(); |
| 690 |
|
} |
| 691 |
|
} |
| 692 |
|
$this->debug( "[orphan]: committing blob with " . $trx->getSize() . " rows" ); |
| 693 |
|
$trx->commit(); |