activemq-commits mailing list archives

Site index · List index

Message view	« Date » · « Thread »
Top	« Date » · « Thread »
From	chir...@apache.org
Subject	svn commit: r358596 [3/5] - in /incubator/activemq/trunk/activeio: ./ activeio-aio/src/main/java/org/activeio/packet/async/aio/ activeio-aio/src/main/java/org/apache/ activeio-aio/src/main/java/org/apache/activeio/ activeio-aio/src/main/java/org/apache...
Date	Thu, 22 Dec 2005 17:53:13 GMT
Copied: incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/async/FilterAsyncChannelServer.java (from r358590, incubator/activemq/trunk/activeio/activeio-core/src/java/org/activeio/packet/async/FilterAsyncChannelServer.java) URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/async/FilterAsyncChannelServer.java?p2=incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/async/FilterAsyncChannelServer.java&p1=incubator/activemq/trunk/activeio/activeio-core/src/java/org/activeio/packet/async/FilterAsyncChannelServer.java&r1=358590&r2=358596&rev=358596&view=diff ============================================================================== --- incubator/activemq/trunk/activeio/activeio-core/src/java/org/activeio/packet/async/FilterAsyncChannelServer.java (original) +++ incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/async/FilterAsyncChannelServer.java Thu Dec 22 09:51:34 2005 @@ -14,18 +14,18 @@ * See the License for the specific language governing permissions and * limitations under the License. / -package org.activeio.packet.async; +package org.apache.activeio.packet.async; import java.io.IOException; import java.net.URI; -import org.activeio.AcceptListener; -import org.activeio.Channel; +import org.apache.activeio.AcceptListener; +import org.apache.activeio.Channel; /* - * A AsyncChannelFilter can be used as a filter between a {@see org.activeio.AsyncChannel} - * and it's {@see org.activeio.ChannelConsumer}. Most {@see org.activeio.AsyncChannel} + * A AsyncChannelFilter can be used as a filter between a {@see org.apache.activeio.AsyncChannel} + * and it's {@see org.apache.activeio.ChannelConsumer}. Most {@see org.apache.activeio.AsyncChannel} * that are not directly accessing the network will extends the AsyncChannelFilter since they act as a * filter between the client and the network. O * @@ -52,14 +52,14 @@ } /** - * @see org.activeio.Disposable#dispose() + * @see org.apache.activeio.Disposable#dispose() / public void dispose() { next.dispose(); } /* - * @see org.activeio.Service#start() + * @see org.apache.activeio.Service#start() * @throws IOException if the next channel has not been set. / public void start() throws IOException { @@ -69,7 +69,7 @@ } /* - * @see org.activeio.Service#stop() + * @see org.apache.activeio.Service#stop() / public void stop() throws IOException { next.stop(); Modified: incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/async/filter/AsyncWriteAsyncChannel.java URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/async/filter/AsyncWriteAsyncChannel.java?rev=358596&r1=358590&r2=358596&view=diff ============================================================================== --- incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/async/filter/AsyncWriteAsyncChannel.java (original) +++ incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/async/filter/AsyncWriteAsyncChannel.java Thu Dec 22 09:51:34 2005 @@ -1,4 +1,4 @@ -package org.activeio.packet.async.filter; +package org.apache.activeio.packet.async.filter; import edu.emory.mathcs.backport.java.util.concurrent.BlockingQueue; import edu.emory.mathcs.backport.java.util.concurrent.CountDownLatch; @@ -8,10 +8,10 @@ import edu.emory.mathcs.backport.java.util.concurrent.TimeUnit; import edu.emory.mathcs.backport.java.util.concurrent.atomic.AtomicInteger; -import org.activeio.ChannelFactory; -import org.activeio.packet.Packet; -import org.activeio.packet.async.AsyncChannel; -import org.activeio.packet.async.FilterAsyncChannel; +import org.apache.activeio.ChannelFactory; +import org.apache.activeio.packet.Packet; +import org.apache.activeio.packet.async.AsyncChannel; +import org.apache.activeio.packet.async.FilterAsyncChannel; import java.io.IOException; import java.io.InterruptedIOException; Modified: incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/async/filter/CounterAsyncChannel.java URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/async/filter/CounterAsyncChannel.java?rev=358596&r1=358590&r2=358596&view=diff ============================================================================== --- incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/async/filter/CounterAsyncChannel.java (original) +++ incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/async/filter/CounterAsyncChannel.java Thu Dec 22 09:51:34 2005 @@ -14,21 +14,21 @@ See the License for the specific language governing permissions and * limitations under the License. / -package org.activeio.packet.async.filter; +package org.apache.activeio.packet.async.filter; import java.io.IOException; -import org.activeio.packet.Packet; -import org.activeio.packet.async.AsyncChannel; -import org.activeio.packet.async.FilterAsyncChannel; +import org.apache.activeio.packet.Packet; +import org.apache.activeio.packet.async.AsyncChannel; +import org.apache.activeio.packet.async.FilterAsyncChannel; /* - * A CounterAsyncChannel is a simple {@see org.activeio.AsyncChannelFilter} + * A CounterAsyncChannel is a simple {@see org.apache.activeio.AsyncChannelFilter} * that counts the number bytes that been sent down and up through the channel. * - * The {@see org.activeio.counter.CounterAttribueEnum.COUNTER_INBOUND_COUNT} - * and {@see org.activeio.counter.CounterAttribueEnum.COUNTER_OUTBOUND_COUNT} + * The {@see org.apache.activeio.counter.CounterAttribueEnum.COUNTER_INBOUND_COUNT} + * and {@see org.apache.activeio.counter.CounterAttribueEnum.COUNTER_OUTBOUND_COUNT} * attributes can be used to find query the channel to get the current inbound and outbound * byte counts. * @@ -48,7 +48,7 @@ } /** - * @see org.activeio.packet.async.FilterAsyncChannel#onPacket(org.activeio.packet.Packet) + * @see org.apache.activeio.packet.async.FilterAsyncChannel#onPacket(org.apache.activeio.packet.Packet) / public void onPacket(Packet packet) { inBoundCounter += packet.remaining(); @@ -56,7 +56,7 @@ } /* - * @see org.activeio.packet.async.FilterAsyncChannel#write(org.activeio.packet.Packet) + * @see org.apache.activeio.packet.async.FilterAsyncChannel#write(org.apache.activeio.packet.Packet) / public void write(Packet packet) throws IOException { outBoundCounter += packet.position(); Modified: incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/async/filter/PacketAggregatingAsyncChannel.java URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/async/filter/PacketAggregatingAsyncChannel.java?rev=358596&r1=358590&r2=358596&view=diff ============================================================================== --- incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/async/filter/PacketAggregatingAsyncChannel.java (original) +++ incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/async/filter/PacketAggregatingAsyncChannel.java Thu Dec 22 09:51:34 2005 @@ -14,14 +14,14 @@ See the License for the specific language governing permissions and * limitations under the License. / -package org.activeio.packet.async.filter; +package org.apache.activeio.packet.async.filter; import java.io.IOException; -import org.activeio.packet.Packet; -import org.activeio.packet.async.AsyncChannel; -import org.activeio.packet.async.FilterAsyncChannel; -import org.activeio.util.PacketAggregator; +import org.apache.activeio.packet.Packet; +import org.apache.activeio.packet.async.AsyncChannel; +import org.apache.activeio.packet.async.FilterAsyncChannel; +import org.apache.activeio.util.PacketAggregator; /* * This PacketAggregatingAsyncChannel can be used when the client is sending a @@ -32,7 +32,7 @@ * Packet that is sent down will not be fragmented or combined with other Packet * objects. * - * This {@see org.activeio.AsyncChannel} adds a 4 byte header + * This {@see org.apache.activeio.AsyncChannel} adds a 4 byte header * to each packet that is sent down. * * @version $Revision$ Modified: incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/async/filter/SynchornizedAsyncChannel.java URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/async/filter/SynchornizedAsyncChannel.java?rev=358596&r1=358590&r2=358596&view=diff ============================================================================== --- incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/async/filter/SynchornizedAsyncChannel.java (original) +++ incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/async/filter/SynchornizedAsyncChannel.java Thu Dec 22 09:51:34 2005 @@ -14,14 +14,14 @@ * See the License for the specific language governing permissions and * limitations under the License. / -package org.activeio.packet.async.filter; +package org.apache.activeio.packet.async.filter; import edu.emory.mathcs.backport.java.util.concurrent.locks.Lock; import edu.emory.mathcs.backport.java.util.concurrent.locks.ReentrantLock; -import org.activeio.packet.Packet; -import org.activeio.packet.async.AsyncChannel; -import org.activeio.packet.async.FilterAsyncChannel; +import org.apache.activeio.packet.Packet; +import org.apache.activeio.packet.async.AsyncChannel; +import org.apache.activeio.packet.async.FilterAsyncChannel; import java.io.IOException; Modified: incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/async/filter/WriteBufferedAsyncChannel.java URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/async/filter/WriteBufferedAsyncChannel.java?rev=358596&r1=358590&r2=358596&view=diff ============================================================================== --- incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/async/filter/WriteBufferedAsyncChannel.java (original) +++ incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/async/filter/WriteBufferedAsyncChannel.java Thu Dec 22 09:51:34 2005 @@ -14,14 +14,14 @@ See the License for the specific language governing permissions and * limitations under the License. / -package org.activeio.packet.async.filter; +package org.apache.activeio.packet.async.filter; import java.io.IOException; -import org.activeio.packet.ByteArrayPacket; -import org.activeio.packet.Packet; -import org.activeio.packet.async.AsyncChannel; -import org.activeio.packet.async.FilterAsyncChannel; +import org.apache.activeio.packet.ByteArrayPacket; +import org.apache.activeio.packet.Packet; +import org.apache.activeio.packet.async.AsyncChannel; +import org.apache.activeio.packet.async.FilterAsyncChannel; /* / Modified: incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/async/nio/NIOAsyncChannel.java URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/async/nio/NIOAsyncChannel.java?rev=358596&r1=358590&r2=358596&view=diff ============================================================================== --- incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/async/nio/NIOAsyncChannel.java (original) +++ incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/async/nio/NIOAsyncChannel.java Thu Dec 22 09:51:34 2005 @@ -16,7 +16,7 @@ / -package org.activeio.packet.async.nio; +package org.apache.activeio.packet.async.nio; import java.io.IOException; import java.io.InterruptedIOException; @@ -25,15 +25,15 @@ import java.nio.channels.SelectionKey; import java.nio.channels.SocketChannel; -import org.activeio.packet.ByteBufferPacket; -import org.activeio.packet.ByteSequence; -import org.activeio.packet.EOSPacket; -import org.activeio.packet.Packet; -import org.activeio.packet.async.AsyncChannel; -import org.activeio.packet.async.AsyncChannelListener; -import org.activeio.packet.async.nio.NIOAsyncChannelSelectorManager.SelectorManagerListener; -import org.activeio.packet.async.nio.NIOAsyncChannelSelectorManager.SocketChannelAsyncChannelSelection; -import org.activeio.packet.sync.nio.NIOBaseChannel; +import org.apache.activeio.packet.ByteBufferPacket; +import org.apache.activeio.packet.ByteSequence; +import org.apache.activeio.packet.EOSPacket; +import org.apache.activeio.packet.Packet; +import org.apache.activeio.packet.async.AsyncChannel; +import org.apache.activeio.packet.async.AsyncChannelListener; +import org.apache.activeio.packet.async.nio.NIOAsyncChannelSelectorManager.SelectorManagerListener; +import org.apache.activeio.packet.async.nio.NIOAsyncChannelSelectorManager.SocketChannelAsyncChannelSelection; +import org.apache.activeio.packet.sync.nio.NIOBaseChannel; / * @version $Revision$ Modified: incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/async/nio/NIOAsyncChannelFactory.java URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/async/nio/NIOAsyncChannelFactory.java?rev=358596&r1=358590&r2=358596&view=diff ============================================================================== --- incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/async/nio/NIOAsyncChannelFactory.java (original) +++ incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/async/nio/NIOAsyncChannelFactory.java Thu Dec 22 09:51:34 2005 @@ -15,7 +15,7 @@ * limitations under the License. * / -package org.activeio.packet.async.nio; +package org.apache.activeio.packet.async.nio; import java.io.IOException; import java.net.InetAddress; @@ -25,23 +25,23 @@ import java.nio.channels.ServerSocketChannel; import java.nio.channels.SocketChannel; -import org.activeio.adapter.SyncToAsyncChannelServer; -import org.activeio.packet.ByteBufferPacket; -import org.activeio.packet.async.AsyncChannel; -import org.activeio.packet.async.AsyncChannelFactory; -import org.activeio.packet.async.AsyncChannelServer; -import org.activeio.packet.async.filter.WriteBufferedAsyncChannel; -import org.activeio.util.URISupport; +import org.apache.activeio.adapter.SyncToAsyncChannelServer; +import org.apache.activeio.packet.ByteBufferPacket; +import org.apache.activeio.packet.async.AsyncChannel; +import org.apache.activeio.packet.async.AsyncChannelFactory; +import org.apache.activeio.packet.async.AsyncChannelServer; +import org.apache.activeio.packet.async.filter.WriteBufferedAsyncChannel; +import org.apache.activeio.util.URISupport; / - * A TcpAsyncChannelFactory creates {@see org.activeio.net.TcpAsyncChannel} - * and {@see org.activeio.net.TcpAsyncChannelServer} objects. + * A TcpAsyncChannelFactory creates {@see org.apache.activeio.net.TcpAsyncChannel} + * and {@see org.apache.activeio.net.TcpAsyncChannelServer} objects. * * @version $Revision$ / public class NIOAsyncChannelFactory implements AsyncChannelFactory { - protected static final int DEFAULT_BUFFER_SIZE = Integer.parseInt(System.getProperty("org.activeio.net.nio.BufferSize", ""+(641024))); + protected static final int DEFAULT_BUFFER_SIZE = Integer.parseInt(System.getProperty("org.apache.activeio.net.nio.BufferSize", ""+(641024))); protected static final int DEFAULT_BACKLOG = 500; boolean useDirectBuffers = true; @@ -60,7 +60,7 @@ /* * Uses the {@param location}'s host and port to create a tcp connection to a remote host. * - * @see org.activeio.AsyncChannelFactory#openAsyncChannel(java.net.URI) + * @see org.apache.activeio.AsyncChannelFactory#openAsyncChannel(java.net.URI) / public AsyncChannel openAsyncChannel(URI location) throws IOException { SocketChannel channel = SocketChannel.open(); @@ -84,7 +84,7 @@ /* * Binds a server socket a the {@param location}'s port. * - * @see org.activeio.AsyncChannelFactory#bindAsyncChannel(java.net.URI) + * @see org.apache.activeio.AsyncChannelFactory#bindAsyncChannel(java.net.URI) / public AsyncChannelServer bindAsyncChannel(URI bindURI) throws IOException { Modified: incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/async/nio/NIOAsyncChannelSelectorManager.java URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/async/nio/NIOAsyncChannelSelectorManager.java?rev=358596&r1=358590&r2=358596&view=diff ============================================================================== --- incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/async/nio/NIOAsyncChannelSelectorManager.java (original) +++ incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/async/nio/NIOAsyncChannelSelectorManager.java Thu Dec 22 09:51:34 2005 @@ -15,12 +15,12 @@ limitations under the License. / -package org.activeio.packet.async.nio; +package org.apache.activeio.packet.async.nio; import edu.emory.mathcs.backport.java.util.concurrent.Executor; import edu.emory.mathcs.backport.java.util.concurrent.ScheduledThreadPoolExecutor; -import org.activeio.ChannelFactory; +import org.apache.activeio.ChannelFactory; import java.io.IOException; import java.nio.channels.ClosedChannelException; Modified: incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/async/nio/NIOAsyncChannelServer.java URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/async/nio/NIOAsyncChannelServer.java?rev=358596&r1=358590&r2=358596&view=diff ============================================================================== --- incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/async/nio/NIOAsyncChannelServer.java (original) +++ incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/async/nio/NIOAsyncChannelServer.java Thu Dec 22 09:51:34 2005 @@ -16,22 +16,22 @@ / -package org.activeio.packet.async.nio; +package org.apache.activeio.packet.async.nio; import java.io.IOException; import java.net.URI; import java.nio.channels.ServerSocketChannel; -import org.activeio.Channel; -import org.activeio.packet.ByteBufferPacket; -import org.activeio.packet.async.AsyncChannel; -import org.activeio.packet.async.filter.WriteBufferedAsyncChannel; -import org.activeio.packet.sync.socket.SocketSyncChannelServer; -import org.activeio.stream.sync.socket.SocketStreamChannel; +import org.apache.activeio.Channel; +import org.apache.activeio.packet.ByteBufferPacket; +import org.apache.activeio.packet.async.AsyncChannel; +import org.apache.activeio.packet.async.filter.WriteBufferedAsyncChannel; +import org.apache.activeio.packet.sync.socket.SocketSyncChannelServer; +import org.apache.activeio.stream.sync.socket.SocketStreamChannel; / * A SynchChannelServer that creates - * {@see org.activeio.net.TcpSynchChannel}objects from accepted + * {@see org.apache.activeio.net.TcpSynchChannel}objects from accepted * tcp socket connections. * * @version $Revision$ Modified: incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/async/vmpipe/VMPipeAsyncChannelFactory.java URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/async/vmpipe/VMPipeAsyncChannelFactory.java?rev=358596&r1=358590&r2=358596&view=diff ============================================================================== --- incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/async/vmpipe/VMPipeAsyncChannelFactory.java (original) +++ incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/async/vmpipe/VMPipeAsyncChannelFactory.java Thu Dec 22 09:51:34 2005 @@ -15,7 +15,7 @@ * limitations under the License. * / -package org.activeio.packet.async.vmpipe; +package org.apache.activeio.packet.async.vmpipe; import java.io.IOException; import java.lang.reflect.InvocationHandler; @@ -27,11 +27,11 @@ import java.util.HashMap; import java.util.Map; -import org.activeio.packet.Packet; -import org.activeio.packet.async.AsyncChannel; -import org.activeio.packet.async.AsyncChannelFactory; -import org.activeio.packet.async.AsyncChannelListener; -import org.activeio.packet.async.AsyncChannelServer; +import org.apache.activeio.packet.Packet; +import org.apache.activeio.packet.async.AsyncChannel; +import org.apache.activeio.packet.async.AsyncChannelFactory; +import org.apache.activeio.packet.async.AsyncChannelListener; +import org.apache.activeio.packet.async.AsyncChannelServer; / * Modified: incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/async/vmpipe/VMPipeAsyncChannelPipe.java URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/async/vmpipe/VMPipeAsyncChannelPipe.java?rev=358596&r1=358590&r2=358596&view=diff ============================================================================== --- incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/async/vmpipe/VMPipeAsyncChannelPipe.java (original) +++ incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/async/vmpipe/VMPipeAsyncChannelPipe.java Thu Dec 22 09:51:34 2005 @@ -15,15 +15,15 @@ * limitations under the License. * */ -package org.activeio.packet.async.vmpipe; +package org.apache.activeio.packet.async.vmpipe; import java.io.IOException; import java.io.InterruptedIOException; -import org.activeio.packet.EOSPacket; -import org.activeio.packet.Packet; -import org.activeio.packet.async.AsyncChannel; -import org.activeio.packet.async.AsyncChannelListener; +import org.apache.activeio.packet.EOSPacket; +import org.apache.activeio.packet.Packet; +import org.apache.activeio.packet.async.AsyncChannel; +import org.apache.activeio.packet.async.AsyncChannelListener; import edu.emory.mathcs.backport.java.util.concurrent.Semaphore; import edu.emory.mathcs.backport.java.util.concurrent.TimeUnit; Modified: incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/async/vmpipe/VMPipeAsyncChannelServer.java URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/async/vmpipe/VMPipeAsyncChannelServer.java?rev=358596&r1=358590&r2=358596&view=diff ============================================================================== --- incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/async/vmpipe/VMPipeAsyncChannelServer.java (original) +++ incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/async/vmpipe/VMPipeAsyncChannelServer.java Thu Dec 22 09:51:34 2005 @@ -16,14 +16,14 @@ / -package org.activeio.packet.async.vmpipe; +package org.apache.activeio.packet.async.vmpipe; import java.io.IOException; import java.net.URI; -import org.activeio.AcceptListener; -import org.activeio.packet.async.AsyncChannel; -import org.activeio.packet.async.AsyncChannelServer; +import org.apache.activeio.AcceptListener; +import org.apache.activeio.packet.async.AsyncChannel; +import org.apache.activeio.packet.async.AsyncChannelServer; / * @version $Revision$ Copied: incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/sync/FilterSyncChannel.java (from r358590, incubator/activemq/trunk/activeio/activeio-core/src/java/org/activeio/packet/sync/FilterSyncChannel.java) URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/sync/FilterSyncChannel.java?p2=incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/sync/FilterSyncChannel.java&p1=incubator/activemq/trunk/activeio/activeio-core/src/java/org/activeio/packet/sync/FilterSyncChannel.java&r1=358590&r2=358596&rev=358596&view=diff ============================================================================== --- incubator/activemq/trunk/activeio/activeio-core/src/java/org/activeio/packet/sync/FilterSyncChannel.java (original) +++ incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/sync/FilterSyncChannel.java Thu Dec 22 09:51:34 2005 @@ -14,16 +14,16 @@ * See the License for the specific language governing permissions and * limitations under the License. / -package org.activeio.packet.sync; +package org.apache.activeio.packet.sync; import java.io.IOException; -import org.activeio.packet.Packet; +import org.apache.activeio.packet.Packet; /* - * A SynchChannelFilter can be used as a filter another {@see org.activeio.SynchChannel} - * Most {@see org.activeio.SynchChannel} that are not directly accessing the network will + * A SynchChannelFilter can be used as a filter another {@see org.apache.activeio.SynchChannel} + * Most {@see org.apache.activeio.SynchChannel} that are not directly accessing the network will * extends the SynchChannelFilter since they act as a filter between the client and the network. * * @version $Revision$ @@ -37,35 +37,35 @@ } /** - * @see org.activeio.Channel#write(org.activeio.packet.Packet) + * @see org.apache.activeio.Channel#write(org.apache.activeio.packet.Packet) / public void write(Packet packet) throws IOException { next.write(packet); } /* - * @see org.activeio.Channel#flush() + * @see org.apache.activeio.Channel#flush() / public void flush() throws IOException { next.flush(); } /* - * @see org.activeio.Disposable#dispose() + * @see org.apache.activeio.Disposable#dispose() / public void dispose() { next.dispose(); } /* - * @see org.activeio.Service#start() + * @see org.apache.activeio.Service#start() / public void start() throws IOException { next.start(); } /* - * @see org.activeio.Service#stop() + * @see org.apache.activeio.Service#stop() / public void stop() throws IOException { next.stop(); @@ -79,7 +79,7 @@ } /* - * @see org.activeio.packet.sync.SyncChannel#read(long) + * @see org.apache.activeio.packet.sync.SyncChannel#read(long) / public Packet read(long timeout) throws IOException { return next.read(timeout); Copied: incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/sync/FilterSyncChannelServer.java (from r358590, incubator/activemq/trunk/activeio/activeio-core/src/java/org/activeio/packet/sync/FilterSyncChannelServer.java) URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/sync/FilterSyncChannelServer.java?p2=incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/sync/FilterSyncChannelServer.java&p1=incubator/activemq/trunk/activeio/activeio-core/src/java/org/activeio/packet/sync/FilterSyncChannelServer.java&r1=358590&r2=358596&rev=358596&view=diff ============================================================================== --- incubator/activemq/trunk/activeio/activeio-core/src/java/org/activeio/packet/sync/FilterSyncChannelServer.java (original) +++ incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/sync/FilterSyncChannelServer.java Thu Dec 22 09:51:34 2005 @@ -14,17 +14,17 @@ See the License for the specific language governing permissions and * limitations under the License. / -package org.activeio.packet.sync; +package org.apache.activeio.packet.sync; import java.io.IOException; import java.net.URI; -import org.activeio.Channel; +import org.apache.activeio.Channel; /* - * A SynchChannelFilter can be used as a filter another {@see org.activeio.SynchChannel} - * Most {@see org.activeio.SynchChannel} that are not directly accessing the network will + * A SynchChannelFilter can be used as a filter another {@see org.apache.activeio.SynchChannel} + * Most {@see org.apache.activeio.SynchChannel} that are not directly accessing the network will * extends the SynchChannelFilter since they act as a filter between the client and the network. * * @version $Revision$ @@ -38,21 +38,21 @@ } /** - * @see org.activeio.Disposable#dispose() + * @see org.apache.activeio.Disposable#dispose() / public void dispose() { next.dispose(); } /* - * @see org.activeio.Service#start() + * @see org.apache.activeio.Service#start() / public void start() throws IOException { next.start(); } /* - * @see org.activeio.Service#stop() + * @see org.apache.activeio.Service#stop() / public void stop() throws IOException { next.stop(); @@ -66,21 +66,21 @@ } /* - * @see org.activeio.packet.sync.SyncChannelServer#accept(long) + * @see org.apache.activeio.packet.sync.SyncChannelServer#accept(long) / public Channel accept(long timeout) throws IOException { return next.accept(timeout); } /* - * @see org.activeio.ChannelServer#getBindURI() + * @see org.apache.activeio.ChannelServer#getBindURI() / public URI getBindURI() { return next.getBindURI(); } /* - * @see org.activeio.ChannelServer#getConnectURI() + * @see org.apache.activeio.ChannelServer#getConnectURI() / public URI getConnectURI() { return next.getConnectURI(); Copied: incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/sync/SyncChannel.java (from r358590, incubator/activemq/trunk/activeio/activeio-core/src/java/org/activeio/packet/sync/SyncChannel.java) URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/sync/SyncChannel.java?p2=incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/sync/SyncChannel.java&p1=incubator/activemq/trunk/activeio/activeio-core/src/java/org/activeio/packet/sync/SyncChannel.java&r1=358590&r2=358596&rev=358596&view=diff ============================================================================== --- incubator/activemq/trunk/activeio/activeio-core/src/java/org/activeio/packet/sync/SyncChannel.java (original) +++ incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/sync/SyncChannel.java Thu Dec 22 09:51:34 2005 @@ -15,17 +15,17 @@ limitations under the License. / -package org.activeio.packet.sync; +package org.apache.activeio.packet.sync; import java.io.IOException; -import org.activeio.Channel; -import org.activeio.packet.Packet; +import org.apache.activeio.Channel; +import org.apache.activeio.packet.Packet; /* * SyncChannel objects allow threaded to synchronously block on the <code>receiveUpPacket</code> - * method to get 'up' {@see org.activeio.Packet} objects when they arrive. + * method to get 'up' {@see org.apache.activeio.Packet} objects when they arrive. * * @version $Revision$ / Copied: incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/sync/SyncChannelFactory.java (from r358590, incubator/activemq/trunk/activeio/activeio-core/src/java/org/activeio/packet/sync/SyncChannelFactory.java) URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/sync/SyncChannelFactory.java?p2=incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/sync/SyncChannelFactory.java&p1=incubator/activemq/trunk/activeio/activeio-core/src/java/org/activeio/packet/sync/SyncChannelFactory.java&r1=358590&r2=358596&rev=358596&view=diff ============================================================================== --- incubator/activemq/trunk/activeio/activeio-core/src/java/org/activeio/packet/sync/SyncChannelFactory.java (original) +++ incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/sync/SyncChannelFactory.java Thu Dec 22 09:51:34 2005 @@ -14,14 +14,14 @@ See the License for the specific language governing permissions and * limitations under the License. / -package org.activeio.packet.sync; +package org.apache.activeio.packet.sync; import java.io.IOException; import java.net.URI; /* - * SynchChannelFactory objects can create {@see org.activeio.SynchChannel} - * and {@see org.activeio.SynchChannelServer} objects. + * SynchChannelFactory objects can create {@see org.apache.activeio.SynchChannel} + * and {@see org.apache.activeio.SynchChannelServer} objects. * * @version $Revision$ / Copied: incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/sync/SyncChannelServer.java (from r358590, incubator/activemq/trunk/activeio/activeio-core/src/java/org/activeio/packet/sync/SyncChannelServer.java) URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/sync/SyncChannelServer.java?p2=incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/sync/SyncChannelServer.java&p1=incubator/activemq/trunk/activeio/activeio-core/src/java/org/activeio/packet/sync/SyncChannelServer.java&r1=358590&r2=358596&rev=358596&view=diff ============================================================================== --- incubator/activemq/trunk/activeio/activeio-core/src/java/org/activeio/packet/sync/SyncChannelServer.java (original) +++ incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/sync/SyncChannelServer.java Thu Dec 22 09:51:34 2005 @@ -14,18 +14,18 @@ See the License for the specific language governing permissions and * limitations under the License. / -package org.activeio.packet.sync; +package org.apache.activeio.packet.sync; import java.io.IOException; -import org.activeio.Channel; -import org.activeio.ChannelServer; +import org.apache.activeio.Channel; +import org.apache.activeio.ChannelServer; /* * A SynchChannelServer object provides an <code>accept</code> method to synchronously - * accept and create {@see org.activeio.Channel} objects. + * accept and create {@see org.apache.activeio.Channel} objects. * * @version $Revision$ / Modified: incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/sync/datagram/DatagramContext.java URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/sync/datagram/DatagramContext.java?rev=358596&r1=358590&r2=358596&view=diff ============================================================================== --- incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/sync/datagram/DatagramContext.java (original) +++ incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/sync/datagram/DatagramContext.java Thu Dec 22 09:51:34 2005 @@ -14,7 +14,7 @@ See the License for the specific language governing permissions and * limitations under the License. / -package org.activeio.packet.sync.datagram; +package org.apache.activeio.packet.sync.datagram; import java.net.DatagramPacket; import java.net.InetAddress; Modified: incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/sync/datagram/DatagramSocketSyncChannel.java URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/sync/datagram/DatagramSocketSyncChannel.java?rev=358596&r1=358590&r2=358596&view=diff ============================================================================== --- incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/sync/datagram/DatagramSocketSyncChannel.java (original) +++ incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/sync/datagram/DatagramSocketSyncChannel.java Thu Dec 22 09:51:34 2005 @@ -15,7 +15,7 @@ limitations under the License. / -package org.activeio.packet.sync.datagram; +package org.apache.activeio.packet.sync.datagram; import java.io.IOException; import java.net.DatagramPacket; @@ -23,15 +23,15 @@ import java.net.SocketException; import java.net.SocketTimeoutException; -import org.activeio.packet.ByteArrayPacket; -import org.activeio.packet.ByteSequence; -import org.activeio.packet.FilterPacket; -import org.activeio.packet.Packet; -import org.activeio.packet.sync.SyncChannel; -import org.activeio.packet.sync.SyncChannelServer; +import org.apache.activeio.packet.ByteArrayPacket; +import org.apache.activeio.packet.ByteSequence; +import org.apache.activeio.packet.FilterPacket; +import org.apache.activeio.packet.Packet; +import org.apache.activeio.packet.sync.SyncChannel; +import org.apache.activeio.packet.sync.SyncChannelServer; /* - * A {@see org.activeio.SynchChannel}implementation that uses + * A {@see org.apache.activeio.SynchChannel}implementation that uses * TCP to talk to the network. * * @version $Revision$ @@ -83,9 +83,9 @@ } /** - * @see org.activeio.packet.sync.SyncChannel#read(long) + * @see org.apache.activeio.packet.sync.SyncChannel#read(long) / - public org.activeio.packet.Packet read(long timeout) throws IOException { + public org.apache.activeio.packet.Packet read(long timeout) throws IOException { try { if (timeout == SyncChannelServer.WAIT_FOREVER_TIMEOUT) @@ -116,9 +116,9 @@ } /* - * @see org.activeio.Channel#write(org.activeio.packet.Packet) + * @see org.apache.activeio.Channel#write(org.apache.activeio.packet.Packet) / - public void write(org.activeio.packet.Packet packet) throws IOException { + public void write(org.apache.activeio.packet.Packet packet) throws IOException { ByteSequence sequence = packet.asByteSequence(); DatagramContext context = (DatagramContext) packet.getAdapter(DatagramContext.class); @@ -130,13 +130,13 @@ } /* - * @see org.activeio.Channel#flush() + * @see org.apache.activeio.Channel#flush() / public void flush() throws IOException { } /* - * @see org.activeio.Disposable#dispose() + * @see org.apache.activeio.Disposable#dispose() / public void dispose() { if (disposed) Modified: incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/sync/datagram/DatagramSocketSyncChannelFactory.java URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/sync/datagram/DatagramSocketSyncChannelFactory.java?rev=358596&r1=358590&r2=358596&view=diff ============================================================================== --- incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/sync/datagram/DatagramSocketSyncChannelFactory.java (original) +++ incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/sync/datagram/DatagramSocketSyncChannelFactory.java Thu Dec 22 09:51:34 2005 @@ -14,20 +14,20 @@ See the License for the specific language governing permissions and * limitations under the License. / -package org.activeio.packet.sync.datagram; +package org.apache.activeio.packet.sync.datagram; import java.io.IOException; import java.net.DatagramSocket; import java.net.InetAddress; import java.net.URI; -import org.activeio.packet.sync.SyncChannel; -import org.activeio.packet.sync.SyncChannelFactory; -import org.activeio.packet.sync.SyncChannelServer; +import org.apache.activeio.packet.sync.SyncChannel; +import org.apache.activeio.packet.sync.SyncChannelFactory; +import org.apache.activeio.packet.sync.SyncChannelServer; /* - * A TcpSynchChannelFactory creates {@see org.activeio.net.TcpSynchChannel} - * and {@see org.activeio.net.TcpSynchChannelServer} objects. + * A TcpSynchChannelFactory creates {@see org.apache.activeio.net.TcpSynchChannel} + * and {@see org.apache.activeio.net.TcpSynchChannelServer} objects. * * @version $Revision$ / @@ -36,7 +36,7 @@ /* * Uses the {@param location}'s host and port to create a tcp connection to a remote host. * - * @see org.activeio.SynchChannelFactory#openSyncChannel(java.net.URI) + * @see org.apache.activeio.SynchChannelFactory#openSyncChannel(java.net.URI) / public SyncChannel openSyncChannel(URI location) throws IOException { DatagramSocket socket=null; @@ -75,7 +75,7 @@ /* * @throws IOException allways thrown. - * @see org.activeio.SynchChannelFactory#bindSynchChannel(java.net.URI) + * @see org.apache.activeio.SynchChannelFactory#bindSynchChannel(java.net.URI) / public SyncChannelServer bindSyncChannel(URI location) throws IOException { throw new IOException("A SynchChannelServer is not available for this channel."); Modified: incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/sync/filter/PacketAggregatingSyncChannel.java URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/sync/filter/PacketAggregatingSyncChannel.java?rev=358596&r1=358590&r2=358596&view=diff ============================================================================== --- incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/sync/filter/PacketAggregatingSyncChannel.java (original) +++ incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/sync/filter/PacketAggregatingSyncChannel.java Thu Dec 22 09:51:34 2005 @@ -14,15 +14,15 @@ See the License for the specific language governing permissions and * limitations under the License. / -package org.activeio.packet.sync.filter; +package org.apache.activeio.packet.sync.filter; import java.io.IOException; import java.util.LinkedList; -import org.activeio.packet.Packet; -import org.activeio.packet.sync.FilterSyncChannel; -import org.activeio.packet.sync.SyncChannel; -import org.activeio.util.PacketAggregator; +import org.apache.activeio.packet.Packet; +import org.apache.activeio.packet.sync.FilterSyncChannel; +import org.apache.activeio.packet.sync.SyncChannel; +import org.apache.activeio.util.PacketAggregator; /* * This PacketAggregatingSynchChannel can be used when the client is sending a @@ -33,7 +33,7 @@ * Packet that is sent down will not be fragmented or combined with other Packet * objects. * - * This {@see org.activeio.SynchChannel} adds a 4 byte header + * This {@see org.apache.activeio.SynchChannel} adds a 4 byte header * to each packet that is sent down. * * @version $Revision$ Modified: incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/sync/filter/PushbackSyncChannel.java URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/sync/filter/PushbackSyncChannel.java?rev=358596&r1=358590&r2=358596&view=diff ============================================================================== --- incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/sync/filter/PushbackSyncChannel.java (original) +++ incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/sync/filter/PushbackSyncChannel.java Thu Dec 22 09:51:34 2005 @@ -14,13 +14,13 @@ * See the License for the specific language governing permissions and * limitations under the License. / -package org.activeio.packet.sync.filter; +package org.apache.activeio.packet.sync.filter; import java.io.IOException; -import org.activeio.packet.Packet; -import org.activeio.packet.sync.FilterSyncChannel; -import org.activeio.packet.sync.SyncChannel; +import org.apache.activeio.packet.Packet; +import org.apache.activeio.packet.sync.FilterSyncChannel; +import org.apache.activeio.packet.sync.SyncChannel; /* * Modified: incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/sync/filter/SynchornizedSyncChannel.java URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/sync/filter/SynchornizedSyncChannel.java?rev=358596&r1=358590&r2=358596&view=diff ============================================================================== --- incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/sync/filter/SynchornizedSyncChannel.java (original) +++ incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/sync/filter/SynchornizedSyncChannel.java Thu Dec 22 09:51:34 2005 @@ -14,15 +14,15 @@ * See the License for the specific language governing permissions and * limitations under the License. / -package org.activeio.packet.sync.filter; +package org.apache.activeio.packet.sync.filter; import java.io.IOException; import java.io.InterruptedIOException; -import org.activeio.packet.Packet; -import org.activeio.packet.sync.FilterSyncChannel; -import org.activeio.packet.sync.SyncChannel; -import org.activeio.packet.sync.SyncChannelServer; +import org.apache.activeio.packet.Packet; +import org.apache.activeio.packet.sync.FilterSyncChannel; +import org.apache.activeio.packet.sync.SyncChannel; +import org.apache.activeio.packet.sync.SyncChannelServer; import edu.emory.mathcs.backport.java.util.concurrent.TimeUnit; import edu.emory.mathcs.backport.java.util.concurrent.locks.Lock; Modified: incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/sync/filter/WriteBufferedSyncChannel.java URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/sync/filter/WriteBufferedSyncChannel.java?rev=358596&r1=358590&r2=358596&view=diff ============================================================================== --- incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/sync/filter/WriteBufferedSyncChannel.java (original) +++ incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/sync/filter/WriteBufferedSyncChannel.java Thu Dec 22 09:51:34 2005 @@ -14,14 +14,14 @@ See the License for the specific language governing permissions and * limitations under the License. / -package org.activeio.packet.sync.filter; +package org.apache.activeio.packet.sync.filter; import java.io.IOException; -import org.activeio.packet.ByteArrayPacket; -import org.activeio.packet.Packet; -import org.activeio.packet.sync.FilterSyncChannel; -import org.activeio.packet.sync.SyncChannel; +import org.apache.activeio.packet.ByteArrayPacket; +import org.apache.activeio.packet.Packet; +import org.apache.activeio.packet.sync.FilterSyncChannel; +import org.apache.activeio.packet.sync.SyncChannel; /* / Modified: incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/sync/jxta/JxtaSocketSyncChannelFactory.java URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/sync/jxta/JxtaSocketSyncChannelFactory.java?rev=358596&r1=358590&r2=358596&view=diff ============================================================================== --- incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/sync/jxta/JxtaSocketSyncChannelFactory.java (original) +++ incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/sync/jxta/JxtaSocketSyncChannelFactory.java Thu Dec 22 09:51:34 2005 @@ -14,7 +14,7 @@ See the License for the specific language governing permissions and * limitations under the License. / -package org.activeio.packet.sync.jxta; +package org.apache.activeio.packet.sync.jxta; import java.io.IOException; import java.net.InetAddress; @@ -25,13 +25,13 @@ import javax.net.ServerSocketFactory; import javax.net.SocketFactory; -import org.activeio.packet.sync.socket.SocketSyncChannelFactory; +import org.apache.activeio.packet.sync.socket.SocketSyncChannelFactory; import org.p2psockets.P2PServerSocket; import org.p2psockets.P2PSocket; /* - * A SslSynchChannelFactory creates {@see org.activeio.net.TcpSynchChannel} - * and {@see org.activeio.net.TcpSynchChannelServer} objects that use SSL. + * A SslSynchChannelFactory creates {@see org.apache.activeio.net.TcpSynchChannel} + * and {@see org.apache.activeio.net.TcpSynchChannelServer} objects that use SSL. * * @version $Revision$ / Modified: incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/sync/multicast/MulticastSocketSyncChannel.java URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/sync/multicast/MulticastSocketSyncChannel.java?rev=358596&r1=358590&r2=358596&view=diff ============================================================================== --- incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/sync/multicast/MulticastSocketSyncChannel.java (original) +++ incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/sync/multicast/MulticastSocketSyncChannel.java Thu Dec 22 09:51:34 2005 @@ -14,13 +14,13 @@ See the License for the specific language governing permissions and * limitations under the License. / -package org.activeio.packet.sync.multicast; +package org.apache.activeio.packet.sync.multicast; import java.io.IOException; import java.net.InetAddress; import java.net.MulticastSocket; -import org.activeio.packet.sync.datagram.DatagramSocketSyncChannel; +import org.apache.activeio.packet.sync.datagram.DatagramSocketSyncChannel; /* Modified: incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/sync/multicast/MulticastSocketSyncChannelFactory.java URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/sync/multicast/MulticastSocketSyncChannelFactory.java?rev=358596&r1=358590&r2=358596&view=diff ============================================================================== --- incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/sync/multicast/MulticastSocketSyncChannelFactory.java (original) +++ incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/sync/multicast/MulticastSocketSyncChannelFactory.java Thu Dec 22 09:51:34 2005 @@ -14,15 +14,15 @@ * See the License for the specific language governing permissions and * limitations under the License. / -package org.activeio.packet.sync.multicast; +package org.apache.activeio.packet.sync.multicast; import java.io.IOException; import java.net.InetAddress; import java.net.MulticastSocket; import java.net.URI; -import org.activeio.packet.sync.SyncChannel; -import org.activeio.packet.sync.SyncChannelServer; +import org.apache.activeio.packet.sync.SyncChannel; +import org.apache.activeio.packet.sync.SyncChannelServer; /* Modified: incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/sync/nio/NIOBaseChannel.java URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/sync/nio/NIOBaseChannel.java?rev=358596&r1=358590&r2=358596&view=diff ============================================================================== --- incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/sync/nio/NIOBaseChannel.java (original) +++ incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/sync/nio/NIOBaseChannel.java Thu Dec 22 09:51:34 2005 @@ -15,7 +15,7 @@ * limitations under the License. / -package org.activeio.packet.sync.nio; +package org.apache.activeio.packet.sync.nio; import java.io.IOException; import java.net.InetAddress; @@ -25,8 +25,8 @@ import java.nio.ByteBuffer; import java.nio.channels.SocketChannel; -import org.activeio.packet.ByteBufferPacket; -import org.activeio.stream.sync.socket.SocketMetadata; +import org.apache.activeio.packet.ByteBufferPacket; +import org.apache.activeio.stream.sync.socket.SocketMetadata; /* * Base class for the Async and Sync implementations of NIO channels. @@ -95,7 +95,7 @@ } /** - * @see org.activeio.Channel#flush() + * @see org.apache.activeio.Channel#flush() / public void flush() throws IOException { } Modified: incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/sync/nio/NIOSyncChannel.java URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/sync/nio/NIOSyncChannel.java?rev=358596&r1=358590&r2=358596&view=diff ============================================================================== --- incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/sync/nio/NIOSyncChannel.java (original) +++ incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/sync/nio/NIOSyncChannel.java Thu Dec 22 09:51:34 2005 @@ -15,23 +15,23 @@ limitations under the License. / -package org.activeio.packet.sync.nio; +package org.apache.activeio.packet.sync.nio; import java.io.IOException; import java.net.SocketTimeoutException; import java.nio.ByteBuffer; import java.nio.channels.SocketChannel; -import org.activeio.packet.ByteBufferPacket; -import org.activeio.packet.ByteSequence; -import org.activeio.packet.EOSPacket; -import org.activeio.packet.EmptyPacket; -import org.activeio.packet.Packet; -import org.activeio.packet.sync.SyncChannel; -import org.activeio.packet.sync.SyncChannelServer; +import org.apache.activeio.packet.ByteBufferPacket; +import org.apache.activeio.packet.ByteSequence; +import org.apache.activeio.packet.EOSPacket; +import org.apache.activeio.packet.EmptyPacket; +import org.apache.activeio.packet.Packet; +import org.apache.activeio.packet.sync.SyncChannel; +import org.apache.activeio.packet.sync.SyncChannelServer; /* - * A {@see org.activeio.SynchChannel} implementation that uses a {@see java.nio.channels.SocketChannel} + * A {@see org.apache.activeio.SynchChannel} implementation that uses a {@see java.nio.channels.SocketChannel} * to talk to the network. * * Using a SocketChannelSynchChannel should be more efficient than using a SocketSynchChannel since Modified: incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/sync/nio/NIOSyncChannelFactory.java URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/sync/nio/NIOSyncChannelFactory.java?rev=358596&r1=358590&r2=358596&view=diff ============================================================================== --- incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/sync/nio/NIOSyncChannelFactory.java (original) +++ incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/sync/nio/NIOSyncChannelFactory.java Thu Dec 22 09:51:34 2005 @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. / -package org.activeio.packet.sync.nio; +package org.apache.activeio.packet.sync.nio; import java.io.IOException; import java.net.InetAddress; @@ -24,22 +24,22 @@ import java.nio.channels.ServerSocketChannel; import java.nio.channels.SocketChannel; -import org.activeio.packet.ByteBufferPacket; -import org.activeio.packet.sync.SyncChannel; -import org.activeio.packet.sync.SyncChannelFactory; -import org.activeio.packet.sync.SyncChannelServer; -import org.activeio.packet.sync.filter.WriteBufferedSyncChannel; -import org.activeio.util.URISupport; +import org.apache.activeio.packet.ByteBufferPacket; +import org.apache.activeio.packet.sync.SyncChannel; +import org.apache.activeio.packet.sync.SyncChannelFactory; +import org.apache.activeio.packet.sync.SyncChannelServer; +import org.apache.activeio.packet.sync.filter.WriteBufferedSyncChannel; +import org.apache.activeio.util.URISupport; /* - * A TcpSynchChannelFactory creates {@see org.activeio.net.TcpSynchChannel} - * and {@see org.activeio.net.TcpSynchChannelServer} objects. + * A TcpSynchChannelFactory creates {@see org.apache.activeio.net.TcpSynchChannel} + * and {@see org.apache.activeio.net.TcpSynchChannelServer} objects. * * @version $Revision$ / public class NIOSyncChannelFactory implements SyncChannelFactory { - protected static final int DEFAULT_BUFFER_SIZE = Integer.parseInt(System.getProperty("org.activeio.net.nio.BufferSize", ""+(641024))); + protected static final int DEFAULT_BUFFER_SIZE = Integer.parseInt(System.getProperty("org.apache.activeio.net.nio.BufferSize", ""+(641024))); protected static final int DEFAULT_BACKLOG = 500; boolean useDirectBuffers = true; @@ -58,7 +58,7 @@ /* * Uses the {@param location}'s host and port to create a tcp connection to a remote host. * - * @see org.activeio.SynchChannelFactory#openSyncChannel(java.net.URI) + * @see org.apache.activeio.SynchChannelFactory#openSyncChannel(java.net.URI) / public SyncChannel openSyncChannel(URI location) throws IOException { SocketChannel channel = SocketChannel.open(); @@ -82,7 +82,7 @@ /* * Binds a server socket a the {@param location}'s port. * - * @see org.activeio.SynchChannelFactory#bindSynchChannel(java.net.URI) + * @see org.apache.activeio.SynchChannelFactory#bindSynchChannel(java.net.URI) / public SyncChannelServer bindSyncChannel(URI bindURI) throws IOException { Modified: incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/sync/nio/NIOSyncChannelServer.java URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/sync/nio/NIOSyncChannelServer.java?rev=358596&r1=358590&r2=358596&view=diff ============================================================================== --- incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/sync/nio/NIOSyncChannelServer.java (original) +++ incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/sync/nio/NIOSyncChannelServer.java Thu Dec 22 09:51:34 2005 @@ -15,22 +15,22 @@ limitations under the License. / -package org.activeio.packet.sync.nio; +package org.apache.activeio.packet.sync.nio; import java.io.IOException; import java.net.URI; import java.nio.channels.ServerSocketChannel; -import org.activeio.Channel; -import org.activeio.packet.ByteBufferPacket; -import org.activeio.packet.sync.SyncChannel; -import org.activeio.packet.sync.filter.WriteBufferedSyncChannel; -import org.activeio.packet.sync.socket.SocketSyncChannelServer; -import org.activeio.stream.sync.socket.SocketStreamChannel; +import org.apache.activeio.Channel; +import org.apache.activeio.packet.ByteBufferPacket; +import org.apache.activeio.packet.sync.SyncChannel; +import org.apache.activeio.packet.sync.filter.WriteBufferedSyncChannel; +import org.apache.activeio.packet.sync.socket.SocketSyncChannelServer; +import org.apache.activeio.stream.sync.socket.SocketStreamChannel; /* * A SynchChannelServer that creates - * {@see org.activeio.net.TcpSynchChannel}objects from accepted + * {@see org.apache.activeio.net.TcpSynchChannel}objects from accepted * tcp socket connections. * * @version $Revision$ Modified: incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/sync/socket/SocketSyncChannel.java URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/sync/socket/SocketSyncChannel.java?rev=358596&r1=358590&r2=358596&view=diff ============================================================================== --- incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/sync/socket/SocketSyncChannel.java (original) +++ incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/sync/socket/SocketSyncChannel.java Thu Dec 22 09:51:34 2005 @@ -15,7 +15,7 @@ * limitations under the License. / -package org.activeio.packet.sync.socket; +package org.apache.activeio.packet.sync.socket; import java.io.IOException; import java.io.InputStream; @@ -23,17 +23,17 @@ import java.net.Socket; import java.net.SocketTimeoutException; -import org.activeio.packet.ByteArrayPacket; -import org.activeio.packet.ByteSequence; -import org.activeio.packet.EOSPacket; -import org.activeio.packet.EmptyPacket; -import org.activeio.packet.Packet; -import org.activeio.packet.sync.SyncChannel; -import org.activeio.packet.sync.SyncChannelServer; -import org.activeio.stream.sync.socket.SocketStreamChannel; +import org.apache.activeio.packet.ByteArrayPacket; +import org.apache.activeio.packet.ByteSequence; +import org.apache.activeio.packet.EOSPacket; +import org.apache.activeio.packet.EmptyPacket; +import org.apache.activeio.packet.Packet; +import org.apache.activeio.packet.sync.SyncChannel; +import org.apache.activeio.packet.sync.SyncChannelServer; +import org.apache.activeio.stream.sync.socket.SocketStreamChannel; /* - * A {@see org.activeio.SynchChannel} implementation that uses a {@see java.net.Socket} + * A {@see org.apache.activeio.SynchChannel} implementation that uses a {@see java.net.Socket} * to talk to the network. * * @version $Revision$ @@ -59,9 +59,9 @@ } /** - * @see org.activeio.SynchChannel#read(long) + * @see org.apache.activeio.SynchChannel#read(long) / - synchronized public org.activeio.packet.Packet read(long timeout) throws IOException { + synchronized public org.apache.activeio.packet.Packet read(long timeout) throws IOException { try { if( timeout==SyncChannelServer.WAIT_FOREVER_TIMEOUT ) @@ -104,21 +104,21 @@ /* - * @see org.activeio.Channel#write(org.activeio.packet.Packet) + * @see org.apache.activeio.Channel#write(org.apache.activeio.packet.Packet) / public void write(Packet packet) throws IOException { packet.writeTo(os); } /* - * @see org.activeio.Channel#flush() + * @see org.apache.activeio.Channel#flush() / public void flush() throws IOException { os.flush(); } /* - * @see org.activeio.Disposable#dispose() + * @see org.apache.activeio.Disposable#dispose() / public void dispose() { channel.dispose(); Modified: incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/sync/socket/SocketSyncChannelFactory.java URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/sync/socket/SocketSyncChannelFactory.java?rev=358596&r1=358590&r2=358596&view=diff ============================================================================== --- incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/sync/socket/SocketSyncChannelFactory.java (original) +++ incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/sync/socket/SocketSyncChannelFactory.java Thu Dec 22 09:51:34 2005 @@ -14,7 +14,7 @@ See the License for the specific language governing permissions and * limitations under the License. / -package org.activeio.packet.sync.socket; +package org.apache.activeio.packet.sync.socket; import java.io.IOException; import java.net.URI; @@ -22,17 +22,17 @@ import javax.net.ServerSocketFactory; import javax.net.SocketFactory; -import org.activeio.packet.sync.SyncChannel; -import org.activeio.packet.sync.SyncChannelFactory; -import org.activeio.packet.sync.SyncChannelServer; -import org.activeio.stream.sync.StreamChannelServer; -import org.activeio.stream.sync.socket.SocketStreamChannel; -import org.activeio.stream.sync.socket.SocketStreamChannelFactory; -import org.activeio.stream.sync.socket.SocketStreamChannelServer; +import org.apache.activeio.packet.sync.SyncChannel; +import org.apache.activeio.packet.sync.SyncChannelFactory; +import org.apache.activeio.packet.sync.SyncChannelServer; +import org.apache.activeio.stream.sync.StreamChannelServer; +import org.apache.activeio.stream.sync.socket.SocketStreamChannel; +import org.apache.activeio.stream.sync.socket.SocketStreamChannelFactory; +import org.apache.activeio.stream.sync.socket.SocketStreamChannelServer; /* - * A TcpSynchChannelFactory creates {@see org.activeio.net.TcpSynchChannel} - * and {@see org.activeio.net.TcpSynchChannelServer} objects. + * A TcpSynchChannelFactory creates {@see org.apache.activeio.net.TcpSynchChannel} + * and {@see org.apache.activeio.net.TcpSynchChannelServer} objects. * * @version $Revision$ / @@ -51,7 +51,7 @@ /* * Uses the {@param location}'s host and port to create a tcp connection to a remote host. * - * @see org.activeio.SyncChannelFactory#openSyncChannel(java.net.URI) + * @see org.apache.activeio.SyncChannelFactory#openSyncChannel(java.net.URI) / public SyncChannel openSyncChannel(URI location) throws IOException { SocketStreamChannel channel = (SocketStreamChannel) factory.openStreamChannel(location); @@ -70,7 +70,7 @@ /* * Binds a server socket a the {@param bindURI}'s port. * - * @see org.activeio.SyncChannelFactory#bindSyncChannel(java.net.URI) + * @see org.apache.activeio.SyncChannelFactory#bindSyncChannel(java.net.URI) / public SyncChannelServer bindSyncChannel(URI bindURI) throws IOException { StreamChannelServer server = factory.bindStreamChannel(bindURI); Modified: incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/sync/socket/SocketSyncChannelServer.java URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/sync/socket/SocketSyncChannelServer.java?rev=358596&r1=358590&r2=358596&view=diff ============================================================================== --- incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/sync/socket/SocketSyncChannelServer.java (original) +++ incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/sync/socket/SocketSyncChannelServer.java Thu Dec 22 09:51:34 2005 @@ -15,20 +15,20 @@ limitations under the License. / -package org.activeio.packet.sync.socket; +package org.apache.activeio.packet.sync.socket; import java.io.IOException; import java.net.ServerSocket; import java.net.URI; -import org.activeio.Channel; -import org.activeio.packet.sync.SyncChannelServer; -import org.activeio.stream.sync.socket.SocketStreamChannel; -import org.activeio.stream.sync.socket.SocketStreamChannelServer; +import org.apache.activeio.Channel; +import org.apache.activeio.packet.sync.SyncChannelServer; +import org.apache.activeio.stream.sync.socket.SocketStreamChannel; +import org.apache.activeio.stream.sync.socket.SocketStreamChannelServer; /* * A SynchChannelServer that creates - * {@see org.activeio.net.TcpSynchChannel}objects from accepted + * {@see org.apache.activeio.net.TcpSynchChannel}objects from accepted * TCP socket connections. * * @version $Revision$ @@ -58,7 +58,7 @@ } /** - * @see org.activeio.Disposable#dispose() + * @see org.apache.activeio.Disposable#dispose() / public void dispose() { server.dispose(); Modified: incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/sync/ssl/SslSocketSyncChannelFactory.java URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/sync/ssl/SslSocketSyncChannelFactory.java?rev=358596&r1=358590&r2=358596&view=diff ============================================================================== --- incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/sync/ssl/SslSocketSyncChannelFactory.java (original) +++ incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/sync/ssl/SslSocketSyncChannelFactory.java Thu Dec 22 09:51:34 2005 @@ -14,16 +14,16 @@ See the License for the specific language governing permissions and * limitations under the License. / -package org.activeio.packet.sync.ssl; +package org.apache.activeio.packet.sync.ssl; import javax.net.ssl.SSLServerSocketFactory; import javax.net.ssl.SSLSocketFactory; -import org.activeio.packet.sync.socket.SocketSyncChannelFactory; +import org.apache.activeio.packet.sync.socket.SocketSyncChannelFactory; /* - * A SslSynchChannelFactory creates {@see org.activeio.net.TcpSynchChannel} - * and {@see org.activeio.net.TcpSynchChannelServer} objects that use SSL. + * A SslSynchChannelFactory creates {@see org.apache.activeio.net.TcpSynchChannel} + * and {@see org.apache.activeio.net.TcpSynchChannelServer} objects that use SSL. * * @version $Revision$ / Copied: incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/stream/sync/StreamChannel.java (from r358590, incubator/activemq/trunk/activeio/activeio-core/src/java/org/activeio/stream/sync/StreamChannel.java) URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/stream/sync/StreamChannel.java?p2=incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/stream/sync/StreamChannel.java&p1=incubator/activemq/trunk/activeio/activeio-core/src/java/org/activeio/stream/sync/StreamChannel.java&r1=358590&r2=358596&rev=358596&view=diff ============================================================================== --- incubator/activemq/trunk/activeio/activeio-core/src/java/org/activeio/stream/sync/StreamChannel.java (original) +++ incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/stream/sync/StreamChannel.java Thu Dec 22 09:51:34 2005 @@ -15,13 +15,13 @@ limitations under the License. / -package org.activeio.stream.sync; +package org.apache.activeio.stream.sync; import java.io.IOException; import java.io.InputStream; import java.io.OutputStream; -import org.activeio.Channel; +import org.apache.activeio.Channel; /* Copied: incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/stream/sync/StreamChannelFactory.java (from r358590, incubator/activemq/trunk/activeio/activeio-core/src/java/org/activeio/stream/sync/StreamChannelFactory.java) URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/stream/sync/StreamChannelFactory.java?p2=incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/stream/sync/StreamChannelFactory.java&p1=incubator/activemq/trunk/activeio/activeio-core/src/java/org/activeio/stream/sync/StreamChannelFactory.java&r1=358590&r2=358596&rev=358596&view=diff ============================================================================== --- incubator/activemq/trunk/activeio/activeio-core/src/java/org/activeio/stream/sync/StreamChannelFactory.java (original) +++ incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/stream/sync/StreamChannelFactory.java Thu Dec 22 09:51:34 2005 @@ -14,14 +14,14 @@ * See the License for the specific language governing permissions and * limitations under the License. / -package org.activeio.stream.sync; +package org.apache.activeio.stream.sync; import java.io.IOException; import java.net.URI; /* - * StreamChannelFactory objects can create {@see org.activeio.StreamChannel} - * and {@see org.activeio.StreamChannelServer} objects. + * StreamChannelFactory objects can create {@see org.apache.activeio.StreamChannel} + * and {@see org.apache.activeio.StreamChannelServer} objects. * * @version $Revision$ / Copied: incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/stream/sync/StreamChannelServer.java (from r358590, incubator/activemq/trunk/activeio/activeio-core/src/java/org/activeio/stream/sync/StreamChannelServer.java) URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/stream/sync/StreamChannelServer.java?p2=incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/stream/sync/StreamChannelServer.java&p1=incubator/activemq/trunk/activeio/activeio-core/src/java/org/activeio/stream/sync/StreamChannelServer.java&r1=358590&r2=358596&rev=358596&view=diff ============================================================================== --- incubator/activemq/trunk/activeio/activeio-core/src/java/org/activeio/stream/sync/StreamChannelServer.java (original) +++ incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/stream/sync/StreamChannelServer.java Thu Dec 22 09:51:34 2005 @@ -14,18 +14,18 @@ See the License for the specific language governing permissions and * limitations under the License. / -package org.activeio.stream.sync; +package org.apache.activeio.stream.sync; import java.io.IOException; -import org.activeio.Channel; -import org.activeio.ChannelServer; +import org.apache.activeio.Channel; +import org.apache.activeio.ChannelServer; /* * A StreamChannelServer object provides an <code>accept</code> method to synchronously - * accept and create {@see org.activeio.channel.Channel} objects. + * accept and create {@see org.apache.activeio.channel.Channel} objects. * * @version $Revision$ / Modified: incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/stream/sync/socket/SocketMetadata.java URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/stream/sync/socket/SocketMetadata.java?rev=358596&r1=358590&r2=358596&view=diff ============================================================================== --- incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/stream/sync/socket/SocketMetadata.java (original) +++ incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/stream/sync/socket/SocketMetadata.java Thu Dec 22 09:51:34 2005 @@ -15,7 +15,7 @@ limitations under the License. * */ -package org.activeio.stream.sync.socket; +package org.apache.activeio.stream.sync.socket; import java.net.InetAddress; import java.net.SocketAddress; Modified: incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/stream/sync/socket/SocketStreamChannel.java URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/stream/sync/socket/SocketStreamChannel.java?rev=358596&r1=358590&r2=358596&view=diff ============================================================================== --- incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/stream/sync/socket/SocketStreamChannel.java (original) +++ incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/stream/sync/socket/SocketStreamChannel.java Thu Dec 22 09:51:34 2005 @@ -15,7 +15,7 @@ limitations under the License. / -package org.activeio.stream.sync.socket; +package org.apache.activeio.stream.sync.socket; import java.io.IOException; import java.io.InputStream; @@ -25,10 +25,10 @@ import java.net.SocketAddress; import java.net.SocketException; -import org.activeio.stream.sync.StreamChannel; +import org.apache.activeio.stream.sync.StreamChannel; /* - * A {@see org.activeio.StreamChannel} implementation that uses a {@see java.net.Socket} + * A {@see org.apache.activeio.StreamChannel} implementation that uses a {@see java.net.Socket} * to talk to the network. * * @version $Revision$ @@ -55,7 +55,7 @@ } /** - * @see org.activeio.Disposable#dispose() + * @see org.apache.activeio.Disposable#dispose() / public void dispose() { if (disposed) Modified: incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/stream/sync/socket/SocketStreamChannelFactory.java URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/stream/sync/socket/SocketStreamChannelFactory.java?rev=358596&r1=358590&r2=358596&view=diff ============================================================================== --- incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/stream/sync/socket/SocketStreamChannelFactory.java (original) +++ incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/stream/sync/socket/SocketStreamChannelFactory.java Thu Dec 22 09:51:34 2005 @@ -14,7 +14,7 @@ See the License for the specific language governing permissions and * limitations under the License. / -package org.activeio.stream.sync.socket; +package org.apache.activeio.stream.sync.socket; import java.io.IOException; import java.net.InetAddress; @@ -26,14 +26,14 @@ import javax.net.ServerSocketFactory; import javax.net.SocketFactory; -import org.activeio.stream.sync.StreamChannel; -import org.activeio.stream.sync.StreamChannelFactory; -import org.activeio.stream.sync.StreamChannelServer; -import org.activeio.util.URISupport; +import org.apache.activeio.stream.sync.StreamChannel; +import org.apache.activeio.stream.sync.StreamChannelFactory; +import org.apache.activeio.stream.sync.StreamChannelServer; +import org.apache.activeio.util.URISupport; /* - * A TcpStreamChannelFactory creates {@see org.activeio.net.TcpStreamChannel} - * and {@see org.activeio.net.TcpStreamChannelServer} objects. + * A TcpStreamChannelFactory creates {@see org.apache.activeio.net.TcpStreamChannel} + * and {@see org.apache.activeio.net.TcpStreamChannelServer} objects. * * @version $Revision$ / @@ -57,7 +57,7 @@ /* * Uses the {@param location}'s host and port to create a tcp connection to a remote host. * - * @see org.activeio.StreamChannelFactory#openStreamChannel(java.net.URI) + * @see org.apache.activeio.StreamChannelFactory#openStreamChannel(java.net.URI) / public StreamChannel openStreamChannel(URI location) throws IOException { Socket socket=null; @@ -77,7 +77,7 @@ /* * Binds a server socket a the {@param bindURI}'s port. * - * @see org.activeio.StreamChannelFactory#bindStreamChannel(java.net.URI) + * @see org.apache.activeio.StreamChannelFactory#bindStreamChannel(java.net.URI) / public StreamChannelServer bindStreamChannel(URI bindURI) throws IOException { Modified: incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/stream/sync/socket/SocketStreamChannelServer.java URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/stream/sync/socket/SocketStreamChannelServer.java?rev=358596&r1=358590&r2=358596&view=diff ============================================================================== --- incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/stream/sync/socket/SocketStreamChannelServer.java (original) +++ incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/stream/sync/socket/SocketStreamChannelServer.java Thu Dec 22 09:51:34 2005 @@ -15,7 +15,7 @@ limitations under the License. / -package org.activeio.stream.sync.socket; +package org.apache.activeio.stream.sync.socket; import java.io.IOException; import java.net.ServerSocket; @@ -24,12 +24,12 @@ import java.net.SocketTimeoutException; import java.net.URI; -import org.activeio.Channel; -import org.activeio.stream.sync.StreamChannelServer; +import org.apache.activeio.Channel; +import org.apache.activeio.stream.sync.StreamChannelServer; /* * A StreamChannelServer that creates - * {@see org.activeio.net.TcpStreamChannel}objects from accepted + * {@see org.apache.activeio.net.TcpStreamChannel}objects from accepted * tcp socket connections. * * @version $Revision$ @@ -82,7 +82,7 @@ } /** - * @see org.activeio.Disposable#dispose() + * @see org.apache.activeio.Disposable#dispose() / public void dispose() { if (serverSocket == null) Modified: incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/util/ByteArrayInputStream.java URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/util/ByteArrayInputStream.java?rev=358596&r1=358590&r2=358596&view=diff ============================================================================== --- incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/util/ByteArrayInputStream.java (original) +++ incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/util/ByteArrayInputStream.java Thu Dec 22 09:51:34 2005 @@ -14,12 +14,12 @@ See the License for the specific language governing permissions and * limitations under the License. / -package org.activeio.util; +package org.apache.activeio.util; import java.io.IOException; import java.io.InputStream; -import org.activeio.packet.ByteSequence; +import org.apache.activeio.packet.ByteSequence; /* * Very similar to the java.io.ByteArrayInputStream but this version Modified: incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/util/ByteArrayOutputStream.java URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/util/ByteArrayOutputStream.java?rev=358596&r1=358590&r2=358596&view=diff ============================================================================== --- incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/util/ByteArrayOutputStream.java (original) +++ incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/util/ByteArrayOutputStream.java Thu Dec 22 09:51:34 2005 @@ -14,11 +14,11 @@ * See the License for the specific language governing permissions and * limitations under the License. / -package org.activeio.util; +package org.apache.activeio.util; import java.io.OutputStream; -import org.activeio.packet.ByteSequence; +import org.apache.activeio.packet.ByteSequence; /* * Very similar to the java.io.ByteArrayOutputStream but this version Modified: incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/util/FactoryFinder.java URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/util/FactoryFinder.java?rev=358596&r1=358590&r2=358596&view=diff ============================================================================== --- incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/util/FactoryFinder.java (original) +++ incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/util/FactoryFinder.java Thu Dec 22 09:51:34 2005 @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. / -package org.activeio.util; +package org.apache.activeio.util; import java.io.BufferedInputStream; import java.io.IOException; Modified: incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/util/PacketAggregator.java URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/util/PacketAggregator.java?rev=358596&r1=358590&r2=358596&view=diff ============================================================================== --- incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/util/PacketAggregator.java (original) +++ incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/util/PacketAggregator.java Thu Dec 22 09:51:34 2005 @@ -14,15 +14,15 @@ See the License for the specific language governing permissions and * limitations under the License. / -package org.activeio.util; +package org.apache.activeio.util; import java.io.IOException; -import org.activeio.packet.AppendedPacket; -import org.activeio.packet.ByteArrayPacket; -import org.activeio.packet.EOSPacket; -import org.activeio.packet.Packet; -import org.activeio.packet.PacketData; +import org.apache.activeio.packet.AppendedPacket; +import org.apache.activeio.packet.ByteArrayPacket; +import org.apache.activeio.packet.EOSPacket; +import org.apache.activeio.packet.Packet; +import org.apache.activeio.packet.PacketData; /* * @version $Revision$ Modified: incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/util/URISupport.java URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/util/URISupport.java?rev=358596&r1=358590&r2=358596&view=diff ============================================================================== --- incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/util/URISupport.java (original) +++ incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/util/URISupport.java Thu Dec 22 09:51:34 2005 @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. / -package org.activeio.util; +package org.apache.activeio.util; import java.net.URI; import java.net.URISyntaxException; Copied: incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/xnet/ServerService.java (from r358590, incubator/activemq/trunk/activeio/activeio-core/src/java/org/activeio/xnet/ServerService.java) URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/xnet/ServerService.java?p2=incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/xnet/ServerService.java&p1=incubator/activemq/trunk/activeio/activeio-core/src/java/org/activeio/xnet/ServerService.java&r1=358590&r2=358596&rev=358596&view=diff ============================================================================== --- incubator/activemq/trunk/activeio/activeio-core/src/java/org/activeio/xnet/ServerService.java (original) +++ incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/xnet/ServerService.java Thu Dec 22 09:51:34 2005 @@ -14,7 +14,7 @@ See the License for the specific language governing permissions and * limitations under the License. */ -package org.activeio.xnet; +package org.apache.activeio.xnet; import java.util.Properties;
Mime	Unnamed text/plain (inline, 7-Bit, 87953 bytes)
	View raw message