aboutsummaryrefslogtreecommitdiffstats
path: root/src/InotifySource.cxx
diff options
context:
space:
mode:
Diffstat (limited to 'src/InotifySource.cxx')
-rw-r--r--src/InotifySource.cxx114
1 files changed, 0 insertions, 114 deletions
diff --git a/src/InotifySource.cxx b/src/InotifySource.cxx
deleted file mode 100644
index ccf5d3e14..000000000
--- a/src/InotifySource.cxx
+++ /dev/null
@@ -1,114 +0,0 @@
-/*
- * Copyright (C) 2003-2013 The Music Player Daemon Project
- * http://www.musicpd.org
- *
- * This program is free software; you can redistribute it and/or modify
- * it under the terms of the GNU General Public License as published by
- * the Free Software Foundation; either version 2 of the License, or
- * (at your option) any later version.
- *
- * This program is distributed in the hope that it will be useful,
- * but WITHOUT ANY WARRANTY; without even the implied warranty of
- * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
- * GNU General Public License for more details.
- *
- * You should have received a copy of the GNU General Public License along
- * with this program; if not, write to the Free Software Foundation, Inc.,
- * 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA.
- */
-
-#include "config.h"
-#include "InotifySource.hxx"
-#include "InotifyDomain.hxx"
-#include "util/Error.hxx"
-#include "system/fd_util.h"
-#include "system/FatalError.hxx"
-#include "Log.hxx"
-
-#include <sys/inotify.h>
-#include <unistd.h>
-#include <errno.h>
-
-bool
-InotifySource::OnSocketReady(gcc_unused unsigned flags)
-{
- const auto dest = buffer.Write();
- if (dest.IsEmpty())
- FatalError("buffer full");
-
- ssize_t nbytes = read(Get(), dest.data, dest.size);
- if (nbytes < 0)
- FatalSystemError("Failed to read from inotify");
- if (nbytes == 0)
- FatalError("end of file from inotify");
-
- buffer.Append(nbytes);
-
- while (true) {
- const char *name;
-
- auto range = buffer.Read();
- const struct inotify_event *event =
- (const struct inotify_event *)
- range.data;
- if (range.size < sizeof(*event) ||
- range.size < sizeof(*event) + event->len)
- break;
-
- if (event->len > 0 && event->name[event->len - 1] == 0)
- name = event->name;
- else
- name = nullptr;
-
- callback(event->wd, event->mask, name, callback_ctx);
- buffer.Consume(sizeof(*event) + event->len);
- }
-
- return true;
-}
-
-inline
-InotifySource::InotifySource(EventLoop &_loop,
- mpd_inotify_callback_t _callback, void *_ctx,
- int _fd)
- :SocketMonitor(_fd, _loop),
- callback(_callback), callback_ctx(_ctx)
-{
- ScheduleRead();
-
-}
-
-InotifySource *
-InotifySource::Create(EventLoop &loop,
- mpd_inotify_callback_t callback, void *callback_ctx,
- Error &error)
-{
- int fd = inotify_init_cloexec();
- if (fd < 0) {
- error.SetErrno("inotify_init() has failed");
- return nullptr;
- }
-
- return new InotifySource(loop, callback, callback_ctx, fd);
-}
-
-int
-InotifySource::Add(const char *path_fs, unsigned mask, Error &error)
-{
- int wd = inotify_add_watch(Get(), path_fs, mask);
- if (wd < 0)
- error.SetErrno("inotify_add_watch() has failed");
-
- return wd;
-}
-
-void
-InotifySource::Remove(unsigned wd)
-{
- int ret = inotify_rm_watch(Get(), wd);
- if (ret < 0 && errno != EINVAL)
- LogErrno(inotify_domain, "inotify_rm_watch() has failed");
-
- /* EINVAL may happen here when the file has been deleted; the
- kernel seems to auto-unregister deleted files */
-}