server-info.con commit Merge branch 'maint' (208f689)
   1#include "cache.h"
   2#include "refs.h"
   3#include "object.h"
   4#include "commit.h"
   5#include "tag.h"
   6
   7/* refs */
   8static FILE *info_ref_fp;
   9
  10static int add_info_ref(const char *path, const unsigned char *sha1, int flag, void *cb_data)
  11{
  12        struct object *o = parse_object(sha1);
  13        if (!o)
  14                return -1;
  15
  16        fprintf(info_ref_fp, "%s        %s\n", sha1_to_hex(sha1), path);
  17        if (o->type == OBJ_TAG) {
  18                o = deref_tag(o, path, 0);
  19                if (o)
  20                        fprintf(info_ref_fp, "%s        %s^{}\n",
  21                                sha1_to_hex(o->sha1), path);
  22        }
  23        return 0;
  24}
  25
  26static int update_info_refs(int force)
  27{
  28        char *path0 = xstrdup(git_path("info/refs"));
  29        int len = strlen(path0);
  30        char *path1 = xmalloc(len + 2);
  31
  32        strcpy(path1, path0);
  33        strcpy(path1 + len, "+");
  34
  35        safe_create_leading_directories(path0);
  36        info_ref_fp = fopen(path1, "w");
  37        if (!info_ref_fp)
  38                return error("unable to update %s", path1);
  39        for_each_ref(add_info_ref, NULL);
  40        fclose(info_ref_fp);
  41        adjust_shared_perm(path1);
  42        rename(path1, path0);
  43        free(path0);
  44        free(path1);
  45        return 0;
  46}
  47
  48/* packs */
  49static struct pack_info {
  50        struct packed_git *p;
  51        int old_num;
  52        int new_num;
  53        int nr_alloc;
  54        int nr_heads;
  55        unsigned char (*head)[20];
  56} **info;
  57static int num_pack;
  58static const char *objdir;
  59static int objdirlen;
  60
  61static struct pack_info *find_pack_by_name(const char *name)
  62{
  63        int i;
  64        for (i = 0; i < num_pack; i++) {
  65                struct packed_git *p = info[i]->p;
  66                /* skip "/pack/" after ".git/objects" */
  67                if (!strcmp(p->pack_name + objdirlen + 6, name))
  68                        return info[i];
  69        }
  70        return NULL;
  71}
  72
  73/* Returns non-zero when we detect that the info in the
  74 * old file is useless.
  75 */
  76static int parse_pack_def(const char *line, int old_cnt)
  77{
  78        struct pack_info *i = find_pack_by_name(line + 2);
  79        if (i) {
  80                i->old_num = old_cnt;
  81                return 0;
  82        }
  83        else {
  84                /* The file describes a pack that is no longer here */
  85                return 1;
  86        }
  87}
  88
  89/* Returns non-zero when we detect that the info in the
  90 * old file is useless.
  91 */
  92static int read_pack_info_file(const char *infofile)
  93{
  94        FILE *fp;
  95        char line[1000];
  96        int old_cnt = 0;
  97
  98        fp = fopen(infofile, "r");
  99        if (!fp)
 100                return 1; /* nonexistent is not an error. */
 101
 102        while (fgets(line, sizeof(line), fp)) {
 103                int len = strlen(line);
 104                if (len && line[len-1] == '\n')
 105                        line[--len] = 0;
 106
 107                if (!len)
 108                        continue;
 109
 110                switch (line[0]) {
 111                case 'P': /* P name */
 112                        if (parse_pack_def(line, old_cnt++))
 113                                goto out_stale;
 114                        break;
 115                case 'D': /* we used to emit D but that was misguided. */
 116                        goto out_stale;
 117                        break;
 118                case 'T': /* we used to emit T but nobody uses it. */
 119                        goto out_stale;
 120                        break;
 121                default:
 122                        error("unrecognized: %s", line);
 123                        break;
 124                }
 125        }
 126        fclose(fp);
 127        return 0;
 128 out_stale:
 129        fclose(fp);
 130        return 1;
 131}
 132
 133static int compare_info(const void *a_, const void *b_)
 134{
 135        struct pack_info * const* a = a_;
 136        struct pack_info * const* b = b_;
 137
 138        if (0 <= (*a)->old_num && 0 <= (*b)->old_num)
 139                /* Keep the order in the original */
 140                return (*a)->old_num - (*b)->old_num;
 141        else if (0 <= (*a)->old_num)
 142                /* Only A existed in the original so B is obviously newer */
 143                return -1;
 144        else if (0 <= (*b)->old_num)
 145                /* The other way around. */
 146                return 1;
 147
 148        /* then it does not matter but at least keep the comparison stable */
 149        if ((*a)->p == (*b)->p)
 150                return 0;
 151        else if ((*a)->p < (*b)->p)
 152                return -1;
 153        else
 154                return 1;
 155}
 156
 157static void init_pack_info(const char *infofile, int force)
 158{
 159        struct packed_git *p;
 160        int stale;
 161        int i = 0;
 162
 163        objdir = get_object_directory();
 164        objdirlen = strlen(objdir);
 165
 166        prepare_packed_git();
 167        for (p = packed_git; p; p = p->next) {
 168                /* we ignore things on alternate path since they are
 169                 * not available to the pullers in general.
 170                 */
 171                if (!p->pack_local)
 172                        continue;
 173                i++;
 174        }
 175        num_pack = i;
 176        info = xcalloc(num_pack, sizeof(struct pack_info *));
 177        for (i = 0, p = packed_git; p; p = p->next) {
 178                if (!p->pack_local)
 179                        continue;
 180                info[i] = xcalloc(1, sizeof(struct pack_info));
 181                info[i]->p = p;
 182                info[i]->old_num = -1;
 183                i++;
 184        }
 185
 186        if (infofile && !force)
 187                stale = read_pack_info_file(infofile);
 188        else
 189                stale = 1;
 190
 191        for (i = 0; i < num_pack; i++) {
 192                if (stale) {
 193                        info[i]->old_num = -1;
 194                        info[i]->nr_heads = 0;
 195                }
 196        }
 197
 198        /* renumber them */
 199        qsort(info, num_pack, sizeof(info[0]), compare_info);
 200        for (i = 0; i < num_pack; i++)
 201                info[i]->new_num = i;
 202}
 203
 204static void write_pack_info_file(FILE *fp)
 205{
 206        int i;
 207        for (i = 0; i < num_pack; i++)
 208                fprintf(fp, "P %s\n", info[i]->p->pack_name + objdirlen + 6);
 209        fputc('\n', fp);
 210}
 211
 212static int update_info_packs(int force)
 213{
 214        char infofile[PATH_MAX];
 215        char name[PATH_MAX];
 216        int namelen;
 217        FILE *fp;
 218
 219        namelen = sprintf(infofile, "%s/info/packs", get_object_directory());
 220        strcpy(name, infofile);
 221        strcpy(name + namelen, "+");
 222
 223        init_pack_info(infofile, force);
 224
 225        safe_create_leading_directories(name);
 226        fp = fopen(name, "w");
 227        if (!fp)
 228                return error("cannot open %s", name);
 229        write_pack_info_file(fp);
 230        fclose(fp);
 231        adjust_shared_perm(name);
 232        rename(name, infofile);
 233        return 0;
 234}
 235
 236/* public */
 237int update_server_info(int force)
 238{
 239        /* We would add more dumb-server support files later,
 240         * including index of available pack files and their
 241         * intended audiences.
 242         */
 243        int errs = 0;
 244
 245        errs = errs | update_info_refs(force);
 246        errs = errs | update_info_packs(force);
 247
 248        /* remove leftover rev-cache file if there is any */
 249        unlink(git_path("info/rev-cache"));
 250
 251        return errs;
 252}