michelp

==25665== Invalid write of size 1
==25665==    at 0x99DBBDB: ChertTable_base::next_free_block() (chert_btreebase.cc:457)
==25665==    by 0x9A07CEA: ChertTable::alter() (chert_table.cc:433)
==25665==    by 0x9A0CCD0: ChertTable::add_kt(bool) (chert_table.cc:901)
==25665==    by 0x9A0D462: ChertTable::add(std::string const&, std::string, bool) (chert_table.cc:1118)
==25665==    by 0x99F7875: ChertPositionListTable::set_positionlist(unsigned int, std::string const&, Xapian::PositionIterator, Xapian::PositionIterator const&, bool) (chert_positionlist.cc:67)
==25665==    by 0x99EF9AD: ChertWritableDatabase::add_document_(unsigned int, Xapian::Document const&) (chert_database.cc:1185)
==25665==    by 0x99F1189: ChertWritableDatabase::add_document(Xapian::Document const&) (chert_database.cc:1149)
==25665==    by 0x969A3F7: ??? (in /usr/lib/python2.7/dist-packages/xapian/_xapian.so)
==25665==    by 0x49D584: PyEval_EvalFrameEx (in /home/michel/wikiparser/.virt/bin/python)

michelp

==15718== Invalid write of size 1
==15718==    at 0x99C7AFB: ChertTable_base::next_free_block() (in /usr/lib/libxapian.so.22.5.0)
==15718==    by 0x99F120A: ChertTable::alter() (in /usr/lib/libxapian.so.22.5.0)
==15718==    by 0x99F5EBB: ChertTable::add_kt(bool) (in /usr/lib/libxapian.so.22.5.0)
==15718==    by 0x99F662F: ChertTable::add(std::string const&, std::string, bool) (in /usr/lib/libxapian.so.22.5.0)
==15718==    by 0x99E2030: ??? (in /usr/lib/libxapian.so.22.5.0)
==15718==    by 0x99DA2D6: ??? (in /usr/lib/libxapian.so.22.5.0)
==15718==    by 0x99DA69E: ??? (in /usr/lib/libxapian.so.22.5.0)
==15718==    by 0x968AF26: ??? (in /usr/lib/python2.7/dist-packages/xapian/_xapian.so)
==15718==    by 0x49D584: PyEval_EvalFrameEx (in /home/michel/wikiparser/.virt/bin/python)

michelp

^CTraceback (most recent call last):
  File "dump.py", line 22, in <module>
    db.add(o)
  File "/home/michel/wikiparser/.virt/local/lib/python2.7/site-packages/xodb/database.py", line 514, in add
    validate=validate)
  File "/home/michel/wikiparser/.virt/local/lib/python2.7/site-packages/xodb/database.py", line 580, in to_document
    return self.doc_from_dict(obj.__xodb_memo__.dict)
  File "/home/michel/wikiparser/.virt/local/lib/python2.7/site-packages/xodb/database.py", line 631, in doc_from_dict
    tg.set_stopper(snowball.stoppers[lang])
  File "/usr/lib/python2.7/dist-packages/xapian/__init__.py", line 7032, in _termgenerator_set_stopper

michelp

from gevent import monkey
monkey.patch_all()

import logging
import socket
import struct
import errno
import uuid
import time

michelp

>>> for d in db.query('title:春节'):
...   print d.title
... 
武警官兵春节拔河比赛
春节购物上网更方便 电商长假“不打烊”
春节期间 天津规划建交系统干部职工坚守岗位
穗车市春节销量创新低 超六成车商关门歇业
春节出游短途出游高峰现 自驾旅游唱主角
过半银行网点春节开张 多数业务可用自助设备完成
广州楼市春节不打烊 传将有更严厉调控

michelp

$ ./pil lib/0mq.l +
: (setq c (new '(+Context)))
-> $1333645565
: c                         
-> $1333645565
: (setq a (new_socket c DEALER))
-> $1333652446
: (bind_to a "ipc://objs.sock") 
-> 0
: (setq b (new_socket c DEALER))

michelp

(load "@lib/zmq.l")

(import zmq)


(de main ()
    (setq c (zmq~new))
    (setq b (zmq~socket c zmq~DEALER))
    (zmq~connect b "ipc://test.sock")
    (while (zmq~poll b -1)

michelp

http://goo.gl/maps/UFLvt

michelp

>>> import zmq
>>> c = zmq.Context()
>>> d = c.socket(zmq.ROUTER)
>>> r = c.socket(zmq.ROUTER)
>>> d = c.socket(zmq.DEALER)
>>> r.bind('ipc://foo.sock')
>>> d.connect('ipc://foo.sock')
>>> d.send_multipart(["a", "b", "c"])
>>> r.recv()
'\x00\xe4<\x98i'

michelp

(load "zmq/zmq.l")
(import zmq)

(de socker (Name) (glue "" (list "ipc://" Name ".sock")))

(de setup-engine (Local . @)
   (setq *Ctx (zmq~zctx-new))
   (setq *Router (zmq~zsocket-new *Ctx zmq~ROUTER))
   (setq *Peers (zmq~zhash-new))