dc50f92 · opencog-atomspace-storage · pear-git-v3

Overview Files Commits Issues Docs Releases Peers

opencog-atomspace-storage commits / dc50f92

The proxies must have smart pointer, not bare

dc50f92cf638f552f4ca2fc252b42864907e1481

by Linas Vepstas <linasvepstas@gmail.com> · 2026-01-18T23:09:27.000Z

Changed files (4) +9 -5

opencog/persist/proxy/ReadThruProxy.cc +2 -1

…	…	@@ -58,8 +58,9 @@ void ReadThruProxy::open(void)
58	58	StorageNodeSeq rdrs = setup();
59	59	_readers.swap(rdrs);
60	60
	61	AtomSpacePtr target = AtomSpaceCast(_target_as->shared_from_this());
61	62	for (const StorageNodePtr& stnp :_readers)
62		stnp->setValue(_open_msg, _target_as);
	63	stnp->setValue(_open_msg, target);
63	64	}
64	65
65	66	void ReadThruProxy::close(void)

opencog/persist/proxy/ReadWriteProxy.cc +3 -2

…	…	@@ -69,8 +69,9 @@ void ReadWriteProxy::open(void)
69	69	_reader = rwpair[0];
70	70	_writer = rwpair[1];
71	71
72		_reader->setValue(_open_msg, _target_as);
73		_writer->setValue(_open_msg, _target_as);
	72	AtomSpacePtr target = AtomSpaceCast(_target_as->shared_from_this());
	73	_reader->setValue(_open_msg, target);
	74	_writer->setValue(_open_msg, target);
74	75	}
75	76
76	77	void ReadWriteProxy::close(void)

opencog/persist/proxy/SequentialReadProxy.cc +2 -1

…	…	@@ -56,8 +56,9 @@ void SequentialReadProxy::open(void)
56	56	StorageNodeSeq rdrs = setup();
57	57	_readers.swap(rdrs);
58	58
	59	AtomSpacePtr target = AtomSpaceCast(_target_as->shared_from_this());
59	60	for (const StorageNodePtr& stnp :_readers)
60		stnp->setValue(_open_msg, _target_as);
	61	stnp->setValue(_open_msg, target);
61	62	}
62	63
63	64	void SequentialReadProxy::close(void)

opencog/persist/proxy/WriteThruProxy.cc +2 -1

…	…	@@ -55,8 +55,9 @@ void WriteThruProxy::open(void)
55	55	StorageNodeSeq sns = setup();
56	56	_targets.swap(sns);
57	57
	58	AtomSpacePtr target = AtomSpaceCast(_target_as->shared_from_this());
58	59	for (const StorageNodePtr& stnp : _targets)
59		stnp->setValue(_open_msg, _target_as);
	60	stnp->setValue(_open_msg, target);
60	61	}
61	62
62	63	void WriteThruProxy::close(void)