#include <sys/types.h>
#include <sys/mman.h>
#include <sys/stat.h>
#include <sys/wait.h>
#include <err.h>
#include <errno.h>
#include <fcntl.h>
#include <signal.h>
#include <stdbool.h>
#include <stdint.h>
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <unistd.h>
#include <hpcfnbounds/syserv-mesg.h>
#include "client.h"
#include "disabled.h"
#include "fnbounds_file_header.h"
#include "messages.h"
#include "sample_sources_all.h"
#include "monitor.h"
Go to the source code of this file.
|
static int | read_all (int fd, void *buf, size_t count) |
|
static int | write_all (int fd, const void *buf, size_t count) |
|
static int | read_mesg (struct syserv_mesg *mesg) |
|
static int | write_mesg (int32_t type, int64_t len) |
|
static size_t | page_align (size_t size) |
|
static void * | mmap_anon (size_t size) |
|
static int | hpcrun_sigpipe_handler (int sig, siginfo_t *info, void *context) |
|
static void | shutdown_server (void) |
|
static int | launch_server (void) |
|
int | hpcrun_syserv_init (void) |
|
void | hpcrun_syserv_fini (void) |
|
void * | hpcrun_syserv_query_specific (const char *fname, struct fnbounds_file_header *fh, int query) |
|
void * | hpcrun_syserv_query (const char *fname, struct fnbounds_file_header *fh) |
|
void * | hpcrun_syserv_query_var (const char *fname, struct fnbounds_file_header *fh) |
|
◆ END_OF_FILE
◆ FAILURE
◆ MIN_NUM_QUERIES
#define MIN_NUM_QUERIES 12 |
◆ SERVER_MEM_LIMIT
#define SERVER_MEM_LIMIT 140 |
◆ SUCCESS
◆ anonymous enum
◆ hpcrun_sigpipe_handler()
static int hpcrun_sigpipe_handler |
( |
int |
sig, |
|
|
siginfo_t * |
info, |
|
|
void * |
context |
|
) |
| |
|
static |
◆ hpcrun_syserv_fini()
void hpcrun_syserv_fini |
( |
void |
| ) |
|
◆ hpcrun_syserv_init()
int hpcrun_syserv_init |
( |
void |
| ) |
|
◆ hpcrun_syserv_query()
◆ hpcrun_syserv_query_specific()
void* hpcrun_syserv_query_specific |
( |
const char * |
fname, |
|
|
struct fnbounds_file_header * |
fh, |
|
|
int |
query |
|
) |
| |
◆ hpcrun_syserv_query_var()
◆ launch_server()
static int launch_server |
( |
void |
| ) |
|
|
static |
◆ mmap_anon()
static void* mmap_anon |
( |
size_t |
size | ) |
|
|
static |
◆ page_align()
static size_t page_align |
( |
size_t |
size | ) |
|
|
static |
◆ read_all()
static int read_all |
( |
int |
fd, |
|
|
void * |
buf, |
|
|
size_t |
count |
|
) |
| |
|
static |
◆ read_mesg()
◆ shutdown_server()
static void shutdown_server |
( |
void |
| ) |
|
|
static |
◆ write_all()
static int write_all |
( |
int |
fd, |
|
|
const void * |
buf, |
|
|
size_t |
count |
|
) |
| |
|
static |
◆ write_mesg()
static int write_mesg |
( |
int32_t |
type, |
|
|
int64_t |
len |
|
) |
| |
|
static |
◆ client_status
◆ environ
◆ fdin
◆ fdout
◆ mem_limit
◆ mem_warning
◆ my_pid
◆ num_queries
◆ server
◆ server_pid