GitHub/gf-core
1
0
Fork 1
mirror of https://github.com/GrammaticalFramework/gf-core.git synced 2026-04-23 19:42:50 -06:00
Code Issues Packages Projects Releases Wiki Activity

ipc_release_file_rwlock should not assume that the file exists

Browse Source
This commit is contained in:
krangelov
2021-10-26 09:35:56 +02:00
parent 157574763f
commit 00ba552026
1 changed files with 3 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files

13
src/runtime/c/pgf/ipc.cxx
View File

@@ -238,21 +238,16 @@ void ipc_release_file_rwlock(const char* file_path,
if (locks == NULL) if (locks == NULL)
return; return;
struct stat s;
if (stat(file_path, &s) != 0) {
ipc_error();
}
pthread_mutex_lock(&locks->mutex); pthread_mutex_lock(&locks->mutex);
lock_entry *entry = ptr(locks->lock_entries,lock_entry); lock_entry *entry = ptr(locks->lock_entries,lock_entry);
ptr_t(lock_entry) *last = &locks->lock_entries; ptr_t(lock_entry) *last = &locks->lock_entries;
while (entry != NULL) { while (entry != NULL) {
if (entry->dev == s.st_dev && entry->ino == s.st_ino) { if (&entry->rwlock == rwlock) {
break; break;
} }
entry = ptr(entry->next,lock_entry);
last = &entry->next; last = &entry->next;
entry = ptr(*last,lock_entry);
} }
if (entry != NULL) { if (entry != NULL) {
@@ -314,8 +309,6 @@ int main(int argc, char *argv[])
return 1; return 1;
} }
printf("%ld\n", sizeof(lock_entry));
pthread_rwlock_t *rwlock = ipc_new_file_rwlock(argv[2]); pthread_rwlock_t *rwlock = ipc_new_file_rwlock(argv[2]);
if (strcmp(argv[1],"r") == 0) { if (strcmp(argv[1],"r") == 0) {
@@ -332,7 +325,7 @@ int main(int argc, char *argv[])
pthread_rwlock_unlock(rwlock); pthread_rwlock_unlock(rwlock);
ipc_release_file_rwlock(argv[2]); ipc_release_file_rwlock(argv[2], rwlock);
return 0; return 0;
} }