import com.google.apphosting.api.ApiProxy.Environment; //导入依赖的package包/类
/**
 * Runs calls in a background thread so that the results will actually be asynchronous.
 *
 * @see com.google.appengine.tools.cloudstorage.RawGcsService#continueObjectCreationAsync(
 *        com.google.appengine.tools.cloudstorage.RawGcsService.RawGcsCreationToken,
 *        java.nio.ByteBuffer, long)
 */
@Override
public Future<RawGcsCreationToken> continueObjectCreationAsync(final RawGcsCreationToken token,
    final ByteBuffer chunk, long timeoutMillis) {
  try {
    ensureInitialized();
  } catch (IOException e) {
    throw new RuntimeException(e);
  }
  final Environment environment = ApiProxy.getCurrentEnvironment();
  return writePool.schedule(new Callable<RawGcsCreationToken>() {
    @Override
    public RawGcsCreationToken call() throws Exception {
      ApiProxy.setEnvironmentForCurrentThread(environment);
      return append(token, chunk);
    }
  }, 50, TimeUnit.MILLISECONDS);
}
 

import com.google.apphosting.api.ApiProxy.Environment; //导入依赖的package包/类
private void printGaeProperties(StringBuilder sb)
{
	sb.append("<h2>GAE Properties</h2>");
	Environment env = ApiProxy.getCurrentEnvironment();
	Iterator<Entry<String, Object>> iter = env.getAttributes().entrySet().iterator();
	sb.append("<table><tr><th>Name</th><th>Value</th></tr>");
	sb.append("<tr><td>").append("getAppId()").append("</td><td>").append(env.getAppId()).append("</td></tr>");
	sb.append("<tr><td>").append("getVersionId()").append("</td><td>").append(env.getVersionId()).append("</td></tr>");
	sb.append("<tr><td>").append("getModuleId()").append("</td><td>").append(env.getModuleId()).append("</td></tr>");
	sb.append("<tr><td>").append("getAuthDomain()").append("</td><td>").append(env.getAuthDomain()).append("</td></tr>");
	sb.append("<tr><td>").append("getEmail()").append("</td><td>").append(env.getEmail()).append("</td></tr>");

	UserService userService = UserServiceFactory.getUserService();
	boolean userLoggedIn = userService.isUserLoggedIn();
	sb.append("<tr><td>").append("isUserLoggedIn()").append("</td><td>").append(userLoggedIn).append("</td></tr>");
	if (userLoggedIn)
	{
		String logoutUrl = "Click <a href=\"" + userService.createLogoutURL(request.getRequestURI()) + "\">here</a> to Logout";
		sb.append("<tr><td>").append("createLogoutURL()").append("</td><td>").append(logoutUrl).append("</td></tr>");
	}
	else
	{
		String loginUrl = "Click <a href=\"" + userService.createLoginURL(request.getRequestURI()) + "\">here</a> to Login";
		sb.append("<tr><td>").append("createLoginURL()").append("</td><td>").append(loginUrl).append("</td></tr>");
	}

	while (iter.hasNext())
	{
		Entry<String, Object> entry = iter.next();
		String paramName = entry.getKey();
		String paramValue = entry.getValue().toString();
		sb.append("<tr><td>").append(paramName).append("</td><td>").append(paramValue).append("</td></tr>");
	}
	sb.append("</table>");
}
 

import com.google.apphosting.api.ApiProxy.Environment; //导入依赖的package包/类
public static String getInfo() {
  String version = SystemProperty.applicationVersion.get();
  String majorVersion = version.substring(0, version.indexOf('.'));
  Environment env = ApiProxy.getCurrentEnvironment();
  String hostname =
      "" + env.getAttributes().get("com.google.appengine.runtime.default_version_hostname");
  String infostring = "version: " + majorVersion + " and hostname: " + hostname;
  return infostring;
}
 

import com.google.apphosting.api.ApiProxy.Environment; //导入依赖的package包/类
public Future<byte[]> makeAsyncCall(
    Environment environment,
    String packageName,
    String methodName,
    byte[] request,
    ApiProxy.ApiConfig apiConfig) {
  return oldDelegate.makeAsyncCall(environment, packageName, methodName, request, apiConfig);
}
 

import com.google.apphosting.api.ApiProxy.Environment; //导入依赖的package包/类
public void doGet(HttpServletRequest req, HttpServletResponse resp) throws IOException {
  resp.setContentType("text/plain");
  Environment env = ApiProxy.getCurrentEnvironment();

  for (Entry entry : env.getAttributes().entrySet()) {
    resp.getWriter().println(entry.getKey() + " => " + entry.getValue());
  }
}
 

import com.google.apphosting.api.ApiProxy.Environment; //导入依赖的package包/类
/**
 * Returns the thread local environment if it is a VmApiProxyEnvironment.
 *
 * @return The ThreadLocal environment or null if no VmApiProxyEnvironment is set on this thread.
 */
private VmApiProxyEnvironment getThreadLocalEnvironment() {
  Environment env = ApiProxy.getCurrentEnvironment();
  if (env instanceof VmApiProxyEnvironment) {
    return (VmApiProxyEnvironment) env;
  }
  return null;
}
 

import com.google.apphosting.api.ApiProxy.Environment; //导入依赖的package包/类
/**
 * Create a new VmRequestThreadFactory.
 *
 * @param requestEnvironment The request environment to install on each thread.
 */
public VmRequestThreadFactory(Environment requestEnvironment) {
  this.mutex = new Object();
  this.requestEnvironment = requestEnvironment;
  this.createdThreads = Lists.newLinkedList();
  this.allowNewRequestThreadCreation = true;
}
 

import com.google.apphosting.api.ApiProxy.Environment; //导入依赖的package包/类
/**
 * Returns the thread local environment if it is a VmApiProxyEnvironment.
 *
 * @return The ThreadLocal environment or null if no VmApiProxyEnvironment is set.
 */
private VmApiProxyEnvironment getThreadLocalEnvironment() {
  Environment env = ApiProxy.getCurrentEnvironment();
  if (env instanceof VmApiProxyEnvironment) {
    return (VmApiProxyEnvironment) env;
  }
  return null;
}
 

import com.google.apphosting.api.ApiProxy.Environment; //导入依赖的package包/类
@Override
protected void doStart() throws Exception {
    this.helper = createHelper();
    this.environment = ApiProxy.getCurrentEnvironment();
    getServletContext().setAttribute(API_PROXY_LOCAL, ApiProxy.getDelegate());
    getServletContext().setAttribute(APPENGINE_WEB_XML, readAppengineWebXml());
    getServletContext().setAttribute(WEB_XML, readWebXml());
    SystemProperty.environment.set(SystemProperty.Environment.Value.Development);
    configureUserRealmAppengineHelper();
    super.doStart();
}
 

import com.google.apphosting.api.ApiProxy.Environment; //导入依赖的package包/类
public static String getBaseUrlWithoutSchema() {
	if (SystemProperty.environment.value()!=SystemProperty.Environment.Value.Development) {
		String appId = AppHelper.getAppId();
		return appId+".appspot.com";
	} else {
		return "127.0.0.1:8888";
	}
}
 

import com.google.apphosting.api.ApiProxy.Environment; //导入依赖的package包/类
public static String getAppId() {
	Environment environment = ApiProxy.getCurrentEnvironment();
	
	String appFullId = environment.getAppId();
	int tildeIndex = appFullId.indexOf("~");
	
	return tildeIndex>-1 ? appFullId.substring(tildeIndex+1) : appFullId;		
}
 

import com.google.apphosting.api.ApiProxy.Environment; //导入依赖的package包/类
public List<Thread> getRequestThreads(Environment environmnent) {
  return oldDelegate.getRequestThreads(environmnent);
}
 

import com.google.apphosting.api.ApiProxy.Environment; //导入依赖的package包/类
public byte[] makeSyncCall(
    Environment environment, String packageName, String methodName, byte[] request)
    throws ApiProxyException {
  return oldDelegate.makeSyncCall(environment, packageName, methodName, request);
}
 

import com.google.apphosting.api.ApiProxy.Environment; //导入依赖的package包/类
public void log(Environment environment, LogRecord record) {
  records.add(record);
  oldDelegate.log(environment, record);
}
 

import com.google.apphosting.api.ApiProxy.Environment; //导入依赖的package包/类
public void flushLogs(Environment environment) {
  oldDelegate.flushLogs(environment);
}