diff --git a/src/servo/content.rs b/src/servo/content.rs index 24b2351977f..a8176a0e12d 100644 --- a/src/servo/content.rs +++ b/src/servo/content.rs @@ -10,7 +10,7 @@ export create_content; export Document; import std::arc::{arc, clone}; -import comm::{port, chan, listen, select2}; +import comm::{Port, Chan, port, chan, listen, select2}; import task::{spawn, spawn_listener}; import io::{read_whole_file, println}; import result::{ok, err}; @@ -88,7 +88,7 @@ class Content { let resource_task: ResourceTask; - new(layout: Layout, sink: S, from_master: port, resource_task: ResourceTask) { + new(layout: Layout, sink: S, from_master: Port, resource_task: ResourceTask) { self.layout = layout; self.sink = sink; self.from_master = from_master; @@ -219,7 +219,7 @@ class Content { } } -fn create_content(layout: Layout, sink: S, resource_task: ResourceTask) -> chan { +fn create_content(layout: Layout, sink: S, resource_task: ResourceTask) -> Chan { do spawn_listener:: |from_master| { Content(layout, sink, from_master, resource_task).start(); } diff --git a/src/servo/gfx/geometry.rs b/src/servo/gfx/geometry.rs index f0c8bf52d69..731c8ee50f2 100644 --- a/src/servo/gfx/geometry.rs +++ b/src/servo/gfx/geometry.rs @@ -6,15 +6,15 @@ import num::Num; enum au = int; impl au : Num { - pure fn add(&&other: au) -> au { au(*self + *other) } - pure fn sub(&&other: au) -> au { au(*self - *other) } - pure fn mul(&&other: au) -> au { au(*self * *other) } - pure fn div(&&other: au) -> au { au(*self / *other) } - pure fn modulo(&&other: au) -> au { au(*self % *other) } - pure fn neg() -> au { au(-*self) } + pure fn add(&&other: au) -> au { au(*self + *other) } + pure fn sub(&&other: au) -> au { au(*self - *other) } + pure fn mul(&&other: au) -> au { au(*self * *other) } + pure fn div(&&other: au) -> au { au(*self / *other) } + pure fn modulo(&&other: au) -> au { au(*self % *other) } + pure fn neg() -> au { au(-*self) } - pure fn to_int() -> int { *self } - pure fn from_int(n: int) -> au { au(n) } + pure fn to_int() -> int { *self } + static pure fn from_int(n: int) -> au { au(n) } } fn box(x: A, y: A, w: A, h: A) -> Rect { diff --git a/src/servo/gfx/pngsink.rs b/src/servo/gfx/pngsink.rs index ad6d7358ce8..8973690b61c 100644 --- a/src/servo/gfx/pngsink.rs +++ b/src/servo/gfx/pngsink.rs @@ -20,7 +20,7 @@ import cairo_bg::{cairo_image_surface_create, cairo_surface_destroy, cairo_surface_write_to_png_stream}; import renderer::{Renderer, Sink, RenderMsg}; import task::spawn_listener; -import comm::{chan, port}; +import comm::{Chan, Port, chan, port}; import unsafe::reinterpret_cast; import vec_from_buf = vec::unsafe::from_buf; import ptr::addr_of; @@ -28,7 +28,7 @@ import dom::event::Event; import dvec::dvec; import layout::display_list::display_list; -type PngSink = chan; +type PngSink = Chan; enum Msg { BeginDrawing(pipes::chan), @@ -36,20 +36,20 @@ enum Msg { Exit } -impl chan : Sink { +impl Chan : Sink { fn begin_drawing(+next_dt: pipes::chan) { self.send(BeginDrawing(next_dt)) } fn draw(+next_dt: pipes::chan, draw_me: AzDrawTargetRef) { self.send(Draw(next_dt, draw_me)) } - fn add_event_listener(_listener: chan) { + fn add_event_listener(_listener: Chan) { // No events in this sink. } } -fn PngSink(output: chan<~[u8]>) -> PngSink { - do spawn_listener |po: port| { +fn PngSink(output: Chan<~[u8]>) -> PngSink { + do spawn_listener |po: Port| { let cairo_surface = ImageSurface(CAIRO_FORMAT_ARGB32, 800, 600); let draw_target = DrawTarget(cairo_surface); @@ -71,7 +71,7 @@ fn PngSink(output: chan<~[u8]>) -> PngSink { fn do_draw(sender: pipes::chan, dt: AzDrawTargetRef, - output: chan<~[u8]>, + output: Chan<~[u8]>, cairo_surface: ImageSurface) { let buffer = io::mem_buffer(); cairo_surface.write_to_png_stream(&buffer); diff --git a/src/servo/layout/layout_task.rs b/src/servo/layout/layout_task.rs index ff5a35ce178..f7199cf43b2 100644 --- a/src/servo/layout/layout_task.rs +++ b/src/servo/layout/layout_task.rs @@ -16,11 +16,11 @@ import style::apply::apply_style; import task::*; import comm::*; -type Layout = chan; +type Layout = Chan; enum Msg { BuildMsg(Node, arc, url), - PingMsg(chan), + PingMsg(Chan), ExitMsg } diff --git a/src/servo/parser/html_lexer.rs b/src/servo/parser/html_lexer.rs index 7884c784f31..f1c3bd62686 100644 --- a/src/servo/parser/html_lexer.rs +++ b/src/servo/parser/html_lexer.rs @@ -1,4 +1,4 @@ -import comm::{port, chan}; +import comm::{Port, Chan, port, chan}; import dom::style; import option::is_none; import str::from_bytes; @@ -166,7 +166,7 @@ impl HtmlLexer : HtmlLexerMethods { } } -fn lexer(+input_port: port, state : ParseState) -> HtmlLexer { +fn lexer(+input_port: Port, state : ParseState) -> HtmlLexer { return { input_state: { mut lookahead: none, @@ -179,7 +179,7 @@ fn lexer(+input_port: port, state : ParseState) -> H } #[allow(non_implicitly_copyable_typarams)] -fn spawn_html_lexer_task(-url: url, resource_task: ResourceTask) -> port { +fn spawn_html_lexer_task(-url: url, resource_task: ResourceTask) -> Port { let html_port = port(); let html_chan = chan(html_port); diff --git a/src/servo/parser/lexer_util.rs b/src/servo/parser/lexer_util.rs index b8e5d7fd3ca..6532e944930 100644 --- a/src/servo/parser/lexer_util.rs +++ b/src/servo/parser/lexer_util.rs @@ -3,7 +3,7 @@ import option::is_none; import str::from_bytes; import vec::push; -import comm::port; +import comm::Port; import resource::resource_task::{ProgressMsg, Payload, Done}; enum CharOrEof { @@ -14,7 +14,7 @@ enum CharOrEof { type InputState = { mut lookahead: option, mut buffer: ~[u8], - input_port: port, + input_port: Port, mut eof: bool }; diff --git a/src/servo/platform/osmain.rs b/src/servo/platform/osmain.rs index 7d1fe3b7677..ab3ddb9b948 100644 --- a/src/servo/platform/osmain.rs +++ b/src/servo/platform/osmain.rs @@ -39,7 +39,7 @@ fn OSMain() -> OSMain { } } -fn mainloop(po: port) { +fn mainloop(po: Port) { let key_handlers: @DVec> = @dvec(); let event_listeners: @DVec> = @dvec(); diff --git a/src/servo/resource/file_loader.rs b/src/servo/resource/file_loader.rs index f6e87dc902c..b765d1b6b42 100644 --- a/src/servo/resource/file_loader.rs +++ b/src/servo/resource/file_loader.rs @@ -1,6 +1,6 @@ export factory; -import comm::chan; +import comm::Chan; import task::spawn; import resource_task::{ProgressMsg, Payload, Done}; import std::net::url::url; @@ -9,7 +9,7 @@ import result::{result, ok, err}; const READ_SIZE: uint = 1024; -fn factory(+url: url, progress_chan: chan) { +fn factory(+url: url, progress_chan: Chan) { assert url.scheme == ~"file"; do spawn { diff --git a/src/servo/resource/http_loader.rs b/src/servo/resource/http_loader.rs index 8713e7c20c2..b0f90aa94e0 100644 --- a/src/servo/resource/http_loader.rs +++ b/src/servo/resource/http_loader.rs @@ -1,13 +1,13 @@ export factory; -import comm::chan; +import comm::Chan; import task::spawn; import resource_task::{ProgressMsg, Payload, Done}; import std::net::url::url; import http_client::{uv_http_request}; import result::{ok, err}; -fn factory(+url: url, progress_chan: chan) { +fn factory(+url: url, progress_chan: Chan) { assert url.scheme == ~"http"; do spawn { diff --git a/src/servo/resource/image_cache_task.rs b/src/servo/resource/image_cache_task.rs index 6ee5fd5d397..be917353811 100644 --- a/src/servo/resource/image_cache_task.rs +++ b/src/servo/resource/image_cache_task.rs @@ -7,7 +7,7 @@ export ImageCacheTaskClient; import image::base::{Image, load_from_memory, test_image_bin}; import std::net::url::url; import util::url::{make_url, UrlMap, url_map}; -import comm::{chan, port}; +import comm::{Chan, Port, chan, port}; import task::{spawn, spawn_listener}; import resource::resource_task; import resource_task::ResourceTask; @@ -26,7 +26,7 @@ enum Msg { /*priv*/ StorePrefetchedImageData(url, result, ()>), /// Request an Image object for a URL - GetImage(url, chan), + GetImage(url, Chan), /// Used by the decoder tasks to post decoded images back to the cache /*priv*/ StoreImage(url, arc<~Image>), @@ -35,7 +35,7 @@ enum Msg { /*priv*/ OnMsg(fn~(msg: &Msg)), /// Clients must wait for a response before shutting down the ResourceTask - Exit(chan<()>) + Exit(Chan<()>) } enum ImageResponseMsg { @@ -43,7 +43,7 @@ enum ImageResponseMsg { ImageNotReady } -type ImageCacheTask = chan; +type ImageCacheTask = Chan; fn image_cache_task(resource_task: ResourceTask) -> ImageCacheTask { do spawn_listener |from_client| { @@ -60,10 +60,10 @@ struct ImageCache { /// A handle to the resource task for fetching the image binaries resource_task: ResourceTask; /// The port on which we'll receive client requests - from_client: port; + from_client: Port; /// The state of processsing an image for a URL state_map: UrlMap; - mut need_exit: option>; + mut need_exit: option>; } enum ImageState { @@ -76,7 +76,7 @@ enum ImageState { } struct FutureData { - mut waiters: ~[chan]; + mut waiters: ~[Chan]; } #[allow(non_implicitly_copyable_typarams)] @@ -203,7 +203,7 @@ impl ImageCache { } } - /*priv*/ fn get_image(+url: url, response: chan) { + /*priv*/ fn get_image(+url: url, response: Chan) { match self.get_state(copy url) { Init => fail ~"Request for image before prefetch", @@ -323,7 +323,7 @@ fn should_exit_on_request() { let mock_resource_task = do spawn_listener |from_client| { // infer me - let from_client: port = from_client; + let from_client: Port = from_client; loop { match from_client.recv() { @@ -363,7 +363,7 @@ fn should_request_url_from_resource_task_on_prefetch() { let mock_resource_task = do spawn_listener |from_client| { // infer me - let from_client: port = from_client; + let from_client: Port = from_client; loop { match from_client.recv() { @@ -393,7 +393,7 @@ fn should_not_request_url_from_resource_task_on_multiple_prefetches() { let mock_resource_task = do spawn_listener |from_client| { // infer me - let from_client: port = from_client; + let from_client: Port = from_client; loop { match from_client.recv() { @@ -425,7 +425,7 @@ fn should_return_image_not_ready_if_data_has_not_arrived() { let mock_resource_task = do spawn_listener |from_client| { // infer me - let from_client: port = from_client; + let from_client: Port = from_client; loop { match from_client.recv() { @@ -458,7 +458,7 @@ fn should_return_decoded_image_data_if_data_has_arrived() { let mock_resource_task = do spawn_listener |from_client| { // infer me - let from_client: port = from_client; + let from_client: Port = from_client; loop { match from_client.recv() { @@ -506,7 +506,7 @@ fn should_return_decoded_image_data_for_multiple_requests() { let mock_resource_task = do spawn_listener |from_client| { // infer me - let from_client: port = from_client; + let from_client: Port = from_client; loop { match from_client.recv() { @@ -562,7 +562,7 @@ fn should_not_request_image_from_resource_task_if_image_is_already_available() { let mock_resource_task = do spawn_listener |from_client| { // infer me - let from_client: port = from_client; + let from_client: Port = from_client; loop { match from_client.recv() { @@ -633,7 +633,7 @@ fn should_not_request_image_from_resource_task_if_image_fetch_already_failed() { let mock_resource_task = do spawn_listener |from_client| { // infer me - let from_client: port = from_client; + let from_client: Port = from_client; loop { match from_client.recv() { @@ -684,7 +684,7 @@ fn should_return_not_ready_if_image_bin_cannot_be_fetched() { let mock_resource_task = do spawn_listener |from_client| { // infer me - let from_client: port = from_client; + let from_client: Port = from_client; loop { match from_client.recv() { @@ -733,7 +733,7 @@ fn should_return_not_ready_for_multiple_get_image_requests_if_image_bin_cannot_b let mock_resource_task = do spawn_listener |from_client| { // infer me - let from_client: port = from_client; + let from_client: Port = from_client; loop { match from_client.recv() { diff --git a/src/servo/resource/resource_task.rs b/src/servo/resource/resource_task.rs index c7a83d3a8f3..735bff992d2 100644 --- a/src/servo/resource/resource_task.rs +++ b/src/servo/resource/resource_task.rs @@ -8,7 +8,7 @@ export ControlMsg, Load, Exit; export ProgressMsg, Payload, Done; export ResourceTask, ResourceManager, LoaderTaskFactory; -import comm::{chan, port}; +import comm::{Chan, Port, chan, port}; import task::{spawn, spawn_listener}; import std::net::url; import std::net::url::url; @@ -16,7 +16,7 @@ import result::{result, ok, err}; enum ControlMsg { /// Request the data associated with a particular URL - Load(url, chan), + Load(url, Chan), Exit } @@ -29,7 +29,7 @@ enum ProgressMsg { } /// Handle to a resource task -type ResourceTask = chan; +type ResourceTask = Chan; /** Creates a task to load a specific resource @@ -37,7 +37,7 @@ Creates a task to load a specific resource The ResourceManager delegates loading to a different type of loader task for each URL scheme */ -type LoaderTaskFactory = fn~(+url: url, chan); +type LoaderTaskFactory = fn~(+url: url, Chan); /// Create a ResourceTask with the default loaders fn ResourceTask() -> ResourceTask { @@ -56,11 +56,11 @@ fn create_resource_task_with_loaders(+loaders: ~[(~str, LoaderTaskFactory)]) -> } class ResourceManager { - let from_client: port; + let from_client: Port; /// Per-scheme resource loaders let loaders: ~[(~str, LoaderTaskFactory)]; - new(from_client: port, -loaders: ~[(~str, LoaderTaskFactory)]) { + new(from_client: Port, -loaders: ~[(~str, LoaderTaskFactory)]) { self.from_client = from_client; self.loaders = loaders; } @@ -78,7 +78,7 @@ class ResourceManager { } } - fn load(+url: url, progress_chan: chan) { + fn load(+url: url, progress_chan: Chan) { match self.get_loader_factory(url) { some(loader_factory) => { @@ -125,7 +125,7 @@ fn test_bad_scheme() { #[allow(non_implicitly_copyable_typarams)] fn should_delegate_to_scheme_loader() { let payload = ~[1, 2, 3]; - let loader_factory = fn~(+_url: url, progress_chan: chan, copy payload) { + let loader_factory = fn~(+_url: url, progress_chan: Chan, copy payload) { progress_chan.send(Payload(copy payload)); progress_chan.send(Done(ok(()))); };