diff options
author | Valentin Anger <syrupthinker@gryphno.de> | 2020-07-08 17:23:50 +0200 |
---|---|---|
committer | GitHub <noreply@github.com> | 2020-07-08 11:23:50 -0400 |
commit | be7e0f2d490ca480aaa154845c4c5c6dccbd7546 (patch) | |
tree | b2a2d284c490a2a1cd8ec3b6175ea5d4077cc65e /core/examples/http_bench.rs | |
parent | cbbd9443592f79f6abf9e5019840de4e01ff8580 (diff) |
BREAKING(core): Remove control slice from ops (#6048)
Diffstat (limited to 'core/examples/http_bench.rs')
-rw-r--r-- | core/examples/http_bench.rs | 19 |
1 files changed, 10 insertions, 9 deletions
diff --git a/core/examples/http_bench.rs b/core/examples/http_bench.rs index 233864fac..92e69d215 100644 --- a/core/examples/http_bench.rs +++ b/core/examples/http_bench.rs @@ -117,18 +117,19 @@ impl Isolate { { let state = self.state.clone(); let core_handler = move |_isolate_state: &mut CoreIsolateState, - control_buf: &[u8], zero_copy_bufs: &mut [ZeroCopyBuf]| -> Op { + assert!(!zero_copy_bufs.is_empty()); let state = state.clone(); - let record = Record::from(control_buf); + let record = Record::from(zero_copy_bufs[0].as_ref()); let is_sync = record.promise_id == 0; assert!(is_sync); - let result: i32 = match handler(state, record.rid, zero_copy_bufs) { - Ok(r) => r as i32, - Err(_) => -1, - }; + let result: i32 = + match handler(state, record.rid, &mut zero_copy_bufs[1..]) { + Ok(r) => r as i32, + Err(_) => -1, + }; let buf = RecordBuf::from(Record { result, ..record })[..].into(); Op::Sync(buf) }; @@ -147,15 +148,15 @@ impl Isolate { { let state = self.state.clone(); let core_handler = move |_isolate_state: &mut CoreIsolateState, - control_buf: &[u8], zero_copy_bufs: &mut [ZeroCopyBuf]| -> Op { + assert!(!zero_copy_bufs.is_empty()); let state = state.clone(); - let record = Record::from(control_buf); + let record = Record::from(zero_copy_bufs[0].as_ref()); let is_sync = record.promise_id == 0; assert!(!is_sync); - let mut zero_copy = zero_copy_bufs.to_vec(); + let mut zero_copy = zero_copy_bufs[1..].to_vec(); let fut = async move { let op = handler(state, record.rid, &mut zero_copy); let result = op |