summaryrefslogtreecommitdiff
path: root/core/examples/http_bench.rs
diff options
context:
space:
mode:
authorValentin Anger <syrupthinker@gryphno.de>2020-07-08 17:23:50 +0200
committerGitHub <noreply@github.com>2020-07-08 11:23:50 -0400
commitbe7e0f2d490ca480aaa154845c4c5c6dccbd7546 (patch)
treeb2a2d284c490a2a1cd8ec3b6175ea5d4077cc65e /core/examples/http_bench.rs
parentcbbd9443592f79f6abf9e5019840de4e01ff8580 (diff)
BREAKING(core): Remove control slice from ops (#6048)
Diffstat (limited to 'core/examples/http_bench.rs')
-rw-r--r--core/examples/http_bench.rs19
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