-Go bindings for creating/managing shared buffers between applications

mojo/go/tests/system_test.go

 // Copyright 2014 The Chromium Authors. All rights reserved.
 // Use of this source code is governed by a BSD-style license that can be
 // found in the LICENSE file.
 
 package tests
 
 import (
         "bytes"
+        "testing"
+        "unsafe"
+
         "mojo/go/system/embedder"
         "mojo/public/go/system"
         m "mojo/public/go/system/impl"
-        "testing"
 )
 
 var core system.Core
 
 func init() {
         embedder.InitializeMojoEmbedder()
         core = m.GetCore()
 }
 
 func TestGetTimeTicksNow(t *testing.T) {
@@ skipping 84 matching lines @@
         if r = core.Close(hp); r != m.MOJO_RESULT_OK {
                 t.Fatalf("Close on hp failed:%v", r)
         }
         if r = core.Wait(hc, m.MOJO_HANDLE_SIGNAL_READABLE, 100); r != m.MOJO_RESULT_FAILED_PRECONDITION {
                 t.Fatalf("hc should not be readable after hp closed:%v", r)
         }
         if r = core.Close(hc); r != m.MOJO_RESULT_OK {
                 t.Fatalf("Close on hc failed:%v", r)
         }
 }
+
+func TestSharedBuffer(t *testing.T) {
+        var h0, h1 m.MojoHandle
+        var bufPtr unsafe.Pointer
+        var r m.MojoResult
+
+        if r, h0 = core.CreateSharedBuffer(nil, 100); r != m.MOJO_RESULT_OK {
+                t.Fatalf("CreateSharedBuffer failed:%v", r)
+        }
+        if h0 == m.MOJO_HANDLE_INVALID {
+                t.Fatalf("CreateSharedBuffer returned an invalid handle h0:%v", h0)
+        }
+        if r, bufPtr = core.MapBuffer(h0, 0, 100, m.MOJO_MAP_BUFFER_FLAG_NONE); r != m.MOJO_RESULT_OK {
+                t.Fatalf("MapBuffer failed to map buffer with h0:%v", r)
+        }
+        bufArrayh0 := (*[100]byte)(bufPtr)
+        bufArrayh0[50] = 'x'
+        if r, h1 = core.DuplicateBufferHandle(h0, nil); r != m.MOJO_RESULT_OK {
+                t.Fatalf("DuplicateBufferHandle of h0 failed:%v", r)
+        }
+        if h1 == m.MOJO_HANDLE_INVALID {
+                t.Fatalf("DuplicateBufferHandle returned an invalid handle h1:%v", h1)
+        }
+        if r = core.Close(h0); r != m.MOJO_RESULT_OK {
+                t.Fatalf("Close on h0 failed:%v", r)
+        }
+        bufArrayh0[51] = 'y'
+        if r = core.UnmapBuffer(bufPtr); r != m.MOJO_RESULT_OK {
+                t.Fatalf("UnmapBuffer failed:%v", r)
+        }
+        if r, bufPtr = core.MapBuffer(h1, 50, 50, m.MOJO_MAP_BUFFER_FLAG_NONE); r != m.MOJO_RESULT_OK {
+                t.Fatalf("MapBuffer failed to map buffer with h1:%v", r)
+        }
+        bufArrayh1 := (*[50]byte)(bufPtr)
+        if bufArrayh1[0] != 'x' || bufArrayh1[1] != 'y' {
+                t.Fatalf("Failed to validate shared buffer. expected:x,y got:%s,%s", bufArrayh1[0], bufArrayh1[1])
+        }
+        if r = core.UnmapBuffer(bufPtr); r != m.MOJO_RESULT_OK {
+                t.Fatalf("UnmapBuffer failed:%v", r)
+        }
+        if r = core.Close(h1); r != m.MOJO_RESULT_OK {
+                t.Fatalf("Close on h1 failed:%v", r)
+        }
+}