}
// send request to notification manager
- int ret = res->publish_commit(this, ofs, target_obj->get_mtime(), etag, target_obj->get_instance());
+ int ret = res->publish_commit(this, ofs, upload->get_mtime(), etag, target_obj->get_instance());
if (ret < 0) {
ldpp_dout(this, 1) << "ERROR: publishing notification failed, with error: " << ret << dendl;
// too late to rollback operation, hence op_ret is not set here
assert_equal(len(events), 1)
assert_equal(events[0]['Records'][0]['eventName'], 'ObjectCreated:CompleteMultipartUpload')
assert_equal(events[0]['Records'][0]['s3']['configurationId'], notification_name+'_3')
- print(events[0]['Records'][0]['s3']['object']['size'])
+ assert_equal(events[0]['Records'][0]['s3']['object']['size'], object_size)
+ assert events[0]['Records'][0]['eventTime'] != '0.000000', 'invalid eventTime'
# cleanup
stop_amqp_receiver(receiver1, task1)