X-Git-Url: https://pintos-os.org/cgi-bin/gitweb.cgi?a=blobdiff_plain;ds=sidebyside;f=ovsdb%2Flog.c;h=b79535ac814b12b3073b6a66a7830888449cd394;hb=03e1125c312b223a28eb75454cc418a044df3ade;hp=67043078f73da192f52971c771d5bcb101175042;hpb=43675e260ccc26f8278fd751436af125a18bee38;p=openvswitch diff --git a/ovsdb/log.c b/ovsdb/log.c index 67043078..b79535ac 100644 --- a/ovsdb/log.c +++ b/ovsdb/log.c @@ -1,4 +1,4 @@ -/* Copyright (c) 2009, 2010, 2011 Nicira Networks +/* Copyright (c) 2009, 2010, 2011, 2012 Nicira, Inc. * * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. @@ -80,7 +80,7 @@ ovsdb_log_open(const char *name, enum ovsdb_log_open_mode open_mode, locking = open_mode != OVSDB_LOG_READ_ONLY; } if (locking) { - int retval = lockfile_lock(name, 0, &lockfile); + int retval = lockfile_lock(name, &lockfile); if (retval) { error = ovsdb_io_error(retval, "%s: failed to lock lockfile", name); @@ -95,7 +95,16 @@ ovsdb_log_open(const char *name, enum ovsdb_log_open_mode open_mode, } else if (open_mode == OVSDB_LOG_READ_WRITE) { flags = O_RDWR; } else if (open_mode == OVSDB_LOG_CREATE) { - flags = O_RDWR | O_CREAT | O_EXCL; + if (stat(name, &s) == -1 && errno == ENOENT + && lstat(name, &s) == 0 && S_ISLNK(s.st_mode)) { + /* 'name' is a dangling symlink. We want to create the file that + * the symlink points to, but POSIX says that open() with O_EXCL + * must fail with EEXIST if the named file is a symlink. So, we + * have to leave off O_EXCL and accept the race. */ + flags = O_RDWR | O_CREAT; + } else { + flags = O_RDWR | O_CREAT | O_EXCL; + } } else { NOT_REACHED(); } @@ -289,7 +298,7 @@ ovsdb_log_read(struct ovsdb_log *file, struct json **jsonp) file->prev_offset = file->offset; file->offset = data_offset + data_length; *jsonp = json; - return 0; + return NULL; error: file->read_error = ovsdb_error_clone(error); @@ -372,7 +381,7 @@ ovsdb_log_write(struct ovsdb_log *file, struct json *json) file->offset += strlen(header) + length; free(json_string); - return 0; + return NULL; error: file->write_error = ovsdb_error_clone(error); @@ -386,7 +395,7 @@ ovsdb_log_commit(struct ovsdb_log *file) if (fsync(fileno(file->stream))) { return ovsdb_io_error(errno, "%s: fsync failed", file->name); } - return 0; + return NULL; } /* Returns the current offset into the file backing 'log', in bytes. This