File Manager

X7ROOT File Manager

Current Path: /opt/alt/ruby20/lib64/ruby/2.0.0

opt / alt / ruby20 / lib64 / ruby / 2.0.0 /

ðŸ“ ..
ðŸ“„ English.rb(6.44 KB)
ðŸ“„ abbrev.rb(3.31 KB)
ðŸ“„ base64.rb(2.63 KB)
ðŸ“„ benchmark.rb(17.94 KB)
ðŸ“ cgi
ðŸ“„ cgi.rb(9.39 KB)
ðŸ“„ cmath.rb(7.22 KB)
ðŸ“„ complex.rb(380 B)
ðŸ“„ csv.rb(81.32 KB)
ðŸ“ date
ðŸ“„ date.rb(946 B)
ðŸ“„ debug.rb(28.9 KB)
ðŸ“„ delegate.rb(9.78 KB)
ðŸ“ digest
ðŸ“„ digest.rb(2.24 KB)
ðŸ“ dl
ðŸ“„ dl.rb(280 B)
ðŸ“ drb
ðŸ“„ drb.rb(19 B)
ðŸ“„ e2mmap.rb(3.8 KB)
ðŸ“„ erb.rb(26.08 KB)
ðŸ“„ expect.rb(2.14 KB)
ðŸ“ fiddle
ðŸ“„ fiddle.rb(1.25 KB)
ðŸ“„ fileutils.rb(46.35 KB)
ðŸ“„ find.rb(2.08 KB)
ðŸ“„ forwardable.rb(7.56 KB)
ðŸ“„ getoptlong.rb(15.38 KB)
ðŸ“„ gserver.rb(8.86 KB)
ðŸ“„ ipaddr.rb(26.17 KB)
ðŸ“ irb
ðŸ“„ irb.rb(20.03 KB)
ðŸ“ json
ðŸ“„ json.rb(1.74 KB)
ðŸ“„ kconv.rb(5.74 KB)
ðŸ“„ logger.rb(20.96 KB)
ðŸ“„ mathn.rb(6.52 KB)
ðŸ“ matrix
ðŸ“„ matrix.rb(45.02 KB)
ðŸ“„ mkmf.rb(78.19 KB)
ðŸ“„ monitor.rb(6.93 KB)
ðŸ“„ mutex_m.rb(2 KB)
ðŸ“ net
ðŸ“„ observer.rb(5.71 KB)
ðŸ“„ open-uri.rb(23.66 KB)
ðŸ“„ open3.rb(21.17 KB)
ðŸ“ openssl
ðŸ“„ openssl.rb(528 B)
ðŸ“ optparse
ðŸ“„ optparse.rb(51.27 KB)
ðŸ“„ ostruct.rb(7.64 KB)
ðŸ“„ pathname.rb(15.3 KB)
ðŸ“„ pp.rb(13.14 KB)
ðŸ“„ prettyprint.rb(9.63 KB)
ðŸ“„ prime.rb(13.98 KB)
ðŸ“„ profile.rb(205 B)
ðŸ“„ profiler.rb(4.29 KB)
ðŸ“„ pstore.rb(14.85 KB)
ðŸ“ psych
ðŸ“„ psych.rb(9.9 KB)
ðŸ“ racc
ðŸ“ rake
ðŸ“„ rake.rb(2.07 KB)
ðŸ“„ rational.rb(308 B)
ðŸ“ rbconfig
ðŸ“ rdoc
ðŸ“„ rdoc.rb(4.88 KB)
ðŸ“„ resolv-replace.rb(1.73 KB)
ðŸ“„ resolv.rb(61.45 KB)
ðŸ“ rexml
ðŸ“ rinda
ðŸ“ ripper
ðŸ“„ ripper.rb(2.53 KB)
ðŸ“ rss
ðŸ“„ rss.rb(2.84 KB)
ðŸ“ rubygems
ðŸ“„ rubygems.rb(27.53 KB)
ðŸ“„ scanf.rb(23.52 KB)
ðŸ“„ securerandom.rb(8.56 KB)
ðŸ“„ set.rb(17.32 KB)
ðŸ“ shell
ðŸ“„ shell.rb(10.3 KB)
ðŸ“„ shellwords.rb(5.94 KB)
ðŸ“„ singleton.rb(4.02 KB)
ðŸ“„ socket.rb(25.76 KB)
ðŸ“„ sync.rb(7.26 KB)
ðŸ“ syslog
ðŸ“„ tempfile.rb(10.15 KB)
ðŸ“ test
ðŸ“„ thread.rb(6.94 KB)
ðŸ“„ thwait.rb(3.38 KB)
ðŸ“„ time.rb(21.09 KB)
ðŸ“„ timeout.rb(3.16 KB)
ðŸ“„ tmpdir.rb(4.15 KB)
ðŸ“„ tracer.rb(6.54 KB)
ðŸ“„ tsort.rb(6.79 KB)
ðŸ“„ ubygems.rb(268 B)
ðŸ“„ un.rb(8.34 KB)
ðŸ“ uri
ðŸ“„ uri.rb(3.07 KB)
ðŸ“„ weakref.rb(3.23 KB)
ðŸ“ webrick
ðŸ“„ webrick.rb(6.7 KB)
ðŸ“ x86_64-linux
ðŸ“ xmlrpc
ðŸ“„ xmlrpc.rb(8.49 KB)
ðŸ“ yaml
ðŸ“„ yaml.rb(2.3 KB)

Editing: gserver.rb

#
# Copyright (C) 2001 John W. Small All Rights Reserved
#
# Author::        John W. Small
# Documentation:: Gavin Sinclair
# Licence::       Ruby License

require "socket"
require "thread"

#
# GServer implements a generic server, featuring thread pool management,
# simple logging, and multi-server management.  See HttpServer in
# <tt>xmlrpc/httpserver.rb</tt> in the Ruby standard library for an example of
# GServer in action.
#
# Any kind of application-level server can be implemented using this class.
# It accepts multiple simultaneous connections from clients, up to an optional
# maximum number.  Several _services_ (i.e. one service per TCP port) can be
# run simultaneously, and stopped at any time through the class method
# <tt>GServer.stop(port)</tt>.  All the threading issues are handled, saving
# you the effort.  All events are optionally logged, but you can provide your
# own event handlers if you wish.
#
# == Example
#
# Using GServer is simple.  Below we implement a simple time server, run it,
# query it, and shut it down.  Try this code in +irb+:
#
#   require 'gserver'
#
#   #
#   # A server that returns the time in seconds since 1970.
#   #
#   class TimeServer < GServer
#     def initialize(port=10001, *args)
#       super(port, *args)
#     end
#     def serve(io)
#       io.puts(Time.now.to_i)
#     end
#   end
#
#   # Run the server with logging enabled (it's a separate thread).
#   server = TimeServer.new
#   server.audit = true                  # Turn logging on.
#   server.start
#
#   # *** Now point your browser to http://localhost:10001 to see it working ***
#
#   # See if it's still running.
#   GServer.in_service?(10001)           # -> true
#   server.stopped?                      # -> false
#
#   # Shut the server down gracefully.
#   server.shutdown
#
#   # Alternatively, stop it immediately.
#   GServer.stop(10001)
#   # or, of course, "server.stop".
#
# All the business of accepting connections and exception handling is taken
# care of.  All we have to do is implement the method that actually serves the
# client.
#
# === Advanced
#
# As the example above shows, the way to use GServer is to subclass it to
# create a specific server, overriding the +serve+ method.  You can override
# other methods as well if you wish, perhaps to collect statistics, or emit
# more detailed logging.
#
# * #connecting
# * #disconnecting
# * #starting
# * #stopping
#
# The above methods are only called if auditing is enabled, via #audit=.
#
# You can also override #log and #error if, for example, you wish to use a
# more sophisticated logging system.
#
class GServer

DEFAULT_HOST = "127.0.0.1"

def serve(io)
  end

@@services = {}   # Hash of opened ports, i.e. services
  @@servicesMutex = Mutex.new

# Stop the server running on the given port, bound to the given host
  #
  # +port+:: port, as a FixNum, of the server to stop
  # +host+:: host on which to find the server to stop
  def GServer.stop(port, host = DEFAULT_HOST)
    @@servicesMutex.synchronize {
      @@services[host][port].stop
    }
  end

# Check if a server is running on the given port and host
  #
  # +port+:: port, as a FixNum, of the server to check
  # +host+:: host on which to find the server to check
  #
  # Returns true if a server is running on that port and host.
  def GServer.in_service?(port, host = DEFAULT_HOST)
    @@services.has_key?(host) and
      @@services[host].has_key?(port)
  end

# Stop the server
  def stop
    @connectionsMutex.synchronize  {
      if @tcpServerThread
        @tcpServerThread.raise "stop"
      end
    }
  end

# Returns true if the server has stopped.
  def stopped?
    @tcpServerThread == nil
  end

# Schedule a shutdown for the server
  def shutdown
    @shutdown = true
  end

# Return the current number of connected clients
  def connections
    @connections.size
  end

# Join with the server thread
  def join
    @tcpServerThread.join if @tcpServerThread
  end

# Port on which to listen, as a FixNum
  attr_reader :port
  # Host on which to bind, as a String
  attr_reader :host
  # Maximum number of connections to accept at a time, as a FixNum
  attr_reader :maxConnections
  # IO Device on which log messages should be written
  attr_accessor :stdlog
  # Set to true to cause the callbacks #connecting, #disconnecting, #starting,
  # and #stopping to be called during the server's lifecycle
  attr_accessor :audit
  # Set to true to show more detailed logging
  attr_accessor :debug

# Called when a client connects, if auditing is enabled.
  #
  # +client+:: a TCPSocket instance representing the client that connected
  #
  # Return true to allow this client to connect, false to prevent it.
  def connecting(client)
    addr = client.peeraddr
    log("#{self.class.to_s} #{@host}:#{@port} client:#{addr[1]} " +
        "#{addr[2]}<#{addr[3]}> connect")
    true
  end

# Called when a client disconnects, if audition is enabled.
  #
  # +clientPort+:: the port of the client that is connecting
  def disconnecting(clientPort)
    log("#{self.class.to_s} #{@host}:#{@port} " +
      "client:#{clientPort} disconnect")
  end

protected :connecting, :disconnecting

# Called when the server is starting up, if auditing is enabled.
  def starting()
    log("#{self.class.to_s} #{@host}:#{@port} start")
  end

# Called when the server is shutting down, if auditing is enabled.
  def stopping()
    log("#{self.class.to_s} #{@host}:#{@port} stop")
  end

protected :starting, :stopping

# Called if #debug is true whenever an unhandled exception is raised.
  # This implementation simply logs the backtrace.
  #
  # +detail+:: the Exception that was caught
  def error(detail)
    log(detail.backtrace.join("\n"))
  end

# Log a message to #stdlog, if it's defined.  This implementation
  # outputs the timestamp and message to the log.
  #
  # +msg+:: the message to log
  def log(msg)
    if @stdlog
      @stdlog.puts("[#{Time.new.ctime}] %s" % msg)
      @stdlog.flush
    end
  end

protected :error, :log

# Create a new server
  #
  # +port+:: the port, as a FixNum, on which to listen
  # +host+:: the host to bind to
  # +maxConnections+:: the maximum number of simultaneous connections to
  #                    accept
  # +stdlog+:: IO device on which to log messages
  # +audit+:: if true, lifecycle callbacks will be called.  See #audit
  # +debug+:: if true, error messages are logged.  See #debug
  def initialize(port, host = DEFAULT_HOST, maxConnections = 4,
    stdlog = $stderr, audit = false, debug = false)
    @tcpServerThread = nil
    @port = port
    @host = host
    @maxConnections = maxConnections
    @connections = []
    @connectionsMutex = Mutex.new
    @connectionsCV = ConditionVariable.new
    @stdlog = stdlog
    @audit = audit
    @debug = debug
  end

# Start the server if it isn't already running
  #
  # +maxConnections+::
  #   override +maxConnections+ given to the constructor.  A negative
  #   value indicates that the value from the constructor should be used.
  def start(maxConnections = -1)
    raise "server is already running" if !stopped?
    @shutdown = false
    @maxConnections = maxConnections if maxConnections > 0
    @@servicesMutex.synchronize  {
      if GServer.in_service?(@port,@host)
        raise "Port already in use: #{host}:#{@port}!"
      end
      @tcpServer = TCPServer.new(@host,@port)
      @port = @tcpServer.addr[1]
      @@services[@host] = {} unless @@services.has_key?(@host)
      @@services[@host][@port] = self;
    }
    @tcpServerThread = Thread.new {
      begin
        starting if @audit
        while !@shutdown
          @connectionsMutex.synchronize  {
             while @connections.size >= @maxConnections
               @connectionsCV.wait(@connectionsMutex)
             end
          }
          client = @tcpServer.accept
          Thread.new(client)  { |myClient|
            @connections << Thread.current
            begin
              myPort = myClient.peeraddr[1]
              serve(myClient) if !@audit or connecting(myClient)
            rescue => detail
              error(detail) if @debug
            ensure
              begin
                myClient.close
              rescue
              end
              @connectionsMutex.synchronize {
                @connections.delete(Thread.current)
                @connectionsCV.signal
              }
              disconnecting(myPort) if @audit
            end
          }
        end
      rescue => detail
        error(detail) if @debug
      ensure
        begin
          @tcpServer.close
        rescue
        end
        if @shutdown
          @connectionsMutex.synchronize  {
             while @connections.size > 0
               @connectionsCV.wait(@connectionsMutex)
             end
          }
        else
          @connections.each { |c| c.raise "stop" }
        end
        @tcpServerThread = nil
        @@servicesMutex.synchronize  {
          @@services[@host].delete(@port)
        }
        stopping if @audit
      end
    }
    self
  end

end

X7ROOT File Manager

Editing: gserver.rb

Upload File

Create Folder