Gecko [ lorencats.com ]

Name	Size	Permission
event	[ DIR ]	drwxr-xr-x
tool	[ DIR ]	drwxr-xr-x
Block.java	3.68 KB	-rw-r--r--
Color.java	329 B	-rw-r--r--
Connection.java	2.95 KB	-rw-r--r--
EventFactory.java	1 KB	-rw-r--r--
Item.java	2.41 KB	-rw-r--r--
Log.java	330 B	-rw-r--r--
Minecraft.java	7.26 KB	-rw-r--r--
Vec.java	2.13 KB	-rw-r--r--
VecFloat.java	1.84 KB	-rw-r--r--
package.html	36 B	-rw-r--r--

Code Editor : Connection.java

package pi;

import java.io.BufferedReader;
import java.io.BufferedWriter;
import java.io.Closeable;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.OutputStreamWriter;
import java.net.Socket;
import java.util.logging.Level;
import java.util.logging.Logger;

/**
 * Connection to a Minecraft Pi game
 *
 * @author Daniel Frisk, twitter:danfrisk
 */
class Connection {

Socket socket;
    BufferedWriter out;
    BufferedReader in;
    boolean autoFlush = true;

Connection(String host, int port) {
        Log.info("Connecting to " + host + ":" + port);
        if (host != null) {
            try {
                this.socket = new Socket(host, port);
                socket.setTcpNoDelay(true);
                socket.setKeepAlive(true);
                socket.setTrafficClass(0x10);
                this.in = new BufferedReader(new InputStreamReader(socket.getInputStream()));
                this.out = new BufferedWriter(new OutputStreamWriter(socket.getOutputStream()));
            } catch (IOException e) {
                throw new ConnectionException("Couldn't connect to Minecraft, is it running?");
            }
        }
        Log.info("Connected");
    }

void send(Object... parts) {
        try {
            drain(in);
            for (int i = 0; i < parts.length; i++) {
                out.write(parts[i].toString());
                if (i == 0) {
                    out.write('(');
                } else if (i < parts.length - 1) {
                    out.write(',');
                }
            }
            out.write(")\n");
            if (autoFlush) {
                flush();
            }
        } catch (IOException e) {
            throw new ConnectionException(e);
        }
    }

void flush() {
        try {
            out.flush();
        } catch (IOException e) {
            throw new ConnectionException(e);
        }
    }

void drain(BufferedReader in) throws IOException {
        while (in.ready()) {
            int c = in.read();
            System.err.print((char) c);
        }
    }

String receive() {
        try {
            return in.readLine();
        } catch (IOException e) {
            throw new ConnectionException(e);
        }
    }

void close() {
        close(in, out);
        try {
            socket.close();
        } catch (IOException _) {
        }
    }

void close(Closeable... cs) {
        for (Closeable c : cs) {
            try {
                if (c != null) {
                    c.close();
                }
            } catch (IOException _) {
            }
        }
    }

void autoFlush(boolean flush) {
        this.autoFlush = flush;
        if (flush) {
            flush();
        }
    }

/**
     *
     */
    static class ConnectionException extends RuntimeException {

ConnectionException(String message) {
            super(message);
        }

ConnectionException(Throwable cause) {
            super(cause);
        }
    }
}

${this.title}

Code Editor : Connection.java