-
Notifications
You must be signed in to change notification settings - Fork 0
/
task_states.h
71 lines (60 loc) · 1.44 KB
/
task_states.h
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
/*-------------------------------------------------------------------------
*
* task_states.h
* definition of task state functions
*
* Copyright (c) 2010-2015, Citus Data, Inc.
*
*-------------------------------------------------------------------------
*/
#ifndef TASK_STATES_H
#define TASK_STATES_H
#include "job_metadata.h"
#include "libpq-fe.h"
#include "postmaster/bgworker.h"
#include "storage/dsm.h"
#include "storage/shm_mq.h"
#include "utils/timestamp.h"
typedef enum
{
CRON_TASK_WAITING = 0,
CRON_TASK_START = 1,
CRON_TASK_CONNECTING = 2,
CRON_TASK_SENDING = 3,
CRON_TASK_RUNNING = 4,
CRON_TASK_RECEIVING = 5,
CRON_TASK_DONE = 6,
CRON_TASK_ERROR = 7,
CRON_TASK_BGW_START = 8,
CRON_TASK_BGW_RUNNING = 9
} CronTaskState;
struct BackgroundWorkerHandle
{
int slot;
uint64 generation;
};
typedef struct CronTask
{
int64 jobId;
int64 runId;
CronTaskState state;
unsigned int pendingRunCount;
PGconn *connection;
PostgresPollingStatusType pollingStatus;
TimestampTz startDeadline;
TimestampTz lastStartTime;
uint32 secondsInterval;
bool isSocketReady;
bool isActive;
char *errorMessage;
bool freeErrorMessage;
shm_mq_handle *sharedMemoryQueue;
dsm_segment *seg;
BackgroundWorkerHandle handle;
} CronTask;
extern void InitializeTaskStateHash(void);
extern void RefreshTaskHash(void);
extern List * CurrentTaskList(void);
extern void InitializeCronTask(CronTask *task, int64 jobId);
extern void RemoveTask(int64 jobId);
#endif