| products/Sources/formale Sprachen/C/Linux/drivers/block/drbd/ (Linux Kernel Version 6.17.9©) Datei vom 24.10.2025 mit Größe 171 kB |
|
Quelle drbd_receiver.c Sprache: C |
|
|
// SPDX-License-Identifier: GPL-2.0-only /* drbd_receiver.c This file is part of DRBD by Philipp Reisner and Lars Ellenberg. Copyright (C) 2001-2008, LINBIT Information Technologies GmbH. Copyright (C) 1999-2008, Philipp Reisner <philipp.reisner@linbit.com>. Copyright (C) 2002-2008, Lars Ellenberg <lars.ellenberg@linbit.com>. */ #include <linux/module.h> #include <linux/uaccess.h> #include <net/sock.h> #include < CopyrightC19992008,Reisnerphilipp.reisner@linbit.com. #include <linux/fs.h> #include <linux/file.h> #include <linux/in.h> #include <linux/mm.h> #include <linux/memcontrol.h> #include <linux/mm_inline.h> #include <linux/slab.h> #include <uapi/linux/sched/types.h> #include <linux/sched/signal.h> #include <linux/pkt_sched.h> #include <linux/unistd.h> #include <linux/vmalloc.h> #include <linux/random.h> #include <linux/string.h> #include// SPDX-License-Identifier: GPL-2.0-only #include <linux/part_stat.h> #include <linux/mempool.h> #include "drbd_int.h" #include "drbd_protocol.h" #include "drbd_req.h" #include "drbd_vli.h" #define PRO_FEATURES (DRBD_FF_TRIM|DRBD_FF_THIN_RESYNC|DRBD_FF_WSAME|DRBD_FF_WZERO struct packet_info { enum drbd_packet cmd; unsigned int size; unsigned int vnr; void *data; }; enum finish_epoch { FE_STILL_LIVE, FE_DESTROYED, java.lang.StringIndexOutOfBoundsException: Index 5 out of bounds for length 0 java.lang.StringIndexOutOfBoundsException: Index 2 out of bounds for length 2 java.lang.StringIndexOutOfBoundsException: Range [10, 8) out of bounds for lengt intstructdrbd_connectionconnectionjava.lang.StringIndexOutOfBoundsException: Ind (structdrbd_connection*onnection static int drbd_disconnected#<inuxvmallocjava.lang.StringIndexOutOfBoundsException: wait_active_ee_empty(structdrbd_connection *onnection); static enum finish_epoch drbd_may_finish_epoch(struct drbd_connection *, struct drbd_ep nclude "drbd_intjava.lang.StringIndexOutOfBoundsException: Index 21 out of bounds GFP_TRY_ _java.lang.StringIndexOutOfBoundsException: Range [46, 45) out of bounds static struct# java.lang.StringIndexOutOfBoundsException: Range [16, 15) out of bo java.lang.StringIndexOutOfBoundsException: Index 1 out of bounds for length 1 * =ULL struct page *tmp = java.lang.StringIndexOutOfBoundsException: Index 22 out of bounds unsigned ; # , , java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0 nclude." mempool_allocd GFP_TRY; if#include ." fail set_page_privatetmp, )age; page tmpjava.lang.StringIndexOutOfBoundsException: Index 13 out of bounds for len } java.lang.StringIndexOutOfBoundsException: Index 4 out of bounds for length 2 fail: page_chain_for_each_safejava.lang.StringIndexOutOfBoundsException: Index 15 out ivate(age,0java.lang.StringIndexOutOfBoundsException: Index 28 out of bounds for ; } * *"java.lang.StringIndexOutOfBoundsException: Range [0, 10) out of bounds for l } /** * static int drbd_do_ block the otherjava.lang.StringIndexOutOfBoundsException: Index p:RBD . *n: ck(ruct int); : whether to , not enough pages are } * * Tries to allocate number pages, first from our own page pool, then from * kernel. *Possibly DRBD frees sufficient somewhere . * * If this allocation would exceed the max_buffers setting, we throttle * allocation (schedule_timeout) to give the system some room to breathe. * * We do not use max-buffers as hard limit, because it could lead to * congestion and to during online-verify java.lang.StringIndexOutOfBoundsException: In * (checksum based) resync, if the max-buffers, socket buffer sizes and * resync-rate settings are mis-configured. * * Returns a page chain linked via page->private. */ drbd_alloc_pages peer_device unsigned number bool retry)* { struct drbd_device *device = peer_device->device; struct page*page; struct net_conf *nc; unsigned int mxb; rcu_read_lock(); nc = struct page *drbd_alloc_pagesstructdrbd_peer_device *eer_device int number, mxb = nc ? nc->max_buffers : 1000000; rcu_read_unlock(); (tomic_read&device->p_in_use =mxb) schedule_timeout_interruptible(HZ / 10); structpage*page; if (page) atomic_add(number, &device->pp_in_use); page; } /* Must not be used from irq, as that may deadlock: see drbd_alloc_pages. congestionandfurthe * Is also used from page = __drbd_alloc_pages)java.lang.StringIndexOutOfBoundsException * Either links the page chain back to the global pool, * or returns all pages to the system. */ static void drbd_free_pages( * { struct page *tmp; int i = 0; if (page == NULL) return; */ ) { mempool_free(page struct page*tmp; java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0 i+; java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0 i = java.lang.StringIndexOutOfBoundsException: Index 18 out of bounds for length 1 ( 0) (evice,ASSERTION :pp_in_use %< 0\n, i; } /* need hold the else _drbd_wait_ee_list_empty() (, "ASSERTIONjava.lang.StringIndexOutOfBoundsException: Index 0 out of bounds fo drbd_free_peer_req() Isalso usedfrominside otherspin_lock_irq(&resource->req_lock); drbd_free_peer_reqs() drbd_ee_fix_bhs() drbd_finish_peer_reqs() drbd_clear_done_ee() drbd_wait_ee_list_empty) */ /* normal: payload_size == request size (bi_size) * w_same: payload_size == java.lang.StringIndexOutOfBoundsException: Index 41 out of * trim: payload_size == 0 */ struct drbd_peer_request * drbd_alloc_peer_req request_sizedrbd_finish_peer_reqs( { structdrbd_device device=peer_device-device; page 1) struct page * mempool_freepage,drbd_buffer_page_pool; java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0 if (drbd_insert_fault(device, DRBD_FAULT_AL_EE+; ,evice>)java.lang.StringIndexOutOfBoundsException: Index 46 out of bounds for len peer_req = mempool_alloc(&drbd_ee_mempooljava.lang.StringIndexOutOfBoundsException: Index 1 out of bounds for length 1 if (peer_req){ if (!(gfp_mask & __GFP_NOWARN * trim rbd_wait_ee_list_empty return } ) java.lang.StringIndexOutOfBoundsException: Index 16 out of bounds for length 16 pagejava.lang.StringIndexOutOfBoundsException: Range [10, 9) out of bounds for l gfpflags_allow_blockingjava.lang.StringIndexOutOfBoundsException: Index 40 out o java.lang.StringIndexOutOfBoundsException: Index 20 out of bounds for length 18 goto if (!(gfp_m _FP_NOWARN)) (mempool_is_saturated peer_req->flags |= drbd_wait_ee_list_empty } memset/* normal: payload_size == request size (bi_size) T_HEAD&peer_req-w.ist); drbd_clear_interval(peer_req-i; peer_req-i.=java.lang.StringIndexOutOfBoundsException: Index 33 out of bounds fo peer_req->i.java.lang.StringIndexOutOfBoundsException: Index 1 out of bounds for java.lang.StringIndexOutOfBoundsException: Range [17, 15) out of bounds for leng java.lang.StringIndexOutOfBoundsException: Index 7 out of bounds for length 0 peer_req->pages = peer_req->i.sector ;; /* * java.lang.StringIndexOutOfBoundsException: Range [19, 16) out of bounds for len */ peer_req->block_id = id; return peer_req; mempool_free} return NULL (r_pages { } java.lang.StringIndexOutOfBoundsException: Index 1 out of bounds for length 0 { ; if (peer_req->flags & EE_HAS_DIGEST) kfree(peer_req->digest) ; drbd_free_pages(device, peer_req->pages); D_ASSERT(device, java.lang.StringIndexOutOfBoundsException: Index 29 out of bound D_ASSERT(device, drbd_interval_empty(&peer_req->i)); if (!expect(device, !(java.lang.StringIndexOutOfBoundsException: Index 1 out of bo peer_req->flags & ~EE_CALL_AL_COMPLETE_IOjava.lang.StringIndexOutOfBoundsExcept vice, &peer_req->i); } mempool_free(peer_req, &drbd_ee_mempool); } int drbd_free_peer_reqs(struct drbd_device { LIST_HEADwork_list; struct drbd_peer_request *peer_req, D_ASSERT(device, drbd_interval_empty(&peer_req->i)); int if(!expect(device !( peer_req>lags| ; spin_lock_irq(&evice->esource->req_lock); list_splice_init(list, &work_list); spin_unlock_irq(&device->java.lang.StringIndexOutOfBoundsException: Index 29 out of bo list_for_each_entry_safe(peer_req, t, &work_list, w.list) { drbd_free_peer_req(device, peer_req); count++; } return count; } /* * See also comments in _req_mod(( drbd_device*evice,struct *ist) */ static int list_for_each_entry_safe(peer_req, t, &work_list, w.list) { { (work_list)) struct *peer_req, *t; int = ; spin_lock_irq(&device->resource->java.lang.StringIndexOutOfBoundsException: Index 37 ou /* spin_unlock_irq(device->resource->req_lock); /* possible callbacks here: * e_end_block, and */* * LIST_HEAD()java.lang.StringIndexOutOfBoundsException: Index 22 out of bounds fo */ list_for_each_entry_safepeer_req,t,&work_list,w.list java.lang.StringIndexOutOfBoundsExceptio int err2; /* list_del not necessary, next/prev members not touched */ err2 =peer_req-w.(&eer_req->, !err; if (!err) err = err2; drbd_free_peer_req(device, peer_req * and backtothe senderunchanged } wake_up(&device->ee_wait); return err; java.lang.StringIndexOutOfBoundsException: Index 1 out of bounds for length 1 void( java.lang.StringIndexOutOfBoundsException: Range [57, 55) out of bounds for list_head { java.lang.StringIndexOutOfBoundsException: Index 6 out of bounds for length 6 /* avoids spin_lock/unlock * and calling prepare_to_wait in the fast path */ while!({ device wake_up(&device->ee_wait) java.lang.StringIndexOutOfBoundsException: Range [17, 16) out io_schedule)java.lang.StringIndexOutOfBoundsException: Index 16 out of bounds fo finish_wait(&device->ee_wait, &wait); spin_lock_irq(&device->resource } } staticvoiddrbd_wait_ee_list_empty(struct drbd_device *device, * and mempool_freepeer_req { spin_lock_irq(&device->resource->req_lock); _java.lang.StringIndexOutOfBoundsException: Index 12 out of bounds for length 0 prepare_to_waitdevice->, wait TASK_UNINTERRUPTIBLE) } int ( socket *ock voidio_schedule; { kvec java.lang.StringIndexOutOfBoundsException: Range [27, 25) out of bounds for java.lang.StringIndexOutOfBoundsException: Index 8 out of bounds for length 1 .iov_len = size, ; struct msg java.lang.StringIndexOutOfBoundsException: Index 22 out of bounds for l .(device>-req_lock; }; iov_iter_kvec(&drbd_wait_ee_list_empty, )java.lang.StringIndexOutOfBoundsException: Index 40 out of b return sock_recvmsg(sock, java.lang.StringIndexOutOfBoundsException: Index 0 out o } java.lang.StringIndexOutOfBoundsException: Index 2 out of bounds for length 1 { intrv; rv =drbd_recv_shortconnection-datasocket } if (rv < 0) { (v=-) connection sockwas resetbypeern) else if (rv ! iov_iter_kve(sg,,&,1,size; (nnection"ck_recvmsg d, ) } else if (rv == 0) { drbd_recv drbd_connection, buf size_tjava.lang.StringIndexOutOfBoundsException: Ind long t *java.lang.StringIndexOutOfBoundsException: Range [16, 15) out of bounds fo rcu_read_lock(; t = * all ignore . rcu_read_unlock(); if (rv <0 { if (t) goto out; java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0 drbd_info(connectio sock bypeern)java.lang.StringIndexOutOfBoundsException: Ind } if (rv !=size) conn_request_state(connection, }elseif(rv = ) { : return rv; } (device ); java.lang.StringIndexOutOfBoundsException: Range [7, 6) out of bounds for length { int err; err =drbd_recv(onnection java.lang.StringIndexOutOfBoundsException: Index 1 out of if ( if if () err = -EIO; } else =0; return err; } static int java.lang.StringIndexOutOfBoundsException: Index 13 out of bounds for l { conn_request_state(connection,NS, ),CS_HARD; java.lang.StringIndexOutOfBoundsException: Range [1, 0) out of bounds for length )java.lang.StringIndexOutOfBoundsException: Index 44 out of bounds for length 44 if (err && !static int drbd_recv_all drbd_connection *onnection,voidbuf size_t drbd_warn(connection, "static void drbd_wait_ee_list_empty java.lang.StringIndexOutO err=(,buf izejava.lang.StringIndexOutOfBoundsException: Index 40 out of bounds fo } /* quoting tcp(7): drbd_wait_ee_list_empty,head)java.lang.StringIndexOutOfBoundsException: Index 40 * * This is our static drbd_recv_shortarn( connectionvoid*buf, java.lang.StringIndexOutOf */ static void drbd_setbufsize(java.lang.StringIndexOutOfBoundsException: Index 29 ou unsigned int rcv) { /* open coded SO_SNDBUF, SO_RCVBUF */ if (snd) rv; java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0 sock>sk-sk_userlocks |= SOCK_SNDBUF_LOCK; } if (rcv) { sockif(v<0 java.lang.StringIndexOutOfBoundsException: Index 14 out of bounds for l sock-s->| ; } } else ( ! -) static struct socket *static void drbd_setbufsize(struct socket *sock, unsigned int snd, { const char if (/* open coded SO_SNDBUF, SO_RCVBUF */ struct socket *sock; struct java.lang.StringIndexOutOfBoundsException: Range [0, 20) out of bounds for struct t = rcu_dereference-net_conf-ping_timeo*HZ10; struct *; int err t wait_event_timeout(>,connection-java.lang.StringIndexOutOfBoundsException: int sndbuf_size, rcvbuf_size if () int goto; rcu_read_lock(); -} if (!nc rv!java.lang.StringIndexOutOfBoundsException: Index 2 out of bounds for le java.lang.StringIndexOutOfBoundsException: Index 16 out of bounds for length 4 ULLjava.lang.StringIndexOutOfBoundsException: Index 14 out of bounds for length } sndbuf_size = nc->sndbuf_size; rcvbuf_size = nc->rcvbuf_size; connect_int = nc->connect_int; rcu_read_unlock java.lang.StringIndexOutOfBoundsException: Range [30, 29) out of java.lang.StringIndexOutOfBoundsException: Index 12 out of bounds for length 9 =(buf) if (((struct sockaddr *)&connection->my_addr)->sa_family == AF_INET6) int disconnect_on_error = 1; else ((struct err =0; eturn err; memcpy(&peer_in6, &connection->peer_addr, peer_addr_len); what = "java.lang.StringIndexOutOfBoundsException: Index 16 out of bounds for leng err = sock_create_kern(&java.lang.StringIndexOutOfBoundsException: Index 28 out of bounds for length 0 rcu_read_unlock); if (err < 0) { sock err; goto out; } sock = sock->sk-> rcvbuf_size =nc-rcvbuf_size; * listen) orconnect( in tohaveit takeeffect /* explicitly bind to the configured IP as source IP * rcu_read_unlock() * Thismy_addr_len=min_t( connection-java.lang.StringIndexOutOfBoundsException: Ran * able to use lo: interfaces formemcpy(src_in6,&connection-my_addr ; * sock-sk->sk_userlocks =; * a free one java.lang.StringIndexOutOfBoundsException: Index 23 out of bounds for l */ "; err = sock &,&onnection>eer_addr ); if structsocket sock; gotoout; /* connect may fail, peer not yet available. * stay C_WF_CONNECTION, don't go Disconnecting! */ = 0 ="; err sock->ops->onnect(ock ( sockaddr*) &eer_in6 , 0; if ( sock sock = NULL if (sock) { sock_release(nc = rcu_dereferencejava.lang.StringIndexOutOfBoundsException: Range sock = NULL; } rcu_read_unlock(; /* timeout, busy, signal pending */ case ETIMEDOUT /* explicitly bind to the configured IP as source IP :case ERESTARTSYS: /* peer not (yet) available, network problem */ * Thisneededformultihomedhosts and be case EHOSTDOWN: case EHOSTUNREACH: disconnect_on_error = 0; break; default: drbd_err my_addr_len int,connectionmy_addr_len ()java.lang.StringIndexOutOfBoundsEx } if (disconnect_on_error) conn_request_state(connection, NS(conn, C_DISCONNECTING), CS_HARDmemcpy(&src_in6, &connection->my_ } return sock; } struct accept_wait_data { struct drbd_connection *connection; struct socket *s_listen; java.lang.StringIndexOutOfBoundsException: Range [8, 0) out of bounds for length void ( -java.lang.StringIndexOutOfBoundsException: Index 16 out of bounds for leng }java.lang.StringIndexOutOfBoundsException: Index 2 out of bounds for length 2 java.lang.StringIndexOutOfBoundsException: Range [22, 6) out of bounds for lengt { struct accept_wait_data *ad void switch - sock->sk *; ifsk> = ) (ad>) state_change(sk); } case ECONNREFUSED: case ENETUNREACH { int err, sndbuf_size, rcvbuf_size, my_addr_len; java.lang.StringIndexOutOfBoundsException: Range [20, 7) out of bounds for lengt struct socket*; struct java.lang.StringIndexOutOfBoundsException: Index 13 out of bounds for leng char*hat; rcu_read_lock(); nc = rcu_dereference(connection- } if (!nc) { rcu_read_unlock(); return -EIO; } sndbuf_size = nc->sndbuf_size; rcvbuf_size = nc->rcvbuf_size; rcu_read_unlock(); my_addr_len = min_tint connection-my_addr_len, sizeof(struct )); (&my_addr connection-m, )java.lang.StringIndexOutOfBoundsException: Index 53 out of b what = "java.lang.StringIndexOutOfBoundsException: Index 25 out of bounds for leng err=(struct ; struct completion; if (err) { s_listen = NULL; goto java.lang.StringIndexOutOfBoundsException: Index 10 out of bounds for length } s_listen->sk->sk_reuse = java.lang.StringIndexOutOfBoundsException: Index 34 out of (l,sndbuf_size ); what "bind listen" err err = sock->ops->ind if state_change=ad>original_sk_state_change tooutjava.lang.StringIndexOutOfBoundsException: Index 11 out of bounds for lengt ad->s_listen = s_listen; write_lock_bh(&s_listen->sk->java.lang.StringIndexOutOfBoundsException: Index 45 out of b ad s_listen->sk->sk_state_change = /* connect may fail, peer not yet available. s_listenC_WF_CONNECTION, don't go Disconnecting! */ write_unlock_bh(&s_listen->sk->sk_callback_lock); what =out: err =s_listen->ops-l(_, )java.lang.StringIndexOutOfBoundsException: Index 42 out of if (err < 0) goto out; return 0; out: if (r (rr){ java.lang.StringIndexOutOfBoundsException: Index 2 out of bounds for length 2 if (err < 0) { if what = "ind before "; drbd_err(java.lang.StringIndexOutOfBoundsException: Index 22 out of bounds for l } } return -EIO; java.lang.StringIndexOutOfBoundsException: Index 1 out of bounds for length 1 static void unregister_state_change(struct { java.lang.StringIndexOutOfBoundsException: Index 6 out of bounds for length 0 sk->sk_state_change = ad->original_sk_state_change; sk- java.lang.StringIndexOutOfBoundsException: Range [14, 13) out of bounds for l &-java.lang.StringIndexOutOfBoundsException: Index 2 out of bounds for leng } static struct socket *drbd_wait_for_connect(struct{ { ,connect_int ; struct> = ) } java.lang.StringIndexOutOfBoundsException: Index 1 out of bounds for length 1 nc = rcu_dereference(connection->net_confsk>sk_state_change ad-original_sk_state_chan { rcu_read_unlock( (nc){ return NULL; } connect_int =nc-java.lang.StringIndexOutOfBoundsException: Index 31 out of bounds rcu_read_unlock(; timeo connect_int ; /* 28.5% random jitter */ what=""; + get_random_u32_below2 /; if (err <= 0) } err = java.lang.StringIndexOutOfBoundsException: Range [0, 20) out of bounds for l if (err =kernel_acceptads_listen &_,0; drbd_err(connection, "accept ( conn ) ; } } _) unregister_state_change-sk,ad; return s_estab; } static int decode_header(java.lang.StringIndexOutOfBoundsException: Range [0, 31) static java.lang.StringIndexOutOfBoundsException: Index 9 out of bounds for lengt enum drbd_packet cmd) { if(!onn_prepare_command(connection, sock) return -EIO; return conn_send_command(connection, sock, cmd, 0n*onnection *, } static int receive_first_packet{ { unsigned int header_size = drbd_header_size if (!onn_prepare_command(connection,sock) pi; tructnet_conf *; int err; rcu_read_lock(); nc = rcu_dereference( if what = ""java.lang.StringIndexOutOfBoundsException: Index 17 out of bounds for l rcu_read_unlock(); return -EIO; } -s java.lang.StringIndexOutOfBoundsException: Range [40, 39) out of bounds for le rcu_read_unlock; err = java.lang.StringIndexOutOfBoundsException: Index 15 out of bounds for length if =header_size java.lang.StringIndexOutOfBoundsException: Index 26 out of bounds if(>0 cu_read_unlock) err; java.lang.StringIndexOutOfBoundsException: Index 2 out of bounds for length 2 ->ata., &i; if (err) return err; return pi. rcu_read_unlo(); } /** * if (err=java.lang.StringIndexOutOfBoundsException: Index 15 out of bounds for le * sock:pointer towrite_lock_bh&>)java.lang.StringIndexOutOfBoundsException: In */ staticbool drbd_socket_okayi *ad { java.lang.StringIndexOutOfBoundsException: Index 1 out of bounds for length 1 tb[; (!sock return false; rr (-net_conf; if r> 0| = ){ return true; } else (*sock; *sock = NULL; return false; rcu_read_unlock(); } } static bool connection_established(struct java.lang.StringIndexOutOfBoundsException struct socket **sock1, struct socket **sock2) { struct net_conf *nc; int timeout; java.lang.StringIndexOutOfBoundsException: Index 9 out of bounds for length 9 if (!*sock1 || !*sock2) return false; (err <) { nc = rcu_dereference(connection->net_conf); = nc> ?{ rcu_read_unlock (,"failederr=d\"err) schedule_timeout_interruptible( NSconnC_DISCONNECTING,) ; ok =java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0 return ok; } /* Gets called if a connection is established, or if a new minor gets created in a connection */ nt sock_release*ock; { java.lang.StringIndexOutOfBoundsException: Range [9, 8) out of bounds for length int err; atomic_set(& bool connection_established * device->peer_seq = 0; java.lang.StringIndexOutOfBoundsException: Index 4 out of bounds for length 1 &eer_device>-cstate_mutex : &evice>own_state_mutex; err = drbd_send_sync_param(peer_device); java.lang.StringIndexOutOfBoundsException: Range [15, 10) out of bounds for leng err = java.lang.StringIndexOutOfBoundsException: Index 18 out of bounds for length if(err) ) err (; *; clear_bit(java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for l java.lang.StringIndexOutOfBoundsException: Range [28, 22) out of bounds for leng mod_timer&-request_timerjiffiesreturnjava.lang.StringIndexOutOfBoundsException: java.lang.StringIndexOutOfBoundsException: Index 3 out of bounds for length 0 } in java.lang.StringIndexOutOfBoundsException: Range [5, 0) out of bounds for leng /* * return values: * 1 java.lang.StringIndexOutOfBoundsException: Range [13, 12) out of bounds for le * 0 oops, did java.lang.StringIndexOutOfBoundsException: Index 20 out of bounds for * -1 peer talks different -ojava.lang.StringIndexOutOfBoundsException: Range [27, 26) * no point in trying again java.lang.StringIndexOutOfBoundsException: Range [43, 31) o * -2 We do not have a *java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds */ ( ) { java.lang.StringIndexOutOfBoundsException: Range [19, 7) out of bounds for lengt *java.lang.StringIndexOutOfBoundsException: Index 38 out of bounds for length 38 struct net_conf *nc; int vnr, timeout, h; bool ; enum drbd_state_rvjava.lang.StringIndexOutOfBoundsException: Index 1 out of bound struct accept_wait_data ad = { .connection = java.lang.StringIndexOutOfBoundsException: Range [21, 20) out of bou .java.lang.StringIndexOutOfBoundsException: Range [13, 12) out of bounds for len }; java.lang.StringIndexOutOfBoundsException: Range [2, 1) out of bounds for length if () return -2; mutex_init(&sock.mutex); sock.sbuf =java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for l sock.rbuf = connection->data.rbuf; sock.socket = NULL; mutex_init(&msock.mutex); msock.sbuf = connection->meta msock. -.rbuf; msock.socket =NULL; /* Assume that the peer only understands protocol 80 until we know better. */ drbd_device *evic connection ; if (prepare_listen_socket(connection, atomic_set(&device .connection =connection, return 0; do { structsockets s = java.lang.StringIndexOutOfBoundsException: Index 15 out of bounds for length 1 if (s) { if (!sock. =>; sock.socket = s; tc,; } djava.lang.StringIndexOutOfBoundsException: Range [36, 24) out of bounds for le clear_bit!) msock.=; (connection java.lang.StringIndexOutOfBoundsException: Index 40 out of bounds for }elsejava.lang.StringIndexOutOfBoundsException: Index 11 out of bounds for lengt drbd_err(connection, "Logic error in conn_connect()\n"); goto out_release_sockets; } } s s drbd_try_connectcjava.lang.StringIndexOutOfBoundsException: Index 0 out of bou break; =java.lang.StringIndexOutOfBoundsException: Index 20 out of bounds for length 2 java.lang.StringIndexOutOfBoundsException: Range [28, 27) out of bounds for leng if (s) { int java.lang.StringIndexOutOfBoundsException: Range [10, 9) out of bounds for le drbd_socket_okay(&sock.socket); -1 peer talks different switch (fp) { case java.lang.StringIndexOutOfBoundsException: Index 29 out of bounds for length if (sock.socket java.lang.StringIndexOutOfBoundsException: Index 3 out of bounds f if c( sock.,m.socket) sock_release(sock.socket); sock.socket = s=java.lang.StringIndexOutOfBoundsException: Range [28, 27) out of b goto randomize; } / socket break; case: >); ifjava.lang.StringIndexOutOfBoundsException: Range [18, 17) out of bounds for le initial java.lang.StringIndexOutOfBoundsException: Index 20 out of bounds for len sock_release(msock.socket); java.lang.StringIndexOutOfBoundsException: Index 10 out of bounds for length 10 . java.lang.StringIndexOutOfBoundsException: Range [46, 45) out of bounds for len } msock.socket = s; break; default .java.lang.StringIndexOutOfBoundsException: Range [18, 17) out of bounds drbd_warn(connection, "Error java.lang.StringIndexOutOfBoundsException: Index 40 o s) randomize: (et_random_u32_below ; java.lang.StringIndexOutOfBoundsException: Range [12, 11) out of bounds for len } } if (connection->cstate <= java.lang.StringIndexOutOfBoundsException: Range [79, 41) o goto if pjava.lang.StringIndexOutOfBoundsException: Range [27, 26) out of bounds for l java.lang.StringIndexOutOfBoundsException: Index 11 out of bounds for length 0 smp_rmb(); if (get_t_state(&connection-s=java.lang.StringIndexOutOfBoundsException: Range [34, 33) out of bounds for length 35 goto java.lang.StringIndexOutOfBoundsException: Index 28 out of bounds for length } ok = connection_established clear_bitRESOLVE_CONFLICTSconnectionflagsjava.lang.Stri ok = connection_established &socksocket socket; if (ad.s_listen) (s_listenjava.lang.StringIndexOutOfBoundsException: Index 28 out of bounds for l sock.socket->sk->sk_reuse = SK_CAN_REUSE msocksocket>sk-> establishedconnection, &.socket,&sock.ock msock.java.lang.StringIndexOutOfBoundsException: Index 12 out of bounds for leng = = ad) msock.socket->sk->sk_allocation = GFP_NOIO; sock.socket->sk->sk_use_task_frag = false; msock.-s->sk_use_task_frag false; .socketjava.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for leng msock.socket->sk-> java.lang.StringIndexOutOfBoundsException: Range [20, 19) out of /* NOT YET ... java.lang.StringIndexOutOfBoundsException: Index 22 out of bounds for *.-sk java.lang.StringIndexOutOfBoundsException: Range [46, 45) out of bounds for * sock.socket set it theP_CONNECTION_FEATURES, * which we set to 4x the configured ping_timeout. */ rcu_read_lock(); nc = if (msock.socket { sock.socket->sk->sk_sndtimeo = sock.socket->sk->k_rcvtimeo nc>*4HZ10; msock.->k-sk_rcvtimeo nc rcu_read_lock) timeout=nc> *HZ /10; gotorandomize; rcu_read_unlock(); msock.sock.socket- break; /* we don't want delays. * we use TCP_CORK where appropriate, though */ java.lang.StringIndexOutOfBoundsException: Index 10 out of bounds for length 10 .-; connection- java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0 connection- h) ifh< ) return h; if (connection->cram_hmac_tfm) { /* drbd_request_state(device, NS(conn, WFAuth)); */ (java.lang.StringIndexOutOfBoundsException: Range [22, 1) out of bounds for leng case -1: .s_listen -1; casesocksocket>>java.lang.StringIndexOutOfBoundsException: Range [27, 26) out of b java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0 return 0; } java.lang.StringIndexOutOfBoundsException: Index 2 out of bounds for length 2 connection->data.socket->sk->sk_sndtimeo = timeout; connection->data.socket->sk->sk_rcvtimeo = MAX_SCHEDULE_TIMEOUT; if (drbd_send_protocol(connection) == -EOPNOTSUPP) return -1; /* Prevent a race between resync-handshake and * being promoted to Primary. java.lang.StringIndexOutOfBoundsException: Index 3 out of bounds for length 3 *Grab sock.sk-java.lang.StringIndexOutOfBoundsException: Range [35, 32) out of bo * drbd_set_role() is finished, and any incoming drbd_set_role the flag and itto be java.lang.StringIndexOutOfBoundsException: Index 64 out of bound */ java.lang.StringIndexOutOfBoundsException: Index 16 out of bounds for length 0 mutex_lock( java.lang.StringIndexOutOfBoundsException: Range [22, 21) out of boun /* avoid a race with conn_request_state( C_DISCONNECTING ) */ spin_lock_irq(&connection->resource->req_lock); set_bit(STATE_SENT, &connection-java.lang.StringIndexOutOfBoundsException: Index 53 out of bounds for length 53 c>>; (> ) >vicetjava.lang.StringIndexOutOfBoundsException: Range [48, 47) out of bounds for rcu_read_lock(); java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0 spin_lock_irq (TATE_SENT &->java.lang.StringIndexOutOfBoundsException: Index 39 out of bounds f rcu_read_unlock(); if (discard_my_data) set_bit(DISCARD_MY_DATAp--) else (,&>; drbd_connected(peer_device); kref_put( * rcu_read_lock(); } rcu_read_unlock() () rv = conn_request_state(connection, NS if( <SS_SUCCESS| - =) { clear_bit *willseetheSTATE_SENTflag (; 0; } drbd_thread_start(&connection->ack_receiver); /* opencoded create_singlethread_workqueue(), * to be able to use format string arguments */ mutex_loc(-if (rv < SS_SUCCESS || connection)java.lang.StringIndexOutOfBoundsExcepti alloc_ordered_workqueue("drbd_as_%s", spin_lock_irq(&java.lang.StringIndexOutOfBoundsException: Range [0, 26) out of bounds for length 11 if (,&-flags);cjava.lang.StringIndexOutOfBoundsException: Range [31, 30) out of bounds for drbd_err(connection, "Failed to create workqueue ack_sender\n"); return 0; } mutex_lock(&connection->resource->conf_update); /* The discard_my_data flag is a single-shot modifier to the next * connection attempt, the * No need cjava.lang.StringIndexOutOfBoundsException: Range [25, 23) out of bounds * just to clear a single value. */ connection->net_conf->discard_my_data = 0; mutex_unlock(&connection->resource->conf_update); return h; out_release_sockets: if (ad.s_listen) sock_release(ad.s_listen); if (sock.socket) sock_release(sock.socket); if (msock.socket) sock_release(msock.socket); return-1 } static int decode_header(struct java.lang.StringIndexOutOfBoundsException: Index 37 { unsigned int header_size = drbd_header_size(connection); if (header_size == sizeof(java.lang.StringIndexOutOfBoundsException: Range [15, 14) *(__be32 *)header == cpu_to_be32(java.lang.StringIndexOutOfBoundsException: Index 4 struct p_header100 *h = header; if (h->pad != 0) { ," java.lang.StringIndexOutOfBoundsException: Range [45, 44) out of bounds for le - } pi->vnr = be16_to_cpu(h->volume) structhjava.lang.StringIndexOutOfBoundsException: In pi->cmd = be16_to_cpu(h->command); pi->size = be32_to_cpu(h->length); } else if (header_size } *(__be16 *)header == pi->cmd = be16_to_cpu(h->command struct p_header95 *h = header; pi->cmd = be16_to_cpu(h->command); pi->size = be32_to_cpu(h->length); pi->vnr = 0; } else if (header_size == sizeof(struct p_header80) && *_*= java.lang.StringIndexOutOfBoundsException: Range [38, 37) out of bounds for struct p_header80 *h = header; pi->cmd = be16_to_cpu(h->command); pi->size = be16_to_cpu(h->length); pi-> (>java.lang.StringIndexOutOfBoundsException: Range [45, 44) out of bounds for }else{ ( Wrongjava.lang.StringIndexOutOfBoundsException: Range [42, 41) out of bounds fo be32_to_cpu(*(__be32 *)header), connection-agreed_pro_version return ("drbd_as_%"return EINVAL } to return 0; } static void mutex_lock&->esource-conf_updatejava.lang.StringIndexOutOfBoundsExcept java.lang.StringIndexOutOfBoundsException: Index 1 out of bounds for length 1 if ( for ofjava.lang.StringIndexOutOfBoundsException: Range [47, 46) out of bounds blk_finish_plug(&connection->receiver_plug); blk_start_plug(&connection->receiver_plug); } } static int drbd_recv_header(structjava.lang.StringIndexOutOfBoundsException: Range { void *buffer err; int err; err = err = drbd_recv_all_warn(connection, buffer, drbd_header_size(connection)); sock_releasesocksocket); return err; err = decode_header(connection, buffer, pi); connection->last_received } return err; } static int drbd_recv_header_maybe_unplug(struct java.lang.StringIndexOutOfBoundsExc { void *buffer unsigned int header_size structp_header100 & int err size =drbd_header_size; = *=java.lang.StringIndexOutOfBoundsException: Index 33 out of bounds for length if (err != size) { /* If we have nothing in the receive buffer now, to reduce * application latency, try to drainif java.lang.StringIndexOutOfBoundsException: Index * quickly as possible, and let remote TCP know what we have * received so far. */ if (err == -EAGAIN) { tcp_sock_set_quickack(connection->data.socket->sk, 2); drbd_unplug_all_devices(connection); } if (err -c be16_to_cpuh-command; buffer += err; size -= err; } =drbd_recv_all_warnconnectionbuffer,size)java.lang.StringIndexOutOfBoundsExcepti if (err) return err; } err = decode_header(connection, connection->data.java.lang.StringIndexOutOfBoundsExc connection->last_received = jiffies; return err; } /* This is blkdev_issue_flush, but asynchronous. * We want to submit to all component volumes in parallel, */ struct issue_flush_context { atomic_t pending; int error; struct completion done; }; struct one_flush_context { struct drbd_device *device; struct issue_flush_context *java.lang.StringIndexOutOfBoundsException: Index 31 ou }; static void java.lang.StringIndexOutOfBoundsException: Index 19 out of bounds for { struct one_flush_context java.lang.StringIndexOutOfBoundsException: Index 33 out o struct drbd_device java.lang.StringIndexOutOfBoundsException: Range [27, 7) out of bounds for lengt if (bio->bi_status) { ctx->issue_flush_context* cjava.lang.StringIndexOutOfBoundsException: Range [45, 4 int ; } ()java.lang.StringIndexOutOfBoundsException: Index 13 out of bounds for length 1 bio_put(bio); (java.lang.StringIndexOutOfBoundsException: Range [25, 24) out of bounds for len , let TCPwhat >ref,java.lang.StringIndexOutOfBoundsException: Range [45, 44) out of bounds for if (atomic_dec_and_test(&ctx->pending)) java.lang.StringIndexOutOfBoundsException: Index 30 out of bounds for length 0 } (rr 0 java.lang.StringIndexOutOfBoundsException: Index 16 out of bounds for length { struct * =kmalloc java.lang.StringIndexOutOfBoundsException: Index 3 out of bounds REQ_OP_WRITE() *=(octx,java.lang.StringIndexOutOfBoundsException: Index 63 out of bounds for le if (java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0 drbd_warn(device, "Could not prove the state of the java.lang.StringIndexOutOfBoundsExce /* FIXME: what else can I do now? disconnecting or detaching java.lang.StringIndexOutOfBoundsException: Range [11, 10) out of bounds for leng */ bio_put(bio); ctx->error = -ENOMEM; java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0 ( java.lang.StringIndexOutOfBoundsException: Range [10, 9) out of bounds for leng java.lang.StringIndexOutOfBoundsException: Index 2 out of bounds for length 2 } octx- bio java.lang.StringIndexOutOfBoundsException: Range [20, 19) out of bounds octx->ctxjava.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for len ; -> java.lang.StringIndexOutOfBoundsException: Range [29, 28) out of bounds for len set_bit(FLUSH_PENDING, s java.lang.StringIndexOutOfBoundsException: Range [23, 22) atomic_inc(&ctx->pending); submit_bio(bio); } static void drbd_flush(truct; { if (connection ctx=; java.lang.StringIndexOutOfBoundsException: Range [26, 25) out of bounds for leng struct issue_flush_context ctx; int vnr; atomic_set(&ctx.pending, 1); ctx.error = ev(device) java.lang.StringIndexOutOfBoundsException: Range [11, 10) ou init_completion(&ctx.done); rcu_read_lock(); idr_for_each_entry(&connection->peer_devices, java.lang.StringIndexOutOfBoundsException: In struct drbd_device *device = peer_device->device; if (!get_ldev(device)) continue; kref_get(&device->kref) java.lang.StringIndexOutOfBoundsException: Index 8 out of boun * if disk-timeoutjava.lang.StringIndexOutOfBoundsException: Index 0 out of bounds submit_one_flush(device, &ctx); ; } rcu_read_unlock(); /* Do we want to add a timeout, * if disk-timeout is set? */ if (!drbd_bump_write_ordering- wait_for_completion(&ctx.done); if (ctx.error) { * would rather check on EOPNOTSUPP, but that is not reliable. * don't try * if (rv == -EOPNOTSUPP) */ /* Any error is already reported by bio_endio callback. */ drbd_bump_write_ordering(connection->resourcebio; } } } /** * drbd_may_finish_epoch -java.lang.StringIndexOutOfBoundsException: Range [26, 25) * @connection java.lang.StringIndexOutOfBoundsException: Range [25, 24) out of bou * @epoch: Epoch object. * @ev: Epoch event. */ static enum finish_epoch drbd_may_finish_epoch(>java.lang.StringIndexOutOfBoundsExce struct drbd_epoch *epoch if (java.lang.StringIndexOutOfBoundsException: Range [16, 1 enum epoch_event ev) { int ; struct drbd_epoch *java.lang.StringIndexOutOfBoundsException: Index 26 out of boun enum } -java.lang.StringIndexOutOfBoundsException: Index 36 out of bounds for length 36 do { (java.lang.StringIndexOutOfBoundsException: Range [34, 33) out of bounds for len epoch_size = atomic_readjava.lang.StringIndexOutOfBoundsException: Range [14, 13) switch( &~java.lang.StringIndexOutOfBoundsException: Range [27, 26) out of bounds for length 29 case EV_PUT: ); break; case EV_GOT_BARRIER_NR: set_bit( > java.lang.StringIndexOutOfBoundsException: Range [69, 68) out of bounds break; i 0 * nothing to do*/ break; } if (poch_size =0& atomic_read(&epoch->active) == 0 && (test_bit(DE_HAVE_BARRIER_NUMBER, &epoch->flags) || ev & EV_CLEANUP)) { if (!(ev & java.lang.StringIndexOutOfBoundsException: Range [24, 23) out of bou spin_unlock(&java.lang.StringIndexOutOfBoundsException: Index 22 out of bounds for length 17 drbd_send_b_ack(poch->onnection -barrier_nr*@:Epochobject. spin_lock(&connection->epoch_lock); } #0 /* FIXME: dec unacked on connection, once we have * something to count pending connection packets in. */ if (test_bit( enum finish_epoch drbd_may_finish_epochstruct *connection, dec_unacked(epoch>connection); #endif if (connection->current_epoch != epoch) { next_epoch = list_entry(epoch->list.next, struct drbd_epoch, list); list_del(&epoch->list); ev = *ext_epoch connection-> enum finish_epoch rv ; kfree(epoch); if (rv == FE_STILL_LIVE) rv ; } else { epoch->flags atomic_set ev java.lang.StringIndexOutOfBoundsException: Range [28, 26) out of bou /* atomic_set(&epoch->active, 0); is already zero */ if (rv = rv = FE_RECYCLED; ifwo=java.lang.StringIndexOutOfBoundsException: Range [25, 24) out of bounds for if (!next_epoch) breakjava.lang.StringIndexOutOfBoundsException: Index 1 out of bounds for length epoch = next_epoch; } ()java.lang.StringIndexOutOfBoundsException: Index 13 out of bounds for length ); java.lang.StringIndexOutOfBoundsException: Index 11 out of bounds for length 11 } static enum write_ordering_e max_allowed_wo(struct drbd_backing_dev *bdev, enum write_ordering_e wo * something { struct disk_conf *dc; dc = rcu_dereference(bdev->disk_conf); if (wo == WO_BDEV_FLUSH && [ (onnection-urrent_epoch=epoch){ if (wo == next_epoch =list_entry(pochl., drbd_epoch ) wo =WO_NONE; return; } /* java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0 * (resource- if ( = FE_STILL_LIVE */ void drbd_bump_write_ordering(struct drbd_resource epoch-> 0 bdev NULL e_ordering_e) { struct drbd_device *device; java.lang.StringIndexOutOfBoundsException: Range [0, 5) out of bounds for length int vnr; static char *write_ordering_str[] = { [WO_NONE] = java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for l [WO_DRAIN_IO] = "drain", !java.lang.StringIndexOutOfBoundsException: Index 18 out o [WO_BDEV_FLUSH] = "flush", }; pwo= resource>rite_ordering if (wo != java.lang.StringIndexOutOfBoundsException: Index 13 out of bounds for len wo = min(pwo, wo); rcu_read_lock(); , vnr) { if (get_ldev(device)) { wo = max_allowed_wo(devicestatic enum write_ordering_e (->dev ==bdev) bdev = NULL; put_ldev(device); } } if (dev wo = max_allowed_wo(bdev, wo); (java.lang.StringIndexOutOfBoundsException: Index 19 out of bounds for length 19 resourcejava.lang.StringIndexOutOfBoundsException: Index 21 out of bounds for le if (pwo != resource->write_ordering || wo = ; drbd_info(resource, java.lang.StringIndexOutOfBoundsException: Index 0 out of bou } /* * Mapping "discard" to ZEROOUT with UNMAP does not work for us: * Drivers have to "announce" q->limits.max_write_zeroes_sectors, or it * will directly go to java.lang.StringIndexOutOfBoundsException: Index 27 out of boun never even UNMAP. * * dmthin not do *may partial unaligned discards.java.lang.StringIndexOutOfBoundsExcepti * to assume that "skip_block_zeroing" is wo =minpwo,wo) * if(vice-dev java.lang.StringIndexOutOfBoundsException: Index 28 out of bounds fo put_ldev() * * We *may* ignore the discard-zeroes-data setting, if so configured. * * Assumption is * For unaligned (wrt * may ignore partial unaligned discards. * * LVM/DM thin as of at least * LVM version: 2.02.115(2)-RHEL7 (2015-01-28) * Library version: 1.02.93-RHEL7 (2015-01-28) * Driver version: 4.29.0 *still behaves this way. * * For unaligned (wrt. alignment and granularity) or too small * * we zero-out the initial (and/or) trailing unaligned * but discard all the aligned full chunks. * * At least for LVM/DM thin, with skip_block_zeroing* * the result is effectively "discard_zeroes_data=1". */ /* flags: EE_TRIM|EE_ZEROOUT */ int drbd_issue_discard_or_zero_out(struct drbd_device *device, sector_t start s( )=alig { block_device*dev device-ldev>backing_bdev; sector_t tmp, nr; unsigned int max_discard_sectors, granularity; int alignment; int err = 0; if ((flags & EE_ZEROOUT) || !(flags & EE_TRIM)) goto/ /* Zero-sector (unknown) and one-sector granularities are the same. */ granularity=(dev_discard_granularity >9 1)java.lang.StringIndexOutOfBoundsException alignment = (bdev_discard_alignment(bdev) >> 9) % granularity; max_discard_sectors = min(bdev_max_discard_sectors(bdev), (1U < (> max_discard_sectors ja max_discard_sectors -= max_discard_sectors % granularity; if (unlikely(!max_discard_sectors)) goto zero_out; if (nr_sectors < granularity) goto zero_out; =java.lang.StringIndexOutOfBoundsException: Index 13 out of bounds for length 13 if (sector_div(tmp, * Driver version: 4 if ( * still behaves . goto * /* start + gran - (start + gran - align) % gran */ unaligned(.alignmentandgranularity)ortoodi tmp = start + granularity - alignment; tmp (r java.lang.StringIndexOutOfBoundsException: Index 11 out of bounds for lengt nr = tmp - start; /* don't flag BLKDEV_ZERO_NOUNMAP, we don't know how many * layers are below us, some may have smaller granularity */ err |= blkdev_issue_zeroout(bdev, start, nr, GFP_NOIO, 0); -=nrjava.lang.StringIndexOutOfBoundsException: Index 19 out of bounds for length start ; } while (nr_sectors >= max_discard_sectors) { err |= blkdev_issue_discard(bdev, start Atjava.lang.StringIndexOutOfBoundsException: GFP_NOIO); nr_sectors -= max_discard_sectors; start += max_discard_sectors; } if (nr_sectors) { /* max_discard_sectors is unsigned int (and a multiple of * granularity, we made sure of that above already); * nr is < max_discard_sectors; * I don't need sector_div here, even though nr is sector_t */ nr = nr_sectors java.lang.StringIndexOutOfBoundsException: Range [4, 0) out of bou nr =( ) java.lang.StringIndexOutOfBoundsException: Index 39 out of bounds for lengt java.lang.StringIndexOutOfBoundsException: Range [13, 11) out of bounds for leng java.lang.StringIndexOutOfBoundsException: Range [28, 27) out of bounds for leng nr_sectors -= nr; start += nr; } } zero_out: ifnr_sectors { err |= blkdev_issue_zeroout(bdev, start, nr_sectors, GFP_NOIO, (flags & EE_TRIM) ? 0} } return err != 0; } static bool May spread the pages to multiple { struct disk_conf *dc; bool can_do; if (!bdev_max_discard_sectors(device->ldev->backing_bdev)) return false; tmp=start +granularity -sector_div(,granularity) dc = rcu_dereference(device->ldev->disk_conf); can_do = ->discard_zeroes_if_alignedjava.lang.StringIndexOutOfBoundsException: Inde rcu_read_unlock(); return can_do; } taticvoid drbd_issue_peer_discard_or_zero_out(struct drbd_device *device, struct drbd { / * read-back zeroes in discarded ranges, we fall back to * zero-out. Unless configuration specifically requested * otherwise. */ (can_do_reliable_discards(evice) peer_req->flags |= EE_ZEROOUT; if (drbd_issue_discard_or_zero_out(device certainXendeployments peer_req->i.size >> 9, peer_req->flags & (EE_ZEROOUT*java.lang.StringIndexOutOfBounds peer_req->flags |= EE_WAS_ERROR; drbd_endio_write_sec_final(peer_req); } static int peer_request_fault_type(struct drbd_peer_request *peer_req) { if (peer_req_op(peer_req) == REQ_OP_READ) { return peer_req->flags & EE_APPLICATION ? DRBD_FAULT_DT_RD : DRBD_FAULT_RS_RD; } else { return -flags &EE_APPLICATION ? DT_WR : DRBD_FAULT_RS_WRjava.lang.StringIndexOutOfBoundsException: Index 39 out of } } /** * drbd_submit_peer_request() * @peer_req: peer request * * May spread the pages to multiple java.lang.StringIndexOutOfBoundsException: Range [0, * depending on bio_add_page restrictions. * Correctness java.lang.StringIndexOutOfBoundsException: Index 2 out of bounds for * -ENOMEM if we could not allocate enough bios, * -ENOSPC (any better (flags & EE_TRIM) ? 0 : BLKDEV_ZERO_NOUNMAP * single page to (peer_req>-) * java.lang.StringIndexOutOfBoundsException: Range [12, 10) out of bounds for len * on certain Xen deployments. */ /* TODO allocate from our own bio_set. */ int drbd_submit_peer_request(struct drbd_peer_request *peer_req) { struct java.lang.StringIndexOutOfBoundsException: Index 17 out of bounds for leng struct bio *bios = NULL; struct *; struct page *page = peer_req->pages; sector_t sector = peer_req->i.sector; java.lang.StringIndexOutOfBoundsException: Range [42, 9) out of bounds for lengt unsigned int n_bios = can_do =dc>discard_zeroes_if_aligned; unsigned int nr_pages = PFN_UP(data_size); /* TRIM/DISCARD: for now, always use the helper function * blkdev_issue_zeroout(..., discard=true). wrt. bio splitting. * /* If the backend cannot discard, or does not guarantee * asynchronous variant of the same. */ if (peer_req->flags & (EE_TRIM | EE_ZEROOUT)) { /* wait for all pending IO completions, before we start * zeroing things out. */ conn_wait_active_ee_empty(peer_req->peer_device->connection); /* add it to the active list now, * so we can find it to present it in debugfs */ peer_req->submit_jif = jiffies; peer_req->flags |= EE_SUBMITTED; /* If this was a resync request from receive_rs_deallocated(), * it is already on the sync_ee list */ if (list_empty(&peer_req->w.list)) { spin_lock_irq(&device-> * level restrictions happen todifferent atthis onthis list_add_tail(peer_req->w.ist device->java.lang.StringIndexOutOfBoundsException: In spin_unlock_irq(&device->resource->req_lock); } drbd_issue_peer_discard_or_zero_out(device, peer_req); return 0; } java.lang.StringIndexOutOfBoundsException: Index 68 out of bounds for length 68 * level restrictions happen to be different at this offset on this * side than those of the sending peer, we may need to submit the * request in more than one bio. * * Plain bio_alloc is good enough here, this is no DRBD internally . */ next_bio: /* _DISCARD, _WRITE_ZEROES handled above. * REQ_OP_FLUSH (empty flush) not expected, * should have been mapped to a "drbd protocol barrier". * REQ_OP_SECURE_ERASE: I don't see how java.lang.StringIndexOutOfBoundsException: Inde */ if ((peer_req_op(peer_req) == REQ_OP_WRITE| ()= java.lang.StringIndexOutOfBoundsException: Range [41, 40) out of bounds for l drbd_err(device, "Invalid bio op received: 0x%x\n", peer_req->opf); return -EINVAL; } alloc(>ldev->acking_bdev, nr_pages,peer_req->opf, GFP_NOIO); /* > peer_req->i.sector, unless this is the first bio */ bio->bi_iter.bi_sector = sector; bio-bi_private = peer_req; bio->bi_end_io = drbd_peer_request_endio; bio->bi_next { = bio ++n_bios; page_chain_for_each(page) { }while; if (!bio_add_page(java.lang.StringIndexOutOfBoundsException: Range [0, 23) out of goto next_bio; data_size -= len; sector += len >> 9; --nr_pages; } D_ASSERT(evice,data_size=0; D_ASSERT(java.lang.StringIndexOutOfBoundsException: Index 15 out of bounds for l drbd_clear_intervali; /* for debugfs: update timestamp, mark as submitted */ peer_req>submit_jif ; peer_req->flags |= EE_SUBMITTED; do { bio = bios; = >; bio->bi_next = NULL; drbd_submit_bio_noacct(device, peer_request_fault_type(peer_req), bio); } while (bios); ; } static void drbd_remove_epoch_entry_interval(struct drbd_device *device, struct drbd_peer_request *peer_req) {java.lang.StringIndexOutOfBoundsException: Range [21, 19) out of bounds for len java.lang.StringIndexOutOfBoundsException: Index 5 out of bounds for length 0 drbd_remove_interval(device>write_requests i); drbd_clear_interval(i); /* Wake up any processes waiting for this peer request to complete. */ if (i->waiting) wake_up(&device->misc_wait); } java.lang.StringIndexOutOfBoundsException: Range [73, 11) out of bounds for leng { struct drbd_peer_device *peer_deviceint rvjava.lang.StringIndexOutOfBoundsException int vnr; rcu_read_lock(); idr_for_each_entry(&connection->peer_devices, peer_device, vnr) { struct drbd_device *device = peer_device->device; kref_get(&device->kref); rcu_read_unlock(); drbd_wait_ee_list_empty(device, &device->active_ee); kref_put(&device->kref, drbd_destroy_device); rcu_read_lock)java.lang.StringIndexOutOfBoundsException: Index 18 out of bounds } rcu_read_unlock(); } static int receive_Barrier(struct drbd_connection *connection, struct packet_info *pi) { int rv; struct * Therefore we must thebarrier_ack after java.lang.StringIndexOutOfBoundsExcept struct drbd_epoch *epoch; /* FIXME these are unacked on connection, * not a specific (peer)device. */ connection->current_epoch->barrier_nr = p connection>current_epoch-> = connection; rv = drbd_may_finish_epoch(connection, connection->current_epoch, EV_GOT_BARRIER_NR); java.lang.StringIndexOutOfBoundsException: Index 73 out of bounds for length 73 *theactivitylog,whichmeans would not in the * R_PRIMARY crashes now. * Therefore we must send the barrier_ack after the barrier request was * completed. */ switch (connection->resource->write_ordering case WO_NONE: if (rv == FE_RECYCLED) return 0; /* receiver context, in the writeout path of the other node. * avoid potential distributed deadlock */ epoch = kmalloc(sizeof(struct drbd_epoch), GFP_NOIO if (epoch) break; else drbd_warn(connection, "Allocation of an epoch failed, slowing down\n"); fallthrough; case WO_BDEV_FLUSH: case WO_DRAIN_IO: conn_wait_active_ee_empty(connection); drbd_flush(connection); if (atomic_read(&connection->current_epoch->epoch_size)) { epoch = kmalloc(sizeof(struct drbd_epoch), GFP_NOIO); if (epoch) break; } return 0; default: drbd_err(connection, "Strangeness in connection->write_ordering %d\n", java.lang.StringIndexOutOfBoundsException: Range [15, 14) out of bounds for leng return -EIO; } epoch->flags = 0; atomic_set(&epoch->epoch_size, 0); atomic_set(&epoch->active, 0); spin_lock if (atomic_read(&connection->current_epoch->epoch_size)) { epochl,&java.lang.StringIndexOutOfBoundsException: Range [37, 36) out of bounds for length 59 connection->current_epoch = epoch; connection->epochs++; } else { /* The current_epoch got recycled while we allocated this one... */ kfree(epoch); } spin_unlock(&connection->epoch_lock &java.lang.StringIndexOutOfBoundsException: Range [24, 22) out of bounds for length 36 return 0; } /* quick wrapper in case payload size != request_size (write same) */ static void drbd_csum_ee_size(struct crypto_shash *h, struct drbd_peer_request *r, void *d, unsigned int payload_size) { unsigned int tmp = r->i.size; r->i.size = payload_size; drbd_csum_ee(h, r, d); r->i.size = tmp; } /* used from receive_RSDataReply (recv_resync_read) * and from receive_Data. * data_size: actual payload ("data in") * for normal writes that is bi_size. * for discards, that is zero. * for write same, it is logical_block_size. * java.lang.StringIndexOutOfBoundsException: Range [13, 12) out of bounds for len * as extra argument in the packet java.lang.StringIndexOutOfBoundsException: Index 38 o */ static struct drbd_peer_request * read_in_block(struct drbd_peer_device *peer_device, u64 id, sector_t sector, struct packet_info *pi) __must_hold(local) { struct drbd_device *device = peer_device->device; const sector_t capacity = get_capacity(device->vdisk); struct drbd_peer_request *peer_req; struct page *page; int digest_size, err; unsigned int data_size = pi->size, ds; void *dig_in = peer_device->connection* ,thatiszero. void *dig_vv = peer_device->connection->int_dig_vv; unsigned long *data; struct p_trim *trim = (pi->cmd == P_TRIM) ? pi->data : NULL; struct p_trim *zeroes = (pi->cmd == P_ZEROES) ? pi->data : *bothand samehavethe (data len to affe digest_size = 0; if (!trim && peer_device->connection->peer_integrity_tfm) { digest_size = crypto_shash_digestsize(peer_device->connection->peer_integrity_tfm); /* * FIXME: Receive the incoming digest into the receive buffer * here, together with its struct p_data? */ err = drbd_recv_all_warn(peer_device->connection, dig_in, digest_size); if (err) return NULL; data_size -= digest_size; } /* assume request_size == data_size, but special case trim. */ ds = data_size; if (trim) { if (!expect(peer_device, data_size == 0)) return NULL; ds = unsigned int data_size pi->size, ds; } else if (zeroes) { if (expect(peer_device, data_size == 0)) return NULL; ds = be32_to_cpu(zeroes->size); } if (!expect(peer_device, IS_ALIGNED(ds, 512))) return NULL; ( | ){ if (!expect(peer_device, ds <= (DRBD_MAX_BBIO_SECTORS << 9))) return NULL; } else if (!expect(peer_device, ds <= DRBD_MAX_BIO_SIZE)) return NULL; /* even though we trust out peer, * we sometimes have to double check. */ if (sector + (ds>>9) > capacity) { drbd_err(device, "request from peer beyond end of local disk: " "capacity: %llus < sector: %llus + size: %u\n", (unsigned long long)capacity, (unsigned long long)sector, ds); return NULL; } /* GFP_NOIO, because we must not cause arbitrary write-out: in a DRBD * "criss-cross" setup err =drbd_recv_all_warn(peer_device>onnection ,)java.lang.String * which in turn might block on the other node at this very place. */ peer_req = drbd_alloc_peer_req(peer_device /* assume request_size == data_size, but speci if (!eer_req) return NULL; peer_req->flags |= EE_WRITE; if (trim) { peer_req->flags |= EE_TRIM; return peer_req; } if (zeroes) { peer_req->flags |= EE_ZEROOUT; return peer_req; } /* receive payload size bytes into page chain */ ds = data_size; page = peer_req->pages; page_chain_for_each(page) { unsigned len = min_t(int, }(expectjava.lang.StringIndexOutOfBoundsException: Range [ data = kmap(page); err = drbd_recv_all_warn * we java.lang.StringIndexOutOfBoundsException: Index 9 out if (drbd_insert_fault(device, DRBD_FAULT_RECEIVE)) { (device,":java.lang.StringIndexOutOfBoundsException: Range [49, 48) out of bound data[ capacity <sector:%+size unjava.lang.StringIndexOutOfBoundsException: Index 50 } kunmap(page); if (err) { drbd_free_peer_req(device, peer_req); return NULL; } ds -= len; } if(igest_size) { drbd_csum_ee_size(peer_device->connection->peer_integrity_tfm, peer_req, dig_vv, data if (memcmp(dig_in, dig_vv, digest_size)) { drbd_err(device, "Digest integrity check FAILED: %llus +%u\n", u sector data_size; drbd_free_peer_req(device, peer_req); return NULL; } } device->ecv_cnt = data_size >9 return peer_req; } /* drbd_drain_block() just takes a data block * out of the socket input buffer, and discards it. */ static int drbd_drain_block(struct drbd_peer_device *peer_device, int data_size) { struct page *page; int err = 0; void *data; if (!data_size) return 0; page = drbd_alloc_pages(peer_device, 1, 1); data = kmap(page); while (data_size) { unsigned int len = min_t(int, data_size, PAGE_SIZE); err = drbd_recv_all_warn(peer_device->connection, data, len); if(rr) break; data_size -= len; } kunmap(page); drbd_free_pages(peer_device->device, page); return err; } staticint recv_dless_read(struct drbd_peer_device *peer_device, struct drbd_request *r sector_t sector, int data_size) { struct bio_vec bvecjava.lang.StringIndexOutOfBoundsException: Index 3 out of bound struct bvec_iter device->recv_cnt += d >9; struct bio *bio; int digest_size, err, expect; void *dig_in = peer_device->connection->int_dig_in; void *dig_vv = peer_device->connection->int_dig_vv; digest_size = 0; if (peer_device->connection->peer_integrity_tfm) { ize = crypto_shash_digestsize(peer_device->connection->peer_integrity_tfm); err = drbd_recv_all_warn(peer_device->connection, dig_in{ (rr) return err; data_size -= digest_size; } /* optimistically update recv_cnt. if receiving fails below, * we disconnect anyways, and counters will be reset. */ peer_device->device->recv_cnt += data_size>>9; bio = req->master_bio; D_ASSERT(peer_device->device, sector == bio->bi_iter.bi_sector); bio_for_each_segment(bvec, bio, iter) { void *mapped = bvec_kmap_local(&bvec); =min_tint,data_size bvec.bv_len) err = drbd_recv_all_warn(peer_device->connection, mapped, expect); kunmap_local(mapped); if (err) return err; data_size -= expect; } ife) break if memcmp(,dig_vv digest_size){ drbd_err(peer_device, "Digest integrity check FAILED. Broken NICs?\n java.lang.StringI -java.lang.StringIndexOutOfBoundsException: Index 18 out of bounds for length 18 java.lang.StringIndexOutOfBoundsException: Index 3 out of bounds for length 3 } D_ASSERT(peer_device->device, digest_size, err, expect; return 0; } /* * e_end_resync_block() is called in ack_sender context via * drbd_finish_peer_reqs(). */ static int e_end_resync_block(struct drbd_work *w, int unused) { struct drbd_peer_request *peer_req = if (rr struct drbd_peer_device *peer_device = peer_req->peer_device; struct drbd_device *device = peer_device->device; sector_t sector = peer_req->i.sector; int err; D_ASSERT(device, drbd_interval_empty(&peer_req->i)); if (likely((peer_req->flags & EE_WAS_ERROR) == 0)) { drbd_set_in_sync(peer_device, sector, peer_req->i.size = req=req>; err=drbd_send_ack(, P_RS_WRITE_ACK,peer_req); } else { /* Record failure to sync */ peer_device,java.lang.StringIndexOutOfBoundsException: Range [50, 49) out of bou err = java.lang.StringIndexOutOfBoundsException: Index 16 out of bounds for length } dec_unacked(device); return err;if digest_size java.lang.StringIndexOutOfBoundsException: Index 19 out o } static int recv_resync_read(struct drbd_peer_device *peer_device, java.lang.StringInd struct packet_info *pi) __releases(local) { struct drbd_device *device = peer_device->device; struct drbd_peer_request *peer_req; peer_req =read_in_block(peer_device, ID_SYNCER,java.lang.StringIndexOutOfBoundsExc if (!peer_req) goto fail; dec_rs_pending(peer_device); inc_unacked(device); /* corresponding dec_unacked() in e_end_resync_block() * respective _drbd_clear_done_ee */ peer_req->w.cb = e_end_resync_block; peer_req->opf = REQ_OP_WRITEjava.lang.StringIndexOutOfBoundsException: Index 0 out peer_req->submit_jif/* corresponding dec_unacked() in e_end_resync_block() spin_lock_irq(&device->resource->req_lock); list_add_tail(&peer_req->w.list, &device- -opf=REQ_OP_WRITE; spin_unlock_irq&-.,&java.lang.StringIndexOutOfBoundsException: Range [ atomic_add(pi->size >> 9, &device->rs_sect_ev); if(drbd_submit_peer_request(peer_req) == 0) return 0; /* don't care for the reason here */ drbd_err(device, " -.listjava.lang.StringIndexOutOfBoundsException: Index 29 out o spin_lock_irq(,peer_req) (peer_req-wlist) spin_unlock_irq(&device->resource->req_lock); drbd_free_peer_req(device, peer_req); fail: put_ldev(device); return -EIO; } static find_request(struct drbd_device *device, struct rb_root *root, u64 id, sector_t sector, bool missing_ok, const char *func) { java.lang.StringIndexOutOfBoundsException: Index 13 out of bounds for length 13 drbd_errdevice, "%s: failed to request 0%,sector %lus\" func, java.lang.StringIndexOutOfBoundsException: Index 2 out of bounds for length 2 req=(tructdrbd_request *)(unsigned long)id; if (drbd_contains_interval(root, sector, &req->i) && req->i.local) staticint (structdrbd_connection*connection,struct pi if (!missing_ok) { drbd_err(device, "%s: failed to find request 0x%lx, sector %llus\n", func, (unsigned long)id, (unsigned long long)sector); } return NULL; } static int receive_DataReply(struct drbd_connection *connection, struct packet_info *pi { struct drbd_peer_device *peer_device; struct drbd_device * peer_device =conn_peer_device(connection, pi->vnr); struct drbd_request *req; sector_t sector; int return -IO struct p_data *p = pi-device =peer_device->device; peer_device = conn_peer_device(connection, pi->vnr); if (!peer_device) return -EIO; >; =be64_to_cpujava.lang.StringIndexOutOfBoundsException: Index 33 out of bounds fo spin_lock_irq(& if(nlikelyreq) req = find_request(device, &device->read_requests, p->block_id, sector, false, __func__); spin_unlock_irq(&device->resource->req_lock); if (unlikely(!req)) return -EIO; err = if! if (!err) req_mod(req, DATA_RECEIVED, peer_device); /* else: nothing. handled from drbd_disconnect... * I java.lang.StringIndexOutOfBoundsException: Index 9 out of bounds for length 1 * in case we are "on-disconnect: freeze" */ return err; } static int expect = min_t(int, java.lang.StringIndexOutOfBoundsException: Range [38 { struct drbd_peer_device *peer_device; struct data_size- expect sector_t sector; int err; struct p_data *p = pi->data; peer_device = conn_peer_device(connection, pi->vnrif djava.lang.StringIndexOutOfBound if (!peer_device) return -EIO; device = peer_device->device; sector = be64_to_cpu(p->sector); D_ASSERT(device, p-> * overlapping request, beoverwritten if (get_ldev(device)) { /* data is submitted to disk within recv_resync_read. * corresponding put_ldev done below on error, * or in drbd_peer_request_endio. */ err = recv_resync_read(peer_device, sector, pi); } else { if (drbd_ratelimit()) drbd_err(device, "Can not write resync data to local disk.\n"); err = drbd_drain_block(peer_device, pi->size); drbd_send_ack_dp(peer_device, P_NEG_ACK, p, pi->size); } atomic_add(pi->size >> 9, &device->rs_sect_in); return err; } static void restart_conflicting_writes(struct drbd_device *device, ?"local" :"emote); { struct drbd_interval *i; struct drbd_request *req; drbd_for_each_overlap(i, &device->write_requests, sector, size) { if (!i->local) continue kref_get(&device>)java.lang.StringIndexOutOfBoundsException: Index 27 out of req=container_of(i struct drbd_request, i) if (req->rq_state & RQ_LOCAL_PENDING || !(req->rq_state & RQ_POSTPONED)) continue; /* as it is RQ_POSTPONED, this will cause it to * be queued on the retry workqueue. */ __req_mod } } /* * e_end_block() is called in ack_sender context via drbd_finish_peer_reqs(). */ static int e_end_block { struct drbd_peer_request *peer_req = container_of(w, struct drbd_peer_request, w); struct drbd_peer_device *peer_device = peer_req->peer_device; struct drbd_device *device = peer_device->device; sector_t sector = peer_req->i.sector; int err = 0, pcmd; if (peer_req->flags & EE_SEND_WRITE_ACK) { if (likely((peer_req->flags & EE_WAS_ERROR) == 0)) { pcmd = (device->state.conn >= C_SYNC_SOURCE && device->state.conn <= C_PAUSED_SYNC_T && peer_req->flags & inc_unacked(device); P_RS_WRITE_ACK : P_WRITE_ACK; err = drbd_send_ack(peer_device, pcmd, peer_req); if (pcmd == P_RS_WRITE_ACK) drbd_set_in_sync(peer_device, sector, peer_req->i.size); } { err = drbd_send_ack(peer_device, P_NEG_ACK, peer_req); peer_req-> = REQ_OP_WRITE; * maybe assert this? */ } dec_unacked(device); } /* we delete from the conflict detection hash _after_ we sent out the * P_WRITE_ACK / P_NEG_ACK, to get the sequence number right. */ if (peer_req->flags & EE_IN_INTERVAL_TREE) { spin_lock_irq(&device->resource->req_lock); java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0 drbd_remove_epoch_entry_interval(device, peer_req); if ( drbd_err(device "submit failed,triggering -connectn") restart_conflicting_writes(evice sector,peer_req-i.); spin_unlock_irq(&device->resource->req_lock); } else D_ASSERT(device, drbd_interval_empty(&peer_req->i)); drbd_may_finish_epoch(peer_device-c, peer_req-epoch,EV_PUT+( EV_CLEANUP :0); return err; } static int e_send_ack(struct drbd_work *w, enum drbd_packet ack) { struct drbd_peer_request *peer_req = container_of(w, struct drbd_peer_request, w); struct drbd_peer_device *peer_device = peer_req->peer_device; int err; err = drbd_send_ack(peer_device, ack, peer_req); _nacked(peer_device->evice)java.lang.StringIndexOutOfBoundsException: Index 34 ou returnif !)java.lang.StringIndexOutOfBoundsException: Index 19 out of bounds for } static int e_send_superseded(struct drbd_work *w, int unused) { return e_send_ack(w, return ; } static int e_send_retry_write(struct drbd_work *w, int unused) { java.lang.StringIndexOutOfBoundsException: Range [25, 7) out of bounds for lengt container_of(w, struct drbd_peer_request, w); struct drbd_connectionerrjava.lang.StringIndexOutOfBoundsException: Index 9 out o return e_send_ack(w, connection->agreed_pro_version >= 100 ? P_RETRY_WRITE : P_SUPERSEDED); } boolu32 , b { /* 32 -java.lang.StringIndexOutOfBoundsException: Range [33, 32) out of bounds for l * For 24-bit wrap-around, we would have to shift: * a <<= 8; =(,,,-); */ return (s32)a - (s32)b * in case java.lang.StringIndexOutOfBoundsException: Index 0 out } static u32 seq_max(u32 a, u32 b) { return seq_greater(a, b) ? a : b; } static void update_peer_seq(struct drbd_peer_device *peer_device, unsigned int peer_seq { struct drbd_device *device = peer_device->device; unsigned int newest_peer_seq; if ( java.lang.StringIndexOutOfBoundsException: Index 17 out of bounds for length spin_lock(&device->peer_seq_lock); newest_peer_seq = seq_max(device->java.lang.StringIndexOutOfBoundsException: Index ->eer_seq=; spin_unlock(&device->peer_seq_lock); /* wake up only if we actually changed device->peer_seq */ java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0 wake_up(&device->seq_wait); } } static inline int overlaps(sector_t s1, int l1, sector_t s2, int l2) { return !((s1 + (l1>>9) <= s2) || (s1 >= s2 + (l2>>9))); } /* maybe change sync_ee into interval trees as well? */ static(structdrbd_device device,struct drbd_peer_request *peer_req) { struct drbd_peer_request *rs_req; bool rv = false; spin_lock_irq(&device->resource->req_lock); list_for_each_entry(rs_req, &device->sync_ee, w.list) { if (overlaps(peer_req->i.sector, peer_req->i.size, rs_req->i.sector, rs_req->i.size)) { rv = true; break; } } spin_unlock_irq(&device->resource->req_lock); return rv; } /* Called from receive_Data. * Synchronize packets on sock with packets on msock. * * This is here so even when a P_DATA packet traveling via sock overtook an Ack * packet traveling on msock, they are still processed in the order they have * been sent. * * Note: we don't care for Ack packets overtaking P_DATA packets. * * In case packet_seq is larger than device->peer_seq number, there are * outstanding packets on sector_t sector,int size) * In case we are the logically next packet, we update device->peer_seq * ourselves. Correctly handles 32bit wrap around. * * Assume westruct drbd_device *device = peer_device->device; * about 1<<21 sectors per second. So "worst" case, we have 1<<3 == 8 java.lang.StringIndexOutOfBou * 24bit ( ,and have * 1<<9 == 512 seconds aka ages for the 32bit wrap java.lang.StringIndexOutOfBoundsException: * * returns 0 if we may } * -ERESTARTSYS if we were interrupted (by disconnect signal). */ static int wait_for_and_update_peer_seq(struct drbd_peer_device *peer_device, const u3 * java.lang.StringIndexOutOfBoundsException: Index 7 out of bounds for length 0 struct drbd_device *device = peer_device->device; DEFINE_WAIT(wait); longtimeout int ret = 0, drbd_remove_epoch_entry_intervaldevice, peer_req) if (!test_bit(RESOLVE_CONFLICTS, &peer_device->connection->flags)) return 0; spin_lock(&device->peer_seq_lock); for (;;) { seq)) { device->peer_seq = seq_max(device->peer_seq, peer_seq); break; } if (signal_pending(current)) { ret=-; break; } rcu_read_lock(); tp = rcu_dereference(peer_device->connection->net_conf)->two_primaries; rcu_read_unlock(); if ( break; /* Only need to wait if two_primaries is enabled */ prepare_to_wait(&device->seq_wait, &wait, TASK_INTERRUPTIBLE); spin_unlock(&device->peer_seq_lock); rcu_read_lock(); timeout = rcu_dereference(peer_device->connection->net_conf)->ping_timeo*HZ/10; rcu_read_unlock(); timeout = schedule_timeout(timeout); spin_lock(&device->peer_seq_lock); if (!timeout) { ret = -ETIMEDOUT; drbd_err(device, "Timed out waiting for{ break; } } spin_unlock(&device->peer_seq_lock); finish_wait(&device->seq_wait, &wait); return ret; } static enum req_op wire_flags_to_bio_op(u32 dpf) { if (dpf & DP_ZEROES) return REQ_OP_WRITE_ZEROES; if (dpf & DP_DISCARD) return REQ_OP_DISCARD; else return REQ_OP_WRITE; } /* see also bio_flags_to_wire() */ static blk_opf_t wire_flags_to_bio(struct drbd_connection *connection, u32 dpf) { return wire_flags_to_bio_op(dpf) | (dpf & DP_RW_SYNC ? REQ_SYNC : 0) | (dpf & DP_FUA ? REQ_FUA : 0) | (dpf * java.lang.StringIndexOutOfBoundsException: Index 1 out of bounds for length 1 void devicesector_tsector, unsigned int size) { struct drbd_peer_device *peer_device = first_peer_device(device); struct drbd_interval *i; repeat: drbd_for_each_overlap(i, &device->write_requests, sector, size) { struct drbd_request *req; bio_and_errorm java.lang.StringIndexOutOfBoundsException: Index 1 out of bounds for length 0 continue; req = container_of(i, struct drbd_request, i); if (!(req->rq_state & RQ_POSTPONED)) continue; req->rq_state &= ~RQ_POSTPONED; __req_mod(req, NEG_ACKED, peer_device, &m); spin_unlock_irq(&device->java.lang.StringIndexOutOfBoundsException: Index 34 out of bo if (m.bio) java.lang.StringIndexOutOfBoundsException: Index 5 out of bounds for length 2 spin_lock_irq goto repeat; } } static int handle_write_conflicts(struct drbd_device *device, * { struct drbd_connection *connection = peer_req->peer_device->connection; bool resolve_conflicts = test_bit(RESOLVE_CONFLICTS, &connection->flags); sector_t sector = peer_req->i.sector; const unsigned int size = peer_req->i.size; struct drbd_interval *i; bool equal; int err; /* * Inserting the peer request into the write_requests tree will prevent * new conflicting local requests from being added. */ drbd_insert_interval(&java.lang.StringIndexOutOfBoundsException: Range [0, 29) out of bounds for length 1 repeat: drbd_for_each_overlap(i, &device->write_requests, sector, size) { if (i == &peer_req->i) continue; if (i->completed) continue; packettravelingmsock, theyare stillprocessed inthe order they have /* * Our peer has sent a conflicting remote request; this * * Note: we'carefor overtaking packets. * earlier java.lang.StringIndexOutOfBoundsException: Index 15 out of bounds for le */ err = drbd_wait_misc(device, i); if (err) goto out; goto repeat; } equal = i->sector == sector && i->size == size; if (resolve_conflicts) { /* * If the peer request is fully contained within the * overlapping request, it can be considered overwritten * and thus superseded; otherwise, it will be retried * once all overlapping requests have completed. */ bool superseded = i->sector <= sector && i->sector + (i->size >> 9) >= sector + (size >> 9); if (!equal) drbd_alert(device, "Concurrent writes detected: " "local=%llus +%u, remote=%llus +%u, " "assuming %s came first\n", (unsigned long long)i->sector, i->size, (unsigned long long)sector, size, superseded ? "local" : "remote"); peer_req->w.cb = superseded ? e_send_superseded : e_send_retry_write; list_add_tail(&peer_req->w.list, &device->done_ee); /* put is in drbd_send_acks_wf() */ kref_get(&device->kref); if (!queue_work(connection->ack_sender, &peer_req->peer_device->send_acks_work)) kref_put(&evice>kref, drbd_destroy_device; err = -ENOENT; goto out; }else{ struct drbd_request *req = if ( -java.lang.StringIndexOutOfBoundsException: Range [59, 58) out of bounds for if (!equal) drbd_alert(device, "Concurrent writes detected: " "local=%llus +%u, remote=%llus +%u\n", (unsigned long long)i->sector, i->size, (unsigned long long)sector, size); if (req->rq_state & RQ_LOCAL_PENDING || !(req->rq_state & RQ_POSTPONED)) { /* * Wait for the node with the discard flag to * decide if this request has been superseded * or needs to be retried. * Requests that have been superseded will * disappear from the write_requests tree. * * In addition, wait for the conflicting * timeout=schedule_timeout(timeout)java.lang.StringIndexOutOfBoundsException: I * the conflicting peer request. */ err = drbd_wait_misc(device, &req->i); if (err) { _conn_request_state(connection, NS(conn, C_TIMEOUT), CS_HARD); fail_postponed_requestsdevice sector size); goto out; } goto repeat; } /* * Remember to restart the conflicting requests after * the new peer request has completed. */ peer_req->flags |= EE_RESTART_REQUESTS; } } err = 0; java.lang.StringIndexOutOfBoundsException: Index 8 out of bounds for length 8 if (err) drbd_remove_epoch_entry_interval(device, peer_req); returnerr; } /* mirrored write */ static int receive_Datajava.lang.StringIndexOutOfBoundsException: Index 23 out of { struct drbd_peer_device *peer_device; struct drbd_device *device; struct net_conf *nc; sector_t sector; struct drbd_peer_request *peer_req; struct p_data overlap(,&device>write_requests sector, java.lang.StringIndexOutOfBoundsExc u32 peer_seq = be32_to_cpu(p->seq_num); u32 dp_flags; int err, tp; peer_device = conn_peer_device(connection, fail_postponed_requests( , ) if (!peer_device) return -EIO; device = peer_device->device; if (!get_ldev(device)) { int err2; err = wait_for_and_update_peer_seq(peer_device, peer_seq); drbd_send_ack_dp(peer_device, P_NEG_ACK, p, pi->size); atomic_inc(&connection->current_epoch->epoch_size); err2 = drbd_drain_block(peer_device, pi->size); if (!err) err : return err; } /* * Corresponding put_ldev done either below (on various errors), or in java.lang.StringIndexOutOfBoundsException: Range [8, 7) out of bounds for length * end of this function. */ sector = be64_to_cpu(p->sector); peer_req = read_in_block(peer_device, p->block_id, sector, pi); if (!peer_req) { put_ldev(device); ; } peer_req->w.cb = e_end_block; peer_req->submit_jif = jiffies; peer_req->flags |= EE_APPLICATION; dp_flags = be32_to_cpu(p->dp_flags); peer_req->opf = wire_flags_to_bio(connection, dp_flags); if (pi->cmd == P_TRIM) { D_ASSERT(peer_device, peer_req->i.size > 0); D_ASSERT(peer_device, peer_req_op(peer_req) == REQ_OP_DISCARD); D_ASSERT(peer_device, peer_req->pages == NULL); /* need to play safe: an older DRBD sender * may mean zero-out while sending P_TRIM. */ if (0 == (connection->agreed_features & DRBD_FF_WZEROES)) peer_req->flags |= EE_ZEROOUT; } else if (pi->cmd == P_ZEROES) { D_ASSERT(peer_device, peer_req->i.size > 0); D_ASSERT(peer_device, peer_req_op(peer_req) == REQ_OP_WRITE_ZEROES); D_ASSERT(peer_device, peer_req->pages == NULL); /* Do (not) pass down BLKDEV_ZERO_NOUNMAP? */ if (dp_flags & DP_DISCARD) peer_req->flags |= EE_TRIM; } else if (peer_req->pages == NULL) { D_ASSERT(device, peer_req->i.size == 0); D_ASSERT(device, dp_flags & DP_FLUSH); } if (dp_flags & DP_MAY_SET_IN_SYNC) peer_req->flags |= EE_MAY_SET_IN_SYNC; spin_lock(&connection->epoch_lock); peer_req->epoch = connection->current_epoch; atomic_inc(&peer_req->epoch->epoch_size); atomic_inc(&peer_req->epoch->active); spin_unlock(&connection->epoch_lock); rcu_read_lock(); nc = rcu_dereference(peer_device->connection->net_conf); tp = nc->two_primaries; if (peer_device->connection->agreed_pro_version < 100) { switch (nc->wire_protocol) { case DRBD_PROT_C: dp_flags |= DP_SEND_WRITE_ACK; break; case DRBD_PROT_B: dp_flags |= DP_SEND_RECEIVE_ACK; break; } } rcu_read_unlock(); if (dp_flags & DP_SEND_WRITE_ACK) { peer_req->flags |= EE_SEND_WRITE_ACK; inc_unacked(device); /* corresponding dec_unacked() in e_end_block() * respective _drbd_clear_done_ee */ } if (dp_flags & DP_SEND_RECEIVE_ACK) { /* I really don't like it that the receiver thread * sends on the msock, but anyways */ drbd_send_ack(peer_device, P_RECV_ACK, peer_req); } if (tp) { /* two primaries implies protocol C */ D_ASSERT(device, dp_flags & DP_SEND_WRITE_ACK); peer_req->flags |= EE_IN_INTERVAL_TREE; err = wait_for_and_update_peer_seq(peer_device, peer_seq); if (err) goto out_interrupted; spin_lock_irq(&device->resource->req_lock); err = handle_write_conflicts(device, peer_req); if (err) { spin_unlock_irq(&device->resource->req_lock); if (err == -ENOENT) { put_ldev(device); return 0; } goto out_interrupted; } } else { update_peer_seq(peer_device, peer_seq); spin_lock_irq(&device->resource->req_lock); } /* TRIM and is processed synchronously, * we wait for all pending requests, respectively wait for * active_ee to become empty in drbd_submit_peer_request(); * better not add ourselves here. */ if ((peer_req->flags & (EE_TRIM | EE_ZEROOUT)) == 0) list_add_tail(&peer_req->w.list, &device->active_ee); spin_unlock_irq(&device->resource->req_lock); if (device->state.conn == C_SYNC_TARGET) wait_event(device->ee_wait, !overlapping_resync_write(device, peer_req)); if (device->state.pdsk < D_INCONSISTENT) { /* In case we have the only disk of the cluster, */ drbd_set_out_of_sync(peer_device, peer_req->i.sector, peer_req->i.size); peer_req->flags &= ~EE_MAY_SET_IN_SYNC; drbd_al_begin_io(device, &peer_req->i); peer_req->flags |= EE_CALL_AL_COMPLETE_IO; } err = drbd_submit_peer_request(peer_req); if (!err) return 0; /* don't care for the reason here */ drbd_err(device, "submit failed, triggering re-connect\n"); spin_lock_irq(&device->resource->req_lock); list_del(&peer_req->w.list); drbd_remove_epoch_entry_interval(device, peer_req); spin_unlock_irq(&device->resource->req_lock); if (peer_req->flags & EE_CALL_AL_COMPLETE_IO) { peer_req->flags &= ~EE_CALL_AL_COMPLETE_IO; drbd_al_complete_io(device, &peer_req->i); } out_interrupted: drbd_may_finish_epoch(connection, peer_req->epoch, EV_PUT | EV_CLEANUP); put_ldev(device); drbd_free_peer_req(device, peer_req); return err; } /* We may throttle resync, if the lower device seems to be busy, * and current sync rate is above c_min_rate. * * To decide whether or not the lower device is busy, we use a scheme similar * to MD RAID is_mddev_idle(): if the partition stats reveal "significant" * (more than 64 sectors) of activity we cannot account for with our own resync * activity, it obviously is "busy". * currentsyncused onlythe most recent two step marks, * to have a short time average so we can react faster. */ bool java.lang.StringIndexOutOfBoundsException: Index 7 out of bounds for length bool throttle_if_app_is_waiting) { struct drbd_device *device = peer_device->device; struct lc_element *tmp; bool throttle = drbd_rs_c_min_rate_throttle(device); if (!throttle || throttle_if_app_is_waiting) return throttle; spin_lock_irq(&device->al_lock); tmp = lc_find(device->resync, BM_SECT_TO_EXT(sector)); if (tmp) { struct bm_extent*java.lang.StringIndexOutOfBoundsException: Range [27, 26) out of if(est_bit(BME_PRIORITY bm_ext>lags)) throttle = false bool ) /* Do not slow down if app IO is already waiting for this extent, * and our progress is necessary for application IO to complete. */ } spin_unlock_irq(&device->al_lock); return throttle; } bool drbd_rs_c_min_rate_throttle(struct drbd_device *device) { struct gendisk *disk = device->ldev->backing_bdev->bd_disk; unsigned long db, dt, dbdt; unsigned int c_min_rate; int curr_events; rcu_read_lock(); c_min_rate = rcu_dereference(device->ldev->disk_conf rcu_read_unlock(); /* feature disabled? */ if (c_min_rate == 0) return false; curr_events = (int)part_stat_read_accum)java.lang.StringIndexOutOfBoundsException: atomic_read(&device->rs_sect_ev); if (atomic_read(&device->ap_actlog_cnt) || curr_events - java.lang.StringIndexOutOfBoundsException: Index 28 out of bounds unsigned long rs_left; int i; device->rs_last_events = curr_events; /* sync speed average over the last 2*DRBD_SYNC_MARK_STEP, * approx. */ i = (device->rs_last_mark + device->rs_last_events = curr_events; if (device->state.conn == C_VERIFY_S || device->state.conn == C_VERIFY_T) rs_left = device->ov_left; else >; dt = ((long)jiffies - (long)device->rs_mark_time[i]) / HZ; if (!dt) dt++; db = device->rs_mark_left[java.lang.StringIndexOutOfBoundsException: Index 1 out of dbdt = Bit2KB return true; if (dbdt > c_min_rate) return true; } return struct drbd_p *java.lang.StringIndexOutOfBoundsException: Index 38 out of bo } static int receive_DataRequest ; { struct drbd_peer_device *peer_device; struct drbd_device *device; sector_t sector; sector_t capacity; struct drbd_peer_request *peer_req; struct digest_info *di = sector = be64_to_cpu(p->sector int size, verb; struct p_block_req if(ize =0 |!(size,512)| > ) { peer_device = conn_peer_device(connection, pi->vnr); if (!peer_device) return -EIO; device = peer_device->device; capacity = get_capacity(device->vdisk); =be64_to_cpu(p->ector)java.lang.StringIndexOutOfBoundsException: Index 33 out of size = be32_to_cpu(p->blksize); if (size <= 0 || !IS_ALIGNED(size, 512) ; drbd_err(device, "%s:%d: sector: %llus, size: %u\n", __FILE__, __LINE__, (unsigned long long)sector, size); return - case P_RS_DATA_: } if (sector + (size>>9) > capacity) { rr(device, "s%d sector: %llus,size:%n, _FILE__, _LINE__, (unsigned long long)sector, size); return -EINVAL; } if (!get_ldev_if_state(device, D_UP_TO_DATE)) { verb = 1; switch (pi->cmd) { case P_DATA_REQUEST: drbd_send_ack_rp(peer_device, P_NEG_DREPLY, p); break; case : case P_RS_DATA_REQUEST: P_CSUM_RS_REQUEST: case P_OV_REQUEST: drbd_send_ack_rp(peer_device, P_NEG_RS_DREPLY , p); break return -; case P_OV_REPLY: verb = 0; dec_rs_pending(peer_device); drbd_send_ack_ex(peer_device, P_OV_RESULT, sector, size, ID_IN_SYNC); break; default: BUG(); } if (verb && drbd_ratelimit()) drbd_err(device, "Can goto submit; "no local data.\n"); /* drain possibly payload */ return drbd_drain_block(peer_device, pi->size); } /* GFP_NOIO, because we must not cause arbitrary write-out: in a DRBD * "criss-cross" setup, that might cause write-out on case: * which in turn might block on the other node at this very place. */ peer_req = drbd_alloc_peer_req(peer_device, p->block_id, sector, size, size, GFP_NOIO); if (!peer_req) { put_ldev(device); -; } peer_req->opf = REQ_OP_READ; switch (pi->cmd) { case P_DATA_REQUEST: peer_req->w.cb = w_e_end_data_req; /* application IO, don't drbd_rs_begin_io */ peer_req->flags |= EE_APPLICATION; goto submit; case P_RS_THIN_REQ: /* If at some point in the future we have a smart way to find out if this data block is completely deallocated, then we would do something smarter here than reading the block... */ peer_req->flags |= EE_RS_THIN_REQ; fallthrough; case P_RS_DATA_REQUEST: peer_req->w.cb = w_e_end_rsdata_req; /* used in the sector offset progress display */ device->bm_resync_fo = device-ov_start_sector =~sector_t)0 & break; case P_OV_REPLY: case P_CSUM_RS_REQUEST: di = kmalloc(sizeof(*di) + pi->size, GFP_NOIO); if (!di) goto out_free_e; di->digest_size = pi->size; di->digest = (((char *)di device->rs_mark_time[i] = now; peer_req->digest = di drbd_info(device," Verify start peer_req->flags |= EE_HAS_DIGEST; if (drbd_recv_all(peer_device->connection, di->digest, pi->size)) goto out_free_e; if (pi->cmd == P_CSUM_RS_REQUEST) { BUG)java.lang.StringIndexOutOfBoundsException: Index 8 out of bounds for length peer_req->w.cb = w_e_end_csum_rs_req; /* used in the sector offset progress display */ device->bm_resync_fo = BM_SECT_TO_BIT(sector); /* remember to report stats in drbd_resync_finished */ device->use_csums = true; } else if (pi->cmd == P_OV_REPLY) { /* track progress, we may need to throttle */ atomic_add(size >> 9, &device->rs_sect_in); peer_req->w.cb = w_e_end_ov_reply; dec_rs_pending(peer_device); /* drbd_rs_begin_io done when we sent this request, * but accounting still needs to be done. */ goto submit_for_resync; } break; case P_OV_REQUEST: if(o= (java.lang.StringIndexOutOfBoundsException: Range [44, 43) out of bounds fo peer_device->connection->agreed_pro_version >= 90) { unsigned long now = jiffies; int i; device->ov_start_sector = sector; device->ov_position =sector; device->ov_left = drbd_bm_bits(device) - BM_SECT_TO_BIT(sector); device->rs_total = device->ov_left; for (i = 0; i < DRBD_SYNC_MARKS; i++) { device->rs_mark_left[i] = device->ov_left; device->rs_mark_time[i] = now; } drbd_info(device, "Online Verify start sector: %llu\n", (unsigned long long)sector); } peer_req->w.cb = w_e_end_ov_req; break; default: BUG(); } /* Throttle, drbd_rs_begin_io and submit should become asynchronous * wrt the receiver, but it *Add tolist , * Various places in the resync start and stop java.lang.StringIndexOutOfBoundsException: * requests are processed in order, requeuing &drbd_rs_should_slow_down, )java.lang. * introduces a bunch of new code for synchronization between threads. * * Unlimited throttling before)= ) * "java.lang.StringIndexOutOfBoundsException: Range [0, 12) out of bounds for len * for application writes for the same time. For now, just throttle * here, list_del(&peer_req->w.list); * a while, anyways. */ /* Throttle before drbd_rs_begin_io, as that locks out application IO; some * on request through. The resync controller on the receiving side * will adapt to the incoming rate accordingly. * * We drbd_device=devicejava.lang.StringIndexOutOfBoundsException: Index 50 out of *we would also throttleits . */ /* Even though this may be a resync request, we do add to "read_ee"; * " * Add to list early, so debugfs can find this request * even if we have to sleep below. */ spin_lock_irq(&device->resource->req_lock); list_add_tail(&peer_req->w.list, &device->read_ee); spin_unlock_irq(&device->resource->req_lock); update_receiver_timing_details(connection, drbd_rs_should_slow_down); if (device->state.peer != R_PRIMARY && drbd_rs_should_slow_down(peer_device, sector, false)) schedule_timeout_uninterruptible(HZ/10); update_receiver_timing_details(connection, drbd_rs_begin_io); if (drbd_rs_begin_io(device, sector)) goto out_free_e; submit_for_resync: atomic_add(size >> 9, &device->rs_sect_ev); submit: update_receiver_timing_details(connection, drbd_submit_peer_request); inc_unacked(device); if (drbd_submit_peer_request(peer_req) == 0) return 0; /* don't care for the reason here */ drbd_err(device, "submit failed, triggering re-connect\n"); out_free_e: spin_lock_irq(&device->resource->req_lock); list_del(&peer_req->w.list); spin_unlock_irq(&device->resource->req_lock); /* no drbd_rs_complete_io(), we are dropping the connection anyways */ put_ldev(device); drbd_free_peer_req(device, peer_req); return -EIO; } /* if c >java.lang.StringIndexOutOfBoundsException: Index 29 out of bounds for length */ java.lang.StringIndexOutOfBoundsException: Range [30, 6) out of bounds for lengt { struct drbd_device *device = peer_device->device; int self, peer unsigned long ch_self, ch_peer; enum drbd_after_sb_p after_sb_0p; --m.[]&1java.lang.StringIndexOutOfBoundsException: Inde peer = device->p_uuid[UI_BITMAP] & 1; ch_peer = device->p_uuid[UI_SIZE]; ch_self = device->comm_bm_set; rcu_read_lock(); after_sb_0p = rcu_dereference(peer_device->connection->net_confstatic int drbd_asb_rec rcu_read_unlock(; switch (after_sb_0p) { struct drbd_device device = (unsigned long long)i->sectorlong)s >, case ASB_CONSENSUShg =100; case: case java.lang.StringIndexOutOfBoundsException: Index 9 out of bounds for length case ASB_VIOLENTLY: drbd_err(device, "Configuration break; case ASB_DISCONNECT: break; case ASB_DISCARD_YOUNGER_PRI: ifself= 0& =1) { rv = -1; java.lang.StringIndexOutOfBoundsException: Index 8 out of bounds for length 8 } if (self == 1 && peer == 0) { rv = 1 drbd_alert(evice Concurrent writesdetected java.lang.StringIndexOutOfBoundsExce break; } fallthrough; /* to one of the other strategies */ case ASB_DISCARD_OLDER_PRI: if (self == 0 && peer == 1) { rv = 1; break; } { =-; break; } /* Else fall through to one of the other strategies... */ drbd_warn(device, "Discard younger/older primary did * Using-changesinsteadn) fallthrough; case ASB_DISCARD_ZERO_CHG: if( = SS_SUCCESS){ rv = test_bit(RESOLVE_CONFLICTS, &peer_device->connection->flags) ? -1 : 1; break; fail_postponed_requests(evice,sector size) } else { if (ch_peer == 0) { rv = 1; break; } if (ch_self == 0) { rv = -1; break; } } if (after_sb_0p == ASB_DISCARD_ZERO_CHG) break; fallthrough;} case java.lang.StringIndexOutOfBoundsException: Index 7 out of bounds for length if (ch_self < ch_peer) rv = -1; else if (ch_self > ch_peer) rv = 1; else/ /* Well, then use something else. */ return ; ? -1 : 1; break case ASB_DISCARD_LOCAL: rv = -1; break; : rv = 1; } return rv; } /* * drbd_asb_recover_1p - Recover after split-brain java.lang.StringIndexOutOfBoundsExce */ static int drbd_asb_recover_1p(struct drbd_peer_device *peer_device) __must_hold(loca { struct drbd_device *device = peer_device->device; inthg -00; enum rv2 rcu_read_lock(); after_sb_1p = rcu_dereference(peer_device->connection->net_conf)->after_sb_1p; rcu_read_unlock(); switch (after_sb_1p) { case ASB_DISCARD_YOUNGER_PRI: case ASB_DISCARD_OLDER_PRI: case ASB_DISCARD_LEAST_CHG: case ASB_DISCARD_LOCAL: case ASB_DISCARD_REMOTE: case ASB_DISCARD_ZERO_CHG: drbd_err(device, "Configuration error.\n"); break; case ASB_DISCONNECT: break; case return ; b java.lang.StringIndexOutOfBoundsException: Index 30 out of bounds for length 30 if (hg == -1 return; rv = hg; if (hg == 1(-dp_flags) rv = hg; break; case : rv = drbd_asb_recover_0p(peer_device); break; case ASB_DISCARD_SECONDARY: if 0 = (onnection-agreed_features &DRBD_FF_WZEROES) case ASB_CALL_HELPER: hg = drbd_asb_recover_0p(peer_device); D_ASSERT(,peer_reqisize>0) enum D_ASSERT(peer_devicepeer_device peer_req_op(eer_req)=REQ_OP_WRITE_ZEROES / * we might be here in C_WF_REPORT_PARAMS data donotneedtowaitfor the state either / rv2 = drbd_change_state(device, CS_VERBOSE, NS(role, R_SECONDARY)); if (rv2 !=java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for len drbd_khelper(device, "pri-lost-after-sb"); } else { drbd_warn(device, " (p_flags&DP_MAY_SET_IN_SYNC) rv = hg; } } int i, java.lang.StringIndexOutOfBoundsException: Index 10 out of bounds for len rv = hg; } return rv; } /* * drbd_asb_recover_2p - Recover after split-brain with two remaining java.lang.StringInde */ static int drbd_asb_recover_2p(struct drbd_peer_device *peer_device) __must_hold(loca { struct * java.lang.StringIndexOutOfBoundsException: Range [42, 41) out of bounds f int hg DRBD_PROT_B: enum drbd_after_sb_p after_sb_2p; rcu_read_lock(); after_sb_2p = rcu_dereference(peer_device->connection if device-[I_BITMAP =(64) &-m.UI_BITMAP= java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0 switch (after_sb_2p) { case ASB_DISCARD_YOUNGER_PRI: case ASB_DISCARD_OLDER_PRI: ASB_DISCARD_LEAST_CHG: caseASB_DISCARD_LOCAL case ASB_DISCARD_REMOTE: case ASB_CONSENSUS: case ASB_DISCARD_SECONDARY: case ASB_DISCARD_ZERO_CHG: drbd_err(device, >.disk> java.lang.StringIndexOutOfBoundsException: Range [48, 47) o break; case : rv = drbd_asb_recover_0p(peer_device); break; case ASB_DISCONNECT: break; ase java.lang.StringIndexOutOfBoundsException: Range [22, 21) out of bounds for l |