62 lines
		
	
	
		
			1.8 KiB
		
	
	
	
		
			PHP
		
	
	
	
	
	
			
		
		
	
	
			62 lines
		
	
	
		
			1.8 KiB
		
	
	
	
		
			PHP
		
	
	
	
	
	
| <?php
 | |
| // +----------------------------------------------------------------------
 | |
| // | ThinkPHP [ WE CAN DO IT JUST THINK ]
 | |
| // +----------------------------------------------------------------------
 | |
| // | Copyright (c) 2006~2015 http://thinkphp.cn All rights reserved.
 | |
| // +----------------------------------------------------------------------
 | |
| // | Licensed ( http://www.apache.org/licenses/LICENSE-2.0 )
 | |
| // +----------------------------------------------------------------------
 | |
| // | Author: yunwuxin <448901948@qq.com>
 | |
| // +----------------------------------------------------------------------
 | |
| 
 | |
| namespace think\process\exception;
 | |
| 
 | |
| use think\Process;
 | |
| 
 | |
| class Timeout extends \RuntimeException
 | |
| {
 | |
| 
 | |
|     const TYPE_GENERAL = 1;
 | |
|     const TYPE_IDLE    = 2;
 | |
| 
 | |
|     private $process;
 | |
|     private $timeoutType;
 | |
| 
 | |
|     public function __construct(Process $process, $timeoutType)
 | |
|     {
 | |
|         $this->process     = $process;
 | |
|         $this->timeoutType = $timeoutType;
 | |
| 
 | |
|         parent::__construct(sprintf('The process "%s" exceeded the timeout of %s seconds.', $process->getCommandLine(), $this->getExceededTimeout()));
 | |
|     }
 | |
| 
 | |
|     public function getProcess()
 | |
|     {
 | |
|         return $this->process;
 | |
|     }
 | |
| 
 | |
|     public function isGeneralTimeout()
 | |
|     {
 | |
|         return $this->timeoutType === self::TYPE_GENERAL;
 | |
|     }
 | |
| 
 | |
|     public function isIdleTimeout()
 | |
|     {
 | |
|         return $this->timeoutType === self::TYPE_IDLE;
 | |
|     }
 | |
| 
 | |
|     public function getExceededTimeout()
 | |
|     {
 | |
|         switch ($this->timeoutType) {
 | |
|             case self::TYPE_GENERAL:
 | |
|                 return $this->process->getTimeout();
 | |
| 
 | |
|             case self::TYPE_IDLE:
 | |
|                 return $this->process->getIdleTimeout();
 | |
| 
 | |
|             default:
 | |
|                 throw new \LogicException(sprintf('Unknown timeout type "%d".', $this->timeoutType));
 | |
|         }
 | |
|     }
 | |
| }
 |