fix

Author: topointon-jump

src/funkier/fd_funkier_rec.c

@@ -258,8 +258,8 @@ fd_funkier_rec_publish( fd_funkier_rec_prepare_t * prepare ) {
 
   /* We need to hold the pool lock whilst inserting and removing from the map, to make the updates
      to the prev_idx/next_idx pointers atomic. */
-  fd_funkier_rec_pool_lock( &rec_pool, 1 );
   fd_rwlock_write(&_pool_lock);
+  fd_funkier_rec_pool_lock( &rec_pool, 1 );
   rec->prev_idx = rec_prev_idx;
   if( fd_funkier_rec_idx_is_null( rec_prev_idx ) ) {
     *rec_head_idx = rec_idx;
@@ -270,8 +270,8 @@ fd_funkier_rec_publish( fd_funkier_rec_prepare_t * prepare ) {
   if( fd_funkier_rec_map_insert( &rec_map, rec, FD_MAP_FLAG_BLOCKING ) ) {
     FD_LOG_CRIT(( "fd_funkier_rec_map_insert failed" ));
   }
-  fd_rwlock_unwrite(&_pool_lock);
   fd_funkier_rec_pool_unlock( &rec_pool );
+  fd_rwlock_unwrite(&_pool_lock);
 }
 
 void
@@ -343,17 +343,17 @@ fd_funkier_rec_hard_remove( fd_funkier_t *               funk,
   }
   fd_funkier_rec_key_copy( pair->key, key );
 
-  fd_funkier_rec_pool_lock( &rec_pool, 1 );
   fd_rwlock_write(&_pool_lock);
+  fd_funkier_rec_pool_lock( &rec_pool, 1 );
 
   fd_funkier_rec_t * rec = NULL;
   for(;;) {
     fd_funkier_rec_map_query_t rec_query[1];
     int err = fd_funkier_rec_map_remove( &rec_map, pair, NULL, rec_query, FD_MAP_FLAG_BLOCKING );
     if( FD_UNLIKELY( err == FD_MAP_ERR_AGAIN ) ) continue;
     if( err == FD_MAP_ERR_KEY ) {
-      fd_rwlock_unwrite(&_pool_lock);
       fd_funkier_rec_pool_unlock( &rec_pool );
+      fd_rwlock_unwrite(&_pool_lock);
       return;
     }
     if( FD_UNLIKELY( err != FD_MAP_SUCCESS ) ) FD_LOG_CRIT(( "map corruption" ));
@@ -374,8 +374,8 @@ fd_funkier_rec_hard_remove( fd_funkier_t *               funk,
     if( fd_funkier_rec_idx_is_null( next_idx ) ) txn->rec_tail_idx =                prev_idx;
     else                                         rec_pool.ele[ next_idx ].prev_idx = prev_idx;
   }
-  fd_rwlock_unwrite(&_pool_lock);
   fd_funkier_rec_pool_unlock( &rec_pool );
+  fd_rwlock_unwrite(&_pool_lock);
 
   fd_funkier_val_flush( rec, alloc, wksp );
   fd_rwlock_write(&_pool_lock);