---

yaml
---
r: 15358
b: refs/heads/try
c: af08aba
h: refs/heads/master
v: v3

Author: olsonjeffery

[refs]

@@ -2,5 +2,5 @@
 refs/heads/master: 61b1875c16de39c166b0f4d54bba19f9c6777d1a
 refs/heads/snap-stage1: e33de59e47c5076a89eadeb38f4934f58a3618a6
 refs/heads/snap-stage3: 4a81779abd786ff22d71434c6d9a5917ea4cdfff
-refs/heads/try: 3817ba7578a5044a5572f35de367b6ca31a35bc0
+refs/heads/try: af08aba5736aacae6662a2ac586bb559f0704cdc
 refs/tags/release-0.1: 1f5c5126e96c79d22cb7862f75304136e204f105

branches/try/src/libstd/uv.rs

@@ -273,7 +273,7 @@ native mod rustrt {
         loop_handle: *ctypes::void,
         handle_ptr: *uv_tcp_t) -> ctypes::c_int;
     fn rust_uv_buf_init(base: *u8, len: ctypes::size_t)
-        -> uv_buf_t;
+        -> *ctypes::void;
     fn rust_uv_last_error(loop_handle: *ctypes::void) -> uv_err_t;
     fn rust_uv_ip4_addr(ip: *u8, port: ctypes::c_int)
         -> *ctypes::void;
@@ -352,10 +352,6 @@ mod direct {
     unsafe fn write_t() -> uv_write_t {
         ret gen_stub_uv_write_t();
     }
-    // FIXME: see github issue #1402
-    unsafe fn buf_init(input: *u8, len: uint) -> *ctypes::void {
-        ret rustrt::rust_uv_buf_init(input, len);
-    }
     unsafe fn get_loop_for_uv_handle(handle: *ctypes::void)
         -> *ctypes::void {
         ret rustrt::rust_uv_get_loop_for_uv_handle(handle);
@@ -373,6 +369,10 @@ mod direct {
         rustrt::rust_uv_set_data_for_req(req, data);
     }
     // FIXME: see github issue #1402
+    unsafe fn buf_init(input: *u8, len: uint) -> *ctypes::void {
+        ret rustrt::rust_uv_buf_init(input, len);
+    }
+    // FIXME: see github issue #1402
     unsafe fn ip4_addr(ip: str, port: ctypes::c_int)
     -> *ctypes::void {
         let addr_vec = str::bytes(ip);
@@ -382,10 +382,9 @@ mod direct {
         io::println(#fmt("vec val: '%s' length: %u",ip_back, vec::len(addr_vec)));
         ret rustrt::rust_uv_ip4_addr(addr_vec_ptr, port);
     }
-
     // this is lame.
     // FIXME: see github issue #1402
-    unsafe fn ip4_addr_free(ptr: *ctypes::void) {
+    unsafe fn free_1402(ptr: *ctypes::void) {
         rustrt::rust_uv_free(ptr);
     }
 }
@@ -1033,7 +1032,7 @@ fn impl_uv_tcp_request() unsafe {
             direct::run(test_loop);
             io::println("after run tcp req loop");
             // FIXME: see github issue #1402
-            direct::ip4_addr_free(addr);
+            direct::free_1402(addr);
         }
         else {
            io::println("direct::tcp_connect() failure");

branches/try/src/rt/rust_uv.cpp

@@ -234,9 +234,22 @@ rust_uv_get_stream_handle_for_connect(uv_connect_t* connect) {
   return connect->handle;
 }
 
-extern "C" uv_buf_t
+static uv_buf_t
+current_kernel_malloc_alloc_cb(uv_handle_t* handle,
+							   size_t suggested_size) {
+  char* base_ptr = (char*)current_kernel_malloc(sizeof(char)
+											* suggested_size,
+										 "uv_buf_t_base_val");
+  return uv_buf_init(base_ptr, suggested_size);
+}
+
+// FIXME see issue #1402
+extern "C" void*
 rust_uv_buf_init(char* base, size_t len) {
-  return uv_buf_init(base, len);
+  uv_buf_t* buf_ptr = current_kernel_malloc(sizeof(uv_buf_t),
+											"uv_buf_t_1402");
+  *buf_ptr = uv_buf_init(base, len);
+  return buf_ptr;
 }
 
 extern "C" uv_loop_t*