Changeset f3f7537


Ignore:
Timestamp:
Oct 11, 2008 7:45:30 AM (12 years ago)
Author:
sponge <sponge@…>
Branches:
master
Children:
ca5c15d
Parents:
855293d6
Message:

Set BOB source/target to JDK 5 (AKA 1.5)
Minor bugfixes/code cleanup on BOB
Add/Cleanup? some documentation to streaming lib javadocs

Location:
apps
Files:
14 edited

Legend:

Unmodified
Added
Removed
  • apps/BOB/nbproject/project.properties

    r855293d6 rf3f7537  
    4141javac.compilerargs=
    4242javac.deprecation=false
    43 javac.source=1.4
    44 javac.target=1.4
     43javac.source=1.5
     44javac.target=1.5
    4545javac.test.classpath=\
    4646    ${javac.classpath}:\
  • apps/BOB/src/net/i2p/BOB/BOB.java

    r855293d6 rf3f7537  
    4040 *
    4141 * BOB, main command socket listener, launches the command parser engine.
    42  * 
     42 *
    4343 * @author sponge
    4444 */
     
    5454        /**
    5555         * Log a warning
    56          * 
     56         *
    5757         * @param arg
    5858         */
     
    6464        /**
    6565         * Log an error
    66          * 
     66         *
    6767         * @param arg
    6868         */
     
    7474        /**
    7575         * Listen for incoming connections and handle them
    76          * 
     76         *
    7777         * @param args
    7878         */
  • apps/BOB/src/net/i2p/BOB/I2Plistener.java

    r855293d6 rf3f7537  
    5959                this._log = _log;
    6060                this.socketManager = S;
    61                 serverSocket = socketManager.getServerSocket();
     61                serverSocket = this.socketManager.getServerSocket();
    6262                tgwatch = 1;
    6363        }
     
    6666         * Simply listen on I2P port, and thread connections
    6767         *
    68          * @throws RuntimeException
    6968         */
    70         public void run() throws RuntimeException {
     69        public void run() {
    7170                boolean g = false;
    7271                I2PSocket sessSocket = null;
     
    106105
    107106                        } catch(I2PException e) {
    108                         //      System.out.println("Exception " + e);
     107                                //      System.out.println("Exception " + e);
    109108                        }
    110109                }
     
    124123                                }
    125124                }
    126 //              System.out.println("STOP Thread count " + Thread.activeCount());
     125
     126                //              System.out.println("STOP Thread count " + Thread.activeCount());
    127127                // need to kill off the socket manager too.
    128128                I2PSession session = socketManager.getSession();
     
    135135//                      System.out.println("destroySession Thread count " + Thread.activeCount());
    136136                }
    137 
    138 
    139137        }
    140138}
  • apps/BOB/src/net/i2p/BOB/I2PtoTCP.java

    r855293d6 rf3f7537  
    3131/**
    3232 * Process I2P->TCP
    33  * 
     33 *
    3434 * @author sponge
    3535 */
     
    3737
    3838        private I2PSocket I2P;
    39         private nickname info, database;
     39        private nickname info,  database;
    4040        private Socket sock;
    4141
    4242        /**
    4343         * Constructor
    44          * 
     44         *
    4545         * @param I2Psock
    4646         * @param info
     
    5555        /**
    5656         * I2P stream to TCP stream thread starter
    57          * 
     57         *
    5858         */
    5959        public void run() {
  • apps/BOB/src/net/i2p/BOB/MUXlisten.java

    r855293d6 rf3f7537  
    3535 *
    3636 * Multiplex listeners for TCP and I2P
    37  * 
     37 *
    3838 * @author sponge
    3939 */
     
    4949        /**
    5050         * Constructor
    51          * 
     51         *
    5252         * @param info
    5353         * @param database
     
    7474                this.info.releaseWriteLock();
    7575                this.database.releaseWriteLock();
    76                
     76
    7777                socketManager = I2PSocketManagerFactory.createManager(prikey, Q);
    7878        }
     
    8080        /**
    8181         * MUX sockets, fire off a thread to connect, get destination info, and do I/O
    82          * 
     82         *
    8383         */
    8484        public void run() {
  • apps/BOB/src/net/i2p/BOB/Main.java

    r855293d6 rf3f7537  
    2222 * ...for any additional details and liscense questions.
    2323 */
    24 
    2524package net.i2p.BOB;
    2625
     
    3029/**
    3130 * Start from command line
    32  * 
     31 *
    3332 * @author sponge
    3433 *
    3534 */
    36 
    3735public class Main {
    3836
  • apps/BOB/src/net/i2p/BOB/TCPio.java

    r855293d6 rf3f7537  
    4141        /**
    4242         * Constructor
    43          * 
     43         *
    4444         * @param Ain
    4545         * @param Aout
     
    6161         * and yes, we are totally OK to block here on writes,
    6262         * The OS has buffers, and I intend to use them.
    63          * 
     63         *
    6464         */
    6565        public void run() {
     
    8888                                } else {
    8989                                        /* according to the specs:
    90                                          * 
    91                                          * The total number of bytes read into the buffer, 
    92                                          * or -1 if there is no more data because the end of 
     90                                         *
     91                                         * The total number of bytes read into the buffer,
     92                                         * or -1 if there is no more data because the end of
    9393                                         * the stream has been reached.
    94                                          * 
     94                                         *
    9595                                         */
    9696                                        return;
  • apps/BOB/src/net/i2p/BOB/TCPlistener.java

    r855293d6 rf3f7537  
    4242public class TCPlistener implements Runnable {
    4343
    44         private nickname info, database;
     44        private nickname info,  database;
    4545        private Log _log;
    4646        private int tgwatch;
     
    6666        /**
    6767         * Simply listen on TCP port, and thread connections
    68          * @throws java.lang.RuntimeException
     68         *
    6969         */
    70         public void run() throws RuntimeException {
     70        public void run() {
    7171                boolean g = false;
    72                                 database.getReadLock();
     72                boolean spin = true;
     73                database.getReadLock();
    7374                info.getReadLock();
    7475                if(info.exists("OUTPORT")) {
     
    8081                        Socket server = new Socket();
    8182                        listener.setSoTimeout(1000);
    82                 info.releaseReadLock();
    83                 database.releaseReadLock();
    84                 boolean spin = true;
    85                 while(spin) {
    86                         database.getReadLock();
    87                         info.getReadLock();
    88                         spin = info.get("RUNNING").equals(Boolean.TRUE);
    8983                        info.releaseReadLock();
    9084                        database.releaseReadLock();
     85                        while(spin) {
     86                                database.getReadLock();
     87                                info.getReadLock();
     88                                spin = info.get("RUNNING").equals(Boolean.TRUE);
     89                                info.releaseReadLock();
     90                                database.releaseReadLock();
    9191//                              System.out.println("Thread count " + Thread.activeCount());
    9292                                try {
     
    102102                                        t.start();
    103103                                        g = false;
    104                                 } 
     104                                }
    105105                        }
    106106                        listener.close();
    107107                } catch(IOException ioe) {
    108                         // throw new RuntimeException(ioe);
     108                        // Fatal failure, cause a stop event
     109                        database.getReadLock();
     110                        info.getReadLock();
     111                        spin = info.get("RUNNING").equals(Boolean.TRUE);
     112                        info.releaseReadLock();
     113                        database.releaseReadLock();
     114                        if(spin) {
     115                                database.getWriteLock();
     116                                info.getWriteLock();
     117                                info.add("STOPPING", new Boolean(true));
     118                                info.add("RUNNING", new Boolean(false));
     119                                info.releaseWriteLock();
     120                                database.releaseWriteLock();
     121                        }
    109122                }
    110123
  • apps/BOB/src/net/i2p/BOB/TCPtoI2P.java

    r855293d6 rf3f7537  
    3838
    3939/**
    40  * 
     40 *
    4141 * Process TCP->I2P
    4242 *
     
    4646
    4747        private I2PSocket I2P;
    48         private nickname info, database;
     48        private nickname info,  database;
    4949        private Socket sock;
    5050        private I2PSocketManager socketManager;
    5151
    5252        /**
    53          * This is a more forgiving readline, 
     53         * This is a more forgiving readline,
    5454         * it works on unbuffered streams
    55          * 
     55         *
    5656         * @param in
    5757         * @return line of text as a String
    58          * @throws Exception 
     58         * @throws Exception
    5959         */
    6060        public static String Lread(InputStream in) throws Exception {
     
    8686         * @param socket
    8787         * @param info
    88          * @param database 
     88         * @param database
    8989         */
    9090        TCPtoI2P(I2PSocketManager i2p, Socket socket, nickname info, nickname database) {
     
    9797        /**
    9898         * Print an error message to out
    99          * 
     99         *
    100100         * @param e
    101101         * @param out
     
    154154                                        }
    155155
    156                                 } catch(I2PException e) {                                       
     156                                } catch(I2PException e) {
    157157                                        Emsg("ERROR " + e.toString(), out);
    158158                                } catch(ConnectException e) {
  • apps/BOB/src/net/i2p/BOB/UDPIOthread.java

    r855293d6 rf3f7537  
    2222 * ...for any additional details and liscense questions.
    2323 */
    24 
    2524package net.i2p.BOB;
    2625
     
    3534import net.i2p.util.Log;
    3635
    37 
    3836/**
    3937 * UDP IO on I2P
    40  * 
     38 *
    4139 *  FIX ME: Untested, and incomplete!
    4240 *  I have no personal need to UDP yet,
     
    5654        private Destination _peerDestination;
    5755        private boolean up;
    58        
    59 /**
    60  * Constructor
    61  * @param info
    62  * @param _log
    63  * @param socket
    64  * @param _session
    65  */     UDPIOthread(nickname info, Log _log, Socket socket, I2PSession _session) {
     56
     57        /**
     58         * Constructor
     59         * @param info
     60         * @param _log
     61         * @param socket
     62         * @param _session
     63         */
     64        UDPIOthread(nickname info, Log _log, Socket socket, I2PSession _session) {
    6665                this.info = info;
    6766                this._log = _log;
     
    7069
    7170        }
    72 /**
    73  *
    74  */
    75  public void run() {
     71
     72        /**
     73         *
     74         */
     75        public void run() {
    7676                byte data[] = new byte[1024];
    7777                up = true;
     
    104104                }
    105105        }
    106 /**
    107  *
    108  * @param session
    109  * @param msgId
    110  * @param size
    111  */
     106
     107        /**
     108         *
     109         * @param session
     110         * @param msgId
     111         * @param size
     112         */
    112113        public void messageAvailable(I2PSession session, int msgId, long size) {
    113114//              _log.debug("Message available: id = " + msgId + " size = " + size);
     
    124125
    125126        // Great, can these be used to kill ourselves.
    126 
    127127        /** required by {@link I2PSessionListener I2PSessionListener} to notify of disconnect */
    128128        public void disconnected(I2PSession session) {
    129129                _log.debug("Disconnected");
    130                 // up = false;
     130        // up = false;
    131131        }
    132132
     
    134134        public void errorOccurred(I2PSession session, String message, Throwable error) {
    135135                _log.debug("Error occurred: " + message, error);
    136                 // up = false;
     136        // up = false;
    137137        }
    138138
     
    140140        public void reportAbuse(I2PSession session, int severity) {
    141141                _log.debug("Abuse reported of severity " + severity);
    142                 // up = false;
     142        // up = false;
    143143        }
    144144}
  • apps/BOB/src/net/i2p/BOB/doCMDS.java

    r855293d6 rf3f7537  
    7171        private static final String P_STARTING = "STARTING";
    7272        private static final String P_STOPPING = "STOPPING";
     73//      private static final String P_INSTATE = "INSTATE";
     74//      private static final String P_OUTSTATE = "OUTSTATE";
     75
    7376        /* command strings */
    7477        private static final String C_help = "help";
     
    491494                                                        database.add(Arg, nickinfo);
    492495                                                        nickinfo.add(P_NICKNAME, Arg);
     496//                                                      nickinfo.add(P_INSTATE,new Boolean(false));
     497//                                                      nickinfo.add(P_OUTSTATE,new Boolean(false));
    493498                                                        nickinfo.add(P_STARTING, Boolean.FALSE);
    494499                                                        nickinfo.add(P_RUNNING, Boolean.FALSE);
  • apps/BOB/src/net/i2p/BOB/nickname.java

    r855293d6 rf3f7537  
    2626/**
    2727 * Internal database to relate nicknames to options to values
    28  * 
     28 *
    2929 * @author sponge
    3030 */
     
    3333        private static final int maxWritersWaiting = 2;
    3434        private volatile Object[][] data;
    35         private volatile int index, writersWaiting, readers;
     35        private volatile int index,  writersWaiting, readers;
    3636        private volatile boolean writingInProgress;
     37
    3738        /**
    3839         * make initial NULL object
    39          * 
     40         *
    4041         */
    4142        public nickname() {
     
    9596        /**
    9697         * Delete an object from array if it exists
    97          * 
     98         *
    9899         * @param key
    99100         */
     
    111112                olddata = new Object[index + 2][2];
    112113                // copy to olddata, skipping 'k'
    113                 for(i = 0          , l = 0; l < index; i++, l++) {
     114                for(i = 0            , l = 0; l < index; i++, l++) {
    114115                        if(i == k) {
    115116                                l++;
     
    127128        /**
    128129         * Add object to the array, deletes the old one if it exists
    129          * 
     130         *
    130131         * @param key
    131132         * @param val
     
    150151        /**
    151152         * Get the object, and return it, throws RuntimeException
    152          * 
     153         *
    153154         * @param key
    154155         * @return Object
     
    166167        /**
    167168         * returns true if an object exists, else returns false
    168          * 
     169         *
    169170         * @param key
    170171         * @return true if an object exists, else returns false
     
    181182
    182183        /**
    183          * 
     184         *
    184185         * @param i index
    185186         * @return an indexed Object
  • apps/streaming/java/src/net/i2p/client/streaming/ConnectionManager.java

    r855293d6 rf3f7537  
    114114        _connectionHandler.setActive(allow);
    115115    }
    116     /** should we acceot connections, or just reject everyone? */
     116    /** @return if we should accept connections */
    117117    public boolean getAllowIncomingConnections() {
    118118        return _connectionHandler.getActive();
  • apps/streaming/java/src/net/i2p/client/streaming/I2PSocketManagerFull.java

    r855293d6 rf3f7537  
    182182     * @param options I2P socket options to be used for connecting
    183183     *
     184     * @return I2PSocket if successful
    184185     * @throws NoRouteToHostException if the peer is not found or not reachable
    185186     * @throws I2PException if there is some other I2P-related problem
     
    216217     * @param peer Destination to connect to
    217218     *
     219     * @return I2PSocket if successful
    218220     * @throws NoRouteToHostException if the peer is not found or not reachable
    219221     * @throws I2PException if there is some other I2P-related problem
Note: See TracChangeset for help on using the changeset viewer.