NotificationsYou must be signed in to change notification settings
Fork4.9k
Star17.7k

Commitf0e37a8

committed

New CHECKPOINT command.

Auto removing of offline log files and creating new fileat checkpoint time.

1 parent7267fdd commitf0e37a8Copy full SHA for f0e37a8

File tree

11 files changed

+274

-39

lines changed

src
- backend
  - access/transam
    - xact.c
    - xlog.c
  - nodes
    - copyfuncs.c
    - equalfuncs.c
  - parser
    - gram.y
    - keywords.c
  - storage/ipc
    - sinval.c
  - tcop
    - utility.c
- include
  - access
    - xlog.h
  - nodes
    - nodes.h
    - parsenodes.h

11 files changed

+274

-39

lines changed

`‎src/backend/access/transam/xact.c`

Lines changed: 5 additions & 5 deletions

Original file line number	Diff line number	Diff line change
`@@ -8,7 +8,7 @@`
`8`	`8`	`*`
`9`	`9`	`*`
`10`	`10`	`* IDENTIFICATION`
`11`		`- * $Header: /cvsroot/pgsql/src/backend/access/transam/xact.c,v 1.79 2000/10/29 18:33:41 vadim Exp $`
	`11`	`+ * $Header: /cvsroot/pgsql/src/backend/access/transam/xact.c,v 1.80 2000/11/05 22:50:19 vadim Exp $`
`12`	`12`	`*`
`13`	`13`	`* NOTES`
`14`	`14`	`*Transaction aborts can now occur two ways:`
`@@ -678,7 +678,7 @@ RecordTransactionCommit()`
`678`	`678`	`leak=BufferPoolCheckLeak();`
`679`	`679`
`680`	`680`	`#ifdefXLOG`
`681`		`-if (MyLastRecPtr.xlogid!=0\|\|MyLastRecPtr.xrecoff!=0)`
	`681`	`+if (MyLastRecPtr.xrecoff!=0)`
`682`	`682`	`{`
`683`	`683`	`xl_xact_commitxlrec;`
`684`	`684`	`structtimevaldelay;`
`@@ -701,7 +701,6 @@ RecordTransactionCommit()`
`701`	`701`	`delay.tv_usec=CommitDelay;`
`702`	`702`	`(void)select(0,NULL,NULL,NULL,&delay);`
`703`	`703`	`XLogFlush(recptr);`
`704`		`-MyLastRecPtr.xlogid=0;`
`705`	`704`	`MyLastRecPtr.xrecoff=0;`
`706`	`705`
`707`	`706`	`TransactionIdCommit(xid);`
`@@ -836,14 +835,16 @@ RecordTransactionAbort(void)`
`836`	`835`	`TransactionIdAbort(xid);`
`837`	`836`
`838`	`837`	`#ifdefXLOG`
`839`		`-if (MyLastRecPtr.xlogid!=0\|\|MyLastRecPtr.xrecoff!=0)`
	`838`	`+if (MyLastRecPtr.xrecoff!=0)`
`840`	`839`	`{`
`841`	`840`	`xl_xact_abortxlrec;`
`842`	`841`	`XLogRecPtrrecptr;`
`843`	`842`
`844`	`843`	`xlrec.xtime=time(NULL);`
`845`	`844`	`recptr=XLogInsert(RM_XACT_ID,XLOG_XACT_ABORT,`
`846`	`845`	`(char*)&xlrec,SizeOfXactAbort,NULL,0);`
	`846`	`+`
	`847`	`+MyProc->logRec.xrecoff=0;`
`847`	`848`	`}`
`848`	`849`	`#endif`
`849`	`850`
`@@ -1189,7 +1190,6 @@ AbortTransaction(void)`
`1189`	`1190`	`AtEOXact_Files();`
`1190`	`1191`
`1191`	`1192`	`/* Here we'll rollback xaction changes */`
`1192`		`-MyLastRecPtr.xlogid=0;`
`1193`	`1193`	`MyLastRecPtr.xrecoff=0;`
`1194`	`1194`
`1195`	`1195`	`AtAbort_Locks();`

0 commit comments

Comments

(0)

Movatterモバイル変換

Navigation Menu

Search code, repositories, users, issues, pull requests...

Provide feedback

Saved searches

Use saved searches to filter your results more quickly

Uh oh!

Commitf0e37a8

File tree

11 files changed

11 files changed

`‎src/backend/access/transam/xact.c`

0 commit comments