g_return_val_if_fail(buf != NULL, PARAM_CHECK_ERRNO);
g_return_val_if_fail(fi != NULL, PARAM_CHECK_ERRNO);
- cfs_debug("enter cfs_plug_base_read %s %lu %ld", path, size, offset);
+ cfs_debug("enter cfs_plug_base_read %s %zu %jd", path, size, offset);
int ret = -EACCES;
g_return_val_if_fail(buf != NULL, PARAM_CHECK_ERRNO);
g_return_val_if_fail(fi != NULL, PARAM_CHECK_ERRNO);
- cfs_debug("enter cfs_plug_base_write %s %lu %ld", path, size, offset);
+ cfs_debug("enter cfs_plug_base_write %s %zu %jd", path, size, offset);
int ret = -EACCES;
g_return_val_if_fail(plug->ops == &cfs_ops, PARAM_CHECK_ERRNO);
g_return_val_if_fail(path != NULL, PARAM_CHECK_ERRNO);
- cfs_debug("enter cfs_plug_base_truncate %s %ld", path, size);
+ cfs_debug("enter cfs_plug_base_truncate %s %jd", path, size);
int ret = -EACCES;
#endif /* HAVE_CONFIG_H */
#include <stdlib.h>
+#include <inttypes.h>
#include <stdio.h>
#include <string.h>
#include <unistd.h>
{
int rc;
- cfs_debug("enter backend_write_inode %016zX", inode);
+ cfs_debug("enter backend_write_inode %016" PRIX64, inode);
if ((rc = sqlite3_bind_int64(stmt, 1, inode)) != SQLITE_OK) {
cfs_critical("sqlite3_bind failed: %s\n", sqlite3_errmsg(db));
goto rollback;
if (sqlite3_changes(bdb->db) != 1) {
- cfs_critical("no such inode %016zX", inode);
+ cfs_critical("no such inode %016" PRIX64, inode);
goto rollback;
}
}
const char *name = (const char *)sqlite3_column_text(stmt, 6);
int namelen = sqlite3_column_bytes(stmt, 6);
if (name == NULL || namelen == 0) {
- cfs_critical("inode has no name (inode = %016zX)", inode);
+ cfs_critical("inode has no name (inode = %016" PRIX64 ")", inode);
goto fail;
}
te = g_malloc0(sizeof(memdb_tree_entry_t) + namelen + 1);
te->data.value = g_memdup(value, size);
} else if (te->type == DT_DIR) {
if (size) {
- cfs_critical("directory inode contains data (inode = %016zX)",
+ cfs_critical("directory inode contains data (inode = %016" PRIX64 ")",
te->inode);
g_free(te);
goto fail;
}
te->data.entries = NULL;
} else {
- cfs_critical("inode has unknown type (inode = %016zX, type = %d)",
+ cfs_critical("inode has unknown type (inode = %016" PRIX64 ", type = %d)",
te->inode, te->type);
g_free(te);
goto fail;
}
- cfs_debug("name %s (inode = %016zX, parent = %016zX)",
+ cfs_debug("name %s (inode = %016" PRIX64 ", parent = %016" PRIX64 ")",
te->name, te->inode, te->parent);
if (te->inode == 0) {
} else if (!(pte->type == DT_DIR || pte->type == 0)) {
cfs_critical("parent is not a directory "
- "(inode = %016zX, parent = %016zX, name = '%s')",
+ "(inode = %016" PRIX64 ", parent = %016" PRIX64 ", name = '%s')",
te->inode, te->parent, te->name);
memdb_tree_entry_free(te);
goto fail;
if ((tmpte = g_hash_table_lookup(index, &te->inode))) {
if (tmpte->type != 0) {
cfs_critical("found strange placeholder for "
- "(inode = %016zX, parent = %016zX, name = '%s', type = '%d')",
+ "(inode = %016" PRIX64 ", parent = %016" PRIX64 ", name = '%s', type = '%d')",
te->inode, te->parent, te->name, tmpte->type);
memdb_tree_entry_free(te);
goto fail;
if (g_hash_table_lookup(pte->data.entries, te->name)) {
cfs_critical("found entry with duplicate name "
- "(inode = %016zX, parent = %016zX, name = '%s')",
+ "(inode = %016" PRIX64 ", parent = %016" PRIX64 ", name = '%s')",
te->inode, te->parent, te->name);
goto fail;
}
while (g_hash_table_iter_next (&iter, &key, &value)) {
memdb_tree_entry_t *te = (memdb_tree_entry_t *)value;
if (te->type == 0) {
- cfs_critical("missing directory inode (inode = %016zX)", te->inode);
+ cfs_critical("missing directory inode (inode = %016" PRIX64 ")", te->inode);
goto fail;
}
}
if (bdb_backend_delete_inode(bdb, slave_inode) != SQLITE_OK)
goto abort;
- cfs_debug("deleted inode %016zX", slave_inode);
+ cfs_debug("deleted inode %016" PRIX64, slave_inode);
}
j++;
}
if (bdb_backend_delete_inode(bdb, slave_inode) != SQLITE_OK)
goto abort;
- cfs_debug("deleted inode %016zX", slave_inode);
+ cfs_debug("deleted inode %016" PRIX64, slave_inode);
j++;
}
#include <stdlib.h>
#include <stdio.h>
+#include <inttypes.h>
#include <string.h>
#include <unistd.h>
#include <glib.h>
g_return_val_if_fail(csum != NULL, FALSE);
if (msg_len < 33) {
- cfs_critical("received short unlock message (%lu < 33)", msg_len);
+ cfs_critical("received short unlock message (%zu < 33)", msg_len);
return FALSE;
}
g_return_val_if_fail(flags != NULL, FALSE);
if (msg_len < 20) {
- cfs_critical("received short fuse message (%lu < 20)", msg_len);
+ cfs_critical("received short fuse message (%zu < 20)", msg_len);
return FALSE;
}
if (!atomic_write_file(HOST_CLUSTER_CONF_FN, data, len, 0644, 0))
goto ret;
- cfs_message("wrote new corosync config '%s' (version = %zd)",
+ cfs_message("wrote new corosync config '%s' (version = %" G_GUINT64_FORMAT ")",
HOST_CLUSTER_CONF_FN, new_version);
if (notify_corosync && old_version) {
g_return_val_if_fail(memdb->root != NULL, FALSE);
- cfs_debug("enter %s %016zX %08X", __func__, memdb->root->version, memdb->root->mtime);
+ cfs_debug("enter %s %016" PRIX64 " %08X", __func__, (uint64_t) memdb->root->version, memdb->root->mtime);
g_mutex_lock (&memdb->mutex);
memdb_index_t *idx = memdb_encode_index(memdb->index, memdb->root);
if (g_hash_table_lookup(updates, &inode))
continue;
- cfs_debug("found different inode %d %016zX", i, inode);
+ cfs_debug("found different inode %d %016" PRIX64, i, (uint64_t) inode);
memdb_tree_entry_t *te, *cpy;
if (!(te = g_hash_table_lookup(memdb->index, &inode))) {
- cfs_critical("can get inode data for inode %016zX", inode);
+ cfs_critical("can get inode data for inode %016" PRIX64, (uint64_t) inode);
goto ret;
}
if (!dcdb_send_update_inode(dfsm, te)) {
/* tolerate error here */
- cfs_critical("sending update inode failed %016zX", te->inode);
+ cfs_critical("sending update inode failed %016" PRIX64, (uint64_t) te->inode);
} else {
- cfs_debug("sent update inode %016zX", te->inode);
+ cfs_debug("sent update inode %016" PRIX64, (uint64_t) te->inode);
}
memdb_tree_entry_free(te);
if (!(te = dcdb_parse_update_inode(msg, msg_len)))
return -1;
- cfs_debug("received inode update %016zX from node %d",
- te->inode, nodeid);
+ cfs_debug("received inode update %016" PRIX64 " from node %d",
+ (uint64_t) te->inode, nodeid);
dcdb_sync_info_t *localsi = (dcdb_sync_info_t *)syncinfo->data;
g_return_val_if_fail(memdb != NULL, FALSE);
- cfs_debug("enter %s %016zX %08X", __func__, memdb->root->version, memdb->root->mtime);
+ cfs_debug("enter %s %016" PRIX64 " %08X", __func__, memdb->root->version, memdb->root->mtime);
g_mutex_lock (&memdb->mutex);
gboolean res = memdb_compute_checksum(memdb->index, memdb->root, csum, csum_len);
g_mutex_unlock (&memdb->mutex);
- cfs_debug("leave %s %016zX (%d)", __func__, *(uint64_t *)csum, res);
+ cfs_debug("leave %s %016" PRIX64 " (%d)", __func__, *( (uint64_t *) csum), res);
return res;
}
if (!DCDB_VALID_MESSAGE_TYPE(msg_type))
goto unknown;
- cfs_debug("process message %d (length = %ld)", msg_type, msg_len);
+ cfs_debug("process message %u (length = %zd)", msg_type, msg_len);
if (!cfs_is_quorate()) {
cfs_critical("received write while not quorate - trigger resync");
return res;
unknown:
- cfs_critical("received unknown message type (msg_type == %d)", msg_type);
+ cfs_critical("received unknown message type (msg_type == %u)", msg_type);
leave:
res = -1;
goto ret;
#endif /* HAVE_CONFIG_H */
#include <sys/types.h>
+#include <inttypes.h>
#include <unistd.h>
#include <string.h>
#include <stdlib.h>
}
if (msg_len < sizeof(dfsm_message_header_t)) {
- cfs_dom_critical(dfsm->log_domain, "received short message (%ld bytes)", msg_len);
+ cfs_dom_critical(dfsm->log_domain, "received short message (%zd bytes)", msg_len);
goto leave;
}
dfsm_message_normal_header_t *header = (dfsm_message_normal_header_t *)msg;
if (msg_len < sizeof(dfsm_message_normal_header_t)) {
- cfs_dom_critical(dfsm->log_domain, "received short message (type = %d, subtype = %d, %ld bytes)",
+ cfs_dom_critical(dfsm->log_domain, "received short message (type = %d, subtype = %d, %zd bytes)",
base_header->type, base_header->subtype, msg_len);
goto leave;
}
if (mode != DFSM_MODE_SYNCED) {
- cfs_dom_debug(dfsm->log_domain, "queue message %zu (subtype = %d, length = %ld)",
+ cfs_dom_debug(dfsm->log_domain, "queue message %" PRIu64 " (subtype = %d, length = %zd)",
header->count, base_header->subtype, msg_len);
if (!dfsm_queue_add_message(dfsm, nodeid, pid, header->count, msg, msg_len))
dfsm_message_state_header_t *header = (dfsm_message_state_header_t *)msg;
if (msg_len < sizeof(dfsm_message_state_header_t)) {
- cfs_dom_critical(dfsm->log_domain, "received short state message (type = %d, subtype = %d, %ld bytes)",
+ cfs_dom_critical(dfsm->log_domain, "received short state message (type = %d, subtype = %d, %zd bytes)",
base_header->type, base_header->subtype, msg_len);
goto leave;
}
} else if (base_header->type == DFSM_MESSAGE_VERIFY_REQUEST) {
if (msg_len != sizeof(dfsm->csum_counter)) {
- cfs_dom_critical(dfsm->log_domain, "cpg received verify request with wrong length (%ld bytes) form node %d/%d", msg_len, nodeid, pid);
+ cfs_dom_critical(dfsm->log_domain, "cpg received verify request with wrong length (%zd bytes) form node %d/%d", msg_len, nodeid, pid);
goto leave;
}
uint64_t csum_id = *((uint64_t *)msg);
msg += 8; msg_len -= 8;
- cfs_dom_debug(dfsm->log_domain, "got verify request from node %d %016zX", nodeid, csum_id);
+ cfs_dom_debug(dfsm->log_domain, "got verify request from node %d %016" PRIX64, nodeid, csum_id);
if (dfsm->dfsm_callbacks->dfsm_checksum_fn) {
if (!dfsm->dfsm_callbacks->dfsm_checksum_fn(
if (dfsm->dfsm_callbacks->dfsm_checksum_fn) {
if (msg_len != (sizeof(dfsm->csum_id) + sizeof(dfsm->csum))) {
- cfs_dom_critical(dfsm->log_domain, "cpg received verify message with wrong length (%ld bytes)", msg_len);
+ cfs_dom_critical(dfsm->log_domain, "cpg received verify message with wrong length (%zd bytes)", msg_len);
goto leave;
}
if (dfsm->csum_id == csum_id &&
(memcmp(&dfsm->csum_epoch, &header->epoch, sizeof(dfsm_sync_epoch_t)) == 0)) {
if (memcmp(msg, dfsm->csum, sizeof(dfsm->csum)) != 0) {
- cfs_dom_critical(dfsm->log_domain, "wrong checksum %016zX != %016zX - restarting",
+ cfs_dom_critical(dfsm->log_domain, "wrong checksum %016" PRIX64 " != %016" PRIX64 " - restarting",
*(uint64_t *)msg, *(uint64_t *)dfsm->csum);
goto leave;
} else {
cfs_dom_debug(dfsm->log_domain, "ignore verify message %d while not synced", base_header->type);
} else {
- cfs_dom_critical(dfsm->log_domain, "received unknown state message type (type = %d, %ld bytes)",
+ cfs_dom_critical(dfsm->log_domain, "received unknown state message type (type = %d, %zd bytes)",
base_header->type, msg_len);
goto leave;
}
struct iovec iov[len];
if (dfsm->csum_counter != dfsm->csum_id) {
- g_message("delay verify request %016zX", dfsm->csum_counter + 1);
+ g_message("delay verify request %016" PRIX64, dfsm->csum_counter + 1);
return CS_OK;
};
iov[0].iov_base = (char *)&dfsm->csum_counter;
iov[0].iov_len = sizeof(dfsm->csum_counter);
- cfs_debug("send verify request %016zX", dfsm->csum_counter);
+ cfs_debug("send verify request %016" PRIX64, dfsm->csum_counter);
cs_error_t result;
result = dfsm_send_state_message_full(dfsm, DFSM_MESSAGE_VERIFY_REQUEST, iov, len);
#include <unistd.h>
#include <stdio.h>
+#include <inttypes.h>
#include <stdint.h>
#include <glib.h>
#include <string.h>
char tbuf[256];
strftime(tbuf, sizeof(tbuf), "%F %T", localtime(<));
printf("cpos %05d %08x %s", cpos, cur->uid, tbuf);
- printf(" %s{%016zX} %s[%s{%016zX}]: %s\n", node, cur->node_digest, tag, ident, cur->ident_digest, msg);
+ printf(" %s{%016" PRIX64 "} %s[%s{%016" PRIX64 "}]: %s\n", node, cur->node_digest, tag, ident, cur->ident_digest, msg);
}
#endif /* HAVE_CONFIG_H */
#include <stdio.h>
+#include <inttypes.h>
#include <stdlib.h>
#include <sys/types.h>
#include <sys/stat.h>
memdb_update_locks(memdb);
- cfs_debug("memdb open '%s' successful (version = %016zX)",
+ cfs_debug("memdb open '%s' successful (version = %016" PRIX64 ")",
dbfilename, memdb->root->version);
return memdb;
g_hash_table_replace(parent->data.entries, te->name, te);
g_hash_table_replace(memdb->index, &te->inode, te);
- cfs_debug("memdb_mkdir %s %s %016zX", dirname, base, memdb->root->version);
+ cfs_debug("memdb_mkdir %s %s %016" PRIX64, dirname, base, memdb->root->version);
if (bdb_backend_write(memdb->bdb, te->inode, te->parent, te->version,
te->writer, te->mtime, 0, DT_DIR, te->name, NULL, 0)) {
record_memdb_change(path);
- cfs_debug("memdb_pwrite %s %s %016zX %016zX", dirname, te->name, te->inode, te->version);
+ cfs_debug("memdb_pwrite %s %s %016" PRIX64 " %016" PRIX64, dirname, te->name, te->inode, te->version);
if (bdb_backend_write(memdb->bdb, te->inode, te->parent, te->version,
te->writer, te->mtime, te->size, te->type, te->name,
record_memdb_change(path);
- cfs_debug("memdb_mtime %s %s %016zX %016zX", dirname, te->name, te->inode, te->version);
+ cfs_debug("memdb_mtime %s %s %016" PRIX64 " %016" PRIX64, dirname, te->name, te->inode, te->version);
if (bdb_backend_write(memdb->bdb, te->inode, te->parent, te->version,
te->writer, te->mtime, te->size, te->type, te->name,
// same as tree_entry_print(), but use cfs_debug() instead of g_print()
- cfs_debug("%016zX %c %016zX %016zX %08X %08X %08X %s\n",
+ cfs_debug("%016" PRIX64 " %c %016" PRIX64 " %016" PRIX64 " %08X %08X %08X %s\n",
te->inode, te->type == DT_DIR ? 'D' : 'R', te->parent, te->version,
te->writer, te->mtime, te->size, te->name);
}
{
g_return_if_fail(te != NULL);
- g_print("%016zX %c %016zX %016zX %08X %08X %08X %s\n",
+ g_print("%016" PRIX64 " %c %016" PRIX64 " %016" PRIX64 " %08X %08X %08X %s\n",
te->inode, te->type == DT_DIR ? 'D' : 'R', te->parent, te->version,
te->writer, te->mtime, te->size, te->name);
}
{
g_return_if_fail(idx != NULL);
- g_print ("INDEX DUMP %016zX\n", idx->version);
+ g_print ("INDEX DUMP %016" PRIX64 "\n", idx->version);
int i;
for (i = 0; i < idx->size; i++) {
- g_print ("%016zX %016zX%016zX%016zX%016zX\n", idx->entries[i].inode,
+ g_print ("%016" PRIX64 " %016" PRIX64 "%016" PRIX64 "%016" PRIX64 "%016" PRIX64 "\n", idx->entries[i].inode,
*((guint64 *)idx->entries[i].digest),
*((guint64 *)(idx->entries[i].digest + 8)),
*((guint64 *)(idx->entries[i].digest + 16)),
{
(void) fi;
- cfs_debug("enter cfs_fuse_read %s %lu %ld", path, size, offset);
+ cfs_debug("enter cfs_fuse_read %s %zu %jd", path, size, offset);
int ret = -EACCES;
{
(void) fi;
- cfs_debug("enter cfs_fuse_write %s %lu %ld", path, size, offset);
+ cfs_debug("enter cfs_fuse_write %s %zu %jd", path, size, offset);
int ret = -EACCES;
static int cfs_fuse_truncate(const char *path, off_t size)
{
- cfs_debug("enter cfs_fuse_truncate %s %ld", path, size);
+ cfs_debug("enter cfs_fuse_truncate %s %jd", path, size);
int ret = -EACCES;
g_return_val_if_fail(msg != NULL, NULL);
if (msg_len < sizeof(clog_entry_t)) {
- cfs_critical("received short log message (%lu < %lu)", msg_len, sizeof(clog_entry_t));
+ cfs_critical("received short log message (%zu < %zu)", msg_len, sizeof(clog_entry_t));
return NULL;
}
entry->ident_len + entry->tag_len + entry->msg_len;
if (msg_len != size) {
- cfs_critical("received log message with wrong size (%lu != %u)", msg_len, size);
+ cfs_critical("received log message with wrong size (%zu != %u)", msg_len, size);
return NULL;
}
g_return_val_if_fail(len != NULL, FALSE);
if (msg_len < 256) {
- cfs_critical("received short kvstore message (%lu < 256)", msg_len);
+ cfs_critical("received short kvstore message (%zu < 256)", msg_len);
return FALSE;
}