inital plugin from webtools project

[phpeclipse.git] / archive / net.sourceforge.phpeclipse.monitor.core / src / net / sourceforge / phpdt / monitor / core / internal / DefaultThread.java

diff --git a/archive/net.sourceforge.phpeclipse.monitor.core/src/net/sourceforge/phpdt/monitor/core/internal/DefaultThread.java b/archive/net.sourceforge.phpeclipse.monitor.core/src/net/sourceforge/phpdt/monitor/core/internal/DefaultThread.java
new file mode 100644 (file)
index 0000000..bd8c2a3
--- /dev/null
+++ b/archive/net.sourceforge.phpeclipse.monitor.core/src/net/sourceforge/phpdt/monitor/core/internal/DefaultThread.java
@@ -0,0 +1,73 @@
+/**********************************************************************
+ * Copyright (c) 2003 IBM Corporation and others.
+ * All rights reserved. This program and the accompanying materials
+ * are made available under the terms of the Common Public License v1.0
+ * which accompanies this distribution, and is available at
+ * http://www.eclipse.org/legal/cpl-v10.html
+ *
+ * Contributors:
+ *    IBM - Initial API and implementation
+ **********************************************************************/
+package net.sourceforge.phpdt.monitor.core.internal;
+
+import java.io.*;
+/**
+ * Monitor server I/O thread.
+ */
+public class DefaultThread extends Thread {
+       private static final int BUFFER = 2048;
+       protected InputStream in;
+       protected OutputStream out;
+       protected boolean isRequest;
+       
+       protected Connection conn;
+       protected Request request;
+
+       /**
+        * MonitorThread constructor comment.
+        */
+       public DefaultThread(Connection conn, Request request, InputStream in, OutputStream out, boolean isRequest) {
+               super();
+               this.conn = conn;
+               this.request = request;
+               this.in = in;
+               this.out = out;
+               this.isRequest = isRequest;
+               setPriority(Thread.NORM_PRIORITY + 1);
+               setDaemon(true);
+       }
+
+       /**
+        * Listen for input, save it, and pass to the output stream.
+        */
+       public void run() {
+               try {
+                       byte[] b = new byte[BUFFER];
+                       int n = in.read(b);
+                       while (n > 0) {
+                               out.write(b, 0, n);
+                               if (b != null && n > 0) {
+                                       byte[] x = null;
+                                       if (n == BUFFER)
+                                               x = b;
+                                       else {
+                                               x = new byte[n];
+                                               System.arraycopy(b, 0, x, 0, n);
+                                       }
+                                       if (isRequest)
+                                               request.addToRequest(x);
+                                       else
+                                               request.addToResponse(x);
+                               }
+                               n = in.read(b);
+                               Thread.yield();
+                       }
+                       out.flush();
+               } catch (IOException e) {
+               } finally {
+                       request.fireChangedEvent();
+                       if (!isRequest)
+                               conn.close();
+               }
+       }
+}
\ No newline at end of file