815物联网平台云端后台.zip

/** * 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. */ package org.apache.curator.framework.imps; import com.google.common.annotations.VisibleForTesting; import com.google.common.base.Preconditions; import com.google.common.base.Predicate; import com.google.common.collect.Iterables; import org.apache.curator.RetryLoop; import org.apache.curator.drivers.OperationTrace; import org.apache.curator.framework.api.*; import org.apache.curator.framework.api.transaction.OperationType; import org.apache.curator.framework.api.transaction.TransactionCreateBuilder; import org.apache.curator.framework.api.transaction.TransactionCreateBuilder2; import org.apache.curator.utils.InternalACLProvider; import org.apache.curator.utils.ThreadUtils; import org.apache.curator.utils.ZKPaths; import org.apache.zookeeper.AsyncCallback; import org.apache.zookeeper.CreateMode; import org.apache.zookeeper.KeeperException; import org.apache.zookeeper.Op; import org.apache.zookeeper.data.ACL; import org.apache.zookeeper.data.Stat; import org.apache.zookeeper.server.DataTree; import java.util.List; import java.util.UUID; import java.util.concurrent.Callable; import java.util.concurrent.Executor; import java.util.concurrent.atomic.AtomicBoolean; public class CreateBuilderImpl implements CreateBuilder, CreateBuilder2, BackgroundOperation<PathAndBytes>, ErrorListenerPathAndBytesable<String> { private final CuratorFrameworkImpl client; private CreateMode createMode; private Backgrounding backgrounding; private boolean createParentsIfNeeded; private boolean createParentsAsContainers; private boolean doProtected; private boolean compress; private boolean setDataIfExists; private int setDataIfExistsVersion = -1; private String protectedId; private ACLing acling; private Stat storingStat; private long ttl; @VisibleForTesting boolean failNextCreateForTesting = false; @VisibleForTesting static final String PROTECTED_PREFIX = "_c_"; CreateBuilderImpl(CuratorFrameworkImpl client) { this.client = client; createMode = CreateMode.PERSISTENT; backgrounding = new Backgrounding(); acling = new ACLing(client.getAclProvider()); createParentsIfNeeded = false; createParentsAsContainers = false; compress = false; doProtected = false; setDataIfExists = false; protectedId = null; storingStat = null; ttl = -1; } public CreateBuilderImpl(CuratorFrameworkImpl client, CreateMode createMode, Backgrounding backgrounding, boolean createParentsIfNeeded, boolean createParentsAsContainers, boolean doProtected, boolean compress, boolean setDataIfExists, List<ACL> aclList, Stat storingStat, long ttl) { this.client = client; this.createMode = createMode; this.backgrounding = backgrounding; this.createParentsIfNeeded = createParentsIfNeeded; this.createParentsAsContainers = createParentsAsContainers; this.doProtected = doProtected; this.compress = compress; this.setDataIfExists = setDataIfExists; protectedId = null; this.acling = new ACLing(client.getAclProvider(), aclList); this.storingStat = storingStat; this.ttl = ttl; } public void setSetDataIfExistsVersion(int version) { this.setDataIfExistsVersion = version; } @Override public CreateBuilder2 orSetData() { return orSetData(-1); } @Override public CreateBuilder2 orSetData(int version) { setDataIfExists = true; setDataIfExistsVersion = version; return this; } @Override public CreateBuilderMain withTtl(long ttl) { Preconditions.checkState(!client.isZk34CompatibilityMode(), "TTLs are not support when running in ZooKeeper 3.4 compatibility mode"); this.ttl = ttl; return this; } <T> TransactionCreateBuilder<T> asTransactionCreateBuilder(final T context, final CuratorMultiTransactionRecord transaction) { return new TransactionCreateBuilder<T>() { @Override public PathAndBytesable<T> withACL(List<ACL> aclList) { return withACL(aclList, false); } @Override public PathAndBytesable<T> withACL(List<ACL> aclList, boolean applyToParents) { CreateBuilderImpl.this.withACL(aclList, applyToParents); return this; } @Override public TransactionCreateBuilder2<T> withTtl(long ttl) { CreateBuilderImpl.this.withTtl(ttl); return this; } @Override public ACLPathAndBytesable<T> withMode(CreateMode mode) { CreateBuilderImpl.this.withMode(mode); return this; } @Override public ACLCreateModePathAndBytesable<T> compressed() { CreateBuilderImpl.this.compressed(); return this; } @Override public T forPath(String path) throws Exception { return forPath(path, client.getDefaultData()); } @Override public T forPath(String path, byte[] data) throws Exception { if ( compress ) { data = client.getCompressionProvider().compress(path, data); } String fixedPath = client.fixForNamespace(path); if ( client.isZk34CompatibilityMode() ) { transaction.add(Op.create(fixedPath, data, acling.getAclList(path), createMode), OperationType.CREATE, path); } return context; } }; } @Override public CreateBackgroundModeStatACLable compressed() { compress = true; return new CreateBackgroundModeStatACLable() { @Override public CreateBackgroundModeACLable storingStatIn(Stat stat) { storingStat = stat; return asCreateBackgroundModeACLable(); } @Override public ACLCreateModePathAndBytesable<String> creatingParentsIfNeeded() { createParentsIfNeeded = true; return asACLCreateModePathAndBytesable(); } @Override public ACLCreateModePathAndBytesable<String> creatingParentContainersIfNeeded() { setCreateParentsAsContainers(); return creatingParentsIfNeeded(); } @Override public ACLPathAndBytesable<String> withProtectedEphemeralSequential() { return CreateBuilderImpl.this.withProtectedEphemeralSequential(); } @Override public BackgroundPathAndBytesable<String> withACL(List<ACL> aclList) { return CreateBuilderImpl.this.withACL(aclList); } @Override public BackgroundP