@@ -54,39 +54,13 @@ main = defaultMain
54
54
-- bench "parser" $ nf parse bs
55
55
-- ]
56
56
-- ]
57
- [ bgroup " Decoder"
58
- [ env (pure dec) $ \ p -> bench " datarow" $ nf (benchDataRowDecoder p) bs]
59
- ]
60
- -- main = benchMultiPw
61
- dec :: Decode (Maybe B. ByteString , Maybe Int32 , Maybe Int32 ,
62
- Maybe Int16 , Maybe Bool , Maybe B. ByteString ,
63
- Maybe Bool , Maybe Bool , Maybe B. ByteString ,
64
- Maybe Int32 , Maybe Int32 , Maybe Int32 )
65
- dec = rowDecoder
66
-
67
- parser = skipDataRowHeader *> p
68
- where
69
- p = (,,,,,,,,,,,)
70
- <$> fn getByteString
71
- <*> fn int4
72
- <*> fn int4
73
- <*> fn int2
74
- <*> fn bool
75
- <*> fn getByteString
76
- <*> fn bool
77
- <*> fn bool
78
- <*> fn getByteString
79
- <*> fn int4
80
- <*> fn int4
81
- <*> fn int4
82
- fn = getNullable
83
-
84
- benchDataRowDecoder d bs = decodeManyRows d $
85
- DataRows (DataChunk 380 bs) Empty
86
- where
87
- decodeDataRow = do
88
- (Header _ len) <- decodeHeader
89
- getByteString len
57
+
58
+ -- benchDataRowDecoder d bs = decodeManyRows d $
59
+ -- DataRows (DataChunk 380 bs) Empty
60
+ -- where
61
+ -- decodeDataRow = do
62
+ -- (Header _ len) <- decodeHeader
63
+ -- getByteString len
90
64
91
65
{-# NOINLINE bs #-}
92
66
bs :: B. ByteString
@@ -155,20 +129,12 @@ benchMultiPw = benchRequests createConnection $ \c -> do
155
129
sendBatchAndSync c [q]
156
130
d <- readNextData c
157
131
waitReadyForQuery c
158
- -- case d of
159
- -- Left _ -> undefined
160
- -- Right rows -> pure $ decodeManyRows dec rows
161
132
where
162
133
q = Query largeStmt V. empty Binary Binary AlwaysCache
163
134
largeStmt = " SELECT * from _bytes_300_of_100"
164
135
-- largeStmt = "select typname, typnamespace, typowner, typlen, typbyval,"
165
136
-- <> "typcategory, typispreferred, typisdefined, typdelim,"
166
137
-- <> "typrelid, typelem, typarray from pg_type"
167
- dec :: Decode (Maybe B. ByteString , Maybe Int32 , Maybe Int32 ,
168
- Maybe Int16 , Maybe Bool , Maybe B. ByteString ,
169
- Maybe Bool , Maybe Bool , Maybe B. ByteString ,
170
- Maybe Int32 , Maybe Int32 , Maybe Int32 )
171
- dec = rowDecoder
172
138
173
139
benchLibpq :: IO ()
174
140
benchLibpq = benchRequests libpqConnection $ \ c -> do
0 commit comments