blob: 010a117ab15f149386e7e62a830a2a6a58e88b36 [file] [log] [blame]
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__