Skip to content
This repository

HTTPS clone URL

Subversion checkout URL

You can clone with HTTPS or Subversion.

Download ZIP
Browse code

Use lcb_breakout()

lcb_wait() should be paired with lcb_breakout()

Change-Id: Ia778d2d6c9f4eef0473803657f5783b771555e1e
Reviewed-on: http://review.couchbase.org/21522
Tested-by: Sergey Avseyev <sergey.avseyev@gmail.com>
Reviewed-by: Matt Ingenthron <matt@couchbase.com>
  • Loading branch information...
commit 674ecb38ffda7bec833bc0958732ddbf0d68f044 1 parent 2d70b53
Sergey Avseyev authored October 10, 2012
4  ext/couchbase_ext/bucket.c
@@ -22,7 +22,7 @@ error_callback(lcb_t handle, lcb_error_t error, const char *errinfo)
22 22
 {
23 23
     struct bucket_st *bucket = (struct bucket_st *)lcb_get_cookie(handle);
24 24
 
25  
-    bucket->io->stop_event_loop(bucket->io);
  25
+    lcb_breakout(handle);
26 26
     bucket->exception = cb_check_error(error, errinfo, Qnil);
27 27
 }
28 28
 
@@ -1058,7 +1058,7 @@ cb_bucket_run(int argc, VALUE *argv, VALUE self)
1058 1058
 cb_bucket_stop(VALUE self)
1059 1059
 {
1060 1060
     struct bucket_st *bucket = DATA_PTR(self);
1061  
-    bucket->io->stop_event_loop(bucket->io);
  1061
+    lcb_breakout(bucket->handle);
1062 1062
     return Qnil;
1063 1063
 }
1064 1064
 
2  ext/couchbase_ext/http.c
@@ -305,7 +305,7 @@ cb_http_request_perform(VALUE self)
305 305
 cb_http_request_pause(VALUE self)
306 306
 {
307 307
     struct http_request_st *req = DATA_PTR(self);
308  
-    req->bucket->io->stop_event_loop(req->bucket->io);
  308
+    lcb_breakout(req->bucket->handle);
309 309
     return Qnil;
310 310
 }
311 311
 

0 notes on commit 674ecb3

Please sign in to comment.
Something went wrong with that request. Please try again.