Форум программистов [Powered by Invision Power Board]

Код

static int try_atomic_semop (struct sem_array * sma, struct sembuf * sops,
340                              int nsops, struct sem_undo *un, int pid)
341 {
342         int result, sem_op;
343         struct sembuf *sop;
344         struct sem * curr;
345 
346         for (sop = sops; sop < sops + nsops; sop++) { /* проходим по всем операциям */
347                 curr = sma->sem_base + sop->sem_num; /* получаем семафор по номеру из операции */
348                 sem_op = sop->sem_op; /* операция над семафором */
349                 result = curr->semval; /* текущее значение семафора */
350   
351                 if (!sem_op && result) /* наш случай: операция = 0, значение != 0 */
352                         goto would_block; /* переход (см. ниже) */
353 
354                 result += sem_op; /* операция над семафором */
355                 if (result < 0)
356                         goto would_block;
357                 if (result > SEMVMX)
358                         goto out_of_range;
359                 if (sop->sem_flg & SEM_UNDO) {
360                         int undo = un->semadj[sop->sem_num] - sem_op;
361                         /*
362                          *      Exceeding the undo range is an error.
363                          */
364                         if (undo < (-SEMAEM - 1) || undo > SEMAEM)
365                                 goto out_of_range;
366                 }
367                 curr->semval = result;
368         }
369 
370         sop--;
371         while (sop >= sops) {
372                 sma->sem_base[sop->sem_num].sempid = pid;
373                 if (sop->sem_flg & SEM_UNDO)
374                         un->semadj[sop->sem_num] -= sop->sem_op;
375                 sop--;
376         }
377         
378         sma->sem_otime = get_seconds();
379         return 0;
380 
381 out_of_range:
382         result = -ERANGE;
383         goto undo;
384 
385 would_block:
386         if (sop->sem_flg & IPC_NOWAIT) /* наш случай: установка EAGAIN в качестве возвращаемого значения */
387                 result = -EAGAIN;
388         else
389                 result = 1;
390 
391 undo: /* откат */
392         sop--; /* текущая операция не выполнилась, поэтому начинаем откат с последней выполнившейся операции */
393         while (sop >= sops) { /* находим все семафоры, над которыми уже были произведены операции */
394                 sma->sem_base[sop->sem_num].semval -= sop->sem_op; /* собственно откат, т. е обратное действие по отношению к действию в строке 354 */
395                 sop--;
396         }
397 
398         return result;
399 }