Function updDocument

graphdb.js:1164–1248

(self)

}

function updDocument(self) {

	if (!self.ready || self.states.update || !self.pending.update.length || F.isKilled)
		return;

	var upd = self.pending.update.shift();
	if (upd) {
		self.states.update = true;

		var offset = offsetDocument(self, upd.id);
		var buf = U.createBufferSize(self.header.documentsize);

		Fs.read(self.fd, buf, 0, buf.length, offset, function(err, size) {

			if (err) {
				self.states.update = false;
				upd.callback(err);
				setImmediate(self.cb_next, NEXT_UPDATE);
				return;
			}

			if (!size) {
				upd.callback(null, 0);
				self.states.update = false;
				setImmediate(self.cb_next, NEXT_UPDATE);
				return;
			}

			var save = function(err) {
				self.states.update = false;
				!err && Fs.write(self.fd, buf, 0, buf.length, offset, self.cb_error);
				upd.callback(err, err ? 0 : 1);
				setImmediate(self.cb_next, NEXT_UPDATE);
			};

			var data = buf.slice(DATAOFFSET, buf.readUInt16LE(15) + DATAOFFSET);
			var limit = self.header.documentsize - DATAOFFSET;
			var schema = self.$classes[buf[1]].schema;
			var doc;

			if (buf[2] === STATE_COMPRESSED) {
				Zlib.inflate(data, ZLIBOPTIONS, function(err, buffer) {
					doc = parseData(schema, buffer.toString('utf8').split('|'));
					buffer = U.createBuffer(stringifyData(schema, upd.fn(doc, upd.value)));
					if (buffer.length > limit) {
						Zlib.deflate(buffer, ZLIBOPTIONS, function(err, buffer) {
							if (buffer.length <= limit) {
								buf.writeUInt16LE(buffer.length, 15);
								buf.writeUInt8(STATE_COMPRESSED, 2);
								buffer.copy(buf, DATAOFFSET);
								save();
							} else
								save(new Error('GraphDB: Data too long'));
						});
					} else {
						buf.writeUInt16LE(buffer.length, 15);
						buf.writeUInt8(STATE_UNCOMPRESSED, 2);
						buffer.copy(buf, DATAOFFSET);