Mercurial > epgrec.yaz
comparison Reservation.class.php @ 165:3d4df1fe4166
merged with upstream
author | Yoshiki Yazawa <yaz@honeyplanet.jp> |
---|---|
date | Thu, 08 Apr 2010 04:22:20 +0900 |
parents | 66eabfc1b118 84220382fea8 |
children | 1c4558d1a449 |
comparison
equal
deleted
inserted
replaced
160:47a3acf19870 | 165:3d4df1fe4166 |
---|---|
2 include_once('config.php'); | 2 include_once('config.php'); |
3 include_once( INSTALL_PATH . "/DBRecord.class.php" ); | 3 include_once( INSTALL_PATH . "/DBRecord.class.php" ); |
4 include_once( INSTALL_PATH . "/reclib.php" ); | 4 include_once( INSTALL_PATH . "/reclib.php" ); |
5 include_once( INSTALL_PATH . "/Settings.class.php" ); | 5 include_once( INSTALL_PATH . "/Settings.class.php" ); |
6 include_once( INSTALL_PATH . "/recLog.inc.php" ); | 6 include_once( INSTALL_PATH . "/recLog.inc.php" ); |
7 | |
8 // 後方互換性 | |
9 if( !defined( "RECORDER_CMD" ) ) { | |
10 define( "RECORDER_CMD", INSTALL_PATH."/recorder.php" ); | |
11 } | |
7 | 12 |
8 | 13 |
9 // 予約クラス | 14 // 予約クラス |
10 | 15 |
11 class Reservation { | 16 class Reservation { |
286 ); | 291 ); |
287 | 292 |
288 // ATで予約する | 293 // ATで予約する |
289 $process = proc_open( $cmdline , $descriptor, $pipes, INSTALL_PATH.$settings->spool, $env ); | 294 $process = proc_open( $cmdline , $descriptor, $pipes, INSTALL_PATH.$settings->spool, $env ); |
290 if( is_resource( $process ) ) { | 295 if( is_resource( $process ) ) { |
291 fwrite($pipes[0], $settings->sleep." ".$sleep_time."\n" ); | 296 fwrite($pipes[0], RECORDER_CMD." ".$rrec->id."\n" ); |
292 fwrite($pipes[0], DO_RECORD . "\n" ); | |
293 fwrite($pipes[0], COMPLETE_CMD." ".$rrec->id."\n" ); | |
294 if( $settings->use_thumbs == 1 ) { | |
295 fwrite($pipes[0], $gen_thumbnail."\n" ); | |
296 } | |
297 fclose($pipes[0]); | 297 fclose($pipes[0]); |
298 // 標準エラーを取る | 298 // 標準エラーを取る |
299 $rstring = stream_get_contents( $pipes[2]); | 299 $rstring = stream_get_contents($pipes[2]); |
300 | 300 |
301 fclose( $pipes[2] ); | 301 fclose( $pipes[2] ); |
302 fclose( $pipes[1] ); | |
302 proc_close( $process ); | 303 proc_close( $process ); |
303 } | 304 } |
304 else { | 305 else { |
305 $rrec->delete(); | 306 $rrec->delete(); |
306 reclog( "Reservation::custom atの実行に失敗した模様", EPGREC_ERROR); | 307 reclog( "Reservation::custom atの実行に失敗した模様", EPGREC_ERROR); |
352 } | 353 } |
353 if( $rec == null ) { | 354 if( $rec == null ) { |
354 throw new Exception("IDの指定が無効です"); | 355 throw new Exception("IDの指定が無効です"); |
355 } | 356 } |
356 if( ! $rec->complete ) { | 357 if( ! $rec->complete ) { |
357 // 未実行の予約である | |
358 if( toTimestamp($rec->starttime) < (time() + PADDING_TIME + $settings->former_time) ) { | 358 if( toTimestamp($rec->starttime) < (time() + PADDING_TIME + $settings->former_time) ) { |
359 reclog("Reservation::cancel 未実行の予約の取り消しが実行された", EPGREC_ERROR ); | 359 reclog("Reservation::cancel 実行中の予約ID".$rec->id."の取り消しが実行された" ); |
360 throw new Exception("未実行の予約です"); | 360 |
361 } | 361 // recorderとの通信を試みる |
362 exec( $settings->atrm . " " . $rec->job ); | 362 $ipc_key = ftok( RECORDER_CMD, "R" ); |
363 reclog("Reservation::cancel ジョブ番号".$rec->job."を削除"); | 363 |
364 } | 364 /* php 5.3以降じゃないとmsg_queue_existsは使えない |
365 $rec->delete(); | 365 if( ! msg_queue_exists( $ipc_key ) ) { |
366 // メッセージキューがない | |
367 reclog( "Reservation::cancel 実行中と推測される予約".$rec->id."が実行されていない", EPGREC_ERROR ); | |
368 $rec->complete = 1; | |
369 throw new RecException( "Reserve:: 実行中と推測される予約が実行されていません。再度、削除を試みてください。", EPGREC_ERROR ); | |
370 } | |
371 else { | |
372 */ | |
373 $msgh_r = msg_get_queue( $ipc_key ); | |
374 $ipc_key = ftok( RECORDER_CMD, "W" ); | |
375 $msgh_w = msg_get_queue( $ipc_key ); | |
376 | |
377 // 終了を指示 | |
378 msg_send( $msgh_r, (int)$rec->id, "terminate" ); | |
379 sleep(1); | |
380 for( $i = 0; $i < 60; $i++ ) { | |
381 $r = msg_receive($msgh_w, (int)$rec->id , $msgtype, 1024, $message, TRUE, MSG_IPC_NOWAIT | MSG_NOERROR); | |
382 if( $r ) { | |
383 if( $message == "success" ) { | |
384 reclog( "Reserve:: 実行中の予約ID".$rec->id."の取り消しに成功した模様" ); | |
385 break; | |
386 } | |
387 else if( $message == "error" ){ | |
388 reclog( "Reserve:: 実行中の予約ID".$rec->id."の取り消しに失敗", EPGREC_ERROR ); | |
389 throw new RecException("実行中の予約取り消しに失敗しました。しばらく時間をおいてから再度、取り消してください", EPGREC_ERROR ); | |
390 } | |
391 // それ以外のメッセージは無視して待つ | |
392 } | |
393 sleep(1); | |
394 } | |
395 if( $i >= 60 ) throw new RecException("実行中の予約取り消しに失敗しました。しばらく時間をおいてから再度、取り消してください", EPGREC_ERROR ); | |
396 // } | |
397 } | |
398 else { | |
399 // まだ実行されていない予約ならatを削除しとく | |
400 exec( $settings->atrm . " " . $rec->job ); | |
401 reclog("Reservation::cancel ジョブ番号".$rec->job."を削除"); | |
402 $rec->delete(); | |
403 } | |
404 } | |
405 else { | |
406 // 録画済み予約ならただ消す | |
407 $rec->delete(); | |
408 } | |
366 } | 409 } |
367 catch( Exception $e ) { | 410 catch( Exception $e ) { |
368 reclog("Reservation::cancel 予約キャンセルでDB接続またはアクセスに失敗した模様", EPGREC_ERROR ); | 411 reclog("Reservation::cancel 予約キャンセルでDB接続またはアクセスに失敗した模様", EPGREC_ERROR ); |
369 throw $e; | 412 throw $e; |
370 } | 413 } |