summaryrefslogtreecommitdiffstats
path: root/src/engine/ConnectionImpl.cpp
diff options
context:
space:
mode:
authorDavid Robillard <d@drobilla.net>2010-05-04 04:22:46 +0000
committerDavid Robillard <d@drobilla.net>2010-05-04 04:22:46 +0000
commita377fe171dd248f9418634f5f23d10a9440fd920 (patch)
treeaf17a5315a8c697d67fa8dbcb7695770345dc202 /src/engine/ConnectionImpl.cpp
parent5fcc724a4bcd9a8111a0a6d483e3d6dcbe97a2d5 (diff)
downloadingen-a377fe171dd248f9418634f5f23d10a9440fd920.tar.gz
ingen-a377fe171dd248f9418634f5f23d10a9440fd920.tar.bz2
ingen-a377fe171dd248f9418634f5f23d10a9440fd920.zip
Rename "object" extension "atom" extension.
git-svn-id: http://svn.drobilla.net/lad/trunk/ingen@2561 a436a847-0d15-0410-975c-d299462d15a1
Diffstat (limited to 'src/engine/ConnectionImpl.cpp')
-rw-r--r--src/engine/ConnectionImpl.cpp16
1 files changed, 8 insertions, 8 deletions
diff --git a/src/engine/ConnectionImpl.cpp b/src/engine/ConnectionImpl.cpp
index 495a97c2..942711c2 100644
--- a/src/engine/ConnectionImpl.cpp
+++ b/src/engine/ConnectionImpl.cpp
@@ -56,7 +56,7 @@ ConnectionImpl::ConnectionImpl(BufferFactory& bufs, PortImpl* src_port, PortImpl
assert(src_port->path() != dst_port->path());
if (must_queue())
- _queue = new Raul::RingBuffer<LV2_Object>(src_port->buffer_size() * 2);
+ _queue = new Raul::RingBuffer<LV2_Atom>(src_port->buffer_size() * 2);
}
@@ -75,12 +75,12 @@ ConnectionImpl::get_sources(Context& context, uint32_t voice,
IntrusivePtr<Buffer>* srcs, uint32_t max_num_srcs, uint32_t& num_srcs)
{
if (must_queue() && _queue->read_space() > 0) {
- LV2_Object obj;
- _queue->peek(sizeof(LV2_Object), &obj);
+ LV2_Atom obj;
+ _queue->peek(sizeof(LV2_Atom), &obj);
IntrusivePtr<Buffer> buf = context.engine().buffer_factory()->get(
- dst_port()->buffer_type(), sizeof(LV2_Object) + obj.size);
+ dst_port()->buffer_type(), sizeof(LV2_Atom) + obj.size);
void* data = buf->port_data(PortType::MESSAGE, context.offset());
- _queue->full_read(sizeof(LV2_Object) + obj.size, (LV2_Object*)data);
+ _queue->full_read(sizeof(LV2_Atom) + obj.size, (LV2_Atom*)data);
srcs[num_srcs++] = buf;
} else if (must_mix()) {
// Mixing down voices: every src voice mixed into every dst voice
@@ -110,15 +110,15 @@ ConnectionImpl::queue(Context& context)
}
for (src_buf->rewind(); src_buf->is_valid(); src_buf->increment()) {
- LV2_Event* ev = src_buf->get_event();
- LV2_Object* obj = LV2_OBJECT_FROM_EVENT(ev);
+ LV2_Event* ev = src_buf->get_event();
+ LV2_Atom* obj = LV2_ATOM_FROM_EVENT(ev);
/*debug << _src_port->path() << " -> " << _dst_port->path()
<< " QUEUE OBJECT TYPE " << obj->type << ":";
for (size_t i = 0; i < obj->size; ++i)
debug << " " << std::hex << (int)obj->body[i];
debug << endl;*/
- _queue->write(sizeof(LV2_Object) + obj->size, obj);
+ _queue->write(sizeof(LV2_Atom) + obj->size, obj);
context.engine().message_context()->run(_dst_port, context.start() + ev->frames);
}
}