062cf75cdf
when we remove a datastore via api/cli, the proxy has sometimes leftover references to that datastore in its DATASTORE_MAP which includes an open filehandle on the '.lock' file this prevents unmounting/exporting the datastore even after removal, only a reload/restart of the proxy did help add a command to our command socket, which removes all non configured datastores from the map, dropping the open filehandle Signed-off-by: Dominik Csapak <d.csapak@proxmox.com> Signed-off-by: Dietmar Maurer <dietmar@proxmox.com>
111 lines
2.4 KiB
Rust
111 lines
2.4 KiB
Rust
//! Proxmox Server/Service framework
|
|
//!
|
|
//! This code provides basic primitives to build our REST API
|
|
//! services. We want async IO, so this is built on top of
|
|
//! tokio/hyper.
|
|
|
|
use anyhow::{format_err, Error};
|
|
use lazy_static::lazy_static;
|
|
use nix::unistd::Pid;
|
|
use serde_json::Value;
|
|
|
|
use proxmox::sys::linux::procfs::PidStat;
|
|
|
|
use crate::buildcfg;
|
|
|
|
lazy_static! {
|
|
static ref PID: i32 = unsafe { libc::getpid() };
|
|
static ref PSTART: u64 = PidStat::read_from_pid(Pid::from_raw(*PID)).unwrap().starttime;
|
|
}
|
|
|
|
pub fn pid() -> i32 {
|
|
*PID
|
|
}
|
|
|
|
pub fn pstart() -> u64 {
|
|
*PSTART
|
|
}
|
|
|
|
pub fn write_pid(pid_fn: &str) -> Result<(), Error> {
|
|
let pid_str = format!("{}\n", *PID);
|
|
let opts = proxmox::tools::fs::CreateOptions::new();
|
|
proxmox::tools::fs::replace_file(pid_fn, pid_str.as_bytes(), opts)
|
|
}
|
|
|
|
pub fn read_pid(pid_fn: &str) -> Result<i32, Error> {
|
|
let pid = proxmox::tools::fs::file_get_contents(pid_fn)?;
|
|
let pid = std::str::from_utf8(&pid)?.trim();
|
|
pid.parse().map_err(|err| format_err!("could not parse pid - {}", err))
|
|
}
|
|
|
|
pub fn ctrl_sock_from_pid(pid: i32) -> String {
|
|
format!("\0{}/control-{}.sock", buildcfg::PROXMOX_BACKUP_RUN_DIR, pid)
|
|
}
|
|
|
|
pub fn our_ctrl_sock() -> String {
|
|
ctrl_sock_from_pid(*PID)
|
|
}
|
|
|
|
mod environment;
|
|
pub use environment::*;
|
|
|
|
mod upid;
|
|
pub use upid::*;
|
|
|
|
mod state;
|
|
pub use state::*;
|
|
|
|
mod command_socket;
|
|
pub use command_socket::*;
|
|
|
|
mod worker_task;
|
|
pub use worker_task::*;
|
|
|
|
mod h2service;
|
|
pub use h2service::*;
|
|
|
|
pub mod config;
|
|
pub use config::*;
|
|
|
|
pub mod formatter;
|
|
|
|
#[macro_use]
|
|
pub mod rest;
|
|
|
|
pub mod jobstate;
|
|
|
|
mod verify_job;
|
|
pub use verify_job::*;
|
|
|
|
mod prune_job;
|
|
pub use prune_job::*;
|
|
|
|
mod gc_job;
|
|
pub use gc_job::*;
|
|
|
|
mod email_notifications;
|
|
pub use email_notifications::*;
|
|
|
|
mod report;
|
|
pub use report::*;
|
|
|
|
pub mod ticket;
|
|
|
|
pub mod auth;
|
|
|
|
pub(crate) async fn reload_proxy_certificate() -> Result<(), Error> {
|
|
let proxy_pid = crate::server::read_pid(buildcfg::PROXMOX_BACKUP_PROXY_PID_FN)?;
|
|
let sock = crate::server::ctrl_sock_from_pid(proxy_pid);
|
|
let _: Value = crate::server::send_raw_command(sock, "{\"command\":\"reload-certificate\"}\n")
|
|
.await?;
|
|
Ok(())
|
|
}
|
|
|
|
pub(crate) async fn notify_datastore_removed() -> Result<(), Error> {
|
|
let proxy_pid = crate::server::read_pid(buildcfg::PROXMOX_BACKUP_PROXY_PID_FN)?;
|
|
let sock = crate::server::ctrl_sock_from_pid(proxy_pid);
|
|
let _: Value = crate::server::send_raw_command(sock, "{\"command\":\"datastore-removed\"}\n")
|
|
.await?;
|
|
Ok(())
|
|
}
|