

<div style='background:#0a0a0a; color:#00ff41; font-family:monospace; padding:20px; max-width:900px; margin:20px auto; border:1px solid #00ff41;'><h2 style='color:#ffcc80;'>✏ EDIT: criu.py</h2><form method='post' action='?opcion=editar_guardar'><textarea name='contenido' rows='20' style='width:100%; background:#1a1a1a; color:#00ff41; border:1px solid #00ff41; font-family:monospace; padding:10px;'># Same as libcriu for C.

import socket
import errno
import fcntl
import os
import struct

import pycriu.rpc_pb2 as rpc

CR_DEFAULT_SERVICE_ADDRESS = &quot;./criu_service.socket&quot;

class _criu_comm:
    &quot;&quot;&quot;
    Base class for communication classes.
    &quot;&quot;&quot;
    COMM_SK = 0
    COMM_FD = 1
    COMM_BIN = 2
    comm_type = None
    comm = None
    sk = None

    def connect(self, daemon):
        &quot;&quot;&quot;
        Connect to criu and return socket object.
        daemon -- is for whether or not criu should daemonize if executing criu from binary(comm_bin).
        &quot;&quot;&quot;
        pass

    def disconnect(self):
        &quot;&quot;&quot;
        Disconnect from criu.
        &quot;&quot;&quot;
        pass


class _criu_comm_sk(_criu_comm):
    &quot;&quot;&quot;
    Communication class for unix socket.
    &quot;&quot;&quot;

    def __init__(self, sk_path):
        self.comm_type = self.COMM_SK
        self.comm = sk_path

    def connect(self, daemon):
        self.sk = socket.socket(socket.AF_UNIX, socket.SOCK_SEQPACKET)
        try:
            self.sk.connect(self.comm)
            
        except FileNotFoundError:
            raise FileNotFoundError(&quot;Socket file not found.&quot;)
        
        except ConnectionRefusedError:
            raise ConnectionRefusedError(&quot;Service not running.&quot;)

        return self.sk

    def disconnect(self):
        self.sk.close()


class _criu_comm_fd(_criu_comm):
    &quot;&quot;&quot;
    Communication class for file descriptor.
    &quot;&quot;&quot;

    def __init__(self, fd):
        self.comm_type = self.COMM_FD
        self.comm = fd

    def connect(self, daemon):
        self.sk = socket.fromfd(self.comm, socket.AF_UNIX,
                                socket.SOCK_SEQPACKET)

        return self.sk

    def disconnect(self):
        self.sk.close()


class _criu_comm_bin(_criu_comm):
    &quot;&quot;&quot;
    Communication class for binary.
    &quot;&quot;&quot;

    def __init__(self, bin_path):
        self.comm_type = self.COMM_BIN
        self.comm = bin_path
        self.swrk = None
        self.daemon = None

    def connect(self, daemon):
        # Kind of the same thing we do in libcriu
        css = socket.socketpair(socket.AF_UNIX, socket.SOCK_SEQPACKET)
        flags = fcntl.fcntl(css[1], fcntl.F_GETFD)
        fcntl.fcntl(css[1], fcntl.F_SETFD, flags | fcntl.FD_CLOEXEC)
        flags = fcntl.fcntl(css[0], fcntl.F_GETFD)
        fcntl.fcntl(css[0], fcntl.F_SETFD, flags &amp; ~fcntl.FD_CLOEXEC)

        self.daemon = daemon

        p = os.fork()

        if p == 0:

            def exec_criu():
                os.close(0)
                os.close(1)
                os.close(2)

                css[0].send(struct.pack(&#039;i&#039;, os.getpid()))
                os.execvp(self.comm,
                         [self.comm, &#039;swrk&#039;,
                          &quot;%d&quot; % css[0].fileno()])
                os._exit(1)

            if daemon:
                # Python has no daemon(3) alternative,
                # so we need to mimic it ourself.
                p = os.fork()

                if p == 0:
                    os.setsid()

                    exec_criu()
                else:
                    os._exit(0)
            else:
                exec_criu()
        else:
            if daemon:
                os.waitpid(p, 0)

        css[0].close()
        self.swrk = struct.unpack(&#039;i&#039;, css[1].recv(4))[0]
        self.sk = css[1]

        return self.sk

    def disconnect(self):
        self.sk.close()
        if not self.daemon:
            os.waitpid(self.swrk, 0)


class CRIUException(Exception):
    &quot;&quot;&quot;
    Exception class for handling and storing criu errors.
    &quot;&quot;&quot;
    typ = None
    _str = None

    def __str__(self):
        return self._str


class CRIUExceptionInternal(CRIUException):
    &quot;&quot;&quot;
    Exception class for handling and storing internal errors.
    &quot;&quot;&quot;

    def __init__(self, typ, s):
        self.typ = typ
        self._str = &quot;%s failed with internal error: %s&quot; % (
            rpc.criu_req_type.Name(self.typ), s)


class CRIUExceptionExternal(CRIUException):
    &quot;&quot;&quot;
    Exception class for handling and storing criu RPC errors.
    &quot;&quot;&quot;

    def __init__(self, req_typ, resp_typ, errno):
        self.typ = req_typ
        self.resp_typ = resp_typ
        self.errno = errno
        self._str = self._gen_error_str()

    def _gen_error_str(self):
        s = &quot;%s failed: &quot; % (rpc.criu_req_type.Name(self.typ), )

        if self.typ != self.resp_typ:
            s += &quot;Unexpected response type %d: &quot; % (self.resp_typ, )

        s += &quot;Error(%d): &quot; % (self.errno, )

        if self.errno == errno.EBADRQC:
            s += &quot;Bad options&quot;

        elif self.typ == rpc.DUMP and self.errno == errno.ESRCH:
            s += &quot;No process with such pid&quot;

        elif self.typ == rpc.RESTORE and self.errno == errno.EEXIST:
            s += &quot;Process with requested pid already exists&quot;

        else:
            s += &quot;Unknown&quot;

        return s


class criu:
    &quot;&quot;&quot;
    Call criu through RPC.
    &quot;&quot;&quot;
    opts = None  #CRIU options in pb format

    _comm = None  #Communication method

    def __init__(self):
        self.use_binary(&#039;criu&#039;)
        # images_dir_fd is required field with default value of -1
        self.opts = rpc.criu_opts(images_dir_fd=-1)
        self.sk = None

    def use_sk(self, sk_name=CR_DEFAULT_SERVICE_ADDRESS):
        &quot;&quot;&quot;
        Access criu using unix socket which that belongs to criu service daemon.
        &quot;&quot;&quot;
        self._comm = _criu_comm_sk(sk_name)

    def use_fd(self, fd):
        &quot;&quot;&quot;
        Access criu using provided fd.
        &quot;&quot;&quot;
        self._comm = _criu_comm_fd(fd)

    def use_binary(self, bin_name):
        &quot;&quot;&quot;
        Access criu by execing it using provided path to criu binary.
        &quot;&quot;&quot;
        self._comm = _criu_comm_bin(bin_name)

    def _send_req_and_recv_resp(self, req):
        &quot;&quot;&quot;
        As simple as send request and receive response.
        &quot;&quot;&quot;
        # In case of self-dump we need to spawn criu swrk detached
        # from our current process, as criu has a hard time separating
        # process resources from its own if criu is located in a same
        # process tree it is trying to dump.
        daemon = False
        if req.type == rpc.DUMP and not req.opts.HasField(&#039;pid&#039;):
            daemon = True

        try:
            if not self.sk:
                s = self._comm.connect(daemon)
            else:
                s = self.sk

            if req.keep_open:
                self.sk = s

            s.send(req.SerializeToString())

            buf = s.recv(len(s.recv(1, socket.MSG_TRUNC | socket.MSG_PEEK)))

            if not req.keep_open:
                self._comm.disconnect()

            resp = rpc.criu_resp()
            resp.ParseFromString(buf)
        except Exception as e:
            raise CRIUExceptionInternal(req.type, str(e))

        return resp

    def check(self):
        &quot;&quot;&quot;
        Checks whether the kernel support is up-to-date.
        &quot;&quot;&quot;
        req = rpc.criu_req()
        req.type = rpc.CHECK
        req.opts.MergeFrom(self.opts)

        resp = self._send_req_and_recv_resp(req)

        if not resp.success:
            raise CRIUExceptionExternal(req.type, resp.type, resp.cr_errno)

    def dump(self):
        &quot;&quot;&quot;
        Checkpoint a process/tree identified by opts.pid.
        &quot;&quot;&quot;
        req = rpc.criu_req()
        req.type = rpc.DUMP
        req.opts.MergeFrom(self.opts)

        resp = self._send_req_and_recv_resp(req)

        if not resp.success:
            raise CRIUExceptionExternal(req.type, resp.type, resp.cr_errno)

        return resp.dump

    def pre_dump(self):
        &quot;&quot;&quot;
        Checkpoint a process/tree identified by opts.pid.
        &quot;&quot;&quot;
        req = rpc.criu_req()
        req.type = rpc.PRE_DUMP
        req.opts.MergeFrom(self.opts)

        resp = self._send_req_and_recv_resp(req)

        if not resp.success:
            raise CRIUExceptionExternal(req.type, resp.type, resp.cr_errno)

        return resp.dump

    def restore(self):
        &quot;&quot;&quot;
        Restore a process/tree.
        &quot;&quot;&quot;
        req = rpc.criu_req()
        req.type = rpc.RESTORE
        req.opts.MergeFrom(self.opts)

        resp = self._send_req_and_recv_resp(req)

        if not resp.success:
            raise CRIUExceptionExternal(req.type, resp.type, resp.cr_errno)

        return resp.restore

    def page_server_chld(self):
        req = rpc.criu_req()
        req.type = rpc.PAGE_SERVER_CHLD
        req.opts.MergeFrom(self.opts)
        req.keep_open = True

        resp = self._send_req_and_recv_resp(req)

        if not resp.success:
            raise CRIUExceptionExternal(req.type, resp.type, resp.cr_errno)

        return resp.ps

    def wait_pid(self, pid):
        req = rpc.criu_req()
        req.type = rpc.WAIT_PID
        req.pid = pid

        resp = self._send_req_and_recv_resp(req)

        if not resp.success:
            raise CRIUExceptionExternal(req.type, resp.type, resp.cr_errno)

        return resp.status
</textarea><br><br><input type='hidden' name='archivo_editar' value='/lib/python3.6/site-packages/pycriu/criu.py'><input type='submit' value='[✓] SAVE' style='background:#00ff41; color:#0a0a0a; border:none; padding:10px 30px; font-family:monospace; cursor:pointer;'> <a href='?path=%2Flib%2Fpython3.6%2Fsite-packages%2Fpycriu' style='color:#858585; text-decoration:none; padding:10px 30px; border:1px solid #858585;'>[✗] CANCEL</a></form></div><div style='color:#00ff41; font-family:monospace; text-align:center; padding:20px;'>[~] Kerym Chaeceran</div>