diff --git a/include/ck_hp_fifo.h b/include/ck_hp_fifo.h index 2aa2956..68423ee 100644 --- a/include/ck_hp_fifo.h +++ b/include/ck_hp_fifo.h @@ -28,7 +28,6 @@ #ifndef _CK_HP_FIFO_H #define _CK_HP_FIFO_H -#include #include #include #include @@ -74,7 +73,6 @@ ck_hp_fifo_enqueue_mpmc(ck_hp_record_t *record, void *value) { struct ck_hp_fifo_entry *tail, *next; - ck_backoff_t backoff = CK_BACKOFF_INITIALIZER; entry->value = value; entry->next = NULL; @@ -93,8 +91,6 @@ ck_hp_fifo_enqueue_mpmc(ck_hp_record_t *record, continue; } else if (ck_pr_cas_ptr(&fifo->tail->next, next, entry) == true) break; - - ck_backoff_eb(&backoff); } ck_pr_cas_ptr(&fifo->tail, tail, entry); @@ -107,7 +103,6 @@ ck_hp_fifo_dequeue_mpmc(ck_hp_record_t *record, void *value) { struct ck_hp_fifo_entry *head, *tail, *next; - ck_backoff_t backoff = CK_BACKOFF_INITIALIZER; for (;;) { tail = ck_pr_load_ptr(&fifo->tail); @@ -132,8 +127,6 @@ ck_hp_fifo_dequeue_mpmc(ck_hp_record_t *record, continue; } else if (ck_pr_cas_ptr(&fifo->head, head, next) == true) break; - - ck_backoff_eb(&backoff); } ck_pr_store_ptr(value, next->value); diff --git a/include/ck_hp_stack.h b/include/ck_hp_stack.h index 3a0d3be..aba8ac4 100644 --- a/include/ck_hp_stack.h +++ b/include/ck_hp_stack.h @@ -27,7 +27,6 @@ #ifndef _CK_HP_STACK_H #define _CK_HP_STACK_H -#include #include #include #include @@ -49,7 +48,6 @@ CK_CC_INLINE static void * ck_hp_stack_pop_mpmc(ck_hp_record_t *record, struct ck_stack *target) { struct ck_stack_entry *entry, *update; - ck_backoff_t backoff = CK_BACKOFF_INITIALIZER; do { entry = ck_pr_load_ptr(&target->head); @@ -75,8 +73,6 @@ ck_hp_stack_pop_mpmc(ck_hp_record_t *record, struct ck_stack *target) if (update == NULL) return (NULL); } - - ck_backoff_eb(&backoff); } return (entry);