about summary refs log tree commit diff stats
path: root/src/server/shared_memory_server.h
diff options
context:
space:
mode:
authorChristian Krinitsin <mail@krinitsin.com>2025-03-23 17:50:37 +0100
committerChristian Krinitsin <mail@krinitsin.com>2025-03-23 17:50:37 +0100
commit03ad55130b4f0047eb64d3cc9947b98f0130623e (patch)
tree1f9014a5a92335051541d34710e3556781d044a8 /src/server/shared_memory_server.h
parent3939238f3fe46ed36919f29cbebe824341689960 (diff)
downloadBT-Programming-Assignment-03ad55130b4f0047eb64d3cc9947b98f0130623e.tar.gz
BT-Programming-Assignment-03ad55130b4f0047eb64d3cc9947b98f0130623e.zip
fix terminology
Diffstat (limited to 'src/server/shared_memory_server.h')
-rw-r--r--src/server/shared_memory_server.h5
1 files changed, 3 insertions, 2 deletions
diff --git a/src/server/shared_memory_server.h b/src/server/shared_memory_server.h
index 6c97e64..3ac375a 100644
--- a/src/server/shared_memory_server.h
+++ b/src/server/shared_memory_server.h
@@ -32,6 +32,7 @@ public:
             mmap(0, sizeof(SharedMemory), PROT_READ | PROT_WRITE, MAP_SHARED, shm_fd, 0);
 
         shared_memory->tail = shared_memory->head = 0;
+        shared_memory->full = false;
 
         pthread_mutexattr_t mutex_attr;
         pthread_condattr_t cond_attr;
@@ -68,7 +69,7 @@ public:
                 pthread_cond_wait(&shared_memory->cond_var, &shared_memory->mutex);
             }
 
-            Request* request = &shared_memory->request[shared_memory->tail];
+            Request* request = &shared_memory->request[shared_memory->head];
 
             K key = deserialize<K>(request->key);
             V value = deserialize<V>(request->value);
@@ -130,7 +131,7 @@ public:
             default:
                 break;
             }
-            shared_memory->tail = (1 + shared_memory->tail) % QUEUE_SIZE;
+            shared_memory->head = (1 + shared_memory->head) % QUEUE_SIZE;
             shared_memory->full = false;
             pthread_cond_signal(&shared_memory->cond_var);
             pthread_mutex_unlock(&shared_memory->mutex);