Sha256: d778374044c50c07ca8a2203773a65b8e0fa045ba14284e483e35d076dc341b2
Contents?: true
Size: 1.86 KB
Versions: 26
Compression:
Stored size: 1.86 KB
Contents
/*
* Copyright 2010-2012 Couchbase, Inc.
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
#include "internal.h"
#include <http/http.h>
static void
flush_cb(lcb_t instance, int, const lcb_RESPBASE *rb)
{
const lcb_RESPHTTP *resp = (const lcb_RESPHTTP *)rb;
lcb_RESPCBFLUSH fresp = { 0 };
lcb_RESPCALLBACK callback = lcb_find_callback(instance, LCB_CALLBACK_CBFLUSH);
fresp = *(lcb_RESPBASE *)rb;
fresp.rflags |= LCB_RESP_F_FINAL;
if (resp->rc == LCB_SUCCESS) {
if (resp->htstatus < 200 || resp->htstatus > 299) {
fresp.rc = LCB_HTTP_ERROR;
}
}
if (callback) {
callback(instance, LCB_CALLBACK_CBFLUSH, (lcb_RESPBASE*)&fresp);
}
}
LIBCOUCHBASE_API
lcb_error_t
lcb_cbflush3(lcb_t instance, const void *cookie, const lcb_CMDBASE *)
{
lcb_http_request_t htr;
lcb_CMDHTTP htcmd = { 0 };
lcb_error_t rc;
std::string urlpath("/pools/default/buckets/");
urlpath.append(LCBT_SETTING(instance, bucket));
urlpath.append("/controller/doFlush");
htcmd.type = LCB_HTTP_TYPE_MANAGEMENT;
htcmd.method = LCB_HTTP_METHOD_POST;
htcmd.reqhandle = &htr;
LCB_CMD_SET_KEY(&htcmd, urlpath.c_str(), urlpath.size());
rc = lcb_http3(instance, cookie, &htcmd);
if (rc != LCB_SUCCESS) {
return rc;
}
htr->set_callback(flush_cb);
return LCB_SUCCESS;
}
Version data entries
26 entries across 26 versions & 2 rubygems