유리상자 속 이야기

package com;


public class FolderWatcher implements Runnable {
	// win32
	private final static int WAIT_OBJECT_0 = 0x00000000;
	private final static int WAIT_TIMEOUT = 258;
	
	// Filter
	public final static int FILTER_CHANGE_FILE_NAME    = 0x00000001;
	public final static int FILTER_CHANGE_DIR_NAME	   = 0x00000002;
	public final static int FILTER_CHANGE_ATTRIBUTES   = 0x00000004;
	public final static int FILTER_CHANGE_SIZE         = 0x00000008;
	public final static int FILTER_CHANGE_LAST_WRITE   = 0x00000010;
	public final static int FILTER_CHANGE_SECURITY     = 0x00000100;
	
	// win32 api
	private native int FindFirstChangeNotification(String folder, boolean watchSubtree, int filter);
	private native boolean FindNextChangeNotification(int hChangeHandle);
	private native boolean FindCloseChangeNotification(int hChangeHandle);
	private native int WaitForMultipleObjects(int nCount, int handle, boolean waitAll, int milliSeconds);
	
	// jni
	static { System.loadLibrary("FolderWatcher"); }
	
	// listener
	private IFolderChangeListener listener = null;
	
	private boolean isWatching = false;
	private int handle = 0;
	private volatile Object lockObj = new Object();
	
	private String folderPath = "";
	private boolean watchSubfolder = false;
	private int filter;
	
	private Thread watchThread = null;
	
	
	//============
	// 생성자
	//============
	public FolderWatcher(IFolderChangeListener listener) {
		this.listener = listener;
	}
	
	
	
	public boolean start(String folderPath, boolean watchSubfolder, int filter) {
		synchronized (this.lockObj) {
			// 이미 실행중인 경우
			if(isWatching == true) { return true; }
			
			// setting
			this.folderPath = folderPath;
			this.watchSubfolder = watchSubfolder;
			this.filter = filter;
			
			// Thread 실행
			this.watchThread = new Thread(this);
			this.watchThread.setDaemon(true);
			this.watchThread.start();
			
			return true;
		}
	}
	
	
	@Override
	public void run(){
		this.isWatching = true;
		
		handle = FindFirstChangeNotification(this.folderPath, this.watchSubfolder, this.filter);
		if(handle == -1) {
			System.out.println("FindFirstChangeNotification function failed.");
			return;
		}
		if(handle == 0) {
			System.out.println("ERROR: FindFirstChangeNotification function failed.");
			return;
		}
		
		while(this.isWatching == true) {
			System.out.println("Waiting for notification...");
			int waitStatus = WaitForMultipleObjects(1, handle, false, 0xFFFFFFFF);
			
			switch(waitStatus)
			{
			case WAIT_OBJECT_0:
				if(FindNextChangeNotification(handle) == true) {
					callback();
				}
				break;
			case WAIT_TIMEOUT:
				System.out.println("No changes in the timeout period.");
				break;
			default:
				System.out.println("ERROR: Unhandled dwWaitStatus.");
				break;
			}
		}
	}
	
	
	
	public boolean stop() {
		synchronized (this.lockObj) {
			if(this.isWatching == false) { return true; }
			//stopWatch();
			FindCloseChangeNotification(this.handle);
			this.isWatching = false;
			this.watchThread.interrupt();
			
			return true;
		}
	}
	
	
	private void callback() {
		if(this.listener != null) {
			this.listener.folderChanged(this, this.folderPath);
		}
	}
} 

#include "FolderWatcher.h"
#include <windows.h>

/*
 * Class:     pCloud_win32_FolderWatcher
 * Method:    FindFirstChangeNotification
 * Signature: (Ljava/lang/String;ZI)I
 */
JNIEXPORT jint JNICALL Java_pCloud_win32_FolderWatcher_FindFirstChangeNotification
  (JNIEnv * env, jobject obj, jstring path, jboolean watchSubtree, jint filter)
{
	jchar* new_path = (*env)->GetStringChars(env, path, NULL);
	OutputDebugString((LPCWSTR)new_path);

	return (jint)FindFirstChangeNotification((LPCWSTR)new_path, (BOOL)watchSubtree, filter);
}

/*
 * Class:     pCloud_win32_FolderWatcher
 * Method:    FindNextChangeNotification
 * Signature: (I)I
 */
JNIEXPORT jboolean JNICALL Java_pCloud_win32_FolderWatcher_FindNextChangeNotification
  (JNIEnv * env, jobject obj, jint changeHandle)
{
	return FindNextChangeNotification((HANDLE)changeHandle);
}

/*
 * Class:     pCloud_win32_FolderWatcher
 * Method:    FindCloseChangeNotification
 * Signature: (I)I
 */
JNIEXPORT jboolean JNICALL Java_pCloud_win32_FolderWatcher_FindCloseChangeNotification
  (JNIEnv * env, jobject obj, jint changeHandle)
{
	return FindCloseChangeNotification((HANDLE)changeHandle);
}

/*
 * Class:     pCloud_win32_FolderWatcher
 * Method:    WaitForMultipleObjects
 * Signature: (IIZI)I
 */
JNIEXPORT jint JNICALL Java_pCloud_win32_FolderWatcher_WaitForMultipleObjects
  (JNIEnv * env, jobject obj, jint count, jint changeHandle, jboolean waitAll, jint milliSeconds)
{
	HANDLE handle = (HANDLE)changeHandle;
	return WaitForMultipleObjects(1, &handle, (BOOL)waitAll, (DWORD)milliSeconds);

}