123456789_123456789_123456789_123456789_123456789_

Class: Gem::Net::InternetMessageIO

Do not use. This class is for internal use only.
Relationships & Source Files
Super Chains via Extension / Inclusion / Inheritance
Class Chain:
self, BufferedIO
Instance Chain:
self, BufferedIO
Inherits: Gem::Net::BufferedIO
Defined in: lib/rubygems/vendor/net-protocol/lib/net/protocol.rb

Overview

internal use only

Constant Summary

BufferedIO - Inherited

BUFSIZE

Class Method Summary

BufferedIO - Inherited

.new

Instance Attribute Summary

BufferedIO - Inherited

#closed?, #continue_timeout, #debug_output, #eof?, #io, #read_timeout, #write_timeout

Instance Method Summary

BufferedIO - Inherited

#<<

Alias for BufferedIO#write.
#close, #inspect, #read, #read_all, #readline, #readuntil, #write, #writeline, #LOG, #LOG_off, #LOG_on, #rbuf_consume, #rbuf_consume_all, #rbuf_fill, #rbuf_flush, #rbuf_size, #write0, #writing

Constructor Details

.new ⇒ InternetMessageIO

[ GitHub ] 

  


# File 'lib/rubygems/vendor/net-protocol/lib/net/protocol.rb', line 364



def initialize(*, **)
  super
  @wbuf = nil
end


  







Instance Method Details



  

    #buffer_filling(buf, src)   (private)
  

  [ GitHub ]


  

  


# File 'lib/rubygems/vendor/net-protocol/lib/net/protocol.rb', line 460



def buffer_filling(buf, src)
  case src
  when String    # for speeding up.
    0.step(src.size - 1, 1024) do |i|
      buf << src[i, 1024]
      yield
    end
  when File    # for speeding up.
    while s = src.read(1024)
      buf << s
      yield
    end
  else    # generic reader
    src.each do |str|
      buf << str
      yield if buf.size > 1024
    end
    yield unless buf.empty?
  end
end


  








  

    #dot_stuff(s)   (private)
  

  [ GitHub ]


  

  


# File 'lib/rubygems/vendor/net-protocol/lib/net/protocol.rb', line 436



def dot_stuff(s)
  s.sub(/\A\./, '..')
end


  








  

    #each_crlf_line(src)   (private)
  

  [ GitHub ]


  

  


# File 'lib/rubygems/vendor/net-protocol/lib/net/protocol.rb', line 452



def each_crlf_line(src)
  buffer_filling(@wbuf, src) do
    while line = @wbuf.slice!(/\A[^\r\n]*(?:\n|\r(?:\n|(?!\z)))/)
      yield line.chomp("\n") + "\r\n"
    end
  end
end


  








  

    #each_list_item  
  



  

    

*library private* (cannot handle ‘break’)


  



  [ GitHub ]


  

  


# File 'lib/rubygems/vendor/net-protocol/lib/net/protocol.rb', line 386



def each_list_item
  while (str = readuntil("\r\n")) != ".\r\n"
    yield str.chop
  end
end


  








  

    #each_message_chunk  
  



  

    

Read


  



  [ GitHub ]


  

  


# File 'lib/rubygems/vendor/net-protocol/lib/net/protocol.rb', line 373



def each_message_chunk
  LOG 'reading message...'
  LOG_off()
  read_bytes = 0
  while (line = readuntil("\r\n")) != ".\r\n"
    read_bytes += line.size
    yield line.delete_prefix('.')
  end
  LOG_on()
  LOG "read message (#{read_bytes} bytes)"
end


  








  

    #using_each_crlf_line   (private)
  

  [ GitHub ]


  

  


# File 'lib/rubygems/vendor/net-protocol/lib/net/protocol.rb', line 440



def using_each_crlf_line
  @wbuf = ''.b
  yield
  if not @wbuf.empty?   # unterminated last line
    write0 dot_stuff(@wbuf.chomp) + "\r\n"
  elsif @written_bytes == 0   # empty src
    write0 "\r\n"
  end
  write0 ".\r\n"
  @wbuf = nil
end


  








  

    #write_message(src)  
  



  

    

Write


  



  [ GitHub ]


  

  


# File 'lib/rubygems/vendor/net-protocol/lib/net/protocol.rb', line 404



def write_message(src)
  LOG "writing message from #{src.class}"
  LOG_off()
  len = writing {
    using_each_crlf_line {
      write_message_0 src
    }
  }
  LOG_on()
  LOG "wrote #{len} bytes"
  len
end


  








  

    #write_message_0(src)  
  

  [ GitHub ]


  

  


# File 'lib/rubygems/vendor/net-protocol/lib/net/protocol.rb', line 392



def write_message_0(src)
  prev = @written_bytes
  each_crlf_line(src) do |line|
    write0 dot_stuff(line)
  end
  @written_bytes - prev
end


  








  

    #write_message_by_block(&block)  
  

  [ GitHub ]


  

  


# File 'lib/rubygems/vendor/net-protocol/lib/net/protocol.rb', line 417



def write_message_by_block(&block)
  LOG 'writing message from block'
  LOG_off()
  len = writing {
    using_each_crlf_line {
      begin
        block.call(WriteAdapter.new(self.method(:write_message_0)))
      rescue LocalJumpError
        # allow `break' from writer block
      end
    }
  }
  LOG_on()
  LOG "wrote #{len} bytes"
  len
end