h !SSKrSSKrSSKrSSKrSSKrSSKJr "SS5r"SS\5r "SS\5r "SS \5r "S S \ 5r "S S \ 5r"SS\ 5r"SS5rg)Nc<\rSrSrSrSrSrSrSrSr Sr Sr Sr S r g) _criu_comm z' Base class for communication classes. rNcg)z Connect to criu and return socket object. daemon -- is for whether or not criu should daemonize if executing criu from binary(comm_bin). Nselfdaemons -/usr/lib/python3/dist-packages/pycriu/criu.pyconnect_criu_comm.connects cg)z Disconnect from criu. Nr r s r disconnect_criu_comm.disconnects rr )__name__ __module__ __qualname____firstlineno____doc__COMM_SKCOMM_FDCOMM_BIN comm_typecommskrr__static_attributes__r rr rr s1GGHI D B  rrc*\rSrSrSrSrSrSrSrg) _criu_comm_sk%z& Communication class for unix socket. c2URUlXlgN)rrr)r sk_paths r __init___criu_comm_sk.__init__*s rc[R"[R[R5UlURR UR 5 UR$r%)socketAF_UNIXSOCK_SEQPACKETrrrr s r r_criu_comm_sk.connect.s;--0E0EF  "wwrc8URR5 gr%rclosers r r_criu_comm_sk.disconnect4  rrrrN rrrrrr'rrr r rr r"r"%s rr"c*\rSrSrSrSrSrSrSrg) _criu_comm_fd8z* Communication class for file descriptor. c2URUlXlgr%)rrrr fds r r'_criu_comm_fd.__init__=s rc[R"UR[R[R5UlUR $r%)r*fromfdrr+r,rr s r r_criu_comm_fd.connectAs2-- 6>> & 5 57wwrc8URR5 gr%r/rs r r_criu_comm_fd.disconnectGr2rr3Nr4r rr r6r68s rr6c*\rSrSrSrSrSrSrSrg)_criu_comm_binKz! Communication class for binary. cNURUlXlSUlSUlgr%)rrrswrkr )r bin_paths r r'_criu_comm_bin.__init__Ps    rc^^[R"[R[R5m[R"TS[R 5n[R"TS[R U[R-5 [R"TS[R 5n[R"TS[R U[R)-5 UTl[R"5nUS:XaeUU4SjnU(aO[R"5nUS:Xa[R"5 U"5 O=[R"S5 O&U"5 OU(a[R"US5 TSR5 [R "STSR#S55STlTSTlTR&$)Nrrc>[R"S5 [R"S5 [R"S5 TSR[R"S[R "555 [R "TRTRSSTSR5-/5 [R"S5 g)NrrrirEz%d) osr0sendstructpackgetpidexecvrfileno_exit)cssr sr exec_criu)_criu_comm_bin.connect..exec_criuds   A FKKRYY[9:))VQ023 rrJ)r* socketpairr+r,fcntlF_GETFDF_SETFD FD_CLOEXECr rKforksetsidrRwaitpidr0rMunpackrecvrEr)r r flagsprTrSs` @r r_criu_comm_bin.connectVsB0E0EF CFEMM2 CFEMM553C3C+CD CFEMM2 CFEMM5E4D4D3D+DE GGI 6 GGI6IIKKHHQK  1a  A MM#s1v{{1~6q9 a&wwrcURR5 UR(d"[R"UR S5 gg)Nr)rr0r rKr^rErs r r_criu_comm_bin.disconnects-  {{ JJtyy! $r)rrr rrENr4r rr rBrBKs .`%rrBc&\rSrSrSrSrSrSrSrg) CRIUExceptionz7 Exception class for handling and storing criu errors. NcUR$r%)_strrs r __str__CRIUException.__str__s yyrr ) rrrrrtyprjrkr r rr rgrgs C Drrgc\rSrSrSrSrSrg)CRIUExceptionInternalz; Exception class for handling and storing internal errors. czXl[RRUR5<SU<3Ulg)Nz failed with internal error: )rmrpc criu_req_typeNamerj)r rmss r r'CRIUExceptionInternal.__init__s*    " "488 ,a1 r)rjrmN)rrrrrr'r r rr roros 1rroc$\rSrSrSrSrSrSrg)CRIUExceptionExternalz; Exception class for handling and storing criu RPC errors. cRXlX lX0lUR5Ulgr%)rmresp_typerrno_gen_error_strrj)r req_typr{r|s r r'CRIUExceptionExternal.__init__s!  '') rc4[RRUR5<S3nURUR:waUSUR4-- nUSUR 4-- nUR [ R :XaUS- nUR[R:Xa#UR [ R:XaUS- nUR[R:Xa#UR [ R:XaUS- nUS- nU$)Nz failed: zUnexpected response type %d: z Error(%d): z Bad optionszNo process with such pidz)Process with requested pid already existsUnknown) rrrsrtrmr{r|EBADRQCDUMPESRCHRESTOREEEXIST)r rus r r}$CRIUExceptionExternal._gen_error_strs ..33DHH= @ 88t}} $ 0DMM3DD DA ]djj^ ++ :: &  A 88sxx zzU[[(// 88s{{ "zzU\\)@@ Yr)rjr|r{rmN)rrrrrr'r}r r rr rxrxs* rrxcb\rSrSrSrSrSrSrSrSr Sr Sr S r S r S rS rS rSrSrg)criuz Call criu through RPC. NchURS5 [R"5UlSUlg)Nr) use_binaryrr criu_optsoptsrrs r r' criu.__init__s" MMO rc$[U5Ulg)zJ Access criu using unix socket which that belongs to criu service daemon. N)r"_comm)r sk_names r use_sk criu.use_sks#7+ rc$[U5Ulg)z Access criu using provided fd. N)r6rr9s r use_fd criu.use_fds#2& rc$[U5Ulg)z? Access criu by execing it using provided path to criu binary. N)rBr)r bin_names r rcriu.use_binarys$H- rc SnUR[R:Xa"URR S5(dSnUR (dUR RU5nO UR nUR(aX0lURUR55 UR[URS[R[R-555nUR(dUR R!5 [R""5nUR%U5 U$![&a$n[)UR[+U55eSnAff=f)z1 As simple as send request and receive response. FpidTrN)typerrrrHasFieldrrr keep_openrLSerializeToStringr`lenr* MSG_TRUNCMSG_PEEKr criu_respParseFromString Exceptionrostr)r reqr rubufrespes r _send_req_and_recv_respcriu._send_req_and_recv_resps 88sxx (9(9%(@(@F :77JJ&&v.GG}} FF3((* +&&QVVAv'7'7&//'IJKLC== %%'==?D   %  :'#a&9 9 :sD E E=E88E=c[R"5n[RUlUR U5nUR (d+[ URURUR5eg)z2 Checks whether the kernel support is up-to-date. N)rrcriu_reqCHECKrrsuccessrxcr_errnor rrs r check criu.checksQlln99++C0||'$))T]]K KrcR[R"5n[RUlURR UR5 UR U5nUR(d+[URURUR5eUR$z3 Checkpoint a process/tree identified by opts.pid. ) rrrrrr MergeFromrrrxrdumprs r r criu.dumpsllln88 499%++C0||'$))T]]K KyyrcR[R"5n[RUlURR UR5 UR U5nUR(d+[URURUR5eUR$r) rrrPRE_DUMPrrrrrrxrrrs r pre_dump criu.pre_dump"sllln<< 499%++C0||'$))T]]K KyyrcR[R"5n[RUlURR UR5 UR U5nUR(d+[URURUR5eUR$)z Restore a process/tree. ) rrrrrrrrrrxrrestorers r r criu.restore1sllln;; 499%++C0||'$))T]]K K||rc`[R"5n[RUlURR UR5 SUlURU5nUR(d+[URURUR5eUR$)NT) rrrPAGE_SERVER_CHLDrrrrrrrxrpsrs r page_server_chldcriu.page_server_chld@srlln'' 499% ++C0||'$))T]]K Kwwrc[R"5n[RUlXlUR U5nUR (d+[URURUR5eUR$r%) rrrWAIT_PIDrrrrrxrstatus)r rrrs r wait_pid criu.wait_pidMsYlln<<++C0||'$))T]]K K{{r)rrr)rrrrrrrr'rrrrrrrrrrr r rr rrsL D E , ' . !F L     rr)r*r|rXrKrMpycriu.rpc_pb2rpc_pb2rrrr"r6rBrrgrorxrr rr rsy   2J&J&>%Z>%BI1M1 M FRRr