diff options
author | Taylor Gerring <taylor.gerring@gmail.com> | 2015-03-20 02:28:31 +0800 |
---|---|---|
committer | Taylor Gerring <taylor.gerring@gmail.com> | 2015-03-20 02:28:31 +0800 |
commit | c7b616ac14a6e349b57bad6511085d7189a19e3e (patch) | |
tree | fbf9fc4d285d07ec65c0b130b8208ee66ea1908d | |
parent | 1f2de6ecd546a094c4bead52c88963b74ed6b66a (diff) | |
download | dexon-c7b616ac14a6e349b57bad6511085d7189a19e3e.tar dexon-c7b616ac14a6e349b57bad6511085d7189a19e3e.tar.gz dexon-c7b616ac14a6e349b57bad6511085d7189a19e3e.tar.bz2 dexon-c7b616ac14a6e349b57bad6511085d7189a19e3e.tar.lz dexon-c7b616ac14a6e349b57bad6511085d7189a19e3e.tar.xz dexon-c7b616ac14a6e349b57bad6511085d7189a19e3e.tar.zst dexon-c7b616ac14a6e349b57bad6511085d7189a19e3e.zip |
Remove util
-rw-r--r-- | rpc/api.go | 33 | ||||
-rw-r--r-- | rpc/util.go | 57 |
2 files changed, 33 insertions, 57 deletions
diff --git a/rpc/api.go b/rpc/api.go index 792498547..d00b86ac0 100644 --- a/rpc/api.go +++ b/rpc/api.go @@ -862,3 +862,36 @@ func toFilterOptions(options *FilterOptions) core.FilterOptions { return opts } + +type whisperFilter struct { + messages []xeth.WhisperMessage + timeout time.Time + id int +} + +func (w *whisperFilter) add(msgs ...xeth.WhisperMessage) { + w.messages = append(w.messages, msgs...) +} +func (w *whisperFilter) get() []xeth.WhisperMessage { + w.timeout = time.Now() + tmp := w.messages + w.messages = nil + return tmp +} + +type logFilter struct { + logs state.Logs + timeout time.Time + id int +} + +func (l *logFilter) add(logs ...state.Log) { + l.logs = append(l.logs, logs...) +} + +func (l *logFilter) get() state.Logs { + l.timeout = time.Now() + tmp := l.logs + l.logs = nil + return tmp +} diff --git a/rpc/util.go b/rpc/util.go deleted file mode 100644 index e2442b9fb..000000000 --- a/rpc/util.go +++ /dev/null @@ -1,57 +0,0 @@ -/* - This file is part of go-ethereum - - go-ethereum 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 3 of the License, or - (at your option) any later version. - - go-ethereum 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 go-ethereum. If not, see <http://www.gnu.org/licenses/>. -*/ -package rpc - -import ( - "time" - - "github.com/ethereum/go-ethereum/state" - "github.com/ethereum/go-ethereum/xeth" -) - -type whisperFilter struct { - messages []xeth.WhisperMessage - timeout time.Time - id int -} - -func (w *whisperFilter) add(msgs ...xeth.WhisperMessage) { - w.messages = append(w.messages, msgs...) -} -func (w *whisperFilter) get() []xeth.WhisperMessage { - w.timeout = time.Now() - tmp := w.messages - w.messages = nil - return tmp -} - -type logFilter struct { - logs state.Logs - timeout time.Time - id int -} - -func (l *logFilter) add(logs ...state.Log) { - l.logs = append(l.logs, logs...) -} - -func (l *logFilter) get() state.Logs { - l.timeout = time.Now() - tmp := l.logs - l.logs = nil - return tmp -} |