Lines Matching refs:blkdesc
43 static CS_RETCODE _blk_rowxfer_in(CS_BLKDESC * blkdesc, CS_INT rows_to_xfer, CS_INT * rows_xferred);
44 static CS_RETCODE _blk_rowxfer_out(CS_BLKDESC * blkdesc, CS_INT rows_to_xfer, CS_INT * rows_xferred…
54 CS_BLKDESC *blkdesc; in blk_alloc() local
64 blkdesc = (CS_BLKDESC *) tds_alloc_bcpinfo(); in blk_alloc()
65 if (!blkdesc) in blk_alloc()
69 blkdesc->bcpinfo.parent = connection; in blk_alloc()
71 *blk_pointer = blkdesc; in blk_alloc()
77 blk_bind(CS_BLKDESC * blkdesc, CS_INT item, CS_DATAFMT * datafmt, CS_VOID * buffer, CS_INT * datale… in blk_bind() argument
84 …tdsdump_log(TDS_DBG_FUNC, "blk_bind(%p, %d, %p, %p, %p, %p)\n", blkdesc, item, datafmt, buffer, da… in blk_bind()
86 if (!blkdesc) { in blk_bind()
89 con = CONN(blkdesc); in blk_bind()
94 blkdesc->bcpinfo.bind_count = CS_UNUSED; in blk_bind()
95 for (i = 0; i < blkdesc->bcpinfo.bindinfo->num_cols; i++ ) { in blk_bind()
96 colinfo = blkdesc->bcpinfo.bindinfo->columns[i]; in blk_bind()
110 if (item < 1 || item > blkdesc->bcpinfo.bindinfo->num_cols) { in blk_bind()
119 colinfo = blkdesc->bcpinfo.bindinfo->columns[item - 1]; in blk_bind()
142 if (blkdesc->bcpinfo.bind_count == CS_UNUSED) { in blk_bind()
143 blkdesc->bcpinfo.bind_count = bind_count; in blk_bind()
146 if (blkdesc->bcpinfo.bind_count != bind_count) { in blk_bind()
147 _ctclient_msg(con, "blk_bind", 1, 1, 1, 137, "%d, %d", bind_count, blkdesc->bcpinfo.bind_count); in blk_bind()
154 colinfo = blkdesc->bcpinfo.bindinfo->columns[item - 1]; in blk_bind()
182 blk_default(CS_BLKDESC * blkdesc, CS_INT colnum, CS_VOID * buffer, CS_INT buflen, CS_INT * outlen) in blk_default() argument
185 …tdsdump_log(TDS_DBG_FUNC, "blk_default(%p, %d, %p, %d, %p)\n", blkdesc, colnum, buffer, buflen, ou… in blk_default()
192 blk_describe(CS_BLKDESC * blkdesc, CS_INT item, CS_DATAFMT * datafmt) in blk_describe() argument
196 tdsdump_log(TDS_DBG_FUNC, "blk_describe(%p, %d, %p)\n", blkdesc, item, datafmt); in blk_describe()
198 if (item < 1 || item > blkdesc->bcpinfo.bindinfo->num_cols) { in blk_describe()
199 _ctclient_msg(CONN(blkdesc), "blk_describe", 2, 5, 1, 141, "%s, %d", "colnum", item); in blk_describe()
203 curcol = blkdesc->bcpinfo.bindinfo->columns[item - 1]; in blk_describe()
236 blk_done(CS_BLKDESC * blkdesc, CS_INT type, CS_INT * outrow) in blk_done() argument
241 tdsdump_log(TDS_DBG_FUNC, "blk_done(%p, %d, %p)\n", blkdesc, type, outrow); in blk_done()
243 tds = CONN(blkdesc)->tds_socket; in blk_done()
248 _ctclient_msg(CONN(blkdesc), "blk_done", 2, 5, 1, 140, ""); in blk_done()
255 if (TDS_FAILED(tds_bcp_start(tds, &blkdesc->bcpinfo))) { in blk_done()
256 _ctclient_msg(CONN(blkdesc), "blk_done", 2, 5, 1, 140, ""); in blk_done()
263 _ctclient_msg(CONN(blkdesc), "blk_done", 2, 5, 1, 140, ""); in blk_done()
271 tds_deinit_bcpinfo(&blkdesc->bcpinfo); in blk_done()
273 blkdesc->bcpinfo.direction = 0; in blk_done()
274 blkdesc->bcpinfo.bind_count = CS_UNUSED; in blk_done()
275 blkdesc->bcpinfo.xfer_init = 0; in blk_done()
285 blk_drop(CS_BLKDESC * blkdesc) in blk_drop() argument
287 tdsdump_log(TDS_DBG_FUNC, "blk_drop(%p)\n", blkdesc); in blk_drop()
290 tds_free_bcpinfo(&blkdesc->bcpinfo); in blk_drop()
315 blk_init(CS_BLKDESC * blkdesc, CS_INT direction, CS_CHAR * tablename, CS_INT tnamelen) in blk_init() argument
317 tdsdump_log(TDS_DBG_FUNC, "blk_init(%p, %d, %p, %d)\n", blkdesc, direction, tablename, tnamelen); in blk_init()
319 if (!blkdesc) { in blk_init()
324 _ctclient_msg(CONN(blkdesc), "blk_init", 2, 6, 1, 138, ""); in blk_init()
329 _ctclient_msg(CONN(blkdesc), "blk_init", 2, 6, 1, 139, ""); in blk_init()
336 tds_deinit_bcpinfo(&blkdesc->bcpinfo); in blk_init()
339 if (!tds_dstr_copyn(&blkdesc->bcpinfo.tablename, tablename, tnamelen)) { in blk_init()
343 blkdesc->bcpinfo.direction = direction; in blk_init()
344 blkdesc->bcpinfo.bind_count = CS_UNUSED; in blk_init()
345 blkdesc->bcpinfo.xfer_init = 0; in blk_init()
347 if (TDS_FAILED(tds_bcp_init(CONN(blkdesc)->tds_socket, &blkdesc->bcpinfo))) { in blk_init()
348 _ctclient_msg(CONN(blkdesc), "blk_init", 2, 5, 1, 140, ""); in blk_init()
351 blkdesc->bcpinfo.bind_count = CS_UNUSED; in blk_init()
357 blk_props(CS_BLKDESC * blkdesc, CS_INT action, CS_INT property, CS_VOID * buffer, CS_INT buflen, CS… in blk_props() argument
361 …tdsdump_log(TDS_DBG_FUNC, "blk_props(%p, %d, %d, %p, %d, %p)\n", blkdesc, action, property, buffer… in blk_props()
370 blkdesc->bcpinfo.identity_insert_on = 1; in blk_props()
372 blkdesc->bcpinfo.identity_insert_on = 0; in blk_props()
377 retval = blkdesc->bcpinfo.identity_insert_on == 1 ? CS_TRUE : CS_FALSE ; in blk_props()
386 _ctclient_msg(CONN(blkdesc), "blk_props", 2, 5, 1, 141, "%s, %d", "action", action); in blk_props()
392 _ctclient_msg(CONN(blkdesc), "blk_props", 2, 5, 1, 141, "%s, %d", "property", property); in blk_props()
417 blk_rowxfer(CS_BLKDESC * blkdesc) in blk_rowxfer() argument
419 tdsdump_log(TDS_DBG_FUNC, "blk_rowxfer(%p)\n", blkdesc); in blk_rowxfer()
421 return blk_rowxfer_mult(blkdesc, NULL); in blk_rowxfer()
425 blk_rowxfer_mult(CS_BLKDESC * blkdesc, CS_INT * row_count) in blk_rowxfer_mult() argument
431 tdsdump_log(TDS_DBG_FUNC, "blk_rowxfer_mult(%p, %p)\n", blkdesc, row_count); in blk_rowxfer_mult()
434 rows_to_xfer = blkdesc->bcpinfo.bind_count; in blk_rowxfer_mult()
438 if (blkdesc->bcpinfo.direction == CS_BLK_IN) { in blk_rowxfer_mult()
439 ret = _blk_rowxfer_in(blkdesc, rows_to_xfer, &rows_xferred); in blk_rowxfer_mult()
441 ret = _blk_rowxfer_out(blkdesc, rows_to_xfer, &rows_xferred); in blk_rowxfer_mult()
450 blk_sendrow(CS_BLKDESC * blkdesc, CS_BLK_ROW * row) in blk_sendrow() argument
453 tdsdump_log(TDS_DBG_FUNC, "blk_sendrow(%p, %p)\n", blkdesc, row); in blk_sendrow()
460 blk_sendtext(CS_BLKDESC * blkdesc, CS_BLK_ROW * row, CS_BYTE * buffer, CS_INT buflen) in blk_sendtext() argument
462 tdsdump_log(TDS_DBG_FUNC, "blk_sendtext(%p, %p, %p, %d)\n", blkdesc, row, buffer, buflen); in blk_sendtext()
478 blk_textxfer(CS_BLKDESC * blkdesc, CS_BYTE * buffer, CS_INT buflen, CS_INT * outlen) in blk_textxfer() argument
480 tdsdump_log(TDS_DBG_FUNC, "blk_textxfer(%p, %p, %d, %p)\n", blkdesc, buffer, buflen, outlen); in blk_textxfer()
487 _blk_rowxfer_out(CS_BLKDESC * blkdesc, CS_INT rows_to_xfer, CS_INT * rows_xferred) in _blk_rowxfer_out() argument
494 tdsdump_log(TDS_DBG_FUNC, "_blk_rowxfer_out(%p, %d, %p)\n", blkdesc, rows_to_xfer, rows_xferred); in _blk_rowxfer_out()
496 if (!blkdesc || !CONN(blkdesc)) in _blk_rowxfer_out()
499 tds = CONN(blkdesc)->tds_socket; in _blk_rowxfer_out()
506 if (blkdesc->bcpinfo.xfer_init == 0) { in _blk_rowxfer_out()
508 …if (TDS_FAILED(tds_submit_queryf(tds, "select * from %s", tds_dstr_cstr(&blkdesc->bcpinfo.tablenam… in _blk_rowxfer_out()
509 _ctclient_msg(CONN(blkdesc), "blk_rowxfer", 2, 5, 1, 140, ""); in _blk_rowxfer_out()
519 _ctclient_msg(CONN(blkdesc), "blk_rowxfer", 2, 5, 1, 140, ""); in _blk_rowxfer_out()
523 blkdesc->bcpinfo.xfer_init = 1; in _blk_rowxfer_out()
539 …if (_ct_bind_data( CONN(blkdesc)->ctx, tds->current_results, blkdesc->bcpinfo.bindinfo, temp_count… in _blk_rowxfer_out()
551 _ctclient_msg(CONN(blkdesc), "blk_rowxfer", 2, 5, 1, 140, ""); in _blk_rowxfer_out()
561 _blk_rowxfer_in(CS_BLKDESC * blkdesc, CS_INT rows_to_xfer, CS_INT * rows_xferred) in _blk_rowxfer_in() argument
566 tdsdump_log(TDS_DBG_FUNC, "_blk_rowxfer_in(%p, %d, %p)\n", blkdesc, rows_to_xfer, rows_xferred); in _blk_rowxfer_in()
568 if (!blkdesc) in _blk_rowxfer_in()
571 tds = CONN(blkdesc)->tds_socket; in _blk_rowxfer_in()
578 if (blkdesc->bcpinfo.xfer_init == 0) { in _blk_rowxfer_in()
585 if (TDS_FAILED(tds_bcp_start_copy_in(tds, &blkdesc->bcpinfo))) { in _blk_rowxfer_in()
586 _ctclient_msg(CONN(blkdesc), "blk_rowxfer", 2, 5, 1, 140, ""); in _blk_rowxfer_in()
590 blkdesc->bcpinfo.xfer_init = 1; in _blk_rowxfer_in()
595 …if (tds_bcp_send_record(tds, &blkdesc->bcpinfo, _blk_get_col_data, _blk_null_error, each_row) == T… in _blk_rowxfer_in()
606 CS_BLKDESC *blkdesc = (CS_BLKDESC *) bcpinfo; in _blk_null_error() local
610 _ctclient_msg(CONN(blkdesc), "blk_rowxfer", 2, 7, 1, 142, "%d, %d", index + 1, offset + 1); in _blk_null_error()
625 CS_BLKDESC *blkdesc = (CS_BLKDESC *) bulk; in _blk_get_col_data() local
626 CS_CONTEXT *ctx = CONN(blkdesc)->ctx; in _blk_get_col_data()