diff options
| author | Martin Lucina <mato@kotelna.sk> | 2010-03-11 20:12:55 +0100 | 
|---|---|---|
| committer | Martin Lucina <mato@kotelna.sk> | 2010-03-11 20:12:55 +0100 | 
| commit | 90944759b66771bbe399922eecedc5095fa2a509 (patch) | |
| tree | 18ccec0d87f87082a023fa8bd77dae7c0010bb5d /bindings/java/org | |
| parent | 9fda070e4d66d538e3c709c6cb8934cbf4442c29 (diff) | |
Removed Java binding from core distribution
Diffstat (limited to 'bindings/java/org')
| -rwxr-xr-x | bindings/java/org/zmq/Context.java | 58 | ||||
| -rwxr-xr-x | bindings/java/org/zmq/Poller.java | 135 | ||||
| -rw-r--r-- | bindings/java/org/zmq/Socket.java | 134 | 
3 files changed, 0 insertions, 327 deletions
| diff --git a/bindings/java/org/zmq/Context.java b/bindings/java/org/zmq/Context.java deleted file mode 100755 index a727749..0000000 --- a/bindings/java/org/zmq/Context.java +++ /dev/null @@ -1,58 +0,0 @@ -/* -    Copyright (c) 2007-2010 iMatix Corporation - -    This file is part of 0MQ. - -    0MQ is free software; you can redistribute it and/or modify it under -    the terms of the Lesser GNU General Public License as published by -    the Free Software Foundation; either version 3 of the License, or -    (at your option) any later version. - -    0MQ is distributed in the hope that it will be useful, -    but WITHOUT ANY WARRANTY; without even the implied warranty of -    MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the -    Lesser GNU General Public License for more details. - -    You should have received a copy of the Lesser GNU General Public License -    along with this program.  If not, see <http://www.gnu.org/licenses/>. -*/ - -package org.zmq; - -public class Context { -    static { -        System.loadLibrary("jzmq"); -    } - -    public static final int POLL = 1; - -    /** -     * Class constructor. -     * -     * @param appThreads maximum number of application threads. -     * @param ioThreads size of the threads pool to handle I/O operations. -     */ -    public Context (int appThreads, int ioThreads, int flags) { -        construct (appThreads, ioThreads, flags); -    } - -    /** Initialize the JNI interface */ -    protected native void construct (int appThreads, int ioThreads, int flags); - -    /** Free all resources used by JNI interface. */ -    protected native void finalize (); - -    /** -     * Get the underlying context handle. -     * This is private because it is only accessed from JNI, where -     * Java access controls are ignored. -     * -     * @return the internal 0MQ context handle. -     */ -    private long getContextHandle () { -        return contextHandle; -    } - -    /** Opaque data used by JNI driver. */ -    private long contextHandle; -} diff --git a/bindings/java/org/zmq/Poller.java b/bindings/java/org/zmq/Poller.java deleted file mode 100755 index dd168b2..0000000 --- a/bindings/java/org/zmq/Poller.java +++ /dev/null @@ -1,135 +0,0 @@ -/* -    Copyright (c) 2007-2010 iMatix Corporation - -    This file is part of 0MQ. - -    0MQ is free software; you can redistribute it and/or modify it under -    the terms of the Lesser GNU General Public License as published by -    the Free Software Foundation; either version 3 of the License, or -    (at your option) any later version. - -    0MQ is distributed in the hope that it will be useful, -    but WITHOUT ANY WARRANTY; without even the implied warranty of -    MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the -    Lesser GNU General Public License for more details. - -    You should have received a copy of the Lesser GNU General Public License -    along with this program.  If not, see <http://www.gnu.org/licenses/>. -*/ - -package org.zmq; - -public class Poller { -    static { -        System.loadLibrary("jzmq"); -    } - -    public static final int POLLIN = 1; -    public static final int POLLOUT = 2; -    public static final int POLLERR = 4; - -    /** -     * Class constructor. -     * -     * @param context a 0MQ context previously created. -     */ -    public Poller (Context context, int size) { -        this.context = context; -        this.size = size; -        this.next = 0; - -        this.socket = new Socket[size]; -        this.event = new short[size]; -        this.revent = new short[size]; - -        for (int i = 0; i < size; ++i) { -            this.event[i] = (POLLIN | POLLOUT | POLLERR); -        } -    } - -    public int register (Socket socket) { -        if (next >= size) -            return -1; -        this.socket[next] = socket; -        return next++; -    } -     -    public long getTimeout () { -        return this.timeout; -    } -     -    public void setTimeout (long timeout) { -        this.timeout = timeout; -    } - -    public int getSize () { -        return this.size; -    } - -    public int getNext () { -        return this.next; -    } - -    /** -     * Issue a poll call. -     * @return how many objects where signalled by poll(). -     */ -    public long poll () { -        if (size <= 0 || next <= 0) -            return 0; - -        for (int i = 0; i < next; ++i) { -            revent[i] = 0; -        } - -        return run_poll(next, socket, event, revent, timeout); -    } - -    public boolean pollin(int index) { -        return poll_mask(index, POLLIN); -    } - -    public boolean pollout(int index) { -        return poll_mask(index, POLLOUT); -    } - -    public boolean pollerr(int index) { -        return poll_mask(index, POLLERR); -    } - -    /** -     * Issue a poll call on the specified 0MQ sockets. -     * -     * @param socket an array of 0MQ Socket objects to poll. -     * @param event an array of short values specifying what to poll for. -     * @param revent an array of short values with the results. -     * @param timeout the maximum timeout in microseconds. -     * @return how many objects where signalled by poll(). -     */ -    private native long run_poll(int count, -                                 Socket[] socket, -                                 short[] event, -                                 short[] revent, -                                 long timeout); - -    /** -     * Check whether a specific mask was signalled by latest poll call. -     * -     * @param index the index indicating the socket. -     * @param mask a combination of POLLIN, POLLOUT and POLLERR. -     * @return true if specific socket was signalled as specified. -     */ -    private boolean poll_mask(int index, int mask) { -        if (mask <= 0 || index < 0 || index >= next) -            return false; -        return (revent[index] & mask) > 0; -    } - -    private Context context = null; -    private long timeout = 0; -    private int size = 0; -    private int next = 0; -    private Socket[] socket = null; -    private short[] event = null; -    private short[] revent = null; -} diff --git a/bindings/java/org/zmq/Socket.java b/bindings/java/org/zmq/Socket.java deleted file mode 100644 index 851b7b8..0000000 --- a/bindings/java/org/zmq/Socket.java +++ /dev/null @@ -1,134 +0,0 @@ -/* -    Copyright (c) 2007-2010 iMatix Corporation - -    This file is part of 0MQ. - -    0MQ is free software; you can redistribute it and/or modify it under -    the terms of the Lesser GNU General Public License as published by -    the Free Software Foundation; either version 3 of the License, or -    (at your option) any later version. - -    0MQ is distributed in the hope that it will be useful, -    but WITHOUT ANY WARRANTY; without even the implied warranty of -    MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the -    Lesser GNU General Public License for more details. - -    You should have received a copy of the Lesser GNU General Public License -    along with this program.  If not, see <http://www.gnu.org/licenses/>. -*/ - -package org.zmq; - -public class Socket { -    static { -        System.loadLibrary("jzmq"); -    } - -    public static final int NOBLOCK = 1; -    public static final int NOFLUSH = 2; - -    public static final int P2P = 0; -    public static final int PUB = 1; -    public static final int SUB = 2; -    public static final int REQ = 3; -    public static final int REP = 4; -    public static final int XREQ = 5; -    public static final int XREP = 6; -    public static final int UPSTREAM = 7; -    public static final int DOWNSTREAM = 8; - -    public static final int HWM = 1; -    public static final int LWM = 2; -    public static final int SWAP = 3; -    public static final int AFFINITY = 4; -    public static final int IDENTITY = 5; -    public static final int SUBSCRIBE = 6; -    public static final int UNSUBSCRIBE = 7; -    public static final int RATE = 8; -    public static final int RECOVERY_IVL = 9; -    public static final int MCAST_LOOP = 10; -    public static final int SNDBUF = 11; -    public static final int RCVBUF = 12; - -    /** -     * Class constructor. -     * -     * @param context a 0MQ context previously created. -     * @param type the socket type. -     */ -    public Socket (Context context, int type) { -        construct (context, type); -    } - -    /** -     * Set the socket option value, given as a long. -     * -     * @param option ID of the option to set. -     * @param optval value (as a long) to set the option to. -     */ -    public native void setsockopt (int option, long optval); - -    /** -     * Set the socket option value, given as a String. -     * -     * @param option ID of the option to set. -     * @param optval value (as a String) to set the option to. -     */ -    public native void setsockopt (int option, String optval); - -    /** -     * Bind to network interface. Start listening for new connections. -     * -     * @param addr the endpoint to bind to. -     */ -    public native void bind (String addr); - -    /** -     * Connect to remote application. -     * -     * @param addr the endpoint to connect to. -     */ -    public native void connect (String addr); - -    /** -     * Send a message. -     * -     * @param msg the message to send, as an array of bytes. -     * @param flags the flags to apply to the send operation. -     * @return true if send was successful, false otherwise. -     */ -    public native boolean send (byte [] msg, long flags); - -    /** -     * Flush the messages down the stream. -     */ -    public native void flush (); - -    /** -     * Receive a message. -     * -     * @param flags the flags to apply to the receive operation. -     * @return the message received, as an array of bytes; null on error. -     */ -    public native byte [] recv (long flags); - -    /** Initialize the JNI interface */ -    protected native void construct (Context context, int type); - -    /** Free all resources used by JNI interface. */ -    protected native void finalize (); - -    /** -     * Get the underlying socket handle. -     * This is private because it is only accessed from JNI, where -     * Java access controls are ignored. -     * -     * @return the internal 0MQ socket handle. -     */ -    private long getSocketHandle () { -        return socketHandle; -    } - -    /** Opaque data used by JNI driver. */ -    private long socketHandle; -} | 
