09/58402769ce603e0f27f0fff2e8c23012d1b93e

   1 Return-Path: <aclements@csail.mit.edu>\r
   2 X-Original-To: notmuch@notmuchmail.org\r
   3 Delivered-To: notmuch@notmuchmail.org\r
   4 Received: from localhost (localhost [127.0.0.1])\r
   5         by olra.theworths.org (Postfix) with ESMTP id 1CF58431FC9\r
   6         for <notmuch@notmuchmail.org>; Fri,  3 Oct 2014 07:19:51 -0700 (PDT)\r
   7 X-Virus-Scanned: Debian amavisd-new at olra.theworths.org\r
   8 X-Spam-Flag: NO\r
   9 X-Spam-Score: -2.3\r
  10 X-Spam-Level: \r
  11 X-Spam-Status: No, score=-2.3 tagged_above=-999 required=5\r
  12         tests=[RCVD_IN_DNSWL_MED=-2.3] autolearn=disabled\r
  13 Received: from olra.theworths.org ([127.0.0.1])\r
  14         by localhost (olra.theworths.org [127.0.0.1]) (amavisd-new, port 10024)\r
  15         with ESMTP id 4BS46qkmBdwK for <notmuch@notmuchmail.org>;\r
  16         Fri,  3 Oct 2014 07:19:45 -0700 (PDT)\r
  17 Received: from dmz-mailsec-scanner-3.mit.edu (dmz-mailsec-scanner-3.mit.edu\r
  18         [18.9.25.14])\r
  19         (using TLSv1 with cipher DHE-RSA-AES256-SHA (256/256 bits))\r
  20         (No client certificate requested)\r
  21         by olra.theworths.org (Postfix) with ESMTPS id A4DFF431FD4\r
  22         for <notmuch@notmuchmail.org>; Fri,  3 Oct 2014 07:19:26 -0700 (PDT)\r
  23 X-AuditID: 1209190e-f79d46d000003643-1c-542eb06db730\r
  24 Received: from mailhub-auth-2.mit.edu ( [18.7.62.36])\r
  25         (using TLS with cipher AES256-SHA (256/256 bits))\r
  26         (Client did not present a certificate)\r
  27         by dmz-mailsec-scanner-3.mit.edu (Symantec Messaging Gateway) with SMTP\r
  28         id 11.C6.13891.D60BE245; Fri,  3 Oct 2014 10:19:25 -0400 (EDT)\r
  29 Received: from outgoing.mit.edu (outgoing-auth-1.mit.edu [18.9.28.11])\r
  30         by mailhub-auth-2.mit.edu (8.13.8/8.9.2) with ESMTP id s93EJOum021145; \r
  31         Fri, 3 Oct 2014 10:19:24 -0400\r
  32 Received: from drake.dyndns.org\r
  33         (216-15-114-40.c3-0.arl-ubr1.sbo-arl.ma.cable.rcn.com\r
  34         [216.15.114.40]) (authenticated bits=0)\r
  35         (User authenticated as amdragon@ATHENA.MIT.EDU)\r
  36         by outgoing.mit.edu (8.13.8/8.12.4) with ESMTP id s93EJLOT023308\r
  37         (version=TLSv1/SSLv3 cipher=AES128-SHA bits=128 verify=NOT);\r
  38         Fri, 3 Oct 2014 10:19:24 -0400\r
  39 Received: from amthrax by drake.dyndns.org with local (Exim 4.84)\r
  40         (envelope-from <aclements@csail.mit.edu>)\r
  41         id 1Xa3hZ-0002Jc-0V; Fri, 03 Oct 2014 10:19:21 -0400\r
  42 From: Austin Clements <aclements@csail.mit.edu>\r
  43 To: notmuch@notmuchmail.org\r
  44 Subject: [PATCH 02/11] lib: Refactor _notmuch_database_link_message\r
  45 Date: Fri,  3 Oct 2014 10:19:09 -0400\r
  46 Message-Id: <1412345958-8278-3-git-send-email-aclements@csail.mit.edu>\r
  47 X-Mailer: git-send-email 2.1.0\r
  48 In-Reply-To: <1412345958-8278-1-git-send-email-aclements@csail.mit.edu>\r
  49 References: <1412345958-8278-1-git-send-email-aclements@csail.mit.edu>\r
  50 X-Brightmail-Tracker:\r
  51  H4sIAAAAAAAAA+NgFtrAIsWRmVeSWpSXmKPExsUixG6nopu7QS/E4MIxC4vrN2cyOzB6PFt1\r
  52         izmAMYrLJiU1J7MstUjfLoEr48JShYJmuYpl8zezNzBuFu9i5OSQEDCRODxpBzuELSZx4d56\r
  53         ti5GLg4hgdlMEpNuHYByNjBKHPmxiR3Cuc0kcWXBHlaQFiGBJYwS0ydpgdhsAvoSK9ZOAouL\r
  54         CEhL7Lw7G8jm4GAWUJP406UCYgoLOEt836ECUsEioCqxdOsqsMW8Am4SK548YoY4Qk5iw+7/\r
  55         jCA2p4C7xIW7T9kgNrlJrDrWzTaBkX8BI8MqRtmU3Crd3MTMnOLUZN3i5MS8vNQiXWO93MwS\r
  56         vdSU0k2MoIDhlOTbwfj1oNIhRgEORiUe3g83dEOEWBPLiitzDzFKcjApifJWLtYLEeJLyk+p\r
  57         zEgszogvKs1JLT7EKMHBrCTCu2AlUI43JbGyKrUoHyYlzcGiJM676QdfiJBAemJJanZqakFq\r
  58         EUxWhoNDSYK3fT1Qo2BRanpqRVpmTglCmomDE2Q4D9BwsBre4oLE3OLMdIj8KUZFKXHeh+uA\r
  59         EgIgiYzSPLheWES/YhQHekWYtwuknQeYDOC6XwENZgIa/M5eF2RwSSJCSqqBccHSqXas/0V8\r
  60         WB0C7DjjdnoxB7t7/tzwKfH7tAWvDQ09NBZIz/OoE97CE7ivNzmzsuXiyV81j9Y3fQ9JvLQh\r
  61         Ln3V4rtMN5e9/ZPRxGqsIaqxZPati6kBm5j2vFS4+2RRC4+0aMqh0/7/SnLC1fTX8G03cBIy\r
  62         ZRTq4Xyhcs7igMDjKYJinZf6lViKMxINtZiLihMBKo+WW8MCAAA=\r
  63 X-BeenThere: notmuch@notmuchmail.org\r
  64 X-Mailman-Version: 2.1.13\r
  65 Precedence: list\r
  66 List-Id: "Use and development of the notmuch mail system."\r
  67         <notmuch.notmuchmail.org>\r
  68 List-Unsubscribe: <http://notmuchmail.org/mailman/options/notmuch>,\r
  69         <mailto:notmuch-request@notmuchmail.org?subject=unsubscribe>\r
  70 List-Archive: <http://notmuchmail.org/pipermail/notmuch>\r
  71 List-Post: <mailto:notmuch@notmuchmail.org>\r
  72 List-Help: <mailto:notmuch-request@notmuchmail.org?subject=help>\r
  73 List-Subscribe: <http://notmuchmail.org/mailman/listinfo/notmuch>,\r
  74         <mailto:notmuch-request@notmuchmail.org?subject=subscribe>\r
  75 X-List-Received-Date: Fri, 03 Oct 2014 14:19:51 -0000\r
  76 \r
  77 From: Austin Clements <amdragon@mit.edu>\r
  78 \r
  79 This moves the code to retrieve and clear the metadata thread ID out\r
  80 of _notmuch_database_link_message into its own function.  This will\r
  81 simplify future changes.\r
  82 ---\r
  83  lib/database.cc | 69 +++++++++++++++++++++++++++++++++++----------------------\r
  84  1 file changed, 43 insertions(+), 26 deletions(-)\r
  85 \r
  86 diff --git a/lib/database.cc b/lib/database.cc\r
  87 index 4e68706..1c6ffc5 100644\r
  88 --- a/lib/database.cc\r
  89 +++ b/lib/database.cc\r
  90 @@ -1958,6 +1958,37 @@ _notmuch_database_link_message_to_children (notmuch_database_t *notmuch,\r
  91      return ret;\r
  92  }\r
  93  \r
  94 +/* Fetch and clear the stored thread_id for message, or NULL if none. */\r
  95 +static char *\r
  96 +_consume_metadata_thread_id (void *ctx, notmuch_database_t *notmuch,\r
  97 +                            notmuch_message_t *message)\r
  98 +{\r
  99 +    const char *message_id;\r
 100 +    string stored_id;\r
 101 +    char *metadata_key;\r
 102 +\r
 103 +    message_id = notmuch_message_get_message_id (message);\r
 104 +    metadata_key = _get_metadata_thread_id_key (ctx, message_id);\r
 105 +\r
 106 +    /* Check if we have already seen related messages to this one.\r
 107 +     * If we have then use the thread_id that we stored at that time.\r
 108 +     */\r
 109 +    stored_id = notmuch->xapian_db->get_metadata (metadata_key);\r
 110 +    if (stored_id.empty ()) {\r
 111 +       return NULL;\r
 112 +    } else {\r
 113 +        Xapian::WritableDatabase *db;\r
 114 +\r
 115 +       db = static_cast <Xapian::WritableDatabase *> (notmuch->xapian_db);\r
 116 +\r
 117 +       /* Clear the metadata for this message ID. We don't need it\r
 118 +        * anymore. */\r
 119 +        db->set_metadata (metadata_key, "");\r
 120 +\r
 121 +        return talloc_strdup (ctx, stored_id.c_str ());\r
 122 +    }\r
 123 +}\r
 124 +\r
 125  /* Given a (mostly empty) 'message' and its corresponding\r
 126   * 'message_file' link it to existing threads in the database.\r
 127   *\r
 128 @@ -1988,42 +2019,25 @@ _notmuch_database_link_message (notmuch_database_t *notmuch,\r
 129                                 notmuch_message_t *message,\r
 130                                 notmuch_message_file_t *message_file)\r
 131  {\r
 132 +    void *local = talloc_new (NULL);\r
 133      notmuch_status_t status;\r
 134 -    const char *message_id, *thread_id = NULL;\r
 135 -    char *metadata_key;\r
 136 -    string stored_id;\r
 137 -\r
 138 -    message_id = notmuch_message_get_message_id (message);\r
 139 -    metadata_key = _get_metadata_thread_id_key (message, message_id);\r
 140 -\r
 141 -    /* Check if we have already seen related messages to this one.\r
 142 -     * If we have then use the thread_id that we stored at that time.\r
 143 -     */\r
 144 -    stored_id = notmuch->xapian_db->get_metadata (metadata_key);\r
 145 -    if (! stored_id.empty()) {\r
 146 -        Xapian::WritableDatabase *db;\r
 147 -\r
 148 -       db = static_cast <Xapian::WritableDatabase *> (notmuch->xapian_db);\r
 149 -\r
 150 -       /* Clear the metadata for this message ID. We don't need it\r
 151 -        * anymore. */\r
 152 -        db->set_metadata (metadata_key, "");\r
 153 -        thread_id = stored_id.c_str();\r
 154 +    const char *thread_id;\r
 155  \r
 156 -        _notmuch_message_add_term (message, "thread", thread_id);\r
 157 -    }\r
 158 -    talloc_free (metadata_key);\r
 159 +    /* Check if the message already had a thread ID */\r
 160 +    thread_id = _consume_metadata_thread_id (local, notmuch, message);\r
 161 +    if (thread_id)\r
 162 +       _notmuch_message_add_term (message, "thread", thread_id);\r
 163  \r
 164      status = _notmuch_database_link_message_to_parents (notmuch, message,\r
 165                                                         message_file,\r
 166                                                         &thread_id);\r
 167      if (status)\r
 168 -       return status;\r
 169 +       goto DONE;\r
 170  \r
 171      status = _notmuch_database_link_message_to_children (notmuch, message,\r
 172                                                          &thread_id);\r
 173      if (status)\r
 174 -       return status;\r
 175 +       goto DONE;\r
 176  \r
 177      /* If not part of any existing thread, generate a new thread ID. */\r
 178      if (thread_id == NULL) {\r
 179 @@ -2032,7 +2046,10 @@ _notmuch_database_link_message (notmuch_database_t *notmuch,\r
 180         _notmuch_message_add_term (message, "thread", thread_id);\r
 181      }\r
 182  \r
 183 -    return NOTMUCH_STATUS_SUCCESS;\r
 184 + DONE:\r
 185 +    talloc_free (local);\r
 186 +\r
 187 +    return status;\r
 188  }\r
 189  \r
 190  notmuch_status_t\r
 191 -- \r
 192 2.1.0\r
 193 \r