Accueil Explorer Aide
S'inscrire Connexion
OTH
/
repos_util
3
0
Fork 0
Fichiers Tickets 0 Pull Requests 0 Wiki
Aborescence: 928cff60fe
Branches Tags
repos_util
/
libpq_test
/
include
/
server
/
access
/
parallel.h

parallel.h 2.2 KB
Historique Raw

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172 
  1. /*-------------------------------------------------------------------------
    2. 

  2.  *
    3. 

  3.  * parallel.h
    4. 

  4.  *	  Infrastructure for launching parallel workers
    5. 

  5.  *
    6. 

  6.  * Portions Copyright (c) 1996-2016, PostgreSQL Global Development Group
    7. 

  7.  * Portions Copyright (c) 1994, Regents of the University of California
    8. 

  8.  *
    9. 

  9.  * src/include/access/parallel.h
    10. 

  10.  *
    11. 

  11.  *-------------------------------------------------------------------------
    12. 

  12.  */
    13. 

  13. 

  14. #ifndef PARALLEL_H
    15. 

  15. #define PARALLEL_H
    16. 

  16. 

  17. #include "access/xlogdefs.h"
    18. 

  18. #include "lib/ilist.h"
    19. 

  19. #include "postmaster/bgworker.h"
    20. 

  20. #include "storage/shm_mq.h"
    21. 

  21. #include "storage/shm_toc.h"
    22. 

  22. 

  23. typedef void (*parallel_worker_main_type) (dsm_segment *seg, shm_toc *toc);
    24. 

  24. 

  25. typedef struct ParallelWorkerInfo
    26. 

  26. {
    27. 

  27. 	BackgroundWorkerHandle *bgwhandle;
    28. 

  28. 	shm_mq_handle *error_mqh;
    29. 

  29. 	int32		pid;
    30. 

  30. } ParallelWorkerInfo;
    31. 

  31. 

  32. typedef struct ParallelContext
    33. 

  33. {
    34. 

  34. 	dlist_node	node;
    35. 

  35. 	SubTransactionId subid;
    36. 

  36. 	int			nworkers;
    37. 

  37. 	int			nworkers_launched;
    38. 

  38. 	parallel_worker_main_type entrypoint;
    39. 

  39. 	char	   *library_name;
    40. 

  40. 	char	   *function_name;
    41. 

  41. 	ErrorContextCallback *error_context_stack;
    42. 

  42. 	shm_toc_estimator estimator;
    43. 

  43. 	dsm_segment *seg;
    44. 

  44. 	void	   *private_memory;
    45. 

  45. 	shm_toc    *toc;
    46. 

  46. 	ParallelWorkerInfo *worker;
    47. 

  47. } ParallelContext;
    48. 

  48. 

  49. extern volatile bool ParallelMessagePending;
    50. 

  50. extern int	ParallelWorkerNumber;
    51. 

  51. extern bool InitializingParallelWorker;
    52. 

  52. 

  53. #define		IsParallelWorker()		(ParallelWorkerNumber >= 0)
    54. 

  54. 

  55. extern ParallelContext *CreateParallelContext(parallel_worker_main_type entrypoint, int nworkers);
    56. 

  56. extern ParallelContext *CreateParallelContextForExternalFunction(char *library_name, char *function_name, int nworkers);
    57. 

  57. extern void InitializeParallelDSM(ParallelContext *pcxt);
    58. 

  58. extern void ReinitializeParallelDSM(ParallelContext *pcxt);
    59. 

  59. extern void LaunchParallelWorkers(ParallelContext *pcxt);
    60. 

  60. extern void WaitForParallelWorkersToFinish(ParallelContext *pcxt);
    61. 

  61. extern void DestroyParallelContext(ParallelContext *pcxt);
    62. 

  62. extern bool ParallelContextActive(void);
    63. 

  63. 

  64. extern void HandleParallelMessageInterrupt(void);
    65. 

  65. extern void HandleParallelMessages(void);
    66. 

  66. extern void AtEOXact_Parallel(bool isCommit);
    67. 

  67. extern void AtEOSubXact_Parallel(bool isCommit, SubTransactionId mySubId);
    68. 

  68. extern void ParallelWorkerReportLastRecEnd(XLogRecPtr last_xlog_end);
    69. 

  69. 

  70. extern void ParallelWorkerMain(Datum main_arg);
    71. 

  71. 

  72. #endif   /* PARALLEL_H */
    73.