diff --git a/scripts/repository/rebuild_summaries.php b/scripts/repository/rebuild_summaries.php
index 524979aeb8..68fa69ecc3 100755
--- a/scripts/repository/rebuild_summaries.php
+++ b/scripts/repository/rebuild_summaries.php
@@ -1,74 +1,74 @@
 #!/usr/bin/env php
 <?php
 
 /*
  * Copyright 2011 Facebook, Inc.
  *
  * Licensed under the Apache License, Version 2.0 (the "License");
  * you may not use this file except in compliance with the License.
  * You may obtain a copy of the License at
  *
  *   http://www.apache.org/licenses/LICENSE-2.0
  *
  * Unless required by applicable law or agreed to in writing, software
  * distributed under the License is distributed on an "AS IS" BASIS,
  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
 
 $root = dirname(dirname(dirname(__FILE__)));
 require_once $root.'/scripts/__init_script__.php';
 require_once $root.'/scripts/__init_env__.php';
 
 phutil_require_module('phutil', 'symbols');
 PhutilSymbolLoader::loadClass('PhabricatorRepository');
 PhutilSymbolLoader::loadClass('PhabricatorRepositoryCommit');
 
 $commit = new PhabricatorRepositoryCommit();
 
-$conn_w = id(new PhabricatorRepository())->establishConnection('r');
+$conn_w = id(new PhabricatorRepository())->establishConnection('w');
 $sizes = queryfx_all(
   $conn_w,
   'SELECT repositoryID, count(*) N FROM %T GROUP BY repositoryID',
   $commit->getTableName());
 $sizes = ipull($sizes, 'N', 'repositoryID');
 
 $maxes = queryfx_all(
   $conn_w,
   'SELECT repositoryID, max(epoch) maxEpoch FROM %T GROUP BY repositoryID',
   $commit->getTableName());
 $maxes = ipull($maxes, 'maxEpoch', 'repositoryID');
 
 
 $repository_ids = array_keys($sizes + $maxes);
 
 echo "Updating ".count($repository_ids)." repositories";
 
 foreach ($repository_ids as $repository_id) {
   $last_commit = queryfx_one(
     $conn_w,
     'SELECT id FROM %T WHERE repositoryID = %d AND epoch = %d LIMIT 1',
     $commit->getTableName(),
     $repository_id,
     idx($maxes, $repository_id, 0));
   if ($last_commit) {
     $last_commit = $last_commit['id'];
   } else {
     $last_commit = 0;
   }
   queryfx(
     $conn_w,
     'INSERT INTO %T (repositoryID, lastCommitID, size, epoch)
       VALUES (%d, %d, %d, %d) ON DUPLICATE KEY UPDATE
         lastCommitID = VALUES(lastCommitID),
         size = VALUES(size),
         epoch = VALUES(epoch)',
     PhabricatorRepository::TABLE_SUMMARY,
     $repository_id,
     $last_commit,
     idx($sizes, $repository_id, 0),
     idx($maxes, $repository_id, 0));
   echo ".";
 }
 echo "\ndone.\n";
diff --git a/src/applications/repository/daemon/commitdiscovery/base/PhabricatorRepositoryCommitDiscoveryDaemon.php b/src/applications/repository/daemon/commitdiscovery/base/PhabricatorRepositoryCommitDiscoveryDaemon.php
index 490094392e..49a32a023a 100644
--- a/src/applications/repository/daemon/commitdiscovery/base/PhabricatorRepositoryCommitDiscoveryDaemon.php
+++ b/src/applications/repository/daemon/commitdiscovery/base/PhabricatorRepositoryCommitDiscoveryDaemon.php
@@ -1,106 +1,106 @@
 <?php
 
 /*
  * Copyright 2011 Facebook, Inc.
  *
  * Licensed under the Apache License, Version 2.0 (the "License");
  * you may not use this file except in compliance with the License.
  * You may obtain a copy of the License at
  *
  *   http://www.apache.org/licenses/LICENSE-2.0
  *
  * Unless required by applicable law or agreed to in writing, software
  * distributed under the License is distributed on an "AS IS" BASIS,
  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
 
 abstract class PhabricatorRepositoryCommitDiscoveryDaemon
   extends PhabricatorRepositoryDaemon {
 
   private $repository;
   private $commitCache = array();
 
   final protected function getRepository() {
     return $this->repository;
   }
 
   final public function run() {
     $this->repository = $this->loadRepository();
 
     $sleep = $this->repository->getDetail('pull-frequency');
     while (true) {
       $this->discoverCommits();
       $this->sleep(max(2, $sleep));
     }
   }
 
   protected function isKnownCommit($target) {
     if (isset($this->commitCache[$target])) {
       return true;
     }
 
     $commit = id(new PhabricatorRepositoryCommit())->loadOneWhere(
       'repositoryID = %s AND commitIdentifier = %s',
       $this->getRepository()->getID(),
       $target);
 
     if (!$commit) {
       return false;
     }
 
     $this->commitCache[$target] = true;
     while (count($this->commitCache) > 64) {
       array_shift($this->commitCache);
     }
 
     return true;
   }
 
   protected function recordCommit($commit_identifier, $epoch) {
     $repository = $this->getRepository();
 
     $commit = new PhabricatorRepositoryCommit();
     $commit->setRepositoryID($repository->getID());
     $commit->setCommitIdentifier($commit_identifier);
     $commit->setEpoch($epoch);
 
     try {
       $commit->save();
       $event = new PhabricatorTimelineEvent(
         'cmit',
         array(
           'id' => $commit->getID(),
         ));
       $event->recordEvent();
 
       queryfx(
-        $repository->establishConnection('r'),
+        $repository->establishConnection('w'),
         'INSERT INTO %T (repositoryID, size, lastCommitID, epoch)
           VALUES (%d, 1, %d, %d)
           ON DUPLICATE KEY UPDATE
             size = size + 1,
             lastCommitID =
               IF(VALUES(epoch) > epoch, VALUES(lastCommitID), lastCommitID),
             epoch = IF(VALUES(epoch) > epoch, VALUES(epoch), epoch)',
         PhabricatorRepository::TABLE_SUMMARY,
         $repository->getID(),
         $commit->getID(),
         $epoch);
 
       $this->commitCache[$commit_identifier] = true;
     } catch (AphrontQueryDuplicateKeyException $ex) {
       // Ignore. This can happen because we discover the same new commit
       // more than once when looking at history, or because of races or
       // data inconsistency or cosmic radiation; in any case, we're still
       // in a good state if we ignore the failure.
       $this->commitCache[$commit_identifier] = true;
     }
 
     $this->stillWorking();
   }
 
   abstract protected function discoverCommits();
 
 }
diff --git a/src/applications/repository/worker/commitmessageparser/base/PhabricatorRepositoryCommitMessageParserWorker.php b/src/applications/repository/worker/commitmessageparser/base/PhabricatorRepositoryCommitMessageParserWorker.php
index 518e34d718..794a0d16b6 100644
--- a/src/applications/repository/worker/commitmessageparser/base/PhabricatorRepositoryCommitMessageParserWorker.php
+++ b/src/applications/repository/worker/commitmessageparser/base/PhabricatorRepositoryCommitMessageParserWorker.php
@@ -1,71 +1,71 @@
 <?php
 
 /*
  * Copyright 2011 Facebook, Inc.
  *
  * Licensed under the Apache License, Version 2.0 (the "License");
  * you may not use this file except in compliance with the License.
  * You may obtain a copy of the License at
  *
  *   http://www.apache.org/licenses/LICENSE-2.0
  *
  * Unless required by applicable law or agreed to in writing, software
  * distributed under the License is distributed on an "AS IS" BASIS,
  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
 
 abstract class PhabricatorRepositoryCommitMessageParserWorker
   extends PhabricatorRepositoryCommitParserWorker {
 
   final protected function updateCommitData($author, $message) {
     $commit = $this->commit;
 
     $data = id(new PhabricatorRepositoryCommitData())->loadOneWhere(
       'commitID = %d',
       $commit->getID());
     if (!$data) {
       $data = new PhabricatorRepositoryCommitData();
     }
     $data->setCommitID($commit->getID());
     $data->setAuthorName($author);
     $data->setCommitMessage($message);
 
     $repository = $this->repository;
     $detail_parser = $repository->getDetail(
       'detail-parser',
       'PhabricatorRepositoryDefaultCommitMessageDetailParser');
 
     if ($detail_parser) {
       PhutilSymbolLoader::loadClass($detail_parser);
       $parser_obj = newv($detail_parser, array($commit, $data));
       $parser_obj->parseCommitDetails();
     }
 
     $data->save();
 
     $revision_id = $data->getCommitDetail('differential.revisionID');
     if ($revision_id) {
       $revision = id(new DifferentialRevision())->load($revision_id);
       if ($revision) {
 
         queryfx(
-          $revision->establishConnection('r'),
+          $revision->establishConnection('w'),
           'INSERT IGNORE INTO %T (revisionID, commitPHID) VALUES (%d, %s)',
           DifferentialRevision::TABLE_COMMIT,
           $revision->getID(),
           $commit->getPHID());
 
         if ($revision->getStatus() != DifferentialRevisionStatus::COMMITTED) {
           $editor = new DifferentialCommentEditor(
             $revision,
             $revision->getAuthorPHID(),
             DifferentialAction::ACTION_COMMIT);
           $editor->save();
         }
       }
     }
   }
 
 }