mirror of
https://github.com/servo/servo.git
synced 2025-09-29 16:19:14 +01:00
f766b66a97
Part of #39418. See that PR for a full description. Moves: - `read_json_from_file` - `write_json_to_file` - `IpcSendResult` - `IpcSend` Renames: - `CoreResourceThreadPool` to `ThreadPool` (shorter and more descriptive, as we use it for more than the core resource thread now) Signed-off-by: Ashwin Naren <arihant2math@gmail.com>
117 lines
3.3 KiB
Rust
117 lines
3.3 KiB
Rust
/* This Source Code Form is subject to the terms of the Mozilla Public
|
|
* License, v. 2.0. If a copy of the MPL was not distributed with this
|
|
* file, You can obtain one at https://mozilla.org/MPL/2.0/. */
|
|
|
|
#![deny(unsafe_code)]
|
|
|
|
//! A crate to hold very common types in Servo.
|
|
//!
|
|
//! You should almost never need to add a data type to this crate. Instead look for
|
|
//! a more shared crate that has fewer dependents.
|
|
|
|
pub mod cross_process_instant;
|
|
pub mod generic_channel;
|
|
pub mod id;
|
|
pub mod print_tree;
|
|
pub mod text;
|
|
pub mod threadpool;
|
|
mod unicode_block;
|
|
|
|
use std::fs::File;
|
|
use std::io::{BufWriter, Read};
|
|
use std::path::Path;
|
|
|
|
use ipc_channel::ipc::{IpcError, IpcSender};
|
|
use log::{trace, warn};
|
|
use malloc_size_of_derive::MallocSizeOf;
|
|
use serde::{Deserialize, Serialize};
|
|
use webrender_api::Epoch as WebRenderEpoch;
|
|
|
|
pub fn read_json_from_file<T>(data: &mut T, config_dir: &Path, filename: &str)
|
|
where
|
|
T: for<'de> Deserialize<'de>,
|
|
{
|
|
let path = config_dir.join(filename);
|
|
let display = path.display();
|
|
|
|
let mut file = match File::open(&path) {
|
|
Err(why) => {
|
|
warn!("couldn't open {}: {}", display, why);
|
|
return;
|
|
},
|
|
Ok(file) => file,
|
|
};
|
|
|
|
let mut string_buffer: String = String::new();
|
|
match file.read_to_string(&mut string_buffer) {
|
|
Err(why) => panic!("couldn't read from {}: {}", display, why),
|
|
Ok(_) => trace!("successfully read from {}", display),
|
|
}
|
|
|
|
match serde_json::from_str(&string_buffer) {
|
|
Ok(decoded_buffer) => *data = decoded_buffer,
|
|
Err(why) => warn!("Could not decode buffer{}", why),
|
|
}
|
|
}
|
|
|
|
pub fn write_json_to_file<T>(data: &T, config_dir: &Path, filename: &str)
|
|
where
|
|
T: Serialize,
|
|
{
|
|
let path = config_dir.join(filename);
|
|
let display = path.display();
|
|
|
|
let mut file = match File::create(&path) {
|
|
Err(why) => panic!("couldn't create {}: {}", display, why),
|
|
Ok(file) => file,
|
|
};
|
|
let mut writer = BufWriter::new(&mut file);
|
|
serde_json::to_writer_pretty(&mut writer, data).expect("Could not serialize to file");
|
|
trace!("successfully wrote to {display}");
|
|
}
|
|
|
|
/// A struct for denoting the age of messages; prevents race conditions.
|
|
#[derive(
|
|
Clone, Copy, Debug, Deserialize, Eq, Hash, Ord, PartialEq, PartialOrd, Serialize, MallocSizeOf,
|
|
)]
|
|
pub struct Epoch(pub u32);
|
|
|
|
impl Epoch {
|
|
pub fn next(&mut self) {
|
|
self.0 += 1;
|
|
}
|
|
}
|
|
|
|
impl From<Epoch> for WebRenderEpoch {
|
|
fn from(val: Epoch) -> Self {
|
|
WebRenderEpoch(val.0)
|
|
}
|
|
}
|
|
|
|
pub trait WebRenderEpochToU16 {
|
|
fn as_u16(&self) -> u16;
|
|
}
|
|
|
|
impl WebRenderEpochToU16 for WebRenderEpoch {
|
|
/// The value of this [`Epoch`] as a u16 value. Note that if this Epoch's
|
|
/// value is more than u16::MAX, then the return value will be modulo
|
|
/// u16::MAX.
|
|
fn as_u16(&self) -> u16 {
|
|
(self.0 % u16::MAX as u32) as u16
|
|
}
|
|
}
|
|
|
|
pub type IpcSendResult = Result<(), IpcError>;
|
|
|
|
/// Abstraction of the ability to send a particular type of message,
|
|
/// used by net_traits::ResourceThreads to ease the use its IpcSender sub-fields
|
|
/// XXX: If this trait will be used more in future, some auto derive might be appealing
|
|
pub trait IpcSend<T>
|
|
where
|
|
T: serde::Serialize + for<'de> serde::Deserialize<'de>,
|
|
{
|
|
/// send message T
|
|
fn send(&self, _: T) -> IpcSendResult;
|
|
/// get underlying sender
|
|
fn sender(&self) -> IpcSender<T>;
|
|
}
|