| FazBrowse GitHub Viewer | Trending | | Home |
| Tools: [Download Repo ZIP] [Original HTTPS Page] |
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
@@ -264,7 +264,14 @@ void WalkHandle(uv_handle_t* h, void* arg) { | |||
| 264 | 264 | writer->json_keyvalue("writable", | |
| 265 | 265 | static_cast<bool>(uv_is_writable(&handle->stream))); | |
| 266 | 266 | } | |
| 267 | - | ||
| 267 | + if (h->type == UV_UDP) { | ||
| 268 | + writer->json_keyvalue( | ||
| 269 | + "writeQueueSize", | ||
| 270 | + uv_udp_get_send_queue_size(reinterpret_cast<uv_udp_t*>(h))); | ||
| 271 | + writer->json_keyvalue( | ||
| 272 | + "writeQueueCount", | ||
| 273 | + uv_udp_get_send_queue_count(reinterpret_cast<uv_udp_t*>(h))); | ||
| 274 | + } | ||
| 268 | 275 | writer->json_end(); | |
| 269 | 276 | } | |
| 270 | 277 | ||
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
@@ -260,6 +260,8 @@ if (process.argv[2] === 'child') { | |||
| 260 | 260 | found_udp.push('connected'); | |
| 261 | 261 | } | |
| 262 | 262 | assert(handle.is_referenced); | |
| 263 | + assert.strictEqual(handle.writeQueueSize, 0); | ||
| 264 | + assert.strictEqual(handle.writeQueueCount, 0); | ||
| 263 | 265 | }, 2), | |
| 264 | 266 | }; | |
| 265 | 267 | ||
| Back | FazBrowse Home | New Git URL |
0 commit comments