ping-pong-uv.js 549 B

12345678910111213141516171819202122232425262728293031
  1. var count = 0;
  2. var byte = new Buffer([0x33]);
  3. function ping(buffer, offset, length) {
  4. count++;
  5. pong(this);
  6. }
  7. function noop() {}
  8. function pong(sock)
  9. {
  10. var writeReq = sock.writeBuffer(byte);
  11. writeReq.oncomplete = noop;
  12. }
  13. var port = 3334;
  14. var TCP = process.binding('tcp_wrap').TCP;
  15. var client = new TCP();
  16. var req = client.connect('127.0.0.1', port);
  17. req.oncomplete = function() {
  18. console.log('connected');
  19. pong(client);
  20. };
  21. client.onread = ping;
  22. client.readStart();
  23. setInterval(function() {
  24. console.log(count);
  25. count = 0;
  26. }, 1000);