Cross Reference: /src/share/examples/puffs/pgfs/pgfs

Lines Matching refs:conn
59 	PGconn *conn;
126 	DPRINTF("no free conn %p\n", cc);
145 	PGconn *conn = xc->conn;
148 	if (PQflush(conn)) {
149 		errx(EXIT_FAILURE, "PQflush: %s", PQerrorMessage(conn));
151 	if (!PQisBusy(conn)) {
274 	PGconn *conn = xc->conn;
278 	res = PQgetResult(conn);
298 		    PQerrorMessage(conn));
301 	res = PQgetResult(conn);
312 	PGconn *conn = xc->conn;
322 	ret = PQsendPrepare(conn, c->name, c->cmd, c->nparams, c->paramtypes);
325 		    PQerrorMessage(conn));
345 	PGconn *conn = xc->conn;
431 		ret = PQsendQueryParams(conn, c->cmd, c->nparams, c->paramtypes,
435 		ret = PQsendQueryPrepared(conn, c->name, c->nparams,
447 		    PQerrorMessage(conn));
523 	PGconn *conn = s->xc->conn;
526 	assert(conn != NULL);
532 		s->res = PQgetResult(conn);
547 			    PQerrorMessage(conn));
630 		while ((res = PQgetResult(s->xc->conn)) != NULL) {
710 	assert(PQtransactionStatus(xc->conn) == PQTRANS_INTRANS);
727 	assert(PQtransactionStatus(xc->conn) == PQTRANS_INTRANS);
741 	status = PQtransactionStatus(xc->conn);
802 	PGconn *conn;
805 		if (PQsocket(xc->conn) == fd) {
810 	conn = xc->conn;
811 	PQconsumeInput(conn);
812 	if (!PQisBusy(conn)) {
864 		PGconn *conn;
868 		conn = PQconnectdbParams(keywords, values, 0);
869 		if (conn == NULL) {
873 		if (PQstatus(conn) != CONNECTION_OK) {
878 			    PQerrorMessage(conn));
880 		DPRINTF("protocol version %d\n", PQprotocolVersion(conn));
881 		puffs_framev_addfd(pu, PQsocket(conn), PUFFS_FBIO_READ);
883 		xc->conn = conn;
890 		PQsetNoticeReceiver(conn, pgfs_notice_receiver, xc);
OpenGrok
