null+****@clear*****
null+****@clear*****
2010年 12月 15日 (水) 02:31:36 JST
Tasuku SUENAGA a.k.a. gunyarakun 2010-12-14 17:31:36 +0000 (Tue, 14 Dec 2010)
New Revision: 2458a75e0d69a728fff84d5e5b98450ecbec780b
Log:
Added weight for suggest replication.
Modified files:
src/suggest/groonga_suggest_learner.c
Modified: src/suggest/groonga_suggest_learner.c (+5 -0)
===================================================================
--- src/suggest/groonga_suggest_learner.c 2010-12-14 09:00:34 +0000 (4d101d5)
+++ src/suggest/groonga_suggest_learner.c 2010-12-14 17:31:36 +0000 (9e8880a)
@@ -24,6 +24,7 @@
#define DEFAULT_RECV_ENDPOINT "tcp://*:1234"
#define DEFAULT_SEND_ENDPOINT "tcp://*:1235"
+#define SEND_WAIT 1000 /* 0.001sec */
int print_error(const char *format, ...);
@@ -233,6 +234,8 @@ send_handler(void *zmq_send_sock, grn_ctx *ctx)
zmq_send_to_httpd(zmq_send_sock, sbuf.data, sbuf.size);
+ usleep(SEND_WAIT);
+
msgpack_sbuffer_destroy(&sbuf);
}
grn_table_cursor_close(ctx, tc);
@@ -298,6 +301,8 @@ send_handler(void *zmq_send_sock, grn_ctx *ctx)
zmq_send_to_httpd(zmq_send_sock, sbuf.data, sbuf.size);
+ usleep(SEND_WAIT);
+
msgpack_sbuffer_destroy(&sbuf);
}
}