Add CommandBroker::OnTransaction to handle incoming transactions

chromeos/binder/command_stream.cc

 // 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.
 
 #include "chromeos/binder/command_stream.h"
 
 #include <linux/android/binder.h>
 #include <stddef.h>
 #include <stdint.h>
 
@@ skipping 93 matching lines @@
     case BR_ERROR: {
       int32_t error = 0;
       if (!reader->Read(&error, sizeof(error))) {
         LOG(ERROR) << "Failed to read error code.";
         return false;
       }
       break;
     }
     case BR_OK:
       break;
-    case BR_TRANSACTION:
-      NOTIMPLEMENTED();
+    case BR_TRANSACTION: {
+      TransactionDataFromDriver data(
+          base::Bind(&CommandStream::FreeTransactionBuffer,
+                     weak_ptr_factory_.GetWeakPtr()));
+      if (!reader->Read(data.mutable_data(), sizeof(*data.mutable_data()))) {
+        LOG(ERROR) << "Failed to read transaction data.";
+        return false;
+      }
+      if (!incoming_command_handler_->OnTransaction(data)) {
+        LOG(ERROR) << "Failed to handle transaction.";
+        return false;
+      }
       break;
+    }
     case BR_REPLY: {
       scoped_ptr<TransactionDataFromDriver> data(new TransactionDataFromDriver(
           base::Bind(&CommandStream::FreeTransactionBuffer,
                      weak_ptr_factory_.GetWeakPtr())));
       binder_transaction_data* data_struct = data->mutable_data();
       if (!reader->Read(data_struct, sizeof(*data_struct))) {
         LOG(ERROR) << "Failed to read transaction data.";
         return false;
       }
       incoming_command_handler_->OnReply(std::move(data));
@@ skipping 67 matching lines @@
   }
   return true;
 }
 
 void CommandStream::FreeTransactionBuffer(const void* ptr) {
   DCHECK(thread_checker_.CalledOnValidThread());
   AppendOutgoingCommand(BC_FREE_BUFFER, &ptr, sizeof(ptr));
 }
 
 }  // namespace binder