Remove support for "all or none" two-phase data pipe read/write.

mojo/public/platform/native_cgo/system_cgo.go

 // Copyright 2015 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 native_cgo
 
 //#include "mojo/public/c/system/core.h"
 // // These functions are used to 8-byte align C structs.
 // MojoResult CreateSharedBuffer(struct MojoCreateSharedBufferOptions* options,
 //     uint64_t num_bytes, MojoHandle* handle) {
@@ skipping 104 matching lines @@
         // A nil options pointer in the C interface means use the default values.
         return createDataPipeWithCOptions(nil)
 }
 
 func (c *CGoSystem) WriteData(producerHandle uint32, buf []byte, flags uint32) (result uint32, bytesWritten uint32) {
         numBytes := C.uint32_t(len(buf))
         r := C.MojoWriteData(C.MojoHandle(producerHandle), unsafe.Pointer(&buf[0]), &numBytes, C.MojoWriteDataFlags(flags))
         return uint32(r), uint32(numBytes)
 }
 
-func (c *CGoSystem) BeginWriteData(producerHandle uint32, numBytes uint32, flags uint32) (result uint32, buf []byte) {
+func (c *CGoSystem) BeginWriteData(producerHandle uint32, flags uint32) (result uint32, buf []byte) {
         var buffer unsafe.Pointer
-        bufferNumBytes := C.uint32_t(numBytes)
+        var bufferNumBytes C.uint32_t
         r := C.MojoBeginWriteData(C.MojoHandle(producerHandle), &buffer, &bufferNumBytes, C.MojoWriteDataFlags(flags))
         if r != C.MOJO_RESULT_OK {
                 return uint32(r), nil
         }
         return uint32(r), unsafeByteSlice(buffer, int(bufferNumBytes))
 }
 
 func (c *CGoSystem) EndWriteData(producerHandle uint32, numBytesWritten uint32) (result uint32) {
         return uint32(C.MojoEndWriteData(C.MojoHandle(producerHandle), C.uint32_t(numBytesWritten)))
 }
 
 func (c *CGoSystem) ReadData(consumerHandle uint32, flags uint32) (result uint32, buf []byte) {
         var numBytes C.uint32_t
         if r := C.MojoReadData(C.MojoHandle(consumerHandle), nil, &numBytes, C.MOJO_READ_DATA_FLAG_QUERY); r != C.MOJO_RESULT_OK {
                 return uint32(r), nil
         }
         buf = make([]byte, int(numBytes))
         r := C.MojoReadData(C.MojoHandle(consumerHandle), unsafe.Pointer(&buf[0]), &numBytes, C.MojoReadDataFlags(flags))
         buf = buf[0:int(numBytes)]
         return uint32(r), buf
 }
 
-func (c *CGoSystem) BeginReadData(consumerHandle uint32, numBytes uint32, flags uint32) (result uint32, buf []byte) {
+func (c *CGoSystem) BeginReadData(consumerHandle uint32, flags uint32) (result uint32, buf []byte) {
         var buffer unsafe.Pointer
-        bufferNumBytes := C.uint32_t(numBytes)
+  var bufferNumBytes C.uint32_t

[rogulenko, 2015/09/25 23:23:05]

indent with tabs

         r := C.MojoBeginReadData(C.MojoHandle(consumerHandle), &buffer, &bufferNumBytes, C.MojoReadDataFlags(flags))
         if r != C.MOJO_RESULT_OK {
                 return uint32(r), nil
         }
         return uint32(r), unsafeByteSlice(buffer, int(bufferNumBytes))
 }
 
 func (c *CGoSystem) EndReadData(consumerHandle uint32, numBytesRead uint32) (result uint32) {
         return uint32(C.MojoEndReadData(C.MojoHandle(consumerHandle), C.uint32_t(numBytesRead)))
 }
@@ skipping 86 matching lines @@
                 Data: uintptr(ptr),
                 Len:  length,
                 Cap:  length,
         }
         return unsafe.Pointer(header)
 }
 
 func unsafeByteSlice(ptr unsafe.Pointer, length int) []byte {
         return *(*[]byte)(newUnsafeSlice(ptr, length))
 }