29828895317

Committed 21 Jul 2026 12:08PM UTC coverage: 87.59% (-0.2%) from 87.839%

Build # 29828895317

Build Type

Pull #1192

github

Committed by

web-flow

Commit Message

Merge bd6b2979b into 1baac981e

Pull Request Pull Request #1192: feat: add Gdal process pool

Coverage Stats

3028 of 3724 new or added lines in 38 files covered. (81.31%)

16 existing lines in 5 files now uncovered.

123314 of 140785 relevant lines covered (87.59%)

481313.41 hits per line

Source File
Press 'n' to go to next uncovered line, 'b' for previous

0.0

/geoengine/operators/src/source/gdal_source/error.rs

use std::io;

use geoengine_datatypes::raster::{GridBoundingBox2D, RasterDataType};
use ipc_channel::IpcError;
use snafu::Snafu;

use crate::source::gdal_worker_process::{GdalProcessPoolError, process_common::IpcProcessError};

#[derive(Debug, Snafu)]
#[snafu(visibility(pub(crate)))]
#[snafu(context(suffix(false)))] // disables default `Snafu` suffix
pub enum GdalSourceError {
    #[snafu(display("Unsupported raster type: {raster_type:?}"))]
    UnsupportedRasterType {
        raster_type: RasterDataType,
    },

    #[snafu(display("Unsupported spatial query: {spatial_query:?}"))]
    IncompatibleSpatialQuery {
        spatial_query: GridBoundingBox2D,
    },

    #[snafu(display("GdalProcess with an unknown error: {error}"))]
    UnknownErrorHappenedWhileReading {
        error: String,
    },

    #[snafu(display("Encountered a poisoned ProcessData Mutex"))]
    ProcessLockPoisoned {
        error: String,
    },

    #[snafu(display("Error while sending data through ipc_channel: {error}"))]
    IpcSendError {
        error: IpcError,
    },

    #[snafu(display("Error while receiving data through ipc_channel: {error}"))]
    IpcReceiveError {
        error: IpcError,
    },

    #[snafu(display("Error while setting up the GdalSource reading process: {reason}"))]
    ProcessSetupFailed {
        reason: io::Error,
    },

    #[snafu(display("Error in the GdalSource reading process: {source}"))]
    IpcProcessError {
        source: IpcProcessError,
    },

    PoolInitializationError,

    WorkerPanic,

    GdalProcessPoolError {
        source: GdalProcessPoolError,
    },
}

impl From<GdalProcessPoolError> for GdalSourceError {
    fn from(source: GdalProcessPoolError) -> Self {
        GdalSourceError::GdalProcessPoolError { source }
    }
}

1	use std::io;
2
3	use geoengine_datatypes::raster::{GridBoundingBox2D, RasterDataType};
4	use ipc_channel::IpcError;
5	use snafu::Snafu;
6
7	use crate::source::gdal_worker_process::{GdalProcessPoolError, process_common::IpcProcessError};
8
9	#[derive(Debug, Snafu)]
10	#[snafu(visibility(pub(crate)))]
11	#[snafu(context(suffix(false)))] // disables default `Snafu` suffix
12	pub enum GdalSourceError {
13	#[snafu(display("Unsupported raster type: {raster_type:?}"))]
14	UnsupportedRasterType {
15	raster_type: RasterDataType,
16	},
17
18	#[snafu(display("Unsupported spatial query: {spatial_query:?}"))]
19	IncompatibleSpatialQuery {
20	spatial_query: GridBoundingBox2D,
21	},
22
23	#[snafu(display("GdalProcess with an unknown error: {error}"))]
24	UnknownErrorHappenedWhileReading {
25	error: String,
26	},
27
28	#[snafu(display("Encountered a poisoned ProcessData Mutex"))]
29	ProcessLockPoisoned {
30	error: String,
31	},
32
33	#[snafu(display("Error while sending data through ipc_channel: {error}"))]
34	IpcSendError {
35	error: IpcError,
36	},
37
38	#[snafu(display("Error while receiving data through ipc_channel: {error}"))]
39	IpcReceiveError {
40	error: IpcError,
41	},
42
43	#[snafu(display("Error while setting up the GdalSource reading process: {reason}"))]
44	ProcessSetupFailed {
45	reason: io::Error,
46	},
47
48	#[snafu(display("Error in the GdalSource reading process: {source}"))]
49	IpcProcessError {
50	source: IpcProcessError,
51	},
52
53	PoolInitializationError,
54
55	WorkerPanic,
56
57	GdalProcessPoolError {
58	source: GdalProcessPoolError,
59	},
60	}
61
62	impl From<GdalProcessPoolError> for GdalSourceError {
NEW 63	fn from(source: GdalProcessPoolError) -> Self {	×
NEW 64	GdalSourceError::GdalProcessPoolError { source }	×
NEW 65	}	×
66	}

geo-engine / geoengine / 29828895317

Source File Press 'n' to go to next uncovered line, 'b' for previous

Source File
Press 'n' to go to next uncovered line, 'b' for previous