Skip to content

Commit e58ca36

Browse files
authored
Update Omicron and Dropshot dependency (#1388)
Picks up new `log_headers` field in Dropshot configuration type
1 parent bc2ed48 commit e58ca36

File tree

8 files changed

+233
-154
lines changed

8 files changed

+233
-154
lines changed

Cargo.lock

+180-118
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

agent/src/server.rs

+13-29
Original file line numberDiff line numberDiff line change
@@ -1,4 +1,4 @@
1-
// Copyright 2021 Oxide Computer Company
1+
// Copyright 2024 Oxide Computer Company
22
use super::datafile::DataFile;
33
use super::model;
44
use anyhow::{anyhow, Result};
@@ -14,16 +14,6 @@ use std::net::SocketAddr;
1414
use std::result::Result as SResult;
1515
use std::sync::Arc;
1616

17-
trait AnyhowFromString<T> {
18-
fn or_bail(self, msg: &str) -> Result<T>;
19-
}
20-
21-
impl<T> AnyhowFromString<T> for SResult<T, String> {
22-
fn or_bail(self, msg: &str) -> Result<T> {
23-
self.map_err(|e| anyhow!("{}: {:?}", msg, e))
24-
}
25-
}
26-
2717
#[endpoint {
2818
method = GET,
2919
path = "/crucible/0/regions",
@@ -337,24 +327,17 @@ async fn region_delete_running_snapshot(
337327
pub fn make_api() -> Result<dropshot::ApiDescription<Arc<DataFile>>> {
338328
let mut api = dropshot::ApiDescription::new();
339329

340-
api.register(region_list).or_bail("registration failure")?;
341-
api.register(region_create)
342-
.or_bail("registration failure")?;
343-
api.register(region_get).or_bail("registration failure")?;
344-
api.register(region_delete)
345-
.or_bail("registration failure")?;
346-
347-
api.register(region_get_snapshots)
348-
.or_bail("registration failure")?;
349-
api.register(region_get_snapshot)
350-
.or_bail("registration failure")?;
351-
api.register(region_delete_snapshot)
352-
.or_bail("registration failure")?;
353-
354-
api.register(region_run_snapshot)
355-
.or_bail("registration failure")?;
356-
api.register(region_delete_running_snapshot)
357-
.or_bail("registration failure")?;
330+
api.register(region_list)?;
331+
api.register(region_create)?;
332+
api.register(region_get)?;
333+
api.register(region_delete)?;
334+
335+
api.register(region_get_snapshots)?;
336+
api.register(region_get_snapshot)?;
337+
api.register(region_delete_snapshot)?;
338+
339+
api.register(region_run_snapshot)?;
340+
api.register(region_delete_running_snapshot)?;
358341

359342
Ok(api)
360343
}
@@ -371,6 +354,7 @@ pub async fn run_server(
371354
bind_address,
372355
request_body_max_bytes: 1024 * 10,
373356
default_handler_task_mode: HandlerTaskMode::Detached,
357+
log_headers: vec![],
374358
},
375359
api,
376360
df,

downstairs/src/admin.rs

+2-4
Original file line numberDiff line numberDiff line change
@@ -95,10 +95,8 @@ pub async fn run_downstairs_for_region(
9595

9696
fn register_endpoints(
9797
api_description: &mut ApiDescription<Arc<ServerContext>>,
98-
) -> Result<(), String> {
99-
api_description.register(run_downstairs_for_region)?;
100-
101-
Ok(())
98+
) -> Result<(), dropshot::ApiDescriptionRegisterError> {
99+
api_description.register(run_downstairs_for_region)
102100
}
103101

104102
pub async fn run_dropshot(

downstairs/src/repair.rs

+1
Original file line numberDiff line numberDiff line change
@@ -59,6 +59,7 @@ pub fn repair_main(
5959
bind_address: addr,
6060
request_body_max_bytes: 1024,
6161
default_handler_task_mode: HandlerTaskMode::Detached,
62+
log_headers: vec![],
6263
};
6364

6465
/*

dsc/src/control.rs

+1
Original file line numberDiff line numberDiff line change
@@ -49,6 +49,7 @@ pub async fn begin(dsci: Arc<DscInfo>, addr: SocketAddr) -> Result<(), String> {
4949
bind_address: addr,
5050
request_body_max_bytes: 1024,
5151
default_handler_task_mode: HandlerTaskMode::Detached,
52+
log_headers: vec![],
5253
};
5354
println!("start access at:{:?}", addr);
5455

pantry/src/server.rs

+5-1
Original file line numberDiff line numberDiff line change
@@ -432,7 +432,10 @@ async fn detach(
432432
Ok(HttpResponseDeleted())
433433
}
434434

435-
pub fn make_api() -> Result<dropshot::ApiDescription<Arc<Pantry>>, String> {
435+
pub fn make_api() -> Result<
436+
dropshot::ApiDescription<Arc<Pantry>>,
437+
dropshot::ApiDescriptionRegisterError,
438+
> {
436439
let mut api = dropshot::ApiDescription::new();
437440

438441
api.register(pantry_status)?;
@@ -468,6 +471,7 @@ pub fn run_server(
468471
request_body_max_bytes: 1024
469472
+ crate::pantry::PantryEntry::MAX_CHUNK_SIZE * 2,
470473
default_handler_task_mode: HandlerTaskMode::Detached,
474+
log_headers: vec![],
471475
},
472476
api,
473477
df.clone(),

upstairs/src/control.rs

+1
Original file line numberDiff line numberDiff line change
@@ -37,6 +37,7 @@ pub async fn start(
3737
bind_address: addr,
3838
request_body_max_bytes: 1024,
3939
default_handler_task_mode: HandlerTaskMode::Detached,
40+
log_headers: vec![],
4041
};
4142

4243
/*

workspace-hack/Cargo.toml

+30-2
Original file line numberDiff line numberDiff line change
@@ -43,7 +43,6 @@ openapiv3 = { version = "2", default-features = false, features = ["skip_seriali
4343
phf_shared = { version = "0.11" }
4444
rand = { version = "0.8", features = ["min_const_gen", "small_rng"] }
4545
rand_chacha = { version = "0.3" }
46-
rand_core = { version = "0.6", default-features = false, features = ["std"] }
4746
reqwest = { version = "0.11", features = ["blocking", "json", "rustls-tls", "stream"] }
4847
schemars = { version = "0.8", features = ["bytes", "chrono", "uuid1"] }
4948
scopeguard = { version = "1" }
@@ -68,27 +67,44 @@ bitflags = { version = "2", default-features = false, features = ["serde", "std"
6867
bytes = { version = "1", features = ["serde"] }
6968
cc = { version = "1", default-features = false, features = ["parallel"] }
7069
chrono = { version = "0.4", features = ["serde"] }
70+
crossbeam-utils = { version = "0.8" }
71+
crypto-common = { version = "0.1", default-features = false, features = ["getrandom", "std"] }
72+
digest = { version = "0.10", features = ["mac", "std"] }
73+
futures-channel = { version = "0.3", features = ["sink"] }
74+
futures-core = { version = "0.3" }
75+
futures-executor = { version = "0.3" }
76+
futures-sink = { version = "0.3" }
77+
futures-util = { version = "0.3", features = ["channel", "io", "sink"] }
7178
getrandom = { version = "0.2", default-features = false, features = ["std"] }
7279
hashbrown = { version = "0.14", features = ["raw"] }
80+
hex = { version = "0.4", features = ["serde"] }
7381
indexmap = { version = "2", features = ["serde"] }
7482
libc = { version = "0.2", features = ["extra_traits"] }
7583
log = { version = "0.4", default-features = false, features = ["std"] }
7684
memchr = { version = "2" }
85+
num-integer = { version = "0.1", default-features = false, features = ["i128", "std"] }
86+
num-iter = { version = "0.1", default-features = false, features = ["i128", "std"] }
7787
num-traits = { version = "0.2", features = ["i128", "libm"] }
7888
openapiv3 = { version = "2", default-features = false, features = ["skip_serializing_defaults"] }
7989
phf_shared = { version = "0.11" }
8090
rand = { version = "0.8", features = ["min_const_gen", "small_rng"] }
8191
rand_chacha = { version = "0.3" }
82-
rand_core = { version = "0.6", default-features = false, features = ["std"] }
92+
reqwest = { version = "0.11", features = ["blocking", "json", "rustls-tls", "stream"] }
8393
schemars = { version = "0.8", features = ["bytes", "chrono", "uuid1"] }
94+
scopeguard = { version = "1" }
8495
semver = { version = "1", features = ["serde"] }
8596
serde = { version = "1", features = ["alloc", "derive", "rc"] }
97+
slog = { version = "2", features = ["dynamic-keys", "max_level_trace", "release_max_level_debug"] }
8698
syn = { version = "2", features = ["extra-traits", "full", "visit", "visit-mut"] }
8799
time = { version = "0.3", features = ["formatting", "local-offset", "macros", "parsing"] }
88100
time-macros = { version = "0.2", default-features = false, features = ["formatting", "parsing"] }
101+
tokio = { version = "1", features = ["full", "test-util"] }
89102
toml_datetime = { version = "0.6", default-features = false, features = ["serde"] }
103+
tracing = { version = "0.1" }
104+
tracing-core = { version = "0.1" }
90105
unicode-bidi = { version = "0.3" }
91106
unicode-normalization = { version = "0.1" }
107+
usdt = { version = "0.5" }
92108
usdt-impl = { version = "0.5", default-features = false, features = ["asm", "des"] }
93109
uuid = { version = "1", features = ["serde", "v4"] }
94110
zerocopy = { version = "0.7", features = ["derive", "simd"] }
@@ -104,7 +120,11 @@ spin = { version = "0.9", default-features = false, features = ["once", "spin_mu
104120

105121
[target.x86_64-unknown-linux-gnu.build-dependencies]
106122
dof = { version = "0.3", default-features = false, features = ["des"] }
123+
hyper = { version = "0.14", features = ["full"] }
124+
mio = { version = "0.8", features = ["net", "os-ext"] }
107125
once_cell = { version = "1", features = ["unstable"] }
126+
rustls = { version = "0.21", features = ["dangerous_configuration"] }
127+
spin = { version = "0.9", default-features = false, features = ["once", "spin_mutex"] }
108128

109129
[target.aarch64-apple-darwin.dependencies]
110130
hyper = { version = "0.14", features = ["full"] }
@@ -114,7 +134,11 @@ rustix = { version = "0.38", features = ["fs", "termios"] }
114134
rustls = { version = "0.21", features = ["dangerous_configuration"] }
115135

116136
[target.aarch64-apple-darwin.build-dependencies]
137+
hyper = { version = "0.14", features = ["full"] }
138+
mio = { version = "0.8", features = ["net", "os-ext"] }
117139
once_cell = { version = "1", features = ["unstable"] }
140+
rustix = { version = "0.38", features = ["fs", "termios"] }
141+
rustls = { version = "0.21", features = ["dangerous_configuration"] }
118142

119143
[target.x86_64-unknown-illumos.dependencies]
120144
dof = { version = "0.3", default-features = false, features = ["des"] }
@@ -127,6 +151,10 @@ spin = { version = "0.9", default-features = false, features = ["once", "spin_mu
127151

128152
[target.x86_64-unknown-illumos.build-dependencies]
129153
dof = { version = "0.3", default-features = false, features = ["des"] }
154+
hyper = { version = "0.14", features = ["full"] }
155+
mio = { version = "0.8", features = ["net", "os-ext"] }
130156
once_cell = { version = "1", features = ["unstable"] }
157+
rustls = { version = "0.21", features = ["dangerous_configuration"] }
158+
spin = { version = "0.9", default-features = false, features = ["once", "spin_mutex"] }
131159

132160
### END HAKARI SECTION

0 commit comments

Comments
 (0)