aaac7fed
 liuqimichale
add
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
|
var assert = require('assert');
var net = require('net');
var streamPair = require('stream-pair');
var thing = require('../');
describe('Handle Thing', function() {
var handle;
var pair;
var socket;
[ 'normal', 'lazy' ].forEach(function(mode) {
describe(mode, function() {
beforeEach(function() {
pair = streamPair.create();
handle = thing.create(mode === 'normal' ? pair.other : null);
socket = new net.Socket({ handle: handle });
if (mode === 'lazy') {
setTimeout(function() {
handle.setStream(pair.other);
}, 50);
}
// For v0.8
socket.readable = true;
socket.writable = true;
});
afterEach(function() {
assert(handle._stream);
});
it('should write data to Socket', function(done) {
pair.write('hello');
pair.write(' world');
pair.end('... ok');
var chunks = '';
socket.on('data', function(chunk) {
chunks += chunk;
});
socket.on('end', function() {
assert.equal(chunks, 'hello world... ok');
// allowHalfOpen is `false`, so the `end` should be followed by `close`
socket.once('close', function() {
done();
});
});
});
it('should read data from Socket', function(done) {
socket.write('hello');
socket.write(' world');
socket.end('... ok');
var chunks = '';
pair.on('data', function(chunk) {
chunks += chunk;
});
pair.on('end', function() {
assert.equal(chunks, 'hello world... ok');
done();
});
});
it('should invoke `close` callback', function(done) {
handle._options.close = function(callback) {
done();
process.nextTick(callback);
};
pair.end('hello');
socket.resume();
});
it('should kill pending requests', function(done) {
handle._options.close = function() {
setTimeout(done, 75);
};
socket.write('hello');
socket.destroy();
});
if (mode === 'normal') {
it('should invoke `getPeerName` callback', function() {
handle._options.getPeerName = function() {
return { address: 'ohai' };
};
assert.equal(socket.remoteAddress, 'ohai');
});
it('should emit ECONNRESET at `close` event', function(done) {
pair.other.emit('close');
// No error emitted in v0.8
if (thing.mode === 'rusty') {
socket.on('close', function() {
done();
});
return;
}
socket.on('error', function(err) {
assert(/ECONNRESET/.test(err.message));
done();
});
});
}
});
});
});
|
