diff --git a/helpers/DATA/ruby1.9.1/gserver.rb b/helpers/DATA/ruby1.9.1/gserver.rb deleted file mode 100644 index 4dd5ad0c0807d303de61b9be4a471b3fe0ce65a1..0000000000000000000000000000000000000000 --- a/helpers/DATA/ruby1.9.1/gserver.rb +++ /dev/null @@ -1,309 +0,0 @@ -# -# 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_s) -# 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 at ime, 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 instances 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 - @connections << Thread.new(client) { |myClient| - 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 diff --git a/helpers/make-ruby1.9.1 b/helpers/make-ruby1.9.1 deleted file mode 100644 index 9b337c023d612e6baa8c878643b188c8d5352c42..0000000000000000000000000000000000000000 --- a/helpers/make-ruby1.9.1 +++ /dev/null @@ -1,29 +0,0 @@ -#!/bin/sh -# -# Copyright (C) 2015 Legimet <legimet.calc@gmail.com> -# -# This program is free software; you can redistribute it and/or modify -# it under the terms of the GNU General Public License as published by -# the Free Software Foundation; either version 2 of the License, or -# (at your option) any later version. -# -# This program is distributed in the hope that it will be useful, -# but WITHOUT ANY WARRANTY; without even the implied warranty of -# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the -# GNU General Public License for more details. -# -# You should have received a copy of the GNU General Public License -# along with this program; if not, write to the Free Software -# Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA -# - -VERSION=1 - -. ./config - -cp $DATA/gserver.rb lib/gserver.rb - -changelog "Replace nonfree file with free version, #10078" - -compile -