diff options
| author | Ryan Dahl <ry@tinyclouds.org> | 2020-01-24 15:10:49 -0500 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2020-01-24 15:10:49 -0500 |
| commit | 5e32c5ea448563be91017d71bab060c8a6bd90fe (patch) | |
| tree | aa9e731b9f4b9f6bc28beab23e7575d43bc14653 /cli/ops/worker_host.rs | |
| parent | 86726f88f1b6fd168fbd5b0d7e01b027cfc268ac (diff) | |
s/PinnedBuf/ZeroCopyBuf (#3782)
Diffstat (limited to 'cli/ops/worker_host.rs')
| -rw-r--r-- | cli/ops/worker_host.rs | 16 |
1 files changed, 8 insertions, 8 deletions
diff --git a/cli/ops/worker_host.rs b/cli/ops/worker_host.rs index c64e86c1c..20ffb8eb7 100644 --- a/cli/ops/worker_host.rs +++ b/cli/ops/worker_host.rs @@ -69,7 +69,7 @@ struct CreateWorkerArgs { fn op_create_worker( state: &ThreadSafeState, args: Value, - _data: Option<PinnedBuf>, + _data: Option<ZeroCopyBuf>, ) -> Result<JsonOp, ErrBox> { let args: CreateWorkerArgs = serde_json::from_value(args)?; @@ -180,7 +180,7 @@ struct WorkerArgs { fn op_host_get_worker_loaded( state: &ThreadSafeState, args: Value, - _data: Option<PinnedBuf>, + _data: Option<ZeroCopyBuf>, ) -> Result<JsonOp, ErrBox> { let args: WorkerArgs = serde_json::from_value(args)?; let id = args.id as u32; @@ -198,7 +198,7 @@ fn op_host_get_worker_loaded( fn op_host_poll_worker( state: &ThreadSafeState, args: Value, - _data: Option<PinnedBuf>, + _data: Option<ZeroCopyBuf>, ) -> Result<JsonOp, ErrBox> { let args: WorkerArgs = serde_json::from_value(args)?; let id = args.id as u32; @@ -226,7 +226,7 @@ fn op_host_poll_worker( fn op_host_close_worker( state: &ThreadSafeState, args: Value, - _data: Option<PinnedBuf>, + _data: Option<ZeroCopyBuf>, ) -> Result<JsonOp, ErrBox> { let args: WorkerArgs = serde_json::from_value(args)?; let id = args.id as u32; @@ -249,7 +249,7 @@ fn op_host_close_worker( fn op_host_resume_worker( state: &ThreadSafeState, args: Value, - _data: Option<PinnedBuf>, + _data: Option<ZeroCopyBuf>, ) -> Result<JsonOp, ErrBox> { let args: WorkerArgs = serde_json::from_value(args)?; let id = args.id as u32; @@ -270,7 +270,7 @@ struct HostGetMessageArgs { fn op_host_get_message( state: &ThreadSafeState, args: Value, - _data: Option<PinnedBuf>, + _data: Option<ZeroCopyBuf>, ) -> Result<JsonOp, ErrBox> { let args: HostGetMessageArgs = serde_json::from_value(args)?; let state_ = state.clone(); @@ -297,7 +297,7 @@ struct HostPostMessageArgs { fn op_host_post_message( state: &ThreadSafeState, args: Value, - data: Option<PinnedBuf>, + data: Option<ZeroCopyBuf>, ) -> Result<JsonOp, ErrBox> { let args: HostPostMessageArgs = serde_json::from_value(args)?; let id = args.id as u32; @@ -317,7 +317,7 @@ fn op_host_post_message( fn op_metrics( state: &ThreadSafeState, _args: Value, - _zero_copy: Option<PinnedBuf>, + _zero_copy: Option<ZeroCopyBuf>, ) -> Result<JsonOp, ErrBox> { let m = &state.metrics; |
