Class SocketFile

src/kernel/socket.ts:28–168

}

export class SocketFile implements IFile {
	task:          ITask;
	isListening:   boolean    = false;
	parent:        SocketFile = undefined;
	refCount:      number     = 1;

	port:          number;
	addr:          string;

	peer:          SocketFile = undefined;

	outgoing:      Pipe = undefined;
	incoming:      Pipe = undefined;

	incomingQueue: Incoming[] = [];
	acceptQueue:   AcceptCallback[] = [];

	constructor(task: ITask) {
		this.task = task;
	}

	stat(cb: (err: any, stats: any) => void): void {
		throw new Error('TODO: SocketFile.stat not implemented');
	}

	readdir(cb: (err: any, files: string[]) => void): void {
		setTimeout(cb, 0, 'cant readdir on normal file');
	}

	listen(cb: (err: number) => void): void {
		this.isListening = true;
		cb(0);
	}

	accept(cb: AcceptCallback): void {
		if (!this.incomingQueue.length) {
			this.acceptQueue.push(cb);
			return;
		}

		let queued = this.incomingQueue.shift();

		let remote = queued.s;
		let local = new SocketFile(this.task);
		local.addr = queued.addr;
		local.port = queued.port;

		let outgoing = new Pipe();
		let incoming = new Pipe();

		local.outgoing = outgoing;
		remote.incoming = outgoing;

		local.incoming = incoming;
		remote.outgoing = incoming;

		local.peer = remote;
		remote.peer = local;