वो कैसा दिखता है

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);

लिनक्स प्रक्रिया शरीर रचना विज्ञान

• (memory mappings): , . «» 4 . /proc/<pid>/maps. , , .
  
  
  • , , ( ).
• : , . , , - , , , . , .
  
• : , . - , . , , , TCP-, .
  
  • . stdin/stdout/stderr, 0, 1 2.
    
  • , , , .
• विविध : प्रक्रिया राज्य के कुछ अन्य भाग हैं जो प्रतिकृति जटिलता में भिन्न होते हैं। लेकिन ज्यादातर मामलों में वे कोई फर्क नहीं पड़ता, उदाहरण के लिए, brk (हीप पॉइंटर)। उनमें से कुछ को केवल अजीब ट्रिक्स या विशेष सिस्टम कॉल की मदद से बहाल किया जा सकता है जैसे PR_SET_MM_MAP , जो पुनर्प्राप्ति को जटिल करता है।

कैसे एक प्रक्रिया telefork करने के लिए

का उपयोग कर एक प्रक्रिया सबमिट करना telefork

1. «» . , , . fork .
   
2. . /proc/<pid>/maps , . proc_maps crate.
   
3. . DMTCP, , , . , [vdso], , , .
   
4. . , , process_vm_readv , .
   
5. स्थानांतरण रजिस्टर । मैं ptracePTRACE_GETREGS सिस्टम कॉल के लिए विकल्प का उपयोग करता हूं । यह आपको बच्चे की प्रक्रिया के रजिस्टर के सभी मूल्यों को प्राप्त करने की अनुमति देता है। फिर मैं उन्हें चैनल पर एक संदेश में लिखता हूं।

एक बच्चे की प्रक्रिया में रनिंग सिस्टम कॉल

1. syscall. syscall , . , process_vm_readv [vdso] , , , syscall Linux, . , [vdso].
   
2. , PTRACE_SETREGS. syscall, rax Linux, rdi, rsi, rdx, r10, r8, r9.
   
3. PTRACE_SINGLESTEPSyscall कमांड निष्पादित करने के लिए पैरामीटर का उपयोग करके एक कदम उठाएं ।
   
4. PTRACE_GETREGSSyscall रिटर्न मान को पुनर्स्थापित करने के साथ रजिस्टरों को पढ़ें और देखें कि क्या यह सफल रहा।

में प्रक्रिया स्वीकृति telepad

1. एक जमे हुए बच्चे की प्रक्रिया को कांटा । भेजने के समान है, लेकिन इस बार हमें एक बच्चे की प्रक्रिया की आवश्यकता है जिसे हम स्थानांतरित प्रक्रिया के क्लोन में बदलने के लिए हेरफेर कर सकते हैं।
   
2. मेमोरी आवंटन कार्ड जांचें । इस बार हमें उन्हें हटाने और आने वाली प्रक्रिया के लिए जगह बनाने के लिए सभी मौजूदा मेमोरी आवंटन कार्डों को जानना होगा।
   
3. . , munmap.
   
4. . mremap, .
   
5. . mmap , process_vm_writev .
   
6. . PTRACE_SETREGS , , rax. raise(SIGSTOP), . , telepad.
   
   • एक मनमाना मूल्य का उपयोग किया जाता है ताकि टेलीफ़र्क सर्वर टीसीपी कनेक्शन के फ़ाइल डिस्क्रिप्टर को स्थानांतरित कर सके जो प्रक्रिया में प्रवेश किया था, और डेटा वापस भेज सकता है या, यदि yoyoउसी स्थिति में वापस टेलीपोर्ट करता है।
7. नई सामग्री का उपयोग करके प्रक्रिया को पुनरारंभ करेंPTRACE_DETACH ।

अधिक सक्षम कार्यान्वयन

• (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 , , .

• क्लस्टर टेलीफ़ॉर्क । टेलीफ़ोर्क के लिए प्रेरणा का प्रारंभिक स्रोत कंप्यूटिंग क्लस्टर में सभी मशीनों के लिए एक प्रक्रिया को स्ट्रीमिंग करने का विचार था। यह पूरे क्लस्टर में वितरण को गति देने के लिए यूडीपी मल्टीकास्ट या पीयर-टू-पीयर विधियों को लागू करने के लिए भी बदल सकता है। आप शायद संचार प्रधानता भी चाहते हैं।
  
• . CRIU , - userfaultfd. , SIGSEGV mmap. , ,  — .
  
• ! , . userfaultfd userfaultfd, , , MESI, . , , .  — , . , , , . : syscall, -, syscall, . , . , , , . , , . , , ( , ) , .