Index: activity.module
===================================================================
--- activity.module     (revision 2298)
+++ activity.module     (working copy)
@@ -344,7 +344,7 @@
   }
 
   if ($op == 'publish') {
-    $rows = db_query("SELECT a.aid, a.status as activity_status, u.status as user_status, n.status as node_status FROM {activity} a INNER JOIN {users} u ON a.uid = u.uid INNER JOIN {node} n ON a.nid = n.nid WHERE a.uid <> 0 AND a.type = 'comment' AND a.eid = %d", $comment['cid']);
+    $rows = db_query("SELECT a.aid, a.status as activity_status, u.status as user_status, n.status as node_status FROM {activity} a INNER JOIN {users} u ON a.uid = u.uid INNER JOIN {node} n ON a.nid = n.nid WHERE a.eid = %d AND a.type = 'comment' AND a.uid <> 0", $comment['cid']);
 
     $update_statuses = array();
 
@@ -383,7 +383,7 @@
 
   if ($op == 'update') {
     // Find all the Activities for this node and determine status bit for each.
-    $db_result = db_query("SELECT a.aid, u.status as user_status, a.status as activity_status FROM {activity} a INNER JOIN {users} u ON u.uid = a.uid WHERE a.uid <> 0 AND a.nid = %d", $node->nid);
+    $db_result = db_query("SELECT a.aid, u.status as user_status, a.status as activity_status FROM {activity} a INNER JOIN {users} u ON u.uid = a.uid WHERE a.nid = %d AND a.uid <> 0", $node->nid);
 
     $update_statuses = array();
     while ($row = db_fetch_object($db_result)) {
@@ -1080,4 +1080,4 @@
   $vars['node_title'] = check_plain($item->node_title);
   $vars['node_link'] = check_url(url('node/'. $item->node_nid, array('absolute' => TRUE)));
   $vars['created'] = date('D, d M Y H:i:s O', $item->created);
-}
\ No newline at end of file
+}
Index: activity.install
===================================================================
--- activity.install    (revision 2298)
+++ activity.install    (working copy)
@@ -74,6 +74,8 @@
       'eid' => array('eid'),
       'created' => array('created'), // Probably not at all useful.
       'actions_id' => array('actions_id'),
+      'eid_type_uid' => array('eid', 'type', 'uid'),
+      'nid_uid' => array('nid', 'uid'),
     ),
   );
   
@@ -262,4 +264,14 @@
  );
 
   return $ret;
-}
\ No newline at end of file
+}
+
+/**
+ * Add indexes to {activity}.
+ */
+function activity_update_6204() {
+  $ret = array();
+  db_add_index($ret, 'activity', 'eid_type_uid', array('eid', 'type', 'uid'));
+  db_add_index($ret, 'activity', 'nid_uid', array('nid', 'uid'));
+  return $ret;
+}