Bumping versions by 0.0.1 after the Helium SR4 release

Change-Id: Id9da8eca6b8110e4e49de1eba99082f8cf730ea6
Signed-off-by: Thanh Ha <thanh.ha@linuxfoundation.org>

Applying the Helium SR4 release patch

Change-Id: I6141d32957328c3e350658023b73bdc094cb108a
Signed-off-by: Thanh Ha <thanh.ha@linuxfoundation.org>

Bug 3356 - Configurable ChannelOutboundQueue size

Change-Id: I1f623cc89e3f9efc6bc6560cf19b4967d1fed732
Signed-off-by: Michal Polkorab <michal.polkorab@pantheon.sk>

BUG 2905 TCP Options incorrect

OpenFlow requires latency related optimizations, not throughput
ones (in the TCP sense of this word).

Signed-off-by: Anton Ivanov <aivanov@brocade.com>

Bug 2866 - Fixed ipv6 address parsing

 - also added uni test with missing case

Change-Id: I4b0e15f1a1896ed63bc47ce326afea40ff18cc07
Signed-off-by: Michal Polkorab <michal.polkorab@pantheon.sk>

Bumping versions by 0.0.1 after the Helium SR3 release

Change-Id: Ib5c6bd3cd3eb9814d73e66211f3e023e36fe1717
Signed-off-by: Thanh Ha <thanh.ha@linuxfoundation.org>

Applying the Helium SR3 release patch

Change-Id: I5740a735d840af4c02e07164dd16046730c5e0eb
Signed-off-by: Thanh Ha <thanh.ha@linuxfoundation.org>

Bumping versions by 0.0.1 after the Helium SR2 release

Change-Id: Ib42d830260dc243dd5673810de0fe0810b2bdfb0
Signed-off-by: Thanh Ha <thanh.ha@linuxfoundation.org>

Applying the Helium SR2 release patch

Change-Id: I6d2923aed518224c344d0d899642d0e251770c74
Signed-off-by: Thanh Ha <thanh.ha@linuxfoundation.org>

Set root pom.xml <name> for Sonar

As mentioned on the mailing list Sonar uses the <name> field of the
pom.xml that is passed to the mvn command as the name of the project in
Sonar. In most cases this is the root pom.xml file in a project. This
patch sets the name to the project shortname.

https://lists.opendaylight.org/pipermail/discuss/2014-November/004024.html

Change-Id: Ia379d9ec23a58e464e8f68ea112779630819a8ba
Signed-off-by: Thanh Ha <thanh.ha@linuxfoundation.org>

Bug 2483 - Removed confusing WARN log on successful RPC

Change-Id: Ie73209b265267fed357f6a9b6d4ce93c12c51373
Signed-off-by: Michal Polkorab <michal.polkorab@pantheon.sk>

Merge "Test updated according to yangtools string validation change" into stable/helium

Test updated according to yangtools string validation change

Change-Id: I653095b4ab78af185a6343dcb7877b79c8c98e66
Signed-off-by: Michal Polkorab <michal.polkorab@pantheon.sk>

Merge "Test updated according to yangtools string validation change" into stable/helium

Test updated according to yangtools string validation change

Change-Id: I2c47a864433208ea31249b88cd815018981dec8d
Signed-off-by: Michal Polkorab <michal.polkorab@pantheon.sk>

Bumping versions by 0.0.1 after the Helium.1 release

Change-Id: Ia06dbc0712dcf694fc9262425859e2510dab072f
Signed-off-by: Thanh Ha <thanh.ha@linuxfoundation.org>

Applying the Helium.1 release patch

Change-Id: I2011903c8cee70bb6fa98a92e31a5392a8ac1852
Signed-off-by: Thanh Ha <thanh.ha@linuxfoundation.org>

Incrementing versions by 0.0.1 for post-helium stability branch

Change-Id: Ib2e0186d0cfff66a4705a83894d6b2793fc6b183
Signed-off-by: Michal Polkorab <michal.polkorab@pantheon.sk>

Changing .gitreview to use the stable/helium

Change-Id: Ib5c9631b57b30d3cf29deb63ae6f0bbdd9c13b6f
Signed-off-by: Michal Polkorab <michal.polkorab@pantheon.sk>

Applying the helium release patch for Openflow Protocol Library

Change-Id: Ia29127e7d2f6ea6e31250ae401e4c2e33a0c7971
Signed-off-by: Michal Polkorab <michal.polkorab@pantheon.sk>

Removed unused extensibility bundles

 - functionality of removed bundles is present in openflowplugin

Change-Id: I073d2de7e0a3c0dee92511e47c45e44e9be12e16
Signed-off-by: Michal Polkorab <michal.polkorab@pantheon.sk>

Bug 1935 - Double fireConnectionReady notification

 - in case of communication over TCP protocol the fireConnectionReady
   notification was incorrectly triggered twice

Change-Id: I23373a6130ebd30f4f183568e4ddda354976df3f
Signed-off-by: Michal Polkorab <michal.polkorab@pantheon.sk>

Improved test coverage

Change-Id: I0846432b14d880b17ccf1dad5759b3a1c1dcf2af
Signed-off-by: Michal Polkorab <michal.polkorab@pantheon.sk>

Fixed incorrect exception type on deserializer lookup

 - removed .toString() call from log
 - updated test to match functionality
 - lowered log level on (de)serializer overwriting

Change-Id: Ie58dc4e4d9bac76532a4df55170ed52e0a0e5fbc
Signed-off-by: Michal Polkorab <michal.polkorab@pantheon.sk>

Added warn log on same key registration

Change-Id: I7a42f674fa1e2fa4c027a480884ba785b6264646
Signed-off-by: Michal Polkorab <michal.polkorab@pantheon.sk>

SwitchConnectionProvider javadoc updated

Change-Id: I1a724de6b0abcbf42ee2bdf666aea8a4961d0386
Signed-off-by: Michal Polkorab <michal.polkorab@pantheon.sk>

BUG-1675: bump netty version

This patch depends on https://git.opendaylight.org/gerrit/10679.

Change-Id: Iafec7084afd6c364f9852b7ff76f7cb2f947a637
Signed-off-by: Robert Varga <rovarga@cisco.com>

Added missing extension registration methods + keys (serialization part)

Change-Id: I44bd91a975c8bd6e56e9c13aa152999d34c8546f
Signed-off-by: Michal Polkorab <michal.polkorab@pantheon.sk>

Added missing extension registration methods + keys (deserialization part)

Change-Id: Id997a3fc52ab8e4491ee74ba61bddec20d23c2d9
Signed-off-by: Michal Polkorab <michal.polkorab@pantheon.sk>

UDP support implementation

 - unit tests will be added in another change

Change-Id: I8b6fba59a82febf60c0ddfb97ef8e2e9267aff56
Signed-off-by: Michal Polkorab <michal.polkorab@pantheon.sk>

Allow to configure number of threads used by Netty's EventLoopGroups

Change-Id: I07e95b45069bcc3437add607cf5dc990f263eb0d
Signed-off-by: Michal Polkorab <michal.polkorab@pantheon.sk>

Added a get method for InetSocketAddress of a remote OF switch

Signed-off-by: Martin Sunal <msunal@cisco.com>

Fixed FIXME on MAC address serialization

 + Fix incorrect log message formatting

Change-Id: Ifc523e1e67e1e29ee3c1271995ca79d6edc8b223
Signed-off-by: Michal Polkorab <michal.polkorab@pantheon.sk>

Merge "Improve unit test coverage"

Improve unit test coverage

Change-Id: I374bcf2c76a4a3b6cba441dc0c0570be7855d8a9
Signed-off-by: Michal Polkorab <michal.polkorab@pantheon.sk>

Features.xml update

 - removed odl-yangtools-binding-generator feature as it is not needed

Change-Id: Ia6a31f0fd235536a87d86fbd3b47305aab44460c
Signed-off-by: Michal Polkorab <michal.polkorab@pantheon.sk>

Fix karaf features, and add testing for them.

Change-Id: I272e0b92099d68e72f30138fe42935495ddf7d94
Signed-off-by: Ed Warnicke <eaw@cisco.com>

More updates to sonar

- per-test reports
- integration test support
- findbugs reports

Change-Id: Ie6a8865551f3d4957be87ccef4b4820d30a1cbd1
Signed-off-by: Robert Varga <rovarga@cisco.com>

Fix UT coverage not reported in sonar

Just a couple of properties and making sure jacoco runs.

Change-Id: I75aeae7b74f5c7e94a0a237728dc2b6f0c4df090
Signed-off-by: Robert Varga <rovarga@cisco.com>

Created experimenter subtype for vendor's actions

ExperimenterActionSerializerKey has a new parameter which is type of vendor's action.
It allows to select right serializer directly in OFJava so a vendor does not need to care about it.
- created codec for Nicira match nxm_of_eth_type

Change-Id: Id9bc0f06820cab7b897eb710a70ddc3d6af13a45
Signed-off-by: Martin Sunal <msunal@cisco.com>

Nicira extensions in OpenFlowJava library

- creates and registers codecs(serializers & deserializers) for:
actions:
reg-load
reg-move
matches:
NXM_NX_REG(0-7)
NXM_NX_TUN_ID
NXM_NX_ARP_SHA
NXM_NX_ARP_THA
NXM_OF_ARP_OP
NXM_OF_ARP_SPA
NXM_OF_ARP_TPA
NXM_NX_TUN_IPV4_DST
NXM_NX_TUN_IPV4_SRC
NXM_OF_ETH_SRC
NXM_OF_ETH_DST
- moved CoSS config to appropriate place
- added revision to ietf-yang-types

Change-Id: If847b9098722337318109d3ffe34ddaca8b6b363
Signed-off-by: Martin Sunal <msunal@cisco.com>
Signed-off-by: Michal Rehak <mirehak@cisco.com>

Corrected equals & hashcode methods in extension keys

- corrected equals & hashcode methods in keys
- tests for equals & hashcode methods in keys

Signed-off-by: Martin Sunal <msunal@cisco.com>

Added switch TLS keys

 - this allows to finish exemplary TLS configuration
 - selfSignedSwitch and selfSignedController keystores were moved to src/test/resources
  as they are used only in test
 - other keystores located in src/main/resources were updated with "exemplary-" prefixes
to clearly mark them for exemplary usage

Change-Id: I821f79e1af8b50fc59e3e5067841a017ec9c1282
Signed-off-by: Michal Polkorab <michal.polkorab@pantheon.sk>

Simplified Multipart TableFeatureProperties serialization

Change-Id: Ifdf3936b5985beba23c94bc1e64dde738a844ca2
Signed-off-by: Michal Polkorab <michal.polkorab@pantheon.sk>

Replaced usage of BytebufUtils.padBuffer() as it is deprecated

 - replaced with buffer.writeZero()

Change-Id: Ica7ef6d244fc531419c42d4055f0d42b09e7ebf0
Signed-off-by: Michal Polkorab <michal.polkorab@pantheon.sk>

TcpFlag match entry serializer registration fix

 - TcpFlag and Tunnel match entry serializers used old keys for registration

Change-Id: Ib0c3944d7d27b3ce8601aa3797d175dc94bce6dd
Signed-off-by: Michal Polkorab <michal.polkorab@pantheon.sk>

Fix: Correct key looked up on experimenter messages

Signed-off-by: Michal Polkorab <michal.polkorab@pantheon.sk>

Example of openflowjava extension for nx_action_resubmit

 - configuration file is located in src/main/resources - use this file to load / register this bundle
 - configuration file is exemplary - it registers the NX_ACTION_RESUBMIT into ofjava 6633 and 6653 instances
 - change contains 2 yang files:
   - nx-resubmit-action.yang - shows how to augment existing structures
   - openflow-nx-resubmit-action.yang - shows how to configure custom bundle
 - unit tests test if the structure is (de)serialized correctly

Change-Id: I6ed7226dba83f36deb100de88e5408ae32c060b2
Signed-off-by: Michal Polkorab <michal.polkorab@pantheon.sk>

Updated experimenter model

 - all extension-capable-messages have their augmentations (experimenter message is defined - so no augment needed here)
 - these augmentations will be used for vendor / experimenter differentiation

Signed-off-by: Michal Polkorab <michal.polkorab@pantheon.sk>

Extracted (De)SerializerExtensionProvider interfaces from SwitchConnectionProvider

Signed-off-by: Michal Polkorab <michal.polkorab@pantheon.sk>

Simplified extension registration (part1)

 - introduced methods for match, action and instruction registration
 - other extension method will be added in part2

Change-Id: I928833e8df6d4a9037fea480ddef4d54d4ac46a6
Signed-off-by: Michal Polkorab <michal.polkorab@pantheon.sk>

Renamed base identity for match oxm_classes

 - renamed from "Clazz" to "OxmClassBase"

Signed-off-by: Michal Polkorab <michal.polkorab@pantheon.sk>

Bug 1373 - Fixed NullPointerException on incorrect input

 - now throws IllegalArgumentException. This is just logged and pushed into Future, the Future delegates the information further to upper ODL layers

Change-Id: I64ac1e4904e8837ab5b26572235bdaf5fac984da
Signed-off-by: Michal Polkorab <michal.polkorab@pantheon.sk>

Created special extension keys for more easier (de)serializer (un)registration

 - these keys don't need special types in their constructors, because they always use the same type (e.g. Experimenter.class)
 - also created two marker interfaces (Experimenter(De)SerializerKey) to mark appropriate extension keys

Signed-off-by: Michal Polkorab <michal.polkorab@pantheon.sk>

Deleted openflow-protocol-ext bundle

 - there is another exemplary bundle - more simpler
 - removal needed by upcoming changes

Signed-off-by: Michal Polkorab <michal.polkorab@pantheon.sk>

Updated extension registration keys

 - keys now properly use experimenter ID to distinguish between experimenter messages
 - also updated initialization and registry helper classes

Change-Id: I6177c72397aa7b534cffdf0a9b729fbec2effa50
Signed-off-by: Michal Polkorab <michal.polkorab@pantheon.sk>

Bug 1324 - Buffer released correctly (even if translated dataObject is null)

 - updated OFDecoderTest - buffer is now released even on deserialization exception

Change-Id: I1a3a6f17309f795b7db08bf3ed68ea49ab888cf0
Signed-off-by: Michal Polkorab <michal.polkorab@pantheon.sk>

Bug 1323 - Treated expensive logging in OFDecoder and OFFrameDecoder

Signed-off-by: Michal Polkorab <michal.polkorab@pantheon.sk>

Default experimenter bundle migrated to ConfigSubsystem

 - updated copyright for ext bundle

Change-Id: I031afe7f1674d4fc44e91be64b5a1cb51bef44ac
Signed-off-by: Michal Polkorab <michal.polkorab@pantheon.sk>

Default experimenters moved to separate bundle + unit tests

(ConfigSubsystem migration will be added later)

Change-Id: Ia6477919fa56347d1e28fd329949b2fb4b852b55
Signed-off-by: Michal Polkorab <michal.polkorab@pantheon.sk>

Changed output directory for generated classes

 - generated classes were not cleaned when located in src -> moved to target
 - also modified .gitignore - removed unnecessary lines

Signed-off-by: Michal Polkorab <michal.polkorab@pantheon.sk>

Extensibility support - added possibility to unregister registered (de)serializers

Signed-off-by: Michal Polkorab <michal.polkorab@pantheon.sk>

Unified extensibility method names

 - removed ambiguity - now both registration methods use the same name pattern
 - registerSerializer() now correctly allows usage of HeaderSerializer

Signed-off-by: Michal Polkorab <michal.polkorab@pantheon.sk>

Merge "Bug 1277 - Move ByteBuffUtils to separate bundle"

Merge "Bug 1277 - Move ByteBuffUtils to separate bundle"

Merge "Bug 1277 - Move ByteBuffUtils to separate bundle"

TLS support - configurable passwords

 - this change allows usage of arbitrary passwords (for keystore, certificate, truststore) instead of hardcoded "opendaylight" password

Signed-off-by: Michal Polkorab <michal.polkorab@pantheon.sk>

Merge "TLS unit test resources moved from src/main/resources to test/main/resources"

Bug 1277 - Move ByteBuffUtils to separate bundle

- ByteBufUtils moved to bundle utils

Signed-off-by: Martin Bobak <mbobak@cisco.com>

Bug 1277 - Move ByteBuffUtils to separate bundle

- constants classes moved form openflow-protocol-impl to openflow-protocol-api

Signed-off-by: Martin Bobak <mbobak@cisco.com>

TLS unit test resources moved from src/main/resources to test/main/resources

 - TLS unit tests access resources via classpath (not relative path)

Signed-off-by: Michal Polkorab <michal.polkorab@pantheon.sk>

Updated logging on NotSslRecordException

 - stackTrace was unnecessarily disruptive

Signed-off-by: Michal Polkorab <michal.polkorab@pantheon.sk>

Bug 1277 - Move ByteBuffUtils to separate bundle

- bundle project directory created
- added dependency on util bundle to openflow-protocol-impl

Signed-off-by: Martin Bobak <mbobak@cisco.com>

Simple client framing fix

 - fixes problem when 2 or more messages were sent simultaneously

Signed-off-by: Michal Polkorab <michal.polkorab@pantheon.sk>

Bug 1248 - Pyang validation fixed

Signed-off-by: Michal Polkorab <michal.polkorab@pantheon.sk>

Extensibility fix - simplified too strict key limitation

 - MessageTypeKey in SwitchConnectionProvider#registerCustomSerializer was restricted to <E extends DataObject>, which does not allow for use of other objects (such as descendants of BaseIdentity)

Signed-off-by: Michal Polkorab <michal.polkorab@pantheon.sk>

Merge "Fix Eclipse errors"

TLS initialization fix

 - fixed TlsConfiguration object creation - now null instead of empty object

Signed-off-by: Michal Polkorab <michal.polkorab@pantheon.sk>

TLS support

TLS is configured in 42-openflowplugin.xml (openflowplugin)
Added tests for:
 - pipeline components
 - TLS classes
 - updated integration test
Added new yang file: openflow-configuration.yang (contains generated classes for library configuration)
Logging updated

Change-Id: I5480b01760377db7de7791594a3b541338a1b43a
Signed-off-by: jameshall03885 <ghall@brocade.com>
Signed-off-by: Michal Polkorab <michal.polkorab@pantheon.sk>

Fix Eclipse errors

Copied in the m2e section from controller.

Change-Id: I19694b87833f44d39433dc05ae4e88932b56fc2e
Signed-off-by: Ed Warnicke <eaw@cisco.com>

Eclipse Build Errors - moved generated source for build-helper

Also removed a version override on maven-bundle-plugin

Change-Id: Ia22f3d3c60cbe1ff9c8f096c52c897eb7fc5fb2b
Signed-off-by: jameshall03885 <ghall@brocade.com>

Removed unnecessary writeAndFlush() from OFEncoder

Signed-off-by: Michal Polkorab <michal.polkorab@pantheon.sk>

Moved interface part of OFJava config into SPI so that OFPlugin won't need dependency on OFJava-IMPL

Change-Id: Ia1c135c1b5d026212e400fe23844c5179d0bb06d
Signed-off-by: Michal Polkorab <michal.polkorab@pantheon.sk>
Signed-off-by: Michal Rehak <mirehak@cisco.com>

Use ReadTimeoutHandler for IdleHandler

This converts to using ReadTimeoutHandler, as it has no impact on the
writeout path -- which IdleStateHandler does by attaching listeners to
promises flying by -- which is omething we don't need.

Change-Id: I4e6f4ac862747116aa9f5f4fcaa9fc9d562f7de9
Signed-off-by: Robert Varga <rovarga@cisco.com>

Started using pooled buffers

Change-Id: I1d5d583cdc0e7ff16da01f07929b8f17a63135fa
Signed-off-by: Michal Polkorab <michal.polkorab@pantheon.sk>

Updated Netty to 4.0.19.Final

 - for pooled buffer performance enhancements
 - MERGE AFTER: https://git.opendaylight.org/gerrit/7727

Signed-off-by: Michal Polkorab <michal.polkorab@pantheon.sk>

Checkstyle maven plugin check - openflowjava

    -violations do not fail build
    -rules defined in yangtools/common/checkstyle-logging
https://git.opendaylight.org/gerrit/#/c/7595/
https://git.opendaylight.org/gerrit/#/c/7108/

Change-Id: Ibf4e7c9dd0bbcc8a26e60a0cead7d2865c32e44d
Signed-off-by: Milos Fabian <milfabia@cisco.com>

Use 0-shifting operand

Do not use sign-dependent operator. Should not matter, as we follow up
with mask, but this makes the intent obvious.

Change-Id: Ie5c4df5373d19f6abe8b48df5b965ee43bf3e8eb
Signed-off-by: Robert Varga <rovarga@cisco.com>

Optimize ipv4/ipv6 formatting

IPv4/IPv6 formatting relied on multiple objects until the final string
was produced. This fixes the way the algorithm operates to make it more
obvious, but also more performant.

Change-Id: Idcfbde227e999dc78363c87952bca7dfb376c5b7
Signed-off-by: Robert Varga <rovarga@cisco.com>

Optimize time checking in flush()

Pre-calculate deadline and do not do timeunit conversions while checking
if we should yield.

Change-Id: Ie315a9650f6f7cdbd1bbd2ac611df2a3dfda4975
Signed-off-by: Robert Varga <rovarga@cisco.com>

Optimize macAddressToBytes()

Using raw string parsing has some significant overhead. For parsing a
MAC address, we can employ hand-coded routing which has does not
allocate objects and is much more (~140x) more efficient.

Change-Id: Iad1e6bc1618dd1eedcdfbc9f1e55ac49d03ea4aa
Signed-off-by: Robert Varga <rovarga@cisco.com>

Optimize mask creation utilities

This introduces a simpified fillBitMask(), which is much simpler to use
and also much faster.

Change-Id: I5519032e3a83a3ace73c1b383784b1e372870782
Signed-off-by: Robert Varga <rovarga@cisco.com>

Adding tunnel ipv4 src/dst openflow augmentations

Augments the low-level openflowjava models and
OF13 implementation to support flow based tunnels
rather then port based tunnels only which is ovsdb
specific thus making a more generic TEP implementation.

I used the v4 parent serializer
AbstractOxmIpv4AddressSerializer since its pretty
class agnostic except for the v4 OpenflowBasic
match but it that is abstracted from the DP and
I don't see any glaring issues uses it. If you
guys would prefer an NXM1Class/NXM0Class specific
ipv4 super just say the word. I have both
implementations local with the same result in the DP.

Output of tests and ovs integration is posted here:
https://gist.github.com/22f0749bba00df1a3cf6

Change-Id: I0f3ebed560bba0137553944fe342704456b4658e
Signed-off-by: Brent Salisbury <brent.salisbury@gmail.com>

Optimize macAddressToString and padBuffer

Optimizes macAddressToString to prevent multiple object allocations and
do a straightforward coversion -- speedup of ~6x.

padBuffer() is deprecated in favor of writeZero(), and uses it
internally.

Change-Id: I98264fe1744b66363b8b3fcae4d54b4b78814cc8
Signed-off-by: Robert Varga <rovarga@cisco.com>

Flush all entries on channel shutdown

This just makes sure we flush out outstanding queue quickly.

Change-Id: Ib1f7262545f012fe8c418cbe980cc63467a4f654
Signed-off-by: Robert Varga <rovarga@cisco.com>

Pre-cache key makers

These are essentially constants, so there is no need to allocate them
over and over again -- just create a single instance and reuse it. Save
CPU and GC cycles.

Change-Id: I77670f4465d8139c6f218bd6f7dab13b66a5b8fc
Signed-off-by: Robert Varga <rovarga@cisco.com>

Do not instantiate Joiner/Splitter

This patch centralized Splitter and Joiner instances to ByteBufUtils,
from where they are used -- reducing object allocation and CPU usage
(due to checks).

As a bonus, this optimizes splitters on single characters to the
simplest possible form, further reducing overhead.

Change-Id: If635656af49967cd17333ebbeef3452091edd5d5
Signed-off-by: Robert Varga <rovarga@cisco.com>

Do not instantiate key in fast path

This is a constant lookup for each packet -- let's just use a static
key to prevent useless allocations.

Change-Id: I4a81fc04e29607ace710c7a35671420271836066
Signed-off-by: Robert Varga <rovarga@cisco.com>

Used Splitter instead of String.split() - performance improvement

- removed ending whitespace characters from .buildBuffer method as those hexStrings should be ended with a hex character

Change-Id: If1e53d7bbcc81293aa7a231b24b1b7a7746cb5c7
Signed-off-by: Michal Polkorab <michal.polkorab@pantheon.sk>

Introduce ChannelOutboundQueue

This patch introduces a tunable queue for outstanding requests. The core
idea is to maintain a limited queue between the message produces and the
IO threads. The producers place their pre-made messages to the queue,
where the IO thread picks them up and pushes them down the pipeline.
Should the queue be empty, the caller is informed of this fact and can
choose a recovery strategy -- current implementation reports
RejectedExecutionException.

The flush task is placed in the IO pool only when the channel is
writable and the queue is non-empty. A single run of the flush task is
time-limited, so a single channel which is being churned by producer
does not end up monopolizing a particular thread for extended periods of
time -- after a tunable time the flush task will re-insert itself on the
task queue and exit.

Change-Id: If6f09c60cf2cf5a69e9f051e2dfe2bae3bb90b5d
Signed-off-by: Robert Varga <rovarga@cisco.com>