Wie sieht es aus

use telefork::{telefork, TeleforkLocation};

fn main() {
    let args: Vec<String> = std::env::args().collect();
    let destination = args.get(1).expect("expected arg: address of teleserver");

    let mut stream = std::net::TcpStream::connect(destination).unwrap();
    match telefork(&mut stream).unwrap() {
        TeleforkLocation::Child(val) => {
            println!("I teleported to another computer and was passed {}!", val);
        }
        TeleforkLocation::Parent => println!("Done sending!"),
    };
}

// load the scene locally, this might require loading local scene files to memory
let scene = create_scene();
let mut backbuffer = vec![Vec3::new(0.0, 0.0, 0.0); width * height];
telefork::yoyo(destination, || {
  // do a big ray tracing job on the remote server with many cores!
  render_scene(&scene, width, height, &mut backbuffer);
});
// write out the result to the local file system
save_png_file(width, height, &backbuffer);

Linux-Prozessanatomie

• (memory mappings): , . «» 4 . /proc/<pid>/maps. , , .
  
  
  • , , ( ).
• : , . , , - , , , . , .
  
• : , . - , . , , , TCP-, .
  
  • . stdin/stdout/stderr, 0, 1 2.
    
  • , , , .
• Verschiedenes : Es gibt einige andere Teile des Prozessstatus, die sich in der Replikationskomplexität unterscheiden. In den meisten Fällen spielen sie jedoch keine Rolle, z. B. brk (Heap-Zeiger). Einige von ihnen können nur mit Hilfe seltsamer Tricks oder spezieller Systemaufrufe wie PR_SET_MM_MAP wiederhergestellt werden , was die Wiederherstellung erschwert.

Wie man einen Prozess teleforkiert

Einreichen eines Prozesses mit telefork

1. «» . , , . fork .
   
2. . /proc/<pid>/maps , . proc_maps crate.
   
3. . DMTCP, , , . , [vdso], , , .
   
4. . , , process_vm_readv , .
   
5. Register übertragen . Ich benutze die Option PTRACE_GETREGSfür den ptrace -Systemaufruf . Hiermit können Sie alle Werte des Registers des untergeordneten Prozesses abrufen. Dann schreibe ich sie einfach in eine Nachricht auf dem Kanal.

Ausführen von Systemaufrufen in einem untergeordneten Prozess

1. syscall. syscall , . , process_vm_readv [vdso] , , , syscall Linux, . , [vdso].
   
2. , PTRACE_SETREGS. syscall, rax Linux, rdi, rsi, rdx, r10, r8, r9.
   
3. Führen Sie mit dem Parameter einen Schritt ausPTRACE_SINGLESTEP , um den Befehl syscall auszuführen.
   
4. Lesen Sie die Register mit PTRACE_GETREGS, um den Syscall-Rückgabewert wiederherzustellen, und prüfen Sie, ob dies erfolgreich war.

Prozessabnahme in telepad

1. Fork einen eingefrorenen untergeordneten Prozess . Ähnlich wie beim Senden, aber dieses Mal benötigen wir einen untergeordneten Prozess, den wir manipulieren können, um ihn in einen Klon des übertragenen Prozesses zu verwandeln.
   
2. Überprüfen Sie die Speicherzuordnungskarten . Dieses Mal müssen wir alle vorhandenen Speicherzuordnungskarten kennen, um sie zu entfernen und Platz für den eingehenden Prozess zu schaffen.
   
3. . , munmap.
   
4. . mremap, .
   
5. . mmap , process_vm_writev .
   
6. . PTRACE_SETREGS , , rax. raise(SIGSTOP), . , telepad.
   
   • Ein beliebiger Wert wird verwendet, damit der Telefork-Server den Dateideskriptor der TCP-Verbindung, in die der Prozess eingegeben wurde, übertragen und Daten zurücksenden oder, falls vorhanden yoyo, an dieselbe Verbindung zurück teleportieren kann.
7. Starten Sie den Prozess mit dem neuen Inhalt neu PTRACE_DETACH.

Kompetentere Umsetzung

• (vDSO). mremap vDSO , DMTCP, , . vDSO, . - , CPU glibc vDSO . , vDSO, syscall, rr, vDSO vDSO .
  
• brk . DMTCP, , brk , brk . , , — PR_SET_MM_MAP, .
  
• . Rust « », , FS GS, , , - glibc pid tid, . CRIU, PID TID .
  
• . , , , / , / FUSE. , TCP-, DMTCP CRIU , perf_event_open.
  
• . fork() Unix , , .

• Cluster Telefork . Die ursprüngliche Inspirationsquelle für Telefork war die Idee, einen Prozess auf alle Maschinen in einem Computercluster zu streamen. Es kann sich sogar herausstellen, dass UDP-Multicast- oder Peer-to-Peer-Methoden implementiert werden, um die Verteilung über den gesamten Cluster zu beschleunigen. Sie möchten wahrscheinlich auch Kommunikationsprimitive haben.
  
• . CRIU , - userfaultfd. , SIGSEGV mmap. , ,  — .
  
• ! , . userfaultfd userfaultfd, , , MESI, . , , .  — , . , , , . : syscall, -, syscall, . , . , , , . , , . , , ( , ) , .