Thrift: Adding StatsProcessor, PeekProcessor, TPipedFileReaderTransport, and TPipedFileReaderTransportFactory classes
- StatsProcessor can be used to print events, or keep track of event frequency
- PeekProcessor is used to examine data in a thrift event, prior to passing it along to an underlying processor
- TPipedFileReaderTransport and its factory are used to pipe a TFileReaderTransport (which TFileProcessor requires)
Also fixed some bugs in TFileTransport - next flush time was overflowing and not always being reset
Reviewed by: aditya, mcslee
Test Plan: Tested using various thrift clients (scribe, falcon) and gdb in sandbox and on dev008.
git-svn-id: https://svn.apache.org/repos/asf/incubator/thrift/trunk@665066 13f79535-47bb-0310-9956-ffa450edef68
diff --git a/lib/cpp/Makefile.am b/lib/cpp/Makefile.am
index b205e78..84618f4 100644
--- a/lib/cpp/Makefile.am
+++ b/lib/cpp/Makefile.am
@@ -11,7 +11,8 @@
src/concurrency/PosixThreadFactory.cpp \
src/concurrency/ThreadManager.cpp \
src/concurrency/TimerManager.cpp \
- src/protocol/TBinaryProtocol.cpp \
+ src/processor/PeekProcessor.cpp \
+ src/protocol/TBinaryProtocol.cpp \
src/transport/TFileTransport.cpp \
src/transport/THttpClient.cpp \
src/transport/TSocket.cpp \
@@ -34,14 +35,14 @@
include_thriftdir = $(includedir)/thrift
include_thrift_HEADERS = \
- config.h \
- src/Thrift.h \
- src/TProcessor.h \
- src/TLogging.h
+ config.h \
+ src/Thrift.h \
+ src/TProcessor.h \
+ src/TLogging.h
include_concurrencydir = $(include_thriftdir)/concurrency
include_concurrency_HEADERS = \
- src/concurrency/Exception.h \
+ src/concurrency/Exception.h \
src/concurrency/Mutex.h \
src/concurrency/Monitor.h \
src/concurrency/PosixThreadFactory.h \