JDPHUFF.c
上传用户:qiutianh
上传日期:2022-08-08
资源大小:939k
文件大小:21k
源码类别:

图形图象

开发平台:

Visual C++

  1. ////////////////////////////////////////////////////////////////////////
  2. //
  3. // Note : this file is included as part of the Smaller Animals Software
  4. // JpegFile package. Though this file has not been modified from it's 
  5. // original IJG 6a form, it is not the responsibility on the Independent
  6. // JPEG Group to answer questions regarding this code.
  7. //
  8. // Any questions you have about this code should be addressed to :
  9. //
  10. // CHRISDL@PAGESZ.NET - the distributor of this package.
  11. //
  12. // Remember, by including this code in the JpegFile package, Smaller 
  13. // Animals Software assumes all responsibilities for answering questions
  14. // about it. If we (SA Software) can't answer your questions ourselves, we 
  15. // will direct you to people who can.
  16. //
  17. // Thanks, CDL.
  18. //
  19. ////////////////////////////////////////////////////////////////////////
  20. /*
  21.  * jdphuff.c
  22.  *
  23.  * Copyright (C) 1995-1996, Thomas G. Lane.
  24.  * This file is part of the Independent JPEG Group's software.
  25.  * For conditions of distribution and use, see the accompanying README file.
  26.  *
  27.  * This file contains Huffman entropy decoding routines for progressive JPEG.
  28.  *
  29.  * Much of the complexity here has to do with supporting input suspension.
  30.  * If the data source module demands suspension, we want to be able to back
  31.  * up to the start of the current MCU.  To do this, we copy state variables
  32.  * into local working storage, and update them back to the permanent
  33.  * storage only upon successful completion of an MCU.
  34.  */
  35. #define JPEG_INTERNALS
  36. #include "jinclude.h"
  37. #include "jpeglib.h"
  38. #include "jdhuff.h" /* Declarations shared with jdhuff.c */
  39. #ifdef D_PROGRESSIVE_SUPPORTED
  40. /*
  41.  * Expanded entropy decoder object for progressive Huffman decoding.
  42.  *
  43.  * The savable_state subrecord contains fields that change within an MCU,
  44.  * but must not be updated permanently until we complete the MCU.
  45.  */
  46. typedef struct {
  47.   unsigned int EOBRUN; /* remaining EOBs in EOBRUN */
  48.   int last_dc_val[MAX_COMPS_IN_SCAN]; /* last DC coef for each component */
  49. } savable_state;
  50. /* This macro is to work around compilers with missing or broken
  51.  * structure assignment.  You'll need to fix this code if you have
  52.  * such a compiler and you change MAX_COMPS_IN_SCAN.
  53.  */
  54. #ifndef NO_STRUCT_ASSIGN
  55. #define ASSIGN_STATE(dest,src)  ((dest) = (src))
  56. #else
  57. #if MAX_COMPS_IN_SCAN == 4
  58. #define ASSIGN_STATE(dest,src)  
  59. ((dest).EOBRUN = (src).EOBRUN, 
  60.  (dest).last_dc_val[0] = (src).last_dc_val[0], 
  61.  (dest).last_dc_val[1] = (src).last_dc_val[1], 
  62.  (dest).last_dc_val[2] = (src).last_dc_val[2], 
  63.  (dest).last_dc_val[3] = (src).last_dc_val[3])
  64. #endif
  65. #endif
  66. typedef struct {
  67.   struct jpeg_entropy_decoder pub; /* public fields */
  68.   /* These fields are loaded into local variables at start of each MCU.
  69.    * In case of suspension, we exit WITHOUT updating them.
  70.    */
  71.   bitread_perm_state bitstate; /* Bit buffer at start of MCU */
  72.   savable_state saved; /* Other state at start of MCU */
  73.   /* These fields are NOT loaded into local working state. */
  74.   unsigned int restarts_to_go; /* MCUs left in this restart interval */
  75.   /* Pointers to derived tables (these workspaces have image lifespan) */
  76.   d_derived_tbl * derived_tbls[NUM_HUFF_TBLS];
  77.   d_derived_tbl * ac_derived_tbl; /* active table during an AC scan */
  78. } phuff_entropy_decoder;
  79. typedef phuff_entropy_decoder * phuff_entropy_ptr;
  80. /* Forward declarations */
  81. METHODDEF(boolean) decode_mcu_DC_first JPP((j_decompress_ptr cinfo,
  82.     JBLOCKROW *MCU_data));
  83. METHODDEF(boolean) decode_mcu_AC_first JPP((j_decompress_ptr cinfo,
  84.     JBLOCKROW *MCU_data));
  85. METHODDEF(boolean) decode_mcu_DC_refine JPP((j_decompress_ptr cinfo,
  86.      JBLOCKROW *MCU_data));
  87. METHODDEF(boolean) decode_mcu_AC_refine JPP((j_decompress_ptr cinfo,
  88.      JBLOCKROW *MCU_data));
  89. /*
  90.  * Initialize for a Huffman-compressed scan.
  91.  */
  92. METHODDEF(void)
  93. start_pass_phuff_decoder (j_decompress_ptr cinfo)
  94. {
  95.   phuff_entropy_ptr entropy = (phuff_entropy_ptr) cinfo->entropy;
  96.   boolean is_DC_band, bad;
  97.   int ci, coefi, tbl;
  98.   int *coef_bit_ptr;
  99.   jpeg_component_info * compptr;
  100.   is_DC_band = (cinfo->Ss == 0);
  101.   /* Validate scan parameters */
  102.   bad = FALSE;
  103.   if (is_DC_band) {
  104.     if (cinfo->Se != 0)
  105.       bad = TRUE;
  106.   } else {
  107.     /* need not check Ss/Se < 0 since they came from unsigned bytes */
  108.     if (cinfo->Ss > cinfo->Se || cinfo->Se >= DCTSIZE2)
  109.       bad = TRUE;
  110.     /* AC scans may have only one component */
  111.     if (cinfo->comps_in_scan != 1)
  112.       bad = TRUE;
  113.   }
  114.   if (cinfo->Ah != 0) {
  115.     /* Successive approximation refinement scan: must have Al = Ah-1. */
  116.     if (cinfo->Al != cinfo->Ah-1)
  117.       bad = TRUE;
  118.   }
  119.   if (cinfo->Al > 13) /* need not check for < 0 */
  120.     bad = TRUE;
  121.   if (bad)
  122.     ERREXIT4(cinfo, JERR_BAD_PROGRESSION,
  123.      cinfo->Ss, cinfo->Se, cinfo->Ah, cinfo->Al);
  124.   /* Update progression status, and verify that scan order is legal.
  125.    * Note that inter-scan inconsistencies are treated as warnings
  126.    * not fatal errors ... not clear if this is right way to behave.
  127.    */
  128.   for (ci = 0; ci < cinfo->comps_in_scan; ci++) {
  129.     int cindex = cinfo->cur_comp_info[ci]->component_index;
  130.     coef_bit_ptr = & cinfo->coef_bits[cindex][0];
  131.     if (!is_DC_band && coef_bit_ptr[0] < 0) /* AC without prior DC scan */
  132.       WARNMS2(cinfo, JWRN_BOGUS_PROGRESSION, cindex, 0);
  133.     for (coefi = cinfo->Ss; coefi <= cinfo->Se; coefi++) {
  134.       int expected = (coef_bit_ptr[coefi] < 0) ? 0 : coef_bit_ptr[coefi];
  135.       if (cinfo->Ah != expected)
  136. WARNMS2(cinfo, JWRN_BOGUS_PROGRESSION, cindex, coefi);
  137.       coef_bit_ptr[coefi] = cinfo->Al;
  138.     }
  139.   }
  140.   /* Select MCU decoding routine */
  141.   if (cinfo->Ah == 0) {
  142.     if (is_DC_band)
  143.       entropy->pub.decode_mcu = decode_mcu_DC_first;
  144.     else
  145.       entropy->pub.decode_mcu = decode_mcu_AC_first;
  146.   } else {
  147.     if (is_DC_band)
  148.       entropy->pub.decode_mcu = decode_mcu_DC_refine;
  149.     else
  150.       entropy->pub.decode_mcu = decode_mcu_AC_refine;
  151.   }
  152.   for (ci = 0; ci < cinfo->comps_in_scan; ci++) {
  153.     compptr = cinfo->cur_comp_info[ci];
  154.     /* Make sure requested tables are present, and compute derived tables.
  155.      * We may build same derived table more than once, but it's not expensive.
  156.      */
  157.     if (is_DC_band) {
  158.       if (cinfo->Ah == 0) { /* DC refinement needs no table */
  159. tbl = compptr->dc_tbl_no;
  160. if (tbl < 0 || tbl >= NUM_HUFF_TBLS ||
  161.     cinfo->dc_huff_tbl_ptrs[tbl] == NULL)
  162.   ERREXIT1(cinfo, JERR_NO_HUFF_TABLE, tbl);
  163. jpeg_make_d_derived_tbl(cinfo, cinfo->dc_huff_tbl_ptrs[tbl],
  164. & entropy->derived_tbls[tbl]);
  165.       }
  166.     } else {
  167.       tbl = compptr->ac_tbl_no;
  168.       if (tbl < 0 || tbl >= NUM_HUFF_TBLS ||
  169.           cinfo->ac_huff_tbl_ptrs[tbl] == NULL)
  170.         ERREXIT1(cinfo, JERR_NO_HUFF_TABLE, tbl);
  171.       jpeg_make_d_derived_tbl(cinfo, cinfo->ac_huff_tbl_ptrs[tbl],
  172.       & entropy->derived_tbls[tbl]);
  173.       /* remember the single active table */
  174.       entropy->ac_derived_tbl = entropy->derived_tbls[tbl];
  175.     }
  176.     /* Initialize DC predictions to 0 */
  177.     entropy->saved.last_dc_val[ci] = 0;
  178.   }
  179.   /* Initialize bitread state variables */
  180.   entropy->bitstate.bits_left = 0;
  181.   entropy->bitstate.get_buffer = 0; /* unnecessary, but keeps Purify quiet */
  182.   entropy->bitstate.printed_eod = FALSE;
  183.   /* Initialize private state variables */
  184.   entropy->saved.EOBRUN = 0;
  185.   /* Initialize restart counter */
  186.   entropy->restarts_to_go = cinfo->restart_interval;
  187. }
  188. /*
  189.  * Figure F.12: extend sign bit.
  190.  * On some machines, a shift and add will be faster than a table lookup.
  191.  */
  192. #ifdef AVOID_TABLES
  193. #define HUFF_EXTEND(x,s)  ((x) < (1<<((s)-1)) ? (x) + (((-1)<<(s)) + 1) : (x))
  194. #else
  195. #define HUFF_EXTEND(x,s)  ((x) < extend_test[s] ? (x) + extend_offset[s] : (x))
  196. static const int extend_test[16] =   /* entry n is 2**(n-1) */
  197.   { 0, 0x0001, 0x0002, 0x0004, 0x0008, 0x0010, 0x0020, 0x0040, 0x0080,
  198.     0x0100, 0x0200, 0x0400, 0x0800, 0x1000, 0x2000, 0x4000 };
  199. static const int extend_offset[16] = /* entry n is (-1 << n) + 1 */
  200.   { 0, ((-1)<<1) + 1, ((-1)<<2) + 1, ((-1)<<3) + 1, ((-1)<<4) + 1,
  201.     ((-1)<<5) + 1, ((-1)<<6) + 1, ((-1)<<7) + 1, ((-1)<<8) + 1,
  202.     ((-1)<<9) + 1, ((-1)<<10) + 1, ((-1)<<11) + 1, ((-1)<<12) + 1,
  203.     ((-1)<<13) + 1, ((-1)<<14) + 1, ((-1)<<15) + 1 };
  204. #endif /* AVOID_TABLES */
  205. /*
  206.  * Check for a restart marker & resynchronize decoder.
  207.  * Returns FALSE if must suspend.
  208.  */
  209. LOCAL(boolean)
  210. process_restart (j_decompress_ptr cinfo)
  211. {
  212.   phuff_entropy_ptr entropy = (phuff_entropy_ptr) cinfo->entropy;
  213.   int ci;
  214.   /* Throw away any unused bits remaining in bit buffer; */
  215.   /* include any full bytes in next_marker's count of discarded bytes */
  216.   cinfo->marker->discarded_bytes += entropy->bitstate.bits_left / 8;
  217.   entropy->bitstate.bits_left = 0;
  218.   /* Advance past the RSTn marker */
  219.   if (! (*cinfo->marker->read_restart_marker) (cinfo))
  220.     return FALSE;
  221.   /* Re-initialize DC predictions to 0 */
  222.   for (ci = 0; ci < cinfo->comps_in_scan; ci++)
  223.     entropy->saved.last_dc_val[ci] = 0;
  224.   /* Re-init EOB run count, too */
  225.   entropy->saved.EOBRUN = 0;
  226.   /* Reset restart counter */
  227.   entropy->restarts_to_go = cinfo->restart_interval;
  228.   /* Next segment can get another out-of-data warning */
  229.   entropy->bitstate.printed_eod = FALSE;
  230.   return TRUE;
  231. }
  232. /*
  233.  * Huffman MCU decoding.
  234.  * Each of these routines decodes and returns one MCU's worth of
  235.  * Huffman-compressed coefficients. 
  236.  * The coefficients are reordered from zigzag order into natural array order,
  237.  * but are not dequantized.
  238.  *
  239.  * The i'th block of the MCU is stored into the block pointed to by
  240.  * MCU_data[i].  WE ASSUME THIS AREA IS INITIALLY ZEROED BY THE CALLER.
  241.  *
  242.  * We return FALSE if data source requested suspension.  In that case no
  243.  * changes have been made to permanent state.  (Exception: some output
  244.  * coefficients may already have been assigned.  This is harmless for
  245.  * spectral selection, since we'll just re-assign them on the next call.
  246.  * Successive approximation AC refinement has to be more careful, however.)
  247.  */
  248. /*
  249.  * MCU decoding for DC initial scan (either spectral selection,
  250.  * or first pass of successive approximation).
  251.  */
  252. METHODDEF(boolean)
  253. decode_mcu_DC_first (j_decompress_ptr cinfo, JBLOCKROW *MCU_data)
  254. {   
  255.   phuff_entropy_ptr entropy = (phuff_entropy_ptr) cinfo->entropy;
  256.   int Al = cinfo->Al;
  257.   register int s, r;
  258.   int blkn, ci;
  259.   JBLOCKROW block;
  260.   BITREAD_STATE_VARS;
  261.   savable_state state;
  262.   d_derived_tbl * tbl;
  263.   jpeg_component_info * compptr;
  264.   /* Process restart marker if needed; may have to suspend */
  265.   if (cinfo->restart_interval) {
  266.     if (entropy->restarts_to_go == 0)
  267.       if (! process_restart(cinfo))
  268. return FALSE;
  269.   }
  270.   /* Load up working state */
  271.   BITREAD_LOAD_STATE(cinfo,entropy->bitstate);
  272.   ASSIGN_STATE(state, entropy->saved);
  273.   /* Outer loop handles each block in the MCU */
  274.   for (blkn = 0; blkn < cinfo->blocks_in_MCU; blkn++) {
  275.     block = MCU_data[blkn];
  276.     ci = cinfo->MCU_membership[blkn];
  277.     compptr = cinfo->cur_comp_info[ci];
  278.     tbl = entropy->derived_tbls[compptr->dc_tbl_no];
  279.     /* Decode a single block's worth of coefficients */
  280.     /* Section F.2.2.1: decode the DC coefficient difference */
  281.     HUFF_DECODE(s, br_state, tbl, return FALSE, label1);
  282.     if (s) {
  283.       CHECK_BIT_BUFFER(br_state, s, return FALSE);
  284.       r = GET_BITS(s);
  285.       s = HUFF_EXTEND(r, s);
  286.     }
  287.     /* Convert DC difference to actual value, update last_dc_val */
  288.     s += state.last_dc_val[ci];
  289.     state.last_dc_val[ci] = s;
  290.     /* Scale and output the DC coefficient (assumes jpeg_natural_order[0]=0) */
  291.     (*block)[0] = (JCOEF) (s << Al);
  292.   }
  293.   /* Completed MCU, so update state */
  294.   BITREAD_SAVE_STATE(cinfo,entropy->bitstate);
  295.   ASSIGN_STATE(entropy->saved, state);
  296.   /* Account for restart interval (no-op if not using restarts) */
  297.   entropy->restarts_to_go--;
  298.   return TRUE;
  299. }
  300. /*
  301.  * MCU decoding for AC initial scan (either spectral selection,
  302.  * or first pass of successive approximation).
  303.  */
  304. METHODDEF(boolean)
  305. decode_mcu_AC_first (j_decompress_ptr cinfo, JBLOCKROW *MCU_data)
  306. {   
  307.   phuff_entropy_ptr entropy = (phuff_entropy_ptr) cinfo->entropy;
  308.   int Se = cinfo->Se;
  309.   int Al = cinfo->Al;
  310.   register int s, k, r;
  311.   unsigned int EOBRUN;
  312.   JBLOCKROW block;
  313.   BITREAD_STATE_VARS;
  314.   d_derived_tbl * tbl;
  315.   /* Process restart marker if needed; may have to suspend */
  316.   if (cinfo->restart_interval) {
  317.     if (entropy->restarts_to_go == 0)
  318.       if (! process_restart(cinfo))
  319. return FALSE;
  320.   }
  321.   /* Load up working state.
  322.    * We can avoid loading/saving bitread state if in an EOB run.
  323.    */
  324.   EOBRUN = entropy->saved.EOBRUN; /* only part of saved state we care about */
  325.   /* There is always only one block per MCU */
  326.   if (EOBRUN > 0) /* if it's a band of zeroes... */
  327.     EOBRUN--; /* ...process it now (we do nothing) */
  328.   else {
  329.     BITREAD_LOAD_STATE(cinfo,entropy->bitstate);
  330.     block = MCU_data[0];
  331.     tbl = entropy->ac_derived_tbl;
  332.     for (k = cinfo->Ss; k <= Se; k++) {
  333.       HUFF_DECODE(s, br_state, tbl, return FALSE, label2);
  334.       r = s >> 4;
  335.       s &= 15;
  336.       if (s) {
  337.         k += r;
  338.         CHECK_BIT_BUFFER(br_state, s, return FALSE);
  339.         r = GET_BITS(s);
  340.         s = HUFF_EXTEND(r, s);
  341. /* Scale and output coefficient in natural (dezigzagged) order */
  342.         (*block)[jpeg_natural_order[k]] = (JCOEF) (s << Al);
  343.       } else {
  344.         if (r == 15) { /* ZRL */
  345.           k += 15; /* skip 15 zeroes in band */
  346.         } else { /* EOBr, run length is 2^r + appended bits */
  347.           EOBRUN = 1 << r;
  348.           if (r) { /* EOBr, r > 0 */
  349.     CHECK_BIT_BUFFER(br_state, r, return FALSE);
  350.             r = GET_BITS(r);
  351.             EOBRUN += r;
  352.           }
  353.   EOBRUN--; /* this band is processed at this moment */
  354.   break; /* force end-of-band */
  355. }
  356.       }
  357.     }
  358.     BITREAD_SAVE_STATE(cinfo,entropy->bitstate);
  359.   }
  360.   /* Completed MCU, so update state */
  361.   entropy->saved.EOBRUN = EOBRUN; /* only part of saved state we care about */
  362.   /* Account for restart interval (no-op if not using restarts) */
  363.   entropy->restarts_to_go--;
  364.   return TRUE;
  365. }
  366. /*
  367.  * MCU decoding for DC successive approximation refinement scan.
  368.  * Note: we assume such scans can be multi-component, although the spec
  369.  * is not very clear on the point.
  370.  */
  371. METHODDEF(boolean)
  372. decode_mcu_DC_refine (j_decompress_ptr cinfo, JBLOCKROW *MCU_data)
  373. {   
  374.   phuff_entropy_ptr entropy = (phuff_entropy_ptr) cinfo->entropy;
  375.   int p1 = 1 << cinfo->Al; /* 1 in the bit position being coded */
  376.   int blkn;
  377.   JBLOCKROW block;
  378.   BITREAD_STATE_VARS;
  379.   /* Process restart marker if needed; may have to suspend */
  380.   if (cinfo->restart_interval) {
  381.     if (entropy->restarts_to_go == 0)
  382.       if (! process_restart(cinfo))
  383. return FALSE;
  384.   }
  385.   /* Load up working state */
  386.   BITREAD_LOAD_STATE(cinfo,entropy->bitstate);
  387.   /* Outer loop handles each block in the MCU */
  388.   for (blkn = 0; blkn < cinfo->blocks_in_MCU; blkn++) {
  389.     block = MCU_data[blkn];
  390.     /* Encoded data is simply the next bit of the two's-complement DC value */
  391.     CHECK_BIT_BUFFER(br_state, 1, return FALSE);
  392.     if (GET_BITS(1))
  393.       (*block)[0] |= p1;
  394.     /* Note: since we use |=, repeating the assignment later is safe */
  395.   }
  396.   /* Completed MCU, so update state */
  397.   BITREAD_SAVE_STATE(cinfo,entropy->bitstate);
  398.   /* Account for restart interval (no-op if not using restarts) */
  399.   entropy->restarts_to_go--;
  400.   return TRUE;
  401. }
  402. /*
  403.  * MCU decoding for AC successive approximation refinement scan.
  404.  */
  405. METHODDEF(boolean)
  406. decode_mcu_AC_refine (j_decompress_ptr cinfo, JBLOCKROW *MCU_data)
  407. {   
  408.   phuff_entropy_ptr entropy = (phuff_entropy_ptr) cinfo->entropy;
  409.   int Se = cinfo->Se;
  410.   int p1 = 1 << cinfo->Al; /* 1 in the bit position being coded */
  411.   int m1 = (-1) << cinfo->Al; /* -1 in the bit position being coded */
  412.   register int s, k, r;
  413.   unsigned int EOBRUN;
  414.   JBLOCKROW block;
  415.   JCOEFPTR thiscoef;
  416.   BITREAD_STATE_VARS;
  417.   d_derived_tbl * tbl;
  418.   int num_newnz;
  419.   int newnz_pos[DCTSIZE2];
  420.   /* Process restart marker if needed; may have to suspend */
  421.   if (cinfo->restart_interval) {
  422.     if (entropy->restarts_to_go == 0)
  423.       if (! process_restart(cinfo))
  424. return FALSE;
  425.   }
  426.   /* Load up working state */
  427.   BITREAD_LOAD_STATE(cinfo,entropy->bitstate);
  428.   EOBRUN = entropy->saved.EOBRUN; /* only part of saved state we care about */
  429.   /* There is always only one block per MCU */
  430.   block = MCU_data[0];
  431.   tbl = entropy->ac_derived_tbl;
  432.   /* If we are forced to suspend, we must undo the assignments to any newly
  433.    * nonzero coefficients in the block, because otherwise we'd get confused
  434.    * next time about which coefficients were already nonzero.
  435.    * But we need not undo addition of bits to already-nonzero coefficients;
  436.    * instead, we can test the current bit position to see if we already did it.
  437.    */
  438.   num_newnz = 0;
  439.   /* initialize coefficient loop counter to start of band */
  440.   k = cinfo->Ss;
  441.   if (EOBRUN == 0) {
  442.     for (; k <= Se; k++) {
  443.       HUFF_DECODE(s, br_state, tbl, goto undoit, label3);
  444.       r = s >> 4;
  445.       s &= 15;
  446.       if (s) {
  447. if (s != 1) /* size of new coef should always be 1 */
  448.   WARNMS(cinfo, JWRN_HUFF_BAD_CODE);
  449.         CHECK_BIT_BUFFER(br_state, 1, goto undoit);
  450.         if (GET_BITS(1))
  451.   s = p1; /* newly nonzero coef is positive */
  452. else
  453.   s = m1; /* newly nonzero coef is negative */
  454.       } else {
  455. if (r != 15) {
  456.   EOBRUN = 1 << r; /* EOBr, run length is 2^r + appended bits */
  457.   if (r) {
  458.     CHECK_BIT_BUFFER(br_state, r, goto undoit);
  459.     r = GET_BITS(r);
  460.     EOBRUN += r;
  461.   }
  462.   break; /* rest of block is handled by EOB logic */
  463. }
  464. /* note s = 0 for processing ZRL */
  465.       }
  466.       /* Advance over already-nonzero coefs and r still-zero coefs,
  467.        * appending correction bits to the nonzeroes.  A correction bit is 1
  468.        * if the absolute value of the coefficient must be increased.
  469.        */
  470.       do {
  471. thiscoef = *block + jpeg_natural_order[k];
  472. if (*thiscoef != 0) {
  473.   CHECK_BIT_BUFFER(br_state, 1, goto undoit);
  474.   if (GET_BITS(1)) {
  475.     if ((*thiscoef & p1) == 0) { /* do nothing if already changed it */
  476.       if (*thiscoef >= 0)
  477. *thiscoef += p1;
  478.       else
  479. *thiscoef += m1;
  480.     }
  481.   }
  482. } else {
  483.   if (--r < 0)
  484.     break; /* reached target zero coefficient */
  485. }
  486. k++;
  487.       } while (k <= Se);
  488.       if (s) {
  489. int pos = jpeg_natural_order[k];
  490. /* Output newly nonzero coefficient */
  491. (*block)[pos] = (JCOEF) s;
  492. /* Remember its position in case we have to suspend */
  493. newnz_pos[num_newnz++] = pos;
  494.       }
  495.     }
  496.   }
  497.   if (EOBRUN > 0) {
  498.     /* Scan any remaining coefficient positions after the end-of-band
  499.      * (the last newly nonzero coefficient, if any).  Append a correction
  500.      * bit to each already-nonzero coefficient.  A correction bit is 1
  501.      * if the absolute value of the coefficient must be increased.
  502.      */
  503.     for (; k <= Se; k++) {
  504.       thiscoef = *block + jpeg_natural_order[k];
  505.       if (*thiscoef != 0) {
  506. CHECK_BIT_BUFFER(br_state, 1, goto undoit);
  507. if (GET_BITS(1)) {
  508.   if ((*thiscoef & p1) == 0) { /* do nothing if already changed it */
  509.     if (*thiscoef >= 0)
  510.       *thiscoef += p1;
  511.     else
  512.       *thiscoef += m1;
  513.   }
  514. }
  515.       }
  516.     }
  517.     /* Count one block completed in EOB run */
  518.     EOBRUN--;
  519.   }
  520.   /* Completed MCU, so update state */
  521.   BITREAD_SAVE_STATE(cinfo,entropy->bitstate);
  522.   entropy->saved.EOBRUN = EOBRUN; /* only part of saved state we care about */
  523.   /* Account for restart interval (no-op if not using restarts) */
  524.   entropy->restarts_to_go--;
  525.   return TRUE;
  526. undoit:
  527.   /* Re-zero any output coefficients that we made newly nonzero */
  528.   while (num_newnz > 0)
  529.     (*block)[newnz_pos[--num_newnz]] = 0;
  530.   return FALSE;
  531. }
  532. /*
  533.  * Module initialization routine for progressive Huffman entropy decoding.
  534.  */
  535. GLOBAL(void)
  536. jinit_phuff_decoder (j_decompress_ptr cinfo)
  537. {
  538.   phuff_entropy_ptr entropy;
  539.   int *coef_bit_ptr;
  540.   int ci, i;
  541.   entropy = (phuff_entropy_ptr)
  542.     (*cinfo->mem->alloc_small) ((j_common_ptr) cinfo, JPOOL_IMAGE,
  543. SIZEOF(phuff_entropy_decoder));
  544.   cinfo->entropy = (struct jpeg_entropy_decoder *) entropy;
  545.   entropy->pub.start_pass = start_pass_phuff_decoder;
  546.   /* Mark derived tables unallocated */
  547.   for (i = 0; i < NUM_HUFF_TBLS; i++) {
  548.     entropy->derived_tbls[i] = NULL;
  549.   }
  550.   /* Create progression status table */
  551.   cinfo->coef_bits = (int (*)[DCTSIZE2])
  552.     (*cinfo->mem->alloc_small) ((j_common_ptr) cinfo, JPOOL_IMAGE,
  553. cinfo->num_components*DCTSIZE2*SIZEOF(int));
  554.   coef_bit_ptr = & cinfo->coef_bits[0][0];
  555.   for (ci = 0; ci < cinfo->num_components; ci++) 
  556.     for (i = 0; i < DCTSIZE2; i++)
  557.       *coef_bit_ptr++ = -1;
  558. }
  559. #endif /* D_PROGRESSIVE_SUPPORTED */