Я использую оболочку класса PHP Event для libevent для чтения последовательного порта. Я использую это, чтобы избежать переполнения буфера - идея состоит в том, чтобы использовать Event для регулярной проверки порта, чтобы данные не были потеряны.
Я надеялся, что события будут срабатывать только тогда, когда он установлен, но пришел к выводу, что события срабатывают только после вызова EventBase::loop(). В этом случае поток управления переходит от моего кода к диспетчеру в libevent, когда я вызываю loop(). В конце концов поток управления возвращается к моему коду в позиции после вызова цикла.
Исходя из этого поведения, я предположил, что я, по сути, планирую отправку событий и должен регулярно вызывать loop(), чтобы мои события не испытывали нехватки ресурсов ЦП.
Однако в этом сценарии я никогда не смогу вызвать loop(), пока выполнялся предыдущий вызов loop(), потому что, согласно приведенному выше объяснению, поток управления находится либо в моем коде, либо в libevent, а не в обоих.
Итак, я разместил вызовы loop() через свой код (всего четыре — я нащупываю свой путь), и два из них выдают предупреждения о повторном входе в libevent.
Я, очевидно, не понимаю этого. Кто-нибудь может помочь?
Ура Пол
<?php
// serial comms defines
define("PORT", "/dev/serial0");
const PORTSETTINGS = array(
'baud' => 9600,
'bits' => 8,
'stop' => 1,
'parity' => 0
);
define("SYN", 170);
define("MSB", 127);
const POLL = 0.1;
/*
** Class Scanner
**
** Manages low level serial comms with the vbus master
**
*/
class Scanner {
private $fd;
private $pkt;
private $state;
private $base;
private $timer;
/*
** __construct()
**
** setup the serial port for reading using dio
** setup a timer to read anything on the serial port frequently
**
*/
function __construct() {
// set up port and state machine
$this->fd = dio_open(PORT, O_RDONLY | O_NOCTTY | O_NONBLOCK);
dio_tcsetattr($this->fd, PORTSETTINGS);
$this->pkt = array();
$this->state = "discard";
// set up timer handler
$this->base = new EventBase();
$this->timer = new Event($this->base, -1, Event::TIMEOUT | Event::PERSIST, array($this, "Tickle"));
$this->timer->addTimer(POLL);
$this->base->loop(EventBase::LOOP_NONBLOCK);
}
function PrintPkt($pkt) {
echo "\n\n".date("H:i:s");
foreach($pkt as $i)
echo " ".dechex($i);
}
/*
** Tickle()
**
** read the serial port, if MSB set discard the packet, else save the packet and then pass for processing
** called by the event timer on a regular basis ie POLL seconds
*/
function Tickle() {
do {
// read the next one and convert to int
$ch = dio_read($this->fd, 1);
$i = ord($ch);
// check for MSB, if set discard to the next packet
if (($i > MSB) && ($i != SYN))
$state="discard";
// if there is nothing on the port it returns 0x0 ie null/false
if ($i) {
if ($i == SYN) {
// we are at the start of a new packet
if (count($this->pkt) > 0) {
if ($this->state === "save")
// this is where we would save the packet but for now we are printing it.
$this->PrintPkt($this->pkt);
// reset for the next packet
$this->pkt = array();
$this->state = "save";
}
}
// save this number
$this->pkt[] = $i;
}
} while ($ch);
// restart the timer
$this->timer->addTimer(POLL);
}
/*
** spin()
**
** call the base loop so that the timer event is serviced
*/
function spin() {
$this->base->loop(EventBase::LOOP_NONBLOCK);
}
}
$c = new Scanner();
echo "setup";
while(1);
// $c->spin();
?>
