كيف تبدو

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

1. «» . , , . fork .
   
2. . /proc/<pid>/maps , . proc_maps crate.
   
3. . DMTCP, , , . , [vdso], , , .
   
4. . , , process_vm_readv , .
   
5. سجلات النقل . يمكنني استخدام خيار PTRACE_GETREGSاستدعاء نظام ptrace . يسمح لك بالحصول على جميع قيم سجل العملية الفرعية. ثم أكتبهم فقط في رسالة على القناة.

تشغيل مكالمات النظام في عملية تابعة

1. syscall. syscall , . , process_vm_readv [vdso] , , , syscall Linux, . , [vdso].
   
2. , PTRACE_SETREGS. syscall, rax Linux, rdi, rsi, rdx, r10, r8, r9.
   
3. اتخذ خطوة واحدة باستخدام المعلمة PTRACE_SINGLESTEPلتنفيذ الأمر syscall.
   
4. قراءة السجلات مع PTRACE_GETREGSاستعادة قيمة الإرجاع syscall ومعرفة ما اذا كان نجح في ذلك.

قبول العملية في telepad

1. شوكة عملية طفل مجمدة . على غرار الإرسال ، لكننا هذه المرة نحتاج إلى عملية فرعية يمكننا معالجتها لتحويلها إلى استنساخ للعملية المنقولة.
   
2. تحقق من بطاقات تخصيص الذاكرة . هذه المرة نحن بحاجة إلى معرفة جميع بطاقات تخصيص الذاكرة الموجودة من أجل إزالتها وإفساح المجال للعملية الواردة.
   
3. . , munmap.
   
4. . mremap, .
   
5. . mmap , process_vm_writev .
   
6. . PTRACE_SETREGS , , rax. raise(SIGSTOP), . , telepad.
   
   • يتم استخدام قيمة عشوائية حتى يتمكن خادم telefork من نقل واصف الملف لاتصال TCP الذي دخلت فيه العملية ، ويمكنه إرسال البيانات مرة أخرى أو ، في حالة 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 , , .

• التليفون العنقودي . كان المصدر الأولي للإلهام لـ Telefork هو فكرة تدفق العملية إلى جميع الأجهزة في مجموعة الحوسبة. قد يتحول حتى إلى تطبيق UDP multicast أو أساليب نظير إلى نظير لتسريع التوزيع عبر المجموعة بأكملها. ربما تريد أيضًا أن يكون لديك بدائيات اتصال.
  
• . CRIU , - userfaultfd. , SIGSEGV mmap. , ,  — .
  
• ! , . userfaultfd userfaultfd, , , MESI, . , , .  — , . , , , . : syscall, -, syscall, . , . , , , . , , . , , ( , ) , .