@@ 82-89 (lines=8) @@ | ||
79 | $this->setWatermark($this->pctSize); |
|
80 | $this->state = self::STATE_PACKET; |
|
81 | } |
|
82 | if ($this->state === self::STATE_PACKET) { |
|
83 | if (false === ($pct = $this->readExact($this->pctSize))) { |
|
84 | return; // not enough data |
|
85 | } |
|
86 | $this->state = self::STATE_ROOT; |
|
87 | $this->setWatermark(2); |
|
88 | $this->onUdpPacket($pct); |
|
89 | } |
|
90 | goto start; |
|
91 | } |
|
92 |
@@ 92-99 (lines=8) @@ | ||
89 | } |
|
90 | } |
|
91 | ||
92 | if ($this->state === self::STATE_DATA) { |
|
93 | if (false === ($this->result = $this->readExact($this->valueLength))) { |
|
94 | return; //we do not have a whole packet |
|
95 | } |
|
96 | $this->state = self::STATE_ROOT; |
|
97 | $this->setWatermark(1); |
|
98 | goto start; |
|
99 | } |
|
100 | } |
|
101 | } |
|
102 |