tested on ftp server: glftpd 1.30
=end
require 'socket'
require 'openssl'
require 'net/ftp'

          # containing "Content-Length: 12345\n\n"
          # This code gets rid of them
          socket = req.instance_variable_get("@socket")
          removed = req.send(:read_line, socket)
          removed += req.send(:read_line, socket)

def socket_read_all(socket)
  buff=""
  while read=socket.read($internal_config_read_len) do buff << read end

require 'socket'
require 'fcntl'
class Session

require 'socket'
module Protobuf
  module Rpc

require 'socket'
module Protobuf
  module Rpc

# See LICENSE file for additional information.
require 'observer'
require 'socket'
require 'fcntl'
require 'network/net_connection'

VI.add_vers("MU* TCP/IP Communications",0,1,0,"2005-8-17","Mario Steele")
class MUSocket
  attr_accessor :host, :port, :buffer, :socket
  def initialize(shost="localhost",sport=7434)

     require 'test/unit/mock'
end
require 'socket'
require 'test/unit'
# This is just a test to make sure the code in the README works as advertised.

       retry_number = 0
       timeout(@connect_timeout) do
      @socket = create_socket(site)
-     @src.host = @socket.addr[3]
-     @src.port = @socket.addr[1]

require 'gtk'
=begin
Sample script using Gtk::Socket and Gtk::Plug.
Written by Alex Boussinet <mailto:dbug@wanadoo.fr> for testing purpose only.
=end

require 'socket'
require 'fcntl'
# Custom session class sends and gets messages in the following format:

         session_port = @engine.configuration[:session_port]
         begin
            socket = UDPSocket.open
            socket.setsockopt(Socket::IPPROTO_IP, Socket::IP_TTL, [1].pack('i'))
            loop do

require 'socket'
module Journeta
   class SessionListener < Journeta::Asynchronous

require 'yaml'
require 'socket'
require 'ipaddr'
require 'journeta/asynchronous'

#
# Copyright (c) Anders Bengtsson 2005-2006
require 'socket'
class PassiveConnection
  @@count = 0

# Revision:: $Revision: 355 $
# License::  GPL2
require 'socket'
require 'English'
resource = { '#nodes upperbound' => '64',

    def initialize(test_case, port)
      @test_case = test_case
      @socket = Socket.new(Socket::AF_INET, Socket::SOCK_STREAM, 0)
      @socket.setsockopt(Socket::IPPROTO_TCP, Socket::TCP_NODELAY, true) # to make mass connects fluid
      @socket.setsockopt(Socket::SOL_SOCKET, Socket::SO_LINGER, [1, 0].pack("ii")) # to avoid port block (TIME_WAIT state)

  end
  # Add a remote connection to the list.
  def add(remote_host, remote_port, socket = nil)
    @connections[remote_host] = Connection.new(remote_host, remote_port, socket)
  end

require 'gtk2'
=begin
Sample script using Gtk::Socket and Gtk::Plug.
 $ ruby t-gtksocket.rb
Written by Alex Boussinet <mailto:dbug@wanadoo.fr> for testing purpose only.

require 'gtk2'
=begin
Sample script using Gtk::Socket and Gtk::Plug.
 $ ruby t-gtksocket.rb
Written by Alex Boussinet <mailto:dbug@wanadoo.fr> for testing purpose only.

require 'gtk2'
=begin
Sample script using Gtk::Socket and Gtk::Plug.
 $ ruby t-gtksocket.rb
Written by Alex Boussinet <mailto:dbug@wanadoo.fr> for testing purpose only.

require 'socket' 
@socket
module Spec

require 'socket' 
@socket
module Spec

module Net
  module NetPrivate
    class SSLSocket < Socket
      extend Forwardable
      def_delegators(:@socket,