kakserpom /
phpdaemon
| @@ 35-39 (lines=5) @@ | ||
| 32 | $frame->contentLength = $fields['c']; |
|
| 33 | ||
| 34 | // consume "content-type" (shortstr) |
|
| 35 | if ($flags & 32768) { |
|
| 36 | $length = \ord($this->buffer); |
|
| 37 | $frame->contentType = \substr($this->buffer, 1, $length); |
|
| 38 | $this->buffer = \substr($this->buffer, 1 + $length); |
|
| 39 | } |
|
| 40 | ||
| 41 | // consume "content-encoding" (shortstr) |
|
| 42 | if ($flags & 16384) { |
|
| @@ 42-46 (lines=5) @@ | ||
| 39 | } |
|
| 40 | ||
| 41 | // consume "content-encoding" (shortstr) |
|
| 42 | if ($flags & 16384) { |
|
| 43 | $length = \ord($this->buffer); |
|
| 44 | $frame->contentEncoding = \substr($this->buffer, 1, $length); |
|
| 45 | $this->buffer = \substr($this->buffer, 1 + $length); |
|
| 46 | } |
|
| 47 | ||
| 48 | // consume "headers" (table)e |
|
| 49 | if ($flags & 8192) { |
|
| @@ 66-70 (lines=5) @@ | ||
| 63 | } |
|
| 64 | ||
| 65 | // consume "correlation-id" (shortstr) |
|
| 66 | if ($flags & 1024) { |
|
| 67 | $length = \ord($this->buffer); |
|
| 68 | $frame->correlationId = \substr($this->buffer, 1, $length); |
|
| 69 | $this->buffer = \substr($this->buffer, 1 + $length); |
|
| 70 | } |
|
| 71 | ||
| 72 | // consume "reply-to" (shortstr) |
|
| 73 | if ($flags & 512) { |
|
| @@ 73-77 (lines=5) @@ | ||
| 70 | } |
|
| 71 | ||
| 72 | // consume "reply-to" (shortstr) |
|
| 73 | if ($flags & 512) { |
|
| 74 | $length = \ord($this->buffer); |
|
| 75 | $frame->replyTo = \substr($this->buffer, 1, $length); |
|
| 76 | $this->buffer = \substr($this->buffer, 1 + $length); |
|
| 77 | } |
|
| 78 | ||
| 79 | // consume "expiration" (shortstr) |
|
| 80 | if ($flags & 256) { |
|
| @@ 80-84 (lines=5) @@ | ||
| 77 | } |
|
| 78 | ||
| 79 | // consume "expiration" (shortstr) |
|
| 80 | if ($flags & 256) { |
|
| 81 | $length = \ord($this->buffer); |
|
| 82 | $frame->expiration = \substr($this->buffer, 1, $length); |
|
| 83 | $this->buffer = \substr($this->buffer, 1 + $length); |
|
| 84 | } |
|
| 85 | ||
| 86 | // consume "message-id" (shortstr) |
|
| 87 | if ($flags & 128) { |
|
| @@ 87-91 (lines=5) @@ | ||
| 84 | } |
|
| 85 | ||
| 86 | // consume "message-id" (shortstr) |
|
| 87 | if ($flags & 128) { |
|
| 88 | $length = \ord($this->buffer); |
|
| 89 | $frame->messageId = \substr($this->buffer, 1, $length); |
|
| 90 | $this->buffer = \substr($this->buffer, 1 + $length); |
|
| 91 | } |
|
| 92 | ||
| 93 | // consume "timestamp" (timestamp) |
|
| 94 | if ($flags & 64) { |
|
| @@ 100-104 (lines=5) @@ | ||
| 97 | } |
|
| 98 | ||
| 99 | // consume "type" (shortstr) |
|
| 100 | if ($flags & 32) { |
|
| 101 | $length = \ord($this->buffer); |
|
| 102 | $frame->type = \substr($this->buffer, 1, $length); |
|
| 103 | $this->buffer = \substr($this->buffer, 1 + $length); |
|
| 104 | } |
|
| 105 | ||
| 106 | // consume "user-id" (shortstr) |
|
| 107 | if ($flags & 16) { |
|
| @@ 107-111 (lines=5) @@ | ||
| 104 | } |
|
| 105 | ||
| 106 | // consume "user-id" (shortstr) |
|
| 107 | if ($flags & 16) { |
|
| 108 | $length = \ord($this->buffer); |
|
| 109 | $frame->userId = \substr($this->buffer, 1, $length); |
|
| 110 | $this->buffer = \substr($this->buffer, 1 + $length); |
|
| 111 | } |
|
| 112 | ||
| 113 | // consume "app-id" (shortstr) |
|
| 114 | if ($flags & 8) { |
|
| @@ 114-118 (lines=5) @@ | ||
| 111 | } |
|
| 112 | ||
| 113 | // consume "app-id" (shortstr) |
|
| 114 | if ($flags & 8) { |
|
| 115 | $length = \ord($this->buffer); |
|
| 116 | $frame->appId = \substr($this->buffer, 1, $length); |
|
| 117 | $this->buffer = \substr($this->buffer, 1 + $length); |
|
| 118 | } |
|
| 119 | ||
| 120 | // consume "cluster-id" (shortstr) |
|
| 121 | if ($flags & 4) { |
|
| @@ 121-125 (lines=5) @@ | ||
| 118 | } |
|
| 119 | ||
| 120 | // consume "cluster-id" (shortstr) |
|
| 121 | if ($flags & 4) { |
|
| 122 | $length = \ord($this->buffer); |
|
| 123 | $frame->clusterId = \substr($this->buffer, 1, $length); |
|
| 124 | $this->buffer = \substr($this->buffer, 1 + $length); |
|
| 125 | } |
|
| 126 | ||
| 127 | return $frame; |
|
| 128 | } |
|
