src/mojo/common/test/test_utils_posix.cc

   1 // Copyright 2014 The Chromium Authors. All rights reserved.
   2 // Use of this source code is governed by a BSD-style license that can be
   3 // found in the LICENSE file.
   4
   5 #include "mojo/common/test/test_utils.h"
   6
   7 #include <fcntl.h>
   8 #include <unistd.h>
   9
  10 #include "base/base_paths.h"
  11 #include "base/path_service.h"
  12 #include "base/posix/eintr_wrapper.h"
  13
  14 namespace mojo {
  15 namespace test {
  16
  17 bool BlockingWrite(const embedder::PlatformHandle& handle,
  18                    const void* buffer,
  19                    size_t bytes_to_write,
  20                    size_t* bytes_written) {
  21   int original_flags = fcntl(handle.fd, F_GETFL);
  22   if (original_flags == -1 ||
  23       fcntl(handle.fd, F_SETFL, original_flags & (~O_NONBLOCK)) != 0) {
  24     return false;
  25   }
  26
  27   ssize_t result = HANDLE_EINTR(write(handle.fd, buffer, bytes_to_write));
  28
  29   fcntl(handle.fd, F_SETFL, original_flags);
  30
  31   if (result < 0)
  32     return false;
  33
  34   *bytes_written = result;
  35   return true;
  36 }
  37
  38 bool BlockingRead(const embedder::PlatformHandle& handle,
  39                   void* buffer,
  40                   size_t buffer_size,
  41                   size_t* bytes_read) {
  42   int original_flags = fcntl(handle.fd, F_GETFL);
  43   if (original_flags == -1 ||
  44       fcntl(handle.fd, F_SETFL, original_flags & (~O_NONBLOCK)) != 0) {
  45     return false;
  46   }
  47
  48   ssize_t result = HANDLE_EINTR(read(handle.fd, buffer, buffer_size));
  49
  50   fcntl(handle.fd, F_SETFL, original_flags);
  51
  52   if (result < 0)
  53     return false;
  54
  55   *bytes_read = result;
  56   return true;
  57 }
  58
  59 bool NonBlockingRead(const embedder::PlatformHandle& handle,
  60                      void* buffer,
  61                      size_t buffer_size,
  62                      size_t* bytes_read) {
  63   ssize_t result = HANDLE_EINTR(read(handle.fd, buffer, buffer_size));
  64
  65   if (result < 0) {
  66     if (errno != EAGAIN && errno != EWOULDBLOCK)
  67       return false;
  68
  69     *bytes_read = 0;
  70   } else {
  71     *bytes_read = result;
  72   }
  73
  74   return true;
  75 }
  76
  77 embedder::ScopedPlatformHandle PlatformHandleFromFILE(base::ScopedFILE fp) {
  78   CHECK(fp);
  79   int rv = dup(fileno(fp.get()));
  80   PCHECK(rv != -1) << "dup";
  81   return embedder::ScopedPlatformHandle(embedder::PlatformHandle(rv));
  82 }
  83
  84 base::ScopedFILE FILEFromPlatformHandle(embedder::ScopedPlatformHandle h,
  85                                         const char* mode) {
  86   CHECK(h.is_valid());
  87   base::ScopedFILE rv(fdopen(h.release().fd, mode));
  88   PCHECK(rv) << "fdopen";
  89   return rv.Pass();
  90 }
  91
  92 base::FilePath GetFilePathForJSResource(const std::string& path) {
  93   std::string binding_path = "gen/" + path + ".js";
  94   base::FilePath exe_dir;
  95   PathService::Get(base::DIR_EXE, &exe_dir);
  96   return exe_dir.AppendASCII(binding_path);
  97 }
  98
  99 }  // namespace test
 100 }  // namespace mojo