jni_vfs.c

resinweb服务器源文件

/*
 * Copyright (c) 1999-2000 Caucho Technology.  All rights reserved.
 *
 * Caucho Technology permits redistribution, modification and use
 * of this file in source and binary form ("the Software") under the
 * Caucho Public License ("the License").  In particular, the following
 * conditions must be met:
 *
 * 1. Each copy or derived work of the Software must preserve the copyright
 *    notice and this notice unmodified.
 *
 * 2. Redistributions of the Software in source or binary form must include 
 *    an unmodified copy of the License, normally in a plain ASCII text
 *
 * 3. The names "Resin" or "Caucho" are trademarks of Caucho Technology and
 *    may not be used to endorse products derived from this software.
 *    "Resin" or "Caucho" may not appear in the names of products derived
 *    from this software.
 *
 * 4. Caucho Technology requests that attribution be given to Resin
 *    in any manner possible.  We suggest using the "Resin Powered"
 *    button or creating a "powered by Resin(tm)" link to
 *    http://www.caucho.com for each page served by Resin.
 *
 * This Software is provided "AS IS," without a warranty of any kind. 
 * ALL EXPRESS OR IMPLIED REPRESENTATIONS AND WARRANTIES, INCLUDING ANY
 * IMPLIED WARRANTY OF MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE
 * OR NON-INFRINGEMENT, ARE HEREBY EXCLUDED.

 * CAUCHO TECHNOLOGY AND ITS LICENSORS SHALL NOT BE LIABLE FOR ANY DAMAGES
 * SUFFERED BY LICENSEE OR ANY THIRD PARTY AS A RESULT OF USING OR
 * DISTRIBUTING SOFTWARE. IN NO EVENT WILL Caucho OR ITS LICENSORS BE LIABLE
 * FOR ANY LOST REVENUE, PROFIT OR DATA, OR FOR DIRECT, INDIRECT, SPECIAL,
 * CONSEQUENTIAL, INCIDENTAL OR PUNITIVE DAMAGES, HOWEVER CAUSED AND
 * REGARDLESS OF THE THEORY OF LIABILITY, ARISING OUT OF THE USE OF OR
 * INABILITY TO USE SOFTWARE, EVEN IF HE HAS BEEN ADVISED OF THE POSSIBILITY
 * OF SUCH DAMAGES.      
 */

#include <sys/types.h>
#include <sys/socket.h>
#include <sys/stat.h>
#include <netinet/in.h>
#include <fcntl.h>
#include <unistd.h>
#include <stdio.h>
#include <stdlib.h>
#include <stdarg.h>
#include <string.h>
#include <dirent.h>
// probably system-dependent
#include <dlfcn.h>
#include <jni.h>

#include "cse.h"
#include "proxy.h"

static int
Java_com_caucho_server_http_JniStream_readNative(JNIEnv *env,
                                                 jobject obj,
                                                 jint fd,
                                                 jbyteArray buf,
                                                 jint offset,
                                                 jint length)
{
  request_t *req = (request_t *) fd;
  int sublen;
  char *jbuf;
  jboolean is_copy;

  if (req->content_offset >= req->content_length)
    return -1;

  sublen = req->length - req->offset;
  if (sublen <= 0) {
    sublen = request_fill(req);
    
    if (sublen <= 0)
      return -1;
  }

  if (sublen > req->content_length - req->content_offset)
    sublen = req->content_length - req->content_offset;

  if (sublen > length)
    sublen = length;

  jbuf = (*env)->GetByteArrayElements(env, buf, &is_copy);

  memcpy(jbuf + offset, req->buffer + req->offset, sublen);

  (*env)->ReleaseByteArrayElements(env, buf, jbuf, JNI_ABORT);

  req->content_offset += sublen;
  req->offset += sublen;

  return sublen;
}

static void
Java_com_caucho_server_http_JniStream_writeNative(JNIEnv *env,
                                                  jobject obj,
                                                  jint fd,
                                                  jbyteArray buf,
                                                  jint offset,
                                                  jint length)
{
  request_t *req = (request_t *) fd;
  response_t *res;
  char *cbuf;
  char buffer[8192];
  int buffer_offset;
  jboolean is_copy;
  int sublen;
  
  buffer_offset = 0;
  
  res = req->response;

  while (length > 0) {
    if (length < 8192)
      sublen = length;
    else
      sublen = 8192;
    
    cbuf = (*env)->GetByteArrayElements(env, buf, &is_copy);

    memcpy(buffer, cbuf + offset, sublen);

    (*env)->ReleaseByteArrayElements(env, buf, cbuf, JNI_ABORT);

    if (! res->after_headers) {
      buffer_offset = response_send_headers(res, buffer, sublen);
      res->after_headers = 1;
    }

    response_write_chunk(res, buffer + buffer_offset, sublen - buffer_offset);

    length -= sublen;
  }
}

void
jni_vfs_init(JNIEnv *env)
{
  JNINativeMethod methods[2];
  jclass jniClass;

  methods[0].name = "writeNative";
  methods[0].signature = "(I[BII)V";
  methods[0].fnPtr = Java_com_caucho_server_http_JniStream_writeNative;

  methods[1].name = "readNative";
  methods[1].signature = "(I[BII)I";
  methods[1].fnPtr = Java_com_caucho_server_http_JniStream_readNative;
  
  jniClass = (*env)->FindClass(env, "com/caucho/server/http/JniStream");
  if (jniClass == 0) {
    fprintf(stderr, "Class not found: com.caucho.server.http.JniStream\n");
    exit(1);
  }

  (*env)->RegisterNatives(env, jniClass, methods, 2);
}