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: socket workers: rename common.rs to storage.rs

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

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

@ -1,6 +1,6 @@
mod common;
mod requests;
mod responses;
mod storage;
use std::time::{Duration, Instant};
@ -19,9 +19,9 @@ use socket2::{Domain, Protocol, Socket, Type};
use crate::common::*;
use crate::config::Config;
use self::common::PendingScrapeResponseSlab;
use self::requests::read_requests;
use self::responses::send_responses;
use self::storage::PendingScrapeResponseSlab;
pub fn run_socket_worker(
_sentinel: PanicSentinel,

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

@ -11,7 +11,7 @@ use aquatic_udp_protocol::*;
use crate::common::*;
use crate::config::Config;
use super::common::PendingScrapeResponseSlab;
use super::storage::PendingScrapeResponseSlab;
pub fn read_requests(
config: &Config,

2
aquatic_udp/src/workers/socket/responses.rs
View file

@ -11,7 +11,7 @@ use aquatic_udp_protocol::*;
use crate::common::*;
use crate::config::Config;
use super::common::PendingScrapeResponseSlab;
use super::storage::PendingScrapeResponseSlab;
pub fn send_responses(
state: &State,

0
aquatic_udp/src/workers/socket/common.rs → aquatic_udp/src/workers/socket/storage.rs
View file