Avoid deeply nested control flow statements.

Open

    elsif opcode == ConnectionData
      c = @conns[conn_binding] or raise ConnectionNotBound, "received data #{data} for unknown signature: #{conn_binding}"
      c.receive_data data
    elsif opcode == LoopbreakSignalled
      run_deferred_callbacks

Method dispatchInboundData has a Cognitive Complexity of 8 (exceeds 5 allowed). Consider refactoring.

Open

    public ByteBuffer dispatchInboundData (ByteBuffer bb) throws SSLException {
        if (sslEngine != null) {
            if (true) throw new RuntimeException ("TLS currently unimplemented");
            System.setProperty("javax.net.debug", "all");
            ByteBuffer w = ByteBuffer.allocate(32*1024); // TODO, WRONG, preallocate this buffer.

• Read up
  Read up

Method start_server has a Cognitive Complexity of 8 (exceeds 5 allowed). Consider refactoring.

Open

  def self.start_server server, port=nil, handler=nil, *args, &block
    begin
      port = Integer(port)
    rescue ArgumentError, TypeError
      # there was no port, so server must be a unix domain socket

• Read up
  Read up

Method close has a Cognitive Complexity of 8 (exceeds 5 allowed). Consider refactoring.

Open

    public void close() {
        if (channelKey != null) {
            channelKey.cancel();
            channelKey = null;
        }

• Read up
  Read up

Method scheduleOutboundData has a Cognitive Complexity of 8 (exceeds 5 allowed). Consider refactoring.

Open

    public void scheduleOutboundData (ByteBuffer bb) {
        if (!bCloseScheduled && bb.remaining() > 0) {
            if (sslEngine != null) {
                try {
                    ByteBuffer b = ByteBuffer.allocate(32*1024); // TODO, preallocate this buffer.

• Read up
  Read up

Avoid deeply nested control flow statements.

Open

  add_define 'WITH_SSL' if find_openssl_library

Method invoke_auth has a Cognitive Complexity of 8 (exceeds 5 allowed). Consider refactoring.

Open

      def invoke_auth
        if @args[:auth]
          if @args[:auth][:type] == :plain
            psw = @args[:auth][:password]
            if psw.respond_to?(:call)

• Read up
  Read up

Avoid deeply nested control flow statements.

Open

                if (@content_length and @content_length > 0) || @chunked || @connection_close
                  @read_state = :content
                else
                  dispatch_response
                  @read_state = :base

Method isReadable has a Cognitive Complexity of 8 (exceeds 5 allowed). Consider refactoring.

Open

    void isReadable (SelectionKey k) {
        EventableChannel ec = (EventableChannel) k.attachment();
        long b = ec.getBinding();

        if (ec.isWatchOnly()) {

• Read up
  Read up

Method isWritable has a Cognitive Complexity of 8 (exceeds 5 allowed). Consider refactoring.

Open

    void isWritable (SelectionKey k) {
        EventableChannel ec = (EventableChannel) k.attachment();
        long b = ec.getBinding();

        if (ec.isWatchOnly()) {

• Read up
  Read up

Avoid deeply nested control flow statements.

Open

              if @lt2_textpos >= @lt2_textsize
                # Reset line mode (the default behavior) BEFORE calling the
                # receive_binary_data. This makes it possible for user code
                # to call set_text_mode, enabling chains of text blocks
                # (which can possibly be of different sizes).

Method bind_connect has 6 arguments (exceeds 4 allowed). Consider refactoring.

Open

  def self.bind_connect bind_addr, bind_port, server, port=nil, handler=nil, *args

Avoid deeply nested control flow statements.

Open

            elsif @content_length
              # If there was no content-length header, we have to wait until the connection
              # closes. Everything we get until that point is content.
              # TODO: Must impose a content-size limit, and also must implement chunking.
              # Also, must support either temporary files for large content, or calling

Avoid deeply nested control flow statements.

Open

              will_take = if remaining_data.length > needed
                            needed
                          else
                            remaining_data.length
                          end

Method run_deferred_callbacks has a Cognitive Complexity of 8 (exceeds 5 allowed). Consider refactoring.

Open

  def self.run_deferred_callbacks
    until (@resultqueue ||= []).empty?
      result,cback = @resultqueue.pop
      cback.call result if cback
    end

• Read up
  Read up

Avoid deeply nested control flow statements.

Open

            rescue Exception => error
              @wrapped_exception = error
              stop

Method receive_line has a Cognitive Complexity of 8 (exceeds 5 allowed). Consider refactoring.

Open

      def receive_line line
        @stomp_initialized || init_message_reader
        @stomp_message.consume_line(line) {|outcome|
          if outcome.first == :sized_text
            set_text_mode outcome[1]

• Read up
  Read up

Method send_cmd has 6 arguments (exceeds 4 allowed). Consider refactoring.

Open

      def send_cmd cmd, key, flags = 0, exptime = 0, bytes = 0, noreply = false

Method receive_chunk_header has a Cognitive Complexity of 8 (exceeds 5 allowed). Consider refactoring.

Open

        def receive_chunk_header ln
          if ln.length > 0
            chunksize = ln.to_i(16)
            if chunksize > 0
              @conn.set_text_mode(ln.to_i(16))

• Read up
  Read up

Avoid deeply nested control flow statements.

Open

                if @headers.length == 1
                  parse_response_line
                elsif ary.first =~ /\Acontent-length:\s*/i
                  # Only take the FIRST content-length header that appears,
                  # which we can distinguish because @content_length is nil.