xstrm.c
/*---------------------------------------------------------------------
 * travel_chunks - travel each chunk for the current LCR and do nothing
 *---------------------------------------------------------------------*/
travel each chunk for the current LCR and do nothing
travel each chunk for the current LCR and do nothing
static void travel_chunks(oci_t *xout_ocip)
{
  oratext *colname;
  ub2      colname_len;
  ub2      coldty;
  oraub8   col_flags;
  ub2      col_csid;
  ub4      chunk_len;
  ub1     *chunk_ptr;
  oraub8   row_flag;
  sword    err;
  sb4      rtncode;
  int chunk_cnt = 0;
  do
  {
    chunk_cnt++;
    OCICALL(xout_ocip,
            OCIXStreamOutChunkReceive(xout_ocip->svcp, xout_ocip->errp,
                                      &colname, &colname_len, &coldty,
                                      &col_flags, &col_csid, &chunk_len,
                                      &chunk_ptr, &row_flag, OCI_DEFAULT));
  } while (row_flag & OCI_XSTREAM_MORE_ROW_DATA);
}
static void travel_chunks ( oci_t * xout_ocip ) { oratext * colname ; ub2 colname_len ; ub2 coldty ; oraub8 col_flags ; ub2 col_csid ; ub4 chunk_len ; ub1 * chunk_ptr ; oraub8 row_flag ; sword err ; sb4 rtncode ; int chunk_cnt = 0 ; do { chunk_cnt ++ ; OCICALL ( xout_ocip , OCIXStreamOutChunkReceive ( xout_ocip -> svcp , xout_ocip -> errp , & colname , & colname_len , & coldty , & col_flags , & col_csid , & chunk_len , & chunk_ptr , & row_flag , OCI_DEFAULT ) ) ; } while ( row_flag & OCI_XSTREAM_MORE_ROW_DATA ) ; }
travel_chunks - travel each chunk for the current LCR and do nothing
travel_chunks - travel each chunk for the current LCR and do nothing
/* Get a chunk from outbound server */ /* print chunk data */ /* print_chunk(chunk_ptr, chunk_len, coldty); */