Skip to content

Commit

Permalink
Updating dropshot, handling new log_headers field in config struct (#…
Browse files Browse the repository at this point in the history
  • Loading branch information
bnaecker authored Jul 18, 2024
1 parent 2ba2846 commit c5ed4de
Show file tree
Hide file tree
Showing 14 changed files with 24 additions and 8 deletions.
11 changes: 6 additions & 5 deletions Cargo.lock

Some generated files are not rendered by default. Learn more about how customized files appear on GitHub.

1 change: 1 addition & 0 deletions dns-server/src/lib.rs
Original file line number Diff line number Diff line change
Expand Up @@ -138,6 +138,7 @@ impl TransientServer {
bind_address: "[::1]:0".parse().unwrap(),
request_body_max_bytes: 4 * 1024 * 1024,
default_handler_task_mode: dropshot::HandlerTaskMode::Detached,
log_headers: vec![],
},
)
.await?;
Expand Down
1 change: 1 addition & 0 deletions dns-server/tests/basic_test.rs
Original file line number Diff line number Diff line change
Expand Up @@ -419,6 +419,7 @@ fn test_config(
bind_address: "[::1]:0".to_string().parse().unwrap(),
request_body_max_bytes: 1024,
default_handler_task_mode: HandlerTaskMode::Detached,
log_headers: vec![],
};

Ok((tmp_dir, config_storage, config_dropshot, logctx))
Expand Down
1 change: 1 addition & 0 deletions gateway/src/lib.rs
Original file line number Diff line number Diff line change
Expand Up @@ -98,6 +98,7 @@ fn start_dropshot_server(
bind_address: SocketAddr::V6(addr),
request_body_max_bytes,
default_handler_task_mode: HandlerTaskMode::Detached,
log_headers: vec![],
};
let http_server_starter = dropshot::HttpServerStarter::new(
&dropshot,
Expand Down
2 changes: 2 additions & 0 deletions installinator-api/src/lib.rs
Original file line number Diff line number Diff line change
Expand Up @@ -131,6 +131,7 @@ pub fn default_config(bind_address: std::net::SocketAddr) -> ConfigDropshot {
// available in omicron.
request_body_max_bytes: 4 * 1024 * 1024,
default_handler_task_mode: HandlerTaskMode::Detached,
log_headers: vec![],
}
}

Expand All @@ -153,6 +154,7 @@ pub fn make_server_starter<T: InstallinatorApi>(
// available in omicron.
request_body_max_bytes: 4 * 1024 * 1024,
default_handler_task_mode: HandlerTaskMode::Detached,
log_headers: vec![],
};

let api = crate::installinator_api::api_description::<T>()?;
Expand Down
1 change: 1 addition & 0 deletions internal-dns/src/resolver.rs
Original file line number Diff line number Diff line change
Expand Up @@ -434,6 +434,7 @@ mod test {
bind_address: "[::1]:0".parse().unwrap(),
request_body_max_bytes: 8 * 1024,
default_handler_task_mode: HandlerTaskMode::Detached,
log_headers: vec![],
},
)
.await
Expand Down
1 change: 1 addition & 0 deletions nexus/src/app/background/init.rs
Original file line number Diff line number Diff line change
Expand Up @@ -928,6 +928,7 @@ pub mod test {
bind_address: "[::1]:0".parse().unwrap(),
request_body_max_bytes: 8 * 1024,
default_handler_task_mode: HandlerTaskMode::Detached,
log_headers: vec![],
},
)
.await
Expand Down
1 change: 1 addition & 0 deletions nexus/test-utils/src/lib.rs
Original file line number Diff line number Diff line change
Expand Up @@ -1575,6 +1575,7 @@ pub async fn start_dns_server(
bind_address: "[::1]:0".parse().unwrap(),
request_body_max_bytes: 8 * 1024,
default_handler_task_mode: HandlerTaskMode::Detached,
log_headers: vec![],
},
)
.await
Expand Down
1 change: 1 addition & 0 deletions oximeter/producer/src/lib.rs
Original file line number Diff line number Diff line change
Expand Up @@ -222,6 +222,7 @@ impl Server {
bind_address: server_info.address,
request_body_max_bytes,
default_handler_task_mode: dropshot::HandlerTaskMode::Detached,
log_headers: vec![],
};
let server = Self::build_dropshot_server(&log, &registry, &dropshot)?;

Expand Down
2 changes: 1 addition & 1 deletion sled-agent/src/server.rs
Original file line number Diff line number Diff line change
Expand Up @@ -68,7 +68,7 @@ impl Server {

let dropshot_config = dropshot::ConfigDropshot {
bind_address: SocketAddr::V6(sled_address),
..config.dropshot
..config.dropshot.clone()
};
let dropshot_log = log.new(o!("component" => "dropshot (SledAgent)"));
let http_server = dropshot::HttpServerStarter::new(
Expand Down
2 changes: 2 additions & 0 deletions sled-agent/src/services.rs
Original file line number Diff line number Diff line change
Expand Up @@ -2160,6 +2160,7 @@ impl ServiceManager {
request_body_max_bytes: 8192 * 1024,
default_handler_task_mode:
HandlerTaskMode::Detached,
log_headers: vec![],
},
},
dropshot_internal: dropshot::ConfigDropshot {
Expand All @@ -2170,6 +2171,7 @@ impl ServiceManager {
// rack setup.
request_body_max_bytes: 10 * 1024 * 1024,
default_handler_task_mode: HandlerTaskMode::Detached,
log_headers: vec![],
},
internal_dns: nexus_config::InternalDns::FromSubnet {
subnet: Ipv6Subnet::<RACK_PREFIX>::new(
Expand Down
1 change: 1 addition & 0 deletions sled-agent/src/sim/storage.rs
Original file line number Diff line number Diff line change
Expand Up @@ -975,6 +975,7 @@ impl PantryServer {
// - bulk writes into disks
request_body_max_bytes: 8192 * 1024,
default_handler_task_mode: HandlerTaskMode::Detached,
log_headers: vec![],
},
super::http_entrypoints_pantry::api(),
pantry.clone(),
Expand Down
1 change: 1 addition & 0 deletions wicketd/src/lib.rs
Original file line number Diff line number Diff line change
Expand Up @@ -135,6 +135,7 @@ impl Server {
// some endpoints.
request_body_max_bytes: 4 << 30,
default_handler_task_mode: HandlerTaskMode::Detached,
log_headers: vec![],
};

let mgs_manager = MgsManager::new(&log, args.mgs_address);
Expand Down
6 changes: 4 additions & 2 deletions workspace-hack/Cargo.toml
Original file line number Diff line number Diff line change
Expand Up @@ -99,6 +99,7 @@ sha2 = { version = "0.10.8", features = ["oid"] }
similar = { version = "2.5.0", features = ["bytes", "inline", "unicode"] }
slog = { version = "2.7.0", features = ["dynamic-keys", "max_level_trace", "release_max_level_debug", "release_max_level_trace"] }
smallvec = { version = "1.13.2", default-features = false, features = ["const_new"] }
socket2 = { version = "0.5.7", default-features = false, features = ["all"] }
spin = { version = "0.9.8" }
string_cache = { version = "0.8.7" }
subtle = { version = "2.5.0" }
Expand All @@ -116,7 +117,7 @@ unicode-bidi = { version = "0.3.15" }
unicode-normalization = { version = "0.1.23" }
usdt = { version = "0.5.0" }
usdt-impl = { version = "0.5.0", default-features = false, features = ["asm", "des"] }
uuid = { version = "1.9.1", features = ["serde", "v4"] }
uuid = { version = "1.10.0", features = ["serde", "v4"] }
yasna = { version = "0.5.2", features = ["bit-vec", "num-bigint", "std", "time"] }
zerocopy = { version = "0.7.34", features = ["derive", "simd"] }
zeroize = { version = "1.7.0", features = ["std", "zeroize_derive"] }
Expand Down Expand Up @@ -204,6 +205,7 @@ sha2 = { version = "0.10.8", features = ["oid"] }
similar = { version = "2.5.0", features = ["bytes", "inline", "unicode"] }
slog = { version = "2.7.0", features = ["dynamic-keys", "max_level_trace", "release_max_level_debug", "release_max_level_trace"] }
smallvec = { version = "1.13.2", default-features = false, features = ["const_new"] }
socket2 = { version = "0.5.7", default-features = false, features = ["all"] }
spin = { version = "0.9.8" }
string_cache = { version = "0.8.7" }
subtle = { version = "2.5.0" }
Expand All @@ -224,7 +226,7 @@ unicode-normalization = { version = "0.1.23" }
unicode-xid = { version = "0.2.4" }
usdt = { version = "0.5.0" }
usdt-impl = { version = "0.5.0", default-features = false, features = ["asm", "des"] }
uuid = { version = "1.9.1", features = ["serde", "v4"] }
uuid = { version = "1.10.0", features = ["serde", "v4"] }
yasna = { version = "0.5.2", features = ["bit-vec", "num-bigint", "std", "time"] }
zerocopy = { version = "0.7.34", features = ["derive", "simd"] }
zeroize = { version = "1.7.0", features = ["std", "zeroize_derive"] }
Expand Down

0 comments on commit c5ed4de

Please sign in to comment.