PhpProfiler\Lib\Process\MemoryReader\MemoryReader

Complexity

Total Complexity

3

Size/Duplication

Total Lines	75
Duplicated Lines	0 %

Importance

Changes	3
Bugs	2	Features	0

2 Methods

Rating	Name	Duplication	Size	Complexity
A	read()	0	40	2
A	__construct()	0	22	1

<?php

/**
 * This file is part of the reliforp/reli-prof package.
 *
 * (c) sji <sji@sj-i.dev>
 *
 * For the full copyright and license information, please view the LICENSE
 * file that was distributed with this source code.
 */

declare(strict_types=1);

namespace Reli\Lib\Process\MemoryReader;

use FFI;
use FFI\CData;
use Reli\Lib\FFI\CannotAllocateBufferException;

final class MemoryReader implements MemoryReaderInterface
{
    private FFI $ffi;
    private CData $local_iov;
    private CData $remote_iov;
    private CData $remote_base;

    public function __construct()
    {
        $this->ffi = FFI::cdef('
        typedef int pid_t;
        struct iovec {
            void  *iov_base;    /* Starting address */
            size_t iov_len;     /* Number of bytes to transfer */
        };
        int errno;
        ssize_t process_vm_readv(pid_t pid,
                         const struct iovec *local_iov,
                         unsigned long liovcnt,
                         const struct iovec *remote_iov,
                         unsigned long riovcnt,
                         unsigned long flags);
       ', 'libc.so.6');
        $this->local_iov = $this->ffi->new('struct iovec')
            ?? throw new CannotAllocateBufferException('cannot allocate buffer');
        $this->remote_iov = $this->ffi->new('struct iovec')
            ?? throw new CannotAllocateBufferException('cannot allocate buffer');
        $this->remote_base = $this->ffi->new('long')
            ?? throw new CannotAllocateBufferException('cannot allocate buffer');
    }

    /**
     * @return \FFI\CArray<int>
     * @throws MemoryReaderException
     */
    public function read(int $pid, int $remote_address, int $size): CData
    {
        $buffer = $this->ffi->new("unsigned char[{$size}]")
            ?? throw new CannotAllocateBufferException('cannot allocate buffer');

        /**
         * @var FFI\Libc\iovec $this->local_iov
         * @psalm-suppress PropertyTypeCoercion
         */
        $this->local_iov->iov_base = FFI::addr($buffer);
        $this->local_iov->iov_len = $size;

        /** @var FFI\Libc\iovec $this->remote_iov */
        $this->remote_iov->iov_len = $size;
        /** @var FFI\CInteger $this->remote_base */
        $this->remote_base->cdata = $remote_address;
        /** @psalm-suppress PropertyTypeCoercion */
        $this->remote_iov->iov_base = FFI::cast('void *', $this->remote_base);

        /** @var FFI\Libc\process_vm_readv_ffi $this->ffi */
        $read = $this->ffi->process_vm_readv(

The method process_vm_readv() does not exist on FFI. It seems like you code against a sub-type of FFI such as FFI\Libc\process_vm_readv_ffi.

            $pid,
            FFI::addr($this->local_iov),
            1,
            FFI::addr($this->remote_iov),
            1,
            0
        );
        if ($read === -1) {
            /** @var int $errno */
            $errno = $this->ffi->errno;
            $log_address = dechex($remote_address);
            throw new MemoryReaderException(
                "failed to read memory. target_pid={$pid}, remote_address=0x{$log_address}, errno={$errno}",
                $errno
            );
        }

        /** @var \FFI\CArray<int> */
        return $buffer;
    }
}