Method dir_config_wrapper has a Cognitive Complexity of 13 (exceeds 5 allowed). Consider refactoring.

Open

def dir_config_wrapper(pretty_name, name, idefault=nil, ldefault=nil)
  inc, lib = dir_config(name, idefault, ldefault)
  if inc && lib
    unless idefault && ldefault
      abort "-----\nCannot find #{pretty_name} include path #{inc}\n-----" unless inc && inc.split(File::PATH_SEPARATOR).any? { |dir| File.directory?(dir) }

• Read up
  Read up

Method each has 39 lines of code (exceeds 25 allowed). Consider refactoring.

Open

    def each(foreach=nil, after=nil, &blk)
      raise ArgumentError, 'proc or block required for iteration' unless foreach ||= blk
      raise RuntimeError, 'cannot iterate over an iterator more than once' if @started or @ended

      @started = true

Method process_header has 37 lines of code (exceeds 25 allowed). Consider refactoring.

Open

        def process_header
          unless @header_lines.first =~ HttpResponseRE
            @conn.close_connection
            @internal_error = :bad_request
          end

Method process_cmd has a Cognitive Complexity of 12 (exceeds 5 allowed). Consider refactoring.

Open

      def process_cmd line
        case line.strip
        when /^VALUE\s+(.+?)\s+(\d+)\s+(\d+)/ # VALUE <key> <flags> <bytes>
          bytes = Integer($3)
          # set_binary_mode bytes+2

• Read up
  Read up

Method currentEvents has a Cognitive Complexity of 12 (exceeds 5 allowed). Consider refactoring.

Open

    private int currentEvents() {
        int events = 0;

        if (bWatchOnly)
        {

• Read up
  Read up

Method receive_data_response has a Cognitive Complexity of 12 (exceeds 5 allowed). Consider refactoring.

Open

      def receive_data_response
        return invoke_error unless @range == 3

        # The data to send can be given in either @args[:message], @args[:content], or the
        # combination of @args[:header] and @args[:body].

• Read up
  Read up

Method future has a Cognitive Complexity of 12 (exceeds 5 allowed). Consider refactoring.

Open

      def self.future arg, cb=nil, eb=nil, &blk
        arg = arg.call if arg.respond_to?(:call)

        if arg.respond_to?(:set_deferred_status)
          if cb || eb

• Read up
  Read up

Method bind_connect has a Cognitive Complexity of 12 (exceeds 5 allowed). Consider refactoring.

Open

  def self.bind_connect bind_addr, bind_port, server, port=nil, handler=nil, *args
    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 35 lines of code (exceeds 25 allowed). Consider refactoring.

Open

    void close() {
        try {
            if (mySelector != null)
                mySelector.close();
        } catch (IOException e) {}

Method receive_line has 33 lines of code (exceeds 25 allowed). Consider refactoring.

Open

      def receive_line ln
        @@parms[:verbose] and $>.puts ">>> #{ln}"

        return process_data_line(ln) if @state.include?(:data)
        return process_auth_line(ln) if @state.include?(:auth_incomplete)

Method receive_data has 32 lines of code (exceeds 25 allowed). Consider refactoring.

Open

      def receive_data data
        if @lbp_mode == :lines
          begin
            @lpb_buffer.extract(data).each do |line|
              receive_line(line.chomp) if respond_to?(:receive_line)

Method processIO has a Cognitive Complexity of 11 (exceeds 5 allowed). Consider refactoring.

Open

    void processIO() {
        Iterator<SelectionKey> it = mySelector.selectedKeys().iterator();
        while (it.hasNext()) {
            SelectionKey k = it.next();
            it.remove();

• Read up
  Read up

Method receive_data has a Cognitive Complexity of 11 (exceeds 5 allowed). Consider refactoring.

Open

      def receive_data data
        @sasl_data << data

        while @sasl_data.length > 2
          len = (@sasl_data[0,2].unpack("n")).first

• Read up
  Read up

Method writeOutboundData has a Cognitive Complexity of 11 (exceeds 5 allowed). Consider refactoring.

Open

    public boolean writeOutboundData() {
        while (!outboundQ.isEmpty()) {
            Packet p = outboundQ.getFirst();
            int written = 0;
            try {

• Read up
  Read up

Method dispatch_conn_message has 30 lines of code (exceeds 25 allowed). Consider refactoring.

Open

      def dispatch_conn_message msg
        case msg
        when AuthentificationClearTextPassword
          raise ArgumentError, "no password specified" if @password.nil?
          send_data PasswordMessage.new(@password).dump

Method process_cmd has 30 lines of code (exceeds 25 allowed). Consider refactoring.

Open

      def process_cmd line
        case line.strip
        when /^VALUE\s+(.+?)\s+(\d+)\s+(\d+)/ # VALUE <key> <flags> <bytes>
          bytes = Integer($3)
          # set_binary_mode bytes+2

Method receive_line has 30 lines of code (exceeds 25 allowed). Consider refactoring.

Open

      def receive_line line
        case @hc_mode
        when :discard_blanks
          unless line == ""
            @hc_mode = :headers

Method process_data_line has 29 lines of code (exceeds 25 allowed). Consider refactoring.

Open

      def process_data_line ln
        if ln == "."
          if @databuffer.length > 0
            receive_data_chunk @databuffer
            @databuffer.clear

Method isAcceptable has 28 lines of code (exceeds 25 allowed). Consider refactoring.

Open

    void isAcceptable (SelectionKey k) {
        ServerSocketChannel ss = (ServerSocketChannel) k.channel();
        SocketChannel sn;
        long b;

Method receive_data has a Cognitive Complexity of 10 (exceeds 5 allowed). Consider refactoring.

Open

      def receive_data data
        @data << data
        while @data.length >= 5
          pktlen = @data[1...5].unpack("N").first
          if @data.length >= (1 + pktlen)

• Read up
  Read up