Home
last modified time | relevance | path

Searched refs:status (Results 1 - 25 of 77) sorted by relevance

1234

/Couchbase_C_Client_v3.0/tests/mc/
H A Dt_iovcursor.cc48 iovcursor_STATUS status; in TEST_F() local
57 status = iovcursor_peek_ex(mincur, cptgt, NULL, 9, 0); in TEST_F()
58 ASSERT_EQ(IOVCURSOR_STATUS_BUFCOPY_OK, status); in TEST_F()
62 status = iovcursor_peek_ex(mincur, cptgt, &contigptr, 9, 0); in TEST_F()
63 ASSERT_EQ(IOVCURSOR_STATUS_BUFCOPY_OK, status); in TEST_F()
67 status = iovcursor_peek_ex(mincur, NULL, &contigptr, 9, 0); in TEST_F()
68 ASSERT_EQ(IOVCURSOR_STATUS_FRAGMENTED, status); in TEST_F()
73 status = iovcursor_peek_ex(mincur, NULL, &contigptr, 3, 0); in TEST_F()
74 ASSERT_EQ(IOVCURSOR_STATUS_CONTIGPTR_OK, status); in TEST_F()
82 status in TEST_F()
[all...]
H A Dpktmaker.h148 Response(const Packet &request, uint16_t status = 0) : Packet() in Response()
150 res->response.status = htons(status); in Response()
/Couchbase_C_Client_v3.0/plugins/io/iocp/
H A Diocp_util.c64 int iocp_just_scheduled(iocp_t *io, iocp_overlapped_t *ol, int status) in iocp_just_scheduled() argument
68 if ((status != 0 && err == WSA_IO_PENDING) || status == 0) { in iocp_just_scheduled()
108 NTSTATUS status = (NTSTATUS)lpOverlapped->Internal; in iocp_overlapped_status() local
109 switch (status) { in iocp_overlapped_status()
212 if ((status & (FACILITY_NTWIN32 << 16)) == (FACILITY_NTWIN32 << 16) && in iocp_overlapped_status()
213 (status & (ERROR_SEVERITY_ERROR | ERROR_SEVERITY_WARNING))) { in iocp_overlapped_status()
216 return (DWORD)(status & 0xffff); in iocp_overlapped_status()
H A Diocp_loop.c68 void iocp_write_done(iocp_t *io, iocp_write_t *w, int status) in iocp_write_done() argument
79 callback(&sd->sd_base, status, uarg); in iocp_write_done()
105 IOCP_LOG(IOCP_WARN, "Got negative status for %p: %d", ol, ws_status); in handle_single_overlapped()
154 BOOL status; in dequeue_io_impl_ex() local
159 status = pGetQueuedCompletionStatusEx(io->hCompletionPort, entries, max_entries, &ulRemoved, msTimeout, FALSE); in dequeue_io_impl_ex()
161 if (status == FALSE || ulRemoved == 0) { in dequeue_io_impl_ex()
/Couchbase_C_Client_v3.0/src/lcbio/
H A Dctx.cc46 static lcb_STATUS convert_lcberr(const lcbio_CTX *ctx, lcbio_IOSTATUS status) in convert_lcberr() argument
58 if (status == LCBIO_SHUTDOWN) { in convert_lcberr()
255 static void send_io_error(lcbio_CTX *ctx, lcbio_IOSTATUS status) in send_io_error() argument
257 lcb_STATUS rc = convert_lcberr(ctx, status); in send_io_error()
259 if (status == LCBIO_SHUTDOWN) { in send_io_error()
268 lcbio_IOSTATUS status; in E_handler() local
273 status = lcbio_E_rdb_slurp(ctx, &ctx->ior); in E_handler()
283 if (!LCBIO_IS_OK(status)) { in E_handler()
284 send_io_error(ctx, status); in E_handler()
298 status in E_handler()
318 Cw_handler(lcb_sockdata_t *sd, int status, void *arg) Cw_handler() argument
535 Cw_ex_handler(lcb_sockdata_t *sd, int status, void *wdata) Cw_ex_handler() argument
559 int status = IOT_V1(iot).write2(IOT_ARG(iot), sd, iov, niov, (void *)(uintptr_t)nb, Cw_ex_handler); C_put_ex() local
[all...]
/Couchbase_C_Client_v3.0/src/mcserver/
H A Dnegotiate.cc526 ErrorMap::ParseStatus status = mm.parse(packet.value(), packet.vallen(), errmsg); in update_errmap() local
528 if (status != ErrorMap::UPDATED && status != ErrorMap::NOT_UPDATED) { in update_errmap()
564 static bool isUnsupported(uint16_t status) in isUnsupported() argument
566 return status == PROTOCOL_BINARY_RESPONSE_NOT_SUPPORTED || status == PROTOCOL_BINARY_RESPONSE_UNKNOWN_COMMAND || in isUnsupported()
567 status == PROTOCOL_BINARY_RESPONSE_EACCESS; in isUnsupported()
586 const uint16_t status = resp.status(); in handle_read() local
606 if (status in handle_read()
622 lcb_log(LOGARGS(this, WARN), LOGFMT "SASL auth failed with STATUS=0x%x", LOGID(this), status); handle_read() local
637 lcb_log(LOGARGS(this, ERROR), LOGFMT "Unexpected status 0x%x received for HELLO", LOGID(this), status); handle_read() local
657 lcb_log(LOGARGS(this, DEBUG), LOGFMT "Server does not support GET_ERRMAP (0x%x)", LOGID(this), status); handle_read() local
660 status); handle_read() local
700 LOGID(this), status); handle_read() local
[all...]
H A Dmcserver.cc39 #define PKTARGS(pkt) (pkt).opcode(), (pkt).status(), (pkt).opaque()
250 auto orig_status = static_cast<protocol_binary_response_status>(resp.status()); in handle_unknown_collection()
251 lcb_STATUS orig_err = resp.status() == PROTOCOL_BINARY_RESPONSE_UNKNOWN_SCOPE ? LCB_ERR_SCOPE_NOT_FOUND in handle_unknown_collection()
383 const errmap::Error &err = settings->errmap->getError(mcresp.status()); in handle_unknown_error()
428 static_cast<protocol_binary_response_status>(mcresp.status()), spec); in handle_unknown_error()
445 static bool is_warmup_issue(uint16_t status) in is_warmup_issue() argument
447 return status == PROTOCOL_BINARY_RESPONSE_NO_BUCKET || status == PROTOCOL_BINARY_RESPONSE_NOT_INITIALIZED; in is_warmup_issue()
510 switch (mcresp.status()) { in try_read()
519 mcresp.opcode(), mcresp.status(), mcres in try_read()
540 auto status = static_cast<protocol_binary_response_status>(mcresp.status()); try_read() local
644 maybe_retry_packet(mc_PACKET *pkt, lcb_STATUS err, protocol_binary_response_status status) maybe_retry_packet() argument
[all...]
/Couchbase_C_Client_v3.0/example/analytics-deferred/
H A Danalytics-deferred.c74 uint16_t status; in row_callback() local
75 lcb_resphttp_http_status(http, &status); in row_callback()
76 printf(", HTTP status: %d", (int)status); in row_callback()
120 const char *status; in row_callback() local
122 lcb_deferred_handle_status(handle, &status, &status_len); in row_callback()
123 printf("\x1b[1mDEFERRED:\x1b[0m %.*s\n", (int)status_len, status); in row_callback()
125 check(lcb_deferred_handle_poll(instance, idx, handle), "poll deferred query status"); in row_callback()
/Couchbase_C_Client_v3.0/example/db/
H A Dvb.c92 uint16_t status; in viewrow_callback() local
95 lcb_resphttp_http_status(http, &status); in viewrow_callback()
96 fprintf(stderr, "HTTP Status: %u\n", status); in viewrow_callback()
110 uint16_t status; in http_callback() local
114 lcb_resphttp_http_status(resp, &status); in http_callback()
115 fprintf(stderr, "%.*s... %d\n", (int)npath, path, status); in http_callback()
120 } else if (status != 201) { in http_callback()
/Couchbase_C_Client_v3.0/tests/basic/
H A Dt_packet.cc22 void getq(const std::string &value, lcb_uint32_t opaque, lcb_uint16_t status = 0, uint64_t cas = 0, in getq()
31 hdr->response.status = htons(status); in getq()
50 void get(const std::string &key, const std::string &value, lcb_uint32_t opaque, lcb_uint16_t status = 0, in get()
62 hdr->response.status = htons(status); in get()
138 ASSERT_EQ(0, pi.status()); in TEST_F()
200 ASSERT_EQ(PROTOCOL_BINARY_RESPONSE_ETMPFAIL, pi.status()); in TEST_F()
/Couchbase_C_Client_v3.0/plugins/io/libuv/
H A Dlibuv_compat.h144 #define UVC_TIMER_CB(func) void func(uv_timer_t *timer, int status)
146 static int uvc_uv2syserr(int status) in uvc_uv2syserr() argument
149 if (status == UV_##errname) { \ in uvc_uv2syserr()
193 static int uv_uv2syserr(int status) in uv_uv2syserr() argument
196 if (status == UV_##name) { \ in uv_uv2syserr()
/Couchbase_C_Client_v3.0/tests/mocksupport/
H A Dprocutil.c136 process->status = WEXITSTATUS(ec); in wait_process()
140 process->status = WTERMSIG(ec); in wait_process()
151 process->status = -1; in wait_process()
264 process->status = result; in wait_process()
287 proc->status = rv; in create_process()
291 proc->status = -1; in create_process()
/Couchbase_C_Client_v3.0/contrib/gtest-1.8.1/src/
H A Dgtest-death-test.cc201 m << "Exited with exit status " << exit_code; in ExitSummary()
206 m << "Exited with exit status " << WEXITSTATUS(exit_code); in ExitSummary()
277 // then exits with status 1.
410 int status() const { return status_; } in status() function in testing::internal::DeathTestImpl
434 // The exit status of the child process.
482 << "unexpected status byte (" in ReadAndInterpretStatusByte()
495 // Writes a status byte to the child's status file descriptor, then
542 // status: The exit status o
814 zx_status_t status = zx_handle_close(child_process_); ~FuchsiaDeathTest() local
965 zx_status_t status; AssumeRole() local
[all...]
/Couchbase_C_Client_v3.0/example/management/
H A Deventing.cc36 check(lcb_resphttp_status(resp), "HTTP operation status in the callback"); in http_callback()
38 uint16_t status; in http_callback() local
39 lcb_resphttp_http_status(resp, &status); in http_callback()
40 printf("HTTP status: %d\n", status); in http_callback()
73 check(lcb_get_bootstrap_status(instance), "check bootstrap status"); in main()
/Couchbase_C_Client_v3.0/src/
H A Dretryq.h77 void add(mc_EXPACKET *detchpkt, lcb_STATUS err, protocol_binary_response_status status, errmap::RetrySpec *spec) in add() argument
79 add(detchpkt, err, status, spec, 0); in add()
90 void ucadd(mc_EXPACKET *pkt, lcb_STATUS orig_err, protocol_binary_response_status status);
H A Ddns-srv.cc99 DNS_STATUS status; in dnssrv_query() local
102 status = DnsQuery_A(addr, DNS_TYPE_SRV, DNS_QUERY_STANDARD, nullptr, (PDNS_RECORD *)&root, nullptr); in dnssrv_query()
103 if (status != 0) { in dnssrv_query()
H A Dretrychk.cc21 static lcb_RETRY_REASON mc_code_to_reason(lcb_STATUS status) in mc_code_to_reason() argument
23 switch (status) { in mc_code_to_reason()
93 * Don't retry operations with status code that maps to unknown reason, as it is not specified in RFC */ in lcb_kv_should_retry()
/Couchbase_C_Client_v3.0/src/search/
H A Dsearch.cc65 return lcb::defer_operation(instance, [instance, cmd](lcb_STATUS status) { in lcb_search()
69 if (status == LCB_ERR_REQUEST_CANCELED) { in lcb_search()
70 response.ctx.rc = status; in lcb_search()
/Couchbase_C_Client_v3.0/src/views/
H A Dview.cc73 return lcb::defer_operation(instance, [instance, cmd](lcb_STATUS status) { in lcb_view()
77 if (status == LCB_ERR_REQUEST_CANCELED) { in lcb_view()
78 response.ctx.rc = status; in lcb_view()
/Couchbase_C_Client_v3.0/src/http/
H A Dhttp.cc39 LIBCOUCHBASE_API lcb_STATUS lcb_resphttp_http_status(const lcb_RESPHTTP *resp, uint16_t *status) in lcb_resphttp_http_status() argument
41 *status = resp->ctx.response_code; in lcb_resphttp_http_status()
279 htstatus_ok = resp.status >= 200 && resp.status < 299; in maybe_refresh_config()
304 res->ctx.response_code = htres.status;
312 if (!(status & NOLCB)) {
317 if ((status & CBINVOKED) == 0) {
323 status |= CBINVOKED;
327 if (status & FINISHED) {
331 TRACE_HTTP_END(this, error, parser->get_cur_response().status);
[all...]
/Couchbase_C_Client_v3.0/example/analytics-ingest/
H A Danalytics-ingest.c74 uint16_t status; in row_callback() local
75 lcb_resphttp_http_status(http, &status); in row_callback()
76 printf(", HTTP status: %d", (int)status); in row_callback()
/Couchbase_C_Client_v3.0/example/users/
H A Dusers.c41 uint16_t status; in http_callback() local
42 lcb_resphttp_http_status(resp, &status); in http_callback()
43 printf("HTTP status: %d\n", status); in http_callback()
/Couchbase_C_Client_v3.0/src/analytics/
H A Danalytics.cc78 return lcb::defer_operation(instance, [instance, cmd](lcb_STATUS status) { in lcb_analytics()
82 if (status == LCB_ERR_REQUEST_CANCELED) { in lcb_analytics()
83 response.ctx.rc = status; in lcb_analytics()
/Couchbase_C_Client_v3.0/src/operations/
H A Dremove.cc222 [instance](lcb_STATUS status, const lcb_RESPGETCID *resp, std::shared_ptr<lcb_CMDREMOVE> operation) { in remove_execute()
233 if (status == LCB_ERR_SHEDULE_FAILURE || resp == nullptr) { in remove_execute()
264 return lcb::defer_operation(instance, [instance, cmd](lcb_STATUS status) {
270 if (status == LCB_ERR_REQUEST_CANCELED) {
271 response.ctx.rc = status;
H A Dtouch.cc208 [instance](lcb_STATUS status, const lcb_RESPGETCID *resp, std::shared_ptr<lcb_CMDTOUCH> operation) { in touch_execute()
219 if (status == LCB_ERR_SHEDULE_FAILURE || resp == nullptr) { in touch_execute()
250 return lcb::defer_operation(instance, [instance, cmd](lcb_STATUS status) {
256 if (status == LCB_ERR_REQUEST_CANCELED) {
257 response.ctx.rc = status;

Completed in 64 milliseconds

1234