fmt
This commit is contained in:
parent
909d0f8574
commit
69c3581f1a
@ -65,8 +65,8 @@ use serde::{Deserialize, Serialize};
|
|||||||
#[cfg(feature = "std")]
|
#[cfg(feature = "std")]
|
||||||
use std::{
|
use std::{
|
||||||
env, fs,
|
env, fs,
|
||||||
net::SocketAddr,
|
|
||||||
io::{Read, Write},
|
io::{Read, Write},
|
||||||
|
net::SocketAddr,
|
||||||
net::{TcpListener, TcpStream},
|
net::{TcpListener, TcpStream},
|
||||||
thread,
|
thread,
|
||||||
};
|
};
|
||||||
|
@ -514,17 +514,18 @@ where
|
|||||||
|
|
||||||
// We start ourself as child process to actually fuzz
|
// We start ourself as child process to actually fuzz
|
||||||
if std::env::var(_ENV_FUZZER_SENDER).is_err() {
|
if std::env::var(_ENV_FUZZER_SENDER).is_err() {
|
||||||
|
|
||||||
#[cfg(target_os = "android")]
|
#[cfg(target_os = "android")]
|
||||||
{
|
{
|
||||||
let path = std::env::current_dir()?;
|
let path = std::env::current_dir()?;
|
||||||
mgr = LlmpEventManager::<I, S, SH, ST>::new_on_domain_socket(
|
mgr = LlmpEventManager::<I, S, SH, ST>::new_on_domain_socket(
|
||||||
stats,
|
stats,
|
||||||
&format!("{}/.llmp_socket", path.display()).to_string(),
|
&format!("{}/.llmp_socket", path.display()).to_string(),
|
||||||
)?;
|
)?;
|
||||||
};
|
};
|
||||||
#[cfg(not(target_os = "android"))]
|
#[cfg(not(target_os = "android"))]
|
||||||
{mgr = LlmpEventManager::<I, S, SH, ST>::new_on_port(stats, broker_port)?};
|
{
|
||||||
|
mgr = LlmpEventManager::<I, S, SH, ST>::new_on_port(stats, broker_port)?
|
||||||
|
};
|
||||||
|
|
||||||
if mgr.is_broker() {
|
if mgr.is_broker() {
|
||||||
// Yep, broker. Just loop here.
|
// Yep, broker. Just loop here.
|
||||||
|
Loading…
x
Reference in New Issue
Block a user