summaryrefslogtreecommitdiffstats
path: root/lldb/examples/interposing/darwin/fd_interposing/FDInterposing.cpp
diff options
context:
space:
mode:
authorKate Stone <katherine.stone@apple.com>2016-09-06 20:57:50 +0000
committerKate Stone <katherine.stone@apple.com>2016-09-06 20:57:50 +0000
commitb9c1b51e45b845debb76d8658edabca70ca56079 (patch)
treedfcb5a13ef2b014202340f47036da383eaee74aa /lldb/examples/interposing/darwin/fd_interposing/FDInterposing.cpp
parentd5aa73376966339caad04013510626ec2e42c760 (diff)
downloadbcm5719-llvm-b9c1b51e45b845debb76d8658edabca70ca56079.tar.gz
bcm5719-llvm-b9c1b51e45b845debb76d8658edabca70ca56079.zip
*** This commit represents a complete reformatting of the LLDB source code
*** to conform to clang-format’s LLVM style. This kind of mass change has *** two obvious implications: Firstly, merging this particular commit into a downstream fork may be a huge effort. Alternatively, it may be worth merging all changes up to this commit, performing the same reformatting operation locally, and then discarding the merge for this particular commit. The commands used to accomplish this reformatting were as follows (with current working directory as the root of the repository): find . \( -iname "*.c" -or -iname "*.cpp" -or -iname "*.h" -or -iname "*.mm" \) -exec clang-format -i {} + find . -iname "*.py" -exec autopep8 --in-place --aggressive --aggressive {} + ; The version of clang-format used was 3.9.0, and autopep8 was 1.2.4. Secondly, “blame” style tools will generally point to this commit instead of a meaningful prior commit. There are alternatives available that will attempt to look through this change and find the appropriate prior commit. YMMV. llvm-svn: 280751
Diffstat (limited to 'lldb/examples/interposing/darwin/fd_interposing/FDInterposing.cpp')
-rw-r--r--lldb/examples/interposing/darwin/fd_interposing/FDInterposing.cpp1533
1 files changed, 683 insertions, 850 deletions
diff --git a/lldb/examples/interposing/darwin/fd_interposing/FDInterposing.cpp b/lldb/examples/interposing/darwin/fd_interposing/FDInterposing.cpp
index e41dc34038b..105251c9574 100644
--- a/lldb/examples/interposing/darwin/fd_interposing/FDInterposing.cpp
+++ b/lldb/examples/interposing/darwin/fd_interposing/FDInterposing.cpp
@@ -7,8 +7,8 @@
//
//===----------------------------------------------------------------------===//
//
-// This file helps with catching double close calls on unix integer file
-// descriptors by interposing functions for all file descriptor create and
+// This file helps with catching double close calls on unix integer file
+// descriptors by interposing functions for all file descriptor create and
// close operations. A stack backtrace for every create and close function is
// maintained, and every create and close operation is logged. When a double
// file descriptor close is encountered, it will be logged.
@@ -18,20 +18,21 @@
// For sh:
// DYLD_INSERT_LIBRARIES=/path/to/FDInterposing.dylib /path/to/executable
// For tcsh:
-// (setenv DYLD_INSERT_LIBRARIES=/path/to/FDInterposing.dylib ; /path/to/executable)
+// (setenv DYLD_INSERT_LIBRARIES=/path/to/FDInterposing.dylib ;
+// /path/to/executable)
//
// Other environment variables that can alter the default actions of this
// interposing shared library include:
//
// "FileDescriptorStackLoggingNoCompact"
//
-// With this environment variable set, all file descriptor create and
-// delete operations will be permanantly maintained in the event map.
+// With this environment variable set, all file descriptor create and
+// delete operations will be permanantly maintained in the event map.
// The default action is to compact the create/delete events by removing
-// any previous file descriptor create events that are matched with a
+// any previous file descriptor create events that are matched with a
// corresponding file descriptor delete event when the next valid file
// descriptor create event is detected.
-//
+//
// "FileDescriptorMinimalLogging"
//
// By default every file descriptor create and delete operation is logged
@@ -49,39 +50,40 @@
#include <assert.h>
#include <dirent.h>
#include <errno.h>
-#include <fcntl.h>
#include <execinfo.h>
+#include <fcntl.h>
#include <libgen.h>
-#include <mach-o/dyld.h>
#include <mach-o/dyld-interposing.h>
-#include <stdlib.h>
+#include <mach-o/dyld.h>
+#include <map>
#include <stdio.h>
+#include <stdlib.h>
#include <string.h>
+#include <string>
#include <sys/event.h>
#include <sys/mman.h>
#include <sys/socket.h>
-#include <sys/types.h>
#include <sys/time.h>
+#include <sys/types.h>
#include <tr1/memory> // for std::tr1::shared_ptr
#include <unistd.h>
-#include <string>
#include <vector>
-#include <map>
//----------------------------------------------------------------------
/// @def DISALLOW_COPY_AND_ASSIGN(TypeName)
/// Macro definition for easily disallowing copy constructor and
/// assignment operators in C++ classes.
//----------------------------------------------------------------------
-#define DISALLOW_COPY_AND_ASSIGN(TypeName) \
-TypeName(const TypeName&); \
-const TypeName& operator=(const TypeName&)
+#define DISALLOW_COPY_AND_ASSIGN(TypeName) \
+ TypeName(const TypeName &); \
+ const TypeName &operator=(const TypeName &)
extern "C" {
- int accept$NOCANCEL (int, struct sockaddr * __restrict, socklen_t * __restrict);
- int close$NOCANCEL(int);
- int open$NOCANCEL(const char *, int, ...);
- int __open_extended(const char *, int, uid_t, gid_t, int, struct kauth_filesec *);
+int accept$NOCANCEL(int, struct sockaddr *__restrict, socklen_t *__restrict);
+int close$NOCANCEL(int);
+int open$NOCANCEL(const char *, int, ...);
+int __open_extended(const char *, int, uid_t, gid_t, int,
+ struct kauth_filesec *);
}
namespace fd_interposing {
@@ -90,76 +92,55 @@ namespace fd_interposing {
// String class so we can get formatted strings without having to worry
// about the memory storage since it will allocate the memory it needs.
//----------------------------------------------------------------------
-class String
-{
+class String {
public:
- String () :
- m_str (NULL)
- {}
-
- String (const char *format, ...) :
- m_str (NULL)
- {
- va_list args;
- va_start (args, format);
- vprintf (format, args);
- va_end (args);
- }
-
- ~String()
- {
- reset();
- }
-
- void
- reset (char *s = NULL)
- {
- if (m_str)
- ::free (m_str);
- m_str = s;
- }
-
- const char *
- c_str () const
- {
- return m_str;
- }
+ String() : m_str(NULL) {}
+
+ String(const char *format, ...) : m_str(NULL) {
+ va_list args;
+ va_start(args, format);
+ vprintf(format, args);
+ va_end(args);
+ }
+
+ ~String() { reset(); }
+
+ void reset(char *s = NULL) {
+ if (m_str)
+ ::free(m_str);
+ m_str = s;
+ }
+
+ const char *c_str() const { return m_str; }
+
+ void printf(const char *format, ...) {
+ va_list args;
+ va_start(args, format);
+ vprintf(format, args);
+ va_end(args);
+ }
+ void vprintf(const char *format, va_list args) {
+ reset();
+ ::vasprintf(&m_str, format, args);
+ }
+
+ void log(int log_fd) {
+ if (m_str && log_fd >= 0) {
+ const int len = strlen(m_str);
+ if (len > 0) {
+ write(log_fd, m_str, len);
+ const char last_char = m_str[len - 1];
+ if (!(last_char == '\n' || last_char == '\r'))
+ write(log_fd, "\n", 1);
+ }
+ }
+ }
- void
- printf (const char *format, ...)
- {
- va_list args;
- va_start (args, format);
- vprintf (format, args);
- va_end (args);
- }
- void
- vprintf (const char *format, va_list args)
- {
- reset();
- ::vasprintf (&m_str, format, args);
- }
-
- void
- log (int log_fd)
- {
- if (m_str && log_fd >= 0)
- {
- const int len = strlen(m_str);
- if (len > 0)
- {
- write (log_fd, m_str, len);
- const char last_char = m_str[len-1];
- if (!(last_char == '\n' || last_char == '\r'))
- write (log_fd, "\n", 1);
- }
- }
- }
protected:
- char *m_str;
-
+ char *m_str;
+
private:
- DISALLOW_COPY_AND_ASSIGN (String);
+ DISALLOW_COPY_AND_ASSIGN(String);
};
//----------------------------------------------------------------------
@@ -171,7 +152,6 @@ typedef std::vector<void *> Frames;
typedef std::tr1::shared_ptr<FDEvent> FDEventSP;
typedef std::tr1::shared_ptr<String> StringSP;
-
//----------------------------------------------------------------------
// FDEvent
//
@@ -180,115 +160,75 @@ typedef std::tr1::shared_ptr<String> StringSP;
// File descriptor events fall into one of two categories: create events
// and delete events.
//----------------------------------------------------------------------
-class FDEvent
-{
+class FDEvent {
public:
- FDEvent (int fd, int err, const StringSP &string_sp, bool is_create, const Frames& frames) :
- m_string_sp (string_sp),
- m_frames (frames.begin(), frames.end()),
- m_fd (fd),
- m_err (err),
- m_is_create (is_create)
- {}
-
- ~FDEvent () {}
-
- bool
- IsCreateEvent() const
- {
- return m_is_create;
- }
+ FDEvent(int fd, int err, const StringSP &string_sp, bool is_create,
+ const Frames &frames)
+ : m_string_sp(string_sp), m_frames(frames.begin(), frames.end()),
+ m_fd(fd), m_err(err), m_is_create(is_create) {}
- bool
- IsDeleteEvent() const
- {
- return !m_is_create;
- }
+ ~FDEvent() {}
- Frames &
- GetFrames ()
- {
- return m_frames;
- }
+ bool IsCreateEvent() const { return m_is_create; }
- const Frames &
- GetFrames () const
- {
- return m_frames;
- }
-
- int
- GetFD () const
- {
- return m_fd;
- }
+ bool IsDeleteEvent() const { return !m_is_create; }
- int
- GetError () const
- {
- return m_err;
- }
-
- void
- Dump (int log_fd) const;
-
- void
- SetCreateEvent (FDEventSP &create_event_sp)
- {
- m_create_event_sp = create_event_sp;
- }
+ Frames &GetFrames() { return m_frames; }
+
+ const Frames &GetFrames() const { return m_frames; }
+
+ int GetFD() const { return m_fd; }
+
+ int GetError() const { return m_err; }
+
+ void Dump(int log_fd) const;
+
+ void SetCreateEvent(FDEventSP &create_event_sp) {
+ m_create_event_sp = create_event_sp;
+ }
private:
- // A shared pointer to a String that describes this event in
- // detail (all args and return and error values)
- StringSP m_string_sp;
- // The frames for the stack backtrace for this event
- Frames m_frames;
- // If this is a file descriptor delete event, this might contain
- // the correspoding file descriptor create event
- FDEventSP m_create_event_sp;
- // The file descriptor for this event
- int m_fd;
- // The error code (if any) for this event
- int m_err;
- // True if this event is a file descriptor create event, false
- // if it is a file descriptor delete event
- bool m_is_create;
+ // A shared pointer to a String that describes this event in
+ // detail (all args and return and error values)
+ StringSP m_string_sp;
+ // The frames for the stack backtrace for this event
+ Frames m_frames;
+ // If this is a file descriptor delete event, this might contain
+ // the correspoding file descriptor create event
+ FDEventSP m_create_event_sp;
+ // The file descriptor for this event
+ int m_fd;
+ // The error code (if any) for this event
+ int m_err;
+ // True if this event is a file descriptor create event, false
+ // if it is a file descriptor delete event
+ bool m_is_create;
};
//----------------------------------------------------------------------
-// Templatized class that will save errno only if the "value" it is
-// constructed with is equal to INVALID. When the class goes out of
+// Templatized class that will save errno only if the "value" it is
+// constructed with is equal to INVALID. When the class goes out of
// scope, it will restore errno if it was saved.
//----------------------------------------------------------------------
-template <int INVALID>
-class Errno
-{
+template <int INVALID> class Errno {
public:
- // Save errno only if we are supposed to
- Errno (int value) :
- m_saved_errno ((value == INVALID) ? errno : 0),
- m_restore (value == INVALID)
- {
- }
-
- // Restore errno only if we are supposed to
- ~Errno()
- {
- if (m_restore)
- errno = m_saved_errno;
- }
+ // Save errno only if we are supposed to
+ Errno(int value)
+ : m_saved_errno((value == INVALID) ? errno : 0),
+ m_restore(value == INVALID) {}
- // Accessor for the saved value of errno
- int
- get_errno() const
- {
- return m_saved_errno;
- }
+ // Restore errno only if we are supposed to
+ ~Errno() {
+ if (m_restore)
+ errno = m_saved_errno;
+ }
+
+ // Accessor for the saved value of errno
+ int get_errno() const { return m_saved_errno; }
protected:
- const int m_saved_errno;
- const bool m_restore;
+ const int m_saved_errno;
+ const bool m_restore;
};
typedef Errno<-1> InvalidFDErrno;
@@ -303,12 +243,13 @@ typedef std::map<int, FDEventArray> FDEventMap;
// descriptor create and close events come in, they will get filled
// into this map (protected by g_mutex). When a file descriptor close
// event is detected, the open event will be removed and placed into
-// the close event so if something tries to double close a file
-// descriptor we can show the previous close event and the file
+// the close event so if something tries to double close a file
+// descriptor we can show the previous close event and the file
// desctiptor event that created it. When a new file descriptor create
-// event comes in, we will remove the previous one for that file
-// desctiptor unless the environment variable "FileDescriptorStackLoggingNoCompact"
-// is set. The file desctiptor history can be accessed using the
+// event comes in, we will remove the previous one for that file
+// desctiptor unless the environment variable
+// "FileDescriptorStackLoggingNoCompact"
+// is set. The file desctiptor history can be accessed using the
// get_fd_history() function.
static FDEventMap g_fd_event_map;
// A mutex to protect access to our data structures in g_fd_event_map
@@ -328,760 +269,662 @@ static bool g_enabled = true;
// Mutex class that will lock a mutex when it is constructed, and unlock
// it when is goes out of scope
//----------------------------------------------------------------------
-class Locker
-{
+class Locker {
public:
- Locker (pthread_mutex_t *mutex_ptr) :
- m_mutex_ptr(mutex_ptr)
- {
- ::pthread_mutex_lock (m_mutex_ptr);
- }
-
- // This allows clients to test try and acquire the mutex...
- Locker (pthread_mutex_t *mutex_ptr, bool &lock_acquired) :
- m_mutex_ptr(NULL)
- {
- lock_acquired = ::pthread_mutex_trylock(mutex_ptr) == 0;
- if (lock_acquired)
- m_mutex_ptr = mutex_ptr;
- }
+ Locker(pthread_mutex_t *mutex_ptr) : m_mutex_ptr(mutex_ptr) {
+ ::pthread_mutex_lock(m_mutex_ptr);
+ }
+
+ // This allows clients to test try and acquire the mutex...
+ Locker(pthread_mutex_t *mutex_ptr, bool &lock_acquired) : m_mutex_ptr(NULL) {
+ lock_acquired = ::pthread_mutex_trylock(mutex_ptr) == 0;
+ if (lock_acquired)
+ m_mutex_ptr = mutex_ptr;
+ }
+
+ ~Locker() {
+ if (m_mutex_ptr)
+ ::pthread_mutex_unlock(m_mutex_ptr);
+ }
- ~Locker ()
- {
- if (m_mutex_ptr)
- ::pthread_mutex_unlock (m_mutex_ptr);
- }
protected:
- pthread_mutex_t *m_mutex_ptr;
+ pthread_mutex_t *m_mutex_ptr;
};
-static void
-log (const char *format, ...) __attribute__ ((format (printf, 1, 2)));
+static void log(const char *format, ...) __attribute__((format(printf, 1, 2)));
-static void
-log (int log_fd, const FDEvent *event, const char *format, ...) __attribute__ ((format (printf, 3, 4)));
+static void log(int log_fd, const FDEvent *event, const char *format, ...)
+ __attribute__((format(printf, 3, 4)));
-static void
-backtrace_log (const char *format, ...) __attribute__ ((format (printf, 1, 2)));
+static void backtrace_log(const char *format, ...)
+ __attribute__((format(printf, 1, 2)));
-static void
-backtrace_error (const char *format, ...) __attribute__ ((format (printf, 1, 2)));
+static void backtrace_error(const char *format, ...)
+ __attribute__((format(printf, 1, 2)));
-static void
-log_to_fd (int log_fd, const char *format, ...) __attribute__ ((format (printf, 2, 3)));
+static void log_to_fd(int log_fd, const char *format, ...)
+ __attribute__((format(printf, 2, 3)));
-static inline size_t
-get_backtrace (Frames &frame_buffer, size_t frames_to_remove)
-{
- void *frames[2048];
- int count = ::backtrace (&frames[0], sizeof(frames)/sizeof(void*));
- if (count > frames_to_remove)
- frame_buffer.assign (&frames[frames_to_remove], &frames[count]);
- else
- frame_buffer.assign (&frames[0], &frames[count]);
- while (frame_buffer.back() < (void *)1024)
- frame_buffer.pop_back();
- return frame_buffer.size();
+static inline size_t get_backtrace(Frames &frame_buffer,
+ size_t frames_to_remove) {
+ void *frames[2048];
+ int count = ::backtrace(&frames[0], sizeof(frames) / sizeof(void *));
+ if (count > frames_to_remove)
+ frame_buffer.assign(&frames[frames_to_remove], &frames[count]);
+ else
+ frame_buffer.assign(&frames[0], &frames[count]);
+ while (frame_buffer.back() < (void *)1024)
+ frame_buffer.pop_back();
+ return frame_buffer.size();
}
static int g_log_fd = STDOUT_FILENO;
static int g_initialized = 0;
-const char *
-get_process_fullpath (bool force = false)
-{
- static char g_process_fullpath[PATH_MAX] = {0};
- if (force || g_process_fullpath[0] == '\0')
- {
- // If DST is NULL, then return the number of bytes needed.
- uint32_t len = sizeof(g_process_fullpath);
- if (_NSGetExecutablePath (g_process_fullpath, &len) != 0)
- strncpy (g_process_fullpath, "<error>", sizeof(g_process_fullpath));
- }
- return g_process_fullpath;
+const char *get_process_fullpath(bool force = false) {
+ static char g_process_fullpath[PATH_MAX] = {0};
+ if (force || g_process_fullpath[0] == '\0') {
+ // If DST is NULL, then return the number of bytes needed.
+ uint32_t len = sizeof(g_process_fullpath);
+ if (_NSGetExecutablePath(g_process_fullpath, &len) != 0)
+ strncpy(g_process_fullpath, "<error>", sizeof(g_process_fullpath));
+ }
+ return g_process_fullpath;
}
// Returns the current process ID, or -1 if inserposing not enabled for
// this process
-static int
-get_interposed_pid()
-{
- if (!g_enabled)
- return -1;
-
- const pid_t pid = getpid();
- if (g_pid != pid)
- {
- if (g_pid == -1)
- {
- g_pid = pid;
- log ("Interposing file descriptor create and delete functions for %s (pid=%i)\n", get_process_fullpath (true), pid);
- }
- else
- {
- log ("pid=%i: disabling interposing file descriptor create and delete functions for child process %s (pid=%i)\n", g_pid, get_process_fullpath (true), pid);
- g_enabled = false;
- return -1;
- }
- // Log when our process changes
- }
- return g_pid;
+static int get_interposed_pid() {
+ if (!g_enabled)
+ return -1;
+
+ const pid_t pid = getpid();
+ if (g_pid != pid) {
+ if (g_pid == -1) {
+ g_pid = pid;
+ log("Interposing file descriptor create and delete functions for %s "
+ "(pid=%i)\n",
+ get_process_fullpath(true), pid);
+ } else {
+ log("pid=%i: disabling interposing file descriptor create and delete "
+ "functions for child process %s (pid=%i)\n",
+ g_pid, get_process_fullpath(true), pid);
+ g_enabled = false;
+ return -1;
+ }
+ // Log when our process changes
+ }
+ return g_pid;
}
-static int
-get_logging_fd ()
-{
- if (!g_enabled)
- return -1;
-
- if (!g_initialized)
- {
- g_initialized = 1;
-
- const pid_t pid = get_interposed_pid();
-
- if (g_enabled)
- {
- // Keep all stack info around for all fd create and delete calls.
- // Otherwise we will remove the fd create call when a corresponding
- // fd delete call is received
- if (getenv("FileDescriptorStackLoggingNoCompact"))
- g_compact = 0;
-
- if (getenv("FileDescriptorMinimalLogging"))
- g_log_all_calls = 0;
-
- const char *log_path = getenv ("FileDescriptorLogFile");
- if (log_path)
- g_log_fd = ::creat (log_path, 0660);
- else
- g_log_fd = STDOUT_FILENO;
-
- // Only let this interposing happen on the first time this matches
- // and stop this from happening so any child processes don't also
- // log their file descriptors
- ::unsetenv ("DYLD_INSERT_LIBRARIES");
- }
- else
- {
- log ("pid=%i: logging disabled\n", getpid());
- }
- }
- return g_log_fd;
-}
+static int get_logging_fd() {
+ if (!g_enabled)
+ return -1;
+
+ if (!g_initialized) {
+ g_initialized = 1;
+
+ const pid_t pid = get_interposed_pid();
+
+ if (g_enabled) {
+ // Keep all stack info around for all fd create and delete calls.
+ // Otherwise we will remove the fd create call when a corresponding
+ // fd delete call is received
+ if (getenv("FileDescriptorStackLoggingNoCompact"))
+ g_compact = 0;
-void
-log_to_fd (int log_fd, const char *format, va_list args)
-{
- if (format && format[0] && log_fd >= 0)
- {
- char buffer[PATH_MAX];
- const int count = ::vsnprintf (buffer, sizeof(buffer), format, args);
- if (count > 0)
- write (log_fd, buffer, count);
+ if (getenv("FileDescriptorMinimalLogging"))
+ g_log_all_calls = 0;
+
+ const char *log_path = getenv("FileDescriptorLogFile");
+ if (log_path)
+ g_log_fd = ::creat(log_path, 0660);
+ else
+ g_log_fd = STDOUT_FILENO;
+
+ // Only let this interposing happen on the first time this matches
+ // and stop this from happening so any child processes don't also
+ // log their file descriptors
+ ::unsetenv("DYLD_INSERT_LIBRARIES");
+ } else {
+ log("pid=%i: logging disabled\n", getpid());
}
+ }
+ return g_log_fd;
}
-void
-log_to_fd (int log_fd, const char *format, ...)
-{
- if (format && format[0])
- {
- va_list args;
- va_start (args, format);
- log_to_fd (log_fd, format, args);
- va_end (args);
- }
+void log_to_fd(int log_fd, const char *format, va_list args) {
+ if (format && format[0] && log_fd >= 0) {
+ char buffer[PATH_MAX];
+ const int count = ::vsnprintf(buffer, sizeof(buffer), format, args);
+ if (count > 0)
+ write(log_fd, buffer, count);
+ }
}
-void
-log (const char *format, va_list args)
-{
- log_to_fd (get_logging_fd (), format, args);
+void log_to_fd(int log_fd, const char *format, ...) {
+ if (format && format[0]) {
+ va_list args;
+ va_start(args, format);
+ log_to_fd(log_fd, format, args);
+ va_end(args);
+ }
}
-void
-log (const char *format, ...)
-{
- if (format && format[0])
- {
- va_list args;
- va_start (args, format);
- log (format, args);
- va_end (args);
- }
+void log(const char *format, va_list args) {
+ log_to_fd(get_logging_fd(), format, args);
}
-void
-log (int log_fd, const FDEvent *event, const char *format, ...)
-{
- if (format && format[0])
- {
- va_list args;
- va_start (args, format);
- log_to_fd (log_fd, format, args);
- va_end (args);
- }
- if (event)
- event->Dump(log_fd);
+void log(const char *format, ...) {
+ if (format && format[0]) {
+ va_list args;
+ va_start(args, format);
+ log(format, args);
+ va_end(args);
+ }
}
-void
-FDEvent::Dump (int log_fd) const
-{
- if (log_fd >= 0)
- {
- log_to_fd (log_fd, "%s\n", m_string_sp->c_str());
- if (!m_frames.empty())
- ::backtrace_symbols_fd (m_frames.data(), m_frames.size(), log_fd);
-
- if (m_create_event_sp)
- {
- log_to_fd (log_fd, "\nfd=%i was created with this event:\n", m_fd);
- m_create_event_sp->Dump (log_fd);
- log_to_fd (log_fd, "\n");
- }
- }
+void log(int log_fd, const FDEvent *event, const char *format, ...) {
+ if (format && format[0]) {
+ va_list args;
+ va_start(args, format);
+ log_to_fd(log_fd, format, args);
+ va_end(args);
+ }
+ if (event)
+ event->Dump(log_fd);
}
+void FDEvent::Dump(int log_fd) const {
+ if (log_fd >= 0) {
+ log_to_fd(log_fd, "%s\n", m_string_sp->c_str());
+ if (!m_frames.empty())
+ ::backtrace_symbols_fd(m_frames.data(), m_frames.size(), log_fd);
-void
-backtrace_log (const char *format, ...)
-{
- const int log_fd = get_logging_fd ();
- if (log_fd >= 0)
- {
- if (format && format[0])
- {
- va_list args;
- va_start (args, format);
- log (format, args);
- va_end (args);
- }
-
- Frames frames;
- if (get_backtrace(frames, 2))
- ::backtrace_symbols_fd (frames.data(), frames.size(), log_fd);
+ if (m_create_event_sp) {
+ log_to_fd(log_fd, "\nfd=%i was created with this event:\n", m_fd);
+ m_create_event_sp->Dump(log_fd);
+ log_to_fd(log_fd, "\n");
}
-
+ }
}
-void
-backtrace_error (const char *format, ...)
-{
- const int pid = get_interposed_pid();
- if (pid >= 0)
- {
- const int log_fd = get_logging_fd ();
- if (log_fd >= 0)
- {
- log ("\nerror: %s (pid=%i): ", get_process_fullpath (), pid);
-
- if (format && format[0])
- {
- va_list args;
- va_start (args, format);
- log (format, args);
- va_end (args);
- }
-
- Frames frames;
- if (get_backtrace(frames, 2))
- ::backtrace_symbols_fd (frames.data(), frames.size(), log_fd);
- }
+void backtrace_log(const char *format, ...) {
+ const int log_fd = get_logging_fd();
+ if (log_fd >= 0) {
+ if (format && format[0]) {
+ va_list args;
+ va_start(args, format);
+ log(format, args);
+ va_end(args);
}
-}
-void
-save_backtrace (int fd, int err, const StringSP &string_sp, bool is_create)
-{
Frames frames;
- get_backtrace(frames, 2);
+ if (get_backtrace(frames, 2))
+ ::backtrace_symbols_fd(frames.data(), frames.size(), log_fd);
+ }
+}
- FDEventSP fd_event_sp (new FDEvent (fd, err, string_sp, is_create, frames));
+void backtrace_error(const char *format, ...) {
+ const int pid = get_interposed_pid();
+ if (pid >= 0) {
+ const int log_fd = get_logging_fd();
+ if (log_fd >= 0) {
+ log("\nerror: %s (pid=%i): ", get_process_fullpath(), pid);
- FDEventMap::iterator pos = g_fd_event_map.find (fd);
-
- if (pos != g_fd_event_map.end())
- {
- // We have history for this fd...
-
- FDEventArray &event_array = g_fd_event_map[fd];
- if (fd_event_sp->IsCreateEvent())
- {
- // The current fd event is a function that creates
- // a descriptor, check in case last event was
- // a create event.
- if (event_array.back()->IsCreateEvent())
- {
- const int log_fd = get_logging_fd();
- // Two fd create functions in a row, we missed
- // a function that closes a fd...
- log (log_fd, fd_event_sp.get(), "\nwarning: unmatched file descriptor create event fd=%i (we missed a file descriptor close event):\n", fd);
- }
- else if (g_compact)
- {
- // We are compacting so we remove previous create event
- // when we get the correspinding delete event
- event_array.pop_back();
- }
- }
- else
- {
- // The current fd event is a function that deletes
- // a descriptor, check in case last event for this
- // fd was a delete event (double close!)
- if (event_array.back()->IsDeleteEvent())
- {
- const int log_fd = get_logging_fd();
- // Two fd delete functions in a row, we must
- // have missed some function that opened a descriptor
- log (log_fd, fd_event_sp.get(), "\nwarning: unmatched file descriptor close event for fd=%d (we missed the file descriptor create event):\n", fd);
- }
- else if (g_compact)
- {
- // Since this is a close event, we want to remember the open event
- // that this close if for...
- fd_event_sp->SetCreateEvent(event_array.back());
- // We are compacting so we remove previous create event
- // when we get the correspinding delete event
- event_array.pop_back();
- }
- }
-
- event_array.push_back(fd_event_sp);
- }
- else
- {
- g_fd_event_map[fd].push_back(fd_event_sp);
+ if (format && format[0]) {
+ va_list args;
+ va_start(args, format);
+ log(format, args);
+ va_end(args);
+ }
+
+ Frames frames;
+ if (get_backtrace(frames, 2))
+ ::backtrace_symbols_fd(frames.data(), frames.size(), log_fd);
}
+ }
+}
+
+void save_backtrace(int fd, int err, const StringSP &string_sp,
+ bool is_create) {
+ Frames frames;
+ get_backtrace(frames, 2);
+
+ FDEventSP fd_event_sp(new FDEvent(fd, err, string_sp, is_create, frames));
+
+ FDEventMap::iterator pos = g_fd_event_map.find(fd);
+
+ if (pos != g_fd_event_map.end()) {
+ // We have history for this fd...
+
+ FDEventArray &event_array = g_fd_event_map[fd];
+ if (fd_event_sp->IsCreateEvent()) {
+ // The current fd event is a function that creates
+ // a descriptor, check in case last event was
+ // a create event.
+ if (event_array.back()->IsCreateEvent()) {
+ const int log_fd = get_logging_fd();
+ // Two fd create functions in a row, we missed
+ // a function that closes a fd...
+ log(log_fd, fd_event_sp.get(), "\nwarning: unmatched file descriptor "
+ "create event fd=%i (we missed a file "
+ "descriptor close event):\n",
+ fd);
+ } else if (g_compact) {
+ // We are compacting so we remove previous create event
+ // when we get the correspinding delete event
+ event_array.pop_back();
+ }
+ } else {
+ // The current fd event is a function that deletes
+ // a descriptor, check in case last event for this
+ // fd was a delete event (double close!)
+ if (event_array.back()->IsDeleteEvent()) {
+ const int log_fd = get_logging_fd();
+ // Two fd delete functions in a row, we must
+ // have missed some function that opened a descriptor
+ log(log_fd, fd_event_sp.get(), "\nwarning: unmatched file descriptor "
+ "close event for fd=%d (we missed the "
+ "file descriptor create event):\n",
+ fd);
+ } else if (g_compact) {
+ // Since this is a close event, we want to remember the open event
+ // that this close if for...
+ fd_event_sp->SetCreateEvent(event_array.back());
+ // We are compacting so we remove previous create event
+ // when we get the correspinding delete event
+ event_array.pop_back();
+ }
+ }
+
+ event_array.push_back(fd_event_sp);
+ } else {
+ g_fd_event_map[fd].push_back(fd_event_sp);
+ }
}
//----------------------------------------------------------------------
// socket() interpose function
//----------------------------------------------------------------------
-extern "C" int
-socket$__interposed__ (int domain, int type, int protocol)
-{
- const int pid = get_interposed_pid();
- if (pid >= 0)
- {
- Locker locker (&g_mutex);
- const int fd = ::socket (domain, type, protocol);
- InvalidFDErrno fd_errno(fd);
- StringSP description_sp(new String);
- if (fd == -1)
- description_sp->printf("pid=%i: socket (domain = %i, type = %i, protocol = %i) => fd=%i errno = %i", pid, domain, type, protocol, fd, fd_errno.get_errno());
- else
- description_sp->printf("pid=%i: socket (domain = %i, type = %i, protocol = %i) => fd=%i", pid, domain, type, protocol, fd);
- if (g_log_all_calls)
- description_sp->log (get_logging_fd());
- if (fd >= 0)
- save_backtrace (fd, fd_errno.get_errno(), description_sp, true);
- return fd;
- }
+extern "C" int socket$__interposed__(int domain, int type, int protocol) {
+ const int pid = get_interposed_pid();
+ if (pid >= 0) {
+ Locker locker(&g_mutex);
+ const int fd = ::socket(domain, type, protocol);
+ InvalidFDErrno fd_errno(fd);
+ StringSP description_sp(new String);
+ if (fd == -1)
+ description_sp->printf("pid=%i: socket (domain = %i, type = %i, protocol "
+ "= %i) => fd=%i errno = %i",
+ pid, domain, type, protocol, fd,
+ fd_errno.get_errno());
else
- {
- return ::socket (domain, type, protocol);
- }
+ description_sp->printf(
+ "pid=%i: socket (domain = %i, type = %i, protocol = %i) => fd=%i",
+ pid, domain, type, protocol, fd);
+ if (g_log_all_calls)
+ description_sp->log(get_logging_fd());
+ if (fd >= 0)
+ save_backtrace(fd, fd_errno.get_errno(), description_sp, true);
+ return fd;
+ } else {
+ return ::socket(domain, type, protocol);
+ }
}
//----------------------------------------------------------------------
// socketpair() interpose function
//----------------------------------------------------------------------
-extern "C" int
-socketpair$__interposed__ (int domain, int type, int protocol, int fds[2])
-{
- const int pid = get_interposed_pid();
- if (pid >= 0)
- {
- Locker locker (&g_mutex);
- fds[0] = -1;
- fds[1] = -1;
- const int err = socketpair (domain, type, protocol, fds);
- NegativeErrorErrno err_errno(err);
- StringSP description_sp(new String ("pid=%i: socketpair (domain=%i, type=%i, protocol=%i, {fd=%i, fd=%i}) -> err=%i", pid, domain, type, protocol, fds[0], fds[1], err));
- if (g_log_all_calls)
- description_sp->log (get_logging_fd());
- if (fds[0] >= 0)
- save_backtrace (fds[0], err_errno.get_errno(), description_sp, true);
- if (fds[1] >= 0)
- save_backtrace (fds[1], err_errno.get_errno(), description_sp, true);
- return err;
- }
- else
- {
- return socketpair (domain, type, protocol, fds);
- }
+extern "C" int socketpair$__interposed__(int domain, int type, int protocol,
+ int fds[2]) {
+ const int pid = get_interposed_pid();
+ if (pid >= 0) {
+ Locker locker(&g_mutex);
+ fds[0] = -1;
+ fds[1] = -1;
+ const int err = socketpair(domain, type, protocol, fds);
+ NegativeErrorErrno err_errno(err);
+ StringSP description_sp(
+ new String("pid=%i: socketpair (domain=%i, type=%i, protocol=%i, "
+ "{fd=%i, fd=%i}) -> err=%i",
+ pid, domain, type, protocol, fds[0], fds[1], err));
+ if (g_log_all_calls)
+ description_sp->log(get_logging_fd());
+ if (fds[0] >= 0)
+ save_backtrace(fds[0], err_errno.get_errno(), description_sp, true);
+ if (fds[1] >= 0)
+ save_backtrace(fds[1], err_errno.get_errno(), description_sp, true);
+ return err;
+ } else {
+ return socketpair(domain, type, protocol, fds);
+ }
}
//----------------------------------------------------------------------
// open() interpose function
//----------------------------------------------------------------------
-extern "C" int
-open$__interposed__ (const char *path, int oflag, int mode)
-{
- const int pid = get_interposed_pid();
- if (pid >= 0)
- {
- Locker locker (&g_mutex);
- int fd = -2;
- StringSP description_sp(new String);
- if (oflag & O_CREAT)
- {
- fd = ::open (path, oflag, mode);
- description_sp->printf("pid=%i: open (path = '%s', oflag = %i, mode = %i) -> fd=%i", pid, path, oflag, mode, fd);
- }
- else
- {
- fd = ::open (path, oflag);
- description_sp->printf("pid=%i: open (path = '%s', oflag = %i) -> fd=%i", pid, path, oflag, fd);
- }
-
- InvalidFDErrno fd_errno(fd);
- if (g_log_all_calls)
- description_sp->log (get_logging_fd());
- if (fd >= 0)
- save_backtrace (fd, fd_errno.get_errno(), description_sp, true);
- return fd;
- }
- else
- {
- return ::open (path, oflag, mode);
- }
+extern "C" int open$__interposed__(const char *path, int oflag, int mode) {
+ const int pid = get_interposed_pid();
+ if (pid >= 0) {
+ Locker locker(&g_mutex);
+ int fd = -2;
+ StringSP description_sp(new String);
+ if (oflag & O_CREAT) {
+ fd = ::open(path, oflag, mode);
+ description_sp->printf(
+ "pid=%i: open (path = '%s', oflag = %i, mode = %i) -> fd=%i", pid,
+ path, oflag, mode, fd);
+ } else {
+ fd = ::open(path, oflag);
+ description_sp->printf("pid=%i: open (path = '%s', oflag = %i) -> fd=%i",
+ pid, path, oflag, fd);
+ }
+
+ InvalidFDErrno fd_errno(fd);
+ if (g_log_all_calls)
+ description_sp->log(get_logging_fd());
+ if (fd >= 0)
+ save_backtrace(fd, fd_errno.get_errno(), description_sp, true);
+ return fd;
+ } else {
+ return ::open(path, oflag, mode);
+ }
}
//----------------------------------------------------------------------
// open$NOCANCEL() interpose function
//----------------------------------------------------------------------
-extern "C" int
-open$NOCANCEL$__interposed__ (const char *path, int oflag, int mode)
-{
- const int pid = get_interposed_pid();
- if (pid >= 0)
- {
- Locker locker (&g_mutex);
- const int fd = ::open$NOCANCEL (path, oflag, mode);
- InvalidFDErrno fd_errno(fd);
- StringSP description_sp(new String ("pid=%i: open$NOCANCEL (path = '%s', oflag = %i, mode = %i) -> fd=%i", pid, path, oflag, mode, fd));
- if (g_log_all_calls)
- description_sp->log (get_logging_fd());
- if (fd >= 0)
- save_backtrace (fd, fd_errno.get_errno(), description_sp, true);
- return fd;
- }
- else
- {
- return ::open$NOCANCEL (path, oflag, mode);
- }
+extern "C" int open$NOCANCEL$__interposed__(const char *path, int oflag,
+ int mode) {
+ const int pid = get_interposed_pid();
+ if (pid >= 0) {
+ Locker locker(&g_mutex);
+ const int fd = ::open$NOCANCEL(path, oflag, mode);
+ InvalidFDErrno fd_errno(fd);
+ StringSP description_sp(new String(
+ "pid=%i: open$NOCANCEL (path = '%s', oflag = %i, mode = %i) -> fd=%i",
+ pid, path, oflag, mode, fd));
+ if (g_log_all_calls)
+ description_sp->log(get_logging_fd());
+ if (fd >= 0)
+ save_backtrace(fd, fd_errno.get_errno(), description_sp, true);
+ return fd;
+ } else {
+ return ::open$NOCANCEL(path, oflag, mode);
+ }
}
-
//----------------------------------------------------------------------
// __open_extended() interpose function
//----------------------------------------------------------------------
-extern "C" int
-__open_extended$__interposed__ (const char *path, int oflag, uid_t uid, gid_t gid, int mode, struct kauth_filesec *fsacl)
-{
- const int pid = get_interposed_pid();
- if (pid >= 0)
- {
- Locker locker (&g_mutex);
- const int fd = ::__open_extended (path, oflag, uid, gid, mode, fsacl);
- InvalidFDErrno fd_errno(fd);
- StringSP description_sp(new String ("pid=%i: __open_extended (path='%s', oflag=%i, uid=%i, gid=%i, mode=%i, fsacl=%p) -> fd=%i", pid, path, oflag, uid, gid, mode, fsacl, fd));
- if (g_log_all_calls)
- description_sp->log (get_logging_fd());
- if (fd >= 0)
- save_backtrace (fd, fd_errno.get_errno(), description_sp, true);
- return fd;
- }
- else
- {
- return ::__open_extended (path, oflag, uid, gid, mode, fsacl);
- }
+extern "C" int __open_extended$__interposed__(const char *path, int oflag,
+ uid_t uid, gid_t gid, int mode,
+ struct kauth_filesec *fsacl) {
+ const int pid = get_interposed_pid();
+ if (pid >= 0) {
+ Locker locker(&g_mutex);
+ const int fd = ::__open_extended(path, oflag, uid, gid, mode, fsacl);
+ InvalidFDErrno fd_errno(fd);
+ StringSP description_sp(
+ new String("pid=%i: __open_extended (path='%s', oflag=%i, uid=%i, "
+ "gid=%i, mode=%i, fsacl=%p) -> fd=%i",
+ pid, path, oflag, uid, gid, mode, fsacl, fd));
+ if (g_log_all_calls)
+ description_sp->log(get_logging_fd());
+ if (fd >= 0)
+ save_backtrace(fd, fd_errno.get_errno(), description_sp, true);
+ return fd;
+ } else {
+ return ::__open_extended(path, oflag, uid, gid, mode, fsacl);
+ }
}
//----------------------------------------------------------------------
// kqueue() interpose function
//----------------------------------------------------------------------
-extern "C" int
-kqueue$__interposed__ (void)
-{
- const int pid = get_interposed_pid();
- if (pid >= 0)
- {
- Locker locker (&g_mutex);
- const int fd = ::kqueue ();
- InvalidFDErrno fd_errno(fd);
- StringSP description_sp(new String ("pid=%i: kqueue () -> fd=%i", pid, fd));
- if (g_log_all_calls)
- description_sp->log (get_logging_fd());
- if (fd >= 0)
- save_backtrace (fd, fd_errno.get_errno(), description_sp, true);
- return fd;
- }
- else
- {
- return ::kqueue ();
- }
+extern "C" int kqueue$__interposed__(void) {
+ const int pid = get_interposed_pid();
+ if (pid >= 0) {
+ Locker locker(&g_mutex);
+ const int fd = ::kqueue();
+ InvalidFDErrno fd_errno(fd);
+ StringSP description_sp(new String("pid=%i: kqueue () -> fd=%i", pid, fd));
+ if (g_log_all_calls)
+ description_sp->log(get_logging_fd());
+ if (fd >= 0)
+ save_backtrace(fd, fd_errno.get_errno(), description_sp, true);
+ return fd;
+ } else {
+ return ::kqueue();
+ }
}
//----------------------------------------------------------------------
// shm_open() interpose function
//----------------------------------------------------------------------
-extern "C" int
-shm_open$__interposed__ (const char *path, int oflag, int mode)
-{
- const int pid = get_interposed_pid();
- if (pid >= 0)
- {
- Locker locker (&g_mutex);
- const int fd = ::shm_open (path, oflag, mode);
- InvalidFDErrno fd_errno(fd);
- StringSP description_sp(new String ("pid=%i: shm_open (path = '%s', oflag = %i, mode = %i) -> fd=%i", pid, path, oflag, mode, fd));
- if (g_log_all_calls)
- description_sp->log (get_logging_fd());
- if (fd >= 0)
- save_backtrace (fd, fd_errno.get_errno(), description_sp, true);
- return fd;
- }
- else
- {
- return ::shm_open (path, oflag, mode);
- }
+extern "C" int shm_open$__interposed__(const char *path, int oflag, int mode) {
+ const int pid = get_interposed_pid();
+ if (pid >= 0) {
+ Locker locker(&g_mutex);
+ const int fd = ::shm_open(path, oflag, mode);
+ InvalidFDErrno fd_errno(fd);
+ StringSP description_sp(new String(
+ "pid=%i: shm_open (path = '%s', oflag = %i, mode = %i) -> fd=%i", pid,
+ path, oflag, mode, fd));
+ if (g_log_all_calls)
+ description_sp->log(get_logging_fd());
+ if (fd >= 0)
+ save_backtrace(fd, fd_errno.get_errno(), description_sp, true);
+ return fd;
+ } else {
+ return ::shm_open(path, oflag, mode);
+ }
}
//----------------------------------------------------------------------
// accept() interpose function
//----------------------------------------------------------------------
-extern "C" int
-accept$__interposed__ (int socket, struct sockaddr *address, socklen_t *address_len)
-{
- const int pid = get_interposed_pid();
- if (pid >= 0)
- {
- Locker locker (&g_mutex);
- const int fd = ::accept (socket, address, address_len);
- InvalidFDErrno fd_errno(fd);
- StringSP description_sp(new String ("pid=%i: accept (socket=%i, ...) -> fd=%i", pid, socket, fd));
- if (g_log_all_calls)
- description_sp->log (get_logging_fd());
- if (fd >= 0)
- save_backtrace (fd, fd_errno.get_errno(), description_sp, true);
- return fd;
- }
- else
- {
- return ::accept (socket, address, address_len);
- }
+extern "C" int accept$__interposed__(int socket, struct sockaddr *address,
+ socklen_t *address_len) {
+ const int pid = get_interposed_pid();
+ if (pid >= 0) {
+ Locker locker(&g_mutex);
+ const int fd = ::accept(socket, address, address_len);
+ InvalidFDErrno fd_errno(fd);
+ StringSP description_sp(new String(
+ "pid=%i: accept (socket=%i, ...) -> fd=%i", pid, socket, fd));
+ if (g_log_all_calls)
+ description_sp->log(get_logging_fd());
+ if (fd >= 0)
+ save_backtrace(fd, fd_errno.get_errno(), description_sp, true);
+ return fd;
+ } else {
+ return ::accept(socket, address, address_len);
+ }
}
-
//----------------------------------------------------------------------
// accept$NOCANCEL() interpose function
//----------------------------------------------------------------------
-extern "C" int
-accept$NOCANCEL$__interposed__ (int socket, struct sockaddr *address, socklen_t *address_len)
-{
- const int pid = get_interposed_pid();
- if (pid >= 0)
- {
- Locker locker (&g_mutex);
- const int fd = ::accept$NOCANCEL (socket, address, address_len);
- InvalidFDErrno fd_errno(fd);
- StringSP description_sp(new String ("pid=%i: accept$NOCANCEL (socket=%i, ...) -> fd=%i", pid, socket, fd));
- if (g_log_all_calls)
- description_sp->log (get_logging_fd());
- if (fd >= 0)
- save_backtrace (fd, fd_errno.get_errno(), description_sp, true);
- return fd;
- }
- else
- {
- return ::accept$NOCANCEL (socket, address, address_len);
- }
+extern "C" int accept$NOCANCEL$__interposed__(int socket,
+ struct sockaddr *address,
+ socklen_t *address_len) {
+ const int pid = get_interposed_pid();
+ if (pid >= 0) {
+ Locker locker(&g_mutex);
+ const int fd = ::accept$NOCANCEL(socket, address, address_len);
+ InvalidFDErrno fd_errno(fd);
+ StringSP description_sp(new String(
+ "pid=%i: accept$NOCANCEL (socket=%i, ...) -> fd=%i", pid, socket, fd));
+ if (g_log_all_calls)
+ description_sp->log(get_logging_fd());
+ if (fd >= 0)
+ save_backtrace(fd, fd_errno.get_errno(), description_sp, true);
+ return fd;
+ } else {
+ return ::accept$NOCANCEL(socket, address, address_len);
+ }
}
//----------------------------------------------------------------------
// dup() interpose function
//----------------------------------------------------------------------
-extern "C" int
-dup$__interposed__ (int fd2)
-{
- const int pid = get_interposed_pid();
- if (pid >= 0)
- {
- Locker locker (&g_mutex);
- const int fd = ::dup (fd2);
- InvalidFDErrno fd_errno(fd);
- StringSP description_sp(new String ("pid=%i: dup (fd2=%i) -> fd=%i", pid, fd2, fd));
- if (g_log_all_calls)
- description_sp->log (get_logging_fd());
- if (fd >= 0)
- save_backtrace (fd, fd_errno.get_errno(), description_sp, true);
- return fd;
- }
- else
- {
- return ::dup (fd2);
- }
+extern "C" int dup$__interposed__(int fd2) {
+ const int pid = get_interposed_pid();
+ if (pid >= 0) {
+ Locker locker(&g_mutex);
+ const int fd = ::dup(fd2);
+ InvalidFDErrno fd_errno(fd);
+ StringSP description_sp(
+ new String("pid=%i: dup (fd2=%i) -> fd=%i", pid, fd2, fd));
+ if (g_log_all_calls)
+ description_sp->log(get_logging_fd());
+ if (fd >= 0)
+ save_backtrace(fd, fd_errno.get_errno(), description_sp, true);
+ return fd;
+ } else {
+ return ::dup(fd2);
+ }
}
//----------------------------------------------------------------------
// dup2() interpose function
//----------------------------------------------------------------------
-extern "C" int
-dup2$__interposed__ (int fd1, int fd2)
-{
- const int pid = get_interposed_pid();
- if (pid >= 0)
- {
- Locker locker (&g_mutex);
- // If "fd2" is already opened, it will be closed during the
- // dup2 call below, so we need to see if we have fd2 in our
- // open map and treat it as a close(fd2)
- FDEventMap::iterator pos = g_fd_event_map.find (fd2);
- StringSP dup2_close_description_sp(new String ("pid=%i: dup2 (fd1=%i, fd2=%i) -> will close (fd=%i)", pid, fd1, fd2, fd2));
- if (pos != g_fd_event_map.end() && pos->second.back()->IsCreateEvent())
- save_backtrace (fd2, 0, dup2_close_description_sp, false);
-
- const int fd = ::dup2(fd1, fd2);
- InvalidFDErrno fd_errno(fd);
- StringSP description_sp(new String ("pid=%i: dup2 (fd1=%i, fd2=%i) -> fd=%i", pid, fd1, fd2, fd));
- if (g_log_all_calls)
- description_sp->log (get_logging_fd());
-
- if (fd >= 0)
- save_backtrace (fd, fd_errno.get_errno(), description_sp, true);
- return fd;
- }
- else
- {
- return ::dup2(fd1, fd2);
- }
+extern "C" int dup2$__interposed__(int fd1, int fd2) {
+ const int pid = get_interposed_pid();
+ if (pid >= 0) {
+ Locker locker(&g_mutex);
+ // If "fd2" is already opened, it will be closed during the
+ // dup2 call below, so we need to see if we have fd2 in our
+ // open map and treat it as a close(fd2)
+ FDEventMap::iterator pos = g_fd_event_map.find(fd2);
+ StringSP dup2_close_description_sp(
+ new String("pid=%i: dup2 (fd1=%i, fd2=%i) -> will close (fd=%i)", pid,
+ fd1, fd2, fd2));
+ if (pos != g_fd_event_map.end() && pos->second.back()->IsCreateEvent())
+ save_backtrace(fd2, 0, dup2_close_description_sp, false);
+
+ const int fd = ::dup2(fd1, fd2);
+ InvalidFDErrno fd_errno(fd);
+ StringSP description_sp(new String("pid=%i: dup2 (fd1=%i, fd2=%i) -> fd=%i",
+ pid, fd1, fd2, fd));
+ if (g_log_all_calls)
+ description_sp->log(get_logging_fd());
+
+ if (fd >= 0)
+ save_backtrace(fd, fd_errno.get_errno(), description_sp, true);
+ return fd;
+ } else {
+ return ::dup2(fd1, fd2);
+ }
}
//----------------------------------------------------------------------
// close() interpose function
//----------------------------------------------------------------------
-extern "C" int
-close$__interposed__ (int fd)
-{
- const int pid = get_interposed_pid();
- if (pid >= 0)
- {
- Locker locker (&g_mutex);
- const int err = close(fd);
- NegativeErrorErrno err_errno(err);
- StringSP description_sp (new String);
- if (err == -1)
- description_sp->printf("pid=%i: close (fd=%i) => %i errno = %i (%s))", pid, fd, err, err_errno.get_errno(), strerror(err_errno.get_errno()));
- else
- description_sp->printf("pid=%i: close (fd=%i) => %i", pid, fd, err);
- if (g_log_all_calls)
- description_sp->log (get_logging_fd());
-
- if (err == 0)
- {
- if (fd >= 0)
- save_backtrace (fd, err, description_sp, false);
- }
- else if (err == -1)
- {
- if (err_errno.get_errno() == EBADF && fd != -1)
- {
- backtrace_error ("close (fd=%d) resulted in EBADF:\n", fd);
-
- FDEventMap::iterator pos = g_fd_event_map.find (fd);
- if (pos != g_fd_event_map.end())
- {
- log (get_logging_fd(), pos->second.back().get(), "\nfd=%d was previously %s with this event:\n", fd, pos->second.back()->IsCreateEvent() ? "opened" : "closed");
- }
- }
- }
- return err;
- }
+extern "C" int close$__interposed__(int fd) {
+ const int pid = get_interposed_pid();
+ if (pid >= 0) {
+ Locker locker(&g_mutex);
+ const int err = close(fd);
+ NegativeErrorErrno err_errno(err);
+ StringSP description_sp(new String);
+ if (err == -1)
+ description_sp->printf("pid=%i: close (fd=%i) => %i errno = %i (%s))",
+ pid, fd, err, err_errno.get_errno(),
+ strerror(err_errno.get_errno()));
else
- {
- return close (fd);
+ description_sp->printf("pid=%i: close (fd=%i) => %i", pid, fd, err);
+ if (g_log_all_calls)
+ description_sp->log(get_logging_fd());
+
+ if (err == 0) {
+ if (fd >= 0)
+ save_backtrace(fd, err, description_sp, false);
+ } else if (err == -1) {
+ if (err_errno.get_errno() == EBADF && fd != -1) {
+ backtrace_error("close (fd=%d) resulted in EBADF:\n", fd);
+
+ FDEventMap::iterator pos = g_fd_event_map.find(fd);
+ if (pos != g_fd_event_map.end()) {
+ log(get_logging_fd(), pos->second.back().get(),
+ "\nfd=%d was previously %s with this event:\n", fd,
+ pos->second.back()->IsCreateEvent() ? "opened" : "closed");
+ }
+ }
}
+ return err;
+ } else {
+ return close(fd);
+ }
}
//----------------------------------------------------------------------
// close$NOCANCEL() interpose function
//----------------------------------------------------------------------
-extern "C" int
-close$NOCANCEL$__interposed__ (int fd)
-{
- const int pid = get_interposed_pid();
- if (pid >= 0)
- {
- Locker locker (&g_mutex);
- const int err = close$NOCANCEL(fd);
- NegativeErrorErrno err_errno(err);
- StringSP description_sp (new String);
- if (err == -1)
- description_sp->printf("pid=%i: close$NOCANCEL (fd=%i) => %i errno = %i (%s))", pid, fd, err, err_errno.get_errno(), strerror(err_errno.get_errno()));
- else
- description_sp->printf("pid=%i: close$NOCANCEL (fd=%i) => %i", pid, fd, err);
- if (g_log_all_calls)
- description_sp->log (get_logging_fd());
-
- if (err == 0)
- {
- if (fd >= 0)
- save_backtrace (fd, err, description_sp, false);
- }
- else if (err == -1)
- {
- if (err_errno.get_errno() == EBADF && fd != -1)
- {
- backtrace_error ("close$NOCANCEL (fd=%d) resulted in EBADF\n:", fd);
-
- FDEventMap::iterator pos = g_fd_event_map.find (fd);
- if (pos != g_fd_event_map.end())
- {
- log (get_logging_fd(), pos->second.back().get(), "\nfd=%d was previously %s with this event:\n", fd, pos->second.back()->IsCreateEvent() ? "opened" : "closed");
- }
- }
+extern "C" int close$NOCANCEL$__interposed__(int fd) {
+ const int pid = get_interposed_pid();
+ if (pid >= 0) {
+ Locker locker(&g_mutex);
+ const int err = close$NOCANCEL(fd);
+ NegativeErrorErrno err_errno(err);
+ StringSP description_sp(new String);
+ if (err == -1)
+ description_sp->printf(
+ "pid=%i: close$NOCANCEL (fd=%i) => %i errno = %i (%s))", pid, fd, err,
+ err_errno.get_errno(), strerror(err_errno.get_errno()));
+ else
+ description_sp->printf("pid=%i: close$NOCANCEL (fd=%i) => %i", pid, fd,
+ err);
+ if (g_log_all_calls)
+ description_sp->log(get_logging_fd());
+
+ if (err == 0) {
+ if (fd >= 0)
+ save_backtrace(fd, err, description_sp, false);
+ } else if (err == -1) {
+ if (err_errno.get_errno() == EBADF && fd != -1) {
+ backtrace_error("close$NOCANCEL (fd=%d) resulted in EBADF\n:", fd);
+
+ FDEventMap::iterator pos = g_fd_event_map.find(fd);
+ if (pos != g_fd_event_map.end()) {
+ log(get_logging_fd(), pos->second.back().get(),
+ "\nfd=%d was previously %s with this event:\n", fd,
+ pos->second.back()->IsCreateEvent() ? "opened" : "closed");
}
- return err;
+ }
}
- else
- {
- return close$NOCANCEL(fd);
- }
+ return err;
+ } else {
+ return close$NOCANCEL(fd);
+ }
}
//----------------------------------------------------------------------
// pipe() interpose function
//----------------------------------------------------------------------
-extern "C" int
-pipe$__interposed__ (int fds[2])
-{
- const int pid = get_interposed_pid();
- if (pid >= 0)
- {
- Locker locker (&g_mutex);
- fds[0] = -1;
- fds[1] = -1;
- const int err = pipe (fds);
- const int saved_errno = errno;
- StringSP description_sp(new String ("pid=%i: pipe ({fd=%i, fd=%i}) -> err=%i", pid, fds[0], fds[1], err));
- if (g_log_all_calls)
- description_sp->log (get_logging_fd());
- if (fds[0] >= 0)
- save_backtrace (fds[0], saved_errno, description_sp, true);
- if (fds[1] >= 0)
- save_backtrace (fds[1], saved_errno, description_sp, true);
- errno = saved_errno;
- return err;
- }
- else
- {
- return pipe (fds);
- }
+extern "C" int pipe$__interposed__(int fds[2]) {
+ const int pid = get_interposed_pid();
+ if (pid >= 0) {
+ Locker locker(&g_mutex);
+ fds[0] = -1;
+ fds[1] = -1;
+ const int err = pipe(fds);
+ const int saved_errno = errno;
+ StringSP description_sp(new String(
+ "pid=%i: pipe ({fd=%i, fd=%i}) -> err=%i", pid, fds[0], fds[1], err));
+ if (g_log_all_calls)
+ description_sp->log(get_logging_fd());
+ if (fds[0] >= 0)
+ save_backtrace(fds[0], saved_errno, description_sp, true);
+ if (fds[1] >= 0)
+ save_backtrace(fds[1], saved_errno, description_sp, true);
+ errno = saved_errno;
+ return err;
+ } else {
+ return pipe(fds);
+ }
}
//----------------------------------------------------------------------
@@ -1095,35 +938,27 @@ pipe$__interposed__ (int fds[2])
// @param[in] fd
// The file descriptor whose history should be dumped
//----------------------------------------------------------------------
-extern "C" void
-get_fd_history (int log_fd, int fd)
-{
- // "create" below needs to be outside of the mutex locker scope
- if (log_fd >= 0)
- {
- bool got_lock = false;
- Locker locker (&g_mutex, got_lock);
- if (got_lock)
- {
- FDEventMap::iterator pos = g_fd_event_map.find (fd);
- log_to_fd (log_fd, "Dumping file descriptor history for fd=%i:\n", fd);
- if (pos != g_fd_event_map.end())
- {
- FDEventArray &event_array = g_fd_event_map[fd];
- const size_t num_events = event_array.size();
- for (size_t i=0; i<num_events; ++i)
- event_array[i]->Dump (log_fd);
- }
- else
- {
- log_to_fd (log_fd, "error: no file descriptor events found for fd=%i\n", fd);
- }
- }
- else
- {
- log_to_fd (log_fd, "error: fd event mutex is locked...\n");
- }
- }
+extern "C" void get_fd_history(int log_fd, int fd) {
+ // "create" below needs to be outside of the mutex locker scope
+ if (log_fd >= 0) {
+ bool got_lock = false;
+ Locker locker(&g_mutex, got_lock);
+ if (got_lock) {
+ FDEventMap::iterator pos = g_fd_event_map.find(fd);
+ log_to_fd(log_fd, "Dumping file descriptor history for fd=%i:\n", fd);
+ if (pos != g_fd_event_map.end()) {
+ FDEventArray &event_array = g_fd_event_map[fd];
+ const size_t num_events = event_array.size();
+ for (size_t i = 0; i < num_events; ++i)
+ event_array[i]->Dump(log_fd);
+ } else {
+ log_to_fd(log_fd, "error: no file descriptor events found for fd=%i\n",
+ fd);
+ }
+ } else {
+ log_to_fd(log_fd, "error: fd event mutex is locked...\n");
+ }
+ }
}
//----------------------------------------------------------------------
@@ -1148,5 +983,3 @@ DYLD_INTERPOSE(close$__interposed__, close);
DYLD_INTERPOSE(close$NOCANCEL$__interposed__, close$NOCANCEL);
} // namespace fd_interposing
-
-
OpenPOWER on IntegriCloud