return 0;
    }
    blob_append(pBlob, rbuf, read);
  }
  return blob_size(pBlob);
}
#endif

/*
** zLine is a line from the header of an HTTP reply.  Find the
** "argument" to this header line.  The argument is the first non-whitespace
** character following the first ":" in the line.  The argument consists of
** non-whitespace and non-semicolon characters.  Zero-terminate the argument
** before returning.
*/
static char *header_arg(char *zIn){
  char *z;
  while( *zIn && *zIn!=':' ){ zIn++; }
  if( *zIn==':' ){ zIn++; }
  while( isspace(*zIn) ){ zIn++; }
  for(z=zIn; *z && *z!=';' && !isspace(*z); z++){}
  *z = 0;
  return zIn;
}

/*
** Make a single attempt to talk to the server.  Return TRUE on success
** and FALSE on a failure.
**
** pHeader contains the HTTP header.  pPayload contains the content.
** The content of the reply is written into pReply.  pReply is assumed
** to be uninitialized prior to this call.
**
** pPayload has already been compressed and/or encrypted prior to being
** passed into this function.  pReply will be decrypted and/or decompressed
** as required by this function, based on the Content-Type of the reply.
**
** If an error occurs, this routine return false, resets pReply and
** closes the persistent connection, if any.
*/
static int http_send_recv(Blob *pHeader, Blob *pPayload, Blob *pReply){
  int closeConnection=1;   /* default to closing the connection */
  int rc;
  int iLength;
  int iHttpVersion;
  int i;
  int nRead;
  int needDecrypt = 0;
  int needDecompress = 0;
  char zLine[2000];

  if( pSocket==0 && http_open_socket() ){
    return 0;
  }
  iLength = -1;
#ifdef __MINGW32__

      if( sscanf(zLine, "HTTP/1.%d %d", &iHttpVersion, &rc)!=2 ) goto write_err;
      if( rc!=200 ) goto write_err;
      if( iHttpVersion==0 ){
        closeConnection = 1;
      }else{
        closeConnection = 0;
      }
    }else if( strncasecmp(zLine,"content-length:",15)==0 ){
      iLength = atoi(header_arg(zLine));
    }else if( strncasecmp(zLine, "connection:", 11)==0 ){
      int c = header_arg(zLine)[0];
      if( c=='c' || c=='C' ){
        closeConnection = 1;   /* Connection: close */
      }else if( c=='k' || c=='K' ){
        closeConnection = 0;   /* Connection: keep-alive */
      }
    }else if( strncasecmp(zLine, "content-type:", 13)==0 ){
      const char *zType = header_arg(zLine);
      if( strcmp(zType, "application/x-fossil")==0 ){
        needDecompress = 1;
        needDecrypt = 0;
      }else if( strcmp(zType, "application/x-fossil-secure")==0 ){
        needDecompress = 1;
        needDecrypt = 1;
      }
    }      
  }
  if( iLength<0 ) goto write_err;
  nRead = socket_read_blob(pReply, pSocket, iLength);
#else
  rc = fwrite(blob_buffer(pHeader), 1, blob_size(pHeader), pSocket);
  if( rc!=blob_size(pHeader) ) goto write_err;
  rc = fwrite(blob_buffer(pPayload), 1, blob_size(pPayload), pSocket);

    closeConnection = 0;   /* Connection: keep-alive */
  }
  while( fgets(zLine, sizeof(zLine), pSocket) ){
    for(i=0; zLine[i] && zLine[i]!='\n' && zLine[i]!='\r'; i++){}
    if( i==0 ) break;
    zLine[i] = 0;
    if( strncasecmp(zLine,"content-length:",15)==0 ){
      iLength = atoi(header_arg(zLine));
    }else if( strncasecmp(zLine, "connection:", 11)==0 ){
      int c = header_arg(zLine)[0];
      if( c=='c' || c=='C' ){
        closeConnection = 1;   /* Connection: close */
      }else if( c=='k' || c=='K' ){
        closeConnection = 0;   /* Connection: keep-alive */
      }
    }else if( strncasecmp(zLine, "content-type:", 13)==0 ){
      const char *zType = header_arg(zLine);
      if( strcmp(zType, "application/x-fossil")==0 ){
        needDecompress = 1;
        needDecrypt = 0;
      }else if( strcmp(zType, "application/x-fossil-secure")==0 ){
        needDecompress = 1;
        needDecrypt = 1;
      }
    }      
  }
  if( iLength<0 ) goto write_err;
  nRead = blob_read_from_channel(pReply, pSocket, iLength);
#endif
  if( nRead!=iLength ){
    blob_reset(pReply);
    goto write_err;
  }
  if( closeConnection ){
    http_close();
  }
  if( needDecrypt ){
    blob_decrypt(pReply, g.urlPasswd, pReply);
  }
  if( needDecompress ){
    blob_uncompress(pReply, pReply);
  }
  return 1;  

write_err:
  http_close();
  return 0;
}

  }        
  blob_reset(&nonce);
  blob_reset(&pw);
  blob_reset(&sig);

  /* Construct the payload, which includes the login card.
  */
  if( g.fHttpSecure && g.urlPasswd[0] ){
    blob_compress(pSend, pSend);
    payload = login;
    blob_encrypt(pSend, g.urlPasswd, &payload);
  }else if( g.fHttpTrace ){
    payload = login;
    blob_append(&payload, blob_buffer(pSend), blob_size(pSend));
  }else{
    blob_compress2(&login, pSend, &payload);
    blob_reset(&login);
  }

  /* Construct the HTTP request header
  */
  blob_zero(&hdr);
  i = strlen(g.urlPath);
  if( i>0 && g.urlPath[i-1]=='/' ){
    zSep = "";
  }else{
    zSep = "/";
  }
  blob_appendf(&hdr, "POST %s%sxfer HTTP/1.1\r\n", g.urlPath, zSep);
  blob_appendf(&hdr, "Host: %s\r\n", g.urlHostname);
  blob_appendf(&hdr, "User-Agent: Fossil/" MANIFEST_VERSION "\r\n");
  if( g.fHttpSecure && g.urlPasswd[0] ){
    blob_appendf(&hdr, "Content-Type: application/x-fossil-secure\r\n");
  }else if( g.fHttpTrace ){
    blob_appendf(&hdr, "Content-Type: application/x-fossil-debug\r\n");
  }else{
    blob_appendf(&hdr, "Content-Type: application/x-fossil\r\n");
  }
  blob_appendf(&hdr, "Content-Length: %d\r\n\r\n", blob_size(&payload));

  if( g.fHttpTrace ){

  if( cnt>=2 ){
    fossil_fatal("connection to server failed");
  }
  blob_reset(&hdr);
  blob_reset(&payload);

  /* Process the reply.  pRecv contains only the payload of the
  ** reply message, not the header.  pRecv has already been decrypted
  ** and decompressed
  */
  if( g.fHttpTrace ){
    printf("HTTP RECEIVE:\n%s\n=======================\n", blob_str(pRecv));


  }
}


/*
** Make sure the socket to the HTTP server is closed 
*/