File tree Expand file tree Collapse file tree 2 files changed +13
-13
lines changed Expand file tree Collapse file tree 2 files changed +13
-13
lines changed Original file line number Diff line number Diff line change 63
63
64
64
_IS_SYNC = False
65
65
66
- TOTAL = []
67
- TOTAL_WRITE = []
68
- TOTAL_READ = []
66
+ # TOTAL = []
67
+ # TOTAL_WRITE = []
68
+ # TOTAL_READ = []
69
69
# print(f"TOTALS: {TOTAL, TOTAL_WRITE, TOTAL_READ}")
70
70
71
71
@@ -211,13 +211,13 @@ async def command_stream(
211
211
read_start = time .monotonic ()
212
212
reply = await receive_message_stream (conn , request_id )
213
213
read_elapsed = time .monotonic () - read_start
214
- if name == "insert" :
215
- TOTAL .append (write_elapsed + read_elapsed )
216
- TOTAL_READ .append (read_elapsed )
217
- TOTAL_WRITE .append (write_elapsed )
218
- if name == "endSessions" :
219
- print (
220
- f"AVERAGE READ: { statistics .mean (TOTAL_READ )} , AVERAGE WRITE: { statistics .mean (TOTAL_WRITE )} , AVERAGE ELAPSED: { statistics .mean (TOTAL )} " )
214
+ # if name == "insert":
215
+ # TOTAL.append(write_elapsed + read_elapsed)
216
+ # TOTAL_READ.append(read_elapsed)
217
+ # TOTAL_WRITE.append(write_elapsed)
218
+ # if name == "endSessions":
219
+ # print(
220
+ # f"AVERAGE READ: {statistics.mean(TOTAL_READ)}, AVERAGE WRITE: {statistics.mean(TOTAL_WRITE)}, AVERAGE ELAPSED: {statistics.mean(TOTAL)}")
221
221
conn .more_to_come = reply .more_to_come
222
222
unpacked_docs = reply .unpack_response (
223
223
codec_options = codec_options , user_fields = user_fields
Original file line number Diff line number Diff line change 60
60
_CURSOR_DOC_FIELDS = {"cursor" : {"firstBatch" : 1 , "nextBatch" : 1 }}
61
61
62
62
63
- TOTAL = []
64
- TOTAL_WRITE = []
65
- TOTAL_READ = []
63
+ # TOTAL = []
64
+ # TOTAL_WRITE = []
65
+ # TOTAL_READ = []
66
66
# print(f"TOTALS: {TOTAL, TOTAL_WRITE, TOTAL_READ}")
67
67
68
68
You can’t perform that action at this time.
0 commit comments