bb36031 · opencog-atomspace-cog

Changed files (2) +3 -18

opencog/persist/cog-simple/CogSimpleIO.cc +0 -12

…	…	@@ -94,9 +94,6 @@ void CogSimpleStorage::storeAtom(const Handle& h, bool synchronous)
94	94
95	95	std::lock_guard<std::mutex> lck(_mtx);
96	96	do_send(msg);
97
98		// Flush the response.
99		do_recv();
100	97	}
101	98
102	99	void CogSimpleStorage::storeValue(const Handle& h, const Handle& key)
…	…	@@ -114,9 +111,6 @@ void CogSimpleStorage::storeValue(const Handle& h, const Handle& key)
114	111
115	112	std::lock_guard<std::mutex> lck(_mtx);
116	113	do_send(msg);
117
118		// Flush the response.
119		do_recv();
120	114	}
121	115
122	116	void CogSimpleStorage::updateValue(const Handle& h, const Handle& key,
…	…	@@ -135,9 +129,6 @@ void CogSimpleStorage::updateValue(const Handle& h, const Handle& key,
135	129
136	130	std::lock_guard<std::mutex> lck(_mtx);
137	131	do_send(msg);
138
139		// Flush the response.
140		do_recv();
141	132	}
142	133
143	134	void CogSimpleStorage::loadValue(const Handle& h, const Handle& key)
…	…	@@ -379,9 +370,6 @@ std::string CogSimpleStorage::writeFrame(const Handle& hasp)
379	370	{
380	371	std::lock_guard<std::mutex> lck(_mtx);
381	372	do_send(msg);
382
383		// Flush the response.
384		do_recv();
385	373	}
386	374
387	375	// Store short-forms

opencog/persist/cog-storage/CogIO.cc +3 -6

…	…	@@ -91,8 +91,7 @@ void CogStorage::storeAtom(const Handle& h, bool synchronous)
91	91	msg = "(cog-set-value! " + Sexpr::encode_atom(h) +
92	92	"(Predicate \"-TruthValueKey-\") #f)\n";
93	93
94		Pkt pkt;
95		_io_queue.enqueue(this, msg, pkt, &CogStorage::noop_const);
	94	_io_queue.enqueue_noreply(msg);
96	95	}
97	96
98	97	void CogStorage::removeAtom(AtomSpace* frame, const Handle& h, bool recursive)
…	…	@@ -116,8 +115,7 @@ void CogStorage::storeValue(const Handle& h, const Handle& key)
116	115	Sexpr::encode_atom(key) +
117	116	Sexpr::encode_value(h->getValue(key)) + ")\n";
118	117
119		Pkt pkt;
120		_io_queue.enqueue(this, msg, pkt, &CogStorage::noop_const);
	118	_io_queue.enqueue_noreply(msg);
121	119	}
122	120
123	121	void CogStorage::updateValue(const Handle& h, const Handle& key,
…	…	@@ -129,8 +127,7 @@ void CogStorage::updateValue(const Handle& h, const Handle& key,
129	127	Sexpr::encode_atom(key) +
130	128	Sexpr::encode_value(delta) + ")\n";
131	129
132		Pkt pkt;
133		_io_queue.enqueue(this, msg, pkt, &CogStorage::noop_const);
	130	_io_queue.enqueue_noreply(msg);
134	131	}
135	132
136	133	void CogStorage::loadValue(const Handle& h, const Handle& key)