@@ -45,23 +45,36 @@ main() {
45
45
46
46
# this fails
47
47
echo " grabbing the content ID"
48
- myCID=$( kubectl exec -n " ${NAMESPACE} " " ${ipfsClusterPodName} " -c ipfs-cluster -- sh -c ' if [ -e /data/ipfs/repo.lock ]; then rm /data/ipfs/repo.lock; fi; ipfs-cluster-ctl add /tmp/testfile.txt' | awk ' {print $2}' )
48
+ myCID=" "
49
+ until [[ -n $myCID ]]; do
50
+ myCID=$( kubectl exec -n " ${NAMESPACE} " " ${ipfsClusterPodName} " -c ipfs-cluster -- sh -c ' if [ -e /data/ipfs/repo.lock ]; then rm /data/ipfs/repo.lock; fi; ipfs-cluster-ctl add /tmp/testfile.txt' | awk ' {print $2}' ) || true
51
+ [[ -z $myCID ]] && sleep 5
52
+ echo " trying again"
53
+ done
49
54
echo " content ID is: ${myCID} "
55
+
56
+ # myCID=$(kubectl exec -n "${NAMESPACE}" "${ipfsClusterPodName}" -c ipfs-cluster -- sh -c 'if [ -e /data/ipfs/repo.lock ]; then rm /data/ipfs/repo.lock; fi; ipfs-cluster-ctl add /tmp/testfile.txt' | awk '{print $2}')
50
57
51
58
# read the value
52
59
echo " getting the other ipfs cluster podname"
53
60
ipfsClusterPodname2=$( kubectl get pod -n " ${NAMESPACE} " -l " ${labelName} =${labelValue} " -o jsonpath=' {.items[1].metadata.name}' )
54
61
55
62
# delete the lockfile if it exists
56
63
echo " deleting the other lockfile now"
57
- kubectl exec -n " ${NAMESPACE} " " ${ipfsClusterPodname2} " -c ipfs-cluster -- sh -c ' if [ -e /data/ipfs/repo.lock ]; then rm /data/ipfs/repo.lock; fi'
58
- echo " checking to see if lockfile still exists"
59
- results=$( kubectl exec -n " ${NAMESPACE} " " ${ipfsClusterPodname2} " -c ipfs-cluster -- sh -c ' ls -al /data/ipfs' | grep ' repo.lock' )
60
- echo " lockfile: ${results} "
64
+ # kubectl exec -n "${NAMESPACE}" "${ipfsClusterPodname2}" -c ipfs-cluster -- sh -c 'if [ -e /data/ipfs/repo.lock ]; then rm /data/ipfs/repo.lock; fi'
65
+ # echo "checking to see if lockfile still exists"
66
+ # results=$(kubectl exec -n "${NAMESPACE}" "${ipfsClusterPodname2}" -c ipfs-cluster -- sh -c 'ls -al /data/ipfs' | grep 'repo.lock')
67
+ # echo "lockfile: ${results}"
61
68
62
69
ipfsCommand=" if [ -e /data/ipfs/repo.lock ]; then rm /data/ipfs/repo.lock; fi; ipfs get --output /tmp/myfile.txt -- ${myCID} "
70
+
63
71
echo " reading a file from ${ipfsClusterPodname2} using command: '${ipfsCommand} '"
64
- kubectl exec -n " ${NAMESPACE} " " ${ipfsClusterPodname2} " -c ipfs -- sh -c " ${ipfsCommand} "
72
+ until kubectl exec -n " ${NAMESPACE} " " ${ipfsClusterPodname2} " -c ipfs -- sh -c " ${ipfsCommand} " ; do
73
+ echo " failed, sleeping..."
74
+ sleep 5
75
+ done
76
+
77
+ # kubectl exec -n "${NAMESPACE}" "${ipfsClusterPodname2}" -c ipfs -- sh -c "${ipfsCommand}"
65
78
echo " success!"
66
79
}
67
80
0 commit comments