]> git.karo-electronics.de Git - karo-tx-linux.git/commitdiff
drbd: Convert all constants in enum drbd_thread_state to upper case
authorAndreas Gruenbacher <agruen@linbit.com>
Tue, 25 Jan 2011 14:43:39 +0000 (15:43 +0100)
committerPhilipp Reisner <philipp.reisner@linbit.com>
Mon, 29 Aug 2011 09:26:56 +0000 (11:26 +0200)
Signed-off-by: Philipp Reisner <philipp.reisner@linbit.com>
Signed-off-by: Lars Ellenberg <lars.ellenberg@linbit.com>
drivers/block/drbd/drbd_int.h
drivers/block/drbd/drbd_main.c
drivers/block/drbd/drbd_receiver.c
drivers/block/drbd/drbd_worker.c

index 6099c667b634818dfa7273c4eea0c64742707fcc..1cf9c0954906f1779a18853729fa51c6f3a248dd 100644 (file)
@@ -649,10 +649,10 @@ union p_polymorph {
 
 /**********************************************************************/
 enum drbd_thread_state {
-       None,
-       Running,
-       Exiting,
-       Restarting
+       NONE,
+       RUNNING,
+       EXITING,
+       RESTARTING
 };
 
 struct drbd_thread {
index c5bb87143347817ae1f479b09b08051f409fed09..19176a149ac7fee58dbf63c6dd2f6b96406e241c 100644 (file)
@@ -1627,25 +1627,25 @@ restart:
 
        spin_lock_irqsave(&thi->t_lock, flags);
 
-       /* if the receiver has been "Exiting", the last thing it did
+       /* if the receiver has been "EXITING", the last thing it did
         * was set the conn state to "StandAlone",
         * if now a re-connect request comes in, conn state goes C_UNCONNECTED,
         * and receiver thread will be "started".
-        * drbd_thread_start needs to set "Restarting" in that case.
+        * drbd_thread_start needs to set "RESTARTING" in that case.
         * t_state check and assignment needs to be within the same spinlock,
-        * so either thread_start sees Exiting, and can remap to Restarting,
-        * or thread_start see None, and can proceed as normal.
+        * so either thread_start sees EXITING, and can remap to RESTARTING,
+        * or thread_start see NONE, and can proceed as normal.
         */
 
-       if (thi->t_state == Restarting) {
+       if (thi->t_state == RESTARTING) {
                dev_info(DEV, "Restarting %s\n", current->comm);
-               thi->t_state = Running;
+               thi->t_state = RUNNING;
                spin_unlock_irqrestore(&thi->t_lock, flags);
                goto restart;
        }
 
        thi->task = NULL;
-       thi->t_state = None;
+       thi->t_state = NONE;
        smp_mb();
        complete(&thi->stop);
        spin_unlock_irqrestore(&thi->t_lock, flags);
@@ -1662,7 +1662,7 @@ static void drbd_thread_init(struct drbd_conf *mdev, struct drbd_thread *thi,
 {
        spin_lock_init(&thi->t_lock);
        thi->task    = NULL;
-       thi->t_state = None;
+       thi->t_state = NONE;
        thi->function = func;
        thi->mdev = mdev;
 }
@@ -1683,7 +1683,7 @@ int drbd_thread_start(struct drbd_thread *thi)
        spin_lock_irqsave(&thi->t_lock, flags);
 
        switch (thi->t_state) {
-       case None:
+       case NONE:
                dev_info(DEV, "Starting %s thread (from %s [%d])\n",
                                me, current->comm, current->pid);
 
@@ -1697,7 +1697,7 @@ int drbd_thread_start(struct drbd_thread *thi)
                init_completion(&thi->stop);
                D_ASSERT(thi->task == NULL);
                thi->reset_cpu_mask = 1;
-               thi->t_state = Running;
+               thi->t_state = RUNNING;
                spin_unlock_irqrestore(&thi->t_lock, flags);
                flush_signals(current); /* otherw. may get -ERESTARTNOINTR */
 
@@ -1712,17 +1712,17 @@ int drbd_thread_start(struct drbd_thread *thi)
                }
                spin_lock_irqsave(&thi->t_lock, flags);
                thi->task = nt;
-               thi->t_state = Running;
+               thi->t_state = RUNNING;
                spin_unlock_irqrestore(&thi->t_lock, flags);
                wake_up_process(nt);
                break;
-       case Exiting:
-               thi->t_state = Restarting;
+       case EXITING:
+               thi->t_state = RESTARTING;
                dev_info(DEV, "Restarting %s thread (from %s [%d])\n",
                                me, current->comm, current->pid);
                /* fall through */
-       case Running:
-       case Restarting:
+       case RUNNING:
+       case RESTARTING:
        default:
                spin_unlock_irqrestore(&thi->t_lock, flags);
                break;
@@ -1736,12 +1736,12 @@ void _drbd_thread_stop(struct drbd_thread *thi, int restart, int wait)
 {
        unsigned long flags;
 
-       enum drbd_thread_state ns = restart ? Restarting : Exiting;
+       enum drbd_thread_state ns = restart ? RESTARTING : EXITING;
 
        /* may be called from state engine, holding the req lock irqsave */
        spin_lock_irqsave(&thi->t_lock, flags);
 
-       if (thi->t_state == None) {
+       if (thi->t_state == NONE) {
                spin_unlock_irqrestore(&thi->t_lock, flags);
                if (restart)
                        drbd_thread_start(thi);
@@ -2504,7 +2504,7 @@ static int we_should_drop_the_connection(struct drbd_conf *mdev, struct socket *
 
        drop_it =   mdev->meta.socket == sock
                || !mdev->asender.task
-               || get_t_state(&mdev->asender) != Running
+               || get_t_state(&mdev->asender) != RUNNING
                || mdev->state.conn < C_CONNECTED;
 
        if (drop_it)
@@ -3046,7 +3046,7 @@ void drbd_init_set_defaults(struct drbd_conf *mdev)
 void drbd_mdev_cleanup(struct drbd_conf *mdev)
 {
        int i;
-       if (mdev->receiver.t_state != None)
+       if (mdev->receiver.t_state != NONE)
                dev_err(DEV, "ASSERT FAILED: receiver t_state == %d expected 0.\n",
                                mdev->receiver.t_state);
 
index 1762ef0375e1b511ecffd91789c5e21dfbb36bad..1cfcc44fd4841d60578e80750e1ecfd74920b538 100644 (file)
@@ -833,7 +833,7 @@ retry:
                if (signal_pending(current)) {
                        flush_signals(current);
                        smp_rmb();
-                       if (get_t_state(&mdev->receiver) == Exiting)
+                       if (get_t_state(&mdev->receiver) == EXITING)
                                goto out_release_sockets;
                }
 
@@ -3700,7 +3700,7 @@ static void drbdd(struct drbd_conf *mdev)
        size_t shs; /* sub header size */
        int rv;
 
-       while (get_t_state(&mdev->receiver) == Running) {
+       while (get_t_state(&mdev->receiver) == RUNNING) {
                drbd_thread_current_set_cpu(mdev);
                if (!drbd_recv_header(mdev, &cmd, &packet_size))
                        goto err_out;
@@ -4490,7 +4490,7 @@ int drbd_asender(struct drbd_thread *thi)
        current->policy = SCHED_RR;  /* Make this a realtime task! */
        current->rt_priority = 2;    /* more important than all other tasks */
 
-       while (get_t_state(thi) == Running) {
+       while (get_t_state(thi) == RUNNING) {
                drbd_thread_current_set_cpu(mdev);
                if (test_and_clear_bit(SEND_PING, &mdev->flags)) {
                        ERR_IF(!drbd_send_ping(mdev)) goto reconnect;
index 550617b1a39c65455fbbca41561e5f93ae53966e..c2a9285afad646212b07fb50b84935c937915af6 100644 (file)
@@ -1617,7 +1617,7 @@ int drbd_worker(struct drbd_thread *thi)
 
        sprintf(current->comm, "drbd%d_worker", mdev_to_minor(mdev));
 
-       while (get_t_state(thi) == Running) {
+       while (get_t_state(thi) == RUNNING) {
                drbd_thread_current_set_cpu(mdev);
 
                if (down_trylock(&mdev->data.work.s)) {
@@ -1637,12 +1637,12 @@ int drbd_worker(struct drbd_thread *thi)
                if (intr) {
                        D_ASSERT(intr == -EINTR);
                        flush_signals(current);
-                       ERR_IF (get_t_state(thi) == Running)
+                       ERR_IF (get_t_state(thi) == RUNNING)
                                continue;
                        break;
                }
 
-               if (get_t_state(thi) != Running)
+               if (get_t_state(thi) != RUNNING)
                        break;
                /* With this break, we have done a down() but not consumed
                   the entry from the list. The cleanup code takes care of
@@ -1704,7 +1704,7 @@ int drbd_worker(struct drbd_thread *thi)
 
        D_ASSERT(mdev->state.disk == D_DISKLESS && mdev->state.conn == C_STANDALONE);
        /* _drbd_set_state only uses stop_nowait.
-        * wait here for the Exiting receiver. */
+        * wait here for the EXITING receiver. */
        drbd_thread_stop(&mdev->receiver);
        drbd_mdev_cleanup(mdev);