Function ipp_read_io

cups/ipp.c:5951–6680

 */

static ipp_state_t			/* O - Current state */
ipp_read_io(void       *src,		/* I - Data source */
	    ipp_iocb_t cb,		/* I - Read callback function */
	    int        blocking,	/* I - Use blocking IO? */
	    ipp_t      *parent,		/* I - Parent request, if any */
	    ipp_t      *ipp,		/* I - IPP data */
	    int        depth)		/* I - Depth of collection */
{
  int			n;		/* Length of data */
  unsigned char		*buffer,	/* Data buffer */
			string[IPP_MAX_TEXT],
					/* Small string buffer */
			*bufptr,	/* Pointer into buffer */
			*bufend;	/* End of buffer */
  ipp_attribute_t	*attr = NULL;	/* Current attribute */
  ipp_tag_t		tag;		/* Current tag */
  ipp_tag_t		value_tag;	/* Current value tag */
  _ipp_value_t		*value;		/* Current value */


  DEBUG_printf(("ipp_read_io(src=%p, cb=%p, blocking=%d, parent=%p, ipp=%p, depth=%d)", (void *)src, (void *)cb, blocking, (void *)parent, (void *)ipp, depth));
  DEBUG_printf(("2ipp_read_io: ipp->state=%d", ipp->state));

  if (depth > 10)
  {
    _cupsSetError(IPP_STATUS_ERROR_INTERNAL, _("IPP message nested too deeply."), 1);
    return (IPP_STATE_ERROR);
  }

  if ((buffer = (unsigned char *)_cupsBufferGet(IPP_BUF_SIZE)) == NULL)
  {
    DEBUG_puts("1ipp_read_io: Unable to get read buffer.");
    return (IPP_STATE_ERROR);
  }

  switch (ipp->state)
  {
    case IPP_STATE_IDLE :
        ipp->state ++; /* Avoid common problem... */

    case IPP_STATE_HEADER :
        if (parent == NULL)
	{
	 /*
          * Get the request header...
	  */

          if ((*cb)(src, buffer, 8) < 8)
	  {
	    DEBUG_puts("1ipp_read_io: Unable to read header.");
	    goto rollback;
	  }

	 /*
          * Then copy the request header over...
	  */

          ipp->request.any.version[0]  = buffer[0];