Skip to content

Commit b3ea111

Browse files
allenwang28meta-codesync[bot]
authored andcommitted
Move from deprecated to regular actor calls (#1827)
Summary: Pull Request resolved: #1827 Chatting with mariusae the deprecated call was a switch form capabilities to context (D82248674). Here, client is already a context so we can use the non-deprecated APIs Reviewed By: dstaay-fb, casteryh Differential Revision: D86788695 fbshipit-source-id: b2b3d097c76ba0bccb9e26f6cf2663f25409f998
1 parent 6273659 commit b3ea111

File tree

1 file changed

+5
-7
lines changed

1 file changed

+5
-7
lines changed

monarch_rdma/src/rdma_components.rs

Lines changed: 5 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -136,7 +136,7 @@ impl RdmaBuffer {
136136
let remote_device = remote.device_name.clone();
137137
let mut qp = self
138138
.owner
139-
.request_queue_pair_deprecated(
139+
.request_queue_pair(
140140
client,
141141
remote_owner.clone(),
142142
local_device.clone(),
@@ -151,7 +151,7 @@ impl RdmaBuffer {
151151

152152
// Release the queue pair back to the actor
153153
self.owner
154-
.release_queue_pair_deprecated(client, remote_owner, local_device, remote_device, qp)
154+
.release_queue_pair(client, remote_owner, local_device, remote_device, qp)
155155
.await?;
156156

157157
result
@@ -190,7 +190,7 @@ impl RdmaBuffer {
190190

191191
let mut qp = self
192192
.owner
193-
.request_queue_pair_deprecated(
193+
.request_queue_pair(
194194
client,
195195
remote_owner.clone(),
196196
local_device.clone(),
@@ -204,7 +204,7 @@ impl RdmaBuffer {
204204

205205
// Release the queue pair back to the actor
206206
self.owner
207-
.release_queue_pair_deprecated(client, remote_owner, local_device, remote_device, qp)
207+
.release_queue_pair(client, remote_owner, local_device, remote_device, qp)
208208
.await?;
209209

210210
result?;
@@ -272,9 +272,7 @@ impl RdmaBuffer {
272272
/// `Ok(())` if the operation completed successfully.
273273
pub async fn drop_buffer(&self, client: &impl context::Actor) -> Result<(), anyhow::Error> {
274274
tracing::debug!("[buffer] dropping buffer {:?}", self);
275-
self.owner
276-
.release_buffer_deprecated(client, self.clone())
277-
.await?;
275+
self.owner.release_buffer(client, self.clone()).await?;
278276
Ok(())
279277
}
280278
}

0 commit comments

Comments
 (0)