[前][次][番号順一覧][スレッド一覧]

ruby-changes:23189

From: naruse <ko1@a...>
Date: Wed, 4 Apr 2012 21:50:15 +0900 (JST)
Subject: [ruby-changes:23189] naruse:r35239 (trunk): Use mount_proc to avoid the delay of writing data to files.

naruse	2012-04-04 21:49:12 +0900 (Wed, 04 Apr 2012)

  New Revision: 35239

  http://svn.ruby-lang.org/cgi-bin/viewvc.cgi?view=rev&revision=35239

  Log:
    Use mount_proc to avoid the delay of writing data to files.

  Modified files:
    trunk/test/open-uri/test_open-uri.rb
    trunk/test/open-uri/test_ssl.rb

Index: test/open-uri/test_open-uri.rb
===================================================================
--- test/open-uri/test_open-uri.rb	(revision 35238)
+++ test/open-uri/test_open-uri.rb	(revision 35239)
@@ -52,7 +52,7 @@
 
   def test_200
     with_http {|srv, dr, url|
-      open("#{dr}/foo200", "w") {|f| f << "foo200" }
+      srv.mount_proc("/foo200", lambda { |req, res| res.body = "foo200" } )
       open("#{url}/foo200") {|f|
         assert_equal("200", f.status[0])
         assert_equal("foo200", f.read)
@@ -63,7 +63,7 @@
   def test_200big
     with_http {|srv, dr, url|
       content = "foo200big"*10240
-      open("#{dr}/foo200big", "w") {|f| f << content }
+      srv.mount_proc("/foo200big", lambda { |req, res| res.body = content } )
       open("#{url}/foo200big") {|f|
         assert_equal("200", f.status[0])
         assert_equal(content, f.read)
@@ -80,7 +80,7 @@
 
   def test_open_uri
     with_http {|srv, dr, url|
-      open("#{dr}/foo_ou", "w") {|f| f << "foo_ou" }
+      srv.mount_proc("/foo_ou", lambda { |req, res| res.body = "foo_ou" } )
       u = URI("#{url}/foo_ou")
       open(u) {|f|
         assert_equal("200", f.status[0])
@@ -124,7 +124,7 @@
 
   def test_mode
     with_http {|srv, dr, url|
-      open("#{dr}/mode", "w") {|f| f << "mode" }
+      srv.mount_proc("/mode", lambda { |req, res| res.body = "mode" } )
       open("#{url}/mode", "r") {|f|
         assert_equal("200", f.status[0])
         assert_equal("mode", f.read)
@@ -146,7 +146,7 @@
 
   def test_without_block
     with_http {|srv, dr, url|
-      open("#{dr}/without_block", "w") {|g| g << "without_block" }
+      srv.mount_proc("/without_block", lambda { |req, res| res.body = "without_block" } )
       begin
         f = open("#{url}/without_block")
         assert_equal("200", f.status[0])
@@ -197,8 +197,7 @@
       proxy_url = "http://#{proxy_host}:#{proxy_port}/"
       begin
         proxy.start
-        open("#{dr}/proxy", "w") {|f| f << "proxy" }
-        sleep 0.5
+        srv.mount_proc("/proxy", lambda { |req, res| res.body = "proxy" } )
         open("#{url}/proxy", :proxy=>proxy_url) {|f|
           assert_equal("200", f.status[0])
           assert_equal("proxy", f.read)
@@ -251,7 +250,7 @@
       proxy_url = "http://#{proxy_host}:#{proxy_port}/"
       begin
         proxy.start
-        open("#{dr}/proxy", "w") {|f| f << "proxy" }
+        srv.mount_proc("/proxy", lambda { |req, res| res.body = "proxy" } )
         exc = assert_raise(OpenURI::HTTPError) { open("#{url}/proxy", :proxy=>proxy_url) {} }
         assert_equal("407", exc.io.status[0])
         assert_match(/#{Regexp.quote url}/, log); log.clear
@@ -420,7 +419,7 @@
 
   def test_uri_read
     with_http {|srv, dr, url|
-      open("#{dr}/uriread", "w") {|f| f << "uriread" }
+      srv.mount_proc("/uriread", lambda { |req, res| res.body = "uriread" } )
       data = URI("#{url}/uriread").read
       assert_equal("200", data.status[0])
       assert_equal("uriread", data)
Index: test/open-uri/test_ssl.rb
===================================================================
--- test/open-uri/test_ssl.rb	(revision 35238)
+++ test/open-uri/test_ssl.rb	(revision 35239)
@@ -26,7 +26,7 @@
         :Port => 0})
       _, port, _, host = srv.listeners[0].addr
       begin
-        th = srv.start
+        srv.start
         yield srv, dr, "https://#{host}:#{port}"
       ensure
         srv.shutdown
@@ -48,7 +48,7 @@
     with_https {|srv, dr, url|
       cacert_filename = "#{dr}/cacert.pem"
       open(cacert_filename, "w") {|f| f << CA_CERT }
-      open("#{dr}/data", "w") {|f| f << "ddd" }
+      srv.mount_proc("/data", lambda { |req, res| res.body = "ddd" } )
       open("#{url}/data", :ssl_ca_cert => cacert_filename) {|f|
         assert_equal("200", f.status[0])
         assert_equal("ddd", f.read)
@@ -77,8 +77,8 @@
         :Port => 0})
       _, p_port, _, p_host = prxy.listeners[0].addr
       begin
-        th = prxy.start
-        open("#{dr}/proxy", "w") {|f| f << "proxy" }
+        prxy.start
+        srv.mount_proc("/proxy", lambda { |req, res| res.body = "proxy" } )
         open("#{url}/proxy", :proxy=>"http://#{p_host}:#{p_port}/", :ssl_ca_cert => cacert_filename) {|f|
           assert_equal("200", f.status[0])
           assert_equal("proxy", f.read)

--
ML: ruby-changes@q...
Info: http://www.atdot.net/~ko1/quickml/

[前][次][番号順一覧][スレッド一覧]