---

yaml
---
r: 31403
b: refs/heads/dist-snap
c: b97fe98
h: refs/heads/master
i:
  31401: f9547cf
  31399: 7631c33
v: v3

Author: eholk

[refs]

@@ -7,6 +7,6 @@ refs/tags/release-0.1: 1f5c5126e96c79d22cb7862f75304136e204f105
 refs/heads/ndm: f3868061cd7988080c30d6d5bf352a5a5fe2460b
 refs/heads/try2: d0c6ce338884ee21843f4b40bf6bf18d222ce5df
 refs/heads/incoming: d9317a174e434d4c99fc1a37fd7dc0d2f5328d37
-refs/heads/dist-snap: c28af2625870b2117e73fc8bee83a1704cff7414
+refs/heads/dist-snap: b97fe9835430553c0b566cf1f5687e6c7403821b
 refs/tags/release-0.2: c870d2dffb391e14efb05aa27898f1f6333a9596
 refs/tags/release-0.3: b5f0d0f648d9a6153664837026ba1be43d3e2503

branches/dist-snap/src/libsyntax/ext/pipes/ast_builder.rs

@@ -91,9 +91,22 @@ trait ext_ctxt_ast_builder {
                     +params: ~[ast::ty_param]) -> @ast::item;
     fn item_ty(name: ident, ty: @ast::ty) -> @ast::item;
     fn ty_vars(+ty_params: ~[ast::ty_param]) -> ~[@ast::ty];
+    fn ty_field_imm(name: ident, ty: @ast::ty) -> ast::ty_field;
+    fn ty_rec(+~[ast::ty_field]) -> @ast::ty;
 }
 
 impl ast_builder of ext_ctxt_ast_builder for ext_ctxt {
+    fn ty_field_imm(name: ident, ty: @ast::ty) -> ast::ty_field {
+        {node: {ident: name, mt: { ty: ty, mutbl: ast::m_imm } },
+          span: empty_span()}
+    }
+
+    fn ty_rec(+fields: ~[ast::ty_field]) -> @ast::ty {
+        @{id: self.next_id(),
+          node: ast::ty_rec(fields),
+          span: empty_span()}
+    }
+
     fn ty_param(id: ast::ident, +bounds: ~[ast::ty_param_bound])
         -> ast::ty_param
     {

branches/dist-snap/src/libsyntax/ext/pipes/pipec.rs

@@ -204,6 +204,7 @@ impl compile of to_type_decls for state {
 
 impl compile of gen_init for protocol {
     fn gen_init(cx: ext_ctxt) -> @ast::item {
+        #debug("gen_init");
         let start_state = self.states[0];
 
         let body = alt start_state.dir {
@@ -237,6 +238,23 @@ impl compile of gen_init for protocol {
             server_states += s.to_endpoint_decls(cx, recv);
         }
 
+        if self.is_bounded() {
+            vec::push(
+                items,
+                cx.item_ty(
+                    @~"buffer",
+                    cx.ty_rec(
+                        (copy self.states).map_to_vec(
+                            |s| cx.ty_field_imm(
+                                s.name,
+                                cx.ty_path_ast_builder(
+                                    (path(@~"pipes")
+                                     + @~"packet")
+                                    .add_ty(
+                                        cx.ty_path_ast_builder(
+                                            path(s.name)))))))))
+        }
+
         vec::push(items,
                   cx.item_mod(@~"client",
                               client_states));