Add FileSystemWatcher class to dart:io.

runtime/bin/file_system_watcher_linux.cc

+// Copyright (c) 2013, the Dart project authors.  Please see the AUTHORS file
+// for details. All rights reserved. Use of this source code is governed by a
+// BSD-style license that can be found in the LICENSE file.
+
+#include "platform/globals.h"
+#if defined(TARGET_OS_LINUX)
+
+#include "bin/file_system_watcher.h"
+
+#include <errno.h>  // NOLINT
+#include <sys/inotify.h>  // NOLINT
+
+
+namespace dart {
+namespace bin {
+
+intptr_t FileSystemWatcher::Init() {
+  int fd = TEMP_FAILURE_RETRY(inotify_init1(IN_NONBLOCK | IN_CLOEXEC));
+  if (fd < 0) return -1;
+  return fd;
+}
+
+
+void FileSystemWatcher::Stop(intptr_t id) {
+  // Don't close it manually, the eventhandler will do it for us.
+}
+
+
+intptr_t FileSystemWatcher::GetSocketId(intptr_t id, intptr_t path_id) {
+  if (path_id != -1) return -1;
+  return id;
+}
+
+
+intptr_t FileSystemWatcher::AddPath(intptr_t id,
+                                    const char* path,
+                                    int events,
+                                    bool recursive) {
+  int list_events = 0;
+  if (events & kCreate) list_events |= IN_CREATE;
+  if (events & kModifyContent) list_events |= IN_MODIFY | IN_ATTRIB;
+  if (events & kDelete) list_events |= IN_DELETE;
+  if (events & kMove) list_events |= IN_MOVE;
+  int fd = TEMP_FAILURE_RETRY(inotify_add_watch(id, path, list_events));
+  if (fd < 0) return -1;
+  return fd;
+}
+
+
+bool FileSystemWatcher::RemovePath(intptr_t id, intptr_t path_id) {
+  return TEMP_FAILURE_RETRY(inotify_rm_watch(id, path_id)) == 0;
+}
+
+
+intptr_t FileSystemWatcher::ReadEvents(intptr_t id,
+                                       intptr_t path_id,
+                                       Event** events) {
+  const intptr_t kEventSize = sizeof(struct inotify_event);
+  const intptr_t kBufferSize = kEventSize + NAME_MAX + 1;
+  uint8_t buffer[kBufferSize];
+  intptr_t bytes = TEMP_FAILURE_RETRY(read(id, buffer, kBufferSize));
+  if (bytes < 0) return -1;
+  const intptr_t kMaxCount = kBufferSize / kEventSize + 1;
+  *events = new Event[kMaxCount];
+  intptr_t offset = 0;
+  intptr_t i = 0;
+  while (offset < bytes) {
+    struct inotify_event* e =
+        reinterpret_cast<struct inotify_event*>(buffer + offset);
+    Event* event = *events + i;
+    event->event = 0;
+    event->path_id = e->wd;
+    event->link = e->cookie;
+    if (e->mask & IN_MODIFY) event->event |= kModifyContent;
+    if (e->mask & IN_ATTRIB) event->event |= kModefyAttribute;
+    if (e->mask & IN_CREATE) event->event |= kCreate;
+    if (e->mask & IN_MOVE) event->event |= kMove;
+    if (e->mask & IN_DELETE) event->event |= kDelete;
+    if (e->len > 0) {
+      event->filename = strdup(e->name);
+    } else {
+      event->filename = NULL;
+    }
+    i++;
+    offset += kEventSize + e->len;
+  }
+  return i;
+}
+
+}  // namespace bin
+}  // namespace dart
+
+#endif  // defined(TARGET_OS_LINUX)
+