diff options
| author | Emiliano Ciavatta | 2020-04-13 15:12:35 +0000 |
|---|---|---|
| committer | Emiliano Ciavatta | 2020-04-13 15:12:35 +0000 |
| commit | a56a4e391d541ae05de0203f3d493edc3b04681d (patch) | |
| tree | ab9344a650305aafb5afe552dc8cad63684de643 /stream_handler.go | |
| parent | 7113463dead05631339fdab94de9440201c42489 (diff) | |
Add AddRoute tests
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{ |