source: mainline/uspace/srv/bd/hr/io.c@ b883aa8

Last change on this file since b883aa8 was 800d188, checked in by Miroslav Cimerman <mc@…>, 4 months ago

hr: metadata saving on stop

New bool argument for hr_metadata_save() to indicate if
we want callback too (on array stop we don't, so we won't
init a rebuild).
  • Property mode set to 100644
File size: 3.2 KB
Line 
1/*
2 * Copyright (c) 2025 Miroslav Cimerman
3 * All rights reserved.
4 *
5 * Redistribution and use in source and binary forms, with or without
6 * modification, are permitted provided that the following conditions
7 * are met:
8 *
9 * - Redistributions of source code must retain the above copyright
10 * notice, this list of conditions and the following disclaimer.
11 * - Redistributions in binary form must reproduce the above copyright
12 * notice, this list of conditions and the following disclaimer in the
13 * documentation and/or other materials provided with the distribution.
14 * - The name of the author may not be used to endorse or promote products
15 * derived from this software without specific prior written permission.
16 *
17 * THIS SOFTWARE IS PROVIDED BY THE AUTHOR ``AS IS'' AND ANY EXPRESS OR
18 * IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES
19 * OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED.
20 * IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR ANY DIRECT, INDIRECT,
21 * INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT
22 * NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
23 * DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
24 * THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
25 * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF
26 * THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
27 */
28
29/** @addtogroup hr
30 * @{
31 */
32/**
33 * @file
34 */
35
36#include <block.h>
37#include <errno.h>
38#include <hr.h>
39#include <inttypes.h>
40#include <stdio.h>
41#include <str_error.h>
42
43#include "io.h"
44#include "util.h"
45#include "var.h"
46
47static errno_t exec_io_op(hr_io_t *);
48
49errno_t hr_io_worker(void *arg)
50{
51 hr_io_t *io = arg;
52
53 errno_t rc = exec_io_op(io);
54
55 /*
56 * We don't have to invalidate extents who got ENOMEM
57 * on READ/SYNC. But when we get ENOMEM on a WRITE, we have
58 * to invalidate it, because there could have been
59 * other writes, there is no way to rollback.
60 */
61 if (rc != EOK && (rc != ENOMEM || io->type == HR_BD_WRITE))
62 io->vol->state_callback(io->vol, io->extent, rc);
63
64 return rc;
65}
66
67errno_t hr_io_worker_basic(void *arg)
68{
69 hr_io_t *io = arg;
70
71 errno_t rc = exec_io_op(io);
72
73 return rc;
74}
75
76static errno_t exec_io_op(hr_io_t *io)
77{
78 size_t ext_idx = io->extent;
79 hr_extent_t *extents = (hr_extent_t *)&io->vol->extents;
80 errno_t rc;
81
82 const char *debug_type_str = NULL;
83 switch (io->type) {
84 case HR_BD_SYNC:
85 debug_type_str = "SYNC";
86 break;
87 case HR_BD_READ:
88 debug_type_str = "READ";
89 break;
90 case HR_BD_WRITE:
91 debug_type_str = "WRITE";
92 break;
93 }
94
95 HR_DEBUG("%s WORKER (%p) on extent: %zu, ba: %" PRIu64 ", "
96 "cnt: %" PRIu64 "\n",
97 debug_type_str, io, io->extent, io->ba, io->cnt);
98
99 switch (io->type) {
100 case HR_BD_SYNC:
101 rc = block_sync_cache(extents[ext_idx].svc_id,
102 io->ba, io->cnt);
103 if (rc == ENOTSUP)
104 rc = EOK;
105 break;
106 case HR_BD_READ:
107 rc = block_read_direct(extents[ext_idx].svc_id, io->ba,
108 io->cnt, io->data_read);
109 break;
110 case HR_BD_WRITE:
111 rc = block_write_direct(extents[ext_idx].svc_id, io->ba,
112 io->cnt, io->data_write);
113 break;
114 default:
115 return EINVAL;
116 }
117
118 HR_DEBUG("WORKER (%p) rc: %s\n", io, str_error(rc));
119
120 return rc;
121}
122
123/** @}
124 */
Note: See TracBrowser for help on using the repository browser.