SAE预加载文件内容

文件名:sae_include.function.php
很多实现方法你看完会感觉233...
完整文件:

 0 ) {
	$_SERVER['HTTP_MYSQLPORT'] = 3307;
}

define( 'SAE_APPNAME', sae_get_env('AppName') );
define( 'SAE_APPVERSION', sae_get_env('AppVersion') );
define( 'SAE_ACCESSKEY', sae_get_env('AccessKey') );
define( 'SAE_SECRETKEY', sae_get_env('SecretKey') );
$_SERVER['HTTP_SECRETKEY'] = 'Discarded';

// document root
$_SERVER['DOCUMENT_ROOT'] = rtrim($_SERVER['DOCUMENT_ROOT'], "/");
$_SERVER['DOCUMENT_ROOT'] = $_SERVER['DOCUMENT_ROOT'] . "/" . sae_get_env('AppHash') . "/" . SAE_APPNAME . "/" . SAE_APPVERSION;

define( 'SAE_MYSQL_HOST_M', 'w.rdc.sae.sina.com.cn' );
define( 'SAE_MYSQL_HOST_S', 'r.rdc.sae.sina.com.cn' );
define( 'SAE_MYSQL_PORT', 3307 );
define( 'SAE_MYSQL_USER', SAE_ACCESSKEY );
define( 'SAE_MYSQL_PASS', SAE_SECRETKEY );
define( 'SAE_MYSQL_DB', 'app_' . SAE_APPNAME );

// gravity define
define("SAE_NorthWest", 1);
define("SAE_North", 2);
define("SAE_NorthEast",3);
define("SAE_East",6);
define("SAE_SouthEast",9);
define("SAE_South",8);
define("SAE_SouthWest",7);
define("SAE_West",4);
define("SAE_Static",10);
define("SAE_Center",5);

// font stretch
define("SAE_Undefined",0);
define("SAE_Normal",1);
define("SAE_UltraCondensed",2);
define("SAE_ExtraCondensed",3);
define("SAE_Condensed",4);
define("SAE_SemiCondensed",5);
define("SAE_SemiExpanded",6);
define("SAE_Expanded",7);
define("SAE_ExtraExpanded",8);
define("SAE_UltraExpanded",9);

// font style
define("SAE_Italic",2);
define("SAE_Oblique",3);

// font name
define("SAE_SimSun",1);
define("SAE_SimKai",2);
define("SAE_SimHei",3);
define("SAE_Arial",4);
define("SAE_MicroHei",5);

// anchor postion
define("SAE_TOP_LEFT","tl");
define("SAE_TOP_CENTER","tc");
define("SAE_TOP_RIGHT","tr");
define("SAE_CENTER_LEFT","cl");
define("SAE_CENTER_CENTER","cc");
define("SAE_CENTER_RIGHT","cr");
define("SAE_BOTTOM_LEFT","bl");
define("SAE_BOTTOM_CENTER","bc");
define("SAE_BOTTOM_RIGHT","br");

// errno define
define("SAE_Success", 0); // OK
define("SAE_ErrKey", 1); // invalid accesskey or secretkey
define("SAE_ErrForbidden", 2); // access fibidden for quota limit
define("SAE_ErrParameter", 3); // parameter not exist or invalid
define("SAE_ErrInternal", 500); // internal Error
define("SAE_ErrUnknown", 999); // unknown error

// fonts for gd
define("SAE_Font_Sun", "/usr/share/fonts/chinese/TrueType/uming.ttf");
define("SAE_Font_Kai", "/usr/share/fonts/chinese/TrueType/ukai.ttf");
define("SAE_Font_Hei", "/usr/share/fonts/chinese/TrueType/wqy-zenhei.ttc");
define("SAE_Font_MicroHei", "/usr/share/fonts/chinese/TrueType/wqy-microhei.ttc");


/**
 * SaeObject
 *
 * @package sae
 * @ignore
 */
abstract class SaeObject implements SaeInterface
{
	function __construct()
	{
		//
	}
}

/**
 * SaeInterface , public interface of all sae client apis
 *
 * all sae client classes must implement these method for setting accesskey and secretkey , getting error infomation.
 * @package sae
 * @ignore
 **/
interface SaeInterface
{
	public function errmsg();
	public function errno();
}


function is_https() {
	return ( ( isset($_SERVER['HTTP_APPMASK']) && $_SERVER['HTTP_APPMASK'] & 0x1 ) || ( isset($_SERVER['HTTP_X_PROTO']) && $_SERVER['HTTP_X_PROTO'] == 'SSL' ) );
}
if ( is_https() ) {
	$_SERVER['HTTPS'] = 'on';
}

function saeAutoLoader( $class_name )
{
	$file = dirname( __FILE__ ) . '/' . strtolower($class_name) . '.class.php';
	if( file_exists($file) )
		include_once( $file );
	if(!class_exists($class_name) && function_exists('__autoload'))
		__autoload($class_name);
	if(!class_exists($class_name) && function_exists('__sae_autoload'))
		__sae_autoload($class_name);
}

spl_autoload_register('saeAutoLoader');

function sae_xhprof_start()
{
	 xhprof_enable(XHPROF_FLAGS_CPU + XHPROF_FLAGS_MEMORY);
}

function sae_xhprof_end()
{
	$data = xhprof_disable();
	if ( !empty($data) ) {
		$s = new SaeStorage();
		$s->write( 'xhprof' , 'xhprof_data_' . time() , serialize( $data ) );
	}
	return $data;
}

if (!function_exists('fsockopen')) {
	function fsockopen($hostname, $port = 80, &$errno = null, &$errstr = null, $timeout = 5) {

		srand(time() + crc32($hostname));

		$fp = FALSE;
		for ($i = 0; $i < 5 && !$fp; $i++) {
			$index = rand();
			$fp = fsockopen_($index, 8000, $errno, $errstr, 5);
		}

		if ($fp) {
			$accesskey = SAE_ACCESSKEY;
			$secretkey = SAE_SECRETKEY;
			$endpoint  = "$hostname:$port";
			$signature = base64_encode(hash_hmac('sha256', $endpoint, $secretkey, true));

			$request = "$accesskey $signature $endpoint $timeoutrn";

			fwrite($fp, $request);
			$response = fread($fp, 128);
			if ($response !== FALSE) {
				rtrim($response, "rn");
				list($errno, $errstr) = explode(":", $response, 2);
				if ($errno != 0) {
					fclose($fp);
					$fp = FALSE;
				}
			} else {
				fclose($fp);
				$fp = FALSE;
				$errno = 500;
				$errstr = "Internal Error In Handshake";
			}
		}

		return $fp;
	}
}

//function sae_debug($errmsg)
//{
//	return trigger_error($errmsg, E_USER_WARNING);
//}

// =====================================================
// 以下函数全部为对0.1版本向前兼容用,不再推荐使用
// easychen@gmail.com
// =====================================================



// image
function sae_image_init( $ak='', $sk='', $image_bin = '' )
{
	if( !isset( $GLOBALS['sae_image_instance'] ) )
	{
		include_once( 'sae_image.class.php' );
		$GLOBALS['sae_image_instance'] = new sae_image( $ak, $sk, $image_bin );
	}

	return $GLOBALS['sae_image_instance'];

}




// storage
function sae_storage_init( $accesskey ,  $secretkey , $ssl = false )
{
	if( !isset( $GLOBALS['sae_storage_instance'] ) )
	{
		include_once( 'sae_storage.class.php' );
		$GLOBALS['sae_storage_instance'] = new sae_storage( $accesskey ,  $secretkey , $ssl );
	}

	return $GLOBALS['sae_storage_instance'];
}



// mysql
function sae_mysql_init( $host , $port , $accesskey , $secretkey , $appname , $do_replication = true )
{
	if( !isset( $GLOBALS['sae_mysql_instance'] ) )
	{
		include_once( 'sae_mysql.class.php' );
		$GLOBALS['sae_mysql_instance'] = new sae_mysql( $host , $port , $accesskey , $secretkey , $appname , $do_replication );
	}

	return $GLOBALS['sae_mysql_instance'];
}

// fetch url
//-------------------------------------------------------------------------------------------------

function _header_info($header)
{
 $hinfo = array();
 $header_lines = explode("r",trim( $header));
 $first = array_shift($header_lines);
 // HTTP/1.1 301 Moved Permanently
 $reg ="/HTTP/(.+?)s([0-9]+)s(.+)/is";
 if(preg_match($reg,trim($first),$out))
   {
    $hinfo['version'] = $out[1];
    $hinfo['code'] = $out[2];
    $hinfo['code_info'] = $out[3];
   }
 else
    return false;
 if(is_array($header_lines))
   {
    foreach($header_lines as $line)
           {
            $fs=explode( ":" , trim($line),2);
            if(strlen(trim($fs[0])) > 0 )
              {
               if(isset( $hinfo[strtolower(trim($fs[0]))] ) )
                  $hinfo[strtolower(trim($fs[0]))] = array_merge( (array)$hinfo[strtolower(trim($fs[0]))] , (array)trim($fs[1]) );
               else
                  $hinfo[strtolower(trim($fs[0]))] = trim($fs[1]);
              }
           }
    }
 return $hinfo;
}
//-------------------------------------------------------------------------------------------------

function _get_signature($accesskey,$securekey,&$header_array)
{
 $content="FetchUrl";
 $content.=$header_array["FetchUrl"];
 $content.="TimeStamp";
 $content.=$header_array['TimeStamp'];
 $content.="AccessKey";
 $content.=$header_array['AccessKey'];
 return base64_encode(hash_hmac('sha256',$content,$securekey,true));
}
//-------------------------------------------------------------------------------------------------

function _read_header($ch,$string)
{
 global $errno,$errmsg,$rheader;
 $rheader.=$string;
 $ret=explode(" ",$string);
 if(count($ret)==3 && $ret[0]=='HTTP/1.1')
   {
    if($ret[1]==200)
       $errno=0;
    else
       {
       $errno=$ret[1];
       $errmsg=$ret[2];
       }
   }
 return strlen($string);
}
//-------------------------------------------------------------------------------------------------

function _read_data($ch,$string)
{
 global $rdata;
 $rdata.=$string;
 return strlen($string);
}
//-------------------------------------------------------------------------------------------------

function _fetch_url($url,$accesskey,$securekey,&$header,&$error,$opt=NULL)
{
 global $errno,$errmsg,$rheader,$rdata;
 $rheader='';
 $rdata='';
 $errno=0;
 $errmsg='';
 $ch=curl_init();
 curl_setopt($ch,CURLOPT_HEADERFUNCTION,'_read_header');
 curl_setopt($ch,CURLOPT_WRITEFUNCTION,'_read_data');
 curl_setopt($ch,CURLOPT_CONNECTTIMEOUT,3);
 curl_setopt($ch,CURLOPT_TIMEOUT,10);
 $header_array=array();
 if($opt && is_array($opt))
   {
    if(array_key_exists('username',$opt) && array_key_exists('password',$opt))
       curl_setopt($ch,CURLOPT_USERPWD,$opt['username'].':'.$opt['password']);
    if(array_key_exists('useragent',$opt))
       curl_setopt($ch,CURLOPT_USERAGENT,$opt['useragent']);
    if(array_key_exists('post',$opt))
      {
       curl_setopt($ch,CURLOPT_POST,true);
       curl_setopt($ch,CURLOPT_POSTFIELDS,$opt['post']);
      }
    if(array_key_exists('truncated',$opt))
       $header_array['AllowTruncated']=$opt['truncated'];

//    if(array_key_exists('connecttimeout',$opt))
//       $header_array['ConnectTimeout']=$opt['connecttimeout'];
//    if(array_key_exists('sendtimeout',$opt))
//       $header_array['SendTimeout']=$opt['sendtimeout'];
//    if(array_key_exists('readtimeout',$opt))
//       $header_array['ReadTimeout']=$opt['readtimeout'];

    if(array_key_exists('headers',$opt))
      {
       $headers=$opt['headers'];
       if(is_array($headers))
         {
          foreach($headers as $k => $v)
                  $header_array[$k]=$v;
         }
      }
   }//end if is_array
 $header_array['FetchUrl']=$url;
 $header_array['AccessKey']=$accesskey;
 $header_array['TimeStamp']=date('Y-m-d H:i:s');
 $header_array['Signature']=_get_signature($accesskey,$securekey,$header_array);

 $header_array2=array();
 foreach($header_array as $k => $v)
         array_push($header_array2,$k.': '.$v);

 curl_setopt($ch,CURLOPT_HTTPHEADER,$header_array2);
 curl_setopt($ch,CURLOPT_URL,SAE_FETCHURL_SERVICE_ADDRESS);
 curl_exec($ch);
 curl_close($ch);
 $header=$rheader;
 if($errno==0)
    return $rdata;
 $error=$errno.': '.$errmsg;
 return false;
}//end function fetchurl
//-------------------------------------------------------------------------------------------------

function fetch_url($url,$accesskey,$securekey,&$header,&$error,$opt=NULL)
{
 if($opt && is_array($opt) && array_key_exists('redirect',$opt) && $opt['redirect']==true)
   {
    $times=0;
    while(true)
         {
          $rt=_fetch_url($url,$accesskey,$securekey,$header,$error,$opt);
          if($rt==false)
             return $rt;
          $info=_header_info($header);
          $jump=false;
		  if(isset($info['location']) && ($info['code']==301|| $info['code']==302) && $times<5)
            $jump=true;
          if($jump==true)
            {
             $times++;
             $url=$info['location'];
             continue;
            }
          return $rt;
         }//end while
   }//end if
 return _fetch_url($url,$accesskey,$securekey,$header,$error,$opt);
}
//-------------------------------------------------------------------------------------------------



if ( ! in_array("saemc", stream_get_wrappers()) )
	stream_wrapper_register("saemc", "SaeMemcacheWrapper");




class SaeMemcacheWrapper // implements WrapperInterface
{
	public $dir_mode = 16895 ; //040000 + 0222;
	public $file_mode = 33279 ; //0100000 + 0777;


	public function __construct()
	{
		$this->mc = memcache_init();
	}

	public function mc() {
		if ( !isset( $this->mc ) ) $this->mc = memcache_init();
		return $this->mc;
	}

	public function stream_open( $path , $mode , $options , &$opened_path)
	{
		$this->position = 0;
		$this->mckey = trim(substr($path, 8));
		$this->mode = $mode;
		$this->options = $options;

		if ( in_array( $this->mode, array( 'r', 'r+', 'rb' ) ) ) {
			if ( $this->mccontent = memcache_get( $this->mc, $this->mckey ) ) {
				$this->get_file_info( $this->mckey );
				$this->stat['mode'] = $this->stat[2] = $this->file_mode;
			} else {
				trigger_error("fopen({$path}): failed to read from Memcached: No such key.", E_USER_WARNING);
				return false;
			}
		} elseif ( in_array( $this->mode, array( 'a', 'a+', 'ab' ) ) ) {
			if ( $this->mccontent = memcache_get( $this->mc , $this->mckey ) ) {
				$this->get_file_info( $this->mckey );
				$this->stat['mode'] = $this->stat[2] = $this->file_mode;
				$this->position = strlen($this->mccontent);
			} else {
				$this->mccontent = '';
				$this->stat['ctime'] = $this->stat[10] = time();
			}
		} elseif ( in_array( $this->mode, array( 'x', 'x+', 'xb' ) ) ) {
			if ( !memcache_get( $this->mc , $this->mckey ) ) {
				$this->mccontent = '';
				$this->statinfo_init();
				$this->stat['ctime'] = $this->stat[10] = time();
			} else {
				trigger_error("fopen({$path}): failed to create at Memcached: Key exists.", E_USER_WARNING);
				return false;
			}
		} elseif ( in_array( $this->mode, array( 'w', 'w+', 'wb' ) ) ) {
			$this->mccontent = '';
			$this->statinfo_init();
			$this->stat['ctime'] = $this->stat[10] = time();
		} else {
			$this->mccontent = memcache_get( $this->mc , $this->mckey );
		}

		return true;
	}

	public function stream_read($count)
	{
		if (in_array($this->mode, array('w', 'x', 'a', 'wb', 'xb', 'ab') ) ) {
			return false;
		}


		$ret = substr( $this->mccontent , $this->position, $count);
		$this->position += strlen($ret);

		$this->stat['atime'] = $this->stat[8] = time();
		$this->stat['uid'] = $this->stat[4] = 0;
		$this->stat['gid'] = $this->stat[5] = 0;

		return $ret;
	}

	public function stream_write($data)
	{
		if ( in_array( $this->mode, array( 'r', 'rb' ) ) ) {
			return false;
		}

		$left = substr($this->mccontent, 0, $this->position);
		$right = substr($this->mccontent, $this->position + strlen($data));
		$this->mccontent = $left . $data . $right;

		if ( memcache_set( $this->mc , $this->mckey , $this->mccontent ) ) {
			$this->stat['mtime'] = $this->stat[9] = time();
			$this->position += strlen($data);
			return $this->stat['size'] = $this->stat[7] = strlen( $data );
		}
		else return false;
	}

	public function stream_close()
	{

		memcache_set( $this->mc , $this->mckey.'.meta' ,  serialize($this->stat)  );
		//memcache_close( $this->mc );
	}


	public function stream_eof()
	{

		return $this->position >= strlen( $this->mccontent  );
	}

	public function stream_tell()
	{

		return $this->position;
	}

	public function stream_seek($offset , $whence = SEEK_SET)
	{

		switch ($whence) {
		case SEEK_SET:

			if ($offset < strlen( $this->mccontent ) && $offset >= 0) {
				$this->position = $offset;
				return true;
			}
			else
				return false;

			break;

		case SEEK_CUR:

			if ($offset >= 0) {
				$this->position += $offset;
				return true;
			}
			else
				return false;

			break;

		case SEEK_END:

			if (strlen( $this->mccontent ) + $offset >= 0) {
				$this->position = strlen( $this->mccontent ) + $offset;
				return true;
			}
			else
				return false;

			break;

		default:

			return false;
		}
	}

	public function stream_stat()
	{
		return $this->stat;
	}

	// ============================================
	public function mkdir($path , $mode , $options)
	{
		$path = trim(substr($path, 8));


		//echo "回调mkdirn";
		$path  = rtrim( $path  , '/' );

		$this->stat = $this->get_file_info( $path );
		$this->stat['ctime'] = $this->stat[10] = time();
		$this->stat['mode'] = $this->stat[2] = $this->dir_mode;

		//echo "生成新的stat数据" . print_r( $this->stat , 1 );

		memcache_set( $this->mc() , $path.'.meta' ,  serialize($this->stat)  );

		//echo "写入MC. key= " . $path.'.meta ' .  memcache_get( $this->mc , $path.'.meta'  );
		memcache_close( $this->mc );


		return true;
	}

	public function rename($path_from , $path_to)
	{
		$path_from = trim(substr($path_from, 8));
		$path_to = trim(substr($path_to, 8));


		memcache_set( $this->mc() , $path_to , memcache_get( $this->mc() , $path_from ) );
		memcache_set( $this->mc() , $path_to . '.meta' , memcache_get( $this->mc() , $path_from . '.meta' ) );
		memcache_delete( $this->mc() , $path_from );
		memcache_delete( $this->mc() , $path_from.'.meta' );
		clearstatcache( true );
		return true;
	}

	public function rmdir($path , $options)
	{
		$path = trim(substr($path, 8));


		$path  = rtrim( $path  , '/' );

		memcache_delete( $this->mc() , $path .'.meta'  );
		clearstatcache( true );
		return true;
	}

	public function unlink($path)
	{
		$path = trim(substr($path, 8));
		$path  = rtrim( $path  , '/' );

		memcache_delete( $this->mc() , $path );
		memcache_delete( $this->mc() , $path . '.meta' );
		clearstatcache( true );
		return true;
	}

	public function url_stat($path , $flags)
	{
		$path = trim(substr($path, 8));
		$path  = rtrim( $path  , '/' );

		if ( !$this->is_file_info_exists( $path ) ) {
			return false;
		} else {
			if ( $stat = memcache_get( $this->mc() , $path . '.meta' ) ) {
				$this->stat = unserialize($stat);
				if ( is_array($this->stat) ) {
					if ( $this->stat['mode'] == $this->dir_mode || $c = memcache_get( $this->mc(), $path ) ) {
						return $this->stat;
					} else {
						memcache_delete( $this->mc() , $path . '.meta' );
					}
				}
			}
			return false;
		}
	}






	// ============================================

	public function is_file_info_exists( $path )
	{
		//echo "获取MC数据 key= " .  $path.'.meta' ;
		$d = memcache_get( $this->mc() , $path . '.meta' );
		//echo "n返回数据为" . $d . "n";
		return $d;
	}

	public function get_file_info( $path )
	{
		if ( $stat = memcache_get( $this->mc() , $path . '.meta' ) )
			return $this->stat =  unserialize($stat);
		else $this->statinfo_init();
	}

	public function statinfo_init( $is_file = true )
	{
		$this->stat['dev'] = $this->stat[0] = 0x8002;
		$this->stat['ino'] = $this->stat[1] = mt_rand(10000, PHP_INT_MAX);

		if( $is_file )
			$this->stat['mode'] = $this->stat[2] = $this->file_mode;
		else
			$this->stat['mode'] = $this->stat[2] = $this->dir_mode;

		$this->stat['nlink'] = $this->stat[3] = 0;
		$this->stat['uid'] = $this->stat[4] = 0;
		$this->stat['gid'] = $this->stat[5] = 0;
		$this->stat['rdev'] = $this->stat[6] = 0;
		$this->stat['size'] = $this->stat[7] = 0;
		$this->stat['atime'] = $this->stat[8] = 0;
		$this->stat['mtime'] = $this->stat[9] = 0;
		$this->stat['ctime'] = $this->stat[10] = 0;
		$this->stat['blksize'] = $this->stat[11] = 0;
		$this->stat['blocks'] = $this->stat[12] = 0;

	}

	public function dir_closedir() {
		return false;
	}

	public function dir_opendir($path, $options) {
		return false;
	}

	public function dir_readdir() {
		return false;
	}

	public function dir_rewinddir() {
		return false;
	}

	public function stream_cast($cast_as) {
		return false;
	}

	public function stream_flush() {
		return false;
	}

	public function stream_lock($operation) {
		return false;
	}

	public function stream_set_option($option, $arg1, $arg2) {
		return false;
	}

}





/* BEGIN *******************  Storage Wrapper By Elmer Zhang At 16/Mar/2010 14:47 ****************/

class SaeStorageWrapper // implements WrapperInterface
{
	private $writen = true;

	public function __construct()
	{
		$this->stor = new SaeStorage();
	}

	public function stor() {
		if ( !isset( $this->stor ) ) $this->stor = new SaeStorage();
	}

	public function stream_open( $path , $mode , $options , &$opened_path)
	{
		$pathinfo = parse_url($path);
		$this->domain = $pathinfo['host'];
		$this->file = ltrim(strstr($path, $pathinfo['path']), '/\');
		$this->position = 0;
		$this->mode = $mode;
		$this->options = $options;

		// print_r("OPENtpath:{$path}tmode:{$mode}toption:{$option}topened_path:{$opened_path}n");

		if ( in_array( $this->mode, array( 'r', 'r+', 'rb' ) ) ) {
			if ( $this->fcontent = $this->stor->read($this->domain, $this->file) ) {
			} else {
				trigger_error("fopen({$path}): failed to read from Storage: No such domain or file.", E_USER_WARNING);
				return false;
			}
		} elseif ( in_array( $this->mode, array( 'a', 'a+', 'ab' ) ) ) {
			trigger_error("fopen({$path}): Sorry, saestor does not support appending", E_USER_WARNING);
			if ( $this->fcontent = $this->stor->read($this->domain, $this->file) ) {
			} else {
				trigger_error("fopen({$path}): failed to read from Storage: No such domain or file.", E_USER_WARNING);
				return false;
			}
		} elseif ( in_array( $this->mode, array( 'x', 'x+', 'xb' ) ) ) {
			if ( !$this->stor->getAttr($this->domain, $this->file) ) {
				$this->fcontent = '';
			} else {
				trigger_error("fopen({$path}): failed to create at Storage: File exists.", E_USER_WARNING);
				return false;
			}
		} elseif ( in_array( $this->mode, array( 'w', 'w+', 'wb' ) ) ) {
			$this->fcontent = '';
		} else {
			$this->fcontent = $this->stor->read($this->domain, $this->file);
		}

		return true;
	}

	public function stream_read($count)
	{
		if (in_array($this->mode, array('w', 'x', 'a', 'wb', 'xb', 'ab') ) ) {
			return false;
		}

		$ret = substr( $this->fcontent , $this->position, $count);
		$this->position += strlen($ret);

		return $ret;
	}

	public function stream_write($data)
	{
		if ( in_array( $this->mode, array( 'r', 'rb' ) ) ) {
			return false;
		}

		// print_r("WRITEtcontent:".strlen($this->fcontent)."tposition:".$this->position."tdata:".strlen($data)."n");

		$left = substr($this->fcontent, 0, $this->position);
		$right = substr($this->fcontent, $this->position + strlen($data));
		$this->fcontent = $left . $data . $right;

		//if ( $this->stor->write( $this->domain, $this->file, $this->fcontent ) ) {
		$this->position += strlen($data);
		if ( strlen( $data ) > 0 )
			$this->writen = false;

		return strlen( $data );
		//}
		//else return false;
	}

	public function stream_close()
	{
		if (!$this->writen) {
			$this->stor->write( $this->domain, $this->file, $this->fcontent );
			$this->writen = true;
		}
	}


	public function stream_eof()
	{

		return $this->position >= strlen( $this->fcontent  );
	}

	public function stream_tell()
	{

		return $this->position;
	}

	public function stream_seek($offset , $whence = SEEK_SET)
	{


		switch ($whence) {
		case SEEK_SET:

			if ($offset < strlen( $this->fcontent ) && $offset >= 0) {
				$this->position = $offset;
				return true;
			}
			else
				return false;

			break;

		case SEEK_CUR:

			if ($offset >= 0) {
				$this->position += $offset;
				return true;
			}
			else
				return false;

			break;

		case SEEK_END:

			if (strlen( $this->fcontent ) + $offset >= 0) {
				$this->position = strlen( $this->fcontent ) + $offset;
				return true;
			}
			else
				return false;

			break;

		default:

			return false;
		}
	}

	public function unlink($path)
	{
		self::stor();
		$pathinfo = parse_url($path);
		$this->domain = $pathinfo['host'];
		$this->file = ltrim(strstr($path, $pathinfo['path']), '/\');

		clearstatcache( true );
		return $this->stor->delete( $this->domain , $this->file );
	}

	public function stream_flush() {
		if (!$this->writen) {
			$this->stor->write( $this->domain, $this->file, $this->fcontent );
			$this->writen = true;
		}

		return $this->writen;
	}

	public function stream_stat() {
		return array();
	}

	public function url_stat($path, $flags) {
		self::stor();
		$pathinfo = parse_url($path);
		$this->domain = $pathinfo['host'];
		$this->file = ltrim(strstr($path, $pathinfo['path']), '/\');

		if ( $attr = $this->stor->getAttr( $this->domain , $this->file ) ) {
			$stat = array();
			$stat['dev'] = $stat[0] = 0x8001;
			$stat['ino'] = $stat[1] = 0;;
			$stat['mode'] = $stat[2] = 33279; //0100000 + 0777;
			$stat['nlink'] = $stat[3] = 0;
			$stat['uid'] = $stat[4] = 0;
			$stat['gid'] = $stat[5] = 0;
			$stat['rdev'] = $stat[6] = 0;
			$stat['size'] = $stat[7] = $attr['length'];
			$stat['atime'] = $stat[8] = 0;
			$stat['mtime'] = $stat[9] = $attr['datetime'];
			$stat['ctime'] = $stat[10] = $attr['datetime'];
			$stat['blksize'] = $stat[11] = 0;
			$stat['blocks'] = $stat[12] = 0;
			return $stat;
		} else {
			return false;
		}
	}

	public function dir_closedir() {
		return false;
	}

	public function dir_opendir($path, $options) {
		return false;
	}

	public function dir_readdir() {
		return false;
	}

	public function dir_rewinddir() {
		return false;
	}

	public function mkdir($path, $mode, $options) {
		return false;
	}

	public function rename($path_from, $path_to) {
		return false;
	}

	public function rmdir($path, $options) {
		return false;
	}

	public function stream_cast($cast_as) {
		return false;
	}

	public function stream_lock($operation) {
		return false;
	}

	public function stream_set_option($option, $arg1, $arg2) {
		return false;
	}

}


if ( in_array( "saestor", stream_get_wrappers() ) ) {
	stream_wrapper_unregister("saestor");
}
stream_wrapper_register( "saestor", "SaeStorageWrapper" )
	or die( "Failed to register protocol" );

/* END *********************  Storage Wrapper By Elmer Zhang At 16/Mar/2010 14:47 ****************/


/* BEGIN *******************  KVDB Wrapper By Elmer Zhang At 12/Dec/2011 12:37 ****************/

class SaeKVWrapper // implements WrapperInterface
{
	private $dir_mode = 16895 ; //040000 + 0222;
	private $file_mode = 33279 ; //0100000 + 0777;


	public function __construct() { }

	private function kv() {
		if ( !isset( $this->kv ) ) $this->kv = new SaeKV();
		$this->kv->init();
		return $this->kv;
	}

	private function open( $key ) {
		$value = $this->kv()->get( $key );
		if ( $value !== false && $this->unpack_stat(substr($value, 0, 20)) === true ) {
			$this->kvcontent = substr($value, 20);
			return true;
		} else {
			return false;
		}
	}

	private function save( $key ) {
		$this->stat['mtime'] = $this->stat[9] = time();
		if ( isset($this->kvcontent) ) {
			$this->stat['size'] = $this->stat[7] = strlen($this->kvcontent);
			$value = $this->pack_stat() . $this->kvcontent;
		} else {
			$this->stat['size'] = $this->stat[7] = 0;
			$value = $this->pack_stat();
		}
		return $this->kv()->set($key, $value);
	}

	private function unpack_stat( $str ) {
		$arr = unpack("L5", $str);

		// check if valid
		if ( $arr[1] < 10000 ) return false;
		if ( !in_array($arr[2], array( $this->dir_mode, $this->file_mode ) ) ) return false;
		if ( $arr[4] > time() ) return false;
		if ( $arr[5] > time() ) return false;

		$this->stat['dev'] = $this->stat[0] = 0x8003;
		$this->stat['ino'] = $this->stat[1] = $arr[1];
		$this->stat['mode'] = $this->stat[2] = $arr[2];
		$this->stat['nlink'] = $this->stat[3] = 0;
		$this->stat['uid'] = $this->stat[4] = 0;
		$this->stat['gid'] = $this->stat[5] = 0;
		$this->stat['rdev'] = $this->stat[6] = 0;
		$this->stat['size'] = $this->stat[7] = $arr[3];
		$this->stat['atime'] = $this->stat[8] = 0;
		$this->stat['mtime'] = $this->stat[9] = $arr[4];
		$this->stat['ctime'] = $this->stat[10] = $arr[5];
		$this->stat['blksize'] = $this->stat[11] = 0;
		$this->stat['blocks'] = $this->stat[12] = 0;

		return true;
	}

	private function pack_stat( ) {
		$str = pack("LLLLL", $this->stat['ino'], $this->stat['mode'], $this->stat['size'], $this->stat['ctime'], $this->stat['mtime']);
		return $str;
	}

	public function stream_open( $path , $mode , $options , &$opened_path)
	{
		$this->position = 0;
		$this->kvkey = rtrim(trim(substr(trim($path), 8)), '/');
		$this->mode = $mode;
		$this->options = $options;

		if ( in_array( $this->mode, array( 'r', 'r+', 'rb' ) ) ) {
			if ( $this->open( $this->kvkey ) === false ) {
				trigger_error("fopen({$path}): No such key in KVDB.", E_USER_WARNING);
				return false;
			}
		} elseif ( in_array( $this->mode, array( 'a', 'a+', 'ab' ) ) ) {
			if ( $this->open( $this->kvkey ) === true ) {
				$this->position = strlen($this->kvcontent);
			} else {
				$this->kvcontent = '';
				$this->statinfo_init();
			}
		} elseif ( in_array( $this->mode, array( 'x', 'x+', 'xb' ) ) ) {
			if ( $this->open( $this->kvkey ) === false ) {
				$this->kvcontent = '';
				$this->statinfo_init();
			} else {
				trigger_error("fopen({$path}): Key exists in KVDB.", E_USER_WARNING);
				return false;
			}
		} elseif ( in_array( $this->mode, array( 'w', 'w+', 'wb' ) ) ) {
			$this->kvcontent = '';
			$this->statinfo_init();
		} else {
			$this->open( $this->kvkey );
		}

		return true;
	}

	public function stream_read($count)
	{
		if (in_array($this->mode, array('w', 'x', 'a', 'wb', 'xb', 'ab') ) ) {
			return false;
		}

		$ret = substr( $this->kvcontent , $this->position, $count);
		$this->position += strlen($ret);

		return $ret;
	}

	public function stream_write($data)
	{
		if ( in_array( $this->mode, array( 'r', 'rb' ) ) ) {
			return false;
		}

		$left = substr($this->kvcontent, 0, $this->position);
		$right = substr($this->kvcontent, $this->position + strlen($data));
		$this->kvcontent = $left . $data . $right;

		if ( $this->save( $this->kvkey ) === true ) {
			$this->position += strlen($data);
			return strlen( $data );
		} else return false;
	}

	public function stream_close()
	{
		$this->save( $this->kvkey );
	}


	public function stream_eof()
	{

		return $this->position >= strlen( $this->kvcontent  );
	}

	public function stream_tell()
	{

		return $this->position;
	}

	public function stream_seek($offset , $whence = SEEK_SET)
	{

		switch ($whence) {
		case SEEK_SET:

			if ($offset < strlen( $this->kvcontent ) && $offset >= 0) {
				$this->position = $offset;
				return true;
			}
			else
				return false;

			break;

		case SEEK_CUR:

			if ($offset >= 0) {
				$this->position += $offset;
				return true;
			}
			else
				return false;

			break;

		case SEEK_END:

			if (strlen( $this->kvcontent ) + $offset >= 0) {
				$this->position = strlen( $this->kvcontent ) + $offset;
				return true;
			}
			else
				return false;

			break;

		default:

			return false;
		}
	}

	public function stream_stat()
	{
		return $this->stat;
	}

	// ============================================
	public function mkdir($path , $mode , $options)
	{
		$path = rtrim(trim(substr(trim($path), 8)), '/');

		if ( $this->open( $path ) === false ) {
			$this->statinfo_init( false );
			return $this->save( $path );
		} else {
			trigger_error("mkdir({$path}): Key exists in KVDB.", E_USER_WARNING);
			return false;
		}
	}

	public function rename($path_from , $path_to)
	{
		$path_from = rtrim(trim(substr(trim($path_from), 8)), '/');
		$path_to = rtrim(trim(substr(trim($path_to), 8)), '/');

		if ( $this->open( $path_from ) === true ) {
			clearstatcache( true );
			return $this->save( $path_to );
		} else {
			trigger_error("rename({$path_from}, {$path_to}): No such key in KVDB.", E_USER_WARNING);
			return false;
		}
	}

	public function rmdir($path , $options)
	{
		$path = rtrim(trim(substr(trim($path), 8)), '/');

		clearstatcache( true );
		return $this->kv()->delete($path);
	}

	public function unlink($path)
	{
		$path = rtrim(trim(substr(trim($path), 8)), '/');

		clearstatcache( true );
		return $this->kv()->delete($path);
	}

	public function url_stat($path , $flags)
	{
		$path = rtrim(trim(substr(trim($path), 8)), '/');

		if ( $this->open( $path ) !== false ) {
			return $this->stat;
		} else {
			return false;
		}
	}






	// ============================================

	private function statinfo_init( $is_file = true )
	{
		$this->stat['dev'] = $this->stat[0] = 0x8003;
		$this->stat['ino'] = $this->stat[1] = crc32(SAE_APPNAME . '/' . $this->kvkey);

		if( $is_file )
			$this->stat['mode'] = $this->stat[2] = $this->file_mode;
		else
			$this->stat['mode'] = $this->stat[2] = $this->dir_mode;

		$this->stat['nlink'] = $this->stat[3] = 0;
		$this->stat['uid'] = $this->stat[4] = 0;
		$this->stat['gid'] = $this->stat[5] = 0;
		$this->stat['rdev'] = $this->stat[6] = 0;
		$this->stat['size'] = $this->stat[7] = 0;
		$this->stat['atime'] = $this->stat[8] = 0;
		$this->stat['mtime'] = $this->stat[9] = time();
		$this->stat['ctime'] = $this->stat[10] = 0;
		$this->stat['blksize'] = $this->stat[11] = 0;
		$this->stat['blocks'] = $this->stat[12] = 0;

	}

	public function dir_closedir() {
		return false;
	}

	public function dir_opendir($path, $options) {
		return false;
	}

	public function dir_readdir() {
		return false;
	}

	public function dir_rewinddir() {
		return false;
	}

	public function stream_cast($cast_as) {
		return false;
	}

	public function stream_flush() {
		return false;
	}

	public function stream_lock($operation) {
		return false;
	}

	public function stream_set_option($option, $arg1, $arg2) {
		return false;
	}

}

if ( ! in_array("saekv", stream_get_wrappers()) )
	stream_wrapper_register("saekv", "SaeKVWrapper");

/* END *********************  KVDB Wrapper By Elmer Zhang At 12/Dec/2011 12:37 ****************/



/* START *********************  Supported for AppCookie By Elmer Zhang At 13/Jun/2010 15:49 ****************/
$appSettings = array();
if (isset($_SERVER['HTTP_APPCOOKIE']) && $_SERVER['HTTP_APPCOOKIE']) {
	$appCookie = trim($_SERVER['HTTP_APPCOOKIE']);
	$tmpSettings = array_filter(explode(';', $appCookie));
	if ($tmpSettings) {
		foreach($tmpSettings as $setting) {
			$tmp = explode('=', $setting);
			$appSettings[$tmp[0]] = $tmp[1];
		}
	}
}

if (isset($appSettings['xhprof']) && in_array(SAE_APPVERSION, explode(',', $appSettings['xhprof']))) {
	sae_xhprof_start();
	register_shutdown_function("sae_xhprof_end");
}

if (isset($appSettings['debug']) && in_array(SAE_APPVERSION, explode(',', $appSettings['debug']))) {
	sae_set_display_errors(true);
}

$srvcStr = substr($_SERVER['HTTP_APPSRVC'], 16);
$srrcCodes = array();
if ( $srvcStr ) {
	foreach( str_split( $srvcStr, 3 ) as $srvcCode ) {
		$srvcCodes[ substr($srvcCode, 0, 2) ] = intval($srvcCode[2]);
	}
}
if ( isset($srvcCodes['AH']) && $srvcCodes['AH'] === 0 && $appSettings['default_version'] == SAE_APPVERSION ) {
	define('SAE_CDN_DOMAIN', SAE_APPVERSION . '.' . SAE_APPNAME . '.sinacdn.com');
} else {
	define('SAE_CDN_DOMAIN', SAE_APPVERSION . '.' . SAE_APPNAME . '.sinaapp.com');
}
if ( isset($srvcCodes['AH']) && $srvcCodes['AH'] === 0) {
	define('SAE_CDN_ENABLED', true);
} else {
	define('SAE_CDN_ENABLED', false);
}

function sae_get_cdn_domain() {
	return SAE_CDN_DOMAIN;
}

function sae_cdn_enabled() {
	return SAE_CDN_ENABLED;
}

unset($srvcCode);
unset($srvcCodes);
unset($srvcStr);
unset($appSettings);
unset($appCookie);
unset($tmpSettings);
unset($tmp);

/* END *********************  Supported for AppCookie By Elmer Zhang At 13/Jun/2010 16:04 ****************/


34925

SAE预加载文件内容 没有评论

发表回复

您的电子邮箱地址不会被公开。 必填项已用*标注

此站点使用Akismet来减少垃圾评论。了解我们如何处理您的评论数据