this._queue.push(msg);
this._socket.send(msg, function(x) {
_this.log(0x1, 'send: ' + msg + ':', x);
+ if (x.bytesWritten < 0) {
+ _this.log(0x1, 'reconnecting...');
+ _this._socket.reconnect();
+ _this.queue = [msg];
+ _this._socket.send(msg);
+ }
});
}
// seekid {SONGID} {TIME}
Mpc.prototype.seekid = Mpc.__make_send_arg2('seekid');
// seekcur {TIME}
-Mpc.prototype.seekcur = Mpc.__make_send_arg1('seek');
+Mpc.prototype.seekcur = Mpc.__make_send_arg1('seekcur');
// stop
Mpc.prototype.stop = Mpc.__make_send_void('stop');