.

go/NOTES

@@ -372,6 +372,7 @@ Tables
 	.value	str
 	(name, nid, partitions, ptid, replicas, version, zodb=pickle...)
 
+# partition table
 - pt
 	.rid	int	// = row id = part of oid space
 	.nid	int

go/neo/connection.go

@@ -742,7 +742,7 @@ func (nl *NodeLink) serveSend() {
 
 // ---- raw IO ----
 
-const dumpio = true
+const dumpio = false
 
 // sendPkt sends raw packet to peer
 // tx error, if any, is returned as is and is analyzed in serveSend

go/neo/t/.gitignore

 /log
+/var

go/neo/t/t.sh

@@ -5,34 +5,43 @@
 Abind=127.0.0.1:5551
 Mbind=127.0.0.1:5552
 Sbind=127.0.0.1:5553
+Zbind=127.0.0.1:5554
 
 # cluster name
 cluster=pygotest
 
 # logs
-logdir=`pwd`/log
-mkdir -p $logdir
+log=`pwd`/log
+mkdir -p $log
 
 # M{py,go}
 # spawn master
 Mpy() {
 	# XXX --autostart=1 ?
 	exec -a Mpy \
-		neomaster --cluster=$cluster --bind=$Mbind --masters=$Mbind -r 1 -p 1 --logfile=$logdir/Mpy.log &
+		neomaster --cluster=$cluster --bind=$Mbind --masters=$Mbind -r 1 -p 1 --logfile=$log/Mpy.log $@ &
 }
 
 Mgo() {
 	exec -a Mgo \
-		neo --log_dir=$logdir master -cluster=$cluster -bind=$Mbind
+		neo --log_dir=$log master -cluster=$cluster -bind=$Mbind
 }
 
-# TODO Spy
+# Spy ...
+# spawn storage
+Spy() {
+	# --adapter=...
+	# --database=...
+	# --engine=...
+	exec -a Spy \
+		neostorage --cluster=$cluster --bind=$Sbind --masters=$Mbind &
+}
 
-# Sgo <data>
+# Sgo <data.fs>
 # spawn storage
 Sgo() {
 	exec -a Sgo \
-		neo -log_dir=$logdir -alsologtostderr storage -cluster=$cluster -bind=$Sbind -masters=$Mbind $@ &
+		neo -log_dir=$log -alsologtostderr storage -cluster=$cluster -bind=$Sbind -masters=$Mbind $@ &
 }
 
 
@@ -43,6 +52,50 @@ Apy() {
 		neoadmin --cluster=$cluster --bind=$Abind --masters=$Mbind $@ &
 }
 
+# Zpy <data.fs>
+# spawn zeo
+Zpy() {
+	exec -a Zpy \
+		runzeo --address $Zbind --filename $@ 2>>$log/Zpy.log &
+}
+
+
+# ---- generate test data ----
+
+var=`pwd`/var
+mkdir -p $var
+
+# generate data with many small (4K) objects
+export WENDELIN_CORE_ZBLK_FMT=ZBlk1
+
+work=128	# array size generated (MB)
+
+# generate data in data.fs
+fs1=$var/fs1
+mkdir -p $fs1
+genfs() {
+	demo-zbigarray --worksize=$work gen $fs1/data.fs
+	sync
+}
+
+#genfs
+#time demo-zbigarray read $fs1/data.fs
+
+#Zpy $fs1/data.fs
+#sleep 1
+#time demo-zbigarray read zeo://$Zbind
+
+#Mpy --autostart=1
+## sleep 0.2
+#Sgo $fs1/data.fs
+
+time demo-zbigarray read neo://$cluster@$Mbind
+
+wait
+exit
+
+
+# --------
 
 # spawn Mpy + Sgo
 Mpy