Blame view

sources/3rdparty/phpdocx/lib/log4php/appenders/LoggerAppenderSocket.php 3.62 KB
31b7f2792   Kload   Upgrade to ownclo...
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
  <?php
  /**
   * Licensed to the Apache Software Foundation (ASF) under one or more
   * contributor license agreements. See the NOTICE file distributed with
   * this work for additional information regarding copyright ownership.
   * The ASF licenses this file to You under the Apache License, Version 2.0
   * (the "License"); you may not use this file except in compliance with
   * the License. You may obtain a copy of the License at
   *
   *	   http://www.apache.org/licenses/LICENSE-2.0
   *
   * Unless required by applicable law or agreed to in writing, software
   * distributed under the License is distributed on an "AS IS" BASIS,
   * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
   * See the License for the specific language governing permissions and
   * limitations under the License.
   */
  
  /**
   * LoggerAppenderSocket appends to a network socket.
   *
   * ## Configurable parameters: ##
   * 
   * - **remoteHost** - Target remote host.
   * - **port** - Target port (optional, defaults to 4446).
   * - **timeout** - Connection timeout in seconds (optional, defaults to 
   *     'default_socket_timeout' from php.ini)
   * 
   * The socket will by default be opened in blocking mode.
   * 
   * @version $Revision: 1337820 $
   * @package log4php
   * @subpackage appenders
   * @license http://www.apache.org/licenses/LICENSE-2.0 Apache License, Version 2.0
   * @link http://logging.apache.org/log4php/docs/appenders/socket.html Appender documentation
   */ 
  class LoggerAppenderSocket extends LoggerAppender {
  	
  	/** 
  	 * Target host.
  	 * @see http://php.net/manual/en/function.fsockopen.php 
  	 */
  	protected $remoteHost;
  	
  	/** Target port */
  	protected $port = 4446;
  	
  	/** Connection timeout in ms. */
  	protected $timeout;
  	
  	// ******************************************
  	// *** Appender methods                   ***
  	// ******************************************
  	
  	/** Override the default layout to use serialized. */
  	public function getDefaultLayout() {
  		return new LoggerLayoutSerialized();
  	}
  	
  	public function activateOptions() {
  		if (empty($this->remoteHost)) {
  			$this->warn("Required parameter [remoteHost] not set. Closing appender.");
  			$this->closed = true;
  			return;
  		}
  	
  		if (empty($this->timeout)) {
  			$this->timeout = ini_get("default_socket_timeout");
  		}
  	
  		$this->closed = false;
  	}
  	
  	public function append(LoggerLoggingEvent $event) {
  		$socket = fsockopen($this->remoteHost, $this->port, $errno, $errstr, $this->timeout);
  		if ($socket === false) {
  			$this->warn("Could not open socket to {$this->remoteHost}:{$this->port}. Closing appender.");
  			$this->closed = true;
  			return;
  		}
  	
  		if (false === fwrite($socket, $this->layout->format($event))) {
  			$this->warn("Error writing to socket. Closing appender.");
  			$this->closed = true;
  		}
  		fclose($socket);
  	}
  	
  	// ******************************************
  	// *** Accessor methods                   ***
  	// ******************************************
  	
  	/** Sets the target host. */
  	public function setRemoteHost($hostname) {
  		$this->setString('remoteHost', $hostname);
  	}
  	
  	/** Sets the target port */
  	public function setPort($port) {
  		$this->setPositiveInteger('port', $port);
  	}
  	 
  	/** Sets the timeout. */
  	public function setTimeout($timeout) {
  		$this->setPositiveInteger('timeout', $timeout);
  	}
  	
  	/** Returns the target host. */
  	public function getRemoteHost() {
  		return $this->getRemoteHost();
  	}
  	
  	/** Returns the target port. */
  	public function getPort() {
  		return $this->port;
  	}
  	
  	/** Returns the timeout */
  	public function getTimeout() {
  		return $this->timeout;
  	}
  }