diff --git a/src/ngx_dynamic_upstream_module.c b/src/ngx_dynamic_upstream_module.c
index 1638477..5a81047 100644
--- a/src/ngx_dynamic_upstream_module.c
+++ b/src/ngx_dynamic_upstream_module.c
@@ -128,7 +128,7 @@ ngx_dynamic_upstream_create_response_buf(ngx_http_upstream_rr_peers_t *peers, ng
 
     primary = peers;
 
-    lock_peers(primary);
+    ngx_http_upstream_rr_peers_rlock(primary);
 
     backup = primary->next;
 
@@ -138,7 +138,7 @@ ngx_dynamic_upstream_create_response_buf(ngx_http_upstream_rr_peers_t *peers, ng
         for (peer = peers->peer; peer; peer = peer->next) {
 
             if (peer->name.len > 511) {
-                unlock_peers(primary);
+                ngx_http_upstream_rr_peers_unlock(primary);
                 return NGX_ERROR;
             }
 
@@ -159,7 +159,7 @@ ngx_dynamic_upstream_create_response_buf(ngx_http_upstream_rr_peers_t *peers, ng
         }
     }
 
-    unlock_peers(primary);
+    ngx_http_upstream_rr_peers_unlock(primary);
 
     return NGX_OK;
 }
@@ -174,7 +174,7 @@ ngx_dynamic_upstream_stream_create_response_buf(ngx_stream_upstream_rr_peers_t *
 
     primary = peers;
 
-    lock_peers(primary);
+    ngx_http_upstream_rr_peers_rlock(primary);
 
     backup = primary->next;
 
@@ -184,7 +184,7 @@ ngx_dynamic_upstream_stream_create_response_buf(ngx_stream_upstream_rr_peers_t *
         for (peer = peers->peer; peer; peer = peer->next) {
 
             if (peer->name.len > 511) {
-                unlock_peers(primary);
+                ngx_http_upstream_rr_peers_unlock(primary);
                 return NGX_ERROR;
             }
 
@@ -205,7 +205,7 @@ ngx_dynamic_upstream_stream_create_response_buf(ngx_stream_upstream_rr_peers_t *
         }
     }
 
-    unlock_peers(primary);
+    ngx_http_upstream_rr_peers_unlock(primary);
 
     return NGX_OK;
 }
diff --git a/src/ngx_dynamic_upstream_op.c b/src/ngx_dynamic_upstream_op.c
index 5be90e4..69ec376 100644
--- a/src/ngx_dynamic_upstream_op.c
+++ b/src/ngx_dynamic_upstream_op.c
@@ -246,9 +246,9 @@ ngx_dynamic_upstream_op_impl(ngx_log_t *log, ngx_dynamic_upstream_op_t *op,
     }
 
     if (op->op_param & NGX_DYNAMIC_UPSTEAM_OP_PARAM_STREAM) {
-        lock_peers(primary->stream);
+        ngx_http_upstream_rr_peers_wlock(primary->stream);
     } else {
-        lock_peers(primary->http);
+        ngx_http_upstream_rr_peers_wlock(primary->http);
     }
 
     switch (op->op) {
@@ -271,9 +271,9 @@ ngx_dynamic_upstream_op_impl(ngx_log_t *log, ngx_dynamic_upstream_op_t *op,
     }
 
     if (op->op_param & NGX_DYNAMIC_UPSTEAM_OP_PARAM_STREAM) {
-        unlock_peers(primary->stream);
+        ngx_http_upstream_rr_peers_unlock(primary->stream);
     } else {
-        unlock_peers(primary->http);
+        ngx_http_upstream_rr_peers_unlock(primary->http);
     }
 
     if (shpool) {
diff --git a/src/ngx_dynamic_upstream_op.h b/src/ngx_dynamic_upstream_op.h
index bd391b7..1757ee4 100644
--- a/src/ngx_dynamic_upstream_op.h
+++ b/src/ngx_dynamic_upstream_op.h
@@ -22,19 +22,4 @@ ngx_int_t ngx_dynamic_upstream_build_op(ngx_http_request_t *r, ngx_dynamic_upstr
 ngx_int_t ngx_dynamic_upstream_op_impl(ngx_log_t *log, ngx_dynamic_upstream_op_t *op,
                                        ngx_slab_pool_t *shpool, ngx_upstream_rr_peers_t *primary);
 
-#define lock_peers(primary) { \
-    ngx_http_upstream_rr_peers_wlock(primary); \
-    if (primary->next) { \
-        ngx_http_upstream_rr_peers_wlock(primary->next); \
-    } \
-}
-
-#define unlock_peers(primary) { \
-    if (primary->next && primary->next->rwlock) { \
-        ngx_http_upstream_rr_peers_unlock(primary->next); \
-    } \
-    ngx_http_upstream_rr_peers_unlock(primary); \
-}
-
-
 #endif /* NGX_DYNAMIC_UPSTEAM_OP_H */