1 files changed, 9 insertions, 4 deletions

diff --git a/src/main/extractor_ipc_gnu.c b/src/main/extractor_ipc_gnu.c
index 2a6dbc3..af2657a 100644
--- a/src/main/extractor_ipc_gnu.c
+++ b/src/main/extractor_ipc_gnu.c
@@ -154,6 +154,9 @@ EXTRACTOR_IPC_shared_memory_create_ (size_t size)
             "%slibextractor-shm-%u-%u", 
             tpath, getpid (),
             (unsigned int) RANDOM());
+  LOG ("Creating shared memory `%s' with %u bytes capacity\n",
+       shm->shm_name,
+       (unsigned int) size);
   if (-1 == (shm->shm_id = shm_open (shm->shm_name,
                                      O_RDWR | O_CREAT, S_IRUSR | S_IWUSR)))
     {
@@ -204,6 +207,8 @@ EXTRACTOR_IPC_shared_memory_change_rc_ (struct EXTRACTOR_SharedMemory *shm,
 void
 EXTRACTOR_IPC_shared_memory_destroy_ (struct EXTRACTOR_SharedMemory *shm)
 {  
+  LOG ("Destroying shared memory `%s'\n",
+       shm->shm_name);
   munmap (shm->shm_ptr, shm->shm_size);
   (void) close (shm->shm_id);
   (void) shm_unlink (shm->shm_name);
@@ -442,10 +447,10 @@ EXTRACTOR_IPC_channel_recv_ (struct EXTRACTOR_Channel **channels,
       if ( (-1 == (iret = read (channel->cpipe_out,
                                 &channel->data[channel->size],
                                 MAX_META_DATA - channel->size)) ) ||
-           (ret = EXTRACTOR_IPC_process_reply_ (channel->plugin,
-                                                channel->data, 
-                                                channel->size + iret, 
-                                                proc, proc_cls)) )
+           (-1 == (ret = EXTRACTOR_IPC_process_reply_ (channel->plugin,
+                                                       channel->data, 
+                                                       channel->size + iret, 
+                                                       proc, proc_cls)) ) )
         {
           if (-1 == iret)
             LOG_STRERROR ("read");