aboutsummaryrefslogtreecommitdiffhomepage
path: root/tensorflow/core/platform/windows
diff options
context:
space:
mode:
authorGravatar A. Unique TensorFlower <gardener@tensorflow.org>2018-01-30 10:05:04 -0800
committerGravatar TensorFlower Gardener <gardener@tensorflow.org>2018-01-30 12:27:47 -0800
commit7149a2e2e2f549035f23e21224ee41afe8df3876 (patch)
tree4fab32a87362e9708d07f388154a10ccb0c7800b /tensorflow/core/platform/windows
parent88eb6c61ef7659c2b5bb1ec6586c7d3cca5e4e9c (diff)
Cleanup: Ran clang-format on files in tensorflow/core/.../*.{cc,h}.
PiperOrigin-RevId: 183848459
Diffstat (limited to 'tensorflow/core/platform/windows')
-rw-r--r--tensorflow/core/platform/windows/env.cc26
-rw-r--r--tensorflow/core/platform/windows/error.cc2
-rw-r--r--tensorflow/core/platform/windows/error.h4
-rw-r--r--tensorflow/core/platform/windows/integral_types.h30
-rw-r--r--tensorflow/core/platform/windows/net.cc18
-rw-r--r--tensorflow/core/platform/windows/subprocess.h3
-rw-r--r--tensorflow/core/platform/windows/test.cc2
-rw-r--r--tensorflow/core/platform/windows/windows_file_system.cc96
-rw-r--r--tensorflow/core/platform/windows/windows_file_system.h40
9 files changed, 111 insertions, 110 deletions
diff --git a/tensorflow/core/platform/windows/env.cc b/tensorflow/core/platform/windows/env.cc
index 788a4bf4b1..41b2644170 100644
--- a/tensorflow/core/platform/windows/env.cc
+++ b/tensorflow/core/platform/windows/env.cc
@@ -24,9 +24,9 @@ limitations under the License.
#undef LoadLibrary
#undef ERROR
+#include <string>
#include <thread>
#include <vector>
-#include <string>
#include "tensorflow/core/lib/core/error_codes.pb.h"
#include "tensorflow/core/platform/load_library.h"
@@ -53,8 +53,7 @@ class StdThread : public Thread {
class WindowsEnv : public Env {
public:
- WindowsEnv()
- : GetSystemTimePreciseAsFileTime_(NULL) {
+ WindowsEnv() : GetSystemTimePreciseAsFileTime_(NULL) {
// GetSystemTimePreciseAsFileTime function is only available in the latest
// versions of Windows. For that reason, we try to look it up in
// kernel32.dll at runtime and use an alternative option if the function
@@ -72,8 +71,8 @@ class WindowsEnv : public Env {
}
bool MatchPath(const string& path, const string& pattern) override {
- std::wstring ws_path(WindowsFileSystem::Utf8ToWideChar(path));
- std::wstring ws_pattern(WindowsFileSystem::Utf8ToWideChar(pattern));
+ std::wstring ws_path(WindowsFileSystem::Utf8ToWideChar(path));
+ std::wstring ws_pattern(WindowsFileSystem::Utf8ToWideChar(pattern));
return PathMatchSpecW(ws_path.c_str(), ws_pattern.c_str()) == TRUE;
}
@@ -122,14 +121,14 @@ class WindowsEnv : public Env {
SetThreadpoolTimer(timer, &FileDueTime, 0, 0);
}
- Status LoadLibrary(const char *library_filename, void** handle) override {
+ Status LoadLibrary(const char* library_filename, void** handle) override {
std::string file_name = library_filename;
std::replace(file_name.begin(), file_name.end(), '/', '\\');
std::wstring ws_file_name(WindowsFileSystem::Utf8ToWideChar(file_name));
HMODULE hModule = LoadLibraryExW(ws_file_name.c_str(), NULL,
- LOAD_WITH_ALTERED_SEARCH_PATH);
+ LOAD_WITH_ALTERED_SEARCH_PATH);
if (!hModule) {
return errors::NotFound(file_name + " not found");
}
@@ -138,31 +137,30 @@ class WindowsEnv : public Env {
}
Status GetSymbolFromLibrary(void* handle, const char* symbol_name,
- void** symbol) override {
+ void** symbol) override {
FARPROC found_symbol;
found_symbol = GetProcAddress((HMODULE)handle, symbol_name);
if (found_symbol == NULL) {
return errors::NotFound(std::string(symbol_name) + " not found");
}
- *symbol = (void **)found_symbol;
+ *symbol = (void**)found_symbol;
return Status::OK();
}
- string FormatLibraryFileName(const string& name, const string& version)
- override {
+ string FormatLibraryFileName(const string& name,
+ const string& version) override {
string filename;
if (version.size() == 0) {
filename = name + ".dll";
- }
- else {
+ } else {
filename = name + version + ".dll";
}
return filename;
}
private:
- typedef VOID(WINAPI * FnGetSystemTimePreciseAsFileTime)(LPFILETIME);
+ typedef VOID(WINAPI* FnGetSystemTimePreciseAsFileTime)(LPFILETIME);
FnGetSystemTimePreciseAsFileTime GetSystemTimePreciseAsFileTime_;
};
diff --git a/tensorflow/core/platform/windows/error.cc b/tensorflow/core/platform/windows/error.cc
index 39e941a383..291fc5003f 100644
--- a/tensorflow/core/platform/windows/error.cc
+++ b/tensorflow/core/platform/windows/error.cc
@@ -21,7 +21,7 @@ namespace internal {
std::string GetWindowsErrorMessage(DWORD err) {
LPSTR buffer = NULL;
DWORD flags = FORMAT_MESSAGE_ALLOCATE_BUFFER | FORMAT_MESSAGE_FROM_SYSTEM |
- FORMAT_MESSAGE_IGNORE_INSERTS;
+ FORMAT_MESSAGE_IGNORE_INSERTS;
FormatMessageA(flags, NULL, err, MAKELANGID(LANG_NEUTRAL, SUBLANG_DEFAULT),
reinterpret_cast<LPSTR>(&buffer), 0, NULL);
std::string message = buffer;
diff --git a/tensorflow/core/platform/windows/error.h b/tensorflow/core/platform/windows/error.h
index 026e0d5aa9..ba643a0fa8 100644
--- a/tensorflow/core/platform/windows/error.h
+++ b/tensorflow/core/platform/windows/error.h
@@ -24,9 +24,7 @@ namespace tensorflow {
namespace internal {
std::string GetWindowsErrorMessage(DWORD err);
-
-}
}
+} // namespace tensorflow
#endif // TENSORFLOW_CORE_PLATFORM_WINDOWS_ERROR_H_
-
diff --git a/tensorflow/core/platform/windows/integral_types.h b/tensorflow/core/platform/windows/integral_types.h
index 4970b8ca6a..46338a536d 100644
--- a/tensorflow/core/platform/windows/integral_types.h
+++ b/tensorflow/core/platform/windows/integral_types.h
@@ -1,18 +1,18 @@
- /* Copyright 2017 The TensorFlow Authors. All Rights Reserved.
-
- Licensed under the Apache License, Version 2.0 (the "License");
- you may not use this file except in compliance with the License.
- You may obtain a copy of the License at
-
- http://www.apache.org/licenses/LICENSE-2.0
-
- Unless required by applicable law or agreed to in writing, software
- distributed under the License is distributed on an "AS IS" BASIS,
- WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- See the License for the specific language governing permissions and
- limitations under the License.
- ==============================================================================*/
-
+/* Copyright 2017 The TensorFlow Authors. All Rights Reserved.
+
+Licensed under the Apache License, Version 2.0 (the "License");
+you may not use this file except in compliance with the License.
+You may obtain a copy of the License at
+
+ http://www.apache.org/licenses/LICENSE-2.0
+
+Unless required by applicable law or agreed to in writing, software
+distributed under the License is distributed on an "AS IS" BASIS,
+WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+See the License for the specific language governing permissions and
+limitations under the License.
+==============================================================================*/
+
#ifndef TENSORFLOW_PLATFORM_WINDOWS_INTEGRAL_TYPES_H_
#define TENSORFLOW_PLATFORM_WINDOWS_INTEGRAL_TYPES_H_
diff --git a/tensorflow/core/platform/windows/net.cc b/tensorflow/core/platform/windows/net.cc
index 46eb072d42..2ab558ab95 100644
--- a/tensorflow/core/platform/windows/net.cc
+++ b/tensorflow/core/platform/windows/net.cc
@@ -26,7 +26,7 @@ limitations under the License.
#undef ERROR
-#pragma comment(lib,"Ws2_32.lib")
+#pragma comment(lib, "Ws2_32.lib")
namespace tensorflow {
namespace internal {
@@ -44,8 +44,8 @@ bool IsPortAvailable(int* port, bool is_tcp) {
CHECK_GE(*port, 0);
CHECK_LE(*port, 65535);
if (sock == INVALID_SOCKET) {
- LOG(ERROR) << "socket() failed: " <<
- GetWindowsErrorMessage(WSAGetLastError());
+ LOG(ERROR) << "socket() failed: "
+ << GetWindowsErrorMessage(WSAGetLastError());
return false;
}
@@ -54,8 +54,8 @@ bool IsPortAvailable(int* port, bool is_tcp) {
int result = setsockopt(sock, SOL_SOCKET, SO_REUSEADDR,
reinterpret_cast<const char*>(&one), sizeof(one));
if (result == SOCKET_ERROR) {
- LOG(ERROR) << "setsockopt() failed: " <<
- GetWindowsErrorMessage(WSAGetLastError());
+ LOG(ERROR) << "setsockopt() failed: "
+ << GetWindowsErrorMessage(WSAGetLastError());
closesocket(sock);
return false;
}
@@ -66,8 +66,8 @@ bool IsPortAvailable(int* port, bool is_tcp) {
addr.sin_port = htons((uint16_t)*port);
result = bind(sock, (struct sockaddr*)&addr, sizeof(addr));
if (result == SOCKET_ERROR) {
- LOG(WARNING) << "bind(port=" << *port << ") failed: " <<
- GetWindowsErrorMessage(WSAGetLastError());
+ LOG(WARNING) << "bind(port=" << *port
+ << ") failed: " << GetWindowsErrorMessage(WSAGetLastError());
closesocket(sock);
return false;
}
@@ -75,8 +75,8 @@ bool IsPortAvailable(int* port, bool is_tcp) {
// Get the bound port number.
result = getsockname(sock, (struct sockaddr*)&addr, &addr_len);
if (result == SOCKET_ERROR) {
- LOG(WARNING) << "getsockname() failed: " <<
- GetWindowsErrorMessage(WSAGetLastError());
+ LOG(WARNING) << "getsockname() failed: "
+ << GetWindowsErrorMessage(WSAGetLastError());
closesocket(sock);
return false;
}
diff --git a/tensorflow/core/platform/windows/subprocess.h b/tensorflow/core/platform/windows/subprocess.h
index b65313363e..66ec44885d 100644
--- a/tensorflow/core/platform/windows/subprocess.h
+++ b/tensorflow/core/platform/windows/subprocess.h
@@ -19,8 +19,7 @@ limitations under the License.
namespace tensorflow {
// SubProcess is not yet implemented for Windows.
-class SubProcess {
-};
+class SubProcess {};
} // namespace tensorflow
diff --git a/tensorflow/core/platform/windows/test.cc b/tensorflow/core/platform/windows/test.cc
index 0ffd02ff14..584acad91b 100644
--- a/tensorflow/core/platform/windows/test.cc
+++ b/tensorflow/core/platform/windows/test.cc
@@ -13,8 +13,8 @@ See the License for the specific language governing permissions and
limitations under the License.
==============================================================================*/
-#include "tensorflow/core/platform/net.h"
#include "tensorflow/core/platform/test.h"
+#include "tensorflow/core/platform/net.h"
#include "tensorflow/core/lib/strings/strcat.h"
#include "tensorflow/core/platform/logging.h"
diff --git a/tensorflow/core/platform/windows/windows_file_system.cc b/tensorflow/core/platform/windows/windows_file_system.cc
index 604348fe03..b6b3722caa 100644
--- a/tensorflow/core/platform/windows/windows_file_system.cc
+++ b/tensorflow/core/platform/windows/windows_file_system.cc
@@ -13,12 +13,12 @@ See the License for the specific language governing permissions and
limitations under the License.
==============================================================================*/
+#include <Shlwapi.h>
#include <Windows.h>
#include <direct.h>
#include <errno.h>
#include <fcntl.h>
#include <io.h>
-#include <Shlwapi.h>
#undef StrCat
#include <stdio.h>
#include <sys/stat.h>
@@ -75,16 +75,16 @@ SSIZE_T pread(HANDLE hfile, char* src, size_t num_bytes, uint64_t offset) {
if (TRUE == read_result) {
result = bytes_read;
} else if ((FALSE == read_result) &&
- ((last_error = GetLastError()) != ERROR_IO_PENDING)) {
+ ((last_error = GetLastError()) != ERROR_IO_PENDING)) {
result = (last_error == ERROR_HANDLE_EOF) ? 0 : -1;
} else {
- if (ERROR_IO_PENDING == last_error) { // Otherwise bytes_read already has the result.
- BOOL overlapped_result = ::GetOverlappedResult(hfile, &overlapped,
- &bytes_read, TRUE);
+ if (ERROR_IO_PENDING ==
+ last_error) { // Otherwise bytes_read already has the result.
+ BOOL overlapped_result =
+ ::GetOverlappedResult(hfile, &overlapped, &bytes_read, TRUE);
if (FALSE == overlapped_result) {
result = (::GetLastError() == ERROR_HANDLE_EOF) ? 0 : -1;
- }
- else {
+ } else {
result = bytes_read;
}
}
@@ -151,11 +151,11 @@ class WindowsWritableFile : public WritableFile {
Status Append(const StringPiece& data) override {
DWORD bytes_written = 0;
DWORD data_size = static_cast<DWORD>(data.size());
- BOOL write_result = ::WriteFile(hfile_, data.data(), data_size,
- &bytes_written, NULL);
+ BOOL write_result =
+ ::WriteFile(hfile_, data.data(), data_size, &bytes_written, NULL);
if (FALSE == write_result) {
- return IOErrorFromWindowsError(
- "Failed to WriteFile: " + filename_, ::GetLastError());
+ return IOErrorFromWindowsError("Failed to WriteFile: " + filename_,
+ ::GetLastError());
}
assert(size_t(bytes_written) == data.size());
@@ -171,8 +171,8 @@ class WindowsWritableFile : public WritableFile {
}
if (FALSE == ::CloseHandle(hfile_)) {
- return IOErrorFromWindowsError(
- "CloseHandle failed for: " + filename_, ::GetLastError());
+ return IOErrorFromWindowsError("CloseHandle failed for: " + filename_,
+ ::GetLastError());
}
hfile_ = INVALID_HANDLE_VALUE;
@@ -187,9 +187,7 @@ class WindowsWritableFile : public WritableFile {
return Status::OK();
}
- Status Sync() override {
- return Flush();
- }
+ Status Sync() override { return Flush(); }
};
class WinReadOnlyMemoryRegion : public ReadOnlyMemoryRegion {
@@ -204,7 +202,10 @@ class WinReadOnlyMemoryRegion : public ReadOnlyMemoryRegion {
public:
WinReadOnlyMemoryRegion(const std::string& filename, HANDLE hfile,
HANDLE hmap, const void* address, uint64 length)
- : filename_(filename), hfile_(hfile), hmap_(hmap), address_(address),
+ : filename_(filename),
+ hfile_(hfile),
+ hmap_(hmap),
+ address_(address),
length_(length) {}
~WinReadOnlyMemoryRegion() {
@@ -238,9 +239,9 @@ Status WindowsFileSystem::NewRandomAccessFile(
// almost all tests would work with a possible exception of fault_injection.
DWORD share_mode = FILE_SHARE_READ | FILE_SHARE_WRITE | FILE_SHARE_DELETE;
- HANDLE hfile = ::CreateFileW(ws_translated_fname.c_str(), GENERIC_READ,
- share_mode, NULL, OPEN_EXISTING, file_flags,
- NULL);
+ HANDLE hfile =
+ ::CreateFileW(ws_translated_fname.c_str(), GENERIC_READ, share_mode, NULL,
+ OPEN_EXISTING, file_flags, NULL);
if (INVALID_HANDLE_VALUE == hfile) {
string context = "NewRandomAccessFile failed to Create/Open: " + fname;
@@ -258,9 +259,9 @@ Status WindowsFileSystem::NewWritableFile(
result->reset();
DWORD share_mode = FILE_SHARE_READ | FILE_SHARE_WRITE | FILE_SHARE_DELETE;
- HANDLE hfile = ::CreateFileW(ws_translated_fname.c_str(), GENERIC_WRITE,
- share_mode, NULL, CREATE_ALWAYS,
- FILE_ATTRIBUTE_NORMAL, NULL);
+ HANDLE hfile =
+ ::CreateFileW(ws_translated_fname.c_str(), GENERIC_WRITE, share_mode,
+ NULL, CREATE_ALWAYS, FILE_ATTRIBUTE_NORMAL, NULL);
if (INVALID_HANDLE_VALUE == hfile) {
string context = "Failed to create a NewWriteableFile: " + fname;
@@ -278,9 +279,9 @@ Status WindowsFileSystem::NewAppendableFile(
result->reset();
DWORD share_mode = FILE_SHARE_READ | FILE_SHARE_WRITE | FILE_SHARE_DELETE;
- HANDLE hfile = ::CreateFileW(ws_translated_fname.c_str(), GENERIC_WRITE,
- share_mode, NULL, OPEN_ALWAYS,
- FILE_ATTRIBUTE_NORMAL, NULL);
+ HANDLE hfile =
+ ::CreateFileW(ws_translated_fname.c_str(), GENERIC_WRITE, share_mode,
+ NULL, OPEN_ALWAYS, FILE_ATTRIBUTE_NORMAL, NULL);
if (INVALID_HANDLE_VALUE == hfile) {
string context = "Failed to create a NewAppendableFile: " + fname;
@@ -316,9 +317,9 @@ Status WindowsFileSystem::NewReadOnlyMemoryRegionFromFile(
file_flags |= FILE_FLAG_OVERLAPPED;
DWORD share_mode = FILE_SHARE_READ | FILE_SHARE_WRITE | FILE_SHARE_DELETE;
- HANDLE hfile = ::CreateFileW(ws_translated_fname.c_str(), GENERIC_READ,
- share_mode, NULL, OPEN_EXISTING, file_flags,
- NULL);
+ HANDLE hfile =
+ ::CreateFileW(ws_translated_fname.c_str(), GENERIC_READ, share_mode, NULL,
+ OPEN_EXISTING, file_flags, NULL);
if (INVALID_HANDLE_VALUE == hfile) {
return IOErrorFromWindowsError(
@@ -345,28 +346,32 @@ Status WindowsFileSystem::NewReadOnlyMemoryRegionFromFile(
NULL); // Mapping name
if (!hmap) {
- string context = "Failed to create file mapping for "
- "NewReadOnlyMemoryRegionFromFile: " + fname;
+ string context =
+ "Failed to create file mapping for "
+ "NewReadOnlyMemoryRegionFromFile: " +
+ fname;
return IOErrorFromWindowsError(context, ::GetLastError());
}
UniqueCloseHandlePtr map_guard(hmap, CloseHandleFunc);
- const void* mapped_region = ::MapViewOfFileEx(
- hmap, FILE_MAP_READ,
- 0, // High DWORD of access start
- 0, // Low DWORD
- file_size,
- NULL); // Let the OS choose the mapping
+ const void* mapped_region =
+ ::MapViewOfFileEx(hmap, FILE_MAP_READ,
+ 0, // High DWORD of access start
+ 0, // Low DWORD
+ file_size,
+ NULL); // Let the OS choose the mapping
if (!mapped_region) {
- string context = "Failed to MapViewOfFile for "
- "NewReadOnlyMemoryRegionFromFile: " + fname;
+ string context =
+ "Failed to MapViewOfFile for "
+ "NewReadOnlyMemoryRegionFromFile: " +
+ fname;
return IOErrorFromWindowsError(context, ::GetLastError());
}
- result->reset(new WinReadOnlyMemoryRegion(fname, hfile, hmap,
- mapped_region, file_size));
+ result->reset(new WinReadOnlyMemoryRegion(fname, hfile, hmap, mapped_region,
+ file_size));
map_guard.release();
file_guard.release();
@@ -404,8 +409,8 @@ Status WindowsFileSystem::GetChildren(const string& dir,
}
do {
- string file_name = WideCharToUtf8(find_data.cFileName);
- const StringPiece basename = file_name;
+ string file_name = WideCharToUtf8(find_data.cFileName);
+ const StringPiece basename = file_name;
if (basename != "." && basename != "..") {
result->push_back(file_name);
}
@@ -457,8 +462,7 @@ Status WindowsFileSystem::GetFileSize(const string& fname, uint64* size) {
file_size.HighPart = attrs.nFileSizeHigh;
file_size.LowPart = attrs.nFileSizeLow;
*size = file_size.QuadPart;
- }
- else {
+ } else {
string context = "Can not get size for: " + fname;
result = IOErrorFromWindowsError(context, ::GetLastError());
}
@@ -472,7 +476,7 @@ Status WindowsFileSystem::RenameFile(const string& src, const string& target) {
std::wstring ws_translated_src = Utf8ToWideChar(TranslateName(src));
std::wstring ws_translated_target = Utf8ToWideChar(TranslateName(target));
if (!::MoveFileExW(ws_translated_src.c_str(), ws_translated_target.c_str(),
- MOVEFILE_REPLACE_EXISTING)) {
+ MOVEFILE_REPLACE_EXISTING)) {
string context(strings::StrCat("Failed to rename: ", src, " to: ", target));
result = IOErrorFromWindowsError(context, ::GetLastError());
}
diff --git a/tensorflow/core/platform/windows/windows_file_system.h b/tensorflow/core/platform/windows/windows_file_system.h
index 8dcc153037..ba0302f0fd 100644
--- a/tensorflow/core/platform/windows/windows_file_system.h
+++ b/tensorflow/core/platform/windows/windows_file_system.h
@@ -63,33 +63,35 @@ class WindowsFileSystem : public FileSystem {
Status RenameFile(const string& src, const string& target) override;
- string TranslateName(const string& name) const override {
- return name;
- }
+ string TranslateName(const string& name) const override { return name; }
static std::wstring Utf8ToWideChar(const string& utf8str) {
- int size_required = MultiByteToWideChar(CP_UTF8, 0, utf8str.c_str(), (int)utf8str.size(), NULL, 0);
- std::wstring ws_translated_str(size_required, 0);
- MultiByteToWideChar(CP_UTF8, 0, utf8str.c_str(), (int)utf8str.size(), &ws_translated_str[0], size_required);
- return ws_translated_str;
+ int size_required = MultiByteToWideChar(CP_UTF8, 0, utf8str.c_str(),
+ (int)utf8str.size(), NULL, 0);
+ std::wstring ws_translated_str(size_required, 0);
+ MultiByteToWideChar(CP_UTF8, 0, utf8str.c_str(), (int)utf8str.size(),
+ &ws_translated_str[0], size_required);
+ return ws_translated_str;
}
- static string WideCharToUtf8(const std::wstring &wstr) {
- if (wstr.empty()) return std::string();
- int size_required = WideCharToMultiByte(CP_UTF8, 0, wstr.c_str(), (int)wstr.size(), NULL, 0, NULL, NULL);
- string utf8_translated_str(size_required, 0);
- WideCharToMultiByte(CP_UTF8, 0, wstr.c_str(), (int)wstr.size(), &utf8_translated_str[0], size_required, NULL, NULL);
- return utf8_translated_str;
+ static string WideCharToUtf8(const std::wstring& wstr) {
+ if (wstr.empty()) return std::string();
+ int size_required = WideCharToMultiByte(
+ CP_UTF8, 0, wstr.c_str(), (int)wstr.size(), NULL, 0, NULL, NULL);
+ string utf8_translated_str(size_required, 0);
+ WideCharToMultiByte(CP_UTF8, 0, wstr.c_str(), (int)wstr.size(),
+ &utf8_translated_str[0], size_required, NULL, NULL);
+ return utf8_translated_str;
}
};
class LocalWinFileSystem : public WindowsFileSystem {
-public:
- string TranslateName(const string& name) const override {
- StringPiece scheme, host, path;
- io::ParseURI(name, &scheme, &host, &path);
- return path.ToString();
- }
+ public:
+ string TranslateName(const string& name) const override {
+ StringPiece scheme, host, path;
+ io::ParseURI(name, &scheme, &host, &path);
+ return path.ToString();
+ }
};
} // namespace tensorflow