diff options
Diffstat (limited to 'stream_handler.go')
| -rw-r--r-- | stream_handler.go | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/stream_handler.go b/stream_handler.go index 78326c6..a436fd5 100644 --- a/stream_handler.go +++ b/stream_handler.go @@ -147,7 +147,7 @@ func (sh *StreamHandler) onMatch(id uint, from uint64, to uint64, _ uint, _ inte func (sh *StreamHandler) storageCurrentDocument() { payload := sh.streamFlow.Hash()&uint64(0xffffffffffffff00) | uint64(len(sh.documentsIDs)) // LOL - streamID := sh.connection.Storage().NewCustomRowID(payload, sh.firstPacketSeen) + streamID := CustomRowID(payload, sh.firstPacketSeen) _, err := sh.connection.Storage().Insert(ConnectionStreams). One(ConnectionStream{ |