summaryrefslogtreecommitdiff
path: root/qpid/java/common/src/main/java/org/apache/qpid/transport/network/io
Commit message (Collapse)AuthorAgeFilesLines
* Attempt one at merge from r1021441:HEADgrkvlt-network-20101013Andrew Donald Kennedy2010-12-061-4/+4
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/grkvlt-network-20101013@1042697 13f79535-47bb-0310-9956-ffa450edef68
* Minor updatesAndrew Donald Kennedy2010-10-133-12/+10
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/grkvlt-network-20101013@1022275 13f79535-47bb-0310-9956-ffa450edef68
* Network layer changes, and then some. Actual commit history preserved ↵Andrew Donald Kennedy2010-10-139-794/+347
| | | | | | elsewhere... git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/grkvlt-network-20101013@1022127 13f79535-47bb-0310-9956-ffa450edef68
* Add the ASF License to various classes currently missing itRobert Gemmell2010-06-021-0/+20
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@950740 13f79535-47bb-0310-9956-ffa450edef68
* Did some general refactoring to support QPID-2444 QPID-2445 QPID-2446 QPID-2447Rajith Muditha Attapattu2010-03-195-13/+148
| | | | | | | | | | 1. Provided a mechanism to register any transport using qpid.transport jvm arg. 2. Created a TransportBuilder class which abstracts the building of receiver and sender pipes. 3. Created a ConnectionSettings class that contains all connection level parameters. This enhancement is also required to support QPID-2343 4. Added SecurityLayer class that adds the nessacery codecs and cordination to retrive the userID for mechanisms like EXTERNAL git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@925261 13f79535-47bb-0310-9956-ffa450edef68
* Updated the references to the new SSL package.Rajith Muditha Attapattu2010-03-151-2/+2
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@923434 13f79535-47bb-0310-9956-ffa450edef68
* Fixed an error in retrieving the SSL parameterRajith Muditha Attapattu2010-02-111-0/+2
| | | | | | | Added a log message in IoTransport to denote successfull creation of SSL Sender and Receiver git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@909150 13f79535-47bb-0310-9956-ffa450edef68
* QPID-2379 : Initial work on adding QMF and federation to the Java BrokerRobert Godfrey2010-01-311-2/+2
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@904934 13f79535-47bb-0310-9956-ffa450edef68
* The commit contains fixes for QPID-2351, QPID-2350 and some ground work for ↵Rajith Muditha Attapattu2010-01-211-1/+1
| | | | | | | | | | | | | | QPID-2352 - Modified Connection.java to add more than one ConnectionListener. This was done to facilitate the SASL encryption patch - QPID-2352. - Changed the access modifier for getSaslClient method to "public" to allow the SaslClient to be retrieved by the SASL encryption code -QPID-2352. - Introduced ConnectionSettings object to hold all the configuration options. Previous constructor methods remains unchanged. - Modified the ClientDelegate to handle heartbeat and idelTimeout value properly. - Added support to specify config options via the connection URL - QPID-2351 - Added support to handle the heartbeat/idle_timeout options properly in the 0-10 code - QPID-2350. However once QPID-2343 is completed, the code will be further simplified. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@901506 13f79535-47bb-0310-9956-ffa450edef68
* Changed the setIdleTimeout method to take an int instead of a long.Rajith Muditha Attapattu2010-01-191-4/+2
| | | | | | | | The socket interface takes the so_timeout as an int and also the AMQP heartbeat interval is taken as an int. This change will help simplify the code that handles heartbeats. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@901000 13f79535-47bb-0310-9956-ffa450edef68
* QPID-2192: remove extraneous printStackTrace()sAidan Skinner2009-12-021-1/+0
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@886031 13f79535-47bb-0310-9956-ffa450edef68
* Merged from java-broker-0-10 branchRobert Godfrey2009-10-251-0/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@829675 13f79535-47bb-0310-9956-ffa450edef68
* This is related to QPID-1853. Since the socket is being closed inside the ↵Rajith Muditha Attapattu2009-05-141-1/+0
| | | | | | finnaly block we can remove the socket.close after the while loop inside the run method. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@774812 13f79535-47bb-0310-9956-ffa450edef68
* This is a fix for QPID-1853. We now close the socket in the finnally block.Rajith Muditha Attapattu2009-05-131-0/+8
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@774297 13f79535-47bb-0310-9956-ffa450edef68
* This is related to QPID-1609.Rajith Muditha Attapattu2009-01-232-7/+16
| | | | | | | | Currently we only check idle state on the incomming side. In the future we plan to add code to send a heartbeat when we reach the idle state on the outgoing side. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@737125 13f79535-47bb-0310-9956-ffa450edef68
* This is related to QPID-1479Rajith Muditha Attapattu2009-01-132-16/+40
| | | | | | | This commit contains the core classes for adding the thread abstraction patch git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@734205 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1547: ignore socket closed exceptions if shutdownInput is brokenRafael H. Schloming2008-12-231-3/+12
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@729021 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1499 : Modification to IoAcceptor so ConnectionTest can close the open ↵Martin Ritchie2008-12-021-0/+11
| | | | | | SocketServer. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@722669 13f79535-47bb-0310-9956-ffa450edef68
* Appologies for the sudden checkin without notice, close to the release cycle.Rajith Muditha Attapattu2008-11-212-37/+16
| | | | | | | Reverting the changes back. Will attach a patch and commit after the release. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@719657 13f79535-47bb-0310-9956-ffa450edef68
* This is related to QPID-1479.Rajith Muditha Attapattu2008-11-212-16/+37
| | | | | | | | | | | | | | | For starters I have changed the IoSender.java IoReceiver.java and AMQSession.java#Dispatcher to use the Thread factory to create the threads they require. The ThreadFactory has two implimentations, the default being the java.lang.Threads. The other is the RealtimeThreadFactory which uses reflection to create threads with a specific priority. -Dqpid.thread_factory=<thread_factory_class> will decide which thread factory should be loaded. -Dqpid.rt_thread_priority=<int> specifies the gloabl real time thread priority and defaults to 20. You could also set individual thread priorities by adding the nessacery config+code changes. I have also changed the Testkit and QpidBench to use the Thread factory so you could use them for testing/benchmarking work on RT JVMs. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@719628 13f79535-47bb-0310-9956-ffa450edef68
* This check in is related to QPID-1296Rajith Muditha Attapattu2008-11-042-25/+67
| | | | | | | | | Since SSLSocket didn't support shutdownInput method, I added an SSL layer on top of the TCP transport. The SSL layer uses the SSLEngine class introduced in java 1.5. This Layer can be used with minimum code changes to the the nio transport as well. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@711455 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1339:Rafael H. Schloming2008-10-271-6/+7
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | - Modified QpidTestCase to start/stop multiple brokers for failover testing. - Modified QpidTestCase to substitute port variables into broker start/stop commands. - Modified test profiles to use the new port variables. - Modified QpidTestCase to permit multiple exclude files. - Modified test profiles to make use of a common exclude list: ExcludeList - Added ConnectionTest.testResumeEmptyReplayBuffer. - Made default exception handling for Connection and Session log the exception. - Added SenderExcetion to specifically signal problems with transmitting connection data. - Modified Session to catch and deal with connection send failures for sessions with positive expiry. - Modified FailoverBaseCase to work for non VM brokers. - Made FailoverTest fail if failover times out. - Modified JMS implementation to make use of the recently added low level session resume. - Unexcluded failover tests from 0-10 test profiles. - Excluded MultipleJCAProviderRegistrationTest due to its testing strategy resulting in spurious failure when running as part of the larger test suite. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@708093 13f79535-47bb-0310-9956-ffa450edef68
* This is for QPID-1296Rajith Muditha Attapattu2008-10-231-8/+21
| | | | | | | | | | | | | added a boolean to the connect method to indicate whether an SSL connection should be created. currently there seems to be two issues. 1. The shutdownInput method used in IoReceiver is not supported by the SSLSocket implementation. 2. I haven't able to get client side authentication working. For item 1 we may need to use nio classes to get around the issue. For item 2 I am yet to figure out the correct config options to get client side auth working. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@707453 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1339: support for low level session resumeRafael H. Schloming2008-10-231-6/+0
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@707241 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1339:Rafael H. Schloming2008-10-131-0/+5
| | | | | | | | | | | | | | | | | | | - Removed the Channel class in order to simplify the state management surrounding Sessions and Connections. - Consolidated the ChannelDelegate into the ConnectionDelegate. - Modified MethodDelegate to invoke a generic handle method as the default action for each dispatched method. - Modified the code generator to produce a separate ConnectionInvoker and SessionInvoker. - Modified the invoker template to use package level visibility for all controls rather than public visibility. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@704147 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1339: refactor of low level client API to permit connections to exist ↵Rafael H. Schloming2008-10-093-10/+5
| | | | | | in a disconnected state as well as to provide a central point from which to track session state git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@703208 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1258 add ASL to java files that were missing itAidan Skinner2008-08-221-0/+21
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@688094 13f79535-47bb-0310-9956-ffa450edef68
* qpid-1251: changed close method for closing the underlying socket on windows ↵Arnaud Simon2008-08-201-1/+8
| | | | | | only. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@687310 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1244: fix for NPE on broker initiated connection close, also preserve ↵Rafael H. Schloming2008-08-141-1/+1
| | | | | | the connection close text for better error reporting git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@686068 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1218: cleaned up the interface to IoTransport a bit; added IoAcceptor; ↵Rafael H. Schloming2008-08-092-55/+151
| | | | | | fixed Session tracking of sync point; default JAVA inside qpid-run git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@684182 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1218 Optionally use IoTransport, it's hot, but doesn't pass all the ↵Aidan Skinner2008-08-083-9/+141
| | | | | | tests yet. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@684016 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1222: round up the buffer size to the nearest power of twoRafael H. Schloming2008-08-061-2/+17
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@683437 13f79535-47bb-0310-9956-ffa450edef68
* Profiling driven changes:Rafael H. Schloming2008-08-052-25/+35
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | - made AMQShortString cache the toString() value - added static initializer to IoTransport to disable use of pooled byte buffers - modified IoSender to permit buffering - removed OutputHandler and eliminated intermediate Frame generation between Disassembler and Sender<ByteBuffer> (IoSender) - made Disassembler take advantage of IoSender's buffering - removed Header and Data as distinct protocol events, added Header and Body members to MessageTransfer - modified Assembler and Disassembler to decode/encode Header and Data directly to/from MessageTransfer - modified Disassembler to only write data if encoding of headers is successful - added Strings.toUTF8(String) -> byte[] to do proper UTF-8 encoding that is also fast for 7-bit ascii - modified JMSTextMessage to use the Strings.toUTF8 - modified QpidBench to only generate 7-bit ascii when using TextMessage git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@682887 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1207: fixed io transport close to ensure threads shutdown properlyRafael H. Schloming2008-07-313-23/+57
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@681474 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1072: renamed org.apache.qpidity -> org.apache.qpidRafael H. Schloming2008-07-293-0/+497
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@680803 13f79535-47bb-0310-9956-ffa450edef68
View Lorry Controller Status