FreeBSD Bugzilla – Attachment 211876 Details for
Bug 241583
[Maintainer timeout] devel/{lib}zookeeper: Update to 3.5.7
Home
|
New
|
Browse
|
Search
|
[?]
|
Reports
|
Help
|
New Account
|
Log In
Remember
[x]
|
Forgot Password
Login:
[x]
[patch]
zookeeper.diff
zookeeper.diff (text/plain), 91.25 KB, created by
Dmitry Wagin
on 2020-02-23 23:15:25 UTC
(
hide
)
Description:
zookeeper.diff
Filename:
MIME Type:
Creator:
Dmitry Wagin
Created:
2020-02-23 23:15:25 UTC
Size:
91.25 KB
patch
obsolete
>Index: devel/libzookeeper/Makefile >=================================================================== >--- devel/libzookeeper/Makefile (revision 526928) >+++ devel/libzookeeper/Makefile (working copy) >@@ -2,9 +2,9 @@ > # $FreeBSD$ > > PORTNAME= zookeeper >-PORTVERSION= 3.5.5 >+PORTVERSION= 3.5.7 > CATEGORIES= devel >-MASTER_SITES= APACHE/${PORTNAME}/current >+MASTER_SITES= APACHE/${PORTNAME}/${PORTNAME}-${PORTVERSION} > PKGNAMEPREFIX= lib > DISTNAME= apache-${PORTNAME}-${PORTVERSION} > >@@ -23,6 +23,10 @@ > > 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 >Index: devel/libzookeeper/distinfo >=================================================================== >--- devel/libzookeeper/distinfo (revision 526928) >+++ devel/libzookeeper/distinfo (working copy) >@@ -1,3 +1,3 @@ >-TIMESTAMP = 1559402372 >-SHA256 (apache-zookeeper-3.5.5.tar.gz) = 60d527254b3816c75a1c46517768b873af5767dfcc2083d6c527b567461c546c >-SIZE (apache-zookeeper-3.5.5.tar.gz) = 3230972 >+TIMESTAMP = 1582496784 >+SHA256 (apache-zookeeper-3.5.7.tar.gz) = 7470d30b17cc77be3b58171d820c432bf5181310fbc62e941e2be2745f7300d4 >+SIZE (apache-zookeeper-3.5.7.tar.gz) = 3130819 >Index: devel/libzookeeper/files/zookeeper.jute.c >=================================================================== >--- devel/libzookeeper/files/zookeeper.jute.c (nonexistent) >+++ devel/libzookeeper/files/zookeeper.jute.c (working copy) >@@ -0,0 +1,1470 @@ >+/** >+* 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 <stdlib.h> >+#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_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;i<v->count; 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;i<v->count;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;i<v->count;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_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;i<v->count; 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;i<v->count;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;i<v->count;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_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_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_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_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;i<v->count; 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;i<v->count;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;i<v->count;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_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_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;i<v->count; 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;i<v->count;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;i<v->count;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); >+} > >Property changes on: devel/libzookeeper/files/zookeeper.jute.c >___________________________________________________________________ >Added: svn:eol-style >## -0,0 +1 ## >+native >\ No newline at end of property >Added: svn:mime-type >## -0,0 +1 ## >+text/plain >\ No newline at end of property >Index: devel/libzookeeper/files/zookeeper.jute.h >=================================================================== >--- devel/libzookeeper/files/zookeeper.jute.h (nonexistent) >+++ devel/libzookeeper/files/zookeeper.jute.h (working copy) >@@ -0,0 +1,540 @@ >+/** >+* 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 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 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 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 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 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 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 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 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__ > >Property changes on: devel/libzookeeper/files/zookeeper.jute.h >___________________________________________________________________ >Added: svn:eol-style >## -0,0 +1 ## >+native >\ No newline at end of property >Added: svn:mime-type >## -0,0 +1 ## >+text/plain >\ No newline at end of property >Index: devel/zookeeper/Makefile >=================================================================== >--- devel/zookeeper/Makefile (revision 526928) >+++ devel/zookeeper/Makefile (working copy) >@@ -1,9 +1,9 @@ > # $FreeBSD$ > > PORTNAME= zookeeper >-PORTVERSION= 3.5.5 >+PORTVERSION= 3.5.7 > CATEGORIES= devel java >-MASTER_SITES= APACHE/${PORTNAME}/current >+MASTER_SITES= APACHE/${PORTNAME}/${PORTNAME}-${PORTVERSION} > DISTNAME= apache-${PORTNAME}-${PORTVERSION}-bin > > MAINTAINER= skreuzer@FreeBSD.org >@@ -13,27 +13,27 @@ > > RUN_DEPENDS= libzookeeper>=${PORTVERSION}:devel/libzookeeper > >-USERS= zookeeper >-GROUPS= zookeeper >+ZOOKEEPER_CONFS?= configuration.xsl log4j.properties zoo.cfg >+ZOOKEEPER_USER?= zookeeper >+ZOOKEEPER_GROUP?= zookeeper >+ZOOKEEPER_DBDIR?= /var/db/zookeeper >+ZOOKEEPER_LOGDIR?= /var/log/zookeeper > >-ZOOKEEPER_CONFS= configuration.xsl log4j.properties zoo.cfg >+USERS= ${ZOOKEEPER_USER} >+GROUPS= ${ZOOKEEPER_GROUP} > >-DATADIR= ${JAVASHAREDIR}/${PORTNAME} >+DATADIR= ${JAVASHAREDIR}/${PORTNAME} > >-ZOOKEEPER_DBDIR?= /var/db/zookeeper >-ZOOKEEPER_LOGDIR?= /var/log/zookeeper >- >+USE_RC_SUBR= zookeeper > SUB_FILES= zookeeper zkCli.sh > SUB_LIST= JAVA=${JAVA} \ >- JAVALIBDIR=${JAVALIBDIR} \ >- ETCDIR=${ETCDIR} \ >- USERS=${USERS} \ >- GROUPS=${GROUPS} \ >+ ZOOKEEPER_USER=${ZOOKEEPER_USER} \ >+ ZOOKEEPER_GROUP=${ZOOKEEPER_GROUP} \ > ZOOKEEPER_LOGDIR=${ZOOKEEPER_LOGDIR} > > PLIST_SUB+= PORTVERSION=${PORTVERSION} \ >- USERS=${USERS} \ >- GROUPS=${GROUPS} \ >+ ZOOKEEPER_USER=${ZOOKEEPER_USER} \ >+ ZOOKEEPER_GROUP=${ZOOKEEPER_GROUP} \ > ZOOKEEPER_DBDIR=${ZOOKEEPER_DBDIR} \ > ZOOKEEPER_LOGDIR=${ZOOKEEPER_LOGDIR} > >@@ -40,9 +40,8 @@ > NO_BUILD= yes > NO_ARCH= yes > USE_JAVA= yes >-JAVA_VERSION= 1.8+ >+JAVA_VERSION= 8+ > JAVA_RUN= yes >-USE_RC_SUBR= zookeeper > > PORTDOCS= * > >Index: devel/zookeeper/distinfo >=================================================================== >--- devel/zookeeper/distinfo (revision 526928) >+++ devel/zookeeper/distinfo (working copy) >@@ -1,3 +1,3 @@ >-TIMESTAMP = 1559404113 >-SHA256 (apache-zookeeper-3.5.5-bin.tar.gz) = c5ff531cbda56c157199ab80632dc50ffefa8b7cbe866a0431345d3c4d72bbd1 >-SIZE (apache-zookeeper-3.5.5-bin.tar.gz) = 10622522 >+TIMESTAMP = 1582492095 >+SHA256 (apache-zookeeper-3.5.7-bin.tar.gz) = 65c5439571cb86bc865d2a4878c83a3ed606d20cf550672e64b9bfdbbf3a8a08 >+SIZE (apache-zookeeper-3.5.7-bin.tar.gz) = 9311744 >Index: devel/zookeeper/files/zookeeper.in >=================================================================== >--- devel/zookeeper/files/zookeeper.in (revision 526928) >+++ devel/zookeeper/files/zookeeper.in (working copy) >@@ -17,18 +17,31 @@ > > load_rc_config "${name}" > >-: ${zookeeper_enable:=NO} >-: ${zookeeper_user:=%%USERS%%} >-: ${zookeeper_pidfile:=/var/run/zookeeper.pid} >-: ${zookeeper_config:=%%ETCDIR%%/zoo.cfg} >-: ${zookeeper_log4jpropfile:=file:%%ETCDIR%%/log4j.properties} >+: ${zookeeper_enable:="NO"} >+: ${zookeeper_user:="%%ZOOKEEPER_USER%%"} >+: ${zookeeper_group:="%%ZOOKEEPER_GROUP%%"} >+: ${zookeeper_config:="%%ETCDIR%%/zoo.cfg"} >+: ${zookeeper_log4j_config:="%%ETCDIR%%/log4j.properties"} > : ${zookeeper_rootlogger:="INFO,ROLLINGFILE"} >-: ${zookeeper_logdir:=%%ZOOKEEPER_LOGDIR%%} >-: ${zookeeper_jvmopts:=} >+: ${zookeeper_logdir:="%%ZOOKEEPER_LOGDIR%%"} > : ${zookeeper_syslog_output_enable:="YES"} > >+start_precmd="zookeeper_start_precmd" >+ >+# backwards compatibility >+if [ -n "${zookeeper_jvmopts}" ]; then >+ zookeeper_java_opts=${zookeeper_jvmopts} >+fi >+if [ -n "${zookeeper_log4jpropfile}" ]; then >+ zookeeper_log4j_config="${zookeeper_log4jpropfile#file:}" >+fi >+ > if checkyesno zookeeper_syslog_output_enable; then >- zookeeper_syslog_output_flags="-T ${name}" >+ if [ -n "${zookeeper_syslog_output_tag}" ]; then >+ zookeeper_syslog_output_flags="-T ${zookeeper_syslog_output_tag}" >+ else >+ zookeeper_syslog_output_flags="-T ${name}" >+ fi > if [ -n "${zookeeper_syslog_output_priority}" ]; then > zookeeper_syslog_output_flags="${zookeeper_syslog_output_flags} -s ${zookeeper_syslog_output_priority}" > fi >@@ -37,18 +50,24 @@ > fi > fi > >-JAVA=%%JAVA%% >+JAVA="%%JAVA%%" > > CLASSPATH=":%%DATADIR%%/*" > >-log4j_params="-Dzookeeper.log.dir=${zookeeper_logdir} -Dlog4j.configuration=${zookeeper_log4jpropfile} -Dzookeeper.root.logger=${zookeeper_rootlogger}" >-zookeeper_main="${zookeeper_jvmopts} ${log4j_params} -cp $CLASSPATH org.apache.zookeeper.server.quorum.QuorumPeerMain ${zookeeper_config}" >-pidfile="${zookeeper_pidfile}" >+log4j_params="-Dzookeeper.root.logger=${zookeeper_rootlogger} -Dzookeeper.log.dir=${zookeeper_logdir} -Dlog4j.configuration=file:${zookeeper_log4j_config}" >+zookeeper_main="${zookeeper_java_opts} ${log4j_params} -cp ${CLASSPATH} org.apache.zookeeper.server.quorum.QuorumPeerMain ${zookeeper_config}" >+pidfile="/var/run/${name}/${name}.pid" > required_dirs="${zookeeper_logdir}" >-required_files="${zookeeper_config}" >+required_files="${zookeeper_config} ${zookeeper_log4j_config}" > > command="/usr/sbin/daemon" >-command_args="-f ${zookeeper_syslog_output_flags} -P ${pidfile} -u ${zookeeper_user} -t ${name} ${JAVA} ${zookeeper_main}" >-unset zookeeper_user >+command_args="-f ${zookeeper_syslog_output_flags} -P ${pidfile} -t ${name} ${JAVA} ${zookeeper_main}" > >+zookeeper_start_precmd() >+{ >+ if [ ! -d "/var/run/${name}" ]; then >+ install -d -m 0750 -o ${zookeeper_user} -g ${zookeeper_group} "/var/run/${name}" >+ fi >+} >+ > run_rc_command "$1" >Index: devel/zookeeper/pkg-plist >=================================================================== >--- devel/zookeeper/pkg-plist (revision 526928) >+++ devel/zookeeper/pkg-plist (working copy) >@@ -1,20 +1,27 @@ > bin/zkCli.sh > %%DATADIR%%/audience-annotations-0.5.0.jar > %%DATADIR%%/commons-cli-1.2.jar >-%%DATADIR%%/jackson-annotations-2.9.0.jar >-%%DATADIR%%/jackson-core-2.9.8.jar >-%%DATADIR%%/jackson-databind-2.9.8.jar >+%%DATADIR%%/jackson-annotations-2.9.10.jar >+%%DATADIR%%/jackson-core-2.9.10.jar >+%%DATADIR%%/jackson-databind-2.9.10.2.jar > %%DATADIR%%/javax.servlet-api-3.1.0.jar >-%%DATADIR%%/jetty-http-9.4.17.v20190418.jar >-%%DATADIR%%/jetty-io-9.4.17.v20190418.jar >-%%DATADIR%%/jetty-security-9.4.17.v20190418.jar >-%%DATADIR%%/jetty-server-9.4.17.v20190418.jar >-%%DATADIR%%/jetty-servlet-9.4.17.v20190418.jar >-%%DATADIR%%/jetty-util-9.4.17.v20190418.jar >+%%DATADIR%%/jetty-http-9.4.24.v20191120.jar >+%%DATADIR%%/jetty-io-9.4.24.v20191120.jar >+%%DATADIR%%/jetty-security-9.4.24.v20191120.jar >+%%DATADIR%%/jetty-server-9.4.24.v20191120.jar >+%%DATADIR%%/jetty-servlet-9.4.24.v20191120.jar >+%%DATADIR%%/jetty-util-9.4.24.v20191120.jar > %%DATADIR%%/jline-2.11.jar > %%DATADIR%%/json-simple-1.1.1.jar > %%DATADIR%%/log4j-1.2.17.jar >-%%DATADIR%%/netty-all-4.1.29.Final.jar >+%%DATADIR%%/netty-buffer-4.1.45.Final.jar >+%%DATADIR%%/netty-codec-4.1.45.Final.jar >+%%DATADIR%%/netty-common-4.1.45.Final.jar >+%%DATADIR%%/netty-handler-4.1.45.Final.jar >+%%DATADIR%%/netty-resolver-4.1.45.Final.jar >+%%DATADIR%%/netty-transport-4.1.45.Final.jar >+%%DATADIR%%/netty-transport-native-epoll-4.1.45.Final.jar >+%%DATADIR%%/netty-transport-native-unix-common-4.1.45.Final.jar > %%DATADIR%%/slf4j-api-1.7.25.jar > %%DATADIR%%/slf4j-log4j12-1.7.25.jar > %%DATADIR%%/zookeeper-%%PORTVERSION%%.jar >@@ -22,5 +29,6 @@ > @sample %%ETCDIR%%/log4j.properties.sample > @sample %%ETCDIR%%/configuration.xsl.sample > @sample %%ETCDIR%%/zoo.cfg.sample >-@dir(%%USERS%%,%%GROUPS%%,755) %%ZOOKEEPER_LOGDIR%% >-@dir(%%USERS%%,%%GROUPS%%,755) %%ZOOKEEPER_DBDIR%% >+@dir(%%ZOOKEEPER_USER%%,%%ZOOKEEPER_GROUP%%,755) %%ETCDIR%% >+@dir(%%ZOOKEEPER_USER%%,%%ZOOKEEPER_GROUP%%,755) %%ZOOKEEPER_DBDIR%% >+@dir(%%ZOOKEEPER_USER%%,%%ZOOKEEPER_GROUP%%,755) %%ZOOKEEPER_LOGDIR%%
You cannot view the attachment while viewing its details because your browser does not support IFRAMEs.
View the attachment on a separate page
.
View Attachment As Diff
View Attachment As Raw
Actions:
View
|
Diff
Attachments on
bug 241583
:
208693
|
208695
|
208697
|
208732
|
208740
|
208812
|
208814
|
208861
|
208865
|
209778
| 211876