Ruby » ruby-trunk

        while fds = IO::select([ua, os])

          if fds[0].member?(ua)

            buf = ua.sysread(1024);

            os.syswrite(buf)

          elsif fds[0].member?(os)

            buf = os.sysread(1024);

            ua.syswrite(buf)

          end

        end

      def do_GET(req, res)

        st = File::stat(@local_path)

        mtime = st.mtime

        if not_modified?(req, res, mtime, res['etag'])

          res.body = ''

          raise HTTPStatus::NotModified

        elsif req['range'] 

          raise HTTPStatus::PartialContent

        else

          mtype = HTTPUtils::mime_type(@local_path, @config[:MimeTypes])

          res['content-type'] = mtype

          res['last-modified'] = mtime.httpdate

          res.body = open(@local_path, "rb")

        end

            "Unrecognized range-spec: \"#{req['range']}\""

        end

        open(filename, "rb"){|io|

            time = Time.now

            boundary = "#{time.sec}_#{time.usec}_#{Process::pid}"

            body = ''

        path = res.filename + basename

        if File.file?(path)

          return basename

          req.accept_language.each{|lang|

            path_with_lang = path + ".#{lang}"

            if langs.member?(lang) && File.file?(path_with_lang)

          elsif st.directory?

            [ name + "/", st.mtime, -1 ]

          else

          end

        }

        list.compact!

        list.each{ |name, time, size|

          if name == ".."

            dname = "Parent Directory"

            dname = name.sub(/^(.{23})(?:.*)/, '\1..')

          else

            dname = name

          end

          s =  " <A HREF=\"#{HTTPUtils::escape(name)}\">#{dname}</A>"

          s << (time ? time.strftime("%Y/%m/%d %H:%M      ") : " " * 22)

          s << (size >= 0 ? size.to_s : "-") << "\n"

          res.body << s

          end

          dump = Marshal.dump(meta)

          cgi_in.write(cgi_out.path)

          cgi_in.write(cgi_err.path)

          cgi_in.write(dump)

            cgi_in.write(req.body)

          end

        ensure

          data = cgi_out.read

          cgi_out.close(true)

          if errmsg = cgi_err.read

              @logger.error("CGIHandler: #{@script_filename}:\n" + errmsg)

            end

          end 

      def redirect_to_directory_uri(req, res)

        if req.path[-1] != ?/

          location = WEBrick::HTTPUtils.escape_path(req.path + "/")

            location << "?" << req.query_string

          end

          res.set_redirect(HTTPStatus::MovedPermanently, location)

  while size > 0

    tmp = io.sysread(size)

    buf << tmp

  end

  return buf

end

    def read_request_line(socket)

      @request_line = read_line(socket, 1024) if socket

        raise HTTPStatus::RequestURITooLarge

      end

      @request_time = Time.now

      elsif self["host"]

        pattern = /\A(#{URI::REGEXP::PATTERN::HOST})(?::(\d+))?\z/n

        host, port = *self['host'].scan(pattern)[0]

        host, port = @addr[2], @addr[1]

      else

        host, port = @config[:ServerName], @config[:Port]

        while @remaining_size > 0 

          sz = [@buffer_size, @remaining_size].min

          break unless buf = read_data(socket, sz)

          block.call(buf)

        end

        if @remaining_size > 0 && @socket.eof?

      chunk_size, = read_chunk_size(socket)

      while chunk_size > 0

        data = read_data(socket, chunk_size) # read chunk-data

          raise BadRequest, "bad chunk data size."

        end

        read_line(socket)                    # skip CRLF

        @header.delete('content-length')

      elsif @header['content-length'].nil?

        unless @body.is_a?(IO)

        end

      end

          while buf = @body.read(@buffer_size)

            next if buf.empty?

            data = ""

            data << buf << CRLF

            _write_data(socket, data)

          end

          _write_data(socket, "0#{CRLF}#{CRLF}")

        else

      if @request_method == "HEAD"

        # do nothing

      elsif chunked?

        while buf = @body[@sent_size, @buffer_size]

          break if buf.empty?

          data = ""

          data << buf << CRLF

          _write_data(socket, data)

        end

        _write_data(socket, "0#{CRLF}#{CRLF}")

      else

          _write_data(socket, @body)

        end

      end

    end

      while offset > 0

        sz = @buffer_size < size ? @buffer_size : size

        buf = input.read(sz)

      end

      if size == 0

          sz = @buffer_size < size ? @buffer_size : size

          buf = input.read(sz)

          _write_data(output, buf)

        end

      end

    end

      def split_param_value(string)

        ret = {}

          case string           

          when /^\s*([\w\-\.\*\%\!]+)=\s*\"((\\.|[^\"])*)\"\s*,?/

            key = $1

                 "abcdefghijklmnopqrstuvwxyz" 

    def random_string(len)

      ret = "" 

      len.times{ ret << RAND_CHARS[rand(rand_max)] }

      ret