packaging
/
ostree
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

lib/repo: Disable locking by default, add locking=true boolean 

I want some time to play with this more with different callers and work through
test scenarios. Let's disable the locking by default for now, but make it easy
to enable.

Closes: #1375
Approved by: jlebon
This commit is contained in:
Colin Walters 2017-12-13 14:27:19 -05:00 committed by Atomic Bot
parent a9a9445582
commit ad814d1c8a
2 changed files with 29 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

29
src/libostree/ostree-repo.c
View File

@ -46,6 +46,9 @@
#include <sys/file.h> #include <sys/file.h>
#include <sys/statvfs.h> #include <sys/statvfs.h>
#define REPO_LOCK_DISABLED (-2)
#define REPO_LOCK_BLOCKING (-1)
/* ABI Size checks for ostree-repo.h, only for LP64 systems; /* ABI Size checks for ostree-repo.h, only for LP64 systems;
* https://en.wikipedia.org/wiki/64-bit_computing#64-bit_data_models * https://en.wikipedia.org/wiki/64-bit_computing#64-bit_data_models
* *
@ -474,8 +477,10 @@ ostree_repo_lock_push (OstreeRepo *self,
if (!self->writable) if (!self->writable)
return TRUE; return TRUE;
g_assert (self->lock_timeout_seconds >= -1); g_assert (self->lock_timeout_seconds >= REPO_LOCK_DISABLED);
if (self->lock_timeout_seconds == -1) if (self->lock_timeout_seconds == REPO_LOCK_DISABLED)
return TRUE; /* No locking */
else if (self->lock_timeout_seconds == REPO_LOCK_BLOCKING)
{ {
g_debug ("Pushing lock blocking"); g_debug ("Pushing lock blocking");
return push_repo_lock (self, lock_type, TRUE, error); return push_repo_lock (self, lock_type, TRUE, error);
@ -562,8 +567,10 @@ ostree_repo_lock_pop (OstreeRepo *self,
if (!self->writable) if (!self->writable)
return TRUE; return TRUE;
g_assert (self->lock_timeout_seconds >= -1); g_assert (self->lock_timeout_seconds >= REPO_LOCK_DISABLED);
if (self->lock_timeout_seconds == -1) if (self->lock_timeout_seconds == REPO_LOCK_DISABLED)
return TRUE;
else if (self->lock_timeout_seconds == REPO_LOCK_BLOCKING)
{ {
g_debug ("Popping lock blocking"); g_debug ("Popping lock blocking");
return pop_repo_lock (self, TRUE, error); return pop_repo_lock (self, TRUE, error);
@ -2733,7 +2740,18 @@ reload_core_config (OstreeRepo *self,
self->tmp_expiry_seconds = g_ascii_strtoull (tmp_expiry_seconds, NULL, 10); self->tmp_expiry_seconds = g_ascii_strtoull (tmp_expiry_seconds, NULL, 10);
} }
{ g_autofree char *lock_timeout_seconds = NULL; /* Disable locking by default for now */
{ gboolean locking;
if (!ot_keyfile_get_boolean_with_default (self->config, "core", "locking",
FALSE, &locking, error))
return FALSE;
if (!locking)
{
self->lock_timeout_seconds = REPO_LOCK_DISABLED;
}
else
{
g_autofree char *lock_timeout_seconds = NULL;
if (!ot_keyfile_get_value_with_default (self->config, "core", "lock-timeout-secs", "30", if (!ot_keyfile_get_value_with_default (self->config, "core", "lock-timeout-secs", "30",
&lock_timeout_seconds, error)) &lock_timeout_seconds, error))
@ -2741,6 +2759,7 @@ reload_core_config (OstreeRepo *self,
self->lock_timeout_seconds = g_ascii_strtoull (lock_timeout_seconds, NULL, 10); self->lock_timeout_seconds = g_ascii_strtoull (lock_timeout_seconds, NULL, 10);
} }
}
{ g_autofree char *compression_level_str = NULL; { g_autofree char *compression_level_str = NULL;

1
tests/test-concurrency.py
View File

@ -43,6 +43,7 @@ subprocess.check_call(['ostree', '--repo=repo', 'init', '--mode=bare'])
# and we don't need xattr coverage for this # and we don't need xattr coverage for this
with open('repo/config', 'a') as f: with open('repo/config', 'a') as f:
f.write('disable-xattrs=true\n') f.write('disable-xattrs=true\n')
f.write('locking=true\n')
def commit(v): def commit(v):
tdir='tree{}'.format(v) tdir='tree{}'.format(v)