diff options
author | Micael Karlberg <[email protected]> | 2019-06-26 14:05:48 +0200 |
---|---|---|
committer | Micael Karlberg <[email protected]> | 2019-06-26 15:06:16 +0200 |
commit | 64cdec60d31e50f6db39452ec028c2f378f017b0 (patch) | |
tree | 9afffa2392fdd6328d723f1f308dbe50eb83da66 | |
parent | 986ece624c097a4f2a573d8c1ecc99991b4e6252 (diff) | |
download | otp-64cdec60d31e50f6db39452ec028c2f378f017b0.tar.gz otp-64cdec60d31e50f6db39452ec028c2f378f017b0.tar.bz2 otp-64cdec60d31e50f6db39452ec028c2f378f017b0.zip |
[esock] Corrected some counter actions
Corrected both read pkg and byte counter increment for recvfrom
(was actually missing).
OTP-1581
-rw-r--r-- | erts/emulator/nifs/common/socket_nif.c | 10 |
1 files changed, 10 insertions, 0 deletions
diff --git a/erts/emulator/nifs/common/socket_nif.c b/erts/emulator/nifs/common/socket_nif.c index 8e679ec6ae..493cacadcd 100644 --- a/erts/emulator/nifs/common/socket_nif.c +++ b/erts/emulator/nifs/common/socket_nif.c @@ -14974,6 +14974,10 @@ ERL_NIF_TERM recv_check_result(ErlNifEnv* env, res = esock_make_error(env, atom_closed); + // This is a bit overkill (to count here), but just in case... + // cnt_inc(&descP->readFails, 1); + SOCK_CNT_INC(env, descP, sockRef, atom_read_fails, &descP->readFails, 1); + /* * When a stream socket peer has performed an orderly shutdown, * the return value will be 0 (the traditional "end-of-file" return). @@ -15537,6 +15541,12 @@ ERL_NIF_TERM recvfrom_check_result(ErlNifEnv* env, data = MKSBIN(env, data, 0, read); } + // cnt_inc(&descP->readPkgCnt, 1); + SOCK_CNT_INC(env, descP, sockRef, atom_read_pkg, &descP->readPkgCnt, 1); + // cnt_inc(&descP->readByteCnt, read); + SOCK_CNT_INC(env, descP, sockRef, atom_read_byte, + &descP->readByteCnt, read); + recv_update_current_reader(env, descP, sockRef); res = esock_make_ok2(env, MKT2(env, eSockAddr, data)); |