conn = doveadm_server_find_unused_conn(server);
if (conn != NULL) {
- array_delete(&server->queue, 0, 1);
+ array_pop_front(&server->queue);
doveadm_mail_server_handle(conn, username);
i_free(username);
}
item = array_first_modifiable(&pipe->item_queue);
i_assert(item->type == type);
pipe->pop_item = *item;
- array_delete(&pipe->item_queue, 0, 1);
+ array_pop_front(&pipe->item_queue);
item = NULL;
pool_unref(&pipe->pop_pool);
if (item->type != ITEM_END_OF_LIST)
return FALSE;
- array_delete(&pipe->item_queue, 0, 1);
+ array_pop_front(&pipe->item_queue);
return TRUE;
}
if ((ret = memcached_ascii_input_reply_read(dict, error_r)) <= 0)
return ret;
/* finished a reply */
- array_delete(&dict->input_states, 0, 1);
+ array_pop_front(&dict->input_states);
replies = array_get_modifiable(&dict->replies, &count);
i_assert(count > 0);
i_assert(replies[0].reply_count > 0);
if (--replies[0].reply_count == 0) {
memcached_ascii_callback(dict, &replies[0], &result);
- array_delete(&dict->replies, 0, 1);
+ array_pop_front(&dict->replies);
}
return 1;
}
static void redis_input_state_remove(struct redis_dict *dict)
{
- array_delete(&dict->input_states, 0, 1);
+ array_pop_front(&dict->input_states);
}
static void redis_callback(struct redis_dict *dict,
DICT_COMMIT_RET_OK, NULL
};
redis_callback(dict, reply, &result);
- array_delete(&dict->replies, 0, 1);
+ array_pop_front(&dict->replies);
/* if we're running in a dict-ioloop, we're handling a
synchronous commit and need to stop now */
if (array_count(&dict->replies) == 0 &&
}
/* remove request from queue */
- array_delete(&conn->request_wait_list, 0, 1);
+ array_pop_front(&conn->request_wait_list);
aborted = (req->state == HTTP_REQUEST_STATE_ABORTED);
req_ref = req;
if (!http_client_connection_unref_request(conn, &req_ref)) {
cmds = array_get(&conn->cmd_send_queue, &count);
if (count > 0 && cmds[0]->tag == conn->cur_tag) {
cmd = cmds[0];
- array_delete(&conn->cmd_send_queue, 0, 1);
+ array_pop_front(&conn->cmd_send_queue);
} else {
cmds = array_get(&conn->cmd_wait_list, &count);
for (i = 0; i < count; i++) {
/* everything sent. move command to wait list. */
cmdp = array_first(&conn->cmd_send_queue);
i_assert(*cmdp == cmd);
- array_delete(&conn->cmd_send_queue, 0, 1);
+ array_pop_front(&conn->cmd_send_queue);
array_push_back(&conn->cmd_wait_list, &cmd);
/* send the next command in queue */
/* finished with the stream */
i_stream_unref(&stream->input);
- array_delete(&cmd->streams, 0, 1);
+ array_pop_front(&cmd->streams);
i_assert(cmd->send_pos != cmd->data->used);
return 1;
reply.text_without_resp = reply.text_full = "Mailbox not open";
reply.state = IMAPC_COMMAND_STATE_DISCONNECTED;
- array_delete(&conn->cmd_send_queue, 0, 1);
+ array_pop_front(&conn->cmd_send_queue);
imapc_command_reply_free(cmd, &reply);
imapc_command_send_more(conn);
return;
reply.text_without_resp = reply.text_full = "Mailbox not open";
reply.state = IMAPC_COMMAND_STATE_DISCONNECTED;
- array_delete(&conn->cmd_send_queue, 0, 1);
+ array_pop_front(&conn->cmd_send_queue);
imapc_command_reply_free(cmd, &reply);
imapc_command_send_more(conn);
return;
if (count == 0)
return IMAPC_COMMAND_STATE_INVALID;
reply = replies[0];
- array_delete(&imapc_cmd_last_replies, 0, 1);
+ array_pop_front(&imapc_cmd_last_replies);
return reply;
}
}
/* drop the command from the list */
- array_delete(&ctx->cmds, 0, 1);
+ array_pop_front(&ctx->cmds);
/* send more BDAT commands if necessary */
(void)_cmd_bdat_send_chunks(ctx, NULL);
/* drop it from array if it's used up */
if (result->cur == result->nqueries)
- array_delete(&db->expected, 0, 1);
+ array_pop_front(&db->expected);
return &res->api;
}
/* drop it from array if it's used up */
if (result->cur == result->nqueries)
- array_delete(&db->expected, 0, 1);
+ array_pop_front(&db->expected);
}
static const char *
return;
}
cmd_copy = *cmd;
- array_delete(&client->commands, 0, 1);
+ array_pop_front(&client->commands);
if (cmd_copy.input != NULL) {
i_stream_seek(cmd_copy.input, 0);
array_first(&root->refresh.roots);
if (strcmp(refresh_root->name, root->root_name) == 0)
break;
- array_delete(&root->refresh.roots, 0, 1);
+ array_pop_front(&root->refresh.roots);
}
imapc_quota_refresh_deinit(root->root.quota, &root->refresh,
sctx.ret == 0);