comparison recorder.php @ 165:3d4df1fe4166

merged with upstream

160:47a3acf19870

if( ! defined( RECORDER_CMD ) ) {
	define( "RECORDER_CMD", INSTALL_PATH . "/recorder.php" );
}


// ノンブロッキングメッセージ受信

function epgrec_get_message() {
	global $msgh_r, $reserve_id;

// こういうやり方しかないのか？
//
function epgrec_childproc( $p )
{
	$st = proc_get_status( $p );
	$cpids = epgrec_childproc( $st['pid'] );
	
	// ps を実行する
	$d = array(
			0 => array( 'file','/dev/null','r' ),
			1 => array( 'pipe','w' ),

	return true;	// 保証できない
}

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

$settings = Settings::factory();
$reserve_id = $argv[1];
$msgh_r = null;		// 受信用メッセージハンドラ
$msgh_w = null;		// 送信用メッセージハンドラ

// メッセージハンドラを得る
$ipc_key = ftok( RECORDER_CMD, "R" );
$msgh_r = msg_get_queue( $ipc_key );

	
	// 録画開始
	
	$proch = false;
	if( ( $proch = epgrec_exec(DO_RECORD) ) !== false ) {
		// 録画完了待ち
		$rec_cont = true;
		while( $rec_cont ){
			$st = proc_get_status($proch);
			if(! $st['running'] ) $rec_cont = false;    // 録画完了

							reclog( "録画コマンドを停止できません", EPGREC_WARN );
						}
						else {
							epgrec_send_message("success");
							reclog("recorder:: 録画ID".$rrec->id .":".$rrec->type.$rrec->channel.$rrec->title."の録画が中断された" );
						}
						break;
					
					case "stat":
						epgrec_send_message("alive");

		$rrec->complete = 1;	// 終わったことにする
		throw new RecException("recorder:: 録画コマンドの実行に失敗した", EPGREC_ERROR );
	}
	
	// 予定より短いようなら終了時間を現在に書き換える
	
	if( time() < $endtime ) {
		$rrec->endtime = toDatetime( time() );
	}
	
	// 完了フラグを立てておく

165:3d4df1fe4166

if( ! defined( RECORDER_CMD ) ) {
	define( "RECORDER_CMD", INSTALL_PATH . "/recorder.php" );
}

$settings = Settings::factory();
$reserve_id = $argv[1];
$msgh_r = null;		// 受信用メッセージハンドラ
$msgh_w = null;		// 送信用メッセージハンドラ


// ノンブロッキングメッセージ受信

function epgrec_get_message() {
	global $msgh_r, $reserve_id;

// こういうやり方しかないのか？
//
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' ),

	return true;	// 保証できない
}

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


// メッセージハンドラを得る
$ipc_key = ftok( RECORDER_CMD, "R" );
$msgh_r = msg_get_queue( $ipc_key );

	
	// 録画開始
	
	$proch = false;
	if( ( $proch = epgrec_exec(DO_RECORD) ) !== false ) {
		reclog("recorder:: 録画ID".$rrec->id .":".$rrec->type.$rrec->channel.$rrec->title."の録画開始" );
		// 録画完了待ち
		$rec_cont = true;
		while( $rec_cont ){
			$st = proc_get_status($proch);
			if(! $st['running'] ) $rec_cont = false;    // 録画完了

							reclog( "録画コマンドを停止できません", EPGREC_WARN );
						}
						else {
							epgrec_send_message("success");
							reclog("recorder:: 録画ID".$rrec->id .":".$rrec->type.$rrec->channel.$rrec->title."の録画が中断された" );
							$rec_cont = false;
						}
						break;
					
					case "stat":
						epgrec_send_message("alive");

		$rrec->complete = 1;	// 終わったことにする
		throw new RecException("recorder:: 録画コマンドの実行に失敗した", EPGREC_ERROR );
	}
	
	// 予定より短いようなら終了時間を現在に書き換える
	if( time() < $endtime ) {
		$rrec->endtime = toDatetime( time() );
	}
	
	// 完了フラグを立てておく