Struct Session 

pub struct Session { /* private fields */ }

점진 재구성 상태 값.

Implementations

impl Session

pub fn new(cfg: SessionConfig) -> Self

설정으로 빈 세션을 만든다.

Examples found in repository

examples/hooks.rs (line 43)

fn main() -> Result<(), String> {
    let out = std::env::args().nth(1).map(PathBuf::from).unwrap_or_else(|| std::env::temp_dir().join("cumulus3d_hooks"));
    let src = out.with_extension("src");
    if !src.join("gps_ref.txt").exists() {
        common::make_dataset(&src);
    }
    if out.exists() {
        std::fs::remove_dir_all(&out).map_err(|e| e.to_string())?;
    }
    let layout = Layout::discover(&src, 1)?;
    let npos = layout.frames.len();

    let mut cfg = SessionConfig::new(src.join("images"));
    cfg.gps = read_gps_file(src.join("gps_ref.txt")).map_err(|e| e.to_string())?;
    (cfg.span, cfg.overlap, cfg.total_positions, cfg.seed) = (4, 1, Some(npos), Some(7));
    if cumulus3d_cuda::is_available() {
        let mut d = DenseConfig::new(make_pm_backend("cuda"), parse_profile("fast")?);
        d.undistort.max_image_size = 160;
        cfg.dense = Some(d);
    }

    // 훅: 사건 문구 출력, 구역 점군 점 수, 경고·오류. 그리고 기본 출력 훅(파일).
    let pipeline = Pipeline::new(Session::new(cfg))
        .on_any(|e: &Event| {
            if let Some(t) = e.timeline_text() {
                println!("[event v{}] {t}", e.meta().version);
            }
        })
        .on(EventKind::ZonePreview, |e: &Event| {
            if let Event::ZonePreview { range, cloud, model, .. } = e {
                println!("  초벌 {}: 조밀 점 {} / 희소 점 {}", range.zone, cloud.len(), model.num_points3d());
            }
        })
        .on(EventKind::ZoneRefined, |e: &Event| {
            if let Event::ZoneRefined { range, cloud, model, .. } = e {
                println!("  정밀 {}: 조밀 점 {} / 희소 점 {}", range.zone, cloud.len(), model.num_points3d());
            }
        })
        .on_message(|k, m| eprintln!("  {k:?}: {m}"));
    let mut pipeline = sinks::attach(pipeline, &out, &SinkOptions::default()).map_err(|e| e.to_string())?;

    for p in 0..npos {
        pipeline.push(Input::Frames(FrameSet::new(CAMS.iter().map(|c| (*c, layout.name(c, p))))));
    }
    let (_, summary) = pipeline.finish();
    println!("이벤트 {} 개, 훅 호출 {} 번, 훅 패닉 {}", summary.events, summary.hook_calls, summary.hook_panics);

    for f in ["timeline.txt", "run.log", "snapshots/manifest.json", "snapshots/timeline.txt", "DONE"] {
        let p = out.join(f);
        println!("{} {}", if p.exists() { "있음" } else { "없음" }, p.display());
    }
    Ok(())
}

pub fn set_sink(&self, sink: Option<EventSink>)

즉시 전달 수신기 설정/해제(세션 계열 공유). 설정 시 쌓여 있던 배경 이벤트를 먼저 전달한다.

pub fn emit_external(&self, make: impl FnOnce(Meta) -> Event)

외부(예: 훅 실행기)에서 이 세션의 버전 순서로 이벤트를 낸다. 수신기가 없으면 수신함에 쌓인다.

pub fn advance(self, input: Input) -> (Session, Vec<Event>)

상태 전이(소유 버전, 복사 없음). step/poll/command/finish 는 이것의 얇은 감쌈.

pub fn apply(&mut self, input: Input) -> Vec<Event>

제자리 상태 전이. 반환 이벤트는 버전 순(그동안 배경 작업이 낸 이벤트도 제자리에 끼워 넣는다).

pub fn positions(&self) -> usize

처리한 위치 수.

pub fn frames(&self) -> &[Vec<FrameImage>]

위치별 프레임 묶음.

pub fn position_of(&self, name: &str) -> Option<usize>

영상 이름의 위치.

pub fn model(&self) -> Option<&Reconstruction>

현재 체인 모델(첫 모델 전에는 None).

pub fn adopted(&self) -> Option<usize>

체인의 기준으로 채택된 마지막 정밀 구역.

pub fn store(&self) -> &FeatureStore

특징 저장소.

pub fn graph(&self) -> &MatchGraph

대응 그래프.

pub fn config(&self) -> &SessionConfig

세션 설정.

pub fn arrived_zones(&self) -> Vec<ZoneRange>

도착(처리)한 구역들.

pub fn previews(&self) -> &BTreeMap<usize, PreviewZone>

구역별 초벌 결과.

pub fn refined(&self) -> BTreeMap<usize, RefinedZone>

구역별 정밀 결과(자세 확정된 것, 배경 작업과 공유되는 현재 값).

pub fn pending_jobs(&self) -> usize

아직 끝나지 않은 배경 정밀 작업 수.

pub fn version(&self) -> u64

마지막으로 발급한 이벤트 버전.

pub fn failed(&self) -> Option<&str>

치명 오류(특징 추출·매칭·첫 모델 실패). 있으면 이후 프레임은 무시된다.

pub fn is_finished(&self) -> bool

Finish 를 처리했는지.

Trait Implementations

impl Clone for Session

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Reducer for Session

crate::pipeline::Pipeline 이 구동하는 리듀서로서의 세션. finish 는 남은 구역을 닫고 배경 정밀 작업을 모두 기다린다.

type Input = Input

한 번에 밀어 넣는 입력(예: 위치 하나의 프레임 묶음).

fn step(&mut self, input: Input) -> Vec<Event>

입력 하나를 처리하고 그 결과 이벤트를 순서대로 돌려준다.

fn poll(&mut self) -> Vec<Event>

백그라운드 작업(정밀 처리 등) 중 끝난 것을 수거한다. 기다리지 않는다.

fn command(&mut self, c: Command) -> Vec<Event>

명령을 처리한다.

fn finish(&mut self) -> Vec<Event>

남은 백그라운드 작업을 모두 끝날 때까지 기다려 수거한다. 기본 구현은 poll 한 번. 백그라운드 작업이 있는 리듀서는 재정의해야 한다.