Bump rust version to 1.87 and asyncs to 0.4.0

See also:
* dtolnay/linkme#61
* rust-lang/rust#133832
* rust-lang/rust@c51b9b6

Author: kezhuw

Cargo.toml

@@ -22,6 +22,7 @@ homepage = "https://github.com/kezhuw/seamdb"
 repository = "https://github.com/kezhuw/seamdb"
 description = "A computation cluster to seam existing services to provide database interfaces"
 documentation = "https://docs.rs/seamdb"
+rust-version = "1.87"
 
 # See more keys and their definitions at https://doc.rust-lang.org/cargo/reference/manifest.html
 
@@ -57,7 +58,7 @@ tokio-stream = "0.1.15"
 datafusion = "47.0.0"
 pgwire = "0.27.0"
 derive-where = "1.2.7"
-asyncs = { version = "0.3.0", features = ["tokio"] }
+asyncs = { version = "0.4.0", features = ["tokio"] }
 async-io = "2.3.4"
 bytes = "1.7.2"
 lazy_static = "1.5.0"
@@ -75,7 +76,7 @@ imstr = "0.2.0"
 
 [dev-dependencies]
 assertor = "0.0.2"
-asyncs = { version = "0.3.0", features = ["test", "tokio"] }
+asyncs = { version = "0.4.0", features = ["test", "tokio"] }
 env_logger = "0.11.5"
 serial_test = "2.0.0"
 speculoos = "0.11.0"
@@ -84,12 +85,6 @@ test-log = "0.2.12"
 testcontainers = "0.14.0"
 tracing-test = "0.2.4"
 
-[profile.dev]
-lto = "thin"
-
-[profile.release]
-lto = "thin"
-
 [workspace]
 members = ["src/protos/build"]
 

src/tablet/service.rs

@@ -472,16 +472,16 @@ impl TabletServiceState {
                         responser.send();
                     }
                 },
-                Some(ref mut txn) = tablet.store.store.updated_txns().recv() => {
+                Some(mut txn) = tablet.store.store.updated_txns().recv() => {
                     trace!("update txn {:?}", txn);
-                    let (replication, requests) = tablet.store.store.update_txn(txn);
+                    let (replication, requests) = tablet.store.store.update_txn(&mut txn);
                     trace!("unblock txn {}(epoch:{}, {:?}) requests {:?}", txn.id(), txn.epoch(), txn.status(), requests);
                     unblocking_requests.extend(requests.into_iter());
                     if let Some(replication) = replication {
                         self.clock.update(txn.commit_ts());
                         txn.write_set.clear();
                         let message = DataMessage {
-                            temporal: Temporal::Transaction(std::mem::take(txn)),
+                            temporal: Temporal::Transaction(txn),
                             ..tablet.new_data_message()
                         };
                         tablet.store.producer.queue(&message)?;