mirror of
https://github.com/mozilla/gecko-dev.git
synced 2024-11-05 08:35:26 +00:00
180 lines
3.6 KiB
C++
180 lines
3.6 KiB
C++
/* -*- Mode: C++; tab-width: 4; indent-tabs-mode: nil; c-basic-offset: 4 -*-
|
|
* The contents of this file are subject to the Netscape Public
|
|
* License Version 1.1 (the "License"); you may not use this file
|
|
* except in compliance with the License. You may obtain a copy of
|
|
* the License at http://www.mozilla.org/NPL/
|
|
*
|
|
* Software distributed under the License is distributed on an "AS
|
|
* IS" basis, WITHOUT WARRANTY OF ANY KIND, either express or
|
|
* implied. See the License for the specific language governing
|
|
* rights and limitations under the License.
|
|
*
|
|
* The Original Code is Mozilla Communicator client code, released
|
|
* March 31, 1998.
|
|
*
|
|
* The Initial Developer of the Original Code is Netscape
|
|
* Communications Corporation. Portions created by Netscape are
|
|
* Copyright (C) 1998-1999 Netscape Communications Corporation. All
|
|
* Rights Reserved.
|
|
*
|
|
*/
|
|
|
|
#ifndef InputStreamShim_h
|
|
#define InputStreamShim_h
|
|
|
|
#include "nsIInputStream.h"
|
|
|
|
#include <jni.h>
|
|
|
|
class InputStreamShimActionEvent;
|
|
struct PRLock;
|
|
|
|
class InputStreamShim : public nsIInputStream
|
|
{
|
|
public:
|
|
InputStreamShim(jobject yourJavaStreamRef,
|
|
PRInt32 contentLength);
|
|
virtual ~InputStreamShim();
|
|
|
|
/**
|
|
|
|
* Called on NativeEventThread from
|
|
* wsLoadFromStreamEvent::handleEvent()
|
|
|
|
* When called, this method will read as up to mContentLength data
|
|
* from the Java input stream. Each read will update the number of
|
|
* bytes available on the stream.
|
|
|
|
* if the ivar mDoClose's value is PR_TRUE, the java
|
|
* InputStream should be closed.
|
|
|
|
* @return NS_ERROR_NOT_AVAILABLE when there is no more data.
|
|
|
|
* @return NS_OK when there is more data
|
|
|
|
* @return NS_ERROR_FAILURE when there has been an unrecoverable
|
|
* error
|
|
|
|
|
|
*/
|
|
|
|
nsresult doReadFromJava(void);
|
|
PRInt32 getContentLength() const { return mContentLength; };
|
|
|
|
private:
|
|
|
|
// called from doReadFromJava. These methods assume they execute
|
|
// within PR_Lock(mLock)
|
|
|
|
nsresult doAvailable(void);
|
|
nsresult doRead(void);
|
|
nsresult doClose(void);
|
|
|
|
private:
|
|
// nsISupports methods
|
|
NS_DECL_ISUPPORTS
|
|
|
|
// nsIInputStream methods
|
|
NS_DECL_NSIINPUTSTREAM
|
|
|
|
protected:
|
|
|
|
/**
|
|
|
|
* A global jobject reference for the java InputStream
|
|
|
|
* MUST be ::util_deleteGlobalRef'd in destructor.
|
|
|
|
*/
|
|
|
|
jobject mJavaStream;
|
|
|
|
/**
|
|
|
|
* the number of bytes we expect to read.
|
|
|
|
*/
|
|
|
|
PRInt32 mContentLength;
|
|
|
|
|
|
/**
|
|
|
|
* a dynamically allocated buffer, written by NativeEventThread
|
|
* calling out doReadFromJava(), read by Mozilla calling our Read().
|
|
|
|
* deleting this buffer signifies the java InputStream should be
|
|
* closed.
|
|
|
|
* MUST be deallocated in the destructor.
|
|
|
|
*/
|
|
|
|
char *mBuffer;
|
|
|
|
/**
|
|
|
|
* the length of the buffer
|
|
|
|
*/
|
|
|
|
PRUint32 mBufferLength;
|
|
|
|
|
|
/**
|
|
|
|
* Running sum of the total number of bytes read so far from java.
|
|
|
|
*/
|
|
|
|
PRUint32 mCountFromJava;
|
|
|
|
/**
|
|
|
|
* Running sum of the total number of bytes read so far by mozilla
|
|
|
|
*/
|
|
|
|
PRUint32 mCountFromMozilla;
|
|
|
|
/**
|
|
|
|
* The number of bytes available on the java InputStream
|
|
|
|
*/
|
|
|
|
PRUint32 mAvailable;
|
|
|
|
/**
|
|
|
|
* The number of bytes available in the buffer that haven't yet been
|
|
* read from Mozilla.
|
|
|
|
*/
|
|
|
|
PRUint32 mAvailableForMozilla;
|
|
|
|
/**
|
|
|
|
* The number of bytes read on the last read from the java
|
|
* InputStream
|
|
|
|
*/
|
|
|
|
PRInt32 mNumRead;
|
|
|
|
PRBool mDoClose;
|
|
|
|
PRBool mDidClose;
|
|
|
|
/**
|
|
|
|
* Provides mutex
|
|
|
|
*/
|
|
|
|
PRLock *mLock;
|
|
};
|
|
|
|
#endif // InputStreamShim_h
|