| diff -urN apache-zookeeper-3.6.3.orig/zookeeper-client/zookeeper-client-c/generated/zookeeper.jute.c apache-zookeeper-3.6.3.desired/zookeeper-client/zookeeper-client-c/generated/zookeeper.jute.c |
| --- apache-zookeeper-3.6.3.orig/zookeeper-client/zookeeper-client-c/generated/zookeeper.jute.c 1970-01-01 00:00:00.000000000 +0000 |
| +++ apache-zookeeper-3.6.3.desired/zookeeper-client/zookeeper-client-c/generated/zookeeper.jute.c 2021-04-18 05:41:30.643935033 +0000 |
| @@ -0,0 +1,1622 @@ |
| +/** |
| +* 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_SetWatches2(struct oarchive *out, const char *tag, struct SetWatches2 *v){ |
| + int rc; |
| + rc = out->start_record(out, tag); |
| + rc = rc ? rc : out->serialize_Long(out, "relativeZxid", &v->relativeZxid); |
| + rc = rc ? rc : serialize_String_vector(out, "dataWatches", &v->dataWatches); |
| + rc = rc ? rc : serialize_String_vector(out, "existWatches", &v->existWatches); |
| + rc = rc ? rc : serialize_String_vector(out, "childWatches", &v->childWatches); |
| + rc = rc ? rc : serialize_String_vector(out, "persistentWatches", &v->persistentWatches); |
| + rc = rc ? rc : serialize_String_vector(out, "persistentRecursiveWatches", &v->persistentRecursiveWatches); |
| + rc = rc ? rc : out->end_record(out, tag); |
| + return rc; |
| +} |
| +int deserialize_SetWatches2(struct iarchive *in, const char *tag, struct SetWatches2*v){ |
| + int rc; |
| + rc = in->start_record(in, tag); |
| + rc = rc ? rc : in->deserialize_Long(in, "relativeZxid", &v->relativeZxid); |
| + rc = rc ? rc : deserialize_String_vector(in, "dataWatches", &v->dataWatches); |
| + rc = rc ? rc : deserialize_String_vector(in, "existWatches", &v->existWatches); |
| + rc = rc ? rc : deserialize_String_vector(in, "childWatches", &v->childWatches); |
| + rc = rc ? rc : deserialize_String_vector(in, "persistentWatches", &v->persistentWatches); |
| + rc = rc ? rc : deserialize_String_vector(in, "persistentRecursiveWatches", &v->persistentRecursiveWatches); |
| + rc = rc ? rc : in->end_record(in, tag); |
| + return rc; |
| +} |
| +void deallocate_SetWatches2(struct SetWatches2*v){ |
| + deallocate_String_vector(&v->dataWatches); |
| + deallocate_String_vector(&v->existWatches); |
| + deallocate_String_vector(&v->childWatches); |
| + deallocate_String_vector(&v->persistentWatches); |
| + deallocate_String_vector(&v->persistentRecursiveWatches); |
| +} |
| +int serialize_RequestHeader(struct oarchive *out, const char *tag, struct RequestHeader *v){ |
| + int rc; |
| + rc = out->start_record(out, tag); |
| + rc = rc ? rc : out->serialize_Int(out, "xid", &v->xid); |
| + rc = rc ? rc : out->serialize_Int(out, "type", &v->type); |
| + rc = rc ? rc : out->end_record(out, tag); |
| + return rc; |
| +} |
| +int deserialize_RequestHeader(struct iarchive *in, const char *tag, struct RequestHeader*v){ |
| + int rc; |
| + rc = in->start_record(in, tag); |
| + rc = rc ? rc : in->deserialize_Int(in, "xid", &v->xid); |
| + rc = rc ? rc : in->deserialize_Int(in, "type", &v->type); |
| + rc = rc ? rc : in->end_record(in, tag); |
| + return rc; |
| +} |
| +void deallocate_RequestHeader(struct RequestHeader*v){ |
| +} |
| +int serialize_MultiHeader(struct oarchive *out, const char *tag, struct MultiHeader *v){ |
| + int rc; |
| + rc = out->start_record(out, tag); |
| + rc = rc ? rc : out->serialize_Int(out, "type", &v->type); |
| + rc = rc ? rc : out->serialize_Bool(out, "done", &v->done); |
| + rc = rc ? rc : out->serialize_Int(out, "err", &v->err); |
| + rc = rc ? rc : out->end_record(out, tag); |
| + return rc; |
| +} |
| +int deserialize_MultiHeader(struct iarchive *in, const char *tag, struct MultiHeader*v){ |
| + int rc; |
| + rc = in->start_record(in, tag); |
| + rc = rc ? rc : in->deserialize_Int(in, "type", &v->type); |
| + rc = rc ? rc : in->deserialize_Bool(in, "done", &v->done); |
| + rc = rc ? rc : in->deserialize_Int(in, "err", &v->err); |
| + rc = rc ? rc : in->end_record(in, tag); |
| + return rc; |
| +} |
| +void deallocate_MultiHeader(struct MultiHeader*v){ |
| +} |
| +int serialize_AuthPacket(struct oarchive *out, const char *tag, struct AuthPacket *v){ |
| + int rc; |
| + rc = out->start_record(out, tag); |
| + rc = rc ? rc : out->serialize_Int(out, "type", &v->type); |
| + rc = rc ? rc : out->serialize_String(out, "scheme", &v->scheme); |
| + rc = rc ? rc : out->serialize_Buffer(out, "auth", &v->auth); |
| + rc = rc ? rc : out->end_record(out, tag); |
| + return rc; |
| +} |
| +int deserialize_AuthPacket(struct iarchive *in, const char *tag, struct AuthPacket*v){ |
| + int rc; |
| + rc = in->start_record(in, tag); |
| + rc = rc ? rc : in->deserialize_Int(in, "type", &v->type); |
| + rc = rc ? rc : in->deserialize_String(in, "scheme", &v->scheme); |
| + rc = rc ? rc : in->deserialize_Buffer(in, "auth", &v->auth); |
| + rc = rc ? rc : in->end_record(in, tag); |
| + return rc; |
| +} |
| +void deallocate_AuthPacket(struct AuthPacket*v){ |
| + deallocate_String(&v->scheme); |
| + deallocate_Buffer(&v->auth); |
| +} |
| +int serialize_ReplyHeader(struct oarchive *out, const char *tag, struct ReplyHeader *v){ |
| + int rc; |
| + rc = out->start_record(out, tag); |
| + rc = rc ? rc : out->serialize_Int(out, "xid", &v->xid); |
| + rc = rc ? rc : out->serialize_Long(out, "zxid", &v->zxid); |
| + rc = rc ? rc : out->serialize_Int(out, "err", &v->err); |
| + rc = rc ? rc : out->end_record(out, tag); |
| + return rc; |
| +} |
| +int deserialize_ReplyHeader(struct iarchive *in, const char *tag, struct ReplyHeader*v){ |
| + int rc; |
| + rc = in->start_record(in, tag); |
| + rc = rc ? rc : in->deserialize_Int(in, "xid", &v->xid); |
| + rc = rc ? rc : in->deserialize_Long(in, "zxid", &v->zxid); |
| + rc = rc ? rc : in->deserialize_Int(in, "err", &v->err); |
| + rc = rc ? rc : in->end_record(in, tag); |
| + return rc; |
| +} |
| +void deallocate_ReplyHeader(struct ReplyHeader*v){ |
| +} |
| +int serialize_GetDataRequest(struct oarchive *out, const char *tag, struct GetDataRequest *v){ |
| + int rc; |
| + rc = out->start_record(out, tag); |
| + rc = rc ? rc : out->serialize_String(out, "path", &v->path); |
| + rc = rc ? rc : out->serialize_Bool(out, "watch", &v->watch); |
| + rc = rc ? rc : out->end_record(out, tag); |
| + return rc; |
| +} |
| +int deserialize_GetDataRequest(struct iarchive *in, const char *tag, struct GetDataRequest*v){ |
| + int rc; |
| + rc = in->start_record(in, tag); |
| + rc = rc ? rc : in->deserialize_String(in, "path", &v->path); |
| + rc = rc ? rc : in->deserialize_Bool(in, "watch", &v->watch); |
| + rc = rc ? rc : in->end_record(in, tag); |
| + return rc; |
| +} |
| +void deallocate_GetDataRequest(struct GetDataRequest*v){ |
| + deallocate_String(&v->path); |
| +} |
| +int serialize_SetDataRequest(struct oarchive *out, const char *tag, struct SetDataRequest *v){ |
| + int rc; |
| + rc = out->start_record(out, tag); |
| + rc = rc ? rc : out->serialize_String(out, "path", &v->path); |
| + rc = rc ? rc : out->serialize_Buffer(out, "data", &v->data); |
| + rc = rc ? rc : out->serialize_Int(out, "version", &v->version); |
| + rc = rc ? rc : out->end_record(out, tag); |
| + return rc; |
| +} |
| +int deserialize_SetDataRequest(struct iarchive *in, const char *tag, struct SetDataRequest*v){ |
| + int rc; |
| + rc = in->start_record(in, tag); |
| + rc = rc ? rc : in->deserialize_String(in, "path", &v->path); |
| + rc = rc ? rc : in->deserialize_Buffer(in, "data", &v->data); |
| + rc = rc ? rc : in->deserialize_Int(in, "version", &v->version); |
| + rc = rc ? rc : in->end_record(in, tag); |
| + return rc; |
| +} |
| +void deallocate_SetDataRequest(struct SetDataRequest*v){ |
| + deallocate_String(&v->path); |
| + deallocate_Buffer(&v->data); |
| +} |
| +int serialize_ReconfigRequest(struct oarchive *out, const char *tag, struct ReconfigRequest *v){ |
| + int rc; |
| + rc = out->start_record(out, tag); |
| + rc = rc ? rc : out->serialize_String(out, "joiningServers", &v->joiningServers); |
| + rc = rc ? rc : out->serialize_String(out, "leavingServers", &v->leavingServers); |
| + rc = rc ? rc : out->serialize_String(out, "newMembers", &v->newMembers); |
| + rc = rc ? rc : out->serialize_Long(out, "curConfigId", &v->curConfigId); |
| + rc = rc ? rc : out->end_record(out, tag); |
| + return rc; |
| +} |
| +int deserialize_ReconfigRequest(struct iarchive *in, const char *tag, struct ReconfigRequest*v){ |
| + int rc; |
| + rc = in->start_record(in, tag); |
| + rc = rc ? rc : in->deserialize_String(in, "joiningServers", &v->joiningServers); |
| + rc = rc ? rc : in->deserialize_String(in, "leavingServers", &v->leavingServers); |
| + rc = rc ? rc : in->deserialize_String(in, "newMembers", &v->newMembers); |
| + rc = rc ? rc : in->deserialize_Long(in, "curConfigId", &v->curConfigId); |
| + rc = rc ? rc : in->end_record(in, tag); |
| + return rc; |
| +} |
| +void deallocate_ReconfigRequest(struct ReconfigRequest*v){ |
| + deallocate_String(&v->joiningServers); |
| + deallocate_String(&v->leavingServers); |
| + deallocate_String(&v->newMembers); |
| +} |
| +int serialize_SetDataResponse(struct oarchive *out, const char *tag, struct SetDataResponse *v){ |
| + int rc; |
| + rc = out->start_record(out, tag); |
| + rc = rc ? rc : serialize_Stat(out, "stat", &v->stat); |
| + rc = rc ? rc : out->end_record(out, tag); |
| + return rc; |
| +} |
| +int deserialize_SetDataResponse(struct iarchive *in, const char *tag, struct SetDataResponse*v){ |
| + int rc; |
| + rc = in->start_record(in, tag); |
| + rc = rc ? rc : deserialize_Stat(in, "stat", &v->stat); |
| + rc = rc ? rc : in->end_record(in, tag); |
| + return rc; |
| +} |
| +void deallocate_SetDataResponse(struct SetDataResponse*v){ |
| + deallocate_Stat(&v->stat); |
| +} |
| +int serialize_GetSASLRequest(struct oarchive *out, const char *tag, struct GetSASLRequest *v){ |
| + int rc; |
| + rc = out->start_record(out, tag); |
| + rc = rc ? rc : out->serialize_Buffer(out, "token", &v->token); |
| + rc = rc ? rc : out->end_record(out, tag); |
| + return rc; |
| +} |
| +int deserialize_GetSASLRequest(struct iarchive *in, const char *tag, struct GetSASLRequest*v){ |
| + int rc; |
| + rc = in->start_record(in, tag); |
| + rc = rc ? rc : in->deserialize_Buffer(in, "token", &v->token); |
| + rc = rc ? rc : in->end_record(in, tag); |
| + return rc; |
| +} |
| +void deallocate_GetSASLRequest(struct GetSASLRequest*v){ |
| + deallocate_Buffer(&v->token); |
| +} |
| +int serialize_SetSASLRequest(struct oarchive *out, const char *tag, struct SetSASLRequest *v){ |
| + int rc; |
| + rc = out->start_record(out, tag); |
| + rc = rc ? rc : out->serialize_Buffer(out, "token", &v->token); |
| + rc = rc ? rc : out->end_record(out, tag); |
| + return rc; |
| +} |
| +int deserialize_SetSASLRequest(struct iarchive *in, const char *tag, struct SetSASLRequest*v){ |
| + int rc; |
| + rc = in->start_record(in, tag); |
| + rc = rc ? rc : in->deserialize_Buffer(in, "token", &v->token); |
| + rc = rc ? rc : in->end_record(in, tag); |
| + return rc; |
| +} |
| +void deallocate_SetSASLRequest(struct SetSASLRequest*v){ |
| + deallocate_Buffer(&v->token); |
| +} |
| +int serialize_SetSASLResponse(struct oarchive *out, const char *tag, struct SetSASLResponse *v){ |
| + int rc; |
| + rc = out->start_record(out, tag); |
| + rc = rc ? rc : out->serialize_Buffer(out, "token", &v->token); |
| + rc = rc ? rc : out->end_record(out, tag); |
| + return rc; |
| +} |
| +int deserialize_SetSASLResponse(struct iarchive *in, const char *tag, struct SetSASLResponse*v){ |
| + int rc; |
| + rc = in->start_record(in, tag); |
| + rc = rc ? rc : in->deserialize_Buffer(in, "token", &v->token); |
| + rc = rc ? rc : in->end_record(in, tag); |
| + return rc; |
| +} |
| +void deallocate_SetSASLResponse(struct SetSASLResponse*v){ |
| + deallocate_Buffer(&v->token); |
| +} |
| +int allocate_ACL_vector(struct ACL_vector *v, int32_t len) { |
| + if (!len) { |
| + v->count = 0; |
| + v->data = 0; |
| + } else { |
| + v->count = len; |
| + v->data = calloc(sizeof(*v->data), len); |
| + } |
| + return 0; |
| +} |
| +int deallocate_ACL_vector(struct ACL_vector *v) { |
| + if (v->data) { |
| + int32_t i; |
| + for(i=0;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_GetAllChildrenNumberRequest(struct oarchive *out, const char *tag, struct GetAllChildrenNumberRequest *v){ |
| + int rc; |
| + rc = out->start_record(out, tag); |
| + rc = rc ? rc : out->serialize_String(out, "path", &v->path); |
| + rc = rc ? rc : out->end_record(out, tag); |
| + return rc; |
| +} |
| +int deserialize_GetAllChildrenNumberRequest(struct iarchive *in, const char *tag, struct GetAllChildrenNumberRequest*v){ |
| + int rc; |
| + rc = in->start_record(in, tag); |
| + rc = rc ? rc : in->deserialize_String(in, "path", &v->path); |
| + rc = rc ? rc : in->end_record(in, tag); |
| + return rc; |
| +} |
| +void deallocate_GetAllChildrenNumberRequest(struct GetAllChildrenNumberRequest*v){ |
| + deallocate_String(&v->path); |
| +} |
| +int serialize_GetChildren2Request(struct oarchive *out, const char *tag, struct GetChildren2Request *v){ |
| + int rc; |
| + rc = out->start_record(out, tag); |
| + rc = rc ? rc : out->serialize_String(out, "path", &v->path); |
| + rc = rc ? rc : out->serialize_Bool(out, "watch", &v->watch); |
| + rc = rc ? rc : out->end_record(out, tag); |
| + return rc; |
| +} |
| +int deserialize_GetChildren2Request(struct iarchive *in, const char *tag, struct GetChildren2Request*v){ |
| + int rc; |
| + rc = in->start_record(in, tag); |
| + rc = rc ? rc : in->deserialize_String(in, "path", &v->path); |
| + rc = rc ? rc : in->deserialize_Bool(in, "watch", &v->watch); |
| + rc = rc ? rc : in->end_record(in, tag); |
| + return rc; |
| +} |
| +void deallocate_GetChildren2Request(struct GetChildren2Request*v){ |
| + deallocate_String(&v->path); |
| +} |
| +int serialize_CheckVersionRequest(struct oarchive *out, const char *tag, struct CheckVersionRequest *v){ |
| + int rc; |
| + rc = out->start_record(out, tag); |
| + rc = rc ? rc : out->serialize_String(out, "path", &v->path); |
| + rc = rc ? rc : out->serialize_Int(out, "version", &v->version); |
| + rc = rc ? rc : out->end_record(out, tag); |
| + return rc; |
| +} |
| +int deserialize_CheckVersionRequest(struct iarchive *in, const char *tag, struct CheckVersionRequest*v){ |
| + int rc; |
| + rc = in->start_record(in, tag); |
| + rc = rc ? rc : in->deserialize_String(in, "path", &v->path); |
| + rc = rc ? rc : in->deserialize_Int(in, "version", &v->version); |
| + rc = rc ? rc : in->end_record(in, tag); |
| + return rc; |
| +} |
| +void deallocate_CheckVersionRequest(struct CheckVersionRequest*v){ |
| + deallocate_String(&v->path); |
| +} |
| +int serialize_GetMaxChildrenRequest(struct oarchive *out, const char *tag, struct GetMaxChildrenRequest *v){ |
| + int rc; |
| + rc = out->start_record(out, tag); |
| + rc = rc ? rc : out->serialize_String(out, "path", &v->path); |
| + rc = rc ? rc : out->end_record(out, tag); |
| + return rc; |
| +} |
| +int deserialize_GetMaxChildrenRequest(struct iarchive *in, const char *tag, struct GetMaxChildrenRequest*v){ |
| + int rc; |
| + rc = in->start_record(in, tag); |
| + rc = rc ? rc : in->deserialize_String(in, "path", &v->path); |
| + rc = rc ? rc : in->end_record(in, tag); |
| + return rc; |
| +} |
| +void deallocate_GetMaxChildrenRequest(struct GetMaxChildrenRequest*v){ |
| + deallocate_String(&v->path); |
| +} |
| +int serialize_GetMaxChildrenResponse(struct oarchive *out, const char *tag, struct GetMaxChildrenResponse *v){ |
| + int rc; |
| + rc = out->start_record(out, tag); |
| + rc = rc ? rc : out->serialize_Int(out, "max", &v->max); |
| + rc = rc ? rc : out->end_record(out, tag); |
| + return rc; |
| +} |
| +int deserialize_GetMaxChildrenResponse(struct iarchive *in, const char *tag, struct GetMaxChildrenResponse*v){ |
| + int rc; |
| + rc = in->start_record(in, tag); |
| + rc = rc ? rc : in->deserialize_Int(in, "max", &v->max); |
| + rc = rc ? rc : in->end_record(in, tag); |
| + return rc; |
| +} |
| +void deallocate_GetMaxChildrenResponse(struct GetMaxChildrenResponse*v){ |
| +} |
| +int serialize_SetMaxChildrenRequest(struct oarchive *out, const char *tag, struct SetMaxChildrenRequest *v){ |
| + int rc; |
| + rc = out->start_record(out, tag); |
| + rc = rc ? rc : out->serialize_String(out, "path", &v->path); |
| + rc = rc ? rc : out->serialize_Int(out, "max", &v->max); |
| + rc = rc ? rc : out->end_record(out, tag); |
| + return rc; |
| +} |
| +int deserialize_SetMaxChildrenRequest(struct iarchive *in, const char *tag, struct SetMaxChildrenRequest*v){ |
| + int rc; |
| + rc = in->start_record(in, tag); |
| + rc = rc ? rc : in->deserialize_String(in, "path", &v->path); |
| + rc = rc ? rc : in->deserialize_Int(in, "max", &v->max); |
| + rc = rc ? rc : in->end_record(in, tag); |
| + return rc; |
| +} |
| +void deallocate_SetMaxChildrenRequest(struct SetMaxChildrenRequest*v){ |
| + deallocate_String(&v->path); |
| +} |
| +int serialize_SyncRequest(struct oarchive *out, const char *tag, struct SyncRequest *v){ |
| + int rc; |
| + rc = out->start_record(out, tag); |
| + rc = rc ? rc : out->serialize_String(out, "path", &v->path); |
| + rc = rc ? rc : out->end_record(out, tag); |
| + return rc; |
| +} |
| +int deserialize_SyncRequest(struct iarchive *in, const char *tag, struct SyncRequest*v){ |
| + int rc; |
| + rc = in->start_record(in, tag); |
| + rc = rc ? rc : in->deserialize_String(in, "path", &v->path); |
| + rc = rc ? rc : in->end_record(in, tag); |
| + return rc; |
| +} |
| +void deallocate_SyncRequest(struct SyncRequest*v){ |
| + deallocate_String(&v->path); |
| +} |
| +int serialize_SyncResponse(struct oarchive *out, const char *tag, struct SyncResponse *v){ |
| + int rc; |
| + rc = out->start_record(out, tag); |
| + rc = rc ? rc : out->serialize_String(out, "path", &v->path); |
| + rc = rc ? rc : out->end_record(out, tag); |
| + return rc; |
| +} |
| +int deserialize_SyncResponse(struct iarchive *in, const char *tag, struct SyncResponse*v){ |
| + int rc; |
| + rc = in->start_record(in, tag); |
| + rc = rc ? rc : in->deserialize_String(in, "path", &v->path); |
| + rc = rc ? rc : in->end_record(in, tag); |
| + return rc; |
| +} |
| +void deallocate_SyncResponse(struct SyncResponse*v){ |
| + deallocate_String(&v->path); |
| +} |
| +int serialize_GetACLRequest(struct oarchive *out, const char *tag, struct GetACLRequest *v){ |
| + int rc; |
| + rc = out->start_record(out, tag); |
| + rc = rc ? rc : out->serialize_String(out, "path", &v->path); |
| + rc = rc ? rc : out->end_record(out, tag); |
| + return rc; |
| +} |
| +int deserialize_GetACLRequest(struct iarchive *in, const char *tag, struct GetACLRequest*v){ |
| + int rc; |
| + rc = in->start_record(in, tag); |
| + rc = rc ? rc : in->deserialize_String(in, "path", &v->path); |
| + rc = rc ? rc : in->end_record(in, tag); |
| + return rc; |
| +} |
| +void deallocate_GetACLRequest(struct GetACLRequest*v){ |
| + deallocate_String(&v->path); |
| +} |
| +int serialize_SetACLRequest(struct oarchive *out, const char *tag, struct SetACLRequest *v){ |
| + int rc; |
| + rc = out->start_record(out, tag); |
| + rc = rc ? rc : out->serialize_String(out, "path", &v->path); |
| + rc = rc ? rc : serialize_ACL_vector(out, "acl", &v->acl); |
| + rc = rc ? rc : out->serialize_Int(out, "version", &v->version); |
| + rc = rc ? rc : out->end_record(out, tag); |
| + return rc; |
| +} |
| +int deserialize_SetACLRequest(struct iarchive *in, const char *tag, struct SetACLRequest*v){ |
| + int rc; |
| + rc = in->start_record(in, tag); |
| + rc = rc ? rc : in->deserialize_String(in, "path", &v->path); |
| + rc = rc ? rc : deserialize_ACL_vector(in, "acl", &v->acl); |
| + rc = rc ? rc : in->deserialize_Int(in, "version", &v->version); |
| + rc = rc ? rc : in->end_record(in, tag); |
| + return rc; |
| +} |
| +void deallocate_SetACLRequest(struct SetACLRequest*v){ |
| + deallocate_String(&v->path); |
| + deallocate_ACL_vector(&v->acl); |
| +} |
| +int serialize_SetACLResponse(struct oarchive *out, const char *tag, struct SetACLResponse *v){ |
| + int rc; |
| + rc = out->start_record(out, tag); |
| + rc = rc ? rc : serialize_Stat(out, "stat", &v->stat); |
| + rc = rc ? rc : out->end_record(out, tag); |
| + return rc; |
| +} |
| +int deserialize_SetACLResponse(struct iarchive *in, const char *tag, struct SetACLResponse*v){ |
| + int rc; |
| + rc = in->start_record(in, tag); |
| + rc = rc ? rc : deserialize_Stat(in, "stat", &v->stat); |
| + rc = rc ? rc : in->end_record(in, tag); |
| + return rc; |
| +} |
| +void deallocate_SetACLResponse(struct SetACLResponse*v){ |
| + deallocate_Stat(&v->stat); |
| +} |
| +int serialize_AddWatchRequest(struct oarchive *out, const char *tag, struct AddWatchRequest *v){ |
| + int rc; |
| + rc = out->start_record(out, tag); |
| + rc = rc ? rc : out->serialize_String(out, "path", &v->path); |
| + rc = rc ? rc : out->serialize_Int(out, "mode", &v->mode); |
| + rc = rc ? rc : out->end_record(out, tag); |
| + return rc; |
| +} |
| +int deserialize_AddWatchRequest(struct iarchive *in, const char *tag, struct AddWatchRequest*v){ |
| + int rc; |
| + rc = in->start_record(in, tag); |
| + rc = rc ? rc : in->deserialize_String(in, "path", &v->path); |
| + rc = rc ? rc : in->deserialize_Int(in, "mode", &v->mode); |
| + rc = rc ? rc : in->end_record(in, tag); |
| + return rc; |
| +} |
| +void deallocate_AddWatchRequest(struct AddWatchRequest*v){ |
| + deallocate_String(&v->path); |
| +} |
| +int serialize_WatcherEvent(struct oarchive *out, const char *tag, struct WatcherEvent *v){ |
| + int rc; |
| + rc = out->start_record(out, tag); |
| + rc = rc ? rc : out->serialize_Int(out, "type", &v->type); |
| + rc = rc ? rc : out->serialize_Int(out, "state", &v->state); |
| + rc = rc ? rc : out->serialize_String(out, "path", &v->path); |
| + rc = rc ? rc : out->end_record(out, tag); |
| + return rc; |
| +} |
| +int deserialize_WatcherEvent(struct iarchive *in, const char *tag, struct WatcherEvent*v){ |
| + int rc; |
| + rc = in->start_record(in, tag); |
| + rc = rc ? rc : in->deserialize_Int(in, "type", &v->type); |
| + rc = rc ? rc : in->deserialize_Int(in, "state", &v->state); |
| + rc = rc ? rc : in->deserialize_String(in, "path", &v->path); |
| + rc = rc ? rc : in->end_record(in, tag); |
| + return rc; |
| +} |
| +void deallocate_WatcherEvent(struct WatcherEvent*v){ |
| + deallocate_String(&v->path); |
| +} |
| +int serialize_ErrorResponse(struct oarchive *out, const char *tag, struct ErrorResponse *v){ |
| + int rc; |
| + rc = out->start_record(out, tag); |
| + rc = rc ? rc : out->serialize_Int(out, "err", &v->err); |
| + rc = rc ? rc : out->end_record(out, tag); |
| + return rc; |
| +} |
| +int deserialize_ErrorResponse(struct iarchive *in, const char *tag, struct ErrorResponse*v){ |
| + int rc; |
| + rc = in->start_record(in, tag); |
| + rc = rc ? rc : in->deserialize_Int(in, "err", &v->err); |
| + rc = rc ? rc : in->end_record(in, tag); |
| + return rc; |
| +} |
| +void deallocate_ErrorResponse(struct ErrorResponse*v){ |
| +} |
| +int serialize_CreateResponse(struct oarchive *out, const char *tag, struct CreateResponse *v){ |
| + int rc; |
| + rc = out->start_record(out, tag); |
| + rc = rc ? rc : out->serialize_String(out, "path", &v->path); |
| + rc = rc ? rc : out->end_record(out, tag); |
| + return rc; |
| +} |
| +int deserialize_CreateResponse(struct iarchive *in, const char *tag, struct CreateResponse*v){ |
| + int rc; |
| + rc = in->start_record(in, tag); |
| + rc = rc ? rc : in->deserialize_String(in, "path", &v->path); |
| + rc = rc ? rc : in->end_record(in, tag); |
| + return rc; |
| +} |
| +void deallocate_CreateResponse(struct CreateResponse*v){ |
| + deallocate_String(&v->path); |
| +} |
| +int serialize_Create2Response(struct oarchive *out, const char *tag, struct Create2Response *v){ |
| + int rc; |
| + rc = out->start_record(out, tag); |
| + rc = rc ? rc : out->serialize_String(out, "path", &v->path); |
| + rc = rc ? rc : serialize_Stat(out, "stat", &v->stat); |
| + rc = rc ? rc : out->end_record(out, tag); |
| + return rc; |
| +} |
| +int deserialize_Create2Response(struct iarchive *in, const char *tag, struct Create2Response*v){ |
| + int rc; |
| + rc = in->start_record(in, tag); |
| + rc = rc ? rc : in->deserialize_String(in, "path", &v->path); |
| + rc = rc ? rc : deserialize_Stat(in, "stat", &v->stat); |
| + rc = rc ? rc : in->end_record(in, tag); |
| + return rc; |
| +} |
| +void deallocate_Create2Response(struct Create2Response*v){ |
| + deallocate_String(&v->path); |
| + deallocate_Stat(&v->stat); |
| +} |
| +int serialize_ExistsRequest(struct oarchive *out, const char *tag, struct ExistsRequest *v){ |
| + int rc; |
| + rc = out->start_record(out, tag); |
| + rc = rc ? rc : out->serialize_String(out, "path", &v->path); |
| + rc = rc ? rc : out->serialize_Bool(out, "watch", &v->watch); |
| + rc = rc ? rc : out->end_record(out, tag); |
| + return rc; |
| +} |
| +int deserialize_ExistsRequest(struct iarchive *in, const char *tag, struct ExistsRequest*v){ |
| + int rc; |
| + rc = in->start_record(in, tag); |
| + rc = rc ? rc : in->deserialize_String(in, "path", &v->path); |
| + rc = rc ? rc : in->deserialize_Bool(in, "watch", &v->watch); |
| + rc = rc ? rc : in->end_record(in, tag); |
| + return rc; |
| +} |
| +void deallocate_ExistsRequest(struct ExistsRequest*v){ |
| + deallocate_String(&v->path); |
| +} |
| +int serialize_ExistsResponse(struct oarchive *out, const char *tag, struct ExistsResponse *v){ |
| + int rc; |
| + rc = out->start_record(out, tag); |
| + rc = rc ? rc : serialize_Stat(out, "stat", &v->stat); |
| + rc = rc ? rc : out->end_record(out, tag); |
| + return rc; |
| +} |
| +int deserialize_ExistsResponse(struct iarchive *in, const char *tag, struct ExistsResponse*v){ |
| + int rc; |
| + rc = in->start_record(in, tag); |
| + rc = rc ? rc : deserialize_Stat(in, "stat", &v->stat); |
| + rc = rc ? rc : in->end_record(in, tag); |
| + return rc; |
| +} |
| +void deallocate_ExistsResponse(struct ExistsResponse*v){ |
| + deallocate_Stat(&v->stat); |
| +} |
| +int serialize_GetDataResponse(struct oarchive *out, const char *tag, struct GetDataResponse *v){ |
| + int rc; |
| + rc = out->start_record(out, tag); |
| + rc = rc ? rc : out->serialize_Buffer(out, "data", &v->data); |
| + rc = rc ? rc : serialize_Stat(out, "stat", &v->stat); |
| + rc = rc ? rc : out->end_record(out, tag); |
| + return rc; |
| +} |
| +int deserialize_GetDataResponse(struct iarchive *in, const char *tag, struct GetDataResponse*v){ |
| + int rc; |
| + rc = in->start_record(in, tag); |
| + rc = rc ? rc : in->deserialize_Buffer(in, "data", &v->data); |
| + rc = rc ? rc : deserialize_Stat(in, "stat", &v->stat); |
| + rc = rc ? rc : in->end_record(in, tag); |
| + return rc; |
| +} |
| +void deallocate_GetDataResponse(struct GetDataResponse*v){ |
| + deallocate_Buffer(&v->data); |
| + deallocate_Stat(&v->stat); |
| +} |
| +int serialize_GetChildrenResponse(struct oarchive *out, const char *tag, struct GetChildrenResponse *v){ |
| + int rc; |
| + rc = out->start_record(out, tag); |
| + rc = rc ? rc : serialize_String_vector(out, "children", &v->children); |
| + rc = rc ? rc : out->end_record(out, tag); |
| + return rc; |
| +} |
| +int deserialize_GetChildrenResponse(struct iarchive *in, const char *tag, struct GetChildrenResponse*v){ |
| + int rc; |
| + rc = in->start_record(in, tag); |
| + rc = rc ? rc : deserialize_String_vector(in, "children", &v->children); |
| + rc = rc ? rc : in->end_record(in, tag); |
| + return rc; |
| +} |
| +void deallocate_GetChildrenResponse(struct GetChildrenResponse*v){ |
| + deallocate_String_vector(&v->children); |
| +} |
| +int serialize_GetAllChildrenNumberResponse(struct oarchive *out, const char *tag, struct GetAllChildrenNumberResponse *v){ |
| + int rc; |
| + rc = out->start_record(out, tag); |
| + rc = rc ? rc : out->serialize_Int(out, "totalNumber", &v->totalNumber); |
| + rc = rc ? rc : out->end_record(out, tag); |
| + return rc; |
| +} |
| +int deserialize_GetAllChildrenNumberResponse(struct iarchive *in, const char *tag, struct GetAllChildrenNumberResponse*v){ |
| + int rc; |
| + rc = in->start_record(in, tag); |
| + rc = rc ? rc : in->deserialize_Int(in, "totalNumber", &v->totalNumber); |
| + rc = rc ? rc : in->end_record(in, tag); |
| + return rc; |
| +} |
| +void deallocate_GetAllChildrenNumberResponse(struct GetAllChildrenNumberResponse*v){ |
| +} |
| +int serialize_GetChildren2Response(struct oarchive *out, const char *tag, struct GetChildren2Response *v){ |
| + int rc; |
| + rc = out->start_record(out, tag); |
| + rc = rc ? rc : serialize_String_vector(out, "children", &v->children); |
| + rc = rc ? rc : serialize_Stat(out, "stat", &v->stat); |
| + rc = rc ? rc : out->end_record(out, tag); |
| + return rc; |
| +} |
| +int deserialize_GetChildren2Response(struct iarchive *in, const char *tag, struct GetChildren2Response*v){ |
| + int rc; |
| + rc = in->start_record(in, tag); |
| + rc = rc ? rc : deserialize_String_vector(in, "children", &v->children); |
| + rc = rc ? rc : deserialize_Stat(in, "stat", &v->stat); |
| + rc = rc ? rc : in->end_record(in, tag); |
| + return rc; |
| +} |
| +void deallocate_GetChildren2Response(struct GetChildren2Response*v){ |
| + deallocate_String_vector(&v->children); |
| + deallocate_Stat(&v->stat); |
| +} |
| +int serialize_GetACLResponse(struct oarchive *out, const char *tag, struct GetACLResponse *v){ |
| + int rc; |
| + rc = out->start_record(out, tag); |
| + rc = rc ? rc : serialize_ACL_vector(out, "acl", &v->acl); |
| + rc = rc ? rc : serialize_Stat(out, "stat", &v->stat); |
| + rc = rc ? rc : out->end_record(out, tag); |
| + return rc; |
| +} |
| +int deserialize_GetACLResponse(struct iarchive *in, const char *tag, struct GetACLResponse*v){ |
| + int rc; |
| + rc = in->start_record(in, tag); |
| + rc = rc ? rc : deserialize_ACL_vector(in, "acl", &v->acl); |
| + rc = rc ? rc : deserialize_Stat(in, "stat", &v->stat); |
| + rc = rc ? rc : in->end_record(in, tag); |
| + return rc; |
| +} |
| +void deallocate_GetACLResponse(struct GetACLResponse*v){ |
| + deallocate_ACL_vector(&v->acl); |
| + deallocate_Stat(&v->stat); |
| +} |
| +int serialize_CheckWatchesRequest(struct oarchive *out, const char *tag, struct CheckWatchesRequest *v){ |
| + int rc; |
| + rc = out->start_record(out, tag); |
| + rc = rc ? rc : out->serialize_String(out, "path", &v->path); |
| + rc = rc ? rc : out->serialize_Int(out, "type", &v->type); |
| + rc = rc ? rc : out->end_record(out, tag); |
| + return rc; |
| +} |
| +int deserialize_CheckWatchesRequest(struct iarchive *in, const char *tag, struct CheckWatchesRequest*v){ |
| + int rc; |
| + rc = in->start_record(in, tag); |
| + rc = rc ? rc : in->deserialize_String(in, "path", &v->path); |
| + rc = rc ? rc : in->deserialize_Int(in, "type", &v->type); |
| + rc = rc ? rc : in->end_record(in, tag); |
| + return rc; |
| +} |
| +void deallocate_CheckWatchesRequest(struct CheckWatchesRequest*v){ |
| + deallocate_String(&v->path); |
| +} |
| +int serialize_RemoveWatchesRequest(struct oarchive *out, const char *tag, struct RemoveWatchesRequest *v){ |
| + int rc; |
| + rc = out->start_record(out, tag); |
| + rc = rc ? rc : out->serialize_String(out, "path", &v->path); |
| + rc = rc ? rc : out->serialize_Int(out, "type", &v->type); |
| + rc = rc ? rc : out->end_record(out, tag); |
| + return rc; |
| +} |
| +int deserialize_RemoveWatchesRequest(struct iarchive *in, const char *tag, struct RemoveWatchesRequest*v){ |
| + int rc; |
| + rc = in->start_record(in, tag); |
| + rc = rc ? rc : in->deserialize_String(in, "path", &v->path); |
| + rc = rc ? rc : in->deserialize_Int(in, "type", &v->type); |
| + rc = rc ? rc : in->end_record(in, tag); |
| + return rc; |
| +} |
| +void deallocate_RemoveWatchesRequest(struct RemoveWatchesRequest*v){ |
| + deallocate_String(&v->path); |
| +} |
| +int serialize_GetEphemeralsRequest(struct oarchive *out, const char *tag, struct GetEphemeralsRequest *v){ |
| + int rc; |
| + rc = out->start_record(out, tag); |
| + rc = rc ? rc : out->serialize_String(out, "prefixPath", &v->prefixPath); |
| + rc = rc ? rc : out->end_record(out, tag); |
| + return rc; |
| +} |
| +int deserialize_GetEphemeralsRequest(struct iarchive *in, const char *tag, struct GetEphemeralsRequest*v){ |
| + int rc; |
| + rc = in->start_record(in, tag); |
| + rc = rc ? rc : in->deserialize_String(in, "prefixPath", &v->prefixPath); |
| + rc = rc ? rc : in->end_record(in, tag); |
| + return rc; |
| +} |
| +void deallocate_GetEphemeralsRequest(struct GetEphemeralsRequest*v){ |
| + deallocate_String(&v->prefixPath); |
| +} |
| +int serialize_GetEphemeralsResponse(struct oarchive *out, const char *tag, struct GetEphemeralsResponse *v){ |
| + int rc; |
| + rc = out->start_record(out, tag); |
| + rc = rc ? rc : serialize_String_vector(out, "ephemerals", &v->ephemerals); |
| + rc = rc ? rc : out->end_record(out, tag); |
| + return rc; |
| +} |
| +int deserialize_GetEphemeralsResponse(struct iarchive *in, const char *tag, struct GetEphemeralsResponse*v){ |
| + int rc; |
| + rc = in->start_record(in, tag); |
| + rc = rc ? rc : deserialize_String_vector(in, "ephemerals", &v->ephemerals); |
| + rc = rc ? rc : in->end_record(in, tag); |
| + return rc; |
| +} |
| +void deallocate_GetEphemeralsResponse(struct GetEphemeralsResponse*v){ |
| + deallocate_String_vector(&v->ephemerals); |
| +} |
| +int 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_TxnDigest(struct oarchive *out, const char *tag, struct TxnDigest *v){ |
| + int rc; |
| + rc = out->start_record(out, tag); |
| + rc = rc ? rc : out->serialize_Int(out, "version", &v->version); |
| + rc = rc ? rc : out->serialize_Long(out, "treeDigest", &v->treeDigest); |
| + rc = rc ? rc : out->end_record(out, tag); |
| + return rc; |
| +} |
| +int deserialize_TxnDigest(struct iarchive *in, const char *tag, struct TxnDigest*v){ |
| + int rc; |
| + rc = in->start_record(in, tag); |
| + rc = rc ? rc : in->deserialize_Int(in, "version", &v->version); |
| + rc = rc ? rc : in->deserialize_Long(in, "treeDigest", &v->treeDigest); |
| + rc = rc ? rc : in->end_record(in, tag); |
| + return rc; |
| +} |
| +void deallocate_TxnDigest(struct TxnDigest*v){ |
| +} |
| +int serialize_TxnHeader(struct oarchive *out, const char *tag, struct TxnHeader *v){ |
| + int rc; |
| + rc = out->start_record(out, tag); |
| + rc = rc ? rc : out->serialize_Long(out, "clientId", &v->clientId); |
| + rc = rc ? rc : out->serialize_Int(out, "cxid", &v->cxid); |
| + rc = rc ? rc : out->serialize_Long(out, "zxid", &v->zxid); |
| + rc = rc ? rc : out->serialize_Long(out, "time", &v->time); |
| + rc = rc ? rc : out->serialize_Int(out, "type", &v->type); |
| + rc = rc ? rc : out->end_record(out, tag); |
| + return rc; |
| +} |
| +int deserialize_TxnHeader(struct iarchive *in, const char *tag, struct TxnHeader*v){ |
| + int rc; |
| + rc = in->start_record(in, tag); |
| + rc = rc ? rc : in->deserialize_Long(in, "clientId", &v->clientId); |
| + rc = rc ? rc : in->deserialize_Int(in, "cxid", &v->cxid); |
| + rc = rc ? rc : in->deserialize_Long(in, "zxid", &v->zxid); |
| + rc = rc ? rc : in->deserialize_Long(in, "time", &v->time); |
| + rc = rc ? rc : in->deserialize_Int(in, "type", &v->type); |
| + rc = rc ? rc : in->end_record(in, tag); |
| + return rc; |
| +} |
| +void deallocate_TxnHeader(struct TxnHeader*v){ |
| +} |
| +int serialize_CreateTxnV0(struct oarchive *out, const char *tag, struct CreateTxnV0 *v){ |
| + int rc; |
| + rc = out->start_record(out, tag); |
| + rc = rc ? rc : out->serialize_String(out, "path", &v->path); |
| + rc = rc ? rc : out->serialize_Buffer(out, "data", &v->data); |
| + rc = rc ? rc : serialize_ACL_vector(out, "acl", &v->acl); |
| + rc = rc ? rc : out->serialize_Bool(out, "ephemeral", &v->ephemeral); |
| + rc = rc ? rc : out->end_record(out, tag); |
| + return rc; |
| +} |
| +int deserialize_CreateTxnV0(struct iarchive *in, const char *tag, struct CreateTxnV0*v){ |
| + int rc; |
| + rc = in->start_record(in, tag); |
| + rc = rc ? rc : in->deserialize_String(in, "path", &v->path); |
| + rc = rc ? rc : in->deserialize_Buffer(in, "data", &v->data); |
| + rc = rc ? rc : deserialize_ACL_vector(in, "acl", &v->acl); |
| + rc = rc ? rc : in->deserialize_Bool(in, "ephemeral", &v->ephemeral); |
| + rc = rc ? rc : in->end_record(in, tag); |
| + return rc; |
| +} |
| +void deallocate_CreateTxnV0(struct CreateTxnV0*v){ |
| + deallocate_String(&v->path); |
| + deallocate_Buffer(&v->data); |
| + deallocate_ACL_vector(&v->acl); |
| +} |
| +int serialize_CreateTxn(struct oarchive *out, const char *tag, struct CreateTxn *v){ |
| + int rc; |
| + rc = out->start_record(out, tag); |
| + rc = rc ? rc : out->serialize_String(out, "path", &v->path); |
| + rc = rc ? rc : out->serialize_Buffer(out, "data", &v->data); |
| + rc = rc ? rc : serialize_ACL_vector(out, "acl", &v->acl); |
| + rc = rc ? rc : out->serialize_Bool(out, "ephemeral", &v->ephemeral); |
| + rc = rc ? rc : out->serialize_Int(out, "parentCVersion", &v->parentCVersion); |
| + rc = rc ? rc : out->end_record(out, tag); |
| + return rc; |
| +} |
| +int deserialize_CreateTxn(struct iarchive *in, const char *tag, struct CreateTxn*v){ |
| + int rc; |
| + rc = in->start_record(in, tag); |
| + rc = rc ? rc : in->deserialize_String(in, "path", &v->path); |
| + rc = rc ? rc : in->deserialize_Buffer(in, "data", &v->data); |
| + rc = rc ? rc : deserialize_ACL_vector(in, "acl", &v->acl); |
| + rc = rc ? rc : in->deserialize_Bool(in, "ephemeral", &v->ephemeral); |
| + rc = rc ? rc : in->deserialize_Int(in, "parentCVersion", &v->parentCVersion); |
| + rc = rc ? rc : in->end_record(in, tag); |
| + return rc; |
| +} |
| +void deallocate_CreateTxn(struct CreateTxn*v){ |
| + deallocate_String(&v->path); |
| + deallocate_Buffer(&v->data); |
| + deallocate_ACL_vector(&v->acl); |
| +} |
| +int serialize_CreateTTLTxn(struct oarchive *out, const char *tag, struct CreateTTLTxn *v){ |
| + int rc; |
| + rc = out->start_record(out, tag); |
| + rc = rc ? rc : out->serialize_String(out, "path", &v->path); |
| + rc = rc ? rc : out->serialize_Buffer(out, "data", &v->data); |
| + rc = rc ? rc : serialize_ACL_vector(out, "acl", &v->acl); |
| + rc = rc ? rc : out->serialize_Int(out, "parentCVersion", &v->parentCVersion); |
| + rc = rc ? rc : out->serialize_Long(out, "ttl", &v->ttl); |
| + rc = rc ? rc : out->end_record(out, tag); |
| + return rc; |
| +} |
| +int deserialize_CreateTTLTxn(struct iarchive *in, const char *tag, struct CreateTTLTxn*v){ |
| + int rc; |
| + rc = in->start_record(in, tag); |
| + rc = rc ? rc : in->deserialize_String(in, "path", &v->path); |
| + rc = rc ? rc : in->deserialize_Buffer(in, "data", &v->data); |
| + rc = rc ? rc : deserialize_ACL_vector(in, "acl", &v->acl); |
| + rc = rc ? rc : in->deserialize_Int(in, "parentCVersion", &v->parentCVersion); |
| + rc = rc ? rc : in->deserialize_Long(in, "ttl", &v->ttl); |
| + rc = rc ? rc : in->end_record(in, tag); |
| + return rc; |
| +} |
| +void deallocate_CreateTTLTxn(struct CreateTTLTxn*v){ |
| + deallocate_String(&v->path); |
| + deallocate_Buffer(&v->data); |
| + deallocate_ACL_vector(&v->acl); |
| +} |
| +int serialize_CreateContainerTxn(struct oarchive *out, const char *tag, struct CreateContainerTxn *v){ |
| + int rc; |
| + rc = out->start_record(out, tag); |
| + rc = rc ? rc : out->serialize_String(out, "path", &v->path); |
| + rc = rc ? rc : out->serialize_Buffer(out, "data", &v->data); |
| + rc = rc ? rc : serialize_ACL_vector(out, "acl", &v->acl); |
| + rc = rc ? rc : out->serialize_Int(out, "parentCVersion", &v->parentCVersion); |
| + rc = rc ? rc : out->end_record(out, tag); |
| + return rc; |
| +} |
| +int deserialize_CreateContainerTxn(struct iarchive *in, const char *tag, struct CreateContainerTxn*v){ |
| + int rc; |
| + rc = in->start_record(in, tag); |
| + rc = rc ? rc : in->deserialize_String(in, "path", &v->path); |
| + rc = rc ? rc : in->deserialize_Buffer(in, "data", &v->data); |
| + rc = rc ? rc : deserialize_ACL_vector(in, "acl", &v->acl); |
| + rc = rc ? rc : in->deserialize_Int(in, "parentCVersion", &v->parentCVersion); |
| + rc = rc ? rc : in->end_record(in, tag); |
| + return rc; |
| +} |
| +void deallocate_CreateContainerTxn(struct CreateContainerTxn*v){ |
| + deallocate_String(&v->path); |
| + deallocate_Buffer(&v->data); |
| + deallocate_ACL_vector(&v->acl); |
| +} |
| +int serialize_DeleteTxn(struct oarchive *out, const char *tag, struct DeleteTxn *v){ |
| + int rc; |
| + rc = out->start_record(out, tag); |
| + rc = rc ? rc : out->serialize_String(out, "path", &v->path); |
| + rc = rc ? rc : out->end_record(out, tag); |
| + return rc; |
| +} |
| +int deserialize_DeleteTxn(struct iarchive *in, const char *tag, struct DeleteTxn*v){ |
| + int rc; |
| + rc = in->start_record(in, tag); |
| + rc = rc ? rc : in->deserialize_String(in, "path", &v->path); |
| + rc = rc ? rc : in->end_record(in, tag); |
| + return rc; |
| +} |
| +void deallocate_DeleteTxn(struct DeleteTxn*v){ |
| + deallocate_String(&v->path); |
| +} |
| +int serialize_SetDataTxn(struct oarchive *out, const char *tag, struct SetDataTxn *v){ |
| + int rc; |
| + rc = out->start_record(out, tag); |
| + rc = rc ? rc : out->serialize_String(out, "path", &v->path); |
| + rc = rc ? rc : out->serialize_Buffer(out, "data", &v->data); |
| + rc = rc ? rc : out->serialize_Int(out, "version", &v->version); |
| + rc = rc ? rc : out->end_record(out, tag); |
| + return rc; |
| +} |
| +int deserialize_SetDataTxn(struct iarchive *in, const char *tag, struct SetDataTxn*v){ |
| + int rc; |
| + rc = in->start_record(in, tag); |
| + rc = rc ? rc : in->deserialize_String(in, "path", &v->path); |
| + rc = rc ? rc : in->deserialize_Buffer(in, "data", &v->data); |
| + rc = rc ? rc : in->deserialize_Int(in, "version", &v->version); |
| + rc = rc ? rc : in->end_record(in, tag); |
| + return rc; |
| +} |
| +void deallocate_SetDataTxn(struct SetDataTxn*v){ |
| + deallocate_String(&v->path); |
| + deallocate_Buffer(&v->data); |
| +} |
| +int serialize_CheckVersionTxn(struct oarchive *out, const char *tag, struct CheckVersionTxn *v){ |
| + int rc; |
| + rc = out->start_record(out, tag); |
| + rc = rc ? rc : out->serialize_String(out, "path", &v->path); |
| + rc = rc ? rc : out->serialize_Int(out, "version", &v->version); |
| + rc = rc ? rc : out->end_record(out, tag); |
| + return rc; |
| +} |
| +int deserialize_CheckVersionTxn(struct iarchive *in, const char *tag, struct CheckVersionTxn*v){ |
| + int rc; |
| + rc = in->start_record(in, tag); |
| + rc = rc ? rc : in->deserialize_String(in, "path", &v->path); |
| + rc = rc ? rc : in->deserialize_Int(in, "version", &v->version); |
| + rc = rc ? rc : in->end_record(in, tag); |
| + return rc; |
| +} |
| +void deallocate_CheckVersionTxn(struct CheckVersionTxn*v){ |
| + deallocate_String(&v->path); |
| +} |
| +int serialize_SetACLTxn(struct oarchive *out, const char *tag, struct SetACLTxn *v){ |
| + int rc; |
| + rc = out->start_record(out, tag); |
| + rc = rc ? rc : out->serialize_String(out, "path", &v->path); |
| + rc = rc ? rc : serialize_ACL_vector(out, "acl", &v->acl); |
| + rc = rc ? rc : out->serialize_Int(out, "version", &v->version); |
| + rc = rc ? rc : out->end_record(out, tag); |
| + return rc; |
| +} |
| +int deserialize_SetACLTxn(struct iarchive *in, const char *tag, struct SetACLTxn*v){ |
| + int rc; |
| + rc = in->start_record(in, tag); |
| + rc = rc ? rc : in->deserialize_String(in, "path", &v->path); |
| + rc = rc ? rc : deserialize_ACL_vector(in, "acl", &v->acl); |
| + rc = rc ? rc : in->deserialize_Int(in, "version", &v->version); |
| + rc = rc ? rc : in->end_record(in, tag); |
| + return rc; |
| +} |
| +void deallocate_SetACLTxn(struct SetACLTxn*v){ |
| + deallocate_String(&v->path); |
| + deallocate_ACL_vector(&v->acl); |
| +} |
| +int serialize_SetMaxChildrenTxn(struct oarchive *out, const char *tag, struct SetMaxChildrenTxn *v){ |
| + int rc; |
| + rc = out->start_record(out, tag); |
| + rc = rc ? rc : out->serialize_String(out, "path", &v->path); |
| + rc = rc ? rc : out->serialize_Int(out, "max", &v->max); |
| + rc = rc ? rc : out->end_record(out, tag); |
| + return rc; |
| +} |
| +int deserialize_SetMaxChildrenTxn(struct iarchive *in, const char *tag, struct SetMaxChildrenTxn*v){ |
| + int rc; |
| + rc = in->start_record(in, tag); |
| + rc = rc ? rc : in->deserialize_String(in, "path", &v->path); |
| + rc = rc ? rc : in->deserialize_Int(in, "max", &v->max); |
| + rc = rc ? rc : in->end_record(in, tag); |
| + return rc; |
| +} |
| +void deallocate_SetMaxChildrenTxn(struct SetMaxChildrenTxn*v){ |
| + deallocate_String(&v->path); |
| +} |
| +int serialize_CreateSessionTxn(struct oarchive *out, const char *tag, struct CreateSessionTxn *v){ |
| + int rc; |
| + rc = out->start_record(out, tag); |
| + rc = rc ? rc : out->serialize_Int(out, "timeOut", &v->timeOut); |
| + rc = rc ? rc : out->end_record(out, tag); |
| + return rc; |
| +} |
| +int deserialize_CreateSessionTxn(struct iarchive *in, const char *tag, struct CreateSessionTxn*v){ |
| + int rc; |
| + rc = in->start_record(in, tag); |
| + rc = rc ? rc : in->deserialize_Int(in, "timeOut", &v->timeOut); |
| + rc = rc ? rc : in->end_record(in, tag); |
| + return rc; |
| +} |
| +void deallocate_CreateSessionTxn(struct CreateSessionTxn*v){ |
| +} |
| +int serialize_CloseSessionTxn(struct oarchive *out, const char *tag, struct CloseSessionTxn *v){ |
| + int rc; |
| + rc = out->start_record(out, tag); |
| + rc = rc ? rc : serialize_String_vector(out, "paths2Delete", &v->paths2Delete); |
| + rc = rc ? rc : out->end_record(out, tag); |
| + return rc; |
| +} |
| +int deserialize_CloseSessionTxn(struct iarchive *in, const char *tag, struct CloseSessionTxn*v){ |
| + int rc; |
| + rc = in->start_record(in, tag); |
| + rc = rc ? rc : deserialize_String_vector(in, "paths2Delete", &v->paths2Delete); |
| + rc = rc ? rc : in->end_record(in, tag); |
| + return rc; |
| +} |
| +void deallocate_CloseSessionTxn(struct CloseSessionTxn*v){ |
| + deallocate_String_vector(&v->paths2Delete); |
| +} |
| +int serialize_ErrorTxn(struct oarchive *out, const char *tag, struct ErrorTxn *v){ |
| + int rc; |
| + rc = out->start_record(out, tag); |
| + rc = rc ? rc : out->serialize_Int(out, "err", &v->err); |
| + rc = rc ? rc : out->end_record(out, tag); |
| + return rc; |
| +} |
| +int deserialize_ErrorTxn(struct iarchive *in, const char *tag, struct ErrorTxn*v){ |
| + int rc; |
| + rc = in->start_record(in, tag); |
| + rc = rc ? rc : in->deserialize_Int(in, "err", &v->err); |
| + rc = rc ? rc : in->end_record(in, tag); |
| + return rc; |
| +} |
| +void deallocate_ErrorTxn(struct ErrorTxn*v){ |
| +} |
| +int serialize_Txn(struct oarchive *out, const char *tag, struct Txn *v){ |
| + int rc; |
| + rc = out->start_record(out, tag); |
| + rc = rc ? rc : out->serialize_Int(out, "type", &v->type); |
| + rc = rc ? rc : out->serialize_Buffer(out, "data", &v->data); |
| + rc = rc ? rc : out->end_record(out, tag); |
| + return rc; |
| +} |
| +int deserialize_Txn(struct iarchive *in, const char *tag, struct Txn*v){ |
| + int rc; |
| + rc = in->start_record(in, tag); |
| + rc = rc ? rc : in->deserialize_Int(in, "type", &v->type); |
| + rc = rc ? rc : in->deserialize_Buffer(in, "data", &v->data); |
| + rc = rc ? rc : in->end_record(in, tag); |
| + return rc; |
| +} |
| +void deallocate_Txn(struct Txn*v){ |
| + deallocate_Buffer(&v->data); |
| +} |
| +int allocate_Txn_vector(struct Txn_vector *v, int32_t len) { |
| + if (!len) { |
| + v->count = 0; |
| + v->data = 0; |
| + } else { |
| + v->count = len; |
| + v->data = calloc(sizeof(*v->data), len); |
| + } |
| + return 0; |
| +} |
| +int deallocate_Txn_vector(struct Txn_vector *v) { |
| + if (v->data) { |
| + int32_t i; |
| + for(i=0;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); |
| +} |
| diff -urN apache-zookeeper-3.6.3.orig/zookeeper-client/zookeeper-client-c/generated/zookeeper.jute.h apache-zookeeper-3.6.3.desired/zookeeper-client/zookeeper-client-c/generated/zookeeper.jute.h |
| --- apache-zookeeper-3.6.3.orig/zookeeper-client/zookeeper-client-c/generated/zookeeper.jute.h 1970-01-01 00:00:00.000000000 +0000 |
| +++ apache-zookeeper-3.6.3.desired/zookeeper-client/zookeeper-client-c/generated/zookeeper.jute.h 2021-04-18 05:41:30.647076266 +0000 |
| @@ -0,0 +1,595 @@ |
| +/** |
| +* 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 SetWatches2 { |
| + int64_t relativeZxid; |
| + struct String_vector dataWatches; |
| + struct String_vector existWatches; |
| + struct String_vector childWatches; |
| + struct String_vector persistentWatches; |
| + struct String_vector persistentRecursiveWatches; |
| +}; |
| +int serialize_SetWatches2(struct oarchive *out, const char *tag, struct SetWatches2 *v); |
| +int deserialize_SetWatches2(struct iarchive *in, const char *tag, struct SetWatches2*v); |
| +void deallocate_SetWatches2(struct SetWatches2*); |
| +struct RequestHeader { |
| + int32_t xid; |
| + int32_t type; |
| +}; |
| +int serialize_RequestHeader(struct oarchive *out, const char *tag, struct RequestHeader *v); |
| +int deserialize_RequestHeader(struct iarchive *in, const char *tag, struct RequestHeader*v); |
| +void deallocate_RequestHeader(struct RequestHeader*); |
| +struct MultiHeader { |
| + int32_t type; |
| + int32_t done; |
| + int32_t err; |
| +}; |
| +int serialize_MultiHeader(struct oarchive *out, const char *tag, struct MultiHeader *v); |
| +int deserialize_MultiHeader(struct iarchive *in, const char *tag, struct MultiHeader*v); |
| +void deallocate_MultiHeader(struct MultiHeader*); |
| +struct AuthPacket { |
| + int32_t type; |
| + char * scheme; |
| + struct buffer auth; |
| +}; |
| +int serialize_AuthPacket(struct oarchive *out, const char *tag, struct AuthPacket *v); |
| +int deserialize_AuthPacket(struct iarchive *in, const char *tag, struct AuthPacket*v); |
| +void deallocate_AuthPacket(struct AuthPacket*); |
| +struct ReplyHeader { |
| + int32_t xid; |
| + int64_t zxid; |
| + int32_t err; |
| +}; |
| +int serialize_ReplyHeader(struct oarchive *out, const char *tag, struct ReplyHeader *v); |
| +int deserialize_ReplyHeader(struct iarchive *in, const char *tag, struct ReplyHeader*v); |
| +void deallocate_ReplyHeader(struct ReplyHeader*); |
| +struct GetDataRequest { |
| + char * path; |
| + int32_t watch; |
| +}; |
| +int serialize_GetDataRequest(struct oarchive *out, const char *tag, struct GetDataRequest *v); |
| +int deserialize_GetDataRequest(struct iarchive *in, const char *tag, struct GetDataRequest*v); |
| +void deallocate_GetDataRequest(struct GetDataRequest*); |
| +struct SetDataRequest { |
| + char * path; |
| + struct buffer data; |
| + int32_t version; |
| +}; |
| +int serialize_SetDataRequest(struct oarchive *out, const char *tag, struct SetDataRequest *v); |
| +int deserialize_SetDataRequest(struct iarchive *in, const char *tag, struct SetDataRequest*v); |
| +void deallocate_SetDataRequest(struct SetDataRequest*); |
| +struct ReconfigRequest { |
| + char * joiningServers; |
| + char * leavingServers; |
| + char * newMembers; |
| + int64_t curConfigId; |
| +}; |
| +int serialize_ReconfigRequest(struct oarchive *out, const char *tag, struct ReconfigRequest *v); |
| +int deserialize_ReconfigRequest(struct iarchive *in, const char *tag, struct ReconfigRequest*v); |
| +void deallocate_ReconfigRequest(struct ReconfigRequest*); |
| +struct SetDataResponse { |
| + struct Stat stat; |
| +}; |
| +int serialize_SetDataResponse(struct oarchive *out, const char *tag, struct SetDataResponse *v); |
| +int deserialize_SetDataResponse(struct iarchive *in, const char *tag, struct SetDataResponse*v); |
| +void deallocate_SetDataResponse(struct SetDataResponse*); |
| +struct GetSASLRequest { |
| + struct buffer token; |
| +}; |
| +int serialize_GetSASLRequest(struct oarchive *out, const char *tag, struct GetSASLRequest *v); |
| +int deserialize_GetSASLRequest(struct iarchive *in, const char *tag, struct GetSASLRequest*v); |
| +void deallocate_GetSASLRequest(struct GetSASLRequest*); |
| +struct SetSASLRequest { |
| + struct buffer token; |
| +}; |
| +int serialize_SetSASLRequest(struct oarchive *out, const char *tag, struct SetSASLRequest *v); |
| +int deserialize_SetSASLRequest(struct iarchive *in, const char *tag, struct SetSASLRequest*v); |
| +void deallocate_SetSASLRequest(struct SetSASLRequest*); |
| +struct SetSASLResponse { |
| + struct buffer token; |
| +}; |
| +int serialize_SetSASLResponse(struct oarchive *out, const char *tag, struct SetSASLResponse *v); |
| +int deserialize_SetSASLResponse(struct iarchive *in, const char *tag, struct SetSASLResponse*v); |
| +void deallocate_SetSASLResponse(struct SetSASLResponse*); |
| +struct ACL_vector { |
| + int32_t count; |
| + struct ACL *data; |
| + |
| +}; |
| +int serialize_ACL_vector(struct oarchive *out, const char *tag, struct ACL_vector *v); |
| +int deserialize_ACL_vector(struct iarchive *in, const char *tag, struct ACL_vector *v); |
| +int allocate_ACL_vector(struct ACL_vector *v, int32_t len); |
| +int deallocate_ACL_vector(struct ACL_vector *v); |
| +struct CreateRequest { |
| + char * path; |
| + struct buffer data; |
| + struct ACL_vector acl; |
| + int32_t flags; |
| +}; |
| +int serialize_CreateRequest(struct oarchive *out, const char *tag, struct CreateRequest *v); |
| +int deserialize_CreateRequest(struct iarchive *in, const char *tag, struct CreateRequest*v); |
| +void deallocate_CreateRequest(struct CreateRequest*); |
| +struct CreateTTLRequest { |
| + char * path; |
| + struct buffer data; |
| + struct ACL_vector acl; |
| + int32_t flags; |
| + int64_t ttl; |
| +}; |
| +int serialize_CreateTTLRequest(struct oarchive *out, const char *tag, struct CreateTTLRequest *v); |
| +int deserialize_CreateTTLRequest(struct iarchive *in, const char *tag, struct CreateTTLRequest*v); |
| +void deallocate_CreateTTLRequest(struct CreateTTLRequest*); |
| +struct DeleteRequest { |
| + char * path; |
| + int32_t version; |
| +}; |
| +int serialize_DeleteRequest(struct oarchive *out, const char *tag, struct DeleteRequest *v); |
| +int deserialize_DeleteRequest(struct iarchive *in, const char *tag, struct DeleteRequest*v); |
| +void deallocate_DeleteRequest(struct DeleteRequest*); |
| +struct GetChildrenRequest { |
| + char * path; |
| + int32_t watch; |
| +}; |
| +int serialize_GetChildrenRequest(struct oarchive *out, const char *tag, struct GetChildrenRequest *v); |
| +int deserialize_GetChildrenRequest(struct iarchive *in, const char *tag, struct GetChildrenRequest*v); |
| +void deallocate_GetChildrenRequest(struct GetChildrenRequest*); |
| +struct GetAllChildrenNumberRequest { |
| + char * path; |
| +}; |
| +int serialize_GetAllChildrenNumberRequest(struct oarchive *out, const char *tag, struct GetAllChildrenNumberRequest *v); |
| +int deserialize_GetAllChildrenNumberRequest(struct iarchive *in, const char *tag, struct GetAllChildrenNumberRequest*v); |
| +void deallocate_GetAllChildrenNumberRequest(struct GetAllChildrenNumberRequest*); |
| +struct GetChildren2Request { |
| + char * path; |
| + int32_t watch; |
| +}; |
| +int serialize_GetChildren2Request(struct oarchive *out, const char *tag, struct GetChildren2Request *v); |
| +int deserialize_GetChildren2Request(struct iarchive *in, const char *tag, struct GetChildren2Request*v); |
| +void deallocate_GetChildren2Request(struct GetChildren2Request*); |
| +struct CheckVersionRequest { |
| + char * path; |
| + int32_t version; |
| +}; |
| +int serialize_CheckVersionRequest(struct oarchive *out, const char *tag, struct CheckVersionRequest *v); |
| +int deserialize_CheckVersionRequest(struct iarchive *in, const char *tag, struct CheckVersionRequest*v); |
| +void deallocate_CheckVersionRequest(struct CheckVersionRequest*); |
| +struct GetMaxChildrenRequest { |
| + char * path; |
| +}; |
| +int serialize_GetMaxChildrenRequest(struct oarchive *out, const char *tag, struct GetMaxChildrenRequest *v); |
| +int deserialize_GetMaxChildrenRequest(struct iarchive *in, const char *tag, struct GetMaxChildrenRequest*v); |
| +void deallocate_GetMaxChildrenRequest(struct GetMaxChildrenRequest*); |
| +struct GetMaxChildrenResponse { |
| + int32_t max; |
| +}; |
| +int serialize_GetMaxChildrenResponse(struct oarchive *out, const char *tag, struct GetMaxChildrenResponse *v); |
| +int deserialize_GetMaxChildrenResponse(struct iarchive *in, const char *tag, struct GetMaxChildrenResponse*v); |
| +void deallocate_GetMaxChildrenResponse(struct GetMaxChildrenResponse*); |
| +struct SetMaxChildrenRequest { |
| + char * path; |
| + int32_t max; |
| +}; |
| +int serialize_SetMaxChildrenRequest(struct oarchive *out, const char *tag, struct SetMaxChildrenRequest *v); |
| +int deserialize_SetMaxChildrenRequest(struct iarchive *in, const char *tag, struct SetMaxChildrenRequest*v); |
| +void deallocate_SetMaxChildrenRequest(struct SetMaxChildrenRequest*); |
| +struct SyncRequest { |
| + char * path; |
| +}; |
| +int serialize_SyncRequest(struct oarchive *out, const char *tag, struct SyncRequest *v); |
| +int deserialize_SyncRequest(struct iarchive *in, const char *tag, struct SyncRequest*v); |
| +void deallocate_SyncRequest(struct SyncRequest*); |
| +struct SyncResponse { |
| + char * path; |
| +}; |
| +int serialize_SyncResponse(struct oarchive *out, const char *tag, struct SyncResponse *v); |
| +int deserialize_SyncResponse(struct iarchive *in, const char *tag, struct SyncResponse*v); |
| +void deallocate_SyncResponse(struct SyncResponse*); |
| +struct GetACLRequest { |
| + char * path; |
| +}; |
| +int serialize_GetACLRequest(struct oarchive *out, const char *tag, struct GetACLRequest *v); |
| +int deserialize_GetACLRequest(struct iarchive *in, const char *tag, struct GetACLRequest*v); |
| +void deallocate_GetACLRequest(struct GetACLRequest*); |
| +struct SetACLRequest { |
| + char * path; |
| + struct ACL_vector acl; |
| + int32_t version; |
| +}; |
| +int serialize_SetACLRequest(struct oarchive *out, const char *tag, struct SetACLRequest *v); |
| +int deserialize_SetACLRequest(struct iarchive *in, const char *tag, struct SetACLRequest*v); |
| +void deallocate_SetACLRequest(struct SetACLRequest*); |
| +struct SetACLResponse { |
| + struct Stat stat; |
| +}; |
| +int serialize_SetACLResponse(struct oarchive *out, const char *tag, struct SetACLResponse *v); |
| +int deserialize_SetACLResponse(struct iarchive *in, const char *tag, struct SetACLResponse*v); |
| +void deallocate_SetACLResponse(struct SetACLResponse*); |
| +struct AddWatchRequest { |
| + char * path; |
| + int32_t mode; |
| +}; |
| +int serialize_AddWatchRequest(struct oarchive *out, const char *tag, struct AddWatchRequest *v); |
| +int deserialize_AddWatchRequest(struct iarchive *in, const char *tag, struct AddWatchRequest*v); |
| +void deallocate_AddWatchRequest(struct AddWatchRequest*); |
| +struct WatcherEvent { |
| + int32_t type; |
| + int32_t state; |
| + char * path; |
| +}; |
| +int serialize_WatcherEvent(struct oarchive *out, const char *tag, struct WatcherEvent *v); |
| +int deserialize_WatcherEvent(struct iarchive *in, const char *tag, struct WatcherEvent*v); |
| +void deallocate_WatcherEvent(struct WatcherEvent*); |
| +struct ErrorResponse { |
| + int32_t err; |
| +}; |
| +int serialize_ErrorResponse(struct oarchive *out, const char *tag, struct ErrorResponse *v); |
| +int deserialize_ErrorResponse(struct iarchive *in, const char *tag, struct ErrorResponse*v); |
| +void deallocate_ErrorResponse(struct ErrorResponse*); |
| +struct CreateResponse { |
| + char * path; |
| +}; |
| +int serialize_CreateResponse(struct oarchive *out, const char *tag, struct CreateResponse *v); |
| +int deserialize_CreateResponse(struct iarchive *in, const char *tag, struct CreateResponse*v); |
| +void deallocate_CreateResponse(struct CreateResponse*); |
| +struct Create2Response { |
| + char * path; |
| + struct Stat stat; |
| +}; |
| +int serialize_Create2Response(struct oarchive *out, const char *tag, struct Create2Response *v); |
| +int deserialize_Create2Response(struct iarchive *in, const char *tag, struct Create2Response*v); |
| +void deallocate_Create2Response(struct Create2Response*); |
| +struct ExistsRequest { |
| + char * path; |
| + int32_t watch; |
| +}; |
| +int serialize_ExistsRequest(struct oarchive *out, const char *tag, struct ExistsRequest *v); |
| +int deserialize_ExistsRequest(struct iarchive *in, const char *tag, struct ExistsRequest*v); |
| +void deallocate_ExistsRequest(struct ExistsRequest*); |
| +struct ExistsResponse { |
| + struct Stat stat; |
| +}; |
| +int serialize_ExistsResponse(struct oarchive *out, const char *tag, struct ExistsResponse *v); |
| +int deserialize_ExistsResponse(struct iarchive *in, const char *tag, struct ExistsResponse*v); |
| +void deallocate_ExistsResponse(struct ExistsResponse*); |
| +struct GetDataResponse { |
| + struct buffer data; |
| + struct Stat stat; |
| +}; |
| +int serialize_GetDataResponse(struct oarchive *out, const char *tag, struct GetDataResponse *v); |
| +int deserialize_GetDataResponse(struct iarchive *in, const char *tag, struct GetDataResponse*v); |
| +void deallocate_GetDataResponse(struct GetDataResponse*); |
| +struct GetChildrenResponse { |
| + struct String_vector children; |
| +}; |
| +int serialize_GetChildrenResponse(struct oarchive *out, const char *tag, struct GetChildrenResponse *v); |
| +int deserialize_GetChildrenResponse(struct iarchive *in, const char *tag, struct GetChildrenResponse*v); |
| +void deallocate_GetChildrenResponse(struct GetChildrenResponse*); |
| +struct GetAllChildrenNumberResponse { |
| + int32_t totalNumber; |
| +}; |
| +int serialize_GetAllChildrenNumberResponse(struct oarchive *out, const char *tag, struct GetAllChildrenNumberResponse *v); |
| +int deserialize_GetAllChildrenNumberResponse(struct iarchive *in, const char *tag, struct GetAllChildrenNumberResponse*v); |
| +void deallocate_GetAllChildrenNumberResponse(struct GetAllChildrenNumberResponse*); |
| +struct GetChildren2Response { |
| + struct String_vector children; |
| + struct Stat stat; |
| +}; |
| +int serialize_GetChildren2Response(struct oarchive *out, const char *tag, struct GetChildren2Response *v); |
| +int deserialize_GetChildren2Response(struct iarchive *in, const char *tag, struct GetChildren2Response*v); |
| +void deallocate_GetChildren2Response(struct GetChildren2Response*); |
| +struct GetACLResponse { |
| + struct ACL_vector acl; |
| + struct Stat stat; |
| +}; |
| +int serialize_GetACLResponse(struct oarchive *out, const char *tag, struct GetACLResponse *v); |
| +int deserialize_GetACLResponse(struct iarchive *in, const char *tag, struct GetACLResponse*v); |
| +void deallocate_GetACLResponse(struct GetACLResponse*); |
| +struct CheckWatchesRequest { |
| + char * path; |
| + int32_t type; |
| +}; |
| +int serialize_CheckWatchesRequest(struct oarchive *out, const char *tag, struct CheckWatchesRequest *v); |
| +int deserialize_CheckWatchesRequest(struct iarchive *in, const char *tag, struct CheckWatchesRequest*v); |
| +void deallocate_CheckWatchesRequest(struct CheckWatchesRequest*); |
| +struct RemoveWatchesRequest { |
| + char * path; |
| + int32_t type; |
| +}; |
| +int serialize_RemoveWatchesRequest(struct oarchive *out, const char *tag, struct RemoveWatchesRequest *v); |
| +int deserialize_RemoveWatchesRequest(struct iarchive *in, const char *tag, struct RemoveWatchesRequest*v); |
| +void deallocate_RemoveWatchesRequest(struct RemoveWatchesRequest*); |
| +struct GetEphemeralsRequest { |
| + char * prefixPath; |
| +}; |
| +int serialize_GetEphemeralsRequest(struct oarchive *out, const char *tag, struct GetEphemeralsRequest *v); |
| +int deserialize_GetEphemeralsRequest(struct iarchive *in, const char *tag, struct GetEphemeralsRequest*v); |
| +void deallocate_GetEphemeralsRequest(struct GetEphemeralsRequest*); |
| +struct GetEphemeralsResponse { |
| + struct String_vector ephemerals; |
| +}; |
| +int serialize_GetEphemeralsResponse(struct oarchive *out, const char *tag, struct GetEphemeralsResponse *v); |
| +int deserialize_GetEphemeralsResponse(struct iarchive *in, const char *tag, struct GetEphemeralsResponse*v); |
| +void deallocate_GetEphemeralsResponse(struct GetEphemeralsResponse*); |
| +struct LearnerInfo { |
| + int64_t serverid; |
| + int32_t protocolVersion; |
| + int64_t configVersion; |
| +}; |
| +int serialize_LearnerInfo(struct oarchive *out, const char *tag, struct LearnerInfo *v); |
| +int deserialize_LearnerInfo(struct iarchive *in, const char *tag, struct LearnerInfo*v); |
| +void deallocate_LearnerInfo(struct LearnerInfo*); |
| +struct Id_vector { |
| + int32_t count; |
| + struct Id *data; |
| + |
| +}; |
| +int serialize_Id_vector(struct oarchive *out, const char *tag, struct Id_vector *v); |
| +int deserialize_Id_vector(struct iarchive *in, const char *tag, struct Id_vector *v); |
| +int allocate_Id_vector(struct Id_vector *v, int32_t len); |
| +int deallocate_Id_vector(struct Id_vector *v); |
| +struct QuorumPacket { |
| + int32_t type; |
| + int64_t zxid; |
| + struct buffer data; |
| + struct Id_vector authinfo; |
| +}; |
| +int serialize_QuorumPacket(struct oarchive *out, const char *tag, struct QuorumPacket *v); |
| +int deserialize_QuorumPacket(struct iarchive *in, const char *tag, struct QuorumPacket*v); |
| +void deallocate_QuorumPacket(struct QuorumPacket*); |
| +struct QuorumAuthPacket { |
| + int64_t magic; |
| + int32_t status; |
| + struct buffer token; |
| +}; |
| +int serialize_QuorumAuthPacket(struct oarchive *out, const char *tag, struct QuorumAuthPacket *v); |
| +int deserialize_QuorumAuthPacket(struct iarchive *in, const char *tag, struct QuorumAuthPacket*v); |
| +void deallocate_QuorumAuthPacket(struct QuorumAuthPacket*); |
| +struct FileHeader { |
| + int32_t magic; |
| + int32_t version; |
| + int64_t dbid; |
| +}; |
| +int serialize_FileHeader(struct oarchive *out, const char *tag, struct FileHeader *v); |
| +int deserialize_FileHeader(struct iarchive *in, const char *tag, struct FileHeader*v); |
| +void deallocate_FileHeader(struct FileHeader*); |
| +struct TxnDigest { |
| + int32_t version; |
| + int64_t treeDigest; |
| +}; |
| +int serialize_TxnDigest(struct oarchive *out, const char *tag, struct TxnDigest *v); |
| +int deserialize_TxnDigest(struct iarchive *in, const char *tag, struct TxnDigest*v); |
| +void deallocate_TxnDigest(struct TxnDigest*); |
| +struct TxnHeader { |
| + int64_t clientId; |
| + int32_t cxid; |
| + int64_t zxid; |
| + int64_t time; |
| + int32_t type; |
| +}; |
| +int serialize_TxnHeader(struct oarchive *out, const char *tag, struct TxnHeader *v); |
| +int deserialize_TxnHeader(struct iarchive *in, const char *tag, struct TxnHeader*v); |
| +void deallocate_TxnHeader(struct TxnHeader*); |
| +struct CreateTxnV0 { |
| + char * path; |
| + struct buffer data; |
| + struct ACL_vector acl; |
| + int32_t ephemeral; |
| +}; |
| +int serialize_CreateTxnV0(struct oarchive *out, const char *tag, struct CreateTxnV0 *v); |
| +int deserialize_CreateTxnV0(struct iarchive *in, const char *tag, struct CreateTxnV0*v); |
| +void deallocate_CreateTxnV0(struct CreateTxnV0*); |
| +struct CreateTxn { |
| + char * path; |
| + struct buffer data; |
| + struct ACL_vector acl; |
| + int32_t ephemeral; |
| + int32_t parentCVersion; |
| +}; |
| +int serialize_CreateTxn(struct oarchive *out, const char *tag, struct CreateTxn *v); |
| +int deserialize_CreateTxn(struct iarchive *in, const char *tag, struct CreateTxn*v); |
| +void deallocate_CreateTxn(struct CreateTxn*); |
| +struct CreateTTLTxn { |
| + char * path; |
| + struct buffer data; |
| + struct ACL_vector acl; |
| + int32_t parentCVersion; |
| + int64_t ttl; |
| +}; |
| +int serialize_CreateTTLTxn(struct oarchive *out, const char *tag, struct CreateTTLTxn *v); |
| +int deserialize_CreateTTLTxn(struct iarchive *in, const char *tag, struct CreateTTLTxn*v); |
| +void deallocate_CreateTTLTxn(struct CreateTTLTxn*); |
| +struct CreateContainerTxn { |
| + char * path; |
| + struct buffer data; |
| + struct ACL_vector acl; |
| + int32_t parentCVersion; |
| +}; |
| +int serialize_CreateContainerTxn(struct oarchive *out, const char *tag, struct CreateContainerTxn *v); |
| +int deserialize_CreateContainerTxn(struct iarchive *in, const char *tag, struct CreateContainerTxn*v); |
| +void deallocate_CreateContainerTxn(struct CreateContainerTxn*); |
| +struct DeleteTxn { |
| + char * path; |
| +}; |
| +int serialize_DeleteTxn(struct oarchive *out, const char *tag, struct DeleteTxn *v); |
| +int deserialize_DeleteTxn(struct iarchive *in, const char *tag, struct DeleteTxn*v); |
| +void deallocate_DeleteTxn(struct DeleteTxn*); |
| +struct SetDataTxn { |
| + char * path; |
| + struct buffer data; |
| + int32_t version; |
| +}; |
| +int serialize_SetDataTxn(struct oarchive *out, const char *tag, struct SetDataTxn *v); |
| +int deserialize_SetDataTxn(struct iarchive *in, const char *tag, struct SetDataTxn*v); |
| +void deallocate_SetDataTxn(struct SetDataTxn*); |
| +struct CheckVersionTxn { |
| + char * path; |
| + int32_t version; |
| +}; |
| +int serialize_CheckVersionTxn(struct oarchive *out, const char *tag, struct CheckVersionTxn *v); |
| +int deserialize_CheckVersionTxn(struct iarchive *in, const char *tag, struct CheckVersionTxn*v); |
| +void deallocate_CheckVersionTxn(struct CheckVersionTxn*); |
| +struct SetACLTxn { |
| + char * path; |
| + struct ACL_vector acl; |
| + int32_t version; |
| +}; |
| +int serialize_SetACLTxn(struct oarchive *out, const char *tag, struct SetACLTxn *v); |
| +int deserialize_SetACLTxn(struct iarchive *in, const char *tag, struct SetACLTxn*v); |
| +void deallocate_SetACLTxn(struct SetACLTxn*); |
| +struct SetMaxChildrenTxn { |
| + char * path; |
| + int32_t max; |
| +}; |
| +int serialize_SetMaxChildrenTxn(struct oarchive *out, const char *tag, struct SetMaxChildrenTxn *v); |
| +int deserialize_SetMaxChildrenTxn(struct iarchive *in, const char *tag, struct SetMaxChildrenTxn*v); |
| +void deallocate_SetMaxChildrenTxn(struct SetMaxChildrenTxn*); |
| +struct CreateSessionTxn { |
| + int32_t timeOut; |
| +}; |
| +int serialize_CreateSessionTxn(struct oarchive *out, const char *tag, struct CreateSessionTxn *v); |
| +int deserialize_CreateSessionTxn(struct iarchive *in, const char *tag, struct CreateSessionTxn*v); |
| +void deallocate_CreateSessionTxn(struct CreateSessionTxn*); |
| +struct CloseSessionTxn { |
| + struct String_vector paths2Delete; |
| +}; |
| +int serialize_CloseSessionTxn(struct oarchive *out, const char *tag, struct CloseSessionTxn *v); |
| +int deserialize_CloseSessionTxn(struct iarchive *in, const char *tag, struct CloseSessionTxn*v); |
| +void deallocate_CloseSessionTxn(struct CloseSessionTxn*); |
| +struct ErrorTxn { |
| + int32_t err; |
| +}; |
| +int serialize_ErrorTxn(struct oarchive *out, const char *tag, struct ErrorTxn *v); |
| +int deserialize_ErrorTxn(struct iarchive *in, const char *tag, struct ErrorTxn*v); |
| +void deallocate_ErrorTxn(struct ErrorTxn*); |
| +struct Txn { |
| + int32_t type; |
| + struct buffer data; |
| +}; |
| +int serialize_Txn(struct oarchive *out, const char *tag, struct Txn *v); |
| +int deserialize_Txn(struct iarchive *in, const char *tag, struct Txn*v); |
| +void deallocate_Txn(struct Txn*); |
| +struct Txn_vector { |
| + int32_t count; |
| + struct Txn *data; |
| + |
| +}; |
| +int serialize_Txn_vector(struct oarchive *out, const char *tag, struct Txn_vector *v); |
| +int deserialize_Txn_vector(struct iarchive *in, const char *tag, struct Txn_vector *v); |
| +int allocate_Txn_vector(struct Txn_vector *v, int32_t len); |
| +int deallocate_Txn_vector(struct Txn_vector *v); |
| +struct MultiTxn { |
| + struct Txn_vector txns; |
| +}; |
| +int serialize_MultiTxn(struct oarchive *out, const char *tag, struct MultiTxn *v); |
| +int deserialize_MultiTxn(struct iarchive *in, const char *tag, struct MultiTxn*v); |
| +void deallocate_MultiTxn(struct MultiTxn*); |
| + |
| +#ifdef __cplusplus |
| +} |
| +#endif |
| + |
| +#endif //ZOOKEEPER_JUTE__ |