bindings/python/read_latest.py

   1 #!/usr/bin/python
   2 # -*- coding: utf-8 -*-
   3
   4 import sys
   5 #sys.path.insert(0, "/usr/lib/")
   6 sys.path.insert(0, "/tmp/dnet/lib/")
   7 from libelliptics_python import *
   8
   9 from time import time, ctime
  10
  11 def add_remotes(n):
  12         addresses = [("localhost", 1025),
  13                         ("localhost", 1026),
  14                         ("172.16.136.1", 1025),
  15                         ("172.16.136.1", 1026),
  16                         ]
  17         failed = 0
  18
  19         for addr in addresses:
  20                 try:
  21                         n.add_remote(addr[0], addr[1])
  22                 except:
  23                         failed += 1
  24                         pass
  25
  26         if failed == len(addresses):
  27                 raise NameError("Can not add remote nodes")
  28
  29 def write(n, id, aflags, groups):
  30         remote_offset = 0
  31         ioflags = 0
  32
  33         n.write_data(id, "time: " + ctime(time()), remote_offset, aflags, ioflags)
  34         n.write_metadata(id, "remote id", groups, aflags)
  35
  36
  37 def main():
  38         try:
  39                 log = elliptics_log_file("/dev/stderr", 8)
  40                 n = elliptics_node_python(log)
  41
  42                 groups = [1, 2, 3]
  43
  44                 n.add_groups(groups)
  45                 add_remotes(n)
  46
  47                 id = elliptics_id([1, 2, 3, 4], 3, 0)
  48
  49                 aflags = 16 # no locks
  50
  51                 write(n, id, aflags, groups)
  52                 ret = n.prepare_latest(id, aflags, groups)
  53
  54                 print "Groups returned:", ret
  55
  56         except Exception as e:
  57                 print "Exception:", e
  58
  59 if __name__ == "__main__":
  60         main()