From 08aff917e55d6333151927da1dc409b1ba264cc3 Mon Sep 17 00:00:00 2001
From: Xuanwo <github@xuanwo.io>
Date: Tue, 11 Jul 2023 17:29:27 +0800
Subject: [PATCH] Bump to version 0.3.0 (#115)

* Bump to version 0.3.0

Signed-off-by: Xuanwo <github@xuanwo.io>

* Add wait

Signed-off-by: Xuanwo <github@xuanwo.io>

---------

Signed-off-by: Xuanwo <github@xuanwo.io>
---
 .github/workflows/ci.yml | 4 ++++
 Cargo.toml               | 7 +++----
 src/async_file.rs        | 2 +-
 3 files changed, 8 insertions(+), 5 deletions(-)

diff --git a/.github/workflows/ci.yml b/.github/workflows/ci.yml
index a3814e5..a333a81 100644
--- a/.github/workflows/ci.yml
+++ b/.github/workflows/ci.yml
@@ -49,6 +49,10 @@ jobs:
         with:
           hdfs-version: ${{ matrix.hdfs-version }}
 
+      - name: Wait for hdfs startup
+        run: |
+          curl --retry 30 --retry-delay 1 --retry-connrefused http://${HDFS_NAMENODE_HTTP_ADDR}
+
       - name: Test
         run: |
           export CLASSPATH=$(find $HADOOP_HOME -iname "*.jar" | xargs echo | tr ' ' ':')
diff --git a/Cargo.toml b/Cargo.toml
index ad24e65..d2371c6 100644
--- a/Cargo.toml
+++ b/Cargo.toml
@@ -7,19 +7,18 @@ edition = "2021"
 license = "Apache-2.0"
 name = "hdrs"
 repository = "https://github.com/Xuanwo/hdrs"
-version = "0.2.0"
+version = "0.3.0"
 
 [package.metadata.docs.rs]
 all-features = true
 
 [features]
-async_file = ["dep:futures", "dep:blocking", "dep:async-lock"]
+async_file = ["dep:futures", "dep:blocking"]
 
 [dependencies]
+blocking = { version = "1.3.0", optional = true }
 errno = "0.3"
 futures = { version = "0.3", optional = true }
-async-lock = { version = "2.3.0", optional = true }
-blocking = { version = "1.3.0", optional = true }
 # hdrs requires at least hadoop 2.3 to work.
 # hadoop 2.2 doesn't handle FileNotFound correctly.
 #
diff --git a/src/async_file.rs b/src/async_file.rs
index afb0ce5..f3ea496 100644
--- a/src/async_file.rs
+++ b/src/async_file.rs
@@ -3,8 +3,8 @@ use std::pin::Pin;
 use std::sync::Arc;
 use std::task::{Context, Poll};
 
-use async_lock::Mutex;
 use blocking::Unblock;
+use futures::lock::Mutex;
 use futures::{ready, AsyncSeek};
 
 use crate::File;