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_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 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 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_header_line has a Cognitive Complexity of 10 (exceeds 5 allowed). Consider refactoring.

Open

        def receive_header_line ln
          if ln.length == 0
            if @header_lines.length > 0
              process_header
            else

• Read up
  Read up

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

Open

    def eventable_write
      # coalesce the outbound array here, perhaps
      @last_activity = Reactor.instance.current_loop_time
      while data = @outbound_q.shift do
        begin

• Read up
  Read up

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

Open

    def run
      raise Error.new( "already running" ) if @running
      @running = true

      begin

• Read up
  Read up

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

Method writeOutboundData has 27 lines of code (exceeds 25 allowed). Consider refactoring.

Open

    public boolean writeOutboundData() throws IOException {
        ByteBuffer[] bufs = new ByteBuffer[64];
        int i;
        long written, toWrite;
        while (!outboundQ.isEmpty()) {

Method process_rcpt_to has 26 lines of code (exceeds 25 allowed). Consider refactoring.

Open

      def process_rcpt_to rcpt
        unless @state.include?(:mail_from)
          send_data "503 MAIL is required before RCPT\r\n"
        else
          succeeded = proc {

Method consume_line has 26 lines of code (exceeds 25 allowed). Consider refactoring.

Open

        def consume_line line
          if @state == :precommand
            unless line =~ /\A\s*\Z/
              @command = line
              @state = :headers

Method invoke_rcpt_to has a Cognitive Complexity of 9 (exceeds 5 allowed). Consider refactoring.

Open

      def invoke_rcpt_to
        @rcpt_responses ||= []
        l = @rcpt_responses.length
        to = @args[:to].is_a?(Array) ? @args[:to] : [@args[:to].to_s]
        if l < to.length

• Read up
  Read up

Method dispatch_conn_message has a Cognitive Complexity of 9 (exceeds 5 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

• Read up
  Read up

Method nameservers has a Cognitive Complexity of 9 (exceeds 5 allowed). Consider refactoring.

Open

      def self.nameservers
        return @nameservers if @nameservers

        if windows?
          _, ns = Win32::Resolv.get_resolv_info

• Read up
  Read up

Method process_data has a Cognitive Complexity of 9 (exceeds 5 allowed). Consider refactoring.

Open

      def process_data
        unless @state.include?(:rcpt)
          send_data "503 Operation sequence error\r\n"
        else
          succeeded = proc {

• Read up
  Read up

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 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

Avoid deeply nested control flow statements.

Open

  add_define 'WITH_SSL' if find_openssl_library