Home
last modified time | relevance | path

Searched refs:job_new (Results 1 – 25 of 53) sorted by relevance

123

/dports/www/firefox-esr/firefox-91.8.0/taskcluster/taskgraph/transforms/
H A Dperftest.py77 job_new = deepcopy(job)
79 job_new["perftest"] = test_symbol
80 job_new["name"] += "-" + test_symbol
88 yield job_new
142 job_new = deepcopy(job)
147 job_new["name"] += "-" + variant
151 job_new[variant] = True
153 yield job_new
177 job_new = deepcopy(job)
181 job_new["name"] += "-" + suffix
[all …]
/dports/www/firefox/firefox-99.0/taskcluster/gecko_taskgraph/transforms/
H A Dperftest.py72 job_new = deepcopy(job)
74 job_new["perftest"] = test_symbol
75 job_new["name"] += "-" + test_symbol
83 yield job_new
137 job_new = deepcopy(job)
142 job_new["name"] += "-" + variant
146 job_new[variant] = True
148 yield job_new
172 job_new = deepcopy(job)
176 job_new["name"] += "-" + suffix
[all …]
/dports/mail/thunderbird/thunderbird-91.8.0/taskcluster/taskgraph/transforms/
H A Dperftest.py77 job_new = deepcopy(job)
79 job_new["perftest"] = test_symbol
80 job_new["name"] += "-" + test_symbol
88 yield job_new
142 job_new = deepcopy(job)
147 job_new["name"] += "-" + variant
151 job_new[variant] = True
153 yield job_new
177 job_new = deepcopy(job)
181 job_new["name"] += "-" + suffix
[all …]
/dports/sysutils/lizardfs/lizardfs-3.12.0/src/chunkserver/
H A Dbgjobs.cc515 return job_new(jp,OP_INVAL,NULL,callback,extra); in job_inval()
533 return job_new(jp,OP_CHUNKOP,args,callback,extra); in job_chunkop()
545 return job_new(jp,OP_OPEN,args,callback,extra); in job_open()
557 return job_new(jp,OP_CLOSE,args,callback,extra); in job_close()
578 return job_new(jp,OP_READ,args,callback,extra); in job_read()
593 return job_new(jp,OP_PREFETCH, args, nullptr, nullptr); in job_prefetch()
613 return job_new(jp, OP_WRITE, args, callback, extra); in job_write()
627 return job_new(jp, OP_GET_BLOCKS, args, callback, extra); in job_get_blocks()
649 return job_new(jp, OP_REPLICATE, args, callback, extra); in job_replicate()
665 return job_new(jp,OP_LEGACY_REPLICATE,args,callback,extra); in job_legacy_replicate()
[all …]
/dports/sysutils/moosefs2-cgiserv/moosefs-2.0.91/mfschunkserver/
H A Dbgjobs.c390 static inline uint32_t job_new(jobpool *jp,uint32_t op,void *args,void (*callback)(uint8_t status,v… in job_new() function
563 return job_new(jp,OP_INVAL,NULL,callback,extra); in job_inval()
588 return job_new(jp,OP_CHUNKOP,args,callback,extra); in job_chunkop()
650 return job_new(jp,OP_SERV_READ,args,callback,extra); in job_serv_read()
661 return job_new(jp,OP_SERV_WRITE,args,callback,extra); in job_serv_write()
676 return job_new(jp,OP_REPLICATE,args,callback,extra); in job_replicate()
694 return job_new(jp,OP_REPLICATE,args,callback,extra); in job_replicate_simple()
705 return job_new(jp,OP_GETBLOCKS,args,callback,extra); in job_get_chunk_blocks()
716 return job_new(jp,OP_GETCHECKSUM,args,callback,extra); in job_get_chunk_checksum()
727 return job_new(jp,OP_GETCHECKSUMTAB,args,callback,extra); in job_get_chunk_checksum_tab()
/dports/sysutils/moosefs2-cgi/moosefs-2.0.91/mfschunkserver/
H A Dbgjobs.c390 static inline uint32_t job_new(jobpool *jp,uint32_t op,void *args,void (*callback)(uint8_t status,v… in job_new() function
563 return job_new(jp,OP_INVAL,NULL,callback,extra); in job_inval()
588 return job_new(jp,OP_CHUNKOP,args,callback,extra); in job_chunkop()
650 return job_new(jp,OP_SERV_READ,args,callback,extra); in job_serv_read()
661 return job_new(jp,OP_SERV_WRITE,args,callback,extra); in job_serv_write()
676 return job_new(jp,OP_REPLICATE,args,callback,extra); in job_replicate()
694 return job_new(jp,OP_REPLICATE,args,callback,extra); in job_replicate_simple()
705 return job_new(jp,OP_GETBLOCKS,args,callback,extra); in job_get_chunk_blocks()
716 return job_new(jp,OP_GETCHECKSUM,args,callback,extra); in job_get_chunk_checksum()
727 return job_new(jp,OP_GETCHECKSUMTAB,args,callback,extra); in job_get_chunk_checksum_tab()
/dports/sysutils/moosefs2-netdump/moosefs-2.0.91/mfschunkserver/
H A Dbgjobs.c390 static inline uint32_t job_new(jobpool *jp,uint32_t op,void *args,void (*callback)(uint8_t status,v… in job_new() function
563 return job_new(jp,OP_INVAL,NULL,callback,extra); in job_inval()
588 return job_new(jp,OP_CHUNKOP,args,callback,extra); in job_chunkop()
650 return job_new(jp,OP_SERV_READ,args,callback,extra); in job_serv_read()
661 return job_new(jp,OP_SERV_WRITE,args,callback,extra); in job_serv_write()
676 return job_new(jp,OP_REPLICATE,args,callback,extra); in job_replicate()
694 return job_new(jp,OP_REPLICATE,args,callback,extra); in job_replicate_simple()
705 return job_new(jp,OP_GETBLOCKS,args,callback,extra); in job_get_chunk_blocks()
716 return job_new(jp,OP_GETCHECKSUM,args,callback,extra); in job_get_chunk_checksum()
727 return job_new(jp,OP_GETCHECKSUMTAB,args,callback,extra); in job_get_chunk_checksum_tab()
/dports/sysutils/moosefs2-master/moosefs-2.0.91/mfschunkserver/
H A Dbgjobs.c390 static inline uint32_t job_new(jobpool *jp,uint32_t op,void *args,void (*callback)(uint8_t status,v… in job_new() function
563 return job_new(jp,OP_INVAL,NULL,callback,extra); in job_inval()
588 return job_new(jp,OP_CHUNKOP,args,callback,extra); in job_chunkop()
650 return job_new(jp,OP_SERV_READ,args,callback,extra); in job_serv_read()
661 return job_new(jp,OP_SERV_WRITE,args,callback,extra); in job_serv_write()
676 return job_new(jp,OP_REPLICATE,args,callback,extra); in job_replicate()
694 return job_new(jp,OP_REPLICATE,args,callback,extra); in job_replicate_simple()
705 return job_new(jp,OP_GETBLOCKS,args,callback,extra); in job_get_chunk_blocks()
716 return job_new(jp,OP_GETCHECKSUM,args,callback,extra); in job_get_chunk_checksum()
727 return job_new(jp,OP_GETCHECKSUMTAB,args,callback,extra); in job_get_chunk_checksum_tab()
/dports/sysutils/moosefs2-metalogger/moosefs-2.0.91/mfschunkserver/
H A Dbgjobs.c390 static inline uint32_t job_new(jobpool *jp,uint32_t op,void *args,void (*callback)(uint8_t status,v… in job_new() function
563 return job_new(jp,OP_INVAL,NULL,callback,extra); in job_inval()
588 return job_new(jp,OP_CHUNKOP,args,callback,extra); in job_chunkop()
650 return job_new(jp,OP_SERV_READ,args,callback,extra); in job_serv_read()
661 return job_new(jp,OP_SERV_WRITE,args,callback,extra); in job_serv_write()
676 return job_new(jp,OP_REPLICATE,args,callback,extra); in job_replicate()
694 return job_new(jp,OP_REPLICATE,args,callback,extra); in job_replicate_simple()
705 return job_new(jp,OP_GETBLOCKS,args,callback,extra); in job_get_chunk_blocks()
716 return job_new(jp,OP_GETCHECKSUM,args,callback,extra); in job_get_chunk_checksum()
727 return job_new(jp,OP_GETCHECKSUMTAB,args,callback,extra); in job_get_chunk_checksum_tab()
/dports/sysutils/moosefs2-chunkserver/moosefs-2.0.91/mfschunkserver/
H A Dbgjobs.c390 static inline uint32_t job_new(jobpool *jp,uint32_t op,void *args,void (*callback)(uint8_t status,v… in job_new() function
563 return job_new(jp,OP_INVAL,NULL,callback,extra); in job_inval()
588 return job_new(jp,OP_CHUNKOP,args,callback,extra); in job_chunkop()
650 return job_new(jp,OP_SERV_READ,args,callback,extra); in job_serv_read()
661 return job_new(jp,OP_SERV_WRITE,args,callback,extra); in job_serv_write()
676 return job_new(jp,OP_REPLICATE,args,callback,extra); in job_replicate()
694 return job_new(jp,OP_REPLICATE,args,callback,extra); in job_replicate_simple()
705 return job_new(jp,OP_GETBLOCKS,args,callback,extra); in job_get_chunk_blocks()
716 return job_new(jp,OP_GETCHECKSUM,args,callback,extra); in job_get_chunk_checksum()
727 return job_new(jp,OP_GETCHECKSUMTAB,args,callback,extra); in job_get_chunk_checksum_tab()
/dports/sysutils/moosefs2-cli/moosefs-2.0.91/mfschunkserver/
H A Dbgjobs.c390 static inline uint32_t job_new(jobpool *jp,uint32_t op,void *args,void (*callback)(uint8_t status,v… in job_new() function
563 return job_new(jp,OP_INVAL,NULL,callback,extra); in job_inval()
588 return job_new(jp,OP_CHUNKOP,args,callback,extra); in job_chunkop()
650 return job_new(jp,OP_SERV_READ,args,callback,extra); in job_serv_read()
661 return job_new(jp,OP_SERV_WRITE,args,callback,extra); in job_serv_write()
676 return job_new(jp,OP_REPLICATE,args,callback,extra); in job_replicate()
694 return job_new(jp,OP_REPLICATE,args,callback,extra); in job_replicate_simple()
705 return job_new(jp,OP_GETBLOCKS,args,callback,extra); in job_get_chunk_blocks()
716 return job_new(jp,OP_GETCHECKSUM,args,callback,extra); in job_get_chunk_checksum()
727 return job_new(jp,OP_GETCHECKSUMTAB,args,callback,extra); in job_get_chunk_checksum_tab()
/dports/sysutils/moosefs2-client/moosefs-2.0.91/mfschunkserver/
H A Dbgjobs.c390 static inline uint32_t job_new(jobpool *jp,uint32_t op,void *args,void (*callback)(uint8_t status,v… in job_new() function
563 return job_new(jp,OP_INVAL,NULL,callback,extra); in job_inval()
588 return job_new(jp,OP_CHUNKOP,args,callback,extra); in job_chunkop()
650 return job_new(jp,OP_SERV_READ,args,callback,extra); in job_serv_read()
661 return job_new(jp,OP_SERV_WRITE,args,callback,extra); in job_serv_write()
676 return job_new(jp,OP_REPLICATE,args,callback,extra); in job_replicate()
694 return job_new(jp,OP_REPLICATE,args,callback,extra); in job_replicate_simple()
705 return job_new(jp,OP_GETBLOCKS,args,callback,extra); in job_get_chunk_blocks()
716 return job_new(jp,OP_GETCHECKSUM,args,callback,extra); in job_get_chunk_checksum()
727 return job_new(jp,OP_GETCHECKSUMTAB,args,callback,extra); in job_get_chunk_checksum_tab()
/dports/sysutils/moosefs3-master/moosefs-3.0.116/mfschunkserver/
H A Dbgjobs.c409 static inline uint32_t job_new(jobpool *jp,uint32_t op,void *args,void (*callback)(uint8_t status,v… in job_new() function
627 return job_new(jp,OP_INVAL,NULL,callback,extra,MFS_ERROR_EINVAL,JOB_MODE_LIMITED_QUEUE); in job_inval()
652 return job_new(jp,OP_CHUNKOP,args,callback,extra,MFS_ERROR_NOTDONE,JOB_MODE_LIMITED_QUEUE); in job_chunkop()
714 return job_new(jp,OP_SERV_READ,args,callback,extra,0,JOB_MODE_LIMITED_RETURN); in job_serv_read()
725 return job_new(jp,OP_SERV_WRITE,args,callback,extra,0,JOB_MODE_LIMITED_RETURN); in job_serv_write()
744 return job_new(jp,OP_REPLICATE,args,callback,extra,MFS_ERROR_NOTDONE,JOB_MODE_LIMITED_QUEUE); in job_replicate_raid()
766 return job_new(jp,OP_REPLICATE,args,callback,extra,MFS_ERROR_NOTDONE,JOB_MODE_LIMITED_QUEUE); in job_replicate_simple()
777 return job_new(jp,OP_GETBLOCKS,args,callback,extra,MFS_ERROR_NOTDONE,JOB_MODE_LIMITED_QUEUE); in job_get_chunk_blocks()
788 return job_new(jp,OP_GETCHECKSUM,args,callback,extra,MFS_ERROR_NOTDONE,JOB_MODE_LIMITED_QUEUE); in job_get_chunk_checksum()
799 return job_new(jp,OP_GETCHECKSUMTAB,args,callback,extra,MFS_ERROR_NOTDONE,JOB_MODE_LIMITED_QUEUE); in job_get_chunk_checksum_tab()
[all …]
/dports/sysutils/moosefs3-netdump/moosefs-3.0.116/mfschunkserver/
H A Dbgjobs.c409 static inline uint32_t job_new(jobpool *jp,uint32_t op,void *args,void (*callback)(uint8_t status,v… in job_new() function
627 return job_new(jp,OP_INVAL,NULL,callback,extra,MFS_ERROR_EINVAL,JOB_MODE_LIMITED_QUEUE); in job_inval()
652 return job_new(jp,OP_CHUNKOP,args,callback,extra,MFS_ERROR_NOTDONE,JOB_MODE_LIMITED_QUEUE); in job_chunkop()
714 return job_new(jp,OP_SERV_READ,args,callback,extra,0,JOB_MODE_LIMITED_RETURN); in job_serv_read()
725 return job_new(jp,OP_SERV_WRITE,args,callback,extra,0,JOB_MODE_LIMITED_RETURN); in job_serv_write()
744 return job_new(jp,OP_REPLICATE,args,callback,extra,MFS_ERROR_NOTDONE,JOB_MODE_LIMITED_QUEUE); in job_replicate_raid()
766 return job_new(jp,OP_REPLICATE,args,callback,extra,MFS_ERROR_NOTDONE,JOB_MODE_LIMITED_QUEUE); in job_replicate_simple()
777 return job_new(jp,OP_GETBLOCKS,args,callback,extra,MFS_ERROR_NOTDONE,JOB_MODE_LIMITED_QUEUE); in job_get_chunk_blocks()
788 return job_new(jp,OP_GETCHECKSUM,args,callback,extra,MFS_ERROR_NOTDONE,JOB_MODE_LIMITED_QUEUE); in job_get_chunk_checksum()
799 return job_new(jp,OP_GETCHECKSUMTAB,args,callback,extra,MFS_ERROR_NOTDONE,JOB_MODE_LIMITED_QUEUE); in job_get_chunk_checksum_tab()
[all …]
/dports/sysutils/moosefs3-cgi/moosefs-3.0.116/mfschunkserver/
H A Dbgjobs.c409 static inline uint32_t job_new(jobpool *jp,uint32_t op,void *args,void (*callback)(uint8_t status,v… in job_new() function
627 return job_new(jp,OP_INVAL,NULL,callback,extra,MFS_ERROR_EINVAL,JOB_MODE_LIMITED_QUEUE); in job_inval()
652 return job_new(jp,OP_CHUNKOP,args,callback,extra,MFS_ERROR_NOTDONE,JOB_MODE_LIMITED_QUEUE); in job_chunkop()
714 return job_new(jp,OP_SERV_READ,args,callback,extra,0,JOB_MODE_LIMITED_RETURN); in job_serv_read()
725 return job_new(jp,OP_SERV_WRITE,args,callback,extra,0,JOB_MODE_LIMITED_RETURN); in job_serv_write()
744 return job_new(jp,OP_REPLICATE,args,callback,extra,MFS_ERROR_NOTDONE,JOB_MODE_LIMITED_QUEUE); in job_replicate_raid()
766 return job_new(jp,OP_REPLICATE,args,callback,extra,MFS_ERROR_NOTDONE,JOB_MODE_LIMITED_QUEUE); in job_replicate_simple()
777 return job_new(jp,OP_GETBLOCKS,args,callback,extra,MFS_ERROR_NOTDONE,JOB_MODE_LIMITED_QUEUE); in job_get_chunk_blocks()
788 return job_new(jp,OP_GETCHECKSUM,args,callback,extra,MFS_ERROR_NOTDONE,JOB_MODE_LIMITED_QUEUE); in job_get_chunk_checksum()
799 return job_new(jp,OP_GETCHECKSUMTAB,args,callback,extra,MFS_ERROR_NOTDONE,JOB_MODE_LIMITED_QUEUE); in job_get_chunk_checksum_tab()
[all …]
/dports/sysutils/moosefs3-cgiserv/moosefs-3.0.116/mfschunkserver/
H A Dbgjobs.c409 static inline uint32_t job_new(jobpool *jp,uint32_t op,void *args,void (*callback)(uint8_t status,v… in job_new() function
627 return job_new(jp,OP_INVAL,NULL,callback,extra,MFS_ERROR_EINVAL,JOB_MODE_LIMITED_QUEUE); in job_inval()
652 return job_new(jp,OP_CHUNKOP,args,callback,extra,MFS_ERROR_NOTDONE,JOB_MODE_LIMITED_QUEUE); in job_chunkop()
714 return job_new(jp,OP_SERV_READ,args,callback,extra,0,JOB_MODE_LIMITED_RETURN); in job_serv_read()
725 return job_new(jp,OP_SERV_WRITE,args,callback,extra,0,JOB_MODE_LIMITED_RETURN); in job_serv_write()
744 return job_new(jp,OP_REPLICATE,args,callback,extra,MFS_ERROR_NOTDONE,JOB_MODE_LIMITED_QUEUE); in job_replicate_raid()
766 return job_new(jp,OP_REPLICATE,args,callback,extra,MFS_ERROR_NOTDONE,JOB_MODE_LIMITED_QUEUE); in job_replicate_simple()
777 return job_new(jp,OP_GETBLOCKS,args,callback,extra,MFS_ERROR_NOTDONE,JOB_MODE_LIMITED_QUEUE); in job_get_chunk_blocks()
788 return job_new(jp,OP_GETCHECKSUM,args,callback,extra,MFS_ERROR_NOTDONE,JOB_MODE_LIMITED_QUEUE); in job_get_chunk_checksum()
799 return job_new(jp,OP_GETCHECKSUMTAB,args,callback,extra,MFS_ERROR_NOTDONE,JOB_MODE_LIMITED_QUEUE); in job_get_chunk_checksum_tab()
[all …]
/dports/sysutils/moosefs3-cli/moosefs-3.0.116/mfschunkserver/
H A Dbgjobs.c409 static inline uint32_t job_new(jobpool *jp,uint32_t op,void *args,void (*callback)(uint8_t status,v… in job_new() function
627 return job_new(jp,OP_INVAL,NULL,callback,extra,MFS_ERROR_EINVAL,JOB_MODE_LIMITED_QUEUE); in job_inval()
652 return job_new(jp,OP_CHUNKOP,args,callback,extra,MFS_ERROR_NOTDONE,JOB_MODE_LIMITED_QUEUE); in job_chunkop()
714 return job_new(jp,OP_SERV_READ,args,callback,extra,0,JOB_MODE_LIMITED_RETURN); in job_serv_read()
725 return job_new(jp,OP_SERV_WRITE,args,callback,extra,0,JOB_MODE_LIMITED_RETURN); in job_serv_write()
744 return job_new(jp,OP_REPLICATE,args,callback,extra,MFS_ERROR_NOTDONE,JOB_MODE_LIMITED_QUEUE); in job_replicate_raid()
766 return job_new(jp,OP_REPLICATE,args,callback,extra,MFS_ERROR_NOTDONE,JOB_MODE_LIMITED_QUEUE); in job_replicate_simple()
777 return job_new(jp,OP_GETBLOCKS,args,callback,extra,MFS_ERROR_NOTDONE,JOB_MODE_LIMITED_QUEUE); in job_get_chunk_blocks()
788 return job_new(jp,OP_GETCHECKSUM,args,callback,extra,MFS_ERROR_NOTDONE,JOB_MODE_LIMITED_QUEUE); in job_get_chunk_checksum()
799 return job_new(jp,OP_GETCHECKSUMTAB,args,callback,extra,MFS_ERROR_NOTDONE,JOB_MODE_LIMITED_QUEUE); in job_get_chunk_checksum_tab()
[all …]
/dports/sysutils/moosefs3-chunkserver/moosefs-3.0.116/mfschunkserver/
H A Dbgjobs.c409 static inline uint32_t job_new(jobpool *jp,uint32_t op,void *args,void (*callback)(uint8_t status,v… in job_new() function
627 return job_new(jp,OP_INVAL,NULL,callback,extra,MFS_ERROR_EINVAL,JOB_MODE_LIMITED_QUEUE); in job_inval()
652 return job_new(jp,OP_CHUNKOP,args,callback,extra,MFS_ERROR_NOTDONE,JOB_MODE_LIMITED_QUEUE); in job_chunkop()
714 return job_new(jp,OP_SERV_READ,args,callback,extra,0,JOB_MODE_LIMITED_RETURN); in job_serv_read()
725 return job_new(jp,OP_SERV_WRITE,args,callback,extra,0,JOB_MODE_LIMITED_RETURN); in job_serv_write()
744 return job_new(jp,OP_REPLICATE,args,callback,extra,MFS_ERROR_NOTDONE,JOB_MODE_LIMITED_QUEUE); in job_replicate_raid()
766 return job_new(jp,OP_REPLICATE,args,callback,extra,MFS_ERROR_NOTDONE,JOB_MODE_LIMITED_QUEUE); in job_replicate_simple()
777 return job_new(jp,OP_GETBLOCKS,args,callback,extra,MFS_ERROR_NOTDONE,JOB_MODE_LIMITED_QUEUE); in job_get_chunk_blocks()
788 return job_new(jp,OP_GETCHECKSUM,args,callback,extra,MFS_ERROR_NOTDONE,JOB_MODE_LIMITED_QUEUE); in job_get_chunk_checksum()
799 return job_new(jp,OP_GETCHECKSUMTAB,args,callback,extra,MFS_ERROR_NOTDONE,JOB_MODE_LIMITED_QUEUE); in job_get_chunk_checksum_tab()
[all …]
/dports/sysutils/moosefs3-metalogger/moosefs-3.0.116/mfschunkserver/
H A Dbgjobs.c409 static inline uint32_t job_new(jobpool *jp,uint32_t op,void *args,void (*callback)(uint8_t status,v… in job_new() function
627 return job_new(jp,OP_INVAL,NULL,callback,extra,MFS_ERROR_EINVAL,JOB_MODE_LIMITED_QUEUE); in job_inval()
652 return job_new(jp,OP_CHUNKOP,args,callback,extra,MFS_ERROR_NOTDONE,JOB_MODE_LIMITED_QUEUE); in job_chunkop()
714 return job_new(jp,OP_SERV_READ,args,callback,extra,0,JOB_MODE_LIMITED_RETURN); in job_serv_read()
725 return job_new(jp,OP_SERV_WRITE,args,callback,extra,0,JOB_MODE_LIMITED_RETURN); in job_serv_write()
744 return job_new(jp,OP_REPLICATE,args,callback,extra,MFS_ERROR_NOTDONE,JOB_MODE_LIMITED_QUEUE); in job_replicate_raid()
766 return job_new(jp,OP_REPLICATE,args,callback,extra,MFS_ERROR_NOTDONE,JOB_MODE_LIMITED_QUEUE); in job_replicate_simple()
777 return job_new(jp,OP_GETBLOCKS,args,callback,extra,MFS_ERROR_NOTDONE,JOB_MODE_LIMITED_QUEUE); in job_get_chunk_blocks()
788 return job_new(jp,OP_GETCHECKSUM,args,callback,extra,MFS_ERROR_NOTDONE,JOB_MODE_LIMITED_QUEUE); in job_get_chunk_checksum()
799 return job_new(jp,OP_GETCHECKSUMTAB,args,callback,extra,MFS_ERROR_NOTDONE,JOB_MODE_LIMITED_QUEUE); in job_get_chunk_checksum_tab()
[all …]
/dports/sysutils/moosefs3-client/moosefs-3.0.116/mfschunkserver/
H A Dbgjobs.c409 static inline uint32_t job_new(jobpool *jp,uint32_t op,void *args,void (*callback)(uint8_t status,v… in job_new() function
627 return job_new(jp,OP_INVAL,NULL,callback,extra,MFS_ERROR_EINVAL,JOB_MODE_LIMITED_QUEUE); in job_inval()
652 return job_new(jp,OP_CHUNKOP,args,callback,extra,MFS_ERROR_NOTDONE,JOB_MODE_LIMITED_QUEUE); in job_chunkop()
714 return job_new(jp,OP_SERV_READ,args,callback,extra,0,JOB_MODE_LIMITED_RETURN); in job_serv_read()
725 return job_new(jp,OP_SERV_WRITE,args,callback,extra,0,JOB_MODE_LIMITED_RETURN); in job_serv_write()
744 return job_new(jp,OP_REPLICATE,args,callback,extra,MFS_ERROR_NOTDONE,JOB_MODE_LIMITED_QUEUE); in job_replicate_raid()
766 return job_new(jp,OP_REPLICATE,args,callback,extra,MFS_ERROR_NOTDONE,JOB_MODE_LIMITED_QUEUE); in job_replicate_simple()
777 return job_new(jp,OP_GETBLOCKS,args,callback,extra,MFS_ERROR_NOTDONE,JOB_MODE_LIMITED_QUEUE); in job_get_chunk_blocks()
788 return job_new(jp,OP_GETCHECKSUM,args,callback,extra,MFS_ERROR_NOTDONE,JOB_MODE_LIMITED_QUEUE); in job_get_chunk_checksum()
799 return job_new(jp,OP_GETCHECKSUMTAB,args,callback,extra,MFS_ERROR_NOTDONE,JOB_MODE_LIMITED_QUEUE); in job_get_chunk_checksum_tab()
[all …]
/dports/devel/elixir-quantum/quantum-elixir-2.2.6/test/quantum/
H A Dexecution_broadcaster_test.exs114 job_new =
123 TestProducer.send(producer, {:add, job_new})
134 job_new =
140 TestProducer.send(producer, {:add, job_new})
142 assert_receive {:received, {:execute, ^job_new}}, @max_timeout
/dports/net/py-avahi/avahi-0.8/avahi-core/
H A Dresponse-sched.c77 static AvahiResponseJob* job_new(AvahiResponseScheduler *s, AvahiRecord *record, AvahiResponseJobSt… in job_new() function
415 if (!(rj = job_new(s, record, AVAHI_SCHEDULED))) in avahi_response_scheduler_post()
457 if (!(rj = job_new(s, record, AVAHI_DONE))) in avahi_response_scheduler_incoming()
495 if (!(rj = job_new(s, record, AVAHI_SUPPRESSED))) in avahi_response_scheduler_suppress()
/dports/net/avahi-libdns/avahi-0.8/avahi-core/
H A Dresponse-sched.c77 static AvahiResponseJob* job_new(AvahiResponseScheduler *s, AvahiRecord *record, AvahiResponseJobSt… in job_new() function
415 if (!(rj = job_new(s, record, AVAHI_SCHEDULED))) in avahi_response_scheduler_post()
457 if (!(rj = job_new(s, record, AVAHI_DONE))) in avahi_response_scheduler_incoming()
495 if (!(rj = job_new(s, record, AVAHI_SUPPRESSED))) in avahi_response_scheduler_suppress()
/dports/net/avahi-sharp/avahi-0.8/avahi-core/
H A Dresponse-sched.c77 static AvahiResponseJob* job_new(AvahiResponseScheduler *s, AvahiRecord *record, AvahiResponseJobSt… in job_new() function
415 if (!(rj = job_new(s, record, AVAHI_SCHEDULED))) in avahi_response_scheduler_post()
457 if (!(rj = job_new(s, record, AVAHI_DONE))) in avahi_response_scheduler_incoming()
495 if (!(rj = job_new(s, record, AVAHI_SUPPRESSED))) in avahi_response_scheduler_suppress()
/dports/net/avahi-app/avahi-0.8/avahi-core/
H A Dresponse-sched.c77 static AvahiResponseJob* job_new(AvahiResponseScheduler *s, AvahiRecord *record, AvahiResponseJobSt… in job_new() function
415 if (!(rj = job_new(s, record, AVAHI_SCHEDULED))) in avahi_response_scheduler_post()
457 if (!(rj = job_new(s, record, AVAHI_DONE))) in avahi_response_scheduler_incoming()
495 if (!(rj = job_new(s, record, AVAHI_SUPPRESSED))) in avahi_response_scheduler_suppress()

123