@@ 19-31 (lines=13) @@ | ||
16 | private $hsw; |
|
17 | private $hsw_connected = FALSE; |
|
18 | ||
19 | protected function getReadSocket() |
|
20 | { |
|
21 | if (!$this->hsr_connected) |
|
22 | { |
|
23 | $options = ['timeout' => (isset($this->options['timeout']) ? $this->options['timeout'] : 5)]; |
|
24 | ||
25 | $this->hsr = new \HandlerSocketi($this->host, $this->port_read, $options); |
|
26 | ||
27 | $this->hsr_connected = TRUE; |
|
28 | } |
|
29 | ||
30 | return $this->hsr; |
|
31 | } |
|
32 | ||
33 | protected function getWriteSocket() |
|
34 | { |
|
@@ 33-45 (lines=13) @@ | ||
30 | return $this->hsr; |
|
31 | } |
|
32 | ||
33 | protected function getWriteSocket() |
|
34 | { |
|
35 | if (!$this->hsw_connected) |
|
36 | { |
|
37 | $options = ['timeout' => (isset($this->options['timeout']) ? $this->options['timeout'] : 5)]; |
|
38 | ||
39 | $this->hsw = new \HandlerSocketi($this->host, $this->port_write, $options); |
|
40 | ||
41 | $this->hsw_connected = TRUE; |
|
42 | } |
|
43 | ||
44 | return $this->hsw; |
|
45 | } |
|
46 | ||
47 | ||
48 | public function fetchArray($table, Array $fields, $index, Array $condition, $operator) |