diff Reservation.class.php @ 161:84220382fea8

mod: 録画中のキャンセルを可能にした（動作確認、まだ不完全かも）

--- a/Reservation.class.php	Tue Mar 30 19:00:39 2010 +0900
+++ b/Reservation.class.php	Sun Apr 04 17:10:17 2010 +0900
@@ -5,6 +5,11 @@
 include_once( INSTALL_PATH . "/Settings.class.php" );
 include_once( INSTALL_PATH . "/recLog.inc.php" );
 
+// 緇���剛��������
+if( !defined( "RECORDER_CMD" ) ) {
+	define( "RECORDER_CMD", INSTALL_PATH."/recorder.php" );
+}
+
 
 // 篋�膣����������
 
@@ -288,17 +293,13 @@
 			// AT��т��膣�������
 			$process = proc_open( $cmdline , $descriptor, $pipes, INSTALL_PATH.$settings->spool, $env );
 			if( is_resource( $process ) ) {
-				fwrite($pipes[0], $settings->sleep." ".$sleep_time."\n" );
-				fwrite($pipes[0], DO_RECORD . "\n" );
-				fwrite($pipes[0], COMPLETE_CMD." ".$rrec->id."\n" );
-				if( $settings->use_thumbs == 1 ) {
-					fwrite($pipes[0], $gen_thumbnail."\n" );
-				}
+				fwrite($pipes[0], RECORDER_CMD." ".$rrec->id."\n" );
 				fclose($pipes[0]);
 				// 罔�羣���������若��������
-				$rstring = stream_get_contents( $pipes[2]);
+				$rstring = stream_get_contents($pipes[2]);
 				
 			    fclose( $pipes[2] );
+			    fclose( $pipes[1] );
 			    proc_close( $process );
 			}
 			else {
@@ -354,15 +355,57 @@
 				throw new Exception("ID������絎������≦�鴻�с��");
 			}
 			if( ! $rec->complete ) {
-				// ���絎�茵����篋�膣���с�����
 				if( toTimestamp($rec->starttime) < (time() + PADDING_TIME + $settings->former_time) ) {
-					reclog("Reservation::cancel ���絎�茵����篋�膣����������羔�������絎�茵����������", EPGREC_ERROR );
-					throw new Exception("���絎�茵����篋�膣���с��");
+					reclog("Reservation::cancel 絎�茵�筝����篋�膣�ID".$rec->id."���������羔�������絎�茵����������" );
+					
+					// recorder���������篆＜��荅���帥��
+					$ipc_key = ftok( RECORDER_CMD, "R" );
+					
+					/* php 5.3篁ラ�����������������msg_queue_exists���篏帥��������
+					if( ! msg_queue_exists( $ipc_key ) ) {
+						// ��＜����祉�若�吾����ャ�若��������
+						reclog( "Reservation::cancel 絎�茵�筝�����ｨ羝����������篋�膣�".$rec->id."���絎�茵�������������������", EPGREC_ERROR );
+						$rec->complete = 1;
+						throw new RecException( "Reserve:: 絎�茵�筝�����ｨ羝����������篋�膣����絎�茵���������������障�����������綺���������ゃ��荅���帥�����������������", EPGREC_ERROR );
+					}
+					else {
+					*/
+						$msgh_r = msg_get_queue( $ipc_key );
+						$ipc_key = ftok( RECORDER_CMD, "W" );
+						$msgh_w = msg_get_queue( $ipc_key );
+						
+						// 腟�篋�������腓�
+						msg_send( $msgh_r, (int)$rec->id, "terminate" );
+						sleep(1);
+						for( $i = 0; $i < 60; $i++ ) {
+							$r = msg_receive($msgh_w, (int)$rec->id , $msgtype, 1024, $message, TRUE, MSG_IPC_NOWAIT | MSG_NOERROR);
+							if( $r ) {
+								if( $message == "success" ) {
+									reclog( "Reserve:: 絎�茵�筝����篋�膣�ID".$rec->id."���������羔�������������������罔≧��" );
+									break;
+								}
+								else if( $message == "error" ){
+									reclog( "Reserve:: 絎�茵�筝����篋�膣�ID".$rec->id."���������羔�������紊掩��", EPGREC_ERROR );
+									throw new RecException("絎�茵�筝����篋�膣�������羔�������紊掩�������障�������������違��������������������������������綺����������羔�������������������", EPGREC_ERROR );
+								}
+								// ������篁ュ�������＜����祉�若�吾����∴��������緇����
+							}
+							sleep(1);
+						}
+						if( $i >= 60 ) throw new RecException("絎�茵�筝����篋�膣�������羔�������紊掩�������障�������������違��������������������������������綺����������羔�������������������", EPGREC_ERROR );
+//					}
 				}
-				exec( $settings->atrm . " " . $rec->job );
-				reclog("Reservation::cancel ��吾�с��������".$rec->job."���������");
+				else {
+					// ��障��絎�茵�������������������篋�膣�������at��������ゃ��������
+					exec( $settings->atrm . " " . $rec->job );
+					reclog("Reservation::cancel ��吾�с��������".$rec->job."���������");
+					$rec->delete();
+				}
 			}
-			$rec->delete();
+			else {
+				// ��牙�紙����推��膣�������������羔����
+				$rec->delete();
+			}
 		}
 		catch( Exception $e ) {
 			reclog("Reservation::cancel 篋�膣������ｃ�潟�祉�����DB�･膓���障�������≪����祉�鴻��紊掩��������罔≧��", EPGREC_ERROR );
@@ -370,4 +413,4 @@
 		}
 	}
 }
-?>
+?>
\ No newline at end of file