comparison recorder.php @ 169:e379552d084c

fix: recorder.php:???????????????????

167:b307e3749e80

	if( is_resource( $p ) ) return $p;
	
	return false;
}

// 指定したプロセスハンドルが生成した子プロセスのpidリストを返す
// こういうやり方しかないのか？
//
function epgrec_childproc( $p )
{
	$st = proc_get_status( $p );
	$ppid = $st['pid'];
	
	// ps を実行する
	$d = array(
			0 => array( 'file','/dev/null','r' ),
			1 => array( 'pipe','w' ),
			2 => array( 'file','/dev/null','w' ),

		}
	}
	fclose( $pipes[1] );
	proc_close( $ps );
	
	return $cpids;
}

// 指定したプロセスハンドルを子プロセスを含め終了させる

	if( DEBUG ) {
		global $logfile;
		system( "ps ax >>".$logfile );
		system( "echo ------- >>".$logfile );
	}
	
	$cpids = epgrec_childproc( $p );
	
	if( DEBUG ) {
		 global $logfile;
		 
		 foreach( $cpids as $cpid ) {
			system( "echo ".$cpid." >>".$logfile );
		}
		system( "echo ------- >>".$logfile );
	}
	
	@proc_terminate( $p );
	sleep(1);
	@proc_terminate( $p );	// 2度送る
	
	foreach( $cpids as $cpid ) {
		$ret = posix_kill( $cpid, SIGTERM );	// sigterm
		usleep(100*1000);
		if( ! $ret ) posix_kill( $cpid, SIGKILL );	// sigkill
	}
	
	if( DEBUG ) {
		global $logfile;
		system( "ps ax >>".$logfile );
		system( "echo ------- >>".$logfile );
	}
	
	foreach( $cpids as $cpid ) {
		$ret = posix_kill( $cpid, SIGTERM );	// sigterm
		if( $ret ) return false;	// 恐らくプロセスが存在するのでエラー
	}
	return true;	// 保証できない
}

////// ここから本編

	
	// 予定より短いようなら終了時間を現在に書き換える
	if( time() < $endtime ) {
		$rrec->endtime = toDatetime( time() );
	}
	
	// 完了フラグを立てておく
	$rrec->complete = '1';
	
	// ちょっと待った方が確実っぽい
	sleep(15);

169:e379552d084c

	if( is_resource( $p ) ) return $p;
	
	return false;
}

// 指定したプロセスIDが生成した子プロセスのpidリストを返す
// こういうやり方しかないのか？
//
function epgrec_childproc( $ppid )
{
	// ps を実行する
	$d = array(
			0 => array( 'file','/dev/null','r' ),
			1 => array( 'pipe','w' ),
			2 => array( 'file','/dev/null','w' ),

		}
	}
	fclose( $pipes[1] );
	proc_close( $ps );
	
	foreach( $cpids as $p ) {
		$ccpids = epgrec_childproc( $p );
		foreach( $ccpids as $ccpid ) {
			array_push( $cpids, $ccpid );
		}
	}
	return $cpids;
}

// 指定したプロセスハンドルを子プロセスを含め終了させる

	if( DEBUG ) {
		global $logfile;
		system( "ps ax >>".$logfile );
		system( "echo ------- >>".$logfile );
	}
	$status = proc_get_status( $p );
	$cpids = epgrec_childproc( $status['pid'] );
	
	if( DEBUG ) {
		 global $logfile;
		 
		 foreach( $cpids as $cpid ) {
			system( "echo ".$cpid." >>".$logfile );
		}
		system( "echo ------- >>".$logfile );
	}
	
	// 親から止める
	@proc_terminate( $p );
	usleep(500*1000);
	@proc_terminate( $p );	// 2度送る
	
	foreach( $cpids as $cpid ) {
		$ret = posix_kill( $cpid, SIGTERM );		// sigterm
		usleep(100*1000);
		if( ! $ret ) posix_kill( $cpid, SIGKILL );	// sigkill
	}
	
	if( DEBUG ) {
		global $logfile;
		system( "ps ax >>".$logfile );
		system( "echo ------- >>".$logfile );
	}
	
	/* プロセスがしばらく居残る場合がある
	foreach( $cpids as $cpid ) {
		$ret = posix_kill( $cpid, SIGTERM );	// sigterm
		if( $ret ) return false;				// 恐らくプロセスが存在するのでエラー
	}
	*/
	return true;	// 保証できない
}

////// ここから本編

	
	// 予定より短いようなら終了時間を現在に書き換える
	if( time() < $endtime ) {
		$rrec->endtime = toDatetime( time() );
	}
	// 完了フラグを立てておく
	$rrec->complete = '1';
	
	// ちょっと待った方が確実っぽい
	sleep(15);