diff --git a/devel/libzookeeper/Makefile b/devel/libzookeeper/Makefile index bceeced18820..018909b49a5c 100644 --- a/devel/libzookeeper/Makefile +++ b/devel/libzookeeper/Makefile @@ -1,34 +1,34 @@ # Created by: skreuzer@FreeBSD.org PORTNAME= zookeeper -PORTVERSION= 3.6.2 +PORTVERSION= 3.7.0 CATEGORIES= devel MASTER_SITES= APACHE/${PORTNAME}/${PORTNAME}-${PORTVERSION} PKGNAMEPREFIX= lib DISTNAME= apache-${PORTNAME}-${PORTVERSION} MAINTAINER= dmitry.wagin@ya.ru COMMENT= C client interface to Zookeeper server LICENSE= APACHE20 LICENSE_FILE= ${WRKSRC}/LICENSE LIB_DEPENDS= libcppunit.so:devel/cppunit USES= autoreconf libtool pkgconfig +USE_LDCONFIG= yes GNU_CONFIGURE= yes -USE_LDCONFIG= yes WRKSRC= ${WRKDIR}/${DISTNAME}/zookeeper-client/zookeeper-client-c post-extract: @${MKDIR} ${WRKSRC}/generated/ @cd ${FILESDIR} && ${CP} -p zookeeper.jute.* ${WRKSRC}/generated/ post-install: @${STRIP_CMD} ${STAGEDIR}${PREFIX}/bin/* ${STAGEDIR}${PREFIX}/lib/*.so ${LN} -sf libzookeeper_mt.so.2 ${STAGEDIR}${PREFIX}/lib/libzookeeper_mt.so ${LN} -sf libzookeeper_st.so.2 ${STAGEDIR}${PREFIX}/lib/libzookeeper_st.so .include diff --git a/devel/libzookeeper/distinfo b/devel/libzookeeper/distinfo index 5deb1db03ba3..d7909bd177a0 100644 --- a/devel/libzookeeper/distinfo +++ b/devel/libzookeeper/distinfo @@ -1,3 +1,3 @@ -TIMESTAMP = 1601308293 -SHA256 (apache-zookeeper-3.6.2.tar.gz) = 62d9e865a7b1da5e906ff39ebf40cfa1880303c04b4cf38e2c88d328bc2bcd6f -SIZE (apache-zookeeper-3.6.2.tar.gz) = 3372391 +TIMESTAMP = 1617193329 +SHA256 (apache-zookeeper-3.7.0.tar.gz) = cb3980f61b66babe550dcb717c940160ba813512c0aca26c2b8a718fac5d465d +SIZE (apache-zookeeper-3.7.0.tar.gz) = 3438672 diff --git a/devel/libzookeeper/files/zookeeper.jute.c b/devel/libzookeeper/files/zookeeper.jute.c index b8d0eae6c693..a68e2b7144f9 100644 --- a/devel/libzookeeper/files/zookeeper.jute.c +++ b/devel/libzookeeper/files/zookeeper.jute.c @@ -1,1622 +1,1704 @@ /** * Licensed to the Apache Software Foundation (ASF) under one * or more contributor license agreements. See the NOTICE file * distributed with this work for additional information * regarding copyright ownership. The ASF licenses this file * to you under the Apache License, Version 2.0 (the * "License"); you may not use this file except in compliance * with the License. You may obtain a copy of the License at * * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * See the License for the specific language governing permissions and * limitations under the License. */ #include #include "zookeeper.jute.h" int serialize_Id(struct oarchive *out, const char *tag, struct Id *v){ int rc; rc = out->start_record(out, tag); rc = rc ? rc : out->serialize_String(out, "scheme", &v->scheme); rc = rc ? rc : out->serialize_String(out, "id", &v->id); rc = rc ? rc : out->end_record(out, tag); return rc; } int deserialize_Id(struct iarchive *in, const char *tag, struct Id*v){ int rc; rc = in->start_record(in, tag); rc = rc ? rc : in->deserialize_String(in, "scheme", &v->scheme); rc = rc ? rc : in->deserialize_String(in, "id", &v->id); rc = rc ? rc : in->end_record(in, tag); return rc; } void deallocate_Id(struct Id*v){ deallocate_String(&v->scheme); deallocate_String(&v->id); } int serialize_ACL(struct oarchive *out, const char *tag, struct ACL *v){ int rc; rc = out->start_record(out, tag); rc = rc ? rc : out->serialize_Int(out, "perms", &v->perms); rc = rc ? rc : serialize_Id(out, "id", &v->id); rc = rc ? rc : out->end_record(out, tag); return rc; } int deserialize_ACL(struct iarchive *in, const char *tag, struct ACL*v){ int rc; rc = in->start_record(in, tag); rc = rc ? rc : in->deserialize_Int(in, "perms", &v->perms); rc = rc ? rc : deserialize_Id(in, "id", &v->id); rc = rc ? rc : in->end_record(in, tag); return rc; } void deallocate_ACL(struct ACL*v){ deallocate_Id(&v->id); } int serialize_Stat(struct oarchive *out, const char *tag, struct Stat *v){ int rc; rc = out->start_record(out, tag); rc = rc ? rc : out->serialize_Long(out, "czxid", &v->czxid); rc = rc ? rc : out->serialize_Long(out, "mzxid", &v->mzxid); rc = rc ? rc : out->serialize_Long(out, "ctime", &v->ctime); rc = rc ? rc : out->serialize_Long(out, "mtime", &v->mtime); rc = rc ? rc : out->serialize_Int(out, "version", &v->version); rc = rc ? rc : out->serialize_Int(out, "cversion", &v->cversion); rc = rc ? rc : out->serialize_Int(out, "aversion", &v->aversion); rc = rc ? rc : out->serialize_Long(out, "ephemeralOwner", &v->ephemeralOwner); rc = rc ? rc : out->serialize_Int(out, "dataLength", &v->dataLength); rc = rc ? rc : out->serialize_Int(out, "numChildren", &v->numChildren); rc = rc ? rc : out->serialize_Long(out, "pzxid", &v->pzxid); rc = rc ? rc : out->end_record(out, tag); return rc; } int deserialize_Stat(struct iarchive *in, const char *tag, struct Stat*v){ int rc; rc = in->start_record(in, tag); rc = rc ? rc : in->deserialize_Long(in, "czxid", &v->czxid); rc = rc ? rc : in->deserialize_Long(in, "mzxid", &v->mzxid); rc = rc ? rc : in->deserialize_Long(in, "ctime", &v->ctime); rc = rc ? rc : in->deserialize_Long(in, "mtime", &v->mtime); rc = rc ? rc : in->deserialize_Int(in, "version", &v->version); rc = rc ? rc : in->deserialize_Int(in, "cversion", &v->cversion); rc = rc ? rc : in->deserialize_Int(in, "aversion", &v->aversion); rc = rc ? rc : in->deserialize_Long(in, "ephemeralOwner", &v->ephemeralOwner); rc = rc ? rc : in->deserialize_Int(in, "dataLength", &v->dataLength); rc = rc ? rc : in->deserialize_Int(in, "numChildren", &v->numChildren); rc = rc ? rc : in->deserialize_Long(in, "pzxid", &v->pzxid); rc = rc ? rc : in->end_record(in, tag); return rc; } void deallocate_Stat(struct Stat*v){ } int serialize_StatPersisted(struct oarchive *out, const char *tag, struct StatPersisted *v){ int rc; rc = out->start_record(out, tag); rc = rc ? rc : out->serialize_Long(out, "czxid", &v->czxid); rc = rc ? rc : out->serialize_Long(out, "mzxid", &v->mzxid); rc = rc ? rc : out->serialize_Long(out, "ctime", &v->ctime); rc = rc ? rc : out->serialize_Long(out, "mtime", &v->mtime); rc = rc ? rc : out->serialize_Int(out, "version", &v->version); rc = rc ? rc : out->serialize_Int(out, "cversion", &v->cversion); rc = rc ? rc : out->serialize_Int(out, "aversion", &v->aversion); rc = rc ? rc : out->serialize_Long(out, "ephemeralOwner", &v->ephemeralOwner); rc = rc ? rc : out->serialize_Long(out, "pzxid", &v->pzxid); rc = rc ? rc : out->end_record(out, tag); return rc; } int deserialize_StatPersisted(struct iarchive *in, const char *tag, struct StatPersisted*v){ int rc; rc = in->start_record(in, tag); rc = rc ? rc : in->deserialize_Long(in, "czxid", &v->czxid); rc = rc ? rc : in->deserialize_Long(in, "mzxid", &v->mzxid); rc = rc ? rc : in->deserialize_Long(in, "ctime", &v->ctime); rc = rc ? rc : in->deserialize_Long(in, "mtime", &v->mtime); rc = rc ? rc : in->deserialize_Int(in, "version", &v->version); rc = rc ? rc : in->deserialize_Int(in, "cversion", &v->cversion); rc = rc ? rc : in->deserialize_Int(in, "aversion", &v->aversion); rc = rc ? rc : in->deserialize_Long(in, "ephemeralOwner", &v->ephemeralOwner); rc = rc ? rc : in->deserialize_Long(in, "pzxid", &v->pzxid); rc = rc ? rc : in->end_record(in, tag); return rc; } void deallocate_StatPersisted(struct StatPersisted*v){ } +int serialize_ClientInfo(struct oarchive *out, const char *tag, struct ClientInfo *v){ + int rc; + rc = out->start_record(out, tag); + rc = rc ? rc : out->serialize_String(out, "authScheme", &v->authScheme); + rc = rc ? rc : out->serialize_String(out, "user", &v->user); + rc = rc ? rc : out->end_record(out, tag); + return rc; +} +int deserialize_ClientInfo(struct iarchive *in, const char *tag, struct ClientInfo*v){ + int rc; + rc = in->start_record(in, tag); + rc = rc ? rc : in->deserialize_String(in, "authScheme", &v->authScheme); + rc = rc ? rc : in->deserialize_String(in, "user", &v->user); + rc = rc ? rc : in->end_record(in, tag); + return rc; +} +void deallocate_ClientInfo(struct ClientInfo*v){ + deallocate_String(&v->authScheme); + deallocate_String(&v->user); +} int serialize_ConnectRequest(struct oarchive *out, const char *tag, struct ConnectRequest *v){ int rc; rc = out->start_record(out, tag); rc = rc ? rc : out->serialize_Int(out, "protocolVersion", &v->protocolVersion); rc = rc ? rc : out->serialize_Long(out, "lastZxidSeen", &v->lastZxidSeen); rc = rc ? rc : out->serialize_Int(out, "timeOut", &v->timeOut); rc = rc ? rc : out->serialize_Long(out, "sessionId", &v->sessionId); rc = rc ? rc : out->serialize_Buffer(out, "passwd", &v->passwd); rc = rc ? rc : out->end_record(out, tag); return rc; } int deserialize_ConnectRequest(struct iarchive *in, const char *tag, struct ConnectRequest*v){ int rc; rc = in->start_record(in, tag); rc = rc ? rc : in->deserialize_Int(in, "protocolVersion", &v->protocolVersion); rc = rc ? rc : in->deserialize_Long(in, "lastZxidSeen", &v->lastZxidSeen); rc = rc ? rc : in->deserialize_Int(in, "timeOut", &v->timeOut); rc = rc ? rc : in->deserialize_Long(in, "sessionId", &v->sessionId); rc = rc ? rc : in->deserialize_Buffer(in, "passwd", &v->passwd); rc = rc ? rc : in->end_record(in, tag); return rc; } void deallocate_ConnectRequest(struct ConnectRequest*v){ deallocate_Buffer(&v->passwd); } int serialize_ConnectResponse(struct oarchive *out, const char *tag, struct ConnectResponse *v){ int rc; rc = out->start_record(out, tag); rc = rc ? rc : out->serialize_Int(out, "protocolVersion", &v->protocolVersion); rc = rc ? rc : out->serialize_Int(out, "timeOut", &v->timeOut); rc = rc ? rc : out->serialize_Long(out, "sessionId", &v->sessionId); rc = rc ? rc : out->serialize_Buffer(out, "passwd", &v->passwd); rc = rc ? rc : out->end_record(out, tag); return rc; } int deserialize_ConnectResponse(struct iarchive *in, const char *tag, struct ConnectResponse*v){ int rc; rc = in->start_record(in, tag); rc = rc ? rc : in->deserialize_Int(in, "protocolVersion", &v->protocolVersion); rc = rc ? rc : in->deserialize_Int(in, "timeOut", &v->timeOut); rc = rc ? rc : in->deserialize_Long(in, "sessionId", &v->sessionId); rc = rc ? rc : in->deserialize_Buffer(in, "passwd", &v->passwd); rc = rc ? rc : in->end_record(in, tag); return rc; } void deallocate_ConnectResponse(struct ConnectResponse*v){ deallocate_Buffer(&v->passwd); } int allocate_String_vector(struct String_vector *v, int32_t len) { if (!len) { v->count = 0; v->data = 0; } else { v->count = len; v->data = calloc(sizeof(*v->data), len); } return 0; } int deallocate_String_vector(struct String_vector *v) { if (v->data) { int32_t i; for(i=0;icount; i++) { deallocate_String(&v->data[i]); } free(v->data); v->data = 0; } return 0; } int serialize_String_vector(struct oarchive *out, const char *tag, struct String_vector *v) { int32_t count = v->count; int rc = 0; int32_t i; rc = out->start_vector(out, tag, &count); for(i=0;icount;i++) { rc = rc ? rc : out->serialize_String(out, "data", &v->data[i]); } rc = rc ? rc : out->end_vector(out, tag); return rc; } int deserialize_String_vector(struct iarchive *in, const char *tag, struct String_vector *v) { int rc = 0; int32_t i; rc = in->start_vector(in, tag, &v->count); v->data = calloc(v->count, sizeof(*v->data)); for(i=0;icount;i++) { rc = rc ? rc : in->deserialize_String(in, "value", &v->data[i]); } rc = in->end_vector(in, tag); return rc; } int serialize_SetWatches(struct oarchive *out, const char *tag, struct SetWatches *v){ int rc; rc = out->start_record(out, tag); rc = rc ? rc : out->serialize_Long(out, "relativeZxid", &v->relativeZxid); rc = rc ? rc : serialize_String_vector(out, "dataWatches", &v->dataWatches); rc = rc ? rc : serialize_String_vector(out, "existWatches", &v->existWatches); rc = rc ? rc : serialize_String_vector(out, "childWatches", &v->childWatches); rc = rc ? rc : out->end_record(out, tag); return rc; } int deserialize_SetWatches(struct iarchive *in, const char *tag, struct SetWatches*v){ int rc; rc = in->start_record(in, tag); rc = rc ? rc : in->deserialize_Long(in, "relativeZxid", &v->relativeZxid); rc = rc ? rc : deserialize_String_vector(in, "dataWatches", &v->dataWatches); rc = rc ? rc : deserialize_String_vector(in, "existWatches", &v->existWatches); rc = rc ? rc : deserialize_String_vector(in, "childWatches", &v->childWatches); rc = rc ? rc : in->end_record(in, tag); return rc; } void deallocate_SetWatches(struct SetWatches*v){ deallocate_String_vector(&v->dataWatches); deallocate_String_vector(&v->existWatches); deallocate_String_vector(&v->childWatches); } int serialize_SetWatches2(struct oarchive *out, const char *tag, struct SetWatches2 *v){ int rc; rc = out->start_record(out, tag); rc = rc ? rc : out->serialize_Long(out, "relativeZxid", &v->relativeZxid); rc = rc ? rc : serialize_String_vector(out, "dataWatches", &v->dataWatches); rc = rc ? rc : serialize_String_vector(out, "existWatches", &v->existWatches); rc = rc ? rc : serialize_String_vector(out, "childWatches", &v->childWatches); rc = rc ? rc : serialize_String_vector(out, "persistentWatches", &v->persistentWatches); rc = rc ? rc : serialize_String_vector(out, "persistentRecursiveWatches", &v->persistentRecursiveWatches); rc = rc ? rc : out->end_record(out, tag); return rc; } int deserialize_SetWatches2(struct iarchive *in, const char *tag, struct SetWatches2*v){ int rc; rc = in->start_record(in, tag); rc = rc ? rc : in->deserialize_Long(in, "relativeZxid", &v->relativeZxid); rc = rc ? rc : deserialize_String_vector(in, "dataWatches", &v->dataWatches); rc = rc ? rc : deserialize_String_vector(in, "existWatches", &v->existWatches); rc = rc ? rc : deserialize_String_vector(in, "childWatches", &v->childWatches); rc = rc ? rc : deserialize_String_vector(in, "persistentWatches", &v->persistentWatches); rc = rc ? rc : deserialize_String_vector(in, "persistentRecursiveWatches", &v->persistentRecursiveWatches); rc = rc ? rc : in->end_record(in, tag); return rc; } void deallocate_SetWatches2(struct SetWatches2*v){ deallocate_String_vector(&v->dataWatches); deallocate_String_vector(&v->existWatches); deallocate_String_vector(&v->childWatches); deallocate_String_vector(&v->persistentWatches); deallocate_String_vector(&v->persistentRecursiveWatches); } int serialize_RequestHeader(struct oarchive *out, const char *tag, struct RequestHeader *v){ int rc; rc = out->start_record(out, tag); rc = rc ? rc : out->serialize_Int(out, "xid", &v->xid); rc = rc ? rc : out->serialize_Int(out, "type", &v->type); rc = rc ? rc : out->end_record(out, tag); return rc; } int deserialize_RequestHeader(struct iarchive *in, const char *tag, struct RequestHeader*v){ int rc; rc = in->start_record(in, tag); rc = rc ? rc : in->deserialize_Int(in, "xid", &v->xid); rc = rc ? rc : in->deserialize_Int(in, "type", &v->type); rc = rc ? rc : in->end_record(in, tag); return rc; } void deallocate_RequestHeader(struct RequestHeader*v){ } int serialize_MultiHeader(struct oarchive *out, const char *tag, struct MultiHeader *v){ int rc; rc = out->start_record(out, tag); rc = rc ? rc : out->serialize_Int(out, "type", &v->type); rc = rc ? rc : out->serialize_Bool(out, "done", &v->done); rc = rc ? rc : out->serialize_Int(out, "err", &v->err); rc = rc ? rc : out->end_record(out, tag); return rc; } int deserialize_MultiHeader(struct iarchive *in, const char *tag, struct MultiHeader*v){ int rc; rc = in->start_record(in, tag); rc = rc ? rc : in->deserialize_Int(in, "type", &v->type); rc = rc ? rc : in->deserialize_Bool(in, "done", &v->done); rc = rc ? rc : in->deserialize_Int(in, "err", &v->err); rc = rc ? rc : in->end_record(in, tag); return rc; } void deallocate_MultiHeader(struct MultiHeader*v){ } int serialize_AuthPacket(struct oarchive *out, const char *tag, struct AuthPacket *v){ int rc; rc = out->start_record(out, tag); rc = rc ? rc : out->serialize_Int(out, "type", &v->type); rc = rc ? rc : out->serialize_String(out, "scheme", &v->scheme); rc = rc ? rc : out->serialize_Buffer(out, "auth", &v->auth); rc = rc ? rc : out->end_record(out, tag); return rc; } int deserialize_AuthPacket(struct iarchive *in, const char *tag, struct AuthPacket*v){ int rc; rc = in->start_record(in, tag); rc = rc ? rc : in->deserialize_Int(in, "type", &v->type); rc = rc ? rc : in->deserialize_String(in, "scheme", &v->scheme); rc = rc ? rc : in->deserialize_Buffer(in, "auth", &v->auth); rc = rc ? rc : in->end_record(in, tag); return rc; } void deallocate_AuthPacket(struct AuthPacket*v){ deallocate_String(&v->scheme); deallocate_Buffer(&v->auth); } int serialize_ReplyHeader(struct oarchive *out, const char *tag, struct ReplyHeader *v){ int rc; rc = out->start_record(out, tag); rc = rc ? rc : out->serialize_Int(out, "xid", &v->xid); rc = rc ? rc : out->serialize_Long(out, "zxid", &v->zxid); rc = rc ? rc : out->serialize_Int(out, "err", &v->err); rc = rc ? rc : out->end_record(out, tag); return rc; } int deserialize_ReplyHeader(struct iarchive *in, const char *tag, struct ReplyHeader*v){ int rc; rc = in->start_record(in, tag); rc = rc ? rc : in->deserialize_Int(in, "xid", &v->xid); rc = rc ? rc : in->deserialize_Long(in, "zxid", &v->zxid); rc = rc ? rc : in->deserialize_Int(in, "err", &v->err); rc = rc ? rc : in->end_record(in, tag); return rc; } void deallocate_ReplyHeader(struct ReplyHeader*v){ } int serialize_GetDataRequest(struct oarchive *out, const char *tag, struct GetDataRequest *v){ int rc; rc = out->start_record(out, tag); rc = rc ? rc : out->serialize_String(out, "path", &v->path); rc = rc ? rc : out->serialize_Bool(out, "watch", &v->watch); rc = rc ? rc : out->end_record(out, tag); return rc; } int deserialize_GetDataRequest(struct iarchive *in, const char *tag, struct GetDataRequest*v){ int rc; rc = in->start_record(in, tag); rc = rc ? rc : in->deserialize_String(in, "path", &v->path); rc = rc ? rc : in->deserialize_Bool(in, "watch", &v->watch); rc = rc ? rc : in->end_record(in, tag); return rc; } void deallocate_GetDataRequest(struct GetDataRequest*v){ deallocate_String(&v->path); } int serialize_SetDataRequest(struct oarchive *out, const char *tag, struct SetDataRequest *v){ int rc; rc = out->start_record(out, tag); rc = rc ? rc : out->serialize_String(out, "path", &v->path); rc = rc ? rc : out->serialize_Buffer(out, "data", &v->data); rc = rc ? rc : out->serialize_Int(out, "version", &v->version); rc = rc ? rc : out->end_record(out, tag); return rc; } int deserialize_SetDataRequest(struct iarchive *in, const char *tag, struct SetDataRequest*v){ int rc; rc = in->start_record(in, tag); rc = rc ? rc : in->deserialize_String(in, "path", &v->path); rc = rc ? rc : in->deserialize_Buffer(in, "data", &v->data); rc = rc ? rc : in->deserialize_Int(in, "version", &v->version); rc = rc ? rc : in->end_record(in, tag); return rc; } void deallocate_SetDataRequest(struct SetDataRequest*v){ deallocate_String(&v->path); deallocate_Buffer(&v->data); } int serialize_ReconfigRequest(struct oarchive *out, const char *tag, struct ReconfigRequest *v){ int rc; rc = out->start_record(out, tag); rc = rc ? rc : out->serialize_String(out, "joiningServers", &v->joiningServers); rc = rc ? rc : out->serialize_String(out, "leavingServers", &v->leavingServers); rc = rc ? rc : out->serialize_String(out, "newMembers", &v->newMembers); rc = rc ? rc : out->serialize_Long(out, "curConfigId", &v->curConfigId); rc = rc ? rc : out->end_record(out, tag); return rc; } int deserialize_ReconfigRequest(struct iarchive *in, const char *tag, struct ReconfigRequest*v){ int rc; rc = in->start_record(in, tag); rc = rc ? rc : in->deserialize_String(in, "joiningServers", &v->joiningServers); rc = rc ? rc : in->deserialize_String(in, "leavingServers", &v->leavingServers); rc = rc ? rc : in->deserialize_String(in, "newMembers", &v->newMembers); rc = rc ? rc : in->deserialize_Long(in, "curConfigId", &v->curConfigId); rc = rc ? rc : in->end_record(in, tag); return rc; } void deallocate_ReconfigRequest(struct ReconfigRequest*v){ deallocate_String(&v->joiningServers); deallocate_String(&v->leavingServers); deallocate_String(&v->newMembers); } int serialize_SetDataResponse(struct oarchive *out, const char *tag, struct SetDataResponse *v){ int rc; rc = out->start_record(out, tag); rc = rc ? rc : serialize_Stat(out, "stat", &v->stat); rc = rc ? rc : out->end_record(out, tag); return rc; } int deserialize_SetDataResponse(struct iarchive *in, const char *tag, struct SetDataResponse*v){ int rc; rc = in->start_record(in, tag); rc = rc ? rc : deserialize_Stat(in, "stat", &v->stat); rc = rc ? rc : in->end_record(in, tag); return rc; } void deallocate_SetDataResponse(struct SetDataResponse*v){ deallocate_Stat(&v->stat); } int serialize_GetSASLRequest(struct oarchive *out, const char *tag, struct GetSASLRequest *v){ int rc; rc = out->start_record(out, tag); rc = rc ? rc : out->serialize_Buffer(out, "token", &v->token); rc = rc ? rc : out->end_record(out, tag); return rc; } int deserialize_GetSASLRequest(struct iarchive *in, const char *tag, struct GetSASLRequest*v){ int rc; rc = in->start_record(in, tag); rc = rc ? rc : in->deserialize_Buffer(in, "token", &v->token); rc = rc ? rc : in->end_record(in, tag); return rc; } void deallocate_GetSASLRequest(struct GetSASLRequest*v){ deallocate_Buffer(&v->token); } int serialize_SetSASLRequest(struct oarchive *out, const char *tag, struct SetSASLRequest *v){ int rc; rc = out->start_record(out, tag); rc = rc ? rc : out->serialize_Buffer(out, "token", &v->token); rc = rc ? rc : out->end_record(out, tag); return rc; } int deserialize_SetSASLRequest(struct iarchive *in, const char *tag, struct SetSASLRequest*v){ int rc; rc = in->start_record(in, tag); rc = rc ? rc : in->deserialize_Buffer(in, "token", &v->token); rc = rc ? rc : in->end_record(in, tag); return rc; } void deallocate_SetSASLRequest(struct SetSASLRequest*v){ deallocate_Buffer(&v->token); } int serialize_SetSASLResponse(struct oarchive *out, const char *tag, struct SetSASLResponse *v){ int rc; rc = out->start_record(out, tag); rc = rc ? rc : out->serialize_Buffer(out, "token", &v->token); rc = rc ? rc : out->end_record(out, tag); return rc; } int deserialize_SetSASLResponse(struct iarchive *in, const char *tag, struct SetSASLResponse*v){ int rc; rc = in->start_record(in, tag); rc = rc ? rc : in->deserialize_Buffer(in, "token", &v->token); rc = rc ? rc : in->end_record(in, tag); return rc; } void deallocate_SetSASLResponse(struct SetSASLResponse*v){ deallocate_Buffer(&v->token); } int allocate_ACL_vector(struct ACL_vector *v, int32_t len) { if (!len) { v->count = 0; v->data = 0; } else { v->count = len; v->data = calloc(sizeof(*v->data), len); } return 0; } int deallocate_ACL_vector(struct ACL_vector *v) { if (v->data) { int32_t i; for(i=0;icount; i++) { deallocate_ACL(&v->data[i]); } free(v->data); v->data = 0; } return 0; } int serialize_ACL_vector(struct oarchive *out, const char *tag, struct ACL_vector *v) { int32_t count = v->count; int rc = 0; int32_t i; rc = out->start_vector(out, tag, &count); for(i=0;icount;i++) { rc = rc ? rc : serialize_ACL(out, "data", &v->data[i]); } rc = rc ? rc : out->end_vector(out, tag); return rc; } int deserialize_ACL_vector(struct iarchive *in, const char *tag, struct ACL_vector *v) { int rc = 0; int32_t i; rc = in->start_vector(in, tag, &v->count); v->data = calloc(v->count, sizeof(*v->data)); for(i=0;icount;i++) { rc = rc ? rc : deserialize_ACL(in, "value", &v->data[i]); } rc = in->end_vector(in, tag); return rc; } int serialize_CreateRequest(struct oarchive *out, const char *tag, struct CreateRequest *v){ int rc; rc = out->start_record(out, tag); rc = rc ? rc : out->serialize_String(out, "path", &v->path); rc = rc ? rc : out->serialize_Buffer(out, "data", &v->data); rc = rc ? rc : serialize_ACL_vector(out, "acl", &v->acl); rc = rc ? rc : out->serialize_Int(out, "flags", &v->flags); rc = rc ? rc : out->end_record(out, tag); return rc; } int deserialize_CreateRequest(struct iarchive *in, const char *tag, struct CreateRequest*v){ int rc; rc = in->start_record(in, tag); rc = rc ? rc : in->deserialize_String(in, "path", &v->path); rc = rc ? rc : in->deserialize_Buffer(in, "data", &v->data); rc = rc ? rc : deserialize_ACL_vector(in, "acl", &v->acl); rc = rc ? rc : in->deserialize_Int(in, "flags", &v->flags); rc = rc ? rc : in->end_record(in, tag); return rc; } void deallocate_CreateRequest(struct CreateRequest*v){ deallocate_String(&v->path); deallocate_Buffer(&v->data); deallocate_ACL_vector(&v->acl); } int serialize_CreateTTLRequest(struct oarchive *out, const char *tag, struct CreateTTLRequest *v){ int rc; rc = out->start_record(out, tag); rc = rc ? rc : out->serialize_String(out, "path", &v->path); rc = rc ? rc : out->serialize_Buffer(out, "data", &v->data); rc = rc ? rc : serialize_ACL_vector(out, "acl", &v->acl); rc = rc ? rc : out->serialize_Int(out, "flags", &v->flags); rc = rc ? rc : out->serialize_Long(out, "ttl", &v->ttl); rc = rc ? rc : out->end_record(out, tag); return rc; } int deserialize_CreateTTLRequest(struct iarchive *in, const char *tag, struct CreateTTLRequest*v){ int rc; rc = in->start_record(in, tag); rc = rc ? rc : in->deserialize_String(in, "path", &v->path); rc = rc ? rc : in->deserialize_Buffer(in, "data", &v->data); rc = rc ? rc : deserialize_ACL_vector(in, "acl", &v->acl); rc = rc ? rc : in->deserialize_Int(in, "flags", &v->flags); rc = rc ? rc : in->deserialize_Long(in, "ttl", &v->ttl); rc = rc ? rc : in->end_record(in, tag); return rc; } void deallocate_CreateTTLRequest(struct CreateTTLRequest*v){ deallocate_String(&v->path); deallocate_Buffer(&v->data); deallocate_ACL_vector(&v->acl); } int serialize_DeleteRequest(struct oarchive *out, const char *tag, struct DeleteRequest *v){ int rc; rc = out->start_record(out, tag); rc = rc ? rc : out->serialize_String(out, "path", &v->path); rc = rc ? rc : out->serialize_Int(out, "version", &v->version); rc = rc ? rc : out->end_record(out, tag); return rc; } int deserialize_DeleteRequest(struct iarchive *in, const char *tag, struct DeleteRequest*v){ int rc; rc = in->start_record(in, tag); rc = rc ? rc : in->deserialize_String(in, "path", &v->path); rc = rc ? rc : in->deserialize_Int(in, "version", &v->version); rc = rc ? rc : in->end_record(in, tag); return rc; } void deallocate_DeleteRequest(struct DeleteRequest*v){ deallocate_String(&v->path); } int serialize_GetChildrenRequest(struct oarchive *out, const char *tag, struct GetChildrenRequest *v){ int rc; rc = out->start_record(out, tag); rc = rc ? rc : out->serialize_String(out, "path", &v->path); rc = rc ? rc : out->serialize_Bool(out, "watch", &v->watch); rc = rc ? rc : out->end_record(out, tag); return rc; } int deserialize_GetChildrenRequest(struct iarchive *in, const char *tag, struct GetChildrenRequest*v){ int rc; rc = in->start_record(in, tag); rc = rc ? rc : in->deserialize_String(in, "path", &v->path); rc = rc ? rc : in->deserialize_Bool(in, "watch", &v->watch); rc = rc ? rc : in->end_record(in, tag); return rc; } void deallocate_GetChildrenRequest(struct GetChildrenRequest*v){ deallocate_String(&v->path); } int serialize_GetAllChildrenNumberRequest(struct oarchive *out, const char *tag, struct GetAllChildrenNumberRequest *v){ int rc; rc = out->start_record(out, tag); rc = rc ? rc : out->serialize_String(out, "path", &v->path); rc = rc ? rc : out->end_record(out, tag); return rc; } int deserialize_GetAllChildrenNumberRequest(struct iarchive *in, const char *tag, struct GetAllChildrenNumberRequest*v){ int rc; rc = in->start_record(in, tag); rc = rc ? rc : in->deserialize_String(in, "path", &v->path); rc = rc ? rc : in->end_record(in, tag); return rc; } void deallocate_GetAllChildrenNumberRequest(struct GetAllChildrenNumberRequest*v){ deallocate_String(&v->path); } int serialize_GetChildren2Request(struct oarchive *out, const char *tag, struct GetChildren2Request *v){ int rc; rc = out->start_record(out, tag); rc = rc ? rc : out->serialize_String(out, "path", &v->path); rc = rc ? rc : out->serialize_Bool(out, "watch", &v->watch); rc = rc ? rc : out->end_record(out, tag); return rc; } int deserialize_GetChildren2Request(struct iarchive *in, const char *tag, struct GetChildren2Request*v){ int rc; rc = in->start_record(in, tag); rc = rc ? rc : in->deserialize_String(in, "path", &v->path); rc = rc ? rc : in->deserialize_Bool(in, "watch", &v->watch); rc = rc ? rc : in->end_record(in, tag); return rc; } void deallocate_GetChildren2Request(struct GetChildren2Request*v){ deallocate_String(&v->path); } int serialize_CheckVersionRequest(struct oarchive *out, const char *tag, struct CheckVersionRequest *v){ int rc; rc = out->start_record(out, tag); rc = rc ? rc : out->serialize_String(out, "path", &v->path); rc = rc ? rc : out->serialize_Int(out, "version", &v->version); rc = rc ? rc : out->end_record(out, tag); return rc; } int deserialize_CheckVersionRequest(struct iarchive *in, const char *tag, struct CheckVersionRequest*v){ int rc; rc = in->start_record(in, tag); rc = rc ? rc : in->deserialize_String(in, "path", &v->path); rc = rc ? rc : in->deserialize_Int(in, "version", &v->version); rc = rc ? rc : in->end_record(in, tag); return rc; } void deallocate_CheckVersionRequest(struct CheckVersionRequest*v){ deallocate_String(&v->path); } int serialize_GetMaxChildrenRequest(struct oarchive *out, const char *tag, struct GetMaxChildrenRequest *v){ int rc; rc = out->start_record(out, tag); rc = rc ? rc : out->serialize_String(out, "path", &v->path); rc = rc ? rc : out->end_record(out, tag); return rc; } int deserialize_GetMaxChildrenRequest(struct iarchive *in, const char *tag, struct GetMaxChildrenRequest*v){ int rc; rc = in->start_record(in, tag); rc = rc ? rc : in->deserialize_String(in, "path", &v->path); rc = rc ? rc : in->end_record(in, tag); return rc; } void deallocate_GetMaxChildrenRequest(struct GetMaxChildrenRequest*v){ deallocate_String(&v->path); } int serialize_GetMaxChildrenResponse(struct oarchive *out, const char *tag, struct GetMaxChildrenResponse *v){ int rc; rc = out->start_record(out, tag); rc = rc ? rc : out->serialize_Int(out, "max", &v->max); rc = rc ? rc : out->end_record(out, tag); return rc; } int deserialize_GetMaxChildrenResponse(struct iarchive *in, const char *tag, struct GetMaxChildrenResponse*v){ int rc; rc = in->start_record(in, tag); rc = rc ? rc : in->deserialize_Int(in, "max", &v->max); rc = rc ? rc : in->end_record(in, tag); return rc; } void deallocate_GetMaxChildrenResponse(struct GetMaxChildrenResponse*v){ } int serialize_SetMaxChildrenRequest(struct oarchive *out, const char *tag, struct SetMaxChildrenRequest *v){ int rc; rc = out->start_record(out, tag); rc = rc ? rc : out->serialize_String(out, "path", &v->path); rc = rc ? rc : out->serialize_Int(out, "max", &v->max); rc = rc ? rc : out->end_record(out, tag); return rc; } int deserialize_SetMaxChildrenRequest(struct iarchive *in, const char *tag, struct SetMaxChildrenRequest*v){ int rc; rc = in->start_record(in, tag); rc = rc ? rc : in->deserialize_String(in, "path", &v->path); rc = rc ? rc : in->deserialize_Int(in, "max", &v->max); rc = rc ? rc : in->end_record(in, tag); return rc; } void deallocate_SetMaxChildrenRequest(struct SetMaxChildrenRequest*v){ deallocate_String(&v->path); } int serialize_SyncRequest(struct oarchive *out, const char *tag, struct SyncRequest *v){ int rc; rc = out->start_record(out, tag); rc = rc ? rc : out->serialize_String(out, "path", &v->path); rc = rc ? rc : out->end_record(out, tag); return rc; } int deserialize_SyncRequest(struct iarchive *in, const char *tag, struct SyncRequest*v){ int rc; rc = in->start_record(in, tag); rc = rc ? rc : in->deserialize_String(in, "path", &v->path); rc = rc ? rc : in->end_record(in, tag); return rc; } void deallocate_SyncRequest(struct SyncRequest*v){ deallocate_String(&v->path); } int serialize_SyncResponse(struct oarchive *out, const char *tag, struct SyncResponse *v){ int rc; rc = out->start_record(out, tag); rc = rc ? rc : out->serialize_String(out, "path", &v->path); rc = rc ? rc : out->end_record(out, tag); return rc; } int deserialize_SyncResponse(struct iarchive *in, const char *tag, struct SyncResponse*v){ int rc; rc = in->start_record(in, tag); rc = rc ? rc : in->deserialize_String(in, "path", &v->path); rc = rc ? rc : in->end_record(in, tag); return rc; } void deallocate_SyncResponse(struct SyncResponse*v){ deallocate_String(&v->path); } int serialize_GetACLRequest(struct oarchive *out, const char *tag, struct GetACLRequest *v){ int rc; rc = out->start_record(out, tag); rc = rc ? rc : out->serialize_String(out, "path", &v->path); rc = rc ? rc : out->end_record(out, tag); return rc; } int deserialize_GetACLRequest(struct iarchive *in, const char *tag, struct GetACLRequest*v){ int rc; rc = in->start_record(in, tag); rc = rc ? rc : in->deserialize_String(in, "path", &v->path); rc = rc ? rc : in->end_record(in, tag); return rc; } void deallocate_GetACLRequest(struct GetACLRequest*v){ deallocate_String(&v->path); } int serialize_SetACLRequest(struct oarchive *out, const char *tag, struct SetACLRequest *v){ int rc; rc = out->start_record(out, tag); rc = rc ? rc : out->serialize_String(out, "path", &v->path); rc = rc ? rc : serialize_ACL_vector(out, "acl", &v->acl); rc = rc ? rc : out->serialize_Int(out, "version", &v->version); rc = rc ? rc : out->end_record(out, tag); return rc; } int deserialize_SetACLRequest(struct iarchive *in, const char *tag, struct SetACLRequest*v){ int rc; rc = in->start_record(in, tag); rc = rc ? rc : in->deserialize_String(in, "path", &v->path); rc = rc ? rc : deserialize_ACL_vector(in, "acl", &v->acl); rc = rc ? rc : in->deserialize_Int(in, "version", &v->version); rc = rc ? rc : in->end_record(in, tag); return rc; } void deallocate_SetACLRequest(struct SetACLRequest*v){ deallocate_String(&v->path); deallocate_ACL_vector(&v->acl); } int serialize_SetACLResponse(struct oarchive *out, const char *tag, struct SetACLResponse *v){ int rc; rc = out->start_record(out, tag); rc = rc ? rc : serialize_Stat(out, "stat", &v->stat); rc = rc ? rc : out->end_record(out, tag); return rc; } int deserialize_SetACLResponse(struct iarchive *in, const char *tag, struct SetACLResponse*v){ int rc; rc = in->start_record(in, tag); rc = rc ? rc : deserialize_Stat(in, "stat", &v->stat); rc = rc ? rc : in->end_record(in, tag); return rc; } void deallocate_SetACLResponse(struct SetACLResponse*v){ deallocate_Stat(&v->stat); } int serialize_AddWatchRequest(struct oarchive *out, const char *tag, struct AddWatchRequest *v){ int rc; rc = out->start_record(out, tag); rc = rc ? rc : out->serialize_String(out, "path", &v->path); rc = rc ? rc : out->serialize_Int(out, "mode", &v->mode); rc = rc ? rc : out->end_record(out, tag); return rc; } int deserialize_AddWatchRequest(struct iarchive *in, const char *tag, struct AddWatchRequest*v){ int rc; rc = in->start_record(in, tag); rc = rc ? rc : in->deserialize_String(in, "path", &v->path); rc = rc ? rc : in->deserialize_Int(in, "mode", &v->mode); rc = rc ? rc : in->end_record(in, tag); return rc; } void deallocate_AddWatchRequest(struct AddWatchRequest*v){ deallocate_String(&v->path); } int serialize_WatcherEvent(struct oarchive *out, const char *tag, struct WatcherEvent *v){ int rc; rc = out->start_record(out, tag); rc = rc ? rc : out->serialize_Int(out, "type", &v->type); rc = rc ? rc : out->serialize_Int(out, "state", &v->state); rc = rc ? rc : out->serialize_String(out, "path", &v->path); rc = rc ? rc : out->end_record(out, tag); return rc; } int deserialize_WatcherEvent(struct iarchive *in, const char *tag, struct WatcherEvent*v){ int rc; rc = in->start_record(in, tag); rc = rc ? rc : in->deserialize_Int(in, "type", &v->type); rc = rc ? rc : in->deserialize_Int(in, "state", &v->state); rc = rc ? rc : in->deserialize_String(in, "path", &v->path); rc = rc ? rc : in->end_record(in, tag); return rc; } void deallocate_WatcherEvent(struct WatcherEvent*v){ deallocate_String(&v->path); } int serialize_ErrorResponse(struct oarchive *out, const char *tag, struct ErrorResponse *v){ int rc; rc = out->start_record(out, tag); rc = rc ? rc : out->serialize_Int(out, "err", &v->err); rc = rc ? rc : out->end_record(out, tag); return rc; } int deserialize_ErrorResponse(struct iarchive *in, const char *tag, struct ErrorResponse*v){ int rc; rc = in->start_record(in, tag); rc = rc ? rc : in->deserialize_Int(in, "err", &v->err); rc = rc ? rc : in->end_record(in, tag); return rc; } void deallocate_ErrorResponse(struct ErrorResponse*v){ } int serialize_CreateResponse(struct oarchive *out, const char *tag, struct CreateResponse *v){ int rc; rc = out->start_record(out, tag); rc = rc ? rc : out->serialize_String(out, "path", &v->path); rc = rc ? rc : out->end_record(out, tag); return rc; } int deserialize_CreateResponse(struct iarchive *in, const char *tag, struct CreateResponse*v){ int rc; rc = in->start_record(in, tag); rc = rc ? rc : in->deserialize_String(in, "path", &v->path); rc = rc ? rc : in->end_record(in, tag); return rc; } void deallocate_CreateResponse(struct CreateResponse*v){ deallocate_String(&v->path); } int serialize_Create2Response(struct oarchive *out, const char *tag, struct Create2Response *v){ int rc; rc = out->start_record(out, tag); rc = rc ? rc : out->serialize_String(out, "path", &v->path); rc = rc ? rc : serialize_Stat(out, "stat", &v->stat); rc = rc ? rc : out->end_record(out, tag); return rc; } int deserialize_Create2Response(struct iarchive *in, const char *tag, struct Create2Response*v){ int rc; rc = in->start_record(in, tag); rc = rc ? rc : in->deserialize_String(in, "path", &v->path); rc = rc ? rc : deserialize_Stat(in, "stat", &v->stat); rc = rc ? rc : in->end_record(in, tag); return rc; } void deallocate_Create2Response(struct Create2Response*v){ deallocate_String(&v->path); deallocate_Stat(&v->stat); } int serialize_ExistsRequest(struct oarchive *out, const char *tag, struct ExistsRequest *v){ int rc; rc = out->start_record(out, tag); rc = rc ? rc : out->serialize_String(out, "path", &v->path); rc = rc ? rc : out->serialize_Bool(out, "watch", &v->watch); rc = rc ? rc : out->end_record(out, tag); return rc; } int deserialize_ExistsRequest(struct iarchive *in, const char *tag, struct ExistsRequest*v){ int rc; rc = in->start_record(in, tag); rc = rc ? rc : in->deserialize_String(in, "path", &v->path); rc = rc ? rc : in->deserialize_Bool(in, "watch", &v->watch); rc = rc ? rc : in->end_record(in, tag); return rc; } void deallocate_ExistsRequest(struct ExistsRequest*v){ deallocate_String(&v->path); } int serialize_ExistsResponse(struct oarchive *out, const char *tag, struct ExistsResponse *v){ int rc; rc = out->start_record(out, tag); rc = rc ? rc : serialize_Stat(out, "stat", &v->stat); rc = rc ? rc : out->end_record(out, tag); return rc; } int deserialize_ExistsResponse(struct iarchive *in, const char *tag, struct ExistsResponse*v){ int rc; rc = in->start_record(in, tag); rc = rc ? rc : deserialize_Stat(in, "stat", &v->stat); rc = rc ? rc : in->end_record(in, tag); return rc; } void deallocate_ExistsResponse(struct ExistsResponse*v){ deallocate_Stat(&v->stat); } int serialize_GetDataResponse(struct oarchive *out, const char *tag, struct GetDataResponse *v){ int rc; rc = out->start_record(out, tag); rc = rc ? rc : out->serialize_Buffer(out, "data", &v->data); rc = rc ? rc : serialize_Stat(out, "stat", &v->stat); rc = rc ? rc : out->end_record(out, tag); return rc; } int deserialize_GetDataResponse(struct iarchive *in, const char *tag, struct GetDataResponse*v){ int rc; rc = in->start_record(in, tag); rc = rc ? rc : in->deserialize_Buffer(in, "data", &v->data); rc = rc ? rc : deserialize_Stat(in, "stat", &v->stat); rc = rc ? rc : in->end_record(in, tag); return rc; } void deallocate_GetDataResponse(struct GetDataResponse*v){ deallocate_Buffer(&v->data); deallocate_Stat(&v->stat); } int serialize_GetChildrenResponse(struct oarchive *out, const char *tag, struct GetChildrenResponse *v){ int rc; rc = out->start_record(out, tag); rc = rc ? rc : serialize_String_vector(out, "children", &v->children); rc = rc ? rc : out->end_record(out, tag); return rc; } int deserialize_GetChildrenResponse(struct iarchive *in, const char *tag, struct GetChildrenResponse*v){ int rc; rc = in->start_record(in, tag); rc = rc ? rc : deserialize_String_vector(in, "children", &v->children); rc = rc ? rc : in->end_record(in, tag); return rc; } void deallocate_GetChildrenResponse(struct GetChildrenResponse*v){ deallocate_String_vector(&v->children); } int serialize_GetAllChildrenNumberResponse(struct oarchive *out, const char *tag, struct GetAllChildrenNumberResponse *v){ int rc; rc = out->start_record(out, tag); rc = rc ? rc : out->serialize_Int(out, "totalNumber", &v->totalNumber); rc = rc ? rc : out->end_record(out, tag); return rc; } int deserialize_GetAllChildrenNumberResponse(struct iarchive *in, const char *tag, struct GetAllChildrenNumberResponse*v){ int rc; rc = in->start_record(in, tag); rc = rc ? rc : in->deserialize_Int(in, "totalNumber", &v->totalNumber); rc = rc ? rc : in->end_record(in, tag); return rc; } void deallocate_GetAllChildrenNumberResponse(struct GetAllChildrenNumberResponse*v){ } int serialize_GetChildren2Response(struct oarchive *out, const char *tag, struct GetChildren2Response *v){ int rc; rc = out->start_record(out, tag); rc = rc ? rc : serialize_String_vector(out, "children", &v->children); rc = rc ? rc : serialize_Stat(out, "stat", &v->stat); rc = rc ? rc : out->end_record(out, tag); return rc; } int deserialize_GetChildren2Response(struct iarchive *in, const char *tag, struct GetChildren2Response*v){ int rc; rc = in->start_record(in, tag); rc = rc ? rc : deserialize_String_vector(in, "children", &v->children); rc = rc ? rc : deserialize_Stat(in, "stat", &v->stat); rc = rc ? rc : in->end_record(in, tag); return rc; } void deallocate_GetChildren2Response(struct GetChildren2Response*v){ deallocate_String_vector(&v->children); deallocate_Stat(&v->stat); } int serialize_GetACLResponse(struct oarchive *out, const char *tag, struct GetACLResponse *v){ int rc; rc = out->start_record(out, tag); rc = rc ? rc : serialize_ACL_vector(out, "acl", &v->acl); rc = rc ? rc : serialize_Stat(out, "stat", &v->stat); rc = rc ? rc : out->end_record(out, tag); return rc; } int deserialize_GetACLResponse(struct iarchive *in, const char *tag, struct GetACLResponse*v){ int rc; rc = in->start_record(in, tag); rc = rc ? rc : deserialize_ACL_vector(in, "acl", &v->acl); rc = rc ? rc : deserialize_Stat(in, "stat", &v->stat); rc = rc ? rc : in->end_record(in, tag); return rc; } void deallocate_GetACLResponse(struct GetACLResponse*v){ deallocate_ACL_vector(&v->acl); deallocate_Stat(&v->stat); } int serialize_CheckWatchesRequest(struct oarchive *out, const char *tag, struct CheckWatchesRequest *v){ int rc; rc = out->start_record(out, tag); rc = rc ? rc : out->serialize_String(out, "path", &v->path); rc = rc ? rc : out->serialize_Int(out, "type", &v->type); rc = rc ? rc : out->end_record(out, tag); return rc; } int deserialize_CheckWatchesRequest(struct iarchive *in, const char *tag, struct CheckWatchesRequest*v){ int rc; rc = in->start_record(in, tag); rc = rc ? rc : in->deserialize_String(in, "path", &v->path); rc = rc ? rc : in->deserialize_Int(in, "type", &v->type); rc = rc ? rc : in->end_record(in, tag); return rc; } void deallocate_CheckWatchesRequest(struct CheckWatchesRequest*v){ deallocate_String(&v->path); } int serialize_RemoveWatchesRequest(struct oarchive *out, const char *tag, struct RemoveWatchesRequest *v){ int rc; rc = out->start_record(out, tag); rc = rc ? rc : out->serialize_String(out, "path", &v->path); rc = rc ? rc : out->serialize_Int(out, "type", &v->type); rc = rc ? rc : out->end_record(out, tag); return rc; } int deserialize_RemoveWatchesRequest(struct iarchive *in, const char *tag, struct RemoveWatchesRequest*v){ int rc; rc = in->start_record(in, tag); rc = rc ? rc : in->deserialize_String(in, "path", &v->path); rc = rc ? rc : in->deserialize_Int(in, "type", &v->type); rc = rc ? rc : in->end_record(in, tag); return rc; } void deallocate_RemoveWatchesRequest(struct RemoveWatchesRequest*v){ deallocate_String(&v->path); } int serialize_GetEphemeralsRequest(struct oarchive *out, const char *tag, struct GetEphemeralsRequest *v){ int rc; rc = out->start_record(out, tag); rc = rc ? rc : out->serialize_String(out, "prefixPath", &v->prefixPath); rc = rc ? rc : out->end_record(out, tag); return rc; } int deserialize_GetEphemeralsRequest(struct iarchive *in, const char *tag, struct GetEphemeralsRequest*v){ int rc; rc = in->start_record(in, tag); rc = rc ? rc : in->deserialize_String(in, "prefixPath", &v->prefixPath); rc = rc ? rc : in->end_record(in, tag); return rc; } void deallocate_GetEphemeralsRequest(struct GetEphemeralsRequest*v){ deallocate_String(&v->prefixPath); } int serialize_GetEphemeralsResponse(struct oarchive *out, const char *tag, struct GetEphemeralsResponse *v){ int rc; rc = out->start_record(out, tag); rc = rc ? rc : serialize_String_vector(out, "ephemerals", &v->ephemerals); rc = rc ? rc : out->end_record(out, tag); return rc; } int deserialize_GetEphemeralsResponse(struct iarchive *in, const char *tag, struct GetEphemeralsResponse*v){ int rc; rc = in->start_record(in, tag); rc = rc ? rc : deserialize_String_vector(in, "ephemerals", &v->ephemerals); rc = rc ? rc : in->end_record(in, tag); return rc; } void deallocate_GetEphemeralsResponse(struct GetEphemeralsResponse*v){ deallocate_String_vector(&v->ephemerals); } +int allocate_ClientInfo_vector(struct ClientInfo_vector *v, int32_t len) { + if (!len) { + v->count = 0; + v->data = 0; + } else { + v->count = len; + v->data = calloc(sizeof(*v->data), len); + } + return 0; +} +int deallocate_ClientInfo_vector(struct ClientInfo_vector *v) { + if (v->data) { + int32_t i; + for(i=0;icount; i++) { + deallocate_ClientInfo(&v->data[i]); + } + free(v->data); + v->data = 0; + } + return 0; +} +int serialize_ClientInfo_vector(struct oarchive *out, const char *tag, struct ClientInfo_vector *v) +{ + int32_t count = v->count; + int rc = 0; + int32_t i; + rc = out->start_vector(out, tag, &count); + for(i=0;icount;i++) { + rc = rc ? rc : serialize_ClientInfo(out, "data", &v->data[i]); + } + rc = rc ? rc : out->end_vector(out, tag); + return rc; +} +int deserialize_ClientInfo_vector(struct iarchive *in, const char *tag, struct ClientInfo_vector *v) +{ + int rc = 0; + int32_t i; + rc = in->start_vector(in, tag, &v->count); + v->data = calloc(v->count, sizeof(*v->data)); + for(i=0;icount;i++) { + rc = rc ? rc : deserialize_ClientInfo(in, "value", &v->data[i]); + } + rc = in->end_vector(in, tag); + return rc; +} +int serialize_WhoAmIResponse(struct oarchive *out, const char *tag, struct WhoAmIResponse *v){ + int rc; + rc = out->start_record(out, tag); + rc = rc ? rc : serialize_ClientInfo_vector(out, "clientInfo", &v->clientInfo); + rc = rc ? rc : out->end_record(out, tag); + return rc; +} +int deserialize_WhoAmIResponse(struct iarchive *in, const char *tag, struct WhoAmIResponse*v){ + int rc; + rc = in->start_record(in, tag); + rc = rc ? rc : deserialize_ClientInfo_vector(in, "clientInfo", &v->clientInfo); + rc = rc ? rc : in->end_record(in, tag); + return rc; +} +void deallocate_WhoAmIResponse(struct WhoAmIResponse*v){ + deallocate_ClientInfo_vector(&v->clientInfo); +} int serialize_LearnerInfo(struct oarchive *out, const char *tag, struct LearnerInfo *v){ int rc; rc = out->start_record(out, tag); rc = rc ? rc : out->serialize_Long(out, "serverid", &v->serverid); rc = rc ? rc : out->serialize_Int(out, "protocolVersion", &v->protocolVersion); rc = rc ? rc : out->serialize_Long(out, "configVersion", &v->configVersion); rc = rc ? rc : out->end_record(out, tag); return rc; } int deserialize_LearnerInfo(struct iarchive *in, const char *tag, struct LearnerInfo*v){ int rc; rc = in->start_record(in, tag); rc = rc ? rc : in->deserialize_Long(in, "serverid", &v->serverid); rc = rc ? rc : in->deserialize_Int(in, "protocolVersion", &v->protocolVersion); rc = rc ? rc : in->deserialize_Long(in, "configVersion", &v->configVersion); rc = rc ? rc : in->end_record(in, tag); return rc; } void deallocate_LearnerInfo(struct LearnerInfo*v){ } int allocate_Id_vector(struct Id_vector *v, int32_t len) { if (!len) { v->count = 0; v->data = 0; } else { v->count = len; v->data = calloc(sizeof(*v->data), len); } return 0; } int deallocate_Id_vector(struct Id_vector *v) { if (v->data) { int32_t i; for(i=0;icount; i++) { deallocate_Id(&v->data[i]); } free(v->data); v->data = 0; } return 0; } int serialize_Id_vector(struct oarchive *out, const char *tag, struct Id_vector *v) { int32_t count = v->count; int rc = 0; int32_t i; rc = out->start_vector(out, tag, &count); for(i=0;icount;i++) { rc = rc ? rc : serialize_Id(out, "data", &v->data[i]); } rc = rc ? rc : out->end_vector(out, tag); return rc; } int deserialize_Id_vector(struct iarchive *in, const char *tag, struct Id_vector *v) { int rc = 0; int32_t i; rc = in->start_vector(in, tag, &v->count); v->data = calloc(v->count, sizeof(*v->data)); for(i=0;icount;i++) { rc = rc ? rc : deserialize_Id(in, "value", &v->data[i]); } rc = in->end_vector(in, tag); return rc; } int serialize_QuorumPacket(struct oarchive *out, const char *tag, struct QuorumPacket *v){ int rc; rc = out->start_record(out, tag); rc = rc ? rc : out->serialize_Int(out, "type", &v->type); rc = rc ? rc : out->serialize_Long(out, "zxid", &v->zxid); rc = rc ? rc : out->serialize_Buffer(out, "data", &v->data); rc = rc ? rc : serialize_Id_vector(out, "authinfo", &v->authinfo); rc = rc ? rc : out->end_record(out, tag); return rc; } int deserialize_QuorumPacket(struct iarchive *in, const char *tag, struct QuorumPacket*v){ int rc; rc = in->start_record(in, tag); rc = rc ? rc : in->deserialize_Int(in, "type", &v->type); rc = rc ? rc : in->deserialize_Long(in, "zxid", &v->zxid); rc = rc ? rc : in->deserialize_Buffer(in, "data", &v->data); rc = rc ? rc : deserialize_Id_vector(in, "authinfo", &v->authinfo); rc = rc ? rc : in->end_record(in, tag); return rc; } void deallocate_QuorumPacket(struct QuorumPacket*v){ deallocate_Buffer(&v->data); deallocate_Id_vector(&v->authinfo); } int serialize_QuorumAuthPacket(struct oarchive *out, const char *tag, struct QuorumAuthPacket *v){ int rc; rc = out->start_record(out, tag); rc = rc ? rc : out->serialize_Long(out, "magic", &v->magic); rc = rc ? rc : out->serialize_Int(out, "status", &v->status); rc = rc ? rc : out->serialize_Buffer(out, "token", &v->token); rc = rc ? rc : out->end_record(out, tag); return rc; } int deserialize_QuorumAuthPacket(struct iarchive *in, const char *tag, struct QuorumAuthPacket*v){ int rc; rc = in->start_record(in, tag); rc = rc ? rc : in->deserialize_Long(in, "magic", &v->magic); rc = rc ? rc : in->deserialize_Int(in, "status", &v->status); rc = rc ? rc : in->deserialize_Buffer(in, "token", &v->token); rc = rc ? rc : in->end_record(in, tag); return rc; } void deallocate_QuorumAuthPacket(struct QuorumAuthPacket*v){ deallocate_Buffer(&v->token); } int serialize_FileHeader(struct oarchive *out, const char *tag, struct FileHeader *v){ int rc; rc = out->start_record(out, tag); rc = rc ? rc : out->serialize_Int(out, "magic", &v->magic); rc = rc ? rc : out->serialize_Int(out, "version", &v->version); rc = rc ? rc : out->serialize_Long(out, "dbid", &v->dbid); rc = rc ? rc : out->end_record(out, tag); return rc; } int deserialize_FileHeader(struct iarchive *in, const char *tag, struct FileHeader*v){ int rc; rc = in->start_record(in, tag); rc = rc ? rc : in->deserialize_Int(in, "magic", &v->magic); rc = rc ? rc : in->deserialize_Int(in, "version", &v->version); rc = rc ? rc : in->deserialize_Long(in, "dbid", &v->dbid); rc = rc ? rc : in->end_record(in, tag); return rc; } void deallocate_FileHeader(struct FileHeader*v){ } int serialize_TxnDigest(struct oarchive *out, const char *tag, struct TxnDigest *v){ int rc; rc = out->start_record(out, tag); rc = rc ? rc : out->serialize_Int(out, "version", &v->version); rc = rc ? rc : out->serialize_Long(out, "treeDigest", &v->treeDigest); rc = rc ? rc : out->end_record(out, tag); return rc; } int deserialize_TxnDigest(struct iarchive *in, const char *tag, struct TxnDigest*v){ int rc; rc = in->start_record(in, tag); rc = rc ? rc : in->deserialize_Int(in, "version", &v->version); rc = rc ? rc : in->deserialize_Long(in, "treeDigest", &v->treeDigest); rc = rc ? rc : in->end_record(in, tag); return rc; } void deallocate_TxnDigest(struct TxnDigest*v){ } int serialize_TxnHeader(struct oarchive *out, const char *tag, struct TxnHeader *v){ int rc; rc = out->start_record(out, tag); rc = rc ? rc : out->serialize_Long(out, "clientId", &v->clientId); rc = rc ? rc : out->serialize_Int(out, "cxid", &v->cxid); rc = rc ? rc : out->serialize_Long(out, "zxid", &v->zxid); rc = rc ? rc : out->serialize_Long(out, "time", &v->time); rc = rc ? rc : out->serialize_Int(out, "type", &v->type); rc = rc ? rc : out->end_record(out, tag); return rc; } int deserialize_TxnHeader(struct iarchive *in, const char *tag, struct TxnHeader*v){ int rc; rc = in->start_record(in, tag); rc = rc ? rc : in->deserialize_Long(in, "clientId", &v->clientId); rc = rc ? rc : in->deserialize_Int(in, "cxid", &v->cxid); rc = rc ? rc : in->deserialize_Long(in, "zxid", &v->zxid); rc = rc ? rc : in->deserialize_Long(in, "time", &v->time); rc = rc ? rc : in->deserialize_Int(in, "type", &v->type); rc = rc ? rc : in->end_record(in, tag); return rc; } void deallocate_TxnHeader(struct TxnHeader*v){ } int serialize_CreateTxnV0(struct oarchive *out, const char *tag, struct CreateTxnV0 *v){ int rc; rc = out->start_record(out, tag); rc = rc ? rc : out->serialize_String(out, "path", &v->path); rc = rc ? rc : out->serialize_Buffer(out, "data", &v->data); rc = rc ? rc : serialize_ACL_vector(out, "acl", &v->acl); rc = rc ? rc : out->serialize_Bool(out, "ephemeral", &v->ephemeral); rc = rc ? rc : out->end_record(out, tag); return rc; } int deserialize_CreateTxnV0(struct iarchive *in, const char *tag, struct CreateTxnV0*v){ int rc; rc = in->start_record(in, tag); rc = rc ? rc : in->deserialize_String(in, "path", &v->path); rc = rc ? rc : in->deserialize_Buffer(in, "data", &v->data); rc = rc ? rc : deserialize_ACL_vector(in, "acl", &v->acl); rc = rc ? rc : in->deserialize_Bool(in, "ephemeral", &v->ephemeral); rc = rc ? rc : in->end_record(in, tag); return rc; } void deallocate_CreateTxnV0(struct CreateTxnV0*v){ deallocate_String(&v->path); deallocate_Buffer(&v->data); deallocate_ACL_vector(&v->acl); } int serialize_CreateTxn(struct oarchive *out, const char *tag, struct CreateTxn *v){ int rc; rc = out->start_record(out, tag); rc = rc ? rc : out->serialize_String(out, "path", &v->path); rc = rc ? rc : out->serialize_Buffer(out, "data", &v->data); rc = rc ? rc : serialize_ACL_vector(out, "acl", &v->acl); rc = rc ? rc : out->serialize_Bool(out, "ephemeral", &v->ephemeral); rc = rc ? rc : out->serialize_Int(out, "parentCVersion", &v->parentCVersion); rc = rc ? rc : out->end_record(out, tag); return rc; } int deserialize_CreateTxn(struct iarchive *in, const char *tag, struct CreateTxn*v){ int rc; rc = in->start_record(in, tag); rc = rc ? rc : in->deserialize_String(in, "path", &v->path); rc = rc ? rc : in->deserialize_Buffer(in, "data", &v->data); rc = rc ? rc : deserialize_ACL_vector(in, "acl", &v->acl); rc = rc ? rc : in->deserialize_Bool(in, "ephemeral", &v->ephemeral); rc = rc ? rc : in->deserialize_Int(in, "parentCVersion", &v->parentCVersion); rc = rc ? rc : in->end_record(in, tag); return rc; } void deallocate_CreateTxn(struct CreateTxn*v){ deallocate_String(&v->path); deallocate_Buffer(&v->data); deallocate_ACL_vector(&v->acl); } int serialize_CreateTTLTxn(struct oarchive *out, const char *tag, struct CreateTTLTxn *v){ int rc; rc = out->start_record(out, tag); rc = rc ? rc : out->serialize_String(out, "path", &v->path); rc = rc ? rc : out->serialize_Buffer(out, "data", &v->data); rc = rc ? rc : serialize_ACL_vector(out, "acl", &v->acl); rc = rc ? rc : out->serialize_Int(out, "parentCVersion", &v->parentCVersion); rc = rc ? rc : out->serialize_Long(out, "ttl", &v->ttl); rc = rc ? rc : out->end_record(out, tag); return rc; } int deserialize_CreateTTLTxn(struct iarchive *in, const char *tag, struct CreateTTLTxn*v){ int rc; rc = in->start_record(in, tag); rc = rc ? rc : in->deserialize_String(in, "path", &v->path); rc = rc ? rc : in->deserialize_Buffer(in, "data", &v->data); rc = rc ? rc : deserialize_ACL_vector(in, "acl", &v->acl); rc = rc ? rc : in->deserialize_Int(in, "parentCVersion", &v->parentCVersion); rc = rc ? rc : in->deserialize_Long(in, "ttl", &v->ttl); rc = rc ? rc : in->end_record(in, tag); return rc; } void deallocate_CreateTTLTxn(struct CreateTTLTxn*v){ deallocate_String(&v->path); deallocate_Buffer(&v->data); deallocate_ACL_vector(&v->acl); } int serialize_CreateContainerTxn(struct oarchive *out, const char *tag, struct CreateContainerTxn *v){ int rc; rc = out->start_record(out, tag); rc = rc ? rc : out->serialize_String(out, "path", &v->path); rc = rc ? rc : out->serialize_Buffer(out, "data", &v->data); rc = rc ? rc : serialize_ACL_vector(out, "acl", &v->acl); rc = rc ? rc : out->serialize_Int(out, "parentCVersion", &v->parentCVersion); rc = rc ? rc : out->end_record(out, tag); return rc; } int deserialize_CreateContainerTxn(struct iarchive *in, const char *tag, struct CreateContainerTxn*v){ int rc; rc = in->start_record(in, tag); rc = rc ? rc : in->deserialize_String(in, "path", &v->path); rc = rc ? rc : in->deserialize_Buffer(in, "data", &v->data); rc = rc ? rc : deserialize_ACL_vector(in, "acl", &v->acl); rc = rc ? rc : in->deserialize_Int(in, "parentCVersion", &v->parentCVersion); rc = rc ? rc : in->end_record(in, tag); return rc; } void deallocate_CreateContainerTxn(struct CreateContainerTxn*v){ deallocate_String(&v->path); deallocate_Buffer(&v->data); deallocate_ACL_vector(&v->acl); } int serialize_DeleteTxn(struct oarchive *out, const char *tag, struct DeleteTxn *v){ int rc; rc = out->start_record(out, tag); rc = rc ? rc : out->serialize_String(out, "path", &v->path); rc = rc ? rc : out->end_record(out, tag); return rc; } int deserialize_DeleteTxn(struct iarchive *in, const char *tag, struct DeleteTxn*v){ int rc; rc = in->start_record(in, tag); rc = rc ? rc : in->deserialize_String(in, "path", &v->path); rc = rc ? rc : in->end_record(in, tag); return rc; } void deallocate_DeleteTxn(struct DeleteTxn*v){ deallocate_String(&v->path); } int serialize_SetDataTxn(struct oarchive *out, const char *tag, struct SetDataTxn *v){ int rc; rc = out->start_record(out, tag); rc = rc ? rc : out->serialize_String(out, "path", &v->path); rc = rc ? rc : out->serialize_Buffer(out, "data", &v->data); rc = rc ? rc : out->serialize_Int(out, "version", &v->version); rc = rc ? rc : out->end_record(out, tag); return rc; } int deserialize_SetDataTxn(struct iarchive *in, const char *tag, struct SetDataTxn*v){ int rc; rc = in->start_record(in, tag); rc = rc ? rc : in->deserialize_String(in, "path", &v->path); rc = rc ? rc : in->deserialize_Buffer(in, "data", &v->data); rc = rc ? rc : in->deserialize_Int(in, "version", &v->version); rc = rc ? rc : in->end_record(in, tag); return rc; } void deallocate_SetDataTxn(struct SetDataTxn*v){ deallocate_String(&v->path); deallocate_Buffer(&v->data); } int serialize_CheckVersionTxn(struct oarchive *out, const char *tag, struct CheckVersionTxn *v){ int rc; rc = out->start_record(out, tag); rc = rc ? rc : out->serialize_String(out, "path", &v->path); rc = rc ? rc : out->serialize_Int(out, "version", &v->version); rc = rc ? rc : out->end_record(out, tag); return rc; } int deserialize_CheckVersionTxn(struct iarchive *in, const char *tag, struct CheckVersionTxn*v){ int rc; rc = in->start_record(in, tag); rc = rc ? rc : in->deserialize_String(in, "path", &v->path); rc = rc ? rc : in->deserialize_Int(in, "version", &v->version); rc = rc ? rc : in->end_record(in, tag); return rc; } void deallocate_CheckVersionTxn(struct CheckVersionTxn*v){ deallocate_String(&v->path); } int serialize_SetACLTxn(struct oarchive *out, const char *tag, struct SetACLTxn *v){ int rc; rc = out->start_record(out, tag); rc = rc ? rc : out->serialize_String(out, "path", &v->path); rc = rc ? rc : serialize_ACL_vector(out, "acl", &v->acl); rc = rc ? rc : out->serialize_Int(out, "version", &v->version); rc = rc ? rc : out->end_record(out, tag); return rc; } int deserialize_SetACLTxn(struct iarchive *in, const char *tag, struct SetACLTxn*v){ int rc; rc = in->start_record(in, tag); rc = rc ? rc : in->deserialize_String(in, "path", &v->path); rc = rc ? rc : deserialize_ACL_vector(in, "acl", &v->acl); rc = rc ? rc : in->deserialize_Int(in, "version", &v->version); rc = rc ? rc : in->end_record(in, tag); return rc; } void deallocate_SetACLTxn(struct SetACLTxn*v){ deallocate_String(&v->path); deallocate_ACL_vector(&v->acl); } int serialize_SetMaxChildrenTxn(struct oarchive *out, const char *tag, struct SetMaxChildrenTxn *v){ int rc; rc = out->start_record(out, tag); rc = rc ? rc : out->serialize_String(out, "path", &v->path); rc = rc ? rc : out->serialize_Int(out, "max", &v->max); rc = rc ? rc : out->end_record(out, tag); return rc; } int deserialize_SetMaxChildrenTxn(struct iarchive *in, const char *tag, struct SetMaxChildrenTxn*v){ int rc; rc = in->start_record(in, tag); rc = rc ? rc : in->deserialize_String(in, "path", &v->path); rc = rc ? rc : in->deserialize_Int(in, "max", &v->max); rc = rc ? rc : in->end_record(in, tag); return rc; } void deallocate_SetMaxChildrenTxn(struct SetMaxChildrenTxn*v){ deallocate_String(&v->path); } int serialize_CreateSessionTxn(struct oarchive *out, const char *tag, struct CreateSessionTxn *v){ int rc; rc = out->start_record(out, tag); rc = rc ? rc : out->serialize_Int(out, "timeOut", &v->timeOut); rc = rc ? rc : out->end_record(out, tag); return rc; } int deserialize_CreateSessionTxn(struct iarchive *in, const char *tag, struct CreateSessionTxn*v){ int rc; rc = in->start_record(in, tag); rc = rc ? rc : in->deserialize_Int(in, "timeOut", &v->timeOut); rc = rc ? rc : in->end_record(in, tag); return rc; } void deallocate_CreateSessionTxn(struct CreateSessionTxn*v){ } int serialize_CloseSessionTxn(struct oarchive *out, const char *tag, struct CloseSessionTxn *v){ int rc; rc = out->start_record(out, tag); rc = rc ? rc : serialize_String_vector(out, "paths2Delete", &v->paths2Delete); rc = rc ? rc : out->end_record(out, tag); return rc; } int deserialize_CloseSessionTxn(struct iarchive *in, const char *tag, struct CloseSessionTxn*v){ int rc; rc = in->start_record(in, tag); rc = rc ? rc : deserialize_String_vector(in, "paths2Delete", &v->paths2Delete); rc = rc ? rc : in->end_record(in, tag); return rc; } void deallocate_CloseSessionTxn(struct CloseSessionTxn*v){ deallocate_String_vector(&v->paths2Delete); } int serialize_ErrorTxn(struct oarchive *out, const char *tag, struct ErrorTxn *v){ int rc; rc = out->start_record(out, tag); rc = rc ? rc : out->serialize_Int(out, "err", &v->err); rc = rc ? rc : out->end_record(out, tag); return rc; } int deserialize_ErrorTxn(struct iarchive *in, const char *tag, struct ErrorTxn*v){ int rc; rc = in->start_record(in, tag); rc = rc ? rc : in->deserialize_Int(in, "err", &v->err); rc = rc ? rc : in->end_record(in, tag); return rc; } void deallocate_ErrorTxn(struct ErrorTxn*v){ } int serialize_Txn(struct oarchive *out, const char *tag, struct Txn *v){ int rc; rc = out->start_record(out, tag); rc = rc ? rc : out->serialize_Int(out, "type", &v->type); rc = rc ? rc : out->serialize_Buffer(out, "data", &v->data); rc = rc ? rc : out->end_record(out, tag); return rc; } int deserialize_Txn(struct iarchive *in, const char *tag, struct Txn*v){ int rc; rc = in->start_record(in, tag); rc = rc ? rc : in->deserialize_Int(in, "type", &v->type); rc = rc ? rc : in->deserialize_Buffer(in, "data", &v->data); rc = rc ? rc : in->end_record(in, tag); return rc; } void deallocate_Txn(struct Txn*v){ deallocate_Buffer(&v->data); } int allocate_Txn_vector(struct Txn_vector *v, int32_t len) { if (!len) { v->count = 0; v->data = 0; } else { v->count = len; v->data = calloc(sizeof(*v->data), len); } return 0; } int deallocate_Txn_vector(struct Txn_vector *v) { if (v->data) { int32_t i; for(i=0;icount; i++) { deallocate_Txn(&v->data[i]); } free(v->data); v->data = 0; } return 0; } int serialize_Txn_vector(struct oarchive *out, const char *tag, struct Txn_vector *v) { int32_t count = v->count; int rc = 0; int32_t i; rc = out->start_vector(out, tag, &count); for(i=0;icount;i++) { rc = rc ? rc : serialize_Txn(out, "data", &v->data[i]); } rc = rc ? rc : out->end_vector(out, tag); return rc; } int deserialize_Txn_vector(struct iarchive *in, const char *tag, struct Txn_vector *v) { int rc = 0; int32_t i; rc = in->start_vector(in, tag, &v->count); v->data = calloc(v->count, sizeof(*v->data)); for(i=0;icount;i++) { rc = rc ? rc : deserialize_Txn(in, "value", &v->data[i]); } rc = in->end_vector(in, tag); return rc; } int serialize_MultiTxn(struct oarchive *out, const char *tag, struct MultiTxn *v){ int rc; rc = out->start_record(out, tag); rc = rc ? rc : serialize_Txn_vector(out, "txns", &v->txns); rc = rc ? rc : out->end_record(out, tag); return rc; } int deserialize_MultiTxn(struct iarchive *in, const char *tag, struct MultiTxn*v){ int rc; rc = in->start_record(in, tag); rc = rc ? rc : deserialize_Txn_vector(in, "txns", &v->txns); rc = rc ? rc : in->end_record(in, tag); return rc; } void deallocate_MultiTxn(struct MultiTxn*v){ deallocate_Txn_vector(&v->txns); } diff --git a/devel/libzookeeper/files/zookeeper.jute.h b/devel/libzookeeper/files/zookeeper.jute.h index b02063a2a34c..c4899db3fc06 100644 --- a/devel/libzookeeper/files/zookeeper.jute.h +++ b/devel/libzookeeper/files/zookeeper.jute.h @@ -1,595 +1,617 @@ /** * Licensed to the Apache Software Foundation (ASF) under one * or more contributor license agreements. See the NOTICE file * distributed with this work for additional information * regarding copyright ownership. The ASF licenses this file * to you under the Apache License, Version 2.0 (the * "License"); you may not use this file except in compliance * with the License. You may obtain a copy of the License at * * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * See the License for the specific language governing permissions and * limitations under the License. */ #ifndef __ZOOKEEPER_JUTE__ #define __ZOOKEEPER_JUTE__ #include "recordio.h" #ifdef __cplusplus extern "C" { #endif struct Id { char * scheme; char * id; }; int serialize_Id(struct oarchive *out, const char *tag, struct Id *v); int deserialize_Id(struct iarchive *in, const char *tag, struct Id*v); void deallocate_Id(struct Id*); struct ACL { int32_t perms; struct Id id; }; int serialize_ACL(struct oarchive *out, const char *tag, struct ACL *v); int deserialize_ACL(struct iarchive *in, const char *tag, struct ACL*v); void deallocate_ACL(struct ACL*); struct Stat { int64_t czxid; int64_t mzxid; int64_t ctime; int64_t mtime; int32_t version; int32_t cversion; int32_t aversion; int64_t ephemeralOwner; int32_t dataLength; int32_t numChildren; int64_t pzxid; }; int serialize_Stat(struct oarchive *out, const char *tag, struct Stat *v); int deserialize_Stat(struct iarchive *in, const char *tag, struct Stat*v); void deallocate_Stat(struct Stat*); struct StatPersisted { int64_t czxid; int64_t mzxid; int64_t ctime; int64_t mtime; int32_t version; int32_t cversion; int32_t aversion; int64_t ephemeralOwner; int64_t pzxid; }; int serialize_StatPersisted(struct oarchive *out, const char *tag, struct StatPersisted *v); int deserialize_StatPersisted(struct iarchive *in, const char *tag, struct StatPersisted*v); void deallocate_StatPersisted(struct StatPersisted*); +struct ClientInfo { + char * authScheme; + char * user; +}; +int serialize_ClientInfo(struct oarchive *out, const char *tag, struct ClientInfo *v); +int deserialize_ClientInfo(struct iarchive *in, const char *tag, struct ClientInfo*v); +void deallocate_ClientInfo(struct ClientInfo*); struct ConnectRequest { int32_t protocolVersion; int64_t lastZxidSeen; int32_t timeOut; int64_t sessionId; struct buffer passwd; }; int serialize_ConnectRequest(struct oarchive *out, const char *tag, struct ConnectRequest *v); int deserialize_ConnectRequest(struct iarchive *in, const char *tag, struct ConnectRequest*v); void deallocate_ConnectRequest(struct ConnectRequest*); struct ConnectResponse { int32_t protocolVersion; int32_t timeOut; int64_t sessionId; struct buffer passwd; }; int serialize_ConnectResponse(struct oarchive *out, const char *tag, struct ConnectResponse *v); int deserialize_ConnectResponse(struct iarchive *in, const char *tag, struct ConnectResponse*v); void deallocate_ConnectResponse(struct ConnectResponse*); struct String_vector { int32_t count; char * *data; }; int serialize_String_vector(struct oarchive *out, const char *tag, struct String_vector *v); int deserialize_String_vector(struct iarchive *in, const char *tag, struct String_vector *v); int allocate_String_vector(struct String_vector *v, int32_t len); int deallocate_String_vector(struct String_vector *v); struct SetWatches { int64_t relativeZxid; struct String_vector dataWatches; struct String_vector existWatches; struct String_vector childWatches; }; int serialize_SetWatches(struct oarchive *out, const char *tag, struct SetWatches *v); int deserialize_SetWatches(struct iarchive *in, const char *tag, struct SetWatches*v); void deallocate_SetWatches(struct SetWatches*); struct SetWatches2 { int64_t relativeZxid; struct String_vector dataWatches; struct String_vector existWatches; struct String_vector childWatches; struct String_vector persistentWatches; struct String_vector persistentRecursiveWatches; }; int serialize_SetWatches2(struct oarchive *out, const char *tag, struct SetWatches2 *v); int deserialize_SetWatches2(struct iarchive *in, const char *tag, struct SetWatches2*v); void deallocate_SetWatches2(struct SetWatches2*); struct RequestHeader { int32_t xid; int32_t type; }; int serialize_RequestHeader(struct oarchive *out, const char *tag, struct RequestHeader *v); int deserialize_RequestHeader(struct iarchive *in, const char *tag, struct RequestHeader*v); void deallocate_RequestHeader(struct RequestHeader*); struct MultiHeader { int32_t type; int32_t done; int32_t err; }; int serialize_MultiHeader(struct oarchive *out, const char *tag, struct MultiHeader *v); int deserialize_MultiHeader(struct iarchive *in, const char *tag, struct MultiHeader*v); void deallocate_MultiHeader(struct MultiHeader*); struct AuthPacket { int32_t type; char * scheme; struct buffer auth; }; int serialize_AuthPacket(struct oarchive *out, const char *tag, struct AuthPacket *v); int deserialize_AuthPacket(struct iarchive *in, const char *tag, struct AuthPacket*v); void deallocate_AuthPacket(struct AuthPacket*); struct ReplyHeader { int32_t xid; int64_t zxid; int32_t err; }; int serialize_ReplyHeader(struct oarchive *out, const char *tag, struct ReplyHeader *v); int deserialize_ReplyHeader(struct iarchive *in, const char *tag, struct ReplyHeader*v); void deallocate_ReplyHeader(struct ReplyHeader*); struct GetDataRequest { char * path; int32_t watch; }; int serialize_GetDataRequest(struct oarchive *out, const char *tag, struct GetDataRequest *v); int deserialize_GetDataRequest(struct iarchive *in, const char *tag, struct GetDataRequest*v); void deallocate_GetDataRequest(struct GetDataRequest*); struct SetDataRequest { char * path; struct buffer data; int32_t version; }; int serialize_SetDataRequest(struct oarchive *out, const char *tag, struct SetDataRequest *v); int deserialize_SetDataRequest(struct iarchive *in, const char *tag, struct SetDataRequest*v); void deallocate_SetDataRequest(struct SetDataRequest*); struct ReconfigRequest { char * joiningServers; char * leavingServers; char * newMembers; int64_t curConfigId; }; int serialize_ReconfigRequest(struct oarchive *out, const char *tag, struct ReconfigRequest *v); int deserialize_ReconfigRequest(struct iarchive *in, const char *tag, struct ReconfigRequest*v); void deallocate_ReconfigRequest(struct ReconfigRequest*); struct SetDataResponse { struct Stat stat; }; int serialize_SetDataResponse(struct oarchive *out, const char *tag, struct SetDataResponse *v); int deserialize_SetDataResponse(struct iarchive *in, const char *tag, struct SetDataResponse*v); void deallocate_SetDataResponse(struct SetDataResponse*); struct GetSASLRequest { struct buffer token; }; int serialize_GetSASLRequest(struct oarchive *out, const char *tag, struct GetSASLRequest *v); int deserialize_GetSASLRequest(struct iarchive *in, const char *tag, struct GetSASLRequest*v); void deallocate_GetSASLRequest(struct GetSASLRequest*); struct SetSASLRequest { struct buffer token; }; int serialize_SetSASLRequest(struct oarchive *out, const char *tag, struct SetSASLRequest *v); int deserialize_SetSASLRequest(struct iarchive *in, const char *tag, struct SetSASLRequest*v); void deallocate_SetSASLRequest(struct SetSASLRequest*); struct SetSASLResponse { struct buffer token; }; int serialize_SetSASLResponse(struct oarchive *out, const char *tag, struct SetSASLResponse *v); int deserialize_SetSASLResponse(struct iarchive *in, const char *tag, struct SetSASLResponse*v); void deallocate_SetSASLResponse(struct SetSASLResponse*); struct ACL_vector { int32_t count; struct ACL *data; }; int serialize_ACL_vector(struct oarchive *out, const char *tag, struct ACL_vector *v); int deserialize_ACL_vector(struct iarchive *in, const char *tag, struct ACL_vector *v); int allocate_ACL_vector(struct ACL_vector *v, int32_t len); int deallocate_ACL_vector(struct ACL_vector *v); struct CreateRequest { char * path; struct buffer data; struct ACL_vector acl; int32_t flags; }; int serialize_CreateRequest(struct oarchive *out, const char *tag, struct CreateRequest *v); int deserialize_CreateRequest(struct iarchive *in, const char *tag, struct CreateRequest*v); void deallocate_CreateRequest(struct CreateRequest*); struct CreateTTLRequest { char * path; struct buffer data; struct ACL_vector acl; int32_t flags; int64_t ttl; }; int serialize_CreateTTLRequest(struct oarchive *out, const char *tag, struct CreateTTLRequest *v); int deserialize_CreateTTLRequest(struct iarchive *in, const char *tag, struct CreateTTLRequest*v); void deallocate_CreateTTLRequest(struct CreateTTLRequest*); struct DeleteRequest { char * path; int32_t version; }; int serialize_DeleteRequest(struct oarchive *out, const char *tag, struct DeleteRequest *v); int deserialize_DeleteRequest(struct iarchive *in, const char *tag, struct DeleteRequest*v); void deallocate_DeleteRequest(struct DeleteRequest*); struct GetChildrenRequest { char * path; int32_t watch; }; int serialize_GetChildrenRequest(struct oarchive *out, const char *tag, struct GetChildrenRequest *v); int deserialize_GetChildrenRequest(struct iarchive *in, const char *tag, struct GetChildrenRequest*v); void deallocate_GetChildrenRequest(struct GetChildrenRequest*); struct GetAllChildrenNumberRequest { char * path; }; int serialize_GetAllChildrenNumberRequest(struct oarchive *out, const char *tag, struct GetAllChildrenNumberRequest *v); int deserialize_GetAllChildrenNumberRequest(struct iarchive *in, const char *tag, struct GetAllChildrenNumberRequest*v); void deallocate_GetAllChildrenNumberRequest(struct GetAllChildrenNumberRequest*); struct GetChildren2Request { char * path; int32_t watch; }; int serialize_GetChildren2Request(struct oarchive *out, const char *tag, struct GetChildren2Request *v); int deserialize_GetChildren2Request(struct iarchive *in, const char *tag, struct GetChildren2Request*v); void deallocate_GetChildren2Request(struct GetChildren2Request*); struct CheckVersionRequest { char * path; int32_t version; }; int serialize_CheckVersionRequest(struct oarchive *out, const char *tag, struct CheckVersionRequest *v); int deserialize_CheckVersionRequest(struct iarchive *in, const char *tag, struct CheckVersionRequest*v); void deallocate_CheckVersionRequest(struct CheckVersionRequest*); struct GetMaxChildrenRequest { char * path; }; int serialize_GetMaxChildrenRequest(struct oarchive *out, const char *tag, struct GetMaxChildrenRequest *v); int deserialize_GetMaxChildrenRequest(struct iarchive *in, const char *tag, struct GetMaxChildrenRequest*v); void deallocate_GetMaxChildrenRequest(struct GetMaxChildrenRequest*); struct GetMaxChildrenResponse { int32_t max; }; int serialize_GetMaxChildrenResponse(struct oarchive *out, const char *tag, struct GetMaxChildrenResponse *v); int deserialize_GetMaxChildrenResponse(struct iarchive *in, const char *tag, struct GetMaxChildrenResponse*v); void deallocate_GetMaxChildrenResponse(struct GetMaxChildrenResponse*); struct SetMaxChildrenRequest { char * path; int32_t max; }; int serialize_SetMaxChildrenRequest(struct oarchive *out, const char *tag, struct SetMaxChildrenRequest *v); int deserialize_SetMaxChildrenRequest(struct iarchive *in, const char *tag, struct SetMaxChildrenRequest*v); void deallocate_SetMaxChildrenRequest(struct SetMaxChildrenRequest*); struct SyncRequest { char * path; }; int serialize_SyncRequest(struct oarchive *out, const char *tag, struct SyncRequest *v); int deserialize_SyncRequest(struct iarchive *in, const char *tag, struct SyncRequest*v); void deallocate_SyncRequest(struct SyncRequest*); struct SyncResponse { char * path; }; int serialize_SyncResponse(struct oarchive *out, const char *tag, struct SyncResponse *v); int deserialize_SyncResponse(struct iarchive *in, const char *tag, struct SyncResponse*v); void deallocate_SyncResponse(struct SyncResponse*); struct GetACLRequest { char * path; }; int serialize_GetACLRequest(struct oarchive *out, const char *tag, struct GetACLRequest *v); int deserialize_GetACLRequest(struct iarchive *in, const char *tag, struct GetACLRequest*v); void deallocate_GetACLRequest(struct GetACLRequest*); struct SetACLRequest { char * path; struct ACL_vector acl; int32_t version; }; int serialize_SetACLRequest(struct oarchive *out, const char *tag, struct SetACLRequest *v); int deserialize_SetACLRequest(struct iarchive *in, const char *tag, struct SetACLRequest*v); void deallocate_SetACLRequest(struct SetACLRequest*); struct SetACLResponse { struct Stat stat; }; int serialize_SetACLResponse(struct oarchive *out, const char *tag, struct SetACLResponse *v); int deserialize_SetACLResponse(struct iarchive *in, const char *tag, struct SetACLResponse*v); void deallocate_SetACLResponse(struct SetACLResponse*); struct AddWatchRequest { char * path; int32_t mode; }; int serialize_AddWatchRequest(struct oarchive *out, const char *tag, struct AddWatchRequest *v); int deserialize_AddWatchRequest(struct iarchive *in, const char *tag, struct AddWatchRequest*v); void deallocate_AddWatchRequest(struct AddWatchRequest*); struct WatcherEvent { int32_t type; int32_t state; char * path; }; int serialize_WatcherEvent(struct oarchive *out, const char *tag, struct WatcherEvent *v); int deserialize_WatcherEvent(struct iarchive *in, const char *tag, struct WatcherEvent*v); void deallocate_WatcherEvent(struct WatcherEvent*); struct ErrorResponse { int32_t err; }; int serialize_ErrorResponse(struct oarchive *out, const char *tag, struct ErrorResponse *v); int deserialize_ErrorResponse(struct iarchive *in, const char *tag, struct ErrorResponse*v); void deallocate_ErrorResponse(struct ErrorResponse*); struct CreateResponse { char * path; }; int serialize_CreateResponse(struct oarchive *out, const char *tag, struct CreateResponse *v); int deserialize_CreateResponse(struct iarchive *in, const char *tag, struct CreateResponse*v); void deallocate_CreateResponse(struct CreateResponse*); struct Create2Response { char * path; struct Stat stat; }; int serialize_Create2Response(struct oarchive *out, const char *tag, struct Create2Response *v); int deserialize_Create2Response(struct iarchive *in, const char *tag, struct Create2Response*v); void deallocate_Create2Response(struct Create2Response*); struct ExistsRequest { char * path; int32_t watch; }; int serialize_ExistsRequest(struct oarchive *out, const char *tag, struct ExistsRequest *v); int deserialize_ExistsRequest(struct iarchive *in, const char *tag, struct ExistsRequest*v); void deallocate_ExistsRequest(struct ExistsRequest*); struct ExistsResponse { struct Stat stat; }; int serialize_ExistsResponse(struct oarchive *out, const char *tag, struct ExistsResponse *v); int deserialize_ExistsResponse(struct iarchive *in, const char *tag, struct ExistsResponse*v); void deallocate_ExistsResponse(struct ExistsResponse*); struct GetDataResponse { struct buffer data; struct Stat stat; }; int serialize_GetDataResponse(struct oarchive *out, const char *tag, struct GetDataResponse *v); int deserialize_GetDataResponse(struct iarchive *in, const char *tag, struct GetDataResponse*v); void deallocate_GetDataResponse(struct GetDataResponse*); struct GetChildrenResponse { struct String_vector children; }; int serialize_GetChildrenResponse(struct oarchive *out, const char *tag, struct GetChildrenResponse *v); int deserialize_GetChildrenResponse(struct iarchive *in, const char *tag, struct GetChildrenResponse*v); void deallocate_GetChildrenResponse(struct GetChildrenResponse*); struct GetAllChildrenNumberResponse { int32_t totalNumber; }; int serialize_GetAllChildrenNumberResponse(struct oarchive *out, const char *tag, struct GetAllChildrenNumberResponse *v); int deserialize_GetAllChildrenNumberResponse(struct iarchive *in, const char *tag, struct GetAllChildrenNumberResponse*v); void deallocate_GetAllChildrenNumberResponse(struct GetAllChildrenNumberResponse*); struct GetChildren2Response { struct String_vector children; struct Stat stat; }; int serialize_GetChildren2Response(struct oarchive *out, const char *tag, struct GetChildren2Response *v); int deserialize_GetChildren2Response(struct iarchive *in, const char *tag, struct GetChildren2Response*v); void deallocate_GetChildren2Response(struct GetChildren2Response*); struct GetACLResponse { struct ACL_vector acl; struct Stat stat; }; int serialize_GetACLResponse(struct oarchive *out, const char *tag, struct GetACLResponse *v); int deserialize_GetACLResponse(struct iarchive *in, const char *tag, struct GetACLResponse*v); void deallocate_GetACLResponse(struct GetACLResponse*); struct CheckWatchesRequest { char * path; int32_t type; }; int serialize_CheckWatchesRequest(struct oarchive *out, const char *tag, struct CheckWatchesRequest *v); int deserialize_CheckWatchesRequest(struct iarchive *in, const char *tag, struct CheckWatchesRequest*v); void deallocate_CheckWatchesRequest(struct CheckWatchesRequest*); struct RemoveWatchesRequest { char * path; int32_t type; }; int serialize_RemoveWatchesRequest(struct oarchive *out, const char *tag, struct RemoveWatchesRequest *v); int deserialize_RemoveWatchesRequest(struct iarchive *in, const char *tag, struct RemoveWatchesRequest*v); void deallocate_RemoveWatchesRequest(struct RemoveWatchesRequest*); struct GetEphemeralsRequest { char * prefixPath; }; int serialize_GetEphemeralsRequest(struct oarchive *out, const char *tag, struct GetEphemeralsRequest *v); int deserialize_GetEphemeralsRequest(struct iarchive *in, const char *tag, struct GetEphemeralsRequest*v); void deallocate_GetEphemeralsRequest(struct GetEphemeralsRequest*); struct GetEphemeralsResponse { struct String_vector ephemerals; }; int serialize_GetEphemeralsResponse(struct oarchive *out, const char *tag, struct GetEphemeralsResponse *v); int deserialize_GetEphemeralsResponse(struct iarchive *in, const char *tag, struct GetEphemeralsResponse*v); void deallocate_GetEphemeralsResponse(struct GetEphemeralsResponse*); +struct ClientInfo_vector { + int32_t count; + struct ClientInfo *data; + +}; +int serialize_ClientInfo_vector(struct oarchive *out, const char *tag, struct ClientInfo_vector *v); +int deserialize_ClientInfo_vector(struct iarchive *in, const char *tag, struct ClientInfo_vector *v); +int allocate_ClientInfo_vector(struct ClientInfo_vector *v, int32_t len); +int deallocate_ClientInfo_vector(struct ClientInfo_vector *v); +struct WhoAmIResponse { + struct ClientInfo_vector clientInfo; +}; +int serialize_WhoAmIResponse(struct oarchive *out, const char *tag, struct WhoAmIResponse *v); +int deserialize_WhoAmIResponse(struct iarchive *in, const char *tag, struct WhoAmIResponse*v); +void deallocate_WhoAmIResponse(struct WhoAmIResponse*); struct LearnerInfo { int64_t serverid; int32_t protocolVersion; int64_t configVersion; }; int serialize_LearnerInfo(struct oarchive *out, const char *tag, struct LearnerInfo *v); int deserialize_LearnerInfo(struct iarchive *in, const char *tag, struct LearnerInfo*v); void deallocate_LearnerInfo(struct LearnerInfo*); struct Id_vector { int32_t count; struct Id *data; }; int serialize_Id_vector(struct oarchive *out, const char *tag, struct Id_vector *v); int deserialize_Id_vector(struct iarchive *in, const char *tag, struct Id_vector *v); int allocate_Id_vector(struct Id_vector *v, int32_t len); int deallocate_Id_vector(struct Id_vector *v); struct QuorumPacket { int32_t type; int64_t zxid; struct buffer data; struct Id_vector authinfo; }; int serialize_QuorumPacket(struct oarchive *out, const char *tag, struct QuorumPacket *v); int deserialize_QuorumPacket(struct iarchive *in, const char *tag, struct QuorumPacket*v); void deallocate_QuorumPacket(struct QuorumPacket*); struct QuorumAuthPacket { int64_t magic; int32_t status; struct buffer token; }; int serialize_QuorumAuthPacket(struct oarchive *out, const char *tag, struct QuorumAuthPacket *v); int deserialize_QuorumAuthPacket(struct iarchive *in, const char *tag, struct QuorumAuthPacket*v); void deallocate_QuorumAuthPacket(struct QuorumAuthPacket*); struct FileHeader { int32_t magic; int32_t version; int64_t dbid; }; int serialize_FileHeader(struct oarchive *out, const char *tag, struct FileHeader *v); int deserialize_FileHeader(struct iarchive *in, const char *tag, struct FileHeader*v); void deallocate_FileHeader(struct FileHeader*); struct TxnDigest { int32_t version; int64_t treeDigest; }; int serialize_TxnDigest(struct oarchive *out, const char *tag, struct TxnDigest *v); int deserialize_TxnDigest(struct iarchive *in, const char *tag, struct TxnDigest*v); void deallocate_TxnDigest(struct TxnDigest*); struct TxnHeader { int64_t clientId; int32_t cxid; int64_t zxid; int64_t time; int32_t type; }; int serialize_TxnHeader(struct oarchive *out, const char *tag, struct TxnHeader *v); int deserialize_TxnHeader(struct iarchive *in, const char *tag, struct TxnHeader*v); void deallocate_TxnHeader(struct TxnHeader*); struct CreateTxnV0 { char * path; struct buffer data; struct ACL_vector acl; int32_t ephemeral; }; int serialize_CreateTxnV0(struct oarchive *out, const char *tag, struct CreateTxnV0 *v); int deserialize_CreateTxnV0(struct iarchive *in, const char *tag, struct CreateTxnV0*v); void deallocate_CreateTxnV0(struct CreateTxnV0*); struct CreateTxn { char * path; struct buffer data; struct ACL_vector acl; int32_t ephemeral; int32_t parentCVersion; }; int serialize_CreateTxn(struct oarchive *out, const char *tag, struct CreateTxn *v); int deserialize_CreateTxn(struct iarchive *in, const char *tag, struct CreateTxn*v); void deallocate_CreateTxn(struct CreateTxn*); struct CreateTTLTxn { char * path; struct buffer data; struct ACL_vector acl; int32_t parentCVersion; int64_t ttl; }; int serialize_CreateTTLTxn(struct oarchive *out, const char *tag, struct CreateTTLTxn *v); int deserialize_CreateTTLTxn(struct iarchive *in, const char *tag, struct CreateTTLTxn*v); void deallocate_CreateTTLTxn(struct CreateTTLTxn*); struct CreateContainerTxn { char * path; struct buffer data; struct ACL_vector acl; int32_t parentCVersion; }; int serialize_CreateContainerTxn(struct oarchive *out, const char *tag, struct CreateContainerTxn *v); int deserialize_CreateContainerTxn(struct iarchive *in, const char *tag, struct CreateContainerTxn*v); void deallocate_CreateContainerTxn(struct CreateContainerTxn*); struct DeleteTxn { char * path; }; int serialize_DeleteTxn(struct oarchive *out, const char *tag, struct DeleteTxn *v); int deserialize_DeleteTxn(struct iarchive *in, const char *tag, struct DeleteTxn*v); void deallocate_DeleteTxn(struct DeleteTxn*); struct SetDataTxn { char * path; struct buffer data; int32_t version; }; int serialize_SetDataTxn(struct oarchive *out, const char *tag, struct SetDataTxn *v); int deserialize_SetDataTxn(struct iarchive *in, const char *tag, struct SetDataTxn*v); void deallocate_SetDataTxn(struct SetDataTxn*); struct CheckVersionTxn { char * path; int32_t version; }; int serialize_CheckVersionTxn(struct oarchive *out, const char *tag, struct CheckVersionTxn *v); int deserialize_CheckVersionTxn(struct iarchive *in, const char *tag, struct CheckVersionTxn*v); void deallocate_CheckVersionTxn(struct CheckVersionTxn*); struct SetACLTxn { char * path; struct ACL_vector acl; int32_t version; }; int serialize_SetACLTxn(struct oarchive *out, const char *tag, struct SetACLTxn *v); int deserialize_SetACLTxn(struct iarchive *in, const char *tag, struct SetACLTxn*v); void deallocate_SetACLTxn(struct SetACLTxn*); struct SetMaxChildrenTxn { char * path; int32_t max; }; int serialize_SetMaxChildrenTxn(struct oarchive *out, const char *tag, struct SetMaxChildrenTxn *v); int deserialize_SetMaxChildrenTxn(struct iarchive *in, const char *tag, struct SetMaxChildrenTxn*v); void deallocate_SetMaxChildrenTxn(struct SetMaxChildrenTxn*); struct CreateSessionTxn { int32_t timeOut; }; int serialize_CreateSessionTxn(struct oarchive *out, const char *tag, struct CreateSessionTxn *v); int deserialize_CreateSessionTxn(struct iarchive *in, const char *tag, struct CreateSessionTxn*v); void deallocate_CreateSessionTxn(struct CreateSessionTxn*); struct CloseSessionTxn { struct String_vector paths2Delete; }; int serialize_CloseSessionTxn(struct oarchive *out, const char *tag, struct CloseSessionTxn *v); int deserialize_CloseSessionTxn(struct iarchive *in, const char *tag, struct CloseSessionTxn*v); void deallocate_CloseSessionTxn(struct CloseSessionTxn*); struct ErrorTxn { int32_t err; }; int serialize_ErrorTxn(struct oarchive *out, const char *tag, struct ErrorTxn *v); int deserialize_ErrorTxn(struct iarchive *in, const char *tag, struct ErrorTxn*v); void deallocate_ErrorTxn(struct ErrorTxn*); struct Txn { int32_t type; struct buffer data; }; int serialize_Txn(struct oarchive *out, const char *tag, struct Txn *v); int deserialize_Txn(struct iarchive *in, const char *tag, struct Txn*v); void deallocate_Txn(struct Txn*); struct Txn_vector { int32_t count; struct Txn *data; }; int serialize_Txn_vector(struct oarchive *out, const char *tag, struct Txn_vector *v); int deserialize_Txn_vector(struct iarchive *in, const char *tag, struct Txn_vector *v); int allocate_Txn_vector(struct Txn_vector *v, int32_t len); int deallocate_Txn_vector(struct Txn_vector *v); struct MultiTxn { struct Txn_vector txns; }; int serialize_MultiTxn(struct oarchive *out, const char *tag, struct MultiTxn *v); int deserialize_MultiTxn(struct iarchive *in, const char *tag, struct MultiTxn*v); void deallocate_MultiTxn(struct MultiTxn*); #ifdef __cplusplus } #endif #endif //ZOOKEEPER_JUTE__