int rados_write(rados_pool_t pool, const char *oid, off_t off, const char *buf, size_t len);
int rados_read(rados_pool_t pool, const char *oid, off_t off, char *buf, size_t len);
int rados_remove(rados_pool_t pool, const char *oid);
-int rados_exec(rados_pool_t pool, const char *o, const char *cls, const char *method,
+int rados_exec(rados_pool_t pool, const char *oid, const char *cls, const char *method,
const char *in_buf, size_t in_len, char *buf, size_t out_len);
/* async io */
int open_pool(const char *name, rados_pool_t *pool);
int close_pool(rados_pool_t pool);
- int write(rados_pool_t pool, object_t& oid, off_t off, bufferlist& bl, size_t len);
- int read(rados_pool_t pool, object_t& oid, off_t off, bufferlist& bl, size_t len);
- int remove(rados_pool_t pool, object_t& oid);
+ int write(rados_pool_t pool, const object_t& oid, off_t off, bufferlist& bl, size_t len);
+ int read(rados_pool_t pool, const object_t& oid, off_t off, bufferlist& bl, size_t len);
+ int remove(rados_pool_t pool, const object_t& oid);
- int exec(rados_pool_t pool, object_t& oid, const char *cls, const char *method,
+ int exec(rados_pool_t pool, const object_t& oid, const char *cls, const char *method,
bufferlist& inbl, bufferlist& outbl);
void put();
};
- int aio_read(int pool, object_t oid, off_t off, bufferlist *pbl, size_t len,
+ int aio_read(int pool, const object_t& oid, off_t off, bufferlist *pbl, size_t len,
AioCompletion **pc);
- int aio_write(int pool, object_t oid, off_t off, bufferlist& bl, size_t len,
+ int aio_write(int pool, const object_t& oid, off_t off, bufferlist& bl, size_t len,
AioCompletion **pc);
};
return osdmap.lookup_pg_pool_name(name);
}
- int write(int pool, object_t& oid, off_t off, bufferlist& bl, size_t len);
- int read(int pool, object_t& oid, off_t off, bufferlist& bl, size_t len);
- int remove(int pool, object_t& oid);
+ int write(int pool, const object_t& oid, off_t off, bufferlist& bl, size_t len);
+ int read(int pool, const object_t& oid, off_t off, bufferlist& bl, size_t len);
+ int remove(int pool, const object_t& oid);
- int exec(int pool, object_t& oid, const char *cls, const char *method, bufferlist& inbl, bufferlist& outbl);
+ int exec(int pool, const object_t& oid, const char *cls, const char *method, bufferlist& inbl, bufferlist& outbl);
// --- aio ---
return true;
}
-int RadosClient::write(int pool, object_t& oid, off_t off, bufferlist& bl, size_t len)
+int RadosClient::write(int pool, const object_t& oid, off_t off, bufferlist& bl, size_t len)
{
SnapContext snapc;
utime_t ut = g_clock.now();
return len;
}
-int RadosClient::aio_read(int pool, object_t oid, off_t off, bufferlist *pbl, size_t len,
+int RadosClient::aio_read(int pool, const object_t oid, off_t off, bufferlist *pbl, size_t len,
AioCompletion **pc)
{
AioCompletion *c = new AioCompletion;
*pc = c;
return 0;
}
-int RadosClient::aio_read(int pool, object_t oid, off_t off, char *buf, size_t len,
+int RadosClient::aio_read(int pool, const object_t oid, off_t off, char *buf, size_t len,
AioCompletion **pc)
{
AioCompletion *c = new AioCompletion;
return 0;
}
-int RadosClient::aio_write(int pool, object_t oid, off_t off, const bufferlist& bl, size_t len,
+int RadosClient::aio_write(int pool, const object_t oid, off_t off, const bufferlist& bl, size_t len,
AioCompletion **pc)
{
SnapContext snapc;
return 0;
}
-int RadosClient::remove(int pool, object_t& oid)
+int RadosClient::remove(int pool, const object_t& oid)
{
SnapContext snapc;
utime_t ut = g_clock.now();
return r;
}
-int RadosClient::exec(int pool, object_t& oid, const char *cls, const char *method,
+int RadosClient::exec(int pool, const object_t& oid, const char *cls, const char *method,
bufferlist& inbl, bufferlist& outbl)
{
SnapContext snapc;
return r;
}
-int RadosClient::read(int pool, object_t& oid, off_t off, bufferlist& bl, size_t len)
+int RadosClient::read(int pool, const object_t& oid, off_t off, bufferlist& bl, size_t len)
{
SnapContext snapc;
return client->init();
}
-int Rados::write(rados_pool_t pool, object_t& oid, off_t off, bufferlist& bl, size_t len)
+int Rados::write(rados_pool_t pool, const object_t& oid, off_t off, bufferlist& bl, size_t len)
{
if (!client)
return -EINVAL;
return client->write(pool, oid, off, bl, len);
}
-int Rados::remove(rados_pool_t pool, object_t& oid)
+int Rados::remove(rados_pool_t pool, const object_t& oid)
{
if (!client)
return -EINVAL;
return client->remove(pool, oid);
}
-int Rados::read(rados_pool_t pool, object_t& oid, off_t off, bufferlist& bl, size_t len)
+int Rados::read(rados_pool_t pool, const object_t& oid, off_t off, bufferlist& bl, size_t len)
{
if (!client)
return -EINVAL;
return client->read(pool, oid, off, bl, len);
}
-int Rados::exec(rados_pool_t pool, object_t& oid, const char *cls, const char *method,
+int Rados::exec(rados_pool_t pool, const object_t& oid, const char *cls, const char *method,
bufferlist& inbl, bufferlist& outbl)
{
if (!client)
return 0;
}
-int Rados::aio_read(int pool, object_t oid, off_t off, bufferlist *pbl, size_t len,
+int Rados::aio_read(int pool, const object_t& oid, off_t off, bufferlist *pbl, size_t len,
Rados::AioCompletion **pc)
{
RadosClient::AioCompletion *c;
return r;
}
-int Rados::aio_write(int pool, object_t oid, off_t off, bufferlist& bl, size_t len,
+int Rados::aio_write(int pool, const object_t& oid, off_t off, bufferlist& bl, size_t len,
AioCompletion **pc)
{
RadosClient::AioCompletion *c;