JezK
Edit File: abstract_request_handler_spec.rb
require 'support/config' require 'support/test_helper' require 'phusion_passenger/abstract_request_handler' require 'fileutils' include PhusionPassenger describe AbstractRequestHandler do before :each do @old_passenger_tmpdir = Utils.passenger_tmpdir Utils.passenger_tmpdir = "abstract_request_handler_spec.tmp" @owner_pipe = IO.pipe @request_handler = AbstractRequestHandler.new(@owner_pipe[1]) def @request_handler.process_request(*args) # Do nothing. end end after :each do @request_handler.cleanup @owner_pipe[0].close rescue nil Utils.passenger_tmpdir = @old_passenger_tmpdir FileUtils.rm_rf("abstract_request_handler_spec.tmp") end def prepare # Do nothing. To be overrided by sub describe blocks. end it "exits if the owner pipe is closed" do @request_handler.start_main_loop_thread @owner_pipe[0].close begin Timeout.timeout(5) do wait_until do !@request_handler.main_loop_running? end end rescue Timeout::Error violated end end it "ignores new connections that don't send any data" do def @request_handler.accept_connection return nil end @request_handler.start_main_loop_thread wait_until do @request_handler.iterations != 0 end @request_handler.processed_requests.should == 0 end it "creates a socket file in the Phusion Passenger temp folder, unless when using TCP sockets" do if @request_handler.socket_type == "unix" File.chmod(0700, "abstract_request_handler_spec.tmp/backends") Dir["abstract_request_handler_spec.tmp/backends/*"].should_not be_empty end end it "accepts pings" do @request_handler.start_main_loop_thread if @request_handler.socket_type == "unix" client = UNIXSocket.new(@request_handler.socket_name) else addr, port = @request_handler.socket_name.split(/:/) client = TCPSocket.new(addr, port.to_i) end begin channel = MessageChannel.new(client) channel.write_scalar("REQUEST_METHOD\0ping\0") client.read.should == "pong" ensure client.close end end def wait_until while !yield sleep 0.01 end end end