more events, more fun
This commit is contained in:
parent
c0b0ccccf3
commit
afce4f3330
@ -498,7 +498,9 @@ where
|
|||||||
state: &mut State<I, R, FT>,
|
state: &mut State<I, R, FT>,
|
||||||
corpus: &mut C,
|
corpus: &mut C,
|
||||||
) -> Result<usize, AflError> {
|
) -> Result<usize, AflError> {
|
||||||
let count = match &mut self.llmp {
|
// TODO: Get around local event copy by moving handle_in_client
|
||||||
|
let mut events = vec![];
|
||||||
|
match &mut self.llmp {
|
||||||
llmp::LlmpConnection::IsClient {client} => {
|
llmp::LlmpConnection::IsClient {client} => {
|
||||||
let mut msg_count = 0;
|
let mut msg_count = 0;
|
||||||
loop {
|
loop {
|
||||||
@ -508,9 +510,8 @@ where
|
|||||||
if tag == _LLMP_TAG_EVENT_TO_BROKER {
|
if tag == _LLMP_TAG_EVENT_TO_BROKER {
|
||||||
continue;
|
continue;
|
||||||
}
|
}
|
||||||
let event = postcard::from_bytes(event_buf)?;
|
let event: Event<I> = postcard::from_bytes(event_buf)?;
|
||||||
// TODO: self.handle_in_client(event, state, corpus)?;
|
events.push(event);
|
||||||
msg_count += 1;
|
|
||||||
},
|
},
|
||||||
None => break msg_count,
|
None => break msg_count,
|
||||||
}
|
}
|
||||||
@ -521,6 +522,8 @@ where
|
|||||||
0
|
0
|
||||||
}
|
}
|
||||||
};
|
};
|
||||||
|
let count = events.len();
|
||||||
|
events.into_iter().try_for_each(|event| self.handle_in_client(event, state, corpus))?;
|
||||||
Ok(count)
|
Ok(count)
|
||||||
}
|
}
|
||||||
|
|
||||||
|
Loading…
x
Reference in New Issue
Block a user