YGGverse/aquatic
1
0
Fork 0
mirror of https://github.com/YGGverse/aquatic.git synced 2026-03-31 17:55:36 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

udp: improve formatting of imports

Browse source
This commit is contained in:
Joakim Frostegård 2022-04-16 00:43:23 +02:00
parent 1851886992
commit 29f97e881e
4 changed files with 15 additions and 20 deletions
Download patch file Download diff file Expand all files Collapse all files

5
aquatic_udp/src/workers/request/mod.rs
View file

@ -6,13 +6,10 @@ use std::sync::atomic::Ordering;
use std::time::Duration;
use std::time::Instant;
use aquatic_common::CanonicalSocketAddr;
use aquatic_common::PanicSentinel;
use aquatic_common::ValidUntil;
use crossbeam_channel::Receiver;
use rand::{rngs::SmallRng, SeedableRng};
use aquatic_common::extract_response_peers;
use aquatic_common::{extract_response_peers, CanonicalSocketAddr, PanicSentinel, ValidUntil};
use aquatic_udp_protocol::*;

8
aquatic_udp/src/workers/request/storage.rs
View file

@ -3,10 +3,10 @@ use std::net::Ipv6Addr;
use std::sync::Arc;
use std::time::Instant;
use aquatic_common::access_list::create_access_list_cache;
use aquatic_common::access_list::AccessListArcSwap;
use aquatic_common::AmortizedIndexMap;
use aquatic_common::ValidUntil;
use aquatic_common::{
access_list::{create_access_list_cache, AccessListArcSwap},
AmortizedIndexMap, ValidUntil,
};
use aquatic_udp_protocol::*;

18
aquatic_udp/src/workers/socket/mod.rs
View file

@ -5,23 +5,23 @@ mod storage;
use std::time::{Duration, Instant};
use anyhow::Context;
use aquatic_common::privileges::PrivilegeDropper;
use crossbeam_channel::Receiver;
use mio::net::UdpSocket;
use mio::{Events, Interest, Poll, Token};
use aquatic_common::access_list::create_access_list_cache;
use aquatic_common::CanonicalSocketAddr;
use aquatic_common::{PanicSentinel, ValidUntil};
use aquatic_udp_protocol::*;
use socket2::{Domain, Protocol, Socket, Type};
use aquatic_common::{
access_list::create_access_list_cache, privileges::PrivilegeDropper, CanonicalSocketAddr,
PanicSentinel, ValidUntil,
};
use aquatic_udp_protocol::*;
use crate::common::*;
use crate::config::Config;
use self::requests::read_requests;
use self::responses::send_responses;
use self::storage::PendingScrapeResponseSlab;
use requests::read_requests;
use responses::send_responses;
use storage::PendingScrapeResponseSlab;
pub fn run_socket_worker(
_sentinel: PanicSentinel,

4
aquatic_udp/src/workers/socket/requests.rs
View file

@ -3,9 +3,7 @@ use std::sync::atomic::Ordering;
use mio::net::UdpSocket;
use aquatic_common::access_list::AccessListCache;
use aquatic_common::CanonicalSocketAddr;
use aquatic_common::ValidUntil;
use aquatic_common::{access_list::AccessListCache, CanonicalSocketAddr, ValidUntil};
use aquatic_udp_protocol::*;
use crate::common::*;