source src/merge_driver.c
| Line | Flow | Count | Block(s) | Source |
|---|---|---|---|---|
| 1 | - | /* | ||
| 2 | - | * Copyright (C) the libgit2 contributors. All rights reserved. | ||
| 3 | - | * | ||
| 4 | - | * This file is part of libgit2, distributed under the GNU GPL v2 with | ||
| 5 | - | * a Linking Exception. For full terms see the included COPYING file. | ||
| 6 | - | */ | ||
| 7 | - | |||
| 8 | - | #include "merge_driver.h" | ||
| 9 | - | |||
| 10 | - | #include "vector.h" | ||
| 11 | - | #include "global.h" | ||
| 12 | - | #include "merge.h" | ||
| 13 | - | #include "git2/merge.h" | ||
| 14 | - | #include "git2/sys/merge.h" | ||
| 15 | - | |||
| 16 | - | static const char *merge_driver_name__text = "text"; | ||
| 17 | - | static const char *merge_driver_name__union = "union"; | ||
| 18 | - | static const char *merge_driver_name__binary = "binary"; | ||
| 19 | - | |||
| 20 | - | struct merge_driver_registry { | ||
| 21 | - | git_rwlock lock; | ||
| 22 | - | git_vector drivers; | ||
| 23 | - | }; | ||
| 24 | - | |||
| 25 | - | typedef struct { | ||
| 26 | - | git_merge_driver *driver; | ||
| 27 | - | int initialized; | ||
| 28 | - | char name[GIT_FLEX_ARRAY]; | ||
| 29 | - | } git_merge_driver_entry; | ||
| 30 | - | |||
| 31 | - | static struct merge_driver_registry merge_driver_registry; | ||
| 32 | - | |||
| 33 | - | static void git_merge_driver_global_shutdown(void); | ||
| 34 | - | |||
| 35 | ##### | 2 | git_repository* git_merge_driver_source_repo(const git_merge_driver_source *src) | |
| 36 | - | { | ||
| 37 | ##### | 2,3 | assert(src); | |
| 38 | ##### | 4 | return src->repo; | |
| 39 | - | } | ||
| 40 | - | |||
| 41 | ##### | 2 | const git_index_entry* git_merge_driver_source_ancestor(const git_merge_driver_source *src) | |
| 42 | - | { | ||
| 43 | ##### | 2,3 | assert(src); | |
| 44 | ##### | 4 | return src->ancestor; | |
| 45 | - | } | ||
| 46 | - | |||
| 47 | ##### | 2 | const git_index_entry* git_merge_driver_source_ours(const git_merge_driver_source *src) | |
| 48 | - | { | ||
| 49 | ##### | 2,3 | assert(src); | |
| 50 | ##### | 4 | return src->ours; | |
| 51 | - | } | ||
| 52 | - | |||
| 53 | ##### | 2 | const git_index_entry* git_merge_driver_source_theirs(const git_merge_driver_source *src) | |
| 54 | - | { | ||
| 55 | ##### | 2,3 | assert(src); | |
| 56 | ##### | 4 | return src->theirs; | |
| 57 | - | } | ||
| 58 | - | |||
| 59 | ##### | 2 | const git_merge_file_options* git_merge_driver_source_file_options(const git_merge_driver_source *src) | |
| 60 | - | { | ||
| 61 | ##### | 2,3 | assert(src); | |
| 62 | ##### | 4 | return src->file_opts; | |
| 63 | - | } | ||
| 64 | - | |||
| 65 | ![]() |
307 | 2 | int git_merge_driver__builtin_apply( |
| 66 | - | git_merge_driver *self, | ||
| 67 | - | const char **path_out, | ||
| 68 | - | uint32_t *mode_out, | ||
| 69 | - | git_buf *merged_out, | ||
| 70 | - | const char *filter_name, | ||
| 71 | - | const git_merge_driver_source *src) | ||
| 72 | - | { | ||
| 73 | 307 | 2 | git_merge_driver__builtin *driver = (git_merge_driver__builtin *)self; | |
| 74 | 307 | 2 | git_merge_file_options file_opts = GIT_MERGE_FILE_OPTIONS_INIT; | |
| 75 | 307 | 2 | git_merge_file_result result = {0}; | |
| 76 | - | int error; | ||
| 77 | - | |||
| 78 | - | GIT_UNUSED(filter_name); | ||
| 79 | - | |||
| 80 | 307 | 2 | if (src->file_opts) | |
| 81 | 307 | 3 | memcpy(&file_opts, src->file_opts, sizeof(git_merge_file_options)); | |
| 82 | - | |||
| 83 | 307 | 4 | if (driver->favor) | |
| 84 | 14 | 5 | file_opts.favor = driver->favor; | |
| 85 | - | |||
| 86 | 307 | 6,7 | if ((error = git_merge_file_from_index(&result, src->repo, | |
| 87 | - | src->ancestor, src->ours, src->theirs, &file_opts)) < 0) | ||
| 88 | ##### | 8 | goto done; | |
| 89 | - | |||
| 90 | 307 | 9,10 | if (!result.automergeable && | |
| 91 | 166 | 10 | !(file_opts.flags & GIT_MERGE_FILE_FAVOR__CONFLICTED)) { | |
| 92 | 155 | 11 | error = GIT_EMERGECONFLICT; | |
| 93 | 155 | 11 | goto done; | |
| 94 | - | } | ||
| 95 | - | |||
| 96 | 152 | 12-21 | *path_out = git_merge_file__best_path( | |
| 97 | 152 | 18,19 | src->ancestor ? src->ancestor->path : NULL, | |
| 98 | 152 | 15,16 | src->ours ? src->ours->path : NULL, | |
| 99 | 152 | 12,13 | src->theirs ? src->theirs->path : NULL); | |
| 100 | - | |||
| 101 | 152 | 22-31 | *mode_out = git_merge_file__best_mode( | |
| 102 | 152 | 28,29 | src->ancestor ? src->ancestor->mode : 0, | |
| 103 | 152 | 25,26 | src->ours ? src->ours->mode : 0, | |
| 104 | 152 | 22,23 | src->theirs ? src->theirs->mode : 0); | |
| 105 | - | |||
| 106 | 152 | 32 | merged_out->ptr = (char *)result.ptr; | |
| 107 | 152 | 32 | merged_out->size = result.len; | |
| 108 | 152 | 32 | merged_out->asize = result.len; | |
| 109 | 152 | 32 | result.ptr = NULL; | |
| 110 | - | |||
| 111 | - | done: | ||
| 112 | 307 | 33 | git_merge_file_result_free(&result); | |
| 113 | 307 | 34 | return error; | |
| 114 | - | } | ||
| 115 | - | |||
| 116 | 3 | 2 | static int merge_driver_binary_apply( | |
| 117 | - | git_merge_driver *self, | ||
| 118 | - | const char **path_out, | ||
| 119 | - | uint32_t *mode_out, | ||
| 120 | - | git_buf *merged_out, | ||
| 121 | - | const char *filter_name, | ||
| 122 | - | const git_merge_driver_source *src) | ||
| 123 | - | { | ||
| 124 | - | GIT_UNUSED(self); | ||
| 125 | - | GIT_UNUSED(path_out); | ||
| 126 | - | GIT_UNUSED(mode_out); | ||
| 127 | - | GIT_UNUSED(merged_out); | ||
| 128 | - | GIT_UNUSED(filter_name); | ||
| 129 | - | GIT_UNUSED(src); | ||
| 130 | - | |||
| 131 | 3 | 2 | return GIT_EMERGECONFLICT; | |
| 132 | - | } | ||
| 133 | - | |||
| 134 | 105 | 2 | static int merge_driver_entry_cmp(const void *a, const void *b) | |
| 135 | - | { | ||
| 136 | 105 | 2 | const git_merge_driver_entry *entry_a = a; | |
| 137 | 105 | 2 | const git_merge_driver_entry *entry_b = b; | |
| 138 | - | |||
| 139 | 105 | 2 | return strcmp(entry_a->name, entry_b->name); | |
| 140 | - | } | ||
| 141 | - | |||
| 142 | 238 | 2 | static int merge_driver_entry_search(const void *a, const void *b) | |
| 143 | - | { | ||
| 144 | 238 | 2 | const char *name_a = a; | |
| 145 | 238 | 2 | const git_merge_driver_entry *entry_b = b; | |
| 146 | - | |||
| 147 | 238 | 2 | return strcmp(name_a, entry_b->name); | |
| 148 | - | } | ||
| 149 | - | |||
| 150 | - | git_merge_driver__builtin git_merge_driver__text = { | ||
| 151 | - | { | ||
| 152 | - | GIT_MERGE_DRIVER_VERSION, | ||
| 153 | - | NULL, | ||
| 154 | - | NULL, | ||
| 155 | - | git_merge_driver__builtin_apply, | ||
| 156 | - | }, | ||
| 157 | - | GIT_MERGE_FILE_FAVOR_NORMAL | ||
| 158 | - | }; | ||
| 159 | - | |||
| 160 | - | git_merge_driver__builtin git_merge_driver__union = { | ||
| 161 | - | { | ||
| 162 | - | GIT_MERGE_DRIVER_VERSION, | ||
| 163 | - | NULL, | ||
| 164 | - | NULL, | ||
| 165 | - | git_merge_driver__builtin_apply, | ||
| 166 | - | }, | ||
| 167 | - | GIT_MERGE_FILE_FAVOR_UNION | ||
| 168 | - | }; | ||
| 169 | - | |||
| 170 | - | git_merge_driver git_merge_driver__binary = { | ||
| 171 | - | GIT_MERGE_DRIVER_VERSION, | ||
| 172 | - | NULL, | ||
| 173 | - | NULL, | ||
| 174 | - | merge_driver_binary_apply | ||
| 175 | - | }; | ||
| 176 | - | |||
| 177 | - | /* Note: callers must lock the registry before calling this function */ | ||
| 178 | 58 | 2 | static int merge_driver_registry_insert( | |
| 179 | - | const char *name, git_merge_driver *driver) | ||
| 180 | - | { | ||
| 181 | - | git_merge_driver_entry *entry; | ||
| 182 | - | |||
| 183 | 58 | 2 | entry = git__calloc(1, sizeof(git_merge_driver_entry) + strlen(name) + 1); | |
| 184 | 58 | 3,4 | GIT_ERROR_CHECK_ALLOC(entry); | |
| 185 | - | |||
| 186 | 58 | 5 | strcpy(entry->name, name); | |
| 187 | 58 | 5 | entry->driver = driver; | |
| 188 | - | |||
| 189 | 58 | 5 | return git_vector_insert_sorted( | |
| 190 | - | &merge_driver_registry.drivers, entry, NULL); | ||
| 191 | - | } | ||
| 192 | - | |||
| 193 | ![]() |
9 | 2 | int git_merge_driver_global_init(void) |
| 194 | - | { | ||
| 195 | - | int error; | ||
| 196 | - | |||
| 197 | 9 | 2,3 | if (git_rwlock_init(&merge_driver_registry.lock) < 0) | |
| 198 | ##### | 4 | return -1; | |
| 199 | - | |||
| 200 | 9 | 5,6 | if ((error = git_vector_init(&merge_driver_registry.drivers, 3, | |
| 201 | - | merge_driver_entry_cmp)) < 0) | ||
| 202 | ##### | 7 | goto done; | |
| 203 | - | |||
| 204 | 9 | 8,9 | if ((error = merge_driver_registry_insert( | |
| 205 | 9 | 10,11 | merge_driver_name__text, &git_merge_driver__text.base)) < 0 || | |
| 206 | 9 | 10 | (error = merge_driver_registry_insert( | |
| 207 | 9 | 12,13 | merge_driver_name__union, &git_merge_driver__union.base)) < 0 || | |
| 208 | 9 | 12 | (error = merge_driver_registry_insert( | |
| 209 | - | merge_driver_name__binary, &git_merge_driver__binary)) < 0) | ||
| 210 | - | goto done; | ||
| 211 | - | |||
| 212 | 9 | 14 | git__on_shutdown(git_merge_driver_global_shutdown); | |
| 213 | - | |||
| 214 | - | done: | ||
| 215 | 9 | 15 | if (error < 0) | |
| 216 | ##### | 16 | git_vector_free_deep(&merge_driver_registry.drivers); | |
| 217 | - | |||
| 218 | 9 | 17 | return error; | |
| 219 | - | } | ||
| 220 | - | |||
| 221 | 9 | 2 | static void git_merge_driver_global_shutdown(void) | |
| 222 | - | { | ||
| 223 | - | git_merge_driver_entry *entry; | ||
| 224 | - | size_t i; | ||
| 225 | - | |||
| 226 | 9 | 2,3 | if (git_rwlock_wrlock(&merge_driver_registry.lock) < 0) | |
| 227 | 9 | 4,15 | return; | |
| 228 | - | |||
| 229 | 36 | 5,9-11 | git_vector_foreach(&merge_driver_registry.drivers, i, entry) { | |
| 230 | 27 | 6 | if (entry->driver->shutdown) | |
| 231 | ##### | 7 | entry->driver->shutdown(entry->driver); | |
| 232 | - | |||
| 233 | 27 | 8 | git__free(entry); | |
| 234 | - | } | ||
| 235 | - | |||
| 236 | 9 | 12 | git_vector_free(&merge_driver_registry.drivers); | |
| 237 | - | |||
| 238 | 9 | 13 | git_rwlock_wrunlock(&merge_driver_registry.lock); | |
| 239 | 9 | 14 | git_rwlock_free(&merge_driver_registry.lock); | |
| 240 | - | } | ||
| 241 | - | |||
| 242 | - | /* Note: callers must lock the registry before calling this function */ | ||
| 243 | 81 | 2 | static int merge_driver_registry_find(size_t *pos, const char *name) | |
| 244 | - | { | ||
| 245 | 81 | 2 | return git_vector_search2(pos, &merge_driver_registry.drivers, | |
| 246 | - | merge_driver_entry_search, name); | ||
| 247 | - | } | ||
| 248 | - | |||
| 249 | - | /* Note: callers must lock the registry before calling this function */ | ||
| 250 | 50 | 2 | static git_merge_driver_entry *merge_driver_registry_lookup( | |
| 251 | - | size_t *pos, const char *name) | ||
| 252 | - | { | ||
| 253 | 50 | 2 | git_merge_driver_entry *entry = NULL; | |
| 254 | - | |||
| 255 | 50 | 2,3 | if (!merge_driver_registry_find(pos, name)) | |
| 256 | 47 | 4 | entry = git_vector_get(&merge_driver_registry.drivers, *pos); | |
| 257 | - | |||
| 258 | 50 | 5 | return entry; | |
| 259 | - | } | ||
| 260 | - | |||
| 261 | ![]() |
31 | 2 | int git_merge_driver_register(const char *name, git_merge_driver *driver) |
| 262 | - | { | ||
| 263 | - | int error; | ||
| 264 | - | |||
| 265 | 31 | 2-4 | assert(name && driver); | |
| 266 | - | |||
| 267 | 31 | 5,6 | if (git_rwlock_wrlock(&merge_driver_registry.lock) < 0) { | |
| 268 | ##### | 7 | git_error_set(GIT_ERROR_OS, "failed to lock merge driver registry"); | |
| 269 | ##### | 8 | return -1; | |
| 270 | - | } | ||
| 271 | - | |||
| 272 | 31 | 9,10 | if (!merge_driver_registry_find(NULL, name)) { | |
| 273 | ##### | 11 | git_error_set(GIT_ERROR_MERGE, "attempt to reregister existing driver '%s'", | |
| 274 | - | name); | ||
| 275 | ##### | 12 | error = GIT_EEXISTS; | |
| 276 | ##### | 12 | goto done; | |
| 277 | - | } | ||
| 278 | - | |||
| 279 | 31 | 13 | error = merge_driver_registry_insert(name, driver); | |
| 280 | - | |||
| 281 | - | done: | ||
| 282 | 31 | 14 | git_rwlock_wrunlock(&merge_driver_registry.lock); | |
| 283 | 31 | 15 | return error; | |
| 284 | - | } | ||
| 285 | - | |||
| 286 | 31 | 2 | int git_merge_driver_unregister(const char *name) | |
| 287 | - | { | ||
| 288 | - | git_merge_driver_entry *entry; | ||
| 289 | - | size_t pos; | ||
| 290 | 31 | 2 | int error = 0; | |
| 291 | - | |||
| 292 | 31 | 2,3 | if (git_rwlock_wrlock(&merge_driver_registry.lock) < 0) { | |
| 293 | ##### | 4 | git_error_set(GIT_ERROR_OS, "failed to lock merge driver registry"); | |
| 294 | ##### | 5 | return -1; | |
| 295 | - | } | ||
| 296 | - | |||
| 297 | 31 | 6,7 | if ((entry = merge_driver_registry_lookup(&pos, name)) == NULL) { | |
| 298 | ##### | 8 | git_error_set(GIT_ERROR_MERGE, "cannot find merge driver '%s' to unregister", | |
| 299 | - | name); | ||
| 300 | ##### | 9 | error = GIT_ENOTFOUND; | |
| 301 | ##### | 9 | goto done; | |
| 302 | - | } | ||
| 303 | - | |||
| 304 | 31 | 10 | git_vector_remove(&merge_driver_registry.drivers, pos); | |
| 305 | - | |||
| 306 | 31 | 11,12 | if (entry->initialized && entry->driver->shutdown) { | |
| 307 | 10 | 13 | entry->driver->shutdown(entry->driver); | |
| 308 | 10 | 14 | entry->initialized = false; | |
| 309 | - | } | ||
| 310 | - | |||
| 311 | 31 | 15 | git__free(entry); | |
| 312 | - | |||
| 313 | - | done: | ||
| 314 | 31 | 16 | git_rwlock_wrunlock(&merge_driver_registry.lock); | |
| 315 | 31 | 17 | return error; | |
| 316 | - | } | ||
| 317 | - | |||
| 318 | ![]() |
309 | 2 | git_merge_driver *git_merge_driver_lookup(const char *name) |
| 319 | - | { | ||
| 320 | - | git_merge_driver_entry *entry; | ||
| 321 | - | size_t pos; | ||
| 322 | - | int error; | ||
| 323 | - | |||
| 324 | - | /* If we've decided the merge driver to use internally - and not | ||
| 325 | - | * based on user configuration (in merge_driver_name_for_path) | ||
| 326 | - | * then we can use a hardcoded name to compare instead of bothering | ||
| 327 | - | * to take a lock and look it up in the vector. | ||
| 328 | - | */ | ||
| 329 | 309 | 2 | if (name == merge_driver_name__text) | |
| 330 | 289 | 3 | return &git_merge_driver__text.base; | |
| 331 | 20 | 4 | else if (name == merge_driver_name__binary) | |
| 332 | 1 | 5 | return &git_merge_driver__binary; | |
| 333 | - | |||
| 334 | 19 | 6,7 | if (git_rwlock_rdlock(&merge_driver_registry.lock) < 0) { | |
| 335 | ##### | 8 | git_error_set(GIT_ERROR_OS, "failed to lock merge driver registry"); | |
| 336 | ##### | 9 | return NULL; | |
| 337 | - | } | ||
| 338 | - | |||
| 339 | 19 | 10 | entry = merge_driver_registry_lookup(&pos, name); | |
| 340 | - | |||
| 341 | 19 | 11 | git_rwlock_rdunlock(&merge_driver_registry.lock); | |
| 342 | - | |||
| 343 | 19 | 12 | if (entry == NULL) { | |
| 344 | 3 | 13 | git_error_set(GIT_ERROR_MERGE, "cannot use an unregistered filter"); | |
| 345 | 3 | 14 | return NULL; | |
| 346 | - | } | ||
| 347 | - | |||
| 348 | 16 | 15 | if (!entry->initialized) { | |
| 349 | 12 | 16-18 | if (entry->driver->initialize && | |
| 350 | 10 | 17 | (error = entry->driver->initialize(entry->driver)) < 0) | |
| 351 | ##### | 19 | return NULL; | |
| 352 | - | |||
| 353 | 12 | 20 | entry->initialized = 1; | |
| 354 | - | } | ||
| 355 | - | |||
| 356 | 16 | 21 | return entry->driver; | |
| 357 | - | } | ||
| 358 | - | |||
| 359 | ![]() |
307 | 2 | static int merge_driver_name_for_path( |
| 360 | - | const char **out, | ||
| 361 | - | git_repository *repo, | ||
| 362 | - | const char *path, | ||
| 363 | - | const char *default_driver) | ||
| 364 | - | { | ||
| 365 | - | const char *value; | ||
| 366 | - | int error; | ||
| 367 | - | |||
| 368 | 307 | 2 | *out = NULL; | |
| 369 | - | |||
| 370 | 307 | 2,3 | if ((error = git_attr_get(&value, repo, 0, path, "merge")) < 0) | |
| 371 | ##### | 4 | return error; | |
| 372 | - | |||
| 373 | - | /* set: use the built-in 3-way merge driver ("text") */ | ||
| 374 | 307 | 5,6 | if (GIT_ATTR_IS_TRUE(value)) | |
| 375 | 1 | 7 | *out = merge_driver_name__text; | |
| 376 | - | |||
| 377 | - | /* unset: do not merge ("binary") */ | ||
| 378 | 306 | 8,9 | else if (GIT_ATTR_IS_FALSE(value)) | |
| 379 | 1 | 10 | *out = merge_driver_name__binary; | |
| 380 | - | |||
| 381 | 305 | 11-13 | else if (GIT_ATTR_IS_UNSPECIFIED(value) && default_driver) | |
| 382 | 10 | 14 | *out = default_driver; | |
| 383 | - | |||
| 384 | 295 | 15,16 | else if (GIT_ATTR_IS_UNSPECIFIED(value)) | |
| 385 | 288 | 17 | *out = merge_driver_name__text; | |
| 386 | - | |||
| 387 | - | else | ||
| 388 | 7 | 18 | *out = value; | |
| 389 | - | |||
| 390 | 307 | 19 | return 0; | |
| 391 | - | } | ||
| 392 | - | |||
| 393 | - | |||
| 394 | 307 | 2 | GIT_INLINE(git_merge_driver *) merge_driver_lookup_with_wildcard( | |
| 395 | - | const char *name) | ||
| 396 | - | { | ||
| 397 | 307 | 2 | git_merge_driver *driver = git_merge_driver_lookup(name); | |
| 398 | - | |||
| 399 | 307 | 3 | if (driver == NULL) | |
| 400 | 2 | 4 | driver = git_merge_driver_lookup("*"); | |
| 401 | - | |||
| 402 | 307 | 5 | return driver; | |
| 403 | - | } | ||
| 404 | - | |||
| 405 | ![]() |
307 | 2 | int git_merge_driver_for_source( |
| 406 | - | const char **name_out, | ||
| 407 | - | git_merge_driver **driver_out, | ||
| 408 | - | const git_merge_driver_source *src) | ||
| 409 | - | { | ||
| 410 | - | const char *path, *driver_name; | ||
| 411 | 307 | 2 | int error = 0; | |
| 412 | - | |||
| 413 | 307 | 2-11 | path = git_merge_file__best_path( | |
| 414 | 307 | 8,9 | src->ancestor ? src->ancestor->path : NULL, | |
| 415 | 307 | 5,6 | src->ours ? src->ours->path : NULL, | |
| 416 | 307 | 2,3 | src->theirs ? src->theirs->path : NULL); | |
| 417 | - | |||
| 418 | 307 | 12,13 | if ((error = merge_driver_name_for_path( | |
| 419 | - | &driver_name, src->repo, path, src->default_driver)) < 0) | ||
| 420 | ##### | 14 | return error; | |
| 421 | - | |||
| 422 | 307 | 15 | *name_out = driver_name; | |
| 423 | 307 | 15 | *driver_out = merge_driver_lookup_with_wildcard(driver_name); | |
| 424 | 307 | 16 | return error; | |
| 425 | - | } | ||
| 426 | - |