ÿØÿà JFIF    ÿÛ „  ( %!1!%)+//.383,7(-.+  -%%-////---/-.+/--+------/------/--0+--/-/-----.-----ÿÀ  ¥2" ÿÄ     ÿÄ J    ! 1AQ"aq2‘#BR‚¡ÁÑ3br’¢±Âð$CSƒ²á4c“%DsÓñÿÄ   ÿÄ *  !1AQa‘"2q3±ð#b¡ÿÚ   ? ¼QxJQaÍuò¸Zö Úü8,ÐÚú "SSn<rçù–´âE—^ªBÖ9À\†¸ÔÁT­ÃÛ5 ëd´³Í#Ý;Þ38œî ¶H£M:wÎ3…³…âpÔF&‚FK¸9„â4àGEõªfÿ ‘ñ(ßw­pŽF|È¥ù®häðÍѶ¹‘[ÒinÙW¶ùñY˜Q{›K"išÒ[Ú8žë\F¹@-?v"ÔU”,ìöžkÿ {I‡£šÍ?e ríV .............................................................................................................................................................................. ............................................................................. ÿØÿà JFIF    ÿÛ „  ( %!1!%)+//.383,7(-.+  -%%-////---/-.+/--+------/------/--0+--/-/-----.-----ÿÀ  ¥2" ÿÄ     ÿÄ J    ! 1AQ"aq2‘#BR‚¡ÁÑ3br’¢±Âð$CSƒ²á4c“%DsÓñÿÄ   ÿÄ *  !1AQa‘"2q3±ð#b¡ÿÚ   ? ¼QxJQaÍuò¸Zö Úü8,ÐÚú "SSn<rçù–´âE—^ªBÖ9À\†¸ÔÁT­ÃÛ5 ëd´³Í#Ý;Þ38œî ¶H£M:wÎ3…³…âpÔF&‚FK¸9„â4àGEõªfÿ ‘ñ(ßw­pŽF|È¥ù®häðÍѶ¹‘[ÒinÙW¶ùñY˜Q{›K"išÒ[Ú8žë\F¹@-?v"ÔU”,ìöžkÿ {I‡£šÍ?e ríV .............................................................................................................................................................................. ............................................................................. 3  i"@sddlZddlZddlZddlZddlZddljZdZGdddZ Gddde Z Gddde Z Gd d d e Z Gd d d e ZGd ddeZGdddeZGdddZdS)Nz./criu_service.socketc@s8eZdZdZdZdZdZdZdZdZ ddZ dd Z dS) _criu_commz/ Base class for communication classes. rNcCsdS)z Connect to criu and return socket object. daemon -- is for whether or not criu should daemonize if executing criu from binary(comm_bin). N)selfdaemonrr/usr/lib/python3.6/criu.pyconnectsz_criu_comm.connectcCsdS)z' Disconnect from criu. Nr)rrrr disconnectsz_criu_comm.disconnect) __name__ __module__ __qualname____doc__COMM_SKCOMM_FDCOMM_BIN comm_typecommskr r rrrrr src@s(eZdZdZddZddZddZdS) _criu_comm_skz. Communication class for unix socket. cCs|j|_||_dS)N)rrr)rZsk_pathrrr__init__+sz_criu_comm_sk.__init__c Csbtjtjtj|_y|jj|jWn6tk r@tdYntk rZtdYnX|jS)NzSocket file not found.zService not running.)socketAF_UNIXSOCK_SEQPACKETrr rFileNotFoundErrorConnectionRefusedError)rrrrrr /s z_criu_comm_sk.connectcCs|jjdS)N)rclose)rrrrr <sz_criu_comm_sk.disconnectN)r r r rrr r rrrrr&s rc@s(eZdZdZddZddZddZdS) _criu_comm_fdz2 Communication class for file descriptor. cCs|j|_||_dS)N)rrr)rfdrrrrEsz_criu_comm_fd.__init__cCstj|jtjtj|_|jS)N)rZfromfdrrrr)rrrrrr Is  z_criu_comm_fd.connectcCs|jjdS)N)rr)rrrrr Osz_criu_comm_fd.disconnectN)r r r rrr r rrrrr@src@s(eZdZdZddZddZddZdS) _criu_comm_binz) Communication class for binary. cCs|j|_||_d|_d|_dS)N)rrrswrkr)rZbin_pathrrrrXsz_criu_comm_bin.__init__cstjtjtjtjdtj}tjdtj|tjBtjdtj}tjdtj|tj@|_t j }|dkrƇfdd}|rt j }|dkrt j |qt j dq|n|rt j |ddjtjddjdd_d_jS)Nrrcshtjdtjdtjddjtjdtjtjjjdddjgtj ddS)Nrrrir z%d) osrsendstructpackgetpidexecvprfileno_exitr)cssrrr exec_criuls   z)_criu_comm_bin.connect..exec_criur!)rZ socketpairrrfcntlZF_GETFDZF_SETFDZ FD_CLOEXECrr"forksetsidr)waitpidrr$unpackrecvr r)rrflagspr+r)r*rrr ^s,     z_criu_comm_bin.connectcCs"|jj|jstj|jddS)Nr)rrrr"r0r )rrrrr s z_criu_comm_bin.disconnectN)r r r rrr r rrrrrSs0rc@s eZdZdZdZdZddZdS) CRIUExceptionz? Exception class for handling and storing criu errors. NcCs|jS)N)_str)rrrr__str__szCRIUException.__str__)r r r rtypr6r7rrrrr5sr5c@seZdZdZddZdS)CRIUExceptionInternalzC Exception class for handling and storing internal errors. cCs"||_dtjj|j|f|_dS)Nz!%s failed with internal error: %s)r8rpc criu_req_typeNamer6)rr8srrrrszCRIUExceptionInternal.__init__N)r r r rrrrrrr9sr9c@s eZdZdZddZddZdS)CRIUExceptionExternalzC Exception class for handling and storing criu RPC errors. cCs ||_||_||_|j|_dS)N)r8resp_typerrno_gen_error_strr6)rZreq_typr?r@rrrrszCRIUExceptionExternal.__init__cCsdtjj|jf}|j|jkr0|d|jf7}|d|jf7}|jtjkrV|d7}nL|jtjkrx|jtjkrx|d7}n*|jtj kr|jtj kr|d7}n|d7}|S)Nz %s failed: zUnexpected response type %d: z Error(%d): z Bad optionszNo process with such pidz)Process with requested pid already existsZUnknown) r:r;r<r8r?r@ZEBADRQCDUMPZESRCHRESTOREZEEXIST)rr=rrrrAs     z$CRIUExceptionExternal._gen_error_strN)r r r rrrArrrrr>sr>c@steZdZdZdZdZddZefddZddZ d d Z d d Z d dZ ddZ ddZddZddZddZdS)criuz Call criu through RPC. NcCs"|jdtjdd|_d|_dS)NrDr)Z images_dir_fd) use_binaryr:Z criu_optsoptsr)rrrrrs z criu.__init__cCst||_dS)zZ Access criu using unix socket which that belongs to criu service daemon. N)r_comm)rZsk_namerrruse_sksz criu.use_skcCst||_dS)z0 Access criu using provided fd. N)rrH)rrrrruse_fdsz criu.use_fdcCst||_dS)zO Access criu by execing it using provided path to criu binary. N)rrH)rZbin_namerrrrFszcriu.use_binarycCsd}|jtjkr"|jjd r"d}yx|js8|jj|}n|j}|jrJ||_|j |j |j t |j dt jt jB}|js|jjtj}|j|Wn2tk r}zt|jt|WYdd}~XnX|S)zA As simple as send request and receive response. FpidTrN)typer:rBrGZHasFieldrrHr keep_openr#ZSerializeToStringr2lenrZ MSG_TRUNCZMSG_PEEKr Z criu_respZParseFromString Exceptionr9str)rreqrr=Zbufresperrr_send_req_and_recv_resps$ "zcriu._send_req_and_recv_respcCsDtj}tj|_|jj|j|j|}|js@t|j|j|j dS)zB Checks whether the kernel support is up-to-date. N) r:criu_reqZCHECKrLrG MergeFromrTsuccessr>cr_errno)rrQrRrrrchecks  z criu.checkcCsFtj}tj|_|jj|j|j|}|js@t|j|j|j |j S)zC Checkpoint a process/tree identified by opts.pid. ) r:rUrBrLrGrVrTrWr>rXdump)rrQrRrrrrZs z criu.dumpcCsFtj}tj|_|jj|j|j|}|js@t|j|j|j |j S)zC Checkpoint a process/tree identified by opts.pid. ) r:rUZPRE_DUMPrLrGrVrTrWr>rXrZ)rrQrRrrrpre_dump+s z criu.pre_dumpcCsFtj}tj|_|jj|j|j|}|js@t|j|j|j |j S)z) Restore a process/tree. ) r:rUrCrLrGrVrTrWr>rXrestore)rrQrRrrrr\:s z criu.restorecCsLtj}tj|_|jj|jd|_|j|}|jsFt |j|j|j |j S)NT) r:rUZPAGE_SERVER_CHLDrLrGrVrMrTrWr>rXZps)rrQrRrrrpage_server_chldIs zcriu.page_server_chldcCs>tj}tj|_||_|j|}|js8t|j|j|j|j S)N) r:rUZWAIT_PIDrLrKrTrWr>rXZstatus)rrKrQrRrrrwait_pidVs z criu.wait_pid)r r r rrGrHrCR_DEFAULT_SERVICE_ADDRESSrIrJrFrTrYrZr[r\r]r^rrrrrDs #  rD)rr@r-r"r$Zpycriu.rpc_pb2Zrpc_pb2r:r_rrrrrOr5r9r>rDrrrrs A  "