Ferreteria/v0.6/clade/IO/Aspect/Connx/Process/@removed
Jump to navigation
Jump to search
|
Removed Code
|
2025-12-13
#
// 2025-12-08 moved to APipes
protected function BlockPipes(bool $bBlock) : int {
$ar = $this->arPipes;
$n = 0;
foreach ($ar as $rPipe) {
$ok = stream_set_blocking($rPipe,$bBlock);
if ($ok) $n++;
}
return $n;
}
protected function ShutPipes() : int {
$ar = $this->arPipes;
$n = 0;
foreach ($ar as $rPipe) {
$ok = fclose($rPipe);
if ($ok) $n++;
}
return $n;
}
protected function CountOpenPipes() : int {
$ar = $this->arPipes;
$n = 0;
foreach ($ar as $ndx => $rPipe) {
$arStat = fstat($rPipe);
if (is_array($arStat)) {
$n++;
} else {
echo "PIPE #$ndx is closed.".CRLF;
}
}
return $n;
}
Removed because the array is now in IO\Aspect\Connx\aux\APipes:
#
private $arPipes;
protected function DestRsrc() : mixed { return $this->arPipes[0]; } // was IPipe (WRITE to this)
protected function SrceRsrc() : mixed { return $this->arPipes[1]; } // was SrcePipe (READ from this)
protected function ErrsRsrc() : mixed { return $this->arPipes[2]; } // was EPipe (READ from this)
#
// 2025-11-29 upgrading to QObj
private $oBufRecv = NULL;
public function SetRecvBuff(BufferIface $o) { $this->oBufRecv = $o; }
protected function GetRecvBuff() : BufferIface { return $this->oBufRecv; }
private $oBufSend = NULL;
public function SetSendBuff(BufferIface $o) { $this->oBufSend = $o; }
protected function GetSendBuff() : BufferIface { return $this->oBufSend; }
2025-06-02
Commented out awhile ago:
#
static public function FromBuffers(BufferIface $oRecv, ?BufferIface $oSend=NULL) : iProcess {
$oThis = new static;
$oThis->SetRecvBuff($oRecv);
if (is_object($oSend)) {
$oThis->SetSendBuff($oSend);
}
return $oThis;
}